Changeset c37cc7a


Ignore:
Timestamp:
Oct 31, 2015 7:13:57 PM (5 years ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
805979b
Parents:
02c1417
Message:

Convert remaining Threads to I2PThread or I2PAppThread

Files:
13 edited

Legend:

Unmodified
Added
Removed
  • apps/BOB/src/net/i2p/BOB/BOB.java

    r02c1417 rc37cc7a  
    339339                                if (g) {
    340340                                        DoCMDS conn_c = new DoCMDS(spin, lock, server, props, database, _log);
    341                                         Thread t = new Thread(conn_c);
     341                                        Thread t = new I2PAppThread(conn_c);
    342342                                        t.setName("BOB.DoCMDS " + i);
    343343                                        t.start();
  • apps/BOB/src/net/i2p/BOB/DoCMDS.java

    r02c1417 rc37cc7a  
    2626import java.util.StringTokenizer;
    2727import java.util.concurrent.atomic.AtomicBoolean;
     28
    2829import net.i2p.I2PAppContext;
    2930import net.i2p.I2PException;
    3031import net.i2p.client.I2PClientFactory;
    31 //import net.i2p.data.DataFormatException;
    3232import net.i2p.data.Destination;
    33 //import net.i2p.i2ptunnel.I2PTunnel;
     33import net.i2p.util.I2PAppThread;
     34
    3435// needed only for debugging.
    3536// import java.util.logging.Level;
     
    13081309                                                                                                        }
    13091310                                                                                                        tunnel = new MUXlisten(lock, database, nickinfo, _log);
    1310                                                                                                         Thread t = new Thread(tunnel);
     1311                                                                                                        Thread t = new I2PAppThread(tunnel);
    13111312                                                                                                        t.start();
    13121313                                                                                                        // try {
  • apps/BOB/src/net/i2p/BOB/I2Plistener.java

    r02c1417 rc37cc7a  
    1919import java.net.SocketTimeoutException;
    2020import java.util.concurrent.atomic.AtomicBoolean;
     21
    2122import net.i2p.I2PException;
    2223import net.i2p.client.streaming.I2PServerSocket;
    2324import net.i2p.client.streaming.I2PSocket;
    2425import net.i2p.client.streaming.I2PSocketManager;
     26import net.i2p.util.I2PAppThread;
    2527
    2628/**
     
    7880                                                // toss the connection to a new thread.
    7981                                                I2PtoTCP conn_c = new I2PtoTCP(sessSocket, info, database, lives);
    80                                                 Thread t = new Thread(conn_c, Thread.currentThread().getName() + " I2PtoTCP " + conn);
     82                                                Thread t = new I2PAppThread(conn_c, Thread.currentThread().getName() + " I2PtoTCP " + conn);
    8183                                                t.start();
    8284                                        }
  • apps/BOB/src/net/i2p/BOB/I2PtoTCP.java

    r02c1417 rc37cc7a  
    2020import java.net.Socket;
    2121import java.util.concurrent.atomic.AtomicBoolean;
     22
    2223import net.i2p.client.streaming.I2PSocket;
     24import net.i2p.util.I2PAppThread;
    2325
    2426/**
     
    112114                                        TCPio conn_c = new TCPio(in, Iout, lives); // app -> I2P
    113115                                        TCPio conn_a = new TCPio(Iin, out, lives); // I2P -> app
    114                                         t = new Thread(conn_c, Thread.currentThread().getName() + " TCPioA");
    115                                         q = new Thread(conn_a, Thread.currentThread().getName() + " TCPioB");
     116                                        t = new I2PAppThread(conn_c, Thread.currentThread().getName() + " TCPioA");
     117                                        q = new I2PAppThread(conn_a, Thread.currentThread().getName() + " TCPioB");
    116118                                        // Fire!
    117119                                        t.start();
  • apps/BOB/src/net/i2p/BOB/MUXlisten.java

    r02c1417 rc37cc7a  
    2222import java.util.Properties;
    2323import java.util.concurrent.atomic.AtomicBoolean;
     24
    2425import net.i2p.I2PException;
    2526import net.i2p.client.I2PClient;
     
    2728import net.i2p.client.streaming.I2PSocketManager;
    2829import net.i2p.client.streaming.I2PSocketManagerFactory;
     30import net.i2p.util.I2PAppThread;
    2931import net.i2p.util.Log;
    3032
     
    202204                                                        SS = socketManager.getServerSocket();
    203205                                                        I2Plistener conn = new I2Plistener(SS, socketManager, info, database, _log, lives);
    204                                                         t = new Thread(tg, conn, "BOBI2Plistener " + N);
     206                                                        t = new I2PAppThread(tg, conn, "BOBI2Plistener " + N);
    205207                                                        t.start();
    206208                                                }
     
    209211                                                        // TCP -> I2P
    210212                                                        TCPlistener conn = new TCPlistener(listener, socketManager, info, database, _log, lives);
    211                                                         q = new Thread(tg, conn, "BOBTCPlistener " + N);
     213                                                        q = new I2PAppThread(tg, conn, "BOBTCPlistener " + N);
    212214                                                        q.start();
    213215                                                }
  • apps/BOB/src/net/i2p/BOB/TCPlistener.java

    r02c1417 rc37cc7a  
    2121import java.net.SocketTimeoutException;
    2222import java.util.concurrent.atomic.AtomicBoolean;
     23
    2324import net.i2p.client.streaming.I2PServerSocket;
    2425import net.i2p.client.streaming.I2PSocketManager;
     26import net.i2p.util.I2PAppThread;
    2527
    2628/**
     
    7678                                                // toss the connection to a new thread.
    7779                                                TCPtoI2P conn_c = new TCPtoI2P(socketManager, server, info, database, lives);
    78                                                 Thread t = new Thread(conn_c, Thread.currentThread().getName() + " TCPtoI2P " + conn);
     80                                                Thread t = new I2PAppThread(conn_c, Thread.currentThread().getName() + " TCPtoI2P " + conn);
    7981                                                t.start();
    8082                                                g = false;
  • apps/BOB/src/net/i2p/BOB/TCPtoI2P.java

    r02c1417 rc37cc7a  
    2525import java.util.Locale;
    2626import java.util.concurrent.atomic.AtomicBoolean;
     27
     28import net.i2p.I2PAppContext;
    2729import net.i2p.I2PException;
    2830import net.i2p.client.streaming.I2PSocket;
     
    3032import net.i2p.data.DataFormatException;
    3133import net.i2p.data.Destination;
    32 //import net.i2p.i2ptunnel.I2PTunnel;
    33 import net.i2p.I2PAppContext;
     34import net.i2p.util.I2PAppThread;
    3435
    3536/**
     
    159160                                        TCPio conn_c = new TCPio(in, Iout, lives); // app -> I2P
    160161                                        TCPio conn_a = new TCPio(Iin, out, lives); // I2P -> app
    161                                         t = new Thread(conn_c, Thread.currentThread().getName() + " TCPioA");
    162                                         q = new Thread(conn_a, Thread.currentThread().getName() + " TCPioB");
     162                                        t = new I2PAppThread(conn_c, Thread.currentThread().getName() + " TCPioA");
     163                                        q = new I2PAppThread(conn_a, Thread.currentThread().getName() + " TCPioB");
    163164                                        // Fire!
    164165                                        t.start();
  • apps/sam/java/src/net/i2p/sam/SAMv3StreamSession.java

    r02c1417 rc37cc7a  
    120120               
    121121                SAMBridge bridge = handler.getBridge();
    122                 (new Thread(rec.getThreadGroup(),
     122                (new I2PAppThread(rec.getThreadGroup(),
    123123                            new Pipe(fromClient, toI2P, bridge),
    124124                            "ConnectV3 SAMPipeClientToI2P")).start();
    125                 (new Thread(rec.getThreadGroup(),
     125                (new I2PAppThread(rec.getThreadGroup(),
    126126                            new Pipe(fromI2P, toClient, bridge),
    127127                            "ConnectV3 SAMPipeI2PToClient")).start();
     
    177177               
    178178                SAMBridge bridge = handler.getBridge();
    179                 (new Thread(rec.getThreadGroup(),
     179                (new I2PAppThread(rec.getThreadGroup(),
    180180                            new Pipe(fromClient, toI2P, bridge),
    181181                            "AcceptV3 SAMPipeClientToI2P")).start();
    182                 (new Thread(rec.getThreadGroup(),
     182                (new I2PAppThread(rec.getThreadGroup(),
    183183                            new Pipe(fromI2P, toClient, bridge),
    184184                            "AcceptV3 SAMPipeI2PToClient")).start();
     
    220220               
    221221                SocketForwarder forwarder = new SocketForwarder(host, port, this, verbose);
    222                 (new Thread(rec.getThreadGroup(), forwarder, "SAMV3StreamForwarder")).start();
     222                (new I2PAppThread(rec.getThreadGroup(), forwarder, "SAMV3StreamForwarder")).start();
    223223            }
    224224           
  • core/java/src/net/i2p/util/I2PAppThread.java

    r02c1417 rc37cc7a  
    3939        super(r, name);
    4040    }
     41
    4142    public I2PAppThread(Runnable r, String name, boolean isDaemon) {
    4243        super(r, name, isDaemon);
     44    }
     45
     46    /**
     47     *  @since 0.9.23
     48     */
     49    public I2PAppThread(ThreadGroup group, Runnable r, String name) {
     50        super(group, r, name);
    4351    }
    4452   
  • core/java/src/net/i2p/util/I2PThread.java

    r02c1417 rc37cc7a  
    7272        //if ( (_log == null) || (_log.shouldLog(Log.DEBUG)) )
    7373        //    _createdBy = new Exception("Created by");
     74    }
     75
     76    /**
     77     *  @since 0.9.23
     78     */
     79    public I2PThread(ThreadGroup group, Runnable r, String name) {
     80        super(group, r, name);
     81        setPriority(NORM_PRIORITY);
    7482    }
    7583
  • router/java/src/net/i2p/router/Router.java

    r02c1417 rc37cc7a  
    11421142            try {
    11431143                //task.run();
    1144                 Thread t = new Thread(task, "Shutdown task " + task.getClass().getName());
     1144                Thread t = new I2PAppThread(task, "Shutdown task " + task.getClass().getName());
    11451145                t.setDaemon(true);
    11461146                t.start();
     
    14551455        // Let's not stop accepting tunnels, etc
    14561456        //_started = _context.clock().now();
    1457         Thread t = new Thread(new Restarter(_context), "Router Restart");
     1457        Thread t = new I2PThread(new Restarter(_context), "Router Restart");
    14581458        t.setPriority(Thread.NORM_PRIORITY + 1);
    14591459        t.start();
  • router/java/src/net/i2p/router/peermanager/PeerManager.java

    r02c1417 rc37cc7a  
    166166     */
    167167    private void loadProfilesInBackground() {
    168         (new Thread(new ProfileLoader())).start();
     168        (new I2PThread(new ProfileLoader())).start();
    169169    }
    170170
  • router/java/src/net/i2p/router/transport/UPnP.java

    r02c1417 rc37cc7a  
    2020import net.i2p.data.DataHelper;
    2121import net.i2p.util.Addresses;
     22import net.i2p.util.I2PThread;
    2223import net.i2p.util.Log;
    2324import net.i2p.util.Translate;
     
    995996                if (_log.shouldLog(Log.INFO))
    996997                        _log.info("Starting thread to forward " + portsToForwardNow.size() + " ports");
    997                 Thread t = new Thread(new RegisterPortsThread(portsToForwardNow));
     998                Thread t = new I2PThread(new RegisterPortsThread(portsToForwardNow));
    998999                t.setName("UPnP Port Opener " + __id.incrementAndGet());
    9991000                t.setDaemon(true);
     
    10351036                if (_log.shouldLog(Log.INFO))
    10361037                        _log.info("Starting thread to un-forward " + portsToForwardNow.size() + " ports");
    1037                 Thread t = new Thread(new UnregisterPortsThread(portsToForwardNow));
     1038                Thread t = new I2PThread(new UnregisterPortsThread(portsToForwardNow));
    10381039                t.setName("UPnP Port Closer " + __id.incrementAndGet());
    10391040                t.setDaemon(true);
Note: See TracChangeset for help on using the changeset viewer.