Top Inners Fields Constructors Methods
io.netty.incubator.channel.uring

pack-priv abstract Class AbstractIOUringServerChannel

extends AbstractIOUringChannel
implements ServerChannel
Class Inheritance
All Implemented Interfaces
io.netty.channel.ServerChannel, io.netty.channel.Channel, java.lang.Comparable, io.netty.channel.ChannelOutboundInvoker, io.netty.util.AttributeMap
Known Direct Subclasses
io.netty.incubator.channel.uring.IOUringServerSocketChannel
Imports
io.netty.channel.Channel, .ChannelOutboundBuffer, .ChannelPipeline, .ChannelPromise, .ServerChannel, io.netty.channel.unix.Buffer, .Errors, java.net.SocketAddress, java.nio.ByteBuffer

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv class
AbstractIOUringServerChannel.UringServerChannelUnsafe

Field Summary

Modifier and TypeField and Description
private final ByteBuffer
acceptedAddressLengthMemory

private final long
acceptedAddressLengthMemoryAddress

private final ByteBuffer
acceptedAddressMemory

private final long
acceptedAddressMemoryAddress

Inherited from io.netty.incubator.channel.uring.AbstractIOUringChannel:
activesocket

Constructor Summary

AccessConstructor and Description
protected
AbstractIOUringServerChannel(LinuxSocket socket, boolean active)

Method Summary

Modifier and TypeMethod and Description
protected void
doClose()

Overrides io.netty.incubator.channel.uring.AbstractIOUringChannel.doClose.

Close the Channel
protected void
doWrite(ChannelOutboundBuffer in)

Overrides io.netty.incubator.channel.uring.AbstractIOUringChannel.doWrite.

Flush the content of the given buffer to the remote peer.
public AbstractIOUringChannel
getChannel()

pack-priv abstract Channel
newChildChannel(int fd, long acceptedAddressMemoryAddress, long acceptedAddressLengthMemoryAddress)

protected AbstractIOUringChannel.AbstractUringUnsafe
newUnsafe()

Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.newUnsafe.

Create a new AbstractUnsafe instance which will be used for the life-time of the Channel
Inherited from io.netty.incubator.channel.uring.AbstractIOUringChannel:
checkResolvableclearPollFlagdoBeginReaddoBinddoDeregisterdoDisconnectdoRegisterfdfilterOutboundMessageioScheduledioUringUnsafeisActiveisCompatibleisOpenlocalAddress0metadatanewDirectBuffernewDirectBufferremoteAddress0resetCachedAddressesschedulePollRdHupsubmissionQueue

Field Detail

acceptedAddressLengthMemoryback to summary
private final ByteBuffer acceptedAddressLengthMemory
acceptedAddressLengthMemoryAddressback to summary
private final long acceptedAddressLengthMemoryAddress
acceptedAddressMemoryback to summary
private final ByteBuffer acceptedAddressMemory
acceptedAddressMemoryAddressback to summary
private final long acceptedAddressMemoryAddress

Constructor Detail

AbstractIOUringServerChannelback to summary
protected AbstractIOUringServerChannel(LinuxSocket socket, boolean active)

Method Detail

doCloseback to summary
protected void doClose() throws Exception

Overrides io.netty.incubator.channel.uring.AbstractIOUringChannel.doClose.

Doc from io.netty.channel.AbstractChannel.doClose.

Close the Channel

Annotations
@Override
doWriteback to summary
protected void doWrite(ChannelOutboundBuffer in)

Overrides io.netty.incubator.channel.uring.AbstractIOUringChannel.doWrite.

Doc from io.netty.channel.AbstractChannel.doWrite.

Flush the content of the given buffer to the remote peer.

Annotations
@Override
getChannelback to summary
public AbstractIOUringChannel getChannel()
newChildChannelback to summary
pack-priv abstract Channel newChildChannel(int fd, long acceptedAddressMemoryAddress, long acceptedAddressLengthMemoryAddress) throws Exception
newUnsafeback to summary
protected AbstractIOUringChannel.AbstractUringUnsafe newUnsafe()

Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.newUnsafe.

