Package jnr.enxio.channels

Class PollSelector

java.lang.Object

java.nio.channels.Selector

java.nio.channels.spi.AbstractSelector

jnr.enxio.channels.PollSelector

All Implemented Interfaces:

Closeable, AutoCloseable

class PollSelector
extends AbstractSelector

An implementation of a Selector that uses good old poll(2)

Field Summary

Fields

Modifier and Type	Field	Description
private static final int	EVENTS_OFFSET
private static final int	FD_OFFSET
private PollSelectionKey[]	keyArray
private final Map<SelectionKey,Boolean>	keys
private int	nfds
private final int[]	pipefd
private ByteBuffer	pollData
(package private) static final int	POLLERR
private static final int	POLLFD_SIZE
(package private) static final int	POLLHUP
(package private) static final int	POLLIN
(package private) static final int	POLLOUT
private final Object	regLock
private static final int	REVENTS_OFFSET
private final Set<SelectionKey>	selected

Constructor Summary

Constructors

Constructor	Description
PollSelector(SelectorProvider provider)

Method Summary

Modifier and Type	Method	Description
private void	add(PollSelectionKey k)
private short	getPollEvents(int idx)
private int	getPollFD(int idx)
private short	getPollRevents(int idx)
protected void	implCloseSelector()
(package private) void	interestOps(PollSelectionKey k, int ops)
Set<SelectionKey>	keys()
private int	poll(long timeout)
private void	putPollEvents(int idx, int events)
private void	putPollFD(int idx, int fd)
private void	putPollRevents(int idx, int events)
protected SelectionKey	register(AbstractSelectableChannel ch, int ops, Object att)
private void	remove(PollSelectionKey k)
int	select()
int	select(long timeout)
Set<SelectionKey>	selectedKeys()
int	selectNow()
Selector	wakeup()
private void	wakeupReceived()

Methods inherited from class java.nio.channels.spi.AbstractSelector

begin, cancelledKeys, close, deregister, end, isOpen, provider

Methods inherited from class java.nio.channels.Selector

open

Methods inherited from class java.lang.Object

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

Field Details

POLLFD_SIZE

private static final int POLLFD_SIZE

See Also:

• Constant Field Values

FD_OFFSET

private static final int FD_OFFSET

See Also:

• Constant Field Values

EVENTS_OFFSET

private static final int EVENTS_OFFSET

See Also:

• Constant Field Values

REVENTS_OFFSET

private static final int REVENTS_OFFSET

See Also:

• Constant Field Values

POLLIN

static final int POLLIN

See Also:

• Constant Field Values

POLLOUT

static final int POLLOUT

See Also:

• Constant Field Values

POLLERR

static final int POLLERR

See Also:

• Constant Field Values

POLLHUP

static final int POLLHUP

See Also:

• Constant Field Values

keyArray

private PollSelectionKey[] keyArray

pollData

private ByteBuffer pollData

nfds

private int nfds

pipefd

private final int[] pipefd

regLock

private final Object regLock

keys

private final Map<SelectionKey,Boolean> keys

selected

private final Set<SelectionKey> selected

Constructor Details

PollSelector

public PollSelector(SelectorProvider provider)

Method Details

putPollFD

private void putPollFD(int idx,
 int fd)

putPollEvents

private void putPollEvents(int idx,
 int events)

getPollFD

private int getPollFD(int idx)

getPollEvents

private short getPollEvents(int idx)

getPollRevents

private short getPollRevents(int idx)

putPollRevents

private void putPollRevents(int idx,
 int events)

implCloseSelector

protected void implCloseSelector()
                          throws IOException

Specified by:

implCloseSelector in class AbstractSelector

Throws:

IOException

register

protected SelectionKey register(AbstractSelectableChannel ch,
 int ops,
 Object att)

Specified by:

register in class AbstractSelector

keys

public Set<SelectionKey> keys()

Specified by:

keys in class Selector

selectedKeys

public Set<SelectionKey> selectedKeys()

Specified by:

selectedKeys in class Selector

interestOps

void interestOps(PollSelectionKey k,
 int ops)

add

private void add(PollSelectionKey k)

remove

private void remove(PollSelectionKey k)

selectNow

public int selectNow()
              throws IOException

Specified by:

selectNow in class Selector

Throws:

IOException

select

public int select(long timeout)
           throws IOException

Specified by:

select in class Selector

Throws:

IOException

select

public int select()
           throws IOException

Specified by:

select in class Selector

Throws:

IOException

poll

private int poll(long timeout)
          throws IOException

Throws:

IOException

wakeupReceived

private void wakeupReceived()
                     throws IOException

Throws:

IOException

wakeup

public Selector wakeup()

Specified by:

wakeup in class Selector