OLD | NEW |
---|---|
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 Loading... | |
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 Loading... | |
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 Loading... | |
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 Loading... | |
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 Loading... | |
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 Loading... | |
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 Loading... | |
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 Loading... | |
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 Loading... | |
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 Loading... | |
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 Loading... | |
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 Loading... | |
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 Loading... | |
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 Loading... | |
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 Loading... | |
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 Loading... | |
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 Loading... | |
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 Loading... | |
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 Loading... | |
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 Loading... | |
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 Loading... | |
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 Loading... | |
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 Loading... | |
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 Loading... | |
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 Loading... | |
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 Loading... | |
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 Loading... | |
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 |
OLD | NEW |