/external/libbrillo/brillo/message_loops/ |
fake_message_loop_unittest.cc | 30 loop_.reset(new FakeMessageLoop(nullptr)); 31 EXPECT_TRUE(loop_.get()); 34 EXPECT_FALSE(loop_->PendingTasks()); 38 std::unique_ptr<FakeMessageLoop> loop_; member in class:brillo::FakeMessageLoopTest 42 EXPECT_FALSE(loop_->CancelTask(MessageLoop::kTaskIdNull)); 43 EXPECT_FALSE(loop_->CancelTask(1234)); 48 loop_->PostDelayedTask(Bind([&order]() { order.push_back(1); }), 50 loop_->PostDelayedTask(Bind([&order]() { order.push_back(4); }), 52 loop_->PostDelayedTask(Bind([&order]() { order.push_back(3); }), 54 loop_->PostDelayedTask(Bind([&order]() { order.push_back(2); }) [all...] |
glib_message_loop_unittest.cc | 30 loop_.reset(new GlibMessageLoop()); 31 EXPECT_TRUE(loop_.get()); 34 std::unique_ptr<GlibMessageLoop> loop_; member in class:brillo::GlibMessageLoopTest 43 TaskId task_id = loop_->WatchFileDescriptor( 47 EXPECT_NE(0, MessageLoopRunMaxIterations(loop_.get(), 10)); 49 EXPECT_TRUE(loop_->CancelTask(task_id)); 56 TaskId task_id = loop_->WatchFileDescriptor( 64 EXPECT_NE(0, MessageLoopRunMaxIterations(loop_.get(), 10)); 66 EXPECT_TRUE(loop_->CancelTask(task_id));
|
message_loop_unittest.cc | 38 EXPECT_TRUE(this->loop_.get()); 43 std::unique_ptr<MessageLoop> loop_; member in class:brillo::MessageLoopTest 53 loop_.reset(new GlibMessageLoop()); 59 loop_.reset(new BaseMessageLoop(base::MessageLoopForIO::current())); 71 EXPECT_FALSE(this->loop_->CancelTask(MessageLoop::kTaskIdNull)); 72 EXPECT_FALSE(this->loop_->CancelTask(1234)); 77 TaskId task_id = this->loop_->PostTask(FROM_HERE, 80 MessageLoopRunMaxIterations(this->loop_.get(), 100); 87 TaskId task_id = this->loop_->PostTask(FROM_HERE, 89 EXPECT_TRUE(this->loop_->CancelTask(task_id)) [all...] |
glib_message_loop.cc | 17 loop_ = g_main_loop_new(g_main_context_default(), FALSE); 28 g_main_loop_unref(loop_); 145 g_main_loop_run(loop_); 149 g_main_loop_quit(loop_);
|
base_message_loop.cc | 306 : location_(location), loop_(loop), task_id_(task_id), 310 return loop_->base_loop_->WatchFileDescriptor( 344 bool base_scheduled = loop_->base_loop_->task_runner()->PostTask( 347 loop_->weak_ptr_factory_.GetWeakPtr(), 367 BaseMessageLoop* loop_ptr = loop_; 375 loop_->io_tasks_.erase(task_id_); 397 loop_->io_tasks_.erase(task_id_); 418 loop_->io_tasks_.erase(task_id_);
|
glib_message_loop.h | 60 GMainLoop* loop_; member in class:brillo::GlibMessageLoop
|
base_message_loop.h | 122 BaseMessageLoop* loop_; member in class:brillo::BaseMessageLoop::IOTask
|
/external/libchrome/base/ |
run_loop.cc | 18 : loop_(MessageLoop::current()), 33 : loop_(MessageLoop::current()), 56 loop_->RunHandler(); 69 if (running_ && loop_->run_loop_ == this) { 71 loop_->QuitNow(); 88 previous_run_loop_ = loop_->run_loop_; 90 loop_->run_loop_ = this; 100 loop_->run_loop_ = previous_run_loop_; 104 loop_->QuitNow();
|
run_loop.h | 93 MessageLoop* loop_; member in class:base::RunLoop
|
observer_list_unittest.cc | 98 loop_(nullptr), 110 loop_ = new MessageLoop(); // Fire up a message loop. 111 loop_->task_runner()->PostTask( 114 loop_->Run(); 115 //LOG(ERROR) << "Loop 0x" << std::hex << loop_ << " done. " << 117 delete loop_; 118 loop_ = reinterpret_cast<MessageLoop*>(0xdeadbeef); 141 loop_->task_runner()->PostTask( 147 loop_->task_runner()->PostTask(FROM_HERE, 159 EXPECT_EQ(loop_, MessageLoop::current()) 167 MessageLoop* loop_; member in class:base::__anon15770::AddRemoveThread [all...] |
/system/update_engine/update_manager/ |
real_device_policy_provider_unittest.cc | 53 loop_.SetAsCurrent(); 70 EXPECT_FALSE(loop_.PendingTasks()); 91 brillo::FakeMessageLoop loop_{nullptr}; 105 loop_.RunOnce(false); 116 loop_.RunOnce(false); 124 loop_.RunOnce(false); 134 loop_.RunOnce(false); 146 loop_.RunOnce(false); 166 loop_.RunOnce(false); 195 loop_.RunOnce(false) [all...] |
generic_variables_unittest.cc | 152 loop_.SetAsCurrent(); 157 EXPECT_FALSE(loop_.PendingTasks()); 161 brillo::FakeMessageLoop loop_{nullptr};
|
real_shill_provider_unittest.cc | 67 loop_.SetAsCurrent(); 80 EXPECT_FALSE(loop_.PendingTasks()); 120 EXPECT_TRUE(loop_.RunOnce(false)); 203 brillo::FakeMessageLoop loop_{nullptr}; 297 EXPECT_TRUE(loop_.RunOnce(false)); 509 EXPECT_TRUE(loop_.RunOnce(false)); 521 EXPECT_TRUE(loop_.RunOnce(false));
|
variable_unittest.cc | 57 loop_.SetAsCurrent(); 60 brillo::FakeMessageLoop loop_{nullptr};
|
update_manager_unittest.cc | 80 loop_.SetAsCurrent(); 87 EXPECT_FALSE(loop_.PendingTasks()); 91 brillo::FakeMessageLoop loop_{&test_clock_};
|
/system/update_engine/common/ |
subprocess_unittest.cc | 68 loop_.SetAsCurrent(); 74 brillo::BaseMessageLoop loop_{&base_loop_}; 136 loop_.Run(); 143 loop_.Run(); 152 loop_.Run(); 166 loop_.Run(); 181 loop_.Run(); 187 loop_.Run(); 246 loop_.WatchFileDescriptor(FROM_HERE, 261 &loop_, [all...] |
http_fetcher_unittest.cc | 382 brillo::BaseMessageLoop loop_{&base_loop_}; 388 loop_.SetAsCurrent(); 392 EXPECT_EQ(0, brillo::MessageLoopRunMaxIterations(&loop_, 1)); 468 this->loop_.PostTask(FROM_HERE, base::Bind( 472 this->loop_.Run(); 483 this->loop_.PostTask(FROM_HERE, base::Bind( 487 this->loop_.Run(); 506 this->loop_.PostTask(FROM_HERE, base::Bind( 510 this->loop_.Run(); 544 this->loop_.PostTask [all...] |
/system/update_engine/ |
update_attempter_unittest.cc | 125 loop_.SetAsCurrent(); 194 brillo::BaseMessageLoop loop_{&base_loop_}; 219 loop_.PostTask(FROM_HERE, base::Bind([this] { this->loop_.BreakLoop(); })); 418 loop_.PostTask(FROM_HERE, 438 loop_.BreakLoop(); 488 loop_.PostTask(FROM_HERE, 493 loop_.BreakLoop(); 513 loop_.BreakLoop(); 518 loop_.Run() [all...] |
chrome_browser_proxy_resolver_unittest.cc | 56 loop_.SetAsCurrent(); 65 EXPECT_TRUE(loop_.RunOnce(false)); 69 EXPECT_FALSE(loop_.PendingTasks()); 81 brillo::FakeMessageLoop loop_{nullptr};
|
p2p_manager_unittest.cc | 74 loop_.SetAsCurrent(); 92 brillo::BaseMessageLoop loop_{&base_loop_}; 480 loop_.Run(); 486 loop_.Run(); 492 loop_.Run(); 499 loop_.Run(); 505 loop_.Run(); 512 loop_.Run();
|
/system/update_engine/payload_consumer/ |
filesystem_verifier_action_unittest.cc | 51 loop_.SetAsCurrent(); 55 EXPECT_EQ(0, brillo::MessageLoopRunMaxIterations(&loop_, 1)); 63 brillo::FakeMessageLoop loop_{nullptr}; 210 loop_.PostTask(FROM_HERE, base::Bind(&StartProcessorInRunLoop, 214 loop_.Run(); 327 while (loop_.RunOnce(false)) {} 365 loop_.PostTask(FROM_HERE, 367 loop_.Run();
|
postinstall_runner_action_unittest.cc | 88 loop_.SetAsCurrent(); 124 loop_.PostDelayedTask( 132 loop_.PostDelayedTask( 143 loop_.PostDelayedTask( 156 brillo::BaseMessageLoop loop_{&base_loop_}; 203 loop_.PostTask(FROM_HERE, 205 loop_.Run(); 316 loop_.PostTask(FROM_HERE,
|
download_action_unittest.cc | 417 loop_.SetAsCurrent(); 422 EXPECT_FALSE(loop_.PendingTasks()); 479 loop_.PostTask(FROM_HERE, base::Bind( 482 loop_.Run(); 486 brillo::FakeMessageLoop loop_{nullptr};
|
/external/libchrome/base/message_loop/ |
message_loop.h | 332 : loop_(loop), 333 old_state_(loop_->NestableTasksAllowed()) { 334 loop_->SetNestableTasksAllowed(true); 337 loop_->SetNestableTasksAllowed(old_state_); 341 MessageLoop* loop_; member in class:base::MessageLoop::ScopedNestableTaskAllower
|
message_pump_glib_unittest.cc | 161 MessagePumpGLibTest() : loop_(NULL), injector_(NULL) { } 165 loop_ = new MessageLoop(MessageLoop::TYPE_UI); 171 delete loop_; 172 loop_ = NULL; 175 MessageLoop* loop() const { return loop_; } 179 MessageLoop* loop_; member in class:base::__anon15751::MessagePumpGLibTest
|