| OLD | NEW |
| (Empty) |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | |
| 2 // Use of this source code is governed by a BSD-style license that can be | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 #include "cc/layers/delegated_frame_resource_collection.h" | |
| 6 | |
| 7 #include "base/bind.h" | |
| 8 #include "cc/trees/blocking_task_runner.h" | |
| 9 | |
| 10 namespace cc { | |
| 11 | |
| 12 DelegatedFrameResourceCollection::DelegatedFrameResourceCollection() | |
| 13 : client_(nullptr), lost_all_resources_(false), weak_ptr_factory_(this) { | |
| 14 DCHECK(main_thread_checker_.CalledOnValidThread()); | |
| 15 } | |
| 16 | |
| 17 DelegatedFrameResourceCollection::~DelegatedFrameResourceCollection() { | |
| 18 DCHECK(main_thread_checker_.CalledOnValidThread()); | |
| 19 } | |
| 20 | |
| 21 void DelegatedFrameResourceCollection::SetClient( | |
| 22 DelegatedFrameResourceCollectionClient* client) { | |
| 23 client_ = client; | |
| 24 } | |
| 25 | |
| 26 void DelegatedFrameResourceCollection::TakeUnusedResourcesForChildCompositor( | |
| 27 ReturnedResourceArray* array) { | |
| 28 DCHECK(main_thread_checker_.CalledOnValidThread()); | |
| 29 DCHECK(array->empty()); | |
| 30 array->swap(returned_resources_for_child_compositor_); | |
| 31 } | |
| 32 | |
| 33 bool DelegatedFrameResourceCollection::LoseAllResources() { | |
| 34 DCHECK(main_thread_checker_.CalledOnValidThread()); | |
| 35 DCHECK(!lost_all_resources_); | |
| 36 lost_all_resources_ = true; | |
| 37 | |
| 38 if (resource_id_ref_count_map_.empty()) | |
| 39 return false; | |
| 40 | |
| 41 ReturnedResourceArray to_return; | |
| 42 | |
| 43 for (ResourceIdRefCountMap::iterator it = resource_id_ref_count_map_.begin(); | |
| 44 it != resource_id_ref_count_map_.end(); | |
| 45 ++it) { | |
| 46 DCHECK_GE(it->second.refs_to_wait_for, 1); | |
| 47 | |
| 48 ReturnedResource returned; | |
| 49 returned.id = it->first; | |
| 50 returned.count = it->second.refs_to_return; | |
| 51 returned.lost = true; | |
| 52 to_return.push_back(returned); | |
| 53 } | |
| 54 | |
| 55 returned_resources_for_child_compositor_.insert( | |
| 56 returned_resources_for_child_compositor_.end(), | |
| 57 to_return.begin(), | |
| 58 to_return.end()); | |
| 59 if (client_) | |
| 60 client_->UnusedResourcesAreAvailable(); | |
| 61 return true; | |
| 62 } | |
| 63 | |
| 64 void DelegatedFrameResourceCollection::ReceivedResources( | |
| 65 const TransferableResourceArray& resources) { | |
| 66 DCHECK(main_thread_checker_.CalledOnValidThread()); | |
| 67 DCHECK(!lost_all_resources_); | |
| 68 | |
| 69 for (size_t i = 0; i < resources.size(); ++i) | |
| 70 resource_id_ref_count_map_[resources[i].id].refs_to_return++; | |
| 71 } | |
| 72 | |
| 73 void DelegatedFrameResourceCollection::UnrefResources( | |
| 74 const ReturnedResourceArray& returned) { | |
| 75 DCHECK(main_thread_checker_.CalledOnValidThread()); | |
| 76 | |
| 77 if (lost_all_resources_) | |
| 78 return; | |
| 79 | |
| 80 ReturnedResourceArray to_return; | |
| 81 | |
| 82 for (size_t i = 0; i < returned.size(); ++i) { | |
| 83 ResourceIdRefCountMap::iterator it = | |
| 84 resource_id_ref_count_map_.find(returned[i].id); | |
| 85 DCHECK(it != resource_id_ref_count_map_.end()); | |
| 86 DCHECK_GE(it->second.refs_to_wait_for, returned[i].count); | |
| 87 it->second.refs_to_wait_for -= returned[i].count; | |
| 88 if (it->second.refs_to_wait_for == 0) { | |
| 89 to_return.push_back(returned[i]); | |
| 90 to_return.back().count = it->second.refs_to_return; | |
| 91 resource_id_ref_count_map_.erase(it); | |
| 92 } | |
| 93 } | |
| 94 | |
| 95 if (to_return.empty()) | |
| 96 return; | |
| 97 | |
| 98 returned_resources_for_child_compositor_.insert( | |
| 99 returned_resources_for_child_compositor_.end(), | |
| 100 to_return.begin(), | |
| 101 to_return.end()); | |
| 102 if (client_) | |
| 103 client_->UnusedResourcesAreAvailable(); | |
| 104 } | |
| 105 | |
| 106 void DelegatedFrameResourceCollection::RefResources( | |
| 107 const TransferableResourceArray& resources) { | |
| 108 DCHECK(main_thread_checker_.CalledOnValidThread()); | |
| 109 for (size_t i = 0; i < resources.size(); ++i) | |
| 110 resource_id_ref_count_map_[resources[i].id].refs_to_wait_for++; | |
| 111 } | |
| 112 | |
| 113 static void UnrefResourcesOnImplThread( | |
| 114 base::WeakPtr<DelegatedFrameResourceCollection> self, | |
| 115 const ReturnedResourceArray& returned, | |
| 116 BlockingTaskRunner* main_thread_task_runner) { | |
| 117 main_thread_task_runner->PostTask( | |
| 118 FROM_HERE, | |
| 119 base::Bind( | |
| 120 &DelegatedFrameResourceCollection::UnrefResources, self, returned)); | |
| 121 } | |
| 122 | |
| 123 ReturnCallback | |
| 124 DelegatedFrameResourceCollection::GetReturnResourcesCallbackForImplThread() { | |
| 125 return base::Bind(&UnrefResourcesOnImplThread, | |
| 126 weak_ptr_factory_.GetWeakPtr()); | |
| 127 } | |
| 128 | |
| 129 } // namespace cc | |
| OLD | NEW |