NTCP: Performance improvement (tickets #2619, #2620)

This commit is contained in:
zzz
2019-10-12 13:23:28 +00:00
parent 29eabc4706
commit 05c30b4f1d
4 changed files with 10 additions and 6 deletions

View File

@ -1,3 +1,9 @@
2019-10-12 zzz
* NTCP: Performance improvement (tickets #2619, #2620)
2019-10-11 zzz
* Console: Fix mime type and encoding on javadoc pages
2019-10-06 zzz 2019-10-06 zzz
* I2NP: Remove unused I2NPMessageHandler methods * I2NP: Remove unused I2NPMessageHandler methods

View File

@ -18,10 +18,10 @@ public class RouterVersion {
/** deprecated */ /** deprecated */
public final static String ID = "Monotone"; public final static String ID = "Monotone";
public final static String VERSION = CoreVersion.VERSION; public final static String VERSION = CoreVersion.VERSION;
public final static long BUILD = 10; public final static long BUILD = 11;
/** for example "-test" */ /** for example "-test" */
public final static String EXTRA = ""; public final static String EXTRA = "-rc";
public final static String FULL_VERSION = VERSION + "-" + BUILD + EXTRA; public final static String FULL_VERSION = VERSION + "-" + BUILD + EXTRA;
public static void main(String args[]) { public static void main(String args[]) {
System.out.println("I2P Router version: " + FULL_VERSION); System.out.println("I2P Router version: " + FULL_VERSION);

View File

@ -64,9 +64,8 @@ class Reader {
already = true; already = true;
} else { } else {
_pendingConnections.add(con); _pendingConnections.add(con);
// only notify here if added? _pendingConnections.notify();
} }
_pendingConnections.notify();
} }
if (_log.shouldLog(Log.DEBUG)) if (_log.shouldLog(Log.DEBUG))
_log.debug("wantsRead: " + con + " already live? " + already); _log.debug("wantsRead: " + con + " already live? " + already);

View File

@ -62,9 +62,8 @@ class Writer {
already = true; already = true;
} else { } else {
pending = _pendingConnections.add(con); pending = _pendingConnections.add(con);
// only notify here if added? _pendingConnections.notify();
} }
_pendingConnections.notify();
} }
if (_log.shouldLog(Log.DEBUG)) if (_log.shouldLog(Log.DEBUG))
_log.debug("wantsWrite: " + con + " already live? " + already + " added to pending? " + pending + ": " + source); _log.debug("wantsWrite: " + con + " already live? " + already + " added to pending? " + pending + ": " + source);