Package io.netty.channel.unix
Class IovArray
- java.lang.Object
-
- io.netty.channel.unix.IovArray
-
- All Implemented Interfaces:
ChannelOutboundBuffer.MessageProcessor
public final class IovArray extends java.lang.Object implements ChannelOutboundBuffer.MessageProcessor
Represent an array of struct array and so can be passed directly over via JNI without the need to do any more array copies. The buffers are written out directly into direct memory to match the struct iov. See alsoman writev
.struct iovec { void *iov_base; size_t iov_len; };
See also Efficient JNI programming IV: Wrapping native data objects.
-
-
Field Summary
Fields Modifier and Type Field Description static int
IOV_SIZE
The size of aniovec
struct in bytes.
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description boolean
add(ByteBuf buf)
Deprecated.boolean
add(ByteBuf buf, int offset, int len)
void
clear()
int
count()
Returns the number if iov entries.long
maxBytes()
Get the maximum amount of bytes that can be added to thisIovArray
.void
maxBytes(long maxBytes)
Set the maximum amount of bytes that can be added to thisIovArray
viaadd(ByteBuf, int, int)
long
memoryAddress(int offset)
Returns thememoryAddress
for the givenoffset
.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 returnsfalse
.void
release()
Release theIovArray
.long
size()
Returns the size in bytes
-
-
-
Constructor Detail
-
IovArray
public IovArray()
-
IovArray
public IovArray(ByteBuf memory)
-
-
Method Detail
-
clear
public void clear()
-
add
@Deprecated public boolean add(ByteBuf buf)
Deprecated.
-
add
public boolean add(ByteBuf buf, int offset, int len)
-
count
public int count()
Returns the number if iov entries.
-
size
public long size()
Returns the size in bytes
-
maxBytes
public void maxBytes(long maxBytes)
Set the maximum amount of bytes that can be added to thisIovArray
viaadd(ByteBuf, int, int)
This will not impact the existing state of the
IovArray
, and only applies to subsequent calls toadd(ByteBuf)
.In order to ensure some progress is made at least one
ByteBuf
will be accepted even if it's size exceeds this value.- Parameters:
maxBytes
- the maximum amount of bytes that can be added to thisIovArray
.
-
maxBytes
public long maxBytes()
Get the maximum amount of bytes that can be added to thisIovArray
.- Returns:
- the maximum amount of bytes that can be added to this
IovArray
.
-
memoryAddress
public long memoryAddress(int offset)
Returns thememoryAddress
for the givenoffset
.
-
release
public void release()
Release theIovArray
. Once release further using of it may crash the JVM!
-
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 returnsfalse
.- Specified by:
processMessage
in interfaceChannelOutboundBuffer.MessageProcessor
- Throws:
java.lang.Exception
-
-