Modifier and Type	Class and Description
private static class	ByteBufferCollector.BufferCache Thread-local cache of `ByteBuffer` array, and processing meta-data.

Modifier and Type	Field and Description
private ByteBufferCollector.BufferCache	cache
private long	maxBytes
private int	maxCount
private static final FastThreadLocal<ByteBufferCollector.BufferCache>	NIO_BUFFERS

Access	Constructor and Description
pack-priv	ByteBufferCollector()

Method Summary

Modifier and Type	Method and Description
private static ByteBuffer[]	expandNioBufferArray(ByteBuffer[] array, int neededSpace, int size)
pack-priv int	nioBufferCount() Returns the number of `ByteBuffer` that can be written out of the `ByteBuffer` array that was obtained via `test(Object)`.
pack-priv ByteBuffer[]	nioBuffers()
pack-priv long	nioBufferSize() Returns the number of bytes that can be written out of the `ByteBuffer` array that was obtained via `test(Object)`.
pack-priv void	prepare(int The maximum amount of buffers that will be added to the return value. maxCount, long A hint toward the maximum number of bytes to include as part of the return value. Note that this value maybe exceeded because we make a best effort to include at least 1 `ByteBuffer` in the return value to ensure write progress is made. maxBytes) Returns an array of direct NIO buffers if the currently pending messages are made of `Buffer` only.
pack-priv void	reset()
public boolean	test(Object the input argument msg) Implements java.util.function.Predicate.test. Evaluates this predicate on the given argument.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

cache	back to summary
private ByteBufferCollector.BufferCache cache

maxBytes	back to summary
private long maxBytes

maxCount	back to summary
private int maxCount

NIO_BUFFERS	back to summary
private static final FastThreadLocal<ByteBufferCollector.BufferCache> NIO_BUFFERS

Constructor Detail

ByteBufferCollector	back to summary
pack-priv ByteBufferCollector()

Method Detail

expandNioBufferArray	back to summary
private static ByteBuffer[] expandNioBufferArray(ByteBuffer[] array, int neededSpace, int size)

nioBufferCount	back to summary
pack-priv int nioBufferCount() Returns the number of `ByteBuffer` that can be written out of the `ByteBuffer` array that was obtained via `test(Object)`. This method MUST be called after `test(Object)` was called.

nioBuffers	back to summary
pack-priv ByteBuffer[] nioBuffers()

nioBufferSize	back to summary
pack-priv long nioBufferSize() Returns the number of bytes that can be written out of the `ByteBuffer` array that was obtained via `test(Object)`. This method MUST be called after `test(Object)` was called.

prepare back to summary

prepare	back to summary
pack-priv void prepare(int maxCount, long maxBytes) Returns an array of direct NIO buffers if the currently pending messages are made of `Buffer` only. `nioBufferCount()` and `nioBufferSize()` will return the number of NIO buffers in the returned array and the total number of readable bytes of the NIO buffers respectively. Parameters maxCount:int The maximum amount of buffers that will be added to the return value. maxBytes:long A hint toward the maximum number of bytes to include as part of the return value. Note that this value maybe exceeded because we make a best effort to include at least 1 `ByteBuffer` in the return value to ensure write progress is made.

pack-priv void prepare(int maxCount, long maxBytes)

Returns an array of direct NIO buffers if the currently pending messages are made of Buffer only. nioBufferCount() and nioBufferSize() will return the number of NIO buffers in the returned array and the total number of readable bytes of the NIO buffers respectively.

Parameters

maxCount:int: The maximum amount of buffers that will be added to the return value.
maxBytes:long: A hint toward the maximum number of bytes to include as part of the return value. Note that this value maybe exceeded because we make a best effort to include at least 1 ByteBuffer in the return value to ensure write progress is made.

reset	back to summary
pack-priv void reset()

test back to summary

test	back to summary
public boolean test(Object msg) throws RuntimeException Implements java.util.function.Predicate.test. Doc from java.util.function.Predicate.test. Evaluates this predicate on the given argument. Parameters msg:Object the input argument Returns:boolean `true` if the input argument matches the predicate, otherwise `false` Annotations @Override

public boolean test(Object msg) throws RuntimeException

Implements java.util.function.Predicate.test.

Doc from java.util.function.Predicate.test.

Evaluates this predicate on the given argument.

Parameters

msg:Object: the input argument

Returns:boolean

true if the input argument matches the predicate, otherwise false

Annotations

@Override

io.netty5.channel.socket.nio back to summary

private final Class ByteBufferCollector.BufferCache

Class Inheritance

extends Object

java.lang.Object
io.netty5.channel.socket.nio.ByteBufferCollector.BufferCache

Thread-local cache of ByteBuffer array, and processing meta-data.

Field Summary

Modifier and Type	Field and Description
pack-priv int	bufferCount
pack-priv ByteBuffer[]	buffers
pack-priv long	totalSize

Constructor Summary

Access	Constructor and Description
private	BufferCache()

Method Summary

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

bufferCount	back to summary
pack-priv int bufferCount

buffers	back to summary
pack-priv ByteBuffer[] buffers

totalSize	back to summary
pack-priv long totalSize

Constructor Detail

BufferCache	back to summary
private BufferCache()

pack-priv final Class ByteBufferCollector

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private final Class ByteBufferCollector.BufferCache

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail