| // Copyright 2019 The Chromium Authors. All rights reserved. |
| // Use of this source code is governed by a BSD-style license that can be |
| // found in the LICENSE file. |
| |
| #include "content/browser/system_connector_impl.h" |
| |
| #include "base/logging.h" |
| #include "base/no_destructor.h" |
| #include "base/task/post_task.h" |
| #include "base/threading/sequence_local_storage_slot.h" |
| #include "content/public/browser/browser_task_traits.h" |
| #include "content/public/browser/browser_thread.h" |
| #include "mojo/public/cpp/bindings/pending_receiver.h" |
| #include "mojo/public/cpp/bindings/pending_remote.h" |
| |
| namespace content { |
| |
| namespace { |
| |
| base::SequenceLocalStorageSlot<service_manager::Connector>& |
| GetConnectorStorage() { |
| static base::NoDestructor< |
| base::SequenceLocalStorageSlot<service_manager::Connector>> |
| storage; |
| return *storage; |
| } |
| |
| void BindReceiverOnMainThread( |
| mojo::PendingReceiver<service_manager::mojom::Connector> receiver) { |
| DCHECK_CURRENTLY_ON(BrowserThread::UI); |
| auto* main_thread_connector = GetSystemConnector(); |
| DCHECK(main_thread_connector) |
| << "GetSystemConnector() called on background thread with no system " |
| << "Connector set on the main thread. If this is a unit test " |
| << "environment, consider calling SetSystemConnectorForTesting in test " |
| "setup."; |
| main_thread_connector->BindConnectorRequest(std::move(receiver)); |
| } |
| |
| } // namespace |
| |
| service_manager::Connector* GetSystemConnector() { |
| auto& storage = GetConnectorStorage(); |
| if (!BrowserThread::IsThreadInitialized(BrowserThread::UI) || |
| BrowserThread::CurrentlyOn(BrowserThread::UI)) { |
| return storage.GetValuePointer(); |
| } |
| |
| if (!storage) { |
| mojo::PendingRemote<service_manager::mojom::Connector> remote; |
| base::PostTaskWithTraits( |
| FROM_HERE, {BrowserThread::UI}, |
| base::BindOnce(&BindReceiverOnMainThread, |
| remote.InitWithNewPipeAndPassReceiver())); |
| storage.emplace(std::move(remote)); |
| } |
| |
| return storage.GetValuePointer(); |
| } |
| |
| void SetSystemConnector(std::unique_ptr<service_manager::Connector> connector) { |
| if (!connector) { |
| GetConnectorStorage().reset(); |
| return; |
| } |
| mojo::PendingRemote<service_manager::mojom::Connector> remote; |
| connector->BindConnectorRequest(remote.InitWithNewPipeAndPassReceiver()); |
| GetConnectorStorage().emplace(std::move(remote)); |
| } |
| |
| void SetSystemConnectorForTesting( |
| std::unique_ptr<service_manager::Connector> connector) { |
| SetSystemConnector(std::move(connector)); |
| } |
| |
| } // namespace content |