| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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 "components/arc/arc_service_manager.h" | 5 #include "components/arc/arc_service_manager.h" |
| 6 | 6 |
| 7 #include "base/logging.h" | 7 #include "base/logging.h" |
| 8 #include "base/memory/ptr_util.h" | 8 #include "base/memory/ptr_util.h" |
| 9 #include "base/task_runner.h" | 9 #include "base/task_runner.h" |
| 10 #include "components/arc/arc_bridge_service.h" | 10 #include "components/arc/arc_bridge_service.h" |
| 11 #include "components/arc/arc_session.h" | 11 #include "components/arc/arc_session.h" |
| 12 #include "components/arc/arc_session_runner.h" | 12 #include "components/arc/arc_session_runner.h" |
| 13 #include "components/arc/intent_helper/arc_intent_helper_observer.h" | 13 #include "components/arc/intent_helper/arc_intent_helper_observer.h" |
| 14 | 14 |
| 15 namespace arc { | 15 namespace arc { |
| 16 namespace { | 16 namespace { |
| 17 | 17 |
| 18 // Weak pointer. This class is owned by arc::ArcServiceLauncher. | 18 // Weak pointer. This class is owned by arc::ArcServiceLauncher. |
| 19 ArcServiceManager* g_arc_service_manager = nullptr; | 19 ArcServiceManager* g_arc_service_manager = nullptr; |
| 20 | 20 |
| 21 } // namespace | 21 } // namespace |
| 22 | 22 |
| 23 class ArcServiceManager::IntentHelperObserverImpl | |
| 24 : public ArcIntentHelperObserver { | |
| 25 public: | |
| 26 explicit IntentHelperObserverImpl(ArcServiceManager* manager); | |
| 27 ~IntentHelperObserverImpl() override = default; | |
| 28 | |
| 29 private: | |
| 30 void OnIntentFiltersUpdated() override; | |
| 31 ArcServiceManager* const manager_; | |
| 32 | |
| 33 DISALLOW_COPY_AND_ASSIGN(IntentHelperObserverImpl); | |
| 34 }; | |
| 35 | |
| 36 ArcServiceManager::IntentHelperObserverImpl::IntentHelperObserverImpl( | |
| 37 ArcServiceManager* manager) | |
| 38 : manager_(manager) {} | |
| 39 | |
| 40 void ArcServiceManager::IntentHelperObserverImpl::OnIntentFiltersUpdated() { | |
| 41 DCHECK(manager_->thread_checker_.CalledOnValidThread()); | |
| 42 for (auto& observer : manager_->observer_list_) | |
| 43 observer.OnIntentFiltersUpdated(); | |
| 44 } | |
| 45 | |
| 46 ArcServiceManager::ArcServiceManager( | 23 ArcServiceManager::ArcServiceManager( |
| 47 scoped_refptr<base::TaskRunner> blocking_task_runner) | 24 scoped_refptr<base::TaskRunner> blocking_task_runner) |
| 48 : blocking_task_runner_(blocking_task_runner), | 25 : blocking_task_runner_(blocking_task_runner), |
| 49 intent_helper_observer_(base::MakeUnique<IntentHelperObserverImpl>(this)), | |
| 50 arc_bridge_service_(base::MakeUnique<ArcBridgeService>()), | 26 arc_bridge_service_(base::MakeUnique<ArcBridgeService>()), |
| 51 icon_loader_(new ActivityIconLoader()), | 27 icon_loader_(new ActivityIconLoader()), |
| 52 activity_resolver_(new LocalActivityResolver()) { | 28 activity_resolver_(new LocalActivityResolver()) { |
| 53 DCHECK(!g_arc_service_manager); | 29 DCHECK(!g_arc_service_manager); |
| 54 g_arc_service_manager = this; | 30 g_arc_service_manager = this; |
| 55 } | 31 } |
| 56 | 32 |
| 57 ArcServiceManager::~ArcServiceManager() { | 33 ArcServiceManager::~ArcServiceManager() { |
| 58 DCHECK(thread_checker_.CalledOnValidThread()); | 34 DCHECK(thread_checker_.CalledOnValidThread()); |
| 59 DCHECK_EQ(g_arc_service_manager, this); | 35 DCHECK_EQ(g_arc_service_manager, this); |
| 60 g_arc_service_manager = nullptr; | 36 g_arc_service_manager = nullptr; |
| 61 } | 37 } |
| 62 | 38 |
| 63 // static | 39 // static |
| 64 ArcServiceManager* ArcServiceManager::Get() { | 40 ArcServiceManager* ArcServiceManager::Get() { |
| 65 if (!g_arc_service_manager) | 41 if (!g_arc_service_manager) |
| 66 return nullptr; | 42 return nullptr; |
| 67 DCHECK(g_arc_service_manager->thread_checker_.CalledOnValidThread()); | 43 DCHECK(g_arc_service_manager->thread_checker_.CalledOnValidThread()); |
| 68 return g_arc_service_manager; | 44 return g_arc_service_manager; |
| 69 } | 45 } |
| 70 | 46 |
| 71 // static | |
| 72 bool ArcServiceManager::IsInitialized() { | |
| 73 if (!g_arc_service_manager) | |
| 74 return false; | |
| 75 DCHECK(g_arc_service_manager->thread_checker_.CalledOnValidThread()); | |
| 76 return true; | |
| 77 } | |
| 78 | |
| 79 ArcBridgeService* ArcServiceManager::arc_bridge_service() { | 47 ArcBridgeService* ArcServiceManager::arc_bridge_service() { |
| 80 DCHECK(thread_checker_.CalledOnValidThread()); | 48 DCHECK(thread_checker_.CalledOnValidThread()); |
| 81 return arc_bridge_service_.get(); | 49 return arc_bridge_service_.get(); |
| 82 } | 50 } |
| 83 | 51 |
| 84 bool ArcServiceManager::AddServiceInternal( | 52 bool ArcServiceManager::AddServiceInternal( |
| 85 const std::string& name, | 53 const std::string& name, |
| 86 std::unique_ptr<ArcService> service) { | 54 std::unique_ptr<ArcService> service) { |
| 87 DCHECK(thread_checker_.CalledOnValidThread()); | 55 DCHECK(thread_checker_.CalledOnValidThread()); |
| 88 if (!name.empty() && services_.count(name) != 0) { | 56 if (!name.empty() && services_.count(name) != 0) { |
| (...skipping 13 matching lines...) Expand all Loading... |
| 102 return nullptr; | 70 return nullptr; |
| 103 } | 71 } |
| 104 auto service = services_.find(name); | 72 auto service = services_.find(name); |
| 105 if (service == services_.end()) { | 73 if (service == services_.end()) { |
| 106 LOG(ERROR) << "Named service " << name << " not found"; | 74 LOG(ERROR) << "Named service " << name << " not found"; |
| 107 return nullptr; | 75 return nullptr; |
| 108 } | 76 } |
| 109 return service->second.get(); | 77 return service->second.get(); |
| 110 } | 78 } |
| 111 | 79 |
| 112 void ArcServiceManager::AddObserver(Observer* observer) { | |
| 113 DCHECK(thread_checker_.CalledOnValidThread()); | |
| 114 observer_list_.AddObserver(observer); | |
| 115 } | |
| 116 | |
| 117 void ArcServiceManager::RemoveObserver(Observer* observer) { | |
| 118 DCHECK(thread_checker_.CalledOnValidThread()); | |
| 119 observer_list_.RemoveObserver(observer); | |
| 120 } | |
| 121 | |
| 122 void ArcServiceManager::Shutdown() { | 80 void ArcServiceManager::Shutdown() { |
| 123 DCHECK(thread_checker_.CalledOnValidThread()); | 81 DCHECK(thread_checker_.CalledOnValidThread()); |
| 124 icon_loader_ = nullptr; | 82 icon_loader_ = nullptr; |
| 125 activity_resolver_ = nullptr; | 83 activity_resolver_ = nullptr; |
| 126 services_.clear(); | 84 services_.clear(); |
| 127 } | 85 } |
| 128 | 86 |
| 129 } // namespace arc | 87 } // namespace arc |
| OLD | NEW |