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 #ifndef CC_RASTER_ONE_COPY_TILE_TASK_WORKER_POOL_H_ | 5 #ifndef CC_RASTER_ONE_COPY_TILE_TASK_WORKER_POOL_H_ |
6 #define CC_RASTER_ONE_COPY_TILE_TASK_WORKER_POOL_H_ | 6 #define CC_RASTER_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" |
(...skipping 45 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
56 // Overridden from TileTaskClient: | 56 // Overridden from TileTaskClient: |
57 scoped_ptr<RasterBuffer> AcquireBufferForRaster( | 57 scoped_ptr<RasterBuffer> AcquireBufferForRaster( |
58 const Resource* resource, | 58 const Resource* resource, |
59 uint64_t resource_content_id, | 59 uint64_t resource_content_id, |
60 uint64_t previous_content_id) override; | 60 uint64_t previous_content_id) override; |
61 void ReleaseBufferForRaster(scoped_ptr<RasterBuffer> buffer) override; | 61 void ReleaseBufferForRaster(scoped_ptr<RasterBuffer> buffer) override; |
62 | 62 |
63 // Playback raster source and schedule copy of |raster_resource| resource to | 63 // Playback raster source and schedule copy of |raster_resource| resource to |
64 // |output_resource|. Returns a non-zero sequence number for this copy | 64 // |output_resource|. Returns a non-zero sequence number for this copy |
65 // operation. | 65 // operation. |
66 CopySequenceNumber PlaybackAndScheduleCopyOnWorkerThread( | 66 void PlaybackAndCopyOnWorkerThread( |
67 bool reusing_raster_resource, | 67 bool reusing_raster_resource, |
68 scoped_ptr<ResourceProvider::ScopedWriteLockGpuMemoryBuffer> | 68 scoped_ptr<ResourceProvider::ScopedWriteLockGpuMemoryBufferForThread> |
69 raster_resource_write_lock, | 69 raster_resource_write_lock, |
70 const Resource* raster_resource, | 70 const Resource* raster_resource, |
71 const Resource* output_resource, | 71 const Resource* output_resource, |
72 const RasterSource* raster_source, | 72 const RasterSource* raster_source, |
73 const gfx::Rect& raster_full_rect, | 73 const gfx::Rect& raster_full_rect, |
74 const gfx::Rect& raster_dirty_rect, | 74 const gfx::Rect& raster_dirty_rect, |
75 float scale); | 75 float scale); |
76 | 76 |
77 // Issues copy operations until |sequence| has been processed. This will | 77 // Issues copy operations until |sequence| has been processed. This will |
78 // return immediately if |sequence| has already been processed. | 78 // return immediately if |sequence| has already been processed. |
79 void AdvanceLastIssuedCopyTo(CopySequenceNumber sequence); | 79 void AdvanceLastIssuedCopyTo(CopySequenceNumber sequence); |
80 | 80 |
81 bool have_persistent_gpu_memory_buffers() const { | 81 bool have_persistent_gpu_memory_buffers() const { |
82 return have_persistent_gpu_memory_buffers_; | 82 return have_persistent_gpu_memory_buffers_; |
83 } | 83 } |
84 | 84 |
85 protected: | 85 protected: |
86 OneCopyTileTaskWorkerPool(base::SequencedTaskRunner* task_runner, | 86 OneCopyTileTaskWorkerPool(base::SequencedTaskRunner* task_runner, |
87 TaskGraphRunner* task_graph_runner, | 87 TaskGraphRunner* task_graph_runner, |
88 ContextProvider* context_provider, | 88 ContextProvider* context_provider, |
89 ResourceProvider* resource_provider, | 89 ResourceProvider* resource_provider, |
90 ResourcePool* resource_pool, | 90 ResourcePool* resource_pool, |
91 int max_copy_texture_chromium_size, | 91 int max_copy_texture_chromium_size, |
92 bool have_persistent_gpu_memory_buffers); | 92 bool have_persistent_gpu_memory_buffers); |
93 | 93 |
94 private: | 94 private: |
95 struct CopyOperation { | |
96 typedef ScopedPtrDeque<CopyOperation> Deque; | |
97 | |
98 CopyOperation(scoped_ptr<ResourceProvider::ScopedWriteLockGpuMemoryBuffer> | |
99 src_write_lock, | |
100 const Resource* src, | |
101 const Resource* dst, | |
102 const gfx::Rect& rect); | |
103 ~CopyOperation(); | |
104 | |
105 scoped_ptr<ResourceProvider::ScopedWriteLockGpuMemoryBuffer> src_write_lock; | |
106 const Resource* src; | |
107 const Resource* dst; | |
108 const gfx::Rect rect; | |
109 }; | |
110 | |
111 void OnTaskSetFinished(TaskSet task_set); | 95 void OnTaskSetFinished(TaskSet task_set); |
112 void AdvanceLastFlushedCopyTo(CopySequenceNumber sequence); | |
113 void IssueCopyOperations(int64 count); | |
114 void ScheduleCheckForCompletedCopyOperationsWithLockAcquired( | |
115 bool wait_if_needed); | |
116 void CheckForCompletedCopyOperations(bool wait_if_needed); | |
117 scoped_refptr<base::trace_event::ConvertableToTraceFormat> StateAsValue() | 96 scoped_refptr<base::trace_event::ConvertableToTraceFormat> StateAsValue() |
118 const; | 97 const; |
119 void StagingStateAsValueInto( | 98 void StagingStateAsValueInto( |
120 base::trace_event::TracedValue* staging_state) const; | 99 base::trace_event::TracedValue* staging_state) const; |
121 | 100 |
122 scoped_refptr<base::SequencedTaskRunner> task_runner_; | 101 scoped_refptr<base::SequencedTaskRunner> task_runner_; |
123 TaskGraphRunner* task_graph_runner_; | 102 TaskGraphRunner* task_graph_runner_; |
124 const NamespaceToken namespace_token_; | 103 const NamespaceToken namespace_token_; |
125 TileTaskRunnerClient* client_; | 104 TileTaskRunnerClient* client_; |
126 ContextProvider* context_provider_; | 105 ContextProvider* context_provider_; |
127 ResourceProvider* resource_provider_; | 106 ResourceProvider* resource_provider_; |
128 ResourcePool* resource_pool_; | 107 ResourcePool* resource_pool_; |
129 const int max_bytes_per_copy_operation_; | 108 const int max_bytes_per_copy_operation_; |
130 const bool have_persistent_gpu_memory_buffers_; | 109 const bool have_persistent_gpu_memory_buffers_; |
131 TaskSetCollection tasks_pending_; | 110 TaskSetCollection tasks_pending_; |
132 scoped_refptr<TileTask> task_set_finished_tasks_[kNumberOfTaskSets]; | 111 scoped_refptr<TileTask> task_set_finished_tasks_[kNumberOfTaskSets]; |
133 CopySequenceNumber last_issued_copy_operation_; | |
134 CopySequenceNumber last_flushed_copy_operation_; | |
135 | 112 |
136 // Task graph used when scheduling tasks and vector used to gather | 113 // Task graph used when scheduling tasks and vector used to gather |
137 // completed tasks. | 114 // completed tasks. |
138 TaskGraph graph_; | 115 TaskGraph graph_; |
139 Task::Vector completed_tasks_; | 116 Task::Vector completed_tasks_; |
140 | 117 |
141 base::Lock lock_; | 118 base::Lock lock_; |
142 // |lock_| must be acquired when accessing the following members. | |
143 base::ConditionVariable copy_operation_count_cv_; | |
144 int bytes_scheduled_since_last_flush_; | |
145 size_t issued_copy_operation_count_; | |
146 CopyOperation::Deque pending_copy_operations_; | |
147 CopySequenceNumber next_copy_operation_sequence_; | |
148 bool check_for_completed_copy_operations_pending_; | |
149 base::TimeTicks last_check_for_completed_copy_operations_time_; | |
150 bool shutdown_; | 119 bool shutdown_; |
151 | 120 |
152 base::WeakPtrFactory<OneCopyTileTaskWorkerPool> weak_ptr_factory_; | 121 base::WeakPtrFactory<OneCopyTileTaskWorkerPool> weak_ptr_factory_; |
153 // "raster finished" tasks need their own factory as they need to be | 122 // "raster finished" tasks need their own factory as they need to be |
154 // canceled when ScheduleTasks() is called. | 123 // canceled when ScheduleTasks() is called. |
155 base::WeakPtrFactory<OneCopyTileTaskWorkerPool> | 124 base::WeakPtrFactory<OneCopyTileTaskWorkerPool> |
156 task_set_finished_weak_ptr_factory_; | 125 task_set_finished_weak_ptr_factory_; |
157 | 126 |
158 DISALLOW_COPY_AND_ASSIGN(OneCopyTileTaskWorkerPool); | 127 DISALLOW_COPY_AND_ASSIGN(OneCopyTileTaskWorkerPool); |
159 }; | 128 }; |
160 | 129 |
161 } // namespace cc | 130 } // namespace cc |
162 | 131 |
163 #endif // CC_RASTER_ONE_COPY_TILE_TASK_WORKER_POOL_H_ | 132 #endif // CC_RASTER_ONE_COPY_TILE_TASK_WORKER_POOL_H_ |
OLD | NEW |