| Index: base/threading/sequenced_worker_pool.cc
|
| diff --git a/base/threading/sequenced_worker_pool.cc b/base/threading/sequenced_worker_pool.cc
|
| index 234f908d950da922a7d9b11c215ba6c486670863..360fb4a537f2d27eb53aa904d83ecd3f33728d2d 100644
|
| --- a/base/threading/sequenced_worker_pool.cc
|
| +++ b/base/threading/sequenced_worker_pool.cc
|
| @@ -30,10 +30,10 @@
|
| #include "base/task_scheduler/post_task.h"
|
| #include "base/task_scheduler/task_scheduler.h"
|
| #include "base/threading/platform_thread.h"
|
| +#include "base/threading/sequenced_task_runner_handle.h"
|
| #include "base/threading/simple_thread.h"
|
| #include "base/threading/thread_local.h"
|
| #include "base/threading/thread_restrictions.h"
|
| -#include "base/threading/thread_task_runner_handle.h"
|
| #include "base/time/time.h"
|
| #include "base/trace_event/trace_event.h"
|
| #include "base/tracked_objects.h"
|
| @@ -1462,7 +1462,7 @@ void SequencedWorkerPool::ResetRedirectToTaskSchedulerForProcessForTesting() {
|
| SequencedWorkerPool::SequencedWorkerPool(size_t max_threads,
|
| const std::string& thread_name_prefix,
|
| base::TaskPriority task_priority)
|
| - : constructor_task_runner_(ThreadTaskRunnerHandle::Get()),
|
| + : constructor_task_runner_(SequencedTaskRunnerHandle::Get()),
|
| inner_(new Inner(this,
|
| max_threads,
|
| thread_name_prefix,
|
| @@ -1473,7 +1473,7 @@ SequencedWorkerPool::SequencedWorkerPool(size_t max_threads,
|
| const std::string& thread_name_prefix,
|
| base::TaskPriority task_priority,
|
| TestingObserver* observer)
|
| - : constructor_task_runner_(ThreadTaskRunnerHandle::Get()),
|
| + : constructor_task_runner_(SequencedTaskRunnerHandle::Get()),
|
| inner_(new Inner(this,
|
| max_threads,
|
| thread_name_prefix,
|
| @@ -1609,7 +1609,7 @@ void SequencedWorkerPool::SignalHasWorkForTesting() {
|
| }
|
|
|
| void SequencedWorkerPool::Shutdown(int max_new_blocking_tasks_after_shutdown) {
|
| - DCHECK(constructor_task_runner_->BelongsToCurrentThread());
|
| + DCHECK(constructor_task_runner_->RunsTasksOnCurrentThread());
|
| inner_->Shutdown(max_new_blocking_tasks_after_shutdown);
|
| }
|
|
|
|
|