| Index: cc/resources/resource_pool.cc
|
| diff --git a/cc/resources/resource_pool.cc b/cc/resources/resource_pool.cc
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..22847809ba3c196f66df1112d978d56342665b3a
|
| --- /dev/null
|
| +++ b/cc/resources/resource_pool.cc
|
| @@ -0,0 +1,130 @@
|
| +// Copyright 2012 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/resources/resource_pool.h"
|
| +
|
| +#include "cc/resources/resource_provider.h"
|
| +#include "cc/resources/scoped_resource.h"
|
| +
|
| +namespace cc {
|
| +
|
| +ResourcePool::ResourcePool(ResourceProvider* resource_provider, GLenum target)
|
| + : resource_provider_(resource_provider),
|
| + target_(target),
|
| + max_memory_usage_bytes_(0),
|
| + max_unused_memory_usage_bytes_(0),
|
| + max_resource_count_(0),
|
| + memory_usage_bytes_(0),
|
| + unused_memory_usage_bytes_(0),
|
| + resource_count_(0) {}
|
| +
|
| +ResourcePool::~ResourcePool() {
|
| + while (!busy_resources_.empty()) {
|
| + DidFinishUsingResource(busy_resources_.front());
|
| + busy_resources_.pop_front();
|
| + }
|
| +
|
| + SetResourceUsageLimits(0, 0, 0);
|
| + DCHECK_EQ(0u, unused_resources_.size());
|
| + DCHECK_EQ(0u, memory_usage_bytes_);
|
| + DCHECK_EQ(0u, unused_memory_usage_bytes_);
|
| + DCHECK_EQ(0u, resource_count_);
|
| +}
|
| +
|
| +scoped_ptr<ScopedResource> ResourcePool::AcquireResource(
|
| + const gfx::Size& size, ResourceFormat format) {
|
| + for (ResourceList::iterator it = unused_resources_.begin();
|
| + it != unused_resources_.end();
|
| + ++it) {
|
| + ScopedResource* resource = *it;
|
| + DCHECK(resource_provider_->CanLockForWrite(resource->id()));
|
| +
|
| + if (resource->format() != format)
|
| + continue;
|
| + if (resource->size() != size)
|
| + continue;
|
| +
|
| + unused_resources_.erase(it);
|
| + unused_memory_usage_bytes_ -= resource->bytes();
|
| + return make_scoped_ptr(resource);
|
| + }
|
| +
|
| + scoped_ptr<ScopedResource> resource =
|
| + ScopedResource::Create(resource_provider_);
|
| + resource->AllocateManaged(size, target_, format);
|
| +
|
| + memory_usage_bytes_ += resource->bytes();
|
| + ++resource_count_;
|
| + return resource.Pass();
|
| +}
|
| +
|
| +void ResourcePool::ReleaseResource(scoped_ptr<ScopedResource> resource) {
|
| + busy_resources_.push_back(resource.release());
|
| +}
|
| +
|
| +void ResourcePool::SetResourceUsageLimits(size_t max_memory_usage_bytes,
|
| + size_t max_unused_memory_usage_bytes,
|
| + size_t max_resource_count) {
|
| + max_memory_usage_bytes_ = max_memory_usage_bytes;
|
| + max_unused_memory_usage_bytes_ = max_unused_memory_usage_bytes;
|
| + max_resource_count_ = max_resource_count;
|
| +
|
| + ReduceResourceUsage();
|
| +}
|
| +
|
| +void ResourcePool::ReduceResourceUsage() {
|
| + while (!unused_resources_.empty()) {
|
| + if (!ResourceUsageTooHigh())
|
| + break;
|
| +
|
| + // LRU eviction pattern. Most recently used might be blocked by
|
| + // a read lock fence but it's still better to evict the least
|
| + // recently used as it prevents a resource that is hard to reuse
|
| + // because of unique size from being kept around. Resources that
|
| + // can't be locked for write might also not be truly free-able.
|
| + // We can free the resource here but it doesn't mean that the
|
| + // memory is necessarily returned to the OS.
|
| + ScopedResource* resource = unused_resources_.front();
|
| + unused_resources_.pop_front();
|
| + memory_usage_bytes_ -= resource->bytes();
|
| + unused_memory_usage_bytes_ -= resource->bytes();
|
| + --resource_count_;
|
| + delete resource;
|
| + }
|
| +}
|
| +
|
| +bool ResourcePool::ResourceUsageTooHigh() {
|
| + if (resource_count_ > max_resource_count_)
|
| + return true;
|
| + if (memory_usage_bytes_ > max_memory_usage_bytes_)
|
| + return true;
|
| + if (unused_memory_usage_bytes_ > max_unused_memory_usage_bytes_)
|
| + return true;
|
| + return false;
|
| +}
|
| +
|
| +void ResourcePool::CheckBusyResources(bool wait_if_needed) {
|
| + ResourceList::iterator it = busy_resources_.begin();
|
| +
|
| + while (it != busy_resources_.end()) {
|
| + ScopedResource* resource = *it;
|
| +
|
| + if (wait_if_needed)
|
| + resource_provider_->WaitReadLockIfNeeded(resource->id());
|
| +
|
| + if (resource_provider_->CanLockForWrite(resource->id())) {
|
| + DidFinishUsingResource(resource);
|
| + it = busy_resources_.erase(it);
|
| + } else {
|
| + ++it;
|
| + }
|
| + }
|
| +}
|
| +
|
| +void ResourcePool::DidFinishUsingResource(ScopedResource* resource) {
|
| + unused_memory_usage_bytes_ += resource->bytes();
|
| + unused_resources_.push_back(resource);
|
| +}
|
| +
|
| +} // namespace cc
|
|
|