Package io.netty.channel.epoll

Class NativeDatagramPacketArray

java.lang.Object

io.netty.channel.epoll.NativeDatagramPacketArray

final class NativeDatagramPacketArray
extends java.lang.Object

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

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field	Description
private int	count
private IovArray	iovArray
private byte[]	ipv4Bytes
private NativeDatagramPacketArray.NativeDatagramPacket[]	packets
private 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, java.net.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 java.net.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 java.lang.Object

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

Field Detail

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 Detail

NativeDatagramPacketArray

NativeDatagramPacketArray()

Method Detail

addWritable

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

add0

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

add

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

Throws:

java.lang.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 java.net.InetSocketAddress newAddress(byte[] addr,
                                                     int addrLen,
                                                     int port,
                                                     int scopeId,
                                                     byte[] ipv4Bytes)
                                              throws java.net.UnknownHostException

Throws:

java.net.UnknownHostException