Class IncomingSocketChannelManager


  • public class IncomingSocketChannelManager
    extends java.lang.Object
    Accepts new incoming socket connections and manages routing of them to registered handlers.
    • 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
      • listenFailCounts

        int[] listenFailCounts
      • this_mon

        protected final AEMonitor this_mon
      • last_non_local_connection_time

        long last_non_local_connection_time
    • Constructor Detail

      • IncomingSocketChannelManager

        public IncomingSocketChannelManager​(java.lang.String _port_config_key,
                                            java.lang.String _port_enable_config_key)
        Create manager and begin accepting and routing new connections.
    • 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()
      • getLastNonLocalConnectionTime

        protected long getLastNonLocalConnectionTime()
      • restartProcessing

        void restartProcessing()