| 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
|
|
|