| /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/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/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/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_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()
186 pub fn set_filled(&mut self, n: usize) { in set_filled()
201 pub fn advance(&mut self, n: usize) { in advance()
213 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()
|
| 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()
|
| /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/fs/ |
| D | file_buf.rs | 35 pub(crate) fn remaining(&self) -> usize { in remaining()
39 pub(crate) fn append_to(&mut self, buf: &mut ReadBuf<'_>) -> usize { in append_to()
54 pub(crate) fn append(&mut self, other: &[u8]) -> usize { in append()
62 pub(crate) fn reserve(&mut self, size: usize) { in reserve()
69 pub(crate) fn read<R: Read>(&mut self, io: &mut R) -> io::Result<usize> { in read()
|
| /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 …]
|
| 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 …]
|
| /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 | 172 fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> { in read()
176 fn read_vectored(&mut self, bufs: &mut [IoSliceMut<'_>]) -> io::Result<usize> { in read_vectored()
182 fn write(&mut self, buf: &[u8]) -> io::Result<usize> { in write()
186 fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> io::Result<usize> { in write_vectored()
195 fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> { in read()
200 fn read_vectored(&mut self, bufs: &mut [IoSliceMut<'_>]) -> io::Result<usize> { in read_vectored()
207 fn write(&mut self, buf: &[u8]) -> io::Result<usize> { in write()
212 fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> io::Result<usize> { in write_vectored()
|
| /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/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/hpack/representation/ |
| D | encoder.rs | 64 pub(crate) fn encode(&mut self, dst: &mut [u8]) -> usize { in encode()
222 pub(crate) fn encode(self, dst: &mut [u8]) -> Result<usize, Self> { in encode()
249 fn encode(self, dst: &mut [u8]) -> Result<usize, ReprEncodeState> { in encode()
260 fn new(index: usize, value: Vec<u8>, is_huffman: bool) -> Self { in new()
272 fn encode(self, dst: &mut [u8]) -> Result<usize, ReprEncodeState> { in encode()
295 fn encode(self, dst: &mut [u8]) -> Result<usize, ReprEncodeState> { in encode()
306 fn new(index: usize, value: Vec<u8>, is_huffman: bool) -> Self { in new()
318 fn encode(self, dst: &mut [u8]) -> Result<usize, ReprEncodeState> { in encode()
341 fn encode(self, dst: &mut [u8]) -> Result<usize, ReprEncodeState> { in encode()
352 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/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_http/ylong_http/src/h2/ |
| D | encoder.rs | 101 pub fn new(max_frame_size: usize, max_header_list_size: usize) -> Self { in new()
159 pub fn encode(&mut self, buf: &mut [u8]) -> Result<usize, FrameEncoderErr> { in encode()
319 pub fn update_max_frame_size(&mut self, size: usize) { in update_max_frame_size()
324 pub fn update_header_table_size(&mut self, size: usize) { in update_header_table_size()
329 fn encode_headers_frame(&mut self, buf: &mut [u8]) -> Result<usize, FrameEncoderErr> { in encode_headers_frame()
397 fn encode_headers_payload(&mut self, buf: &mut [u8]) -> Result<usize, FrameEncoderErr> { in encode_headers_payload()
433 fn encode_continuation_frames(&mut self, buf: &mut [u8]) -> Result<usize, FrameEncoderErr> { in encode_continuation_frames()
500 fn encode_data_header(&mut self, buf: &mut [u8]) -> Result<usize, FrameEncoderErr> { in encode_data_header()
554 fn encode_data_payload(&mut self, buf: &mut [u8]) -> Result<usize, FrameEncoderErr> { in encode_data_payload()
583 fn encode_padding(&mut self, buf: &mut [u8]) -> Result<usize, FrameEncoderErr> { in encode_padding()
[all …]
|
| /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_http/ylong_http_client/src/sync_impl/ |
| D | http_body.rs | 60 pub(crate) fn text(len: usize, pre: &[u8], io: BoxStreamData) -> Self { in text()
87 pub(crate) fn new(len: usize, pre: &[u8], io: BoxStreamData) -> Self { in new()
99 fn data(&mut self, buf: &mut [u8]) -> Result<usize, Self::Error> { in data()
122 fn data(&mut self, buf: &mut [u8]) -> Result<usize, HttpClientError> { in data()
215 fn data(&mut self, buf: &mut [u8]) -> Result<usize, HttpClientError> { in data()
277 fn merge_chunks(&mut self, buf: &mut [u8]) -> Result<(usize, bool), HttpClientError> { in merge_chunks()
|
| 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()
|