Nested and Inner Type Summary

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

Field Summary

Modifier and Type	Field and Description
private final 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 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 Runtime	runtime
private final Set<SelectionKey>	selected
private final Native.Timespec	ZERO_TIMESPEC

Constructor Summary

Access	Constructor and Description
public	KQSelector(NativeSelectorProvider provider)

Method Summary

Modifier and Type	Method and Description
private int	handleCancelledKeys()
private void	handleChangedKey(KQSelector.Descriptor changed)
protected void	implCloseSelector() Implements abstract java.nio.channels.spi.AbstractSelector.implCloseSelector. Closes this selector.
pack-priv void	interestOps(KQSelectionKey k, int ops)
public Set<SelectionKey>	keys() Implements abstract java.nio.channels.Selector.keys. Returns this selector's key set.
private int	poll(long timeout)
protected SelectionKey	register(AbstractSelectableChannel The channel to be registered ch, int The initial interest set, which must be valid ops, Object The initial attachment for the resulting key att) Implements abstract java.nio.channels.spi.AbstractSelector.register. Registers the given channel with this selector.
public int	select(long If positive, block for up to `timeout` milliseconds, more or less, while waiting for a channel to become ready; if zero, block indefinitely; must not be negative timeout) Implements abstract java.nio.channels.Selector.select. Selects a set of keys whose corresponding channels are ready for I/O operations.
public int	select() Implements abstract java.nio.channels.Selector.select. Selects a set of keys whose corresponding channels are ready for I/O operations.
public Set<SelectionKey>	selectedKeys() Implements abstract java.nio.channels.Selector.selectedKeys. Returns this selector's selected-key set.
public int	selectNow() Implements abstract java.nio.channels.Selector.selectNow. Selects a set of keys whose corresponding channels are ready for I/O operations.
public Selector	wakeup() Implements abstract java.nio.channels.Selector.wakeup. Causes the first selection operation that has not yet returned to return immediately.
private void	wakeupReceived()

Inherited from java.nio.channels.spi.AbstractSelector:: begin cancelledKeys close deregister end isOpen provider

Field Detail

changebuf	back to summary
private final Pointer changebuf

DEBUG	back to summary
private static final boolean DEBUG

descriptors	back to summary
private final Map<Integer, KQSelector.Descriptor> descriptors

EV_ADD	back to summary
private static final int EV_ADD

EV_CLEAR	back to summary
private static final int EV_CLEAR

EV_DELETE	back to summary
private static final int EV_DELETE

EV_DISABLE	back to summary
private static final int EV_DISABLE

EV_ENABLE	back to summary
private static final int EV_ENABLE

eventbuf	back to summary
private final Pointer eventbuf

EVFILT_READ	back to summary
private static final int EVFILT_READ

EVFILT_WRITE	back to summary
private static final int EVFILT_WRITE

io	back to summary
private final KQSelector.EventIO io

kqfd	back to summary
private int kqfd

MAX_EVENTS	back to summary
private static final int MAX_EVENTS

pipefd	back to summary
private final int[] pipefd

regLock	back to summary
private final Object regLock

runtime	back to summary
private final Runtime runtime

selected	back to summary
private final Set<SelectionKey> selected

ZERO_TIMESPEC	back to summary
private final Native.Timespec ZERO_TIMESPEC

Constructor Detail

KQSelector	back to summary
public KQSelector(NativeSelectorProvider provider)

Method Detail

handleCancelledKeys	back to summary
private int handleCancelledKeys()

handleChangedKey	back to summary
private void handleChangedKey(KQSelector.Descriptor changed)

implCloseSelector back to summary

