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

Unified Diff: components/sync/engine_impl/sync_scheduler_impl.cc

Issue 2850213002: [Sync] Minor refactor around SyncCycle and ModelTypeSet usage. (Closed)
Patch Set: Fix comment grammar. Created 3 years, 8 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: components/sync/engine_impl/sync_scheduler_impl.cc
diff --git a/components/sync/engine_impl/sync_scheduler_impl.cc b/components/sync/engine_impl/sync_scheduler_impl.cc
index d9d72533754ab6518a7f42bb63b25b7d3a7f23e3..96e6d202fb36fbd4957c4216db4c8d2a28cf39ae 100644
--- a/components/sync/engine_impl/sync_scheduler_impl.cc
+++ b/components/sync/engine_impl/sync_scheduler_impl.cc
@@ -239,9 +239,8 @@ ModelTypeSet SyncSchedulerImpl::GetEnabledAndUnblockedTypes() {
void SyncSchedulerImpl::SendInitialSnapshot() {
DCHECK(CalledOnValidThread());
- std::unique_ptr<SyncCycle> dummy(SyncCycle::Build(cycle_context_, this));
SyncCycleEvent event(SyncCycleEvent::STATUS_CHANGED);
- event.snapshot = dummy->TakeSnapshot();
+ event.snapshot = SyncCycle(cycle_context_, this).TakeSnapshot();
for (auto& observer : *cycle_context_->listeners())
observer.OnSyncCycleEvent(event);
}
@@ -429,9 +428,9 @@ void SyncSchedulerImpl::DoNudgeSyncCycleJob(JobPriority priority) {
DVLOG(2) << "Will run normal mode sync cycle with types "
<< ModelTypeSetToString(GetEnabledAndUnblockedTypes());
- std::unique_ptr<SyncCycle> cycle(SyncCycle::Build(cycle_context_, this));
+ SyncCycle cycle(cycle_context_, this);
bool success = syncer_->NormalSyncShare(GetEnabledAndUnblockedTypes(),
- &nudge_tracker_, cycle.get());
+ &nudge_tracker_, &cycle);
if (success) {
// That cycle took care of any outstanding work we had.
@@ -447,7 +446,7 @@ void SyncSchedulerImpl::DoNudgeSyncCycleJob(JobPriority priority) {
AdjustPolling(UPDATE_INTERVAL);
}
} else {
- HandleFailure(cycle->status_controller().model_neutral_state());
+ HandleFailure(cycle.status_controller().model_neutral_state());
}
}
@@ -465,10 +464,10 @@ void SyncSchedulerImpl::DoConfigurationSyncCycleJob(JobPriority priority) {
SDVLOG(2) << "Will run configure SyncShare with types "
<< ModelTypeSetToString(
pending_configure_params_->types_to_download);
- std::unique_ptr<SyncCycle> cycle(SyncCycle::Build(cycle_context_, this));
- bool success = syncer_->ConfigureSyncShare(
- pending_configure_params_->types_to_download,
- pending_configure_params_->source, cycle.get());
+ SyncCycle cycle(cycle_context_, this);
+ bool success =
+ syncer_->ConfigureSyncShare(pending_configure_params_->types_to_download,
+ pending_configure_params_->source, &cycle);
if (success) {
SDVLOG(2) << "Configure succeeded.";
@@ -476,7 +475,7 @@ void SyncSchedulerImpl::DoConfigurationSyncCycleJob(JobPriority priority) {
pending_configure_params_.reset();
HandleSuccess();
} else {
- HandleFailure(cycle->status_controller().model_neutral_state());
+ HandleFailure(cycle.status_controller().model_neutral_state());
// Sync cycle might receive response from server that causes scheduler to
// stop and draws pending_configure_params_ invalid.
if (started_)
@@ -493,10 +492,10 @@ void SyncSchedulerImpl::DoClearServerDataSyncCycleJob(JobPriority priority) {
return;
}
- std::unique_ptr<SyncCycle> cycle(SyncCycle::Build(cycle_context_, this));
- const bool success = syncer_->PostClearServerData(cycle.get());
+ SyncCycle cycle(cycle_context_, this);
+ const bool success = syncer_->PostClearServerData(&cycle);
if (!success) {
- HandleFailure(cycle->status_controller().model_neutral_state());
+ HandleFailure(cycle.status_controller().model_neutral_state());
return;
}
@@ -538,9 +537,8 @@ void SyncSchedulerImpl::HandleFailure(
void SyncSchedulerImpl::DoPollSyncCycleJob() {
SDVLOG(2) << "Polling with types "
<< ModelTypeSetToString(GetEnabledAndUnblockedTypes());
- std::unique_ptr<SyncCycle> cycle(SyncCycle::Build(cycle_context_, this));
- bool success =
- syncer_->PollSyncShare(GetEnabledAndUnblockedTypes(), cycle.get());
+ SyncCycle cycle(cycle_context_, this);
+ bool success = syncer_->PollSyncShare(GetEnabledAndUnblockedTypes(), &cycle);
// Only restart the timer if the poll succeeded. Otherwise rely on normal
// failure handling to retry with backoff.
@@ -548,7 +546,7 @@ void SyncSchedulerImpl::DoPollSyncCycleJob() {
AdjustPolling(FORCE_RESET);
HandleSuccess();
} else {
- HandleFailure(cycle->status_controller().model_neutral_state());
+ HandleFailure(cycle.status_controller().model_neutral_state());
}
}
« no previous file with comments | « components/sync/engine_impl/get_updates_processor.cc ('k') | components/sync/engine_impl/sync_scheduler_impl_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698