Package io.netty.incubator.channel.uring
Class AbstractIOUringServerChannel.UringServerChannelUnsafe
java.lang.Object
io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe
io.netty.incubator.channel.uring.AbstractIOUringServerChannel.UringServerChannelUnsafe
- All Implemented Interfaces:
io.netty.channel.Channel.Unsafe
- Enclosing class:
AbstractIOUringServerChannel
final class AbstractIOUringServerChannel.UringServerChannelUnsafe
extends AbstractIOUringChannel.AbstractUringUnsafe
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
connect
(SocketAddress remoteAddress, SocketAddress localAddress, io.netty.channel.ChannelPromise promise) protected void
readComplete0
(int res, int data, int outstanding) Called once a read was completed.protected int
Schedule a read and returns the number ofAbstractIOUringChannel.AbstractUringUnsafe.readComplete(int, int)
calls that are expected because of the scheduled read.protected int
scheduleWriteMultiple
(io.netty.channel.ChannelOutboundBuffer in) Schedule the write of multiple messages in theChannelOutboundBuffer
and returns the number ofAbstractIOUringChannel.AbstractUringUnsafe.writeComplete(int, int)
calls that are expected because of the scheduled write.protected int
Schedule the write of a single message and returns the number ofAbstractIOUringChannel.AbstractUringUnsafe.writeComplete(int, int)
calls that are expected because of the scheduled write(package private) boolean
writeComplete0
(int res, int data, int outstanding) Called once a write was completed.Methods inherited from class io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe
close, connectComplete, flush0, newIOUringHandle, pollIn, pollOut, pollRdHup, processDelayedClose, readComplete, recvBufAllocHandle, schedulePollIn, scheduleRead, shutdownInput, writeComplete
-
Constructor Details
-
UringServerChannelUnsafe
UringServerChannelUnsafe()
-
-
Method Details
-
scheduleWriteMultiple
protected int scheduleWriteMultiple(io.netty.channel.ChannelOutboundBuffer in) Description copied from class:AbstractIOUringChannel.AbstractUringUnsafe
Schedule the write of multiple messages in theChannelOutboundBuffer
and returns the number ofAbstractIOUringChannel.AbstractUringUnsafe.writeComplete(int, int)
calls that are expected because of the scheduled write.- Specified by:
scheduleWriteMultiple
in classAbstractIOUringChannel.AbstractUringUnsafe
-
scheduleWriteSingle
Description copied from class:AbstractIOUringChannel.AbstractUringUnsafe
Schedule the write of a single message and returns the number ofAbstractIOUringChannel.AbstractUringUnsafe.writeComplete(int, int)
calls that are expected because of the scheduled write- Specified by:
scheduleWriteSingle
in classAbstractIOUringChannel.AbstractUringUnsafe
-
writeComplete0
boolean writeComplete0(int res, int data, int outstanding) Description copied from class:AbstractIOUringChannel.AbstractUringUnsafe
Called once a write was completed.- Specified by:
writeComplete0
in classAbstractIOUringChannel.AbstractUringUnsafe
-
scheduleRead0
protected int scheduleRead0()Description copied from class:AbstractIOUringChannel.AbstractUringUnsafe
Schedule a read and returns the number ofAbstractIOUringChannel.AbstractUringUnsafe.readComplete(int, int)
calls that are expected because of the scheduled read.- Specified by:
scheduleRead0
in classAbstractIOUringChannel.AbstractUringUnsafe
-
readComplete0
protected void readComplete0(int res, int data, int outstanding) Description copied from class:AbstractIOUringChannel.AbstractUringUnsafe
Called once a read was completed.- Specified by:
readComplete0
in classAbstractIOUringChannel.AbstractUringUnsafe
-
connect
public void connect(SocketAddress remoteAddress, SocketAddress localAddress, io.netty.channel.ChannelPromise promise) - Specified by:
connect
in interfaceio.netty.channel.Channel.Unsafe
- Overrides:
connect
in classAbstractIOUringChannel.AbstractUringUnsafe
-