| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 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 | 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/raster_worker_pool.h" | 5 #include "cc/resources/raster_worker_pool.h" |
| 6 | 6 |
| 7 #include <limits> | 7 #include <limits> |
| 8 #include <vector> | 8 #include <vector> |
| 9 | 9 |
| 10 #include "base/cancelable_callback.h" | 10 #include "base/cancelable_callback.h" |
| (...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 51 | 51 |
| 52 TestRasterTaskImpl(const Resource* resource, | 52 TestRasterTaskImpl(const Resource* resource, |
| 53 const Reply& reply, | 53 const Reply& reply, |
| 54 ImageDecodeTask::Vector* dependencies) | 54 ImageDecodeTask::Vector* dependencies) |
| 55 : RasterTask(resource, dependencies), | 55 : RasterTask(resource, dependencies), |
| 56 reply_(reply), | 56 reply_(reply), |
| 57 picture_pile_(FakePicturePileImpl::CreateEmptyPile(gfx::Size(1, 1), | 57 picture_pile_(FakePicturePileImpl::CreateEmptyPile(gfx::Size(1, 1), |
| 58 gfx::Size(1, 1))) {} | 58 gfx::Size(1, 1))) {} |
| 59 | 59 |
| 60 // Overridden from Task: | 60 // Overridden from Task: |
| 61 virtual void RunOnWorkerThread() override { | 61 void RunOnWorkerThread() override { |
| 62 raster_buffer_->Playback( | 62 raster_buffer_->Playback( |
| 63 picture_pile_.get(), gfx::Rect(0, 0, 1, 1), 1.0, NULL); | 63 picture_pile_.get(), gfx::Rect(0, 0, 1, 1), 1.0, NULL); |
| 64 } | 64 } |
| 65 | 65 |
| 66 // Overridden from RasterizerTask: | 66 // Overridden from RasterizerTask: |
| 67 virtual void ScheduleOnOriginThread(RasterizerTaskClient* client) override { | 67 void ScheduleOnOriginThread(RasterizerTaskClient* client) override { |
| 68 raster_buffer_ = client->AcquireBufferForRaster(resource()); | 68 raster_buffer_ = client->AcquireBufferForRaster(resource()); |
| 69 } | 69 } |
| 70 virtual void CompleteOnOriginThread(RasterizerTaskClient* client) override { | 70 void CompleteOnOriginThread(RasterizerTaskClient* client) override { |
| 71 client->ReleaseBufferForRaster(raster_buffer_.Pass()); | 71 client->ReleaseBufferForRaster(raster_buffer_.Pass()); |
| 72 } | 72 } |
| 73 virtual void RunReplyOnOriginThread() override { | 73 void RunReplyOnOriginThread() override { |
| 74 reply_.Run(PicturePileImpl::Analysis(), !HasFinishedRunning()); | 74 reply_.Run(PicturePileImpl::Analysis(), !HasFinishedRunning()); |
| 75 } | 75 } |
| 76 | 76 |
| 77 protected: | 77 protected: |
| 78 virtual ~TestRasterTaskImpl() {} | 78 ~TestRasterTaskImpl() override {} |
| 79 | 79 |
| 80 private: | 80 private: |
| 81 const Reply reply_; | 81 const Reply reply_; |
| 82 scoped_ptr<RasterBuffer> raster_buffer_; | 82 scoped_ptr<RasterBuffer> raster_buffer_; |
| 83 scoped_refptr<PicturePileImpl> picture_pile_; | 83 scoped_refptr<PicturePileImpl> picture_pile_; |
| 84 | 84 |
| 85 DISALLOW_COPY_AND_ASSIGN(TestRasterTaskImpl); | 85 DISALLOW_COPY_AND_ASSIGN(TestRasterTaskImpl); |
| 86 }; | 86 }; |
| 87 | 87 |
| 88 class BlockingTestRasterTaskImpl : public TestRasterTaskImpl { | 88 class BlockingTestRasterTaskImpl : public TestRasterTaskImpl { |
| 89 public: | 89 public: |
| 90 BlockingTestRasterTaskImpl(const Resource* resource, | 90 BlockingTestRasterTaskImpl(const Resource* resource, |
| 91 const Reply& reply, | 91 const Reply& reply, |
| 92 base::Lock* lock, | 92 base::Lock* lock, |
| 93 ImageDecodeTask::Vector* dependencies) | 93 ImageDecodeTask::Vector* dependencies) |
| 94 : TestRasterTaskImpl(resource, reply, dependencies), lock_(lock) {} | 94 : TestRasterTaskImpl(resource, reply, dependencies), lock_(lock) {} |
| 95 | 95 |
| 96 // Overridden from Task: | 96 // Overridden from Task: |
| 97 virtual void RunOnWorkerThread() override { | 97 void RunOnWorkerThread() override { |
| 98 base::AutoLock lock(*lock_); | 98 base::AutoLock lock(*lock_); |
| 99 TestRasterTaskImpl::RunOnWorkerThread(); | 99 TestRasterTaskImpl::RunOnWorkerThread(); |
| 100 } | 100 } |
| 101 | 101 |
| 102 // Overridden from RasterizerTask: | 102 // Overridden from RasterizerTask: |
| 103 virtual void RunReplyOnOriginThread() override {} | 103 void RunReplyOnOriginThread() override {} |
| 104 | 104 |
| 105 protected: | 105 protected: |
| 106 virtual ~BlockingTestRasterTaskImpl() {} | 106 ~BlockingTestRasterTaskImpl() override {} |
| 107 | 107 |
| 108 private: | 108 private: |
| 109 base::Lock* lock_; | 109 base::Lock* lock_; |
| 110 | 110 |
| 111 DISALLOW_COPY_AND_ASSIGN(BlockingTestRasterTaskImpl); | 111 DISALLOW_COPY_AND_ASSIGN(BlockingTestRasterTaskImpl); |
| 112 }; | 112 }; |
| 113 | 113 |
| 114 class RasterWorkerPoolTest | 114 class RasterWorkerPoolTest |
| 115 : public testing::TestWithParam<RasterWorkerPoolType>, | 115 : public testing::TestWithParam<RasterWorkerPoolType>, |
| 116 public RasterizerClient { | 116 public RasterizerClient { |
| (...skipping 61 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 178 DCHECK(raster_worker_pool_); | 178 DCHECK(raster_worker_pool_); |
| 179 raster_worker_pool_->AsRasterizer()->SetClient(this); | 179 raster_worker_pool_->AsRasterizer()->SetClient(this); |
| 180 } | 180 } |
| 181 | 181 |
| 182 virtual void TearDown() override { | 182 virtual void TearDown() override { |
| 183 raster_worker_pool_->AsRasterizer()->Shutdown(); | 183 raster_worker_pool_->AsRasterizer()->Shutdown(); |
| 184 raster_worker_pool_->AsRasterizer()->CheckForCompletedTasks(); | 184 raster_worker_pool_->AsRasterizer()->CheckForCompletedTasks(); |
| 185 } | 185 } |
| 186 | 186 |
| 187 // Overriden from RasterWorkerPoolClient: | 187 // Overriden from RasterWorkerPoolClient: |
| 188 virtual void DidFinishRunningTasks(TaskSet task_set) override { | 188 void DidFinishRunningTasks(TaskSet task_set) override { |
| 189 if (task_set == ALL) { | 189 if (task_set == ALL) { |
| 190 raster_worker_pool_->AsRasterizer()->CheckForCompletedTasks(); | 190 raster_worker_pool_->AsRasterizer()->CheckForCompletedTasks(); |
| 191 base::MessageLoop::current()->Quit(); | 191 base::MessageLoop::current()->Quit(); |
| 192 } | 192 } |
| 193 } | 193 } |
| 194 virtual TaskSetCollection TasksThatShouldBeForcedToComplete() const override { | 194 TaskSetCollection TasksThatShouldBeForcedToComplete() const override { |
| 195 return TaskSetCollection(); | 195 return TaskSetCollection(); |
| 196 } | 196 } |
| 197 | 197 |
| 198 void RunMessageLoopUntilAllTasksHaveCompleted() { | 198 void RunMessageLoopUntilAllTasksHaveCompleted() { |
| 199 if (timeout_seconds_) { | 199 if (timeout_seconds_) { |
| 200 timeout_.Reset( | 200 timeout_.Reset( |
| 201 base::Bind(&RasterWorkerPoolTest::OnTimeout, base::Unretained(this))); | 201 base::Bind(&RasterWorkerPoolTest::OnTimeout, base::Unretained(this))); |
| 202 base::MessageLoopProxy::current()->PostDelayedTask( | 202 base::MessageLoopProxy::current()->PostDelayedTask( |
| 203 FROM_HERE, | 203 FROM_HERE, |
| 204 timeout_.callback(), | 204 timeout_.callback(), |
| (...skipping 198 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 403 INSTANTIATE_TEST_CASE_P(RasterWorkerPoolTests, | 403 INSTANTIATE_TEST_CASE_P(RasterWorkerPoolTests, |
| 404 RasterWorkerPoolTest, | 404 RasterWorkerPoolTest, |
| 405 ::testing::Values(RASTER_WORKER_POOL_TYPE_PIXEL_BUFFER, | 405 ::testing::Values(RASTER_WORKER_POOL_TYPE_PIXEL_BUFFER, |
| 406 RASTER_WORKER_POOL_TYPE_ZERO_COPY, | 406 RASTER_WORKER_POOL_TYPE_ZERO_COPY, |
| 407 RASTER_WORKER_POOL_TYPE_ONE_COPY, | 407 RASTER_WORKER_POOL_TYPE_ONE_COPY, |
| 408 RASTER_WORKER_POOL_TYPE_GPU, | 408 RASTER_WORKER_POOL_TYPE_GPU, |
| 409 RASTER_WORKER_POOL_TYPE_BITMAP)); | 409 RASTER_WORKER_POOL_TYPE_BITMAP)); |
| 410 | 410 |
| 411 } // namespace | 411 } // namespace |
| 412 } // namespace cc | 412 } // namespace cc |
| OLD | NEW |