io.netty.channel.kqueue

Class AbstractKQueueChannel.AbstractKQueueUnsafe

java.lang.Object

io.netty.channel.AbstractChannel.AbstractUnsafe

io.netty.channel.kqueue.AbstractKQueueChannel.AbstractKQueueUnsafe

All Implemented Interfaces:

Channel.Unsafe

Direct Known Subclasses:

AbstractKQueueServerChannel.KQueueServerSocketUnsafe, AbstractKQueueStreamChannel.KQueueStreamUnsafe, KQueueDatagramChannel.KQueueDatagramChannelUnsafe

Enclosing class:

AbstractKQueueChannel

abstract class AbstractKQueueChannel.AbstractKQueueUnsafe
extends AbstractChannel.AbstractUnsafe

Field Summary

Fields

Modifier and Type	Field and Description
private KQueueRecvByteAllocatorHandle	allocHandle
(package private) boolean	maybeMoreDataToRead
(package private) boolean	readPending
private java.lang.Runnable	readReadyRunnable

Constructor Summary

Constructors

Constructor and Description
AbstractKQueueUnsafe()

Method Summary

Modifier and Type	Method and Description
protected void	clearReadFilter0()
(package private) void	executeReadReadyRunnable(ChannelConfig config)
private void	fireEventAndClose(java.lang.Object evt)
(package private) void	readEOF()
(package private) abstract void	readReady(KQueueRecvByteAllocatorHandle allocHandle)
(package private) void	readReady(long numberBytesPending)
(package private) void	readReadyBefore()
(package private) void	readReadyFinally(ChannelConfig config)
KQueueRecvByteAllocatorHandle	recvBufAllocHandle() Return the assigned RecvByteBufAllocator.Handle which will be used to allocate ByteBuf's when receiving data.
(package private) void	shutdownInput(boolean readEOF) Shutdown the input side of the channel.
(package private) void	writeReady()

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

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.channel.Channel.Unsafe

connect

Field Detail

readPending

boolean readPending

maybeMoreDataToRead

boolean maybeMoreDataToRead

allocHandle

private KQueueRecvByteAllocatorHandle allocHandle

readReadyRunnable

private final java.lang.Runnable readReadyRunnable

Constructor Detail

AbstractKQueueUnsafe

AbstractKQueueUnsafe()

Method Detail

readReady

final void readReady(long numberBytesPending)

readReady

abstract void readReady(KQueueRecvByteAllocatorHandle allocHandle)

readReadyBefore

final void readReadyBefore()

readReadyFinally

final void readReadyFinally(ChannelConfig config)

writeReady

void writeReady()

shutdownInput

void shutdownInput(boolean readEOF)

Shutdown the input side of the channel.

readEOF

final void readEOF()

recvBufAllocHandle

public KQueueRecvByteAllocatorHandle recvBufAllocHandle()

Description copied from interface: Channel.Unsafe

Return the assigned RecvByteBufAllocator.Handle which will be used to allocate ByteBuf's when receiving data.

Specified by:

recvBufAllocHandle in interface Channel.Unsafe

Overrides:

recvBufAllocHandle in class AbstractChannel.AbstractUnsafe

executeReadReadyRunnable

final void executeReadReadyRunnable(ChannelConfig config)

clearReadFilter0

protected final void clearReadFilter0()

fireEventAndClose

private void fireEventAndClose(java.lang.Object evt)