chrome/browser: Remove use of MessageLoopProxy and deprecated MessageLoop APIs

chrome/browser/prefs/leveldb_pref_store_unittest.cc

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "chrome/browser/prefs/leveldb_pref_store.h"
 
 #include "base/files/file_util.h"
 #include "base/files/scoped_temp_dir.h"
 #include "base/memory/scoped_ptr.h"
-#include "base/message_loop/message_loop.h"
 #include "base/path_service.h"
 #include "base/run_loop.h"
 #include "base/values.h"
 #include "chrome/common/chrome_paths.h"
 #include "testing/gmock/include/gmock/gmock.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 namespace {
 
 class MockPrefStoreObserver : public PrefStore::Observer {
@@ skipping 15 matching lines @@
     ASSERT_TRUE(temp_dir_.CreateUniqueTempDir());
 
     ASSERT_TRUE(PathService::Get(chrome::DIR_TEST_DATA, &data_dir_));
     data_dir_ = data_dir_.AppendASCII("prefs");
     ASSERT_TRUE(PathExists(data_dir_));
   }
 
   void TearDown() override { Close(); }
 
   void Open() {
-    pref_store_ = new LevelDBPrefStore(
-        temp_dir_.path(), message_loop_.message_loop_proxy().get());
+    pref_store_ = new LevelDBPrefStore(temp_dir_.path(),
+                                       message_loop_.task_runner().get());
     EXPECT_EQ(LevelDBPrefStore::PREF_READ_ERROR_NONE, pref_store_->ReadPrefs());
   }
 
   void Close() {
     pref_store_ = NULL;
     base::RunLoop().RunUntilIdle();
   }
 
   void CloseAndReopen() {
     Close();
@@ skipping 28 matching lines @@
                         WriteablePrefStore::DEFAULT_PREF_WRITE_FLAGS);
 
   CloseAndReopen();
   const base::Value* actual_value = NULL;
   base::FundamentalValue orig_value(5);
   EXPECT_TRUE(pref_store_->GetValue(key, &actual_value));
   EXPECT_TRUE(orig_value.Equals(actual_value));
 }
 
 TEST_F(LevelDBPrefStoreTest, BasicObserver) {
-  scoped_refptr<LevelDBPrefStore> pref_store = new LevelDBPrefStore(
-      temp_dir_.path(), message_loop_.message_loop_proxy().get());
+  scoped_refptr<LevelDBPrefStore> pref_store =
+      new LevelDBPrefStore(temp_dir_.path(), message_loop_.task_runner().get());
   MockPrefStoreObserver mock_observer;
   pref_store->AddObserver(&mock_observer);
   EXPECT_CALL(mock_observer, OnInitializationCompleted(true)).Times(1);
   EXPECT_EQ(PersistentPrefStore::PREF_READ_ERROR_NONE, pref_store->ReadPrefs());
   testing::Mock::VerifyAndClearExpectations(&mock_observer);
 
   const std::string key = "some.key";
   EXPECT_CALL(mock_observer, OnPrefValueChanged(key)).Times(1);
   pref_store->SetValue(key, new base::FundamentalValue(5),
                        WriteablePrefStore::DEFAULT_PREF_WRITE_FLAGS);
@@ skipping 84 matching lines @@
 
 TEST_F(LevelDBPrefStoreTest, OpenAsync) {
   // First set a key/value with a synchronous connection.
   Open();
   const std::string key = "some.key";
   pref_store_->SetValue(key, new base::FundamentalValue(5),
                         WriteablePrefStore::DEFAULT_PREF_WRITE_FLAGS);
   Close();
 
   scoped_refptr<LevelDBPrefStore> pref_store(new LevelDBPrefStore(
-      temp_dir_.path(), message_loop_.message_loop_proxy().get()));
+      temp_dir_.path(), message_loop_.task_runner().get()));
   MockReadErrorDelegate* delegate = new MockReadErrorDelegate;
   pref_store->ReadPrefsAsync(delegate);
 
   MockPrefStoreObserver mock_observer;
   pref_store->AddObserver(&mock_observer);
   EXPECT_CALL(mock_observer, OnInitializationCompleted(true)).Times(1);
   base::RunLoop().RunUntilIdle();
   pref_store->RemoveObserver(&mock_observer);
 
   const base::Value* result;
   EXPECT_TRUE(pref_store->GetValue("some.key", &result));
   int int_value;
   EXPECT_TRUE(result->GetAsInteger(&int_value));
   EXPECT_EQ(5, int_value);
 
   pref_store = NULL;
 }
 
 TEST_F(LevelDBPrefStoreTest, OpenAsyncError) {
   // Open a connection that will lock the database.
   Open();
 
   // Try to open an async connection to the same database.
   scoped_refptr<LevelDBPrefStore> pref_store(new LevelDBPrefStore(
-      temp_dir_.path(), message_loop_.message_loop_proxy().get()));
+      temp_dir_.path(), message_loop_.task_runner().get()));
   MockReadErrorDelegate* delegate = new MockReadErrorDelegate;
   pref_store->ReadPrefsAsync(delegate);
 
   MockPrefStoreObserver mock_observer;
   pref_store->AddObserver(&mock_observer);
   EXPECT_CALL(*delegate,
               OnError(PersistentPrefStore::PREF_READ_ERROR_LEVELDB_IO))
       .Times(1);
   EXPECT_CALL(mock_observer, OnInitializationCompleted(true)).Times(1);
   base::RunLoop().RunUntilIdle();
   pref_store->RemoveObserver(&mock_observer);
 
   EXPECT_TRUE(pref_store->ReadOnly());
   EXPECT_EQ(PersistentPrefStore::PREF_READ_ERROR_LEVELDB_IO,
             pref_store->GetReadError());
 
   // Sync connection to the database will be closed by the destructor.
 }
 
 TEST_F(LevelDBPrefStoreTest, RepairCorrupt) {
   // Open a database where CURRENT has no newline. Ensure that repair is called
   // and there is no error reading the database.
   base::FilePath corrupted_dir = data_dir_.AppendASCII("corrupted_leveldb");
   base::FilePath dest = temp_dir_.path().AppendASCII("corrupted_leveldb");
   const bool kRecursive = true;
   ASSERT_TRUE(CopyDirectory(corrupted_dir, dest, kRecursive));
-  pref_store_ =
-      new LevelDBPrefStore(dest, message_loop_.message_loop_proxy().get());
+  pref_store_ = new LevelDBPrefStore(dest, message_loop_.task_runner().get());
   EXPECT_EQ(LevelDBPrefStore::PREF_READ_ERROR_LEVELDB_CORRUPTION,
             pref_store_->ReadPrefs());
 }
 
 TEST_F(LevelDBPrefStoreTest, Values) {
   Open();
   pref_store_->SetValue("boolean", new base::FundamentalValue(false),
                         WriteablePrefStore::DEFAULT_PREF_WRITE_FLAGS);
   pref_store_->SetValue("integer", new base::FundamentalValue(10),
                         WriteablePrefStore::DEFAULT_PREF_WRITE_FLAGS);
@@ skipping 43 matching lines @@
 
   EXPECT_TRUE(pref_store_->GetValue("dictionary", &value));
   EXPECT_TRUE(base::Value::Equals(golden_dict_value.get(), value));
 
   EXPECT_TRUE(pref_store_->GetValue("list", &value));
   EXPECT_TRUE(base::Value::Equals(golden_list_value.get(), value));
 
   EXPECT_TRUE(pref_store_->GetValue("compound_value", &value));
   EXPECT_TRUE(base::Value::Equals(golden_compound_value.get(), value));
 }