Searched refs:read_watcher_ (Results 1 – 3 of 3) sorted by relevance
288 DCHECK(!read_watcher_); in ~ChannelPosix()293 DCHECK(!read_watcher_); in StartOnIOThread()295 read_watcher_.reset( in StartOnIOThread()301 base::MessagePumpForIO::WATCH_READ, read_watcher_.get(), this); in StartOnIOThread()307 base::MessagePumpForIO::WATCH_READ, read_watcher_.get(), this); in StartOnIOThread()338 read_watcher_.reset(); in ShutDownOnIOThread()427 read_watcher_.reset(); in OnFileCanReadWithoutBlocking()478 read_watcher_.reset(); in OnFileCanReadWithoutBlocking()692 if (read_watcher_) { in OnWriteError()715 std::unique_ptr<base::MessagePumpForIO::FdWatchController> read_watcher_; member in mojo::core::__anonf6ee2ebb0111::ChannelPosix
87 MessageLoop::current()->CancelTask(read_watcher_); in WaitForData()88 read_watcher_ = MessageLoop::current()->WatchFileDescriptor( in WaitForData()95 if (read_watcher_ == MessageLoop::kTaskIdNull) { in WaitForData()158 if (read_watcher_ != MessageLoop::kTaskIdNull) { in CancelPendingAsyncOperations()159 MessageLoop::current()->CancelTask(read_watcher_); in CancelPendingAsyncOperations()160 read_watcher_ = MessageLoop::kTaskIdNull; in CancelPendingAsyncOperations()202 MessageLoop::TaskId read_watcher_{MessageLoop::kTaskIdNull}; member in brillo::FileDescriptor
69 read_watcher_ = base::FileDescriptorWatcher::WatchReadable( in StartWatching()84 read_watcher_.reset(); in StopWatching()94 std::unique_ptr<base::FileDescriptorWatcher::Controller> read_watcher_; member in dbus::__anonfab9559b0111::Watch