src/jdk.jfr/share/classes/jdk/jfr/consumer/EventFileStream.java
branchJEP-349-branch
changeset 57861 86022e34ba63
parent 57690 9316d02dd4a5
child 57971 aa7b1ea52413
equal deleted inserted replaced
57860:588a3f63efff 57861:86022e34ba63
    75                     close();
    75                     close();
    76                     return;
    76                     return;
    77                 }
    77                 }
    78                 StreamConfiguration c2 = configuration;
    78                 StreamConfiguration c2 = configuration;
    79                 boolean ordered = c2.getOrdered();
    79                 boolean ordered = c2.getOrdered();
       
    80                 chunkParser.setFlushOperation(flushOperation);
    80                 chunkParser.setFirstNanos(start);
    81                 chunkParser.setFirstNanos(start);
    81                 chunkParser.setLastNanos(end);
    82                 chunkParser.setLastNanos(end);
    82                 chunkParser.setReuse(c2.getReuse());
    83                 chunkParser.setReuse(c2.getReuse());
    83                 chunkParser.setOrdered(ordered);
    84                 chunkParser.setOrdered(ordered);
    84                 chunkParser.resetEventCache();
    85                 chunkParser.resetEventCache();
    88                 if (ordered) {
    89                 if (ordered) {
    89                     processOrdered();
    90                     processOrdered();
    90                 } else {
    91                 } else {
    91                     processUnordered();
    92                     processUnordered();
    92                 }
    93                 }
    93                 runFlushActions();
       
    94                 if (chunkParser.isLastChunk()) {
    94                 if (chunkParser.isLastChunk()) {
    95                     return;
    95                     return;
    96                 }
    96                 }
    97                 chunkParser = chunkParser.nextChunkParser();
    97                 chunkParser = chunkParser.nextChunkParser();
    98             }
    98             }