[Sync] Add client-side plumbing for server control of sessions commit delay

chrome/browser/sync/engine/sync_scheduler_unittest.cc

 // Copyright (c) 2011 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/scoped_callback_factory.h"
 #include "base/message_loop.h"
 #include "base/task.h"
@@ skipping 611 matching lines @@
   StartSyncScheduler(SyncScheduler::NORMAL_MODE);
   RunLoop();
 
   // Run again to wait for polling.
   RunLoop();
 
   scheduler()->Stop();
   AnalyzePollRun(records, kMinNumSamples, optimal_start, poll2);
 }
 
+// Test that the sessions commit delay is updated when needed.
+TEST_F(SyncSchedulerTest, SessionsCommitDelay) {
+  SyncShareRecords records;
+  TimeDelta delay1(TimeDelta::FromMilliseconds(120));
+  TimeDelta delay2(TimeDelta::FromMilliseconds(30));
+  scheduler()->OnReceivedSessionsCommitDelay(delay1);
+
+  EXPECT_CALL(*syncer(), SyncShare(_,_,_))
+      .WillOnce(
+          DoAll(
+              WithArg<0>(
+                  sessions::test_util::SimulateSessionsCommitDelayUpdate(
+                      delay2)),
+              Invoke(sessions::test_util::SimulateSuccess),
+              QuitLoopNowAction()));
+
+  EXPECT_EQ(delay1, scheduler()->sessions_commit_delay());
+  StartSyncScheduler(SyncScheduler::NORMAL_MODE);
+  RunLoop();
+
+  EXPECT_EQ(delay1, scheduler()->sessions_commit_delay());
+  syncable::ModelTypeBitSet model_types;
+  model_types[syncable::BOOKMARKS] = true;
+  scheduler()->ScheduleNudge(
+      zero(), NUDGE_SOURCE_LOCAL, model_types, FROM_HERE);
+  RunLoop();
+
+  EXPECT_EQ(delay2, scheduler()->sessions_commit_delay());
+  scheduler()->Stop();
+}
+
 // Test that a sync session is run through to completion.
 TEST_F(SyncSchedulerTest, HasMoreToSync) {
   EXPECT_CALL(*syncer(), SyncShare(_,_,_))
       .WillOnce(Invoke(sessions::test_util::SimulateHasMoreToSync))
       .WillOnce(DoAll(Invoke(sessions::test_util::SimulateSuccess),
                       QuitLoopNowAction()));
   StartSyncScheduler(SyncScheduler::NORMAL_MODE);
   RunLoop();
 
   scheduler()->ScheduleNudge(
@@ skipping 397 matching lines @@
   PumpLoop();
   // Pump again to run job.
   PumpLoop();
 
   scheduler()->Stop();
 
   EXPECT_TRUE(expected == context()->previous_session_routing_info());
 }
 
 }  // namespace browser_sync