| Index: cc/resources/zero_copy_tile_task_worker_pool.cc
|
| diff --git a/cc/resources/zero_copy_raster_worker_pool.cc b/cc/resources/zero_copy_tile_task_worker_pool.cc
|
| similarity index 57%
|
| rename from cc/resources/zero_copy_raster_worker_pool.cc
|
| rename to cc/resources/zero_copy_tile_task_worker_pool.cc
|
| index ca2bc9b01e10ed5ec68ba2c5791a60d0eb72d02c..6ef78f4b6ed2679f341c466ee4bb0cfae1956d2b 100644
|
| --- a/cc/resources/zero_copy_raster_worker_pool.cc
|
| +++ b/cc/resources/zero_copy_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/zero_copy_raster_worker_pool.h"
|
| +#include "cc/resources/zero_copy_tile_task_worker_pool.h"
|
|
|
| #include <algorithm>
|
|
|
| @@ -31,7 +31,7 @@ class RasterBufferImpl : public RasterBuffer {
|
| if (!gpu_memory_buffer)
|
| return;
|
|
|
| - RasterWorkerPool::PlaybackToMemory(
|
| + TileTaskWorkerPool::PlaybackToMemory(
|
| gpu_memory_buffer->Map(), resource_->format(), resource_->size(),
|
| gpu_memory_buffer->GetStride(), raster_source, rect, scale);
|
| gpu_memory_buffer->Unmap();
|
| @@ -47,15 +47,15 @@ class RasterBufferImpl : public RasterBuffer {
|
| } // namespace
|
|
|
| // static
|
| -scoped_ptr<RasterWorkerPool> ZeroCopyRasterWorkerPool::Create(
|
| +scoped_ptr<TileTaskWorkerPool> ZeroCopyTileTaskWorkerPool::Create(
|
| base::SequencedTaskRunner* task_runner,
|
| TaskGraphRunner* task_graph_runner,
|
| ResourceProvider* resource_provider) {
|
| - return make_scoped_ptr<RasterWorkerPool>(new ZeroCopyRasterWorkerPool(
|
| + return make_scoped_ptr<TileTaskWorkerPool>(new ZeroCopyTileTaskWorkerPool(
|
| task_runner, task_graph_runner, resource_provider));
|
| }
|
|
|
| -ZeroCopyRasterWorkerPool::ZeroCopyRasterWorkerPool(
|
| +ZeroCopyTileTaskWorkerPool::ZeroCopyTileTaskWorkerPool(
|
| base::SequencedTaskRunner* task_runner,
|
| TaskGraphRunner* task_graph_runner,
|
| ResourceProvider* resource_provider)
|
| @@ -63,60 +63,58 @@ ZeroCopyRasterWorkerPool::ZeroCopyRasterWorkerPool(
|
| 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) {
|
| }
|
|
|
| -ZeroCopyRasterWorkerPool::~ZeroCopyRasterWorkerPool() {
|
| +ZeroCopyTileTaskWorkerPool::~ZeroCopyTileTaskWorkerPool() {
|
| }
|
|
|
| -Rasterizer* ZeroCopyRasterWorkerPool::AsRasterizer() {
|
| +TileTaskRunner* ZeroCopyTileTaskWorkerPool::AsTileTaskRunner() {
|
| return this;
|
| }
|
|
|
| -void ZeroCopyRasterWorkerPool::SetClient(RasterizerClient* client) {
|
| +void ZeroCopyTileTaskWorkerPool::SetClient(TileTaskRunnerClient* client) {
|
| client_ = client;
|
| }
|
|
|
| -void ZeroCopyRasterWorkerPool::Shutdown() {
|
| - TRACE_EVENT0("cc", "ZeroCopyRasterWorkerPool::Shutdown");
|
| +void ZeroCopyTileTaskWorkerPool::Shutdown() {
|
| + TRACE_EVENT0("cc", "ZeroCopyTileTaskWorkerPool::Shutdown");
|
|
|
| TaskGraph empty;
|
| task_graph_runner_->ScheduleTasks(namespace_token_, &empty);
|
| task_graph_runner_->WaitForTasksToFinishRunning(namespace_token_);
|
| }
|
|
|
| -void ZeroCopyRasterWorkerPool::ScheduleTasks(RasterTaskQueue* queue) {
|
| - TRACE_EVENT0("cc", "ZeroCopyRasterWorkerPool::ScheduleTasks");
|
| +void ZeroCopyTileTaskWorkerPool::ScheduleTasks(TileTaskQueue* queue) {
|
| + TRACE_EVENT0("cc", "ZeroCopyTileTaskWorkerPool::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(&ZeroCopyRasterWorkerPool::OnRasterFinished,
|
| - raster_finished_weak_ptr_factory_.GetWeakPtr(),
|
| - task_set));
|
| + base::Bind(&ZeroCopyTileTaskWorkerPool::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());
|
|
|
| @@ -127,39 +125,36 @@ void ZeroCopyRasterWorkerPool::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 ZeroCopyRasterWorkerPool::CheckForCompletedTasks() {
|
| - TRACE_EVENT0("cc", "ZeroCopyRasterWorkerPool::CheckForCompletedTasks");
|
| +void ZeroCopyTileTaskWorkerPool::CheckForCompletedTasks() {
|
| + TRACE_EVENT0("cc", "ZeroCopyTileTaskWorkerPool::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);
|
| @@ -170,40 +165,40 @@ void ZeroCopyRasterWorkerPool::CheckForCompletedTasks() {
|
| completed_tasks_.clear();
|
| }
|
|
|
| -scoped_ptr<RasterBuffer> ZeroCopyRasterWorkerPool::AcquireBufferForRaster(
|
| +scoped_ptr<RasterBuffer> ZeroCopyTileTaskWorkerPool::AcquireBufferForRaster(
|
| const Resource* resource) {
|
| return make_scoped_ptr<RasterBuffer>(
|
| new RasterBufferImpl(resource_provider_, resource));
|
| }
|
|
|
| -void ZeroCopyRasterWorkerPool::ReleaseBufferForRaster(
|
| +void ZeroCopyTileTaskWorkerPool::ReleaseBufferForRaster(
|
| scoped_ptr<RasterBuffer> buffer) {
|
| // Nothing to do here. RasterBufferImpl destructor cleans up after itself.
|
| }
|
|
|
| -void ZeroCopyRasterWorkerPool::OnRasterFinished(TaskSet task_set) {
|
| - TRACE_EVENT1(
|
| - "cc", "ZeroCopyRasterWorkerPool::OnRasterFinished", "task_set", task_set);
|
| +void ZeroCopyTileTaskWorkerPool::OnTaskSetFinished(TaskSet task_set) {
|
| + TRACE_EVENT1("cc", "ZeroCopyTileTaskWorkerPool::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>
|
| -ZeroCopyRasterWorkerPool::StateAsValue() const {
|
| +ZeroCopyTileTaskWorkerPool::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;
|
| }
|
|
|