fix: write job resets

This commit is contained in:
Kingtous
2022-12-06 15:09:57 +08:00
parent c77fe6c01c
commit e3c239f5ae
2 changed files with 5 additions and 7 deletions

View File

@@ -598,8 +598,8 @@ async fn handle_fs(fs: ipc::FS, write_jobs: &mut Vec<fs::TransferJob>, tx: &Unbo
}
ipc::FS::WriteError { id, file_num, err } => {
if let Some(job) = fs::get_job(id, write_jobs) {
send_raw(fs::new_error(id, err, file_num), tx);
fs::remove_job(id, write_jobs);
send_raw(fs::new_error(job.id(), err, file_num), tx);
fs::remove_job(job.id(), write_jobs);
}
}
ipc::FS::WriteBlock {