com.aelitis.azureus.core.networkmanager.impl.tcp
Class IncomingSocketChannelManager

java.lang.Object
  com.aelitis.azureus.core.networkmanager.impl.tcp.IncomingSocketChannelManager

public class IncomingSocketChannelManager
extends java.lang.Object

Accepts new incoming socket connections and manages routing of them to registered handlers.

Field Summary

protected AEMonitor

this_mon

Constructor Summary

IncomingSocketChannelManager(java.lang.String _port_config_key, java.lang.String _port_enable_config_key)
Create manager and begin accepting and routing new connections.

Method Summary

void	clearExplicitBindAddress()
protected java.net.InetAddress[]	getEffectiveBindAddresses()
protected long	getLastNonLocalConnectionTime()
int	getTCPListeningPortNumber() Get port that the TCP server socket is listening for incoming connections on.
boolean	isEffectiveBindAddress(java.net.InetAddress address)
boolean	isEnabled()
protected void	process(int local_port, TransportHelperFilter filter)
void	setExplicitBindAddress(java.net.InetAddress address)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

this_mon

protected final AEMonitor this_mon

Constructor Detail

IncomingSocketChannelManager

public IncomingSocketChannelManager(java.lang.String _port_config_key,
                                    java.lang.String _port_enable_config_key)

Create manager and begin accepting and routing new connections.

Method Detail

isEnabled

public boolean isEnabled()

getTCPListeningPortNumber

public int getTCPListeningPortNumber()

Get port that the TCP server socket is listening for incoming connections on.

Returns:

port number

setExplicitBindAddress

public void setExplicitBindAddress(java.net.InetAddress address)

clearExplicitBindAddress

public void clearExplicitBindAddress()

getEffectiveBindAddresses

protected java.net.InetAddress[] getEffectiveBindAddresses()

isEffectiveBindAddress

public boolean isEffectiveBindAddress(java.net.InetAddress address)

process

protected void process(int local_port,
                       TransportHelperFilter filter)

getLastNonLocalConnectionTime

protected long getLastNonLocalConnectionTime()