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/net/rtp/cast_message_builder.h" | 5 #include "media/cast/net/rtp/cast_message_builder.h" |
6 | 6 |
7 #include "media/cast/cast_defines.h" | 7 #include "media/cast/cast_defines.h" |
8 | 8 |
9 namespace media { | 9 namespace media { |
10 namespace cast { | 10 namespace cast { |
11 | 11 |
12 CastMessageBuilder::CastMessageBuilder( | 12 CastMessageBuilder::CastMessageBuilder( |
13 base::TickClock* clock, | 13 base::TickClock* clock, |
14 RtpPayloadFeedback* incoming_payload_feedback, | 14 RtpPayloadFeedback* incoming_payload_feedback, |
15 FrameIdMap* frame_id_map, | 15 FrameIdMap* frame_id_map, |
16 uint32 media_ssrc, | 16 uint32 media_ssrc, |
17 bool decoder_faster_than_max_frame_rate, | 17 bool decoder_faster_than_max_frame_rate, |
18 int max_unacked_frames) | 18 int max_unacked_frames) |
19 : clock_(clock), | 19 : clock_(clock), |
20 cast_feedback_(incoming_payload_feedback), | 20 cast_feedback_(incoming_payload_feedback), |
21 frame_id_map_(frame_id_map), | 21 frame_id_map_(frame_id_map), |
22 media_ssrc_(media_ssrc), | 22 media_ssrc_(media_ssrc), |
23 decoder_faster_than_max_frame_rate_(decoder_faster_than_max_frame_rate), | 23 decoder_faster_than_max_frame_rate_(decoder_faster_than_max_frame_rate), |
24 max_unacked_frames_(max_unacked_frames), | 24 max_unacked_frames_(max_unacked_frames), |
25 cast_msg_(media_ssrc), | 25 cast_msg_(media_ssrc), |
26 slowing_down_ack_(false), | 26 slowing_down_ack_(false), |
27 acked_last_frame_(true), | 27 acked_last_frame_(true), |
28 last_acked_frame_id_(kStartFrameId) { | 28 last_acked_frame_id_(kStartFrameId) { |
29 cast_msg_.ack_frame_id_ = kStartFrameId; | 29 cast_msg_.ack_frame_id = kStartFrameId; |
30 } | 30 } |
31 | 31 |
32 CastMessageBuilder::~CastMessageBuilder() {} | 32 CastMessageBuilder::~CastMessageBuilder() {} |
33 | 33 |
34 void CastMessageBuilder::CompleteFrameReceived(uint32 frame_id) { | 34 void CastMessageBuilder::CompleteFrameReceived(uint32 frame_id) { |
35 DCHECK_GE(static_cast<int32>(frame_id - last_acked_frame_id_), 0); | 35 DCHECK_GE(static_cast<int32>(frame_id - last_acked_frame_id_), 0); |
36 VLOG(2) << "CompleteFrameReceived: " << frame_id; | 36 VLOG(2) << "CompleteFrameReceived: " << frame_id; |
37 if (last_update_time_.is_null()) { | 37 if (last_update_time_.is_null()) { |
38 // Our first update. | 38 // Our first update. |
39 last_update_time_ = clock_->NowTicks(); | 39 last_update_time_ = clock_->NowTicks(); |
(...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
79 frame_id = ack_queue_.front(); | 79 frame_id = ack_queue_.front(); |
80 } | 80 } |
81 | 81 |
82 acked_last_frame_ = false; | 82 acked_last_frame_ = false; |
83 // Is it a new frame? | 83 // Is it a new frame? |
84 if (last_acked_frame_id_ == frame_id) { | 84 if (last_acked_frame_id_ == frame_id) { |
85 return false; | 85 return false; |
86 } | 86 } |
87 acked_last_frame_ = true; | 87 acked_last_frame_ = true; |
88 last_acked_frame_id_ = frame_id; | 88 last_acked_frame_id_ = frame_id; |
89 cast_msg_.ack_frame_id_ = last_acked_frame_id_; | 89 cast_msg_.ack_frame_id = last_acked_frame_id_; |
90 cast_msg_.missing_frames_and_packets_.clear(); | 90 cast_msg_.missing_frames_and_packets.clear(); |
91 last_update_time_ = clock_->NowTicks(); | 91 last_update_time_ = clock_->NowTicks(); |
92 return true; | 92 return true; |
93 } | 93 } |
94 | 94 |
95 bool CastMessageBuilder::TimeToSendNextCastMessage( | 95 bool CastMessageBuilder::TimeToSendNextCastMessage( |
96 base::TimeTicks* time_to_send) { | 96 base::TimeTicks* time_to_send) { |
97 // We haven't received any packets. | 97 // We haven't received any packets. |
98 if (last_update_time_.is_null() && frame_id_map_->Empty()) | 98 if (last_update_time_.is_null() && frame_id_map_->Empty()) |
99 return false; | 99 return false; |
100 | 100 |
101 *time_to_send = last_update_time_ + base::TimeDelta::FromMilliseconds( | 101 *time_to_send = last_update_time_ + base::TimeDelta::FromMilliseconds( |
102 kCastMessageUpdateIntervalMs); | 102 kCastMessageUpdateIntervalMs); |
103 return true; | 103 return true; |
104 } | 104 } |
105 | 105 |
106 void CastMessageBuilder::UpdateCastMessage() { | 106 void CastMessageBuilder::UpdateCastMessage() { |
107 RtcpCastMessage message(media_ssrc_); | 107 RtcpCastMessage message(media_ssrc_); |
108 if (!UpdateCastMessageInternal(&message)) | 108 if (!UpdateCastMessageInternal(&message)) |
109 return; | 109 return; |
110 | 110 |
111 // Send cast message. | 111 // Send cast message. |
112 cast_feedback_->CastFeedback(message); | 112 cast_feedback_->CastFeedback(message); |
113 } | 113 } |
114 | 114 |
115 void CastMessageBuilder::Reset() { | 115 void CastMessageBuilder::Reset() { |
116 cast_msg_.ack_frame_id_ = kStartFrameId; | 116 cast_msg_.ack_frame_id = kStartFrameId; |
117 cast_msg_.missing_frames_and_packets_.clear(); | 117 cast_msg_.missing_frames_and_packets.clear(); |
118 time_last_nacked_map_.clear(); | 118 time_last_nacked_map_.clear(); |
119 } | 119 } |
120 | 120 |
121 bool CastMessageBuilder::UpdateCastMessageInternal(RtcpCastMessage* message) { | 121 bool CastMessageBuilder::UpdateCastMessageInternal(RtcpCastMessage* message) { |
122 if (last_update_time_.is_null()) { | 122 if (last_update_time_.is_null()) { |
123 if (!frame_id_map_->Empty()) { | 123 if (!frame_id_map_->Empty()) { |
124 // We have received packets. | 124 // We have received packets. |
125 last_update_time_ = clock_->NowTicks(); | 125 last_update_time_ = clock_->NowTicks(); |
126 } | 126 } |
127 return false; | 127 return false; |
128 } | 128 } |
129 // Is it time to update the cast message? | 129 // Is it time to update the cast message? |
130 base::TimeTicks now = clock_->NowTicks(); | 130 base::TimeTicks now = clock_->NowTicks(); |
131 if (now - last_update_time_ < | 131 if (now - last_update_time_ < |
132 base::TimeDelta::FromMilliseconds(kCastMessageUpdateIntervalMs)) { | 132 base::TimeDelta::FromMilliseconds(kCastMessageUpdateIntervalMs)) { |
133 return false; | 133 return false; |
134 } | 134 } |
135 last_update_time_ = now; | 135 last_update_time_ = now; |
136 | 136 |
137 // Needed to cover when a frame is skipped. | 137 // Needed to cover when a frame is skipped. |
138 UpdateAckMessage(last_acked_frame_id_); | 138 UpdateAckMessage(last_acked_frame_id_); |
139 BuildPacketList(); | 139 BuildPacketList(); |
140 message->Copy(cast_msg_); | 140 *message = cast_msg_; |
141 return true; | 141 return true; |
142 } | 142 } |
143 | 143 |
144 void CastMessageBuilder::BuildPacketList() { | 144 void CastMessageBuilder::BuildPacketList() { |
145 base::TimeTicks now = clock_->NowTicks(); | 145 base::TimeTicks now = clock_->NowTicks(); |
146 | 146 |
147 // Clear message NACK list. | 147 // Clear message NACK list. |
148 cast_msg_.missing_frames_and_packets_.clear(); | 148 cast_msg_.missing_frames_and_packets.clear(); |
149 | 149 |
150 // Are we missing packets? | 150 // Are we missing packets? |
151 if (frame_id_map_->Empty()) | 151 if (frame_id_map_->Empty()) |
152 return; | 152 return; |
153 | 153 |
154 uint32 newest_frame_id = frame_id_map_->NewestFrameId(); | 154 uint32 newest_frame_id = frame_id_map_->NewestFrameId(); |
155 uint32 next_expected_frame_id = cast_msg_.ack_frame_id_ + 1; | 155 uint32 next_expected_frame_id = cast_msg_.ack_frame_id + 1; |
156 | 156 |
157 // Iterate over all frames. | 157 // Iterate over all frames. |
158 for (; !IsNewerFrameId(next_expected_frame_id, newest_frame_id); | 158 for (; !IsNewerFrameId(next_expected_frame_id, newest_frame_id); |
159 ++next_expected_frame_id) { | 159 ++next_expected_frame_id) { |
160 TimeLastNackMap::iterator it = | 160 TimeLastNackMap::iterator it = |
161 time_last_nacked_map_.find(next_expected_frame_id); | 161 time_last_nacked_map_.find(next_expected_frame_id); |
162 if (it != time_last_nacked_map_.end()) { | 162 if (it != time_last_nacked_map_.end()) { |
163 // We have sent a NACK in this frame before, make sure enough time have | 163 // We have sent a NACK in this frame before, make sure enough time have |
164 // passed. | 164 // passed. |
165 if (now - it->second < | 165 if (now - it->second < |
166 base::TimeDelta::FromMilliseconds(kNackRepeatIntervalMs)) { | 166 base::TimeDelta::FromMilliseconds(kNackRepeatIntervalMs)) { |
167 continue; | 167 continue; |
168 } | 168 } |
169 } | 169 } |
170 | 170 |
171 PacketIdSet missing; | 171 PacketIdSet missing; |
172 if (frame_id_map_->FrameExists(next_expected_frame_id)) { | 172 if (frame_id_map_->FrameExists(next_expected_frame_id)) { |
173 bool last_frame = (newest_frame_id == next_expected_frame_id); | 173 bool last_frame = (newest_frame_id == next_expected_frame_id); |
174 frame_id_map_->GetMissingPackets( | 174 frame_id_map_->GetMissingPackets( |
175 next_expected_frame_id, last_frame, &missing); | 175 next_expected_frame_id, last_frame, &missing); |
176 if (!missing.empty()) { | 176 if (!missing.empty()) { |
177 time_last_nacked_map_[next_expected_frame_id] = now; | 177 time_last_nacked_map_[next_expected_frame_id] = now; |
178 cast_msg_.missing_frames_and_packets_.insert( | 178 cast_msg_.missing_frames_and_packets.insert( |
179 std::make_pair(next_expected_frame_id, missing)); | 179 std::make_pair(next_expected_frame_id, missing)); |
180 } | 180 } |
181 } else { | 181 } else { |
182 time_last_nacked_map_[next_expected_frame_id] = now; | 182 time_last_nacked_map_[next_expected_frame_id] = now; |
183 missing.insert(kRtcpCastAllPacketsLost); | 183 missing.insert(kRtcpCastAllPacketsLost); |
184 cast_msg_.missing_frames_and_packets_[next_expected_frame_id] = missing; | 184 cast_msg_.missing_frames_and_packets[next_expected_frame_id] = missing; |
185 } | 185 } |
186 } | 186 } |
187 } | 187 } |
188 | 188 |
189 } // namespace cast | 189 } // namespace cast |
190 } // namespace media | 190 } // namespace media |
OLD | NEW |