Index: content/renderer/media/android/stream_texture_factory_synchronous_impl.cc |
diff --git a/content/renderer/media/android/stream_texture_factory_synchronous_impl.cc b/content/renderer/media/android/stream_texture_factory_synchronous_impl.cc |
index 20c8ee7ae1ab6f16ec19b736b342b4d222f35803..2d0c873801c5b02e8f63203118e75f7d000aa9a3 100644 |
--- a/content/renderer/media/android/stream_texture_factory_synchronous_impl.cc |
+++ b/content/renderer/media/android/stream_texture_factory_synchronous_impl.cc |
@@ -34,22 +34,27 @@ class StreamTextureProxyImpl |
virtual ~StreamTextureProxyImpl(); |
// StreamTextureProxy implementation: |
- virtual void BindToCurrentThread(int32 stream_id) OVERRIDE; |
- virtual void SetClient(cc::VideoFrameProvider::Client* client) OVERRIDE; |
+ virtual void BindToLoop(int32 stream_id, |
+ cc::VideoFrameProvider::Client* client, |
+ scoped_refptr<base::MessageLoopProxy> loop) OVERRIDE; |
virtual void Release() OVERRIDE; |
private: |
+ void SetClient(cc::VideoFrameProvider::Client* client); |
+ void BindOnThread(int32 stream_id, |
+ cc::VideoFrameProvider::Client* client, |
+ scoped_refptr<base::MessageLoopProxy> loop); |
void OnFrameAvailable(); |
- scoped_refptr<base::MessageLoopProxy> loop_; |
base::Lock client_lock_; |
cc::VideoFrameProvider::Client* client_; |
- base::Closure callback_; |
+ // Accessed on the |loop_| thread only. |
+ scoped_refptr<base::MessageLoopProxy> loop_; |
+ base::Closure callback_; |
scoped_refptr<StreamTextureFactorySynchronousImpl::ContextProvider> |
context_provider_; |
scoped_refptr<gfx::SurfaceTexture> surface_texture_; |
- |
float current_matrix_[16]; |
bool has_updated_; |
@@ -58,18 +63,20 @@ class StreamTextureProxyImpl |
StreamTextureProxyImpl::StreamTextureProxyImpl( |
StreamTextureFactorySynchronousImpl::ContextProvider* provider) |
- : context_provider_(provider), has_updated_(false) { |
+ : client_(NULL), context_provider_(provider), has_updated_(false) { |
std::fill(current_matrix_, current_matrix_ + 16, 0); |
} |
StreamTextureProxyImpl::~StreamTextureProxyImpl() {} |
void StreamTextureProxyImpl::Release() { |
+ // Assumes this is the last reference to this object. So no need to acquire |
+ // lock. |
SetClient(NULL); |
- if (loop_.get() && !loop_->BelongsToCurrentThread()) |
- loop_->DeleteSoon(FROM_HERE, this); |
- else |
+ if (!loop_.get() || loop_->BelongsToCurrentThread() || |
+ !loop_->DeleteSoon(FROM_HERE, this)) { |
delete this; |
+ } |
} |
void StreamTextureProxyImpl::SetClient(cc::VideoFrameProvider::Client* client) { |
@@ -77,8 +84,32 @@ void StreamTextureProxyImpl::SetClient(cc::VideoFrameProvider::Client* client) { |
client_ = client; |
} |
-void StreamTextureProxyImpl::BindToCurrentThread(int stream_id) { |
- loop_ = base::MessageLoopProxy::current(); |
+void StreamTextureProxyImpl::BindToLoop( |
+ int32 stream_id, |
+ cc::VideoFrameProvider::Client* client, |
+ scoped_refptr<base::MessageLoopProxy> loop) { |
+ |
+ if (loop->BelongsToCurrentThread()) { |
+ BindOnThread(stream_id, client, loop); |
+ return; |
+ } |
+ // Unretained is safe here only because the object is deleted on |loop_| |
+ // thread. |
+ loop->PostTask(FROM_HERE, |
+ base::Bind(&StreamTextureProxyImpl::BindOnThread, |
+ base::Unretained(this), |
+ stream_id, |
+ client, |
+ loop)); |
+} |
+ |
+void StreamTextureProxyImpl::BindOnThread( |
+ int32 stream_id, |
+ cc::VideoFrameProvider::Client* client, |
+ scoped_refptr<base::MessageLoopProxy> loop) { |
+ SetClient(client); |
+ loop_ = loop; |
+ |
surface_texture_ = context_provider_->GetSurfaceTexture(stream_id); |
if (!surface_texture_) { |
LOG(ERROR) << "Failed to get SurfaceTexture for stream."; |
@@ -182,4 +213,14 @@ gpu::gles2::GLES2Interface* StreamTextureFactorySynchronousImpl::ContextGL() { |
return context_provider_->ContextGL(); |
} |
+void StreamTextureFactorySynchronousImpl::AddObserver( |
+ StreamTextureFactoryContextObserver* obs) { |
+ context_provider_->AddObserver(obs); |
+} |
+ |
+void StreamTextureFactorySynchronousImpl::RemoveObserver( |
+ StreamTextureFactoryContextObserver* obs) { |
+ context_provider_->RemoveObserver(obs); |
+} |
+ |
} // namespace content |