| Index: components/domain_reliability/dispatcher.cc
|
| diff --git a/components/domain_reliability/dispatcher.cc b/components/domain_reliability/dispatcher.cc
|
| index ceb4da09c8b5e6ca76129831eacb696cb93af012..d951cd2b8e842a62ef16da2f5b3e5b90c46ed78a 100644
|
| --- a/components/domain_reliability/dispatcher.cc
|
| +++ b/components/domain_reliability/dispatcher.cc
|
| @@ -12,6 +12,20 @@
|
|
|
| namespace domain_reliability {
|
|
|
| +struct DomainReliabilityDispatcher::Task {
|
| + Task(const base::Closure& closure,
|
| + scoped_ptr<MockableTime::Timer> timer,
|
| + base::TimeDelta min_delay,
|
| + base::TimeDelta max_delay);
|
| + ~Task();
|
| +
|
| + base::Closure closure;
|
| + scoped_ptr<MockableTime::Timer> timer;
|
| + base::TimeDelta min_delay;
|
| + base::TimeDelta max_delay;
|
| + bool eligible;
|
| +};
|
| +
|
| DomainReliabilityDispatcher::DomainReliabilityDispatcher(MockableTime* time)
|
| : time_(time) {}
|
|
|
| @@ -72,13 +86,11 @@ void DomainReliabilityDispatcher::MakeTaskWaiting(Task* task) {
|
| DCHECK(task);
|
| DCHECK(!task->eligible);
|
| DCHECK(!task->timer->IsRunning());
|
| - task->timer->Start(
|
| - FROM_HERE,
|
| - task->min_delay,
|
| - base::Bind(
|
| - &DomainReliabilityDispatcher::MakeTaskEligible,
|
| - base::Unretained(this),
|
| - task));
|
| + task->timer->Start(FROM_HERE,
|
| + task->min_delay,
|
| + base::Bind(&DomainReliabilityDispatcher::MakeTaskEligible,
|
| + base::Unretained(this),
|
| + task));
|
| }
|
|
|
| void
|
| @@ -87,13 +99,11 @@ DomainReliabilityDispatcher::MakeTaskEligible(Task* task) {
|
| DCHECK(!task->eligible);
|
| task->eligible = true;
|
| eligible_tasks_.insert(task);
|
| - task->timer->Start(
|
| - FROM_HERE,
|
| - task->max_delay - task->min_delay,
|
| - base::Bind(
|
| - &DomainReliabilityDispatcher::RunAndDeleteTask,
|
| - base::Unretained(this),
|
| - task));
|
| + task->timer->Start(FROM_HERE,
|
| + task->max_delay - task->min_delay,
|
| + base::Bind(&DomainReliabilityDispatcher::RunAndDeleteTask,
|
| + base::Unretained(this),
|
| + task));
|
| }
|
|
|
| void DomainReliabilityDispatcher::RunAndDeleteTask(Task* task) {
|
|
|