tyler.durden
/
test262
mirror of https://github.com/tc39/test262.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Atomics.waitAsync: no spurious wakeup on [operation]

This commit is contained in:
Rick Waldron 2020-04-07 15:43:13 -04:00
parent 6d4b4eba98
commit 974a4ffbc5
9 changed files with 633 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

71
test/built-ins/Atomics/waitAsync/no-spurious-wakeup-no-operation.js Normal file
View File

@ -0,0 +1,71 @@
// Copyright (C) 2020 Rick Waldron. All rights reserved.
// This code is governed by the BSD license found in the LICENSE file.
/*---
esid: sec-atomics.waitasync
description: >
Test that Atomics.waitAsync returns the right result when it timed out and that
the time to time out is reasonable.
info: |
AddWaiter ( WL, waiterRecord )
5. Append waiterRecord as the last element of WL.[[Waiters]]
6. If waiterRecord.[[Timeout]] is finite, then in parallel,
a. Wait waiterRecord.[[Timeout]] milliseconds.
b. Perform TriggerTimeout(WL, waiterRecord).
TriggerTimeout( WL, waiterRecord )
3. If waiterRecord is in WL.[[Waiters]], then
a. Set waiterRecord.[[Result]] to "timed-out".
b. Perform RemoveWaiter(WL, waiterRecord).
c. Perform NotifyWaiter(WL, waiterRecord).
4. Perform LeaveCriticalSection(WL).
includes: [atomicsHelper.js]
features: [Atomics.waitAsync, SharedArrayBuffer, TypedArray, Atomics]
---*/
const RUNNING = 1;
const TIMEOUT = $262.agent.timeouts.small;
const i32a = new Int32Array(
new SharedArrayBuffer(Int32Array.BYTES_PER_ELEMENT * 4)
);
$262.agent.start(`
$262.agent.receiveBroadcast(async (sab, id) => {
const i32a = new Int32Array(sab);
Atomics.add(i32a, ${RUNNING}, 1);
const before = $262.agent.monotonicNow();
const unpark = await Atomics.waitAsync(i32a, 0, 0, ${TIMEOUT}).value;
const duration = $262.agent.monotonicNow() - before;
$262.agent.report(duration);
$262.agent.report(unpark);
$262.agent.leaving();
});
`);
$262.agent.safeBroadcast(i32a);
$262.agent.waitUntil(i32a, RUNNING, 1);
$262.agent.tryYield();
// NO OPERATION OCCURS HERE!
assert(
$262.agent.getReport() >= TIMEOUT,
'The result of `(lapse >= TIMEOUT)` is true'
);
assert.sameValue(
$262.agent.getReport(),
'timed-out',
'await Atomics.wait(i32a, 0, 0, ${TIMEOUT}).value resolves to "timed-out"'
);
assert.sameValue(
Atomics.notify(i32a, 0),
0,
'Atomics.notify(i32a, 0) returns 0'
);

70
test/built-ins/Atomics/waitAsync/no-spurious-wakeup-on-add.js Normal file
View File

