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

Side by Side Diff: webrtc/media/engine/webrtcvideoengine.cc

Issue 2932073002: s/WebRtcVideoChannel2/WebRtcVideoChannel and s/WebRtcVideoEngine2/WebRtcVideoEngine (Closed)
Patch Set: Created 3 years, 6 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
1 /* 1 /*
2 * Copyright (c) 2014 The WebRTC project authors. All Rights Reserved. 2 * Copyright (c) 2014 The WebRTC project authors. All Rights Reserved.
3 * 3 *
4 * Use of this source code is governed by a BSD-style license 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 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 6 * tree. An additional intellectual property rights grant can be found
7 * in the file PATENTS. All contributing project authors may 7 * in the file PATENTS. All contributing project authors may
8 * be found in the AUTHORS file in the root of the source tree. 8 * be found in the AUTHORS file in the root of the source tree.
9 */ 9 */
10 10
11 #include "webrtc/media/engine/webrtcvideoengine2.h" 11 #include "webrtc/media/engine/webrtcvideoengine.h"
12 12
13 #include <stdio.h> 13 #include <stdio.h>
14 #include <algorithm> 14 #include <algorithm>
15 #include <set> 15 #include <set>
16 #include <string> 16 #include <string>
17 #include <utility> 17 #include <utility>
18 18
19 #include "webrtc/api/video/i420_buffer.h" 19 #include "webrtc/api/video/i420_buffer.h"
20 #include "webrtc/api/video_codecs/video_decoder.h" 20 #include "webrtc/api/video_codecs/video_decoder.h"
21 #include "webrtc/api/video_codecs/video_encoder.h" 21 #include "webrtc/api/video_codecs/video_encoder.h"
(...skipping 344 matching lines...) Expand 10 before | Expand all | Expand 10 after
366 366
367 static const int kDefaultRtcpReceiverReportSsrc = 1; 367 static const int kDefaultRtcpReceiverReportSsrc = 1;
368 368
369 // Minimum time interval for logging stats. 369 // Minimum time interval for logging stats.
370 static const int64_t kStatsLogIntervalMs = 10000; 370 static const int64_t kStatsLogIntervalMs = 10000;
371 371
372 static std::vector<VideoCodec> GetSupportedCodecs( 372 static std::vector<VideoCodec> GetSupportedCodecs(
373 const WebRtcVideoEncoderFactory* external_encoder_factory); 373 const WebRtcVideoEncoderFactory* external_encoder_factory);
374 374
375 rtc::scoped_refptr<webrtc::VideoEncoderConfig::EncoderSpecificSettings> 375 rtc::scoped_refptr<webrtc::VideoEncoderConfig::EncoderSpecificSettings>
376 WebRtcVideoChannel2::WebRtcVideoSendStream::ConfigureVideoEncoderSettings( 376 WebRtcVideoChannel::WebRtcVideoSendStream::ConfigureVideoEncoderSettings(
377 const VideoCodec& codec) { 377 const VideoCodec& codec) {
378 RTC_DCHECK_RUN_ON(&thread_checker_); 378 RTC_DCHECK_RUN_ON(&thread_checker_);
379 bool is_screencast = parameters_.options.is_screencast.value_or(false); 379 bool is_screencast = parameters_.options.is_screencast.value_or(false);
380 // No automatic resizing when using simulcast or screencast. 380 // No automatic resizing when using simulcast or screencast.
381 bool automatic_resize = 381 bool automatic_resize =
382 !is_screencast && parameters_.config.rtp.ssrcs.size() == 1; 382 !is_screencast && parameters_.config.rtp.ssrcs.size() == 1;
383 bool frame_dropping = !is_screencast; 383 bool frame_dropping = !is_screencast;
384 bool denoising; 384 bool denoising;
385 bool codec_default_denoising = false; 385 bool codec_default_denoising = false;
386 if (is_screencast) { 386 if (is_screencast) {
(...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after
425 return new rtc::RefCountedObject< 425 return new rtc::RefCountedObject<
426 webrtc::VideoEncoderConfig::Vp9EncoderSpecificSettings>(vp9_settings); 426 webrtc::VideoEncoderConfig::Vp9EncoderSpecificSettings>(vp9_settings);
427 } 427 }
428 return nullptr; 428 return nullptr;
429 } 429 }
430 430
431 DefaultUnsignalledSsrcHandler::DefaultUnsignalledSsrcHandler() 431 DefaultUnsignalledSsrcHandler::DefaultUnsignalledSsrcHandler()
432 : default_sink_(nullptr) {} 432 : default_sink_(nullptr) {}
433 433
434 UnsignalledSsrcHandler::Action DefaultUnsignalledSsrcHandler::OnUnsignalledSsrc( 434 UnsignalledSsrcHandler::Action DefaultUnsignalledSsrcHandler::OnUnsignalledSsrc(
435 WebRtcVideoChannel2* channel, 435 WebRtcVideoChannel* channel,
436 uint32_t ssrc) { 436 uint32_t ssrc) {
437 rtc::Optional<uint32_t> default_recv_ssrc = 437 rtc::Optional<uint32_t> default_recv_ssrc =
438 channel->GetDefaultReceiveStreamSsrc(); 438 channel->GetDefaultReceiveStreamSsrc();
439 439
440 if (default_recv_ssrc) { 440 if (default_recv_ssrc) {
441 LOG(LS_INFO) << "Destroying old default receive stream for SSRC=" << ssrc 441 LOG(LS_INFO) << "Destroying old default receive stream for SSRC=" << ssrc
442 << "."; 442 << ".";
443 channel->RemoveRecvStream(*default_recv_ssrc); 443 channel->RemoveRecvStream(*default_recv_ssrc);
444 } 444 }
445 445
446 StreamParams sp; 446 StreamParams sp;
447 sp.ssrcs.push_back(ssrc); 447 sp.ssrcs.push_back(ssrc);
448 LOG(LS_INFO) << "Creating default receive stream for SSRC=" << ssrc << "."; 448 LOG(LS_INFO) << "Creating default receive stream for SSRC=" << ssrc << ".";
449 if (!channel->AddRecvStream(sp, true)) { 449 if (!channel->AddRecvStream(sp, true)) {
450 LOG(LS_WARNING) << "Could not create default receive stream."; 450 LOG(LS_WARNING) << "Could not create default receive stream.";
451 } 451 }
452 452
453 channel->SetSink(ssrc, default_sink_); 453 channel->SetSink(ssrc, default_sink_);
454 return kDeliverPacket; 454 return kDeliverPacket;
455 } 455 }
456 456
457 rtc::VideoSinkInterface<webrtc::VideoFrame>* 457 rtc::VideoSinkInterface<webrtc::VideoFrame>*
458 DefaultUnsignalledSsrcHandler::GetDefaultSink() const { 458 DefaultUnsignalledSsrcHandler::GetDefaultSink() const {
459 return default_sink_; 459 return default_sink_;
460 } 460 }
461 461
462 void DefaultUnsignalledSsrcHandler::SetDefaultSink( 462 void DefaultUnsignalledSsrcHandler::SetDefaultSink(
463 WebRtcVideoChannel2* channel, 463 WebRtcVideoChannel* channel,
464 rtc::VideoSinkInterface<webrtc::VideoFrame>* sink) { 464 rtc::VideoSinkInterface<webrtc::VideoFrame>* sink) {
465 // 3
stefan-webrtc 2017/06/09 11:17:17 Remove?
eladalon 2017/06/09 11:48:37 Oops! Thanks for catching!
465 default_sink_ = sink; 466 default_sink_ = sink;
466 rtc::Optional<uint32_t> default_recv_ssrc = 467 rtc::Optional<uint32_t> default_recv_ssrc =
467 channel->GetDefaultReceiveStreamSsrc(); 468 channel->GetDefaultReceiveStreamSsrc();
468 if (default_recv_ssrc) { 469 if (default_recv_ssrc) {
469 channel->SetSink(*default_recv_ssrc, default_sink_); 470 channel->SetSink(*default_recv_ssrc, default_sink_);
470 } 471 }
471 } 472 }
472 473
473 WebRtcVideoEngine2::WebRtcVideoEngine2() 474 WebRtcVideoEngine::WebRtcVideoEngine()
474 : initialized_(false), 475 : initialized_(false),
475 external_decoder_factory_(NULL), 476 external_decoder_factory_(NULL),
476 external_encoder_factory_(NULL) { 477 external_encoder_factory_(NULL) {
477 LOG(LS_INFO) << "WebRtcVideoEngine2::WebRtcVideoEngine2()"; 478 LOG(LS_INFO) << "WebRtcVideoEngine::WebRtcVideoEngine()";
478 } 479 }
479 480
480 WebRtcVideoEngine2::~WebRtcVideoEngine2() { 481 WebRtcVideoEngine::~WebRtcVideoEngine() {
481 LOG(LS_INFO) << "WebRtcVideoEngine2::~WebRtcVideoEngine2"; 482 LOG(LS_INFO) << "WebRtcVideoEngine::~WebRtcVideoEngine";
482 } 483 }
483 484
484 void WebRtcVideoEngine2::Init() { 485 void WebRtcVideoEngine::Init() {
485 LOG(LS_INFO) << "WebRtcVideoEngine2::Init"; 486 LOG(LS_INFO) << "WebRtcVideoEngine::Init";
486 initialized_ = true; 487 initialized_ = true;
487 } 488 }
488 489
489 WebRtcVideoChannel2* WebRtcVideoEngine2::CreateChannel( 490 WebRtcVideoChannel* WebRtcVideoEngine::CreateChannel(
490 webrtc::Call* call, 491 webrtc::Call* call,
491 const MediaConfig& config, 492 const MediaConfig& config,
492 const VideoOptions& options) { 493 const VideoOptions& options) {
493 RTC_DCHECK(initialized_); 494 RTC_DCHECK(initialized_);
494 LOG(LS_INFO) << "CreateChannel. Options: " << options.ToString(); 495 LOG(LS_INFO) << "CreateChannel. Options: " << options.ToString();
495 return new WebRtcVideoChannel2(call, config, options, 496 return new WebRtcVideoChannel(call, config, options,
496 external_encoder_factory_, 497 external_encoder_factory_,
497 external_decoder_factory_); 498 external_decoder_factory_);
498 } 499 }
499 500
500 std::vector<VideoCodec> WebRtcVideoEngine2::codecs() const { 501 std::vector<VideoCodec> WebRtcVideoEngine::codecs() const {
501 return GetSupportedCodecs(external_encoder_factory_); 502 return GetSupportedCodecs(external_encoder_factory_);
502 } 503 }
503 504
504 RtpCapabilities WebRtcVideoEngine2::GetCapabilities() const { 505 RtpCapabilities WebRtcVideoEngine::GetCapabilities() const {
505 RtpCapabilities capabilities; 506 RtpCapabilities capabilities;
506 capabilities.header_extensions.push_back( 507 capabilities.header_extensions.push_back(
507 webrtc::RtpExtension(webrtc::RtpExtension::kTimestampOffsetUri, 508 webrtc::RtpExtension(webrtc::RtpExtension::kTimestampOffsetUri,
508 webrtc::RtpExtension::kTimestampOffsetDefaultId)); 509 webrtc::RtpExtension::kTimestampOffsetDefaultId));
509 capabilities.header_extensions.push_back( 510 capabilities.header_extensions.push_back(
510 webrtc::RtpExtension(webrtc::RtpExtension::kAbsSendTimeUri, 511 webrtc::RtpExtension(webrtc::RtpExtension::kAbsSendTimeUri,
511 webrtc::RtpExtension::kAbsSendTimeDefaultId)); 512 webrtc::RtpExtension::kAbsSendTimeDefaultId));
512 capabilities.header_extensions.push_back( 513 capabilities.header_extensions.push_back(
513 webrtc::RtpExtension(webrtc::RtpExtension::kVideoRotationUri, 514 webrtc::RtpExtension(webrtc::RtpExtension::kVideoRotationUri,
514 webrtc::RtpExtension::kVideoRotationDefaultId)); 515 webrtc::RtpExtension::kVideoRotationDefaultId));
515 capabilities.header_extensions.push_back(webrtc::RtpExtension( 516 capabilities.header_extensions.push_back(webrtc::RtpExtension(
516 webrtc::RtpExtension::kTransportSequenceNumberUri, 517 webrtc::RtpExtension::kTransportSequenceNumberUri,
517 webrtc::RtpExtension::kTransportSequenceNumberDefaultId)); 518 webrtc::RtpExtension::kTransportSequenceNumberDefaultId));
518 capabilities.header_extensions.push_back( 519 capabilities.header_extensions.push_back(
519 webrtc::RtpExtension(webrtc::RtpExtension::kPlayoutDelayUri, 520 webrtc::RtpExtension(webrtc::RtpExtension::kPlayoutDelayUri,
520 webrtc::RtpExtension::kPlayoutDelayDefaultId)); 521 webrtc::RtpExtension::kPlayoutDelayDefaultId));
521 if (IsVideoContentTypeExtensionFieldTrialEnabled()) { 522 if (IsVideoContentTypeExtensionFieldTrialEnabled()) {
522 capabilities.header_extensions.push_back( 523 capabilities.header_extensions.push_back(
523 webrtc::RtpExtension(webrtc::RtpExtension::kVideoContentTypeUri, 524 webrtc::RtpExtension(webrtc::RtpExtension::kVideoContentTypeUri,
524 webrtc::RtpExtension::kVideoContentTypeDefaultId)); 525 webrtc::RtpExtension::kVideoContentTypeDefaultId));
525 } 526 }
526 return capabilities; 527 return capabilities;
527 } 528 }
528 529
529 void WebRtcVideoEngine2::SetExternalDecoderFactory( 530 void WebRtcVideoEngine::SetExternalDecoderFactory(
530 WebRtcVideoDecoderFactory* decoder_factory) { 531 WebRtcVideoDecoderFactory* decoder_factory) {
531 RTC_DCHECK(!initialized_); 532 RTC_DCHECK(!initialized_);
532 external_decoder_factory_ = decoder_factory; 533 external_decoder_factory_ = decoder_factory;
533 } 534 }
534 535
535 void WebRtcVideoEngine2::SetExternalEncoderFactory( 536 void WebRtcVideoEngine::SetExternalEncoderFactory(
536 WebRtcVideoEncoderFactory* encoder_factory) { 537 WebRtcVideoEncoderFactory* encoder_factory) {
537 RTC_DCHECK(!initialized_); 538 RTC_DCHECK(!initialized_);
538 if (external_encoder_factory_ == encoder_factory) 539 if (external_encoder_factory_ == encoder_factory)
539 return; 540 return;
540 541
541 // No matter what happens we shouldn't hold on to a stale 542 // No matter what happens we shouldn't hold on to a stale
542 // WebRtcSimulcastEncoderFactory. 543 // WebRtcSimulcastEncoderFactory.
543 simulcast_encoder_factory_.reset(); 544 simulcast_encoder_factory_.reset();
544 545
545 if (encoder_factory && 546 if (encoder_factory &&
(...skipping 83 matching lines...) Expand 10 before | Expand all | Expand 10 after
629 const std::vector<VideoCodec>& external_codecs = 630 const std::vector<VideoCodec>& external_codecs =
630 external_encoder_factory->supported_codecs(); 631 external_encoder_factory->supported_codecs();
631 AppendVideoCodecs(external_codecs, &unified_codecs); 632 AppendVideoCodecs(external_codecs, &unified_codecs);
632 LOG(LS_INFO) << "Codecs supported by the external encoder factory: " 633 LOG(LS_INFO) << "Codecs supported by the external encoder factory: "
633 << CodecVectorToString(external_codecs); 634 << CodecVectorToString(external_codecs);
634 } 635 }
635 636
636 return unified_codecs; 637 return unified_codecs;
637 } 638 }
638 639
639 WebRtcVideoChannel2::WebRtcVideoChannel2( 640 WebRtcVideoChannel::WebRtcVideoChannel(
640 webrtc::Call* call, 641 webrtc::Call* call,
641 const MediaConfig& config, 642 const MediaConfig& config,
642 const VideoOptions& options, 643 const VideoOptions& options,
643 WebRtcVideoEncoderFactory* external_encoder_factory, 644 WebRtcVideoEncoderFactory* external_encoder_factory,
644 WebRtcVideoDecoderFactory* external_decoder_factory) 645 WebRtcVideoDecoderFactory* external_decoder_factory)
645 : VideoMediaChannel(config), 646 : VideoMediaChannel(config),
646 call_(call), 647 call_(call),
647 unsignalled_ssrc_handler_(&default_unsignalled_ssrc_handler_), 648 unsignalled_ssrc_handler_(&default_unsignalled_ssrc_handler_),
648 video_config_(config.video), 649 video_config_(config.video),
649 external_encoder_factory_(external_encoder_factory), 650 external_encoder_factory_(external_encoder_factory),
650 external_decoder_factory_(external_decoder_factory), 651 external_decoder_factory_(external_decoder_factory),
651 default_send_options_(options), 652 default_send_options_(options),
652 last_stats_log_ms_(-1) { 653 last_stats_log_ms_(-1) {
653 RTC_DCHECK(thread_checker_.CalledOnValidThread()); 654 RTC_DCHECK(thread_checker_.CalledOnValidThread());
654 655
655 rtcp_receiver_report_ssrc_ = kDefaultRtcpReceiverReportSsrc; 656 rtcp_receiver_report_ssrc_ = kDefaultRtcpReceiverReportSsrc;
656 sending_ = false; 657 sending_ = false;
657 recv_codecs_ = MapCodecs(GetSupportedCodecs(external_encoder_factory)); 658 recv_codecs_ = MapCodecs(GetSupportedCodecs(external_encoder_factory));
658 recv_flexfec_payload_type_ = recv_codecs_.front().flexfec_payload_type; 659 recv_flexfec_payload_type_ = recv_codecs_.front().flexfec_payload_type;
659 } 660 }
660 661
661 WebRtcVideoChannel2::~WebRtcVideoChannel2() { 662 WebRtcVideoChannel::~WebRtcVideoChannel() {
662 for (auto& kv : send_streams_) 663 for (auto& kv : send_streams_)
663 delete kv.second; 664 delete kv.second;
664 for (auto& kv : receive_streams_) 665 for (auto& kv : receive_streams_)
665 delete kv.second; 666 delete kv.second;
666 } 667 }
667 668
668 rtc::Optional<WebRtcVideoChannel2::VideoCodecSettings> 669 rtc::Optional<WebRtcVideoChannel::VideoCodecSettings>
669 WebRtcVideoChannel2::SelectSendVideoCodec( 670 WebRtcVideoChannel::SelectSendVideoCodec(
670 const std::vector<VideoCodecSettings>& remote_mapped_codecs) const { 671 const std::vector<VideoCodecSettings>& remote_mapped_codecs) const {
671 const std::vector<VideoCodec> local_supported_codecs = 672 const std::vector<VideoCodec> local_supported_codecs =
672 GetSupportedCodecs(external_encoder_factory_); 673 GetSupportedCodecs(external_encoder_factory_);
673 // Select the first remote codec that is supported locally. 674 // Select the first remote codec that is supported locally.
674 for (const VideoCodecSettings& remote_mapped_codec : remote_mapped_codecs) { 675 for (const VideoCodecSettings& remote_mapped_codec : remote_mapped_codecs) {
675 // For H264, we will limit the encode level to the remote offered level 676 // For H264, we will limit the encode level to the remote offered level
676 // regardless if level asymmetry is allowed or not. This is strictly not 677 // regardless if level asymmetry is allowed or not. This is strictly not
677 // following the spec in https://tools.ietf.org/html/rfc6184#section-8.2.2 678 // following the spec in https://tools.ietf.org/html/rfc6184#section-8.2.2
678 // since we should limit the encode level to the lower of local and remote 679 // since we should limit the encode level to the lower of local and remote
679 // level when level asymmetry is not allowed. 680 // level when level asymmetry is not allowed.
680 if (FindMatchingCodec(local_supported_codecs, remote_mapped_codec.codec)) 681 if (FindMatchingCodec(local_supported_codecs, remote_mapped_codec.codec))
681 return rtc::Optional<VideoCodecSettings>(remote_mapped_codec); 682 return rtc::Optional<VideoCodecSettings>(remote_mapped_codec);
682 } 683 }
683 // No remote codec was supported. 684 // No remote codec was supported.
684 return rtc::Optional<VideoCodecSettings>(); 685 return rtc::Optional<VideoCodecSettings>();
685 } 686 }
686 687
687 bool WebRtcVideoChannel2::NonFlexfecReceiveCodecsHaveChanged( 688 bool WebRtcVideoChannel::NonFlexfecReceiveCodecsHaveChanged(
688 std::vector<VideoCodecSettings> before, 689 std::vector<VideoCodecSettings> before,
689 std::vector<VideoCodecSettings> after) { 690 std::vector<VideoCodecSettings> after) {
690 if (before.size() != after.size()) { 691 if (before.size() != after.size()) {
691 return true; 692 return true;
692 } 693 }
693 694
694 // The receive codec order doesn't matter, so we sort the codecs before 695 // The receive codec order doesn't matter, so we sort the codecs before
695 // comparing. This is necessary because currently the 696 // comparing. This is necessary because currently the
696 // only way to change the send codec is to munge SDP, which causes 697 // only way to change the send codec is to munge SDP, which causes
697 // the receive codec list to change order, which causes the streams 698 // the receive codec list to change order, which causes the streams
698 // to be recreates which causes a "blink" of black video. In order 699 // to be recreates which causes a "blink" of black video. In order
699 // to support munging the SDP in this way without recreating receive 700 // to support munging the SDP in this way without recreating receive
700 // streams, we ignore the order of the received codecs so that 701 // streams, we ignore the order of the received codecs so that
701 // changing the order doesn't cause this "blink". 702 // changing the order doesn't cause this "blink".
702 auto comparison = 703 auto comparison =
703 [](const VideoCodecSettings& codec1, const VideoCodecSettings& codec2) { 704 [](const VideoCodecSettings& codec1, const VideoCodecSettings& codec2) {
704 return codec1.codec.id > codec2.codec.id; 705 return codec1.codec.id > codec2.codec.id;
705 }; 706 };
706 std::sort(before.begin(), before.end(), comparison); 707 std::sort(before.begin(), before.end(), comparison);
707 std::sort(after.begin(), after.end(), comparison); 708 std::sort(after.begin(), after.end(), comparison);
708 709
709 // Changes in FlexFEC payload type are handled separately in 710 // Changes in FlexFEC payload type are handled separately in
710 // WebRtcVideoChannel2::GetChangedRecvParameters, so disregard FlexFEC in the 711 // WebRtcVideoChannel::GetChangedRecvParameters, so disregard FlexFEC in the
711 // comparison here. 712 // comparison here.
712 return !std::equal(before.begin(), before.end(), after.begin(), 713 return !std::equal(before.begin(), before.end(), after.begin(),
713 VideoCodecSettings::EqualsDisregardingFlexfec); 714 VideoCodecSettings::EqualsDisregardingFlexfec);
714 } 715 }
715 716
716 bool WebRtcVideoChannel2::GetChangedSendParameters( 717 bool WebRtcVideoChannel::GetChangedSendParameters(
717 const VideoSendParameters& params, 718 const VideoSendParameters& params,
718 ChangedSendParameters* changed_params) const { 719 ChangedSendParameters* changed_params) const {
719 if (!ValidateCodecFormats(params.codecs) || 720 if (!ValidateCodecFormats(params.codecs) ||
720 !ValidateRtpExtensions(params.extensions)) { 721 !ValidateRtpExtensions(params.extensions)) {
721 return false; 722 return false;
722 } 723 }
723 724
724 // Select one of the remote codecs that will be used as send codec. 725 // Select one of the remote codecs that will be used as send codec.
725 rtc::Optional<VideoCodecSettings> selected_send_codec = 726 rtc::Optional<VideoCodecSettings> selected_send_codec =
726 SelectSendVideoCodec(MapCodecs(params.codecs)); 727 SelectSendVideoCodec(MapCodecs(params.codecs));
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after
769 // Handle RTCP mode. 770 // Handle RTCP mode.
770 if (params.rtcp.reduced_size != send_params_.rtcp.reduced_size) { 771 if (params.rtcp.reduced_size != send_params_.rtcp.reduced_size) {
771 changed_params->rtcp_mode = rtc::Optional<webrtc::RtcpMode>( 772 changed_params->rtcp_mode = rtc::Optional<webrtc::RtcpMode>(
772 params.rtcp.reduced_size ? webrtc::RtcpMode::kReducedSize 773 params.rtcp.reduced_size ? webrtc::RtcpMode::kReducedSize
773 : webrtc::RtcpMode::kCompound); 774 : webrtc::RtcpMode::kCompound);
774 } 775 }
775 776
776 return true; 777 return true;
777 } 778 }
778 779
779 rtc::DiffServCodePoint WebRtcVideoChannel2::PreferredDscp() const { 780 rtc::DiffServCodePoint WebRtcVideoChannel::PreferredDscp() const {
780 return rtc::DSCP_AF41; 781 return rtc::DSCP_AF41;
781 } 782 }
782 783
783 bool WebRtcVideoChannel2::SetSendParameters(const VideoSendParameters& params) { 784 bool WebRtcVideoChannel::SetSendParameters(const VideoSendParameters& params) {
784 TRACE_EVENT0("webrtc", "WebRtcVideoChannel2::SetSendParameters"); 785 TRACE_EVENT0("webrtc", "WebRtcVideoChannel::SetSendParameters");
785 LOG(LS_INFO) << "SetSendParameters: " << params.ToString(); 786 LOG(LS_INFO) << "SetSendParameters: " << params.ToString();
786 ChangedSendParameters changed_params; 787 ChangedSendParameters changed_params;
787 if (!GetChangedSendParameters(params, &changed_params)) { 788 if (!GetChangedSendParameters(params, &changed_params)) {
788 return false; 789 return false;
789 } 790 }
790 791
791 if (changed_params.codec) { 792 if (changed_params.codec) {
792 const VideoCodecSettings& codec_settings = *changed_params.codec; 793 const VideoCodecSettings& codec_settings = *changed_params.codec;
793 send_codec_ = rtc::Optional<VideoCodecSettings>(codec_settings); 794 send_codec_ = rtc::Optional<VideoCodecSettings>(codec_settings);
794 LOG(LS_INFO) << "Using codec: " << codec_settings.codec.ToString(); 795 LOG(LS_INFO) << "Using codec: " << codec_settings.codec.ToString();
(...skipping 21 matching lines...) Expand all
816 // If the codec isn't changing, set the start bitrate to -1 which means 817 // If the codec isn't changing, set the start bitrate to -1 which means
817 // "unchanged" so that BWE isn't affected. 818 // "unchanged" so that BWE isn't affected.
818 bitrate_config_.start_bitrate_bps = -1; 819 bitrate_config_.start_bitrate_bps = -1;
819 } 820 }
820 } 821 }
821 if (params.max_bandwidth_bps >= 0) { 822 if (params.max_bandwidth_bps >= 0) {
822 // Note that max_bandwidth_bps intentionally takes priority over the 823 // Note that max_bandwidth_bps intentionally takes priority over the
823 // bitrate config for the codec. This allows FEC to be applied above the 824 // bitrate config for the codec. This allows FEC to be applied above the
824 // codec target bitrate. 825 // codec target bitrate.
825 // TODO(pbos): Figure out whether b=AS means max bitrate for this 826 // TODO(pbos): Figure out whether b=AS means max bitrate for this
826 // WebRtcVideoChannel2 (in which case we're good), or per sender (SSRC), 827 // WebRtcVideoChannel (in which case we're good), or per sender (SSRC),
827 // in which case this should not set a Call::BitrateConfig but rather 828 // in which case this should not set a Call::BitrateConfig but rather
828 // reconfigure all senders. 829 // reconfigure all senders.
829 bitrate_config_.max_bitrate_bps = 830 bitrate_config_.max_bitrate_bps =
830 params.max_bandwidth_bps == 0 ? -1 : params.max_bandwidth_bps; 831 params.max_bandwidth_bps == 0 ? -1 : params.max_bandwidth_bps;
831 } 832 }
832 call_->SetBitrateConfig(bitrate_config_); 833 call_->SetBitrateConfig(bitrate_config_);
833 } 834 }
834 835
835 { 836 {
836 rtc::CritScope stream_lock(&stream_crit_); 837 rtc::CritScope stream_lock(&stream_crit_);
(...skipping 12 matching lines...) Expand all
849 HasTransportCc(send_codec_->codec), 850 HasTransportCc(send_codec_->codec),
850 params.rtcp.reduced_size ? webrtc::RtcpMode::kReducedSize 851 params.rtcp.reduced_size ? webrtc::RtcpMode::kReducedSize
851 : webrtc::RtcpMode::kCompound); 852 : webrtc::RtcpMode::kCompound);
852 } 853 }
853 } 854 }
854 } 855 }
855 send_params_ = params; 856 send_params_ = params;
856 return true; 857 return true;
857 } 858 }
858 859
859 webrtc::RtpParameters WebRtcVideoChannel2::GetRtpSendParameters( 860 webrtc::RtpParameters WebRtcVideoChannel::GetRtpSendParameters(
860 uint32_t ssrc) const { 861 uint32_t ssrc) const {
861 rtc::CritScope stream_lock(&stream_crit_); 862 rtc::CritScope stream_lock(&stream_crit_);
862 auto it = send_streams_.find(ssrc); 863 auto it = send_streams_.find(ssrc);
863 if (it == send_streams_.end()) { 864 if (it == send_streams_.end()) {
864 LOG(LS_WARNING) << "Attempting to get RTP send parameters for stream " 865 LOG(LS_WARNING) << "Attempting to get RTP send parameters for stream "
865 << "with ssrc " << ssrc << " which doesn't exist."; 866 << "with ssrc " << ssrc << " which doesn't exist.";
866 return webrtc::RtpParameters(); 867 return webrtc::RtpParameters();
867 } 868 }
868 869
869 webrtc::RtpParameters rtp_params = it->second->GetRtpParameters(); 870 webrtc::RtpParameters rtp_params = it->second->GetRtpParameters();
870 // Need to add the common list of codecs to the send stream-specific 871 // Need to add the common list of codecs to the send stream-specific
871 // RTP parameters. 872 // RTP parameters.
872 for (const VideoCodec& codec : send_params_.codecs) { 873 for (const VideoCodec& codec : send_params_.codecs) {
873 rtp_params.codecs.push_back(codec.ToCodecParameters()); 874 rtp_params.codecs.push_back(codec.ToCodecParameters());
874 } 875 }
875 return rtp_params; 876 return rtp_params;
876 } 877 }
877 878
878 bool WebRtcVideoChannel2::SetRtpSendParameters( 879 bool WebRtcVideoChannel::SetRtpSendParameters(
879 uint32_t ssrc, 880 uint32_t ssrc,
880 const webrtc::RtpParameters& parameters) { 881 const webrtc::RtpParameters& parameters) {
881 TRACE_EVENT0("webrtc", "WebRtcVideoChannel2::SetRtpSendParameters"); 882 TRACE_EVENT0("webrtc", "WebRtcVideoChannel::SetRtpSendParameters");
882 rtc::CritScope stream_lock(&stream_crit_); 883 rtc::CritScope stream_lock(&stream_crit_);
883 auto it = send_streams_.find(ssrc); 884 auto it = send_streams_.find(ssrc);
884 if (it == send_streams_.end()) { 885 if (it == send_streams_.end()) {
885 LOG(LS_ERROR) << "Attempting to set RTP send parameters for stream " 886 LOG(LS_ERROR) << "Attempting to set RTP send parameters for stream "
886 << "with ssrc " << ssrc << " which doesn't exist."; 887 << "with ssrc " << ssrc << " which doesn't exist.";
887 return false; 888 return false;
888 } 889 }
889 890
890 // TODO(deadbeef): Handle setting parameters with a list of codecs in a 891 // TODO(deadbeef): Handle setting parameters with a list of codecs in a
891 // different order (which should change the send codec). 892 // different order (which should change the send codec).
892 webrtc::RtpParameters current_parameters = GetRtpSendParameters(ssrc); 893 webrtc::RtpParameters current_parameters = GetRtpSendParameters(ssrc);
893 if (current_parameters.codecs != parameters.codecs) { 894 if (current_parameters.codecs != parameters.codecs) {
894 LOG(LS_ERROR) << "Using SetParameters to change the set of codecs " 895 LOG(LS_ERROR) << "Using SetParameters to change the set of codecs "
895 << "is not currently supported."; 896 << "is not currently supported.";
896 return false; 897 return false;
897 } 898 }
898 899
899 return it->second->SetRtpParameters(parameters); 900 return it->second->SetRtpParameters(parameters);
900 } 901 }
901 902
902 webrtc::RtpParameters WebRtcVideoChannel2::GetRtpReceiveParameters( 903 webrtc::RtpParameters WebRtcVideoChannel::GetRtpReceiveParameters(
903 uint32_t ssrc) const { 904 uint32_t ssrc) const {
904 webrtc::RtpParameters rtp_params; 905 webrtc::RtpParameters rtp_params;
905 rtc::CritScope stream_lock(&stream_crit_); 906 rtc::CritScope stream_lock(&stream_crit_);
906 // SSRC of 0 represents an unsignaled receive stream. 907 // SSRC of 0 represents an unsignaled receive stream.
907 if (ssrc == 0) { 908 if (ssrc == 0) {
908 if (!default_unsignalled_ssrc_handler_.GetDefaultSink()) { 909 if (!default_unsignalled_ssrc_handler_.GetDefaultSink()) {
909 LOG(LS_WARNING) << "Attempting to get RTP parameters for the default, " 910 LOG(LS_WARNING) << "Attempting to get RTP parameters for the default, "
910 "unsignaled video receive stream, but not yet " 911 "unsignaled video receive stream, but not yet "
911 "configured to receive such a stream."; 912 "configured to receive such a stream.";
912 return rtp_params; 913 return rtp_params;
(...skipping 11 matching lines...) Expand all
924 rtp_params.encodings[0].ssrc = it->second->GetFirstPrimarySsrc(); 925 rtp_params.encodings[0].ssrc = it->second->GetFirstPrimarySsrc();
925 } 926 }
926 927
927 // Add codecs, which any stream is prepared to receive. 928 // Add codecs, which any stream is prepared to receive.
928 for (const VideoCodec& codec : recv_params_.codecs) { 929 for (const VideoCodec& codec : recv_params_.codecs) {
929 rtp_params.codecs.push_back(codec.ToCodecParameters()); 930 rtp_params.codecs.push_back(codec.ToCodecParameters());
930 } 931 }
931 return rtp_params; 932 return rtp_params;
932 } 933 }
933 934
934 bool WebRtcVideoChannel2::SetRtpReceiveParameters( 935 bool WebRtcVideoChannel::SetRtpReceiveParameters(
935 uint32_t ssrc, 936 uint32_t ssrc,
936 const webrtc::RtpParameters& parameters) { 937 const webrtc::RtpParameters& parameters) {
937 TRACE_EVENT0("webrtc", "WebRtcVideoChannel2::SetRtpReceiveParameters"); 938 TRACE_EVENT0("webrtc", "WebRtcVideoChannel::SetRtpReceiveParameters");
938 rtc::CritScope stream_lock(&stream_crit_); 939 rtc::CritScope stream_lock(&stream_crit_);
939 940
940 // SSRC of 0 represents an unsignaled receive stream. 941 // SSRC of 0 represents an unsignaled receive stream.
941 if (ssrc == 0) { 942 if (ssrc == 0) {
942 if (!default_unsignalled_ssrc_handler_.GetDefaultSink()) { 943 if (!default_unsignalled_ssrc_handler_.GetDefaultSink()) {
943 LOG(LS_WARNING) << "Attempting to set RTP parameters for the default, " 944 LOG(LS_WARNING) << "Attempting to set RTP parameters for the default, "
944 "unsignaled video receive stream, but not yet " 945 "unsignaled video receive stream, but not yet "
945 "configured to receive such a stream."; 946 "configured to receive such a stream.";
946 return false; 947 return false;
947 } 948 }
948 } else { 949 } else {
949 auto it = receive_streams_.find(ssrc); 950 auto it = receive_streams_.find(ssrc);
950 if (it == receive_streams_.end()) { 951 if (it == receive_streams_.end()) {
951 LOG(LS_WARNING) << "Attempting to set RTP receive parameters for stream " 952 LOG(LS_WARNING) << "Attempting to set RTP receive parameters for stream "
952 << "with SSRC " << ssrc << " which doesn't exist."; 953 << "with SSRC " << ssrc << " which doesn't exist.";
953 return false; 954 return false;
954 } 955 }
955 } 956 }
956 957
957 webrtc::RtpParameters current_parameters = GetRtpReceiveParameters(ssrc); 958 webrtc::RtpParameters current_parameters = GetRtpReceiveParameters(ssrc);
958 if (current_parameters != parameters) { 959 if (current_parameters != parameters) {
959 LOG(LS_ERROR) << "Changing the RTP receive parameters is currently " 960 LOG(LS_ERROR) << "Changing the RTP receive parameters is currently "
960 << "unsupported."; 961 << "unsupported.";
961 return false; 962 return false;
962 } 963 }
963 return true; 964 return true;
964 } 965 }
965 966
966 bool WebRtcVideoChannel2::GetChangedRecvParameters( 967 bool WebRtcVideoChannel::GetChangedRecvParameters(
967 const VideoRecvParameters& params, 968 const VideoRecvParameters& params,
968 ChangedRecvParameters* changed_params) const { 969 ChangedRecvParameters* changed_params) const {
969 if (!ValidateCodecFormats(params.codecs) || 970 if (!ValidateCodecFormats(params.codecs) ||
970 !ValidateRtpExtensions(params.extensions)) { 971 !ValidateRtpExtensions(params.extensions)) {
971 return false; 972 return false;
972 } 973 }
973 974
974 // Handle receive codecs. 975 // Handle receive codecs.
975 const std::vector<VideoCodecSettings> mapped_codecs = 976 const std::vector<VideoCodecSettings> mapped_codecs =
976 MapCodecs(params.codecs); 977 MapCodecs(params.codecs);
(...skipping 28 matching lines...) Expand all
1005 1006
1006 int flexfec_payload_type = mapped_codecs.front().flexfec_payload_type; 1007 int flexfec_payload_type = mapped_codecs.front().flexfec_payload_type;
1007 if (flexfec_payload_type != recv_flexfec_payload_type_) { 1008 if (flexfec_payload_type != recv_flexfec_payload_type_) {
1008 changed_params->flexfec_payload_type = 1009 changed_params->flexfec_payload_type =
1009 rtc::Optional<int>(flexfec_payload_type); 1010 rtc::Optional<int>(flexfec_payload_type);
1010 } 1011 }
1011 1012
1012 return true; 1013 return true;
1013 } 1014 }
1014 1015
1015 bool WebRtcVideoChannel2::SetRecvParameters(const VideoRecvParameters& params) { 1016 bool WebRtcVideoChannel::SetRecvParameters(const VideoRecvParameters& params) {
1016 TRACE_EVENT0("webrtc", "WebRtcVideoChannel2::SetRecvParameters"); 1017 TRACE_EVENT0("webrtc", "WebRtcVideoChannel::SetRecvParameters");
1017 LOG(LS_INFO) << "SetRecvParameters: " << params.ToString(); 1018 LOG(LS_INFO) << "SetRecvParameters: " << params.ToString();
1018 ChangedRecvParameters changed_params; 1019 ChangedRecvParameters changed_params;
1019 if (!GetChangedRecvParameters(params, &changed_params)) { 1020 if (!GetChangedRecvParameters(params, &changed_params)) {
1020 return false; 1021 return false;
1021 } 1022 }
1022 if (changed_params.flexfec_payload_type) { 1023 if (changed_params.flexfec_payload_type) {
1023 LOG(LS_INFO) << "Changing FlexFEC payload type (recv) from " 1024 LOG(LS_INFO) << "Changing FlexFEC payload type (recv) from "
1024 << recv_flexfec_payload_type_ << " to " 1025 << recv_flexfec_payload_type_ << " to "
1025 << *changed_params.flexfec_payload_type; 1026 << *changed_params.flexfec_payload_type;
1026 recv_flexfec_payload_type_ = *changed_params.flexfec_payload_type; 1027 recv_flexfec_payload_type_ = *changed_params.flexfec_payload_type;
(...skipping 11 matching lines...) Expand all
1038 { 1039 {
1039 rtc::CritScope stream_lock(&stream_crit_); 1040 rtc::CritScope stream_lock(&stream_crit_);
1040 for (auto& kv : receive_streams_) { 1041 for (auto& kv : receive_streams_) {
1041 kv.second->SetRecvParameters(changed_params); 1042 kv.second->SetRecvParameters(changed_params);
1042 } 1043 }
1043 } 1044 }
1044 recv_params_ = params; 1045 recv_params_ = params;
1045 return true; 1046 return true;
1046 } 1047 }
1047 1048
1048 std::string WebRtcVideoChannel2::CodecSettingsVectorToString( 1049 std::string WebRtcVideoChannel::CodecSettingsVectorToString(
1049 const std::vector<VideoCodecSettings>& codecs) { 1050 const std::vector<VideoCodecSettings>& codecs) {
1050 std::stringstream out; 1051 std::stringstream out;
1051 out << '{'; 1052 out << '{';
1052 for (size_t i = 0; i < codecs.size(); ++i) { 1053 for (size_t i = 0; i < codecs.size(); ++i) {
1053 out << codecs[i].codec.ToString(); 1054 out << codecs[i].codec.ToString();
1054 if (i != codecs.size() - 1) { 1055 if (i != codecs.size() - 1) {
1055 out << ", "; 1056 out << ", ";
1056 } 1057 }
1057 } 1058 }
1058 out << '}'; 1059 out << '}';
1059 return out.str(); 1060 return out.str();
1060 } 1061 }
1061 1062
1062 bool WebRtcVideoChannel2::GetSendCodec(VideoCodec* codec) { 1063 bool WebRtcVideoChannel::GetSendCodec(VideoCodec* codec) {
1063 if (!send_codec_) { 1064 if (!send_codec_) {
1064 LOG(LS_VERBOSE) << "GetSendCodec: No send codec set."; 1065 LOG(LS_VERBOSE) << "GetSendCodec: No send codec set.";
1065 return false; 1066 return false;
1066 } 1067 }
1067 *codec = send_codec_->codec; 1068 *codec = send_codec_->codec;
1068 return true; 1069 return true;
1069 } 1070 }
1070 1071
1071 bool WebRtcVideoChannel2::SetSend(bool send) { 1072 bool WebRtcVideoChannel::SetSend(bool send) {
1072 TRACE_EVENT0("webrtc", "WebRtcVideoChannel2::SetSend"); 1073 TRACE_EVENT0("webrtc", "WebRtcVideoChannel::SetSend");
1073 LOG(LS_VERBOSE) << "SetSend: " << (send ? "true" : "false"); 1074 LOG(LS_VERBOSE) << "SetSend: " << (send ? "true" : "false");
1074 if (send && !send_codec_) { 1075 if (send && !send_codec_) {
1075 LOG(LS_ERROR) << "SetSend(true) called before setting codec."; 1076 LOG(LS_ERROR) << "SetSend(true) called before setting codec.";
1076 return false; 1077 return false;
1077 } 1078 }
1078 { 1079 {
1079 rtc::CritScope stream_lock(&stream_crit_); 1080 rtc::CritScope stream_lock(&stream_crit_);
1080 for (const auto& kv : send_streams_) { 1081 for (const auto& kv : send_streams_) {
1081 kv.second->SetSend(send); 1082 kv.second->SetSend(send);
1082 } 1083 }
1083 } 1084 }
1084 sending_ = send; 1085 sending_ = send;
1085 return true; 1086 return true;
1086 } 1087 }
1087 1088
1088 // TODO(nisse): The enable argument was used for mute logic which has 1089 // TODO(nisse): The enable argument was used for mute logic which has
1089 // been moved to VideoBroadcaster. So remove the argument from this 1090 // been moved to VideoBroadcaster. So remove the argument from this
1090 // method. 1091 // method.
1091 bool WebRtcVideoChannel2::SetVideoSend( 1092 bool WebRtcVideoChannel::SetVideoSend(
1092 uint32_t ssrc, 1093 uint32_t ssrc,
1093 bool enable, 1094 bool enable,
1094 const VideoOptions* options, 1095 const VideoOptions* options,
1095 rtc::VideoSourceInterface<webrtc::VideoFrame>* source) { 1096 rtc::VideoSourceInterface<webrtc::VideoFrame>* source) {
1096 TRACE_EVENT0("webrtc", "SetVideoSend"); 1097 TRACE_EVENT0("webrtc", "SetVideoSend");
1097 RTC_DCHECK(ssrc != 0); 1098 RTC_DCHECK(ssrc != 0);
1098 LOG(LS_INFO) << "SetVideoSend (ssrc= " << ssrc << ", enable = " << enable 1099 LOG(LS_INFO) << "SetVideoSend (ssrc= " << ssrc << ", enable = " << enable
1099 << ", options: " << (options ? options->ToString() : "nullptr") 1100 << ", options: " << (options ? options->ToString() : "nullptr")
1100 << ", source = " << (source ? "(source)" : "nullptr") << ")"; 1101 << ", source = " << (source ? "(source)" : "nullptr") << ")";
1101 1102
1102 rtc::CritScope stream_lock(&stream_crit_); 1103 rtc::CritScope stream_lock(&stream_crit_);
1103 const auto& kv = send_streams_.find(ssrc); 1104 const auto& kv = send_streams_.find(ssrc);
1104 if (kv == send_streams_.end()) { 1105 if (kv == send_streams_.end()) {
1105 // Allow unknown ssrc only if source is null. 1106 // Allow unknown ssrc only if source is null.
1106 RTC_CHECK(source == nullptr); 1107 RTC_CHECK(source == nullptr);
1107 LOG(LS_ERROR) << "No sending stream on ssrc " << ssrc; 1108 LOG(LS_ERROR) << "No sending stream on ssrc " << ssrc;
1108 return false; 1109 return false;
1109 } 1110 }
1110 1111
1111 return kv->second->SetVideoSend(enable, options, source); 1112 return kv->second->SetVideoSend(enable, options, source);
1112 } 1113 }
1113 1114
1114 bool WebRtcVideoChannel2::ValidateSendSsrcAvailability( 1115 bool WebRtcVideoChannel::ValidateSendSsrcAvailability(
1115 const StreamParams& sp) const { 1116 const StreamParams& sp) const {
1116 for (uint32_t ssrc : sp.ssrcs) { 1117 for (uint32_t ssrc : sp.ssrcs) {
1117 if (send_ssrcs_.find(ssrc) != send_ssrcs_.end()) { 1118 if (send_ssrcs_.find(ssrc) != send_ssrcs_.end()) {
1118 LOG(LS_ERROR) << "Send stream with SSRC '" << ssrc << "' already exists."; 1119 LOG(LS_ERROR) << "Send stream with SSRC '" << ssrc << "' already exists.";
1119 return false; 1120 return false;
1120 } 1121 }
1121 } 1122 }
1122 return true; 1123 return true;
1123 } 1124 }
1124 1125
1125 bool WebRtcVideoChannel2::ValidateReceiveSsrcAvailability( 1126 bool WebRtcVideoChannel::ValidateReceiveSsrcAvailability(
1126 const StreamParams& sp) const { 1127 const StreamParams& sp) const {
1127 for (uint32_t ssrc : sp.ssrcs) { 1128 for (uint32_t ssrc : sp.ssrcs) {
1128 if (receive_ssrcs_.find(ssrc) != receive_ssrcs_.end()) { 1129 if (receive_ssrcs_.find(ssrc) != receive_ssrcs_.end()) {
1129 LOG(LS_ERROR) << "Receive stream with SSRC '" << ssrc 1130 LOG(LS_ERROR) << "Receive stream with SSRC '" << ssrc
1130 << "' already exists."; 1131 << "' already exists.";
1131 return false; 1132 return false;
1132 } 1133 }
1133 } 1134 }
1134 return true; 1135 return true;
1135 } 1136 }
1136 1137
1137 bool WebRtcVideoChannel2::AddSendStream(const StreamParams& sp) { 1138 bool WebRtcVideoChannel::AddSendStream(const StreamParams& sp) {
1138 LOG(LS_INFO) << "AddSendStream: " << sp.ToString(); 1139 LOG(LS_INFO) << "AddSendStream: " << sp.ToString();
1139 if (!ValidateStreamParams(sp)) 1140 if (!ValidateStreamParams(sp))
1140 return false; 1141 return false;
1141 1142
1142 rtc::CritScope stream_lock(&stream_crit_); 1143 rtc::CritScope stream_lock(&stream_crit_);
1143 1144
1144 if (!ValidateSendSsrcAvailability(sp)) 1145 if (!ValidateSendSsrcAvailability(sp))
1145 return false; 1146 return false;
1146 1147
1147 for (uint32_t used_ssrc : sp.ssrcs) 1148 for (uint32_t used_ssrc : sp.ssrcs)
(...skipping 20 matching lines...) Expand all
1168 for (auto& kv : receive_streams_) 1169 for (auto& kv : receive_streams_)
1169 kv.second->SetLocalSsrc(ssrc); 1170 kv.second->SetLocalSsrc(ssrc);
1170 } 1171 }
1171 if (sending_) { 1172 if (sending_) {
1172 stream->SetSend(true); 1173 stream->SetSend(true);
1173 } 1174 }
1174 1175
1175 return true; 1176 return true;
1176 } 1177 }
1177 1178
1178 bool WebRtcVideoChannel2::RemoveSendStream(uint32_t ssrc) { 1179 bool WebRtcVideoChannel::RemoveSendStream(uint32_t ssrc) {
1179 LOG(LS_INFO) << "RemoveSendStream: " << ssrc; 1180 LOG(LS_INFO) << "RemoveSendStream: " << ssrc;
1180 1181
1181 WebRtcVideoSendStream* removed_stream; 1182 WebRtcVideoSendStream* removed_stream;
1182 { 1183 {
1183 rtc::CritScope stream_lock(&stream_crit_); 1184 rtc::CritScope stream_lock(&stream_crit_);
1184 std::map<uint32_t, WebRtcVideoSendStream*>::iterator it = 1185 std::map<uint32_t, WebRtcVideoSendStream*>::iterator it =
1185 send_streams_.find(ssrc); 1186 send_streams_.find(ssrc);
1186 if (it == send_streams_.end()) { 1187 if (it == send_streams_.end()) {
1187 return false; 1188 return false;
1188 } 1189 }
(...skipping 16 matching lines...) Expand all
1205 kv.second->SetLocalSsrc(rtcp_receiver_report_ssrc_); 1206 kv.second->SetLocalSsrc(rtcp_receiver_report_ssrc_);
1206 } 1207 }
1207 } 1208 }
1208 } 1209 }
1209 1210
1210 delete removed_stream; 1211 delete removed_stream;
1211 1212
1212 return true; 1213 return true;
1213 } 1214 }
1214 1215
1215 void WebRtcVideoChannel2::DeleteReceiveStream( 1216 void WebRtcVideoChannel::DeleteReceiveStream(
1216 WebRtcVideoChannel2::WebRtcVideoReceiveStream* stream) { 1217 WebRtcVideoChannel::WebRtcVideoReceiveStream* stream) {
1217 for (uint32_t old_ssrc : stream->GetSsrcs()) 1218 for (uint32_t old_ssrc : stream->GetSsrcs())
1218 receive_ssrcs_.erase(old_ssrc); 1219 receive_ssrcs_.erase(old_ssrc);
1219 delete stream; 1220 delete stream;
1220 } 1221 }
1221 1222
1222 bool WebRtcVideoChannel2::AddRecvStream(const StreamParams& sp) { 1223 bool WebRtcVideoChannel::AddRecvStream(const StreamParams& sp) {
1223 return AddRecvStream(sp, false); 1224 return AddRecvStream(sp, false);
1224 } 1225 }
1225 1226
1226 bool WebRtcVideoChannel2::AddRecvStream(const StreamParams& sp, 1227 bool WebRtcVideoChannel::AddRecvStream(const StreamParams& sp,
1227 bool default_stream) { 1228 bool default_stream) {
1228 RTC_DCHECK(thread_checker_.CalledOnValidThread()); 1229 RTC_DCHECK(thread_checker_.CalledOnValidThread());
1229 1230
1230 LOG(LS_INFO) << "AddRecvStream" << (default_stream ? " (default stream)" : "") 1231 LOG(LS_INFO) << "AddRecvStream" << (default_stream ? " (default stream)" : "")
1231 << ": " << sp.ToString(); 1232 << ": " << sp.ToString();
1232 if (!ValidateStreamParams(sp)) 1233 if (!ValidateStreamParams(sp))
1233 return false; 1234 return false;
1234 1235
1235 uint32_t ssrc = sp.first_ssrc(); 1236 uint32_t ssrc = sp.first_ssrc();
1236 RTC_DCHECK(ssrc != 0); // TODO(pbos): Is this ever valid? 1237 RTC_DCHECK(ssrc != 0); // TODO(pbos): Is this ever valid?
1237 1238
(...skipping 24 matching lines...) Expand all
1262 video_config_.disable_prerenderer_smoothing; 1263 video_config_.disable_prerenderer_smoothing;
1263 config.sync_group = sp.sync_label; 1264 config.sync_group = sp.sync_label;
1264 1265
1265 receive_streams_[ssrc] = new WebRtcVideoReceiveStream( 1266 receive_streams_[ssrc] = new WebRtcVideoReceiveStream(
1266 call_, sp, std::move(config), external_decoder_factory_, default_stream, 1267 call_, sp, std::move(config), external_decoder_factory_, default_stream,
1267 recv_codecs_, flexfec_config); 1268 recv_codecs_, flexfec_config);
1268 1269
1269 return true; 1270 return true;
1270 } 1271 }
1271 1272
1272 void WebRtcVideoChannel2::ConfigureReceiverRtp( 1273 void WebRtcVideoChannel::ConfigureReceiverRtp(
1273 webrtc::VideoReceiveStream::Config* config, 1274 webrtc::VideoReceiveStream::Config* config,
1274 webrtc::FlexfecReceiveStream::Config* flexfec_config, 1275 webrtc::FlexfecReceiveStream::Config* flexfec_config,
1275 const StreamParams& sp) const { 1276 const StreamParams& sp) const {
1276 uint32_t ssrc = sp.first_ssrc(); 1277 uint32_t ssrc = sp.first_ssrc();
1277 1278
1278 config->rtp.remote_ssrc = ssrc; 1279 config->rtp.remote_ssrc = ssrc;
1279 config->rtp.local_ssrc = rtcp_receiver_report_ssrc_; 1280 config->rtp.local_ssrc = rtcp_receiver_report_ssrc_;
1280 1281
1281 // TODO(pbos): This protection is against setting the same local ssrc as 1282 // TODO(pbos): This protection is against setting the same local ssrc as
1282 // remote which is not permitted by the lower-level API. RTCP requires a 1283 // remote which is not permitted by the lower-level API. RTCP requires a
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after
1314 flexfec_config->protected_media_ssrcs = {ssrc}; 1315 flexfec_config->protected_media_ssrcs = {ssrc};
1315 flexfec_config->local_ssrc = config->rtp.local_ssrc; 1316 flexfec_config->local_ssrc = config->rtp.local_ssrc;
1316 flexfec_config->rtcp_mode = config->rtp.rtcp_mode; 1317 flexfec_config->rtcp_mode = config->rtp.rtcp_mode;
1317 // TODO(brandtr): We should be spec-compliant and set |transport_cc| here 1318 // TODO(brandtr): We should be spec-compliant and set |transport_cc| here
1318 // based on the rtcp-fb for the FlexFEC codec, not the media codec. 1319 // based on the rtcp-fb for the FlexFEC codec, not the media codec.
1319 flexfec_config->transport_cc = config->rtp.transport_cc; 1320 flexfec_config->transport_cc = config->rtp.transport_cc;
1320 flexfec_config->rtp_header_extensions = config->rtp.extensions; 1321 flexfec_config->rtp_header_extensions = config->rtp.extensions;
1321 } 1322 }
1322 } 1323 }
1323 1324
1324 bool WebRtcVideoChannel2::RemoveRecvStream(uint32_t ssrc) { 1325 bool WebRtcVideoChannel::RemoveRecvStream(uint32_t ssrc) {
1325 LOG(LS_INFO) << "RemoveRecvStream: " << ssrc; 1326 LOG(LS_INFO) << "RemoveRecvStream: " << ssrc;
1326 if (ssrc == 0) { 1327 if (ssrc == 0) {
1327 LOG(LS_ERROR) << "RemoveRecvStream with 0 ssrc is not supported."; 1328 LOG(LS_ERROR) << "RemoveRecvStream with 0 ssrc is not supported.";
1328 return false; 1329 return false;
1329 } 1330 }
1330 1331
1331 rtc::CritScope stream_lock(&stream_crit_); 1332 rtc::CritScope stream_lock(&stream_crit_);
1332 std::map<uint32_t, WebRtcVideoReceiveStream*>::iterator stream = 1333 std::map<uint32_t, WebRtcVideoReceiveStream*>::iterator stream =
1333 receive_streams_.find(ssrc); 1334 receive_streams_.find(ssrc);
1334 if (stream == receive_streams_.end()) { 1335 if (stream == receive_streams_.end()) {
1335 LOG(LS_ERROR) << "Stream not found for ssrc: " << ssrc; 1336 LOG(LS_ERROR) << "Stream not found for ssrc: " << ssrc;
1336 return false; 1337 return false;
1337 } 1338 }
1338 DeleteReceiveStream(stream->second); 1339 DeleteReceiveStream(stream->second);
1339 receive_streams_.erase(stream); 1340 receive_streams_.erase(stream);
1340 1341
1341 return true; 1342 return true;
1342 } 1343 }
1343 1344
1344 bool WebRtcVideoChannel2::SetSink( 1345 bool WebRtcVideoChannel::SetSink(
1345 uint32_t ssrc, 1346 uint32_t ssrc,
1346 rtc::VideoSinkInterface<webrtc::VideoFrame>* sink) { 1347 rtc::VideoSinkInterface<webrtc::VideoFrame>* sink) {
1347 LOG(LS_INFO) << "SetSink: ssrc:" << ssrc << " " 1348 LOG(LS_INFO) << "SetSink: ssrc:" << ssrc << " "
1348 << (sink ? "(ptr)" : "nullptr"); 1349 << (sink ? "(ptr)" : "nullptr");
1349 if (ssrc == 0) { 1350 if (ssrc == 0) {
1350 // Do not hold |stream_crit_| here, since SetDefaultSink will call 1351 // Do not hold |stream_crit_| here, since SetDefaultSink will call
1351 // WebRtcVideoChannel2::GetDefaultReceiveStreamSsrc(). 1352 // WebRtcVideoChannel::GetDefaultReceiveStreamSsrc().
1352 default_unsignalled_ssrc_handler_.SetDefaultSink(this, sink); 1353 default_unsignalled_ssrc_handler_.SetDefaultSink(this, sink);
1353 return true; 1354 return true;
1354 } 1355 }
1355 1356
1356 rtc::CritScope stream_lock(&stream_crit_); 1357 rtc::CritScope stream_lock(&stream_crit_);
1357 std::map<uint32_t, WebRtcVideoReceiveStream*>::iterator it = 1358 std::map<uint32_t, WebRtcVideoReceiveStream*>::iterator it =
1358 receive_streams_.find(ssrc); 1359 receive_streams_.find(ssrc);
1359 if (it == receive_streams_.end()) { 1360 if (it == receive_streams_.end()) {
1360 return false; 1361 return false;
1361 } 1362 }
1362 1363
1363 it->second->SetSink(sink); 1364 it->second->SetSink(sink);
1364 return true; 1365 return true;
1365 } 1366 }
1366 1367
1367 bool WebRtcVideoChannel2::GetStats(VideoMediaInfo* info) { 1368 bool WebRtcVideoChannel::GetStats(VideoMediaInfo* info) {
1368 TRACE_EVENT0("webrtc", "WebRtcVideoChannel2::GetStats"); 1369 TRACE_EVENT0("webrtc", "WebRtcVideoChannel::GetStats");
1369 1370
1370 // Log stats periodically. 1371 // Log stats periodically.
1371 bool log_stats = false; 1372 bool log_stats = false;
1372 int64_t now_ms = rtc::TimeMillis(); 1373 int64_t now_ms = rtc::TimeMillis();
1373 if (last_stats_log_ms_ == -1 || 1374 if (last_stats_log_ms_ == -1 ||
1374 now_ms - last_stats_log_ms_ > kStatsLogIntervalMs) { 1375 now_ms - last_stats_log_ms_ > kStatsLogIntervalMs) {
1375 last_stats_log_ms_ = now_ms; 1376 last_stats_log_ms_ = now_ms;
1376 log_stats = true; 1377 log_stats = true;
1377 } 1378 }
1378 1379
1379 info->Clear(); 1380 info->Clear();
1380 FillSenderStats(info, log_stats); 1381 FillSenderStats(info, log_stats);
1381 FillReceiverStats(info, log_stats); 1382 FillReceiverStats(info, log_stats);
1382 FillSendAndReceiveCodecStats(info); 1383 FillSendAndReceiveCodecStats(info);
1383 // TODO(holmer): We should either have rtt available as a metric on 1384 // TODO(holmer): We should either have rtt available as a metric on
1384 // VideoSend/ReceiveStreams, or we should remove rtt from VideoSenderInfo. 1385 // VideoSend/ReceiveStreams, or we should remove rtt from VideoSenderInfo.
1385 webrtc::Call::Stats stats = call_->GetStats(); 1386 webrtc::Call::Stats stats = call_->GetStats();
1386 if (stats.rtt_ms != -1) { 1387 if (stats.rtt_ms != -1) {
1387 for (size_t i = 0; i < info->senders.size(); ++i) { 1388 for (size_t i = 0; i < info->senders.size(); ++i) {
1388 info->senders[i].rtt_ms = stats.rtt_ms; 1389 info->senders[i].rtt_ms = stats.rtt_ms;
1389 } 1390 }
1390 } 1391 }
1391 1392
1392 if (log_stats) 1393 if (log_stats)
1393 LOG(LS_INFO) << stats.ToString(now_ms); 1394 LOG(LS_INFO) << stats.ToString(now_ms);
1394 1395
1395 return true; 1396 return true;
1396 } 1397 }
1397 1398
1398 void WebRtcVideoChannel2::FillSenderStats(VideoMediaInfo* video_media_info, 1399 void WebRtcVideoChannel::FillSenderStats(VideoMediaInfo* video_media_info,
1399 bool log_stats) { 1400 bool log_stats) {
1400 rtc::CritScope stream_lock(&stream_crit_); 1401 rtc::CritScope stream_lock(&stream_crit_);
1401 for (std::map<uint32_t, WebRtcVideoSendStream*>::iterator it = 1402 for (std::map<uint32_t, WebRtcVideoSendStream*>::iterator it =
1402 send_streams_.begin(); 1403 send_streams_.begin();
1403 it != send_streams_.end(); ++it) { 1404 it != send_streams_.end(); ++it) {
1404 video_media_info->senders.push_back( 1405 video_media_info->senders.push_back(
1405 it->second->GetVideoSenderInfo(log_stats)); 1406 it->second->GetVideoSenderInfo(log_stats));
1406 } 1407 }
1407 } 1408 }
1408 1409
1409 void WebRtcVideoChannel2::FillReceiverStats(VideoMediaInfo* video_media_info, 1410 void WebRtcVideoChannel::FillReceiverStats(VideoMediaInfo* video_media_info,
1410 bool log_stats) { 1411 bool log_stats) {
1411 rtc::CritScope stream_lock(&stream_crit_); 1412 rtc::CritScope stream_lock(&stream_crit_);
1412 for (std::map<uint32_t, WebRtcVideoReceiveStream*>::iterator it = 1413 for (std::map<uint32_t, WebRtcVideoReceiveStream*>::iterator it =
1413 receive_streams_.begin(); 1414 receive_streams_.begin();
1414 it != receive_streams_.end(); ++it) { 1415 it != receive_streams_.end(); ++it) {
1415 video_media_info->receivers.push_back( 1416 video_media_info->receivers.push_back(
1416 it->second->GetVideoReceiverInfo(log_stats)); 1417 it->second->GetVideoReceiverInfo(log_stats));
1417 } 1418 }
1418 } 1419 }
1419 1420
1420 void WebRtcVideoChannel2::FillBitrateInfo(BandwidthEstimationInfo* bwe_info) { 1421 void WebRtcVideoChannel::FillBitrateInfo(BandwidthEstimationInfo* bwe_info) {
1421 rtc::CritScope stream_lock(&stream_crit_); 1422 rtc::CritScope stream_lock(&stream_crit_);
1422 for (std::map<uint32_t, WebRtcVideoSendStream*>::iterator stream = 1423 for (std::map<uint32_t, WebRtcVideoSendStream*>::iterator stream =
1423 send_streams_.begin(); 1424 send_streams_.begin();
1424 stream != send_streams_.end(); ++stream) { 1425 stream != send_streams_.end(); ++stream) {
1425 stream->second->FillBitrateInfo(bwe_info); 1426 stream->second->FillBitrateInfo(bwe_info);
1426 } 1427 }
1427 } 1428 }
1428 1429
1429 void WebRtcVideoChannel2::FillSendAndReceiveCodecStats( 1430 void WebRtcVideoChannel::FillSendAndReceiveCodecStats(
1430 VideoMediaInfo* video_media_info) { 1431 VideoMediaInfo* video_media_info) {
1431 for (const VideoCodec& codec : send_params_.codecs) { 1432 for (const VideoCodec& codec : send_params_.codecs) {
1432 webrtc::RtpCodecParameters codec_params = codec.ToCodecParameters(); 1433 webrtc::RtpCodecParameters codec_params = codec.ToCodecParameters();
1433 video_media_info->send_codecs.insert( 1434 video_media_info->send_codecs.insert(
1434 std::make_pair(codec_params.payload_type, std::move(codec_params))); 1435 std::make_pair(codec_params.payload_type, std::move(codec_params)));
1435 } 1436 }
1436 for (const VideoCodec& codec : recv_params_.codecs) { 1437 for (const VideoCodec& codec : recv_params_.codecs) {
1437 webrtc::RtpCodecParameters codec_params = codec.ToCodecParameters(); 1438 webrtc::RtpCodecParameters codec_params = codec.ToCodecParameters();
1438 video_media_info->receive_codecs.insert( 1439 video_media_info->receive_codecs.insert(
1439 std::make_pair(codec_params.payload_type, std::move(codec_params))); 1440 std::make_pair(codec_params.payload_type, std::move(codec_params)));
1440 } 1441 }
1441 } 1442 }
1442 1443
1443 void WebRtcVideoChannel2::OnPacketReceived( 1444 void WebRtcVideoChannel::OnPacketReceived(
1444 rtc::CopyOnWriteBuffer* packet, 1445 rtc::CopyOnWriteBuffer* packet,
1445 const rtc::PacketTime& packet_time) { 1446 const rtc::PacketTime& packet_time) {
1446 const webrtc::PacketTime webrtc_packet_time(packet_time.timestamp, 1447 const webrtc::PacketTime webrtc_packet_time(packet_time.timestamp,
1447 packet_time.not_before); 1448 packet_time.not_before);
1448 const webrtc::PacketReceiver::DeliveryStatus delivery_result = 1449 const webrtc::PacketReceiver::DeliveryStatus delivery_result =
1449 call_->Receiver()->DeliverPacket( 1450 call_->Receiver()->DeliverPacket(
1450 webrtc::MediaType::VIDEO, 1451 webrtc::MediaType::VIDEO,
1451 packet->cdata(), packet->size(), 1452 packet->cdata(), packet->size(),
1452 webrtc_packet_time); 1453 webrtc_packet_time);
1453 switch (delivery_result) { 1454 switch (delivery_result) {
(...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after
1494 1495
1495 if (call_->Receiver()->DeliverPacket( 1496 if (call_->Receiver()->DeliverPacket(
1496 webrtc::MediaType::VIDEO, 1497 webrtc::MediaType::VIDEO,
1497 packet->cdata(), packet->size(), 1498 packet->cdata(), packet->size(),
1498 webrtc_packet_time) != webrtc::PacketReceiver::DELIVERY_OK) { 1499 webrtc_packet_time) != webrtc::PacketReceiver::DELIVERY_OK) {
1499 LOG(LS_WARNING) << "Failed to deliver RTP packet on re-delivery."; 1500 LOG(LS_WARNING) << "Failed to deliver RTP packet on re-delivery.";
1500 return; 1501 return;
1501 } 1502 }
1502 } 1503 }
1503 1504
1504 void WebRtcVideoChannel2::OnRtcpReceived( 1505 void WebRtcVideoChannel::OnRtcpReceived(
1505 rtc::CopyOnWriteBuffer* packet, 1506 rtc::CopyOnWriteBuffer* packet,
1506 const rtc::PacketTime& packet_time) { 1507 const rtc::PacketTime& packet_time) {
1507 const webrtc::PacketTime webrtc_packet_time(packet_time.timestamp, 1508 const webrtc::PacketTime webrtc_packet_time(packet_time.timestamp,
1508 packet_time.not_before); 1509 packet_time.not_before);
1509 // TODO(pbos): Check webrtc::PacketReceiver::DELIVERY_OK once we deliver 1510 // TODO(pbos): Check webrtc::PacketReceiver::DELIVERY_OK once we deliver
1510 // for both audio and video on the same path. Since BundleFilter doesn't 1511 // for both audio and video on the same path. Since BundleFilter doesn't
1511 // filter RTCP anymore incoming RTCP packets could've been going to audio (so 1512 // filter RTCP anymore incoming RTCP packets could've been going to audio (so
1512 // logging failures spam the log). 1513 // logging failures spam the log).
1513 call_->Receiver()->DeliverPacket( 1514 call_->Receiver()->DeliverPacket(
1514 webrtc::MediaType::VIDEO, 1515 webrtc::MediaType::VIDEO,
1515 packet->cdata(), packet->size(), 1516 packet->cdata(), packet->size(),
1516 webrtc_packet_time); 1517 webrtc_packet_time);
1517 } 1518 }
1518 1519
1519 void WebRtcVideoChannel2::OnReadyToSend(bool ready) { 1520 void WebRtcVideoChannel::OnReadyToSend(bool ready) {
1520 LOG(LS_VERBOSE) << "OnReadyToSend: " << (ready ? "Ready." : "Not ready."); 1521 LOG(LS_VERBOSE) << "OnReadyToSend: " << (ready ? "Ready." : "Not ready.");
1521 call_->SignalChannelNetworkState( 1522 call_->SignalChannelNetworkState(
1522 webrtc::MediaType::VIDEO, 1523 webrtc::MediaType::VIDEO,
1523 ready ? webrtc::kNetworkUp : webrtc::kNetworkDown); 1524 ready ? webrtc::kNetworkUp : webrtc::kNetworkDown);
1524 } 1525 }
1525 1526
1526 void WebRtcVideoChannel2::OnNetworkRouteChanged( 1527 void WebRtcVideoChannel::OnNetworkRouteChanged(
1527 const std::string& transport_name, 1528 const std::string& transport_name,
1528 const rtc::NetworkRoute& network_route) { 1529 const rtc::NetworkRoute& network_route) {
1529 call_->OnNetworkRouteChanged(transport_name, network_route); 1530 call_->OnNetworkRouteChanged(transport_name, network_route);
1530 } 1531 }
1531 1532
1532 void WebRtcVideoChannel2::OnTransportOverheadChanged( 1533 void WebRtcVideoChannel::OnTransportOverheadChanged(
1533 int transport_overhead_per_packet) { 1534 int transport_overhead_per_packet) {
1534 call_->OnTransportOverheadChanged(webrtc::MediaType::VIDEO, 1535 call_->OnTransportOverheadChanged(webrtc::MediaType::VIDEO,
1535 transport_overhead_per_packet); 1536 transport_overhead_per_packet);
1536 } 1537 }
1537 1538
1538 void WebRtcVideoChannel2::SetInterface(NetworkInterface* iface) { 1539 void WebRtcVideoChannel::SetInterface(NetworkInterface* iface) {
1539 MediaChannel::SetInterface(iface); 1540 MediaChannel::SetInterface(iface);
1540 // Set the RTP recv/send buffer to a bigger size 1541 // Set the RTP recv/send buffer to a bigger size
1541 MediaChannel::SetOption(NetworkInterface::ST_RTP, 1542 MediaChannel::SetOption(NetworkInterface::ST_RTP,
1542 rtc::Socket::OPT_RCVBUF, 1543 rtc::Socket::OPT_RCVBUF,
1543 kVideoRtpBufferSize); 1544 kVideoRtpBufferSize);
1544 1545
1545 // Speculative change to increase the outbound socket buffer size. 1546 // Speculative change to increase the outbound socket buffer size.
1546 // In b/15152257, we are seeing a significant number of packets discarded 1547 // In b/15152257, we are seeing a significant number of packets discarded
1547 // due to lack of socket buffer space, although it's not yet clear what the 1548 // due to lack of socket buffer space, although it's not yet clear what the
1548 // ideal value should be. 1549 // ideal value should be.
1549 MediaChannel::SetOption(NetworkInterface::ST_RTP, 1550 MediaChannel::SetOption(NetworkInterface::ST_RTP,
1550 rtc::Socket::OPT_SNDBUF, 1551 rtc::Socket::OPT_SNDBUF,
1551 kVideoRtpBufferSize); 1552 kVideoRtpBufferSize);
1552 } 1553 }
1553 1554
1554 rtc::Optional<uint32_t> WebRtcVideoChannel2::GetDefaultReceiveStreamSsrc() { 1555 rtc::Optional<uint32_t> WebRtcVideoChannel::GetDefaultReceiveStreamSsrc() {
1555 rtc::CritScope stream_lock(&stream_crit_); 1556 rtc::CritScope stream_lock(&stream_crit_);
1556 rtc::Optional<uint32_t> ssrc; 1557 rtc::Optional<uint32_t> ssrc;
1557 for (auto it = receive_streams_.begin(); it != receive_streams_.end(); ++it) { 1558 for (auto it = receive_streams_.begin(); it != receive_streams_.end(); ++it) {
1558 if (it->second->IsDefaultStream()) { 1559 if (it->second->IsDefaultStream()) {
1559 ssrc.emplace(it->first); 1560 ssrc.emplace(it->first);
1560 break; 1561 break;
1561 } 1562 }
1562 } 1563 }
1563 return ssrc; 1564 return ssrc;
1564 } 1565 }
1565 1566
1566 bool WebRtcVideoChannel2::SendRtp(const uint8_t* data, 1567 bool WebRtcVideoChannel::SendRtp(const uint8_t* data,
1567 size_t len, 1568 size_t len,
1568 const webrtc::PacketOptions& options) { 1569 const webrtc::PacketOptions& options) {
1569 rtc::CopyOnWriteBuffer packet(data, len, kMaxRtpPacketLen); 1570 rtc::CopyOnWriteBuffer packet(data, len, kMaxRtpPacketLen);
1570 rtc::PacketOptions rtc_options; 1571 rtc::PacketOptions rtc_options;
1571 rtc_options.packet_id = options.packet_id; 1572 rtc_options.packet_id = options.packet_id;
1572 return MediaChannel::SendPacket(&packet, rtc_options); 1573 return MediaChannel::SendPacket(&packet, rtc_options);
1573 } 1574 }
1574 1575
1575 bool WebRtcVideoChannel2::SendRtcp(const uint8_t* data, size_t len) { 1576 bool WebRtcVideoChannel::SendRtcp(const uint8_t* data, size_t len) {
1576 rtc::CopyOnWriteBuffer packet(data, len, kMaxRtpPacketLen); 1577 rtc::CopyOnWriteBuffer packet(data, len, kMaxRtpPacketLen);
1577 return MediaChannel::SendRtcp(&packet, rtc::PacketOptions()); 1578 return MediaChannel::SendRtcp(&packet, rtc::PacketOptions());
1578 } 1579 }
1579 1580
1580 WebRtcVideoChannel2::WebRtcVideoSendStream::VideoSendStreamParameters:: 1581 WebRtcVideoChannel::WebRtcVideoSendStream::VideoSendStreamParameters::
1581 VideoSendStreamParameters( 1582 VideoSendStreamParameters(
1582 webrtc::VideoSendStream::Config config, 1583 webrtc::VideoSendStream::Config config,
1583 const VideoOptions& options, 1584 const VideoOptions& options,
1584 int max_bitrate_bps, 1585 int max_bitrate_bps,
1585 const rtc::Optional<VideoCodecSettings>& codec_settings) 1586 const rtc::Optional<VideoCodecSettings>& codec_settings)
1586 : config(std::move(config)), 1587 : config(std::move(config)),
1587 options(options), 1588 options(options),
1588 max_bitrate_bps(max_bitrate_bps), 1589 max_bitrate_bps(max_bitrate_bps),
1589 conference_mode(false), 1590 conference_mode(false),
1590 codec_settings(codec_settings) {} 1591 codec_settings(codec_settings) {}
1591 1592
1592 WebRtcVideoChannel2::WebRtcVideoSendStream::AllocatedEncoder::AllocatedEncoder( 1593 WebRtcVideoChannel::WebRtcVideoSendStream::AllocatedEncoder::AllocatedEncoder(
1593 webrtc::VideoEncoder* encoder, 1594 webrtc::VideoEncoder* encoder,
1594 const cricket::VideoCodec& codec, 1595 const cricket::VideoCodec& codec,
1595 bool external) 1596 bool external)
1596 : encoder(encoder), 1597 : encoder(encoder),
1597 external_encoder(nullptr), 1598 external_encoder(nullptr),
1598 codec(codec), 1599 codec(codec),
1599 external(external) { 1600 external(external) {
1600 if (external) { 1601 if (external) {
1601 external_encoder = encoder; 1602 external_encoder = encoder;
1602 this->encoder = 1603 this->encoder =
1603 new webrtc::VideoEncoderSoftwareFallbackWrapper(codec, encoder); 1604 new webrtc::VideoEncoderSoftwareFallbackWrapper(codec, encoder);
1604 } 1605 }
1605 } 1606 }
1606 1607
1607 WebRtcVideoChannel2::WebRtcVideoSendStream::WebRtcVideoSendStream( 1608 WebRtcVideoChannel::WebRtcVideoSendStream::WebRtcVideoSendStream(
1608 webrtc::Call* call, 1609 webrtc::Call* call,
1609 const StreamParams& sp, 1610 const StreamParams& sp,
1610 webrtc::VideoSendStream::Config config, 1611 webrtc::VideoSendStream::Config config,
1611 const VideoOptions& options, 1612 const VideoOptions& options,
1612 WebRtcVideoEncoderFactory* external_encoder_factory, 1613 WebRtcVideoEncoderFactory* external_encoder_factory,
1613 bool enable_cpu_overuse_detection, 1614 bool enable_cpu_overuse_detection,
1614 int max_bitrate_bps, 1615 int max_bitrate_bps,
1615 const rtc::Optional<VideoCodecSettings>& codec_settings, 1616 const rtc::Optional<VideoCodecSettings>& codec_settings,
1616 const rtc::Optional<std::vector<webrtc::RtpExtension>>& rtp_extensions, 1617 const rtc::Optional<std::vector<webrtc::RtpExtension>>& rtp_extensions,
1617 // TODO(deadbeef): Don't duplicate information between send_params, 1618 // TODO(deadbeef): Don't duplicate information between send_params,
(...skipping 57 matching lines...) Expand 10 before | Expand all | Expand 10 after
1675 } 1676 }
1676 parameters_.config.rtp.rtcp_mode = send_params.rtcp.reduced_size 1677 parameters_.config.rtp.rtcp_mode = send_params.rtcp.reduced_size
1677 ? webrtc::RtcpMode::kReducedSize 1678 ? webrtc::RtcpMode::kReducedSize
1678 : webrtc::RtcpMode::kCompound; 1679 : webrtc::RtcpMode::kCompound;
1679 if (codec_settings) { 1680 if (codec_settings) {
1680 bool force_encoder_allocation = false; 1681 bool force_encoder_allocation = false;
1681 SetCodec(*codec_settings, force_encoder_allocation); 1682 SetCodec(*codec_settings, force_encoder_allocation);
1682 } 1683 }
1683 } 1684 }
1684 1685
1685 WebRtcVideoChannel2::WebRtcVideoSendStream::~WebRtcVideoSendStream() { 1686 WebRtcVideoChannel::WebRtcVideoSendStream::~WebRtcVideoSendStream() {
1686 if (stream_ != NULL) { 1687 if (stream_ != NULL) {
1687 call_->DestroyVideoSendStream(stream_); 1688 call_->DestroyVideoSendStream(stream_);
1688 } 1689 }
1689 DestroyVideoEncoder(&allocated_encoder_); 1690 DestroyVideoEncoder(&allocated_encoder_);
1690 } 1691 }
1691 1692
1692 bool WebRtcVideoChannel2::WebRtcVideoSendStream::SetVideoSend( 1693 bool WebRtcVideoChannel::WebRtcVideoSendStream::SetVideoSend(
1693 bool enable, 1694 bool enable,
1694 const VideoOptions* options, 1695 const VideoOptions* options,
1695 rtc::VideoSourceInterface<webrtc::VideoFrame>* source) { 1696 rtc::VideoSourceInterface<webrtc::VideoFrame>* source) {
1696 TRACE_EVENT0("webrtc", "WebRtcVideoSendStream::SetVideoSend"); 1697 TRACE_EVENT0("webrtc", "WebRtcVideoSendStream::SetVideoSend");
1697 RTC_DCHECK_RUN_ON(&thread_checker_); 1698 RTC_DCHECK_RUN_ON(&thread_checker_);
1698 1699
1699 // Ignore |options| pointer if |enable| is false. 1700 // Ignore |options| pointer if |enable| is false.
1700 bool options_present = enable && options; 1701 bool options_present = enable && options;
1701 1702
1702 if (options_present) { 1703 if (options_present) {
(...skipping 21 matching lines...) Expand all
1724 } 1725 }
1725 // Switch to the new source. 1726 // Switch to the new source.
1726 source_ = source; 1727 source_ = source;
1727 if (source && stream_) { 1728 if (source && stream_) {
1728 stream_->SetSource(this, GetDegradationPreference()); 1729 stream_->SetSource(this, GetDegradationPreference());
1729 } 1730 }
1730 return true; 1731 return true;
1731 } 1732 }
1732 1733
1733 webrtc::VideoSendStream::DegradationPreference 1734 webrtc::VideoSendStream::DegradationPreference
1734 WebRtcVideoChannel2::WebRtcVideoSendStream::GetDegradationPreference() const { 1735 WebRtcVideoChannel::WebRtcVideoSendStream::GetDegradationPreference() const {
1735 // Do not adapt resolution for screen content as this will likely 1736 // Do not adapt resolution for screen content as this will likely
1736 // result in blurry and unreadable text. 1737 // result in blurry and unreadable text.
1737 // |this| acts like a VideoSource to make sure SinkWants are handled on the 1738 // |this| acts like a VideoSource to make sure SinkWants are handled on the
1738 // correct thread. 1739 // correct thread.
1739 DegradationPreference degradation_preference; 1740 DegradationPreference degradation_preference;
1740 if (!enable_cpu_overuse_detection_) { 1741 if (!enable_cpu_overuse_detection_) {
1741 degradation_preference = DegradationPreference::kDegradationDisabled; 1742 degradation_preference = DegradationPreference::kDegradationDisabled;
1742 } else { 1743 } else {
1743 if (parameters_.options.is_screencast.value_or(false)) { 1744 if (parameters_.options.is_screencast.value_or(false)) {
1744 degradation_preference = DegradationPreference::kMaintainResolution; 1745 degradation_preference = DegradationPreference::kMaintainResolution;
1745 } else { 1746 } else {
1746 degradation_preference = DegradationPreference::kMaintainFramerate; 1747 degradation_preference = DegradationPreference::kMaintainFramerate;
1747 } 1748 }
1748 } 1749 }
1749 return degradation_preference; 1750 return degradation_preference;
1750 } 1751 }
1751 1752
1752 const std::vector<uint32_t>& 1753 const std::vector<uint32_t>&
1753 WebRtcVideoChannel2::WebRtcVideoSendStream::GetSsrcs() const { 1754 WebRtcVideoChannel::WebRtcVideoSendStream::GetSsrcs() const {
1754 return ssrcs_; 1755 return ssrcs_;
1755 } 1756 }
1756 1757
1757 WebRtcVideoChannel2::WebRtcVideoSendStream::AllocatedEncoder 1758 WebRtcVideoChannel::WebRtcVideoSendStream::AllocatedEncoder
1758 WebRtcVideoChannel2::WebRtcVideoSendStream::CreateVideoEncoder( 1759 WebRtcVideoChannel::WebRtcVideoSendStream::CreateVideoEncoder(
1759 const VideoCodec& codec, 1760 const VideoCodec& codec,
1760 bool force_encoder_allocation) { 1761 bool force_encoder_allocation) {
1761 RTC_DCHECK_RUN_ON(&thread_checker_); 1762 RTC_DCHECK_RUN_ON(&thread_checker_);
1762 // Do not re-create encoders of the same type. 1763 // Do not re-create encoders of the same type.
1763 if (!force_encoder_allocation && codec == allocated_encoder_.codec && 1764 if (!force_encoder_allocation && codec == allocated_encoder_.codec &&
1764 allocated_encoder_.encoder != nullptr) { 1765 allocated_encoder_.encoder != nullptr) {
1765 return allocated_encoder_; 1766 return allocated_encoder_;
1766 } 1767 }
1767 1768
1768 // Try creating external encoder. 1769 // Try creating external encoder.
(...skipping 21 matching lines...) Expand all
1790 internal_encoder_factory_->CreateVideoEncoder(codec), codec, 1791 internal_encoder_factory_->CreateVideoEncoder(codec), codec,
1791 false /* is_external */); 1792 false /* is_external */);
1792 } 1793 }
1793 1794
1794 // This shouldn't happen, we should not be trying to create something we don't 1795 // This shouldn't happen, we should not be trying to create something we don't
1795 // support. 1796 // support.
1796 RTC_NOTREACHED(); 1797 RTC_NOTREACHED();
1797 return AllocatedEncoder(NULL, cricket::VideoCodec(), false); 1798 return AllocatedEncoder(NULL, cricket::VideoCodec(), false);
1798 } 1799 }
1799 1800
1800 void WebRtcVideoChannel2::WebRtcVideoSendStream::DestroyVideoEncoder( 1801 void WebRtcVideoChannel::WebRtcVideoSendStream::DestroyVideoEncoder(
1801 AllocatedEncoder* encoder) { 1802 AllocatedEncoder* encoder) {
1802 RTC_DCHECK_RUN_ON(&thread_checker_); 1803 RTC_DCHECK_RUN_ON(&thread_checker_);
1803 if (encoder->external) { 1804 if (encoder->external) {
1804 external_encoder_factory_->DestroyVideoEncoder(encoder->external_encoder); 1805 external_encoder_factory_->DestroyVideoEncoder(encoder->external_encoder);
1805 } 1806 }
1806 delete encoder->encoder; 1807 delete encoder->encoder;
1807 } 1808 }
1808 1809
1809 void WebRtcVideoChannel2::WebRtcVideoSendStream::SetCodec( 1810 void WebRtcVideoChannel::WebRtcVideoSendStream::SetCodec(
1810 const VideoCodecSettings& codec_settings, 1811 const VideoCodecSettings& codec_settings,
1811 bool force_encoder_allocation) { 1812 bool force_encoder_allocation) {
1812 RTC_DCHECK_RUN_ON(&thread_checker_); 1813 RTC_DCHECK_RUN_ON(&thread_checker_);
1813 parameters_.encoder_config = CreateVideoEncoderConfig(codec_settings.codec); 1814 parameters_.encoder_config = CreateVideoEncoderConfig(codec_settings.codec);
1814 RTC_DCHECK_GT(parameters_.encoder_config.number_of_streams, 0); 1815 RTC_DCHECK_GT(parameters_.encoder_config.number_of_streams, 0);
1815 1816
1816 AllocatedEncoder new_encoder = 1817 AllocatedEncoder new_encoder =
1817 CreateVideoEncoder(codec_settings.codec, force_encoder_allocation); 1818 CreateVideoEncoder(codec_settings.codec, force_encoder_allocation);
1818 parameters_.config.encoder_settings.encoder = new_encoder.encoder; 1819 parameters_.config.encoder_settings.encoder = new_encoder.encoder;
1819 parameters_.config.encoder_settings.full_overuse_time = new_encoder.external; 1820 parameters_.config.encoder_settings.full_overuse_time = new_encoder.external;
(...skipping 20 matching lines...) Expand all
1840 parameters_.config.rtp.rtx.ssrcs.clear(); 1841 parameters_.config.rtp.rtx.ssrcs.clear();
1841 } else { 1842 } else {
1842 parameters_.config.rtp.rtx.payload_type = codec_settings.rtx_payload_type; 1843 parameters_.config.rtp.rtx.payload_type = codec_settings.rtx_payload_type;
1843 } 1844 }
1844 } 1845 }
1845 1846
1846 parameters_.config.rtp.nack.rtp_history_ms = 1847 parameters_.config.rtp.nack.rtp_history_ms =
1847 HasNack(codec_settings.codec) ? kNackHistoryMs : 0; 1848 HasNack(codec_settings.codec) ? kNackHistoryMs : 0;
1848 1849
1849 parameters_.codec_settings = 1850 parameters_.codec_settings =
1850 rtc::Optional<WebRtcVideoChannel2::VideoCodecSettings>(codec_settings); 1851 rtc::Optional<WebRtcVideoChannel::VideoCodecSettings>(codec_settings);
1851 1852
1852 LOG(LS_INFO) << "RecreateWebRtcStream (send) because of SetCodec."; 1853 LOG(LS_INFO) << "RecreateWebRtcStream (send) because of SetCodec.";
1853 RecreateWebRtcStream(); 1854 RecreateWebRtcStream();
1854 if (allocated_encoder_.encoder != new_encoder.encoder) { 1855 if (allocated_encoder_.encoder != new_encoder.encoder) {
1855 DestroyVideoEncoder(&allocated_encoder_); 1856 DestroyVideoEncoder(&allocated_encoder_);
1856 allocated_encoder_ = new_encoder; 1857 allocated_encoder_ = new_encoder;
1857 } 1858 }
1858 } 1859 }
1859 1860
1860 void WebRtcVideoChannel2::WebRtcVideoSendStream::SetSendParameters( 1861 void WebRtcVideoChannel::WebRtcVideoSendStream::SetSendParameters(
1861 const ChangedSendParameters& params) { 1862 const ChangedSendParameters& params) {
1862 RTC_DCHECK_RUN_ON(&thread_checker_); 1863 RTC_DCHECK_RUN_ON(&thread_checker_);
1863 // |recreate_stream| means construction-time parameters have changed and the 1864 // |recreate_stream| means construction-time parameters have changed and the
1864 // sending stream needs to be reset with the new config. 1865 // sending stream needs to be reset with the new config.
1865 bool recreate_stream = false; 1866 bool recreate_stream = false;
1866 if (params.rtcp_mode) { 1867 if (params.rtcp_mode) {
1867 parameters_.config.rtp.rtcp_mode = *params.rtcp_mode; 1868 parameters_.config.rtp.rtcp_mode = *params.rtcp_mode;
1868 recreate_stream = true; 1869 recreate_stream = true;
1869 } 1870 }
1870 if (params.rtp_header_extensions) { 1871 if (params.rtp_header_extensions) {
(...skipping 17 matching lines...) Expand all
1888 bool force_encoder_allocation = false; 1889 bool force_encoder_allocation = false;
1889 SetCodec(*parameters_.codec_settings, force_encoder_allocation); 1890 SetCodec(*parameters_.codec_settings, force_encoder_allocation);
1890 recreate_stream = false; // SetCodec has already recreated the stream. 1891 recreate_stream = false; // SetCodec has already recreated the stream.
1891 } 1892 }
1892 if (recreate_stream) { 1893 if (recreate_stream) {
1893 LOG(LS_INFO) << "RecreateWebRtcStream (send) because of SetSendParameters"; 1894 LOG(LS_INFO) << "RecreateWebRtcStream (send) because of SetSendParameters";
1894 RecreateWebRtcStream(); 1895 RecreateWebRtcStream();
1895 } 1896 }
1896 } 1897 }
1897 1898
1898 bool WebRtcVideoChannel2::WebRtcVideoSendStream::SetRtpParameters( 1899 bool WebRtcVideoChannel::WebRtcVideoSendStream::SetRtpParameters(
1899 const webrtc::RtpParameters& new_parameters) { 1900 const webrtc::RtpParameters& new_parameters) {
1900 RTC_DCHECK_RUN_ON(&thread_checker_); 1901 RTC_DCHECK_RUN_ON(&thread_checker_);
1901 if (!ValidateRtpParameters(new_parameters)) { 1902 if (!ValidateRtpParameters(new_parameters)) {
1902 return false; 1903 return false;
1903 } 1904 }
1904 1905
1905 bool reconfigure_encoder = new_parameters.encodings[0].max_bitrate_bps != 1906 bool reconfigure_encoder = new_parameters.encodings[0].max_bitrate_bps !=
1906 rtp_parameters_.encodings[0].max_bitrate_bps; 1907 rtp_parameters_.encodings[0].max_bitrate_bps;
1907 rtp_parameters_ = new_parameters; 1908 rtp_parameters_ = new_parameters;
1908 // Codecs are currently handled at the WebRtcVideoChannel2 level. 1909 // Codecs are currently handled at the WebRtcVideoChannel level.
1909 rtp_parameters_.codecs.clear(); 1910 rtp_parameters_.codecs.clear();
1910 if (reconfigure_encoder) { 1911 if (reconfigure_encoder) {
1911 ReconfigureEncoder(); 1912 ReconfigureEncoder();
1912 } 1913 }
1913 // Encoding may have been activated/deactivated. 1914 // Encoding may have been activated/deactivated.
1914 UpdateSendState(); 1915 UpdateSendState();
1915 return true; 1916 return true;
1916 } 1917 }
1917 1918
1918 webrtc::RtpParameters 1919 webrtc::RtpParameters
1919 WebRtcVideoChannel2::WebRtcVideoSendStream::GetRtpParameters() const { 1920 WebRtcVideoChannel::WebRtcVideoSendStream::GetRtpParameters() const {
1920 RTC_DCHECK_RUN_ON(&thread_checker_); 1921 RTC_DCHECK_RUN_ON(&thread_checker_);
1921 return rtp_parameters_; 1922 return rtp_parameters_;
1922 } 1923 }
1923 1924
1924 bool WebRtcVideoChannel2::WebRtcVideoSendStream::ValidateRtpParameters( 1925 bool WebRtcVideoChannel::WebRtcVideoSendStream::ValidateRtpParameters(
1925 const webrtc::RtpParameters& rtp_parameters) { 1926 const webrtc::RtpParameters& rtp_parameters) {
1926 RTC_DCHECK_RUN_ON(&thread_checker_); 1927 RTC_DCHECK_RUN_ON(&thread_checker_);
1927 if (rtp_parameters.encodings.size() != 1) { 1928 if (rtp_parameters.encodings.size() != 1) {
1928 LOG(LS_ERROR) 1929 LOG(LS_ERROR)
1929 << "Attempted to set RtpParameters without exactly one encoding"; 1930 << "Attempted to set RtpParameters without exactly one encoding";
1930 return false; 1931 return false;
1931 } 1932 }
1932 if (rtp_parameters.encodings[0].ssrc != rtp_parameters_.encodings[0].ssrc) { 1933 if (rtp_parameters.encodings[0].ssrc != rtp_parameters_.encodings[0].ssrc) {
1933 LOG(LS_ERROR) << "Attempted to set RtpParameters with modified SSRC"; 1934 LOG(LS_ERROR) << "Attempted to set RtpParameters with modified SSRC";
1934 return false; 1935 return false;
1935 } 1936 }
1936 return true; 1937 return true;
1937 } 1938 }
1938 1939
1939 void WebRtcVideoChannel2::WebRtcVideoSendStream::UpdateSendState() { 1940 void WebRtcVideoChannel::WebRtcVideoSendStream::UpdateSendState() {
1940 RTC_DCHECK_RUN_ON(&thread_checker_); 1941 RTC_DCHECK_RUN_ON(&thread_checker_);
1941 // TODO(deadbeef): Need to handle more than one encoding in the future. 1942 // TODO(deadbeef): Need to handle more than one encoding in the future.
1942 RTC_DCHECK(rtp_parameters_.encodings.size() == 1u); 1943 RTC_DCHECK(rtp_parameters_.encodings.size() == 1u);
1943 if (sending_ && rtp_parameters_.encodings[0].active) { 1944 if (sending_ && rtp_parameters_.encodings[0].active) {
1944 RTC_DCHECK(stream_ != nullptr); 1945 RTC_DCHECK(stream_ != nullptr);
1945 stream_->Start(); 1946 stream_->Start();
1946 } else { 1947 } else {
1947 if (stream_ != nullptr) { 1948 if (stream_ != nullptr) {
1948 stream_->Stop(); 1949 stream_->Stop();
1949 } 1950 }
1950 } 1951 }
1951 } 1952 }
1952 1953
1953 webrtc::VideoEncoderConfig 1954 webrtc::VideoEncoderConfig
1954 WebRtcVideoChannel2::WebRtcVideoSendStream::CreateVideoEncoderConfig( 1955 WebRtcVideoChannel::WebRtcVideoSendStream::CreateVideoEncoderConfig(
1955 const VideoCodec& codec) const { 1956 const VideoCodec& codec) const {
1956 RTC_DCHECK_RUN_ON(&thread_checker_); 1957 RTC_DCHECK_RUN_ON(&thread_checker_);
1957 webrtc::VideoEncoderConfig encoder_config; 1958 webrtc::VideoEncoderConfig encoder_config;
1958 bool is_screencast = parameters_.options.is_screencast.value_or(false); 1959 bool is_screencast = parameters_.options.is_screencast.value_or(false);
1959 if (is_screencast) { 1960 if (is_screencast) {
1960 encoder_config.min_transmit_bitrate_bps = 1961 encoder_config.min_transmit_bitrate_bps =
1961 1000 * parameters_.options.screencast_min_bitrate_kbps.value_or(0); 1962 1000 * parameters_.options.screencast_min_bitrate_kbps.value_or(0);
1962 encoder_config.content_type = 1963 encoder_config.content_type =
1963 webrtc::VideoEncoderConfig::ContentType::kScreen; 1964 webrtc::VideoEncoderConfig::ContentType::kScreen;
1964 } else { 1965 } else {
(...skipping 28 matching lines...) Expand all
1993 1994
1994 int max_qp = kDefaultQpMax; 1995 int max_qp = kDefaultQpMax;
1995 codec.GetParam(kCodecParamMaxQuantization, &max_qp); 1996 codec.GetParam(kCodecParamMaxQuantization, &max_qp);
1996 encoder_config.video_stream_factory = 1997 encoder_config.video_stream_factory =
1997 new rtc::RefCountedObject<EncoderStreamFactory>( 1998 new rtc::RefCountedObject<EncoderStreamFactory>(
1998 codec.name, max_qp, kDefaultVideoMaxFramerate, is_screencast, 1999 codec.name, max_qp, kDefaultVideoMaxFramerate, is_screencast,
1999 parameters_.conference_mode); 2000 parameters_.conference_mode);
2000 return encoder_config; 2001 return encoder_config;
2001 } 2002 }
2002 2003
2003 void WebRtcVideoChannel2::WebRtcVideoSendStream::ReconfigureEncoder() { 2004 void WebRtcVideoChannel::WebRtcVideoSendStream::ReconfigureEncoder() {
2004 RTC_DCHECK_RUN_ON(&thread_checker_); 2005 RTC_DCHECK_RUN_ON(&thread_checker_);
2005 if (!stream_) { 2006 if (!stream_) {
2006 // The webrtc::VideoSendStream |stream_| has not yet been created but other 2007 // The webrtc::VideoSendStream |stream_| has not yet been created but other
2007 // parameters has changed. 2008 // parameters has changed.
2008 return; 2009 return;
2009 } 2010 }
2010 2011
2011 RTC_DCHECK_GT(parameters_.encoder_config.number_of_streams, 0); 2012 RTC_DCHECK_GT(parameters_.encoder_config.number_of_streams, 0);
2012 2013
2013 RTC_CHECK(parameters_.codec_settings); 2014 RTC_CHECK(parameters_.codec_settings);
2014 VideoCodecSettings codec_settings = *parameters_.codec_settings; 2015 VideoCodecSettings codec_settings = *parameters_.codec_settings;
2015 2016
2016 webrtc::VideoEncoderConfig encoder_config = 2017 webrtc::VideoEncoderConfig encoder_config =
2017 CreateVideoEncoderConfig(codec_settings.codec); 2018 CreateVideoEncoderConfig(codec_settings.codec);
2018 2019
2019 encoder_config.encoder_specific_settings = ConfigureVideoEncoderSettings( 2020 encoder_config.encoder_specific_settings = ConfigureVideoEncoderSettings(
2020 codec_settings.codec); 2021 codec_settings.codec);
2021 2022
2022 stream_->ReconfigureVideoEncoder(encoder_config.Copy()); 2023 stream_->ReconfigureVideoEncoder(encoder_config.Copy());
2023 2024
2024 encoder_config.encoder_specific_settings = NULL; 2025 encoder_config.encoder_specific_settings = NULL;
2025 2026
2026 parameters_.encoder_config = std::move(encoder_config); 2027 parameters_.encoder_config = std::move(encoder_config);
2027 } 2028 }
2028 2029
2029 void WebRtcVideoChannel2::WebRtcVideoSendStream::SetSend(bool send) { 2030 void WebRtcVideoChannel::WebRtcVideoSendStream::SetSend(bool send) {
2030 RTC_DCHECK_RUN_ON(&thread_checker_); 2031 RTC_DCHECK_RUN_ON(&thread_checker_);
2031 sending_ = send; 2032 sending_ = send;
2032 UpdateSendState(); 2033 UpdateSendState();
2033 } 2034 }
2034 2035
2035 void WebRtcVideoChannel2::WebRtcVideoSendStream::RemoveSink( 2036 void WebRtcVideoChannel::WebRtcVideoSendStream::RemoveSink(
2036 rtc::VideoSinkInterface<webrtc::VideoFrame>* sink) { 2037 rtc::VideoSinkInterface<webrtc::VideoFrame>* sink) {
2037 RTC_DCHECK_RUN_ON(&thread_checker_); 2038 RTC_DCHECK_RUN_ON(&thread_checker_);
2038 RTC_DCHECK(encoder_sink_ == sink); 2039 RTC_DCHECK(encoder_sink_ == sink);
2039 encoder_sink_ = nullptr; 2040 encoder_sink_ = nullptr;
2040 source_->RemoveSink(sink); 2041 source_->RemoveSink(sink);
2041 } 2042 }
2042 2043
2043 void WebRtcVideoChannel2::WebRtcVideoSendStream::AddOrUpdateSink( 2044 void WebRtcVideoChannel::WebRtcVideoSendStream::AddOrUpdateSink(
2044 rtc::VideoSinkInterface<webrtc::VideoFrame>* sink, 2045 rtc::VideoSinkInterface<webrtc::VideoFrame>* sink,
2045 const rtc::VideoSinkWants& wants) { 2046 const rtc::VideoSinkWants& wants) {
2046 if (worker_thread_ == rtc::Thread::Current()) { 2047 if (worker_thread_ == rtc::Thread::Current()) {
2047 // AddOrUpdateSink is called on |worker_thread_| if this is the first 2048 // AddOrUpdateSink is called on |worker_thread_| if this is the first
2048 // registration of |sink|. 2049 // registration of |sink|.
2049 RTC_DCHECK_RUN_ON(&thread_checker_); 2050 RTC_DCHECK_RUN_ON(&thread_checker_);
2050 encoder_sink_ = sink; 2051 encoder_sink_ = sink;
2051 source_->AddOrUpdateSink(encoder_sink_, wants); 2052 source_->AddOrUpdateSink(encoder_sink_, wants);
2052 } else { 2053 } else {
2053 // Subsequent calls to AddOrUpdateSink will happen on the encoder task 2054 // Subsequent calls to AddOrUpdateSink will happen on the encoder task
2054 // queue. 2055 // queue.
2055 invoker_.AsyncInvoke<void>( 2056 invoker_.AsyncInvoke<void>(
2056 RTC_FROM_HERE, worker_thread_, [this, sink, wants] { 2057 RTC_FROM_HERE, worker_thread_, [this, sink, wants] {
2057 RTC_DCHECK_RUN_ON(&thread_checker_); 2058 RTC_DCHECK_RUN_ON(&thread_checker_);
2058 // |sink| may be invalidated after this task was posted since 2059 // |sink| may be invalidated after this task was posted since
2059 // RemoveSink is called on the worker thread. 2060 // RemoveSink is called on the worker thread.
2060 bool encoder_sink_valid = (sink == encoder_sink_); 2061 bool encoder_sink_valid = (sink == encoder_sink_);
2061 if (source_ && encoder_sink_valid) { 2062 if (source_ && encoder_sink_valid) {
2062 source_->AddOrUpdateSink(encoder_sink_, wants); 2063 source_->AddOrUpdateSink(encoder_sink_, wants);
2063 } 2064 }
2064 }); 2065 });
2065 } 2066 }
2066 } 2067 }
2067 2068
2068 VideoSenderInfo WebRtcVideoChannel2::WebRtcVideoSendStream::GetVideoSenderInfo( 2069 VideoSenderInfo WebRtcVideoChannel::WebRtcVideoSendStream::GetVideoSenderInfo(
2069 bool log_stats) { 2070 bool log_stats) {
2070 VideoSenderInfo info; 2071 VideoSenderInfo info;
2071 RTC_DCHECK_RUN_ON(&thread_checker_); 2072 RTC_DCHECK_RUN_ON(&thread_checker_);
2072 for (uint32_t ssrc : parameters_.config.rtp.ssrcs) 2073 for (uint32_t ssrc : parameters_.config.rtp.ssrcs)
2073 info.add_ssrc(ssrc); 2074 info.add_ssrc(ssrc);
2074 2075
2075 if (parameters_.codec_settings) { 2076 if (parameters_.codec_settings) {
2076 info.codec_name = parameters_.codec_settings->codec.name; 2077 info.codec_name = parameters_.codec_settings->codec.name;
2077 info.codec_payload_type = rtc::Optional<int>( 2078 info.codec_payload_type = rtc::Optional<int>(
2078 parameters_.codec_settings->codec.id); 2079 parameters_.codec_settings->codec.id);
(...skipping 56 matching lines...) Expand 10 before | Expand all | Expand 10 after
2135 webrtc::VideoSendStream::StreamStats first_stream_stats = 2136 webrtc::VideoSendStream::StreamStats first_stream_stats =
2136 stats.substreams.begin()->second; 2137 stats.substreams.begin()->second;
2137 info.fraction_lost = 2138 info.fraction_lost =
2138 static_cast<float>(first_stream_stats.rtcp_stats.fraction_lost) / 2139 static_cast<float>(first_stream_stats.rtcp_stats.fraction_lost) /
2139 (1 << 8); 2140 (1 << 8);
2140 } 2141 }
2141 2142
2142 return info; 2143 return info;
2143 } 2144 }
2144 2145
2145 void WebRtcVideoChannel2::WebRtcVideoSendStream::FillBitrateInfo( 2146 void WebRtcVideoChannel::WebRtcVideoSendStream::FillBitrateInfo(
2146 BandwidthEstimationInfo* bwe_info) { 2147 BandwidthEstimationInfo* bwe_info) {
2147 RTC_DCHECK_RUN_ON(&thread_checker_); 2148 RTC_DCHECK_RUN_ON(&thread_checker_);
2148 if (stream_ == NULL) { 2149 if (stream_ == NULL) {
2149 return; 2150 return;
2150 } 2151 }
2151 webrtc::VideoSendStream::Stats stats = stream_->GetStats(); 2152 webrtc::VideoSendStream::Stats stats = stream_->GetStats();
2152 for (std::map<uint32_t, webrtc::VideoSendStream::StreamStats>::iterator it = 2153 for (std::map<uint32_t, webrtc::VideoSendStream::StreamStats>::iterator it =
2153 stats.substreams.begin(); 2154 stats.substreams.begin();
2154 it != stats.substreams.end(); ++it) { 2155 it != stats.substreams.end(); ++it) {
2155 bwe_info->transmit_bitrate += it->second.total_bitrate_bps; 2156 bwe_info->transmit_bitrate += it->second.total_bitrate_bps;
2156 bwe_info->retransmit_bitrate += it->second.retransmit_bitrate_bps; 2157 bwe_info->retransmit_bitrate += it->second.retransmit_bitrate_bps;
2157 } 2158 }
2158 bwe_info->target_enc_bitrate += stats.target_media_bitrate_bps; 2159 bwe_info->target_enc_bitrate += stats.target_media_bitrate_bps;
2159 bwe_info->actual_enc_bitrate += stats.media_bitrate_bps; 2160 bwe_info->actual_enc_bitrate += stats.media_bitrate_bps;
2160 } 2161 }
2161 2162
2162 void WebRtcVideoChannel2::WebRtcVideoSendStream::RecreateWebRtcStream() { 2163 void WebRtcVideoChannel::WebRtcVideoSendStream::RecreateWebRtcStream() {
2163 RTC_DCHECK_RUN_ON(&thread_checker_); 2164 RTC_DCHECK_RUN_ON(&thread_checker_);
2164 if (stream_ != NULL) { 2165 if (stream_ != NULL) {
2165 call_->DestroyVideoSendStream(stream_); 2166 call_->DestroyVideoSendStream(stream_);
2166 } 2167 }
2167 2168
2168 RTC_CHECK(parameters_.codec_settings); 2169 RTC_CHECK(parameters_.codec_settings);
2169 RTC_DCHECK_EQ((parameters_.encoder_config.content_type == 2170 RTC_DCHECK_EQ((parameters_.encoder_config.content_type ==
2170 webrtc::VideoEncoderConfig::ContentType::kScreen), 2171 webrtc::VideoEncoderConfig::ContentType::kScreen),
2171 parameters_.options.is_screencast.value_or(false)) 2172 parameters_.options.is_screencast.value_or(false))
2172 << "encoder content type inconsistent with screencast option"; 2173 << "encoder content type inconsistent with screencast option";
(...skipping 12 matching lines...) Expand all
2185 parameters_.encoder_config.encoder_specific_settings = NULL; 2186 parameters_.encoder_config.encoder_specific_settings = NULL;
2186 2187
2187 if (source_) { 2188 if (source_) {
2188 stream_->SetSource(this, GetDegradationPreference()); 2189 stream_->SetSource(this, GetDegradationPreference());
2189 } 2190 }
2190 2191
2191 // Call stream_->Start() if necessary conditions are met. 2192 // Call stream_->Start() if necessary conditions are met.
2192 UpdateSendState(); 2193 UpdateSendState();
2193 } 2194 }
2194 2195
2195 WebRtcVideoChannel2::WebRtcVideoReceiveStream::WebRtcVideoReceiveStream( 2196 WebRtcVideoChannel::WebRtcVideoReceiveStream::WebRtcVideoReceiveStream(
2196 webrtc::Call* call, 2197 webrtc::Call* call,
2197 const StreamParams& sp, 2198 const StreamParams& sp,
2198 webrtc::VideoReceiveStream::Config config, 2199 webrtc::VideoReceiveStream::Config config,
2199 WebRtcVideoDecoderFactory* external_decoder_factory, 2200 WebRtcVideoDecoderFactory* external_decoder_factory,
2200 bool default_stream, 2201 bool default_stream,
2201 const std::vector<VideoCodecSettings>& recv_codecs, 2202 const std::vector<VideoCodecSettings>& recv_codecs,
2202 const webrtc::FlexfecReceiveStream::Config& flexfec_config) 2203 const webrtc::FlexfecReceiveStream::Config& flexfec_config)
2203 : call_(call), 2204 : call_(call),
2204 stream_params_(sp), 2205 stream_params_(sp),
2205 stream_(NULL), 2206 stream_(NULL),
2206 default_stream_(default_stream), 2207 default_stream_(default_stream),
2207 config_(std::move(config)), 2208 config_(std::move(config)),
2208 flexfec_config_(flexfec_config), 2209 flexfec_config_(flexfec_config),
2209 flexfec_stream_(nullptr), 2210 flexfec_stream_(nullptr),
2210 external_decoder_factory_(external_decoder_factory), 2211 external_decoder_factory_(external_decoder_factory),
2211 sink_(NULL), 2212 sink_(NULL),
2212 first_frame_timestamp_(-1), 2213 first_frame_timestamp_(-1),
2213 estimated_remote_start_ntp_time_ms_(0) { 2214 estimated_remote_start_ntp_time_ms_(0) {
2214 config_.renderer = this; 2215 config_.renderer = this;
2215 std::vector<AllocatedDecoder> old_decoders; 2216 std::vector<AllocatedDecoder> old_decoders;
2216 ConfigureCodecs(recv_codecs, &old_decoders); 2217 ConfigureCodecs(recv_codecs, &old_decoders);
2217 ConfigureFlexfecCodec(flexfec_config.payload_type); 2218 ConfigureFlexfecCodec(flexfec_config.payload_type);
2218 MaybeRecreateWebRtcFlexfecStream(); 2219 MaybeRecreateWebRtcFlexfecStream();
2219 RecreateWebRtcVideoStream(); 2220 RecreateWebRtcVideoStream();
2220 RTC_DCHECK(old_decoders.empty()); 2221 RTC_DCHECK(old_decoders.empty());
2221 } 2222 }
2222 2223
2223 WebRtcVideoChannel2::WebRtcVideoReceiveStream::AllocatedDecoder:: 2224 WebRtcVideoChannel::WebRtcVideoReceiveStream::AllocatedDecoder::
2224 AllocatedDecoder(webrtc::VideoDecoder* decoder, 2225 AllocatedDecoder(webrtc::VideoDecoder* decoder,
2225 webrtc::VideoCodecType type, 2226 webrtc::VideoCodecType type,
2226 bool external) 2227 bool external)
2227 : decoder(decoder), 2228 : decoder(decoder),
2228 external_decoder(nullptr), 2229 external_decoder(nullptr),
2229 type(type), 2230 type(type),
2230 external(external) { 2231 external(external) {
2231 if (external) { 2232 if (external) {
2232 external_decoder = decoder; 2233 external_decoder = decoder;
2233 this->decoder = 2234 this->decoder =
2234 new webrtc::VideoDecoderSoftwareFallbackWrapper(type, external_decoder); 2235 new webrtc::VideoDecoderSoftwareFallbackWrapper(type, external_decoder);
2235 } 2236 }
2236 } 2237 }
2237 2238
2238 WebRtcVideoChannel2::WebRtcVideoReceiveStream::~WebRtcVideoReceiveStream() { 2239 WebRtcVideoChannel::WebRtcVideoReceiveStream::~WebRtcVideoReceiveStream() {
2239 if (flexfec_stream_) { 2240 if (flexfec_stream_) {
2240 call_->DestroyFlexfecReceiveStream(flexfec_stream_); 2241 call_->DestroyFlexfecReceiveStream(flexfec_stream_);
2241 } 2242 }
2242 call_->DestroyVideoReceiveStream(stream_); 2243 call_->DestroyVideoReceiveStream(stream_);
2243 ClearDecoders(&allocated_decoders_); 2244 ClearDecoders(&allocated_decoders_);
2244 } 2245 }
2245 2246
2246 const std::vector<uint32_t>& 2247 const std::vector<uint32_t>&
2247 WebRtcVideoChannel2::WebRtcVideoReceiveStream::GetSsrcs() const { 2248 WebRtcVideoChannel::WebRtcVideoReceiveStream::GetSsrcs() const {
2248 return stream_params_.ssrcs; 2249 return stream_params_.ssrcs;
2249 } 2250 }
2250 2251
2251 rtc::Optional<uint32_t> 2252 rtc::Optional<uint32_t>
2252 WebRtcVideoChannel2::WebRtcVideoReceiveStream::GetFirstPrimarySsrc() const { 2253 WebRtcVideoChannel::WebRtcVideoReceiveStream::GetFirstPrimarySsrc() const {
2253 std::vector<uint32_t> primary_ssrcs; 2254 std::vector<uint32_t> primary_ssrcs;
2254 stream_params_.GetPrimarySsrcs(&primary_ssrcs); 2255 stream_params_.GetPrimarySsrcs(&primary_ssrcs);
2255 2256
2256 if (primary_ssrcs.empty()) { 2257 if (primary_ssrcs.empty()) {
2257 LOG(LS_WARNING) << "Empty primary ssrcs vector, returning empty optional"; 2258 LOG(LS_WARNING) << "Empty primary ssrcs vector, returning empty optional";
2258 return rtc::Optional<uint32_t>(); 2259 return rtc::Optional<uint32_t>();
2259 } else { 2260 } else {
2260 return rtc::Optional<uint32_t>(primary_ssrcs[0]); 2261 return rtc::Optional<uint32_t>(primary_ssrcs[0]);
2261 } 2262 }
2262 } 2263 }
2263 2264
2264 WebRtcVideoChannel2::WebRtcVideoReceiveStream::AllocatedDecoder 2265 WebRtcVideoChannel::WebRtcVideoReceiveStream::AllocatedDecoder
2265 WebRtcVideoChannel2::WebRtcVideoReceiveStream::CreateOrReuseVideoDecoder( 2266 WebRtcVideoChannel::WebRtcVideoReceiveStream::CreateOrReuseVideoDecoder(
2266 std::vector<AllocatedDecoder>* old_decoders, 2267 std::vector<AllocatedDecoder>* old_decoders,
2267 const VideoCodec& codec) { 2268 const VideoCodec& codec) {
2268 webrtc::VideoCodecType type = webrtc::PayloadNameToCodecType(codec.name) 2269 webrtc::VideoCodecType type = webrtc::PayloadNameToCodecType(codec.name)
2269 .value_or(webrtc::kVideoCodecUnknown); 2270 .value_or(webrtc::kVideoCodecUnknown);
2270 2271
2271 for (size_t i = 0; i < old_decoders->size(); ++i) { 2272 for (size_t i = 0; i < old_decoders->size(); ++i) {
2272 if ((*old_decoders)[i].type == type) { 2273 if ((*old_decoders)[i].type == type) {
2273 AllocatedDecoder decoder = (*old_decoders)[i]; 2274 AllocatedDecoder decoder = (*old_decoders)[i];
2274 (*old_decoders)[i] = old_decoders->back(); 2275 (*old_decoders)[i] = old_decoders->back();
2275 old_decoders->pop_back(); 2276 old_decoders->pop_back();
2276 return decoder; 2277 return decoder;
2277 } 2278 }
2278 } 2279 }
2279 2280
2280 if (external_decoder_factory_ != NULL) { 2281 if (external_decoder_factory_ != NULL) {
2281 webrtc::VideoDecoder* decoder = 2282 webrtc::VideoDecoder* decoder =
2282 external_decoder_factory_->CreateVideoDecoderWithParams( 2283 external_decoder_factory_->CreateVideoDecoderWithParams(
2283 type, {stream_params_.id}); 2284 type, {stream_params_.id});
2284 if (decoder != NULL) { 2285 if (decoder != NULL) {
2285 return AllocatedDecoder(decoder, type, true /* is_external */); 2286 return AllocatedDecoder(decoder, type, true /* is_external */);
2286 } 2287 }
2287 } 2288 }
2288 2289
2289 InternalDecoderFactory internal_decoder_factory; 2290 InternalDecoderFactory internal_decoder_factory;
2290 return AllocatedDecoder(internal_decoder_factory.CreateVideoDecoderWithParams( 2291 return AllocatedDecoder(internal_decoder_factory.CreateVideoDecoderWithParams(
2291 type, {stream_params_.id}), 2292 type, {stream_params_.id}),
2292 type, false /* is_external */); 2293 type, false /* is_external */);
2293 } 2294 }
2294 2295
2295 void WebRtcVideoChannel2::WebRtcVideoReceiveStream::ConfigureCodecs( 2296 void WebRtcVideoChannel::WebRtcVideoReceiveStream::ConfigureCodecs(
2296 const std::vector<VideoCodecSettings>& recv_codecs, 2297 const std::vector<VideoCodecSettings>& recv_codecs,
2297 std::vector<AllocatedDecoder>* old_decoders) { 2298 std::vector<AllocatedDecoder>* old_decoders) {
2298 *old_decoders = allocated_decoders_; 2299 *old_decoders = allocated_decoders_;
2299 allocated_decoders_.clear(); 2300 allocated_decoders_.clear();
2300 config_.decoders.clear(); 2301 config_.decoders.clear();
2301 for (size_t i = 0; i < recv_codecs.size(); ++i) { 2302 for (size_t i = 0; i < recv_codecs.size(); ++i) {
2302 AllocatedDecoder allocated_decoder = 2303 AllocatedDecoder allocated_decoder =
2303 CreateOrReuseVideoDecoder(old_decoders, recv_codecs[i].codec); 2304 CreateOrReuseVideoDecoder(old_decoders, recv_codecs[i].codec);
2304 allocated_decoders_.push_back(allocated_decoder); 2305 allocated_decoders_.push_back(allocated_decoder);
2305 2306
(...skipping 10 matching lines...) Expand all
2316 config_.rtp.rtx_payload_types[recv_codec.codec.id] = 2317 config_.rtp.rtx_payload_types[recv_codec.codec.id] =
2317 recv_codec.rtx_payload_type; 2318 recv_codec.rtx_payload_type;
2318 } 2319 }
2319 2320
2320 config_.rtp.ulpfec = recv_codecs.front().ulpfec; 2321 config_.rtp.ulpfec = recv_codecs.front().ulpfec;
2321 2322
2322 config_.rtp.nack.rtp_history_ms = 2323 config_.rtp.nack.rtp_history_ms =
2323 HasNack(recv_codecs.begin()->codec) ? kNackHistoryMs : 0; 2324 HasNack(recv_codecs.begin()->codec) ? kNackHistoryMs : 0;
2324 } 2325 }
2325 2326
2326 void WebRtcVideoChannel2::WebRtcVideoReceiveStream::ConfigureFlexfecCodec( 2327 void WebRtcVideoChannel::WebRtcVideoReceiveStream::ConfigureFlexfecCodec(
2327 int flexfec_payload_type) { 2328 int flexfec_payload_type) {
2328 flexfec_config_.payload_type = flexfec_payload_type; 2329 flexfec_config_.payload_type = flexfec_payload_type;
2329 } 2330 }
2330 2331
2331 void WebRtcVideoChannel2::WebRtcVideoReceiveStream::SetLocalSsrc( 2332 void WebRtcVideoChannel::WebRtcVideoReceiveStream::SetLocalSsrc(
2332 uint32_t local_ssrc) { 2333 uint32_t local_ssrc) {
2333 // TODO(pbos): Consider turning this sanity check into a RTC_DCHECK. You 2334 // TODO(pbos): Consider turning this sanity check into a RTC_DCHECK. You
2334 // should not be able to create a sender with the same SSRC as a receiver, but 2335 // should not be able to create a sender with the same SSRC as a receiver, but
2335 // right now this can't be done due to unittests depending on receiving what 2336 // right now this can't be done due to unittests depending on receiving what
2336 // they are sending from the same MediaChannel. 2337 // they are sending from the same MediaChannel.
2337 if (local_ssrc == config_.rtp.remote_ssrc) { 2338 if (local_ssrc == config_.rtp.remote_ssrc) {
2338 LOG(LS_INFO) << "Ignoring call to SetLocalSsrc because parameters are " 2339 LOG(LS_INFO) << "Ignoring call to SetLocalSsrc because parameters are "
2339 "unchanged; local_ssrc=" << local_ssrc; 2340 "unchanged; local_ssrc=" << local_ssrc;
2340 return; 2341 return;
2341 } 2342 }
2342 2343
2343 config_.rtp.local_ssrc = local_ssrc; 2344 config_.rtp.local_ssrc = local_ssrc;
2344 flexfec_config_.local_ssrc = local_ssrc; 2345 flexfec_config_.local_ssrc = local_ssrc;
2345 LOG(LS_INFO) 2346 LOG(LS_INFO)
2346 << "RecreateWebRtcStream (recv) because of SetLocalSsrc; local_ssrc=" 2347 << "RecreateWebRtcStream (recv) because of SetLocalSsrc; local_ssrc="
2347 << local_ssrc; 2348 << local_ssrc;
2348 MaybeRecreateWebRtcFlexfecStream(); 2349 MaybeRecreateWebRtcFlexfecStream();
2349 RecreateWebRtcVideoStream(); 2350 RecreateWebRtcVideoStream();
2350 } 2351 }
2351 2352
2352 void WebRtcVideoChannel2::WebRtcVideoReceiveStream::SetFeedbackParameters( 2353 void WebRtcVideoChannel::WebRtcVideoReceiveStream::SetFeedbackParameters(
2353 bool nack_enabled, 2354 bool nack_enabled,
2354 bool remb_enabled, 2355 bool remb_enabled,
2355 bool transport_cc_enabled, 2356 bool transport_cc_enabled,
2356 webrtc::RtcpMode rtcp_mode) { 2357 webrtc::RtcpMode rtcp_mode) {
2357 int nack_history_ms = nack_enabled ? kNackHistoryMs : 0; 2358 int nack_history_ms = nack_enabled ? kNackHistoryMs : 0;
2358 if (config_.rtp.nack.rtp_history_ms == nack_history_ms && 2359 if (config_.rtp.nack.rtp_history_ms == nack_history_ms &&
2359 config_.rtp.remb == remb_enabled && 2360 config_.rtp.remb == remb_enabled &&
2360 config_.rtp.transport_cc == transport_cc_enabled && 2361 config_.rtp.transport_cc == transport_cc_enabled &&
2361 config_.rtp.rtcp_mode == rtcp_mode) { 2362 config_.rtp.rtcp_mode == rtcp_mode) {
2362 LOG(LS_INFO) 2363 LOG(LS_INFO)
(...skipping 12 matching lines...) Expand all
2375 flexfec_config_.transport_cc = config_.rtp.transport_cc; 2376 flexfec_config_.transport_cc = config_.rtp.transport_cc;
2376 flexfec_config_.rtcp_mode = config_.rtp.rtcp_mode; 2377 flexfec_config_.rtcp_mode = config_.rtp.rtcp_mode;
2377 LOG(LS_INFO) 2378 LOG(LS_INFO)
2378 << "RecreateWebRtcStream (recv) because of SetFeedbackParameters; nack=" 2379 << "RecreateWebRtcStream (recv) because of SetFeedbackParameters; nack="
2379 << nack_enabled << ", remb=" << remb_enabled 2380 << nack_enabled << ", remb=" << remb_enabled
2380 << ", transport_cc=" << transport_cc_enabled; 2381 << ", transport_cc=" << transport_cc_enabled;
2381 MaybeRecreateWebRtcFlexfecStream(); 2382 MaybeRecreateWebRtcFlexfecStream();
2382 RecreateWebRtcVideoStream(); 2383 RecreateWebRtcVideoStream();
2383 } 2384 }
2384 2385
2385 void WebRtcVideoChannel2::WebRtcVideoReceiveStream::SetRecvParameters( 2386 void WebRtcVideoChannel::WebRtcVideoReceiveStream::SetRecvParameters(
2386 const ChangedRecvParameters& params) { 2387 const ChangedRecvParameters& params) {
2387 bool video_needs_recreation = false; 2388 bool video_needs_recreation = false;
2388 bool flexfec_needs_recreation = false; 2389 bool flexfec_needs_recreation = false;
2389 std::vector<AllocatedDecoder> old_decoders; 2390 std::vector<AllocatedDecoder> old_decoders;
2390 if (params.codec_settings) { 2391 if (params.codec_settings) {
2391 ConfigureCodecs(*params.codec_settings, &old_decoders); 2392 ConfigureCodecs(*params.codec_settings, &old_decoders);
2392 video_needs_recreation = true; 2393 video_needs_recreation = true;
2393 } 2394 }
2394 if (params.rtp_header_extensions) { 2395 if (params.rtp_header_extensions) {
2395 config_.rtp.extensions = *params.rtp_header_extensions; 2396 config_.rtp.extensions = *params.rtp_header_extensions;
(...skipping 11 matching lines...) Expand all
2407 MaybeRecreateWebRtcFlexfecStream(); 2408 MaybeRecreateWebRtcFlexfecStream();
2408 } 2409 }
2409 if (video_needs_recreation) { 2410 if (video_needs_recreation) {
2410 LOG(LS_INFO) 2411 LOG(LS_INFO)
2411 << "RecreateWebRtcVideoStream (recv) because of SetRecvParameters"; 2412 << "RecreateWebRtcVideoStream (recv) because of SetRecvParameters";
2412 RecreateWebRtcVideoStream(); 2413 RecreateWebRtcVideoStream();
2413 ClearDecoders(&old_decoders); 2414 ClearDecoders(&old_decoders);
2414 } 2415 }
2415 } 2416 }
2416 2417
2417 void WebRtcVideoChannel2::WebRtcVideoReceiveStream:: 2418 void WebRtcVideoChannel::WebRtcVideoReceiveStream::
2418 RecreateWebRtcVideoStream() { 2419 RecreateWebRtcVideoStream() {
2419 if (stream_) { 2420 if (stream_) {
2420 call_->DestroyVideoReceiveStream(stream_); 2421 call_->DestroyVideoReceiveStream(stream_);
2421 stream_ = nullptr; 2422 stream_ = nullptr;
2422 } 2423 }
2423 webrtc::VideoReceiveStream::Config config = config_.Copy(); 2424 webrtc::VideoReceiveStream::Config config = config_.Copy();
2424 config.rtp.protected_by_flexfec = (flexfec_stream_ != nullptr); 2425 config.rtp.protected_by_flexfec = (flexfec_stream_ != nullptr);
2425 stream_ = call_->CreateVideoReceiveStream(std::move(config)); 2426 stream_ = call_->CreateVideoReceiveStream(std::move(config));
2426 stream_->Start(); 2427 stream_->Start();
2427 } 2428 }
2428 2429
2429 void WebRtcVideoChannel2::WebRtcVideoReceiveStream:: 2430 void WebRtcVideoChannel::WebRtcVideoReceiveStream::
2430 MaybeRecreateWebRtcFlexfecStream() { 2431 MaybeRecreateWebRtcFlexfecStream() {
2431 if (flexfec_stream_) { 2432 if (flexfec_stream_) {
2432 call_->DestroyFlexfecReceiveStream(flexfec_stream_); 2433 call_->DestroyFlexfecReceiveStream(flexfec_stream_);
2433 flexfec_stream_ = nullptr; 2434 flexfec_stream_ = nullptr;
2434 } 2435 }
2435 if (flexfec_config_.IsCompleteAndEnabled()) { 2436 if (flexfec_config_.IsCompleteAndEnabled()) {
2436 flexfec_stream_ = call_->CreateFlexfecReceiveStream(flexfec_config_); 2437 flexfec_stream_ = call_->CreateFlexfecReceiveStream(flexfec_config_);
2437 flexfec_stream_->Start(); 2438 flexfec_stream_->Start();
2438 } 2439 }
2439 } 2440 }
2440 2441
2441 void WebRtcVideoChannel2::WebRtcVideoReceiveStream::ClearDecoders( 2442 void WebRtcVideoChannel::WebRtcVideoReceiveStream::ClearDecoders(
2442 std::vector<AllocatedDecoder>* allocated_decoders) { 2443 std::vector<AllocatedDecoder>* allocated_decoders) {
2443 for (size_t i = 0; i < allocated_decoders->size(); ++i) { 2444 for (size_t i = 0; i < allocated_decoders->size(); ++i) {
2444 if ((*allocated_decoders)[i].external) { 2445 if ((*allocated_decoders)[i].external) {
2445 external_decoder_factory_->DestroyVideoDecoder( 2446 external_decoder_factory_->DestroyVideoDecoder(
2446 (*allocated_decoders)[i].external_decoder); 2447 (*allocated_decoders)[i].external_decoder);
2447 } 2448 }
2448 delete (*allocated_decoders)[i].decoder; 2449 delete (*allocated_decoders)[i].decoder;
2449 } 2450 }
2450 allocated_decoders->clear(); 2451 allocated_decoders->clear();
2451 } 2452 }
2452 2453
2453 void WebRtcVideoChannel2::WebRtcVideoReceiveStream::OnFrame( 2454 void WebRtcVideoChannel::WebRtcVideoReceiveStream::OnFrame(
2454 const webrtc::VideoFrame& frame) { 2455 const webrtc::VideoFrame& frame) {
2455 rtc::CritScope crit(&sink_lock_); 2456 rtc::CritScope crit(&sink_lock_);
2456 2457
2457 if (first_frame_timestamp_ < 0) 2458 if (first_frame_timestamp_ < 0)
2458 first_frame_timestamp_ = frame.timestamp(); 2459 first_frame_timestamp_ = frame.timestamp();
2459 int64_t rtp_time_elapsed_since_first_frame = 2460 int64_t rtp_time_elapsed_since_first_frame =
2460 (timestamp_wraparound_handler_.Unwrap(frame.timestamp()) - 2461 (timestamp_wraparound_handler_.Unwrap(frame.timestamp()) -
2461 first_frame_timestamp_); 2462 first_frame_timestamp_);
2462 int64_t elapsed_time_ms = rtp_time_elapsed_since_first_frame / 2463 int64_t elapsed_time_ms = rtp_time_elapsed_since_first_frame /
2463 (cricket::kVideoCodecClockrate / 1000); 2464 (cricket::kVideoCodecClockrate / 1000);
2464 if (frame.ntp_time_ms() > 0) 2465 if (frame.ntp_time_ms() > 0)
2465 estimated_remote_start_ntp_time_ms_ = frame.ntp_time_ms() - elapsed_time_ms; 2466 estimated_remote_start_ntp_time_ms_ = frame.ntp_time_ms() - elapsed_time_ms;
2466 2467
2467 if (sink_ == NULL) { 2468 if (sink_ == NULL) {
2468 LOG(LS_WARNING) << "VideoReceiveStream not connected to a VideoSink."; 2469 LOG(LS_WARNING) << "VideoReceiveStream not connected to a VideoSink.";
2469 return; 2470 return;
2470 } 2471 }
2471 2472
2472 sink_->OnFrame(frame); 2473 sink_->OnFrame(frame);
2473 } 2474 }
2474 2475
2475 bool WebRtcVideoChannel2::WebRtcVideoReceiveStream::IsDefaultStream() const { 2476 bool WebRtcVideoChannel::WebRtcVideoReceiveStream::IsDefaultStream() const {
2476 return default_stream_; 2477 return default_stream_;
2477 } 2478 }
2478 2479
2479 void WebRtcVideoChannel2::WebRtcVideoReceiveStream::SetSink( 2480 void WebRtcVideoChannel::WebRtcVideoReceiveStream::SetSink(
2480 rtc::VideoSinkInterface<webrtc::VideoFrame>* sink) { 2481 rtc::VideoSinkInterface<webrtc::VideoFrame>* sink) {
2481 rtc::CritScope crit(&sink_lock_); 2482 rtc::CritScope crit(&sink_lock_);
2482 sink_ = sink; 2483 sink_ = sink;
2483 } 2484 }
2484 2485
2485 std::string 2486 std::string
2486 WebRtcVideoChannel2::WebRtcVideoReceiveStream::GetCodecNameFromPayloadType( 2487 WebRtcVideoChannel::WebRtcVideoReceiveStream::GetCodecNameFromPayloadType(
2487 int payload_type) { 2488 int payload_type) {
2488 for (const webrtc::VideoReceiveStream::Decoder& decoder : config_.decoders) { 2489 for (const webrtc::VideoReceiveStream::Decoder& decoder : config_.decoders) {
2489 if (decoder.payload_type == payload_type) { 2490 if (decoder.payload_type == payload_type) {
2490 return decoder.payload_name; 2491 return decoder.payload_name;
2491 } 2492 }
2492 } 2493 }
2493 return ""; 2494 return "";
2494 } 2495 }
2495 2496
2496 VideoReceiverInfo 2497 VideoReceiverInfo
2497 WebRtcVideoChannel2::WebRtcVideoReceiveStream::GetVideoReceiverInfo( 2498 WebRtcVideoChannel::WebRtcVideoReceiveStream::GetVideoReceiverInfo(
2498 bool log_stats) { 2499 bool log_stats) {
2499 VideoReceiverInfo info; 2500 VideoReceiverInfo info;
2500 info.ssrc_groups = stream_params_.ssrc_groups; 2501 info.ssrc_groups = stream_params_.ssrc_groups;
2501 info.add_ssrc(config_.rtp.remote_ssrc); 2502 info.add_ssrc(config_.rtp.remote_ssrc);
2502 webrtc::VideoReceiveStream::Stats stats = stream_->GetStats(); 2503 webrtc::VideoReceiveStream::Stats stats = stream_->GetStats();
2503 info.decoder_implementation_name = stats.decoder_implementation_name; 2504 info.decoder_implementation_name = stats.decoder_implementation_name;
2504 if (stats.current_payload_type != -1) { 2505 if (stats.current_payload_type != -1) {
2505 info.codec_payload_type = rtc::Optional<int>( 2506 info.codec_payload_type = rtc::Optional<int>(
2506 stats.current_payload_type); 2507 stats.current_payload_type);
2507 } 2508 }
(...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after
2542 info.firs_sent = stats.rtcp_packet_type_counts.fir_packets; 2543 info.firs_sent = stats.rtcp_packet_type_counts.fir_packets;
2543 info.plis_sent = stats.rtcp_packet_type_counts.pli_packets; 2544 info.plis_sent = stats.rtcp_packet_type_counts.pli_packets;
2544 info.nacks_sent = stats.rtcp_packet_type_counts.nack_packets; 2545 info.nacks_sent = stats.rtcp_packet_type_counts.nack_packets;
2545 2546
2546 if (log_stats) 2547 if (log_stats)
2547 LOG(LS_INFO) << stats.ToString(rtc::TimeMillis()); 2548 LOG(LS_INFO) << stats.ToString(rtc::TimeMillis());
2548 2549
2549 return info; 2550 return info;
2550 } 2551 }
2551 2552
2552 WebRtcVideoChannel2::VideoCodecSettings::VideoCodecSettings() 2553 WebRtcVideoChannel::VideoCodecSettings::VideoCodecSettings()
2553 : flexfec_payload_type(-1), rtx_payload_type(-1) {} 2554 : flexfec_payload_type(-1), rtx_payload_type(-1) {}
2554 2555
2555 bool WebRtcVideoChannel2::VideoCodecSettings::operator==( 2556 bool WebRtcVideoChannel::VideoCodecSettings::operator==(
2556 const WebRtcVideoChannel2::VideoCodecSettings& other) const { 2557 const WebRtcVideoChannel::VideoCodecSettings& other) const {
2557 return codec == other.codec && ulpfec == other.ulpfec && 2558 return codec == other.codec && ulpfec == other.ulpfec &&
2558 flexfec_payload_type == other.flexfec_payload_type && 2559 flexfec_payload_type == other.flexfec_payload_type &&
2559 rtx_payload_type == other.rtx_payload_type; 2560 rtx_payload_type == other.rtx_payload_type;
2560 } 2561 }
2561 2562
2562 bool WebRtcVideoChannel2::VideoCodecSettings::EqualsDisregardingFlexfec( 2563 bool WebRtcVideoChannel::VideoCodecSettings::EqualsDisregardingFlexfec(
2563 const WebRtcVideoChannel2::VideoCodecSettings& a, 2564 const WebRtcVideoChannel::VideoCodecSettings& a,
2564 const WebRtcVideoChannel2::VideoCodecSettings& b) { 2565 const WebRtcVideoChannel::VideoCodecSettings& b) {
2565 return a.codec == b.codec && a.ulpfec == b.ulpfec && 2566 return a.codec == b.codec && a.ulpfec == b.ulpfec &&
2566 a.rtx_payload_type == b.rtx_payload_type; 2567 a.rtx_payload_type == b.rtx_payload_type;
2567 } 2568 }
2568 2569
2569 bool WebRtcVideoChannel2::VideoCodecSettings::operator!=( 2570 bool WebRtcVideoChannel::VideoCodecSettings::operator!=(
2570 const WebRtcVideoChannel2::VideoCodecSettings& other) const { 2571 const WebRtcVideoChannel::VideoCodecSettings& other) const {
2571 return !(*this == other); 2572 return !(*this == other);
2572 } 2573 }
2573 2574
2574 std::vector<WebRtcVideoChannel2::VideoCodecSettings> 2575 std::vector<WebRtcVideoChannel::VideoCodecSettings>
2575 WebRtcVideoChannel2::MapCodecs(const std::vector<VideoCodec>& codecs) { 2576 WebRtcVideoChannel::MapCodecs(const std::vector<VideoCodec>& codecs) {
2576 RTC_DCHECK(!codecs.empty()); 2577 RTC_DCHECK(!codecs.empty());
2577 2578
2578 std::vector<VideoCodecSettings> video_codecs; 2579 std::vector<VideoCodecSettings> video_codecs;
2579 std::map<int, bool> payload_used; 2580 std::map<int, bool> payload_used;
2580 std::map<int, VideoCodec::CodecType> payload_codec_type; 2581 std::map<int, VideoCodec::CodecType> payload_codec_type;
2581 // |rtx_mapping| maps video payload type to rtx payload type. 2582 // |rtx_mapping| maps video payload type to rtx payload type.
2582 std::map<int, int> rtx_mapping; 2583 std::map<int, int> rtx_mapping;
2583 2584
2584 webrtc::UlpfecConfig ulpfec_config; 2585 webrtc::UlpfecConfig ulpfec_config;
2585 int flexfec_payload_type = -1; 2586 int flexfec_payload_type = -1;
(...skipping 83 matching lines...) Expand 10 before | Expand all | Expand 10 after
2669 rtx_mapping[video_codecs[i].codec.id] != 2670 rtx_mapping[video_codecs[i].codec.id] !=
2670 ulpfec_config.red_payload_type) { 2671 ulpfec_config.red_payload_type) {
2671 video_codecs[i].rtx_payload_type = rtx_mapping[video_codecs[i].codec.id]; 2672 video_codecs[i].rtx_payload_type = rtx_mapping[video_codecs[i].codec.id];
2672 } 2673 }
2673 } 2674 }
2674 2675
2675 return video_codecs; 2676 return video_codecs;
2676 } 2677 }
2677 2678
2678 } // namespace cricket 2679 } // namespace cricket
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698