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.

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

  Registers a newly created socket with the poller.

  Parameters:

  socket - The newly created socket

• cancelledKey

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

• 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

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

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