| Index: base/task_scheduler/delayed_task_manager.cc
|
| diff --git a/base/task_scheduler/delayed_task_manager.cc b/base/task_scheduler/delayed_task_manager.cc
|
| index 47f9bbc83a02dfb3bc2b5c0353ec71c2fcbee141..d648b9d4628fab6324b9e8474daffa607692f0d8 100644
|
| --- a/base/task_scheduler/delayed_task_manager.cc
|
| +++ b/base/task_scheduler/delayed_task_manager.cc
|
| @@ -15,12 +15,12 @@ namespace internal {
|
| struct DelayedTaskManager::DelayedTask {
|
| DelayedTask(std::unique_ptr<Task> task,
|
| scoped_refptr<Sequence> sequence,
|
| - SchedulerWorkerThread* worker_thread,
|
| + SchedulerWorker* worker,
|
| SchedulerWorkerPool* worker_pool,
|
| uint64_t index)
|
| : task(std::move(task)),
|
| sequence(std::move(sequence)),
|
| - worker_thread(worker_thread),
|
| + worker(worker),
|
| worker_pool(worker_pool),
|
| index(index) {}
|
|
|
| @@ -30,11 +30,11 @@ struct DelayedTaskManager::DelayedTask {
|
|
|
| DelayedTask& operator=(DelayedTask&& other) = default;
|
|
|
| - // |task| will be posted to |worker_pool| with |sequence| and |worker_thread|
|
| + // |task| will be posted to |worker_pool| with |sequence| and |worker|
|
| // when it becomes ripe for execution.
|
| std::unique_ptr<Task> task;
|
| scoped_refptr<Sequence> sequence;
|
| - SchedulerWorkerThread* worker_thread;
|
| + SchedulerWorker* worker;
|
| SchedulerWorkerPool* worker_pool;
|
|
|
| // Ensures that tasks that have the same |delayed_run_time| are sorted
|
| @@ -55,7 +55,7 @@ DelayedTaskManager::~DelayedTaskManager() = default;
|
|
|
| void DelayedTaskManager::AddDelayedTask(std::unique_ptr<Task> task,
|
| scoped_refptr<Sequence> sequence,
|
| - SchedulerWorkerThread* worker_thread,
|
| + SchedulerWorker* worker,
|
| SchedulerWorkerPool* worker_pool) {
|
| DCHECK(task);
|
| DCHECK(sequence);
|
| @@ -70,7 +70,7 @@ void DelayedTaskManager::AddDelayedTask(std::unique_ptr<Task> task,
|
| if (!delayed_tasks_.empty())
|
| current_delayed_run_time = delayed_tasks_.top().task->delayed_run_time;
|
|
|
| - delayed_tasks_.emplace(std::move(task), std::move(sequence), worker_thread,
|
| + delayed_tasks_.emplace(std::move(task), std::move(sequence), worker,
|
| worker_pool, ++delayed_task_index_);
|
| }
|
|
|
| @@ -105,7 +105,7 @@ void DelayedTaskManager::PostReadyTasks() {
|
| for (auto& delayed_task : ready_tasks) {
|
| delayed_task.worker_pool->PostTaskWithSequenceNow(
|
| std::move(delayed_task.task), std::move(delayed_task.sequence),
|
| - delayed_task.worker_thread);
|
| + delayed_task.worker);
|
| }
|
| }
|
|
|
|
|