Make DOMStorageContextWrapper a client of memory coordinator

content/browser/dom_storage/dom_storage_context_wrapper.cc

 // Copyright 2013 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/dom_storage/dom_storage_context_wrapper.h"
 
 #include <string>
 #include <vector>
 
 #include "base/bind.h"
 #include "base/bind_helpers.h"
 #include "base/files/file_path.h"
 #include "base/location.h"
 #include "base/memory/ptr_util.h"
 #include "base/memory/weak_ptr.h"
 #include "base/single_thread_task_runner.h"
 #include "base/strings/utf_string_conversions.h"
 #include "base/threading/thread_task_runner_handle.h"
 #include "components/filesystem/public/interfaces/directory.mojom.h"
 #include "components/leveldb/public/interfaces/leveldb.mojom.h"
+#include "components/memory_coordinator/browser/memory_coordinator.h"
 #include "content/browser/dom_storage/dom_storage_area.h"
 #include "content/browser/dom_storage/dom_storage_context_impl.h"
 #include "content/browser/dom_storage/dom_storage_task_runner.h"
 #include "content/browser/dom_storage/session_storage_namespace_impl.h"
 #include "content/browser/leveldb_wrapper_impl.h"
 #include "content/public/browser/browser_thread.h"
 #include "content/public/browser/local_storage_usage_info.h"
 #include "content/public/browser/session_storage_usage_info.h"
 #include "mojo/common/common_type_converters.h"
 #include "services/file/public/cpp/constants.h"
@@ skipping 246 matching lines @@
                         : data_path.AppendASCII(kLocalStorageDirectory),
       data_path.empty() ? data_path
                         : data_path.AppendASCII(kSessionStorageDirectory),
       special_storage_policy,
       new DOMStorageWorkerPoolTaskRunner(
           worker_pool,
           worker_pool->GetNamedSequenceToken("dom_storage_primary"),
           worker_pool->GetNamedSequenceToken("dom_storage_commit"),
           BrowserThread::GetTaskRunnerForThread(BrowserThread::IO).get()));
 
-  memory_pressure_listener_.reset(new base::MemoryPressureListener(
+  if (memory_coordinator::MemoryCoordinator::GetInstance()) {
+    memory_coordinator::MemoryCoordinator::GetInstance()->RegisterClient(this);
+  } else {
+    memory_pressure_listener_.reset(new base::MemoryPressureListener(
       base::Bind(&DOMStorageContextWrapper::OnMemoryPressure, this)));
+  }
 }
 
 DOMStorageContextWrapper::~DOMStorageContextWrapper() {}
 
 void DOMStorageContextWrapper::GetLocalStorageUsage(
     const GetLocalStorageUsageCallback& callback) {
   DCHECK(context_.get());
   context_->task_runner()->PostShutdownBlockingTask(
       FROM_HERE, DOMStorageTaskRunner::PRIMARY_SEQUENCE,
       base::Bind(&GetLocalStorageUsageHelper,
@@ skipping 59 matching lines @@
 }
 
 void DOMStorageContextWrapper::Shutdown() {
   DCHECK(context_.get());
   mojo_state_.reset();
   memory_pressure_listener_.reset();
   context_->task_runner()->PostShutdownBlockingTask(
       FROM_HERE,
       DOMStorageTaskRunner::PRIMARY_SEQUENCE,
       base::Bind(&DOMStorageContextImpl::Shutdown, context_));
+  if (memory_coordinator::MemoryCoordinator::GetInstance()) {
+    memory_coordinator::MemoryCoordinator::GetInstance()->UnregisterClient(
+        this);
+  }
+
 }
 
 void DOMStorageContextWrapper::Flush() {
   DCHECK(context_.get());
   context_->task_runner()->PostShutdownBlockingTask(
       FROM_HERE, DOMStorageTaskRunner::PRIMARY_SEQUENCE,
       base::Bind(&DOMStorageContextImpl::Flush, context_));
 }
 
 void DOMStorageContextWrapper::OpenLocalStorage(
     const url::Origin& origin,
     mojom::LevelDBObserverPtr observer,
     mojom::LevelDBWrapperRequest request) {
   mojo_state_->OpenLocalStorage(
       origin, std::move(observer), std::move(request));
 }
 
 void DOMStorageContextWrapper::OnMemoryPressure(
     base::MemoryPressureListener::MemoryPressureLevel memory_pressure_level) {
+  PurgeMemory(memory_pressure_level ==
+      base::MemoryPressureListener::MEMORY_PRESSURE_LEVEL_CRITICAL);
+}
+
+void DOMStorageContextWrapper::OnMemoryStateChange(
+    memory_coordinator::MemoryState state) {
+  // TODO(hajimehoshi): As OnMemoryStateChange changes the state, we should
+  // adjust the limitation to the amount of cache, DomStroageContextImpl doesn't
+  // have such limitation so far though.
+  switch (state) {
+  case memory_coordinator::MemoryState::NORMAL:

[michaeln, 2016/09/14 19:40:49]

style nit: indent cases by 2 spaces

[hajimehoshi, 2016/09/15 09:14:46]

Done.

+    // Don't have to purge memory here.
+    break;
+  case memory_coordinator::MemoryState::THROTTLED:
+    // TOOD(hajimehoshi): We don't have throttling 'level' so far. When we have
+    // such value, let's change the argument accroding to the value.
+    PurgeMemory(false);
+    break;
+  case memory_coordinator::MemoryState::UNKNOWN:
+  case memory_coordinator::MemoryState::SUSPENDED:
+    NOTREACHED();

[michaeln, 2016/09/14 19:40:49]

maybe comment that SUSPENDED doesn't occur in the main browser process

[hajimehoshi, 2016/09/15 09:14:46]

Done.

+    break;
+  }
+}
+
+void DOMStorageContextWrapper::PurgeMemory(bool aggressively)
+{

[michaeln, 2016/09/14 19:40:49]

style nit: move { up to the end of the previous line

[hajimehoshi, 2016/09/15 09:14:46]

Done.

   DOMStorageContextImpl::PurgeOption purge_option =
       DOMStorageContextImpl::PURGE_UNOPENED;
-  if (memory_pressure_level ==
-      base::MemoryPressureListener::MEMORY_PRESSURE_LEVEL_CRITICAL) {
+  if (aggressively) {
     purge_option = DOMStorageContextImpl::PURGE_AGGRESSIVE;
   }
   context_->task_runner()->PostTask(
       FROM_HERE,
       base::Bind(&DOMStorageContextImpl::PurgeMemory, context_, purge_option));
 }
 
 }  // namespace content