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

Modifier and Type	Method	Description
void	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	scheduleRead0()	Schedule a read and returns the number of AbstractIOUringChannel.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 the ChannelOutboundBuffer and returns the number of AbstractIOUringChannel.AbstractUringUnsafe.writeComplete(int, int) calls that are expected because of the scheduled write.
protected int	scheduleWriteSingle(Object msg)	Schedule the write of a single message and returns the number of AbstractIOUringChannel.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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 the ChannelOutboundBuffer and returns the number of AbstractIOUringChannel.AbstractUringUnsafe.writeComplete(int, int) calls that are expected because of the scheduled write.

Specified by:

scheduleWriteMultiple in class AbstractIOUringChannel.AbstractUringUnsafe

scheduleWriteSingle

protected int scheduleWriteSingle(Object msg)

Description copied from class: AbstractIOUringChannel.AbstractUringUnsafe

Schedule the write of a single message and returns the number of AbstractIOUringChannel.AbstractUringUnsafe.writeComplete(int, int) calls that are expected because of the scheduled write

Specified by:

scheduleWriteSingle in class AbstractIOUringChannel.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 class AbstractIOUringChannel.AbstractUringUnsafe

scheduleRead0

protected int scheduleRead0()

Description copied from class: AbstractIOUringChannel.AbstractUringUnsafe

Schedule a read and returns the number of AbstractIOUringChannel.AbstractUringUnsafe.readComplete(int, int) calls that are expected because of the scheduled read.

Specified by:

scheduleRead0 in class AbstractIOUringChannel.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 class AbstractIOUringChannel.AbstractUringUnsafe

connect

public void connect(SocketAddress remoteAddress,
 SocketAddress localAddress,
 io.netty.channel.ChannelPromise promise)

Specified by:

connect in interface io.netty.channel.Channel.Unsafe

Overrides:

connect in class AbstractIOUringChannel.AbstractUringUnsafe