Searched refs:update_queue (Results 1 – 1 of 1) sorted by relevance
92 update_queue: Mutex<VecDeque<Pin<Arc<Mutex<SockState>>>>>, field108 update_queue: Mutex::new(VecDeque::new()), in new()162 let mut update_queue = self.update_queue.lock().unwrap(); in feed_events() localVariable188 update_queue.push_back(sock_state.clone()); in feed_events()199 let mut update_queue = self.update_queue.lock().unwrap(); in update_sockets_events() localVariable200 for sock in update_queue.iter_mut() { in update_sockets_events()207 update_queue.retain(|sock| sock.lock().unwrap().has_error()); in update_sockets_events()265 let mut update_queue = self.update_queue.lock().unwrap(); in queue_state() localVariable266 update_queue.push_back(sock_state); in queue_state()