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

Side by Side Diff: chrome/browser/sync/sync_prefs.cc

Issue 10451058: sync: move invalidation version prefs out of SyncPrefs into InvalidatorStorage. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: init Created 8 years, 6 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
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/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
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
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
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
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
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698