class org.h2.mvstore.StreamStore$Stream extends java.io.InputStream
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: org.h2.mvstore.StreamStore$Stream
  super_class: java.io.InputStream
{
  private final org.h2.mvstore.StreamStore store;
    descriptor: Lorg/h2/mvstore/StreamStore;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private byte[] oneByteBuffer;
    descriptor: [B
    flags: (0x0002) ACC_PRIVATE

  private java.nio.ByteBuffer idBuffer;
    descriptor: Ljava/nio/ByteBuffer;
    flags: (0x0002) ACC_PRIVATE

  private java.io.ByteArrayInputStream buffer;
    descriptor: Ljava/io/ByteArrayInputStream;
    flags: (0x0002) ACC_PRIVATE

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

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

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

  void <init>(org.h2.mvstore.StreamStore, byte[]);
    descriptor: (Lorg/h2/mvstore/StreamStore;[B)V
    flags: (0x0000) 
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // org.h2.mvstore.StreamStore$Stream this
        start local 1 // org.h2.mvstore.StreamStore store
        start local 2 // byte[] id
         0: .line 456
            aload 0 /* this */
            invokespecial java.io.InputStream.<init>:()V
         1: .line 457
            aload 0 /* this */
            aload 1 /* store */
            putfield org.h2.mvstore.StreamStore$Stream.store:Lorg/h2/mvstore/StreamStore;
         2: .line 458
            aload 0 /* this */
            aload 1 /* store */
            aload 2 /* id */
            invokevirtual org.h2.mvstore.StreamStore.length:([B)J
            putfield org.h2.mvstore.StreamStore$Stream.length:J
         3: .line 459
            aload 0 /* this */
            aload 2 /* id */
            invokestatic java.nio.ByteBuffer.wrap:([B)Ljava/nio/ByteBuffer;
            putfield org.h2.mvstore.StreamStore$Stream.idBuffer:Ljava/nio/ByteBuffer;
         4: .line 460
            return
        end local 2 // byte[] id
        end local 1 // org.h2.mvstore.StreamStore store
        end local 0 // org.h2.mvstore.StreamStore$Stream this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    5     0   this  Lorg/h2/mvstore/StreamStore$Stream;
            0    5     1  store  Lorg/h2/mvstore/StreamStore;
            0    5     2     id  [B
    MethodParameters:
       Name  Flags
      store  
      id     

  public int read();
    descriptor: ()I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=1
        start local 0 // org.h2.mvstore.StreamStore$Stream this
         0: .line 464
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.oneByteBuffer:[B
            astore 1 /* buffer */
        start local 1 // byte[] buffer
         1: .line 465
            aload 1 /* buffer */
            ifnonnull 3
         2: .line 466
            aload 0 /* this */
            iconst_1
            newarray 8
            dup_x1
            putfield org.h2.mvstore.StreamStore$Stream.oneByteBuffer:[B
            astore 1 /* buffer */
         3: .line 468
      StackMap locals: byte[]
      StackMap stack:
            aload 0 /* this */
            aload 1 /* buffer */
            iconst_0
            iconst_1
            invokevirtual org.h2.mvstore.StreamStore$Stream.read:([BII)I
            istore 2 /* len */
        start local 2 // int len
         4: .line 469
            iload 2 /* len */
            iconst_m1
            if_icmpne 5
            iconst_m1
            goto 6
      StackMap locals: int
      StackMap stack:
         5: aload 1 /* buffer */
            iconst_0
            baload
            sipush 255
            iand
      StackMap locals:
      StackMap stack: int
         6: ireturn
        end local 2 // int len
        end local 1 // byte[] buffer
        end local 0 // org.h2.mvstore.StreamStore$Stream this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    7     0    this  Lorg/h2/mvstore/StreamStore$Stream;
            1    7     1  buffer  [B
            4    7     2     len  I
    Exceptions:
      throws java.io.IOException

  public long skip(long);
    descriptor: (J)J
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=5, args_size=2
        start local 0 // org.h2.mvstore.StreamStore$Stream this
        start local 1 // long n
         0: .line 474
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.length:J
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.pos:J
            lsub
            lload 1 /* n */
            invokestatic java.lang.Math.min:(JJ)J
            lstore 1 /* n */
         1: .line 475
            lload 1 /* n */
            lconst_0
            lcmp
            ifne 3
         2: .line 476
            lconst_0
            lreturn
         3: .line 478
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.buffer:Ljava/io/ByteArrayInputStream;
            ifnull 11
         4: .line 479
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.buffer:Ljava/io/ByteArrayInputStream;
            lload 1 /* n */
            invokevirtual java.io.ByteArrayInputStream.skip:(J)J
            lstore 3 /* s */
        start local 3 // long s
         5: .line 480
            lload 3 /* s */
            lconst_0
            lcmp
            ifle 8
         6: .line 481
            lload 3 /* s */
            lstore 1 /* n */
         7: .line 482
            goto 12
         8: .line 483
      StackMap locals: long
      StackMap stack:
            aload 0 /* this */
            aconst_null
            putfield org.h2.mvstore.StreamStore$Stream.buffer:Ljava/io/ByteArrayInputStream;
         9: .line 484
            aload 0 /* this */
            dup
            getfield org.h2.mvstore.StreamStore$Stream.skip:J
            lload 1 /* n */
            ladd
            putfield org.h2.mvstore.StreamStore$Stream.skip:J
        end local 3 // long s
        10: .line 486
            goto 12
        11: .line 487
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            dup
            getfield org.h2.mvstore.StreamStore$Stream.skip:J
            lload 1 /* n */
            ladd
            putfield org.h2.mvstore.StreamStore$Stream.skip:J
        12: .line 489
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            dup
            getfield org.h2.mvstore.StreamStore$Stream.pos:J
            lload 1 /* n */
            ladd
            putfield org.h2.mvstore.StreamStore$Stream.pos:J
        13: .line 490
            lload 1 /* n */
            lreturn
        end local 1 // long n
        end local 0 // org.h2.mvstore.StreamStore$Stream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   14     0  this  Lorg/h2/mvstore/StreamStore$Stream;
            0   14     1     n  J
            5   10     3     s  J
    MethodParameters:
      Name  Flags
      n     

  public void close();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.h2.mvstore.StreamStore$Stream this
         0: .line 495
            aload 0 /* this */
            aconst_null
            putfield org.h2.mvstore.StreamStore$Stream.buffer:Ljava/io/ByteArrayInputStream;
         1: .line 496
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.idBuffer:Ljava/nio/ByteBuffer;
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.idBuffer:Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.limit:()I
            invokevirtual java.nio.ByteBuffer.position:(I)Ljava/nio/Buffer;
            pop
         2: .line 497
            aload 0 /* this */
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.length:J
            putfield org.h2.mvstore.StreamStore$Stream.pos:J
         3: .line 498
            return
        end local 0 // org.h2.mvstore.StreamStore$Stream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lorg/h2/mvstore/StreamStore$Stream;

  public int read(byte[], int, int);
    descriptor: ([BII)I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=6, args_size=4
        start local 0 // org.h2.mvstore.StreamStore$Stream this
        start local 1 // byte[] b
        start local 2 // int off
        start local 3 // int len
         0: .line 502
            iload 3 /* len */
            ifgt 2
         1: .line 503
            iconst_0
            ireturn
         2: .line 506
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.buffer:Ljava/io/ByteArrayInputStream;
            ifnonnull 13
         3: .line 508
            aload 0 /* this */
            aload 0 /* this */
            invokevirtual org.h2.mvstore.StreamStore$Stream.nextBuffer:()Ljava/io/ByteArrayInputStream;
            putfield org.h2.mvstore.StreamStore$Stream.buffer:Ljava/io/ByteArrayInputStream;
         4: .line 509
            goto 11
      StackMap locals:
      StackMap stack: java.lang.IllegalStateException
         5: astore 4 /* e */
        start local 4 // java.lang.IllegalStateException e
         6: .line 511
            bipush 50
         7: .line 512
            ldc "Block not found in id {0}"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
         8: .line 513
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.idBuffer:Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.array:()[B
            invokestatic java.util.Arrays.toString:([B)Ljava/lang/String;
            aastore
         9: .line 510
            invokestatic org.h2.mvstore.DataUtils.formatMessage:(ILjava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
            astore 5 /* msg */
        start local 5 // java.lang.String msg
        10: .line 514
            new java.io.IOException
            dup
            aload 5 /* msg */
            aload 4 /* e */
            invokespecial java.io.IOException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
            athrow
        end local 5 // java.lang.String msg
        end local 4 // java.lang.IllegalStateException e
        11: .line 516
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.buffer:Ljava/io/ByteArrayInputStream;
            ifnonnull 13
        12: .line 517
            iconst_m1
            ireturn
        13: .line 520
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.buffer:Ljava/io/ByteArrayInputStream;
            aload 1 /* b */
            iload 2 /* off */
            iload 3 /* len */
            invokevirtual java.io.ByteArrayInputStream.read:([BII)I
            istore 4 /* result */
        start local 4 // int result
        14: .line 521
            iload 4 /* result */
            ifle 17
        15: .line 522
            aload 0 /* this */
            dup
            getfield org.h2.mvstore.StreamStore$Stream.pos:J
            iload 4 /* result */
            i2l
            ladd
            putfield org.h2.mvstore.StreamStore$Stream.pos:J
        16: .line 523
            iload 4 /* result */
            ireturn
        17: .line 525
      StackMap locals: int
      StackMap stack:
            aload 0 /* this */
            aconst_null
            putfield org.h2.mvstore.StreamStore$Stream.buffer:Ljava/io/ByteArrayInputStream;
        end local 4 // int result
        18: .line 505
            goto 2
        end local 3 // int len
        end local 2 // int off
        end local 1 // byte[] b
        end local 0 // org.h2.mvstore.StreamStore$Stream this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   19     0    this  Lorg/h2/mvstore/StreamStore$Stream;
            0   19     1       b  [B
            0   19     2     off  I
            0   19     3     len  I
            6   11     4       e  Ljava/lang/IllegalStateException;
           10   11     5     msg  Ljava/lang/String;
           14   18     4  result  I
      Exception table:
        from    to  target  type
           3     4       5  Class java.lang.IllegalStateException
    Exceptions:
      throws java.io.IOException
    MethodParameters:
      Name  Flags
      b     
      off   
      len   

  private java.io.ByteArrayInputStream nextBuffer();
    descriptor: ()Ljava/io/ByteArrayInputStream;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=6, locals=7, args_size=1
        start local 0 // org.h2.mvstore.StreamStore$Stream this
         0: .line 530
            goto 39
         1: .line 531
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.idBuffer:Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.get:()B
            tableswitch { // 0 - 2
                    0: 2
                    1: 11
                    2: 20
              default: 36
          }
         2: .line 533
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.idBuffer:Ljava/nio/ByteBuffer;
            invokestatic org.h2.mvstore.DataUtils.readVarInt:(Ljava/nio/ByteBuffer;)I
            istore 1 /* len */
        start local 1 // int len
         3: .line 534
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.skip:J
            iload 1 /* len */
            i2l
            lcmp
            iflt 7
         4: .line 535
            aload 0 /* this */
            dup
            getfield org.h2.mvstore.StreamStore$Stream.skip:J
            iload 1 /* len */
            i2l
            lsub
            putfield org.h2.mvstore.StreamStore$Stream.skip:J
         5: .line 536
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.idBuffer:Ljava/nio/ByteBuffer;
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.idBuffer:Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.position:()I
            iload 1 /* len */
            iadd
            invokevirtual java.nio.ByteBuffer.position:(I)Ljava/nio/Buffer;
            pop
         6: .line 537
            goto 39
         7: .line 539
      StackMap locals: int
      StackMap stack:
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.idBuffer:Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.position:()I
            i2l
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.skip:J
            ladd
            l2i
            istore 2 /* p */
        start local 2 // int p
         8: .line 540
            iload 1 /* len */
            i2l
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.skip:J
            lsub
            l2i
            istore 3 /* l */
        start local 3 // int l
         9: .line 541
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.idBuffer:Ljava/nio/ByteBuffer;
            iload 2 /* p */
            iload 3 /* l */
            iadd
            invokevirtual java.nio.ByteBuffer.position:(I)Ljava/nio/Buffer;
            pop
        10: .line 542
            new java.io.ByteArrayInputStream
            dup
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.idBuffer:Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.array:()[B
            iload 2 /* p */
            iload 3 /* l */
            invokespecial java.io.ByteArrayInputStream.<init>:([BII)V
            areturn
        end local 3 // int l
        end local 2 // int p
        end local 1 // int len
        11: .line 545
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.idBuffer:Ljava/nio/ByteBuffer;
            invokestatic org.h2.mvstore.DataUtils.readVarInt:(Ljava/nio/ByteBuffer;)I
            istore 1 /* len */
        start local 1 // int len
        12: .line 546
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.idBuffer:Ljava/nio/ByteBuffer;
            invokestatic org.h2.mvstore.DataUtils.readVarLong:(Ljava/nio/ByteBuffer;)J
            lstore 2 /* key */
        start local 2 // long key
        13: .line 547
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.skip:J
            iload 1 /* len */
            i2l
            lcmp
            iflt 16
        14: .line 548
            aload 0 /* this */
            dup
            getfield org.h2.mvstore.StreamStore$Stream.skip:J
            iload 1 /* len */
            i2l
            lsub
            putfield org.h2.mvstore.StreamStore$Stream.skip:J
        15: .line 549
            goto 39
        16: .line 551
      StackMap locals: int long
      StackMap stack:
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.store:Lorg/h2/mvstore/StreamStore;
            lload 2 /* key */
            invokevirtual org.h2.mvstore.StreamStore.getBlock:(J)[B
            astore 4 /* data */
        start local 4 // byte[] data
        17: .line 552
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.skip:J
            l2i
            istore 5 /* s */
        start local 5 // int s
        18: .line 553
            aload 0 /* this */
            lconst_0
            putfield org.h2.mvstore.StreamStore$Stream.skip:J
        19: .line 554
            new java.io.ByteArrayInputStream
            dup
            aload 4 /* data */
            iload 5 /* s */
            aload 4 /* data */
            arraylength
            iload 5 /* s */
            isub
            invokespecial java.io.ByteArrayInputStream.<init>:([BII)V
            areturn
        end local 5 // int s
        end local 4 // byte[] data
        end local 2 // long key
        end local 1 // int len
        20: .line 557
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.idBuffer:Ljava/nio/ByteBuffer;
            invokestatic org.h2.mvstore.DataUtils.readVarLong:(Ljava/nio/ByteBuffer;)J
            lstore 1 /* len */
        start local 1 // long len
        21: .line 558
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.idBuffer:Ljava/nio/ByteBuffer;
            invokestatic org.h2.mvstore.DataUtils.readVarLong:(Ljava/nio/ByteBuffer;)J
            lstore 3 /* key */
        start local 3 // long key
        22: .line 559
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.skip:J
            lload 1 /* len */
            lcmp
            iflt 25
        23: .line 560
            aload 0 /* this */
            dup
            getfield org.h2.mvstore.StreamStore$Stream.skip:J
            lload 1 /* len */
            lsub
            putfield org.h2.mvstore.StreamStore$Stream.skip:J
        24: .line 561
            goto 39
        25: .line 563
      StackMap locals: long long
      StackMap stack:
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.store:Lorg/h2/mvstore/StreamStore;
            lload 3 /* key */
            invokevirtual org.h2.mvstore.StreamStore.getBlock:(J)[B
            astore 5 /* k */
        start local 5 // byte[] k
        26: .line 564
            aload 5 /* k */
            arraylength
        27: .line 565
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.idBuffer:Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.limit:()I
        28: .line 564
            iadd
        29: .line 565
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.idBuffer:Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.position:()I
        30: .line 564
            isub
            invokestatic java.nio.ByteBuffer.allocate:(I)Ljava/nio/ByteBuffer;
            astore 6 /* newBuffer */
        start local 6 // java.nio.ByteBuffer newBuffer
        31: .line 566
            aload 6 /* newBuffer */
            aload 5 /* k */
            invokevirtual java.nio.ByteBuffer.put:([B)Ljava/nio/ByteBuffer;
            pop
        32: .line 567
            aload 6 /* newBuffer */
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.idBuffer:Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.put:(Ljava/nio/ByteBuffer;)Ljava/nio/ByteBuffer;
            pop
        33: .line 568
            aload 6 /* newBuffer */
            invokevirtual java.nio.ByteBuffer.flip:()Ljava/nio/Buffer;
            pop
        34: .line 569
            aload 0 /* this */
            aload 6 /* newBuffer */
            putfield org.h2.mvstore.StreamStore$Stream.idBuffer:Ljava/nio/ByteBuffer;
        35: .line 570
            aload 0 /* this */
            invokevirtual org.h2.mvstore.StreamStore$Stream.nextBuffer:()Ljava/io/ByteArrayInputStream;
            areturn
        end local 6 // java.nio.ByteBuffer newBuffer
        end local 5 // byte[] k
        end local 3 // long key
        end local 1 // long len
        36: .line 574
      StackMap locals:
      StackMap stack:
            ldc "Unsupported id {0}"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
        37: .line 575
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.idBuffer:Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.array:()[B
            invokestatic java.util.Arrays.toString:([B)Ljava/lang/String;
            aastore
        38: .line 573
            invokestatic org.h2.mvstore.DataUtils.newIllegalArgumentException:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/IllegalArgumentException;
            athrow
        39: .line 530
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.h2.mvstore.StreamStore$Stream.idBuffer:Ljava/nio/ByteBuffer;
            invokevirtual java.nio.ByteBuffer.hasRemaining:()Z
            ifne 1
        40: .line 578
            aconst_null
            areturn
        end local 0 // org.h2.mvstore.StreamStore$Stream this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0   41     0       this  Lorg/h2/mvstore/StreamStore$Stream;
            3   11     1        len  I
            8   11     2          p  I
            9   11     3          l  I
           12   20     1        len  I
           13   20     2        key  J
           17   20     4       data  [B
           18   20     5          s  I
           21   36     1        len  J
           22   36     3        key  J
           26   36     5          k  [B
           31   36     6  newBuffer  Ljava/nio/ByteBuffer;
}
SourceFile: "StreamStore.java"
NestHost: org.h2.mvstore.StreamStore
InnerClasses:
  Stream = org.h2.mvstore.StreamStore$Stream of org.h2.mvstore.StreamStore