| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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/tracked/segregated_pref_store.h" | 5 #include "chrome/browser/prefs/tracked/segregated_pref_store.h" |
| 6 | 6 |
| 7 #include "base/logging.h" | 7 #include "base/logging.h" |
| 8 #include "base/stl_util.h" | 8 #include "base/stl_util.h" |
| 9 #include "base/values.h" | 9 #include "base/values.h" |
| 10 | 10 |
| (...skipping 17 matching lines...) Expand all Loading... |
| 28 void SegregatedPrefStore::AggregatingObserver::OnInitializationCompleted( | 28 void SegregatedPrefStore::AggregatingObserver::OnInitializationCompleted( |
| 29 bool succeeded) { | 29 bool succeeded) { |
| 30 if (succeeded) | 30 if (succeeded) |
| 31 ++successful_sub_initializations_; | 31 ++successful_sub_initializations_; |
| 32 else | 32 else |
| 33 ++failed_sub_initializations_; | 33 ++failed_sub_initializations_; |
| 34 | 34 |
| 35 DCHECK_LE(failed_sub_initializations_ + successful_sub_initializations_, 2); | 35 DCHECK_LE(failed_sub_initializations_ + successful_sub_initializations_, 2); |
| 36 | 36 |
| 37 if (failed_sub_initializations_ + successful_sub_initializations_ == 2) { | 37 if (failed_sub_initializations_ + successful_sub_initializations_ == 2) { |
| 38 if (!outer_->on_initialization_.is_null()) | |
| 39 outer_->on_initialization_.Run(); | |
| 40 | |
| 41 if (successful_sub_initializations_ == 2 && outer_->read_error_delegate_) { | 38 if (successful_sub_initializations_ == 2 && outer_->read_error_delegate_) { |
| 42 PersistentPrefStore::PrefReadError read_error = outer_->GetReadError(); | 39 PersistentPrefStore::PrefReadError read_error = outer_->GetReadError(); |
| 43 if (read_error != PersistentPrefStore::PREF_READ_ERROR_NONE) | 40 if (read_error != PersistentPrefStore::PREF_READ_ERROR_NONE) |
| 44 outer_->read_error_delegate_->OnError(read_error); | 41 outer_->read_error_delegate_->OnError(read_error); |
| 45 } | 42 } |
| 46 | 43 |
| 47 FOR_EACH_OBSERVER( | 44 FOR_EACH_OBSERVER( |
| 48 PrefStore::Observer, | 45 PrefStore::Observer, |
| 49 outer_->observers_, | 46 outer_->observers_, |
| 50 OnInitializationCompleted(successful_sub_initializations_ == 2)); | 47 OnInitializationCompleted(successful_sub_initializations_ == 2)); |
| 51 } | 48 } |
| 52 } | 49 } |
| 53 | 50 |
| 54 SegregatedPrefStore::SegregatedPrefStore( | 51 SegregatedPrefStore::SegregatedPrefStore( |
| 55 const scoped_refptr<PersistentPrefStore>& default_pref_store, | 52 const scoped_refptr<PersistentPrefStore>& default_pref_store, |
| 56 const scoped_refptr<PersistentPrefStore>& selected_pref_store, | 53 const scoped_refptr<PersistentPrefStore>& selected_pref_store, |
| 57 const std::set<std::string>& selected_pref_names, | 54 const std::set<std::string>& selected_pref_names) |
| 58 const base::Closure& on_initialization) | |
| 59 : default_pref_store_(default_pref_store), | 55 : default_pref_store_(default_pref_store), |
| 60 selected_pref_store_(selected_pref_store), | 56 selected_pref_store_(selected_pref_store), |
| 61 selected_preference_names_(selected_pref_names), | 57 selected_preference_names_(selected_pref_names), |
| 62 on_initialization_(on_initialization), | |
| 63 aggregating_observer_(this) { | 58 aggregating_observer_(this) { |
| 64 | 59 |
| 65 default_pref_store_->AddObserver(&aggregating_observer_); | 60 default_pref_store_->AddObserver(&aggregating_observer_); |
| 66 selected_pref_store_->AddObserver(&aggregating_observer_); | 61 selected_pref_store_->AddObserver(&aggregating_observer_); |
| 67 } | 62 } |
| 68 | 63 |
| 69 void SegregatedPrefStore::AddObserver(Observer* observer) { | 64 void SegregatedPrefStore::AddObserver(Observer* observer) { |
| 70 observers_.AddObserver(observer); | 65 observers_.AddObserver(observer); |
| 71 } | 66 } |
| 72 | 67 |
| (...skipping 70 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 143 void SegregatedPrefStore::CommitPendingWrite() { | 138 void SegregatedPrefStore::CommitPendingWrite() { |
| 144 default_pref_store_->CommitPendingWrite(); | 139 default_pref_store_->CommitPendingWrite(); |
| 145 selected_pref_store_->CommitPendingWrite(); | 140 selected_pref_store_->CommitPendingWrite(); |
| 146 } | 141 } |
| 147 | 142 |
| 148 SegregatedPrefStore::~SegregatedPrefStore() { | 143 SegregatedPrefStore::~SegregatedPrefStore() { |
| 149 default_pref_store_->RemoveObserver(&aggregating_observer_); | 144 default_pref_store_->RemoveObserver(&aggregating_observer_); |
| 150 selected_pref_store_->RemoveObserver(&aggregating_observer_); | 145 selected_pref_store_->RemoveObserver(&aggregating_observer_); |
| 151 } | 146 } |
| 152 | 147 |
| 148 PersistentPrefStore* SegregatedPrefStore::StoreForKey( |
| 149 const std::string& key) { |
| 150 return ContainsKey(selected_preference_names_, key) ? |
| 151 selected_pref_store_ : default_pref_store_; |
| 152 } |
| 153 |
| 153 const PersistentPrefStore* SegregatedPrefStore::StoreForKey( | 154 const PersistentPrefStore* SegregatedPrefStore::StoreForKey( |
| 154 const std::string& key) const { | 155 const std::string& key) const { |
| 155 if (ContainsKey(selected_preference_names_, key) || | 156 return ContainsKey(selected_preference_names_, key) ? |
| 156 selected_pref_store_->GetValue(key, NULL)) { | 157 selected_pref_store_ : default_pref_store_; |
| 157 return selected_pref_store_.get(); | |
| 158 } | |
| 159 return default_pref_store_.get(); | |
| 160 } | 158 } |
| 161 | |
| 162 PersistentPrefStore* SegregatedPrefStore::StoreForKey(const std::string& key) { | |
| 163 if (ContainsKey(selected_preference_names_, key)) | |
| 164 return selected_pref_store_.get(); | |
| 165 | |
| 166 // Check if this unselected value was previously selected. If so, migrate it | |
| 167 // back to the unselected store. | |
| 168 // It's hard to do this in a single pass at startup because PrefStore does not | |
| 169 // permit us to enumerate its contents. | |
| 170 const base::Value* value = NULL; | |
| 171 if (selected_pref_store_->GetValue(key, &value)) { | |
| 172 default_pref_store_->SetValue(key, value->DeepCopy()); | |
| 173 // Commit |default_pref_store_| to guarantee that the migrated value is | |
| 174 // flushed to disk before the removal from |selected_pref_store_| is | |
| 175 // eventually flushed to disk. | |
| 176 default_pref_store_->CommitPendingWrite(); | |
| 177 | |
| 178 value = NULL; | |
| 179 selected_pref_store_->RemoveValue(key); | |
| 180 } | |
| 181 | |
| 182 return default_pref_store_.get(); | |
| 183 } | |
| OLD | NEW |