Package io.netty.channel.epoll
Class AbstractEpollChannel
java.lang.Object
io.netty.util.DefaultAttributeMap
io.netty.channel.AbstractChannel
io.netty.channel.epoll.AbstractEpollChannel
- All Implemented Interfaces:
Channel
,ChannelOutboundInvoker
,UnixChannel
,AttributeMap
,Comparable<Channel>
- Direct Known Subclasses:
AbstractEpollServerChannel
,AbstractEpollStreamChannel
,EpollDatagramChannel
,EpollDomainDatagramChannel
-
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
protected int
(package private) boolean
private SocketAddress
private static final ChannelMetadata
private SocketAddress
private SocketAddress
protected final LinuxSocket
-
Constructor Summary
ConstructorsConstructorDescriptionAbstractEpollChannel
(Channel parent, LinuxSocket fd, boolean active) AbstractEpollChannel
(Channel parent, LinuxSocket fd, SocketAddress remote) -
Method Summary
Modifier and TypeMethodDescriptionprotected static void
(package private) final void
(package private) void
clearFlag
(int flag) abstract EpollChannelConfig
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 peer(package private) boolean
doConnect0
(SocketAddress remote) 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) (package private) final long
doWriteOrSendBytes
(ByteBuf data, InetSocketAddress remoteAddress, boolean fastOpen) Write bytes to the socket, with or without a remote address.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.(package private) boolean
isFlagSet
(int flag) boolean
isOpen()
Returnstrue
if theChannel
is open and may get active later(package private) static boolean
isSoErrorZero
(Socket fd) protected SocketAddress
Returns theSocketAddress
which is bound locally.metadata()
private void
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 AbstractEpollChannel.AbstractEpollUnsafe
Create a newAbstractChannel.AbstractUnsafe
instance which will be used for the life-time of theChannel
protected SocketAddress
Return theSocketAddress
which theChannel
is connected to.(package private) void
protected void
setFlag
(int flag) (package private) final boolean
shouldBreakEpollInReady
(ChannelConfig config) 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
-
socket
-
connectPromise
The future of the current connection attempt. If not null, subsequent connection attempts will fail. -
connectTimeoutFuture
-
requestedRemoteAddress
-
local
-
remote
-
flags
protected int flags -
inputClosedSeenErrorOnRead
boolean inputClosedSeenErrorOnRead -
epollInReadyRunnablePending
boolean epollInReadyRunnablePending -
active
protected volatile boolean active
-
-
Constructor Details
-
AbstractEpollChannel
AbstractEpollChannel(LinuxSocket fd) -
AbstractEpollChannel
AbstractEpollChannel(Channel parent, LinuxSocket fd, boolean active) -
AbstractEpollChannel
AbstractEpollChannel(Channel parent, LinuxSocket fd, SocketAddress remote)
-
-
Method Details
-
isSoErrorZero
-
setFlag
- Throws:
IOException
-
clearFlag
- Throws:
IOException
-
isFlagSet
boolean isFlagSet(int flag) -
fd
Description copied from interface:UnixChannel
Returns theFileDescriptor
that is used by thisChannel
.- Specified by:
fd
in interfaceUnixChannel
-
config
Description copied from interface:Channel
Returns the configuration of this channel. -
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
-
resetCachedAddresses
void resetCachedAddresses() -
doDisconnect
Description copied from class:AbstractChannel
Disconnect thisChannel
from its remote peer- Specified by:
doDisconnect
in classAbstractChannel
- Throws:
Exception
-
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
-
doBeginRead
Description copied from class:AbstractChannel
Schedule a read operation.- Specified by:
doBeginRead
in classAbstractChannel
- Throws:
Exception
-
shouldBreakEpollInReady
-
isAllowHalfClosure
-
clearEpollIn
final void clearEpollIn() -
modifyEvents
- Throws:
IOException
-
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
-
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
-
doWriteOrSendBytes
final long doWriteOrSendBytes(ByteBuf data, InetSocketAddress remoteAddress, boolean fastOpen) throws IOException Write bytes to the socket, with or without a remote address. Used for datagram and TCP client fast open writes.- Throws:
IOException
-
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
- 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
-