Searched refs:update_queue (Results 1 – 1 of 1) sorted by relevance
80 update_queue: Mutex<VecDeque<Pin<Arc<Mutex<SockState>>>>>, field96 update_queue: Mutex::new(VecDeque::new()), in new()151 let mut update_queue = self.update_queue.lock().unwrap(); in feed_events() localVariable177 update_queue.push_back(sock_state.clone()); in feed_events()188 let mut update_queue = self.update_queue.lock().unwrap(); in update_sockets_events() localVariable189 for sock in update_queue.iter_mut() { in update_sockets_events()196 update_queue.retain(|sock| sock.lock().unwrap().has_error()); in update_sockets_events()254 let mut update_queue = self.update_queue.lock().unwrap(); in queue_state() localVariable255 update_queue.push_back(sock_state); in queue_state()