Package org.apache.cassandra.net

Class AbstractMessageHandler.LargeMessage<H>

java.lang.Object

org.apache.cassandra.net.AbstractMessageHandler.LargeMessage<H>

Enclosing class:

AbstractMessageHandler

protected abstract class AbstractMessageHandler.LargeMessage<H>
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected final List<ShareableBytes>	buffers
protected final long	expiresAtNanos
protected final H	header
protected boolean	isCorrupt
protected boolean	isExpired
protected int	received
protected final int	size

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	LargeMessage(int size, H header, long expiresAtNanos, boolean isExpired)
protected	LargeMessage(int size, H header, long expiresAtNanos, ShareableBytes bytes)

Method Summary

Modifier and Type	Method	Description
protected abstract void	abort()
protected abstract void	onComplete()
protected void	onCorruptFrame()
protected void	onIntactFrame(FrameDecoder.IntactFrame frame)
protected void	releaseBuffers()
protected void	releaseBuffersAndCapacity()
boolean	supply(FrameDecoder.Frame frame)	Return true if this was the last frame of the large message.

Methods inherited from class java.lang.Object

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

Field Details

size

protected final int size

header

protected final H header

buffers

protected final List<ShareableBytes> buffers

received

protected int received

expiresAtNanos

protected final long expiresAtNanos

isExpired

protected boolean isExpired

isCorrupt

protected boolean isCorrupt

Constructor Details

LargeMessage

protected LargeMessage(int size,
 H header,
 long expiresAtNanos,
 boolean isExpired)

LargeMessage

protected LargeMessage(int size,
 H header,
 long expiresAtNanos,
 ShareableBytes bytes)

Method Details

supply

public boolean supply(FrameDecoder.Frame frame)

Return true if this was the last frame of the large message.

onIntactFrame

protected void onIntactFrame(FrameDecoder.IntactFrame frame)

onCorruptFrame

protected void onCorruptFrame()

onComplete

protected abstract void onComplete()

abort

protected abstract void abort()

releaseBuffers

protected void releaseBuffers()

releaseBuffersAndCapacity

protected void releaseBuffersAndCapacity()