boxlite 0.9.3

Embeddable virtual machine runtime for secure, isolated code execution
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59

//! Initialization tasks.
//!
//! ## Dependency Graph
//!
//! ```text
//! Filesystem ─────┐
//!                 │
//! ContainerRootfs ┼──→ VmmSpawn ──→ GuestConnect ──→ GuestInit
//!                 │
//! GuestRootfs ────┘
//!
//! Starting (new box):
//! - Stage 1 (sequential): [Filesystem]
//! - Stage 2 (parallel):   [ContainerRootfs, GuestRootfs]
//! - Stage 3 (sequential): [VmmSpawn, GuestConnect, GuestInit]
//!
//! Stopped (restart):
//! - Stage 1 (sequential): [Filesystem]
//! - Stage 2 (parallel):   [ContainerRootfs, GuestRootfs]
//! - Stage 3 (sequential): [VmmSpawn, GuestConnect]
//!
//! Running (reattach):
//! - Stage 1 (sequential): [VmmAttach, GuestConnect]
//! ```

mod container_rootfs;
mod filesystem;
mod guest_connect;
mod guest_entrypoint;
mod guest_init;
mod guest_rootfs;
mod vmm_attach;
mod vmm_spawn;

use super::types::InitPipelineContext;
use crate::runtime::id::BoxID;
use boxlite_shared::errors::BoxliteError;
use std::sync::Arc;
use tokio::sync::Mutex;

pub type InitCtx = Arc<Mutex<InitPipelineContext>>;

async fn task_start(ctx: &InitCtx, task_name: &str) -> BoxID {
    let box_id = { ctx.lock().await.config.id.clone() };
    tracing::debug!(box_id = %box_id, task = %task_name, "Executing task");
    box_id
}

fn log_task_error(box_id: &BoxID, task_name: &str, err: &BoxliteError) {
    tracing::error!(box_id = %box_id, task = %task_name, "Task failed: {}", err);
}

pub use container_rootfs::ContainerRootfsTask;
pub use filesystem::FilesystemTask;
pub use guest_connect::GuestConnectTask;
pub use guest_init::GuestInitTask;
pub use guest_rootfs::GuestRootfsTask;
pub use vmm_attach::VmmAttachTask;
pub use vmm_spawn::VmmSpawnTask;