org.eclipse.jetty/jetty-io/11.0.0 : org/eclipse/jetty/io/AbstractByteBufferPool.class

AbstractByteBufferPool
https://eclipse.org/jetty/jetty-io: The Eclipse Jetty Project (Webtide)
Greg Wilkins (Webtide, LLC)
Jan Bartel (Webtide, LLC)
Jesse McConnell (Webtide, LLC)
Joakim Erdfelt (Webtide, LLC)
Simone Bordet (Webtide, LLC)
David Jencks (IBM)
Olivier Lamy (Webtide, LLC)
Ludovic Orban (Webtide, LLC)
abstract class org.eclipse.jetty.io.AbstractByteBufferPool implements org.eclipse.jetty.io.ByteBufferPool
  minor version: 0
  major version: 59
  flags: flags: (0x0420) ACC_SUPER, ACC_ABSTRACT
  this_class: org.eclipse.jetty.io.AbstractByteBufferPool
  super_class: java.lang.Object
{
  private final int _factor;
    descriptor: I
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final int _maxQueueLength;
    descriptor: I
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final long _maxHeapMemory;
    descriptor: J
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.util.concurrent.atomic.AtomicLong _heapMemory;
    descriptor: Ljava/util/concurrent/atomic/AtomicLong;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final long _maxDirectMemory;
    descriptor: J
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.util.concurrent.atomic.AtomicLong _directMemory;
    descriptor: Ljava/util/concurrent/atomic/AtomicLong;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  protected void <init>(int, int, long, long);
    descriptor: (IIJJ)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=3, locals=7, args_size=5
        start local 0 // org.eclipse.jetty.io.AbstractByteBufferPool this
        start local 1 // int factor
        start local 2 // int maxQueueLength
        start local 3 // long maxHeapMemory
        start local 5 // long maxDirectMemory
         0: .line 39
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 35
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicLong
            dup
            invokespecial java.util.concurrent.atomic.AtomicLong.<init>:()V
            putfield org.eclipse.jetty.io.AbstractByteBufferPool._heapMemory:Ljava/util/concurrent/atomic/AtomicLong;
         2: .line 37
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicLong
            dup
            invokespecial java.util.concurrent.atomic.AtomicLong.<init>:()V
            putfield org.eclipse.jetty.io.AbstractByteBufferPool._directMemory:Ljava/util/concurrent/atomic/AtomicLong;
         3: .line 41
            aload 0 /* this */
            iload 1 /* factor */
            ifgt 4
            sipush 1024
            goto 5
      StackMap locals: org.eclipse.jetty.io.AbstractByteBufferPool int int long long
      StackMap stack: org.eclipse.jetty.io.AbstractByteBufferPool
         4: iload 1 /* factor */
      StackMap locals: org.eclipse.jetty.io.AbstractByteBufferPool int int long long
      StackMap stack: org.eclipse.jetty.io.AbstractByteBufferPool int
         5: putfield org.eclipse.jetty.io.AbstractByteBufferPool._factor:I
         6: .line 42
            aload 0 /* this */
            iload 2 /* maxQueueLength */
            putfield org.eclipse.jetty.io.AbstractByteBufferPool._maxQueueLength:I
         7: .line 43
            aload 0 /* this */
            lload 3 /* maxHeapMemory */
            putfield org.eclipse.jetty.io.AbstractByteBufferPool._maxHeapMemory:J
         8: .line 44
            aload 0 /* this */
            lload 5 /* maxDirectMemory */
            putfield org.eclipse.jetty.io.AbstractByteBufferPool._maxDirectMemory:J
         9: .line 45
            return
        end local 5 // long maxDirectMemory
        end local 3 // long maxHeapMemory
        end local 2 // int maxQueueLength
        end local 1 // int factor
        end local 0 // org.eclipse.jetty.io.AbstractByteBufferPool this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0   10     0             this  Lorg/eclipse/jetty/io/AbstractByteBufferPool;
            0   10     1           factor  I
            0   10     2   maxQueueLength  I
            0   10     3    maxHeapMemory  J
            0   10     5  maxDirectMemory  J
    MethodParameters:
                 Name  Flags
      factor           
      maxQueueLength   
      maxHeapMemory    
      maxDirectMemory  

  protected int getCapacityFactor();
    descriptor: ()I
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.io.AbstractByteBufferPool this
         0: .line 49
            aload 0 /* this */
            getfield org.eclipse.jetty.io.AbstractByteBufferPool._factor:I
            ireturn
        end local 0 // org.eclipse.jetty.io.AbstractByteBufferPool this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/io/AbstractByteBufferPool;

  protected int getMaxQueueLength();
    descriptor: ()I
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.io.AbstractByteBufferPool this
         0: .line 54
            aload 0 /* this */
            getfield org.eclipse.jetty.io.AbstractByteBufferPool._maxQueueLength:I
            ireturn
        end local 0 // org.eclipse.jetty.io.AbstractByteBufferPool this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/io/AbstractByteBufferPool;

  protected void decrementMemory(java.nio.ByteBuffer);
    descriptor: (Ljava/nio/ByteBuffer;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // org.eclipse.jetty.io.AbstractByteBufferPool this
        start local 1 // java.nio.ByteBuffer buffer
         0: .line 59
            aload 0 /* this */
            aload 1 /* buffer */
            iconst_0
            invokevirtual org.eclipse.jetty.io.AbstractByteBufferPool.updateMemory:(Ljava/nio/ByteBuffer;Z)V
         1: .line 60
            return
        end local 1 // java.nio.ByteBuffer buffer
        end local 0 // org.eclipse.jetty.io.AbstractByteBufferPool this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0    this  Lorg/eclipse/jetty/io/AbstractByteBufferPool;
            0    2     1  buffer  Ljava/nio/ByteBuffer;
    MethodParameters:
        Name  Flags
      buffer  

  protected void incrementMemory(java.nio.ByteBuffer);
    descriptor: (Ljava/nio/ByteBuffer;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // org.eclipse.jetty.io.AbstractByteBufferPool this
        start local 1 // java.nio.ByteBuffer buffer
         0: .line 64
            aload 0 /* this */
            aload 1 /* buffer */
            iconst_1
            invokevirtual org.eclipse.jetty.io.AbstractByteBufferPool.updateMemory:(Ljava/nio/ByteBuffer;Z)V
         1: .line 65
            return
        end local 1 // java.nio.ByteBuffer buffer
        end local 0 // org.eclipse.jetty.io.AbstractByteBufferPool this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0    this  Lorg/eclipse/jetty/io/AbstractByteBufferPool;
            0    2     1  buffer  Ljava/nio/ByteBuffer;
    MethodParameters:
        Name  Flags
      buffer  

  private void updateMemory(java.nio.ByteBuffer, boolean);
    descriptor: (Ljava/nio/ByteBuffer;Z)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=5, args_size=3
        start local 0 // org.eclipse.jetty.io.AbstractByteBufferPool this
        start local 1 // java.nio.ByteBuffer buffer
        start local 2 // boolean addOrSub
         0: .line 69
            aload 1 /* buffer */
            invokevirtual java.nio.ByteBuffer.isDirect:()Z
            ifeq 1
            aload 0 /* this */
            getfield org.eclipse.jetty.io.AbstractByteBufferPool._directMemory:Ljava/util/concurrent/atomic/AtomicLong;
            goto 2
      StackMap locals:
      StackMap stack:
         1: aload 0 /* this */
            getfield org.eclipse.jetty.io.AbstractByteBufferPool._heapMemory:Ljava/util/concurrent/atomic/AtomicLong;
      StackMap locals:
      StackMap stack: java.util.concurrent.atomic.AtomicLong
         2: astore 3 /* memory */
        start local 3 // java.util.concurrent.atomic.AtomicLong memory
         3: .line 70
            aload 1 /* buffer */
            invokevirtual java.nio.ByteBuffer.capacity:()I
            istore 4 /* capacity */
        start local 4 // int capacity
         4: .line 71
            aload 3 /* memory */
            iload 2 /* addOrSub */
            ifeq 5
            iload 4 /* capacity */
            goto 6
      StackMap locals: org.eclipse.jetty.io.AbstractByteBufferPool java.nio.ByteBuffer int java.util.concurrent.atomic.AtomicLong int
      StackMap stack: java.util.concurrent.atomic.AtomicLong
         5: iload 4 /* capacity */
            ineg
      StackMap locals: org.eclipse.jetty.io.AbstractByteBufferPool java.nio.ByteBuffer int java.util.concurrent.atomic.AtomicLong int
      StackMap stack: java.util.concurrent.atomic.AtomicLong int
         6: i2l
            invokevirtual java.util.concurrent.atomic.AtomicLong.addAndGet:(J)J
            pop2
         7: .line 72
            return
        end local 4 // int capacity
        end local 3 // java.util.concurrent.atomic.AtomicLong memory
        end local 2 // boolean addOrSub
        end local 1 // java.nio.ByteBuffer buffer
        end local 0 // org.eclipse.jetty.io.AbstractByteBufferPool this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    8     0      this  Lorg/eclipse/jetty/io/AbstractByteBufferPool;
            0    8     1    buffer  Ljava/nio/ByteBuffer;
            0    8     2  addOrSub  Z
            3    8     3    memory  Ljava/util/concurrent/atomic/AtomicLong;
            4    8     4  capacity  I
    MethodParameters:
          Name  Flags
      buffer    
      addOrSub  

  protected void releaseExcessMemory(boolean, java.util.function.Consumer<java.lang.Boolean>);
    descriptor: (ZLjava/util/function/Consumer;)V
    flags: (0x0004) ACC_PROTECTED
    Code:
      stack=4, locals=5, args_size=3
        start local 0 // org.eclipse.jetty.io.AbstractByteBufferPool this
        start local 1 // boolean direct
        start local 2 // java.util.function.Consumer clearFn
         0: .line 76
            iload 1 /* direct */
            ifeq 1
            aload 0 /* this */
            getfield org.eclipse.jetty.io.AbstractByteBufferPool._maxDirectMemory:J
            goto 2
      StackMap locals:
      StackMap stack:
         1: aload 0 /* this */
            getfield org.eclipse.jetty.io.AbstractByteBufferPool._maxHeapMemory:J
      StackMap locals:
      StackMap stack: long
         2: lstore 3 /* maxMemory */
        start local 3 // long maxMemory
         3: .line 77
            lload 3 /* maxMemory */
            lconst_0
            lcmp
            ifle 7
         4: .line 79
            goto 6
         5: .line 81
      StackMap locals: long
      StackMap stack:
            aload 2 /* clearFn */
            iload 1 /* direct */
            invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
            invokeinterface java.util.function.Consumer.accept:(Ljava/lang/Object;)V
         6: .line 79
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iload 1 /* direct */
            invokevirtual org.eclipse.jetty.io.AbstractByteBufferPool.getMemory:(Z)J
            lload 3 /* maxMemory */
            lcmp
            ifgt 5
         7: .line 84
      StackMap locals:
      StackMap stack:
            return
        end local 3 // long maxMemory
        end local 2 // java.util.function.Consumer clearFn
        end local 1 // boolean direct
        end local 0 // org.eclipse.jetty.io.AbstractByteBufferPool this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    8     0       this  Lorg/eclipse/jetty/io/AbstractByteBufferPool;
            0    8     1     direct  Z
            0    8     2    clearFn  Ljava/util/function/Consumer<Ljava/lang/Boolean;>;
            3    8     3  maxMemory  J
    Signature: (ZLjava/util/function/Consumer<Ljava/lang/Boolean;>;)V
    MethodParameters:
         Name  Flags
      direct   
      clearFn  

  public long getDirectMemory();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.io.AbstractByteBufferPool this
         0: .line 89
            aload 0 /* this */
            iconst_1
            invokevirtual org.eclipse.jetty.io.AbstractByteBufferPool.getMemory:(Z)J
            lreturn
        end local 0 // org.eclipse.jetty.io.AbstractByteBufferPool this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/io/AbstractByteBufferPool;
    RuntimeVisibleAnnotations: 
      org.eclipse.jetty.util.annotation.ManagedAttribute(value = "The bytes retained by direct ByteBuffers")

  public long getHeapMemory();
    descriptor: ()J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.io.AbstractByteBufferPool this
         0: .line 95
            aload 0 /* this */
            iconst_0
            invokevirtual org.eclipse.jetty.io.AbstractByteBufferPool.getMemory:(Z)J
            lreturn
        end local 0 // org.eclipse.jetty.io.AbstractByteBufferPool this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/io/AbstractByteBufferPool;
    RuntimeVisibleAnnotations: 
      org.eclipse.jetty.util.annotation.ManagedAttribute(value = "The bytes retained by heap ByteBuffers")

  public long getMemory(boolean);
    descriptor: (Z)J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // org.eclipse.jetty.io.AbstractByteBufferPool this
        start local 1 // boolean direct
         0: .line 100
            iload 1 /* direct */
            ifeq 1
            aload 0 /* this */
            getfield org.eclipse.jetty.io.AbstractByteBufferPool._directMemory:Ljava/util/concurrent/atomic/AtomicLong;
            goto 2
      StackMap locals:
      StackMap stack:
         1: aload 0 /* this */
            getfield org.eclipse.jetty.io.AbstractByteBufferPool._heapMemory:Ljava/util/concurrent/atomic/AtomicLong;
      StackMap locals:
      StackMap stack: java.util.concurrent.atomic.AtomicLong
         2: astore 2 /* memory */
        start local 2 // java.util.concurrent.atomic.AtomicLong memory
         3: .line 101
            aload 2 /* memory */
            invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
            lreturn
        end local 2 // java.util.concurrent.atomic.AtomicLong memory
        end local 1 // boolean direct
        end local 0 // org.eclipse.jetty.io.AbstractByteBufferPool this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    4     0    this  Lorg/eclipse/jetty/io/AbstractByteBufferPool;
            0    4     1  direct  Z
            3    4     2  memory  Ljava/util/concurrent/atomic/AtomicLong;
    MethodParameters:
        Name  Flags
      direct  

  public void clear();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.io.AbstractByteBufferPool this
         0: .line 107
            aload 0 /* this */
            getfield org.eclipse.jetty.io.AbstractByteBufferPool._heapMemory:Ljava/util/concurrent/atomic/AtomicLong;
            lconst_0
            invokevirtual java.util.concurrent.atomic.AtomicLong.set:(J)V
         1: .line 108
            aload 0 /* this */
            getfield org.eclipse.jetty.io.AbstractByteBufferPool._directMemory:Ljava/util/concurrent/atomic/AtomicLong;
            lconst_0
            invokevirtual java.util.concurrent.atomic.AtomicLong.set:(J)V
         2: .line 109
            return
        end local 0 // org.eclipse.jetty.io.AbstractByteBufferPool this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lorg/eclipse/jetty/io/AbstractByteBufferPool;
    RuntimeVisibleAnnotations: 
      org.eclipse.jetty.util.annotation.ManagedOperation(value = "Clears this ByteBufferPool", impact = "ACTION")
}
SourceFile: "AbstractByteBufferPool.java"
    RuntimeVisibleAnnotations: 
      org.eclipse.jetty.util.annotation.ManagedObject()
/

org.eclipse.jetty/ jetty-io/ 11.0.0/ org/eclipse/jetty/io/AbstractByteBufferPool.class
