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

Merge branch 'ssu-sync-fix' into 'master'

Browse Source 
lock locked_shouldSend on this

See merge request i2p-hackers/i2p.i2p!3
This commit is contained in:
Zlatin Balevsky
2020-12-18 13:48:40 +00:00
parent 56059448c5 66b724759d
commit a9b6b86183
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1662,9 +1662,10 @@ public class PeerState {
} }
/** /**
* Caller should synch * Locks this.
*/ */
private boolean locked_shouldSend(OutboundMessageState state, long now, boolean resetWindow) { private boolean locked_shouldSend(OutboundMessageState state, long now, boolean resetWindow) {
synchronized(this) {
if (allocateSendingBytes(state, now, resetWindow)) { if (allocateSendingBytes(state, now, resetWindow)) {
if (_log.shouldLog(Log.DEBUG)) if (_log.shouldLog(Log.DEBUG))
_log.debug(_remotePeer + " Allocation allowed with " _log.debug(_remotePeer + " Allocation allowed with "
@@ -1683,6 +1684,7 @@ public class PeerState {
+ " for message " + state.getMessageId() + ": " + state); + " for message " + state.getMessageId() + ": " + state);
return false; return false;
} }
}
} }
/** /**