Report expected task queueing time via UMA

components/scheduler/base/task_queue_manager_perftest.cc

 // 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.
 
 #include "components/scheduler/base/task_queue_manager.h"
 
 #include <stddef.h>
 
 #include "base/bind.h"
 #include "base/memory/ptr_util.h"
 #include "base/threading/thread.h"
 #include "base/time/default_tick_clock.h"
 #include "components/scheduler/base/task_queue_impl.h"
 #include "components/scheduler/base/task_queue_manager_delegate_for_test.h"
 #include "components/scheduler/base/task_queue_selector.h"
+#include "components/scheduler/base/task_time_tracker.h"
 #include "components/scheduler/base/work_queue_sets.h"
 #include "testing/gtest/include/gtest/gtest.h"
 #include "testing/perf/perf_test.h"
 
 namespace scheduler {
 
 class TaskQueueManagerPerfTest : public testing::Test {
  public:
   TaskQueueManagerPerfTest()
       : num_queues_(0),
         max_tasks_in_flight_(0),
         num_tasks_in_flight_(0),
         num_tasks_to_post_(0),
-        num_tasks_to_run_(0) {}
+        num_tasks_to_run_(0),
+        task_time_tracker_(nullptr) {}
 
   void SetUp() override {
     if (base::ThreadTicks::IsSupported())
       base::ThreadTicks::WaitUntilInitialized();
   }
 
   void Initialize(size_t num_queues) {
     num_queues_ = num_queues;
     message_loop_.reset(new base::MessageLoop());
     manager_ = base::WrapUnique(new TaskQueueManager(
         TaskQueueManagerDelegateForTest::Create(
             message_loop_->task_runner(),
             base::WrapUnique(new base::DefaultTickClock())),
         "fake.category", "fake.category", "fake.category.debug"));
+    manager_->SetTaskTimeTracker(&task_time_tracker_);
     for (size_t i = 0; i < num_queues; i++)
       queues_.push_back(manager_->NewTaskQueue(TaskQueue::Spec("test")));
   }
 
   void TestDelayedTask() {
     if (--num_tasks_to_run_ == 0) {
       message_loop_->QuitWhenIdle();
     }
 
     num_tasks_in_flight_--;
@@ skipping 50 matching lines @@
   }
 
   size_t num_queues_;
   unsigned int max_tasks_in_flight_;
   unsigned int num_tasks_in_flight_;
   unsigned int num_tasks_to_post_;
   unsigned int num_tasks_to_run_;
   std::unique_ptr<TaskQueueManager> manager_;
   std::unique_ptr<base::MessageLoop> message_loop_;
   std::vector<scoped_refptr<base::SingleThreadTaskRunner>> queues_;
+  TaskTimeTracker task_time_tracker_;

[alex clarke (OOO till 29th), 2016/07/06 09:51:39]

Can you add a TODO(alexclarke): parameterize so we can measure with and without
this

[tdresser, 2016/07/06 13:25:34]

Done.

 };
 
 TEST_F(TaskQueueManagerPerfTest, RunTenThousandDelayedTasks_OneQueue) {
   if (!base::ThreadTicks::IsSupported())
     return;
   Initialize(1u);
 
   max_tasks_in_flight_ = 200;
   Benchmark("run 10000 delayed tasks with one queue",
             base::Bind(&TaskQueueManagerPerfTest::ResetAndCallTestDelayedTask,
@@ skipping 30 matching lines @@
   max_tasks_in_flight_ = 200;
   Benchmark("run 10000 delayed tasks with eight queues",
             base::Bind(&TaskQueueManagerPerfTest::ResetAndCallTestDelayedTask,
                        base::Unretained(this), 10000));
 }
 
 // TODO(alexclarke): Add additional tests with different mixes of non-delayed vs
 // delayed tasks.
 
 }  // namespace scheduler