Switch LevelDBWrapper::GetAll to use the new Mojo sync IPC mechanism.

content/renderer/dom_storage/local_storage_cached_area.cc

Index: content/renderer/dom_storage/local_storage_cached_area.cc
diff --git a/content/renderer/dom_storage/local_storage_cached_area.cc b/content/renderer/dom_storage/local_storage_cached_area.cc
new file mode 100644
index 0000000000000000000000000000000000000000..1c3b2e22199c2dd1ae7bde70ef752d27982bd8ee
--- /dev/null
+++ b/content/renderer/dom_storage/local_storage_cached_area.cc
@@ -0,0 +1,85 @@
+// 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 "content/renderer/dom_storage/local_storage_cached_area.h"
+
+#include "content/common/storage_partition_service.mojom.h"
+#include "content/renderer/dom_storage/local_storage_cached_areas.h"
+
+namespace content {
+
+LocalStorageCachedArea::LocalStorageCachedArea(
+    const url::Origin& origin,
+    StoragePartitionService* storage_partition_service,
+    LocalStorageCachedAreas* cached_areas)
+    : loaded_(false), origin_(origin), binding_(this),
+      cached_areas_(cached_areas) {
+  storage_partition_service->OpenLocalStorage(
+      origin_.Serialize(), mojo::GetProxy(&leveldb_));
+}
+
+LocalStorageCachedArea::~LocalStorageCachedArea() {
+  cached_areas_->LocalStorageCacheAreaClosed(this);
+}
+
+unsigned LocalStorageCachedArea::GetLength() {
+  EnsureLoaded();
+  return 0u;
+}
+
+base::NullableString16 LocalStorageCachedArea::GetKey(unsigned index) {
+  EnsureLoaded();
+  return base::NullableString16();
+}
+
+base::NullableString16 LocalStorageCachedArea::GetItem(
+    const base::string16& key) {
+  EnsureLoaded();
+  return base::NullableString16();
+}
+
+bool LocalStorageCachedArea::SetItem(const base::string16& key,
+                                     const base::string16& value,
+                                     const GURL& page_url) {
+  EnsureLoaded();
+  return false;
+}
+
+void LocalStorageCachedArea::RemoveItem(const base::string16& key,
+                                        const GURL& page_url) {
+  EnsureLoaded();
+}
+
+void LocalStorageCachedArea::Clear(const GURL& page_url) {
+  // No need to prime the cache in this case.
+
+  binding_.Close();

[michaeln, 2016/03/01 01:38:48]

Nice, this is a much nicer api for ignoring mutation events. The caller still
has to know to do this but the api is a lot more instructive.

[jam, 2016/03/01 06:50:53]

fyi if the caller forgets to do this, they will get a dcheck because it's
already bound.

+  // TODO:
+  // binding_.CreateInterfacePtrAndBind()
+}
+
+void LocalStorageCachedArea::KeyChanged(mojo::Array<uint8_t> key,
+                                        mojo::Array<uint8_t> new_value,
+                                        mojo::Array<uint8_t> old_value,
+                                        const mojo::String& source) {
+}
+
+void LocalStorageCachedArea::KeyDeleted(mojo::Array<uint8_t> key,
+                                        const mojo::String& source) {
+}
+
+void LocalStorageCachedArea::AllDeleted(const mojo::String& source) {
+}
+
+void LocalStorageCachedArea::EnsureLoaded() {
+  if (loaded_)
+    return;
+
+  loaded_ = true;
+  leveldb::DatabaseError status = leveldb::DatabaseError::OK;
+  mojo::Array<content::KeyValuePtr> data;
+  leveldb_->GetAll(binding_.CreateInterfacePtrAndBind(), &status, &data);
+}
+
+}  // namespace content