io.netty.channel.uring

Class IoUringIoOps

java.lang.Object

io.netty.channel.uring.IoUringIoOps

All Implemented Interfaces:

io.netty.channel.IoOps

public final class IoUringIoOps
extends Object
implements io.netty.channel.IoOps

IoOps for implementation for IO_uring.

Constructor Summary

Constructors

Constructor and Description
IoUringIoOps(byte opcode, int flags, short ioPrio, int fd, int rwFlags, long bufferAddress, int length, long offset, short data) Create a new instance

Method Summary

Modifier and Type	Method and Description
long	bufferAddress() Returns the bufferAddress that will be used.
short	data() Returns the data that the user attached to the op.
int	fd() Returns the filedescriptor.
int	flags() Returns the flags that will be applied.
short	ioPrio() Returns the priority.
int	length() Returns the length that will be used.
static IoUringIoOps	newAccept(int fd, int flags, int acceptFlags, long acceptedAddressMemoryAddress, long acceptedAddressLengthMemoryAddress, short data) Returns a new OP_ACCEPT IoUringIoOps.
static IoUringIoOps	newAsyncCancel(int fd, int flags, long userData, short data) Returns a new OP_ASYNC_CANCEL IoUringIoOps.
static IoUringIoOps	newClose(int fd, int flags, short data) Returns a new OP_CLOSE IoUringIoOps.
static IoUringIoOps	newConnect(int fd, int flags, long remoteMemoryAddress, short data) Returns a new OP_CONNECT IoUringIoOps.
static IoUringIoOps	newPollAdd(int fd, int flags, int mask, short data) Returns a new OP_POLL_ADD IoUringIoOps.
static IoUringIoOps	newPollRemove(int fd, int flags, long userData, short data) Returns a new OP_POLL_REMOVE IoUringIoOps.
static IoUringIoOps	newRecv(int fd, int flags, int recvFlags, long memoryAddress, int length, short data) Returns a new OP_RECV IoUringIoOps.
static IoUringIoOps	newRecvmsg(int fd, int flags, int msgFlags, long memoryAddress, short data) Returns a new OP_RECVMSG IoUringIoOps.
static IoUringIoOps	newSend(int fd, int flags, int sendFlags, long memoryAddress, int length, short data) Returns a new OP_SEND IoUringIoOps.
static IoUringIoOps	newSendmsg(int fd, int flags, int msgFlags, long address, short data) Returns a new OP_SENDMSG IoUringIoOps.
static IoUringIoOps	newShutdown(int fd, int flags, int how, int id, short data) Returns a new OP_SHUTDOWN IoUringIoOps.
static IoUringIoOps	newWrite(int fd, int flags, int writeFlags, long memoryAddress, int length, short data) Returns a new OP_WRITE IoUringIoOps.
static IoUringIoOps	newWritev(int fd, int flags, int writevFlags, long memoryAddress, int length, short data) Returns a new OP_WRITEV IoUringIoOps.
long	offset() Returns the offset that will be used.
byte	opcode() Returns the opcode.
int	rwFlags() Returns the rwFlags that will be applied.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

IoUringIoOps

public IoUringIoOps(byte opcode,
                    int flags,
                    short ioPrio,
                    int fd,
                    int rwFlags,
                    long bufferAddress,
                    int length,
                    long offset,
                    short data)

Create a new instance

Parameters:

opcode - the operation.

flags - the flags

ioPrio - the priority.

fd - the filedescriptor.

rwFlags - the flags specific for the op.

bufferAddress - the bufferaddress

length - the length

offset - the offset.

data - the user data that will be passed back on completion.

Method Detail

fd

public int fd()

Returns the filedescriptor.

Returns:

fd

opcode

public byte opcode()

Returns the opcode.

Returns:

opcode

flags

public int flags()

Returns the flags that will be applied.

Returns:

flags

ioPrio

public short ioPrio()

Returns the priority.

Returns:

ioPrio

rwFlags

public int rwFlags()

Returns the rwFlags that will be applied. These are specific to the opcode.

Returns:

rwFlags

bufferAddress

public long bufferAddress()

Returns the bufferAddress that will be used. This is specific to the opcode.

Returns:

bufferAddress

length

public int length()

Returns the length that will be used. This is specific to the opcode.

Returns:

length

offset

public long offset()

Returns the offset that will be used. This is specific to the opcode.

Returns:

offset

data

public short data()

Returns the data that the user attached to the op. This data will be passed back on completion.

Returns:

data

toString

public String toString()

Overrides:

toString in class Object

newAsyncCancel

public static IoUringIoOps newAsyncCancel(int fd,
                                          int flags,
                                          long userData,
                                          short data)

Returns a new OP_ASYNC_CANCEL IoUringIoOps.

Parameters:

fd - the filedescriptor

flags - the flags.

userData - the user data that identify a previous submitted IoUringIoOps that should be cancelled. The value to use here is returned by IoUringIoRegistration.submit(IoOps).

