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
FieldsModifier and TypeFieldDescriptionprivate KQueueRecvByteAllocatorHandle
(package private) boolean
(package private) boolean
private final Runnable
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected final void
void
connect
(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) private boolean
(package private) final void
(package private) final boolean
failConnectPromise
(Throwable cause) private void
private void
fireEventAndClose
(Object evt) protected final void
flush0()
private void
fulfillConnectPromise
(ChannelPromise promise, boolean wasActive) private void
fulfillConnectPromise
(ChannelPromise promise, Throwable cause) (package private) final void
readEOF()
(package private) final void
readReady
(long numberBytesPending) (package private) abstract void
readReady
(KQueueRecvByteAllocatorHandle allocHandle) (package private) final void
(package private) final void
readReadyFinally
(ChannelConfig config) Return the assignedRecvByteBufAllocator.Handle
which will be used to allocateByteBuf
's when receiving data.(package private) void
shutdownInput
(boolean readEOF) Shutdown the input side of the channel.(package private) final void
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
-
Field Details
-
readPending
boolean readPending -
maybeMoreDataToRead
boolean maybeMoreDataToRead -
allocHandle
-
readReadyRunnable
-
-
Constructor Details
-
AbstractKQueueUnsafe
public AbstractKQueueUnsafe()
-
-
Method Details
-
readReady
final void readReady(long numberBytesPending) -
readReady
-
readReadyBefore
final void readReadyBefore() -
readReadyFinally
-
failConnectPromise
-
writeReady
final void writeReady() -
shutdownInput
void shutdownInput(boolean readEOF) Shutdown the input side of the channel. -
readEOF
final void readEOF() -
recvBufAllocHandle
Description copied from interface:Channel.Unsafe
Return the assignedRecvByteBufAllocator.Handle
which will be used to allocateByteBuf
's when receiving data.- Specified by:
recvBufAllocHandle
in interfaceChannel.Unsafe
- Overrides:
recvBufAllocHandle
in classAbstractChannel.AbstractUnsafe
-
flush0
protected final void flush0()- Overrides:
flush0
in classAbstractChannel.AbstractUnsafe
-
executeReadReadyRunnable
-
clearReadFilter0
protected final void clearReadFilter0() -
fireEventAndClose
-
connect
public void connect(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) Description copied from interface:Channel.Unsafe
Connect theChannel
of the givenChannelFuture
with the given remoteSocketAddress
. If a specific localSocketAddress
should be used it need to be given as argument. Otherwise just passnull
to it. TheChannelPromise
will get notified once the connect operation was complete. -
fulfillConnectPromise
-
fulfillConnectPromise
-
finishConnect
private void finishConnect() -
doFinishConnect
- Throws:
Exception
-