Method launch_module

crates/core/src/host/host_controller.rs:766–808

(self)

impl<F: Fn() + Send + Sync + 'static> ModuleLauncher<F> {
    async fn launch_module(self) -> anyhow::Result<(Program, LaunchedModule)> {
        let db_identity = self.database.database_identity;
        info!(
            "launching module db={} replica={} program={} host_type={}",
            db_identity,
            self.replica_id,
            self.program.hash,
            HostType::from(self.program.kind)
        );

        let replica_ctx = make_replica_ctx(
            self.module_logs,
            self.database,
            self.replica_id,
            self.relational_db,
            self.bsatn_rlb_pool,
        )
        .await
        .map(Arc::new)?;
        let (scheduler, scheduler_starter) = Scheduler::open(replica_ctx.relational_db().clone());
        let (program, module_host) = make_module_host(
            self.runtimes.clone(),
            replica_ctx.clone(),
            scheduler.clone(),
            self.program,
            self.energy_monitor,
            self.on_panic,
            self.core,
        )
        .await?;

        trace!("launched database {} with program {}", db_identity, program.hash);

        Ok((
            program,
            LaunchedModule {
                replica_ctx,
                module_host,
                scheduler,
                scheduler_starter,
            },
        ))
    }
}

fn repair_stale_view_backing_tables_on_launch(launched: &LaunchedModule) -> anyhow::Result<()> {