Searched refs:is_pending (Results 1 – 6 of 6) sorted by relevance
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/ |
| H A D | try_join3.rs | 19 ($fut: expr, $is_pending: expr, $cx: expr) => {
21 Poll::Pending => $is_pending = true,
43 let mut is_pending = false; in try_join3() localVariable
46 poll_return_if_err!(fut1, is_pending, cx); in try_join3()
49 poll_return_if_err!(fut2, is_pending, cx); in try_join3()
52 poll_return_if_err!(fut3, is_pending, cx); in try_join3()
54 if is_pending { in try_join3()
171 if fut.as_mut().poll(cx).is_pending() { in ut_future_done_test()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| H A D | manager.rs | 67 if manager.poll_blocked_frames(cx).is_pending() { in poll()
77 if manager.poll_recv_message(cx, frame)?.is_pending() { in poll()
84 if manager.manage_resp_error(cx, e)?.is_pending() { in poll()
92 if manager.poll_recv_message(cx, frame)?.is_pending() { in poll()
98 if manager.manage_resp_error(cx, e)?.is_pending() { in poll()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | timer_test.rs | 107 if Pin::new(&mut sleep).poll(cx).is_pending() { in poll()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| H A D | timer.rs | 143 if Pin::new(&mut self.start).poll(cx).is_pending() { in poll_next_period()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/sys/unix/ |
| H A D | child.rs | 68 let signal_pending = self.signal.poll_recv(cx).is_pending(); in poll()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| H A D | addr.rs | 69 if poll.is_pending() { in poll()
|