| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| H A D | ready.rs | 36 impl Ready { implementation
37 pub const EMPTY: Ready = Ready(0);
39 pub const READABLE: Ready = Ready(READABLE);
41 pub const WRITABLE: Ready = Ready(WRITABLE);
43 pub const READ_CLOSED: Ready = Ready(READ_CLOSED);
45 pub const WRITE_CLOSED: Ready = Ready(WRITE_CLOSED);
92 Ready(val & Ready::ALL.as_usize()) in from_usize()
124 impl ops::BitOr<Ready> for Ready { implementation
133 impl ops::BitOrAssign<Ready> for Ready { implementation
140 impl ops::BitAnd<Ready> for Ready { implementation
[all …]
|
| H A D | schedule_io.rs | 28 use crate::net::{Ready, ReadyEvent};
152 Poll::Ready(ready_event) in poll_readiness()
180 self.wake0(Ready::ALL, true); in shutdown()
184 let mask_no_closed = ready.get_ready() - Ready::READ_CLOSED - Ready::WRITE_CLOSED; in clear_readiness()
194 f: impl Fn(Ready) -> Ready, in set_readiness() argument
247 pub(crate) fn wake(&self, ready: Ready) { in wake() argument
251 fn wake0(&self, ready: Ready, shutdown: bool) { in wake0() argument
288 self.wake(Ready::ALL); in drop()
349 readiness = Ready::ALL; in poll_init()
408 return Some(Poll::Ready(res)); in poll_state()
[all …]
|
| H A D | async_source.rs | 112 Poll::Ready(x) => x,
116 Poll::Ready(Ok(x))
132 x => return Poll::Ready(x),
189 Poll::Ready(Ok(x)) => x,
190 Poll::Ready(Err(e)) => return Poll::Ready(Err(e)),
196 Poll::Ready(Ok(()))
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| H A D | output.rs | 86 Poll::Ready(Err(e)) => { in poll_read_frame()
125 Poll::Ready(Ok(_)) => { in poll_read_frame()
130 Poll::Ready(Err(e)) => return Poll::Ready(Err(e)), in poll_read_frame()
135 return Poll::Ready(Err(e)); in poll_read_frame()
144 Poll::Ready(Ok(_)) => {} in poll_blocked_task()
145 Poll::Ready(Err(_)) => { in poll_blocked_task()
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()
220 Poll::Ready(Ok(_)) => Poll::Ready(Ok(())), in transmit_message()
[all …]
|
| H A D | input.rs | 79 Poll::Ready(Err(e)) => { in poll()
81 return Poll::Ready(Err(e)); in poll()
106 Poll::Ready(Ok(())) => {} in poll()
107 Poll::Ready(Err(e)) => return Poll::Ready(Err(e)), in poll()
142 Poll::Ready(written) => { in poll_writer_frame()
171 Poll::Ready(written) => { in poll_writer_frame()
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()
199 Poll::Ready(Err(_e)) => Poll::Ready(Err(DispatchErrorKind::ChannelClosed)), in poll_recv_frame()
[all …]
|
| H A D | manager.rs | 180 Poll::Ready(None) => { in poll_recv_request()
304 return Poll::Ready(Err( in poll_recv_frame()
326 Poll::Ready(Ok(())) in poll_recv_frame()
407 return Poll::Ready(Ok(())); in recv_go_away_frame()
425 Poll::Ready(_) => {} in recv_go_away_frame()
436 Poll::Ready(Ok(())) in recv_go_away_frame()
485 return Poll::Ready(Ok(())); in recv_data_frame()
705 Poll::Ready(Ok(_)) => Poll::Ready(Ok(())), in poll_recv_message()
724 Poll::Ready(_) => { in poll_blocked_frames()
728 Poll::Ready(()) in poll_blocked_frames()
[all …]
|
| H A D | data_ref.rs | 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()
|
| /ohos5.0/foundation/ability/idl_tool/test/ts/moduletest/ts_code_emitter_test/ |
| H A D | ts_code_emitter_test.cpp | 59 EXPECT_EQ(Ready(argc, parameters.GetArgv()), ERR_OK);
76 EXPECT_EQ(Ready(argc, parameters.GetArgv()), ERR_OK);
93 EXPECT_EQ(Ready(argc, parameters.GetArgv()), ERR_OK);
110 EXPECT_EQ(Ready(argc, parameters.GetArgv()), ERR_OK);
127 EXPECT_EQ(Ready(argc, parameters.GetArgv()), ERR_OK);
144 EXPECT_EQ(Ready(argc, parameters.GetArgv()), ERR_OK);
161 EXPECT_EQ(Ready(argc, parameters.GetArgv()), ERR_OK);
178 EXPECT_EQ(Ready(argc, parameters.GetArgv()), ERR_OK);
196 EXPECT_EQ(Ready(argc, parameters.GetArgv()), ERR_OK);
213 EXPECT_EQ(Ready(argc, parameters.GetArgv()), ERR_OK);
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| H A D | http_body.rs | 111 return Poll::Ready(Ok(0)); in poll_data()
158 _ => Poll::Ready(Ok(None)), in poll_trailer()
209 return Poll::Ready(Ok(0)); in data()
227 Poll::Ready(Ok(read)) in data()
241 Poll::Ready(Ok(())) => { in poll_read_io()
251 Poll::Ready(Ok(read)) in poll_read_io()
260 Poll::Ready(Err(e)) => { in poll_read_io()
322 Poll::Ready(Ok(read)) in data()
360 Poll::Ready(Ok(())) => { in poll_read_io()
389 Poll::Ready(Err(e)) => { in poll_read_io()
[all …]
|
| H A D | timeout.rs | 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()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/ |
| H A D | try_join3.rs | 22 Poll::Ready(Err(e)) => return Poll::Ready(Err(e)),
23 Poll::Ready(_) => {}
58 Poll::Ready(Ok(( in try_join3()
70 Ready(F::Output), enumerator
85 if let FutureDone::Ready(output) = std::mem::replace(inner, FutureDone::None) { in take_output()
101 Poll::Ready(Err(e)) => Poll::Ready(Err(e)), in poll()
102 Poll::Ready(Ok(res)) => { in poll()
103 self.set(FutureDone::Ready(Ok(res))); in poll()
104 Poll::Ready(Ok(())) in poll()
108 FutureDone::Ready(_) => Poll::Ready(Ok(())), in poll()
[all …]
|
| /ohos5.0/foundation/ability/idl_tool/test/ts/unittest/ts_code_emitter_interface_test/ |
| H A D | ts_code_emitter_interface_test.cpp | 59 EXPECT_EQ(Ready(argc, parameters.GetArgv()), ERR_OK);
78 EXPECT_EQ(Ready(argc, parameters.GetArgv()), ERR_OK);
97 EXPECT_EQ(Ready(argc, parameters.GetArgv()), ERR_OK);
116 EXPECT_EQ(Ready(argc, parameters.GetArgv()), ERR_OK);
135 EXPECT_EQ(Ready(argc, parameters.GetArgv()), ERR_OK);
154 EXPECT_EQ(Ready(argc, parameters.GetArgv()), ERR_OK);
173 EXPECT_EQ(Ready(argc, parameters.GetArgv()), ERR_OK);
192 EXPECT_EQ(Ready(argc, parameters.GetArgv()), ERR_OK);
211 EXPECT_EQ(Ready(argc, parameters.GetArgv()), ERR_OK);
230 EXPECT_EQ(Ready(argc, parameters.GetArgv()), ERR_OK);
[all …]
|
| /ohos5.0/docs/en/device-dev/kernel/ |
| H A D | kernel-small-basic-process-process.md | 24 - Ready: The process is in the Ready queue and waits for scheduling by the CPU.
38 - Init→Ready:
41 - Ready→Running:
42 …Ready queue is executed and enters the Running state. If this process has no thread in the Ready s…
47 - Pending→Ready:
48 … in a Pending process restores to the Ready state, the process is added to the Ready queue and cha…
50 - Ready→Pending:
51 …the Pending state, the process is deleted from the Ready queue, and the process changes from the R…
53 - Running→Ready:
54 …A process may change from the Running state to the Ready state in either of the following scenario…
[all …]
|
| H A D | kernel-small-basic-process-thread.md | 22 - Ready: The task is in the Ready queue and waits for scheduling by the CPU.
36 - Init→Ready:
39 - Ready→Running:
40 … the highest priority in the Ready queue is executed and enters the Running state. Then, this task…
45 - Blocked→Ready:
46 …semaphore is read), the task is added to the Ready queue and will change from the Blocked state to…
48 - Ready→Blocked:
49 …When a task in the Ready state is blocked (suspended), the task changes to the Blocked state and i…
51 - Running→Ready:
52 …riority in the Ready queue changes to the Running state. The originally running task changes to th…
[all …]
|
| H A D | kernel-mini-basic-task.md | 29 - Ready: The task is in the ready queue, waiting for execution by a CPU.
47 - Ready → Running
49 …Ready state once created. When task switching occurs, the task with the highest priority in the Re…
53 - Blocked -> Ready (Prerequisites for Blocked -> Running)
55 …Ready queue and change from the Blocked state to the Ready state. If the priority of the recovered…
56 - Ready → Blocked
58 …When a task in the Ready state is blocked (suspended), the task changes to the Blocked state and i…
59 - Running → Ready
61 …priority in the Ready queue changes to the Running state. The originally running task changes to t…
75 …ty. When task switching occurs, the task with the highest priority in the Ready queue will be exec…
[all …]
|
| /ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/uploader/ |
| H A D | mod.rs | 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()
159 Poll::Ready(Ok(_)) => {} in poll_read()
160 Poll::Ready(Err(_)) => return Poll::Ready(Err(std::io::ErrorKind::Other.into())), in poll_read()
166 Poll::Ready(Ok(())) in poll_read()
|
| H A D | multipart.rs | 205 return Poll::Ready(Ok(())); in poll_read()
209 Poll::Ready(Ok(())) => { in poll_read()
214 Poll::Ready(Ok(())) in poll_read()
219 Poll::Ready(Ok(())) in poll_read()
227 Poll::Ready(Ok(())) in poll_read()
417 Poll::Ready(Ok(())) in poll_read_curr()
422 Poll::Ready(Ok(())) => { in poll_read_curr()
426 Poll::Ready(Ok(())) in poll_read_curr()
437 Poll::Ready(Ok(())) in poll_read_curr()
472 Poll::Ready(Ok(())) => {} in poll_read()
[all …]
|
| /ohos5.0/docs/zh-cn/device-dev/kernel/ |
| H A D | kernel-small-basic-process-process.md | 24 - 就绪（Ready）：进程在就绪列表中，等待CPU调度。
38 - Init→Ready：
41 - Ready→Running：
47 - Pending→Ready：
50 - Ready→Pending：
53 - Running→Ready：
|
| H A D | kernel-small-basic-process-thread.md | 22 - 就绪（Ready）：任务在就绪列表中，等待CPU调度。
36 - Init→Ready：
39 - Ready→Running：
45 - Blocked→Ready ：
48 - Ready→Blocked：
51 - Running→Ready：
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| H A D | read_task.rs | 66 Poll::Ready(Err(e)) => Poll::Ready(Err(e)), in poll()
67 Poll::Ready(_) => Poll::Ready(Ok(buf.filled_len())), in poll()
122 Poll::Ready(Ok(())) => { in poll_read_to_end()
128 Poll::Ready(Err(e)) => return Poll::Ready(Err(e)), in poll_read_to_end()
177 Poll::Ready(Ok(bytes)) in io_string_result()
185 Poll::Ready(Err(io::Error::new( in io_string_result()
192 Poll::Ready(Err(io_err)) in io_string_result()
200 Poll::Ready(Err(io_err)) in io_string_result()
253 return Poll::Ready(Ok(())); in poll()
407 return Poll::Ready(Ok(None)); in poll_next()
[all …]
|
| /ohos5.0/base/request/request/services/src/task/ |
| H A D | operator.rs | 60 return Poll::Ready(Err(HttpClientError::user_aborted())); in poll_progress_common()
124 Poll::Ready(_) => return Poll::Ready(Ok(())), in poll_progress_common()
128 Poll::Ready(Ok(())) in poll_progress_common()
140 Poll::Ready(Ok(size)) => { in poll_write_file()
143 Poll::Ready(Ok(size + skip_size)) in poll_write_file()
146 Poll::Ready(Err(e)) => Poll::Ready(Err(HttpClientError::other(e))), in poll_write_file()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/encode/ |
| H A D | part.rs | 200 PartStatus::Start => Poll::Ready(self.start_encode()), in poll_data()
201 PartStatus::Headers => Poll::Ready(self.headers_encode(&mut buf[count..])), in poll_data()
202 PartStatus::Crlf => Poll::Ready(self.crlf_encode(&mut buf[count..])), 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()
213 Poll::Ready(Ok(count)) in poll_data()
226 if let Poll::Ready(Ok(0)) = poll_result { in poll_mime_body()
234 Poll::Ready(Ok(0)) in poll_mime_body()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| H A D | dispatcher.rs | 481 Poll::Ready(Ok(_)) => Poll::Ready(Ok(())), in send_message_to_stream()
483 Poll::Ready(Err(_)) => { in send_message_to_stream()
508 Poll::Ready(Ok(_)) => {} in poll_blocked_message()
510 Poll::Ready(Err(_)) => { in poll_blocked_message()
539 Poll::Ready(()) in poll_blocked_message()
585 Poll::Ready(None) => { in poll_recv()
588 Poll::Ready(Some(message)) => match message { in poll_recv()
589 RespMessage::Output(frame) => Poll::Ready(Ok(frame)), in poll_recv()
597 Poll::Ready(Err(e)) => { in poll_recv()
600 Poll::Ready(Ok(message)) => match message { in poll_recv()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/ |
| H A D | wrapper.rs | 50 Poll::Ready(()) => Ok(buf.filled().len()), in read()
63 Poll::Ready(r) => r, in write()
71 Poll::Ready(r) => r, in flush()
84 Ok(t) => Poll::Ready(Ok(t)), in check_io_to_poll()
86 Err(e) => Poll::Ready(Err(e)), in check_io_to_poll()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/ |
| H A D | http2.rs | 245 Poll::Ready(frame) => match frame.payload() { in match_channel_message()
249 Some(Poll::Ready(Ok(()))) in match_channel_message()
260 Some(Poll::Ready(Ok(()))) in match_channel_message()
269 Some(Poll::Ready(Ok(()))) in match_channel_message()
277 _ => Some(Poll::Ready(Err(std::io::Error::new( in match_channel_message()
295 Some(Poll::Ready(Ok(()))) in end_read()
300 Some(Poll::Ready(Ok(()))) in end_read()
321 Some(Poll::Ready(Ok(()))) in read_remaining_data()
327 _ => Some(Poll::Ready(Err(std::io::Error::new( in read_remaining_data()
353 return Poll::Ready(Ok(())); in poll_read()
[all …]
|