[Sync] Parse and save per-data type throttle data

chrome/browser/sync/engine/syncer_proto_util.h

 // 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.
 
 #ifndef CHROME_BROWSER_SYNC_ENGINE_SYNCER_PROTO_UTIL_H_
 #define CHROME_BROWSER_SYNC_ENGINE_SYNCER_PROTO_UTIL_H_
 #pragma once
 
 #include <string>
 
 #include "base/gtest_prod_util.h"

[akalin, 2011/11/21 20:04:26]

#include "base/time.h"

[lipalani1, 2011/11/21 21:55:38]

Done.

+#include "chrome/browser/sync/sessions/sync_session.h"
+#include "chrome/browser/sync/sessions/sync_session_context.h"

[akalin, 2011/11/21 20:04:26]

forward-declare context and syncprotocolerror

[lipalani1, 2011/11/21 21:55:38]

Done.

 #include "chrome/browser/sync/syncable/blob.h"
 #include "chrome/browser/sync/syncable/model_type.h"
 
 namespace syncable {
 class Directory;
 class Entry;
 }  // namespace syncable
 
 namespace sync_pb {
 class ClientToServerResponse;
 class EntitySpecifics;
 }  // namespace sync_pb
 
 namespace browser_sync {
 
 namespace sessions {
 class SyncSession;

[akalin, 2011/11/21 20:04:26]

remove this since you're #including now

[lipalani1, 2011/11/21 21:55:38]

Done.

 }
 
 class ClientToServerMessage;
 class ServerConnectionManager;
 class SyncEntity;
 class CommitResponse_EntryResponse;
 
 class SyncerProtoUtil {
  public:
   // Posts the given message and fills the buffer with the returned value.
@@ skipping 69 matching lines @@
   // Post the message using the scm, and do some processing on the returned
   // headers. Decode the server response.
   static bool PostAndProcessHeaders(browser_sync::ServerConnectionManager* scm,
                                     sessions::SyncSession* session,
                                     const ClientToServerMessage& msg,
                                     sync_pb::ClientToServerResponse* response);
 
   static base::TimeDelta GetThrottleDelay(
       const sync_pb::ClientToServerResponse& response);
 
+  static void SyncerProtoUtil::HandleThrottling(

[akalin, 2011/11/21 20:04:26]

remove SyncerProtoUtil::

[lipalani1, 2011/11/21 21:55:38]

Done.

+    const SyncProtocolError& error,
+    const base::TimeTicks& throttled_until,
+    sessions::SyncSessionContext* context,
+    sessions::SyncSession::Delegate* delegate);
+
   friend class SyncerProtoUtilTest;
   FRIEND_TEST_ALL_PREFIXES(SyncerProtoUtilTest, AddRequestBirthday);
   FRIEND_TEST_ALL_PREFIXES(SyncerProtoUtilTest, PostAndProcessHeaders);
   FRIEND_TEST_ALL_PREFIXES(SyncerProtoUtilTest, VerifyResponseBirthday);
+  FRIEND_TEST_ALL_PREFIXES(SyncerProtoUtilTest, HandleThrottlingNoDatatypes);
+  FRIEND_TEST_ALL_PREFIXES(SyncerProtoUtilTest, HandleThrottlingWithDatatypes);
 
   DISALLOW_COPY_AND_ASSIGN(SyncerProtoUtil);
 };
 
 }  // namespace browser_sync
 
 #endif  // CHROME_BROWSER_SYNC_ENGINE_SYNCER_PROTO_UTIL_H_