Package org.jboss.netty.channel.socket.oio

Class AbstractOioChannel

java.lang.Object

org.jboss.netty.channel.AbstractChannel

org.jboss.netty.channel.socket.oio.AbstractOioChannel

All Implemented Interfaces:

Comparable<Channel>, Channel

Direct Known Subclasses:

OioDatagramChannel, OioSocketChannel

abstract class AbstractOioChannel
extends AbstractChannel

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final Object	interestOpsLock
private InetSocketAddress	localAddress
(package private) InetSocketAddress	remoteAddress
(package private) Worker	worker
(package private) Thread	workerThread

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

OP_NONE, OP_READ, OP_READ_WRITE, OP_WRITE

Constructor Summary

Constructors

Constructor	Description
AbstractOioChannel(Channel parent, ChannelFactory factory, ChannelPipeline pipeline, ChannelSink sink)

Method Summary

Modifier and Type	Method	Description
(package private) abstract void	closeSocket()
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()
boolean	isBound()	Returns true if and only if this channel is bound to a local address.
boolean	isConnected()	Returns true if and only if this channel is connected to a remote address.
(package private) abstract boolean	isSocketBound()
(package private) abstract boolean	isSocketClosed()
(package private) abstract boolean	isSocketConnected()
protected boolean	setClosed()	Marks this channel as closed.
protected void	setInternalInterestOps(int interestOps)	Sets the interestOps property of this channel immediately.
ChannelFuture	write(Object message, SocketAddress remoteAddress)	Sends a message to this channel asynchronously.

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

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

Field Details

localAddress

private volatile InetSocketAddress localAddress

remoteAddress

volatile InetSocketAddress remoteAddress

workerThread

volatile Thread workerThread

worker

volatile Worker worker

interestOpsLock

final Object interestOpsLock

Constructor Details

AbstractOioChannel

AbstractOioChannel(Channel parent,
 ChannelFactory factory,
 ChannelPipeline pipeline,
 ChannelSink sink)

Method Details

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

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

write

public ChannelFuture write(Object message,
 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

Overrides:

write in class AbstractChannel

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

isBound

public boolean isBound()

Description copied from interface: Channel

Returns true if and only if this channel is bound to a local address.

isConnected

public boolean isConnected()

Description copied from interface: Channel

Returns true if and only if this channel is connected to a remote address.

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.

isSocketBound

abstract boolean isSocketBound()

isSocketConnected

abstract boolean isSocketConnected()

isSocketClosed

abstract boolean isSocketClosed()

getLocalSocketAddress

abstract InetSocketAddress getLocalSocketAddress()
                                          throws Exception

Throws:

Exception

getRemoteSocketAddress

abstract InetSocketAddress getRemoteSocketAddress()
                                           throws Exception

Throws:

Exception

closeSocket

abstract void closeSocket()
                   throws IOException

Throws:

IOException