Chromium Code Reviews| Index: chrome/browser/sync_file_system/drive_backend/sync_engine_unittest.cc |
| diff --git a/chrome/browser/sync_file_system/drive_backend/sync_engine_unittest.cc b/chrome/browser/sync_file_system/drive_backend/sync_engine_unittest.cc |
| index 13cc2c1400f652069c54860e7da99e7e989b9e50..2139519ab85b9f97cbe1aa3f07d697ef5f0435e6 100644 |
| --- a/chrome/browser/sync_file_system/drive_backend/sync_engine_unittest.cc |
| +++ b/chrome/browser/sync_file_system/drive_backend/sync_engine_unittest.cc |
| @@ -7,6 +7,7 @@ |
| #include "base/files/scoped_temp_dir.h" |
| #include "base/macros.h" |
| #include "base/run_loop.h" |
| +#include "base/test/sequenced_worker_pool_owner.h" |
| #include "base/thread_task_runner_handle.h" |
| #include "chrome/browser/sync_file_system/drive_backend/callback_helper.h" |
| #include "chrome/browser/sync_file_system/drive_backend/fake_sync_worker.h" |
| @@ -28,7 +29,7 @@ class SyncEngineTest : public testing::Test, |
| public: |
| typedef RemoteFileSyncService::OriginStatusMap RemoteOriginStatusMap; |
| - SyncEngineTest() {} |
| + SyncEngineTest() : worker_pool_owner_(1, "Worker") {} |
| ~SyncEngineTest() override {} |
| void SetUp() override { |
| @@ -37,27 +38,20 @@ class SyncEngineTest : public testing::Test, |
| scoped_ptr<drive::DriveServiceInterface> |
| fake_drive_service(new drive::FakeDriveService); |
| - worker_pool_ = new base::SequencedWorkerPool(1, "Worker"); |
| scoped_refptr<base::SingleThreadTaskRunner> ui_task_runner = |
| base::ThreadTaskRunnerHandle::Get(); |
| worker_task_runner_ = |
| - worker_pool_->GetSequencedTaskRunnerWithShutdownBehavior( |
| - worker_pool_->GetSequenceToken(), |
| + worker_pool_owner_.pool()->GetSequencedTaskRunnerWithShutdownBehavior( |
| + worker_pool_owner_.pool()->GetSequenceToken(), |
| base::SequencedWorkerPool::SKIP_ON_SHUTDOWN); |
| sync_engine_.reset(new drive_backend::SyncEngine( |
| - ui_task_runner.get(), |
|
brettw
2015/12/01 18:17:50
I found the old formatting here much better. If cl
tommycli
2015/12/02 19:57:04
Done. See if this patchset looks better. It's also
|
| - worker_task_runner_.get(), |
| - nullptr /* drive_task_runner */, |
| - worker_pool_.get(), |
| - profile_dir_.path(), |
| - nullptr /* task_logger */, |
| - nullptr /* notification_manager */, |
| - nullptr /* extension_service */, |
| - nullptr /* signin_manager */, |
| - nullptr /* token_service */, |
| - nullptr /* request_context */, |
| - nullptr /* drive_service_factory */, |
| + ui_task_runner.get(), worker_task_runner_.get(), |
| + nullptr /* drive_task_runner */, worker_pool_owner_.pool().get(), |
| + profile_dir_.path(), nullptr /* task_logger */, |
| + nullptr /* notification_manager */, nullptr /* extension_service */, |
| + nullptr /* signin_manager */, nullptr /* token_service */, |
| + nullptr /* request_context */, nullptr /* drive_service_factory */, |
| nullptr /* in_memory_env */)); |
| sync_engine_->InitializeForTesting( |
| @@ -73,12 +67,8 @@ class SyncEngineTest : public testing::Test, |
| void TearDown() override { |
| sync_engine_.reset(); |
| WaitForWorkerTaskRunner(); |
| - worker_pool_->Shutdown(); |
| worker_task_runner_ = nullptr; |
| - worker_pool_ = nullptr; |
| - |
| - base::RunLoop().RunUntilIdle(); |
| } |
| bool FindOriginStatus(const GURL& origin, std::string* status) { |
| @@ -131,7 +121,7 @@ class SyncEngineTest : public testing::Test, |
| base::ScopedTempDir profile_dir_; |
| scoped_ptr<drive_backend::SyncEngine> sync_engine_; |
| - scoped_refptr<base::SequencedWorkerPool> worker_pool_; |
| + base::SequencedWorkerPoolOwner worker_pool_owner_; |
| scoped_refptr<base::SequencedTaskRunner> worker_task_runner_; |
| DISALLOW_COPY_AND_ASSIGN(SyncEngineTest); |