73d401b9d1
Details: https://docs.google.com/document/d/1-Gi37Ks7rXMVVRkC_HkwGxenP7T1huQUOMrYOtkUCFk/edit?usp=sharing Bug: v8:11340 Change-Id: Ia1d75270373a7ef2307e7ee0fd24da9ecfa27d18 Reviewed-on: https://chromium-review.googlesource.com/c/v8/v8/+/2643381 Reviewed-by: Michael Achenbach <machenbach@chromium.org> Reviewed-by: Camillo Bruni <cbruni@chromium.org> Reviewed-by: Andreas Haas <ahaas@chromium.org> Commit-Queue: Marja Hölttä <marja@chromium.org> Cr-Commit-Position: refs/heads/master@{#72315}
249 lines
7.4 KiB
JavaScript
249 lines
7.4 KiB
JavaScript
// Copyright 2015 the V8 project authors. All rights reserved.
|
|
// Use of this source code is governed by a BSD-style license that can be
|
|
// found in the LICENSE file.
|
|
|
|
// Flags: --allow-natives-syntax --harmony-sharedarraybuffer
|
|
|
|
(function TestNonSharedArrayBehavior() {
|
|
var ab = new ArrayBuffer(16);
|
|
|
|
var i8a = new Int8Array(ab);
|
|
var i16a = new Int16Array(ab);
|
|
var i32a = new Int32Array(ab);
|
|
var ui8a = new Uint8Array(ab);
|
|
var ui8ca = new Uint8ClampedArray(ab);
|
|
var ui16a = new Uint16Array(ab);
|
|
var ui32a = new Uint32Array(ab);
|
|
var f32a = new Float32Array(ab);
|
|
var f64a = new Float64Array(ab);
|
|
|
|
[i8a, i16a, i32a, ui8a, ui8ca, ui16a, ui32a, f32a, f64a].forEach(function(
|
|
ta) {
|
|
assertThrows(function() { Atomics.wait(ta, 0, 0); });
|
|
if (ta === i32a) {
|
|
assertEquals(0, Atomics.notify(ta, 0, 1));
|
|
} else {
|
|
assertThrows(function() { Atomics.notify(ta, 0, 1); });
|
|
}
|
|
});
|
|
})();
|
|
|
|
(function TestFailsWithNonSharedInt32Array() {
|
|
var sab = new SharedArrayBuffer(16);
|
|
|
|
var i8a = new Int8Array(sab);
|
|
var i16a = new Int16Array(sab);
|
|
var ui8a = new Uint8Array(sab);
|
|
var ui8ca = new Uint8ClampedArray(sab);
|
|
var ui16a = new Uint16Array(sab);
|
|
var ui32a = new Uint32Array(sab);
|
|
var f32a = new Float32Array(sab);
|
|
var f64a = new Float64Array(sab);
|
|
|
|
[i8a, i16a, ui8a, ui8ca, ui16a, ui32a, f32a, f64a].forEach(function(
|
|
ta) {
|
|
assertThrows(function() { Atomics.wait(ta, 0, 0); });
|
|
assertThrows(function() { Atomics.notify(ta, 0, 1); });
|
|
});
|
|
})();
|
|
|
|
(function TestInvalidIndex() {
|
|
var sab = new SharedArrayBuffer(16);
|
|
var i32a = new Int32Array(sab);
|
|
|
|
// Valid indexes are 0-3.
|
|
[-1, 4, 100, 0xffffffff].forEach(function(invalidIndex) {
|
|
assertThrows(function() {
|
|
Atomics.wait(i32a, invalidIndex, 0);
|
|
}, RangeError);
|
|
assertThrows(function() {
|
|
Atomics.notify(i32a, invalidIndex, 0);
|
|
}, RangeError);
|
|
var validIndex = 0;
|
|
});
|
|
|
|
i32a = new Int32Array(sab, 8);
|
|
[-1, 2, 100, 0xffffffff].forEach(function(invalidIndex) {
|
|
assertThrows(function() {
|
|
Atomics.wait(i32a, invalidIndex, 0);
|
|
}, RangeError);
|
|
assertThrows(function() {
|
|
Atomics.notify(i32a, invalidIndex, 0);
|
|
}, RangeError);
|
|
var validIndex = 0;
|
|
});
|
|
})();
|
|
|
|
(function TestWaitTimeout() {
|
|
var i32a = new Int32Array(new SharedArrayBuffer(16));
|
|
var waitMs = 100;
|
|
var startTime = new Date();
|
|
assertEquals("timed-out", Atomics.wait(i32a, 0, 0, waitMs));
|
|
var endTime = new Date();
|
|
assertTrue(endTime - startTime >= waitMs);
|
|
})();
|
|
|
|
(function TestWaitNotEqual() {
|
|
var sab = new SharedArrayBuffer(16);
|
|
var i32a = new Int32Array(sab);
|
|
assertEquals("not-equal", Atomics.wait(i32a, 0, 42));
|
|
|
|
i32a = new Int32Array(sab, 8);
|
|
i32a[0] = 1;
|
|
assertEquals("not-equal", Atomics.wait(i32a, 0, 0));
|
|
})();
|
|
|
|
(function TestWaitNegativeTimeout() {
|
|
var i32a = new Int32Array(new SharedArrayBuffer(16));
|
|
assertEquals("timed-out", Atomics.wait(i32a, 0, 0, -1));
|
|
assertEquals("timed-out", Atomics.wait(i32a, 0, 0, -Infinity));
|
|
})();
|
|
|
|
(function TestWaitNotAllowed() {
|
|
%SetAllowAtomicsWait(false);
|
|
var i32a = new Int32Array(new SharedArrayBuffer(16));
|
|
assertThrows(function() {
|
|
Atomics.wait(i32a, 0, 0, -1);
|
|
});
|
|
%SetAllowAtomicsWait(true);
|
|
})();
|
|
|
|
(function TestWakePositiveInfinity() {
|
|
var i32a = new Int32Array(new SharedArrayBuffer(16));
|
|
Atomics.notify(i32a, 0, Number.POSITIVE_INFINITY);
|
|
})();
|
|
|
|
// In a previous version, this test caused a check failure
|
|
(function TestObjectWaitValue() {
|
|
var sab = new SharedArrayBuffer(16);
|
|
var i32a = new Int32Array(sab);
|
|
assertEquals("timed-out", Atomics.wait(i32a, 0, Math, 0));
|
|
})();
|
|
|
|
|
|
//// WORKER ONLY TESTS
|
|
|
|
if (this.Worker) {
|
|
|
|
var TestWaitWithTimeout = function(notify, timeout) {
|
|
var sab = new SharedArrayBuffer(16);
|
|
var i32a = new Int32Array(sab);
|
|
|
|
var workerScript =
|
|
`onmessage = function(msg) {
|
|
var i32a = new Int32Array(msg.sab, msg.offset);
|
|
var result = Atomics.wait(i32a, 0, 0, ${timeout});
|
|
postMessage(result);
|
|
};`;
|
|
|
|
var worker = new Worker(workerScript, {type: 'string'});
|
|
worker.postMessage({sab: sab, offset: offset});
|
|
|
|
// Spin until the worker is waiting on the futex.
|
|
while (%AtomicsNumWaitersForTesting(i32a, 0) != 1) {}
|
|
|
|
notify(i32a, 0, 1);
|
|
assertEquals("ok", worker.getMessage());
|
|
worker.terminate();
|
|
|
|
var worker2 = new Worker(workerScript, {type: 'string'});
|
|
var offset = 8;
|
|
var i32a2 = new Int32Array(sab, offset);
|
|
worker2.postMessage({sab: sab, offset: offset});
|
|
|
|
// Spin until the worker is waiting on the futex.
|
|
while (%AtomicsNumWaitersForTesting(i32a2, 0) != 1) {}
|
|
notify(i32a2, 0, 1);
|
|
assertEquals("ok", worker2.getMessage());
|
|
worker2.terminate();
|
|
|
|
// Futex should work when index and buffer views are different, but
|
|
// the real address is the same.
|
|
var worker3 = new Worker(workerScript, {type: 'string'});
|
|
i32a2 = new Int32Array(sab, 4);
|
|
worker3.postMessage({sab: sab, offset: 8});
|
|
|
|
// Spin until the worker is waiting on the futex.
|
|
while (%AtomicsNumWaitersForTesting(i32a2, 1) != 1) {}
|
|
notify(i32a2, 1, 1);
|
|
assertEquals("ok", worker3.getMessage());
|
|
worker3.terminate();
|
|
};
|
|
|
|
// Test various infinite timeouts
|
|
TestWaitWithTimeout(Atomics.notify, undefined);
|
|
TestWaitWithTimeout(Atomics.notify, NaN);
|
|
TestWaitWithTimeout(Atomics.notify, Infinity);
|
|
|
|
var TestWakeMulti = function(notify) {
|
|
var sab = new SharedArrayBuffer(20);
|
|
var i32a = new Int32Array(sab);
|
|
|
|
// SAB values:
|
|
// i32a[id], where id in range [0, 3]:
|
|
// 0 => Worker |id| is still waiting on the futex
|
|
// 1 => Worker |id| is not waiting on futex, but has not be reaped by the
|
|
// main thread.
|
|
// 2 => Worker |id| has been reaped.
|
|
//
|
|
// i32a[4]:
|
|
// always 0. Each worker is waiting on this index.
|
|
|
|
function workerCode() {
|
|
onmessage = function(msg) {
|
|
var id = msg.id;
|
|
var i32a = new Int32Array(msg.sab);
|
|
|
|
// Wait on i32a[4] (should be zero).
|
|
var result = Atomics.wait(i32a, 4, 0);
|
|
// Set i32a[id] to 1 to notify the main thread which workers were
|
|
// woken up.
|
|
Atomics.store(i32a, id, 1);
|
|
postMessage(result);
|
|
};
|
|
}
|
|
|
|
var id;
|
|
var workers = [];
|
|
for (id = 0; id < 4; id++) {
|
|
workers[id] = new Worker(workerCode, {type: 'function'});
|
|
workers[id].postMessage({sab: sab, id: id});
|
|
}
|
|
|
|
// Spin until all workers are waiting on the futex.
|
|
while (%AtomicsNumWaitersForTesting(i32a, 4) != 4) {}
|
|
|
|
// Wake up three waiters.
|
|
assertEquals(3, notify(i32a, 4, 3));
|
|
|
|
var wokenCount = 0;
|
|
var waitingId = 0 + 1 + 2 + 3;
|
|
while (wokenCount < 3) {
|
|
for (id = 0; id < 4; id++) {
|
|
// Look for workers that have not yet been reaped. Set i32a[id] to 2
|
|
// when they've been processed so we don't look at them again.
|
|
if (Atomics.compareExchange(i32a, id, 1, 2) == 1) {
|
|
assertEquals("ok", workers[id].getMessage());
|
|
workers[id].terminate();
|
|
waitingId -= id;
|
|
wokenCount++;
|
|
}
|
|
}
|
|
}
|
|
|
|
assertEquals(3, wokenCount);
|
|
assertEquals(0, Atomics.load(i32a, waitingId));
|
|
assertEquals(1, %AtomicsNumWaitersForTesting(i32a, 4));
|
|
|
|
// Finally wake the last waiter.
|
|
assertEquals(1, notify(i32a, 4, 1));
|
|
assertEquals("ok", workers[waitingId].getMessage());
|
|
workers[waitingId].terminate();
|
|
|
|
assertEquals(0, %AtomicsNumWaitersForTesting(i32a, 4));
|
|
|
|
};
|
|
|
|
TestWakeMulti(Atomics.notify);
|
|
}
|