Package io.netty.channel.kqueue
Class AbstractKQueueChannel
java.lang.Object
io.netty.util.DefaultAttributeMap
io.netty.channel.AbstractChannel
io.netty.channel.kqueue.AbstractKQueueChannel
- All Implemented Interfaces:
Channel
,ChannelOutboundInvoker
,UnixChannel
,AttributeMap
,Comparable<Channel>
- Direct Known Subclasses:
AbstractKQueueDatagramChannel
,AbstractKQueueServerChannel
,AbstractKQueueStreamChannel
-
Nested Class Summary
Nested ClassesNested classes/interfaces inherited from class io.netty.channel.AbstractChannel
AbstractChannel.AbstractUnsafe
Nested classes/interfaces inherited from interface io.netty.channel.Channel
Channel.Unsafe
-
Field Summary
FieldsModifier and TypeFieldDescriptionprotected boolean
private ChannelPromise
The future of the current connection attempt.private Future
<?> (package private) boolean
private SocketAddress
private static final ChannelMetadata
private boolean
(package private) boolean
(package private) KQueueEventLoop.KQueueRegistration
private SocketAddress
private SocketAddress
(package private) final BsdSocket
private boolean
-
Constructor Summary
ConstructorsConstructorDescriptionAbstractKQueueChannel
(Channel parent, BsdSocket fd, boolean active) AbstractKQueueChannel
(Channel parent, BsdSocket fd, SocketAddress remote) -
Method Summary
Modifier and TypeMethodDescriptionprotected static void
private void
(package private) final void
abstract KQueueChannelConfig
config()
Returns the configuration of this channel.protected final void
Schedule a read operation.protected void
doBind
(SocketAddress local) Bind theChannel
to theSocketAddress
protected void
doClose()
Close theChannel
protected boolean
doConnect
(SocketAddress remoteAddress, SocketAddress localAddress) Connect to the remote peerprotected boolean
doConnect0
(SocketAddress remoteAddress, SocketAddress localAddress) protected void
protected void
Disconnect thisChannel
from its remote peerprotected final int
doReadBytes
(ByteBuf byteBuf) Read bytes into the givenByteBuf
and return the amount.protected void
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) final FileDescriptor
fd()
Returns theFileDescriptor
that is used by thisChannel
.boolean
isActive()
Returntrue
if theChannel
is active and so connected.private static boolean
isAllowHalfClosure
(ChannelConfig config) protected boolean
isCompatible
(EventLoop loop) Returntrue
if the givenEventLoop
is compatible with this instance.boolean
isOpen()
Returnstrue
if theChannel
is open and may get active later(package private) static boolean
protected SocketAddress
Returns theSocketAddress
which is bound locally.metadata()
protected final ByteBuf
newDirectBuffer
(ByteBuf buf) Returns an off-heap copy of the specifiedByteBuf
, and releases the original one.protected final ByteBuf
newDirectBuffer
(Object holder, ByteBuf buf) Returns an off-heap copy of the specifiedByteBuf
, and releases the specified holder.private static ByteBuf
newDirectBuffer0
(Object holder, ByteBuf buf, ByteBufAllocator alloc, int capacity) protected abstract AbstractKQueueChannel.AbstractKQueueUnsafe
Create a newAbstractChannel.AbstractUnsafe
instance which will be used for the life-time of theChannel
(package private) void
readFilter
(boolean readFilterEnabled) protected SocketAddress
Return theSocketAddress
which theChannel
is connected to.(package private) void
(package private) final boolean
shouldBreakReadReady
(ChannelConfig config) (package private) void
(package private) void
writeFilter
(boolean writeFilterEnabled) Methods inherited from class io.netty.channel.AbstractChannel
alloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doShutdownOutput, doWrite, equals, eventLoop, filterOutboundMessage, flush, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, localAddress, maxMessagesPerWrite, newChannelPipeline, newFailedFuture, newId, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, remoteAddress, toString, unsafe, validateFileRegion, voidPromise, write, write, writeAndFlush, writeAndFlush
Methods inherited from class io.netty.util.DefaultAttributeMap
attr, hasAttr
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
Methods inherited from interface io.netty.util.AttributeMap
attr, hasAttr
Methods inherited from interface io.netty.channel.Channel
alloc, bytesBeforeUnwritable, bytesBeforeWritable, closeFuture, eventLoop, flush, id, isRegistered, isWritable, localAddress, parent, pipeline, read, remoteAddress, unsafe
Methods inherited from interface io.netty.channel.ChannelOutboundInvoker
bind, bind, close, close, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, voidPromise, write, write, writeAndFlush, writeAndFlush
Methods inherited from interface java.lang.Comparable
compareTo
-
Field Details
-
METADATA
-
connectPromise
The future of the current connection attempt. If not null, subsequent connection attempts will fail. -
connectTimeoutFuture
-
requestedRemoteAddress
-
socket
-
readFilterEnabled
private boolean readFilterEnabled -
writeFilterEnabled
private boolean writeFilterEnabled -
registration
KQueueEventLoop.KQueueRegistration registration -
readReadyRunnablePending
boolean readReadyRunnablePending -
inputClosedSeenErrorOnRead
boolean inputClosedSeenErrorOnRead -
active
protected volatile boolean active -
local
-
remote
-
-
Constructor Details
-
AbstractKQueueChannel
-
AbstractKQueueChannel
AbstractKQueueChannel(Channel parent, BsdSocket fd, SocketAddress remote)
-
-
Method Details
-
isSoErrorZero
-
fd
Description copied from interface:UnixChannel
Returns theFileDescriptor
that is used by thisChannel
.- Specified by:
fd
in interfaceUnixChannel
-
isActive
public boolean isActive()Description copied from interface:Channel
Returntrue
if theChannel
is active and so connected. -
metadata
Description copied from interface:Channel
-
doClose
Description copied from class:AbstractChannel
Close theChannel
- Specified by:
doClose
in classAbstractChannel
- Throws:
Exception
-
doDisconnect
Description copied from class:AbstractChannel
Disconnect thisChannel
from its remote peer- Specified by:
doDisconnect
in classAbstractChannel
- Throws:
Exception
-
resetCachedAddresses
void resetCachedAddresses() -
isCompatible
Description copied from class:AbstractChannel
Returntrue
if the givenEventLoop
is compatible with this instance.- Specified by:
isCompatible
in classAbstractChannel
-
isOpen
public boolean isOpen()Description copied from interface:Channel
Returnstrue
if theChannel
is open and may get active later -
doDeregister
Description copied from class:AbstractChannel
- Overrides:
doDeregister
in classAbstractChannel
- Throws:
Exception
-
unregisterFilters
- Throws:
Exception
-
clearRdHup0
private void clearRdHup0() -
doBeginRead
Description copied from class:AbstractChannel
Schedule a read operation.- Specified by:
doBeginRead
in classAbstractChannel
- Throws:
Exception
-
doRegister
Description copied from class:AbstractChannel
Is called after theChannel
is registered with itsEventLoop
as part of the register process. Sub-classes may override this method- Overrides:
doRegister
in classAbstractChannel
- Throws:
Exception
-
newUnsafe
Description copied from class:AbstractChannel
Create a newAbstractChannel.AbstractUnsafe
instance which will be used for the life-time of theChannel
- Specified by:
newUnsafe
in classAbstractChannel
-
config
Description copied from interface:Channel
Returns the configuration of this channel. -
newDirectBuffer
Returns an off-heap copy of the specifiedByteBuf
, and releases the original one. -
newDirectBuffer
-
newDirectBuffer0
private static ByteBuf newDirectBuffer0(Object holder, ByteBuf buf, ByteBufAllocator alloc, int capacity) -
checkResolvable
-
doReadBytes
Read bytes into the givenByteBuf
and return the amount.- Throws:
Exception
-
doWriteBytes
- Throws:
Exception
-
shouldBreakReadReady
-
isAllowHalfClosure
-
clearReadFilter
final void clearReadFilter() -
readFilter
- Throws:
IOException
-
writeFilter
- Throws:
IOException
-
evSet
private void evSet(short filter, short flags) -
evSet0
private void evSet0(short filter, short flags) -
evSet0
private void evSet0(short filter, short flags, int fflags) -
doBind
Description copied from class:AbstractChannel
Bind theChannel
to theSocketAddress
- Specified by:
doBind
in classAbstractChannel
- Throws:
Exception
-
doConnect
protected boolean doConnect(SocketAddress remoteAddress, SocketAddress localAddress) throws Exception Connect to the remote peer- Throws:
Exception
-
doConnect0
protected boolean doConnect0(SocketAddress remoteAddress, SocketAddress localAddress) throws Exception - Throws:
Exception
-
localAddress0
Description copied from class:AbstractChannel
Returns theSocketAddress
which is bound locally.- Specified by:
localAddress0
in classAbstractChannel
-
remoteAddress0
Description copied from class:AbstractChannel
Return theSocketAddress
which theChannel
is connected to.- Specified by:
remoteAddress0
in classAbstractChannel
-