net.i2p.BOB
Class MUXlisten

java.lang.Object
  extended by net.i2p.BOB.MUXlisten
All Implemented Interfaces:
java.lang.Runnable

public class MUXlisten
extends java.lang.Object
implements java.lang.Runnable

Multiplex listeners for TCP and I2P

Author:
sponge

Field Summary
(package private)  boolean come_in
           
(package private)  boolean go_out
           
 
Constructor Summary
MUXlisten(java.util.concurrent.atomic.AtomicBoolean lock, NamedDB database, NamedDB info, Log _log)
          Constructor Will fail if INPORT is occupied.
 
Method Summary
 void run()
          MUX sockets, fire off a thread to connect, get destination info, and do I/O
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

go_out

boolean go_out

come_in

boolean come_in
Constructor Detail

MUXlisten

MUXlisten(java.util.concurrent.atomic.AtomicBoolean lock,
          NamedDB database,
          NamedDB info,
          Log _log)
    throws I2PException,
           java.io.IOException,
           java.lang.RuntimeException
Constructor Will fail if INPORT is occupied.

Parameters:
info - DB entry for this tunnel
database - master database of tunnels
_log -
Throws:
I2PException
java.io.IOException
java.lang.RuntimeException
Method Detail

run

public void run()
MUX sockets, fire off a thread to connect, get destination info, and do I/O

Specified by:
run in interface java.lang.Runnable