Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(21)

Unified Diff: components/invalidation/sync_invalidation_listener.cc

Issue 1144153004: components: Remove use of MessageLoopProxy and deprecated MessageLoop APIs (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Rebased. Created 5 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: components/invalidation/sync_invalidation_listener.cc
diff --git a/components/invalidation/sync_invalidation_listener.cc b/components/invalidation/sync_invalidation_listener.cc
index 7259f73ebd2f2bbdbd00a3e1bcdff14a6c8ef6c9..d7dd8f4089adac44e0ee41c765bdf814380cf52b 100644
--- a/components/invalidation/sync_invalidation_listener.cc
+++ b/components/invalidation/sync_invalidation_listener.cc
@@ -9,7 +9,10 @@
#include "base/bind.h"
#include "base/callback.h"
#include "base/compiler_specific.h"
+#include "base/location.h"
#include "base/logging.h"
+#include "base/single_thread_task_runner.h"
+#include "base/thread_task_runner_handle.h"
#include "base/tracked_objects.h"
#include "components/invalidation/invalidation_util.h"
#include "components/invalidation/object_id_invalidation_map.h"
@@ -137,7 +140,7 @@ void SyncInvalidationListener::Invalidate(
ObjectIdInvalidationMap invalidations;
Invalidation inv = Invalidation::Init(id, invalidation.version(), payload);
- inv.SetAckHandler(AsWeakPtr(), base::MessageLoopProxy::current());
+ inv.SetAckHandler(AsWeakPtr(), base::ThreadTaskRunnerHandle::Get());
invalidations.Insert(inv);
DispatchInvalidations(invalidations);
@@ -154,7 +157,8 @@ void SyncInvalidationListener::InvalidateUnknownVersion(
ObjectIdInvalidationMap invalidations;
Invalidation unknown_version = Invalidation::InitUnknownVersion(object_id);
- unknown_version.SetAckHandler(AsWeakPtr(), base::MessageLoopProxy::current());
+ unknown_version.SetAckHandler(AsWeakPtr(),
+ base::ThreadTaskRunnerHandle::Get());
invalidations.Insert(unknown_version);
DispatchInvalidations(invalidations);
@@ -175,7 +179,7 @@ void SyncInvalidationListener::InvalidateAll(
it != registered_ids_.end(); ++it) {
Invalidation unknown_version = Invalidation::InitUnknownVersion(*it);
unknown_version.SetAckHandler(AsWeakPtr(),
- base::MessageLoopProxy::current());
+ base::ThreadTaskRunnerHandle::Get());
invalidations.Insert(unknown_version);
}
@@ -358,7 +362,7 @@ void SyncInvalidationListener::DoRegistrationUpdate() {
continue;
}
map_it->second.ExportInvalidations(AsWeakPtr(),
- base::MessageLoopProxy::current(),
+ base::ThreadTaskRunnerHandle::Get(),
&object_id_invalidation_map);
}

Powered by Google App Engine
This is Rietveld 408576698