Home
last modified time | relevance | path

Searched refs:total_processed (Results 1 – 9 of 9) sorted by relevance

/ohos5.0/base/request/request/services/src/manage/
H A Dnotifier.rs56 let total_processed = notify_data.progress.common_data.total_processed; in progress() localVariable
58 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 …]
/ohos5.0/base/request/request/services/src/task/
H A Doperator.rs80 let total_processed = self in poll_progress_common() localVariable
86 .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()
H A Dnotify.rs48 pub(crate) total_processed: usize,
74 total_processed: 0, in new()
H A Drequest_task.rs324 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() localVariable
610 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()
H A Ddownload.rs104 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()
H A Dupload.rs82 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()
/ohos5.0/base/request/request/test/rustest/src/
H A Dlib.rs410 total_processed: u64, field
459 let total_processed = input.take_value(); in deserialize() localVariable
473 total_processed, in deserialize()
/ohos5.0/base/request/request/services/src/service/
H A Dstub.rs149 reply.write(&(tf.progress.common_data.total_processed as u64))?; in serialize_task_info()
/ohos5.0/base/request/request/services/src/service/client/
H A Dmod.rs306 &(notify_data.progress.common_data.total_processed as u64).to_le_bytes(), in handle_send_notify_data()