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 <queue> | 5 #include <queue> |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/command_line.h" | 8 #include "base/command_line.h" |
9 #include "base/message_loop/message_loop.h" | 9 #include "base/message_loop/message_loop.h" |
10 #include "base/power_monitor/power_monitor.h" | 10 #include "base/power_monitor/power_monitor.h" |
(...skipping 66 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
77 OperationalStatus in_status) { | 77 OperationalStatus in_status) { |
78 *out_status = in_status; | 78 *out_status = in_status; |
79 } | 79 } |
80 | 80 |
81 class MetadataRecorder : public base::RefCountedThreadSafe<MetadataRecorder> { | 81 class MetadataRecorder : public base::RefCountedThreadSafe<MetadataRecorder> { |
82 public: | 82 public: |
83 MetadataRecorder() : count_frames_delivered_(0) {} | 83 MetadataRecorder() : count_frames_delivered_(0) {} |
84 | 84 |
85 int count_frames_delivered() const { return count_frames_delivered_; } | 85 int count_frames_delivered() const { return count_frames_delivered_; } |
86 | 86 |
87 void PushExpectation(uint32 expected_frame_id, | 87 void PushExpectation(uint32_t expected_frame_id, |
88 uint32 expected_last_referenced_frame_id, | 88 uint32_t expected_last_referenced_frame_id, |
89 uint32 expected_rtp_timestamp, | 89 uint32_t expected_rtp_timestamp, |
90 const base::TimeTicks& expected_reference_time) { | 90 const base::TimeTicks& expected_reference_time) { |
91 expectations_.push(Expectation{expected_frame_id, | 91 expectations_.push(Expectation{expected_frame_id, |
92 expected_last_referenced_frame_id, | 92 expected_last_referenced_frame_id, |
93 expected_rtp_timestamp, | 93 expected_rtp_timestamp, |
94 expected_reference_time}); | 94 expected_reference_time}); |
95 } | 95 } |
96 | 96 |
97 void CompareFrameWithExpected(scoped_ptr<SenderEncodedFrame> encoded_frame) { | 97 void CompareFrameWithExpected(scoped_ptr<SenderEncodedFrame> encoded_frame) { |
98 ASSERT_LT(0u, expectations_.size()); | 98 ASSERT_LT(0u, expectations_.size()); |
99 auto e = expectations_.front(); | 99 auto e = expectations_.front(); |
(...skipping 13 matching lines...) Expand all Loading... |
113 ++count_frames_delivered_; | 113 ++count_frames_delivered_; |
114 } | 114 } |
115 | 115 |
116 private: | 116 private: |
117 friend class base::RefCountedThreadSafe<MetadataRecorder>; | 117 friend class base::RefCountedThreadSafe<MetadataRecorder>; |
118 virtual ~MetadataRecorder() {} | 118 virtual ~MetadataRecorder() {} |
119 | 119 |
120 int count_frames_delivered_; | 120 int count_frames_delivered_; |
121 | 121 |
122 struct Expectation { | 122 struct Expectation { |
123 uint32 expected_frame_id; | 123 uint32_t expected_frame_id; |
124 uint32 expected_last_referenced_frame_id; | 124 uint32_t expected_last_referenced_frame_id; |
125 uint32 expected_rtp_timestamp; | 125 uint32_t expected_rtp_timestamp; |
126 base::TimeTicks expected_reference_time; | 126 base::TimeTicks expected_reference_time; |
127 }; | 127 }; |
128 std::queue<Expectation> expectations_; | 128 std::queue<Expectation> expectations_; |
129 | 129 |
130 DISALLOW_COPY_AND_ASSIGN(MetadataRecorder); | 130 DISALLOW_COPY_AND_ASSIGN(MetadataRecorder); |
131 }; | 131 }; |
132 | 132 |
133 class EndToEndFrameChecker | 133 class EndToEndFrameChecker |
134 : public base::RefCountedThreadSafe<EndToEndFrameChecker> { | 134 : public base::RefCountedThreadSafe<EndToEndFrameChecker> { |
135 public: | 135 public: |
(...skipping 149 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
285 scoped_refptr<MetadataRecorder> metadata_recorder(new MetadataRecorder()); | 285 scoped_refptr<MetadataRecorder> metadata_recorder(new MetadataRecorder()); |
286 VideoEncoder::FrameEncodedCallback cb = base::Bind( | 286 VideoEncoder::FrameEncodedCallback cb = base::Bind( |
287 &MetadataRecorder::CompareFrameWithExpected, metadata_recorder.get()); | 287 &MetadataRecorder::CompareFrameWithExpected, metadata_recorder.get()); |
288 | 288 |
289 metadata_recorder->PushExpectation( | 289 metadata_recorder->PushExpectation( |
290 0, 0, TimeDeltaToRtpDelta(frame_->timestamp(), kVideoFrequency), | 290 0, 0, TimeDeltaToRtpDelta(frame_->timestamp(), kVideoFrequency), |
291 clock_->NowTicks()); | 291 clock_->NowTicks()); |
292 EXPECT_TRUE(encoder_->EncodeVideoFrame(frame_, clock_->NowTicks(), cb)); | 292 EXPECT_TRUE(encoder_->EncodeVideoFrame(frame_, clock_->NowTicks(), cb)); |
293 message_loop_.RunUntilIdle(); | 293 message_loop_.RunUntilIdle(); |
294 | 294 |
295 for (uint32 frame_id = 1; frame_id < 10; ++frame_id) { | 295 for (uint32_t frame_id = 1; frame_id < 10; ++frame_id) { |
296 AdvanceClockAndVideoFrameTimestamp(); | 296 AdvanceClockAndVideoFrameTimestamp(); |
297 metadata_recorder->PushExpectation( | 297 metadata_recorder->PushExpectation( |
298 frame_id, frame_id - 1, | 298 frame_id, frame_id - 1, |
299 TimeDeltaToRtpDelta(frame_->timestamp(), kVideoFrequency), | 299 TimeDeltaToRtpDelta(frame_->timestamp(), kVideoFrequency), |
300 clock_->NowTicks()); | 300 clock_->NowTicks()); |
301 EXPECT_TRUE(encoder_->EncodeVideoFrame(frame_, clock_->NowTicks(), cb)); | 301 EXPECT_TRUE(encoder_->EncodeVideoFrame(frame_, clock_->NowTicks(), cb)); |
302 } | 302 } |
303 | 303 |
304 encoder_.reset(); | 304 encoder_.reset(); |
305 message_loop_.RunUntilIdle(); | 305 message_loop_.RunUntilIdle(); |
306 | 306 |
307 EXPECT_EQ(10, metadata_recorder->count_frames_delivered()); | 307 EXPECT_EQ(10, metadata_recorder->count_frames_delivered()); |
308 } | 308 } |
309 | 309 |
310 #if defined(USE_PROPRIETARY_CODECS) | 310 #if defined(USE_PROPRIETARY_CODECS) |
311 TEST_F(H264VideoToolboxEncoderTest, CheckFramesAreDecodable) { | 311 TEST_F(H264VideoToolboxEncoderTest, CheckFramesAreDecodable) { |
312 VideoDecoderConfig config(kCodecH264, H264PROFILE_MAIN, frame_->format(), | 312 VideoDecoderConfig config(kCodecH264, H264PROFILE_MAIN, frame_->format(), |
313 COLOR_SPACE_UNSPECIFIED, frame_->coded_size(), | 313 COLOR_SPACE_UNSPECIFIED, frame_->coded_size(), |
314 frame_->visible_rect(), frame_->natural_size(), | 314 frame_->visible_rect(), frame_->natural_size(), |
315 EmptyExtraData(), false); | 315 EmptyExtraData(), false); |
316 scoped_refptr<EndToEndFrameChecker> checker(new EndToEndFrameChecker(config)); | 316 scoped_refptr<EndToEndFrameChecker> checker(new EndToEndFrameChecker(config)); |
317 | 317 |
318 VideoEncoder::FrameEncodedCallback cb = | 318 VideoEncoder::FrameEncodedCallback cb = |
319 base::Bind(&EndToEndFrameChecker::EncodeDone, checker.get()); | 319 base::Bind(&EndToEndFrameChecker::EncodeDone, checker.get()); |
320 for (uint32 frame_id = 0; frame_id < 6; ++frame_id) { | 320 for (uint32_t frame_id = 0; frame_id < 6; ++frame_id) { |
321 checker->PushExpectation(frame_); | 321 checker->PushExpectation(frame_); |
322 EXPECT_TRUE(encoder_->EncodeVideoFrame(frame_, clock_->NowTicks(), cb)); | 322 EXPECT_TRUE(encoder_->EncodeVideoFrame(frame_, clock_->NowTicks(), cb)); |
323 AdvanceClockAndVideoFrameTimestamp(); | 323 AdvanceClockAndVideoFrameTimestamp(); |
324 } | 324 } |
325 | 325 |
326 encoder_.reset(); | 326 encoder_.reset(); |
327 message_loop_.RunUntilIdle(); | 327 message_loop_.RunUntilIdle(); |
328 | 328 |
329 EXPECT_EQ(5, checker->count_frames_checked()); | 329 EXPECT_EQ(5, checker->count_frames_checked()); |
330 } | 330 } |
(...skipping 78 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
409 gfx::Size(kVideoWidth, kVideoHeight), base::TimeDelta())); | 409 gfx::Size(kVideoWidth, kVideoHeight), base::TimeDelta())); |
410 | 410 |
411 // After a power resume event, the factory should produce frames right away | 411 // After a power resume event, the factory should produce frames right away |
412 // because the encoder re-initializes on its own. | 412 // because the encoder re-initializes on its own. |
413 power_source_->GenerateResumeEvent(); | 413 power_source_->GenerateResumeEvent(); |
414 CreateFrameAndMemsetPlane(video_frame_factory.get()); | 414 CreateFrameAndMemsetPlane(video_frame_factory.get()); |
415 } | 415 } |
416 | 416 |
417 } // namespace cast | 417 } // namespace cast |
418 } // namespace media | 418 } // namespace media |
OLD | NEW |