echelon/i2p.i2p
1
0
Fork 0
forked from I2P_Developers/i2p.i2p
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix

Browse Source
This commit is contained in:
zab2
2014-01-25 00:59:42 +00:00
parent 3427464de6
commit 747d833392
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
router/java/src/net/i2p/router/transport/ntcp/Writer.java
View File

@ -24,16 +24,12 @@ class Writer {
private final Set<NTCPConnection> _writeAfterLive; private final Set<NTCPConnection> _writeAfterLive;
private final List<Runner> _runners; private final List<Runner> _runners;
/** a scratch space to serialize and encrypt messages */
private final NTCPConnection.PrepBuffer _prepBuffer;
public Writer(RouterContext ctx) { public Writer(RouterContext ctx) {
_log = ctx.logManager().getLog(getClass()); _log = ctx.logManager().getLog(getClass());
_pendingConnections = new LinkedHashSet<NTCPConnection>(16); _pendingConnections = new LinkedHashSet<NTCPConnection>(16);
_runners = new ArrayList<Runner>(5); _runners = new ArrayList<Runner>(5);
_liveWrites = new HashSet<NTCPConnection>(5); _liveWrites = new HashSet<NTCPConnection>(5);
_writeAfterLive = new HashSet<NTCPConnection>(5); _writeAfterLive = new HashSet<NTCPConnection>(5);
_prepBuffer = new NTCPConnection.PrepBuffer();
} }
public synchronized void startWriting(int numWriters) { public synchronized void startWriting(int numWriters) {
@ -84,9 +80,15 @@ class Writer {
} }
private class Runner implements Runnable { private class Runner implements Runnable {
/** a scratch space to serialize and encrypt messages */
private final NTCPConnection.PrepBuffer _prepBuffer;
private volatile boolean _stop; private volatile boolean _stop;
public Runner() {} public Runner() {
_prepBuffer = new NTCPConnection.PrepBuffer();
}
public void stop() { _stop = true; } public void stop() { _stop = true; }