Searched refs:poll_ctx (Results 1 – 4 of 4) sorted by relevance
44 poll_ctx: Arc<EpollContext<Descriptor>>, field66 let poll_ctx: EpollContext<Descriptor> = EpollContext::new() in start() localVariable76 let poll_ctx = Arc::new(poll_ctx); in start() localVariable79 poll_ctx: poll_ctx.clone(), in start()93 let events = match poll_ctx.wait(&event_loop) { in start()129 let _ = poll_ctx.delete(&Descriptor(fd)); in start()163 self.poll_ctx in add_event()180 self.poll_ctx in remove_event_for_fd()
236 poll_ctx: EpollContext<usize>, field246 poll_ctx: EpollContext::new().map_err(Error::CreatingContext)?, in new()262 self.poll_ctx in add_operation()342 .poll_ctx in run()363 self.poll_ctx in run()397 .poll_ctx in cancel_operation()429 if let Err(e) = self.poll_ctx.delete(&data.file) { in drop()
121 let poll_ctx: PollContext<Token> = in read_audio_message_with_timeout() localVariable133 None => poll_ctx.wait(), in read_audio_message_with_timeout()134 Some(duration) => poll_ctx.wait_timeout(duration), in read_audio_message_with_timeout()
530 let poll_ctx: PollContext<Token> = in wait_for_message() localVariable533 let events = poll_ctx.wait()?; in wait_for_message()