OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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 <stdint.h> | 5 #include <stdint.h> |
6 | 6 |
7 #include "base/memory/scoped_ptr.h" | 7 #include "base/memory/scoped_ptr.h" |
8 #include "base/test/simple_test_tick_clock.h" | 8 #include "base/test/simple_test_tick_clock.h" |
9 #include "media/cast/framer/cast_message_builder.h" | 9 #include "media/cast/framer/cast_message_builder.h" |
10 #include "media/cast/rtcp/rtcp.h" | 10 #include "media/cast/rtcp/rtcp.h" |
(...skipping 70 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
81 | 81 |
82 class CastMessageBuilderTest : public ::testing::Test { | 82 class CastMessageBuilderTest : public ::testing::Test { |
83 protected: | 83 protected: |
84 CastMessageBuilderTest() | 84 CastMessageBuilderTest() |
85 : cast_msg_builder_(new CastMessageBuilder(&testing_clock_, | 85 : cast_msg_builder_(new CastMessageBuilder(&testing_clock_, |
86 &feedback_, | 86 &feedback_, |
87 &frame_id_map_, | 87 &frame_id_map_, |
88 kSsrc, | 88 kSsrc, |
89 true, | 89 true, |
90 0)) { | 90 0)) { |
91 rtp_header_.webrtc.header.ssrc = kSsrc; | 91 rtp_header_.sender_ssrc = kSsrc; |
92 rtp_header_.is_key_frame = false; | 92 rtp_header_.is_key_frame = false; |
93 testing_clock_.Advance( | 93 testing_clock_.Advance( |
94 base::TimeDelta::FromMilliseconds(kStartMillisecond)); | 94 base::TimeDelta::FromMilliseconds(kStartMillisecond)); |
95 } | 95 } |
96 | 96 |
97 virtual ~CastMessageBuilderTest() {} | 97 virtual ~CastMessageBuilderTest() {} |
98 | 98 |
99 void SetFrameId(uint32 frame_id) { rtp_header_.frame_id = frame_id; } | 99 void SetFrameIds(uint32 frame_id, uint32 reference_frame_id) { |
| 100 rtp_header_.frame_id = frame_id; |
| 101 rtp_header_.reference_frame_id = reference_frame_id; |
| 102 } |
100 | 103 |
101 void SetPacketId(uint16 packet_id) { rtp_header_.packet_id = packet_id; } | 104 void SetPacketId(uint16 packet_id) { rtp_header_.packet_id = packet_id; } |
102 | 105 |
103 void SetMaxPacketId(uint16 max_packet_id) { | 106 void SetMaxPacketId(uint16 max_packet_id) { |
104 rtp_header_.max_packet_id = max_packet_id; | 107 rtp_header_.max_packet_id = max_packet_id; |
105 } | 108 } |
106 | 109 |
107 void SetKeyFrame(bool is_key) { rtp_header_.is_key_frame = is_key; } | 110 void SetKeyFrame(bool is_key) { rtp_header_.is_key_frame = is_key; } |
108 | 111 |
109 void SetReferenceFrameId(uint32 reference_frame_id) { | |
110 rtp_header_.is_reference = true; | |
111 rtp_header_.reference_frame_id = reference_frame_id; | |
112 } | |
113 | |
114 void InsertPacket() { | 112 void InsertPacket() { |
115 PacketType packet_type = frame_id_map_.InsertPacket(rtp_header_); | 113 PacketType packet_type = frame_id_map_.InsertPacket(rtp_header_); |
116 if (packet_type == kNewPacketCompletingFrame) { | 114 if (packet_type == kNewPacketCompletingFrame) { |
117 cast_msg_builder_->CompleteFrameReceived(rtp_header_.frame_id, | 115 cast_msg_builder_->CompleteFrameReceived(rtp_header_.frame_id, |
118 rtp_header_.is_key_frame); | 116 rtp_header_.is_key_frame); |
119 } | 117 } |
120 cast_msg_builder_->UpdateCastMessage(); | 118 cast_msg_builder_->UpdateCastMessage(); |
121 } | 119 } |
122 | 120 |
123 void SetDecoderSlowerThanMaxFrameRate(int max_unacked_frames) { | 121 void SetDecoderSlowerThanMaxFrameRate(int max_unacked_frames) { |
124 cast_msg_builder_.reset(new CastMessageBuilder(&testing_clock_, | 122 cast_msg_builder_.reset(new CastMessageBuilder(&testing_clock_, |
125 &feedback_, | 123 &feedback_, |
126 &frame_id_map_, | 124 &frame_id_map_, |
127 kSsrc, | 125 kSsrc, |
128 false, | 126 false, |
129 max_unacked_frames)); | 127 max_unacked_frames)); |
130 } | 128 } |
131 | 129 |
132 NackFeedbackVerification feedback_; | 130 NackFeedbackVerification feedback_; |
133 scoped_ptr<CastMessageBuilder> cast_msg_builder_; | 131 scoped_ptr<CastMessageBuilder> cast_msg_builder_; |
134 RtpCastHeader rtp_header_; | 132 RtpCastHeader rtp_header_; |
135 FrameIdMap frame_id_map_; | 133 FrameIdMap frame_id_map_; |
136 base::SimpleTestTickClock testing_clock_; | 134 base::SimpleTestTickClock testing_clock_; |
137 | 135 |
138 DISALLOW_COPY_AND_ASSIGN(CastMessageBuilderTest); | 136 DISALLOW_COPY_AND_ASSIGN(CastMessageBuilderTest); |
139 }; | 137 }; |
140 | 138 |
141 TEST_F(CastMessageBuilderTest, StartWithAKeyFrame) { | 139 TEST_F(CastMessageBuilderTest, StartWithAKeyFrame) { |
142 SetFrameId(3); | 140 SetFrameIds(3, 2); |
143 SetPacketId(0); | 141 SetPacketId(0); |
144 SetMaxPacketId(0); | 142 SetMaxPacketId(0); |
145 InsertPacket(); | 143 InsertPacket(); |
146 // Should not trigger ack. | 144 // Should not trigger ack. |
147 EXPECT_FALSE(feedback_.triggered()); | 145 EXPECT_FALSE(feedback_.triggered()); |
148 SetFrameId(5); | 146 SetFrameIds(5, 5); |
149 SetPacketId(0); | 147 SetPacketId(0); |
150 SetMaxPacketId(0); | 148 SetMaxPacketId(0); |
151 SetKeyFrame(true); | 149 SetKeyFrame(true); |
152 InsertPacket(); | 150 InsertPacket(); |
153 frame_id_map_.RemoveOldFrames(5); // Simulate 5 being pulled for rendering. | 151 frame_id_map_.RemoveOldFrames(5); // Simulate 5 being pulled for rendering. |
154 testing_clock_.Advance( | 152 testing_clock_.Advance( |
155 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); | 153 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); |
156 cast_msg_builder_->UpdateCastMessage(); | 154 cast_msg_builder_->UpdateCastMessage(); |
157 EXPECT_TRUE(feedback_.triggered()); | 155 EXPECT_TRUE(feedback_.triggered()); |
158 EXPECT_EQ(5u, feedback_.last_frame_acked()); | 156 EXPECT_EQ(5u, feedback_.last_frame_acked()); |
159 } | 157 } |
160 | 158 |
161 TEST_F(CastMessageBuilderTest, OneFrameNackList) { | 159 TEST_F(CastMessageBuilderTest, OneFrameNackList) { |
162 SetFrameId(0); | 160 SetFrameIds(0, 0); |
163 SetPacketId(4); | 161 SetPacketId(4); |
164 SetMaxPacketId(10); | 162 SetMaxPacketId(10); |
165 InsertPacket(); | 163 InsertPacket(); |
166 testing_clock_.Advance( | 164 testing_clock_.Advance( |
167 base::TimeDelta::FromMilliseconds(kShortTimeIncrementMs)); | 165 base::TimeDelta::FromMilliseconds(kShortTimeIncrementMs)); |
168 EXPECT_FALSE(feedback_.triggered()); | 166 EXPECT_FALSE(feedback_.triggered()); |
169 testing_clock_.Advance( | 167 testing_clock_.Advance( |
170 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); | 168 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); |
171 SetPacketId(5); | 169 SetPacketId(5); |
172 InsertPacket(); | 170 InsertPacket(); |
173 EXPECT_TRUE(feedback_.triggered()); | 171 EXPECT_TRUE(feedback_.triggered()); |
174 EXPECT_EQ(4u, feedback_.num_missing_packets(0)); | 172 EXPECT_EQ(4u, feedback_.num_missing_packets(0)); |
175 } | 173 } |
176 | 174 |
177 TEST_F(CastMessageBuilderTest, CompleteFrameMissing) { | 175 TEST_F(CastMessageBuilderTest, CompleteFrameMissing) { |
178 SetFrameId(0); | 176 SetFrameIds(0, 0); |
179 SetPacketId(2); | 177 SetPacketId(2); |
180 SetMaxPacketId(5); | 178 SetMaxPacketId(5); |
181 InsertPacket(); | 179 InsertPacket(); |
182 testing_clock_.Advance( | 180 testing_clock_.Advance( |
183 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); | 181 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); |
184 SetFrameId(2); | 182 SetFrameIds(2, 1); |
185 SetPacketId(2); | 183 SetPacketId(2); |
186 SetMaxPacketId(5); | 184 SetMaxPacketId(5); |
187 InsertPacket(); | 185 InsertPacket(); |
188 EXPECT_TRUE(feedback_.triggered()); | 186 EXPECT_TRUE(feedback_.triggered()); |
189 EXPECT_EQ(kRtcpCastAllPacketsLost, feedback_.num_missing_packets(1)); | 187 EXPECT_EQ(kRtcpCastAllPacketsLost, feedback_.num_missing_packets(1)); |
190 } | 188 } |
191 | 189 |
192 TEST_F(CastMessageBuilderTest, FastForwardAck) { | 190 TEST_F(CastMessageBuilderTest, FastForwardAck) { |
193 SetFrameId(1); | 191 SetFrameIds(1, 0); |
194 SetPacketId(0); | 192 SetPacketId(0); |
195 SetMaxPacketId(0); | 193 SetMaxPacketId(0); |
196 InsertPacket(); | 194 InsertPacket(); |
197 EXPECT_FALSE(feedback_.triggered()); | 195 EXPECT_FALSE(feedback_.triggered()); |
198 testing_clock_.Advance( | 196 testing_clock_.Advance( |
199 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); | 197 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); |
200 SetFrameId(2); | 198 SetFrameIds(2, 1); |
201 SetPacketId(0); | 199 SetPacketId(0); |
202 SetMaxPacketId(0); | 200 SetMaxPacketId(0); |
203 InsertPacket(); | 201 InsertPacket(); |
204 EXPECT_TRUE(feedback_.triggered()); | 202 EXPECT_TRUE(feedback_.triggered()); |
205 EXPECT_EQ(kStartFrameId, feedback_.last_frame_acked()); | 203 EXPECT_EQ(kStartFrameId, feedback_.last_frame_acked()); |
206 testing_clock_.Advance( | 204 testing_clock_.Advance( |
207 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); | 205 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); |
208 SetFrameId(0); | 206 SetFrameIds(0, 0); |
209 SetPacketId(0); | 207 SetPacketId(0); |
210 SetMaxPacketId(0); | 208 SetMaxPacketId(0); |
211 SetKeyFrame(true); | 209 SetKeyFrame(true); |
212 InsertPacket(); | 210 InsertPacket(); |
213 EXPECT_TRUE(feedback_.triggered()); | 211 EXPECT_TRUE(feedback_.triggered()); |
214 EXPECT_EQ(2u, feedback_.last_frame_acked()); | 212 EXPECT_EQ(2u, feedback_.last_frame_acked()); |
215 } | 213 } |
216 | 214 |
217 TEST_F(CastMessageBuilderTest, RemoveOldFrames) { | 215 TEST_F(CastMessageBuilderTest, RemoveOldFrames) { |
218 SetFrameId(1); | 216 SetFrameIds(1, 0); |
219 SetPacketId(0); | 217 SetPacketId(0); |
220 SetMaxPacketId(1); | 218 SetMaxPacketId(1); |
221 InsertPacket(); | 219 InsertPacket(); |
222 EXPECT_FALSE(feedback_.triggered()); | 220 EXPECT_FALSE(feedback_.triggered()); |
223 testing_clock_.Advance( | 221 testing_clock_.Advance( |
224 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); | 222 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); |
225 SetFrameId(2); | 223 SetFrameIds(2, 1); |
226 SetPacketId(0); | 224 SetPacketId(0); |
227 SetMaxPacketId(0); | 225 SetMaxPacketId(0); |
228 InsertPacket(); | 226 InsertPacket(); |
229 EXPECT_TRUE(feedback_.triggered()); | 227 EXPECT_TRUE(feedback_.triggered()); |
230 testing_clock_.Advance( | 228 testing_clock_.Advance( |
231 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); | 229 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); |
232 SetFrameId(3); | 230 SetFrameIds(3, 2); |
233 SetPacketId(0); | 231 SetPacketId(0); |
234 SetMaxPacketId(5); | 232 SetMaxPacketId(5); |
235 InsertPacket(); | 233 InsertPacket(); |
236 EXPECT_TRUE(feedback_.triggered()); | 234 EXPECT_TRUE(feedback_.triggered()); |
237 EXPECT_EQ(kStartFrameId, feedback_.last_frame_acked()); | 235 EXPECT_EQ(kStartFrameId, feedback_.last_frame_acked()); |
238 testing_clock_.Advance( | 236 testing_clock_.Advance( |
239 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); | 237 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); |
240 SetFrameId(5); | 238 SetFrameIds(5, 5); |
241 SetPacketId(0); | 239 SetPacketId(0); |
242 SetMaxPacketId(0); | 240 SetMaxPacketId(0); |
243 SetKeyFrame(true); | 241 SetKeyFrame(true); |
244 InsertPacket(); | 242 InsertPacket(); |
245 testing_clock_.Advance( | 243 testing_clock_.Advance( |
246 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); | 244 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); |
247 frame_id_map_.RemoveOldFrames(5); // Simulate 5 being pulled for rendering. | 245 frame_id_map_.RemoveOldFrames(5); // Simulate 5 being pulled for rendering. |
248 cast_msg_builder_->UpdateCastMessage(); | 246 cast_msg_builder_->UpdateCastMessage(); |
249 EXPECT_TRUE(feedback_.triggered()); | 247 EXPECT_TRUE(feedback_.triggered()); |
250 EXPECT_EQ(5u, feedback_.last_frame_acked()); | 248 EXPECT_EQ(5u, feedback_.last_frame_acked()); |
251 testing_clock_.Advance( | 249 testing_clock_.Advance( |
252 base::TimeDelta::FromMilliseconds(kShortTimeIncrementMs)); | 250 base::TimeDelta::FromMilliseconds(kShortTimeIncrementMs)); |
253 SetFrameId(1); | 251 SetFrameIds(1, 0); |
254 SetPacketId(1); | 252 SetPacketId(1); |
255 SetMaxPacketId(1); | 253 SetMaxPacketId(1); |
256 InsertPacket(); | 254 InsertPacket(); |
257 EXPECT_FALSE(feedback_.triggered()); | 255 EXPECT_FALSE(feedback_.triggered()); |
258 testing_clock_.Advance( | 256 testing_clock_.Advance( |
259 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); | 257 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); |
260 InsertPacket(); | 258 InsertPacket(); |
261 EXPECT_TRUE(feedback_.triggered()); | 259 EXPECT_TRUE(feedback_.triggered()); |
262 EXPECT_EQ(5u, feedback_.last_frame_acked()); | 260 EXPECT_EQ(5u, feedback_.last_frame_acked()); |
263 } | 261 } |
264 | 262 |
265 TEST_F(CastMessageBuilderTest, WrapFastForward) { | 263 TEST_F(CastMessageBuilderTest, WrapFastForward) { |
266 SetFrameId(254); | 264 SetFrameIds(254, 254); |
267 SetPacketId(0); | 265 SetPacketId(0); |
268 SetMaxPacketId(1); | 266 SetMaxPacketId(1); |
269 SetKeyFrame(true); | 267 SetKeyFrame(true); |
270 InsertPacket(); | 268 InsertPacket(); |
271 EXPECT_FALSE(feedback_.triggered()); | 269 EXPECT_FALSE(feedback_.triggered()); |
272 testing_clock_.Advance( | 270 testing_clock_.Advance( |
273 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); | 271 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); |
274 SetFrameId(255); | 272 SetFrameIds(255, 254); |
275 SetPacketId(0); | 273 SetPacketId(0); |
276 SetMaxPacketId(0); | 274 SetMaxPacketId(0); |
277 SetKeyFrame(false); | 275 SetKeyFrame(false); |
278 InsertPacket(); | 276 InsertPacket(); |
279 EXPECT_TRUE(feedback_.triggered()); | 277 EXPECT_TRUE(feedback_.triggered()); |
280 EXPECT_EQ(253u, feedback_.last_frame_acked()); | 278 EXPECT_EQ(253u, feedback_.last_frame_acked()); |
281 testing_clock_.Advance( | 279 testing_clock_.Advance( |
282 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); | 280 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); |
283 SetFrameId(256); | 281 SetFrameIds(256, 255); |
284 SetPacketId(0); | 282 SetPacketId(0); |
285 SetMaxPacketId(0); | 283 SetMaxPacketId(0); |
286 SetKeyFrame(false); | 284 SetKeyFrame(false); |
287 InsertPacket(); | 285 InsertPacket(); |
288 EXPECT_TRUE(feedback_.triggered()); | 286 EXPECT_TRUE(feedback_.triggered()); |
289 EXPECT_EQ(253u, feedback_.last_frame_acked()); | 287 EXPECT_EQ(253u, feedback_.last_frame_acked()); |
290 testing_clock_.Advance( | 288 testing_clock_.Advance( |
291 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); | 289 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); |
292 SetFrameId(254); | 290 SetFrameIds(254, 254); |
293 SetPacketId(1); | 291 SetPacketId(1); |
294 SetMaxPacketId(1); | 292 SetMaxPacketId(1); |
295 SetKeyFrame(true); | 293 SetKeyFrame(true); |
296 InsertPacket(); | 294 InsertPacket(); |
297 EXPECT_TRUE(feedback_.triggered()); | 295 EXPECT_TRUE(feedback_.triggered()); |
298 EXPECT_EQ(256u, feedback_.last_frame_acked()); | 296 EXPECT_EQ(256u, feedback_.last_frame_acked()); |
299 } | 297 } |
300 | 298 |
301 TEST_F(CastMessageBuilderTest, NackUntilMaxReceivedPacket) { | 299 TEST_F(CastMessageBuilderTest, NackUntilMaxReceivedPacket) { |
302 SetFrameId(0); | 300 SetFrameIds(0, 0); |
303 SetPacketId(0); | 301 SetPacketId(0); |
304 SetMaxPacketId(20); | 302 SetMaxPacketId(20); |
305 SetKeyFrame(true); | 303 SetKeyFrame(true); |
306 InsertPacket(); | 304 InsertPacket(); |
307 testing_clock_.Advance( | 305 testing_clock_.Advance( |
308 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); | 306 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); |
309 SetPacketId(5); | 307 SetPacketId(5); |
310 InsertPacket(); | 308 InsertPacket(); |
311 EXPECT_TRUE(feedback_.triggered()); | 309 EXPECT_TRUE(feedback_.triggered()); |
312 EXPECT_EQ(4u, feedback_.num_missing_packets(0)); | 310 EXPECT_EQ(4u, feedback_.num_missing_packets(0)); |
313 } | 311 } |
314 | 312 |
315 TEST_F(CastMessageBuilderTest, NackUntilMaxReceivedPacketNextFrame) { | 313 TEST_F(CastMessageBuilderTest, NackUntilMaxReceivedPacketNextFrame) { |
316 SetFrameId(0); | 314 SetFrameIds(0, 0); |
317 SetPacketId(0); | 315 SetPacketId(0); |
318 SetMaxPacketId(20); | 316 SetMaxPacketId(20); |
319 SetKeyFrame(true); | 317 SetKeyFrame(true); |
320 InsertPacket(); | 318 InsertPacket(); |
321 testing_clock_.Advance( | 319 testing_clock_.Advance( |
322 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); | 320 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); |
323 SetPacketId(5); | 321 SetPacketId(5); |
324 InsertPacket(); | 322 InsertPacket(); |
325 testing_clock_.Advance( | 323 testing_clock_.Advance( |
326 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); | 324 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); |
327 EXPECT_TRUE(feedback_.triggered()); | 325 EXPECT_TRUE(feedback_.triggered()); |
328 EXPECT_EQ(4u, feedback_.num_missing_packets(0)); | 326 EXPECT_EQ(4u, feedback_.num_missing_packets(0)); |
329 SetFrameId(1); | 327 SetFrameIds(1, 0); |
330 SetMaxPacketId(2); | 328 SetMaxPacketId(2); |
331 SetPacketId(0); | 329 SetPacketId(0); |
332 SetKeyFrame(false); | 330 SetKeyFrame(false); |
333 InsertPacket(); | 331 InsertPacket(); |
334 testing_clock_.Advance( | 332 testing_clock_.Advance( |
335 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); | 333 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); |
336 EXPECT_TRUE(feedback_.triggered()); | 334 EXPECT_TRUE(feedback_.triggered()); |
337 EXPECT_EQ(19u, feedback_.num_missing_packets(0)); | 335 EXPECT_EQ(19u, feedback_.num_missing_packets(0)); |
338 } | 336 } |
339 | 337 |
340 TEST_F(CastMessageBuilderTest, NackUntilMaxReceivedPacketNextKey) { | 338 TEST_F(CastMessageBuilderTest, NackUntilMaxReceivedPacketNextKey) { |
341 SetFrameId(0); | 339 SetFrameIds(0, 0); |
342 SetPacketId(0); | 340 SetPacketId(0); |
343 SetMaxPacketId(20); | 341 SetMaxPacketId(20); |
344 SetKeyFrame(true); | 342 SetKeyFrame(true); |
345 InsertPacket(); | 343 InsertPacket(); |
346 testing_clock_.Advance( | 344 testing_clock_.Advance( |
347 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); | 345 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); |
348 SetPacketId(5); | 346 SetPacketId(5); |
349 InsertPacket(); | 347 InsertPacket(); |
350 testing_clock_.Advance( | 348 testing_clock_.Advance( |
351 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); | 349 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); |
352 EXPECT_TRUE(feedback_.triggered()); | 350 EXPECT_TRUE(feedback_.triggered()); |
353 EXPECT_EQ(4u, feedback_.num_missing_packets(0)); | 351 EXPECT_EQ(4u, feedback_.num_missing_packets(0)); |
354 SetFrameId(1); | 352 SetFrameIds(1, 1); |
355 SetMaxPacketId(0); | 353 SetMaxPacketId(0); |
356 SetPacketId(0); | 354 SetPacketId(0); |
357 SetKeyFrame(true); | 355 SetKeyFrame(true); |
358 InsertPacket(); | 356 InsertPacket(); |
359 testing_clock_.Advance( | 357 testing_clock_.Advance( |
360 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); | 358 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); |
361 EXPECT_TRUE(feedback_.triggered()); | 359 EXPECT_TRUE(feedback_.triggered()); |
362 EXPECT_EQ(0u, feedback_.num_missing_packets(0)); | 360 EXPECT_EQ(0u, feedback_.num_missing_packets(0)); |
363 } | 361 } |
364 | 362 |
365 TEST_F(CastMessageBuilderTest, Reset) { | 363 TEST_F(CastMessageBuilderTest, Reset) { |
366 InsertPacket(); | 364 InsertPacket(); |
367 testing_clock_.Advance( | 365 testing_clock_.Advance( |
368 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); | 366 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); |
369 cast_msg_builder_->Reset(); | 367 cast_msg_builder_->Reset(); |
370 frame_id_map_.Clear(); | 368 frame_id_map_.Clear(); |
371 // Should reset nack list state and request a key frame. | 369 // Should reset nack list state and request a key frame. |
372 cast_msg_builder_->UpdateCastMessage(); | 370 cast_msg_builder_->UpdateCastMessage(); |
373 EXPECT_TRUE(feedback_.triggered()); | 371 EXPECT_TRUE(feedback_.triggered()); |
374 EXPECT_EQ(0u, feedback_.num_missing_packets(0)); | 372 EXPECT_EQ(0u, feedback_.num_missing_packets(0)); |
375 } | 373 } |
376 | 374 |
377 TEST_F(CastMessageBuilderTest, DeltaAfterReset) { | 375 TEST_F(CastMessageBuilderTest, DeltaAfterReset) { |
378 SetFrameId(0); | 376 SetFrameIds(0, 0); |
379 SetPacketId(0); | 377 SetPacketId(0); |
380 SetMaxPacketId(0); | 378 SetMaxPacketId(0); |
381 SetKeyFrame(true); | 379 SetKeyFrame(true); |
382 InsertPacket(); | 380 InsertPacket(); |
383 EXPECT_TRUE(feedback_.triggered()); | 381 EXPECT_TRUE(feedback_.triggered()); |
384 EXPECT_EQ(0u, feedback_.num_missing_packets(0)); | 382 EXPECT_EQ(0u, feedback_.num_missing_packets(0)); |
385 testing_clock_.Advance( | 383 testing_clock_.Advance( |
386 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); | 384 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); |
387 cast_msg_builder_->Reset(); | 385 cast_msg_builder_->Reset(); |
388 SetFrameId(1); | 386 SetFrameIds(1, 0); |
389 SetPacketId(0); | 387 SetPacketId(0); |
390 SetMaxPacketId(0); | 388 SetMaxPacketId(0); |
391 SetKeyFrame(true); | 389 SetKeyFrame(true); |
392 EXPECT_FALSE(feedback_.triggered()); | 390 EXPECT_FALSE(feedback_.triggered()); |
393 } | 391 } |
394 | 392 |
395 TEST_F(CastMessageBuilderTest, BasicRps) { | 393 TEST_F(CastMessageBuilderTest, BasicRps) { |
396 SetFrameId(0); | 394 SetFrameIds(0, 0); |
397 SetPacketId(0); | 395 SetPacketId(0); |
398 SetMaxPacketId(0); | 396 SetMaxPacketId(0); |
399 SetKeyFrame(true); | 397 SetKeyFrame(true); |
400 InsertPacket(); | 398 InsertPacket(); |
401 testing_clock_.Advance( | 399 testing_clock_.Advance( |
402 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); | 400 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); |
403 EXPECT_TRUE(feedback_.triggered()); | 401 EXPECT_TRUE(feedback_.triggered()); |
404 EXPECT_EQ(0u, feedback_.last_frame_acked()); | 402 EXPECT_EQ(0u, feedback_.last_frame_acked()); |
405 SetFrameId(3); | 403 SetFrameIds(3, 0); |
406 SetKeyFrame(false); | 404 SetKeyFrame(false); |
407 SetReferenceFrameId(0); | |
408 InsertPacket(); | 405 InsertPacket(); |
409 EXPECT_TRUE(feedback_.triggered()); | 406 EXPECT_TRUE(feedback_.triggered()); |
410 EXPECT_EQ(0u, feedback_.last_frame_acked()); | 407 EXPECT_EQ(0u, feedback_.last_frame_acked()); |
411 testing_clock_.Advance( | 408 testing_clock_.Advance( |
412 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); | 409 base::TimeDelta::FromMilliseconds(kLongTimeIncrementMs)); |
413 frame_id_map_.RemoveOldFrames(3); // Simulate 3 being pulled for rendering. | 410 frame_id_map_.RemoveOldFrames(3); // Simulate 3 being pulled for rendering. |
414 cast_msg_builder_->UpdateCastMessage(); | 411 cast_msg_builder_->UpdateCastMessage(); |
415 EXPECT_TRUE(feedback_.triggered()); | 412 EXPECT_TRUE(feedback_.triggered()); |
416 EXPECT_EQ(3u, feedback_.last_frame_acked()); | 413 EXPECT_EQ(3u, feedback_.last_frame_acked()); |
417 } | 414 } |
418 | 415 |
419 TEST_F(CastMessageBuilderTest, InOrderRps) { | 416 TEST_F(CastMessageBuilderTest, InOrderRps) { |
420 // Create a pattern - skip to rps, and don't look back. | 417 // Create a pattern - skip to rps, and don't look back. |
421 SetFrameId(0); | 418 SetFrameIds(0, 0); |
422 SetPacketId(0); | 419 SetPacketId(0); |
423 SetMaxPacketId(0); | 420 SetMaxPacketId(0); |
424 SetKeyFrame(true); | 421 SetKeyFrame(true); |
425 InsertPacket(); | 422 InsertPacket(); |
426 testing_clock_.Advance( | 423 testing_clock_.Advance( |
427 base::TimeDelta::FromMilliseconds(kShortTimeIncrementMs)); | 424 base::TimeDelta::FromMilliseconds(kShortTimeIncrementMs)); |
428 EXPECT_TRUE(feedback_.triggered()); | 425 EXPECT_TRUE(feedback_.triggered()); |
429 EXPECT_EQ(0u, feedback_.last_frame_acked()); | 426 EXPECT_EQ(0u, feedback_.last_frame_acked()); |
430 SetFrameId(1); | 427 SetFrameIds(1, 0); |
431 SetPacketId(0); | 428 SetPacketId(0); |
432 SetMaxPacketId(1); | 429 SetMaxPacketId(1); |
433 SetKeyFrame(false); | 430 SetKeyFrame(false); |
434 InsertPacket(); | 431 InsertPacket(); |
435 testing_clock_.Advance( | 432 testing_clock_.Advance( |
436 base::TimeDelta::FromMilliseconds(kShortTimeIncrementMs)); | 433 base::TimeDelta::FromMilliseconds(kShortTimeIncrementMs)); |
437 EXPECT_FALSE(feedback_.triggered()); | 434 EXPECT_FALSE(feedback_.triggered()); |
438 SetFrameId(3); | 435 SetFrameIds(3, 0); |
439 SetPacketId(0); | 436 SetPacketId(0); |
440 SetMaxPacketId(0); | 437 SetMaxPacketId(0); |
441 SetKeyFrame(false); | 438 SetKeyFrame(false); |
442 SetReferenceFrameId(0); | |
443 InsertPacket(); | 439 InsertPacket(); |
444 testing_clock_.Advance( | 440 testing_clock_.Advance( |
445 base::TimeDelta::FromMilliseconds(kShortTimeIncrementMs)); | 441 base::TimeDelta::FromMilliseconds(kShortTimeIncrementMs)); |
446 frame_id_map_.RemoveOldFrames(3); // Simulate 3 being pulled for rendering. | 442 frame_id_map_.RemoveOldFrames(3); // Simulate 3 being pulled for rendering. |
447 testing_clock_.Advance( | 443 testing_clock_.Advance( |
448 base::TimeDelta::FromMilliseconds(kShortTimeIncrementMs)); | 444 base::TimeDelta::FromMilliseconds(kShortTimeIncrementMs)); |
449 cast_msg_builder_->UpdateCastMessage(); | 445 cast_msg_builder_->UpdateCastMessage(); |
450 EXPECT_TRUE(feedback_.triggered()); | 446 EXPECT_TRUE(feedback_.triggered()); |
451 EXPECT_EQ(3u, feedback_.last_frame_acked()); | 447 EXPECT_EQ(3u, feedback_.last_frame_acked()); |
452 // Make an old frame complete - should not trigger an ack. | 448 // Make an old frame complete - should not trigger an ack. |
453 SetFrameId(1); | 449 SetFrameIds(1, 0); |
454 SetPacketId(1); | 450 SetPacketId(1); |
455 SetMaxPacketId(1); | 451 SetMaxPacketId(1); |
456 SetKeyFrame(false); | 452 SetKeyFrame(false); |
457 InsertPacket(); | 453 InsertPacket(); |
458 testing_clock_.Advance( | 454 testing_clock_.Advance( |
459 base::TimeDelta::FromMilliseconds(kShortTimeIncrementMs)); | 455 base::TimeDelta::FromMilliseconds(kShortTimeIncrementMs)); |
460 EXPECT_FALSE(feedback_.triggered()); | 456 EXPECT_FALSE(feedback_.triggered()); |
461 EXPECT_EQ(3u, feedback_.last_frame_acked()); | 457 EXPECT_EQ(3u, feedback_.last_frame_acked()); |
462 } | 458 } |
463 | 459 |
464 TEST_F(CastMessageBuilderTest, SlowDownAck) { | 460 TEST_F(CastMessageBuilderTest, SlowDownAck) { |
465 SetDecoderSlowerThanMaxFrameRate(3); | 461 SetDecoderSlowerThanMaxFrameRate(3); |
466 SetFrameId(0); | 462 SetFrameIds(0, 0); |
467 SetPacketId(0); | 463 SetPacketId(0); |
468 SetMaxPacketId(0); | 464 SetMaxPacketId(0); |
469 SetKeyFrame(true); | 465 SetKeyFrame(true); |
470 InsertPacket(); | 466 InsertPacket(); |
471 | 467 |
472 uint32 frame_id; | 468 uint32 frame_id; |
473 testing_clock_.Advance( | 469 testing_clock_.Advance( |
474 base::TimeDelta::FromMilliseconds(kShortTimeIncrementMs)); | 470 base::TimeDelta::FromMilliseconds(kShortTimeIncrementMs)); |
475 SetKeyFrame(false); | 471 SetKeyFrame(false); |
476 for (frame_id = 1; frame_id < 3; ++frame_id) { | 472 for (frame_id = 1; frame_id < 3; ++frame_id) { |
477 EXPECT_TRUE(feedback_.triggered()); | 473 EXPECT_TRUE(feedback_.triggered()); |
478 EXPECT_EQ(frame_id - 1, feedback_.last_frame_acked()); | 474 EXPECT_EQ(frame_id - 1, feedback_.last_frame_acked()); |
479 SetFrameId(frame_id); | 475 SetFrameIds(frame_id, frame_id - 1); |
480 InsertPacket(); | 476 InsertPacket(); |
481 testing_clock_.Advance( | 477 testing_clock_.Advance( |
482 base::TimeDelta::FromMilliseconds(kShortTimeIncrementMs)); | 478 base::TimeDelta::FromMilliseconds(kShortTimeIncrementMs)); |
483 } | 479 } |
484 // We should now have entered the slowdown ACK state. | 480 // We should now have entered the slowdown ACK state. |
485 uint32 expected_frame_id = 1; | 481 uint32 expected_frame_id = 1; |
486 for (; frame_id < 10; ++frame_id) { | 482 for (; frame_id < 10; ++frame_id) { |
487 if (frame_id % 2) | 483 if (frame_id % 2) |
488 ++expected_frame_id; | 484 ++expected_frame_id; |
489 EXPECT_TRUE(feedback_.triggered()); | 485 EXPECT_TRUE(feedback_.triggered()); |
490 EXPECT_EQ(expected_frame_id, feedback_.last_frame_acked()); | 486 EXPECT_EQ(expected_frame_id, feedback_.last_frame_acked()); |
491 SetFrameId(frame_id); | 487 SetFrameIds(frame_id, frame_id - 1); |
492 InsertPacket(); | 488 InsertPacket(); |
493 testing_clock_.Advance( | 489 testing_clock_.Advance( |
494 base::TimeDelta::FromMilliseconds(kShortTimeIncrementMs)); | 490 base::TimeDelta::FromMilliseconds(kShortTimeIncrementMs)); |
495 } | 491 } |
496 EXPECT_TRUE(feedback_.triggered()); | 492 EXPECT_TRUE(feedback_.triggered()); |
497 EXPECT_EQ(expected_frame_id, feedback_.last_frame_acked()); | 493 EXPECT_EQ(expected_frame_id, feedback_.last_frame_acked()); |
498 | 494 |
499 // Simulate frame_id being pulled for rendering. | 495 // Simulate frame_id being pulled for rendering. |
500 frame_id_map_.RemoveOldFrames(frame_id); | 496 frame_id_map_.RemoveOldFrames(frame_id); |
501 // We should now leave the slowdown ACK state. | 497 // We should now leave the slowdown ACK state. |
502 ++frame_id; | 498 ++frame_id; |
503 SetFrameId(frame_id); | 499 SetFrameIds(frame_id, frame_id - 1); |
504 InsertPacket(); | 500 InsertPacket(); |
505 testing_clock_.Advance( | 501 testing_clock_.Advance( |
506 base::TimeDelta::FromMilliseconds(kShortTimeIncrementMs)); | 502 base::TimeDelta::FromMilliseconds(kShortTimeIncrementMs)); |
507 EXPECT_TRUE(feedback_.triggered()); | 503 EXPECT_TRUE(feedback_.triggered()); |
508 EXPECT_EQ(frame_id, feedback_.last_frame_acked()); | 504 EXPECT_EQ(frame_id, feedback_.last_frame_acked()); |
509 } | 505 } |
510 | 506 |
511 } // namespace cast | 507 } // namespace cast |
512 } // namespace media | 508 } // namespace media |
OLD | NEW |