public class AprEndpoint.Poller extends Object implements Runnable
Modifier and Type | Field and Description |
---|---|
protected int |
actualPollerSize
Actual poller size.
|
protected AprEndpoint.SocketList |
addList
List of sockets to be added to the poller.
|
protected int |
connectionCount
Amount of connections inside this poller.
|
protected long[] |
desc
Socket descriptors.
|
protected boolean |
event
Event mode flag.
|
protected long |
lastMaintain
Last run of maintain.
|
protected AprEndpoint.SocketList |
localAddList
List of sockets to be added to the poller.
|
protected int |
pollerCount
Amount of low level pollers in use by this poller.
|
protected long[] |
pollers
Pointers to the pollers.
|
protected int[] |
pollerSpace
Amount of spots left in the poller.
|
protected int |
pollerTime
Timeout value for the poll call.
|
protected long |
pool
Root pool.
|
protected AprEndpoint.SocketTimeouts |
timeouts
Structure used for storing timeouts.
|
Constructor and Description |
---|
AprEndpoint.Poller(boolean event) |
Modifier and Type | Method and Description |
---|---|
void |
add(long socket)
Add specified socket and associated pool to the poller.
|
void |
add(long socket,
int timeout,
boolean read,
boolean write,
boolean resume,
boolean wakeup)
Add specified socket and associated pool to the poller.
|
protected boolean |
addToPoller(long socket,
int events)
Add specified socket to one of the pollers.
|
protected void |
destroy()
Destroy the poller.
|
int |
getConnectionCount() |
protected void |
init()
Create the poller.
|
protected void |
maintain()
Timeout checks.
|
protected boolean |
removeFromPoller(long socket)
Remove specified socket from the pollers.
|
void |
run()
The background thread that listens for incoming TCP/IP connections and
hands them off to an appropriate processor.
|
String |
toString()
Displays the list of sockets in the pollers.
|
protected long[] pollers
protected int actualPollerSize
protected int[] pollerSpace
protected int pollerCount
protected int pollerTime
protected long pool
protected long[] desc
protected AprEndpoint.SocketList addList
protected AprEndpoint.SocketList localAddList
protected boolean event
protected AprEndpoint.SocketTimeouts timeouts
protected long lastMaintain
protected int connectionCount
public int getConnectionCount()
protected void init()
protected void destroy()
public void add(long socket)
socket
- to add to the pollerpublic void add(long socket, int timeout, boolean read, boolean write, boolean resume, boolean wakeup)
socket
- to add to the pollertimeout
- to use for this connectionread
- to do read pollingwrite
- to do write pollingresume
- to send a callback eventprotected boolean addToPoller(long socket, int events)
protected boolean removeFromPoller(long socket)
protected void maintain()
public String toString()
Copyright © 2013 JBoss, a division of Red Hat, Inc.. All rights reserved.