OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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/raster/gpu_tile_task_worker_pool.h" | 5 #include "cc/raster/gpu_tile_task_worker_pool.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 | 8 |
9 #include "base/trace_event/trace_event.h" | 9 #include "base/trace_event/trace_event.h" |
10 #include "cc/playback/display_list_raster_source.h" | 10 #include "cc/playback/display_list_raster_source.h" |
(...skipping 84 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
95 ContextProvider* context_provider, | 95 ContextProvider* context_provider, |
96 ResourceProvider* resource_provider, | 96 ResourceProvider* resource_provider, |
97 bool use_distance_field_text, | 97 bool use_distance_field_text, |
98 int gpu_rasterization_msaa_sample_count) | 98 int gpu_rasterization_msaa_sample_count) |
99 : task_runner_(task_runner), | 99 : task_runner_(task_runner), |
100 task_graph_runner_(task_graph_runner), | 100 task_graph_runner_(task_graph_runner), |
101 namespace_token_(task_graph_runner_->GetNamespaceToken()), | 101 namespace_token_(task_graph_runner_->GetNamespaceToken()), |
102 rasterizer_(new GpuRasterizer(context_provider, | 102 rasterizer_(new GpuRasterizer(context_provider, |
103 resource_provider, | 103 resource_provider, |
104 use_distance_field_text, | 104 use_distance_field_text, |
105 gpu_rasterization_msaa_sample_count)), | 105 gpu_rasterization_msaa_sample_count)) {} |
106 task_set_finished_weak_ptr_factory_(this), | |
107 weak_ptr_factory_(this) { | |
108 } | |
109 | 106 |
110 GpuTileTaskWorkerPool::~GpuTileTaskWorkerPool() { | 107 GpuTileTaskWorkerPool::~GpuTileTaskWorkerPool() { |
111 DCHECK_EQ(0u, completed_tasks_.size()); | 108 DCHECK_EQ(0u, completed_tasks_.size()); |
112 } | 109 } |
113 | 110 |
114 TileTaskRunner* GpuTileTaskWorkerPool::AsTileTaskRunner() { | 111 TileTaskRunner* GpuTileTaskWorkerPool::AsTileTaskRunner() { |
115 return this; | 112 return this; |
116 } | 113 } |
117 | 114 |
118 void GpuTileTaskWorkerPool::SetClient(TileTaskRunnerClient* client) { | |
119 client_ = client; | |
120 } | |
121 | |
122 void GpuTileTaskWorkerPool::Shutdown() { | 115 void GpuTileTaskWorkerPool::Shutdown() { |
123 TRACE_EVENT0("cc", "GpuTileTaskWorkerPool::Shutdown"); | 116 TRACE_EVENT0("cc", "GpuTileTaskWorkerPool::Shutdown"); |
124 | 117 |
125 TaskGraph empty; | 118 TaskGraph empty; |
126 task_graph_runner_->ScheduleTasks(namespace_token_, &empty); | 119 task_graph_runner_->ScheduleTasks(namespace_token_, &empty); |
127 task_graph_runner_->WaitForTasksToFinishRunning(namespace_token_); | 120 task_graph_runner_->WaitForTasksToFinishRunning(namespace_token_); |
128 } | 121 } |
129 | 122 |
130 void GpuTileTaskWorkerPool::ScheduleTasks(TileTaskQueue* queue) { | 123 void GpuTileTaskWorkerPool::ScheduleTasks(TaskGraph* graph) { |
131 TRACE_EVENT0("cc", "GpuTileTaskWorkerPool::ScheduleTasks"); | 124 TRACE_EVENT0("cc", "GpuTileTaskWorkerPool::ScheduleTasks"); |
132 | 125 |
133 // Mark all task sets as pending. | 126 ScheduleTasksOnOriginThread(this, graph); |
134 tasks_pending_.set(); | |
135 | |
136 size_t priority = kTileTaskPriorityBase; | |
137 | |
138 graph_.Reset(); | |
139 | |
140 // Cancel existing OnTaskSetFinished callbacks. | |
141 task_set_finished_weak_ptr_factory_.InvalidateWeakPtrs(); | |
142 | |
143 scoped_refptr<TileTask> new_task_set_finished_tasks[kNumberOfTaskSets]; | |
144 | |
145 size_t task_count[kNumberOfTaskSets] = {0}; | |
146 | |
147 for (TaskSet task_set = 0; task_set < kNumberOfTaskSets; ++task_set) { | |
148 new_task_set_finished_tasks[task_set] = CreateTaskSetFinishedTask( | |
149 task_runner_.get(), | |
150 base::Bind(&GpuTileTaskWorkerPool::OnTaskSetFinished, | |
151 task_set_finished_weak_ptr_factory_.GetWeakPtr(), task_set)); | |
152 } | |
153 | |
154 for (TileTaskQueue::Item::Vector::const_iterator it = queue->items.begin(); | |
155 it != queue->items.end(); ++it) { | |
156 const TileTaskQueue::Item& item = *it; | |
157 RasterTask* task = item.task; | |
158 DCHECK(!task->HasCompleted()); | |
159 | |
160 for (TaskSet task_set = 0; task_set < kNumberOfTaskSets; ++task_set) { | |
161 if (!item.task_sets[task_set]) | |
162 continue; | |
163 | |
164 ++task_count[task_set]; | |
165 | |
166 graph_.edges.push_back( | |
167 TaskGraph::Edge(task, new_task_set_finished_tasks[task_set].get())); | |
168 } | |
169 | |
170 InsertNodesForRasterTask(&graph_, task, task->dependencies(), priority++); | |
171 } | |
172 | |
173 for (TaskSet task_set = 0; task_set < kNumberOfTaskSets; ++task_set) { | |
174 InsertNodeForTask(&graph_, new_task_set_finished_tasks[task_set].get(), | |
175 kTaskSetFinishedTaskPriorityBase + task_set, | |
176 task_count[task_set]); | |
177 } | |
178 | |
179 ScheduleTasksOnOriginThread(this, &graph_); | |
180 | 127 |
181 // Barrier to sync any new resources to the worker context. | 128 // Barrier to sync any new resources to the worker context. |
182 rasterizer_->resource_provider() | 129 rasterizer_->resource_provider() |
183 ->output_surface() | 130 ->output_surface() |
184 ->context_provider() | 131 ->context_provider() |
185 ->ContextGL() | 132 ->ContextGL() |
186 ->OrderingBarrierCHROMIUM(); | 133 ->OrderingBarrierCHROMIUM(); |
187 | 134 |
188 task_graph_runner_->ScheduleTasks(namespace_token_, &graph_); | 135 task_graph_runner_->ScheduleTasks(namespace_token_, graph); |
189 | |
190 std::copy(new_task_set_finished_tasks, | |
191 new_task_set_finished_tasks + kNumberOfTaskSets, | |
192 task_set_finished_tasks_); | |
193 } | 136 } |
194 | 137 |
195 void GpuTileTaskWorkerPool::CheckForCompletedTasks() { | 138 void GpuTileTaskWorkerPool::CheckForCompletedTasks() { |
196 TRACE_EVENT0("cc", "GpuTileTaskWorkerPool::CheckForCompletedTasks"); | 139 TRACE_EVENT0("cc", "GpuTileTaskWorkerPool::CheckForCompletedTasks"); |
197 | 140 |
198 task_graph_runner_->CollectCompletedTasks(namespace_token_, | 141 task_graph_runner_->CollectCompletedTasks(namespace_token_, |
199 &completed_tasks_); | 142 &completed_tasks_); |
200 CompleteTasks(completed_tasks_); | 143 CompleteTasks(completed_tasks_); |
201 completed_tasks_.clear(); | 144 completed_tasks_.clear(); |
202 } | 145 } |
(...skipping 26 matching lines...) Expand all Loading... |
229 uint64_t previous_content_id) { | 172 uint64_t previous_content_id) { |
230 return scoped_ptr<RasterBuffer>(new RasterBufferImpl( | 173 return scoped_ptr<RasterBuffer>(new RasterBufferImpl( |
231 rasterizer_.get(), resource, resource_content_id, previous_content_id)); | 174 rasterizer_.get(), resource, resource_content_id, previous_content_id)); |
232 } | 175 } |
233 | 176 |
234 void GpuTileTaskWorkerPool::ReleaseBufferForRaster( | 177 void GpuTileTaskWorkerPool::ReleaseBufferForRaster( |
235 scoped_ptr<RasterBuffer> buffer) { | 178 scoped_ptr<RasterBuffer> buffer) { |
236 // Nothing to do here. RasterBufferImpl destructor cleans up after itself. | 179 // Nothing to do here. RasterBufferImpl destructor cleans up after itself. |
237 } | 180 } |
238 | 181 |
239 void GpuTileTaskWorkerPool::OnTaskSetFinished(TaskSet task_set) { | |
240 TRACE_EVENT1("cc", "GpuTileTaskWorkerPool::OnTaskSetFinished", "task_set", | |
241 task_set); | |
242 | |
243 DCHECK(tasks_pending_[task_set]); | |
244 tasks_pending_[task_set] = false; | |
245 client_->DidFinishRunningTileTasks(task_set); | |
246 } | |
247 | |
248 } // namespace cc | 182 } // namespace cc |
OLD | NEW |