From 747d833392ec61fa85845e6756f9a1e7299dae29 Mon Sep 17 00:00:00 2001
From: zab2 <zab2@mail.i2p>
Date: Sat, 25 Jan 2014 00:59:42 +0000
Subject: [PATCH] Fix

---
 .../src/net/i2p/router/transport/ntcp/Writer.java    | 12 +++++++-----
 1 file changed, 7 insertions(+), 5 deletions(-)

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 d9c09735d..3d01bfc9d 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<NTCPConnection> _writeAfterLive;
     private final List<Runner> _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<NTCPConnection>(16);
         _runners = new ArrayList<Runner>(5);
         _liveWrites = new HashSet<NTCPConnection>(5);
         _writeAfterLive = new HashSet<NTCPConnection>(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; }