| /external/libchrome/base/test/ |
| test_io_thread.h | 42 base::MessageLoopForIO* message_loop() {
43 return static_cast<base::MessageLoopForIO*>(io_thread_.message_loop());
|
| /external/libbrillo/brillo/message_loops/ |
| base_message_loop.h | 9 // base::MessageLoopForIO. This allows to mix new code using
10 // brillo::MessageLoop and legacy code using base::MessageLoopForIO in the
13 // since base::MessageLoopForIO doesn't provide a way to remove the event.
32 // Construct a base::MessageLoopForIO message loop instance and use it as
36 // Construct a brillo::BaseMessageLoop using the passed base::MessageLoopForIO
38 explicit BaseMessageLoop(base::MessageLoopForIO* base_loop);
72 // Called by base::MessageLoopForIO when is time to call the callback
95 class IOTask : public base::MessageLoopForIO::Watcher {
101 base::MessageLoopForIO::Mode base_mode,
133 base::MessageLoopForIO::Mode base_mode_
[all...] |
| base_message_loop.cc | 50 << "You can't create a base::MessageLoopForIO when another "
52 owned_base_loop_.reset(new base::MessageLoopForIO);
56 BaseMessageLoop::BaseMessageLoop(base::MessageLoopForIO* base_loop)
110 // base::MessageLoopForIO CHECKS that "fd >= 0", so we handle that case here.
114 base::MessageLoopForIO::Mode base_mode = base::MessageLoopForIO::WATCH_READ;
117 base_mode = base::MessageLoopForIO::WATCH_READ;
120 base_mode = base::MessageLoopForIO::WATCH_WRITE;
190 // delayed_tasks_ since we can't tell base::MessageLoopForIO to not run it.
198 base::RunLoop run_loop; // Uses the base::MessageLoopForIO implicitly
[all...] |
| message_loop_unittest.cc | 41 std::unique_ptr<base::MessageLoopForIO> base_loop_;
58 base_loop_.reset(new base::MessageLoopForIO());
59 loop_.reset(new BaseMessageLoop(base::MessageLoopForIO::current()));
|
| /external/libchrome/base/files/ |
| file_path_watcher_kqueue.h | 31 public MessageLoopForIO::Watcher,
36 // MessageLoopForIO::Watcher overrides.
123 MessageLoopForIO::FileDescriptorWatcher kqueue_watcher_;
|
| file_path_watcher_kqueue.cc | 39 DCHECK(MessageLoopForIO::current());
234 DCHECK(MessageLoopForIO::current());
317 DCHECK(MessageLoopForIO::current());
356 return MessageLoopForIO::current()->WatchFileDescriptor(
357 kqueue_, true, MessageLoopForIO::WATCH_READ, &kqueue_watcher_, this);
375 DCHECK(MessageLoopForIO::current());
|
| file_path_watcher_fsevents.cc | 82 DCHECK(MessageLoopForIO::current());
|
| file_path_watcher_linux.cc | 369 DCHECK(MessageLoopForIO::current());
454 DCHECK(MessageLoopForIO::current());
|
| /external/libchrome/components/timers/ |
| alarm_timer_chromeos.cc | 27 // a MessageLoopForIO. It is a lazy global instance because it may not always
89 // available on a MessageLoopForIO but there is no guarantee the timer is going
91 // with a MessageLoopForIO that posts tasks back to the thread that started the
95 public base::MessageLoopForIO::Watcher {
118 // base::MessageLoopForIO::Watcher overrides.
127 // called on a MessageLoopForIO.
148 std::unique_ptr<base::MessageLoopForIO::FileDescriptorWatcher> fd_watcher_;
151 // |origin_task_runner_| and on the MessageLoopForIO used for watching the
154 // it receives from the MessageLoopForIO matches
208 // Run ResetImpl() on a MessageLoopForIO
[all...] |
| /external/libmojo/mojo/edk/system/ |
| channel_win.cc | 73 public base::MessageLoopForIO::IOHandler {
152 base::MessageLoopForIO::current()->RegisterIOHandler(
215 void OnIOCompleted(base::MessageLoopForIO::IOContext* context,
328 base::MessageLoopForIO::IOContext connect_context_;
329 base::MessageLoopForIO::IOContext read_context_;
330 base::MessageLoopForIO::IOContext write_context_;
|
| channel_posix.cc | 88 public base::MessageLoopForIO::Watcher {
213 read_watcher_.reset(new base::MessageLoopForIO::FileDescriptorWatcher);
214 write_watcher_.reset(new base::MessageLoopForIO::FileDescriptorWatcher);
215 base::MessageLoopForIO::current()->WatchFileDescriptor(
217 base::MessageLoopForIO::WATCH_READ, read_watcher_.get(), this);
233 base::MessageLoopForIO::current()->WatchFileDescriptor(
235 base::MessageLoopForIO::WATCH_WRITE, write_watcher_.get(), this);
265 // base::MessageLoopForIO::Watcher:
488 std::unique_ptr<base::MessageLoopForIO::FileDescriptorWatcher> read_watcher_;
489 std::unique_ptr<base::MessageLoopForIO::FileDescriptorWatcher> write_watcher_
[all...] |
| /external/libchrome/base/message_loop/ |
| message_loop.h | 92 // MessageLoopForIO.
624 // MessageLoopForIO extends MessageLoop with methods that are particular to a
628 // MessageLoopForIO::current()->...call some method...
630 class BASE_EXPORT MessageLoopForIO : public MessageLoop {
632 MessageLoopForIO();
634 // Returns the MessageLoopForIO of the current thread.
635 static MessageLoopForIO* current() {
637 DCHECK(loop) << "Can't call MessageLoopForIO::current() when no message "
639 " MessageLoop::current() or MessageLoopForIO::IsCurrent().";
641 return static_cast<MessageLoopForIO*>(loop)
[all...] |
| message_loop_unittest.cc | 429 class TestIOHandler : public MessageLoopForIO::IOHandler {
433 void OnIOCompleted(MessageLoopForIO::IOContext* context,
444 MessageLoopForIO::IOContext context_;
460 MessageLoopForIO::current()->RegisterIOHandler(file_.Get(), this);
469 void TestIOHandler::OnIOCompleted(MessageLoopForIO::IOContext* context,
476 EXPECT_TRUE(MessageLoopForIO::current()->WaitForIOCompletion(300, this));
477 EXPECT_TRUE(MessageLoopForIO::current()->WaitForIOCompletion(400, this));
689 class QuitDelegate : public MessageLoopForIO::Watcher {
712 MessageLoopForIO::FileDescriptorWatcher controller;
714 MessageLoopForIO message_loop
[all...] |
| message_loop.cc | 743 // MessageLoopForIO
745 MessageLoopForIO::MessageLoopForIO() : MessageLoop(TYPE_IO) {}
750 void MessageLoopForIO::RegisterIOHandler(HANDLE file, IOHandler* handler) {
754 bool MessageLoopForIO::RegisterJobObject(HANDLE job, IOHandler* handler) {
758 bool MessageLoopForIO::WaitForIOCompletion(DWORD timeout, IOHandler* filter) {
762 bool MessageLoopForIO::WatchFileDescriptor(int fd,
|
| /external/libbrillo/brillo/http/ |
| http_transport_curl.cc | 34 class Transport::SocketPollData : public base::MessageLoopForIO::Watcher {
46 base::MessageLoopForIO::FileDescriptorWatcher* GetWatcher() {
51 // Overrides from base::MessageLoopForIO::Watcher.
82 base::MessageLoopForIO::FileDescriptorWatcher file_descriptor_watcher_;
206 base::MessageLoopForIO::current()->PostTask(from_here, callback);
355 base::MessageLoopForIO::current()->DeleteSoon(FROM_HERE, poll_data);
359 base::MessageLoopForIO::Mode watch_mode = base::MessageLoopForIO::WATCH_READ;
362 watch_mode = base::MessageLoopForIO::WATCH_READ;
365 watch_mode = base::MessageLoopForIO::WATCH_WRITE
[all...] |
| http_transport_curl_unittest.cc | 193 base::MessageLoopForIO message_loop;
|
| /frameworks/native/services/nativeperms/ |
| nativeperms.cpp | 78 base::MessageLoopForIO messageLoopForIo;
79 brillo::BaseMessageLoop messageLoop{&messageLoopForIo};
|
| /external/libyuv/files/tools/ubsan/ |
| vptr_blacklist.txt | 17 type:*base*MessageLoopForIO*
|
| /system/tpm/trunks/ |
| background_command_transceiver_test.cc | 75 base::MessageLoopForIO message_loop_;
|
| /external/libbrillo/brillo/ |
| asynchronous_signal_handler_unittest.cc | 41 base::MessageLoopForIO base_loop_;
|
| process_reaper_unittest.cc | 55 base::MessageLoopForIO base_loop_;
|
| /external/libchrome/dbus/ |
| bus.cc | 59 base::MessageLoopForIO::Mode mode = base::MessageLoopForIO::WATCH_READ;
61 mode = base::MessageLoopForIO::WATCH_READ_WRITE;
63 mode = base::MessageLoopForIO::WATCH_READ;
65 mode = base::MessageLoopForIO::WATCH_WRITE;
70 const bool success = base::MessageLoopForIO::current()->WatchFileDescriptor(
[all...] |
| /system/update_engine/client_library/ |
| client_dbus.cc | 193 if (!base::MessageLoopForIO::current()) {
|
| /system/update_engine/common/ |
| subprocess_unittest.cc | 73 base::MessageLoopForIO base_loop_;
|
| /system/update_engine/payload_consumer/ |
| postinstall_runner_action_unittest.cc | 148 base::MessageLoopForIO base_loop_;
|
