components: Remove use of MessageLoopProxy and deprecated MessageLoop APIs

components/dom_distiller/core/dom_distiller_store.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/dom_distiller/core/dom_distiller_store.h"
 
 #include "base/bind.h"
+#include "base/location.h"
 #include "base/logging.h"
-#include "base/message_loop/message_loop.h"
+#include "base/single_thread_task_runner.h"
+#include "base/thread_task_runner_handle.h"
 #include "components/dom_distiller/core/article_entry.h"
 #include "sync/api/sync_change.h"
 #include "sync/protocol/article_specifics.pb.h"
 #include "sync/protocol/sync.pb.h"
 
 using leveldb_proto::ProtoDatabase;
 using sync_pb::ArticleSpecifics;
 using sync_pb::EntitySpecifics;
 using syncer::ModelType;
 using syncer::SyncChange;
@@ skipping 43 matching lines @@
 
 bool DomDistillerStore::GetEntryByUrl(const GURL& url, ArticleEntry* entry) {
   return model_.GetEntryByUrl(url, entry);
 }
 
 void DomDistillerStore::UpdateAttachments(
     const std::string& entry_id,
     scoped_ptr<ArticleAttachmentsData> attachments_data,
     const UpdateAttachmentsCallback& callback) {
   if (!GetEntryById(entry_id, nullptr)) {
-    base::MessageLoop::current()->PostTask(FROM_HERE,
-                                           base::Bind(callback, false));
+    base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE,
+                                                  base::Bind(callback, false));
   }
 
   scoped_ptr<sync_pb::ArticleAttachments> article_attachments(
       new sync_pb::ArticleAttachments());
   syncer::AttachmentList attachment_list;
   attachments_data->CreateSyncAttachments(&attachment_list,
                                           article_attachments.get());
 
   attachment_store_->Write(
       attachment_list,
@@ skipping 40 matching lines @@
 
       ApplyChangesToModel(changes_to_apply, &changes_applied, &changes_missing);
 
       DCHECK_EQ(size_t(0), changes_missing.size());
       DCHECK_EQ(size_t(1), changes_applied.size());
 
       ApplyChangesToSync(FROM_HERE, changes_applied);
       ApplyChangesToDatabase(changes_applied);
     }
   }
-  base::MessageLoop::current()->PostTask(FROM_HERE,
-                                         base::Bind(callback, success));
+  base::ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE,
+                                                base::Bind(callback, success));
 }
 
 void DomDistillerStore::GetAttachments(
     const std::string& entry_id,
     const GetAttachmentsCallback& callback) {
   ArticleEntry entry;
   if (!model_.GetEntryById(entry_id, &entry)
       || !entry.has_attachments()) {
-    base::MessageLoop::current()->PostTask(
+    base::ThreadTaskRunnerHandle::Get()->PostTask(
         FROM_HERE, base::Bind(callback, false, nullptr));
     return;
   }
 
   // TODO(cjhopman): This should use GetOrDownloadAttachments() once there is a
   // feasible way to use that.
   attachment_store_->Read(GetAttachmentIds(entry.attachments()),
                           base::Bind(&DomDistillerStore::OnAttachmentsRead,
                                      weak_ptr_factory_.GetWeakPtr(),
                                      entry.attachments(), callback));
@@ skipping 13 matching lines @@
     case syncer::AttachmentStore::SUCCESS:
       DCHECK(missing->empty());
       success = true;
       break;
   }
   scoped_ptr<ArticleAttachmentsData> attachments_data;
   if (success) {
     attachments_data = ArticleAttachmentsData::GetFromAttachmentMap(
         attachments_proto, *attachments);
   }
-  base::MessageLoop::current()->PostTask(
+  base::ThreadTaskRunnerHandle::Get()->PostTask(
       FROM_HERE,
       base::Bind(callback, success, base::Passed(&attachments_data)));
 }
 
 bool DomDistillerStore::AddEntry(const ArticleEntry& entry) {
   return ChangeEntry(entry, SyncChange::ACTION_ADD);
 }
 
 bool DomDistillerStore::UpdateEntry(const ArticleEntry& entry) {
   return ChangeEntry(entry, SyncChange::ACTION_UPDATE);
@@ skipping 277 matching lines @@
   result.set_num_items_deleted(0);
 
   result.set_pre_association_version(0);
   result.set_num_items_after_association(model_.GetNumEntries());
   result.set_error(error);
 
   return result;
 }
 
 }  // namespace dom_distiller