Class TCPNetworkManager
- java.lang.Object
-
- com.biglybt.core.networkmanager.impl.tcp.TCPNetworkManager
-
public class TCPNetworkManager extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description private java.util.List<IncomingSocketChannelManager>
additional_incoming_socketchannel_managers
private TCPConnectionManager
connect_disconnect_manager
private IncomingSocketChannelManager
default_incoming_socketchannel_manager
private static TCPNetworkManager
instance
(package private) long
read_select_count
(package private) static int
READ_SELECT_LOOP_TIME
(package private) static int
READ_SELECT_MIN_LOOP_TIME
(package private) VirtualChannelSelector
read_selector
static boolean
TCP_INCOMING_ENABLED
protected static int
tcp_mss_size
static boolean
TCP_OUTGOING_ENABLED
(package private) long
write_select_count
(package private) static int
WRITE_SELECT_LOOP_TIME
(package private) static int
WRITE_SELECT_MIN_LOOP_TIME
(package private) VirtualChannelSelector
write_selector
-
Constructor Summary
Constructors Modifier Constructor Description protected
TCPNetworkManager()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description int
getAdditionalTCPListeningPortNumber(java.util.List<java.lang.Integer> excluded_ports)
TCPConnectionManager
getConnectDisconnectManager()
Get the socket channel connect / disconnect manager.IncomingSocketChannelManager
getDefaultIncomingSocketManager()
int
getDefaultTCPListeningPortNumber()
Get port that the TCP server socket is listening for incoming connections on.long
getLastIncomingNonLocalConnectionTime()
VirtualChannelSelector
getReadSelector()
Get the virtual selector used for socket channel read readiness.static TCPNetworkManager
getSingleton()
static int
getTcpMssSize()
Get the configured TCP MSS (Maximum Segment Size) unit, i.e.VirtualChannelSelector
getWriteSelector()
Get the virtual selector used for socket channel write readiness.boolean
isDefaultTCPListenerEnabled()
static void
refreshRates(int min_rate)
-
-
-
Field Detail
-
WRITE_SELECT_LOOP_TIME
static int WRITE_SELECT_LOOP_TIME
-
WRITE_SELECT_MIN_LOOP_TIME
static int WRITE_SELECT_MIN_LOOP_TIME
-
READ_SELECT_LOOP_TIME
static int READ_SELECT_LOOP_TIME
-
READ_SELECT_MIN_LOOP_TIME
static int READ_SELECT_MIN_LOOP_TIME
-
tcp_mss_size
protected static int tcp_mss_size
-
instance
private static final TCPNetworkManager instance
-
TCP_INCOMING_ENABLED
public static boolean TCP_INCOMING_ENABLED
-
TCP_OUTGOING_ENABLED
public static boolean TCP_OUTGOING_ENABLED
-
read_selector
final VirtualChannelSelector read_selector
-
write_selector
final VirtualChannelSelector write_selector
-
connect_disconnect_manager
private final TCPConnectionManager connect_disconnect_manager
-
default_incoming_socketchannel_manager
private final IncomingSocketChannelManager default_incoming_socketchannel_manager
-
additional_incoming_socketchannel_managers
private java.util.List<IncomingSocketChannelManager> additional_incoming_socketchannel_managers
-
read_select_count
long read_select_count
-
write_select_count
long write_select_count
-
-
Method Detail
-
getSingleton
public static TCPNetworkManager getSingleton()
-
getTcpMssSize
public static int getTcpMssSize()
Get the configured TCP MSS (Maximum Segment Size) unit, i.e. the max (preferred) packet payload size. NOTE: MSS is MTU-40bytes for TCPIP headers, usually 1460 (1500-40) for standard ethernet connections, or 1452 (1492-40) for PPPOE connections.- Returns:
- mss size in bytes
-
refreshRates
public static void refreshRates(int min_rate)
-
getDefaultIncomingSocketManager
public IncomingSocketChannelManager getDefaultIncomingSocketManager()
-
getConnectDisconnectManager
public TCPConnectionManager getConnectDisconnectManager()
Get the socket channel connect / disconnect manager.- Returns:
- connect manager
-
getReadSelector
public VirtualChannelSelector getReadSelector()
Get the virtual selector used for socket channel read readiness.- Returns:
- read readiness selector
-
getWriteSelector
public VirtualChannelSelector getWriteSelector()
Get the virtual selector used for socket channel write readiness.- Returns:
- write readiness selector
-
isDefaultTCPListenerEnabled
public boolean isDefaultTCPListenerEnabled()
-
getDefaultTCPListeningPortNumber
public int getDefaultTCPListeningPortNumber()
Get port that the TCP server socket is listening for incoming connections on.- Returns:
- port number
-
getLastIncomingNonLocalConnectionTime
public long getLastIncomingNonLocalConnectionTime()
-
getAdditionalTCPListeningPortNumber
public int getAdditionalTCPListeningPortNumber(java.util.List<java.lang.Integer> excluded_ports)
-
-