| Index: sync/engine/sync_scheduler_unittest.cc
|
| diff --git a/sync/engine/sync_scheduler_unittest.cc b/sync/engine/sync_scheduler_unittest.cc
|
| index 0420bcb6c943f1c08f1706f82da2bd8e071c9417..53d2ed4fb13e1de1acff9b022fe345b4b3cf7ba9 100644
|
| --- a/sync/engine/sync_scheduler_unittest.cc
|
| +++ b/sync/engine/sync_scheduler_unittest.cc
|
| @@ -8,6 +8,7 @@
|
| #include "base/memory/weak_ptr.h"
|
| #include "base/message_loop.h"
|
| #include "base/test/test_timeouts.h"
|
| +#include "sync/engine/backoff_delay_provider.h"
|
| #include "sync/engine/sync_scheduler_impl.h"
|
| #include "sync/engine/syncer.h"
|
| #include "sync/engine/throttled_data_type_tracker.h"
|
| @@ -88,8 +89,13 @@ class SyncSchedulerTest : public testing::Test {
|
| syncer_(NULL),
|
| delay_(NULL) {}
|
|
|
| - class MockDelayProvider : public SyncSchedulerImpl::DelayProvider {
|
| + class MockDelayProvider : public BackoffDelayProvider {
|
| public:
|
| + MockDelayProvider() : BackoffDelayProvider(
|
| + TimeDelta::FromSeconds(kInitialBackoffRetrySeconds),
|
| + TimeDelta::FromSeconds(kInitialBackoffShortRetrySeconds)) {
|
| + }
|
| +
|
| MOCK_METHOD1(GetDelay, TimeDelta(const TimeDelta&));
|
| };
|
|
|
| @@ -126,7 +132,10 @@ class SyncSchedulerTest : public testing::Test {
|
| context_->set_notifications_enabled(true);
|
| context_->set_account_name("Test");
|
| scheduler_.reset(
|
| - new SyncSchedulerImpl("TestSyncScheduler", context(), syncer_));
|
| + new SyncSchedulerImpl("TestSyncScheduler",
|
| + BackoffDelayProvider::FromDefaults(),
|
| + context(),
|
| + syncer_));
|
| }
|
|
|
| SyncSchedulerImpl* scheduler() { return scheduler_.get(); }
|
| @@ -959,38 +968,6 @@ TEST_F(SyncSchedulerTest, BackoffElevation) {
|
| EXPECT_GE(r.times[4] - r.times[3], fifth);
|
| }
|
|
|
| -TEST_F(SyncSchedulerTest, GetInitialBackoffDelay) {
|
| - sessions::ModelNeutralState state;
|
| - state.last_get_key_result = SYNC_SERVER_ERROR;
|
| - EXPECT_EQ(kInitialBackoffRetrySeconds,
|
| - scheduler()->GetInitialBackoffDelay(state).InSeconds());
|
| -
|
| - state.last_get_key_result = UNSET;
|
| - state.last_download_updates_result = SERVER_RETURN_MIGRATION_DONE;
|
| - EXPECT_EQ(kInitialBackoffShortRetrySeconds,
|
| - scheduler()->GetInitialBackoffDelay(state).InSeconds());
|
| -
|
| - state.last_download_updates_result = SERVER_RETURN_TRANSIENT_ERROR;
|
| - EXPECT_EQ(kInitialBackoffRetrySeconds,
|
| - scheduler()->GetInitialBackoffDelay(state).InSeconds());
|
| -
|
| - state.last_download_updates_result = SERVER_RESPONSE_VALIDATION_FAILED;
|
| - EXPECT_EQ(kInitialBackoffRetrySeconds,
|
| - scheduler()->GetInitialBackoffDelay(state).InSeconds());
|
| -
|
| - state.last_download_updates_result = SYNCER_OK;
|
| - // Note that updating credentials triggers a canary job, trumping
|
| - // the initial delay, but in theory we still expect this function to treat
|
| - // it like any other error in the system (except migration).
|
| - state.commit_result = SERVER_RETURN_INVALID_CREDENTIAL;
|
| - EXPECT_EQ(kInitialBackoffRetrySeconds,
|
| - scheduler()->GetInitialBackoffDelay(state).InSeconds());
|
| -
|
| - state.commit_result = SERVER_RETURN_MIGRATION_DONE;
|
| - EXPECT_EQ(kInitialBackoffShortRetrySeconds,
|
| - scheduler()->GetInitialBackoffDelay(state).InSeconds());
|
| -}
|
| -
|
| // Test that things go back to normal once a retry makes forward progress.
|
| TEST_F(SyncSchedulerTest, BackoffRelief) {
|
| SyncShareRecords r;
|
| @@ -1066,25 +1043,6 @@ TEST_F(SyncSchedulerTest, TransientPollFailure) {
|
| EXPECT_FALSE(scheduler()->IsBackingOff());
|
| }
|
|
|
| -TEST_F(SyncSchedulerTest, GetRecommendedDelay) {
|
| - EXPECT_LE(TimeDelta::FromSeconds(0),
|
| - SyncSchedulerImpl::GetRecommendedDelay(TimeDelta::FromSeconds(0)));
|
| - EXPECT_LE(TimeDelta::FromSeconds(1),
|
| - SyncSchedulerImpl::GetRecommendedDelay(TimeDelta::FromSeconds(1)));
|
| - EXPECT_LE(TimeDelta::FromSeconds(50),
|
| - SyncSchedulerImpl::GetRecommendedDelay(
|
| - TimeDelta::FromSeconds(50)));
|
| - EXPECT_LE(TimeDelta::FromSeconds(10),
|
| - SyncSchedulerImpl::GetRecommendedDelay(
|
| - TimeDelta::FromSeconds(10)));
|
| - EXPECT_EQ(TimeDelta::FromSeconds(kMaxBackoffSeconds),
|
| - SyncSchedulerImpl::GetRecommendedDelay(
|
| - TimeDelta::FromSeconds(kMaxBackoffSeconds)));
|
| - EXPECT_EQ(TimeDelta::FromSeconds(kMaxBackoffSeconds),
|
| - SyncSchedulerImpl::GetRecommendedDelay(
|
| - TimeDelta::FromSeconds(kMaxBackoffSeconds + 1)));
|
| -}
|
| -
|
| // Test that appropriate syncer steps are requested for each job type.
|
| TEST_F(SyncSchedulerTest, SyncerSteps) {
|
| // Nudges.
|
|
|