| Index: base/task/cancelable_task_tracker_unittest.cc
|
| diff --git a/base/task/cancelable_task_tracker_unittest.cc b/base/task/cancelable_task_tracker_unittest.cc
|
| index 8b2b86a6a52ed7e717261d49ef69a331ec93ffb7..ff9e40b855eaebce8d77f362ed827757f151cb5f 100644
|
| --- a/base/task/cancelable_task_tracker_unittest.cc
|
| +++ b/base/task/cancelable_task_tracker_unittest.cc
|
| @@ -13,8 +13,8 @@
|
| #include "base/logging.h"
|
| #include "base/memory/ref_counted.h"
|
| #include "base/memory/weak_ptr.h"
|
| -#include "base/message_loop/message_loop.h"
|
| #include "base/run_loop.h"
|
| +#include "base/single_thread_task_runner.h"
|
| #include "base/test/test_simple_task_runner.h"
|
| #include "base/threading/thread.h"
|
| #include "testing/gtest/include/gtest/gtest.h"
|
| @@ -84,15 +84,13 @@ TEST_F(CancelableTaskTrackerTest, NoCancel) {
|
| Thread worker_thread("worker thread");
|
| ASSERT_TRUE(worker_thread.Start());
|
|
|
| - ignore_result(task_tracker_.PostTask(worker_thread.message_loop_proxy().get(),
|
| + ignore_result(task_tracker_.PostTask(worker_thread.task_runner().get(),
|
| FROM_HERE,
|
| MakeExpectedRunClosure(FROM_HERE)));
|
|
|
| - ignore_result(
|
| - task_tracker_.PostTaskAndReply(worker_thread.message_loop_proxy().get(),
|
| - FROM_HERE,
|
| - MakeExpectedRunClosure(FROM_HERE),
|
| - MakeExpectedRunClosure(FROM_HERE)));
|
| + ignore_result(task_tracker_.PostTaskAndReply(
|
| + worker_thread.task_runner().get(), FROM_HERE,
|
| + MakeExpectedRunClosure(FROM_HERE), MakeExpectedRunClosure(FROM_HERE)));
|
|
|
| CancelableTaskTracker::IsCanceledCallback is_canceled;
|
| ignore_result(task_tracker_.NewTrackedTaskId(&is_canceled));
|
| @@ -166,11 +164,9 @@ TEST_F(CancelableTaskTrackerTest, CancelReplyDifferentThread) {
|
| Thread worker_thread("worker thread");
|
| ASSERT_TRUE(worker_thread.Start());
|
|
|
| - CancelableTaskTracker::TaskId task_id =
|
| - task_tracker_.PostTaskAndReply(worker_thread.message_loop_proxy().get(),
|
| - FROM_HERE,
|
| - Bind(&DoNothing),
|
| - MakeExpectedNotRunClosure(FROM_HERE));
|
| + CancelableTaskTracker::TaskId task_id = task_tracker_.PostTaskAndReply(
|
| + worker_thread.task_runner().get(), FROM_HERE, Bind(&DoNothing),
|
| + MakeExpectedNotRunClosure(FROM_HERE));
|
| EXPECT_NE(CancelableTaskTracker::kBadTaskId, task_id);
|
|
|
| task_tracker_.TryCancel(task_id);
|
| @@ -196,14 +192,14 @@ TEST_F(CancelableTaskTrackerTest, NewTrackedTaskIdDifferentThread) {
|
|
|
| Thread other_thread("other thread");
|
| ASSERT_TRUE(other_thread.Start());
|
| - other_thread.message_loop_proxy()->PostTask(
|
| + other_thread.task_runner()->PostTask(
|
| FROM_HERE, Bind(&ExpectIsCanceled, is_canceled, false));
|
| other_thread.Stop();
|
|
|
| task_tracker_.TryCancel(task_id);
|
|
|
| ASSERT_TRUE(other_thread.Start());
|
| - other_thread.message_loop_proxy()->PostTask(
|
| + other_thread.task_runner()->PostTask(
|
| FROM_HERE, Bind(&ExpectIsCanceled, is_canceled, true));
|
| other_thread.Stop();
|
| }
|
| @@ -378,11 +374,9 @@ TEST_F(CancelableTaskTrackerDeathTest, PostFromDifferentThread) {
|
| Thread bad_thread("bad thread");
|
| ASSERT_TRUE(bad_thread.Start());
|
|
|
| - bad_thread.message_loop_proxy()->PostTask(
|
| - FROM_HERE,
|
| - Bind(&MaybeRunDeadlyTaskTrackerMemberFunction,
|
| - Unretained(&task_tracker_),
|
| - Bind(&PostDoNothingTask)));
|
| + bad_thread.task_runner()->PostTask(
|
| + FROM_HERE, Bind(&MaybeRunDeadlyTaskTrackerMemberFunction,
|
| + Unretained(&task_tracker_), Bind(&PostDoNothingTask)));
|
| }
|
|
|
| void TryCancel(CancelableTaskTracker::TaskId task_id,
|
| @@ -401,11 +395,9 @@ TEST_F(CancelableTaskTrackerDeathTest, CancelOnDifferentThread) {
|
| test_task_runner.get(), FROM_HERE, Bind(&DoNothing));
|
| EXPECT_NE(CancelableTaskTracker::kBadTaskId, task_id);
|
|
|
| - bad_thread.message_loop_proxy()->PostTask(
|
| - FROM_HERE,
|
| - Bind(&MaybeRunDeadlyTaskTrackerMemberFunction,
|
| - Unretained(&task_tracker_),
|
| - Bind(&TryCancel, task_id)));
|
| + bad_thread.task_runner()->PostTask(
|
| + FROM_HERE, Bind(&MaybeRunDeadlyTaskTrackerMemberFunction,
|
| + Unretained(&task_tracker_), Bind(&TryCancel, task_id)));
|
|
|
| test_task_runner->RunUntilIdle();
|
| }
|
| @@ -421,10 +413,9 @@ TEST_F(CancelableTaskTrackerDeathTest, CancelAllOnDifferentThread) {
|
| test_task_runner.get(), FROM_HERE, Bind(&DoNothing));
|
| EXPECT_NE(CancelableTaskTracker::kBadTaskId, task_id);
|
|
|
| - bad_thread.message_loop_proxy()->PostTask(
|
| + bad_thread.task_runner()->PostTask(
|
| FROM_HERE,
|
| - Bind(&MaybeRunDeadlyTaskTrackerMemberFunction,
|
| - Unretained(&task_tracker_),
|
| + Bind(&MaybeRunDeadlyTaskTrackerMemberFunction, Unretained(&task_tracker_),
|
| Bind(&CancelableTaskTracker::TryCancelAll)));
|
|
|
| test_task_runner->RunUntilIdle();
|
|
|