Searched refs:write_watcher_ (Results 1 – 3 of 3) sorted by relevance
105 MessageLoop::current()->CancelTask(write_watcher_); in WaitForData()106 write_watcher_ = MessageLoop::current()->WatchFileDescriptor( in WaitForData()113 if (write_watcher_ == MessageLoop::kTaskIdNull) { in WaitForData()164 if (write_watcher_ != MessageLoop::kTaskIdNull) { in CancelPendingAsyncOperations()165 MessageLoop::current()->CancelTask(write_watcher_); in CancelPendingAsyncOperations()166 write_watcher_ = MessageLoop::kTaskIdNull; in CancelPendingAsyncOperations()203 MessageLoop::TaskId write_watcher_{MessageLoop::kTaskIdNull}; member in brillo::FileDescriptor
289 DCHECK(!write_watcher_); in ~ChannelPosix()294 DCHECK(!write_watcher_); in StartOnIOThread()303 write_watcher_.reset( in StartOnIOThread()321 if (!write_watcher_) in WaitForWriteOnIOThreadNoLock()327 base::MessagePumpForIO::WATCH_WRITE, write_watcher_.get(), this); in WaitForWriteOnIOThreadNoLock()339 write_watcher_.reset(); in ShutDownOnIOThread()693 write_watcher_.reset(); in OnWriteError()716 std::unique_ptr<base::MessagePumpForIO::FdWatchController> write_watcher_; member in mojo::core::__anonf6ee2ebb0111::ChannelPosix
75 write_watcher_ = base::FileDescriptorWatcher::WatchWritable( in StartWatching()85 write_watcher_.reset(); in StopWatching()95 std::unique_ptr<base::FileDescriptorWatcher::Controller> write_watcher_; member in dbus::__anonfab9559b0111::Watch