| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/parallel/ |
| H A D | slice.rs | 21 fn reduce(self, len: usize) -> Self { in reduce()
24 fn split(self) -> (Self, Option<Self>) { in split()
36 fn reduce(self, len: usize) -> Self { in reduce()
40 fn split(self) -> (Self, Option<Self>) { in split()
|
| H A D | vec.rs | 21 fn reduce(mut self, len: usize) -> Self { in reduce()
26 fn split(mut self) -> (Self, Option<Self>) { in split()
|
| /ohos5.0/base/msdp/device_status/rust/subsystem/input/sys/src/interaction/ |
| H A D | extra_data.rs | 24 pub fn new(appended: bool) -> Self { in new()
35 pub fn set_appended(&mut self, appended: bool) -> &mut Self { in set_appended()
41 pub fn set_buffer(&mut self, vec: &Vec<u8>) -> &mut Self { in set_buffer()
49 pub fn set_source_type(&mut self, source_type: i32) -> &mut Self { in set_source_type()
55 pub fn set_pointer_id(&mut self, pointer_id: i32) -> &mut Self { in set_pointer_id()
68 pub fn new(appended: bool) -> Self { in new()
|
| /ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/ |
| H A D | mod.rs | 153 pub fn http1_only(self) -> Self { in http1_only()
166 pub fn http2_prior_knowledge(self) -> Self { in http2_prior_knowledge()
186 pub fn request_timeout(self, timeout: Timeout) -> Self { in request_timeout()
206 pub fn connect_timeout(self, timeout: Timeout) -> Self { in connect_timeout()
225 pub fn redirect(self, redirect: Redirect) -> Self { in redirect() method
243 pub fn proxy(self, proxy: Proxy) -> Self { in proxy() method
266 pub fn max_tls_version(self, version: TlsVersion) -> Self { in max_tls_version()
286 pub fn min_tls_version(self, version: TlsVersion) -> Self { in min_tls_version()
305 pub fn add_root_certificate(mut self, cert: Certificate) -> Self { in add_root_certificate()
|
| /ohos5.0/base/request/request/services/src/task/ |
| H A D | config.rs | 184 fn from(value: u8) -> Self { in from()
194 fn from(value: u8) -> Self { in from()
204 fn from(value: u8) -> Self { in from()
213 fn from(value: u8) -> Self { in from()
306 pub fn url(&mut self, url: &str) -> &mut Self { in url() method
312 pub fn version(&mut self, version: u8) -> &mut Self { in version() method
329 pub fn mode(&mut self, mode: Mode) -> &mut Self { in mode() method
341 pub fn uid(&mut self, uid: u64) -> &mut Self { in uid() method
376 pub fn begins(&mut self, begins: u64) -> &mut Self { in begins() method
382 pub fn ends(&mut self, ends: u64) -> &mut Self { in ends() method
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| H A D | async_read.rs | 42 self: Pin<&mut Self>, in poll_read()
51 mut self: Pin<&mut Self>, in poll_read()
62 mut self: Pin<&mut Self>, in poll_read()
77 self: Pin<&mut Self>, in poll_read()
111 fn read<'a>(&'a mut self, buf: &'a mut [u8]) -> ReadTask<'a, Self> { in read() argument
130 fn read_exact<'a>(&'a mut self, buf: &'a mut [u8]) -> ReadExactTask<'a, Self> { in read_exact() argument
148 fn read_to_end<'a>(&'a mut self, buf: &'a mut Vec<u8>) -> ReadToEndTask<'a, Self> { in read_to_end() argument
167 fn read_to_string<'a>(&'a mut self, dst: &'a mut String) -> ReadToStringTask<'a, Self> { in read_to_string() argument
211 mut self: Pin<&mut Self>, in poll_read()
|
| H A D | async_buf_read.rs | 37 fn poll_fill_buf(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<&[u8]>>; in poll_fill_buf()
47 fn consume(self: Pin<&mut Self>, amt: usize); in consume()
52 fn poll_fill_buf(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<&[u8]>> { in poll_fill_buf()
56 fn consume(mut self: Pin<&mut Self>, amt: usize) { in consume()
63 fn poll_fill_buf(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<&[u8]>> { in poll_fill_buf()
67 fn consume(mut self: Pin<&mut Self>, amt: usize) { in consume()
78 fn poll_fill_buf(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<&[u8]>> { in poll_fill_buf()
82 fn consume(self: Pin<&mut Self>, amt: usize) { in consume()
|
| H A D | async_write.rs | 41 self: Pin<&mut Self>, in poll_write()
51 self: Pin<&mut Self>, 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()
152 self: Pin<&mut Self>, in poll_write()
160 self: Pin<&mut Self>, in poll_write_vectored()
171 fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_flush()
175 fn poll_shutdown(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_shutdown()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| H A D | client.rs | 88 pub fn with_connector(connector: C) -> Self { in with_connector()
228 pub fn http1_only(mut self) -> Self { in http1_only()
246 pub fn request_timeout(mut self, timeout: Timeout) -> Self { in request_timeout()
263 pub fn connect_timeout(mut self, timeout: Timeout) -> Self { in connect_timeout()
280 pub fn redirect(mut self, redirect: Redirect) -> Self { in redirect() method
297 pub fn proxy(mut self, proxy: Proxy) -> Self { in proxy() method
403 pub fn tls_ca_file(mut self, path: &str) -> Self { in tls_ca_file()
422 pub fn tls_cipher_list(mut self, list: &str) -> Self { in tls_cipher_list()
443 pub fn tls_cipher_suites(mut self, list: &str) -> Self { in tls_cipher_suites()
458 pub fn tls_built_in_root_certs(mut self, is_use: bool) -> Self { in tls_built_in_root_certs()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/builder/ |
| H A D | multi_thread_builder.rs | 97 pub fn max_worker_num_by_qos(mut self, qos: Qos, num: u32) -> Self { in max_worker_num_by_qos()
108 pub fn worker_name(mut self, name: String) -> Self { in worker_name()
127 pub fn worker_num(self, core_pool_size: usize) -> Self { in worker_num()
135 pub fn is_affinity(self, _is_affinity: bool) -> Self { in is_affinity()
143 pub fn schedule_algo(self, _schedule_algo: ScheduleAlgo) -> Self { in schedule_algo()
173 pub fn blocking_permanent_thread_num(self, _blocking_permanent_thread_num: u8) -> Self { in blocking_permanent_thread_num()
184 pub fn max_blocking_pool_size(self, _max_blocking_pool_size: u8) -> Self { in max_blocking_pool_size()
193 pub fn keep_alive_time(self, _keep_alive_time: Duration) -> Self { in keep_alive_time()
205 pub fn stack_size_by_qos(mut self, qos: Qos, stack_size: usize) -> Self { in stack_size_by_qos()
218 pub fn worker_stack_size(self, stack_size: usize) -> Self { in worker_stack_size()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/pty_process/ |
| H A D | pty.rs | 160 fn from(value: Pty) -> Self { in from()
180 self: Pin<&mut Self>, in poll_read()
190 self: Pin<&mut Self>, in poll_write()
197 fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_flush()
211 fn new(pts_inner: super::sys::PtsInner) -> Self { in new()
230 self: Pin<&mut Self>, in poll_read()
267 self: Pin<&mut Self>, in poll_write()
274 fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_flush()
289 self: Pin<&mut Self>, in poll_read()
326 self: Pin<&mut Self>, in poll_write()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/ |
| H A D | mix.rs | 34 mut self: Pin<&mut Self>, in poll_read()
51 mut self: Pin<&mut Self>, in poll_write()
61 fn poll_flush(mut self: Pin<&mut Self>, ctx: &mut Context<'_>) -> Poll<std::io::Result<()>> { in poll_flush()
68 fn poll_shutdown(mut self: Pin<&mut Self>, ctx: &mut Context<'_>) -> Poll<std::io::Result<()>> { in poll_shutdown()
|
| H A D | c_ssl_stream.rs | 29 fn with_context<F, R>(self: Pin<&mut Self>, ctx: &mut Context<'_>, f: F) -> R in with_context()
64 ) -> Result<Self, ErrorStack> { in new()
78 fn poll_connect(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), ssl::SslError>> { in poll_connect()
94 self: Pin<&mut Self>, in poll_read()
126 fn poll_write(self: Pin<&mut Self>, ctx: &mut Context, buf: &[u8]) -> Poll<io::Result<usize>> { in poll_write()
130 fn poll_flush(self: Pin<&mut Self>, ctx: &mut Context) -> Poll<io::Result<()>> { in poll_flush()
134 fn poll_shutdown(mut self: Pin<&mut Self>, ctx: &mut Context) -> Poll<io::Result<()>> { in poll_shutdown()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ |
| H A D | adapter.rs | 86 pub fn ca_file<T: AsRef<Path>>(mut self, path: T) -> Self { in ca_file()
106 pub fn max_proto_version(mut self, version: TlsVersion) -> Self { in max_proto_version()
128 pub fn min_proto_version(mut self, version: TlsVersion) -> Self { in min_proto_version()
153 pub fn cipher_list(mut self, list: &str) -> Self { in cipher_list()
178 pub fn cipher_suites(mut self, list: &str) -> Self { in cipher_suites()
254 pub fn add_path_certificates(mut self, path: String) -> Self { in add_path_certificates()
264 pub(crate) fn alpn_protos(mut self, protocols: &[u8]) -> Self { in alpn_protos()
285 pub fn build_in_root_certs(mut self, is_use: bool) -> Self { in build_in_root_certs()
375 pub fn sni(mut self, use_sni: bool) -> Self { in sni()
596 pub fn from_pem(pem: &[u8]) -> Result<Self, HttpClientError> { in from_pem()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/representation/ |
| H A D | encoder.rs | 34 pub(crate) fn new(table: &'a mut DynamicTable) -> Self { in new()
171 fn new(parts: Parts) -> Self { in new()
244 fn from(index: Integer) -> Self { in from()
248 fn new(index: usize) -> Self { in new()
273 fn from(inner: IndexAndValue) -> Self { in from()
296 fn from(inner: NameAndValue) -> Self { in from()
319 fn from(inner: IndexAndValue) -> Self { in from()
342 fn from(inner: NameAndValue) -> Self { in from()
365 fn from(inner: IndexAndValue) -> Self { in from()
388 fn from(inner: NameAndValue) -> Self { in from()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/format/ |
| H A D | encoder.rs | 53 ) -> Self { in new()
347 fn from(capacity: Integer) -> Self { in from()
369 fn from(index: Integer) -> Self { in from()
373 fn new(index: usize) -> Self { in new()
391 fn from(index: Integer) -> Self { in from()
421 fn from(index: Integer) -> Self { in from()
425 fn new(index: usize) -> Self { in new()
485 ) -> Self { in new()
579 fn from(inner: NameAndValue) -> Self { in from()
611 fn from(inner: NameAndValue) -> Self { in from()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/buffered/ |
| H A D | async_buf_writer.rs | 173 fn flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in flush()
207 mut self: Pin<&mut Self>, in poll_write()
225 mut self: Pin<&mut Self>, in poll_write_vectored()
282 fn poll_flush(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_flush()
288 fn poll_shutdown(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_shutdown()
297 mut self: Pin<&mut Self>, in poll_seek()
309 self: Pin<&mut Self>, in poll_read()
319 fn poll_fill_buf(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<&[u8]>> { in poll_fill_buf()
324 fn consume(self: Pin<&mut Self>, amt: usize) { in consume()
|
| /ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/uploader/ |
| H A D | multipart.rs | 68 pub fn part(mut self, part: Part) -> Self { in part() method
193 mut self: Pin<&mut Self>, in poll_read()
232 fn from(value: MultiPart) -> Self { in from()
285 pub fn name(mut self, name: &str) -> Self { in name() method
301 pub fn file_name(mut self, file_name: &str) -> Self { in file_name() method
317 pub fn mime(mut self, mime: &str) -> Self { in mime() method
333 pub fn length(mut self, length: Option<u64>) -> Self { in length() method
349 pub fn body<T: AsRef<[u8]>>(mut self, body: T) -> Self { in body() method
447 fn bytes(bytes: Vec<u8>) -> Self { in bytes() method
451 fn stream(reader: Pin<Box<dyn AsyncRead + Send + Sync>>) -> Self { in stream()
[all …]
|
| /ohos5.0/foundation/communication/ipc/interfaces/innerkits/rust/src/parcel/ |
| H A D | wrapper.rs | 160 fn read_process(parcel: Pin<&mut Parcel>) -> IpcResult<Self>; in read_process()
172 fn read_process(parcel: Pin<&mut Parcel>) -> IpcResult<Self> { in read_process()
198 fn read_process(parcel: Pin<&mut Parcel>) -> IpcResult<Self> { in read_process()
224 fn read_process(parcel: Pin<&mut Parcel>) -> IpcResult<Self> { in read_process()
249 fn read_process(parcel: Pin<&mut Parcel>) -> IpcResult<Self> { in read_process()
274 fn read_process(parcel: Pin<&mut Parcel>) -> IpcResult<Self> { in read_process()
300 fn read_process(parcel: Pin<&mut Parcel>) -> IpcResult<Self> { in read_process()
325 fn read_process(parcel: Pin<&mut Parcel>) -> IpcResult<Self> { in read_process()
351 fn read_process(parcel: Pin<&mut Parcel>) -> IpcResult<Self> { in read_process()
376 fn read_process(parcel: Pin<&mut Parcel>) -> IpcResult<Self> { in read_process()
[all …]
|
| /ohos5.0/foundation/communication/ipc/interfaces/innerkits/rust/src/remote/ |
| H A D | obj.rs | 35 fn clone(&self) -> Self { in clone()
51 pub fn try_new(wrap: UniquePtr<IRemoteObjectWrapper>) -> Option<Self> { in try_new()
59 pub unsafe fn new_unchecked(wrap: UniquePtr<IRemoteObjectWrapper>) -> Self { in new_unchecked()
63 pub unsafe fn from_ciremote(remote: *mut IRemoteObject) -> Option<Self> { in from_ciremote()
77 pub fn from_stub<T: RemoteStub + 'static>(stub: T) -> Option<Self> { in from_stub()
82 pub fn from_sptr(sptr: UniquePtr<SptrIRemoteObject>) -> Option<Self> { in from_sptr()
112 self: &Arc<Self>, in async_send_request()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/ |
| H A D | error.rs | 40 fn from(kind: ErrorKind) -> Self { in from()
46 fn from(err: InvalidUri) -> Self { in from()
53 fn from(err: H2Error) -> Self { in from()
59 fn from(_value: Infallible) -> Self { in from()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| H A D | client.rs | 136 pub fn with_connector(connector: C) -> Self { in with_connector()
328 pub fn http1_only(mut self) -> Self { in http1_only()
346 pub fn request_timeout(mut self, timeout: Timeout) -> Self { in request_timeout()
380 pub fn redirect(mut self, redirect: Redirect) -> Self { in redirect() method
415 pub fn retry(mut self, retry: Retry) -> Self { in retry() method
433 pub fn proxy(mut self, proxy: Proxy) -> Self { in proxy() method
536 pub fn http2_prior_knowledge(mut self) -> Self { in http2_prior_knowledge()
741 pub fn tls_ca_file(mut self, path: &str) -> Self { in tls_ca_file()
760 pub fn tls_cipher_list(mut self, list: &str) -> Self { in tls_cipher_list()
781 pub fn tls_cipher_suites(mut self, list: &str) -> Self { in tls_cipher_suites()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| H A D | request.rs | 26 pub(crate) fn new(request: Request) -> Self { in new()
40 pub(crate) fn new(request: Request) -> Self { in new()
54 fn clone(&self) -> Self { in clone()
|
| /ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/downloader/ |
| H A D | operator.rs | 64 self: Pin<&mut Self>, in poll_download()
73 self: Pin<&mut Self>, in poll_progress()
110 mut self: Pin<&mut Self>, in poll_download()
118 mut self: Pin<&mut Self>, in poll_progress()
139 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
158 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
169 self: Pin<&mut Self>, in poll_download()
178 self: Pin<&mut Self>, in poll_progress()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/downloader/ |
| H A D | operator.rs | 28 self: Pin<&mut Self>, in poll_download()
38 self: Pin<&mut Self>, in poll_progress()
81 mut self: Pin<&mut Self>, in poll_download()
89 mut self: Pin<&mut Self>, in poll_progress()
109 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
127 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
138 self: Pin<&mut Self>, in poll_download()
150 self: Pin<&mut Self>, in poll_progress()
|