notifier.rs - OpenGrok cross reference for /base/request/request/services/src/manage/notifier.rs

Lines Matching refs:progress
53     pub(crate) fn progress(client_manager: &ClientManagerEntry, notify_data: NotifyData) {
54         let total_processed = notify_data.progress.common_data.total_processed;
55         let file_total_size: i64 = notify_data.progress.sizes.iter().sum();
169                 assert!(!data.progress.extras.is_empty());
170                 assert_eq!(data.progress.common_data.state, State::Running.repr);
171                 assert_eq!(data.progress.common_data.index, 0);
173                     data.progress.processed[0],
174                     data.progress.common_data.total_processed
177                 assert!(data.progress.common_data.total_processed >= previous);
178                 previous = data.progress.common_data.total_processed;
179                 if data.progress.common_data.total_processed == GITEE_FILE_LEN {
214             assert!(data.progress.extras.is_empty());
215             assert_eq!(data.progress.common_data.state, State::Paused.repr);
216             assert_eq!(data.progress.common_data.index, 0);
218                 data.progress.processed[0],
219                 data.progress.common_data.total_processed
221             assert_eq!(data.progress.common_data.total_processed, 0);
227             assert!(data.progress.extras.is_empty());
228             assert_eq!(data.progress.common_data.state, State::Waiting.repr);
229             assert_eq!(data.progress.common_data.index, 0);
231                 data.progress.processed[0],
232                 data.progress.common_data.total_processed
234             assert_eq!(data.progress.common_data.total_processed, 0);
264             assert!(data.progress.extras.is_empty());
265             assert_eq!(data.progress.common_data.state, State::Removed.repr);
266             assert_eq!(data.progress.common_data.index, 0);
268                 data.progress.processed[0],
269                 data.progress.common_data.total_processed
271             assert_eq!(data.progress.common_data.total_processed, 0);
302             assert!(data.progress.extras.is_empty());
303             assert_eq!(data.progress.common_data.state, State::Completed.repr);
304             assert_eq!(data.progress.common_data.index, 0);
306                 data.progress.processed[0],
307                 data.progress.common_data.total_processed
309             assert_eq!(data.progress.common_data.total_processed, 0);
340             assert!(data.progress.extras.is_empty());
341             assert_eq!(data.progress.common_data.state, State::Failed.repr);
342             assert_eq!(data.progress.common_data.index, 0);
344                 data.progress.processed[0],
345                 data.progress.common_data.total_processed
347             assert_eq!(data.progress.common_data.total_processed, 0);