Uses of Interface
org.apache.cassandra.net.ResourceLimits.Limit

Packages that use ResourceLimits.Limit

Package	Description
org.apache.cassandra.net
org.apache.cassandra.transport

Uses of ResourceLimits.Limit in org.apache.cassandra.net

Classes in org.apache.cassandra.net that implement ResourceLimits.Limit

Modifier and Type	Class	Description
static class	ResourceLimits.Basic	A cheaper, thread-unsafe permit container to be used for unshared limits.
static class	ResourceLimits.Concurrent	A thread-safe permit container.

Fields in org.apache.cassandra.net declared as ResourceLimits.Limit

Modifier and Type	Field	Description
ResourceLimits.Limit	OutboundConnectionSettings.applicationSendQueueReserveGlobalCapacityInBytes
protected ResourceLimits.Limit	AbstractMessageHandler.endpointReserveCapacity
protected ResourceLimits.Limit	AbstractMessageHandler.globalReserveCapacity

Methods in org.apache.cassandra.net that return ResourceLimits.Limit

Modifier and Type	Method	Description
ResourceLimits.Limit	OutboundConnectionSettings.applicationSendQueueReserveGlobalCapacityInBytes()
ResourceLimits.Limit	ResourceLimits.EndpointAndGlobal.endpoint()
ResourceLimits.Limit	ResourceLimits.EndpointAndGlobal.global()

Methods in org.apache.cassandra.net with parameters of type ResourceLimits.Limit

Modifier and Type	Method	Description
protected ResourceLimits.Outcome	AbstractMessageHandler.acquireCapacity(ResourceLimits.Limit endpointReserve, ResourceLimits.Limit globalReserve, int bytes)
protected boolean	AbstractMessageHandler.acquireCapacity(ResourceLimits.Limit endpointReserve, ResourceLimits.Limit globalReserve, int bytes, long currentTimeNanos, long expiresAtNanos)	Try to acquire permits for the inbound message.
static AbstractMessageHandler.WaitQueue	AbstractMessageHandler.WaitQueue.endpoint(ResourceLimits.Limit endpointReserveCapacity)
static AbstractMessageHandler.WaitQueue	AbstractMessageHandler.WaitQueue.global(ResourceLimits.Limit globalReserveCapacity)
protected abstract boolean	AbstractMessageHandler.processFirstFrameOfLargeMessage(FrameDecoder.IntactFrame frame, ResourceLimits.Limit endpointReserve, ResourceLimits.Limit globalReserve)
protected boolean	InboundMessageHandler.processFirstFrameOfLargeMessage(FrameDecoder.IntactFrame frame, ResourceLimits.Limit endpointReserve, ResourceLimits.Limit globalReserve)
protected abstract boolean	AbstractMessageHandler.processOneContainedMessage(ShareableBytes bytes, ResourceLimits.Limit endpointReserve, ResourceLimits.Limit globalReserve)
protected boolean	InboundMessageHandler.processOneContainedMessage(ShareableBytes bytes, ResourceLimits.Limit endpointReserve, ResourceLimits.Limit globalReserve)
protected boolean	AbstractMessageHandler.processUpToOneMessage(ResourceLimits.Limit endpointReserve, ResourceLimits.Limit globalReserve)
OutboundConnectionSettings	OutboundConnectionSettings.withApplicationReserveSendQueueCapacityInBytes(java.lang.Integer applicationReserveSendQueueEndpointCapacityInBytes, ResourceLimits.Limit applicationReserveSendQueueGlobalCapacityInBytes)

Constructors in org.apache.cassandra.net with parameters of type ResourceLimits.Limit

Constructor	Description
AbstractMessageHandler(FrameDecoder decoder, io.netty.channel.Channel channel, int largeThreshold, long queueCapacity, ResourceLimits.Limit endpointReserveCapacity, ResourceLimits.Limit globalReserveCapacity, AbstractMessageHandler.WaitQueue endpointWaitQueue, AbstractMessageHandler.WaitQueue globalWaitQueue, AbstractMessageHandler.OnHandlerClosed onClosed)
EndpointAndGlobal(ResourceLimits.Limit endpoint, ResourceLimits.Limit global)

Uses of ResourceLimits.Limit in org.apache.cassandra.transport

Methods in org.apache.cassandra.transport with parameters of type ResourceLimits.Limit

Modifier and Type	Method	Description
protected boolean	CQLMessageHandler.processFirstFrameOfLargeMessage(FrameDecoder.IntactFrame frame, ResourceLimits.Limit endpointReserve, ResourceLimits.Limit globalReserve)
protected boolean	CQLMessageHandler.processOneContainedMessage(ShareableBytes bytes, ResourceLimits.Limit endpointReserve, ResourceLimits.Limit globalReserve)	Checks limits on bytes in flight and the request rate limiter (if enabled), then takes one of three actions: 1.) If no limits are breached, process the request.