[Sync] Add ClearServerData support to Sync Scheduler

sync/engine/sync_scheduler_unittest.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "base/bind.h"
 #include "base/callback.h"
 #include "base/compiler_specific.h"
 #include "base/memory/weak_ptr.h"
 #include "base/run_loop.h"
 #include "base/test/test_timeouts.h"
@@ skipping 1419 matching lines @@
   EXPECT_CALL(*syncer(), NormalSyncShare(_,_,_))
       .WillOnce(DoAll(Invoke(sessions::test_util::SimulateNormalSuccess),
                       RecordSyncShare(&times, true)));
 
   // Run to wait for retrying.
   RunLoop();
 
   StopSyncScheduler();
 }
 
+TEST_F(SyncSchedulerTest, ScheduleClearServerData_Succeeds) {
+  StartSyncConfiguration();
+  scheduler()->Start(SyncScheduler::CLEAR_SERVER_DATA_MODE, base::Time());
+  CallbackCounter success_counter;
+  ClearParams params(base::Bind(&CallbackCounter::Callback,
+                                base::Unretained(&success_counter)));
+  scheduler()->ScheduleClearServerData(params);
+  PumpLoop();
+  ASSERT_EQ(1, success_counter.times_called());
+}
+
+TEST_F(SyncSchedulerTest, ScheduleClearServerData_FailsRetriesSucceeds) {
+  UseMockDelayProvider();
+  TimeDelta delta(TimeDelta::FromMilliseconds(20));
+  EXPECT_CALL(*delay(), GetDelay(_)).WillRepeatedly(Return(delta));
+
+  StartSyncConfiguration();
+  scheduler()->Start(SyncScheduler::CLEAR_SERVER_DATA_MODE, base::Time());
+  CallbackCounter success_counter;
+  ClearParams params(base::Bind(&CallbackCounter::Callback,
+                                base::Unretained(&success_counter)));
+
+  // Next request will fail.
+  connection()->SetServerNotReachable();
+  scheduler()->ScheduleClearServerData(params);
+  PumpLoop();
+  ASSERT_EQ(0, success_counter.times_called());
+  ASSERT_TRUE(scheduler()->IsBackingOff());
+
+  // Now succeed.
+  connection()->SetServerReachable();
+  PumpLoopFor(2 * delta);
+  ASSERT_EQ(1, success_counter.times_called());
+  ASSERT_FALSE(scheduler()->IsBackingOff());
+}
+
 }  // namespace syncer