include the port # in the thread name, and logging
This commit is contained in:
@ -53,7 +53,7 @@ public class ClientManager {
|
|||||||
_pendingRunners = new HashSet();
|
_pendingRunners = new HashSet();
|
||||||
_listener = new ClientListenerRunner(_context, this, port);
|
_listener = new ClientListenerRunner(_context, this, port);
|
||||||
Thread t = new I2PThread(_listener);
|
Thread t = new I2PThread(_listener);
|
||||||
t.setName("ClientListener");
|
t.setName("ClientListener:" + port);
|
||||||
t.setDaemon(true);
|
t.setDaemon(true);
|
||||||
t.start();
|
t.start();
|
||||||
}
|
}
|
||||||
@ -101,6 +101,9 @@ public class ClientManager {
|
|||||||
}
|
}
|
||||||
|
|
||||||
public void destinationEstablished(ClientConnectionRunner runner) {
|
public void destinationEstablished(ClientConnectionRunner runner) {
|
||||||
|
if (_log.shouldLog(Log.DEBUG))
|
||||||
|
_log.debug("DestinationEstablished called for destination " + runner.getConfig().getDestination().calculateHash().toBase64());
|
||||||
|
|
||||||
synchronized (_pendingRunners) {
|
synchronized (_pendingRunners) {
|
||||||
_pendingRunners.remove(runner);
|
_pendingRunners.remove(runner);
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user