Modifier and Type	Class and Description
public abstract class	AbstractKQueueChannel.AbstractKQueueUnsafe

Modifier and Type	Field and Description
protected volatile boolean	active
private ChannelPromise	connectPromise The future of the current connection attempt.
private Future<?>	connectTimeoutFuture
pack-priv boolean	inputClosedSeenErrorOnRead
private volatile SocketAddress	local
private static final ChannelMetadata	METADATA
private boolean	readFilterEnabled
pack-priv boolean	readReadyRunnablePending
private volatile SocketAddress	remote
private SocketAddress	requestedRemoteAddress
pack-priv final BsdSocket	socket
private boolean	writeFilterEnabled

Access	Constructor and Description
pack-priv	AbstractKQueueChannel(Channel parent, BsdSocket fd, boolean active)
pack-priv	AbstractKQueueChannel(Channel parent, BsdSocket fd, SocketAddress remote)

Method Summary

Modifier and Type	Method and Description
protected static void	checkResolvable(InetSocketAddress addr)
private void	clearRdHup0()
pack-priv final void	clearReadFilter()
public abstract KQueueChannelConfig	config() Redeclares io.netty.channel.Channel.config. Returns the configuration of this channel.
protected final void	doBeginRead() Implements abstract io.netty.channel.AbstractChannel.doBeginRead. Schedule a read operation.
protected void	doBind(SocketAddress local) Implements abstract io.netty.channel.AbstractChannel.doBind. Bind the `Channel` to the `SocketAddress`
protected void	doClose() Implements abstract io.netty.channel.AbstractChannel.doClose. Close the `Channel`
protected boolean	doConnect(SocketAddress remoteAddress, SocketAddress localAddress) Connect to the remote peer
protected boolean	doConnect0(SocketAddress remoteAddress, SocketAddress localAddress)
protected void	doDeregister() Overrides io.netty.channel.AbstractChannel.doDeregister. Deregister the `Channel` from its `EventLoop`.
protected void	doDisconnect() Implements abstract io.netty.channel.AbstractChannel.doDisconnect. Disconnect this `Channel` from its remote peer
protected final int	doReadBytes(ByteBuf byteBuf) Read bytes into the given `ByteBuf` and return the amount.
protected void	doRegister() Overrides io.netty.channel.AbstractChannel.doRegister. Is called after the `Channel` is registered with its `EventLoop` as part of the register process.
protected final int	doWriteBytes(ChannelOutboundBuffer in, ByteBuf buf)
private void	evSet(short filter, short flags)
private void	evSet0(short filter, short flags)
private void	evSet0(short filter, short flags, int fflags)
public final FileDescriptor	fd() Implements io.netty.channel.unix.UnixChannel.fd. Returns the `FileDescriptor` that is used by this `Channel`.
public boolean	isActive() Implements io.netty.channel.Channel.isActive. Return `true` if the `Channel` is active and so connected.
private static boolean	isAllowHalfClosure(ChannelConfig config)
protected boolean	isCompatible(EventLoop loop) Implements abstract io.netty.channel.AbstractChannel.isCompatible. Return `true` if the given `EventLoop` is compatible with this instance.
public boolean	isOpen() Implements io.netty.channel.Channel.isOpen. Returns `true` if the `Channel` is open and may get active later
pack-priv static boolean	isSoErrorZero(BsdSocket fd)
protected SocketAddress	localAddress0() Implements abstract io.netty.channel.AbstractChannel.localAddress0. Returns the `SocketAddress` which is bound locally.
public ChannelMetadata	metadata() Implements io.netty.channel.Channel.metadata. Return the `ChannelMetadata` of the `Channel` which describe the nature of the `Channel`.
protected final ByteBuf	newDirectBuffer(ByteBuf buf) Returns an off-heap copy of the specified `ByteBuf`, and releases the original one.
protected final ByteBuf	newDirectBuffer(Object holder, ByteBuf buf) Returns an off-heap copy of the specified `ByteBuf`, and releases the specified holder.
private static ByteBuf	newDirectBuffer0(Object holder, ByteBuf buf, ByteBufAllocator alloc, int capacity)
protected abstract AbstractKQueueChannel.AbstractKQueueUnsafe	newUnsafe() Implements abstract io.netty.channel.AbstractChannel.newUnsafe. Create a new `AbstractUnsafe` instance which will be used for the life-time of the `Channel`
pack-priv void	readFilter(boolean readFilterEnabled)
protected SocketAddress	remoteAddress0() Implements abstract io.netty.channel.AbstractChannel.remoteAddress0. Return the `SocketAddress` which the `Channel` is connected to.
pack-priv void	resetCachedAddresses()
pack-priv final boolean	shouldBreakReadReady(ChannelConfig config)
pack-priv void	unregisterFilters()
pack-priv void	writeFilter(boolean writeFilterEnabled)

