Class NioWorker

java.lang.Object

org.jboss.netty.channel.socket.nio.AbstractNioSelector

org.jboss.netty.channel.socket.nio.AbstractNioWorker

org.jboss.netty.channel.socket.nio.NioWorker

All Implemented Interfaces:

Runnable, NioSelector, Worker

public class NioWorker
extends AbstractNioWorker

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private final class	NioWorker.RegisterTask

Field Summary

Fields

Modifier and Type	Field	Description
private final SocketReceiveBufferAllocator	recvBufferPool

Fields inherited from class AbstractNioWorker

sendBufferPool

Fields inherited from class AbstractNioSelector

logger, selector, startupLatch, thread, wakenUp

Constructor Summary

Constructors

Constructor	Description
NioWorker(Executor executor)
NioWorker(Executor executor, ThreadNameDeterminer determiner)

Method Summary

Modifier and Type	Method	Description
protected Runnable	createRegisterTask(Channel channel, ChannelFuture future)
protected boolean	read(SelectionKey k)	Read is called when a Selector has been notified that the underlying channel was something to be read.
void	run()
protected boolean	scheduleWriteIfNecessary(AbstractNioChannel<?> channel)

Methods inherited from class AbstractNioWorker

cleanUpWriteBuffer, clearOpWrite, close, close, executeInIoThread, executeInIoThread, isIoThread, newThreadRenamingRunnable, process, setInterestOps, setOpWrite, write0, writeFromSelectorLoop, writeFromTaskLoop, writeFromUserCode

Methods inherited from class AbstractNioSelector

cleanUpCancelledKeys, increaseCancelledKeys, isIoThread, rebuildSelector, register, registerTask, select, shutdown

Methods inherited from class Object

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

Field Details

recvBufferPool

private final SocketReceiveBufferAllocator recvBufferPool

Constructor Details

NioWorker

public NioWorker(Executor executor)

NioWorker

public NioWorker(Executor executor,
 ThreadNameDeterminer determiner)

Method Details

read

protected boolean read(SelectionKey k)

Description copied from class: AbstractNioWorker

Read is called when a Selector has been notified that the underlying channel was something to be read. The channel would previously have registered its interest in read operations.

Specified by:

read in class AbstractNioWorker

Parameters:

k - The selection key which contains the Selector registration information.

scheduleWriteIfNecessary

protected boolean scheduleWriteIfNecessary(AbstractNioChannel<?> channel)

Specified by:

scheduleWriteIfNecessary in class AbstractNioWorker

createRegisterTask

protected Runnable createRegisterTask(Channel channel,
 ChannelFuture future)

Specified by:

createRegisterTask in class AbstractNioSelector

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class AbstractNioWorker