Home
last modified time | relevance | path

Searched refs:update_queue (Results 1 - 1 of 1) sorted by relevance

/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/
H A Dselector.rs80 update_queue: Mutex<VecDeque<Pin<Arc<Mutex<SockState>>>>>,
96 update_queue: Mutex::new(VecDeque::new()), in new()
151 let mut update_queue = self.update_queue.lock().unwrap(); in feed_events() variables
177 update_queue.push_back(sock_state.clone()); in feed_events()
188 let mut update_queue = self.update_queue.lock().unwrap(); in update_sockets_events() variables
189 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 in queue_state() variables
[all...]

Completed in 2 milliseconds