Class MsgHdrMemory

java.lang.Object

io.netty.channel.uring.MsgHdrMemory

final class MsgHdrMemory
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final ByteBuffer	cmsgDataMemory
private final CleanableDirectBuffer	cmsgDataMemoryCleanable
private final int	cmsgDataOffset
private static final byte[]	EMPTY_SOCKADDR_STORAGE
private static final ByteBuffer	GLOBAL_IOV_BASE
private static final long	GLOBAL_IOV_BASE_ADDRESS
private static final int	GLOBAL_IOV_LEN
private final short	idx
private final ByteBuffer	iovMemory
private final CleanableDirectBuffer	iovMemoryCleanable
static final int	MSG_HDR_SIZE
private final ByteBuffer	msgHdrMemory
private final long	msgHdrMemoryAddress
private final CleanableDirectBuffer	msgHdrMemoryCleanable
private final ByteBuffer	socketAddrMemory
private final CleanableDirectBuffer	socketAddrMemoryCleanable

Constructor Summary

Constructors

Constructor	Description
MsgHdrMemory()
MsgHdrMemory(short idx, ByteBuffer msgHdrMemoryArray)

Method Summary

Modifier and Type	Method	Description
(package private) long	address()
(package private) DatagramPacket	get(IoUringDatagramChannel channel, IoUringIoHandler handler, ByteBuf buffer, int bytesRead)
(package private) int	getScmRightsFd()
(package private) boolean	hasPort(IoUringDatagramChannel channel)
(package private) short	idx()
(package private) void	prepRecvReadFd()
(package private) void	release()
(package private) void	set(long iovArray, int length)
(package private) void	set(LinuxSocket socket, InetSocketAddress address, long bufferAddress, int length, short segmentSize)
(package private) void	setScmRightsFd(int fd)
private int	setSocketAddress(LinuxSocket socket, InetSocketAddress address)
(package private) void	setWithIovArrayAddress(LinuxSocket socket, InetSocketAddress address, long iovArrayAddress, int iovArrayLength, short segmentSize)

Methods inherited from class Object

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

Field Details

MSG_HDR_SIZE

public static final int MSG_HDR_SIZE

EMPTY_SOCKADDR_STORAGE

private static final byte[] EMPTY_SOCKADDR_STORAGE

GLOBAL_IOV_LEN

private static final int GLOBAL_IOV_LEN

See Also:

• Constant Field Values

GLOBAL_IOV_BASE

private static final ByteBuffer GLOBAL_IOV_BASE

GLOBAL_IOV_BASE_ADDRESS

private static final long GLOBAL_IOV_BASE_ADDRESS

msgHdrMemoryCleanable

private final CleanableDirectBuffer msgHdrMemoryCleanable

socketAddrMemoryCleanable

private final CleanableDirectBuffer socketAddrMemoryCleanable

iovMemoryCleanable

private final CleanableDirectBuffer iovMemoryCleanable

cmsgDataMemoryCleanable

private final CleanableDirectBuffer cmsgDataMemoryCleanable

msgHdrMemory

private final ByteBuffer msgHdrMemory

socketAddrMemory

private final ByteBuffer socketAddrMemory

iovMemory

private final ByteBuffer iovMemory

cmsgDataMemory

private final ByteBuffer cmsgDataMemory

msgHdrMemoryAddress

private final long msgHdrMemoryAddress

idx

private final short idx

cmsgDataOffset

private final int cmsgDataOffset

Constructor Details

MsgHdrMemory

MsgHdrMemory(short idx,
 ByteBuffer msgHdrMemoryArray)

MsgHdrMemory

MsgHdrMemory()

Method Details

set

void set(LinuxSocket socket,
 InetSocketAddress address,
 long bufferAddress,
 int length,
 short segmentSize)

set

void set(long iovArray,
 int length)

setWithIovArrayAddress

void setWithIovArrayAddress(LinuxSocket socket,
 InetSocketAddress address,
 long iovArrayAddress,
 int iovArrayLength,
 short segmentSize)

setSocketAddress

private int setSocketAddress(LinuxSocket socket,
 InetSocketAddress address)

setScmRightsFd

void setScmRightsFd(int fd)

getScmRightsFd

int getScmRightsFd()

prepRecvReadFd

void prepRecvReadFd()

hasPort

boolean hasPort(IoUringDatagramChannel channel)

get

DatagramPacket get(IoUringDatagramChannel channel,
 IoUringIoHandler handler,
 ByteBuf buffer,
 int bytesRead)

idx

short idx()

address

long address()

release

void release()