Index: sync/engine/syncer_proto_util.cc |
diff --git a/sync/engine/syncer_proto_util.cc b/sync/engine/syncer_proto_util.cc |
index 8a20b95067620ef6ac8a59dacf6e8024898adab4..25695913d414ac1b080557c191c436eab661c570 100644 |
--- a/sync/engine/syncer_proto_util.cc |
+++ b/sync/engine/syncer_proto_util.cc |
@@ -19,10 +19,13 @@ |
#include "sync/syncable/directory.h" |
#include "sync/syncable/entry.h" |
#include "sync/syncable/syncable-inl.h" |
+#include "sync/syncable/syncable_proto_util.h" |
#include "sync/util/time.h" |
using std::string; |
using std::stringstream; |
+using sync_pb::ClientToServerMessage; |
+using sync_pb::ClientToServerResponse; |
namespace syncer { |
@@ -107,7 +110,7 @@ SyncerError ServerConnectionErrorAsSyncerError( |
// static |
void SyncerProtoUtil::HandleMigrationDoneResponse( |
- const sync_pb::ClientToServerResponse* response, |
+ const ClientToServerResponse* response, |
sessions::SyncSession* session) { |
LOG_IF(ERROR, 0 >= response->migrated_data_type_id_size()) |
<< "MIGRATION_DONE but no types specified."; |
@@ -165,6 +168,9 @@ bool SyncerProtoUtil::PostAndProcessHeaders(ServerConnectionManager* scm, |
const ClientToServerMessage& msg, |
ClientToServerResponse* response) { |
ServerConnectionManager::PostBufferParams params; |
+ DCHECK(msg.has_protocol_version()); |
+ DCHECK_EQ(msg.protocol_version(), |
+ ClientToServerMessage::default_instance().protocol_version()); |
msg.SerializeToString(¶ms.buffer_in); |
ScopedServerStatusWatcher server_status_watcher(scm, ¶ms.response); |
@@ -199,7 +205,7 @@ bool SyncerProtoUtil::PostAndProcessHeaders(ServerConnectionManager* scm, |
} |
base::TimeDelta SyncerProtoUtil::GetThrottleDelay( |
- const sync_pb::ClientToServerResponse& response) { |
+ const ClientToServerResponse& response) { |
base::TimeDelta throttle_delay = |
base::TimeDelta::FromSeconds(kSyncDelayAfterThrottled); |
if (response.has_client_command()) { |
@@ -289,7 +295,7 @@ syncer::ClientAction ConvertClientActionPBToLocalClientAction( |
} |
syncer::SyncProtocolError ConvertErrorPBToLocalType( |
- const sync_pb::ClientToServerResponse::Error& error) { |
+ const ClientToServerResponse::Error& error) { |
syncer::SyncProtocolError sync_protocol_error; |
sync_protocol_error.error_type = ConvertSyncProtocolErrorTypePBToLocalType( |
error.error_type()); |
@@ -415,10 +421,10 @@ SyncerError SyncerProtoUtil::PostClientToServerMessage( |
// static |
bool SyncerProtoUtil::Compare(const syncable::Entry& local_entry, |
- const SyncEntity& server_entry) { |
+ const sync_pb::SyncEntity& server_entry) { |
const std::string name = NameFromSyncEntity(server_entry); |
- CHECK(local_entry.Get(ID) == server_entry.id()) << |
+ CHECK(local_entry.Get(ID) == SyncableIdFromProto(server_entry.id_string())) << |
akalin
2012/07/11 01:42:22
CHECK_EQ?
rlarocque
2012/07/11 19:22:16
Done.
|
" SyncerProtoUtil::Compare precondition not met."; |
CHECK(server_entry.version() == local_entry.Get(BASE_VERSION)) << |
" SyncerProtoUtil::Compare precondition not met."; |
@@ -439,11 +445,12 @@ bool SyncerProtoUtil::Compare(const syncable::Entry& local_entry, |
LOG(WARNING) << "Client name mismatch"; |
return false; |
} |
- if (local_entry.Get(PARENT_ID) != server_entry.parent_id()) { |
+ if (local_entry.Get(PARENT_ID) != |
+ SyncableIdFromProto(server_entry.parent_id_string())) { |
LOG(WARNING) << "Parent ID mismatch"; |
return false; |
} |
- if (local_entry.Get(IS_DIR) != server_entry.IsFolder()) { |
+ if (local_entry.Get(IS_DIR) != IsFolder(server_entry)) { |
LOG(WARNING) << "Dir field mismatch"; |
return false; |
} |
@@ -492,7 +499,7 @@ const std::string& SyncerProtoUtil::NameFromSyncEntity( |
// static |
const std::string& SyncerProtoUtil::NameFromCommitEntryResponse( |
- const CommitResponse_EntryResponse& entry) { |
+ const sync_pb::CommitResponse_EntryResponse& entry) { |
if (entry.has_non_unique_name()) |
return entry.non_unique_name(); |
return entry.name(); |
@@ -534,7 +541,7 @@ std::string GetUpdatesResponseString( |
} // namespace |
std::string SyncerProtoUtil::ClientToServerResponseDebugString( |
- const sync_pb::ClientToServerResponse& response) { |
+ const ClientToServerResponse& response) { |
// Add more handlers as needed. |
std::string output; |
if (response.has_get_updates()) |