Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(412)

Unified Diff: sync/engine/syncer_proto_util.cc

Issue 10735041: Remove syncproto.h (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Improve DCHECKing, fix tests Created 8 years, 5 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
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(&params.buffer_in);
ScopedServerStatusWatcher server_status_watcher(scm, &params.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())

Powered by Google App Engine
This is Rietveld 408576698