Class AbstractKQueueChannel.AbstractKQueueUnsafe

java.lang.Object

io.netty.channel.AbstractChannel.AbstractUnsafe

io.netty.channel.kqueue.AbstractKQueueChannel.AbstractKQueueUnsafe

All Implemented Interfaces:

Channel.Unsafe, IoHandle, KQueueIoHandle, AutoCloseable

Direct Known Subclasses:

AbstractKQueueServerChannel.KQueueServerSocketUnsafe, AbstractKQueueStreamChannel.KQueueStreamUnsafe, KQueueDatagramChannel.KQueueDatagramChannelUnsafe, KQueueDomainDatagramChannel.KQueueDomainDatagramChannelUnsafe

Enclosing class:

AbstractKQueueChannel

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

Field Summary

Fields

Modifier and Type	Field	Description
private KQueueRecvByteAllocatorHandle	allocHandle
(package private) boolean	readPending

Constructor Summary

Constructors

Constructor	Description
AbstractKQueueUnsafe()

Method Summary

Modifier and Type	Method	Description
(package private) Channel	channel()
protected final void	clearReadFilter0()
void	close()	Called once the IoHandle should be closed.
void	connect(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise)	Connect the Channel of the given ChannelFuture with the given remote SocketAddress.
private boolean	doFinishConnect()
(package private) final boolean	failConnectPromise(Throwable cause)
private void	finishConnect()
private void	fireEventAndClose(Object evt)
protected final void	flush0()
private void	fulfillConnectPromise(ChannelPromise promise, boolean wasActive)
private void	fulfillConnectPromise(ChannelPromise promise, Throwable cause)
void	handle(IoRegistration registration, IoEvent event)	Be called once there is something to handle.
int	ident()	Return the ident of the IoHandle.
private void	readEOF()
(package private) abstract void	readReady(KQueueRecvByteAllocatorHandle allocHandle)
KQueueRecvByteAllocatorHandle	recvBufAllocHandle()	Return the assigned RecvByteBufAllocator.Handle which will be used to allocate ByteBuf's when receiving data.
(package private) final boolean	shouldStopReading(ChannelConfig config)
(package private) void	shutdownInput(boolean readEOF)	Shutdown the input side of the channel.
private void	writeReady()

Methods inherited from class AbstractChannel.AbstractUnsafe

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

Methods inherited from class Object

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

Methods inherited from interface IoHandle

registered, unregistered

Field Details

readPending

boolean readPending

allocHandle

private KQueueRecvByteAllocatorHandle allocHandle

Constructor Details

AbstractKQueueUnsafe

public AbstractKQueueUnsafe()

Method Details

channel

Channel channel()

ident

public int ident()

Description copied from interface: KQueueIoHandle

Return the ident of the IoHandle.

Specified by:

ident in interface KQueueIoHandle

Returns:

ident.

close

public void close()

Description copied from interface: IoHandle

Called once the IoHandle should be closed. Even once this method is called this handle might still receive events via IoHandle.handle(IoRegistration, IoEvent) (if it was previous be registered and so its IoHandle.registered() method was called) until the IoHandle.unregistered() method is called.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface IoHandle

handle

public void handle(IoRegistration registration,
 IoEvent event)

Description copied from interface: IoHandle

Be called once there is something to handle.

Specified by:

handle in interface IoHandle

Parameters:

registration - the IoRegistration for this IoHandle.

event - the IoEvent that must be handled. The IoEvent is only valid while this method is executed and so must not escape it.

readReady

abstract void readReady(KQueueRecvByteAllocatorHandle allocHandle)

shouldStopReading

final boolean shouldStopReading(ChannelConfig config)

failConnectPromise

final boolean failConnectPromise(Throwable cause)

writeReady

private void writeReady()

shutdownInput

void shutdownInput(boolean readEOF)

Shutdown the input side of the channel.

readEOF

private 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

clearReadFilter0

protected final void clearReadFilter0()

fireEventAndClose

private void fireEventAndClose(Object evt)

connect

public void connect(SocketAddress remoteAddress,
 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.

Specified by:

connect in interface Channel.Unsafe

fulfillConnectPromise

private void fulfillConnectPromise(ChannelPromise promise,
 boolean wasActive)

fulfillConnectPromise

private void fulfillConnectPromise(ChannelPromise promise,
 Throwable cause)

finishConnect

private void finishConnect()

doFinishConnect

private boolean doFinishConnect()
                         throws Exception

Throws:

Exception