Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(393)

Unified Diff: services/preferences/user_prefs.cc

Issue 2743463002: WIP: Pref service user prefs. (Closed)
Patch Set: Created 3 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « services/preferences/user_prefs.h ('k') | services/preferences/user_prefs_factory.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: services/preferences/user_prefs.cc
diff --git a/services/preferences/user_prefs.cc b/services/preferences/user_prefs.cc
new file mode 100644
index 0000000000000000000000000000000000000000..2f17a1d83e17309f68ba94599632b98950244020
--- /dev/null
+++ b/services/preferences/user_prefs.cc
@@ -0,0 +1,160 @@
+// Copyright 2017 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 "services/preferences/user_prefs.h"
+
+#include <memory>
+#include <set>
+#include <utility>
+
+#include "base/auto_reset.h"
+#include "base/macros.h"
+#include "base/memory/ptr_util.h"
+#include "base/values.h"
+#include "components/prefs/persistent_pref_store.h"
+#include "mojo/public/cpp/bindings/binding.h"
+
+namespace prefs {
+
+class UserPrefs::Connection : public mojom::PersistentPrefStore {
+ public:
+ Connection(UserPrefs* user_prefs,
+ mojom::PersistentPrefStoreRequest request,
+ mojom::PrefStoreObserverPtr observer)
+ : user_prefs_(user_prefs),
+ binding_(this, std::move(request)),
+ observer_(std::move(observer)) {
+ auto error_callback = base::Bind(&UserPrefs::Connection::OnConnectionError,
+ base::Unretained(this));
+ binding_.set_connection_error_handler(error_callback);
+ observer_.set_connection_error_handler(error_callback);
+ }
+
+ ~Connection() override = default;
+
+ void OnPrefValueChanged(const std::string& key, const base::Value* value) {
+ if (call_in_progress_)
+ return;
+
+ observer_->OnPrefChanged(key, value ? value->CreateDeepCopy() : nullptr);
+ }
+
+ private:
+ // mojom::PersistentPrefStore:
+ void SetValue(const std::string& key,
+ std::unique_ptr<base::Value> value,
+ uint32_t flags) override {
+ base::AutoReset<bool> scoped_call_in_progress(&call_in_progress_, true);
+ user_prefs_->SetValue(key, std::move(value), flags);
+ }
+
+ void CommitPendingWrite() override { user_prefs_->CommitPendingWrite(); }
+ void SchedulePendingLossyWrites() override {
+ user_prefs_->SchedulePendingLossyWrites();
+ }
+ void ClearMutableValues() override { user_prefs_->ClearMutableValues(); }
+
+ void OnConnectionError() { user_prefs_->OnConnectionError(this); }
+
+ // Owns |this|.
+ UserPrefs* user_prefs_;
+
+ mojo::Binding<mojom::PersistentPrefStore> binding_;
+ mojom::PrefStoreObserverPtr observer_;
+
+ bool call_in_progress_ = false;
+
+ DISALLOW_COPY_AND_ASSIGN(Connection);
+};
+
+UserPrefs::UserPrefs(
+ scoped_refptr<PersistentPrefStore> backing_pref_store,
+ mojom::TrackedPreferenceValidationDelegatePtr validation_delegate)
+ : backing_pref_store_(backing_pref_store),
+ validation_delegate_(std::move(validation_delegate)) {}
+
+UserPrefs::~UserPrefs() {
+ backing_pref_store_->RemoveObserver(this);
+}
+
+// mojom::PersistentPrefStoreConnector override:
+void UserPrefs::Connect(const ConnectCallback& callback) {
+ if (backing_pref_store_->IsInitializationComplete()) {
+ CallConnectCallback(callback);
+ return;
+ }
+ connect_callbacks_.push_back(callback);
+ if (loading_)
+ return;
+
+ backing_pref_store_->AddObserver(this);
+ loading_ = true;
+ backing_pref_store_->ReadPrefsAsync(nullptr);
+}
+
+void UserPrefs::OnPrefValueChanged(const std::string& key) {
+ // All mutations are triggered by a client. Updates are only sent to clients
+ // other than the instigator.
+ if (connections_.size() == 1)
+ return;
+
+ const base::Value* value = nullptr;
+ // XXX: Path expansion?!
+ backing_pref_store_->GetValue(key, &value);
+ for (auto& entry : connections_)
+ entry.first->OnPrefValueChanged(key, value);
+}
+
+void UserPrefs::OnInitializationCompleted(bool succeeded) {
+ loading_ = false;
+ for (const auto& callback : connect_callbacks_) {
+ CallConnectCallback(callback);
+ }
+ connect_callbacks_.clear();
+}
+
+void UserPrefs::CallConnectCallback(
+ const mojom::PersistentPrefStoreConnector::ConnectCallback& callback) {
+ mojom::PersistentPrefStorePtr pref_store_ptr;
+ mojom::PrefStoreObserverPtr observer;
+ mojom::PrefStoreObserverRequest observer_request =
+ mojo::MakeRequest(&observer);
+ auto connection = base::MakeUnique<Connection>(
+ this, mojo::MakeRequest(&pref_store_ptr), std::move(observer));
+ auto* connection_ptr = connection.get();
+ connections_.insert(std::make_pair(connection_ptr, std::move(connection)));
+ callback.Run(backing_pref_store_->GetReadError(),
+ backing_pref_store_->ReadOnly(),
+ backing_pref_store_->IsInitializationComplete()
+ ? backing_pref_store_->GetValues()
+ : nullptr,
+ std::move(pref_store_ptr), std::move(observer_request));
+}
+
+void UserPrefs::SetValue(const std::string& key,
+ std::unique_ptr<base::Value> value,
+ uint32_t flags) {
+ if (value)
+ backing_pref_store_->SetValue(key, std::move(value), flags);
+ else
+ backing_pref_store_->RemoveValue(key, flags);
+}
+
+void UserPrefs::CommitPendingWrite() {
+ backing_pref_store_->CommitPendingWrite();
+}
+
+void UserPrefs::SchedulePendingLossyWrites() {
+ backing_pref_store_->SchedulePendingLossyWrites();
+}
+
+void UserPrefs::ClearMutableValues() {
+ backing_pref_store_->ClearMutableValues();
+}
+
+void UserPrefs::OnConnectionError(Connection* connection) {
+ connections_.erase(connection);
+}
+
+} // namespace prefs
« no previous file with comments | « services/preferences/user_prefs.h ('k') | services/preferences/user_prefs_factory.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698