Index: sync/engine/sync_scheduler_unittest.cc |
diff --git a/sync/engine/sync_scheduler_unittest.cc b/sync/engine/sync_scheduler_unittest.cc |
index 2b9ea8733ef0864bffba36e783819a88469618c1..0c6db7a8834d94567a04e8cce7cfd145d470bbdb 100644 |
--- a/sync/engine/sync_scheduler_unittest.cc |
+++ b/sync/engine/sync_scheduler_unittest.cc |
@@ -189,13 +189,13 @@ class SyncSchedulerTest : public testing::Test { |
scheduler_->delay_provider_.reset(delay_); |
} |
- // Compare a ModelTypeSet to a ModelTypePayloadMap, ignoring |
- // payload values. |
- bool CompareModelTypeSetToModelTypePayloadMap( |
+ // Compare a ModelTypeSet to a ModelTypeStateMap, ignoring |
+ // state values. |
+ bool CompareModelTypeSetToModelTypeStateMap( |
ModelTypeSet lhs, |
- const ModelTypePayloadMap& rhs) { |
+ const ModelTypeStateMap& rhs) { |
size_t count = 0; |
- for (ModelTypePayloadMap::const_iterator i = rhs.begin(); |
+ for (ModelTypeStateMap::const_iterator i = rhs.begin(); |
i != rhs.end(); ++i, ++count) { |
if (!lhs.Has(i->first)) |
return false; |
@@ -271,7 +271,7 @@ TEST_F(SyncSchedulerTest, Nudge) { |
RunLoop(); |
ASSERT_EQ(1U, records.snapshots.size()); |
- EXPECT_TRUE(CompareModelTypeSetToModelTypePayloadMap(model_types, |
+ EXPECT_TRUE(CompareModelTypeSetToModelTypeStateMap(model_types, |
records.snapshots[0].source().types)); |
EXPECT_EQ(GetUpdatesCallerInfo::LOCAL, |
records.snapshots[0].source().updates_source); |
@@ -290,7 +290,7 @@ TEST_F(SyncSchedulerTest, Nudge) { |
RunLoop(); |
ASSERT_EQ(1U, records2.snapshots.size()); |
- EXPECT_TRUE(CompareModelTypeSetToModelTypePayloadMap(model_types, |
+ EXPECT_TRUE(CompareModelTypeSetToModelTypeStateMap(model_types, |
records2.snapshots[0].source().types)); |
EXPECT_EQ(GetUpdatesCallerInfo::LOCAL, |
records2.snapshots[0].source().updates_source); |
@@ -318,7 +318,7 @@ TEST_F(SyncSchedulerTest, Config) { |
ASSERT_EQ(1, counter.times_called()); |
ASSERT_EQ(1U, records.snapshots.size()); |
- EXPECT_TRUE(CompareModelTypeSetToModelTypePayloadMap(model_types, |
+ EXPECT_TRUE(CompareModelTypeSetToModelTypeStateMap(model_types, |
records.snapshots[0].source().types)); |
EXPECT_EQ(GetUpdatesCallerInfo::RECONFIGURATION, |
records.snapshots[0].source().updates_source); |
@@ -355,7 +355,7 @@ TEST_F(SyncSchedulerTest, ConfigWithBackingOff) { |
ASSERT_EQ(2U, records.snapshots.size()); |
ASSERT_EQ(1, counter.times_called()); |
- EXPECT_TRUE(CompareModelTypeSetToModelTypePayloadMap(model_types, |
+ EXPECT_TRUE(CompareModelTypeSetToModelTypeStateMap(model_types, |
records.snapshots[1].source().types)); |
EXPECT_EQ(GetUpdatesCallerInfo::RECONFIGURATION, |
records.snapshots[1].source().updates_source); |
@@ -408,12 +408,12 @@ TEST_F(SyncSchedulerTest, NudgeWithConfigWithBackingOff) { |
ASSERT_EQ(4U, records.snapshots.size()); |
- EXPECT_TRUE(CompareModelTypeSetToModelTypePayloadMap(model_types, |
+ EXPECT_TRUE(CompareModelTypeSetToModelTypeStateMap(model_types, |
records.snapshots[2].source().types)); |
EXPECT_EQ(GetUpdatesCallerInfo::RECONFIGURATION, |
records.snapshots[2].source().updates_source); |
- EXPECT_TRUE(CompareModelTypeSetToModelTypePayloadMap(model_types, |
+ EXPECT_TRUE(CompareModelTypeSetToModelTypeStateMap(model_types, |
records.snapshots[3].source().types)); |
EXPECT_EQ(GetUpdatesCallerInfo::LOCAL, |
records.snapshots[3].source().updates_source); |
@@ -439,7 +439,7 @@ TEST_F(SyncSchedulerTest, NudgeCoalescing) { |
ASSERT_EQ(1U, r.snapshots.size()); |
EXPECT_GE(r.times[0], optimal_time); |
- EXPECT_TRUE(CompareModelTypeSetToModelTypePayloadMap( |
+ EXPECT_TRUE(CompareModelTypeSetToModelTypeStateMap( |
Union(types1, types2), r.snapshots[0].source().types)); |
EXPECT_EQ(GetUpdatesCallerInfo::LOCAL, |
r.snapshots[0].source().updates_source); |
@@ -455,7 +455,7 @@ TEST_F(SyncSchedulerTest, NudgeCoalescing) { |
RunLoop(); |
ASSERT_EQ(1U, r2.snapshots.size()); |
- EXPECT_TRUE(CompareModelTypeSetToModelTypePayloadMap(types3, |
+ EXPECT_TRUE(CompareModelTypeSetToModelTypeStateMap(types3, |
r2.snapshots[0].source().types)); |
EXPECT_EQ(GetUpdatesCallerInfo::NOTIFICATION, |
r2.snapshots[0].source().updates_source); |
@@ -487,7 +487,7 @@ TEST_F(SyncSchedulerTest, NudgeCoalescingWithDifferentTimings) { |
// Make sure the sync has happened. |
ASSERT_EQ(1U, r.snapshots.size()); |
- EXPECT_TRUE(CompareModelTypeSetToModelTypePayloadMap( |
+ EXPECT_TRUE(CompareModelTypeSetToModelTypeStateMap( |
Union(types1, types2), r.snapshots[0].source().types)); |
// Make sure the sync happened at the right time. |
@@ -496,23 +496,23 @@ TEST_F(SyncSchedulerTest, NudgeCoalescingWithDifferentTimings) { |
} |
// Test nudge scheduling. |
-TEST_F(SyncSchedulerTest, NudgeWithPayloads) { |
+TEST_F(SyncSchedulerTest, NudgeWithStates) { |
StartSyncScheduler(SyncScheduler::NORMAL_MODE); |
SyncShareRecords records; |
- ModelTypePayloadMap model_types_with_payloads; |
- model_types_with_payloads[BOOKMARKS] = "test"; |
+ ModelTypeStateMap type_state_map; |
+ type_state_map[BOOKMARKS].payload = "test"; |
EXPECT_CALL(*syncer(), SyncShare(_,_,_)) |
.WillOnce(DoAll(Invoke(sessions::test_util::SimulateSuccess), |
WithArg<0>(RecordSyncShare(&records)))) |
.RetiresOnSaturation(); |
- scheduler()->ScheduleNudgeWithPayloadsAsync( |
- zero(), NUDGE_SOURCE_LOCAL, model_types_with_payloads, FROM_HERE); |
+ scheduler()->ScheduleNudgeWithStatesAsync( |
+ zero(), NUDGE_SOURCE_LOCAL, type_state_map, FROM_HERE); |
RunLoop(); |
ASSERT_EQ(1U, records.snapshots.size()); |
- EXPECT_EQ(model_types_with_payloads, records.snapshots[0].source().types); |
+ EXPECT_EQ(type_state_map, records.snapshots[0].source().types); |
EXPECT_EQ(GetUpdatesCallerInfo::LOCAL, |
records.snapshots[0].source().updates_source); |
@@ -520,46 +520,46 @@ TEST_F(SyncSchedulerTest, NudgeWithPayloads) { |
// Make sure a second, later, nudge is unaffected by first (no coalescing). |
SyncShareRecords records2; |
- model_types_with_payloads.erase(BOOKMARKS); |
- model_types_with_payloads[AUTOFILL] = "test2"; |
+ type_state_map.erase(BOOKMARKS); |
+ type_state_map[AUTOFILL].payload = "test2"; |
EXPECT_CALL(*syncer(), SyncShare(_,_,_)) |
.WillOnce(DoAll(Invoke(sessions::test_util::SimulateSuccess), |
WithArg<0>(RecordSyncShare(&records2)))); |
- scheduler()->ScheduleNudgeWithPayloadsAsync( |
- zero(), NUDGE_SOURCE_LOCAL, model_types_with_payloads, FROM_HERE); |
+ scheduler()->ScheduleNudgeWithStatesAsync( |
+ zero(), NUDGE_SOURCE_LOCAL, type_state_map, FROM_HERE); |
RunLoop(); |
ASSERT_EQ(1U, records2.snapshots.size()); |
- EXPECT_EQ(model_types_with_payloads, records2.snapshots[0].source().types); |
+ EXPECT_EQ(type_state_map, records2.snapshots[0].source().types); |
EXPECT_EQ(GetUpdatesCallerInfo::LOCAL, |
records2.snapshots[0].source().updates_source); |
} |
// Test that nudges are coalesced. |
-TEST_F(SyncSchedulerTest, NudgeWithPayloadsCoalescing) { |
+TEST_F(SyncSchedulerTest, NudgeWithStatesCoalescing) { |
StartSyncScheduler(SyncScheduler::NORMAL_MODE); |
SyncShareRecords r; |
EXPECT_CALL(*syncer(), SyncShare(_,_,_)) |
.WillOnce(DoAll(Invoke(sessions::test_util::SimulateSuccess), |
WithArg<0>(RecordSyncShare(&r)))); |
- ModelTypePayloadMap types1, types2, types3; |
- types1[BOOKMARKS] = "test1"; |
- types2[AUTOFILL] = "test2"; |
- types3[THEMES] = "test3"; |
+ ModelTypeStateMap types1, types2, types3; |
+ types1[BOOKMARKS].payload = "test1"; |
+ types2[AUTOFILL].payload = "test2"; |
+ types3[THEMES].payload = "test3"; |
TimeDelta delay = zero(); |
TimeTicks optimal_time = TimeTicks::Now() + delay; |
- scheduler()->ScheduleNudgeWithPayloadsAsync( |
+ scheduler()->ScheduleNudgeWithStatesAsync( |
delay, NUDGE_SOURCE_UNKNOWN, types1, FROM_HERE); |
- scheduler()->ScheduleNudgeWithPayloadsAsync( |
+ scheduler()->ScheduleNudgeWithStatesAsync( |
zero(), NUDGE_SOURCE_LOCAL, types2, FROM_HERE); |
RunLoop(); |
ASSERT_EQ(1U, r.snapshots.size()); |
EXPECT_GE(r.times[0], optimal_time); |
- ModelTypePayloadMap coalesced_types; |
- CoalescePayloads(&coalesced_types, types1); |
- CoalescePayloads(&coalesced_types, types2); |
+ ModelTypeStateMap coalesced_types; |
+ CoalesceStates(&coalesced_types, types1); |
+ CoalesceStates(&coalesced_types, types2); |
EXPECT_EQ(coalesced_types, r.snapshots[0].source().types); |
EXPECT_EQ(GetUpdatesCallerInfo::LOCAL, |
r.snapshots[0].source().updates_source); |
@@ -570,7 +570,7 @@ TEST_F(SyncSchedulerTest, NudgeWithPayloadsCoalescing) { |
EXPECT_CALL(*syncer(), SyncShare(_,_,_)) |
.WillOnce(DoAll(Invoke(sessions::test_util::SimulateSuccess), |
WithArg<0>(RecordSyncShare(&r2)))); |
- scheduler()->ScheduleNudgeWithPayloadsAsync( |
+ scheduler()->ScheduleNudgeWithStatesAsync( |
zero(), NUDGE_SOURCE_NOTIFICATION, types3, FROM_HERE); |
RunLoop(); |
@@ -786,7 +786,7 @@ TEST_F(SyncSchedulerTest, ConfigurationMode) { |
ASSERT_EQ(1, counter.times_called()); |
ASSERT_EQ(1U, records.snapshots.size()); |
- EXPECT_TRUE(CompareModelTypeSetToModelTypePayloadMap(config_types, |
+ EXPECT_TRUE(CompareModelTypeSetToModelTypeStateMap(config_types, |
records.snapshots[0].source().types)); |
} |