From 6edf5d1e4f00a0de2b7f84a77651e78cb86d9501 Mon Sep 17 00:00:00 2001 From: jrandom Date: Tue, 4 May 2004 08:15:18 +0000 Subject: [PATCH] add a unique id to the thread names --- .../java/src/net/i2p/i2ptunnel/I2PTunnelRunner.java | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelRunner.java b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelRunner.java index 58923d238..deb56127e 100644 --- a/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelRunner.java +++ b/apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelRunner.java @@ -21,6 +21,8 @@ import net.i2p.util.Log; public class I2PTunnelRunner extends I2PThread { private final static Log _log = new Log(I2PTunnelRunner.class); + private static volatile long __runnerId; + private long _runnerId; /** * max bytes streamed in a packet - smaller ones might be filled * up to this size. Larger ones are not split (at least not on @@ -51,7 +53,8 @@ public class I2PTunnelRunner extends I2PThread { lastActivityOn = -1; startedOn = -1; _log.info("I2PTunnelRunner started"); - setName("I2PTunnelRunner"); + _runnerId = ++__runnerId; + setName("I2PTunnelRunner " + _runnerId); start(); } @@ -129,6 +132,8 @@ public class I2PTunnelRunner extends I2PThread { } } + private volatile long __forwarderId = 0; + private class StreamForwarder extends I2PThread { InputStream in; @@ -137,7 +142,7 @@ public class I2PTunnelRunner extends I2PThread { private StreamForwarder(InputStream in, OutputStream out) { this.in = in; this.out = out; - setName("StreamForwarder"); + setName("StreamForwarder " + _runnerId + "." + (++__forwarderId)); start(); }