| <!doctype html> |
| <title>Test RTCPeerConnection.prototype.addIceCandidate</title> |
| <script src="/resources/testharness.js"></script> |
| <script src="/resources/testharnessreport.js"></script> |
| <script src="RTCPeerConnection-helper.js"></script> |
| <script> |
| 'use strict'; |
| |
| // This test may be flaky, so it's in its own file. |
| // The test belongs in RTCPeerConnection-addIceCandidate. |
| |
| promise_test(async t => { |
| const pc1 = new RTCPeerConnection(); |
| const pc2 = new RTCPeerConnection(); |
| t.add_cleanup(() => pc1.close()); |
| t.add_cleanup(() => pc2.close()); |
| const transceiver = pc1.addTransceiver('video'); |
| |
| exchangeIceCandidates(pc1, pc2); |
| await exchangeOffer(pc1, pc2); |
| const answer = await pc2.createAnswer(); |
| // Note that sequence of the following two calls is critical |
| // for test stability. |
| await pc1.setRemoteDescription(answer); |
| await pc2.setLocalDescription(answer); |
| await waitForState(transceiver.sender.transport, 'connected'); |
| }, 'Candidates are added dynamically; connection should work'); |
| |
| promise_test(async t => { |
| const pc1 = new RTCPeerConnection(); |
| const pc2 = new RTCPeerConnection(); |
| t.add_cleanup(() => pc1.close()); |
| t.add_cleanup(() => pc2.close()); |
| const transceiver = pc1.addTransceiver('video'); |
| |
| let candidates1to2 = []; |
| let candidates2to1 = []; |
| pc1.onicecandidate = e => candidates1to2.push(e.candidate); |
| pc2.onicecandidate = e => candidates2to1.push(e.candidate); |
| const pc2GatheredCandidates = new Promise((resolve) => { |
| pc2.addEventListener('icegatheringstatechange', () => { |
| if (pc2.iceGatheringState == 'complete') { |
| resolve(); |
| } |
| }); |
| }); |
| await exchangeOffer(pc1, pc2); |
| let answer = await pc2.createAnswer(); |
| await pc1.setRemoteDescription(answer); |
| await pc2.setLocalDescription(answer); |
| await pc2GatheredCandidates; |
| // Add candidates to pc1, ensuring that it goes to "connecting" state before "connected". |
| for (let candidate of candidates2to1) { |
| await pc1.addIceCandidate(candidate); |
| } |
| await waitForState(transceiver.sender.transport, 'connecting'); |
| await waitForState(transceiver.sender.transport, 'connected'); |
| }, 'Candidates are added at PC1; connection should work'); |
| |
| promise_test(async t => { |
| const pc1 = new RTCPeerConnection(); |
| const pc2 = new RTCPeerConnection(); |
| t.add_cleanup(() => pc1.close()); |
| t.add_cleanup(() => pc2.close()); |
| const transceiver = pc1.addTransceiver('video'); |
| |
| let candidates1to2 = []; |
| let candidates2to1 = []; |
| pc1.onicecandidate = e => candidates1to2.push(e.candidate); |
| pc2.onicecandidate = e => candidates2to1.push(e.candidate); |
| const pc1GatheredCandidates = new Promise((resolve) => { |
| pc1.addEventListener('icegatheringstatechange', () => { |
| if (pc1.iceGatheringState == 'complete') { |
| resolve(); |
| } |
| }); |
| }); |
| await exchangeOffer(pc1, pc2); |
| let answer = await pc2.createAnswer(); |
| await pc1.setRemoteDescription(answer); |
| await pc2.setLocalDescription(answer); |
| await pc1GatheredCandidates; |
| // Add candidates to pc2 |
| for (let candidate of candidates1to2) { |
| await pc2.addIceCandidate(candidate); |
| } |
| await waitForState(transceiver.sender.transport, 'connected'); |
| }, 'Candidates are added at PC2; connection should work'); |
| |
| </script> |