implCloseSelector	back to summary
protected void implCloseSelector() throws IOException Implements abstract java.nio.channels.spi.AbstractSelector.implCloseSelector. Doc from java.nio.channels.spi.AbstractSelector.implCloseSelector. Closes this selector. This method is invoked by the `close` method in order to perform the actual work of closing the selector. This method is only invoked if the selector has not yet been closed, and it is never invoked more than once. An implementation of this method must arrange for any other thread that is blocked in a selection operation upon this selector to return immediately as if by invoking the `wakeup` method. Annotations @Override Exceptions IOException: If an I/O error occurs while closing the selector

protected void implCloseSelector() throws IOException

Implements abstract java.nio.channels.spi.AbstractSelector.implCloseSelector.

Doc from java.nio.channels.spi.AbstractSelector.implCloseSelector.

Closes this selector.

This method is invoked by the close method in order to perform the actual work of closing the selector. This method is only invoked if the selector has not yet been closed, and it is never invoked more than once.

An implementation of this method must arrange for any other thread that is blocked in a selection operation upon this selector to return immediately as if by invoking the wakeup method.

Annotations

@Override

Exceptions

IOException:: If an I/O error occurs while closing the selector

interestOps	back to summary
pack-priv void interestOps(KQSelectionKey k, int ops)

keys back to summary

keys	back to summary
public Set<SelectionKey> keys() Implements abstract java.nio.channels.Selector.keys. Doc from java.nio.channels.Selector.keys. Returns this selector's key set. The key set is not directly modifiable. A key is removed only after it has been cancelled and its channel has been deregistered. Any attempt to modify the key set will cause an `UnsupportedOperationException` to be thrown. The set is safe for use by multiple concurrent threads. Returns:Set<SelectionKey> This selector's key set Annotations @Override

public Set<SelectionKey> keys()

Implements abstract java.nio.channels.Selector.keys.

Doc from java.nio.channels.Selector.keys.

Returns this selector's key set.

The key set is not directly modifiable. A key is removed only after it has been cancelled and its channel has been deregistered. Any attempt to modify the key set will cause an UnsupportedOperationException to be thrown.

The set is safe for use by multiple concurrent threads.

Returns:Set<SelectionKey>

This selector's key set

Annotations

@Override

poll	back to summary
private int poll(long timeout)

register	back to summary
protected SelectionKey register(AbstractSelectableChannel ch, int ops, Object att) Implements abstract java.nio.channels.spi.AbstractSelector.register. Doc from java.nio.channels.spi.AbstractSelector.register. Registers the given channel with this selector. This method is invoked by a channel's `register` method in order to perform the actual work of registering the channel with this selector. Parameters ch:AbstractSelectableChannel The channel to be registered ops:int The initial interest set, which must be valid att:Object The initial attachment for the resulting key Returns:SelectionKey A new key representing the registration of the given channel with this selector Annotations @Override

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

Implements abstract java.nio.channels.spi.AbstractSelector.register.

Doc from java.nio.channels.spi.AbstractSelector.register.

Registers the given channel with this selector.

This method is invoked by a channel's register method in order to perform the actual work of registering the channel with this selector.

Parameters

ch:AbstractSelectableChannel: The channel to be registered
ops:int: The initial interest set, which must be valid
att:Object: The initial attachment for the resulting key

Returns:SelectionKey

A new key representing the registration of the given channel with this selector

Annotations

@Override

select back to summary

select	back to summary
public int select(long timeout) throws IOException Implements abstract java.nio.channels.Selector.select. Doc from java.nio.channels.Selector.select. Selects a set of keys whose corresponding channels are ready for I/O operations. This method performs a blocking selection operation. It returns only after at least one channel is selected, this selector's `wakeup` method is invoked, the current thread is interrupted, or the given timeout period expires, whichever comes first. This method does not offer real-time guarantees: It schedules the timeout as if by invoking the `Object#wait(long)` method. Parameters timeout:long If positive, block for up to `timeout` milliseconds, more or less, while waiting for a channel to become ready; if zero, block indefinitely; must not be negative Returns:int The number of keys, possibly zero, whose ready-operation sets now indicate readiness for at least one category of operations for which the channel was not previously detected to be ready Annotations @Override Exceptions IOException: If an I/O error occurs

