OLD | NEW |
(Empty) | |
| 1 /* |
| 2 * Copyright 2017 The WebRTC project authors. All Rights Reserved. |
| 3 * |
| 4 * Use of this source code is governed by a BSD-style license |
| 5 * that can be found in the LICENSE file in the root of the source |
| 6 * tree. An additional intellectual property rights grant can be found |
| 7 * in the file PATENTS. All contributing project authors may |
| 8 * be found in the AUTHORS file in the root of the source tree. |
| 9 */ |
| 10 |
| 11 #include <memory> |
| 12 |
| 13 #include "webrtc/base/gunit.h" |
| 14 #include "webrtc/media/base/fakemediaengine.h" |
| 15 #include "webrtc/p2p/base/fakepackettransport.h" |
| 16 #include "webrtc/ortc/ortcfactory.h" |
| 17 #include "webrtc/ortc/testrtpparameters.h" |
| 18 #include "webrtc/pc/test/fakevideotracksource.h" |
| 19 |
| 20 namespace webrtc { |
| 21 |
| 22 // This test uses an individual RtpSender using only the public interface, and |
| 23 // verify that its APIs behave as intended. Also tests that parameters are |
| 24 // applied to the audio/video engines as expected. Network and media interfaces |
| 25 // are faked to isolate what's being tested. |
| 26 // |
| 27 // This test shouldn't result any any actual media being sent. That sort of |
| 28 // test should go in ortcfactory_integrationtest.cc. |
| 29 class OrtcRtpSenderTest : public testing::Test { |
| 30 public: |
| 31 OrtcRtpSenderTest() : fake_packet_transport_("fake") { |
| 32 // Need to set the fake packet transport to writable, in order to test that |
| 33 // the "send" flag is applied to the media engine based on the encoding |
| 34 // |active| flag. |
| 35 fake_packet_transport_.SetWritable(true); |
| 36 fake_media_engine_ = new cricket::FakeMediaEngine(); |
| 37 // Note: This doesn't need to use fake network classes, since we already |
| 38 // use FakePacketTransport. |
| 39 auto ortc_factory_result = OrtcFactory::Create( |
| 40 nullptr, nullptr, nullptr, nullptr, nullptr, |
| 41 std::unique_ptr<cricket::MediaEngineInterface>(fake_media_engine_)); |
| 42 ortc_factory_ = ortc_factory_result.MoveValue(); |
| 43 RtcpParameters rtcp_parameters; |
| 44 rtcp_parameters.mux = true; |
| 45 auto rtp_transport_result = ortc_factory_->CreateRtpTransport( |
| 46 rtcp_parameters, &fake_packet_transport_, nullptr, nullptr); |
| 47 rtp_transport_ = rtp_transport_result.MoveValue(); |
| 48 } |
| 49 |
| 50 protected: |
| 51 rtc::scoped_refptr<AudioTrackInterface> CreateAudioTrack( |
| 52 const std::string& id) { |
| 53 return ortc_factory_->CreateAudioTrack(id, nullptr); |
| 54 } |
| 55 |
| 56 rtc::scoped_refptr<VideoTrackInterface> CreateVideoTrack( |
| 57 const std::string& id) { |
| 58 return rtc::scoped_refptr<webrtc::VideoTrackInterface>( |
| 59 ortc_factory_->CreateVideoTrack(id, FakeVideoTrackSource::Create())); |
| 60 } |
| 61 |
| 62 // Owned by |ortc_factory_|. |
| 63 cricket::FakeMediaEngine* fake_media_engine_; |
| 64 rtc::FakePacketTransport fake_packet_transport_; |
| 65 std::unique_ptr<OrtcFactoryInterface> ortc_factory_; |
| 66 std::unique_ptr<RtpTransportInterface> rtp_transport_; |
| 67 }; |
| 68 |
| 69 TEST_F(OrtcRtpSenderTest, GetAndSetTrack) { |
| 70 // Test GetTrack with a sender constructed with a track. |
| 71 auto audio_track = CreateAudioTrack("audio"); |
| 72 auto audio_sender_result = |
| 73 ortc_factory_->CreateRtpSender(audio_track, rtp_transport_.get()); |
| 74 auto audio_sender = audio_sender_result.MoveValue(); |
| 75 EXPECT_EQ(audio_track, audio_sender->GetTrack()); |
| 76 |
| 77 // Test GetTrack after SetTrack. |
| 78 auto video_sender_result = ortc_factory_->CreateRtpSender( |
| 79 cricket::MEDIA_TYPE_VIDEO, rtp_transport_.get()); |
| 80 auto video_sender = video_sender_result.MoveValue(); |
| 81 auto video_track = CreateVideoTrack("video1"); |
| 82 EXPECT_TRUE(video_sender->SetTrack(video_track).ok()); |
| 83 EXPECT_EQ(video_track, video_sender->GetTrack()); |
| 84 video_track = CreateVideoTrack("video2"); |
| 85 EXPECT_TRUE(video_sender->SetTrack(video_track).ok()); |
| 86 EXPECT_EQ(video_track, video_sender->GetTrack()); |
| 87 } |
| 88 |
| 89 // Test that track can be sent, even mid sending (or at least, configured for |
| 90 // sending). |
| 91 TEST_F(OrtcRtpSenderTest, SetTrackWhileSending) { |
| 92 auto audio_sender_result = ortc_factory_->CreateRtpSender( |
| 93 cricket::MEDIA_TYPE_AUDIO, rtp_transport_.get()); |
| 94 auto audio_sender = audio_sender_result.MoveValue(); |
| 95 EXPECT_TRUE(audio_sender->Send(MakeMinimalOpusParameters()).ok()); |
| 96 EXPECT_TRUE(audio_sender->SetTrack(CreateAudioTrack("audio")).ok()); |
| 97 |
| 98 auto video_sender_result = ortc_factory_->CreateRtpSender( |
| 99 cricket::MEDIA_TYPE_VIDEO, rtp_transport_.get()); |
| 100 auto video_sender = video_sender_result.MoveValue(); |
| 101 EXPECT_TRUE(video_sender->Send(MakeMinimalVp8Parameters()).ok()); |
| 102 EXPECT_TRUE(video_sender->SetTrack(CreateVideoTrack("video")).ok()); |
| 103 } |
| 104 |
| 105 // Test that track can be changed mid-sending. |
| 106 TEST_F(OrtcRtpSenderTest, ChangeTrackWhileSending) { |
| 107 auto audio_sender_result = ortc_factory_->CreateRtpSender( |
| 108 CreateAudioTrack("audio1"), rtp_transport_.get()); |
| 109 auto audio_sender = audio_sender_result.MoveValue(); |
| 110 EXPECT_TRUE(audio_sender->Send(MakeMinimalOpusParameters()).ok()); |
| 111 EXPECT_TRUE(audio_sender->SetTrack(CreateAudioTrack("audio2")).ok()); |
| 112 |
| 113 auto video_sender_result = ortc_factory_->CreateRtpSender( |
| 114 CreateVideoTrack("video1"), rtp_transport_.get()); |
| 115 auto video_sender = video_sender_result.MoveValue(); |
| 116 EXPECT_TRUE(video_sender->Send(MakeMinimalVp8Parameters()).ok()); |
| 117 EXPECT_TRUE(video_sender->SetTrack(CreateVideoTrack("video2")).ok()); |
| 118 } |
| 119 |
| 120 // Test that track can be set to null wihle sending. |
| 121 TEST_F(OrtcRtpSenderTest, UnsetTrackWhileSending) { |
| 122 auto audio_sender_result = ortc_factory_->CreateRtpSender( |
| 123 CreateAudioTrack("audio"), rtp_transport_.get()); |
| 124 auto audio_sender = audio_sender_result.MoveValue(); |
| 125 EXPECT_TRUE(audio_sender->Send(MakeMinimalOpusParameters()).ok()); |
| 126 EXPECT_TRUE(audio_sender->SetTrack(nullptr).ok()); |
| 127 |
| 128 auto video_sender_result = ortc_factory_->CreateRtpSender( |
| 129 CreateVideoTrack("video"), rtp_transport_.get()); |
| 130 auto video_sender = video_sender_result.MoveValue(); |
| 131 EXPECT_TRUE(video_sender->Send(MakeMinimalVp8Parameters()).ok()); |
| 132 EXPECT_TRUE(video_sender->SetTrack(nullptr).ok()); |
| 133 } |
| 134 |
| 135 // Shouldn't be able to set an audio track on a video sender or vice versa. |
| 136 TEST_F(OrtcRtpSenderTest, SetTrackOfWrongKindFails) { |
| 137 auto audio_sender_result = ortc_factory_->CreateRtpSender( |
| 138 cricket::MEDIA_TYPE_AUDIO, rtp_transport_.get()); |
| 139 auto audio_sender = audio_sender_result.MoveValue(); |
| 140 EXPECT_EQ(RTCErrorType::INVALID_PARAMETER, |
| 141 audio_sender->SetTrack(CreateVideoTrack("video")).type()); |
| 142 |
| 143 auto video_sender_result = ortc_factory_->CreateRtpSender( |
| 144 cricket::MEDIA_TYPE_VIDEO, rtp_transport_.get()); |
| 145 auto video_sender = video_sender_result.MoveValue(); |
| 146 EXPECT_EQ(RTCErrorType::INVALID_PARAMETER, |
| 147 video_sender->SetTrack(CreateAudioTrack("audio")).type()); |
| 148 } |
| 149 |
| 150 // Currently SetTransport isn't supported. When it is, replace this test with a |
| 151 // test/tests for it. |
| 152 TEST_F(OrtcRtpSenderTest, SetTransportFails) { |
| 153 rtc::FakePacketTransport fake_packet_transport("another_transport"); |
| 154 RtcpParameters rtcp_parameters; |
| 155 rtcp_parameters.mux = true; |
| 156 auto rtp_transport_result = ortc_factory_->CreateRtpTransport( |
| 157 rtcp_parameters, &fake_packet_transport, nullptr, nullptr); |
| 158 auto rtp_transport = rtp_transport_result.MoveValue(); |
| 159 |
| 160 auto sender_result = ortc_factory_->CreateRtpSender(cricket::MEDIA_TYPE_AUDIO, |
| 161 rtp_transport_.get()); |
| 162 auto sender = sender_result.MoveValue(); |
| 163 EXPECT_EQ(RTCErrorType::UNSUPPORTED_PARAMETER, |
| 164 sender->SetTransport(rtp_transport.get()).type()); |
| 165 } |
| 166 |
| 167 TEST_F(OrtcRtpSenderTest, GetTransport) { |
| 168 auto result = ortc_factory_->CreateRtpSender(cricket::MEDIA_TYPE_AUDIO, |
| 169 rtp_transport_.get()); |
| 170 EXPECT_EQ(rtp_transport_.get(), result.value()->GetTransport()); |
| 171 } |
| 172 |
| 173 // Test that "Send" causes the expected parameters to be applied to the media |
| 174 // engine level, for an audio sender. |
| 175 TEST_F(OrtcRtpSenderTest, SendAppliesAudioParametersToMediaEngine) { |
| 176 auto audio_sender_result = ortc_factory_->CreateRtpSender( |
| 177 cricket::MEDIA_TYPE_AUDIO, rtp_transport_.get()); |
| 178 auto audio_sender = audio_sender_result.MoveValue(); |
| 179 |
| 180 // First, create parameters with all the bells and whistles. |
| 181 RtpParameters parameters; |
| 182 |
| 183 RtpCodecParameters opus_codec; |
| 184 opus_codec.name = "opus"; |
| 185 opus_codec.kind = cricket::MEDIA_TYPE_AUDIO; |
| 186 opus_codec.payload_type = 120; |
| 187 opus_codec.clock_rate.emplace(48000); |
| 188 opus_codec.num_channels.emplace(2); |
| 189 opus_codec.parameters["minptime"] = "10"; |
| 190 opus_codec.rtcp_feedback.emplace_back(RtcpFeedbackType::TRANSPORT_CC); |
| 191 parameters.codecs.push_back(std::move(opus_codec)); |
| 192 |
| 193 // Add two codecs, expecting the first to be used. |
| 194 // TODO(deadbeef): Once "codec_payload_type" is supported, use it to select a |
| 195 // codec that's not at the top of the list. |
| 196 RtpCodecParameters isac_codec; |
| 197 isac_codec.name = "ISAC"; |
| 198 isac_codec.kind = cricket::MEDIA_TYPE_AUDIO; |
| 199 isac_codec.payload_type = 110; |
| 200 isac_codec.clock_rate.emplace(16000); |
| 201 parameters.codecs.push_back(std::move(isac_codec)); |
| 202 |
| 203 RtpEncodingParameters encoding; |
| 204 encoding.ssrc.emplace(0xdeadbeef); |
| 205 encoding.max_bitrate_bps.emplace(20000); |
| 206 parameters.encodings.push_back(std::move(encoding)); |
| 207 |
| 208 parameters.header_extensions.emplace_back( |
| 209 "urn:ietf:params:rtp-hdrext:ssrc-audio-level", 3); |
| 210 |
| 211 EXPECT_TRUE(audio_sender->Send(parameters).ok()); |
| 212 |
| 213 // Now verify that the parameters were applied to the fake media engine layer |
| 214 // that exists below BaseChannel. |
| 215 cricket::FakeVoiceMediaChannel* fake_voice_channel = |
| 216 fake_media_engine_->GetVoiceChannel(0); |
| 217 ASSERT_NE(nullptr, fake_voice_channel); |
| 218 EXPECT_TRUE(fake_voice_channel->sending()); |
| 219 |
| 220 // Verify codec parameters. |
| 221 ASSERT_GT(fake_voice_channel->send_codecs().size(), 0u); |
| 222 const cricket::AudioCodec& top_codec = fake_voice_channel->send_codecs()[0]; |
| 223 EXPECT_EQ("opus", top_codec.name); |
| 224 EXPECT_EQ(120, top_codec.id); |
| 225 EXPECT_EQ(48000, top_codec.clockrate); |
| 226 EXPECT_EQ(2u, top_codec.channels); |
| 227 ASSERT_NE(top_codec.params.end(), top_codec.params.find("minptime")); |
| 228 EXPECT_EQ("10", top_codec.params.at("minptime")); |
| 229 |
| 230 // Verify encoding parameters. |
| 231 EXPECT_EQ(20000, fake_voice_channel->max_bps()); |
| 232 EXPECT_EQ(1u, fake_voice_channel->send_streams().size()); |
| 233 const cricket::StreamParams& send_stream = |
| 234 fake_voice_channel->send_streams()[0]; |
| 235 EXPECT_EQ(1u, send_stream.ssrcs.size()); |
| 236 EXPECT_EQ(0xdeadbeef, send_stream.first_ssrc()); |
| 237 |
| 238 // Verify header extensions. |
| 239 ASSERT_EQ(1u, fake_voice_channel->send_extensions().size()); |
| 240 const RtpExtension& extension = fake_voice_channel->send_extensions()[0]; |
| 241 EXPECT_EQ("urn:ietf:params:rtp-hdrext:ssrc-audio-level", extension.uri); |
| 242 EXPECT_EQ(3, extension.id); |
| 243 } |
| 244 |
| 245 // Test that "Send" causes the expected parameters to be applied to the media |
| 246 // engine level, for a video sender. |
| 247 TEST_F(OrtcRtpSenderTest, SendAppliesVideoParametersToMediaEngine) { |
| 248 auto video_sender_result = ortc_factory_->CreateRtpSender( |
| 249 cricket::MEDIA_TYPE_VIDEO, rtp_transport_.get()); |
| 250 auto video_sender = video_sender_result.MoveValue(); |
| 251 |
| 252 // First, create parameters with all the bells and whistles. |
| 253 RtpParameters parameters; |
| 254 |
| 255 RtpCodecParameters vp8_codec; |
| 256 vp8_codec.name = "VP8"; |
| 257 vp8_codec.kind = cricket::MEDIA_TYPE_VIDEO; |
| 258 vp8_codec.payload_type = 99; |
| 259 // Try a couple types of feedback params. "Generic NACK" is a bit of a |
| 260 // special case, so test it here. |
| 261 vp8_codec.rtcp_feedback.emplace_back(RtcpFeedbackType::CCM, |
| 262 RtcpFeedbackMessageType::FIR); |
| 263 vp8_codec.rtcp_feedback.emplace_back(RtcpFeedbackType::NACK, |
| 264 RtcpFeedbackMessageType::GENERIC_NACK); |
| 265 parameters.codecs.push_back(std::move(vp8_codec)); |
| 266 |
| 267 RtpCodecParameters vp8_rtx_codec; |
| 268 vp8_rtx_codec.name = "rtx"; |
| 269 vp8_rtx_codec.kind = cricket::MEDIA_TYPE_VIDEO; |
| 270 vp8_rtx_codec.payload_type = 100; |
| 271 vp8_rtx_codec.parameters["apt"] = "99"; |
| 272 parameters.codecs.push_back(std::move(vp8_rtx_codec)); |
| 273 |
| 274 // Add two codecs, expecting the first to be used. |
| 275 // TODO(deadbeef): Once "codec_payload_type" is supported, use it to select a |
| 276 // codec that's not at the top of the list. |
| 277 RtpCodecParameters vp9_codec; |
| 278 vp9_codec.name = "VP9"; |
| 279 vp9_codec.kind = cricket::MEDIA_TYPE_VIDEO; |
| 280 vp9_codec.payload_type = 102; |
| 281 parameters.codecs.push_back(std::move(vp9_codec)); |
| 282 |
| 283 RtpCodecParameters vp9_rtx_codec; |
| 284 vp9_rtx_codec.name = "rtx"; |
| 285 vp9_rtx_codec.kind = cricket::MEDIA_TYPE_VIDEO; |
| 286 vp9_rtx_codec.payload_type = 103; |
| 287 vp9_rtx_codec.parameters["apt"] = "102"; |
| 288 parameters.codecs.push_back(std::move(vp9_rtx_codec)); |
| 289 |
| 290 RtpEncodingParameters encoding; |
| 291 encoding.ssrc.emplace(0xdeadbeef); |
| 292 encoding.rtx.emplace(0xbaadfeed); |
| 293 encoding.max_bitrate_bps.emplace(99999); |
| 294 parameters.encodings.push_back(std::move(encoding)); |
| 295 |
| 296 parameters.header_extensions.emplace_back("urn:3gpp:video-orientation", 4); |
| 297 parameters.header_extensions.emplace_back( |
| 298 "http://www.webrtc.org/experiments/rtp-hdrext/playout-delay", 6); |
| 299 |
| 300 EXPECT_TRUE(video_sender->Send(parameters).ok()); |
| 301 |
| 302 // Now verify that the parameters were applied to the fake media engine layer |
| 303 // that exists below BaseChannel. |
| 304 cricket::FakeVideoMediaChannel* fake_video_channel = |
| 305 fake_media_engine_->GetVideoChannel(0); |
| 306 ASSERT_NE(nullptr, fake_video_channel); |
| 307 EXPECT_TRUE(fake_video_channel->sending()); |
| 308 |
| 309 // Verify codec parameters. |
| 310 ASSERT_GE(fake_video_channel->send_codecs().size(), 2u); |
| 311 const cricket::VideoCodec& top_codec = fake_video_channel->send_codecs()[0]; |
| 312 EXPECT_EQ("VP8", top_codec.name); |
| 313 EXPECT_EQ(99, top_codec.id); |
| 314 EXPECT_TRUE( |
| 315 top_codec.feedback_params.Has(cricket::FeedbackParam("ccm", "fir"))); |
| 316 EXPECT_TRUE(top_codec.feedback_params.Has(cricket::FeedbackParam("nack"))); |
| 317 |
| 318 const cricket::VideoCodec& rtx_codec = fake_video_channel->send_codecs()[1]; |
| 319 EXPECT_EQ("rtx", rtx_codec.name); |
| 320 EXPECT_EQ(100, rtx_codec.id); |
| 321 ASSERT_NE(rtx_codec.params.end(), rtx_codec.params.find("apt")); |
| 322 EXPECT_EQ("99", rtx_codec.params.at("apt")); |
| 323 |
| 324 // Verify encoding parameters. |
| 325 EXPECT_EQ(99999, fake_video_channel->max_bps()); |
| 326 EXPECT_EQ(1u, fake_video_channel->send_streams().size()); |
| 327 const cricket::StreamParams& send_stream = |
| 328 fake_video_channel->send_streams()[0]; |
| 329 EXPECT_EQ(2u, send_stream.ssrcs.size()); |
| 330 EXPECT_EQ(0xdeadbeef, send_stream.first_ssrc()); |
| 331 uint32_t rtx_ssrc = 0u; |
| 332 EXPECT_TRUE(send_stream.GetFidSsrc(send_stream.first_ssrc(), &rtx_ssrc)); |
| 333 EXPECT_EQ(0xbaadfeed, rtx_ssrc); |
| 334 |
| 335 // Verify header extensions. |
| 336 ASSERT_EQ(2u, fake_video_channel->send_extensions().size()); |
| 337 const RtpExtension& extension1 = fake_video_channel->send_extensions()[0]; |
| 338 EXPECT_EQ("urn:3gpp:video-orientation", extension1.uri); |
| 339 EXPECT_EQ(4, extension1.id); |
| 340 const RtpExtension& extension2 = fake_video_channel->send_extensions()[1]; |
| 341 EXPECT_EQ("http://www.webrtc.org/experiments/rtp-hdrext/playout-delay", |
| 342 extension2.uri); |
| 343 EXPECT_EQ(6, extension2.id); |
| 344 } |
| 345 |
| 346 // Ensure that when primary or RTX SSRCs are left unset, they're generated |
| 347 // automatically. |
| 348 TEST_F(OrtcRtpSenderTest, SendGeneratesSsrcsWhenEmpty) { |
| 349 auto audio_sender_result = ortc_factory_->CreateRtpSender( |
| 350 cricket::MEDIA_TYPE_AUDIO, rtp_transport_.get()); |
| 351 auto audio_sender = audio_sender_result.MoveValue(); |
| 352 auto parameters = MakeMinimalOpusParametersWithNoSsrc(); |
| 353 // Default RTX parameters, with no SSRC. |
| 354 parameters.encodings[0].rtx.emplace(); |
| 355 EXPECT_TRUE(audio_sender->Send(parameters).ok()); |
| 356 |
| 357 cricket::FakeVoiceMediaChannel* fake_voice_channel = |
| 358 fake_media_engine_->GetVoiceChannel(0); |
| 359 ASSERT_NE(nullptr, fake_voice_channel); |
| 360 ASSERT_EQ(1u, fake_voice_channel->send_streams().size()); |
| 361 const cricket::StreamParams& audio_send_stream = |
| 362 fake_voice_channel->send_streams()[0]; |
| 363 EXPECT_NE(0u, audio_send_stream.first_ssrc()); |
| 364 uint32_t rtx_ssrc = 0u; |
| 365 EXPECT_TRUE( |
| 366 audio_send_stream.GetFidSsrc(audio_send_stream.first_ssrc(), &rtx_ssrc)); |
| 367 EXPECT_NE(0u, rtx_ssrc); |
| 368 EXPECT_NE(audio_send_stream.first_ssrc(), rtx_ssrc); |
| 369 |
| 370 auto video_sender_result = ortc_factory_->CreateRtpSender( |
| 371 cricket::MEDIA_TYPE_VIDEO, rtp_transport_.get()); |
| 372 auto video_sender = video_sender_result.MoveValue(); |
| 373 parameters = MakeMinimalVp8ParametersWithNoSsrc(); |
| 374 // Default RTX parameters, with no SSRC. |
| 375 parameters.encodings[0].rtx.emplace(); |
| 376 EXPECT_TRUE(video_sender->Send(parameters).ok()); |
| 377 |
| 378 cricket::FakeVideoMediaChannel* fake_video_channel = |
| 379 fake_media_engine_->GetVideoChannel(0); |
| 380 ASSERT_NE(nullptr, fake_video_channel); |
| 381 ASSERT_EQ(1u, fake_video_channel->send_streams().size()); |
| 382 const cricket::StreamParams& video_send_stream = |
| 383 fake_video_channel->send_streams()[0]; |
| 384 EXPECT_NE(0u, video_send_stream.first_ssrc()); |
| 385 rtx_ssrc = 0u; |
| 386 EXPECT_TRUE( |
| 387 video_send_stream.GetFidSsrc(video_send_stream.first_ssrc(), &rtx_ssrc)); |
| 388 EXPECT_NE(0u, rtx_ssrc); |
| 389 EXPECT_NE(video_send_stream.first_ssrc(), rtx_ssrc); |
| 390 EXPECT_NE(video_send_stream.first_ssrc(), audio_send_stream.first_ssrc()); |
| 391 } |
| 392 |
| 393 // Test changing both the send codec and SSRC at the same time, and verify that |
| 394 // the new parameters are applied to the media engine level. |
| 395 TEST_F(OrtcRtpSenderTest, CallingSendTwiceChangesParameters) { |
| 396 auto audio_sender_result = ortc_factory_->CreateRtpSender( |
| 397 cricket::MEDIA_TYPE_AUDIO, rtp_transport_.get()); |
| 398 auto audio_sender = audio_sender_result.MoveValue(); |
| 399 EXPECT_TRUE( |
| 400 audio_sender->Send(MakeMinimalOpusParametersWithSsrc(0x11111111)).ok()); |
| 401 EXPECT_TRUE( |
| 402 audio_sender->Send(MakeMinimalIsacParametersWithSsrc(0x22222222)).ok()); |
| 403 |
| 404 cricket::FakeVoiceMediaChannel* fake_voice_channel = |
| 405 fake_media_engine_->GetVoiceChannel(0); |
| 406 ASSERT_NE(nullptr, fake_voice_channel); |
| 407 ASSERT_GT(fake_voice_channel->send_codecs().size(), 0u); |
| 408 EXPECT_EQ("ISAC", fake_voice_channel->send_codecs()[0].name); |
| 409 ASSERT_EQ(1u, fake_voice_channel->send_streams().size()); |
| 410 EXPECT_EQ(0x22222222u, fake_voice_channel->send_streams()[0].first_ssrc()); |
| 411 |
| 412 auto video_sender_result = ortc_factory_->CreateRtpSender( |
| 413 cricket::MEDIA_TYPE_VIDEO, rtp_transport_.get()); |
| 414 auto video_sender = video_sender_result.MoveValue(); |
| 415 EXPECT_TRUE( |
| 416 video_sender->Send(MakeMinimalVp8ParametersWithSsrc(0x33333333)).ok()); |
| 417 EXPECT_TRUE( |
| 418 video_sender->Send(MakeMinimalVp9ParametersWithSsrc(0x44444444)).ok()); |
| 419 |
| 420 cricket::FakeVideoMediaChannel* fake_video_channel = |
| 421 fake_media_engine_->GetVideoChannel(0); |
| 422 ASSERT_NE(nullptr, fake_video_channel); |
| 423 ASSERT_GT(fake_video_channel->send_codecs().size(), 0u); |
| 424 EXPECT_EQ("VP9", fake_video_channel->send_codecs()[0].name); |
| 425 ASSERT_EQ(1u, fake_video_channel->send_streams().size()); |
| 426 EXPECT_EQ(0x44444444u, fake_video_channel->send_streams()[0].first_ssrc()); |
| 427 } |
| 428 |
| 429 // Ensure that if the |active| flag of RtpEncodingParameters is set to false, |
| 430 // sending stops at the media engine level. |
| 431 TEST_F(OrtcRtpSenderTest, DeactivatingEncodingStopsSending) { |
| 432 auto audio_sender_result = ortc_factory_->CreateRtpSender( |
| 433 cricket::MEDIA_TYPE_AUDIO, rtp_transport_.get()); |
| 434 auto audio_sender = audio_sender_result.MoveValue(); |
| 435 RtpParameters parameters = MakeMinimalOpusParameters(); |
| 436 EXPECT_TRUE(audio_sender->Send(parameters).ok()); |
| 437 parameters.encodings[0].active = false; |
| 438 EXPECT_TRUE(audio_sender->Send(parameters).ok()); |
| 439 |
| 440 cricket::FakeVoiceMediaChannel* fake_voice_channel = |
| 441 fake_media_engine_->GetVoiceChannel(0); |
| 442 ASSERT_NE(nullptr, fake_voice_channel); |
| 443 EXPECT_FALSE(fake_voice_channel->sending()); |
| 444 |
| 445 auto video_sender_result = ortc_factory_->CreateRtpSender( |
| 446 cricket::MEDIA_TYPE_VIDEO, rtp_transport_.get()); |
| 447 auto video_sender = video_sender_result.MoveValue(); |
| 448 parameters = MakeMinimalVp8Parameters(); |
| 449 EXPECT_TRUE(video_sender->Send(parameters).ok()); |
| 450 parameters.encodings[0].active = false; |
| 451 EXPECT_TRUE(video_sender->Send(parameters).ok()); |
| 452 |
| 453 cricket::FakeVideoMediaChannel* fake_video_channel = |
| 454 fake_media_engine_->GetVideoChannel(0); |
| 455 ASSERT_NE(nullptr, fake_video_channel); |
| 456 EXPECT_FALSE(fake_video_channel->sending()); |
| 457 } |
| 458 |
| 459 // Ensure that calling Send with an empty list of encodings causes send streams |
| 460 // at the media engine level to be cleared. |
| 461 TEST_F(OrtcRtpSenderTest, CallingSendWithEmptyEncodingsClearsSendStreams) { |
| 462 auto audio_sender_result = ortc_factory_->CreateRtpSender( |
| 463 cricket::MEDIA_TYPE_AUDIO, rtp_transport_.get()); |
| 464 auto audio_sender = audio_sender_result.MoveValue(); |
| 465 auto parameters = MakeMinimalOpusParameters(); |
| 466 EXPECT_TRUE(audio_sender->Send(parameters).ok()); |
| 467 parameters.encodings.clear(); |
| 468 EXPECT_TRUE(audio_sender->Send(parameters).ok()); |
| 469 |
| 470 cricket::FakeVoiceMediaChannel* fake_voice_channel = |
| 471 fake_media_engine_->GetVoiceChannel(0); |
| 472 ASSERT_NE(nullptr, fake_voice_channel); |
| 473 EXPECT_TRUE(fake_voice_channel->send_streams().empty()); |
| 474 |
| 475 auto video_sender_result = ortc_factory_->CreateRtpSender( |
| 476 cricket::MEDIA_TYPE_VIDEO, rtp_transport_.get()); |
| 477 auto video_sender = video_sender_result.MoveValue(); |
| 478 parameters = MakeMinimalVp8Parameters(); |
| 479 EXPECT_TRUE(video_sender->Send(parameters).ok()); |
| 480 parameters.encodings.clear(); |
| 481 EXPECT_TRUE(video_sender->Send(parameters).ok()); |
| 482 |
| 483 cricket::FakeVideoMediaChannel* fake_video_channel = |
| 484 fake_media_engine_->GetVideoChannel(0); |
| 485 ASSERT_NE(nullptr, fake_video_channel); |
| 486 EXPECT_TRUE(fake_video_channel->send_streams().empty()); |
| 487 } |
| 488 |
| 489 // Ensure that deleting a sender causes send streams at the media engine level |
| 490 // to be cleared. |
| 491 TEST_F(OrtcRtpSenderTest, DeletingSenderClearsSendStreams) { |
| 492 auto audio_sender_result = ortc_factory_->CreateRtpSender( |
| 493 cricket::MEDIA_TYPE_AUDIO, rtp_transport_.get()); |
| 494 auto audio_sender = audio_sender_result.MoveValue(); |
| 495 EXPECT_TRUE(audio_sender->Send(MakeMinimalOpusParameters()).ok()); |
| 496 |
| 497 // Also create an audio receiver, to prevent the voice channel from being |
| 498 // completely deleted. |
| 499 auto audio_receiver_result = ortc_factory_->CreateRtpReceiver( |
| 500 cricket::MEDIA_TYPE_AUDIO, rtp_transport_.get()); |
| 501 auto audio_receiver = audio_receiver_result.MoveValue(); |
| 502 EXPECT_TRUE(audio_receiver->Receive(MakeMinimalOpusParameters()).ok()); |
| 503 |
| 504 audio_sender.reset(nullptr); |
| 505 cricket::FakeVoiceMediaChannel* fake_voice_channel = |
| 506 fake_media_engine_->GetVoiceChannel(0); |
| 507 ASSERT_NE(nullptr, fake_voice_channel); |
| 508 EXPECT_TRUE(fake_voice_channel->send_streams().empty()); |
| 509 |
| 510 auto video_sender_result = ortc_factory_->CreateRtpSender( |
| 511 cricket::MEDIA_TYPE_VIDEO, rtp_transport_.get()); |
| 512 auto video_sender = video_sender_result.MoveValue(); |
| 513 EXPECT_TRUE(video_sender->Send(MakeMinimalVp8Parameters()).ok()); |
| 514 |
| 515 // Also create an video receiver, to prevent the video channel from being |
| 516 // completely deleted. |
| 517 auto video_receiver_result = ortc_factory_->CreateRtpReceiver( |
| 518 cricket::MEDIA_TYPE_VIDEO, rtp_transport_.get()); |
| 519 auto video_receiver = video_receiver_result.MoveValue(); |
| 520 EXPECT_TRUE(video_receiver->Receive(MakeMinimalVp8Parameters()).ok()); |
| 521 |
| 522 video_sender.reset(nullptr); |
| 523 cricket::FakeVideoMediaChannel* fake_video_channel = |
| 524 fake_media_engine_->GetVideoChannel(0); |
| 525 ASSERT_NE(nullptr, fake_video_channel); |
| 526 EXPECT_TRUE(fake_video_channel->send_streams().empty()); |
| 527 } |
| 528 |
| 529 // If Send hasn't been called, GetParameters should return empty parameters. |
| 530 TEST_F(OrtcRtpSenderTest, GetDefaultParameters) { |
| 531 auto result = ortc_factory_->CreateRtpSender(cricket::MEDIA_TYPE_AUDIO, |
| 532 rtp_transport_.get()); |
| 533 EXPECT_EQ(RtpParameters(), result.value()->GetParameters()); |
| 534 result = ortc_factory_->CreateRtpSender(cricket::MEDIA_TYPE_VIDEO, |
| 535 rtp_transport_.get()); |
| 536 EXPECT_EQ(RtpParameters(), result.value()->GetParameters()); |
| 537 } |
| 538 |
| 539 // Test that GetParameters returns the last parameters passed into Send, along |
| 540 // with the implementation-default values filled in where they were left unset. |
| 541 TEST_F(OrtcRtpSenderTest, |
| 542 GetParametersReturnsLastSetParametersWithDefaultsFilled) { |
| 543 auto audio_sender_result = ortc_factory_->CreateRtpSender( |
| 544 CreateAudioTrack("audio"), rtp_transport_.get()); |
| 545 auto audio_sender = audio_sender_result.MoveValue(); |
| 546 |
| 547 RtpParameters opus_parameters = MakeMinimalOpusParameters(); |
| 548 EXPECT_TRUE(audio_sender->Send(opus_parameters).ok()); |
| 549 EXPECT_EQ(opus_parameters, audio_sender->GetParameters()); |
| 550 |
| 551 RtpParameters isac_parameters = MakeMinimalIsacParameters(); |
| 552 // Sanity check that num_channels actually is left unset. |
| 553 ASSERT_FALSE(isac_parameters.codecs[0].num_channels); |
| 554 EXPECT_TRUE(audio_sender->Send(isac_parameters).ok()); |
| 555 // Should be filled with a default "num channels" of 1. |
| 556 isac_parameters.codecs[0].num_channels.emplace(1); |
| 557 EXPECT_EQ(isac_parameters, audio_sender->GetParameters()); |
| 558 |
| 559 auto video_sender_result = ortc_factory_->CreateRtpSender( |
| 560 CreateVideoTrack("video"), rtp_transport_.get()); |
| 561 auto video_sender = video_sender_result.MoveValue(); |
| 562 |
| 563 RtpParameters vp8_parameters = MakeMinimalVp8Parameters(); |
| 564 // Sanity check that clock_rate actually is left unset. |
| 565 EXPECT_TRUE(video_sender->Send(vp8_parameters).ok()); |
| 566 // Should be filled with a default clock rate of 90000. |
| 567 vp8_parameters.codecs[0].clock_rate.emplace(90000); |
| 568 EXPECT_EQ(vp8_parameters, video_sender->GetParameters()); |
| 569 |
| 570 RtpParameters vp9_parameters = MakeMinimalVp9Parameters(); |
| 571 // Sanity check that clock_rate actually is left unset. |
| 572 EXPECT_TRUE(video_sender->Send(vp9_parameters).ok()); |
| 573 // Should be filled with a default clock rate of 90000. |
| 574 vp9_parameters.codecs[0].clock_rate.emplace(90000); |
| 575 EXPECT_EQ(vp9_parameters, video_sender->GetParameters()); |
| 576 } |
| 577 |
| 578 TEST_F(OrtcRtpSenderTest, GetKind) { |
| 579 // Construct one sender from the "kind" enum and another from a track. |
| 580 auto audio_sender_result = ortc_factory_->CreateRtpSender( |
| 581 cricket::MEDIA_TYPE_AUDIO, rtp_transport_.get()); |
| 582 auto audio_sender = audio_sender_result.MoveValue(); |
| 583 auto video_sender_result = ortc_factory_->CreateRtpSender( |
| 584 CreateVideoTrack("video"), rtp_transport_.get()); |
| 585 auto video_sender = video_sender_result.MoveValue(); |
| 586 EXPECT_EQ(cricket::MEDIA_TYPE_AUDIO, audio_sender->GetKind()); |
| 587 EXPECT_EQ(cricket::MEDIA_TYPE_VIDEO, video_sender->GetKind()); |
| 588 } |
| 589 |
| 590 } // namespace webrtc |
OLD | NEW |