components/domain_reliability/dispatcher.h

   1 // Copyright 2014 The Chromium Authors. All rights reserved.
   2 // Use of this source code is governed by a BSD-style license that can be
   3 // found in the LICENSE file.
   4
   5 #ifndef COMPONENTS_DOMAIN_RELIABILITY_DISPATCHER_H_
   6 #define COMPONENTS_DOMAIN_RELIABILITY_DISPATCHER_H_
   7
   8 #include <set>
   9
  10 #include "base/callback.h"
  11 #include "base/memory/scoped_vector.h"
  12 #include "base/time/time.h"
  13 #include "components/domain_reliability/domain_reliability_export.h"
  14 #include "components/domain_reliability/util.h"
  15
  16 namespace tracked_objects {
  17 class Location;
  18 }  // namespace tracked_objects
  19
  20 namespace domain_reliability {
  21
  22 // Runs tasks during a specified interval. Calling |RunEligibleTasks| gives any
  23 // task a chance to run early (if the minimum delay has already passed); tasks
  24 // that aren't run early will be run once their maximum delay has passed.
  25 //
  26 // (See scheduler.h for an explanation of how the intervals are chosen.)
  27 class DOMAIN_RELIABILITY_EXPORT DomainReliabilityDispatcher {
  28  public:
  29   DomainReliabilityDispatcher(MockableTime* time);
  30   ~DomainReliabilityDispatcher();
  31
  32   void ScheduleTask(
  33       const base::Closure& task,
  34       base::TimeDelta min_delay,
  35       base::TimeDelta max_delay);
  36
  37   void RunEligibleTasks();
  38
  39  private:
  40   struct Task {
  41     Task(const base::Closure& closure_p,
  42          scoped_ptr<MockableTime::Timer> timer_p,
  43          base::TimeDelta min_delay_p,
  44          base::TimeDelta max_delay_p);
  45     ~Task();
  46
  47     base::Closure closure;
  48     scoped_ptr<MockableTime::Timer> timer;
  49     base::TimeDelta min_delay;
  50     base::TimeDelta max_delay;
  51     bool eligible;
  52   };
  53
  54   void MakeTaskWaiting(Task* task);
  55   void MakeTaskEligible(Task* task);
  56   void RunAndDeleteTask(Task* task);
  57
  58   MockableTime* time_;
  59   std::set<Task*> tasks_;
  60   std::set<Task*> eligible_tasks_;
  61 };
  62
  63 }  // namespace domain_reliability
  64
  65 #endif