Doc from io.netty.channel.AbstractChannel.newUnsafe.

Create a new AbstractUnsafe instance which will be used for the life-time of the Channel

Annotations
@Override
io.netty.incubator.channel.uring back to summary

pack-priv final Class AbstractIOUringServerChannel.UringServerChannelUnsafe

extends AbstractUringUnsafe
Class Inheritance

Constructor Summary

AccessConstructor and Description
pack-priv
UringServerChannelUnsafe()

Method Summary

Modifier and TypeMethod and Description
public void
connect(final SocketAddress remoteAddress, final SocketAddress localAddress, final ChannelPromise promise)

Overrides io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.connect.

Implements io.netty.channel.Channel.Unsafe.connect.

Connect the Channel of the given ChannelFuture with the given remote SocketAddress.
protected void
readComplete0(int res, int data, int outstanding)

Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.readComplete0.

Called once a read was completed.
protected int
scheduleRead0()

Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.scheduleRead0.

Schedule a read and returns the number of readComplete(int, int) calls that are expected because of the scheduled read.
protected int
scheduleWriteMultiple(ChannelOutboundBuffer in)

Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.scheduleWriteMultiple.

Schedule the write of multiple messages in the ChannelOutboundBuffer and returns the number of writeComplete(int, int) calls that are expected because of the scheduled write.
protected int
scheduleWriteSingle(Object msg)

Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.scheduleWriteSingle.

Schedule the write of a single message and returns the number of writeComplete(int, int) calls that are expected because of the scheduled write
pack-priv boolean
writeComplete0(int res, int data, int outstanding)

Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.writeComplete0.

Called once a write was completed.
Inherited from io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe:
closeconnectCompleteflush0newIOUringHandlepollInpollOutpollRdHupprocessDelayedClosereadCompleterecvBufAllocHandleschedulePollInscheduleReadshutdownInputwriteComplete

Constructor Detail

UringServerChannelUnsafeback to summary
pack-priv UringServerChannelUnsafe()

Method Detail

connectback to summary
public void connect(final SocketAddress remoteAddress, final SocketAddress localAddress, final ChannelPromise promise)

Overrides io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.connect.

Implements io.netty.channel.Channel.Unsafe.connect.

Doc from io.netty.channel.Channel.Unsafe.connect.

Connect the Channel of the given ChannelFuture with the given remote SocketAddress. If a specific local SocketAddress should be used it need to be given as argument. Otherwise just pass null to it. The ChannelPromise will get notified once the connect operation was complete.

Annotations
@Override
readComplete0back to summary
protected void readComplete0(int res, int data, int outstanding)

Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.readComplete0.

Doc from io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.readComplete0.

Called once a read was completed.

Annotations
@Override
scheduleRead0back to summary
protected int scheduleRead0()

Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.scheduleRead0.

Doc from io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.scheduleRead0.

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

Annotations
@Override
scheduleWriteMultipleback to summary
protected int scheduleWriteMultiple(ChannelOutboundBuffer in)

Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.scheduleWriteMultiple.

Doc from io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.scheduleWriteMultiple.

Schedule the write of multiple messages in the ChannelOutboundBuffer and returns the number of writeComplete(int, int) calls that are expected because of the scheduled write.

Annotations
@Override
scheduleWriteSingleback to summary
protected int scheduleWriteSingle(Object msg)

Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.scheduleWriteSingle.

Doc from io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.scheduleWriteSingle.

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

Annotations
@Override
writeComplete0back to summary
pack-priv boolean writeComplete0(int res, int data, int outstanding)

Implements abstract io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.writeComplete0.

Doc from io.netty.incubator.channel.uring.AbstractIOUringChannel.AbstractUringUnsafe.writeComplete0.

Called once a write was completed.

Annotations
@Override