Chromium Code Reviews| 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 <string> | 5 #include <string> |
| 6 | 6 |
| 7 #include "base/basictypes.h" | 7 #include "base/basictypes.h" |
| 8 #include "base/logging.h" | 8 #include "base/logging.h" |
| 9 #include "base/memory/scoped_ptr.h" | 9 #include "base/memory/scoped_ptr.h" |
| 10 #include "base/strings/stringprintf.h" | 10 #include "base/strings/stringprintf.h" |
| (...skipping 117 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 128 | 128 |
| 129 DISALLOW_COPY_AND_ASSIGN(MockMediaPlayerManager); | 129 DISALLOW_COPY_AND_ASSIGN(MockMediaPlayerManager); |
| 130 }; | 130 }; |
| 131 | 131 |
| 132 class MockDemuxerAndroid : public DemuxerAndroid { | 132 class MockDemuxerAndroid : public DemuxerAndroid { |
| 133 public: | 133 public: |
| 134 explicit MockDemuxerAndroid(base::MessageLoop* message_loop) | 134 explicit MockDemuxerAndroid(base::MessageLoop* message_loop) |
| 135 : message_loop_(message_loop), | 135 : message_loop_(message_loop), |
| 136 num_data_requests_(0), | 136 num_data_requests_(0), |
| 137 num_seek_requests_(0), | 137 num_seek_requests_(0), |
| 138 num_browser_seek_requests_(0), | 138 num_browser_seek_requests_(0) {} |
| 139 num_config_requests_(0) {} | |
| 140 virtual ~MockDemuxerAndroid() {} | 139 virtual ~MockDemuxerAndroid() {} |
| 141 | 140 |
| 142 virtual void Initialize(DemuxerAndroidClient* client) OVERRIDE {} | 141 virtual void Initialize(DemuxerAndroidClient* client) OVERRIDE {} |
| 143 virtual void RequestDemuxerConfigs() OVERRIDE { | |
| 144 num_config_requests_++; | |
| 145 } | |
| 146 virtual void RequestDemuxerData(DemuxerStream::Type type) OVERRIDE { | 142 virtual void RequestDemuxerData(DemuxerStream::Type type) OVERRIDE { |
| 147 num_data_requests_++; | 143 num_data_requests_++; |
| 148 if (message_loop_->is_running()) | 144 if (message_loop_->is_running()) |
| 149 message_loop_->Quit(); | 145 message_loop_->Quit(); |
| 150 } | 146 } |
| 151 virtual void RequestDemuxerSeek(const base::TimeDelta& time_to_seek, | 147 virtual void RequestDemuxerSeek(const base::TimeDelta& time_to_seek, |
| 152 bool is_browser_seek) OVERRIDE { | 148 bool is_browser_seek) OVERRIDE { |
| 153 num_seek_requests_++; | 149 num_seek_requests_++; |
| 154 if (is_browser_seek) | 150 if (is_browser_seek) |
| 155 num_browser_seek_requests_++; | 151 num_browser_seek_requests_++; |
| 156 } | 152 } |
| 157 | 153 |
| 158 int num_data_requests() const { return num_data_requests_; } | 154 int num_data_requests() const { return num_data_requests_; } |
| 159 int num_seek_requests() const { return num_seek_requests_; } | 155 int num_seek_requests() const { return num_seek_requests_; } |
| 160 int num_browser_seek_requests() const { return num_browser_seek_requests_; } | 156 int num_browser_seek_requests() const { return num_browser_seek_requests_; } |
| 161 int num_config_requests() const { return num_config_requests_; } | |
| 162 | 157 |
| 163 private: | 158 private: |
| 164 base::MessageLoop* message_loop_; | 159 base::MessageLoop* message_loop_; |
| 165 | 160 |
| 166 // The number of encoded data requests this object has seen. | 161 // The number of encoded data requests this object has seen. |
| 167 int num_data_requests_; | 162 int num_data_requests_; |
| 168 | 163 |
| 169 // The number of regular and browser seek requests this object has seen. | 164 // The number of regular and browser seek requests this object has seen. |
| 170 int num_seek_requests_; | 165 int num_seek_requests_; |
| 171 | 166 |
| 172 // The number of browser seek requests this object has seen. | 167 // The number of browser seek requests this object has seen. |
| 173 int num_browser_seek_requests_; | 168 int num_browser_seek_requests_; |
| 174 | 169 |
| 175 // The number of demuxer config requests this object has seen. | |
| 176 int num_config_requests_; | |
| 177 | |
| 178 DISALLOW_COPY_AND_ASSIGN(MockDemuxerAndroid); | 170 DISALLOW_COPY_AND_ASSIGN(MockDemuxerAndroid); |
| 179 }; | 171 }; |
| 180 | 172 |
| 181 class MediaSourcePlayerTest : public testing::Test { | 173 class MediaSourcePlayerTest : public testing::Test { |
| 182 public: | 174 public: |
| 183 MediaSourcePlayerTest() | 175 MediaSourcePlayerTest() |
| 184 : manager_(&message_loop_), | 176 : manager_(&message_loop_), |
| 185 demuxer_(new MockDemuxerAndroid(&message_loop_)), | 177 demuxer_(new MockDemuxerAndroid(&message_loop_)), |
| 186 player_(0, &manager_, | 178 player_(0, &manager_, |
| 187 base::Bind(&MockMediaPlayerManager::OnMediaResourcesRequested, | 179 base::Bind(&MockMediaPlayerManager::OnMediaResourcesRequested, |
| (...skipping 334 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 522 DemuxerData CreateReadFromDemuxerAckWithConfigChanged(bool is_audio, | 514 DemuxerData CreateReadFromDemuxerAckWithConfigChanged(bool is_audio, |
| 523 int config_unit_index) { | 515 int config_unit_index) { |
| 524 DemuxerData data; | 516 DemuxerData data; |
| 525 data.type = is_audio ? DemuxerStream::AUDIO : DemuxerStream::VIDEO; | 517 data.type = is_audio ? DemuxerStream::AUDIO : DemuxerStream::VIDEO; |
| 526 data.access_units.resize(config_unit_index + 1); | 518 data.access_units.resize(config_unit_index + 1); |
| 527 | 519 |
| 528 for (int i = 0; i < config_unit_index; ++i) | 520 for (int i = 0; i < config_unit_index; ++i) |
| 529 data.access_units[i] = CreateAccessUnitWithData(is_audio, i); | 521 data.access_units[i] = CreateAccessUnitWithData(is_audio, i); |
| 530 | 522 |
| 531 data.access_units[config_unit_index].status = DemuxerStream::kConfigChanged; | 523 data.access_units[config_unit_index].status = DemuxerStream::kConfigChanged; |
| 524 data.demuxer_configs.resize(1); | |
| 525 data.demuxer_configs[0] = CreateDemuxerConfigs(is_audio, !is_audio); | |
| 532 return data; | 526 return data; |
| 533 } | 527 } |
| 534 | 528 |
| 535 // Valid only for video-only player tests. If |trigger_with_release_start| is | 529 // Valid only for video-only player tests. If |trigger_with_release_start| is |
| 536 // true, triggers the browser seek with a Release() + video data received + | 530 // true, triggers the browser seek with a Release() + video data received + |
| 537 // Start() with a new surface. If false, triggers the browser seek by | 531 // Start() with a new surface. If false, triggers the browser seek by |
| 538 // setting a new video surface after beginning decode of received video data. | 532 // setting a new video surface after beginning decode of received video data. |
| 539 // Such data receipt causes possibility that an I-frame is not next, and | 533 // Such data receipt causes possibility that an I-frame is not next, and |
| 540 // browser seek results once decode completes and surface change processing | 534 // browser seek results once decode completes and surface change processing |
| 541 // begins. | 535 // begins. |
| (...skipping 54 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 596 | 590 |
| 597 // Creates a new decoder job and feeds it data ending with a |kConfigChanged| | 591 // Creates a new decoder job and feeds it data ending with a |kConfigChanged| |
| 598 // access unit. If |config_unit_in_prefetch| is true, sends feeds the config | 592 // access unit. If |config_unit_in_prefetch| is true, sends feeds the config |
| 599 // change AU in response to the job's first read request (prefetch). If | 593 // change AU in response to the job's first read request (prefetch). If |
| 600 // false, regular data is fed and decoded prior to feeding the config change | 594 // false, regular data is fed and decoded prior to feeding the config change |
| 601 // AU in response to the second data request (after prefetch completed). | 595 // AU in response to the second data request (after prefetch completed). |
| 602 // |config_unit_index| controls which access unit is |kConfigChanged|. | 596 // |config_unit_index| controls which access unit is |kConfigChanged|. |
| 603 void StartConfigChange(bool is_audio, | 597 void StartConfigChange(bool is_audio, |
| 604 bool config_unit_in_prefetch, | 598 bool config_unit_in_prefetch, |
| 605 int config_unit_index) { | 599 int config_unit_index) { |
| 606 int expected_num_config_requests = demuxer_->num_config_requests(); | |
| 607 | |
| 608 EXPECT_FALSE(GetMediaDecoderJob(is_audio)); | 600 EXPECT_FALSE(GetMediaDecoderJob(is_audio)); |
| 609 if (is_audio) { | 601 if (is_audio) { |
| 610 StartAudioDecoderJob(true); | 602 StartAudioDecoderJob(true); |
| 611 } else { | 603 } else { |
| 612 CreateNextTextureAndSetVideoSurface(); | 604 CreateNextTextureAndSetVideoSurface(); |
| 613 StartVideoDecoderJob(true); | 605 StartVideoDecoderJob(true); |
| 614 } | 606 } |
| 615 | 607 |
| 616 int expected_num_data_requests = demuxer_->num_data_requests(); | 608 int expected_num_data_requests = demuxer_->num_data_requests(); |
| 617 | 609 |
| 618 // Feed and decode a standalone access unit so the player exits prefetch. | 610 // Feed and decode a standalone access unit so the player exits prefetch. |
| 619 if (!config_unit_in_prefetch) { | 611 if (!config_unit_in_prefetch) { |
| 620 if (is_audio) | 612 if (is_audio) |
| 621 player_.OnDemuxerDataAvailable(CreateReadFromDemuxerAckForAudio(0)); | 613 player_.OnDemuxerDataAvailable(CreateReadFromDemuxerAckForAudio(0)); |
| 622 else | 614 else |
| 623 player_.OnDemuxerDataAvailable(CreateReadFromDemuxerAckForVideo()); | 615 player_.OnDemuxerDataAvailable(CreateReadFromDemuxerAckForVideo()); |
| 624 | 616 |
| 625 WaitForDecodeDone(is_audio, !is_audio); | 617 WaitForDecodeDone(is_audio, !is_audio); |
| 626 | 618 |
| 627 // We should have completed the prefetch phase at this point. | 619 // We should have completed the prefetch phase at this point. |
| 628 expected_num_data_requests++; | 620 expected_num_data_requests++; |
| 629 EXPECT_EQ(expected_num_data_requests, demuxer_->num_data_requests()); | 621 EXPECT_EQ(expected_num_data_requests, demuxer_->num_data_requests()); |
| 630 } | 622 } |
| 631 | 623 |
| 632 EXPECT_EQ(expected_num_config_requests, demuxer_->num_config_requests()); | |
| 633 | |
| 634 // Feed and decode access units with data for any units prior to | 624 // Feed and decode access units with data for any units prior to |
| 635 // |config_unit_index|, and a |kConfigChanged| unit at that index. | 625 // |config_unit_index|, and a |kConfigChanged| unit at that index. |
| 636 // Player should prepare to reconfigure the decoder job, and should request | 626 // Player should prepare to reconfigure the decoder job, and should request |
| 637 // new demuxer configs. | 627 // new demuxer configs. |
| 638 player_.OnDemuxerDataAvailable( | 628 player_.OnDemuxerDataAvailable( |
| 639 CreateReadFromDemuxerAckWithConfigChanged(is_audio, config_unit_index)); | 629 CreateReadFromDemuxerAckWithConfigChanged(is_audio, config_unit_index)); |
| 640 WaitForDecodeDone(is_audio, !is_audio); | 630 // Run until decoder starts to request new data. |
| 641 | 631 while (demuxer_->num_data_requests() == expected_num_data_requests) |
| 642 expected_num_config_requests++; | 632 message_loop_.RunUntilIdle(); |
| 643 EXPECT_EQ(expected_num_data_requests, demuxer_->num_data_requests()); | |
| 644 EXPECT_EQ(expected_num_config_requests, demuxer_->num_config_requests()); | |
| 645 } | 633 } |
| 646 | 634 |
| 647 void CreateNextTextureAndSetVideoSurface() { | 635 void CreateNextTextureAndSetVideoSurface() { |
| 648 gfx::SurfaceTexture* surface_texture; | 636 gfx::SurfaceTexture* surface_texture; |
| 649 if (surface_texture_a_is_next_) { | 637 if (surface_texture_a_is_next_) { |
| 650 surface_texture_a_ = gfx::SurfaceTexture::Create(next_texture_id_++); | 638 surface_texture_a_ = gfx::SurfaceTexture::Create(next_texture_id_++); |
| 651 surface_texture = surface_texture_a_.get(); | 639 surface_texture = surface_texture_a_.get(); |
| 652 } else { | 640 } else { |
| 653 surface_texture_b_ = gfx::SurfaceTexture::Create(next_texture_id_++); | 641 surface_texture_b_ = gfx::SurfaceTexture::Create(next_texture_id_++); |
| 654 surface_texture = surface_texture_b_.get(); | 642 surface_texture = surface_texture_b_.get(); |
| (...skipping 537 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 1192 SKIP_TEST_IF_MEDIA_CODEC_BRIDGE_IS_NOT_AVAILABLE(); | 1180 SKIP_TEST_IF_MEDIA_CODEC_BRIDGE_IS_NOT_AVAILABLE(); |
| 1193 | 1181 |
| 1194 // Test that if one stream (audio) has completed decode of EOS and the other | 1182 // Test that if one stream (audio) has completed decode of EOS and the other |
| 1195 // stream (video) processes config change, that subsequent video EOS completes | 1183 // stream (video) processes config change, that subsequent video EOS completes |
| 1196 // A/V playback. | 1184 // A/V playback. |
| 1197 // Also tests that seeking+Start() after completing playback resumes playback. | 1185 // Also tests that seeking+Start() after completing playback resumes playback. |
| 1198 CreateNextTextureAndSetVideoSurface(); | 1186 CreateNextTextureAndSetVideoSurface(); |
| 1199 Start(CreateAudioVideoDemuxerConfigs(), true); | 1187 Start(CreateAudioVideoDemuxerConfigs(), true); |
| 1200 | 1188 |
| 1201 player_.OnDemuxerDataAvailable(CreateEOSAck(true)); // Audio EOS | 1189 player_.OnDemuxerDataAvailable(CreateEOSAck(true)); // Audio EOS |
| 1202 EXPECT_EQ(0, demuxer_->num_config_requests()); | |
| 1203 player_.OnDemuxerDataAvailable(CreateReadFromDemuxerAckWithConfigChanged( | 1190 player_.OnDemuxerDataAvailable(CreateReadFromDemuxerAckWithConfigChanged( |
| 1204 false, 0)); // Video |kConfigChanged| as first unit. | 1191 false, 0)); // Video |kConfigChanged| as first unit. |
| 1205 | 1192 |
| 1206 WaitForAudioVideoDecodeDone(); | 1193 WaitForAudioVideoDecodeDone(); |
| 1207 | 1194 |
| 1208 EXPECT_EQ(1, demuxer_->num_config_requests()); | |
| 1209 EXPECT_EQ(2, demuxer_->num_data_requests()); | |
| 1210 player_.OnDemuxerConfigsAvailable(CreateAudioVideoDemuxerConfigs()); | |
| 1211 EXPECT_EQ(3, demuxer_->num_data_requests()); | 1195 EXPECT_EQ(3, demuxer_->num_data_requests()); |
| 1212 | 1196 |
| 1213 // At no time after completing audio EOS decode, above, should the | 1197 // At no time after completing audio EOS decode, above, should the |
| 1214 // audio decoder job resume decoding. Send and decode video EOS. | 1198 // audio decoder job resume decoding. Send and decode video EOS. |
| 1215 VerifyPlaybackCompletesOnEOSDecode(true, false); | 1199 VerifyPlaybackCompletesOnEOSDecode(true, false); |
| 1216 VerifyCompletedPlaybackResumesOnSeekPlusStart(true, true); | 1200 VerifyCompletedPlaybackResumesOnSeekPlusStart(true, true); |
| 1217 } | 1201 } |
| 1218 | 1202 |
| 1219 TEST_F(MediaSourcePlayerTest, VA_PlaybackCompletionAcrossConfigChange) { | 1203 TEST_F(MediaSourcePlayerTest, VA_PlaybackCompletionAcrossConfigChange) { |
| 1220 SKIP_TEST_IF_MEDIA_CODEC_BRIDGE_IS_NOT_AVAILABLE(); | 1204 SKIP_TEST_IF_MEDIA_CODEC_BRIDGE_IS_NOT_AVAILABLE(); |
| 1221 | 1205 |
| 1222 // Test that if one stream (video) has completed decode of EOS and the other | 1206 // Test that if one stream (video) has completed decode of EOS and the other |
| 1223 // stream (audio) processes config change, that subsequent audio EOS completes | 1207 // stream (audio) processes config change, that subsequent audio EOS completes |
| 1224 // A/V playback. | 1208 // A/V playback. |
| 1225 // Also tests that seeking+Start() after completing playback resumes playback. | 1209 // Also tests that seeking+Start() after completing playback resumes playback. |
| 1226 CreateNextTextureAndSetVideoSurface(); | 1210 CreateNextTextureAndSetVideoSurface(); |
| 1227 Start(CreateAudioVideoDemuxerConfigs(), true); | 1211 Start(CreateAudioVideoDemuxerConfigs(), true); |
| 1228 | 1212 |
| 1229 player_.OnDemuxerDataAvailable(CreateEOSAck(false)); // Video EOS | 1213 player_.OnDemuxerDataAvailable(CreateEOSAck(false)); // Video EOS |
| 1230 EXPECT_EQ(0, demuxer_->num_config_requests()); | |
| 1231 player_.OnDemuxerDataAvailable(CreateReadFromDemuxerAckWithConfigChanged( | 1214 player_.OnDemuxerDataAvailable(CreateReadFromDemuxerAckWithConfigChanged( |
| 1232 true, 0)); // Audio |kConfigChanged| as first unit. | 1215 true, 0)); // Audio |kConfigChanged| as first unit. |
| 1233 | 1216 |
| 1234 WaitForAudioVideoDecodeDone(); | 1217 WaitForAudioVideoDecodeDone(); |
| 1235 | 1218 |
| 1236 // TODO(wolenetz/qinmin): Prevent redundant demuxer config request and change | |
| 1237 // expectation to 1 here. See http://crbug.com/325528. | |
| 1238 EXPECT_EQ(2, demuxer_->num_config_requests()); | |
| 1239 EXPECT_EQ(2, demuxer_->num_data_requests()); | |
| 1240 player_.OnDemuxerConfigsAvailable(CreateAudioVideoDemuxerConfigs()); | |
| 1241 EXPECT_EQ(3, demuxer_->num_data_requests()); | 1219 EXPECT_EQ(3, demuxer_->num_data_requests()); |
| 1242 | 1220 |
| 1243 // At no time after completing video EOS decode, above, should the | 1221 // At no time after completing video EOS decode, above, should the |
| 1244 // video decoder job resume decoding. Send and decode audio EOS. | 1222 // video decoder job resume decoding. Send and decode audio EOS. |
| 1245 VerifyPlaybackCompletesOnEOSDecode(true, true); | 1223 VerifyPlaybackCompletesOnEOSDecode(true, true); |
| 1246 VerifyCompletedPlaybackResumesOnSeekPlusStart(true, true); | 1224 VerifyCompletedPlaybackResumesOnSeekPlusStart(true, true); |
| 1247 } | 1225 } |
| 1248 | 1226 |
| 1249 TEST_F(MediaSourcePlayerTest, AV_NoPrefetchForFinishedVideoOnAudioStarvation) { | 1227 TEST_F(MediaSourcePlayerTest, AV_NoPrefetchForFinishedVideoOnAudioStarvation) { |
| 1250 SKIP_TEST_IF_MEDIA_CODEC_BRIDGE_IS_NOT_AVAILABLE(); | 1228 SKIP_TEST_IF_MEDIA_CODEC_BRIDGE_IS_NOT_AVAILABLE(); |
| (...skipping 334 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 1585 StartAudioDecoderJob(true); | 1563 StartAudioDecoderJob(true); |
| 1586 | 1564 |
| 1587 SeekPlayerWithAbort(true, base::TimeDelta::FromMilliseconds(100)); | 1565 SeekPlayerWithAbort(true, base::TimeDelta::FromMilliseconds(100)); |
| 1588 EXPECT_TRUE(IsPrerolling(true)); | 1566 EXPECT_TRUE(IsPrerolling(true)); |
| 1589 EXPECT_EQ(100.0, GetPrerollTimestamp().InMillisecondsF()); | 1567 EXPECT_EQ(100.0, GetPrerollTimestamp().InMillisecondsF()); |
| 1590 | 1568 |
| 1591 // In response to data request, simulate that demuxer signals config change by | 1569 // In response to data request, simulate that demuxer signals config change by |
| 1592 // sending an AU with |kConfigChanged|. Player should prepare to reconfigure | 1570 // sending an AU with |kConfigChanged|. Player should prepare to reconfigure |
| 1593 // the audio decoder job, and should request new demuxer configs. | 1571 // the audio decoder job, and should request new demuxer configs. |
| 1594 DemuxerData data = CreateReadFromDemuxerAckWithConfigChanged(true, 0); | 1572 DemuxerData data = CreateReadFromDemuxerAckWithConfigChanged(true, 0); |
| 1595 EXPECT_EQ(0, demuxer_->num_config_requests()); | |
| 1596 player_.OnDemuxerDataAvailable(data); | 1573 player_.OnDemuxerDataAvailable(data); |
| 1597 EXPECT_EQ(1, demuxer_->num_config_requests()); | |
| 1598 | 1574 |
| 1599 // Simulate arrival of new configs. | 1575 // Simulate arrival of new configs. |
| 1600 player_.OnDemuxerConfigsAvailable(CreateAudioDemuxerConfigs(kCodecVorbis)); | 1576 player_.OnDemuxerConfigsAvailable(CreateAudioDemuxerConfigs(kCodecVorbis)); |
| 1601 | 1577 |
| 1602 PrerollDecoderToTime( | 1578 PrerollDecoderToTime( |
| 1603 true, base::TimeDelta(), base::TimeDelta::FromMilliseconds(100)); | 1579 true, base::TimeDelta(), base::TimeDelta::FromMilliseconds(100)); |
| 1604 } | 1580 } |
| 1605 | 1581 |
| 1606 TEST_F(MediaSourcePlayerTest, SimultaneousAudioVideoConfigChange) { | 1582 TEST_F(MediaSourcePlayerTest, SimultaneousAudioVideoConfigChange) { |
| 1607 SKIP_TEST_IF_MEDIA_CODEC_BRIDGE_IS_NOT_AVAILABLE(); | 1583 SKIP_TEST_IF_MEDIA_CODEC_BRIDGE_IS_NOT_AVAILABLE(); |
| 1608 | 1584 |
| 1609 // Test that the player allows simultaneous audio and video config change, | 1585 // Test that the player allows simultaneous audio and video config change, |
| 1610 // such as might occur during OnPrefetchDone() if next access unit for both | 1586 // such as might occur during OnPrefetchDone() if next access unit for both |
| 1611 // audio and video jobs is |kConfigChanged|. | 1587 // audio and video jobs is |kConfigChanged|. |
| 1612 CreateNextTextureAndSetVideoSurface(); | 1588 CreateNextTextureAndSetVideoSurface(); |
| 1613 Start(CreateAudioVideoDemuxerConfigs(), true); | 1589 Start(CreateAudioVideoDemuxerConfigs(), true); |
| 1614 MediaDecoderJob* first_audio_job = GetMediaDecoderJob(true); | 1590 MediaDecoderJob* first_audio_job = GetMediaDecoderJob(true); |
| 1615 MediaDecoderJob* first_video_job = GetMediaDecoderJob(false); | 1591 MediaDecoderJob* first_video_job = GetMediaDecoderJob(false); |
| 1616 | 1592 |
| 1617 // Simulate audio |kConfigChanged| prefetched as standalone access unit. | 1593 // Simulate audio |kConfigChanged| prefetched as standalone access unit. |
| 1618 player_.OnDemuxerDataAvailable( | 1594 player_.OnDemuxerDataAvailable( |
| 1619 CreateReadFromDemuxerAckWithConfigChanged(true, 0)); | 1595 CreateReadFromDemuxerAckWithConfigChanged(true, 0)); |
| 1620 EXPECT_EQ(0, demuxer_->num_config_requests()); // No OnPrefetchDone() yet. | |
| 1621 | 1596 |
| 1622 // Simulate video |kConfigChanged| prefetched as standalone access unit. | 1597 // Simulate video |kConfigChanged| prefetched as standalone access unit. |
| 1623 player_.OnDemuxerDataAvailable( | 1598 player_.OnDemuxerDataAvailable( |
| 1624 CreateReadFromDemuxerAckWithConfigChanged(false, 0)); | 1599 CreateReadFromDemuxerAckWithConfigChanged(false, 0)); |
| 1625 EXPECT_EQ(1, demuxer_->num_config_requests()); // OnPrefetchDone() occurred. | 1600 EXPECT_EQ(4, demuxer_->num_data_requests()); // No more data requested yet. |
|
wolenetz
2014/05/02 22:25:30
nit: remove the incorrect(?) comment
qinmin
2014/05/05 20:52:19
Done.
| |
| 1626 EXPECT_EQ(2, demuxer_->num_data_requests()); // No more data requested yet. | |
| 1627 | 1601 |
| 1628 // No job re-creation should occur until the requested configs arrive. | 1602 // No job re-creation should occur until the requested configs arrive. |
|
wolenetz
2014/05/02 22:25:30
nit: adjust the wording of comment: Both jobs shou
qinmin
2014/05/05 20:52:19
Done.
| |
| 1629 EXPECT_EQ(first_audio_job, GetMediaDecoderJob(true)); | 1603 EXPECT_NE(first_audio_job, GetMediaDecoderJob(true)); |
|
wolenetz
2014/05/02 22:25:30
nit: these pointer checks can be flaky. I think we
qinmin
2014/05/05 20:52:19
Done.
| |
| 1630 EXPECT_EQ(first_video_job, GetMediaDecoderJob(false)); | 1604 EXPECT_NE(first_video_job, GetMediaDecoderJob(false)); |
| 1631 | 1605 EXPECT_TRUE(GetMediaDecoderJob(true) && GetMediaDecoderJob(false)); |
| 1632 player_.OnDemuxerConfigsAvailable(CreateAudioVideoDemuxerConfigs()); | |
| 1633 EXPECT_EQ(4, demuxer_->num_data_requests()); | |
| 1634 MediaDecoderJob* second_audio_job = GetMediaDecoderJob(true); | |
| 1635 MediaDecoderJob* second_video_job = GetMediaDecoderJob(false); | |
| 1636 EXPECT_NE(first_audio_job, second_audio_job); | |
| 1637 EXPECT_NE(first_video_job, second_video_job); | |
| 1638 EXPECT_TRUE(second_audio_job && second_video_job); | |
| 1639 | |
| 1640 // Confirm no further demuxer configs requested. | |
| 1641 EXPECT_EQ(1, demuxer_->num_config_requests()); | |
| 1642 } | 1606 } |
| 1643 | 1607 |
| 1644 TEST_F(MediaSourcePlayerTest, DemuxerConfigRequestedIfInPrefetchUnit0) { | 1608 TEST_F(MediaSourcePlayerTest, DemuxerConfigRequestedIfInPrefetchUnit0) { |
| 1645 SKIP_TEST_IF_MEDIA_CODEC_BRIDGE_IS_NOT_AVAILABLE(); | 1609 SKIP_TEST_IF_MEDIA_CODEC_BRIDGE_IS_NOT_AVAILABLE(); |
| 1646 | 1610 |
| 1647 // Test that the player detects need for and requests demuxer configs if | 1611 // Test that the player detects need for and requests demuxer configs if |
| 1648 // the |kConfigChanged| unit is the very first unit in the set of units | 1612 // the |kConfigChanged| unit is the very first unit in the set of units |
| 1649 // received in OnDemuxerDataAvailable() ostensibly while | 1613 // received in OnDemuxerDataAvailable() ostensibly while |
| 1650 // |PREFETCH_DONE_EVENT_PENDING|. | 1614 // |PREFETCH_DONE_EVENT_PENDING|. |
| 1651 StartConfigChange(true, true, 0); | 1615 StartConfigChange(true, true, 0); |
| (...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 1696 EXPECT_EQ(100.0, GetPrerollTimestamp().InMillisecondsF()); | 1660 EXPECT_EQ(100.0, GetPrerollTimestamp().InMillisecondsF()); |
| 1697 EXPECT_EQ(3, demuxer_->num_data_requests()); | 1661 EXPECT_EQ(3, demuxer_->num_data_requests()); |
| 1698 | 1662 |
| 1699 PrerollDecoderToTime( | 1663 PrerollDecoderToTime( |
| 1700 false, base::TimeDelta(), base::TimeDelta::FromMilliseconds(100)); | 1664 false, base::TimeDelta(), base::TimeDelta::FromMilliseconds(100)); |
| 1701 } | 1665 } |
| 1702 | 1666 |
| 1703 TEST_F(MediaSourcePlayerTest, VideoDemuxerConfigChange) { | 1667 TEST_F(MediaSourcePlayerTest, VideoDemuxerConfigChange) { |
| 1704 SKIP_TEST_IF_MEDIA_CODEC_BRIDGE_IS_NOT_AVAILABLE(); | 1668 SKIP_TEST_IF_MEDIA_CODEC_BRIDGE_IS_NOT_AVAILABLE(); |
| 1705 | 1669 |
| 1706 // Test that video config change notification results in request for demuxer | 1670 // Test that video config change notification results in creating a new |
| 1707 // configuration, and that a video decoder job results without any browser | 1671 // video decoder job results without any browser seek. |
| 1708 // seek necessary once the new demuxer config arrives. | |
| 1709 StartConfigChange(false, true, 1); | 1672 StartConfigChange(false, true, 1); |
| 1710 MediaDecoderJob* first_job = GetMediaDecoderJob(false); | 1673 EXPECT_TRUE(GetMediaDecoderJob(false)); |
| 1711 EXPECT_TRUE(first_job); | |
| 1712 EXPECT_EQ(1, demuxer_->num_data_requests()); | |
| 1713 EXPECT_EQ(1, demuxer_->num_config_requests()); | |
| 1714 | |
| 1715 // Simulate arrival of new configs. | |
| 1716 player_.OnDemuxerConfigsAvailable(CreateVideoDemuxerConfigs()); | |
| 1717 | |
| 1718 // New video decoder job should have been created and configured, without any | |
| 1719 // browser seek. | |
| 1720 MediaDecoderJob* second_job = GetMediaDecoderJob(false); | |
| 1721 EXPECT_TRUE(second_job); | |
| 1722 EXPECT_NE(first_job, second_job); | |
| 1723 EXPECT_EQ(2, demuxer_->num_data_requests()); | 1674 EXPECT_EQ(2, demuxer_->num_data_requests()); |
| 1724 EXPECT_EQ(1, demuxer_->num_config_requests()); | |
| 1725 EXPECT_EQ(0, demuxer_->num_seek_requests()); | 1675 EXPECT_EQ(0, demuxer_->num_seek_requests()); |
| 1726 } | 1676 } |
| 1727 | 1677 |
| 1728 TEST_F(MediaSourcePlayerTest, VideoConfigChangeContinuesAcrossSeek) { | 1678 TEST_F(MediaSourcePlayerTest, NewSurfaceAfterChangingConfigs) { |
| 1729 SKIP_TEST_IF_MEDIA_CODEC_BRIDGE_IS_NOT_AVAILABLE(); | 1679 SKIP_TEST_IF_MEDIA_CODEC_BRIDGE_IS_NOT_AVAILABLE(); |
| 1730 | 1680 |
| 1731 // Test if a demuxer config request is pending (due to previously receiving | 1681 // Test that no seek results from a SetVideoSurface() that occurs after |
| 1732 // |kConfigChanged|), and a seek request arrives prior to demuxer configs, | 1682 // the player processes new demuxer configs. This test may be good to keep |
| 1733 // then seek is processed first, followed by the decoder config change. | 1683 // beyond browser seek hack. |
| 1734 // This assumes the demuxer sends |kConfigChanged| read response prior to | |
| 1735 // canceling any reads pending seek; no |kAborted| is involved in this test. | |
| 1736 StartConfigChange(false, false, 1); | 1684 StartConfigChange(false, false, 1); |
| 1737 MediaDecoderJob* first_job = GetMediaDecoderJob(false); | 1685 EXPECT_TRUE(GetMediaDecoderJob(false)); |
| 1738 EXPECT_TRUE(first_job); | |
| 1739 EXPECT_EQ(1, demuxer_->num_config_requests()); | |
| 1740 EXPECT_EQ(2, demuxer_->num_data_requests()); | |
| 1741 EXPECT_EQ(0, demuxer_->num_seek_requests()); | |
| 1742 | |
| 1743 player_.SeekTo(base::TimeDelta::FromMilliseconds(100)); | |
| 1744 | |
| 1745 // Verify that the seek is requested immediately. | |
| 1746 EXPECT_EQ(1, demuxer_->num_seek_requests()); | |
| 1747 | |
| 1748 // Simulate unlikely delayed arrival of the demuxer configs, completing the | |
| 1749 // config change. | |
| 1750 // TODO(wolenetz): Is it even possible for requested demuxer configs to be | |
| 1751 // delayed until after a SeekTo request arrives? | |
| 1752 player_.OnDemuxerConfigsAvailable(CreateVideoDemuxerConfigs()); | |
| 1753 | |
| 1754 MediaDecoderJob* second_job = GetMediaDecoderJob(false); | |
| 1755 EXPECT_NE(first_job, second_job); | |
| 1756 EXPECT_TRUE(second_job); | |
| 1757 | |
| 1758 // Send back the seek done notification. This should finish the seek and | |
| 1759 // trigger the player to request more data. | |
| 1760 EXPECT_EQ(2, demuxer_->num_data_requests()); | |
| 1761 player_.OnDemuxerSeekDone(kNoTimestamp()); | |
| 1762 EXPECT_EQ(3, demuxer_->num_data_requests()); | 1686 EXPECT_EQ(3, demuxer_->num_data_requests()); |
| 1763 } | |
| 1764 | |
| 1765 TEST_F(MediaSourcePlayerTest, NewSurfaceWhileChangingConfigs) { | |
| 1766 SKIP_TEST_IF_MEDIA_CODEC_BRIDGE_IS_NOT_AVAILABLE(); | |
| 1767 | |
| 1768 // Test that no seek or duplicated demuxer config request results from a | |
| 1769 // SetVideoSurface() that occurs while the player is expecting new demuxer | |
| 1770 // configs. This test may be good to keep beyond browser seek hack. | |
| 1771 StartConfigChange(false, false, 1); | |
| 1772 MediaDecoderJob* first_job = GetMediaDecoderJob(false); | |
| 1773 EXPECT_TRUE(first_job); | |
| 1774 EXPECT_EQ(1, demuxer_->num_config_requests()); | |
| 1775 EXPECT_EQ(2, demuxer_->num_data_requests()); | |
| 1776 | 1687 |
| 1777 CreateNextTextureAndSetVideoSurface(); | 1688 CreateNextTextureAndSetVideoSurface(); |
| 1778 | 1689 EXPECT_TRUE(GetMediaDecoderJob(false)); |
| 1779 // Surface change processing (including decoder job re-creation) should | |
| 1780 // not occur until the pending video config change is completed. | |
| 1781 EXPECT_EQ(first_job, GetMediaDecoderJob(false)); | |
| 1782 | |
| 1783 player_.OnDemuxerConfigsAvailable(CreateVideoDemuxerConfigs()); | |
| 1784 MediaDecoderJob* second_job = GetMediaDecoderJob(false); | |
| 1785 EXPECT_NE(first_job, second_job); | |
| 1786 EXPECT_TRUE(second_job); | |
| 1787 | |
| 1788 EXPECT_EQ(3, demuxer_->num_data_requests()); | 1690 EXPECT_EQ(3, demuxer_->num_data_requests()); |
| 1789 EXPECT_EQ(1, demuxer_->num_config_requests()); | |
| 1790 EXPECT_EQ(0, demuxer_->num_seek_requests()); | 1691 EXPECT_EQ(0, demuxer_->num_seek_requests()); |
| 1791 } | 1692 } |
| 1792 | 1693 |
| 1793 TEST_F(MediaSourcePlayerTest, | 1694 TEST_F(MediaSourcePlayerTest, |
| 1794 BrowserSeek_DecoderStarvationWhilePendingSurfaceChange) { | 1695 BrowserSeek_DecoderStarvationWhilePendingSurfaceChange) { |
| 1795 SKIP_TEST_IF_MEDIA_CODEC_BRIDGE_IS_NOT_AVAILABLE(); | 1696 SKIP_TEST_IF_MEDIA_CODEC_BRIDGE_IS_NOT_AVAILABLE(); |
| 1796 | 1697 |
| 1797 // Test video decoder starvation while handling a pending surface change | 1698 // Test video decoder starvation while handling a pending surface change |
| 1798 // should not cause any crashes. | 1699 // should not cause any crashes. |
| 1799 CreateNextTextureAndSetVideoSurface(); | 1700 CreateNextTextureAndSetVideoSurface(); |
| (...skipping 158 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 1958 player_.OnDemuxerSeekDone(kNoTimestamp()); | 1859 player_.OnDemuxerSeekDone(kNoTimestamp()); |
| 1959 EXPECT_TRUE(GetMediaDecoderJob(true)); | 1860 EXPECT_TRUE(GetMediaDecoderJob(true)); |
| 1960 EXPECT_TRUE(IsPrerolling(true)); | 1861 EXPECT_TRUE(IsPrerolling(true)); |
| 1961 EXPECT_EQ(100.0, GetPrerollTimestamp().InMillisecondsF()); | 1862 EXPECT_EQ(100.0, GetPrerollTimestamp().InMillisecondsF()); |
| 1962 EXPECT_EQ(3, demuxer_->num_data_requests()); | 1863 EXPECT_EQ(3, demuxer_->num_data_requests()); |
| 1963 | 1864 |
| 1964 // No further seek should have been requested since before Release(), above. | 1865 // No further seek should have been requested since before Release(), above. |
| 1965 EXPECT_EQ(1, demuxer_->num_seek_requests()); | 1866 EXPECT_EQ(1, demuxer_->num_seek_requests()); |
| 1966 } | 1867 } |
| 1967 | 1868 |
| 1968 TEST_F(MediaSourcePlayerTest, ConfigChangedThenReleaseThenConfigsAvailable) { | 1869 TEST_F(MediaSourcePlayerTest, ConfigChangedThenReleaseThenConfigsAvailable) { |
|
wolenetz
2014/05/02 22:25:30
Test needs renaming (no separation of configchange
qinmin
2014/05/05 20:52:19
Merged this test with the next test.
Added a DCHEC
| |
| 1969 SKIP_TEST_IF_MEDIA_CODEC_BRIDGE_IS_NOT_AVAILABLE(); | 1870 SKIP_TEST_IF_MEDIA_CODEC_BRIDGE_IS_NOT_AVAILABLE(); |
| 1970 | 1871 |
| 1971 // Test if Release() occurs after |kConfigChanged| detected, new configs | 1872 // Test if Release() occurs after |kConfigChanged| detected, new configs |
|
wolenetz
2014/05/02 22:25:30
nit: comment needs rewording (no configs requested
qinmin
2014/05/05 20:52:19
Done.
| |
| 1972 // requested of demuxer, and the requested configs arrive before the next | 1873 // requested of demuxer, and the requested configs arrive before the next |
| 1973 // Start(), then the player completes the pending config change processing on | 1874 // Start(), then the player completes the pending config change processing on |
| 1974 // their receipt. | 1875 // their receipt. |
| 1975 StartConfigChange(true, true, 0); | 1876 StartConfigChange(true, true, 0); |
| 1976 ReleasePlayer(); | 1877 ReleasePlayer(); |
| 1977 | 1878 |
| 1978 player_.OnDemuxerConfigsAvailable(CreateAudioDemuxerConfigs(kCodecVorbis)); | |
| 1979 EXPECT_FALSE(GetMediaDecoderJob(true)); | 1879 EXPECT_FALSE(GetMediaDecoderJob(true)); |
| 1980 EXPECT_FALSE(player_.IsPlaying()); | 1880 EXPECT_FALSE(player_.IsPlaying()); |
| 1981 EXPECT_EQ(1, demuxer_->num_data_requests()); | 1881 EXPECT_EQ(2, demuxer_->num_data_requests()); |
| 1982 | 1882 |
| 1983 // Player should resume upon Start(), even without further configs supplied. | 1883 // Player should resume upon Start(), even without further configs supplied. |
| 1984 player_.Start(); | 1884 player_.Start(); |
| 1985 EXPECT_TRUE(GetMediaDecoderJob(true)); | 1885 EXPECT_TRUE(GetMediaDecoderJob(true)); |
| 1986 EXPECT_TRUE(player_.IsPlaying()); | 1886 EXPECT_TRUE(player_.IsPlaying()); |
| 1987 EXPECT_EQ(2, demuxer_->num_data_requests()); | 1887 EXPECT_EQ(2, demuxer_->num_data_requests()); |
| 1988 | |
| 1989 // No further config request should have occurred since StartConfigChange(). | |
| 1990 EXPECT_EQ(1, demuxer_->num_config_requests()); | |
| 1991 } | 1888 } |
| 1992 | 1889 |
| 1993 TEST_F(MediaSourcePlayerTest, ConfigChangedThenReleaseThenStart) { | 1890 TEST_F(MediaSourcePlayerTest, ConfigChangedThenReleaseThenStart) { |
|
wolenetz
2014/05/02 22:25:30
This test is now entirely a subset of the previous
qinmin
2014/05/05 20:52:19
merged with the above one
On 2014/05/02 22:25:30,
| |
| 1994 SKIP_TEST_IF_MEDIA_CODEC_BRIDGE_IS_NOT_AVAILABLE(); | 1891 SKIP_TEST_IF_MEDIA_CODEC_BRIDGE_IS_NOT_AVAILABLE(); |
| 1995 | 1892 |
| 1996 // Test if Release() occurs after |kConfigChanged| detected, new configs | 1893 // Test if Release() occurs after |kConfigChanged| detected, new configs |
| 1997 // requested of demuxer, and the requested configs arrive after the next | 1894 // requested of demuxer, and the requested configs arrive after the next |
| 1998 // Start(), then the player pends job creation until the new configs arrive. | 1895 // Start(), then the player pends job creation until the new configs arrive. |
| 1999 StartConfigChange(true, true, 0); | 1896 StartConfigChange(true, true, 0); |
| 2000 ReleasePlayer(); | 1897 ReleasePlayer(); |
| 2001 | 1898 |
| 2002 player_.Start(); | 1899 player_.Start(); |
| 2003 EXPECT_TRUE(player_.IsPlaying()); | 1900 EXPECT_TRUE(player_.IsPlaying()); |
| 2004 EXPECT_FALSE(GetMediaDecoderJob(true)); | |
| 2005 EXPECT_EQ(1, demuxer_->num_data_requests()); | |
| 2006 | |
| 2007 player_.OnDemuxerConfigsAvailable(CreateAudioDemuxerConfigs(kCodecVorbis)); | |
| 2008 EXPECT_TRUE(GetMediaDecoderJob(true)); | 1901 EXPECT_TRUE(GetMediaDecoderJob(true)); |
| 2009 EXPECT_EQ(2, demuxer_->num_data_requests()); | 1902 EXPECT_EQ(2, demuxer_->num_data_requests()); |
| 2010 | |
| 2011 // No further config request should have occurred since StartConfigChange(). | |
| 2012 EXPECT_EQ(1, demuxer_->num_config_requests()); | |
| 2013 } | 1903 } |
| 2014 | 1904 |
| 2015 TEST_F(MediaSourcePlayerTest, BrowserSeek_ThenReleaseThenDemuxerSeekDone) { | 1905 TEST_F(MediaSourcePlayerTest, BrowserSeek_ThenReleaseThenDemuxerSeekDone) { |
| 2016 SKIP_TEST_IF_MEDIA_CODEC_BRIDGE_IS_NOT_AVAILABLE(); | 1906 SKIP_TEST_IF_MEDIA_CODEC_BRIDGE_IS_NOT_AVAILABLE(); |
| 2017 | 1907 |
| 2018 // Test that Release() after a browser seek's DemuxerSeek IPC request has been | 1908 // Test that Release() after a browser seek's DemuxerSeek IPC request has been |
| 2019 // sent behaves similar to a regular seek: if OnDemuxerSeekDone() occurs | 1909 // sent behaves similar to a regular seek: if OnDemuxerSeekDone() occurs |
| 2020 // before the next Start()+SetVideoSurface(), then the player will resume | 1910 // before the next Start()+SetVideoSurface(), then the player will resume |
| 2021 // correct post-seek preroll upon Start()+SetVideoSurface(). | 1911 // correct post-seek preroll upon Start()+SetVideoSurface(). |
| 2022 BrowserSeekPlayer(false); | 1912 BrowserSeekPlayer(false); |
| (...skipping 86 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 2109 | 1999 |
| 2110 // Test current time keep on increasing after audio config change. | 2000 // Test current time keep on increasing after audio config change. |
| 2111 // Test that current time is updated while decoder is starved. | 2001 // Test that current time is updated while decoder is starved. |
| 2112 StartAudioDecoderJob(true); | 2002 StartAudioDecoderJob(true); |
| 2113 | 2003 |
| 2114 DecodeAudioDataUntilOutputBecomesAvailable(); | 2004 DecodeAudioDataUntilOutputBecomesAvailable(); |
| 2115 | 2005 |
| 2116 DemuxerData data = CreateReadFromDemuxerAckWithConfigChanged(true, 0); | 2006 DemuxerData data = CreateReadFromDemuxerAckWithConfigChanged(true, 0); |
| 2117 player_.OnDemuxerDataAvailable(data); | 2007 player_.OnDemuxerDataAvailable(data); |
| 2118 WaitForAudioDecodeDone(); | 2008 WaitForAudioDecodeDone(); |
| 2119 | |
| 2120 // Simulate arrival of new configs. | |
| 2121 player_.OnDemuxerConfigsAvailable(CreateAudioDemuxerConfigs(kCodecVorbis)); | |
| 2122 DecodeAudioDataUntilOutputBecomesAvailable(); | 2009 DecodeAudioDataUntilOutputBecomesAvailable(); |
| 2123 } | 2010 } |
| 2124 | 2011 |
| 2125 } // namespace media | 2012 } // namespace media |
| OLD | NEW |