1 files changed, 55 insertions, 0 deletions
diff --git a/testing/web-platform/tests/webaudio/the-audio-api/the-audiocontext-interface/processing-after-resume.https.html b/testing/web-platform/tests/webaudio/the-audio-api/the-audiocontext-interface/processing-after-resume.https.html
new file mode 100644
index 0000000000..e000ab124f
--- /dev/null
+++ b/testing/web-platform/tests/webaudio/the-audio-api/the-audiocontext-interface/processing-after-resume.https.html
@@ -0,0 +1,55 @@
+<!doctype html>
+<title>Test consistency of processing after resume()</title>
+<script src=/resources/testharness.js></script>
+<script src=/resources/testharnessreport.js></script>
+<script>
+const get_node_and_reply = (context) => {
+  const node = new AudioWorkletNode(context, 'port-processor');
+  return new Promise((resolve) => {
+    node.port.onmessage = (event) => resolve({node: node, reply: event.data});
+  });
+};
+const ping_for_reply = (node) => {
+  return new Promise((resolve) => {
+    node.port.onmessage = (event) => resolve(event.data);
+    node.port.postMessage('ping');
+  });
+};
+const assert_consistent = (constructReply, pong, expectedPongTime, name) => {
+  const blockSize = 128;
+  assert_equals(pong.timeStamp, expectedPongTime, `${name} pong time`);
+  assert_equals(pong.processCallCount * blockSize,
+                pong.currentFrame - constructReply.currentFrame,
+                `${name} processed frame count`);
+};
+const modulePath = '/webaudio/the-audio-api/' +
+    'the-audioworklet-interface/processors/port-processor.js';
+
+promise_test(async () => {
+  const realtime = new AudioContext();
+  await realtime.audioWorklet.addModule(modulePath);
+  await realtime.suspend();
+  const timeBeforeResume = realtime.currentTime;
+  // Two AudioWorkletNodes are constructed.
+  // node1 is constructed before and node2 after the resume() call.
+  const construct1 = get_node_and_reply(realtime);
+  const resume = realtime.resume();
+  const construct2 = get_node_and_reply(realtime);
+  const {node: node1, reply: constructReply1} = await construct1;
+  assert_equals(constructReply1.timeStamp, timeBeforeResume,
+                'construct time before resume');
+  const {node: node2, reply: constructReply2} = await construct2;
+  assert_greater_than_equal(constructReply2.timeStamp, timeBeforeResume,
+                'construct time after resume');
+  await resume;
+  // Suspend the context to freeze time and check that the processing for each
+  // node matches the elapsed time.
+  await realtime.suspend();
+  const timeAfterSuspend = realtime.currentTime;
+  const pong1 = await ping_for_reply(node1);
+  const pong2 = await ping_for_reply(node2);
+  assert_consistent(constructReply1, pong1, timeAfterSuspend, 'node1');
+  assert_consistent(constructReply2, pong2, timeAfterSuspend, 'node2');
+  assert_equals(pong1.currentFrame, pong2.currentFrame, 'currentFrame matches');
+});
+</script>