Re-land: cc: Add raster finished signals to RasterWorkerPool.

cc/resources/pixel_buffer_raster_worker_pool.cc

 // Copyright 2013 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "cc/resources/pixel_buffer_raster_worker_pool.h"
 
 #include "base/debug/trace_event.h"
 #include "cc/resources/resource.h"
 #include "third_party/skia/include/core/SkDevice.h"
 
@@ skipping 66 matching lines @@
 
 const int kCheckForCompletedRasterTasksDelayMs = 6;
 
 const size_t kMaxPendingRasterBytes =
     kMaxBytesUploadedPerMs * kCheckForCompletedRasterTasksDelayMs;
 
 }  // namespace
 
 PixelBufferRasterWorkerPool::PixelBufferRasterWorkerPool(
     ResourceProvider* resource_provider,
-    size_t num_threads) : RasterWorkerPool(resource_provider, num_threads),
-                          shutdown_(false),
-                          bytes_pending_upload_(0),
-                          has_performed_uploads_since_last_flush_(false),
-                          check_for_completed_raster_tasks_pending_(false) {
+    size_t num_threads)
+    : RasterWorkerPool(resource_provider, num_threads),
+      shutdown_(false),
+      bytes_pending_upload_(0),
+      has_performed_uploads_since_last_flush_(false),
+      check_for_completed_raster_tasks_pending_(false),
+      finished_running_tasks_pending_(false),
+      finished_running_tasks_required_for_activation_pending_(false) {
 }
 
 PixelBufferRasterWorkerPool::~PixelBufferRasterWorkerPool() {
   DCHECK(shutdown_);
   DCHECK(!check_for_completed_raster_tasks_pending_);
   DCHECK_EQ(0u, pixel_buffer_tasks_.size());
   DCHECK_EQ(0u, tasks_with_pending_upload_.size());
   DCHECK_EQ(0u, completed_tasks_.size());
 }
 
@@ skipping 12 matching lines @@
       completed_tasks_.push_back(task);
     }
   }
 }
 
 void PixelBufferRasterWorkerPool::ScheduleTasks(RasterTask::Queue* queue) {
   TRACE_EVENT0("cc", "PixelBufferRasterWorkerPool::ScheduleTasks");
 
   RasterWorkerPool::SetRasterTasks(queue);
 
+  finished_running_tasks_pending_ = true;
+  finished_running_tasks_required_for_activation_pending_ = true;
+
   // Build new pixel buffer task set.
   TaskMap new_pixel_buffer_tasks;
   for (RasterTaskVector::const_iterator it = raster_tasks().begin();
        it != raster_tasks().end(); ++it) {
     internal::RasterWorkerPoolTask* task = it->get();
     DCHECK(new_pixel_buffer_tasks.find(task) == new_pixel_buffer_tasks.end());
     DCHECK(!task->HasCompleted());
 
     // Use existing pixel buffer task if available.
     TaskMap::iterator pixel_buffer_it = pixel_buffer_tasks_.find(task);
@@ skipping 19 matching lines @@
     // Inactive task can be canceled.
     if (!pixel_buffer_task && !task->HasFinishedRunning()) {
       task->DidRun(true);
       DCHECK(std::find(completed_tasks_.begin(),
                        completed_tasks_.end(),
                        task) == completed_tasks_.end());
       completed_tasks_.push_back(task);
     }
   }
 
+  tasks_required_for_activation_.clear();
+  for (TaskMap::iterator it = new_pixel_buffer_tasks.begin();
+       it != new_pixel_buffer_tasks.end(); ++it) {
+    internal::RasterWorkerPoolTask* task = it->first;
+    if (IsRasterTaskRequiredForActivation(task)) {
+      DCHECK(std::find(tasks_required_for_activation_.begin(),

[vmpstr, 2013/06/21 18:38:33]

I don't think we need this dcheck. We already dcheck to ensure
new_pixel_buffer_tasks contains unique tasks above, and we clear the activation
list right above the loop.

[reveman, 2013/06/24 16:04:03]

Done.

+                       tasks_required_for_activation_.end(),
+                       task) == tasks_required_for_activation_.end());
+      tasks_required_for_activation_.insert(task);
+    }
+  }
+
   pixel_buffer_tasks_.swap(new_pixel_buffer_tasks);
 
   // This will schedule more tasks after checking for completed raster
   // tasks. It's worth checking for completed tasks when ScheduleTasks()
   // is called as priorities might have changed and this allows us to
   // schedule as many new top priority tasks as possible.
   CheckForCompletedRasterTasks();
 }
 
 void PixelBufferRasterWorkerPool::CheckForCompletedTasks() {
@@ skipping 16 matching lines @@
   }
 }
 
 void PixelBufferRasterWorkerPool::OnRasterTasksFinished() {
   // Call CheckForCompletedTasks() when we've finished running all raster
   // tasks needed since last time ScheduleMoreTasks() was called. This
   // reduces latency when processing only a small number of raster tasks.
   CheckForCompletedRasterTasks();
 }
 