Field Detail

active	back to summary
protected volatile boolean active

connectPromise	back to summary
private ChannelPromise connectPromise The future of the current connection attempt. If not null, subsequent connection attempts will fail.

connectTimeoutFuture	back to summary
private Future<?> connectTimeoutFuture

inputClosedSeenErrorOnRead	back to summary
pack-priv boolean inputClosedSeenErrorOnRead

local	back to summary
private volatile SocketAddress local

METADATA	back to summary
private static final ChannelMetadata METADATA

readFilterEnabled	back to summary
private boolean readFilterEnabled

readReadyRunnablePending	back to summary
pack-priv boolean readReadyRunnablePending

remote	back to summary
private volatile SocketAddress remote

requestedRemoteAddress	back to summary
private SocketAddress requestedRemoteAddress

socket	back to summary
pack-priv final BsdSocket socket

writeFilterEnabled	back to summary
private boolean writeFilterEnabled

Constructor Detail

AbstractKQueueChannel	back to summary
pack-priv AbstractKQueueChannel(Channel parent, BsdSocket fd, boolean active)

AbstractKQueueChannel	back to summary
pack-priv AbstractKQueueChannel(Channel parent, BsdSocket fd, SocketAddress remote)

Method Detail

checkResolvable	back to summary
protected static void checkResolvable(InetSocketAddress addr)

clearRdHup0	back to summary
private void clearRdHup0()

clearReadFilter	back to summary
pack-priv final void clearReadFilter()

config	back to summary
public abstract KQueueChannelConfig config() Redeclares io.netty.channel.Channel.config. Doc from io.netty.channel.Channel.config. Returns the configuration of this channel. Annotations @Override

config

back to summary

public abstract KQueueChannelConfig config()

Redeclares io.netty.channel.Channel.config.

Doc from io.netty.channel.Channel.config.

Returns the configuration of this channel.

Annotations

@Override

doBeginRead	back to summary
protected final void doBeginRead() throws Exception Implements abstract io.netty.channel.AbstractChannel.doBeginRead. Doc from io.netty.channel.AbstractChannel.doBeginRead. Schedule a read operation. Annotations @Override

doBeginRead

back to summary

protected final void doBeginRead() throws Exception

Implements abstract io.netty.channel.AbstractChannel.doBeginRead.

Doc from io.netty.channel.AbstractChannel.doBeginRead.

Schedule a read operation.

Annotations

@Override

doBind back to summary

doBind	back to summary
protected void doBind(SocketAddress local) throws Exception Implements abstract io.netty.channel.AbstractChannel.doBind. Doc from io.netty.channel.AbstractChannel.doBind. Bind the `Channel` to the `SocketAddress` Annotations @Override

protected void doBind(SocketAddress local) throws Exception

Implements abstract io.netty.channel.AbstractChannel.doBind.

Doc from io.netty.channel.AbstractChannel.doBind.

Bind the Channel to the SocketAddress

Annotations

@Override

doClose back to summary

doClose	back to summary
protected void doClose() throws Exception Implements abstract io.netty.channel.AbstractChannel.doClose. Doc from io.netty.channel.AbstractChannel.doClose. Close the `Channel` Annotations @Override

protected void doClose() throws Exception

Implements abstract io.netty.channel.AbstractChannel.doClose.

Doc from io.netty.channel.AbstractChannel.doClose.

Close the Channel

Annotations

@Override

doConnect	back to summary
protected boolean doConnect(SocketAddress remoteAddress, SocketAddress localAddress) throws Exception Connect to the remote peer

doConnect0	back to summary
protected boolean doConnect0(SocketAddress remoteAddress, SocketAddress localAddress) throws Exception

doDeregister back to summary

doDeregister	back to summary
protected void doDeregister() throws Exception Overrides io.netty.channel.AbstractChannel.doDeregister. Doc from io.netty.channel.AbstractChannel.doDeregister. Deregister the `Channel` from its `EventLoop`. Sub-classes may override this method Annotations @Override

protected void doDeregister() throws Exception

Overrides io.netty.channel.AbstractChannel.doDeregister.

