OLD | NEW |
1 /* | 1 /* |
2 * Copyright (c) 2012 The WebRTC project authors. All Rights Reserved. | 2 * Copyright (c) 2012 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 214 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
225 | 225 |
226 void SendSideCongestionController::Process() { | 226 void SendSideCongestionController::Process() { |
227 bitrate_controller_->Process(); | 227 bitrate_controller_->Process(); |
228 probe_controller_->Process(); | 228 probe_controller_->Process(); |
229 MaybeTriggerOnNetworkChanged(); | 229 MaybeTriggerOnNetworkChanged(); |
230 } | 230 } |
231 | 231 |
232 void SendSideCongestionController::AddPacket( | 232 void SendSideCongestionController::AddPacket( |
233 uint32_t ssrc, | 233 uint32_t ssrc, |
234 uint16_t sequence_number, | 234 uint16_t sequence_number, |
235 size_t length, | 235 size_t payload_size, |
| 236 size_t rtp_headers_size, |
236 const PacedPacketInfo& pacing_info) { | 237 const PacedPacketInfo& pacing_info) { |
237 transport_feedback_adapter_.AddPacket(ssrc, sequence_number, length, | 238 transport_feedback_adapter_.AddPacket(ssrc, sequence_number, payload_size, |
238 pacing_info); | 239 rtp_headers_size, pacing_info); |
239 } | 240 } |
240 | 241 |
241 void SendSideCongestionController::OnTransportFeedback( | 242 void SendSideCongestionController::OnTransportFeedback( |
242 const rtcp::TransportFeedback& feedback) { | 243 const rtcp::TransportFeedback& feedback) { |
243 RTC_DCHECK(worker_thread_checker_.CalledOnValidThread()); | 244 RTC_DCHECK(worker_thread_checker_.CalledOnValidThread()); |
244 transport_feedback_adapter_.OnTransportFeedback(feedback); | 245 transport_feedback_adapter_.OnTransportFeedback(feedback); |
245 std::vector<PacketFeedback> feedback_vector = | 246 std::vector<PacketFeedback> feedback_vector = |
246 transport_feedback_adapter_.GetTransportFeedbackVector(); | 247 transport_feedback_adapter_.GetTransportFeedbackVector(); |
247 DelayBasedBwe::Result result; | 248 DelayBasedBwe::Result result; |
248 { | 249 { |
(...skipping 62 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
311 bool SendSideCongestionController::IsSendQueueFull() const { | 312 bool SendSideCongestionController::IsSendQueueFull() const { |
312 return pacer_->ExpectedQueueTimeMs() > PacedSender::kMaxQueueLengthMs; | 313 return pacer_->ExpectedQueueTimeMs() > PacedSender::kMaxQueueLengthMs; |
313 } | 314 } |
314 | 315 |
315 bool SendSideCongestionController::IsNetworkDown() const { | 316 bool SendSideCongestionController::IsNetworkDown() const { |
316 rtc::CritScope cs(&network_state_lock_); | 317 rtc::CritScope cs(&network_state_lock_); |
317 return network_state_ == kNetworkDown; | 318 return network_state_ == kNetworkDown; |
318 } | 319 } |
319 | 320 |
320 } // namespace webrtc | 321 } // namespace webrtc |
OLD | NEW |