Lines Matching refs:epitem

362                     let epitem = Arc::new(EPollItem::new(  in do_epoll_ctl()  localVariable
368 Self::ep_insert(&mut epoll_guard, dst_file, epitem)?; in do_epoll_ctl()
533 while let Some(epitem) = ep_guard.ready_list.pop_front() { in ep_send_events()
535 push_back.push(epitem); in ep_send_events()
538 let ep_events = EPollEventType::from_bits_truncate(epitem.event.read().events); in ep_send_events()
541 let revents = epitem.ep_item_poll(); in ep_send_events()
549 data: epitem.event.read().data, in ep_send_events()
578 let mut event_writer = epitem.event.write(); in ep_send_events()
582 push_back.push(epitem); in ep_send_events()
604 epitem: Arc<EPollItem>, in ep_insert()
617 epoll_guard.ep_items.insert(epitem.fd, epitem.clone()); in ep_insert()
620 let event = epitem.ep_item_poll(); in ep_insert()
623 epoll_guard.ep_add_ready(epitem.clone()); in ep_insert()
631 if epitem.event.read().events & EPollEventType::EPOLLWAKEUP.bits() != 0 { in ep_insert()
635 dst_file.add_epoll(epitem.clone())?; in ep_insert()
648 let epitem = epoll.ep_items.remove(&fd).unwrap(); in ep_remove() localVariable
652 .extract_if(|item| Arc::ptr_eq(item, &epitem)); in ep_remove()
665 epitem: Arc<EPollItem>, in ep_modify()
668 let mut epi_event_guard = epitem.event.write(); in ep_modify()
676 let event = epitem.ep_item_poll(); in ep_modify()
678 epoll_guard.ep_add_ready(epitem.clone()); in ep_modify()
693 pub fn ep_add_ready(&mut self, epitem: Arc<EPollItem>) { in ep_add_ready()
694 let ret = self.ready_list.iter().find(|epi| Arc::ptr_eq(epi, &epitem)); in ep_add_ready()
697 self.ready_list.push_back(epitem); in ep_add_ready()
723 if let Some(epitem) = epitems_guard.pop_front() { in wakeup_epoll()
725 if let Some(file) = epitem.file.upgrade() { in wakeup_epoll()
732 if let Some(epoll) = epitem.epoll().upgrade() { in wakeup_epoll()
734 let binding = epitem.clone(); in wakeup_epoll()
747 epoll_guard.ep_add_ready(epitem.clone()); in wakeup_epoll()
761 epitems_guard.push_back(epitem); in wakeup_epoll()