| 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 <set> | 5 #include <set> |
| 6 #include <utility> | 6 #include <utility> |
| 7 | 7 |
| 8 #include "base/bind.h" | 8 #include "base/bind.h" |
| 9 #include "base/callback.h" | 9 #include "base/callback.h" |
| 10 #include "base/macros.h" | 10 #include "base/macros.h" |
| (...skipping 11 matching lines...) Expand all Loading... |
| 22 namespace mojo { | 22 namespace mojo { |
| 23 | 23 |
| 24 namespace { | 24 namespace { |
| 25 | 25 |
| 26 class ApplicationThread : public base::PlatformThread::Delegate { | 26 class ApplicationThread : public base::PlatformThread::Delegate { |
| 27 public: | 27 public: |
| 28 ApplicationThread( | 28 ApplicationThread( |
| 29 scoped_refptr<base::SingleThreadTaskRunner> handler_thread, | 29 scoped_refptr<base::SingleThreadTaskRunner> handler_thread, |
| 30 const base::Callback<void(ApplicationThread*)>& termination_callback, | 30 const base::Callback<void(ApplicationThread*)>& termination_callback, |
| 31 ContentHandlerFactory::Delegate* handler_delegate, | 31 ContentHandlerFactory::Delegate* handler_delegate, |
| 32 InterfaceRequest<shell::mojom::Application> application_request, | 32 InterfaceRequest<shell::mojom::ShellClient> request, |
| 33 URLResponsePtr response, | 33 URLResponsePtr response, |
| 34 const Callback<void()>& destruct_callback) | 34 const Callback<void()>& destruct_callback) |
| 35 : handler_thread_(handler_thread), | 35 : handler_thread_(handler_thread), |
| 36 termination_callback_(termination_callback), | 36 termination_callback_(termination_callback), |
| 37 handler_delegate_(handler_delegate), | 37 handler_delegate_(handler_delegate), |
| 38 application_request_(std::move(application_request)), | 38 request_(std::move(request)), |
| 39 response_(std::move(response)), | 39 response_(std::move(response)), |
| 40 destruct_callback_(destruct_callback) {} | 40 destruct_callback_(destruct_callback) {} |
| 41 | 41 |
| 42 ~ApplicationThread() override { | 42 ~ApplicationThread() override { |
| 43 destruct_callback_.Run(); | 43 destruct_callback_.Run(); |
| 44 } | 44 } |
| 45 | 45 |
| 46 private: | 46 private: |
| 47 void ThreadMain() override { | 47 void ThreadMain() override { |
| 48 handler_delegate_->RunApplication(std::move(application_request_), | 48 handler_delegate_->RunApplication(std::move(request_), |
| 49 std::move(response_)); | 49 std::move(response_)); |
| 50 handler_thread_->PostTask(FROM_HERE, | 50 handler_thread_->PostTask(FROM_HERE, |
| 51 base::Bind(termination_callback_, this)); | 51 base::Bind(termination_callback_, this)); |
| 52 } | 52 } |
| 53 | 53 |
| 54 scoped_refptr<base::SingleThreadTaskRunner> handler_thread_; | 54 scoped_refptr<base::SingleThreadTaskRunner> handler_thread_; |
| 55 base::Callback<void(ApplicationThread*)> termination_callback_; | 55 base::Callback<void(ApplicationThread*)> termination_callback_; |
| 56 ContentHandlerFactory::Delegate* handler_delegate_; | 56 ContentHandlerFactory::Delegate* handler_delegate_; |
| 57 InterfaceRequest<shell::mojom::Application> application_request_; | 57 InterfaceRequest<shell::mojom::ShellClient> request_; |
| 58 URLResponsePtr response_; | 58 URLResponsePtr response_; |
| 59 Callback<void()> destruct_callback_; | 59 Callback<void()> destruct_callback_; |
| 60 | 60 |
| 61 DISALLOW_COPY_AND_ASSIGN(ApplicationThread); | 61 DISALLOW_COPY_AND_ASSIGN(ApplicationThread); |
| 62 }; | 62 }; |
| 63 | 63 |
| 64 class ContentHandlerImpl : public shell::mojom::ContentHandler { | 64 class ContentHandlerImpl : public shell::mojom::ContentHandler { |
| 65 public: | 65 public: |
| 66 ContentHandlerImpl(ContentHandlerFactory::Delegate* delegate, | 66 ContentHandlerImpl(ContentHandlerFactory::Delegate* delegate, |
| 67 InterfaceRequest<shell::mojom::ContentHandler> request) | 67 InterfaceRequest<shell::mojom::ContentHandler> request) |
| 68 : delegate_(delegate), | 68 : delegate_(delegate), |
| 69 binding_(this, std::move(request)), | 69 binding_(this, std::move(request)), |
| 70 weak_factory_(this) {} | 70 weak_factory_(this) {} |
| 71 ~ContentHandlerImpl() override { | 71 ~ContentHandlerImpl() override { |
| 72 // We're shutting down and doing cleanup. Cleanup may trigger calls back to | 72 // We're shutting down and doing cleanup. Cleanup may trigger calls back to |
| 73 // OnThreadEnd(). As we're doing the cleanup here we don't want to do it in | 73 // OnThreadEnd(). As we're doing the cleanup here we don't want to do it in |
| 74 // OnThreadEnd() as well. InvalidateWeakPtrs() ensures we don't get any | 74 // OnThreadEnd() as well. InvalidateWeakPtrs() ensures we don't get any |
| 75 // calls to OnThreadEnd(). | 75 // calls to OnThreadEnd(). |
| 76 weak_factory_.InvalidateWeakPtrs(); | 76 weak_factory_.InvalidateWeakPtrs(); |
| 77 for (auto thread : active_threads_) { | 77 for (auto thread : active_threads_) { |
| 78 base::PlatformThread::Join(thread.second); | 78 base::PlatformThread::Join(thread.second); |
| 79 delete thread.first; | 79 delete thread.first; |
| 80 } | 80 } |
| 81 } | 81 } |
| 82 | 82 |
| 83 private: | 83 private: |
| 84 // Overridden from ContentHandler: | 84 // Overridden from ContentHandler: |
| 85 void StartApplication( | 85 void StartApplication(InterfaceRequest<shell::mojom::ShellClient> request, |
| 86 InterfaceRequest<shell::mojom::Application> application_request, | 86 URLResponsePtr response, |
| 87 URLResponsePtr response, | 87 const Callback<void()>& destruct_callback) override { |
| 88 const Callback<void()>& destruct_callback) override { | |
| 89 ApplicationThread* thread = | 88 ApplicationThread* thread = |
| 90 new ApplicationThread(base::ThreadTaskRunnerHandle::Get(), | 89 new ApplicationThread(base::ThreadTaskRunnerHandle::Get(), |
| 91 base::Bind(&ContentHandlerImpl::OnThreadEnd, | 90 base::Bind(&ContentHandlerImpl::OnThreadEnd, |
| 92 weak_factory_.GetWeakPtr()), | 91 weak_factory_.GetWeakPtr()), |
| 93 delegate_, std::move(application_request), | 92 delegate_, std::move(request), |
| 94 std::move(response), destruct_callback); | 93 std::move(response), destruct_callback); |
| 95 base::PlatformThreadHandle handle; | 94 base::PlatformThreadHandle handle; |
| 96 bool launched = base::PlatformThread::Create(0, thread, &handle); | 95 bool launched = base::PlatformThread::Create(0, thread, &handle); |
| 97 DCHECK(launched); | 96 DCHECK(launched); |
| 98 active_threads_[thread] = handle; | 97 active_threads_[thread] = handle; |
| 99 } | 98 } |
| 100 | 99 |
| 101 void OnThreadEnd(ApplicationThread* thread) { | 100 void OnThreadEnd(ApplicationThread* thread) { |
| 102 DCHECK(active_threads_.find(thread) != active_threads_.end()); | 101 DCHECK(active_threads_.find(thread) != active_threads_.end()); |
| 103 base::PlatformThreadHandle handle = active_threads_[thread]; | 102 base::PlatformThreadHandle handle = active_threads_[thread]; |
| (...skipping 13 matching lines...) Expand all Loading... |
| 117 } // namespace | 116 } // namespace |
| 118 | 117 |
| 119 ContentHandlerFactory::ContentHandlerFactory(Delegate* delegate) | 118 ContentHandlerFactory::ContentHandlerFactory(Delegate* delegate) |
| 120 : delegate_(delegate) { | 119 : delegate_(delegate) { |
| 121 } | 120 } |
| 122 | 121 |
| 123 ContentHandlerFactory::~ContentHandlerFactory() { | 122 ContentHandlerFactory::~ContentHandlerFactory() { |
| 124 } | 123 } |
| 125 | 124 |
| 126 void ContentHandlerFactory::ManagedDelegate::RunApplication( | 125 void ContentHandlerFactory::ManagedDelegate::RunApplication( |
| 127 InterfaceRequest<shell::mojom::Application> application_request, | 126 InterfaceRequest<shell::mojom::ShellClient> request, |
| 128 URLResponsePtr response) { | 127 URLResponsePtr response) { |
| 129 base::MessageLoop loop(common::MessagePumpMojo::Create()); | 128 base::MessageLoop loop(common::MessagePumpMojo::Create()); |
| 130 auto application = this->CreateApplication(std::move(application_request), | 129 auto application = |
| 131 std::move(response)); | 130 this->CreateApplication(std::move(request), std::move(response)); |
| 132 if (application) | 131 if (application) |
| 133 loop.Run(); | 132 loop.Run(); |
| 134 } | 133 } |
| 135 | 134 |
| 136 void ContentHandlerFactory::Create( | 135 void ContentHandlerFactory::Create( |
| 137 Connection* connection, | 136 Connection* connection, |
| 138 InterfaceRequest<shell::mojom::ContentHandler> request) { | 137 InterfaceRequest<shell::mojom::ContentHandler> request) { |
| 139 new ContentHandlerImpl(delegate_, std::move(request)); | 138 new ContentHandlerImpl(delegate_, std::move(request)); |
| 140 } | 139 } |
| 141 | 140 |
| 142 } // namespace mojo | 141 } // namespace mojo |
| OLD | NEW |