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 Constructor Description UringServerChannelUnsafe()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
connect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, io.netty.channel.ChannelPromise promise)
protected void
readComplete0(int res, int data, int outstanding)
Called once a read was completed.protected int
scheduleRead0()
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
scheduleWriteSingle(java.lang.Object msg)
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
-
-
-
-
Method Detail
-
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
protected int scheduleWriteSingle(java.lang.Object msg)
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(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, io.netty.channel.ChannelPromise promise)
- Specified by:
connect
in interfaceio.netty.channel.Channel.Unsafe
- Overrides:
connect
in classAbstractIOUringChannel.AbstractUringUnsafe
-
-