Package org.apache.cassandra.net

Class BufferPoolAllocator

  • All Implemented Interfaces:
    io.netty.buffer.ByteBufAllocator
    Direct Known Subclasses:
    GlobalBufferPoolAllocator
    public abstract class BufferPoolAllocator
extends io.netty.buffer.AbstractByteBufAllocator
    A trivial wrapper around BufferPool for integrating with Netty, but retaining ownership of pooling behaviour that is integrated into Cassandra's other pooling.

    • Nested Class Summary

      Nested Classes 
      Modifier and Type Class Description
      static class  BufferPoolAllocator.Wrapped
      A simple extension to UnpooledUnsafeDirectByteBuf that returns buffers to BufferPool on deallocate, and permits extracting the buffer from it to take ownership and use directly.

    • Field Summary

      • Fields inherited from interface io.netty.buffer.ByteBufAllocator

        DEFAULT

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      boolean isDirectBufferPooled()  
      protected io.netty.buffer.ByteBuf newDirectBuffer​(int minCapacity, int maxCapacity)  
      protected io.netty.buffer.ByteBuf newHeapBuffer​(int minCapacity, int maxCapacity)
      shouldn't be invoked
      long usedSizeInBytes()  

      • Methods inherited from class io.netty.buffer.AbstractByteBufAllocator

        buffer, buffer, buffer, calculateNewCapacity, compositeBuffer, compositeBuffer, compositeDirectBuffer, compositeDirectBuffer, compositeHeapBuffer, compositeHeapBuffer, directBuffer, directBuffer, directBuffer, heapBuffer, heapBuffer, heapBuffer, ioBuffer, ioBuffer, ioBuffer, toLeakAwareBuffer, toLeakAwareBuffer, toString

      • Methods inherited from class java.lang.Object

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

    • Method Detail

      • isDirectBufferPooled

        public boolean isDirectBufferPooled()

      • newHeapBuffer

        protected io.netty.buffer.ByteBuf newHeapBuffer​(int minCapacity,
                                                int maxCapacity)
        shouldn't be invoked
        Specified by:
        newHeapBuffer in class io.netty.buffer.AbstractByteBufAllocator

      • newDirectBuffer

        protected io.netty.buffer.ByteBuf newDirectBuffer​(int minCapacity,
                                                  int maxCapacity)
        Specified by:
        newDirectBuffer in class io.netty.buffer.AbstractByteBufAllocator

      • usedSizeInBytes

        public long usedSizeInBytes()