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

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

Issue 786583002: cc: Renaming Rasterizer and RasterWorkerPool interfaces (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Fix test. Update include files alphabetic orders. Created 6 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
OLDNEW
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 #ifndef CC_RESOURCES_ONE_COPY_RASTER_WORKER_POOL_H_ 5 #ifndef CC_RESOURCES_ONE_COPY_TILE_TASK_WORKER_POOL_H_
6 #define CC_RESOURCES_ONE_COPY_RASTER_WORKER_POOL_H_ 6 #define CC_RESOURCES_ONE_COPY_TILE_TASK_WORKER_POOL_H_
7 7
8 #include "base/memory/weak_ptr.h" 8 #include "base/memory/weak_ptr.h"
9 #include "base/synchronization/lock.h" 9 #include "base/synchronization/lock.h"
10 #include "base/values.h" 10 #include "base/values.h"
11 #include "cc/base/scoped_ptr_deque.h" 11 #include "cc/base/scoped_ptr_deque.h"
12 #include "cc/output/context_provider.h" 12 #include "cc/output/context_provider.h"
13 #include "cc/resources/raster_worker_pool.h"
14 #include "cc/resources/rasterizer.h"
15 #include "cc/resources/resource_provider.h" 13 #include "cc/resources/resource_provider.h"
14 #include "cc/resources/tile_task_runner.h"
15 #include "cc/resources/tile_task_worker_pool.h"
16 16
17 namespace base { 17 namespace base {
18 namespace debug { 18 namespace debug {
19 class ConvertableToTraceFormat; 19 class ConvertableToTraceFormat;
20 class TracedValue; 20 class TracedValue;
21 } 21 }
22 } 22 }
23 23
24 namespace cc { 24 namespace cc {
25 class ResourcePool; 25 class ResourcePool;
26 class ScopedResource; 26 class ScopedResource;
27 27
28 typedef int64 CopySequenceNumber; 28 typedef int64 CopySequenceNumber;
29 29
30 class CC_EXPORT OneCopyRasterWorkerPool : public RasterWorkerPool, 30 class CC_EXPORT OneCopyTileTaskWorkerPool : public TileTaskWorkerPool,
31 public Rasterizer, 31 public TileTaskRunner,
32 public RasterizerTaskClient { 32 public TileTaskClient {
33 public: 33 public:
34 ~OneCopyRasterWorkerPool() override; 34 ~OneCopyTileTaskWorkerPool() override;
35 35
36 static scoped_ptr<RasterWorkerPool> Create( 36 static scoped_ptr<TileTaskWorkerPool> Create(
37 base::SequencedTaskRunner* task_runner, 37 base::SequencedTaskRunner* task_runner,
38 TaskGraphRunner* task_graph_runner, 38 TaskGraphRunner* task_graph_runner,
39 ContextProvider* context_provider, 39 ContextProvider* context_provider,
40 ResourceProvider* resource_provider, 40 ResourceProvider* resource_provider,
41 ResourcePool* resource_pool); 41 ResourcePool* resource_pool);
42 42
43 // Overridden from RasterWorkerPool: 43 // Overridden from TileTaskWorkerPool:
44 Rasterizer* AsRasterizer() override; 44 TileTaskRunner* AsTileTaskRunner() override;
45 45
46 // Overridden from Rasterizer: 46 // Overridden from TileTaskRunner:
47 void SetClient(RasterizerClient* client) override; 47 void SetClient(TileTaskRunnerClient* client) override;
48 void Shutdown() override; 48 void Shutdown() override;
49 void ScheduleTasks(RasterTaskQueue* queue) override; 49 void ScheduleTasks(TileTaskQueue* queue) override;
50 void CheckForCompletedTasks() override; 50 void CheckForCompletedTasks() override;
51 51
52 // Overridden from RasterizerTaskClient: 52 // Overridden from TileTaskClient:
53 scoped_ptr<RasterBuffer> AcquireBufferForRaster( 53 scoped_ptr<RasterBuffer> AcquireBufferForRaster(
54 const Resource* resource) override; 54 const Resource* resource) override;
55 void ReleaseBufferForRaster(scoped_ptr<RasterBuffer> buffer) override; 55 void ReleaseBufferForRaster(scoped_ptr<RasterBuffer> buffer) override;
56 56
57 // Playback raster source and schedule copy of |src| resource to |dst| 57 // Playback raster source and schedule copy of |src| resource to |dst|
58 // resource. Returns a non-zero sequence number for this copy operation. 58 // resource. Returns a non-zero sequence number for this copy operation.
59 CopySequenceNumber PlaybackAndScheduleCopyOnWorkerThread( 59 CopySequenceNumber PlaybackAndScheduleCopyOnWorkerThread(
60 scoped_ptr<ResourceProvider::ScopedWriteLockGpuMemoryBuffer> write_lock, 60 scoped_ptr<ResourceProvider::ScopedWriteLockGpuMemoryBuffer> write_lock,
61 scoped_ptr<ScopedResource> src, 61 scoped_ptr<ScopedResource> src,
62 const Resource* dst, 62 const Resource* dst,
63 const RasterSource* raster_source, 63 const RasterSource* raster_source,
64 const gfx::Rect& rect, 64 const gfx::Rect& rect,
65 float scale); 65 float scale);
66 66
67 // Issues copy operations until |sequence| has been processed. This will 67 // Issues copy operations until |sequence| has been processed. This will
68 // return immediately if |sequence| has already been processed. 68 // return immediately if |sequence| has already been processed.
69 void AdvanceLastIssuedCopyTo(CopySequenceNumber sequence); 69 void AdvanceLastIssuedCopyTo(CopySequenceNumber sequence);
70 70
71 protected: 71 protected:
72 OneCopyRasterWorkerPool(base::SequencedTaskRunner* task_runner, 72 OneCopyTileTaskWorkerPool(base::SequencedTaskRunner* task_runner,
73 TaskGraphRunner* task_graph_runner, 73 TaskGraphRunner* task_graph_runner,
74 ContextProvider* context_provider, 74 ContextProvider* context_provider,
75 ResourceProvider* resource_provider, 75 ResourceProvider* resource_provider,
76 ResourcePool* resource_pool); 76 ResourcePool* resource_pool);
77 77
78 private: 78 private:
79 struct CopyOperation { 79 struct CopyOperation {
80 typedef ScopedPtrDeque<CopyOperation> Deque; 80 typedef ScopedPtrDeque<CopyOperation> Deque;
81 81
82 CopyOperation( 82 CopyOperation(
83 scoped_ptr<ResourceProvider::ScopedWriteLockGpuMemoryBuffer> write_lock, 83 scoped_ptr<ResourceProvider::ScopedWriteLockGpuMemoryBuffer> write_lock,
84 scoped_ptr<ScopedResource> src, 84 scoped_ptr<ScopedResource> src,
85 const Resource* dst); 85 const Resource* dst);
86 ~CopyOperation(); 86 ~CopyOperation();
87 87
88 scoped_ptr<ResourceProvider::ScopedWriteLockGpuMemoryBuffer> write_lock; 88 scoped_ptr<ResourceProvider::ScopedWriteLockGpuMemoryBuffer> write_lock;
89 scoped_ptr<ScopedResource> src; 89 scoped_ptr<ScopedResource> src;
90 const Resource* dst; 90 const Resource* dst;
91 }; 91 };
92 92
93 void OnRasterFinished(TaskSet task_set); 93 void OnTaskSetFinished(TaskSet task_set);
94 void AdvanceLastFlushedCopyTo(CopySequenceNumber sequence); 94 void AdvanceLastFlushedCopyTo(CopySequenceNumber sequence);
95 void IssueCopyOperations(int64 count); 95 void IssueCopyOperations(int64 count);
96 void ScheduleCheckForCompletedCopyOperationsWithLockAcquired( 96 void ScheduleCheckForCompletedCopyOperationsWithLockAcquired(
97 bool wait_if_needed); 97 bool wait_if_needed);
98 void CheckForCompletedCopyOperations(bool wait_if_needed); 98 void CheckForCompletedCopyOperations(bool wait_if_needed);
99 scoped_refptr<base::debug::ConvertableToTraceFormat> StateAsValue() const; 99 scoped_refptr<base::debug::ConvertableToTraceFormat> StateAsValue() const;
100 void StagingStateAsValueInto(base::debug::TracedValue* staging_state) const; 100 void StagingStateAsValueInto(base::debug::TracedValue* staging_state) const;
101 101
102 scoped_refptr<base::SequencedTaskRunner> task_runner_; 102 scoped_refptr<base::SequencedTaskRunner> task_runner_;
103 TaskGraphRunner* task_graph_runner_; 103 TaskGraphRunner* task_graph_runner_;
104 const NamespaceToken namespace_token_; 104 const NamespaceToken namespace_token_;
105 RasterizerClient* client_; 105 TileTaskRunnerClient* client_;
106 ContextProvider* context_provider_; 106 ContextProvider* context_provider_;
107 ResourceProvider* resource_provider_; 107 ResourceProvider* resource_provider_;
108 ResourcePool* resource_pool_; 108 ResourcePool* resource_pool_;
109 TaskSetCollection raster_pending_; 109 TaskSetCollection tasks_pending_;
110 scoped_refptr<RasterizerTask> raster_finished_tasks_[kNumberOfTaskSets]; 110 scoped_refptr<TileTask> task_set_finished_tasks_[kNumberOfTaskSets];
111 CopySequenceNumber last_issued_copy_operation_; 111 CopySequenceNumber last_issued_copy_operation_;
112 CopySequenceNumber last_flushed_copy_operation_; 112 CopySequenceNumber last_flushed_copy_operation_;
113 113
114 // Task graph used when scheduling tasks and vector used to gather 114 // Task graph used when scheduling tasks and vector used to gather
115 // completed tasks. 115 // completed tasks.
116 TaskGraph graph_; 116 TaskGraph graph_;
117 Task::Vector completed_tasks_; 117 Task::Vector completed_tasks_;
118 118
119 base::Lock lock_; 119 base::Lock lock_;
120 // |lock_| must be acquired when accessing the following members. 120 // |lock_| must be acquired when accessing the following members.
121 base::ConditionVariable copy_operation_count_cv_; 121 base::ConditionVariable copy_operation_count_cv_;
122 size_t scheduled_copy_operation_count_; 122 size_t scheduled_copy_operation_count_;
123 size_t issued_copy_operation_count_; 123 size_t issued_copy_operation_count_;
124 CopyOperation::Deque pending_copy_operations_; 124 CopyOperation::Deque pending_copy_operations_;
125 CopySequenceNumber next_copy_operation_sequence_; 125 CopySequenceNumber next_copy_operation_sequence_;
126 bool check_for_completed_copy_operations_pending_; 126 bool check_for_completed_copy_operations_pending_;
127 base::TimeTicks last_check_for_completed_copy_operations_time_; 127 base::TimeTicks last_check_for_completed_copy_operations_time_;
128 bool shutdown_; 128 bool shutdown_;
129 129
130 base::WeakPtrFactory<OneCopyRasterWorkerPool> weak_ptr_factory_; 130 base::WeakPtrFactory<OneCopyTileTaskWorkerPool> weak_ptr_factory_;
131 // "raster finished" tasks need their own factory as they need to be 131 // "raster finished" tasks need their own factory as they need to be
132 // canceled when ScheduleTasks() is called. 132 // canceled when ScheduleTasks() is called.
133 base::WeakPtrFactory<OneCopyRasterWorkerPool> 133 base::WeakPtrFactory<OneCopyTileTaskWorkerPool>
134 raster_finished_weak_ptr_factory_; 134 task_set_finished_weak_ptr_factory_;
135 135
136 DISALLOW_COPY_AND_ASSIGN(OneCopyRasterWorkerPool); 136 DISALLOW_COPY_AND_ASSIGN(OneCopyTileTaskWorkerPool);
137 }; 137 };
138 138
139 } // namespace cc 139 } // namespace cc
140 140
141 #endif // CC_RESOURCES_ONE_COPY_RASTER_WORKER_POOL_H_ 141 #endif // CC_RESOURCES_ONE_COPY_TILE_TASK_WORKER_POOL_H_
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698