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

Class AbstractNioChannel<C extends SelectableChannel & WritableByteChannel>

java.lang.Object

org.jboss.netty.channel.AbstractChannel

org.jboss.netty.channel.socket.nio.AbstractNioChannel<C>

All Implemented Interfaces:

Comparable<Channel>, Channel

Direct Known Subclasses:

NioDatagramChannel, NioSocketChannel

abstract class AbstractNioChannel<C extends SelectableChannel & WritableByteChannel>
extends AbstractChannel

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) final class	AbstractNioChannel.WriteRequestQueue
private final class	AbstractNioChannel.WriteTask

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final C	channel
(package private) SocketSendBufferPool.SendBuffer	currentWriteBuffer
(package private) MessageEvent	currentWriteEvent	The current write MessageEvent
(package private) final AtomicInteger	highWaterMarkCounter	Keeps track of the highWaterMark.
(package private) boolean	inWriteNowLoop	Boolean that indicates that write operation is in progress.
private InetSocketAddress	localAddress
(package private) InetSocketAddress	remoteAddress
(package private) final AbstractNioWorker	worker	The AbstractNioWorker.
(package private) final AbstractNioChannel<C>.WriteRequestQueue	writeBufferQueue	Queue of write MessageEvents.
(package private) final AtomicInteger	writeBufferSize	Keeps track of the number of bytes that the AbstractNioChannel<C extends SelectableChannel & WritableByteChannel>.WriteRequestQueue currently contains.
(package private) final Object	writeLock	Monitor object for synchronizing access to the AbstractNioChannel<C extends SelectableChannel & WritableByteChannel>.WriteRequestQueue.
(package private) boolean	writeSuspended
(package private) final Runnable	writeTask	WriteTask that performs write operations.
(package private) final AtomicBoolean	writeTaskInTaskQueue	Indicates if there is a AbstractNioChannel<C extends SelectableChannel & WritableByteChannel>.WriteTask in the task queue.

Fields inherited from interface org.jboss.netty.channel.Channel

OP_NONE, OP_READ, OP_READ_WRITE, OP_WRITE

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractNioChannel(Integer id, Channel parent, ChannelFactory factory, ChannelPipeline pipeline, ChannelSink sink, AbstractNioWorker worker, C ch)
protected	AbstractNioChannel(Channel parent, ChannelFactory factory, ChannelPipeline pipeline, ChannelSink sink, AbstractNioWorker worker, C ch)

Method Summary

Modifier and Type	Method	Description
abstract NioChannelConfig	getConfig()	Returns the configuration of this channel.
protected int	getInternalInterestOps()
InetSocketAddress	getLocalAddress()	Returns the local address where this channel is bound to.
(package private) abstract InetSocketAddress	getLocalSocketAddress()
InetSocketAddress	getRemoteAddress()	Returns the remote address where this channel is connected to.
(package private) abstract InetSocketAddress	getRemoteSocketAddress()
AbstractNioWorker	getWorker()	Return the AbstractNioWorker that handle the IO of the AbstractNioChannel
protected boolean	setClosed()	Marks this channel as closed.
protected void	setInternalInterestOps(int interestOps)	Sets the interestOps property of this channel immediately.

Methods inherited from class org.jboss.netty.channel.AbstractChannel

bind, close, compareTo, connect, disconnect, equals, getAttachment, getCloseFuture, getFactory, getId, getInterestOps, getParent, getPipeline, getSucceededFuture, getUnsupportedOperationFuture, getUserDefinedWritability, hashCode, isOpen, isReadable, isWritable, setAttachment, setInterestOps, setReadable, setUnwritable, setUserDefinedWritability, setWritable, toString, unbind, write, write

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.jboss.netty.channel.Channel

isBound, isConnected

Field Details

worker

final AbstractNioWorker worker

The AbstractNioWorker.

writeLock

final Object writeLock

