Modifier and Type	Class and Description
protected static class	DefaultSelectorHandler.DeregisterChannelOperation
protected static class	DefaultSelectorHandler.RegisterChannelOperation
protected static class	DefaultSelectorHandler.RegisterKeyTask
protected static class	DefaultSelectorHandler.RunnableTask

Modifier and Type	Field and Description
private static final long	DEFAULT_SELECT_TIMEOUT_MILLIS
public static final boolean	IS_WORKAROUND_SELECTOR_SPIN
private static final Logger	logger
protected final long	selectTimeout
private static final int	SPIN_RATE_THRESHOLD The threshold for detecting selector.select spin on linux, used for enabling workaround to prevent server from hanging.

Access	Constructor and Description
public	DefaultSelectorHandler()
public	DefaultSelectorHandler(final long selectTimeout, final TimeUnit timeunit)

Modifier and Type	Method and Description
private void	addPendingTask(final SelectorRunner selectorRunner, final SelectorHandlerTask task)
public void	deregisterChannel(final SelectorRunner selectorRunner, final SelectableChannel channel) Implements org.glassfish.grizzly.nio.SelectorHandler.deregisterChannel. Deregister the channel from the `SelectorRunner`'s Selector.
private static void	deregisterChannel0(final SelectorRunner selectorRunner, final SelectableChannel channel, final CompletionHandler<RegisterChannelResult> completionHandler)
public void	deregisterChannelAsync(final SelectorRunner selectorRunner, final SelectableChannel channel, final CompletionHandler<RegisterChannelResult> completionHandler) Implements org.glassfish.grizzly.nio.SelectorHandler.deregisterChannelAsync. Deregister the channel from the `SelectorRunner`'s Selector.
public void	deregisterKeyInterest(final SelectorRunner selectorRunner, final SelectionKey key, final int interest) Implements org.glassfish.grizzly.nio.SelectorHandler.deregisterKeyInterest. Deregisters SelectionKey interest.
public void	enque(final SelectorRunner selectorRunner, final SelectorHandler.Task task, final CompletionHandler<SelectorHandler.Task> completionHandler) Implements org.glassfish.grizzly.nio.SelectorHandler.enque. Execute task in a selector thread.
public void	execute(final SelectorRunner selectorRunner, final SelectorHandler.Task task, final CompletionHandler<SelectorHandler.Task> completionHandler) Implements org.glassfish.grizzly.nio.SelectorHandler.execute. Execute task in a selector thread.
private static void	failChannelRegistration(final CompletionHandler<RegisterChannelResult> completionHandler, final Throwable error)
public long	getSelectTimeout() Implements org.glassfish.grizzly.nio.SelectorHandler.getSelectTimeout.
private static boolean	isSelectorRunnerThread(final SelectorRunner selectorRunner)
public boolean	onSelectorClosed(final SelectorRunner selectorRunner) Implements org.glassfish.grizzly.nio.SelectorHandler.onSelectorClosed.
public void	postSelect(final SelectorRunner selectorRunner) Implements org.glassfish.grizzly.nio.SelectorHandler.postSelect.
public boolean	preSelect(final SelectorRunner selectorRunner) Implements org.glassfish.grizzly.nio.SelectorHandler.preSelect.
private boolean	processPendingTaskQueue(final SelectorRunner selectorRunner, final Queue<SelectorHandlerTask> selectorHandlerTasks)
private boolean	processPendingTasks(final SelectorRunner selectorRunner)
public void	registerChannel(final SelectorRunner selectorRunner, final SelectableChannel channel, final int interest, final Object attachment) Implements org.glassfish.grizzly.nio.SelectorHandler.registerChannel.
private static void	registerChannel0(final SelectorRunner selectorRunner, final SelectableChannel channel, final int interest, final Object attachment, final CompletionHandler<RegisterChannelResult> completionHandler)
public void	registerChannelAsync(SelectorRunner selectorRunner, SelectableChannel channel, int interest, Object attachment, CompletionHandler<RegisterChannelResult> completionHandler) Implements org.glassfish.grizzly.nio.SelectorHandler.registerChannelAsync.
private static void	registerKey0(final SelectionKey selectionKey, final int interest)
public void	registerKeyInterest(final SelectorRunner selectorRunner, final SelectionKey key, final int interest) Implements org.glassfish.grizzly.nio.SelectorHandler.registerKeyInterest.
public Set<SelectionKey>	select(final SelectorRunner selectorRunner) Implements org.glassfish.grizzly.nio.SelectorHandler.select.

