Lines Matching full:controller
80 ZxHandleWatchController* controller = in HandleSignal() local
82 DCHECK_EQ(controller->handler, &HandleSignal); in HandleSignal()
89 if (controller->weak_pump_ && controller->weak_pump_->run_state_) { in HandleSignal()
91 controller->weak_pump_->run_state_->delegate->BeginWorkItem(); in HandleSignal()
98 << controller->created_from_location_.ToString(); in HandleSignal()
102 controller->handler = nullptr; in HandleSignal()
106 // |controller| should not be accessed again, and we mustn't continue the in HandleSignal()
110 controller->was_stopped_ = &was_stopped; in HandleSignal()
112 controller->watcher_->OnZxHandleSignalled(wait->object, signal->observed); in HandleSignal()
117 controller->was_stopped_ = nullptr; in HandleSignal()
119 if (controller->persistent_) in HandleSignal()
120 controller->WaitBegin(); in HandleSignal()
194 FdWatchController* controller, in WatchFileDescriptor() argument
197 DCHECK(controller); in WatchFileDescriptor()
200 if (!controller->StopWatchingFileDescriptor()) in WatchFileDescriptor()
203 controller->fd_ = fd; in WatchFileDescriptor()
204 controller->watcher_ = delegate; in WatchFileDescriptor()
206 DCHECK(!controller->io_); in WatchFileDescriptor()
207 controller->io_ = fdio_unsafe_fd_to_io(fd); in WatchFileDescriptor()
208 if (!controller->io_) { in WatchFileDescriptor()
215 controller->desired_events_ = FDIO_EVT_READABLE; in WatchFileDescriptor()
218 controller->desired_events_ = FDIO_EVT_WRITABLE; in WatchFileDescriptor()
221 controller->desired_events_ = FDIO_EVT_READABLE | FDIO_EVT_WRITABLE; in WatchFileDescriptor()
231 return WatchZxHandle(ZX_HANDLE_INVALID, persistent, 1, controller, in WatchFileDescriptor()
232 controller); in WatchFileDescriptor()
238 ZxHandleWatchController* controller, in WatchZxHandle() argument
241 DCHECK(controller); in WatchZxHandle()
244 // If the watch controller is active then WatchZxHandle() can be called only in WatchZxHandle()
246 DCHECK(handle == ZX_HANDLE_INVALID || !controller->is_active() || in WatchZxHandle()
247 handle == controller->async_wait_t::object); in WatchZxHandle()
249 if (!controller->StopWatchingZxHandle()) in WatchZxHandle()
252 controller->async_wait_t::object = handle; in WatchZxHandle()
253 controller->persistent_ = persistent; in WatchZxHandle()
254 controller->async_wait_t::trigger = signals; in WatchZxHandle()
255 controller->watcher_ = delegate; in WatchZxHandle()
257 controller->weak_pump_ = weak_factory_.GetWeakPtr(); in WatchZxHandle()
259 return controller->WaitBegin(); in WatchZxHandle()