Package org.apache.cassandra.net

Class BufferPoolAllocator.Wrapped

java.lang.Object
io.netty.buffer.ByteBuf
io.netty.buffer.AbstractByteBuf
io.netty.buffer.AbstractReferenceCountedByteBuf
io.netty.buffer.UnpooledDirectByteBuf
io.netty.buffer.UnpooledUnsafeDirectByteBuf
org.apache.cassandra.net.BufferPoolAllocator.Wrapped
All Implemented Interfaces:
io.netty.buffer.ByteBufConvertible, io.netty.util.ReferenceCounted, Comparable<io.netty.buffer.ByteBuf>
Enclosing class:
BufferPoolAllocator
public static class BufferPoolAllocator.Wrapped extends io.netty.buffer.UnpooledUnsafeDirectByteBuf
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.

  • Method Summary

    Modifier and Type
    Method
    Description
    ByteBuffer
    adopt()
     
    protected ByteBuffer
    allocateDirect(int initialCapacity)
     
    io.netty.buffer.ByteBuf
    capacity(int newCapacity)
     
    void
    deallocate()
     
    protected void
    freeDirect(ByteBuffer buffer)
     

    Methods inherited from class io.netty.buffer.UnpooledUnsafeDirectByteBuf

    _getByte, _getInt, _getIntLE, _getLong, _getLongLE, _getShort, _getShortLE, _getUnsignedMedium, _getUnsignedMediumLE, _setByte, _setInt, _setIntLE, _setLong, _setLongLE, _setMedium, _setMediumLE, _setShort, _setShortLE, copy, getByte, getBytes, getInt, getLong, getShort, getUnsignedMedium, hasMemoryAddress, memoryAddress, newSwappedByteBuf, setByte, setBytes, setBytes, setBytes, setBytes, setInt, setLong, setMedium, setShort, setZero, writeZero

    Methods inherited from class io.netty.buffer.UnpooledDirectByteBuf

    alloc, array, arrayOffset, capacity, getBytes, getBytes, getBytes, getBytes, getBytes, hasArray, internalNioBuffer, isContiguous, isDirect, nioBuffer, nioBufferCount, nioBuffers, order, readBytes, readBytes, readBytes, readBytes, readBytes, setBytes, setBytes, unwrap

    Methods inherited from class io.netty.buffer.AbstractReferenceCountedByteBuf

    refCnt, release, release, resetRefCnt, retain, retain, setRefCnt, touch, touch

    Methods inherited from class io.netty.buffer.AbstractByteBuf

    adjustMarkers, asReadOnly, bytesBefore, bytesBefore, bytesBefore, checkDstIndex, checkDstIndex, checkIndex, checkIndex, checkNewCapacity, checkReadableBytes, checkSrcIndex, clear, compareTo, copy, discardReadBytes, discardSomeReadBytes, duplicate, ensureAccessible, ensureWritable, ensureWritable, equals, forEachByte, forEachByte, forEachByteDesc, forEachByteDesc, getBoolean, getBytes, getBytes, getBytes, getChar, getCharSequence, getDouble, getFloat, getIntLE, getLongLE, getMedium, getMediumLE, getShortLE, getUnsignedByte, getUnsignedInt, getUnsignedIntLE, getUnsignedMediumLE, getUnsignedShort, getUnsignedShortLE, hashCode, indexOf, isReadable, isReadable, isReadOnly, isWritable, isWritable, markReaderIndex, markWriterIndex, maxCapacity, maxCapacity, maxWritableBytes, nioBuffer, nioBuffers, order, readableBytes, readBoolean, readByte, readBytes, readBytes, readBytes, readBytes, readBytes, readChar, readCharSequence, readDouble, readerIndex, readerIndex, readFloat, readInt, readIntLE, readLong, readLongLE, readMedium, readMediumLE, readRetainedSlice, readShort, readShortLE, readSlice, readUnsignedByte, readUnsignedInt, readUnsignedIntLE, readUnsignedMedium, readUnsignedMediumLE, readUnsignedShort, readUnsignedShortLE, resetReaderIndex, resetWriterIndex, retainedDuplicate, retainedSlice, retainedSlice, setBoolean, setBytes, setBytes, setBytes, setChar, setCharSequence, setDouble, setFloat, setIndex, setIntLE, setLongLE, setMediumLE, setShortLE, skipBytes, slice, slice, toString, toString, toString, trimIndicesToCapacity, writableBytes, writeBoolean, writeByte, writeBytes, writeBytes, writeBytes, writeBytes, writeBytes, writeBytes, writeBytes, writeBytes, writeBytes, writeChar, writeCharSequence, writeDouble, writeFloat, writeInt, writeIntLE, writeLong, writeLongLE, writeMedium, writeMediumLE, writerIndex, writerIndex, writeShort, writeShortLE

    Methods inherited from class io.netty.buffer.ByteBuf

    asByteBuf, getDoubleLE, getFloatLE, maxFastWritableBytes, readDoubleLE, readFloatLE, setDoubleLE, setFloatLE, writeDoubleLE, writeFloatLE

    Methods inherited from class java.lang.Object

    clone, finalize, getClass, notify, notifyAll, wait, wait, wait

  • Method Details

    • capacity

      public io.netty.buffer.ByteBuf capacity(int newCapacity)
      Overrides:
      capacity in class io.netty.buffer.UnpooledDirectByteBuf

    • allocateDirect

      protected ByteBuffer allocateDirect(int initialCapacity)
      Overrides:
      allocateDirect in class io.netty.buffer.UnpooledDirectByteBuf

    • freeDirect

      protected void freeDirect(ByteBuffer buffer)
      Overrides:
      freeDirect in class io.netty.buffer.UnpooledDirectByteBuf

    • deallocate

      public void deallocate()
      Overrides:
      deallocate in class io.netty.buffer.UnpooledDirectByteBuf

    • adopt

      public ByteBuffer adopt()