Class FixedRecvByteBufAllocator

java.lang.Object

io.netty.channel.DefaultMaxMessagesRecvByteBufAllocator

io.netty.channel.FixedRecvByteBufAllocator

All Implemented Interfaces:

MaxMessagesRecvByteBufAllocator, RecvByteBufAllocator

public class FixedRecvByteBufAllocator
extends DefaultMaxMessagesRecvByteBufAllocator

The RecvByteBufAllocator that always yields the same buffer size prediction. This predictor ignores the feed back from the I/O thread.

Nested Class Summary

Nested classes/interfaces inherited from class DefaultMaxMessagesRecvByteBufAllocator

DefaultMaxMessagesRecvByteBufAllocator.MaxMessageHandle

Modifier and Type	Class	Description
class	DefaultMaxMessagesRecvByteBufAllocator.MaxMessageHandle	Focuses on enforcing the maximum messages per read condition for DefaultMaxMessagesRecvByteBufAllocator.MaxMessageHandle.continueReading().

Nested classes/interfaces inherited from interface RecvByteBufAllocator

RecvByteBufAllocator.DelegatingHandle, RecvByteBufAllocator.ExtendedHandle, RecvByteBufAllocator.Handle

Modifier and Type	Interface	Description
static class	RecvByteBufAllocator.DelegatingHandle	A RecvByteBufAllocator.Handle which delegates all call to some other RecvByteBufAllocator.Handle.
static interface	RecvByteBufAllocator.ExtendedHandle
static interface	RecvByteBufAllocator.Handle	Deprecated. Use RecvByteBufAllocator.ExtendedHandle.

Constructor Summary

Constructors

Constructor	Description
FixedRecvByteBufAllocator(int bufferSize)	Creates a new predictor that always returns the same prediction of the specified buffer size.

Method Summary

Modifier and Type	Method	Description
RecvByteBufAllocator.Handle	newHandle()	Creates a new handle.
FixedRecvByteBufAllocator	respectMaybeMoreData(boolean respectMaybeMoreData)	Determine if future instances of RecvByteBufAllocator.newHandle() will stop reading if we think there is no more data.

Methods inherited from class DefaultMaxMessagesRecvByteBufAllocator

maxMessagesPerRead, maxMessagesPerRead, respectMaybeMoreData

Modifier and Type	Method	Description
int	maxMessagesPerRead()	Returns the maximum number of messages to read per read loop. a channelRead() event.
MaxMessagesRecvByteBufAllocator	maxMessagesPerRead(int maxMessagesPerRead)	Sets the maximum number of messages to read per read loop.
final boolean	respectMaybeMoreData()	Get if future instances of RecvByteBufAllocator.newHandle() will stop reading if we think there is no more data.

Methods inherited from class Object

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

Constructor Details

FixedRecvByteBufAllocator

public FixedRecvByteBufAllocator(int bufferSize)

Creates a new predictor that always returns the same prediction of the specified buffer size.

Method Details

newHandle

public RecvByteBufAllocator.Handle newHandle()

Description copied from interface: RecvByteBufAllocator

Creates a new handle. The handle provides the actual operations and keeps the internal information which is required for predicting an optimal buffer capacity.

respectMaybeMoreData

public FixedRecvByteBufAllocator respectMaybeMoreData(boolean respectMaybeMoreData)

Description copied from class: DefaultMaxMessagesRecvByteBufAllocator

Determine if future instances of RecvByteBufAllocator.newHandle() will stop reading if we think there is no more data.

Overrides:

respectMaybeMoreData in class DefaultMaxMessagesRecvByteBufAllocator

Parameters:

respectMaybeMoreData -

• true to stop reading if we think there is no more data. This may save a system call to read from the socket, but if data has arrived in a racy fashion we may give up our DefaultMaxMessagesRecvByteBufAllocator.maxMessagesPerRead() quantum and have to wait for the selector to notify us of more data.
• false to keep reading (up to DefaultMaxMessagesRecvByteBufAllocator.maxMessagesPerRead()) or until there is no data when we attempt to read.

Returns:

this.