@ -0,0 +1,70 @@
// Copyright (C) 2020 Rick Waldron. All rights reserved.
// This code is governed by the BSD license found in the LICENSE file.
/*---
esid: sec-atomics.waitasync
description: >
Waiter does not spuriously notify on index which is subject to Add operation
info: |
AddWaiter ( WL, waiterRecord )
5. Append waiterRecord as the last element of WL.[[Waiters]]
6. If waiterRecord.[[Timeout]] is finite, then in parallel,
a. Wait waiterRecord.[[Timeout]] milliseconds.
b. Perform TriggerTimeout(WL, waiterRecord).
TriggerTimeout( WL, waiterRecord )
3. If waiterRecord is in WL.[[Waiters]], then
a. Set waiterRecord.[[Result]] to "timed-out".
b. Perform RemoveWaiter(WL, waiterRecord).
c. Perform NotifyWaiter(WL, waiterRecord).
4. Perform LeaveCriticalSection(WL).
includes: [atomicsHelper.js]
features: [Atomics.waitAsync, SharedArrayBuffer, TypedArray, Atomics]
---*/
const RUNNING = 1;
const TIMEOUT = $262.agent.timeouts.small;
const i32a = new Int32Array(
new SharedArrayBuffer(Int32Array.BYTES_PER_ELEMENT * 4)
);
$262.agent.start(`
$262.agent.receiveBroadcast(async (sab, id) => {
const i32a = new Int32Array(sab);
Atomics.add(i32a, ${RUNNING}, 1);
const before = $262.agent.monotonicNow();
const unpark = await Atomics.waitAsync(i32a, 0, 0, ${TIMEOUT}).value;
const duration = $262.agent.monotonicNow() - before;
$262.agent.report(duration);
$262.agent.report(unpark);
$262.agent.leaving();
});
`);
$262.agent.safeBroadcast(i32a);
$262.agent.waitUntil(i32a, RUNNING, 1);
$262.agent.tryYield();
Atomics.add(i32a, 0, 1);
assert(
$262.agent.getReport() >= TIMEOUT,
'The result of `(lapse >= TIMEOUT)` is true'
);
assert.sameValue(
$262.agent.getReport(),
'timed-out',
'await Atomics.wait(i32a, 0, 0, ${TIMEOUT}).value resolves to "timed-out"'
);
assert.sameValue(
Atomics.notify(i32a, 0),
0,
'Atomics.notify(i32a, 0) returns 0'
);

70
test/built-ins/Atomics/waitAsync/no-spurious-wakeup-on-and.js Normal file
View File

@ -0,0 +1,70 @@
// Copyright (C) 2020 Rick Waldron. All rights reserved.
// This code is governed by the BSD license found in the LICENSE file.
/*---
esid: sec-atomics.waitasync
description: >
Waiter does not spuriously notify on index which is subject to And operation
info: |
AddWaiter ( WL, waiterRecord )
5. Append waiterRecord as the last element of WL.[[Waiters]]
6. If waiterRecord.[[Timeout]] is finite, then in parallel,
a. Wait waiterRecord.[[Timeout]] milliseconds.
b. Perform TriggerTimeout(WL, waiterRecord).
TriggerTimeout( WL, waiterRecord )
3. If waiterRecord is in WL.[[Waiters]], then
a. Set waiterRecord.[[Result]] to "timed-out".
b. Perform RemoveWaiter(WL, waiterRecord).
c. Perform NotifyWaiter(WL, waiterRecord).
4. Perform LeaveCriticalSection(WL).
includes: [atomicsHelper.js]
features: [Atomics.waitAsync, SharedArrayBuffer, TypedArray, Atomics]
---*/
const RUNNING = 1;
const TIMEOUT = $262.agent.timeouts.small;
const i32a = new Int32Array(
new SharedArrayBuffer(Int32Array.BYTES_PER_ELEMENT * 4)
);
$262.agent.start(`
$262.agent.receiveBroadcast(async (sab, id) => {
const i32a = new Int32Array(sab);
Atomics.add(i32a, ${RUNNING}, 1);
const before = $262.agent.monotonicNow();
const unpark = await Atomics.waitAsync(i32a, 0, 0, ${TIMEOUT}).value;
const duration = $262.agent.monotonicNow() - before;
$262.agent.report(duration);
$262.agent.report(unpark);
$262.agent.leaving();
});
`);
$262.agent.safeBroadcast(i32a);
$262.agent.waitUntil(i32a, RUNNING, 1);
$262.agent.tryYield();
Atomics.and(i32a, 0, 1);
assert(
$262.agent.getReport() >= TIMEOUT,
'The result of `(lapse >= TIMEOUT)` is true'
);
assert.sameValue(
$262.agent.getReport(),
'timed-out',
'await Atomics.wait(i32a, 0, 0, ${TIMEOUT}).value resolves to "timed-out"'
);
assert.sameValue(
Atomics.notify(i32a, 0),
0,
'Atomics.notify(i32a, 0) returns 0'
);

