class AbstractKQueueStreamChannel.KQueueStreamUnsafe extends AbstractKQueueChannel.AbstractKQueueUnsafe
maybeMoreDataToRead, readPending
Constructor and Description |
---|
KQueueStreamUnsafe() |
Modifier and Type | Method and Description |
---|---|
void |
connect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress,
ChannelPromise promise)
|
(package private) boolean |
doFinishConnect() |
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,
KQueueRecvByteAllocatorHandle allocHandle) |
protected java.util.concurrent.Executor |
prepareToClose()
Prepares to close the
Channel . |
(package private) void |
readReady(KQueueRecvByteAllocatorHandle allocHandle) |
(package private) void |
writeReady() |
clearReadFilter0, executeReadReadyRunnable, readEOF, readReady, readReadyBefore, readReadyFinally, recvBufAllocHandle, shutdownInput
annotateConnectException, beginRead, bind, close, closeForcibly, closeIfClosed, deregister, disconnect, ensureOpen, flush, flush0, 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
void readReady(KQueueRecvByteAllocatorHandle allocHandle)
readReady
in class AbstractKQueueChannel.AbstractKQueueUnsafe
void writeReady()
writeReady
in class AbstractKQueueChannel.AbstractKQueueUnsafe
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()
boolean doFinishConnect() throws java.lang.Exception
java.lang.Exception
private void handleReadException(ChannelPipeline pipeline, ByteBuf byteBuf, java.lang.Throwable cause, boolean close, KQueueRecvByteAllocatorHandle allocHandle)