Doc from io.netty.channel.AbstractChannel.doDeregister.

Deregister the Channel from its EventLoop. Sub-classes may override this method

Annotations

@Override

doDisconnect back to summary

doDisconnect	back to summary
protected void doDisconnect() throws Exception Implements abstract io.netty.channel.AbstractChannel.doDisconnect. Doc from io.netty.channel.AbstractChannel.doDisconnect. Disconnect this `Channel` from its remote peer Annotations @Override

protected void doDisconnect() throws Exception

Implements abstract io.netty.channel.AbstractChannel.doDisconnect.

Doc from io.netty.channel.AbstractChannel.doDisconnect.

Disconnect this Channel from its remote peer

Annotations

@Override

doReadBytes	back to summary
protected final int doReadBytes(ByteBuf byteBuf) throws Exception Read bytes into the given `ByteBuf` and return the amount.

doRegister back to summary

doRegister	back to summary
protected void doRegister() throws Exception Overrides io.netty.channel.AbstractChannel.doRegister. Doc from io.netty.channel.AbstractChannel.doRegister. Is called after the `Channel` is registered with its `EventLoop` as part of the register process. Sub-classes may override this method Annotations @Override

protected void doRegister() throws Exception

Overrides io.netty.channel.AbstractChannel.doRegister.

Doc from io.netty.channel.AbstractChannel.doRegister.

Is called after the Channel is registered with its EventLoop as part of the register process. Sub-classes may override this method

Annotations

@Override

doWriteBytes	back to summary
protected final int doWriteBytes(ChannelOutboundBuffer in, ByteBuf buf) throws Exception

evSet	back to summary
private void evSet(short filter, short flags)

evSet0	back to summary
private void evSet0(short filter, short flags)

evSet0	back to summary
private void evSet0(short filter, short flags, int fflags)

fd back to summary

fd	back to summary
public final FileDescriptor fd() Implements io.netty.channel.unix.UnixChannel.fd. Doc from io.netty.channel.unix.UnixChannel.fd. Returns the `FileDescriptor` that is used by this `Channel`. Annotations @Override

public final FileDescriptor fd()

Implements io.netty.channel.unix.UnixChannel.fd.

Doc from io.netty.channel.unix.UnixChannel.fd.

Returns the FileDescriptor that is used by this Channel.

Annotations

@Override

isActive back to summary

isActive	back to summary
public boolean isActive() Implements io.netty.channel.Channel.isActive. Doc from io.netty.channel.Channel.isActive. Return `true` if the `Channel` is active and so connected. Annotations @Override

public boolean isActive()

Implements io.netty.channel.Channel.isActive.

Doc from io.netty.channel.Channel.isActive.

Return true if the Channel is active and so connected.

Annotations

@Override

isAllowHalfClosure	back to summary
private static boolean isAllowHalfClosure(ChannelConfig config)

isCompatible back to summary

isCompatible	back to summary
protected boolean isCompatible(EventLoop loop) Implements abstract io.netty.channel.AbstractChannel.isCompatible. Doc from io.netty.channel.AbstractChannel.isCompatible. Return `true` if the given `EventLoop` is compatible with this instance. Annotations @Override

protected boolean isCompatible(EventLoop loop)

Implements abstract io.netty.channel.AbstractChannel.isCompatible.

Doc from io.netty.channel.AbstractChannel.isCompatible.

Return true if the given EventLoop is compatible with this instance.

Annotations

@Override

isOpen back to summary

isOpen	back to summary
public boolean isOpen() Implements io.netty.channel.Channel.isOpen. Doc from io.netty.channel.Channel.isOpen. Returns `true` if the `Channel` is open and may get active later Annotations @Override

public boolean isOpen()

Implements io.netty.channel.Channel.isOpen.

Doc from io.netty.channel.Channel.isOpen.

Returns true if the Channel is open and may get active later

Annotations

@Override

isSoErrorZero	back to summary
pack-priv static boolean isSoErrorZero(BsdSocket fd)

localAddress0 back to summary

localAddress0	back to summary
protected SocketAddress localAddress0() Implements abstract io.netty.channel.AbstractChannel.localAddress0. Doc from io.netty.channel.AbstractChannel.localAddress0. Returns the `SocketAddress` which is bound locally. Annotations @Override

protected SocketAddress localAddress0()

Implements abstract io.netty.channel.AbstractChannel.localAddress0.

Doc from io.netty.channel.AbstractChannel.localAddress0.

Returns the SocketAddress which is bound locally.

Annotations

