Skip to main content

requeue_claimed

Function requeue_claimed 

Source
pub fn requeue_claimed(work_dir: &Path, max_tries: u32) -> usize
Expand description

What: Return every claim to pending with one more try, or to failed at max_tries, whatever its age. Returns how many were moved. Why: A consumer that starts holds no claim yet, and the manager runs one consumer at a time, so a claim it finds was left by a consumer that died or was replaced; waiting out the lease would strand the work for as long as the lease lasts.

In TS you’d write (pseudocode):

for (const left of claimed) requeue(left)