| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/uploader/ |
| D | operator.rs | 56 _uploaded: u64, in poll_progress()
57 _total: Option<u64>, in poll_progress()
63 fn progress<'a>(&'a mut self, uploaded: u64, total: Option<u64>) -> ProgressFuture<'a, Self> in progress()
82 uploaded: u64, in poll_progress()
83 total: Option<u64>, in poll_progress()
115 uploaded: u64, in poll_progress()
116 _total: Option<u64>, in poll_progress()
|
| D | mod.rs | 275 uploaded: u64, in upload_op_cov()
276 total: Option<u64>, in upload_op_cov()
308 _uploaded: u64, in upload_and_show_progress()
309 _total: Option<u64>, in upload_and_show_progress()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/metrics/ |
| D | runtime.rs | 236 pub fn global_queue_total_task_count(&self) -> u64 { in global_queue_total_task_count()
290 pub fn worker_total_task_count(&self, index: usize) -> Option<u64> { in worker_total_task_count()
348 pub fn steal_times(&self) -> Option<u64> { in steal_times()
373 pub fn worker_get_task_from_global_count(&self, index: usize) -> Option<u64> { in worker_get_task_from_global_count()
404 pub fn worker_push_task_to_global_count(&self, index: usize) -> Option<u64> { in worker_push_task_to_global_count()
434 pub fn fd_registered_count(&self) -> u64 { in fd_registered_count()
454 pub fn io_driver_ready_count(&self) -> u64 { in io_driver_ready_count()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
| D | frame.rs | 108 pub fn new(ty: u64, len: u64, payload: Payload) -> Self { in new()
112 pub fn frame_type(&self) -> &u64 { in frame_type()
116 pub fn frame_len(&self) -> &u64 { in frame_len()
173 pub fn get_max_fied_section_size(&self) -> &Option<u64> { in get_max_fied_section_size()
178 pub fn get_qpack_max_table_capacity(&self) -> &Option<u64> { in get_qpack_max_table_capacity()
183 pub fn get_qpack_block_stream(&self) -> &Option<u64> { in get_qpack_block_stream()
188 pub fn get_connect_protocol_enabled(&self) -> &Option<u64> { in get_connect_protocol_enabled()
192 pub fn get_h3_datagram(&self) -> &Option<u64> { in get_h3_datagram()
215 pub fn get_push_id(&self) -> &u64 { in get_push_id()
241 pub fn new(push_id: u64, header: Vec<u8>) -> Self { in new()
[all …]
|
| D | octets.rs | 97 pub fn into_u64(&mut self) -> Result<u64> { in into_u64()
115 pub fn get_varint(&mut self) -> Result<u64> { in get_varint()
250 pub fn write_varint_with_len(&mut self, value: u64, len: usize) -> Result<usize> { in write_varint_with_len()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/downloader/ |
| D | operator.rs | 40 _downloaded: u64, in poll_progress()
41 _total: Option<u64>, in poll_progress()
64 fn progress<'a>(&'a mut self, downloaded: u64, total: Option<u64>) -> ProgressFuture<'a, Self> in progress()
91 downloaded: u64, in poll_progress()
92 total: Option<u64>, in poll_progress()
152 downloaded: u64, in poll_progress()
153 _total: Option<u64>, in poll_progress()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| D | async_seek.rs | 42 ) -> Poll<io::Result<u64>>; in poll_seek()
53 ) -> Poll<io::Result<u64>> { in poll_seek()
63 ) -> Poll<io::Result<u64>> { in poll_seek()
73 ) -> Poll<io::Result<u64>> { in poll_seek()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| D | wheel.rs | 71 pub(crate) fn expiration(&self) -> u64 { in expiration()
76 pub(crate) fn set_expiration(&mut self, expiration: u64) { in set_expiration()
90 pub(crate) fn duration(&self) -> u64 { in duration()
94 pub(crate) fn set_duration(&mut self, duration: u64) { in set_duration()
182 pub(crate) fn elapsed(&self) -> u64 { in elapsed()
187 pub(crate) fn set_elapsed(&mut self, elapsed: u64) { in set_elapsed()
193 pub(crate) fn find_level(expiration: u64, elapsed: u64) -> usize { in find_level()
220 pub(crate) fn insert(&mut self, mut clock_entry: NonNull<Clock>) -> Result<u64, Error> { in insert()
387 fn calculate_deadline(slot: usize, level: usize, now: u64) -> u64 { in calculate_deadline()
424 fn slot_range(level: usize) -> u64 { in slot_range()
|
| D | driver.rs | 53 pub(crate) fn timer_register(&self, clock_entry: NonNull<Clock>) -> Result<u64, Error> { in timer_register()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ffi/ |
| D | mod.rs | 31 pub(crate) fn OPENSSL_init_ssl(opts: u64, settings: *const OPENSSL_INIT_SETTINGS) -> c_int; in OPENSSL_init_ssl()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/task_helpers/ |
| D | mod.rs | 84 pub fn recur_fibbo(a: u64) -> u64 { in recur_fibbo()
91 pub fn fibbo(upper: usize) -> u64 { in fibbo()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/examples/ |
| D | ylong_tokio_schedule.rs | 19 fn recur_fibbo(a: u64) -> u64 { in recur_fibbo()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| D | queue.rs | 111 pub(crate) fn count(&self) -> u64 { in count()
116 pub(crate) fn task_from_global_count(&self) -> u64 { in task_from_global_count()
121 pub(crate) fn task_to_global_count(&self) -> u64 { in task_to_global_count()
159 fn count(&self) -> u64 { in count()
165 fn task_from_global_count(&self) -> u64 { in task_from_global_count()
171 fn task_to_global_count(&self) -> u64 { in task_to_global_count()
546 pub(crate) fn get_count(&self) -> u64 { in get_count()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| D | http_body.rs | 59 pub(crate) fn text(len: u64, pre: &[u8], io: BoxStreamData) -> Self { in text()
86 pub(crate) fn new(len: u64, pre: &[u8], io: BoxStreamData) -> Self { in new()
|
| /commonlibrary/c_utils/base/src/rust/ |
| D | directory_ex.rs | 88 pub fn GetFolderSize(path: &CxxString) -> u64; in GetFolderSize()
|
| /commonlibrary/rust/ylong_json/src/value/ |
| D | number.rs | 100 pub fn try_as_u64(&self) -> Result<u64, Error> { in try_as_u64()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| D | driver.rs | 107 pub(crate) fn get_registered_count(&self) -> u64 { in get_registered_count()
115 pub(crate) fn get_ready_count(&self) -> u64 { in get_ready_count()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/buffered/ |
| D | async_buf_writer.rs | 300 ) -> Poll<io::Result<u64>> { in poll_seek()
|
| D | async_buf_reader.rs | 225 ) -> Poll<std::io::Result<u64>> { in poll_seek()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/config/ |
| D | settings.rs | 268 pub fn min_speed(mut self, min: u64, secs: u64) -> Self { in min_speed()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/ |
| D | async_dir.rs | 273 pub async fn copy<P: AsRef<Path>, Q: AsRef<Path>>(from: P, to: Q) -> io::Result<u64> { in copy()
|
| D | async_file.rs | 380 ) -> Poll<io::Result<u64>> { in poll_seek()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/ |
| D | simple.rs | 100 pub fn total_bytes(&self) -> Option<u64> { in total_bytes()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| D | http_body.rs | 278 len: u64, in new()
|