OLD | NEW |
1 // Copyright 2012 The Chromium Authors. All rights reserved. | 1 // Copyright 2012 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "cc/resources/resource_pool.h" | 5 #include "cc/resources/resource_pool.h" |
6 | 6 |
7 #include "cc/resources/resource_provider.h" | 7 #include "cc/resources/resource_provider.h" |
8 #include "cc/resources/scoped_resource.h" | 8 #include "cc/resources/scoped_resource.h" |
9 | 9 |
10 namespace cc { | 10 namespace cc { |
11 | 11 |
12 ResourcePool::ResourcePool(ResourceProvider* resource_provider, GLenum target) | 12 ResourcePool::ResourcePool(ResourceProvider* resource_provider, GLenum target) |
13 : resource_provider_(resource_provider), | 13 : resource_provider_(resource_provider), |
14 target_(target), | 14 target_(target), |
15 max_memory_usage_bytes_(0), | 15 max_memory_usage_bytes_(0), |
16 max_unused_memory_usage_bytes_(0), | 16 max_unused_memory_usage_bytes_(0), |
17 max_resource_count_(0), | 17 max_resource_count_(0), |
18 memory_usage_bytes_(0), | 18 memory_usage_bytes_(0), |
19 unused_memory_usage_bytes_(0), | 19 unused_memory_usage_bytes_(0), |
20 resource_count_(0) {} | 20 resource_count_(0) {} |
21 | 21 |
22 ResourcePool::~ResourcePool() { | 22 ResourcePool::~ResourcePool() { |
23 while (!busy_resources_.empty()) { | 23 while (!busy_resources_.empty()) { |
24 DidFinishUsingResource(busy_resources_.front()); | 24 auto const& front = busy_resources_.front(); |
| 25 DidFinishUsingResource(front.resource, front.content_id); |
25 busy_resources_.pop_front(); | 26 busy_resources_.pop_front(); |
26 } | 27 } |
27 | 28 |
28 SetResourceUsageLimits(0, 0, 0); | 29 SetResourceUsageLimits(0, 0, 0); |
29 DCHECK_EQ(0u, unused_resources_.size()); | 30 DCHECK_EQ(0u, unused_resources_.size()); |
30 DCHECK_EQ(0u, memory_usage_bytes_); | 31 DCHECK_EQ(0u, memory_usage_bytes_); |
31 DCHECK_EQ(0u, unused_memory_usage_bytes_); | 32 DCHECK_EQ(0u, unused_memory_usage_bytes_); |
32 DCHECK_EQ(0u, resource_count_); | 33 DCHECK_EQ(0u, resource_count_); |
33 } | 34 } |
34 | 35 |
35 scoped_ptr<ScopedResource> ResourcePool::AcquireResource( | 36 scoped_ptr<ScopedResource> ResourcePool::AcquireResource( |
36 const gfx::Size& size, ResourceFormat format) { | 37 const gfx::Size& size, ResourceFormat format) { |
37 for (ResourceList::iterator it = unused_resources_.begin(); | 38 for (ResourceList::iterator it = unused_resources_.begin(); |
38 it != unused_resources_.end(); | 39 it != unused_resources_.end(); |
39 ++it) { | 40 ++it) { |
40 ScopedResource* resource = *it; | 41 ScopedResource* resource = it->resource; |
41 DCHECK(resource_provider_->CanLockForWrite(resource->id())); | 42 DCHECK(resource_provider_->CanLockForWrite(resource->id())); |
42 | 43 |
43 if (resource->format() != format) | 44 if (resource->format() != format) |
44 continue; | 45 continue; |
45 if (resource->size() != size) | 46 if (resource->size() != size) |
46 continue; | 47 continue; |
47 | 48 |
48 unused_resources_.erase(it); | 49 unused_resources_.erase(it); |
49 unused_memory_usage_bytes_ -= resource->bytes(); | 50 unused_memory_usage_bytes_ -= resource->bytes(); |
50 return make_scoped_ptr(resource); | 51 return make_scoped_ptr(resource); |
51 } | 52 } |
52 | 53 |
53 scoped_ptr<ScopedResource> resource = | 54 scoped_ptr<ScopedResource> resource = |
54 ScopedResource::Create(resource_provider_); | 55 ScopedResource::Create(resource_provider_); |
55 resource->AllocateManaged(size, target_, format); | 56 resource->AllocateManaged(size, target_, format); |
56 | 57 |
57 memory_usage_bytes_ += resource->bytes(); | 58 memory_usage_bytes_ += resource->bytes(); |
58 ++resource_count_; | 59 ++resource_count_; |
59 return resource.Pass(); | 60 return resource.Pass(); |
60 } | 61 } |
61 | 62 |
62 void ResourcePool::ReleaseResource(scoped_ptr<ScopedResource> resource) { | 63 scoped_ptr<ScopedResource> ResourcePool::TryAcquireResourceWithContentId( |
63 busy_resources_.push_back(resource.release()); | 64 uint64_t content_id) { |
| 65 DCHECK(content_id); |
| 66 |
| 67 auto it = std::find_if(unused_resources_.begin(), unused_resources_.end(), |
| 68 [content_id](const PoolResource& pool_resource) { |
| 69 return pool_resource.content_id == content_id; |
| 70 }); |
| 71 if (it == unused_resources_.end()) |
| 72 return nullptr; |
| 73 |
| 74 ScopedResource* resource = it->resource; |
| 75 DCHECK(resource_provider_->CanLockForWrite(resource->id())); |
| 76 |
| 77 unused_resources_.erase(it); |
| 78 unused_memory_usage_bytes_ -= resource->bytes(); |
| 79 return make_scoped_ptr(resource); |
| 80 } |
| 81 |
| 82 void ResourcePool::ReleaseResource(scoped_ptr<ScopedResource> resource, |
| 83 uint64_t content_id) { |
| 84 busy_resources_.push_back(PoolResource(resource.release(), content_id)); |
64 } | 85 } |
65 | 86 |
66 void ResourcePool::SetResourceUsageLimits(size_t max_memory_usage_bytes, | 87 void ResourcePool::SetResourceUsageLimits(size_t max_memory_usage_bytes, |
67 size_t max_unused_memory_usage_bytes, | 88 size_t max_unused_memory_usage_bytes, |
68 size_t max_resource_count) { | 89 size_t max_resource_count) { |
69 max_memory_usage_bytes_ = max_memory_usage_bytes; | 90 max_memory_usage_bytes_ = max_memory_usage_bytes; |
70 max_unused_memory_usage_bytes_ = max_unused_memory_usage_bytes; | 91 max_unused_memory_usage_bytes_ = max_unused_memory_usage_bytes; |
71 max_resource_count_ = max_resource_count; | 92 max_resource_count_ = max_resource_count; |
72 | 93 |
73 ReduceResourceUsage(); | 94 ReduceResourceUsage(); |
74 } | 95 } |
75 | 96 |
76 void ResourcePool::ReduceResourceUsage() { | 97 void ResourcePool::ReduceResourceUsage() { |
77 while (!unused_resources_.empty()) { | 98 while (!unused_resources_.empty()) { |
78 if (!ResourceUsageTooHigh()) | 99 if (!ResourceUsageTooHigh()) |
79 break; | 100 break; |
80 | 101 |
81 // LRU eviction pattern. Most recently used might be blocked by | 102 // LRU eviction pattern. Most recently used might be blocked by |
82 // a read lock fence but it's still better to evict the least | 103 // a read lock fence but it's still better to evict the least |
83 // recently used as it prevents a resource that is hard to reuse | 104 // recently used as it prevents a resource that is hard to reuse |
84 // because of unique size from being kept around. Resources that | 105 // because of unique size from being kept around. Resources that |
85 // can't be locked for write might also not be truly free-able. | 106 // can't be locked for write might also not be truly free-able. |
86 // We can free the resource here but it doesn't mean that the | 107 // We can free the resource here but it doesn't mean that the |
87 // memory is necessarily returned to the OS. | 108 // memory is necessarily returned to the OS. |
88 ScopedResource* resource = unused_resources_.front(); | 109 ScopedResource* resource = unused_resources_.front().resource; |
89 unused_resources_.pop_front(); | 110 unused_resources_.pop_front(); |
90 memory_usage_bytes_ -= resource->bytes(); | 111 memory_usage_bytes_ -= resource->bytes(); |
91 unused_memory_usage_bytes_ -= resource->bytes(); | 112 unused_memory_usage_bytes_ -= resource->bytes(); |
92 --resource_count_; | 113 --resource_count_; |
93 delete resource; | 114 delete resource; |
94 } | 115 } |
95 } | 116 } |
96 | 117 |
97 bool ResourcePool::ResourceUsageTooHigh() { | 118 bool ResourcePool::ResourceUsageTooHigh() { |
98 if (resource_count_ > max_resource_count_) | 119 if (resource_count_ > max_resource_count_) |
99 return true; | 120 return true; |
100 if (memory_usage_bytes_ > max_memory_usage_bytes_) | 121 if (memory_usage_bytes_ > max_memory_usage_bytes_) |
101 return true; | 122 return true; |
102 if (unused_memory_usage_bytes_ > max_unused_memory_usage_bytes_) | 123 if (unused_memory_usage_bytes_ > max_unused_memory_usage_bytes_) |
103 return true; | 124 return true; |
104 return false; | 125 return false; |
105 } | 126 } |
106 | 127 |
107 void ResourcePool::CheckBusyResources(bool wait_if_needed) { | 128 void ResourcePool::CheckBusyResources(bool wait_if_needed) { |
108 ResourceList::iterator it = busy_resources_.begin(); | 129 ResourceList::iterator it = busy_resources_.begin(); |
109 | 130 |
110 while (it != busy_resources_.end()) { | 131 while (it != busy_resources_.end()) { |
111 ScopedResource* resource = *it; | 132 ScopedResource* resource = it->resource; |
112 | 133 |
113 if (wait_if_needed) | 134 if (wait_if_needed) |
114 resource_provider_->WaitReadLockIfNeeded(resource->id()); | 135 resource_provider_->WaitReadLockIfNeeded(resource->id()); |
115 | 136 |
116 if (resource_provider_->CanLockForWrite(resource->id())) { | 137 if (resource_provider_->CanLockForWrite(resource->id())) { |
117 DidFinishUsingResource(resource); | 138 DidFinishUsingResource(resource, it->content_id); |
118 it = busy_resources_.erase(it); | 139 it = busy_resources_.erase(it); |
119 } else { | 140 } else { |
120 ++it; | 141 ++it; |
121 } | 142 } |
122 } | 143 } |
123 } | 144 } |
124 | 145 |
125 void ResourcePool::DidFinishUsingResource(ScopedResource* resource) { | 146 void ResourcePool::DidFinishUsingResource(ScopedResource* resource, |
| 147 uint64_t content_id) { |
126 unused_memory_usage_bytes_ += resource->bytes(); | 148 unused_memory_usage_bytes_ += resource->bytes(); |
127 unused_resources_.push_back(resource); | 149 unused_resources_.push_back(PoolResource(resource, content_id)); |
128 } | 150 } |
129 | 151 |
130 } // namespace cc | 152 } // namespace cc |
OLD | NEW |