| Index: components/prefs/json_pref_store.cc
|
| diff --git a/components/prefs/json_pref_store.cc b/components/prefs/json_pref_store.cc
|
| index 240f1daf56381c4684927d0365113f8a35aeb30c..c44dfa9e9e4aa4bc2344620987e784bdca432cda 100644
|
| --- a/components/prefs/json_pref_store.cc
|
| +++ b/components/prefs/json_pref_store.cc
|
| @@ -162,7 +162,7 @@ JsonPrefStore::JsonPrefStore(
|
|
|
| bool JsonPrefStore::GetValue(const std::string& key,
|
| const base::Value** result) const {
|
| - DCHECK(CalledOnValidThread());
|
| + DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
|
|
|
| base::Value* tmp = nullptr;
|
| if (!prefs_->Get(key, &tmp))
|
| @@ -178,32 +178,32 @@ std::unique_ptr<base::DictionaryValue> JsonPrefStore::GetValues() const {
|
| }
|
|
|
| void JsonPrefStore::AddObserver(PrefStore::Observer* observer) {
|
| - DCHECK(CalledOnValidThread());
|
| + DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
|
|
|
| observers_.AddObserver(observer);
|
| }
|
|
|
| void JsonPrefStore::RemoveObserver(PrefStore::Observer* observer) {
|
| - DCHECK(CalledOnValidThread());
|
| + DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
|
|
|
| observers_.RemoveObserver(observer);
|
| }
|
|
|
| bool JsonPrefStore::HasObservers() const {
|
| - DCHECK(CalledOnValidThread());
|
| + DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
|
|
|
| return observers_.might_have_observers();
|
| }
|
|
|
| bool JsonPrefStore::IsInitializationComplete() const {
|
| - DCHECK(CalledOnValidThread());
|
| + DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
|
|
|
| return initialized_;
|
| }
|
|
|
| bool JsonPrefStore::GetMutableValue(const std::string& key,
|
| base::Value** result) {
|
| - DCHECK(CalledOnValidThread());
|
| + DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
|
|
|
| return prefs_->Get(key, result);
|
| }
|
| @@ -211,7 +211,7 @@ bool JsonPrefStore::GetMutableValue(const std::string& key,
|
| void JsonPrefStore::SetValue(const std::string& key,
|
| std::unique_ptr<base::Value> value,
|
| uint32_t flags) {
|
| - DCHECK(CalledOnValidThread());
|
| + DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
|
|
|
| DCHECK(value);
|
| base::Value* old_value = nullptr;
|
| @@ -225,7 +225,7 @@ void JsonPrefStore::SetValue(const std::string& key,
|
| void JsonPrefStore::SetValueSilently(const std::string& key,
|
| std::unique_ptr<base::Value> value,
|
| uint32_t flags) {
|
| - DCHECK(CalledOnValidThread());
|
| + DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
|
|
|
| DCHECK(value);
|
| base::Value* old_value = nullptr;
|
| @@ -237,7 +237,7 @@ void JsonPrefStore::SetValueSilently(const std::string& key,
|
| }
|
|
|
| void JsonPrefStore::RemoveValue(const std::string& key, uint32_t flags) {
|
| - DCHECK(CalledOnValidThread());
|
| + DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
|
|
|
| if (prefs_->RemovePath(key, nullptr))
|
| ReportValueChanged(key, flags);
|
| @@ -245,26 +245,26 @@ void JsonPrefStore::RemoveValue(const std::string& key, uint32_t flags) {
|
|
|
| void JsonPrefStore::RemoveValueSilently(const std::string& key,
|
| uint32_t flags) {
|
| - DCHECK(CalledOnValidThread());
|
| + DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
|
|
|
| prefs_->RemovePath(key, nullptr);
|
| ScheduleWrite(flags);
|
| }
|
|
|
| bool JsonPrefStore::ReadOnly() const {
|
| - DCHECK(CalledOnValidThread());
|
| + DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
|
|
|
| return read_only_;
|
| }
|
|
|
| PersistentPrefStore::PrefReadError JsonPrefStore::GetReadError() const {
|
| - DCHECK(CalledOnValidThread());
|
| + DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
|
|
|
| return read_error_;
|
| }
|
|
|
| PersistentPrefStore::PrefReadError JsonPrefStore::ReadPrefs() {
|
| - DCHECK(CalledOnValidThread());
|
| + DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
|
|
|
| OnFileRead(ReadPrefsFromDisk(path_));
|
| return filtering_in_progress_ ? PREF_READ_ERROR_ASYNCHRONOUS_TASK_INCOMPLETE
|
| @@ -272,7 +272,7 @@ PersistentPrefStore::PrefReadError JsonPrefStore::ReadPrefs() {
|
| }
|
|
|
| void JsonPrefStore::ReadPrefsAsync(ReadErrorDelegate* error_delegate) {
|
| - DCHECK(CalledOnValidThread());
|
| + DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
|
|
|
| initialized_ = false;
|
| error_delegate_.reset(error_delegate);
|
| @@ -285,7 +285,7 @@ void JsonPrefStore::ReadPrefsAsync(ReadErrorDelegate* error_delegate) {
|
| }
|
|
|
| void JsonPrefStore::CommitPendingWrite() {
|
| - DCHECK(CalledOnValidThread());
|
| + DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
|
|
|
| // Schedule a write for any lossy writes that are outstanding to ensure that
|
| // they get flushed when this function is called.
|
| @@ -301,7 +301,7 @@ void JsonPrefStore::SchedulePendingLossyWrites() {
|
| }
|
|
|
| void JsonPrefStore::ReportValueChanged(const std::string& key, uint32_t flags) {
|
| - DCHECK(CalledOnValidThread());
|
| + DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
|
|
|
| if (pref_filter_)
|
| pref_filter_->FilterUpdate(key);
|
| @@ -314,7 +314,7 @@ void JsonPrefStore::ReportValueChanged(const std::string& key, uint32_t flags) {
|
|
|
| void JsonPrefStore::RunOrScheduleNextSuccessfulWriteCallback(
|
| bool write_success) {
|
| - DCHECK(CalledOnValidThread());
|
| + DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
|
|
|
| has_pending_write_reply_ = false;
|
| if (!on_next_successful_write_reply_.is_null()) {
|
| @@ -345,7 +345,7 @@ void JsonPrefStore::PostWriteCallback(
|
|
|
| void JsonPrefStore::RegisterOnNextSuccessfulWriteReply(
|
| const base::Closure& on_next_successful_write_reply) {
|
| - DCHECK(CalledOnValidThread());
|
| + DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
|
| DCHECK(on_next_successful_write_reply_.is_null());
|
|
|
| on_next_successful_write_reply_ = on_next_successful_write_reply;
|
| @@ -367,7 +367,7 @@ void JsonPrefStore::RegisterOnNextSuccessfulWriteReply(
|
|
|
| void JsonPrefStore::RegisterOnNextWriteSynchronousCallbacks(
|
| OnWriteCallbackPair callbacks) {
|
| - DCHECK(CalledOnValidThread());
|
| + DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
|
|
|
| has_pending_write_reply_ = true;
|
|
|
| @@ -385,7 +385,7 @@ void JsonPrefStore::ClearMutableValues() {
|
| }
|
|
|
| void JsonPrefStore::OnFileRead(std::unique_ptr<ReadResult> read_result) {
|
| - DCHECK(CalledOnValidThread());
|
| + DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
|
|
|
| DCHECK(read_result);
|
|
|
| @@ -441,11 +441,12 @@ void JsonPrefStore::OnFileRead(std::unique_ptr<ReadResult> read_result) {
|
| }
|
|
|
| JsonPrefStore::~JsonPrefStore() {
|
| + DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
|
| CommitPendingWrite();
|
| }
|
|
|
| bool JsonPrefStore::SerializeData(std::string* output) {
|
| - DCHECK(CalledOnValidThread());
|
| + DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
|
|
|
| pending_lossy_write_ = false;
|
|
|
| @@ -472,7 +473,7 @@ void JsonPrefStore::FinalizeFileRead(
|
| bool initialization_successful,
|
| std::unique_ptr<base::DictionaryValue> prefs,
|
| bool schedule_write) {
|
| - DCHECK(CalledOnValidThread());
|
| + DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
|
|
|
| filtering_in_progress_ = false;
|
|
|
|
|