src/jdk.jfr/share/classes/jdk/jfr/consumer/EventFileStream.java
branchJEP-349-branch
changeset 57452 6fabe73e5d9a
parent 57449 099789ceff7d
child 57604 838f9a7635b6
equal deleted inserted replaced
57449:099789ceff7d 57452:6fabe73e5d9a
    30 import java.security.AccessControlContext;
    30 import java.security.AccessControlContext;
    31 import java.security.AccessController;
    31 import java.security.AccessController;
    32 import java.time.Duration;
    32 import java.time.Duration;
    33 import java.time.Instant;
    33 import java.time.Instant;
    34 import java.util.Arrays;
    34 import java.util.Arrays;
    35 import java.util.Comparator;
       
    36 import java.util.Objects;
    35 import java.util.Objects;
    37 import java.util.function.Consumer;
    36 import java.util.function.Consumer;
    38 
    37 
    39 import jdk.jfr.internal.consumer.RecordingInput;
    38 import jdk.jfr.internal.consumer.RecordingInput;
    40 
    39 
    43  *
    42  *
    44  */
    43  */
    45 final class EventFileStream implements EventStream {
    44 final class EventFileStream implements EventStream {
    46 
    45 
    47     private final static class FileConsumer extends EventConsumer {
    46     private final static class FileConsumer extends EventConsumer {
    48         private static final Comparator<? super RecordedEvent> END_TIME = (e1, e2) -> Long.compare(e1.endTime, e2.endTime);
       
    49         private static final int DEFAULT_ARRAY_SIZE = 100_000;
    47         private static final int DEFAULT_ARRAY_SIZE = 100_000;
    50         private final RecordingInput input;
    48         private final RecordingInput input;
    51         private ChunkParser chunkParser;
    49         private ChunkParser chunkParser;
    52         private boolean reuse = true;
    50         private boolean reuse = true;
    53         private RecordedEvent[] sortedList;
    51         private RecordedEvent[] sortedList;