Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(124)

Unified Diff: chrome/browser/sync/test/integration/two_client_uss_sync_test.cc

Issue 2458013002: [Sync] Rename ModelTypeService to ModelTypeSyncBridge. (Closed)
Patch Set: s/SetBridgeError/ErrorOnNextCall Created 4 years, 2 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « chrome/browser/sync/chrome_sync_client.cc ('k') | components/browser_sync/profile_sync_service.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: chrome/browser/sync/test/integration/two_client_uss_sync_test.cc
diff --git a/chrome/browser/sync/test/integration/two_client_uss_sync_test.cc b/chrome/browser/sync/test/integration/two_client_uss_sync_test.cc
index c0d5bb212a0f5aecb5f4ec450a78f516fa45f3c7..c1a597d01587ba3402366ebfcbbe4a96d806e053 100644
--- a/chrome/browser/sync/test/integration/two_client_uss_sync_test.cc
+++ b/chrome/browser/sync/test/integration/two_client_uss_sync_test.cc
@@ -14,16 +14,16 @@
#include "chrome/browser/sync/test/integration/sync_test.h"
#include "components/browser_sync/profile_sync_components_factory_impl.h"
#include "components/browser_sync/profile_sync_service.h"
-#include "components/sync/model/fake_model_type_service.h"
+#include "components/sync/model/fake_model_type_sync_bridge.h"
#include "components/sync/model/metadata_change_list.h"
#include "components/sync/model/model_type_change_processor.h"
using browser_sync::ChromeSyncClient;
using browser_sync::ProfileSyncComponentsFactoryImpl;
using syncer::ConflictResolution;
-using syncer::FakeModelTypeService;
+using syncer::FakeModelTypeSyncBridge;
using syncer::ModelTypeChangeProcessor;
-using syncer::ModelTypeService;
+using syncer::ModelTypeSyncBridge;
namespace {
@@ -36,33 +36,33 @@ const char kValue2[] = "value2";
const char kValue3[] = "value3";
const char* kPassphrase = "12345";
-// A ChromeSyncClient that provides a ModelTypeService for PREFERENCES.
+// A ChromeSyncClient that provides a ModelTypeSyncBridge for PREFERENCES.
class TestSyncClient : public ChromeSyncClient {
public:
- TestSyncClient(Profile* profile, ModelTypeService* service)
- : ChromeSyncClient(profile), service_(service) {}
+ TestSyncClient(Profile* profile, ModelTypeSyncBridge* bridge)
+ : ChromeSyncClient(profile), bridge_(bridge) {}
- base::WeakPtr<ModelTypeService> GetModelTypeServiceForType(
+ base::WeakPtr<ModelTypeSyncBridge> GetSyncBridgeForModelType(
syncer::ModelType type) override {
return type == syncer::PREFERENCES
- ? service_->AsWeakPtr()
- : ChromeSyncClient::GetModelTypeServiceForType(type);
+ ? bridge_->AsWeakPtr()
+ : ChromeSyncClient::GetSyncBridgeForModelType(type);
}
private:
- ModelTypeService* const service_;
+ ModelTypeSyncBridge* const bridge_;
};
-// A FakeModelTypeService that supports observing ApplySyncChanges.
-class TestModelTypeService : public FakeModelTypeService {
+// A FakeModelTypeSyncBridge that supports observing ApplySyncChanges.
+class TestModelTypeSyncBridge : public FakeModelTypeSyncBridge {
public:
class Observer {
public:
virtual void OnApplySyncChanges() = 0;
};
- TestModelTypeService()
- : FakeModelTypeService(base::Bind(&ModelTypeChangeProcessor::Create)) {
+ TestModelTypeSyncBridge()
+ : FakeModelTypeSyncBridge(base::Bind(&ModelTypeChangeProcessor::Create)) {
change_processor()->OnMetadataLoaded(syncer::SyncError(),
db().CreateMetadataBatch());
}
@@ -70,7 +70,7 @@ class TestModelTypeService : public FakeModelTypeService {
syncer::SyncError ApplySyncChanges(
std::unique_ptr<syncer::MetadataChangeList> metadata_changes,
syncer::EntityChangeList entity_changes) override {
- syncer::SyncError error = FakeModelTypeService::ApplySyncChanges(
+ syncer::SyncError error = FakeModelTypeSyncBridge::ApplySyncChanges(
std::move(metadata_changes), entity_changes);
NotifyObservers();
return error;
@@ -90,34 +90,34 @@ class TestModelTypeService : public FakeModelTypeService {
};
// A StatusChangeChecker for checking the status of keys in a
-// TestModelTypeService::Store.
+// TestModelTypeSyncBridge::Store.
class KeyChecker : public StatusChangeChecker,
- public TestModelTypeService::Observer {
+ public TestModelTypeSyncBridge::Observer {
public:
- KeyChecker(TestModelTypeService* service, const std::string& key)
- : service_(service), key_(key) {
- service_->AddObserver(this);
+ KeyChecker(TestModelTypeSyncBridge* bridge, const std::string& key)
+ : bridge_(bridge), key_(key) {
+ bridge_->AddObserver(this);
}
- ~KeyChecker() override { service_->RemoveObserver(this); }
+ ~KeyChecker() override { bridge_->RemoveObserver(this); }
void OnApplySyncChanges() override { CheckExitCondition(); }
protected:
- TestModelTypeService* const service_;
+ TestModelTypeSyncBridge* const bridge_;
const std::string key_;
};
// Wait for data for a key to have a certain value.
class DataChecker : public KeyChecker {
public:
- DataChecker(TestModelTypeService* service,
+ DataChecker(TestModelTypeSyncBridge* bridge,
const std::string& key,
const std::string& value)
- : KeyChecker(service, key), value_(value) {}
+ : KeyChecker(bridge, key), value_(value) {}
bool IsExitConditionSatisfied() override {
- const auto& db = service_->db();
+ const auto& db = bridge_->db();
return db.HasData(key_) && db.GetValue(key_) == value_;
}
@@ -132,11 +132,11 @@ class DataChecker : public KeyChecker {
// Wait for data for a key to be absent.
class DataAbsentChecker : public KeyChecker {
public:
- DataAbsentChecker(TestModelTypeService* service, const std::string& key)
- : KeyChecker(service, key) {}
+ DataAbsentChecker(TestModelTypeSyncBridge* bridge, const std::string& key)
+ : KeyChecker(bridge, key) {}
bool IsExitConditionSatisfied() override {
- return !service_->db().HasData(key_);
+ return !bridge_->db().HasData(key_);
}
std::string GetDebugMessage() const override {
@@ -147,11 +147,12 @@ class DataAbsentChecker : public KeyChecker {
// Wait for metadata for a key to be present.
class MetadataPresentChecker : public KeyChecker {
public:
- MetadataPresentChecker(TestModelTypeService* service, const std::string& key)
- : KeyChecker(service, key) {}
+ MetadataPresentChecker(TestModelTypeSyncBridge* bridge,
+ const std::string& key)
+ : KeyChecker(bridge, key) {}
bool IsExitConditionSatisfied() override {
- return service_->db().HasMetadata(key_);
+ return bridge_->db().HasMetadata(key_);
}
std::string GetDebugMessage() const override {
@@ -162,11 +163,11 @@ class MetadataPresentChecker : public KeyChecker {
// Wait for metadata for a key to be absent.
class MetadataAbsentChecker : public KeyChecker {
public:
- MetadataAbsentChecker(TestModelTypeService* service, const std::string& key)
- : KeyChecker(service, key) {}
+ MetadataAbsentChecker(TestModelTypeSyncBridge* bridge, const std::string& key)
+ : KeyChecker(bridge, key) {}
bool IsExitConditionSatisfied() override {
- return !service_->db().HasMetadata(key_);
+ return !bridge_->db().HasMetadata(key_);
}
std::string GetDebugMessage() const override {
@@ -207,8 +208,8 @@ class TwoClientUssSyncTest : public SyncTest {
bool TestUsesSelfNotifications() override { return false; }
- TestModelTypeService* GetModelTypeService(int i) {
- return services_.at(i).get();
+ TestModelTypeSyncBridge* GetModelTypeSyncBridge(int i) {
+ return bridges_.at(i).get();
}
protected:
@@ -218,15 +219,15 @@ class TwoClientUssSyncTest : public SyncTest {
first_client_ignored_ = true;
return base::MakeUnique<ChromeSyncClient>(profile);
}
- auto service = base::MakeUnique<TestModelTypeService>();
- auto client = base::MakeUnique<TestSyncClient>(profile, service.get());
+ auto bridge = base::MakeUnique<TestModelTypeSyncBridge>();
+ auto client = base::MakeUnique<TestSyncClient>(profile, bridge.get());
clients_.push_back(client.get());
- services_.push_back(std::move(service));
+ bridges_.push_back(std::move(bridge));
return std::move(client);
}
ProfileSyncServiceFactory::SyncClientFactory sync_client_factory_;
- std::vector<std::unique_ptr<TestModelTypeService>> services_;
+ std::vector<std::unique_ptr<TestModelTypeSyncBridge>> bridges_;
std::vector<TestSyncClient*> clients_;
bool first_client_ignored_ = false;
@@ -237,9 +238,9 @@ class TwoClientUssSyncTest : public SyncTest {
IN_PROC_BROWSER_TEST_F(TwoClientUssSyncTest, Sanity) {
ASSERT_TRUE(SetupSync());
ASSERT_EQ(2U, clients_.size());
- ASSERT_EQ(2U, services_.size());
- TestModelTypeService* model0 = GetModelTypeService(0);
- TestModelTypeService* model1 = GetModelTypeService(1);
+ ASSERT_EQ(2U, bridges_.size());
+ TestModelTypeSyncBridge* model0 = GetModelTypeSyncBridge(0);
+ TestModelTypeSyncBridge* model1 = GetModelTypeSyncBridge(1);
// Add an entity.
model0->WriteItem(kKey1, kValue1);
@@ -256,8 +257,8 @@ IN_PROC_BROWSER_TEST_F(TwoClientUssSyncTest, Sanity) {
IN_PROC_BROWSER_TEST_F(TwoClientUssSyncTest, DisableEnable) {
ASSERT_TRUE(SetupSync());
- TestModelTypeService* model0 = GetModelTypeService(0);
- TestModelTypeService* model1 = GetModelTypeService(1);
+ TestModelTypeSyncBridge* model0 = GetModelTypeSyncBridge(0);
+ TestModelTypeSyncBridge* model1 = GetModelTypeSyncBridge(1);
// Add an entity to test with.
model0->WriteItem(kKey1, kValue1);
@@ -293,34 +294,34 @@ IN_PROC_BROWSER_TEST_F(TwoClientUssSyncTest, DisableEnable) {
IN_PROC_BROWSER_TEST_F(TwoClientUssSyncTest, ConflictResolution) {
ASSERT_TRUE(SetupSync());
- TestModelTypeService* model0 = GetModelTypeService(0);
- TestModelTypeService* model1 = GetModelTypeService(1);
+ TestModelTypeSyncBridge* model0 = GetModelTypeSyncBridge(0);
+ TestModelTypeSyncBridge* model1 = GetModelTypeSyncBridge(1);
model0->SetConflictResolution(ConflictResolution::UseNew(
- FakeModelTypeService::GenerateEntityData(kKey1, kValue3)));
+ FakeModelTypeSyncBridge::GenerateEntityData(kKey1, kValue3)));
model1->SetConflictResolution(ConflictResolution::UseNew(
- FakeModelTypeService::GenerateEntityData(kKey1, kValue3)));
+ FakeModelTypeSyncBridge::GenerateEntityData(kKey1, kValue3)));
// Write conflicting entities.
model0->WriteItem(kKey1, kValue1);
model1->WriteItem(kKey1, kValue2);
// Wait for them to be resolved to kResolutionValue by the custom conflict
- // resolution logic in TestModelTypeService.
+ // resolution logic in TestModelTypeSyncBridge.
ASSERT_TRUE(DataChecker(model0, kKey1, kValue3).Wait());
ASSERT_TRUE(DataChecker(model1, kKey1, kValue3).Wait());
}
IN_PROC_BROWSER_TEST_F(TwoClientUssSyncTest, Error) {
ASSERT_TRUE(SetupSync());
- TestModelTypeService* model0 = GetModelTypeService(0);
- TestModelTypeService* model1 = GetModelTypeService(1);
+ TestModelTypeSyncBridge* model0 = GetModelTypeSyncBridge(0);
+ TestModelTypeSyncBridge* model1 = GetModelTypeSyncBridge(1);
// Add an entity.
model0->WriteItem(kKey1, kValue1);
ASSERT_TRUE(DataChecker(model1, kKey1, kValue1).Wait());
// Set an error in model 1 to trigger in the next GetUpdates.
- model1->SetServiceError(syncer::SyncError::DATATYPE_ERROR);
+ model1->ErrorOnNextCall(syncer::SyncError::DATATYPE_ERROR);
// Write an item on model 0 to trigger a GetUpdates in model 1.
model0->WriteItem(kKey1, kValue2);
@@ -333,8 +334,8 @@ IN_PROC_BROWSER_TEST_F(TwoClientUssSyncTest, Error) {
IN_PROC_BROWSER_TEST_F(TwoClientUssSyncTest, Encryption) {
ASSERT_TRUE(SetupSync());
- TestModelTypeService* model0 = GetModelTypeService(0);
- TestModelTypeService* model1 = GetModelTypeService(1);
+ TestModelTypeSyncBridge* model0 = GetModelTypeSyncBridge(0);
+ TestModelTypeSyncBridge* model1 = GetModelTypeSyncBridge(1);
model0->WriteItem(kKey1, kValue1);
ASSERT_TRUE(DataChecker(model1, kKey1, kValue1).Wait());
« no previous file with comments | « chrome/browser/sync/chrome_sync_client.cc ('k') | components/browser_sync/profile_sync_service.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698