diff --git a/router/java/src/net/i2p/router/RouterVersion.java b/router/java/src/net/i2p/router/RouterVersion.java index 4e28a2c8d2676ff98ee569a93ae883ef407d9461..c10128fe6223a59f4fa2320e38c3309487438a87 100644 --- a/router/java/src/net/i2p/router/RouterVersion.java +++ b/router/java/src/net/i2p/router/RouterVersion.java @@ -18,7 +18,7 @@ public class RouterVersion { /** deprecated */ public final static String ID = "Monotone"; public final static String VERSION = CoreVersion.VERSION; - public final static long BUILD = 5; + public final static long BUILD = 6; /** for example "-test" */ public final static String EXTRA = ""; 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 e4f4a3b0ee4bb7b38947664e14a829d0d88e7164..7944bfaa31b99e346b90d9859b6810cdb5bb62cf 100644 --- a/router/java/src/net/i2p/router/transport/ntcp/NTCPConnection.java +++ b/router/java/src/net/i2p/router/transport/ntcp/NTCPConnection.java @@ -83,7 +83,7 @@ class NTCPConnection { private final Set<FIFOBandwidthLimiter.Request> _bwInRequests; private final Set<FIFOBandwidthLimiter.Request> _bwOutRequests; private long _establishedOn; - private EstablishState _establishState; + private volatile EstablishState _establishState; private final NTCPTransport _transport; private final boolean _isInbound; private volatile boolean _closed; @@ -232,7 +232,7 @@ class NTCPConnection { public void setChannel(SocketChannel chan) { _chan = chan; } public void setKey(SelectionKey key) { _conKey = key; } public boolean isInbound() { return _isInbound; } - public synchronized boolean isEstablished() { return _establishState.isComplete(); } + public boolean isEstablished() { return _establishState.isComplete(); } /** * @since IPv6