1 files changed, 105 insertions, 0 deletions
diff --git a/toolkit/components/asyncshutdown/tests/xpcshell/test_AsyncShutdown_leave_uncaught.js b/toolkit/components/asyncshutdown/tests/xpcshell/test_AsyncShutdown_leave_uncaught.js
new file mode 100644
index 0000000000..b37416d7a7
--- /dev/null
+++ b/toolkit/components/asyncshutdown/tests/xpcshell/test_AsyncShutdown_leave_uncaught.js
@@ -0,0 +1,105 @@
+/* Any copyright is dedicated to the Public Domain.
+ * http://creativecommons.org/publicdomain/zero/1.0/ */
+"use strict";
+
+//
+// This file contains tests that need to leave uncaught asynchronous
+// errors. If your test catches all its asynchronous errors, please
+// put it in another file.
+//
+const { PromiseTestUtils } = ChromeUtils.importESModule(
+  "resource://testing-common/PromiseTestUtils.sys.mjs"
+);
+PromiseTestUtils.thisTestLeaksUncaughtRejectionsAndShouldBeFixed();
+
+add_task(async function test_phase_simple_async() {
+  info("Testing various combinations of a phase with a single condition");
+  for (let kind of [
+    "phase",
+    "barrier",
+    "xpcom-barrier",
+    "xpcom-barrier-unwrapped",
+  ]) {
+    for (let arg of [undefined, null, "foo", 100, new Error("BOOM")]) {
+      for (let resolution of [arg, Promise.reject(arg)]) {
+        for (let success of [false, true]) {
+          for (let state of [
+            [null],
+            [],
+            [() => "some state"],
+            [
+              function () {
+                throw new Error("State BOOM");
+              },
+            ],
+            [
+              function () {
+                return {
+                  toJSON() {
+                    throw new Error("State.toJSON BOOM");
+                  },
+                };
+              },
+            ],
+          ]) {
+            // Asynchronous phase
+            info(
+              "Asynchronous test with " + arg + ", " + resolution + ", " + kind
+            );
+            let lock = makeLock(kind);
+            let outParam = { isFinished: false };
+            lock.addBlocker(
+              "Async test",
+              function () {
+                if (success) {
+                  return longRunningAsyncTask(resolution, outParam);
+                }
+                throw resolution;
+              },
+              ...state
+            );
+            Assert.ok(!outParam.isFinished);
+            await lock.wait();
+            Assert.equal(outParam.isFinished, success);
+          }
+        }
+
+        // Synchronous phase - just test that we don't throw/freeze
+        info("Synchronous test with " + arg + ", " + resolution + ", " + kind);
+        let lock = makeLock(kind);
+        lock.addBlocker("Sync test", resolution);
+        await lock.wait();
+      }
+    }
+  }
+});
+
+add_task(async function test_phase_many() {
+  info("Testing various combinations of a phase with many conditions");
+  for (let kind of [
+    "phase",
+    "barrier",
+    "xpcom-barrier",
+    "xpcom-barrier-unwrapped",
+  ]) {
+    let lock = makeLock(kind);
+    let outParams = [];
+    for (let arg of [undefined, null, "foo", 100, new Error("BOOM")]) {
+      for (let resolve of [true, false]) {
+        info("Testing with " + kind + ", " + arg + ", " + resolve);
+        let resolution = resolve ? arg : Promise.reject(arg);
+        let outParam = { isFinished: false };
+        lock.addBlocker("Test " + Math.random(), () =>
+          longRunningAsyncTask(resolution, outParam)
+        );
+      }
+    }
+    Assert.ok(outParams.every(x => !x.isFinished));
+    await lock.wait();
+    Assert.ok(outParams.every(x => x.isFinished));
+  }
+});
+
+add_task(async function () {
+  Services.prefs.clearUserPref("toolkit.asyncshutdown.testing");
+});