+void PixelBufferRasterWorkerPool::
+    OnRasterTasksRequiredForActivationFinished() {
+  OnRasterTasksFinished();
+}
+
 void PixelBufferRasterWorkerPool::FlushUploads() {
   if (!has_performed_uploads_since_last_flush_)
     return;
 
   resource_provider()->ShallowFlushIfSupported();
   has_performed_uploads_since_last_flush_ = false;
 }
 
 void PixelBufferRasterWorkerPool::CheckForCompletedUploads() {
   TaskDeque tasks_with_completed_uploads;
@@ skipping 47 matching lines @@
 
     bytes_pending_upload_ -= task->resource()->bytes();
 
     task->DidRun(false);
 
     DCHECK(std::find(completed_tasks_.begin(),
                      completed_tasks_.end(),
                      task) == completed_tasks_.end());
     completed_tasks_.push_back(task);
 
+    tasks_required_for_activation_.erase(task);
+
     tasks_with_completed_uploads.pop_front();
   }
 }
 
 void PixelBufferRasterWorkerPool::ScheduleCheckForCompletedRasterTasks() {
   if (check_for_completed_raster_tasks_pending_)
     return;
 
   check_for_completed_raster_tasks_callback_.Reset(
       base::Bind(&PixelBufferRasterWorkerPool::CheckForCompletedRasterTasks,
                  base::Unretained(this)));
   base::MessageLoopProxy::current()->PostDelayedTask(
       FROM_HERE,
       check_for_completed_raster_tasks_callback_.callback(),
       base::TimeDelta::FromMilliseconds(kCheckForCompletedRasterTasksDelayMs));
   check_for_completed_raster_tasks_pending_ = true;
 }
 
 void PixelBufferRasterWorkerPool::CheckForCompletedRasterTasks() {
   TRACE_EVENT0(
       "cc", "PixelBufferRasterWorkerPool::CheckForCompletedRasterTasks");
 
   check_for_completed_raster_tasks_callback_.Cancel();
   check_for_completed_raster_tasks_pending_ = false;
 
   RasterWorkerPool::CheckForCompletedTasks();
   CheckForCompletedUploads();
   FlushUploads();
 
-  ScheduleMoreTasks();
+  if (NumPendingRasterTasks())
+    ScheduleMoreTasks();
 
-  // Make sure another check for completed uploads is scheduled
-  // while there is still pending uploads left.
-  if (!tasks_with_pending_upload_.empty())
+  // Schedule another check for completed raster tasks while there are
+  // pending raster tasks or pending uploads.
+  if (NumPendingRasterTasks() || !tasks_with_pending_upload_.empty())
     ScheduleCheckForCompletedRasterTasks();
+
+  CheckIfFinishedRunningTasks();
+  CheckIfFinishedRunningTasksRequiredForActivation();
 }
 
 void PixelBufferRasterWorkerPool::ScheduleMoreTasks() {
   TRACE_EVENT0("cc", "PixelBufferRasterWorkerPool::ScheduleMoreTasks");
 
   size_t bytes_pending_upload = bytes_pending_upload_;
   size_t bytes_pending_raster = 0;
 
   RasterTaskGraph graph;
   for (RasterTaskVector::const_iterator it = raster_tasks().begin();
@@ skipping 34 matching lines @@
     if (new_bytes_pending_raster > kMaxPendingRasterBytes)
       break;
 
     // Update both |bytes_pending_raster| and |bytes_pending_upload|
     // now that task has cleared all throttling limits.
     bytes_pending_raster = new_bytes_pending_raster;
     bytes_pending_upload = new_bytes_pending_upload;
 
     // Use existing pixel buffer task if available.
     if (pixel_buffer_task) {
-      graph.InsertRasterTask(pixel_buffer_task, task->dependencies());
+      graph.InsertRasterTask(pixel_buffer_task,
+                             task->dependencies(),
+                             IsRasterTaskRequiredForActivation(task));
       continue;
     }
 
     // Request a pixel buffer. This will reserve shared memory.
     resource_provider()->AcquirePixelBuffer(task->resource()->id());
 
     // MapPixelBuffer() returns NULL if context was lost at the time
     // AcquirePixelBuffer() was called. For simplicity we still post
     // a raster task that is essentially a noop in these situations.
     uint8* buffer = resource_provider()->MapPixelBuffer(
         task->resource()->id());
 
     scoped_refptr<internal::WorkerPoolTask> new_pixel_buffer_task(
         new PixelBufferWorkerPoolTaskImpl(
             task,
             buffer,
             base::Bind(&PixelBufferRasterWorkerPool::OnRasterTaskCompleted,
                        base::Unretained(this),
                        make_scoped_refptr(task))));
     pixel_buffer_tasks_[task] = new_pixel_buffer_task;
-    graph.InsertRasterTask(new_pixel_buffer_task.get(), task->dependencies());
+    graph.InsertRasterTask(new_pixel_buffer_task.get(),
+                           task->dependencies(),
+                           IsRasterTaskRequiredForActivation(task));
   }
 
   SetRasterTaskGraph(&graph);
-
-  // At least one task that could need an upload is now pending, schedule
-  // a check for completed raster tasks to ensure this upload is dispatched
-  // without too much latency.
-  if (bytes_pending_raster)
-    ScheduleCheckForCompletedRasterTasks();
 }
 
 void PixelBufferRasterWorkerPool::OnRasterTaskCompleted(
     scoped_refptr<internal::RasterWorkerPoolTask> task,
     bool was_canceled,
     bool needs_upload) {
   TRACE_EVENT2("cc", "PixelBufferRasterWorkerPool::OnRasterTaskCompleted",
                "was_canceled", was_canceled,
                "needs_upload", needs_upload);
 
   DCHECK(pixel_buffer_tasks_.find(task.get()) != pixel_buffer_tasks_.end());
 
   // Balanced with MapPixelBuffer() call in ScheduleMoreTasks().
   resource_provider()->UnmapPixelBuffer(task->resource()->id());
 
   if (!needs_upload) {
     resource_provider()->ReleasePixelBuffer(task->resource()->id());
     task->DidRun(was_canceled);
     DCHECK(std::find(completed_tasks_.begin(),
                      completed_tasks_.end(),
                      task) == completed_tasks_.end());
     completed_tasks_.push_back(task);
+    tasks_required_for_activation_.erase(task);
     return;
   }
 
   resource_provider()->BeginSetPixels(task->resource()->id());
   has_performed_uploads_since_last_flush_ = true;
 
   bytes_pending_upload_ += task->resource()->bytes();
   tasks_with_pending_upload_.push_back(task);
 }
 
