Field Detail

• selector

  protected java.nio.channels.Selector selector

• events

  protected java.util.concurrent.ConcurrentLinkedQueue<java.lang.Runnable> events

• close

  protected volatile boolean close

• nextExpiration

  protected long nextExpiration

• wakeupCounter

  protected java.util.concurrent.atomic.AtomicLong wakeupCounter

• keyCount

  protected volatile int keyCount

Constructor Detail

• NioEndpoint.Poller

  public NioEndpoint.Poller()
                     throws java.io.IOException

  Throws:

  java.io.IOException

Method Detail

• getKeyCount

  public int getKeyCount()

• getSelector

  public java.nio.channels.Selector getSelector()

• destroy

  protected void destroy()

  Destroy the poller.

• addEvent

  @Deprecated
  public void addEvent(java.lang.Runnable event)

  Deprecated. 
  Only used in this class. Will be made private in Tomcat 8.0.x

• cometInterest

  @Deprecated
  public void cometInterest(NioChannel socket)

  Deprecated. 
  Unused. Will be removed in Tomcat 8.0.x

• add

  public void add(NioChannel socket)

  Add specified socket and associated pool to the poller. The socket will be added to a temporary array, and polled first after a maximum amount of time equal to pollTime (in most cases, latency will be much lower, however).

  Parameters:

  socket - to add to the poller

• add

  public void add(NioChannel socket,
         int interestOps)

• events

  public boolean events()

  Processes events in the event queue of the Poller.

  Returns:

  true if some events were processed, false if queue was empty

• register

  public void register(NioChannel socket)

• cancelledKey

  public NioEndpoint.KeyAttachment cancelledKey(java.nio.channels.SelectionKey key,
                                       SocketStatus status,
                                       boolean dispatch)

• run

  public void run()

  The background thread that listens for incoming TCP/IP connections and hands them off to an appropriate processor.

  Specified by:

  run in interface java.lang.Runnable

• processKey

  protected boolean processKey(java.nio.channels.SelectionKey sk,
                   NioEndpoint.KeyAttachment attachment)

• processSendfile

  @Deprecated
  public boolean processSendfile(java.nio.channels.SelectionKey sk,
                                   NioEndpoint.KeyAttachment attachment,
                                   boolean reg,
                                   boolean event)

  Deprecated. Replaced by processSendfile(sk, attachment, event)

• processSendfile

  public boolean processSendfile(java.nio.channels.SelectionKey sk,
                        NioEndpoint.KeyAttachment attachment,
                        boolean event)

• unreg

  protected void unreg(java.nio.channels.SelectionKey sk,
           NioEndpoint.KeyAttachment attachment,
           int readyOps)

• reg

  protected void reg(java.nio.channels.SelectionKey sk,
         NioEndpoint.KeyAttachment attachment,
         int intops)

• timeout

  protected void timeout(int keyCount,
             boolean hasEvents)