io.netty.channel.epoll

Class NativeDatagramPacketArray

java.lang.Object

io.netty.channel.epoll.NativeDatagramPacketArray

All Implemented Interfaces:

ChannelOutboundBuffer.MessageProcessor

final class NativeDatagramPacketArray
extends java.lang.Object
implements ChannelOutboundBuffer.MessageProcessor

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	NativeDatagramPacketArray.NativeDatagramPacket Used to pass needed data to JNI.

Field Summary

Fields

Modifier and Type	Field and Description
private static FastThreadLocal<NativeDatagramPacketArray>	ARRAY
private int	count
private NativeDatagramPacketArray.NativeDatagramPacket[]	packets

Constructor Summary

Constructors

Modifier	Constructor and Description
private	NativeDatagramPacketArray()

Method Summary

Modifier and Type	Method and Description
(package private) boolean	add(DatagramPacket packet) Try to add the given DatagramPacket.
(package private) int	count() Returns the count
(package private) static NativeDatagramPacketArray	getInstance(ChannelOutboundBuffer buffer) Returns a NativeDatagramPacketArray which is filled with the flushed messages of ChannelOutboundBuffer.
(package private) NativeDatagramPacketArray.NativeDatagramPacket[]	packets() Returns an array with count() NativeDatagramPacketArray.NativeDatagramPackets filled.
boolean	processMessage(java.lang.Object msg) Will be called for each flushed message until it either there are no more flushed messages or this method returns false.

Methods inherited from class java.lang.Object

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

Field Detail

ARRAY

private static final FastThreadLocal<NativeDatagramPacketArray> ARRAY

packets

private final NativeDatagramPacketArray.NativeDatagramPacket[] packets

count

private int count

Constructor Detail

NativeDatagramPacketArray

private NativeDatagramPacketArray()

Method Detail

add

boolean add(DatagramPacket packet)

Try to add the given DatagramPacket. Returns true on success, false otherwise.

processMessage

public boolean processMessage(java.lang.Object msg)
                       throws java.lang.Exception

Description copied from interface: ChannelOutboundBuffer.MessageProcessor

Will be called for each flushed message until it either there are no more flushed messages or this method returns false.

Specified by:

processMessage in interface ChannelOutboundBuffer.MessageProcessor

Throws:

java.lang.Exception

count

int count()

Returns the count

packets

NativeDatagramPacketArray.NativeDatagramPacket[] packets()

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

getInstance

static NativeDatagramPacketArray getInstance(ChannelOutboundBuffer buffer)
                                      throws java.lang.Exception

Returns a NativeDatagramPacketArray which is filled with the flushed messages of ChannelOutboundBuffer.

Throws:

java.lang.Exception