I2P_Developers/i2p.itoopie
3
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

logging (toss a unique ID onto the handler / inactivity threads)

Browse Source
This commit is contained in:
jrandom
2004-05-03 03:36:38 +00:00
committed by zzz
parent 60584228d9
commit 2bfbe1ca27
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelHTTPClient.java
View File

@ -64,8 +64,10 @@ public class I2PTunnelHTTPClient extends I2PTunnelClientBase implements Runnable
// this(localPort, l, ownDest, wwwProxy, (EventDispatcher)null); // this(localPort, l, ownDest, wwwProxy, (EventDispatcher)null);
// } // }
private static volatile long __clientId = 0;
public I2PTunnelHTTPClient(int localPort, Logging l, boolean ownDest, String wwwProxy, EventDispatcher notifyThis) { public I2PTunnelHTTPClient(int localPort, Logging l, boolean ownDest, String wwwProxy, EventDispatcher notifyThis) {
super(localPort, ownDest, l, notifyThis, "HTTPHandler"); super(localPort, ownDest, l, notifyThis, "HTTPHandler " + (++__clientId));
if (waitEventValue("openBaseClientResult").equals("error")) { if (waitEventValue("openBaseClientResult").equals("error")) {
notifyEvent("openHTTPClientResult", "error"); notifyEvent("openHTTPClientResult", "error");
@ -211,6 +213,7 @@ public class I2PTunnelHTTPClient extends I2PTunnelClientBase implements Runnable
} }
private static final long INACTIVITY_TIMEOUT = 120 * 1000; private static final long INACTIVITY_TIMEOUT = 120 * 1000;
private static volatile long __timeoutId = 0;
private class InactivityTimeoutThread extends I2PThread { private class InactivityTimeoutThread extends I2PThread {
@ -230,7 +233,8 @@ public class I2PTunnelHTTPClient extends I2PTunnelClientBase implements Runnable
_targetRequest = targetRequest; _targetRequest = targetRequest;
_useWWWProxy = useWWWProxy; _useWWWProxy = useWWWProxy;
_disabled = false; _disabled = false;
setName("InactivityThread"); long timeoutId = ++__timeoutId;
setName("InactivityThread " + timeoutId);
} }
public void disable() { public void disable() {