diff options
| author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-19 01:47:29 +0000 |
|---|---|---|
| committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-19 01:47:29 +0000 |
| commit | 0ebf5bdf043a27fd3dfb7f92e0cb63d88954c44d (patch) | |
| tree | a31f07c9bcca9d56ce61e9a1ffd30ef350d513aa /testing/web-platform/tests/webrtc-extensions/RTCRtpReceiver-jitterBufferTarget-stats.html | |
| parent | Initial commit. (diff) | |
| download | firefox-esr-0ebf5bdf043a27fd3dfb7f92e0cb63d88954c44d.tar.xz firefox-esr-0ebf5bdf043a27fd3dfb7f92e0cb63d88954c44d.zip | |
Adding upstream version 115.8.0esr.upstream/115.8.0esr
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'testing/web-platform/tests/webrtc-extensions/RTCRtpReceiver-jitterBufferTarget-stats.html')
| -rw-r--r-- | testing/web-platform/tests/webrtc-extensions/RTCRtpReceiver-jitterBufferTarget-stats.html | 96 |
1 files changed, 96 insertions, 0 deletions
diff --git a/testing/web-platform/tests/webrtc-extensions/RTCRtpReceiver-jitterBufferTarget-stats.html b/testing/web-platform/tests/webrtc-extensions/RTCRtpReceiver-jitterBufferTarget-stats.html new file mode 100644 index 0000000000..33f71800bd --- /dev/null +++ b/testing/web-platform/tests/webrtc-extensions/RTCRtpReceiver-jitterBufferTarget-stats.html @@ -0,0 +1,96 @@ +<!DOCTYPE html> +<meta charset="utf-8"> +<meta name="timeout" content="long"> +<title>Tests RTCRtpReceiver-jitterBufferTarget verified with stats</title> +<script src="/resources/testharness.js"></script> +<script src="/resources/testharnessreport.js"></script> +<script src="/webrtc/RTCPeerConnection-helper.js"></script> +<body> +<script> +'use strict' + +function async_promise_test(func, name, properties) { + async_test(t => { + Promise.resolve(func(t)) + .catch(t.step_func(e => { throw e; })) + .then(() => t.done()); + }, name, properties); +} + +async_promise_test(t => applyJitterBufferTarget(t, "video", 4000), + "measure raising and lowering video jitterBufferTarget"); +async_promise_test(t => applyJitterBufferTarget(t, "audio", 4000), + "measure raising and lowering audio jitterBufferTarget"); + +async function applyJitterBufferTarget(t, kind, target) { + const caller = new RTCPeerConnection(); + t.add_cleanup(() => caller.close()); + const callee = new RTCPeerConnection(); + t.add_cleanup(() => callee.close()); + + const stream = await getNoiseStream({[kind]:true}); + t.add_cleanup(() => stream.getTracks().forEach(track => track.stop())); + caller.addTransceiver(stream.getTracks()[0], {streams: [stream]}); + caller.addTransceiver(stream.getTracks()[0], {streams: [stream]}); + + exchangeIceCandidates(caller, callee); + await exchangeOffer(caller, callee); + const [unconstrainedReceiver, constrainedReceiver] = callee.getReceivers(); + const haveRtp = Promise.all([ + new Promise(r => constrainedReceiver.track.onunmute = r), + new Promise(r => unconstrainedReceiver.track.onunmute = r) + ]); + await exchangeAnswer(caller, callee); + const chromeTimeout = new Promise(r => t.step_timeout(r, 1000)); // crbug.com/1295295 + await Promise.race([haveRtp, chromeTimeout]); + + // Allow some data to be processed to let the jitter buffer to stabilize a bit before measuring + await new Promise(r => t.step_timeout(r, 5000)); + + t.step(() => assert_equals(constrainedReceiver.jitterBufferTarget, null, + `jitterBufferTarget supported for ${kind}`)); + + constrainedReceiver.jitterBufferTarget = target; + t.step(() => assert_equals(constrainedReceiver.jitterBufferTarget, target, + `jitterBufferTarget increase target for ${kind}`)); + + const [increased, base] = await Promise.all([ + measureDelayFromStats(t, constrainedReceiver, 20), + measureDelayFromStats(t, unconstrainedReceiver, 20) + ]); + + t.step(() => assert_greater_than(increased , base, + `${kind} increased delay ${increased} ` + + ` greater than base delay ${base}`)); + + constrainedReceiver.jitterBufferTarget = 0; + + // Allow the jitter buffer to stabilize a bit before measuring + await new Promise(r => t.step_timeout(r, 5000)); + t.step(() => assert_equals(constrainedReceiver.jitterBufferTarget, 0, + `jitterBufferTarget decrease target for ${kind}`)); + + const decreased = await measureDelayFromStats(t, constrainedReceiver, 20); + + t.step(() => assert_less_than(decreased, increased, + `${kind} decreasedDelay ${decreased} ` + + `less than increased delay ${increased}`)); +} + +async function measureDelayFromStats(t, receiver, cycles) { + + let statsReport = await receiver.getStats(); + const oldInboundStats = [...statsReport.values()].find(({type}) => type == "inbound-rtp"); + + await new Promise(r => t.step_timeout(r, 1000 * cycles)); + + statsReport = await receiver.getStats(); + const inboundStats = [...statsReport.values()].find(({type}) => type == "inbound-rtp"); + + const delay = ((inboundStats.jitterBufferDelay - oldInboundStats.jitterBufferDelay) / + (inboundStats.jitterBufferEmittedCount - oldInboundStats.jitterBufferEmittedCount) * 1000); + + return delay; +} +</script> +</body> |