summaryrefslogtreecommitdiffstats
path: root/sync/engine
diff options
context:
space:
mode:
authortim@chromium.org <tim@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98>2012-09-17 05:40:06 +0000
committertim@chromium.org <tim@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98>2012-09-17 05:40:06 +0000
commit61161fdc716423ae44471cb08893977a8ed995ae (patch)
tree7e15efa48ae620addf6bfd7966835b99d1600022 /sync/engine
parent9874e3fbb370cab52617c2d4dd64340d75a9c8b2 (diff)
downloadchromium_src-61161fdc716423ae44471cb08893977a8ed995ae.zip
chromium_src-61161fdc716423ae44471cb08893977a8ed995ae.tar.gz
chromium_src-61161fdc716423ae44471cb08893977a8ed995ae.tar.bz2
sync: add Google API Key to all ClientToServerMessages.
Also move setting of "must have" sync fields to PostClientToServerMessage (from DownloadUpdatesCommand & BuildCommitCommand). Needed for M23 branch. BUG= Review URL: https://chromiumcodereview.appspot.com/10916276 git-svn-id: svn://svn.chromium.org/chrome/trunk/src@157081 0039d316-1c4b-4281-b951-d872f2087c98
Diffstat (limited to 'sync/engine')
-rw-r--r--sync/engine/build_commit_command.cc5
-rw-r--r--sync/engine/commit.cc2
-rw-r--r--sync/engine/download_updates_command.cc6
-rw-r--r--sync/engine/syncer_proto_util.cc24
-rw-r--r--sync/engine/syncer_proto_util.h2
5 files changed, 17 insertions, 22 deletions
diff --git a/sync/engine/build_commit_command.cc b/sync/engine/build_commit_command.cc
index ade6acb..8e51ddb 100644
--- a/sync/engine/build_commit_command.cc
+++ b/sync/engine/build_commit_command.cc
@@ -111,11 +111,6 @@ SyncerError BuildCommitCommand::ExecuteImpl(SyncSession* session) {
commit_message->set_cache_guid(
session->write_transaction()->directory()->cache_guid());
AddExtensionsActivityToMessage(session, commit_message);
- SyncerProtoUtil::SetProtocolVersion(commit_message_);
- SyncerProtoUtil::AddRequestBirthday(
- session->write_transaction()->directory(), commit_message_);
- SyncerProtoUtil::AddBagOfChips(
- session->write_transaction()->directory(), commit_message_);
// Cache previously computed position values. Because |commit_ids|
// is already in sibling order, we should always hit this map after
diff --git a/sync/engine/commit.cc b/sync/engine/commit.cc
index 731643a..49443e9 100644
--- a/sync/engine/commit.cc
+++ b/sync/engine/commit.cc
@@ -101,7 +101,7 @@ SyncerError BuildAndPostCommitsImpl(Syncer* syncer,
DVLOG(1) << "Sending commit message.";
TRACE_EVENT_BEGIN0("sync", "PostCommit");
const SyncerError post_result = SyncerProtoUtil::PostClientToServerMessage(
- commit_message, &commit_response, session);
+ &commit_message, &commit_response, session);
TRACE_EVENT_END0("sync", "PostCommit");
if (post_result != SYNCER_OK) {
diff --git a/sync/engine/download_updates_command.cc b/sync/engine/download_updates_command.cc
index cd0730a..50ad8a0 100644
--- a/sync/engine/download_updates_command.cc
+++ b/sync/engine/download_updates_command.cc
@@ -109,16 +109,12 @@ SyncerError DownloadUpdatesCommand::ExecuteImpl(SyncSession* session) {
get_updates->mutable_caller_info()->set_notifications_enabled(
session->context()->notifications_enabled());
- SyncerProtoUtil::SetProtocolVersion(&client_to_server_message);
- SyncerProtoUtil::AddRequestBirthday(dir, &client_to_server_message);
- SyncerProtoUtil::AddBagOfChips(dir, &client_to_server_message);
-
DebugInfo* debug_info = client_to_server_message.mutable_debug_info();
AppendClientDebugInfoIfNeeded(session, debug_info);
SyncerError result = SyncerProtoUtil::PostClientToServerMessage(
- client_to_server_message,
+ &client_to_server_message,
&update_response,
session);
diff --git a/sync/engine/syncer_proto_util.cc b/sync/engine/syncer_proto_util.cc
index 81b3c64..c24b538 100644
--- a/sync/engine/syncer_proto_util.cc
+++ b/sync/engine/syncer_proto_util.cc
@@ -6,6 +6,7 @@
#include "base/format_macros.h"
#include "base/stringprintf.h"
+#include "google_apis/google_api_keys.h"
#include "sync/engine/net/server_connection_manager.h"
#include "sync/engine/syncer.h"
#include "sync/engine/syncer_types.h"
@@ -346,24 +347,27 @@ SyncProtocolError ConvertLegacyErrorCodeToNewError(
// static
SyncerError SyncerProtoUtil::PostClientToServerMessage(
- const ClientToServerMessage& msg,
+ ClientToServerMessage* msg,
ClientToServerResponse* response,
SyncSession* session) {
CHECK(response);
- DCHECK(!msg.get_updates().has_from_timestamp()); // Deprecated.
- DCHECK(!msg.get_updates().has_requested_types()); // Deprecated.
- DCHECK(msg.has_store_birthday() || IsVeryFirstGetUpdates(msg))
- << "Must call AddRequestBirthday to set birthday.";
- DCHECK(msg.has_bag_of_chips())
- << "Must call AddBagOfChips to set bag_of_chips.";
+ DCHECK(!msg->get_updates().has_from_timestamp()); // Deprecated.
+ DCHECK(!msg->get_updates().has_requested_types()); // Deprecated.
+
+ // Add must-have fields.
+ SetProtocolVersion(msg);
+ AddRequestBirthday(session->context()->directory(), msg);
+ DCHECK(msg->has_store_birthday() || IsVeryFirstGetUpdates(*msg));
+ AddBagOfChips(session->context()->directory(), msg);
+ msg->set_api_key(google_apis::GetAPIKey());
syncable::Directory* dir = session->context()->directory();
- LogClientToServerMessage(msg);
- session->context()->traffic_recorder()->RecordClientToServerMessage(msg);
+ LogClientToServerMessage(*msg);
+ session->context()->traffic_recorder()->RecordClientToServerMessage(*msg);
if (!PostAndProcessHeaders(session->context()->connection_manager(), session,
- msg, response)) {
+ *msg, response)) {
// There was an error establishing communication with the server.
// We can not proceed beyond this point.
const HttpResponse::ServerConnectionCode server_status =
diff --git a/sync/engine/syncer_proto_util.h b/sync/engine/syncer_proto_util.h
index fab1406..8256dbd 100644
--- a/sync/engine/syncer_proto_util.h
+++ b/sync/engine/syncer_proto_util.h
@@ -43,7 +43,7 @@ class SyncerProtoUtil {
// Returns true on success. Also handles store birthday verification: will
// produce a SyncError if the birthday is incorrect.
static SyncerError PostClientToServerMessage(
- const sync_pb::ClientToServerMessage& msg,
+ sync_pb::ClientToServerMessage* msg,
sync_pb::ClientToServerResponse* response,
sessions::SyncSession* session);