From c2ec6cdefff2975944ee86a18f653ea74fa731b0 Mon Sep 17 00:00:00 2001 From: zzz Date: Thu, 17 Mar 2022 16:08:15 -0400 Subject: [PATCH] SSU2: Set _lastACKSend --- router/java/src/net/i2p/router/transport/udp/PeerState.java | 6 +----- .../java/src/net/i2p/router/transport/udp/PeerState2.java | 2 ++ 2 files changed, 3 insertions(+), 5 deletions(-) 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 096729849..7397c4d51 100644 --- a/router/java/src/net/i2p/router/transport/udp/PeerState.java +++ b/router/java/src/net/i2p/router/transport/udp/PeerState.java @@ -109,7 +109,7 @@ public class PeerState { private final Queue _currentACKsResend; /** when did we last send ACKs to the peer? */ - private volatile long _lastACKSend; + protected volatile long _lastACKSend; /** when did we decide we need to ACK to this peer? */ protected volatile long _wantACKSendSince; /** have we received a packet with the ECN bit set in the current second? */ @@ -358,8 +358,6 @@ public class PeerState { _sendWindowBytes = 4 * _mtu; _sendWindowBytesRemaining = _sendWindowBytes; - _lastACKSend = -1; - _rto = INIT_RTO; _rtt = INIT_RTT; if (rtt > 0) @@ -409,8 +407,6 @@ public class PeerState { _sendWindowBytes = 3 * _mtu; _sendWindowBytesRemaining = _sendWindowBytes; - _lastACKSend = -1; - _rto = INIT_RTO; _rtt = INIT_RTT; if (rtt > 0) diff --git a/router/java/src/net/i2p/router/transport/udp/PeerState2.java b/router/java/src/net/i2p/router/transport/udp/PeerState2.java index 53e03fff8..44b9fb09c 100644 --- a/router/java/src/net/i2p/router/transport/udp/PeerState2.java +++ b/router/java/src/net/i2p/router/transport/udp/PeerState2.java @@ -274,9 +274,11 @@ public class PeerState2 extends PeerState implements SSU2Payload.PayloadCallback synchronized(this) { // cancel the ack timer _wantACKSendSince = 0; + _lastACKSend = _context.clock().now(); } return _receivedMessages; } + SSU2Bitfield getAckedMessages() { return _ackedMessages; } /**