org.eclipse.jetty/jetty-io/11.0.0 : org/eclipse/jetty/io/ByteBufferPool$Bucket.class

ByteBufferPool$Bucket
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)
public class org.eclipse.jetty.io.ByteBufferPool$Bucket
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.eclipse.jetty.io.ByteBufferPool$Bucket
  super_class: java.lang.Object
{
  private final java.util.Deque<java.nio.ByteBuffer> _queue;
    descriptor: Ljava/util/Deque;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/Deque<Ljava/nio/ByteBuffer;>;

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

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

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

  private long _lastUpdate;
    descriptor: J
    flags: (0x0002) ACC_PRIVATE

  public void <init>(int, int);
    descriptor: (II)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // org.eclipse.jetty.io.ByteBufferPool$Bucket this
        start local 1 // int capacity
        start local 2 // int maxSize
         0: .line 162
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 156
            aload 0 /* this */
            new java.util.concurrent.ConcurrentLinkedDeque
            dup
            invokespecial java.util.concurrent.ConcurrentLinkedDeque.<init>:()V
            putfield org.eclipse.jetty.io.ByteBufferPool$Bucket._queue:Ljava/util/Deque;
         2: .line 160
            aload 0 /* this */
            invokestatic java.lang.System.nanoTime:()J
            putfield org.eclipse.jetty.io.ByteBufferPool$Bucket._lastUpdate:J
         3: .line 164
            aload 0 /* this */
            iload 1 /* capacity */
            putfield org.eclipse.jetty.io.ByteBufferPool$Bucket._capacity:I
         4: .line 165
            aload 0 /* this */
            iload 2 /* maxSize */
            putfield org.eclipse.jetty.io.ByteBufferPool$Bucket._maxSize:I
         5: .line 166
            aload 0 /* this */
            iload 2 /* maxSize */
            ifle 6
            new java.util.concurrent.atomic.AtomicInteger
            dup
            invokespecial java.util.concurrent.atomic.AtomicInteger.<init>:()V
            goto 7
      StackMap locals: org.eclipse.jetty.io.ByteBufferPool$Bucket int int
      StackMap stack: org.eclipse.jetty.io.ByteBufferPool$Bucket
         6: aconst_null
      StackMap locals: org.eclipse.jetty.io.ByteBufferPool$Bucket int int
      StackMap stack: org.eclipse.jetty.io.ByteBufferPool$Bucket java.util.concurrent.atomic.AtomicInteger
         7: putfield org.eclipse.jetty.io.ByteBufferPool$Bucket._size:Ljava/util/concurrent/atomic/AtomicInteger;
         8: .line 167
            return
        end local 2 // int maxSize
        end local 1 // int capacity
        end local 0 // org.eclipse.jetty.io.ByteBufferPool$Bucket this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    9     0      this  Lorg/eclipse/jetty/io/ByteBufferPool$Bucket;
            0    9     1  capacity  I
            0    9     2   maxSize  I
    MethodParameters:
          Name  Flags
      capacity  
      maxSize   

  public java.nio.ByteBuffer acquire();
    descriptor: ()Ljava/nio/ByteBuffer;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=2, args_size=1
        start local 0 // org.eclipse.jetty.io.ByteBufferPool$Bucket this
         0: .line 171
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.io.ByteBufferPool$Bucket.queuePoll:()Ljava/nio/ByteBuffer;
            astore 1 /* buffer */
        start local 1 // java.nio.ByteBuffer buffer
         1: .line 172
            aload 1 /* buffer */
            ifnonnull 3
         2: .line 173
            aconst_null
            areturn
         3: .line 174
      StackMap locals: java.nio.ByteBuffer
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ByteBufferPool$Bucket._size:Ljava/util/concurrent/atomic/AtomicInteger;
            ifnull 5
         4: .line 175
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ByteBufferPool$Bucket._size:Ljava/util/concurrent/atomic/AtomicInteger;
            invokevirtual java.util.concurrent.atomic.AtomicInteger.decrementAndGet:()I
            pop
         5: .line 176
      StackMap locals:
      StackMap stack:
            aload 1 /* buffer */
            areturn
        end local 1 // java.nio.ByteBuffer buffer
        end local 0 // org.eclipse.jetty.io.ByteBufferPool$Bucket this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    6     0    this  Lorg/eclipse/jetty/io/ByteBufferPool$Bucket;
            1    6     1  buffer  Ljava/nio/ByteBuffer;

  public void release(java.nio.ByteBuffer);
    descriptor: (Ljava/nio/ByteBuffer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // org.eclipse.jetty.io.ByteBufferPool$Bucket this
        start local 1 // java.nio.ByteBuffer buffer
         0: .line 181
            aload 0 /* this */
            invokestatic java.lang.System.nanoTime:()J
            putfield org.eclipse.jetty.io.ByteBufferPool$Bucket._lastUpdate:J
         1: .line 182
            aload 1 /* buffer */
            invokestatic org.eclipse.jetty.util.BufferUtil.clear:(Ljava/nio/ByteBuffer;)V
         2: .line 183
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ByteBufferPool$Bucket._size:Ljava/util/concurrent/atomic/AtomicInteger;
            ifnonnull 4
         3: .line 184
            aload 0 /* this */
            aload 1 /* buffer */
            invokevirtual org.eclipse.jetty.io.ByteBufferPool$Bucket.queueOffer:(Ljava/nio/ByteBuffer;)V
            goto 7
         4: .line 185
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ByteBufferPool$Bucket._size:Ljava/util/concurrent/atomic/AtomicInteger;
            invokevirtual java.util.concurrent.atomic.AtomicInteger.incrementAndGet:()I
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ByteBufferPool$Bucket._maxSize:I
            if_icmpgt 6
         5: .line 186
            aload 0 /* this */
            aload 1 /* buffer */
            invokevirtual org.eclipse.jetty.io.ByteBufferPool$Bucket.queueOffer:(Ljava/nio/ByteBuffer;)V
            goto 7
         6: .line 188
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ByteBufferPool$Bucket._size:Ljava/util/concurrent/atomic/AtomicInteger;
            invokevirtual java.util.concurrent.atomic.AtomicInteger.decrementAndGet:()I
            pop
         7: .line 189
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.nio.ByteBuffer buffer
        end local 0 // org.eclipse.jetty.io.ByteBufferPool$Bucket this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    8     0    this  Lorg/eclipse/jetty/io/ByteBufferPool$Bucket;
            0    8     1  buffer  Ljava/nio/ByteBuffer;
    MethodParameters:
        Name  Flags
      buffer  

  public void clear();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.io.ByteBufferPool$Bucket this
         0: .line 193
            aload 0 /* this */
            aconst_null
            invokevirtual org.eclipse.jetty.io.ByteBufferPool$Bucket.clear:(Ljava/util/function/Consumer;)V
         1: .line 194
            return
        end local 0 // org.eclipse.jetty.io.ByteBufferPool$Bucket this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/eclipse/jetty/io/ByteBufferPool$Bucket;

  void clear(java.util.function.Consumer<java.nio.ByteBuffer>);
    descriptor: (Ljava/util/function/Consumer;)V
    flags: (0x0000) 
    Code:
      stack=2, locals=4, args_size=2
        start local 0 // org.eclipse.jetty.io.ByteBufferPool$Bucket this
        start local 1 // java.util.function.Consumer memoryFn
         0: .line 198
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ByteBufferPool$Bucket._size:Ljava/util/concurrent/atomic/AtomicInteger;
            ifnonnull 1
            iconst_0
            goto 2
      StackMap locals:
      StackMap stack:
         1: aload 0 /* this */
            getfield org.eclipse.jetty.io.ByteBufferPool$Bucket._size:Ljava/util/concurrent/atomic/AtomicInteger;
            invokevirtual java.util.concurrent.atomic.AtomicInteger.get:()I
            iconst_1
            isub
      StackMap locals:
      StackMap stack: int
         2: istore 2 /* size */
        start local 2 // int size
         3: .line 199
            goto 12
         4: .line 201
      StackMap locals: int
      StackMap stack:
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.io.ByteBufferPool$Bucket.queuePoll:()Ljava/nio/ByteBuffer;
            astore 3 /* buffer */
        start local 3 // java.nio.ByteBuffer buffer
         5: .line 202
            aload 3 /* buffer */
            ifnonnull 7
         6: .line 203
            goto 13
         7: .line 204
      StackMap locals: java.nio.ByteBuffer
      StackMap stack:
            aload 1 /* memoryFn */
            ifnull 9
         8: .line 205
            aload 1 /* memoryFn */
            aload 3 /* buffer */
            invokeinterface java.util.function.Consumer.accept:(Ljava/lang/Object;)V
         9: .line 206
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ByteBufferPool$Bucket._size:Ljava/util/concurrent/atomic/AtomicInteger;
            ifnull 12
        10: .line 208
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ByteBufferPool$Bucket._size:Ljava/util/concurrent/atomic/AtomicInteger;
            invokevirtual java.util.concurrent.atomic.AtomicInteger.decrementAndGet:()I
            pop
        11: .line 209
            iinc 2 /* size */ -1
        end local 3 // java.nio.ByteBuffer buffer
        12: .line 199
      StackMap locals:
      StackMap stack:
            iload 2 /* size */
            ifge 4
        13: .line 212
      StackMap locals:
      StackMap stack:
            return
        end local 2 // int size
        end local 1 // java.util.function.Consumer memoryFn
        end local 0 // org.eclipse.jetty.io.ByteBufferPool$Bucket this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   14     0      this  Lorg/eclipse/jetty/io/ByteBufferPool$Bucket;
            0   14     1  memoryFn  Ljava/util/function/Consumer<Ljava/nio/ByteBuffer;>;
            3   14     2      size  I
            5   12     3    buffer  Ljava/nio/ByteBuffer;
    Signature: (Ljava/util/function/Consumer<Ljava/nio/ByteBuffer;>;)V
    MethodParameters:
          Name  Flags
      memoryFn  

  private void queueOffer(java.nio.ByteBuffer);
    descriptor: (Ljava/nio/ByteBuffer;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.eclipse.jetty.io.ByteBufferPool$Bucket this
        start local 1 // java.nio.ByteBuffer buffer
         0: .line 216
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ByteBufferPool$Bucket._queue:Ljava/util/Deque;
            aload 1 /* buffer */
            invokeinterface java.util.Deque.offerFirst:(Ljava/lang/Object;)Z
            pop
         1: .line 217
            return
        end local 1 // java.nio.ByteBuffer buffer
        end local 0 // org.eclipse.jetty.io.ByteBufferPool$Bucket this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0    this  Lorg/eclipse/jetty/io/ByteBufferPool$Bucket;
            0    2     1  buffer  Ljava/nio/ByteBuffer;
    MethodParameters:
        Name  Flags
      buffer  

  private java.nio.ByteBuffer queuePoll();
    descriptor: ()Ljava/nio/ByteBuffer;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.io.ByteBufferPool$Bucket this
         0: .line 221
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ByteBufferPool$Bucket._queue:Ljava/util/Deque;
            invokeinterface java.util.Deque.poll:()Ljava/lang/Object;
            checkcast java.nio.ByteBuffer
            areturn
        end local 0 // org.eclipse.jetty.io.ByteBufferPool$Bucket this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/io/ByteBufferPool$Bucket;

  boolean isEmpty();
    descriptor: ()Z
    flags: (0x0000) 
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.io.ByteBufferPool$Bucket this
         0: .line 226
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ByteBufferPool$Bucket._queue:Ljava/util/Deque;
            invokeinterface java.util.Deque.isEmpty:()Z
            ireturn
        end local 0 // org.eclipse.jetty.io.ByteBufferPool$Bucket this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/io/ByteBufferPool$Bucket;

  int size();
    descriptor: ()I
    flags: (0x0000) 
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.io.ByteBufferPool$Bucket this
         0: .line 231
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ByteBufferPool$Bucket._queue:Ljava/util/Deque;
            invokeinterface java.util.Deque.size:()I
            ireturn
        end local 0 // org.eclipse.jetty.io.ByteBufferPool$Bucket this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/io/ByteBufferPool$Bucket;

  long getLastUpdate();
    descriptor: ()J
    flags: (0x0000) 
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.io.ByteBufferPool$Bucket this
         0: .line 236
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ByteBufferPool$Bucket._lastUpdate:J
            lreturn
        end local 0 // org.eclipse.jetty.io.ByteBufferPool$Bucket this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/io/ByteBufferPool$Bucket;

  public java.lang.String toString();
    descriptor: ()Ljava/lang/String;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=1, args_size=1
        start local 0 // org.eclipse.jetty.io.ByteBufferPool$Bucket this
         0: .line 242
            ldc "%s@%x{%d/%d@%d}"
            iconst_5
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            invokevirtual java.lang.Class.getSimpleName:()Ljava/lang/String;
            aastore
            dup
            iconst_1
            aload 0 /* this */
            invokevirtual java.lang.Object.hashCode:()I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_2
            aload 0 /* this */
            invokevirtual org.eclipse.jetty.io.ByteBufferPool$Bucket.size:()I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_3
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ByteBufferPool$Bucket._maxSize:I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            dup
            iconst_4
            aload 0 /* this */
            getfield org.eclipse.jetty.io.ByteBufferPool$Bucket._capacity:I
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            aastore
            invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
            areturn
        end local 0 // org.eclipse.jetty.io.ByteBufferPool$Bucket this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/eclipse/jetty/io/ByteBufferPool$Bucket;
}
SourceFile: "ByteBufferPool.java"
NestHost: org.eclipse.jetty.io.ByteBufferPool
InnerClasses:
  public Bucket = org.eclipse.jetty.io.ByteBufferPool$Bucket of org.eclipse.jetty.io.ByteBufferPool
/

org.eclipse.jetty/ jetty-io/ 11.0.0/ org/eclipse/jetty/io/ByteBufferPool$Bucket.class
