1 /*

     2  * Copyright (c) 2018, Oracle and/or its affiliates. All rights reserved.

     3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.

     4  *

     5  * This code is free software; you can redistribute it and/or modify it

     6  * under the terms of the GNU General Public License version 2 only, as

     7  * published by the Free Software Foundation.  Oracle designates this

     8  * particular file as subject to the "Classpath" exception as provided

     9  * by Oracle in the LICENSE file that accompanied this code.

    10  *

    11  * This code is distributed in the hope that it will be useful, but WITHOUT

    12  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or

    13  * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License

    14  * version 2 for more details (a copy is included in the LICENSE file that

    15  * accompanied this code).

    16  *

    17  * You should have received a copy of the GNU General Public License version

    18  * 2 along with this work; if not, write to the Free Software Foundation,

    19  * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.

    20  *

    21  * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA

    22  * or visit www.oracle.com if you need additional information or have any

    23  * questions.

    24  */

    25 

    26 package jdk.jfr.api.recording.event;

    27 

    28 import java.time.Instant;

    29 import java.util.ArrayList;

    30 import java.util.Collections;

    31 import java.util.List;

    32 

    33 import jdk.jfr.Event;

    34 import jdk.jfr.Recording;

    35 import jdk.jfr.consumer.RecordedEvent;

    36 import jdk.test.lib.Asserts;

    37 import jdk.test.lib.jfr.CommonHelper;

    38 import jdk.test.lib.jfr.EventNames;

    39 import jdk.test.lib.jfr.Events;

    40 

    41 /*

    42  * @test

    43  * @summary Test getStartTime() and getEndTime(). Verify startTime <= endTime

    44  * @key jfr

    45  * @library /test/lib

    46  * @run main/othervm jdk.jfr.api.recording.event.TestEventTime

    47  */

    48 public class TestEventTime {

    49 

    50     static List<TimeEvent> actualOrder = new ArrayList<>();

    51 

    52     public static void main(String[] args) throws Throwable {

    53         Recording r = new Recording();

    54         r.enable(MyEvent.class).withoutStackTrace();

    55         // for debugging time related issues

    56         r.enable(EventNames.CPUTimeStampCounter);

    57         r.start();

    58         MyEvent event1 = beginEvent(1);

    59         MyEvent event2 = beginEvent(2);

    60         endEvent(event1);

    61         MyEvent event3 = beginEvent(3);

    62         endEvent(event2);

    63         endEvent(event3);

    64 

    65         r.stop();

    66 

    67         List<RecordedEvent> events = Events.fromRecording(r);

    68 

    69         RecordedEvent recEvent1 = findEvent(1, events);

    70         RecordedEvent recEvent2 = findEvent(2, events);

    71         RecordedEvent recEvent3 = findEvent(3, events);

    72 

    73         List<TimeEvent> recordedOrder = new ArrayList<>();

    74         recordedOrder.add(new TimeEvent(1, true, recEvent1.getStartTime()));

    75         recordedOrder.add(new TimeEvent(1, false, recEvent1.getEndTime()));

    76         recordedOrder.add(new TimeEvent(2, true, recEvent2.getStartTime()));

    77         recordedOrder.add(new TimeEvent(2, false, recEvent2.getEndTime()));

    78         recordedOrder.add(new TimeEvent(3, true, recEvent3.getStartTime()));

    79         recordedOrder.add(new TimeEvent(3, false, recEvent3.getEndTime()));

    80         Collections.sort(recordedOrder);

    81 

    82         printTimedEvents("Actual order", actualOrder);

    83         printTimedEvents("Recorded order", recordedOrder);

    84 

    85         for (int i = 0; i < 6; i++) {

    86             if (!actualOrder.get(i).equals(recordedOrder.get(i))) {

    87                 throw new Exception("Event times not in expected order. Was " + recordedOrder.get(1) + " but expected " + actualOrder.get(1));

    88             }

    89         }

    90     }

    91 

    92     private static void printTimedEvents(String heading, List<TimeEvent> recordedOrder) {

    93         System.out.println();

    94         System.out.println(heading);

    95         System.out.println("======================");

    96         for (TimeEvent t : recordedOrder) {

    97             System.out.println(t.toString());

    98         }

    99     }

   100 

   101     private static MyEvent beginEvent(int id) throws Exception {

   102         MyEvent event = new MyEvent(id);

   103         event.begin();

   104         if (!CommonHelper.hasFastTimeEnabled()) {

   105             CommonHelper.waitForSystemCurrentMillisToChange();;

   106         }

   107         actualOrder.add(new TimeEvent(id, true));

   108         return event;

   109     }

   110 

   111     private static void endEvent(MyEvent event) throws Exception {

   112         event.end();

   113         if (!CommonHelper.hasFastTimeEnabled()) {

   114             CommonHelper.waitForSystemCurrentMillisToChange();;

   115         }

   116         event.commit();

   117         actualOrder.add(new TimeEvent(event.id, false));

   118     }

   119 

   120     private final static class TimeEvent implements Comparable<TimeEvent> {

   121         long id;

   122         private boolean begin;

   123         private Instant time;

   124 

   125         public TimeEvent(int id, boolean begin) {

   126             this.id = id;

   127             this.begin = begin;

   128         }

   129 

   130         public TimeEvent(int id, boolean begin, Instant time) {

   131             this(id, begin);

   132             this.time = time;

   133         }

   134 

   135         @Override

   136         public int compareTo(TimeEvent that) {

   137             return this.time.compareTo(that.time);

   138         }

   139 

   140         public String toString() {

   141             StringBuilder sb = new StringBuilder();

   142             if (begin) {

   143                 sb.append("begin");

   144             } else {

   145                 sb.append("end");

   146             }

   147             sb.append("Event");

   148             sb.append("(");

   149             sb.append(id);

   150             sb.append(")");

   151             return sb.toString();

   152         }

   153 

   154         public boolean equals(Object thatObject) {

   155             if (thatObject instanceof TimeEvent) {

   156                 TimeEvent that = (TimeEvent) thatObject;

   157                 return that.id == this.id && that.begin == this.begin;

   158             }

   159             return false;

   160         }

   161     }

   162 

   163     private static RecordedEvent findEvent(int id, List<RecordedEvent> events) {

   164         for (RecordedEvent event : events) {

   165             if (!event.getEventType().getName().equals(EventNames.CPUTimeStampCounter)) {

   166                 int eventId = Events.assertField(event, "id").getValue();

   167                 if (eventId == id) {

   168                     return event;

   169                 }

   170             }

   171         }

   172         Asserts.fail("No event with id " + id);

   173         return null;

   174     }

   175 

   176     private static class MyEvent extends Event {

   177         int id;

   178 

   179         public MyEvent(int id) {

   180             this.id = id;

   181         }

   182     }

   183 }