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

Unified Diff: sync/engine/sync_scheduler_impl.cc

Issue 10837214: Refactor ModelTypePayloadMap and ObjectIdPayloadMap to StateMaps. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Fix unit test Created 8 years, 4 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/sync_scheduler_impl.h ('k') | sync/engine/sync_scheduler_unittest.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: sync/engine/sync_scheduler_impl.cc
diff --git a/sync/engine/sync_scheduler_impl.cc b/sync/engine/sync_scheduler_impl.cc
index ff177b4f8347ec1bcd5582ee5c4873bb1cf948ec..dab9b1bcb76e4fa549e5b3ffd7647ff3325afb34 100644
--- a/sync/engine/sync_scheduler_impl.cc
+++ b/sync/engine/sync_scheduler_impl.cc
@@ -351,7 +351,7 @@ bool SyncSchedulerImpl::ScheduleConfiguration(
session_context_,
this,
SyncSourceInfo(params.source,
- ModelSafeRoutingInfoToPayloadMap(
+ ModelSafeRoutingInfoToStateMap(
restricted_routes,
std::string())),
restricted_routes,
@@ -423,7 +423,7 @@ SyncSchedulerImpl::JobProcessDecision SyncSchedulerImpl::DecideOnJob(
if (job.purpose == SyncSessionJob::NUDGE &&
job.session->source().updates_source == GetUpdatesCallerInfo::LOCAL) {
ModelTypeSet requested_types;
- for (ModelTypePayloadMap::const_iterator i =
+ for (ModelTypeStateMap::const_iterator i =
job.session->source().types.begin();
i != job.session->source().types.end();
++i) {
@@ -554,29 +554,29 @@ void SyncSchedulerImpl::ScheduleNudgeAsync(
<< "source " << GetNudgeSourceString(source) << ", "
<< "types " << ModelTypeSetToString(types);
- ModelTypePayloadMap types_with_payloads =
- ModelTypePayloadMapFromEnumSet(types, std::string());
+ ModelTypeStateMap type_state_map =
+ ModelTypeSetToStateMap(types, std::string());
SyncSchedulerImpl::ScheduleNudgeImpl(delay,
GetUpdatesFromNudgeSource(source),
- types_with_payloads,
+ type_state_map,
false,
nudge_location);
}
-void SyncSchedulerImpl::ScheduleNudgeWithPayloadsAsync(
+void SyncSchedulerImpl::ScheduleNudgeWithStatesAsync(
const TimeDelta& delay,
- NudgeSource source, const ModelTypePayloadMap& types_with_payloads,
+ NudgeSource source, const ModelTypeStateMap& type_state_map,
const tracked_objects::Location& nudge_location) {
DCHECK_EQ(MessageLoop::current(), sync_loop_);
SDVLOG_LOC(nudge_location, 2)
<< "Nudge scheduled with delay " << delay.InMilliseconds() << " ms, "
<< "source " << GetNudgeSourceString(source) << ", "
<< "payloads "
- << ModelTypePayloadMapToString(types_with_payloads);
+ << ModelTypeStateMapToString(type_state_map);
SyncSchedulerImpl::ScheduleNudgeImpl(delay,
GetUpdatesFromNudgeSource(source),
- types_with_payloads,
+ type_state_map,
false,
nudge_location);
}
@@ -584,7 +584,7 @@ void SyncSchedulerImpl::ScheduleNudgeWithPayloadsAsync(
void SyncSchedulerImpl::ScheduleNudgeImpl(
const TimeDelta& delay,
GetUpdatesCallerInfo::GetUpdatesSource source,
- const ModelTypePayloadMap& types_with_payloads,
+ const ModelTypeStateMap& type_state_map,
bool is_canary_job, const tracked_objects::Location& nudge_location) {
DCHECK_EQ(MessageLoop::current(), sync_loop_);
@@ -593,10 +593,10 @@ void SyncSchedulerImpl::ScheduleNudgeImpl(
<< delay.InMilliseconds() << " ms, "
<< "source " << GetUpdatesSourceString(source) << ", "
<< "payloads "
- << ModelTypePayloadMapToString(types_with_payloads)
+ << ModelTypeStateMapToString(type_state_map)
<< (is_canary_job ? " (canary)" : "");
- SyncSourceInfo info(source, types_with_payloads);
+ SyncSourceInfo info(source, type_state_map);
SyncSession* session(CreateSyncSession(info));
SyncSessionJob job(SyncSessionJob::NUDGE, TimeTicks::Now() + delay,
@@ -774,7 +774,7 @@ void SyncSchedulerImpl::FinishSyncSessionJob(const SyncSessionJob& job) {
// Update timing information for how often datatypes are triggering nudges.
base::TimeTicks now = TimeTicks::Now();
if (!last_sync_session_end_time_.is_null()) {
- ModelTypePayloadMap::const_iterator iter;
+ ModelTypeStateMap::const_iterator iter;
for (iter = job.session->source().types.begin();
iter != job.session->source().types.end();
++iter) {
@@ -1013,9 +1013,9 @@ SyncSession* SyncSchedulerImpl::CreateSyncSession(
void SyncSchedulerImpl::PollTimerCallback() {
DCHECK_EQ(MessageLoop::current(), sync_loop_);
ModelSafeRoutingInfo r;
- ModelTypePayloadMap types_with_payloads =
- ModelSafeRoutingInfoToPayloadMap(r, std::string());
- SyncSourceInfo info(GetUpdatesCallerInfo::PERIODIC, types_with_payloads);
+ ModelTypeStateMap type_state_map =
+ ModelSafeRoutingInfoToStateMap(r, std::string());
+ SyncSourceInfo info(GetUpdatesCallerInfo::PERIODIC, type_state_map);
SyncSession* s = CreateSyncSession(info);
SyncSessionJob job(SyncSessionJob::POLL, TimeTicks::Now(),
« no previous file with comments | « sync/engine/sync_scheduler_impl.h ('k') | sync/engine/sync_scheduler_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698