DEFAULT_SELECT_TIMEOUT_MILLIS	back to summary
private static final long DEFAULT_SELECT_TIMEOUT_MILLIS

IS_WORKAROUND_SELECTOR_SPIN	back to summary
public static final boolean IS_WORKAROUND_SELECTOR_SPIN

logger	back to summary
private static final Logger logger

selectTimeout	back to summary
protected final long selectTimeout

SPIN_RATE_THRESHOLD	back to summary
private static final int SPIN_RATE_THRESHOLD The threshold for detecting selector.select spin on linux, used for enabling workaround to prevent server from hanging.

DefaultSelectorHandler	back to summary
public DefaultSelectorHandler()

DefaultSelectorHandler	back to summary
public DefaultSelectorHandler(final long selectTimeout, final TimeUnit timeunit)

Method Detail

addPendingTask	back to summary
private void addPendingTask(final SelectorRunner selectorRunner, final SelectorHandlerTask task)

deregisterChannel back to summary

deregisterChannel	back to summary
public void deregisterChannel(final SelectorRunner selectorRunner, final SelectableChannel channel) throws IOException Implements org.glassfish.grizzly.nio.SelectorHandler.deregisterChannel. Doc from org.glassfish.grizzly.nio.SelectorHandler.deregisterChannel. Deregister the channel from the `SelectorRunner`'s Selector. Annotations @Override

public void deregisterChannel(final SelectorRunner selectorRunner, final SelectableChannel channel) throws IOException

Implements org.glassfish.grizzly.nio.SelectorHandler.deregisterChannel.

Doc from org.glassfish.grizzly.nio.SelectorHandler.deregisterChannel.

Deregister the channel from the SelectorRunner's Selector.

Annotations

@Override

deregisterChannel0	back to summary
private static void deregisterChannel0(final SelectorRunner selectorRunner, final SelectableChannel channel, final CompletionHandler<RegisterChannelResult> completionHandler)

deregisterChannelAsync back to summary

deregisterChannelAsync	back to summary
public void deregisterChannelAsync(final SelectorRunner selectorRunner, final SelectableChannel channel, final CompletionHandler<RegisterChannelResult> completionHandler) Implements org.glassfish.grizzly.nio.SelectorHandler.deregisterChannelAsync. Doc from org.glassfish.grizzly.nio.SelectorHandler.deregisterChannelAsync. Deregister the channel from the `SelectorRunner`'s Selector. Annotations @Override

public void deregisterChannelAsync(final SelectorRunner selectorRunner, final SelectableChannel channel, final CompletionHandler<RegisterChannelResult> completionHandler)

Implements org.glassfish.grizzly.nio.SelectorHandler.deregisterChannelAsync.

Doc from org.glassfish.grizzly.nio.SelectorHandler.deregisterChannelAsync.

Deregister the channel from the SelectorRunner's Selector.

Annotations

@Override

deregisterKeyInterest	back to summary
public void deregisterKeyInterest(final SelectorRunner selectorRunner, final SelectionKey key, final int interest) throws IOException Implements org.glassfish.grizzly.nio.SelectorHandler.deregisterKeyInterest. Doc from org.glassfish.grizzly.nio.SelectorHandler.deregisterKeyInterest. Deregisters SelectionKey interest. This method must be called from the SelectorRunner's thread only! Annotations @Override

