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
|
<!doctype html>
<html>
<head>
<meta charset=utf-8>
<meta name="timeout" content="long">
<script src="/resources/testharness.js"></script>
<script src="/resources/testharnessreport.js"></script>
<script src="/common/gc.js"></script>
<script src="RTCPeerConnection-helper.js"></script>
</head>
<body>
<script>
'use strict';
// Check that RTCDataChannel is not collected by GC while observing remote pc close
async function didRemotePcClose(t, closeRemotePc) {
let pc1 = new RTCPeerConnection(), pc2 = new RTCPeerConnection();
t.add_cleanup(async () => await garbageCollect());
pc1.onicecandidate = e => pc2.addIceCandidate(e.candidate);
pc2.onicecandidate = e => pc1.addIceCandidate(e.candidate);
let dc1 = pc1.createDataChannel("");
const haveOpened = new Promise(r => dc1.onopen = r);
let closed = false;
const haveClosed = new Promise(r => dc1.onclose = () => r(closed = true));
dc1 = null;
await pc1.setLocalDescription();
await pc2.setRemoteDescription(pc1.localDescription);
await pc2.setLocalDescription();
await pc1.setRemoteDescription(pc2.localDescription);
await haveOpened;
if (closeRemotePc) pc2.close();
pc1 = pc2 = null;
await garbageCollect();
await Promise.race([haveClosed, new Promise(r => t.step_timeout(r, 10000))]);
return closed;
}
promise_test(async t => {
assert_true(await didRemotePcClose(t, true));
}, "Control: detected remote PC being closed using a data channel");
promise_test(async t => {
assert_false(await didRemotePcClose(t, false));
}, "While remote PC remains open, its datachannel should not be collected");
</script>
</body>
</html>
|
