Top Description Inners Fields Constructors Methods
io.netty5.channel.epoll

pack-priv final Class NativeDatagramPacketArray

extends Object
Class Inheritance
Imports
io.netty5.buffer.Buffer, io.netty5.channel.socket.DatagramPacket, io.netty5.channel.unix.IovArray, .Limits, .SegmentedDatagramPacket, io.netty5.util.internal.UnstableApi, java.net.Inet6Address, .InetAddress, .InetSocketAddress, .UnknownHostException, java.util.function.Predicate
Support sendmmsg(...) on linux with GLIBC 2.14+

Nested and Inner Type Summary

Modifier and TypeClass and Description
private class
NativeDatagramPacketArray.MyMessageProcessor

public class
NativeDatagramPacketArray.NativeDatagramPacket

Used to pass needed data to JNI.

Field Summary

Modifier and TypeField and Description
private int
count

private final IovArray
iovArray

private final byte[]
ipv4Bytes

private final NativeDatagramPacketArray.NativeDatagramPacket[]
packets

private final NativeDatagramPacketArray.MyMessageProcessor
processor

Constructor Summary

AccessConstructor and Description
pack-priv
NativeDatagramPacketArray()

Method Summary

Modifier and TypeMethod and Description
pack-priv Predicate<Object>
addFunction(boolean connected, int maxMessagesPerWrite)

pack-priv boolean
addReadable(Buffer buf, int segmentLen, InetSocketAddress recipient)

pack-priv boolean
addWritable(Buffer buf, int segmentLen, InetSocketAddress recipient)

pack-priv void
clear()

pack-priv int
count()

Returns the count

private static InetSocketAddress
newAddress(byte[] addr, int addrLen, int port, int scopeId, byte[] ipv4Bytes)

pack-priv NativeDatagramPacketArray.NativeDatagramPacket[]
packets()

Returns an array with count() NativeDatagramPackets filled.

pack-priv void
release()

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

countback to summary
private int count
iovArrayback to summary
private final IovArray iovArray
ipv4Bytesback to summary
private final byte[] ipv4Bytes
packetsback to summary
private final NativeDatagramPacketArray.NativeDatagramPacket[] packets
processorback to summary
private final NativeDatagramPacketArray.MyMessageProcessor processor

Constructor Detail

NativeDatagramPacketArrayback to summary
pack-priv NativeDatagramPacketArray()

Method Detail

addFunctionback to summary
pack-priv Predicate<Object> addFunction(boolean connected, int maxMessagesPerWrite)
addReadableback to summary
pack-priv boolean addReadable(Buffer buf, int segmentLen, InetSocketAddress recipient)
addWritableback to summary
pack-priv boolean addWritable(Buffer buf, int segmentLen, InetSocketAddress recipient)
clearback to summary
pack-priv void clear()
countback to summary
pack-priv int count()

Returns the count

newAddressback to summary
private static InetSocketAddress newAddress(byte[] addr, int addrLen, int port, int scopeId, byte[] ipv4Bytes) throws UnknownHostException
packetsback to summary
pack-priv NativeDatagramPacketArray.NativeDatagramPacket[] packets()

Returns an array with count() NativeDatagramPackets filled.

releaseback to summary
pack-priv void release()
io.netty5.channel.epoll back to summary

private final Class NativeDatagramPacketArray.MyMessageProcessor

extends Object
implements Predicate<Object>
Class Inheritance
  • java.lang.Object
  • io.netty5.channel.epoll.NativeDatagramPacketArray.MyMessageProcessor
All Implemented Interfaces
java.util.function.Predicate

Field Summary

Modifier and TypeField and Description
private boolean
connected

private int
maxMessagesPerWrite

Constructor Summary

AccessConstructor and Description
private
MyMessageProcessor()

Method Summary

Modifier and TypeMethod and Description
public boolean
test(Object
the input argument
msg)

Implements java.util.function.Predicate.test.

Evaluates this predicate on the given argument.
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

connectedback to summary
private boolean connected
maxMessagesPerWriteback to summary
private int maxMessagesPerWrite

Constructor Detail

MyMessageProcessorback to summary
private MyMessageProcessor()

Method Detail

testback to summary
public boolean test(Object msg)

Implements java.util.function.Predicate.test.

Doc from java.util.function.Predicate.test.

Evaluates this predicate on the given argument.

Parameters
msg:Object

the input argument

Returns:boolean

true if the input argument matches the predicate, otherwise false

Annotations
@Override
io.netty5.channel.epoll back to summary

public final Class NativeDatagramPacketArray.NativeDatagramPacket

extends Object
Class Inheritance
  • java.lang.Object
  • io.netty5.channel.epoll.NativeDatagramPacketArray.NativeDatagramPacket
Annotations
@SuppressWarnings:unused
@UnstableApi
Used to pass needed data to JNI.

Field Summary

Modifier and TypeField and Description
private int
count

private long
memoryAddress

private final byte[]
recipientAddr

private int
recipientAddrLen

private int
recipientPort

private int
recipientScopeId

private int
segmentSize

private final byte[]
senderAddr

private int
senderAddrLen

private int
senderPort

private int
senderScopeId

Constructor Summary

AccessConstructor and Description
public
NativeDatagramPacket()

Method Summary

Modifier and TypeMethod and Description
pack-priv int
count()

pack-priv boolean
hasSender()

private void
init(long memoryAddress, int count, int segmentSize, InetSocketAddress recipient)

pack-priv DatagramPacket
newDatagramPacket(Buffer buffer, InetSocketAddress recipient)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

countback to summary
private int count
memoryAddressback to summary
private long memoryAddress
recipientAddrback to summary
private final byte[] recipientAddr
recipientAddrLenback to summary
private int recipientAddrLen
recipientPortback to summary
private int recipientPort
recipientScopeIdback to summary
private int recipientScopeId
segmentSizeback to summary
private int segmentSize
senderAddrback to summary
private final byte[] senderAddr
senderAddrLenback to summary
private int senderAddrLen
senderPortback to summary
private int senderPort
senderScopeIdback to summary
private int senderScopeId

Constructor Detail

NativeDatagramPacketback to summary
public NativeDatagramPacket()

Method Detail

countback to summary
pack-priv int count()
hasSenderback to summary
pack-priv boolean hasSender()
initback to summary
private void init(long memoryAddress, int count, int segmentSize, InetSocketAddress recipient)
newDatagramPacketback to summary
pack-priv DatagramPacket newDatagramPacket(Buffer buffer, InetSocketAddress recipient) throws UnknownHostException