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
|
// How long (in ms) these tests should wait before deciding no further messages
// will be received.
const time_to_wait_for_messages = 100;
async_test(t => {
const c = new MessageChannel();
c.port1.onmessage = t.unreached_func('Should not have delivered message');
c.port1.close();
c.port2.postMessage('TEST');
setTimeout(t.step_func_done(), time_to_wait_for_messages);
}, 'Message sent to closed port should not arrive.');
async_test(t => {
const c = new MessageChannel();
c.port1.onmessage = t.unreached_func('Should not have delivered message');
c.port2.close();
c.port2.postMessage('TEST');
setTimeout(t.step_func_done(), time_to_wait_for_messages);
}, 'Message sent from closed port should not arrive.');
async_test(t => {
const c = new MessageChannel();
c.port1.onmessage = t.unreached_func('Should not have delivered message');
c.port1.close();
const c2 = new MessageChannel();
c2.port1.onmessage = t.step_func(e => {
e.ports[0].postMessage('TESTMSG');
setTimeout(t.step_func_done(), time_to_wait_for_messages);
});
c2.port2.postMessage('TEST', [c.port2]);
}, 'Message sent to closed port from transferred port should not arrive.');
async_test(t => {
const c = new MessageChannel();
let isClosed = false;
c.port1.onmessage = t.step_func_done(e => {
assert_true(isClosed);
assert_equals(e.data, 'TEST');
});
c.port2.postMessage('TEST');
c.port2.close();
isClosed = true;
}, 'Inflight messages should be delivered even when sending port is closed afterwards.');
async_test(t => {
const c = new MessageChannel();
c.port1.onmessage = t.step_func_done(e => {
if (e.data == 'DONE') t.done();
assert_equals(e.data, 'TEST');
c.port1.close();
});
c.port2.postMessage('TEST');
c.port2.postMessage('DONE');
}, 'Close in onmessage should not cancel inflight messages.');
test(() => {
const c1 = new MessageChannel();
const c2 = new MessageChannel();
c1.port1.close();
assert_throws_dom("DataCloneError", () => c2.port1.postMessage(null, [c1.port1]));
c2.port1.postMessage(null, [c1.port2]);
}, "close() detaches a MessagePort (but not the one its entangled with)");
|
