Home
last modified time | relevance | path

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

/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/
H A Dnet.rs65 let mut sock_state = state.state.lock().unwrap(); in deregister() variables
66 sock_state.start_drop(); in deregister()
124 let mut sock_state = self.state.lock().unwrap(); in drop() variables
125 sock_state.start_drop(); in drop()
H A Dselector.rs168 let sock_state = from_overlapped(iocp_event.overlapped()); in feed_events()
169 let mut sock_guard = sock_state.lock().unwrap(); in feed_events()
177 update_queue.push_back(sock_state.clone()); in feed_events()
213 let mut sock_state = SockState::new(raw_socket, afd)?; variables
216 sock_state.set_event(flags, token.0 as u64);
218 let pin_sock_state = Arc::pin(Mutex::new(sock_state));
253 fn queue_state(&self, sock_state: Pin<Arc<Mutex<SockState>>>) { in queue_state()
255 update_queue.push_back(sock_state); in queue_state()
607 fn into_overlapped(sock_state: Pin<Arc<Mutex<SockState>>>) -> *mut c_void { in into_overlapped()
609 unsafe { Arc::into_raw(Pin::into_inner_unchecked(sock_state)) }; in into_overlapped()
[all...]

Completed in 2 milliseconds