| Index: cc/resources/bitmap_tile_task_worker_pool.cc
|
| diff --git a/cc/resources/bitmap_raster_worker_pool.cc b/cc/resources/bitmap_tile_task_worker_pool.cc
|
| similarity index 54%
|
| rename from cc/resources/bitmap_raster_worker_pool.cc
|
| rename to cc/resources/bitmap_tile_task_worker_pool.cc
|
| index a7adf4ee9da4aec01e3d07f0382c5b0558ccee58..c4bd1f270854973a94a9cefe1868b35bc92ec3fb 100644
|
| --- a/cc/resources/bitmap_raster_worker_pool.cc
|
| +++ b/cc/resources/bitmap_tile_task_worker_pool.cc
|
| @@ -2,7 +2,7 @@
|
| // Use of this source code is governed by a BSD-style license that can be
|
| // found in the LICENSE file.
|
|
|
| -#include "cc/resources/bitmap_raster_worker_pool.h"
|
| +#include "cc/resources/bitmap_tile_task_worker_pool.h"
|
|
|
| #include <algorithm>
|
|
|
| @@ -27,9 +27,9 @@ class RasterBufferImpl : public RasterBuffer {
|
| void Playback(const RasterSource* raster_source,
|
| const gfx::Rect& rect,
|
| float scale) override {
|
| - RasterWorkerPool::PlaybackToMemory(lock_.sk_bitmap().getPixels(),
|
| - resource_->format(), resource_->size(),
|
| - 0, raster_source, rect, scale);
|
| + TileTaskWorkerPool::PlaybackToMemory(lock_.sk_bitmap().getPixels(),
|
| + resource_->format(), resource_->size(),
|
| + 0, raster_source, rect, scale);
|
| }
|
|
|
| private:
|
| @@ -42,15 +42,15 @@ class RasterBufferImpl : public RasterBuffer {
|
| } // namespace
|
|
|
| // static
|
| -scoped_ptr<RasterWorkerPool> BitmapRasterWorkerPool::Create(
|
| +scoped_ptr<TileTaskWorkerPool> BitmapTileTaskWorkerPool::Create(
|
| base::SequencedTaskRunner* task_runner,
|
| TaskGraphRunner* task_graph_runner,
|
| ResourceProvider* resource_provider) {
|
| - return make_scoped_ptr<RasterWorkerPool>(new BitmapRasterWorkerPool(
|
| + return make_scoped_ptr<TileTaskWorkerPool>(new BitmapTileTaskWorkerPool(
|
| task_runner, task_graph_runner, resource_provider));
|
| }
|
|
|
| -BitmapRasterWorkerPool::BitmapRasterWorkerPool(
|
| +BitmapTileTaskWorkerPool::BitmapTileTaskWorkerPool(
|
| base::SequencedTaskRunner* task_runner,
|
| TaskGraphRunner* task_graph_runner,
|
| ResourceProvider* resource_provider)
|
| @@ -58,60 +58,58 @@ BitmapRasterWorkerPool::BitmapRasterWorkerPool(
|
| task_graph_runner_(task_graph_runner),
|
| namespace_token_(task_graph_runner->GetNamespaceToken()),
|
| resource_provider_(resource_provider),
|
| - raster_finished_weak_ptr_factory_(this) {
|
| + task_set_finished_weak_ptr_factory_(this) {
|
| }
|
|
|
| -BitmapRasterWorkerPool::~BitmapRasterWorkerPool() {
|
| +BitmapTileTaskWorkerPool::~BitmapTileTaskWorkerPool() {
|
| }
|
|
|
| -Rasterizer* BitmapRasterWorkerPool::AsRasterizer() {
|
| +TileTaskRunner* BitmapTileTaskWorkerPool::AsTileTaskRunner() {
|
| return this;
|
| }
|
|
|
| -void BitmapRasterWorkerPool::SetClient(RasterizerClient* client) {
|
| +void BitmapTileTaskWorkerPool::SetClient(TileTaskRunnerClient* client) {
|
| client_ = client;
|
| }
|
|
|
| -void BitmapRasterWorkerPool::Shutdown() {
|
| - TRACE_EVENT0("cc", "BitmapRasterWorkerPool::Shutdown");
|
| +void BitmapTileTaskWorkerPool::Shutdown() {
|
| + TRACE_EVENT0("cc", "BitmapTileTaskWorkerPool::Shutdown");
|
|
|
| TaskGraph empty;
|
| task_graph_runner_->ScheduleTasks(namespace_token_, &empty);
|
| task_graph_runner_->WaitForTasksToFinishRunning(namespace_token_);
|
| }
|
|
|
| -void BitmapRasterWorkerPool::ScheduleTasks(RasterTaskQueue* queue) {
|
| - TRACE_EVENT0("cc", "BitmapRasterWorkerPool::ScheduleTasks");
|
| +void BitmapTileTaskWorkerPool::ScheduleTasks(TileTaskQueue* queue) {
|
| + TRACE_EVENT0("cc", "BitmapTileTaskWorkerPool::ScheduleTasks");
|
|
|
| - if (raster_pending_.none())
|
| + if (tasks_pending_.none())
|
| TRACE_EVENT_ASYNC_BEGIN0("cc", "ScheduledTasks", this);
|
|
|
| // Mark all task sets as pending.
|
| - raster_pending_.set();
|
| + tasks_pending_.set();
|
|
|
| - unsigned priority = kRasterTaskPriorityBase;
|
| + unsigned priority = kTileTaskPriorityBase;
|
|
|
| graph_.Reset();
|
|
|
| - // Cancel existing OnRasterFinished callbacks.
|
| - raster_finished_weak_ptr_factory_.InvalidateWeakPtrs();
|
| + // Cancel existing OnTaskSetFinished callbacks.
|
| + task_set_finished_weak_ptr_factory_.InvalidateWeakPtrs();
|
|
|
| - scoped_refptr<RasterizerTask> new_raster_finished_tasks[kNumberOfTaskSets];
|
| + scoped_refptr<TileTask> new_task_set_finished_tasks[kNumberOfTaskSets];
|
|
|
| size_t task_count[kNumberOfTaskSets] = {0};
|
|
|
| for (TaskSet task_set = 0; task_set < kNumberOfTaskSets; ++task_set) {
|
| - new_raster_finished_tasks[task_set] = CreateRasterFinishedTask(
|
| + new_task_set_finished_tasks[task_set] = CreateTaskSetFinishedTask(
|
| task_runner_.get(),
|
| - base::Bind(&BitmapRasterWorkerPool::OnRasterFinished,
|
| - raster_finished_weak_ptr_factory_.GetWeakPtr(),
|
| - task_set));
|
| + base::Bind(&BitmapTileTaskWorkerPool::OnTaskSetFinished,
|
| + task_set_finished_weak_ptr_factory_.GetWeakPtr(), task_set));
|
| }
|
|
|
| - for (RasterTaskQueue::Item::Vector::const_iterator it = queue->items.begin();
|
| - it != queue->items.end();
|
| - ++it) {
|
| - const RasterTaskQueue::Item& item = *it;
|
| + for (TileTaskQueue::Item::Vector::const_iterator it = queue->items.begin();
|
| + it != queue->items.end(); ++it) {
|
| + const TileTaskQueue::Item& item = *it;
|
| RasterTask* task = item.task;
|
| DCHECK(!task->HasCompleted());
|
|
|
| @@ -122,39 +120,36 @@ void BitmapRasterWorkerPool::ScheduleTasks(RasterTaskQueue* queue) {
|
| ++task_count[task_set];
|
|
|
| graph_.edges.push_back(
|
| - TaskGraph::Edge(task, new_raster_finished_tasks[task_set].get()));
|
| + TaskGraph::Edge(task, new_task_set_finished_tasks[task_set].get()));
|
| }
|
|
|
| InsertNodesForRasterTask(&graph_, task, task->dependencies(), priority++);
|
| }
|
|
|
| for (TaskSet task_set = 0; task_set < kNumberOfTaskSets; ++task_set) {
|
| - InsertNodeForTask(&graph_,
|
| - new_raster_finished_tasks[task_set].get(),
|
| - kRasterFinishedTaskPriority,
|
| - task_count[task_set]);
|
| + InsertNodeForTask(&graph_, new_task_set_finished_tasks[task_set].get(),
|
| + kTaskSetFinishedTaskPriority, task_count[task_set]);
|
| }
|
|
|
| ScheduleTasksOnOriginThread(this, &graph_);
|
| task_graph_runner_->ScheduleTasks(namespace_token_, &graph_);
|
|
|
| - std::copy(new_raster_finished_tasks,
|
| - new_raster_finished_tasks + kNumberOfTaskSets,
|
| - raster_finished_tasks_);
|
| + std::copy(new_task_set_finished_tasks,
|
| + new_task_set_finished_tasks + kNumberOfTaskSets,
|
| + task_set_finished_tasks_);
|
|
|
| - TRACE_EVENT_ASYNC_STEP_INTO1(
|
| - "cc", "ScheduledTasks", this, "rasterizing", "state", StateAsValue());
|
| + TRACE_EVENT_ASYNC_STEP_INTO1("cc", "ScheduledTasks", this, "running", "state",
|
| + StateAsValue());
|
| }
|
|
|
| -void BitmapRasterWorkerPool::CheckForCompletedTasks() {
|
| - TRACE_EVENT0("cc", "BitmapRasterWorkerPool::CheckForCompletedTasks");
|
| +void BitmapTileTaskWorkerPool::CheckForCompletedTasks() {
|
| + TRACE_EVENT0("cc", "BitmapTileTaskWorkerPool::CheckForCompletedTasks");
|
|
|
| task_graph_runner_->CollectCompletedTasks(namespace_token_,
|
| &completed_tasks_);
|
| for (Task::Vector::const_iterator it = completed_tasks_.begin();
|
| - it != completed_tasks_.end();
|
| - ++it) {
|
| - RasterizerTask* task = static_cast<RasterizerTask*>(it->get());
|
| + it != completed_tasks_.end(); ++it) {
|
| + TileTask* task = static_cast<TileTask*>(it->get());
|
|
|
| task->WillComplete();
|
| task->CompleteOnOriginThread(this);
|
| @@ -165,40 +160,40 @@ void BitmapRasterWorkerPool::CheckForCompletedTasks() {
|
| completed_tasks_.clear();
|
| }
|
|
|
| -scoped_ptr<RasterBuffer> BitmapRasterWorkerPool::AcquireBufferForRaster(
|
| +scoped_ptr<RasterBuffer> BitmapTileTaskWorkerPool::AcquireBufferForRaster(
|
| const Resource* resource) {
|
| return make_scoped_ptr<RasterBuffer>(
|
| new RasterBufferImpl(resource_provider_, resource));
|
| }
|
|
|
| -void BitmapRasterWorkerPool::ReleaseBufferForRaster(
|
| +void BitmapTileTaskWorkerPool::ReleaseBufferForRaster(
|
| scoped_ptr<RasterBuffer> buffer) {
|
| // Nothing to do here. RasterBufferImpl destructor cleans up after itself.
|
| }
|
|
|
| -void BitmapRasterWorkerPool::OnRasterFinished(TaskSet task_set) {
|
| - TRACE_EVENT1(
|
| - "cc", "BitmapRasterWorkerPool::OnRasterFinished", "task_set", task_set);
|
| +void BitmapTileTaskWorkerPool::OnTaskSetFinished(TaskSet task_set) {
|
| + TRACE_EVENT1("cc", "BitmapTileTaskWorkerPool::OnTaskSetFinished", "task_set",
|
| + task_set);
|
|
|
| - DCHECK(raster_pending_[task_set]);
|
| - raster_pending_[task_set] = false;
|
| - if (raster_pending_.any()) {
|
| - TRACE_EVENT_ASYNC_STEP_INTO1(
|
| - "cc", "ScheduledTasks", this, "rasterizing", "state", StateAsValue());
|
| + DCHECK(tasks_pending_[task_set]);
|
| + tasks_pending_[task_set] = false;
|
| + if (tasks_pending_.any()) {
|
| + TRACE_EVENT_ASYNC_STEP_INTO1("cc", "ScheduledTasks", this, "running",
|
| + "state", StateAsValue());
|
| } else {
|
| TRACE_EVENT_ASYNC_END0("cc", "ScheduledTasks", this);
|
| }
|
| - client_->DidFinishRunningTasks(task_set);
|
| + client_->DidFinishRunningTileTasks(task_set);
|
| }
|
|
|
| scoped_refptr<base::debug::ConvertableToTraceFormat>
|
| -BitmapRasterWorkerPool::StateAsValue() const {
|
| +BitmapTileTaskWorkerPool::StateAsValue() const {
|
| scoped_refptr<base::debug::TracedValue> state =
|
| new base::debug::TracedValue();
|
|
|
| state->BeginArray("tasks_pending");
|
| for (TaskSet task_set = 0; task_set < kNumberOfTaskSets; ++task_set)
|
| - state->AppendBoolean(raster_pending_[task_set]);
|
| + state->AppendBoolean(tasks_pending_[task_set]);
|
| state->EndArray();
|
| return state;
|
| }
|
|
|