From 66b724759db708af9a6ac3004e3d8117a28758d5 Mon Sep 17 00:00:00 2001
From: Zlatin Balevsky <zlatinb@gmail.com>
Date: Fri, 18 Dec 2020 09:03:52 +0000
Subject: [PATCH] lock locked_shouldSend on this
---
router/java/src/net/i2p/router/transport/udp/PeerState.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/router/java/src/net/i2p/router/transport/udp/PeerState.java b/router/java/src/net/i2p/router/transport/udp/PeerState.java
index 77a952b03b..9ca1191599 100644
--- a/router/java/src/net/i2p/router/transport/udp/PeerState.java
+++ b/router/java/src/net/i2p/router/transport/udp/PeerState.java
@@ -1662,9 +1662,10 @@ public class PeerState {
}
/**
- * Caller should synch
+ * Locks this.
*/
private boolean locked_shouldSend(OutboundMessageState state, long now, boolean resetWindow) {
+ synchronized(this) {
if (allocateSendingBytes(state, now, resetWindow)) {
if (_log.shouldLog(Log.DEBUG))
_log.debug(_remotePeer + " Allocation allowed with "
@@ -1683,6 +1684,7 @@ public class PeerState {
+ " for message " + state.getMessageId() + ": " + state);
return false;
}
+ }
}
/**
--
GitLab