Test dynamic priorities on android (1F + 1B)

content/renderer/raster_worker_pool.h

 // Copyright 2015 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.
 
 #ifndef CONTENT_RENDERER_RASTER_WORKER_POOL_H_
 #define CONTENT_RENDERER_RASTER_WORKER_POOL_H_
 
 #include "base/callback.h"
 #include "base/containers/hash_tables.h"
 #include "base/macros.h"
@@ skipping 30 matching lines @@
 
   // Overridden from cc::TaskGraphRunner:
   cc::NamespaceToken GetNamespaceToken() override;
   void ScheduleTasks(cc::NamespaceToken token, cc::TaskGraph* graph) override;
   void WaitForTasksToFinishRunning(cc::NamespaceToken token) override;
   void CollectCompletedTasks(cc::NamespaceToken token,
                              cc::Task::Vector* completed_tasks) override;
 
   // Runs a task from one of the provided categories. Categories listed first
   // have higher priority.
-  void Run(const std::vector<cc::TaskCategory>& categories,
+  void Run(base::TestSimpleThread* runner,
+           const std::vector<cc::TaskCategory>& categories,
            base::ConditionVariable* has_ready_to_run_tasks_cv);
 
   void FlushForTesting();
 
   // Spawn |num_threads| number of threads and start running work on the
   // worker threads.
   void Start(int num_threads);
 
   // Finish running all the posted tasks (and nested task posted by those tasks)
   // of all the associated task runners.
@@ skipping 32 matching lines @@
     DISALLOW_COPY_AND_ASSIGN(ClosureTask);
   };
 
   void ScheduleTasksWithLockAcquired(cc::NamespaceToken token,
                                      cc::TaskGraph* graph);
   void CollectCompletedTasksWithLockAcquired(cc::NamespaceToken token,
                                              cc::Task::Vector* completed_tasks);
 
   // Runs a task from one of the provided categories. Categories listed first
   // have higher priority. Returns false if there were no tasks to run.
-  bool RunTaskWithLockAcquired(const std::vector<cc::TaskCategory>& categories);
+  bool RunTaskWithLockAcquired(base::TestSimpleThread* runner,
+                               const std::vector<cc::TaskCategory>& categories);
 
   // Run next task for the given category. Caller must acquire |lock_| prior to
   // calling this function and make sure at least one task is ready to run.
-  void RunTaskInCategoryWithLockAcquired(cc::TaskCategory category);
+  void RunTaskInCategoryWithLockAcquired(base::TestSimpleThread* runner,
+                                         cc::TaskCategory category);
 
   // Helper function which signals worker threads if tasks are ready to run.
   void SignalHasReadyToRunTasksWithLockAcquired();
 
   // Determines if we should run a new task for the given category. This factors
   // in whether a task is available and whether the count of running tasks is
   // low enough to start a new one.
   bool ShouldRunTaskForCategoryWithLockAcquired(cc::TaskCategory category);
 
   // The actual threads where work is done.
@@ skipping 19 matching lines @@
   // Condition variable that is waited on by origin threads until a namespace
   // has finished running all associated tasks.
   base::ConditionVariable has_namespaces_with_finished_running_tasks_cv_;
   // Set during shutdown. Tells Run() to return when no more tasks are pending.
   bool shutdown_;
 };
 
 }  // namespace content
 
 #endif  // CONTENT_RENDERER_RASTER_WORKER_POOL_H_