Source code
Revision control
Copy as Markdown
Other Tools
Test Info: Errors
- This test failed 13 times in the preceding 30 days. quicksearch this test
- Manifest: dom/workers/test/browser.toml
/* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
"use strict";
function unscream(s) {
// Takes SCREAMINGCASE `s` and returns "Screamingcase".
return s.charAt(0) + s.slice(1).toLowerCase();
}
function screamToCamel(s) {
// Takes SCREAMING_CASE `s` and returns "screamingCase".
const pascal = s.split("_").map(unscream).join("");
return pascal.charAt(0).toLowerCase() + pascal.slice(1);
}
var check_use_counter_worker = async function (
use_counter_name,
worker_type,
content_task
) {
info(`checking ${use_counter_name} use counters for ${worker_type} worker`);
let newTab = BrowserTestUtils.addTab(gBrowser, "about:blank");
gBrowser.selectedTab = newTab;
newTab.linkedBrowser.stop();
// Hold on to the current values of the instrumentation we're
// interested in.
await Services.fog.testFlushAllChildren();
let glean_before =
Glean[`useCounterWorker${unscream(worker_type)}`][
screamToCamel(use_counter_name)
].testGetValue();
let glean_destructions_before =
Glean.useCounter[
`${worker_type.toLowerCase()}WorkersDestroyed`
].testGetValue();
BrowserTestUtils.startLoadingURIString(
gBrowser.selectedBrowser,
gHttpTestRoot + "file_use_counter_worker.html"
);
await BrowserTestUtils.browserLoaded(gBrowser.selectedBrowser);
await content_task(gBrowser.selectedBrowser);
// Tear down the page.
let tabClosed = BrowserTestUtils.waitForTabClosing(newTab);
gBrowser.removeTab(newTab);
await tabClosed;
// Grab data again and compare.
// We'd like for this to be synchronous, but use counters are reported on
// worker destruction which we don't directly observe.
// So we check in a quick loop.
await BrowserTestUtils.waitForCondition(async () => {
await Services.fog.testFlushAllChildren();
return (
glean_before !=
Glean[`useCounterWorker${unscream(worker_type)}`][
screamToCamel(use_counter_name)
].testGetValue()
);
});
let glean_after =
Glean[`useCounterWorker${unscream(worker_type)}`][
screamToCamel(use_counter_name)
].testGetValue();
let glean_destructions_after =
Glean.useCounter[
`${worker_type.toLowerCase()}WorkersDestroyed`
].testGetValue();
is(
glean_after,
glean_before + 1,
`Glean counter ${use_counter_name} for ${worker_type} worker is correct.`
);
// There might be other workers created by prior tests get destroyed during
// this tests.
Assert.greater(
glean_destructions_after,
glean_destructions_before ?? 0,
`Glean ${worker_type} worker counts are correct`
);
};
add_task(async function test_dedicated_worker() {
await check_use_counter_worker("CONSOLE_LOG", "DEDICATED", async browser => {
await ContentTask.spawn(browser, {}, function () {
return new Promise(resolve => {
let worker = new content.Worker("file_use_counter_worker.js");
worker.onmessage = function (e) {
if (e.data === "DONE") {
worker.terminate();
resolve();
}
};
});
});
});
});
add_task(async function test_shared_worker() {
await check_use_counter_worker("CONSOLE_LOG", "SHARED", async browser => {
await ContentTask.spawn(browser, {}, function () {
return new Promise(resolve => {
let worker = new content.SharedWorker(
"file_use_counter_shared_worker.js"
);
worker.port.onmessage = function (e) {
if (e.data === "DONE") {
resolve();
}
};
worker.port.postMessage("RUN");
});
});
});
});
add_task(async function test_shared_worker_microtask() {
await check_use_counter_worker("CONSOLE_LOG", "SHARED", async browser => {
await ContentTask.spawn(browser, {}, function () {
return new Promise(resolve => {
let worker = new content.SharedWorker(
"file_use_counter_shared_worker_microtask.js"
);
worker.port.onmessage = function (e) {
if (e.data === "DONE") {
resolve();
}
};
worker.port.postMessage("RUN");
});
});
});
});
add_task(async function test_service_worker() {
await check_use_counter_worker("CONSOLE_LOG", "SERVICE", async browser => {
await ContentTask.spawn(browser, {}, function () {
let waitForActivated = async function (registration) {
return new Promise(resolve => {
let worker =
registration.installing ||
registration.waiting ||
registration.active;
if (worker.state === "activated") {
resolve(worker);
return;
}
worker.addEventListener("statechange", function onStateChange() {
if (worker.state === "activated") {
worker.removeEventListener("statechange", onStateChange);
resolve(worker);
}
});
});
};
return new Promise(resolve => {
content.navigator.serviceWorker
.register("file_use_counter_service_worker.js")
.then(async registration => {
content.navigator.serviceWorker.onmessage = function (e) {
if (e.data === "DONE") {
registration.unregister().then(resolve);
}
};
let worker = await waitForActivated(registration);
worker.postMessage("RUN");
});
});
});
});
});