Pref service: add persistent pref store frontend and backend.

services/preferences/persistent_pref_store_impl.cc

Index: services/preferences/persistent_pref_store_impl.cc
diff --git a/services/preferences/persistent_pref_store_impl.cc b/services/preferences/persistent_pref_store_impl.cc
new file mode 100644
index 0000000000000000000000000000000000000000..65e2444a3790a7ed9e796575e8491e0fa3f659c6
--- /dev/null
+++ b/services/preferences/persistent_pref_store_impl.cc
@@ -0,0 +1,165 @@
+// 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/persistent_pref_store_impl.h"
+
+#include <utility>
+
+#include "base/auto_reset.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 PersistentPrefStoreImpl::Connection : public mojom::PersistentPrefStore {
+ public:
+  Connection(PersistentPrefStoreImpl* pref_store,
+             mojom::PersistentPrefStoreRequest request,
+             mojom::PrefStoreObserverPtr observer)
+      : pref_store_(pref_store),
+        binding_(this, std::move(request)),
+        observer_(std::move(observer)) {
+    auto error_callback =
+        base::Bind(&PersistentPrefStoreImpl::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 (write_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(&write_in_progress_, true);
+    pref_store_->SetValue(key, std::move(value), flags);
+  }
+
+  void CommitPendingWrite() override { pref_store_->CommitPendingWrite(); }
+  void SchedulePendingLossyWrites() override {
+    pref_store_->SchedulePendingLossyWrites();
+  }
+  void ClearMutableValues() override { pref_store_->ClearMutableValues(); }
+
+  void OnConnectionError() { pref_store_->OnConnectionError(this); }
+
+  // Owns |this|.
+  PersistentPrefStoreImpl* pref_store_;
+
+  mojo::Binding<mojom::PersistentPrefStore> binding_;
+  mojom::PrefStoreObserverPtr observer_;
+
+  // If true then a write is in progress and any update notifications should be
+  // ignored, as those updates would originate from ourselves.
+  bool write_in_progress_ = false;
+
+  DISALLOW_COPY_AND_ASSIGN(Connection);
+};
+
+PersistentPrefStoreImpl::PersistentPrefStoreImpl(
+    scoped_refptr<PersistentPrefStore> backing_pref_store,
+    mojom::TrackedPreferenceValidationDelegatePtr validation_delegate)
+    : backing_pref_store_(backing_pref_store),
+      validation_delegate_(std::move(validation_delegate)) {
+  backing_pref_store_->AddObserver(this);
+  if (!backing_pref_store_->IsInitializationComplete()) {
+    initializing_ = true;
+    backing_pref_store_->ReadPrefsAsync(nullptr);
+  }
+}
+
+PersistentPrefStoreImpl::~PersistentPrefStoreImpl() {
+  backing_pref_store_->RemoveObserver(this);
+}
+
+// mojom::PersistentPrefStoreConnector override:
+void PersistentPrefStoreImpl::Connect(const ConnectCallback& callback) {
+  if (initializing_) {
+    pending_connect_callbacks_.push_back(callback);
+    return;
+  }
+  CallConnectCallback(callback);
+}
+
+void PersistentPrefStoreImpl::OnPrefValueChanged(const std::string& key) {
+  // All mutations are triggered by a client. Updates are only sent to clients
+  // other than the instigator so if there is only one client, it will ignore
+  // the update.
+  if (connections_.size() == 1)
+    return;
+
+  const base::Value* value = nullptr;
+  backing_pref_store_->GetValue(key, &value);
+  for (auto& entry : connections_)
+    entry.first->OnPrefValueChanged(key, value);
+}
+
+void PersistentPrefStoreImpl::OnInitializationCompleted(bool succeeded) {
+  DCHECK(initializing_);
+  initializing_ = false;
+  for (const auto& callback : pending_connect_callbacks_) {
+    CallConnectCallback(callback);
+  }
+  pending_connect_callbacks_.clear();
+}
+
+void PersistentPrefStoreImpl::CallConnectCallback(
+    const mojom::PersistentPrefStoreConnector::ConnectCallback& callback) {
+  DCHECK(!initializing_);
+  if (!backing_pref_store_->IsInitializationComplete()) {
+    callback.Run(backing_pref_store_->GetReadError(),
+                 backing_pref_store_->ReadOnly(), nullptr, nullptr, nullptr);
+    return;
+  }
+  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_->GetValues(), std::move(pref_store_ptr),
+               std::move(observer_request));
+}
+
+void PersistentPrefStoreImpl::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 PersistentPrefStoreImpl::CommitPendingWrite() {
+  backing_pref_store_->CommitPendingWrite();
+}
+
+void PersistentPrefStoreImpl::SchedulePendingLossyWrites() {
+  backing_pref_store_->SchedulePendingLossyWrites();
+}
+
+void PersistentPrefStoreImpl::ClearMutableValues() {
+  backing_pref_store_->ClearMutableValues();
+}
+
+void PersistentPrefStoreImpl::OnConnectionError(Connection* connection) {
+  connections_.erase(connection);
+}
+
+}  // namespace prefs