1 files changed, 66 insertions, 24 deletions
diff --git a/testing/web-platform/tests/compute-pressure/compute_pressure_timestamp.https.any.js b/testing/web-platform/tests/compute-pressure/compute_pressure_timestamp.https.any.js
index 09caeb3478..18db1dac46 100644
--- a/testing/web-platform/tests/compute-pressure/compute_pressure_timestamp.https.any.js
+++ b/testing/web-platform/tests/compute-pressure/compute_pressure_timestamp.https.any.js
@@ -5,32 +5,73 @@
 'use strict';
 
 pressure_test(async (t, mockPressureService) => {
+  const [change, timeOrigin] = await new Promise(resolve => {
+    const observer = new PressureObserver(change => {
+      resolve([change, performance.timeOrigin]);
+    });
+    t.add_cleanup(() => observer.disconnect());
+    observer.observe('cpu');
+    mockPressureService.setPressureUpdate('cpu', 'critical');
+    mockPressureService.startPlatformCollector(/*sampleInterval=*/ 200);
+  });
+  assert_greater_than(change[0].time, timeOrigin);
+}, 'Timestamp from update should be greater than timeOrigin');
+
+pressure_test(async (t, mockPressureService) => {
   const readings = ['nominal', 'fair', 'serious', 'critical'];
 
   const sampleInterval = 250;
-  const pressureChanges = await new Promise(async resolve => {
-    const observerChanges = [];
-    const observer = new PressureObserver(changes => {
-      observerChanges.push(changes);
-    }, {sampleInterval});
-    observer.observe('cpu');
+  const pressureChanges = [];
+  const observer = new PressureObserver(changes => {
+    pressureChanges.push(changes);
+  });
+  observer.observe('cpu', {sampleInterval});
 
-    mockPressureService.startPlatformCollector(sampleInterval / 2);
-    let i = 0;
-    // mockPressureService.updatesDelivered() does not necessarily match
-    // pressureChanges.length, as system load and browser optimizations can
-    // cause the actual timer used by mockPressureService to deliver readings
-    // to be a bit slower or faster than requested.
-    while (observerChanges.length < 4) {
-      mockPressureService.setPressureUpdate(
-          'cpu', readings[i++ % readings.length]);
-      await t.step_wait(
-          () => mockPressureService.updatesDelivered() >= i,
-          `At least ${i} readings have been delivered`);
-    }
-    observer.disconnect();
-    resolve(observerChanges);
+  mockPressureService.startPlatformCollector(sampleInterval / 2);
+  let i = 0;
+  // mockPressureService.updatesDelivered() does not necessarily match
+  // pressureChanges.length, as system load and browser optimizations can
+  // cause the actual timer used by mockPressureService to deliver readings
+  // to be a bit slower or faster than requested.
+  while (pressureChanges.length < 4) {
+    mockPressureService.setPressureUpdate(
+        'cpu', readings[i++ % readings.length]);
+    await t.step_wait(
+        () => mockPressureService.updatesDelivered() >= i,
+        `At least ${i} readings have been delivered`);
+  }
+  observer.disconnect();
+
+  assert_equals(pressureChanges.length, 4);
+  assert_greater_than(pressureChanges[1][0].time, pressureChanges[0][0].time);
+  assert_greater_than(pressureChanges[2][0].time, pressureChanges[1][0].time);
+  assert_greater_than(pressureChanges[3][0].time, pressureChanges[2][0].time);
+}, 'Timestamp difference between two changes should be continuously increasing');
+
+pressure_test(async (t, mockPressureService) => {
+  const readings = ['nominal', 'fair', 'serious', 'critical'];
+
+  const sampleInterval = 250;
+  const pressureChanges = [];
+  const observer = new PressureObserver(change => {
+    pressureChanges.push(change);
   });
+  observer.observe('cpu', {sampleInterval});
+
+  mockPressureService.startPlatformCollector(sampleInterval / 2);
+  let i = 0;
+  // mockPressureService.updatesDelivered() does not necessarily match
+  // pressureChanges.length, as system load and browser optimizations can
+  // cause the actual timer used by mockPressureService to deliver readings
+  // to be a bit slower or faster than requested.
+  while (pressureChanges.length < 4) {
+    mockPressureService.setPressureUpdate(
+        'cpu', readings[i++ % readings.length]);
+    await t.step_wait(
+        () => mockPressureService.updatesDelivered() >= i,
+        `At least ${i} readings have been delivered`);
+  }
+  observer.disconnect();
 
   assert_equals(pressureChanges.length, 4);
   assert_greater_than_equal(
@@ -46,10 +87,10 @@ pressure_test(async (t, mockPressureService) => {
   const sampleInterval = 1000;
   const observer = new PressureObserver(changes => {
     pressureChanges.push(changes);
-  }, {sampleInterval});
+  });
 
   await new Promise(async resolve => {
-    observer.observe('cpu');
+    observer.observe('cpu', {sampleInterval});
     mockPressureService.setPressureUpdate('cpu', 'critical');
     mockPressureService.startPlatformCollector(sampleInterval);
     await t.step_wait(() => pressureChanges.length == 1);
@@ -71,5 +112,6 @@ pressure_test(async (t, mockPressureService) => {
   // should be deleted. So the second PressureRecord is not discarded even
   // though the time interval does not meet the requirement.
   assert_less_than(
-      pressureChanges[1][0].time - pressureChanges[0][0].time, sampleInterval);
+      (pressureChanges[1][0].time - pressureChanges[0][0].time),
+      sampleInterval);
 }, 'disconnect() should update [[LastRecordMap]]');