OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 "base/bind.h" | 5 #include "base/bind.h" |
6 #include "base/callback.h" | 6 #include "base/callback.h" |
7 #include "base/compiler_specific.h" | 7 #include "base/compiler_specific.h" |
8 #include "base/memory/weak_ptr.h" | 8 #include "base/memory/weak_ptr.h" |
9 #include "base/message_loop.h" | 9 #include "base/message_loop.h" |
10 #include "base/test/test_timeouts.h" | 10 #include "base/test/test_timeouts.h" |
(...skipping 706 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
717 | 717 |
718 EXPECT_CALL(*syncer(), SyncShare(_,_,_)) | 718 EXPECT_CALL(*syncer(), SyncShare(_,_,_)) |
719 .WillOnce(DoAll( | 719 .WillOnce(DoAll( |
720 WithArg<0>(sessions::test_util::SimulateThrottled(throttle)), | 720 WithArg<0>(sessions::test_util::SimulateThrottled(throttle)), |
721 Return(true))) | 721 Return(true))) |
722 .WillRepeatedly(AddFailureAndQuitLoopNow()); | 722 .WillRepeatedly(AddFailureAndQuitLoopNow()); |
723 | 723 |
724 StartSyncScheduler(SyncScheduler::NORMAL_MODE); | 724 StartSyncScheduler(SyncScheduler::NORMAL_MODE); |
725 | 725 |
726 scheduler()->ScheduleNudgeAsync( | 726 scheduler()->ScheduleNudgeAsync( |
727 zero(), NUDGE_SOURCE_LOCAL, types, FROM_HERE); | 727 TimeDelta::FromMicroseconds(1), NUDGE_SOURCE_LOCAL, types, FROM_HERE); |
728 PumpLoop(); | 728 PumpLoop(); |
729 | 729 |
730 StartSyncScheduler(SyncScheduler::CONFIGURATION_MODE); | 730 StartSyncScheduler(SyncScheduler::CONFIGURATION_MODE); |
731 | 731 |
732 CallbackCounter counter; | 732 CallbackCounter counter; |
733 ConfigurationParams params( | 733 ConfigurationParams params( |
734 GetUpdatesCallerInfo::RECONFIGURATION, | 734 GetUpdatesCallerInfo::RECONFIGURATION, |
735 types, | 735 types, |
736 TypesToRoutingInfo(types), | 736 TypesToRoutingInfo(types), |
737 base::Bind(&CallbackCounter::Callback, base::Unretained(&counter))); | 737 base::Bind(&CallbackCounter::Callback, base::Unretained(&counter))); |
(...skipping 550 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1288 base::Bind(&CallbackCounter::Callback, base::Unretained(&counter))); | 1288 base::Bind(&CallbackCounter::Callback, base::Unretained(&counter))); |
1289 scheduler()->ScheduleConfiguration(params); | 1289 scheduler()->ScheduleConfiguration(params); |
1290 | 1290 |
1291 scheduler()->OnConnectionStatusChange(); | 1291 scheduler()->OnConnectionStatusChange(); |
1292 scheduler()->OnConnectionStatusChange(); | 1292 scheduler()->OnConnectionStatusChange(); |
1293 | 1293 |
1294 PumpLoop(); // Run the nudge, that will fail and schedule a quick retry. | 1294 PumpLoop(); // Run the nudge, that will fail and schedule a quick retry. |
1295 } | 1295 } |
1296 | 1296 |
1297 } // namespace syncer | 1297 } // namespace syncer |
OLD | NEW |