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/receiver/frame_receiver.h" | 5 #include "media/cast/receiver/frame_receiver.h" |
6 | 6 |
7 #include <stddef.h> | 7 #include <stddef.h> |
8 #include <stdint.h> | 8 #include <stdint.h> |
9 #include <deque> | 9 #include <deque> |
10 #include <utility> | 10 #include <utility> |
(...skipping 166 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
177 | 177 |
178 CreateFrameReceiverOfAudio(); | 178 CreateFrameReceiverOfAudio(); |
179 | 179 |
180 SimpleEventSubscriber event_subscriber; | 180 SimpleEventSubscriber event_subscriber; |
181 cast_environment_->logger()->Subscribe(&event_subscriber); | 181 cast_environment_->logger()->Subscribe(&event_subscriber); |
182 | 182 |
183 EXPECT_CALL(mock_transport_, InitializeRtpReceiverRtcpBuilder(_, _)) | 183 EXPECT_CALL(mock_transport_, InitializeRtpReceiverRtcpBuilder(_, _)) |
184 .WillRepeatedly(testing::Return()); | 184 .WillRepeatedly(testing::Return()); |
185 EXPECT_CALL(mock_transport_, AddCastFeedback(_, _)) | 185 EXPECT_CALL(mock_transport_, AddCastFeedback(_, _)) |
186 .WillRepeatedly(testing::Return()); | 186 .WillRepeatedly(testing::Return()); |
| 187 EXPECT_CALL(mock_transport_, AddPli(_)).WillRepeatedly(testing::Return()); |
187 EXPECT_CALL(mock_transport_, AddRtcpEvents(_)) | 188 EXPECT_CALL(mock_transport_, AddRtcpEvents(_)) |
188 .WillRepeatedly(testing::Return()); | 189 .WillRepeatedly(testing::Return()); |
189 EXPECT_CALL(mock_transport_, SendRtcpFromRtpReceiver()) | 190 EXPECT_CALL(mock_transport_, SendRtcpFromRtpReceiver()) |
190 .WillRepeatedly(testing::Return()); | 191 .WillRepeatedly(testing::Return()); |
191 | 192 |
192 FeedLipSyncInfoIntoReceiver(); | 193 FeedLipSyncInfoIntoReceiver(); |
193 task_runner_->RunTasks(); | 194 task_runner_->RunTasks(); |
194 | 195 |
195 // Enqueue a request for a frame. | 196 // Enqueue a request for a frame. |
196 receiver_->RequestEncodedFrame( | 197 receiver_->RequestEncodedFrame( |
(...skipping 30 matching lines...) Expand all Loading... |
227 | 228 |
228 CreateFrameReceiverOfAudio(); | 229 CreateFrameReceiverOfAudio(); |
229 | 230 |
230 SimpleEventSubscriber event_subscriber; | 231 SimpleEventSubscriber event_subscriber; |
231 cast_environment_->logger()->Subscribe(&event_subscriber); | 232 cast_environment_->logger()->Subscribe(&event_subscriber); |
232 | 233 |
233 EXPECT_CALL(mock_transport_, InitializeRtpReceiverRtcpBuilder(_, _)) | 234 EXPECT_CALL(mock_transport_, InitializeRtpReceiverRtcpBuilder(_, _)) |
234 .WillRepeatedly(testing::Return()); | 235 .WillRepeatedly(testing::Return()); |
235 EXPECT_CALL(mock_transport_, AddCastFeedback(_, _)) | 236 EXPECT_CALL(mock_transport_, AddCastFeedback(_, _)) |
236 .WillRepeatedly(testing::Return()); | 237 .WillRepeatedly(testing::Return()); |
| 238 EXPECT_CALL(mock_transport_, AddPli(_)).WillRepeatedly(testing::Return()); |
237 EXPECT_CALL(mock_transport_, AddRtcpEvents(_)) | 239 EXPECT_CALL(mock_transport_, AddRtcpEvents(_)) |
238 .WillRepeatedly(testing::Return()); | 240 .WillRepeatedly(testing::Return()); |
239 EXPECT_CALL(mock_transport_, SendRtcpFromRtpReceiver()) | 241 EXPECT_CALL(mock_transport_, SendRtcpFromRtpReceiver()) |
240 .WillRepeatedly(testing::Return()); | 242 .WillRepeatedly(testing::Return()); |
241 | 243 |
242 const base::TimeDelta time_advance_per_frame = | 244 const base::TimeDelta time_advance_per_frame = |
243 base::TimeDelta::FromSeconds(1) / config_.target_frame_rate; | 245 base::TimeDelta::FromSeconds(1) / config_.target_frame_rate; |
244 const RtpTimeDelta rtp_advance_per_frame = | 246 const RtpTimeDelta rtp_advance_per_frame = |
245 RtpTimeDelta::FromTimeDelta(time_advance_per_frame, config_.rtp_timebase); | 247 RtpTimeDelta::FromTimeDelta(time_advance_per_frame, config_.rtp_timebase); |
246 | 248 |
(...skipping 92 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
339 | 341 |
340 CreateFrameReceiverOfVideo(); | 342 CreateFrameReceiverOfVideo(); |
341 | 343 |
342 SimpleEventSubscriber event_subscriber; | 344 SimpleEventSubscriber event_subscriber; |
343 cast_environment_->logger()->Subscribe(&event_subscriber); | 345 cast_environment_->logger()->Subscribe(&event_subscriber); |
344 | 346 |
345 EXPECT_CALL(mock_transport_, InitializeRtpReceiverRtcpBuilder(_, _)) | 347 EXPECT_CALL(mock_transport_, InitializeRtpReceiverRtcpBuilder(_, _)) |
346 .WillRepeatedly(testing::Return()); | 348 .WillRepeatedly(testing::Return()); |
347 EXPECT_CALL(mock_transport_, AddCastFeedback(_, _)) | 349 EXPECT_CALL(mock_transport_, AddCastFeedback(_, _)) |
348 .WillRepeatedly(testing::Return()); | 350 .WillRepeatedly(testing::Return()); |
| 351 EXPECT_CALL(mock_transport_, AddPli(_)).WillRepeatedly(testing::Return()); |
349 EXPECT_CALL(mock_transport_, AddRtcpEvents(_)) | 352 EXPECT_CALL(mock_transport_, AddRtcpEvents(_)) |
350 .WillRepeatedly(testing::Return()); | 353 .WillRepeatedly(testing::Return()); |
351 EXPECT_CALL(mock_transport_, SendRtcpFromRtpReceiver()) | 354 EXPECT_CALL(mock_transport_, SendRtcpFromRtpReceiver()) |
352 .WillRepeatedly(testing::Return()); | 355 .WillRepeatedly(testing::Return()); |
353 | 356 |
354 const base::TimeDelta time_advance_per_frame = | 357 const base::TimeDelta time_advance_per_frame = |
355 base::TimeDelta::FromSeconds(1) / config_.target_frame_rate; | 358 base::TimeDelta::FromSeconds(1) / config_.target_frame_rate; |
356 const RtpTimeDelta rtp_advance_per_frame = | 359 const RtpTimeDelta rtp_advance_per_frame = |
357 RtpTimeDelta::FromTimeDelta(time_advance_per_frame, config_.rtp_timebase); | 360 RtpTimeDelta::FromTimeDelta(time_advance_per_frame, config_.rtp_timebase); |
358 | 361 |
(...skipping 84 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
443 EXPECT_GE(kFirstFrameId + 3, frame_events[i].frame_id); | 446 EXPECT_GE(kFirstFrameId + 3, frame_events[i].frame_id); |
444 const int frame_offset = frame_events[i].frame_id - kFirstFrameId; | 447 const int frame_offset = frame_events[i].frame_id - kFirstFrameId; |
445 EXPECT_EQ(RtpTimeTicks() + (rtp_advance_per_frame * frame_offset), | 448 EXPECT_EQ(RtpTimeTicks() + (rtp_advance_per_frame * frame_offset), |
446 frame_events[i].rtp_timestamp); | 449 frame_events[i].rtp_timestamp); |
447 } | 450 } |
448 cast_environment_->logger()->Unsubscribe(&event_subscriber); | 451 cast_environment_->logger()->Unsubscribe(&event_subscriber); |
449 } | 452 } |
450 | 453 |
451 } // namespace cast | 454 } // namespace cast |
452 } // namespace media | 455 } // namespace media |
OLD | NEW |