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
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected void
clearReadFilter0()
void
connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, ChannelPromise promise)
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 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) 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
-
-
-
-
Field Detail
-
readPending
boolean readPending
-
maybeMoreDataToRead
boolean maybeMoreDataToRead
-
allocHandle
private KQueueRecvByteAllocatorHandle allocHandle
-
readReadyRunnable
private final java.lang.Runnable readReadyRunnable
-
-
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 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
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 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
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
-
-