Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(237)

Side by Side Diff: cc/resources/raster_worker_pool.h

Issue 110883015: Add preliminary support for hw-accelerated tile rasterization. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: complete gpu tasks at appropriate time Created 7 years ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
1 // Copyright 2013 The Chromium Authors. All rights reserved. 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 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 #ifndef CC_RESOURCES_RASTER_WORKER_POOL_H_ 5 #ifndef CC_RESOURCES_RASTER_WORKER_POOL_H_
6 #define CC_RESOURCES_RASTER_WORKER_POOL_H_ 6 #define CC_RESOURCES_RASTER_WORKER_POOL_H_
7 7
8 #include <vector> 8 #include <vector>
9 9
10 #include "base/containers/hash_tables.h" 10 #include "base/containers/hash_tables.h"
(...skipping 18 matching lines...) Expand all
29 public: 29 public:
30 typedef std::vector<scoped_refptr<WorkerPoolTask> > TaskVector; 30 typedef std::vector<scoped_refptr<WorkerPoolTask> > TaskVector;
31 31
32 // Returns true if |buffer| was written to. False indicate that 32 // Returns true if |buffer| was written to. False indicate that
33 // the content of |buffer| is undefined and the resource doesn't 33 // the content of |buffer| is undefined and the resource doesn't
34 // need to be initialized. 34 // need to be initialized.
35 virtual bool RunOnWorkerThread(unsigned thread_index, 35 virtual bool RunOnWorkerThread(unsigned thread_index,
36 void* buffer, 36 void* buffer,
37 gfx::Size size, 37 gfx::Size size,
38 int stride) = 0; 38 int stride) = 0;
39 virtual void RunOnOriginThread(ResourceProvider* resource_provider,
40 ContextProvider* context_provider) = 0;
39 virtual void CompleteOnOriginThread() = 0; 41 virtual void CompleteOnOriginThread() = 0;
40 42
41 void DidRun(bool was_canceled); 43 void DidRun(bool was_canceled);
42 bool HasFinishedRunning() const; 44 bool HasFinishedRunning() const;
43 bool WasCanceled() const; 45 bool WasCanceled() const;
44 void WillComplete(); 46 void WillComplete();
45 void DidComplete(); 47 void DidComplete();
46 bool HasCompleted() const; 48 bool HasCompleted() const;
47 49
48 const Resource* resource() const { return resource_; } 50 const Resource* resource() const { return resource_; }
49 const TaskVector& dependencies() const { return dependencies_; } 51 const TaskVector& dependencies() const { return dependencies_; }
52 bool use_gpu_rasterization() const { return use_gpu_rasterization_; }
50 53
51 protected: 54 protected:
52 friend class base::RefCounted<RasterWorkerPoolTask>; 55 friend class base::RefCounted<RasterWorkerPoolTask>;
53 56
54 RasterWorkerPoolTask(const Resource* resource, TaskVector* dependencies); 57 RasterWorkerPoolTask(const Resource* resource,
58 TaskVector* dependencies,
59 bool use_gpu_rasterization);
55 virtual ~RasterWorkerPoolTask(); 60 virtual ~RasterWorkerPoolTask();
56 61
57 private: 62 private:
58 bool did_run_; 63 bool did_run_;
59 bool did_complete_; 64 bool did_complete_;
60 bool was_canceled_; 65 bool was_canceled_;
61 const Resource* resource_; 66 const Resource* resource_;
62 TaskVector dependencies_; 67 TaskVector dependencies_;
68 bool use_gpu_rasterization_;
63 }; 69 };
64 70
65 } // namespace internal 71 } // namespace internal
66 } // namespace cc 72 } // namespace cc
67 73
68 #if defined(COMPILER_GCC) 74 #if defined(COMPILER_GCC)
69 namespace BASE_HASH_NAMESPACE { 75 namespace BASE_HASH_NAMESPACE {
70 template <> struct hash<cc::internal::RasterWorkerPoolTask*> { 76 template <> struct hash<cc::internal::RasterWorkerPoolTask*> {
71 size_t operator()(cc::internal::RasterWorkerPoolTask* ptr) const { 77 size_t operator()(cc::internal::RasterWorkerPoolTask* ptr) const {
72 return hash<size_t>()(reinterpret_cast<size_t>(ptr)); 78 return hash<size_t>()(reinterpret_cast<size_t>(ptr));
(...skipping 92 matching lines...) Expand 10 before | Expand all | Expand 10 after
165 explicit RasterTask(internal::RasterWorkerPoolTask* internal); 171 explicit RasterTask(internal::RasterWorkerPoolTask* internal);
166 172
167 scoped_refptr<internal::RasterWorkerPoolTask> internal_; 173 scoped_refptr<internal::RasterWorkerPoolTask> internal_;
168 }; 174 };
169 175
170 virtual ~RasterWorkerPool(); 176 virtual ~RasterWorkerPool();
171 177
172 void SetClient(RasterWorkerPoolClient* client); 178 void SetClient(RasterWorkerPoolClient* client);
173 179
174 // Tells the worker pool to shutdown after canceling all previously 180 // Tells the worker pool to shutdown after canceling all previously
175 // scheduled tasks. Reply callbacks are still guaranteed to run. 181 // scheduled tasks. Reply callbacks are still guaranteed to run.
reveman 2013/12/19 01:36:47 Do you mind replacing this comment with "// Overri
alokp 2013/12/19 06:25:42 Done.
176 virtual void Shutdown() OVERRIDE; 182 virtual void Shutdown() OVERRIDE;
177 183
184 // Force a check for completed tasks.
185 // Runs reply callbacks for completed tasks.
186 virtual void CheckForCompletedTasks() OVERRIDE;
reveman 2013/12/19 01:36:47 Hm, this will still result in raster task completi
alokp 2013/12/19 06:25:42 Hm. It does not sound like the right thing to do.
reveman 2013/12/19 17:52:03 This doesn't have to be overridden by RWP implemen
alokp 2013/12/19 21:37:51 Good Idea! With this change we are moving away fro
reveman 2013/12/19 22:05:26 Yes, I think we'll do that but I like to first lan
187
178 // Schedule running of raster tasks in |queue| and all dependencies. 188 // Schedule running of raster tasks in |queue| and all dependencies.
179 // Previously scheduled tasks that are no longer needed to run 189 // Previously scheduled tasks that are no longer needed to run
180 // raster tasks in |queue| will be canceled unless already running. 190 // raster tasks in |queue| will be canceled unless already running.
181 // Once scheduled, reply callbacks are guaranteed to run for all tasks 191 // Once scheduled, reply callbacks are guaranteed to run for all tasks
182 // even if they later get canceled by another call to ScheduleTasks(). 192 // even if they later get canceled by another call to ScheduleTasks().
183 virtual void ScheduleTasks(RasterTask::Queue* queue) = 0; 193 virtual void ScheduleTasks(RasterTask::Queue* queue) = 0;
184 194
185 // Returns the target that needs to be used for raster task resources. 195 // Returns the target that needs to be used for raster task resources.
186 virtual GLenum GetResourceTarget() const = 0; 196 virtual GLenum GetResourceTarget() const = 0;
187 197
188 // Returns the format that needs to be used for raster task resources. 198 // Returns the format that needs to be used for raster task resources.
189 virtual ResourceFormat GetResourceFormat() const = 0; 199 virtual ResourceFormat GetResourceFormat() const = 0;
190 200
191 // TODO(vmpstr): Figure out an elegant way to not pass this many parameters. 201 // TODO(vmpstr): Figure out an elegant way to not pass this many parameters.
192 static RasterTask CreateRasterTask( 202 static RasterTask CreateRasterTask(
193 const Resource* resource, 203 const Resource* resource,
194 PicturePileImpl* picture_pile, 204 PicturePileImpl* picture_pile,
195 gfx::Rect content_rect, 205 gfx::Rect content_rect,
196 float contents_scale, 206 float contents_scale,
197 RasterMode raster_mode, 207 RasterMode raster_mode,
198 TileResolution tile_resolution, 208 TileResolution tile_resolution,
199 int layer_id, 209 int layer_id,
200 const void* tile_id, 210 const void* tile_id,
201 int source_frame_number, 211 int source_frame_number,
212 bool use_gpu_rasterization,
202 RenderingStatsInstrumentation* rendering_stats, 213 RenderingStatsInstrumentation* rendering_stats,
203 const RasterTask::Reply& reply, 214 const RasterTask::Reply& reply,
204 Task::Set* dependencies); 215 Task::Set* dependencies);
205 216
206 static Task CreateImageDecodeTask( 217 static Task CreateImageDecodeTask(
207 skia::LazyPixelRef* pixel_ref, 218 skia::LazyPixelRef* pixel_ref,
208 int layer_id, 219 int layer_id,
209 RenderingStatsInstrumentation* stats_instrumentation, 220 RenderingStatsInstrumentation* stats_instrumentation,
210 const Task::Reply& reply); 221 const Task::Reply& reply);
211 222
212 protected: 223 protected:
213 typedef std::vector<scoped_refptr<internal::WorkerPoolTask> > TaskVector; 224 typedef std::vector<scoped_refptr<internal::WorkerPoolTask> > TaskVector;
214 typedef std::vector<scoped_refptr<internal::RasterWorkerPoolTask> > 225 typedef std::vector<scoped_refptr<internal::RasterWorkerPoolTask> >
215 RasterTaskVector; 226 RasterTaskVector;
216 typedef base::hash_set<internal::RasterWorkerPoolTask*> RasterTaskSet; 227 typedef base::hash_set<internal::RasterWorkerPoolTask*> RasterTaskSet;
217 typedef internal::RasterWorkerPoolTask* TaskMapKey; 228 typedef internal::RasterWorkerPoolTask* TaskMapKey;
218 typedef base::hash_map<TaskMapKey, 229 typedef base::hash_map<TaskMapKey,
219 scoped_refptr<internal::WorkerPoolTask> > TaskMap; 230 scoped_refptr<internal::WorkerPoolTask> > TaskMap;
220 231
221 RasterWorkerPool(ResourceProvider* resource_provider, size_t num_threads); 232 RasterWorkerPool(ResourceProvider* resource_provider,
233 ContextProvider* context_provider,
234 size_t num_threads);
222 235
223 virtual void OnRasterTasksFinished() = 0; 236 virtual void OnRasterTasksFinished() = 0;
224 virtual void OnRasterTasksRequiredForActivationFinished() = 0; 237 virtual void OnRasterTasksRequiredForActivationFinished() = 0;
225 238
226 void SetRasterTasks(RasterTask::Queue* queue); 239 void SetRasterTasks(RasterTask::Queue* queue);
227 bool IsRasterTaskRequiredForActivation( 240 bool IsRasterTaskRequiredForActivation(
228 internal::RasterWorkerPoolTask* task) const; 241 internal::RasterWorkerPoolTask* task) const;
242 // Run raster tasks that use GPU on impl thread.
reveman 2013/12/19 01:36:47 nit: s/impl/current/
alokp 2013/12/19 06:25:42 Done.
243 void RunGpuRasterTasks(RasterTaskVector* tasks);
229 244
230 RasterWorkerPoolClient* client() const { return client_; } 245 RasterWorkerPoolClient* client() const { return client_; }
231 ResourceProvider* resource_provider() const { return resource_provider_; } 246 ResourceProvider* resource_provider() const { return resource_provider_; }
247 ContextProvider* context_provider() const { return context_provider_; }
232 const RasterTaskVector& raster_tasks() const { return raster_tasks_; } 248 const RasterTaskVector& raster_tasks() const { return raster_tasks_; }
233 const RasterTaskSet& raster_tasks_required_for_activation() const { 249 const RasterTaskSet& raster_tasks_required_for_activation() const {
234 return raster_tasks_required_for_activation_; 250 return raster_tasks_required_for_activation_;
235 } 251 }
236 void set_raster_finished_task( 252 void set_raster_finished_task(
237 scoped_refptr<internal::WorkerPoolTask> raster_finished_task) { 253 scoped_refptr<internal::WorkerPoolTask> raster_finished_task) {
238 raster_finished_task_ = raster_finished_task; 254 raster_finished_task_ = raster_finished_task;
239 } 255 }
240 void set_raster_required_for_activation_finished_task( 256 void set_raster_required_for_activation_finished_task(
241 scoped_refptr<internal::WorkerPoolTask> 257 scoped_refptr<internal::WorkerPoolTask>
(...skipping 19 matching lines...) Expand all
261 unsigned priority, 277 unsigned priority,
262 TaskGraph* graph); 278 TaskGraph* graph);
263 279
264 private: 280 private:
265 void OnRasterFinished(const internal::WorkerPoolTask* source); 281 void OnRasterFinished(const internal::WorkerPoolTask* source);
266 void OnRasterRequiredForActivationFinished( 282 void OnRasterRequiredForActivationFinished(
267 const internal::WorkerPoolTask* source); 283 const internal::WorkerPoolTask* source);
268 284
269 RasterWorkerPoolClient* client_; 285 RasterWorkerPoolClient* client_;
270 ResourceProvider* resource_provider_; 286 ResourceProvider* resource_provider_;
287 ContextProvider* context_provider_;
271 RasterTask::Queue::TaskVector raster_tasks_; 288 RasterTask::Queue::TaskVector raster_tasks_;
272 RasterTask::Queue::TaskSet raster_tasks_required_for_activation_; 289 RasterTask::Queue::TaskSet raster_tasks_required_for_activation_;
290 RasterTaskVector gpu_raster_tasks_;
273 291
274 scoped_refptr<internal::WorkerPoolTask> raster_finished_task_; 292 scoped_refptr<internal::WorkerPoolTask> raster_finished_task_;
275 scoped_refptr<internal::WorkerPoolTask> 293 scoped_refptr<internal::WorkerPoolTask>
276 raster_required_for_activation_finished_task_; 294 raster_required_for_activation_finished_task_;
277 base::WeakPtrFactory<RasterWorkerPool> weak_ptr_factory_; 295 base::WeakPtrFactory<RasterWorkerPool> weak_ptr_factory_;
278 }; 296 };
279 297
280 } // namespace cc 298 } // namespace cc
281 299
282 #endif // CC_RESOURCES_RASTER_WORKER_POOL_H_ 300 #endif // CC_RESOURCES_RASTER_WORKER_POOL_H_
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698