src/jdk.jfr/share/classes/jdk/jfr/consumer/ChunkParser.java
branchJEP-349-branch
changeset 58020 f082177c5023
parent 57985 be121cbf3284
child 58129 7b751fe181a5
equal deleted inserted replaced
57997:8dea18a54031 58020:f082177c5023
    52     static final byte CHECKPOINT_FLUSH_MASK = 1;
    52     static final byte CHECKPOINT_FLUSH_MASK = 1;
    53     // Checkpoint contains chunk header information in the first pool
    53     // Checkpoint contains chunk header information in the first pool
    54     static final byte CHECKPOINT_CHUNK_HEADER_MASK = 2;
    54     static final byte CHECKPOINT_CHUNK_HEADER_MASK = 2;
    55     // Checkpoint contains only statics that will not change from chunk to chunk
    55     // Checkpoint contains only statics that will not change from chunk to chunk
    56     static final byte CHECKPOINT_STATICS_MASK = 4;
    56     static final byte CHECKPOINT_STATICS_MASK = 4;
    57     // Checkpoint contains thread realted information
    57     // Checkpoint contains thread related information
    58     static final byte CHECKPOINT_THREADS_MASK = 8;
    58     static final byte CHECKPOINT_THREADS_MASK = 8;
    59 
    59 
    60     private static final long CONSTANT_POOL_TYPE_ID = 1;
    60     private static final long CONSTANT_POOL_TYPE_ID = 1;
    61     private static final String CHUNKHEADER = "jdk.types.ChunkHeader";
    61     private static final String CHUNKHEADER = "jdk.types.ChunkHeader";
    62     private final RecordingInput input;
    62     private final RecordingInput input;
   207         return null;
   207         return null;
   208     }
   208     }
   209 
   209 
   210     private void parseCheckpoint() throws IOException {
   210     private void parseCheckpoint() throws IOException {
   211         // Content has been parsed previously. This
   211         // Content has been parsed previously. This
   212         // is for triggering flsuh
   212         // is to trigger flush
   213         input.readLong(); // timestamp
   213         input.readLong(); // timestamp
   214         input.readLong(); // duration
   214         input.readLong(); // duration
   215         input.readLong(); // delta
   215         input.readLong(); // delta
   216         byte c = input.readByte();
   216         byte c = input.readByte();
   217         if ((c & CHECKPOINT_FLUSH_MASK)== 1) {
   217         if ((c & CHECKPOINT_FLUSH_MASK)== 1) {
   447     }
   447     }
   448 
   448 
   449     public long getStartNanos() {
   449     public long getStartNanos() {
   450         return chunkHeader.getStartNanos();
   450         return chunkHeader.getStartNanos();
   451     }
   451     }
   452 
       
   453 
       
   454 }
   452 }