underhill_core/dispatch/
pci_shutdown.rs

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
// Copyright (c) Microsoft Corporation.
// Licensed under the MIT License.

use blocking::unblock;
use fs_err::PathExt;
use futures::future::try_join_all;
use std::os::unix::prelude::*;
use thiserror::Error;
use tracing::Instrument;

#[derive(Debug, Error)]
pub enum ShutdownError {
    #[error("failed operating on sysfs")]
    SysFs(#[source] std::io::Error),
    #[error("failed to unbind {driver} driver for {pci_id}")]
    Unbind {
        driver: String,
        pci_id: String,
        #[source]
        source: std::io::Error,
    },
}

/// Unbinds drivers from all PCI devices so that they reenter quiescent state
/// for the next kernel boot.
///
/// Skips vfio devices since those need to be managed in user mode, so unbinding
/// vfio from them won't help.
pub async fn shutdown_pci_devices() -> Result<(), ShutdownError> {
    let dir = fs_err::read_dir("/sys/bus/pci/devices").map_err(ShutdownError::SysFs)?;
    let ops = try_join_all(dir.map(async |entry| {
        let entry = entry.map_err(ShutdownError::SysFs)?;
        let driver_link = entry.path().join("driver");
        match driver_link.fs_err_read_link() {
            Ok(driver_path) => {
                let driver_name = driver_path.file_name().unwrap().to_string_lossy();
                let pci_id = entry.file_name();
                let pci_id_str = pci_id.to_string_lossy().into_owned();
                if driver_name == "vfio-pci" {
                    tracing::debug!(
                        pci_id = pci_id_str.as_str(),
                        "skipping unbind for vfio device"
                    );
                    return Ok(());
                }
                // Use unblock to run each unbind on a separate thread concurrently.
                unblock(move || fs_err::write(driver_link.join("unbind"), pci_id.as_bytes()))
                    .instrument(tracing::info_span!(
                        "unbind_pci_device",
                        driver = driver_name.as_ref(),
                        pci_id = pci_id_str.as_str(),
                    ))
                    .await
                    .map_err(|err| ShutdownError::Unbind {
                        driver: driver_name.into_owned(),
                        pci_id: pci_id_str,
                        source: err,
                    })?;
            }
            Err(err) if err.kind() == std::io::ErrorKind::NotFound => {
                // No driver bound to this device.
            }
            Err(err) => {
                return Err(ShutdownError::SysFs(err));
            }
        }
        Ok(())
    }));

    ops.await?;
    Ok(())
}