Constructor Detail

• NioEndpoint.Poller

  public NioEndpoint.Poller()
                     throws IOException

  Throws:

  IOException

Method Detail

• getKeyCount

  public int getKeyCount()

• getSelector

  public 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 void cancelledKey(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 Runnable

• processKey

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

• processSendfile

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

• unreg

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

• reg

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

• timeout

  protected void timeout(int keyCount,
             boolean hasEvents)