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

Unified Diff: sync/engine/get_updates_delegate.cc

Issue 2130453004: [Sync] Move //sync to //components/sync. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Rebase. Created 4 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
« no previous file with comments | « sync/engine/get_updates_delegate.h ('k') | sync/engine/get_updates_processor.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: sync/engine/get_updates_delegate.cc
diff --git a/sync/engine/get_updates_delegate.cc b/sync/engine/get_updates_delegate.cc
deleted file mode 100644
index 8ee88b729b0ad1e0b204ba950dfc2dea3c2ec3d5..0000000000000000000000000000000000000000
--- a/sync/engine/get_updates_delegate.cc
+++ /dev/null
@@ -1,173 +0,0 @@
-// Copyright 2014 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.
-
-#include "sync/engine/get_updates_delegate.h"
-
-#include "sync/engine/directory_update_handler.h"
-#include "sync/engine/get_updates_processor.h"
-#include "sync/internal_api/public/events/configure_get_updates_request_event.h"
-#include "sync/internal_api/public/events/normal_get_updates_request_event.h"
-#include "sync/internal_api/public/events/poll_get_updates_request_event.h"
-
-namespace syncer {
-
-namespace {
-
-void NonPassiveApplyUpdates(
- ModelTypeSet gu_types,
- sessions::StatusController* status_controller,
- UpdateHandlerMap* update_handler_map) {
- for (UpdateHandlerMap::iterator it = update_handler_map->begin();
- it != update_handler_map->end(); ++it) {
- if (gu_types.Has(it->first))
- it->second->ApplyUpdates(status_controller);
- }
-}
-
-void PassiveApplyUpdates(
- ModelTypeSet gu_types,
- sessions::StatusController* status_controller,
- UpdateHandlerMap* update_handler_map) {
- for (UpdateHandlerMap::iterator it = update_handler_map->begin();
- it != update_handler_map->end(); ++it) {
- if (gu_types.Has(it->first))
- it->second->PassiveApplyUpdates(status_controller);
- }
-}
-
-} // namespace
-
-GetUpdatesDelegate::GetUpdatesDelegate() {}
-
-GetUpdatesDelegate::~GetUpdatesDelegate() {}
-
-NormalGetUpdatesDelegate::NormalGetUpdatesDelegate(
- const sessions::NudgeTracker& nudge_tracker)
- : nudge_tracker_(nudge_tracker) {}
-
-NormalGetUpdatesDelegate::~NormalGetUpdatesDelegate() {}
-
-// This function assumes the progress markers have already been populated.
-void NormalGetUpdatesDelegate::HelpPopulateGuMessage(
- sync_pb::GetUpdatesMessage* get_updates) const {
- // Set legacy GetUpdatesMessage.GetUpdatesCallerInfo information.
- get_updates->mutable_caller_info()->set_source(
- nudge_tracker_.GetLegacySource());
-
- // Set the new and improved version of source, too.
- get_updates->set_get_updates_origin(sync_pb::SyncEnums::GU_TRIGGER);
- get_updates->set_is_retry(nudge_tracker_.IsRetryRequired());
-
- // Special case: A GU performed for no other reason than retry will have its
- // origin set to RETRY.
- if (nudge_tracker_.GetLegacySource() == sync_pb::GetUpdatesCallerInfo::RETRY)
- get_updates->set_get_updates_origin(sync_pb::SyncEnums::RETRY);
-
- // Fill in the notification hints.
- for (int i = 0; i < get_updates->from_progress_marker_size(); ++i) {
- sync_pb::DataTypeProgressMarker* progress_marker =
- get_updates->mutable_from_progress_marker(i);
- ModelType type = GetModelTypeFromSpecificsFieldNumber(
- progress_marker->data_type_id());
-
- DCHECK(!nudge_tracker_.IsTypeThrottled(type))
- << "Throttled types should have been removed from the request_types.";
-
- nudge_tracker_.SetLegacyNotificationHint(type, progress_marker);
- nudge_tracker_.FillProtoMessage(
- type,
- progress_marker->mutable_get_update_triggers());
- }
-}
-
-void NormalGetUpdatesDelegate::ApplyUpdates(
- ModelTypeSet gu_types,
- sessions::StatusController* status_controller,
- UpdateHandlerMap* update_handler_map) const {
- NonPassiveApplyUpdates(gu_types, status_controller, update_handler_map);
-}
-
-std::unique_ptr<ProtocolEvent> NormalGetUpdatesDelegate::GetNetworkRequestEvent(
- base::Time timestamp,
- const sync_pb::ClientToServerMessage& request) const {
- return std::unique_ptr<ProtocolEvent>(
- new NormalGetUpdatesRequestEvent(timestamp, nudge_tracker_, request));
-}
-
-ConfigureGetUpdatesDelegate::ConfigureGetUpdatesDelegate(
- sync_pb::GetUpdatesCallerInfo::GetUpdatesSource source) : source_(source) {}
-
-ConfigureGetUpdatesDelegate::~ConfigureGetUpdatesDelegate() {}
-
-void ConfigureGetUpdatesDelegate::HelpPopulateGuMessage(
- sync_pb::GetUpdatesMessage* get_updates) const {
- get_updates->mutable_caller_info()->set_source(source_);
- get_updates->set_get_updates_origin(ConvertConfigureSourceToOrigin(source_));
-}
-
-void ConfigureGetUpdatesDelegate::ApplyUpdates(
- ModelTypeSet gu_types,
- sessions::StatusController* status_controller,
- UpdateHandlerMap* update_handler_map) const {
- PassiveApplyUpdates(gu_types, status_controller, update_handler_map);
-}
-
-std::unique_ptr<ProtocolEvent>
-ConfigureGetUpdatesDelegate::GetNetworkRequestEvent(
- base::Time timestamp,
- const sync_pb::ClientToServerMessage& request) const {
- return std::unique_ptr<ProtocolEvent>(new ConfigureGetUpdatesRequestEvent(
- timestamp, ConvertConfigureSourceToOrigin(source_), request));
-}
-
-sync_pb::SyncEnums::GetUpdatesOrigin
-ConfigureGetUpdatesDelegate::ConvertConfigureSourceToOrigin(
- sync_pb::GetUpdatesCallerInfo::GetUpdatesSource source) {
- switch (source) {
- // Configurations:
- case sync_pb::GetUpdatesCallerInfo::NEWLY_SUPPORTED_DATATYPE:
- return sync_pb::SyncEnums::NEWLY_SUPPORTED_DATATYPE;
- case sync_pb::GetUpdatesCallerInfo::MIGRATION:
- return sync_pb::SyncEnums::MIGRATION;
- case sync_pb::GetUpdatesCallerInfo::RECONFIGURATION:
- return sync_pb::SyncEnums::RECONFIGURATION;
- case sync_pb::GetUpdatesCallerInfo::NEW_CLIENT:
- return sync_pb::SyncEnums::NEW_CLIENT;
- case sync_pb::GetUpdatesCallerInfo::PROGRAMMATIC:
- return sync_pb::SyncEnums::PROGRAMMATIC;
- default:
- NOTREACHED();
- return sync_pb::SyncEnums::UNKNOWN_ORIGIN;
- }
-}
-
-PollGetUpdatesDelegate::PollGetUpdatesDelegate() {}
-
-PollGetUpdatesDelegate::~PollGetUpdatesDelegate() {}
-
-void PollGetUpdatesDelegate::HelpPopulateGuMessage(
- sync_pb::GetUpdatesMessage* get_updates) const {
- // Set legacy GetUpdatesMessage.GetUpdatesCallerInfo information.
- get_updates->mutable_caller_info()->set_source(
- sync_pb::GetUpdatesCallerInfo::PERIODIC);
-
- // Set the new and improved version of source, too.
- get_updates->set_get_updates_origin(sync_pb::SyncEnums::PERIODIC);
-}
-
-void PollGetUpdatesDelegate::ApplyUpdates(
- ModelTypeSet gu_types,
- sessions::StatusController* status_controller,
- UpdateHandlerMap* update_handler_map) const {
- NonPassiveApplyUpdates(gu_types, status_controller, update_handler_map);
-}
-
-std::unique_ptr<ProtocolEvent> PollGetUpdatesDelegate::GetNetworkRequestEvent(
- base::Time timestamp,
- const sync_pb::ClientToServerMessage& request) const {
- return std::unique_ptr<ProtocolEvent>(
- new PollGetUpdatesRequestEvent(timestamp, request));
-}
-
-} // namespace syncer
« no previous file with comments | « sync/engine/get_updates_delegate.h ('k') | sync/engine/get_updates_processor.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698