final class AbstractKQueueServerChannel.KQueueServerSocketUnsafe extends AbstractKQueueChannel.AbstractKQueueUnsafe
Modifier and Type | Field and Description |
---|---|
private byte[] |
acceptedAddress |
maybeMoreDataToRead, readPending
Constructor and Description |
---|
KQueueServerSocketUnsafe() |
Modifier and Type | Method and Description |
---|---|
void |
connect(java.net.SocketAddress socketAddress,
java.net.SocketAddress socketAddress2,
ChannelPromise channelPromise)
|
(package private) void |
readReady(KQueueRecvByteAllocatorHandle allocHandle) |
clearReadFilter0, executeReadReadyRunnable, readEOF, readReady, readReadyBefore, readReadyFinally, recvBufAllocHandle, shutdownInput, writeReady
annotateConnectException, beginRead, bind, close, closeForcibly, closeIfClosed, deregister, disconnect, ensureOpen, flush, flush0, localAddress, outboundBuffer, prepareToClose, register, remoteAddress, safeSetFailure, safeSetSuccess, voidPromise, write
public void connect(java.net.SocketAddress socketAddress, java.net.SocketAddress socketAddress2, ChannelPromise channelPromise)
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.void readReady(KQueueRecvByteAllocatorHandle allocHandle)
readReady
in class AbstractKQueueChannel.AbstractKQueueUnsafe