Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(375)

Side by Side Diff: talk/media/webrtc/webrtcvideoengine2_unittest.cc

Issue 1587193006: Move talk/media to webrtc/media (Closed) Base URL: https://chromium.googlesource.com/external/webrtc.git@master
Patch Set: Disable sign-compare warning on Win Clang Created 4 years, 11 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
(Empty)
1 /*
2 * libjingle
3 * Copyright 2004 Google Inc.
4 *
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions are met:
7 *
8 * 1. Redistributions of source code must retain the above copyright notice,
9 * this list of conditions and the following disclaimer.
10 * 2. Redistributions in binary form must reproduce the above copyright notice,
11 * this list of conditions and the following disclaimer in the documentation
12 * and/or other materials provided with the distribution.
13 * 3. The name of the author may not be used to endorse or promote products
14 * derived from this software without specific prior written permission.
15 *
16 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED
17 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
18 * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO
19 * EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
20 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
21 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS;
22 * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
23 * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR
24 * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
25 * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
26 */
27
28 #include <algorithm>
29 #include <map>
30 #include <vector>
31
32 #include "talk/media/base/testutils.h"
33 #include "talk/media/base/videoengine_unittest.h"
34 #include "talk/media/webrtc/fakewebrtccall.h"
35 #include "talk/media/webrtc/fakewebrtcvideoengine.h"
36 #include "talk/media/webrtc/simulcast.h"
37 #include "talk/media/webrtc/webrtcvideochannelfactory.h"
38 #include "talk/media/webrtc/webrtcvideoengine2.h"
39 #include "talk/media/webrtc/webrtcvoiceengine.h"
40 #include "webrtc/base/arraysize.h"
41 #include "webrtc/base/gunit.h"
42 #include "webrtc/base/stringutils.h"
43 #include "webrtc/test/field_trial.h"
44 #include "webrtc/video_encoder.h"
45
46 namespace {
47 static const int kDefaultQpMax = 56;
48 static const int kDefaultFramerate = 30;
49
50 static const cricket::VideoCodec kVp8Codec720p(100, "VP8", 1280, 720, 30, 0);
51 static const cricket::VideoCodec kVp8Codec360p(100, "VP8", 640, 360, 30, 0);
52 static const cricket::VideoCodec kVp8Codec270p(100, "VP8", 480, 270, 30, 0);
53
54 static const cricket::VideoCodec kVp8Codec(100, "VP8", 640, 400, 30, 0);
55 static const cricket::VideoCodec kVp9Codec(101, "VP9", 640, 400, 30, 0);
56 static const cricket::VideoCodec kH264Codec(102, "H264", 640, 400, 30, 0);
57
58 static const cricket::VideoCodec kRedCodec(116, "red", 0, 0, 0, 0);
59 static const cricket::VideoCodec kUlpfecCodec(117, "ulpfec", 0, 0, 0, 0);
60
61 static const uint8_t kRedRtxPayloadType = 125;
62
63 static const uint32_t kSsrcs1[] = {1};
64 static const uint32_t kSsrcs3[] = {1, 2, 3};
65 static const uint32_t kRtxSsrcs1[] = {4};
66 static const uint32_t kIncomingUnsignalledSsrc = 0xC0FFEE;
67 static const char kUnsupportedExtensionName[] =
68 "urn:ietf:params:rtp-hdrext:unsupported";
69
70 void VerifyCodecHasDefaultFeedbackParams(const cricket::VideoCodec& codec) {
71 EXPECT_TRUE(codec.HasFeedbackParam(cricket::FeedbackParam(
72 cricket::kRtcpFbParamNack, cricket::kParamValueEmpty)));
73 EXPECT_TRUE(codec.HasFeedbackParam(cricket::FeedbackParam(
74 cricket::kRtcpFbParamNack, cricket::kRtcpFbNackParamPli)));
75 EXPECT_TRUE(codec.HasFeedbackParam(cricket::FeedbackParam(
76 cricket::kRtcpFbParamRemb, cricket::kParamValueEmpty)));
77 EXPECT_TRUE(codec.HasFeedbackParam(cricket::FeedbackParam(
78 cricket::kRtcpFbParamTransportCc, cricket::kParamValueEmpty)));
79 EXPECT_TRUE(codec.HasFeedbackParam(cricket::FeedbackParam(
80 cricket::kRtcpFbParamCcm, cricket::kRtcpFbCcmParamFir)));
81 }
82
83 static void CreateBlackFrame(webrtc::VideoFrame* video_frame,
84 int width,
85 int height) {
86 video_frame->CreateEmptyFrame(
87 width, height, width, (width + 1) / 2, (width + 1) / 2);
88 memset(video_frame->buffer(webrtc::kYPlane), 16,
89 video_frame->allocated_size(webrtc::kYPlane));
90 memset(video_frame->buffer(webrtc::kUPlane), 128,
91 video_frame->allocated_size(webrtc::kUPlane));
92 memset(video_frame->buffer(webrtc::kVPlane), 128,
93 video_frame->allocated_size(webrtc::kVPlane));
94 }
95
96 void VerifySendStreamHasRtxTypes(const webrtc::VideoSendStream::Config& config,
97 const std::map<int, int>& rtx_types) {
98 std::map<int, int>::const_iterator it;
99 it = rtx_types.find(config.encoder_settings.payload_type);
100 EXPECT_TRUE(it != rtx_types.end() &&
101 it->second == config.rtp.rtx.payload_type);
102
103 if (config.rtp.fec.red_rtx_payload_type != -1) {
104 it = rtx_types.find(config.rtp.fec.red_payload_type);
105 EXPECT_TRUE(it != rtx_types.end() &&
106 it->second == config.rtp.fec.red_rtx_payload_type);
107 }
108 }
109 } // namespace
110
111 namespace cricket {
112 class WebRtcVideoEngine2Test : public ::testing::Test {
113 public:
114 WebRtcVideoEngine2Test() : WebRtcVideoEngine2Test("") {}
115 explicit WebRtcVideoEngine2Test(const char* field_trials)
116 : WebRtcVideoEngine2Test(nullptr, field_trials) {}
117 WebRtcVideoEngine2Test(WebRtcVoiceEngine* voice_engine,
118 const char* field_trials)
119 : override_field_trials_(field_trials),
120 call_(webrtc::Call::Create(webrtc::Call::Config())),
121 engine_() {
122 std::vector<VideoCodec> engine_codecs = engine_.codecs();
123 RTC_DCHECK(!engine_codecs.empty());
124 bool codec_set = false;
125 for (size_t i = 0; i < engine_codecs.size(); ++i) {
126 if (engine_codecs[i].name == "red") {
127 default_red_codec_ = engine_codecs[i];
128 } else if (engine_codecs[i].name == "ulpfec") {
129 default_ulpfec_codec_ = engine_codecs[i];
130 } else if (engine_codecs[i].name == "rtx") {
131 int associated_payload_type;
132 if (engine_codecs[i].GetParam(kCodecParamAssociatedPayloadType,
133 &associated_payload_type)) {
134 default_apt_rtx_types_[associated_payload_type] = engine_codecs[i].id;
135 }
136 } else if (!codec_set) {
137 default_codec_ = engine_codecs[i];
138 codec_set = true;
139 }
140 }
141
142 RTC_DCHECK(codec_set);
143 }
144
145 protected:
146 VideoMediaChannel* SetUpForExternalEncoderFactory(
147 cricket::WebRtcVideoEncoderFactory* encoder_factory,
148 const std::vector<VideoCodec>& codecs);
149
150 VideoMediaChannel* SetUpForExternalDecoderFactory(
151 cricket::WebRtcVideoDecoderFactory* decoder_factory,
152 const std::vector<VideoCodec>& codecs);
153
154 webrtc::test::ScopedFieldTrials override_field_trials_;
155 // Used in WebRtcVideoEngine2VoiceTest, but defined here so it's properly
156 // initialized when the constructor is called.
157 rtc::scoped_ptr<webrtc::Call> call_;
158 WebRtcVoiceEngine voice_engine_;
159 WebRtcVideoEngine2 engine_;
160 VideoCodec default_codec_;
161 VideoCodec default_red_codec_;
162 VideoCodec default_ulpfec_codec_;
163 std::map<int, int> default_apt_rtx_types_;
164 };
165
166 TEST_F(WebRtcVideoEngine2Test, FindCodec) {
167 const std::vector<cricket::VideoCodec>& c = engine_.codecs();
168 EXPECT_EQ(cricket::DefaultVideoCodecList().size(), c.size());
169
170 cricket::VideoCodec vp8(104, "VP8", 320, 200, 30, 0);
171 EXPECT_TRUE(engine_.FindCodec(vp8));
172
173 cricket::VideoCodec vp8_ci(104, "vp8", 320, 200, 30, 0);
174 EXPECT_TRUE(engine_.FindCodec(vp8));
175
176 cricket::VideoCodec vp8_diff_fr_diff_pref(104, "VP8", 320, 200, 50, 50);
177 EXPECT_TRUE(engine_.FindCodec(vp8_diff_fr_diff_pref));
178
179 cricket::VideoCodec vp8_diff_id(95, "VP8", 320, 200, 30, 0);
180 EXPECT_FALSE(engine_.FindCodec(vp8_diff_id));
181 vp8_diff_id.id = 97;
182 EXPECT_TRUE(engine_.FindCodec(vp8_diff_id));
183
184 // FindCodec ignores the codec size.
185 // Test that FindCodec can accept uncommon codec size.
186 cricket::VideoCodec vp8_diff_res(104, "VP8", 320, 111, 30, 0);
187 EXPECT_TRUE(engine_.FindCodec(vp8_diff_res));
188
189 // PeerConnection doesn't negotiate the resolution at this point.
190 // Test that FindCodec can handle the case when width/height is 0.
191 cricket::VideoCodec vp8_zero_res(104, "VP8", 0, 0, 30, 0);
192 EXPECT_TRUE(engine_.FindCodec(vp8_zero_res));
193
194 cricket::VideoCodec red(101, "RED", 0, 0, 30, 0);
195 EXPECT_TRUE(engine_.FindCodec(red));
196
197 cricket::VideoCodec red_ci(101, "red", 0, 0, 30, 0);
198 EXPECT_TRUE(engine_.FindCodec(red));
199
200 cricket::VideoCodec fec(102, "ULPFEC", 0, 0, 30, 0);
201 EXPECT_TRUE(engine_.FindCodec(fec));
202
203 cricket::VideoCodec fec_ci(102, "ulpfec", 0, 0, 30, 0);
204 EXPECT_TRUE(engine_.FindCodec(fec));
205
206 cricket::VideoCodec rtx(96, "rtx", 0, 0, 30, 0);
207 EXPECT_TRUE(engine_.FindCodec(rtx));
208 }
209
210 TEST_F(WebRtcVideoEngine2Test, DefaultRtxCodecHasAssociatedPayloadTypeSet) {
211 std::vector<VideoCodec> engine_codecs = engine_.codecs();
212 for (size_t i = 0; i < engine_codecs.size(); ++i) {
213 if (engine_codecs[i].name != kRtxCodecName)
214 continue;
215 int associated_payload_type;
216 EXPECT_TRUE(engine_codecs[i].GetParam(kCodecParamAssociatedPayloadType,
217 &associated_payload_type));
218 EXPECT_EQ(default_codec_.id, associated_payload_type);
219 return;
220 }
221 FAIL() << "No RTX codec found among default codecs.";
222 }
223
224 TEST_F(WebRtcVideoEngine2Test, SupportsTimestampOffsetHeaderExtension) {
225 RtpCapabilities capabilities = engine_.GetCapabilities();
226 ASSERT_FALSE(capabilities.header_extensions.empty());
227 for (const RtpHeaderExtension& extension : capabilities.header_extensions) {
228 if (extension.uri == kRtpTimestampOffsetHeaderExtension) {
229 EXPECT_EQ(kRtpTimestampOffsetHeaderExtensionDefaultId, extension.id);
230 return;
231 }
232 }
233 FAIL() << "Timestamp offset extension not in header-extension list.";
234 }
235
236 TEST_F(WebRtcVideoEngine2Test, SupportsAbsoluteSenderTimeHeaderExtension) {
237 RtpCapabilities capabilities = engine_.GetCapabilities();
238 ASSERT_FALSE(capabilities.header_extensions.empty());
239 for (const RtpHeaderExtension& extension : capabilities.header_extensions) {
240 if (extension.uri == kRtpAbsoluteSenderTimeHeaderExtension) {
241 EXPECT_EQ(kRtpAbsoluteSenderTimeHeaderExtensionDefaultId, extension.id);
242 return;
243 }
244 }
245 FAIL() << "Absolute Sender Time extension not in header-extension list.";
246 }
247
248 class WebRtcVideoEngine2WithSendSideBweTest : public WebRtcVideoEngine2Test {
249 public:
250 WebRtcVideoEngine2WithSendSideBweTest()
251 : WebRtcVideoEngine2Test("WebRTC-SendSideBwe/Enabled/") {}
252 };
253
254 TEST_F(WebRtcVideoEngine2WithSendSideBweTest,
255 SupportsTransportSequenceNumberHeaderExtension) {
256 RtpCapabilities capabilities = engine_.GetCapabilities();
257 ASSERT_FALSE(capabilities.header_extensions.empty());
258 for (const RtpHeaderExtension& extension : capabilities.header_extensions) {
259 if (extension.uri == kRtpTransportSequenceNumberHeaderExtension) {
260 EXPECT_EQ(kRtpTransportSequenceNumberHeaderExtensionDefaultId,
261 extension.id);
262 return;
263 }
264 }
265 FAIL() << "Transport sequence number extension not in header-extension list.";
266 }
267
268 TEST_F(WebRtcVideoEngine2Test, SupportsVideoRotationHeaderExtension) {
269 RtpCapabilities capabilities = engine_.GetCapabilities();
270 ASSERT_FALSE(capabilities.header_extensions.empty());
271 for (const RtpHeaderExtension& extension : capabilities.header_extensions) {
272 if (extension.uri == kRtpVideoRotationHeaderExtension) {
273 EXPECT_EQ(kRtpVideoRotationHeaderExtensionDefaultId, extension.id);
274 return;
275 }
276 }
277 FAIL() << "Video Rotation extension not in header-extension list.";
278 }
279
280 TEST_F(WebRtcVideoEngine2Test, CVOSetHeaderExtensionBeforeCapturer) {
281 // Allocate the capturer first to prevent early destruction before channel's
282 // dtor is called.
283 cricket::FakeVideoCapturer capturer;
284
285 cricket::FakeWebRtcVideoEncoderFactory encoder_factory;
286 encoder_factory.AddSupportedVideoCodecType(webrtc::kVideoCodecVP8, "VP8");
287 cricket::VideoSendParameters parameters;
288 parameters.codecs.push_back(kVp8Codec);
289
290 rtc::scoped_ptr<VideoMediaChannel> channel(
291 SetUpForExternalEncoderFactory(&encoder_factory, parameters.codecs));
292 EXPECT_TRUE(channel->AddSendStream(StreamParams::CreateLegacy(kSsrc)));
293
294 // Add CVO extension.
295 const int id = 1;
296 parameters.extensions.push_back(
297 cricket::RtpHeaderExtension(kRtpVideoRotationHeaderExtension, id));
298 EXPECT_TRUE(channel->SetSendParameters(parameters));
299
300 // Set capturer.
301 EXPECT_TRUE(channel->SetCapturer(kSsrc, &capturer));
302
303 // Verify capturer has turned off applying rotation.
304 EXPECT_FALSE(capturer.GetApplyRotation());
305
306 // Verify removing header extension turns on applying rotation.
307 parameters.extensions.clear();
308 EXPECT_TRUE(channel->SetSendParameters(parameters));
309 EXPECT_TRUE(capturer.GetApplyRotation());
310 }
311
312 TEST_F(WebRtcVideoEngine2Test, CVOSetHeaderExtensionAfterCapturer) {
313 cricket::FakeVideoCapturer capturer;
314
315 cricket::FakeWebRtcVideoEncoderFactory encoder_factory;
316 encoder_factory.AddSupportedVideoCodecType(webrtc::kVideoCodecVP8, "VP8");
317 cricket::VideoSendParameters parameters;
318 parameters.codecs.push_back(kVp8Codec);
319
320 rtc::scoped_ptr<VideoMediaChannel> channel(
321 SetUpForExternalEncoderFactory(&encoder_factory, parameters.codecs));
322 EXPECT_TRUE(channel->AddSendStream(StreamParams::CreateLegacy(kSsrc)));
323
324 // Set capturer.
325 EXPECT_TRUE(channel->SetCapturer(kSsrc, &capturer));
326
327 // Add CVO extension.
328 const int id = 1;
329 parameters.extensions.push_back(
330 cricket::RtpHeaderExtension(kRtpVideoRotationHeaderExtension, id));
331 EXPECT_TRUE(channel->SetSendParameters(parameters));
332
333 // Verify capturer has turned off applying rotation.
334 EXPECT_FALSE(capturer.GetApplyRotation());
335
336 // Verify removing header extension turns on applying rotation.
337 parameters.extensions.clear();
338 EXPECT_TRUE(channel->SetSendParameters(parameters));
339 EXPECT_TRUE(capturer.GetApplyRotation());
340 }
341
342 TEST_F(WebRtcVideoEngine2Test, SetSendFailsBeforeSettingCodecs) {
343 engine_.Init();
344 rtc::scoped_ptr<VideoMediaChannel> channel(
345 engine_.CreateChannel(call_.get(), cricket::VideoOptions()));
346
347 EXPECT_TRUE(channel->AddSendStream(StreamParams::CreateLegacy(123)));
348
349 EXPECT_FALSE(channel->SetSend(true))
350 << "Channel should not start without codecs.";
351 EXPECT_TRUE(channel->SetSend(false))
352 << "Channel should be stoppable even without set codecs.";
353 }
354
355 TEST_F(WebRtcVideoEngine2Test, GetStatsWithoutSendCodecsSetDoesNotCrash) {
356 engine_.Init();
357 rtc::scoped_ptr<VideoMediaChannel> channel(
358 engine_.CreateChannel(call_.get(), cricket::VideoOptions()));
359 EXPECT_TRUE(channel->AddSendStream(StreamParams::CreateLegacy(123)));
360 VideoMediaInfo info;
361 channel->GetStats(&info);
362 }
363
364 TEST_F(WebRtcVideoEngine2Test, UseExternalFactoryForVp8WhenSupported) {
365 cricket::FakeWebRtcVideoEncoderFactory encoder_factory;
366 encoder_factory.AddSupportedVideoCodecType(webrtc::kVideoCodecVP8, "VP8");
367 cricket::VideoSendParameters parameters;
368 parameters.codecs.push_back(kVp8Codec);
369
370 rtc::scoped_ptr<VideoMediaChannel> channel(
371 SetUpForExternalEncoderFactory(&encoder_factory, parameters.codecs));
372
373 EXPECT_TRUE(
374 channel->AddSendStream(cricket::StreamParams::CreateLegacy(kSsrc)));
375 ASSERT_EQ(1u, encoder_factory.encoders().size());
376 EXPECT_TRUE(channel->SetSend(true));
377
378 cricket::FakeVideoCapturer capturer;
379 EXPECT_TRUE(channel->SetCapturer(kSsrc, &capturer));
380 EXPECT_EQ(cricket::CS_RUNNING,
381 capturer.Start(capturer.GetSupportedFormats()->front()));
382 EXPECT_TRUE(capturer.CaptureFrame());
383 EXPECT_TRUE_WAIT(encoder_factory.encoders()[0]->GetNumEncodedFrames() > 0,
384 kTimeout);
385
386 // Sending one frame will have reallocated the encoder since input size
387 // changes from a small default to the actual frame width/height.
388 int num_created_encoders = encoder_factory.GetNumCreatedEncoders();
389 EXPECT_EQ(num_created_encoders, 2);
390
391 // Setting codecs of the same type should not reallocate any encoders
392 // (expecting a no-op).
393 EXPECT_TRUE(channel->SetSendParameters(parameters));
394 EXPECT_EQ(num_created_encoders, encoder_factory.GetNumCreatedEncoders());
395
396 // Remove stream previously added to free the external encoder instance.
397 EXPECT_TRUE(channel->RemoveSendStream(kSsrc));
398 EXPECT_EQ(0u, encoder_factory.encoders().size());
399 }
400
401 TEST_F(WebRtcVideoEngine2Test, CanConstructDecoderForVp9EncoderFactory) {
402 cricket::FakeWebRtcVideoEncoderFactory encoder_factory;
403 encoder_factory.AddSupportedVideoCodecType(webrtc::kVideoCodecVP9, "VP9");
404 std::vector<cricket::VideoCodec> codecs;
405 codecs.push_back(kVp9Codec);
406
407 rtc::scoped_ptr<VideoMediaChannel> channel(
408 SetUpForExternalEncoderFactory(&encoder_factory, codecs));
409
410 EXPECT_TRUE(
411 channel->AddRecvStream(cricket::StreamParams::CreateLegacy(kSsrc)));
412 }
413
414 TEST_F(WebRtcVideoEngine2Test, PropagatesInputFrameTimestamp) {
415 cricket::FakeWebRtcVideoEncoderFactory encoder_factory;
416 encoder_factory.AddSupportedVideoCodecType(webrtc::kVideoCodecVP8, "VP8");
417 std::vector<cricket::VideoCodec> codecs;
418 codecs.push_back(kVp8Codec);
419
420 FakeCall* fake_call = new FakeCall(webrtc::Call::Config());
421 call_.reset(fake_call);
422 rtc::scoped_ptr<VideoMediaChannel> channel(
423 SetUpForExternalEncoderFactory(&encoder_factory, codecs));
424
425 EXPECT_TRUE(
426 channel->AddSendStream(cricket::StreamParams::CreateLegacy(kSsrc)));
427
428 FakeVideoCapturer capturer;
429 EXPECT_TRUE(channel->SetCapturer(kSsrc, &capturer));
430 capturer.Start(cricket::VideoFormat(1280, 720,
431 cricket::VideoFormat::FpsToInterval(60),
432 cricket::FOURCC_I420));
433 channel->SetSend(true);
434
435 FakeVideoSendStream* stream = fake_call->GetVideoSendStreams()[0];
436
437 EXPECT_TRUE(capturer.CaptureFrame());
438 int64_t last_timestamp = stream->GetLastTimestamp();
439 for (int i = 0; i < 10; i++) {
440 EXPECT_TRUE(capturer.CaptureFrame());
441 int64_t timestamp = stream->GetLastTimestamp();
442 int64_t interval = timestamp - last_timestamp;
443
444 // Precision changes from nanosecond to millisecond.
445 // Allow error to be no more than 1.
446 EXPECT_NEAR(cricket::VideoFormat::FpsToInterval(60) / 1E6, interval, 1);
447
448 last_timestamp = timestamp;
449 }
450
451 capturer.Start(cricket::VideoFormat(1280, 720,
452 cricket::VideoFormat::FpsToInterval(30),
453 cricket::FOURCC_I420));
454
455 EXPECT_TRUE(capturer.CaptureFrame());
456 last_timestamp = stream->GetLastTimestamp();
457 for (int i = 0; i < 10; i++) {
458 EXPECT_TRUE(capturer.CaptureFrame());
459 int64_t timestamp = stream->GetLastTimestamp();
460 int64_t interval = timestamp - last_timestamp;
461
462 // Precision changes from nanosecond to millisecond.
463 // Allow error to be no more than 1.
464 EXPECT_NEAR(cricket::VideoFormat::FpsToInterval(30) / 1E6, interval, 1);
465
466 last_timestamp = timestamp;
467 }
468
469 // Remove stream previously added to free the external encoder instance.
470 EXPECT_TRUE(channel->RemoveSendStream(kSsrc));
471 }
472
473 TEST_F(WebRtcVideoEngine2Test,
474 ProducesIncreasingTimestampsWithResetInputSources) {
475 cricket::FakeWebRtcVideoEncoderFactory encoder_factory;
476 encoder_factory.AddSupportedVideoCodecType(webrtc::kVideoCodecVP8, "VP8");
477 std::vector<cricket::VideoCodec> codecs;
478 codecs.push_back(kVp8Codec);
479
480 FakeCall* fake_call = new FakeCall(webrtc::Call::Config());
481 call_.reset(fake_call);
482 rtc::scoped_ptr<VideoMediaChannel> channel(
483 SetUpForExternalEncoderFactory(&encoder_factory, codecs));
484
485 EXPECT_TRUE(
486 channel->AddSendStream(cricket::StreamParams::CreateLegacy(kSsrc)));
487 channel->SetSend(true);
488 FakeVideoSendStream* stream = fake_call->GetVideoSendStreams()[0];
489
490 FakeVideoCapturer capturer1;
491 EXPECT_TRUE(channel->SetCapturer(kSsrc, &capturer1));
492
493 cricket::CapturedFrame frame;
494 frame.width = 1280;
495 frame.height = 720;
496 frame.fourcc = cricket::FOURCC_I420;
497 frame.data_size = static_cast<uint32_t>(
498 cricket::VideoFrame::SizeOf(frame.width, frame.height));
499 rtc::scoped_ptr<char[]> data(new char[frame.data_size]);
500 frame.data = data.get();
501 memset(frame.data, 1, frame.data_size);
502 const int kInitialTimestamp = 123456;
503 frame.time_stamp = kInitialTimestamp;
504
505 // Deliver initial frame.
506 capturer1.SignalCapturedFrame(&frame);
507 // Deliver next frame 1 second later.
508 frame.time_stamp += rtc::kNumNanosecsPerSec;
509 rtc::Thread::Current()->SleepMs(1000);
510 capturer1.SignalCapturedFrame(&frame);
511
512 int64_t capturer1_last_timestamp = stream->GetLastTimestamp();
513 // Reset input source, should still be continuous even though input-frame
514 // timestamp is less than before.
515 FakeVideoCapturer capturer2;
516 EXPECT_TRUE(channel->SetCapturer(kSsrc, &capturer2));
517
518 rtc::Thread::Current()->SleepMs(1);
519 // Deliver with a timestamp (10 seconds) before the previous initial one,
520 // these should not be related at all anymore and it should still work fine.
521 frame.time_stamp = kInitialTimestamp - 10000;
522 capturer2.SignalCapturedFrame(&frame);
523
524 // New timestamp should be at least 1ms in the future and not old.
525 EXPECT_GT(stream->GetLastTimestamp(), capturer1_last_timestamp);
526
527 EXPECT_TRUE(channel->RemoveSendStream(kSsrc));
528 }
529
530 VideoMediaChannel* WebRtcVideoEngine2Test::SetUpForExternalEncoderFactory(
531 cricket::WebRtcVideoEncoderFactory* encoder_factory,
532 const std::vector<VideoCodec>& codecs) {
533 engine_.SetExternalEncoderFactory(encoder_factory);
534 engine_.Init();
535
536 VideoMediaChannel* channel =
537 engine_.CreateChannel(call_.get(), cricket::VideoOptions());
538 cricket::VideoSendParameters parameters;
539 parameters.codecs = codecs;
540 EXPECT_TRUE(channel->SetSendParameters(parameters));
541
542 return channel;
543 }
544
545 VideoMediaChannel* WebRtcVideoEngine2Test::SetUpForExternalDecoderFactory(
546 cricket::WebRtcVideoDecoderFactory* decoder_factory,
547 const std::vector<VideoCodec>& codecs) {
548 engine_.SetExternalDecoderFactory(decoder_factory);
549 engine_.Init();
550
551 VideoMediaChannel* channel =
552 engine_.CreateChannel(call_.get(), cricket::VideoOptions());
553 cricket::VideoRecvParameters parameters;
554 parameters.codecs = codecs;
555 EXPECT_TRUE(channel->SetRecvParameters(parameters));
556
557 return channel;
558 }
559
560 TEST_F(WebRtcVideoEngine2Test, UsesSimulcastAdapterForVp8Factories) {
561 cricket::FakeWebRtcVideoEncoderFactory encoder_factory;
562 encoder_factory.AddSupportedVideoCodecType(webrtc::kVideoCodecVP8, "VP8");
563 std::vector<cricket::VideoCodec> codecs;
564 codecs.push_back(kVp8Codec);
565
566 rtc::scoped_ptr<VideoMediaChannel> channel(
567 SetUpForExternalEncoderFactory(&encoder_factory, codecs));
568
569 std::vector<uint32_t> ssrcs = MAKE_VECTOR(kSsrcs3);
570
571 EXPECT_TRUE(
572 channel->AddSendStream(CreateSimStreamParams("cname", ssrcs)));
573 EXPECT_TRUE(channel->SetSend(true));
574
575 cricket::FakeVideoCapturer capturer;
576 EXPECT_TRUE(channel->SetCapturer(ssrcs.front(), &capturer));
577 EXPECT_EQ(cricket::CS_RUNNING,
578 capturer.Start(capturer.GetSupportedFormats()->front()));
579 EXPECT_TRUE(capturer.CaptureFrame());
580
581 EXPECT_GT(encoder_factory.encoders().size(), 1u);
582
583 // Verify that encoders are configured for simulcast through adapter
584 // (increasing resolution and only configured to send one stream each).
585 int prev_width = -1;
586 for (size_t i = 0; i < encoder_factory.encoders().size(); ++i) {
587 webrtc::VideoCodec codec_settings =
588 encoder_factory.encoders()[i]->GetCodecSettings();
589 EXPECT_EQ(0, codec_settings.numberOfSimulcastStreams);
590 EXPECT_GT(codec_settings.width, prev_width);
591 prev_width = codec_settings.width;
592 }
593
594 EXPECT_TRUE(channel->SetCapturer(ssrcs.front(), NULL));
595
596 channel.reset();
597 ASSERT_EQ(0u, encoder_factory.encoders().size());
598 }
599
600 TEST_F(WebRtcVideoEngine2Test, ChannelWithExternalH264CanChangeToInternalVp8) {
601 cricket::FakeWebRtcVideoEncoderFactory encoder_factory;
602 encoder_factory.AddSupportedVideoCodecType(webrtc::kVideoCodecH264, "H264");
603 std::vector<cricket::VideoCodec> codecs;
604 codecs.push_back(kH264Codec);
605
606 rtc::scoped_ptr<VideoMediaChannel> channel(
607 SetUpForExternalEncoderFactory(&encoder_factory, codecs));
608
609 EXPECT_TRUE(
610 channel->AddSendStream(cricket::StreamParams::CreateLegacy(kSsrc)));
611 ASSERT_EQ(1u, encoder_factory.encoders().size());
612
613 cricket::VideoSendParameters parameters;
614 parameters.codecs.push_back(kVp8Codec);
615 EXPECT_TRUE(channel->SetSendParameters(parameters));
616 ASSERT_EQ(0u, encoder_factory.encoders().size());
617 }
618
619 TEST_F(WebRtcVideoEngine2Test,
620 DontUseExternalEncoderFactoryForUnsupportedCodecs) {
621 cricket::FakeWebRtcVideoEncoderFactory encoder_factory;
622 encoder_factory.AddSupportedVideoCodecType(webrtc::kVideoCodecH264, "H264");
623 std::vector<cricket::VideoCodec> codecs;
624 codecs.push_back(kVp8Codec);
625
626 rtc::scoped_ptr<VideoMediaChannel> channel(
627 SetUpForExternalEncoderFactory(&encoder_factory, codecs));
628
629 EXPECT_TRUE(
630 channel->AddSendStream(cricket::StreamParams::CreateLegacy(kSsrc)));
631 // Make sure DestroyVideoEncoder was called on the factory.
632 ASSERT_EQ(0u, encoder_factory.encoders().size());
633 }
634
635 TEST_F(WebRtcVideoEngine2Test,
636 UsesSimulcastAdapterForVp8WithCombinedVP8AndH264Factory) {
637 cricket::FakeWebRtcVideoEncoderFactory encoder_factory;
638 encoder_factory.AddSupportedVideoCodecType(webrtc::kVideoCodecVP8, "VP8");
639 encoder_factory.AddSupportedVideoCodecType(webrtc::kVideoCodecH264, "H264");
640
641 std::vector<cricket::VideoCodec> codecs;
642 codecs.push_back(kVp8Codec);
643
644 rtc::scoped_ptr<VideoMediaChannel> channel(
645 SetUpForExternalEncoderFactory(&encoder_factory, codecs));
646
647 std::vector<uint32_t> ssrcs = MAKE_VECTOR(kSsrcs3);
648
649 EXPECT_TRUE(
650 channel->AddSendStream(CreateSimStreamParams("cname", ssrcs)));
651 EXPECT_TRUE(channel->SetSend(true));
652
653 // Send a fake frame, or else the media engine will configure the simulcast
654 // encoder adapter at a low-enough size that it'll only create a single
655 // encoder layer.
656 cricket::FakeVideoCapturer capturer;
657 EXPECT_TRUE(channel->SetCapturer(ssrcs.front(), &capturer));
658 EXPECT_EQ(cricket::CS_RUNNING,
659 capturer.Start(capturer.GetSupportedFormats()->front()));
660 EXPECT_TRUE(capturer.CaptureFrame());
661
662 ASSERT_GT(encoder_factory.encoders().size(), 1u);
663 EXPECT_EQ(webrtc::kVideoCodecVP8,
664 encoder_factory.encoders()[0]->GetCodecSettings().codecType);
665
666 channel.reset();
667 // Make sure DestroyVideoEncoder was called on the factory.
668 EXPECT_EQ(0u, encoder_factory.encoders().size());
669 }
670
671 TEST_F(WebRtcVideoEngine2Test,
672 DestroysNonSimulcastEncoderFromCombinedVP8AndH264Factory) {
673 cricket::FakeWebRtcVideoEncoderFactory encoder_factory;
674 encoder_factory.AddSupportedVideoCodecType(webrtc::kVideoCodecVP8, "VP8");
675 encoder_factory.AddSupportedVideoCodecType(webrtc::kVideoCodecH264, "H264");
676
677 std::vector<cricket::VideoCodec> codecs;
678 codecs.push_back(kH264Codec);
679
680 rtc::scoped_ptr<VideoMediaChannel> channel(
681 SetUpForExternalEncoderFactory(&encoder_factory, codecs));
682
683 EXPECT_TRUE(
684 channel->AddSendStream(cricket::StreamParams::CreateLegacy(kSsrc)));
685 ASSERT_EQ(1u, encoder_factory.encoders().size());
686 EXPECT_EQ(webrtc::kVideoCodecH264,
687 encoder_factory.encoders()[0]->GetCodecSettings().codecType);
688
689 channel.reset();
690 // Make sure DestroyVideoEncoder was called on the factory.
691 ASSERT_EQ(0u, encoder_factory.encoders().size());
692 }
693
694 TEST_F(WebRtcVideoEngine2Test, SimulcastDisabledForH264) {
695 cricket::FakeWebRtcVideoEncoderFactory encoder_factory;
696 encoder_factory.AddSupportedVideoCodecType(webrtc::kVideoCodecH264, "H264");
697 std::vector<cricket::VideoCodec> codecs;
698 codecs.push_back(kH264Codec);
699
700 rtc::scoped_ptr<VideoMediaChannel> channel(
701 SetUpForExternalEncoderFactory(&encoder_factory, codecs));
702
703 const std::vector<uint32_t> ssrcs = MAKE_VECTOR(kSsrcs3);
704 EXPECT_TRUE(
705 channel->AddSendStream(cricket::CreateSimStreamParams("cname", ssrcs)));
706 // Set the stream to 720p. This should trigger a "real" encoder
707 // initialization.
708 cricket::VideoFormat format(
709 1280, 720, cricket::VideoFormat::FpsToInterval(30), cricket::FOURCC_I420);
710 EXPECT_TRUE(channel->SetSendStreamFormat(ssrcs[0], format));
711 ASSERT_EQ(1u, encoder_factory.encoders().size());
712 FakeWebRtcVideoEncoder* encoder = encoder_factory.encoders()[0];
713 EXPECT_EQ(webrtc::kVideoCodecH264, encoder->GetCodecSettings().codecType);
714 EXPECT_EQ(1u, encoder->GetCodecSettings().numberOfSimulcastStreams);
715 }
716
717 // Test external codec with be added to the end of the supported codec list.
718 TEST_F(WebRtcVideoEngine2Test, ReportSupportedExternalCodecs) {
719 cricket::FakeWebRtcVideoEncoderFactory encoder_factory;
720 encoder_factory.AddSupportedVideoCodecType(webrtc::kVideoCodecH264, "H264");
721 engine_.SetExternalEncoderFactory(&encoder_factory);
722 engine_.Init();
723
724 std::vector<cricket::VideoCodec> codecs(engine_.codecs());
725 ASSERT_GE(codecs.size(), 2u);
726 cricket::VideoCodec internal_codec = codecs.front();
727 cricket::VideoCodec external_codec = codecs.back();
728
729 // The external codec will appear at last.
730 EXPECT_EQ("VP8", internal_codec.name);
731 EXPECT_EQ("H264", external_codec.name);
732 }
733
734 TEST_F(WebRtcVideoEngine2Test, RegisterExternalDecodersIfSupported) {
735 cricket::FakeWebRtcVideoDecoderFactory decoder_factory;
736 decoder_factory.AddSupportedVideoCodecType(webrtc::kVideoCodecVP8);
737 cricket::VideoRecvParameters parameters;
738 parameters.codecs.push_back(kVp8Codec);
739
740 rtc::scoped_ptr<VideoMediaChannel> channel(
741 SetUpForExternalDecoderFactory(&decoder_factory, parameters.codecs));
742
743 EXPECT_TRUE(
744 channel->AddRecvStream(cricket::StreamParams::CreateLegacy(kSsrc)));
745 ASSERT_EQ(1u, decoder_factory.decoders().size());
746
747 // Setting codecs of the same type should not reallocate the decoder.
748 EXPECT_TRUE(channel->SetRecvParameters(parameters));
749 EXPECT_EQ(1, decoder_factory.GetNumCreatedDecoders());
750
751 // Remove stream previously added to free the external decoder instance.
752 EXPECT_TRUE(channel->RemoveRecvStream(kSsrc));
753 EXPECT_EQ(0u, decoder_factory.decoders().size());
754 }
755
756 // Verifies that we can set up decoders that are not internally supported.
757 TEST_F(WebRtcVideoEngine2Test, RegisterExternalH264DecoderIfSupported) {
758 // TODO(pbos): Do not assume that encoder/decoder support is symmetric. We
759 // can't even query the WebRtcVideoDecoderFactory for supported codecs.
760 // For now we add a FakeWebRtcVideoEncoderFactory to add H264 to supported
761 // codecs.
762 cricket::FakeWebRtcVideoEncoderFactory encoder_factory;
763 encoder_factory.AddSupportedVideoCodecType(webrtc::kVideoCodecH264, "H264");
764 engine_.SetExternalEncoderFactory(&encoder_factory);
765 cricket::FakeWebRtcVideoDecoderFactory decoder_factory;
766 decoder_factory.AddSupportedVideoCodecType(webrtc::kVideoCodecH264);
767 std::vector<cricket::VideoCodec> codecs;
768 codecs.push_back(kH264Codec);
769
770 rtc::scoped_ptr<VideoMediaChannel> channel(
771 SetUpForExternalDecoderFactory(&decoder_factory, codecs));
772
773 EXPECT_TRUE(
774 channel->AddRecvStream(cricket::StreamParams::CreateLegacy(kSsrc)));
775 ASSERT_EQ(1u, decoder_factory.decoders().size());
776 }
777
778 class WebRtcVideoChannel2BaseTest
779 : public VideoMediaChannelTest<WebRtcVideoEngine2, WebRtcVideoChannel2> {
780 protected:
781 typedef VideoMediaChannelTest<WebRtcVideoEngine2, WebRtcVideoChannel2> Base;
782
783 cricket::VideoCodec DefaultCodec() override { return kVp8Codec; }
784 };
785
786 #define WEBRTC_BASE_TEST(test) \
787 TEST_F(WebRtcVideoChannel2BaseTest, test) { Base::test(); }
788
789 #define WEBRTC_DISABLED_BASE_TEST(test) \
790 TEST_F(WebRtcVideoChannel2BaseTest, DISABLED_##test) { Base::test(); }
791
792 WEBRTC_BASE_TEST(SetSend);
793 WEBRTC_BASE_TEST(SetSendWithoutCodecs);
794 WEBRTC_BASE_TEST(SetSendSetsTransportBufferSizes);
795
796 WEBRTC_BASE_TEST(GetStats);
797 WEBRTC_BASE_TEST(GetStatsMultipleRecvStreams);
798 WEBRTC_BASE_TEST(GetStatsMultipleSendStreams);
799
800 WEBRTC_BASE_TEST(SetSendBandwidth);
801
802 WEBRTC_BASE_TEST(SetSendSsrc);
803 WEBRTC_BASE_TEST(SetSendSsrcAfterSetCodecs);
804
805 WEBRTC_BASE_TEST(SetRenderer);
806
807 WEBRTC_DISABLED_BASE_TEST(AddRemoveRecvStreamAndRender);
808
809 WEBRTC_BASE_TEST(AddRemoveSendStreams);
810
811 WEBRTC_BASE_TEST(SimulateConference);
812
813 WEBRTC_BASE_TEST(AddRemoveCapturer);
814
815 WEBRTC_BASE_TEST(RemoveCapturerWithoutAdd);
816
817 WEBRTC_BASE_TEST(AddRemoveCapturerMultipleSources);
818
819 // TODO(pbos): Figure out why this fails so often.
820 WEBRTC_DISABLED_BASE_TEST(HighAspectHighHeightCapturer);
821
822 WEBRTC_BASE_TEST(RejectEmptyStreamParams);
823
824 WEBRTC_BASE_TEST(AdaptResolution16x10);
825
826 WEBRTC_BASE_TEST(AdaptResolution4x3);
827
828 // TODO(juberti): Restore this test once we support sending 0 fps.
829 WEBRTC_DISABLED_BASE_TEST(AdaptDropAllFrames);
830 // TODO(juberti): Understand why we get decode errors on this test.
831 WEBRTC_DISABLED_BASE_TEST(AdaptFramerate);
832
833 WEBRTC_BASE_TEST(SendsLowerResolutionOnSmallerFrames);
834
835 WEBRTC_BASE_TEST(MuteStream);
836
837 WEBRTC_BASE_TEST(MultipleSendStreams);
838
839 WEBRTC_BASE_TEST(SetSendStreamFormat0x0);
840
841 // TODO(zhurunz): Fix the flakey test.
842 WEBRTC_DISABLED_BASE_TEST(SetSendStreamFormat);
843
844 TEST_F(WebRtcVideoChannel2BaseTest, SendAndReceiveVp8Vga) {
845 SendAndReceive(cricket::VideoCodec(100, "VP8", 640, 400, 30, 0));
846 }
847
848 TEST_F(WebRtcVideoChannel2BaseTest, SendAndReceiveVp8Qvga) {
849 SendAndReceive(cricket::VideoCodec(100, "VP8", 320, 200, 30, 0));
850 }
851
852 TEST_F(WebRtcVideoChannel2BaseTest, SendAndReceiveVp8SvcQqvga) {
853 SendAndReceive(cricket::VideoCodec(100, "VP8", 160, 100, 30, 0));
854 }
855
856 TEST_F(WebRtcVideoChannel2BaseTest, TwoStreamsSendAndReceive) {
857 Base::TwoStreamsSendAndReceive(kVp8Codec);
858 }
859
860 TEST_F(WebRtcVideoChannel2BaseTest, TwoStreamsReUseFirstStream) {
861 Base::TwoStreamsReUseFirstStream(kVp8Codec);
862 }
863
864 // TODO(pbos): Enable and figure out why this fails (or should work).
865 TEST_F(WebRtcVideoChannel2BaseTest, DISABLED_SendVp8HdAndReceiveAdaptedVp8Vga) {
866 EXPECT_TRUE(channel_->SetCapturer(kSsrc, NULL));
867 EXPECT_TRUE(channel_->SetRenderer(kDefaultReceiveSsrc, &renderer_));
868 channel_->UpdateAspectRatio(1280, 720);
869 video_capturer_.reset(new cricket::FakeVideoCapturer);
870 const std::vector<cricket::VideoFormat>* formats =
871 video_capturer_->GetSupportedFormats();
872 cricket::VideoFormat capture_format_hd = (*formats)[0];
873 EXPECT_EQ(cricket::CS_RUNNING, video_capturer_->Start(capture_format_hd));
874 EXPECT_TRUE(channel_->SetCapturer(kSsrc, video_capturer_.get()));
875
876 // Capture format HD -> adapt (OnOutputFormatRequest VGA) -> VGA.
877 cricket::VideoCodec codec = kVp8Codec720p;
878 EXPECT_TRUE(SetOneCodec(codec));
879 codec.width /= 2;
880 codec.height /= 2;
881 EXPECT_TRUE(SetSend(true));
882 EXPECT_EQ(0, renderer_.num_rendered_frames());
883 EXPECT_TRUE(SendFrame());
884 EXPECT_FRAME_WAIT(1, codec.width, codec.height, kTimeout);
885 }
886
887 class WebRtcVideoChannel2Test : public WebRtcVideoEngine2Test {
888 public:
889 WebRtcVideoChannel2Test() : WebRtcVideoChannel2Test("") {}
890 explicit WebRtcVideoChannel2Test(const char* field_trials)
891 : WebRtcVideoEngine2Test(field_trials), last_ssrc_(0) {}
892 void SetUp() override {
893 fake_call_.reset(new FakeCall(webrtc::Call::Config()));
894 engine_.Init();
895 channel_.reset(
896 engine_.CreateChannel(fake_call_.get(), cricket::VideoOptions()));
897 last_ssrc_ = 123;
898 send_parameters_.codecs = engine_.codecs();
899 recv_parameters_.codecs = engine_.codecs();
900 ASSERT_TRUE(channel_->SetSendParameters(send_parameters_));
901 }
902
903 protected:
904 FakeVideoSendStream* AddSendStream() {
905 return AddSendStream(StreamParams::CreateLegacy(++last_ssrc_));
906 }
907
908 FakeVideoSendStream* AddSendStream(const StreamParams& sp) {
909 size_t num_streams = fake_call_->GetVideoSendStreams().size();
910 EXPECT_TRUE(channel_->AddSendStream(sp));
911 std::vector<FakeVideoSendStream*> streams =
912 fake_call_->GetVideoSendStreams();
913 EXPECT_EQ(num_streams + 1, streams.size());
914 return streams[streams.size() - 1];
915 }
916
917 std::vector<FakeVideoSendStream*> GetFakeSendStreams() {
918 return fake_call_->GetVideoSendStreams();
919 }
920
921 FakeVideoReceiveStream* AddRecvStream() {
922 return AddRecvStream(StreamParams::CreateLegacy(++last_ssrc_));
923 }
924
925 FakeVideoReceiveStream* AddRecvStream(const StreamParams& sp) {
926 size_t num_streams = fake_call_->GetVideoReceiveStreams().size();
927 EXPECT_TRUE(channel_->AddRecvStream(sp));
928 std::vector<FakeVideoReceiveStream*> streams =
929 fake_call_->GetVideoReceiveStreams();
930 EXPECT_EQ(num_streams + 1, streams.size());
931 return streams[streams.size() - 1];
932 }
933
934 void SetSendCodecsShouldWorkForBitrates(const char* min_bitrate_kbps,
935 int expected_min_bitrate_bps,
936 const char* start_bitrate_kbps,
937 int expected_start_bitrate_bps,
938 const char* max_bitrate_kbps,
939 int expected_max_bitrate_bps) {
940 auto& codecs = send_parameters_.codecs;
941 codecs.clear();
942 codecs.push_back(kVp8Codec);
943 codecs[0].params[kCodecParamMinBitrate] = min_bitrate_kbps;
944 codecs[0].params[kCodecParamStartBitrate] = start_bitrate_kbps;
945 codecs[0].params[kCodecParamMaxBitrate] = max_bitrate_kbps;
946 EXPECT_TRUE(channel_->SetSendParameters(send_parameters_));
947
948 EXPECT_EQ(expected_min_bitrate_bps,
949 fake_call_->GetConfig().bitrate_config.min_bitrate_bps);
950 EXPECT_EQ(expected_start_bitrate_bps,
951 fake_call_->GetConfig().bitrate_config.start_bitrate_bps);
952 EXPECT_EQ(expected_max_bitrate_bps,
953 fake_call_->GetConfig().bitrate_config.max_bitrate_bps);
954 }
955
956 void TestSetSendRtpHeaderExtensions(const std::string& cricket_ext,
957 const std::string& webrtc_ext) {
958 // Enable extension.
959 const int id = 1;
960 cricket::VideoSendParameters parameters = send_parameters_;
961 parameters.extensions.push_back(
962 cricket::RtpHeaderExtension(cricket_ext, id));
963 EXPECT_TRUE(channel_->SetSendParameters(parameters));
964 FakeVideoSendStream* send_stream =
965 AddSendStream(cricket::StreamParams::CreateLegacy(123));
966
967 // Verify the send extension id.
968 ASSERT_EQ(1u, send_stream->GetConfig().rtp.extensions.size());
969 EXPECT_EQ(id, send_stream->GetConfig().rtp.extensions[0].id);
970 EXPECT_EQ(webrtc_ext, send_stream->GetConfig().rtp.extensions[0].name);
971 // Verify call with same set of extensions returns true.
972 EXPECT_TRUE(channel_->SetSendParameters(parameters));
973 // Verify that SetSendRtpHeaderExtensions doesn't implicitly add them for
974 // receivers.
975 EXPECT_TRUE(AddRecvStream(cricket::StreamParams::CreateLegacy(123))
976 ->GetConfig()
977 .rtp.extensions.empty());
978
979 // Verify that existing RTP header extensions can be removed.
980 EXPECT_TRUE(channel_->SetSendParameters(send_parameters_));
981 ASSERT_EQ(1u, fake_call_->GetVideoSendStreams().size());
982 send_stream = fake_call_->GetVideoSendStreams()[0];
983 EXPECT_TRUE(send_stream->GetConfig().rtp.extensions.empty());
984
985 // Verify that adding receive RTP header extensions adds them for existing
986 // streams.
987 EXPECT_TRUE(channel_->SetSendParameters(parameters));
988 send_stream = fake_call_->GetVideoSendStreams()[0];
989 ASSERT_EQ(1u, send_stream->GetConfig().rtp.extensions.size());
990 EXPECT_EQ(id, send_stream->GetConfig().rtp.extensions[0].id);
991 EXPECT_EQ(webrtc_ext, send_stream->GetConfig().rtp.extensions[0].name);
992 }
993
994 void TestSetRecvRtpHeaderExtensions(const std::string& cricket_ext,
995 const std::string& webrtc_ext) {
996 // Enable extension.
997 const int id = 1;
998 cricket::VideoRecvParameters parameters = recv_parameters_;
999 parameters.extensions.push_back(
1000 cricket::RtpHeaderExtension(cricket_ext, id));
1001 EXPECT_TRUE(channel_->SetRecvParameters(parameters));
1002
1003 FakeVideoReceiveStream* recv_stream =
1004 AddRecvStream(cricket::StreamParams::CreateLegacy(123));
1005
1006 // Verify the recv extension id.
1007 ASSERT_EQ(1u, recv_stream->GetConfig().rtp.extensions.size());
1008 EXPECT_EQ(id, recv_stream->GetConfig().rtp.extensions[0].id);
1009 EXPECT_EQ(webrtc_ext, recv_stream->GetConfig().rtp.extensions[0].name);
1010 // Verify call with same set of extensions returns true.
1011 EXPECT_TRUE(channel_->SetRecvParameters(parameters));
1012
1013 // Verify that SetRecvRtpHeaderExtensions doesn't implicitly add them for
1014 // senders.
1015 EXPECT_TRUE(AddSendStream(cricket::StreamParams::CreateLegacy(123))
1016 ->GetConfig()
1017 .rtp.extensions.empty());
1018
1019 // Verify that existing RTP header extensions can be removed.
1020 EXPECT_TRUE(channel_->SetRecvParameters(recv_parameters_));
1021 ASSERT_EQ(1u, fake_call_->GetVideoReceiveStreams().size());
1022 recv_stream = fake_call_->GetVideoReceiveStreams()[0];
1023 EXPECT_TRUE(recv_stream->GetConfig().rtp.extensions.empty());
1024
1025 // Verify that adding receive RTP header extensions adds them for existing
1026 // streams.
1027 EXPECT_TRUE(channel_->SetRecvParameters(parameters));
1028 recv_stream = fake_call_->GetVideoReceiveStreams()[0];
1029 ASSERT_EQ(1u, recv_stream->GetConfig().rtp.extensions.size());
1030 EXPECT_EQ(id, recv_stream->GetConfig().rtp.extensions[0].id);
1031 EXPECT_EQ(webrtc_ext, recv_stream->GetConfig().rtp.extensions[0].name);
1032 }
1033
1034 void TestExtensionFilter(const std::vector<std::string>& extensions,
1035 const std::string& expected_extension) {
1036 cricket::VideoSendParameters parameters = send_parameters_;
1037 int expected_id = -1;
1038 int id = 1;
1039 for (const std::string& extension : extensions) {
1040 if (extension == expected_extension)
1041 expected_id = id;
1042 parameters.extensions.push_back(
1043 cricket::RtpHeaderExtension(extension, id++));
1044 }
1045 EXPECT_TRUE(channel_->SetSendParameters(parameters));
1046 FakeVideoSendStream* send_stream =
1047 AddSendStream(cricket::StreamParams::CreateLegacy(123));
1048
1049 // Verify that only one of them has been set, and that it is the one with
1050 // highest priority (transport sequence number).
1051 ASSERT_EQ(1u, send_stream->GetConfig().rtp.extensions.size());
1052 EXPECT_EQ(expected_id, send_stream->GetConfig().rtp.extensions[0].id);
1053 EXPECT_EQ(expected_extension,
1054 send_stream->GetConfig().rtp.extensions[0].name);
1055 }
1056
1057 void TestCpuAdaptation(bool enable_overuse, bool is_screenshare);
1058 void TestReceiverLocalSsrcConfiguration(bool receiver_first);
1059 void TestReceiveUnsignalledSsrcPacket(uint8_t payload_type,
1060 bool expect_created_receive_stream);
1061
1062 FakeVideoSendStream* SetDenoisingOption(
1063 const cricket::VideoSendParameters& parameters, bool enabled) {
1064 cricket::VideoSendParameters params = parameters;
1065 params.options.video_noise_reduction = rtc::Optional<bool>(enabled);
1066 channel_->SetSendParameters(params);
1067 return fake_call_->GetVideoSendStreams().back();
1068 }
1069
1070 FakeVideoSendStream* SetUpSimulcast(bool enabled, bool with_rtx) {
1071 const int kRtxSsrcOffset = 0xDEADBEEF;
1072 last_ssrc_ += 3;
1073 std::vector<uint32_t> ssrcs;
1074 std::vector<uint32_t> rtx_ssrcs;
1075 uint32_t num_streams = enabled ? 3 : 1;
1076 for (uint32_t i = 0; i < num_streams; ++i) {
1077 uint32_t ssrc = last_ssrc_ + i;
1078 ssrcs.push_back(ssrc);
1079 if (with_rtx) {
1080 rtx_ssrcs.push_back(ssrc + kRtxSsrcOffset);
1081 }
1082 }
1083 if (with_rtx) {
1084 return AddSendStream(
1085 cricket::CreateSimWithRtxStreamParams("cname", ssrcs, rtx_ssrcs));
1086 }
1087 return AddSendStream(CreateSimStreamParams("cname", ssrcs));
1088 }
1089
1090 rtc::scoped_ptr<FakeCall> fake_call_;
1091 rtc::scoped_ptr<VideoMediaChannel> channel_;
1092 cricket::VideoSendParameters send_parameters_;
1093 cricket::VideoRecvParameters recv_parameters_;
1094 uint32_t last_ssrc_;
1095 };
1096
1097 TEST_F(WebRtcVideoChannel2Test, SetsSyncGroupFromSyncLabel) {
1098 const uint32_t kVideoSsrc = 123;
1099 const std::string kSyncLabel = "AvSyncLabel";
1100
1101 cricket::StreamParams sp = cricket::StreamParams::CreateLegacy(kVideoSsrc);
1102 sp.sync_label = kSyncLabel;
1103 EXPECT_TRUE(channel_->AddRecvStream(sp));
1104
1105 EXPECT_EQ(1, fake_call_->GetVideoReceiveStreams().size());
1106 EXPECT_EQ(kSyncLabel,
1107 fake_call_->GetVideoReceiveStreams()[0]->GetConfig().sync_group)
1108 << "SyncGroup should be set based on sync_label";
1109 }
1110
1111 TEST_F(WebRtcVideoChannel2Test, RecvStreamWithSimAndRtx) {
1112 cricket::VideoSendParameters parameters;
1113 parameters.codecs = engine_.codecs();
1114 EXPECT_TRUE(channel_->SetSendParameters(parameters));
1115 EXPECT_TRUE(channel_->SetSend(true));
1116 parameters.options.conference_mode = rtc::Optional<bool>(true);
1117 EXPECT_TRUE(channel_->SetSendParameters(parameters));
1118
1119 // Send side.
1120 const std::vector<uint32_t> ssrcs = MAKE_VECTOR(kSsrcs1);
1121 const std::vector<uint32_t> rtx_ssrcs = MAKE_VECTOR(kRtxSsrcs1);
1122 FakeVideoSendStream* send_stream = AddSendStream(
1123 cricket::CreateSimWithRtxStreamParams("cname", ssrcs, rtx_ssrcs));
1124
1125 ASSERT_EQ(rtx_ssrcs.size(), send_stream->GetConfig().rtp.rtx.ssrcs.size());
1126 for (size_t i = 0; i < rtx_ssrcs.size(); ++i)
1127 EXPECT_EQ(rtx_ssrcs[i], send_stream->GetConfig().rtp.rtx.ssrcs[i]);
1128
1129 // Receiver side.
1130 FakeVideoReceiveStream* recv_stream = AddRecvStream(
1131 cricket::CreateSimWithRtxStreamParams("cname", ssrcs, rtx_ssrcs));
1132 ASSERT_GT(recv_stream->GetConfig().rtp.rtx.size(), 0u)
1133 << "No SSRCs for RTX configured by AddRecvStream.";
1134 ASSERT_EQ(1u, recv_stream->GetConfig().rtp.rtx.size())
1135 << "This test only works with one receive codec. Please update the test.";
1136 EXPECT_EQ(rtx_ssrcs[0],
1137 recv_stream->GetConfig().rtp.rtx.begin()->second.ssrc);
1138 // TODO(pbos): Make sure we set the RTX for correct payloads etc.
1139 }
1140
1141 TEST_F(WebRtcVideoChannel2Test, RecvStreamWithRtx) {
1142 // Setup one channel with an associated RTX stream.
1143 cricket::StreamParams params =
1144 cricket::StreamParams::CreateLegacy(kSsrcs1[0]);
1145 params.AddFidSsrc(kSsrcs1[0], kRtxSsrcs1[0]);
1146 FakeVideoReceiveStream* recv_stream = AddRecvStream(params);
1147 ASSERT_EQ(1u, recv_stream->GetConfig().rtp.rtx.size());
1148 EXPECT_EQ(kRtxSsrcs1[0],
1149 recv_stream->GetConfig().rtp.rtx.begin()->second.ssrc);
1150 }
1151
1152 TEST_F(WebRtcVideoChannel2Test, RecvStreamNoRtx) {
1153 // Setup one channel without an associated RTX stream.
1154 cricket::StreamParams params =
1155 cricket::StreamParams::CreateLegacy(kSsrcs1[0]);
1156 FakeVideoReceiveStream* recv_stream = AddRecvStream(params);
1157 ASSERT_TRUE(recv_stream->GetConfig().rtp.rtx.empty());
1158 }
1159
1160 TEST_F(WebRtcVideoChannel2Test, NoHeaderExtesionsByDefault) {
1161 FakeVideoSendStream* send_stream =
1162 AddSendStream(cricket::StreamParams::CreateLegacy(kSsrcs1[0]));
1163 ASSERT_TRUE(send_stream->GetConfig().rtp.extensions.empty());
1164
1165 FakeVideoReceiveStream* recv_stream =
1166 AddRecvStream(cricket::StreamParams::CreateLegacy(kSsrcs1[0]));
1167 ASSERT_TRUE(recv_stream->GetConfig().rtp.extensions.empty());
1168 }
1169
1170 // Test support for RTP timestamp offset header extension.
1171 TEST_F(WebRtcVideoChannel2Test, SendRtpTimestampOffsetHeaderExtensions) {
1172 TestSetSendRtpHeaderExtensions(kRtpTimestampOffsetHeaderExtension,
1173 webrtc::RtpExtension::kTOffset);
1174 }
1175 TEST_F(WebRtcVideoChannel2Test, RecvRtpTimestampOffsetHeaderExtensions) {
1176 TestSetRecvRtpHeaderExtensions(kRtpTimestampOffsetHeaderExtension,
1177 webrtc::RtpExtension::kTOffset);
1178 }
1179
1180 // Test support for absolute send time header extension.
1181 TEST_F(WebRtcVideoChannel2Test, SendAbsoluteSendTimeHeaderExtensions) {
1182 TestSetSendRtpHeaderExtensions(kRtpAbsoluteSenderTimeHeaderExtension,
1183 webrtc::RtpExtension::kAbsSendTime);
1184 }
1185 TEST_F(WebRtcVideoChannel2Test, RecvAbsoluteSendTimeHeaderExtensions) {
1186 TestSetRecvRtpHeaderExtensions(kRtpAbsoluteSenderTimeHeaderExtension,
1187 webrtc::RtpExtension::kAbsSendTime);
1188 }
1189
1190 TEST_F(WebRtcVideoChannel2Test, FiltersExtensionsPicksTransportSeqNum) {
1191 // Enable three redundant extensions.
1192 std::vector<std::string> extensions;
1193 extensions.push_back(kRtpAbsoluteSenderTimeHeaderExtension);
1194 extensions.push_back(kRtpTimestampOffsetHeaderExtension);
1195 extensions.push_back(kRtpTransportSequenceNumberHeaderExtension);
1196 TestExtensionFilter(extensions, kRtpTransportSequenceNumberHeaderExtension);
1197 }
1198
1199 TEST_F(WebRtcVideoChannel2Test, FiltersExtensionsPicksAbsSendTime) {
1200 // Enable two redundant extensions.
1201 std::vector<std::string> extensions;
1202 extensions.push_back(kRtpAbsoluteSenderTimeHeaderExtension);
1203 extensions.push_back(kRtpTimestampOffsetHeaderExtension);
1204 TestExtensionFilter(extensions, kRtpAbsoluteSenderTimeHeaderExtension);
1205 }
1206
1207 class WebRtcVideoChannel2WithSendSideBweTest : public WebRtcVideoChannel2Test {
1208 public:
1209 WebRtcVideoChannel2WithSendSideBweTest()
1210 : WebRtcVideoChannel2Test("WebRTC-SendSideBwe/Enabled/") {}
1211 };
1212
1213 // Test support for transport sequence number header extension.
1214 TEST_F(WebRtcVideoChannel2WithSendSideBweTest,
1215 SendTransportSequenceNumberHeaderExtensions) {
1216 TestSetSendRtpHeaderExtensions(
1217 kRtpTransportSequenceNumberHeaderExtension,
1218 webrtc::RtpExtension::kTransportSequenceNumber);
1219 }
1220 TEST_F(WebRtcVideoChannel2WithSendSideBweTest,
1221 RecvTransportSequenceNumberHeaderExtensions) {
1222 TestSetRecvRtpHeaderExtensions(
1223 kRtpTransportSequenceNumberHeaderExtension,
1224 webrtc::RtpExtension::kTransportSequenceNumber);
1225 }
1226
1227 // Test support for video rotation header extension.
1228 TEST_F(WebRtcVideoChannel2Test, SendVideoRotationHeaderExtensions) {
1229 TestSetSendRtpHeaderExtensions(kRtpVideoRotationHeaderExtension,
1230 webrtc::RtpExtension::kVideoRotation);
1231 }
1232 TEST_F(WebRtcVideoChannel2Test, RecvVideoRotationHeaderExtensions) {
1233 TestSetRecvRtpHeaderExtensions(kRtpVideoRotationHeaderExtension,
1234 webrtc::RtpExtension::kVideoRotation);
1235 }
1236
1237 TEST_F(WebRtcVideoChannel2Test, IdenticalSendExtensionsDoesntRecreateStream) {
1238 const int kAbsSendTimeId = 1;
1239 const int kVideoRotationId = 2;
1240 send_parameters_.extensions.push_back(cricket::RtpHeaderExtension(
1241 kRtpAbsoluteSenderTimeHeaderExtension, kAbsSendTimeId));
1242 send_parameters_.extensions.push_back(cricket::RtpHeaderExtension(
1243 kRtpVideoRotationHeaderExtension, kVideoRotationId));
1244
1245 EXPECT_TRUE(channel_->SetSendParameters(send_parameters_));
1246 FakeVideoSendStream* send_stream =
1247 AddSendStream(cricket::StreamParams::CreateLegacy(123));
1248
1249 EXPECT_EQ(1, fake_call_->GetNumCreatedSendStreams());
1250 ASSERT_EQ(2u, send_stream->GetConfig().rtp.extensions.size());
1251
1252 // Setting the same extensions (even if in different order) shouldn't
1253 // reallocate the stream.
1254 std::reverse(send_parameters_.extensions.begin(),
1255 send_parameters_.extensions.end());
1256 EXPECT_TRUE(channel_->SetSendParameters(send_parameters_));
1257
1258 EXPECT_EQ(1, fake_call_->GetNumCreatedSendStreams());
1259
1260 // Setting different extensions should recreate the stream.
1261 send_parameters_.extensions.resize(1);
1262 EXPECT_TRUE(channel_->SetSendParameters(send_parameters_));
1263
1264 EXPECT_EQ(2, fake_call_->GetNumCreatedSendStreams());
1265 }
1266
1267 TEST_F(WebRtcVideoChannel2Test, IdenticalRecvExtensionsDoesntRecreateStream) {
1268 const int kTOffsetId = 1;
1269 const int kAbsSendTimeId = 2;
1270 const int kVideoRotationId = 3;
1271 recv_parameters_.extensions.push_back(cricket::RtpHeaderExtension(
1272 kRtpAbsoluteSenderTimeHeaderExtension, kAbsSendTimeId));
1273 recv_parameters_.extensions.push_back(cricket::RtpHeaderExtension(
1274 kRtpTimestampOffsetHeaderExtension, kTOffsetId));
1275 recv_parameters_.extensions.push_back(cricket::RtpHeaderExtension(
1276 kRtpVideoRotationHeaderExtension, kVideoRotationId));
1277
1278 EXPECT_TRUE(channel_->SetRecvParameters(recv_parameters_));
1279 FakeVideoReceiveStream* recv_stream =
1280 AddRecvStream(cricket::StreamParams::CreateLegacy(123));
1281
1282 EXPECT_EQ(1, fake_call_->GetNumCreatedReceiveStreams());
1283 ASSERT_EQ(3u, recv_stream->GetConfig().rtp.extensions.size());
1284
1285 // Setting the same extensions (even if in different order) shouldn't
1286 // reallocate the stream.
1287 std::reverse(recv_parameters_.extensions.begin(),
1288 recv_parameters_.extensions.end());
1289 EXPECT_TRUE(channel_->SetRecvParameters(recv_parameters_));
1290
1291 EXPECT_EQ(1, fake_call_->GetNumCreatedReceiveStreams());
1292
1293 // Setting different extensions should recreate the stream.
1294 recv_parameters_.extensions.resize(1);
1295 EXPECT_TRUE(channel_->SetRecvParameters(recv_parameters_));
1296
1297 EXPECT_EQ(2, fake_call_->GetNumCreatedReceiveStreams());
1298 }
1299
1300 TEST_F(WebRtcVideoChannel2Test,
1301 SetSendRtpHeaderExtensionsExcludeUnsupportedExtensions) {
1302 const int kUnsupportedId = 1;
1303 const int kTOffsetId = 2;
1304
1305 send_parameters_.extensions.push_back(
1306 cricket::RtpHeaderExtension(kUnsupportedExtensionName, kUnsupportedId));
1307 send_parameters_.extensions.push_back(
1308 cricket::RtpHeaderExtension(webrtc::RtpExtension::kTOffset, kTOffsetId));
1309 EXPECT_TRUE(channel_->SetSendParameters(send_parameters_));
1310 FakeVideoSendStream* send_stream =
1311 AddSendStream(cricket::StreamParams::CreateLegacy(123));
1312
1313 // Only timestamp offset extension is set to send stream,
1314 // unsupported rtp extension is ignored.
1315 ASSERT_EQ(1u, send_stream->GetConfig().rtp.extensions.size());
1316 EXPECT_STREQ(webrtc::RtpExtension::kTOffset,
1317 send_stream->GetConfig().rtp.extensions[0].name.c_str());
1318 }
1319
1320 TEST_F(WebRtcVideoChannel2Test,
1321 SetRecvRtpHeaderExtensionsExcludeUnsupportedExtensions) {
1322 const int kUnsupportedId = 1;
1323 const int kTOffsetId = 2;
1324
1325 recv_parameters_.extensions.push_back(
1326 cricket::RtpHeaderExtension(kUnsupportedExtensionName, kUnsupportedId));
1327 recv_parameters_.extensions.push_back(
1328 cricket::RtpHeaderExtension(webrtc::RtpExtension::kTOffset, kTOffsetId));
1329 EXPECT_TRUE(channel_->SetRecvParameters(recv_parameters_));
1330 FakeVideoReceiveStream* recv_stream =
1331 AddRecvStream(cricket::StreamParams::CreateLegacy(123));
1332
1333 // Only timestamp offset extension is set to receive stream,
1334 // unsupported rtp extension is ignored.
1335 ASSERT_EQ(1u, recv_stream->GetConfig().rtp.extensions.size());
1336 EXPECT_STREQ(webrtc::RtpExtension::kTOffset,
1337 recv_stream->GetConfig().rtp.extensions[0].name.c_str());
1338 }
1339
1340 TEST_F(WebRtcVideoChannel2Test, SetSendRtpHeaderExtensionsRejectsIncorrectIds) {
1341 const int kIncorrectIds[] = {-2, -1, 0, 15, 16};
1342 for (size_t i = 0; i < arraysize(kIncorrectIds); ++i) {
1343 send_parameters_.extensions.push_back(cricket::RtpHeaderExtension(
1344 webrtc::RtpExtension::kTOffset, kIncorrectIds[i]));
1345 EXPECT_FALSE(channel_->SetSendParameters(send_parameters_))
1346 << "Bad extension id '" << kIncorrectIds[i] << "' accepted.";
1347 }
1348 }
1349
1350 TEST_F(WebRtcVideoChannel2Test, SetRecvRtpHeaderExtensionsRejectsIncorrectIds) {
1351 const int kIncorrectIds[] = {-2, -1, 0, 15, 16};
1352 for (size_t i = 0; i < arraysize(kIncorrectIds); ++i) {
1353 recv_parameters_.extensions.push_back(cricket::RtpHeaderExtension(
1354 webrtc::RtpExtension::kTOffset, kIncorrectIds[i]));
1355 EXPECT_FALSE(channel_->SetRecvParameters(recv_parameters_))
1356 << "Bad extension id '" << kIncorrectIds[i] << "' accepted.";
1357 }
1358 }
1359
1360 TEST_F(WebRtcVideoChannel2Test, SetSendRtpHeaderExtensionsRejectsDuplicateIds) {
1361 const int id = 1;
1362 send_parameters_.extensions.push_back(
1363 cricket::RtpHeaderExtension(webrtc::RtpExtension::kTOffset, id));
1364 send_parameters_.extensions.push_back(
1365 cricket::RtpHeaderExtension(kRtpAbsoluteSenderTimeHeaderExtension, id));
1366 EXPECT_FALSE(channel_->SetSendParameters(send_parameters_));
1367
1368 // Duplicate entries are also not supported.
1369 send_parameters_.extensions.clear();
1370 send_parameters_.extensions.push_back(
1371 cricket::RtpHeaderExtension(webrtc::RtpExtension::kTOffset, id));
1372 send_parameters_.extensions.push_back(send_parameters_.extensions.back());
1373 EXPECT_FALSE(channel_->SetSendParameters(send_parameters_));
1374 }
1375
1376 TEST_F(WebRtcVideoChannel2Test, SetRecvRtpHeaderExtensionsRejectsDuplicateIds) {
1377 const int id = 1;
1378 recv_parameters_.extensions.push_back(
1379 cricket::RtpHeaderExtension(webrtc::RtpExtension::kTOffset, id));
1380 recv_parameters_.extensions.push_back(
1381 cricket::RtpHeaderExtension(kRtpAbsoluteSenderTimeHeaderExtension, id));
1382 EXPECT_FALSE(channel_->SetRecvParameters(recv_parameters_));
1383
1384 // Duplicate entries are also not supported.
1385 recv_parameters_.extensions.clear();
1386 recv_parameters_.extensions.push_back(
1387 cricket::RtpHeaderExtension(webrtc::RtpExtension::kTOffset, id));
1388 recv_parameters_.extensions.push_back(recv_parameters_.extensions.back());
1389 EXPECT_FALSE(channel_->SetRecvParameters(recv_parameters_));
1390 }
1391
1392 TEST_F(WebRtcVideoChannel2Test, DISABLED_LeakyBucketTest) {
1393 FAIL() << "Not implemented."; // TODO(pbos): Implement.
1394 }
1395
1396 TEST_F(WebRtcVideoChannel2Test, DISABLED_BufferedModeLatency) {
1397 FAIL() << "Not implemented."; // TODO(pbos): Implement.
1398 }
1399
1400 TEST_F(WebRtcVideoChannel2Test, DISABLED_AdditiveVideoOptions) {
1401 FAIL() << "Not implemented."; // TODO(pbos): Implement.
1402 }
1403
1404 TEST_F(WebRtcVideoChannel2Test, AddRecvStreamOnlyUsesOneReceiveStream) {
1405 EXPECT_TRUE(channel_->AddRecvStream(cricket::StreamParams::CreateLegacy(1)));
1406 EXPECT_EQ(1u, fake_call_->GetVideoReceiveStreams().size());
1407 }
1408
1409 TEST_F(WebRtcVideoChannel2Test, RtcpIsCompoundByDefault) {
1410 FakeVideoReceiveStream* stream = AddRecvStream();
1411 EXPECT_EQ(webrtc::RtcpMode::kCompound, stream->GetConfig().rtp.rtcp_mode);
1412 }
1413
1414 TEST_F(WebRtcVideoChannel2Test, RembIsEnabledByDefault) {
1415 FakeVideoReceiveStream* stream = AddRecvStream();
1416 EXPECT_TRUE(stream->GetConfig().rtp.remb);
1417 }
1418
1419 TEST_F(WebRtcVideoChannel2Test, TransportCcIsEnabledByDefault) {
1420 FakeVideoReceiveStream* stream = AddRecvStream();
1421 EXPECT_TRUE(stream->GetConfig().rtp.transport_cc);
1422 }
1423
1424 TEST_F(WebRtcVideoChannel2Test, RembCanBeEnabledAndDisabled) {
1425 FakeVideoReceiveStream* stream = AddRecvStream();
1426 EXPECT_TRUE(stream->GetConfig().rtp.remb);
1427
1428 // Verify that REMB is turned off when send(!) codecs without REMB are set.
1429 cricket::VideoSendParameters parameters;
1430 parameters.codecs.push_back(kVp8Codec);
1431 EXPECT_TRUE(parameters.codecs[0].feedback_params.params().empty());
1432 EXPECT_TRUE(channel_->SetSendParameters(parameters));
1433 stream = fake_call_->GetVideoReceiveStreams()[0];
1434 EXPECT_FALSE(stream->GetConfig().rtp.remb);
1435
1436 // Verify that REMB is turned on when setting default codecs since the
1437 // default codecs have REMB enabled.
1438 parameters.codecs = engine_.codecs();
1439 EXPECT_TRUE(channel_->SetSendParameters(parameters));
1440 stream = fake_call_->GetVideoReceiveStreams()[0];
1441 EXPECT_TRUE(stream->GetConfig().rtp.remb);
1442 }
1443
1444 TEST_F(WebRtcVideoChannel2Test, TransportCcCanBeEnabledAndDisabled) {
1445 FakeVideoReceiveStream* stream = AddRecvStream();
1446 EXPECT_TRUE(stream->GetConfig().rtp.transport_cc);
1447
1448 // Verify that transport cc feedback is turned off when send(!) codecs without
1449 // transport cc feedback are set.
1450 cricket::VideoSendParameters parameters;
1451 parameters.codecs.push_back(kVp8Codec);
1452 EXPECT_TRUE(parameters.codecs[0].feedback_params.params().empty());
1453 EXPECT_TRUE(channel_->SetSendParameters(parameters));
1454 stream = fake_call_->GetVideoReceiveStreams()[0];
1455 EXPECT_FALSE(stream->GetConfig().rtp.transport_cc);
1456
1457 // Verify that transport cc feedback is turned on when setting default codecs
1458 // since the default codecs have transport cc feedback enabled.
1459 parameters.codecs = engine_.codecs();
1460 EXPECT_TRUE(channel_->SetSendParameters(parameters));
1461 stream = fake_call_->GetVideoReceiveStreams()[0];
1462 EXPECT_TRUE(stream->GetConfig().rtp.transport_cc);
1463 }
1464
1465 TEST_F(WebRtcVideoChannel2Test, NackIsEnabledByDefault) {
1466 VerifyCodecHasDefaultFeedbackParams(default_codec_);
1467
1468 cricket::VideoSendParameters parameters;
1469 parameters.codecs = engine_.codecs();
1470 EXPECT_TRUE(channel_->SetSendParameters(parameters));
1471 EXPECT_TRUE(channel_->SetSend(true));
1472
1473 // Send side.
1474 FakeVideoSendStream* send_stream =
1475 AddSendStream(cricket::StreamParams::CreateLegacy(1));
1476 EXPECT_GT(send_stream->GetConfig().rtp.nack.rtp_history_ms, 0);
1477
1478 // Receiver side.
1479 FakeVideoReceiveStream* recv_stream =
1480 AddRecvStream(cricket::StreamParams::CreateLegacy(1));
1481 EXPECT_GT(recv_stream->GetConfig().rtp.nack.rtp_history_ms, 0);
1482
1483 // Nack history size should match between sender and receiver.
1484 EXPECT_EQ(send_stream->GetConfig().rtp.nack.rtp_history_ms,
1485 recv_stream->GetConfig().rtp.nack.rtp_history_ms);
1486 }
1487
1488 TEST_F(WebRtcVideoChannel2Test, NackCanBeEnabledAndDisabled) {
1489 FakeVideoSendStream* send_stream = AddSendStream();
1490 FakeVideoReceiveStream* recv_stream = AddRecvStream();
1491
1492 EXPECT_GT(recv_stream->GetConfig().rtp.nack.rtp_history_ms, 0);
1493 EXPECT_GT(send_stream->GetConfig().rtp.nack.rtp_history_ms, 0);
1494
1495 // Verify that NACK is turned off when send(!) codecs without NACK are set.
1496 cricket::VideoSendParameters parameters;
1497 parameters.codecs.push_back(kVp8Codec);
1498 EXPECT_TRUE(parameters.codecs[0].feedback_params.params().empty());
1499 EXPECT_TRUE(channel_->SetSendParameters(parameters));
1500 recv_stream = fake_call_->GetVideoReceiveStreams()[0];
1501 EXPECT_EQ(0, recv_stream->GetConfig().rtp.nack.rtp_history_ms);
1502 send_stream = fake_call_->GetVideoSendStreams()[0];
1503 EXPECT_EQ(0, send_stream->GetConfig().rtp.nack.rtp_history_ms);
1504
1505 // Verify that NACK is turned on when setting default codecs since the
1506 // default codecs have NACK enabled.
1507 parameters.codecs = engine_.codecs();
1508 EXPECT_TRUE(channel_->SetSendParameters(parameters));
1509 recv_stream = fake_call_->GetVideoReceiveStreams()[0];
1510 EXPECT_GT(recv_stream->GetConfig().rtp.nack.rtp_history_ms, 0);
1511 send_stream = fake_call_->GetVideoSendStreams()[0];
1512 EXPECT_GT(send_stream->GetConfig().rtp.nack.rtp_history_ms, 0);
1513 }
1514
1515 TEST_F(WebRtcVideoChannel2Test, DISABLED_VideoProtectionInterop) {
1516 FAIL() << "Not implemented."; // TODO(pbos): Implement.
1517 }
1518
1519 TEST_F(WebRtcVideoChannel2Test, DISABLED_VideoProtectionInteropReversed) {
1520 FAIL() << "Not implemented."; // TODO(pbos): Implement.
1521 }
1522
1523 TEST_F(WebRtcVideoChannel2Test, DISABLED_HybridNackFecConference) {
1524 FAIL() << "Not implemented."; // TODO(pbos): Implement.
1525 }
1526
1527 TEST_F(WebRtcVideoChannel2Test, DISABLED_AddRemoveRecvStreamConference) {
1528 FAIL() << "Not implemented."; // TODO(pbos): Implement.
1529 }
1530
1531 TEST_F(WebRtcVideoChannel2Test, DISABLED_SetBandwidthAuto) {
1532 FAIL() << "Not implemented."; // TODO(pbos): Implement.
1533 }
1534
1535 TEST_F(WebRtcVideoChannel2Test, DISABLED_SetBandwidthAutoCapped) {
1536 FAIL() << "Not implemented."; // TODO(pbos): Implement.
1537 }
1538
1539 TEST_F(WebRtcVideoChannel2Test, DISABLED_SetBandwidthFixed) {
1540 FAIL() << "Not implemented."; // TODO(pbos): Implement.
1541 }
1542
1543 TEST_F(WebRtcVideoChannel2Test, DISABLED_SetBandwidthInConference) {
1544 FAIL() << "Not implemented."; // TODO(pbos): Implement.
1545 }
1546
1547 TEST_F(WebRtcVideoChannel2Test, UsesCorrectSettingsForScreencast) {
1548 static const int kScreenshareMinBitrateKbps = 800;
1549 cricket::VideoCodec codec = kVp8Codec360p;
1550 cricket::VideoSendParameters parameters;
1551 parameters.codecs.push_back(codec);
1552 parameters.options.screencast_min_bitrate =
1553 rtc::Optional<int>(kScreenshareMinBitrateKbps);
1554 EXPECT_TRUE(channel_->SetSendParameters(parameters));
1555
1556 AddSendStream();
1557
1558 cricket::FakeVideoCapturer capturer;
1559 capturer.SetScreencast(false);
1560 EXPECT_TRUE(channel_->SetCapturer(last_ssrc_, &capturer));
1561 cricket::VideoFormat capture_format_hd =
1562 capturer.GetSupportedFormats()->front();
1563 EXPECT_EQ(1280, capture_format_hd.width);
1564 EXPECT_EQ(720, capture_format_hd.height);
1565 EXPECT_EQ(cricket::CS_RUNNING, capturer.Start(capture_format_hd));
1566
1567 EXPECT_TRUE(channel_->SetSend(true));
1568
1569 EXPECT_TRUE(capturer.CaptureFrame());
1570 ASSERT_EQ(1u, fake_call_->GetVideoSendStreams().size());
1571 FakeVideoSendStream* send_stream = fake_call_->GetVideoSendStreams().front();
1572
1573 EXPECT_EQ(1, send_stream->GetNumberOfSwappedFrames());
1574
1575 // Verify non-screencast settings.
1576 webrtc::VideoEncoderConfig encoder_config = send_stream->GetEncoderConfig();
1577 EXPECT_EQ(webrtc::VideoEncoderConfig::ContentType::kRealtimeVideo,
1578 encoder_config.content_type);
1579 EXPECT_EQ(codec.width, encoder_config.streams.front().width);
1580 EXPECT_EQ(codec.height, encoder_config.streams.front().height);
1581 EXPECT_EQ(0, encoder_config.min_transmit_bitrate_bps)
1582 << "Non-screenshare shouldn't use min-transmit bitrate.";
1583
1584 capturer.SetScreencast(true);
1585 EXPECT_TRUE(capturer.CaptureFrame());
1586
1587 EXPECT_EQ(2, send_stream->GetNumberOfSwappedFrames());
1588
1589 // Verify screencast settings.
1590 encoder_config = send_stream->GetEncoderConfig();
1591 EXPECT_EQ(webrtc::VideoEncoderConfig::ContentType::kScreen,
1592 encoder_config.content_type);
1593 EXPECT_EQ(kScreenshareMinBitrateKbps * 1000,
1594 encoder_config.min_transmit_bitrate_bps);
1595
1596 EXPECT_EQ(capture_format_hd.width, encoder_config.streams.front().width);
1597 EXPECT_EQ(capture_format_hd.height, encoder_config.streams.front().height);
1598 EXPECT_TRUE(encoder_config.streams[0].temporal_layer_thresholds_bps.empty());
1599
1600 EXPECT_TRUE(channel_->SetCapturer(last_ssrc_, NULL));
1601 }
1602
1603 TEST_F(WebRtcVideoChannel2Test,
1604 ConferenceModeScreencastConfiguresTemporalLayer) {
1605 static const int kConferenceScreencastTemporalBitrateBps =
1606 ScreenshareLayerConfig::GetDefault().tl0_bitrate_kbps * 1000;
1607 send_parameters_.options.conference_mode = rtc::Optional<bool>(true);
1608 channel_->SetSendParameters(send_parameters_);
1609
1610 AddSendStream();
1611
1612 cricket::FakeVideoCapturer capturer;
1613 capturer.SetScreencast(true);
1614 EXPECT_TRUE(channel_->SetCapturer(last_ssrc_, &capturer));
1615 cricket::VideoFormat capture_format_hd =
1616 capturer.GetSupportedFormats()->front();
1617 EXPECT_EQ(cricket::CS_RUNNING, capturer.Start(capture_format_hd));
1618
1619 EXPECT_TRUE(channel_->SetSend(true));
1620
1621 EXPECT_TRUE(capturer.CaptureFrame());
1622 ASSERT_EQ(1u, fake_call_->GetVideoSendStreams().size());
1623 FakeVideoSendStream* send_stream = fake_call_->GetVideoSendStreams().front();
1624
1625 webrtc::VideoEncoderConfig encoder_config = send_stream->GetEncoderConfig();
1626
1627 // Verify screencast settings.
1628 encoder_config = send_stream->GetEncoderConfig();
1629 EXPECT_EQ(webrtc::VideoEncoderConfig::ContentType::kScreen,
1630 encoder_config.content_type);
1631 ASSERT_EQ(1u, encoder_config.streams.size());
1632 ASSERT_EQ(1u, encoder_config.streams[0].temporal_layer_thresholds_bps.size());
1633 EXPECT_EQ(kConferenceScreencastTemporalBitrateBps,
1634 encoder_config.streams[0].temporal_layer_thresholds_bps[0]);
1635
1636 EXPECT_TRUE(channel_->SetCapturer(last_ssrc_, NULL));
1637 }
1638
1639 TEST_F(WebRtcVideoChannel2Test, DISABLED_SetSendSsrcAndCname) {
1640 FAIL() << "Not implemented."; // TODO(pbos): Implement.
1641 }
1642
1643 TEST_F(WebRtcVideoChannel2Test,
1644 DISABLED_SetSendSsrcAfterCreatingReceiveChannel) {
1645 FAIL() << "Not implemented."; // TODO(pbos): Implement.
1646 }
1647
1648 TEST_F(WebRtcVideoChannel2Test, SuspendBelowMinBitrateDisabledByDefault) {
1649 FakeVideoSendStream* stream = AddSendStream();
1650 EXPECT_FALSE(stream->GetConfig().suspend_below_min_bitrate);
1651 }
1652
1653 TEST_F(WebRtcVideoChannel2Test, SetOptionsWithSuspendBelowMinBitrate) {
1654 send_parameters_.options.suspend_below_min_bitrate =
1655 rtc::Optional<bool>(true);
1656 channel_->SetSendParameters(send_parameters_);
1657
1658 FakeVideoSendStream* stream = AddSendStream();
1659 EXPECT_TRUE(stream->GetConfig().suspend_below_min_bitrate);
1660
1661 send_parameters_.options.suspend_below_min_bitrate =
1662 rtc::Optional<bool>(false);
1663 channel_->SetSendParameters(send_parameters_);
1664
1665 stream = fake_call_->GetVideoSendStreams()[0];
1666 EXPECT_FALSE(stream->GetConfig().suspend_below_min_bitrate);
1667 }
1668
1669 TEST_F(WebRtcVideoChannel2Test, Vp8DenoisingEnabledByDefault) {
1670 FakeVideoSendStream* stream = AddSendStream();
1671 webrtc::VideoCodecVP8 vp8_settings;
1672 ASSERT_TRUE(stream->GetVp8Settings(&vp8_settings)) << "No VP8 config set.";
1673 EXPECT_TRUE(vp8_settings.denoisingOn);
1674 }
1675
1676 TEST_F(WebRtcVideoChannel2Test, VerifyVp8SpecificSettings) {
1677 cricket::VideoSendParameters parameters;
1678 parameters.codecs.push_back(kVp8Codec720p);
1679 ASSERT_TRUE(channel_->SetSendParameters(parameters));
1680
1681 // Single-stream settings should apply with RTX as well (verifies that we
1682 // check number of regular SSRCs and not StreamParams::ssrcs which contains
1683 // both RTX and regular SSRCs).
1684 FakeVideoSendStream* stream = SetUpSimulcast(false, true);
1685
1686 cricket::FakeVideoCapturer capturer;
1687 capturer.SetScreencast(false);
1688 EXPECT_EQ(cricket::CS_RUNNING,
1689 capturer.Start(capturer.GetSupportedFormats()->front()));
1690 EXPECT_TRUE(channel_->SetCapturer(last_ssrc_, &capturer));
1691 channel_->SetSend(true);
1692
1693 EXPECT_TRUE(capturer.CaptureFrame());
1694
1695 webrtc::VideoCodecVP8 vp8_settings;
1696 ASSERT_TRUE(stream->GetVp8Settings(&vp8_settings)) << "No VP8 config set.";
1697 EXPECT_TRUE(vp8_settings.denoisingOn)
1698 << "VP8 denoising should be on by default.";
1699
1700 stream = SetDenoisingOption(parameters, false);
1701
1702 ASSERT_TRUE(stream->GetVp8Settings(&vp8_settings)) << "No VP8 config set.";
1703 EXPECT_FALSE(vp8_settings.denoisingOn);
1704 EXPECT_TRUE(vp8_settings.automaticResizeOn);
1705 EXPECT_TRUE(vp8_settings.frameDroppingOn);
1706
1707 stream = SetDenoisingOption(parameters, true);
1708
1709 ASSERT_TRUE(stream->GetVp8Settings(&vp8_settings)) << "No VP8 config set.";
1710 EXPECT_TRUE(vp8_settings.denoisingOn);
1711 EXPECT_TRUE(vp8_settings.automaticResizeOn);
1712 EXPECT_TRUE(vp8_settings.frameDroppingOn);
1713
1714 EXPECT_TRUE(channel_->SetCapturer(last_ssrc_, NULL));
1715 stream = SetUpSimulcast(true, false);
1716 EXPECT_TRUE(channel_->SetCapturer(last_ssrc_, &capturer));
1717 channel_->SetSend(true);
1718 EXPECT_TRUE(capturer.CaptureFrame());
1719
1720 EXPECT_EQ(3, stream->GetVideoStreams().size());
1721 ASSERT_TRUE(stream->GetVp8Settings(&vp8_settings)) << "No VP8 config set.";
1722 // Autmatic resize off when using simulcast.
1723 EXPECT_FALSE(vp8_settings.automaticResizeOn);
1724 EXPECT_TRUE(vp8_settings.frameDroppingOn);
1725
1726 // In screen-share mode, denoising is forced off and simulcast disabled.
1727 capturer.SetScreencast(true);
1728 EXPECT_TRUE(capturer.CaptureFrame());
1729 stream = SetDenoisingOption(parameters, false);
1730
1731 EXPECT_EQ(1, stream->GetVideoStreams().size());
1732 ASSERT_TRUE(stream->GetVp8Settings(&vp8_settings)) << "No VP8 config set.";
1733 EXPECT_FALSE(vp8_settings.denoisingOn);
1734 // Resizing and frame dropping always off for screen sharing.
1735 EXPECT_FALSE(vp8_settings.automaticResizeOn);
1736 EXPECT_FALSE(vp8_settings.frameDroppingOn);
1737
1738 stream = SetDenoisingOption(parameters, true);
1739
1740 ASSERT_TRUE(stream->GetVp8Settings(&vp8_settings)) << "No VP8 config set.";
1741 EXPECT_FALSE(vp8_settings.denoisingOn);
1742 EXPECT_FALSE(vp8_settings.automaticResizeOn);
1743 EXPECT_FALSE(vp8_settings.frameDroppingOn);
1744
1745 EXPECT_TRUE(channel_->SetCapturer(last_ssrc_, NULL));
1746 }
1747
1748 class Vp9SettingsTest : public WebRtcVideoChannel2Test {
1749 public:
1750 Vp9SettingsTest() : WebRtcVideoChannel2Test() {
1751 encoder_factory_.AddSupportedVideoCodecType(webrtc::kVideoCodecVP9, "VP9");
1752 }
1753 virtual ~Vp9SettingsTest() {}
1754
1755 protected:
1756 void SetUp() override {
1757 engine_.SetExternalEncoderFactory(&encoder_factory_);
1758
1759 WebRtcVideoChannel2Test::SetUp();
1760 }
1761
1762 void TearDown() override {
1763 // Remove references to encoder_factory_ since this will be destroyed
1764 // before channel_ and engine_.
1765 ASSERT_TRUE(channel_->SetSendParameters(send_parameters_));
1766 }
1767
1768 cricket::FakeWebRtcVideoEncoderFactory encoder_factory_;
1769 };
1770
1771 TEST_F(Vp9SettingsTest, VerifyVp9SpecificSettings) {
1772 cricket::VideoSendParameters parameters;
1773 parameters.codecs.push_back(kVp9Codec);
1774 ASSERT_TRUE(channel_->SetSendParameters(parameters));
1775
1776 FakeVideoSendStream* stream = SetUpSimulcast(false, false);
1777
1778 cricket::FakeVideoCapturer capturer;
1779 capturer.SetScreencast(false);
1780 EXPECT_EQ(cricket::CS_RUNNING,
1781 capturer.Start(capturer.GetSupportedFormats()->front()));
1782 EXPECT_TRUE(channel_->SetCapturer(last_ssrc_, &capturer));
1783 channel_->SetSend(true);
1784
1785 EXPECT_TRUE(capturer.CaptureFrame());
1786
1787 webrtc::VideoCodecVP9 vp9_settings;
1788 ASSERT_TRUE(stream->GetVp9Settings(&vp9_settings)) << "No VP9 config set.";
1789 EXPECT_FALSE(vp9_settings.denoisingOn)
1790 << "VP9 denoising should be off by default.";
1791
1792 stream = SetDenoisingOption(parameters, false);
1793
1794 ASSERT_TRUE(stream->GetVp9Settings(&vp9_settings)) << "No VP9 config set.";
1795 EXPECT_FALSE(vp9_settings.denoisingOn);
1796 // Frame dropping always on for real time video.
1797 EXPECT_TRUE(vp9_settings.frameDroppingOn);
1798
1799 stream = SetDenoisingOption(parameters, true);
1800
1801 ASSERT_TRUE(stream->GetVp9Settings(&vp9_settings)) << "No VP9 config set.";
1802 EXPECT_TRUE(vp9_settings.denoisingOn);
1803 EXPECT_TRUE(vp9_settings.frameDroppingOn);
1804
1805 // In screen-share mode, denoising is forced off.
1806 capturer.SetScreencast(true);
1807 EXPECT_TRUE(capturer.CaptureFrame());
1808 stream = SetDenoisingOption(parameters, false);
1809
1810 ASSERT_TRUE(stream->GetVp9Settings(&vp9_settings)) << "No VP9 config set.";
1811 EXPECT_FALSE(vp9_settings.denoisingOn);
1812 // Frame dropping always off for screen sharing.
1813 EXPECT_FALSE(vp9_settings.frameDroppingOn);
1814
1815 stream = SetDenoisingOption(parameters, false);
1816
1817 ASSERT_TRUE(stream->GetVp9Settings(&vp9_settings)) << "No VP9 config set.";
1818 EXPECT_FALSE(vp9_settings.denoisingOn);
1819 EXPECT_FALSE(vp9_settings.frameDroppingOn);
1820
1821 EXPECT_TRUE(channel_->SetCapturer(last_ssrc_, NULL));
1822 }
1823
1824 TEST_F(WebRtcVideoChannel2Test, DISABLED_MultipleSendStreamsWithOneCapturer) {
1825 FAIL() << "Not implemented."; // TODO(pbos): Implement.
1826 }
1827
1828 TEST_F(WebRtcVideoChannel2Test, DISABLED_SendReceiveBitratesStats) {
1829 FAIL() << "Not implemented."; // TODO(pbos): Implement.
1830 }
1831
1832 TEST_F(WebRtcVideoChannel2Test, AdaptsOnOveruse) {
1833 TestCpuAdaptation(true, false);
1834 }
1835
1836 TEST_F(WebRtcVideoChannel2Test, DoesNotAdaptOnOveruseWhenDisabled) {
1837 TestCpuAdaptation(false, false);
1838 }
1839
1840 TEST_F(WebRtcVideoChannel2Test, DoesNotAdaptOnOveruseWhenScreensharing) {
1841 TestCpuAdaptation(true, true);
1842 }
1843
1844 void WebRtcVideoChannel2Test::TestCpuAdaptation(bool enable_overuse,
1845 bool is_screenshare) {
1846 cricket::VideoCodec codec = kVp8Codec720p;
1847 cricket::VideoSendParameters parameters;
1848 parameters.codecs.push_back(codec);
1849 if (!enable_overuse) {
1850 parameters.options.cpu_overuse_detection = rtc::Optional<bool>(false);
1851 }
1852 EXPECT_TRUE(channel_->SetSendParameters(parameters));
1853
1854 AddSendStream();
1855
1856 cricket::FakeVideoCapturer capturer;
1857 capturer.SetScreencast(is_screenshare);
1858 EXPECT_TRUE(channel_->SetCapturer(last_ssrc_, &capturer));
1859 EXPECT_EQ(cricket::CS_RUNNING,
1860 capturer.Start(capturer.GetSupportedFormats()->front()));
1861
1862 EXPECT_TRUE(channel_->SetSend(true));
1863
1864 // Trigger overuse.
1865 ASSERT_EQ(1u, fake_call_->GetVideoSendStreams().size());
1866 FakeVideoSendStream* send_stream = fake_call_->GetVideoSendStreams().front();
1867 webrtc::LoadObserver* overuse_callback =
1868 send_stream->GetConfig().overuse_callback;
1869 ASSERT_TRUE(overuse_callback != NULL);
1870 overuse_callback->OnLoadUpdate(webrtc::LoadObserver::kOveruse);
1871
1872 EXPECT_TRUE(capturer.CaptureFrame());
1873 EXPECT_EQ(1, send_stream->GetNumberOfSwappedFrames());
1874
1875 if (enable_overuse && !is_screenshare) {
1876 EXPECT_LT(send_stream->GetLastWidth(), codec.width);
1877 EXPECT_LT(send_stream->GetLastHeight(), codec.height);
1878 } else {
1879 EXPECT_EQ(codec.width, send_stream->GetLastWidth());
1880 EXPECT_EQ(codec.height, send_stream->GetLastHeight());
1881 }
1882
1883 // Trigger underuse which should go back to normal resolution.
1884 overuse_callback->OnLoadUpdate(webrtc::LoadObserver::kUnderuse);
1885 EXPECT_TRUE(capturer.CaptureFrame());
1886
1887 EXPECT_EQ(2, send_stream->GetNumberOfSwappedFrames());
1888
1889 EXPECT_EQ(codec.width, send_stream->GetLastWidth());
1890 EXPECT_EQ(codec.height, send_stream->GetLastHeight());
1891
1892 EXPECT_TRUE(channel_->SetCapturer(last_ssrc_, NULL));
1893 }
1894
1895 TEST_F(WebRtcVideoChannel2Test, EstimatesNtpStartTimeCorrectly) {
1896 // Start at last timestamp to verify that wraparounds are estimated correctly.
1897 static const uint32_t kInitialTimestamp = 0xFFFFFFFFu;
1898 static const int64_t kInitialNtpTimeMs = 1247891230;
1899 static const int kFrameOffsetMs = 20;
1900 EXPECT_TRUE(channel_->SetRecvParameters(recv_parameters_));
1901
1902 FakeVideoReceiveStream* stream = AddRecvStream();
1903 cricket::FakeVideoRenderer renderer;
1904 EXPECT_TRUE(channel_->SetRenderer(last_ssrc_, &renderer));
1905
1906 webrtc::VideoFrame video_frame;
1907 CreateBlackFrame(&video_frame, 4, 4);
1908 video_frame.set_timestamp(kInitialTimestamp);
1909 // Initial NTP time is not available on the first frame, but should still be
1910 // able to be estimated.
1911 stream->InjectFrame(video_frame, 0);
1912
1913 EXPECT_EQ(1, renderer.num_rendered_frames());
1914
1915 // This timestamp is kInitialTimestamp (-1) + kFrameOffsetMs * 90, which
1916 // triggers a constant-overflow warning, hence we're calculating it explicitly
1917 // here.
1918 video_frame.set_timestamp(kFrameOffsetMs * 90 - 1);
1919 video_frame.set_ntp_time_ms(kInitialNtpTimeMs + kFrameOffsetMs);
1920 stream->InjectFrame(video_frame, 0);
1921
1922 EXPECT_EQ(2, renderer.num_rendered_frames());
1923
1924 // Verify that NTP time has been correctly deduced.
1925 cricket::VideoMediaInfo info;
1926 ASSERT_TRUE(channel_->GetStats(&info));
1927 ASSERT_EQ(1u, info.receivers.size());
1928 EXPECT_EQ(kInitialNtpTimeMs, info.receivers[0].capture_start_ntp_time_ms);
1929 }
1930
1931 TEST_F(WebRtcVideoChannel2Test, SetDefaultSendCodecs) {
1932 ASSERT_TRUE(channel_->SetSendParameters(send_parameters_));
1933
1934 VideoCodec codec;
1935 EXPECT_TRUE(channel_->GetSendCodec(&codec));
1936 EXPECT_TRUE(codec.Matches(engine_.codecs()[0]));
1937
1938 // Using a RTX setup to verify that the default RTX payload type is good.
1939 const std::vector<uint32_t> ssrcs = MAKE_VECTOR(kSsrcs1);
1940 const std::vector<uint32_t> rtx_ssrcs = MAKE_VECTOR(kRtxSsrcs1);
1941 FakeVideoSendStream* stream = AddSendStream(
1942 cricket::CreateSimWithRtxStreamParams("cname", ssrcs, rtx_ssrcs));
1943 webrtc::VideoSendStream::Config config = stream->GetConfig();
1944
1945 // Make sure NACK and FEC are enabled on the correct payload types.
1946 EXPECT_EQ(1000, config.rtp.nack.rtp_history_ms);
1947 EXPECT_EQ(default_ulpfec_codec_.id, config.rtp.fec.ulpfec_payload_type);
1948 EXPECT_EQ(default_red_codec_.id, config.rtp.fec.red_payload_type);
1949
1950 EXPECT_EQ(1u, config.rtp.rtx.ssrcs.size());
1951 EXPECT_EQ(kRtxSsrcs1[0], config.rtp.rtx.ssrcs[0]);
1952 VerifySendStreamHasRtxTypes(config, default_apt_rtx_types_);
1953 // TODO(juberti): Check RTCP, PLI, TMMBR.
1954 }
1955
1956 TEST_F(WebRtcVideoChannel2Test, SetSendCodecsWithoutFec) {
1957 cricket::VideoSendParameters parameters;
1958 parameters.codecs.push_back(kVp8Codec);
1959 ASSERT_TRUE(channel_->SetSendParameters(parameters));
1960
1961 FakeVideoSendStream* stream = AddSendStream();
1962 webrtc::VideoSendStream::Config config = stream->GetConfig();
1963
1964 EXPECT_EQ(-1, config.rtp.fec.ulpfec_payload_type);
1965 EXPECT_EQ(-1, config.rtp.fec.red_payload_type);
1966 }
1967
1968 TEST_F(WebRtcVideoChannel2Test,
1969 SetSendCodecRejectsRtxWithoutAssociatedPayloadType) {
1970 cricket::VideoSendParameters parameters;
1971 cricket::VideoCodec rtx_codec(96, "rtx", 0, 0, 0, 0);
1972 parameters.codecs.push_back(rtx_codec);
1973 EXPECT_FALSE(channel_->SetSendParameters(parameters))
1974 << "RTX codec without associated payload type should be rejected.";
1975 }
1976
1977 TEST_F(WebRtcVideoChannel2Test,
1978 SetSendCodecRejectsRtxWithoutMatchingVideoCodec) {
1979 cricket::VideoSendParameters parameters;
1980 cricket::VideoCodec rtx_codec =
1981 cricket::VideoCodec::CreateRtxCodec(96, kVp8Codec.id);
1982 parameters.codecs.push_back(kVp8Codec);
1983 parameters.codecs.push_back(rtx_codec);
1984 ASSERT_TRUE(channel_->SetSendParameters(parameters));
1985
1986 cricket::VideoCodec rtx_codec2 =
1987 cricket::VideoCodec::CreateRtxCodec(96, kVp8Codec.id + 1);
1988 parameters.codecs.pop_back();
1989 parameters.codecs.push_back(rtx_codec2);
1990 EXPECT_FALSE(channel_->SetSendParameters(parameters))
1991 << "RTX without matching video codec should be rejected.";
1992 }
1993
1994 TEST_F(WebRtcVideoChannel2Test, SetSendCodecsWithoutFecDisablesFec) {
1995 cricket::VideoSendParameters parameters;
1996 parameters.codecs.push_back(kVp8Codec);
1997 parameters.codecs.push_back(kUlpfecCodec);
1998 ASSERT_TRUE(channel_->SetSendParameters(parameters));
1999
2000 FakeVideoSendStream* stream = AddSendStream();
2001 webrtc::VideoSendStream::Config config = stream->GetConfig();
2002
2003 EXPECT_EQ(kUlpfecCodec.id, config.rtp.fec.ulpfec_payload_type);
2004
2005 parameters.codecs.pop_back();
2006 ASSERT_TRUE(channel_->SetSendParameters(parameters));
2007 stream = fake_call_->GetVideoSendStreams()[0];
2008 ASSERT_TRUE(stream != NULL);
2009 config = stream->GetConfig();
2010 EXPECT_EQ(-1, config.rtp.fec.ulpfec_payload_type)
2011 << "SetSendCodec without FEC should disable current FEC.";
2012 }
2013
2014 TEST_F(WebRtcVideoChannel2Test, SetSendCodecsChangesExistingStreams) {
2015 cricket::VideoSendParameters parameters;
2016 parameters.codecs.push_back(kVp8Codec720p);
2017 ASSERT_TRUE(channel_->SetSendParameters(parameters));
2018 channel_->SetSend(true);
2019
2020 FakeVideoSendStream* stream = AddSendStream();
2021
2022 cricket::FakeVideoCapturer capturer;
2023 EXPECT_TRUE(channel_->SetCapturer(last_ssrc_, &capturer));
2024 EXPECT_EQ(cricket::CS_RUNNING,
2025 capturer.Start(capturer.GetSupportedFormats()->front()));
2026 EXPECT_TRUE(capturer.CaptureFrame());
2027
2028 std::vector<webrtc::VideoStream> streams = stream->GetVideoStreams();
2029 EXPECT_EQ(kVp8Codec720p.width, streams[0].width);
2030 EXPECT_EQ(kVp8Codec720p.height, streams[0].height);
2031
2032 parameters.codecs.clear();
2033 parameters.codecs.push_back(kVp8Codec360p);
2034 ASSERT_TRUE(channel_->SetSendParameters(parameters));
2035 streams = fake_call_->GetVideoSendStreams()[0]->GetVideoStreams();
2036 EXPECT_EQ(kVp8Codec360p.width, streams[0].width);
2037 EXPECT_EQ(kVp8Codec360p.height, streams[0].height);
2038 EXPECT_TRUE(channel_->SetCapturer(last_ssrc_, NULL));
2039 }
2040
2041 TEST_F(WebRtcVideoChannel2Test, SetSendCodecsWithBitrates) {
2042 SetSendCodecsShouldWorkForBitrates("100", 100000, "150", 150000, "200",
2043 200000);
2044 }
2045
2046 TEST_F(WebRtcVideoChannel2Test, SetSendCodecsWithHighMaxBitrate) {
2047 SetSendCodecsShouldWorkForBitrates("", 0, "", -1, "10000", 10000000);
2048 std::vector<webrtc::VideoStream> streams = AddSendStream()->GetVideoStreams();
2049 ASSERT_EQ(1u, streams.size());
2050 EXPECT_EQ(10000000, streams[0].max_bitrate_bps);
2051 }
2052
2053 TEST_F(WebRtcVideoChannel2Test,
2054 SetSendCodecsWithoutBitratesUsesCorrectDefaults) {
2055 SetSendCodecsShouldWorkForBitrates(
2056 "", 0, "", -1, "", -1);
2057 }
2058
2059 TEST_F(WebRtcVideoChannel2Test, SetSendCodecsCapsMinAndStartBitrate) {
2060 SetSendCodecsShouldWorkForBitrates("-1", 0, "-100", -1, "", -1);
2061 }
2062
2063 TEST_F(WebRtcVideoChannel2Test, SetSendCodecsRejectsMaxLessThanMinBitrate) {
2064 send_parameters_.codecs[0].params[kCodecParamMinBitrate] = "300";
2065 send_parameters_.codecs[0].params[kCodecParamMaxBitrate] = "200";
2066 EXPECT_FALSE(channel_->SetSendParameters(send_parameters_));
2067 }
2068
2069 TEST_F(WebRtcVideoChannel2Test,
2070 SetMaxSendBandwidthShouldPreserveOtherBitrates) {
2071 SetSendCodecsShouldWorkForBitrates("100", 100000, "150", 150000, "200",
2072 200000);
2073 send_parameters_.max_bandwidth_bps = 300000;
2074 EXPECT_TRUE(channel_->SetSendParameters(send_parameters_));
2075 EXPECT_EQ(100000, fake_call_->GetConfig().bitrate_config.min_bitrate_bps)
2076 << "Setting max bitrate should keep previous min bitrate.";
2077 EXPECT_EQ(-1, fake_call_->GetConfig().bitrate_config.start_bitrate_bps)
2078 << "Setting max bitrate should not reset start bitrate.";
2079 EXPECT_EQ(300000, fake_call_->GetConfig().bitrate_config.max_bitrate_bps);
2080 }
2081
2082 TEST_F(WebRtcVideoChannel2Test, SetMaxSendBandwidthShouldBeRemovable) {
2083 send_parameters_.max_bandwidth_bps = 300000;
2084 EXPECT_TRUE(channel_->SetSendParameters(send_parameters_));
2085 EXPECT_EQ(300000, fake_call_->GetConfig().bitrate_config.max_bitrate_bps);
2086 // <= 0 means disable (infinite) max bitrate.
2087 send_parameters_.max_bandwidth_bps = 0;
2088 EXPECT_TRUE(channel_->SetSendParameters(send_parameters_));
2089 EXPECT_EQ(-1, fake_call_->GetConfig().bitrate_config.max_bitrate_bps)
2090 << "Setting zero max bitrate did not reset start bitrate.";
2091 }
2092
2093 TEST_F(WebRtcVideoChannel2Test, SetMaxSendBitrateCanIncreaseSenderBitrate) {
2094 cricket::VideoSendParameters parameters;
2095 parameters.codecs.push_back(kVp8Codec720p);
2096 ASSERT_TRUE(channel_->SetSendParameters(parameters));
2097 channel_->SetSend(true);
2098
2099 FakeVideoSendStream* stream = AddSendStream();
2100
2101 std::vector<webrtc::VideoStream> streams = stream->GetVideoStreams();
2102 int initial_max_bitrate_bps = streams[0].max_bitrate_bps;
2103 EXPECT_GT(initial_max_bitrate_bps, 0);
2104
2105 parameters.max_bandwidth_bps = initial_max_bitrate_bps * 2;
2106 EXPECT_TRUE(channel_->SetSendParameters(parameters));
2107 streams = stream->GetVideoStreams();
2108 EXPECT_EQ(initial_max_bitrate_bps * 2, streams[0].max_bitrate_bps);
2109 }
2110
2111 TEST_F(WebRtcVideoChannel2Test,
2112 SetMaxSendBitrateCanIncreaseSimulcastSenderBitrate) {
2113 cricket::VideoSendParameters parameters;
2114 parameters.codecs.push_back(kVp8Codec720p);
2115 ASSERT_TRUE(channel_->SetSendParameters(parameters));
2116 channel_->SetSend(true);
2117
2118 FakeVideoSendStream* stream = AddSendStream(
2119 cricket::CreateSimStreamParams("cname", MAKE_VECTOR(kSsrcs3)));
2120
2121 // Send a frame to make sure this scales up to >1 stream (simulcast).
2122 cricket::FakeVideoCapturer capturer;
2123 EXPECT_TRUE(channel_->SetCapturer(kSsrcs3[0], &capturer));
2124 EXPECT_EQ(cricket::CS_RUNNING,
2125 capturer.Start(capturer.GetSupportedFormats()->front()));
2126 EXPECT_TRUE(capturer.CaptureFrame());
2127
2128 std::vector<webrtc::VideoStream> streams = stream->GetVideoStreams();
2129 ASSERT_GT(streams.size(), 1u)
2130 << "Without simulcast this test doesn't make sense.";
2131 int initial_max_bitrate_bps = GetTotalMaxBitrateBps(streams);
2132 EXPECT_GT(initial_max_bitrate_bps, 0);
2133
2134 parameters.max_bandwidth_bps = initial_max_bitrate_bps * 2;
2135 EXPECT_TRUE(channel_->SetSendParameters(parameters));
2136 streams = stream->GetVideoStreams();
2137 int increased_max_bitrate_bps = GetTotalMaxBitrateBps(streams);
2138 EXPECT_EQ(initial_max_bitrate_bps * 2, increased_max_bitrate_bps);
2139
2140 EXPECT_TRUE(channel_->SetCapturer(kSsrcs3[0], nullptr));
2141 }
2142
2143 TEST_F(WebRtcVideoChannel2Test, SetSendCodecsWithMaxQuantization) {
2144 static const char* kMaxQuantization = "21";
2145 cricket::VideoSendParameters parameters;
2146 parameters.codecs.push_back(kVp8Codec);
2147 parameters.codecs[0].params[kCodecParamMaxQuantization] = kMaxQuantization;
2148 EXPECT_TRUE(channel_->SetSendParameters(parameters));
2149 EXPECT_EQ(static_cast<unsigned int>(atoi(kMaxQuantization)),
2150 AddSendStream()->GetVideoStreams().back().max_qp);
2151
2152 VideoCodec codec;
2153 EXPECT_TRUE(channel_->GetSendCodec(&codec));
2154 EXPECT_EQ(kMaxQuantization, codec.params[kCodecParamMaxQuantization]);
2155 }
2156
2157 TEST_F(WebRtcVideoChannel2Test, SetSendCodecsRejectBadDimensions) {
2158 cricket::VideoSendParameters parameters;
2159 parameters.codecs.push_back(kVp8Codec);
2160
2161 parameters.codecs[0].width = 0;
2162 EXPECT_FALSE(channel_->SetSendParameters(parameters))
2163 << "Codec set though codec width is zero.";
2164
2165 parameters.codecs[0].width = kVp8Codec.width;
2166 parameters.codecs[0].height = 0;
2167 EXPECT_FALSE(channel_->SetSendParameters(parameters))
2168 << "Codec set though codec height is zero.";
2169 }
2170
2171 TEST_F(WebRtcVideoChannel2Test, SetSendCodecsRejectBadPayloadTypes) {
2172 // TODO(pbos): Should we only allow the dynamic range?
2173 static const int kIncorrectPayloads[] = {-2, -1, 128, 129};
2174 cricket::VideoSendParameters parameters;
2175 parameters.codecs.push_back(kVp8Codec);
2176 for (size_t i = 0; i < arraysize(kIncorrectPayloads); ++i) {
2177 parameters.codecs[0].id = kIncorrectPayloads[i];
2178 EXPECT_FALSE(channel_->SetSendParameters(parameters))
2179 << "Bad payload type '" << kIncorrectPayloads[i] << "' accepted.";
2180 }
2181 }
2182
2183 TEST_F(WebRtcVideoChannel2Test, SetSendCodecsAcceptAllValidPayloadTypes) {
2184 cricket::VideoSendParameters parameters;
2185 parameters.codecs.push_back(kVp8Codec);
2186 for (int payload_type = 0; payload_type <= 127; ++payload_type) {
2187 parameters.codecs[0].id = payload_type;
2188 EXPECT_TRUE(channel_->SetSendParameters(parameters))
2189 << "Payload type '" << payload_type << "' rejected.";
2190 }
2191 }
2192
2193 TEST_F(WebRtcVideoChannel2Test, SetRecvCodecsWithOnlyVp8) {
2194 cricket::VideoRecvParameters parameters;
2195 parameters.codecs.push_back(kVp8Codec);
2196 EXPECT_TRUE(channel_->SetRecvParameters(parameters));
2197 }
2198
2199 // Test that we set our inbound RTX codecs properly.
2200 TEST_F(WebRtcVideoChannel2Test, SetRecvCodecsWithRtx) {
2201 cricket::VideoRecvParameters parameters;
2202 parameters.codecs.push_back(kVp8Codec);
2203 cricket::VideoCodec rtx_codec(96, "rtx", 0, 0, 0, 0);
2204 parameters.codecs.push_back(rtx_codec);
2205 EXPECT_FALSE(channel_->SetRecvParameters(parameters))
2206 << "RTX codec without associated payload should be rejected.";
2207
2208 parameters.codecs[1].SetParam("apt", kVp8Codec.id + 1);
2209 EXPECT_FALSE(channel_->SetRecvParameters(parameters))
2210 << "RTX codec with invalid associated payload type should be rejected.";
2211
2212 parameters.codecs[1].SetParam("apt", kVp8Codec.id);
2213 EXPECT_TRUE(channel_->SetRecvParameters(parameters));
2214
2215 cricket::VideoCodec rtx_codec2(97, "rtx", 0, 0, 0, 0);
2216 rtx_codec2.SetParam("apt", rtx_codec.id);
2217 parameters.codecs.push_back(rtx_codec2);
2218
2219 EXPECT_FALSE(channel_->SetRecvParameters(parameters)) <<
2220 "RTX codec with another RTX as associated payload type should be "
2221 "rejected.";
2222 }
2223
2224 TEST_F(WebRtcVideoChannel2Test, SetRecvCodecsDifferentPayloadType) {
2225 cricket::VideoRecvParameters parameters;
2226 parameters.codecs.push_back(kVp8Codec);
2227 parameters.codecs[0].id = 99;
2228 EXPECT_TRUE(channel_->SetRecvParameters(parameters));
2229 }
2230
2231 TEST_F(WebRtcVideoChannel2Test, SetRecvCodecsAcceptDefaultCodecs) {
2232 cricket::VideoRecvParameters parameters;
2233 parameters.codecs = engine_.codecs();
2234 EXPECT_TRUE(channel_->SetRecvParameters(parameters));
2235
2236 FakeVideoReceiveStream* stream = AddRecvStream();
2237 webrtc::VideoReceiveStream::Config config = stream->GetConfig();
2238 EXPECT_EQ(engine_.codecs()[0].name, config.decoders[0].payload_name);
2239 EXPECT_EQ(engine_.codecs()[0].id, config.decoders[0].payload_type);
2240 }
2241
2242 TEST_F(WebRtcVideoChannel2Test, SetRecvCodecsRejectUnsupportedCodec) {
2243 cricket::VideoRecvParameters parameters;
2244 parameters.codecs.push_back(kVp8Codec);
2245 parameters.codecs.push_back(VideoCodec(101, "WTF3", 640, 400, 30, 0));
2246 EXPECT_FALSE(channel_->SetRecvParameters(parameters));
2247 }
2248
2249 // TODO(pbos): Enable VP9 through external codec support
2250 TEST_F(WebRtcVideoChannel2Test,
2251 DISABLED_SetRecvCodecsAcceptsMultipleVideoCodecs) {
2252 cricket::VideoRecvParameters parameters;
2253 parameters.codecs.push_back(kVp8Codec);
2254 parameters.codecs.push_back(kVp9Codec);
2255 EXPECT_TRUE(channel_->SetRecvParameters(parameters));
2256 }
2257
2258 TEST_F(WebRtcVideoChannel2Test,
2259 DISABLED_SetRecvCodecsSetsFecForAllVideoCodecs) {
2260 cricket::VideoRecvParameters parameters;
2261 parameters.codecs.push_back(kVp8Codec);
2262 parameters.codecs.push_back(kVp9Codec);
2263 EXPECT_TRUE(channel_->SetRecvParameters(parameters));
2264 FAIL(); // TODO(pbos): Verify that the FEC parameters are set for all codecs.
2265 }
2266
2267 TEST_F(WebRtcVideoChannel2Test, SetRecvCodecsWithoutFecDisablesFec) {
2268 cricket::VideoSendParameters send_parameters;
2269 send_parameters.codecs.push_back(kVp8Codec);
2270 send_parameters.codecs.push_back(kUlpfecCodec);
2271 ASSERT_TRUE(channel_->SetSendParameters(send_parameters));
2272
2273 FakeVideoReceiveStream* stream = AddRecvStream();
2274 webrtc::VideoReceiveStream::Config config = stream->GetConfig();
2275
2276 EXPECT_EQ(kUlpfecCodec.id, config.rtp.fec.ulpfec_payload_type);
2277
2278 cricket::VideoRecvParameters recv_parameters;
2279 recv_parameters.codecs.push_back(kVp8Codec);
2280 ASSERT_TRUE(channel_->SetRecvParameters(recv_parameters));
2281 stream = fake_call_->GetVideoReceiveStreams()[0];
2282 ASSERT_TRUE(stream != NULL);
2283 config = stream->GetConfig();
2284 EXPECT_EQ(-1, config.rtp.fec.ulpfec_payload_type)
2285 << "SetSendCodec without FEC should disable current FEC.";
2286 }
2287
2288 TEST_F(WebRtcVideoChannel2Test, SetSendCodecsRejectDuplicateFecPayloads) {
2289 cricket::VideoRecvParameters parameters;
2290 parameters.codecs.push_back(kVp8Codec);
2291 parameters.codecs.push_back(kRedCodec);
2292 parameters.codecs[1].id = parameters.codecs[0].id;
2293 EXPECT_FALSE(channel_->SetRecvParameters(parameters));
2294 }
2295
2296 TEST_F(WebRtcVideoChannel2Test, SetRecvCodecsRejectDuplicateCodecPayloads) {
2297 cricket::VideoRecvParameters parameters;
2298 parameters.codecs.push_back(kVp8Codec);
2299 parameters.codecs.push_back(kVp9Codec);
2300 parameters.codecs[1].id = parameters.codecs[0].id;
2301 EXPECT_FALSE(channel_->SetRecvParameters(parameters));
2302 }
2303
2304 TEST_F(WebRtcVideoChannel2Test,
2305 SetRecvCodecsAcceptSameCodecOnMultiplePayloadTypes) {
2306 cricket::VideoRecvParameters parameters;
2307 parameters.codecs.push_back(kVp8Codec);
2308 parameters.codecs.push_back(kVp8Codec);
2309 parameters.codecs[1].id += 1;
2310 EXPECT_TRUE(channel_->SetRecvParameters(parameters));
2311 }
2312
2313 // Test that setting the same codecs but with a different order and preference
2314 // doesn't result in the stream being recreated.
2315 TEST_F(WebRtcVideoChannel2Test,
2316 SetRecvCodecsDifferentOrderAndPreferenceDoesntRecreateStream) {
2317 cricket::VideoRecvParameters parameters1;
2318 parameters1.codecs.push_back(kVp8Codec);
2319 parameters1.codecs.push_back(kRedCodec);
2320 EXPECT_TRUE(channel_->SetRecvParameters(parameters1));
2321
2322 AddRecvStream(cricket::StreamParams::CreateLegacy(123));
2323 EXPECT_EQ(1, fake_call_->GetNumCreatedReceiveStreams());
2324
2325 cricket::VideoRecvParameters parameters2;
2326 parameters2.codecs.push_back(kRedCodec);
2327 parameters2.codecs.push_back(kVp8Codec);
2328 parameters2.codecs[1].preference += 1;
2329 EXPECT_TRUE(channel_->SetRecvParameters(parameters2));
2330 EXPECT_EQ(1, fake_call_->GetNumCreatedReceiveStreams());
2331 }
2332
2333 TEST_F(WebRtcVideoChannel2Test, SendStreamNotSendingByDefault) {
2334 EXPECT_FALSE(AddSendStream()->IsSending());
2335 }
2336
2337 TEST_F(WebRtcVideoChannel2Test, ReceiveStreamReceivingByDefault) {
2338 EXPECT_TRUE(AddRecvStream()->IsReceiving());
2339 }
2340
2341 TEST_F(WebRtcVideoChannel2Test, SetSend) {
2342 FakeVideoSendStream* stream = AddSendStream();
2343 EXPECT_FALSE(stream->IsSending());
2344
2345 // false->true
2346 EXPECT_TRUE(channel_->SetSend(true));
2347 EXPECT_TRUE(stream->IsSending());
2348 // true->true
2349 EXPECT_TRUE(channel_->SetSend(true));
2350 EXPECT_TRUE(stream->IsSending());
2351 // true->false
2352 EXPECT_TRUE(channel_->SetSend(false));
2353 EXPECT_FALSE(stream->IsSending());
2354 // false->false
2355 EXPECT_TRUE(channel_->SetSend(false));
2356 EXPECT_FALSE(stream->IsSending());
2357
2358 EXPECT_TRUE(channel_->SetSend(true));
2359 FakeVideoSendStream* new_stream = AddSendStream();
2360 EXPECT_TRUE(new_stream->IsSending())
2361 << "Send stream created after SetSend(true) not sending initially.";
2362 }
2363
2364 // This test verifies DSCP settings are properly applied on video media channel.
2365 TEST_F(WebRtcVideoChannel2Test, TestSetDscpOptions) {
2366 rtc::scoped_ptr<cricket::FakeNetworkInterface> network_interface(
2367 new cricket::FakeNetworkInterface);
2368 channel_->SetInterface(network_interface.get());
2369 cricket::VideoSendParameters parameters = send_parameters_;
2370 EXPECT_TRUE(channel_->SetSendParameters(parameters));
2371 EXPECT_EQ(rtc::DSCP_NO_CHANGE, network_interface->dscp());
2372 parameters.options.dscp = rtc::Optional<bool>(true);
2373 EXPECT_TRUE(channel_->SetSendParameters(parameters));
2374 EXPECT_EQ(rtc::DSCP_AF41, network_interface->dscp());
2375 // Verify previous value is not modified if dscp option is not set.
2376 cricket::VideoSendParameters parameters1 = send_parameters_;
2377 EXPECT_TRUE(channel_->SetSendParameters(parameters1));
2378 EXPECT_EQ(rtc::DSCP_AF41, network_interface->dscp());
2379 parameters1.options.dscp = rtc::Optional<bool>(false);
2380 EXPECT_TRUE(channel_->SetSendParameters(parameters1));
2381 EXPECT_EQ(rtc::DSCP_DEFAULT, network_interface->dscp());
2382 channel_->SetInterface(NULL);
2383 }
2384
2385 // This test verifies that the RTCP reduced size mode is properly applied to
2386 // send video streams.
2387 TEST_F(WebRtcVideoChannel2Test, TestSetSendRtcpReducedSize) {
2388 // Create stream, expecting that default mode is "compound".
2389 FakeVideoSendStream* stream1 = AddSendStream();
2390 EXPECT_EQ(webrtc::RtcpMode::kCompound, stream1->GetConfig().rtp.rtcp_mode);
2391
2392 // Now enable reduced size mode.
2393 send_parameters_.rtcp.reduced_size = true;
2394 EXPECT_TRUE(channel_->SetSendParameters(send_parameters_));
2395 stream1 = fake_call_->GetVideoSendStreams()[0];
2396 EXPECT_EQ(webrtc::RtcpMode::kReducedSize, stream1->GetConfig().rtp.rtcp_mode);
2397
2398 // Create a new stream and ensure it picks up the reduced size mode.
2399 FakeVideoSendStream* stream2 = AddSendStream();
2400 EXPECT_EQ(webrtc::RtcpMode::kReducedSize, stream2->GetConfig().rtp.rtcp_mode);
2401 }
2402
2403 // This test verifies that the RTCP reduced size mode is properly applied to
2404 // receive video streams.
2405 TEST_F(WebRtcVideoChannel2Test, TestSetRecvRtcpReducedSize) {
2406 // Create stream, expecting that default mode is "compound".
2407 FakeVideoReceiveStream* stream1 = AddRecvStream();
2408 EXPECT_EQ(webrtc::RtcpMode::kCompound, stream1->GetConfig().rtp.rtcp_mode);
2409
2410 // Now enable reduced size mode.
2411 recv_parameters_.rtcp.reduced_size = true;
2412 EXPECT_TRUE(channel_->SetRecvParameters(recv_parameters_));
2413 stream1 = fake_call_->GetVideoReceiveStreams()[0];
2414 EXPECT_EQ(webrtc::RtcpMode::kReducedSize, stream1->GetConfig().rtp.rtcp_mode);
2415
2416 // Create a new stream and ensure it picks up the reduced size mode.
2417 FakeVideoReceiveStream* stream2 = AddRecvStream();
2418 EXPECT_EQ(webrtc::RtcpMode::kReducedSize, stream2->GetConfig().rtp.rtcp_mode);
2419 }
2420
2421 TEST_F(WebRtcVideoChannel2Test, OnReadyToSendSignalsNetworkState) {
2422 EXPECT_EQ(webrtc::kNetworkUp, fake_call_->GetNetworkState());
2423
2424 channel_->OnReadyToSend(false);
2425 EXPECT_EQ(webrtc::kNetworkDown, fake_call_->GetNetworkState());
2426
2427 channel_->OnReadyToSend(true);
2428 EXPECT_EQ(webrtc::kNetworkUp, fake_call_->GetNetworkState());
2429 }
2430
2431 TEST_F(WebRtcVideoChannel2Test, GetStatsReportsSentCodecName) {
2432 cricket::VideoSendParameters parameters;
2433 parameters.codecs.push_back(kVp8Codec);
2434 EXPECT_TRUE(channel_->SetSendParameters(parameters));
2435
2436 AddSendStream();
2437
2438 cricket::VideoMediaInfo info;
2439 ASSERT_TRUE(channel_->GetStats(&info));
2440 EXPECT_EQ(kVp8Codec.name, info.senders[0].codec_name);
2441 }
2442
2443 TEST_F(WebRtcVideoChannel2Test, GetStatsReportsEncoderImplementationName) {
2444 FakeVideoSendStream* stream = AddSendStream();
2445 webrtc::VideoSendStream::Stats stats;
2446 stats.encoder_implementation_name = "encoder_implementation_name";
2447 stream->SetStats(stats);
2448
2449 cricket::VideoMediaInfo info;
2450 ASSERT_TRUE(channel_->GetStats(&info));
2451 EXPECT_EQ(stats.encoder_implementation_name,
2452 info.senders[0].encoder_implementation_name);
2453 }
2454
2455 TEST_F(WebRtcVideoChannel2Test, GetStatsReportsCpuOveruseMetrics) {
2456 FakeVideoSendStream* stream = AddSendStream();
2457 webrtc::VideoSendStream::Stats stats;
2458 stats.avg_encode_time_ms = 13;
2459 stats.encode_usage_percent = 42;
2460 stream->SetStats(stats);
2461
2462 cricket::VideoMediaInfo info;
2463 ASSERT_TRUE(channel_->GetStats(&info));
2464 EXPECT_EQ(stats.avg_encode_time_ms, info.senders[0].avg_encode_ms);
2465 EXPECT_EQ(stats.encode_usage_percent, info.senders[0].encode_usage_percent);
2466 }
2467
2468 TEST_F(WebRtcVideoChannel2Test, GetStatsReportsUpperResolution) {
2469 FakeVideoSendStream* stream = AddSendStream();
2470 webrtc::VideoSendStream::Stats stats;
2471 stats.substreams[17].width = 123;
2472 stats.substreams[17].height = 40;
2473 stats.substreams[42].width = 80;
2474 stats.substreams[42].height = 31;
2475 stats.substreams[11].width = 20;
2476 stats.substreams[11].height = 90;
2477 stream->SetStats(stats);
2478
2479 cricket::VideoMediaInfo info;
2480 ASSERT_TRUE(channel_->GetStats(&info));
2481 ASSERT_EQ(1u, info.senders.size());
2482 EXPECT_EQ(123, info.senders[0].send_frame_width);
2483 EXPECT_EQ(90, info.senders[0].send_frame_height);
2484 }
2485
2486 TEST_F(WebRtcVideoChannel2Test, GetStatsTracksAdaptationStats) {
2487 AddSendStream(cricket::CreateSimStreamParams("cname", MAKE_VECTOR(kSsrcs3)));
2488
2489 // Capture format VGA.
2490 cricket::FakeVideoCapturer video_capturer_vga;
2491 const std::vector<cricket::VideoFormat>* formats =
2492 video_capturer_vga.GetSupportedFormats();
2493 cricket::VideoFormat capture_format_vga = (*formats)[1];
2494 EXPECT_EQ(cricket::CS_RUNNING, video_capturer_vga.Start(capture_format_vga));
2495 EXPECT_TRUE(channel_->SetCapturer(kSsrcs3[0], &video_capturer_vga));
2496 EXPECT_TRUE(video_capturer_vga.CaptureFrame());
2497
2498 cricket::VideoCodec send_codec(100, "VP8", 640, 480, 30, 0);
2499 cricket::VideoSendParameters parameters;
2500 parameters.codecs.push_back(send_codec);
2501 EXPECT_TRUE(channel_->SetSendParameters(parameters));
2502 EXPECT_TRUE(channel_->SetSend(true));
2503
2504 // Verify that the CpuOveruseObserver is registered and trigger downgrade.
2505 parameters.options.cpu_overuse_detection = rtc::Optional<bool>(true);
2506 EXPECT_TRUE(channel_->SetSendParameters(parameters));
2507
2508 // Trigger overuse.
2509 ASSERT_EQ(1u, fake_call_->GetVideoSendStreams().size());
2510 webrtc::LoadObserver* overuse_callback =
2511 fake_call_->GetVideoSendStreams().front()->GetConfig().overuse_callback;
2512 ASSERT_TRUE(overuse_callback != NULL);
2513 overuse_callback->OnLoadUpdate(webrtc::LoadObserver::kOveruse);
2514
2515 // Capture format VGA -> adapt (OnCpuResolutionRequest downgrade) -> VGA/2.
2516 EXPECT_TRUE(video_capturer_vga.CaptureFrame());
2517 cricket::VideoMediaInfo info;
2518 EXPECT_TRUE(channel_->GetStats(&info));
2519 ASSERT_EQ(1U, info.senders.size());
2520 EXPECT_EQ(1, info.senders[0].adapt_changes);
2521 EXPECT_EQ(CoordinatedVideoAdapter::ADAPTREASON_CPU,
2522 info.senders[0].adapt_reason);
2523
2524 // Trigger upgrade and verify that we adapt back up to VGA.
2525 overuse_callback->OnLoadUpdate(webrtc::LoadObserver::kUnderuse);
2526 EXPECT_TRUE(video_capturer_vga.CaptureFrame());
2527 info.Clear();
2528 EXPECT_TRUE(channel_->GetStats(&info));
2529 ASSERT_EQ(1U, info.senders.size());
2530 EXPECT_EQ(2, info.senders[0].adapt_changes);
2531 EXPECT_EQ(CoordinatedVideoAdapter::ADAPTREASON_NONE,
2532 info.senders[0].adapt_reason);
2533
2534 // No capturer (no adapter). Adapt changes from old adapter should be kept.
2535 EXPECT_TRUE(channel_->SetCapturer(kSsrcs3[0], NULL));
2536 info.Clear();
2537 EXPECT_TRUE(channel_->GetStats(&info));
2538 ASSERT_EQ(1U, info.senders.size());
2539 EXPECT_EQ(2, info.senders[0].adapt_changes);
2540 EXPECT_EQ(CoordinatedVideoAdapter::ADAPTREASON_NONE,
2541 info.senders[0].adapt_reason);
2542
2543 // Set new capturer, capture format HD.
2544 cricket::FakeVideoCapturer video_capturer_hd;
2545 cricket::VideoFormat capture_format_hd = (*formats)[0];
2546 EXPECT_EQ(cricket::CS_RUNNING, video_capturer_hd.Start(capture_format_hd));
2547 EXPECT_TRUE(channel_->SetCapturer(kSsrcs3[0], &video_capturer_hd));
2548 EXPECT_TRUE(video_capturer_hd.CaptureFrame());
2549
2550 // Trigger overuse, HD -> adapt (OnCpuResolutionRequest downgrade) -> HD/2.
2551 overuse_callback->OnLoadUpdate(webrtc::LoadObserver::kOveruse);
2552 EXPECT_TRUE(video_capturer_hd.CaptureFrame());
2553 info.Clear();
2554 EXPECT_TRUE(channel_->GetStats(&info));
2555 ASSERT_EQ(1U, info.senders.size());
2556 EXPECT_EQ(3, info.senders[0].adapt_changes);
2557 EXPECT_EQ(CoordinatedVideoAdapter::ADAPTREASON_CPU,
2558 info.senders[0].adapt_reason);
2559
2560 EXPECT_TRUE(channel_->SetCapturer(kSsrcs3[0], NULL));
2561 }
2562
2563 TEST_F(WebRtcVideoChannel2Test, GetStatsTracksAdaptationAndBandwidthStats) {
2564 AddSendStream(cricket::CreateSimStreamParams("cname", MAKE_VECTOR(kSsrcs3)));
2565
2566 // Capture format VGA.
2567 cricket::FakeVideoCapturer video_capturer_vga;
2568 const std::vector<cricket::VideoFormat>* formats =
2569 video_capturer_vga.GetSupportedFormats();
2570 cricket::VideoFormat capture_format_vga = (*formats)[1];
2571 EXPECT_EQ(cricket::CS_RUNNING, video_capturer_vga.Start(capture_format_vga));
2572 EXPECT_TRUE(channel_->SetCapturer(kSsrcs3[0], &video_capturer_vga));
2573 EXPECT_TRUE(video_capturer_vga.CaptureFrame());
2574
2575 cricket::VideoCodec send_codec(100, "VP8", 640, 480, 30, 0);
2576 cricket::VideoSendParameters parameters;
2577 parameters.codecs.push_back(send_codec);
2578 EXPECT_TRUE(channel_->SetSendParameters(parameters));
2579 EXPECT_TRUE(channel_->SetSend(true));
2580
2581 // Verify that the CpuOveruseObserver is registered and trigger downgrade.
2582 parameters.options.cpu_overuse_detection = rtc::Optional<bool>(true);
2583 EXPECT_TRUE(channel_->SetSendParameters(parameters));
2584
2585 // Trigger overuse -> adapt CPU.
2586 ASSERT_EQ(1u, fake_call_->GetVideoSendStreams().size());
2587 webrtc::LoadObserver* overuse_callback =
2588 fake_call_->GetVideoSendStreams().front()->GetConfig().overuse_callback;
2589 ASSERT_TRUE(overuse_callback != NULL);
2590 overuse_callback->OnLoadUpdate(webrtc::LoadObserver::kOveruse);
2591 EXPECT_TRUE(video_capturer_vga.CaptureFrame());
2592 cricket::VideoMediaInfo info;
2593 EXPECT_TRUE(channel_->GetStats(&info));
2594 ASSERT_EQ(1U, info.senders.size());
2595 EXPECT_EQ(CoordinatedVideoAdapter::ADAPTREASON_CPU,
2596 info.senders[0].adapt_reason);
2597
2598 // Set bandwidth limitation stats for the stream -> adapt CPU + BW.
2599 webrtc::VideoSendStream::Stats stats;
2600 stats.bw_limited_resolution = true;
2601 fake_call_->GetVideoSendStreams().front()->SetStats(stats);
2602 info.Clear();
2603 EXPECT_TRUE(channel_->GetStats(&info));
2604 ASSERT_EQ(1U, info.senders.size());
2605 EXPECT_EQ(CoordinatedVideoAdapter::ADAPTREASON_CPU +
2606 CoordinatedVideoAdapter::ADAPTREASON_BANDWIDTH,
2607 info.senders[0].adapt_reason);
2608
2609 // Trigger upgrade -> adapt BW.
2610 overuse_callback->OnLoadUpdate(webrtc::LoadObserver::kUnderuse);
2611 EXPECT_TRUE(video_capturer_vga.CaptureFrame());
2612 info.Clear();
2613 EXPECT_TRUE(channel_->GetStats(&info));
2614 ASSERT_EQ(1U, info.senders.size());
2615 EXPECT_EQ(CoordinatedVideoAdapter::ADAPTREASON_BANDWIDTH,
2616 info.senders[0].adapt_reason);
2617
2618 // Reset bandwidth limitation state -> adapt NONE.
2619 stats.bw_limited_resolution = false;
2620 fake_call_->GetVideoSendStreams().front()->SetStats(stats);
2621 info.Clear();
2622 EXPECT_TRUE(channel_->GetStats(&info));
2623 ASSERT_EQ(1U, info.senders.size());
2624 EXPECT_EQ(CoordinatedVideoAdapter::ADAPTREASON_NONE,
2625 info.senders[0].adapt_reason);
2626
2627 EXPECT_TRUE(channel_->SetCapturer(kSsrcs3[0], NULL));
2628 }
2629
2630 TEST_F(WebRtcVideoChannel2Test,
2631 GetStatsTranslatesBandwidthLimitedResolutionCorrectly) {
2632 FakeVideoSendStream* stream = AddSendStream();
2633 webrtc::VideoSendStream::Stats stats;
2634 stats.bw_limited_resolution = true;
2635 stream->SetStats(stats);
2636
2637 cricket::VideoMediaInfo info;
2638 EXPECT_TRUE(channel_->GetStats(&info));
2639 ASSERT_EQ(1U, info.senders.size());
2640 EXPECT_EQ(CoordinatedVideoAdapter::ADAPTREASON_BANDWIDTH,
2641 info.senders[0].adapt_reason);
2642 }
2643
2644 TEST_F(WebRtcVideoChannel2Test,
2645 GetStatsTranslatesSendRtcpPacketTypesCorrectly) {
2646 FakeVideoSendStream* stream = AddSendStream();
2647 webrtc::VideoSendStream::Stats stats;
2648 stats.substreams[17].rtcp_packet_type_counts.fir_packets = 2;
2649 stats.substreams[17].rtcp_packet_type_counts.nack_packets = 3;
2650 stats.substreams[17].rtcp_packet_type_counts.pli_packets = 4;
2651
2652 stats.substreams[42].rtcp_packet_type_counts.fir_packets = 5;
2653 stats.substreams[42].rtcp_packet_type_counts.nack_packets = 7;
2654 stats.substreams[42].rtcp_packet_type_counts.pli_packets = 9;
2655
2656 stream->SetStats(stats);
2657
2658 cricket::VideoMediaInfo info;
2659 ASSERT_TRUE(channel_->GetStats(&info));
2660 EXPECT_EQ(7, info.senders[0].firs_rcvd);
2661 EXPECT_EQ(10, info.senders[0].nacks_rcvd);
2662 EXPECT_EQ(13, info.senders[0].plis_rcvd);
2663 }
2664
2665 TEST_F(WebRtcVideoChannel2Test,
2666 GetStatsTranslatesReceiveRtcpPacketTypesCorrectly) {
2667 FakeVideoReceiveStream* stream = AddRecvStream();
2668 webrtc::VideoReceiveStream::Stats stats;
2669 stats.rtcp_packet_type_counts.fir_packets = 2;
2670 stats.rtcp_packet_type_counts.nack_packets = 3;
2671 stats.rtcp_packet_type_counts.pli_packets = 4;
2672 stream->SetStats(stats);
2673
2674 cricket::VideoMediaInfo info;
2675 ASSERT_TRUE(channel_->GetStats(&info));
2676 EXPECT_EQ(stats.rtcp_packet_type_counts.fir_packets,
2677 info.receivers[0].firs_sent);
2678 EXPECT_EQ(stats.rtcp_packet_type_counts.nack_packets,
2679 info.receivers[0].nacks_sent);
2680 EXPECT_EQ(stats.rtcp_packet_type_counts.pli_packets,
2681 info.receivers[0].plis_sent);
2682 }
2683
2684 TEST_F(WebRtcVideoChannel2Test, GetStatsTranslatesDecodeStatsCorrectly) {
2685 FakeVideoReceiveStream* stream = AddRecvStream();
2686 webrtc::VideoReceiveStream::Stats stats;
2687 stats.decoder_implementation_name = "decoder_implementation_name";
2688 stats.decode_ms = 2;
2689 stats.max_decode_ms = 3;
2690 stats.current_delay_ms = 4;
2691 stats.target_delay_ms = 5;
2692 stats.jitter_buffer_ms = 6;
2693 stats.min_playout_delay_ms = 7;
2694 stats.render_delay_ms = 8;
2695 stream->SetStats(stats);
2696
2697 cricket::VideoMediaInfo info;
2698 ASSERT_TRUE(channel_->GetStats(&info));
2699 EXPECT_EQ(stats.decoder_implementation_name,
2700 info.receivers[0].decoder_implementation_name);
2701 EXPECT_EQ(stats.decode_ms, info.receivers[0].decode_ms);
2702 EXPECT_EQ(stats.max_decode_ms, info.receivers[0].max_decode_ms);
2703 EXPECT_EQ(stats.current_delay_ms, info.receivers[0].current_delay_ms);
2704 EXPECT_EQ(stats.target_delay_ms, info.receivers[0].target_delay_ms);
2705 EXPECT_EQ(stats.jitter_buffer_ms, info.receivers[0].jitter_buffer_ms);
2706 EXPECT_EQ(stats.min_playout_delay_ms, info.receivers[0].min_playout_delay_ms);
2707 EXPECT_EQ(stats.render_delay_ms, info.receivers[0].render_delay_ms);
2708 }
2709
2710 TEST_F(WebRtcVideoChannel2Test, GetStatsTranslatesReceivePacketStatsCorrectly) {
2711 FakeVideoReceiveStream* stream = AddRecvStream();
2712 webrtc::VideoReceiveStream::Stats stats;
2713 stats.rtp_stats.transmitted.payload_bytes = 2;
2714 stats.rtp_stats.transmitted.header_bytes = 3;
2715 stats.rtp_stats.transmitted.padding_bytes = 4;
2716 stats.rtp_stats.transmitted.packets = 5;
2717 stats.rtcp_stats.cumulative_lost = 6;
2718 stats.rtcp_stats.fraction_lost = 7;
2719 stream->SetStats(stats);
2720
2721 cricket::VideoMediaInfo info;
2722 ASSERT_TRUE(channel_->GetStats(&info));
2723 EXPECT_EQ(stats.rtp_stats.transmitted.payload_bytes +
2724 stats.rtp_stats.transmitted.header_bytes +
2725 stats.rtp_stats.transmitted.padding_bytes,
2726 info.receivers[0].bytes_rcvd);
2727 EXPECT_EQ(stats.rtp_stats.transmitted.packets,
2728 info.receivers[0].packets_rcvd);
2729 EXPECT_EQ(stats.rtcp_stats.cumulative_lost, info.receivers[0].packets_lost);
2730 EXPECT_EQ(static_cast<float>(stats.rtcp_stats.fraction_lost) / (1 << 8),
2731 info.receivers[0].fraction_lost);
2732 }
2733
2734 TEST_F(WebRtcVideoChannel2Test, TranslatesCallStatsCorrectly) {
2735 AddSendStream();
2736 AddSendStream();
2737 webrtc::Call::Stats stats;
2738 stats.rtt_ms = 123;
2739 fake_call_->SetStats(stats);
2740
2741 cricket::VideoMediaInfo info;
2742 ASSERT_TRUE(channel_->GetStats(&info));
2743 ASSERT_EQ(2u, info.senders.size());
2744 EXPECT_EQ(stats.rtt_ms, info.senders[0].rtt_ms);
2745 EXPECT_EQ(stats.rtt_ms, info.senders[1].rtt_ms);
2746 }
2747
2748 TEST_F(WebRtcVideoChannel2Test, TranslatesSenderBitrateStatsCorrectly) {
2749 FakeVideoSendStream* stream = AddSendStream();
2750 webrtc::VideoSendStream::Stats stats;
2751 stats.target_media_bitrate_bps = 156;
2752 stats.media_bitrate_bps = 123;
2753 stats.substreams[17].total_bitrate_bps = 1;
2754 stats.substreams[17].retransmit_bitrate_bps = 2;
2755 stats.substreams[42].total_bitrate_bps = 3;
2756 stats.substreams[42].retransmit_bitrate_bps = 4;
2757 stream->SetStats(stats);
2758
2759 FakeVideoSendStream* stream2 = AddSendStream();
2760 webrtc::VideoSendStream::Stats stats2;
2761 stats2.target_media_bitrate_bps = 200;
2762 stats2.media_bitrate_bps = 321;
2763 stats2.substreams[13].total_bitrate_bps = 5;
2764 stats2.substreams[13].retransmit_bitrate_bps = 6;
2765 stats2.substreams[21].total_bitrate_bps = 7;
2766 stats2.substreams[21].retransmit_bitrate_bps = 8;
2767 stream2->SetStats(stats2);
2768
2769 cricket::VideoMediaInfo info;
2770 ASSERT_TRUE(channel_->GetStats(&info));
2771 ASSERT_EQ(2u, info.senders.size());
2772 // Assuming stream and stream2 corresponds to senders[0] and [1] respectively
2773 // is OK as std::maps are sorted and AddSendStream() gives increasing SSRCs.
2774 EXPECT_EQ(stats.media_bitrate_bps, info.senders[0].nominal_bitrate);
2775 EXPECT_EQ(stats2.media_bitrate_bps, info.senders[1].nominal_bitrate);
2776 EXPECT_EQ(stats.target_media_bitrate_bps + stats2.target_media_bitrate_bps,
2777 info.bw_estimations[0].target_enc_bitrate);
2778 EXPECT_EQ(stats.media_bitrate_bps + stats2.media_bitrate_bps,
2779 info.bw_estimations[0].actual_enc_bitrate);
2780 EXPECT_EQ(1 + 3 + 5 + 7, info.bw_estimations[0].transmit_bitrate)
2781 << "Bandwidth stats should take all streams into account.";
2782 EXPECT_EQ(2 + 4 + 6 + 8, info.bw_estimations[0].retransmit_bitrate)
2783 << "Bandwidth stats should take all streams into account.";
2784 }
2785
2786 TEST_F(WebRtcVideoChannel2Test, DefaultReceiveStreamReconfiguresToUseRtx) {
2787 EXPECT_TRUE(channel_->SetSendParameters(send_parameters_));
2788
2789 const std::vector<uint32_t> ssrcs = MAKE_VECTOR(kSsrcs1);
2790 const std::vector<uint32_t> rtx_ssrcs = MAKE_VECTOR(kRtxSsrcs1);
2791
2792 ASSERT_EQ(0u, fake_call_->GetVideoReceiveStreams().size());
2793 const size_t kDataLength = 12;
2794 uint8_t data[kDataLength];
2795 memset(data, 0, sizeof(data));
2796 rtc::SetBE32(&data[8], ssrcs[0]);
2797 rtc::Buffer packet(data, kDataLength);
2798 rtc::PacketTime packet_time;
2799 channel_->OnPacketReceived(&packet, packet_time);
2800
2801 ASSERT_EQ(1u, fake_call_->GetVideoReceiveStreams().size())
2802 << "No default receive stream created.";
2803 FakeVideoReceiveStream* recv_stream = fake_call_->GetVideoReceiveStreams()[0];
2804 EXPECT_EQ(0u, recv_stream->GetConfig().rtp.rtx.size())
2805 << "Default receive stream should not have configured RTX";
2806
2807 EXPECT_TRUE(channel_->AddRecvStream(
2808 cricket::CreateSimWithRtxStreamParams("cname", ssrcs, rtx_ssrcs)));
2809 ASSERT_EQ(1u, fake_call_->GetVideoReceiveStreams().size())
2810 << "AddRecvStream should've reconfigured, not added a new receiver.";
2811 recv_stream = fake_call_->GetVideoReceiveStreams()[0];
2812 ASSERT_EQ(1u, recv_stream->GetConfig().rtp.rtx.size());
2813 EXPECT_EQ(rtx_ssrcs[0],
2814 recv_stream->GetConfig().rtp.rtx.begin()->second.ssrc);
2815 }
2816
2817 TEST_F(WebRtcVideoChannel2Test, RejectsAddingStreamsWithMissingSsrcsForRtx) {
2818 EXPECT_TRUE(channel_->SetSendParameters(send_parameters_));
2819
2820 const std::vector<uint32_t> ssrcs = MAKE_VECTOR(kSsrcs1);
2821 const std::vector<uint32_t> rtx_ssrcs = MAKE_VECTOR(kRtxSsrcs1);
2822
2823 StreamParams sp =
2824 cricket::CreateSimWithRtxStreamParams("cname", ssrcs, rtx_ssrcs);
2825 sp.ssrcs = ssrcs; // Without RTXs, this is the important part.
2826
2827 EXPECT_FALSE(channel_->AddSendStream(sp));
2828 EXPECT_FALSE(channel_->AddRecvStream(sp));
2829 }
2830
2831 TEST_F(WebRtcVideoChannel2Test, RejectsAddingStreamsWithOverlappingRtxSsrcs) {
2832 EXPECT_TRUE(channel_->SetSendParameters(send_parameters_));
2833
2834 const std::vector<uint32_t> ssrcs = MAKE_VECTOR(kSsrcs1);
2835 const std::vector<uint32_t> rtx_ssrcs = MAKE_VECTOR(kRtxSsrcs1);
2836
2837 StreamParams sp =
2838 cricket::CreateSimWithRtxStreamParams("cname", ssrcs, rtx_ssrcs);
2839
2840 EXPECT_TRUE(channel_->AddSendStream(sp));
2841 EXPECT_TRUE(channel_->AddRecvStream(sp));
2842
2843 // The RTX SSRC is already used in previous streams, using it should fail.
2844 sp = cricket::StreamParams::CreateLegacy(rtx_ssrcs[0]);
2845 EXPECT_FALSE(channel_->AddSendStream(sp));
2846 EXPECT_FALSE(channel_->AddRecvStream(sp));
2847
2848 // After removing the original stream this should be fine to add (makes sure
2849 // that RTX ssrcs are not forever taken).
2850 EXPECT_TRUE(channel_->RemoveSendStream(ssrcs[0]));
2851 EXPECT_TRUE(channel_->RemoveRecvStream(ssrcs[0]));
2852 EXPECT_TRUE(channel_->AddSendStream(sp));
2853 EXPECT_TRUE(channel_->AddRecvStream(sp));
2854 }
2855
2856 TEST_F(WebRtcVideoChannel2Test,
2857 RejectsAddingStreamsWithOverlappingSimulcastSsrcs) {
2858 static const uint32_t kFirstStreamSsrcs[] = {1, 2, 3};
2859 static const uint32_t kOverlappingStreamSsrcs[] = {4, 3, 5};
2860 EXPECT_TRUE(channel_->SetSendParameters(send_parameters_));
2861
2862 StreamParams sp =
2863 cricket::CreateSimStreamParams("cname", MAKE_VECTOR(kFirstStreamSsrcs));
2864
2865 EXPECT_TRUE(channel_->AddSendStream(sp));
2866 EXPECT_TRUE(channel_->AddRecvStream(sp));
2867
2868 // One of the SSRCs is already used in previous streams, using it should fail.
2869 sp = cricket::CreateSimStreamParams("cname",
2870 MAKE_VECTOR(kOverlappingStreamSsrcs));
2871 EXPECT_FALSE(channel_->AddSendStream(sp));
2872 EXPECT_FALSE(channel_->AddRecvStream(sp));
2873
2874 // After removing the original stream this should be fine to add (makes sure
2875 // that RTX ssrcs are not forever taken).
2876 EXPECT_TRUE(channel_->RemoveSendStream(kFirstStreamSsrcs[0]));
2877 EXPECT_TRUE(channel_->RemoveRecvStream(kFirstStreamSsrcs[0]));
2878 EXPECT_TRUE(channel_->AddSendStream(sp));
2879 EXPECT_TRUE(channel_->AddRecvStream(sp));
2880 }
2881
2882 TEST_F(WebRtcVideoChannel2Test, ReportsSsrcGroupsInStats) {
2883 EXPECT_TRUE(channel_->SetSendParameters(send_parameters_));
2884
2885 static const uint32_t kSenderSsrcs[] = {4, 7, 10};
2886 static const uint32_t kSenderRtxSsrcs[] = {5, 8, 11};
2887
2888 StreamParams sender_sp = cricket::CreateSimWithRtxStreamParams(
2889 "cname", MAKE_VECTOR(kSenderSsrcs), MAKE_VECTOR(kSenderRtxSsrcs));
2890
2891 EXPECT_TRUE(channel_->AddSendStream(sender_sp));
2892
2893 static const uint32_t kReceiverSsrcs[] = {3};
2894 static const uint32_t kReceiverRtxSsrcs[] = {2};
2895
2896 StreamParams receiver_sp = cricket::CreateSimWithRtxStreamParams(
2897 "cname", MAKE_VECTOR(kReceiverSsrcs), MAKE_VECTOR(kReceiverRtxSsrcs));
2898 EXPECT_TRUE(channel_->AddRecvStream(receiver_sp));
2899
2900 cricket::VideoMediaInfo info;
2901 ASSERT_TRUE(channel_->GetStats(&info));
2902
2903 ASSERT_EQ(1u, info.senders.size());
2904 ASSERT_EQ(1u, info.receivers.size());
2905
2906 EXPECT_NE(sender_sp.ssrc_groups, receiver_sp.ssrc_groups);
2907 EXPECT_EQ(sender_sp.ssrc_groups, info.senders[0].ssrc_groups);
2908 EXPECT_EQ(receiver_sp.ssrc_groups, info.receivers[0].ssrc_groups);
2909 }
2910
2911 TEST_F(WebRtcVideoChannel2Test, MapsReceivedPayloadTypeToCodecName) {
2912 FakeVideoReceiveStream* stream = AddRecvStream();
2913 webrtc::VideoReceiveStream::Stats stats;
2914 cricket::VideoMediaInfo info;
2915
2916 // Report no codec name before receiving.
2917 stream->SetStats(stats);
2918 ASSERT_TRUE(channel_->GetStats(&info));
2919 EXPECT_STREQ("", info.receivers[0].codec_name.c_str());
2920
2921 // Report VP8 if we're receiving it.
2922 stats.current_payload_type = kDefaultVp8PlType;
2923 stream->SetStats(stats);
2924 ASSERT_TRUE(channel_->GetStats(&info));
2925 EXPECT_STREQ(kVp8CodecName, info.receivers[0].codec_name.c_str());
2926
2927 // Report no codec name for unknown playload types.
2928 stats.current_payload_type = 3;
2929 stream->SetStats(stats);
2930 ASSERT_TRUE(channel_->GetStats(&info));
2931 EXPECT_STREQ("", info.receivers[0].codec_name.c_str());
2932 }
2933
2934 void WebRtcVideoChannel2Test::TestReceiveUnsignalledSsrcPacket(
2935 uint8_t payload_type,
2936 bool expect_created_receive_stream) {
2937 // Add a RED RTX codec.
2938 VideoCodec red_rtx_codec =
2939 VideoCodec::CreateRtxCodec(kRedRtxPayloadType, kDefaultRedPlType);
2940 recv_parameters_.codecs.push_back(red_rtx_codec);
2941 EXPECT_TRUE(channel_->SetRecvParameters(recv_parameters_));
2942
2943 ASSERT_EQ(0u, fake_call_->GetVideoReceiveStreams().size());
2944 const size_t kDataLength = 12;
2945 uint8_t data[kDataLength];
2946 memset(data, 0, sizeof(data));
2947
2948 rtc::Set8(data, 1, payload_type);
2949 rtc::SetBE32(&data[8], kIncomingUnsignalledSsrc);
2950 rtc::Buffer packet(data, kDataLength);
2951 rtc::PacketTime packet_time;
2952 channel_->OnPacketReceived(&packet, packet_time);
2953
2954 if (expect_created_receive_stream) {
2955 EXPECT_EQ(1u, fake_call_->GetVideoReceiveStreams().size())
2956 << "Should have created a receive stream for payload type: "
2957 << payload_type;
2958 } else {
2959 EXPECT_EQ(0u, fake_call_->GetVideoReceiveStreams().size())
2960 << "Shouldn't have created a receive stream for payload type: "
2961 << payload_type;
2962 }
2963 }
2964
2965 TEST_F(WebRtcVideoChannel2Test, Vp8PacketCreatesUnsignalledStream) {
2966 TestReceiveUnsignalledSsrcPacket(kDefaultVp8PlType, true);
2967 }
2968
2969 TEST_F(WebRtcVideoChannel2Test, Vp9PacketCreatesUnsignalledStream) {
2970 TestReceiveUnsignalledSsrcPacket(kDefaultVp9PlType, true);
2971 }
2972
2973 TEST_F(WebRtcVideoChannel2Test, RtxPacketDoesntCreateUnsignalledStream) {
2974 TestReceiveUnsignalledSsrcPacket(kDefaultRtxVp8PlType, false);
2975 }
2976
2977 TEST_F(WebRtcVideoChannel2Test, UlpfecPacketDoesntCreateUnsignalledStream) {
2978 TestReceiveUnsignalledSsrcPacket(kDefaultUlpfecType, false);
2979 }
2980
2981 TEST_F(WebRtcVideoChannel2Test, RedRtxPacketDoesntCreateUnsignalledStream) {
2982 TestReceiveUnsignalledSsrcPacket(kRedRtxPayloadType, false);
2983 }
2984
2985 void WebRtcVideoChannel2Test::TestReceiverLocalSsrcConfiguration(
2986 bool receiver_first) {
2987 EXPECT_TRUE(channel_->SetSendParameters(send_parameters_));
2988
2989 const uint32_t kSenderSsrc = 0xC0FFEE;
2990 const uint32_t kSecondSenderSsrc = 0xBADCAFE;
2991 const uint32_t kReceiverSsrc = 0x4711;
2992 const uint32_t kExpectedDefaultReceiverSsrc = 1;
2993
2994 if (receiver_first) {
2995 AddRecvStream(StreamParams::CreateLegacy(kReceiverSsrc));
2996 std::vector<FakeVideoReceiveStream*> receive_streams =
2997 fake_call_->GetVideoReceiveStreams();
2998 ASSERT_EQ(1u, receive_streams.size());
2999 // Default local SSRC when we have no sender.
3000 EXPECT_EQ(kExpectedDefaultReceiverSsrc,
3001 receive_streams[0]->GetConfig().rtp.local_ssrc);
3002 }
3003 AddSendStream(StreamParams::CreateLegacy(kSenderSsrc));
3004 if (!receiver_first)
3005 AddRecvStream(StreamParams::CreateLegacy(kReceiverSsrc));
3006 std::vector<FakeVideoReceiveStream*> receive_streams =
3007 fake_call_->GetVideoReceiveStreams();
3008 ASSERT_EQ(1u, receive_streams.size());
3009 EXPECT_EQ(kSenderSsrc, receive_streams[0]->GetConfig().rtp.local_ssrc);
3010
3011 // Removing first sender should fall back to another (in this case the second)
3012 // local send stream's SSRC.
3013 AddSendStream(StreamParams::CreateLegacy(kSecondSenderSsrc));
3014 ASSERT_TRUE(channel_->RemoveSendStream(kSenderSsrc));
3015 receive_streams =
3016 fake_call_->GetVideoReceiveStreams();
3017 ASSERT_EQ(1u, receive_streams.size());
3018 EXPECT_EQ(kSecondSenderSsrc, receive_streams[0]->GetConfig().rtp.local_ssrc);
3019
3020 // Removing the last sender should fall back to default local SSRC.
3021 ASSERT_TRUE(channel_->RemoveSendStream(kSecondSenderSsrc));
3022 receive_streams =
3023 fake_call_->GetVideoReceiveStreams();
3024 ASSERT_EQ(1u, receive_streams.size());
3025 EXPECT_EQ(kExpectedDefaultReceiverSsrc,
3026 receive_streams[0]->GetConfig().rtp.local_ssrc);
3027 }
3028
3029 TEST_F(WebRtcVideoChannel2Test, ConfiguresLocalSsrc) {
3030 TestReceiverLocalSsrcConfiguration(false);
3031 }
3032
3033 TEST_F(WebRtcVideoChannel2Test, ConfiguresLocalSsrcOnExistingReceivers) {
3034 TestReceiverLocalSsrcConfiguration(true);
3035 }
3036
3037 class WebRtcVideoEngine2SimulcastTest : public testing::Test {};
3038
3039 // Test that if we add a stream with RTX SSRC's, SSRC's get set correctly.
3040 TEST_F(WebRtcVideoEngine2SimulcastTest, DISABLED_TestStreamWithRtx) {
3041 // TODO(pbos): Implement.
3042 FAIL() << "Not implemented.";
3043 }
3044
3045 // Test that if we get too few ssrcs are given in AddSendStream(),
3046 // only supported sub-streams will be added.
3047 TEST_F(WebRtcVideoEngine2SimulcastTest, DISABLED_TooFewSimulcastSsrcs) {
3048 // TODO(pbos): Implement.
3049 FAIL() << "Not implemented.";
3050 }
3051
3052 // Test that even more than enough ssrcs are given in AddSendStream(),
3053 // only supported sub-streams will be added.
3054 TEST_F(WebRtcVideoEngine2SimulcastTest, DISABLED_MoreThanEnoughSimulcastSscrs) {
3055 // TODO(pbos): Implement.
3056 FAIL() << "Not implemented.";
3057 }
3058
3059 // Test that SetSendStreamFormat works well with simulcast.
3060 TEST_F(WebRtcVideoEngine2SimulcastTest,
3061 DISABLED_SetSendStreamFormatWithSimulcast) {
3062 // TODO(pbos): Implement.
3063 FAIL() << "Not implemented.";
3064 }
3065
3066 // Test that simulcast send codec is reset on new video frame size.
3067 TEST_F(WebRtcVideoEngine2SimulcastTest,
3068 DISABLED_ResetSimulcastSendCodecOnNewFrameSize) {
3069 // TODO(pbos): Implement.
3070 FAIL() << "Not implemented.";
3071 }
3072
3073 // Test that simulcast send codec is reset on new portait mode video frame.
3074 TEST_F(WebRtcVideoEngine2SimulcastTest,
3075 DISABLED_ResetSimulcastSendCodecOnNewPortaitFrame) {
3076 // TODO(pbos): Implement.
3077 FAIL() << "Not implemented.";
3078 }
3079
3080 TEST_F(WebRtcVideoEngine2SimulcastTest,
3081 DISABLED_SetBandwidthInConferenceWithSimulcast) {
3082 // TODO(pbos): Implement.
3083 FAIL() << "Not implemented.";
3084 }
3085
3086 // Test that sending screencast frames in conference mode changes
3087 // bitrate.
3088 TEST_F(WebRtcVideoEngine2SimulcastTest,
3089 DISABLED_SetBandwidthScreencastInConference) {
3090 // TODO(pbos): Implement.
3091 FAIL() << "Not implemented.";
3092 }
3093
3094 // Test AddSendStream with simulcast rejects bad StreamParams.
3095 TEST_F(WebRtcVideoEngine2SimulcastTest,
3096 DISABLED_AddSendStreamWithBadStreamParams) {
3097 // TODO(pbos): Implement.
3098 FAIL() << "Not implemented.";
3099 }
3100
3101 // Test AddSendStream with simulcast sets ssrc and cname correctly.
3102 TEST_F(WebRtcVideoEngine2SimulcastTest, DISABLED_AddSendStreamWithSimulcast) {
3103 // TODO(pbos): Implement.
3104 FAIL() << "Not implemented.";
3105 }
3106
3107 // Test RemoveSendStream with simulcast.
3108 TEST_F(WebRtcVideoEngine2SimulcastTest,
3109 DISABLED_RemoveSendStreamWithSimulcast) {
3110 // TODO(pbos): Implement.
3111 FAIL() << "Not implemented.";
3112 }
3113
3114 // Test AddSendStream after send codec has already been set will reset
3115 // send codec with simulcast settings.
3116 TEST_F(WebRtcVideoEngine2SimulcastTest,
3117 DISABLED_AddSimulcastStreamAfterSetSendCodec) {
3118 // TODO(pbos): Implement.
3119 FAIL() << "Not implemented.";
3120 }
3121
3122 TEST_F(WebRtcVideoEngine2SimulcastTest, DISABLED_GetStatsWithMultipleSsrcs) {
3123 // TODO(pbos): Implement.
3124 FAIL() << "Not implemented.";
3125 }
3126
3127 // Test receiving channel(s) local ssrc is set to the same as the first
3128 // simulcast sending ssrc.
3129 TEST_F(WebRtcVideoEngine2SimulcastTest,
3130 DISABLED_AddSimulcastStreamAfterCreatingRecvChannels) {
3131 // TODO(pbos): Implement.
3132 FAIL() << "Not implemented.";
3133 }
3134
3135 // Test 1:1 call never turn on simulcast.
3136 TEST_F(WebRtcVideoEngine2SimulcastTest, DISABLED_NoSimulcastWith1on1) {
3137 // TODO(pbos): Implement.
3138 FAIL() << "Not implemented.";
3139 }
3140
3141 // Test SetOptions with OPT_CONFERENCE flag.
3142 TEST_F(WebRtcVideoEngine2SimulcastTest, DISABLED_SetOptionsWithConferenceMode) {
3143 // TODO(pbos): Implement.
3144 FAIL() << "Not implemented.";
3145 }
3146
3147 // Test that two different streams can have different formats.
3148 TEST_F(WebRtcVideoEngine2SimulcastTest,
3149 DISABLED_MultipleSendStreamsDifferentFormats) {
3150 // TODO(pbos): Implement.
3151 FAIL() << "Not implemented.";
3152 }
3153
3154 TEST_F(WebRtcVideoEngine2SimulcastTest, DISABLED_TestAdaptToOutputFormat) {
3155 // TODO(pbos): Implement.
3156 FAIL() << "Not implemented.";
3157 }
3158
3159 TEST_F(WebRtcVideoEngine2SimulcastTest,
3160 DISABLED_TestAdaptWithCpuOveruseObserver) {
3161 // TODO(pbos): Implement.
3162 FAIL() << "Not implemented.";
3163 }
3164
3165 // Test that codec is not reset for every frame sent in non-conference and
3166 // non-screencast mode.
3167 TEST_F(WebRtcVideoEngine2SimulcastTest, DISABLED_DontResetCodecOnSendFrame) {
3168 // TODO(pbos): Implement.
3169 FAIL() << "Not implemented.";
3170 }
3171
3172 TEST_F(WebRtcVideoEngine2SimulcastTest,
3173 DISABLED_UseSimulcastAdapterOnVp8OnlyFactory) {
3174 // TODO(pbos): Implement.
3175 FAIL() << "Not implemented.";
3176 }
3177
3178 TEST_F(WebRtcVideoEngine2SimulcastTest,
3179 DISABLED_DontUseSimulcastAdapterOnNonVp8Factory) {
3180 // TODO(pbos): Implement.
3181 FAIL() << "Not implemented.";
3182 }
3183
3184 class WebRtcVideoChannel2SimulcastTest : public testing::Test {
3185 public:
3186 WebRtcVideoChannel2SimulcastTest() : fake_call_(webrtc::Call::Config()) {}
3187
3188 void SetUp() override {
3189 engine_.Init();
3190 channel_.reset(engine_.CreateChannel(&fake_call_, VideoOptions()));
3191 last_ssrc_ = 123;
3192 }
3193
3194 protected:
3195 void VerifySimulcastSettings(const VideoCodec& codec,
3196 size_t num_configured_streams,
3197 size_t expected_num_streams) {
3198 cricket::VideoSendParameters parameters;
3199 parameters.codecs.push_back(codec);
3200 ASSERT_TRUE(channel_->SetSendParameters(parameters));
3201
3202 std::vector<uint32_t> ssrcs = MAKE_VECTOR(kSsrcs3);
3203 RTC_DCHECK(num_configured_streams <= ssrcs.size());
3204 ssrcs.resize(num_configured_streams);
3205
3206 FakeVideoSendStream* stream =
3207 AddSendStream(CreateSimStreamParams("cname", ssrcs));
3208 // Send a full-size frame to trigger a stream reconfiguration to use all
3209 // expected simulcast layers.
3210 cricket::FakeVideoCapturer capturer;
3211 EXPECT_TRUE(channel_->SetCapturer(ssrcs.front(), &capturer));
3212 EXPECT_EQ(cricket::CS_RUNNING, capturer.Start(cricket::VideoFormat(
3213 codec.width, codec.height,
3214 cricket::VideoFormat::FpsToInterval(30),
3215 cricket::FOURCC_I420)));
3216 channel_->SetSend(true);
3217 EXPECT_TRUE(capturer.CaptureFrame());
3218
3219 std::vector<webrtc::VideoStream> video_streams = stream->GetVideoStreams();
3220 ASSERT_EQ(expected_num_streams, video_streams.size());
3221
3222 std::vector<webrtc::VideoStream> expected_streams = GetSimulcastConfig(
3223 num_configured_streams, codec.width, codec.height, 0, kDefaultQpMax,
3224 codec.framerate != 0 ? codec.framerate : kDefaultFramerate);
3225
3226 ASSERT_EQ(expected_streams.size(), video_streams.size());
3227
3228 size_t num_streams = video_streams.size();
3229 int total_max_bitrate_bps = 0;
3230 for (size_t i = 0; i < num_streams; ++i) {
3231 EXPECT_EQ(expected_streams[i].width, video_streams[i].width);
3232 EXPECT_EQ(expected_streams[i].height, video_streams[i].height);
3233
3234 EXPECT_GT(video_streams[i].max_framerate, 0);
3235 EXPECT_EQ(expected_streams[i].max_framerate,
3236 video_streams[i].max_framerate);
3237
3238 EXPECT_GT(video_streams[i].min_bitrate_bps, 0);
3239 EXPECT_EQ(expected_streams[i].min_bitrate_bps,
3240 video_streams[i].min_bitrate_bps);
3241
3242 EXPECT_GT(video_streams[i].target_bitrate_bps, 0);
3243 EXPECT_EQ(expected_streams[i].target_bitrate_bps,
3244 video_streams[i].target_bitrate_bps);
3245
3246 EXPECT_GT(video_streams[i].max_bitrate_bps, 0);
3247 EXPECT_EQ(expected_streams[i].max_bitrate_bps,
3248 video_streams[i].max_bitrate_bps);
3249
3250 EXPECT_GT(video_streams[i].max_qp, 0);
3251 EXPECT_EQ(expected_streams[i].max_qp, video_streams[i].max_qp);
3252
3253 EXPECT_FALSE(expected_streams[i].temporal_layer_thresholds_bps.empty());
3254 EXPECT_EQ(expected_streams[i].temporal_layer_thresholds_bps,
3255 video_streams[i].temporal_layer_thresholds_bps);
3256
3257 if (i == num_streams - 1) {
3258 total_max_bitrate_bps += video_streams[i].max_bitrate_bps;
3259 } else {
3260 total_max_bitrate_bps += video_streams[i].target_bitrate_bps;
3261 }
3262 }
3263 cricket::VideoMediaInfo info;
3264 ASSERT_TRUE(channel_->GetStats(&info));
3265 ASSERT_EQ(1u, info.senders.size());
3266 EXPECT_EQ(total_max_bitrate_bps, info.senders[0].preferred_bitrate);
3267
3268 EXPECT_TRUE(channel_->SetCapturer(ssrcs.front(), NULL));
3269 }
3270
3271 FakeVideoSendStream* AddSendStream() {
3272 return AddSendStream(StreamParams::CreateLegacy(last_ssrc_++));
3273 }
3274
3275 FakeVideoSendStream* AddSendStream(const StreamParams& sp) {
3276 size_t num_streams =
3277 fake_call_.GetVideoSendStreams().size();
3278 EXPECT_TRUE(channel_->AddSendStream(sp));
3279 std::vector<FakeVideoSendStream*> streams =
3280 fake_call_.GetVideoSendStreams();
3281 EXPECT_EQ(num_streams + 1, streams.size());
3282 return streams[streams.size() - 1];
3283 }
3284
3285 std::vector<FakeVideoSendStream*> GetFakeSendStreams() {
3286 return fake_call_.GetVideoSendStreams();
3287 }
3288
3289 FakeVideoReceiveStream* AddRecvStream() {
3290 return AddRecvStream(StreamParams::CreateLegacy(last_ssrc_++));
3291 }
3292
3293 FakeVideoReceiveStream* AddRecvStream(const StreamParams& sp) {
3294 size_t num_streams =
3295 fake_call_.GetVideoReceiveStreams().size();
3296 EXPECT_TRUE(channel_->AddRecvStream(sp));
3297 std::vector<FakeVideoReceiveStream*> streams =
3298 fake_call_.GetVideoReceiveStreams();
3299 EXPECT_EQ(num_streams + 1, streams.size());
3300 return streams[streams.size() - 1];
3301 }
3302
3303 FakeCall fake_call_;
3304 WebRtcVideoEngine2 engine_;
3305 rtc::scoped_ptr<VideoMediaChannel> channel_;
3306 uint32_t last_ssrc_;
3307 };
3308
3309 TEST_F(WebRtcVideoChannel2SimulcastTest, SetSendCodecsWith2SimulcastStreams) {
3310 VerifySimulcastSettings(kVp8Codec, 2, 2);
3311 }
3312
3313 TEST_F(WebRtcVideoChannel2SimulcastTest, SetSendCodecsWith3SimulcastStreams) {
3314 VerifySimulcastSettings(kVp8Codec720p, 3, 3);
3315 }
3316
3317 // Test that we normalize send codec format size in simulcast.
3318 TEST_F(WebRtcVideoChannel2SimulcastTest, SetSendCodecsWithOddSizeInSimulcast) {
3319 cricket::VideoCodec codec(kVp8Codec270p);
3320 codec.width += 1;
3321 codec.height += 1;
3322 VerifySimulcastSettings(codec, 2, 2);
3323 }
3324
3325 TEST_F(WebRtcVideoChannel2SimulcastTest, DISABLED_SimulcastSend_1280x800) {
3326 // TODO(pbos): Implement.
3327 FAIL() << "Not implemented.";
3328 }
3329
3330 TEST_F(WebRtcVideoChannel2SimulcastTest, DISABLED_SimulcastSend_1280x720) {
3331 // TODO(pbos): Implement.
3332 FAIL() << "Not implemented.";
3333 }
3334
3335 TEST_F(WebRtcVideoChannel2SimulcastTest, DISABLED_SimulcastSend_960x540) {
3336 // TODO(pbos): Implement.
3337 FAIL() << "Not implemented.";
3338 }
3339
3340 TEST_F(WebRtcVideoChannel2SimulcastTest, DISABLED_SimulcastSend_960x600) {
3341 // TODO(pbos): Implement.
3342 FAIL() << "Not implemented.";
3343 }
3344
3345 TEST_F(WebRtcVideoChannel2SimulcastTest, DISABLED_SimulcastSend_640x400) {
3346 // TODO(pbos): Implement.
3347 FAIL() << "Not implemented.";
3348 }
3349
3350 TEST_F(WebRtcVideoChannel2SimulcastTest, DISABLED_SimulcastSend_640x360) {
3351 // TODO(pbos): Implement.
3352 FAIL() << "Not implemented.";
3353 }
3354
3355 TEST_F(WebRtcVideoChannel2SimulcastTest, DISABLED_SimulcastSend_480x300) {
3356 // TODO(pbos): Implement.
3357 FAIL() << "Not implemented.";
3358 }
3359
3360 TEST_F(WebRtcVideoChannel2SimulcastTest, DISABLED_SimulcastSend_480x270) {
3361 // TODO(pbos): Implement.
3362 FAIL() << "Not implemented.";
3363 }
3364
3365 TEST_F(WebRtcVideoChannel2SimulcastTest, DISABLED_SimulcastSend_320x200) {
3366 // TODO(pbos): Implement.
3367 FAIL() << "Not implemented.";
3368 }
3369
3370 TEST_F(WebRtcVideoChannel2SimulcastTest, DISABLED_SimulcastSend_320x180) {
3371 // TODO(pbos): Implement.
3372 FAIL() << "Not implemented.";
3373 }
3374
3375 // Test simulcast streams are decodeable with expected sizes.
3376 TEST_F(WebRtcVideoChannel2SimulcastTest, DISABLED_SimulcastStreams) {
3377 // TODO(pbos): Implement.
3378 FAIL() << "Not implemented.";
3379 }
3380
3381 // Simulcast and resolution resizing should be turned off when screencasting
3382 // but not otherwise.
3383 TEST_F(WebRtcVideoChannel2SimulcastTest, DISABLED_ScreencastRendering) {
3384 // TODO(pbos): Implement.
3385 FAIL() << "Not implemented.";
3386 }
3387
3388 // Ensures that the correct settings are applied to the codec when single
3389 // temporal layer screencasting is enabled, and that the correct simulcast
3390 // settings are reapplied when disabling screencasting.
3391 TEST_F(WebRtcVideoChannel2SimulcastTest,
3392 DISABLED_OneTemporalLayerScreencastSettings) {
3393 // TODO(pbos): Implement.
3394 FAIL() << "Not implemented.";
3395 }
3396
3397 // Ensures that the correct settings are applied to the codec when two temporal
3398 // layer screencasting is enabled, and that the correct simulcast settings are
3399 // reapplied when disabling screencasting.
3400 TEST_F(WebRtcVideoChannel2SimulcastTest,
3401 DISABLED_TwoTemporalLayerScreencastSettings) {
3402 // TODO(pbos): Implement.
3403 FAIL() << "Not implemented.";
3404 }
3405
3406 } // namespace cricket
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698