[v1] qga: clean up command source locations and conditionals

[PATCH 04/20] qga: move linux fs/disk command impls to commands-linux.c

Posted by Daniel P. Berrangé 5 months, 3 weeks ago

The qmp_guest_{fstrim, get_fsinfo, get_disks} command impls in
commands-posix.c are surrounded by '#ifdef __linux__' so should
instead live in commands-linux.c

Signed-off-by: Daniel P. Berrangé <berrange@redhat.com>
---
 qga/commands-linux.c | 904 ++++++++++++++++++++++++++++++++++++++++++
 qga/commands-posix.c | 909 -------------------------------------------
 2 files changed, 904 insertions(+), 909 deletions(-)

diff --git a/qga/commands-linux.c b/qga/commands-linux.c
index 3fabf54882..084e6c9e85 100644
--- a/qga/commands-linux.c
+++ b/qga/commands-linux.c
@@ -14,10 +14,21 @@
 #include "qemu/osdep.h"
 #include "qapi/error.h"
 #include "qga-qapi-commands.h"
+#include "qapi/error.h"
+#include "qapi/qmp/qerror.h"
 #include "commands-common.h"
 #include "cutils.h"
 #include <mntent.h>
 #include <sys/ioctl.h>
+#include <mntent.h>
+#include <linux/nvme_ioctl.h>
+#include "block/nvme.h"
+
+#ifdef CONFIG_LIBUDEV
+#include <libudev.h>
+#endif
+
+#include <sys/statvfs.h>
 
 #if defined(CONFIG_FSFREEZE) || defined(CONFIG_FSTRIM)
 static int dev_major_minor(const char *devpath,
@@ -286,6 +297,899 @@ int qmp_guest_fsfreeze_do_thaw(Error **errp)
 }
 #endif /* CONFIG_FSFREEZE */
 
