Package io.netty.channel.uring

Class SubmissionQueue

java.lang.Object

io.netty.channel.uring.SubmissionQueue

final class SubmissionQueue
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	closed
private int	enterFlags
(package private) int	enterRingFd
private int	head
private static VarHandle	INT_HANDLE
private java.nio.ByteBuffer	kflags
private java.nio.ByteBuffer	kHead
private java.nio.ByteBuffer	kTail
private static InternalLogger	logger
(package private) long	ringAddress
(package private) int	ringEntries
(package private) int	ringFd
private int	ringMask
(package private) int	ringSize
private static int	SQE_FD_FIELD
private static int	SQE_FLAGS_FIELD
private static int	SQE_IOPRIO_FIELD
private static int	SQE_LEN_FIELD
private static int	SQE_OP_CODE_FIELD
private static int	SQE_PERSONALITY_FIELD
(package private) static int	SQE_SIZE
private static int	SQE_UNION1_FIELD
private static int	SQE_UNION2_FIELD
private static int	SQE_UNION3_FIELD
private static int	SQE_UNION4_FIELD
private static int	SQE_UNION5_FIELD
private static int	SQE_UNION6_FIELD
private static int	SQE_USER_DATA_FIELD
private java.nio.ByteBuffer	submissionQueueArray
private int	tail

Constructor Summary

Constructors

Constructor	Description
SubmissionQueue(java.nio.ByteBuffer khead, java.nio.ByteBuffer ktail, int ringMask, int ringEntries, java.nio.ByteBuffer kflags, java.nio.ByteBuffer submissionQueueArray, int ringSize, long ringAddress, int ringFd)

Method Summary

Modifier and Type	Method	Description
(package private) long	addCancel(long sqeToCancel, long udata)
(package private) long	addEventFdRead(int fd, long bufferAddress, int pos, int limit, long udata)
(package private) long	addLinkTimeout(long timeoutMemoryAddress, long extraData)
(package private) long	addNop(byte flags, int nopFlags, long udata)
(package private) long	addNop(byte flags, long udata)
(package private) long	addTimeout(long timeoutMemoryAddress, long udata)
private void	checkClosed()
(package private) void	close()
int	count()
(package private) long	enqueueSqe(byte opcode, byte flags, short ioPrio, int fd, long union1, long union2, int len, int union3, long udata, short union4, short personality, int union5, long union6)
(package private) int	flags()
private int	ioUringEnter(int toSubmit, int minComplete, int flags)
private int	ioUringEnter0(int toSubmit, int minComplete, int f)
int	remaining()
private static int	sqeIndex(int tail, int ringMask)
(package private) long	submissionQueueArrayAddress()
(package private) int	submit()	Submit entries.
private int	submit(int toSubmit, int minComplete, int flags)
(package private) int	submitAndGet()	Submit entries and fetch completions.
private int	submitAndGet0(int minComplete)
(package private) int	submitAndGetNow()	Submit entries and fetch completions.
java.lang.String	toString()
(package private) void	tryRegisterRingFd()

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static final InternalLogger logger

SQE_SIZE

static final int SQE_SIZE

See Also:

Constant Field Values

SQE_OP_CODE_FIELD

private static final int SQE_OP_CODE_FIELD

See Also:

Constant Field Values

SQE_FLAGS_FIELD

private static final int SQE_FLAGS_FIELD

See Also:

Constant Field Values

SQE_IOPRIO_FIELD

private static final int SQE_IOPRIO_FIELD

See Also:

Constant Field Values

SQE_FD_FIELD

private static final int SQE_FD_FIELD

See Also:

Constant Field Values

SQE_UNION1_FIELD

private static final int SQE_UNION1_FIELD

See Also:

Constant Field Values

SQE_UNION2_FIELD

private static final int SQE_UNION2_FIELD

See Also:

Constant Field Values

SQE_LEN_FIELD

private static final int SQE_LEN_FIELD

See Also:

Constant Field Values

SQE_UNION3_FIELD

private static final int SQE_UNION3_FIELD

See Also:

Constant Field Values

SQE_USER_DATA_FIELD

private static final int SQE_USER_DATA_FIELD

See Also:

Constant Field Values

SQE_UNION4_FIELD

private static final int SQE_UNION4_FIELD

See Also:

Constant Field Values

SQE_PERSONALITY_FIELD

private static final int SQE_PERSONALITY_FIELD

See Also:

Constant Field Values

SQE_UNION5_FIELD

private static final int SQE_UNION5_FIELD

See Also:

Constant Field Values

SQE_UNION6_FIELD

private static final int SQE_UNION6_FIELD

See Also:

Constant Field Values

INT_HANDLE

private static final VarHandle INT_HANDLE

kHead

private final java.nio.ByteBuffer kHead

kTail

private final java.nio.ByteBuffer kTail

kflags

private final java.nio.ByteBuffer kflags

submissionQueueArray

private final java.nio.ByteBuffer submissionQueueArray

ringEntries

final int ringEntries

ringMask

private final int ringMask

ringSize

final int ringSize

ringAddress

final long ringAddress

ringFd

final int ringFd

enterRingFd

int enterRingFd

enterFlags

private int enterFlags

head

private int head

tail

private int tail

closed

private boolean closed

Constructor Detail

SubmissionQueue

SubmissionQueue(java.nio.ByteBuffer khead,
                java.nio.ByteBuffer ktail,
                int ringMask,
                int ringEntries,
                java.nio.ByteBuffer kflags,
                java.nio.ByteBuffer submissionQueueArray,
                int ringSize,
                long ringAddress,
                int ringFd)

Method Detail

flags

int flags()

submissionQueueArrayAddress

long submissionQueueArrayAddress()

close

void close()

checkClosed

private void checkClosed()

tryRegisterRingFd

void tryRegisterRingFd()

enqueueSqe

long enqueueSqe(byte opcode,
                byte flags,
                short ioPrio,
                int fd,
                long union1,
                long union2,
                int len,
                int union3,
                long udata,
                short union4,
                short personality,
                int union5,
                long union6)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

sqeIndex

private static int sqeIndex(int tail,
                            int ringMask)

addNop

long addNop(byte flags,
            long udata)

addNop

long addNop(byte flags,
            int nopFlags,
            long udata)

addTimeout

long addTimeout(long timeoutMemoryAddress,
                long udata)

addLinkTimeout

long addLinkTimeout(long timeoutMemoryAddress,
                    long extraData)

addEventFdRead

long addEventFdRead(int fd,
                    long bufferAddress,
                    int pos,
                    int limit,
                    long udata)

addCancel

long addCancel(long sqeToCancel,
               long udata)

submit

int submit()

Submit entries.

Returns:

the number of submitted entries.

submitAndGet

int submitAndGet()

Submit entries and fetch completions. This method will block until there is at least one completion ready to be processed.

Returns:

the number of submitted entries.

submitAndGetNow

int submitAndGetNow()

Submit entries and fetch completions.

Returns:

the number of submitted entries.

submitAndGet0

private int submitAndGet0(int minComplete)

submit

private int submit(int toSubmit,
                   int minComplete,
                   int flags)

ioUringEnter

private int ioUringEnter(int toSubmit,
                         int minComplete,
                         int flags)

ioUringEnter0

private int ioUringEnter0(int toSubmit,
                          int minComplete,
                          int f)

count

public int count()

remaining

public int remaining()