Commit c8c0ede7 authored by pranay.kumar's avatar pranay.kumar Committed by Commit bot

Replace MessageLoopProxy usage with ThreadTaskRunnerHandle in chrome watcher module.

MessageLoopProxy is deprecated.
This basically does a search and replace:

MessageLoopProxy::current() -> ThreadTaskRunnerHandle::Get().

BUG=391045

Review URL: https://codereview.chromium.org/1103343003

Cr-Commit-Position: refs/heads/master@{#327363}
parent 5ed119b3
...@@ -13,17 +13,17 @@ ...@@ -13,17 +13,17 @@
#include "base/logging_win.h" #include "base/logging_win.h"
#include "base/macros.h" #include "base/macros.h"
#include "base/memory/ref_counted.h" #include "base/memory/ref_counted.h"
#include "base/message_loop/message_loop.h"
#include "base/message_loop/message_loop_proxy.h"
#include "base/process/process.h" #include "base/process/process.h"
#include "base/run_loop.h" #include "base/run_loop.h"
#include "base/sequenced_task_runner.h" #include "base/sequenced_task_runner.h"
#include "base/single_thread_task_runner.h"
#include "base/strings/string16.h" #include "base/strings/string16.h"
#include "base/strings/string_number_conversions.h" #include "base/strings/string_number_conversions.h"
#include "base/strings/string_piece.h" #include "base/strings/string_piece.h"
#include "base/strings/utf_string_conversions.h" #include "base/strings/utf_string_conversions.h"
#include "base/synchronization/waitable_event.h" #include "base/synchronization/waitable_event.h"
#include "base/template_util.h" #include "base/template_util.h"
#include "base/thread_task_runner_handle.h"
#include "base/threading/thread.h" #include "base/threading/thread.h"
#include "base/time/time.h" #include "base/time/time.h"
#include "base/win/scoped_handle.h" #include "base/win/scoped_handle.h"
...@@ -104,7 +104,7 @@ BrowserMonitor::BrowserMonitor(base::RunLoop* run_loop, ...@@ -104,7 +104,7 @@ BrowserMonitor::BrowserMonitor(base::RunLoop* run_loop,
base::Unretained(this))), base::Unretained(this))),
background_thread_("BrowserWatcherThread"), background_thread_("BrowserWatcherThread"),
run_loop_(run_loop), run_loop_(run_loop),
main_thread_(base::MessageLoopProxy::current()) { main_thread_(base::ThreadTaskRunnerHandle::Get()) {
} }
BrowserMonitor::~BrowserMonitor() { BrowserMonitor::~BrowserMonitor() {
...@@ -138,7 +138,7 @@ bool BrowserMonitor::StartWatching( ...@@ -138,7 +138,7 @@ bool BrowserMonitor::StartWatching(
} }
void BrowserMonitor::OnEndSessionMessage(UINT message, LPARAM lparam) { void BrowserMonitor::OnEndSessionMessage(UINT message, LPARAM lparam) {
DCHECK_EQ(main_thread_, base::MessageLoopProxy::current()); DCHECK_EQ(main_thread_, base::ThreadTaskRunnerHandle::Get());
if (message == WM_QUERYENDSESSION) { if (message == WM_QUERYENDSESSION) {
exit_funnel_.RecordEvent(L"WatcherQueryEndSession"); exit_funnel_.RecordEvent(L"WatcherQueryEndSession");
...@@ -165,7 +165,7 @@ void BrowserMonitor::OnEndSessionMessage(UINT message, LPARAM lparam) { ...@@ -165,7 +165,7 @@ void BrowserMonitor::OnEndSessionMessage(UINT message, LPARAM lparam) {
void BrowserMonitor::Watch(base::win::ScopedHandle on_initialized_event) { void BrowserMonitor::Watch(base::win::ScopedHandle on_initialized_event) {
// This needs to run on an IO thread. // This needs to run on an IO thread.
DCHECK_NE(main_thread_, base::MessageLoopProxy::current()); DCHECK_NE(main_thread_, base::ThreadTaskRunnerHandle::Get());
// Signal our client now that the Kasko reporter is initialized and we have // Signal our client now that the Kasko reporter is initialized and we have
// cleared all of the obstacles that might lead to an early exit. // cleared all of the obstacles that might lead to an early exit.
...@@ -184,7 +184,7 @@ void BrowserMonitor::Watch(base::win::ScopedHandle on_initialized_event) { ...@@ -184,7 +184,7 @@ void BrowserMonitor::Watch(base::win::ScopedHandle on_initialized_event) {
void BrowserMonitor::BrowserExited() { void BrowserMonitor::BrowserExited() {
// This runs in the main thread. // This runs in the main thread.
DCHECK_EQ(main_thread_, base::MessageLoopProxy::current()); DCHECK_EQ(main_thread_, base::ThreadTaskRunnerHandle::Get());
// Our background thread has served it's purpose. // Our background thread has served it's purpose.
background_thread_.Stop(); background_thread_.Stop();
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment