OLD | NEW |
1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "components/sync/driver/model_type_controller.h" | 5 #include "components/sync/driver/model_type_controller.h" |
6 | 6 |
7 #include <utility> | 7 #include <utility> |
8 | 8 |
9 #include "base/bind.h" | 9 #include "base/bind.h" |
10 #include "base/callback.h" | 10 #include "base/callback.h" |
(...skipping 107 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
118 } // namespace | 118 } // namespace |
119 | 119 |
120 class ModelTypeControllerTest : public testing::Test, public FakeSyncClient { | 120 class ModelTypeControllerTest : public testing::Test, public FakeSyncClient { |
121 public: | 121 public: |
122 ModelTypeControllerTest() | 122 ModelTypeControllerTest() |
123 : model_thread_("modelthread"), sync_prefs_(GetPrefService()) {} | 123 : model_thread_("modelthread"), sync_prefs_(GetPrefService()) {} |
124 | 124 |
125 void SetUp() override { | 125 void SetUp() override { |
126 model_thread_.Start(); | 126 model_thread_.Start(); |
127 InitializeModelTypeService(); | 127 InitializeModelTypeService(); |
128 controller_.reset(new ModelTypeController( | 128 controller_ = base::MakeUnique<ModelTypeController>( |
129 kTestModelType, base::Closure(), this, model_thread_.task_runner())); | 129 kTestModelType, base::Closure(), this, model_thread_.task_runner()); |
130 } | 130 } |
131 | 131 |
132 void TearDown() override { | 132 void TearDown() override { |
133 ClearModelTypeService(); | 133 ClearModelTypeService(); |
134 PumpUIThread(); | 134 PumpUIThread(); |
135 } | 135 } |
136 | 136 |
137 base::WeakPtr<ModelTypeService> GetModelTypeServiceForType( | 137 base::WeakPtr<ModelTypeService> GetModelTypeServiceForType( |
138 ModelType type) override { | 138 ModelType type) override { |
139 return service_->AsWeakPtr(); | 139 return service_->AsWeakPtr(); |
(...skipping 73 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
213 ModelType type, | 213 ModelType type, |
214 ModelTypeService* service) { | 214 ModelTypeService* service) { |
215 std::unique_ptr<TestModelTypeProcessor> processor = | 215 std::unique_ptr<TestModelTypeProcessor> processor = |
216 base::MakeUnique<TestModelTypeProcessor>(&disable_sync_call_count_); | 216 base::MakeUnique<TestModelTypeProcessor>(&disable_sync_call_count_); |
217 processor_ = processor.get(); | 217 processor_ = processor.get(); |
218 return std::move(processor); | 218 return std::move(processor); |
219 } | 219 } |
220 | 220 |
221 void InitializeModelTypeService() { | 221 void InitializeModelTypeService() { |
222 if (model_thread_.task_runner()->BelongsToCurrentThread()) { | 222 if (model_thread_.task_runner()->BelongsToCurrentThread()) { |
223 service_.reset(new StubModelTypeService(base::Bind( | 223 service_ = base::MakeUnique<StubModelTypeService>(base::Bind( |
224 &ModelTypeControllerTest::CreateProcessor, base::Unretained(this)))); | 224 &ModelTypeControllerTest::CreateProcessor, base::Unretained(this))); |
225 } else { | 225 } else { |
226 model_thread_.task_runner()->PostTask( | 226 model_thread_.task_runner()->PostTask( |
227 FROM_HERE, | 227 FROM_HERE, |
228 base::Bind(&ModelTypeControllerTest::InitializeModelTypeService, | 228 base::Bind(&ModelTypeControllerTest::InitializeModelTypeService, |
229 base::Unretained(this))); | 229 base::Unretained(this))); |
230 PumpModelThread(); | 230 PumpModelThread(); |
231 } | 231 } |
232 } | 232 } |
233 | 233 |
234 void ClearModelTypeService() { | 234 void ClearModelTypeService() { |
(...skipping 137 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
372 | 372 |
373 // Clearing preferences emulates signing out. | 373 // Clearing preferences emulates signing out. |
374 sync_prefs()->ClearPreferences(); | 374 sync_prefs()->ClearPreferences(); |
375 controller()->Stop(); | 375 controller()->Stop(); |
376 EXPECT_EQ(DataTypeController::NOT_RUNNING, controller()->state()); | 376 EXPECT_EQ(DataTypeController::NOT_RUNNING, controller()->state()); |
377 // Ensure that DisableSync is not called. | 377 // Ensure that DisableSync is not called. |
378 EXPECT_EQ(0, disable_sync_call_count()); | 378 EXPECT_EQ(0, disable_sync_call_count()); |
379 } | 379 } |
380 | 380 |
381 } // namespace syncer | 381 } // namespace syncer |
OLD | NEW |