Grizzly NIO 5.0.2 · org.glassfish.grizzly.nio.SelectorRunner

Modifier and Type	Field and Description
private Queue<SelectorHandlerTask>	currentPostponedTasks
private volatile int	dumbVolatile
private int	emptySpinCounter
private final Queue<SelectorHandlerTask>	evenPostponedTasks
pack-priv volatile boolean	hasPendingTasks
private boolean	isResume
private Iterator<SelectionKey>	iterator
private SelectionKey	key
private int	keyReadyOps
private int	lastSelectedKeysCount
private long	lastSpinTimestamp Selector spin discovering
private static final Logger	LOGGER
private final Queue<SelectorHandlerTask>	oddPostponedTasks
private final Queue<SelectorHandlerTask>	pendingTasks
private Set<SelectionKey>	readyKeySet
private final AtomicInteger	runnerThreadActivityCounter
private Selector	selector
private Thread	selectorRunnerThread
private final AtomicBoolean	selectorWakeupFlag
private final Map<Selector, Long>	spinnedSelectorsHistory
private final AtomicReference<Transport.State>	stateHolder
private static final String	THREAD_MARKER
private final NIOTransport	transport

Access	Constructor and Description
private	SelectorRunner(final NIOTransport transport, final Selector selector)

Method Summary

Modifier and Type	Method and Description
private void	abortTasksInQueue(final Queue<SelectorHandlerTask> taskQueue)
pack-priv void	addPendingTask(final SelectorHandlerTask task)
private void	addThreadNameMarker(final Thread currentThread)
pack-priv SelectionKey	checkIfSpinnedKey(final SelectionKey key)
pack-priv void	checkSelectorSpin(final boolean hasSelectedKeys, final int spinRateThreshold)
public static SelectorRunner	create(final NIOTransport transport)
protected boolean	doSelect() This method handle the processing of all Selector's interest op (OP_ACCEPT,OP_READ,OP_WRITE,OP_CONNECT) by delegating to its Handler.
private void	dropConnectionDueToException(final SelectionKey `SelectionKey`, which was processed, when the `Exception` occurred key, final String error description description, final Exception `Exception` occurred e, final Level logger `Level` to use, if transport is in running state runLogLevel, final Level logger `Level` to use, if transport is not in running state stoppedLogLevel) Notify transport about the `Exception` happened, log it and cancel the `SelectionKey`, if it is not null
public int	Returns: number of `SelectionKey`s, which were selected last time. getLastSelectedKeysCount() Number of `SelectionKey`s, which were selected last time.
public Queue<SelectorHandlerTask>	getPendingTasks()
public Queue<SelectorHandlerTask>	getPostponedTasks()
public Thread	getRunnerThread()
public Selector	getSelector()
public Transport.State	getState()
public NIOTransport	getTransport()
pack-priv int	Returns: current spin rate (emptyspins/sec). incSpinCounter() Increments spin counter and returns current spin rate (emptyspins/sec).
private boolean	isRunning()
pack-priv boolean	isStop()
private boolean	iterateKeyEvents()
private boolean	iterateKeys()
public Queue<SelectorHandlerTask>	obtainPostponedTasks()
public void	postpone()
private void	removeThreadNameMarker(final Thread currentThread)
pack-priv void	resetSpinCounter()
public void	run() Implements java.lang.Runnable.run. Runs this operation.
private void	setRunnerThread(final Thread runnerThread)
pack-priv void	setSelector(final Selector the new `Selector` to be associated with this `SelectorRunner`. selector) Sets the `Selector`, associated with the runner.
private void	shutdownSelector()
public synchronized void	start()
public synchronized void	stop()
protected void	switchToNewSelector()
private void	wakeupSelector()
pack-priv void	workaroundSelectorSpin()

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

Field Detail

currentPostponedTasks	back to summary
private Queue<SelectorHandlerTask> currentPostponedTasks

dumbVolatile	back to summary
private volatile int dumbVolatile

emptySpinCounter	back to summary
private int emptySpinCounter

evenPostponedTasks	back to summary
private final Queue<SelectorHandlerTask> evenPostponedTasks

hasPendingTasks	back to summary
pack-priv volatile boolean hasPendingTasks

isResume	back to summary
private boolean isResume

iterator	back to summary
private Iterator<SelectionKey> iterator

key	back to summary
private SelectionKey key

keyReadyOps	back to summary
private int keyReadyOps

lastSelectedKeysCount	back to summary
private int lastSelectedKeysCount

lastSpinTimestamp	back to summary
private long lastSpinTimestamp Selector spin discovering

LOGGER	back to summary
private static final Logger LOGGER

oddPostponedTasks	back to summary
private final Queue<SelectorHandlerTask> oddPostponedTasks

pendingTasks	back to summary
private final Queue<SelectorHandlerTask> pendingTasks

readyKeySet	back to summary
private Set<SelectionKey> readyKeySet

runnerThreadActivityCounter	back to summary
private final AtomicInteger runnerThreadActivityCounter

selector	back to summary
private Selector selector

selectorRunnerThread	back to summary
private Thread selectorRunnerThread

selectorWakeupFlag	back to summary
private final AtomicBoolean selectorWakeupFlag

spinnedSelectorsHistory	back to summary
private final Map<Selector, Long> spinnedSelectorsHistory

stateHolder	back to summary
private final AtomicReference<Transport.State> stateHolder

