openharmony/request_request
1
0
Fork 0
mirror of https://gitee.com/openharmony/request_request synced 2024-11-30 10:32:30 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

日志补充

Browse Source 
Signed-off-by: Shenyx <shenyuxiang3@h-partners.com>
Change-Id: I06dea5aa782b02ed47d74837f2c5ffb798c660d5
Signed-off-by: Shenyx <shenyuxiang3@h-partners.com>
This commit is contained in:
Shenyx 2024-08-31 10:38:00 +08:00
parent 2a4e9dab77
commit a26c9043df
2 changed files with 14 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
services/src/task/download.rs
View File

@ -202,13 +202,11 @@ pub(crate) async fn download_inner(task: Arc<RequestTask>) -> Result<(), TaskErr
task.get_file_info(&response)?;
task.update_progress_in_database();
let size = task.progress.lock().unwrap().sizes[0];
#[cfg(feature = "oh")]
let _trace = Trace::new(&format!(
"download file tid:{} size:{}",
task.task_id(),
size
task.progress.lock().unwrap().sizes[0]
));
let mut downloader = build_downloader(task.clone(), response);
@ -235,24 +233,28 @@ fn check_file_exist(task: &Arc<RequestTask>) -> Result<(), TaskError> {
use crate::task::ATOMIC_SERVICE;
let config = task.config();
let uid = config.common_data.uid;
let bundle = config.bundle.as_str();
let is_account = config.bundle_type == ATOMIC_SERVICE;
let atomic_account = config.atomic_account.as_str();
let bundle_and_account = check_atomic_convert_path(is_account, bundle, atomic_account);
let real_path = convert_path(uid, &bundle_and_account, &config.file_specs[0].path);
let bundle_and_account = check_atomic_convert_path(
config.bundle_type == ATOMIC_SERVICE,
config.bundle.as_str(),
config.atomic_account.as_str(),
);
let real_path = convert_path(
config.common_data.uid,
&bundle_and_account,
&config.file_specs[0].path,
);
// Cannot compare param because file_total_size will be changed when resume task
match std::fs::metadata(real_path) {
Ok(metadata) => {
if metadata.is_file() {
Ok(())
} else {
error!("local download not a file");
error!("task {} local not file", task.task_id());
Err(TaskError::Failed(Reason::IoError))
}
}
Err(e) => {
error!("local file not exist:{}", e);
error!("task {} local not exist:{}", task.task_id(), e);
Err(TaskError::Failed(Reason::IoError))
}
}