diff --git a/router/java/src/net/i2p/router/transport/ntcp/NTCPConnection.java b/router/java/src/net/i2p/router/transport/ntcp/NTCPConnection.java index b4991f659..394c2db88 100644 --- a/router/java/src/net/i2p/router/transport/ntcp/NTCPConnection.java +++ b/router/java/src/net/i2p/router/transport/ntcp/NTCPConnection.java @@ -205,7 +205,7 @@ public class NTCPConnection implements Closeable { DELAY_DEFAULT, DELAY_DEFAULT); private static final int MIN_PADDING_RANGE = 16; private static final int MAX_PADDING_RANGE = 128; - private NTCP2Options _paddingConfig; + private NTCP2Options _paddingConfig = OUR_PADDING; private int _version; private CipherState _sender; private long _sendSipk1, _sendSipk2; @@ -1346,7 +1346,6 @@ public class NTCPConnection implements Closeable { synchronized void finishOutboundEstablishment(CipherState sender, CipherState receiver, byte[] sip_ab, byte[] sip_ba, long clockSkew) { finishEstablishment(sender, receiver, sip_ab, sip_ba, clockSkew); - _paddingConfig = OUR_PADDING; _transport.markReachable(getRemotePeer().calculateHash(), false); if (!_outbound.isEmpty()) _transport.getWriter().wantsWrite(this, "outbound established"); @@ -1378,8 +1377,6 @@ public class NTCPConnection implements Closeable { "\nhis padding options: " + hisPadding + "\nour padding options: " + OUR_PADDING + "\nmerged config is: " + _paddingConfig); - } else { - _paddingConfig = OUR_PADDING; } NTCPConnection toClose = _transport.inboundEstablished(this); if (toClose != null && toClose != this) {