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()