Package io.netty.channel.nio
Class AbstractNioChannel.AbstractNioUnsafe
- java.lang.Object
-
- io.netty.channel.AbstractChannel.AbstractUnsafe
-
- io.netty.channel.nio.AbstractNioChannel.AbstractNioUnsafe
-
- All Implemented Interfaces:
Channel.Unsafe,AbstractNioChannel.NioUnsafe
- Direct Known Subclasses:
AbstractNioByteChannel.NioByteUnsafe,AbstractNioMessageChannel.NioMessageUnsafe
- Enclosing class:
- AbstractNioChannel
protected abstract class AbstractNioChannel.AbstractNioUnsafe extends AbstractChannel.AbstractUnsafe implements AbstractNioChannel.NioUnsafe
-
-
Constructor Summary
Constructors Modifier Constructor Description protectedAbstractNioUnsafe()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.nio.channels.SelectableChannelch()Return underlyingSelectableChannelvoidconnect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)voidfinishConnect()Finish connectprotected voidflush0()voidforceFlush()private voidfulfillConnectPromise(ChannelPromise promise, boolean wasActive)private voidfulfillConnectPromise(ChannelPromise promise, java.lang.Throwable cause)private booleanisFlushPending()protected voidremoveReadOp()-
Methods inherited from class io.netty.channel.AbstractChannel.AbstractUnsafe
annotateConnectException, beginRead, bind, close, closeForcibly, closeIfClosed, deregister, disconnect, ensureOpen, flush, localAddress, outboundBuffer, prepareToClose, recvBufAllocHandle, register, remoteAddress, safeSetFailure, safeSetSuccess, shutdownOutput, voidPromise, write
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface io.netty.channel.nio.AbstractNioChannel.NioUnsafe
read
-
Methods inherited from interface io.netty.channel.Channel.Unsafe
beginRead, bind, close, closeForcibly, deregister, disconnect, flush, localAddress, outboundBuffer, recvBufAllocHandle, register, remoteAddress, voidPromise, write
-
-
-
-
Method Detail
-
removeReadOp
protected final void removeReadOp()
-
ch
public final java.nio.channels.SelectableChannel ch()
Description copied from interface:AbstractNioChannel.NioUnsafeReturn underlyingSelectableChannel- Specified by:
chin interfaceAbstractNioChannel.NioUnsafe
-
connect
public final void connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)Description copied from interface:Channel.UnsafeConnect theChannelof the givenChannelFuturewith the given remoteSocketAddress. If a specific localSocketAddressshould be used it need to be given as argument. Otherwise just passnullto it. TheChannelPromisewill get notified once the connect operation was complete.- Specified by:
connectin interfaceChannel.Unsafe
-
fulfillConnectPromise
private void fulfillConnectPromise(ChannelPromise promise, boolean wasActive)
-
fulfillConnectPromise
private void fulfillConnectPromise(ChannelPromise promise, java.lang.Throwable cause)
-
finishConnect
public final void finishConnect()
Description copied from interface:AbstractNioChannel.NioUnsafeFinish connect- Specified by:
finishConnectin interfaceAbstractNioChannel.NioUnsafe
-
flush0
protected final void flush0()
- Overrides:
flush0in classAbstractChannel.AbstractUnsafe
-
forceFlush
public final void forceFlush()
- Specified by:
forceFlushin interfaceAbstractNioChannel.NioUnsafe
-
isFlushPending
private boolean isFlushPending()
-
-