Monitor object for synchronizing access to the AbstractNioChannel<C extends SelectableChannel & WritableByteChannel>.WriteRequestQueue.

writeTask

final Runnable writeTask

WriteTask that performs write operations.

writeTaskInTaskQueue

final AtomicBoolean writeTaskInTaskQueue

Indicates if there is a AbstractNioChannel<C extends SelectableChannel & WritableByteChannel>.WriteTask in the task queue.

writeBufferQueue

final AbstractNioChannel<C extends SelectableChannel & WritableByteChannel>.WriteRequestQueue writeBufferQueue

Queue of write MessageEvents.

writeBufferSize

final AtomicInteger writeBufferSize

Keeps track of the number of bytes that the AbstractNioChannel<C extends SelectableChannel & WritableByteChannel>.WriteRequestQueue currently contains.

highWaterMarkCounter

final AtomicInteger highWaterMarkCounter

Keeps track of the highWaterMark.

currentWriteEvent

MessageEvent currentWriteEvent

The current write MessageEvent

currentWriteBuffer

SocketSendBufferPool.SendBuffer currentWriteBuffer

inWriteNowLoop

boolean inWriteNowLoop

Boolean that indicates that write operation is in progress.

writeSuspended

boolean writeSuspended

localAddress

private volatile InetSocketAddress localAddress

remoteAddress

volatile InetSocketAddress remoteAddress

channel

final C extends SelectableChannel & WritableByteChannel channel

Constructor Details

AbstractNioChannel

protected AbstractNioChannel(Integer id,
 Channel parent,
 ChannelFactory factory,
 ChannelPipeline pipeline,
 ChannelSink sink,
 AbstractNioWorker worker,
 C ch)

AbstractNioChannel

protected AbstractNioChannel(Channel parent,
 ChannelFactory factory,
 ChannelPipeline pipeline,
 ChannelSink sink,
 AbstractNioWorker worker,
 C ch)

Method Details

getWorker

public AbstractNioWorker getWorker()

Return the AbstractNioWorker that handle the IO of the AbstractNioChannel

Returns:

worker

getLocalAddress

public InetSocketAddress getLocalAddress()

Description copied from interface: Channel

Returns the local address where this channel is bound to. The returned SocketAddress is supposed to be down-cast into more concrete type such as InetSocketAddress to retrieve the detailed information.

Returns:

the local address of this channel. null if this channel is not bound.

getRemoteAddress

public InetSocketAddress getRemoteAddress()

Description copied from interface: Channel

Returns the remote address where this channel is connected to. The returned SocketAddress is supposed to be down-cast into more concrete type such as InetSocketAddress to retrieve the detailed information.

Returns:

the remote address of this channel. null if this channel is not connected. If this channel is not connected but it can receive messages from arbitrary remote addresses (e.g. DatagramChannel, use MessageEvent.getRemoteAddress() to determine the origination of the received message as this method will return null.

getConfig

public abstract NioChannelConfig getConfig()

Description copied from interface: Channel

Returns the configuration of this channel.

getInternalInterestOps

protected int getInternalInterestOps()

Overrides:

getInternalInterestOps in class AbstractChannel

setInternalInterestOps

protected void setInternalInterestOps(int interestOps)

Description copied from class: AbstractChannel

Sets the interestOps property of this channel immediately. This method is intended to be called by an internal component - please do not call it unless you know what you are doing.

Overrides:

setInternalInterestOps in class AbstractChannel

setClosed

protected boolean setClosed()

Description copied from class: AbstractChannel

Marks this channel as closed. This method is intended to be called by an internal component - please do not call it unless you know what you are doing.

Overrides:

setClosed in class AbstractChannel

Returns:

true if and only if this channel was not marked as closed yet

getLocalSocketAddress

abstract InetSocketAddress getLocalSocketAddress()
                                          throws Exception

Throws:

Exception

getRemoteSocketAddress

abstract InetSocketAddress getRemoteSocketAddress()
                                           throws Exception

Throws:

Exception