| <!doctype html> |
| <meta charset=utf-8> |
| <title>RTCPeerConnection Simulcast Tests - setParameters/active</title> |
| <meta name="timeout" content="long"> |
| <script src="../third_party/sdp/sdp.js"></script> |
| <script src="simulcast.js"></script> |
| <script src="../RTCPeerConnection-helper.js"></script> |
| <script src="/resources/testharness.js"></script> |
| <script src="/resources/testharnessreport.js"></script> |
| <script src="/resources/testdriver.js"></script> |
| <script src="/resources/testdriver-vendor.js"></script> |
| <script src="../../mediacapture-streams/permission-helper.js"></script> |
| <script> |
| async function queryReceiverStats(pc) { |
| const inboundStats = |
| await Promise.all(pc.getReceivers().map(async receiver => { |
| const receiverStats = await receiver.getStats(); |
| let inboundStat; |
| receiverStats.forEach(stat => { |
| if (stat.type === 'inbound-rtp') { |
| inboundStat = stat; |
| } |
| }); |
| return inboundStat; |
| })); |
| return inboundStats.map(s => s.framesDecoded); |
| } |
| |
| promise_test(async t => { |
| const rids = [0, 1]; |
| const pc1 = new RTCPeerConnection(); |
| t.add_cleanup(() => pc1.close()); |
| const pc2 = new RTCPeerConnection(); |
| t.add_cleanup(() => pc2.close()); |
| |
| await negotiateSimulcastAndWaitForVideo(t, await getCameraStream(t), rids, pc1, pc2); |
| |
| // Deactivate first sender. |
| const parameters = pc1.getSenders()[0].getParameters(); |
| parameters.encodings[0].active = false; |
| await pc1.getSenders()[0].setParameters(parameters); |
| |
| // Assert (almost) no new frames are received on the first encoding. |
| // Without any action we would expect to have received around 30fps. |
| await new Promise(resolve => t.step_timeout(resolve, 200)); // Wait a bit. |
| const initialStats = await queryReceiverStats(pc2); |
| await new Promise(resolve => t.step_timeout(resolve, 1000)); // Wait more. |
| const subsequentStats = await queryReceiverStats(pc2); |
| |
| assert_equals(subsequentStats[0], initialStats[0]); |
| assert_greater_than(subsequentStats[1], initialStats[1]); |
| }, 'Simulcast setParameters active=false on first encoding stops sending frames for that encoding'); |
| |
| promise_test(async t => { |
| const rids = [0, 1]; |
| const pc1 = new RTCPeerConnection(); |
| t.add_cleanup(() => pc1.close()); |
| const pc2 = new RTCPeerConnection(); |
| t.add_cleanup(() => pc2.close()); |
| |
| await negotiateSimulcastAndWaitForVideo(t, await getCameraStream(t), rids, pc1, pc2); |
| |
| // Deactivate second sender. |
| const parameters = pc1.getSenders()[0].getParameters(); |
| parameters.encodings[1].active = false; |
| await pc1.getSenders()[0].setParameters(parameters); |
| |
| // Assert (almost) no new frames are received on the second encoding. |
| // Without any action we would expect to have received around 30fps. |
| await new Promise(resolve => t.step_timeout(resolve, 200)); // Wait a bit. |
| const initialStats = await queryReceiverStats(pc2); |
| await new Promise(resolve => t.step_timeout(resolve, 1000)); // Wait more. |
| const subsequentStats = await queryReceiverStats(pc2); |
| |
| assert_equals(subsequentStats[1], initialStats[1]); |
| assert_greater_than(subsequentStats[0], initialStats[0]); |
| }, 'Simulcast setParameters active=false on second encoding stops sending frames for that encoding'); |
| |
| promise_test(async t => { |
| const rids = [0, 1]; |
| const pc1 = new RTCPeerConnection(); |
| t.add_cleanup(() => pc1.close()); |
| const pc2 = new RTCPeerConnection(); |
| t.add_cleanup(() => pc2.close()); |
| |
| await negotiateSimulcastAndWaitForVideo(t, await getCameraStream(t), rids, pc1, pc2); |
| |
| // Deactivate all senders. |
| const parameters = pc1.getSenders()[0].getParameters(); |
| parameters.encodings.forEach(e => { |
| e.active = false; |
| }); |
| await pc1.getSenders()[0].setParameters(parameters); |
| |
| // Assert (almost) no new frames are received. |
| // Without any action we would expect to have received around 30fps. |
| await new Promise(resolve => t.step_timeout(resolve, 200)); // Wait a bit. |
| const initialStats = await queryReceiverStats(pc2); |
| await new Promise(resolve => t.step_timeout(resolve, 1000)); // Wait more. |
| const subsequentStats = await queryReceiverStats(pc2); |
| |
| subsequentStats.forEach((framesDecoded, idx) => { |
| assert_equals(framesDecoded, initialStats[idx]); |
| }); |
| }, 'Simulcast setParameters active=false stops sending frames'); |
| </script> |
