mirror of
https://github.com/tc39/test262.git
synced 2025-05-15 20:30:31 +02:00
e4883091b9
Migrating all tests to this API is necessary to prevent tests from hanging indefinitely when a SAB is sent to a worker but the code in the worker attempts to create a non-sharable TypedArray (something that is not Int32Array or BigInt64Array). When that scenario occurs, an exception is thrown and the agent worker can no longer communicate with any other threads that control the SAB. If the main thread happens to be spinning in the $262.agent.waitUntil() while loop, it will never meet its termination condition and the test will hang indefinitely. Because we've defined $262.agent.broadcast(SAB) in https://github.com/tc39/test262/blob/master/INTERPRETING.md, there are host implementations that assume compatibility, which must be maintained.
90 lines
2.9 KiB
JavaScript
90 lines
2.9 KiB
JavaScript
// Copyright (C) 2017 Mozilla Corporation. All rights reserved.
|
|
// This code is governed by the BSD license found in the LICENSE file.
|
|
|
|
/*---
|
|
esid: sec-atomics.notify
|
|
description: >
|
|
Test that Atomics.notify notifies all waiters on a location, but does not
|
|
notify waiters on other locations.
|
|
includes: [atomicsHelper.js]
|
|
features: [Atomics, SharedArrayBuffer, TypedArray]
|
|
---*/
|
|
|
|
const WAIT_INDEX = 0; // Waiters on this will be woken
|
|
const WAIT_FAKE = 1; // Waiters on this will not be woken
|
|
const RUNNING = 2; // Accounting of live agents
|
|
const NOTIFY_INDEX = 3; // Accounting for too early timeouts
|
|
const NUMAGENT = 3;
|
|
const TIMEOUT_AGENT_MESSAGES = 2; // Number of messages for the timeout agent
|
|
const BUFFER_SIZE = 4;
|
|
|
|
// Long timeout to ensure the agent doesn't timeout before the main agent calls
|
|
// `Atomics.notify`.
|
|
const TIMEOUT = $262.agent.timeouts.long;
|
|
|
|
for (var i = 0; i < NUMAGENT; i++) {
|
|
$262.agent.start(`
|
|
$262.agent.receiveBroadcast(function(sab) {
|
|
const i32a = new Int32Array(sab);
|
|
Atomics.add(i32a, ${RUNNING}, 1);
|
|
|
|
$262.agent.report("A " + Atomics.wait(i32a, ${WAIT_INDEX}, 0));
|
|
$262.agent.leaving();
|
|
});
|
|
`);
|
|
}
|
|
|
|
$262.agent.start(`
|
|
$262.agent.receiveBroadcast(function(sab) {
|
|
const i32a = new Int32Array(sab);
|
|
Atomics.add(i32a, ${RUNNING}, 1);
|
|
|
|
// This will always time out.
|
|
$262.agent.report("B " + Atomics.wait(i32a, ${WAIT_FAKE}, 0, ${TIMEOUT}));
|
|
|
|
// If this value is not 1, then the agent timeout before the main agent
|
|
// called Atomics.notify.
|
|
const result = Atomics.load(i32a, ${NOTIFY_INDEX}) === 1
|
|
? "timeout after Atomics.notify"
|
|
: "timeout before Atomics.notify";
|
|
$262.agent.report("W " + result);
|
|
|
|
$262.agent.leaving();
|
|
});
|
|
`);
|
|
|
|
const i32a = new Int32Array(
|
|
new SharedArrayBuffer(Int32Array.BYTES_PER_ELEMENT * BUFFER_SIZE)
|
|
);
|
|
|
|
$262.agent.safeBroadcast(i32a);
|
|
|
|
// Wait for agents to be running.
|
|
$262.agent.waitUntil(i32a, RUNNING, NUMAGENT + 1);
|
|
|
|
// Try to yield control to ensure the agent actually started to wait. If we
|
|
// don't, we risk sending the notification before agents are sleeping, and we hang.
|
|
$262.agent.tryYield();
|
|
|
|
// Notify all waiting on WAIT_INDEX, should be 3 always, they won't time out.
|
|
assert.sameValue(
|
|
Atomics.notify(i32a, WAIT_INDEX),
|
|
NUMAGENT,
|
|
'Atomics.notify(i32a, WAIT_INDEX) returns the value of `NUMAGENT`'
|
|
);
|
|
|
|
Atomics.store(i32a, NOTIFY_INDEX, 1);
|
|
|
|
const reports = [];
|
|
for (var i = 0; i < NUMAGENT + TIMEOUT_AGENT_MESSAGES; i++) {
|
|
reports.push($262.agent.getReport());
|
|
}
|
|
reports.sort();
|
|
|
|
for (var i = 0; i < NUMAGENT; i++) {
|
|
assert.sameValue(reports[i], "A ok", 'The value of reports[i] is "A ok"');
|
|
}
|
|
assert.sameValue(reports[NUMAGENT], "B timed-out", 'The value of reports[NUMAGENT] is "B timed-out"');
|
|
assert.sameValue(reports[NUMAGENT + 1], "W timeout after Atomics.notify",
|
|
'The value of reports[NUMAGENT + 1] is "W timeout after Atomics.notify"');
|