Index: base/prefs/json_pref_store.cc |
diff --git a/base/prefs/json_pref_store.cc b/base/prefs/json_pref_store.cc |
index 9180984d0e8b9008b288ff846f3eafdd72c24f63..88dc73df3f99afbe6451daca1c7ce10abe29826a 100644 |
--- a/base/prefs/json_pref_store.cc |
+++ b/base/prefs/json_pref_store.cc |
@@ -12,9 +12,9 @@ |
#include "base/json/json_file_value_serializer.h" |
#include "base/json/json_string_value_serializer.h" |
#include "base/memory/ref_counted.h" |
-#include "base/message_loop/message_loop_proxy.h" |
#include "base/prefs/pref_filter.h" |
#include "base/sequenced_task_runner.h" |
+#include "base/thread_task_runner_handle.h" |
#include "base/threading/sequenced_worker_pool.h" |
#include "base/values.h" |
@@ -28,18 +28,18 @@ const base::FilePath::CharType* kBadExtension = FILE_PATH_LITERAL("bad"); |
class FileThreadDeserializer |
: public base::RefCountedThreadSafe<FileThreadDeserializer> { |
public: |
- FileThreadDeserializer(JsonPrefStore* delegate, |
- base::SequencedTaskRunner* sequenced_task_runner) |
+ FileThreadDeserializer( |
+ JsonPrefStore* delegate, |
+ const scoped_refptr<base::SequencedTaskRunner>& sequenced_task_runner) |
: no_dir_(false), |
error_(PersistentPrefStore::PREF_READ_ERROR_NONE), |
delegate_(delegate), |
sequenced_task_runner_(sequenced_task_runner), |
- origin_loop_proxy_(base::MessageLoopProxy::current()) { |
- } |
+ origin_task_runner_(base::ThreadTaskRunnerHandle::Get()) {} |
void Start(const base::FilePath& path, |
const base::FilePath& alternate_path) { |
- DCHECK(origin_loop_proxy_->BelongsToCurrentThread()); |
+ DCHECK(origin_task_runner_->RunsTasksOnCurrentThread()); |
// TODO(gab): This should use PostTaskAndReplyWithResult instead of using |
// the |error_| member to pass data across tasks. |
sequenced_task_runner_->PostTask( |
@@ -55,14 +55,14 @@ class FileThreadDeserializer |
value_.reset(DoReading(path, alternate_path, &error_, &no_dir_)); |
- origin_loop_proxy_->PostTask( |
+ origin_task_runner_->PostTask( |
FROM_HERE, |
base::Bind(&FileThreadDeserializer::ReportOnOriginThread, this)); |
} |
// Reports deserialization result on the origin thread. |
void ReportOnOriginThread() { |
- DCHECK(origin_loop_proxy_->BelongsToCurrentThread()); |
+ DCHECK(origin_task_runner_->RunsTasksOnCurrentThread()); |
delegate_->OnFileRead(value_.Pass(), error_, no_dir_); |
} |
@@ -99,7 +99,7 @@ class FileThreadDeserializer |
scoped_ptr<base::Value> value_; |
const scoped_refptr<JsonPrefStore> delegate_; |
const scoped_refptr<base::SequencedTaskRunner> sequenced_task_runner_; |
- const scoped_refptr<base::MessageLoopProxy> origin_loop_proxy_; |
+ const scoped_refptr<base::SequencedTaskRunner> origin_task_runner_; |
}; |
// static |
@@ -161,9 +161,10 @@ scoped_refptr<base::SequencedTaskRunner> JsonPrefStore::GetTaskRunnerForFile( |
base::SequencedWorkerPool::BLOCK_SHUTDOWN); |
} |
-JsonPrefStore::JsonPrefStore(const base::FilePath& filename, |
- base::SequencedTaskRunner* sequenced_task_runner, |
- scoped_ptr<PrefFilter> pref_filter) |
+JsonPrefStore::JsonPrefStore( |
+ const base::FilePath& filename, |
+ const scoped_refptr<base::SequencedTaskRunner>& sequenced_task_runner, |
+ scoped_ptr<PrefFilter> pref_filter) |
: path_(filename), |
sequenced_task_runner_(sequenced_task_runner), |
prefs_(new base::DictionaryValue()), |
@@ -175,10 +176,11 @@ JsonPrefStore::JsonPrefStore(const base::FilePath& filename, |
read_error_(PREF_READ_ERROR_NONE) { |
} |
-JsonPrefStore::JsonPrefStore(const base::FilePath& filename, |
- const base::FilePath& alternate_filename, |
- base::SequencedTaskRunner* sequenced_task_runner, |
- scoped_ptr<PrefFilter> pref_filter) |
+JsonPrefStore::JsonPrefStore( |
+ const base::FilePath& filename, |
+ const base::FilePath& alternate_filename, |
+ const scoped_refptr<base::SequencedTaskRunner>& sequenced_task_runner, |
+ scoped_ptr<PrefFilter> pref_filter) |
: path_(filename), |
alternate_path_(alternate_filename), |
sequenced_task_runner_(sequenced_task_runner), |