mirror of
https://github.com/chatmail/core.git
synced 2026-05-02 21:06:31 +03:00
improve logging
This commit is contained in:
@@ -136,11 +136,6 @@ async fn decode_openpgp(context: &Context, qr: &str) -> Lot {
|
|||||||
return format_err!("Bad fingerprint length in QR code").into();
|
return format_err!("Bad fingerprint length in QR code").into();
|
||||||
}
|
}
|
||||||
|
|
||||||
println!(
|
|
||||||
"{:?} {:?} {:?} {:?} {:?} {:?} {:?}",
|
|
||||||
addr, name, invitenumber, auth, grpid, grpname, fingerprint
|
|
||||||
);
|
|
||||||
|
|
||||||
let mut lot = Lot::new();
|
let mut lot = Lot::new();
|
||||||
|
|
||||||
// retrieve known state for this fingerprint
|
// retrieve known state for this fingerprint
|
||||||
|
|||||||
@@ -247,13 +247,17 @@ async fn smtp_loop(ctx: Context, started: Sender<()>, smtp_handlers: SmtpConnect
|
|||||||
.await
|
.await
|
||||||
{
|
{
|
||||||
Ok(Some(job)) => {
|
Ok(Some(job)) => {
|
||||||
|
info!(ctx, "executing smtp job");
|
||||||
job::perform_job(&ctx, job::Connection::Smtp(&mut connection), job).await;
|
job::perform_job(&ctx, job::Connection::Smtp(&mut connection), job).await;
|
||||||
ctx.scheduler.write().await.set_probe_network(false);
|
ctx.scheduler.write().await.set_probe_network(false);
|
||||||
}
|
}
|
||||||
Ok(None) | Err(async_std::future::TimeoutError { .. }) => {
|
Ok(None) | Err(async_std::future::TimeoutError { .. }) => {
|
||||||
|
info!(ctx, "smpt fake idle");
|
||||||
// Fake Idle
|
// Fake Idle
|
||||||
async_std::task::sleep(Duration::from_millis(500))
|
async_std::task::sleep(Duration::from_secs(5))
|
||||||
.race(idle_interrupt_receiver.recv().map(|_| ()))
|
.race(idle_interrupt_receiver.recv().map(|_| {
|
||||||
|
info!(ctx, "smtp idle interrupt");
|
||||||
|
}))
|
||||||
.await;
|
.await;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user