public int select(long timeout) throws IOException

Implements abstract java.nio.channels.Selector.select.

Doc from java.nio.channels.Selector.select.

Selects a set of keys whose corresponding channels are ready for I/O operations.

This method performs a blocking selection operation. It returns only after at least one channel is selected, this selector's wakeup method is invoked, the current thread is interrupted, or the given timeout period expires, whichever comes first.

This method does not offer real-time guarantees: It schedules the timeout as if by invoking the Object#wait(long) method.

Parameters

timeout:long: If positive, block for up to timeout milliseconds, more or less, while waiting for a channel to become ready; if zero, block indefinitely; must not be negative

Returns:int

The number of keys, possibly zero, whose ready-operation sets now indicate readiness for at least one category of operations for which the channel was not previously detected to be ready

Annotations

@Override

Exceptions

IOException:: If an I/O error occurs

select back to summary

select	back to summary
public int select() throws IOException Implements abstract java.nio.channels.Selector.select. Doc from java.nio.channels.Selector.select. Selects a set of keys whose corresponding channels are ready for I/O operations. This method performs a blocking selection operation. It returns only after at least one channel is selected, this selector's `wakeup` method is invoked, or the current thread is interrupted, whichever comes first. Returns:int The number of keys, possibly zero, whose ready-operation sets now indicate readiness for at least one category of operations for which the channel was not previously detected to be ready Annotations @Override Exceptions IOException: If an I/O error occurs

public int select() throws IOException

Implements abstract java.nio.channels.Selector.select.

Doc from java.nio.channels.Selector.select.

Selects a set of keys whose corresponding channels are ready for I/O operations.

This method performs a blocking selection operation. It returns only after at least one channel is selected, this selector's wakeup method is invoked, or the current thread is interrupted, whichever comes first.

Returns:int

The number of keys, possibly zero, whose ready-operation sets now indicate readiness for at least one category of operations for which the channel was not previously detected to be ready

Annotations

@Override

Exceptions

IOException:: If an I/O error occurs

selectedKeys back to summary

selectedKeys	back to summary
public Set<SelectionKey> selectedKeys() Implements abstract java.nio.channels.Selector.selectedKeys. Doc from java.nio.channels.Selector.selectedKeys. Returns this selector's selected-key set. Keys may be removed from, but not directly added to, the selected-key set. Any attempt to add an object to the key set will cause an `UnsupportedOperationException` to be thrown. The selected-key set is not thread-safe. Returns:Set<SelectionKey> This selector's selected-key set Annotations @Override

public Set<SelectionKey> selectedKeys()

Implements abstract java.nio.channels.Selector.selectedKeys.

Doc from java.nio.channels.Selector.selectedKeys.

Returns this selector's selected-key set.

Keys may be removed from, but not directly added to, the selected-key set. Any attempt to add an object to the key set will cause an UnsupportedOperationException to be thrown.

The selected-key set is not thread-safe.

Returns:Set<SelectionKey>

This selector's selected-key set

Annotations

@Override

selectNow back to summary

selectNow	back to summary
public int selectNow() throws IOException Implements abstract java.nio.channels.Selector.selectNow. Doc from java.nio.channels.Selector.selectNow. Selects a set of keys whose corresponding channels are ready for I/O operations. This method performs a non-blocking selection operation. If no channels have become selectable since the previous selection operation then this method immediately returns zero. Invoking this method clears the effect of any previous invocations of the `wakeup` method. Returns:int The number of keys, possibly zero, whose ready-operation sets now indicate readiness for at least one category of operations for which the channel was not previously detected to be ready Annotations @Override Exceptions IOException: If an I/O error occurs

public int selectNow() throws IOException

Implements abstract java.nio.channels.Selector.selectNow.

Doc from java.nio.channels.Selector.selectNow.

Selects a set of keys whose corresponding channels are ready for I/O operations.

