Class NativeDatagramPacketArray

java.lang.Object

io.netty.channel.epoll.NativeDatagramPacketArray

final class NativeDatagramPacketArray
extends Object

Support sendmmsg(...) on linux with GLIBC 2.14+

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private final class	NativeDatagramPacketArray.MyMessageProcessor
final class	NativeDatagramPacketArray.NativeDatagramPacket	Used to pass needed data to JNI.

Field Summary

Fields

Modifier and Type	Field	Description
private int	count
private final IovArray	iovArray
private final byte[]	ipv4Bytes
private final NativeDatagramPacketArray.NativeDatagramPacket[]	packets
private final NativeDatagramPacketArray.MyMessageProcessor	processor

Constructor Summary

Constructors

Constructor	Description
NativeDatagramPacketArray()

Method Summary

Modifier and Type	Method	Description
(package private) void	add(ChannelOutboundBuffer buffer, boolean connected, int maxMessagesPerWrite)
private boolean	add0(ByteBuf buf, int index, int len, int segmentLen, InetSocketAddress recipient)
(package private) boolean	addWritable(ByteBuf buf, int index, int len)
(package private) void	clear()
(package private) int	count()	Returns the count
private static InetSocketAddress	newAddress(byte[] addr, int addrLen, int port, int scopeId, byte[] ipv4Bytes)
(package private) NativeDatagramPacketArray.NativeDatagramPacket[]	packets()	Returns an array with count() NativeDatagramPacketArray.NativeDatagramPackets filled.
(package private) void	release()

Methods inherited from class Object

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

Field Details

packets

private final NativeDatagramPacketArray.NativeDatagramPacket[] packets

iovArray

private final IovArray iovArray

ipv4Bytes

private final byte[] ipv4Bytes

processor

private final NativeDatagramPacketArray.MyMessageProcessor processor

count

private int count

Constructor Details

NativeDatagramPacketArray

NativeDatagramPacketArray()

Method Details

addWritable

boolean addWritable(ByteBuf buf,
 int index,
 int len)

add0

private boolean add0(ByteBuf buf,
 int index,
 int len,
 int segmentLen,
 InetSocketAddress recipient)

add

void add(ChannelOutboundBuffer buffer,
 boolean connected,
 int maxMessagesPerWrite)
  throws Exception

Throws:

Exception

count

int count()

Returns the count

packets

NativeDatagramPacketArray.NativeDatagramPacket[] packets()

Returns an array with count() NativeDatagramPacketArray.NativeDatagramPackets filled.

clear

void clear()

release

void release()

newAddress

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

Throws:

UnknownHostException