equal
deleted
inserted
replaced
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; |