Struct InstallSessionRegistry 

pub struct InstallSessionRegistry {
    sessions: Mutex<HashMap<String, Sender<()>>>,
    active_providers: Mutex<HashSet<String>>,
}

Per-session abort handle so install.cancel can kill an in-flight install. Also tracks active_providers so concurrent sessions for the same provider directory are rejected — without that, cancel of one would rm_rf the shared dir mid-install for the other. parking_lot::Mutex since the engine is sync at the handler boundary.

Fields

sessions: Mutex<HashMap<String, Sender<()>>>

active_providers: Mutex<HashSet<String>>

Implementations

impl InstallSessionRegistry

pub fn new() -> Arc<Self>

fn insert(&self, session_id: String, tx: Sender<()>)

fn try_claim_provider(&self, provider_id: &str) -> bool

Try to claim a provider; returns false if another session is already installing this provider.

fn release_provider(&self, provider_id: &str)

fn cancel(&self, session_id: &str) -> bool

fn drop_session(&self, session_id: &str)

Trait Implementations

impl Default for InstallSessionRegistry

fn default() -> InstallSessionRegistry

Returns the “default value” for a type.