diff --git a/router/java/src/net/i2p/router/transport/ntcp/Writer.java b/router/java/src/net/i2p/router/transport/ntcp/Writer.java index d9c09735d1..3d01bfc9dd 100644 --- a/router/java/src/net/i2p/router/transport/ntcp/Writer.java +++ b/router/java/src/net/i2p/router/transport/ntcp/Writer.java @@ -24,16 +24,12 @@ class Writer { private final Set _writeAfterLive; private final List _runners; - /** a scratch space to serialize and encrypt messages */ - private final NTCPConnection.PrepBuffer _prepBuffer; - public Writer(RouterContext ctx) { _log = ctx.logManager().getLog(getClass()); _pendingConnections = new LinkedHashSet(16); _runners = new ArrayList(5); _liveWrites = new HashSet(5); _writeAfterLive = new HashSet(5); - _prepBuffer = new NTCPConnection.PrepBuffer(); } public synchronized void startWriting(int numWriters) { @@ -84,9 +80,15 @@ class Writer { } private class Runner implements Runnable { + + /** a scratch space to serialize and encrypt messages */ + private final NTCPConnection.PrepBuffer _prepBuffer; + private volatile boolean _stop; - public Runner() {} + public Runner() { + _prepBuffer = new NTCPConnection.PrepBuffer(); + } public void stop() { _stop = true; }