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

add unique IDs to the threads for easier tracing

Browse Source
This commit is contained in:
jrandom
2004-05-04 04:46:04 +00:00
committed by zzz
parent 3a4d0549aa
commit b04512a4f6
2 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
core/java/src/net/i2p/client/I2PSessionImpl.java
View File

@@ -318,6 +318,8 @@ abstract class I2PSessionImpl implements I2PSession, I2CPMessageReader.I2CPMessa
return tags; return tags;
} }
private static volatile long __notifierId = 0;
/** /**
* Recieve a payload message and let the app know its available * Recieve a payload message and let the app know its available
*/ */
@@ -337,9 +339,12 @@ abstract class I2PSessionImpl implements I2PSession, I2CPMessageReader.I2CPMessa
_sessionListener.messageAvailable(I2PSessionImpl.this, id, size); _sessionListener.messageAvailable(I2PSessionImpl.this, id, size);
} }
}); });
notifier.setName("Notifier [" + _sessionId + "/" + id + "]"); long nid = ++__notifierId;
notifier.setName("Notifier " + nid);
notifier.setDaemon(true); notifier.setDaemon(true);
notifier.start(); notifier.start();
if (_log.shouldLog(Log.INFO))
_log.info("Notifier " + nid + " is for session " + _sessionId + ", message " + id + "]");
} }
} }

4
core/java/src/net/i2p/data/i2cp/I2CPMessageReader.java
View File

@@ -30,6 +30,8 @@ public class I2CPMessageReader {
private I2CPMessageEventListener _listener; private I2CPMessageEventListener _listener;
private I2CPMessageReaderRunner _reader; private I2CPMessageReaderRunner _reader;
private Thread _readerThread; private Thread _readerThread;
private static volatile long __readerId = 0;
public I2CPMessageReader(InputStream stream, I2CPMessageEventListener lsnr) { public I2CPMessageReader(InputStream stream, I2CPMessageEventListener lsnr) {
_stream = stream; _stream = stream;
@@ -37,7 +39,7 @@ public class I2CPMessageReader {
_reader = new I2CPMessageReaderRunner(); _reader = new I2CPMessageReaderRunner();
_readerThread = new I2PThread(_reader); _readerThread = new I2PThread(_reader);
_readerThread.setDaemon(true); _readerThread.setDaemon(true);
_readerThread.setName("I2CP Reader"); _readerThread.setName("I2CP Reader " + (++__readerId));
} }
public void setListener(I2CPMessageEventListener lsnr) { public void setListener(I2CPMessageEventListener lsnr) {