io.netty.channel.oio

Class AbstractOioChannel

java.lang.Object

io.netty.util.DefaultAttributeMap

io.netty.channel.AbstractChannel

io.netty.channel.oio.AbstractOioChannel

All Implemented Interfaces:

Channel, AttributeMap, java.lang.Comparable<Channel>

Direct Known Subclasses:

AbstractOioByteChannel, AbstractOioMessageChannel

public abstract class AbstractOioChannel
extends AbstractChannel

Abstract base class for Channel implementations that use Old-Blocking-IO

Nested Class Summary

Nested classes/interfaces inherited from class io.netty.channel.AbstractChannel

AbstractChannel.AbstractUnsafe

Nested classes/interfaces inherited from interface io.netty.channel.Channel

Channel.Unsafe

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	SO_TIMEOUT

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractOioChannel(Channel parent)

Method Summary

Modifier and Type	Method and Description
protected void	doBeginRead() Schedule a read operation.
protected abstract void	doConnect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress) Connect to the remote peer using the given localAddress if one is specified or null otherwise.
protected abstract void	doRead()
protected boolean	isCompatible(EventLoop loop) Return true if the given EventLoop is compatible with this instance.
protected boolean	isReadPending()
protected AbstractChannel.AbstractUnsafe	newUnsafe() Create a new AbstractChannel.AbstractUnsafe instance which will be used for the life-time of the Channel
protected void	setReadPending(boolean readPending)

Methods inherited from class io.netty.channel.AbstractChannel

alloc, bind, bind, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doBind, doClose, doDeregister, doDisconnect, doRegister, doShutdownOutput, doWrite, equals, eventLoop, filterOutboundMessage, flush, hashCode, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, localAddress, localAddress0, newChannelPipeline, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, remoteAddress, remoteAddress0, toString, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlush

Methods inherited from class io.netty.util.DefaultAttributeMap

attr

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.channel.Channel

config, isActive, isOpen, metadata

Methods inherited from interface io.netty.util.AttributeMap

attr

Field Detail

SO_TIMEOUT

protected static final int SO_TIMEOUT

See Also:

Constant Field Values

Constructor Detail

AbstractOioChannel

protected AbstractOioChannel(Channel parent)

See Also:

AbstractChannel.AbstractChannel(Channel)

Method Detail

newUnsafe

protected AbstractChannel.AbstractUnsafe newUnsafe()

Description copied from class: AbstractChannel

Create a new AbstractChannel.AbstractUnsafe instance which will be used for the life-time of the Channel

Specified by:

newUnsafe in class AbstractChannel

isCompatible

protected boolean isCompatible(EventLoop loop)

Description copied from class: AbstractChannel

Return true if the given EventLoop is compatible with this instance.

Specified by:

isCompatible in class AbstractChannel

doConnect

protected abstract void doConnect(java.net.SocketAddress remoteAddress,
                                  java.net.SocketAddress localAddress)
                           throws java.lang.Exception

Connect to the remote peer using the given localAddress if one is specified or null otherwise.

Throws:

java.lang.Exception

doBeginRead

protected void doBeginRead()
                    throws java.lang.Exception

Description copied from class: AbstractChannel

Schedule a read operation.

Specified by:

doBeginRead in class AbstractChannel

Throws:

java.lang.Exception

doRead

protected abstract void doRead()

isReadPending

protected boolean isReadPending()

setReadPending

protected void setReadPending(boolean readPending)