Index: sync/engine/sync_scheduler_unittest.cc |
diff --git a/sync/engine/sync_scheduler_unittest.cc b/sync/engine/sync_scheduler_unittest.cc |
index c231087f9c98683ed81d5094847ed1aa9ba65b39..8348eabfef86d32b8783261735a7b82ebb5b9a5e 100644 |
--- a/sync/engine/sync_scheduler_unittest.cc |
+++ b/sync/engine/sync_scheduler_unittest.cc |
@@ -20,6 +20,7 @@ |
#include "sync/test/engine/fake_model_worker.h" |
#include "sync/test/engine/mock_connection_manager.h" |
#include "sync/test/engine/test_directory_setter_upper.h" |
+#include "sync/test/mock_invalidation.h" |
#include "sync/util/extensions_activity.h" |
#include "testing/gmock/include/gmock/gmock.h" |
#include "testing/gtest/include/gtest/gtest.h" |
@@ -220,6 +221,13 @@ class SyncSchedulerTest : public testing::Test { |
return scheduler_->retry_timer_.GetCurrentDelay(); |
} |
+ static scoped_ptr<InvalidationInterface> BuildInvalidation( |
+ int64 version, |
+ const std::string& payload) { |
+ return MockInvalidation::Build(version, payload) |
+ .PassAs<InvalidationInterface>(); |
+ } |
+ |
private: |
syncable::Directory* directory() { |
return dir_maker_.directory(); |
@@ -523,25 +531,23 @@ TEST_F(SyncSchedulerTest, NudgeWithStates) { |
StartSyncScheduler(SyncScheduler::NORMAL_MODE); |
SyncShareTimes times1; |
- ObjectIdInvalidationMap invalidations1 = |
- BuildInvalidationMap(BOOKMARKS, 10, "test"); |
EXPECT_CALL(*syncer(), NormalSyncShare(_,_,_)) |
.WillOnce(DoAll(Invoke(sessions::test_util::SimulateNormalSuccess), |
RecordSyncShare(×1))) |
.RetiresOnSaturation(); |
- scheduler()->ScheduleInvalidationNudge(zero(), invalidations1, FROM_HERE); |
+ scheduler()->ScheduleInvalidationNudge( |
+ zero(), BOOKMARKS, BuildInvalidation(10, "test"), FROM_HERE); |
RunLoop(); |
Mock::VerifyAndClearExpectations(syncer()); |
// Make sure a second, later, nudge is unaffected by first (no coalescing). |
SyncShareTimes times2; |
- ObjectIdInvalidationMap invalidations2 = |
- BuildInvalidationMap(AUTOFILL, 10, "test2"); |
EXPECT_CALL(*syncer(), NormalSyncShare(_,_,_)) |
.WillOnce(DoAll(Invoke(sessions::test_util::SimulateNormalSuccess), |
RecordSyncShare(×2))); |
- scheduler()->ScheduleInvalidationNudge(zero(), invalidations2, FROM_HERE); |
+ scheduler()->ScheduleInvalidationNudge( |
+ zero(), AUTOFILL, BuildInvalidation(10, "test2"), FROM_HERE); |
RunLoop(); |
} |
@@ -834,9 +840,8 @@ TEST_F(SyncSchedulerTest, TypeThrottlingDoesBlockOtherSources) { |
EXPECT_TRUE(GetThrottledTypes().HasAll(throttled_types)); |
// Ignore invalidations for throttled types. |
- ObjectIdInvalidationMap invalidations = |
- BuildInvalidationMap(BOOKMARKS, 10, "test"); |
- scheduler()->ScheduleInvalidationNudge(zero(), invalidations, FROM_HERE); |
+ scheduler()->ScheduleInvalidationNudge( |
+ zero(), BOOKMARKS, BuildInvalidation(10, "test"), FROM_HERE); |
PumpLoop(); |
// Ignore refresh requests for throttled types. |