File: open-request-queue.html

package info (click to toggle)
firefox-esr 78.15.0esr-1~deb11u1
  • links: PTS, VCS
  • area: main
  • in suites: bullseye
  • size: 3,301,156 kB
  • sloc: cpp: 5,665,905; javascript: 4,798,386; ansic: 2,878,233; python: 977,004; asm: 270,347; xml: 181,456; java: 111,756; sh: 72,926; makefile: 21,819; perl: 13,380; cs: 4,725; yacc: 4,565; objc: 3,026; pascal: 1,787; lex: 1,720; ada: 1,681; exp: 505; php: 436; lisp: 260; awk: 152; ruby: 103; csh: 80; sed: 53; sql: 45
file content (63 lines) | stat: -rw-r--r-- 2,132 bytes parent folder | download | duplicates (12)
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
<!doctype html>
<meta charset=utf-8>
<title>IndexedDB: open and delete requests are processed as a FIFO queue</title>
<link rel="help" href="https://w3c.github.io/IndexedDB/#request-connection-queue">
<script src="/resources/testharness.js"></script>
<script src="/resources/testharnessreport.js"></script>
<script src="support.js"></script>
<script>

async_test(t => {
    let db_name = 'db' + self.location.pathname + '-' + t.name;
    indexedDB.deleteDatabase(db_name);

    // Open and hold connection while other requests are queued up.
    let r = indexedDB.open(db_name, 1);
    r.onerror = t.unreached_func('open should succeed');
    r.onsuccess = t.step_func(e => {
        let db = r.result;

        let saw = expect(t, [
            'open1 success',
            'open1 versionchange',
            'delete1 blocked',
            'delete1 success',
            'open2 success',
            'open2 versionchange',
            'delete2 blocked',
            'delete2 success'
        ]);

        function open(token, version) {
            let r = indexedDB.open(db_name, version);
            r.onsuccess = t.step_func(e => {
                saw(token + ' success');
                let db = r.result;
                db.onversionchange = t.step_func(e => {
                    saw(token + ' versionchange');
                    setTimeout(t.step_func(() => db.close()), 0);
                });
            });
            r.onblocked = t.step_func(e => saw(token + ' blocked'));
            r.onerror = t.unreached_func('open should succeed');
        }

        function deleteDatabase(token) {
            let r = indexedDB.deleteDatabase(db_name);
            r.onsuccess = t.step_func(e => saw(token + ' success'));
            r.onblocked = t.step_func(e => saw(token + ' blocked'));
            r.onerror = t.unreached_func('deleteDatabase should succeed');
        }

        open('open1', 2);
        deleteDatabase('delete1');
        open('open2', 3);
        deleteDatabase('delete2');

        // Now unblock the queue.
        db.close();
    });

}, 'Opens and deletes are processed in order');

</script>