diff --git a/src/client/io_loop.rs b/src/client/io_loop.rs index 5adca6d81..efeacb61c 100644 --- a/src/client/io_loop.rs +++ b/src/client/io_loop.rs @@ -933,14 +933,12 @@ impl Remote { err = job.job_error(); fs::remove_job(d.id, &mut self.write_jobs); } - if let Some(job) = fs::get_job(d.id, &mut self.read_jobs) { - job.modify_time(); - err = job.job_error(); - fs::remove_job(d.id, &mut self.read_jobs); - } self.handle_job_status(d.id, d.file_num, err); } Some(file_response::Union::Error(e)) => { + if let Some(job) = fs::get_job(e.id, &mut self.write_jobs) { + fs::remove_job(e.id, &mut self.write_jobs); + } self.handle_job_status(e.id, e.file_num, Some(e.error)); } _ => {} diff --git a/src/ui_cm_interface.rs b/src/ui_cm_interface.rs index 97ae82b8b..695d60417 100644 --- a/src/ui_cm_interface.rs +++ b/src/ui_cm_interface.rs @@ -598,8 +598,8 @@ async fn handle_fs(fs: ipc::FS, write_jobs: &mut Vec, 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 {