Struct PendingBackgroundPids 

pub struct PendingBackgroundPids {
    inner: Mutex<HashMap<String, PendingEntry>>,
}

Fields

inner: Mutex<HashMap<String, PendingEntry>>

Implementations

impl PendingBackgroundPids

pub fn new() -> Self

fn evict_expired_locked(guard: &mut HashMap<String, PendingEntry>, now_ms: i64)

pub fn set_or_stash<E>( &self, id: &str, pid: i64, now_ms: i64, try_set: impl FnOnce(i64) -> Result<bool, E>, ) -> Result<(), E>

Called from the pid-arrival side (COMMAND_BACKGROUND_TASK_PID). Runs try_set(pid) (the background_task_set_pid DB call) while holding this module’s lock; if it reports the row doesn’t exist yet (Ok(false)), stashes the pid instead of losing it. Atomic with observe_and_apply below for the same id — see the module doc comment for why that matters.

pub fn observe_and_apply<E>( &self, id: &str, now_ms: i64, apply: impl FnOnce(i64) -> Result<bool, E>, ) -> Result<(), E>

Called from the row-creation side (COMMAND_DOCK_NODE_STATUS), after its own background_task_observe(...) call. Checks for a pid stashed ahead of the row’s existence and, if present and not expired, applies it via apply (another background_task_set_pid call) while holding this module’s lock. Atomic with set_or_stash above for the same id.

Trait Implementations

impl Default for PendingBackgroundPids

fn default() -> PendingBackgroundPids

Returns the “default value” for a type.