sync: Process client commands on commit response

sync/engine/syncer_proto_util.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 "sync/engine/syncer_proto_util.h"
 
 #include "base/format_macros.h"
 #include "base/stringprintf.h"
 #include "sync/engine/net/server_connection_manager.h"
 #include "sync/engine/syncer.h"
@@ skipping 376 matching lines @@
         response->error_code());
   }
 
   // Now set the error into the status so the layers above us could read it.
   sessions::StatusController* status = session->mutable_status_controller();
   status->set_sync_protocol_error(sync_protocol_error);
 
   // Inform the delegate of the error we got.
   session->delegate()->OnSyncProtocolError(session->TakeSnapshot());
 
+  // Update our state for any other commands we've received.
+  if (response->has_client_command()) {
+    const sync_pb::ClientCommand& command = response->client_command();
+    if (command.has_max_commit_batch_size()) {
+      session->context()->set_max_commit_batch_size(
+          command.max_commit_batch_size());
+    }
+
+    if (command.has_set_sync_long_poll_interval()) {
+      session->delegate()->OnReceivedLongPollIntervalUpdate(
+          base::TimeDelta::FromSeconds(command.set_sync_long_poll_interval()));
+    }
+
+    if (command.has_set_sync_poll_interval()) {
+      session->delegate()->OnReceivedShortPollIntervalUpdate(
+          base::TimeDelta::FromSeconds(command.set_sync_poll_interval()));
+    }
+
+    if (command.has_sessions_commit_delay_seconds()) {
+      session->delegate()->OnReceivedSessionsCommitDelay(
+          base::TimeDelta::FromSeconds(
+              command.sessions_commit_delay_seconds()));
+    }
+  }
+
   // Now do any special handling for the error type and decide on the return
   // value.
   switch (sync_protocol_error.error_type) {
     case UNKNOWN_ERROR:
       LOG(WARNING) << "Sync protocol out-of-date. The server is using a more "
                    << "recent version.";
       return SERVER_RETURN_UNKNOWN_ERROR;
     case SYNC_SUCCESS:
       LogResponseProfilingData(*response);
       return SYNCER_OK;
@@ skipping 140 matching lines @@
 std::string SyncerProtoUtil::ClientToServerResponseDebugString(
     const ClientToServerResponse& response) {
   // Add more handlers as needed.
   std::string output;
   if (response.has_get_updates())
     output.append(GetUpdatesResponseString(response.get_updates()));
   return output;
 }
 
 }  // namespace syncer