@Override

metadata back to summary

public ChannelMetadata metadata()

Implements io.netty.channel.Channel.metadata.

Doc from io.netty.channel.Channel.metadata.

Return the ChannelMetadata of the Channel which describe the nature of the Channel.

Annotations

@Override

newDirectBuffer	back to summary
protected final ByteBuf newDirectBuffer(ByteBuf buf) Returns an off-heap copy of the specified `ByteBuf`, and releases the original one.

newDirectBuffer	back to summary
protected final ByteBuf newDirectBuffer(Object holder, ByteBuf buf) Returns an off-heap copy of the specified `ByteBuf`, and releases the specified holder. The caller must ensure that the holder releases the original `ByteBuf` when the holder is released by this method.

newDirectBuffer0	back to summary
private static ByteBuf newDirectBuffer0(Object holder, ByteBuf buf, ByteBufAllocator alloc, int capacity)

newUnsafe back to summary

newUnsafe	back to summary
protected abstract AbstractKQueueChannel.AbstractKQueueUnsafe newUnsafe() Implements abstract io.netty.channel.AbstractChannel.newUnsafe. Doc from io.netty.channel.AbstractChannel.newUnsafe. Create a new `AbstractUnsafe` instance which will be used for the life-time of the `Channel` Annotations @Override

protected abstract AbstractKQueueChannel.AbstractKQueueUnsafe newUnsafe()

Implements abstract io.netty.channel.AbstractChannel.newUnsafe.

Doc from io.netty.channel.AbstractChannel.newUnsafe.

Create a new AbstractUnsafe instance which will be used for the life-time of the Channel

Annotations

@Override

readFilter	back to summary
pack-priv void readFilter(boolean readFilterEnabled) throws IOException

remoteAddress0 back to summary

remoteAddress0	back to summary
protected SocketAddress remoteAddress0() Implements abstract io.netty.channel.AbstractChannel.remoteAddress0. Doc from io.netty.channel.AbstractChannel.remoteAddress0. Return the `SocketAddress` which the `Channel` is connected to. Annotations @Override

protected SocketAddress remoteAddress0()

Implements abstract io.netty.channel.AbstractChannel.remoteAddress0.

Doc from io.netty.channel.AbstractChannel.remoteAddress0.

Return the SocketAddress which the Channel is connected to.

Annotations

@Override

resetCachedAddresses	back to summary
pack-priv void resetCachedAddresses()

shouldBreakReadReady	back to summary
pack-priv final boolean shouldBreakReadReady(ChannelConfig config)

unregisterFilters	back to summary
pack-priv void unregisterFilters() throws Exception

writeFilter	back to summary
pack-priv void writeFilter(boolean writeFilterEnabled) throws IOException

io.netty.channel.kqueue back to summary

public abstract Class AbstractKQueueChannel.AbstractKQueueUnsafe

Class Inheritance

extends AbstractUnsafe

java.lang.Object
io.netty.channel.AbstractChannel.AbstractUnsafe
io.netty.channel.kqueue.AbstractKQueueChannel.AbstractKQueueUnsafe

Known Direct Subclasses

io.netty.channel.kqueue.AbstractKQueueServerChannel.KQueueServerSocketUnsafe, io.netty.channel.kqueue.AbstractKQueueStreamChannel.KQueueStreamUnsafe, io.netty.channel.kqueue.KQueueDatagramChannel.KQueueDatagramChannelUnsafe, io.netty.channel.kqueue.KQueueDomainDatagramChannel.KQueueDomainDatagramChannelUnsafe

Annotations

@UnstableApi

Field Summary

Modifier and Type	Field and Description
private KQueueRecvByteAllocatorHandle	allocHandle Deprecated as a consequence of `KQueueRecvByteAllocatorHandle` being deprecated.
pack-priv boolean	maybeMoreDataToRead
pack-priv boolean	readPending
private final Runnable	readReadyRunnable

Constructor Summary

Access	Constructor and Description
public	AbstractKQueueUnsafe()

Method Summary

