Class AbstractByteBufferPool

    • Field Detail

      • _factor

        private final int _factor
      • _maxQueueLength

        private final int _maxQueueLength
      • _maxHeapMemory

        private final long _maxHeapMemory
      • _heapMemory

        private final java.util.concurrent.atomic.AtomicLong _heapMemory
      • _maxDirectMemory

        private final long _maxDirectMemory
      • _directMemory

        private final java.util.concurrent.atomic.AtomicLong _directMemory
    • Constructor Detail

      • AbstractByteBufferPool

        protected AbstractByteBufferPool​(int factor,
                                         int maxQueueLength,
                                         long maxHeapMemory,
                                         long maxDirectMemory)
    • Method Detail

      • getCapacityFactor

        protected int getCapacityFactor()
      • getMaxQueueLength

        protected int getMaxQueueLength()
      • decrementMemory

        protected void decrementMemory​(java.nio.ByteBuffer buffer)
      • incrementMemory

        protected void incrementMemory​(java.nio.ByteBuffer buffer)
      • updateMemory

        private void updateMemory​(java.nio.ByteBuffer buffer,
                                  boolean addOrSub)
      • releaseExcessMemory

        protected void releaseExcessMemory​(boolean direct,
                                           java.util.function.Consumer<java.lang.Boolean> clearFn)
      • getDirectMemory

        @ManagedAttribute("The bytes retained by direct ByteBuffers")
        public long getDirectMemory()
      • getHeapMemory

        @ManagedAttribute("The bytes retained by heap ByteBuffers")
        public long getHeapMemory()
      • getMemory

        public long getMemory​(boolean direct)