/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_;
|