70
test/built-ins/Atomics/waitAsync/no-spurious-wakeup-on-compareExchange.js Normal file
View File

@ -0,0 +1,70 @@
// Copyright (C) 2020 Rick Waldron. All rights reserved.
// This code is governed by the BSD license found in the LICENSE file.
/*---
esid: sec-atomics.waitasync
description: >
Waiter does not spuriously notify on index which is subject to compareExchange operation
info: |
AddWaiter ( WL, waiterRecord )
5. Append waiterRecord as the last element of WL.[[Waiters]]
6. If waiterRecord.[[Timeout]] is finite, then in parallel,
a. Wait waiterRecord.[[Timeout]] milliseconds.
b. Perform TriggerTimeout(WL, waiterRecord).
TriggerTimeout( WL, waiterRecord )
3. If waiterRecord is in WL.[[Waiters]], then
a. Set waiterRecord.[[Result]] to "timed-out".
b. Perform RemoveWaiter(WL, waiterRecord).
c. Perform NotifyWaiter(WL, waiterRecord).
4. Perform LeaveCriticalSection(WL).
includes: [atomicsHelper.js]
features: [Atomics.waitAsync, SharedArrayBuffer, TypedArray, Atomics]
---*/
const RUNNING = 1;
const TIMEOUT = $262.agent.timeouts.small;
const i32a = new Int32Array(
new SharedArrayBuffer(Int32Array.BYTES_PER_ELEMENT * 4)
);
$262.agent.start(`
$262.agent.receiveBroadcast(async (sab, id) => {
const i32a = new Int32Array(sab);
Atomics.add(i32a, ${RUNNING}, 1);
const before = $262.agent.monotonicNow();
const unpark = await Atomics.waitAsync(i32a, 0, 0, ${TIMEOUT}).value;
const duration = $262.agent.monotonicNow() - before;
$262.agent.report(duration);
$262.agent.report(unpark);
$262.agent.leaving();
});
`);
$262.agent.safeBroadcast(i32a);
$262.agent.waitUntil(i32a, RUNNING, 1);
$262.agent.tryYield();
Atomics.compareExchange(i32a, 0, 0, 1);
assert(
$262.agent.getReport() >= TIMEOUT,
'The result of `(lapse >= TIMEOUT)` is true'
);
assert.sameValue(
$262.agent.getReport(),
'timed-out',
'await Atomics.wait(i32a, 0, 0, ${TIMEOUT}).value resolves to "timed-out"'
);
assert.sameValue(
Atomics.notify(i32a, 0),
0,
'Atomics.notify(i32a, 0) returns 0'
);

70
test/built-ins/Atomics/waitAsync/no-spurious-wakeup-on-exchange.js Normal file
View File

