Mirrors/chatmail-core
1
0
Fork 0
mirror of https://github.com/chatmail/core.git synced 2026-05-06 06:46:35 +03:00
Code Issues Packages Projects Releases Wiki Activity

log some more

Browse Source
This commit is contained in:
Floris Bruynooghe
2023-03-02 11:21:05 +01:00
parent 155dff2813
commit 9d88ef069e
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/imex/transfer.rs
View File

@@ -188,7 +188,7 @@ impl BackupProvider {
tokio::select! { tokio::select! {
biased; biased;
res = &mut provider => { res = &mut provider => {
break res.context("BackupSender failed"); break res.context("BackupProvider failed");
}, },
maybe_event = events.recv() => { maybe_event = events.recv() => {
match maybe_event { match maybe_event {
@@ -206,7 +206,7 @@ impl BackupProvider {
} }
Event::TransferAborted { .. } => { Event::TransferAborted { .. } => {
provider.shutdown(); provider.shutdown();
break Err(anyhow!("BackupSender transfer aborted")); break Err(anyhow!("BackupProvider transfer aborted"));
} }
} }
} }
@@ -218,7 +218,7 @@ impl BackupProvider {
// We really shouldn't be lagging, if we did we may have missed // We really shouldn't be lagging, if we did we may have missed
// a completion event. // a completion event.
provider.shutdown(); provider.shutdown();
break Err(anyhow!("Missed events from BackupSender")); break Err(anyhow!("Missed events from BackupProvider"));
} }
} }
}, },
@@ -235,7 +235,10 @@ impl BackupProvider {
.take(); .take();
match &res { match &res {
Ok(_) => context.emit_event(SendProgress::Completed.into()), Ok(_) => context.emit_event(SendProgress::Completed.into()),
Err(_) => context.emit_event(SendProgress::Failed.into()), Err(err) => {
error!(context, "Backup transfer failure: {err:#}");
context.emit_event(SendProgress::Failed.into())
}
} }
context.free_ongoing().await; context.free_ongoing().await;
res res