Uses of Class
org.apache.cassandra.net.ShareableBytes
-
Packages that use ShareableBytes Package Description org.apache.cassandra.net org.apache.cassandra.transport -
-
Uses of ShareableBytes in org.apache.cassandra.net
Fields in org.apache.cassandra.net declared as ShareableBytes Modifier and Type Field Description ShareableBytesFrameDecoder.IntactFrame. contentsFields in org.apache.cassandra.net with type parameters of type ShareableBytes Modifier and Type Field Description protected java.util.List<ShareableBytes>AbstractMessageHandler.LargeMessage. buffersMethods in org.apache.cassandra.net that return ShareableBytes Modifier and Type Method Description ShareableBytesShareableBytes. share()Ensure this ShareableBytes will use atomic operations for updating its count from now on.ShareableBytesShareableBytes. sliceAndConsume(int length)Create a slice over the nextlengthbytes, consuming them from our buffer, and incrementing the owner countstatic ShareableBytesShareableBytes. wrap(java.nio.ByteBuffer buffer)Methods in org.apache.cassandra.net with parameters of type ShareableBytes Modifier and Type Method Description protected abstract booleanAbstractMessageHandler. processOneContainedMessage(ShareableBytes bytes, ResourceLimits.Limit endpointReserve, ResourceLimits.Limit globalReserve)protected booleanInboundMessageHandler. processOneContainedMessage(ShareableBytes bytes, ResourceLimits.Limit endpointReserve, ResourceLimits.Limit globalReserve)Constructors in org.apache.cassandra.net with parameters of type ShareableBytes Constructor Description LargeMessage(int size, H header, long expiresAtNanos, ShareableBytes bytes) -
Uses of ShareableBytes in org.apache.cassandra.transport
Methods in org.apache.cassandra.transport with parameters of type ShareableBytes Modifier and Type Method Description protected booleanCQLMessageHandler. 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.
-