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

Calculate job backoff relative to the current time

Browse Source 
Otherwise it is possible that desired_timestamp is in the past.
This commit is contained in:
Alexander Krotov
2019-11-28 21:44:44 +01:00
committed by Floris Bruynooghe
parent f0486eb820
commit 7e66af05ff
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/job.rs
View File

@@ -810,11 +810,11 @@ fn job_perform(context: &Context, thread: Thread, probe_network: bool) {
if tries < JOB_RETRIES { if tries < JOB_RETRIES {
job.tries = tries; job.tries = tries;
let time_offset = get_backoff_time_offset(tries); let time_offset = get_backoff_time_offset(tries);
job.desired_timestamp = job.added_timestamp + time_offset; job.desired_timestamp = time() + time_offset;
job.update(context); job.update(context);
info!( info!(
context, context,
"{}-job #{} not succeeded on try #{}, retry in ADD_TIME+{} (in {} seconds).", "{}-job #{} not succeeded on try #{}, retry in {} seconds.",
if thread == Thread::Imap { if thread == Thread::Imap {
"INBOX" "INBOX"
} else { } else {
@@ -822,8 +822,7 @@ fn job_perform(context: &Context, thread: Thread, probe_network: bool) {
}, },
job.job_id as u32, job.job_id as u32,
tries, tries,
time_offset, time_offset
job.added_timestamp + time_offset - time()
); );
if thread == Thread::Smtp && tries < JOB_RETRIES - 1 { if thread == Thread::Smtp && tries < JOB_RETRIES - 1 {
context context