| 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 |