| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 "webkit/media/webmediaplayer_impl.h" | 5 #include "webkit/media/webmediaplayer_impl.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 #include <limits> | 8 #include <limits> |
| 9 #include <string> | 9 #include <string> |
| 10 #include <vector> | 10 #include <vector> |
| 11 | 11 |
| 12 #include "base/bind.h" | 12 #include "base/bind.h" |
| 13 #include "base/callback.h" | 13 #include "base/callback.h" |
| 14 #include "base/message_loop_proxy.h" | 14 #include "base/message_loop_proxy.h" |
| 15 #include "base/metrics/histogram.h" | 15 #include "base/metrics/histogram.h" |
| 16 #include "base/string_number_conversions.h" | 16 #include "base/string_number_conversions.h" |
| 17 #include "base/synchronization/waitable_event.h" | 17 #include "base/synchronization/waitable_event.h" |
| 18 #include "cc/layers/video_layer.h" |
| 18 #include "gpu/GLES2/gl2extchromium.h" | 19 #include "gpu/GLES2/gl2extchromium.h" |
| 19 #include "media/audio/null_audio_sink.h" | 20 #include "media/audio/null_audio_sink.h" |
| 20 #include "media/base/bind_to_loop.h" | 21 #include "media/base/bind_to_loop.h" |
| 21 #include "media/base/filter_collection.h" | 22 #include "media/base/filter_collection.h" |
| 22 #include "media/base/limits.h" | 23 #include "media/base/limits.h" |
| 23 #include "media/base/media_log.h" | 24 #include "media/base/media_log.h" |
| 24 #include "media/base/pipeline.h" | 25 #include "media/base/pipeline.h" |
| 25 #include "media/base/video_frame.h" | 26 #include "media/base/video_frame.h" |
| 26 #include "media/filters/audio_renderer_impl.h" | 27 #include "media/filters/audio_renderer_impl.h" |
| 27 #include "media/filters/chunk_demuxer.h" | 28 #include "media/filters/chunk_demuxer.h" |
| 28 #include "media/filters/video_renderer_base.h" | 29 #include "media/filters/video_renderer_base.h" |
| 29 #include "third_party/WebKit/Source/Platform/chromium/public/WebRect.h" | 30 #include "third_party/WebKit/Source/Platform/chromium/public/WebRect.h" |
| 30 #include "third_party/WebKit/Source/Platform/chromium/public/WebSize.h" | 31 #include "third_party/WebKit/Source/Platform/chromium/public/WebSize.h" |
| 31 #include "third_party/WebKit/Source/Platform/chromium/public/WebString.h" | 32 #include "third_party/WebKit/Source/Platform/chromium/public/WebString.h" |
| 32 #include "third_party/WebKit/Source/Platform/chromium/public/WebURL.h" | 33 #include "third_party/WebKit/Source/Platform/chromium/public/WebURL.h" |
| 33 #include "third_party/WebKit/Source/WebKit/chromium/public/WebMediaSource.h" | 34 #include "third_party/WebKit/Source/WebKit/chromium/public/WebMediaSource.h" |
| 34 #include "third_party/WebKit/Source/WebKit/chromium/public/WebRuntimeFeatures.h" | 35 #include "third_party/WebKit/Source/WebKit/chromium/public/WebRuntimeFeatures.h" |
| 35 #include "third_party/WebKit/Source/WebKit/chromium/public/WebView.h" | 36 #include "third_party/WebKit/Source/WebKit/chromium/public/WebView.h" |
| 36 #include "v8/include/v8.h" | 37 #include "v8/include/v8.h" |
| 38 #include "webkit/compositor_bindings/web_layer_impl.h" |
| 37 #include "webkit/media/buffered_data_source.h" | 39 #include "webkit/media/buffered_data_source.h" |
| 38 #include "webkit/media/filter_helpers.h" | 40 #include "webkit/media/filter_helpers.h" |
| 39 #include "webkit/media/webaudiosourceprovider_impl.h" | 41 #include "webkit/media/webaudiosourceprovider_impl.h" |
| 40 #include "webkit/media/webmediaplayer_delegate.h" | 42 #include "webkit/media/webmediaplayer_delegate.h" |
| 41 #include "webkit/media/webmediaplayer_params.h" | 43 #include "webkit/media/webmediaplayer_params.h" |
| 42 #include "webkit/media/webmediaplayer_util.h" | 44 #include "webkit/media/webmediaplayer_util.h" |
| 43 #include "webkit/media/webmediasourceclient_impl.h" | 45 #include "webkit/media/webmediasourceclient_impl.h" |
| 44 #include "webkit/media/webvideoframe_impl.h" | |
| 45 #include "webkit/plugins/ppapi/ppapi_webplugin_impl.h" | 46 #include "webkit/plugins/ppapi/ppapi_webplugin_impl.h" |
| 46 | 47 |
| 47 using WebKit::WebCanvas; | 48 using WebKit::WebCanvas; |
| 48 using WebKit::WebMediaPlayer; | 49 using WebKit::WebMediaPlayer; |
| 49 using WebKit::WebRect; | 50 using WebKit::WebRect; |
| 50 using WebKit::WebSize; | 51 using WebKit::WebSize; |
| 51 using WebKit::WebString; | 52 using WebKit::WebString; |
| 52 using media::PipelineStatus; | 53 using media::PipelineStatus; |
| 53 | 54 |
| 54 namespace { | 55 namespace { |
| (...skipping 83 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 138 pending_seek_(false), | 139 pending_seek_(false), |
| 139 pending_seek_seconds_(0.0f), | 140 pending_seek_seconds_(0.0f), |
| 140 client_(client), | 141 client_(client), |
| 141 delegate_(delegate), | 142 delegate_(delegate), |
| 142 media_log_(params.media_log()), | 143 media_log_(params.media_log()), |
| 143 accelerated_compositing_reported_(false), | 144 accelerated_compositing_reported_(false), |
| 144 incremented_externally_allocated_memory_(false), | 145 incremented_externally_allocated_memory_(false), |
| 145 is_local_source_(false), | 146 is_local_source_(false), |
| 146 supports_save_(true), | 147 supports_save_(true), |
| 147 starting_(false), | 148 starting_(false), |
| 148 pending_repaint_(false) { | 149 pending_repaint_(false), |
| 150 video_frame_provider_client_(NULL) { |
| 149 media_log_->AddEvent( | 151 media_log_->AddEvent( |
| 150 media_log_->CreateEvent(media::MediaLogEvent::WEBMEDIAPLAYER_CREATED)); | 152 media_log_->CreateEvent(media::MediaLogEvent::WEBMEDIAPLAYER_CREATED)); |
| 151 | 153 |
| 152 CHECK(media_thread_.Start()); | 154 CHECK(media_thread_.Start()); |
| 153 pipeline_ = new media::Pipeline( | 155 pipeline_ = new media::Pipeline( |
| 154 media_thread_.message_loop_proxy(), media_log_); | 156 media_thread_.message_loop_proxy(), media_log_); |
| 155 | 157 |
| 156 // Let V8 know we started new thread if we did not do it yet. | 158 // Let V8 know we started new thread if we did not do it yet. |
| 157 // Made separate task to avoid deletion of player currently being created. | 159 // Made separate task to avoid deletion of player currently being created. |
| 158 // Also, delaying GC until after player starts gets rid of starting lag -- | 160 // Also, delaying GC until after player starts gets rid of starting lag -- |
| (...skipping 45 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 204 new media::NullAudioSink(media_thread_.message_loop_proxy())); | 206 new media::NullAudioSink(media_thread_.message_loop_proxy())); |
| 205 scoped_ptr<media::AudioRenderer> audio_renderer( | 207 scoped_ptr<media::AudioRenderer> audio_renderer( |
| 206 new media::AudioRendererImpl( | 208 new media::AudioRendererImpl( |
| 207 media_thread_.message_loop_proxy(), | 209 media_thread_.message_loop_proxy(), |
| 208 audio_source_provider_, | 210 audio_source_provider_, |
| 209 set_decryptor_ready_cb)); | 211 set_decryptor_ready_cb)); |
| 210 filter_collection_->SetAudioRenderer(audio_renderer.Pass()); | 212 filter_collection_->SetAudioRenderer(audio_renderer.Pass()); |
| 211 } | 213 } |
| 212 | 214 |
| 213 WebMediaPlayerImpl::~WebMediaPlayerImpl() { | 215 WebMediaPlayerImpl::~WebMediaPlayerImpl() { |
| 216 SetVideoFrameProviderClient(NULL); |
| 217 GetClient()->setWebLayer(NULL); |
| 218 |
| 214 DCHECK(main_loop_->BelongsToCurrentThread()); | 219 DCHECK(main_loop_->BelongsToCurrentThread()); |
| 215 Destroy(); | 220 Destroy(); |
| 216 media_log_->AddEvent( | 221 media_log_->AddEvent( |
| 217 media_log_->CreateEvent(media::MediaLogEvent::WEBMEDIAPLAYER_DESTROYED)); | 222 media_log_->CreateEvent(media::MediaLogEvent::WEBMEDIAPLAYER_DESTROYED)); |
| 218 | 223 |
| 219 if (delegate_) | 224 if (delegate_) |
| 220 delegate_->PlayerGone(this); | 225 delegate_->PlayerGone(this); |
| 221 | 226 |
| 222 // Remove destruction observer if we're being destroyed but the main thread is | 227 // Remove destruction observer if we're being destroyed but the main thread is |
| 223 // still running. | 228 // still running. |
| (...skipping 425 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 649 return stats.audio_bytes_decoded; | 654 return stats.audio_bytes_decoded; |
| 650 } | 655 } |
| 651 | 656 |
| 652 unsigned WebMediaPlayerImpl::videoDecodedByteCount() const { | 657 unsigned WebMediaPlayerImpl::videoDecodedByteCount() const { |
| 653 DCHECK(main_loop_->BelongsToCurrentThread()); | 658 DCHECK(main_loop_->BelongsToCurrentThread()); |
| 654 | 659 |
| 655 media::PipelineStatistics stats = pipeline_->GetStatistics(); | 660 media::PipelineStatistics stats = pipeline_->GetStatistics(); |
| 656 return stats.video_bytes_decoded; | 661 return stats.video_bytes_decoded; |
| 657 } | 662 } |
| 658 | 663 |
| 659 WebKit::WebVideoFrame* WebMediaPlayerImpl::getCurrentFrame() { | 664 void WebMediaPlayerImpl::SetVideoFrameProviderClient( |
| 660 base::AutoLock auto_lock(lock_); | 665 cc::VideoFrameProvider::Client* client) { |
| 661 if (current_frame_) | 666 // This is called from both the main renderer thread and the compositor |
| 662 return new WebVideoFrameImpl(current_frame_); | 667 // thread (when the main thread is blocked). |
| 663 return NULL; | 668 if (video_frame_provider_client_) |
| 669 video_frame_provider_client_->StopUsingProvider(); |
| 670 video_frame_provider_client_ = client; |
| 664 } | 671 } |
| 665 | 672 |
| 666 void WebMediaPlayerImpl::putCurrentFrame( | 673 scoped_refptr<media::VideoFrame> WebMediaPlayerImpl::GetCurrentFrame() { |
| 667 WebKit::WebVideoFrame* web_video_frame) { | 674 base::AutoLock auto_lock(lock_); |
| 675 return current_frame_; |
| 676 } |
| 677 |
| 678 void WebMediaPlayerImpl::PutCurrentFrame( |
| 679 const scoped_refptr<media::VideoFrame>& frame) { |
| 668 if (!accelerated_compositing_reported_) { | 680 if (!accelerated_compositing_reported_) { |
| 669 accelerated_compositing_reported_ = true; | 681 accelerated_compositing_reported_ = true; |
| 670 DCHECK(frame_->view()->isAcceleratedCompositingActive()); | 682 DCHECK(frame_->view()->isAcceleratedCompositingActive()); |
| 671 UMA_HISTOGRAM_BOOLEAN("Media.AcceleratedCompositingActive", true); | 683 UMA_HISTOGRAM_BOOLEAN("Media.AcceleratedCompositingActive", true); |
| 672 } | 684 } |
| 673 delete web_video_frame; | |
| 674 } | 685 } |
| 675 | 686 |
| 676 bool WebMediaPlayerImpl::copyVideoTextureToPlatformTexture( | 687 bool WebMediaPlayerImpl::copyVideoTextureToPlatformTexture( |
| 677 WebKit::WebGraphicsContext3D* web_graphics_context, | 688 WebKit::WebGraphicsContext3D* web_graphics_context, |
| 678 unsigned int texture, | 689 unsigned int texture, |
| 679 unsigned int level, | 690 unsigned int level, |
| 680 unsigned int internal_format, | 691 unsigned int internal_format, |
| 681 bool premultiply_alpha, | 692 bool premultiply_alpha, |
| 682 bool flip_y) { | 693 bool flip_y) { |
| 683 scoped_refptr<media::VideoFrame> video_frame; | 694 scoped_refptr<media::VideoFrame> video_frame; |
| (...skipping 425 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1109 // Always notify to ensure client has the latest value. | 1120 // Always notify to ensure client has the latest value. |
| 1110 GetClient()->networkStateChanged(); | 1121 GetClient()->networkStateChanged(); |
| 1111 } | 1122 } |
| 1112 | 1123 |
| 1113 void WebMediaPlayerImpl::SetReadyState(WebMediaPlayer::ReadyState state) { | 1124 void WebMediaPlayerImpl::SetReadyState(WebMediaPlayer::ReadyState state) { |
| 1114 DCHECK(main_loop_->BelongsToCurrentThread()); | 1125 DCHECK(main_loop_->BelongsToCurrentThread()); |
| 1115 DVLOG(1) << "SetReadyState: " << state; | 1126 DVLOG(1) << "SetReadyState: " << state; |
| 1116 | 1127 |
| 1117 if (ready_state_ == WebMediaPlayer::ReadyStateHaveNothing && | 1128 if (ready_state_ == WebMediaPlayer::ReadyStateHaveNothing && |
| 1118 state >= WebMediaPlayer::ReadyStateHaveMetadata) { | 1129 state >= WebMediaPlayer::ReadyStateHaveMetadata) { |
| 1119 if (!hasVideo()) | 1130 if (!hasVideo()) { |
| 1120 GetClient()->disableAcceleratedCompositing(); | 1131 GetClient()->disableAcceleratedCompositing(); |
| 1132 } else { |
| 1133 DCHECK(!video_weblayer_); |
| 1134 video_weblayer_.reset( |
| 1135 new webkit::WebLayerImpl(cc::VideoLayer::Create(this))); |
| 1136 GetClient()->setWebLayer(video_weblayer_.get()); |
| 1137 } |
| 1121 } else if (state == WebMediaPlayer::ReadyStateHaveEnoughData) { | 1138 } else if (state == WebMediaPlayer::ReadyStateHaveEnoughData) { |
| 1122 if (is_local_source_ && | 1139 if (is_local_source_ && |
| 1123 network_state_ == WebMediaPlayer::NetworkStateLoading) { | 1140 network_state_ == WebMediaPlayer::NetworkStateLoading) { |
| 1124 SetNetworkState(WebMediaPlayer::NetworkStateLoaded); | 1141 SetNetworkState(WebMediaPlayer::NetworkStateLoaded); |
| 1125 } | 1142 } |
| 1126 } | 1143 } |
| 1127 | 1144 |
| 1128 ready_state_ = state; | 1145 ready_state_ = state; |
| 1129 // Always notify to ensure client has the latest value. | 1146 // Always notify to ensure client has the latest value. |
| 1130 GetClient()->readyStateChanged(); | 1147 GetClient()->readyStateChanged(); |
| (...skipping 69 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1200 | 1217 |
| 1201 if (pending_repaint_) | 1218 if (pending_repaint_) |
| 1202 return; | 1219 return; |
| 1203 | 1220 |
| 1204 pending_repaint_ = true; | 1221 pending_repaint_ = true; |
| 1205 main_loop_->PostTask(FROM_HERE, base::Bind( | 1222 main_loop_->PostTask(FROM_HERE, base::Bind( |
| 1206 &WebMediaPlayerImpl::Repaint, AsWeakPtr())); | 1223 &WebMediaPlayerImpl::Repaint, AsWeakPtr())); |
| 1207 } | 1224 } |
| 1208 | 1225 |
| 1209 } // namespace webkit_media | 1226 } // namespace webkit_media |
| OLD | NEW |