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

Side by Side Diff: base/message_loop/message_loop_unittest.cc

Issue 2375663002: Replace MessageLoop::current()->task_runner() with ThreadTaskRunnerHandle::Get(). (Closed)
Patch Set: rebase Created 4 years, 2 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 unified diff | Download patch
OLDNEW
1 // Copyright 2013 The Chromium Authors. All rights reserved. 1 // Copyright 2013 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include <stddef.h> 5 #include <stddef.h>
6 #include <stdint.h> 6 #include <stdint.h>
7 7
8 #include <vector> 8 #include <vector>
9 9
10 #include "base/bind.h" 10 #include "base/bind.h"
(...skipping 438 matching lines...) Expand 10 before | Expand all | Expand 10 after
449 EXPECT_EQ(order.Get(14), TaskItem(RECURSIVE, 1, true)); 449 EXPECT_EQ(order.Get(14), TaskItem(RECURSIVE, 1, true));
450 EXPECT_EQ(order.Get(15), TaskItem(RECURSIVE, 1, false)); 450 EXPECT_EQ(order.Get(15), TaskItem(RECURSIVE, 1, false));
451 EXPECT_EQ(order.Get(16), TaskItem(RECURSIVE, 3, true)); 451 EXPECT_EQ(order.Get(16), TaskItem(RECURSIVE, 3, true));
452 EXPECT_EQ(order.Get(17), TaskItem(RECURSIVE, 3, false)); 452 EXPECT_EQ(order.Get(17), TaskItem(RECURSIVE, 3, false));
453 } 453 }
454 454
455 #endif // defined(OS_WIN) 455 #endif // defined(OS_WIN)
456 456
457 void PostNTasksThenQuit(int posts_remaining) { 457 void PostNTasksThenQuit(int posts_remaining) {
458 if (posts_remaining > 1) { 458 if (posts_remaining > 1) {
459 MessageLoop::current()->task_runner()->PostTask( 459 ThreadTaskRunnerHandle::Get()->PostTask(
460 FROM_HERE, Bind(&PostNTasksThenQuit, posts_remaining - 1)); 460 FROM_HERE, Bind(&PostNTasksThenQuit, posts_remaining - 1));
461 } else { 461 } else {
462 MessageLoop::current()->QuitWhenIdle(); 462 MessageLoop::current()->QuitWhenIdle();
463 } 463 }
464 } 464 }
465 465
466 #if defined(OS_WIN) 466 #if defined(OS_WIN)
467 467
468 class TestIOHandler : public MessageLoopForIO::IOHandler { 468 class TestIOHandler : public MessageLoopForIO::IOHandler {
469 public: 469 public:
(...skipping 395 matching lines...) Expand 10 before | Expand all | Expand 10 after
865 // posts tasks on that message loop. 865 // posts tasks on that message loop.
866 TEST(MessageLoopTest, ThreadMainTaskRunner) { 866 TEST(MessageLoopTest, ThreadMainTaskRunner) {
867 MessageLoop loop; 867 MessageLoop loop;
868 868
869 scoped_refptr<Foo> foo(new Foo()); 869 scoped_refptr<Foo> foo(new Foo());
870 std::string a("a"); 870 std::string a("a");
871 ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE, Bind( 871 ThreadTaskRunnerHandle::Get()->PostTask(FROM_HERE, Bind(
872 &Foo::Test1ConstRef, foo, a)); 872 &Foo::Test1ConstRef, foo, a));
873 873
874 // Post quit task; 874 // Post quit task;
875 MessageLoop::current()->task_runner()->PostTask( 875 ThreadTaskRunnerHandle::Get()->PostTask(
876 FROM_HERE, 876 FROM_HERE,
877 Bind(&MessageLoop::QuitWhenIdle, Unretained(MessageLoop::current()))); 877 Bind(&MessageLoop::QuitWhenIdle, Unretained(MessageLoop::current())));
878 878
879 // Now kick things off 879 // Now kick things off
880 RunLoop().Run(); 880 RunLoop().Run();
881 881
882 EXPECT_EQ(foo->test_count(), 1); 882 EXPECT_EQ(foo->test_count(), 1);
883 EXPECT_EQ(foo->result(), "a"); 883 EXPECT_EQ(foo->result(), "a");
884 } 884 }
885 885
(...skipping 138 matching lines...) Expand 10 before | Expand all | Expand 10 after
1024 1024
1025 { 1025 {
1026 std::string kThreadName("bar"); 1026 std::string kThreadName("bar");
1027 base::Thread thread(kThreadName); 1027 base::Thread thread(kThreadName);
1028 ASSERT_TRUE(thread.StartAndWaitForTesting()); 1028 ASSERT_TRUE(thread.StartAndWaitForTesting());
1029 EXPECT_EQ(kThreadName, thread.message_loop()->GetThreadName()); 1029 EXPECT_EQ(kThreadName, thread.message_loop()->GetThreadName());
1030 } 1030 }
1031 } 1031 }
1032 1032
1033 } // namespace base 1033 } // namespace base
OLDNEW
« no previous file with comments | « base/message_loop/message_loop_test.cc ('k') | base/message_loop/message_pump_libevent_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698