final class NativeDatagramPacketArray extends java.lang.Object implements ChannelOutboundBuffer.MessageProcessor
Modifier and Type | Class and Description |
---|---|
(package private) static class |
NativeDatagramPacketArray.NativeDatagramPacket
Used to pass needed data to JNI.
|
Modifier and Type | Field and Description |
---|---|
private static FastThreadLocal<NativeDatagramPacketArray> |
ARRAY |
private int |
count |
private NativeDatagramPacketArray.NativeDatagramPacket[] |
packets |
Modifier | Constructor and Description |
---|---|
private |
NativeDatagramPacketArray() |
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.NativeDatagramPacket s 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 . |
private static final FastThreadLocal<NativeDatagramPacketArray> ARRAY
private final NativeDatagramPacketArray.NativeDatagramPacket[] packets
private int count
boolean add(DatagramPacket packet)
public boolean processMessage(java.lang.Object msg) throws java.lang.Exception
ChannelOutboundBuffer.MessageProcessor
false
.processMessage
in interface ChannelOutboundBuffer.MessageProcessor
java.lang.Exception
int count()
NativeDatagramPacketArray.NativeDatagramPacket[] packets()
count()
NativeDatagramPacketArray.NativeDatagramPacket
s filled.static NativeDatagramPacketArray getInstance(ChannelOutboundBuffer buffer) throws java.lang.Exception
NativeDatagramPacketArray
which is filled with the flushed messages of
ChannelOutboundBuffer
.java.lang.Exception