| Index: components/scheduler/base/task_queue_impl.h
|
| diff --git a/components/scheduler/base/task_queue_impl.h b/components/scheduler/base/task_queue_impl.h
|
| index aa84639426c4ac5e888402ee7e2cefd962342928..1f130e124eefa9c7a0b59ff9723989c349859351 100644
|
| --- a/components/scheduler/base/task_queue_impl.h
|
| +++ b/components/scheduler/base/task_queue_impl.h
|
| @@ -23,7 +23,7 @@
|
| class SCHEDULER_EXPORT TaskQueueImpl final : public TaskQueue {
|
| public:
|
| TaskQueueImpl(TaskQueueManager* task_queue_manager,
|
| - TimeDomain* time_domain,
|
| + const scoped_refptr<TimeDomain>& time_domain,
|
| const Spec& spec,
|
| const char* disabled_by_default_tracing_category,
|
| const char* disabled_by_default_verbose_tracing_category);
|
| @@ -70,6 +70,9 @@
|
| bool PostNonNestableDelayedTask(const tracked_objects::Location& from_here,
|
| const base::Closure& task,
|
| base::TimeDelta delay) override;
|
| + bool PostDelayedTaskAt(const tracked_objects::Location& from_here,
|
| + const base::Closure& task,
|
| + base::TimeTicks desired_run_time) override;
|
|
|
| bool IsQueueEnabled() const override;
|
| QueueState GetQueueState() const override;
|
| @@ -79,7 +82,7 @@
|
| void AddTaskObserver(base::MessageLoop::TaskObserver* task_observer) override;
|
| void RemoveTaskObserver(
|
| base::MessageLoop::TaskObserver* task_observer) override;
|
| - void SetTimeDomain(TimeDomain* time_domain) override;
|
| + void SetTimeDomain(const scoped_refptr<TimeDomain>& time_domain) override;
|
|
|
| void UpdateWorkQueue(LazyNow* lazy_now,
|
| bool should_trigger_wakeup,
|
| @@ -151,7 +154,7 @@
|
| struct AnyThread {
|
| AnyThread(TaskQueueManager* task_queue_manager,
|
| PumpPolicy pump_policy,
|
| - TimeDomain* time_domain);
|
| + const scoped_refptr<TimeDomain>& time_domain);
|
| ~AnyThread();
|
|
|
| // TaskQueueManager is maintained in two copies: inside AnyThread and inside
|
| @@ -162,7 +165,7 @@
|
| std::queue<Task> incoming_queue;
|
| PumpPolicy pump_policy;
|
| std::priority_queue<Task> delayed_task_queue;
|
| - TimeDomain* time_domain;
|
| + scoped_refptr<TimeDomain> time_domain;
|
| };
|
|
|
| struct MainThreadOnly {
|
| @@ -189,7 +192,7 @@
|
| const base::Closure& task,
|
| base::TimeTicks desired_run_time,
|
| TaskType task_type);
|
| - void ScheduleDelayedWorkTask(TimeDomain* time_domain,
|
| + void ScheduleDelayedWorkTask(const scoped_refptr<TimeDomain> time_domain,
|
| base::TimeTicks desired_run_time);
|
|
|
| // Enqueues any delayed tasks which should be run now on the incoming_queue_.
|
|
|