public final class IovArray extends Object implements ChannelOutboundBuffer.MessageProcessor
man writev
.
struct iovec { void *iov_base; size_t iov_len; };See also Efficient JNI programming IV: Wrapping native data objects.
Constructor and Description |
---|
IovArray() |
Modifier and Type | Method and Description |
---|---|
boolean |
add(ByteBuf buf)
Try to add the given
ByteBuf . |
boolean |
add(CompositeByteBuf buf)
Try to add the given
CompositeByteBuf . |
void |
clear() |
int |
count()
Returns the number if iov entries.
|
long |
memoryAddress(int offset)
Returns the
memoryAddress for the given offset . |
boolean |
processMessage(Object msg)
Will be called for each flushed message until it either there are no more flushed messages or this
method returns
false . |
long |
processWritten(int index,
long written)
Process the written iov entries.
|
void |
release()
Release the
IovArray . |
long |
size()
Returns the size in bytes
|
public void clear()
public boolean add(ByteBuf buf)
public boolean add(CompositeByteBuf buf)
public long processWritten(int index, long written)
written
value. Otherwise it returns -1
.public int count()
public long size()
public long memoryAddress(int offset)
memoryAddress
for the given offset
.public void release()
IovArray
. Once release further using of it may crash the JVM!public boolean processMessage(Object msg) throws Exception
ChannelOutboundBuffer.MessageProcessor
false
.processMessage
in interface ChannelOutboundBuffer.MessageProcessor
Exception
Copyright © 2008–2017 The Netty Project. All rights reserved.