Package org.jboss.netty.channel.socket.nio

Class AbstractNioWorker

java.lang.Object

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

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

All Implemented Interfaces:

Runnable, NioSelector, Worker

Direct Known Subclasses:

NioDatagramWorker, NioWorker

abstract class AbstractNioWorker
extends AbstractNioSelector
implements Worker

Field Summary

Fields

Modifier and Type	Field	Description
protected final SocketSendBufferPool	sendBufferPool

Fields inherited from class org.jboss.netty.channel.socket.nio.AbstractNioSelector

logger, selector, startupLatch, thread, wakenUp

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected static void	cleanUpWriteBuffer(AbstractNioChannel<?> channel)
protected void	clearOpWrite(AbstractNioChannel<?> channel)
protected void	close(SelectionKey k)
protected void	close(AbstractNioChannel<?> channel, ChannelFuture future)
void	executeInIoThread(Runnable task)	Execute the given Runnable in the IO-Thread.
void	executeInIoThread(Runnable task, boolean alwaysAsync)	Execute the Runnable in a IO-Thread
(package private) static boolean	isIoThread(AbstractNioChannel<?> channel)
protected ThreadRenamingRunnable	newThreadRenamingRunnable(int id, ThreadNameDeterminer determiner)
protected void	process(Selector selector)
protected abstract 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 abstract boolean	scheduleWriteIfNecessary(AbstractNioChannel<?> channel)
(package private) void	setInterestOps(AbstractNioChannel<?> channel, ChannelFuture future, int interestOps)
protected void	setOpWrite(AbstractNioChannel<?> channel)
protected void	write0(AbstractNioChannel<?> channel)
(package private) void	writeFromSelectorLoop(SelectionKey k)
(package private) void	writeFromTaskLoop(AbstractNioChannel<?> ch)
(package private) void	writeFromUserCode(AbstractNioChannel<?> channel)

Methods inherited from class org.jboss.netty.channel.socket.nio.AbstractNioSelector

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

Methods inherited from class java.lang.Object

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

Field Details

sendBufferPool

protected final SocketSendBufferPool sendBufferPool

Constructor Details

AbstractNioWorker

AbstractNioWorker(Executor executor)

AbstractNioWorker

AbstractNioWorker(Executor executor,
 ThreadNameDeterminer determiner)

Method Details

executeInIoThread

public void executeInIoThread(Runnable task)

Description copied from interface: Worker

Execute the given Runnable in the IO-Thread. This may be now or later once the IO-Thread do some other work.

Specified by:

executeInIoThread in interface Worker

Parameters:

task - the Runnable to execute

executeInIoThread

public void executeInIoThread(Runnable task,
 boolean alwaysAsync)

Execute the Runnable in a IO-Thread

Parameters:

task - the Runnable to execute

alwaysAsync - true if the Runnable should be executed in an async fashion even if the current Thread == IO Thread

close

protected void close(SelectionKey k)

Specified by:

close in class AbstractNioSelector

newThreadRenamingRunnable

protected ThreadRenamingRunnable newThreadRenamingRunnable(int id,
 ThreadNameDeterminer determiner)

Specified by:

newThreadRenamingRunnable in class AbstractNioSelector

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class AbstractNioSelector

process

protected void process(Selector selector)
                throws IOException

Specified by:

process in class AbstractNioSelector

Throws:

IOException

writeFromUserCode

void writeFromUserCode(AbstractNioChannel<?> channel)

writeFromTaskLoop

void writeFromTaskLoop(AbstractNioChannel<?> ch)

writeFromSelectorLoop

void writeFromSelectorLoop(SelectionKey k)

scheduleWriteIfNecessary

protected abstract boolean scheduleWriteIfNecessary(AbstractNioChannel<?> channel)

write0

protected void write0(AbstractNioChannel<?> channel)

isIoThread

static boolean isIoThread(AbstractNioChannel<?> channel)

setOpWrite

protected void setOpWrite(AbstractNioChannel<?> channel)

clearOpWrite

protected void clearOpWrite(AbstractNioChannel<?> channel)

close

protected void close(AbstractNioChannel<?> channel,
 ChannelFuture future)

cleanUpWriteBuffer

protected static void cleanUpWriteBuffer(AbstractNioChannel<?> channel)

setInterestOps

void setInterestOps(AbstractNioChannel<?> channel,
 ChannelFuture future,
 int interestOps)

read

protected abstract boolean read(SelectionKey k)

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.

Parameters:

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