| Index: chrome/browser/prefs/preferences_connection_manager.cc
|
| diff --git a/chrome/browser/prefs/preferences_connection_manager.cc b/chrome/browser/prefs/preferences_connection_manager.cc
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..8a97e55e957a89c4c57a643e95341a20c8781dc7
|
| --- /dev/null
|
| +++ b/chrome/browser/prefs/preferences_connection_manager.cc
|
| @@ -0,0 +1,105 @@
|
| +// Copyright 2016 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 "chrome/browser/prefs/preferences_connection_manager.h"
|
| +
|
| +#include "chrome/browser/browser_process.h"
|
| +#include "chrome/browser/prefs/preferences_manager.h"
|
| +#include "chrome/browser/profiles/profile.h"
|
| +#include "chrome/browser/profiles/profile_manager.h"
|
| +#include "chrome/browser/signin/profile_oauth2_token_service_factory.h"
|
| +#include "components/keyed_service/content/browser_context_keyed_service_shutdown_notifier_factory.h"
|
| +#include "services/service_manager/public/cpp/interface_registry.h"
|
| +
|
| +namespace {
|
| +
|
| +// Required singleton subclass to control dependencies between
|
| +// PreferenceConnectionManager and the KeyedServiceShutdownNotifier.
|
| +class ShutdownNotifierFactory
|
| + : public BrowserContextKeyedServiceShutdownNotifierFactory {
|
| + public:
|
| + static ShutdownNotifierFactory* GetInstance() {
|
| + return base::Singleton<ShutdownNotifierFactory>::get();
|
| + }
|
| +
|
| + private:
|
| + friend struct base::DefaultSingletonTraits<ShutdownNotifierFactory>;
|
| +
|
| + ShutdownNotifierFactory()
|
| + : BrowserContextKeyedServiceShutdownNotifierFactory(
|
| + "PreferencesConnectionManager") {
|
| + DependsOn(ProfileOAuth2TokenServiceFactory::GetInstance());
|
| + }
|
| + ~ShutdownNotifierFactory() override {}
|
| +
|
| + DISALLOW_COPY_AND_ASSIGN(ShutdownNotifierFactory);
|
| +};
|
| +
|
| +} // namespace
|
| +
|
| +PreferencesConnectionManager::PreferencesConnectionManager() {}
|
| +
|
| +PreferencesConnectionManager::~PreferencesConnectionManager() {}
|
| +
|
| +void PreferencesConnectionManager::OnConnectionError(
|
| + mojo::StrongBindingPtr<prefs::mojom::PreferencesManager> binding) {
|
| + if (!binding)
|
| + return;
|
| + for (auto it = std::begin(bindings_); it != std::end(bindings_); ++it) {
|
| + if (it->get() == binding.get()) {
|
| + bindings_.erase(it);
|
| + return;
|
| + }
|
| + }
|
| +}
|
| +
|
| +void PreferencesConnectionManager::OnProfileDestroyed() {
|
| + for (auto& it : bindings_) {
|
| + // Shutdown any PreferenceManager that is still alive.
|
| + if (it)
|
| + it->Close();
|
| + }
|
| +
|
| + profile_shutdown_notification_.reset();
|
| +}
|
| +
|
| +void PreferencesConnectionManager::Create(
|
| + const service_manager::Identity& remote_identity,
|
| + prefs::mojom::PreferencesManagerRequest request) {
|
| + // Certain tests have no profiles to connect to, and static initializers
|
| + // which block the creation of test profiles.
|
| + if (!g_browser_process->profile_manager()->GetNumberOfProfiles())
|
| + return;
|
| +
|
| + Profile* profile = ProfileManager::GetActiveUserProfile();
|
| + mojo::StrongBindingPtr<prefs::mojom::PreferencesManager> binding =
|
| + mojo::MakeStrongBinding(base::MakeUnique<PreferencesManager>(profile),
|
| + std::move(request));
|
| + // Copying the base::WeakPtr for future deletion.
|
| + binding->set_connection_error_handler(
|
| + base::Bind(&PreferencesConnectionManager::OnConnectionError,
|
| + base::Unretained(this), binding));
|
| + bindings_.push_back(std::move(binding));
|
| +}
|
| +
|
| +void PreferencesConnectionManager::OnStart() {
|
| + // Certain tests have no profiles to connect to, and static initializers
|
| + // which block the creation of test profiles.
|
| + if (!g_browser_process->profile_manager()->GetNumberOfProfiles())
|
| + return;
|
| +
|
| + profile_shutdown_notification_ =
|
| + ShutdownNotifierFactory::GetInstance()
|
| + ->Get(ProfileManager::GetActiveUserProfile())
|
| + ->Subscribe(
|
| + base::Bind(&PreferencesConnectionManager::OnProfileDestroyed,
|
| + base::Unretained(this)));
|
| +}
|
| +
|
| +bool PreferencesConnectionManager::OnConnect(
|
| + const service_manager::ServiceInfo& remote_info,
|
| + service_manager::InterfaceRegistry* registry) {
|
| + registry->AddInterface<prefs::mojom::PreferencesManager>(this);
|
| + return true;
|
| +}
|
|
|