Class IncomingSocketChannelManager
- java.lang.Object
-
- com.biglybt.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.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private class
IncomingSocketChannelManager.TcpSelectListener
-
Field Summary
Fields Modifier and Type Field Description (package private) java.net.InetAddress[]
default_bind_addresses
private java.net.InetAddress
explicit_bind_address
private boolean
explicit_bind_address_set
(package private) IncomingConnectionManager
incoming_manager
(package private) long
last_non_local_connection_time
(package private) int[]
listenFailCounts
(package private) static LogIDs
LOGID
(package private) java.lang.String
port_config_key
private java.lang.String
port_enable_config_key
private AEProxyAddressMapper
proxy_address_mapper
private VirtualServerChannelSelector.SelectListener
selectListener
(package private) VirtualServerChannelSelector[]
serverSelectors
(package private) int
so_rcvbuf_size
(package private) int
tcp_listen_port
protected AEMonitor
this_mon
-
Constructor Summary
Constructors Constructor Description 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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description 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)
(package private) void
restartProcessing()
void
setExplicitBindAddress(java.net.InetAddress address)
private void
startProcessing()
-
-
-
Field Detail
-
LOGID
static final LogIDs LOGID
-
port_config_key
final java.lang.String port_config_key
-
port_enable_config_key
private final java.lang.String port_enable_config_key
-
tcp_listen_port
int tcp_listen_port
-
so_rcvbuf_size
int so_rcvbuf_size
-
default_bind_addresses
java.net.InetAddress[] default_bind_addresses
-
explicit_bind_address
private java.net.InetAddress explicit_bind_address
-
explicit_bind_address_set
private boolean explicit_bind_address_set
-
serverSelectors
VirtualServerChannelSelector[] serverSelectors
-
listenFailCounts
int[] listenFailCounts
-
incoming_manager
final IncomingConnectionManager incoming_manager
-
this_mon
protected final AEMonitor this_mon
-
last_non_local_connection_time
long last_non_local_connection_time
-
proxy_address_mapper
private final AEProxyAddressMapper proxy_address_mapper
-
selectListener
private final VirtualServerChannelSelector.SelectListener selectListener
-
-
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)
-
startProcessing
private void startProcessing()
-
process
protected void process(int local_port, TransportHelperFilter filter)
-
getLastNonLocalConnectionTime
protected long getLastNonLocalConnectionTime()
-
restartProcessing
void restartProcessing()
-
-