Home
last modified time | relevance | path

Searched refs:Poll (Results 1 – 25 of 124) sorted by relevance

12345

/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/
H A Doutput.rs19 use std::task::{Context, Poll};
130 Poll::Ready(Err(e)) => return Poll::Ready(Err(e)), in poll_read_frame()
131 Poll::Pending => return Poll::Pending, in poll_read_frame()
158 Poll::Ready(Ok(())) in poll_blocked_task()
191 Poll::Ready(Ok(())) in poll_iterator_frames()
200 Poll::Ready(_) => Poll::Ready(Err(exit_err)), in transmit_error()
201 Poll::Pending => { in transmit_error()
203 Poll::Pending in transmit_error()
220 Poll::Ready(Ok(_)) => Poll::Ready(Ok(())), in transmit_message()
222 Poll::Ready(Err(_)) => Poll::Ready(Err(DispatchErrorKind::ChannelClosed)), in transmit_message()
[all …]
H A Dinput.rs19 use std::task::{Context, Poll};
83 Poll::Pending => return Poll::Pending, in poll()
107 Poll::Ready(Err(e)) => return Poll::Ready(Err(e)), in poll()
108 Poll::Pending => return Poll::Pending, in poll()
186 Poll::Ready(Ok(())) in poll_writer_frame()
193 Poll::Ready(None) => Poll::Ready(Err(DispatchErrorKind::ChannelClosed)), in poll_recv_frame()
194 Poll::Ready(Some(frame)) => Poll::Ready(Ok(frame)), in poll_recv_frame()
195 Poll::Pending => Poll::Pending, in poll_recv_frame()
199 Poll::Ready(Err(_e)) => Poll::Ready(Err(DispatchErrorKind::ChannelClosed)), in poll_recv_frame()
200 Poll::Ready(Ok(frame)) => Poll::Ready(Ok(frame)), in poll_recv_frame()
[all …]
H A Dmanager.rs19 use std::task::{Context, Poll};
163 Poll::Pending in manage_pending_state()
326 Poll::Ready(Ok(())) in poll_recv_frame()
434 Poll::Pending in recv_go_away_frame()
436 Poll::Ready(Ok(())) in recv_go_away_frame()
636 Poll::Pending in manage_conn_error()
700 Poll::Pending => { in poll_recv_message()
703 Poll::Pending in poll_recv_message()
705 Poll::Ready(Ok(_)) => Poll::Ready(Ok(())), in poll_recv_message()
716 Poll::Pending in poll_channel_closed_exit()
[all …]
H A Ddata_ref.rs17 use std::task::{Context, Poll};
43 ) -> Poll<Result<usize, H2Error>> { in poll_read()
47 return Poll::Ready(Ok(0)); in poll_read()
53 Poll::Ready(Err(_e)) => { in poll_read()
54 Poll::Ready(Err(H2Error::ConnectionError(ErrorCode::IntervalError))) in poll_read()
56 Poll::Ready(Ok(_)) => Poll::Ready(Ok(read_buf.filled().len())), in poll_read()
57 Poll::Pending => Poll::Pending, in poll_read()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/
H A Dhttp_body.rs15 use core::task::{Context, Poll};
227 Poll::Ready(Ok(read)) in data()
241 Poll::Ready(Ok(())) => { in poll_read_io()
253 Poll::Pending => { in poll_read_io()
258 Poll::Pending in poll_read_io()
260 Poll::Ready(Err(e)) => { in poll_read_io()
322 Poll::Ready(Ok(read)) in data()
382 Poll::Pending => { in poll_read_io()
387 Poll::Pending in poll_read_io()
474 Poll::Pending => { in data()
[all …]
H A Dtimeout.rs16 use std::task::{Context, Poll};
43 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
47 if let Poll::Ready(()) = delay.as_mut().poll(cx) { in poll()
48 return Poll::Ready(err_from_io!(Timeout, std::io::ErrorKind::TimedOut.into())); in poll()
52 Poll::Ready(Ok(mut response)) => { in poll()
54 Poll::Ready(Ok(response)) in poll()
56 Poll::Ready(Err(e)) => Poll::Ready(Err(e)), in poll()
57 Poll::Pending => Poll::Pending, in poll()
/ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/uploader/
H A Dmod.rs26 use std::task::{Context, Poll};
135 ) -> Poll<std::io::Result<()>> { in poll_read()
149 Poll::Ready(Ok(())) => {} in poll_read()
150 Poll::Ready(Err(e)) if e.error_kind() == ErrorKind::UserAborted => { in poll_read()
151 return Poll::Ready(Ok(())); in poll_read()
153 Poll::Ready(Err(_)) => return Poll::Ready(Err(std::io::ErrorKind::Other.into())), in poll_read()
154 Poll::Pending => return Poll::Pending, in poll_read()
159 Poll::Ready(Ok(_)) => {} in poll_read()
160 Poll::Ready(Err(_)) => return Poll::Ready(Err(std::io::ErrorKind::Other.into())), in poll_read()
161 Poll::Pending => return Poll::Pending, in poll_read()
[all …]
H A Dmultipart.rs18 use std::task::{Context, Poll};
196 ) -> Poll<std::io::Result<()>> { in poll_read()
209 Poll::Ready(Ok(())) => { in poll_read()
214 Poll::Ready(Ok(())) in poll_read()
216 Poll::Pending => { in poll_read()
221 Poll::Pending in poll_read()
227 Poll::Ready(Ok(())) in poll_read()
404 ) -> Poll<std::io::Result<()>> { in poll_read_curr()
437 Poll::Ready(Ok(())) in poll_read_curr()
461 ) -> Poll<std::io::Result<()>> { in poll_read()
[all …]
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/pty_process/
H A Dpty.rs20 use std::task::{Context, Poll};
183 ) -> Poll<io::Result<()>> { in poll_read()
193 ) -> Poll<io::Result<usize>> { in poll_write()
198 Poll::Ready(Ok(())) in poll_flush()
202 Poll::Ready(Ok(())) in poll_shutdown()
233 ) -> Poll<io::Result<()>> { in poll_read()
275 Poll::Ready(Ok(())) in poll_flush()
279 Poll::Ready(Ok(())) in poll_shutdown()
292 ) -> Poll<io::Result<()>> { in poll_read()
334 Poll::Ready(Ok(())) in poll_flush()
[all …]
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/
H A Dtry_join3.rs16 use std::task::{Context, Poll};
21 Poll::Pending => $is_pending = true,
22 Poll::Ready(Err(e)) => return Poll::Ready(Err(e)),
23 Poll::Ready(_) => {}
55 Poll::Pending in try_join3()
58 Poll::Ready(Ok(( in try_join3()
101 Poll::Ready(Err(e)) => Poll::Ready(Err(e)), in poll()
104 Poll::Ready(Ok(())) in poll()
106 Poll::Pending => Poll::Pending, in poll()
119 use std::task::Poll;
[all …]
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/
H A Dread_task.rs19 use std::task::{Context, Poll};
66 Poll::Ready(Err(e)) => Poll::Ready(Err(e)), in poll()
67 Poll::Ready(_) => Poll::Ready(Ok(buf.filled_len())), in poll()
68 Poll::Pending => { in poll()
70 Poll::Pending in poll()
102 ) -> Poll<io::Result<usize>> { in poll_read_to_end()
118 Poll::Pending => return Poll::Pending, in poll_read_to_end()
128 Poll::Ready(Err(e)) => return Poll::Ready(Err(e)), in poll_read_to_end()
173 ) -> Poll<io::Result<usize>> { in io_string_result()
177 Poll::Ready(Ok(bytes)) in io_string_result()
[all …]
H A Dwrite_task.rs18 use std::task::{Context, Poll};
62 Poll::Pending => { in poll()
64 Poll::Pending in poll()
102 Poll::Pending => { in poll()
104 Poll::Pending in poll()
144 Poll::Ready(Ok(0)) => return Poll::Ready(Err(io::ErrorKind::WriteZero.into())), in poll()
145 Poll::Ready(Ok(n)) => self.w_len += n, in poll()
146 Poll::Ready(Err(e)) => return Poll::Ready(Err(e)), in poll()
147 Poll::Pending => { in poll()
149 return Poll::Pending; in poll()
[all …]
H A Dstdio.rs24 Poll(JoinHandle<(io::Result<usize>, BufInner, T)>), enumerator
115 ) -> Poll<io::Result<usize>> {
138 self.state = State::Poll(handle);
141 State::Poll(ref mut join_handle) => {
143 Poll::Ready(t) => t,
144 Poll::Pending => return Poll::Pending,
150 return Poll::Ready(Ok(n));
162 return Poll::Ready(Ok(()));
176 Poll::Ready(t) => t,
177 Poll::Pending => return Poll::Pending,
[all …]
H A Dasync_write.rs18 use std::task::{Context, Poll};
44 ) -> Poll<io::Result<usize>>; in poll_write()
54 ) -> Poll<io::Result<usize>> { in poll_write_vectored()
76 fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>>; in poll_flush()
94 fn poll_shutdown(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>>; in poll_shutdown()
105 ) -> Poll<Result<usize, io::Error>> {
115 ) -> Poll<Result<usize, io::Error>> {
155 ) -> Poll<Result<usize, io::Error>> { in poll_write()
163 ) -> Poll<Result<usize, io::Error>> { in poll_write_vectored()
171 fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_flush()
[all …]
H A Dstdin.rs17 use std::task::{Context, Poll};
50 ) -> Poll<io::Result<()>> { in poll_read()
60 return Poll::Ready(Ok(())); in poll_read()
71 self.state = State::Poll(handle); in poll_read()
73 State::Poll(ref mut join_handle) => { in poll_read()
75 Poll::Ready(t) => t, in poll_read()
76 Poll::Pending => return Poll::Pending, in poll_read()
84 Poll::Ready(Ok(())) in poll_read()
88 Poll::Ready(Err(e)) in poll_read()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/
H A Dc_ssl_stream.rs15 use core::task::{Context, Poll};
97 ) -> Poll<io::Result<()>> { in poll_read()
105 Poll::Ready(len) => { in poll_read()
114 Poll::Ready(Ok(())) in poll_read()
116 Poll::Pending => Poll::Pending, in poll_read()
130 fn poll_flush(self: Pin<&mut Self>, ctx: &mut Context) -> Poll<io::Result<()>> { in poll_flush()
148 return Poll::Pending; in poll_shutdown()
152 return Poll::Ready(Err(e in poll_shutdown()
165 Ok(t) => Poll::Ready(Ok(t)), in check_result_to_poll()
167 SslErrorCode::WANT_READ | SslErrorCode::WANT_WRITE => Poll::Pending, in check_result_to_poll()
[all …]
H A Dwrapper.rs16 use core::task::{Context, Poll};
50 Poll::Ready(()) => Ok(buf.filled().len()), in read()
51 Poll::Pending => Err(io::Error::from(io::ErrorKind::WouldBlock)), in read()
63 Poll::Ready(r) => r, in write()
64 Poll::Pending => Err(io::Error::from(io::ErrorKind::WouldBlock)), in write()
71 Poll::Ready(r) => r, in flush()
72 Poll::Pending => Err(io::Error::from(io::ErrorKind::WouldBlock)), in flush()
82 pub(crate) fn check_io_to_poll<T>(r: io::Result<T>) -> Poll<io::Result<T>> { in check_io_to_poll()
84 Ok(t) => Poll::Ready(Ok(t)), in check_io_to_poll()
85 Err(ref e) if e.kind() == io::ErrorKind::WouldBlock => Poll::Pending, in check_io_to_poll()
[all …]
/ohos5.0/base/request/request/services/src/task/
H A Doperator.rs18 use std::task::{Context, Poll};
58 ) -> Poll<Result<(), HttpClientError>> { in poll_progress_common()
60 return Poll::Ready(Err(HttpClientError::user_aborted())); in poll_progress_common()
124 Poll::Ready(_) => return Poll::Ready(Ok(())), in poll_progress_common()
125 Poll::Pending => return Poll::Pending, in poll_progress_common()
128 Poll::Ready(Ok(())) in poll_progress_common()
136 ) -> Poll<Result<usize, HttpClientError>> { in poll_write_file()
140 Poll::Ready(Ok(size)) => { in poll_write_file()
143 Poll::Ready(Ok(size + skip_size)) in poll_write_file()
145 Poll::Pending => Poll::Pending, in poll_write_file()
[all …]
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/
H A Dasync_source.rs20 use std::task::{Context, Poll};
112 Poll::Ready(x) => x,
113 Poll::Pending => return Poll::Pending,
116 Poll::Ready(Ok(x))
124 ) -> Poll<io::Result<R>> {
162 ) -> Poll<io::Result<R>> {
171 ) -> Poll<io::Result<R>> {
179 ) -> Poll<io::Result<()>>
190 Poll::Ready(Err(e)) => return Poll::Ready(Err(e)),
191 Poll::Pending => return Poll::Pending,
[all …]
/ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/downloader/
H A Doperator.rs19 use std::task::{Context, Poll};
67 ) -> Poll<Result<usize, HttpClientError>>; in poll_download()
77 ) -> Poll<Result<(), HttpClientError>> { in poll_progress()
78 Poll::Ready(Ok(())) in poll_progress()
113 ) -> Poll<Result<usize, HttpClientError>> { in poll_download()
122 ) -> Poll<Result<(), HttpClientError>> { in poll_progress()
139 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
172 ) -> Poll<Result<usize, HttpClientError>> { in poll_download()
174 Poll::Ready(Ok(data.len())) in poll_download()
182 ) -> Poll<Result<(), HttpClientError>> { in poll_progress()
[all …]
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/downloader/
H A Doperator.rs16 use std::task::{Context, Poll};
31 ) -> Poll<Result<usize, HttpClientError>>; in poll_download()
42 ) -> Poll<Result<(), HttpClientError>> { in poll_progress()
43 Poll::Ready(Ok(())) in poll_progress()
84 ) -> Poll<Result<usize, HttpClientError>> { in poll_download()
93 ) -> Poll<Result<(), HttpClientError>> { in poll_progress()
109 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
141 ) -> Poll<Result<usize, HttpClientError>> { in poll_download()
146 Poll::Ready(Ok(data.len())) in poll_download()
154 ) -> Poll<Result<(), HttpClientError>> { in poll_progress()
[all …]
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/io/
H A Dsplit.rs20 use std::task::{Context, Poll};
28 std::task::Poll::Ready(t) => t,
29 std::task::Poll::Pending => return std::task::Poll::Pending,
75 ) -> Poll<io::Result<()>> { in poll_read()
86 ) -> Poll<Result<usize, io::Error>> { in poll_write()
95 ) -> Poll<std::io::Result<usize>> { in poll_write_vectored()
104 fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), io::Error>> { in poll_flush()
109 fn poll_shutdown(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<std::io::Result<()>> { in poll_shutdown()
124 fn get_lock(&self, cx: &mut Context<'_>) -> Poll<StreamGuard<T>> { in get_lock()
126 Ok(guard) => Poll::Ready(StreamGuard { inner: guard }), in get_lock()
[all …]
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/
H A Dmod.rs23 use std::task::{Context, Poll};
147 pub fn poll_recv(&mut self, cx: &mut Context<'_>) -> Poll<()> { in poll_recv() argument
151 Poll::Ready(Ok(())) => Poll::Ready(()), in poll_recv()
152 Poll::Ready(Err(_)) => panic!("Signal sender has been dropped"), in poll_recv()
153 Poll::Pending => Poll::Pending, in poll_recv()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/encode/
H A Dpart.rs16 use core::task::{Context, Poll};
196 ) -> Poll<Result<usize, Self::Error>> { in poll_data()
199 let encode_size: Poll<SizeResult> = match self.stage { in poll_data()
204 PartStatus::End => return Poll::Ready(Ok(count)), in poll_data()
208 Poll::Ready(Ok(size)) => count += size, in poll_data()
209 Poll::Ready(Err(err)) => return Poll::Ready(Err(err)), in poll_data()
210 Poll::Pending => return Poll::Pending, in poll_data()
213 Poll::Ready(Ok(count)) in poll_data()
222 ) -> Poll<Result<usize, std::io::Error>> { in poll_mime_body()
226 if let Poll::Ready(Ok(0)) = poll_result { in poll_mime_body()
[all …]
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/
H A Ddispatcher.rs156 use std::task::{Context, Poll};
471 ) -> Poll<Result<(), H2Error>> { in send_message_to_stream()
481 Poll::Ready(Ok(_)) => Poll::Ready(Ok(())), in send_message_to_stream()
487 Poll::Pending => { in send_message_to_stream()
489 Poll::Pending in send_message_to_stream()
501 ) -> Poll<()> { in poll_blocked_message() argument
529 Poll::Pending => { in poll_blocked_message()
537 Poll::Pending in poll_blocked_message()
539 Poll::Ready(()) in poll_blocked_message()
592 Poll::Pending => Poll::Pending, in poll_recv()
[all …]

12345