Changeset f37c0ed


Ignore:
Timestamp:
Apr 9, 2004 1:22:04 AM (17 years ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
ee119de6
Parents:
6b1d671
git-author:
jrandom <jrandom> (04/09/04 01:22:04)
git-committer:
zzz <zzz@…> (04/09/04 01:22:04)
Message:

name all threads, and (nearly) always use I2PThread (in case we add some pooling/throttling/monitoring or whatnot later)

Files:
9 edited

Legend:

Unmodified
Added
Removed
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelClientBase.java

    r6b1d671 rf37c0ed  
    2222import net.i2p.util.EventDispatcher;
    2323import net.i2p.util.Log;
     24import net.i2p.util.I2PThread;
    2425
    2526public abstract class I2PTunnelClientBase extends I2PTunnelTask
     
    7475        l.log("I2P session created");
    7576       
    76         Thread t = new Thread(this);
     77        Thread t = new I2PThread(this);
    7778        t.setName("Client");
    7879        listenerReady=false;
     
    271272    }
    272273
    273     public class ClientConnectionRunner extends Thread {
     274    public class ClientConnectionRunner extends I2PThread {
    274275        private Socket s;
    275276       
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelHTTPClient.java

    r6b1d671 rf37c0ed  
    209209                _useWWWProxy = useWWWProxy;
    210210                _disabled = false;
     211                setName("InactivityThread");
    211212            }
    212213            public void disable() {
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelRunner.java

    r6b1d671 rf37c0ed  
    1616import net.i2p.util.Log;
    1717import net.i2p.util.Clock;
     18import net.i2p.util.I2PThread;
    1819
    19 public class I2PTunnelRunner extends Thread {
     20public class I2PTunnelRunner extends I2PThread {
    2021    private final static Log _log = new Log(I2PTunnelRunner.class);
    2122   
     
    122123    }
    123124
    124     private class StreamForwarder extends Thread {
     125    private class StreamForwarder extends I2PThread {
    125126
    126127        InputStream in;
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelServer.java

    r6b1d671 rf37c0ed  
    2424import net.i2p.util.EventDispatcher;
    2525import net.i2p.util.Log;
     26import net.i2p.util.I2PThread;
    2627
    2728public class I2PTunnelServer extends I2PTunnelTask
     
    8384        notifyEvent("openServerResult", "ok");
    8485        open=true;
    85         Thread t = new Thread(this);
     86        Thread t = new I2PThread(this);
    8687        t.setName("Server");
    8788        t.start();
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2Ping.java

    r6b1d671 rf37c0ed  
    1616import net.i2p.util.EventDispatcher;
    1717import net.i2p.util.Log;
     18import net.i2p.util.I2PThread;
    1819
    1920public class I2Ping extends I2PTunnelTask implements Runnable {
     
    5960            }
    6061        }
    61         Thread t = new Thread(this);
     62        Thread t = new I2PThread(this);
    6263        t.setName("Client");
    6364        t.start();
     
    181182
    182183
    183     public class PingHandler extends Thread {
     184    public class PingHandler extends I2PThread {
    184185        private String destination;
    185186       
  • apps/i2ptunnel/java/src/net/i2p/i2ptunnel/TunnelManager.java

    r6b1d671 rf37c0ed  
    193193
    194194        TunnelManager mgr = new TunnelManager(host, port);
    195         Thread t = new Thread(mgr, "Listener");
     195        Thread t = new I2PThread(mgr, "Listener");
    196196        t.start();
    197197    }
  • apps/ministreaming/java/src/net/i2p/client/streaming/I2PSocketImpl.java

    r6b1d671 rf37c0ed  
    1010import net.i2p.data.Destination;
    1111import net.i2p.util.Log;
     12import net.i2p.util.I2PThread;
    1213
    1314/**
     
    228229    }
    229230
    230     public class I2PSocketRunner extends Thread {
     231    public class I2PSocketRunner extends I2PThread {
    231232
    232233        public InputStream in;
     
    235236            _log.debug("Runner's input stream is: "+in.hashCode());
    236237            this.in=in;
     238            setName("SocketRunner from " + I2PSocketImpl.this.remote.calculateHash().toBase64().substring(0, 4));
    237239            start();
    238240        }
  • core/java/src/net/i2p/crypto/DHSessionKeyBuilder.java

    r6b1d671 rf37c0ed  
    1515import net.i2p.util.NativeBigInteger;
    1616import net.i2p.util.Clock;
     17import net.i2p.util.I2PThread;
    1718import java.math.BigInteger;
    1819
     
    8586        if (_log.shouldLog(Log.DEBUG)) _log.debug("DH Precalc (minimum: " + MIN_NUM_BUILDERS + " max: " + MAX_NUM_BUILDERS + ", delay: " + CALC_DELAY + ")");
    8687       
    87         _precalcThread = new Thread(new DHSessionKeyBuilderPrecalcRunner(MIN_NUM_BUILDERS, MAX_NUM_BUILDERS));
     88        _precalcThread = new I2PThread(new DHSessionKeyBuilderPrecalcRunner(MIN_NUM_BUILDERS, MAX_NUM_BUILDERS));
    8889        _precalcThread.setName("DH Precalc");
    8990        _precalcThread.setDaemon(true);
  • core/java/src/net/i2p/crypto/YKGenerator.java

    r6b1d671 rf37c0ed  
    1515import net.i2p.util.Clock;
    1616import net.i2p.util.Log;
     17import net.i2p.util.I2PThread;
    1718import net.i2p.util.NativeBigInteger;
    1819import net.i2p.util.RandomSource;
     
    7980        if (_log.shouldLog(Log.DEBUG)) _log.debug("ElGamal YK Precalc (minimum: " + MIN_NUM_BUILDERS + " max: " + MAX_NUM_BUILDERS + ", delay: " + CALC_DELAY + ")");
    8081       
    81         _precalcThread = new Thread(new YKPrecalcRunner(MIN_NUM_BUILDERS, MAX_NUM_BUILDERS));
     82        _precalcThread = new I2PThread(new YKPrecalcRunner(MIN_NUM_BUILDERS, MAX_NUM_BUILDERS));
    8283        _precalcThread.setName("YK Precalc");
    8384        _precalcThread.setDaemon(true);
Note: See TracChangeset for help on using the changeset viewer.