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

Side by Side Diff: chrome/browser/prefs/pref_model_associator.cc

Issue 1302303002: Remove year+ old migration support of "session.urls_to_restore_on_startup". (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@pref_service_syncable_unittest
Patch Set: Remove old include of "base/gtest_prod_util.h" Created 5 years, 3 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
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 "chrome/browser/prefs/pref_model_associator.h" 5 #include "chrome/browser/prefs/pref_model_associator.h"
6 6
7 #include "base/auto_reset.h" 7 #include "base/auto_reset.h"
8 #include "base/json/json_reader.h" 8 #include "base/json/json_reader.h"
9 #include "base/json/json_string_value_serializer.h" 9 #include "base/json/json_string_value_serializer.h"
10 #include "base/location.h" 10 #include "base/location.h"
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after
42 sync_pb::EntitySpecifics* specifics) { 42 sync_pb::EntitySpecifics* specifics) {
43 if (type == syncer::PRIORITY_PREFERENCES) { 43 if (type == syncer::PRIORITY_PREFERENCES) {
44 DCHECK(!specifics->has_preference()); 44 DCHECK(!specifics->has_preference());
45 return specifics->mutable_priority_preference()->mutable_preference(); 45 return specifics->mutable_priority_preference()->mutable_preference();
46 } else { 46 } else {
47 DCHECK(!specifics->has_priority_preference()); 47 DCHECK(!specifics->has_priority_preference());
48 return specifics->mutable_preference(); 48 return specifics->mutable_preference();
49 } 49 }
50 } 50 }
51 51
52 // List of migrated preference name pairs. If a preference is migrated
53 // (meaning renamed) adding the old and new preference names here will ensure
54 // that the sync engine knows how to deal with the synced values coming in
55 // with the old name. Preference migration itself doesn't happen here. It may
56 // happen in session_startup_pref.cc.
57 const struct MigratedPreferences {
58 const char* const old_name;
59 const char* const new_name;
60 } kMigratedPreferences[] = {
61 { prefs::kURLsToRestoreOnStartupOld, prefs::kURLsToRestoreOnStartup },
62 };
63
64 std::string GetOldMigratedPreferenceName(const char* preference_name) {
65 for (size_t i = 0; i < arraysize(kMigratedPreferences); ++i) {
66 if (!strcmp(kMigratedPreferences[i].new_name, preference_name))
67 return kMigratedPreferences[i].old_name;
68 }
69 return std::string();
70 }
71
72 std::string GetNewMigratedPreferenceName(const char* old_preference_name) {
73 for (size_t i = 0; i < arraysize(kMigratedPreferences); ++i) {
74 if (!strcmp(kMigratedPreferences[i].old_name, old_preference_name))
75 return kMigratedPreferences[i].new_name;
76 }
77 return std::string();
78 }
79
80 } // namespace 52 } // namespace
81 53
82 PrefModelAssociator::PrefModelAssociator(syncer::ModelType type) 54 PrefModelAssociator::PrefModelAssociator(syncer::ModelType type)
83 : models_associated_(false), 55 : models_associated_(false),
84 processing_syncer_changes_(false), 56 processing_syncer_changes_(false),
85 pref_service_(NULL), 57 pref_service_(NULL),
86 type_(type) { 58 type_(type) {
87 DCHECK(CalledOnValidThread()); 59 DCHECK(CalledOnValidThread());
88 DCHECK(type_ == PREFERENCES || type_ == PRIORITY_PREFERENCES); 60 DCHECK(type_ == PREFERENCES || type_ == PRIORITY_PREFERENCES);
89 } 61 }
90 62
91 PrefModelAssociator::~PrefModelAssociator() { 63 PrefModelAssociator::~PrefModelAssociator() {
92 DCHECK(CalledOnValidThread()); 64 DCHECK(CalledOnValidThread());
93 pref_service_ = NULL; 65 pref_service_ = NULL;
94 66
95 STLDeleteContainerPairSecondPointers(synced_pref_observers_.begin(), 67 STLDeleteContainerPairSecondPointers(synced_pref_observers_.begin(),
96 synced_pref_observers_.end()); 68 synced_pref_observers_.end());
97 synced_pref_observers_.clear(); 69 synced_pref_observers_.clear();
98 } 70 }
99 71
100 void PrefModelAssociator::InitPrefAndAssociate( 72 void PrefModelAssociator::InitPrefAndAssociate(
101 const syncer::SyncData& sync_pref, 73 const syncer::SyncData& sync_pref,
102 const std::string& pref_name, 74 const std::string& pref_name,
103 syncer::SyncChangeList* sync_changes, 75 syncer::SyncChangeList* sync_changes) {
104 SyncDataMap* migrated_preference_list) {
105 const base::Value* user_pref_value = pref_service_->GetUserPrefValue( 76 const base::Value* user_pref_value = pref_service_->GetUserPrefValue(
106 pref_name.c_str()); 77 pref_name.c_str());
107 VLOG(1) << "Associating preference " << pref_name; 78 VLOG(1) << "Associating preference " << pref_name;
108 79
109 if (sync_pref.IsValid()) { 80 if (sync_pref.IsValid()) {
110 const sync_pb::PreferenceSpecifics& preference = GetSpecifics(sync_pref); 81 const sync_pb::PreferenceSpecifics& preference = GetSpecifics(sync_pref);
111 DCHECK(pref_name == preference.name() || 82 DCHECK(pref_name == preference.name());
112 (IsMigratedPreference(pref_name.c_str()) &&
113 preference.name() ==
114 GetOldMigratedPreferenceName(pref_name.c_str())));
115 base::JSONReader reader; 83 base::JSONReader reader;
116 scoped_ptr<base::Value> sync_value(reader.ReadToValue(preference.value())); 84 scoped_ptr<base::Value> sync_value(reader.ReadToValue(preference.value()));
117 if (!sync_value.get()) { 85 if (!sync_value.get()) {
118 LOG(ERROR) << "Failed to deserialize preference value: " 86 LOG(ERROR) << "Failed to deserialize preference value: "
119 << reader.GetErrorMessage(); 87 << reader.GetErrorMessage();
120 return; 88 return;
121 } 89 }
122 90
123 if (user_pref_value) { 91 if (user_pref_value) {
124 DVLOG(1) << "Found user pref value for " << pref_name; 92 DVLOG(1) << "Found user pref value for " << pref_name;
(...skipping 16 matching lines...) Expand all
141 pref_service_->Set(pref_name.c_str(), *new_value); 109 pref_service_->Set(pref_name.c_str(), *new_value);
142 } 110 }
143 111
144 // If the merge resulted in an updated value, inform the syncer. 112 // If the merge resulted in an updated value, inform the syncer.
145 if (!sync_value->Equals(new_value.get())) { 113 if (!sync_value->Equals(new_value.get())) {
146 syncer::SyncData sync_data; 114 syncer::SyncData sync_data;
147 if (!CreatePrefSyncData(pref_name, *new_value, &sync_data)) { 115 if (!CreatePrefSyncData(pref_name, *new_value, &sync_data)) {
148 LOG(ERROR) << "Failed to update preference."; 116 LOG(ERROR) << "Failed to update preference.";
149 return; 117 return;
150 } 118 }
151
152 if (IsMigratedPreference(pref_name.c_str())) {
153 // This preference has been migrated from an old version that must be
154 // kept in sync on older versions of Chrome.
155 std::string old_pref_name =
156 GetOldMigratedPreferenceName(pref_name.c_str());
157
158 if (preference.name() == old_pref_name) {
159 DCHECK(migrated_preference_list);
160 // If the name the syncer has is the old pre-migration value, then
161 // it's possible the new migrated preference name hasn't been synced
162 // yet. In that case the SyncChange should be an ACTION_ADD rather
163 // than an ACTION_UPDATE. Defer the decision of whether to sync with
164 // ACTION_ADD or ACTION_UPDATE until the migrated_preferences phase.
165 if (migrated_preference_list)
166 (*migrated_preference_list)[pref_name] = sync_data;
167 } else {
168 DCHECK_EQ(preference.name(), pref_name);
169 sync_changes->push_back(
170 syncer::SyncChange(FROM_HERE,
171 syncer::SyncChange::ACTION_UPDATE,
172 sync_data));
173 }
174
175 syncer::SyncData old_sync_data;
176 if (!CreatePrefSyncData(old_pref_name, *new_value, &old_sync_data)) {
177 LOG(ERROR) << "Failed to update preference.";
178 return;
179 }
180 if (migrated_preference_list)
181 (*migrated_preference_list)[old_pref_name] = old_sync_data;
182 } else {
183 sync_changes->push_back(
184 syncer::SyncChange(FROM_HERE,
185 syncer::SyncChange::ACTION_UPDATE,
186 sync_data));
187 }
188 } 119 }
189 } else if (!sync_value->IsType(base::Value::TYPE_NULL)) { 120 } else if (!sync_value->IsType(base::Value::TYPE_NULL)) {
190 // Only a server value exists. Just set the local user value. 121 // Only a server value exists. Just set the local user value.
191 pref_service_->Set(pref_name.c_str(), *sync_value); 122 pref_service_->Set(pref_name.c_str(), *sync_value);
192 } else { 123 } else {
193 LOG(WARNING) << "Sync has null value for pref " << pref_name.c_str(); 124 LOG(WARNING) << "Sync has null value for pref " << pref_name.c_str();
194 } 125 }
195 synced_preferences_.insert(preference.name()); 126 synced_preferences_.insert(preference.name());
196 } else if (user_pref_value) { 127 } else if (user_pref_value) {
197 // The server does not know about this preference and should be added 128 // The server does not know about this preference and should be added
(...skipping 27 matching lines...) Expand all
225 DCHECK(!sync_processor_.get()); 156 DCHECK(!sync_processor_.get());
226 DCHECK(sync_processor.get()); 157 DCHECK(sync_processor.get());
227 DCHECK(sync_error_factory.get()); 158 DCHECK(sync_error_factory.get());
228 syncer::SyncMergeResult merge_result(type); 159 syncer::SyncMergeResult merge_result(type);
229 sync_processor_ = sync_processor.Pass(); 160 sync_processor_ = sync_processor.Pass();
230 sync_error_factory_ = sync_error_factory.Pass(); 161 sync_error_factory_ = sync_error_factory.Pass();
231 162
232 syncer::SyncChangeList new_changes; 163 syncer::SyncChangeList new_changes;
233 std::set<std::string> remaining_preferences = registered_preferences_; 164 std::set<std::string> remaining_preferences = registered_preferences_;
234 165
235 // Maintains a list of old migrated preference names that we wish to sync.
236 // Keep track of these in a list such that when the preference iteration
237 // loops below are complete we can go back and determine whether
238 SyncDataMap migrated_preference_list;
239
240 // Go through and check for all preferences we care about that sync already 166 // Go through and check for all preferences we care about that sync already
241 // knows about. 167 // knows about.
242 for (syncer::SyncDataList::const_iterator sync_iter = 168 for (syncer::SyncDataList::const_iterator sync_iter =
243 initial_sync_data.begin(); 169 initial_sync_data.begin();
244 sync_iter != initial_sync_data.end(); 170 sync_iter != initial_sync_data.end();
245 ++sync_iter) { 171 ++sync_iter) {
246 DCHECK_EQ(type_, sync_iter->GetDataType()); 172 DCHECK_EQ(type_, sync_iter->GetDataType());
247 173
248 const sync_pb::PreferenceSpecifics& preference = GetSpecifics(*sync_iter); 174 const sync_pb::PreferenceSpecifics& preference = GetSpecifics(*sync_iter);
249 std::string sync_pref_name = preference.name(); 175 std::string sync_pref_name = preference.name();
250 176
251 if (remaining_preferences.count(sync_pref_name) == 0) { 177 if (remaining_preferences.count(sync_pref_name) == 0) {
252 if (IsOldMigratedPreference(sync_pref_name.c_str())) { 178 // We're not syncing this preference locally, ignore the sync data.
253 // This old pref name is not syncable locally anymore but we accept 179 // TODO(zea): Eventually we want to be able to have the syncable service
254 // changes from other Chrome installs of previous versions and migrate 180 // reconstruct all sync data for its datatype (therefore having
255 // them to the new name. Note that we will be merging any differences 181 // GetAllSyncData be a complete representation). We should store this
256 // between the new and old values and sync'ing them back. 182 // data somewhere, even if we don't use it.
257 sync_pref_name = GetNewMigratedPreferenceName(sync_pref_name.c_str()); 183 continue;
258 } else {
259 // We're not syncing this preference locally, ignore the sync data.
260 // TODO(zea): Eventually we want to be able to have the syncable service
261 // reconstruct all sync data for its datatype (therefore having
262 // GetAllSyncData be a complete representation). We should store this
263 // data somewhere, even if we don't use it.
264 continue;
265 }
266 } else { 184 } else {
Alexei Svitkine (slow) 2015/08/31 15:08:11 Nit: No need for } else { if you have a continue a
sdefresne 2015/09/02 11:23:37 Done.
267 remaining_preferences.erase(sync_pref_name); 185 remaining_preferences.erase(sync_pref_name);
268 } 186 }
269 InitPrefAndAssociate(*sync_iter, sync_pref_name, &new_changes, 187 InitPrefAndAssociate(*sync_iter, sync_pref_name, &new_changes);
270 &migrated_preference_list);
271 } 188 }
272 189
273 // Go through and build sync data for any remaining preferences. 190 // Go through and build sync data for any remaining preferences.
274 for (std::set<std::string>::iterator pref_name_iter = 191 for (std::set<std::string>::iterator pref_name_iter =
275 remaining_preferences.begin(); 192 remaining_preferences.begin();
276 pref_name_iter != remaining_preferences.end(); 193 pref_name_iter != remaining_preferences.end();
277 ++pref_name_iter) { 194 ++pref_name_iter) {
278 InitPrefAndAssociate(syncer::SyncData(), *pref_name_iter, &new_changes, 195 InitPrefAndAssociate(syncer::SyncData(), *pref_name_iter, &new_changes);
279 &migrated_preference_list);
280 }
281
282 // Now go over any migrated preference names and build sync data for them too.
283 for (SyncDataMap::const_iterator migrated_pref_iter =
284 migrated_preference_list.begin();
285 migrated_pref_iter != migrated_preference_list.end();
286 ++migrated_pref_iter) {
287 syncer::SyncChange::SyncChangeType change_type =
288 (synced_preferences_.count(migrated_pref_iter->first) == 0) ?
289 syncer::SyncChange::ACTION_ADD :
290 syncer::SyncChange::ACTION_UPDATE;
291 new_changes.push_back(
292 syncer::SyncChange(FROM_HERE, change_type, migrated_pref_iter->second));
293 synced_preferences_.insert(migrated_pref_iter->first);
294 } 196 }
295 197
296 // Push updates to sync. 198 // Push updates to sync.
297 merge_result.set_error( 199 merge_result.set_error(
298 sync_processor_->ProcessSyncChanges(FROM_HERE, new_changes)); 200 sync_processor_->ProcessSyncChanges(FROM_HERE, new_changes));
299 if (merge_result.error().IsSet()) 201 if (merge_result.error().IsSet())
300 return merge_result; 202 return merge_result;
301 203
302 models_associated_ = true; 204 models_associated_ = true;
303 pref_service_->OnIsSyncingChanged(); 205 pref_service_->OnIsSyncingChanged();
304 return merge_result; 206 return merge_result;
305 } 207 }
306 208
307 void PrefModelAssociator::StopSyncing(syncer::ModelType type) { 209 void PrefModelAssociator::StopSyncing(syncer::ModelType type) {
308 DCHECK_EQ(type_, type); 210 DCHECK_EQ(type_, type);
309 models_associated_ = false; 211 models_associated_ = false;
310 sync_processor_.reset(); 212 sync_processor_.reset();
311 sync_error_factory_.reset(); 213 sync_error_factory_.reset();
312 pref_service_->OnIsSyncingChanged(); 214 pref_service_->OnIsSyncingChanged();
313 } 215 }
314 216
315 scoped_ptr<base::Value> PrefModelAssociator::MergePreference( 217 scoped_ptr<base::Value> PrefModelAssociator::MergePreference(
316 const std::string& name, 218 const std::string& name,
317 const base::Value& local_value, 219 const base::Value& local_value,
318 const base::Value& server_value) { 220 const base::Value& server_value) {
319 // This function special cases preferences individually, so don't attempt 221 if (name == prefs::kURLsToRestoreOnStartup) {
320 // to merge for all migrated values.
321 if (name == prefs::kURLsToRestoreOnStartup ||
322 name == prefs::kURLsToRestoreOnStartupOld) {
323 return make_scoped_ptr(MergeListValues(local_value, server_value)); 222 return make_scoped_ptr(MergeListValues(local_value, server_value));
324 } 223 }
325 224
326 content_settings::WebsiteSettingsRegistry* registry = 225 content_settings::WebsiteSettingsRegistry* registry =
327 content_settings::WebsiteSettingsRegistry::GetInstance(); 226 content_settings::WebsiteSettingsRegistry::GetInstance();
328 for (int i = 0; i < CONTENT_SETTINGS_NUM_TYPES; ++i) { 227 for (int i = 0; i < CONTENT_SETTINGS_NUM_TYPES; ++i) {
329 ContentSettingsType type = static_cast<ContentSettingsType>(i); 228 ContentSettingsType type = static_cast<ContentSettingsType>(i);
330 if (registry->Get(type)->pref_name() == name) 229 if (registry->Get(type)->pref_name() == name)
331 return make_scoped_ptr(MergeDictionaryValues(local_value, server_value)); 230 return make_scoped_ptr(MergeDictionaryValues(local_value, server_value));
332 } 231 }
(...skipping 82 matching lines...) Expand 10 before | Expand all | Expand 10 after
415 } 314 }
416 // Note that for all other types we want to preserve the "to" 315 // Note that for all other types we want to preserve the "to"
417 // values so we do nothing here. 316 // values so we do nothing here.
418 } else { 317 } else {
419 result->SetWithoutPathExpansion(it.key(), from_key_value->DeepCopy()); 318 result->SetWithoutPathExpansion(it.key(), from_key_value->DeepCopy());
420 } 319 }
421 } 320 }
422 return result; 321 return result;
423 } 322 }
424 323
425 // static
426 bool PrefModelAssociator::IsMigratedPreference(const char* preference_name) {
427 return !GetOldMigratedPreferenceName(preference_name).empty();
428 }
429
430 // static
431 bool PrefModelAssociator::IsOldMigratedPreference(
432 const char* old_preference_name) {
433 return !GetNewMigratedPreferenceName(old_preference_name).empty();
434 }
435
436 // Note: This will build a model of all preferences registered as syncable 324 // Note: This will build a model of all preferences registered as syncable
437 // with user controlled data. We do not track any information for preferences 325 // with user controlled data. We do not track any information for preferences
438 // not registered locally as syncable and do not inform the syncer of 326 // not registered locally as syncable and do not inform the syncer of
439 // non-user controlled preferences. 327 // non-user controlled preferences.
440 syncer::SyncDataList PrefModelAssociator::GetAllSyncData( 328 syncer::SyncDataList PrefModelAssociator::GetAllSyncData(
441 syncer::ModelType type) 329 syncer::ModelType type)
442 const { 330 const {
443 DCHECK_EQ(type_, type); 331 DCHECK_EQ(type_, type);
444 syncer::SyncDataList current_data; 332 syncer::SyncDataList current_data;
445 for (PreferenceSet::const_iterator iter = synced_preferences_.begin(); 333 for (PreferenceSet::const_iterator iter = synced_preferences_.begin();
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after
477 365
478 const sync_pb::PreferenceSpecifics& pref_specifics = 366 const sync_pb::PreferenceSpecifics& pref_specifics =
479 GetSpecifics(iter->sync_data()); 367 GetSpecifics(iter->sync_data());
480 368
481 std::string name = pref_specifics.name(); 369 std::string name = pref_specifics.name();
482 // It is possible that we may receive a change to a preference we do not 370 // It is possible that we may receive a change to a preference we do not
483 // want to sync. For example if the user is syncing a Mac client and a 371 // want to sync. For example if the user is syncing a Mac client and a
484 // Windows client, the Windows client does not support 372 // Windows client, the Windows client does not support
485 // kConfirmToQuitEnabled. Ignore updates from these preferences. 373 // kConfirmToQuitEnabled. Ignore updates from these preferences.
486 const char* pref_name = name.c_str(); 374 const char* pref_name = name.c_str();
487 std::string new_name;
488 // We migrated this preference name, so do as if the name had not changed.
489 if (IsOldMigratedPreference(pref_name)) {
490 new_name = GetNewMigratedPreferenceName(pref_name);
491 pref_name = new_name.c_str();
492 }
493
494 if (!IsPrefRegistered(pref_name)) 375 if (!IsPrefRegistered(pref_name))
495 continue; 376 continue;
496 377
497 if (iter->change_type() == syncer::SyncChange::ACTION_DELETE) { 378 if (iter->change_type() == syncer::SyncChange::ACTION_DELETE) {
498 pref_service_->ClearPref(pref_name); 379 pref_service_->ClearPref(pref_name);
499 continue; 380 continue;
500 } 381 }
501 382
502 scoped_ptr<base::Value> value(ReadPreferenceSpecifics(pref_specifics)); 383 scoped_ptr<base::Value> value(ReadPreferenceSpecifics(pref_specifics));
503 if (!value.get()) { 384 if (!value.get()) {
(...skipping 95 matching lines...) Expand 10 before | Expand all | Expand 10 after
599 } 480 }
600 481
601 base::AutoReset<bool> processing_changes(&processing_syncer_changes_, true); 482 base::AutoReset<bool> processing_changes(&processing_syncer_changes_, true);
602 483
603 NotifySyncedPrefObservers(name, false /*from_sync*/); 484 NotifySyncedPrefObservers(name, false /*from_sync*/);
604 485
605 if (synced_preferences_.count(name) == 0) { 486 if (synced_preferences_.count(name) == 0) {
606 // Not in synced_preferences_ means no synced data. InitPrefAndAssociate(..) 487 // Not in synced_preferences_ means no synced data. InitPrefAndAssociate(..)
607 // will determine if we care about its data (e.g. if it has a default value 488 // will determine if we care about its data (e.g. if it has a default value
608 // and hasn't been changed yet we don't) and take care syncing any new data. 489 // and hasn't been changed yet we don't) and take care syncing any new data.
609 InitPrefAndAssociate(syncer::SyncData(), name, &changes, NULL); 490 InitPrefAndAssociate(syncer::SyncData(), name, &changes);
610 } else { 491 } else {
611 // We are already syncing this preference, just update it's sync node. 492 // We are already syncing this preference, just update it's sync node.
612 syncer::SyncData sync_data; 493 syncer::SyncData sync_data;
613 if (!CreatePrefSyncData(name, *preference->GetValue(), &sync_data)) { 494 if (!CreatePrefSyncData(name, *preference->GetValue(), &sync_data)) {
614 LOG(ERROR) << "Failed to update preference."; 495 LOG(ERROR) << "Failed to update preference.";
615 return; 496 return;
616 } 497 }
617 changes.push_back( 498 changes.push_back(
618 syncer::SyncChange(FROM_HERE, 499 syncer::SyncChange(FROM_HERE,
619 syncer::SyncChange::ACTION_UPDATE, 500 syncer::SyncChange::ACTION_UPDATE,
620 sync_data)); 501 sync_data));
621 // This preference has been migrated from an old version that must be kept
622 // in sync on older versions of Chrome.
623 if (IsMigratedPreference(name.c_str())) {
624 std::string old_pref_name = GetOldMigratedPreferenceName(name.c_str());
625 if (!CreatePrefSyncData(old_pref_name,
626 *preference->GetValue(),
627 &sync_data)) {
628 LOG(ERROR) << "Failed to update preference.";
629 return;
630 }
631
632 syncer::SyncChange::SyncChangeType change_type =
633 (synced_preferences_.count(old_pref_name) == 0) ?
634 syncer::SyncChange::ACTION_ADD :
635 syncer::SyncChange::ACTION_UPDATE;
636 changes.push_back(
637 syncer::SyncChange(FROM_HERE, change_type, sync_data));
638 }
639 } 502 }
640 503
641 syncer::SyncError error = 504 syncer::SyncError error =
642 sync_processor_->ProcessSyncChanges(FROM_HERE, changes); 505 sync_processor_->ProcessSyncChanges(FROM_HERE, changes);
643 } 506 }
644 507
645 void PrefModelAssociator::SetPrefService(PrefServiceSyncable* pref_service) { 508 void PrefModelAssociator::SetPrefService(PrefServiceSyncable* pref_service) {
646 DCHECK(pref_service_ == NULL); 509 DCHECK(pref_service_ == NULL);
647 pref_service_ = pref_service; 510 pref_service_ = pref_service;
648 } 511 }
649 512
650 void PrefModelAssociator::NotifySyncedPrefObservers(const std::string& path, 513 void PrefModelAssociator::NotifySyncedPrefObservers(const std::string& path,
651 bool from_sync) const { 514 bool from_sync) const {
652 SyncedPrefObserverMap::const_iterator observer_iter = 515 SyncedPrefObserverMap::const_iterator observer_iter =
653 synced_pref_observers_.find(path); 516 synced_pref_observers_.find(path);
654 if (observer_iter == synced_pref_observers_.end()) 517 if (observer_iter == synced_pref_observers_.end())
655 return; 518 return;
656 SyncedPrefObserverList* observers = observer_iter->second; 519 SyncedPrefObserverList* observers = observer_iter->second;
657 FOR_EACH_OBSERVER(SyncedPrefObserver, *observers, 520 FOR_EACH_OBSERVER(SyncedPrefObserver, *observers,
658 OnSyncedPrefChanged(path, from_sync)); 521 OnSyncedPrefChanged(path, from_sync));
659 } 522 }
OLDNEW
« no previous file with comments | « chrome/browser/prefs/pref_model_associator.h ('k') | chrome/browser/prefs/pref_service_syncable_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698