equal
deleted
inserted
replaced
57 public static void main(String... args) throws Exception { |
57 public static void main(String... args) throws Exception { |
58 try (Recording r = new Recording()) { |
58 try (Recording r = new Recording()) { |
59 r.setFlushInterval(Duration.ofSeconds(1)); |
59 r.setFlushInterval(Duration.ofSeconds(1)); |
60 r.start(); |
60 r.start(); |
61 Mark event1 = new Mark(); |
61 Mark event1 = new Mark(); |
|
62 event1.begin(); // start time |
62 event1.before = true; |
63 event1.before = true; |
63 advanceClock(); |
64 advanceClock(); |
64 event1.commit(); // start time |
65 event1.commit(); |
65 |
66 |
66 Mark event2 = new Mark(); |
67 Mark event2 = new Mark(); |
67 event2.begin(); // end time |
68 event2.begin(); // end time |
68 advanceClock(); |
69 advanceClock(); |
69 // event2.end(); |
|
70 Thread.sleep(100); |
70 Thread.sleep(100); |
71 event2.before = false; |
71 event2.before = false; |
72 event2.commit(); |
72 event2.commit(); |
73 |
73 |
74 Path p = Paths.get("recording.jfr"); |
74 Path p = Paths.get("recording.jfr"); |
83 if (!e.getBoolean("before")) { |
83 if (!e.getBoolean("before")) { |
84 end = e.getStartTime(); |
84 end = e.getStartTime(); |
85 System.out.println("End : " + end); |
85 System.out.println("End : " + end); |
86 } |
86 } |
87 } |
87 } |
88 |
88 System.out.println("==================="); |
89 AtomicBoolean error = new AtomicBoolean(true); |
89 AtomicBoolean error = new AtomicBoolean(true); |
90 try (EventStream d = EventStream.openRepository()) { |
90 try (EventStream d = EventStream.openRepository()) { |
91 d.setStartTime(start); |
91 d.setStartTime(start); |
92 d.setEndTime(end); |
92 d.setEndTime(end); |
93 d.onEvent(e -> { |
93 d.onEvent(e -> { |