<!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.
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);
  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);
        reportTestSuccess();
        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");
  pc1.createOffer(function(sdp1) {
    pc1.setLocalDescription(sdp1);
    pc2.setRemoteDescription(sdp1, function() {
      console.log("creating answer");
      pc2.createAnswer(function(sdp2) {
        pc1.setRemoteDescription(sdp2);
        pc2.setLocalDescription(sdp2);
      }, error => failTest(error.toString()));
    }, error => failTest(error.toString()));
  }, error => failTest(error.toString()));
}
</script>