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

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

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
(Empty)
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
3 // found in the LICENSE file.
4
5 #include "cc/resources/raster_worker_pool.h"
6
7 #include "base/test/test_simple_task_runner.h"
8 #include "base/time/time.h"
9 #include "cc/debug/lap_timer.h"
10 #include "cc/output/context_provider.h"
11 #include "cc/resources/bitmap_raster_worker_pool.h"
12 #include "cc/resources/gpu_raster_worker_pool.h"
13 #include "cc/resources/one_copy_raster_worker_pool.h"
14 #include "cc/resources/pixel_buffer_raster_worker_pool.h"
15 #include "cc/resources/raster_buffer.h"
16 #include "cc/resources/rasterizer.h"
17 #include "cc/resources/resource_pool.h"
18 #include "cc/resources/resource_provider.h"
19 #include "cc/resources/scoped_resource.h"
20 #include "cc/resources/zero_copy_raster_worker_pool.h"
21 #include "cc/test/fake_output_surface.h"
22 #include "cc/test/fake_output_surface_client.h"
23 #include "cc/test/test_context_support.h"
24 #include "cc/test/test_gpu_memory_buffer_manager.h"
25 #include "cc/test/test_shared_bitmap_manager.h"
26 #include "cc/test/test_web_graphics_context_3d.h"
27 #include "testing/gtest/include/gtest/gtest.h"
28 #include "testing/perf/perf_test.h"
29 #include "third_party/khronos/GLES2/gl2.h"
30
31 namespace cc {
32 namespace {
33
34 class PerfGLES2Interface : public gpu::gles2::GLES2InterfaceStub {
35 // Overridden from gpu::gles2::GLES2Interface:
36 GLuint CreateImageCHROMIUM(ClientBuffer buffer,
37 GLsizei width,
38 GLsizei height,
39 GLenum internalformat) override {
40 return 1u;
41 }
42 void GenBuffers(GLsizei n, GLuint* buffers) override {
43 for (GLsizei i = 0; i < n; ++i)
44 buffers[i] = 1u;
45 }
46 void GenTextures(GLsizei n, GLuint* textures) override {
47 for (GLsizei i = 0; i < n; ++i)
48 textures[i] = 1u;
49 }
50 void GetIntegerv(GLenum pname, GLint* params) override {
51 if (pname == GL_MAX_TEXTURE_SIZE)
52 *params = INT_MAX;
53 }
54 void GenQueriesEXT(GLsizei n, GLuint* queries) override {
55 for (GLsizei i = 0; i < n; ++i)
56 queries[i] = 1u;
57 }
58 void GetQueryObjectuivEXT(GLuint query,
59 GLenum pname,
60 GLuint* params) override {
61 if (pname == GL_QUERY_RESULT_AVAILABLE_EXT)
62 *params = 1;
63 }
64 };
65
66 class PerfContextProvider : public ContextProvider {
67 public:
68 PerfContextProvider() : context_gl_(new PerfGLES2Interface) {}
69
70 bool BindToCurrentThread() override { return true; }
71 Capabilities ContextCapabilities() override {
72 Capabilities capabilities;
73 capabilities.gpu.image = true;
74 capabilities.gpu.sync_query = true;
75 return capabilities;
76 }
77 gpu::gles2::GLES2Interface* ContextGL() override { return context_gl_.get(); }
78 gpu::ContextSupport* ContextSupport() override { return &support_; }
79 class GrContext* GrContext() override {
80 return NULL;
81 }
82 bool IsContextLost() override { return false; }
83 void VerifyContexts() override {}
84 void DeleteCachedResources() override {}
85 bool DestroyedOnMainThread() override { return false; }
86 void SetLostContextCallback(const LostContextCallback& cb) override {}
87 void SetMemoryPolicyChangedCallback(
88 const MemoryPolicyChangedCallback& cb) override {}
89
90 private:
91 ~PerfContextProvider() override {}
92
93 scoped_ptr<PerfGLES2Interface> context_gl_;
94 TestContextSupport support_;
95 };
96
97 enum RasterWorkerPoolType {
98 RASTER_WORKER_POOL_TYPE_PIXEL_BUFFER,
99 RASTER_WORKER_POOL_TYPE_ZERO_COPY,
100 RASTER_WORKER_POOL_TYPE_ONE_COPY,
101 RASTER_WORKER_POOL_TYPE_GPU,
102 RASTER_WORKER_POOL_TYPE_BITMAP
103 };
104
105 static const int kTimeLimitMillis = 2000;
106 static const int kWarmupRuns = 5;
107 static const int kTimeCheckInterval = 10;
108
109 class PerfImageDecodeTaskImpl : public ImageDecodeTask {
110 public:
111 PerfImageDecodeTaskImpl() {}
112
113 // Overridden from Task:
114 void RunOnWorkerThread() override {}
115
116 // Overridden from RasterizerTask:
117 void ScheduleOnOriginThread(RasterizerTaskClient* client) override {}
118 void CompleteOnOriginThread(RasterizerTaskClient* client) override {}
119 void RunReplyOnOriginThread() override { Reset(); }
120
121 void Reset() {
122 did_run_ = false;
123 did_complete_ = false;
124 }
125
126 protected:
127 ~PerfImageDecodeTaskImpl() override {}
128
129 private:
130 DISALLOW_COPY_AND_ASSIGN(PerfImageDecodeTaskImpl);
131 };
132
133 class PerfRasterTaskImpl : public RasterTask {
134 public:
135 PerfRasterTaskImpl(scoped_ptr<ScopedResource> resource,
136 ImageDecodeTask::Vector* dependencies)
137 : RasterTask(resource.get(), dependencies), resource_(resource.Pass()) {}
138
139 // Overridden from Task:
140 void RunOnWorkerThread() override {}
141
142 // Overridden from RasterizerTask:
143 void ScheduleOnOriginThread(RasterizerTaskClient* client) override {
144 raster_buffer_ = client->AcquireBufferForRaster(resource());
145 }
146 void CompleteOnOriginThread(RasterizerTaskClient* client) override {
147 client->ReleaseBufferForRaster(raster_buffer_.Pass());
148 }
149 void RunReplyOnOriginThread() override { Reset(); }
150
151 void Reset() {
152 did_run_ = false;
153 did_complete_ = false;
154 }
155
156 protected:
157 ~PerfRasterTaskImpl() override {}
158
159 private:
160 scoped_ptr<ScopedResource> resource_;
161 scoped_ptr<RasterBuffer> raster_buffer_;
162
163 DISALLOW_COPY_AND_ASSIGN(PerfRasterTaskImpl);
164 };
165
166 class RasterWorkerPoolPerfTestBase {
167 public:
168 typedef std::vector<scoped_refptr<RasterTask>> RasterTaskVector;
169
170 enum NamedTaskSet { ALL, REQUIRED_FOR_ACTIVATION, REQUIRED_FOR_DRAW };
171
172 RasterWorkerPoolPerfTestBase()
173 : context_provider_(make_scoped_refptr(new PerfContextProvider)),
174 task_runner_(new base::TestSimpleTaskRunner),
175 task_graph_runner_(new TaskGraphRunner),
176 timer_(kWarmupRuns,
177 base::TimeDelta::FromMilliseconds(kTimeLimitMillis),
178 kTimeCheckInterval) {}
179
180 void CreateImageDecodeTasks(unsigned num_image_decode_tasks,
181 ImageDecodeTask::Vector* image_decode_tasks) {
182 for (unsigned i = 0; i < num_image_decode_tasks; ++i)
183 image_decode_tasks->push_back(new PerfImageDecodeTaskImpl);
184 }
185
186 void CreateRasterTasks(unsigned num_raster_tasks,
187 const ImageDecodeTask::Vector& image_decode_tasks,
188 RasterTaskVector* raster_tasks) {
189 const gfx::Size size(1, 1);
190
191 for (unsigned i = 0; i < num_raster_tasks; ++i) {
192 scoped_ptr<ScopedResource> resource(
193 ScopedResource::Create(resource_provider_.get()));
194 resource->Allocate(
195 size, ResourceProvider::TextureHintImmutable, RGBA_8888);
196
197 ImageDecodeTask::Vector dependencies = image_decode_tasks;
198 raster_tasks->push_back(
199 new PerfRasterTaskImpl(resource.Pass(), &dependencies));
200 }
201 }
202
203 void BuildRasterTaskQueue(RasterTaskQueue* queue,
204 const RasterTaskVector& raster_tasks) {
205 for (size_t i = 0u; i < raster_tasks.size(); ++i) {
206 bool required_for_activation = (i % 2) == 0;
207 TaskSetCollection task_set_collection;
208 task_set_collection[ALL] = true;
209 task_set_collection[REQUIRED_FOR_ACTIVATION] = required_for_activation;
210 queue->items.push_back(
211 RasterTaskQueue::Item(raster_tasks[i].get(), task_set_collection));
212 }
213 }
214
215 protected:
216 scoped_refptr<ContextProvider> context_provider_;
217 FakeOutputSurfaceClient output_surface_client_;
218 scoped_ptr<FakeOutputSurface> output_surface_;
219 scoped_ptr<ResourceProvider> resource_provider_;
220 scoped_refptr<base::TestSimpleTaskRunner> task_runner_;
221 scoped_ptr<TaskGraphRunner> task_graph_runner_;
222 LapTimer timer_;
223 };
224
225 class RasterWorkerPoolPerfTest
226 : public RasterWorkerPoolPerfTestBase,
227 public testing::TestWithParam<RasterWorkerPoolType>,
228 public RasterizerClient {
229 public:
230 // Overridden from testing::Test:
231 void SetUp() override {
232 switch (GetParam()) {
233 case RASTER_WORKER_POOL_TYPE_PIXEL_BUFFER:
234 Create3dOutputSurfaceAndResourceProvider();
235 raster_worker_pool_ = PixelBufferRasterWorkerPool::Create(
236 task_runner_.get(),
237 task_graph_runner_.get(),
238 context_provider_.get(),
239 resource_provider_.get(),
240 std::numeric_limits<size_t>::max());
241 break;
242 case RASTER_WORKER_POOL_TYPE_ZERO_COPY:
243 Create3dOutputSurfaceAndResourceProvider();
244 raster_worker_pool_ =
245 ZeroCopyRasterWorkerPool::Create(task_runner_.get(),
246 task_graph_runner_.get(),
247 resource_provider_.get());
248 break;
249 case RASTER_WORKER_POOL_TYPE_ONE_COPY:
250 Create3dOutputSurfaceAndResourceProvider();
251 staging_resource_pool_ = ResourcePool::Create(
252 resource_provider_.get(), GL_TEXTURE_2D, RGBA_8888);
253 raster_worker_pool_ =
254 OneCopyRasterWorkerPool::Create(task_runner_.get(),
255 task_graph_runner_.get(),
256 context_provider_.get(),
257 resource_provider_.get(),
258 staging_resource_pool_.get());
259 break;
260 case RASTER_WORKER_POOL_TYPE_GPU:
261 Create3dOutputSurfaceAndResourceProvider();
262 raster_worker_pool_ =
263 GpuRasterWorkerPool::Create(task_runner_.get(),
264 context_provider_.get(),
265 resource_provider_.get(),
266 false);
267 break;
268 case RASTER_WORKER_POOL_TYPE_BITMAP:
269 CreateSoftwareOutputSurfaceAndResourceProvider();
270 raster_worker_pool_ =
271 BitmapRasterWorkerPool::Create(task_runner_.get(),
272 task_graph_runner_.get(),
273 resource_provider_.get());
274 break;
275 }
276
277 DCHECK(raster_worker_pool_);
278 raster_worker_pool_->AsRasterizer()->SetClient(this);
279 }
280 void TearDown() override {
281 raster_worker_pool_->AsRasterizer()->Shutdown();
282 raster_worker_pool_->AsRasterizer()->CheckForCompletedTasks();
283 }
284
285 // Overriden from RasterizerClient:
286 void DidFinishRunningTasks(TaskSet task_set) override {
287 raster_worker_pool_->AsRasterizer()->CheckForCompletedTasks();
288 }
289 TaskSetCollection TasksThatShouldBeForcedToComplete() const override {
290 return TaskSetCollection();
291 }
292
293 void RunMessageLoopUntilAllTasksHaveCompleted() {
294 task_graph_runner_->RunUntilIdle();
295 task_runner_->RunUntilIdle();
296 }
297
298 void RunScheduleTasksTest(const std::string& test_name,
299 unsigned num_raster_tasks,
300 unsigned num_image_decode_tasks) {
301 ImageDecodeTask::Vector image_decode_tasks;
302 RasterTaskVector raster_tasks;
303 CreateImageDecodeTasks(num_image_decode_tasks, &image_decode_tasks);
304 CreateRasterTasks(num_raster_tasks, image_decode_tasks, &raster_tasks);
305
306 // Avoid unnecessary heap allocations by reusing the same queue.
307 RasterTaskQueue queue;
308
309 timer_.Reset();
310 do {
311 queue.Reset();
312 BuildRasterTaskQueue(&queue, raster_tasks);
313 raster_worker_pool_->AsRasterizer()->ScheduleTasks(&queue);
314 raster_worker_pool_->AsRasterizer()->CheckForCompletedTasks();
315 timer_.NextLap();
316 } while (!timer_.HasTimeLimitExpired());
317
318 RasterTaskQueue empty;
319 raster_worker_pool_->AsRasterizer()->ScheduleTasks(&empty);
320 RunMessageLoopUntilAllTasksHaveCompleted();
321
322 perf_test::PrintResult("schedule_tasks",
323 TestModifierString(),
324 test_name,
325 timer_.LapsPerSecond(),
326 "runs/s",
327 true);
328 }
329
330 void RunScheduleAlternateTasksTest(const std::string& test_name,
331 unsigned num_raster_tasks,
332 unsigned num_image_decode_tasks) {
333 const size_t kNumVersions = 2;
334 ImageDecodeTask::Vector image_decode_tasks[kNumVersions];
335 RasterTaskVector raster_tasks[kNumVersions];
336 for (size_t i = 0; i < kNumVersions; ++i) {
337 CreateImageDecodeTasks(num_image_decode_tasks, &image_decode_tasks[i]);
338 CreateRasterTasks(
339 num_raster_tasks, image_decode_tasks[i], &raster_tasks[i]);
340 }
341
342 // Avoid unnecessary heap allocations by reusing the same queue.
343 RasterTaskQueue queue;
344
345 size_t count = 0;
346 timer_.Reset();
347 do {
348 queue.Reset();
349 BuildRasterTaskQueue(&queue, raster_tasks[count % kNumVersions]);
350 raster_worker_pool_->AsRasterizer()->ScheduleTasks(&queue);
351 raster_worker_pool_->AsRasterizer()->CheckForCompletedTasks();
352 ++count;
353 timer_.NextLap();
354 } while (!timer_.HasTimeLimitExpired());
355
356 RasterTaskQueue empty;
357 raster_worker_pool_->AsRasterizer()->ScheduleTasks(&empty);
358 RunMessageLoopUntilAllTasksHaveCompleted();
359
360 perf_test::PrintResult("schedule_alternate_tasks",
361 TestModifierString(),
362 test_name,
363 timer_.LapsPerSecond(),
364 "runs/s",
365 true);
366 }
367
368 void RunScheduleAndExecuteTasksTest(const std::string& test_name,
369 unsigned num_raster_tasks,
370 unsigned num_image_decode_tasks) {
371 ImageDecodeTask::Vector image_decode_tasks;
372 RasterTaskVector raster_tasks;
373 CreateImageDecodeTasks(num_image_decode_tasks, &image_decode_tasks);
374 CreateRasterTasks(num_raster_tasks, image_decode_tasks, &raster_tasks);
375
376 // Avoid unnecessary heap allocations by reusing the same queue.
377 RasterTaskQueue queue;
378
379 timer_.Reset();
380 do {
381 queue.Reset();
382 BuildRasterTaskQueue(&queue, raster_tasks);
383 raster_worker_pool_->AsRasterizer()->ScheduleTasks(&queue);
384 RunMessageLoopUntilAllTasksHaveCompleted();
385 timer_.NextLap();
386 } while (!timer_.HasTimeLimitExpired());
387
388 RasterTaskQueue empty;
389 raster_worker_pool_->AsRasterizer()->ScheduleTasks(&empty);
390 RunMessageLoopUntilAllTasksHaveCompleted();
391
392 perf_test::PrintResult("schedule_and_execute_tasks",
393 TestModifierString(),
394 test_name,
395 timer_.LapsPerSecond(),
396 "runs/s",
397 true);
398 }
399
400 private:
401 void Create3dOutputSurfaceAndResourceProvider() {
402 output_surface_ = FakeOutputSurface::Create3d(context_provider_).Pass();
403 CHECK(output_surface_->BindToClient(&output_surface_client_));
404 resource_provider_ = ResourceProvider::Create(output_surface_.get(),
405 NULL,
406 &gpu_memory_buffer_manager_,
407 NULL,
408 0,
409 false,
410 1).Pass();
411 }
412
413 void CreateSoftwareOutputSurfaceAndResourceProvider() {
414 output_surface_ = FakeOutputSurface::CreateSoftware(
415 make_scoped_ptr(new SoftwareOutputDevice));
416 CHECK(output_surface_->BindToClient(&output_surface_client_));
417 resource_provider_ = ResourceProvider::Create(output_surface_.get(),
418 &shared_bitmap_manager_,
419 NULL,
420 NULL,
421 0,
422 false,
423 1).Pass();
424 }
425
426 std::string TestModifierString() const {
427 switch (GetParam()) {
428 case RASTER_WORKER_POOL_TYPE_PIXEL_BUFFER:
429 return std::string("_pixel_raster_worker_pool");
430 case RASTER_WORKER_POOL_TYPE_ZERO_COPY:
431 return std::string("_zero_copy_raster_worker_pool");
432 case RASTER_WORKER_POOL_TYPE_ONE_COPY:
433 return std::string("_one_copy_raster_worker_pool");
434 case RASTER_WORKER_POOL_TYPE_GPU:
435 return std::string("_gpu_raster_worker_pool");
436 case RASTER_WORKER_POOL_TYPE_BITMAP:
437 return std::string("_bitmap_raster_worker_pool");
438 }
439 NOTREACHED();
440 return std::string();
441 }
442
443 scoped_ptr<ResourcePool> staging_resource_pool_;
444 scoped_ptr<RasterWorkerPool> raster_worker_pool_;
445 TestGpuMemoryBufferManager gpu_memory_buffer_manager_;
446 TestSharedBitmapManager shared_bitmap_manager_;
447 };
448
449 TEST_P(RasterWorkerPoolPerfTest, ScheduleTasks) {
450 RunScheduleTasksTest("1_0", 1, 0);
451 RunScheduleTasksTest("32_0", 32, 0);
452 RunScheduleTasksTest("1_1", 1, 1);
453 RunScheduleTasksTest("32_1", 32, 1);
454 RunScheduleTasksTest("1_4", 1, 4);
455 RunScheduleTasksTest("32_4", 32, 4);
456 }
457
458 TEST_P(RasterWorkerPoolPerfTest, ScheduleAlternateTasks) {
459 RunScheduleAlternateTasksTest("1_0", 1, 0);
460 RunScheduleAlternateTasksTest("32_0", 32, 0);
461 RunScheduleAlternateTasksTest("1_1", 1, 1);
462 RunScheduleAlternateTasksTest("32_1", 32, 1);
463 RunScheduleAlternateTasksTest("1_4", 1, 4);
464 RunScheduleAlternateTasksTest("32_4", 32, 4);
465 }
466
467 TEST_P(RasterWorkerPoolPerfTest, ScheduleAndExecuteTasks) {
468 RunScheduleAndExecuteTasksTest("1_0", 1, 0);
469 RunScheduleAndExecuteTasksTest("32_0", 32, 0);
470 RunScheduleAndExecuteTasksTest("1_1", 1, 1);
471 RunScheduleAndExecuteTasksTest("32_1", 32, 1);
472 RunScheduleAndExecuteTasksTest("1_4", 1, 4);
473 RunScheduleAndExecuteTasksTest("32_4", 32, 4);
474 }
475
476 INSTANTIATE_TEST_CASE_P(RasterWorkerPoolPerfTests,
477 RasterWorkerPoolPerfTest,
478 ::testing::Values(RASTER_WORKER_POOL_TYPE_PIXEL_BUFFER,
479 RASTER_WORKER_POOL_TYPE_ZERO_COPY,
480 RASTER_WORKER_POOL_TYPE_ONE_COPY,
481 RASTER_WORKER_POOL_TYPE_GPU,
482 RASTER_WORKER_POOL_TYPE_BITMAP));
483
484 class RasterWorkerPoolCommonPerfTest : public RasterWorkerPoolPerfTestBase,
485 public testing::Test {
486 public:
487 // Overridden from testing::Test:
488 void SetUp() override {
489 output_surface_ = FakeOutputSurface::Create3d(context_provider_).Pass();
490 CHECK(output_surface_->BindToClient(&output_surface_client_));
491 resource_provider_ =
492 ResourceProvider::Create(
493 output_surface_.get(), NULL, NULL, NULL, 0, false, 1).Pass();
494 }
495
496 void RunBuildRasterTaskQueueTest(const std::string& test_name,
497 unsigned num_raster_tasks,
498 unsigned num_image_decode_tasks) {
499 ImageDecodeTask::Vector image_decode_tasks;
500 RasterTaskVector raster_tasks;
501 CreateImageDecodeTasks(num_image_decode_tasks, &image_decode_tasks);
502 CreateRasterTasks(num_raster_tasks, image_decode_tasks, &raster_tasks);
503
504 // Avoid unnecessary heap allocations by reusing the same queue.
505 RasterTaskQueue queue;
506
507 timer_.Reset();
508 do {
509 queue.Reset();
510 BuildRasterTaskQueue(&queue, raster_tasks);
511 timer_.NextLap();
512 } while (!timer_.HasTimeLimitExpired());
513
514 perf_test::PrintResult("build_raster_task_queue",
515 "",
516 test_name,
517 timer_.LapsPerSecond(),
518 "runs/s",
519 true);
520 }
521 };
522
523 TEST_F(RasterWorkerPoolCommonPerfTest, BuildRasterTaskQueue) {
524 RunBuildRasterTaskQueueTest("1_0", 1, 0);
525 RunBuildRasterTaskQueueTest("32_0", 32, 0);
526 RunBuildRasterTaskQueueTest("1_1", 1, 1);
527 RunBuildRasterTaskQueueTest("32_1", 32, 1);
528 RunBuildRasterTaskQueueTest("1_4", 1, 4);
529 RunBuildRasterTaskQueueTest("32_4", 32, 4);
530 }
531
532 } // namespace
533 } // namespace cc
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698