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

Side by Side Diff: webrtc/modules/remote_bitrate_estimator/test/packet_sender.cc

Issue 2628563003: Propagate packet pacing information to SenTimeHistory (Closed)
Patch Set: Rebase Created 3 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 257 matching lines...) Expand 10 before | Expand all | Expand 10 after
268 Packets to_transfer; 268 Packets to_transfer;
269 to_transfer.splice(to_transfer.begin(), queue_, queue_.begin(), it); 269 to_transfer.splice(to_transfer.begin(), queue_, queue_.begin(), it);
270 bwe_->OnPacketsSent(to_transfer); 270 bwe_->OnPacketsSent(to_transfer);
271 batch->merge(to_transfer, DereferencingComparator<Packet>); 271 batch->merge(to_transfer, DereferencingComparator<Packet>);
272 } 272 }
273 273
274 bool PacedVideoSender::TimeToSendPacket(uint32_t ssrc, 274 bool PacedVideoSender::TimeToSendPacket(uint32_t ssrc,
275 uint16_t sequence_number, 275 uint16_t sequence_number,
276 int64_t capture_time_ms, 276 int64_t capture_time_ms,
277 bool retransmission, 277 bool retransmission,
278 int probe_cluster_id) { 278 const PacedPacketInfo& pacing_info) {
279 for (Packets::iterator it = pacer_queue_.begin(); it != pacer_queue_.end(); 279 for (Packets::iterator it = pacer_queue_.begin(); it != pacer_queue_.end();
280 ++it) { 280 ++it) {
281 MediaPacket* media_packet = static_cast<MediaPacket*>(*it); 281 MediaPacket* media_packet = static_cast<MediaPacket*>(*it);
282 if (media_packet->header().sequenceNumber == sequence_number) { 282 if (media_packet->header().sequenceNumber == sequence_number) {
283 int64_t pace_out_time_ms = clock_.TimeInMilliseconds(); 283 int64_t pace_out_time_ms = clock_.TimeInMilliseconds();
284 284
285 // Make sure a packet is never paced out earlier than when it was put into 285 // Make sure a packet is never paced out earlier than when it was put into
286 // the pacer. 286 // the pacer.
287 assert(pace_out_time_ms >= media_packet->send_time_ms()); 287 assert(pace_out_time_ms >= media_packet->send_time_ms());
288 288
289 media_packet->SetAbsSendTimeMs(pace_out_time_ms); 289 media_packet->SetAbsSendTimeMs(pace_out_time_ms);
290 media_packet->set_send_time_us(1000 * pace_out_time_ms); 290 media_packet->set_send_time_us(1000 * pace_out_time_ms);
291 media_packet->set_sender_timestamp_us(1000 * pace_out_time_ms); 291 media_packet->set_sender_timestamp_us(1000 * pace_out_time_ms);
292 queue_.push_back(media_packet); 292 queue_.push_back(media_packet);
293 pacer_queue_.erase(it); 293 pacer_queue_.erase(it);
294 return true; 294 return true;
295 } 295 }
296 } 296 }
297 return false; 297 return false;
298 } 298 }
299 299
300 size_t PacedVideoSender::TimeToSendPadding(size_t bytes, int probe_cluster_id) { 300 size_t PacedVideoSender::TimeToSendPadding(size_t bytes,
301 const PacedPacketInfo& pacing_info) {
301 return 0; 302 return 0;
302 } 303 }
303 304
304 void PacedVideoSender::OnNetworkChanged(uint32_t target_bitrate_bps, 305 void PacedVideoSender::OnNetworkChanged(uint32_t target_bitrate_bps,
305 uint8_t fraction_lost, 306 uint8_t fraction_lost,
306 int64_t rtt) { 307 int64_t rtt) {
307 VideoSender::OnNetworkChanged(target_bitrate_bps, fraction_lost, rtt); 308 VideoSender::OnNetworkChanged(target_bitrate_bps, fraction_lost, rtt);
308 pacer_.SetEstimatedBitrate(target_bitrate_bps); 309 pacer_.SetEstimatedBitrate(target_bitrate_bps);
309 } 310 }
310 311
(...skipping 167 matching lines...) Expand 10 before | Expand all | Expand 10 after
478 RecordBitrate(); 479 RecordBitrate();
479 } 480 }
480 481
481 uint32_t TcpSender::TargetBitrateKbps() { 482 uint32_t TcpSender::TargetBitrateKbps() {
482 return bitrate_kbps_; 483 return bitrate_kbps_;
483 } 484 }
484 485
485 } // namespace bwe 486 } // namespace bwe
486 } // namespace testing 487 } // namespace testing
487 } // namespace webrtc 488 } // namespace webrtc
OLDNEW
« no previous file with comments | « webrtc/modules/remote_bitrate_estimator/test/packet_sender.h ('k') | webrtc/modules/rtp_rtcp/include/rtp_rtcp.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698