deregisterKeyInterest

back to summary

public void deregisterKeyInterest(final SelectorRunner selectorRunner, final SelectionKey key, final int interest) throws IOException

Implements org.glassfish.grizzly.nio.SelectorHandler.deregisterKeyInterest.

Doc from org.glassfish.grizzly.nio.SelectorHandler.deregisterKeyInterest.

Deregisters SelectionKey interest. This method must be called from the SelectorRunner's thread only!

Annotations

@Override

enque back to summary

enque	back to summary
public void enque(final SelectorRunner selectorRunner, final SelectorHandler.Task task, final CompletionHandler<SelectorHandler.Task> completionHandler) Implements org.glassfish.grizzly.nio.SelectorHandler.enque. Doc from org.glassfish.grizzly.nio.SelectorHandler.enque. Execute task in a selector thread. Unlike `execute(org.glassfish.grizzly.nio.SelectorRunner, org.glassfish.grizzly.nio.SelectorHandler.Task, org.glassfish.grizzly.CompletionHandler)`, this operation will postpone the task execution if current thread is a selector thread, and execute it during the next `select(org.glassfish.grizzly.nio.SelectorRunner)` iteration. Annotations @Override

public void enque(final SelectorRunner selectorRunner, final SelectorHandler.Task task, final CompletionHandler<SelectorHandler.Task> completionHandler)

Implements org.glassfish.grizzly.nio.SelectorHandler.enque.

Doc from org.glassfish.grizzly.nio.SelectorHandler.enque.

Execute task in a selector thread. Unlike execute(org.glassfish.grizzly.nio.SelectorRunner, org.glassfish.grizzly.nio.SelectorHandler.Task, org.glassfish.grizzly.CompletionHandler), this operation will postpone the task execution if current thread is a selector thread, and execute it during the next select(org.glassfish.grizzly.nio.SelectorRunner) iteration.

Annotations

@Override

execute back to summary

execute	back to summary
public void execute(final SelectorRunner selectorRunner, final SelectorHandler.Task task, final CompletionHandler<SelectorHandler.Task> completionHandler) Implements org.glassfish.grizzly.nio.SelectorHandler.execute. Doc from org.glassfish.grizzly.nio.SelectorHandler.execute. Execute task in a selector thread. Unlike `enque(org.glassfish.grizzly.nio.SelectorRunner, org.glassfish.grizzly.nio.SelectorHandler.Task, org.glassfish.grizzly.CompletionHandler)`, this operation will execute the task immediately if the current is a selector thread. Annotations @Override

public void execute(final SelectorRunner selectorRunner, final SelectorHandler.Task task, final CompletionHandler<SelectorHandler.Task> completionHandler)

Implements org.glassfish.grizzly.nio.SelectorHandler.execute.

Doc from org.glassfish.grizzly.nio.SelectorHandler.execute.

Execute task in a selector thread. Unlike enque(org.glassfish.grizzly.nio.SelectorRunner, org.glassfish.grizzly.nio.SelectorHandler.Task, org.glassfish.grizzly.CompletionHandler), this operation will execute the task immediately if the current is a selector thread.

Annotations

@Override

failChannelRegistration	back to summary
private static void failChannelRegistration(final CompletionHandler<RegisterChannelResult> completionHandler, final Throwable error)

getSelectTimeout	back to summary
public long getSelectTimeout() Implements org.glassfish.grizzly.nio.SelectorHandler.getSelectTimeout. Annotations @Override

getSelectTimeout

back to summary

public long getSelectTimeout()

Implements org.glassfish.grizzly.nio.SelectorHandler.getSelectTimeout.

Annotations

@Override

isSelectorRunnerThread	back to summary
private static boolean isSelectorRunnerThread(final SelectorRunner selectorRunner)