+#if defined(CONFIG_FSFREEZE)
+
+static char *get_pci_driver(char const *syspath, int pathlen, Error **errp)
+{
+    char *path;
+    char *dpath;
+    char *driver = NULL;
+    char buf[PATH_MAX];
+    ssize_t len;
+
+    path = g_strndup(syspath, pathlen);
+    dpath = g_strdup_printf("%s/driver", path);
+    len = readlink(dpath, buf, sizeof(buf) - 1);
+    if (len != -1) {
+        buf[len] = 0;
+        driver = g_path_get_basename(buf);
+    }
+    g_free(dpath);
+    g_free(path);
+    return driver;
+}
+
+static int compare_uint(const void *_a, const void *_b)
+{
+    unsigned int a = *(unsigned int *)_a;
+    unsigned int b = *(unsigned int *)_b;
+
+    return a < b ? -1 : a > b ? 1 : 0;
+}
+
+/* Walk the specified sysfs and build a sorted list of host or ata numbers */
+static int build_hosts(char const *syspath, char const *host, bool ata,
+                       unsigned int *hosts, int hosts_max, Error **errp)
+{
+    char *path;
+    DIR *dir;
+    struct dirent *entry;
+    int i = 0;
+
+    path = g_strndup(syspath, host - syspath);
+    dir = opendir(path);
+    if (!dir) {
+        error_setg_errno(errp, errno, "opendir(\"%s\")", path);
+        g_free(path);
+        return -1;
+    }
+
+    while (i < hosts_max) {
+        entry = readdir(dir);
+        if (!entry) {
+            break;
+        }
+        if (ata && sscanf(entry->d_name, "ata%d", hosts + i) == 1) {
+            ++i;
+        } else if (!ata && sscanf(entry->d_name, "host%d", hosts + i) == 1) {
+            ++i;
+        }
+    }
+
+    qsort(hosts, i, sizeof(hosts[0]), compare_uint);
+
+    g_free(path);
+    closedir(dir);
+    return i;
+}
+
+/*
+ * Store disk device info for devices on the PCI bus.
+ * Returns true if information has been stored, or false for failure.
+ */
+static bool build_guest_fsinfo_for_pci_dev(char const *syspath,
+                                           GuestDiskAddress *disk,
+                                           Error **errp)
+{
+    unsigned int pci[4], host, hosts[8], tgt[3];
+    int i, nhosts = 0, pcilen;
+    GuestPCIAddress *pciaddr = disk->pci_controller;
+    bool has_ata = false, has_host = false, has_tgt = false;
+    char *p, *q, *driver = NULL;
+    bool ret = false;
+
+    p = strstr(syspath, "/devices/pci");
+    if (!p || sscanf(p + 12, "%*x:%*x/%x:%x:%x.%x%n",
+                     pci, pci + 1, pci + 2, pci + 3, &pcilen) < 4) {
+        g_debug("only pci device is supported: sysfs path '%s'", syspath);
+        return false;
+    }
+
+    p += 12 + pcilen;
+    while (true) {
+        driver = get_pci_driver(syspath, p - syspath, errp);
+        if (driver && (g_str_equal(driver, "ata_piix") ||
+                       g_str_equal(driver, "sym53c8xx") ||
+                       g_str_equal(driver, "virtio-pci") ||
+                       g_str_equal(driver, "ahci") ||
+                       g_str_equal(driver, "nvme") ||
+                       g_str_equal(driver, "xhci_hcd") ||
+                       g_str_equal(driver, "ehci-pci"))) {
+            break;
+        }
+
+        g_free(driver);
+        if (sscanf(p, "/%x:%x:%x.%x%n",
+                          pci, pci + 1, pci + 2, pci + 3, &pcilen) == 4) {
+            p += pcilen;
+            continue;
+        }
+
+        g_debug("unsupported driver or sysfs path '%s'", syspath);
+        return false;
+    }
+
+    p = strstr(syspath, "/target");
+    if (p && sscanf(p + 7, "%*u:%*u:%*u/%*u:%u:%u:%u",
+                    tgt, tgt + 1, tgt + 2) == 3) {
+        has_tgt = true;
+    }
+
+    p = strstr(syspath, "/ata");
+    if (p) {
+        q = p + 4;
+        has_ata = true;
+    } else {
+        p = strstr(syspath, "/host");
+        q = p + 5;
+    }
+    if (p && sscanf(q, "%u", &host) == 1) {
+        has_host = true;
+        nhosts = build_hosts(syspath, p, has_ata, hosts,
+                             ARRAY_SIZE(hosts), errp);
+        if (nhosts < 0) {
+            goto cleanup;
+        }
+    }
+
+    pciaddr->domain = pci[0];
+    pciaddr->bus = pci[1];
+    pciaddr->slot = pci[2];
+    pciaddr->function = pci[3];
+
+    if (strcmp(driver, "ata_piix") == 0) {
+        /* a host per ide bus, target*:0:<unit>:0 */
+        if (!has_host || !has_tgt) {
+            g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver);
+            goto cleanup;
+        }
+        for (i = 0; i < nhosts; i++) {
+            if (host == hosts[i]) {
+                disk->bus_type = GUEST_DISK_BUS_TYPE_IDE;
+                disk->bus = i;
+                disk->unit = tgt[1];
+                break;
+            }
+        }
+        if (i >= nhosts) {
+            g_debug("no host for '%s' (driver '%s')", syspath, driver);
+            goto cleanup;
+        }
+    } else if (strcmp(driver, "sym53c8xx") == 0) {
+        /* scsi(LSI Logic): target*:0:<unit>:0 */
+        if (!has_tgt) {
+            g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver);
+            goto cleanup;
+        }
+        disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI;
+        disk->unit = tgt[1];
+    } else if (strcmp(driver, "virtio-pci") == 0) {
+        if (has_tgt) {
+            /* virtio-scsi: target*:0:0:<unit> */
+            disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI;
+            disk->unit = tgt[2];
+        } else {
+            /* virtio-blk: 1 disk per 1 device */
+            disk->bus_type = GUEST_DISK_BUS_TYPE_VIRTIO;
+        }
+    } else if (strcmp(driver, "ahci") == 0) {
+        /* ahci: 1 host per 1 unit */
+        if (!has_host || !has_tgt) {
+            g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver);
+            goto cleanup;
+        }
+        for (i = 0; i < nhosts; i++) {
+            if (host == hosts[i]) {
+                disk->unit = i;
+                disk->bus_type = GUEST_DISK_BUS_TYPE_SATA;
+                break;
+            }
+        }
+        if (i >= nhosts) {
+            g_debug("no host for '%s' (driver '%s')", syspath, driver);
+            goto cleanup;
+        }
+    } else if (strcmp(driver, "nvme") == 0) {
+        disk->bus_type = GUEST_DISK_BUS_TYPE_NVME;
+    } else if (strcmp(driver, "ehci-pci") == 0 || strcmp(driver, "xhci_hcd") == 0) {
+        disk->bus_type = GUEST_DISK_BUS_TYPE_USB;
+    } else {
+        g_debug("unknown driver '%s' (sysfs path '%s')", driver, syspath);
+        goto cleanup;
+    }
+
+    ret = true;
+
+cleanup:
+    g_free(driver);
+    return ret;
+}
+
+/*
+ * Store disk device info for non-PCI virtio devices (for example s390x
+ * channel I/O devices). Returns true if information has been stored, or
+ * false for failure.
+ */
+static bool build_guest_fsinfo_for_nonpci_virtio(char const *syspath,
+                                                 GuestDiskAddress *disk,
+                                                 Error **errp)
+{
+    unsigned int tgt[3];
+    char *p;
+
+    if (!strstr(syspath, "/virtio") || !strstr(syspath, "/block")) {
+        g_debug("Unsupported virtio device '%s'", syspath);
+        return false;
+    }
+
+    p = strstr(syspath, "/target");
+    if (p && sscanf(p + 7, "%*u:%*u:%*u/%*u:%u:%u:%u",
+                    &tgt[0], &tgt[1], &tgt[2]) == 3) {
+        /* virtio-scsi: target*:0:<target>:<unit> */
+        disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI;
+        disk->bus = tgt[0];
+        disk->target = tgt[1];
+        disk->unit = tgt[2];
+    } else {
+        /* virtio-blk: 1 disk per 1 device */
+        disk->bus_type = GUEST_DISK_BUS_TYPE_VIRTIO;
+    }
+
+    return true;
+}
+
+/*
+ * Store disk device info for CCW devices (s390x channel I/O devices).
+ * Returns true if information has been stored, or false for failure.
+ */
+static bool build_guest_fsinfo_for_ccw_dev(char const *syspath,
+                                           GuestDiskAddress *disk,
+                                           Error **errp)
+{
+    unsigned int cssid, ssid, subchno, devno;
+    char *p;
+
+    p = strstr(syspath, "/devices/css");
+    if (!p || sscanf(p + 12, "%*x/%x.%x.%x/%*x.%*x.%x/",
+                     &cssid, &ssid, &subchno, &devno) < 4) {
+        g_debug("could not parse ccw device sysfs path: %s", syspath);
+        return false;
+    }
+
+    disk->ccw_address = g_new0(GuestCCWAddress, 1);
+    disk->ccw_address->cssid = cssid;
+    disk->ccw_address->ssid = ssid;
+    disk->ccw_address->subchno = subchno;
+    disk->ccw_address->devno = devno;
+
+    if (strstr(p, "/virtio")) {
+        build_guest_fsinfo_for_nonpci_virtio(syspath, disk, errp);
+    }
+
+    return true;
+}
+
+/* Store disk device info specified by @sysfs into @fs */
+static void build_guest_fsinfo_for_real_device(char const *syspath,
+                                               GuestFilesystemInfo *fs,
+                                               Error **errp)
+{
+    GuestDiskAddress *disk;
+    GuestPCIAddress *pciaddr;
+    bool has_hwinf;
+#ifdef CONFIG_LIBUDEV
+    struct udev *udev = NULL;
+    struct udev_device *udevice = NULL;
+#endif
+
+    pciaddr = g_new0(GuestPCIAddress, 1);
+    pciaddr->domain = -1;                       /* -1 means field is invalid */
+    pciaddr->bus = -1;
+    pciaddr->slot = -1;
+    pciaddr->function = -1;
+
+    disk = g_new0(GuestDiskAddress, 1);
+    disk->pci_controller = pciaddr;
+    disk->bus_type = GUEST_DISK_BUS_TYPE_UNKNOWN;
+
+#ifdef CONFIG_LIBUDEV
+    udev = udev_new();
+    udevice = udev_device_new_from_syspath(udev, syspath);
+    if (udev == NULL || udevice == NULL) {
+        g_debug("failed to query udev");
+    } else {
+        const char *devnode, *serial;
+        devnode = udev_device_get_devnode(udevice);
+        if (devnode != NULL) {
+            disk->dev = g_strdup(devnode);
+        }
+        serial = udev_device_get_property_value(udevice, "ID_SERIAL");
+        if (serial != NULL && *serial != 0) {
+            disk->serial = g_strdup(serial);
+        }
+    }
+
+    udev_unref(udev);
+    udev_device_unref(udevice);
+#endif
+
+    if (strstr(syspath, "/devices/pci")) {
+        has_hwinf = build_guest_fsinfo_for_pci_dev(syspath, disk, errp);
+    } else if (strstr(syspath, "/devices/css")) {
+        has_hwinf = build_guest_fsinfo_for_ccw_dev(syspath, disk, errp);
+    } else if (strstr(syspath, "/virtio")) {
+        has_hwinf = build_guest_fsinfo_for_nonpci_virtio(syspath, disk, errp);
+    } else {
+        g_debug("Unsupported device type for '%s'", syspath);
+        has_hwinf = false;
+    }
+
+    if (has_hwinf || disk->dev || disk->serial) {
+        QAPI_LIST_PREPEND(fs->disk, disk);
+    } else {
+        qapi_free_GuestDiskAddress(disk);
+    }
+}
+
+static void build_guest_fsinfo_for_device(char const *devpath,
+                                          GuestFilesystemInfo *fs,
+                                          Error **errp);
+
+/* Store a list of slave devices of virtual volume specified by @syspath into
+ * @fs */
+static void build_guest_fsinfo_for_virtual_device(char const *syspath,
+                                                  GuestFilesystemInfo *fs,
+                                                  Error **errp)
+{
+    Error *err = NULL;
+    DIR *dir;
+    char *dirpath;
+    struct dirent *entry;
+
+    dirpath = g_strdup_printf("%s/slaves", syspath);
+    dir = opendir(dirpath);
+    if (!dir) {
+        if (errno != ENOENT) {
+            error_setg_errno(errp, errno, "opendir(\"%s\")", dirpath);
+        }
+        g_free(dirpath);
+        return;
+    }
+
+    for (;;) {
+        errno = 0;
+        entry = readdir(dir);
+        if (entry == NULL) {
+            if (errno) {
+                error_setg_errno(errp, errno, "readdir(\"%s\")", dirpath);
+            }
+            break;
+        }
+
+        if (entry->d_type == DT_LNK) {
+            char *path;
+
+            g_debug(" slave device '%s'", entry->d_name);
+            path = g_strdup_printf("%s/slaves/%s", syspath, entry->d_name);
+            build_guest_fsinfo_for_device(path, fs, &err);
+            g_free(path);
+
+            if (err) {
+                error_propagate(errp, err);
+                break;
+            }
+        }
+    }
+
+    g_free(dirpath);
+    closedir(dir);
+}
+
+static bool is_disk_virtual(const char *devpath, Error **errp)
+{
+    g_autofree char *syspath = realpath(devpath, NULL);
+
+    if (!syspath) {
+        error_setg_errno(errp, errno, "realpath(\"%s\")", devpath);
+        return false;
+    }
+    return strstr(syspath, "/devices/virtual/block/") != NULL;
+}
+
+/* Dispatch to functions for virtual/real device */
+static void build_guest_fsinfo_for_device(char const *devpath,
+                                          GuestFilesystemInfo *fs,
+                                          Error **errp)
+{
+    ERRP_GUARD();
+    g_autofree char *syspath = NULL;
+    bool is_virtual = false;
+
+    syspath = realpath(devpath, NULL);
+    if (!syspath) {
+        if (errno != ENOENT) {
+            error_setg_errno(errp, errno, "realpath(\"%s\")", devpath);
+            return;
+        }
+
+        /* ENOENT: This devpath may not exist because of container config */
+        if (!fs->name) {
+            fs->name = g_path_get_basename(devpath);
+        }
+        return;
+    }
+
+    if (!fs->name) {
+        fs->name = g_path_get_basename(syspath);
+    }
+
+    g_debug("  parse sysfs path '%s'", syspath);
+    is_virtual = is_disk_virtual(syspath, errp);
+    if (*errp != NULL) {
+        return;
+    }
+    if (is_virtual) {
+        build_guest_fsinfo_for_virtual_device(syspath, fs, errp);
+    } else {
+        build_guest_fsinfo_for_real_device(syspath, fs, errp);
+    }
+}
+
+#ifdef CONFIG_LIBUDEV
+
+/*
+ * Wrapper around build_guest_fsinfo_for_device() for getting just
+ * the disk address.
+ */
+static GuestDiskAddress *get_disk_address(const char *syspath, Error **errp)
+{
+    g_autoptr(GuestFilesystemInfo) fs = NULL;
+
+    fs = g_new0(GuestFilesystemInfo, 1);
+    build_guest_fsinfo_for_device(syspath, fs, errp);
+    if (fs->disk != NULL) {
+        return g_steal_pointer(&fs->disk->value);
+    }
+    return NULL;
+}
+
+static char *get_alias_for_syspath(const char *syspath)
+{
+    struct udev *udev = NULL;
+    struct udev_device *udevice = NULL;
+    char *ret = NULL;
+
+    udev = udev_new();
+    if (udev == NULL) {
+        g_debug("failed to query udev");
+        goto out;
+    }
+    udevice = udev_device_new_from_syspath(udev, syspath);
+    if (udevice == NULL) {
+        g_debug("failed to query udev for path: %s", syspath);
+        goto out;
+    } else {
+        const char *alias = udev_device_get_property_value(
+            udevice, "DM_NAME");
+        /*
+         * NULL means there was an error and empty string means there is no
+         * alias. In case of no alias we return NULL instead of empty string.
+         */
+        if (alias == NULL) {
+            g_debug("failed to query udev for device alias for: %s",
+                syspath);
+        } else if (*alias != 0) {
+            ret = g_strdup(alias);
+        }
+    }
+
+out:
+    udev_unref(udev);
+    udev_device_unref(udevice);
+    return ret;
+}
+
+static char *get_device_for_syspath(const char *syspath)
+{
+    struct udev *udev = NULL;
+    struct udev_device *udevice = NULL;
+    char *ret = NULL;
+
+    udev = udev_new();
+    if (udev == NULL) {
+        g_debug("failed to query udev");
+        goto out;
+    }
+    udevice = udev_device_new_from_syspath(udev, syspath);
+    if (udevice == NULL) {
+        g_debug("failed to query udev for path: %s", syspath);
+        goto out;
+    } else {
+        ret = g_strdup(udev_device_get_devnode(udevice));
+    }
+
+out:
+    udev_unref(udev);
+    udev_device_unref(udevice);
+    return ret;
+}
+
+static void get_disk_deps(const char *disk_dir, GuestDiskInfo *disk)
+{
+    g_autofree char *deps_dir = NULL;
+    const gchar *dep;
+    GDir *dp_deps = NULL;
+
+    /* List dependent disks */
+    deps_dir = g_strdup_printf("%s/slaves", disk_dir);
+    g_debug("  listing entries in: %s", deps_dir);
+    dp_deps = g_dir_open(deps_dir, 0, NULL);
+    if (dp_deps == NULL) {
+        g_debug("failed to list entries in %s", deps_dir);
+        return;
+    }
+    disk->has_dependencies = true;
+    while ((dep = g_dir_read_name(dp_deps)) != NULL) {
+        g_autofree char *dep_dir = NULL;
+        char *dev_name;
+
+        /* Add dependent disks */
+        dep_dir = g_strdup_printf("%s/%s", deps_dir, dep);
+        dev_name = get_device_for_syspath(dep_dir);
+        if (dev_name != NULL) {
+            g_debug("  adding dependent device: %s", dev_name);
+            QAPI_LIST_PREPEND(disk->dependencies, dev_name);
+        }
+    }
+    g_dir_close(dp_deps);
+}
+
+/*
+ * Detect partitions subdirectory, name is "<disk_name><number>" or
+ * "<disk_name>p<number>"
+ *
+ * @disk_name -- last component of /sys path (e.g. sda)
+ * @disk_dir -- sys path of the disk (e.g. /sys/block/sda)
+ * @disk_dev -- device node of the disk (e.g. /dev/sda)
+ */
+static GuestDiskInfoList *get_disk_partitions(
+    GuestDiskInfoList *list,
+    const char *disk_name, const char *disk_dir,
+    const char *disk_dev)
+{
+    GuestDiskInfoList *ret = list;
+    struct dirent *de_disk;
+    DIR *dp_disk = NULL;
+    size_t len = strlen(disk_name);
+
+    dp_disk = opendir(disk_dir);
+    while ((de_disk = readdir(dp_disk)) != NULL) {
+        g_autofree char *partition_dir = NULL;
+        char *dev_name;
+        GuestDiskInfo *partition;
+
+        if (!(de_disk->d_type & DT_DIR)) {
+            continue;
+        }
+
+        if (!(strncmp(disk_name, de_disk->d_name, len) == 0 &&
+            ((*(de_disk->d_name + len) == 'p' &&
+            isdigit(*(de_disk->d_name + len + 1))) ||
+                isdigit(*(de_disk->d_name + len))))) {
+            continue;
+        }
+
+        partition_dir = g_strdup_printf("%s/%s",
+            disk_dir, de_disk->d_name);
+        dev_name = get_device_for_syspath(partition_dir);
+        if (dev_name == NULL) {
+            g_debug("Failed to get device name for syspath: %s",
+                disk_dir);
+            continue;
+        }
+        partition = g_new0(GuestDiskInfo, 1);
+        partition->name = dev_name;
+        partition->partition = true;
+        partition->has_dependencies = true;
+        /* Add parent disk as dependent for easier tracking of hierarchy */
+        QAPI_LIST_PREPEND(partition->dependencies, g_strdup(disk_dev));
+
+        QAPI_LIST_PREPEND(ret, partition);
+    }
+    closedir(dp_disk);
+
+    return ret;
+}
+
+static void get_nvme_smart(GuestDiskInfo *disk)
+{
+    int fd;
+    GuestNVMeSmart *smart;
+    NvmeSmartLog log = {0};
+    struct nvme_admin_cmd cmd = {
+        .opcode = NVME_ADM_CMD_GET_LOG_PAGE,
+        .nsid = NVME_NSID_BROADCAST,
+        .addr = (uintptr_t)&log,
+        .data_len = sizeof(log),
+        .cdw10 = NVME_LOG_SMART_INFO | (1 << 15) /* RAE bit */
+                 | (((sizeof(log) >> 2) - 1) << 16)
+    };
+
+    fd = qga_open_cloexec(disk->name, O_RDONLY, 0);
+    if (fd == -1) {
+        g_debug("Failed to open device: %s: %s", disk->name, g_strerror(errno));
+        return;
+    }
+
+    if (ioctl(fd, NVME_IOCTL_ADMIN_CMD, &cmd)) {
+        g_debug("Failed to get smart: %s: %s", disk->name, g_strerror(errno));
+        close(fd);
+        return;
+    }
+
+    disk->smart = g_new0(GuestDiskSmart, 1);
+    disk->smart->type = GUEST_DISK_BUS_TYPE_NVME;
+
+    smart = &disk->smart->u.nvme;
+    smart->critical_warning = log.critical_warning;
+    smart->temperature = lduw_le_p(&log.temperature); /* unaligned field */
+    smart->available_spare = log.available_spare;
+    smart->available_spare_threshold = log.available_spare_threshold;
+    smart->percentage_used = log.percentage_used;
+    smart->data_units_read_lo = le64_to_cpu(log.data_units_read[0]);
+    smart->data_units_read_hi = le64_to_cpu(log.data_units_read[1]);
+    smart->data_units_written_lo = le64_to_cpu(log.data_units_written[0]);
+    smart->data_units_written_hi = le64_to_cpu(log.data_units_written[1]);
+    smart->host_read_commands_lo = le64_to_cpu(log.host_read_commands[0]);
+    smart->host_read_commands_hi = le64_to_cpu(log.host_read_commands[1]);
+    smart->host_write_commands_lo = le64_to_cpu(log.host_write_commands[0]);
+    smart->host_write_commands_hi = le64_to_cpu(log.host_write_commands[1]);
+    smart->controller_busy_time_lo = le64_to_cpu(log.controller_busy_time[0]);
+    smart->controller_busy_time_hi = le64_to_cpu(log.controller_busy_time[1]);
+    smart->power_cycles_lo = le64_to_cpu(log.power_cycles[0]);
+    smart->power_cycles_hi = le64_to_cpu(log.power_cycles[1]);
+    smart->power_on_hours_lo = le64_to_cpu(log.power_on_hours[0]);
+    smart->power_on_hours_hi = le64_to_cpu(log.power_on_hours[1]);
+    smart->unsafe_shutdowns_lo = le64_to_cpu(log.unsafe_shutdowns[0]);
+    smart->unsafe_shutdowns_hi = le64_to_cpu(log.unsafe_shutdowns[1]);
+    smart->media_errors_lo = le64_to_cpu(log.media_errors[0]);
+    smart->media_errors_hi = le64_to_cpu(log.media_errors[1]);
+    smart->number_of_error_log_entries_lo =
+        le64_to_cpu(log.number_of_error_log_entries[0]);
+    smart->number_of_error_log_entries_hi =
+        le64_to_cpu(log.number_of_error_log_entries[1]);
+
+    close(fd);
+}
+
+static void get_disk_smart(GuestDiskInfo *disk)
+{
+    if (disk->address
+        && (disk->address->bus_type == GUEST_DISK_BUS_TYPE_NVME)) {
+        get_nvme_smart(disk);
+    }
+}
+
+GuestDiskInfoList *qmp_guest_get_disks(Error **errp)
+{
+    GuestDiskInfoList *ret = NULL;
+    GuestDiskInfo *disk;
+    DIR *dp = NULL;
+    struct dirent *de = NULL;
+
+    g_debug("listing /sys/block directory");
+    dp = opendir("/sys/block");
+    if (dp == NULL) {
+        error_setg_errno(errp, errno, "Can't open directory \"/sys/block\"");
+        return NULL;
+    }
+    while ((de = readdir(dp)) != NULL) {
+        g_autofree char *disk_dir = NULL, *line = NULL,
+            *size_path = NULL;
+        char *dev_name;
+        Error *local_err = NULL;
+        if (de->d_type != DT_LNK) {
+            g_debug("  skipping entry: %s", de->d_name);
+            continue;
+        }
+
+        /* Check size and skip zero-sized disks */
+        g_debug("  checking disk size");
+        size_path = g_strdup_printf("/sys/block/%s/size", de->d_name);
+        if (!g_file_get_contents(size_path, &line, NULL, NULL)) {
+            g_debug("  failed to read disk size");
+            continue;
+        }
+        if (g_strcmp0(line, "0\n") == 0) {
+            g_debug("  skipping zero-sized disk");
+            continue;
+        }
+
+        g_debug("  adding %s", de->d_name);
+        disk_dir = g_strdup_printf("/sys/block/%s", de->d_name);
+        dev_name = get_device_for_syspath(disk_dir);
+        if (dev_name == NULL) {
+            g_debug("Failed to get device name for syspath: %s",
+                disk_dir);
+            continue;
+        }
+        disk = g_new0(GuestDiskInfo, 1);
+        disk->name = dev_name;
+        disk->partition = false;
+        disk->alias = get_alias_for_syspath(disk_dir);
+        QAPI_LIST_PREPEND(ret, disk);
+
+        /* Get address for non-virtual devices */
+        bool is_virtual = is_disk_virtual(disk_dir, &local_err);
+        if (local_err != NULL) {
+            g_debug("  failed to check disk path, ignoring error: %s",
+                error_get_pretty(local_err));
+            error_free(local_err);
+            local_err = NULL;
+            /* Don't try to get the address */
+            is_virtual = true;
+        }
+        if (!is_virtual) {
+            disk->address = get_disk_address(disk_dir, &local_err);
+            if (local_err != NULL) {
+                g_debug("  failed to get device info, ignoring error: %s",
+                    error_get_pretty(local_err));
+                error_free(local_err);
+                local_err = NULL;
+            }
+        }
+
+        get_disk_deps(disk_dir, disk);
+        get_disk_smart(disk);
+        ret = get_disk_partitions(ret, de->d_name, disk_dir, dev_name);
+    }
+
+    closedir(dp);
+
+    return ret;
+}
+
+#else
+
+GuestDiskInfoList *qmp_guest_get_disks(Error **errp)
+{
+    error_setg(errp, QERR_UNSUPPORTED);
+    return NULL;
+}
+
+#endif
+
+/* Return a list of the disk device(s)' info which @mount lies on */
+static GuestFilesystemInfo *build_guest_fsinfo(struct FsMount *mount,
+                                               Error **errp)
+{
+    GuestFilesystemInfo *fs = g_malloc0(sizeof(*fs));
+    struct statvfs buf;
+    unsigned long used, nonroot_total, fr_size;
+    char *devpath = g_strdup_printf("/sys/dev/block/%u:%u",
+                                    mount->devmajor, mount->devminor);
+
+    fs->mountpoint = g_strdup(mount->dirname);
+    fs->type = g_strdup(mount->devtype);
+    build_guest_fsinfo_for_device(devpath, fs, errp);
+
+    if (statvfs(fs->mountpoint, &buf) == 0) {
+        fr_size = buf.f_frsize;
+        used = buf.f_blocks - buf.f_bfree;
+        nonroot_total = used + buf.f_bavail;
+        fs->used_bytes = used * fr_size;
+        fs->total_bytes = nonroot_total * fr_size;
+        fs->total_bytes_privileged = buf.f_blocks * fr_size;
+
+        fs->has_total_bytes = true;
+        fs->has_total_bytes_privileged = true;
+        fs->has_used_bytes = true;
+    }
+
+    g_free(devpath);
+
+    return fs;
+}
+
+GuestFilesystemInfoList *qmp_guest_get_fsinfo(Error **errp)
+{
+    FsMountList mounts;
+    struct FsMount *mount;
+    GuestFilesystemInfoList *ret = NULL;
+    Error *local_err = NULL;
+
+    QTAILQ_INIT(&mounts);
+    if (!build_fs_mount_list(&mounts, &local_err)) {
+        error_propagate(errp, local_err);
+        return NULL;
+    }
+
+    QTAILQ_FOREACH(mount, &mounts, next) {
+        g_debug("Building guest fsinfo for '%s'", mount->dirname);
+
+        QAPI_LIST_PREPEND(ret, build_guest_fsinfo(mount, &local_err));
+        if (local_err) {
+            error_propagate(errp, local_err);
+            qapi_free_GuestFilesystemInfoList(ret);
+            ret = NULL;
+            break;
+        }
+    }
+
+    free_fs_mount_list(&mounts);
+    return ret;
+}
+#endif /* CONFIG_FSFREEZE */
+
+#if defined(CONFIG_FSTRIM)
+/*
+ * Walk list of mounted file systems in the guest, and trim them.
+ */
+GuestFilesystemTrimResponse *
+qmp_guest_fstrim(bool has_minimum, int64_t minimum, Error **errp)
+{
+    GuestFilesystemTrimResponse *response;
+    GuestFilesystemTrimResult *result;
+    int ret = 0;
+    FsMountList mounts;
+    struct FsMount *mount;
+    int fd;
+    struct fstrim_range r;
+
+    slog("guest-fstrim called");
+
+    QTAILQ_INIT(&mounts);
+    if (!build_fs_mount_list(&mounts, errp)) {
+        return NULL;
+    }
+
+    response = g_malloc0(sizeof(*response));
+
+    QTAILQ_FOREACH(mount, &mounts, next) {
+        result = g_malloc0(sizeof(*result));
+        result->path = g_strdup(mount->dirname);
+
+        QAPI_LIST_PREPEND(response->paths, result);
+
+        fd = qga_open_cloexec(mount->dirname, O_RDONLY, 0);
+        if (fd == -1) {
+            result->error = g_strdup_printf("failed to open: %s",
+                                            strerror(errno));
+            continue;
+        }
+
+        /* We try to cull filesystems we know won't work in advance, but other
+         * filesystems may not implement fstrim for less obvious reasons.
+         * These will report EOPNOTSUPP; while in some other cases ENOTTY
+         * will be reported (e.g. CD-ROMs).
+         * Any other error means an unexpected error.
+         */
+        r.start = 0;
+        r.len = -1;
+        r.minlen = has_minimum ? minimum : 0;
+        ret = ioctl(fd, FITRIM, &r);
+        if (ret == -1) {
+            if (errno == ENOTTY || errno == EOPNOTSUPP) {
+                result->error = g_strdup("trim not supported");
+            } else {
+                result->error = g_strdup_printf("failed to trim: %s",
+                                                strerror(errno));
+            }
+            close(fd);
+            continue;
+        }
+
+        result->has_minimum = true;
+        result->minimum = r.minlen;
+        result->has_trimmed = true;
+        result->trimmed = r.len;
+        close(fd);
+    }
+
+    free_fs_mount_list(&mounts);
+    return response;
+}
+#endif /* CONFIG_FSTRIM */
 
 #define LINUX_SYS_STATE_FILE "/sys/power/state"
 #define SUSPEND_SUPPORTED 0
diff --git a/qga/commands-posix.c b/qga/commands-posix.c
index ef21da63be..98aafc45f3 100644
--- a/qga/commands-posix.c
+++ b/qga/commands-posix.c
@@ -24,23 +24,12 @@
 #include "qemu/base64.h"
 #include "qemu/cutils.h"
 #include "commands-common.h"
-#include "block/nvme.h"
 #include "cutils.h"
 
 #ifdef HAVE_UTMPX
 #include <utmpx.h>
 #endif
 
-#if defined(__linux__)
-#include <mntent.h>
-#include <sys/statvfs.h>
-#include <linux/nvme_ioctl.h>
-
-#ifdef CONFIG_LIBUDEV
-#include <libudev.h>
-#endif
-#endif
-
 #ifdef HAVE_GETIFADDRS
 #include <arpa/inet.h>
 #include <sys/socket.h>
