Package org.apache.cassandra.net

Class InboundMessageHandlers

java.lang.Object

org.apache.cassandra.net.InboundMessageHandlers

public final class InboundMessageHandlers
extends java.lang.Object

An aggregation of InboundMessageHandlers for all connections from a peer. Manages metrics and shared resource limits. Can have multiple connections of a single type open simultaneousely (legacy in particular).

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	InboundMessageHandlers.GlobalMetricCallbacks
static interface	InboundMessageHandlers.MessageConsumer

Constructor Summary

Constructors

Constructor	Description
InboundMessageHandlers(InetAddressAndPort self, InetAddressAndPort peer, int queueCapacity, long endpointReserveCapacity, org.apache.cassandra.net.InboundMessageHandlers.GlobalResourceLimits globalResourceLimits, InboundMessageHandlers.GlobalMetricCallbacks globalMetricCallbacks, InboundMessageHandlers.MessageConsumer messageConsumer)
InboundMessageHandlers(InetAddressAndPort self, InetAddressAndPort peer, int queueCapacity, long endpointReserveCapacity, org.apache.cassandra.net.InboundMessageHandlers.GlobalResourceLimits globalResourceLimits, InboundMessageHandlers.GlobalMetricCallbacks globalMetricCallbacks, InboundMessageHandlers.MessageConsumer messageConsumer, org.apache.cassandra.net.InboundMessageHandlers.HandlerProvider handlerProvider)

Method Summary

Modifier and Type	Method	Description
long	corruptFramesRecovered()
long	corruptFramesUnrecovered()
int	count()
long	errorBytes()
long	errorCount()
long	expiredBytes()
long	expiredCount()
long	processedBytes()
long	processedCount()
long	receivedBytes()
long	receivedCount()
long	scheduledBytes()
long	scheduledCount()
long	throttledCount()
long	throttledNanos()
long	usingCapacity()
long	usingEndpointReserveCapacity()

Methods inherited from class java.lang.Object

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

Constructor Detail

InboundMessageHandlers

public InboundMessageHandlers(InetAddressAndPort self,
                              InetAddressAndPort peer,
                              int queueCapacity,
                              long endpointReserveCapacity,
                              org.apache.cassandra.net.InboundMessageHandlers.GlobalResourceLimits globalResourceLimits,
                              InboundMessageHandlers.GlobalMetricCallbacks globalMetricCallbacks,
                              InboundMessageHandlers.MessageConsumer messageConsumer)

InboundMessageHandlers

public InboundMessageHandlers(InetAddressAndPort self,
                              InetAddressAndPort peer,
                              int queueCapacity,
                              long endpointReserveCapacity,
                              org.apache.cassandra.net.InboundMessageHandlers.GlobalResourceLimits globalResourceLimits,
                              InboundMessageHandlers.GlobalMetricCallbacks globalMetricCallbacks,
                              InboundMessageHandlers.MessageConsumer messageConsumer,
                              org.apache.cassandra.net.InboundMessageHandlers.HandlerProvider handlerProvider)

Method Detail

count

public int count()

receivedCount

public long receivedCount()

receivedBytes

public long receivedBytes()

throttledCount

public long throttledCount()

throttledNanos

public long throttledNanos()

usingCapacity

public long usingCapacity()

usingEndpointReserveCapacity

public long usingEndpointReserveCapacity()

corruptFramesRecovered

public long corruptFramesRecovered()

corruptFramesUnrecovered

public long corruptFramesUnrecovered()

errorCount

public long errorCount()

errorBytes

public long errorBytes()

expiredCount

public long expiredCount()

expiredBytes

public long expiredBytes()

processedCount

public long processedCount()

processedBytes

public long processedBytes()

scheduledCount

public long scheduledCount()

scheduledBytes

public long scheduledBytes()