Class IoUringIoHandler.DefaultIoUringIoRegistration

java.lang.Object

io.netty.channel.uring.IoUringIoHandler.DefaultIoUringIoRegistration

All Implemented Interfaces:

IoRegistration

Enclosing class:

IoUringIoHandler

private final class IoUringIoHandler.DefaultIoUringIoRegistration
extends Object
implements IoRegistration

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicBoolean	canceled
private final IoUringIoEvent	event
private final ThreadAwareExecutor	executor
(package private) final IoUringIoHandle	handle
private int	id
private int	outstandingCompletions
private boolean	removeLater

Constructor Summary

Constructors

Constructor	Description
DefaultIoUringIoRegistration(ThreadAwareExecutor executor, IoUringIoHandle handle)

Method Summary

Modifier and Type	Method	Description
<T> T	attachment()	Implementation specific attachment, which might be null.
boolean	cancel()	Cancel the registration.
private boolean	canUseFastPath(long userData)
(package private) void	close()
private int	fd()
(package private) void	handle(int res, int flags, byte op, long userData, ByteBuffer extraCqeData)
boolean	isValid()	Returns true if the registration is still valid.
private void	remove()
(package private) void	setId(int id)
long	submit(IoOps ops)	Submit the IoOps to the registration.
private void	submitFastPath0(IoUringIoOps ioOps, long seq)
private void	submitSlowPath0(IoUringIoOps ioOps, long token, long userData)
private void	tryRemove()

Methods inherited from class Object

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

Field Details

canceled

private final AtomicBoolean canceled

executor

private final ThreadAwareExecutor executor

event

private final IoUringIoEvent event

handle

final IoUringIoHandle handle

removeLater

private boolean removeLater

outstandingCompletions

private int outstandingCompletions

id

private int id

Constructor Details

DefaultIoUringIoRegistration

DefaultIoUringIoRegistration(ThreadAwareExecutor executor,
 IoUringIoHandle handle)

Method Details

setId

void setId(int id)

submit

public long submit(IoOps ops)

Description copied from interface: IoRegistration

Submit the IoOps to the registration.

Specified by:

submit in interface IoRegistration

Parameters:

ops - ops.

Returns:

an identifier for the operation, which might be unique or not (depending on the implementation).

submitFastPath0

private void submitFastPath0(IoUringIoOps ioOps,
 long seq)

submitSlowPath0

private void submitSlowPath0(IoUringIoOps ioOps,
 long token,
 long userData)

canUseFastPath

private boolean canUseFastPath(long userData)

fd

private int fd()

attachment

public <T> T attachment()

Description copied from interface: IoRegistration

Implementation specific attachment, which might be null.

Specified by:

attachment in interface IoRegistration

Returns:

attachment.

isValid

public boolean isValid()

Description copied from interface: IoRegistration

Returns true if the registration is still valid. Once IoRegistration.cancel() is called this will return false.

Specified by:

isValid in interface IoRegistration

Returns:

valid.

cancel

public boolean cancel()

Description copied from interface: IoRegistration

Cancel the registration.

Specified by:

cancel in interface IoRegistration

Returns:

true if cancellation was successful, false otherwise.

tryRemove

private void tryRemove()

remove

private void remove()

close

void close()

handle

void handle(int res,
 int flags,
 byte op,
 long userData,
 ByteBuffer extraCqeData)