io.netty.channel.kqueue

Class AbstractKQueueStreamChannel.KQueueStreamUnsafe

java.lang.Object

io.netty.channel.AbstractChannel.AbstractUnsafe

io.netty.channel.kqueue.AbstractKQueueChannel.AbstractKQueueUnsafe

io.netty.channel.kqueue.AbstractKQueueStreamChannel.KQueueStreamUnsafe

All Implemented Interfaces:

Channel.Unsafe

Direct Known Subclasses:

KQueueDomainSocketChannel.KQueueDomainUnsafe, KQueueSocketChannel.KQueueSocketChannelUnsafe

Enclosing class:

AbstractKQueueStreamChannel

class AbstractKQueueStreamChannel.KQueueStreamUnsafe
extends AbstractKQueueChannel.AbstractKQueueUnsafe

Field Summary

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

maybeMoreDataToRead, readPending

Constructor Summary

Constructors

Constructor and Description
KQueueStreamUnsafe()

Method Summary

Modifier and Type	Method and Description
void	connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise) Connect the Channel of the given ChannelFuture with the given remote SocketAddress.
(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()

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

KQueueStreamUnsafe

KQueueStreamUnsafe()

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 AbstractChannel.AbstractUnsafe

readReady

void readReady(KQueueRecvByteAllocatorHandle allocHandle)

Specified by:

readReady in class AbstractKQueueChannel.AbstractKQueueUnsafe

writeReady

void writeReady()

Overrides:

writeReady in class AbstractKQueueChannel.AbstractKQueueUnsafe

connect

public void connect(java.net.SocketAddress remoteAddress,
                    java.net.SocketAddress localAddress,
                    ChannelPromise promise)

Description copied from interface: Channel.Unsafe

Connect the 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.

fulfillConnectPromise

private void fulfillConnectPromise(ChannelPromise promise,
                                   boolean wasActive)

fulfillConnectPromise

private void fulfillConnectPromise(ChannelPromise promise,
                                   java.lang.Throwable cause)

finishConnect

private void finishConnect()

doFinishConnect

boolean doFinishConnect()
                 throws java.lang.Exception

Throws:

java.lang.Exception

handleReadException

private void handleReadException(ChannelPipeline pipeline,
                                 ByteBuf byteBuf,
                                 java.lang.Throwable cause,
                                 boolean close,
                                 KQueueRecvByteAllocatorHandle allocHandle)