io.netty.channel.unix

类 IovArray

java.lang.Object

io.netty.channel.unix.IovArray

所有已实现的接口:

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 also man writev.

 struct iovec {
   void  *iov_base;
   size_t iov_len;
 };
 

See also Efficient JNI programming IV: Wrapping native data objects.

字段概要

字段

限定符和类型	字段和说明
static int	IOV_SIZE The size of an iovec struct in bytes.

构造器概要

构造器

构造器和说明
IovArray()
IovArray(ByteBuf memory)

方法概要

限定符和类型	方法和说明
boolean	add(ByteBuf buf) 已过时。 Use add(ByteBuf, int, int)
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 this IovArray.
void	maxBytes(long maxBytes) Set the maximum amount of bytes that can be added to this IovArray via add(ByteBuf, int, int) This will not impact the existing state of the IovArray, and only applies to subsequent calls to add(ByteBuf).
long	memoryAddress(int offset) Returns the memoryAddress for the given offset.
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.
void	release() Release the IovArray.
long	size() Returns the size in bytes

从类继承的方法 java.lang.Object

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

字段详细资料

IOV_SIZE

public static final int IOV_SIZE

The size of an iovec struct in bytes. This is calculated as we have 2 entries each of the size of the address.

构造器详细资料

IovArray

public IovArray()

IovArray

public IovArray(ByteBuf memory)

方法详细资料

clear

public void clear()

add

@Deprecated
public boolean add(ByteBuf buf)

已过时。 Use add(ByteBuf, int, int)

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 this IovArray via add(ByteBuf, int, int)

This will not impact the existing state of the IovArray, and only applies to subsequent calls to add(ByteBuf).

In order to ensure some progress is made at least one ByteBuf will be accepted even if it's size exceeds this value.

参数:

maxBytes - the maximum amount of bytes that can be added to this IovArray.

maxBytes

public long maxBytes()

Get the maximum amount of bytes that can be added to this IovArray.

返回:

the maximum amount of bytes that can be added to this IovArray.

memoryAddress

public long memoryAddress(int offset)

Returns the memoryAddress for the given offset.

release

public void release()

Release the IovArray. Once release further using of it may crash the JVM!

processMessage

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

从接口复制的说明: ChannelOutboundBuffer.MessageProcessor

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

指定者:

processMessage 在接口中 ChannelOutboundBuffer.MessageProcessor

抛出:

java.lang.Exception