@ -0,0 +1,70 @@
// Copyright (C) 2020 Rick Waldron. All rights reserved.
// This code is governed by the BSD license found in the LICENSE file.
/*---
esid: sec-atomics.waitasync
description: >
Waiter does not spuriously notify on index which is subject to exchange operation
info: |
AddWaiter ( WL, waiterRecord )
5. Append waiterRecord as the last element of WL.[[Waiters]]
6. If waiterRecord.[[Timeout]] is finite, then in parallel,
a. Wait waiterRecord.[[Timeout]] milliseconds.
b. Perform TriggerTimeout(WL, waiterRecord).
TriggerTimeout( WL, waiterRecord )
3. If waiterRecord is in WL.[[Waiters]], then
a. Set waiterRecord.[[Result]] to "timed-out".
b. Perform RemoveWaiter(WL, waiterRecord).
c. Perform NotifyWaiter(WL, waiterRecord).
4. Perform LeaveCriticalSection(WL).
includes: [atomicsHelper.js]
features: [Atomics.waitAsync, SharedArrayBuffer, TypedArray, Atomics]
---*/
const RUNNING = 1;
const TIMEOUT = $262.agent.timeouts.small;
const i32a = new Int32Array(
new SharedArrayBuffer(Int32Array.BYTES_PER_ELEMENT * 4)
);
$262.agent.start(`
$262.agent.receiveBroadcast(async (sab, id) => {
const i32a = new Int32Array(sab);
Atomics.add(i32a, ${RUNNING}, 1);
const before = $262.agent.monotonicNow();
const unpark = await Atomics.waitAsync(i32a, 0, 0, ${TIMEOUT}).value;
const duration = $262.agent.monotonicNow() - before;
$262.agent.report(duration);
$262.agent.report(unpark);
$262.agent.leaving();
});
`);
$262.agent.safeBroadcast(i32a);
$262.agent.waitUntil(i32a, RUNNING, 1);
$262.agent.tryYield();
Atomics.exchange(i32a, 0, 1);
assert(
$262.agent.getReport() >= TIMEOUT,
'The result of `(lapse >= TIMEOUT)` is true'
);
assert.sameValue(
$262.agent.getReport(),
'timed-out',
'await Atomics.wait(i32a, 0, 0, ${TIMEOUT}).value resolves to "timed-out"'
);
assert.sameValue(
Atomics.notify(i32a, 0),
0,
'Atomics.notify(i32a, 0) returns 0'
);

70
test/built-ins/Atomics/waitAsync/no-spurious-wakeup-on-or.js Normal file
View File

@ -0,0 +1,70 @@
// Copyright (C) 2020 Rick Waldron. All rights reserved.
// This code is governed by the BSD license found in the LICENSE file.
/*---
esid: sec-atomics.waitasync
description: >
Waiter does not spuriously notify on index which is subject to Or operation
info: |
AddWaiter ( WL, waiterRecord )
5. Append waiterRecord as the last element of WL.[[Waiters]]
6. If waiterRecord.[[Timeout]] is finite, then in parallel,
a. Wait waiterRecord.[[Timeout]] milliseconds.
b. Perform TriggerTimeout(WL, waiterRecord).
TriggerTimeout( WL, waiterRecord )
3. If waiterRecord is in WL.[[Waiters]], then
a. Set waiterRecord.[[Result]] to "timed-out".
b. Perform RemoveWaiter(WL, waiterRecord).
c. Perform NotifyWaiter(WL, waiterRecord).
4. Perform LeaveCriticalSection(WL).
includes: [atomicsHelper.js]
features: [Atomics.waitAsync, SharedArrayBuffer, TypedArray, Atomics]
---*/
const RUNNING = 1;
const TIMEOUT = $262.agent.timeouts.small;
const i32a = new Int32Array(
new SharedArrayBuffer(Int32Array.BYTES_PER_ELEMENT * 4)
);
$262.agent.start(`
$262.agent.receiveBroadcast(async (sab, id) => {
const i32a = new Int32Array(sab);
Atomics.add(i32a, ${RUNNING}, 1);
const before = $262.agent.monotonicNow();
const unpark = await Atomics.waitAsync(i32a, 0, 0, ${TIMEOUT}).value;
const duration = $262.agent.monotonicNow() - before;
$262.agent.report(duration);
$262.agent.report(unpark);
$262.agent.leaving();
});
`);
$262.agent.safeBroadcast(i32a);
$262.agent.waitUntil(i32a, RUNNING, 1);
$262.agent.tryYield();
Atomics.or(i32a, 0, 1);
assert(
$262.agent.getReport() >= TIMEOUT,
'The result of `(lapse >= TIMEOUT)` is true'
);
assert.sameValue(
$262.agent.getReport(),
'timed-out',
'await Atomics.wait(i32a, 0, 0, ${TIMEOUT}).value resolves to "timed-out"'
);
assert.sameValue(
Atomics.notify(i32a, 0),
0,
'Atomics.notify(i32a, 0) returns 0'
);

