Class IncomingSocketChannelManager
java.lang.Object
com.biglybt.core.networkmanager.impl.tcp.IncomingSocketChannelManager
Accepts new incoming socket connections and manages routing of them
to registered handlers.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprivate final class
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) InetAddress[]
private InetAddress
private boolean
(package private) final IncomingConnectionManager
(package private) long
(package private) int[]
(package private) static final LogIDs
(package private) final String
private final String
private final AEProxyAddressMapper
private final VirtualServerChannelSelector.SelectListener
(package private) VirtualServerChannelSelector[]
(package private) int
(package private) int
protected final AEMonitor
-
Constructor Summary
ConstructorsConstructorDescriptionIncomingSocketChannelManager
(String _port_config_key, String _port_enable_config_key) Create manager and begin accepting and routing new connections. -
Method Summary
Modifier and TypeMethodDescriptionvoid
protected InetAddress[]
protected long
int
Get port that the TCP server socket is listening for incoming connections on.boolean
isEffectiveBindAddress
(InetAddress address) boolean
protected void
process
(int local_port, TransportHelperFilter filter) (package private) void
void
setExplicitBindAddress
(InetAddress address) private void
-
Field Details
-
LOGID
-
port_config_key
-
port_enable_config_key
-
tcp_listen_port
int tcp_listen_port -
so_rcvbuf_size
int so_rcvbuf_size -
default_bind_addresses
InetAddress[] default_bind_addresses -
explicit_bind_address
-
explicit_bind_address_set
private boolean explicit_bind_address_set -
serverSelectors
VirtualServerChannelSelector[] serverSelectors -
listenFailCounts
int[] listenFailCounts -
incoming_manager
-
this_mon
-
last_non_local_connection_time
long last_non_local_connection_time -
proxy_address_mapper
-
selectListener
-
-
Constructor Details
-
IncomingSocketChannelManager
Create manager and begin accepting and routing new connections.
-
-
Method Details
-
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
-
clearExplicitBindAddress
public void clearExplicitBindAddress() -
getEffectiveBindAddresses
-
isEffectiveBindAddress
-
startProcessing
private void startProcessing() -
process
-
getLastNonLocalConnectionTime
protected long getLastNonLocalConnectionTime() -
restartProcessing
void restartProcessing()
-