| Index: base/prefs/json_pref_store_unittest.cc
|
| diff --git a/base/prefs/json_pref_store_unittest.cc b/base/prefs/json_pref_store_unittest.cc
|
| index 746c72bda8a51ea46a196a9330405c60cdc455cc..728a57d3417fc4e5893c4226939f12ba1b5cc7e8 100644
|
| --- a/base/prefs/json_pref_store_unittest.cc
|
| +++ b/base/prefs/json_pref_store_unittest.cc
|
| @@ -7,6 +7,7 @@
|
| #include "base/bind.h"
|
| #include "base/files/file_util.h"
|
| #include "base/files/scoped_temp_dir.h"
|
| +#include "base/location.h"
|
| #include "base/memory/ref_counted.h"
|
| #include "base/memory/scoped_ptr.h"
|
| #include "base/message_loop/message_loop.h"
|
| @@ -15,6 +16,7 @@
|
| #include "base/path_service.h"
|
| #include "base/prefs/pref_filter.h"
|
| #include "base/run_loop.h"
|
| +#include "base/single_thread_task_runner.h"
|
| #include "base/strings/string_number_conversions.h"
|
| #include "base/strings/string_util.h"
|
| #include "base/strings/utf_string_conversions.h"
|
| @@ -106,7 +108,8 @@ class JsonPrefStoreTest : public testing::Test {
|
| void TearDown() override {
|
| // Make sure all pending tasks have been processed (e.g., deleting the
|
| // JsonPrefStore may post write tasks).
|
| - message_loop_.PostTask(FROM_HERE, MessageLoop::QuitWhenIdleClosure());
|
| + message_loop_.task_runner()->PostTask(FROM_HERE,
|
| + MessageLoop::QuitWhenIdleClosure());
|
| message_loop_.Run();
|
| }
|
|
|
| @@ -127,9 +130,7 @@ TEST_F(JsonPrefStoreTest, NonExistentFile) {
|
| base::FilePath bogus_input_file = data_dir_.AppendASCII("read.txt");
|
| ASSERT_FALSE(PathExists(bogus_input_file));
|
| scoped_refptr<JsonPrefStore> pref_store = new JsonPrefStore(
|
| - bogus_input_file,
|
| - message_loop_.message_loop_proxy().get(),
|
| - scoped_ptr<PrefFilter>());
|
| + bogus_input_file, message_loop_.task_runner(), scoped_ptr<PrefFilter>());
|
| EXPECT_EQ(PersistentPrefStore::PREF_READ_ERROR_NO_FILE,
|
| pref_store->ReadPrefs());
|
| EXPECT_FALSE(pref_store->ReadOnly());
|
| @@ -142,11 +143,9 @@ TEST_F(JsonPrefStoreTest, NonExistentFileAndAlternateFile) {
|
| data_dir_.AppendASCII("read_alternate.txt");
|
| ASSERT_FALSE(PathExists(bogus_input_file));
|
| ASSERT_FALSE(PathExists(bogus_alternate_input_file));
|
| - scoped_refptr<JsonPrefStore> pref_store = new JsonPrefStore(
|
| - bogus_input_file,
|
| - bogus_alternate_input_file,
|
| - message_loop_.message_loop_proxy().get(),
|
| - scoped_ptr<PrefFilter>());
|
| + scoped_refptr<JsonPrefStore> pref_store =
|
| + new JsonPrefStore(bogus_input_file, bogus_alternate_input_file,
|
| + message_loop_.task_runner(), scoped_ptr<PrefFilter>());
|
| EXPECT_EQ(PersistentPrefStore::PREF_READ_ERROR_NO_FILE,
|
| pref_store->ReadPrefs());
|
| EXPECT_FALSE(pref_store->ReadOnly());
|
| @@ -157,10 +156,8 @@ TEST_F(JsonPrefStoreTest, InvalidFile) {
|
| base::FilePath invalid_file_original = data_dir_.AppendASCII("invalid.json");
|
| base::FilePath invalid_file = temp_dir_.path().AppendASCII("invalid.json");
|
| ASSERT_TRUE(base::CopyFile(invalid_file_original, invalid_file));
|
| - scoped_refptr<JsonPrefStore> pref_store =
|
| - new JsonPrefStore(invalid_file,
|
| - message_loop_.message_loop_proxy().get(),
|
| - scoped_ptr<PrefFilter>());
|
| + scoped_refptr<JsonPrefStore> pref_store = new JsonPrefStore(
|
| + invalid_file, message_loop_.task_runner(), scoped_ptr<PrefFilter>());
|
| EXPECT_EQ(PersistentPrefStore::PREF_READ_ERROR_JSON_PARSE,
|
| pref_store->ReadPrefs());
|
| EXPECT_FALSE(pref_store->ReadOnly());
|
| @@ -246,9 +243,7 @@ TEST_F(JsonPrefStoreTest, Basic) {
|
| base::FilePath input_file = temp_dir_.path().AppendASCII("write.json");
|
| ASSERT_TRUE(PathExists(input_file));
|
| scoped_refptr<JsonPrefStore> pref_store = new JsonPrefStore(
|
| - input_file,
|
| - message_loop_.message_loop_proxy().get(),
|
| - scoped_ptr<PrefFilter>());
|
| + input_file, message_loop_.task_runner(), scoped_ptr<PrefFilter>());
|
| ASSERT_EQ(PersistentPrefStore::PREF_READ_ERROR_NONE, pref_store->ReadPrefs());
|
| EXPECT_FALSE(pref_store->ReadOnly());
|
| EXPECT_TRUE(pref_store->IsInitializationComplete());
|
| @@ -275,9 +270,7 @@ TEST_F(JsonPrefStoreTest, BasicAsync) {
|
| base::FilePath input_file = temp_dir_.path().AppendASCII("write.json");
|
| ASSERT_TRUE(PathExists(input_file));
|
| scoped_refptr<JsonPrefStore> pref_store = new JsonPrefStore(
|
| - input_file,
|
| - message_loop_.message_loop_proxy().get(),
|
| - scoped_ptr<PrefFilter>());
|
| + input_file, message_loop_.task_runner(), scoped_ptr<PrefFilter>());
|
|
|
| {
|
| MockPrefStoreObserver mock_observer;
|
| @@ -314,9 +307,7 @@ TEST_F(JsonPrefStoreTest, PreserveEmptyValues) {
|
| FilePath pref_file = temp_dir_.path().AppendASCII("empty_values.json");
|
|
|
| scoped_refptr<JsonPrefStore> pref_store = new JsonPrefStore(
|
| - pref_file,
|
| - message_loop_.message_loop_proxy(),
|
| - scoped_ptr<PrefFilter>());
|
| + pref_file, message_loop_.task_runner(), scoped_ptr<PrefFilter>());
|
|
|
| // Set some keys with empty values.
|
| pref_store->SetValue("list", new base::ListValue);
|
| @@ -327,10 +318,8 @@ TEST_F(JsonPrefStoreTest, PreserveEmptyValues) {
|
| MessageLoop::current()->RunUntilIdle();
|
|
|
| // Reload.
|
| - pref_store = new JsonPrefStore(
|
| - pref_file,
|
| - message_loop_.message_loop_proxy(),
|
| - scoped_ptr<PrefFilter>());
|
| + pref_store = new JsonPrefStore(pref_file, message_loop_.task_runner(),
|
| + scoped_ptr<PrefFilter>());
|
| ASSERT_EQ(PersistentPrefStore::PREF_READ_ERROR_NONE, pref_store->ReadPrefs());
|
| ASSERT_FALSE(pref_store->ReadOnly());
|
|
|
| @@ -348,9 +337,7 @@ TEST_F(JsonPrefStoreTest, RemoveClearsEmptyParent) {
|
| FilePath pref_file = temp_dir_.path().AppendASCII("empty_values.json");
|
|
|
| scoped_refptr<JsonPrefStore> pref_store = new JsonPrefStore(
|
| - pref_file,
|
| - message_loop_.message_loop_proxy(),
|
| - scoped_ptr<PrefFilter>());
|
| + pref_file, message_loop_.task_runner(), scoped_ptr<PrefFilter>());
|
|
|
| base::DictionaryValue* dict = new base::DictionaryValue;
|
| dict->SetString("key", "value");
|
| @@ -368,9 +355,7 @@ TEST_F(JsonPrefStoreTest, AsyncNonExistingFile) {
|
| base::FilePath bogus_input_file = data_dir_.AppendASCII("read.txt");
|
| ASSERT_FALSE(PathExists(bogus_input_file));
|
| scoped_refptr<JsonPrefStore> pref_store = new JsonPrefStore(
|
| - bogus_input_file,
|
| - message_loop_.message_loop_proxy().get(),
|
| - scoped_ptr<PrefFilter>());
|
| + bogus_input_file, message_loop_.task_runner(), scoped_ptr<PrefFilter>());
|
| MockPrefStoreObserver mock_observer;
|
| pref_store->AddObserver(&mock_observer);
|
|
|
| @@ -398,10 +383,8 @@ TEST_F(JsonPrefStoreTest, ReadWithInterceptor) {
|
| new InterceptingPrefFilter());
|
| InterceptingPrefFilter* raw_intercepting_pref_filter_ =
|
| intercepting_pref_filter.get();
|
| - scoped_refptr<JsonPrefStore> pref_store =
|
| - new JsonPrefStore(input_file,
|
| - message_loop_.message_loop_proxy().get(),
|
| - intercepting_pref_filter.Pass());
|
| + scoped_refptr<JsonPrefStore> pref_store = new JsonPrefStore(
|
| + input_file, message_loop_.task_runner(), intercepting_pref_filter.Pass());
|
|
|
| ASSERT_EQ(PersistentPrefStore::PREF_READ_ERROR_ASYNCHRONOUS_TASK_INCOMPLETE,
|
| pref_store->ReadPrefs());
|
| @@ -445,10 +428,8 @@ TEST_F(JsonPrefStoreTest, ReadAsyncWithInterceptor) {
|
| new InterceptingPrefFilter());
|
| InterceptingPrefFilter* raw_intercepting_pref_filter_ =
|
| intercepting_pref_filter.get();
|
| - scoped_refptr<JsonPrefStore> pref_store =
|
| - new JsonPrefStore(input_file,
|
| - message_loop_.message_loop_proxy().get(),
|
| - intercepting_pref_filter.Pass());
|
| + scoped_refptr<JsonPrefStore> pref_store = new JsonPrefStore(
|
| + input_file, message_loop_.task_runner(), intercepting_pref_filter.Pass());
|
|
|
| MockPrefStoreObserver mock_observer;
|
| pref_store->AddObserver(&mock_observer);
|
| @@ -511,11 +492,9 @@ TEST_F(JsonPrefStoreTest, AlternateFile) {
|
| temp_dir_.path().AppendASCII("alternate.json");
|
| ASSERT_FALSE(PathExists(input_file));
|
| ASSERT_TRUE(PathExists(alternate_input_file));
|
| - scoped_refptr<JsonPrefStore> pref_store = new JsonPrefStore(
|
| - input_file,
|
| - alternate_input_file,
|
| - message_loop_.message_loop_proxy().get(),
|
| - scoped_ptr<PrefFilter>());
|
| + scoped_refptr<JsonPrefStore> pref_store =
|
| + new JsonPrefStore(input_file, alternate_input_file,
|
| + message_loop_.task_runner(), scoped_ptr<PrefFilter>());
|
|
|
| ASSERT_FALSE(PathExists(input_file));
|
| ASSERT_TRUE(PathExists(alternate_input_file));
|
| @@ -557,11 +536,9 @@ TEST_F(JsonPrefStoreTest, AlternateFileIgnoredWhenMainFileExists) {
|
| temp_dir_.path().AppendASCII("alternate.json");
|
| ASSERT_TRUE(PathExists(input_file));
|
| ASSERT_TRUE(PathExists(alternate_input_file));
|
| - scoped_refptr<JsonPrefStore> pref_store = new JsonPrefStore(
|
| - input_file,
|
| - alternate_input_file,
|
| - message_loop_.message_loop_proxy().get(),
|
| - scoped_ptr<PrefFilter>());
|
| + scoped_refptr<JsonPrefStore> pref_store =
|
| + new JsonPrefStore(input_file, alternate_input_file,
|
| + message_loop_.task_runner(), scoped_ptr<PrefFilter>());
|
|
|
| ASSERT_TRUE(PathExists(input_file));
|
| ASSERT_TRUE(PathExists(alternate_input_file));
|
| @@ -599,11 +576,9 @@ TEST_F(JsonPrefStoreTest, AlternateFileDNE) {
|
| temp_dir_.path().AppendASCII("alternate.json");
|
| ASSERT_TRUE(PathExists(input_file));
|
| ASSERT_FALSE(PathExists(alternate_input_file));
|
| - scoped_refptr<JsonPrefStore> pref_store = new JsonPrefStore(
|
| - input_file,
|
| - alternate_input_file,
|
| - message_loop_.message_loop_proxy().get(),
|
| - scoped_ptr<PrefFilter>());
|
| + scoped_refptr<JsonPrefStore> pref_store =
|
| + new JsonPrefStore(input_file, alternate_input_file,
|
| + message_loop_.task_runner(), scoped_ptr<PrefFilter>());
|
|
|
| ASSERT_TRUE(PathExists(input_file));
|
| ASSERT_FALSE(PathExists(alternate_input_file));
|
| @@ -641,11 +616,9 @@ TEST_F(JsonPrefStoreTest, BasicAsyncWithAlternateFile) {
|
| temp_dir_.path().AppendASCII("alternate.json");
|
| ASSERT_FALSE(PathExists(input_file));
|
| ASSERT_TRUE(PathExists(alternate_input_file));
|
| - scoped_refptr<JsonPrefStore> pref_store = new JsonPrefStore(
|
| - input_file,
|
| - alternate_input_file,
|
| - message_loop_.message_loop_proxy().get(),
|
| - scoped_ptr<PrefFilter>());
|
| + scoped_refptr<JsonPrefStore> pref_store =
|
| + new JsonPrefStore(input_file, alternate_input_file,
|
| + message_loop_.task_runner(), scoped_ptr<PrefFilter>());
|
|
|
| ASSERT_FALSE(PathExists(input_file));
|
| ASSERT_TRUE(PathExists(alternate_input_file));
|
|
|