base: Add free list implementation to browser-wide discardable memory system.

content/child/child_discardable_shared_memory_manager.cc

Index: content/child/child_discardable_shared_memory_manager.cc
diff --git a/content/child/child_discardable_shared_memory_manager.cc b/content/child/child_discardable_shared_memory_manager.cc
index 606ca6ceb06074b02e02c421ee613bcb26a3d2b6..d5b97a06153fec7c0a0dcbacfc7cfba4b20d36a6 100644
--- a/content/child/child_discardable_shared_memory_manager.cc
+++ b/content/child/child_discardable_shared_memory_manager.cc
@@ -5,19 +5,149 @@
 #include "content/child/child_discardable_shared_memory_manager.h"
 
 #include "base/memory/discardable_shared_memory.h"
+#include "base/process/process_metrics.h"
 #include "content/child/child_thread.h"
 #include "content/common/child_process_messages.h"
 
 namespace content {
+namespace {
+
+// Default allocation size.
+const size_t kAllocationSize = 4 * 1024 * 1024;
+
+class DiscardableMemoryShmemChunkImpl
+    : public base::DiscardableMemoryShmemChunk {
+ public:
+  DiscardableMemoryShmemChunkImpl(
+      ChildDiscardableSharedMemoryManager* manager,
+      scoped_ptr<DiscardableSharedMemoryHeap::Span> span)
+      : manager_(manager), span_(span.Pass()) {}
+  ~DiscardableMemoryShmemChunkImpl() override {
+    manager_->ReleaseSpan(span_.Pass());
+  }
+
+  // Overridden from DiscardableMemoryShmemChunk:
+  bool Lock() override { return manager_->LockSpan(span_.get()); }
+  void Unlock() override { manager_->UnlockSpan(span_.get()); }
+  void* Memory() const override {
+    return reinterpret_cast<void*>(span_->start() * base::GetPageSize());
+  }
+  bool IsMemoryResident() const override {
+    return manager_->IsSpanResident(span_.get());
+  }
+
+ private:
+  ChildDiscardableSharedMemoryManager* manager_;
+  scoped_ptr<DiscardableSharedMemoryHeap::Span> span_;
+
+  DISALLOW_COPY_AND_ASSIGN(DiscardableMemoryShmemChunkImpl);
+};
+
+}  // namespace
 
 ChildDiscardableSharedMemoryManager::ChildDiscardableSharedMemoryManager(
     ThreadSafeSender* sender)
-    : sender_(sender) {
+    : heap_(base::GetPageSize()), sender_(sender) {
 }
 
 ChildDiscardableSharedMemoryManager::~ChildDiscardableSharedMemoryManager() {
 }
 
+scoped_ptr<base::DiscardableMemoryShmemChunk>
+ChildDiscardableSharedMemoryManager::AllocateLockedDiscardableMemory(
+    size_t size) {
+  base::AutoLock lock(lock_);
+
+  DCHECK_NE(size, 0u);
+
+  // Round up to multiple of page size.
+  size_t pages = (size + base::GetPageSize() - 1) / base::GetPageSize();
+
+  for (;;) {
+    // Search free list for available space.
+    scoped_ptr<DiscardableSharedMemoryHeap::Span> free_span =
+        heap_.SearchFreeList(pages);
+    if (!free_span.get())
+      break;
+
+    // Attempt to lock |free_span|. Delete span and search free list again
+    // if locking failed.
+    if (!free_span->shared_memory()->Lock(
+            free_span->start() * base::GetPageSize() -
+                reinterpret_cast<size_t>(free_span->shared_memory()->memory()),
+            free_span->length() * base::GetPageSize())) {
+      heap_.DeleteSpan(free_span.Pass());
+      continue;
+    }
+
+    return make_scoped_ptr(
+        new DiscardableMemoryShmemChunkImpl(this, free_span.Pass()));
+  }
+
+  size_t pages_to_allocate =
+      std::max(kAllocationSize / base::GetPageSize(), pages);
+  size_t allocation_size_in_bytes = pages_to_allocate * base::GetPageSize();
+
+  // Ask parent process to allocate a new discardable shared memory segment.
+  scoped_ptr<base::DiscardableSharedMemory> shared_memory(
+      AllocateLockedDiscardableSharedMemory(allocation_size_in_bytes));
+
+  // Create span for allocated memory.
+  scoped_ptr<DiscardableSharedMemoryHeap::Span> new_span(
+      heap_.Grow(shared_memory.Pass(), allocation_size_in_bytes));
+
+  // Unlock and insert any left over memory into free list.
+  if (pages < pages_to_allocate) {
+    scoped_ptr<DiscardableSharedMemoryHeap::Span> leftover =
+        heap_.Split(new_span.get(), pages);
+    leftover->shared_memory()->Unlock(
+        leftover->start() * base::GetPageSize() -
+            reinterpret_cast<size_t>(leftover->shared_memory()->memory()),
+        leftover->length() * base::GetPageSize());
+    heap_.MergeIntoFreeList(leftover.Pass());
+  }
+
+  return make_scoped_ptr(
+      new DiscardableMemoryShmemChunkImpl(this, new_span.Pass()));
+}
+
+bool ChildDiscardableSharedMemoryManager::LockSpan(
+    DiscardableSharedMemoryHeap::Span* span) {
+  base::AutoLock lock(lock_);
+  return span->shared_memory()->Lock(
+      span->start() * base::GetPageSize() -
+          reinterpret_cast<size_t>(span->shared_memory()->memory()),
+      span->length() * base::GetPageSize());
+}
+
+void ChildDiscardableSharedMemoryManager::UnlockSpan(
+    DiscardableSharedMemoryHeap::Span* span) {
+  base::AutoLock lock(lock_);
+  return span->shared_memory()->Unlock(
+      span->start() * base::GetPageSize() -
+          reinterpret_cast<size_t>(span->shared_memory()->memory()),
+      span->length() * base::GetPageSize());
+}
+
+bool ChildDiscardableSharedMemoryManager::IsSpanResident(
+    DiscardableSharedMemoryHeap::Span* span) const {
+  base::AutoLock lock(lock_);
+  return span->shared_memory()->IsMemoryResident();
+}
+
+void ChildDiscardableSharedMemoryManager::ReleaseSpan(
+    scoped_ptr<DiscardableSharedMemoryHeap::Span> span) {
+  base::AutoLock lock(lock_);
+
+  // Limit free list to spans less or equal to kAllocationSize.
+  if (span->length() * base::GetPageSize() > kAllocationSize) {
+    heap_.DeleteSpan(span.Pass());
+    return;
+  }
+
+  heap_.MergeIntoFreeList(span.Pass());
+}
+
 scoped_ptr<base::DiscardableSharedMemory>
 ChildDiscardableSharedMemoryManager::AllocateLockedDiscardableSharedMemory(
     size_t size) {