Home
last modified time | relevance | path

Searched defs:usize (Results 1 – 25 of 174) sorted by relevance

1234567

/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dsingleton_runtime.rs21 async fn test_future(num: usize) -> usize { in test_future()
25 async fn test_multi_future_in_async(i: usize, j: usize) -> (usize, usize) { in test_multi_future_in_async()
32 async fn test_async_in_async(i: usize, j: usize) -> (usize, usize) { in test_async_in_async()
H A Dspawn.rs14 async fn test_future(num: usize) -> usize { in test_future()
18 async fn test_multi_future_in_async(i: usize, j: usize) -> (usize, usize) { in test_multi_future_in_async()
25 async fn test_async_in_async(i: usize, j: usize) -> (usize, usize) { in test_async_in_async()
/ohos5.0/build/rust/tests/test_cxx/src/
H A Dlib.rs29 fn r_return_sum(_: usize, _: usize) -> usize; in r_return_sum()
48 fn r_return_sum(n1: usize, n2: usize) -> usize { in r_return_sum()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/examples/
H A Dylong_tokio_schedule.rs34 fn ylong_schedule_task(num: usize) { in ylong_schedule_task()
47 fn tokio_schedule_task(num: usize) { in tokio_schedule_task()
64 fn ylong_schedule_fibbo_task(num: usize) { in ylong_schedule_fibbo_task()
78 fn tokio_schedule_fibbo_task(num: usize) { in tokio_schedule_fibbo_task()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/
H A Dfile_buf.rs33 pub(crate) fn remaining(&self) -> usize { in remaining()
37 pub(crate) fn append_to(&mut self, buf: &mut ReadBuf<'_>) -> usize { in append_to()
52 pub(crate) fn append(&mut self, other: &[u8], buf_size_limit: usize) -> usize { in append()
60 pub(crate) fn reserve(&mut self, size: usize, buf_size_limit: usize) { in reserve()
67 pub(crate) fn read<R: Read>(&mut self, io: &mut R) -> io::Result<usize> { in read()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/metrics/
H A Druntime.rs56 pub fn workers_num(&self) -> usize { in workers_num()
79 pub fn park_workers_num(&self) -> Option<usize> { in park_workers_num()
104 pub fn active_workers_num(&self) -> Option<usize> { in active_workers_num()
129 pub fn park_workers_list(&self) -> Option<Vec<usize>> { in park_workers_list()
152 pub fn active_workers_list(&self) -> Option<Vec<usize>> { in active_workers_list()
213 pub fn global_queue_length(&self) -> usize { in global_queue_length()
259 pub fn worker_task_len(&self, index: usize) -> Option<usize> { in worker_task_len()
321 pub fn worker_poll_count(&self, index: usize) -> Option<usize> { in worker_poll_count()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/
H A Dcore.rs77 min_split_len: usize, in recur()
78 mut split_time: usize, in recur()
129 min_split_len: usize, in spawn_task()
130 split_time: usize, in spawn_task()
154 min_split_len: usize, in recur_ffrt()
155 mut split_time: usize, in recur_ffrt()
191 min_split_len: usize, in spawn_task_ffrt()
192 split_time: usize, in spawn_task_ffrt()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/
H A Dread_buf.rs51 filled: usize, in create()
52 initialized: usize, in create()
73 pub fn capacity(&self) -> usize { in capacity()
79 pub fn filled_len(&self) -> usize { in filled_len()
85 pub fn initialized_len(&self) -> usize { in initialized_len()
138 pub fn remaining(&self) -> usize { in remaining()
185 pub fn set_filled(&mut self, n: usize) { in set_filled()
204 pub fn advance(&mut self, n: usize) { in advance()
216 pub fn assume_init(&mut self, n: usize) { in assume_init()
H A Dasync_buf_read.rs47 fn consume(self: Pin<&mut Self>, amt: usize); in consume()
56 fn consume(mut self: Pin<&mut Self>, amt: usize) { in consume()
67 fn consume(mut self: Pin<&mut Self>, amt: usize) { in consume()
82 fn consume(self: Pin<&mut Self>, amt: usize) { in consume()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h3/
H A Doctets.rs140 pub fn cap(&self) -> usize { in cap()
162 fn new(src: &'a [u8], src_idx: &'a mut usize, dst: &'a mut [u8]) -> Self { in new()
166 fn write(&mut self) -> TokenResult<usize> { in write()
189 pub fn new(src: &'a [u8], src_idx: &'a mut usize, dst: &'a mut [u8]) -> Self { in new()
196 pub fn write_u8(&mut self, value: u8) -> Result<usize> { in write_u8()
208 pub fn write_u16(&mut self, value: u16) -> Result<usize> { in write_u16()
220 pub fn write_u32(&mut self, value: u32) -> Result<usize> { in write_u32()
232 pub fn write_u64(&mut self, value: u64) -> Result<usize> { in write_u64()
246 pub fn write_varint(&mut self, value: u64) -> Result<usize> { in write_varint()
285 pub const fn varint_len(v: u64) -> usize { in varint_len()
[all …]
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/
H A Dinteger.rs24 pub(crate) fn index(pre: u8, index: usize, mask: u8) -> Self { in index() method
29 pub(crate) fn length(length: usize, is_huffman: bool) -> Self { in length() method
34 pub(crate) fn encode(mut self, dst: &mut [u8]) -> Result<usize, Self> { in encode()
56 pub(crate) fn first_byte(byte: u8, mask: u8) -> Result<usize, Self> { in first_byte()
70 pub(crate) fn next_byte(&mut self, byte: u8) -> Result<Option<usize>, H3errorQpack> { in next_byte()
102 pub(crate) fn new(pre: u8, i: usize, mask: u8) -> Self { in new()
112 pub(crate) fn get_index(&self) -> usize { in get_index()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h1/request/
H A Dencoder.rs251 pub fn encode(&mut self, dst: &mut [u8]) -> Result<usize, HttpError> { in encode()
429 fn encode(&mut self, buf: &mut [u8]) -> TokenResult<usize> { in encode()
460 fn encode(&mut self, buf: &mut [u8]) -> TokenResult<usize> { in encode()
482 fn encode(&mut self, buf: &mut [u8]) -> TokenResult<usize> { in encode()
533 fn encode(&mut self, buf: &mut [u8]) -> TokenResult<usize> { in encode()
543 fn encode_name(&mut self, buf: &mut [u8]) -> TokenResult<usize> { in encode_name()
558 fn encode_colon(&mut self, buf: &mut [u8]) -> TokenResult<usize> { in encode_colon()
573 fn encode_value(&mut self, buf: &mut [u8]) -> TokenResult<usize> { in encode_value()
622 fn encode(&mut self, buf: &mut [u8]) -> TokenResult<usize> { in encode()
638 fn encode(&mut self, buf: &mut [u8]) -> TokenResult<usize> { in encode()
[all …]
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/
H A Dtoken.rs25 impl From<Token> for usize { implementation
26 fn from(val: Token) -> usize { in from()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/
H A Dstream.rs215 pub fn peek(&self, buf: &mut [u8]) -> io::Result<usize> { in peek()
221 fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> { in read()
225 fn read_vectored(&mut self, bufs: &mut [IoSliceMut<'_>]) -> io::Result<usize> { in read_vectored()
231 fn write(&mut self, buf: &[u8]) -> io::Result<usize> { in write()
235 fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> io::Result<usize> { in write_vectored()
245 fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> { in read()
250 fn read_vectored(&mut self, bufs: &mut [IoSliceMut<'_>]) -> io::Result<usize> { in read_vectored()
257 fn write(&mut self, buf: &[u8]) -> io::Result<usize> { in write()
262 fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> io::Result<usize> { in write_vectored()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h2/
H A Dencoder.rs426 len: usize, in iterate_headers_header()
572 payload_len: usize, in iterate_data_header()
573 len: usize, in iterate_data_header()
696 len: usize, in iterate_goaway_header()
754 len: usize, in iterate_goaway_payload()
814 len: usize, in iterate_window_update_header()
914 len: usize, in iterate_settings_header()
972 len: usize, in iterate_settings_payload()
1037 len: usize, in iterate_priority_header()
1097 len: usize, in iterate_priority_payload()
[all …]
/ohos5.0/commonlibrary/rust/ylong_json/src/reader/
H A Dmod.rs38 fn index(&self) -> usize; in index()
54 fn cached_len(&mut self) -> Option<usize>; in cached_len()
78 fn remainder_len(&self) -> usize; in remainder_len()
100 fn discard_n(&mut self, n: usize); in discard_n()
113 pub(crate) fn new(line: usize, column: usize) -> Self { in new()
119 pub(crate) fn line(&self) -> usize { in line()
125 pub(crate) fn column(&self) -> usize { in column()
/ohos5.0/base/request/request/services/src/manage/scheduler/qos/
H A Drss.rs53 pub(crate) fn m1(&self) -> usize { in m1()
57 pub(crate) fn m2(&self) -> usize { in m2()
61 pub(crate) fn m3(&self) -> usize { in m3()
/ohos5.0/base/update/updater/services/rust/hash_signed_data/src/
H A Devp.rs20 pub fn get_b64_decode_len(in_data: &[u8]) -> Result<(usize, usize), String> in get_b64_decode_len() argument
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/format/
H A Dencoder.rs50 draining_index: usize, in new()
52 insert_length: &'a mut usize, in new()
84 required_insert_count: &mut usize, in encode()
85 ) -> (usize, usize) { in encode()
395 fn new(index: usize, is_static: bool) -> Self { in new()
480 index: usize, in new()
649 fn set_index(mut self, pre: u8, index: usize, mask: u8) -> Self { in set_index()
660 fn encode(mut self, dst: &mut [u8]) -> Result<usize, Self> { in encode()
688 fn set_index(mut self, pre: u8, index: usize, mask: u8) -> Self { in set_index()
701 fn encode(mut self, dst: &mut [u8]) -> Result<usize, Self> { in encode()
[all …]
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/
H A Dstream.rs163 fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> { in read()
167 fn read_vectored(&mut self, bufs: &mut [IoSliceMut<'_>]) -> io::Result<usize> { in read_vectored()
173 fn write(&mut self, buf: &[u8]) -> io::Result<usize> { in write()
177 fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> io::Result<usize> { in write_vectored()
186 fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> { in read()
191 fn read_vectored(&mut self, bufs: &mut [IoSliceMut<'_>]) -> io::Result<usize> { in read_vectored()
198 fn write(&mut self, buf: &[u8]) -> io::Result<usize> { in write()
203 fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> io::Result<usize> { in write_vectored()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/representation/
H A Dencoder.rs265 fn new(index: usize, value: Vec<u8>, is_huffman: bool) -> Self { in new()
311 fn new(index: usize, value: Vec<u8>, is_huffman: bool) -> Self { in new()
357 fn new(index: usize, value: Vec<u8>, is_huffman: bool) -> Self { in new()
428 fn set_index(mut self, index: usize, mask: u8, pre: u8) -> Self { in set_index()
440 fn encode(mut self, dst: &mut [u8]) -> Result<usize, Self> { in encode()
483 fn encode(mut self, dst: &mut [u8]) -> Result<usize, Self> { in encode()
499 fn index(index: usize, mask: u8, pre: u8) -> Self { in index() method
505 fn length(length: usize, is_huffman: bool) -> Self { in length() method
511 fn encode(mut self, dst: &mut [u8]) -> Result<usize, Self> { in encode()
541 fn len(&self) -> usize { in len()
[all …]
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime_macros/src/
H A Dselect.rs44 fn parse_ident(ident: &Ident, idx: &mut usize, flags: &mut Flags) -> bool { in parse_ident()
69 idx: &mut usize, in parse_group()
90 fn parse_token(buf: &[TokenTree], idx: &mut usize, flags: &mut Flags, builder: &mut ParserBuilder) { in parse_token()
131 fn group_num(inner: TokenStream) -> usize { in group_num()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/
H A Dstate.rs44 pub(crate) fn ref_count(state: usize) -> usize { in ref_count()
105 pub(crate) fn dec_ref(&self) -> usize { in dec_ref()
115 pub(crate) fn get_current_state(&self) -> usize { in get_current_state()
150 pub(crate) fn turning_to_finish(&self) -> Result<usize, ErrorKind> { in turning_to_finish()
207 pub(crate) fn turn_to_scheduling(&self) -> usize { in turn_to_scheduling()
214 pub(crate) fn turn_to_un_set_waker(&self) -> Result<usize, usize> { in turn_to_un_set_waker() argument
240 pub(crate) fn turn_to_set_waker(&self) -> Result<usize, usize> { in turn_to_set_waker() argument
297 pub(crate) fn turn_to_un_join_handle(&self) -> Result<usize, ()> { in turn_to_un_join_handle()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/
H A Dssl_stream.rs31 fn read(&mut self, buf: &mut [u8]) -> std::io::Result<usize> { in read()
42 fn write(&mut self, buf: &[u8]) -> std::io::Result<usize> { in write()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/
H A Ddatagram.rs168 pub fn try_recv(&self, buf: &mut [u8]) -> Result<usize> { in try_recv()
236 pub fn try_send(&self, buf: &[u8]) -> Result<usize> { in try_send()
325 pub async fn send(&self, buf: &[u8]) -> Result<usize> { in send()
347 pub async fn send_to<P: AsRef<Path>>(&self, buf: &[u8], path: P) -> Result<usize> { in send_to()
369 pub async fn recv(&self, buf: &mut [u8]) -> Result<usize> { in recv()
391 pub async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, net::SocketAddr)> { in recv_from()

1234567