net.i2p.BOB
Class MUXlisten

java.lang.Object
  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