| /commonlibrary/rust/ylong_runtime/ylong_io/examples/ |
| H A D | ylong_io_tcp_server.rs | 42 if SERVER == event.token() { in main()
46 let token = Token(unique_token.0 + 1); in main()
48 poll.register(&mut stream, token, Interest::READABLE | Interest::WRITABLE)?; in main()
49 connections.insert(token, stream); in main()
51 match connections.get_mut(&event.token()) { in main()
59 poll.register(connection, event.token(), Interest::READABLE)?; in main()
65 poll.register(connection, event.token(), Interest::READABLE)?; in main()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/ |
| H A D | waker.rs | 51 pub(crate) fn new(selector: &Selector, token: Token) -> io::Result<WakerInner> {
59 .register(fd, token, Interest::READABLE)
86 token: Token,
90 pub(crate) fn new(selector: &Selector, token: Token) -> io::Result<WakerInner> {
92 selector.register_waker(token)?;
93 Ok(WakerInner { selector, token })
97 self.selector.wake(self.token)
|
| H A D | kqueue.rs | 75 pub fn register(&self, fd: RawFd, token: Token, interests: Interest) -> io::Result<()> { in register()
79 let kevent = kevent_new(fd, libc::EVFILT_READ, flags, token.0); in register()
84 let kevent = kevent_new(fd, libc::EVFILT_WRITE, flags, token.0); in register()
93 pub fn reregister(&self, fd: i32, token: Token, interests: Interest) -> io::Result<()> { in reregister()
107 events.push(kevent_new(fd, libc::EVFILT_READ, r_flags, token.0)); in reregister()
108 events.push(kevent_new(fd, libc::EVFILT_WRITE, w_flags, token.0)); in reregister()
137 pub fn register_waker(&self, token: Token) -> io::Result<()> { in register_waker()
142 token.0, in register_waker()
150 pub fn wake(&self, token: Token) -> io::Result<()> { in wake()
155 token in wake()
249 fn token(&self) -> Token { token() functions
[all...] |
| H A D | epoll.rs | 76 pub fn register(&self, fd: i32, token: Token, interests: Interest) -> io::Result<()> { in register()
79 u64: usize::from(token) as u64, in register()
89 pub fn reregister(&self, fd: i32, token: Token, interests: Interest) -> io::Result<()> { in reregister()
92 u64: usize::from(token) as u64, in reregister()
136 fn token(&self) -> Token { in token() functions
|
| H A D | source_fd.rs | 27 token: Token, in register()
30 selector.register(self.get_fd(), token, interests) in register()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/ |
| H A D | waker.rs | 22 token: Token,
28 pub(crate) fn new(selector: &Selector, token: Token) -> io::Result<WakerInner> {
30 token,
37 self.completion_port.post(self.token)
|
| H A D | net.rs | 48 token: Token, in register()
54 None => selector.register(socket, token, interests).map(|state| { in register()
87 net_inner.token,
101 token: Token,
109 token: Token,
115 token,
|
| H A D | events.rs | 31 pub(crate) fn new(token: Token) -> Event {
34 data: usize::from(token) as u64,
52 data: status.token() as u64,
144 fn token(&self) -> Token { in token() functions
|
| H A D | iocp.rs | 47 token: usize,
51 CreateIoCompletionPort(t.as_raw_handle() as HANDLE, self.handle.raw(), token, 0),
87 pub(crate) fn post(&self, token: Token) -> io::Result<()> {
88 let mut event = Event::new(token);
119 pub(crate) fn new(bytes: u32, token: usize, overlapped: *mut Overlapped) -> Self {
122 lpCompletionKey: token,
139 pub fn token(&self) -> usize { in token() functions
|
| H A D | selector.rs | 64 token: Token,
67 SelectorInner::register(&self.inner, socket, token, interests)
157 } else if iocp_event.token() % 2 == 1 { in feed_events()
208 token: Token,
216 sock_state.set_event(flags, token.0 as u64);
220 let net_internal = NetInner::new(this.clone(), token, interests, pin_sock_state.clone());
236 token: Token,
240 state.lock().unwrap().set_event(flags, token.0 as u64);
293 } else if iocp_event.token() % 2 == 1 { in release_events()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| H A D | driver.rs | 165 /// IO dispatch function. Wakes the task through the token getting from the
167 fn dispatch(&mut self, token: Token, ready: Ready) { in dispatch()
168 let addr_bit = Bit::from_usize(token.0); in dispatch()
183 .set_readiness(Some(token.0), Tick::Set(self.tick), |curr| curr | ready) in dispatch()
264 let token = event.token();
265 if token == WAKE_TOKEN {
269 if token == SIGNAL_TOKEN {
274 self.dispatch(token, ready);
324 let token in ffrt_dispatch_signal_event()
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
| H A D | uds_test.rs | 82 if SERVER == event.token() { in server()
84 let token = Token(unique_token.0 + 1); in server()
86 poll.register(&mut stream, token, Interest::READABLE | Interest::WRITABLE)?; in server()
87 connections.insert(token, stream); in server()
89 match connections.get_mut(&event.token()) { in server()
95 poll.register(connection, event.token(), Interest::READABLE)?; in server()
100 poll.register(connection, event.token(), Interest::READABLE)?; in server()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/ |
| H A D | lib.rs | 19 mod token; modules
20 pub use token::Token;
|
| H A D | poll.rs | 42 pub fn register<S>(&self, source: &mut S, token: Token, interests: Interest) -> io::Result<()> in register()
46 source.register(&self.selector, token, interests) in register()
|
| H A D | waker.rs | 27 pub fn new(poll: &Poll, token: Token) -> io::Result<Self> { in new()
28 WakerInner::new(poll.selector(), token).map(|inner| Waker { inner }) in new()
|
| H A D | source.rs | 34 token: Token, in register()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h2/ |
| H A D | decoder.rs | 838 fn get_stream_id(token: &[u8]) -> StreamId { in get_stream_id()
839 (((token[0] & 0x7f) as u32) << 24) in get_stream_id()
840 | ((token[1] as u32) << 16) in get_stream_id()
841 | ((token[2] as u32) << 8) in get_stream_id()
842 | (token[3] as u32) in get_stream_id()
845 fn get_code_value(token: &[u8]) -> u32 { in get_code_value()
846 ((token[0] as u32) << 24) in get_code_value()
847 | ((token[1] as u32) << 16) in get_code_value()
848 | ((token[2] as u32) << 8) in get_code_value()
849 | (token[ in get_code_value()
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/ |
| H A D | listener.rs | 148 token: Token, in register()
152 .register(selector, token, interests, self.as_raw_socket()) in register()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/ |
| H A D | events.rs | 19 fn token(&self) -> Token; in token() functions
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/udp/ |
| H A D | udp_socket.rs | 760 token: Token, in register()
763 selector.register(self.get_fd(), token, interests) in register()
779 token: Token, in register()
782 selector.register(self.get_fd(), token, interests) in register()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/udp/ |
| H A D | udp_socket.rs | 640 token: Token, in register()
644 .register(selector, token, interests, self.get_fd()) in register()
660 token: Token, in register()
664 .register(selector, token, interests, self.get_fd()) in register()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/ |
| H A D | datagram.rs | 266 token: Token, in register()
269 selector.register(self.inner.as_raw_fd(), token, interests) in register()
|
| H A D | listener.rs | 169 token: Token, in register()
172 selector.register(self.inner.as_raw_fd(), token, interests) in register()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/ |
| H A D | listener.rs | 179 token: Token, in register()
182 selector.register(self.get_fd(), token, interests) in register()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | driver_handle.rs | 107 token: Token,
110 self.io.register_source_with_token(io, token, interest)
|