Class EpollRecvByteAllocatorHandle

java.lang.Object

io.netty.channel.RecvByteBufAllocator.DelegatingHandle

io.netty.channel.epoll.EpollRecvByteAllocatorHandle

All Implemented Interfaces:

RecvByteBufAllocator.ExtendedHandle, RecvByteBufAllocator.Handle

Direct Known Subclasses:

EpollRecvByteAllocatorStreamingHandle

class EpollRecvByteAllocatorHandle
extends RecvByteBufAllocator.DelegatingHandle
implements RecvByteBufAllocator.ExtendedHandle

Field Summary

Fields

Modifier and Type	Field	Description
private final UncheckedBooleanSupplier	defaultMaybeMoreDataSupplier
private boolean	isEdgeTriggered
private final PreferredDirectByteBufAllocator	preferredDirectByteBufAllocator
private boolean	receivedRdHup

Constructor Summary

Constructors

Constructor	Description
EpollRecvByteAllocatorHandle(RecvByteBufAllocator.ExtendedHandle handle)

Method Summary

Modifier and Type	Method	Description
final ByteBuf	allocate(ByteBufAllocator alloc)	Creates a new receive buffer whose capacity is probably large enough to read all inbound data and small enough not to waste its space.
final boolean	continueReading()	Determine if the current read loop should continue.
final boolean	continueReading(UncheckedBooleanSupplier maybeMoreDataSupplier)	Same as RecvByteBufAllocator.Handle.continueReading() except "more data" is determined by the supplier parameter.
(package private) final void	edgeTriggered(boolean edgeTriggered)
(package private) final boolean	isEdgeTriggered()
(package private) final boolean	isReceivedRdHup()
(package private) boolean	maybeMoreDataToRead()
(package private) final void	receivedRdHup()

Methods inherited from class RecvByteBufAllocator.DelegatingHandle

attemptedBytesRead, attemptedBytesRead, delegate, guess, incMessagesRead, lastBytesRead, lastBytesRead, readComplete, reset

Methods inherited from class Object

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

Methods inherited from interface RecvByteBufAllocator.Handle

attemptedBytesRead, attemptedBytesRead, guess, incMessagesRead, lastBytesRead, lastBytesRead, readComplete, reset

Field Details

preferredDirectByteBufAllocator

private final PreferredDirectByteBufAllocator preferredDirectByteBufAllocator

defaultMaybeMoreDataSupplier

private final UncheckedBooleanSupplier defaultMaybeMoreDataSupplier

isEdgeTriggered

private boolean isEdgeTriggered

receivedRdHup

private boolean receivedRdHup

Constructor Details

EpollRecvByteAllocatorHandle

EpollRecvByteAllocatorHandle(RecvByteBufAllocator.ExtendedHandle handle)

Method Details

receivedRdHup

final void receivedRdHup()

isReceivedRdHup

final boolean isReceivedRdHup()

maybeMoreDataToRead

boolean maybeMoreDataToRead()

edgeTriggered

final void edgeTriggered(boolean edgeTriggered)

isEdgeTriggered

final boolean isEdgeTriggered()

allocate

public final ByteBuf allocate(ByteBufAllocator alloc)

Description copied from interface: RecvByteBufAllocator.Handle

Creates a new receive buffer whose capacity is probably large enough to read all inbound data and small enough not to waste its space.

Specified by:

allocate in interface RecvByteBufAllocator.Handle

Overrides:

allocate in class RecvByteBufAllocator.DelegatingHandle

continueReading

public final boolean continueReading(UncheckedBooleanSupplier maybeMoreDataSupplier)

Description copied from interface: RecvByteBufAllocator.ExtendedHandle

Same as RecvByteBufAllocator.Handle.continueReading() except "more data" is determined by the supplier parameter.

Specified by:

continueReading in interface RecvByteBufAllocator.ExtendedHandle

Parameters:

maybeMoreDataSupplier - A supplier that determines if there maybe more data to read.

continueReading

public final boolean continueReading()

Description copied from interface: RecvByteBufAllocator.Handle

Determine if the current read loop should continue.

Specified by:

continueReading in interface RecvByteBufAllocator.Handle

Overrides:

continueReading in class RecvByteBufAllocator.DelegatingHandle

Returns:

true if the read loop should continue reading. false if the read loop is complete.