Home
last modified time | relevance | path

Searched refs:MessageLoopForIO (Results 1 – 20 of 20) sorted by relevance

/external/libbrillo/brillo/message_loops/
Dbase_message_loop.h32 explicit BaseMessageLoop(base::MessageLoopForIO* base_loop);
91 class IOTask : public base::MessageLoopForIO::Watcher {
97 base::MessageLoopForIO::Mode base_mode,
129 base::MessageLoopForIO::Mode base_mode_;
133 base::MessageLoopForIO::FileDescriptorWatcher fd_watcher_;
165 base::MessageLoopForIO* base_loop_;
Dbase_message_loop.cc44 BaseMessageLoop::BaseMessageLoop(base::MessageLoopForIO* base_loop) in BaseMessageLoop()
103 base::MessageLoopForIO::Mode base_mode = base::MessageLoopForIO::WATCH_READ; in WatchFileDescriptor()
106 base_mode = base::MessageLoopForIO::WATCH_READ; in WatchFileDescriptor()
109 base_mode = base::MessageLoopForIO::WATCH_WRITE; in WatchFileDescriptor()
303 base::MessageLoopForIO::Mode base_mode, in IOTask()
353 << (base_mode_ == base::MessageLoopForIO::WATCH_READ ? in OnFileReady()
381 << (base_mode_ == base::MessageLoopForIO::WATCH_READ ? in OnFileReadyPostedTask()
Dmessage_loop_unittest.cc41 std::unique_ptr<base::MessageLoopForIO> base_loop_;
58 base_loop_.reset(new base::MessageLoopForIO()); in MessageLoopSetUp()
59 loop_.reset(new BaseMessageLoop(base::MessageLoopForIO::current())); in MessageLoopSetUp()
/external/libbrillo/brillo/http/
Dhttp_transport_curl.cc34 class Transport::SocketPollData : public base::MessageLoopForIO::Watcher {
46 base::MessageLoopForIO::FileDescriptorWatcher* GetWatcher() { in GetWatcher()
82 base::MessageLoopForIO::FileDescriptorWatcher file_descriptor_watcher_;
206 base::MessageLoopForIO::current()->PostTask(from_here, callback); in RunCallbackAsync()
355 base::MessageLoopForIO::current()->DeleteSoon(FROM_HERE, poll_data); in MultiSocketCallback()
359 base::MessageLoopForIO::Mode watch_mode = base::MessageLoopForIO::WATCH_READ; in MultiSocketCallback()
362 watch_mode = base::MessageLoopForIO::WATCH_READ; in MultiSocketCallback()
365 watch_mode = base::MessageLoopForIO::WATCH_WRITE; in MultiSocketCallback()
368 watch_mode = base::MessageLoopForIO::WATCH_READ_WRITE; in MultiSocketCallback()
384 CHECK(base::MessageLoopForIO::current()->WatchFileDescriptor( in MultiSocketCallback()
[all …]
Dhttp_transport_curl_unittest.cc193 base::MessageLoopForIO message_loop; in TEST_F()
/external/libchrome/components/timers/
Dalarm_timer_chromeos.cc95 public base::MessageLoopForIO::Watcher {
148 scoped_ptr<base::MessageLoopForIO::FileDescriptorWatcher> fd_watcher_;
209 if (base::MessageLoopForIO::IsCurrent()) { in Reset()
221 if (!base::MessageLoopForIO::IsCurrent()) { in Stop()
268 DCHECK(base::MessageLoopForIO::IsCurrent()); in ResetImpl()
277 fd_watcher_.reset(new base::MessageLoopForIO::FileDescriptorWatcher); in ResetImpl()
280 if (!base::MessageLoopForIO::current()->WatchFileDescriptor( in ResetImpl()
281 alarm_fd_, false, base::MessageLoopForIO::WATCH_READ, in ResetImpl()
/external/libchrome/base/message_loop/
Dmessage_loop.cc720 MessageLoopForIO::MessageLoopForIO() : MessageLoop(TYPE_IO) {} in MessageLoopForIO() function in base::MessageLoopForIO
723 void MessageLoopForIO::AddIOObserver( in AddIOObserver()
724 MessageLoopForIO::IOObserver* io_observer) { in AddIOObserver()
728 void MessageLoopForIO::RemoveIOObserver( in RemoveIOObserver()
729 MessageLoopForIO::IOObserver* io_observer) { in RemoveIOObserver()
734 void MessageLoopForIO::RegisterIOHandler(HANDLE file, IOHandler* handler) { in RegisterIOHandler()
738 bool MessageLoopForIO::RegisterJobObject(HANDLE job, IOHandler* handler) { in RegisterJobObject()
742 bool MessageLoopForIO::WaitForIOCompletion(DWORD timeout, IOHandler* filter) { in WaitForIOCompletion()
746 bool MessageLoopForIO::WatchFileDescriptor(int fd, in WatchFileDescriptor()
Dmessage_loop_unittest.cc493 class TestIOHandler : public MessageLoopForIO::IOHandler {
497 void OnIOCompleted(MessageLoopForIO::IOContext* context,
508 MessageLoopForIO::IOContext context_;
526 MessageLoopForIO::current()->RegisterIOHandler(file_.Get(), this); in Init()
535 void TestIOHandler::OnIOCompleted(MessageLoopForIO::IOContext* context, in OnIOCompleted()
542 EXPECT_TRUE(MessageLoopForIO::current()->WaitForIOCompletion(300, this)); in WaitForIO()
543 EXPECT_TRUE(MessageLoopForIO::current()->WaitForIOCompletion(400, this)); in WaitForIO()
762 class QuitDelegate : public MessageLoopForIO::Watcher {
785 MessageLoopForIO::FileDescriptorWatcher controller; in TEST()
787 MessageLoopForIO message_loop; in TEST()
[all …]
Dmessage_loop.h619 class BASE_EXPORT MessageLoopForIO : public MessageLoop {
621 MessageLoopForIO();
624 static MessageLoopForIO* current() { in current()
627 return static_cast<MessageLoopForIO*>(loop); in current()
687 static_assert(sizeof(MessageLoop) == sizeof(MessageLoopForIO),
/external/libchrome/base/files/
Dfile_path_watcher_kqueue.cc39 DCHECK(MessageLoopForIO::current()); in EventsForPath()
234 DCHECK(MessageLoopForIO::current()); in OnFileCanReadWithoutBlocking()
317 DCHECK(MessageLoopForIO::current()); in Watch()
356 return MessageLoopForIO::current()->WatchFileDescriptor( in Watch()
357 kqueue_, true, MessageLoopForIO::WATCH_READ, &kqueue_watcher_, this); in Watch()
375 DCHECK(MessageLoopForIO::current()); in CancelOnMessageLoopThread()
Dfile_path_watcher_kqueue.h31 public MessageLoopForIO::Watcher,
123 MessageLoopForIO::FileDescriptorWatcher kqueue_watcher_;
Dfile_path_watcher_linux.cc369 DCHECK(MessageLoopForIO::current()); in OnFilePathChanged()
454 DCHECK(MessageLoopForIO::current()); in Watch()
Dfile_path_watcher_fsevents.cc88 DCHECK(MessageLoopForIO::current()); in Watch()
/external/libchrome/base/test/
Dtest_io_thread.h42 base::MessageLoopForIO* message_loop() { in message_loop()
43 return static_cast<base::MessageLoopForIO*>(io_thread_.message_loop()); in message_loop()
/external/libbrillo/brillo/daemons/
Ddaemon.h102 base::MessageLoopForIO message_loop_;
/external/libchrome/dbus/
Dbus.cc58 base::MessageLoopForIO::Mode mode = base::MessageLoopForIO::WATCH_READ; in StartWatching()
60 mode = base::MessageLoopForIO::WATCH_READ_WRITE; in StartWatching()
62 mode = base::MessageLoopForIO::WATCH_READ; in StartWatching()
64 mode = base::MessageLoopForIO::WATCH_WRITE; in StartWatching()
69 const bool success = base::MessageLoopForIO::current()->WatchFileDescriptor( in StartWatching()
/external/libbrillo/brillo/
Dasynchronous_signal_handler_unittest.cc41 base::MessageLoopForIO base_loop_;
Dprocess_reaper_unittest.cc55 base::MessageLoopForIO base_loop_;
/external/libchrome/base/
Dbase_nacl.gyp92 # For MessageLoopForIO based on libevent.
/external/libbrillo/brillo/streams/
Dfile_stream_unittest.cc1032 base::MessageLoopForIO base_loop; in TEST_F()
1081 base::MessageLoopForIO base_loop; in TEST_F()