| /ohos5.0/base/request/request/services/src/task/ |
| H A D | operator.rs | 135 skip_size: usize, in poll_write_file()
136 ) -> Poll<Result<usize, HttpClientError>> { in poll_write_file()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/util/ |
| H A D | bit.rs | 176 pub fn as_usize(&self) -> usize { in as_usize()
214 pub fn set_by_mask(&mut self, mask: Mask, val: usize) { in set_by_mask()
232 pub fn get_by_mask(&self, mask: Mask) -> usize { in get_by_mask()
241 fn set(&mut self, val: usize) { in set()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/util/core_affinity/ |
| H A D | windows.rs | 22 fn SetThreadAffinityMask(hThread: HANDLE, dwThreadAffinityMask: usize) -> usize; in SetThreadAffinityMask()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/ |
| H A D | decoder.rs | 94 pub fn new(field_list_size: usize, table: &'a mut DynamicTable) -> Self { in new()
306 stream_id: usize, in finish()
308 ) -> Result<(Parts, Option<usize>), H3errorQpack> { in finish()
350 stream_id: usize, in stream_cancel()
352 ) -> Result<usize, H3errorQpack> { in stream_cancel()
402 insert_count: usize, in get_field_by_name_and_value()
436 fn new(field_list_size: usize, table: &'a DynamicTable, lines: &'a mut FiledLines) -> Self { in new()
569 pub(crate) fn update_size(&mut self, addition: usize) { in update_size()
583 fn field_line_length(key_size: usize, value_size: usize) -> usize { in field_line_length()
|
| H A D | encoder.rs | 110 stream_id: usize, in new()
112 draining_index: usize, in new()
141 pub fn set_capacity(&mut self, max_size: usize, encoder_buf: &mut [u8]) -> usize { in set_capacity()
210 fn get_prefix(&self, prefix_buf: &mut [u8]) -> usize { in get_prefix()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/body/ |
| H A D | empty.rs | 86 fn data(&mut self, _buf: &mut [u8]) -> Result<usize, Self::Error> { in data()
98 ) -> Poll<Result<usize, Self::Error>> { in poll_data()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
| H A D | decoder.rs | 30 field_list_size: usize, in new()
32 stream_id: usize, in new()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/ |
| H A D | stream.rs | 238 pub fn try_read(&self, buf: &mut [u8]) -> Result<usize> { in try_read()
306 pub fn try_write(&self, buf: &[u8]) -> Result<usize> { in try_write()
348 fn poll_write(self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8]) -> Poll<Result<usize>> { in poll_write()
356 ) -> Poll<Result<usize>> { in poll_write_vectored()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/common/ |
| H A D | mod.rs | 74 pub(crate) fn data_copy(src: &[u8], src_idx: &mut usize, buf: &mut [u8]) -> TokenResult<usize> { in data_copy()
125 ) -> Result<TokenStatus<&[u8], usize>, HttpError> { in consume_crlf() argument
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| H A D | http_body.rs | 98 fn data(&mut self, buf: &mut [u8]) -> Result<usize, Self::Error> { in data()
121 fn data(&mut self, buf: &mut [u8]) -> Result<usize, HttpClientError> { in data()
206 fn data(&mut self, buf: &mut [u8]) -> Result<usize, HttpClientError> { in data()
263 fn merge_chunks(&mut self, buf: &mut [u8]) -> Result<(usize, bool), HttpClientError> { in merge_chunks()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/config/tls/verifier/ |
| H A D | openssl.rs | 42 pub fn version(&self) -> Result<usize, HttpClientError> { in version()
120 pub fn cmp_pem_cert(&self, target_pem: &[u8]) -> Result<usize, HttpClientError> { in cmp_pem_cert()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| H A D | task_handle.rs | 59 fn finish(self, state: usize, output: Result<T::Output, ScheduleError>) { in finish()
107 fn set_waker_inner(&self, des_waker: Waker, cur_state: usize) -> Result<usize, usize> { in set_waker_inner() argument
131 pub(crate) fn set_waker(self, cur: usize, des_waker: &Waker) -> bool { in set_waker()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/ |
| H A D | table.rs | 106 pub(crate) fn curr_size(&self) -> usize { in curr_size()
110 pub(crate) fn max_size(&self) -> usize { in max_size()
138 pub(crate) fn update_size(&mut self, max_size: usize) { in update_size()
416 pub(crate) fn len(&self) -> usize { in len()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/examples/ |
| H A D | ylong_runtime_multi_runtimes.rs | 19 async fn test_future(num: usize) -> usize { in test_future()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| H A D | stream.rs | 189 pub fn try_read(&self, buf: &mut [u8]) -> io::Result<usize> { in try_read()
254 pub fn try_write(&self, buf: &[u8]) -> io::Result<usize> { in try_write()
527 pub async fn peek(&self, buf: &mut [u8]) -> io::Result<usize> { in peek()
613 ) -> Poll<io::Result<usize>> { in poll_write()
621 ) -> Poll<io::Result<usize>> { in poll_write_vectored()
|
| H A D | split.rs | 44 ) -> Poll<std::io::Result<usize>> { in poll_write()
52 ) -> Poll<std::io::Result<usize>> { in poll_write_vectored()
90 ) -> Poll<std::io::Result<usize>> { in poll_write()
98 ) -> Poll<std::io::Result<usize>> { in poll_write_vectored()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/ |
| H A D | mod.rs | 273 pub fn capacity(&self) -> usize { in capacity()
288 pub fn len(&self) -> usize { in len()
330 pub fn len(&self) -> usize { in len()
|
| /ohos5.0/base/sensors/sensor/rust/utils/socket_ipc_rust_ffi/src/stream_buffer/ |
| H A D | net_packet.rs | 96 fn size(&self) -> usize { in size()
99 pub(super) fn get_packet_length(&self) -> usize { in get_packet_length()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ssl/ |
| H A D | stream.rs | 117 pub(crate) fn ssl_read(&mut self, buf: &[u8]) -> Result<usize, SslError> { in ssl_read()
129 pub(crate) fn ssl_write(&mut self, buf: &[u8]) -> Result<usize, SslError> { in ssl_write()
187 fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> { in read()
215 fn write(&mut self, buf: &[u8]) -> io::Result<usize> { in write()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/encode/ |
| H A D | part.rs | 173 fn data(&mut self, buf: &mut [u8]) -> Result<usize, Self::Error> { in data()
196 ) -> Poll<Result<usize, Self::Error>> { in poll_data()
222 ) -> Poll<Result<usize, std::io::Error>> { in poll_mime_body()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/udp/ |
| H A D | udp_socket.rs | 178 pub fn send_to(&self, buf: &[u8], target: SocketAddr) -> io::Result<usize> { in send_to()
211 pub fn recv_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in recv_from()
232 pub fn peek_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in peek_from()
533 pub fn send(&self, buf: &[u8]) -> io::Result<usize> { in send()
574 pub fn recv(&self, buf: &mut [u8]) -> io::Result<usize> { in recv()
601 pub fn peek(&self, buf: &mut [u8]) -> io::Result<usize> { in peek()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/udp/ |
| H A D | udp_socket.rs | 112 pub fn send_to(&self, buf: &[u8], target: SocketAddr) -> io::Result<usize> { in send_to()
132 pub fn recv_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in recv_from()
152 pub fn peek_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in peek_from()
431 pub fn send(&self, buf: &[u8]) -> io::Result<usize> { in send()
456 pub fn recv(&self, buf: &mut [u8]) -> io::Result<usize> { in recv()
482 pub fn peek(&self, buf: &mut [u8]) -> io::Result<usize> { in peek()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| H A D | wheel.rs | 81 pub(crate) fn level(&self) -> usize { in level()
86 pub(crate) fn set_level(&mut self, level: usize) { in set_level()
193 pub(crate) fn find_level(expiration: u64, elapsed: u64) -> usize { in find_level()
387 fn calculate_deadline(slot: usize, level: usize, now: u64) -> u64 { in calculate_deadline()
403 pub(crate) fn next_occupied_slot(&self, now: u64) -> Option<usize> { in next_occupied_slot()
|
| /ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/downloader/ |
| H A D | operator.rs | 67 ) -> Poll<Result<usize, HttpClientError>>; in poll_download()
113 ) -> Poll<Result<usize, HttpClientError>> { in poll_download()
172 ) -> Poll<Result<usize, HttpClientError>> { in poll_download()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/downloader/ |
| H A D | operator.rs | 31 ) -> Poll<Result<usize, HttpClientError>>; in poll_download()
84 ) -> Poll<Result<usize, HttpClientError>> { in poll_download()
141 ) -> Poll<Result<usize, HttpClientError>> { in poll_download()
|