| 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 "cc/resources/texture_mailbox_deleter.h" | 5 #include "cc/resources/texture_mailbox_deleter.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/location.h" | 8 #include "base/location.h" |
| 9 #include "base/memory/weak_ptr.h" | 9 #include "base/memory/weak_ptr.h" |
| 10 #include "base/message_loop/message_loop_proxy.h" | 10 #include "base/message_loop/message_loop_proxy.h" |
| 11 #include "cc/output/context_provider.h" | 11 #include "cc/output/context_provider.h" |
| 12 #include "third_party/WebKit/public/platform/WebGraphicsContext3D.h" | 12 #include "third_party/WebKit/public/platform/WebGraphicsContext3D.h" |
| 13 | 13 |
| 14 namespace cc { | 14 namespace cc { |
| 15 | 15 |
| 16 static void DeleteTextureOnImplThread( | 16 static void DeleteTextureOnImplThread( |
| 17 const scoped_refptr<ContextProvider>& context_provider, | 17 const scoped_refptr<ContextProvider>& context_provider, |
| 18 unsigned texture_id, | 18 unsigned texture_id, |
| 19 unsigned sync_point, | 19 unsigned sync_point, |
| 20 bool is_lost) { | 20 bool is_lost) { |
| 21 if (sync_point) | 21 if (sync_point) |
| 22 context_provider->Context3d()->waitSyncPoint(sync_point); | 22 context_provider->Context3d()->waitSyncPoint(sync_point); |
| 23 context_provider->Context3d()->deleteTexture(texture_id); | 23 context_provider->Context3d()->deleteTexture(texture_id); |
| 24 } | 24 } |
| 25 | 25 |
| 26 static void PostTaskFromMainToImplThread( | 26 static void PostTaskFromMainToImplThread( |
| 27 scoped_refptr<base::SingleThreadTaskRunner> impl_task_runner, | 27 scoped_refptr<base::SingleThreadTaskRunner> impl_task_runner, |
| 28 TextureMailbox::ReleaseCallback run_impl_callback, | 28 ReleaseCallback run_impl_callback, |
| 29 unsigned sync_point, | 29 unsigned sync_point, |
| 30 bool is_lost) { | 30 bool is_lost) { |
| 31 // This posts the task to RunDeleteTextureOnImplThread(). | 31 // This posts the task to RunDeleteTextureOnImplThread(). |
| 32 impl_task_runner->PostTask( | 32 impl_task_runner->PostTask( |
| 33 FROM_HERE, base::Bind(run_impl_callback, sync_point, is_lost)); | 33 FROM_HERE, base::Bind(run_impl_callback, sync_point, is_lost)); |
| 34 } | 34 } |
| 35 | 35 |
| 36 TextureMailboxDeleter::TextureMailboxDeleter() : weak_ptr_factory_(this) {} | 36 TextureMailboxDeleter::TextureMailboxDeleter() : weak_ptr_factory_(this) {} |
| 37 | 37 |
| 38 TextureMailboxDeleter::~TextureMailboxDeleter() { | 38 TextureMailboxDeleter::~TextureMailboxDeleter() { |
| 39 for (size_t i = 0; i < impl_callbacks_.size(); ++i) | 39 for (size_t i = 0; i < impl_callbacks_.size(); ++i) |
| 40 impl_callbacks_.at(i)->Run(0, true); | 40 impl_callbacks_.at(i)->RunAndReset(0, true); |
| 41 } | 41 } |
| 42 | 42 |
| 43 TextureMailbox::ReleaseCallback TextureMailboxDeleter::GetReleaseCallback( | 43 ScopedReleaseCallback TextureMailboxDeleter::GetReleaseCallback( |
| 44 const scoped_refptr<ContextProvider>& context_provider, | 44 const scoped_refptr<ContextProvider>& context_provider, |
| 45 unsigned texture_id) { | 45 unsigned texture_id) { |
| 46 // This callback owns a reference on the |context_provider|. It must be | 46 // This callback owns a reference on the |context_provider|. It must be |
| 47 // destroyed on the impl thread. Upon destruction of this class, the | 47 // destroyed on the impl thread. Upon destruction of this class, the |
| 48 // callback must immediately be destroyed. | 48 // callback must immediately be destroyed. |
| 49 scoped_ptr<TextureMailbox::ReleaseCallback> impl_callback( | 49 scoped_ptr<ScopedReleaseCallback> impl_callback( |
| 50 new TextureMailbox::ReleaseCallback(base::Bind( | 50 new ScopedReleaseCallback(base::Bind(&DeleteTextureOnImplThread, |
| 51 &DeleteTextureOnImplThread, context_provider, texture_id))); | 51 context_provider, |
| 52 texture_id))); |
| 52 | 53 |
| 53 impl_callbacks_.push_back(impl_callback.Pass()); | 54 impl_callbacks_.push_back(impl_callback.Pass()); |
| 54 | 55 |
| 55 // The raw pointer to the impl-side callback is valid as long as this | 56 // The raw pointer to the impl-side callback is valid as long as this |
| 56 // class is alive. So we guard it with a WeakPtr. | 57 // class is alive. So we guard it with a WeakPtr. |
| 57 TextureMailbox::ReleaseCallback run_impl_callback = | 58 ReleaseCallback run_impl_callback( |
| 58 base::Bind(&TextureMailboxDeleter::RunDeleteTextureOnImplThread, | 59 base::Bind(&TextureMailboxDeleter::RunDeleteTextureOnImplThread, |
| 59 weak_ptr_factory_.GetWeakPtr(), | 60 weak_ptr_factory_.GetWeakPtr(), |
| 60 impl_callbacks_.back()); | 61 impl_callbacks_.back())); |
| 61 | 62 |
| 62 // Provide a callback for the main thread that posts back to the impl | 63 // Provide a callback for the main thread that posts back to the impl |
| 63 // thread. | 64 // thread. |
| 64 TextureMailbox::ReleaseCallback main_callback = | 65 ScopedReleaseCallback main_callback( |
| 65 base::Bind(&PostTaskFromMainToImplThread, | 66 base::Bind(&PostTaskFromMainToImplThread, |
| 66 base::MessageLoopProxy::current(), | 67 base::MessageLoopProxy::current(), |
| 67 run_impl_callback); | 68 run_impl_callback)); |
| 68 | 69 |
| 69 return main_callback; | 70 return main_callback.Pass(); |
| 70 } | 71 } |
| 71 | 72 |
| 72 void TextureMailboxDeleter::RunDeleteTextureOnImplThread( | 73 void TextureMailboxDeleter::RunDeleteTextureOnImplThread( |
| 73 TextureMailbox::ReleaseCallback* impl_callback, | 74 ScopedReleaseCallback* impl_callback, |
| 74 unsigned sync_point, | 75 unsigned sync_point, |
| 75 bool is_lost) { | 76 bool is_lost) { |
| 76 for (size_t i = 0; i < impl_callbacks_.size(); ++i) { | 77 for (size_t i = 0; i < impl_callbacks_.size(); ++i) { |
| 77 if (impl_callbacks_.at(i)->Equals(*impl_callback)) { | 78 if (impl_callbacks_.at(i)->Equals(*impl_callback)) { |
| 78 // Run the callback, then destroy it here on the impl thread. | 79 // Run the callback, then destroy it here on the impl thread. |
| 79 impl_callback->Run(sync_point, is_lost); | 80 impl_callback->RunAndReset(sync_point, is_lost); |
| 80 impl_callbacks_.erase(impl_callbacks_.begin() + i); | 81 impl_callbacks_.erase(impl_callbacks_.begin() + i); |
| 81 return; | 82 return; |
| 82 } | 83 } |
| 83 } | 84 } |
| 84 | 85 |
| 85 NOTREACHED() << "The Callback returned by GetDeleteCallback() was called " | 86 NOTREACHED() << "The Callback returned by GetDeleteCallback() was called " |
| 86 << "more than once."; | 87 << "more than once."; |
| 87 } | 88 } |
| 88 | 89 |
| 89 } // namespace cc | 90 } // namespace cc |
| OLD | NEW |