THREAD_MARKER	back to summary
private static final String THREAD_MARKER

transport	back to summary
private final NIOTransport transport

Constructor Detail

SelectorRunner	back to summary
private SelectorRunner(final NIOTransport transport, final Selector selector)

Method Detail

abortTasksInQueue	back to summary
private void abortTasksInQueue(final Queue<SelectorHandlerTask> taskQueue)

addPendingTask	back to summary
pack-priv void addPendingTask(final SelectorHandlerTask task)

addThreadNameMarker	back to summary
private void addThreadNameMarker(final Thread currentThread)

checkIfSpinnedKey	back to summary
pack-priv SelectionKey checkIfSpinnedKey(final SelectionKey key)

checkSelectorSpin	back to summary
pack-priv void checkSelectorSpin(final boolean hasSelectedKeys, final int spinRateThreshold) throws IOException

create	back to summary
public static SelectorRunner create(final NIOTransport transport) throws IOException

doSelect	back to summary
protected boolean doSelect() This method handle the processing of all Selector's interest op (OP_ACCEPT,OP_READ,OP_WRITE,OP_CONNECT) by delegating to its Handler. By default, all java.nio.channels.Selector operations are implemented using SelectorHandler. All SelectionKey operations are implemented by SelectionKeyHandler. Finally, ProtocolChain creation/re-use are implemented by InstanceHandler.

doSelect

back to summary

protected boolean doSelect()

This method handle the processing of all Selector's interest op (OP_ACCEPT,OP_READ,OP_WRITE,OP_CONNECT) by delegating to its Handler. By default, all java.nio.channels.Selector operations are implemented using SelectorHandler. All SelectionKey operations are implemented by SelectionKeyHandler. Finally, ProtocolChain creation/re-use are implemented by InstanceHandler.

dropConnectionDueToException back to summary

dropConnectionDueToException	back to summary
private void dropConnectionDueToException(final SelectionKey key, final String description, final Exception e, final Level runLogLevel, final Level stoppedLogLevel) Notify transport about the `Exception` happened, log it and cancel the `SelectionKey`, if it is not null Parameters key:SelectionKey `SelectionKey`, which was processed, when the `Exception` occurred description:String error description e:Exception `Exception` occurred runLogLevel:Level logger `Level` to use, if transport is in running state stoppedLogLevel:Level logger `Level` to use, if transport is not in running state

private void dropConnectionDueToException(final SelectionKey key, final String description, final Exception e, final Level runLogLevel, final Level stoppedLogLevel)

Notify transport about the Exception happened, log it and cancel the SelectionKey, if it is not null

Parameters

key:SelectionKey: SelectionKey, which was processed, when the Exception occurred
description:String: error description
e:Exception: Exception occurred
runLogLevel:Level: logger Level to use, if transport is in running state
stoppedLogLevel:Level: logger Level to use, if transport is not in running state

getLastSelectedKeysCount back to summary

getLastSelectedKeysCount	back to summary
public int getLastSelectedKeysCount() Number of `SelectionKey`s, which were selected last time. Operation is not thread-safe. Returns:int number of `SelectionKey`s, which were selected last time.

public int getLastSelectedKeysCount()

Number of SelectionKeys, which were selected last time. Operation is not thread-safe.

Returns:int: number of SelectionKeys, which were selected last time.

getPendingTasks	back to summary
public Queue<SelectorHandlerTask> getPendingTasks()

getPostponedTasks	back to summary
public Queue<SelectorHandlerTask> getPostponedTasks()

getRunnerThread	back to summary
public Thread getRunnerThread()

getSelector	back to summary
public Selector getSelector()

getState	back to summary
public Transport.State getState()

getTransport	back to summary
public NIOTransport getTransport()

incSpinCounter	back to summary
pack-priv int incSpinCounter() Increments spin counter and returns current spin rate (emptyspins/sec). Returns:int current spin rate (emptyspins/sec).

incSpinCounter

back to summary

pack-priv int incSpinCounter()

Increments spin counter and returns current spin rate (emptyspins/sec).

Returns:int: current spin rate (emptyspins/sec).

isRunning	back to summary
private boolean isRunning()

isStop	back to summary
pack-priv boolean isStop()

iterateKeyEvents	back to summary
private boolean iterateKeyEvents() throws IOException

iterateKeys	back to summary
private boolean iterateKeys()

obtainPostponedTasks	back to summary
public Queue<SelectorHandlerTask> obtainPostponedTasks()

postpone	back to summary
public void postpone()

removeThreadNameMarker	back to summary
private void removeThreadNameMarker(final Thread currentThread)

resetSpinCounter	back to summary
pack-priv void resetSpinCounter()

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

setRunnerThread	back to summary
private void setRunnerThread(final Thread runnerThread)

setSelector back to summary

pack-priv void setSelector(final Selector selector)

Sets the Selector, associated with the runner. The method should be called from the runner thread.

Parameters

selector:Selector: the new Selector to be associated with this SelectorRunner.

shutdownSelector	back to summary
private void shutdownSelector()

start	back to summary
public synchronized void start()

stop	back to summary
public synchronized void stop()

switchToNewSelector	back to summary
protected void switchToNewSelector() throws IOException

wakeupSelector	back to summary
private void wakeupSelector()

workaroundSelectorSpin	back to summary
pack-priv void workaroundSelectorSpin() throws IOException

public final Class SelectorRunner

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail