org.apache.tomcat.util.net
Class NioEndpoint.Poller

java.lang.Object
  org.apache.tomcat.util.net.NioEndpoint.Poller

All Implemented Interfaces:

Runnable

Enclosing class:

NioEndpoint

public class NioEndpoint.Poller
extends Object
implements Runnable

Poller class.

Field Summary

protected boolean	close
protected ConcurrentLinkedQueue<Runnable>	events
protected int	keyCount
protected long	nextExpiration
protected Selector	selector
protected AtomicLong	wakeupCounter

Constructor Summary

NioEndpoint.Poller()

Method Summary

void	add(NioChannel socket) Add specified socket and associated pool to the poller.
void	add(NioChannel socket, int interestOps)
void	addEvent(Runnable event)
void	cancelledKey(SelectionKey key, SocketStatus status, boolean dispatch)
void	cometInterest(NioChannel socket)
protected void	destroy() Destroy the poller.
boolean	events() Processes events in the event queue of the Poller.
int	getKeyCount()
Selector	getSelector()
protected boolean	processKey(SelectionKey sk, NioEndpoint.KeyAttachment attachment)
boolean	processSendfile(SelectionKey sk, NioEndpoint.KeyAttachment attachment, boolean event)
boolean	processSendfile(SelectionKey sk, NioEndpoint.KeyAttachment attachment, boolean reg, boolean event) Deprecated. Replaced by processSendfile(sk, attachment, event)
protected void	reg(SelectionKey sk, NioEndpoint.KeyAttachment attachment, int intops)
void	register(NioChannel socket)
void	run() The background thread that listens for incoming TCP/IP connections and hands them off to an appropriate processor.
protected void	timeout(int keyCount, boolean hasEvents)
protected void	unreg(SelectionKey sk, NioEndpoint.KeyAttachment attachment, int readyOps)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

selector

protected Selector selector

events

protected ConcurrentLinkedQueue<Runnable> events

close

protected volatile boolean close

nextExpiration

protected long nextExpiration

wakeupCounter

protected AtomicLong wakeupCounter

keyCount

protected volatile int keyCount

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.

addEvent

public void addEvent(Runnable event)

cometInterest

public void cometInterest(NioChannel socket)

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

processKey

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

processSendfile

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

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

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)