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
content / test / data / media / datachannel_test.html [blame]
<!DOCTYPE html>
<title>RTCDataChannel Content Browser Test</title>
<script type="text/javascript" src="webrtc_test_utilities.js"></script>
<script>
// Tests that an RTCDataChannel with event handlers is not garbage-collected
// prematurely.
async function testDataChannelGC() {
var pc1 = new RTCPeerConnection();
var pc2 = new RTCPeerConnection();
var iceCandidateHandler = function(rpc) {
return function(e) {
if (e.candidate) {
rpc.addIceCandidate(e.candidate);
}
}
};
pc1.addEventListener("icecandidate", iceCandidateHandler(pc2));
pc2.addEventListener("icecandidate", iceCandidateHandler(pc1));
var messagesReceived = 0;
var dc1 = pc1.createDataChannel(null);
const resultPromise = new Promise(resolve => {
dc1.addEventListener("open", function(e) {
console.log("dc1/open event");
var messagesToSend = 6;
var messagesSent = 0;
var id = setInterval(function() {
if (messagesReceived < messagesToSend) {
messagesSent++;
dc1.send("message #" + messagesSent);
} else if (messagesReceived == messagesToSend) {
clearInterval(id);
resolve();
return;
}
if (messagesSent == 3) {
gc(); // Force garbage collection (requires: --js-flags="--expose-gc").
}
}, 10);
});
});
pc2.addEventListener("datachannel", function(e) {
console.log("pc2/datachannel event");
var dc2 = e.channel;
dc2.addEventListener("message", function(e) {
console.log("dc2/message event: " + JSON.stringify(e.data));
messagesReceived++;
});
});
console.log("creating offer");
const sdp1 = await new Promise((resolve, reject) => {
pc1.createOffer(resolve, reject);
});
pc1.setLocalDescription(sdp1);
await new Promise((resolve, reject) => {
pc2.setRemoteDescription(sdp1, resolve, reject);
});
console.log("creating answer");
const sdp2 = await new Promise((resolve, reject) => {
pc2.createAnswer(resolve, reject);
});
pc1.setRemoteDescription(sdp2);
pc2.setLocalDescription(sdp2);
await resultPromise;
return logSuccess();
}
</script>