io.netty.channel

Class DefaultMaxMessagesRecvByteBufAllocator

java.lang.Object

io.netty.channel.DefaultMaxMessagesRecvByteBufAllocator

All Implemented Interfaces:

MaxMessagesRecvByteBufAllocator, RecvByteBufAllocator

Direct Known Subclasses:

AdaptiveRecvByteBufAllocator, FixedRecvByteBufAllocator

public abstract class DefaultMaxMessagesRecvByteBufAllocator
extends Object
implements MaxMessagesRecvByteBufAllocator

Default implementation of MaxMessagesRecvByteBufAllocator which respects ChannelConfig.isAutoRead() and also prevents overflow.

Nested Class Summary

Nested Classes

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

Nested classes/interfaces inherited from interface io.netty.channel.RecvByteBufAllocator

RecvByteBufAllocator.DelegatingHandle, RecvByteBufAllocator.ExtendedHandle, RecvByteBufAllocator.Handle

Constructor Summary

Constructors

Constructor and Description
DefaultMaxMessagesRecvByteBufAllocator()
DefaultMaxMessagesRecvByteBufAllocator(int maxMessagesPerRead)

Method Summary

Modifier and Type	Method and Description
int	maxMessagesPerRead() Returns the maximum number of messages to read per read loop.
MaxMessagesRecvByteBufAllocator	maxMessagesPerRead(int maxMessagesPerRead) Sets the maximum number of messages to read per read loop.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.channel.RecvByteBufAllocator

newHandle

Constructor Detail

DefaultMaxMessagesRecvByteBufAllocator

public DefaultMaxMessagesRecvByteBufAllocator()

DefaultMaxMessagesRecvByteBufAllocator

public DefaultMaxMessagesRecvByteBufAllocator(int maxMessagesPerRead)

Method Detail

maxMessagesPerRead

public int maxMessagesPerRead()

Description copied from interface: MaxMessagesRecvByteBufAllocator

Returns the maximum number of messages to read per read loop. a channelRead() event. If this value is greater than 1, an event loop might attempt to read multiple times to procure multiple messages.

Specified by:

maxMessagesPerRead in interface MaxMessagesRecvByteBufAllocator

maxMessagesPerRead

public MaxMessagesRecvByteBufAllocator maxMessagesPerRead(int maxMessagesPerRead)

Description copied from interface: MaxMessagesRecvByteBufAllocator

Sets the maximum number of messages to read per read loop. If this value is greater than 1, an event loop might attempt to read multiple times to procure multiple messages.

Specified by:

maxMessagesPerRead in interface MaxMessagesRecvByteBufAllocator