1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
|
// META: title=Web Locks API: Mixed Modes
// META: script=resources/helpers.js
// META: global=window,dedicatedworker,sharedworker,serviceworker
'use strict';
promise_test(async t => {
let unblock;
const blocked = new Promise(r => { unblock = r; });
const granted = [];
// These should be granted immediately, and held until unblocked.
navigator.locks.request('a', {mode: 'shared'}, async lock => {
granted.push('a-shared-1'); await blocked; });
navigator.locks.request('a', {mode: 'shared'}, async lock => {
granted.push('a-shared-2'); await blocked; });
navigator.locks.request('a', {mode: 'shared'}, async lock => {
granted.push('a-shared-3'); await blocked; });
// This should be blocked.
let exclusive_lock;
const exclusive_request = navigator.locks.request('a', async lock => {
granted.push('a-exclusive');
exclusive_lock = lock;
});
// This should be granted immediately (different name).
await navigator.locks.request('b', {mode: 'exclusive'}, lock => {
granted.push('b-exclusive'); });
assert_array_equals(
granted, ['a-shared-1', 'a-shared-2', 'a-shared-3', 'b-exclusive']);
// Release the shared locks granted above.
unblock();
// Now the blocked request can be granted.
await exclusive_request;
assert_equals(exclusive_lock.mode, 'exclusive');
assert_array_equals(
granted,
['a-shared-1', 'a-shared-2', 'a-shared-3', 'b-exclusive', 'a-exclusive']);
}, 'Lock requests are granted in order');
promise_test(async t => {
const res = uniqueName(t);
let [promise, resolve] = makePromiseAndResolveFunc();
const exclusive = navigator.locks.request(res, () => promise);
for (let i = 0; i < 5; i++) {
requestLockAndHold(t, res, { mode: "shared" });
}
let answer = await navigator.locks.query();
assert_equals(answer.held.length, 1, "An exclusive lock is held");
assert_equals(answer.pending.length, 5, "Requests for shared locks are pending");
resolve();
await exclusive;
answer = await navigator.locks.query();
assert_equals(answer.held.length, 5, "Shared locks are held");
assert_true(answer.held.every(l => l.mode === "shared"), "All held locks are shared ones");
}, 'Releasing exclusive lock grants multiple shared locks');
promise_test(async t => {
const res = uniqueName(t);
let [sharedPromise, sharedResolve] = makePromiseAndResolveFunc();
let [exclusivePromise, exclusiveResolve] = makePromiseAndResolveFunc();
const sharedReleasedPromise = Promise.all(new Array(5).fill(0).map(
() => navigator.locks.request(res, { mode: "shared" }, () => sharedPromise))
);
const exclusiveReleasedPromise = navigator.locks.request(res, () => exclusivePromise);
for (let i = 0; i < 5; i++) {
requestLockAndHold(t, res, { mode: "shared" });
}
let answer = await navigator.locks.query();
assert_equals(answer.held.length, 5, "Shared locks are held");
assert_true(answer.held.every(l => l.mode === "shared"), "All held locks are shared ones");
sharedResolve();
await sharedReleasedPromise;
answer = await navigator.locks.query();
assert_equals(answer.held.length, 1, "An exclusive lock is held");
assert_equals(answer.held[0].mode, "exclusive");
exclusiveResolve();
await exclusiveReleasedPromise;
answer = await navigator.locks.query();
assert_equals(answer.held.length, 5, "The next shared locks are held");
assert_true(answer.held.every(l => l.mode === "shared"), "All held locks are shared ones");
}, 'An exclusive lock between shared locks');
|
