teldra/buzz-ed
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Don't hide errors

Browse Source
This commit is contained in:
Jon Gjengset 2019-02-24 17:45:47 -05:00
parent 874c5a609f
commit 9ba1f290ad
No known key found for this signature in database
GPG Key ID: F8FBEB3BC15B735B
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/main.rs
View File

@ -58,9 +58,10 @@ struct Connection<T: Read + Write> {
impl<T: Read + Write + imap::extensions::idle::SetReadTimeout> Connection<T> {
pub fn handle(mut self, account: usize, mut tx: mpsc::Sender<(usize, usize)>) {
loop {
if let Err(_) = self.check(account, &mut tx) {
if let Err(e) = self.check(account, &mut tx) {
// the connection has failed for some reason
// try to log out (we probably can't)
eprintln!("connection to {} failed: {:?}", self.account.name, e);
self.socket.logout().is_err();
break;
}
@ -69,7 +70,7 @@ impl<T: Read + Write + imap::extensions::idle::SetReadTimeout> Connection<T> {
// try to reconnect
let mut wait = 1;
for _ in 0..5 {
println!(
eprintln!(
"connection to {} lost; trying to reconnect...",
self.account.name
);
@ -78,10 +79,10 @@ impl<T: Read + Write + imap::extensions::idle::SetReadTimeout> Connection<T> {
println!("{} connection reestablished", self.account.name);
return c.handle(account, tx);
}
Err(imap::error::Error::Io(_)) => {
Err(e) => {
eprintln!("failed to connect to {}: {:?}", self.account.name, e);
thread::sleep(Duration::from_secs(wait));
}
Err(_) => break,
}
wait *= 2;