Chromium Code Reviews| Index: gpu/command_buffer/client/query_tracker.cc |
| diff --git a/gpu/command_buffer/client/query_tracker.cc b/gpu/command_buffer/client/query_tracker.cc |
| index e960d139f9c50200baa0634f3ba9d6d05cd37323..0dacd44279484d27d3f774bdaed2787d3d3e99e7 100644 |
| --- a/gpu/command_buffer/client/query_tracker.cc |
| +++ b/gpu/command_buffer/client/query_tracker.cc |
| @@ -25,12 +25,7 @@ QuerySyncManager::Bucket::Bucket(QuerySync* sync_mem, |
| unsigned int shm_offset) |
| : syncs(sync_mem), |
| shm_id(shm_id), |
| - base_shm_offset(shm_offset), |
| - free_queries(kSyncsPerBucket) { |
| - static_assert(kSyncsPerBucket <= USHRT_MAX, |
| - "Can't fit kSyncsPerBucket in unsigned short"); |
| - for (size_t ii = 0; ii < kSyncsPerBucket; ++ii) |
| - free_queries[ii] = ii; |
| + base_shm_offset(shm_offset) { |
| } |
| QuerySyncManager::Bucket::~Bucket() = default; |
| @@ -52,7 +47,9 @@ bool QuerySyncManager::Alloc(QuerySyncManager::QueryInfo* info) { |
| DCHECK(info); |
| Bucket* bucket = nullptr; |
| for (Bucket* bucket_candidate : buckets_) { |
| - if (!bucket_candidate->free_queries.empty()) { |
| + // In C++11 STL this could be replaced with |
| + // if (!bucket_candidate->in_use_queries.all()) { ... } |
| + if (bucket_candidate->in_use_queries.count() != kSyncsPerBucket) { |
| bucket = bucket_candidate; |
| break; |
| } |
| @@ -70,27 +67,35 @@ bool QuerySyncManager::Alloc(QuerySyncManager::QueryInfo* info) { |
| buckets_.push_back(bucket); |
| } |
| - unsigned short index_in_bucket = bucket->free_queries.back(); |
| + unsigned short index_in_bucket = 0; |
| + for (size_t i = 0; i < kSyncsPerBucket; i++) { |
| + if (!bucket->in_use_queries[i]) { |
| + index_in_bucket = i; |
| + break; |
| + } |
| + } |
| + |
| uint32 shm_offset = |
| bucket->base_shm_offset + index_in_bucket * sizeof(QuerySync); |
| QuerySync* sync = bucket->syncs + index_in_bucket; |
| *info = QueryInfo(bucket, bucket->shm_id, shm_offset, sync); |
| info->sync->Reset(); |
| - bucket->free_queries.pop_back(); |
| + bucket->in_use_queries[index_in_bucket] = true; |
| return true; |
| } |
| void QuerySyncManager::Free(const QuerySyncManager::QueryInfo& info) { |
| - DCHECK(info.bucket->free_queries.size() < kSyncsPerBucket); |
| + DCHECK(info.bucket->in_use_queries.count() > 0); |
|
reveman
2015/05/20 14:35:13
nit: please use DCHECK_NE(info.bucket->in_use_quer
|
| unsigned short index_in_bucket = info.sync - info.bucket->syncs; |
| - info.bucket->free_queries.push_back(index_in_bucket); |
| + DCHECK(info.bucket->in_use_queries[index_in_bucket] == true); |
|
reveman
2015/05/20 14:35:13
nit: DCHECK(info.bucket->in_use_queries[index_in_b
|
| + info.bucket->in_use_queries[index_in_bucket] = false; |
| } |
| void QuerySyncManager::Shrink() { |
| std::deque<Bucket*> new_buckets; |
| while (!buckets_.empty()) { |
| Bucket* bucket = buckets_.front(); |
| - if (bucket->free_queries.size() < kSyncsPerBucket) { |
| + if (bucket->in_use_queries.any()) { |
| new_buckets.push_back(bucket); |
| } else { |
| mapped_memory_->Free(bucket->syncs); |