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 1ff491cc3..6a65cc110 100644 --- a/router/java/src/net/i2p/router/transport/ntcp/NTCPConnection.java +++ b/router/java/src/net/i2p/router/transport/ntcp/NTCPConnection.java @@ -16,7 +16,6 @@ import java.util.List; import java.util.Queue; import java.util.Set; import java.util.concurrent.ConcurrentLinkedQueue; -import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicLong; @@ -36,7 +35,6 @@ import net.i2p.data.SessionKey; import net.i2p.data.i2np.DatabaseStoreMessage; import net.i2p.data.i2np.I2NPMessage; import net.i2p.data.i2np.I2NPMessageException; -import net.i2p.data.i2np.I2NPMessageHandler; import net.i2p.router.OutNetMessage; import net.i2p.router.Router; import net.i2p.router.RouterContext; @@ -1299,24 +1297,6 @@ public class NTCPConnection implements Closeable { _clockSkew = newSkew; } - private static final int MAX_HANDLERS = 4; - - /** - * FIXME static queue mixes handlers from different contexts in multirouter JVM - */ - private final static LinkedBlockingQueue _i2npHandlers = new LinkedBlockingQueue(MAX_HANDLERS); - - private final static I2NPMessageHandler acquireHandler(RouterContext ctx) { - I2NPMessageHandler rv = _i2npHandlers.poll(); - if (rv == null) - rv = new I2NPMessageHandler(ctx); - return rv; - } - - private static void releaseHandler(I2NPMessageHandler handler) { - _i2npHandlers.offer(handler); - } - private static ByteArray acquireReadBuf() { return _dataReadBufs.acquire(); } @@ -1330,7 +1310,6 @@ public class NTCPConnection implements Closeable { * @since 0.8.8 */ static void releaseResources() { - _i2npHandlers.clear(); } private interface ReadState {