/external/libchrome/base/test/ |
test_io_thread.h | 44 base::MessageLoopForIO* message_loop() { 45 return static_cast<base::MessageLoopForIO*>(io_thread_.message_loop());
|
/external/libchrome/base/files/ |
file_descriptor_watcher_posix.cc | 21 // MessageLoopForIO used to watch file descriptors for which callbacks are 23 LazyInstance<ThreadLocalPointer<MessageLoopForIO>>::Leaky 31 // Delete |watcher_| on the MessageLoopForIO. 33 // If the MessageLoopForIO is deleted before Watcher::StartWatching() runs, 34 // |watcher_| is leaked. If the MessageLoopForIO is deleted after 44 : public MessageLoopForIO::Watcher, 47 Watcher(WeakPtr<Controller> controller, MessageLoopForIO::Mode mode, int fd); 55 // MessageLoopForIO::Watcher: 62 // Used to instruct the MessageLoopForIO to stop watching the file descriptor. 63 MessageLoopForIO::FileDescriptorWatcher file_descriptor_watcher_ [all...] |
file_descriptor_watcher_posix.h | 40 Controller(MessageLoopForIO::Mode mode, int fd, const Closure& callback); 52 // TaskRunner associated with the MessageLoopForIO that watches the file 57 // Notified by the MessageLoopForIO associated with 62 // task posted to the MessageLoopForIO. This ensures that |watcher_| isn't 63 // deleted while it is being used by the MessageLoopForIO. 79 FileDescriptorWatcher(MessageLoopForIO* message_loop_for_io);
|
file_descriptor_watcher_posix_unittest.cc | 52 ? new MessageLoopForIO 73 static_cast<MessageLoopForIO*>(message_loop_for_io)); 146 // Thread running a MessageLoopForIO. Used when the test type is 151 // Determines which MessageLoopForIO is used to watch file descriptors for 294 // Delete the MessageLoopForIO. 303 // posted to the MessageLoopForIO thread.
|
/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/libmojo/mojo/edk/system/ |
channel_posix.cc | 88 public base::MessageLoopForIO::Watcher { 215 new base::MessageLoopForIO::FileDescriptorWatcher(FROM_HERE)); 218 base::MessageLoopForIO::current()->WatchFileDescriptor( 220 base::MessageLoopForIO::WATCH_READ, read_watcher_.get(), this); 223 new base::MessageLoopForIO::FileDescriptorWatcher(FROM_HERE)); 224 base::MessageLoopForIO::current()->WatchFileDescriptor( 226 base::MessageLoopForIO::WATCH_READ, read_watcher_.get(), this); 244 base::MessageLoopForIO::current()->WatchFileDescriptor( 246 base::MessageLoopForIO::WATCH_WRITE, write_watcher_.get(), this); 276 // base::MessageLoopForIO::Watcher [all...] |
channel_win.cc | 74 public base::MessageLoopForIO::IOHandler { 153 base::MessageLoopForIO::current()->RegisterIOHandler( 216 void OnIOCompleted(base::MessageLoopForIO::IOContext* context, 329 base::MessageLoopForIO::IOContext connect_context_; 330 base::MessageLoopForIO::IOContext read_context_; 331 base::MessageLoopForIO::IOContext write_context_;
|
/external/libchrome/base/message_loop/ |
message_loop.h | 98 // MessageLoopForIO. 554 // MessageLoopForIO extends MessageLoop with methods that are particular to a 558 // MessageLoopForIO::current()->...call some method... 560 class BASE_EXPORT MessageLoopForIO : public MessageLoop { 562 MessageLoopForIO() : MessageLoop(TYPE_IO) { 565 // Returns the MessageLoopForIO of the current thread. 566 static MessageLoopForIO* current() { 568 DCHECK(loop) << "Can't call MessageLoopForIO::current() when no message " 570 " MessageLoop::current() or MessageLoopForIO::IsCurrent()."; 572 return static_cast<MessageLoopForIO*>(loop) [all...] |
message_loop_unittest.cc | 481 class TestIOHandler : public MessageLoopForIO::IOHandler { 485 void OnIOCompleted(MessageLoopForIO::IOContext* context, 496 MessageLoopForIO::IOContext context_; 512 MessageLoopForIO::current()->RegisterIOHandler(file_.Get(), this); 521 void TestIOHandler::OnIOCompleted(MessageLoopForIO::IOContext* context, 528 EXPECT_TRUE(MessageLoopForIO::current()->WaitForIOCompletion(300, this)); 529 EXPECT_TRUE(MessageLoopForIO::current()->WaitForIOCompletion(400, this)); 732 class QuitDelegate : public MessageLoopForIO::Watcher { 755 MessageLoopForIO::FileDescriptorWatcher controller(FROM_HERE); 757 MessageLoopForIO message_loop [all...] |
message_loop.cc | 642 // MessageLoopForIO 647 void MessageLoopForIO::RegisterIOHandler(HANDLE file, IOHandler* handler) { 651 bool MessageLoopForIO::RegisterJobObject(HANDLE job, IOHandler* handler) { 655 bool MessageLoopForIO::WaitForIOCompletion(DWORD timeout, IOHandler* filter) { 659 bool MessageLoopForIO::WatchFileDescriptor(int fd,
|
/external/libbrillo/brillo/http/ |
http_transport_curl.cc | 34 class Transport::SocketPollData : public base::MessageLoopForIO::Watcher { 47 base::MessageLoopForIO::FileDescriptorWatcher* GetWatcher() { 52 // Overrides from base::MessageLoopForIO::Watcher. 83 base::MessageLoopForIO::FileDescriptorWatcher file_descriptor_watcher_; 207 base::MessageLoopForIO::current()->task_runner()->PostTask( 357 base::MessageLoopForIO::current()->task_runner()-> 362 base::MessageLoopForIO::Mode watch_mode = base::MessageLoopForIO::WATCH_READ; 365 watch_mode = base::MessageLoopForIO::WATCH_READ; 368 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/libchrome/base/threading/ |
thread.cc | 303 // Allow threads running a MessageLoopForIO to use FileDescriptorWatcher API. 305 if (MessageLoopForIO::IsCurrent()) { 306 DCHECK_EQ(message_loop_, MessageLoopForIO::current()); 308 new FileDescriptorWatcher(MessageLoopForIO::current()));
|
/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 | 64 base::MessageLoopForIO::Mode mode = base::MessageLoopForIO::WATCH_READ; 66 mode = base::MessageLoopForIO::WATCH_READ_WRITE; 68 mode = base::MessageLoopForIO::WATCH_READ; 70 mode = base::MessageLoopForIO::WATCH_WRITE; 75 const bool success = base::MessageLoopForIO::current()->WatchFileDescriptor( [all...] |
/system/update_engine/client_library/ |
client_dbus.cc | 195 if (!base::MessageLoopForIO::current()) {
|
/system/update_engine/common/ |
subprocess_unittest.cc | 72 base::MessageLoopForIO base_loop_;
|
/system/update_engine/payload_consumer/ |
postinstall_runner_action_unittest.cc | 145 base::MessageLoopForIO base_loop_;
|
/system/update_engine/ |
p2p_manager_unittest.cc | 91 base::MessageLoopForIO base_loop_;
|