Package | Description |
---|---|
org.apache.cassandra.net | |
org.apache.cassandra.transport |
Modifier and Type | Field and Description |
---|---|
ShareableBytes |
FrameDecoder.IntactFrame.contents |
Modifier and Type | Field and Description |
---|---|
protected java.util.List<ShareableBytes> |
AbstractMessageHandler.LargeMessage.buffers |
Modifier and Type | Method and Description |
---|---|
ShareableBytes |
ShareableBytes.share()
Ensure this ShareableBytes will use atomic operations for updating its count from now on.
|
ShareableBytes |
ShareableBytes.sliceAndConsume(int length)
Create a slice over the next
length bytes, consuming them from our buffer, and incrementing the owner count |
static ShareableBytes |
ShareableBytes.wrap(java.nio.ByteBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
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) |
Constructor and Description |
---|
LargeMessage(int size,
H header,
long expiresAtNanos,
ShareableBytes bytes) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
CQLMessageHandler.processOneContainedMessage(ShareableBytes bytes,
ResourceLimits.Limit endpointReserve,
ResourceLimits.Limit globalReserve) |
Copyright © 2009-2022 The Apache Software Foundation