OLD | NEW |
1 // Copyright 2012 The Chromium Authors. All rights reserved. | 1 // Copyright 2012 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/test/fake_tile_manager.h" | 5 #include "cc/test/fake_tile_manager.h" |
6 | 6 |
7 #include <stddef.h> | 7 #include <stddef.h> |
8 #include <stdint.h> | 8 #include <stdint.h> |
9 | 9 |
10 #include <deque> | 10 #include <deque> |
11 #include <limits> | 11 #include <limits> |
12 | 12 |
13 #include "base/lazy_instance.h" | 13 #include "base/lazy_instance.h" |
14 #include "base/thread_task_runner_handle.h" | 14 #include "base/thread_task_runner_handle.h" |
15 #include "cc/raster/raster_buffer.h" | 15 #include "cc/raster/raster_buffer.h" |
16 #include "cc/raster/tile_task_worker_pool.h" | 16 #include "cc/raster/tile_task_worker_pool.h" |
17 | 17 |
18 namespace cc { | 18 namespace cc { |
19 | 19 |
20 namespace { | 20 namespace { |
21 | 21 |
22 class FakeTileTaskWorkerPoolImpl : public TileTaskWorkerPool, | 22 class FakeTileTaskWorkerPoolImpl : public TileTaskWorkerPool, |
23 public RasterBufferProvider { | 23 public RasterBufferProvider { |
24 public: | 24 public: |
25 // Overridden from TileTaskWorkerPool: | 25 // Overridden from TileTaskWorkerPool: |
26 void Shutdown() override {} | 26 void BarrierToSyncResources() override {} |
27 void ScheduleTasks(TaskGraph* graph) override { | |
28 for (const auto& node : graph->nodes) { | |
29 TileTask* task = static_cast<TileTask*>(node.task); | |
30 | |
31 task->WillSchedule(); | |
32 task->ScheduleOnOriginThread(this); | |
33 task->DidSchedule(); | |
34 | |
35 completed_tasks_.push_back(task); | |
36 } | |
37 } | |
38 void CheckForCompletedTasks() override { | |
39 for (TileTask::Vector::iterator it = completed_tasks_.begin(); | |
40 it != completed_tasks_.end(); ++it) { | |
41 TileTask* task = it->get(); | |
42 | |
43 task->WillComplete(); | |
44 task->CompleteOnOriginThread(this); | |
45 task->DidComplete(); | |
46 } | |
47 completed_tasks_.clear(); | |
48 } | |
49 ResourceFormat GetResourceFormat(bool must_support_alpha) const override { | 27 ResourceFormat GetResourceFormat(bool must_support_alpha) const override { |
50 return RGBA_8888; | 28 return RGBA_8888; |
51 } | 29 } |
52 bool GetResourceRequiresSwizzle(bool must_support_alpha) const override { | 30 bool GetResourceRequiresSwizzle(bool must_support_alpha) const override { |
53 return ResourceFormatRequiresSwizzle(GetResourceFormat(must_support_alpha)); | 31 return ResourceFormatRequiresSwizzle(GetResourceFormat(must_support_alpha)); |
54 } | 32 } |
55 RasterBufferProvider* AsRasterBufferProvider() override { return this; } | 33 RasterBufferProvider* AsRasterBufferProvider() override { return this; } |
56 | 34 |
57 // Overridden from RasterBufferProvider: | 35 // Overridden from RasterBufferProvider: |
58 std::unique_ptr<RasterBuffer> AcquireBufferForRaster( | 36 std::unique_ptr<RasterBuffer> AcquireBufferForRaster( |
59 const Resource* resource, | 37 const Resource* resource, |
60 uint64_t resource_content_id, | 38 uint64_t resource_content_id, |
61 uint64_t previous_content_id) override { | 39 uint64_t previous_content_id) override { |
62 return nullptr; | 40 return nullptr; |
63 } | 41 } |
64 void ReleaseBufferForRaster(std::unique_ptr<RasterBuffer> buffer) override {} | 42 void ReleaseBufferForRaster(std::unique_ptr<RasterBuffer> buffer) override {} |
| 43 }; |
65 | 44 |
66 private: | 45 class FakeTileTaskManager : public TileTaskManager { |
67 TileTask::Vector completed_tasks_; | 46 public: |
| 47 FakeTileTaskManager() |
| 48 : TileTaskManager(base::WrapUnique<FakeTileTaskWorkerPoolImpl>( |
| 49 new FakeTileTaskWorkerPoolImpl)) {} |
| 50 ~FakeTileTaskManager() override {} |
| 51 void Shutdown() override {} |
| 52 void ScheduleTasks(TaskGraph* graph) override { |
| 53 for (const auto& node : graph->nodes) { |
| 54 TileTask* task = static_cast<TileTask*>(node.task); |
| 55 |
| 56 task->WillSchedule(); |
| 57 task->ScheduleOnOriginThread( |
| 58 tile_task_worker_pool_->AsRasterBufferProvider()); |
| 59 task->DidSchedule(); |
| 60 |
| 61 completed_tasks_.push_back(task); |
| 62 } |
| 63 } |
| 64 void CheckForCompletedTasks() override { |
| 65 for (Task::Vector::iterator it = completed_tasks_.begin(); |
| 66 it != completed_tasks_.end(); ++it) { |
| 67 TileTask* task = static_cast<TileTask*>(it->get()); |
| 68 |
| 69 task->WillComplete(); |
| 70 task->CompleteOnOriginThread( |
| 71 tile_task_worker_pool_->AsRasterBufferProvider()); |
| 72 task->DidComplete(); |
| 73 } |
| 74 completed_tasks_.clear(); |
| 75 } |
| 76 |
| 77 // Get TileTaskWorkerPool. |
| 78 TileTaskWorkerPool* GetTileTaskWorkerPool() const override { |
| 79 return tile_task_worker_pool_.get(); |
| 80 } |
68 }; | 81 }; |
69 base::LazyInstance<FakeTileTaskWorkerPoolImpl> g_fake_tile_task_worker_pool = | 82 |
| 83 base::LazyInstance<FakeTileTaskManager> g_fake_tile_task_manager = |
70 LAZY_INSTANCE_INITIALIZER; | 84 LAZY_INSTANCE_INITIALIZER; |
71 | 85 |
72 } // namespace | 86 } // namespace |
73 | 87 |
74 FakeTileManager::FakeTileManager(TileManagerClient* client) | 88 FakeTileManager::FakeTileManager(TileManagerClient* client) |
75 : TileManager(client, | 89 : TileManager(client, |
76 base::ThreadTaskRunnerHandle::Get(), | 90 base::ThreadTaskRunnerHandle::Get(), |
77 std::numeric_limits<size_t>::max(), | 91 std::numeric_limits<size_t>::max(), |
78 false /* use_partial_raster */) { | 92 false /* use_partial_raster */) { |
79 SetResources(nullptr, g_fake_tile_task_worker_pool.Pointer(), | 93 SetResources( |
80 &image_decode_controller_, std::numeric_limits<size_t>::max(), | 94 nullptr, &image_decode_controller_, g_fake_tile_task_manager.Pointer(), |
81 false /* use_gpu_rasterization */); | 95 std::numeric_limits<size_t>::max(), false /* use_gpu_rasterization */); |
82 } | 96 } |
83 | 97 |
84 FakeTileManager::FakeTileManager(TileManagerClient* client, | 98 FakeTileManager::FakeTileManager(TileManagerClient* client, |
85 ResourcePool* resource_pool) | 99 ResourcePool* resource_pool) |
86 : TileManager(client, | 100 : TileManager(client, |
87 base::ThreadTaskRunnerHandle::Get(), | 101 base::ThreadTaskRunnerHandle::Get(), |
88 std::numeric_limits<size_t>::max(), | 102 std::numeric_limits<size_t>::max(), |
89 false /* use_partial_raster */) { | 103 false /* use_partial_raster */) { |
90 SetResources(resource_pool, g_fake_tile_task_worker_pool.Pointer(), | 104 SetResources(resource_pool, &image_decode_controller_, |
91 &image_decode_controller_, std::numeric_limits<size_t>::max(), | 105 g_fake_tile_task_manager.Pointer(), |
| 106 std::numeric_limits<size_t>::max(), |
92 false /* use_gpu_rasterization */); | 107 false /* use_gpu_rasterization */); |
93 } | 108 } |
94 | 109 |
95 FakeTileManager::~FakeTileManager() {} | 110 FakeTileManager::~FakeTileManager() {} |
96 | 111 |
97 bool FakeTileManager::HasBeenAssignedMemory(Tile* tile) { | 112 bool FakeTileManager::HasBeenAssignedMemory(Tile* tile) { |
98 return std::find(tiles_for_raster.begin(), | 113 return std::find(tiles_for_raster.begin(), |
99 tiles_for_raster.end(), | 114 tiles_for_raster.end(), |
100 tile) != tiles_for_raster.end(); | 115 tile) != tiles_for_raster.end(); |
101 } | 116 } |
102 | 117 |
103 void FakeTileManager::Release(Tile* tile) { | 118 void FakeTileManager::Release(Tile* tile) { |
104 TileManager::Release(tile); | 119 TileManager::Release(tile); |
105 | 120 |
106 FreeResourcesForReleasedTiles(); | 121 FreeResourcesForReleasedTiles(); |
107 CleanUpReleasedTiles(); | 122 CleanUpReleasedTiles(); |
108 } | 123 } |
109 | 124 |
110 } // namespace cc | 125 } // namespace cc |
OLD | NEW |