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)
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)
-