public abstract class AbstractEpollStreamChannel
extends io.netty.channel.AbstractChannel
implements io.netty.channel.socket.DuplexChannel
Modifier and Type | Class and Description |
---|---|
protected class |
AbstractEpollStreamChannel.SpliceInTask |
Modifier and Type | Field and Description |
---|---|
protected boolean |
active |
protected int |
flags |
Modifier | Constructor and Description |
---|---|
protected |
AbstractEpollStreamChannel(io.netty.channel.Channel parent,
int fd) |
protected |
AbstractEpollStreamChannel(int fd) |
protected |
AbstractEpollStreamChannel(io.netty.channel.epoll.LinuxSocket fd,
boolean active) |
Modifier and Type | Method and Description |
---|---|
protected static void |
checkResolvable(InetSocketAddress addr) |
abstract EpollChannelConfig |
config() |
protected void |
doBeginRead() |
protected void |
doBind(SocketAddress local) |
protected void |
doClose() |
protected boolean |
doConnect(SocketAddress remoteAddress,
SocketAddress localAddress)
Connect to the remote peer
|
protected void |
doDeregister() |
protected void |
doDisconnect() |
protected int |
doReadBytes(io.netty.buffer.ByteBuf byteBuf)
Read bytes into the given
ByteBuf and return the amount. |
protected void |
doRegister() |
protected void |
doShutdownOutput() |
protected void |
doWrite(io.netty.channel.ChannelOutboundBuffer in) |
protected int |
doWriteBytes(io.netty.channel.ChannelOutboundBuffer in,
io.netty.buffer.ByteBuf buf) |
protected int |
doWriteSingle(io.netty.channel.ChannelOutboundBuffer in)
Attempt to write a single object.
|
io.netty.channel.unix.FileDescriptor |
fd() |
protected Object |
filterOutboundMessage(Object msg) |
boolean |
isActive() |
protected boolean |
isCompatible(io.netty.channel.EventLoop loop) |
boolean |
isInputShutdown() |
boolean |
isOpen() |
boolean |
isOutputShutdown() |
boolean |
isShutdown() |
protected SocketAddress |
localAddress0() |
io.netty.channel.ChannelMetadata |
metadata() |
protected io.netty.buffer.ByteBuf |
newDirectBuffer(io.netty.buffer.ByteBuf buf)
Returns an off-heap copy of the specified
ByteBuf , and releases the original one. |
protected io.netty.buffer.ByteBuf |
newDirectBuffer(Object holder,
io.netty.buffer.ByteBuf buf)
Returns an off-heap copy of the specified
ByteBuf , and releases the specified holder. |
protected io.netty.channel.epoll.AbstractEpollChannel.AbstractEpollUnsafe |
newUnsafe() |
protected SocketAddress |
remoteAddress0() |
io.netty.channel.ChannelFuture |
shutdown() |
io.netty.channel.ChannelFuture |
shutdown(io.netty.channel.ChannelPromise promise) |
io.netty.channel.ChannelFuture |
shutdownInput() |
io.netty.channel.ChannelFuture |
shutdownInput(io.netty.channel.ChannelPromise promise) |
io.netty.channel.ChannelFuture |
shutdownOutput() |
io.netty.channel.ChannelFuture |
shutdownOutput(io.netty.channel.ChannelPromise promise) |
io.netty.channel.ChannelFuture |
spliceTo(AbstractEpollStreamChannel ch,
int len)
Splice from this
AbstractEpollStreamChannel to another AbstractEpollStreamChannel . |
io.netty.channel.ChannelFuture |
spliceTo(AbstractEpollStreamChannel ch,
int len,
io.netty.channel.ChannelPromise promise)
Splice from this
AbstractEpollStreamChannel to another AbstractEpollStreamChannel . |
io.netty.channel.ChannelFuture |
spliceTo(io.netty.channel.unix.FileDescriptor ch,
int offset,
int len)
Splice from this
AbstractEpollStreamChannel to another FileDescriptor . |
io.netty.channel.ChannelFuture |
spliceTo(io.netty.channel.unix.FileDescriptor ch,
int offset,
int len,
io.netty.channel.ChannelPromise promise)
Splice from this
AbstractEpollStreamChannel to another FileDescriptor . |
alloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, equals, eventLoop, flush, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, localAddress, newChannelPipeline, newFailedFuture, newId, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, remoteAddress, toString, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlush
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
alloc, bytesBeforeUnwritable, bytesBeforeWritable, closeFuture, config, eventLoop, flush, id, isActive, isOpen, isRegistered, isWritable, localAddress, parent, pipeline, read, remoteAddress, unsafe
bind, bind, close, close, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, voidPromise, write, write, writeAndFlush, writeAndFlush
compareTo
protected AbstractEpollStreamChannel(io.netty.channel.Channel parent, int fd)
protected AbstractEpollStreamChannel(int fd)
protected AbstractEpollStreamChannel(io.netty.channel.epoll.LinuxSocket fd, boolean active)
protected io.netty.channel.epoll.AbstractEpollChannel.AbstractEpollUnsafe newUnsafe()
public io.netty.channel.ChannelMetadata metadata()
metadata
in interface io.netty.channel.Channel
public final io.netty.channel.ChannelFuture spliceTo(AbstractEpollStreamChannel ch, int len)
AbstractEpollStreamChannel
to another AbstractEpollStreamChannel
.
The len
is the number of bytes to splice. If using Integer.MAX_VALUE
it will
splice until the ChannelFuture
was canceled or it was failed.
Please note:
EventLoop
, otherwise an
IllegalArgumentException
is thrown. EpollChannelConfig.getEpollMode()
must be EpollMode.LEVEL_TRIGGERED
for this and the
target AbstractEpollStreamChannel
public final io.netty.channel.ChannelFuture spliceTo(AbstractEpollStreamChannel ch, int len, io.netty.channel.ChannelPromise promise)
AbstractEpollStreamChannel
to another AbstractEpollStreamChannel
.
The len
is the number of bytes to splice. If using Integer.MAX_VALUE
it will
splice until the ChannelFuture
was canceled or it was failed.
Please note:
EventLoop
, otherwise an
IllegalArgumentException
is thrown. EpollChannelConfig.getEpollMode()
must be EpollMode.LEVEL_TRIGGERED
for this and the
target AbstractEpollStreamChannel
public final io.netty.channel.ChannelFuture spliceTo(io.netty.channel.unix.FileDescriptor ch, int offset, int len)
AbstractEpollStreamChannel
to another FileDescriptor
.
The offset
is the offset for the FileDescriptor
and len
is the
number of bytes to splice. If using Integer.MAX_VALUE
it will splice until the
ChannelFuture
was canceled or it was failed.
Please note:
EpollChannelConfig.getEpollMode()
must be EpollMode.LEVEL_TRIGGERED
for this
AbstractEpollStreamChannel
FileDescriptor
will not be closed after the ChannelFuture
is notifiedIllegalStateException
will be thrown.public final io.netty.channel.ChannelFuture spliceTo(io.netty.channel.unix.FileDescriptor ch, int offset, int len, io.netty.channel.ChannelPromise promise)
AbstractEpollStreamChannel
to another FileDescriptor
.
The offset
is the offset for the FileDescriptor
and len
is the
number of bytes to splice. If using Integer.MAX_VALUE
it will splice until the
ChannelFuture
was canceled or it was failed.
Please note:
EpollChannelConfig.getEpollMode()
must be EpollMode.LEVEL_TRIGGERED
for this
AbstractEpollStreamChannel
FileDescriptor
will not be closed after the ChannelPromise
is notifiedIllegalStateException
will be thrown.protected void doWrite(io.netty.channel.ChannelOutboundBuffer in) throws Exception
doWrite
in class io.netty.channel.AbstractChannel
Exception
protected int doWriteSingle(io.netty.channel.ChannelOutboundBuffer in) throws Exception
in
- the collection which contains objects to write.ChannelConfig.getWriteSpinCount()
. The typical use cases are as follows:
ByteBuf
(or other empty content)
is encounteredChannelUtils.WRITE_STATUS_SNDBUF_FULL
- if an attempt to write data was made to the OS, but
no data was acceptedException
- If an I/O error occurs.protected Object filterOutboundMessage(Object msg)
filterOutboundMessage
in class io.netty.channel.AbstractChannel
@UnstableApi protected final void doShutdownOutput() throws Exception
doShutdownOutput
in class io.netty.channel.AbstractChannel
Exception
public boolean isOutputShutdown()
isOutputShutdown
in interface io.netty.channel.socket.DuplexChannel
public boolean isInputShutdown()
isInputShutdown
in interface io.netty.channel.socket.DuplexChannel
public boolean isShutdown()
isShutdown
in interface io.netty.channel.socket.DuplexChannel
public io.netty.channel.ChannelFuture shutdownOutput()
shutdownOutput
in interface io.netty.channel.socket.DuplexChannel
public io.netty.channel.ChannelFuture shutdownOutput(io.netty.channel.ChannelPromise promise)
shutdownOutput
in interface io.netty.channel.socket.DuplexChannel
public io.netty.channel.ChannelFuture shutdownInput()
shutdownInput
in interface io.netty.channel.socket.DuplexChannel
public io.netty.channel.ChannelFuture shutdownInput(io.netty.channel.ChannelPromise promise)
shutdownInput
in interface io.netty.channel.socket.DuplexChannel
public io.netty.channel.ChannelFuture shutdown()
shutdown
in interface io.netty.channel.socket.DuplexChannel
public io.netty.channel.ChannelFuture shutdown(io.netty.channel.ChannelPromise promise)
shutdown
in interface io.netty.channel.socket.DuplexChannel
public final io.netty.channel.unix.FileDescriptor fd()
fd
in interface io.netty.channel.unix.UnixChannel
public abstract EpollChannelConfig config()
config
in interface io.netty.channel.Channel
public boolean isActive()
isActive
in interface io.netty.channel.Channel
protected void doDisconnect() throws Exception
doDisconnect
in class io.netty.channel.AbstractChannel
Exception
protected boolean isCompatible(io.netty.channel.EventLoop loop)
isCompatible
in class io.netty.channel.AbstractChannel
public boolean isOpen()
isOpen
in interface io.netty.channel.Channel
protected void doDeregister() throws Exception
doDeregister
in class io.netty.channel.AbstractChannel
Exception
protected final void doBeginRead() throws Exception
doBeginRead
in class io.netty.channel.AbstractChannel
Exception
protected void doRegister() throws Exception
doRegister
in class io.netty.channel.AbstractChannel
Exception
protected final io.netty.buffer.ByteBuf newDirectBuffer(io.netty.buffer.ByteBuf buf)
ByteBuf
, and releases the original one.protected final io.netty.buffer.ByteBuf newDirectBuffer(Object holder, io.netty.buffer.ByteBuf buf)
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.protected static void checkResolvable(InetSocketAddress addr)
protected final int doReadBytes(io.netty.buffer.ByteBuf byteBuf) throws Exception
ByteBuf
and return the amount.Exception
protected final int doWriteBytes(io.netty.channel.ChannelOutboundBuffer in, io.netty.buffer.ByteBuf buf) throws Exception
Exception
protected void doBind(SocketAddress local) throws Exception
doBind
in class io.netty.channel.AbstractChannel
Exception
protected boolean doConnect(SocketAddress remoteAddress, SocketAddress localAddress) throws Exception
Exception
protected SocketAddress localAddress0()
localAddress0
in class io.netty.channel.AbstractChannel
protected SocketAddress remoteAddress0()
remoteAddress0
in class io.netty.channel.AbstractChannel
Copyright © 2008–2019 The Netty Project. All rights reserved.