Lines Matching refs:afd_group
33 afd_group: Mutex<Vec<Arc<Afd>>>, field
39 afd_group: Mutex::new(Vec::new()), in new()
45 let mut afd_group = self.afd_group.lock().unwrap(); in release_unused_afd() localVariable
46 afd_group.retain(|g| Arc::strong_count(&g) > 1); in release_unused_afd()
55 let mut afd_group = self.afd_group.lock().unwrap(); localVariable
56 if afd_group.len() == 0 {
57 self._alloc_afd_group(&mut afd_group)?;
60 if Arc::strong_count(afd_group.last().unwrap()) >= POLL_GROUP__MAX_GROUP_SIZE + 1 {
61 self._alloc_afd_group(&mut afd_group)?;
65 match afd_group.last() {
69 self, afd_group
74 fn _alloc_afd_group(&self, afd_group: &mut Vec<Arc<Afd>>) -> io::Result<()> {
77 afd_group.push(arc);
417 afd_group: AfdGroup, field
433 afd_group: AfdGroup::new(cp_afd), in new()
492 self.afd_group.release_unused_afd(); in update_sockets_events()
533 self.afd_group.release_unused_afd(); in feed_events()
633 let afd = self.afd_group.acquire()?;
734 self.afd_group.release_unused_afd(); in drop()