OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 "sync/sessions/model_type_registry.h" | 5 #include "components/sync/sessions_impl/model_type_registry.h" |
6 | 6 |
7 #include <utility> | 7 #include <utility> |
8 #include <vector> | 8 #include <vector> |
9 | 9 |
10 #include "base/deferred_sequenced_task_runner.h" | 10 #include "base/deferred_sequenced_task_runner.h" |
11 #include "base/memory/ptr_util.h" | 11 #include "base/memory/ptr_util.h" |
12 #include "base/message_loop/message_loop.h" | 12 #include "base/message_loop/message_loop.h" |
13 #include "sync/internal_api/public/activation_context.h" | 13 #include "components/sync/base/model_type.h" |
14 #include "sync/internal_api/public/base/model_type.h" | 14 #include "components/sync/core/activation_context.h" |
15 #include "sync/internal_api/public/test/fake_model_type_processor.h" | 15 #include "components/sync/core/test/fake_model_type_processor.h" |
16 #include "sync/protocol/data_type_state.pb.h" | 16 #include "components/sync/protocol/data_type_state.pb.h" |
17 #include "sync/syncable/directory.h" | 17 #include "components/sync/syncable/directory.h" |
18 #include "sync/syncable/model_neutral_mutable_entry.h" | 18 #include "components/sync/syncable/model_neutral_mutable_entry.h" |
19 #include "sync/syncable/syncable_model_neutral_write_transaction.h" | 19 #include "components/sync/syncable/syncable_model_neutral_write_transaction.h" |
20 #include "sync/test/engine/fake_model_worker.h" | 20 #include "components/sync/test/engine/fake_model_worker.h" |
21 #include "sync/test/engine/mock_nudge_handler.h" | 21 #include "components/sync/test/engine/mock_nudge_handler.h" |
22 #include "sync/test/engine/test_directory_setter_upper.h" | 22 #include "components/sync/test/engine/test_directory_setter_upper.h" |
23 #include "testing/gtest/include/gtest/gtest.h" | 23 #include "testing/gtest/include/gtest/gtest.h" |
24 | 24 |
25 namespace syncer { | 25 namespace syncer { |
26 | 26 |
27 class ModelTypeRegistryTest : public ::testing::Test { | 27 class ModelTypeRegistryTest : public ::testing::Test { |
28 public: | 28 public: |
29 ModelTypeRegistryTest(); | 29 ModelTypeRegistryTest(); |
30 void SetUp() override; | 30 void SetUp() override; |
31 void TearDown() override; | 31 void TearDown() override; |
32 | 32 |
(...skipping 26 matching lines...) Expand all Loading... |
59 entry.PutUniqueServerTag(ModelTypeToRootTag(type)); | 59 entry.PutUniqueServerTag(ModelTypeToRootTag(type)); |
60 directory()->MarkInitialSyncEndedForType(&trans, type); | 60 directory()->MarkInitialSyncEndedForType(&trans, type); |
61 } | 61 } |
62 | 62 |
63 private: | 63 private: |
64 syncable::Directory* directory(); | 64 syncable::Directory* directory(); |
65 | 65 |
66 base::MessageLoop message_loop_; | 66 base::MessageLoop message_loop_; |
67 | 67 |
68 TestDirectorySetterUpper dir_maker_; | 68 TestDirectorySetterUpper dir_maker_; |
69 std::vector<scoped_refptr<ModelSafeWorker> > workers_; | 69 std::vector<scoped_refptr<ModelSafeWorker>> workers_; |
70 std::unique_ptr<ModelTypeRegistry> registry_; | 70 std::unique_ptr<ModelTypeRegistry> registry_; |
71 MockNudgeHandler mock_nudge_handler_; | 71 MockNudgeHandler mock_nudge_handler_; |
72 }; | 72 }; |
73 | 73 |
74 ModelTypeRegistryTest::ModelTypeRegistryTest() {} | 74 ModelTypeRegistryTest::ModelTypeRegistryTest() {} |
75 | 75 |
76 void ModelTypeRegistryTest::SetUp() { | 76 void ModelTypeRegistryTest::SetUp() { |
77 dir_maker_.SetUp(); | 77 dir_maker_.SetUp(); |
78 scoped_refptr<ModelSafeWorker> passive_worker( | 78 scoped_refptr<ModelSafeWorker> passive_worker( |
79 new FakeModelWorker(GROUP_PASSIVE)); | 79 new FakeModelWorker(GROUP_PASSIVE)); |
80 scoped_refptr<ModelSafeWorker> ui_worker( | 80 scoped_refptr<ModelSafeWorker> ui_worker(new FakeModelWorker(GROUP_UI)); |
81 new FakeModelWorker(GROUP_UI)); | 81 scoped_refptr<ModelSafeWorker> db_worker(new FakeModelWorker(GROUP_DB)); |
82 scoped_refptr<ModelSafeWorker> db_worker( | |
83 new FakeModelWorker(GROUP_DB)); | |
84 workers_.push_back(passive_worker); | 82 workers_.push_back(passive_worker); |
85 workers_.push_back(ui_worker); | 83 workers_.push_back(ui_worker); |
86 workers_.push_back(db_worker); | 84 workers_.push_back(db_worker); |
87 | 85 |
88 registry_.reset( | 86 registry_.reset( |
89 new ModelTypeRegistry(workers_, directory(), &mock_nudge_handler_)); | 87 new ModelTypeRegistry(workers_, directory(), &mock_nudge_handler_)); |
90 } | 88 } |
91 | 89 |
92 void ModelTypeRegistryTest::TearDown() { | 90 void ModelTypeRegistryTest::TearDown() { |
93 registry_.reset(); | 91 registry_.reset(); |
(...skipping 178 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
272 syncer::THEMES, | 270 syncer::THEMES, |
273 MakeActivationContext( | 271 MakeActivationContext( |
274 data_type_state, | 272 data_type_state, |
275 base::WrapUnique(new syncer_v2::FakeModelTypeProcessor()))); | 273 base::WrapUnique(new syncer_v2::FakeModelTypeProcessor()))); |
276 | 274 |
277 EXPECT_EQ(ModelTypeSet(AUTOFILL, THEMES), | 275 EXPECT_EQ(ModelTypeSet(AUTOFILL, THEMES), |
278 registry()->GetInitialSyncEndedTypes()); | 276 registry()->GetInitialSyncEndedTypes()); |
279 } | 277 } |
280 | 278 |
281 } // namespace syncer | 279 } // namespace syncer |
OLD | NEW |