Package org.apache.cassandra.net

Class InboundMessageHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

org.apache.cassandra.net.AbstractMessageHandler

org.apache.cassandra.net.InboundMessageHandler

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler, FrameDecoder.FrameProcessor

public class InboundMessageHandler
extends AbstractMessageHandler

Implementation of AbstractMessageHandler for processing internode messages from peers. # Small vs large messages Small messages are deserialized in place, and then handed off to an appropriate thread pool for processing. Large messages accumulate frames until completion of a message, then hand off the untouched frames to the correct thread pool for the verb to be deserialized there and immediately processed. # Flow control (backpressure) To prevent nodes from overwhelming and bringing each other to the knees with more inbound messages that can be processed in a timely manner, InboundMessageHandler implements a strict flow control policy. The size of the incoming message is dependent on the messaging version of the specific peer connection. See Message.Serializer#inferMessageSize(ByteBuffer, int, int, int). By default, every connection has 4MiB of exlusive permits available before needing to access the per-endpoint and global reserves. Permits are released after the verb handler has been invoked on the Stage for the Verb of the message.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.cassandra.net.AbstractMessageHandler

AbstractMessageHandler.OnHandlerClosed, AbstractMessageHandler.WaitQueue

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

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields inherited from class org.apache.cassandra.net.AbstractMessageHandler

channel, corruptFramesRecovered, corruptFramesUnrecovered, decoder, endpointReserveCapacity, endpointWaitQueue, globalReserveCapacity, globalWaitQueue, largeMessage, largeThreshold, onClosed, queueCapacity, receivedBytes, receivedCount, throttledCount, throttledNanos

Method Summary

Modifier and Type	Method	Description
void	exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
protected void	fatalExceptionCaught(Throwable cause)
protected String	id()
protected void	processCorruptFrame(FrameDecoder.CorruptFrame frame)
protected boolean	processFirstFrameOfLargeMessage(FrameDecoder.IntactFrame frame, ResourceLimits.Limit endpointReserve, ResourceLimits.Limit globalReserve)
protected boolean	processOneContainedMessage(ShareableBytes bytes, ResourceLimits.Limit endpointReserve, ResourceLimits.Limit globalReserve)
String	toString()

Methods inherited from class org.apache.cassandra.net.AbstractMessageHandler

acquireCapacity, acquireCapacity, channelInactive, channelRead, handlerAdded, process, processSubsequentFrameOfLargeMessage, processUpToOneMessage, releaseCapacity, releaseProcessedCapacity

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerRemoved, isSharable

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.channel.ChannelHandler

handlerRemoved

Method Details

processOneContainedMessage

protected boolean processOneContainedMessage(ShareableBytes bytes,
 ResourceLimits.Limit endpointReserve,
 ResourceLimits.Limit globalReserve)
                                      throws IOException

Specified by:

processOneContainedMessage in class AbstractMessageHandler

Throws:

IOException

processFirstFrameOfLargeMessage

protected boolean processFirstFrameOfLargeMessage(FrameDecoder.IntactFrame frame,
 ResourceLimits.Limit endpointReserve,
 ResourceLimits.Limit globalReserve)
                                           throws IOException

Specified by:

processFirstFrameOfLargeMessage in class AbstractMessageHandler

Throws:

IOException

processCorruptFrame

protected void processCorruptFrame(FrameDecoder.CorruptFrame frame)
                            throws Crc.InvalidCrc

Specified by:

processCorruptFrame in class AbstractMessageHandler

Throws:

Crc.InvalidCrc

id

protected String id()

Specified by:

id in class AbstractMessageHandler

toString

public String toString()

Overrides:

toString in class Object

exceptionCaught

public void exceptionCaught(io.netty.channel.ChannelHandlerContext ctx,
 Throwable cause)

Specified by:

exceptionCaught in interface io.netty.channel.ChannelHandler

Specified by:

exceptionCaught in interface io.netty.channel.ChannelInboundHandler

Overrides:

exceptionCaught in class io.netty.channel.ChannelInboundHandlerAdapter

fatalExceptionCaught

protected void fatalExceptionCaught(Throwable cause)

Specified by:

fatalExceptionCaught in class AbstractMessageHandler