Searched refs:total (Results 1 - 10 of 10) sorted by relevance
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/uploader/ |
| H A D | operator.rs | 43 /// total: Option<u64>,
52 /// the total size.
63 fn progress<'a>(&'a mut self, uploaded: u64, total: Option<u64>) -> ProgressFuture<'a, Self> in progress()
70 total, in progress()
83 total: Option<u64>, in poll_progress()
85 Pin::new(&mut **self).poll_progress(cx, uploaded, total) in poll_progress()
93 total: Option<u64>,
104 Pin::new(&mut fut.operator).poll_progress(cx, fut.uploaded, fut.total)
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | async_pool.rs | 117 let total = 1; in sdv_async_pool_001()
125 .worker_num(total) in sdv_async_pool_001()
167 /// 1. Asynchronous thread pool capacity total set to 64.
177 let total = 64; in sdv_async_pool_002()
185 .worker_num(total) in sdv_async_pool_002()
227 /// 1. Asynchronous thread pool capacity total set to 0.
237 let total = 0; in sdv_async_pool_003()
245 .worker_num(total) in sdv_async_pool_003()
287 /// 1. Asynchronous thread pool capacity total set to 65.
297 let total in sdv_async_pool_004()
[all...] |
| H A D | sync.rs | 32 total: usize,
36 TestFuture { value: 0, total: t } in create_new()
42 if self.total > self.value { in poll()
47 Poll::Ready(self.total)
|
| H A D | block_on.rs | 281 total: usize,
287 total: 1000, in create_new()
294 if self.total > self.value { in poll()
299 Poll::Ready(self.total)
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/downloader/ |
| H A D | operator.rs | 64 fn progress<'a>(&'a mut self, downloaded: u64, total: Option<u64>) -> ProgressFuture<'a, Self> in progress()
71 total, in progress()
92 total: Option<u64>, in poll_progress()
94 Pin::new(&mut **self).poll_progress(cx, downloaded, total) in poll_progress()
118 total: Option<u64>,
129 Pin::new(&mut fut.processor).poll_progress(cx, fut.downloaded, fut.total)
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| H A D | test_utils.rs | 96 let mut total = _size; variables
97 while !&buf[..total].ends_with($end.as_bytes()) {
98 let tmp_size = stream.read(&mut buf[total..]).await.expect("tcp stream read error !");
99 total += tmp_size;
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | async_pool.rs | 43 /// Number of total workers
131 // index is bounded by total worker num
161 // this index is bounded by total worker num
171 // this index is bounded by total worker num
204 // this index is bounded by total worker num in enqueue_under_ctx()
269 // The number of stealing workers should be less than half of the total worker in get_task_from_searching()
319 // this index is bounded by total worker num in steal()
368 /// Number of total threads
369 pub(crate) total: usize,
403 if *finished >= inner.total { in async_thread_proc()
[all...] |
| H A D | queue.rs | 139 /// The total number of task which has entered this LocalQueue
141 /// The total number of task which has entered this LocalQueue from
144 /// The total number of task which has entered GlobalQueue from this
158 /// Returns the total number of task which has entered this LocalQueue
163 /// Returns the total number of task which has entered this LocalQueue from
169 /// Returns the total number of task which has entered GlobalQueue from this
428 /// The total number of tasks which has entered global queue.
586 total: usize,
592 total: 1000, in create_new()
599 if self.total > sel in poll()
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http/src/h2/ |
| H A D | encoder.rs | 1955 let total = assert_encoded_data(encoder, &mut result, buf); in encode_small_frame()
1956 assert_eq!(total, 10 + 9); in encode_small_frame()
1984 let total = assert_encoded_data(&mut encoder, &mut result, &mut buf); in ut_encode_large_data_frame()
1987 assert_eq!(total, 1024 + 9 * 11); in ut_encode_large_data_frame()
2002 let total = assert_encoded_data(&mut encoder, &mut result, &mut buf); in ut_encode_large_data_frame()
2005 assert_eq!(total, 1024 + 9 * 11); in ut_encode_large_data_frame()
2013 let mut total = 0; in assert_encoded_data() variables
2016 result[total..total + size].copy_from_slice(&buf[..size]); in assert_encoded_data()
2017 total in assert_encoded_data()
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/builder/ |
| H A D | multi_thread_builder.rs | 293 assert_eq!(x.inner.total, 6); in ut_build_global()
|
Completed in 8 milliseconds