[components/policy] Use ThreadTaskRunnerHandle instead of LoopProxy

components/policy/core/common/async_policy_provider.cc

 // Copyright 2013 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 "components/policy/core/common/async_policy_provider.h"
 
 #include "base/bind.h"
 #include "base/bind_helpers.h"
 #include "base/location.h"
-#include "base/message_loop/message_loop.h"
-#include "base/message_loop/message_loop_proxy.h"
 #include "base/sequenced_task_runner.h"
+#include "base/single_thread_task_runner.h"
+#include "base/thread_task_runner_handle.h"
 #include "components/policy/core/common/async_policy_loader.h"
 #include "components/policy/core/common/policy_bundle.h"
 #include "components/policy/core/common/schema_registry.h"
 
 namespace policy {
 
 AsyncPolicyProvider::AsyncPolicyProvider(
     SchemaRegistry* registry,
     scoped_ptr<AsyncPolicyLoader> loader)
     : loader_(loader.Pass()),
       weak_factory_(this) {
   // Make an immediate synchronous load on startup.
   OnLoaderReloaded(loader_->InitialLoad(registry->schema_map()));
 }
 
 AsyncPolicyProvider::~AsyncPolicyProvider() {
   DCHECK(CalledOnValidThread());
 }
 
 void AsyncPolicyProvider::Init(SchemaRegistry* registry) {
   DCHECK(CalledOnValidThread());
   ConfigurationPolicyProvider::Init(registry);
 
   if (!loader_)
     return;
 
   AsyncPolicyLoader::UpdateCallback callback =
       base::Bind(&AsyncPolicyProvider::LoaderUpdateCallback,
-                 base::MessageLoopProxy::current(),
+                 base::ThreadTaskRunnerHandle::Get(),
                  weak_factory_.GetWeakPtr());
   bool post = loader_->task_runner()->PostTask(
       FROM_HERE,
       base::Bind(&AsyncPolicyLoader::Init,
                  base::Unretained(loader_.get()),
                  callback));
   DCHECK(post) << "AsyncPolicyProvider::Init() called with threads not running";
 }
 
 void AsyncPolicyProvider::Shutdown() {
@@ skipping 61 matching lines @@
 void AsyncPolicyProvider::OnLoaderReloaded(scoped_ptr<PolicyBundle> bundle) {
   DCHECK(CalledOnValidThread());
   // Only propagate policy updates if there are no pending refreshes, and if
   // Shutdown() hasn't been called yet.
   if (refresh_callback_.IsCancelled() && loader_)
     UpdatePolicy(bundle.Pass());
 }
 
 // static
 void AsyncPolicyProvider::LoaderUpdateCallback(
-    scoped_refptr<base::MessageLoopProxy> loop,
+    scoped_refptr<base::SingleThreadTaskRunner> runner,
     base::WeakPtr<AsyncPolicyProvider> weak_this,
     scoped_ptr<PolicyBundle> bundle) {
-  loop->PostTask(FROM_HERE,
+  runner->PostTask(FROM_HERE,
                  base::Bind(&AsyncPolicyProvider::OnLoaderReloaded,
                             weak_this,
                             base::Passed(&bundle)));
 }
 
 }  // namespace policy