onSelectorClosed	back to summary
public boolean onSelectorClosed(final SelectorRunner selectorRunner) Implements org.glassfish.grizzly.nio.SelectorHandler.onSelectorClosed. Annotations @Override

onSelectorClosed

back to summary

public boolean onSelectorClosed(final SelectorRunner selectorRunner)

Implements org.glassfish.grizzly.nio.SelectorHandler.onSelectorClosed.

Annotations

@Override

postSelect	back to summary
public void postSelect(final SelectorRunner selectorRunner) throws IOException Implements org.glassfish.grizzly.nio.SelectorHandler.postSelect. Annotations @Override

postSelect

back to summary

public void postSelect(final SelectorRunner selectorRunner) throws IOException

Implements org.glassfish.grizzly.nio.SelectorHandler.postSelect.

Annotations

@Override

preSelect	back to summary
public boolean preSelect(final SelectorRunner selectorRunner) throws IOException Implements org.glassfish.grizzly.nio.SelectorHandler.preSelect. Annotations @Override

preSelect

back to summary

public boolean preSelect(final SelectorRunner selectorRunner) throws IOException

Implements org.glassfish.grizzly.nio.SelectorHandler.preSelect.

Annotations

@Override

processPendingTaskQueue	back to summary
private boolean processPendingTaskQueue(final SelectorRunner selectorRunner, final Queue<SelectorHandlerTask> selectorHandlerTasks) throws IOException

processPendingTasks	back to summary
private boolean processPendingTasks(final SelectorRunner selectorRunner) throws IOException

registerChannel	back to summary
public void registerChannel(final SelectorRunner selectorRunner, final SelectableChannel channel, final int interest, final Object attachment) throws IOException Implements org.glassfish.grizzly.nio.SelectorHandler.registerChannel. Annotations @Override

registerChannel

back to summary

public void registerChannel(final SelectorRunner selectorRunner, final SelectableChannel channel, final int interest, final Object attachment) throws IOException

Implements org.glassfish.grizzly.nio.SelectorHandler.registerChannel.

Annotations

@Override

registerChannel0	back to summary
private static void registerChannel0(final SelectorRunner selectorRunner, final SelectableChannel channel, final int interest, final Object attachment, final CompletionHandler<RegisterChannelResult> completionHandler)

registerChannelAsync	back to summary
public void registerChannelAsync(SelectorRunner selectorRunner, SelectableChannel channel, int interest, Object attachment, CompletionHandler<RegisterChannelResult> completionHandler) Implements org.glassfish.grizzly.nio.SelectorHandler.registerChannelAsync. Annotations @Override

registerChannelAsync

back to summary

public void registerChannelAsync(SelectorRunner selectorRunner, SelectableChannel channel, int interest, Object attachment, CompletionHandler<RegisterChannelResult> completionHandler)

Implements org.glassfish.grizzly.nio.SelectorHandler.registerChannelAsync.

Annotations

@Override

registerKey0	back to summary
private static void registerKey0(final SelectionKey selectionKey, final int interest)

registerKeyInterest	back to summary
public void registerKeyInterest(final SelectorRunner selectorRunner, final SelectionKey key, final int interest) throws IOException Implements org.glassfish.grizzly.nio.SelectorHandler.registerKeyInterest. Annotations @Override

registerKeyInterest

back to summary

public void registerKeyInterest(final SelectorRunner selectorRunner, final SelectionKey key, final int interest) throws IOException

Implements org.glassfish.grizzly.nio.SelectorHandler.registerKeyInterest.

Annotations

@Override

select	back to summary
public Set<SelectionKey> select(final SelectorRunner selectorRunner) throws IOException Implements org.glassfish.grizzly.nio.SelectorHandler.select. Annotations @Override

select

back to summary

public Set<SelectionKey> select(final SelectorRunner selectorRunner) throws IOException

Implements org.glassfish.grizzly.nio.SelectorHandler.select.

Annotations

@Override