data - the data

Returns:

ops.

newClose

public static IoUringIoOps newClose(int fd,
                                    int flags,
                                    short data)

Returns a new OP_CLOSE IoUringIoOps.

Parameters:

fd - the filedescriptor

flags - the flags.

data - the data

Returns:

ops.

newPollAdd

public static IoUringIoOps newPollAdd(int fd,
                                      int flags,
                                      int mask,
                                      short data)

Returns a new OP_POLL_ADD IoUringIoOps.

Parameters:

fd - the filedescriptor

flags - the flags.

mask - the mask.

data - the data

Returns:

ops.

newSendmsg

public static IoUringIoOps newSendmsg(int fd,
                                      int flags,
                                      int msgFlags,
                                      long address,
                                      short data)

Returns a new OP_SENDMSG IoUringIoOps.

Parameters:

fd - the filedescriptor

flags - the flags.

msgFlags - the msg flags.

data - the data

Returns:

ops.

newConnect

public static IoUringIoOps newConnect(int fd,
                                      int flags,
                                      long remoteMemoryAddress,
                                      short data)

Returns a new OP_CONNECT IoUringIoOps.

Parameters:

fd - the filedescriptor

flags - the flags.

remoteMemoryAddress - the memory address of the sockaddr_storage.

data - the data

Returns:

ops.

newPollRemove

public static IoUringIoOps newPollRemove(int fd,
                                         int flags,
                                         long userData,
                                         short data)

Returns a new OP_POLL_REMOVE IoUringIoOps.

Parameters:

fd - the filedescriptor

flags - the flags.

userData - the user data that identify a previous submitted IoUringIoOps that should be cancelled. The value to use here is returned by IoUringIoRegistration.submit(IoOps).

data - the data

Returns:

ops.

newAccept

public static IoUringIoOps newAccept(int fd,
                                     int flags,
                                     int acceptFlags,
                                     long acceptedAddressMemoryAddress,
                                     long acceptedAddressLengthMemoryAddress,
                                     short data)

Returns a new OP_ACCEPT IoUringIoOps.

Parameters:

fd - the filedescriptor

flags - the flags.

acceptedAddressMemoryAddress - the memory address of the sockaddr_storage.

acceptedAddressLengthMemoryAddress - the memory address of the length that will be updated once a new connection was accepted.

data - the data

Returns:

ops.

newWritev

public static IoUringIoOps newWritev(int fd,
                                     int flags,
                                     int writevFlags,
                                     long memoryAddress,
                                     int length,
                                     short data)

Returns a new OP_WRITEV IoUringIoOps.

Parameters:

fd - the filedescriptor

flags - the flags.

writevFlags - the writev flags.

memoryAddress - the memory address of the io_vec array.

length - the length of the io_vec array.

data - the data

Returns:

ops.

newWrite

public static IoUringIoOps newWrite(int fd,
                                    int flags,
                                    int writeFlags,
                                    long memoryAddress,
                                    int length,
                                    short data)

Returns a new OP_WRITE IoUringIoOps.

Parameters:

fd - the filedescriptor

flags - the flags.

writeFlags - the write flags.

memoryAddress - the memory address of the buffer

length - the length of the buffer.

data - the data

Returns:

ops.

newRecv

public static IoUringIoOps newRecv(int fd,
                                   int flags,
                                   int recvFlags,
                                   long memoryAddress,
                                   int length,
                                   short data)

Returns a new OP_RECV IoUringIoOps.

Parameters:

fd - the filedescriptor

flags - the flags.

recvFlags - the recv flags.

memoryAddress - the memory address of the buffer

length - the length of the buffer.

data - the data

Returns:

ops.

newRecvmsg

public static IoUringIoOps newRecvmsg(int fd,
                                      int flags,
                                      int msgFlags,
                                      long memoryAddress,
                                      short data)

Returns a new OP_RECVMSG IoUringIoOps.

Parameters:

fd - the filedescriptor

flags - the flags.

msgFlags - the recvmsg flags.

memoryAddress - the memory address of the msghdr struct

data - the data

Returns:

ops.

newSend

public static IoUringIoOps newSend(int fd,
                                   int flags,
                                   int sendFlags,
                                   long memoryAddress,
                                   int length,
                                   short data)

Returns a new OP_SEND IoUringIoOps.

Parameters:

fd - the filedescriptor

flags - the flags.

sendFlags - the send flags.

memoryAddress - the memory address of the buffer.

length - the length of the buffer.

data - the data

Returns:

ops.

newShutdown

public static IoUringIoOps newShutdown(int fd,
                                       int flags,
                                       int how,
                                       int id,
                                       short data)

Returns a new OP_SHUTDOWN IoUringIoOps.

Parameters:

fd - the filedescriptor

flags - the flags.

how - how the shutdown will be done.

data - the data

Returns:

ops.