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

Side by Side Diff: webrtc/modules/remote_bitrate_estimator/test/estimators/send_side.cc

Issue 1663413003: Clean up of CongestionController. (Closed) Base URL: https://chromium.googlesource.com/external/webrtc.git@master
Patch Set: Rebase. Created 4 years, 10 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) 2015 The WebRTC project authors. All Rights Reserved. 2 * Copyright (c) 2015 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
(...skipping 83 matching lines...) Expand 10 before | Expand all | Expand 10 after
94 MediaPacket* media_packet = static_cast<MediaPacket*>(packet); 94 MediaPacket* media_packet = static_cast<MediaPacket*>(packet);
95 send_time_history_.AddAndRemoveOld(media_packet->header().sequenceNumber, 95 send_time_history_.AddAndRemoveOld(media_packet->header().sequenceNumber,
96 media_packet->payload_size(), 96 media_packet->payload_size(),
97 packet->paced()); 97 packet->paced());
98 send_time_history_.OnSentPacket(media_packet->header().sequenceNumber, 98 send_time_history_.OnSentPacket(media_packet->header().sequenceNumber,
99 media_packet->sender_timestamp_ms()); 99 media_packet->sender_timestamp_ms());
100 } 100 }
101 } 101 }
102 } 102 }
103 103
104 void FullBweSender::OnReceiveBitrateChanged( 104 void FullBweSender::OnReceiveBitrateChanged(const std::vector<uint32_t>& ssrcs,
105 const std::vector<unsigned int>& ssrcs, 105 uint32_t bitrate) {
106 unsigned int bitrate) {
107 feedback_observer_->OnReceivedEstimatedBitrate(bitrate); 106 feedback_observer_->OnReceivedEstimatedBitrate(bitrate);
108 } 107 }
109 108
110 int64_t FullBweSender::TimeUntilNextProcess() { 109 int64_t FullBweSender::TimeUntilNextProcess() {
111 return bitrate_controller_->TimeUntilNextProcess(); 110 return bitrate_controller_->TimeUntilNextProcess();
112 } 111 }
113 112
114 int FullBweSender::Process() { 113 int FullBweSender::Process() {
115 rbe_->Process(); 114 rbe_->Process();
116 return bitrate_controller_->Process(); 115 return bitrate_controller_->Process();
(...skipping 25 matching lines...) Expand all
142 packet_feedback_vector_.back().arrival_time_ms; 141 packet_feedback_vector_.back().arrival_time_ms;
143 FeedbackPacket* fb = new SendSideBweFeedback( 142 FeedbackPacket* fb = new SendSideBweFeedback(
144 flow_id_, now_ms * 1000, corrected_send_time_ms, packet_feedback_vector_); 143 flow_id_, now_ms * 1000, corrected_send_time_ms, packet_feedback_vector_);
145 packet_feedback_vector_.clear(); 144 packet_feedback_vector_.clear();
146 return fb; 145 return fb;
147 } 146 }
148 147
149 } // namespace bwe 148 } // namespace bwe
150 } // namespace testing 149 } // namespace testing
151 } // namespace webrtc 150 } // namespace webrtc
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698