Package io.netty.channel.uring

Class MsgHdrMemory

java.lang.Object

io.netty.channel.uring.MsgHdrMemory

final class MsgHdrMemory
extends java.lang.Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
MsgHdrMemory()
MsgHdrMemory(short idx, java.nio.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, java.net.InetSocketAddress address, long bufferAddress, int length, short segmentSize)
(package private) void	setScmRightsFd(int fd)
private int	setSocketAddress(LinuxSocket socket, java.net.InetSocketAddress address)
(package private) void	setWithIovArrayAddress(LinuxSocket socket, java.net.InetSocketAddress address, long iovArrayAddress, int iovArrayLength, short segmentSize)

Methods inherited from class java.lang.Object

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

Field Detail

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 java.nio.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 java.nio.ByteBuffer msgHdrMemory

socketAddrMemory

private final java.nio.ByteBuffer socketAddrMemory

iovMemory

private final java.nio.ByteBuffer iovMemory

cmsgDataMemory

private final java.nio.ByteBuffer cmsgDataMemory

msgHdrMemoryAddress

private final long msgHdrMemoryAddress

idx

private final short idx

cmsgDataOffset

private final int cmsgDataOffset

Constructor Detail

MsgHdrMemory

MsgHdrMemory(short idx,
             java.nio.ByteBuffer msgHdrMemoryArray)

MsgHdrMemory

MsgHdrMemory()

Method Detail

set

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

set

void set(long iovArray,
         int length)

setWithIovArrayAddress

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

setSocketAddress

private int setSocketAddress(LinuxSocket socket,
                             java.net.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()