From 51bdd9a283c2d26672207c9862e74b666185d4df Mon Sep 17 00:00:00 2001 From: zzz <zzz@i2pmail.org> Date: Wed, 23 Feb 2022 09:25:21 -0500 Subject: [PATCH] SSU: Add getVersion() methods (prep for SSU2) --- .../net/i2p/router/transport/udp/InboundEstablishState.java | 5 +++++ .../net/i2p/router/transport/udp/OutboundEstablishState.java | 5 +++++ .../net/i2p/router/transport/udp/OutboundMessageState.java | 5 +++++ router/java/src/net/i2p/router/transport/udp/PeerState.java | 5 +++++ 4 files changed, 20 insertions(+) diff --git a/router/java/src/net/i2p/router/transport/udp/InboundEstablishState.java b/router/java/src/net/i2p/router/transport/udp/InboundEstablishState.java index 7e64a95280..3d746f1524 100644 --- a/router/java/src/net/i2p/router/transport/udp/InboundEstablishState.java +++ b/router/java/src/net/i2p/router/transport/udp/InboundEstablishState.java @@ -113,6 +113,11 @@ class InboundEstablishState { receiveSessionRequest(req); } + /** + * @since 0.9.54 + */ + public int getVersion() { return 1; } + public synchronized InboundState getState() { return _currentState; } /** @return if previously complete */ diff --git a/router/java/src/net/i2p/router/transport/udp/OutboundEstablishState.java b/router/java/src/net/i2p/router/transport/udp/OutboundEstablishState.java index 632013fb49..2f706d842f 100644 --- a/router/java/src/net/i2p/router/transport/udp/OutboundEstablishState.java +++ b/router/java/src/net/i2p/router/transport/udp/OutboundEstablishState.java @@ -151,6 +151,11 @@ class OutboundEstablishState { } } + /** + * @since 0.9.54 + */ + public int getVersion() { return 1; } + public synchronized OutboundState getState() { return _currentState; } /** @return if previously complete */ diff --git a/router/java/src/net/i2p/router/transport/udp/OutboundMessageState.java b/router/java/src/net/i2p/router/transport/udp/OutboundMessageState.java index 8194b14b64..0c05840e36 100644 --- a/router/java/src/net/i2p/router/transport/udp/OutboundMessageState.java +++ b/router/java/src/net/i2p/router/transport/udp/OutboundMessageState.java @@ -104,6 +104,11 @@ class OutboundMessageState implements CDPQEntry { _fragmentAcks = _numFragments < 64 ? mask(_numFragments) - 1L : -1L; _fragmentSends = (numFragments > 1) ? new byte[numFragments] : null; } + + /** + * @since 0.9.54 + */ + public int getVersion() { return _peer.getVersion(); } /** * @param fragment 0-63 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 75e28a7bee..c3cc25b732 100644 --- a/router/java/src/net/i2p/router/transport/udp/PeerState.java +++ b/router/java/src/net/i2p/router/transport/udp/PeerState.java @@ -378,6 +378,11 @@ public class PeerState { _remoteHostId = new RemoteHostId(remoteIP, remotePort); _bwEstimator = new SimpleBandwidthEstimator(ctx, this); } + + /** + * @since 0.9.54 + */ + public int getVersion() { return 1; } /** * Caller should sync; UDPTransport must remove and add to peersByRemoteHost map -- GitLab