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
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
|
/* -*- Mode: javascript; tab-width: 2; indent-tabs-mode: nil; js-indent-level: 2 -*- */
requestLongerTimeout(3);
const BASE_URI = "http://mochi.test:8888/browser/dom/file/ipc/tests/empty.html";
add_task(async function test() {
await SpecialPowers.pushPrefEnv({
set: [
["dom.blob.memoryToTemporaryFile", 1],
["dom.ipc.processCount", 4],
],
});
let tab1 = await BrowserTestUtils.openNewForegroundTab(gBrowser, BASE_URI);
let browser1 = gBrowser.getBrowserForTab(tab1);
let tab2 = await BrowserTestUtils.openNewForegroundTab(gBrowser, BASE_URI);
let browser2 = gBrowser.getBrowserForTab(tab2);
await SpecialPowers.spawn(browser2, [], function () {
content.window.testPromise = new content.window.Promise(resolve => {
let bc = new content.window.BroadcastChannel("foobar");
bc.onmessage = e => {
function realTest() {
return new content.window.Promise(resolve => {
let count = 10;
for (let i = 0; i < count; ++i) {
info("FileReader at the same time: " + i);
let fr = new content.window.FileReader();
fr.readAsText(e.data);
fr.onerror = () => {
ok(false, "Something wrong happened.");
};
fr.onloadend = () => {
is(fr.result.length, e.data.size, "FileReader worked fine.");
if (!--count) {
resolve(true);
}
};
}
});
}
let promises = [];
for (let i = 0; i < 5; ++i) {
promises.push(realTest());
}
Promise.all(promises).then(() => {
resolve(true);
});
};
});
});
let status = await SpecialPowers.spawn(browser1, [], function () {
let p = new content.window.Promise(resolve => {
let xhr = new content.window.XMLHttpRequest();
xhr.open("GET", "temporary.sjs", true);
xhr.responseType = "blob";
xhr.onload = () => {
resolve(xhr.response);
};
xhr.send();
});
return p.then(blob => {
function realTest() {
return new content.window.Promise(resolve => {
info("Let's broadcast the blob...");
let bc = new content.window.BroadcastChannel("foobar");
bc.postMessage(blob);
info("Here the test...");
let count = 10;
for (let i = 0; i < count; ++i) {
info("FileReader at the same time: " + i);
let fr = new content.window.FileReader();
fr.readAsText(blob);
fr.onerror = () => {
ok(false, "Something wrong happened.");
};
fr.onloadend = () => {
is(fr.result.length, blob.size, "FileReader worked fine.");
if (!--count) {
resolve(true);
}
};
}
});
}
let promises = [];
for (let i = 0; i < 5; ++i) {
promises.push(realTest());
}
return Promise.all(promises);
});
});
ok(status, "All good for tab1!");
status = await SpecialPowers.spawn(browser2, [], function () {
return content.window.testPromise;
});
ok(status, "All good for tab2!");
BrowserTestUtils.removeTab(tab1);
BrowserTestUtils.removeTab(tab2);
});
|
