Class AbstractIOUringChannel.AbstractUringUnsafe

java.lang.Object

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

All Implemented Interfaces:

io.netty.channel.Channel.Unsafe

Direct Known Subclasses:

AbstractIOUringServerChannel.UringServerChannelUnsafe, AbstractIOUringStreamChannel.IOUringStreamUnsafe, IOUringDatagramChannel.IOUringDatagramChannelUnsafe

Enclosing class:

AbstractIOUringChannel

abstract class AbstractIOUringChannel.AbstractUringUnsafe
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private IOUringRecvByteAllocatorHandle	allocHandle

Constructor Summary

Constructors

Constructor	Description
AbstractUringUnsafe()

Method Summary

Modifier and Type	Method	Description
void	close(io.netty.channel.ChannelPromise promise)
void	connect(SocketAddress remoteAddress, SocketAddress localAddress, io.netty.channel.ChannelPromise promise)
(package private) void	connectComplete(int res)	Connect was completed.
private void	fireEventAndClose(Object evt)
protected final void	flush0()
private void	forceClose(io.netty.channel.ChannelPromise promise)
private void	fulfillConnectPromise(io.netty.channel.ChannelPromise promise, boolean wasActive)
private void	fulfillConnectPromise(io.netty.channel.ChannelPromise promise, Throwable cause)
(package private) final IOUringRecvByteAllocatorHandle	newIOUringHandle(io.netty.channel.RecvByteBufAllocator.ExtendedHandle handle)
(package private) final void	pollIn(int res)	Called once POLLIN event is ready to be processed
(package private) final void	pollOut(int res)	Called once POLLOUT event is ready to be processed
(package private) final void	pollRdHup(int res)	Called once POLLRDHUP event is ready to be processed
(package private) final void	processDelayedClose()
(package private) final void	readComplete(int res, int data)
protected abstract void	readComplete0(int res, int data, int outstandingCompletes)	Called once a read was completed.
final IOUringRecvByteAllocatorHandle	recvBufAllocHandle()
private void	scheduleFirstRead()
private void	scheduleFirstReadIfNeeded()
(package private) final void	schedulePollIn()
protected final void	scheduleRead()
protected abstract int	scheduleRead0()	Schedule a read and returns the number of readComplete(int, int) calls that are expected because of the scheduled read.
protected abstract int	scheduleWriteMultiple(io.netty.channel.ChannelOutboundBuffer in)	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 abstract int	scheduleWriteSingle(Object msg)	Schedule the write of a single message and returns the number of writeComplete(int, int) calls that are expected because of the scheduled write
(package private) final void	shutdownInput(boolean rdHup)
(package private) final void	writeComplete(int res, int data)	Called once a write was completed.
(package private) abstract boolean	writeComplete0(int res, int data, int outstanding)	Called once a write was completed.

Methods inherited from class Object

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

Field Details

allocHandle

private IOUringRecvByteAllocatorHandle allocHandle

Constructor Details

AbstractUringUnsafe

AbstractUringUnsafe()

Method Details

scheduleWriteMultiple

protected abstract int scheduleWriteMultiple(io.netty.channel.ChannelOutboundBuffer in)

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.

scheduleWriteSingle

protected abstract int scheduleWriteSingle(Object msg)

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

close

public void close(io.netty.channel.ChannelPromise promise)

Specified by:

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

forceClose

private void forceClose(io.netty.channel.ChannelPromise promise)

flush0

protected final void flush0()

fulfillConnectPromise

private void fulfillConnectPromise(io.netty.channel.ChannelPromise promise,
 Throwable cause)

fulfillConnectPromise

private void fulfillConnectPromise(io.netty.channel.ChannelPromise promise,
 boolean wasActive)

newIOUringHandle

final IOUringRecvByteAllocatorHandle newIOUringHandle(io.netty.channel.RecvByteBufAllocator.ExtendedHandle handle)

recvBufAllocHandle

public final IOUringRecvByteAllocatorHandle recvBufAllocHandle()

Specified by:

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

shutdownInput

final void shutdownInput(boolean rdHup)

fireEventAndClose

private void fireEventAndClose(Object evt)

schedulePollIn

final void schedulePollIn()

processDelayedClose

final void processDelayedClose()

readComplete

final void readComplete(int res,
 int data)

readComplete0

protected abstract void readComplete0(int res,
 int data,
 int outstandingCompletes)

Called once a read was completed.

pollRdHup

final void pollRdHup(int res)

Called once POLLRDHUP event is ready to be processed

pollIn

final void pollIn(int res)

Called once POLLIN event is ready to be processed

scheduleFirstReadIfNeeded

private void scheduleFirstReadIfNeeded()

scheduleFirstRead

private void scheduleFirstRead()

scheduleRead

protected final void scheduleRead()

scheduleRead0

protected abstract int scheduleRead0()

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

pollOut

final void pollOut(int res)

Called once POLLOUT event is ready to be processed

writeComplete

final void writeComplete(int res,
 int data)

Called once a write was completed.

writeComplete0

abstract boolean writeComplete0(int res,
 int data,
 int outstanding)

Called once a write was completed.

connectComplete

void connectComplete(int res)

Connect was completed.

connect

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