Class IncomingSocketChannelManager

java.lang.Object
com.biglybt.core.networkmanager.impl.tcp.IncomingSocketChannelManager

public class IncomingSocketChannelManager extends Object
Accepts new incoming socket connections and manages routing of them to registered handlers.
  • Field Details

    • LOGID

      static final LogIDs LOGID
    • port_config_key

      final String port_config_key
    • port_enable_config_key

      private final String 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

      private 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
  • Constructor Details

    • IncomingSocketChannelManager

      public IncomingSocketChannelManager(String _port_config_key, String _port_enable_config_key)
      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

      public void setExplicitBindAddress(InetAddress address)
    • clearExplicitBindAddress

      public void clearExplicitBindAddress()
    • getEffectiveBindAddresses

      protected InetAddress[] getEffectiveBindAddresses()
    • isEffectiveBindAddress

      public boolean isEffectiveBindAddress(InetAddress address)
    • startProcessing

      private void startProcessing()
    • process

      protected void process(int local_port, TransportHelperFilter filter)
    • getLastNonLocalConnectionTime

      protected long getLastNonLocalConnectionTime()
    • restartProcessing

      void restartProcessing()