topodb-json 0.0.8

JSON conversion layer for the TopoDB agent-memory engine
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36

//! Bounded retry for opening a `Db` whose file another process holds.
//! Retries ONLY on [`TopoError::Busy`]; every other outcome (success or a
//! different error) is returned from the first attempt that produced it.

use std::time::{Duration, Instant};

use topodb::{Db, TopoError};

/// Calls `open` until it stops returning `Busy` or `budget_ms` elapses.
/// Backoff: 25ms doubling to a 500ms cap, with cheap deterministic-enough
/// jitter (from the clock's nanoseconds — no rand dependency) so two
/// contending processes don't retry in lockstep. `budget_ms == 0` means
/// exactly one attempt (fail fast). Exhaustion returns `Err(Busy)`.
pub fn open_with_busy_retry(
    budget_ms: u64,
    mut open: impl FnMut() -> Result<Db, TopoError>,
) -> Result<Db, TopoError> {
    let start = Instant::now();
    let mut delay_ms: u64 = 25;
    loop {
        match open() {
            Err(TopoError::Busy) => {
                let elapsed = start.elapsed();
                let elapsed_ms = elapsed.as_millis() as u64;
                if elapsed_ms >= budget_ms {
                    return Err(TopoError::Busy);
                }
                let jitter = u64::from(elapsed.subsec_nanos()) % (delay_ms / 4 + 1);
                let remaining = budget_ms - elapsed_ms;
                std::thread::sleep(Duration::from_millis((delay_ms + jitter).min(remaining)));
                delay_ms = (delay_ms * 2).min(500);
            }
            other => return other,
        }
    }
}