supermachine 0.7.82

Run any OCI/Docker image as a hardware-isolated microVM on macOS HVF (Linux KVM and Windows WHP in progress). Single library API, zero flags for the common case, sub-100 ms cold-restore from snapshot.
Documentation 
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
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75

//! Validate KVM data volumes: attach a host-backed virtio-blk, mount it in the
//! guest, write data, then re-start a fresh VM with the SAME volume and confirm
//! the data persisted (the backing file survives VM teardown).
//!
//! Usage: kvm_volume [backing_file]   (default /tmp/sm-vol.img)

#[cfg(all(target_os = "linux", target_arch = "x86_64"))]
fn main() {
    use std::time::Duration;
    use supermachine::vmm::resources::VolumeSpec;
    use supermachine::{Image, VmConfig};

    let backing = std::env::args()
        .nth(1)
        .unwrap_or_else(|| "/tmp/sm-vol.img".to_string());
    let _ = std::fs::remove_file(&backing); // fresh start for the demo
    let cfg = || {
        VmConfig::new().with_volume(VolumeSpec {
            host_path: backing.clone(),
            guest_path: "/data".to_string(),
            size_bytes: 64 * 1024 * 1024,
        })
    };

    let image = Image::from_oci("alpine").expect("from_oci");

    eprintln!("=== VM #1: mount /data (vol), write a file ===");
    let vm = image.start(&cfg()).expect("start1");
    std::thread::sleep(Duration::from_millis(5000));
    let w = vm
        .exec_builder()
        .argv([
            "/bin/sh",
            "-c",
            "mount | grep -q ' /data ' && V=persisted-$(date +%s) && echo $V > /data/probe && sync && cat /data/probe",
        ])
        .output()
        .expect("exec write");
    let written = String::from_utf8_lossy(&w.stdout).trim_end().to_string();
    eprintln!("VM#1: success={} out={:?}", w.success(), written);
    vm.stop().expect("stop1");

    eprintln!("=== VM #2: same volume, read the file back (persistence) ===");
    let vm2 = image.start(&cfg()).expect("start2");
    std::thread::sleep(Duration::from_millis(5000));
    let r = vm2
        .exec_builder()
        .argv(["/bin/sh", "-c", "cat /data/probe 2>&1"])
        .output()
        .expect("exec read");
    let read_back = String::from_utf8_lossy(&r.stdout).trim_end().to_string();
    eprintln!("VM#2: success={} read={:?}", r.success(), read_back);
    vm2.stop().expect("stop2");

    let persisted =
        written.contains("persisted-") && read_back == written.lines().next().unwrap_or("X");
    // (written's first line is the probe value; cat in VM#1 echoes it then MOUNTED)
    let probe_val = written.lines().next().unwrap_or("");
    eprintln!(
        "=== VOLUME PERSISTENCE: {} (wrote {:?}, read {:?}) ===",
        if read_back == probe_val {
            "PASS"
        } else {
            "FAIL"
        },
        probe_val,
        read_back
    );
    let _ = persisted;
}

#[cfg(not(all(target_os = "linux", target_arch = "x86_64")))]
fn main() {
    eprintln!("kvm_volume is Linux/x86_64 only");
}