io.netty.channel.kqueue

Class KQueueSocketChannel.KQueueSocketChannelUnsafe

java.lang.Object

io.netty.channel.AbstractChannel.AbstractUnsafe

io.netty.channel.kqueue.AbstractKQueueChannel.AbstractKQueueUnsafe

io.netty.channel.kqueue.AbstractKQueueStreamChannel.KQueueStreamUnsafe

io.netty.channel.kqueue.KQueueSocketChannel.KQueueSocketChannelUnsafe

All Implemented Interfaces:

Channel.Unsafe

Enclosing class:

KQueueSocketChannel

private final class KQueueSocketChannel.KQueueSocketChannelUnsafe
extends AbstractKQueueStreamChannel.KQueueStreamUnsafe

Field Summary

Fields inherited from class io.netty.channel.kqueue.AbstractKQueueChannel.AbstractKQueueUnsafe

maybeMoreDataToRead, readPending

Constructor Summary

Constructors

Modifier	Constructor and Description
private	KQueueSocketChannelUnsafe()

Method Summary

Modifier and Type	Method and Description
(package private) boolean	doFinishConnect()
protected java.util.concurrent.Executor	prepareToClose() Prepares to close the Channel.

Methods inherited from class io.netty.channel.kqueue.AbstractKQueueStreamChannel.KQueueStreamUnsafe

connect, readReady, writeReady

Methods inherited from class io.netty.channel.kqueue.AbstractKQueueChannel.AbstractKQueueUnsafe

clearReadFilter0, executeReadReadyRunnable, readEOF, readReady, readReadyBefore, readReadyFinally, recvBufAllocHandle, shutdownInput

Methods inherited from class io.netty.channel.AbstractChannel.AbstractUnsafe

annotateConnectException, beginRead, bind, close, closeForcibly, closeIfClosed, deregister, disconnect, ensureOpen, flush, flush0, localAddress, outboundBuffer, register, remoteAddress, safeSetFailure, safeSetSuccess, voidPromise, write

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KQueueSocketChannelUnsafe

private KQueueSocketChannelUnsafe()

Method Detail

prepareToClose

protected java.util.concurrent.Executor prepareToClose()

Description copied from class: AbstractChannel.AbstractUnsafe

Prepares to close the 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)

Overrides:

prepareToClose in class AbstractKQueueStreamChannel.KQueueStreamUnsafe

doFinishConnect

boolean doFinishConnect()
                 throws java.lang.Exception

Overrides:

doFinishConnect in class AbstractKQueueStreamChannel.KQueueStreamUnsafe

Throws:

java.lang.Exception