public final class jdk.jfr.internal.consumer.OngoingStream extends jdk.jfr.internal.management.EventByteStream
  minor version: 0
  major version: 59
  flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
  this_class: jdk.jfr.internal.consumer.OngoingStream
  super_class: jdk.jfr.internal.management.EventByteStream
{
  private static final byte[] EMPTY_ARRAY;
    descriptor: [B
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private static final int HEADER_SIZE;
    descriptor: I
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: 68

  private static final int HEADER_FILE_STATE_POSITION;
    descriptor: I
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: 64

  private static final byte MODIFYING_STATE;
    descriptor: B
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: -1

  private final jdk.jfr.internal.consumer.RepositoryFiles repositoryFiles;
    descriptor: Ljdk/jfr/internal/consumer/RepositoryFiles;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final jdk.jfr.Recording recording;
    descriptor: Ljdk/jfr/Recording;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

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

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

  private final byte[] headerBytes;
    descriptor: [B
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private jdk.jfr.internal.consumer.RecordingInput input;
    descriptor: Ljdk/jfr/internal/consumer/RecordingInput;
    flags: (0x0002) ACC_PRIVATE

  private jdk.jfr.internal.consumer.ChunkHeader header;
    descriptor: Ljdk/jfr/internal/consumer/ChunkHeader;
    flags: (0x0002) ACC_PRIVATE

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

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

  private java.nio.file.Path path;
    descriptor: Ljava/nio/file/Path;
    flags: (0x0002) ACC_PRIVATE

  private boolean first;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 42
            iconst_0
            newarray 8
            putstatic jdk.jfr.internal.consumer.OngoingStream.EMPTY_ARRAY:[B
         1: .line 45
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>(jdk.jfr.Recording, int, long, long);
    descriptor: (Ljdk/jfr/Recording;IJJ)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=7, args_size=5
        start local 0 // jdk.jfr.internal.consumer.OngoingStream this
        start local 1 // jdk.jfr.Recording recording
        start local 2 // int blockSize
        start local 3 // long startTimeNanos
        start local 5 // long endTimeNanos
         0: .line 61
            aload 0 /* this */
            invokespecial jdk.jfr.internal.management.EventByteStream.<init>:()V
         1: .line 51
            aload 0 /* this */
            bipush 68
            newarray 8
            putfield jdk.jfr.internal.consumer.OngoingStream.headerBytes:[B
         2: .line 58
            aload 0 /* this */
            iconst_1
            putfield jdk.jfr.internal.consumer.OngoingStream.first:Z
         3: .line 62
            aload 0 /* this */
            aload 1 /* recording */
            putfield jdk.jfr.internal.consumer.OngoingStream.recording:Ljdk/jfr/Recording;
         4: .line 63
            aload 0 /* this */
            iload 2 /* blockSize */
            putfield jdk.jfr.internal.consumer.OngoingStream.blockSize:I
         5: .line 64
            aload 0 /* this */
            lload 3 /* startTimeNanos */
            putfield jdk.jfr.internal.consumer.OngoingStream.startTimeNanos:J
         6: .line 65
            aload 0 /* this */
            lload 5 /* endTimeNanos */
            putfield jdk.jfr.internal.consumer.OngoingStream.endTimeNanos:J
         7: .line 66
            aload 0 /* this */
            new jdk.jfr.internal.consumer.RepositoryFiles
            dup
            getstatic jdk.jfr.internal.SecuritySupport.PRIVILEGED:Ljdk/jfr/internal/consumer/FileAccess;
            aconst_null
            invokespecial jdk.jfr.internal.consumer.RepositoryFiles.<init>:(Ljdk/jfr/internal/consumer/FileAccess;Ljava/nio/file/Path;)V
            putfield jdk.jfr.internal.consumer.OngoingStream.repositoryFiles:Ljdk/jfr/internal/consumer/RepositoryFiles;
         8: .line 67
            return
        end local 5 // long endTimeNanos
        end local 3 // long startTimeNanos
        end local 2 // int blockSize
        end local 1 // jdk.jfr.Recording recording
        end local 0 // jdk.jfr.internal.consumer.OngoingStream this
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0    9     0            this  Ljdk/jfr/internal/consumer/OngoingStream;
            0    9     1       recording  Ljdk/jfr/Recording;
            0    9     2       blockSize  I
            0    9     3  startTimeNanos  J
            0    9     5    endTimeNanos  J
    MethodParameters:
                Name  Flags
      recording       
      blockSize       
      startTimeNanos  
      endTimeNanos    

  public synchronized byte[] read();
    descriptor: ()[B
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // jdk.jfr.internal.consumer.OngoingStream this
         0: .line 71
            aload 0 /* this */
            invokevirtual jdk.jfr.internal.consumer.OngoingStream.readBytes:()[B
         1: areturn
         2: .line 72
      StackMap locals:
      StackMap stack: java.io.IOException
            astore 1 /* ioe */
        start local 1 // java.io.IOException ioe
         3: .line 73
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.recording:Ljdk/jfr/Recording;
            invokevirtual jdk.jfr.Recording.getState:()Ljdk/jfr/RecordingState;
            getstatic jdk.jfr.RecordingState.CLOSED:Ljdk/jfr/RecordingState;
            if_acmpne 5
         4: .line 75
            aconst_null
            areturn
         5: .line 78
      StackMap locals: java.io.IOException
      StackMap stack:
            aload 1 /* ioe */
            athrow
        end local 1 // java.io.IOException ioe
        end local 0 // jdk.jfr.internal.consumer.OngoingStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Ljdk/jfr/internal/consumer/OngoingStream;
            3    6     1   ioe  Ljava/io/IOException;
      Exception table:
        from    to  target  type
           0     1       2  Class java.io.IOException
    Exceptions:
      throws java.io.IOException

  private byte[] readBytes();
    descriptor: ()[B
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=3, args_size=1
        start local 0 // jdk.jfr.internal.consumer.OngoingStream this
         0: .line 83
            aload 0 /* this */
            invokevirtual jdk.jfr.internal.consumer.OngoingStream.touch:()V
         1: .line 84
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.recording:Ljdk/jfr/Recording;
            invokevirtual jdk.jfr.Recording.getState:()Ljdk/jfr/RecordingState;
            getstatic jdk.jfr.RecordingState.NEW:Ljdk/jfr/RecordingState;
            if_acmpne 3
         2: .line 85
            getstatic jdk.jfr.internal.consumer.OngoingStream.EMPTY_ARRAY:[B
            areturn
         3: .line 88
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.recording:Ljdk/jfr/Recording;
            invokevirtual jdk.jfr.Recording.getState:()Ljdk/jfr/RecordingState;
            getstatic jdk.jfr.RecordingState.DELAYED:Ljdk/jfr/RecordingState;
            if_acmpne 5
         4: .line 89
            getstatic jdk.jfr.internal.consumer.OngoingStream.EMPTY_ARRAY:[B
            areturn
         5: .line 92
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.first:Z
            ifeq 9
         6: .line 94
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.recording:Ljdk/jfr/Recording;
            invokestatic jdk.jfr.internal.management.ManagementSupport.getStartTimeNanos:(Ljdk/jfr/Recording;)J
            lstore 1 /* s */
        start local 1 // long s
         7: .line 95
            aload 0 /* this */
            lload 1 /* s */
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.startTimeNanos:J
            invokestatic java.lang.Math.max:(JJ)J
            putfield jdk.jfr.internal.consumer.OngoingStream.startTimeNanos:J
         8: .line 96
            aload 0 /* this */
            iconst_0
            putfield jdk.jfr.internal.consumer.OngoingStream.first:Z
        end local 1 // long s
         9: .line 100
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.startTimeNanos:J
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.endTimeNanos:J
            lcmp
            ifle 11
        10: .line 101
            aconst_null
            areturn
        11: .line 103
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual jdk.jfr.internal.consumer.OngoingStream.isRecordingClosed:()Z
            ifeq 14
        12: .line 104
            aload 0 /* this */
            invokevirtual jdk.jfr.internal.consumer.OngoingStream.closeInput:()V
        13: .line 105
            aconst_null
            areturn
        14: .line 107
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual jdk.jfr.internal.consumer.OngoingStream.ensurePath:()Z
            ifne 16
        15: .line 108
            getstatic jdk.jfr.internal.consumer.OngoingStream.EMPTY_ARRAY:[B
            areturn
        16: .line 110
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual jdk.jfr.internal.consumer.OngoingStream.ensureInput:()Z
            ifne 18
        17: .line 111
            getstatic jdk.jfr.internal.consumer.OngoingStream.EMPTY_ARRAY:[B
            areturn
        18: .line 113
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.position:J
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.header:Ljdk/jfr/internal/consumer/ChunkHeader;
            invokevirtual jdk.jfr.internal.consumer.ChunkHeader.getChunkSize:()J
            lcmp
            ifge 21
        19: .line 114
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.header:Ljdk/jfr/internal/consumer/ChunkHeader;
            invokevirtual jdk.jfr.internal.consumer.ChunkHeader.getChunkSize:()J
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.position:J
            lsub
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.blockSize:I
            i2l
            invokestatic java.lang.Math.min:(JJ)J
            lstore 1 /* size */
        start local 1 // long size
        20: .line 115
            aload 0 /* this */
            lload 1 /* size */
            l2i
            invokevirtual jdk.jfr.internal.consumer.OngoingStream.readBytes:(I)[B
            areturn
        end local 1 // long size
        21: .line 117
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.header:Ljdk/jfr/internal/consumer/ChunkHeader;
            invokevirtual jdk.jfr.internal.consumer.ChunkHeader.isFinished:()Z
            ifeq 28
        22: .line 118
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.header:Ljdk/jfr/internal/consumer/ChunkHeader;
            invokevirtual jdk.jfr.internal.consumer.ChunkHeader.getDurationNanos:()J
            lconst_1
            lcmp
            ifge 24
        23: .line 119
            new java.io.IOException
            dup
            ldc "No progress"
            invokespecial java.io.IOException.<init>:(Ljava/lang/String;)V
            athrow
        24: .line 121
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            dup
            getfield jdk.jfr.internal.consumer.OngoingStream.startTimeNanos:J
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.header:Ljdk/jfr/internal/consumer/ChunkHeader;
            invokevirtual jdk.jfr.internal.consumer.ChunkHeader.getDurationNanos:()J
            ladd
            putfield jdk.jfr.internal.consumer.OngoingStream.startTimeNanos:J
        25: .line 122
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.recording:Ljdk/jfr/Recording;
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.path:Ljava/nio/file/Path;
            invokestatic jdk.jfr.internal.management.ManagementSupport.removePath:(Ljdk/jfr/Recording;Ljava/nio/file/Path;)V
        26: .line 123
            aload 0 /* this */
            invokevirtual jdk.jfr.internal.consumer.OngoingStream.closeInput:()V
        27: .line 124
            goto 9
        28: .line 125
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.header:Ljdk/jfr/internal/consumer/ChunkHeader;
            invokevirtual jdk.jfr.internal.consumer.ChunkHeader.refresh:()V
        29: .line 126
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.position:J
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.header:Ljdk/jfr/internal/consumer/ChunkHeader;
            invokevirtual jdk.jfr.internal.consumer.ChunkHeader.getChunkSize:()J
            lcmp
            iflt 9
        30: .line 127
            getstatic jdk.jfr.internal.consumer.OngoingStream.EMPTY_ARRAY:[B
            areturn
        end local 0 // jdk.jfr.internal.consumer.OngoingStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   31     0  this  Ljdk/jfr/internal/consumer/OngoingStream;
            7    9     1     s  J
           20   21     1  size  J
    Exceptions:
      throws java.io.IOException

  private boolean isRecordingClosed();
    descriptor: ()Z
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // jdk.jfr.internal.consumer.OngoingStream this
         0: .line 134
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.recording:Ljdk/jfr/Recording;
            ifnull 1
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.recording:Ljdk/jfr/Recording;
            invokevirtual jdk.jfr.Recording.getState:()Ljdk/jfr/RecordingState;
            getstatic jdk.jfr.RecordingState.CLOSED:Ljdk/jfr/RecordingState;
            if_acmpne 1
            iconst_1
            ireturn
      StackMap locals:
      StackMap stack:
         1: iconst_0
            ireturn
        end local 0 // jdk.jfr.internal.consumer.OngoingStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Ljdk/jfr/internal/consumer/OngoingStream;

  private void closeInput();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // jdk.jfr.internal.consumer.OngoingStream this
         0: .line 138
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.input:Ljdk/jfr/internal/consumer/RecordingInput;
            ifnull 7
         1: .line 140
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.input:Ljdk/jfr/internal/consumer/RecordingInput;
            invokevirtual jdk.jfr.internal.consumer.RecordingInput.close:()V
         2: .line 141
            goto 4
      StackMap locals:
      StackMap stack: java.io.IOException
         3: pop
         4: .line 144
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aconst_null
            putfield jdk.jfr.internal.consumer.OngoingStream.input:Ljdk/jfr/internal/consumer/RecordingInput;
         5: .line 145
            aload 0 /* this */
            lconst_0
            putfield jdk.jfr.internal.consumer.OngoingStream.position:J
         6: .line 146
            aload 0 /* this */
            aconst_null
            putfield jdk.jfr.internal.consumer.OngoingStream.path:Ljava/nio/file/Path;
         7: .line 148
      StackMap locals:
      StackMap stack:
            return
        end local 0 // jdk.jfr.internal.consumer.OngoingStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    8     0  this  Ljdk/jfr/internal/consumer/OngoingStream;
      Exception table:
        from    to  target  type
           1     2       3  Class java.io.IOException

  private byte[] readBytes(int);
    descriptor: (I)[B
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // jdk.jfr.internal.consumer.OngoingStream this
        start local 1 // int size
         0: .line 151
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.position:J
            lconst_0
            lcmp
            ifne 2
         1: .line 152
            aload 0 /* this */
            iload 1 /* size */
            invokevirtual jdk.jfr.internal.consumer.OngoingStream.readWithHeader:(I)[B
            areturn
         2: .line 154
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iload 1 /* size */
            invokevirtual jdk.jfr.internal.consumer.OngoingStream.readNonHeader:(I)[B
            areturn
        end local 1 // int size
        end local 0 // jdk.jfr.internal.consumer.OngoingStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Ljdk/jfr/internal/consumer/OngoingStream;
            0    3     1  size  I
    Exceptions:
      throws java.io.IOException
    MethodParameters:
      Name  Flags
      size  

  private byte[] readNonHeader(int);
    descriptor: (I)[B
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=3, args_size=2
        start local 0 // jdk.jfr.internal.consumer.OngoingStream this
        start local 1 // int size
         0: .line 159
            iload 1 /* size */
            newarray 8
            astore 2 /* result */
        start local 2 // byte[] result
         1: .line 160
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.input:Ljdk/jfr/internal/consumer/RecordingInput;
            aload 2 /* result */
            invokevirtual jdk.jfr.internal.consumer.RecordingInput.readFully:([B)V
         2: .line 161
            aload 0 /* this */
            dup
            getfield jdk.jfr.internal.consumer.OngoingStream.position:J
            iload 1 /* size */
            i2l
            ladd
            putfield jdk.jfr.internal.consumer.OngoingStream.position:J
         3: .line 162
            aload 2 /* result */
            areturn
        end local 2 // byte[] result
        end local 1 // int size
        end local 0 // jdk.jfr.internal.consumer.OngoingStream this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    4     0    this  Ljdk/jfr/internal/consumer/OngoingStream;
            0    4     1    size  I
            1    4     2  result  [B
    Exceptions:
      throws java.io.IOException
    MethodParameters:
      Name  Flags
      size  

  private byte[] readWithHeader(int);
    descriptor: (I)[B
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=6, args_size=2
        start local 0 // jdk.jfr.internal.consumer.OngoingStream this
        start local 1 // int size
         0: .line 166
            bipush 68
            iload 1 /* size */
            invokestatic java.lang.Math.max:(II)I
            newarray 8
            astore 2 /* bytes */
        start local 2 // byte[] bytes
         1: .line 167
            iconst_0
            istore 3 /* attempts */
        start local 3 // int attempts
         2: goto 21
         3: .line 169
      StackMap locals: byte[] int
      StackMap stack:
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.input:Ljdk/jfr/internal/consumer/RecordingInput;
            lconst_0
            invokevirtual jdk.jfr.internal.consumer.RecordingInput.position:(J)V
         4: .line 170
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.input:Ljdk/jfr/internal/consumer/RecordingInput;
            aload 2 /* bytes */
            iconst_0
            bipush 68
            invokevirtual jdk.jfr.internal.consumer.RecordingInput.readFully:([BII)V
         5: .line 171
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.input:Ljdk/jfr/internal/consumer/RecordingInput;
            lconst_0
            invokevirtual jdk.jfr.internal.consumer.RecordingInput.position:(J)V
         6: .line 172
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.input:Ljdk/jfr/internal/consumer/RecordingInput;
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.headerBytes:[B
            invokevirtual jdk.jfr.internal.consumer.RecordingInput.readFully:([B)V
         7: .line 173
            aload 2 /* bytes */
            bipush 64
            baload
            iconst_m1
            if_icmpeq 19
         8: .line 174
            aload 2 /* bytes */
            bipush 64
            baload
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.headerBytes:[B
            bipush 64
            baload
            if_icmpne 19
         9: .line 175
            aload 2 /* bytes */
            invokestatic java.nio.ByteBuffer.wrap:([B)Ljava/nio/ByteBuffer;
            astore 4 /* buffer */
        start local 4 // java.nio.ByteBuffer buffer
        10: .line 180
            aload 4 /* buffer */
            bipush 8
            ldc 68
            invokevirtual java.nio.ByteBuffer.putLong:(IJ)Ljava/nio/ByteBuffer;
            pop
        11: .line 182
            aload 4 /* buffer */
            bipush 16
            lconst_0
            invokevirtual java.nio.ByteBuffer.putLong:(IJ)Ljava/nio/ByteBuffer;
            pop
        12: .line 184
            aload 4 /* buffer */
            bipush 24
            lconst_0
            invokevirtual java.nio.ByteBuffer.putLong:(IJ)Ljava/nio/ByteBuffer;
            pop
        13: .line 187
            aload 4 /* buffer */
            bipush 40
            lconst_0
            invokevirtual java.nio.ByteBuffer.putLong:(IJ)Ljava/nio/ByteBuffer;
            pop
        14: .line 191
            aload 4 /* buffer */
            bipush 64
            iconst_1
            invokevirtual java.nio.ByteBuffer.put:(IB)Ljava/nio/ByteBuffer;
            pop
        15: .line 193
            aload 2 /* bytes */
            arraylength
            bipush 68
            isub
            istore 5 /* left */
        start local 5 // int left
        16: .line 194
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.input:Ljdk/jfr/internal/consumer/RecordingInput;
            aload 2 /* bytes */
            bipush 68
            iload 5 /* left */
            invokevirtual jdk.jfr.internal.consumer.RecordingInput.readFully:([BII)V
        17: .line 195
            aload 0 /* this */
            dup
            getfield jdk.jfr.internal.consumer.OngoingStream.position:J
            aload 2 /* bytes */
            arraylength
            i2l
            ladd
            putfield jdk.jfr.internal.consumer.OngoingStream.position:J
        18: .line 196
            aload 2 /* bytes */
            areturn
        end local 5 // int left
        end local 4 // java.nio.ByteBuffer buffer
        19: .line 199
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual jdk.jfr.internal.consumer.OngoingStream.takeNap:()V
        20: .line 167
            iinc 3 /* attempts */ 1
      StackMap locals:
      StackMap stack:
        21: iload 3 /* attempts */
            bipush 25
            if_icmplt 3
        end local 3 // int attempts
        22: .line 201
            getstatic jdk.jfr.internal.consumer.OngoingStream.EMPTY_ARRAY:[B
            areturn
        end local 2 // byte[] bytes
        end local 1 // int size
        end local 0 // jdk.jfr.internal.consumer.OngoingStream this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   23     0      this  Ljdk/jfr/internal/consumer/OngoingStream;
            0   23     1      size  I
            1   23     2     bytes  [B
            2   22     3  attempts  I
           10   19     4    buffer  Ljava/nio/ByteBuffer;
           16   19     5      left  I
    Exceptions:
      throws java.io.IOException
    MethodParameters:
      Name  Flags
      size  

  private void takeNap();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=2, args_size=1
        start local 0 // jdk.jfr.internal.consumer.OngoingStream this
         0: .line 206
            ldc 10
            invokestatic java.lang.Thread.sleep:(J)V
         1: .line 207
            goto 4
      StackMap locals:
      StackMap stack: java.lang.InterruptedException
         2: astore 1 /* ie */
        start local 1 // java.lang.InterruptedException ie
         3: .line 208
            new java.io.IOException
            dup
            ldc "Read operation interrupted"
            aload 1 /* ie */
            invokespecial java.io.IOException.<init>:(Ljava/lang/String;Ljava/lang/Throwable;)V
            athrow
        end local 1 // java.lang.InterruptedException ie
         4: .line 210
      StackMap locals:
      StackMap stack:
            return
        end local 0 // jdk.jfr.internal.consumer.OngoingStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Ljdk/jfr/internal/consumer/OngoingStream;
            3    4     1    ie  Ljava/lang/InterruptedException;
      Exception table:
        from    to  target  type
           0     1       2  Class java.lang.InterruptedException
    Exceptions:
      throws java.io.IOException

  private boolean ensureInput();
    descriptor: ()Z
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=1, args_size=1
        start local 0 // jdk.jfr.internal.consumer.OngoingStream this
         0: .line 213
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.input:Ljdk/jfr/internal/consumer/RecordingInput;
            ifnonnull 5
         1: .line 214
            new jdk.jfr.internal.SecuritySupport$SafePath
            dup
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.path:Ljava/nio/file/Path;
            invokespecial jdk.jfr.internal.SecuritySupport$SafePath.<init>:(Ljava/nio/file/Path;)V
            invokestatic jdk.jfr.internal.SecuritySupport.getFileSize:(Ljdk/jfr/internal/SecuritySupport$SafePath;)J
            ldc 68
            lcmp
            ifge 3
         2: .line 215
            iconst_0
            ireturn
         3: .line 217
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            new jdk.jfr.internal.consumer.RecordingInput
            dup
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.path:Ljava/nio/file/Path;
            invokeinterface java.nio.file.Path.toFile:()Ljava/io/File;
            getstatic jdk.jfr.internal.SecuritySupport.PRIVILEGED:Ljdk/jfr/internal/consumer/FileAccess;
            invokespecial jdk.jfr.internal.consumer.RecordingInput.<init>:(Ljava/io/File;Ljdk/jfr/internal/consumer/FileAccess;)V
            putfield jdk.jfr.internal.consumer.OngoingStream.input:Ljdk/jfr/internal/consumer/RecordingInput;
         4: .line 218
            aload 0 /* this */
            new jdk.jfr.internal.consumer.ChunkHeader
            dup
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.input:Ljdk/jfr/internal/consumer/RecordingInput;
            invokespecial jdk.jfr.internal.consumer.ChunkHeader.<init>:(Ljdk/jfr/internal/consumer/RecordingInput;)V
            putfield jdk.jfr.internal.consumer.OngoingStream.header:Ljdk/jfr/internal/consumer/ChunkHeader;
         5: .line 220
      StackMap locals:
      StackMap stack:
            iconst_1
            ireturn
        end local 0 // jdk.jfr.internal.consumer.OngoingStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Ljdk/jfr/internal/consumer/OngoingStream;
    Exceptions:
      throws java.io.IOException

  private boolean ensurePath();
    descriptor: ()Z
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=1, args_size=1
        start local 0 // jdk.jfr.internal.consumer.OngoingStream this
         0: .line 224
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.path:Ljava/nio/file/Path;
            ifnonnull 2
         1: .line 225
            aload 0 /* this */
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.repositoryFiles:Ljdk/jfr/internal/consumer/RepositoryFiles;
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.startTimeNanos:J
            iconst_0
            invokevirtual jdk.jfr.internal.consumer.RepositoryFiles.nextPath:(JZ)Ljava/nio/file/Path;
            putfield jdk.jfr.internal.consumer.OngoingStream.path:Ljava/nio/file/Path;
         2: .line 227
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.path:Ljava/nio/file/Path;
            ifnull 3
            iconst_1
            ireturn
      StackMap locals:
      StackMap stack:
         3: iconst_0
            ireturn
        end local 0 // jdk.jfr.internal.consumer.OngoingStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Ljdk/jfr/internal/consumer/OngoingStream;

  public synchronized void close();
    descriptor: ()V
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // jdk.jfr.internal.consumer.OngoingStream this
         0: .line 232
            aload 0 /* this */
            invokevirtual jdk.jfr.internal.consumer.OngoingStream.closeInput:()V
         1: .line 234
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.recording:Ljdk/jfr/Recording;
            invokevirtual jdk.jfr.Recording.getName:()Ljava/lang/String;
            ldc "Remote Recording Stream"
            invokevirtual java.lang.String.startsWith:(Ljava/lang/String;)Z
            ifeq 3
         2: .line 235
            aload 0 /* this */
            getfield jdk.jfr.internal.consumer.OngoingStream.recording:Ljdk/jfr/Recording;
            invokevirtual jdk.jfr.Recording.close:()V
         3: .line 237
      StackMap locals:
      StackMap stack:
            return
        end local 0 // jdk.jfr.internal.consumer.OngoingStream this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Ljdk/jfr/internal/consumer/OngoingStream;
    Exceptions:
      throws java.io.IOException
}
SourceFile: "OngoingStream.java"
InnerClasses:
  public final SafePath = jdk.jfr.internal.SecuritySupport$SafePath of jdk.jfr.internal.SecuritySupport