OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "media/cast/sender/frame_sender.h" | 5 #include "media/cast/sender/frame_sender.h" |
6 | 6 |
7 namespace media { | 7 namespace media { |
8 namespace cast { | 8 namespace cast { |
9 namespace { | 9 namespace { |
10 const int kMinSchedulingDelayMs = 1; | 10 const int kMinSchedulingDelayMs = 1; |
(...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
44 FROM_HERE, | 44 FROM_HERE, |
45 base::Bind(&FrameSender::SendRtcpReport, weak_factory_.GetWeakPtr(), | 45 base::Bind(&FrameSender::SendRtcpReport, weak_factory_.GetWeakPtr(), |
46 true), | 46 true), |
47 time_to_next); | 47 time_to_next); |
48 } | 48 } |
49 | 49 |
50 void FrameSender::SendRtcpReport(bool schedule_future_reports) { | 50 void FrameSender::SendRtcpReport(bool schedule_future_reports) { |
51 DCHECK(cast_environment_->CurrentlyOn(CastEnvironment::MAIN)); | 51 DCHECK(cast_environment_->CurrentlyOn(CastEnvironment::MAIN)); |
52 const base::TimeTicks now = cast_environment_->Clock()->NowTicks(); | 52 const base::TimeTicks now = cast_environment_->Clock()->NowTicks(); |
53 uint32 now_as_rtp_timestamp = 0; | 53 uint32 now_as_rtp_timestamp = 0; |
54 if (rtp_timestamp_helper_.GetCurrentTimeAsRtpTimestamp( | 54 if (rtp_timestamp_helper_.EstimateRtpTimestamp(now, &now_as_rtp_timestamp)) { |
55 now, &now_as_rtp_timestamp)) { | |
56 transport_sender_->SendSenderReport(ssrc_, now, now_as_rtp_timestamp); | 55 transport_sender_->SendSenderReport(ssrc_, now, now_as_rtp_timestamp); |
57 } else { | 56 } else { |
58 // |rtp_timestamp_helper_| should have stored a mapping by this point. | 57 // |rtp_timestamp_helper_| should have stored a mapping by this point. |
59 NOTREACHED(); | 58 NOTREACHED(); |
60 } | 59 } |
61 if (schedule_future_reports) | 60 if (schedule_future_reports) |
62 ScheduleNextRtcpReport(); | 61 ScheduleNextRtcpReport(); |
63 } | 62 } |
64 | 63 |
65 void FrameSender::OnReceivedRtt(base::TimeDelta rtt, | 64 void FrameSender::OnReceivedRtt(base::TimeDelta rtt, |
66 base::TimeDelta avg_rtt, | 65 base::TimeDelta avg_rtt, |
67 base::TimeDelta min_rtt, | 66 base::TimeDelta min_rtt, |
68 base::TimeDelta max_rtt) { | 67 base::TimeDelta max_rtt) { |
69 rtt_available_ = true; | 68 rtt_available_ = true; |
70 rtt_ = rtt; | 69 rtt_ = rtt; |
71 avg_rtt_ = avg_rtt; | 70 avg_rtt_ = avg_rtt; |
72 min_rtt_ = min_rtt; | 71 min_rtt_ = min_rtt; |
73 max_rtt_ = max_rtt; | 72 max_rtt_ = max_rtt; |
74 } | 73 } |
75 | 74 |
76 void FrameSender::SetTargetPlayoutDelay( | 75 void FrameSender::SetTargetPlayoutDelay( |
77 base::TimeDelta new_target_playout_delay) { | 76 base::TimeDelta new_target_playout_delay) { |
78 target_playout_delay_ = new_target_playout_delay; | 77 target_playout_delay_ = new_target_playout_delay; |
79 max_unacked_frames_ = | 78 max_unacked_frames_ = |
80 std::min(kMaxUnackedFrames, | 79 std::min(kMaxUnackedFrames, |
81 1 + static_cast<int>(target_playout_delay_ * | 80 1 + static_cast<int>(target_playout_delay_ * |
82 max_frame_rate_ / | 81 max_frame_rate_ / |
83 base::TimeDelta::FromSeconds(1))); | 82 base::TimeDelta::FromSeconds(1))); |
| 83 max_unacked_rtp_delta_ = |
| 84 1 + TimeDeltaToRtpDelta(target_playout_delay_, |
| 85 rtp_timestamp_helper_.frequency()); |
84 send_target_playout_delay_ = true; | 86 send_target_playout_delay_ = true; |
85 } | 87 } |
86 | 88 |
87 } // namespace cast | 89 } // namespace cast |
88 } // namespace media | 90 } // namespace media |
OLD | NEW |