110 lines
4.4 KiB
HTML
110 lines
4.4 KiB
HTML
<!doctype html>
|
|
<meta charset=utf-8>
|
|
<title>No RTCRtpStreamStats should exist prior to RTP/RTCP packet flow</title>
|
|
<script src="/resources/testharness.js"></script>
|
|
<script src="/resources/testharnessreport.js"></script>
|
|
<script src="../webrtc/RTCPeerConnection-helper.js"></script>
|
|
<script>
|
|
'use strict';
|
|
|
|
promise_test(async (test) => {
|
|
const localPc = createPeerConnectionWithCleanup(test);
|
|
const remotePc = createPeerConnectionWithCleanup(test);
|
|
|
|
localPc.addTransceiver("audio");
|
|
localPc.addTransceiver("video");
|
|
await exchangeOfferAndListenToOntrack(test, localPc, remotePc);
|
|
const report = await remotePc.getStats();
|
|
const rtp = [...report.values()].filter(({type}) => type.endsWith("rtp"));
|
|
assert_equals(rtp.length, 0, "no rtp stats with only remote description");
|
|
}, "No RTCRtpStreamStats exist when only remote description is set");
|
|
|
|
promise_test(async (test) => {
|
|
const localPc = createPeerConnectionWithCleanup(test);
|
|
const remotePc = createPeerConnectionWithCleanup(test);
|
|
|
|
localPc.addTrack(...await createTrackAndStreamWithCleanup(test, "audio"));
|
|
localPc.addTrack(...await createTrackAndStreamWithCleanup(test, "video"));
|
|
await exchangeOfferAndListenToOntrack(test, localPc, remotePc);
|
|
const report = await localPc.getStats();
|
|
const rtp = [...report.values()].filter(({type}) => type.endsWith("rtp"));
|
|
assert_equals(rtp.length, 0, "no rtp stats with only local description");
|
|
}, "No RTCRtpStreamStats exist when only local description is set");
|
|
|
|
promise_test(async (test) => {
|
|
const localPc = createPeerConnectionWithCleanup(test);
|
|
const remotePc = createPeerConnectionWithCleanup(test);
|
|
|
|
localPc.addTrack(...await createTrackAndStreamWithCleanup(test, "audio"));
|
|
localPc.addTrack(...await createTrackAndStreamWithCleanup(test, "video"));
|
|
exchangeIceCandidates(localPc, remotePc);
|
|
await Promise.all([
|
|
exchangeOfferAnswer(localPc, remotePc),
|
|
new Promise(r => remotePc.ontrack = e => e.track.onunmute = r)
|
|
]);
|
|
const start = performance.now();
|
|
while (true) {
|
|
const report = await localPc.getStats();
|
|
const outbound =
|
|
[...report.values()].filter(({type}) => type == "outbound-rtp");
|
|
assert_true(outbound.every(({packetsSent}) => packetsSent > 0),
|
|
"no outbound rtp stats before packets sent");
|
|
if (outbound.length == 2) {
|
|
// One outbound stat for each track is present. We're done.
|
|
break;
|
|
}
|
|
if (performance.now() > start + 5000) {
|
|
assert_unreached("outbound stats should become available");
|
|
}
|
|
await new Promise(r => test.step_timeout(r, 100));
|
|
}
|
|
}, "No RTCOutboundRtpStreamStats exist until packets have been sent");
|
|
|
|
promise_test(async (test) => {
|
|
const localPc = createPeerConnectionWithCleanup(test);
|
|
const remotePc = createPeerConnectionWithCleanup(test);
|
|
|
|
localPc.addTrack(...await createTrackAndStreamWithCleanup(test, "audio"));
|
|
localPc.addTrack(...await createTrackAndStreamWithCleanup(test, "video"));
|
|
exchangeIceCandidates(localPc, remotePc);
|
|
await exchangeOfferAnswer(localPc, remotePc);
|
|
const start = performance.now();
|
|
while (true) {
|
|
const report = await remotePc.getStats();
|
|
const inbound =
|
|
[...report.values()].filter(({type}) => type == "inbound-rtp");
|
|
assert_true(inbound.every(({packetsReceived}) => packetsReceived > 0),
|
|
"no inbound rtp stats before packets received");
|
|
if (inbound.length == 2) {
|
|
// One inbound stat for each track is present. We're done.
|
|
break;
|
|
}
|
|
if (performance.now() > start + 5000) {
|
|
assert_unreached("inbound stats should become available");
|
|
}
|
|
await new Promise(r => test.step_timeout(r, 100));
|
|
}
|
|
}, "No RTCInboundRtpStreamStats exist until packets have been received");
|
|
|
|
promise_test(async (test) => {
|
|
const localPc = createPeerConnectionWithCleanup(test);
|
|
const remotePc = createPeerConnectionWithCleanup(test);
|
|
|
|
localPc.addTrack(...await createTrackAndStreamWithCleanup(test, "audio"));
|
|
exchangeIceCandidates(localPc, remotePc);
|
|
await exchangeOfferAnswer(localPc, remotePc);
|
|
const start = performance.now();
|
|
while (true) {
|
|
const report = await remotePc.getStats();
|
|
const audioPlayout =
|
|
[...report.values()].filter(({type}) => type == "media-playout");
|
|
if (audioPlayout.length == 1) {
|
|
break;
|
|
}
|
|
if (performance.now() > start + 5000) {
|
|
assert_unreached("Audio playout stats should become available");
|
|
}
|
|
await new Promise(r => test.step_timeout(r, 100));
|
|
}
|
|
}, "RTCAudioPlayoutStats should be present");
|
|
</script>
|