Package 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, KQueueDomainDatagramChannel.KQueueDomainDatagramChannelUnsafe

Enclosing class:

AbstractKQueueChannel

@UnstableApi
public abstract class AbstractKQueueChannel.AbstractKQueueUnsafe
extends AbstractChannel.AbstractUnsafe

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
AbstractKQueueUnsafe()

Method Summary

Modifier and Type	Method	Description
protected void	clearReadFilter0()
void	connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)	Connect the Channel of the given ChannelFuture with the given remote SocketAddress.
private boolean	doFinishConnect()
(package private) void	executeReadReadyRunnable(ChannelConfig config)
(package private) boolean	failConnectPromise(java.lang.Throwable cause)
private void	finishConnect()
private void	fireEventAndClose(java.lang.Object evt)
protected void	flush0()
private void	fulfillConnectPromise(ChannelPromise promise, boolean wasActive)
private void	fulfillConnectPromise(ChannelPromise promise, java.lang.Throwable cause)
(package private) void	readEOF()
(package private) void	readReady(long numberBytesPending)
(package private) abstract void	readReady(KQueueRecvByteAllocatorHandle allocHandle)
(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, handleWriteError, localAddress, outboundBuffer, prepareToClose, register, remoteAddress, safeSetFailure, safeSetSuccess, shutdownOutput, voidPromise, write

Methods inherited from class java.lang.Object

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

Field Detail

readPending

boolean readPending

maybeMoreDataToRead

boolean maybeMoreDataToRead

allocHandle

private KQueueRecvByteAllocatorHandle allocHandle

readReadyRunnable

private final java.lang.Runnable readReadyRunnable

Constructor Detail

AbstractKQueueUnsafe

public 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)

failConnectPromise

final boolean failConnectPromise(java.lang.Throwable cause)

writeReady

final 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

flush0

protected final void flush0()

Overrides:

flush0 in class AbstractChannel.AbstractUnsafe

executeReadReadyRunnable

final void executeReadReadyRunnable(ChannelConfig config)

clearReadFilter0

protected final void clearReadFilter0()

fireEventAndClose

private void fireEventAndClose(java.lang.Object evt)

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

private boolean doFinishConnect()
                         throws java.lang.Exception

Throws:

java.lang.Exception