[Sync] Sync client should to exponential backoff when receive partial failure

components/sync/test/engine/mock_connection_manager.cc

 // Copyright 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 "components/sync/test/engine/mock_connection_manager.h"
 
 #include <map>
 
 #include "base/location.h"
 #include "base/strings/stringprintf.h"
@@ skipping 27 matching lines @@
       conflict_all_commits_(false),
       conflict_n_commits_(0),
       next_new_id_(10000),
       store_birthday_("Store BDay!"),
       store_birthday_sent_(false),
       client_stuck_(false),
       countdown_to_postbuffer_fail_(0),
       directory_(directory),
       mid_commit_observer_(nullptr),
       throttling_(false),
-      partialThrottling_(false),
+      partial_failure_(false),
       fail_non_periodic_get_updates_(false),
       next_position_in_parent_(2),
       use_legacy_bookmarks_protocol_(false),
       num_get_updates_requests_(0) {
   SetNewTimestamp(0);
   SetAuthToken(kValidAuthToken);
 }
 
 MockConnectionManager::~MockConnectionManager() {
   EXPECT_TRUE(update_queue_.empty()) << "Unfetched updates.";
@@ skipping 86 matching lines @@
              ClientToServerMessage::CLEAR_SERVER_DATA) {
     ProcessClearServerData(&post, &response);
   } else {
     EXPECT_TRUE(false) << "Unknown/unsupported ClientToServerMessage";
     return false;
   }
 
   {
     base::AutoLock lock(response_code_override_lock_);
     if (throttling_) {
-      response.set_error_code(SyncEnums::THROTTLED);
-      throttling_ = false;
-    }
-
-    if (partialThrottling_) {
       sync_pb::ClientToServerResponse_Error* response_error =
           response.mutable_error();
-      response_error->set_error_type(SyncEnums::PARTIAL_FAILURE);
-      for (ModelTypeSet::Iterator it = throttled_type_.First(); it.Good();
+      response_error->set_error_type(SyncEnums::THROTTLED);
+      for (ModelTypeSet::Iterator it = partial_failure_type_.First(); it.Good();
            it.Inc()) {
         response_error->add_error_data_type_ids(
             GetSpecificsFieldNumberFromModelType(it.Get()));
       }
-      partialThrottling_ = false;
+      throttling_ = false;
+    }
+
+    if (partial_failure_) {
+      sync_pb::ClientToServerResponse_Error* response_error =
+          response.mutable_error();
+      response_error->set_error_type(SyncEnums::PARTIAL_FAILURE);
+      for (ModelTypeSet::Iterator it = partial_failure_type_.First(); it.Good();
+           it.Inc()) {
+        response_error->add_error_data_type_ids(
+            GetSpecificsFieldNumberFromModelType(it.Get()));
+      }
+      partial_failure_ = false;
     }
   }
 
   response.SerializeToString(&params->buffer_out);
   if (post.message_contents() == ClientToServerMessage::COMMIT &&
       !mid_commit_callback_.is_null()) {
     mid_commit_callback_.Run();
     mid_commit_callback_.Reset();
   }
   if (mid_commit_observer_) {
@@ skipping 576 matching lines @@
     server_status_ = HttpResponse::SERVER_CONNECTION_OK;
   }
 }
 
 void MockConnectionManager::SetServerStatus(
     HttpResponse::ServerConnectionCode server_status) {
   server_status_ = server_status;
 }
 
 }  // namespace syncer