Class AbstractPollingIoConnector.Connector

  • All Implemented Interfaces:
    java.lang.Runnable
    Enclosing class:
    AbstractPollingIoConnector<S extends AbstractIoSession,​H>

    private class AbstractPollingIoConnector.Connector
    extends java.lang.Object
    implements java.lang.Runnable
    • Constructor Summary

      Constructors 
      Modifier Constructor Description
      private Connector()  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      private int cancelKeys()  
      private int processConnections​(java.util.Iterator<H> handlers)
      Process the incoming connections, creating a new session for each valid connection.
      private void processTimedOutSessions​(java.util.Iterator<H> handles)  
      private int registerNew()  
      void run()
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • Connector

        private Connector()
    • Method Detail

      • run

        public void run()
        Specified by:
        run in interface java.lang.Runnable
      • registerNew

        private int registerNew()
      • cancelKeys

        private int cancelKeys()
      • processConnections

        private int processConnections​(java.util.Iterator<H> handlers)
        Process the incoming connections, creating a new session for each valid connection.
      • processTimedOutSessions

        private void processTimedOutSessions​(java.util.Iterator<H> handles)