| /commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
| D | encoder.rs | 110 pub fn set_max_blocked_stream_size(&mut self, max_blocked: usize) { in set_max_blocked_stream_size()
184 ) -> Result<(usize, usize), H3Error> { in encode() argument
288 pub(crate) fn repr_offset(&self) -> usize { in repr_offset()
292 pub(crate) fn inst_offset(&self) -> usize { in inst_offset()
296 pub(crate) fn repr_offset_inc(&mut self, increment: usize) { in repr_offset_inc()
300 pub(crate) fn inst_offset_inc(&mut self, increment: usize) { in inst_offset_inc()
304 pub(crate) fn remaining_repr(&self) -> usize { in remaining_repr()
308 pub(crate) fn remaining_inst(&self) -> usize { in remaining_inst()
314 pub fn frame_size(&self) -> usize { in frame_size()
318 pub fn inst_size(&self) -> usize { in inst_size()
[all …]
|
| D | octets.rs | 98 pub fn cap(&self) -> usize { in cap()
102 pub fn index(&self) -> usize { in index()
152 pub fn remaining(&self) -> usize { in remaining()
156 pub fn index(&self) -> usize { in index()
160 pub fn idx_add(&mut self, offset: usize) { in idx_add()
166 pub fn write_u8(&mut self, value: u8) -> Result<usize> { in write_u8()
170 pub fn write_u16(&mut self, value: u16) -> Result<usize> { in write_u16()
174 pub fn write_u32(&mut self, value: u32) -> Result<usize> { in write_u32()
178 pub fn write_u64(&mut self, value: u64) -> Result<usize> { in write_u64()
184 pub fn write_varint(&mut self, value: u64) -> Result<usize> { in write_varint()
[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()
|
| /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/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/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_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/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/h3/qpack/ |
| D | table.rs | 106 pub(crate) fn size(&self) -> usize { in size()
137 pub(crate) fn update_capacity(&mut self, new_cap: usize) -> Option<usize> { in update_capacity()
153 pub(crate) fn insert_count(&self) -> usize { in insert_count()
157 pub(crate) fn track_field(&mut self, index: usize) { in track_field()
165 pub(crate) fn untracked_field(&mut self, index: usize) { in untracked_field()
174 pub(crate) fn increase_known_receive_count(&mut self, increment: usize) { in increase_known_receive_count()
180 pub(crate) fn size(&self) -> usize { in size()
184 pub(crate) fn capacity(&self) -> usize { in capacity()
188 pub(crate) fn can_evict(&mut self, required: usize) -> Option<usize> { in can_evict()
208 pub(crate) fn evict_drained(&mut self, size: usize) { in evict_drained()
[all …]
|
| D | integer.rs | 23 pub(crate) fn index(pre: u8, index: usize, mask: u8) -> Self { in index() method
28 pub(crate) fn length(length: usize, is_huffman: bool) -> Self { in length() method
51 pub(crate) fn first_byte(byte: u8, mask: u8) -> Result<usize, Self> { in first_byte()
65 pub(crate) fn next_byte(&mut self, byte: u8) -> Result<Option<usize>, QpackError> { in next_byte()
95 pub(crate) fn new(pre: u8, i: usize, mask: u8) -> Self { in new()
105 pub(crate) fn get_index(&self) -> usize { in get_index()
|
| /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/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()
381 fn encode_headers_frame(&mut self, buf: &mut [u8]) -> Result<usize, FrameEncoderErr> { in encode_headers_frame()
430 len: usize, in iterate_headers_header()
467 fn encode_headers_payload(&mut self, buf: &mut [u8]) -> Result<usize, FrameEncoderErr> { in encode_headers_payload()
486 fn encode_continuation_frames(&mut self, buf: &mut [u8]) -> Result<usize, FrameEncoderErr> { in encode_continuation_frames()
532 fn encode_data_header(&mut self, buf: &mut [u8]) -> Result<usize, FrameEncoderErr> { in encode_data_header()
[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_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/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_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_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/h3/qpack/format/ |
| D | decoder.rs | 40 ) -> Result<Option<(usize, EncoderInstruction)>, QpackError> { in decode()
78 ) -> Result<Option<(usize, Representation)>, QpackError> { in decode()
200 fn decode(self, buf: &[u8]) -> DecResult<(usize, Representation), ReprDecodeState> { in decode()
229 fn decode(self, buf: &[u8]) -> DecResult<(usize, EncoderInstruction), InstDecodeState> { in decode()
285 fn decode(self, buf: &[u8]) -> DecResult<(usize, Representation), ReprDecodeState> { in decode()
340 ) -> DecResult<(usize, RequireInsertCount, bool, DeltaBase), FSPInner> { in decode()
526 fn decode(mut self, buf: &[u8]) -> DecResult<(usize, Vec<u8>), LiteralString> { in decode()
572 fn decode(mut self, buf: &[u8]) -> DecResult<(usize, Vec<u8>), LiteralString> { in decode()
651 fn decode(self, buf: &[u8]) -> DecResult<(usize, Vec<u8>), LiteralString> { in decode()
692 fn decode(mut self, buf: &[u8]) -> DecResult<(usize, Vec<u8>), LiteralString> { in decode()
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| D | wake_list.rs | 65 pub fn insert(&self, waker: ListItem) -> usize { in insert()
116 fn get_wait_permit(&self) -> usize { in get_wait_permit()
119 fn change_permit(&self, curr: usize, next: usize) -> Result<usize, usize> { in change_permit() argument
177 pub(crate) fn remove_permit(&mut self, key: usize, wait_permit: usize) -> bool { in remove_permit()
|