alioth 0.12.0

Core library for Alioth, an experimental Type-2 hypervisor.
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
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93

// Copyright 2025 Google LLC
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     https://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

use std::os::fd::{AsFd, BorrowedFd};
use std::sync::atomic::{AtomicBool, AtomicU16, AtomicU64};
use std::sync::mpsc::Sender;

use rstest::fixture;

use crate::hv::IoeventFd;
use crate::mem::mapped::{ArcMemPages, RamBus};
use crate::virtio::queue::{QUEUE_SIZE_MAX, QueueReg};
use crate::virtio::{IrqSender, Result};

pub const QUEUE_SIZE: u16 = QUEUE_SIZE_MAX;
const MEM_SIZE: usize = 2 << 20;
pub const DATA_ADDR: u64 = 0x0;
const QUEUE_START: u64 = 1 << 20;

#[fixture]
pub fn fixture_ram_bus() -> RamBus {
    let host_pages = ArcMemPages::from_anonymous(MEM_SIZE, None, None).unwrap();
    let ram_bus = RamBus::new();
    ram_bus.add(0, host_pages).unwrap();
    ram_bus
}

#[fixture]
pub fn fixture_queues(#[default(1)] count: u16) -> Box<[QueueReg]> {
    (0..count)
        .map(|i| {
            let base = QUEUE_START + i as u64 * 0x2000;
            QueueReg {
                size: AtomicU16::new(QUEUE_SIZE),
                desc: AtomicU64::new(base),
                driver: AtomicU64::new(base + 0x1000),
                device: AtomicU64::new(base + 0x1400),
                enabled: AtomicBool::new(true),
            }
        })
        .collect()
}

#[derive(Debug)]
pub struct FakeIrqSender {
    pub q_tx: Sender<u16>,
}

impl IrqSender for FakeIrqSender {
    fn queue_irq(&self, idx: u16) {
        self.q_tx.send(idx).unwrap();
    }

    fn config_irq(&self) {
        unimplemented!()
    }

    fn queue_irqfd<F, T>(&self, _idx: u16, _f: F) -> Result<T>
    where
        F: FnOnce(BorrowedFd) -> Result<T>,
    {
        unimplemented!()
    }

    fn config_irqfd<F, T>(&self, _f: F) -> Result<T>
    where
        F: FnOnce(BorrowedFd) -> Result<T>,
    {
        unimplemented!()
    }
}

#[derive(Debug, Default)]
pub struct FakeIoeventFd;

impl AsFd for FakeIoeventFd {
    fn as_fd(&self) -> BorrowedFd<'_> {
        unreachable!()
    }
}

impl IoeventFd for FakeIoeventFd {}