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

Side by Side Diff: webrtc/video/video_send_stream.cc

Issue 2725823002: Move delay_based_bwe_ into CongestionController (Closed)
Patch Set: More refactoring + UTs moved. Created 3 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
1 /* 1 /*
2 * Copyright (c) 2013 The WebRTC project authors. All Rights Reserved. 2 * Copyright (c) 2013 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 #include "webrtc/video/video_send_stream.h" 10 #include "webrtc/video/video_send_stream.h"
(...skipping 740 matching lines...) Expand 10 before | Expand all | Expand 10 after
751 PacketRouter* packet_router, 751 PacketRouter* packet_router,
752 BitrateAllocator* bitrate_allocator, 752 BitrateAllocator* bitrate_allocator,
753 SendDelayStats* send_delay_stats, 753 SendDelayStats* send_delay_stats,
754 VieRemb* remb, 754 VieRemb* remb,
755 ViEEncoder* vie_encoder, 755 ViEEncoder* vie_encoder,
756 RtcEventLog* event_log, 756 RtcEventLog* event_log,
757 const VideoSendStream::Config* config, 757 const VideoSendStream::Config* config,
758 int initial_encoder_max_bitrate, 758 int initial_encoder_max_bitrate,
759 std::map<uint32_t, RtpState> suspended_ssrcs) 759 std::map<uint32_t, RtpState> suspended_ssrcs)
760 : send_side_bwe_with_overhead_(webrtc::field_trial::FindFullName( 760 : send_side_bwe_with_overhead_(webrtc::field_trial::FindFullName(
761 "WebRTC-SendSideBwe-WithOverhead") == "Enabled"), 761 "WebRTC-SendSideBwe-WithOverhead") ==
762 "Enabled"),
762 stats_proxy_(stats_proxy), 763 stats_proxy_(stats_proxy),
763 config_(config), 764 config_(config),
764 suspended_ssrcs_(std::move(suspended_ssrcs)), 765 suspended_ssrcs_(std::move(suspended_ssrcs)),
765 module_process_thread_(nullptr), 766 module_process_thread_(nullptr),
766 worker_queue_(worker_queue), 767 worker_queue_(worker_queue),
767 check_encoder_activity_task_(nullptr), 768 check_encoder_activity_task_(nullptr),
768 call_stats_(call_stats), 769 call_stats_(call_stats),
769 congestion_controller_(congestion_controller), 770 congestion_controller_(congestion_controller),
770 packet_router_(packet_router), 771 packet_router_(packet_router),
771 bitrate_allocator_(bitrate_allocator), 772 bitrate_allocator_(bitrate_allocator),
772 remb_(remb), 773 remb_(remb),
773 flexfec_sender_(MaybeCreateFlexfecSender(*config_)), 774 flexfec_sender_(MaybeCreateFlexfecSender(*config_)),
774 max_padding_bitrate_(0), 775 max_padding_bitrate_(0),
775 encoder_min_bitrate_bps_(0), 776 encoder_min_bitrate_bps_(0),
776 encoder_max_bitrate_bps_(initial_encoder_max_bitrate), 777 encoder_max_bitrate_bps_(initial_encoder_max_bitrate),
777 encoder_target_rate_bps_(0), 778 encoder_target_rate_bps_(0),
778 vie_encoder_(vie_encoder), 779 vie_encoder_(vie_encoder),
779 encoder_feedback_(Clock::GetRealTimeClock(), 780 encoder_feedback_(Clock::GetRealTimeClock(),
780 config_->rtp.ssrcs, 781 config_->rtp.ssrcs,
781 vie_encoder), 782 vie_encoder),
782 protection_bitrate_calculator_(Clock::GetRealTimeClock(), this), 783 protection_bitrate_calculator_(Clock::GetRealTimeClock(), this),
783 bandwidth_observer_(congestion_controller_->GetBitrateController() 784 bandwidth_observer_(congestion_controller_->GetBitrateController()
784 ->CreateRtcpBandwidthObserver()), 785 ->CreateRtcpBandwidthObserver()),
785 rtp_rtcp_modules_(CreateRtpRtcpModules( 786 rtp_rtcp_modules_(CreateRtpRtcpModules(
786 config_->send_transport, 787 config_->send_transport,
787 &encoder_feedback_, 788 &encoder_feedback_,
788 bandwidth_observer_.get(), 789 bandwidth_observer_.get(),
789 congestion_controller_->GetTransportFeedbackObserver(), 790 congestion_controller_,
790 call_stats_->rtcp_rtt_stats(), 791 call_stats_->rtcp_rtt_stats(),
791 congestion_controller_->pacer(), 792 congestion_controller_->pacer(),
792 packet_router_, 793 packet_router_,
793 flexfec_sender_.get(), 794 flexfec_sender_.get(),
794 stats_proxy_, 795 stats_proxy_,
795 send_delay_stats, 796 send_delay_stats,
796 event_log, 797 event_log,
797 congestion_controller_->GetRetransmissionRateLimiter(), 798 congestion_controller_->GetRetransmissionRateLimiter(),
798 this, 799 this,
799 config_->rtp.ssrcs.size())), 800 config_->rtp.ssrcs.size())),
(...skipping 535 matching lines...) Expand 10 before | Expand all | Expand 10 after
1335 std::min(config_->rtp.max_packet_size, 1336 std::min(config_->rtp.max_packet_size,
1336 kPathMTU - transport_overhead_bytes_per_packet_); 1337 kPathMTU - transport_overhead_bytes_per_packet_);
1337 1338
1338 for (RtpRtcp* rtp_rtcp : rtp_rtcp_modules_) { 1339 for (RtpRtcp* rtp_rtcp : rtp_rtcp_modules_) {
1339 rtp_rtcp->SetMaxRtpPacketSize(rtp_packet_size); 1340 rtp_rtcp->SetMaxRtpPacketSize(rtp_packet_size);
1340 } 1341 }
1341 } 1342 }
1342 1343
1343 } // namespace internal 1344 } // namespace internal
1344 } // namespace webrtc 1345 } // namespace webrtc
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698