@@ -842,904 +831,6 @@ static void guest_fsfreeze_cleanup(void)
 }
 #endif
 
-/* linux-specific implementations. avoid this if at all possible. */
-#if defined(__linux__)
-#if defined(CONFIG_FSFREEZE)
-
-static char *get_pci_driver(char const *syspath, int pathlen, Error **errp)
-{
-    char *path;
-    char *dpath;
-    char *driver = NULL;
-    char buf[PATH_MAX];
-    ssize_t len;
-
-    path = g_strndup(syspath, pathlen);
-    dpath = g_strdup_printf("%s/driver", path);
-    len = readlink(dpath, buf, sizeof(buf) - 1);
-    if (len != -1) {
-        buf[len] = 0;
-        driver = g_path_get_basename(buf);
-    }
-    g_free(dpath);
-    g_free(path);
-    return driver;
-}
-
-static int compare_uint(const void *_a, const void *_b)
-{
-    unsigned int a = *(unsigned int *)_a;
-    unsigned int b = *(unsigned int *)_b;
-
-    return a < b ? -1 : a > b ? 1 : 0;
-}
-
-/* Walk the specified sysfs and build a sorted list of host or ata numbers */
-static int build_hosts(char const *syspath, char const *host, bool ata,
-                       unsigned int *hosts, int hosts_max, Error **errp)
-{
-    char *path;
-    DIR *dir;
-    struct dirent *entry;
-    int i = 0;
-
-    path = g_strndup(syspath, host - syspath);
-    dir = opendir(path);
-    if (!dir) {
-        error_setg_errno(errp, errno, "opendir(\"%s\")", path);
-        g_free(path);
-        return -1;
-    }
-
-    while (i < hosts_max) {
-        entry = readdir(dir);
-        if (!entry) {
-            break;
-        }
-        if (ata && sscanf(entry->d_name, "ata%d", hosts + i) == 1) {
-            ++i;
-        } else if (!ata && sscanf(entry->d_name, "host%d", hosts + i) == 1) {
-            ++i;
-        }
-    }
-
-    qsort(hosts, i, sizeof(hosts[0]), compare_uint);
-
-    g_free(path);
-    closedir(dir);
-    return i;
-}
-
-/*
- * Store disk device info for devices on the PCI bus.
- * Returns true if information has been stored, or false for failure.
- */
-static bool build_guest_fsinfo_for_pci_dev(char const *syspath,
-                                           GuestDiskAddress *disk,
-                                           Error **errp)
-{
-    unsigned int pci[4], host, hosts[8], tgt[3];
-    int i, nhosts = 0, pcilen;
-    GuestPCIAddress *pciaddr = disk->pci_controller;
-    bool has_ata = false, has_host = false, has_tgt = false;
-    char *p, *q, *driver = NULL;
-    bool ret = false;
-
-    p = strstr(syspath, "/devices/pci");
-    if (!p || sscanf(p + 12, "%*x:%*x/%x:%x:%x.%x%n",
-                     pci, pci + 1, pci + 2, pci + 3, &pcilen) < 4) {
-        g_debug("only pci device is supported: sysfs path '%s'", syspath);
-        return false;
-    }
-
-    p += 12 + pcilen;
-    while (true) {
-        driver = get_pci_driver(syspath, p - syspath, errp);
-        if (driver && (g_str_equal(driver, "ata_piix") ||
-                       g_str_equal(driver, "sym53c8xx") ||
-                       g_str_equal(driver, "virtio-pci") ||
-                       g_str_equal(driver, "ahci") ||
-                       g_str_equal(driver, "nvme") ||
-                       g_str_equal(driver, "xhci_hcd") ||
-                       g_str_equal(driver, "ehci-pci"))) {
-            break;
-        }
-
-        g_free(driver);
-        if (sscanf(p, "/%x:%x:%x.%x%n",
-                          pci, pci + 1, pci + 2, pci + 3, &pcilen) == 4) {
-            p += pcilen;
-            continue;
-        }
-
-        g_debug("unsupported driver or sysfs path '%s'", syspath);
-        return false;
-    }
-
-    p = strstr(syspath, "/target");
-    if (p && sscanf(p + 7, "%*u:%*u:%*u/%*u:%u:%u:%u",
-                    tgt, tgt + 1, tgt + 2) == 3) {
-        has_tgt = true;
-    }
-
-    p = strstr(syspath, "/ata");
-    if (p) {
-        q = p + 4;
-        has_ata = true;
-    } else {
-        p = strstr(syspath, "/host");
-        q = p + 5;
-    }
-    if (p && sscanf(q, "%u", &host) == 1) {
-        has_host = true;
-        nhosts = build_hosts(syspath, p, has_ata, hosts,
-                             ARRAY_SIZE(hosts), errp);
-        if (nhosts < 0) {
-            goto cleanup;
-        }
-    }
-
-    pciaddr->domain = pci[0];
-    pciaddr->bus = pci[1];
-    pciaddr->slot = pci[2];
-    pciaddr->function = pci[3];
-
-    if (strcmp(driver, "ata_piix") == 0) {
-        /* a host per ide bus, target*:0:<unit>:0 */
-        if (!has_host || !has_tgt) {
-            g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver);
-            goto cleanup;
-        }
-        for (i = 0; i < nhosts; i++) {
-            if (host == hosts[i]) {
-                disk->bus_type = GUEST_DISK_BUS_TYPE_IDE;
-                disk->bus = i;
-                disk->unit = tgt[1];
-                break;
-            }
-        }
-        if (i >= nhosts) {
-            g_debug("no host for '%s' (driver '%s')", syspath, driver);
-            goto cleanup;
-        }
-    } else if (strcmp(driver, "sym53c8xx") == 0) {
-        /* scsi(LSI Logic): target*:0:<unit>:0 */
-        if (!has_tgt) {
-            g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver);
-            goto cleanup;
-        }
-        disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI;
-        disk->unit = tgt[1];
-    } else if (strcmp(driver, "virtio-pci") == 0) {
-        if (has_tgt) {
-            /* virtio-scsi: target*:0:0:<unit> */
-            disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI;
-            disk->unit = tgt[2];
-        } else {
-            /* virtio-blk: 1 disk per 1 device */
-            disk->bus_type = GUEST_DISK_BUS_TYPE_VIRTIO;
-        }
-    } else if (strcmp(driver, "ahci") == 0) {
-        /* ahci: 1 host per 1 unit */
-        if (!has_host || !has_tgt) {
-            g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver);
-            goto cleanup;
-        }
-        for (i = 0; i < nhosts; i++) {
-            if (host == hosts[i]) {
-                disk->unit = i;
-                disk->bus_type = GUEST_DISK_BUS_TYPE_SATA;
-                break;
-            }
-        }
-        if (i >= nhosts) {
-            g_debug("no host for '%s' (driver '%s')", syspath, driver);
-            goto cleanup;
-        }
-    } else if (strcmp(driver, "nvme") == 0) {
-        disk->bus_type = GUEST_DISK_BUS_TYPE_NVME;
-    } else if (strcmp(driver, "ehci-pci") == 0 || strcmp(driver, "xhci_hcd") == 0) {
-        disk->bus_type = GUEST_DISK_BUS_TYPE_USB;
-    } else {
-        g_debug("unknown driver '%s' (sysfs path '%s')", driver, syspath);
-        goto cleanup;
-    }
-
-    ret = true;
-
-cleanup:
-    g_free(driver);
-    return ret;
-}
-
-/*
- * Store disk device info for non-PCI virtio devices (for example s390x
- * channel I/O devices). Returns true if information has been stored, or
- * false for failure.
- */
-static bool build_guest_fsinfo_for_nonpci_virtio(char const *syspath,
-                                                 GuestDiskAddress *disk,
-                                                 Error **errp)
-{
-    unsigned int tgt[3];
-    char *p;
-
-    if (!strstr(syspath, "/virtio") || !strstr(syspath, "/block")) {
-        g_debug("Unsupported virtio device '%s'", syspath);
-        return false;
-    }
-
-    p = strstr(syspath, "/target");
-    if (p && sscanf(p + 7, "%*u:%*u:%*u/%*u:%u:%u:%u",
-                    &tgt[0], &tgt[1], &tgt[2]) == 3) {
-        /* virtio-scsi: target*:0:<target>:<unit> */
-        disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI;
-        disk->bus = tgt[0];
-        disk->target = tgt[1];
-        disk->unit = tgt[2];
-    } else {
-        /* virtio-blk: 1 disk per 1 device */
-        disk->bus_type = GUEST_DISK_BUS_TYPE_VIRTIO;
-    }
-
-    return true;
-}
-
-/*
- * Store disk device info for CCW devices (s390x channel I/O devices).
- * Returns true if information has been stored, or false for failure.
- */
-static bool build_guest_fsinfo_for_ccw_dev(char const *syspath,
-                                           GuestDiskAddress *disk,
-                                           Error **errp)
-{
-    unsigned int cssid, ssid, subchno, devno;
-    char *p;
-
-    p = strstr(syspath, "/devices/css");
-    if (!p || sscanf(p + 12, "%*x/%x.%x.%x/%*x.%*x.%x/",
-                     &cssid, &ssid, &subchno, &devno) < 4) {
-        g_debug("could not parse ccw device sysfs path: %s", syspath);
-        return false;
-    }
-
-    disk->ccw_address = g_new0(GuestCCWAddress, 1);
-    disk->ccw_address->cssid = cssid;
-    disk->ccw_address->ssid = ssid;
-    disk->ccw_address->subchno = subchno;
-    disk->ccw_address->devno = devno;
-
-    if (strstr(p, "/virtio")) {
-        build_guest_fsinfo_for_nonpci_virtio(syspath, disk, errp);
-    }
-
-    return true;
-}
-
-/* Store disk device info specified by @sysfs into @fs */
-static void build_guest_fsinfo_for_real_device(char const *syspath,
-                                               GuestFilesystemInfo *fs,
-                                               Error **errp)
-{
-    GuestDiskAddress *disk;
-    GuestPCIAddress *pciaddr;
-    bool has_hwinf;
-#ifdef CONFIG_LIBUDEV
-    struct udev *udev = NULL;
-    struct udev_device *udevice = NULL;
-#endif
-
-    pciaddr = g_new0(GuestPCIAddress, 1);
-    pciaddr->domain = -1;                       /* -1 means field is invalid */
-    pciaddr->bus = -1;
-    pciaddr->slot = -1;
-    pciaddr->function = -1;
-
-    disk = g_new0(GuestDiskAddress, 1);
-    disk->pci_controller = pciaddr;
-    disk->bus_type = GUEST_DISK_BUS_TYPE_UNKNOWN;
-
-#ifdef CONFIG_LIBUDEV
-    udev = udev_new();
-    udevice = udev_device_new_from_syspath(udev, syspath);
-    if (udev == NULL || udevice == NULL) {
-        g_debug("failed to query udev");
-    } else {
-        const char *devnode, *serial;
-        devnode = udev_device_get_devnode(udevice);
-        if (devnode != NULL) {
-            disk->dev = g_strdup(devnode);
-        }
-        serial = udev_device_get_property_value(udevice, "ID_SERIAL");
-        if (serial != NULL && *serial != 0) {
-            disk->serial = g_strdup(serial);
-        }
-    }
-
-    udev_unref(udev);
-    udev_device_unref(udevice);
-#endif
-
-    if (strstr(syspath, "/devices/pci")) {
-        has_hwinf = build_guest_fsinfo_for_pci_dev(syspath, disk, errp);
-    } else if (strstr(syspath, "/devices/css")) {
-        has_hwinf = build_guest_fsinfo_for_ccw_dev(syspath, disk, errp);
-    } else if (strstr(syspath, "/virtio")) {
-        has_hwinf = build_guest_fsinfo_for_nonpci_virtio(syspath, disk, errp);
-    } else {
-        g_debug("Unsupported device type for '%s'", syspath);
-        has_hwinf = false;
-    }
-
-    if (has_hwinf || disk->dev || disk->serial) {
-        QAPI_LIST_PREPEND(fs->disk, disk);
-    } else {
-        qapi_free_GuestDiskAddress(disk);
-    }
-}
-
-static void build_guest_fsinfo_for_device(char const *devpath,
-                                          GuestFilesystemInfo *fs,
-                                          Error **errp);
-
-/* Store a list of slave devices of virtual volume specified by @syspath into
- * @fs */
-static void build_guest_fsinfo_for_virtual_device(char const *syspath,
-                                                  GuestFilesystemInfo *fs,
-                                                  Error **errp)
-{
-    Error *err = NULL;
-    DIR *dir;
-    char *dirpath;
-    struct dirent *entry;
-
-    dirpath = g_strdup_printf("%s/slaves", syspath);
-    dir = opendir(dirpath);
-    if (!dir) {
-        if (errno != ENOENT) {
-            error_setg_errno(errp, errno, "opendir(\"%s\")", dirpath);
-        }
-        g_free(dirpath);
-        return;
-    }
-
-    for (;;) {
-        errno = 0;
-        entry = readdir(dir);
-        if (entry == NULL) {
-            if (errno) {
-                error_setg_errno(errp, errno, "readdir(\"%s\")", dirpath);
-            }
-            break;
-        }
-
-        if (entry->d_type == DT_LNK) {
-            char *path;
-
-            g_debug(" slave device '%s'", entry->d_name);
-            path = g_strdup_printf("%s/slaves/%s", syspath, entry->d_name);
-            build_guest_fsinfo_for_device(path, fs, &err);
-            g_free(path);
-
-            if (err) {
-                error_propagate(errp, err);
-                break;
-            }
-        }
-    }
-
-    g_free(dirpath);
-    closedir(dir);
-}
-
-static bool is_disk_virtual(const char *devpath, Error **errp)
-{
-    g_autofree char *syspath = realpath(devpath, NULL);
-
-    if (!syspath) {
-        error_setg_errno(errp, errno, "realpath(\"%s\")", devpath);
-        return false;
-    }
-    return strstr(syspath, "/devices/virtual/block/") != NULL;
-}
-
-/* Dispatch to functions for virtual/real device */
-static void build_guest_fsinfo_for_device(char const *devpath,
-                                          GuestFilesystemInfo *fs,
-                                          Error **errp)
-{
-    ERRP_GUARD();
-    g_autofree char *syspath = NULL;
-    bool is_virtual = false;
-
-    syspath = realpath(devpath, NULL);
-    if (!syspath) {
-        if (errno != ENOENT) {
-            error_setg_errno(errp, errno, "realpath(\"%s\")", devpath);
-            return;
-        }
-
-        /* ENOENT: This devpath may not exist because of container config */
-        if (!fs->name) {
-            fs->name = g_path_get_basename(devpath);
-        }
-        return;
-    }
-
-    if (!fs->name) {
-        fs->name = g_path_get_basename(syspath);
-    }
-
-    g_debug("  parse sysfs path '%s'", syspath);
-    is_virtual = is_disk_virtual(syspath, errp);
-    if (*errp != NULL) {
-        return;
-    }
-    if (is_virtual) {
-        build_guest_fsinfo_for_virtual_device(syspath, fs, errp);
-    } else {
-        build_guest_fsinfo_for_real_device(syspath, fs, errp);
-    }
-}
-
-#ifdef CONFIG_LIBUDEV
-
-/*
- * Wrapper around build_guest_fsinfo_for_device() for getting just
- * the disk address.
- */
-static GuestDiskAddress *get_disk_address(const char *syspath, Error **errp)
-{
-    g_autoptr(GuestFilesystemInfo) fs = NULL;
-
-    fs = g_new0(GuestFilesystemInfo, 1);
-    build_guest_fsinfo_for_device(syspath, fs, errp);
-    if (fs->disk != NULL) {
-        return g_steal_pointer(&fs->disk->value);
-    }
-    return NULL;
-}
-
-static char *get_alias_for_syspath(const char *syspath)
-{
-    struct udev *udev = NULL;
-    struct udev_device *udevice = NULL;
-    char *ret = NULL;
-
-    udev = udev_new();
-    if (udev == NULL) {
-        g_debug("failed to query udev");
-        goto out;
-    }
-    udevice = udev_device_new_from_syspath(udev, syspath);
-    if (udevice == NULL) {
-        g_debug("failed to query udev for path: %s", syspath);
-        goto out;
-    } else {
-        const char *alias = udev_device_get_property_value(
-            udevice, "DM_NAME");
-        /*
-         * NULL means there was an error and empty string means there is no
-         * alias. In case of no alias we return NULL instead of empty string.
-         */
-        if (alias == NULL) {
-            g_debug("failed to query udev for device alias for: %s",
-                syspath);
-        } else if (*alias != 0) {
-            ret = g_strdup(alias);
-        }
-    }
-
-out:
-    udev_unref(udev);
-    udev_device_unref(udevice);
-    return ret;
-}
-
-static char *get_device_for_syspath(const char *syspath)
-{
-    struct udev *udev = NULL;
-    struct udev_device *udevice = NULL;
-    char *ret = NULL;
-
-    udev = udev_new();
-    if (udev == NULL) {
-        g_debug("failed to query udev");
-        goto out;
-    }
-    udevice = udev_device_new_from_syspath(udev, syspath);
-    if (udevice == NULL) {
-        g_debug("failed to query udev for path: %s", syspath);
-        goto out;
-    } else {
-        ret = g_strdup(udev_device_get_devnode(udevice));
-    }
-
-out:
-    udev_unref(udev);
-    udev_device_unref(udevice);
-    return ret;
-}
-
-static void get_disk_deps(const char *disk_dir, GuestDiskInfo *disk)
-{
-    g_autofree char *deps_dir = NULL;
-    const gchar *dep;
-    GDir *dp_deps = NULL;
-
-    /* List dependent disks */
-    deps_dir = g_strdup_printf("%s/slaves", disk_dir);
-    g_debug("  listing entries in: %s", deps_dir);
-    dp_deps = g_dir_open(deps_dir, 0, NULL);
-    if (dp_deps == NULL) {
-        g_debug("failed to list entries in %s", deps_dir);
-        return;
-    }
-    disk->has_dependencies = true;
-    while ((dep = g_dir_read_name(dp_deps)) != NULL) {
-        g_autofree char *dep_dir = NULL;
-        char *dev_name;
-
-        /* Add dependent disks */
-        dep_dir = g_strdup_printf("%s/%s", deps_dir, dep);
-        dev_name = get_device_for_syspath(dep_dir);
-        if (dev_name != NULL) {
-            g_debug("  adding dependent device: %s", dev_name);
-            QAPI_LIST_PREPEND(disk->dependencies, dev_name);
-        }
-    }
-    g_dir_close(dp_deps);
-}
-
-/*
- * Detect partitions subdirectory, name is "<disk_name><number>" or
- * "<disk_name>p<number>"
- *
- * @disk_name -- last component of /sys path (e.g. sda)
- * @disk_dir -- sys path of the disk (e.g. /sys/block/sda)
- * @disk_dev -- device node of the disk (e.g. /dev/sda)
- */
-static GuestDiskInfoList *get_disk_partitions(
-    GuestDiskInfoList *list,
-    const char *disk_name, const char *disk_dir,
-    const char *disk_dev)
-{
-    GuestDiskInfoList *ret = list;
-    struct dirent *de_disk;
-    DIR *dp_disk = NULL;
-    size_t len = strlen(disk_name);
-
-    dp_disk = opendir(disk_dir);
-    while ((de_disk = readdir(dp_disk)) != NULL) {
-        g_autofree char *partition_dir = NULL;
-        char *dev_name;
-        GuestDiskInfo *partition;
-
-        if (!(de_disk->d_type & DT_DIR)) {
-            continue;
-        }
-
-        if (!(strncmp(disk_name, de_disk->d_name, len) == 0 &&
-            ((*(de_disk->d_name + len) == 'p' &&
-            isdigit(*(de_disk->d_name + len + 1))) ||
-                isdigit(*(de_disk->d_name + len))))) {
-            continue;
-        }
-
-        partition_dir = g_strdup_printf("%s/%s",
-            disk_dir, de_disk->d_name);
-        dev_name = get_device_for_syspath(partition_dir);
-        if (dev_name == NULL) {
-            g_debug("Failed to get device name for syspath: %s",
-                disk_dir);
-            continue;
-        }
-        partition = g_new0(GuestDiskInfo, 1);
-        partition->name = dev_name;
-        partition->partition = true;
-        partition->has_dependencies = true;
-        /* Add parent disk as dependent for easier tracking of hierarchy */
-        QAPI_LIST_PREPEND(partition->dependencies, g_strdup(disk_dev));
-
-        QAPI_LIST_PREPEND(ret, partition);
-    }
-    closedir(dp_disk);
-
-    return ret;
-}
-
-static void get_nvme_smart(GuestDiskInfo *disk)
-{
-    int fd;
-    GuestNVMeSmart *smart;
-    NvmeSmartLog log = {0};
-    struct nvme_admin_cmd cmd = {
-        .opcode = NVME_ADM_CMD_GET_LOG_PAGE,
-        .nsid = NVME_NSID_BROADCAST,
-        .addr = (uintptr_t)&log,
-        .data_len = sizeof(log),
-        .cdw10 = NVME_LOG_SMART_INFO | (1 << 15) /* RAE bit */
-                 | (((sizeof(log) >> 2) - 1) << 16)
-    };
-
-    fd = qga_open_cloexec(disk->name, O_RDONLY, 0);
-    if (fd == -1) {
-        g_debug("Failed to open device: %s: %s", disk->name, g_strerror(errno));
-        return;
-    }
-
-    if (ioctl(fd, NVME_IOCTL_ADMIN_CMD, &cmd)) {
-        g_debug("Failed to get smart: %s: %s", disk->name, g_strerror(errno));
-        close(fd);
-        return;
-    }
-
-    disk->smart = g_new0(GuestDiskSmart, 1);
-    disk->smart->type = GUEST_DISK_BUS_TYPE_NVME;
-
-    smart = &disk->smart->u.nvme;
-    smart->critical_warning = log.critical_warning;
-    smart->temperature = lduw_le_p(&log.temperature); /* unaligned field */
-    smart->available_spare = log.available_spare;
-    smart->available_spare_threshold = log.available_spare_threshold;
-    smart->percentage_used = log.percentage_used;
-    smart->data_units_read_lo = le64_to_cpu(log.data_units_read[0]);
-    smart->data_units_read_hi = le64_to_cpu(log.data_units_read[1]);
-    smart->data_units_written_lo = le64_to_cpu(log.data_units_written[0]);
-    smart->data_units_written_hi = le64_to_cpu(log.data_units_written[1]);
-    smart->host_read_commands_lo = le64_to_cpu(log.host_read_commands[0]);
-    smart->host_read_commands_hi = le64_to_cpu(log.host_read_commands[1]);
-    smart->host_write_commands_lo = le64_to_cpu(log.host_write_commands[0]);
-    smart->host_write_commands_hi = le64_to_cpu(log.host_write_commands[1]);
-    smart->controller_busy_time_lo = le64_to_cpu(log.controller_busy_time[0]);
-    smart->controller_busy_time_hi = le64_to_cpu(log.controller_busy_time[1]);
-    smart->power_cycles_lo = le64_to_cpu(log.power_cycles[0]);
-    smart->power_cycles_hi = le64_to_cpu(log.power_cycles[1]);
-    smart->power_on_hours_lo = le64_to_cpu(log.power_on_hours[0]);
-    smart->power_on_hours_hi = le64_to_cpu(log.power_on_hours[1]);
-    smart->unsafe_shutdowns_lo = le64_to_cpu(log.unsafe_shutdowns[0]);
-    smart->unsafe_shutdowns_hi = le64_to_cpu(log.unsafe_shutdowns[1]);
-    smart->media_errors_lo = le64_to_cpu(log.media_errors[0]);
-    smart->media_errors_hi = le64_to_cpu(log.media_errors[1]);
-    smart->number_of_error_log_entries_lo =
-        le64_to_cpu(log.number_of_error_log_entries[0]);
-    smart->number_of_error_log_entries_hi =
-        le64_to_cpu(log.number_of_error_log_entries[1]);
-
-    close(fd);
-}
-
-static void get_disk_smart(GuestDiskInfo *disk)
-{
-    if (disk->address
-        && (disk->address->bus_type == GUEST_DISK_BUS_TYPE_NVME)) {
-        get_nvme_smart(disk);
-    }
-}
-
-GuestDiskInfoList *qmp_guest_get_disks(Error **errp)
-{
-    GuestDiskInfoList *ret = NULL;
-    GuestDiskInfo *disk;
-    DIR *dp = NULL;
-    struct dirent *de = NULL;
-
-    g_debug("listing /sys/block directory");
-    dp = opendir("/sys/block");
-    if (dp == NULL) {
-        error_setg_errno(errp, errno, "Can't open directory \"/sys/block\"");
-        return NULL;
-    }
-    while ((de = readdir(dp)) != NULL) {
-        g_autofree char *disk_dir = NULL, *line = NULL,
-            *size_path = NULL;
-        char *dev_name;
-        Error *local_err = NULL;
-        if (de->d_type != DT_LNK) {
-            g_debug("  skipping entry: %s", de->d_name);
-            continue;
-        }
-
-        /* Check size and skip zero-sized disks */
-        g_debug("  checking disk size");
-        size_path = g_strdup_printf("/sys/block/%s/size", de->d_name);
-        if (!g_file_get_contents(size_path, &line, NULL, NULL)) {
-            g_debug("  failed to read disk size");
-            continue;
-        }
-        if (g_strcmp0(line, "0\n") == 0) {
-            g_debug("  skipping zero-sized disk");
-            continue;
-        }
-
-        g_debug("  adding %s", de->d_name);
-        disk_dir = g_strdup_printf("/sys/block/%s", de->d_name);
-        dev_name = get_device_for_syspath(disk_dir);
-        if (dev_name == NULL) {
-            g_debug("Failed to get device name for syspath: %s",
-                disk_dir);
-            continue;
-        }
-        disk = g_new0(GuestDiskInfo, 1);
-        disk->name = dev_name;
-        disk->partition = false;
-        disk->alias = get_alias_for_syspath(disk_dir);
-        QAPI_LIST_PREPEND(ret, disk);
-
-        /* Get address for non-virtual devices */
-        bool is_virtual = is_disk_virtual(disk_dir, &local_err);
-        if (local_err != NULL) {
-            g_debug("  failed to check disk path, ignoring error: %s",
-                error_get_pretty(local_err));
-            error_free(local_err);
-            local_err = NULL;
-            /* Don't try to get the address */
-            is_virtual = true;
-        }
-        if (!is_virtual) {
-            disk->address = get_disk_address(disk_dir, &local_err);
-            if (local_err != NULL) {
-                g_debug("  failed to get device info, ignoring error: %s",
-                    error_get_pretty(local_err));
-                error_free(local_err);
-                local_err = NULL;
-            }
-        }
-
-        get_disk_deps(disk_dir, disk);
-        get_disk_smart(disk);
-        ret = get_disk_partitions(ret, de->d_name, disk_dir, dev_name);
-    }
-
-    closedir(dp);
-
-    return ret;
-}
-
-#else
-
-GuestDiskInfoList *qmp_guest_get_disks(Error **errp)
-{
-    error_setg(errp, QERR_UNSUPPORTED);
-    return NULL;
-}
-
-#endif
-
-/* Return a list of the disk device(s)' info which @mount lies on */
-static GuestFilesystemInfo *build_guest_fsinfo(struct FsMount *mount,
-                                               Error **errp)
-{
-    GuestFilesystemInfo *fs = g_malloc0(sizeof(*fs));
-    struct statvfs buf;
-    unsigned long used, nonroot_total, fr_size;
-    char *devpath = g_strdup_printf("/sys/dev/block/%u:%u",
-                                    mount->devmajor, mount->devminor);
-
-    fs->mountpoint = g_strdup(mount->dirname);
-    fs->type = g_strdup(mount->devtype);
-    build_guest_fsinfo_for_device(devpath, fs, errp);
-
-    if (statvfs(fs->mountpoint, &buf) == 0) {
-        fr_size = buf.f_frsize;
-        used = buf.f_blocks - buf.f_bfree;
-        nonroot_total = used + buf.f_bavail;
-        fs->used_bytes = used * fr_size;
-        fs->total_bytes = nonroot_total * fr_size;
-        fs->total_bytes_privileged = buf.f_blocks * fr_size;
-
-        fs->has_total_bytes = true;
-        fs->has_total_bytes_privileged = true;
-        fs->has_used_bytes = true;
-    }
-
-    g_free(devpath);
-
-    return fs;
-}
-
-GuestFilesystemInfoList *qmp_guest_get_fsinfo(Error **errp)
-{
-    FsMountList mounts;
-    struct FsMount *mount;
-    GuestFilesystemInfoList *ret = NULL;
-    Error *local_err = NULL;
-
-    QTAILQ_INIT(&mounts);
-    if (!build_fs_mount_list(&mounts, &local_err)) {
-        error_propagate(errp, local_err);
-        return NULL;
-    }
-
-    QTAILQ_FOREACH(mount, &mounts, next) {
-        g_debug("Building guest fsinfo for '%s'", mount->dirname);
-
-        QAPI_LIST_PREPEND(ret, build_guest_fsinfo(mount, &local_err));
-        if (local_err) {
-            error_propagate(errp, local_err);
-            qapi_free_GuestFilesystemInfoList(ret);
-            ret = NULL;
-            break;
-        }
-    }
-
-    free_fs_mount_list(&mounts);
-    return ret;
-}
-#endif /* CONFIG_FSFREEZE */
-
-#if defined(CONFIG_FSTRIM)
-/*
- * Walk list of mounted file systems in the guest, and trim them.
- */
-GuestFilesystemTrimResponse *
-qmp_guest_fstrim(bool has_minimum, int64_t minimum, Error **errp)
-{
-    GuestFilesystemTrimResponse *response;
-    GuestFilesystemTrimResult *result;
-    int ret = 0;
-    FsMountList mounts;
-    struct FsMount *mount;
-    int fd;
-    struct fstrim_range r;
-
-    slog("guest-fstrim called");
-
-    QTAILQ_INIT(&mounts);
-    if (!build_fs_mount_list(&mounts, errp)) {
-        return NULL;
-    }
-
-    response = g_malloc0(sizeof(*response));
-
-    QTAILQ_FOREACH(mount, &mounts, next) {
-        result = g_malloc0(sizeof(*result));
-        result->path = g_strdup(mount->dirname);
-
-        QAPI_LIST_PREPEND(response->paths, result);
-
-        fd = qga_open_cloexec(mount->dirname, O_RDONLY, 0);
-        if (fd == -1) {
-            result->error = g_strdup_printf("failed to open: %s",
-                                            strerror(errno));
-            continue;
-        }
-
-        /* We try to cull filesystems we know won't work in advance, but other
-         * filesystems may not implement fstrim for less obvious reasons.
-         * These will report EOPNOTSUPP; while in some other cases ENOTTY
-         * will be reported (e.g. CD-ROMs).
-         * Any other error means an unexpected error.
-         */
-        r.start = 0;
-        r.len = -1;
-        r.minlen = has_minimum ? minimum : 0;
-        ret = ioctl(fd, FITRIM, &r);
-        if (ret == -1) {
-            if (errno == ENOTTY || errno == EOPNOTSUPP) {
-                result->error = g_strdup("trim not supported");
-            } else {
-                result->error = g_strdup_printf("failed to trim: %s",
-                                                strerror(errno));
-            }
-            close(fd);
-            continue;
-        }
-
-        result->has_minimum = true;
-        result->minimum = r.minlen;
-        result->has_trimmed = true;
-        result->trimmed = r.len;
-        close(fd);
-    }
-
-    free_fs_mount_list(&mounts);
-    return response;
-}
-#endif /* CONFIG_FSTRIM */
-
-#endif /* __linux__ */
-
 #if defined(__linux__) || defined(__FreeBSD__)
 void qmp_guest_set_user_password(const char *username,
                                  const char *password,
-- 
2.45.1

Re: [PATCH 04/20] qga: move linux fs/disk command impls to commands-linux.c

Posted by Manos Pitsidianakis 5 months, 3 weeks ago

On Tue, 04 Jun 2024 16:49, "Daniel P. Berrangé" <berrange@redhat.com> wrote:
>The qmp_guest_{fstrim, get_fsinfo, get_disks} command impls in
>commands-posix.c are surrounded by '#ifdef __linux__' so should
>instead live in commands-linux.c
>
>Signed-off-by: Daniel P. Berrangé <berrange@redhat.com>
>---


Reviewed-by: Manos Pitsidianakis <manos.pitsidianakis@linaro.org>

> qga/commands-linux.c | 904 ++++++++++++++++++++++++++++++++++++++++++
> qga/commands-posix.c | 909 -------------------------------------------
> 2 files changed, 904 insertions(+), 909 deletions(-)
>
>diff --git a/qga/commands-linux.c b/qga/commands-linux.c
>index 3fabf54882..084e6c9e85 100644
>--- a/qga/commands-linux.c
>+++ b/qga/commands-linux.c
>@@ -14,10 +14,21 @@
> #include "qemu/osdep.h"
> #include "qapi/error.h"
> #include "qga-qapi-commands.h"
>+#include "qapi/error.h"
>+#include "qapi/qmp/qerror.h"
> #include "commands-common.h"
> #include "cutils.h"
> #include <mntent.h>
> #include <sys/ioctl.h>
>+#include <mntent.h>
>+#include <linux/nvme_ioctl.h>
>+#include "block/nvme.h"
>+
>+#ifdef CONFIG_LIBUDEV
>+#include <libudev.h>
>+#endif
>+
>+#include <sys/statvfs.h>
> 
> #if defined(CONFIG_FSFREEZE) || defined(CONFIG_FSTRIM)
> static int dev_major_minor(const char *devpath,
>@@ -286,6 +297,899 @@ int qmp_guest_fsfreeze_do_thaw(Error **errp)
> }
> #endif /* CONFIG_FSFREEZE */
> 
>+#if defined(CONFIG_FSFREEZE)
>+
>+static char *get_pci_driver(char const *syspath, int pathlen, Error **errp)
>+{
>+    char *path;
>+    char *dpath;
>+    char *driver = NULL;
>+    char buf[PATH_MAX];
>+    ssize_t len;
>+
>+    path = g_strndup(syspath, pathlen);
>+    dpath = g_strdup_printf("%s/driver", path);
>+    len = readlink(dpath, buf, sizeof(buf) - 1);
>+    if (len != -1) {
>+        buf[len] = 0;
>+        driver = g_path_get_basename(buf);
>+    }
>+    g_free(dpath);
>+    g_free(path);
>+    return driver;
>+}
>+
>+static int compare_uint(const void *_a, const void *_b)
>+{
>+    unsigned int a = *(unsigned int *)_a;
>+    unsigned int b = *(unsigned int *)_b;
>+
>+    return a < b ? -1 : a > b ? 1 : 0;
>+}
>+
>+/* Walk the specified sysfs and build a sorted list of host or ata numbers */
>+static int build_hosts(char const *syspath, char const *host, bool ata,
>+                       unsigned int *hosts, int hosts_max, Error **errp)
>+{
>+    char *path;
>+    DIR *dir;
>+    struct dirent *entry;
>+    int i = 0;
>+
>+    path = g_strndup(syspath, host - syspath);
>+    dir = opendir(path);
>+    if (!dir) {
>+        error_setg_errno(errp, errno, "opendir(\"%s\")", path);
>+        g_free(path);
>+        return -1;
>+    }
>+
>+    while (i < hosts_max) {
>+        entry = readdir(dir);
>+        if (!entry) {
>+            break;
>+        }
>+        if (ata && sscanf(entry->d_name, "ata%d", hosts + i) == 1) {
>+            ++i;
>+        } else if (!ata && sscanf(entry->d_name, "host%d", hosts + i) == 1) {
>+            ++i;
>+        }
>+    }
>+
>+    qsort(hosts, i, sizeof(hosts[0]), compare_uint);
>+
>+    g_free(path);
>+    closedir(dir);
>+    return i;
>+}
>+
>+/*
>+ * Store disk device info for devices on the PCI bus.
>+ * Returns true if information has been stored, or false for failure.
>+ */
>+static bool build_guest_fsinfo_for_pci_dev(char const *syspath,
>+                                           GuestDiskAddress *disk,
>+                                           Error **errp)
>+{
>+    unsigned int pci[4], host, hosts[8], tgt[3];
>+    int i, nhosts = 0, pcilen;
>+    GuestPCIAddress *pciaddr = disk->pci_controller;
>+    bool has_ata = false, has_host = false, has_tgt = false;
>+    char *p, *q, *driver = NULL;
>+    bool ret = false;
>+
>+    p = strstr(syspath, "/devices/pci");
>+    if (!p || sscanf(p + 12, "%*x:%*x/%x:%x:%x.%x%n",
>+                     pci, pci + 1, pci + 2, pci + 3, &pcilen) < 4) {
>+        g_debug("only pci device is supported: sysfs path '%s'", syspath);
>+        return false;
>+    }
>+
>+    p += 12 + pcilen;
>+    while (true) {
>+        driver = get_pci_driver(syspath, p - syspath, errp);
>+        if (driver && (g_str_equal(driver, "ata_piix") ||
>+                       g_str_equal(driver, "sym53c8xx") ||
>+                       g_str_equal(driver, "virtio-pci") ||
>+                       g_str_equal(driver, "ahci") ||
>+                       g_str_equal(driver, "nvme") ||
>+                       g_str_equal(driver, "xhci_hcd") ||
>+                       g_str_equal(driver, "ehci-pci"))) {
>+            break;
>+        }
>+
>+        g_free(driver);
>+        if (sscanf(p, "/%x:%x:%x.%x%n",
>+                          pci, pci + 1, pci + 2, pci + 3, &pcilen) == 4) {
>+            p += pcilen;
>+            continue;
>+        }
>+
>+        g_debug("unsupported driver or sysfs path '%s'", syspath);
>+        return false;
>+    }
>+
>+    p = strstr(syspath, "/target");
>+    if (p && sscanf(p + 7, "%*u:%*u:%*u/%*u:%u:%u:%u",
>+                    tgt, tgt + 1, tgt + 2) == 3) {
>+        has_tgt = true;
>+    }
>+
>+    p = strstr(syspath, "/ata");
>+    if (p) {
>+        q = p + 4;
>+        has_ata = true;
>+    } else {
>+        p = strstr(syspath, "/host");
>+        q = p + 5;
>+    }
>+    if (p && sscanf(q, "%u", &host) == 1) {
>+        has_host = true;
>+        nhosts = build_hosts(syspath, p, has_ata, hosts,
>+                             ARRAY_SIZE(hosts), errp);
>+        if (nhosts < 0) {
>+            goto cleanup;
>+        }
>+    }
>+
>+    pciaddr->domain = pci[0];
>+    pciaddr->bus = pci[1];
>+    pciaddr->slot = pci[2];
>+    pciaddr->function = pci[3];
>+
>+    if (strcmp(driver, "ata_piix") == 0) {
>+        /* a host per ide bus, target*:0:<unit>:0 */
>+        if (!has_host || !has_tgt) {
>+            g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver);
>+            goto cleanup;
>+        }
>+        for (i = 0; i < nhosts; i++) {
>+            if (host == hosts[i]) {
>+                disk->bus_type = GUEST_DISK_BUS_TYPE_IDE;
>+                disk->bus = i;
>+                disk->unit = tgt[1];
>+                break;
>+            }
>+        }
>+        if (i >= nhosts) {
>+            g_debug("no host for '%s' (driver '%s')", syspath, driver);
>+            goto cleanup;
>+        }
>+    } else if (strcmp(driver, "sym53c8xx") == 0) {
>+        /* scsi(LSI Logic): target*:0:<unit>:0 */
>+        if (!has_tgt) {
>+            g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver);
>+            goto cleanup;
>+        }
>+        disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI;
>+        disk->unit = tgt[1];
>+    } else if (strcmp(driver, "virtio-pci") == 0) {
>+        if (has_tgt) {
>+            /* virtio-scsi: target*:0:0:<unit> */
>+            disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI;
>+            disk->unit = tgt[2];
>+        } else {
>+            /* virtio-blk: 1 disk per 1 device */
>+            disk->bus_type = GUEST_DISK_BUS_TYPE_VIRTIO;
>+        }
>+    } else if (strcmp(driver, "ahci") == 0) {
>+        /* ahci: 1 host per 1 unit */
>+        if (!has_host || !has_tgt) {
>+            g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver);
>+            goto cleanup;
>+        }
>+        for (i = 0; i < nhosts; i++) {
>+            if (host == hosts[i]) {
>+                disk->unit = i;
>+                disk->bus_type = GUEST_DISK_BUS_TYPE_SATA;
>+                break;
>+            }
>+        }
>+        if (i >= nhosts) {
>+            g_debug("no host for '%s' (driver '%s')", syspath, driver);
>+            goto cleanup;
>+        }
>+    } else if (strcmp(driver, "nvme") == 0) {
>+        disk->bus_type = GUEST_DISK_BUS_TYPE_NVME;
>+    } else if (strcmp(driver, "ehci-pci") == 0 || strcmp(driver, "xhci_hcd") == 0) {
>+        disk->bus_type = GUEST_DISK_BUS_TYPE_USB;
>+    } else {
>+        g_debug("unknown driver '%s' (sysfs path '%s')", driver, syspath);
>+        goto cleanup;
>+    }
>+
>+    ret = true;
>+
>+cleanup:
>+    g_free(driver);
>+    return ret;
>+}
>+
>+/*
>+ * Store disk device info for non-PCI virtio devices (for example s390x
>+ * channel I/O devices). Returns true if information has been stored, or
>+ * false for failure.
>+ */
>+static bool build_guest_fsinfo_for_nonpci_virtio(char const *syspath,
>+                                                 GuestDiskAddress *disk,
>+                                                 Error **errp)
>+{
>+    unsigned int tgt[3];
>+    char *p;
>+
>+    if (!strstr(syspath, "/virtio") || !strstr(syspath, "/block")) {
>+        g_debug("Unsupported virtio device '%s'", syspath);
>+        return false;
>+    }
>+
>+    p = strstr(syspath, "/target");
>+    if (p && sscanf(p + 7, "%*u:%*u:%*u/%*u:%u:%u:%u",
>+                    &tgt[0], &tgt[1], &tgt[2]) == 3) {
>+        /* virtio-scsi: target*:0:<target>:<unit> */
>+        disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI;
>+        disk->bus = tgt[0];
>+        disk->target = tgt[1];
>+        disk->unit = tgt[2];
>+    } else {
>+        /* virtio-blk: 1 disk per 1 device */
>+        disk->bus_type = GUEST_DISK_BUS_TYPE_VIRTIO;
>+    }
>+
>+    return true;
>+}
>+
>+/*
>+ * Store disk device info for CCW devices (s390x channel I/O devices).
>+ * Returns true if information has been stored, or false for failure.
>+ */
>+static bool build_guest_fsinfo_for_ccw_dev(char const *syspath,
>+                                           GuestDiskAddress *disk,
>+                                           Error **errp)
>+{
>+    unsigned int cssid, ssid, subchno, devno;
>+    char *p;
>+
>+    p = strstr(syspath, "/devices/css");
>+    if (!p || sscanf(p + 12, "%*x/%x.%x.%x/%*x.%*x.%x/",
>+                     &cssid, &ssid, &subchno, &devno) < 4) {
>+        g_debug("could not parse ccw device sysfs path: %s", syspath);
>+        return false;
>+    }
>+
>+    disk->ccw_address = g_new0(GuestCCWAddress, 1);
>+    disk->ccw_address->cssid = cssid;
>+    disk->ccw_address->ssid = ssid;
>+    disk->ccw_address->subchno = subchno;
>+    disk->ccw_address->devno = devno;
>+
>+    if (strstr(p, "/virtio")) {
>+        build_guest_fsinfo_for_nonpci_virtio(syspath, disk, errp);
>+    }
>+
>+    return true;
>+}
>+
>+/* Store disk device info specified by @sysfs into @fs */
>+static void build_guest_fsinfo_for_real_device(char const *syspath,
>+                                               GuestFilesystemInfo *fs,
>+                                               Error **errp)
>+{
>+    GuestDiskAddress *disk;
>+    GuestPCIAddress *pciaddr;
>+    bool has_hwinf;
>+#ifdef CONFIG_LIBUDEV
>+    struct udev *udev = NULL;
>+    struct udev_device *udevice = NULL;
>+#endif
>+
>+    pciaddr = g_new0(GuestPCIAddress, 1);
>+    pciaddr->domain = -1;                       /* -1 means field is invalid */
>+    pciaddr->bus = -1;
>+    pciaddr->slot = -1;
>+    pciaddr->function = -1;
>+
>+    disk = g_new0(GuestDiskAddress, 1);
>+    disk->pci_controller = pciaddr;
>+    disk->bus_type = GUEST_DISK_BUS_TYPE_UNKNOWN;
>+
>+#ifdef CONFIG_LIBUDEV
>+    udev = udev_new();
>+    udevice = udev_device_new_from_syspath(udev, syspath);
>+    if (udev == NULL || udevice == NULL) {
>+        g_debug("failed to query udev");
>+    } else {
>+        const char *devnode, *serial;
>+        devnode = udev_device_get_devnode(udevice);
>+        if (devnode != NULL) {
>+            disk->dev = g_strdup(devnode);
>+        }
>+        serial = udev_device_get_property_value(udevice, "ID_SERIAL");
>+        if (serial != NULL && *serial != 0) {
>+            disk->serial = g_strdup(serial);
>+        }
>+    }
>+
>+    udev_unref(udev);
>+    udev_device_unref(udevice);
>+#endif
>+
>+    if (strstr(syspath, "/devices/pci")) {
>+        has_hwinf = build_guest_fsinfo_for_pci_dev(syspath, disk, errp);
>+    } else if (strstr(syspath, "/devices/css")) {
>+        has_hwinf = build_guest_fsinfo_for_ccw_dev(syspath, disk, errp);
>+    } else if (strstr(syspath, "/virtio")) {
>+        has_hwinf = build_guest_fsinfo_for_nonpci_virtio(syspath, disk, errp);
>+    } else {
>+        g_debug("Unsupported device type for '%s'", syspath);
>+        has_hwinf = false;
>+    }
>+
>+    if (has_hwinf || disk->dev || disk->serial) {
>+        QAPI_LIST_PREPEND(fs->disk, disk);
>+    } else {
>+        qapi_free_GuestDiskAddress(disk);
>+    }
>+}
>+
>+static void build_guest_fsinfo_for_device(char const *devpath,
>+                                          GuestFilesystemInfo *fs,
>+                                          Error **errp);
>+
>+/* Store a list of slave devices of virtual volume specified by @syspath into
>+ * @fs */
>+static void build_guest_fsinfo_for_virtual_device(char const *syspath,
>+                                                  GuestFilesystemInfo *fs,
>+                                                  Error **errp)
>+{
>+    Error *err = NULL;
>+    DIR *dir;
>+    char *dirpath;
>+    struct dirent *entry;
>+
>+    dirpath = g_strdup_printf("%s/slaves", syspath);
>+    dir = opendir(dirpath);
>+    if (!dir) {
>+        if (errno != ENOENT) {
>+            error_setg_errno(errp, errno, "opendir(\"%s\")", dirpath);
>+        }
>+        g_free(dirpath);
>+        return;
>+    }
>+
>+    for (;;) {
>+        errno = 0;
>+        entry = readdir(dir);
>+        if (entry == NULL) {
>+            if (errno) {
>+                error_setg_errno(errp, errno, "readdir(\"%s\")", dirpath);
>+            }
>+            break;
>+        }
>+
>+        if (entry->d_type == DT_LNK) {
>+            char *path;
>+
>+            g_debug(" slave device '%s'", entry->d_name);
>+            path = g_strdup_printf("%s/slaves/%s", syspath, entry->d_name);
>+            build_guest_fsinfo_for_device(path, fs, &err);
>+            g_free(path);
>+
>+            if (err) {
>+                error_propagate(errp, err);
>+                break;
>+            }
>+        }
>+    }
>+
>+    g_free(dirpath);
>+    closedir(dir);
>+}
>+
>+static bool is_disk_virtual(const char *devpath, Error **errp)
>+{
>+    g_autofree char *syspath = realpath(devpath, NULL);
>+
>+    if (!syspath) {
>+        error_setg_errno(errp, errno, "realpath(\"%s\")", devpath);
>+        return false;
>+    }
>+    return strstr(syspath, "/devices/virtual/block/") != NULL;
>+}
>+
>+/* Dispatch to functions for virtual/real device */
>+static void build_guest_fsinfo_for_device(char const *devpath,
>+                                          GuestFilesystemInfo *fs,
>+                                          Error **errp)
>+{
>+    ERRP_GUARD();
>+    g_autofree char *syspath = NULL;
>+    bool is_virtual = false;
>+
>+    syspath = realpath(devpath, NULL);
>+    if (!syspath) {
>+        if (errno != ENOENT) {
>+            error_setg_errno(errp, errno, "realpath(\"%s\")", devpath);
>+            return;
>+        }
>+
>+        /* ENOENT: This devpath may not exist because of container config */
>+        if (!fs->name) {
>+            fs->name = g_path_get_basename(devpath);
>+        }
>+        return;
>+    }
>+
>+    if (!fs->name) {
>+        fs->name = g_path_get_basename(syspath);
>+    }
>+
>+    g_debug("  parse sysfs path '%s'", syspath);
>+    is_virtual = is_disk_virtual(syspath, errp);
>+    if (*errp != NULL) {
>+        return;
>+    }
>+    if (is_virtual) {
>+        build_guest_fsinfo_for_virtual_device(syspath, fs, errp);
>+    } else {
>+        build_guest_fsinfo_for_real_device(syspath, fs, errp);
>+    }
>+}
>+
>+#ifdef CONFIG_LIBUDEV
>+
>+/*
>+ * Wrapper around build_guest_fsinfo_for_device() for getting just
>+ * the disk address.
>+ */
>+static GuestDiskAddress *get_disk_address(const char *syspath, Error **errp)
>+{
>+    g_autoptr(GuestFilesystemInfo) fs = NULL;
>+
>+    fs = g_new0(GuestFilesystemInfo, 1);
>+    build_guest_fsinfo_for_device(syspath, fs, errp);
>+    if (fs->disk != NULL) {
>+        return g_steal_pointer(&fs->disk->value);
>+    }
>+    return NULL;
>+}
>+
>+static char *get_alias_for_syspath(const char *syspath)
>+{
>+    struct udev *udev = NULL;
>+    struct udev_device *udevice = NULL;
>+    char *ret = NULL;
>+
>+    udev = udev_new();
>+    if (udev == NULL) {
>+        g_debug("failed to query udev");
>+        goto out;
>+    }
>+    udevice = udev_device_new_from_syspath(udev, syspath);
>+    if (udevice == NULL) {
>+        g_debug("failed to query udev for path: %s", syspath);
>+        goto out;
>+    } else {
>+        const char *alias = udev_device_get_property_value(
>+            udevice, "DM_NAME");
>+        /*
>+         * NULL means there was an error and empty string means there is no
>+         * alias. In case of no alias we return NULL instead of empty string.
>+         */
>+        if (alias == NULL) {
>+            g_debug("failed to query udev for device alias for: %s",
>+                syspath);
>+        } else if (*alias != 0) {
>+            ret = g_strdup(alias);
>+        }
>+    }
>+
>+out:
>+    udev_unref(udev);
>+    udev_device_unref(udevice);
>+    return ret;
>+}
>+
>+static char *get_device_for_syspath(const char *syspath)
>+{
>+    struct udev *udev = NULL;
>+    struct udev_device *udevice = NULL;
>+    char *ret = NULL;
>+
>+    udev = udev_new();
>+    if (udev == NULL) {
>+        g_debug("failed to query udev");
>+        goto out;
>+    }
>+    udevice = udev_device_new_from_syspath(udev, syspath);
>+    if (udevice == NULL) {
>+        g_debug("failed to query udev for path: %s", syspath);
>+        goto out;
>+    } else {
>+        ret = g_strdup(udev_device_get_devnode(udevice));
>+    }
>+
>+out:
>+    udev_unref(udev);
>+    udev_device_unref(udevice);
>+    return ret;
>+}
>+
>+static void get_disk_deps(const char *disk_dir, GuestDiskInfo *disk)
>+{
>+    g_autofree char *deps_dir = NULL;
>+    const gchar *dep;
>+    GDir *dp_deps = NULL;
>+
>+    /* List dependent disks */
>+    deps_dir = g_strdup_printf("%s/slaves", disk_dir);
>+    g_debug("  listing entries in: %s", deps_dir);
>+    dp_deps = g_dir_open(deps_dir, 0, NULL);
>+    if (dp_deps == NULL) {
>+        g_debug("failed to list entries in %s", deps_dir);
>+        return;
>+    }
>+    disk->has_dependencies = true;
>+    while ((dep = g_dir_read_name(dp_deps)) != NULL) {
>+        g_autofree char *dep_dir = NULL;
>+        char *dev_name;
>+
>+        /* Add dependent disks */
>+        dep_dir = g_strdup_printf("%s/%s", deps_dir, dep);
>+        dev_name = get_device_for_syspath(dep_dir);
>+        if (dev_name != NULL) {
>+            g_debug("  adding dependent device: %s", dev_name);
>+            QAPI_LIST_PREPEND(disk->dependencies, dev_name);
>+        }
>+    }
>+    g_dir_close(dp_deps);
>+}
>+
>+/*
>+ * Detect partitions subdirectory, name is "<disk_name><number>" or
>+ * "<disk_name>p<number>"
>+ *
>+ * @disk_name -- last component of /sys path (e.g. sda)
>+ * @disk_dir -- sys path of the disk (e.g. /sys/block/sda)
>+ * @disk_dev -- device node of the disk (e.g. /dev/sda)
>+ */
>+static GuestDiskInfoList *get_disk_partitions(
>+    GuestDiskInfoList *list,
>+    const char *disk_name, const char *disk_dir,
>+    const char *disk_dev)
>+{
>+    GuestDiskInfoList *ret = list;
>+    struct dirent *de_disk;
>+    DIR *dp_disk = NULL;
>+    size_t len = strlen(disk_name);
>+
>+    dp_disk = opendir(disk_dir);
>+    while ((de_disk = readdir(dp_disk)) != NULL) {
>+        g_autofree char *partition_dir = NULL;
>+        char *dev_name;
>+        GuestDiskInfo *partition;
>+
>+        if (!(de_disk->d_type & DT_DIR)) {
>+            continue;
>+        }
>+
>+        if (!(strncmp(disk_name, de_disk->d_name, len) == 0 &&
>+            ((*(de_disk->d_name + len) == 'p' &&
>+            isdigit(*(de_disk->d_name + len + 1))) ||
>+                isdigit(*(de_disk->d_name + len))))) {
>+            continue;
>+        }
>+
>+        partition_dir = g_strdup_printf("%s/%s",
>+            disk_dir, de_disk->d_name);
>+        dev_name = get_device_for_syspath(partition_dir);
>+        if (dev_name == NULL) {
>+            g_debug("Failed to get device name for syspath: %s",
>+                disk_dir);
>+            continue;
>+        }
>+        partition = g_new0(GuestDiskInfo, 1);
>+        partition->name = dev_name;
>+        partition->partition = true;
>+        partition->has_dependencies = true;
>+        /* Add parent disk as dependent for easier tracking of hierarchy */
>+        QAPI_LIST_PREPEND(partition->dependencies, g_strdup(disk_dev));
>+
>+        QAPI_LIST_PREPEND(ret, partition);
>+    }
>+    closedir(dp_disk);
>+
>+    return ret;
>+}
>+
>+static void get_nvme_smart(GuestDiskInfo *disk)
>+{
>+    int fd;
>+    GuestNVMeSmart *smart;
>+    NvmeSmartLog log = {0};
>+    struct nvme_admin_cmd cmd = {
>+        .opcode = NVME_ADM_CMD_GET_LOG_PAGE,
>+        .nsid = NVME_NSID_BROADCAST,
>+        .addr = (uintptr_t)&log,
>+        .data_len = sizeof(log),
>+        .cdw10 = NVME_LOG_SMART_INFO | (1 << 15) /* RAE bit */
>+                 | (((sizeof(log) >> 2) - 1) << 16)
>+    };
>+
>+    fd = qga_open_cloexec(disk->name, O_RDONLY, 0);
>+    if (fd == -1) {
>+        g_debug("Failed to open device: %s: %s", disk->name, g_strerror(errno));
>+        return;
>+    }
>+
>+    if (ioctl(fd, NVME_IOCTL_ADMIN_CMD, &cmd)) {
>+        g_debug("Failed to get smart: %s: %s", disk->name, g_strerror(errno));
>+        close(fd);
>+        return;
>+    }
>+
>+    disk->smart = g_new0(GuestDiskSmart, 1);
>+    disk->smart->type = GUEST_DISK_BUS_TYPE_NVME;
>+
>+    smart = &disk->smart->u.nvme;
>+    smart->critical_warning = log.critical_warning;
>+    smart->temperature = lduw_le_p(&log.temperature); /* unaligned field */
>+    smart->available_spare = log.available_spare;
>+    smart->available_spare_threshold = log.available_spare_threshold;
>+    smart->percentage_used = log.percentage_used;
>+    smart->data_units_read_lo = le64_to_cpu(log.data_units_read[0]);
>+    smart->data_units_read_hi = le64_to_cpu(log.data_units_read[1]);
>+    smart->data_units_written_lo = le64_to_cpu(log.data_units_written[0]);
>+    smart->data_units_written_hi = le64_to_cpu(log.data_units_written[1]);
>+    smart->host_read_commands_lo = le64_to_cpu(log.host_read_commands[0]);
>+    smart->host_read_commands_hi = le64_to_cpu(log.host_read_commands[1]);
>+    smart->host_write_commands_lo = le64_to_cpu(log.host_write_commands[0]);
>+    smart->host_write_commands_hi = le64_to_cpu(log.host_write_commands[1]);
>+    smart->controller_busy_time_lo = le64_to_cpu(log.controller_busy_time[0]);
>+    smart->controller_busy_time_hi = le64_to_cpu(log.controller_busy_time[1]);
>+    smart->power_cycles_lo = le64_to_cpu(log.power_cycles[0]);
>+    smart->power_cycles_hi = le64_to_cpu(log.power_cycles[1]);
>+    smart->power_on_hours_lo = le64_to_cpu(log.power_on_hours[0]);
>+    smart->power_on_hours_hi = le64_to_cpu(log.power_on_hours[1]);
>+    smart->unsafe_shutdowns_lo = le64_to_cpu(log.unsafe_shutdowns[0]);
>+    smart->unsafe_shutdowns_hi = le64_to_cpu(log.unsafe_shutdowns[1]);
>+    smart->media_errors_lo = le64_to_cpu(log.media_errors[0]);
>+    smart->media_errors_hi = le64_to_cpu(log.media_errors[1]);
>+    smart->number_of_error_log_entries_lo =
>+        le64_to_cpu(log.number_of_error_log_entries[0]);
>+    smart->number_of_error_log_entries_hi =
>+        le64_to_cpu(log.number_of_error_log_entries[1]);
>+
>+    close(fd);
>+}
>+
>+static void get_disk_smart(GuestDiskInfo *disk)
>+{
>+    if (disk->address
>+        && (disk->address->bus_type == GUEST_DISK_BUS_TYPE_NVME)) {
>+        get_nvme_smart(disk);
>+    }
>+}
>+
>+GuestDiskInfoList *qmp_guest_get_disks(Error **errp)
>+{
>+    GuestDiskInfoList *ret = NULL;
>+    GuestDiskInfo *disk;
>+    DIR *dp = NULL;
>+    struct dirent *de = NULL;
>+
>+    g_debug("listing /sys/block directory");
>+    dp = opendir("/sys/block");
>+    if (dp == NULL) {
>+        error_setg_errno(errp, errno, "Can't open directory \"/sys/block\"");
>+        return NULL;
>+    }
>+    while ((de = readdir(dp)) != NULL) {
>+        g_autofree char *disk_dir = NULL, *line = NULL,
>+            *size_path = NULL;
>+        char *dev_name;
>+        Error *local_err = NULL;
>+        if (de->d_type != DT_LNK) {
>+            g_debug("  skipping entry: %s", de->d_name);
>+            continue;
>+        }
>+
>+        /* Check size and skip zero-sized disks */
>+        g_debug("  checking disk size");
>+        size_path = g_strdup_printf("/sys/block/%s/size", de->d_name);
>+        if (!g_file_get_contents(size_path, &line, NULL, NULL)) {
>+            g_debug("  failed to read disk size");
>+            continue;
>+        }
>+        if (g_strcmp0(line, "0\n") == 0) {
>+            g_debug("  skipping zero-sized disk");
>+            continue;
>+        }
>+
>+        g_debug("  adding %s", de->d_name);
>+        disk_dir = g_strdup_printf("/sys/block/%s", de->d_name);
>+        dev_name = get_device_for_syspath(disk_dir);
>+        if (dev_name == NULL) {
>+            g_debug("Failed to get device name for syspath: %s",
>+                disk_dir);
>+            continue;
>+        }
>+        disk = g_new0(GuestDiskInfo, 1);
>+        disk->name = dev_name;
>+        disk->partition = false;
>+        disk->alias = get_alias_for_syspath(disk_dir);
>+        QAPI_LIST_PREPEND(ret, disk);
>+
>+        /* Get address for non-virtual devices */
>+        bool is_virtual = is_disk_virtual(disk_dir, &local_err);
>+        if (local_err != NULL) {
>+            g_debug("  failed to check disk path, ignoring error: %s",
>+                error_get_pretty(local_err));
>+            error_free(local_err);
>+            local_err = NULL;
>+            /* Don't try to get the address */
>+            is_virtual = true;
>+        }
>+        if (!is_virtual) {
>+            disk->address = get_disk_address(disk_dir, &local_err);
>+            if (local_err != NULL) {
>+                g_debug("  failed to get device info, ignoring error: %s",
>+                    error_get_pretty(local_err));
>+                error_free(local_err);
>+                local_err = NULL;
>+            }
>+        }
>+
>+        get_disk_deps(disk_dir, disk);
>+        get_disk_smart(disk);
>+        ret = get_disk_partitions(ret, de->d_name, disk_dir, dev_name);
>+    }
>+
>+    closedir(dp);
>+
>+    return ret;
>+}
>+
>+#else
>+
>+GuestDiskInfoList *qmp_guest_get_disks(Error **errp)
>+{
>+    error_setg(errp, QERR_UNSUPPORTED);
>+    return NULL;
>+}
>+
>+#endif
>+
>+/* Return a list of the disk device(s)' info which @mount lies on */
>+static GuestFilesystemInfo *build_guest_fsinfo(struct FsMount *mount,
>+                                               Error **errp)
>+{
>+    GuestFilesystemInfo *fs = g_malloc0(sizeof(*fs));
>+    struct statvfs buf;
>+    unsigned long used, nonroot_total, fr_size;
>+    char *devpath = g_strdup_printf("/sys/dev/block/%u:%u",
>+                                    mount->devmajor, mount->devminor);
>+
>+    fs->mountpoint = g_strdup(mount->dirname);
>+    fs->type = g_strdup(mount->devtype);
>+    build_guest_fsinfo_for_device(devpath, fs, errp);
>+
>+    if (statvfs(fs->mountpoint, &buf) == 0) {
>+        fr_size = buf.f_frsize;
>+        used = buf.f_blocks - buf.f_bfree;
>+        nonroot_total = used + buf.f_bavail;
>+        fs->used_bytes = used * fr_size;
>+        fs->total_bytes = nonroot_total * fr_size;
>+        fs->total_bytes_privileged = buf.f_blocks * fr_size;
>+
>+        fs->has_total_bytes = true;
>+        fs->has_total_bytes_privileged = true;
>+        fs->has_used_bytes = true;
>+    }
>+
>+    g_free(devpath);
>+
>+    return fs;
>+}
>+
>+GuestFilesystemInfoList *qmp_guest_get_fsinfo(Error **errp)
>+{
>+    FsMountList mounts;
>+    struct FsMount *mount;
>+    GuestFilesystemInfoList *ret = NULL;
>+    Error *local_err = NULL;
>+
>+    QTAILQ_INIT(&mounts);
>+    if (!build_fs_mount_list(&mounts, &local_err)) {
>+        error_propagate(errp, local_err);
>+        return NULL;
>+    }
>+
>+    QTAILQ_FOREACH(mount, &mounts, next) {
>+        g_debug("Building guest fsinfo for '%s'", mount->dirname);
>+
>+        QAPI_LIST_PREPEND(ret, build_guest_fsinfo(mount, &local_err));
>+        if (local_err) {
>+            error_propagate(errp, local_err);
>+            qapi_free_GuestFilesystemInfoList(ret);
>+            ret = NULL;
>+            break;
>+        }
>+    }
>+
>+    free_fs_mount_list(&mounts);
>+    return ret;
>+}
>+#endif /* CONFIG_FSFREEZE */
>+
>+#if defined(CONFIG_FSTRIM)
>+/*
>+ * Walk list of mounted file systems in the guest, and trim them.
>+ */
>+GuestFilesystemTrimResponse *
>+qmp_guest_fstrim(bool has_minimum, int64_t minimum, Error **errp)
>+{
>+    GuestFilesystemTrimResponse *response;
>+    GuestFilesystemTrimResult *result;
>+    int ret = 0;
>+    FsMountList mounts;
>+    struct FsMount *mount;
>+    int fd;
>+    struct fstrim_range r;
>+
>+    slog("guest-fstrim called");
>+
>+    QTAILQ_INIT(&mounts);
>+    if (!build_fs_mount_list(&mounts, errp)) {
>+        return NULL;
>+    }
>+
>+    response = g_malloc0(sizeof(*response));
>+
>+    QTAILQ_FOREACH(mount, &mounts, next) {
>+        result = g_malloc0(sizeof(*result));
>+        result->path = g_strdup(mount->dirname);
>+
>+        QAPI_LIST_PREPEND(response->paths, result);
>+
>+        fd = qga_open_cloexec(mount->dirname, O_RDONLY, 0);
>+        if (fd == -1) {
>+            result->error = g_strdup_printf("failed to open: %s",
>+                                            strerror(errno));
>+            continue;
>+        }
>+
>+        /* We try to cull filesystems we know won't work in advance, but other
>+         * filesystems may not implement fstrim for less obvious reasons.
>+         * These will report EOPNOTSUPP; while in some other cases ENOTTY
>+         * will be reported (e.g. CD-ROMs).
>+         * Any other error means an unexpected error.
>+         */
>+        r.start = 0;
>+        r.len = -1;
>+        r.minlen = has_minimum ? minimum : 0;
>+        ret = ioctl(fd, FITRIM, &r);
>+        if (ret == -1) {
>+            if (errno == ENOTTY || errno == EOPNOTSUPP) {
>+                result->error = g_strdup("trim not supported");
>+            } else {
>+                result->error = g_strdup_printf("failed to trim: %s",
>+                                                strerror(errno));
>+            }
>+            close(fd);
>+            continue;
>+        }
>+
>+        result->has_minimum = true;
>+        result->minimum = r.minlen;
>+        result->has_trimmed = true;
>+        result->trimmed = r.len;
>+        close(fd);
>+    }
>+
>+    free_fs_mount_list(&mounts);
>+    return response;
>+}
>+#endif /* CONFIG_FSTRIM */
> 
> #define LINUX_SYS_STATE_FILE "/sys/power/state"
> #define SUSPEND_SUPPORTED 0
>diff --git a/qga/commands-posix.c b/qga/commands-posix.c
>index ef21da63be..98aafc45f3 100644
>--- a/qga/commands-posix.c
>+++ b/qga/commands-posix.c
>@@ -24,23 +24,12 @@
> #include "qemu/base64.h"
> #include "qemu/cutils.h"
> #include "commands-common.h"
>-#include "block/nvme.h"
> #include "cutils.h"
> 
> #ifdef HAVE_UTMPX
> #include <utmpx.h>
> #endif
> 
>-#if defined(__linux__)
>-#include <mntent.h>
>-#include <sys/statvfs.h>
>-#include <linux/nvme_ioctl.h>
>-
>-#ifdef CONFIG_LIBUDEV
>-#include <libudev.h>
>-#endif
>-#endif
>-
> #ifdef HAVE_GETIFADDRS
> #include <arpa/inet.h>
> #include <sys/socket.h>
>@@ -842,904 +831,6 @@ static void guest_fsfreeze_cleanup(void)
> }
> #endif
> 
>-/* linux-specific implementations. avoid this if at all possible. */
>-#if defined(__linux__)
>-#if defined(CONFIG_FSFREEZE)
>-
>-static char *get_pci_driver(char const *syspath, int pathlen, Error **errp)
>-{
>-    char *path;
>-    char *dpath;
>-    char *driver = NULL;
>-    char buf[PATH_MAX];
>-    ssize_t len;
>-
>-    path = g_strndup(syspath, pathlen);
>-    dpath = g_strdup_printf("%s/driver", path);
>-    len = readlink(dpath, buf, sizeof(buf) - 1);
>-    if (len != -1) {
>-        buf[len] = 0;
>-        driver = g_path_get_basename(buf);
>-    }
>-    g_free(dpath);
>-    g_free(path);
>-    return driver;
>-}
>-
>-static int compare_uint(const void *_a, const void *_b)
>-{
>-    unsigned int a = *(unsigned int *)_a;
>-    unsigned int b = *(unsigned int *)_b;
>-
>-    return a < b ? -1 : a > b ? 1 : 0;
>-}
>-
>-/* Walk the specified sysfs and build a sorted list of host or ata numbers */
>-static int build_hosts(char const *syspath, char const *host, bool ata,
>-                       unsigned int *hosts, int hosts_max, Error **errp)
>-{
>-    char *path;
>-    DIR *dir;
>-    struct dirent *entry;
>-    int i = 0;
>-
>-    path = g_strndup(syspath, host - syspath);
>-    dir = opendir(path);
>-    if (!dir) {
>-        error_setg_errno(errp, errno, "opendir(\"%s\")", path);
>-        g_free(path);
>-        return -1;
>-    }
>-
>-    while (i < hosts_max) {
>-        entry = readdir(dir);
>-        if (!entry) {
>-            break;
>-        }
>-        if (ata && sscanf(entry->d_name, "ata%d", hosts + i) == 1) {
>-            ++i;
>-        } else if (!ata && sscanf(entry->d_name, "host%d", hosts + i) == 1) {
>-            ++i;
>-        }
>-    }
>-
>-    qsort(hosts, i, sizeof(hosts[0]), compare_uint);
>-
>-    g_free(path);
>-    closedir(dir);
>-    return i;
>-}
>-
>-/*
>- * Store disk device info for devices on the PCI bus.
>- * Returns true if information has been stored, or false for failure.
>- */
>-static bool build_guest_fsinfo_for_pci_dev(char const *syspath,
>-                                           GuestDiskAddress *disk,
>-                                           Error **errp)
>-{
>-    unsigned int pci[4], host, hosts[8], tgt[3];
>-    int i, nhosts = 0, pcilen;
>-    GuestPCIAddress *pciaddr = disk->pci_controller;
>-    bool has_ata = false, has_host = false, has_tgt = false;
>-    char *p, *q, *driver = NULL;
>-    bool ret = false;
>-
>-    p = strstr(syspath, "/devices/pci");
>-    if (!p || sscanf(p + 12, "%*x:%*x/%x:%x:%x.%x%n",
>-                     pci, pci + 1, pci + 2, pci + 3, &pcilen) < 4) {
>-        g_debug("only pci device is supported: sysfs path '%s'", syspath);
>-        return false;
>-    }
>-
>-    p += 12 + pcilen;
>-    while (true) {
>-        driver = get_pci_driver(syspath, p - syspath, errp);
>-        if (driver && (g_str_equal(driver, "ata_piix") ||
>-                       g_str_equal(driver, "sym53c8xx") ||
>-                       g_str_equal(driver, "virtio-pci") ||
>-                       g_str_equal(driver, "ahci") ||
>-                       g_str_equal(driver, "nvme") ||
>-                       g_str_equal(driver, "xhci_hcd") ||
>-                       g_str_equal(driver, "ehci-pci"))) {
>-            break;
>-        }
>-
>-        g_free(driver);
>-        if (sscanf(p, "/%x:%x:%x.%x%n",
>-                          pci, pci + 1, pci + 2, pci + 3, &pcilen) == 4) {
>-            p += pcilen;
>-            continue;
>-        }
>-
>-        g_debug("unsupported driver or sysfs path '%s'", syspath);
>-        return false;
>-    }
>-
>-    p = strstr(syspath, "/target");
>-    if (p && sscanf(p + 7, "%*u:%*u:%*u/%*u:%u:%u:%u",
>-                    tgt, tgt + 1, tgt + 2) == 3) {
>-        has_tgt = true;
>-    }
>-
>-    p = strstr(syspath, "/ata");
>-    if (p) {
>-        q = p + 4;
>-        has_ata = true;
>-    } else {
>-        p = strstr(syspath, "/host");
>-        q = p + 5;
>-    }
>-    if (p && sscanf(q, "%u", &host) == 1) {
>-        has_host = true;
>-        nhosts = build_hosts(syspath, p, has_ata, hosts,
>-                             ARRAY_SIZE(hosts), errp);
>-        if (nhosts < 0) {
>-            goto cleanup;
>-        }
>-    }
>-
>-    pciaddr->domain = pci[0];
>-    pciaddr->bus = pci[1];
>-    pciaddr->slot = pci[2];
>-    pciaddr->function = pci[3];
>-
>-    if (strcmp(driver, "ata_piix") == 0) {
>-        /* a host per ide bus, target*:0:<unit>:0 */
>-        if (!has_host || !has_tgt) {
>-            g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver);
>-            goto cleanup;
>-        }
>-        for (i = 0; i < nhosts; i++) {
>-            if (host == hosts[i]) {
>-                disk->bus_type = GUEST_DISK_BUS_TYPE_IDE;
>-                disk->bus = i;
>-                disk->unit = tgt[1];
>-                break;
>-            }
>-        }
>-        if (i >= nhosts) {
>-            g_debug("no host for '%s' (driver '%s')", syspath, driver);
>-            goto cleanup;
>-        }
>-    } else if (strcmp(driver, "sym53c8xx") == 0) {
>-        /* scsi(LSI Logic): target*:0:<unit>:0 */
>-        if (!has_tgt) {
>-            g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver);
>-            goto cleanup;
>-        }
>-        disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI;
>-        disk->unit = tgt[1];
>-    } else if (strcmp(driver, "virtio-pci") == 0) {
>-        if (has_tgt) {
>-            /* virtio-scsi: target*:0:0:<unit> */
>-            disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI;
>-            disk->unit = tgt[2];
>-        } else {
>-            /* virtio-blk: 1 disk per 1 device */
>-            disk->bus_type = GUEST_DISK_BUS_TYPE_VIRTIO;
>-        }
>-    } else if (strcmp(driver, "ahci") == 0) {
>-        /* ahci: 1 host per 1 unit */
>-        if (!has_host || !has_tgt) {
>-            g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver);
>-            goto cleanup;
>-        }
>-        for (i = 0; i < nhosts; i++) {
>-            if (host == hosts[i]) {
>-                disk->unit = i;
>-                disk->bus_type = GUEST_DISK_BUS_TYPE_SATA;
>-                break;
>-            }
>-        }
>-        if (i >= nhosts) {
>-            g_debug("no host for '%s' (driver '%s')", syspath, driver);
>-            goto cleanup;
>-        }
>-    } else if (strcmp(driver, "nvme") == 0) {
>-        disk->bus_type = GUEST_DISK_BUS_TYPE_NVME;
>-    } else if (strcmp(driver, "ehci-pci") == 0 || strcmp(driver, "xhci_hcd") == 0) {
>-        disk->bus_type = GUEST_DISK_BUS_TYPE_USB;
>-    } else {
>-        g_debug("unknown driver '%s' (sysfs path '%s')", driver, syspath);
>-        goto cleanup;
>-    }
>-
>-    ret = true;
>-
>-cleanup:
>-    g_free(driver);
>-    return ret;
>-}
>-
>-/*
>- * Store disk device info for non-PCI virtio devices (for example s390x
>- * channel I/O devices). Returns true if information has been stored, or
>- * false for failure.
>- */
>-static bool build_guest_fsinfo_for_nonpci_virtio(char const *syspath,
>-                                                 GuestDiskAddress *disk,
>-                                                 Error **errp)
>-{
>-    unsigned int tgt[3];
>-    char *p;
>-
>-    if (!strstr(syspath, "/virtio") || !strstr(syspath, "/block")) {
>-        g_debug("Unsupported virtio device '%s'", syspath);
>-        return false;
>-    }
>-
>-    p = strstr(syspath, "/target");
>-    if (p && sscanf(p + 7, "%*u:%*u:%*u/%*u:%u:%u:%u",
>-                    &tgt[0], &tgt[1], &tgt[2]) == 3) {
>-        /* virtio-scsi: target*:0:<target>:<unit> */
>-        disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI;
>-        disk->bus = tgt[0];
>-        disk->target = tgt[1];
>-        disk->unit = tgt[2];
>-    } else {
>-        /* virtio-blk: 1 disk per 1 device */
>-        disk->bus_type = GUEST_DISK_BUS_TYPE_VIRTIO;
>-    }
>-
>-    return true;
>-}
>-
>-/*
>- * Store disk device info for CCW devices (s390x channel I/O devices).
>- * Returns true if information has been stored, or false for failure.
>- */
>-static bool build_guest_fsinfo_for_ccw_dev(char const *syspath,
>-                                           GuestDiskAddress *disk,
>-                                           Error **errp)
>-{
>-    unsigned int cssid, ssid, subchno, devno;
>-    char *p;
>-
>-    p = strstr(syspath, "/devices/css");
>-    if (!p || sscanf(p + 12, "%*x/%x.%x.%x/%*x.%*x.%x/",
>-                     &cssid, &ssid, &subchno, &devno) < 4) {
>-        g_debug("could not parse ccw device sysfs path: %s", syspath);
>-        return false;
>-    }
>-
>-    disk->ccw_address = g_new0(GuestCCWAddress, 1);
>-    disk->ccw_address->cssid = cssid;
>-    disk->ccw_address->ssid = ssid;
>-    disk->ccw_address->subchno = subchno;
>-    disk->ccw_address->devno = devno;
>-
>-    if (strstr(p, "/virtio")) {
>-        build_guest_fsinfo_for_nonpci_virtio(syspath, disk, errp);
>-    }
>-
>-    return true;
>-}
>-
>-/* Store disk device info specified by @sysfs into @fs */
>-static void build_guest_fsinfo_for_real_device(char const *syspath,
>-                                               GuestFilesystemInfo *fs,
>-                                               Error **errp)
>-{
>-    GuestDiskAddress *disk;
>-    GuestPCIAddress *pciaddr;
>-    bool has_hwinf;
>-#ifdef CONFIG_LIBUDEV
>-    struct udev *udev = NULL;
>-    struct udev_device *udevice = NULL;
>-#endif
>-
>-    pciaddr = g_new0(GuestPCIAddress, 1);
>-    pciaddr->domain = -1;                       /* -1 means field is invalid */
>-    pciaddr->bus = -1;
>-    pciaddr->slot = -1;
>-    pciaddr->function = -1;
>-
>-    disk = g_new0(GuestDiskAddress, 1);
>-    disk->pci_controller = pciaddr;
>-    disk->bus_type = GUEST_DISK_BUS_TYPE_UNKNOWN;
>-
>-#ifdef CONFIG_LIBUDEV
>-    udev = udev_new();
>-    udevice = udev_device_new_from_syspath(udev, syspath);
>-    if (udev == NULL || udevice == NULL) {
>-        g_debug("failed to query udev");
>-    } else {
>-        const char *devnode, *serial;
>-        devnode = udev_device_get_devnode(udevice);
>-        if (devnode != NULL) {
>-            disk->dev = g_strdup(devnode);
>-        }
>-        serial = udev_device_get_property_value(udevice, "ID_SERIAL");
>-        if (serial != NULL && *serial != 0) {
>-            disk->serial = g_strdup(serial);
>-        }
>-    }
>-
>-    udev_unref(udev);
>-    udev_device_unref(udevice);
>-#endif
>-
>-    if (strstr(syspath, "/devices/pci")) {
>-        has_hwinf = build_guest_fsinfo_for_pci_dev(syspath, disk, errp);
>-    } else if (strstr(syspath, "/devices/css")) {
>-        has_hwinf = build_guest_fsinfo_for_ccw_dev(syspath, disk, errp);
>-    } else if (strstr(syspath, "/virtio")) {
>-        has_hwinf = build_guest_fsinfo_for_nonpci_virtio(syspath, disk, errp);
>-    } else {
>-        g_debug("Unsupported device type for '%s'", syspath);
>-        has_hwinf = false;
>-    }
>-
>-    if (has_hwinf || disk->dev || disk->serial) {
>-        QAPI_LIST_PREPEND(fs->disk, disk);
>-    } else {
>-        qapi_free_GuestDiskAddress(disk);
>-    }
>-}
>-
>-static void build_guest_fsinfo_for_device(char const *devpath,
>-                                          GuestFilesystemInfo *fs,
>-                                          Error **errp);
>-
>-/* Store a list of slave devices of virtual volume specified by @syspath into
>- * @fs */
>-static void build_guest_fsinfo_for_virtual_device(char const *syspath,
>-                                                  GuestFilesystemInfo *fs,
>-                                                  Error **errp)
>-{
>-    Error *err = NULL;
>-    DIR *dir;
>-    char *dirpath;
>-    struct dirent *entry;
>-
>-    dirpath = g_strdup_printf("%s/slaves", syspath);
>-    dir = opendir(dirpath);
>-    if (!dir) {
>-        if (errno != ENOENT) {
>-            error_setg_errno(errp, errno, "opendir(\"%s\")", dirpath);
>-        }
>-        g_free(dirpath);
>-        return;
>-    }
>-
>-    for (;;) {
>-        errno = 0;
>-        entry = readdir(dir);
>-        if (entry == NULL) {
>-            if (errno) {
>-                error_setg_errno(errp, errno, "readdir(\"%s\")", dirpath);
>-            }
>-            break;
>-        }
>-
>-        if (entry->d_type == DT_LNK) {
>-            char *path;
>-
>-            g_debug(" slave device '%s'", entry->d_name);
>-            path = g_strdup_printf("%s/slaves/%s", syspath, entry->d_name);
>-            build_guest_fsinfo_for_device(path, fs, &err);
>-            g_free(path);
>-
>-            if (err) {
>-                error_propagate(errp, err);
>-                break;
>-            }
>-        }
>-    }
>-
>-    g_free(dirpath);
>-    closedir(dir);
>-}
>-
>-static bool is_disk_virtual(const char *devpath, Error **errp)
>-{
>-    g_autofree char *syspath = realpath(devpath, NULL);
>-
>-    if (!syspath) {
>-        error_setg_errno(errp, errno, "realpath(\"%s\")", devpath);
>-        return false;
>-    }
>-    return strstr(syspath, "/devices/virtual/block/") != NULL;
>-}
>-
>-/* Dispatch to functions for virtual/real device */
>-static void build_guest_fsinfo_for_device(char const *devpath,
>-                                          GuestFilesystemInfo *fs,
>-                                          Error **errp)
>-{
>-    ERRP_GUARD();
>-    g_autofree char *syspath = NULL;
>-    bool is_virtual = false;
>-
>-    syspath = realpath(devpath, NULL);
>-    if (!syspath) {
>-        if (errno != ENOENT) {
>-            error_setg_errno(errp, errno, "realpath(\"%s\")", devpath);
>-            return;
>-        }
>-
>-        /* ENOENT: This devpath may not exist because of container config */
>-        if (!fs->name) {
>-            fs->name = g_path_get_basename(devpath);
>-        }
>-        return;
>-    }
>-
>-    if (!fs->name) {
>-        fs->name = g_path_get_basename(syspath);
>-    }
>-
>-    g_debug("  parse sysfs path '%s'", syspath);
>-    is_virtual = is_disk_virtual(syspath, errp);
>-    if (*errp != NULL) {
>-        return;
>-    }
>-    if (is_virtual) {
>-        build_guest_fsinfo_for_virtual_device(syspath, fs, errp);
>-    } else {
>-        build_guest_fsinfo_for_real_device(syspath, fs, errp);
>-    }
>-}
>-
>-#ifdef CONFIG_LIBUDEV
>-
>-/*
>- * Wrapper around build_guest_fsinfo_for_device() for getting just
>- * the disk address.
>- */
>-static GuestDiskAddress *get_disk_address(const char *syspath, Error **errp)
>-{
>-    g_autoptr(GuestFilesystemInfo) fs = NULL;
>-
>-    fs = g_new0(GuestFilesystemInfo, 1);
>-    build_guest_fsinfo_for_device(syspath, fs, errp);
>-    if (fs->disk != NULL) {
>-        return g_steal_pointer(&fs->disk->value);
>-    }
>-    return NULL;
>-}
>-
>-static char *get_alias_for_syspath(const char *syspath)
>-{
>-    struct udev *udev = NULL;
>-    struct udev_device *udevice = NULL;
>-    char *ret = NULL;
>-
>-    udev = udev_new();
>-    if (udev == NULL) {
>-        g_debug("failed to query udev");
>-        goto out;
>-    }
>-    udevice = udev_device_new_from_syspath(udev, syspath);
>-    if (udevice == NULL) {
>-        g_debug("failed to query udev for path: %s", syspath);
>-        goto out;
>-    } else {
>-        const char *alias = udev_device_get_property_value(
>-            udevice, "DM_NAME");
>-        /*
>-         * NULL means there was an error and empty string means there is no
>-         * alias. In case of no alias we return NULL instead of empty string.
>-         */
>-        if (alias == NULL) {
>-            g_debug("failed to query udev for device alias for: %s",
>-                syspath);
>-        } else if (*alias != 0) {
>-            ret = g_strdup(alias);
>-        }
>-    }
>-
>-out:
>-    udev_unref(udev);
>-    udev_device_unref(udevice);
>-    return ret;
>-}
>-
>-static char *get_device_for_syspath(const char *syspath)
>-{
>-    struct udev *udev = NULL;
>-    struct udev_device *udevice = NULL;
>-    char *ret = NULL;
>-
>-    udev = udev_new();
>-    if (udev == NULL) {
>-        g_debug("failed to query udev");
>-        goto out;
>-    }
>-    udevice = udev_device_new_from_syspath(udev, syspath);
>-    if (udevice == NULL) {
>-        g_debug("failed to query udev for path: %s", syspath);
>-        goto out;
>-    } else {
>-        ret = g_strdup(udev_device_get_devnode(udevice));
>-    }
>-
>-out:
>-    udev_unref(udev);
>-    udev_device_unref(udevice);
>-    return ret;
>-}
>-
>-static void get_disk_deps(const char *disk_dir, GuestDiskInfo *disk)
>-{
>-    g_autofree char *deps_dir = NULL;
>-    const gchar *dep;
>-    GDir *dp_deps = NULL;
>-
>-    /* List dependent disks */
>-    deps_dir = g_strdup_printf("%s/slaves", disk_dir);
>-    g_debug("  listing entries in: %s", deps_dir);
>-    dp_deps = g_dir_open(deps_dir, 0, NULL);
>-    if (dp_deps == NULL) {
>-        g_debug("failed to list entries in %s", deps_dir);
>-        return;
>-    }
>-    disk->has_dependencies = true;
>-    while ((dep = g_dir_read_name(dp_deps)) != NULL) {
>-        g_autofree char *dep_dir = NULL;
>-        char *dev_name;
>-
>-        /* Add dependent disks */
>-        dep_dir = g_strdup_printf("%s/%s", deps_dir, dep);
>-        dev_name = get_device_for_syspath(dep_dir);
>-        if (dev_name != NULL) {
>-            g_debug("  adding dependent device: %s", dev_name);
>-            QAPI_LIST_PREPEND(disk->dependencies, dev_name);
>-        }
>-    }
>-    g_dir_close(dp_deps);
>-}
>-
>-/*
>- * Detect partitions subdirectory, name is "<disk_name><number>" or
>- * "<disk_name>p<number>"
>- *
>- * @disk_name -- last component of /sys path (e.g. sda)
>- * @disk_dir -- sys path of the disk (e.g. /sys/block/sda)
>- * @disk_dev -- device node of the disk (e.g. /dev/sda)
>- */
>-static GuestDiskInfoList *get_disk_partitions(
>-    GuestDiskInfoList *list,
>-    const char *disk_name, const char *disk_dir,
>-    const char *disk_dev)
>-{
>-    GuestDiskInfoList *ret = list;
>-    struct dirent *de_disk;
>-    DIR *dp_disk = NULL;
>-    size_t len = strlen(disk_name);
>-
>-    dp_disk = opendir(disk_dir);
>-    while ((de_disk = readdir(dp_disk)) != NULL) {
>-        g_autofree char *partition_dir = NULL;
>-        char *dev_name;
>-        GuestDiskInfo *partition;
>-
>-        if (!(de_disk->d_type & DT_DIR)) {
>-            continue;
>-        }
>-
>-        if (!(strncmp(disk_name, de_disk->d_name, len) == 0 &&
>-            ((*(de_disk->d_name + len) == 'p' &&
>-            isdigit(*(de_disk->d_name + len + 1))) ||
>-                isdigit(*(de_disk->d_name + len))))) {
>-            continue;
>-        }
>-
>-        partition_dir = g_strdup_printf("%s/%s",
>-            disk_dir, de_disk->d_name);
>-        dev_name = get_device_for_syspath(partition_dir);
>-        if (dev_name == NULL) {
>-            g_debug("Failed to get device name for syspath: %s",
>-                disk_dir);
>-            continue;
>-        }
>-        partition = g_new0(GuestDiskInfo, 1);
>-        partition->name = dev_name;
>-        partition->partition = true;
>-        partition->has_dependencies = true;
>-        /* Add parent disk as dependent for easier tracking of hierarchy */
>-        QAPI_LIST_PREPEND(partition->dependencies, g_strdup(disk_dev));
>-
>-        QAPI_LIST_PREPEND(ret, partition);
>-    }
>-    closedir(dp_disk);
>-
>-    return ret;
>-}
>-
>-static void get_nvme_smart(GuestDiskInfo *disk)
>-{
>-    int fd;
>-    GuestNVMeSmart *smart;
>-    NvmeSmartLog log = {0};
>-    struct nvme_admin_cmd cmd = {
>-        .opcode = NVME_ADM_CMD_GET_LOG_PAGE,
>-        .nsid = NVME_NSID_BROADCAST,
>-        .addr = (uintptr_t)&log,
>-        .data_len = sizeof(log),
>-        .cdw10 = NVME_LOG_SMART_INFO | (1 << 15) /* RAE bit */
>-                 | (((sizeof(log) >> 2) - 1) << 16)
>-    };
>-
>-    fd = qga_open_cloexec(disk->name, O_RDONLY, 0);
>-    if (fd == -1) {
>-        g_debug("Failed to open device: %s: %s", disk->name, g_strerror(errno));
>-        return;
>-    }
>-
>-    if (ioctl(fd, NVME_IOCTL_ADMIN_CMD, &cmd)) {
>-        g_debug("Failed to get smart: %s: %s", disk->name, g_strerror(errno));
>-        close(fd);
>-        return;
>-    }
>-
>-    disk->smart = g_new0(GuestDiskSmart, 1);
>-    disk->smart->type = GUEST_DISK_BUS_TYPE_NVME;
>-
>-    smart = &disk->smart->u.nvme;
>-    smart->critical_warning = log.critical_warning;
>-    smart->temperature = lduw_le_p(&log.temperature); /* unaligned field */
>-    smart->available_spare = log.available_spare;
>-    smart->available_spare_threshold = log.available_spare_threshold;
>-    smart->percentage_used = log.percentage_used;
>-    smart->data_units_read_lo = le64_to_cpu(log.data_units_read[0]);
>-    smart->data_units_read_hi = le64_to_cpu(log.data_units_read[1]);
>-    smart->data_units_written_lo = le64_to_cpu(log.data_units_written[0]);
>-    smart->data_units_written_hi = le64_to_cpu(log.data_units_written[1]);
>-    smart->host_read_commands_lo = le64_to_cpu(log.host_read_commands[0]);
>-    smart->host_read_commands_hi = le64_to_cpu(log.host_read_commands[1]);
>-    smart->host_write_commands_lo = le64_to_cpu(log.host_write_commands[0]);
>-    smart->host_write_commands_hi = le64_to_cpu(log.host_write_commands[1]);
>-    smart->controller_busy_time_lo = le64_to_cpu(log.controller_busy_time[0]);
>-    smart->controller_busy_time_hi = le64_to_cpu(log.controller_busy_time[1]);
>-    smart->power_cycles_lo = le64_to_cpu(log.power_cycles[0]);
>-    smart->power_cycles_hi = le64_to_cpu(log.power_cycles[1]);
>-    smart->power_on_hours_lo = le64_to_cpu(log.power_on_hours[0]);
>-    smart->power_on_hours_hi = le64_to_cpu(log.power_on_hours[1]);
>-    smart->unsafe_shutdowns_lo = le64_to_cpu(log.unsafe_shutdowns[0]);
>-    smart->unsafe_shutdowns_hi = le64_to_cpu(log.unsafe_shutdowns[1]);
>-    smart->media_errors_lo = le64_to_cpu(log.media_errors[0]);
>-    smart->media_errors_hi = le64_to_cpu(log.media_errors[1]);
>-    smart->number_of_error_log_entries_lo =
>-        le64_to_cpu(log.number_of_error_log_entries[0]);
>-    smart->number_of_error_log_entries_hi =
>-        le64_to_cpu(log.number_of_error_log_entries[1]);
>-
>-    close(fd);
>-}
>-
>-static void get_disk_smart(GuestDiskInfo *disk)
>-{
>-    if (disk->address
>-        && (disk->address->bus_type == GUEST_DISK_BUS_TYPE_NVME)) {
>-        get_nvme_smart(disk);
>-    }
>-}
>-
>-GuestDiskInfoList *qmp_guest_get_disks(Error **errp)
>-{
>-    GuestDiskInfoList *ret = NULL;
>-    GuestDiskInfo *disk;
>-    DIR *dp = NULL;
>-    struct dirent *de = NULL;
>-
>-    g_debug("listing /sys/block directory");
>-    dp = opendir("/sys/block");
>-    if (dp == NULL) {
>-        error_setg_errno(errp, errno, "Can't open directory \"/sys/block\"");
>-        return NULL;
>-    }
>-    while ((de = readdir(dp)) != NULL) {
>-        g_autofree char *disk_dir = NULL, *line = NULL,
>-            *size_path = NULL;
>-        char *dev_name;
>-        Error *local_err = NULL;
>-        if (de->d_type != DT_LNK) {
>-            g_debug("  skipping entry: %s", de->d_name);
>-            continue;
>-        }
>-
>-        /* Check size and skip zero-sized disks */
>-        g_debug("  checking disk size");
>-        size_path = g_strdup_printf("/sys/block/%s/size", de->d_name);
>-        if (!g_file_get_contents(size_path, &line, NULL, NULL)) {
>-            g_debug("  failed to read disk size");
>-            continue;
>-        }
>-        if (g_strcmp0(line, "0\n") == 0) {
>-            g_debug("  skipping zero-sized disk");
>-            continue;
>-        }
>-
>-        g_debug("  adding %s", de->d_name);
>-        disk_dir = g_strdup_printf("/sys/block/%s", de->d_name);
>-        dev_name = get_device_for_syspath(disk_dir);
>-        if (dev_name == NULL) {
>-            g_debug("Failed to get device name for syspath: %s",
>-                disk_dir);
>-            continue;
>-        }
>-        disk = g_new0(GuestDiskInfo, 1);
>-        disk->name = dev_name;
>-        disk->partition = false;
>-        disk->alias = get_alias_for_syspath(disk_dir);
>-        QAPI_LIST_PREPEND(ret, disk);
>-
>-        /* Get address for non-virtual devices */
>-        bool is_virtual = is_disk_virtual(disk_dir, &local_err);
>-        if (local_err != NULL) {
>-            g_debug("  failed to check disk path, ignoring error: %s",
>-                error_get_pretty(local_err));
>-            error_free(local_err);
>-            local_err = NULL;
>-            /* Don't try to get the address */
>-            is_virtual = true;
>-        }
>-        if (!is_virtual) {
>-            disk->address = get_disk_address(disk_dir, &local_err);
>-            if (local_err != NULL) {
>-                g_debug("  failed to get device info, ignoring error: %s",
>-                    error_get_pretty(local_err));
>-                error_free(local_err);
>-                local_err = NULL;
>-            }
>-        }
>-
>-        get_disk_deps(disk_dir, disk);
>-        get_disk_smart(disk);
>-        ret = get_disk_partitions(ret, de->d_name, disk_dir, dev_name);
>-    }
>-
>-    closedir(dp);
>-
>-    return ret;
>-}
>-
>-#else
>-
>-GuestDiskInfoList *qmp_guest_get_disks(Error **errp)
>-{
>-    error_setg(errp, QERR_UNSUPPORTED);
>-    return NULL;
>-}
>-
>-#endif
>-
>-/* Return a list of the disk device(s)' info which @mount lies on */
>-static GuestFilesystemInfo *build_guest_fsinfo(struct FsMount *mount,
>-                                               Error **errp)
>-{
>-    GuestFilesystemInfo *fs = g_malloc0(sizeof(*fs));
>-    struct statvfs buf;
>-    unsigned long used, nonroot_total, fr_size;
>-    char *devpath = g_strdup_printf("/sys/dev/block/%u:%u",
>-                                    mount->devmajor, mount->devminor);
>-
>-    fs->mountpoint = g_strdup(mount->dirname);
>-    fs->type = g_strdup(mount->devtype);
>-    build_guest_fsinfo_for_device(devpath, fs, errp);
>-
>-    if (statvfs(fs->mountpoint, &buf) == 0) {
>-        fr_size = buf.f_frsize;
>-        used = buf.f_blocks - buf.f_bfree;
>-        nonroot_total = used + buf.f_bavail;
>-        fs->used_bytes = used * fr_size;
>-        fs->total_bytes = nonroot_total * fr_size;
>-        fs->total_bytes_privileged = buf.f_blocks * fr_size;
>-
>-        fs->has_total_bytes = true;
>-        fs->has_total_bytes_privileged = true;
>-        fs->has_used_bytes = true;
>-    }
>-
>-    g_free(devpath);
>-
>-    return fs;
>-}
>-
>-GuestFilesystemInfoList *qmp_guest_get_fsinfo(Error **errp)
>-{
>-    FsMountList mounts;
>-    struct FsMount *mount;
>-    GuestFilesystemInfoList *ret = NULL;
>-    Error *local_err = NULL;
>-
>-    QTAILQ_INIT(&mounts);
>-    if (!build_fs_mount_list(&mounts, &local_err)) {
>-        error_propagate(errp, local_err);
>-        return NULL;
>-    }
>-
>-    QTAILQ_FOREACH(mount, &mounts, next) {
>-        g_debug("Building guest fsinfo for '%s'", mount->dirname);
>-
>-        QAPI_LIST_PREPEND(ret, build_guest_fsinfo(mount, &local_err));
>-        if (local_err) {
>-            error_propagate(errp, local_err);
>-            qapi_free_GuestFilesystemInfoList(ret);
>-            ret = NULL;
>-            break;
>-        }
>-    }
>-
>-    free_fs_mount_list(&mounts);
>-    return ret;
>-}
>-#endif /* CONFIG_FSFREEZE */
>-
>-#if defined(CONFIG_FSTRIM)
>-/*
>- * Walk list of mounted file systems in the guest, and trim them.
>- */
>-GuestFilesystemTrimResponse *
>-qmp_guest_fstrim(bool has_minimum, int64_t minimum, Error **errp)
>-{
>-    GuestFilesystemTrimResponse *response;
>-    GuestFilesystemTrimResult *result;
>-    int ret = 0;
>-    FsMountList mounts;
>-    struct FsMount *mount;
>-    int fd;
>-    struct fstrim_range r;
>-
>-    slog("guest-fstrim called");
>-
>-    QTAILQ_INIT(&mounts);
>-    if (!build_fs_mount_list(&mounts, errp)) {
>-        return NULL;
>-    }
>-
>-    response = g_malloc0(sizeof(*response));
>-
>-    QTAILQ_FOREACH(mount, &mounts, next) {
>-        result = g_malloc0(sizeof(*result));
>-        result->path = g_strdup(mount->dirname);
>-
>-        QAPI_LIST_PREPEND(response->paths, result);
>-
>-        fd = qga_open_cloexec(mount->dirname, O_RDONLY, 0);
>-        if (fd == -1) {
>-            result->error = g_strdup_printf("failed to open: %s",
>-                                            strerror(errno));
>-            continue;
>-        }
>-
>-        /* We try to cull filesystems we know won't work in advance, but other
>-         * filesystems may not implement fstrim for less obvious reasons.
>-         * These will report EOPNOTSUPP; while in some other cases ENOTTY
>-         * will be reported (e.g. CD-ROMs).
>-         * Any other error means an unexpected error.
>-         */
>-        r.start = 0;
>-        r.len = -1;
>-        r.minlen = has_minimum ? minimum : 0;
>-        ret = ioctl(fd, FITRIM, &r);
>-        if (ret == -1) {
>-            if (errno == ENOTTY || errno == EOPNOTSUPP) {
>-                result->error = g_strdup("trim not supported");
>-            } else {
>-                result->error = g_strdup_printf("failed to trim: %s",
>-                                                strerror(errno));
>-            }
>-            close(fd);
>-            continue;
>-        }
>-
>-        result->has_minimum = true;
>-        result->minimum = r.minlen;
>-        result->has_trimmed = true;
>-        result->trimmed = r.len;
>-        close(fd);
>-    }
>-
>-    free_fs_mount_list(&mounts);
>-    return response;
>-}
>-#endif /* CONFIG_FSTRIM */
>-
>-#endif /* __linux__ */
>-
> #if defined(__linux__) || defined(__FreeBSD__)
> void qmp_guest_set_user_password(const char *username,
>                                  const char *password,
>-- 
>2.45.1
>
>