Top Description Inners Fields Constructors Methods
io.netty.channel.oio

public abstract Class AbstractOioChannel

extends AbstractChannel
Class Inheritance
Known Direct Subclasses
io.netty.channel.oio.AbstractOioMessageChannel, io.netty.channel.oio.AbstractOioByteChannel
Annotations
@Deprecated
Imports
io.netty.channel.AbstractChannel, .Channel, .ChannelPromise, .EventLoop, .ThreadPerChannelEventLoop, java.net.SocketAddress

Deprecated

use NIO / EPOLL / KQUEUE transport.

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

Nested and Inner Type Summary

Modifier and TypeClass and Description
private class
AbstractOioChannel.DefaultOioUnsafe

Field Summary

Modifier and TypeField and Description
private final Runnable
clearReadPendingRunnable

pack-priv boolean
readPending

pack-priv final Runnable
readTask

pack-priv boolean
readWhenInactive

protected static final int
SO_TIMEOUT

Constructor Summary

AccessConstructor and Description
protected
AbstractOioChannel(Channel parent)

Method Summary

Modifier and TypeMethod and Description
protected final void
clearReadPending()

Set read pending to false.

protected void
doBeginRead()

Implements abstract io.netty.channel.AbstractChannel.doBeginRead.

Schedule a read operation.
protected abstract void
doConnect(SocketAddress remoteAddress, 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)

Implements abstract io.netty.channel.AbstractChannel.isCompatible.

Return true if the given EventLoop is compatible with this instance.
protected boolean
isReadPending()

Deprecated No longer supported. No longer supported.
protected AbstractChannel.AbstractUnsafe
newUnsafe()

Implements abstract io.netty.channel.AbstractChannel.newUnsafe.

Create a new AbstractUnsafe instance which will be used for the life-time of the Channel
protected void
setReadPending(final boolean readPending)

Deprecated Use clearReadPending() if appropriate instead. No longer supported.
Inherited from io.netty.channel.AbstractChannel:
allocbindbindbytesBeforeUnwritablebytesBeforeWritablecloseclosecloseFuturecompareToconnectconnectconnectconnectderegisterderegisterdisconnectdisconnectdoBinddoClosedoDeregisterdoDisconnectdoRegisterdoShutdownOutputdoWriteequalseventLoopfilterOutboundMessageflushhashCodeidinvalidateLocalAddressinvalidateRemoteAddressisRegisteredisWritablelocalAddresslocalAddress0maxMessagesPerWritenewChannelPipelinenewFailedFuturenewIdnewProgressivePromisenewPromisenewSucceededFutureparentpipelinereadremoteAddressremoteAddress0toStringunsafevalidateFileRegionvoidPromisewritewritewriteAndFlushwriteAndFlush

Field Detail

clearReadPendingRunnableback to summary
private final Runnable clearReadPendingRunnable
readPendingback to summary
pack-priv boolean readPending
readTaskback to summary
pack-priv final Runnable readTask
readWhenInactiveback to summary
pack-priv boolean readWhenInactive
SO_TIMEOUTback to summary
protected static final int SO_TIMEOUT

Constructor Detail

AbstractOioChannelback to summary
protected AbstractOioChannel(Channel parent)
See Also
AbstractChannel#AbstractChannel(Channel)

Method Detail

clearReadPendingback to summary
protected final void clearReadPending()

Set read pending to false.

doBeginReadback to summary
protected void doBeginRead() throws Exception

Implements abstract io.netty.channel.AbstractChannel.doBeginRead.

Doc from io.netty.channel.AbstractChannel.doBeginRead.

Schedule a read operation.

Annotations
@Override
doConnectback to summary
protected abstract void doConnect(SocketAddress remoteAddress, SocketAddress localAddress) throws Exception

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

doReadback to summary
protected abstract void doRead()
isCompatibleback to summary
protected boolean isCompatible(EventLoop loop)

Implements abstract io.netty.channel.AbstractChannel.isCompatible.

Doc from io.netty.channel.AbstractChannel.isCompatible.

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

Annotations
@Override
isReadPendingback to summary
protected boolean isReadPending()

Deprecated

No longer supported. No longer supported.

Annotations
@Deprecated
newUnsafeback to summary
protected AbstractChannel.AbstractUnsafe newUnsafe()

Implements abstract io.netty.channel.AbstractChannel.newUnsafe.

Doc from io.netty.channel.AbstractChannel.newUnsafe.

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

Annotations
@Override
setReadPendingback to summary
protected void setReadPending(final boolean readPending)

Deprecated

Use clearReadPending() if appropriate instead. No longer supported.

Annotations
@Deprecated
io.netty.channel.oio back to summary

private final Class AbstractOioChannel.DefaultOioUnsafe

extends AbstractUnsafe
Class Inheritance

Constructor Summary

AccessConstructor and Description
private
DefaultOioUnsafe()

Method Summary

Modifier and TypeMethod and Description
public void
connect(final SocketAddress remoteAddress, final SocketAddress localAddress, final ChannelPromise promise)

Implements io.netty.channel.Channel.Unsafe.connect.

Connect the Channel of the given ChannelFuture with the given remote SocketAddress.
Inherited from io.netty.channel.AbstractChannel.AbstractUnsafe:
annotateConnectExceptionbeginReadbindclosecloseForciblycloseIfClosedderegisterdisconnectensureOpenflushflush0handleWriteErrorlocalAddressoutboundBufferprepareToCloserecvBufAllocHandleregisterremoteAddresssafeSetFailuresafeSetSuccessshutdownOutputvoidPromisewrite

Constructor Detail

DefaultOioUnsafeback to summary
private DefaultOioUnsafe()

Method Detail

connectback to summary
public void connect(final SocketAddress remoteAddress, final SocketAddress localAddress, final ChannelPromise promise)

Implements io.netty.channel.Channel.Unsafe.connect.

Doc from io.netty.channel.Channel.Unsafe.connect.

Connect the Channel of the given ChannelFuture with the given remote SocketAddress. If a specific local SocketAddress should be used it need to be given as argument. Otherwise just pass null to it. The ChannelPromise will get notified once the connect operation was complete.

Annotations
@Override