Function lock_bus

nodedb/src/control/shutdown/bus.rs:182–190

(state: &Mutex<BusState>)

}

fn lock_bus(state: &Mutex<BusState>) -> std::sync::MutexGuard<'_, BusState> {
    match state.lock() {
        Ok(g) => g,
        Err(p) => {
            error!(target: "shutdown", "ShutdownBus mutex poisoned — recovering");
            p.into_inner()
        }
    }
}

impl ShutdownBus {
    /// Create a new `ShutdownBus`. Returns the bus (for registering tasks