| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "components/sync/engine_impl/get_updates_processor.h" | 5 #include "components/sync/engine_impl/get_updates_processor.h" |
| 6 | 6 |
| 7 #include <stddef.h> | 7 #include <stddef.h> |
| 8 | 8 |
| 9 #include <utility> |
| 10 |
| 9 #include "base/trace_event/trace_event.h" | 11 #include "base/trace_event/trace_event.h" |
| 10 #include "components/sync/engine/events/get_updates_response_event.h" | 12 #include "components/sync/engine/events/get_updates_response_event.h" |
| 11 #include "components/sync/engine_impl/cycle/status_controller.h" | 13 #include "components/sync/engine_impl/cycle/status_controller.h" |
| 12 #include "components/sync/engine_impl/cycle/sync_cycle.h" | 14 #include "components/sync/engine_impl/cycle/sync_cycle.h" |
| 13 #include "components/sync/engine_impl/get_updates_delegate.h" | 15 #include "components/sync/engine_impl/get_updates_delegate.h" |
| 14 #include "components/sync/engine_impl/syncer_proto_util.h" | 16 #include "components/sync/engine_impl/syncer_proto_util.h" |
| 15 #include "components/sync/engine_impl/update_handler.h" | 17 #include "components/sync/engine_impl/update_handler.h" |
| 16 #include "components/sync/syncable/directory.h" | 18 #include "components/sync/syncable/directory.h" |
| 17 #include "components/sync/syncable/nigori_handler.h" | 19 #include "components/sync/syncable/nigori_handler.h" |
| 18 #include "components/sync/syncable/syncable_read_transaction.h" | 20 #include "components/sync/syncable/syncable_read_transaction.h" |
| 19 | 21 |
| 20 typedef std::vector<const sync_pb::SyncEntity*> SyncEntityList; | |
| 21 typedef std::map<syncer::ModelType, SyncEntityList> TypeSyncEntityMap; | |
| 22 | |
| 23 namespace syncer { | 22 namespace syncer { |
| 24 | 23 |
| 24 namespace { |
| 25 |
| 26 typedef std::vector<const sync_pb::SyncEntity*> SyncEntityList; |
| 27 typedef std::map<ModelType, SyncEntityList> TypeSyncEntityMap; |
| 25 typedef std::map<ModelType, size_t> TypeToIndexMap; | 28 typedef std::map<ModelType, size_t> TypeToIndexMap; |
| 26 | 29 |
| 27 namespace { | |
| 28 | |
| 29 bool ShouldRequestEncryptionKey(SyncCycleContext* context) { | 30 bool ShouldRequestEncryptionKey(SyncCycleContext* context) { |
| 30 syncable::Directory* dir = context->directory(); | 31 syncable::Directory* dir = context->directory(); |
| 31 syncable::ReadTransaction trans(FROM_HERE, dir); | 32 syncable::ReadTransaction trans(FROM_HERE, dir); |
| 32 syncable::NigoriHandler* nigori_handler = dir->GetNigoriHandler(); | 33 syncable::NigoriHandler* nigori_handler = dir->GetNigoriHandler(); |
| 33 return nigori_handler->NeedKeystoreKey(&trans); | 34 return nigori_handler->NeedKeystoreKey(&trans); |
| 34 } | 35 } |
| 35 | 36 |
| 36 SyncerError HandleGetEncryptionKeyResponse( | 37 SyncerError HandleGetEncryptionKeyResponse( |
| 37 const sync_pb::ClientToServerResponse& update_response, | 38 const sync_pb::ClientToServerResponse& update_response, |
| 38 syncable::Directory* dir) { | 39 syncable::Directory* dir) { |
| (...skipping 238 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 277 ModelTypeSet request_types, | 278 ModelTypeSet request_types, |
| 278 StatusController* status) { | 279 StatusController* status) { |
| 279 status->increment_num_updates_downloaded_by(gu_response.entries_size()); | 280 status->increment_num_updates_downloaded_by(gu_response.entries_size()); |
| 280 | 281 |
| 281 // The changes remaining field is used to prevent the client from looping. If | 282 // The changes remaining field is used to prevent the client from looping. If |
| 282 // that field is being set incorrectly, we're in big trouble. | 283 // that field is being set incorrectly, we're in big trouble. |
| 283 if (!gu_response.has_changes_remaining()) { | 284 if (!gu_response.has_changes_remaining()) { |
| 284 return SERVER_RESPONSE_VALIDATION_FAILED; | 285 return SERVER_RESPONSE_VALIDATION_FAILED; |
| 285 } | 286 } |
| 286 | 287 |
| 287 syncer::SyncerError result = | 288 SyncerError result = |
| 288 ProcessGetUpdatesResponse(request_types, gu_response, status); | 289 ProcessGetUpdatesResponse(request_types, gu_response, status); |
| 289 if (result != syncer::SYNCER_OK) | 290 if (result != SYNCER_OK) |
| 290 return result; | 291 return result; |
| 291 | 292 |
| 292 if (gu_response.changes_remaining() == 0) { | 293 if (gu_response.changes_remaining() == 0) { |
| 293 return SYNCER_OK; | 294 return SYNCER_OK; |
| 294 } else { | 295 } else { |
| 295 return SERVER_MORE_TO_DOWNLOAD; | 296 return SERVER_MORE_TO_DOWNLOAD; |
| 296 } | 297 } |
| 297 } | 298 } |
| 298 | 299 |
| 299 syncer::SyncerError GetUpdatesProcessor::ProcessGetUpdatesResponse( | 300 SyncerError GetUpdatesProcessor::ProcessGetUpdatesResponse( |
| 300 ModelTypeSet gu_types, | 301 ModelTypeSet gu_types, |
| 301 const sync_pb::GetUpdatesResponse& gu_response, | 302 const sync_pb::GetUpdatesResponse& gu_response, |
| 302 StatusController* status_controller) { | 303 StatusController* status_controller) { |
| 303 TypeSyncEntityMap updates_by_type; | 304 TypeSyncEntityMap updates_by_type; |
| 304 PartitionUpdatesByType(gu_response, gu_types, &updates_by_type); | 305 PartitionUpdatesByType(gu_response, gu_types, &updates_by_type); |
| 305 DCHECK_EQ(gu_types.Size(), updates_by_type.size()); | 306 DCHECK_EQ(gu_types.Size(), updates_by_type.size()); |
| 306 | 307 |
| 307 TypeToIndexMap progress_index_by_type; | 308 TypeToIndexMap progress_index_by_type; |
| 308 PartitionProgressMarkersByType(gu_response, gu_types, | 309 PartitionProgressMarkersByType(gu_response, gu_types, |
| 309 &progress_index_by_type); | 310 &progress_index_by_type); |
| 310 if (gu_types.Size() != progress_index_by_type.size()) { | 311 if (gu_types.Size() != progress_index_by_type.size()) { |
| 311 NOTREACHED() << "Missing progress markers in GetUpdates response."; | 312 NOTREACHED() << "Missing progress markers in GetUpdates response."; |
| 312 return syncer::SERVER_RESPONSE_VALIDATION_FAILED; | 313 return SERVER_RESPONSE_VALIDATION_FAILED; |
| 313 } | 314 } |
| 314 | 315 |
| 315 TypeToIndexMap context_by_type; | 316 TypeToIndexMap context_by_type; |
| 316 PartitionContextMutationsByType(gu_response, gu_types, &context_by_type); | 317 PartitionContextMutationsByType(gu_response, gu_types, &context_by_type); |
| 317 | 318 |
| 318 // Iterate over these maps in parallel, processing updates for each type. | 319 // Iterate over these maps in parallel, processing updates for each type. |
| 319 TypeToIndexMap::iterator progress_marker_iter = | 320 TypeToIndexMap::iterator progress_marker_iter = |
| 320 progress_index_by_type.begin(); | 321 progress_index_by_type.begin(); |
| 321 TypeSyncEntityMap::iterator updates_iter = updates_by_type.begin(); | 322 TypeSyncEntityMap::iterator updates_iter = updates_by_type.begin(); |
| 322 for (; (progress_marker_iter != progress_index_by_type.end() && | 323 for (; (progress_marker_iter != progress_index_by_type.end() && |
| 323 updates_iter != updates_by_type.end()); | 324 updates_iter != updates_by_type.end()); |
| 324 ++progress_marker_iter, ++updates_iter) { | 325 ++progress_marker_iter, ++updates_iter) { |
| 325 DCHECK_EQ(progress_marker_iter->first, updates_iter->first); | 326 DCHECK_EQ(progress_marker_iter->first, updates_iter->first); |
| 326 ModelType type = progress_marker_iter->first; | 327 ModelType type = progress_marker_iter->first; |
| 327 | 328 |
| 328 UpdateHandlerMap::iterator update_handler_iter = | 329 UpdateHandlerMap::iterator update_handler_iter = |
| 329 update_handler_map_->find(type); | 330 update_handler_map_->find(type); |
| 330 | 331 |
| 331 sync_pb::DataTypeContext context; | 332 sync_pb::DataTypeContext context; |
| 332 TypeToIndexMap::iterator context_iter = context_by_type.find(type); | 333 TypeToIndexMap::iterator context_iter = context_by_type.find(type); |
| 333 if (context_iter != context_by_type.end()) | 334 if (context_iter != context_by_type.end()) |
| 334 context.CopyFrom(gu_response.context_mutations(context_iter->second)); | 335 context.CopyFrom(gu_response.context_mutations(context_iter->second)); |
| 335 | 336 |
| 336 if (update_handler_iter != update_handler_map_->end()) { | 337 if (update_handler_iter != update_handler_map_->end()) { |
| 337 syncer::SyncerError result = | 338 SyncerError result = |
| 338 update_handler_iter->second->ProcessGetUpdatesResponse( | 339 update_handler_iter->second->ProcessGetUpdatesResponse( |
| 339 gu_response.new_progress_marker(progress_marker_iter->second), | 340 gu_response.new_progress_marker(progress_marker_iter->second), |
| 340 context, updates_iter->second, status_controller); | 341 context, updates_iter->second, status_controller); |
| 341 if (result != syncer::SYNCER_OK) | 342 if (result != SYNCER_OK) |
| 342 return result; | 343 return result; |
| 343 } else { | 344 } else { |
| 344 DLOG(WARNING) << "Ignoring received updates of a type we can't handle. " | 345 DLOG(WARNING) << "Ignoring received updates of a type we can't handle. " |
| 345 << "Type is: " << ModelTypeToString(type); | 346 << "Type is: " << ModelTypeToString(type); |
| 346 continue; | 347 continue; |
| 347 } | 348 } |
| 348 } | 349 } |
| 349 DCHECK(progress_marker_iter == progress_index_by_type.end() && | 350 DCHECK(progress_marker_iter == progress_index_by_type.end() && |
| 350 updates_iter == updates_by_type.end()); | 351 updates_iter == updates_by_type.end()); |
| 351 | 352 |
| 352 return syncer::SYNCER_OK; | 353 return SYNCER_OK; |
| 353 } | 354 } |
| 354 | 355 |
| 355 void GetUpdatesProcessor::ApplyUpdates(ModelTypeSet gu_types, | 356 void GetUpdatesProcessor::ApplyUpdates(ModelTypeSet gu_types, |
| 356 StatusController* status_controller) { | 357 StatusController* status_controller) { |
| 357 status_controller->set_get_updates_request_types(gu_types); | 358 status_controller->set_get_updates_request_types(gu_types); |
| 358 delegate_.ApplyUpdates(gu_types, status_controller, update_handler_map_); | 359 delegate_.ApplyUpdates(gu_types, status_controller, update_handler_map_); |
| 359 } | 360 } |
| 360 | 361 |
| 361 void GetUpdatesProcessor::CopyClientDebugInfo( | 362 void GetUpdatesProcessor::CopyClientDebugInfo( |
| 362 DebugInfoGetter* debug_info_getter, | 363 DebugInfoGetter* debug_info_getter, |
| 363 sync_pb::DebugInfo* debug_info) { | 364 sync_pb::DebugInfo* debug_info) { |
| 364 DVLOG(1) << "Copying client debug info to send."; | 365 DVLOG(1) << "Copying client debug info to send."; |
| 365 debug_info_getter->GetDebugInfo(debug_info); | 366 debug_info_getter->GetDebugInfo(debug_info); |
| 366 } | 367 } |
| 367 | 368 |
| 368 } // namespace syncer | 369 } // namespace syncer |
| OLD | NEW |