| Index: components/sync_driver/non_ui_data_type_controller_unittest.cc
|
| diff --git a/components/sync_driver/non_ui_data_type_controller_unittest.cc b/components/sync_driver/non_ui_data_type_controller_unittest.cc
|
| index 27fe04e3f0907ac474f274e6f999211c281ac38f..8a3b8efc60b3919aa54c5d50eec57d35b5919344 100644
|
| --- a/components/sync_driver/non_ui_data_type_controller_unittest.cc
|
| +++ b/components/sync_driver/non_ui_data_type_controller_unittest.cc
|
| @@ -8,10 +8,12 @@
|
| #include "base/bind_helpers.h"
|
| #include "base/callback.h"
|
| #include "base/compiler_specific.h"
|
| +#include "base/location.h"
|
| #include "base/memory/scoped_ptr.h"
|
| -#include "base/message_loop/message_loop.h"
|
| +#include "base/single_thread_task_runner.h"
|
| #include "base/synchronization/waitable_event.h"
|
| #include "base/test/test_timeouts.h"
|
| +#include "base/thread_task_runner_handle.h"
|
| #include "base/threading/thread.h"
|
| #include "base/tracked_objects.h"
|
| #include "components/sync_driver/data_type_controller_mock.h"
|
| @@ -96,15 +98,14 @@ class NonUIDataTypeControllerFake
|
| SyncApiComponentFactory* sync_factory,
|
| NonUIDataTypeControllerMock* mock,
|
| SharedChangeProcessor* change_processor,
|
| - scoped_refptr<base::MessageLoopProxy> backend_loop)
|
| - : NonUIDataTypeController(
|
| - base::MessageLoopProxy::current(),
|
| - base::Closure(),
|
| - sync_factory),
|
| + scoped_refptr<base::SingleThreadTaskRunner> backend_task_runner)
|
| + : NonUIDataTypeController(base::ThreadTaskRunnerHandle::Get(),
|
| + base::Closure(),
|
| + sync_factory),
|
| blocked_(false),
|
| mock_(mock),
|
| change_processor_(change_processor),
|
| - backend_loop_(backend_loop) {}
|
| + backend_task_runner_(backend_task_runner) {}
|
|
|
| syncer::ModelType type() const override { return AUTOFILL_PROFILE; }
|
| syncer::ModelSafeGroup model_safe_group() const override {
|
| @@ -139,7 +140,7 @@ class NonUIDataTypeControllerFake
|
| pending_tasks_.push_back(PendingTask(from_here, task));
|
| return true;
|
| } else {
|
| - return backend_loop_->PostTask(from_here, task);
|
| + return backend_task_runner_->PostTask(from_here, task);
|
| }
|
| }
|
|
|
| @@ -172,7 +173,7 @@ class NonUIDataTypeControllerFake
|
| std::vector<PendingTask> pending_tasks_;
|
| NonUIDataTypeControllerMock* mock_;
|
| scoped_refptr<SharedChangeProcessor> change_processor_;
|
| - scoped_refptr<base::MessageLoopProxy> backend_loop_;
|
| + scoped_refptr<base::SingleThreadTaskRunner> backend_task_runner_;
|
| };
|
|
|
| class SyncNonUIDataTypeControllerTest : public testing::Test {
|
| @@ -185,21 +186,18 @@ class SyncNonUIDataTypeControllerTest : public testing::Test {
|
| change_processor_ = new SharedChangeProcessorMock();
|
| // All of these are refcounted, so don't need to be released.
|
| dtc_mock_ = new StrictMock<NonUIDataTypeControllerMock>();
|
| - non_ui_dtc_ =
|
| - new NonUIDataTypeControllerFake(NULL,
|
| - dtc_mock_.get(),
|
| - change_processor_.get(),
|
| - backend_thread_.message_loop_proxy());
|
| + non_ui_dtc_ = new NonUIDataTypeControllerFake(
|
| + NULL, dtc_mock_.get(), change_processor_.get(),
|
| + backend_thread_.task_runner());
|
| }
|
|
|
| void TearDown() override { backend_thread_.Stop(); }
|
|
|
| void WaitForDTC() {
|
| WaitableEvent done(true, false);
|
| - backend_thread_.message_loop_proxy()->PostTask(
|
| - FROM_HERE,
|
| - base::Bind(&SyncNonUIDataTypeControllerTest::SignalDone,
|
| - &done));
|
| + backend_thread_.task_runner()->PostTask(
|
| + FROM_HERE,
|
| + base::Bind(&SyncNonUIDataTypeControllerTest::SignalDone, &done));
|
| done.TimedWait(TestTimeouts::action_timeout());
|
| if (!done.IsSignaled()) {
|
| ADD_FAILURE() << "Timed out waiting for DB thread to finish.";
|
| @@ -481,11 +479,11 @@ TEST_F(SyncNonUIDataTypeControllerTest, OnSingleDataTypeUnrecoverableError) {
|
| syncer::SyncError::DATATYPE_ERROR,
|
| "error",
|
| non_ui_dtc_->type());
|
| - backend_thread_.message_loop_proxy()->PostTask(FROM_HERE, base::Bind(
|
| - &NonUIDataTypeControllerFake::
|
| - OnSingleDataTypeUnrecoverableError,
|
| - non_ui_dtc_.get(),
|
| - error));
|
| + backend_thread_.task_runner()->PostTask(
|
| + FROM_HERE,
|
| + base::Bind(
|
| + &NonUIDataTypeControllerFake::OnSingleDataTypeUnrecoverableError,
|
| + non_ui_dtc_.get(), error));
|
| WaitForDTC();
|
| }
|
|
|
|
|