public final class IoUringServerSocketChannel
extends io.netty.channel.AbstractChannel
implements io.netty.channel.socket.ServerSocketChannel
| Modifier and Type | Field and Description |
|---|---|
protected boolean |
active |
| Constructor and Description |
|---|
IoUringServerSocketChannel() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
cancelOutstandingReads(IoUringIoRegistration registration,
int numOutstandingReads)
Cancel all outstanding reads
|
protected void |
cancelOutstandingWrites(IoUringIoRegistration registration,
int numOutstandingWrites)
Cancel all outstanding writes
|
protected static void |
checkResolvable(InetSocketAddress addr) |
io.netty.channel.socket.ServerSocketChannelConfig |
config() |
protected void |
doBeginRead() |
void |
doBind(SocketAddress localAddress) |
protected void |
doClose() |
protected void |
doDeregister() |
protected void |
doDisconnect() |
protected void |
doRegister(io.netty.channel.ChannelPromise promise) |
protected void |
doWrite(io.netty.channel.ChannelOutboundBuffer in) |
io.netty.channel.unix.FileDescriptor |
fd() |
protected Object |
filterOutboundMessage(Object msg) |
boolean |
isActive() |
protected boolean |
isCompatible(io.netty.channel.EventLoop loop) |
boolean |
isOpen() |
InetSocketAddress |
localAddress() |
protected SocketAddress |
localAddress0() |
io.netty.channel.ChannelMetadata |
metadata() |
protected io.netty.buffer.ByteBuf |
newDirectBuffer(io.netty.buffer.ByteBuf buf) |
protected io.netty.buffer.ByteBuf |
newDirectBuffer(Object holder,
io.netty.buffer.ByteBuf buf) |
protected io.netty.channel.uring.AbstractIoUringChannel.AbstractUringUnsafe |
newUnsafe() |
protected short |
nextOpsId()
Returns the next id that should be used when submitting
IoUringIoOps. |
protected IoUringIoRegistration |
registration() |
InetSocketAddress |
remoteAddress() |
protected SocketAddress |
remoteAddress0() |
closeFuture, compareTo, doRegister, doShutdownOutput, equals, eventLoop, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, maxMessagesPerWrite, newChannelPipeline, newId, parent, pipeline, toString, unsafe, validateFileRegion, voidPromiseclone, finalize, getClass, notify, notifyAll, wait, wait, waitalloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, eventLoop, flush, getOption, id, isActive, isOpen, isRegistered, isWritable, metadata, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, setOption, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlushcompareTopublic io.netty.channel.socket.ServerSocketChannelConfig config()
config in interface io.netty.channel.Channelconfig in interface io.netty.channel.socket.ServerSocketChannelpublic InetSocketAddress remoteAddress()
remoteAddress in interface io.netty.channel.ChannelremoteAddress in interface io.netty.channel.socket.ServerSocketChannelremoteAddress in class io.netty.channel.AbstractChannelpublic InetSocketAddress localAddress()
localAddress in interface io.netty.channel.ChannellocalAddress in interface io.netty.channel.socket.ServerSocketChannellocalAddress in class io.netty.channel.AbstractChannelpublic void doBind(SocketAddress localAddress) throws Exception
Exceptionpublic final io.netty.channel.ChannelMetadata metadata()
metadata in interface io.netty.channel.Channelprotected final io.netty.channel.uring.AbstractIoUringChannel.AbstractUringUnsafe newUnsafe()
newUnsafe in class io.netty.channel.AbstractChannelprotected final void doWrite(io.netty.channel.ChannelOutboundBuffer in)
protected final void cancelOutstandingReads(IoUringIoRegistration registration, int numOutstandingReads)
registration - the IoUringIoRegistration.numOutstandingReads - the number of outstanding reads.protected final void cancelOutstandingWrites(IoUringIoRegistration registration, int numOutstandingWrites)
registration - the IoUringIoRegistration.numOutstandingWrites - the number of outstanding writes.protected final short nextOpsId()
IoUringIoOps.public final boolean isOpen()
isOpen in interface io.netty.channel.Channelpublic boolean isActive()
isActive in interface io.netty.channel.Channelpublic final io.netty.channel.unix.FileDescriptor fd()
fd in interface io.netty.channel.unix.UnixChannelprotected boolean isCompatible(io.netty.channel.EventLoop loop)
isCompatible in class io.netty.channel.AbstractChannelprotected final io.netty.buffer.ByteBuf newDirectBuffer(io.netty.buffer.ByteBuf buf)
protected final io.netty.buffer.ByteBuf newDirectBuffer(Object holder, io.netty.buffer.ByteBuf buf)
protected void doDisconnect()
throws Exception
doDisconnect in class io.netty.channel.AbstractChannelExceptionprotected final void doBeginRead()
doBeginRead in class io.netty.channel.AbstractChannelprotected final IoUringIoRegistration registration()
protected Object filterOutboundMessage(Object msg)
filterOutboundMessage in class io.netty.channel.AbstractChannelprotected void doRegister(io.netty.channel.ChannelPromise promise)
doRegister in class io.netty.channel.AbstractChannelprotected final void doDeregister()
doDeregister in class io.netty.channel.AbstractChannelprotected static void checkResolvable(InetSocketAddress addr)
protected final SocketAddress localAddress0()
localAddress0 in class io.netty.channel.AbstractChannelprotected final SocketAddress remoteAddress0()
remoteAddress0 in class io.netty.channel.AbstractChannelCopyright © 2008–2024 The Netty Project. All rights reserved.