76 lines
2.4 KiB
HTML
76 lines
2.4 KiB
HTML
<!doctype html>
|
|
<meta charset=utf-8>
|
|
<meta name="timeout" content="long">
|
|
<title>RTCDataChannel interactions with ICE restart</title>
|
|
<script src="/resources/testharness.js"></script>
|
|
<script src="/resources/testharnessreport.js"></script>
|
|
<script src="RTCPeerConnection-helper.js"></script>
|
|
<script>
|
|
'use strict';
|
|
|
|
async function checkCanPassData(channel1, channel2) {
|
|
channel1.send('hello');
|
|
const message = await awaitMessage(channel2);
|
|
assert_equals(message, 'hello');
|
|
}
|
|
|
|
async function pingPongData(channel1, channel2, size=1) {
|
|
channel1.send('hello');
|
|
const request = await awaitMessage(channel2);
|
|
assert_equals(request, 'hello');
|
|
const response = 'x'.repeat(size);
|
|
channel2.send(response);
|
|
const responseReceived = await awaitMessage(channel1);
|
|
assert_equals(response, responseReceived);
|
|
}
|
|
|
|
promise_test(async t => {
|
|
const pc1 = new RTCPeerConnection();
|
|
t.add_cleanup(() => pc1.close());
|
|
const pc2 = new RTCPeerConnection();
|
|
t.add_cleanup(() => pc2.close());
|
|
|
|
const [channel1, channel2] = await createDataChannelPair(t, {}, pc1, pc2);
|
|
channel2.addEventListener('error', t.unreached_func());
|
|
channel2.addEventListener('error', t.unreached_func());
|
|
|
|
await checkCanPassData(channel1, channel2);
|
|
await checkCanPassData(channel2, channel1);
|
|
|
|
pc1.restartIce();
|
|
await exchangeOfferAnswer(pc1, pc2);
|
|
|
|
await checkCanPassData(channel1, channel2);
|
|
await checkCanPassData(channel2, channel1);
|
|
channel1.close();
|
|
channel2.close();
|
|
}, `Data channel remains usable after ICE restart`);
|
|
|
|
promise_test(async t => {
|
|
const pc1 = new RTCPeerConnection();
|
|
t.add_cleanup(() => pc1.close());
|
|
const pc2 = new RTCPeerConnection();
|
|
t.add_cleanup(() => pc2.close());
|
|
|
|
const [channel1, channel2] = await createDataChannelPair(t, {}, pc1, pc2);
|
|
channel2.addEventListener('error', t.unreached_func());
|
|
channel2.addEventListener('error', t.unreached_func());
|
|
|
|
await pingPongData(channel1, channel2);
|
|
pc1.restartIce();
|
|
|
|
await pc1.setLocalDescription();
|
|
await pingPongData(channel1, channel2);
|
|
await pc2.setRemoteDescription(pc1.localDescription);
|
|
await pingPongData(channel1, channel2);
|
|
await pc2.setLocalDescription(await pc2.createAnswer());
|
|
await pingPongData(channel1, channel2);
|
|
await pc1.setRemoteDescription(pc2.localDescription);
|
|
await pingPongData(channel1, channel2);
|
|
channel1.close();
|
|
channel2.close();
|
|
}, `Data channel remains usable at each step of an ICE restart`);
|
|
|
|
|
|
|
|
</script>
|