Make cc::SoftwareImageDecodeController, cc::ResourcePool, and cc::StagingBufferPoo…

cc/raster/staging_buffer_pool.cc

 // 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 "cc/raster/staging_buffer_pool.h"
 
 #include <memory>
 
 #include "base/memory/ptr_util.h"
 #include "base/strings/stringprintf.h"
 #include "base/threading/thread_task_runner_handle.h"
 #include "base/trace_event/memory_dump_manager.h"
 #include "cc/base/container_util.h"
 #include "cc/debug/traced_value.h"
 #include "cc/resources/scoped_resource.h"
+#include "components/memory_coordinator/common/client_registry.h"
 #include "gpu/command_buffer/client/gles2_interface.h"
 
 namespace cc {
 namespace {
 
 // Delay between checking for query result to be available.
 const int kCheckForQueryResultAvailableTickRateMs = 1;
 
 // Number of attempts to allow before we perform a check that will wait for
 // query to complete.
@@ skipping 108 matching lines @@
       free_staging_buffer_usage_in_bytes_(0),
       staging_buffer_expiration_delay_(
           base::TimeDelta::FromMilliseconds(kStagingBufferExpirationDelayMs)),
       reduce_memory_usage_pending_(false),
       weak_ptr_factory_(this) {
   DCHECK(worker_context_provider_);
   base::trace_event::MemoryDumpManager::GetInstance()->RegisterDumpProvider(
       this, "cc::StagingBufferPool", base::ThreadTaskRunnerHandle::Get());
   reduce_memory_usage_callback_ = base::Bind(
       &StagingBufferPool::ReduceMemoryUsage, weak_ptr_factory_.GetWeakPtr());
+
+  // Register this component with memory_coordinator::ClientRegistry.
+  memory_coordinator::ClientRegistry* registry =
+      memory_coordinator::ClientRegistry::GetInstance();
+  if (registry)
+    registry->RegisterClient(this);
 }
 
 StagingBufferPool::~StagingBufferPool() {
   base::trace_event::MemoryDumpManager::GetInstance()->UnregisterDumpProvider(
       this);
+  // Unregister this component with memory_coordinator::ClientRegistry.
+  memory_coordinator::ClientRegistry* registry =
+      memory_coordinator::ClientRegistry::GetInstance();
+  if (registry)
+    registry->UnregisterClient(this);
 }
 
 void StagingBufferPool::Shutdown() {
   base::AutoLock lock(lock_);
   if (buffers_.empty())
     return;
 
   ReleaseBuffersNotUsedSince(base::TimeTicks() + base::TimeDelta::Max());
   DCHECK_EQ(staging_buffer_usage_in_bytes_, 0);
   DCHECK_EQ(free_staging_buffer_usage_in_bytes_, 0);
@@ skipping 243 matching lines @@
       if (busy_buffers_.front()->last_usage > time)
         return;
 
       busy_buffers_.front()->DestroyGLResources(gl);
       RemoveStagingBuffer(busy_buffers_.front().get());
       busy_buffers_.pop_front();
     }
   }
 }
 
+void StagingBufferPool::OnMemoryStateChange(
+    memory_coordinator::mojom::MemoryState state) {
+  switch (state) {
+    case memory_coordinator::mojom::MemoryState::NORMAL:
+      // TODO(tasak): go back to normal state.
+      break;
+    case memory_coordinator::mojom::MemoryState::THROTTLED:
+      // TODO(tasak): make the limits of this component's caches smaller to
+      // save memory usage.
+      break;
+    case memory_coordinator::mojom::MemoryState::SUSPENDED:
+      // TODO(tasak): free this component's caches as much as possible before
+      // suspending renderer.
+      break;
+    default:

[vmpstr, 2016/09/06 18:14:47]

nit: typically, if we handle all of the cases in the switch, we don't put the
default case since then the compiler would complain if a new case is added. 

[tasak, 2016/09/15 07:08:44]

Done.

+      // NOT_REACHED.
+      break;
+  }
+}
+
 }  // namespace cc