70
test/built-ins/Atomics/waitAsync/no-spurious-wakeup-on-store.js Normal file
View File

@ -0,0 +1,70 @@
// Copyright (C) 2020 Rick Waldron. All rights reserved.
// This code is governed by the BSD license found in the LICENSE file.
/*---
esid: sec-atomics.waitasync
description: >
Waiter does not spuriously notify on index which is subject to Store operation
info: |
AddWaiter ( WL, waiterRecord )
5. Append waiterRecord as the last element of WL.[[Waiters]]
6. If waiterRecord.[[Timeout]] is finite, then in parallel,
a. Wait waiterRecord.[[Timeout]] milliseconds.
b. Perform TriggerTimeout(WL, waiterRecord).
TriggerTimeout( WL, waiterRecord )
3. If waiterRecord is in WL.[[Waiters]], then
a. Set waiterRecord.[[Result]] to "timed-out".
b. Perform RemoveWaiter(WL, waiterRecord).
c. Perform NotifyWaiter(WL, waiterRecord).
4. Perform LeaveCriticalSection(WL).
includes: [atomicsHelper.js]
features: [Atomics.waitAsync, SharedArrayBuffer, TypedArray, Atomics]
---*/
const RUNNING = 1;
const TIMEOUT = $262.agent.timeouts.small;
const i32a = new Int32Array(
new SharedArrayBuffer(Int32Array.BYTES_PER_ELEMENT * 4)
);
$262.agent.start(`
$262.agent.receiveBroadcast(async (sab, id) => {
const i32a = new Int32Array(sab);
Atomics.add(i32a, ${RUNNING}, 1);
const before = $262.agent.monotonicNow();
const unpark = await Atomics.waitAsync(i32a, 0, 0, ${TIMEOUT}).value;
const duration = $262.agent.monotonicNow() - before;
$262.agent.report(duration);
$262.agent.report(unpark);
$262.agent.leaving();
});
`);
$262.agent.safeBroadcast(i32a);
$262.agent.waitUntil(i32a, RUNNING, 1);
$262.agent.tryYield();
Atomics.store(i32a, 0, 0x111111);
assert(
$262.agent.getReport() >= TIMEOUT,
'The result of `(lapse >= TIMEOUT)` is true'
);
assert.sameValue(
$262.agent.getReport(),
'timed-out',
'await Atomics.wait(i32a, 0, 0, ${TIMEOUT}).value resolves to "timed-out"'
);
assert.sameValue(
Atomics.notify(i32a, 0),
0,
'Atomics.notify(i32a, 0) returns 0'
);

71
test/built-ins/Atomics/waitAsync/no-spurious-wakeup-on-sub.js Normal file
View File