org.glassfish.grizzly.nio back to summary

protected final Class DefaultSelectorHandler.DeregisterChannelOperation

Class Inheritance

extends Object
implements SelectorHandlerTask

java.lang.Object
org.glassfish.grizzly.nio.DefaultSelectorHandler.DeregisterChannelOperation

All Implemented Interfaces

org.glassfish.grizzly.nio.SelectorHandlerTask

Field Summary

Modifier and Type	Field and Description
private final SelectableChannel	channel
private final CompletionHandler<RegisterChannelResult>	completionHandler

Constructor Summary

Access	Constructor and Description
private	DeregisterChannelOperation(final SelectableChannel channel, final CompletionHandler<RegisterChannelResult> completionHandler)

Method Summary

Modifier and Type	Method and Description
public void	cancel() Implements org.glassfish.grizzly.nio.SelectorHandlerTask.cancel.
public boolean	run(final SelectorRunner selectorRunner) Implements org.glassfish.grizzly.nio.SelectorHandlerTask.run.

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

Field Detail

channel	back to summary
private final SelectableChannel channel

completionHandler	back to summary
private final CompletionHandler<RegisterChannelResult> completionHandler

Constructor Detail

DeregisterChannelOperation	back to summary
private DeregisterChannelOperation(final SelectableChannel channel, final CompletionHandler<RegisterChannelResult> completionHandler)

Method Detail

cancel	back to summary
public void cancel() Implements org.glassfish.grizzly.nio.SelectorHandlerTask.cancel. Annotations @Override

cancel

back to summary

public void cancel()

Implements org.glassfish.grizzly.nio.SelectorHandlerTask.cancel.

Annotations

@Override

run	back to summary
public boolean run(final SelectorRunner selectorRunner) throws IOException Implements org.glassfish.grizzly.nio.SelectorHandlerTask.run. Annotations @Override

run

back to summary

public boolean run(final SelectorRunner selectorRunner) throws IOException

Implements org.glassfish.grizzly.nio.SelectorHandlerTask.run.

Annotations

@Override

org.glassfish.grizzly.nio back to summary

protected final Class DefaultSelectorHandler.RegisterChannelOperation

Class Inheritance

extends Object
implements SelectorHandlerTask

java.lang.Object
org.glassfish.grizzly.nio.DefaultSelectorHandler.RegisterChannelOperation

All Implemented Interfaces

org.glassfish.grizzly.nio.SelectorHandlerTask

Field Summary

Modifier and Type	Field and Description
private final Object	attachment
private final SelectableChannel	channel
private final CompletionHandler<RegisterChannelResult>	completionHandler
private final int	interest

Constructor Summary

Access	Constructor and Description
private	RegisterChannelOperation(final SelectableChannel channel, final int interest, final Object attachment, final CompletionHandler<RegisterChannelResult> completionHandler)

Method Summary

Modifier and Type	Method and Description
public void	cancel() Implements org.glassfish.grizzly.nio.SelectorHandlerTask.cancel.
public boolean	run(final SelectorRunner selectorRunner) Implements org.glassfish.grizzly.nio.SelectorHandlerTask.run.

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

Field Detail

attachment	back to summary
private final Object attachment

channel	back to summary
private final SelectableChannel channel

completionHandler	back to summary
private final CompletionHandler<RegisterChannelResult> completionHandler

interest	back to summary
private final int interest

Constructor Detail

RegisterChannelOperation	back to summary
private RegisterChannelOperation(final SelectableChannel channel, final int interest, final Object attachment, final CompletionHandler<RegisterChannelResult> completionHandler)

Method Detail

cancel	back to summary
public void cancel() Implements org.glassfish.grizzly.nio.SelectorHandlerTask.cancel. Annotations @Override

cancel

back to summary

public void cancel()

Implements org.glassfish.grizzly.nio.SelectorHandlerTask.cancel.

Annotations

@Override

