| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| D | singleton_runtime.rs | 21 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()
|
| D | spawn.rs | 14 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()
|
| 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()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/ |
| D | file_buf.rs | 33 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()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/metrics/ |
| D | runtime.rs | 56 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()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/examples/ |
| D | ylong_tokio_schedule.rs | 34 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()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/ |
| D | core.rs | 77 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()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/ |
| D | integer.rs | 24 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()
|
| 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()
258 ) -> (usize, usize, Option<([u8; 1024], usize)>) { in encode() argument
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| D | read_buf.rs | 51 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()
|
| D | async_buf_read.rs | 47 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()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
| D | octets.rs | 140 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()
250 pub fn write_varint_with_len(&mut self, value: u64, len: usize) -> Result<usize> { in write_varint_with_len()
[all …]
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h1/request/ |
| D | encoder.rs | 251 pub fn encode(&mut self, dst: &mut [u8]) -> Result<usize, HttpError> { in encode()
310 fn method_encode(&mut self, dst: &mut [u8]) -> Result<usize, HttpError> { in method_encode()
323 fn method_sp_encode(&mut self, dst: &mut [u8]) -> Result<usize, HttpError> { in method_sp_encode()
337 fn uri_encode(&mut self, dst: &mut [u8]) -> Result<usize, HttpError> { in uri_encode()
350 fn uri_sp_encode(&mut self, dst: &mut [u8]) -> Result<usize, HttpError> { in uri_sp_encode()
363 fn version_encode(&mut self, dst: &mut [u8]) -> Result<usize, HttpError> { in version_encode()
376 fn version_crlf_encode(&mut self, dst: &mut [u8]) -> Result<usize, HttpError> { in version_crlf_encode()
389 fn header_encode(&mut self, dst: &mut [u8]) -> Result<usize, HttpError> { in header_encode()
402 fn header_crlf_encode(&mut self, dst: &mut [u8]) -> Result<usize, HttpError> { in header_crlf_encode()
429 fn encode(&mut self, buf: &mut [u8]) -> TokenResult<usize> { in encode()
[all …]
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h2/ |
| D | encoder.rs | 115 pub fn new(max_frame_size: usize, use_huffman: bool) -> Self { in new()
184 pub fn encode(&mut self, buf: &mut [u8]) -> Result<usize, FrameEncoderErr> { in encode()
344 pub fn update_max_frame_size(&mut self, size: usize) { in update_max_frame_size()
350 pub fn update_header_table_size(&mut self, size: usize) { in update_header_table_size()
355 pub(crate) fn update_max_header_list_size(&mut self, size: usize) { in update_max_header_list_size()
374 fn encode_headers_frame(&mut self, buf: &mut [u8]) -> Result<usize, FrameEncoderErr> { in encode_headers_frame()
426 len: usize, in iterate_headers_header()
463 fn encode_headers_payload(&mut self, buf: &mut [u8]) -> Result<usize, FrameEncoderErr> { in encode_headers_payload()
485 fn encode_continuation_frames(&mut self, buf: &mut [u8]) -> Result<usize, FrameEncoderErr> { in encode_continuation_frames()
534 fn encode_data_header(&mut self, buf: &mut [u8]) -> Result<usize, FrameEncoderErr> { in encode_data_header()
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/ |
| D | stream.rs | 215 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()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/format/ |
| D | encoder.rs | 50 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()
357 pub(crate) fn encode(self, dst: &mut [u8]) -> Result<usize, ReprEncodeState> { in encode()
379 fn encode(self, dst: &mut [u8]) -> Result<usize, ReprEncodeState> { in encode()
395 fn new(index: usize, is_static: bool) -> Self { in new()
409 fn encode(self, dst: &mut [u8]) -> Result<usize, ReprEncodeState> { in encode()
431 fn encode(self, dst: &mut [u8]) -> Result<usize, ReprEncodeState> { in encode()
447 fn new(index: usize, value: Vec<u8>, is_huffman: bool, is_static: bool) -> Self { in new()
[all …]
|
| /commonlibrary/rust/ylong_json/src/reader/ |
| D | mod.rs | 38 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()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/ |
| D | stream.rs | 163 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()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/representation/ |
| D | encoder.rs | 65 pub(crate) fn encode(&mut self, dst: &mut [u8], use_huffman: bool) -> usize { in encode()
227 pub(crate) fn encode(self, dst: &mut [u8]) -> Result<usize, Self> { in encode()
254 fn encode(self, dst: &mut [u8]) -> Result<usize, ReprEncodeState> { in encode()
265 fn new(index: usize, value: Vec<u8>, is_huffman: bool) -> Self { in new()
277 fn encode(self, dst: &mut [u8]) -> Result<usize, ReprEncodeState> { in encode()
300 fn encode(self, dst: &mut [u8]) -> Result<usize, ReprEncodeState> { in encode()
311 fn new(index: usize, value: Vec<u8>, is_huffman: bool) -> Self { in new()
323 fn encode(self, dst: &mut [u8]) -> Result<usize, ReprEncodeState> { in encode()
346 fn encode(self, dst: &mut [u8]) -> Result<usize, ReprEncodeState> { in encode()
357 fn new(index: usize, value: Vec<u8>, is_huffman: bool) -> Self { in new()
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/ |
| D | token.rs | 25 impl From<Token> for usize { implementation
26 fn from(val: Token) -> usize { in from()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| D | state.rs | 44 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()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/ |
| D | datagram.rs | 168 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()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime_macros/src/ |
| D | select.rs | 44 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()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| D | ssl_stream.rs | 31 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()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/ |
| 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()
|