This method performs a non-blocking selection operation. If no channels have become selectable since the previous selection operation then this method immediately returns zero.

Invoking this method clears the effect of any previous invocations of the wakeup method.

Returns:int

The number of keys, possibly zero, whose ready-operation sets now indicate readiness for at least one category of operations for which the channel was not previously detected to be ready

Annotations

@Override

Exceptions

IOException:: If an I/O error occurs

wakeup back to summary

wakeup	back to summary
public Selector wakeup() Implements abstract java.nio.channels.Selector.wakeup. Doc from java.nio.channels.Selector.wakeup. Causes the first selection operation that has not yet returned to return immediately. If another thread is currently blocked in a selection operation then that invocation will return immediately. If no selection operation is currently in progress then the next invocation of a selection operation will return immediately unless `selectNow()` or `selectNow(Consumer)` is invoked in the meantime. In any case the value returned by that invocation may be non-zero. Subsequent selection operations will block as usual unless this method is invoked again in the meantime. Invoking this method more than once between two successive selection operations has the same effect as invoking it just once. Returns:Selector This selector Annotations @Override

public Selector wakeup()

Implements abstract java.nio.channels.Selector.wakeup.

Doc from java.nio.channels.Selector.wakeup.

Causes the first selection operation that has not yet returned to return immediately.

If another thread is currently blocked in a selection operation then that invocation will return immediately. If no selection operation is currently in progress then the next invocation of a selection operation will return immediately unless selectNow() or selectNow(Consumer) is invoked in the meantime. In any case the value returned by that invocation may be non-zero. Subsequent selection operations will block as usual unless this method is invoked again in the meantime.

Invoking this method more than once between two successive selection operations has the same effect as invoking it just once.

Returns:Selector

This selector

Annotations

@Override

wakeupReceived	back to summary
private void wakeupReceived()

jnr.enxio.channels back to summary

private Class KQSelector.Descriptor

Class Inheritance

extends Object

java.lang.Object
jnr.enxio.channels.KQSelector.Descriptor

Field Summary

Modifier and Type	Field and Description
private final int	fd
private final Set<KQSelectionKey>	keys
private boolean	read
private boolean	write

Constructor Summary

Access	Constructor and Description
public	Descriptor(int fd)

Method Summary

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

fd	back to summary
private final int fd

keys	back to summary
private final Set<KQSelectionKey> keys

read	back to summary
private boolean read

write	back to summary
private boolean write

Constructor Detail

Descriptor	back to summary
public Descriptor(int fd)

jnr.enxio.channels back to summary

private final Class KQSelector.EventIO

Class Inheritance

extends Object

java.lang.Object
jnr.enxio.channels.KQSelector.EventIO

Field Summary

Modifier and Type	Field and Description
private static final KQSelector.EventIO	INSTANCE
private final KQSelector.EventLayout	layout
private final Type	uintptr_t

Constructor Summary

Access	Constructor and Description
private	EventIO()

Method Summary

Modifier and Type	Method and Description
pack-priv int	getFD(Pointer ptr, int index)
public final int	getFilter(Pointer buf, int index)
public static KQSelector.EventIO	getInstance()
public final void	put(Pointer buf, int index, int fd, int filt, int flags)
public final void	putFilter(Pointer buf, int index, int filter)
public final void	putFlags(Pointer buf, int index, int flags)
public final int	size()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

INSTANCE	back to summary
private static final KQSelector.EventIO INSTANCE

layout	back to summary
private final KQSelector.EventLayout layout

uintptr_t	back to summary
private final Type uintptr_t

Constructor Detail

EventIO	back to summary
private EventIO()

Method Detail

getFD	back to summary
pack-priv int getFD(Pointer ptr, int index)

getFilter	back to summary
public final int getFilter(Pointer buf, int index)

getInstance	back to summary
public static KQSelector.EventIO getInstance()

