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

Side by Side Diff: cc/resources/gpu_tile_task_worker_pool.cc

Issue 935333002: Update from https://crrev.com/316786 (Closed) Base URL: git@github.com:domokit/mojo.git@master
Patch Set: Created 5 years, 10 months 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
« no previous file with comments | « cc/resources/gpu_tile_task_worker_pool.h ('k') | cc/resources/one_copy_tile_task_worker_pool.h » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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 #include "cc/resources/gpu_tile_task_worker_pool.h" 5 #include "cc/resources/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/resources/gpu_rasterizer.h"
10 #include "cc/resources/raster_buffer.h" 11 #include "cc/resources/raster_buffer.h"
11 #include "cc/resources/raster_source.h" 12 #include "cc/resources/raster_source.h"
12 #include "cc/resources/resource.h" 13 #include "cc/resources/resource.h"
13 #include "cc/resources/scoped_gpu_raster.h" 14 #include "cc/resources/scoped_gpu_raster.h"
14 #include "gpu/command_buffer/client/gles2_interface.h" 15 #include "gpu/command_buffer/client/gles2_interface.h"
15 #include "third_party/skia/include/core/SkMultiPictureDraw.h" 16 #include "third_party/skia/include/core/SkMultiPictureDraw.h"
16 #include "third_party/skia/include/core/SkPictureRecorder.h" 17 #include "third_party/skia/include/core/SkPictureRecorder.h"
17 #include "third_party/skia/include/core/SkSurface.h" 18 #include "third_party/skia/include/core/SkSurface.h"
18 #include "third_party/skia/include/gpu/GrContext.h" 19 #include "third_party/skia/include/gpu/GrContext.h"
19 20
20 namespace cc { 21 namespace cc {
21 namespace { 22 namespace {
22 23
23 class RasterBufferImpl : public RasterBuffer { 24 class RasterBufferImpl : public RasterBuffer {
24 public: 25 public:
25 RasterBufferImpl() {} 26 RasterBufferImpl(GpuRasterizer* rasterizer, const Resource* resource)
27 : rasterizer_(rasterizer),
28 lock_(rasterizer->resource_provider(), resource->id()),
29 resource_(resource) {}
26 30
27 // Overridden from RasterBuffer: 31 // Overridden from RasterBuffer:
28 void Playback(const RasterSource* raster_source, 32 void Playback(const RasterSource* raster_source,
29 const gfx::Rect& rect, 33 const gfx::Rect& rect,
30 float scale) override { 34 float scale) override {
31 // Don't do anything. 35 TRACE_EVENT0("cc", "RasterBufferImpl::Playback");
36 ContextProvider* context_provider = rasterizer_->resource_provider()
37 ->output_surface()
38 ->worker_context_provider();
39
40 // The context lock must be held while accessing the context on a
41 // worker thread.
42 base::AutoLock context_lock(*context_provider->GetLock());
43
44 // Allow this worker thread to bind to context_provider.
45 context_provider->DetachFromThread();
46
47 // Rasterize source into resource.
48 rasterizer_->RasterizeSource(true, &lock_, raster_source, rect, scale);
49
50 // Barrier to sync worker context output to cc context.
51 context_provider->ContextGL()->OrderingBarrierCHROMIUM();
52
53 // Allow compositor thread to bind to context_provider.
54 context_provider->DetachFromThread();
32 } 55 }
33 56
34 private: 57 private:
58 GpuRasterizer* rasterizer_;
59 ResourceProvider::ScopedWriteLockGr lock_;
60 const Resource* resource_;
61
35 DISALLOW_COPY_AND_ASSIGN(RasterBufferImpl); 62 DISALLOW_COPY_AND_ASSIGN(RasterBufferImpl);
36 }; 63 };
37 64
38 } // namespace 65 } // namespace
66
39 // static 67 // static
40 scoped_ptr<TileTaskWorkerPool> GpuTileTaskWorkerPool::Create( 68 scoped_ptr<TileTaskWorkerPool> GpuTileTaskWorkerPool::Create(
41 base::SequencedTaskRunner* task_runner, 69 base::SequencedTaskRunner* task_runner,
42 TaskGraphRunner* task_graph_runner, 70 TaskGraphRunner* task_graph_runner,
43 ResourceProvider* resource_provider) { 71 GpuRasterizer* rasterizer) {
44 return make_scoped_ptr<TileTaskWorkerPool>( 72 return make_scoped_ptr<TileTaskWorkerPool>(
45 new GpuTileTaskWorkerPool( 73 new GpuTileTaskWorkerPool(task_runner, task_graph_runner, rasterizer));
46 task_runner, task_graph_runner, resource_provider));
47 } 74 }
48 75
49 // TODO(hendrikw): This class should be removed. See crbug.com/444938.
50 GpuTileTaskWorkerPool::GpuTileTaskWorkerPool( 76 GpuTileTaskWorkerPool::GpuTileTaskWorkerPool(
51 base::SequencedTaskRunner* task_runner, 77 base::SequencedTaskRunner* task_runner,
52 TaskGraphRunner* task_graph_runner, 78 TaskGraphRunner* task_graph_runner,
53 ResourceProvider* resource_provider) 79 GpuRasterizer* rasterizer)
54 : task_runner_(task_runner), 80 : task_runner_(task_runner),
55 task_graph_runner_(task_graph_runner), 81 task_graph_runner_(task_graph_runner),
56 namespace_token_(task_graph_runner_->GetNamespaceToken()), 82 namespace_token_(task_graph_runner_->GetNamespaceToken()),
57 resource_provider_(resource_provider), 83 rasterizer_(rasterizer),
58 task_set_finished_weak_ptr_factory_(this), 84 task_set_finished_weak_ptr_factory_(this),
59 weak_ptr_factory_(this) { 85 weak_ptr_factory_(this) {
60 } 86 }
61 87
62 GpuTileTaskWorkerPool::~GpuTileTaskWorkerPool() { 88 GpuTileTaskWorkerPool::~GpuTileTaskWorkerPool() {
63 DCHECK_EQ(0u, completed_tasks_.size()); 89 DCHECK_EQ(0u, completed_tasks_.size());
64 } 90 }
65 91
66 TileTaskRunner* GpuTileTaskWorkerPool::AsTileTaskRunner() { 92 TileTaskRunner* GpuTileTaskWorkerPool::AsTileTaskRunner() {
67 return this; 93 return this;
(...skipping 54 matching lines...) Expand 10 before | Expand all | Expand 10 after
122 InsertNodesForRasterTask(&graph_, task, task->dependencies(), priority++); 148 InsertNodesForRasterTask(&graph_, task, task->dependencies(), priority++);
123 } 149 }
124 150
125 for (TaskSet task_set = 0; task_set < kNumberOfTaskSets; ++task_set) { 151 for (TaskSet task_set = 0; task_set < kNumberOfTaskSets; ++task_set) {
126 InsertNodeForTask(&graph_, new_task_set_finished_tasks[task_set].get(), 152 InsertNodeForTask(&graph_, new_task_set_finished_tasks[task_set].get(),
127 kTaskSetFinishedTaskPriorityBase + task_set, 153 kTaskSetFinishedTaskPriorityBase + task_set,
128 task_count[task_set]); 154 task_count[task_set]);
129 } 155 }
130 156
131 ScheduleTasksOnOriginThread(this, &graph_); 157 ScheduleTasksOnOriginThread(this, &graph_);
158
159 // Barrier to sync any new resources to the worker context.
160 rasterizer_->resource_provider()
161 ->output_surface()
162 ->context_provider()
163 ->ContextGL()
164 ->OrderingBarrierCHROMIUM();
165
132 task_graph_runner_->ScheduleTasks(namespace_token_, &graph_); 166 task_graph_runner_->ScheduleTasks(namespace_token_, &graph_);
133 167
134 std::copy(new_task_set_finished_tasks, 168 std::copy(new_task_set_finished_tasks,
135 new_task_set_finished_tasks + kNumberOfTaskSets, 169 new_task_set_finished_tasks + kNumberOfTaskSets,
136 task_set_finished_tasks_); 170 task_set_finished_tasks_);
137 } 171 }
138 172
139 void GpuTileTaskWorkerPool::CheckForCompletedTasks() { 173 void GpuTileTaskWorkerPool::CheckForCompletedTasks() {
140 TRACE_EVENT0("cc", "GpuTileTaskWorkerPool::CheckForCompletedTasks"); 174 TRACE_EVENT0("cc", "GpuTileTaskWorkerPool::CheckForCompletedTasks");
141 175
142 task_graph_runner_->CollectCompletedTasks(namespace_token_, 176 task_graph_runner_->CollectCompletedTasks(namespace_token_,
143 &completed_tasks_); 177 &completed_tasks_);
144 CompleteTasks(completed_tasks_); 178 CompleteTasks(completed_tasks_);
145 completed_tasks_.clear(); 179 completed_tasks_.clear();
146 } 180 }
147 181
148 ResourceFormat GpuTileTaskWorkerPool::GetResourceFormat() { 182 ResourceFormat GpuTileTaskWorkerPool::GetResourceFormat() {
149 return resource_provider_->best_texture_format(); 183 return rasterizer_->resource_provider()->best_texture_format();
150 } 184 }
151 185
152 void GpuTileTaskWorkerPool::CompleteTasks(const Task::Vector& tasks) { 186 void GpuTileTaskWorkerPool::CompleteTasks(const Task::Vector& tasks) {
153 for (auto& task : tasks) { 187 for (auto& task : tasks) {
154 RasterTask* raster_task = static_cast<RasterTask*>(task.get()); 188 RasterTask* raster_task = static_cast<RasterTask*>(task.get());
155 189
156 raster_task->WillComplete(); 190 raster_task->WillComplete();
157 raster_task->CompleteOnOriginThread(this); 191 raster_task->CompleteOnOriginThread(this);
158 raster_task->DidComplete(); 192 raster_task->DidComplete();
159 193
160 raster_task->RunReplyOnOriginThread(); 194 raster_task->RunReplyOnOriginThread();
161 } 195 }
162 completed_tasks_.clear(); 196 completed_tasks_.clear();
163 } 197 }
164 198
165 scoped_ptr<RasterBuffer> GpuTileTaskWorkerPool::AcquireBufferForRaster( 199 scoped_ptr<RasterBuffer> GpuTileTaskWorkerPool::AcquireBufferForRaster(
166 const Resource* resource) { 200 const Resource* resource) {
167 return make_scoped_ptr<RasterBuffer>(new RasterBufferImpl()); 201 return make_scoped_ptr<RasterBuffer>(
202 new RasterBufferImpl(rasterizer_, resource));
168 } 203 }
169 204
170 void GpuTileTaskWorkerPool::ReleaseBufferForRaster( 205 void GpuTileTaskWorkerPool::ReleaseBufferForRaster(
171 scoped_ptr<RasterBuffer> buffer) { 206 scoped_ptr<RasterBuffer> buffer) {
172 // Nothing to do here. RasterBufferImpl destructor cleans up after itself. 207 // Nothing to do here. RasterBufferImpl destructor cleans up after itself.
173 } 208 }
174 209
175 void GpuTileTaskWorkerPool::OnTaskSetFinished(TaskSet task_set) { 210 void GpuTileTaskWorkerPool::OnTaskSetFinished(TaskSet task_set) {
176 TRACE_EVENT1("cc", "GpuTileTaskWorkerPool::OnTaskSetFinished", "task_set", 211 TRACE_EVENT1("cc", "GpuTileTaskWorkerPool::OnTaskSetFinished", "task_set",
177 task_set); 212 task_set);
178 213
179 DCHECK(tasks_pending_[task_set]); 214 DCHECK(tasks_pending_[task_set]);
180 tasks_pending_[task_set] = false; 215 tasks_pending_[task_set] = false;
181 client_->DidFinishRunningTileTasks(task_set); 216 client_->DidFinishRunningTileTasks(task_set);
182 } 217 }
183 218
184 } // namespace cc 219 } // namespace cc
OLDNEW
« no previous file with comments | « cc/resources/gpu_tile_task_worker_pool.h ('k') | cc/resources/one_copy_tile_task_worker_pool.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698