florian/imapidle
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

exponentially increasing wait times for reconnect

Browse Source
This commit is contained in:
Florian Stecker 2023-01-01 00:29:07 +01:00
parent bf15e2811f
commit 4a5d5a464a
1 changed files with 11 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/lib.rs
View File

@ -150,7 +150,7 @@ pub fn run() -> AResult<()> {
let elapsed = status.last_run.elapsed().unwrap_or_default(); let elapsed = status.last_run.elapsed().unwrap_or_default();
let run = status.connected && elapsed >= interval_duration; let run = status.connected && elapsed >= interval_duration;
println!("time = {:?}, run = {}", SystemTime::now(), run); // println!("time = {:?}, run = {}", SystemTime::now(), run);
if run { if run {
println!("Interval timer expired, running command ..."); println!("Interval timer expired, running command ...");
@ -198,7 +198,8 @@ pub fn run() -> AResult<()> {
status.last_run = SystemTime::now(); status.last_run = SystemTime::now();
}; };
// reconnect in an infinite loop // reconnect in an infinite loop, with exponentially increasing wait times up to 1/2 hour
let mut time_to_reconnect: u64 = 1;
loop { loop {
return match connect_and_idle(&cli, connect_callback , mail_callback) { return match connect_and_idle(&cli, connect_callback , mail_callback) {
Ok(_) => Ok(()), Ok(_) => Ok(()),
@ -206,18 +207,19 @@ pub fn run() -> AResult<()> {
Some(io_err) if CONNECTION_LOST_ERRORS.contains(&io_err.kind()) => { Some(io_err) if CONNECTION_LOST_ERRORS.contains(&io_err.kind()) => {
connection_status.lock().unwrap().connected = false; connection_status.lock().unwrap().connected = false;
let secs_to_reconnect = 10; time_to_reconnect = 1;
println!("Connection lost, reconnecting in {secs_to_reconnect} seconds"); println!("Connection lost, reconnecting in {time_to_reconnect} seconds");
thread::sleep(Duration::from_secs(secs_to_reconnect)); thread::sleep(Duration::from_secs(time_to_reconnect));
continue; continue;
}, },
Some(io_err) if CANT_CONNECT_ERRORS.contains(&io_err.kind()) => { Some(io_err) if CANT_CONNECT_ERRORS.contains(&io_err.kind()) => {
connection_status.lock().unwrap().connected = false; connection_status.lock().unwrap().connected = false;
let secs_to_reconnect = 10*60; time_to_reconnect = u64::min(time_to_reconnect*2, 1800);
println!("Cannot connect currently, retrying in {secs_to_reconnect} seconds");
thread::sleep(Duration::from_secs(secs_to_reconnect)); println!("Cannot connect currently, retrying in {time_to_reconnect} seconds");
thread::sleep(Duration::from_secs(time_to_reconnect));
continue; continue;
}, },
@ -267,7 +269,7 @@ pub fn connect_and_idle<F: Fn(), G: Fn()>(cli: &Cli,
let mut socket = TcpStream::connect(addrs.as_slice())?; let mut socket = TcpStream::connect(addrs.as_slice())?;
let mut state = ImapState::Unauthenticated; let mut state = ImapState::Unauthenticated;
socket.set_read_timeout(Some(Duration::from_secs(10*60)))?; socket.set_read_timeout(Some(Duration::from_secs(120)))?;
loop { loop {
if tls_client.is_handshaking() { if tls_client.is_handshaking() {