| /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));
51 loop_->PostDelayedTask(Bind(callback, base::Unretained(&order), 1),
53 loop_->PostDelayedTask(Bind(callback, base::Unretained(&order), 4),
55 loop_->PostDelayedTask(Bind(callback, base::Unretained(&order), 3),
57 loop_->PostDelayedTask(Bind(callback, base::Unretained(&order), 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 | 317 : location_(location), loop_(loop), task_id_(task_id),
321 return loop_->base_loop_->WatchFileDescriptor(
355 bool base_scheduled = loop_->base_loop_->task_runner()->PostTask(
358 loop_->weak_ptr_factory_.GetWeakPtr(),
378 BaseMessageLoop* loop_ptr = loop_;
386 loop_->io_tasks_.erase(task_id_);
408 loop_->io_tasks_.erase(task_id_);
429 loop_->io_tasks_.erase(task_id_);
|
| glib_message_loop.h | 60 GMainLoop* loop_; member in class:brillo::GlibMessageLoop
|
| /external/libchrome/base/ |
| run_loop.cc | 14 : loop_(MessageLoop::current()),
35 loop_->RunHandler();
48 if (running_ && loop_->run_loop_ == this) {
50 loop_->QuitNow();
75 previous_run_loop_ = loop_->run_loop_;
77 loop_->run_loop_ = this;
80 loop_->NotifyBeginNestedLoop();
90 loop_->run_loop_ = previous_run_loop_;
94 loop_->QuitNow();
|
| run_loop.h | 92 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(
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::__anon22786::AddRemoveThread
[all...] |
| /system/update_engine/ |
| proxy_resolver_unittest.cc | 37 void SetUp() override { loop_.SetAsCurrent(); }
39 void TearDown() override { EXPECT_FALSE(loop_.PendingTasks()); }
41 brillo::FakeMessageLoop loop_{nullptr};
62 loop_.Run();
76 loop_.Run();
88 loop_.Run();
|
| update_attempter_unittest.cc | 124 loop_.SetAsCurrent();
187 brillo::BaseMessageLoop loop_{&base_loop_};
209 loop_.PostTask(
212 base::Unretained(&loop_)));
405 loop_.PostTask(FROM_HERE,
425 loop_.BreakLoop();
475 loop_.PostTask(FROM_HERE,
480 loop_.BreakLoop();
500 loop_.BreakLoop();
505 loop_.Run()
[all...] |
| 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();
523 loop_.Run();
|
| /system/update_engine/update_manager/ |
| real_device_policy_provider_unittest.cc | 61 loop_.SetAsCurrent();
87 EXPECT_FALSE(loop_.PendingTasks());
108 brillo::FakeMessageLoop loop_{nullptr};
123 loop_.RunOnce(false);
136 loop_.RunOnce(false);
149 loop_.RunOnce(false);
160 loop_.RunOnce(false);
173 loop_.RunOnce(false);
195 loop_.RunOnce(false);
232 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 | 69 loop_.SetAsCurrent();
83 EXPECT_FALSE(loop_.PendingTasks());
123 EXPECT_TRUE(loop_.RunOnce(false));
206 brillo::FakeMessageLoop loop_{nullptr};
300 EXPECT_TRUE(loop_.RunOnce(false));
512 EXPECT_TRUE(loop_.RunOnce(false));
524 EXPECT_TRUE(loop_.RunOnce(false));
|
| variable_unittest.cc | 57 loop_.SetAsCurrent();
60 brillo::FakeMessageLoop loop_{nullptr};
|
| /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();
183 loop_.Run();
189 loop_.Run();
259 loop_.WatchFileDescriptor(FROM_HERE,
274 &loop_,
[all...] |
| http_fetcher_unittest.cc | 380 brillo::BaseMessageLoop loop_{&base_loop_};
386 loop_.SetAsCurrent();
390 EXPECT_EQ(0, brillo::MessageLoopRunMaxIterations(&loop_, 1));
465 this->loop_.PostTask(FROM_HERE, base::Bind(
469 this->loop_.Run();
481 this->loop_.PostTask(FROM_HERE, base::Bind(
485 this->loop_.Run();
505 this->loop_.PostTask(FROM_HERE, base::Bind(
509 this->loop_.Run();
543 this->loop_.PostTask
[all...] |
| /system/update_engine/payload_consumer/ |
| postinstall_runner_action_unittest.cc | 88 loop_.SetAsCurrent();
117 loop_.PostDelayedTask(
125 loop_.PostDelayedTask(
136 loop_.PostDelayedTask(
149 brillo::BaseMessageLoop loop_{&base_loop_};
196 loop_.PostTask(
201 loop_.Run();
320 loop_.PostTask(FROM_HERE,
|
| filesystem_verifier_action_unittest.cc | 50 loop_.SetAsCurrent();
54 EXPECT_EQ(0, brillo::MessageLoopRunMaxIterations(&loop_, 1));
60 brillo::FakeMessageLoop loop_{nullptr};
185 loop_.PostTask(FROM_HERE, base::Bind(&StartProcessorInRunLoop,
189 loop_.Run();
299 while (loop_.RunOnce(false)) {}
|
| /external/libchrome/base/message_loop/ |
| message_loop.h | 337 : loop_(loop),
338 old_state_(loop_->NestableTasksAllowed()) {
339 loop_->SetNestableTasksAllowed(true);
342 loop_->SetNestableTasksAllowed(old_state_);
346 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::__anon22758::MessagePumpGLibTest
|
| /system/extras/simpleperf/ |
| event_selection_set.h | 70 : for_stat_cmd_(for_stat_cmd), mmap_pages_(0), loop_(new IOEventLoop) {}
109 return loop_.get();
164 std::unique_ptr<IOEventLoop> loop_; member in class:EventSelectionSet
|
| inplace_sampler_lib.cpp | 93 IOEventLoop loop_; member in class:__anon114436::SampleManager
101 return loop_.ExitLoop();
103 if (!conn_->PrepareForIO(loop_, read_callback, close_callback)) {
106 loop_.RunLoop();
194 return loop_.AddPeriodicEvent(tv, [&]() {
|
| event_selection_set.cpp | 533 if (!event_fd->StartPolling(*loop_, [this]() {
541 if (!sampler->StartPolling(*loop_, callback,
641 loop_.reset(new IOEventLoop);
645 return loop_->ExitLoop();
653 if (!sampler->StopProfiling(*loop_, close_callback)) {
669 if (!loop_->AddPeriodicEvent(tv, [&]() { return loop_->ExitLoop(); })) {
672 return loop_->RunLoop();
679 if (!loop_->AddPeriodicEvent(SecondToTimeval(check_interval_in_sec),
822 !fd_with_buffer->StartPolling(*loop_, [this]()
[all...] |
