cc: Move internal::Task::did_schedule_ to internal::WorkerPoolTask.

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/containers/stack_container.h"
 #include "base/debug/trace_event.h"
 #include "base/values.h"
 #include "cc/debug/traced_value.h"
@@ skipping 114 matching lines @@
 
       new_raster_task_states[task] = state;
       // |raster_tasks_required_for_activation_| contains all tasks that need to
       // complete before we can send a "ready to activate" signal. Tasks that
       // have already completed should not be part of this set.
       if (state != COMPLETED && IsRasterTaskRequiredForActivation(task))
         raster_tasks_required_for_activation_.insert(task);
 
       raster_task_states_.erase(state_it);
     } else {
+      DCHECK(!task->HasBeenScheduled());
       new_raster_task_states[task] = UNSCHEDULED;
       if (IsRasterTaskRequiredForActivation(task))
         raster_tasks_required_for_activation_.insert(task);
     }
   }
 
   // Transfer old raster task state to |new_raster_task_states| and cancel all
   // remaining unscheduled tasks.
   for (RasterTaskStateMap::iterator it = raster_task_states_.begin();
        it != raster_task_states_.end();
        ++it) {
     internal::RasterWorkerPoolTask* task = it->first;
     DCHECK(new_raster_task_states.find(task) == new_raster_task_states.end());
     DCHECK(!IsRasterTaskRequiredForActivation(task));
 
     // Unscheduled task can be canceled.
     if (it->second == UNSCHEDULED) {
+      DCHECK(!task->HasBeenScheduled());
       DCHECK(std::find(completed_raster_tasks_.begin(),
                        completed_raster_tasks_.end(),
                        task) == completed_raster_tasks_.end());
       completed_raster_tasks_.push_back(task);
       new_raster_task_states[task] = COMPLETED;
       continue;
     }
 
     // Move state to |new_raster_task_states|.
     new_raster_task_states[task] = it->second;
@@ skipping 356 matching lines @@
     // All raster tasks need to be throttled by bytes of pending uploads.
     size_t new_bytes_pending_upload = bytes_pending_upload;
     new_bytes_pending_upload += task->resource()->bytes();
     if (new_bytes_pending_upload > max_bytes_pending_upload_) {
       did_throttle_raster_tasks = true;
       break;
     }
 
     // If raster has finished, just update |bytes_pending_upload|.
     if (state_it->second == UPLOADING) {
+      DCHECK(task->HasCompleted());
       bytes_pending_upload = new_bytes_pending_upload;
       continue;
     }
 
     // Throttle raster tasks based on kMaxScheduledRasterTasks.
     size_t scheduled_raster_task_count =
         tasks[PREPAINT_TYPE].container().size() +
         tasks[REQUIRED_FOR_ACTIVATION_TYPE].container().size();
     if (scheduled_raster_task_count >= kMaxScheduledRasterTasks) {
       did_throttle_raster_tasks = true;
       break;
     }
 
     // Update |bytes_pending_upload| now that task has cleared all
     // throttling limits.
     bytes_pending_upload = new_bytes_pending_upload;
 
     RasterTaskType type = IsRasterTaskRequiredForActivation(task)
                               ? REQUIRED_FOR_ACTIVATION_TYPE
                               : PREPAINT_TYPE;
 
-    task->ScheduleOnOriginThread(this);
     DCHECK(state_it->second == UNSCHEDULED || state_it->second == SCHEDULED);
     state_it->second = SCHEDULED;
 
     tasks[type].container().push_back(CreateGraphNodeForRasterTask(
         task, task->dependencies(), priority++, &graph));
   }
 
   scoped_refptr<internal::WorkerPoolTask>
       new_raster_required_for_activation_finished_task;
 
@@ skipping 112 matching lines @@
 
   throttle_state->SetInteger("bytes_available_for_upload",
                              max_bytes_pending_upload_ - bytes_pending_upload_);
   throttle_state->SetInteger("bytes_pending_upload", bytes_pending_upload_);
   throttle_state->SetInteger("scheduled_raster_task_count",
                              scheduled_raster_task_count_);
   return throttle_state.PassAs<base::Value>();
 }
 
 }  // namespace cc