| /commonlibrary/rust/ylong_runtime/ylong_io/examples/ |
| H A D | ylong_io_tcp_server.rs | 28 let poll = Poll::new()?; in main()
33 poll.register(&mut server, SERVER, Interest::READABLE)?; in main()
39 poll.poll(&mut events, None)?; in main()
48 poll.register(&mut stream, token, Interest::READABLE | Interest::WRITABLE)?; in main()
58 poll.deregister(connection)?; in main()
59 poll.register(connection, event.token(), Interest::READABLE)?; in main()
64 poll.deregister(connection)?; in main()
65 poll.register(connection, event.token(), Interest::READABLE)?; in main()
74 poll in main()
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
| H A D | uds_test.rs | 70 let poll = Poll::new()?; in server()
73 poll.register(&mut server, SERVER, Interest::READABLE)?; in server()
79 poll.poll(&mut events, None)?; in server()
86 poll.register(&mut stream, token, Interest::READABLE | Interest::WRITABLE)?; in server()
94 poll.deregister(connection)?; in server()
95 poll.register(connection, event.token(), Interest::READABLE)?; in server()
99 poll.deregister(connection)?; in server()
100 poll.register(connection, event.token(), Interest::READABLE)?; in server()
107 Ok(0) => poll in server()
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_io/src/ |
| 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()
48 let poll = Poll::new().unwrap(); in ut_waker_debug_info()
49 let waker = Waker::new(&poll, Token::from_usize(0)).unwrap(); in ut_waker_debug_info()
|
| H A D | lib.rs | 16 mod poll; modules
17 pub use poll::Poll;
|
| H A D | poll.rs | 37 pub fn poll(&self, events: &mut Events, timeout: Option<Duration>) -> io::Result<()> { in poll() functions
72 /// UT cases for debug info of poll in fmt()
81 let poll = Poll::new().unwrap(); in fmt()
82 let fmt = format!("{:?}", poll); in fmt()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| H A D | driver.rs | 61 poll: Arc<Poll>,
197 let poll =
199 let waker = ylong_io::Waker::new(&poll, WAKE_TOKEN)
201 let arc_poll = Arc::new(poll);
220 poll: arc_poll,
256 match self.poll.poll(&mut events, time_out) {
|
| /commonlibrary/memory_utils/libsync/src/ |
| H A D | sync.c | 17 #include <poll.h>
34 result = poll(&work, 1, time); in SyncWait()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| H A D | yield_now.rs | 45 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() functions
67 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() functions
|
| H A D | join_handle.rs | 102 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() functions
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| H A D | read_task.rs | 32 None => panic!("read: poll after finished"),
61 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() functions
115 let poll = Pin::new(&mut reader).poll_read(cx, &mut read_buf); in poll_read_to_end()
117 match poll { in poll_read_to_end()
139 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() functions
211 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() functions
246 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() functions
330 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() functions
366 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() functions
|
| H A D | write_task.rs | 26 None => panic!("write: poll after finished"),
58 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() functions
98 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() functions
140 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() functions
177 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() functions
202 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() functions
|
| H A D | stdin.rs | 74 let (res, mut buf_inner, std) = match Pin::new(join_handle).poll(cx)? { in poll_read()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/downloader/ |
| H A D | operator.rs | 109 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() functions
127 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() functions
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/ |
| H A D | try_join3.rs | 20 match $fut.as_mut().poll($cx) {
96 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() functions
100 FutureDone::Pending(fut) => match Pin::new_unchecked(fut).poll(cx) { in poll()
171 if fut.as_mut().poll(cx).is_pending() { in ut_future_done_test()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | sync.rs | 41 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() functions
|
| H A D | join_set.rs | 52 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() functions
69 /// 2. Spawn a future that returns pending during first poll and ready for
70 /// second poll.
|
| H A D | task_cancel.rs | 74 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() functions
|
| H A D | timer_test.rs | 101 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() functions
107 if Pin::new(&mut sleep).poll(cx).is_pending() {
121 /// `poll`
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/ |
| H A D | async_file.rs | 68 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() functions
73 let (file_buf, res) = poll_ready!(Pin::new(x).poll(cx))?;
79 let (file_buf, res) = poll_ready!(Pin::new(x).poll(cx))?;
503 let res = poll_ready!(Pin::new(state).poll(cx)); in poll_seek()
560 let (mut file_buf, res) = poll_ready!(Pin::new(x).poll(cx))?; in poll_read()
569 let (file_buf, res) = poll_ready!(Pin::new(x).poll(cx))?; in poll_read()
578 let (file_buf, res) = poll_ready!(Pin::new(x).poll(cx))?; in poll_read()
627 if let Poll::Ready(Err(e)) = Pin::new(state).poll(cx) { in poll_write()
662 let res = poll_ready!(Pin::new(state).poll(cx)); in poll_flush()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| H A D | timeout.rs | 43 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() functions
47 if let Poll::Ready(()) = delay.as_mut().poll(cx) {
51 match Pin::new(&mut this.future).poll(cx) {
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| H A D | timeout.rs | 72 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() functions
76 if let Poll::Ready(result) = value.poll(cx) {
81 match sleep.poll(cx) {
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/ |
| H A D | spawn.rs | 39 fn poll(mut self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() functions
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| H A D | semaphore_inner.rs | 233 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() functions
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/dns/ |
| H A D | resolver.rs | 81 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll() functions
82 Pin::new(&mut self.inner).poll(cx).map(|res| match res { in poll()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | block_on.rs | 105 if let Poll::Ready(res) = future.as_mut().poll(&mut cx) {
|