Package io.netty.incubator.channel.uring

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 java.lang.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(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress, io.netty.channel.ChannelPromise promise)
(package private) void	connectComplete(int res)	Connect was completed.
private void	fireEventAndClose(java.lang.Object evt)
protected 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, java.lang.Throwable cause)
(package private) IOUringRecvByteAllocatorHandle	newIOUringHandle(io.netty.channel.RecvByteBufAllocator.ExtendedHandle handle)
(package private) void	pollIn(int res)	Called once POLLIN event is ready to be processed
(package private) void	pollOut(int res)	Called once POLLOUT event is ready to be processed
(package private) void	pollRdHup(int res)	Called once POLLRDHUP event is ready to be processed
(package private) void	processDelayedClose()
(package private) void	readComplete(int res, int data)
protected abstract void	readComplete0(int res, int data, int outstandingCompletes)	Called once a read was completed.
IOUringRecvByteAllocatorHandle	recvBufAllocHandle()
private void	scheduleFirstRead()
private void	scheduleFirstReadIfNeeded()
(package private) void	schedulePollIn()
protected 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(java.lang.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) void	shutdownInput(boolean rdHup)
(package private) 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 java.lang.Object

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

Field Detail

allocHandle

private IOUringRecvByteAllocatorHandle allocHandle

Constructor Detail

AbstractUringUnsafe

AbstractUringUnsafe()

Method Detail

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(java.lang.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,
                                   java.lang.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(java.lang.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(java.net.SocketAddress remoteAddress,
                    java.net.SocketAddress localAddress,
                    io.netty.channel.ChannelPromise promise)