lbt/i2p.i2p
1
0
Fork 0
forked from I2P_Developers/i2p.i2p
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

SSU: Fix restoration of window after failed message

Browse Source 
Reported by and adapted from patch by zlatinb
This commit is contained in:
zzz
2020-12-27 08:50:11 -05:00
parent 8606d30e9a
commit a2734ffa72
1 changed files with 11 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
router/java/src/net/i2p/router/transport/udp/PeerState.java
View File

@ -1434,18 +1434,18 @@ public class PeerState {
if (_log.shouldLog(Log.WARN))
_log.warn("Unable to send a direct message: " + state + " to: " + this);
}
if (failedSize > 0) {
// restore the window
synchronized(this) {
// this isn't exactly right, because some fragments may not have been sent at all,
// but that should be unlikely
_sendWindowBytesRemaining += failedSize;
_sendWindowBytesRemaining += failedCount * fragmentOverhead();
if (_sendWindowBytesRemaining > _sendWindowBytes)
_sendWindowBytesRemaining = _sendWindowBytes;
}
// no need to nudge(), this is called from OMF loop before allocateSend()
}
if (failedSize > 0) {
// restore the window
synchronized(this) {
// this isn't exactly right, because some fragments may not have been sent at all,
// but that should be unlikely
_sendWindowBytesRemaining += failedSize;
_sendWindowBytesRemaining += failedCount * fragmentOverhead();
if (_sendWindowBytesRemaining > _sendWindowBytes)
_sendWindowBytesRemaining = _sendWindowBytes;
}
// no need to nudge(), this is called from OMF loop before allocateSend()
}
}