class AbstractEpollStreamChannel.EpollStreamUnsafe extends AbstractEpollChannel.AbstractEpollUnsafe
maybeMoreDataToRead, 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 void |
handleReadException(ChannelPipeline pipeline,
ByteBuf byteBuf,
java.lang.Throwable cause,
boolean close,
EpollRecvByteAllocatorHandle allocHandle) |
(package private) EpollRecvByteAllocatorHandle |
newEpollHandle(RecvByteBufAllocator.ExtendedHandle handle)
Create a new
EpollRecvByteAllocatorHandle instance. |
protected java.util.concurrent.Executor |
prepareToClose()
Prepares to close the
Channel . |
clearEpollIn0, epollInBefore, epollInFinally, epollRdHupReady, executeEpollInReadyRunnable, flush0, recvBufAllocHandle, shutdownInput
annotateConnectException, beginRead, bind, close, closeForcibly, closeIfClosed, deregister, disconnect, ensureOpen, flush, localAddress, outboundBuffer, register, remoteAddress, safeSetFailure, safeSetSuccess, voidPromise, write
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 void handleReadException(ChannelPipeline pipeline, ByteBuf byteBuf, java.lang.Throwable cause, boolean close, EpollRecvByteAllocatorHandle allocHandle)
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
EpollRecvByteAllocatorHandle newEpollHandle(RecvByteBufAllocator.ExtendedHandle handle)
AbstractEpollChannel.AbstractEpollUnsafe
EpollRecvByteAllocatorHandle
instance.newEpollHandle
in class AbstractEpollChannel.AbstractEpollUnsafe
handle
- The handle to wrap with EPOLL specific logic.void epollInReady()
AbstractEpollChannel.AbstractEpollUnsafe
epollInReady
in class AbstractEpollChannel.AbstractEpollUnsafe