Searched refs:total_processed (Results 1 – 9 of 9) sorted by relevance
56 let total_processed = notify_data.progress.common_data.total_processed; in progress() localVariable58 if total_processed == 0 && file_total_size < 0 { in progress()247 data.progress.common_data.total_processed in ut_notify_progress()251 previous = data.progress.common_data.total_processed; in ut_notify_progress()292 data.progress.common_data.total_processed in ut_notify_pause_resume()294 assert_eq!(data.progress.common_data.total_processed, 0); in ut_notify_pause_resume()305 data.progress.common_data.total_processed in ut_notify_pause_resume()307 assert_eq!(data.progress.common_data.total_processed, 0); in ut_notify_pause_resume()342 data.progress.common_data.total_processed in ut_notify_remove()380 data.progress.common_data.total_processed in ut_notify_completed()[all …]
80 let total_processed = self in poll_progress_common() localVariable86 .total_processed as u64; in poll_progress_common()98 self.last_size = total_processed; in poll_progress_common()100 && ((total_processed - self.last_size) > speed_limit * SPEED_LIMIT_INTERVAL) in poll_progress_common()104 (total_processed - self.last_size) / speed_limit - (current - self.last_time); in poll_progress_common()118 self.last_size = total_processed; in poll_progress_common()142 progress_guard.common_data.total_processed += size; in poll_write_file()
48 pub(crate) total_processed: usize,74 total_processed: 0, in new()
324 progress_guard.common_data.total_processed = 0; in clear_downloaded_file()609 let total_processed = self.progress.lock().unwrap().common_data.total_processed as u64; in background_notify() localVariable610 if file_total_size <= 0 || total_processed == 0 { in background_notify()630 let percent = total_processed * 100 / (file_total_size as u64); in background_notify()
104 progress.common_data.total_processed = downloaded; in prepare_download()564 progress.common_data.total_processed = 321223; in ut_download_invalid_task()575 task.progress.lock().unwrap().common_data.total_processed as u64 in ut_download_invalid_task()611 progress.common_data.total_processed = 321223; in ut_download_sizes()
82 progress_guard.common_data.total_processed += upload_size; in poll_read()101 progress_guard.common_data.total_processed += upload_size; in poll_read()253 progress.common_data.total_processed = progress.processed.iter().take(index).sum(); in prepare_single_upload()
410 total_processed: u64, field459 let total_processed = input.take_value(); in deserialize() localVariable473 total_processed, in deserialize()
149 reply.write(&(tf.progress.common_data.total_processed as u64))?; in serialize_task_info()
306 &(notify_data.progress.common_data.total_processed as u64).to_le_bytes(), in handle_send_notify_data()