@ -0,0 +1,71 @@
// Copyright (C) 2020 Rick Waldron. All rights reserved.
// This code is governed by the BSD license found in the LICENSE file.
/*---
esid: sec-atomics.waitasync
description: >
Waiter does not spuriously notify on index which is subject to Sub operation
info: |
AddWaiter ( WL, waiterRecord )
5. Append waiterRecord as the last element of WL.[[Waiters]]
6. If waiterRecord.[[Timeout]] is finite, then in parallel,
a. Wait waiterRecord.[[Timeout]] milliseconds.
b. Perform TriggerTimeout(WL, waiterRecord).
TriggerTimeout( WL, waiterRecord )
3. If waiterRecord is in WL.[[Waiters]], then
a. Set waiterRecord.[[Result]] to "timed-out".
b. Perform RemoveWaiter(WL, waiterRecord).
c. Perform NotifyWaiter(WL, waiterRecord).
4. Perform LeaveCriticalSection(WL).
includes: [atomicsHelper.js]
features: [Atomics.waitAsync, SharedArrayBuffer, TypedArray, Atomics]
---*/
const RUNNING = 1;
const TIMEOUT = $262.agent.timeouts.small;
const i32a = new Int32Array(
new SharedArrayBuffer(Int32Array.BYTES_PER_ELEMENT * 4)
);
$262.agent.start(`
$262.agent.receiveBroadcast(async (sab, id) => {
const i32a = new Int32Array(sab);
Atomics.add(i32a, ${RUNNING}, 1);
const before = $262.agent.monotonicNow();
const unpark = await Atomics.waitAsync(i32a, 0, 0, ${TIMEOUT}).value;
const duration = $262.agent.monotonicNow() - before;
$262.agent.report(duration);
$262.agent.report(unpark);
$262.agent.leaving();
});
`);
$262.agent.safeBroadcast(i32a);
$262.agent.waitUntil(i32a, RUNNING, 1);
$262.agent.tryYield();
Atomics.sub(i32a, 0, 1);
assert(
$262.agent.getReport() >= TIMEOUT,
'The result of `(lapse >= TIMEOUT)` is true'
);
assert.sameValue(
$262.agent.getReport(),
'timed-out',
'await Atomics.wait(i32a, 0, 0, ${TIMEOUT}).value resolves to "timed-out"'
);
assert.sameValue(
Atomics.notify(i32a, 0),
0,
'Atomics.notify(i32a, 0) returns 0'
);

71
test/built-ins/Atomics/waitAsync/no-spurious-wakeup-on-xor.js Normal file
View File

@ -0,0 +1,71 @@
// Copyright (C) 2020 Rick Waldron. All rights reserved.
// This code is governed by the BSD license found in the LICENSE file.
/*---
esid: sec-atomics.waitasync
description: >
Waiter does not spuriously notify on index which is subject to xor operation
info: |
AddWaiter ( WL, waiterRecord )
5. Append waiterRecord as the last element of WL.[[Waiters]]
6. If waiterRecord.[[Timeout]] is finite, then in parallel,
a. Wait waiterRecord.[[Timeout]] milliseconds.
b. Perform TriggerTimeout(WL, waiterRecord).
TriggerTimeout( WL, waiterRecord )
3. If waiterRecord is in WL.[[Waiters]], then
a. Set waiterRecord.[[Result]] to "timed-out".
b. Perform RemoveWaiter(WL, waiterRecord).
c. Perform NotifyWaiter(WL, waiterRecord).
4. Perform LeaveCriticalSection(WL).
includes: [atomicsHelper.js]
features: [Atomics.waitAsync, SharedArrayBuffer, TypedArray, Atomics]
---*/
const RUNNING = 1;
const TIMEOUT = $262.agent.timeouts.small;
const i32a = new Int32Array(
new SharedArrayBuffer(Int32Array.BYTES_PER_ELEMENT * 4)
);
$262.agent.start(`
$262.agent.receiveBroadcast(async (sab, id) => {
const i32a = new Int32Array(sab);
Atomics.add(i32a, ${RUNNING}, 1);
const before = $262.agent.monotonicNow();
const unpark = await Atomics.waitAsync(i32a, 0, 0, ${TIMEOUT}).value;
const duration = $262.agent.monotonicNow() - before;
$262.agent.report(duration);
$262.agent.report(unpark);
$262.agent.leaving();
});
`);
$262.agent.safeBroadcast(i32a);
$262.agent.waitUntil(i32a, RUNNING, 1);
$262.agent.tryYield();
Atomics.xor(i32a, 0, 1);
assert(
$262.agent.getReport() >= TIMEOUT,
'The result of `(lapse >= TIMEOUT)` is true'
);
assert.sameValue(
$262.agent.getReport(),
'timed-out',
'await Atomics.wait(i32a, 0, 0, ${TIMEOUT}).value resolves to "timed-out"'
);
assert.sameValue(
Atomics.notify(i32a, 0),
0,
'Atomics.notify(i32a, 0) returns 0'
);