run	back to summary
public boolean run(final SelectorRunner selectorRunner) throws IOException Implements org.glassfish.grizzly.nio.SelectorHandlerTask.run. Annotations @Override

run

back to summary

public boolean run(final SelectorRunner selectorRunner) throws IOException

Implements org.glassfish.grizzly.nio.SelectorHandlerTask.run.

Annotations

@Override

org.glassfish.grizzly.nio back to summary

protected final Class DefaultSelectorHandler.RegisterKeyTask

Class Inheritance

extends Object
implements SelectorHandlerTask

java.lang.Object
org.glassfish.grizzly.nio.DefaultSelectorHandler.RegisterKeyTask

All Implemented Interfaces

org.glassfish.grizzly.nio.SelectorHandlerTask

Field Summary

Modifier and Type	Field and Description
private final int	interest
private final SelectionKey	selectionKey

Constructor Summary

Access	Constructor and Description
public	RegisterKeyTask(final SelectionKey selectionKey, final int interest)

Method Summary

Modifier and Type	Method and Description
public void	cancel() Implements org.glassfish.grizzly.nio.SelectorHandlerTask.cancel.
public boolean	run(final SelectorRunner selectorRunner) Implements org.glassfish.grizzly.nio.SelectorHandlerTask.run.

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

Field Detail

interest	back to summary
private final int interest

selectionKey	back to summary
private final SelectionKey selectionKey

Constructor Detail

RegisterKeyTask	back to summary
public RegisterKeyTask(final SelectionKey selectionKey, final int interest)

Method Detail

cancel

back to summary

public void cancel()

Implements org.glassfish.grizzly.nio.SelectorHandlerTask.cancel.

Annotations

@Override

run

back to summary

public boolean run(final SelectorRunner selectorRunner) throws IOException

Implements org.glassfish.grizzly.nio.SelectorHandlerTask.run.

Annotations

@Override

org.glassfish.grizzly.nio back to summary

protected final Class DefaultSelectorHandler.RunnableTask

Class Inheritance

extends Object
implements SelectorHandlerTask

java.lang.Object
org.glassfish.grizzly.nio.DefaultSelectorHandler.RunnableTask

All Implemented Interfaces

org.glassfish.grizzly.nio.SelectorHandlerTask

Field Summary

Modifier and Type	Field and Description
private final CompletionHandler<SelectorHandler.Task>	completionHandler
private final SelectorHandler.Task	task

Constructor Summary

Access	Constructor and Description
private	RunnableTask(final SelectorHandler.Task task, final CompletionHandler<SelectorHandler.Task> completionHandler)

Method Summary

Modifier and Type	Method and Description
public void	cancel() Implements org.glassfish.grizzly.nio.SelectorHandlerTask.cancel.
public boolean	run(final SelectorRunner selectorRunner) Implements org.glassfish.grizzly.nio.SelectorHandlerTask.run.

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

Field Detail

completionHandler	back to summary
private final CompletionHandler<SelectorHandler.Task> completionHandler

task	back to summary
private final SelectorHandler.Task task

Constructor Detail

RunnableTask	back to summary
private RunnableTask(final SelectorHandler.Task task, final CompletionHandler<SelectorHandler.Task> completionHandler)

Method Detail

cancel

back to summary

public void cancel()

Implements org.glassfish.grizzly.nio.SelectorHandlerTask.cancel.

Annotations

@Override

run

back to summary

public boolean run(final SelectorRunner selectorRunner) throws IOException

Implements org.glassfish.grizzly.nio.SelectorHandlerTask.run.

Annotations

@Override

public Class DefaultSelectorHandler

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

protected final Class DefaultSelectorHandler.DeregisterChannelOperation

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

protected final Class DefaultSelectorHandler.RegisterChannelOperation

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

protected final Class DefaultSelectorHandler.RegisterKeyTask

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

protected final Class DefaultSelectorHandler.RunnableTask

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail