| 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_update_controller.h" | 5 #include "cc/resources/resource_update_controller.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/location.h" | 8 #include "base/location.h" |
| 9 #include "base/single_thread_task_runner.h" | 9 #include "base/single_thread_task_runner.h" |
| 10 #include "cc/resources/prioritized_resource.h" | 10 #include "cc/resources/prioritized_resource.h" |
| (...skipping 14 matching lines...) Expand all Loading... |
| 25 } // namespace | 25 } // namespace |
| 26 | 26 |
| 27 namespace cc { | 27 namespace cc { |
| 28 | 28 |
| 29 size_t ResourceUpdateController::MaxPartialTextureUpdates() { | 29 size_t ResourceUpdateController::MaxPartialTextureUpdates() { |
| 30 return kPartialTextureUpdatesMax; | 30 return kPartialTextureUpdatesMax; |
| 31 } | 31 } |
| 32 | 32 |
| 33 size_t ResourceUpdateController::MaxFullUpdatesPerTick( | 33 size_t ResourceUpdateController::MaxFullUpdatesPerTick( |
| 34 ResourceProvider* resource_provider) { | 34 ResourceProvider* resource_provider) { |
| 35 double textures_per_second = resource_provider->EstimatedUploadsPerSecond(); | 35 return resource_provider->EstimatedUploadsPerTick(); |
| 36 size_t textures_per_tick = | |
| 37 floor(resource_provider->TextureUpdateTickRate().InSecondsF() * | |
| 38 textures_per_second); | |
| 39 return textures_per_tick ? textures_per_tick : 1; | |
| 40 } | 36 } |
| 41 | 37 |
| 42 ResourceUpdateController::ResourceUpdateController( | 38 ResourceUpdateController::ResourceUpdateController( |
| 43 ResourceUpdateControllerClient* client, | 39 ResourceUpdateControllerClient* client, |
| 44 base::SingleThreadTaskRunner* task_runner, | 40 base::SingleThreadTaskRunner* task_runner, |
| 45 scoped_ptr<ResourceUpdateQueue> queue, | 41 scoped_ptr<ResourceUpdateQueue> queue, |
| 46 ResourceProvider* resource_provider) | 42 ResourceProvider* resource_provider) |
| 47 : client_(client), | 43 : client_(client), |
| 48 queue_(queue.Pass()), | 44 queue_(queue.Pass()), |
| 49 resource_provider_(resource_provider), | 45 resource_provider_(resource_provider), |
| (...skipping 56 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 106 | 102 |
| 107 resource_provider_->FlushUploads(); | 103 resource_provider_->FlushUploads(); |
| 108 } | 104 } |
| 109 | 105 |
| 110 void ResourceUpdateController::OnTimerFired() { | 106 void ResourceUpdateController::OnTimerFired() { |
| 111 task_posted_ = false; | 107 task_posted_ = false; |
| 112 if (!UpdateMoreTexturesIfEnoughTimeRemaining()) | 108 if (!UpdateMoreTexturesIfEnoughTimeRemaining()) |
| 113 client_->ReadyToFinalizeTextureUpdates(); | 109 client_->ReadyToFinalizeTextureUpdates(); |
| 114 } | 110 } |
| 115 | 111 |
| 116 base::TimeTicks ResourceUpdateController::Now() const { | 112 base::TimeTicks ResourceUpdateController::UpdateMoreTexturesCompletionTime() { |
| 117 return gfx::FrameTime::Now(); | 113 return resource_provider_->EstimatedUploadCompletionTime( |
| 118 } | 114 texture_updates_per_tick_); |
| 119 | |
| 120 base::TimeDelta ResourceUpdateController::UpdateMoreTexturesTime() const { | |
| 121 return resource_provider_->TextureUpdateTickRate(); | |
| 122 } | 115 } |
| 123 | 116 |
| 124 size_t ResourceUpdateController::UpdateMoreTexturesSize() const { | 117 size_t ResourceUpdateController::UpdateMoreTexturesSize() const { |
| 125 return texture_updates_per_tick_; | 118 return texture_updates_per_tick_; |
| 126 } | 119 } |
| 127 | 120 |
| 128 size_t ResourceUpdateController::MaxBlockingUpdates() const { | 121 size_t ResourceUpdateController::MaxBlockingUpdates() const { |
| 129 return UpdateMoreTexturesSize() * kMaxBlockingUpdateIntervals; | 122 return UpdateMoreTexturesSize() * kMaxBlockingUpdateIntervals; |
| 130 } | 123 } |
| 131 | 124 |
| 132 base::TimeDelta ResourceUpdateController::PendingUpdateTime() const { | |
| 133 base::TimeDelta update_one_resource_time = | |
| 134 UpdateMoreTexturesTime() / UpdateMoreTexturesSize(); | |
| 135 return update_one_resource_time * resource_provider_->NumBlockingUploads(); | |
| 136 } | |
| 137 | |
| 138 bool ResourceUpdateController::UpdateMoreTexturesIfEnoughTimeRemaining() { | 125 bool ResourceUpdateController::UpdateMoreTexturesIfEnoughTimeRemaining() { |
| 139 while (resource_provider_->NumBlockingUploads() < MaxBlockingUpdates()) { | 126 while (resource_provider_->NumBlockingUploads() < MaxBlockingUpdates()) { |
| 140 if (!queue_->FullUploadSize()) | 127 if (!queue_->FullUploadSize()) |
| 141 return false; | 128 return false; |
| 142 | 129 |
| 143 if (!time_limit_.is_null()) { | 130 if (!time_limit_.is_null()) { |
| 144 // Estimated completion time of all pending updates. | 131 base::TimeTicks completion_time = UpdateMoreTexturesCompletionTime(); |
| 145 base::TimeTicks completion_time = Now() + PendingUpdateTime(); | 132 if (completion_time > time_limit_) |
| 146 | |
| 147 // Time remaining based on current completion estimate. | |
| 148 base::TimeDelta time_remaining = time_limit_ - completion_time; | |
| 149 | |
| 150 if (time_remaining < UpdateMoreTexturesTime()) | |
| 151 return true; | 133 return true; |
| 152 } | 134 } |
| 153 | 135 |
| 154 UpdateMoreTexturesNow(); | 136 UpdateMoreTexturesNow(); |
| 155 } | 137 } |
| 156 | 138 |
| 157 task_posted_ = true; | 139 task_posted_ = true; |
| 158 task_runner_->PostDelayedTask( | 140 task_runner_->PostDelayedTask( |
| 159 FROM_HERE, | 141 FROM_HERE, |
| 160 base::Bind(&ResourceUpdateController::OnTimerFired, | 142 base::Bind(&ResourceUpdateController::OnTimerFired, |
| 161 weak_factory_.GetWeakPtr()), | 143 weak_factory_.GetWeakPtr()), |
| 162 base::TimeDelta::FromMilliseconds(kUploaderBusyTickRate * 1000)); | 144 base::TimeDelta::FromMilliseconds(kUploaderBusyTickRate * 1000)); |
| 163 return true; | 145 return true; |
| 164 } | 146 } |
| 165 | 147 |
| 166 void ResourceUpdateController::UpdateMoreTexturesNow() { | 148 void ResourceUpdateController::UpdateMoreTexturesNow() { |
| 167 size_t uploads = std::min( | 149 size_t uploads = std::min( |
| 168 queue_->FullUploadSize(), UpdateMoreTexturesSize()); | 150 queue_->FullUploadSize(), UpdateMoreTexturesSize()); |
| 169 | 151 |
| 170 if (!uploads) | 152 if (!uploads) |
| 171 return; | 153 return; |
| 172 | 154 |
| 173 while (queue_->FullUploadSize() && uploads--) | 155 while (queue_->FullUploadSize() && uploads--) |
| 174 UpdateTexture(queue_->TakeFirstFullUpload()); | 156 UpdateTexture(queue_->TakeFirstFullUpload()); |
| 175 | 157 |
| 176 resource_provider_->FlushUploads(); | 158 resource_provider_->FlushUploads(); |
| 177 } | 159 } |
| 178 | 160 |
| 179 } // namespace cc | 161 } // namespace cc |
| OLD | NEW |