Fixed a timing issue in the test code.

chiroito · May 10, 2023 · 8db859c · 8db859c
1 parent aafd2f3
commit 8db859c
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/jdbc42/src/test/java/dev/jfr4jdbc/internal/JfrResourceMonitorTest.java b/jdbc42/src/test/java/dev/jfr4jdbc/internal/JfrResourceMonitorTest.java
@@ -88,6 +88,7 @@ void datasourceUsageCount() throws Exception {
         fr.stop();
 
         List<RecordedEvent> events = fr.getEvents("ConnectionResource", e -> e.getString("label").equals("ds" + labelId));
+        events.sort((o1, o2) -> o1.getStartTime().compareTo(o2.getStartTime()));
         assertEquals(3, events.size());
         RecordedEvent first = events.get(0);
         assertEquals(0, first.getInt("usage"));
@@ -115,6 +116,7 @@ void connectionUsageCount() throws Exception {
         fr.stop();
 
         List<RecordedEvent> events = fr.getEvents("ConnectionResource", e -> e.getString("label").equals("con" + labelId));
+        events.sort((o1, o2) -> o1.getStartTime().compareTo(o2.getStartTime()));
         assertEquals(2, events.size());
         RecordedEvent first = events.get(0);
         assertEquals(1, first.getInt("usage"));
@@ -144,12 +146,15 @@ void datasourceAndConnectionUsageCount() throws Exception {
         fr.stop();
 
         List<RecordedEvent> conEvents = fr.getEvents("ConnectionResource", e -> e.getString("label").equals("con" + labelId));
+        conEvents.sort((o1, o2) -> o1.getStartTime().compareTo(o2.getStartTime()));
         assertEquals(2, conEvents.size());
         RecordedEvent first = conEvents.get(0);
         assertEquals(1, first.getInt("usage"));
         RecordedEvent second = conEvents.get(1);
         assertEquals(0, second.getInt("usage"));
+
         List<RecordedEvent> dsEvents = fr.getEvents("ConnectionResource", e -> e.getString("label").equals("ds" + labelId));
+        dsEvents.sort((o1, o2) -> o1.getStartTime().compareTo(o2.getStartTime()));
         assertEquals(3, dsEvents.size());
         RecordedEvent dsFirst = dsEvents.get(0);
         assertEquals(0, dsFirst.getInt("usage"));
@@ -193,6 +198,7 @@ void datasourceWaitCount() throws Exception {
         fr.stop();
 
         List<RecordedEvent> events = fr.getEvents("ConnectionResource", e -> e.getString("label").equals("ds" + labelId));
+        events.sort((o1, o2) -> o1.getStartTime().compareTo(o2.getStartTime()));
         assertEquals(4, events.size());
         RecordedEvent first = events.get(0);
         assertEquals(0, first.getInt("wait"));
@@ -266,6 +272,7 @@ void eachDatasourceWaitCount() throws Exception {
         assertTrue(e6.getInt("wait") <= 2);
 
         List<RecordedEvent> events2 = fr.getEvents("ConnectionResource", e -> e.getString("label").equals("ds" + labelId + "_2"));
+        events2.sort((o1, o2) -> o1.getStartTime().compareTo(o2.getStartTime()));
         assertEquals(6, events2.size());
         RecordedEvent f1 = events2.get(0);
         assertEquals(0, f1.getInt("wait"));