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 "media/base/android/media_source_player.h" |
| 6 |
5 #include <stdint.h> | 7 #include <stdint.h> |
6 | |
7 #include <string> | 8 #include <string> |
| 9 #include <utility> |
8 | 10 |
9 #include "base/logging.h" | 11 #include "base/logging.h" |
10 #include "base/macros.h" | 12 #include "base/macros.h" |
11 #include "base/memory/scoped_ptr.h" | 13 #include "base/memory/scoped_ptr.h" |
12 #include "base/strings/stringprintf.h" | 14 #include "base/strings/stringprintf.h" |
13 #include "build/build_config.h" | 15 #include "build/build_config.h" |
14 #include "media/base/android/audio_decoder_job.h" | 16 #include "media/base/android/audio_decoder_job.h" |
15 #include "media/base/android/media_codec_util.h" | 17 #include "media/base/android/media_codec_util.h" |
16 #include "media/base/android/media_drm_bridge.h" | 18 #include "media/base/android/media_drm_bridge.h" |
17 #include "media/base/android/media_player_manager.h" | 19 #include "media/base/android/media_player_manager.h" |
18 #include "media/base/android/media_source_player.h" | |
19 #include "media/base/android/media_url_interceptor.h" | 20 #include "media/base/android/media_url_interceptor.h" |
20 #include "media/base/android/sdk_media_codec_bridge.h" | 21 #include "media/base/android/sdk_media_codec_bridge.h" |
21 #include "media/base/android/video_decoder_job.h" | 22 #include "media/base/android/video_decoder_job.h" |
22 #include "media/base/bind_to_current_loop.h" | 23 #include "media/base/bind_to_current_loop.h" |
23 #include "media/base/decoder_buffer.h" | 24 #include "media/base/decoder_buffer.h" |
24 #include "media/base/test_data_util.h" | 25 #include "media/base/test_data_util.h" |
25 #include "media/base/timestamp_constants.h" | 26 #include "media/base/timestamp_constants.h" |
26 #include "testing/gmock/include/gmock/gmock.h" | 27 #include "testing/gmock/include/gmock/gmock.h" |
27 #include "ui/gl/android/surface_texture.h" | 28 #include "ui/gl/android/surface_texture.h" |
28 | 29 |
(...skipping 674 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
703 if (surface_texture_a_is_next_) { | 704 if (surface_texture_a_is_next_) { |
704 surface_texture_a_ = gfx::SurfaceTexture::Create(next_texture_id_++); | 705 surface_texture_a_ = gfx::SurfaceTexture::Create(next_texture_id_++); |
705 surface_texture = surface_texture_a_.get(); | 706 surface_texture = surface_texture_a_.get(); |
706 } else { | 707 } else { |
707 surface_texture_b_ = gfx::SurfaceTexture::Create(next_texture_id_++); | 708 surface_texture_b_ = gfx::SurfaceTexture::Create(next_texture_id_++); |
708 surface_texture = surface_texture_b_.get(); | 709 surface_texture = surface_texture_b_.get(); |
709 } | 710 } |
710 | 711 |
711 surface_texture_a_is_next_ = !surface_texture_a_is_next_; | 712 surface_texture_a_is_next_ = !surface_texture_a_is_next_; |
712 gfx::ScopedJavaSurface surface = gfx::ScopedJavaSurface(surface_texture); | 713 gfx::ScopedJavaSurface surface = gfx::ScopedJavaSurface(surface_texture); |
713 player_.SetVideoSurface(surface.Pass()); | 714 player_.SetVideoSurface(std::move(surface)); |
714 } | 715 } |
715 | 716 |
716 // Wait for one or both of the jobs to complete decoding. Media codec bridges | 717 // Wait for one or both of the jobs to complete decoding. Media codec bridges |
717 // are assumed to exist for any stream whose decode completion is awaited. | 718 // are assumed to exist for any stream whose decode completion is awaited. |
718 void WaitForDecodeDone(bool wait_for_audio, bool wait_for_video) { | 719 void WaitForDecodeDone(bool wait_for_audio, bool wait_for_video) { |
719 DCHECK(wait_for_audio || wait_for_video); | 720 DCHECK(wait_for_audio || wait_for_video); |
720 while ((wait_for_audio && GetMediaCodecBridge(true) && | 721 while ((wait_for_audio && GetMediaCodecBridge(true) && |
721 GetMediaDecoderJob(true)->HasData() && | 722 GetMediaDecoderJob(true)->HasData() && |
722 GetMediaDecoderJob(true)->is_decoding()) || | 723 GetMediaDecoderJob(true)->is_decoding()) || |
723 (wait_for_video && GetMediaCodecBridge(false) && | 724 (wait_for_video && GetMediaCodecBridge(false) && |
(...skipping 186 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
910 SKIP_TEST_IF_MEDIA_CODEC_BRIDGE_IS_NOT_AVAILABLE(); | 911 SKIP_TEST_IF_MEDIA_CODEC_BRIDGE_IS_NOT_AVAILABLE(); |
911 | 912 |
912 // Test video codec will not be created when surface is invalid. | 913 // Test video codec will not be created when surface is invalid. |
913 scoped_refptr<gfx::SurfaceTexture> surface_texture( | 914 scoped_refptr<gfx::SurfaceTexture> surface_texture( |
914 gfx::SurfaceTexture::Create(0)); | 915 gfx::SurfaceTexture::Create(0)); |
915 gfx::ScopedJavaSurface surface(surface_texture.get()); | 916 gfx::ScopedJavaSurface surface(surface_texture.get()); |
916 StartVideoDecoderJob(); | 917 StartVideoDecoderJob(); |
917 | 918 |
918 // Release the surface texture. | 919 // Release the surface texture. |
919 surface_texture = NULL; | 920 surface_texture = NULL; |
920 player_.SetVideoSurface(surface.Pass()); | 921 player_.SetVideoSurface(std::move(surface)); |
921 | 922 |
922 // Player should not seek the demuxer on setting initial surface. | 923 // Player should not seek the demuxer on setting initial surface. |
923 EXPECT_EQ(0, demuxer_->num_seek_requests()); | 924 EXPECT_EQ(0, demuxer_->num_seek_requests()); |
924 EXPECT_EQ(1, demuxer_->num_data_requests()); | 925 EXPECT_EQ(1, demuxer_->num_data_requests()); |
925 | 926 |
926 player_.OnDemuxerDataAvailable(CreateReadFromDemuxerAckForVideo(false)); | 927 player_.OnDemuxerDataAvailable(CreateReadFromDemuxerAckForVideo(false)); |
927 EXPECT_FALSE(GetMediaCodecBridge(false)); | 928 EXPECT_FALSE(GetMediaCodecBridge(false)); |
928 } | 929 } |
929 | 930 |
930 TEST_F(MediaSourcePlayerTest, ReadFromDemuxerAfterSeek) { | 931 TEST_F(MediaSourcePlayerTest, ReadFromDemuxerAfterSeek) { |
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
973 CreateNextTextureAndSetVideoSurface(); | 974 CreateNextTextureAndSetVideoSurface(); |
974 StartVideoDecoderJob(); | 975 StartVideoDecoderJob(); |
975 EXPECT_EQ(0, demuxer_->num_seek_requests()); | 976 EXPECT_EQ(0, demuxer_->num_seek_requests()); |
976 | 977 |
977 // Send the first input chunk. | 978 // Send the first input chunk. |
978 player_.OnDemuxerDataAvailable(CreateReadFromDemuxerAckForVideo(false)); | 979 player_.OnDemuxerDataAvailable(CreateReadFromDemuxerAckForVideo(false)); |
979 | 980 |
980 // While the decoder is decoding, change multiple surfaces. Pass an empty | 981 // While the decoder is decoding, change multiple surfaces. Pass an empty |
981 // surface first. | 982 // surface first. |
982 gfx::ScopedJavaSurface empty_surface; | 983 gfx::ScopedJavaSurface empty_surface; |
983 player_.SetVideoSurface(empty_surface.Pass()); | 984 player_.SetVideoSurface(std::move(empty_surface)); |
984 // Next, pass a new non-empty surface. | 985 // Next, pass a new non-empty surface. |
985 CreateNextTextureAndSetVideoSurface(); | 986 CreateNextTextureAndSetVideoSurface(); |
986 | 987 |
987 // Wait for the media codec bridge to finish decoding and be reset pending a | 988 // Wait for the media codec bridge to finish decoding and be reset pending a |
988 // browser seek. | 989 // browser seek. |
989 WaitForVideoDecodeDone(); | 990 WaitForVideoDecodeDone(); |
990 player_.OnDemuxerDataAvailable(CreateReadFromDemuxerAckForVideo(false)); | 991 player_.OnDemuxerDataAvailable(CreateReadFromDemuxerAckForVideo(false)); |
991 | 992 |
992 // Only one browser seek should have been initiated. No further data request | 993 // Only one browser seek should have been initiated. No further data request |
993 // should have been processed on |message_loop_| before surface change event | 994 // should have been processed on |message_loop_| before surface change event |
(...skipping 19 matching lines...) Expand all Loading... |
1013 // Test player pauses if an empty surface is passed. | 1014 // Test player pauses if an empty surface is passed. |
1014 CreateNextTextureAndSetVideoSurface(); | 1015 CreateNextTextureAndSetVideoSurface(); |
1015 StartVideoDecoderJob(); | 1016 StartVideoDecoderJob(); |
1016 EXPECT_EQ(1, demuxer_->num_data_requests()); | 1017 EXPECT_EQ(1, demuxer_->num_data_requests()); |
1017 | 1018 |
1018 // Send the first input chunk. | 1019 // Send the first input chunk. |
1019 player_.OnDemuxerDataAvailable(CreateReadFromDemuxerAckForVideo(false)); | 1020 player_.OnDemuxerDataAvailable(CreateReadFromDemuxerAckForVideo(false)); |
1020 | 1021 |
1021 // While the decoder is decoding, pass an empty surface. | 1022 // While the decoder is decoding, pass an empty surface. |
1022 gfx::ScopedJavaSurface empty_surface; | 1023 gfx::ScopedJavaSurface empty_surface; |
1023 player_.SetVideoSurface(empty_surface.Pass()); | 1024 player_.SetVideoSurface(std::move(empty_surface)); |
1024 // Let the player starve. However, it should not issue any new data request in | 1025 // Let the player starve. However, it should not issue any new data request in |
1025 // this case. | 1026 // this case. |
1026 TriggerPlayerStarvation(); | 1027 TriggerPlayerStarvation(); |
1027 // Wait for the media codec bridge to finish decoding and be reset. | 1028 // Wait for the media codec bridge to finish decoding and be reset. |
1028 while (GetMediaDecoderJob(false)->is_decoding()) | 1029 while (GetMediaDecoderJob(false)->is_decoding()) |
1029 message_loop_.RunUntilIdle(); | 1030 message_loop_.RunUntilIdle(); |
1030 | 1031 |
1031 // No further seek or data requests should have been received since the | 1032 // No further seek or data requests should have been received since the |
1032 // surface is empty. | 1033 // surface is empty. |
1033 EXPECT_EQ(0, demuxer_->num_browser_seek_requests()); | 1034 EXPECT_EQ(0, demuxer_->num_browser_seek_requests()); |
(...skipping 1345 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
2379 | 2380 |
2380 EXPECT_EQ(demuxer_->num_data_requests(), 0); | 2381 EXPECT_EQ(demuxer_->num_data_requests(), 0); |
2381 player_.OnDemuxerConfigsAvailable(CreateDemuxerConfigs(true, true)); | 2382 player_.OnDemuxerConfigsAvailable(CreateDemuxerConfigs(true, true)); |
2382 | 2383 |
2383 manager_.set_allow_play(true); | 2384 manager_.set_allow_play(true); |
2384 player_.Start(); | 2385 player_.Start(); |
2385 EXPECT_TRUE(player_.IsPlaying()); | 2386 EXPECT_TRUE(player_.IsPlaying()); |
2386 } | 2387 } |
2387 | 2388 |
2388 } // namespace media | 2389 } // namespace media |
OLD | NEW |