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 "content/renderer/media/android/stream_texture_factory_synchronous_impl
.h" | 5 #include "content/renderer/media/android/stream_texture_factory_synchronous_impl
.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 | 8 |
9 #include "base/bind.h" | 9 #include "base/bind.h" |
10 #include "base/callback.h" | 10 #include "base/callback.h" |
11 #include "base/location.h" | 11 #include "base/location.h" |
| 12 #include "base/macros.h" |
12 #include "base/memory/weak_ptr.h" | 13 #include "base/memory/weak_ptr.h" |
13 #include "base/process/process_handle.h" | 14 #include "base/process/process_handle.h" |
14 #include "base/single_thread_task_runner.h" | 15 #include "base/single_thread_task_runner.h" |
15 #include "base/synchronization/lock.h" | 16 #include "base/synchronization/lock.h" |
16 #include "cc/output/context_provider.h" | 17 #include "cc/output/context_provider.h" |
17 #include "content/common/android/surface_texture_peer.h" | 18 #include "content/common/android/surface_texture_peer.h" |
18 #include "content/renderer/render_thread_impl.h" | 19 #include "content/renderer/render_thread_impl.h" |
19 #include "gpu/command_buffer/client/gles2_interface.h" | 20 #include "gpu/command_buffer/client/gles2_interface.h" |
20 #include "ui/gl/android/surface_texture.h" | 21 #include "ui/gl/android/surface_texture.h" |
21 | 22 |
22 using gpu::gles2::GLES2Interface; | 23 using gpu::gles2::GLES2Interface; |
23 | 24 |
24 namespace content { | 25 namespace content { |
25 | 26 |
26 namespace { | 27 namespace { |
27 | 28 |
28 class StreamTextureProxyImpl | 29 class StreamTextureProxyImpl |
29 : public StreamTextureProxy, | 30 : public StreamTextureProxy, |
30 public base::SupportsWeakPtr<StreamTextureProxyImpl> { | 31 public base::SupportsWeakPtr<StreamTextureProxyImpl> { |
31 public: | 32 public: |
32 explicit StreamTextureProxyImpl( | 33 explicit StreamTextureProxyImpl( |
33 StreamTextureFactorySynchronousImpl::ContextProvider* provider); | 34 StreamTextureFactorySynchronousImpl::ContextProvider* provider); |
34 ~StreamTextureProxyImpl() override; | 35 ~StreamTextureProxyImpl() override; |
35 | 36 |
36 // StreamTextureProxy implementation: | 37 // StreamTextureProxy implementation: |
37 void BindToLoop(int32 stream_id, | 38 void BindToLoop(int32_t stream_id, |
38 cc::VideoFrameProvider::Client* client, | 39 cc::VideoFrameProvider::Client* client, |
39 scoped_refptr<base::SingleThreadTaskRunner> loop) override; | 40 scoped_refptr<base::SingleThreadTaskRunner> loop) override; |
40 void Release() override; | 41 void Release() override; |
41 | 42 |
42 private: | 43 private: |
43 void BindOnThread(int32 stream_id); | 44 void BindOnThread(int32_t stream_id); |
44 void OnFrameAvailable(); | 45 void OnFrameAvailable(); |
45 | 46 |
46 // Protects access to |client_| and |loop_|. | 47 // Protects access to |client_| and |loop_|. |
47 base::Lock lock_; | 48 base::Lock lock_; |
48 cc::VideoFrameProvider::Client* client_; | 49 cc::VideoFrameProvider::Client* client_; |
49 scoped_refptr<base::SingleThreadTaskRunner> loop_; | 50 scoped_refptr<base::SingleThreadTaskRunner> loop_; |
50 | 51 |
51 // Accessed on the |loop_| thread only. | 52 // Accessed on the |loop_| thread only. |
52 base::Closure callback_; | 53 base::Closure callback_; |
53 scoped_refptr<StreamTextureFactorySynchronousImpl::ContextProvider> | 54 scoped_refptr<StreamTextureFactorySynchronousImpl::ContextProvider> |
(...skipping 23 matching lines...) Expand all Loading... |
77 // Release is analogous to the destructor, so there should be no more external | 78 // Release is analogous to the destructor, so there should be no more external |
78 // calls to this object in Release. Therefore there is no need to acquire the | 79 // calls to this object in Release. Therefore there is no need to acquire the |
79 // lock to access |loop_|. | 80 // lock to access |loop_|. |
80 if (!loop_.get() || loop_->BelongsToCurrentThread() || | 81 if (!loop_.get() || loop_->BelongsToCurrentThread() || |
81 !loop_->DeleteSoon(FROM_HERE, this)) { | 82 !loop_->DeleteSoon(FROM_HERE, this)) { |
82 delete this; | 83 delete this; |
83 } | 84 } |
84 } | 85 } |
85 | 86 |
86 void StreamTextureProxyImpl::BindToLoop( | 87 void StreamTextureProxyImpl::BindToLoop( |
87 int32 stream_id, | 88 int32_t stream_id, |
88 cc::VideoFrameProvider::Client* client, | 89 cc::VideoFrameProvider::Client* client, |
89 scoped_refptr<base::SingleThreadTaskRunner> loop) { | 90 scoped_refptr<base::SingleThreadTaskRunner> loop) { |
90 DCHECK(loop.get()); | 91 DCHECK(loop.get()); |
91 | 92 |
92 { | 93 { |
93 base::AutoLock lock(lock_); | 94 base::AutoLock lock(lock_); |
94 DCHECK(!loop_.get() || (loop.get() == loop_.get())); | 95 DCHECK(!loop_.get() || (loop.get() == loop_.get())); |
95 loop_ = loop; | 96 loop_ = loop; |
96 client_ = client; | 97 client_ = client; |
97 } | 98 } |
98 | 99 |
99 if (loop->BelongsToCurrentThread()) { | 100 if (loop->BelongsToCurrentThread()) { |
100 BindOnThread(stream_id); | 101 BindOnThread(stream_id); |
101 return; | 102 return; |
102 } | 103 } |
103 // Unretained is safe here only because the object is deleted on |loop_| | 104 // Unretained is safe here only because the object is deleted on |loop_| |
104 // thread. | 105 // thread. |
105 loop->PostTask(FROM_HERE, | 106 loop->PostTask(FROM_HERE, |
106 base::Bind(&StreamTextureProxyImpl::BindOnThread, | 107 base::Bind(&StreamTextureProxyImpl::BindOnThread, |
107 base::Unretained(this), | 108 base::Unretained(this), |
108 stream_id)); | 109 stream_id)); |
109 } | 110 } |
110 | 111 |
111 void StreamTextureProxyImpl::BindOnThread(int32 stream_id) { | 112 void StreamTextureProxyImpl::BindOnThread(int32_t stream_id) { |
112 surface_texture_ = context_provider_->GetSurfaceTexture(stream_id); | 113 surface_texture_ = context_provider_->GetSurfaceTexture(stream_id); |
113 if (!surface_texture_.get()) { | 114 if (!surface_texture_.get()) { |
114 LOG(ERROR) << "Failed to get SurfaceTexture for stream."; | 115 LOG(ERROR) << "Failed to get SurfaceTexture for stream."; |
115 return; | 116 return; |
116 } | 117 } |
117 | 118 |
118 callback_ = | 119 callback_ = |
119 base::Bind(&StreamTextureProxyImpl::OnFrameAvailable, AsWeakPtr()); | 120 base::Bind(&StreamTextureProxyImpl::OnFrameAvailable, AsWeakPtr()); |
120 surface_texture_->SetFrameAvailableCallback(callback_); | 121 surface_texture_->SetFrameAvailableCallback(callback_); |
121 } | 122 } |
(...skipping 49 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
171 context_provider_ = create_context_provider_callback_.Run(); | 172 context_provider_ = create_context_provider_callback_.Run(); |
172 | 173 |
173 if (!context_provider_.get()) | 174 if (!context_provider_.get()) |
174 return NULL; | 175 return NULL; |
175 | 176 |
176 if (observer_ && !had_proxy) | 177 if (observer_ && !had_proxy) |
177 context_provider_->AddObserver(observer_); | 178 context_provider_->AddObserver(observer_); |
178 return new StreamTextureProxyImpl(context_provider_.get()); | 179 return new StreamTextureProxyImpl(context_provider_.get()); |
179 } | 180 } |
180 | 181 |
181 void StreamTextureFactorySynchronousImpl::EstablishPeer(int32 stream_id, | 182 void StreamTextureFactorySynchronousImpl::EstablishPeer(int32_t stream_id, |
182 int player_id, | 183 int player_id, |
183 int frame_id) { | 184 int frame_id) { |
184 DCHECK(context_provider_.get()); | 185 DCHECK(context_provider_.get()); |
185 scoped_refptr<gfx::SurfaceTexture> surface_texture = | 186 scoped_refptr<gfx::SurfaceTexture> surface_texture = |
186 context_provider_->GetSurfaceTexture(stream_id); | 187 context_provider_->GetSurfaceTexture(stream_id); |
187 if (surface_texture.get()) { | 188 if (surface_texture.get()) { |
188 SurfaceTexturePeer::GetInstance()->EstablishSurfaceTexturePeer( | 189 SurfaceTexturePeer::GetInstance()->EstablishSurfaceTexturePeer( |
189 base::GetCurrentProcessHandle(), | 190 base::GetCurrentProcessHandle(), |
190 surface_texture, | 191 surface_texture, |
191 frame_id_, | 192 frame_id_, |
(...skipping 11 matching lines...) Expand all Loading... |
203 gl->GenTextures(1, texture_id); | 204 gl->GenTextures(1, texture_id); |
204 gl->ShallowFlushCHROMIUM(); | 205 gl->ShallowFlushCHROMIUM(); |
205 stream_id = context_provider_->CreateStreamTexture(*texture_id); | 206 stream_id = context_provider_->CreateStreamTexture(*texture_id); |
206 gl->GenMailboxCHROMIUM(texture_mailbox->name); | 207 gl->GenMailboxCHROMIUM(texture_mailbox->name); |
207 gl->ProduceTextureDirectCHROMIUM( | 208 gl->ProduceTextureDirectCHROMIUM( |
208 *texture_id, texture_target, texture_mailbox->name); | 209 *texture_id, texture_target, texture_mailbox->name); |
209 return stream_id; | 210 return stream_id; |
210 } | 211 } |
211 | 212 |
212 void StreamTextureFactorySynchronousImpl::SetStreamTextureSize( | 213 void StreamTextureFactorySynchronousImpl::SetStreamTextureSize( |
213 int32 stream_id, | 214 int32_t stream_id, |
214 const gfx::Size& size) {} | 215 const gfx::Size& size) {} |
215 | 216 |
216 gpu::gles2::GLES2Interface* StreamTextureFactorySynchronousImpl::ContextGL() { | 217 gpu::gles2::GLES2Interface* StreamTextureFactorySynchronousImpl::ContextGL() { |
217 DCHECK(context_provider_.get()); | 218 DCHECK(context_provider_.get()); |
218 return context_provider_->ContextGL(); | 219 return context_provider_->ContextGL(); |
219 } | 220 } |
220 | 221 |
221 void StreamTextureFactorySynchronousImpl::AddObserver( | 222 void StreamTextureFactorySynchronousImpl::AddObserver( |
222 StreamTextureFactoryContextObserver* obs) { | 223 StreamTextureFactoryContextObserver* obs) { |
223 DCHECK(!observer_); | 224 DCHECK(!observer_); |
224 observer_ = obs; | 225 observer_ = obs; |
225 if (context_provider_.get()) | 226 if (context_provider_.get()) |
226 context_provider_->AddObserver(obs); | 227 context_provider_->AddObserver(obs); |
227 } | 228 } |
228 | 229 |
229 void StreamTextureFactorySynchronousImpl::RemoveObserver( | 230 void StreamTextureFactorySynchronousImpl::RemoveObserver( |
230 StreamTextureFactoryContextObserver* obs) { | 231 StreamTextureFactoryContextObserver* obs) { |
231 DCHECK_EQ(observer_, obs); | 232 DCHECK_EQ(observer_, obs); |
232 observer_ = NULL; | 233 observer_ = NULL; |
233 if (context_provider_.get()) | 234 if (context_provider_.get()) |
234 context_provider_->RemoveObserver(obs); | 235 context_provider_->RemoveObserver(obs); |
235 } | 236 } |
236 | 237 |
237 } // namespace content | 238 } // namespace content |
OLD | NEW |