| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/metrics/ |
| D | runtime.rs | 56 pub fn workers_num(&self) -> usize { in workers_num()
79 pub fn searching_workers_num(&self) -> Option<usize> { in searching_workers_num()
102 pub fn active_workers_num(&self) -> Option<usize> { in active_workers_num()
125 pub fn idle_workers_list(&self) -> Option<Vec<usize>> { in idle_workers_list()
148 pub fn park_workers_list(&self) -> Option<Vec<usize>> { in park_workers_list()
171 pub fn active_workers_list(&self) -> Option<Vec<usize>> { in active_workers_list()
232 pub fn global_queue_depth(&self) -> usize { in global_queue_depth()
255 pub fn global_queue_total_task_count(&self) -> usize { in global_queue_total_task_count()
278 pub fn worker_task_len(&self, index: u8) -> Option<usize> { in worker_task_len()
309 pub fn worker_total_task_count(&self, index: u8) -> Option<usize> { in worker_total_task_count()
[all …]
|
| /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 | 31 async fn test_future(num: usize) -> usize { in test_future()
36 async fn test_multi_future(i: usize, j: usize) -> usize { in test_multi_future()
44 async fn test_nested_future(i: usize, j: usize) -> usize { in test_nested_future()
|
| /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/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_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/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_runtime/ylong_io/src/sys/linux/tcp/ |
| D | stream.rs | 176 pub fn peek(&self, buf: &mut [u8]) -> io::Result<usize> { in peek()
182 fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> { in read()
186 fn read_vectored(&mut self, bufs: &mut [IoSliceMut<'_>]) -> io::Result<usize> { in read_vectored()
192 fn write(&mut self, buf: &[u8]) -> io::Result<usize> { in write()
196 fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> io::Result<usize> { in write_vectored()
206 fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> { in read()
211 fn read_vectored(&mut self, bufs: &mut [IoSliceMut<'_>]) -> io::Result<usize> { in read_vectored()
218 fn write(&mut self, buf: &[u8]) -> io::Result<usize> { in write()
223 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 | 248 pub fn encode(&mut self, dst: &mut [u8]) -> Result<usize, HttpError> { in encode()
308 fn method_encode(&mut self, dst: &mut [u8]) -> Result<usize, HttpError> { in method_encode()
321 fn method_sp_encode(&mut self, dst: &mut [u8]) -> Result<usize, HttpError> { in method_sp_encode()
335 fn uri_encode(&mut self, dst: &mut [u8]) -> Result<usize, HttpError> { in uri_encode()
348 fn uri_sp_encode(&mut self, dst: &mut [u8]) -> Result<usize, HttpError> { in uri_sp_encode()
361 fn version_encode(&mut self, dst: &mut [u8]) -> Result<usize, HttpError> { in version_encode()
374 fn version_crlf_encode(&mut self, dst: &mut [u8]) -> Result<usize, HttpError> { in version_crlf_encode()
387 fn header_encode(&mut self, dst: &mut [u8]) -> Result<usize, HttpError> { in header_encode()
400 fn header_crlf_encode(&mut self, dst: &mut [u8]) -> Result<usize, HttpError> { in header_crlf_encode()
427 fn encode(&mut self, buf: &mut [u8]) -> TokenResult<usize> { in encode()
[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_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_runtime/src/executor/ |
| D | sleeper.rs | 38 pub fn pop_worker(&self) -> Option<usize> { in pop_worker()
77 pub(crate) fn load_state(&self) -> (usize, usize) { in load_state()
118 fn load_state(&self) -> (usize, usize) { in load_state()
|
| /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/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_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()
|
| 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()
120 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()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| D | wheel.rs | 100 pub(crate) fn find_level(&self, expiration: u64) -> usize { in find_level()
156 pub(crate) fn next_expiration(&self) -> Option<(usize, usize, u64)> { in next_expiration()
169 pub(crate) fn process_expiration(&mut self, expiration: &(usize, usize, u64)) { in process_expiration()
278 pub(crate) fn next_expiration(&self, now: u64) -> Option<(usize, usize, u64)> { in next_expiration()
293 pub(crate) fn next_occupied_slot(&self, now: u64) -> Option<usize> { in next_occupied_slot()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/ |
| D | chunk.rs | 131 fn chunk_encode(&mut self, src: &[u8], dst: &mut [u8]) -> usize { in chunk_encode()
164 fn chunk_encode(&mut self, dst: &mut [u8]) -> usize { in chunk_encode()
190 fn chunk_encode(&mut self, dst: &mut [u8]) -> usize { in chunk_encode()
216 fn chunk_encode(&mut self, dst: &mut [u8]) -> usize { in chunk_encode()
224 fn data(&mut self, buf: &mut [u8]) -> Result<usize, Self::Error> { in data()
241 fn data(&mut self, buf: &mut [u8]) -> Result<usize, Self::Error> { in data()
272 ) -> Poll<Result<usize, Self::Error>> { in poll_data()
298 ) -> Poll<Result<usize, Self::Error>> { in poll_data()
353 ) -> Poll<Result<usize, Self::Error>> { in poll_data()
401 fn bytes_encode(&mut self, dst: &mut [u8]) -> usize { in bytes_encode()
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/buffered/ |
| 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()
|
| 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()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/parallel/ |
| D | slice.rs | 17 fn len(&self) -> usize { in len()
32 fn len(&self) -> usize { in len()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| D | udp.rs | 234 pub async fn send_to<A: ToSocketAddrs>(&self, buf: &[u8], target: A) -> io::Result<usize> { in send_to()
276 pub fn try_send_to(&self, buf: &[u8], target: SocketAddr) -> io::Result<usize> { in try_send_to()
314 ) -> Poll<io::Result<usize>> { in poll_send_to()
347 pub async fn recv_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in recv_from()
383 pub fn try_recv_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in try_recv_from()
409 pub async fn peek_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in peek_from()
437 pub async fn try_peek_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in try_peek_from()
961 pub async fn send(&self, buf: &[u8]) -> io::Result<usize> { in send()
1001 pub fn try_send(&self, buf: &[u8]) -> io::Result<usize> { in try_send()
1041 pub fn poll_send(&self, cx: &mut Context<'_>, buf: &[u8]) -> Poll<io::Result<usize>> { in poll_send()
[all …]
|