Method get_module_host

crates/core/src/host/host_controller.rs:559–569

(&self, replica_id: u64)

    /// the host if it is not running.
    #[tracing::instrument(level = "trace", skip_all)]
    pub async fn get_module_host(&self, replica_id: u64) -> Result<ModuleHost, NoSuchModule> {
        trace!("get module host {replica_id}");
        let guard = self.acquire_read_lock(replica_id).await.map_err(|_| {
            warn!("timeout waiting for read lock on replica {replica_id} in `get_module_host`");
            NoSuchModule
        })?;
        guard
            .as_ref()
            .map(|Host { module, .. }| module.borrow().clone())
            .ok_or(NoSuchModule)
    }

    /// Subscribe to updates of the [`ModuleHost`] identified by `replica_id`,
    /// or return an error if it is not registered with the controller.