Index: sync/engine/sync_scheduler_unittest.cc |
diff --git a/sync/engine/sync_scheduler_unittest.cc b/sync/engine/sync_scheduler_unittest.cc |
index 63dc3c3cc7e2baa525456dda55bec939108c14c2..1bb52453508f13eb28e688209c7b78911d7803ff 100644 |
--- a/sync/engine/sync_scheduler_unittest.cc |
+++ b/sync/engine/sync_scheduler_unittest.cc |
@@ -12,7 +12,7 @@ |
#include "sync/engine/sync_scheduler_impl.h" |
#include "sync/engine/syncer.h" |
#include "sync/engine/throttled_data_type_tracker.h" |
-#include "sync/internal_api/public/base/model_type_state_map_test_util.h" |
+#include "sync/internal_api/public/base/model_type_invalidation_map_test_util.h" |
#include "sync/sessions/test_util.h" |
#include "sync/test/callback_counter.h" |
#include "sync/test/engine/fake_model_worker.h" |
@@ -199,13 +199,13 @@ class SyncSchedulerTest : public testing::Test { |
scheduler_->delay_provider_.reset(delay_); |
} |
- // Compare a ModelTypeSet to a ModelTypeStateMap, ignoring |
+ // Compare a ModelTypeSet to a ModelTypeInvalidationMap, ignoring |
// state values. |
- bool CompareModelTypeSetToModelTypeStateMap( |
+ bool CompareModelTypeSetToModelTypeInvalidationMap( |
ModelTypeSet lhs, |
- const ModelTypeStateMap& rhs) { |
+ const ModelTypeInvalidationMap& rhs) { |
size_t count = 0; |
- for (ModelTypeStateMap::const_iterator i = rhs.begin(); |
+ for (ModelTypeInvalidationMap::const_iterator i = rhs.begin(); |
i != rhs.end(); ++i, ++count) { |
if (!lhs.Has(i->first)) |
return false; |
@@ -282,7 +282,7 @@ TEST_F(SyncSchedulerTest, Nudge) { |
RunLoop(); |
ASSERT_EQ(1U, records.snapshots.size()); |
- EXPECT_TRUE(CompareModelTypeSetToModelTypeStateMap(model_types, |
+ EXPECT_TRUE(CompareModelTypeSetToModelTypeInvalidationMap(model_types, |
records.snapshots[0].source().types)); |
EXPECT_EQ(GetUpdatesCallerInfo::LOCAL, |
records.snapshots[0].source().updates_source); |
@@ -301,7 +301,7 @@ TEST_F(SyncSchedulerTest, Nudge) { |
RunLoop(); |
ASSERT_EQ(1U, records2.snapshots.size()); |
- EXPECT_TRUE(CompareModelTypeSetToModelTypeStateMap(model_types, |
+ EXPECT_TRUE(CompareModelTypeSetToModelTypeInvalidationMap(model_types, |
records2.snapshots[0].source().types)); |
EXPECT_EQ(GetUpdatesCallerInfo::LOCAL, |
records2.snapshots[0].source().updates_source); |
@@ -329,7 +329,7 @@ TEST_F(SyncSchedulerTest, Config) { |
ASSERT_EQ(1, counter.times_called()); |
ASSERT_EQ(1U, records.snapshots.size()); |
- EXPECT_TRUE(CompareModelTypeSetToModelTypeStateMap(model_types, |
+ EXPECT_TRUE(CompareModelTypeSetToModelTypeInvalidationMap(model_types, |
records.snapshots[0].source().types)); |
EXPECT_EQ(GetUpdatesCallerInfo::RECONFIGURATION, |
records.snapshots[0].source().updates_source); |
@@ -366,7 +366,7 @@ TEST_F(SyncSchedulerTest, ConfigWithBackingOff) { |
ASSERT_EQ(2U, records.snapshots.size()); |
ASSERT_EQ(1, counter.times_called()); |
- EXPECT_TRUE(CompareModelTypeSetToModelTypeStateMap(model_types, |
+ EXPECT_TRUE(CompareModelTypeSetToModelTypeInvalidationMap(model_types, |
records.snapshots[1].source().types)); |
EXPECT_EQ(GetUpdatesCallerInfo::RECONFIGURATION, |
records.snapshots[1].source().updates_source); |
@@ -425,12 +425,12 @@ TEST_F(SyncSchedulerTest, NudgeWithConfigWithBackingOff) { |
ASSERT_EQ(4U, records.snapshots.size()); |
- EXPECT_TRUE(CompareModelTypeSetToModelTypeStateMap(model_types, |
+ EXPECT_TRUE(CompareModelTypeSetToModelTypeInvalidationMap(model_types, |
records.snapshots[2].source().types)); |
EXPECT_EQ(GetUpdatesCallerInfo::RECONFIGURATION, |
records.snapshots[2].source().updates_source); |
- EXPECT_TRUE(CompareModelTypeSetToModelTypeStateMap(model_types, |
+ EXPECT_TRUE(CompareModelTypeSetToModelTypeInvalidationMap(model_types, |
records.snapshots[3].source().types)); |
EXPECT_EQ(GetUpdatesCallerInfo::LOCAL, |
records.snapshots[3].source().updates_source); |
@@ -456,7 +456,7 @@ TEST_F(SyncSchedulerTest, NudgeCoalescing) { |
ASSERT_EQ(1U, r.snapshots.size()); |
EXPECT_GE(r.times[0], optimal_time); |
- EXPECT_TRUE(CompareModelTypeSetToModelTypeStateMap( |
+ EXPECT_TRUE(CompareModelTypeSetToModelTypeInvalidationMap( |
Union(types1, types2), r.snapshots[0].source().types)); |
EXPECT_EQ(GetUpdatesCallerInfo::LOCAL, |
r.snapshots[0].source().updates_source); |
@@ -472,7 +472,7 @@ TEST_F(SyncSchedulerTest, NudgeCoalescing) { |
RunLoop(); |
ASSERT_EQ(1U, r2.snapshots.size()); |
- EXPECT_TRUE(CompareModelTypeSetToModelTypeStateMap(types3, |
+ EXPECT_TRUE(CompareModelTypeSetToModelTypeInvalidationMap(types3, |
r2.snapshots[0].source().types)); |
EXPECT_EQ(GetUpdatesCallerInfo::NOTIFICATION, |
r2.snapshots[0].source().updates_source); |
@@ -504,7 +504,7 @@ TEST_F(SyncSchedulerTest, NudgeCoalescingWithDifferentTimings) { |
// Make sure the sync has happened. |
ASSERT_EQ(1U, r.snapshots.size()); |
- EXPECT_TRUE(CompareModelTypeSetToModelTypeStateMap( |
+ EXPECT_TRUE(CompareModelTypeSetToModelTypeInvalidationMap( |
Union(types1, types2), r.snapshots[0].source().types)); |
// Make sure the sync happened at the right time. |
@@ -517,19 +517,20 @@ TEST_F(SyncSchedulerTest, NudgeWithStates) { |
StartSyncScheduler(SyncScheduler::NORMAL_MODE); |
SyncShareRecords records; |
- ModelTypeStateMap type_state_map; |
- type_state_map[BOOKMARKS].payload = "test"; |
+ const ModelTypeSet types(BOOKMARKS); |
+ ModelTypeInvalidationMap invalidation_map = |
+ ModelTypeSetToInvalidationMap(types, "test"); |
EXPECT_CALL(*syncer(), SyncShare(_,_,_)) |
.WillOnce(DoAll(Invoke(sessions::test_util::SimulateSuccess), |
WithArg<0>(RecordSyncShare(&records)))) |
.RetiresOnSaturation(); |
scheduler()->ScheduleNudgeWithStatesAsync( |
- zero(), NUDGE_SOURCE_LOCAL, type_state_map, FROM_HERE); |
+ zero(), NUDGE_SOURCE_LOCAL, invalidation_map, FROM_HERE); |
RunLoop(); |
ASSERT_EQ(1U, records.snapshots.size()); |
- EXPECT_THAT(type_state_map, Eq(records.snapshots[0].source().types)); |
+ EXPECT_THAT(invalidation_map, Eq(records.snapshots[0].source().types)); |
EXPECT_EQ(GetUpdatesCallerInfo::LOCAL, |
records.snapshots[0].source().updates_source); |
@@ -537,17 +538,17 @@ TEST_F(SyncSchedulerTest, NudgeWithStates) { |
// Make sure a second, later, nudge is unaffected by first (no coalescing). |
SyncShareRecords records2; |
- type_state_map.erase(BOOKMARKS); |
- type_state_map[AUTOFILL].payload = "test2"; |
+ invalidation_map.erase(BOOKMARKS); |
+ invalidation_map[AUTOFILL].payload = "test2"; |
EXPECT_CALL(*syncer(), SyncShare(_,_,_)) |
.WillOnce(DoAll(Invoke(sessions::test_util::SimulateSuccess), |
WithArg<0>(RecordSyncShare(&records2)))); |
scheduler()->ScheduleNudgeWithStatesAsync( |
- zero(), NUDGE_SOURCE_LOCAL, type_state_map, FROM_HERE); |
+ zero(), NUDGE_SOURCE_LOCAL, invalidation_map, FROM_HERE); |
RunLoop(); |
ASSERT_EQ(1U, records2.snapshots.size()); |
- EXPECT_THAT(type_state_map, Eq(records2.snapshots[0].source().types)); |
+ EXPECT_THAT(invalidation_map, Eq(records2.snapshots[0].source().types)); |
EXPECT_EQ(GetUpdatesCallerInfo::LOCAL, |
records2.snapshots[0].source().updates_source); |
} |
@@ -560,7 +561,7 @@ TEST_F(SyncSchedulerTest, NudgeWithStatesCoalescing) { |
EXPECT_CALL(*syncer(), SyncShare(_,_,_)) |
.WillOnce(DoAll(Invoke(sessions::test_util::SimulateSuccess), |
WithArg<0>(RecordSyncShare(&r)))); |
- ModelTypeStateMap types1, types2, types3; |
+ ModelTypeInvalidationMap types1, types2, types3; |
types1[BOOKMARKS].payload = "test1"; |
types2[AUTOFILL].payload = "test2"; |
types3[THEMES].payload = "test3"; |
@@ -574,7 +575,7 @@ TEST_F(SyncSchedulerTest, NudgeWithStatesCoalescing) { |
ASSERT_EQ(1U, r.snapshots.size()); |
EXPECT_GE(r.times[0], optimal_time); |
- ModelTypeStateMap coalesced_types; |
+ ModelTypeInvalidationMap coalesced_types; |
CoalesceStates(&coalesced_types, types1); |
CoalesceStates(&coalesced_types, types2); |
EXPECT_THAT(coalesced_types, Eq(r.snapshots[0].source().types)); |
@@ -804,7 +805,7 @@ TEST_F(SyncSchedulerTest, ConfigurationMode) { |
ASSERT_EQ(1, counter.times_called()); |
ASSERT_EQ(1U, records.snapshots.size()); |
- EXPECT_TRUE(CompareModelTypeSetToModelTypeStateMap(config_types, |
+ EXPECT_TRUE(CompareModelTypeSetToModelTypeInvalidationMap(config_types, |
records.snapshots[0].source().types)); |
// Switch to NORMAL_MODE to ensure NUDGES were properly saved and run. |
@@ -824,7 +825,7 @@ TEST_F(SyncSchedulerTest, ConfigurationMode) { |
ASSERT_EQ(1U, records2.snapshots.size()); |
EXPECT_EQ(GetUpdatesCallerInfo::LOCAL, |
records2.snapshots[0].source().updates_source); |
- EXPECT_TRUE(CompareModelTypeSetToModelTypeStateMap(nudge_types, |
+ EXPECT_TRUE(CompareModelTypeSetToModelTypeInvalidationMap(nudge_types, |
records2.snapshots[0].source().types)); |
PumpLoop(); |
} |