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 | |
39 if (!outer_->on_initialization_.is_null()) | 38 if (!outer_->on_initialization_.is_null()) |
40 outer_->on_initialization_.Run(); | 39 outer_->on_initialization_.Run(); |
41 | 40 |
42 if (successful_sub_initializations_ == 2 && outer_->read_error_delegate_) { | 41 if (successful_sub_initializations_ == 2 && outer_->read_error_delegate_) { |
43 PersistentPrefStore::PrefReadError read_error = outer_->GetReadError(); | 42 PersistentPrefStore::PrefReadError read_error = outer_->GetReadError(); |
44 if (read_error != PersistentPrefStore::PREF_READ_ERROR_NONE) | 43 if (read_error != PersistentPrefStore::PREF_READ_ERROR_NONE) |
45 outer_->read_error_delegate_->OnError(read_error); | 44 outer_->read_error_delegate_->OnError(read_error); |
46 } | 45 } |
47 | 46 |
48 FOR_EACH_OBSERVER( | 47 FOR_EACH_OBSERVER( |
(...skipping 95 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
144 void SegregatedPrefStore::CommitPendingWrite() { | 143 void SegregatedPrefStore::CommitPendingWrite() { |
145 default_pref_store_->CommitPendingWrite(); | 144 default_pref_store_->CommitPendingWrite(); |
146 selected_pref_store_->CommitPendingWrite(); | 145 selected_pref_store_->CommitPendingWrite(); |
147 } | 146 } |
148 | 147 |
149 SegregatedPrefStore::~SegregatedPrefStore() { | 148 SegregatedPrefStore::~SegregatedPrefStore() { |
150 default_pref_store_->RemoveObserver(&aggregating_observer_); | 149 default_pref_store_->RemoveObserver(&aggregating_observer_); |
151 selected_pref_store_->RemoveObserver(&aggregating_observer_); | 150 selected_pref_store_->RemoveObserver(&aggregating_observer_); |
152 } | 151 } |
153 | 152 |
154 const PersistentPrefStore* | 153 const PersistentPrefStore* SegregatedPrefStore::StoreForKey( |
155 SegregatedPrefStore::StoreForKey(const std::string& key) const { | 154 const std::string& key) const { |
156 if (ContainsKey(selected_preference_names_, key) || | 155 if (ContainsKey(selected_preference_names_, key) || |
157 selected_pref_store_->GetValue(key, NULL)) { | 156 selected_pref_store_->GetValue(key, NULL)) { |
158 return selected_pref_store_.get(); | 157 return selected_pref_store_.get(); |
159 } | 158 } |
160 return default_pref_store_.get(); | 159 return default_pref_store_.get(); |
161 } | 160 } |
162 | 161 |
163 PersistentPrefStore* SegregatedPrefStore::StoreForKey(const std::string& key) { | 162 PersistentPrefStore* SegregatedPrefStore::StoreForKey(const std::string& key) { |
164 if (ContainsKey(selected_preference_names_, key)) | 163 if (ContainsKey(selected_preference_names_, key)) |
165 return selected_pref_store_.get(); | 164 return selected_pref_store_.get(); |
166 | 165 |
167 // Check if this unselected value was previously selected. If so, migrate it | 166 // Check if this unselected value was previously selected. If so, migrate it |
168 // back to the unselected store. | 167 // back to the unselected store. |
169 // It's hard to do this in a single pass at startup because PrefStore does not | 168 // It's hard to do this in a single pass at startup because PrefStore does not |
170 // permit us to enumerate its contents. | 169 // permit us to enumerate its contents. |
171 const base::Value* value = NULL; | 170 const base::Value* value = NULL; |
172 if (selected_pref_store_->GetValue(key, &value)) { | 171 if (selected_pref_store_->GetValue(key, &value)) { |
173 scoped_ptr<base::Value> migrated_value(value->DeepCopy()); | 172 default_pref_store_->SetValue(key, value->DeepCopy()); |
173 default_pref_store_->CommitPendingWrite(); | |
gab
2014/04/02 17:02:15
Add a comment as to why this commit is required, i
erikwright (departed)
2014/04/03 13:25:47
Done.
| |
174 | |
174 value = NULL; | 175 value = NULL; |
gab
2014/04/02 17:02:15
Why even do this? It doesn't seem to matter that |
erikwright (departed)
2014/04/03 13:25:47
AfterRemoveValue, |value| is invalid.
If this 'if
gab
2014/04/03 15:47:13
Oh right, good point.
| |
175 default_pref_store_->SetValue(key, migrated_value.release()); | |
176 default_pref_store_->CommitPendingWrite(); | |
177 selected_pref_store_->RemoveValue(key); | 176 selected_pref_store_->RemoveValue(key); |
178 selected_pref_store_->CommitPendingWrite(); | |
179 } | 177 } |
180 | 178 |
181 return default_pref_store_.get(); | 179 return default_pref_store_.get(); |
182 } | 180 } |
OLD | NEW |