put	back to summary
public final void put(Pointer buf, int index, int fd, int filt, int flags)

putFilter	back to summary
public final void putFilter(Pointer buf, int index, int filter)

putFlags	back to summary
public final void putFlags(Pointer buf, int index, int flags)

size	back to summary
public final int size()

jnr.enxio.channels back to summary

private abstract Class KQSelector.EventLayout

Class Inheritance

extends StructLayout

java.lang.Object
jnr.ffi.Type
jnr.ffi.StructLayout
jnr.enxio.channels.KQSelector.EventLayout

Known Direct Subclasses

jnr.enxio.channels.KQSelector.LegacyEventLayout, jnr.enxio.channels.KQSelector.FreeBSD12EventLayout

Field Summary

Modifier and Type	Field and Description
public final StructLayout.u_int32_t	fflags
public final StructLayout.int16_t	filter
public final StructLayout.u_int16_t	flags
public final StructLayout.uintptr_t	ident

Constructor Summary

Access	Constructor and Description
private	EventLayout(Runtime runtime)

Method Summary

Inherited from jnr.ffi.StructLayout:: addField addField addField addField alignment array arrayBegin arrayEnd at function function getNativeType getRuntime inner offset size toString

Field Detail

fflags	back to summary
public final StructLayout.u_int32_t fflags

filter	back to summary
public final StructLayout.int16_t filter

flags	back to summary
public final StructLayout.u_int16_t flags

ident	back to summary
public final StructLayout.uintptr_t ident

Constructor Detail

EventLayout	back to summary
private EventLayout(Runtime runtime)

jnr.enxio.channels back to summary

private Class KQSelector.FreeBSD12EventLayout

Class Inheritance

extends EventLayout

java.lang.Object
jnr.ffi.Type
jnr.ffi.StructLayout
jnr.enxio.channels.KQSelector.EventLayout
jnr.enxio.channels.KQSelector.FreeBSD12EventLayout

Field Summary

Modifier and Type	Field and Description
public final StructLayout.int64_t	data
public final StructLayout.u_int64_t[]	ext
public final StructLayout.Pointer	udata

Inherited from jnr.enxio.channels.KQSelector.EventLayout:: fflags filter flags ident

Constructor Summary

Access	Constructor and Description
private	FreeBSD12EventLayout(Runtime runtime)

Field Detail

data	back to summary
public final StructLayout.int64_t data

ext	back to summary
public final StructLayout.u_int64_t[] ext

udata	back to summary
public final StructLayout.Pointer udata

Constructor Detail

FreeBSD12EventLayout	back to summary
private FreeBSD12EventLayout(Runtime runtime)

jnr.enxio.channels back to summary

private Class KQSelector.LegacyEventLayout

Class Inheritance

extends EventLayout

java.lang.Object
jnr.ffi.Type
jnr.ffi.StructLayout
jnr.enxio.channels.KQSelector.EventLayout
jnr.enxio.channels.KQSelector.LegacyEventLayout

Field Summary

Modifier and Type	Field and Description
public final StructLayout.intptr_t	data
public final StructLayout.Pointer	udata

Inherited from jnr.enxio.channels.KQSelector.EventLayout:: fflags filter flags ident

Constructor Summary

Access	Constructor and Description
private	LegacyEventLayout(Runtime runtime)

Field Detail

data	back to summary
public final StructLayout.intptr_t data

udata	back to summary
public final StructLayout.Pointer udata

Constructor Detail

LegacyEventLayout	back to summary
private LegacyEventLayout(Runtime runtime)

pack-priv Class KQSelector

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class KQSelector.Descriptor

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

private final Class KQSelector.EventIO

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private abstract Class KQSelector.EventLayout

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

private Class KQSelector.FreeBSD12EventLayout

Field Summary

Constructor Summary

Field Detail

Constructor Detail

private Class KQSelector.LegacyEventLayout

Field Summary

Constructor Summary

Field Detail

Constructor Detail