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

Side by Side Diff: sync/engine/syncer.cc

Issue 171813013: sync: Merge GU retry logic into normal GU (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Rebase Created 6 years, 9 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 unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « sync/engine/syncer.h ('k') | sync/sessions/data_type_tracker.h » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 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 "sync/engine/syncer.h" 5 #include "sync/engine/syncer.h"
6 6
7 #include "base/debug/trace_event.h" 7 #include "base/debug/trace_event.h"
8 #include "base/location.h" 8 #include "base/location.h"
9 #include "base/logging.h" 9 #include "base/logging.h"
10 #include "base/message_loop/message_loop.h" 10 #include "base/message_loop/message_loop.h"
(...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after
63 VLOG(1) << "Downloading types " << ModelTypeSetToString(request_types); 63 VLOG(1) << "Downloading types " << ModelTypeSetToString(request_types);
64 NormalGetUpdatesDelegate normal_delegate(nudge_tracker); 64 NormalGetUpdatesDelegate normal_delegate(nudge_tracker);
65 GetUpdatesProcessor get_updates_processor( 65 GetUpdatesProcessor get_updates_processor(
66 session->context()->model_type_registry()->update_handler_map(), 66 session->context()->model_type_registry()->update_handler_map(),
67 normal_delegate); 67 normal_delegate);
68 if (!DownloadAndApplyUpdates( 68 if (!DownloadAndApplyUpdates(
69 request_types, 69 request_types,
70 session, 70 session,
71 &get_updates_processor, 71 &get_updates_processor,
72 kCreateMobileBookmarksFolder)) { 72 kCreateMobileBookmarksFolder)) {
73 return HandleCycleEnd(session, nudge_tracker.updates_source()); 73 return HandleCycleEnd(session, nudge_tracker.GetLegacySource());
74 } 74 }
75 } 75 }
76 76
77 VLOG(1) << "Committing from types " << ModelTypeSetToString(request_types); 77 VLOG(1) << "Committing from types " << ModelTypeSetToString(request_types);
78 CommitProcessor commit_processor( 78 CommitProcessor commit_processor(
79 session->context()->model_type_registry()->commit_contributor_map()); 79 session->context()->model_type_registry()->commit_contributor_map());
80 SyncerError commit_result = 80 SyncerError commit_result =
81 BuildAndPostCommits(request_types, session, &commit_processor); 81 BuildAndPostCommits(request_types, session, &commit_processor);
82 session->mutable_status_controller()->set_commit_result(commit_result); 82 session->mutable_status_controller()->set_commit_result(commit_result);
83 83
84 return HandleCycleEnd(session, nudge_tracker.updates_source()); 84 return HandleCycleEnd(session, nudge_tracker.GetLegacySource());
85 } 85 }
86 86
87 bool Syncer::ConfigureSyncShare( 87 bool Syncer::ConfigureSyncShare(
88 ModelTypeSet request_types, 88 ModelTypeSet request_types,
89 sync_pb::GetUpdatesCallerInfo::GetUpdatesSource source, 89 sync_pb::GetUpdatesCallerInfo::GetUpdatesSource source,
90 SyncSession* session) { 90 SyncSession* session) {
91 VLOG(1) << "Configuring types " << ModelTypeSetToString(request_types); 91 VLOG(1) << "Configuring types " << ModelTypeSetToString(request_types);
92 HandleCycleBegin(session); 92 HandleCycleBegin(session);
93 ConfigureGetUpdatesDelegate configure_delegate(source); 93 ConfigureGetUpdatesDelegate configure_delegate(source);
94 GetUpdatesProcessor get_updates_processor( 94 GetUpdatesProcessor get_updates_processor(
(...skipping 16 matching lines...) Expand all
111 session->context()->model_type_registry()->update_handler_map(), 111 session->context()->model_type_registry()->update_handler_map(),
112 poll_delegate); 112 poll_delegate);
113 DownloadAndApplyUpdates( 113 DownloadAndApplyUpdates(
114 request_types, 114 request_types,
115 session, 115 session,
116 &get_updates_processor, 116 &get_updates_processor,
117 kCreateMobileBookmarksFolder); 117 kCreateMobileBookmarksFolder);
118 return HandleCycleEnd(session, sync_pb::GetUpdatesCallerInfo::PERIODIC); 118 return HandleCycleEnd(session, sync_pb::GetUpdatesCallerInfo::PERIODIC);
119 } 119 }
120 120
121 bool Syncer::RetrySyncShare(ModelTypeSet request_types,
122 SyncSession* session) {
123 VLOG(1) << "Retrying types " << ModelTypeSetToString(request_types);
124 HandleCycleBegin(session);
125 RetryGetUpdatesDelegate retry_delegate;
126 GetUpdatesProcessor get_updates_processor(
127 session->context()->model_type_registry()->update_handler_map(),
128 retry_delegate);
129 DownloadAndApplyUpdates(
130 request_types,
131 session,
132 &get_updates_processor,
133 kCreateMobileBookmarksFolder);
134 return HandleCycleEnd(session, sync_pb::GetUpdatesCallerInfo::RETRY);
135 }
136
137 bool Syncer::DownloadAndApplyUpdates( 121 bool Syncer::DownloadAndApplyUpdates(
138 ModelTypeSet request_types, 122 ModelTypeSet request_types,
139 SyncSession* session, 123 SyncSession* session,
140 GetUpdatesProcessor* get_updates_processor, 124 GetUpdatesProcessor* get_updates_processor,
141 bool create_mobile_bookmarks_folder) { 125 bool create_mobile_bookmarks_folder) {
142 SyncerError download_result = UNSET; 126 SyncerError download_result = UNSET;
143 do { 127 do {
144 download_result = get_updates_processor->DownloadUpdates( 128 download_result = get_updates_processor->DownloadUpdates(
145 request_types, 129 request_types,
146 session, 130 session,
(...skipping 70 matching lines...) Expand 10 before | Expand all | Expand 10 after
217 sync_pb::GetUpdatesCallerInfo::GetUpdatesSource source) { 201 sync_pb::GetUpdatesCallerInfo::GetUpdatesSource source) {
218 if (!ExitRequested()) { 202 if (!ExitRequested()) {
219 session->SendSyncCycleEndEventNotification(source); 203 session->SendSyncCycleEndEventNotification(source);
220 return true; 204 return true;
221 } else { 205 } else {
222 return false; 206 return false;
223 } 207 }
224 } 208 }
225 209
226 } // namespace syncer 210 } // namespace syncer
OLDNEW
« no previous file with comments | « sync/engine/syncer.h ('k') | sync/sessions/data_type_tracker.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698