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/message_loop.h" | 9 #include "base/message_loop/message_loop.h" |
10 #include "base/test/test_timeouts.h" | 10 #include "base/test/test_timeouts.h" |
(...skipping 1351 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1362 TEST_F(SyncSchedulerTest, ReceiveNewRetryDelay) { | 1362 TEST_F(SyncSchedulerTest, ReceiveNewRetryDelay) { |
1363 StartSyncScheduler(SyncScheduler::NORMAL_MODE); | 1363 StartSyncScheduler(SyncScheduler::NORMAL_MODE); |
1364 | 1364 |
1365 SyncShareTimes times; | 1365 SyncShareTimes times; |
1366 base::TimeDelta delay1 = base::TimeDelta::FromMilliseconds(100); | 1366 base::TimeDelta delay1 = base::TimeDelta::FromMilliseconds(100); |
1367 base::TimeDelta delay2 = base::TimeDelta::FromMilliseconds(200); | 1367 base::TimeDelta delay2 = base::TimeDelta::FromMilliseconds(200); |
1368 | 1368 |
1369 scheduler()->ScheduleLocalRefreshRequest(zero(), ModelTypeSet(BOOKMARKS), | 1369 scheduler()->ScheduleLocalRefreshRequest(zero(), ModelTypeSet(BOOKMARKS), |
1370 FROM_HERE); | 1370 FROM_HERE); |
1371 scheduler()->OnReceivedGuRetryDelay(delay1); | 1371 scheduler()->OnReceivedGuRetryDelay(delay1); |
| 1372 EXPECT_EQ(delay1, GetRetryTimerDelay()); |
1372 | 1373 |
1373 EXPECT_CALL(*syncer(), NormalSyncShare(_,_,_)) | 1374 EXPECT_CALL(*syncer(), NormalSyncShare(_,_,_)) |
1374 .WillOnce(DoAll( | 1375 .WillOnce(DoAll( |
1375 WithoutArgs(VerifyRetryTimerDelay(this, delay1)), | 1376 WithoutArgs(VerifyRetryTimerDelay(this, delay1)), |
1376 WithArg<2>(sessions::test_util::SimulateGuRetryDelayCommand(delay2)), | 1377 WithArg<2>(sessions::test_util::SimulateGuRetryDelayCommand(delay2)), |
1377 WithoutArgs(VerifyRetryTimerDelay(this, delay2)), | |
1378 RecordSyncShare(×))); | 1378 RecordSyncShare(×))); |
1379 | 1379 |
1380 // Run nudge GU. | 1380 // Run nudge GU. |
1381 RunLoop(); | 1381 RunLoop(); |
| 1382 EXPECT_EQ(delay2, GetRetryTimerDelay()); |
1382 | 1383 |
1383 EXPECT_CALL(*syncer(), RetrySyncShare(_,_)) | 1384 EXPECT_CALL(*syncer(), RetrySyncShare(_,_)) |
1384 .WillOnce( | 1385 .WillOnce(DoAll(Invoke(sessions::test_util::SimulatePollRetrySuccess), |
1385 DoAll(Invoke(sessions::test_util::SimulatePollRetrySuccess), | 1386 RecordSyncShare(×))); |
1386 RecordSyncShare(×))); | |
1387 | 1387 |
1388 // Run to wait for retrying. | 1388 // Run to wait for retrying. |
1389 RunLoop(); | 1389 RunLoop(); |
1390 | 1390 |
1391 StopSyncScheduler(); | 1391 StopSyncScheduler(); |
1392 } | 1392 } |
1393 | 1393 |
1394 } // namespace syncer | 1394 } // namespace syncer |
OLD | NEW |