103 lines
3.2 KiB
JavaScript
103 lines
3.2 KiB
JavaScript
/* 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
|
|
* file, You can obtain one at http://mozilla.org/MPL/2.0/. */
|
|
"use strict";
|
|
|
|
// This test is at the edge of timing out, probably because of LUL
|
|
// initialization on Linux. This is also happening only once, which is why only
|
|
// this test needs it: for other tests LUL is already initialized because
|
|
// they're running in the same Firefox instance.
|
|
// See also bug 1635442.
|
|
requestLongerTimeout(2);
|
|
|
|
async function decompressGzip(buffer) {
|
|
if (buffer.resizable) {
|
|
// Not sure why, but we can't use a resizable buffer for streams.
|
|
buffer = buffer.transferToFixedLength();
|
|
}
|
|
const decompressionStream = new DecompressionStream("gzip");
|
|
const decoderStream = new TextDecoderStream();
|
|
const decodedStream = decompressionStream.readable.pipeThrough(decoderStream);
|
|
const writer = decompressionStream.writable.getWriter();
|
|
writer.write(buffer);
|
|
const writePromise = writer.close();
|
|
|
|
let result = "";
|
|
for await (const chunk of decodedStream) {
|
|
result += chunk;
|
|
}
|
|
|
|
await writePromise;
|
|
return JSON.parse(result);
|
|
}
|
|
|
|
/**
|
|
* Run through a series of basic recording actions for the perf actor.
|
|
*/
|
|
add_task(async function () {
|
|
const { front, client } = await initPerfFront();
|
|
|
|
// Assert the initial state.
|
|
is(
|
|
await front.isSupportedPlatform(),
|
|
true,
|
|
"This test only runs on supported platforms."
|
|
);
|
|
is(await front.isActive(), false, "The profiler is not active yet.");
|
|
|
|
// Start the profiler.
|
|
const profilerStarted = once(front, "profiler-started");
|
|
await front.startProfiler();
|
|
await profilerStarted;
|
|
is(await front.isActive(), true, "The profiler was started.");
|
|
|
|
// Stop the profiler and assert the results.
|
|
const profilerStopped1 = once(front, "profiler-stopped");
|
|
const { profile: gzippedProfile, additionalInformation } =
|
|
await front.getProfileAndStopProfiler();
|
|
await profilerStopped1;
|
|
is(await front.isActive(), false, "The profiler was stopped.");
|
|
const profile = await decompressGzip(gzippedProfile);
|
|
ok("threads" in profile, "The actor was used to record a profile.");
|
|
ok(
|
|
additionalInformation.sharedLibraries,
|
|
"We retrieved some shared libraries as well."
|
|
);
|
|
|
|
// Restart the profiler.
|
|
await front.startProfiler();
|
|
is(await front.isActive(), true, "The profiler was re-started.");
|
|
|
|
// Stop and discard.
|
|
const profilerStopped2 = once(front, "profiler-stopped");
|
|
await front.stopProfilerAndDiscardProfile();
|
|
await profilerStopped2;
|
|
is(
|
|
await front.isActive(),
|
|
false,
|
|
"The profiler was stopped and the profile discarded."
|
|
);
|
|
|
|
await front.destroy();
|
|
await client.close();
|
|
});
|
|
|
|
add_task(async function test_error_case() {
|
|
const { front, client } = await initPerfFront();
|
|
|
|
try {
|
|
// We try to get the profile without starting the profiler first. This should
|
|
// trigger an error in the our C++ code.
|
|
await front.getProfileAndStopProfiler();
|
|
ok(false, "Getting the profile should fail");
|
|
} catch (e) {
|
|
Assert.stringContains(
|
|
e.message,
|
|
"The profiler is not active.",
|
|
"The error contains the expected error message."
|
|
);
|
|
}
|
|
|
|
await front.destroy();
|
|
await client.close();
|
|
});
|