Modifier and Type	Method and Description
protected final void	clearReadFilter0()
public void	connect(final SocketAddress remoteAddress, final SocketAddress localAddress, final ChannelPromise promise) Implements io.netty.channel.Channel.Unsafe.connect. Connect the `Channel` of the given `ChannelFuture` with the given remote `SocketAddress`.
private boolean	doFinishConnect()
pack-priv final void	executeReadReadyRunnable(ChannelConfig config)
pack-priv final boolean	failConnectPromise(Throwable cause)
private void	finishConnect()
private void	fireEventAndClose(Object evt)
protected final void	flush0() Overrides io.netty.channel.AbstractChannel.AbstractUnsafe.flush0.
private void	fulfillConnectPromise(ChannelPromise promise, boolean wasActive)
private void	fulfillConnectPromise(ChannelPromise promise, Throwable cause)
pack-priv final void	readEOF()
pack-priv final void	readReady(long numberBytesPending)
pack-priv abstract void	readReady(KQueueRecvByteAllocatorHandle allocHandle) Deprecated as a consequence of `KQueueRecvByteAllocatorHandle` being deprecated.
pack-priv final void	readReadyBefore()
pack-priv final void	readReadyFinally(ChannelConfig config)
public KQueueRecvByteAllocatorHandle	recvBufAllocHandle() Overrides io.netty.channel.AbstractChannel.AbstractUnsafe.recvBufAllocHandle. Implements io.netty.channel.Channel.Unsafe.recvBufAllocHandle. Deprecated as a consequence of `KQueueRecvByteAllocatorHandle` being deprecated. Return the assigned `RecvByteBufAllocator.Handle` which will be used to allocate `ByteBuf`'s when receiving data.
pack-priv void	shutdownInput(boolean readEOF) Shutdown the input side of the channel.
pack-priv final void	writeReady()

Field Detail

allocHandle	back to summary
private KQueueRecvByteAllocatorHandle allocHandle Deprecated as a consequence of `KQueueRecvByteAllocatorHandle` being deprecated. See corresponding docs for further information.

maybeMoreDataToRead	back to summary
pack-priv boolean maybeMoreDataToRead

readPending	back to summary
pack-priv boolean readPending

readReadyRunnable	back to summary
private final Runnable readReadyRunnable

Constructor Detail

AbstractKQueueUnsafe	back to summary
public AbstractKQueueUnsafe()

Method Detail

clearReadFilter0	back to summary
protected final void clearReadFilter0()

connect back to summary

public void connect(final SocketAddress remoteAddress, final SocketAddress localAddress, final ChannelPromise promise)

Implements io.netty.channel.Channel.Unsafe.connect.

Doc from io.netty.channel.Channel.Unsafe.connect.

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.

Annotations

@Override

doFinishConnect	back to summary
private boolean doFinishConnect() throws Exception

executeReadReadyRunnable	back to summary
pack-priv final void executeReadReadyRunnable(ChannelConfig config)

failConnectPromise	back to summary
pack-priv final boolean failConnectPromise(Throwable cause)

finishConnect	back to summary
private void finishConnect()

fireEventAndClose	back to summary
private void fireEventAndClose(Object evt)

flush0

back to summary

protected final void flush0()

Overrides io.netty.channel.AbstractChannel.AbstractUnsafe.flush0.

Annotations

@Override

fulfillConnectPromise	back to summary
private void fulfillConnectPromise(ChannelPromise promise, boolean wasActive)

fulfillConnectPromise	back to summary
private void fulfillConnectPromise(ChannelPromise promise, Throwable cause)

readEOF	back to summary
pack-priv final void readEOF()

readReady	back to summary
pack-priv final void readReady(long numberBytesPending)

readReady	back to summary
pack-priv abstract void readReady(KQueueRecvByteAllocatorHandle allocHandle) Deprecated as a consequence of `KQueueRecvByteAllocatorHandle` being deprecated. See corresponding docs for further information.

readReadyBefore	back to summary
pack-priv final void readReadyBefore()

readReadyFinally	back to summary
pack-priv final void readReadyFinally(ChannelConfig config)

recvBufAllocHandle back to summary

public KQueueRecvByteAllocatorHandle recvBufAllocHandle()

Overrides io.netty.channel.AbstractChannel.AbstractUnsafe.recvBufAllocHandle.

Implements io.netty.channel.Channel.Unsafe.recvBufAllocHandle.

Doc from io.netty.channel.Channel.Unsafe.recvBufAllocHandle.

Deprecated

as a consequence of KQueueRecvByteAllocatorHandle being deprecated. See corresponding docs for further information.

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

Annotations

@Override

shutdownInput	back to summary
pack-priv void shutdownInput(boolean readEOF) Shutdown the input side of the channel.

writeReady	back to summary
pack-priv final void writeReady()

pack-priv abstract Class AbstractKQueueChannel

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public abstract Class AbstractKQueueChannel.AbstractKQueueUnsafe

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail