Class KQSelector

java.lang.Object

java.nio.channels.Selector

java.nio.channels.spi.AbstractSelector

jnr.enxio.channels.KQSelector

All Implemented Interfaces:

Closeable, AutoCloseable

class KQSelector
extends AbstractSelector

An implementation of a Selector that uses the BSD (including MacOS) kqueue(2) mechanism

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	KQSelector.Descriptor
private static final class	KQSelector.EventIO
private static class	KQSelector.EventLayout
private static class	KQSelector.FreeBSD12EventLayout
private static class	KQSelector.LegacyEventLayout

Field Summary

Fields

Modifier and Type	Field	Description
private final jnr.ffi.Pointer	changebuf
private static final boolean	DEBUG
private final Map<Integer, KQSelector.Descriptor>	descriptors
private static final int	EV_ADD
private static final int	EV_CLEAR
private static final int	EV_DELETE
private static final int	EV_DISABLE
private static final int	EV_ENABLE
private final jnr.ffi.Pointer	eventbuf
private static final int	EVFILT_READ
private static final int	EVFILT_WRITE
private final KQSelector.EventIO	io
private int	kqfd
private static final int	MAX_EVENTS
private final int[]	pipefd
private final Object	regLock
private final jnr.ffi.Runtime	runtime
private final Set<SelectionKey>	selected
private final Native.Timespec	ZERO_TIMESPEC

Constructor Summary

Constructors

Constructor	Description
KQSelector(NativeSelectorProvider provider)

Method Summary

Modifier and Type	Method	Description
private int	handleCancelledKeys()
private void	handleChangedKey(KQSelector.Descriptor changed)
protected void	implCloseSelector()
(package private) void	interestOps(KQSelectionKey k, int ops)
Set<SelectionKey>	keys()
private int	poll(long timeout)
protected SelectionKey	register(AbstractSelectableChannel ch, int ops, Object att)
int	select()
int	select(long timeout)
Set<SelectionKey>	selectedKeys()
int	selectNow()
Selector	wakeup()
private void	wakeupReceived()

Methods inherited from class AbstractSelector

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

Methods inherited from class Selector

open

Methods inherited from class Object

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

Field Details

DEBUG

private static final boolean DEBUG

See Also:

• Constant Field Values

MAX_EVENTS

private static final int MAX_EVENTS

See Also:

• Constant Field Values

EVFILT_READ

private static final int EVFILT_READ

See Also:

• Constant Field Values

EVFILT_WRITE

private static final int EVFILT_WRITE

See Also:

• Constant Field Values

EV_ADD

private static final int EV_ADD

See Also:

• Constant Field Values

EV_DELETE

private static final int EV_DELETE

See Also:

• Constant Field Values

EV_ENABLE

private static final int EV_ENABLE

See Also:

• Constant Field Values

EV_DISABLE

private static final int EV_DISABLE

See Also:

• Constant Field Values

EV_CLEAR

private static final int EV_CLEAR

See Also:

• Constant Field Values

kqfd

private int kqfd

runtime

private final jnr.ffi.Runtime runtime

changebuf

private final jnr.ffi.Pointer changebuf

eventbuf

private final jnr.ffi.Pointer eventbuf

io

private final KQSelector.EventIO io

pipefd

private final int[] pipefd

regLock

private final Object regLock

descriptors

private final Map<Integer, KQSelector.Descriptor> descriptors

selected

private final Set<SelectionKey> selected

ZERO_TIMESPEC

private final Native.Timespec ZERO_TIMESPEC

Constructor Details

KQSelector

public KQSelector(NativeSelectorProvider provider)

Method Details

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

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)

handleCancelledKeys

private int handleCancelledKeys()

handleChangedKey

private void handleChangedKey(KQSelector.Descriptor changed)

wakeupReceived

private void wakeupReceived()

wakeup

public Selector wakeup()

Specified by:

wakeup in class Selector

interestOps

void interestOps(KQSelectionKey k,
 int ops)