class AbstractEpollStreamChannel.EpollStreamUnsafe extends AbstractEpollChannel.AbstractEpollUnsafe
Modifier and Type | Field and Description |
---|---|
private RecvByteBufAllocator.Handle |
allocHandle |
readPending
Constructor and Description |
---|
EpollStreamUnsafe() |
Modifier and Type | Method and Description |
---|---|
void |
connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise)
|
(package private) boolean |
doFinishConnect()
Finish the connect
|
(package private) void |
epollInReady()
Called once EPOLLIN event is ready to be processed
|
(package private) void |
epollOutReady()
Called once a EPOLLOUT event is ready to be processed
|
private void |
finishConnect() |
private void |
fulfillConnectPromise(ChannelPromise promise,
boolean wasActive) |
private void |
fulfillConnectPromise(ChannelPromise promise,
java.lang.Throwable cause) |
private boolean |
handleReadException(ChannelPipeline pipeline,
ByteBuf byteBuf,
java.lang.Throwable cause,
boolean close) |
protected java.util.concurrent.Executor |
prepareToClose()
Prepares to close the
Channel . |
clearEpollIn0, epollRdHupReady, flush0, isRdHup, shutdownInput
annotateConnectException, beginRead, bind, close, closeForcibly, closeIfClosed, deregister, disconnect, ensureOpen, flush, localAddress, outboundBuffer, register, remoteAddress, safeSetFailure, safeSetSuccess, voidPromise, write
private RecvByteBufAllocator.Handle allocHandle
protected java.util.concurrent.Executor prepareToClose()
AbstractChannel.AbstractUnsafe
Channel
. If this method returns an Executor
, the
caller must call the Executor.execute(Runnable)
method with a task that calls
AbstractChannel.doClose()
on the returned Executor
. If this method returns null
,
AbstractChannel.doClose()
must be called from the caller thread. (i.e. EventLoop
)prepareToClose
in class AbstractChannel.AbstractUnsafe
private boolean handleReadException(ChannelPipeline pipeline, ByteBuf byteBuf, java.lang.Throwable cause, boolean close)
public void connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
Channel.Unsafe
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.private void fulfillConnectPromise(ChannelPromise promise, boolean wasActive)
private void fulfillConnectPromise(ChannelPromise promise, java.lang.Throwable cause)
private void finishConnect()
void epollOutReady()
AbstractEpollChannel.AbstractEpollUnsafe
epollOutReady
in class AbstractEpollChannel.AbstractEpollUnsafe
boolean doFinishConnect() throws java.lang.Exception
java.lang.Exception
void epollInReady()
AbstractEpollChannel.AbstractEpollUnsafe
epollInReady
in class AbstractEpollChannel.AbstractEpollUnsafe