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
All Methods Static Methods Instance Methods Concrete Methods 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 countprivate static java.net.InetSocketAddress
newAddress(byte[] addr, int addrLen, int port, int scopeId, byte[] ipv4Bytes)
(package private) NativeDatagramPacketArray.NativeDatagramPacket[]
packets()
Returns an array withcount()
NativeDatagramPacketArray.NativeDatagramPacket
s filled.(package private) void
release()
-
-
-
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
-
-
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 withcount()
NativeDatagramPacketArray.NativeDatagramPacket
s 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
-
-