Lines Matching refs:MessageLoop
87 MessageLoop::current()->CancelTask(read_watcher_); in WaitForData()
88 read_watcher_ = MessageLoop::current()->WatchFileDescriptor( in WaitForData()
91 MessageLoop::WatchMode::kWatchRead, in WaitForData()
95 if (read_watcher_ == MessageLoop::kTaskIdNull) { in WaitForData()
105 MessageLoop::current()->CancelTask(write_watcher_); in WaitForData()
106 write_watcher_ = MessageLoop::current()->WatchFileDescriptor( in WaitForData()
109 MessageLoop::WatchMode::kWatchWrite, in WaitForData()
113 if (write_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()
164 if (write_watcher_ != MessageLoop::kTaskIdNull) { in CancelPendingAsyncOperations()
165 MessageLoop::current()->CancelTask(write_watcher_); in CancelPendingAsyncOperations()
166 write_watcher_ = MessageLoop::kTaskIdNull; in CancelPendingAsyncOperations()
202 MessageLoop::TaskId read_watcher_{MessageLoop::kTaskIdNull};
203 MessageLoop::TaskId write_watcher_{MessageLoop::kTaskIdNull};