| /external/libbrillo/brillo/ |
| binder_watcher.cc | 37 : message_loop_(message_loop) {}
39 BinderWatcher::BinderWatcher() : message_loop_(nullptr) {}
43 message_loop_->CancelTask(task_id_);
47 if (!message_loop_)
48 message_loop_ = MessageLoop::current();
49 if (!message_loop_) {
69 task_id_ = message_loop_->WatchFileDescriptor(
|
| binder_watcher.h | 40 MessageLoop* message_loop_; member in class:brillo::final
|
| /external/libchrome/base/synchronization/ |
| waitable_event_watcher_posix.cc | 65 : message_loop_(message_loop),
72 message_loop_->task_runner()->PostTask(FROM_HERE, callback_);
88 MessageLoop *const message_loop_; member in class:base::AsyncWaiter
111 : message_loop_(NULL),
136 if (message_loop_) {
137 message_loop_->RemoveDestructionObserver(this);
138 message_loop_ = NULL;
166 message_loop_ = current_ml;
179 if (message_loop_) {
180 message_loop_->RemoveDestructionObserver(this)
[all...] |
| waitable_event_watcher.h | 101 MessageLoop* message_loop_; member in class:base::WaitableEventWatcher
|
| /system/bt/stack/btu/ |
| btu_task.cc | 48 static base::MessageLoop* message_loop_ = NULL; variable
86 base::MessageLoop* get_message_loop() { return message_loop_; }
89 message_loop_ = new base::MessageLoop();
93 message_loop_->task_runner()->PostTask(
99 delete message_loop_;
100 message_loop_ = NULL;
138 if (run_loop_ && message_loop_) {
139 message_loop_->task_runner()->PostTask(FROM_HERE, run_loop_->QuitClosure());
|
| /external/libchrome/base/threading/ |
| thread.cc | 71 message_loop_(nullptr),
92 DCHECK(!message_loop_);
111 message_loop_ = message_loop.get();
121 message_loop_ = nullptr;
130 DCHECK(message_loop_);
143 if (!message_loop_)
159 // TODO(darin): Unfortunately, we need to keep message_loop_ around until
165 // The thread should nullify message_loop_ on exit.
166 DCHECK(!message_loop_);
176 if (stopping_ || !message_loop_)
[all...] |
| thread.h | 94 DCHECK(!message_loop_);
161 MessageLoop* message_loop() const { return message_loop_; }
169 return message_loop_ ? message_loop_->task_runner() : nullptr;
203 message_loop_ = message_loop;
224 // |message_loop_|. It may non-nullptr and invalid.
243 MessageLoop* message_loop_; member in class:base::Thread
|
| /external/libchrome/base/message_loop/ |
| incoming_task_queue.cc | 54 message_loop_(message_loop),
57 always_schedule_work_(AlwaysNotifyPump(message_loop_->type())),
118 message_loop_ = NULL;
131 DCHECK(message_loop_);
134 message_loop_->ScheduleWork();
140 DCHECK(!message_loop_);
148 // Ensures |message_loop_| isn't destroyed while running.
151 if (!message_loop_) {
170 message_loop_->task_annotator()->DidQueueTask("MessageLoop::PostTask",
194 message_loop_->ScheduleWork()
[all...] |
| incoming_task_queue.h | 80 // |message_loop_|.
83 // Lock that protects |message_loop_| to prevent it from being deleted while a
89 // |message_loop_|.
93 MessageLoop* message_loop_; member in class:base::internal::IncomingTaskQueue
|
| /external/libmojo/base/android/ |
| java_handler_thread.h | 31 base::MessageLoop* message_loop() const { return message_loop_.get(); }
47 std::unique_ptr<base::MessageLoop> message_loop_; member in class:base::android::JavaHandlerThread
|
| java_handler_thread.cc | 32 DCHECK(!message_loop_);
65 message_loop_.reset(new base::MessageLoop(base::MessageLoop::TYPE_JAVA));
66 static_cast<MessageLoopForUI*>(message_loop_.get())->Start();
73 static_cast<MessageLoopForUI*>(message_loop_.get())->QuitWhenIdle();
|
| /external/libbrillo/brillo/daemons/ |
| daemon.cc | 18 message_loop_.SetAsCurrent();
29 message_loop_.Run();
38 while (message_loop_.RunOnce(false /* may_block */)) {}
47 message_loop_.PostTask(FROM_HERE, QuitClosure());
|
| daemon.h | 89 return message_loop_.QuitClosure();
99 // other members, especially the |message_loop_|.
102 BaseMessageLoop message_loop_; member in class:brillo::Daemon
|
| /system/bt/service/ |
| daemon.cc | 47 void StartMainLoop() override { message_loop_->Run(); }
52 return message_loop_.get();
120 message_loop_.reset(new base::MessageLoop());
148 std::unique_ptr<base::MessageLoop> message_loop_; member in class:bluetooth::__anon113504::DaemonImpl
|
| /external/libchrome/components/timers/ |
| alarm_timer_chromeos.cc | 52 : message_loop_(message_loop),
54 DCHECK(message_loop_);
55 message_loop_->AddDestructionObserver(this);
59 // If |message_loop_| was destroyed, then this class will have already
61 if (message_loop_)
62 message_loop_->RemoveDestructionObserver(this);
67 message_loop_->RemoveDestructionObserver(this);
68 message_loop_ = NULL;
75 base::MessageLoop* message_loop_; member in class:timers::AlarmTimer::MessageLoopObserver
77 // The callback to run when |message_loop_| will be destroyed
[all...] |
| /system/tpm/trunks/ |
| background_command_transceiver_test.cc | 75 base::MessageLoopForIO message_loop_; member in class:trunks::BackgroundTransceiverTest
98 message_loop_.PostTask(FROM_HERE,
|
| /system/bt/hci/src/ |
| hci_layer.cc | 95 static base::MessageLoop* message_loop_ = nullptr; variable
139 message_loop_->task_runner()->PostTask(
169 message_loop_ = new base::MessageLoop();
173 message_loop_->task_runner()->PostTask(FROM_HERE,
179 delete message_loop_;
180 message_loop_ = nullptr;
266 message_loop_->task_runner()->PostTask(FROM_HERE, run_loop_->QuitClosure());
383 if (message_loop_ == nullptr) {
389 message_loop_->task_runner()->PostTask(FROM_HERE, std::move(callback));
410 if (message_loop_ == nullptr)
[all...] |
| /system/bt/service/test/ |
| ipc_linux_unittest.cc | 55 .WillByDefault(Return(&message_loop_));
103 base::MessageLoop message_loop_; member in class:__anon113529::IPCLinuxTest
170 message_loop_.Run();
180 message_loop_.Run();
191 message_loop_.Run();
|
| /system/bt/osi/test/ |
| alarm_test.cc | 42 base::MessageLoop* message_loop_; variable
47 message_loop_ = new base::MessageLoop();
53 delete message_loop_;
54 message_loop_ = nullptr;
60 base::MessageLoop* get_message_loop() { return message_loop_; }
350 message_loop_->PostTask(FROM_HERE, run_loop_->QuitWhenIdleClosure());
|
| /external/libmojo/mojo/public/cpp/system/tests/ |
| watcher_unittest.cc | 39 message_loop_.reset(new base::MessageLoop);
43 message_loop_.reset();
47 std::unique_ptr<base::MessageLoop> message_loop_; member in class:mojo::WatcherTest
179 message_loop_.reset();
|
| /system/bt/btif/src/ |
| btif_core.cc | 129 base::MessageLoop* message_loop_ = NULL; variable
222 if (!message_loop_ || !message_loop_->task_runner().get()) {
228 if (message_loop_->task_runner()->PostTask(from_here, task))
325 message_loop_ = new base::MessageLoop(base::MessageLoop::Type::TYPE_DEFAULT);
328 message_loop_->task_runner()->PostTask(FROM_HERE,
334 delete message_loop_;
335 message_loop_ = NULL;
518 if (jni_run_loop && message_loop_) {
519 message_loop_->task_runner()->PostTask(FROM_HERE
[all...] |
| /external/libmojo/mojo/public/cpp/bindings/tests/ |
| e2e_perftest.cc | 135 base::MessageLoop message_loop_; member in class:mojo::__anon23748::MojoE2EPerftest
180 message_loop_.task_runner(), FROM_HERE,
190 RunTestOnTaskRunner(message_loop_.task_runner().get(), client_mp,
|
| /external/libmojo/mojo/message_pump/ |
| handle_watcher_perftest.cc | 72 HandleWatcherPerftest() : message_loop_(CreateMessageLoop(GetParam())) {}
81 std::unique_ptr<base::MessageLoop> message_loop_; member in class:mojo::common::test::HandleWatcherPerftest
|
| handle_watcher_unittest.cc | 127 message_loop_(CreateMessageLoop(GetParam())) {}
138 message_loop_.reset();
151 std::unique_ptr<base::MessageLoop> message_loop_; member in class:mojo::common::test::HandleWatcherTest
|
| /external/libchrome/base/ |
| sequence_checker_unittest.cc | 115 MessageLoop message_loop_; // Needed by SequencedWorkerPool to function. member in class:base::__anon22811::SequenceCheckerTest
|
