| /ohos5.0/foundation/communication/ipc/interfaces/innerkits/rust/src/parcel/ |
| H A D | msg.rs | 373 pub fn size(&self) -> usize { in size()
388 pub fn writable(&self) -> usize { in writable()
402 pub fn readable(&self) -> usize { in readable()
413 pub fn offset(&self) -> usize { in offset()
428 pub fn capacity(&self) -> usize { in capacity()
441 pub fn max_capacity(&self) -> usize { in max_capacity()
456 pub fn write_position(&mut self) -> usize { in write_position()
473 pub fn read_position(&mut self) -> usize { in read_position()
603 pub fn skip_read(&mut self, size: usize) { in skip_read()
697 fn get_pad_size(size: usize) -> usize { in get_pad_size()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/ |
| H A D | encoder.rs | 31 pub(crate) fn new(max_size: usize, use_huffman: bool) -> Self { in new()
40 pub(crate) fn update_max_dynamic_table_size(&self, _max_size: usize) {} in update_max_dynamic_table_size()
49 pub(crate) fn encode(&mut self, dst: &mut [u8]) -> usize { in encode()
|
| H A D | integer.rs | 55 pub(crate) fn first_byte(byte: u8, mask: u8) -> Result<usize, Self> { in first_byte()
69 pub(crate) fn next_byte(&mut self, byte: u8) -> Result<Option<usize>, H2Error> { in next_byte()
113 pub(crate) fn new(i: usize, mask: u8, pre: u8) -> Self { in new()
|
| H A D | decoder.rs | 41 pub(crate) fn with_max_size(header_table_size: usize, max_header_list_size: usize) -> Self { in with_max_size()
85 pub(crate) fn update_header_list_size(&mut self, size: usize) { in update_header_list_size()
103 header_list_size: usize, in new()
176 pub(crate) fn update_size(&mut self, addition: usize) { in update_size()
199 fn header_line_length(key_size: usize, value_size: usize) -> usize { in header_line_length()
|
| /ohos5.0/base/sensors/sensor/rust/utils/socket_ipc_rust_ffi/src/ |
| H A D | stream_buffer.rs | 133 fn unread_size(&self) -> usize { in unread_size()
152 pub(crate) fn size(&self) -> usize { in size()
158 fn get_available_buf_size(&self) -> usize { in get_available_buf_size()
340 fn r_count(&self) -> usize { in r_count()
343 fn w_count(&self) -> usize { in w_count()
346 fn w_pos(&self) -> usize { in w_pos()
349 fn r_pos(&self) -> usize { in r_pos()
358 fn set_r_pos(&mut self, r_pos: usize) { in set_r_pos()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | async_pool.rs | 30 async fn test_future(num: usize) -> usize { in test_future()
35 async fn test_multi_future(i: usize, j: usize) -> usize { in test_multi_future()
43 async fn test_nested_future(i: usize, j: usize) -> usize { in test_nested_future()
79 fn get_other_thread_affinity(pid: i32) -> Vec<usize> { in get_other_thread_affinity()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/parallel/ |
| H A D | slice.rs | 17 fn len(&self) -> usize { in len()
32 fn len(&self) -> usize { in len()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | sleeper.rs | 39 pub fn pop_worker_by_id(&self, worker_index: &usize) { in pop_worker_by_id()
51 pub fn pop_worker(&self, last_search: bool) -> Option<usize> { in pop_worker()
139 fn load_state(&self) -> (usize, usize) { in load_state()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/buffered/ |
| H A D | async_buf_writer.rs | 72 pub fn with_capacity(cap: usize, inner: W) -> AsyncBufWriter<W> { in with_capacity()
169 pub fn capacity(&self) -> usize { in capacity()
210 ) -> Poll<io::Result<usize>> { in poll_write()
228 ) -> Poll<io::Result<usize>> { in poll_write_vectored()
324 fn consume(self: Pin<&mut Self>, amt: usize) { in consume()
|
| H A D | async_buf_reader.rs | 74 pub fn with_capacity(capacity: usize, inner: R) -> AsyncBufReader<R> { in with_capacity()
161 pub fn capacity(&self) -> usize { in capacity()
214 fn consume(self: Pin<&mut Self>, amt: usize) { in consume()
256 ) -> Poll<std::io::Result<usize>> { in poll_write()
265 ) -> Poll<std::io::Result<usize>> { in poll_write_vectored()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/format/ |
| H A D | decoder.rs | 47 ) -> Result<Option<(usize, EncoderInstruction)>, H3errorQpack> { in decode()
86 ) -> Result<Option<(usize, Representation)>, H3errorQpack> { in decode()
210 fn decode(self, buf: &[u8]) -> DecResult<(usize, Representation), ReprDecodeState> { in decode()
239 fn decode(self, buf: &[u8]) -> DecResult<(usize, EncoderInstruction), InstDecodeState> { in decode()
297 fn decode(self, buf: &[u8]) -> DecResult<(usize, Representation), ReprDecodeState> { in decode()
354 ) -> DecResult<(usize, RequireInsertCount, bool, DeltaBase), FSPInner> { in decode()
539 fn decode(mut self, buf: &[u8]) -> DecResult<(usize, Vec<u8>), LiteralString> { in decode()
585 fn decode(mut self, buf: &[u8]) -> DecResult<(usize, Vec<u8>), LiteralString> { in decode()
660 fn decode(self, buf: &[u8]) -> DecResult<(usize, Vec<u8>), LiteralString> { in decode()
701 fn decode(mut self, buf: &[u8]) -> DecResult<(usize, Vec<u8>), LiteralString> { in decode()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/examples/ |
| H A D | ylong_runtime_par_iter.rs | 32 fn fibbo(n: usize) -> usize { in fibbo()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| H A D | semaphore_inner.rs | 77 pub(crate) fn current_permits(&self) -> usize { in current_permits()
101 pub(crate) fn release_multi(&self, mut permits: usize) { in release_multi()
160 curr: &mut usize, in update_permit()
161 permit_num: usize, in update_permit()
182 waker_index: &mut Option<usize>, in poll_acquire()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| H A D | ylong_tokio_multi_threaded.rs | 94 fn iter(runtime: Arc<Runtime>, sender: mpsc::SyncSender<()>, n: usize) { in chained_spawn()
138 fn iter(sender: mpsc::SyncSender<()>, n: usize) { in chained_spawn()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| H A D | stdio.rs | 50 pub(crate) fn len(&self) -> usize { in len()
68 pub(crate) fn clone_from(&mut self, buf: &[u8]) -> usize { in clone_from()
74 pub(crate) fn clone_into(&mut self, buf: &mut ReadBuf<'_>) -> usize { in clone_into()
86 pub(crate) fn read_from<T: Read>(&mut self, std: &mut T) -> io::Result<usize> { in read_from()
|
| H A D | async_write.rs | 44 ) -> Poll<io::Result<usize>>; in poll_write()
54 ) -> Poll<io::Result<usize>> { in poll_write_vectored()
155 ) -> Poll<Result<usize, io::Error>> { in poll_write()
163 ) -> Poll<Result<usize, io::Error>> { in poll_write_vectored()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
| H A D | encoder.rs | 69 qpack_drain_index: usize, in new()
70 stream_id: usize, in new()
125 fn encode_payload(&self, buf: &mut OctetsMut, data: &[u8], start: usize) -> usize { in encode_payload()
134 fn encode_frame(&self, frame_ref: Option<&Frame>, buf: &mut [u8]) -> Result<usize, Err> { in encode_frame()
146 pub fn encode(&mut self, buf: &mut [u8]) -> Result<usize, Err> { in encode()
386 pub(crate) fn update_dyn_size(&mut self, max_size: usize) { in update_dyn_size()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/ |
| H A D | table.rs | 117 pub(crate) fn size(&self) -> usize { in size()
121 pub(crate) fn capacity(&self) -> usize { in capacity()
125 pub(crate) fn max_entries(&self) -> usize { in max_entries()
141 insert_length: &usize, in have_enough_space()
165 pub(crate) fn update_size(&mut self, max_size: usize) { in update_size()
700 pub(crate) fn len(&self) -> usize { in len()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/ |
| H A D | wrapper.rs | 46 fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> { in read()
60 fn write(&mut self, buf: &[u8]) -> io::Result<usize> { in write()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/ |
| H A D | iocp.rs | 47 token: usize, in add_handle()
119 pub(crate) fn new(bytes: u32, token: usize, overlapped: *mut Overlapped) -> Self { in new()
139 pub fn token(&self) -> usize { in token()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/sys/unix/ |
| H A D | pipe.rs | 35 fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> { in read()
41 fn write(&mut self, buf: &[u8]) -> io::Result<usize> { in write()
45 fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> io::Result<usize> { in write_vectored()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/ |
| H A D | datagram.rs | 166 pub fn recv_from(&self, buf: &mut [u8]) -> io::Result<(usize, net::SocketAddr)> { in recv_from()
184 pub fn recv(&self, buf: &mut [u8]) -> io::Result<usize> { in recv()
203 pub fn send_to<P: AsRef<Path>>(&self, buf: &[u8], path: P) -> io::Result<usize> { in send_to()
221 pub fn send(&self, buf: &[u8]) -> io::Result<usize> { in send()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/body/ |
| H A D | chunk.rs | 164 fn chunk_encode(&mut self, dst: &mut [u8]) -> usize { in chunk_encode()
170 fn chunk_encode(&mut self, dst: &mut [u8]) -> usize { in chunk_encode()
198 ) -> Poll<Result<usize, Error>> { in poll_partial()
272 ) -> Poll<Result<usize, Self::Error>> { in poll_data()
298 ) -> Poll<Result<usize, Self::Error>> { in poll_data()
565 fn set_chunk_idx(&mut self, num: usize) { in set_chunk_idx()
632 fn write(&mut self) -> Token<usize> { in write()
815 fn set_id(&mut self, id: usize) { in set_id()
824 pub fn id(&self) -> usize { in id()
836 pub fn size(&self) -> usize { in size()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| H A D | http_body.rs | 109 ) -> Poll<Result<usize, Self::Error>> { in poll_data()
207 ) -> Poll<Result<usize, HttpClientError>> { in data()
234 read: usize, in poll_read_io()
236 ) -> Poll<Result<usize, HttpClientError>> { in poll_read_io()
297 ) -> Poll<Result<usize, HttpClientError>> { in data()
328 read: usize, in read_remaining()
329 ) -> Option<Poll<Result<usize, HttpClientError>>> { in read_remaining()
354 read: usize, in poll_read_io()
355 ) -> Poll<Result<usize, HttpClientError>> { in poll_read_io()
424 ) -> Poll<Result<usize, HttpClientError>> { in data()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| H A D | udp.rs | 274 pub fn try_send_to(&self, buf: &[u8], target: SocketAddr) -> io::Result<usize> { in try_send_to()
312 ) -> Poll<io::Result<usize>> { in poll_send_to()
345 pub async fn recv_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in recv_from()
381 pub fn try_recv_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in try_recv_from()
433 pub fn try_peek_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in try_peek_from()
957 pub async fn send(&self, buf: &[u8]) -> io::Result<usize> { in send()
997 pub fn try_send(&self, buf: &[u8]) -> io::Result<usize> { in try_send()
1077 pub async fn recv(&self, buf: &mut [u8]) -> io::Result<usize> { in recv()
1122 pub fn try_recv(&self, buf: &mut [u8]) -> io::Result<usize> { in try_recv()
1211 pub async fn peek(&self, buf: &mut [u8]) -> io::Result<usize> { in peek()
[all …]
|