Magic-Mirror/gecko-dev
1
0
Fork 0
mirror of https://github.com/mozilla/gecko-dev.git synced 2024-10-28 12:45:27 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Bug 1385417 - Fix sendOnTimeout test. r=gfritzsche

Browse Source
This commit is contained in:
Kate Ustiuzhanina 2017-08-04 10:11:38 +01:00
parent ab70851265
commit 099014b6d9
1 changed files with 45 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

54
toolkit/components/telemetry/tests/unit/test_TelemetryHealthPing.js
View File

@ -11,6 +11,7 @@ Cu.import("resource://gre/modules/TelemetryStorage.jsm", this);
Cu.import("resource://gre/modules/TelemetryUtils.jsm", this);
Cu.import("resource://gre/modules/Preferences.jsm", this);
Cu.import("resource://gre/modules/XPCOMUtils.jsm", this);
Cu.import("resource://testing-common/TelemetryArchiveTesting.jsm", this);
XPCOMUtils.defineLazyModuleGetter(this, "TelemetryHealthPing",
"resource://gre/modules/TelemetryHealthPing.jsm");
@ -30,6 +31,18 @@ function fakeHealthSchedulerTimer(set, clear) {
telemetryHealthPing.Policy.clearSchedulerTickTimeout = clear;
}
async function waitForConditionWithPromise(promiseFn, timeoutMsg, tryCount = 30) {
const SINGLE_TRY_TIMEOUT = 100;
let tries = 0;
do {
try {
return await promiseFn();
} catch (ex) {}
await new Promise(resolve => do_timeout(SINGLE_TRY_TIMEOUT, resolve));
} while (++tries <= tryCount);
throw new Error(timeoutMsg);
}
add_task(async function setup() {
// Trigger a proper telemetry init.
do_get_profile(true);
@ -110,34 +123,56 @@ add_task(async function test_sendOverSizedPing() {
add_task(async function test_sendOnTimeout() {
TelemetryHealthPing.testReset();
await TelemetrySend.reset();
PingServer.clearRequests();
let PING_TYPE = "ping-on-timeout";
// Disable send retry to make this test more deterministic.
fakePingSendTimer(() => {}, () => {});
// Set up small ping submission timeout to always have timeout error.
TelemetrySend.testSetTimeoutForPingSubmit(2);
// Reset the timeout after receiving the first ping to be able to send health ping.
PingServer.registerPingHandler((request, result) => {
await TelemetryController.submitExternalPing(PING_TYPE, {});
let response;
PingServer.registerPingHandler((req, res) => {
PingServer.resetPingHandler();
TelemetrySend.testResetTimeOutToDefault();
// We don't finish the response yet to make sure to trigger a timeout.
res.processAsync();
response = res;
});
await TelemetryController.submitExternalPing(PING_TYPE, {});
let ping = await PingServer.promiseNextPing();
checkHealthPingStructure(ping, {
// Wait for health ping.
let ac = new TelemetryArchiveTesting.Checker();
await ac.promiseInit();
await waitForConditionWithPromise(() => {
ac.promiseFindPing("health", []);
}, "Failed to find health ping");
if (response) {
response.finish();
}
TelemetrySend.testResetTimeOutToDefault();
PingServer.resetPingHandler();
TelemetrySend.notifyCanUpload();
let pings = await PingServer.promiseNextPings(2);
let healthPing = pings.find(ping => ping.type === "health");
checkHealthPingStructure(healthPing, {
[TelemetryHealthPing.FailureType.SEND_FAILURE]: {
"timeout": 1
},
"os": TelemetryHealthPing.OsInfo,
"reason": TelemetryHealthPing.Reason.IMMEDIATE
});
// Clear pending pings to avoid resending pings which fail with time out error.
await TelemetryStorage.testClearPendingPings();
});
add_task(async function test_sendOnlyTopTenDiscardedPings() {
TelemetryHealthPing.testReset();
await TelemetrySend.reset();
PingServer.clearRequests();
let PING_TYPE = "sort-discarded";
@ -155,10 +190,11 @@ add_task(async function test_sendOnlyTopTenDiscardedPings() {
// Add failures
for (let i = 1; i < 12; i++) {
for (let j = 1; j < i; j++) {
await TelemetryHealthPing.recordDiscardedPing(PING_TYPE + i);
TelemetryHealthPing.recordDiscardedPing(PING_TYPE + i);
}
}
await TelemetrySend.reset();
await pingSubmissionCallBack();
let ping = await PingServer.promiseNextPing();