72 lines
3 KiB
HTML
72 lines
3 KiB
HTML
<!doctype html>
|
|
<meta charset=utf-8>
|
|
<meta name="timeout" content="long">
|
|
<title>RTCPeerConnection.prototype.iceConnectionState - disconnection</title>
|
|
<script src="/resources/testharness.js"></script>
|
|
<script src="/resources/testharnessreport.js"></script>
|
|
<script src="RTCPeerConnection-helper.js"></script>
|
|
<script>
|
|
'use strict';
|
|
promise_test(async t => {
|
|
const caller = new RTCPeerConnection();
|
|
t.add_cleanup(() => caller.close());
|
|
const callee = new RTCPeerConnection();
|
|
t.add_cleanup(() => callee.close());
|
|
|
|
const stream = await getNoiseStream({audio:true});
|
|
t.add_cleanup(() => stream.getTracks().forEach(track => track.stop()));
|
|
const [track] = stream.getTracks();
|
|
caller.addTrack(track, stream);
|
|
exchangeIceCandidates(caller, callee);
|
|
await exchangeOfferAnswer(caller, callee);
|
|
|
|
await listenToIceConnected(caller);
|
|
|
|
callee.close();
|
|
await waitForIceStateChange(caller, ['disconnected', 'failed']);
|
|
// TODO: this should eventually transition to failed but that takes
|
|
// somewhat long (15-30s) so is not testable.
|
|
}, 'ICE goes to disconnected if the other side goes away');
|
|
|
|
promise_test(async t => {
|
|
const caller = new RTCPeerConnection();
|
|
t.add_cleanup(() => caller.close());
|
|
const callee = new RTCPeerConnection();
|
|
t.add_cleanup(() => callee.close());
|
|
caller.addTransceiver('audio', {direction: 'sendrecv'});
|
|
exchangeIceCandidates(caller, callee);
|
|
await exchangeOfferAnswer(caller, callee);
|
|
await listenToIceConnected(caller);
|
|
|
|
// Now, we pull a fast one, and convince callee to abandon the transport
|
|
// without telling caller.
|
|
await caller.setLocalDescription();
|
|
await callee.setRemoteDescription(caller.localDescription);
|
|
const staleAnswer = await callee.createAnswer();
|
|
await callee.setRemoteDescription({type: 'rollback', sdp: ''});
|
|
|
|
const mlineRegex = /m=audio [0-9]+ /;
|
|
const mungedOfferSdp = caller.localDescription.sdp
|
|
.replace(mlineRegex, 'm=audio 0 ')
|
|
.replace('BUNDLE', 'BUNGLE'); // Avoid "But that mid is rejected!" errors
|
|
|
|
// callee gets the munged reoffer with a rejected m-section, caller gets a
|
|
// stale answer that was made before callee saw the rejected m-section.
|
|
await callee.setRemoteDescription({type: 'offer', sdp: mungedOfferSdp});
|
|
await callee.setLocalDescription();
|
|
await caller.setRemoteDescription(staleAnswer);
|
|
assert_equals(await nextIceConnectionState(caller), 'disconnected');
|
|
|
|
// Now, let's fix this with an ICE restart! callee has already negotiated
|
|
// a rejection of the first m-section, so it will tolerate it being
|
|
// revived.
|
|
caller.restartIce();
|
|
await caller.setLocalDescription();
|
|
await callee.setRemoteDescription(caller.localDescription);
|
|
await callee.setLocalDescription();
|
|
await caller.setRemoteDescription(callee.localDescription);
|
|
assert_equals(await nextIceConnectionState(caller), 'checking');
|
|
assert_equals(await nextIceConnectionState(caller), 'connected');
|
|
}, 'ICE restart when ICE is disconnected results in checking, then connected');
|
|
|
|
</script>
|