| /external/libchrome/base/synchronization/ |
| waitable_event_watcher_posix.cc | 20 // That AsyncWaiter has a pointer to MessageLoop, and a Task to be posted to it.
21 // The MessageLoop ends up running the task, which calls the delegate.
26 // the MessageLoop which runs the Task, we are assured that the delegate cannot
57 // This is an asynchronous waiter which posts a task to a MessageLoop when
62 AsyncWaiter(MessageLoop* message_loop,
88 MessageLoop *const message_loop_;
94 // For async waits we need to make a callback in a MessageLoop thread. We do
101 // Runs in MessageLoop thread.
128 MessageLoop *const current_ml = MessageLoop::current()
[all...] |
| /system/media/brillo/audio/audioservice/ |
| audio_daemon.cpp | 46 MessageLoop* message_loop = MessageLoop::current();
54 message_loop->WatchFileDescriptor(fd, MessageLoop::kWatchRead,
70 brillo::MessageLoop::current()->PostDelayedTask(
|
| /external/libchrome/base/ |
| run_loop.cc | 18 : loop_(MessageLoop::current()),
33 : loop_(MessageLoop::current()),
|
| observer_list_unittest.cc | 110 loop_ = new MessageLoop(); // Fire up a message loop.
118 loop_ = reinterpret_cast<MessageLoop*>(0xdeadbeef);
148 MessageLoop::QuitWhenIdleClosure());
159 EXPECT_EQ(loop_, MessageLoop::current());
167 MessageLoop* loop_;
209 MessageLoop loop;
239 MessageLoop loop;
276 // No MessageLoop, so these should not be added.
282 MessageLoop loop;
311 MessageLoop loop
[all...] |
| /external/libchrome/components/timers/ |
| alarm_timer_chromeos.h | 16 class MessageLoop;
35 // pending in the MessageLoop.
80 base::MessageLoop* origin_message_loop_;
|
| /system/update_engine/payload_consumer/ |
| postinstall_runner_action.cc | 50 using brillo::MessageLoop;
200 progress_task_ = MessageLoop::current()->WatchFileDescriptor(
203 MessageLoop::WatchMode::kWatchRead,
231 MessageLoop::current()->CancelTask(progress_task_);
232 progress_task_ = MessageLoop::kTaskIdNull;
275 if (progress_task_ != MessageLoop::kTaskIdNull) {
276 MessageLoop::current()->CancelTask(progress_task_);
277 progress_task_ = MessageLoop::kTaskIdNull;
|
| postinstall_runner_action.h | 144 brillo::MessageLoop::TaskId progress_task_{brillo::MessageLoop::kTaskIdNull};
|
| /system/webservd/libwebserv/ |
| binder_server.h | 43 BinderServer(brillo::MessageLoop* message_loop,
71 brillo::MessageLoop* message_loop_;
|
| server.cc | 45 brillo::MessageLoop* message_loop,
|
| /system/update_engine/ |
| chrome_browser_proxy_resolver_unittest.cc | 36 using brillo::MessageLoop;
115 MessageLoop::current()->BreakLoop();
121 MessageLoop::current()->BreakLoop();
144 MessageLoop::current()->PostDelayedTask(
155 MessageLoop::current()->Run();
|
| real_system_state.cc | 36 using brillo::MessageLoop;
175 MessageLoop::current()->PostDelayedTask(
183 MessageLoop::current()->PostTask(FROM_HERE, base::Bind(
188 MessageLoop::current()->PostTask(FROM_HERE, base::Bind(
|
| /system/update_engine/update_manager/ |
| real_device_policy_provider.cc | 31 using brillo::MessageLoop;
45 MessageLoop::current()->CancelTask(scheduled_refresh_);
72 MessageLoop::current()->CancelTask(scheduled_refresh_);
73 scheduled_refresh_ = MessageLoop::kTaskIdNull;
93 scheduled_refresh_ = MessageLoop::current()->PostDelayedTask(
|
| variable_unittest.cc | 27 using brillo::MessageLoop;
118 MessageLoopRunMaxIterations(MessageLoop::current(), 100);
127 MessageLoopRunMaxIterations(MessageLoop::current(), 100);
176 MessageLoopRunMaxIterations(MessageLoop::current(), 100);
|
| evaluation_context_unittest.cc | 37 using brillo::MessageLoop;
221 MessageLoopRunMaxIterations(MessageLoop::current(), 100);
228 MessageLoopRunMaxIterations(MessageLoop::current(), 100);
243 MessageLoopRunMaxIterations(MessageLoop::current(), 100);
255 MessageLoopRunMaxIterations(MessageLoop::current(), 10);
257 MessageLoopRunUntil(MessageLoop::current(),
272 MessageLoopRunMaxIterations(MessageLoop::current(), 10);
274 MessageLoopRunUntil(MessageLoop::current(),
299 MessageLoopRunMaxIterations(MessageLoop::current(), 100);
318 MessageLoopRunUntil(MessageLoop::current()
[all...] |
| /external/libbrillo/brillo/streams/ |
| file_stream.cc | 87 MessageLoop::current()->CancelTask(read_watcher_);
88 read_watcher_ = MessageLoop::current()->WatchFileDescriptor(
91 MessageLoop::WatchMode::kWatchRead,
95 if (read_watcher_ == MessageLoop::kTaskIdNull) {
105 MessageLoop::current()->CancelTask(write_watcher_);
106 write_watcher_ = MessageLoop::current()->WatchFileDescriptor(
109 MessageLoop::WatchMode::kWatchWrite,
113 if (write_watcher_ == MessageLoop::kTaskIdNull) {
158 if (read_watcher_ != MessageLoop::kTaskIdNull) {
159 MessageLoop::current()->CancelTask(read_watcher_)
[all...] |
| /external/libchrome/base/files/ |
| important_file_writer_unittest.cc | 96 MessageLoop loop_;
157 FROM_HERE, MessageLoop::QuitWhenIdleClosure(),
159 MessageLoop::current()->Run();
173 FROM_HERE, MessageLoop::QuitWhenIdleClosure(),
175 MessageLoop::current()->Run();
190 FROM_HERE, MessageLoop::QuitWhenIdleClosure(),
192 MessageLoop::current()->Run();
|
| /system/update_engine/common/ |
| subprocess.cc | 38 using brillo::MessageLoop;
129 MessageLoop::current()->CancelTask(record->stdout_task_id);
130 record->stdout_task_id = MessageLoop::kTaskIdNull;
145 MessageLoop::current()->CancelTask(record->stdout_task_id);
146 record->stdout_task_id = MessageLoop::kTaskIdNull;
200 record->stdout_task_id = MessageLoop::current()->WatchFileDescriptor(
203 MessageLoop::WatchMode::kWatchRead,
|
| libcurl_http_fetcher.h | 195 std::map<int, brillo::MessageLoop::TaskId> fd_task_maps_[2];
199 brillo::MessageLoop::TaskId timeout_id_{brillo::MessageLoop::kTaskIdNull};
|
| mock_http_fetcher.h | 50 timeout_id_(brillo::MessageLoop::kTaskIdNull),
137 brillo::MessageLoop::TaskId timeout_id_;
|
| subprocess.h | 123 brillo::MessageLoop::TaskId stdout_task_id{
124 brillo::MessageLoop::kTaskIdNull};
|
| /system/bt/service/ |
| daemon.cpp | 56 base::MessageLoop* GetMessageLoop() const override {
107 message_loop_.reset(new base::MessageLoop());
135 std::unique_ptr<base::MessageLoop> message_loop_;
|
| /external/libchrome/base/test/ |
| sequenced_worker_pool_owner.cc | 16 : constructor_message_loop_(MessageLoop::current()),
|
| test_io_thread.cc | 43 base::Thread::Options(base::MessageLoop::TYPE_IO, 0)));
|
| /system/connectivity/shill/ |
| shill_daemon.cc | 60 brillo::MessageLoop::current()->Run();
|
| /frameworks/base/core/java/android/speech/tts/ |
| AudioPlaybackHandler.java | 34 mHandlerThread = new Thread(new MessageLoop(), "TTS.AudioPlaybackThread");
114 * The MessageLoop is a handler like implementation that
117 private final class MessageLoop implements Runnable {
125 if (DBG) Log.d(TAG, "MessageLoop : Shutting down (interrupted)");
|
