webrtc/RTCDataChannel-GC.html

<!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;
  // Spec says having a "close" event handler prevents GC, and if the
  // datachannel is immune to GC, it should prevent the peerconnection from
  // being GCed too.
  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 = 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));
}, "Having a 'close' event handler registered should prevent a datachannel from being GCed");
</script>
</body>
</html>