org.jboss.netty.channel

Class AbstractChannel

java.lang.Object

org.jboss.netty.channel.AbstractChannel

All Implemented Interfaces:

java.lang.Comparable<Channel>, Channel

Direct Known Subclasses:

AbstractNioChannel, AbstractOioChannel, AbstractServerChannel, DefaultLocalChannel, EmbeddedChannel, HttpTunnelingClientSocketChannel

public abstract class AbstractChannel
extends java.lang.Object
implements Channel

A skeletal Channel implementation.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	AbstractChannel.ChannelCloseFuture

Field Summary

Fields

Modifier and Type	Field and Description
(package private) static java.util.concurrent.ConcurrentMap<java.lang.Integer,Channel>	allChannels
private java.lang.Object	attachment
private AbstractChannel.ChannelCloseFuture	closeFuture
private ChannelFactory	factory
private java.lang.Integer	id
private int	interestOps
private Channel	parent
private ChannelPipeline	pipeline
private static java.util.Random	random
private java.lang.String	strVal
private boolean	strValConnected Cache for the string representation of this channel
private ChannelFuture	succeededFuture
private int	unwritable
private static java.util.concurrent.atomic.AtomicIntegerFieldUpdater<AbstractChannel>	UNWRITABLE_UPDATER

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

OP_NONE, OP_READ, OP_READ_WRITE, OP_WRITE

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractChannel(Channel parent, ChannelFactory factory, ChannelPipeline pipeline, ChannelSink sink) Creates a new instance.
protected	AbstractChannel(java.lang.Integer id, Channel parent, ChannelFactory factory, ChannelPipeline pipeline, ChannelSink sink) (Internal use only) Creates a new temporary instance with the specified ID.

Method Summary

Modifier and Type	Method and Description
private static java.lang.Integer	allocateId(Channel channel)
ChannelFuture	bind(java.net.SocketAddress localAddress) Binds this channel to the specified local address asynchronously.
private void	clearUserDefinedWritability(int index)
ChannelFuture	close() Closes this channel asynchronously.
int	compareTo(Channel o) Compares the ID of the two channels.
ChannelFuture	connect(java.net.SocketAddress remoteAddress) Connects this channel to the specified remote address asynchronously.
ChannelFuture	disconnect() Disconnects this channel from the current remote address asynchronously.
boolean	equals(java.lang.Object o) Returns true if and only if the specified object is identical with this channel (i.e: this == o).
java.lang.Object	getAttachment() Retrieves an object which is attached to this Channel.
ChannelFuture	getCloseFuture() Returns the ChannelFuture which will be notified when this channel is closed.
ChannelFactory	getFactory() Returns the ChannelFactory which created this channel.
java.lang.Integer	getId() Returns the unique integer ID of this channel.
private java.lang.String	getIdString()
int	getInterestOps() Returns the current interestOps of this channel.
protected int	getInternalInterestOps()
Channel	getParent() Returns the parent of this channel.
ChannelPipeline	getPipeline() Returns the ChannelPipeline which handles ChannelEvents associated with this channel.
protected ChannelFuture	getSucceededFuture() Returns the cached SucceededChannelFuture instance.
protected ChannelFuture	getUnsupportedOperationFuture() Returns the FailedChannelFuture whose cause is an UnsupportedOperationException.
boolean	getUserDefinedWritability(int index) Returns true if and only if the user-defined writability flag at the specified index is set to true.
int	hashCode() Returns the ID of this channel.
boolean	isOpen() Returns true if and only if this channel is open.
boolean	isReadable() Returns true if and only if the I/O thread will read a message from this channel.
boolean	isWritable() Returns true if and only if the I/O thread will perform the requested write operation immediately.
void	setAttachment(java.lang.Object attachment) Attaches an object to this Channel to store a stateful information
protected boolean	setClosed() Marks this channel as closed.
ChannelFuture	setInterestOps(int interestOps) Changes the interestOps of this channel asynchronously.
protected void	setInternalInterestOps(int interestOps) Sets the interestOps property of this channel immediately.
ChannelFuture	setReadable(boolean readable) Suspends or resumes the read operation of the I/O thread asynchronously.
protected boolean	setUnwritable()
private void	setUserDefinedWritability(int index)
void	setUserDefinedWritability(int index, boolean writable) Sets a user-defined writability flag at the specified index.
protected boolean	setWritable()
java.lang.String	toString() Returns the String representation of this channel.
ChannelFuture	unbind() Unbinds this channel from the current local address asynchronously.
private static int	writabilityMask(int index)
ChannelFuture	write(java.lang.Object message) Sends a message to this channel asynchronously.
ChannelFuture	write(java.lang.Object message, java.net.SocketAddress remoteAddress) Sends a message to this channel asynchronously.

Methods inherited from class java.lang.Object

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

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

getConfig, getLocalAddress, getRemoteAddress, isBound, isConnected

Field Detail

allChannels

