| OLD | NEW |
| 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/sync/sync_prefs.h" | 5 #include "chrome/browser/sync/sync_prefs.h" |
| 6 | 6 |
| 7 #include "base/logging.h" | 7 #include "base/logging.h" |
| 8 #include "base/string_number_conversions.h" | 8 #include "base/string_number_conversions.h" |
| 9 #include "base/values.h" | 9 #include "base/values.h" |
| 10 #include "build/build_config.h" | 10 #include "build/build_config.h" |
| (...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 45 | 45 |
| 46 void SyncPrefs::ClearPreferences() { | 46 void SyncPrefs::ClearPreferences() { |
| 47 DCHECK(non_thread_safe_.CalledOnValidThread()); | 47 DCHECK(non_thread_safe_.CalledOnValidThread()); |
| 48 CHECK(pref_service_); | 48 CHECK(pref_service_); |
| 49 pref_service_->ClearPref(prefs::kSyncLastSyncedTime); | 49 pref_service_->ClearPref(prefs::kSyncLastSyncedTime); |
| 50 pref_service_->ClearPref(prefs::kSyncHasSetupCompleted); | 50 pref_service_->ClearPref(prefs::kSyncHasSetupCompleted); |
| 51 pref_service_->ClearPref(prefs::kSyncEncryptionBootstrapToken); | 51 pref_service_->ClearPref(prefs::kSyncEncryptionBootstrapToken); |
| 52 | 52 |
| 53 // TODO(nick): The current behavior does not clear | 53 // TODO(nick): The current behavior does not clear |
| 54 // e.g. prefs::kSyncBookmarks. Is that really what we want? | 54 // e.g. prefs::kSyncBookmarks. Is that really what we want? |
| 55 | |
| 56 pref_service_->ClearPref(prefs::kSyncMaxInvalidationVersions); | |
| 57 } | 55 } |
| 58 | 56 |
| 59 bool SyncPrefs::HasSyncSetupCompleted() const { | 57 bool SyncPrefs::HasSyncSetupCompleted() const { |
| 60 DCHECK(non_thread_safe_.CalledOnValidThread()); | 58 DCHECK(non_thread_safe_.CalledOnValidThread()); |
| 61 return | 59 return |
| 62 pref_service_ && | 60 pref_service_ && |
| 63 pref_service_->GetBoolean(prefs::kSyncHasSetupCompleted); | 61 pref_service_->GetBoolean(prefs::kSyncHasSetupCompleted); |
| 64 } | 62 } |
| 65 | 63 |
| 66 void SyncPrefs::SetSyncSetupCompleted() { | 64 void SyncPrefs::SetSyncSetupCompleted() { |
| (...skipping 115 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 182 return pref_service_ ? | 180 return pref_service_ ? |
| 183 pref_service_->GetString(prefs::kSyncSpareBootstrapToken) : ""; | 181 pref_service_->GetString(prefs::kSyncSpareBootstrapToken) : ""; |
| 184 } | 182 } |
| 185 | 183 |
| 186 void SyncPrefs::SetSpareBootstrapToken(const std::string& token) { | 184 void SyncPrefs::SetSpareBootstrapToken(const std::string& token) { |
| 187 DCHECK(non_thread_safe_.CalledOnValidThread()); | 185 DCHECK(non_thread_safe_.CalledOnValidThread()); |
| 188 pref_service_->SetString(prefs::kSyncSpareBootstrapToken, token); | 186 pref_service_->SetString(prefs::kSyncSpareBootstrapToken, token); |
| 189 } | 187 } |
| 190 #endif | 188 #endif |
| 191 | 189 |
| 192 sync_notifier::InvalidationVersionMap SyncPrefs::GetAllMaxVersions() const { | |
| 193 DCHECK(non_thread_safe_.CalledOnValidThread()); | |
| 194 if (!pref_service_) { | |
| 195 return sync_notifier::InvalidationVersionMap(); | |
| 196 } | |
| 197 // Complicated gross code to convert from a string -> string | |
| 198 // DictionaryValue to a ModelType -> int64 map. | |
| 199 const base::DictionaryValue* max_versions_dict = | |
| 200 pref_service_->GetDictionary(prefs::kSyncMaxInvalidationVersions); | |
| 201 CHECK(max_versions_dict); | |
| 202 sync_notifier::InvalidationVersionMap max_versions; | |
| 203 for (base::DictionaryValue::key_iterator it = | |
| 204 max_versions_dict->begin_keys(); | |
| 205 it != max_versions_dict->end_keys(); ++it) { | |
| 206 int model_type_int = 0; | |
| 207 if (!base::StringToInt(*it, &model_type_int)) { | |
| 208 LOG(WARNING) << "Invalid model type key: " << *it; | |
| 209 continue; | |
| 210 } | |
| 211 if ((model_type_int < syncable::FIRST_REAL_MODEL_TYPE) || | |
| 212 (model_type_int >= syncable::MODEL_TYPE_COUNT)) { | |
| 213 LOG(WARNING) << "Out-of-range model type key: " << model_type_int; | |
| 214 continue; | |
| 215 } | |
| 216 const syncable::ModelType model_type = | |
| 217 syncable::ModelTypeFromInt(model_type_int); | |
| 218 std::string max_version_str; | |
| 219 CHECK(max_versions_dict->GetString(*it, &max_version_str)); | |
| 220 int64 max_version = 0; | |
| 221 if (!base::StringToInt64(max_version_str, &max_version)) { | |
| 222 LOG(WARNING) << "Invalid max invalidation version for " | |
| 223 << syncable::ModelTypeToString(model_type) << ": " | |
| 224 << max_version_str; | |
| 225 continue; | |
| 226 } | |
| 227 max_versions[model_type] = max_version; | |
| 228 } | |
| 229 return max_versions; | |
| 230 } | |
| 231 | |
| 232 void SyncPrefs::SetMaxVersion(syncable::ModelType model_type, | |
| 233 int64 max_version) { | |
| 234 DCHECK(non_thread_safe_.CalledOnValidThread()); | |
| 235 DCHECK(syncable::IsRealDataType(model_type)); | |
| 236 CHECK(pref_service_); | |
| 237 sync_notifier::InvalidationVersionMap max_versions = | |
| 238 GetAllMaxVersions(); | |
| 239 sync_notifier::InvalidationVersionMap::iterator it = | |
| 240 max_versions.find(model_type); | |
| 241 if ((it != max_versions.end()) && (max_version <= it->second)) { | |
| 242 NOTREACHED(); | |
| 243 return; | |
| 244 } | |
| 245 max_versions[model_type] = max_version; | |
| 246 | |
| 247 // Gross code to convert from a ModelType -> int64 map to a string | |
| 248 // -> string DictionaryValue. | |
| 249 base::DictionaryValue max_versions_dict; | |
| 250 for (sync_notifier::InvalidationVersionMap::const_iterator it = | |
| 251 max_versions.begin(); | |
| 252 it != max_versions.end(); ++it) { | |
| 253 max_versions_dict.SetString( | |
| 254 base::IntToString(it->first), | |
| 255 base::Int64ToString(it->second)); | |
| 256 } | |
| 257 pref_service_->Set(prefs::kSyncMaxInvalidationVersions, max_versions_dict); | |
| 258 } | |
| 259 | 190 |
| 260 void SyncPrefs::AcknowledgeSyncedTypes( | 191 void SyncPrefs::AcknowledgeSyncedTypes( |
| 261 syncable::ModelTypeSet types) { | 192 syncable::ModelTypeSet types) { |
| 262 DCHECK(non_thread_safe_.CalledOnValidThread()); | 193 DCHECK(non_thread_safe_.CalledOnValidThread()); |
| 263 CHECK(pref_service_); | 194 CHECK(pref_service_); |
| 264 // Add the types to the current set of acknowledged | 195 // Add the types to the current set of acknowledged |
| 265 // types, and then store the resulting set in prefs. | 196 // types, and then store the resulting set in prefs. |
| 266 const syncable::ModelTypeSet acknowledged_types = | 197 const syncable::ModelTypeSet acknowledged_types = |
| 267 Union(types, | 198 Union(types, |
| 268 syncable::ModelTypeSetFromValue( | 199 syncable::ModelTypeSetFromValue( |
| (...skipping 159 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 428 model_set.Put(syncable::THEMES); | 359 model_set.Put(syncable::THEMES); |
| 429 model_set.Put(syncable::EXTENSIONS); | 360 model_set.Put(syncable::EXTENSIONS); |
| 430 model_set.Put(syncable::NIGORI); | 361 model_set.Put(syncable::NIGORI); |
| 431 model_set.Put(syncable::SEARCH_ENGINES); | 362 model_set.Put(syncable::SEARCH_ENGINES); |
| 432 model_set.Put(syncable::APPS); | 363 model_set.Put(syncable::APPS); |
| 433 model_set.Put(syncable::TYPED_URLS); | 364 model_set.Put(syncable::TYPED_URLS); |
| 434 model_set.Put(syncable::SESSIONS); | 365 model_set.Put(syncable::SESSIONS); |
| 435 pref_service_->RegisterListPref(prefs::kSyncAcknowledgedSyncTypes, | 366 pref_service_->RegisterListPref(prefs::kSyncAcknowledgedSyncTypes, |
| 436 syncable::ModelTypeSetToValue(model_set), | 367 syncable::ModelTypeSetToValue(model_set), |
| 437 PrefService::UNSYNCABLE_PREF); | 368 PrefService::UNSYNCABLE_PREF); |
| 438 | |
| 439 pref_service_->RegisterDictionaryPref(prefs::kSyncMaxInvalidationVersions, | |
| 440 PrefService::UNSYNCABLE_PREF); | |
| 441 } | 369 } |
| 442 | 370 |
| 443 void SyncPrefs::RegisterDataTypePreferredPref(syncable::ModelType type, | 371 void SyncPrefs::RegisterDataTypePreferredPref(syncable::ModelType type, |
| 444 bool is_preferred) { | 372 bool is_preferred) { |
| 445 DCHECK(non_thread_safe_.CalledOnValidThread()); | 373 DCHECK(non_thread_safe_.CalledOnValidThread()); |
| 446 CHECK(pref_service_); | 374 CHECK(pref_service_); |
| 447 const char* pref_name = GetPrefNameForDataType(type); | 375 const char* pref_name = GetPrefNameForDataType(type); |
| 448 if (!pref_name) { | 376 if (!pref_name) { |
| 449 NOTREACHED(); | 377 NOTREACHED(); |
| 450 return; | 378 return; |
| (...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 489 if (types.Has(i->first)) | 417 if (types.Has(i->first)) |
| 490 types_with_groups.PutAll(i->second); | 418 types_with_groups.PutAll(i->second); |
| 491 else | 419 else |
| 492 types_with_groups.RemoveAll(i->second); | 420 types_with_groups.RemoveAll(i->second); |
| 493 } | 421 } |
| 494 types_with_groups.RetainAll(registered_types); | 422 types_with_groups.RetainAll(registered_types); |
| 495 return types_with_groups; | 423 return types_with_groups; |
| 496 } | 424 } |
| 497 | 425 |
| 498 } // namespace browser_sync | 426 } // namespace browser_sync |
| OLD | NEW |