+unsigned PixelBufferRasterWorkerPool::NumPendingRasterTasks() const {

[vmpstr, 2013/06/21 18:38:33]

nit: I prefer PendingRasterTaskCount

[reveman, 2013/06/24 16:04:03]

Done.

+  DCHECK_GE(pixel_buffer_tasks_.size(), completed_tasks_.size());
+  return pixel_buffer_tasks_.size() - completed_tasks_.size();
+}
+
+void PixelBufferRasterWorkerPool::CheckIfFinishedRunningTasks() {

[vmpstr, 2013/06/21 18:38:33]

Maybe something like NotifyClientIfFinishedRunningTasks? I think that would
better reflect what the function is doing

[reveman, 2013/06/24 16:04:03]

Done.

+  if (!finished_running_tasks_pending_)
+    return;
+
+  if (NumPendingRasterTasks())
+    return;
+
+  if (tasks_with_pending_upload_.empty())
+    return;
+
+  client()->DidFinishedRunningTasks();
+  finished_running_tasks_pending_ = false;
+}
+
+void PixelBufferRasterWorkerPool::
+    CheckIfFinishedRunningTasksRequiredForActivation() {

[vmpstr, 2013/06/21 18:38:33]

NotifyClient... The function name gets to be a bit too long though.

[reveman, 2013/06/24 16:04:03]

Done.

+  if (!finished_running_tasks_required_for_activation_pending_)
+    return;
+
+  if (!tasks_required_for_activation_.empty())
+    return;
+
+  client()->DidFinishedRunningTasksRequiredForActivation();
+  finished_running_tasks_required_for_activation_pending_ = false;
+}
+
 }  // namespace cc