static final java.util.concurrent.ConcurrentMap<java.lang.Integer,Channel> allChannels

random

private static final java.util.Random random

id

private final java.lang.Integer id

parent

private final Channel parent

factory

private final ChannelFactory factory

pipeline

private final ChannelPipeline pipeline

succeededFuture

private final ChannelFuture succeededFuture

closeFuture

private final AbstractChannel.ChannelCloseFuture closeFuture

interestOps

private volatile int interestOps

strValConnected

private boolean strValConnected

Cache for the string representation of this channel

strVal

private java.lang.String strVal

attachment

private volatile java.lang.Object attachment

UNWRITABLE_UPDATER

private static final java.util.concurrent.atomic.AtomicIntegerFieldUpdater<AbstractChannel> UNWRITABLE_UPDATER

unwritable

private volatile int unwritable

Constructor Detail

AbstractChannel

protected AbstractChannel(Channel parent,
                          ChannelFactory factory,
                          ChannelPipeline pipeline,
                          ChannelSink sink)

Creates a new instance.

Parameters:

parent - the parent of this channel. null if there's no parent.

factory - the factory which created this channel

pipeline - the pipeline which is going to be attached to this channel

sink - the sink which will receive downstream events from the pipeline and send upstream events to the pipeline

AbstractChannel

protected AbstractChannel(java.lang.Integer id,
                          Channel parent,
                          ChannelFactory factory,
                          ChannelPipeline pipeline,
                          ChannelSink sink)

(Internal use only) Creates a new temporary instance with the specified ID.

Parameters:

parent - the parent of this channel. null if there's no parent.

factory - the factory which created this channel

pipeline - the pipeline which is going to be attached to this channel

sink - the sink which will receive downstream events from the pipeline and send upstream events to the pipeline

Method Detail

allocateId

private static java.lang.Integer allocateId(Channel channel)

getId

public final java.lang.Integer getId()

Description copied from interface: Channel

Returns the unique integer ID of this channel.

Specified by:

getId in interface Channel

getParent

public Channel getParent()

Description copied from interface: Channel

Returns the parent of this channel.

Specified by:

getParent in interface Channel

Returns:

the parent channel. null if this channel does not have a parent channel.

getFactory

public ChannelFactory getFactory()

Description copied from interface: Channel

Returns the ChannelFactory which created this channel.

Specified by:

getFactory in interface Channel

getPipeline

public ChannelPipeline getPipeline()

Description copied from interface: Channel

Returns the ChannelPipeline which handles ChannelEvents associated with this channel.

Specified by:

getPipeline in interface Channel

getSucceededFuture

protected ChannelFuture getSucceededFuture()

Returns the cached SucceededChannelFuture instance.

getUnsupportedOperationFuture

protected ChannelFuture getUnsupportedOperationFuture()

Returns the FailedChannelFuture whose cause is an UnsupportedOperationException.

hashCode

public final int hashCode()

Returns the ID of this channel.

Overrides:

hashCode in class java.lang.Object

equals

public final boolean equals(java.lang.Object o)

Returns true if and only if the specified object is identical with this channel (i.e: this == o).

Overrides:

equals in class java.lang.Object

compareTo

public final int compareTo(Channel o)

Compares the ID of the two channels.

Specified by:

compareTo in interface java.lang.Comparable<Channel>

isOpen

public boolean isOpen()

Description copied from interface: Channel

Returns true if and only if this channel is open.

Specified by:

isOpen in interface Channel

setClosed

protected boolean setClosed()

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.

Returns:

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

bind

public ChannelFuture bind(java.net.SocketAddress localAddress)

Description copied from interface: Channel

Binds this channel to the specified local address asynchronously.

Specified by:

bind in interface Channel

Parameters:

localAddress - where to bind

Returns:

the ChannelFuture which will be notified when the bind request succeeds or fails

unbind

public ChannelFuture unbind()

Description copied from interface: Channel

Unbinds this channel from the current local address asynchronously.

Specified by:

unbind in interface Channel

Returns:

the ChannelFuture which will be notified when the unbind request succeeds or fails

close

public ChannelFuture close()

Description copied from interface: Channel

Closes this channel asynchronously. If this channel is bound or connected, it will be disconnected and unbound first. Once a channel is closed, it can not be open again. Calling this method on a closed channel has no effect. Please note that this method always returns the same future instance.

Specified by:

close in interface Channel

Returns:

the ChannelFuture which will be notified when the close request succeeds or fails

getCloseFuture

public ChannelFuture getCloseFuture()

Description copied from interface: Channel

Returns the ChannelFuture which will be notified when this channel is closed. This method always returns the same future instance.

Specified by:

getCloseFuture in interface Channel

connect

public ChannelFuture connect(java.net.SocketAddress remoteAddress)

Description copied from interface: Channel

Connects this channel to the specified remote address asynchronously.

Specified by:

connect in interface Channel

Parameters:

remoteAddress - where to connect

Returns:

the ChannelFuture which will be notified when the connection request succeeds or fails

disconnect

public ChannelFuture disconnect()

Description copied from interface: Channel

Disconnects this channel from the current remote address asynchronously.

Specified by:

disconnect in interface Channel

Returns:

the ChannelFuture which will be notified when the disconnection request succeeds or fails

getInterestOps

public int getInterestOps()

Description copied from interface: Channel

Returns the current interestOps of this channel.

Specified by:

getInterestOps in interface Channel

Returns:

Channel.OP_NONE, Channel.OP_READ, Channel.OP_WRITE, or Channel.OP_READ_WRITE

setInterestOps

public ChannelFuture setInterestOps(int interestOps)

Description copied from interface: Channel

Changes the interestOps of this channel asynchronously.

Specified by:

setInterestOps in interface Channel

Parameters:

interestOps - the new interestOps

Returns:

the ChannelFuture which will be notified when the interestOps change request succeeds or fails

getInternalInterestOps

protected int getInternalInterestOps()

setInternalInterestOps

protected void setInternalInterestOps(int interestOps)

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.

isReadable

public boolean isReadable()

Description copied from interface: Channel

Returns true if and only if the I/O thread will read a message from this channel. This method is a shortcut to the following code:

 return (getInterestOps() & OP_READ) != 0;
 

Specified by:

isReadable in interface Channel

isWritable

public boolean isWritable()

Description copied from interface: Channel

Returns true if and only if the I/O thread will perform the requested write operation immediately. Any write requests made when this method returns false are queued until the I/O thread is ready to process the queued write requests. This method is a shortcut to the following code:

 return (getInterestOps() & OP_WRITE) == 0;
 

Specified by:

isWritable in interface Channel

getUserDefinedWritability

public final boolean getUserDefinedWritability(int index)

Description copied from interface: Channel

Returns true if and only if the user-defined writability flag at the specified index is set to true.

Specified by:

getUserDefinedWritability in interface Channel

setUserDefinedWritability

public final void setUserDefinedWritability(int index,
                                            boolean writable)

Description copied from interface: Channel

Sets a user-defined writability flag at the specified index.

Specified by:

setUserDefinedWritability in interface Channel

setUserDefinedWritability

private void setUserDefinedWritability(int index)

clearUserDefinedWritability

private void clearUserDefinedWritability(int index)

writabilityMask

private static int writabilityMask(int index)

setWritable

protected boolean setWritable()

setUnwritable

protected boolean setUnwritable()

setReadable

public ChannelFuture setReadable(boolean readable)

Description copied from interface: Channel

Suspends or resumes the read operation of the I/O thread asynchronously. This method is a shortcut to the following code:

 int interestOps = getInterestOps();
 if (readable) {
     setInterestOps(interestOps | OP_READ);
 } else {
     setInterestOps(interestOps & ~OP_READ);
 }
 

Specified by:

setReadable in interface Channel

Parameters:

readable - true to resume the read operation and false to suspend the read operation

Returns:

the ChannelFuture which will be notified when the interestOps change request succeeds or fails

write

public ChannelFuture write(java.lang.Object message)

Description copied from interface: Channel

Sends a message to this channel asynchronously. If this channel was created by a connectionless transport (e.g. DatagramChannel) and is not connected yet, you have to call Channel.write(Object, SocketAddress) instead. Otherwise, the write request will fail with NotYetConnectedException and an 'exceptionCaught' event will be triggered.

Specified by:

write in interface Channel

Parameters:

message - the message to write

Returns:

the ChannelFuture which will be notified when the write request succeeds or fails

write

public ChannelFuture write(java.lang.Object message,
                           java.net.SocketAddress remoteAddress)

Description copied from interface: Channel

Sends a message to this channel asynchronously. It has an additional parameter that allows a user to specify where to send the specified message instead of this channel's current remote address. If this channel was created by a connectionless transport (e.g. DatagramChannel) and is not connected yet, you must specify non-null address. Otherwise, the write request will fail with NotYetConnectedException and an 'exceptionCaught' event will be triggered.

Specified by:

write in interface Channel

Parameters:

message - the message to write

remoteAddress - where to send the specified message. This method is identical to Channel.write(Object) if null is specified here.

Returns:

the ChannelFuture which will be notified when the write request succeeds or fails

getAttachment

public java.lang.Object getAttachment()

Description copied from interface: Channel

Retrieves an object which is attached to this Channel.

Specified by:

getAttachment in interface Channel

Returns:

null if no object was attached or null was attached

setAttachment

public void setAttachment(java.lang.Object attachment)

Description copied from interface: Channel

Attaches an object to this Channel to store a stateful information

Specified by:

setAttachment in interface Channel

toString

public java.lang.String toString()

Returns the String representation of this channel. The returned string contains the ID, local address, and remote address of this channel for easier identification.

Overrides:

toString in class java.lang.Object

getIdString

private java.lang.String getIdString()