1c216e5adSMichael Roth /* 2c216e5adSMichael Roth * QEMU Guest Agent POSIX-specific command implementations 3c216e5adSMichael Roth * 4c216e5adSMichael Roth * Copyright IBM Corp. 2011 5c216e5adSMichael Roth * 6c216e5adSMichael Roth * Authors: 7c216e5adSMichael Roth * Michael Roth <mdroth@linux.vnet.ibm.com> 83424fc9fSMichal Privoznik * Michal Privoznik <mprivozn@redhat.com> 9c216e5adSMichael Roth * 10c216e5adSMichael Roth * This work is licensed under the terms of the GNU GPL, version 2 or later. 11c216e5adSMichael Roth * See the COPYING file in the top-level directory. 12c216e5adSMichael Roth */ 13c216e5adSMichael Roth 144459bf38SPeter Maydell #include "qemu/osdep.h" 15c216e5adSMichael Roth #include <sys/ioctl.h> 169848f797STomáš Golembiovský #include <sys/utsname.h> 172c02cbf6SLuiz Capitulino #include <sys/wait.h> 1846d4c572STomoki Sekiyama #include <dirent.h> 19dc03272dSMichael S. Tsirkin #include "guest-agent-core.h" 20eb815e24SMarkus Armbruster #include "qga-qapi-commands.h" 21e688df6bSMarkus Armbruster #include "qapi/error.h" 227b1b5d19SPaolo Bonzini #include "qapi/qmp/qerror.h" 231de7afc9SPaolo Bonzini #include "qemu/queue.h" 241de7afc9SPaolo Bonzini #include "qemu/host-utils.h" 2512505396SDenis V. Lunev #include "qemu/sockets.h" 26920639caSDaniel P. Berrange #include "qemu/base64.h" 27f348b6d1SVeronia Bahaa #include "qemu/cutils.h" 285d3586b8SPhilippe Mathieu-Daudé #include "commands-common.h" 2922668881Szhenwei pi #include "block/nvme.h" 301a89a17bSMarc-André Lureau #include "cutils.h" 31c216e5adSMichael Roth 32e674605fSTomáš Golembiovský #ifdef HAVE_UTMPX 33e674605fSTomáš Golembiovský #include <utmpx.h> 34e674605fSTomáš Golembiovský #endif 35e674605fSTomáš Golembiovský 36e72c3f2eSMichael Roth #if defined(__linux__) 37e72c3f2eSMichael Roth #include <mntent.h> 38e72c3f2eSMichael Roth #include <linux/fs.h> 3925b5ff1aSChen Hanxiao #include <sys/statvfs.h> 4022668881Szhenwei pi #include <linux/nvme_ioctl.h> 41e72c3f2eSMichael Roth 42b616105aSTomáš Golembiovský #ifdef CONFIG_LIBUDEV 43b616105aSTomáš Golembiovský #include <libudev.h> 44b616105aSTomáš Golembiovský #endif 45b616105aSTomáš Golembiovský 46eab5fd59SPaolo Bonzini #ifdef FIFREEZE 47e72c3f2eSMichael Roth #define CONFIG_FSFREEZE 48e72c3f2eSMichael Roth #endif 49eab5fd59SPaolo Bonzini #ifdef FITRIM 50eab5fd59SPaolo Bonzini #define CONFIG_FSTRIM 51eab5fd59SPaolo Bonzini #endif 52e72c3f2eSMichael Roth #endif 53e72c3f2eSMichael Roth 5459e35c7bSAndrew Deason #ifdef HAVE_GETIFADDRS 5559e35c7bSAndrew Deason #include <arpa/inet.h> 5659e35c7bSAndrew Deason #include <sys/socket.h> 5759e35c7bSAndrew Deason #include <net/if.h> 5859e35c7bSAndrew Deason #include <sys/types.h> 5959e35c7bSAndrew Deason #include <ifaddrs.h> 6059e35c7bSAndrew Deason #ifdef CONFIG_SOLARIS 6159e35c7bSAndrew Deason #include <sys/sockio.h> 6259e35c7bSAndrew Deason #endif 6359e35c7bSAndrew Deason #endif 6459e35c7bSAndrew Deason 6577dbc81bSMarkus Armbruster static void ga_wait_child(pid_t pid, int *status, Error **errp) 66d220a6dfSLuiz Capitulino { 67d220a6dfSLuiz Capitulino pid_t rpid; 68d220a6dfSLuiz Capitulino 69d220a6dfSLuiz Capitulino *status = 0; 70d220a6dfSLuiz Capitulino 71d220a6dfSLuiz Capitulino do { 72d220a6dfSLuiz Capitulino rpid = waitpid(pid, status, 0); 73d220a6dfSLuiz Capitulino } while (rpid == -1 && errno == EINTR); 74d220a6dfSLuiz Capitulino 75d220a6dfSLuiz Capitulino if (rpid == -1) { 7677dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to wait for child (pid: %d)", 7777dbc81bSMarkus Armbruster pid); 78d220a6dfSLuiz Capitulino return; 79d220a6dfSLuiz Capitulino } 80d220a6dfSLuiz Capitulino 81d220a6dfSLuiz Capitulino g_assert(rpid == pid); 82d220a6dfSLuiz Capitulino } 83d220a6dfSLuiz Capitulino 8477dbc81bSMarkus Armbruster void qmp_guest_shutdown(bool has_mode, const char *mode, Error **errp) 85c216e5adSMichael Roth { 86c216e5adSMichael Roth const char *shutdown_flag; 87d220a6dfSLuiz Capitulino Error *local_err = NULL; 88d220a6dfSLuiz Capitulino pid_t pid; 893674838cSLuiz Capitulino int status; 90c216e5adSMichael Roth 91c8ec041dSAndrew Deason #ifdef CONFIG_SOLARIS 92c8ec041dSAndrew Deason const char *powerdown_flag = "-i5"; 93c8ec041dSAndrew Deason const char *halt_flag = "-i0"; 94c8ec041dSAndrew Deason const char *reboot_flag = "-i6"; 95c8ec041dSAndrew Deason #else 96c8ec041dSAndrew Deason const char *powerdown_flag = "-P"; 97c8ec041dSAndrew Deason const char *halt_flag = "-H"; 98c8ec041dSAndrew Deason const char *reboot_flag = "-r"; 99c8ec041dSAndrew Deason #endif 100c8ec041dSAndrew Deason 101c216e5adSMichael Roth slog("guest-shutdown called, mode: %s", mode); 102c216e5adSMichael Roth if (!has_mode || strcmp(mode, "powerdown") == 0) { 103c8ec041dSAndrew Deason shutdown_flag = powerdown_flag; 104c216e5adSMichael Roth } else if (strcmp(mode, "halt") == 0) { 105c8ec041dSAndrew Deason shutdown_flag = halt_flag; 106c216e5adSMichael Roth } else if (strcmp(mode, "reboot") == 0) { 107c8ec041dSAndrew Deason shutdown_flag = reboot_flag; 108c216e5adSMichael Roth } else { 10977dbc81bSMarkus Armbruster error_setg(errp, 110d220a6dfSLuiz Capitulino "mode is invalid (valid values are: halt|powerdown|reboot"); 111c216e5adSMichael Roth return; 112c216e5adSMichael Roth } 113c216e5adSMichael Roth 114d5dd3498SLuiz Capitulino pid = fork(); 115d5dd3498SLuiz Capitulino if (pid == 0) { 116c216e5adSMichael Roth /* child, start the shutdown */ 117c216e5adSMichael Roth setsid(); 1183674838cSLuiz Capitulino reopen_fd_to_null(0); 1193674838cSLuiz Capitulino reopen_fd_to_null(1); 1203674838cSLuiz Capitulino reopen_fd_to_null(2); 121c216e5adSMichael Roth 122c8ec041dSAndrew Deason #ifdef CONFIG_SOLARIS 123c8ec041dSAndrew Deason execl("/sbin/shutdown", "shutdown", shutdown_flag, "-g0", "-y", 124c8ec041dSAndrew Deason "hypervisor initiated shutdown", (char *)NULL); 125c8ec041dSAndrew Deason #else 126fcc41961SMarc-André Lureau execl("/sbin/shutdown", "shutdown", "-h", shutdown_flag, "+0", 127fcc41961SMarc-André Lureau "hypervisor initiated shutdown", (char *)NULL); 128c8ec041dSAndrew Deason #endif 1293674838cSLuiz Capitulino _exit(EXIT_FAILURE); 130d5dd3498SLuiz Capitulino } else if (pid < 0) { 13177dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to create child process"); 132d5dd3498SLuiz Capitulino return; 133d5dd3498SLuiz Capitulino } 134d5dd3498SLuiz Capitulino 135d220a6dfSLuiz Capitulino ga_wait_child(pid, &status, &local_err); 13684d18f06SMarkus Armbruster if (local_err) { 13777dbc81bSMarkus Armbruster error_propagate(errp, local_err); 138d220a6dfSLuiz Capitulino return; 139d220a6dfSLuiz Capitulino } 140d220a6dfSLuiz Capitulino 141d220a6dfSLuiz Capitulino if (!WIFEXITED(status)) { 14277dbc81bSMarkus Armbruster error_setg(errp, "child process has terminated abnormally"); 143d220a6dfSLuiz Capitulino return; 144d220a6dfSLuiz Capitulino } 145d220a6dfSLuiz Capitulino 146d220a6dfSLuiz Capitulino if (WEXITSTATUS(status)) { 14777dbc81bSMarkus Armbruster error_setg(errp, "child process has failed to shutdown"); 148d220a6dfSLuiz Capitulino return; 149d220a6dfSLuiz Capitulino } 150d220a6dfSLuiz Capitulino 151085d8134SPeter Maydell /* succeeded */ 152c216e5adSMichael Roth } 153c216e5adSMichael Roth 1542c958923SMichal Privoznik void qmp_guest_set_time(bool has_time, int64_t time_ns, Error **errp) 155a1bca57fSLei Li { 156a1bca57fSLei Li int ret; 157a1bca57fSLei Li int status; 158a1bca57fSLei Li pid_t pid; 159a1bca57fSLei Li Error *local_err = NULL; 160a1bca57fSLei Li struct timeval tv; 1615c6096e5SCornelia Huck static const char hwclock_path[] = "/sbin/hwclock"; 1625c6096e5SCornelia Huck static int hwclock_available = -1; 1635c6096e5SCornelia Huck 1645c6096e5SCornelia Huck if (hwclock_available < 0) { 1655c6096e5SCornelia Huck hwclock_available = (access(hwclock_path, X_OK) == 0); 1665c6096e5SCornelia Huck } 1675c6096e5SCornelia Huck 1685c6096e5SCornelia Huck if (!hwclock_available) { 1695c6096e5SCornelia Huck error_setg(errp, QERR_UNSUPPORTED); 1705c6096e5SCornelia Huck return; 1715c6096e5SCornelia Huck } 172a1bca57fSLei Li 1732c958923SMichal Privoznik /* If user has passed a time, validate and set it. */ 1742c958923SMichal Privoznik if (has_time) { 17500d2f370SMarc-André Lureau GDate date = { 0, }; 17600d2f370SMarc-André Lureau 177a1bca57fSLei Li /* year-2038 will overflow in case time_t is 32bit */ 178a1bca57fSLei Li if (time_ns / 1000000000 != (time_t)(time_ns / 1000000000)) { 179a1bca57fSLei Li error_setg(errp, "Time %" PRId64 " is too large", time_ns); 180a1bca57fSLei Li return; 181a1bca57fSLei Li } 182a1bca57fSLei Li 183a1bca57fSLei Li tv.tv_sec = time_ns / 1000000000; 184a1bca57fSLei Li tv.tv_usec = (time_ns % 1000000000) / 1000; 18500d2f370SMarc-André Lureau g_date_set_time_t(&date, tv.tv_sec); 18600d2f370SMarc-André Lureau if (date.year < 1970 || date.year >= 2070) { 18700d2f370SMarc-André Lureau error_setg_errno(errp, errno, "Invalid time"); 18800d2f370SMarc-André Lureau return; 18900d2f370SMarc-André Lureau } 190a1bca57fSLei Li 191a1bca57fSLei Li ret = settimeofday(&tv, NULL); 192a1bca57fSLei Li if (ret < 0) { 193a1bca57fSLei Li error_setg_errno(errp, errno, "Failed to set time to guest"); 194a1bca57fSLei Li return; 195a1bca57fSLei Li } 1962c958923SMichal Privoznik } 197a1bca57fSLei Li 1982c958923SMichal Privoznik /* Now, if user has passed a time to set and the system time is set, we 1992c958923SMichal Privoznik * just need to synchronize the hardware clock. However, if no time was 2002c958923SMichal Privoznik * passed, user is requesting the opposite: set the system time from the 2011634df56SAmos Kong * hardware clock (RTC). */ 202a1bca57fSLei Li pid = fork(); 203a1bca57fSLei Li if (pid == 0) { 204a1bca57fSLei Li setsid(); 205a1bca57fSLei Li reopen_fd_to_null(0); 206a1bca57fSLei Li reopen_fd_to_null(1); 207a1bca57fSLei Li reopen_fd_to_null(2); 208a1bca57fSLei Li 2092c958923SMichal Privoznik /* Use '/sbin/hwclock -w' to set RTC from the system time, 2102c958923SMichal Privoznik * or '/sbin/hwclock -s' to set the system time from RTC. */ 211fcc41961SMarc-André Lureau execl(hwclock_path, "hwclock", has_time ? "-w" : "-s", NULL); 212a1bca57fSLei Li _exit(EXIT_FAILURE); 213a1bca57fSLei Li } else if (pid < 0) { 214a1bca57fSLei Li error_setg_errno(errp, errno, "failed to create child process"); 215a1bca57fSLei Li return; 216a1bca57fSLei Li } 217a1bca57fSLei Li 218a1bca57fSLei Li ga_wait_child(pid, &status, &local_err); 21984d18f06SMarkus Armbruster if (local_err) { 220a1bca57fSLei Li error_propagate(errp, local_err); 221a1bca57fSLei Li return; 222a1bca57fSLei Li } 223a1bca57fSLei Li 224a1bca57fSLei Li if (!WIFEXITED(status)) { 225a1bca57fSLei Li error_setg(errp, "child process has terminated abnormally"); 226a1bca57fSLei Li return; 227a1bca57fSLei Li } 228a1bca57fSLei Li 229a1bca57fSLei Li if (WEXITSTATUS(status)) { 230a1bca57fSLei Li error_setg(errp, "hwclock failed to set hardware clock to system time"); 231a1bca57fSLei Li return; 232a1bca57fSLei Li } 233a1bca57fSLei Li } 234a1bca57fSLei Li 235895b00f6SMarc-André Lureau typedef enum { 236895b00f6SMarc-André Lureau RW_STATE_NEW, 237895b00f6SMarc-André Lureau RW_STATE_READING, 238895b00f6SMarc-André Lureau RW_STATE_WRITING, 239895b00f6SMarc-André Lureau } RwState; 240895b00f6SMarc-André Lureau 2415d3586b8SPhilippe Mathieu-Daudé struct GuestFileHandle { 242c216e5adSMichael Roth uint64_t id; 243c216e5adSMichael Roth FILE *fh; 244895b00f6SMarc-André Lureau RwState state; 245c216e5adSMichael Roth QTAILQ_ENTRY(GuestFileHandle) next; 2465d3586b8SPhilippe Mathieu-Daudé }; 247c216e5adSMichael Roth 248c216e5adSMichael Roth static struct { 249c216e5adSMichael Roth QTAILQ_HEAD(, GuestFileHandle) filehandles; 250b4fe97c8SDenis V. Lunev } guest_file_state = { 251b4fe97c8SDenis V. Lunev .filehandles = QTAILQ_HEAD_INITIALIZER(guest_file_state.filehandles), 252b4fe97c8SDenis V. Lunev }; 253c216e5adSMichael Roth 25439097dafSMichael Roth static int64_t guest_file_handle_add(FILE *fh, Error **errp) 255c216e5adSMichael Roth { 256c216e5adSMichael Roth GuestFileHandle *gfh; 25739097dafSMichael Roth int64_t handle; 25839097dafSMichael Roth 25939097dafSMichael Roth handle = ga_get_fd_handle(ga_state, errp); 260a903f40cSMarkus Armbruster if (handle < 0) { 261a903f40cSMarkus Armbruster return -1; 26239097dafSMichael Roth } 263c216e5adSMichael Roth 264f3a06403SMarkus Armbruster gfh = g_new0(GuestFileHandle, 1); 26539097dafSMichael Roth gfh->id = handle; 266c216e5adSMichael Roth gfh->fh = fh; 267c216e5adSMichael Roth QTAILQ_INSERT_TAIL(&guest_file_state.filehandles, gfh, next); 26839097dafSMichael Roth 26939097dafSMichael Roth return handle; 270c216e5adSMichael Roth } 271c216e5adSMichael Roth 2725d3586b8SPhilippe Mathieu-Daudé GuestFileHandle *guest_file_handle_find(int64_t id, Error **errp) 273c216e5adSMichael Roth { 274c216e5adSMichael Roth GuestFileHandle *gfh; 275c216e5adSMichael Roth 276c216e5adSMichael Roth QTAILQ_FOREACH(gfh, &guest_file_state.filehandles, next) 277c216e5adSMichael Roth { 278c216e5adSMichael Roth if (gfh->id == id) { 279c216e5adSMichael Roth return gfh; 280c216e5adSMichael Roth } 281c216e5adSMichael Roth } 282c216e5adSMichael Roth 28377dbc81bSMarkus Armbruster error_setg(errp, "handle '%" PRId64 "' has not been found", id); 284c216e5adSMichael Roth return NULL; 285c216e5adSMichael Roth } 286c216e5adSMichael Roth 287c689b4f1SLaszlo Ersek typedef const char * const ccpc; 288c689b4f1SLaszlo Ersek 2898fe6bbcaSLaszlo Ersek #ifndef O_BINARY 2908fe6bbcaSLaszlo Ersek #define O_BINARY 0 2918fe6bbcaSLaszlo Ersek #endif 2928fe6bbcaSLaszlo Ersek 293c689b4f1SLaszlo Ersek /* http://pubs.opengroup.org/onlinepubs/9699919799/functions/fopen.html */ 294c689b4f1SLaszlo Ersek static const struct { 295c689b4f1SLaszlo Ersek ccpc *forms; 296c689b4f1SLaszlo Ersek int oflag_base; 297c689b4f1SLaszlo Ersek } guest_file_open_modes[] = { 2988fe6bbcaSLaszlo Ersek { (ccpc[]){ "r", NULL }, O_RDONLY }, 2998fe6bbcaSLaszlo Ersek { (ccpc[]){ "rb", NULL }, O_RDONLY | O_BINARY }, 3008fe6bbcaSLaszlo Ersek { (ccpc[]){ "w", NULL }, O_WRONLY | O_CREAT | O_TRUNC }, 3018fe6bbcaSLaszlo Ersek { (ccpc[]){ "wb", NULL }, O_WRONLY | O_CREAT | O_TRUNC | O_BINARY }, 3028fe6bbcaSLaszlo Ersek { (ccpc[]){ "a", NULL }, O_WRONLY | O_CREAT | O_APPEND }, 3038fe6bbcaSLaszlo Ersek { (ccpc[]){ "ab", NULL }, O_WRONLY | O_CREAT | O_APPEND | O_BINARY }, 3048fe6bbcaSLaszlo Ersek { (ccpc[]){ "r+", NULL }, O_RDWR }, 3058fe6bbcaSLaszlo Ersek { (ccpc[]){ "rb+", "r+b", NULL }, O_RDWR | O_BINARY }, 3068fe6bbcaSLaszlo Ersek { (ccpc[]){ "w+", NULL }, O_RDWR | O_CREAT | O_TRUNC }, 3078fe6bbcaSLaszlo Ersek { (ccpc[]){ "wb+", "w+b", NULL }, O_RDWR | O_CREAT | O_TRUNC | O_BINARY }, 3088fe6bbcaSLaszlo Ersek { (ccpc[]){ "a+", NULL }, O_RDWR | O_CREAT | O_APPEND }, 3098fe6bbcaSLaszlo Ersek { (ccpc[]){ "ab+", "a+b", NULL }, O_RDWR | O_CREAT | O_APPEND | O_BINARY } 310c689b4f1SLaszlo Ersek }; 311c689b4f1SLaszlo Ersek 312c689b4f1SLaszlo Ersek static int 31377dbc81bSMarkus Armbruster find_open_flag(const char *mode_str, Error **errp) 314c689b4f1SLaszlo Ersek { 315c689b4f1SLaszlo Ersek unsigned mode; 316c689b4f1SLaszlo Ersek 317c689b4f1SLaszlo Ersek for (mode = 0; mode < ARRAY_SIZE(guest_file_open_modes); ++mode) { 318c689b4f1SLaszlo Ersek ccpc *form; 319c689b4f1SLaszlo Ersek 320c689b4f1SLaszlo Ersek form = guest_file_open_modes[mode].forms; 321c689b4f1SLaszlo Ersek while (*form != NULL && strcmp(*form, mode_str) != 0) { 322c689b4f1SLaszlo Ersek ++form; 323c689b4f1SLaszlo Ersek } 324c689b4f1SLaszlo Ersek if (*form != NULL) { 325c689b4f1SLaszlo Ersek break; 326c689b4f1SLaszlo Ersek } 327c689b4f1SLaszlo Ersek } 328c689b4f1SLaszlo Ersek 329c689b4f1SLaszlo Ersek if (mode == ARRAY_SIZE(guest_file_open_modes)) { 33077dbc81bSMarkus Armbruster error_setg(errp, "invalid file open mode '%s'", mode_str); 331c689b4f1SLaszlo Ersek return -1; 332c689b4f1SLaszlo Ersek } 333c689b4f1SLaszlo Ersek return guest_file_open_modes[mode].oflag_base | O_NOCTTY | O_NONBLOCK; 334c689b4f1SLaszlo Ersek } 335c689b4f1SLaszlo Ersek 336c689b4f1SLaszlo Ersek #define DEFAULT_NEW_FILE_MODE (S_IRUSR | S_IWUSR | \ 337c689b4f1SLaszlo Ersek S_IRGRP | S_IWGRP | \ 338c689b4f1SLaszlo Ersek S_IROTH | S_IWOTH) 339c689b4f1SLaszlo Ersek 340c689b4f1SLaszlo Ersek static FILE * 34177dbc81bSMarkus Armbruster safe_open_or_create(const char *path, const char *mode, Error **errp) 342c689b4f1SLaszlo Ersek { 343c689b4f1SLaszlo Ersek int oflag; 34469f56c14SMarc-André Lureau int fd = -1; 34569f56c14SMarc-André Lureau FILE *f = NULL; 346c689b4f1SLaszlo Ersek 34769f56c14SMarc-André Lureau oflag = find_open_flag(mode, errp); 34869f56c14SMarc-André Lureau if (oflag < 0) { 34969f56c14SMarc-André Lureau goto end; 35069f56c14SMarc-André Lureau } 351c689b4f1SLaszlo Ersek 352c689b4f1SLaszlo Ersek /* If the caller wants / allows creation of a new file, we implement it 353c689b4f1SLaszlo Ersek * with a two step process: open() + (open() / fchmod()). 354c689b4f1SLaszlo Ersek * 355c689b4f1SLaszlo Ersek * First we insist on creating the file exclusively as a new file. If 356c689b4f1SLaszlo Ersek * that succeeds, we're free to set any file-mode bits on it. (The 357c689b4f1SLaszlo Ersek * motivation is that we want to set those file-mode bits independently 358c689b4f1SLaszlo Ersek * of the current umask.) 359c689b4f1SLaszlo Ersek * 360c689b4f1SLaszlo Ersek * If the exclusive creation fails because the file already exists 361c689b4f1SLaszlo Ersek * (EEXIST is not possible for any other reason), we just attempt to 362c689b4f1SLaszlo Ersek * open the file, but in this case we won't be allowed to change the 363c689b4f1SLaszlo Ersek * file-mode bits on the preexistent file. 364c689b4f1SLaszlo Ersek * 365c689b4f1SLaszlo Ersek * The pathname should never disappear between the two open()s in 366c689b4f1SLaszlo Ersek * practice. If it happens, then someone very likely tried to race us. 367c689b4f1SLaszlo Ersek * In this case just go ahead and report the ENOENT from the second 368c689b4f1SLaszlo Ersek * open() to the caller. 369c689b4f1SLaszlo Ersek * 370c689b4f1SLaszlo Ersek * If the caller wants to open a preexistent file, then the first 371c689b4f1SLaszlo Ersek * open() is decisive and its third argument is ignored, and the second 372c689b4f1SLaszlo Ersek * open() and the fchmod() are never called. 373c689b4f1SLaszlo Ersek */ 3741a89a17bSMarc-André Lureau fd = qga_open_cloexec(path, oflag | ((oflag & O_CREAT) ? O_EXCL : 0), 0); 375c689b4f1SLaszlo Ersek if (fd == -1 && errno == EEXIST) { 376c689b4f1SLaszlo Ersek oflag &= ~(unsigned)O_CREAT; 3771a89a17bSMarc-André Lureau fd = qga_open_cloexec(path, oflag, 0); 378c689b4f1SLaszlo Ersek } 379c689b4f1SLaszlo Ersek if (fd == -1) { 38069f56c14SMarc-André Lureau error_setg_errno(errp, errno, 38169f56c14SMarc-André Lureau "failed to open file '%s' (mode: '%s')", 38269f56c14SMarc-André Lureau path, mode); 38369f56c14SMarc-André Lureau goto end; 38469f56c14SMarc-André Lureau } 38569f56c14SMarc-André Lureau 386c689b4f1SLaszlo Ersek if ((oflag & O_CREAT) && fchmod(fd, DEFAULT_NEW_FILE_MODE) == -1) { 38769f56c14SMarc-André Lureau error_setg_errno(errp, errno, "failed to set permission " 388c689b4f1SLaszlo Ersek "0%03o on new file '%s' (mode: '%s')", 389c689b4f1SLaszlo Ersek (unsigned)DEFAULT_NEW_FILE_MODE, path, mode); 39069f56c14SMarc-André Lureau goto end; 39169f56c14SMarc-André Lureau } 392c689b4f1SLaszlo Ersek 393c689b4f1SLaszlo Ersek f = fdopen(fd, mode); 394c689b4f1SLaszlo Ersek if (f == NULL) { 39569f56c14SMarc-André Lureau error_setg_errno(errp, errno, "failed to associate stdio stream with " 39669f56c14SMarc-André Lureau "file descriptor %d, file '%s' (mode: '%s')", 39769f56c14SMarc-André Lureau fd, path, mode); 398c689b4f1SLaszlo Ersek } 399c689b4f1SLaszlo Ersek 40069f56c14SMarc-André Lureau end: 40169f56c14SMarc-André Lureau if (f == NULL && fd != -1) { 402c689b4f1SLaszlo Ersek close(fd); 4032b720018SLaszlo Ersek if (oflag & O_CREAT) { 4042b720018SLaszlo Ersek unlink(path); 4052b720018SLaszlo Ersek } 406c689b4f1SLaszlo Ersek } 40769f56c14SMarc-André Lureau return f; 408c689b4f1SLaszlo Ersek } 409c689b4f1SLaszlo Ersek 41077dbc81bSMarkus Armbruster int64_t qmp_guest_file_open(const char *path, bool has_mode, const char *mode, 41177dbc81bSMarkus Armbruster Error **errp) 412c216e5adSMichael Roth { 413c216e5adSMichael Roth FILE *fh; 414c689b4f1SLaszlo Ersek Error *local_err = NULL; 41585b6f6f5SSimon Zolin int64_t handle; 416c216e5adSMichael Roth 417c216e5adSMichael Roth if (!has_mode) { 418c216e5adSMichael Roth mode = "r"; 419c216e5adSMichael Roth } 420c216e5adSMichael Roth slog("guest-file-open called, filepath: %s, mode: %s", path, mode); 421c689b4f1SLaszlo Ersek fh = safe_open_or_create(path, mode, &local_err); 422c689b4f1SLaszlo Ersek if (local_err != NULL) { 42377dbc81bSMarkus Armbruster error_propagate(errp, local_err); 424c216e5adSMichael Roth return -1; 425c216e5adSMichael Roth } 426c216e5adSMichael Roth 427c216e5adSMichael Roth /* set fd non-blocking to avoid common use cases (like reading from a 428c216e5adSMichael Roth * named pipe) from hanging the agent 429c216e5adSMichael Roth */ 430b0a8f9adSMarc-André Lureau if (!g_unix_set_fd_nonblocking(fileno(fh), true, NULL)) { 431b0a8f9adSMarc-André Lureau fclose(fh); 432b0a8f9adSMarc-André Lureau error_setg_errno(errp, errno, "Failed to set FD nonblocking"); 433b0a8f9adSMarc-André Lureau return -1; 434b0a8f9adSMarc-André Lureau } 435c216e5adSMichael Roth 43677dbc81bSMarkus Armbruster handle = guest_file_handle_add(fh, errp); 437a903f40cSMarkus Armbruster if (handle < 0) { 43839097dafSMichael Roth fclose(fh); 43939097dafSMichael Roth return -1; 44039097dafSMichael Roth } 44139097dafSMichael Roth 442d607a523SStefan Weil slog("guest-file-open, handle: %" PRId64, handle); 44339097dafSMichael Roth return handle; 444c216e5adSMichael Roth } 445c216e5adSMichael Roth 44677dbc81bSMarkus Armbruster void qmp_guest_file_close(int64_t handle, Error **errp) 447c216e5adSMichael Roth { 44877dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 449c216e5adSMichael Roth int ret; 450c216e5adSMichael Roth 451d607a523SStefan Weil slog("guest-file-close called, handle: %" PRId64, handle); 452c216e5adSMichael Roth if (!gfh) { 453c216e5adSMichael Roth return; 454c216e5adSMichael Roth } 455c216e5adSMichael Roth 456c216e5adSMichael Roth ret = fclose(gfh->fh); 4573ac4b7c5SLuiz Capitulino if (ret == EOF) { 45877dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to close handle"); 459c216e5adSMichael Roth return; 460c216e5adSMichael Roth } 461c216e5adSMichael Roth 462c216e5adSMichael Roth QTAILQ_REMOVE(&guest_file_state.filehandles, gfh, next); 463c216e5adSMichael Roth g_free(gfh); 464c216e5adSMichael Roth } 465c216e5adSMichael Roth 466ead83a13SPhilippe Mathieu-Daudé GuestFileRead *guest_file_read_unsafe(GuestFileHandle *gfh, 46777dbc81bSMarkus Armbruster int64_t count, Error **errp) 468c216e5adSMichael Roth { 469c216e5adSMichael Roth GuestFileRead *read_data = NULL; 470c216e5adSMichael Roth guchar *buf; 471ead83a13SPhilippe Mathieu-Daudé FILE *fh = gfh->fh; 472c216e5adSMichael Roth size_t read_count; 473c216e5adSMichael Roth 474895b00f6SMarc-André Lureau /* explicitly flush when switching from writing to reading */ 475895b00f6SMarc-André Lureau if (gfh->state == RW_STATE_WRITING) { 476895b00f6SMarc-André Lureau int ret = fflush(fh); 477895b00f6SMarc-André Lureau if (ret == EOF) { 478895b00f6SMarc-André Lureau error_setg_errno(errp, errno, "failed to flush file"); 479895b00f6SMarc-André Lureau return NULL; 480895b00f6SMarc-André Lureau } 481895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 482895b00f6SMarc-André Lureau } 483895b00f6SMarc-André Lureau 484c216e5adSMichael Roth buf = g_malloc0(count + 1); 485c216e5adSMichael Roth read_count = fread(buf, 1, count, fh); 486c216e5adSMichael Roth if (ferror(fh)) { 48777dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to read file"); 488c216e5adSMichael Roth } else { 489c216e5adSMichael Roth buf[read_count] = 0; 490f3a06403SMarkus Armbruster read_data = g_new0(GuestFileRead, 1); 491c216e5adSMichael Roth read_data->count = read_count; 492c216e5adSMichael Roth read_data->eof = feof(fh); 493c216e5adSMichael Roth if (read_count) { 494c216e5adSMichael Roth read_data->buf_b64 = g_base64_encode(buf, read_count); 495c216e5adSMichael Roth } 496895b00f6SMarc-André Lureau gfh->state = RW_STATE_READING; 497c216e5adSMichael Roth } 498c216e5adSMichael Roth g_free(buf); 499c216e5adSMichael Roth clearerr(fh); 500c216e5adSMichael Roth 501c216e5adSMichael Roth return read_data; 502c216e5adSMichael Roth } 503c216e5adSMichael Roth 504c216e5adSMichael Roth GuestFileWrite *qmp_guest_file_write(int64_t handle, const char *buf_b64, 50577dbc81bSMarkus Armbruster bool has_count, int64_t count, 50677dbc81bSMarkus Armbruster Error **errp) 507c216e5adSMichael Roth { 508c216e5adSMichael Roth GuestFileWrite *write_data = NULL; 509c216e5adSMichael Roth guchar *buf; 510c216e5adSMichael Roth gsize buf_len; 511c216e5adSMichael Roth int write_count; 51277dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 513c216e5adSMichael Roth FILE *fh; 514c216e5adSMichael Roth 515c216e5adSMichael Roth if (!gfh) { 516c216e5adSMichael Roth return NULL; 517c216e5adSMichael Roth } 518c216e5adSMichael Roth 519c216e5adSMichael Roth fh = gfh->fh; 520895b00f6SMarc-André Lureau 521895b00f6SMarc-André Lureau if (gfh->state == RW_STATE_READING) { 522895b00f6SMarc-André Lureau int ret = fseek(fh, 0, SEEK_CUR); 523895b00f6SMarc-André Lureau if (ret == -1) { 524895b00f6SMarc-André Lureau error_setg_errno(errp, errno, "failed to seek file"); 525895b00f6SMarc-André Lureau return NULL; 526895b00f6SMarc-André Lureau } 527895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 528895b00f6SMarc-André Lureau } 529895b00f6SMarc-André Lureau 530920639caSDaniel P. Berrange buf = qbase64_decode(buf_b64, -1, &buf_len, errp); 531920639caSDaniel P. Berrange if (!buf) { 532920639caSDaniel P. Berrange return NULL; 533920639caSDaniel P. Berrange } 534c216e5adSMichael Roth 535c216e5adSMichael Roth if (!has_count) { 536c216e5adSMichael Roth count = buf_len; 537c216e5adSMichael Roth } else if (count < 0 || count > buf_len) { 53877dbc81bSMarkus Armbruster error_setg(errp, "value '%" PRId64 "' is invalid for argument count", 539db3edb66SLuiz Capitulino count); 540c216e5adSMichael Roth g_free(buf); 541c216e5adSMichael Roth return NULL; 542c216e5adSMichael Roth } 543c216e5adSMichael Roth 544c216e5adSMichael Roth write_count = fwrite(buf, 1, count, fh); 545c216e5adSMichael Roth if (ferror(fh)) { 54677dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to write to file"); 547d607a523SStefan Weil slog("guest-file-write failed, handle: %" PRId64, handle); 548c216e5adSMichael Roth } else { 549f3a06403SMarkus Armbruster write_data = g_new0(GuestFileWrite, 1); 550c216e5adSMichael Roth write_data->count = write_count; 551c216e5adSMichael Roth write_data->eof = feof(fh); 552895b00f6SMarc-André Lureau gfh->state = RW_STATE_WRITING; 553c216e5adSMichael Roth } 554c216e5adSMichael Roth g_free(buf); 555c216e5adSMichael Roth clearerr(fh); 556c216e5adSMichael Roth 557c216e5adSMichael Roth return write_data; 558c216e5adSMichael Roth } 559c216e5adSMichael Roth 560c216e5adSMichael Roth struct GuestFileSeek *qmp_guest_file_seek(int64_t handle, int64_t offset, 5610b4b4938SEric Blake GuestFileWhence *whence_code, 5620b4b4938SEric Blake Error **errp) 563c216e5adSMichael Roth { 56477dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 565c216e5adSMichael Roth GuestFileSeek *seek_data = NULL; 566c216e5adSMichael Roth FILE *fh; 567c216e5adSMichael Roth int ret; 5680a982b1bSEric Blake int whence; 5690b4b4938SEric Blake Error *err = NULL; 570c216e5adSMichael Roth 571c216e5adSMichael Roth if (!gfh) { 572c216e5adSMichael Roth return NULL; 573c216e5adSMichael Roth } 574c216e5adSMichael Roth 5750a982b1bSEric Blake /* We stupidly exposed 'whence':'int' in our qapi */ 5760b4b4938SEric Blake whence = ga_parse_whence(whence_code, &err); 5770b4b4938SEric Blake if (err) { 5780b4b4938SEric Blake error_propagate(errp, err); 5790a982b1bSEric Blake return NULL; 5800a982b1bSEric Blake } 5810a982b1bSEric Blake 582c216e5adSMichael Roth fh = gfh->fh; 583c216e5adSMichael Roth ret = fseek(fh, offset, whence); 584c216e5adSMichael Roth if (ret == -1) { 58577dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to seek file"); 586895b00f6SMarc-André Lureau if (errno == ESPIPE) { 587895b00f6SMarc-André Lureau /* file is non-seekable, stdio shouldn't be buffering anyways */ 588895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 589895b00f6SMarc-André Lureau } 590c216e5adSMichael Roth } else { 59110b7c5ddSMarkus Armbruster seek_data = g_new0(GuestFileSeek, 1); 592c216e5adSMichael Roth seek_data->position = ftell(fh); 593c216e5adSMichael Roth seek_data->eof = feof(fh); 594895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 595c216e5adSMichael Roth } 596c216e5adSMichael Roth clearerr(fh); 597c216e5adSMichael Roth 598c216e5adSMichael Roth return seek_data; 599c216e5adSMichael Roth } 600c216e5adSMichael Roth 60177dbc81bSMarkus Armbruster void qmp_guest_file_flush(int64_t handle, Error **errp) 602c216e5adSMichael Roth { 60377dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 604c216e5adSMichael Roth FILE *fh; 605c216e5adSMichael Roth int ret; 606c216e5adSMichael Roth 607c216e5adSMichael Roth if (!gfh) { 608c216e5adSMichael Roth return; 609c216e5adSMichael Roth } 610c216e5adSMichael Roth 611c216e5adSMichael Roth fh = gfh->fh; 612c216e5adSMichael Roth ret = fflush(fh); 613c216e5adSMichael Roth if (ret == EOF) { 61477dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to flush file"); 615895b00f6SMarc-André Lureau } else { 616895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 617c216e5adSMichael Roth } 618c216e5adSMichael Roth } 619c216e5adSMichael Roth 620e72c3f2eSMichael Roth /* linux-specific implementations. avoid this if at all possible. */ 621e72c3f2eSMichael Roth #if defined(__linux__) 622e72c3f2eSMichael Roth 623eab5fd59SPaolo Bonzini #if defined(CONFIG_FSFREEZE) || defined(CONFIG_FSTRIM) 624af02203fSPaolo Bonzini typedef struct FsMount { 625c216e5adSMichael Roth char *dirname; 626c216e5adSMichael Roth char *devtype; 62746d4c572STomoki Sekiyama unsigned int devmajor, devminor; 628af02203fSPaolo Bonzini QTAILQ_ENTRY(FsMount) next; 629af02203fSPaolo Bonzini } FsMount; 630c216e5adSMichael Roth 631e5d9adbdSTomoki Sekiyama typedef QTAILQ_HEAD(FsMountList, FsMount) FsMountList; 6329e8aded4SMichael Roth 633af02203fSPaolo Bonzini static void free_fs_mount_list(FsMountList *mounts) 634c216e5adSMichael Roth { 635af02203fSPaolo Bonzini FsMount *mount, *temp; 636c216e5adSMichael Roth 6379e8aded4SMichael Roth if (!mounts) { 6389e8aded4SMichael Roth return; 6399e8aded4SMichael Roth } 6409e8aded4SMichael Roth 6419e8aded4SMichael Roth QTAILQ_FOREACH_SAFE(mount, mounts, next, temp) { 6429e8aded4SMichael Roth QTAILQ_REMOVE(mounts, mount, next); 643c216e5adSMichael Roth g_free(mount->dirname); 644c216e5adSMichael Roth g_free(mount->devtype); 645c216e5adSMichael Roth g_free(mount); 646c216e5adSMichael Roth } 6479e8aded4SMichael Roth } 6489e8aded4SMichael Roth 64946d4c572STomoki Sekiyama static int dev_major_minor(const char *devpath, 65046d4c572STomoki Sekiyama unsigned int *devmajor, unsigned int *devminor) 65146d4c572STomoki Sekiyama { 65246d4c572STomoki Sekiyama struct stat st; 65346d4c572STomoki Sekiyama 65446d4c572STomoki Sekiyama *devmajor = 0; 65546d4c572STomoki Sekiyama *devminor = 0; 65646d4c572STomoki Sekiyama 65746d4c572STomoki Sekiyama if (stat(devpath, &st) < 0) { 65846d4c572STomoki Sekiyama slog("failed to stat device file '%s': %s", devpath, strerror(errno)); 65946d4c572STomoki Sekiyama return -1; 66046d4c572STomoki Sekiyama } 66146d4c572STomoki Sekiyama if (S_ISDIR(st.st_mode)) { 66246d4c572STomoki Sekiyama /* It is bind mount */ 66346d4c572STomoki Sekiyama return -2; 66446d4c572STomoki Sekiyama } 66546d4c572STomoki Sekiyama if (S_ISBLK(st.st_mode)) { 66646d4c572STomoki Sekiyama *devmajor = major(st.st_rdev); 66746d4c572STomoki Sekiyama *devminor = minor(st.st_rdev); 66846d4c572STomoki Sekiyama return 0; 66946d4c572STomoki Sekiyama } 67046d4c572STomoki Sekiyama return -1; 67146d4c572STomoki Sekiyama } 67246d4c572STomoki Sekiyama 6739e8aded4SMichael Roth /* 6749e8aded4SMichael Roth * Walk the mount table and build a list of local file systems 6759e8aded4SMichael Roth */ 676561bfcb6SMarc-André Lureau static bool build_fs_mount_list_from_mtab(FsMountList *mounts, Error **errp) 6779e8aded4SMichael Roth { 6789e8aded4SMichael Roth struct mntent *ment; 679af02203fSPaolo Bonzini FsMount *mount; 6809e2fa418SMichael Roth char const *mtab = "/proc/self/mounts"; 6819e8aded4SMichael Roth FILE *fp; 68246d4c572STomoki Sekiyama unsigned int devmajor, devminor; 683c216e5adSMichael Roth 684c216e5adSMichael Roth fp = setmntent(mtab, "r"); 685c216e5adSMichael Roth if (!fp) { 68677dbc81bSMarkus Armbruster error_setg(errp, "failed to open mtab file: '%s'", mtab); 687561bfcb6SMarc-André Lureau return false; 688c216e5adSMichael Roth } 689c216e5adSMichael Roth 690c216e5adSMichael Roth while ((ment = getmntent(fp))) { 691c216e5adSMichael Roth /* 692c216e5adSMichael Roth * An entry which device name doesn't start with a '/' is 693c216e5adSMichael Roth * either a dummy file system or a network file system. 694c216e5adSMichael Roth * Add special handling for smbfs and cifs as is done by 695c216e5adSMichael Roth * coreutils as well. 696c216e5adSMichael Roth */ 697c216e5adSMichael Roth if ((ment->mnt_fsname[0] != '/') || 698c216e5adSMichael Roth (strcmp(ment->mnt_type, "smbfs") == 0) || 699c216e5adSMichael Roth (strcmp(ment->mnt_type, "cifs") == 0)) { 700c216e5adSMichael Roth continue; 701c216e5adSMichael Roth } 70246d4c572STomoki Sekiyama if (dev_major_minor(ment->mnt_fsname, &devmajor, &devminor) == -2) { 70346d4c572STomoki Sekiyama /* Skip bind mounts */ 70446d4c572STomoki Sekiyama continue; 70546d4c572STomoki Sekiyama } 706c216e5adSMichael Roth 707f3a06403SMarkus Armbruster mount = g_new0(FsMount, 1); 708c216e5adSMichael Roth mount->dirname = g_strdup(ment->mnt_dir); 709c216e5adSMichael Roth mount->devtype = g_strdup(ment->mnt_type); 71046d4c572STomoki Sekiyama mount->devmajor = devmajor; 71146d4c572STomoki Sekiyama mount->devminor = devminor; 712c216e5adSMichael Roth 7139e8aded4SMichael Roth QTAILQ_INSERT_TAIL(mounts, mount, next); 714c216e5adSMichael Roth } 715c216e5adSMichael Roth 716c216e5adSMichael Roth endmntent(fp); 717561bfcb6SMarc-André Lureau return true; 718c216e5adSMichael Roth } 71946d4c572STomoki Sekiyama 72046d4c572STomoki Sekiyama static void decode_mntname(char *name, int len) 72146d4c572STomoki Sekiyama { 72246d4c572STomoki Sekiyama int i, j = 0; 72346d4c572STomoki Sekiyama for (i = 0; i <= len; i++) { 72446d4c572STomoki Sekiyama if (name[i] != '\\') { 72546d4c572STomoki Sekiyama name[j++] = name[i]; 72646d4c572STomoki Sekiyama } else if (name[i + 1] == '\\') { 72746d4c572STomoki Sekiyama name[j++] = '\\'; 72846d4c572STomoki Sekiyama i++; 72946d4c572STomoki Sekiyama } else if (name[i + 1] >= '0' && name[i + 1] <= '3' && 73046d4c572STomoki Sekiyama name[i + 2] >= '0' && name[i + 2] <= '7' && 73146d4c572STomoki Sekiyama name[i + 3] >= '0' && name[i + 3] <= '7') { 73246d4c572STomoki Sekiyama name[j++] = (name[i + 1] - '0') * 64 + 73346d4c572STomoki Sekiyama (name[i + 2] - '0') * 8 + 73446d4c572STomoki Sekiyama (name[i + 3] - '0'); 73546d4c572STomoki Sekiyama i += 3; 73646d4c572STomoki Sekiyama } else { 73746d4c572STomoki Sekiyama name[j++] = name[i]; 73846d4c572STomoki Sekiyama } 73946d4c572STomoki Sekiyama } 74046d4c572STomoki Sekiyama } 74146d4c572STomoki Sekiyama 742561bfcb6SMarc-André Lureau static bool build_fs_mount_list(FsMountList *mounts, Error **errp) 74346d4c572STomoki Sekiyama { 74446d4c572STomoki Sekiyama FsMount *mount; 74546d4c572STomoki Sekiyama char const *mountinfo = "/proc/self/mountinfo"; 74646d4c572STomoki Sekiyama FILE *fp; 74746d4c572STomoki Sekiyama char *line = NULL, *dash; 74846d4c572STomoki Sekiyama size_t n; 74946d4c572STomoki Sekiyama char check; 75046d4c572STomoki Sekiyama unsigned int devmajor, devminor; 75146d4c572STomoki Sekiyama int ret, dir_s, dir_e, type_s, type_e, dev_s, dev_e; 75246d4c572STomoki Sekiyama 75346d4c572STomoki Sekiyama fp = fopen(mountinfo, "r"); 75446d4c572STomoki Sekiyama if (!fp) { 755561bfcb6SMarc-André Lureau return build_fs_mount_list_from_mtab(mounts, errp); 75646d4c572STomoki Sekiyama } 75746d4c572STomoki Sekiyama 75846d4c572STomoki Sekiyama while (getline(&line, &n, fp) != -1) { 75946d4c572STomoki Sekiyama ret = sscanf(line, "%*u %*u %u:%u %*s %n%*s%n%c", 76046d4c572STomoki Sekiyama &devmajor, &devminor, &dir_s, &dir_e, &check); 76146d4c572STomoki Sekiyama if (ret < 3) { 76246d4c572STomoki Sekiyama continue; 76346d4c572STomoki Sekiyama } 76446d4c572STomoki Sekiyama dash = strstr(line + dir_e, " - "); 76546d4c572STomoki Sekiyama if (!dash) { 76646d4c572STomoki Sekiyama continue; 76746d4c572STomoki Sekiyama } 76846d4c572STomoki Sekiyama ret = sscanf(dash, " - %n%*s%n %n%*s%n%c", 76946d4c572STomoki Sekiyama &type_s, &type_e, &dev_s, &dev_e, &check); 77046d4c572STomoki Sekiyama if (ret < 1) { 77146d4c572STomoki Sekiyama continue; 77246d4c572STomoki Sekiyama } 77346d4c572STomoki Sekiyama line[dir_e] = 0; 77446d4c572STomoki Sekiyama dash[type_e] = 0; 77546d4c572STomoki Sekiyama dash[dev_e] = 0; 77646d4c572STomoki Sekiyama decode_mntname(line + dir_s, dir_e - dir_s); 77746d4c572STomoki Sekiyama decode_mntname(dash + dev_s, dev_e - dev_s); 77846d4c572STomoki Sekiyama if (devmajor == 0) { 77946d4c572STomoki Sekiyama /* btrfs reports major number = 0 */ 78046d4c572STomoki Sekiyama if (strcmp("btrfs", dash + type_s) != 0 || 78146d4c572STomoki Sekiyama dev_major_minor(dash + dev_s, &devmajor, &devminor) < 0) { 78246d4c572STomoki Sekiyama continue; 78346d4c572STomoki Sekiyama } 78446d4c572STomoki Sekiyama } 78546d4c572STomoki Sekiyama 786f3a06403SMarkus Armbruster mount = g_new0(FsMount, 1); 78746d4c572STomoki Sekiyama mount->dirname = g_strdup(line + dir_s); 78846d4c572STomoki Sekiyama mount->devtype = g_strdup(dash + type_s); 78946d4c572STomoki Sekiyama mount->devmajor = devmajor; 79046d4c572STomoki Sekiyama mount->devminor = devminor; 79146d4c572STomoki Sekiyama 79246d4c572STomoki Sekiyama QTAILQ_INSERT_TAIL(mounts, mount, next); 79346d4c572STomoki Sekiyama } 79446d4c572STomoki Sekiyama free(line); 79546d4c572STomoki Sekiyama 79646d4c572STomoki Sekiyama fclose(fp); 797561bfcb6SMarc-André Lureau return true; 79846d4c572STomoki Sekiyama } 799eab5fd59SPaolo Bonzini #endif 800eab5fd59SPaolo Bonzini 801eab5fd59SPaolo Bonzini #if defined(CONFIG_FSFREEZE) 802c216e5adSMichael Roth 80346d4c572STomoki Sekiyama static char *get_pci_driver(char const *syspath, int pathlen, Error **errp) 80446d4c572STomoki Sekiyama { 80546d4c572STomoki Sekiyama char *path; 80646d4c572STomoki Sekiyama char *dpath; 80746d4c572STomoki Sekiyama char *driver = NULL; 80846d4c572STomoki Sekiyama char buf[PATH_MAX]; 80946d4c572STomoki Sekiyama ssize_t len; 81046d4c572STomoki Sekiyama 81146d4c572STomoki Sekiyama path = g_strndup(syspath, pathlen); 81246d4c572STomoki Sekiyama dpath = g_strdup_printf("%s/driver", path); 81346d4c572STomoki Sekiyama len = readlink(dpath, buf, sizeof(buf) - 1); 81446d4c572STomoki Sekiyama if (len != -1) { 81546d4c572STomoki Sekiyama buf[len] = 0; 8163e015d81SJulia Suvorova driver = g_path_get_basename(buf); 81746d4c572STomoki Sekiyama } 81846d4c572STomoki Sekiyama g_free(dpath); 81946d4c572STomoki Sekiyama g_free(path); 82046d4c572STomoki Sekiyama return driver; 82146d4c572STomoki Sekiyama } 82246d4c572STomoki Sekiyama 82346d4c572STomoki Sekiyama static int compare_uint(const void *_a, const void *_b) 82446d4c572STomoki Sekiyama { 82546d4c572STomoki Sekiyama unsigned int a = *(unsigned int *)_a; 82646d4c572STomoki Sekiyama unsigned int b = *(unsigned int *)_b; 82746d4c572STomoki Sekiyama 82846d4c572STomoki Sekiyama return a < b ? -1 : a > b ? 1 : 0; 82946d4c572STomoki Sekiyama } 83046d4c572STomoki Sekiyama 83146d4c572STomoki Sekiyama /* Walk the specified sysfs and build a sorted list of host or ata numbers */ 83246d4c572STomoki Sekiyama static int build_hosts(char const *syspath, char const *host, bool ata, 83346d4c572STomoki Sekiyama unsigned int *hosts, int hosts_max, Error **errp) 83446d4c572STomoki Sekiyama { 83546d4c572STomoki Sekiyama char *path; 83646d4c572STomoki Sekiyama DIR *dir; 83746d4c572STomoki Sekiyama struct dirent *entry; 83846d4c572STomoki Sekiyama int i = 0; 83946d4c572STomoki Sekiyama 84046d4c572STomoki Sekiyama path = g_strndup(syspath, host - syspath); 84146d4c572STomoki Sekiyama dir = opendir(path); 84246d4c572STomoki Sekiyama if (!dir) { 84346d4c572STomoki Sekiyama error_setg_errno(errp, errno, "opendir(\"%s\")", path); 84446d4c572STomoki Sekiyama g_free(path); 84546d4c572STomoki Sekiyama return -1; 84646d4c572STomoki Sekiyama } 84746d4c572STomoki Sekiyama 84846d4c572STomoki Sekiyama while (i < hosts_max) { 84946d4c572STomoki Sekiyama entry = readdir(dir); 85046d4c572STomoki Sekiyama if (!entry) { 85146d4c572STomoki Sekiyama break; 85246d4c572STomoki Sekiyama } 85346d4c572STomoki Sekiyama if (ata && sscanf(entry->d_name, "ata%d", hosts + i) == 1) { 85446d4c572STomoki Sekiyama ++i; 85546d4c572STomoki Sekiyama } else if (!ata && sscanf(entry->d_name, "host%d", hosts + i) == 1) { 85646d4c572STomoki Sekiyama ++i; 85746d4c572STomoki Sekiyama } 85846d4c572STomoki Sekiyama } 85946d4c572STomoki Sekiyama 86046d4c572STomoki Sekiyama qsort(hosts, i, sizeof(hosts[0]), compare_uint); 86146d4c572STomoki Sekiyama 86246d4c572STomoki Sekiyama g_free(path); 86346d4c572STomoki Sekiyama closedir(dir); 86446d4c572STomoki Sekiyama return i; 86546d4c572STomoki Sekiyama } 86646d4c572STomoki Sekiyama 867d9fe4f0fSThomas Huth /* 868d9fe4f0fSThomas Huth * Store disk device info for devices on the PCI bus. 869d9fe4f0fSThomas Huth * Returns true if information has been stored, or false for failure. 870d9fe4f0fSThomas Huth */ 871d9fe4f0fSThomas Huth static bool build_guest_fsinfo_for_pci_dev(char const *syspath, 872d9fe4f0fSThomas Huth GuestDiskAddress *disk, 87346d4c572STomoki Sekiyama Error **errp) 87446d4c572STomoki Sekiyama { 87546d4c572STomoki Sekiyama unsigned int pci[4], host, hosts[8], tgt[3]; 87646d4c572STomoki Sekiyama int i, nhosts = 0, pcilen; 877d9fe4f0fSThomas Huth GuestPCIAddress *pciaddr = disk->pci_controller; 87846d4c572STomoki Sekiyama bool has_ata = false, has_host = false, has_tgt = false; 87946d4c572STomoki Sekiyama char *p, *q, *driver = NULL; 880d9fe4f0fSThomas Huth bool ret = false; 88146d4c572STomoki Sekiyama 88246d4c572STomoki Sekiyama p = strstr(syspath, "/devices/pci"); 88346d4c572STomoki Sekiyama if (!p || sscanf(p + 12, "%*x:%*x/%x:%x:%x.%x%n", 88446d4c572STomoki Sekiyama pci, pci + 1, pci + 2, pci + 3, &pcilen) < 4) { 885743c71d0SMarc-André Lureau g_debug("only pci device is supported: sysfs path '%s'", syspath); 886d9fe4f0fSThomas Huth return false; 88746d4c572STomoki Sekiyama } 88846d4c572STomoki Sekiyama 889743c71d0SMarc-André Lureau p += 12 + pcilen; 890743c71d0SMarc-André Lureau while (true) { 891743c71d0SMarc-André Lureau driver = get_pci_driver(syspath, p - syspath, errp); 892743c71d0SMarc-André Lureau if (driver && (g_str_equal(driver, "ata_piix") || 893743c71d0SMarc-André Lureau g_str_equal(driver, "sym53c8xx") || 894743c71d0SMarc-André Lureau g_str_equal(driver, "virtio-pci") || 895d48f61c8Szhenwei pi g_str_equal(driver, "ahci") || 896d48f61c8Szhenwei pi g_str_equal(driver, "nvme"))) { 897743c71d0SMarc-André Lureau break; 898743c71d0SMarc-André Lureau } 899743c71d0SMarc-André Lureau 900bb23a736SMarc-André Lureau g_free(driver); 901743c71d0SMarc-André Lureau if (sscanf(p, "/%x:%x:%x.%x%n", 902743c71d0SMarc-André Lureau pci, pci + 1, pci + 2, pci + 3, &pcilen) == 4) { 903743c71d0SMarc-André Lureau p += pcilen; 904743c71d0SMarc-André Lureau continue; 905743c71d0SMarc-André Lureau } 906743c71d0SMarc-André Lureau 907743c71d0SMarc-André Lureau g_debug("unsupported driver or sysfs path '%s'", syspath); 908d9fe4f0fSThomas Huth return false; 90946d4c572STomoki Sekiyama } 91046d4c572STomoki Sekiyama 91146d4c572STomoki Sekiyama p = strstr(syspath, "/target"); 91246d4c572STomoki Sekiyama if (p && sscanf(p + 7, "%*u:%*u:%*u/%*u:%u:%u:%u", 91346d4c572STomoki Sekiyama tgt, tgt + 1, tgt + 2) == 3) { 91446d4c572STomoki Sekiyama has_tgt = true; 91546d4c572STomoki Sekiyama } 91646d4c572STomoki Sekiyama 91746d4c572STomoki Sekiyama p = strstr(syspath, "/ata"); 91846d4c572STomoki Sekiyama if (p) { 91946d4c572STomoki Sekiyama q = p + 4; 92046d4c572STomoki Sekiyama has_ata = true; 92146d4c572STomoki Sekiyama } else { 92246d4c572STomoki Sekiyama p = strstr(syspath, "/host"); 92346d4c572STomoki Sekiyama q = p + 5; 92446d4c572STomoki Sekiyama } 92546d4c572STomoki Sekiyama if (p && sscanf(q, "%u", &host) == 1) { 92646d4c572STomoki Sekiyama has_host = true; 92746d4c572STomoki Sekiyama nhosts = build_hosts(syspath, p, has_ata, hosts, 92801a6df1bSPhilippe Mathieu-Daudé ARRAY_SIZE(hosts), errp); 92946d4c572STomoki Sekiyama if (nhosts < 0) { 93046d4c572STomoki Sekiyama goto cleanup; 93146d4c572STomoki Sekiyama } 93246d4c572STomoki Sekiyama } 93346d4c572STomoki Sekiyama 93446d4c572STomoki Sekiyama pciaddr->domain = pci[0]; 93546d4c572STomoki Sekiyama pciaddr->bus = pci[1]; 93646d4c572STomoki Sekiyama pciaddr->slot = pci[2]; 93746d4c572STomoki Sekiyama pciaddr->function = pci[3]; 93846d4c572STomoki Sekiyama 93946d4c572STomoki Sekiyama if (strcmp(driver, "ata_piix") == 0) { 94046d4c572STomoki Sekiyama /* a host per ide bus, target*:0:<unit>:0 */ 94146d4c572STomoki Sekiyama if (!has_host || !has_tgt) { 94246d4c572STomoki Sekiyama g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver); 94346d4c572STomoki Sekiyama goto cleanup; 94446d4c572STomoki Sekiyama } 94546d4c572STomoki Sekiyama for (i = 0; i < nhosts; i++) { 94646d4c572STomoki Sekiyama if (host == hosts[i]) { 94746d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_IDE; 94846d4c572STomoki Sekiyama disk->bus = i; 94946d4c572STomoki Sekiyama disk->unit = tgt[1]; 95046d4c572STomoki Sekiyama break; 95146d4c572STomoki Sekiyama } 95246d4c572STomoki Sekiyama } 95346d4c572STomoki Sekiyama if (i >= nhosts) { 95446d4c572STomoki Sekiyama g_debug("no host for '%s' (driver '%s')", syspath, driver); 95546d4c572STomoki Sekiyama goto cleanup; 95646d4c572STomoki Sekiyama } 95746d4c572STomoki Sekiyama } else if (strcmp(driver, "sym53c8xx") == 0) { 95846d4c572STomoki Sekiyama /* scsi(LSI Logic): target*:0:<unit>:0 */ 95946d4c572STomoki Sekiyama if (!has_tgt) { 96046d4c572STomoki Sekiyama g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver); 96146d4c572STomoki Sekiyama goto cleanup; 96246d4c572STomoki Sekiyama } 96346d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI; 96446d4c572STomoki Sekiyama disk->unit = tgt[1]; 96546d4c572STomoki Sekiyama } else if (strcmp(driver, "virtio-pci") == 0) { 96646d4c572STomoki Sekiyama if (has_tgt) { 96746d4c572STomoki Sekiyama /* virtio-scsi: target*:0:0:<unit> */ 96846d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI; 96946d4c572STomoki Sekiyama disk->unit = tgt[2]; 97046d4c572STomoki Sekiyama } else { 97146d4c572STomoki Sekiyama /* virtio-blk: 1 disk per 1 device */ 97246d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_VIRTIO; 97346d4c572STomoki Sekiyama } 97446d4c572STomoki Sekiyama } else if (strcmp(driver, "ahci") == 0) { 97546d4c572STomoki Sekiyama /* ahci: 1 host per 1 unit */ 97646d4c572STomoki Sekiyama if (!has_host || !has_tgt) { 97746d4c572STomoki Sekiyama g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver); 97846d4c572STomoki Sekiyama goto cleanup; 97946d4c572STomoki Sekiyama } 98046d4c572STomoki Sekiyama for (i = 0; i < nhosts; i++) { 98146d4c572STomoki Sekiyama if (host == hosts[i]) { 98246d4c572STomoki Sekiyama disk->unit = i; 98346d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_SATA; 98446d4c572STomoki Sekiyama break; 98546d4c572STomoki Sekiyama } 98646d4c572STomoki Sekiyama } 98746d4c572STomoki Sekiyama if (i >= nhosts) { 98846d4c572STomoki Sekiyama g_debug("no host for '%s' (driver '%s')", syspath, driver); 98946d4c572STomoki Sekiyama goto cleanup; 99046d4c572STomoki Sekiyama } 991d48f61c8Szhenwei pi } else if (strcmp(driver, "nvme") == 0) { 992d48f61c8Szhenwei pi disk->bus_type = GUEST_DISK_BUS_TYPE_NVME; 99346d4c572STomoki Sekiyama } else { 99446d4c572STomoki Sekiyama g_debug("unknown driver '%s' (sysfs path '%s')", driver, syspath); 99546d4c572STomoki Sekiyama goto cleanup; 99646d4c572STomoki Sekiyama } 99746d4c572STomoki Sekiyama 998d9fe4f0fSThomas Huth ret = true; 99946d4c572STomoki Sekiyama 100046d4c572STomoki Sekiyama cleanup: 100146d4c572STomoki Sekiyama g_free(driver); 1002d9fe4f0fSThomas Huth return ret; 1003d9fe4f0fSThomas Huth } 1004d9fe4f0fSThomas Huth 100523843c12SThomas Huth /* 100623843c12SThomas Huth * Store disk device info for non-PCI virtio devices (for example s390x 100723843c12SThomas Huth * channel I/O devices). Returns true if information has been stored, or 100823843c12SThomas Huth * false for failure. 100923843c12SThomas Huth */ 101023843c12SThomas Huth static bool build_guest_fsinfo_for_nonpci_virtio(char const *syspath, 101123843c12SThomas Huth GuestDiskAddress *disk, 101223843c12SThomas Huth Error **errp) 101323843c12SThomas Huth { 101423843c12SThomas Huth unsigned int tgt[3]; 101523843c12SThomas Huth char *p; 101623843c12SThomas Huth 101723843c12SThomas Huth if (!strstr(syspath, "/virtio") || !strstr(syspath, "/block")) { 101823843c12SThomas Huth g_debug("Unsupported virtio device '%s'", syspath); 101923843c12SThomas Huth return false; 102023843c12SThomas Huth } 102123843c12SThomas Huth 102223843c12SThomas Huth p = strstr(syspath, "/target"); 102323843c12SThomas Huth if (p && sscanf(p + 7, "%*u:%*u:%*u/%*u:%u:%u:%u", 102423843c12SThomas Huth &tgt[0], &tgt[1], &tgt[2]) == 3) { 102523843c12SThomas Huth /* virtio-scsi: target*:0:<target>:<unit> */ 102623843c12SThomas Huth disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI; 102723843c12SThomas Huth disk->bus = tgt[0]; 102823843c12SThomas Huth disk->target = tgt[1]; 102923843c12SThomas Huth disk->unit = tgt[2]; 103023843c12SThomas Huth } else { 103123843c12SThomas Huth /* virtio-blk: 1 disk per 1 device */ 103223843c12SThomas Huth disk->bus_type = GUEST_DISK_BUS_TYPE_VIRTIO; 103323843c12SThomas Huth } 103423843c12SThomas Huth 103523843c12SThomas Huth return true; 103623843c12SThomas Huth } 103723843c12SThomas Huth 10385b723a5dSThomas Huth /* 10395b723a5dSThomas Huth * Store disk device info for CCW devices (s390x channel I/O devices). 10405b723a5dSThomas Huth * Returns true if information has been stored, or false for failure. 10415b723a5dSThomas Huth */ 10425b723a5dSThomas Huth static bool build_guest_fsinfo_for_ccw_dev(char const *syspath, 10435b723a5dSThomas Huth GuestDiskAddress *disk, 10445b723a5dSThomas Huth Error **errp) 10455b723a5dSThomas Huth { 10465b723a5dSThomas Huth unsigned int cssid, ssid, subchno, devno; 10475b723a5dSThomas Huth char *p; 10485b723a5dSThomas Huth 10495b723a5dSThomas Huth p = strstr(syspath, "/devices/css"); 10505b723a5dSThomas Huth if (!p || sscanf(p + 12, "%*x/%x.%x.%x/%*x.%*x.%x/", 10515b723a5dSThomas Huth &cssid, &ssid, &subchno, &devno) < 4) { 10525b723a5dSThomas Huth g_debug("could not parse ccw device sysfs path: %s", syspath); 10535b723a5dSThomas Huth return false; 10545b723a5dSThomas Huth } 10555b723a5dSThomas Huth 10565b723a5dSThomas Huth disk->has_ccw_address = true; 10575b723a5dSThomas Huth disk->ccw_address = g_new0(GuestCCWAddress, 1); 10585b723a5dSThomas Huth disk->ccw_address->cssid = cssid; 10595b723a5dSThomas Huth disk->ccw_address->ssid = ssid; 10605b723a5dSThomas Huth disk->ccw_address->subchno = subchno; 10615b723a5dSThomas Huth disk->ccw_address->devno = devno; 10625b723a5dSThomas Huth 10635b723a5dSThomas Huth if (strstr(p, "/virtio")) { 10645b723a5dSThomas Huth build_guest_fsinfo_for_nonpci_virtio(syspath, disk, errp); 10655b723a5dSThomas Huth } 10665b723a5dSThomas Huth 10675b723a5dSThomas Huth return true; 10685b723a5dSThomas Huth } 10695b723a5dSThomas Huth 1070d9fe4f0fSThomas Huth /* Store disk device info specified by @sysfs into @fs */ 1071d9fe4f0fSThomas Huth static void build_guest_fsinfo_for_real_device(char const *syspath, 1072d9fe4f0fSThomas Huth GuestFilesystemInfo *fs, 1073d9fe4f0fSThomas Huth Error **errp) 1074d9fe4f0fSThomas Huth { 1075d9fe4f0fSThomas Huth GuestDiskAddress *disk; 1076d9fe4f0fSThomas Huth GuestPCIAddress *pciaddr; 1077d9fe4f0fSThomas Huth bool has_hwinf; 107843dadc43SThomas Huth #ifdef CONFIG_LIBUDEV 107943dadc43SThomas Huth struct udev *udev = NULL; 108043dadc43SThomas Huth struct udev_device *udevice = NULL; 108143dadc43SThomas Huth #endif 1082d9fe4f0fSThomas Huth 1083d9fe4f0fSThomas Huth pciaddr = g_new0(GuestPCIAddress, 1); 108443dadc43SThomas Huth pciaddr->domain = -1; /* -1 means field is invalid */ 108543dadc43SThomas Huth pciaddr->bus = -1; 108643dadc43SThomas Huth pciaddr->slot = -1; 108743dadc43SThomas Huth pciaddr->function = -1; 1088d9fe4f0fSThomas Huth 1089d9fe4f0fSThomas Huth disk = g_new0(GuestDiskAddress, 1); 1090d9fe4f0fSThomas Huth disk->pci_controller = pciaddr; 109143dadc43SThomas Huth disk->bus_type = GUEST_DISK_BUS_TYPE_UNKNOWN; 1092d9fe4f0fSThomas Huth 109343dadc43SThomas Huth #ifdef CONFIG_LIBUDEV 109443dadc43SThomas Huth udev = udev_new(); 109543dadc43SThomas Huth udevice = udev_device_new_from_syspath(udev, syspath); 109643dadc43SThomas Huth if (udev == NULL || udevice == NULL) { 109743dadc43SThomas Huth g_debug("failed to query udev"); 109843dadc43SThomas Huth } else { 109943dadc43SThomas Huth const char *devnode, *serial; 110043dadc43SThomas Huth devnode = udev_device_get_devnode(udevice); 110143dadc43SThomas Huth if (devnode != NULL) { 110243dadc43SThomas Huth disk->dev = g_strdup(devnode); 110343dadc43SThomas Huth disk->has_dev = true; 110443dadc43SThomas Huth } 110543dadc43SThomas Huth serial = udev_device_get_property_value(udevice, "ID_SERIAL"); 110643dadc43SThomas Huth if (serial != NULL && *serial != 0) { 110743dadc43SThomas Huth disk->serial = g_strdup(serial); 110843dadc43SThomas Huth disk->has_serial = true; 110943dadc43SThomas Huth } 111043dadc43SThomas Huth } 111143dadc43SThomas Huth 111243dadc43SThomas Huth udev_unref(udev); 111343dadc43SThomas Huth udev_device_unref(udevice); 111443dadc43SThomas Huth #endif 111543dadc43SThomas Huth 111623843c12SThomas Huth if (strstr(syspath, "/devices/pci")) { 1117d9fe4f0fSThomas Huth has_hwinf = build_guest_fsinfo_for_pci_dev(syspath, disk, errp); 11185b723a5dSThomas Huth } else if (strstr(syspath, "/devices/css")) { 11195b723a5dSThomas Huth has_hwinf = build_guest_fsinfo_for_ccw_dev(syspath, disk, errp); 112023843c12SThomas Huth } else if (strstr(syspath, "/virtio")) { 112123843c12SThomas Huth has_hwinf = build_guest_fsinfo_for_nonpci_virtio(syspath, disk, errp); 112223843c12SThomas Huth } else { 112323843c12SThomas Huth g_debug("Unsupported device type for '%s'", syspath); 112423843c12SThomas Huth has_hwinf = false; 112523843c12SThomas Huth } 1126d9fe4f0fSThomas Huth 112743dadc43SThomas Huth if (has_hwinf || disk->has_dev || disk->has_serial) { 112854aa3de7SEric Blake QAPI_LIST_PREPEND(fs->disk, disk); 1129d9fe4f0fSThomas Huth } else { 113054aa3de7SEric Blake qapi_free_GuestDiskAddress(disk); 1131d9fe4f0fSThomas Huth } 113246d4c572STomoki Sekiyama } 113346d4c572STomoki Sekiyama 113446d4c572STomoki Sekiyama static void build_guest_fsinfo_for_device(char const *devpath, 113546d4c572STomoki Sekiyama GuestFilesystemInfo *fs, 113646d4c572STomoki Sekiyama Error **errp); 113746d4c572STomoki Sekiyama 113846d4c572STomoki Sekiyama /* Store a list of slave devices of virtual volume specified by @syspath into 113946d4c572STomoki Sekiyama * @fs */ 114046d4c572STomoki Sekiyama static void build_guest_fsinfo_for_virtual_device(char const *syspath, 114146d4c572STomoki Sekiyama GuestFilesystemInfo *fs, 114246d4c572STomoki Sekiyama Error **errp) 114346d4c572STomoki Sekiyama { 1144292743d9SMarkus Armbruster Error *err = NULL; 114546d4c572STomoki Sekiyama DIR *dir; 114646d4c572STomoki Sekiyama char *dirpath; 1147e668d1b8Szhanghailiang struct dirent *entry; 114846d4c572STomoki Sekiyama 114946d4c572STomoki Sekiyama dirpath = g_strdup_printf("%s/slaves", syspath); 115046d4c572STomoki Sekiyama dir = opendir(dirpath); 115146d4c572STomoki Sekiyama if (!dir) { 11528251a72fSMichael Roth if (errno != ENOENT) { 115346d4c572STomoki Sekiyama error_setg_errno(errp, errno, "opendir(\"%s\")", dirpath); 11548251a72fSMichael Roth } 115546d4c572STomoki Sekiyama g_free(dirpath); 115646d4c572STomoki Sekiyama return; 115746d4c572STomoki Sekiyama } 115846d4c572STomoki Sekiyama 115946d4c572STomoki Sekiyama for (;;) { 1160e668d1b8Szhanghailiang errno = 0; 1161e668d1b8Szhanghailiang entry = readdir(dir); 1162e668d1b8Szhanghailiang if (entry == NULL) { 1163e668d1b8Szhanghailiang if (errno) { 1164e668d1b8Szhanghailiang error_setg_errno(errp, errno, "readdir(\"%s\")", dirpath); 116546d4c572STomoki Sekiyama } 116646d4c572STomoki Sekiyama break; 116746d4c572STomoki Sekiyama } 116846d4c572STomoki Sekiyama 1169e668d1b8Szhanghailiang if (entry->d_type == DT_LNK) { 1170e668d1b8Szhanghailiang char *path; 1171e668d1b8Szhanghailiang 1172e668d1b8Szhanghailiang g_debug(" slave device '%s'", entry->d_name); 1173e668d1b8Szhanghailiang path = g_strdup_printf("%s/slaves/%s", syspath, entry->d_name); 1174292743d9SMarkus Armbruster build_guest_fsinfo_for_device(path, fs, &err); 1175e668d1b8Szhanghailiang g_free(path); 117646d4c572STomoki Sekiyama 1177292743d9SMarkus Armbruster if (err) { 1178292743d9SMarkus Armbruster error_propagate(errp, err); 117946d4c572STomoki Sekiyama break; 118046d4c572STomoki Sekiyama } 118146d4c572STomoki Sekiyama } 118246d4c572STomoki Sekiyama } 118346d4c572STomoki Sekiyama 1184e668d1b8Szhanghailiang g_free(dirpath); 118546d4c572STomoki Sekiyama closedir(dir); 118646d4c572STomoki Sekiyama } 118746d4c572STomoki Sekiyama 1188fed39564STomáš Golembiovský static bool is_disk_virtual(const char *devpath, Error **errp) 1189fed39564STomáš Golembiovský { 1190fed39564STomáš Golembiovský g_autofree char *syspath = realpath(devpath, NULL); 1191fed39564STomáš Golembiovský 1192fed39564STomáš Golembiovský if (!syspath) { 1193fed39564STomáš Golembiovský error_setg_errno(errp, errno, "realpath(\"%s\")", devpath); 1194fed39564STomáš Golembiovský return false; 1195fed39564STomáš Golembiovský } 1196fed39564STomáš Golembiovský return strstr(syspath, "/devices/virtual/block/") != NULL; 1197fed39564STomáš Golembiovský } 1198fed39564STomáš Golembiovský 119946d4c572STomoki Sekiyama /* Dispatch to functions for virtual/real device */ 120046d4c572STomoki Sekiyama static void build_guest_fsinfo_for_device(char const *devpath, 120146d4c572STomoki Sekiyama GuestFilesystemInfo *fs, 120246d4c572STomoki Sekiyama Error **errp) 120346d4c572STomoki Sekiyama { 1204fed39564STomáš Golembiovský ERRP_GUARD(); 1205fed39564STomáš Golembiovský g_autofree char *syspath = NULL; 1206fed39564STomáš Golembiovský bool is_virtual = false; 120746d4c572STomoki Sekiyama 1208fed39564STomáš Golembiovský syspath = realpath(devpath, NULL); 120946d4c572STomoki Sekiyama if (!syspath) { 1210bbb0151cSJohn Snow if (errno != ENOENT) { 121146d4c572STomoki Sekiyama error_setg_errno(errp, errno, "realpath(\"%s\")", devpath); 121246d4c572STomoki Sekiyama return; 121346d4c572STomoki Sekiyama } 121446d4c572STomoki Sekiyama 1215bbb0151cSJohn Snow /* ENOENT: This devpath may not exist because of container config */ 1216bbb0151cSJohn Snow if (!fs->name) { 1217bbb0151cSJohn Snow fs->name = g_path_get_basename(devpath); 1218bbb0151cSJohn Snow } 1219bbb0151cSJohn Snow return; 1220bbb0151cSJohn Snow } 1221bbb0151cSJohn Snow 122246d4c572STomoki Sekiyama if (!fs->name) { 12233e015d81SJulia Suvorova fs->name = g_path_get_basename(syspath); 122446d4c572STomoki Sekiyama } 122546d4c572STomoki Sekiyama 122646d4c572STomoki Sekiyama g_debug(" parse sysfs path '%s'", syspath); 1227fed39564STomáš Golembiovský is_virtual = is_disk_virtual(syspath, errp); 1228fed39564STomáš Golembiovský if (*errp != NULL) { 1229fed39564STomáš Golembiovský return; 1230fed39564STomáš Golembiovský } 1231fed39564STomáš Golembiovský if (is_virtual) { 123246d4c572STomoki Sekiyama build_guest_fsinfo_for_virtual_device(syspath, fs, errp); 123346d4c572STomoki Sekiyama } else { 123446d4c572STomoki Sekiyama build_guest_fsinfo_for_real_device(syspath, fs, errp); 123546d4c572STomoki Sekiyama } 123646d4c572STomoki Sekiyama } 123746d4c572STomoki Sekiyama 1238fed39564STomáš Golembiovský #ifdef CONFIG_LIBUDEV 1239fed39564STomáš Golembiovský 1240fed39564STomáš Golembiovský /* 1241fed39564STomáš Golembiovský * Wrapper around build_guest_fsinfo_for_device() for getting just 1242fed39564STomáš Golembiovský * the disk address. 1243fed39564STomáš Golembiovský */ 1244fed39564STomáš Golembiovský static GuestDiskAddress *get_disk_address(const char *syspath, Error **errp) 1245fed39564STomáš Golembiovský { 1246fed39564STomáš Golembiovský g_autoptr(GuestFilesystemInfo) fs = NULL; 1247fed39564STomáš Golembiovský 1248fed39564STomáš Golembiovský fs = g_new0(GuestFilesystemInfo, 1); 1249fed39564STomáš Golembiovský build_guest_fsinfo_for_device(syspath, fs, errp); 1250fed39564STomáš Golembiovský if (fs->disk != NULL) { 1251fed39564STomáš Golembiovský return g_steal_pointer(&fs->disk->value); 1252fed39564STomáš Golembiovský } 1253fed39564STomáš Golembiovský return NULL; 1254fed39564STomáš Golembiovský } 1255fed39564STomáš Golembiovský 1256fed39564STomáš Golembiovský static char *get_alias_for_syspath(const char *syspath) 1257fed39564STomáš Golembiovský { 1258fed39564STomáš Golembiovský struct udev *udev = NULL; 1259fed39564STomáš Golembiovský struct udev_device *udevice = NULL; 1260fed39564STomáš Golembiovský char *ret = NULL; 1261fed39564STomáš Golembiovský 1262fed39564STomáš Golembiovský udev = udev_new(); 1263fed39564STomáš Golembiovský if (udev == NULL) { 1264fed39564STomáš Golembiovský g_debug("failed to query udev"); 1265fed39564STomáš Golembiovský goto out; 1266fed39564STomáš Golembiovský } 1267fed39564STomáš Golembiovský udevice = udev_device_new_from_syspath(udev, syspath); 1268fed39564STomáš Golembiovský if (udevice == NULL) { 1269fed39564STomáš Golembiovský g_debug("failed to query udev for path: %s", syspath); 1270fed39564STomáš Golembiovský goto out; 1271fed39564STomáš Golembiovský } else { 1272fed39564STomáš Golembiovský const char *alias = udev_device_get_property_value( 1273fed39564STomáš Golembiovský udevice, "DM_NAME"); 1274fed39564STomáš Golembiovský /* 1275fed39564STomáš Golembiovský * NULL means there was an error and empty string means there is no 1276fed39564STomáš Golembiovský * alias. In case of no alias we return NULL instead of empty string. 1277fed39564STomáš Golembiovský */ 1278fed39564STomáš Golembiovský if (alias == NULL) { 1279fed39564STomáš Golembiovský g_debug("failed to query udev for device alias for: %s", 1280fed39564STomáš Golembiovský syspath); 1281fed39564STomáš Golembiovský } else if (*alias != 0) { 1282fed39564STomáš Golembiovský ret = g_strdup(alias); 1283fed39564STomáš Golembiovský } 1284fed39564STomáš Golembiovský } 1285fed39564STomáš Golembiovský 1286fed39564STomáš Golembiovský out: 1287fed39564STomáš Golembiovský udev_unref(udev); 1288fed39564STomáš Golembiovský udev_device_unref(udevice); 1289fed39564STomáš Golembiovský return ret; 1290fed39564STomáš Golembiovský } 1291fed39564STomáš Golembiovský 1292fed39564STomáš Golembiovský static char *get_device_for_syspath(const char *syspath) 1293fed39564STomáš Golembiovský { 1294fed39564STomáš Golembiovský struct udev *udev = NULL; 1295fed39564STomáš Golembiovský struct udev_device *udevice = NULL; 1296fed39564STomáš Golembiovský char *ret = NULL; 1297fed39564STomáš Golembiovský 1298fed39564STomáš Golembiovský udev = udev_new(); 1299fed39564STomáš Golembiovský if (udev == NULL) { 1300fed39564STomáš Golembiovský g_debug("failed to query udev"); 1301fed39564STomáš Golembiovský goto out; 1302fed39564STomáš Golembiovský } 1303fed39564STomáš Golembiovský udevice = udev_device_new_from_syspath(udev, syspath); 1304fed39564STomáš Golembiovský if (udevice == NULL) { 1305fed39564STomáš Golembiovský g_debug("failed to query udev for path: %s", syspath); 1306fed39564STomáš Golembiovský goto out; 1307fed39564STomáš Golembiovský } else { 1308fed39564STomáš Golembiovský ret = g_strdup(udev_device_get_devnode(udevice)); 1309fed39564STomáš Golembiovský } 1310fed39564STomáš Golembiovský 1311fed39564STomáš Golembiovský out: 1312fed39564STomáš Golembiovský udev_unref(udev); 1313fed39564STomáš Golembiovský udev_device_unref(udevice); 1314fed39564STomáš Golembiovský return ret; 1315fed39564STomáš Golembiovský } 1316fed39564STomáš Golembiovský 1317fed39564STomáš Golembiovský static void get_disk_deps(const char *disk_dir, GuestDiskInfo *disk) 1318fed39564STomáš Golembiovský { 1319fed39564STomáš Golembiovský g_autofree char *deps_dir = NULL; 1320fed39564STomáš Golembiovský const gchar *dep; 1321fed39564STomáš Golembiovský GDir *dp_deps = NULL; 1322fed39564STomáš Golembiovský 1323fed39564STomáš Golembiovský /* List dependent disks */ 1324fed39564STomáš Golembiovský deps_dir = g_strdup_printf("%s/slaves", disk_dir); 1325fed39564STomáš Golembiovský g_debug(" listing entries in: %s", deps_dir); 1326fed39564STomáš Golembiovský dp_deps = g_dir_open(deps_dir, 0, NULL); 1327fed39564STomáš Golembiovský if (dp_deps == NULL) { 1328fed39564STomáš Golembiovský g_debug("failed to list entries in %s", deps_dir); 1329fed39564STomáš Golembiovský return; 1330fed39564STomáš Golembiovský } 1331a8aa94b5SMichael Roth disk->has_dependencies = true; 1332fed39564STomáš Golembiovský while ((dep = g_dir_read_name(dp_deps)) != NULL) { 1333fed39564STomáš Golembiovský g_autofree char *dep_dir = NULL; 1334fed39564STomáš Golembiovský char *dev_name; 1335fed39564STomáš Golembiovský 1336fed39564STomáš Golembiovský /* Add dependent disks */ 1337fed39564STomáš Golembiovský dep_dir = g_strdup_printf("%s/%s", deps_dir, dep); 1338fed39564STomáš Golembiovský dev_name = get_device_for_syspath(dep_dir); 1339fed39564STomáš Golembiovský if (dev_name != NULL) { 1340fed39564STomáš Golembiovský g_debug(" adding dependent device: %s", dev_name); 134154aa3de7SEric Blake QAPI_LIST_PREPEND(disk->dependencies, dev_name); 1342fed39564STomáš Golembiovský } 1343fed39564STomáš Golembiovský } 1344fed39564STomáš Golembiovský g_dir_close(dp_deps); 1345fed39564STomáš Golembiovský } 1346fed39564STomáš Golembiovský 1347fed39564STomáš Golembiovský /* 1348fed39564STomáš Golembiovský * Detect partitions subdirectory, name is "<disk_name><number>" or 1349fed39564STomáš Golembiovský * "<disk_name>p<number>" 1350fed39564STomáš Golembiovský * 1351fed39564STomáš Golembiovský * @disk_name -- last component of /sys path (e.g. sda) 1352fed39564STomáš Golembiovský * @disk_dir -- sys path of the disk (e.g. /sys/block/sda) 1353fed39564STomáš Golembiovský * @disk_dev -- device node of the disk (e.g. /dev/sda) 1354fed39564STomáš Golembiovský */ 1355fed39564STomáš Golembiovský static GuestDiskInfoList *get_disk_partitions( 1356fed39564STomáš Golembiovský GuestDiskInfoList *list, 1357fed39564STomáš Golembiovský const char *disk_name, const char *disk_dir, 1358fed39564STomáš Golembiovský const char *disk_dev) 1359fed39564STomáš Golembiovský { 136054aa3de7SEric Blake GuestDiskInfoList *ret = list; 1361fed39564STomáš Golembiovský struct dirent *de_disk; 1362fed39564STomáš Golembiovský DIR *dp_disk = NULL; 1363fed39564STomáš Golembiovský size_t len = strlen(disk_name); 1364fed39564STomáš Golembiovský 1365fed39564STomáš Golembiovský dp_disk = opendir(disk_dir); 1366fed39564STomáš Golembiovský while ((de_disk = readdir(dp_disk)) != NULL) { 1367fed39564STomáš Golembiovský g_autofree char *partition_dir = NULL; 1368fed39564STomáš Golembiovský char *dev_name; 1369fed39564STomáš Golembiovský GuestDiskInfo *partition; 1370fed39564STomáš Golembiovský 1371fed39564STomáš Golembiovský if (!(de_disk->d_type & DT_DIR)) { 1372fed39564STomáš Golembiovský continue; 1373fed39564STomáš Golembiovský } 1374fed39564STomáš Golembiovský 1375fed39564STomáš Golembiovský if (!(strncmp(disk_name, de_disk->d_name, len) == 0 && 1376fed39564STomáš Golembiovský ((*(de_disk->d_name + len) == 'p' && 1377fed39564STomáš Golembiovský isdigit(*(de_disk->d_name + len + 1))) || 1378fed39564STomáš Golembiovský isdigit(*(de_disk->d_name + len))))) { 1379fed39564STomáš Golembiovský continue; 1380fed39564STomáš Golembiovský } 1381fed39564STomáš Golembiovský 1382fed39564STomáš Golembiovský partition_dir = g_strdup_printf("%s/%s", 1383fed39564STomáš Golembiovský disk_dir, de_disk->d_name); 1384fed39564STomáš Golembiovský dev_name = get_device_for_syspath(partition_dir); 1385fed39564STomáš Golembiovský if (dev_name == NULL) { 1386fed39564STomáš Golembiovský g_debug("Failed to get device name for syspath: %s", 1387fed39564STomáš Golembiovský disk_dir); 1388fed39564STomáš Golembiovský continue; 1389fed39564STomáš Golembiovský } 1390fed39564STomáš Golembiovský partition = g_new0(GuestDiskInfo, 1); 1391fed39564STomáš Golembiovský partition->name = dev_name; 1392fed39564STomáš Golembiovský partition->partition = true; 1393bac9b87bSMarc-André Lureau partition->has_dependencies = true; 1394fed39564STomáš Golembiovský /* Add parent disk as dependent for easier tracking of hierarchy */ 139554aa3de7SEric Blake QAPI_LIST_PREPEND(partition->dependencies, g_strdup(disk_dev)); 1396fed39564STomáš Golembiovský 139754aa3de7SEric Blake QAPI_LIST_PREPEND(ret, partition); 1398fed39564STomáš Golembiovský } 1399fed39564STomáš Golembiovský closedir(dp_disk); 1400fed39564STomáš Golembiovský 1401fed39564STomáš Golembiovský return ret; 1402fed39564STomáš Golembiovský } 1403fed39564STomáš Golembiovský 140422668881Szhenwei pi static void get_nvme_smart(GuestDiskInfo *disk) 140522668881Szhenwei pi { 140622668881Szhenwei pi int fd; 140722668881Szhenwei pi GuestNVMeSmart *smart; 140822668881Szhenwei pi NvmeSmartLog log = {0}; 140922668881Szhenwei pi struct nvme_admin_cmd cmd = { 141022668881Szhenwei pi .opcode = NVME_ADM_CMD_GET_LOG_PAGE, 141122668881Szhenwei pi .nsid = NVME_NSID_BROADCAST, 141222668881Szhenwei pi .addr = (uintptr_t)&log, 141322668881Szhenwei pi .data_len = sizeof(log), 141422668881Szhenwei pi .cdw10 = NVME_LOG_SMART_INFO | (1 << 15) /* RAE bit */ 141522668881Szhenwei pi | (((sizeof(log) >> 2) - 1) << 16) 141622668881Szhenwei pi }; 141722668881Szhenwei pi 1418b9947c9cSMarc-André Lureau fd = qga_open_cloexec(disk->name, O_RDONLY, 0); 141922668881Szhenwei pi if (fd == -1) { 142022668881Szhenwei pi g_debug("Failed to open device: %s: %s", disk->name, g_strerror(errno)); 142122668881Szhenwei pi return; 142222668881Szhenwei pi } 142322668881Szhenwei pi 142422668881Szhenwei pi if (ioctl(fd, NVME_IOCTL_ADMIN_CMD, &cmd)) { 142522668881Szhenwei pi g_debug("Failed to get smart: %s: %s", disk->name, g_strerror(errno)); 142622668881Szhenwei pi close(fd); 142722668881Szhenwei pi return; 142822668881Szhenwei pi } 142922668881Szhenwei pi 143022668881Szhenwei pi disk->has_smart = true; 143122668881Szhenwei pi disk->smart = g_new0(GuestDiskSmart, 1); 143222668881Szhenwei pi disk->smart->type = GUEST_DISK_BUS_TYPE_NVME; 143322668881Szhenwei pi 143422668881Szhenwei pi smart = &disk->smart->u.nvme; 143522668881Szhenwei pi smart->critical_warning = log.critical_warning; 143622668881Szhenwei pi smart->temperature = lduw_le_p(&log.temperature); /* unaligned field */ 143722668881Szhenwei pi smart->available_spare = log.available_spare; 143822668881Szhenwei pi smart->available_spare_threshold = log.available_spare_threshold; 143922668881Szhenwei pi smart->percentage_used = log.percentage_used; 144022668881Szhenwei pi smart->data_units_read_lo = le64_to_cpu(log.data_units_read[0]); 144122668881Szhenwei pi smart->data_units_read_hi = le64_to_cpu(log.data_units_read[1]); 144222668881Szhenwei pi smart->data_units_written_lo = le64_to_cpu(log.data_units_written[0]); 144322668881Szhenwei pi smart->data_units_written_hi = le64_to_cpu(log.data_units_written[1]); 144422668881Szhenwei pi smart->host_read_commands_lo = le64_to_cpu(log.host_read_commands[0]); 144522668881Szhenwei pi smart->host_read_commands_hi = le64_to_cpu(log.host_read_commands[1]); 144622668881Szhenwei pi smart->host_write_commands_lo = le64_to_cpu(log.host_write_commands[0]); 144722668881Szhenwei pi smart->host_write_commands_hi = le64_to_cpu(log.host_write_commands[1]); 144822668881Szhenwei pi smart->controller_busy_time_lo = le64_to_cpu(log.controller_busy_time[0]); 144922668881Szhenwei pi smart->controller_busy_time_hi = le64_to_cpu(log.controller_busy_time[1]); 145022668881Szhenwei pi smart->power_cycles_lo = le64_to_cpu(log.power_cycles[0]); 145122668881Szhenwei pi smart->power_cycles_hi = le64_to_cpu(log.power_cycles[1]); 145222668881Szhenwei pi smart->power_on_hours_lo = le64_to_cpu(log.power_on_hours[0]); 145322668881Szhenwei pi smart->power_on_hours_hi = le64_to_cpu(log.power_on_hours[1]); 145422668881Szhenwei pi smart->unsafe_shutdowns_lo = le64_to_cpu(log.unsafe_shutdowns[0]); 145522668881Szhenwei pi smart->unsafe_shutdowns_hi = le64_to_cpu(log.unsafe_shutdowns[1]); 145622668881Szhenwei pi smart->media_errors_lo = le64_to_cpu(log.media_errors[0]); 145722668881Szhenwei pi smart->media_errors_hi = le64_to_cpu(log.media_errors[1]); 145822668881Szhenwei pi smart->number_of_error_log_entries_lo = 145922668881Szhenwei pi le64_to_cpu(log.number_of_error_log_entries[0]); 146022668881Szhenwei pi smart->number_of_error_log_entries_hi = 146122668881Szhenwei pi le64_to_cpu(log.number_of_error_log_entries[1]); 146222668881Szhenwei pi 146322668881Szhenwei pi close(fd); 146422668881Szhenwei pi } 146522668881Szhenwei pi 146622668881Szhenwei pi static void get_disk_smart(GuestDiskInfo *disk) 146722668881Szhenwei pi { 146822668881Szhenwei pi if (disk->has_address 146922668881Szhenwei pi && (disk->address->bus_type == GUEST_DISK_BUS_TYPE_NVME)) { 147022668881Szhenwei pi get_nvme_smart(disk); 147122668881Szhenwei pi } 147222668881Szhenwei pi } 147322668881Szhenwei pi 1474fed39564STomáš Golembiovský GuestDiskInfoList *qmp_guest_get_disks(Error **errp) 1475fed39564STomáš Golembiovský { 147654aa3de7SEric Blake GuestDiskInfoList *ret = NULL; 1477fed39564STomáš Golembiovský GuestDiskInfo *disk; 1478fed39564STomáš Golembiovský DIR *dp = NULL; 1479fed39564STomáš Golembiovský struct dirent *de = NULL; 1480fed39564STomáš Golembiovský 1481fed39564STomáš Golembiovský g_debug("listing /sys/block directory"); 1482fed39564STomáš Golembiovský dp = opendir("/sys/block"); 1483fed39564STomáš Golembiovský if (dp == NULL) { 1484fed39564STomáš Golembiovský error_setg_errno(errp, errno, "Can't open directory \"/sys/block\""); 1485fed39564STomáš Golembiovský return NULL; 1486fed39564STomáš Golembiovský } 1487fed39564STomáš Golembiovský while ((de = readdir(dp)) != NULL) { 1488fed39564STomáš Golembiovský g_autofree char *disk_dir = NULL, *line = NULL, 1489fed39564STomáš Golembiovský *size_path = NULL; 1490fed39564STomáš Golembiovský char *dev_name; 1491fed39564STomáš Golembiovský Error *local_err = NULL; 1492fed39564STomáš Golembiovský if (de->d_type != DT_LNK) { 1493fed39564STomáš Golembiovský g_debug(" skipping entry: %s", de->d_name); 1494fed39564STomáš Golembiovský continue; 1495fed39564STomáš Golembiovský } 1496fed39564STomáš Golembiovský 1497fed39564STomáš Golembiovský /* Check size and skip zero-sized disks */ 1498fed39564STomáš Golembiovský g_debug(" checking disk size"); 1499fed39564STomáš Golembiovský size_path = g_strdup_printf("/sys/block/%s/size", de->d_name); 1500fed39564STomáš Golembiovský if (!g_file_get_contents(size_path, &line, NULL, NULL)) { 1501fed39564STomáš Golembiovský g_debug(" failed to read disk size"); 1502fed39564STomáš Golembiovský continue; 1503fed39564STomáš Golembiovský } 1504fed39564STomáš Golembiovský if (g_strcmp0(line, "0\n") == 0) { 1505fed39564STomáš Golembiovský g_debug(" skipping zero-sized disk"); 1506fed39564STomáš Golembiovský continue; 1507fed39564STomáš Golembiovský } 1508fed39564STomáš Golembiovský 1509fed39564STomáš Golembiovský g_debug(" adding %s", de->d_name); 1510fed39564STomáš Golembiovský disk_dir = g_strdup_printf("/sys/block/%s", de->d_name); 1511fed39564STomáš Golembiovský dev_name = get_device_for_syspath(disk_dir); 1512fed39564STomáš Golembiovský if (dev_name == NULL) { 1513fed39564STomáš Golembiovský g_debug("Failed to get device name for syspath: %s", 1514fed39564STomáš Golembiovský disk_dir); 1515fed39564STomáš Golembiovský continue; 1516fed39564STomáš Golembiovský } 1517fed39564STomáš Golembiovský disk = g_new0(GuestDiskInfo, 1); 1518fed39564STomáš Golembiovský disk->name = dev_name; 1519fed39564STomáš Golembiovský disk->partition = false; 1520fed39564STomáš Golembiovský disk->alias = get_alias_for_syspath(disk_dir); 1521fed39564STomáš Golembiovský disk->has_alias = (disk->alias != NULL); 152254aa3de7SEric Blake QAPI_LIST_PREPEND(ret, disk); 1523fed39564STomáš Golembiovský 1524fed39564STomáš Golembiovský /* Get address for non-virtual devices */ 1525fed39564STomáš Golembiovský bool is_virtual = is_disk_virtual(disk_dir, &local_err); 1526fed39564STomáš Golembiovský if (local_err != NULL) { 1527fed39564STomáš Golembiovský g_debug(" failed to check disk path, ignoring error: %s", 1528fed39564STomáš Golembiovský error_get_pretty(local_err)); 1529fed39564STomáš Golembiovský error_free(local_err); 1530fed39564STomáš Golembiovský local_err = NULL; 1531fed39564STomáš Golembiovský /* Don't try to get the address */ 1532fed39564STomáš Golembiovský is_virtual = true; 1533fed39564STomáš Golembiovský } 1534fed39564STomáš Golembiovský if (!is_virtual) { 1535fed39564STomáš Golembiovský disk->address = get_disk_address(disk_dir, &local_err); 1536fed39564STomáš Golembiovský if (local_err != NULL) { 1537fed39564STomáš Golembiovský g_debug(" failed to get device info, ignoring error: %s", 1538fed39564STomáš Golembiovský error_get_pretty(local_err)); 1539fed39564STomáš Golembiovský error_free(local_err); 1540fed39564STomáš Golembiovský local_err = NULL; 1541fed39564STomáš Golembiovský } else if (disk->address != NULL) { 1542fed39564STomáš Golembiovský disk->has_address = true; 1543fed39564STomáš Golembiovský } 1544fed39564STomáš Golembiovský } 1545fed39564STomáš Golembiovský 1546fed39564STomáš Golembiovský get_disk_deps(disk_dir, disk); 154722668881Szhenwei pi get_disk_smart(disk); 1548fed39564STomáš Golembiovský ret = get_disk_partitions(ret, de->d_name, disk_dir, dev_name); 1549fed39564STomáš Golembiovský } 1550b1b9ab1cSMichael Roth 1551b1b9ab1cSMichael Roth closedir(dp); 1552b1b9ab1cSMichael Roth 1553fed39564STomáš Golembiovský return ret; 1554fed39564STomáš Golembiovský } 1555fed39564STomáš Golembiovský 1556fed39564STomáš Golembiovský #else 1557fed39564STomáš Golembiovský 1558fed39564STomáš Golembiovský GuestDiskInfoList *qmp_guest_get_disks(Error **errp) 1559fed39564STomáš Golembiovský { 1560fed39564STomáš Golembiovský error_setg(errp, QERR_UNSUPPORTED); 1561fed39564STomáš Golembiovský return NULL; 1562fed39564STomáš Golembiovský } 1563fed39564STomáš Golembiovský 1564fed39564STomáš Golembiovský #endif 1565fed39564STomáš Golembiovský 156646d4c572STomoki Sekiyama /* Return a list of the disk device(s)' info which @mount lies on */ 156746d4c572STomoki Sekiyama static GuestFilesystemInfo *build_guest_fsinfo(struct FsMount *mount, 156846d4c572STomoki Sekiyama Error **errp) 156946d4c572STomoki Sekiyama { 157046d4c572STomoki Sekiyama GuestFilesystemInfo *fs = g_malloc0(sizeof(*fs)); 157125b5ff1aSChen Hanxiao struct statvfs buf; 157225b5ff1aSChen Hanxiao unsigned long used, nonroot_total, fr_size; 157346d4c572STomoki Sekiyama char *devpath = g_strdup_printf("/sys/dev/block/%u:%u", 157446d4c572STomoki Sekiyama mount->devmajor, mount->devminor); 157546d4c572STomoki Sekiyama 157646d4c572STomoki Sekiyama fs->mountpoint = g_strdup(mount->dirname); 157746d4c572STomoki Sekiyama fs->type = g_strdup(mount->devtype); 157846d4c572STomoki Sekiyama build_guest_fsinfo_for_device(devpath, fs, errp); 157946d4c572STomoki Sekiyama 158025b5ff1aSChen Hanxiao if (statvfs(fs->mountpoint, &buf) == 0) { 158125b5ff1aSChen Hanxiao fr_size = buf.f_frsize; 158225b5ff1aSChen Hanxiao used = buf.f_blocks - buf.f_bfree; 158325b5ff1aSChen Hanxiao nonroot_total = used + buf.f_bavail; 158425b5ff1aSChen Hanxiao fs->used_bytes = used * fr_size; 158525b5ff1aSChen Hanxiao fs->total_bytes = nonroot_total * fr_size; 158625b5ff1aSChen Hanxiao 158725b5ff1aSChen Hanxiao fs->has_total_bytes = true; 158825b5ff1aSChen Hanxiao fs->has_used_bytes = true; 158925b5ff1aSChen Hanxiao } 159025b5ff1aSChen Hanxiao 159146d4c572STomoki Sekiyama g_free(devpath); 159225b5ff1aSChen Hanxiao 159346d4c572STomoki Sekiyama return fs; 159446d4c572STomoki Sekiyama } 159546d4c572STomoki Sekiyama 159646d4c572STomoki Sekiyama GuestFilesystemInfoList *qmp_guest_get_fsinfo(Error **errp) 159746d4c572STomoki Sekiyama { 159846d4c572STomoki Sekiyama FsMountList mounts; 159946d4c572STomoki Sekiyama struct FsMount *mount; 160054aa3de7SEric Blake GuestFilesystemInfoList *ret = NULL; 160146d4c572STomoki Sekiyama Error *local_err = NULL; 160246d4c572STomoki Sekiyama 160346d4c572STomoki Sekiyama QTAILQ_INIT(&mounts); 1604561bfcb6SMarc-André Lureau if (!build_fs_mount_list(&mounts, &local_err)) { 160546d4c572STomoki Sekiyama error_propagate(errp, local_err); 160646d4c572STomoki Sekiyama return NULL; 160746d4c572STomoki Sekiyama } 160846d4c572STomoki Sekiyama 160946d4c572STomoki Sekiyama QTAILQ_FOREACH(mount, &mounts, next) { 161046d4c572STomoki Sekiyama g_debug("Building guest fsinfo for '%s'", mount->dirname); 161146d4c572STomoki Sekiyama 161254aa3de7SEric Blake QAPI_LIST_PREPEND(ret, build_guest_fsinfo(mount, &local_err)); 161346d4c572STomoki Sekiyama if (local_err) { 161446d4c572STomoki Sekiyama error_propagate(errp, local_err); 161546d4c572STomoki Sekiyama qapi_free_GuestFilesystemInfoList(ret); 161646d4c572STomoki Sekiyama ret = NULL; 161746d4c572STomoki Sekiyama break; 161846d4c572STomoki Sekiyama } 161946d4c572STomoki Sekiyama } 162046d4c572STomoki Sekiyama 162146d4c572STomoki Sekiyama free_fs_mount_list(&mounts); 162246d4c572STomoki Sekiyama return ret; 162346d4c572STomoki Sekiyama } 162446d4c572STomoki Sekiyama 162546d4c572STomoki Sekiyama 1626ec0f694cSTomoki Sekiyama typedef enum { 1627ec0f694cSTomoki Sekiyama FSFREEZE_HOOK_THAW = 0, 1628ec0f694cSTomoki Sekiyama FSFREEZE_HOOK_FREEZE, 1629ec0f694cSTomoki Sekiyama } FsfreezeHookArg; 1630ec0f694cSTomoki Sekiyama 163113a439ecSStefan Weil static const char *fsfreeze_hook_arg_string[] = { 1632ec0f694cSTomoki Sekiyama "thaw", 1633ec0f694cSTomoki Sekiyama "freeze", 1634ec0f694cSTomoki Sekiyama }; 1635ec0f694cSTomoki Sekiyama 163677dbc81bSMarkus Armbruster static void execute_fsfreeze_hook(FsfreezeHookArg arg, Error **errp) 1637ec0f694cSTomoki Sekiyama { 1638ec0f694cSTomoki Sekiyama int status; 1639ec0f694cSTomoki Sekiyama pid_t pid; 1640ec0f694cSTomoki Sekiyama const char *hook; 1641ec0f694cSTomoki Sekiyama const char *arg_str = fsfreeze_hook_arg_string[arg]; 1642ec0f694cSTomoki Sekiyama Error *local_err = NULL; 1643ec0f694cSTomoki Sekiyama 1644ec0f694cSTomoki Sekiyama hook = ga_fsfreeze_hook(ga_state); 1645ec0f694cSTomoki Sekiyama if (!hook) { 1646ec0f694cSTomoki Sekiyama return; 1647ec0f694cSTomoki Sekiyama } 1648ec0f694cSTomoki Sekiyama if (access(hook, X_OK) != 0) { 164977dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "can't access fsfreeze hook '%s'", hook); 1650ec0f694cSTomoki Sekiyama return; 1651ec0f694cSTomoki Sekiyama } 1652ec0f694cSTomoki Sekiyama 1653ec0f694cSTomoki Sekiyama slog("executing fsfreeze hook with arg '%s'", arg_str); 1654ec0f694cSTomoki Sekiyama pid = fork(); 1655ec0f694cSTomoki Sekiyama if (pid == 0) { 1656ec0f694cSTomoki Sekiyama setsid(); 1657ec0f694cSTomoki Sekiyama reopen_fd_to_null(0); 1658ec0f694cSTomoki Sekiyama reopen_fd_to_null(1); 1659ec0f694cSTomoki Sekiyama reopen_fd_to_null(2); 1660ec0f694cSTomoki Sekiyama 1661fcc41961SMarc-André Lureau execl(hook, hook, arg_str, NULL); 1662ec0f694cSTomoki Sekiyama _exit(EXIT_FAILURE); 1663ec0f694cSTomoki Sekiyama } else if (pid < 0) { 166477dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to create child process"); 1665ec0f694cSTomoki Sekiyama return; 1666ec0f694cSTomoki Sekiyama } 1667ec0f694cSTomoki Sekiyama 1668ec0f694cSTomoki Sekiyama ga_wait_child(pid, &status, &local_err); 166984d18f06SMarkus Armbruster if (local_err) { 167077dbc81bSMarkus Armbruster error_propagate(errp, local_err); 1671ec0f694cSTomoki Sekiyama return; 1672ec0f694cSTomoki Sekiyama } 1673ec0f694cSTomoki Sekiyama 1674ec0f694cSTomoki Sekiyama if (!WIFEXITED(status)) { 167577dbc81bSMarkus Armbruster error_setg(errp, "fsfreeze hook has terminated abnormally"); 1676ec0f694cSTomoki Sekiyama return; 1677ec0f694cSTomoki Sekiyama } 1678ec0f694cSTomoki Sekiyama 1679ec0f694cSTomoki Sekiyama status = WEXITSTATUS(status); 1680ec0f694cSTomoki Sekiyama if (status) { 168177dbc81bSMarkus Armbruster error_setg(errp, "fsfreeze hook has failed with status %d", status); 1682ec0f694cSTomoki Sekiyama return; 1683ec0f694cSTomoki Sekiyama } 1684ec0f694cSTomoki Sekiyama } 1685ec0f694cSTomoki Sekiyama 1686c216e5adSMichael Roth /* 1687c216e5adSMichael Roth * Return status of freeze/thaw 1688c216e5adSMichael Roth */ 168977dbc81bSMarkus Armbruster GuestFsfreezeStatus qmp_guest_fsfreeze_status(Error **errp) 1690c216e5adSMichael Roth { 1691f22d85e9SMichael Roth if (ga_is_frozen(ga_state)) { 1692f22d85e9SMichael Roth return GUEST_FSFREEZE_STATUS_FROZEN; 1693f22d85e9SMichael Roth } 1694f22d85e9SMichael Roth 1695f22d85e9SMichael Roth return GUEST_FSFREEZE_STATUS_THAWED; 1696c216e5adSMichael Roth } 1697c216e5adSMichael Roth 1698e99bce20STomoki Sekiyama int64_t qmp_guest_fsfreeze_freeze(Error **errp) 1699e99bce20STomoki Sekiyama { 1700e99bce20STomoki Sekiyama return qmp_guest_fsfreeze_freeze_list(false, NULL, errp); 1701e99bce20STomoki Sekiyama } 1702e99bce20STomoki Sekiyama 1703c216e5adSMichael Roth /* 1704c216e5adSMichael Roth * Walk list of mounted file systems in the guest, and freeze the ones which 1705c216e5adSMichael Roth * are real local file systems. 1706c216e5adSMichael Roth */ 1707e99bce20STomoki Sekiyama int64_t qmp_guest_fsfreeze_freeze_list(bool has_mountpoints, 1708e99bce20STomoki Sekiyama strList *mountpoints, 1709e99bce20STomoki Sekiyama Error **errp) 1710c216e5adSMichael Roth { 1711c216e5adSMichael Roth int ret = 0, i = 0; 1712e99bce20STomoki Sekiyama strList *list; 1713af02203fSPaolo Bonzini FsMountList mounts; 1714af02203fSPaolo Bonzini struct FsMount *mount; 1715261551d1SLuiz Capitulino Error *local_err = NULL; 1716c216e5adSMichael Roth int fd; 1717c216e5adSMichael Roth 1718c216e5adSMichael Roth slog("guest-fsfreeze called"); 1719c216e5adSMichael Roth 1720ec0f694cSTomoki Sekiyama execute_fsfreeze_hook(FSFREEZE_HOOK_FREEZE, &local_err); 172184d18f06SMarkus Armbruster if (local_err) { 172277dbc81bSMarkus Armbruster error_propagate(errp, local_err); 1723ec0f694cSTomoki Sekiyama return -1; 1724ec0f694cSTomoki Sekiyama } 1725ec0f694cSTomoki Sekiyama 17269e8aded4SMichael Roth QTAILQ_INIT(&mounts); 1727561bfcb6SMarc-André Lureau if (!build_fs_mount_list(&mounts, &local_err)) { 172877dbc81bSMarkus Armbruster error_propagate(errp, local_err); 1729261551d1SLuiz Capitulino return -1; 1730c216e5adSMichael Roth } 1731c216e5adSMichael Roth 1732c216e5adSMichael Roth /* cannot risk guest agent blocking itself on a write in this state */ 1733f22d85e9SMichael Roth ga_set_frozen(ga_state); 1734c216e5adSMichael Roth 1735eae3eb3eSPaolo Bonzini QTAILQ_FOREACH_REVERSE(mount, &mounts, next) { 1736e99bce20STomoki Sekiyama /* To issue fsfreeze in the reverse order of mounts, check if the 1737e99bce20STomoki Sekiyama * mount is listed in the list here */ 1738e99bce20STomoki Sekiyama if (has_mountpoints) { 1739e99bce20STomoki Sekiyama for (list = mountpoints; list; list = list->next) { 1740e99bce20STomoki Sekiyama if (strcmp(list->value, mount->dirname) == 0) { 1741e99bce20STomoki Sekiyama break; 1742e99bce20STomoki Sekiyama } 1743e99bce20STomoki Sekiyama } 1744e99bce20STomoki Sekiyama if (!list) { 1745e99bce20STomoki Sekiyama continue; 1746e99bce20STomoki Sekiyama } 1747e99bce20STomoki Sekiyama } 1748e99bce20STomoki Sekiyama 1749b9947c9cSMarc-André Lureau fd = qga_open_cloexec(mount->dirname, O_RDONLY, 0); 1750c216e5adSMichael Roth if (fd == -1) { 175177dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to open %s", mount->dirname); 1752c216e5adSMichael Roth goto error; 1753c216e5adSMichael Roth } 1754c216e5adSMichael Roth 1755e35916acSMichael Tokarev /* we try to cull filesystems we know won't work in advance, but other 1756e35916acSMichael Tokarev * filesystems may not implement fsfreeze for less obvious reasons. 17579e8aded4SMichael Roth * these will report EOPNOTSUPP. we simply ignore these when tallying 17589e8aded4SMichael Roth * the number of frozen filesystems. 1759ce2eb6c4SPeter Lieven * if a filesystem is mounted more than once (aka bind mount) a 1760ce2eb6c4SPeter Lieven * consecutive attempt to freeze an already frozen filesystem will 1761ce2eb6c4SPeter Lieven * return EBUSY. 17629e8aded4SMichael Roth * 17639e8aded4SMichael Roth * any other error means a failure to freeze a filesystem we 17649e8aded4SMichael Roth * expect to be freezable, so return an error in those cases 17659e8aded4SMichael Roth * and return system to thawed state. 1766c216e5adSMichael Roth */ 1767c216e5adSMichael Roth ret = ioctl(fd, FIFREEZE); 17689e8aded4SMichael Roth if (ret == -1) { 1769ce2eb6c4SPeter Lieven if (errno != EOPNOTSUPP && errno != EBUSY) { 177077dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to freeze %s", 1771617fbbc1SLuiz Capitulino mount->dirname); 1772c216e5adSMichael Roth close(fd); 1773c216e5adSMichael Roth goto error; 1774c216e5adSMichael Roth } 17759e8aded4SMichael Roth } else { 1776c216e5adSMichael Roth i++; 1777c216e5adSMichael Roth } 17789e8aded4SMichael Roth close(fd); 17799e8aded4SMichael Roth } 1780c216e5adSMichael Roth 1781af02203fSPaolo Bonzini free_fs_mount_list(&mounts); 178265650f01SChen Hanxiao /* We may not issue any FIFREEZE here. 178365650f01SChen Hanxiao * Just unset ga_state here and ready for the next call. 178465650f01SChen Hanxiao */ 178565650f01SChen Hanxiao if (i == 0) { 178665650f01SChen Hanxiao ga_unset_frozen(ga_state); 178765650f01SChen Hanxiao } 1788c216e5adSMichael Roth return i; 1789c216e5adSMichael Roth 1790c216e5adSMichael Roth error: 1791af02203fSPaolo Bonzini free_fs_mount_list(&mounts); 1792c216e5adSMichael Roth qmp_guest_fsfreeze_thaw(NULL); 1793c216e5adSMichael Roth return 0; 1794c216e5adSMichael Roth } 1795c216e5adSMichael Roth 1796c216e5adSMichael Roth /* 1797c216e5adSMichael Roth * Walk list of frozen file systems in the guest, and thaw them. 1798c216e5adSMichael Roth */ 179977dbc81bSMarkus Armbruster int64_t qmp_guest_fsfreeze_thaw(Error **errp) 1800c216e5adSMichael Roth { 1801c216e5adSMichael Roth int ret; 1802af02203fSPaolo Bonzini FsMountList mounts; 1803af02203fSPaolo Bonzini FsMount *mount; 18049e8aded4SMichael Roth int fd, i = 0, logged; 1805261551d1SLuiz Capitulino Error *local_err = NULL; 1806c216e5adSMichael Roth 18079e8aded4SMichael Roth QTAILQ_INIT(&mounts); 1808561bfcb6SMarc-André Lureau if (!build_fs_mount_list(&mounts, &local_err)) { 180977dbc81bSMarkus Armbruster error_propagate(errp, local_err); 18109e8aded4SMichael Roth return 0; 18119e8aded4SMichael Roth } 18129e8aded4SMichael Roth 18139e8aded4SMichael Roth QTAILQ_FOREACH(mount, &mounts, next) { 18149e8aded4SMichael Roth logged = false; 1815b9947c9cSMarc-André Lureau fd = qga_open_cloexec(mount->dirname, O_RDONLY, 0); 1816c216e5adSMichael Roth if (fd == -1) { 1817c216e5adSMichael Roth continue; 1818c216e5adSMichael Roth } 18199e8aded4SMichael Roth /* we have no way of knowing whether a filesystem was actually unfrozen 18209e8aded4SMichael Roth * as a result of a successful call to FITHAW, only that if an error 18219e8aded4SMichael Roth * was returned the filesystem was *not* unfrozen by that particular 18229e8aded4SMichael Roth * call. 18239e8aded4SMichael Roth * 1824a31f0531SJim Meyering * since multiple preceding FIFREEZEs require multiple calls to FITHAW 18259e8aded4SMichael Roth * to unfreeze, continuing issuing FITHAW until an error is returned, 18269e8aded4SMichael Roth * in which case either the filesystem is in an unfreezable state, or, 18279e8aded4SMichael Roth * more likely, it was thawed previously (and remains so afterward). 18289e8aded4SMichael Roth * 18299e8aded4SMichael Roth * also, since the most recent successful call is the one that did 18309e8aded4SMichael Roth * the actual unfreeze, we can use this to provide an accurate count 18319e8aded4SMichael Roth * of the number of filesystems unfrozen by guest-fsfreeze-thaw, which 18329e8aded4SMichael Roth * may * be useful for determining whether a filesystem was unfrozen 18339e8aded4SMichael Roth * during the freeze/thaw phase by a process other than qemu-ga. 18349e8aded4SMichael Roth */ 18359e8aded4SMichael Roth do { 1836c216e5adSMichael Roth ret = ioctl(fd, FITHAW); 18379e8aded4SMichael Roth if (ret == 0 && !logged) { 1838c216e5adSMichael Roth i++; 18399e8aded4SMichael Roth logged = true; 18409e8aded4SMichael Roth } 18419e8aded4SMichael Roth } while (ret == 0); 18429e8aded4SMichael Roth close(fd); 1843c216e5adSMichael Roth } 1844c216e5adSMichael Roth 1845f22d85e9SMichael Roth ga_unset_frozen(ga_state); 1846af02203fSPaolo Bonzini free_fs_mount_list(&mounts); 1847ec0f694cSTomoki Sekiyama 184877dbc81bSMarkus Armbruster execute_fsfreeze_hook(FSFREEZE_HOOK_THAW, errp); 1849ec0f694cSTomoki Sekiyama 1850c216e5adSMichael Roth return i; 1851c216e5adSMichael Roth } 1852c216e5adSMichael Roth 1853c216e5adSMichael Roth static void guest_fsfreeze_cleanup(void) 1854c216e5adSMichael Roth { 1855c216e5adSMichael Roth Error *err = NULL; 1856c216e5adSMichael Roth 1857f22d85e9SMichael Roth if (ga_is_frozen(ga_state) == GUEST_FSFREEZE_STATUS_FROZEN) { 18586f686749SMarkus Armbruster qmp_guest_fsfreeze_thaw(&err); 18596f686749SMarkus Armbruster if (err) { 18606f686749SMarkus Armbruster slog("failed to clean up frozen filesystems: %s", 18616f686749SMarkus Armbruster error_get_pretty(err)); 18626f686749SMarkus Armbruster error_free(err); 1863c216e5adSMichael Roth } 1864c216e5adSMichael Roth } 1865c216e5adSMichael Roth } 1866e72c3f2eSMichael Roth #endif /* CONFIG_FSFREEZE */ 1867c216e5adSMichael Roth 1868eab5fd59SPaolo Bonzini #if defined(CONFIG_FSTRIM) 1869eab5fd59SPaolo Bonzini /* 1870eab5fd59SPaolo Bonzini * Walk list of mounted file systems in the guest, and trim them. 1871eab5fd59SPaolo Bonzini */ 1872e82855d9SJustin Ossevoort GuestFilesystemTrimResponse * 1873e82855d9SJustin Ossevoort qmp_guest_fstrim(bool has_minimum, int64_t minimum, Error **errp) 1874eab5fd59SPaolo Bonzini { 1875e82855d9SJustin Ossevoort GuestFilesystemTrimResponse *response; 1876e82855d9SJustin Ossevoort GuestFilesystemTrimResult *result; 1877eab5fd59SPaolo Bonzini int ret = 0; 1878eab5fd59SPaolo Bonzini FsMountList mounts; 1879eab5fd59SPaolo Bonzini struct FsMount *mount; 1880eab5fd59SPaolo Bonzini int fd; 188173a652a1SJustin Ossevoort struct fstrim_range r; 1882eab5fd59SPaolo Bonzini 1883eab5fd59SPaolo Bonzini slog("guest-fstrim called"); 1884eab5fd59SPaolo Bonzini 1885eab5fd59SPaolo Bonzini QTAILQ_INIT(&mounts); 1886561bfcb6SMarc-André Lureau if (!build_fs_mount_list(&mounts, errp)) { 1887e82855d9SJustin Ossevoort return NULL; 1888eab5fd59SPaolo Bonzini } 1889eab5fd59SPaolo Bonzini 1890e82855d9SJustin Ossevoort response = g_malloc0(sizeof(*response)); 1891e82855d9SJustin Ossevoort 1892eab5fd59SPaolo Bonzini QTAILQ_FOREACH(mount, &mounts, next) { 1893e82855d9SJustin Ossevoort result = g_malloc0(sizeof(*result)); 1894e82855d9SJustin Ossevoort result->path = g_strdup(mount->dirname); 1895e82855d9SJustin Ossevoort 189654aa3de7SEric Blake QAPI_LIST_PREPEND(response->paths, result); 1897e82855d9SJustin Ossevoort 1898b9947c9cSMarc-André Lureau fd = qga_open_cloexec(mount->dirname, O_RDONLY, 0); 1899eab5fd59SPaolo Bonzini if (fd == -1) { 1900e82855d9SJustin Ossevoort result->error = g_strdup_printf("failed to open: %s", 1901e82855d9SJustin Ossevoort strerror(errno)); 1902e82855d9SJustin Ossevoort result->has_error = true; 1903e82855d9SJustin Ossevoort continue; 1904eab5fd59SPaolo Bonzini } 1905eab5fd59SPaolo Bonzini 1906e35916acSMichael Tokarev /* We try to cull filesystems we know won't work in advance, but other 1907e35916acSMichael Tokarev * filesystems may not implement fstrim for less obvious reasons. 1908e35916acSMichael Tokarev * These will report EOPNOTSUPP; while in some other cases ENOTTY 1909e35916acSMichael Tokarev * will be reported (e.g. CD-ROMs). 1910e82855d9SJustin Ossevoort * Any other error means an unexpected error. 1911eab5fd59SPaolo Bonzini */ 191273a652a1SJustin Ossevoort r.start = 0; 191373a652a1SJustin Ossevoort r.len = -1; 191473a652a1SJustin Ossevoort r.minlen = has_minimum ? minimum : 0; 1915eab5fd59SPaolo Bonzini ret = ioctl(fd, FITRIM, &r); 1916eab5fd59SPaolo Bonzini if (ret == -1) { 1917e82855d9SJustin Ossevoort result->has_error = true; 1918e82855d9SJustin Ossevoort if (errno == ENOTTY || errno == EOPNOTSUPP) { 1919e82855d9SJustin Ossevoort result->error = g_strdup("trim not supported"); 1920e82855d9SJustin Ossevoort } else { 1921e82855d9SJustin Ossevoort result->error = g_strdup_printf("failed to trim: %s", 1922e82855d9SJustin Ossevoort strerror(errno)); 1923e82855d9SJustin Ossevoort } 1924eab5fd59SPaolo Bonzini close(fd); 1925e82855d9SJustin Ossevoort continue; 1926eab5fd59SPaolo Bonzini } 1927e82855d9SJustin Ossevoort 1928e82855d9SJustin Ossevoort result->has_minimum = true; 1929e82855d9SJustin Ossevoort result->minimum = r.minlen; 1930e82855d9SJustin Ossevoort result->has_trimmed = true; 1931e82855d9SJustin Ossevoort result->trimmed = r.len; 1932eab5fd59SPaolo Bonzini close(fd); 1933eab5fd59SPaolo Bonzini } 1934eab5fd59SPaolo Bonzini 1935eab5fd59SPaolo Bonzini free_fs_mount_list(&mounts); 1936e82855d9SJustin Ossevoort return response; 1937eab5fd59SPaolo Bonzini } 1938eab5fd59SPaolo Bonzini #endif /* CONFIG_FSTRIM */ 1939eab5fd59SPaolo Bonzini 1940eab5fd59SPaolo Bonzini 194111d0f125SLuiz Capitulino #define LINUX_SYS_STATE_FILE "/sys/power/state" 194211d0f125SLuiz Capitulino #define SUSPEND_SUPPORTED 0 194311d0f125SLuiz Capitulino #define SUSPEND_NOT_SUPPORTED 1 194411d0f125SLuiz Capitulino 19458b020b5eSDaniel Henrique Barboza typedef enum { 19468b020b5eSDaniel Henrique Barboza SUSPEND_MODE_DISK = 0, 19478b020b5eSDaniel Henrique Barboza SUSPEND_MODE_RAM = 1, 19488b020b5eSDaniel Henrique Barboza SUSPEND_MODE_HYBRID = 2, 19498b020b5eSDaniel Henrique Barboza } SuspendMode; 19508b020b5eSDaniel Henrique Barboza 19518b020b5eSDaniel Henrique Barboza /* 19528b020b5eSDaniel Henrique Barboza * Executes a command in a child process using g_spawn_sync, 19538b020b5eSDaniel Henrique Barboza * returning an int >= 0 representing the exit status of the 19548b020b5eSDaniel Henrique Barboza * process. 19558b020b5eSDaniel Henrique Barboza * 19568b020b5eSDaniel Henrique Barboza * If the program wasn't found in path, returns -1. 19578b020b5eSDaniel Henrique Barboza * 19588b020b5eSDaniel Henrique Barboza * If a problem happened when creating the child process, 19598b020b5eSDaniel Henrique Barboza * returns -1 and errp is set. 19608b020b5eSDaniel Henrique Barboza */ 19618b020b5eSDaniel Henrique Barboza static int run_process_child(const char *command[], Error **errp) 19628b020b5eSDaniel Henrique Barboza { 19638b020b5eSDaniel Henrique Barboza int exit_status, spawn_flag; 19648b020b5eSDaniel Henrique Barboza GError *g_err = NULL; 19658b020b5eSDaniel Henrique Barboza bool success; 19668b020b5eSDaniel Henrique Barboza 19678b020b5eSDaniel Henrique Barboza spawn_flag = G_SPAWN_SEARCH_PATH | G_SPAWN_STDOUT_TO_DEV_NULL | 19688b020b5eSDaniel Henrique Barboza G_SPAWN_STDERR_TO_DEV_NULL; 19698b020b5eSDaniel Henrique Barboza 1970fcc41961SMarc-André Lureau success = g_spawn_sync(NULL, (char **)command, NULL, spawn_flag, 19718b020b5eSDaniel Henrique Barboza NULL, NULL, NULL, NULL, 19728b020b5eSDaniel Henrique Barboza &exit_status, &g_err); 19738b020b5eSDaniel Henrique Barboza 19748b020b5eSDaniel Henrique Barboza if (success) { 19758b020b5eSDaniel Henrique Barboza return WEXITSTATUS(exit_status); 19768b020b5eSDaniel Henrique Barboza } 19778b020b5eSDaniel Henrique Barboza 19788b020b5eSDaniel Henrique Barboza if (g_err && (g_err->code != G_SPAWN_ERROR_NOENT)) { 19798b020b5eSDaniel Henrique Barboza error_setg(errp, "failed to create child process, error '%s'", 19808b020b5eSDaniel Henrique Barboza g_err->message); 19818b020b5eSDaniel Henrique Barboza } 19828b020b5eSDaniel Henrique Barboza 19838b020b5eSDaniel Henrique Barboza g_error_free(g_err); 19848b020b5eSDaniel Henrique Barboza return -1; 19858b020b5eSDaniel Henrique Barboza } 19868b020b5eSDaniel Henrique Barboza 1987067927d6SDaniel Henrique Barboza static bool systemd_supports_mode(SuspendMode mode, Error **errp) 1988067927d6SDaniel Henrique Barboza { 1989067927d6SDaniel Henrique Barboza const char *systemctl_args[3] = {"systemd-hibernate", "systemd-suspend", 1990067927d6SDaniel Henrique Barboza "systemd-hybrid-sleep"}; 1991067927d6SDaniel Henrique Barboza const char *cmd[4] = {"systemctl", "status", systemctl_args[mode], NULL}; 1992067927d6SDaniel Henrique Barboza int status; 1993067927d6SDaniel Henrique Barboza 1994992861fbSMarkus Armbruster status = run_process_child(cmd, errp); 1995067927d6SDaniel Henrique Barboza 1996067927d6SDaniel Henrique Barboza /* 1997067927d6SDaniel Henrique Barboza * systemctl status uses LSB return codes so we can expect 1998067927d6SDaniel Henrique Barboza * status > 0 and be ok. To assert if the guest has support 1999067927d6SDaniel Henrique Barboza * for the selected suspend mode, status should be < 4. 4 is 2000067927d6SDaniel Henrique Barboza * the code for unknown service status, the return value when 2001067927d6SDaniel Henrique Barboza * the service does not exist. A common value is status = 3 2002067927d6SDaniel Henrique Barboza * (program is not running). 2003067927d6SDaniel Henrique Barboza */ 2004067927d6SDaniel Henrique Barboza if (status > 0 && status < 4) { 2005067927d6SDaniel Henrique Barboza return true; 2006067927d6SDaniel Henrique Barboza } 2007067927d6SDaniel Henrique Barboza 2008067927d6SDaniel Henrique Barboza return false; 2009067927d6SDaniel Henrique Barboza } 2010067927d6SDaniel Henrique Barboza 2011067927d6SDaniel Henrique Barboza static void systemd_suspend(SuspendMode mode, Error **errp) 2012067927d6SDaniel Henrique Barboza { 2013067927d6SDaniel Henrique Barboza Error *local_err = NULL; 2014067927d6SDaniel Henrique Barboza const char *systemctl_args[3] = {"hibernate", "suspend", "hybrid-sleep"}; 2015067927d6SDaniel Henrique Barboza const char *cmd[3] = {"systemctl", systemctl_args[mode], NULL}; 2016067927d6SDaniel Henrique Barboza int status; 2017067927d6SDaniel Henrique Barboza 2018067927d6SDaniel Henrique Barboza status = run_process_child(cmd, &local_err); 2019067927d6SDaniel Henrique Barboza 2020067927d6SDaniel Henrique Barboza if (status == 0) { 2021067927d6SDaniel Henrique Barboza return; 2022067927d6SDaniel Henrique Barboza } 2023067927d6SDaniel Henrique Barboza 2024067927d6SDaniel Henrique Barboza if ((status == -1) && !local_err) { 2025067927d6SDaniel Henrique Barboza error_setg(errp, "the helper program 'systemctl %s' was not found", 2026067927d6SDaniel Henrique Barboza systemctl_args[mode]); 2027067927d6SDaniel Henrique Barboza return; 2028067927d6SDaniel Henrique Barboza } 2029067927d6SDaniel Henrique Barboza 2030067927d6SDaniel Henrique Barboza if (local_err) { 2031067927d6SDaniel Henrique Barboza error_propagate(errp, local_err); 2032067927d6SDaniel Henrique Barboza } else { 2033067927d6SDaniel Henrique Barboza error_setg(errp, "the helper program 'systemctl %s' returned an " 2034067927d6SDaniel Henrique Barboza "unexpected exit status code (%d)", 2035067927d6SDaniel Henrique Barboza systemctl_args[mode], status); 2036067927d6SDaniel Henrique Barboza } 2037067927d6SDaniel Henrique Barboza } 2038067927d6SDaniel Henrique Barboza 20398b020b5eSDaniel Henrique Barboza static bool pmutils_supports_mode(SuspendMode mode, Error **errp) 204011d0f125SLuiz Capitulino { 20416b26e837SLuiz Capitulino Error *local_err = NULL; 20428b020b5eSDaniel Henrique Barboza const char *pmutils_args[3] = {"--hibernate", "--suspend", 20438b020b5eSDaniel Henrique Barboza "--suspend-hybrid"}; 20448b020b5eSDaniel Henrique Barboza const char *cmd[3] = {"pm-is-supported", pmutils_args[mode], NULL}; 2045dc8764f0SLuiz Capitulino int status; 204611d0f125SLuiz Capitulino 20478b020b5eSDaniel Henrique Barboza status = run_process_child(cmd, &local_err); 2048304a0fcbSDaniel Henrique Barboza 20498b020b5eSDaniel Henrique Barboza if (status == SUSPEND_SUPPORTED) { 20508b020b5eSDaniel Henrique Barboza return true; 2051304a0fcbSDaniel Henrique Barboza } 2052304a0fcbSDaniel Henrique Barboza 20538b020b5eSDaniel Henrique Barboza if ((status == -1) && !local_err) { 20548b020b5eSDaniel Henrique Barboza return false; 2055a5fcf0e3SDaniel Henrique Barboza } 205611d0f125SLuiz Capitulino 205784d18f06SMarkus Armbruster if (local_err) { 205877dbc81bSMarkus Armbruster error_propagate(errp, local_err); 20598b020b5eSDaniel Henrique Barboza } else { 206077dbc81bSMarkus Armbruster error_setg(errp, 20618b020b5eSDaniel Henrique Barboza "the helper program '%s' returned an unexpected exit" 20628b020b5eSDaniel Henrique Barboza " status code (%d)", "pm-is-supported", status); 2063dc8764f0SLuiz Capitulino } 206411d0f125SLuiz Capitulino 20658b020b5eSDaniel Henrique Barboza return false; 2066a5fcf0e3SDaniel Henrique Barboza } 2067a5fcf0e3SDaniel Henrique Barboza 20688b020b5eSDaniel Henrique Barboza static void pmutils_suspend(SuspendMode mode, Error **errp) 2069246d76ebSDaniel Henrique Barboza { 2070246d76ebSDaniel Henrique Barboza Error *local_err = NULL; 20718b020b5eSDaniel Henrique Barboza const char *pmutils_binaries[3] = {"pm-hibernate", "pm-suspend", 20728b020b5eSDaniel Henrique Barboza "pm-suspend-hybrid"}; 20738b020b5eSDaniel Henrique Barboza const char *cmd[2] = {pmutils_binaries[mode], NULL}; 2074246d76ebSDaniel Henrique Barboza int status; 2075246d76ebSDaniel Henrique Barboza 20768b020b5eSDaniel Henrique Barboza status = run_process_child(cmd, &local_err); 2077246d76ebSDaniel Henrique Barboza 20788b020b5eSDaniel Henrique Barboza if (status == 0) { 2079246d76ebSDaniel Henrique Barboza return; 2080246d76ebSDaniel Henrique Barboza } 2081246d76ebSDaniel Henrique Barboza 20828b020b5eSDaniel Henrique Barboza if ((status == -1) && !local_err) { 20838b020b5eSDaniel Henrique Barboza error_setg(errp, "the helper program '%s' was not found", 20848b020b5eSDaniel Henrique Barboza pmutils_binaries[mode]); 2085246d76ebSDaniel Henrique Barboza return; 2086246d76ebSDaniel Henrique Barboza } 2087246d76ebSDaniel Henrique Barboza 2088246d76ebSDaniel Henrique Barboza if (local_err) { 2089246d76ebSDaniel Henrique Barboza error_propagate(errp, local_err); 20908b020b5eSDaniel Henrique Barboza } else { 2091246d76ebSDaniel Henrique Barboza error_setg(errp, 20928b020b5eSDaniel Henrique Barboza "the helper program '%s' returned an unexpected exit" 20938b020b5eSDaniel Henrique Barboza " status code (%d)", pmutils_binaries[mode], status); 20948b020b5eSDaniel Henrique Barboza } 2095246d76ebSDaniel Henrique Barboza } 2096246d76ebSDaniel Henrique Barboza 20978b020b5eSDaniel Henrique Barboza static bool linux_sys_state_supports_mode(SuspendMode mode, Error **errp) 2098a5fcf0e3SDaniel Henrique Barboza { 20998b020b5eSDaniel Henrique Barboza const char *sysfile_strs[3] = {"disk", "mem", NULL}; 21008b020b5eSDaniel Henrique Barboza const char *sysfile_str = sysfile_strs[mode]; 2101a5fcf0e3SDaniel Henrique Barboza char buf[32]; /* hopefully big enough */ 2102a5fcf0e3SDaniel Henrique Barboza int fd; 2103a5fcf0e3SDaniel Henrique Barboza ssize_t ret; 2104a5fcf0e3SDaniel Henrique Barboza 21058b020b5eSDaniel Henrique Barboza if (!sysfile_str) { 21068b020b5eSDaniel Henrique Barboza error_setg(errp, "unknown guest suspend mode"); 2107a5fcf0e3SDaniel Henrique Barboza return false; 2108a5fcf0e3SDaniel Henrique Barboza } 2109a5fcf0e3SDaniel Henrique Barboza 2110a5fcf0e3SDaniel Henrique Barboza fd = open(LINUX_SYS_STATE_FILE, O_RDONLY); 2111a5fcf0e3SDaniel Henrique Barboza if (fd < 0) { 2112a5fcf0e3SDaniel Henrique Barboza return false; 2113a5fcf0e3SDaniel Henrique Barboza } 2114a5fcf0e3SDaniel Henrique Barboza 2115a5fcf0e3SDaniel Henrique Barboza ret = read(fd, buf, sizeof(buf) - 1); 2116d9c745c1SPaolo Bonzini close(fd); 2117a5fcf0e3SDaniel Henrique Barboza if (ret <= 0) { 2118a5fcf0e3SDaniel Henrique Barboza return false; 2119a5fcf0e3SDaniel Henrique Barboza } 2120a5fcf0e3SDaniel Henrique Barboza buf[ret] = '\0'; 2121a5fcf0e3SDaniel Henrique Barboza 2122a5fcf0e3SDaniel Henrique Barboza if (strstr(buf, sysfile_str)) { 2123a5fcf0e3SDaniel Henrique Barboza return true; 2124a5fcf0e3SDaniel Henrique Barboza } 2125a5fcf0e3SDaniel Henrique Barboza return false; 2126a5fcf0e3SDaniel Henrique Barboza } 2127a5fcf0e3SDaniel Henrique Barboza 21288b020b5eSDaniel Henrique Barboza static void linux_sys_state_suspend(SuspendMode mode, Error **errp) 2129246d76ebSDaniel Henrique Barboza { 2130246d76ebSDaniel Henrique Barboza Error *local_err = NULL; 21318b020b5eSDaniel Henrique Barboza const char *sysfile_strs[3] = {"disk", "mem", NULL}; 21328b020b5eSDaniel Henrique Barboza const char *sysfile_str = sysfile_strs[mode]; 2133246d76ebSDaniel Henrique Barboza pid_t pid; 2134246d76ebSDaniel Henrique Barboza int status; 2135246d76ebSDaniel Henrique Barboza 21368b020b5eSDaniel Henrique Barboza if (!sysfile_str) { 2137246d76ebSDaniel Henrique Barboza error_setg(errp, "unknown guest suspend mode"); 2138246d76ebSDaniel Henrique Barboza return; 2139246d76ebSDaniel Henrique Barboza } 2140246d76ebSDaniel Henrique Barboza 2141246d76ebSDaniel Henrique Barboza pid = fork(); 2142246d76ebSDaniel Henrique Barboza if (!pid) { 2143246d76ebSDaniel Henrique Barboza /* child */ 2144246d76ebSDaniel Henrique Barboza int fd; 2145246d76ebSDaniel Henrique Barboza 2146246d76ebSDaniel Henrique Barboza setsid(); 2147246d76ebSDaniel Henrique Barboza reopen_fd_to_null(0); 2148246d76ebSDaniel Henrique Barboza reopen_fd_to_null(1); 2149246d76ebSDaniel Henrique Barboza reopen_fd_to_null(2); 2150246d76ebSDaniel Henrique Barboza 2151246d76ebSDaniel Henrique Barboza fd = open(LINUX_SYS_STATE_FILE, O_WRONLY); 2152246d76ebSDaniel Henrique Barboza if (fd < 0) { 2153246d76ebSDaniel Henrique Barboza _exit(EXIT_FAILURE); 2154246d76ebSDaniel Henrique Barboza } 2155246d76ebSDaniel Henrique Barboza 2156246d76ebSDaniel Henrique Barboza if (write(fd, sysfile_str, strlen(sysfile_str)) < 0) { 2157246d76ebSDaniel Henrique Barboza _exit(EXIT_FAILURE); 2158246d76ebSDaniel Henrique Barboza } 2159246d76ebSDaniel Henrique Barboza 2160246d76ebSDaniel Henrique Barboza _exit(EXIT_SUCCESS); 2161246d76ebSDaniel Henrique Barboza } else if (pid < 0) { 2162246d76ebSDaniel Henrique Barboza error_setg_errno(errp, errno, "failed to create child process"); 2163246d76ebSDaniel Henrique Barboza return; 2164246d76ebSDaniel Henrique Barboza } 2165246d76ebSDaniel Henrique Barboza 2166246d76ebSDaniel Henrique Barboza ga_wait_child(pid, &status, &local_err); 2167246d76ebSDaniel Henrique Barboza if (local_err) { 2168246d76ebSDaniel Henrique Barboza error_propagate(errp, local_err); 2169246d76ebSDaniel Henrique Barboza return; 2170246d76ebSDaniel Henrique Barboza } 2171246d76ebSDaniel Henrique Barboza 2172246d76ebSDaniel Henrique Barboza if (WEXITSTATUS(status)) { 2173246d76ebSDaniel Henrique Barboza error_setg(errp, "child process has failed to suspend"); 2174246d76ebSDaniel Henrique Barboza } 2175246d76ebSDaniel Henrique Barboza 2176246d76ebSDaniel Henrique Barboza } 2177246d76ebSDaniel Henrique Barboza 21788b020b5eSDaniel Henrique Barboza static void guest_suspend(SuspendMode mode, Error **errp) 217911d0f125SLuiz Capitulino { 21807b376087SLuiz Capitulino Error *local_err = NULL; 218173e1d8ebSDaniel Henrique Barboza bool mode_supported = false; 218211d0f125SLuiz Capitulino 218373e1d8ebSDaniel Henrique Barboza if (systemd_supports_mode(mode, &local_err)) { 218473e1d8ebSDaniel Henrique Barboza mode_supported = true; 2185067927d6SDaniel Henrique Barboza systemd_suspend(mode, &local_err); 218673e1d8ebSDaniel Henrique Barboza } 218773e1d8ebSDaniel Henrique Barboza 2188067927d6SDaniel Henrique Barboza if (!local_err) { 2189067927d6SDaniel Henrique Barboza return; 2190067927d6SDaniel Henrique Barboza } 2191067927d6SDaniel Henrique Barboza 2192067927d6SDaniel Henrique Barboza error_free(local_err); 21936a4a3853SVladimir Sementsov-Ogievskiy local_err = NULL; 2194067927d6SDaniel Henrique Barboza 219573e1d8ebSDaniel Henrique Barboza if (pmutils_supports_mode(mode, &local_err)) { 219673e1d8ebSDaniel Henrique Barboza mode_supported = true; 21978b020b5eSDaniel Henrique Barboza pmutils_suspend(mode, &local_err); 219873e1d8ebSDaniel Henrique Barboza } 219973e1d8ebSDaniel Henrique Barboza 2200246d76ebSDaniel Henrique Barboza if (!local_err) { 2201304a0fcbSDaniel Henrique Barboza return; 2202304a0fcbSDaniel Henrique Barboza } 2203304a0fcbSDaniel Henrique Barboza 2204246d76ebSDaniel Henrique Barboza error_free(local_err); 22056a4a3853SVladimir Sementsov-Ogievskiy local_err = NULL; 220611d0f125SLuiz Capitulino 220773e1d8ebSDaniel Henrique Barboza if (linux_sys_state_supports_mode(mode, &local_err)) { 220873e1d8ebSDaniel Henrique Barboza mode_supported = true; 22098b020b5eSDaniel Henrique Barboza linux_sys_state_suspend(mode, &local_err); 221073e1d8ebSDaniel Henrique Barboza } 221173e1d8ebSDaniel Henrique Barboza 221273e1d8ebSDaniel Henrique Barboza if (!mode_supported) { 22136a4a3853SVladimir Sementsov-Ogievskiy error_free(local_err); 221473e1d8ebSDaniel Henrique Barboza error_setg(errp, 221573e1d8ebSDaniel Henrique Barboza "the requested suspend mode is not supported by the guest"); 2216b2322003SMarkus Armbruster } else { 221777dbc81bSMarkus Armbruster error_propagate(errp, local_err); 22187b376087SLuiz Capitulino } 221911d0f125SLuiz Capitulino } 222011d0f125SLuiz Capitulino 222177dbc81bSMarkus Armbruster void qmp_guest_suspend_disk(Error **errp) 222211d0f125SLuiz Capitulino { 2223304a0fcbSDaniel Henrique Barboza guest_suspend(SUSPEND_MODE_DISK, errp); 222411d0f125SLuiz Capitulino } 222511d0f125SLuiz Capitulino 222677dbc81bSMarkus Armbruster void qmp_guest_suspend_ram(Error **errp) 2227fbf42210SLuiz Capitulino { 2228304a0fcbSDaniel Henrique Barboza guest_suspend(SUSPEND_MODE_RAM, errp); 2229fbf42210SLuiz Capitulino } 2230fbf42210SLuiz Capitulino 223177dbc81bSMarkus Armbruster void qmp_guest_suspend_hybrid(Error **errp) 223295f4f404SLuiz Capitulino { 2233304a0fcbSDaniel Henrique Barboza guest_suspend(SUSPEND_MODE_HYBRID, errp); 223495f4f404SLuiz Capitulino } 223595f4f404SLuiz Capitulino 2236d2baff62SLaszlo Ersek /* Transfer online/offline status between @vcpu and the guest system. 2237d2baff62SLaszlo Ersek * 2238d2baff62SLaszlo Ersek * On input either @errp or *@errp must be NULL. 2239d2baff62SLaszlo Ersek * 2240d2baff62SLaszlo Ersek * In system-to-@vcpu direction, the following @vcpu fields are accessed: 2241d2baff62SLaszlo Ersek * - R: vcpu->logical_id 2242d2baff62SLaszlo Ersek * - W: vcpu->online 2243d2baff62SLaszlo Ersek * - W: vcpu->can_offline 2244d2baff62SLaszlo Ersek * 2245d2baff62SLaszlo Ersek * In @vcpu-to-system direction, the following @vcpu fields are accessed: 2246d2baff62SLaszlo Ersek * - R: vcpu->logical_id 2247d2baff62SLaszlo Ersek * - R: vcpu->online 2248d2baff62SLaszlo Ersek * 2249d2baff62SLaszlo Ersek * Written members remain unmodified on error. 2250d2baff62SLaszlo Ersek */ 2251d2baff62SLaszlo Ersek static void transfer_vcpu(GuestLogicalProcessor *vcpu, bool sys2vcpu, 2252b4bf912aSIgor Mammedov char *dirpath, Error **errp) 2253d2baff62SLaszlo Ersek { 2254b4bf912aSIgor Mammedov int fd; 2255b4bf912aSIgor Mammedov int res; 2256d2baff62SLaszlo Ersek int dirfd; 2257b4bf912aSIgor Mammedov static const char fn[] = "online"; 2258d2baff62SLaszlo Ersek 2259d2baff62SLaszlo Ersek dirfd = open(dirpath, O_RDONLY | O_DIRECTORY); 2260d2baff62SLaszlo Ersek if (dirfd == -1) { 2261d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "open(\"%s\")", dirpath); 2262b4bf912aSIgor Mammedov return; 2263b4bf912aSIgor Mammedov } 2264d2baff62SLaszlo Ersek 2265d2baff62SLaszlo Ersek fd = openat(dirfd, fn, sys2vcpu ? O_RDONLY : O_RDWR); 2266d2baff62SLaszlo Ersek if (fd == -1) { 2267d2baff62SLaszlo Ersek if (errno != ENOENT) { 2268d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "open(\"%s/%s\")", dirpath, fn); 2269d2baff62SLaszlo Ersek } else if (sys2vcpu) { 2270d2baff62SLaszlo Ersek vcpu->online = true; 2271d2baff62SLaszlo Ersek vcpu->can_offline = false; 2272d2baff62SLaszlo Ersek } else if (!vcpu->online) { 2273d2baff62SLaszlo Ersek error_setg(errp, "logical processor #%" PRId64 " can't be " 2274d2baff62SLaszlo Ersek "offlined", vcpu->logical_id); 2275d2baff62SLaszlo Ersek } /* otherwise pretend successful re-onlining */ 2276d2baff62SLaszlo Ersek } else { 2277d2baff62SLaszlo Ersek unsigned char status; 2278d2baff62SLaszlo Ersek 2279d2baff62SLaszlo Ersek res = pread(fd, &status, 1, 0); 2280d2baff62SLaszlo Ersek if (res == -1) { 2281d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "pread(\"%s/%s\")", dirpath, fn); 2282d2baff62SLaszlo Ersek } else if (res == 0) { 2283d2baff62SLaszlo Ersek error_setg(errp, "pread(\"%s/%s\"): unexpected EOF", dirpath, 2284d2baff62SLaszlo Ersek fn); 2285d2baff62SLaszlo Ersek } else if (sys2vcpu) { 2286d2baff62SLaszlo Ersek vcpu->online = (status != '0'); 2287d2baff62SLaszlo Ersek vcpu->can_offline = true; 2288d2baff62SLaszlo Ersek } else if (vcpu->online != (status != '0')) { 2289d2baff62SLaszlo Ersek status = '0' + vcpu->online; 2290d2baff62SLaszlo Ersek if (pwrite(fd, &status, 1, 0) == -1) { 2291d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "pwrite(\"%s/%s\")", dirpath, 2292d2baff62SLaszlo Ersek fn); 2293d2baff62SLaszlo Ersek } 2294d2baff62SLaszlo Ersek } /* otherwise pretend successful re-(on|off)-lining */ 2295d2baff62SLaszlo Ersek 2296d2baff62SLaszlo Ersek res = close(fd); 2297d2baff62SLaszlo Ersek g_assert(res == 0); 2298d2baff62SLaszlo Ersek } 2299d2baff62SLaszlo Ersek 2300d2baff62SLaszlo Ersek res = close(dirfd); 2301d2baff62SLaszlo Ersek g_assert(res == 0); 2302d2baff62SLaszlo Ersek } 2303d2baff62SLaszlo Ersek 2304d2baff62SLaszlo Ersek GuestLogicalProcessorList *qmp_guest_get_vcpus(Error **errp) 2305d2baff62SLaszlo Ersek { 2306c3033fd3SEric Blake GuestLogicalProcessorList *head, **tail; 230727e7de3cSLin Ma const char *cpu_dir = "/sys/devices/system/cpu"; 230827e7de3cSLin Ma const gchar *line; 230927e7de3cSLin Ma g_autoptr(GDir) cpu_gdir = NULL; 2310d2baff62SLaszlo Ersek Error *local_err = NULL; 2311d2baff62SLaszlo Ersek 2312d2baff62SLaszlo Ersek head = NULL; 2313c3033fd3SEric Blake tail = &head; 231427e7de3cSLin Ma cpu_gdir = g_dir_open(cpu_dir, 0, NULL); 2315d2baff62SLaszlo Ersek 231627e7de3cSLin Ma if (cpu_gdir == NULL) { 231727e7de3cSLin Ma error_setg_errno(errp, errno, "failed to list entries: %s", cpu_dir); 231827e7de3cSLin Ma return NULL; 231927e7de3cSLin Ma } 232027e7de3cSLin Ma 232127e7de3cSLin Ma while (local_err == NULL && (line = g_dir_read_name(cpu_gdir)) != NULL) { 2322d2baff62SLaszlo Ersek GuestLogicalProcessor *vcpu; 232327e7de3cSLin Ma int64_t id; 232427e7de3cSLin Ma if (sscanf(line, "cpu%" PRId64, &id)) { 232527e7de3cSLin Ma g_autofree char *path = g_strdup_printf("/sys/devices/system/cpu/" 232627e7de3cSLin Ma "cpu%" PRId64 "/", id); 2327d2baff62SLaszlo Ersek vcpu = g_malloc0(sizeof *vcpu); 2328b4bf912aSIgor Mammedov vcpu->logical_id = id; 2329d2baff62SLaszlo Ersek vcpu->has_can_offline = true; /* lolspeak ftw */ 2330b4bf912aSIgor Mammedov transfer_vcpu(vcpu, true, path, &local_err); 2331c3033fd3SEric Blake QAPI_LIST_APPEND(tail, vcpu); 2332d2baff62SLaszlo Ersek } 2333b4bf912aSIgor Mammedov } 2334d2baff62SLaszlo Ersek 2335d2baff62SLaszlo Ersek if (local_err == NULL) { 2336d2baff62SLaszlo Ersek /* there's no guest with zero VCPUs */ 2337d2baff62SLaszlo Ersek g_assert(head != NULL); 2338d2baff62SLaszlo Ersek return head; 2339d2baff62SLaszlo Ersek } 2340d2baff62SLaszlo Ersek 2341d2baff62SLaszlo Ersek qapi_free_GuestLogicalProcessorList(head); 2342d2baff62SLaszlo Ersek error_propagate(errp, local_err); 2343d2baff62SLaszlo Ersek return NULL; 2344d2baff62SLaszlo Ersek } 2345d2baff62SLaszlo Ersek 2346cbb65fc2SLaszlo Ersek int64_t qmp_guest_set_vcpus(GuestLogicalProcessorList *vcpus, Error **errp) 2347cbb65fc2SLaszlo Ersek { 2348cbb65fc2SLaszlo Ersek int64_t processed; 2349cbb65fc2SLaszlo Ersek Error *local_err = NULL; 2350cbb65fc2SLaszlo Ersek 2351cbb65fc2SLaszlo Ersek processed = 0; 2352cbb65fc2SLaszlo Ersek while (vcpus != NULL) { 2353b4bf912aSIgor Mammedov char *path = g_strdup_printf("/sys/devices/system/cpu/cpu%" PRId64 "/", 2354b4bf912aSIgor Mammedov vcpus->value->logical_id); 2355b4bf912aSIgor Mammedov 2356b4bf912aSIgor Mammedov transfer_vcpu(vcpus->value, false, path, &local_err); 2357b4bf912aSIgor Mammedov g_free(path); 2358cbb65fc2SLaszlo Ersek if (local_err != NULL) { 2359cbb65fc2SLaszlo Ersek break; 2360cbb65fc2SLaszlo Ersek } 2361cbb65fc2SLaszlo Ersek ++processed; 2362cbb65fc2SLaszlo Ersek vcpus = vcpus->next; 2363cbb65fc2SLaszlo Ersek } 2364cbb65fc2SLaszlo Ersek 2365cbb65fc2SLaszlo Ersek if (local_err != NULL) { 2366cbb65fc2SLaszlo Ersek if (processed == 0) { 2367cbb65fc2SLaszlo Ersek error_propagate(errp, local_err); 2368cbb65fc2SLaszlo Ersek } else { 2369cbb65fc2SLaszlo Ersek error_free(local_err); 2370cbb65fc2SLaszlo Ersek } 2371cbb65fc2SLaszlo Ersek } 2372cbb65fc2SLaszlo Ersek 2373cbb65fc2SLaszlo Ersek return processed; 2374cbb65fc2SLaszlo Ersek } 2375cbb65fc2SLaszlo Ersek 2376215a2771SDaniel P. Berrange void qmp_guest_set_user_password(const char *username, 2377215a2771SDaniel P. Berrange const char *password, 2378215a2771SDaniel P. Berrange bool crypted, 2379215a2771SDaniel P. Berrange Error **errp) 2380215a2771SDaniel P. Berrange { 2381215a2771SDaniel P. Berrange Error *local_err = NULL; 2382215a2771SDaniel P. Berrange char *passwd_path = NULL; 2383215a2771SDaniel P. Berrange pid_t pid; 2384215a2771SDaniel P. Berrange int status; 2385215a2771SDaniel P. Berrange int datafd[2] = { -1, -1 }; 2386215a2771SDaniel P. Berrange char *rawpasswddata = NULL; 2387215a2771SDaniel P. Berrange size_t rawpasswdlen; 2388215a2771SDaniel P. Berrange char *chpasswddata = NULL; 2389215a2771SDaniel P. Berrange size_t chpasswdlen; 2390215a2771SDaniel P. Berrange 2391920639caSDaniel P. Berrange rawpasswddata = (char *)qbase64_decode(password, -1, &rawpasswdlen, errp); 2392920639caSDaniel P. Berrange if (!rawpasswddata) { 2393920639caSDaniel P. Berrange return; 2394920639caSDaniel P. Berrange } 2395215a2771SDaniel P. Berrange rawpasswddata = g_renew(char, rawpasswddata, rawpasswdlen + 1); 2396215a2771SDaniel P. Berrange rawpasswddata[rawpasswdlen] = '\0'; 2397215a2771SDaniel P. Berrange 2398215a2771SDaniel P. Berrange if (strchr(rawpasswddata, '\n')) { 2399215a2771SDaniel P. Berrange error_setg(errp, "forbidden characters in raw password"); 2400215a2771SDaniel P. Berrange goto out; 2401215a2771SDaniel P. Berrange } 2402215a2771SDaniel P. Berrange 2403215a2771SDaniel P. Berrange if (strchr(username, '\n') || 2404215a2771SDaniel P. Berrange strchr(username, ':')) { 2405215a2771SDaniel P. Berrange error_setg(errp, "forbidden characters in username"); 2406215a2771SDaniel P. Berrange goto out; 2407215a2771SDaniel P. Berrange } 2408215a2771SDaniel P. Berrange 2409215a2771SDaniel P. Berrange chpasswddata = g_strdup_printf("%s:%s\n", username, rawpasswddata); 2410215a2771SDaniel P. Berrange chpasswdlen = strlen(chpasswddata); 2411215a2771SDaniel P. Berrange 2412215a2771SDaniel P. Berrange passwd_path = g_find_program_in_path("chpasswd"); 2413215a2771SDaniel P. Berrange 2414215a2771SDaniel P. Berrange if (!passwd_path) { 2415215a2771SDaniel P. Berrange error_setg(errp, "cannot find 'passwd' program in PATH"); 2416215a2771SDaniel P. Berrange goto out; 2417215a2771SDaniel P. Berrange } 2418215a2771SDaniel P. Berrange 2419ed78331dSMarc-André Lureau if (!g_unix_open_pipe(datafd, FD_CLOEXEC, NULL)) { 2420215a2771SDaniel P. Berrange error_setg(errp, "cannot create pipe FDs"); 2421215a2771SDaniel P. Berrange goto out; 2422215a2771SDaniel P. Berrange } 2423215a2771SDaniel P. Berrange 2424215a2771SDaniel P. Berrange pid = fork(); 2425215a2771SDaniel P. Berrange if (pid == 0) { 2426215a2771SDaniel P. Berrange close(datafd[1]); 2427215a2771SDaniel P. Berrange /* child */ 2428215a2771SDaniel P. Berrange setsid(); 2429215a2771SDaniel P. Berrange dup2(datafd[0], 0); 2430215a2771SDaniel P. Berrange reopen_fd_to_null(1); 2431215a2771SDaniel P. Berrange reopen_fd_to_null(2); 2432215a2771SDaniel P. Berrange 2433215a2771SDaniel P. Berrange if (crypted) { 2434fcc41961SMarc-André Lureau execl(passwd_path, "chpasswd", "-e", NULL); 2435215a2771SDaniel P. Berrange } else { 2436fcc41961SMarc-André Lureau execl(passwd_path, "chpasswd", NULL); 2437215a2771SDaniel P. Berrange } 2438215a2771SDaniel P. Berrange _exit(EXIT_FAILURE); 2439215a2771SDaniel P. Berrange } else if (pid < 0) { 2440215a2771SDaniel P. Berrange error_setg_errno(errp, errno, "failed to create child process"); 2441215a2771SDaniel P. Berrange goto out; 2442215a2771SDaniel P. Berrange } 2443215a2771SDaniel P. Berrange close(datafd[0]); 2444215a2771SDaniel P. Berrange datafd[0] = -1; 2445215a2771SDaniel P. Berrange 2446215a2771SDaniel P. Berrange if (qemu_write_full(datafd[1], chpasswddata, chpasswdlen) != chpasswdlen) { 2447215a2771SDaniel P. Berrange error_setg_errno(errp, errno, "cannot write new account password"); 2448215a2771SDaniel P. Berrange goto out; 2449215a2771SDaniel P. Berrange } 2450215a2771SDaniel P. Berrange close(datafd[1]); 2451215a2771SDaniel P. Berrange datafd[1] = -1; 2452215a2771SDaniel P. Berrange 2453215a2771SDaniel P. Berrange ga_wait_child(pid, &status, &local_err); 2454215a2771SDaniel P. Berrange if (local_err) { 2455215a2771SDaniel P. Berrange error_propagate(errp, local_err); 2456215a2771SDaniel P. Berrange goto out; 2457215a2771SDaniel P. Berrange } 2458215a2771SDaniel P. Berrange 2459215a2771SDaniel P. Berrange if (!WIFEXITED(status)) { 2460215a2771SDaniel P. Berrange error_setg(errp, "child process has terminated abnormally"); 2461215a2771SDaniel P. Berrange goto out; 2462215a2771SDaniel P. Berrange } 2463215a2771SDaniel P. Berrange 2464215a2771SDaniel P. Berrange if (WEXITSTATUS(status)) { 2465215a2771SDaniel P. Berrange error_setg(errp, "child process has failed to set user password"); 2466215a2771SDaniel P. Berrange goto out; 2467215a2771SDaniel P. Berrange } 2468215a2771SDaniel P. Berrange 2469215a2771SDaniel P. Berrange out: 2470215a2771SDaniel P. Berrange g_free(chpasswddata); 2471215a2771SDaniel P. Berrange g_free(rawpasswddata); 2472215a2771SDaniel P. Berrange g_free(passwd_path); 2473215a2771SDaniel P. Berrange if (datafd[0] != -1) { 2474215a2771SDaniel P. Berrange close(datafd[0]); 2475215a2771SDaniel P. Berrange } 2476215a2771SDaniel P. Berrange if (datafd[1] != -1) { 2477215a2771SDaniel P. Berrange close(datafd[1]); 2478215a2771SDaniel P. Berrange } 2479215a2771SDaniel P. Berrange } 2480215a2771SDaniel P. Berrange 2481bd240fcaSzhanghailiang static void ga_read_sysfs_file(int dirfd, const char *pathname, char *buf, 2482bd240fcaSzhanghailiang int size, Error **errp) 2483bd240fcaSzhanghailiang { 2484bd240fcaSzhanghailiang int fd; 2485bd240fcaSzhanghailiang int res; 2486bd240fcaSzhanghailiang 2487bd240fcaSzhanghailiang errno = 0; 2488bd240fcaSzhanghailiang fd = openat(dirfd, pathname, O_RDONLY); 2489bd240fcaSzhanghailiang if (fd == -1) { 2490bd240fcaSzhanghailiang error_setg_errno(errp, errno, "open sysfs file \"%s\"", pathname); 2491bd240fcaSzhanghailiang return; 2492bd240fcaSzhanghailiang } 2493bd240fcaSzhanghailiang 2494bd240fcaSzhanghailiang res = pread(fd, buf, size, 0); 2495bd240fcaSzhanghailiang if (res == -1) { 2496bd240fcaSzhanghailiang error_setg_errno(errp, errno, "pread sysfs file \"%s\"", pathname); 2497bd240fcaSzhanghailiang } else if (res == 0) { 2498bd240fcaSzhanghailiang error_setg(errp, "pread sysfs file \"%s\": unexpected EOF", pathname); 2499bd240fcaSzhanghailiang } 2500bd240fcaSzhanghailiang close(fd); 2501bd240fcaSzhanghailiang } 2502bd240fcaSzhanghailiang 2503bd240fcaSzhanghailiang static void ga_write_sysfs_file(int dirfd, const char *pathname, 2504bd240fcaSzhanghailiang const char *buf, int size, Error **errp) 2505bd240fcaSzhanghailiang { 2506bd240fcaSzhanghailiang int fd; 2507bd240fcaSzhanghailiang 2508bd240fcaSzhanghailiang errno = 0; 2509bd240fcaSzhanghailiang fd = openat(dirfd, pathname, O_WRONLY); 2510bd240fcaSzhanghailiang if (fd == -1) { 2511bd240fcaSzhanghailiang error_setg_errno(errp, errno, "open sysfs file \"%s\"", pathname); 2512bd240fcaSzhanghailiang return; 2513bd240fcaSzhanghailiang } 2514bd240fcaSzhanghailiang 2515bd240fcaSzhanghailiang if (pwrite(fd, buf, size, 0) == -1) { 2516bd240fcaSzhanghailiang error_setg_errno(errp, errno, "pwrite sysfs file \"%s\"", pathname); 2517bd240fcaSzhanghailiang } 2518bd240fcaSzhanghailiang 2519bd240fcaSzhanghailiang close(fd); 2520bd240fcaSzhanghailiang } 2521bd240fcaSzhanghailiang 2522bd240fcaSzhanghailiang /* Transfer online/offline status between @mem_blk and the guest system. 2523bd240fcaSzhanghailiang * 2524bd240fcaSzhanghailiang * On input either @errp or *@errp must be NULL. 2525bd240fcaSzhanghailiang * 2526bd240fcaSzhanghailiang * In system-to-@mem_blk direction, the following @mem_blk fields are accessed: 2527bd240fcaSzhanghailiang * - R: mem_blk->phys_index 2528bd240fcaSzhanghailiang * - W: mem_blk->online 2529bd240fcaSzhanghailiang * - W: mem_blk->can_offline 2530bd240fcaSzhanghailiang * 2531bd240fcaSzhanghailiang * In @mem_blk-to-system direction, the following @mem_blk fields are accessed: 2532bd240fcaSzhanghailiang * - R: mem_blk->phys_index 2533bd240fcaSzhanghailiang * - R: mem_blk->online 2534bd240fcaSzhanghailiang *- R: mem_blk->can_offline 2535bd240fcaSzhanghailiang * Written members remain unmodified on error. 2536bd240fcaSzhanghailiang */ 2537bd240fcaSzhanghailiang static void transfer_memory_block(GuestMemoryBlock *mem_blk, bool sys2memblk, 2538bd240fcaSzhanghailiang GuestMemoryBlockResponse *result, 2539bd240fcaSzhanghailiang Error **errp) 2540bd240fcaSzhanghailiang { 2541bd240fcaSzhanghailiang char *dirpath; 2542bd240fcaSzhanghailiang int dirfd; 2543bd240fcaSzhanghailiang char *status; 2544bd240fcaSzhanghailiang Error *local_err = NULL; 2545bd240fcaSzhanghailiang 2546bd240fcaSzhanghailiang if (!sys2memblk) { 2547bd240fcaSzhanghailiang DIR *dp; 2548bd240fcaSzhanghailiang 2549bd240fcaSzhanghailiang if (!result) { 2550bd240fcaSzhanghailiang error_setg(errp, "Internal error, 'result' should not be NULL"); 2551bd240fcaSzhanghailiang return; 2552bd240fcaSzhanghailiang } 2553bd240fcaSzhanghailiang errno = 0; 2554bd240fcaSzhanghailiang dp = opendir("/sys/devices/system/memory/"); 2555bd240fcaSzhanghailiang /* if there is no 'memory' directory in sysfs, 2556bd240fcaSzhanghailiang * we think this VM does not support online/offline memory block, 2557bd240fcaSzhanghailiang * any other solution? 2558bd240fcaSzhanghailiang */ 25599879f5acSPhilippe Mathieu-Daudé if (!dp) { 25609879f5acSPhilippe Mathieu-Daudé if (errno == ENOENT) { 2561bd240fcaSzhanghailiang result->response = 2562bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_NOT_SUPPORTED; 25639879f5acSPhilippe Mathieu-Daudé } 2564bd240fcaSzhanghailiang goto out1; 2565bd240fcaSzhanghailiang } 2566bd240fcaSzhanghailiang closedir(dp); 2567bd240fcaSzhanghailiang } 2568bd240fcaSzhanghailiang 2569bd240fcaSzhanghailiang dirpath = g_strdup_printf("/sys/devices/system/memory/memory%" PRId64 "/", 2570bd240fcaSzhanghailiang mem_blk->phys_index); 2571bd240fcaSzhanghailiang dirfd = open(dirpath, O_RDONLY | O_DIRECTORY); 2572bd240fcaSzhanghailiang if (dirfd == -1) { 2573bd240fcaSzhanghailiang if (sys2memblk) { 2574bd240fcaSzhanghailiang error_setg_errno(errp, errno, "open(\"%s\")", dirpath); 2575bd240fcaSzhanghailiang } else { 2576bd240fcaSzhanghailiang if (errno == ENOENT) { 2577bd240fcaSzhanghailiang result->response = GUEST_MEMORY_BLOCK_RESPONSE_TYPE_NOT_FOUND; 2578bd240fcaSzhanghailiang } else { 2579bd240fcaSzhanghailiang result->response = 2580bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_FAILED; 2581bd240fcaSzhanghailiang } 2582bd240fcaSzhanghailiang } 2583bd240fcaSzhanghailiang g_free(dirpath); 2584bd240fcaSzhanghailiang goto out1; 2585bd240fcaSzhanghailiang } 2586bd240fcaSzhanghailiang g_free(dirpath); 2587bd240fcaSzhanghailiang 2588bd240fcaSzhanghailiang status = g_malloc0(10); 2589bd240fcaSzhanghailiang ga_read_sysfs_file(dirfd, "state", status, 10, &local_err); 2590bd240fcaSzhanghailiang if (local_err) { 2591bd240fcaSzhanghailiang /* treat with sysfs file that not exist in old kernel */ 2592bd240fcaSzhanghailiang if (errno == ENOENT) { 2593bd240fcaSzhanghailiang error_free(local_err); 2594bd240fcaSzhanghailiang if (sys2memblk) { 2595bd240fcaSzhanghailiang mem_blk->online = true; 2596bd240fcaSzhanghailiang mem_blk->can_offline = false; 2597bd240fcaSzhanghailiang } else if (!mem_blk->online) { 2598bd240fcaSzhanghailiang result->response = 2599bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_NOT_SUPPORTED; 2600bd240fcaSzhanghailiang } 2601bd240fcaSzhanghailiang } else { 2602bd240fcaSzhanghailiang if (sys2memblk) { 2603bd240fcaSzhanghailiang error_propagate(errp, local_err); 2604bd240fcaSzhanghailiang } else { 2605b368123dSMarkus Armbruster error_free(local_err); 2606bd240fcaSzhanghailiang result->response = 2607bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_FAILED; 2608bd240fcaSzhanghailiang } 2609bd240fcaSzhanghailiang } 2610bd240fcaSzhanghailiang goto out2; 2611bd240fcaSzhanghailiang } 2612bd240fcaSzhanghailiang 2613bd240fcaSzhanghailiang if (sys2memblk) { 2614bd240fcaSzhanghailiang char removable = '0'; 2615bd240fcaSzhanghailiang 2616bd240fcaSzhanghailiang mem_blk->online = (strncmp(status, "online", 6) == 0); 2617bd240fcaSzhanghailiang 2618bd240fcaSzhanghailiang ga_read_sysfs_file(dirfd, "removable", &removable, 1, &local_err); 2619bd240fcaSzhanghailiang if (local_err) { 262067cc32ebSVeres Lajos /* if no 'removable' file, it doesn't support offline mem blk */ 2621bd240fcaSzhanghailiang if (errno == ENOENT) { 2622bd240fcaSzhanghailiang error_free(local_err); 2623bd240fcaSzhanghailiang mem_blk->can_offline = false; 2624bd240fcaSzhanghailiang } else { 2625bd240fcaSzhanghailiang error_propagate(errp, local_err); 2626bd240fcaSzhanghailiang } 2627bd240fcaSzhanghailiang } else { 2628bd240fcaSzhanghailiang mem_blk->can_offline = (removable != '0'); 2629bd240fcaSzhanghailiang } 2630bd240fcaSzhanghailiang } else { 2631bd240fcaSzhanghailiang if (mem_blk->online != (strncmp(status, "online", 6) == 0)) { 26327064024dSMarc-André Lureau const char *new_state = mem_blk->online ? "online" : "offline"; 2633bd240fcaSzhanghailiang 2634bd240fcaSzhanghailiang ga_write_sysfs_file(dirfd, "state", new_state, strlen(new_state), 2635bd240fcaSzhanghailiang &local_err); 2636bd240fcaSzhanghailiang if (local_err) { 2637bd240fcaSzhanghailiang error_free(local_err); 2638bd240fcaSzhanghailiang result->response = 2639bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_FAILED; 2640bd240fcaSzhanghailiang goto out2; 2641bd240fcaSzhanghailiang } 2642bd240fcaSzhanghailiang 2643bd240fcaSzhanghailiang result->response = GUEST_MEMORY_BLOCK_RESPONSE_TYPE_SUCCESS; 2644bd240fcaSzhanghailiang result->has_error_code = false; 2645bd240fcaSzhanghailiang } /* otherwise pretend successful re-(on|off)-lining */ 2646bd240fcaSzhanghailiang } 2647bd240fcaSzhanghailiang g_free(status); 2648bd240fcaSzhanghailiang close(dirfd); 2649bd240fcaSzhanghailiang return; 2650bd240fcaSzhanghailiang 2651bd240fcaSzhanghailiang out2: 2652bd240fcaSzhanghailiang g_free(status); 2653bd240fcaSzhanghailiang close(dirfd); 2654bd240fcaSzhanghailiang out1: 2655bd240fcaSzhanghailiang if (!sys2memblk) { 2656bd240fcaSzhanghailiang result->has_error_code = true; 2657bd240fcaSzhanghailiang result->error_code = errno; 2658bd240fcaSzhanghailiang } 2659bd240fcaSzhanghailiang } 2660bd240fcaSzhanghailiang 2661a065aaa9Szhanghailiang GuestMemoryBlockList *qmp_guest_get_memory_blocks(Error **errp) 2662a065aaa9Szhanghailiang { 2663c3033fd3SEric Blake GuestMemoryBlockList *head, **tail; 2664bd240fcaSzhanghailiang Error *local_err = NULL; 2665bd240fcaSzhanghailiang struct dirent *de; 2666bd240fcaSzhanghailiang DIR *dp; 2667bd240fcaSzhanghailiang 2668bd240fcaSzhanghailiang head = NULL; 2669c3033fd3SEric Blake tail = &head; 2670bd240fcaSzhanghailiang 2671bd240fcaSzhanghailiang dp = opendir("/sys/devices/system/memory/"); 2672bd240fcaSzhanghailiang if (!dp) { 2673f693fe6eSMichael Roth /* it's ok if this happens to be a system that doesn't expose 2674f693fe6eSMichael Roth * memory blocks via sysfs, but otherwise we should report 2675f693fe6eSMichael Roth * an error 2676f693fe6eSMichael Roth */ 2677f693fe6eSMichael Roth if (errno != ENOENT) { 2678bd240fcaSzhanghailiang error_setg_errno(errp, errno, "Can't open directory" 26799af9e0feSMarkus Armbruster "\"/sys/devices/system/memory/\""); 2680f693fe6eSMichael Roth } 2681bd240fcaSzhanghailiang return NULL; 2682bd240fcaSzhanghailiang } 2683bd240fcaSzhanghailiang 2684bd240fcaSzhanghailiang /* Note: the phys_index of memory block may be discontinuous, 2685bd240fcaSzhanghailiang * this is because a memblk is the unit of the Sparse Memory design, which 2686bd240fcaSzhanghailiang * allows discontinuous memory ranges (ex. NUMA), so here we should 2687bd240fcaSzhanghailiang * traverse the memory block directory. 2688bd240fcaSzhanghailiang */ 2689bd240fcaSzhanghailiang while ((de = readdir(dp)) != NULL) { 2690bd240fcaSzhanghailiang GuestMemoryBlock *mem_blk; 2691bd240fcaSzhanghailiang 2692bd240fcaSzhanghailiang if ((strncmp(de->d_name, "memory", 6) != 0) || 2693bd240fcaSzhanghailiang !(de->d_type & DT_DIR)) { 2694bd240fcaSzhanghailiang continue; 2695bd240fcaSzhanghailiang } 2696bd240fcaSzhanghailiang 2697bd240fcaSzhanghailiang mem_blk = g_malloc0(sizeof *mem_blk); 2698bd240fcaSzhanghailiang /* The d_name is "memoryXXX", phys_index is block id, same as XXX */ 2699bd240fcaSzhanghailiang mem_blk->phys_index = strtoul(&de->d_name[6], NULL, 10); 2700bd240fcaSzhanghailiang mem_blk->has_can_offline = true; /* lolspeak ftw */ 2701bd240fcaSzhanghailiang transfer_memory_block(mem_blk, true, NULL, &local_err); 27024155c998SMarkus Armbruster if (local_err) { 27034155c998SMarkus Armbruster break; 27044155c998SMarkus Armbruster } 2705bd240fcaSzhanghailiang 2706c3033fd3SEric Blake QAPI_LIST_APPEND(tail, mem_blk); 2707bd240fcaSzhanghailiang } 2708bd240fcaSzhanghailiang 2709bd240fcaSzhanghailiang closedir(dp); 2710bd240fcaSzhanghailiang if (local_err == NULL) { 2711bd240fcaSzhanghailiang /* there's no guest with zero memory blocks */ 2712bd240fcaSzhanghailiang if (head == NULL) { 2713bd240fcaSzhanghailiang error_setg(errp, "guest reported zero memory blocks!"); 2714bd240fcaSzhanghailiang } 2715bd240fcaSzhanghailiang return head; 2716bd240fcaSzhanghailiang } 2717bd240fcaSzhanghailiang 2718bd240fcaSzhanghailiang qapi_free_GuestMemoryBlockList(head); 2719bd240fcaSzhanghailiang error_propagate(errp, local_err); 2720a065aaa9Szhanghailiang return NULL; 2721a065aaa9Szhanghailiang } 2722a065aaa9Szhanghailiang 2723a065aaa9Szhanghailiang GuestMemoryBlockResponseList * 2724a065aaa9Szhanghailiang qmp_guest_set_memory_blocks(GuestMemoryBlockList *mem_blks, Error **errp) 2725a065aaa9Szhanghailiang { 2726c3033fd3SEric Blake GuestMemoryBlockResponseList *head, **tail; 272732ca7927Szhanghailiang Error *local_err = NULL; 272832ca7927Szhanghailiang 272932ca7927Szhanghailiang head = NULL; 2730c3033fd3SEric Blake tail = &head; 273132ca7927Szhanghailiang 273232ca7927Szhanghailiang while (mem_blks != NULL) { 273332ca7927Szhanghailiang GuestMemoryBlockResponse *result; 273432ca7927Szhanghailiang GuestMemoryBlock *current_mem_blk = mem_blks->value; 273532ca7927Szhanghailiang 273632ca7927Szhanghailiang result = g_malloc0(sizeof(*result)); 273732ca7927Szhanghailiang result->phys_index = current_mem_blk->phys_index; 273832ca7927Szhanghailiang transfer_memory_block(current_mem_blk, false, result, &local_err); 273932ca7927Szhanghailiang if (local_err) { /* should never happen */ 274032ca7927Szhanghailiang goto err; 274132ca7927Szhanghailiang } 274232ca7927Szhanghailiang 2743c3033fd3SEric Blake QAPI_LIST_APPEND(tail, result); 274432ca7927Szhanghailiang mem_blks = mem_blks->next; 274532ca7927Szhanghailiang } 274632ca7927Szhanghailiang 274732ca7927Szhanghailiang return head; 274832ca7927Szhanghailiang err: 274932ca7927Szhanghailiang qapi_free_GuestMemoryBlockResponseList(head); 275032ca7927Szhanghailiang error_propagate(errp, local_err); 2751a065aaa9Szhanghailiang return NULL; 2752a065aaa9Szhanghailiang } 2753a065aaa9Szhanghailiang 2754a065aaa9Szhanghailiang GuestMemoryBlockInfo *qmp_guest_get_memory_block_info(Error **errp) 2755a065aaa9Szhanghailiang { 2756ef82b60bSzhanghailiang Error *local_err = NULL; 2757ef82b60bSzhanghailiang char *dirpath; 2758ef82b60bSzhanghailiang int dirfd; 2759ef82b60bSzhanghailiang char *buf; 2760ef82b60bSzhanghailiang GuestMemoryBlockInfo *info; 2761ef82b60bSzhanghailiang 2762ef82b60bSzhanghailiang dirpath = g_strdup_printf("/sys/devices/system/memory/"); 2763ef82b60bSzhanghailiang dirfd = open(dirpath, O_RDONLY | O_DIRECTORY); 2764ef82b60bSzhanghailiang if (dirfd == -1) { 2765ef82b60bSzhanghailiang error_setg_errno(errp, errno, "open(\"%s\")", dirpath); 2766ef82b60bSzhanghailiang g_free(dirpath); 2767a065aaa9Szhanghailiang return NULL; 2768a065aaa9Szhanghailiang } 2769ef82b60bSzhanghailiang g_free(dirpath); 2770ef82b60bSzhanghailiang 2771ef82b60bSzhanghailiang buf = g_malloc0(20); 2772ef82b60bSzhanghailiang ga_read_sysfs_file(dirfd, "block_size_bytes", buf, 20, &local_err); 27738ce1ee46SShannon Zhao close(dirfd); 2774ef82b60bSzhanghailiang if (local_err) { 2775ef82b60bSzhanghailiang g_free(buf); 2776ef82b60bSzhanghailiang error_propagate(errp, local_err); 2777ef82b60bSzhanghailiang return NULL; 2778ef82b60bSzhanghailiang } 2779ef82b60bSzhanghailiang 2780ef82b60bSzhanghailiang info = g_new0(GuestMemoryBlockInfo, 1); 2781ef82b60bSzhanghailiang info->size = strtol(buf, NULL, 16); /* the unit is bytes */ 2782ef82b60bSzhanghailiang 2783ef82b60bSzhanghailiang g_free(buf); 2784ef82b60bSzhanghailiang 2785ef82b60bSzhanghailiang return info; 2786ef82b60bSzhanghailiang } 2787a065aaa9Szhanghailiang 27883569664eSluzhipeng #define MAX_NAME_LEN 128 27893569664eSluzhipeng static GuestDiskStatsInfoList *guest_get_diskstats(Error **errp) 27903569664eSluzhipeng { 27913569664eSluzhipeng #ifdef CONFIG_LINUX 27923569664eSluzhipeng GuestDiskStatsInfoList *head = NULL, **tail = &head; 27933569664eSluzhipeng const char *diskstats = "/proc/diskstats"; 27943569664eSluzhipeng FILE *fp; 27953569664eSluzhipeng size_t n; 27963569664eSluzhipeng char *line = NULL; 27973569664eSluzhipeng 27983569664eSluzhipeng fp = fopen(diskstats, "r"); 27993569664eSluzhipeng if (fp == NULL) { 28003569664eSluzhipeng error_setg_errno(errp, errno, "open(\"%s\")", diskstats); 28013569664eSluzhipeng return NULL; 28023569664eSluzhipeng } 28033569664eSluzhipeng 28043569664eSluzhipeng while (getline(&line, &n, fp) != -1) { 28053569664eSluzhipeng g_autofree GuestDiskStatsInfo *diskstatinfo = NULL; 28063569664eSluzhipeng g_autofree GuestDiskStats *diskstat = NULL; 28073569664eSluzhipeng char dev_name[MAX_NAME_LEN]; 28083569664eSluzhipeng unsigned int ios_pgr, tot_ticks, rq_ticks, wr_ticks, dc_ticks, fl_ticks; 28093569664eSluzhipeng unsigned long rd_ios, rd_merges_or_rd_sec, rd_ticks_or_wr_sec, wr_ios; 28103569664eSluzhipeng unsigned long wr_merges, rd_sec_or_wr_ios, wr_sec; 28113569664eSluzhipeng unsigned long dc_ios, dc_merges, dc_sec, fl_ios; 28123569664eSluzhipeng unsigned int major, minor; 28133569664eSluzhipeng int i; 28143569664eSluzhipeng 28153569664eSluzhipeng i = sscanf(line, "%u %u %s %lu %lu %lu" 28163569664eSluzhipeng "%lu %lu %lu %lu %u %u %u %u" 28173569664eSluzhipeng "%lu %lu %lu %u %lu %u", 28183569664eSluzhipeng &major, &minor, dev_name, 28193569664eSluzhipeng &rd_ios, &rd_merges_or_rd_sec, &rd_sec_or_wr_ios, 28203569664eSluzhipeng &rd_ticks_or_wr_sec, &wr_ios, &wr_merges, &wr_sec, 28213569664eSluzhipeng &wr_ticks, &ios_pgr, &tot_ticks, &rq_ticks, 28223569664eSluzhipeng &dc_ios, &dc_merges, &dc_sec, &dc_ticks, 28233569664eSluzhipeng &fl_ios, &fl_ticks); 28243569664eSluzhipeng 28253569664eSluzhipeng if (i < 7) { 28263569664eSluzhipeng continue; 28273569664eSluzhipeng } 28283569664eSluzhipeng 28293569664eSluzhipeng diskstatinfo = g_new0(GuestDiskStatsInfo, 1); 28303569664eSluzhipeng diskstatinfo->name = g_strdup(dev_name); 28313569664eSluzhipeng diskstatinfo->major = major; 28323569664eSluzhipeng diskstatinfo->minor = minor; 28333569664eSluzhipeng 28343569664eSluzhipeng diskstat = g_new0(GuestDiskStats, 1); 28353569664eSluzhipeng if (i == 7) { 28363569664eSluzhipeng diskstat->has_read_ios = true; 28373569664eSluzhipeng diskstat->read_ios = rd_ios; 28383569664eSluzhipeng diskstat->has_read_sectors = true; 28393569664eSluzhipeng diskstat->read_sectors = rd_merges_or_rd_sec; 28403569664eSluzhipeng diskstat->has_write_ios = true; 28413569664eSluzhipeng diskstat->write_ios = rd_sec_or_wr_ios; 28423569664eSluzhipeng diskstat->has_write_sectors = true; 28433569664eSluzhipeng diskstat->write_sectors = rd_ticks_or_wr_sec; 28443569664eSluzhipeng } 28453569664eSluzhipeng if (i >= 14) { 28463569664eSluzhipeng diskstat->has_read_ios = true; 28473569664eSluzhipeng diskstat->read_ios = rd_ios; 28483569664eSluzhipeng diskstat->has_read_sectors = true; 28493569664eSluzhipeng diskstat->read_sectors = rd_sec_or_wr_ios; 28503569664eSluzhipeng diskstat->has_read_merges = true; 28513569664eSluzhipeng diskstat->read_merges = rd_merges_or_rd_sec; 28523569664eSluzhipeng diskstat->has_read_ticks = true; 28533569664eSluzhipeng diskstat->read_ticks = rd_ticks_or_wr_sec; 28543569664eSluzhipeng diskstat->has_write_ios = true; 28553569664eSluzhipeng diskstat->write_ios = wr_ios; 28563569664eSluzhipeng diskstat->has_write_sectors = true; 28573569664eSluzhipeng diskstat->write_sectors = wr_sec; 28583569664eSluzhipeng diskstat->has_write_merges = true; 28593569664eSluzhipeng diskstat->write_merges = wr_merges; 28603569664eSluzhipeng diskstat->has_write_ticks = true; 28613569664eSluzhipeng diskstat->write_ticks = wr_ticks; 28623569664eSluzhipeng diskstat->has_ios_pgr = true; 28633569664eSluzhipeng diskstat->ios_pgr = ios_pgr; 28643569664eSluzhipeng diskstat->has_total_ticks = true; 28653569664eSluzhipeng diskstat->total_ticks = tot_ticks; 28663569664eSluzhipeng diskstat->has_weight_ticks = true; 28673569664eSluzhipeng diskstat->weight_ticks = rq_ticks; 28683569664eSluzhipeng } 28693569664eSluzhipeng if (i >= 18) { 28703569664eSluzhipeng diskstat->has_discard_ios = true; 28713569664eSluzhipeng diskstat->discard_ios = dc_ios; 28723569664eSluzhipeng diskstat->has_discard_merges = true; 28733569664eSluzhipeng diskstat->discard_merges = dc_merges; 28743569664eSluzhipeng diskstat->has_discard_sectors = true; 28753569664eSluzhipeng diskstat->discard_sectors = dc_sec; 28763569664eSluzhipeng diskstat->has_discard_ticks = true; 28773569664eSluzhipeng diskstat->discard_ticks = dc_ticks; 28783569664eSluzhipeng } 28793569664eSluzhipeng if (i >= 20) { 28803569664eSluzhipeng diskstat->has_flush_ios = true; 28813569664eSluzhipeng diskstat->flush_ios = fl_ios; 28823569664eSluzhipeng diskstat->has_flush_ticks = true; 28833569664eSluzhipeng diskstat->flush_ticks = fl_ticks; 28843569664eSluzhipeng } 28853569664eSluzhipeng 28863569664eSluzhipeng diskstatinfo->stats = g_steal_pointer(&diskstat); 28873569664eSluzhipeng QAPI_LIST_APPEND(tail, diskstatinfo); 28883569664eSluzhipeng diskstatinfo = NULL; 28893569664eSluzhipeng } 28903569664eSluzhipeng free(line); 28913569664eSluzhipeng fclose(fp); 28923569664eSluzhipeng return head; 28933569664eSluzhipeng #else 28943569664eSluzhipeng g_debug("disk stats reporting available only for Linux"); 28953569664eSluzhipeng return NULL; 28963569664eSluzhipeng #endif 28973569664eSluzhipeng } 28983569664eSluzhipeng 28993569664eSluzhipeng GuestDiskStatsInfoList *qmp_guest_get_diskstats(Error **errp) 29003569664eSluzhipeng { 29013569664eSluzhipeng return guest_get_diskstats(errp); 29023569664eSluzhipeng } 29033569664eSluzhipeng 29041db8a0b0Szhenwei pi GuestCpuStatsList *qmp_guest_get_cpustats(Error **errp) 29051db8a0b0Szhenwei pi { 29061db8a0b0Szhenwei pi GuestCpuStatsList *head = NULL, **tail = &head; 29071db8a0b0Szhenwei pi const char *cpustats = "/proc/stat"; 29081db8a0b0Szhenwei pi int clk_tck = sysconf(_SC_CLK_TCK); 29091db8a0b0Szhenwei pi FILE *fp; 29101db8a0b0Szhenwei pi size_t n; 29111db8a0b0Szhenwei pi char *line = NULL; 29121db8a0b0Szhenwei pi 29131db8a0b0Szhenwei pi fp = fopen(cpustats, "r"); 29141db8a0b0Szhenwei pi if (fp == NULL) { 29151db8a0b0Szhenwei pi error_setg_errno(errp, errno, "open(\"%s\")", cpustats); 29161db8a0b0Szhenwei pi return NULL; 29171db8a0b0Szhenwei pi } 29181db8a0b0Szhenwei pi 29191db8a0b0Szhenwei pi while (getline(&line, &n, fp) != -1) { 29201db8a0b0Szhenwei pi GuestCpuStats *cpustat = NULL; 29211db8a0b0Szhenwei pi GuestLinuxCpuStats *linuxcpustat; 29221db8a0b0Szhenwei pi int i; 29231db8a0b0Szhenwei pi unsigned long user, system, idle, iowait, irq, softirq, steal, guest; 29241db8a0b0Szhenwei pi unsigned long nice, guest_nice; 29251db8a0b0Szhenwei pi char name[64]; 29261db8a0b0Szhenwei pi 29271db8a0b0Szhenwei pi i = sscanf(line, "%s %lu %lu %lu %lu %lu %lu %lu %lu %lu %lu", 29281db8a0b0Szhenwei pi name, &user, &nice, &system, &idle, &iowait, &irq, &softirq, 29291db8a0b0Szhenwei pi &steal, &guest, &guest_nice); 29301db8a0b0Szhenwei pi 29311db8a0b0Szhenwei pi /* drop "cpu 1 2 3 ...", get "cpuX 1 2 3 ..." only */ 29321db8a0b0Szhenwei pi if ((i == EOF) || strncmp(name, "cpu", 3) || (name[3] == '\0')) { 29331db8a0b0Szhenwei pi continue; 29341db8a0b0Szhenwei pi } 29351db8a0b0Szhenwei pi 29361db8a0b0Szhenwei pi if (i < 5) { 29371db8a0b0Szhenwei pi slog("Parsing cpu stat from %s failed, see \"man proc\"", cpustats); 29381db8a0b0Szhenwei pi break; 29391db8a0b0Szhenwei pi } 29401db8a0b0Szhenwei pi 29411db8a0b0Szhenwei pi cpustat = g_new0(GuestCpuStats, 1); 29421db8a0b0Szhenwei pi cpustat->type = GUEST_CPU_STATS_TYPE_LINUX; 29431db8a0b0Szhenwei pi 29441db8a0b0Szhenwei pi linuxcpustat = &cpustat->u.q_linux; 29451db8a0b0Szhenwei pi linuxcpustat->cpu = atoi(&name[3]); 29461db8a0b0Szhenwei pi linuxcpustat->user = user * 1000 / clk_tck; 29471db8a0b0Szhenwei pi linuxcpustat->nice = nice * 1000 / clk_tck; 29481db8a0b0Szhenwei pi linuxcpustat->system = system * 1000 / clk_tck; 29491db8a0b0Szhenwei pi linuxcpustat->idle = idle * 1000 / clk_tck; 29501db8a0b0Szhenwei pi 29511db8a0b0Szhenwei pi if (i > 5) { 29521db8a0b0Szhenwei pi linuxcpustat->has_iowait = true; 29531db8a0b0Szhenwei pi linuxcpustat->iowait = iowait * 1000 / clk_tck; 29541db8a0b0Szhenwei pi } 29551db8a0b0Szhenwei pi 29561db8a0b0Szhenwei pi if (i > 6) { 29571db8a0b0Szhenwei pi linuxcpustat->has_irq = true; 29581db8a0b0Szhenwei pi linuxcpustat->irq = irq * 1000 / clk_tck; 29591db8a0b0Szhenwei pi linuxcpustat->has_softirq = true; 29601db8a0b0Szhenwei pi linuxcpustat->softirq = softirq * 1000 / clk_tck; 29611db8a0b0Szhenwei pi } 29621db8a0b0Szhenwei pi 29631db8a0b0Szhenwei pi if (i > 8) { 29641db8a0b0Szhenwei pi linuxcpustat->has_steal = true; 29651db8a0b0Szhenwei pi linuxcpustat->steal = steal * 1000 / clk_tck; 29661db8a0b0Szhenwei pi } 29671db8a0b0Szhenwei pi 29681db8a0b0Szhenwei pi if (i > 9) { 29691db8a0b0Szhenwei pi linuxcpustat->has_guest = true; 29701db8a0b0Szhenwei pi linuxcpustat->guest = guest * 1000 / clk_tck; 29711db8a0b0Szhenwei pi } 29721db8a0b0Szhenwei pi 29731db8a0b0Szhenwei pi if (i > 10) { 29741db8a0b0Szhenwei pi linuxcpustat->has_guest = true; 29751db8a0b0Szhenwei pi linuxcpustat->guest = guest * 1000 / clk_tck; 29761db8a0b0Szhenwei pi linuxcpustat->has_guestnice = true; 29771db8a0b0Szhenwei pi linuxcpustat->guestnice = guest_nice * 1000 / clk_tck; 29781db8a0b0Szhenwei pi } 29791db8a0b0Szhenwei pi 29801db8a0b0Szhenwei pi QAPI_LIST_APPEND(tail, cpustat); 29811db8a0b0Szhenwei pi } 29821db8a0b0Szhenwei pi 29831db8a0b0Szhenwei pi free(line); 29841db8a0b0Szhenwei pi fclose(fp); 29851db8a0b0Szhenwei pi return head; 29861db8a0b0Szhenwei pi } 29871db8a0b0Szhenwei pi 2988e72c3f2eSMichael Roth #else /* defined(__linux__) */ 2989e72c3f2eSMichael Roth 299077dbc81bSMarkus Armbruster void qmp_guest_suspend_disk(Error **errp) 2991e72c3f2eSMichael Roth { 2992c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2993e72c3f2eSMichael Roth } 2994e72c3f2eSMichael Roth 299577dbc81bSMarkus Armbruster void qmp_guest_suspend_ram(Error **errp) 2996e72c3f2eSMichael Roth { 2997c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2998e72c3f2eSMichael Roth } 2999e72c3f2eSMichael Roth 300077dbc81bSMarkus Armbruster void qmp_guest_suspend_hybrid(Error **errp) 3001e72c3f2eSMichael Roth { 3002c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3003e72c3f2eSMichael Roth } 3004e72c3f2eSMichael Roth 3005d2baff62SLaszlo Ersek GuestLogicalProcessorList *qmp_guest_get_vcpus(Error **errp) 3006d2baff62SLaszlo Ersek { 3007c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3008d2baff62SLaszlo Ersek return NULL; 3009d2baff62SLaszlo Ersek } 3010d2baff62SLaszlo Ersek 3011cbb65fc2SLaszlo Ersek int64_t qmp_guest_set_vcpus(GuestLogicalProcessorList *vcpus, Error **errp) 3012cbb65fc2SLaszlo Ersek { 3013c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3014cbb65fc2SLaszlo Ersek return -1; 3015cbb65fc2SLaszlo Ersek } 3016cbb65fc2SLaszlo Ersek 3017215a2771SDaniel P. Berrange void qmp_guest_set_user_password(const char *username, 3018215a2771SDaniel P. Berrange const char *password, 3019215a2771SDaniel P. Berrange bool crypted, 3020215a2771SDaniel P. Berrange Error **errp) 3021215a2771SDaniel P. Berrange { 3022c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3023215a2771SDaniel P. Berrange } 3024215a2771SDaniel P. Berrange 3025a065aaa9Szhanghailiang GuestMemoryBlockList *qmp_guest_get_memory_blocks(Error **errp) 3026a065aaa9Szhanghailiang { 3027c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3028a065aaa9Szhanghailiang return NULL; 3029a065aaa9Szhanghailiang } 3030a065aaa9Szhanghailiang 3031a065aaa9Szhanghailiang GuestMemoryBlockResponseList * 3032a065aaa9Szhanghailiang qmp_guest_set_memory_blocks(GuestMemoryBlockList *mem_blks, Error **errp) 3033a065aaa9Szhanghailiang { 3034c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3035a065aaa9Szhanghailiang return NULL; 3036a065aaa9Szhanghailiang } 3037a065aaa9Szhanghailiang 3038a065aaa9Szhanghailiang GuestMemoryBlockInfo *qmp_guest_get_memory_block_info(Error **errp) 3039a065aaa9Szhanghailiang { 3040c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3041a065aaa9Szhanghailiang return NULL; 3042a065aaa9Szhanghailiang } 3043a065aaa9Szhanghailiang 3044e72c3f2eSMichael Roth #endif 3045e72c3f2eSMichael Roth 304659e35c7bSAndrew Deason #ifdef HAVE_GETIFADDRS 304759e35c7bSAndrew Deason static GuestNetworkInterface * 304859e35c7bSAndrew Deason guest_find_interface(GuestNetworkInterfaceList *head, 304959e35c7bSAndrew Deason const char *name) 305059e35c7bSAndrew Deason { 305159e35c7bSAndrew Deason for (; head; head = head->next) { 305259e35c7bSAndrew Deason if (strcmp(head->value->name, name) == 0) { 305359e35c7bSAndrew Deason return head->value; 305459e35c7bSAndrew Deason } 305559e35c7bSAndrew Deason } 305659e35c7bSAndrew Deason 305759e35c7bSAndrew Deason return NULL; 305859e35c7bSAndrew Deason } 305959e35c7bSAndrew Deason 306059e35c7bSAndrew Deason static int guest_get_network_stats(const char *name, 306159e35c7bSAndrew Deason GuestNetworkInterfaceStat *stats) 306259e35c7bSAndrew Deason { 306370335c46SAndrew Deason #ifdef CONFIG_LINUX 306459e35c7bSAndrew Deason int name_len; 306559e35c7bSAndrew Deason char const *devinfo = "/proc/net/dev"; 306659e35c7bSAndrew Deason FILE *fp; 306759e35c7bSAndrew Deason char *line = NULL, *colon; 306859e35c7bSAndrew Deason size_t n = 0; 306959e35c7bSAndrew Deason fp = fopen(devinfo, "r"); 307059e35c7bSAndrew Deason if (!fp) { 3071a539dc8aSAndrew Deason g_debug("failed to open network stats %s: %s", devinfo, 3072a539dc8aSAndrew Deason g_strerror(errno)); 307359e35c7bSAndrew Deason return -1; 307459e35c7bSAndrew Deason } 307559e35c7bSAndrew Deason name_len = strlen(name); 307659e35c7bSAndrew Deason while (getline(&line, &n, fp) != -1) { 307759e35c7bSAndrew Deason long long dummy; 307859e35c7bSAndrew Deason long long rx_bytes; 307959e35c7bSAndrew Deason long long rx_packets; 308059e35c7bSAndrew Deason long long rx_errs; 308159e35c7bSAndrew Deason long long rx_dropped; 308259e35c7bSAndrew Deason long long tx_bytes; 308359e35c7bSAndrew Deason long long tx_packets; 308459e35c7bSAndrew Deason long long tx_errs; 308559e35c7bSAndrew Deason long long tx_dropped; 308659e35c7bSAndrew Deason char *trim_line; 308759e35c7bSAndrew Deason trim_line = g_strchug(line); 308859e35c7bSAndrew Deason if (trim_line[0] == '\0') { 308959e35c7bSAndrew Deason continue; 309059e35c7bSAndrew Deason } 309159e35c7bSAndrew Deason colon = strchr(trim_line, ':'); 309259e35c7bSAndrew Deason if (!colon) { 309359e35c7bSAndrew Deason continue; 309459e35c7bSAndrew Deason } 309559e35c7bSAndrew Deason if (colon - name_len == trim_line && 309659e35c7bSAndrew Deason strncmp(trim_line, name, name_len) == 0) { 309759e35c7bSAndrew Deason if (sscanf(colon + 1, 309859e35c7bSAndrew Deason "%lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld", 309959e35c7bSAndrew Deason &rx_bytes, &rx_packets, &rx_errs, &rx_dropped, 310059e35c7bSAndrew Deason &dummy, &dummy, &dummy, &dummy, 310159e35c7bSAndrew Deason &tx_bytes, &tx_packets, &tx_errs, &tx_dropped, 310259e35c7bSAndrew Deason &dummy, &dummy, &dummy, &dummy) != 16) { 310359e35c7bSAndrew Deason continue; 310459e35c7bSAndrew Deason } 310559e35c7bSAndrew Deason stats->rx_bytes = rx_bytes; 310659e35c7bSAndrew Deason stats->rx_packets = rx_packets; 310759e35c7bSAndrew Deason stats->rx_errs = rx_errs; 310859e35c7bSAndrew Deason stats->rx_dropped = rx_dropped; 310959e35c7bSAndrew Deason stats->tx_bytes = tx_bytes; 311059e35c7bSAndrew Deason stats->tx_packets = tx_packets; 311159e35c7bSAndrew Deason stats->tx_errs = tx_errs; 311259e35c7bSAndrew Deason stats->tx_dropped = tx_dropped; 311359e35c7bSAndrew Deason fclose(fp); 311459e35c7bSAndrew Deason g_free(line); 311559e35c7bSAndrew Deason return 0; 311659e35c7bSAndrew Deason } 311759e35c7bSAndrew Deason } 311859e35c7bSAndrew Deason fclose(fp); 311959e35c7bSAndrew Deason g_free(line); 312059e35c7bSAndrew Deason g_debug("/proc/net/dev: Interface '%s' not found", name); 3121a539dc8aSAndrew Deason #else /* !CONFIG_LINUX */ 3122a539dc8aSAndrew Deason g_debug("Network stats reporting available only for Linux"); 3123a539dc8aSAndrew Deason #endif /* !CONFIG_LINUX */ 312459e35c7bSAndrew Deason return -1; 312559e35c7bSAndrew Deason } 312659e35c7bSAndrew Deason 312759e35c7bSAndrew Deason /* 312859e35c7bSAndrew Deason * Build information about guest interfaces 312959e35c7bSAndrew Deason */ 313059e35c7bSAndrew Deason GuestNetworkInterfaceList *qmp_guest_network_get_interfaces(Error **errp) 313159e35c7bSAndrew Deason { 313259e35c7bSAndrew Deason GuestNetworkInterfaceList *head = NULL, **tail = &head; 313359e35c7bSAndrew Deason struct ifaddrs *ifap, *ifa; 313459e35c7bSAndrew Deason 313559e35c7bSAndrew Deason if (getifaddrs(&ifap) < 0) { 313659e35c7bSAndrew Deason error_setg_errno(errp, errno, "getifaddrs failed"); 313759e35c7bSAndrew Deason goto error; 313859e35c7bSAndrew Deason } 313959e35c7bSAndrew Deason 314059e35c7bSAndrew Deason for (ifa = ifap; ifa; ifa = ifa->ifa_next) { 314159e35c7bSAndrew Deason GuestNetworkInterface *info; 314259e35c7bSAndrew Deason GuestIpAddressList **address_tail; 314359e35c7bSAndrew Deason GuestIpAddress *address_item = NULL; 314459e35c7bSAndrew Deason GuestNetworkInterfaceStat *interface_stat = NULL; 314559e35c7bSAndrew Deason char addr4[INET_ADDRSTRLEN]; 314659e35c7bSAndrew Deason char addr6[INET6_ADDRSTRLEN]; 314759e35c7bSAndrew Deason int sock; 314859e35c7bSAndrew Deason struct ifreq ifr; 314959e35c7bSAndrew Deason unsigned char *mac_addr; 315059e35c7bSAndrew Deason void *p; 315159e35c7bSAndrew Deason 315259e35c7bSAndrew Deason g_debug("Processing %s interface", ifa->ifa_name); 315359e35c7bSAndrew Deason 315459e35c7bSAndrew Deason info = guest_find_interface(head, ifa->ifa_name); 315559e35c7bSAndrew Deason 315659e35c7bSAndrew Deason if (!info) { 315759e35c7bSAndrew Deason info = g_malloc0(sizeof(*info)); 315859e35c7bSAndrew Deason info->name = g_strdup(ifa->ifa_name); 315959e35c7bSAndrew Deason 316059e35c7bSAndrew Deason QAPI_LIST_APPEND(tail, info); 316159e35c7bSAndrew Deason } 316259e35c7bSAndrew Deason 3163aec0730eSAndrew Deason if (!info->has_hardware_address) { 316459e35c7bSAndrew Deason /* we haven't obtained HW address yet */ 316559e35c7bSAndrew Deason sock = socket(PF_INET, SOCK_STREAM, 0); 316659e35c7bSAndrew Deason if (sock == -1) { 316759e35c7bSAndrew Deason error_setg_errno(errp, errno, "failed to create socket"); 316859e35c7bSAndrew Deason goto error; 316959e35c7bSAndrew Deason } 317059e35c7bSAndrew Deason 317159e35c7bSAndrew Deason memset(&ifr, 0, sizeof(ifr)); 317259e35c7bSAndrew Deason pstrcpy(ifr.ifr_name, IF_NAMESIZE, info->name); 317359e35c7bSAndrew Deason if (ioctl(sock, SIOCGIFHWADDR, &ifr) == -1) { 3174aec0730eSAndrew Deason /* 3175aec0730eSAndrew Deason * We can't get the hw addr of this interface, but that's not a 3176aec0730eSAndrew Deason * fatal error. Don't set info->hardware_address, but keep 3177aec0730eSAndrew Deason * going. 3178aec0730eSAndrew Deason */ 3179aec0730eSAndrew Deason if (errno == EADDRNOTAVAIL) { 3180aec0730eSAndrew Deason /* The interface doesn't have a hw addr (e.g. loopback). */ 3181aec0730eSAndrew Deason g_debug("failed to get MAC address of %s: %s", 3182aec0730eSAndrew Deason ifa->ifa_name, strerror(errno)); 3183aec0730eSAndrew Deason } else{ 3184aec0730eSAndrew Deason g_warning("failed to get MAC address of %s: %s", 3185aec0730eSAndrew Deason ifa->ifa_name, strerror(errno)); 318659e35c7bSAndrew Deason } 318759e35c7bSAndrew Deason 3188aec0730eSAndrew Deason } else { 318970335c46SAndrew Deason #ifdef CONFIG_SOLARIS 319070335c46SAndrew Deason mac_addr = (unsigned char *) &ifr.ifr_addr.sa_data; 319170335c46SAndrew Deason #else 319259e35c7bSAndrew Deason mac_addr = (unsigned char *) &ifr.ifr_hwaddr.sa_data; 319370335c46SAndrew Deason #endif 319459e35c7bSAndrew Deason info->hardware_address = 319559e35c7bSAndrew Deason g_strdup_printf("%02x:%02x:%02x:%02x:%02x:%02x", 319659e35c7bSAndrew Deason (int) mac_addr[0], (int) mac_addr[1], 319759e35c7bSAndrew Deason (int) mac_addr[2], (int) mac_addr[3], 319859e35c7bSAndrew Deason (int) mac_addr[4], (int) mac_addr[5]); 319959e35c7bSAndrew Deason 320059e35c7bSAndrew Deason info->has_hardware_address = true; 320159e35c7bSAndrew Deason } 3202aec0730eSAndrew Deason close(sock); 3203aec0730eSAndrew Deason } 320459e35c7bSAndrew Deason 320559e35c7bSAndrew Deason if (ifa->ifa_addr && 320659e35c7bSAndrew Deason ifa->ifa_addr->sa_family == AF_INET) { 320759e35c7bSAndrew Deason /* interface with IPv4 address */ 320859e35c7bSAndrew Deason p = &((struct sockaddr_in *)ifa->ifa_addr)->sin_addr; 320959e35c7bSAndrew Deason if (!inet_ntop(AF_INET, p, addr4, sizeof(addr4))) { 321059e35c7bSAndrew Deason error_setg_errno(errp, errno, "inet_ntop failed"); 321159e35c7bSAndrew Deason goto error; 321259e35c7bSAndrew Deason } 321359e35c7bSAndrew Deason 321459e35c7bSAndrew Deason address_item = g_malloc0(sizeof(*address_item)); 321559e35c7bSAndrew Deason address_item->ip_address = g_strdup(addr4); 321659e35c7bSAndrew Deason address_item->ip_address_type = GUEST_IP_ADDRESS_TYPE_IPV4; 321759e35c7bSAndrew Deason 321859e35c7bSAndrew Deason if (ifa->ifa_netmask) { 321959e35c7bSAndrew Deason /* Count the number of set bits in netmask. 322059e35c7bSAndrew Deason * This is safe as '1' and '0' cannot be shuffled in netmask. */ 322159e35c7bSAndrew Deason p = &((struct sockaddr_in *)ifa->ifa_netmask)->sin_addr; 322259e35c7bSAndrew Deason address_item->prefix = ctpop32(((uint32_t *) p)[0]); 322359e35c7bSAndrew Deason } 322459e35c7bSAndrew Deason } else if (ifa->ifa_addr && 322559e35c7bSAndrew Deason ifa->ifa_addr->sa_family == AF_INET6) { 322659e35c7bSAndrew Deason /* interface with IPv6 address */ 322759e35c7bSAndrew Deason p = &((struct sockaddr_in6 *)ifa->ifa_addr)->sin6_addr; 322859e35c7bSAndrew Deason if (!inet_ntop(AF_INET6, p, addr6, sizeof(addr6))) { 322959e35c7bSAndrew Deason error_setg_errno(errp, errno, "inet_ntop failed"); 323059e35c7bSAndrew Deason goto error; 323159e35c7bSAndrew Deason } 323259e35c7bSAndrew Deason 323359e35c7bSAndrew Deason address_item = g_malloc0(sizeof(*address_item)); 323459e35c7bSAndrew Deason address_item->ip_address = g_strdup(addr6); 323559e35c7bSAndrew Deason address_item->ip_address_type = GUEST_IP_ADDRESS_TYPE_IPV6; 323659e35c7bSAndrew Deason 323759e35c7bSAndrew Deason if (ifa->ifa_netmask) { 323859e35c7bSAndrew Deason /* Count the number of set bits in netmask. 323959e35c7bSAndrew Deason * This is safe as '1' and '0' cannot be shuffled in netmask. */ 324059e35c7bSAndrew Deason p = &((struct sockaddr_in6 *)ifa->ifa_netmask)->sin6_addr; 324159e35c7bSAndrew Deason address_item->prefix = 324259e35c7bSAndrew Deason ctpop32(((uint32_t *) p)[0]) + 324359e35c7bSAndrew Deason ctpop32(((uint32_t *) p)[1]) + 324459e35c7bSAndrew Deason ctpop32(((uint32_t *) p)[2]) + 324559e35c7bSAndrew Deason ctpop32(((uint32_t *) p)[3]); 324659e35c7bSAndrew Deason } 324759e35c7bSAndrew Deason } 324859e35c7bSAndrew Deason 324959e35c7bSAndrew Deason if (!address_item) { 325059e35c7bSAndrew Deason continue; 325159e35c7bSAndrew Deason } 325259e35c7bSAndrew Deason 325359e35c7bSAndrew Deason address_tail = &info->ip_addresses; 325459e35c7bSAndrew Deason while (*address_tail) { 325559e35c7bSAndrew Deason address_tail = &(*address_tail)->next; 325659e35c7bSAndrew Deason } 325759e35c7bSAndrew Deason QAPI_LIST_APPEND(address_tail, address_item); 325859e35c7bSAndrew Deason 325959e35c7bSAndrew Deason info->has_ip_addresses = true; 326059e35c7bSAndrew Deason 326159e35c7bSAndrew Deason if (!info->has_statistics) { 326259e35c7bSAndrew Deason interface_stat = g_malloc0(sizeof(*interface_stat)); 326359e35c7bSAndrew Deason if (guest_get_network_stats(info->name, interface_stat) == -1) { 326459e35c7bSAndrew Deason info->has_statistics = false; 326559e35c7bSAndrew Deason g_free(interface_stat); 326659e35c7bSAndrew Deason } else { 326759e35c7bSAndrew Deason info->statistics = interface_stat; 326859e35c7bSAndrew Deason info->has_statistics = true; 326959e35c7bSAndrew Deason } 327059e35c7bSAndrew Deason } 327159e35c7bSAndrew Deason } 327259e35c7bSAndrew Deason 327359e35c7bSAndrew Deason freeifaddrs(ifap); 327459e35c7bSAndrew Deason return head; 327559e35c7bSAndrew Deason 327659e35c7bSAndrew Deason error: 327759e35c7bSAndrew Deason freeifaddrs(ifap); 327859e35c7bSAndrew Deason qapi_free_GuestNetworkInterfaceList(head); 327959e35c7bSAndrew Deason return NULL; 328059e35c7bSAndrew Deason } 328159e35c7bSAndrew Deason 328259e35c7bSAndrew Deason #else 328359e35c7bSAndrew Deason 328459e35c7bSAndrew Deason GuestNetworkInterfaceList *qmp_guest_network_get_interfaces(Error **errp) 328559e35c7bSAndrew Deason { 328659e35c7bSAndrew Deason error_setg(errp, QERR_UNSUPPORTED); 328759e35c7bSAndrew Deason return NULL; 328859e35c7bSAndrew Deason } 328959e35c7bSAndrew Deason 329059e35c7bSAndrew Deason #endif /* HAVE_GETIFADDRS */ 329159e35c7bSAndrew Deason 3292d35d4cb5SMichael Roth #if !defined(CONFIG_FSFREEZE) 3293d35d4cb5SMichael Roth 329446d4c572STomoki Sekiyama GuestFilesystemInfoList *qmp_guest_get_fsinfo(Error **errp) 329546d4c572STomoki Sekiyama { 3296c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 329746d4c572STomoki Sekiyama return NULL; 329846d4c572STomoki Sekiyama } 329946d4c572STomoki Sekiyama 330077dbc81bSMarkus Armbruster GuestFsfreezeStatus qmp_guest_fsfreeze_status(Error **errp) 3301d35d4cb5SMichael Roth { 3302c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3303d35d4cb5SMichael Roth 3304d35d4cb5SMichael Roth return 0; 3305d35d4cb5SMichael Roth } 3306d35d4cb5SMichael Roth 330777dbc81bSMarkus Armbruster int64_t qmp_guest_fsfreeze_freeze(Error **errp) 3308d35d4cb5SMichael Roth { 3309c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3310d35d4cb5SMichael Roth 3311d35d4cb5SMichael Roth return 0; 3312d35d4cb5SMichael Roth } 3313d35d4cb5SMichael Roth 3314e99bce20STomoki Sekiyama int64_t qmp_guest_fsfreeze_freeze_list(bool has_mountpoints, 3315e99bce20STomoki Sekiyama strList *mountpoints, 3316e99bce20STomoki Sekiyama Error **errp) 3317e99bce20STomoki Sekiyama { 3318c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3319e99bce20STomoki Sekiyama 3320e99bce20STomoki Sekiyama return 0; 3321e99bce20STomoki Sekiyama } 3322e99bce20STomoki Sekiyama 332377dbc81bSMarkus Armbruster int64_t qmp_guest_fsfreeze_thaw(Error **errp) 3324d35d4cb5SMichael Roth { 3325c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3326d35d4cb5SMichael Roth 3327d35d4cb5SMichael Roth return 0; 3328d35d4cb5SMichael Roth } 3329fed39564STomáš Golembiovský 3330fed39564STomáš Golembiovský GuestDiskInfoList *qmp_guest_get_disks(Error **errp) 3331fed39564STomáš Golembiovský { 3332fed39564STomáš Golembiovský error_setg(errp, QERR_UNSUPPORTED); 3333fed39564STomáš Golembiovský return NULL; 3334fed39564STomáš Golembiovský } 3335fed39564STomáš Golembiovský 33363569664eSluzhipeng GuestDiskStatsInfoList *qmp_guest_get_diskstats(Error **errp) 33373569664eSluzhipeng { 33383569664eSluzhipeng error_setg(errp, QERR_UNSUPPORTED); 33393569664eSluzhipeng return NULL; 33403569664eSluzhipeng } 33413569664eSluzhipeng 33421db8a0b0Szhenwei pi GuestCpuStatsList *qmp_guest_get_cpustats(Error **errp) 33431db8a0b0Szhenwei pi { 33441db8a0b0Szhenwei pi error_setg(errp, QERR_UNSUPPORTED); 33451db8a0b0Szhenwei pi return NULL; 33461db8a0b0Szhenwei pi } 33473569664eSluzhipeng 3348eab5fd59SPaolo Bonzini #endif /* CONFIG_FSFREEZE */ 3349d35d4cb5SMichael Roth 3350eab5fd59SPaolo Bonzini #if !defined(CONFIG_FSTRIM) 3351e82855d9SJustin Ossevoort GuestFilesystemTrimResponse * 3352e82855d9SJustin Ossevoort qmp_guest_fstrim(bool has_minimum, int64_t minimum, Error **errp) 3353eab5fd59SPaolo Bonzini { 3354c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3355e82855d9SJustin Ossevoort return NULL; 3356eab5fd59SPaolo Bonzini } 3357d35d4cb5SMichael Roth #endif 3358d35d4cb5SMichael Roth 3359*0e4ef702SThomas Huth /* add unsupported commands to the list of blocked RPCs */ 3360*0e4ef702SThomas Huth GList *ga_command_init_blockedrpcs(GList *blockedrpcs) 33611281c08aSTomoki Sekiyama { 33621281c08aSTomoki Sekiyama #if !defined(__linux__) 33631281c08aSTomoki Sekiyama { 33641281c08aSTomoki Sekiyama const char *list[] = { 33651281c08aSTomoki Sekiyama "guest-suspend-disk", "guest-suspend-ram", 336659e35c7bSAndrew Deason "guest-suspend-hybrid", "guest-get-vcpus", "guest-set-vcpus", 33670dd38a03Szhanghailiang "guest-get-memory-blocks", "guest-set-memory-blocks", 336828d8dd35SBasil Salman "guest-get-memory-block-size", "guest-get-memory-block-info", 336928d8dd35SBasil Salman NULL}; 33701281c08aSTomoki Sekiyama char **p = (char **)list; 33711281c08aSTomoki Sekiyama 33721281c08aSTomoki Sekiyama while (*p) { 3373*0e4ef702SThomas Huth blockedrpcs = g_list_append(blockedrpcs, g_strdup(*p++)); 33741281c08aSTomoki Sekiyama } 33751281c08aSTomoki Sekiyama } 33761281c08aSTomoki Sekiyama #endif 33771281c08aSTomoki Sekiyama 337859e35c7bSAndrew Deason #if !defined(HAVE_GETIFADDRS) 3379*0e4ef702SThomas Huth blockedrpcs = g_list_append(blockedrpcs, 338059e35c7bSAndrew Deason g_strdup("guest-network-get-interfaces")); 338159e35c7bSAndrew Deason #endif 338259e35c7bSAndrew Deason 33831281c08aSTomoki Sekiyama #if !defined(CONFIG_FSFREEZE) 33841281c08aSTomoki Sekiyama { 33851281c08aSTomoki Sekiyama const char *list[] = { 33861281c08aSTomoki Sekiyama "guest-get-fsinfo", "guest-fsfreeze-status", 33871281c08aSTomoki Sekiyama "guest-fsfreeze-freeze", "guest-fsfreeze-freeze-list", 3388fed39564STomáš Golembiovský "guest-fsfreeze-thaw", "guest-get-fsinfo", 3389fed39564STomáš Golembiovský "guest-get-disks", NULL}; 33901281c08aSTomoki Sekiyama char **p = (char **)list; 33911281c08aSTomoki Sekiyama 33921281c08aSTomoki Sekiyama while (*p) { 3393*0e4ef702SThomas Huth blockedrpcs = g_list_append(blockedrpcs, g_strdup(*p++)); 33941281c08aSTomoki Sekiyama } 33951281c08aSTomoki Sekiyama } 33961281c08aSTomoki Sekiyama #endif 33971281c08aSTomoki Sekiyama 33981281c08aSTomoki Sekiyama #if !defined(CONFIG_FSTRIM) 3399*0e4ef702SThomas Huth blockedrpcs = g_list_append(blockedrpcs, g_strdup("guest-fstrim")); 34001281c08aSTomoki Sekiyama #endif 34011281c08aSTomoki Sekiyama 3402*0e4ef702SThomas Huth blockedrpcs = g_list_append(blockedrpcs, g_strdup("guest-get-devices")); 34032e4211ceSTomáš Golembiovský 3404*0e4ef702SThomas Huth return blockedrpcs; 34051281c08aSTomoki Sekiyama } 34061281c08aSTomoki Sekiyama 3407c216e5adSMichael Roth /* register init/cleanup routines for stateful command groups */ 3408c216e5adSMichael Roth void ga_command_state_init(GAState *s, GACommandState *cs) 3409c216e5adSMichael Roth { 3410c216e5adSMichael Roth #if defined(CONFIG_FSFREEZE) 3411f22d85e9SMichael Roth ga_command_state_add(cs, NULL, guest_fsfreeze_cleanup); 3412c216e5adSMichael Roth #endif 3413c216e5adSMichael Roth } 3414161a56a9SVinzenz Feenstra 3415e674605fSTomáš Golembiovský #ifdef HAVE_UTMPX 3416e674605fSTomáš Golembiovský 3417161a56a9SVinzenz Feenstra #define QGA_MICRO_SECOND_TO_SECOND 1000000 3418161a56a9SVinzenz Feenstra 3419161a56a9SVinzenz Feenstra static double ga_get_login_time(struct utmpx *user_info) 3420161a56a9SVinzenz Feenstra { 3421161a56a9SVinzenz Feenstra double seconds = (double)user_info->ut_tv.tv_sec; 3422161a56a9SVinzenz Feenstra double useconds = (double)user_info->ut_tv.tv_usec; 3423161a56a9SVinzenz Feenstra useconds /= QGA_MICRO_SECOND_TO_SECOND; 3424161a56a9SVinzenz Feenstra return seconds + useconds; 3425161a56a9SVinzenz Feenstra } 3426161a56a9SVinzenz Feenstra 3427b90abbacSVladimir Sementsov-Ogievskiy GuestUserList *qmp_guest_get_users(Error **errp) 3428161a56a9SVinzenz Feenstra { 3429161a56a9SVinzenz Feenstra GHashTable *cache = NULL; 343095b3a8c8SEric Blake GuestUserList *head = NULL, **tail = &head; 3431161a56a9SVinzenz Feenstra struct utmpx *user_info = NULL; 3432161a56a9SVinzenz Feenstra gpointer value = NULL; 3433161a56a9SVinzenz Feenstra GuestUser *user = NULL; 3434161a56a9SVinzenz Feenstra double login_time = 0; 3435161a56a9SVinzenz Feenstra 3436161a56a9SVinzenz Feenstra cache = g_hash_table_new(g_str_hash, g_str_equal); 3437161a56a9SVinzenz Feenstra setutxent(); 3438161a56a9SVinzenz Feenstra 3439161a56a9SVinzenz Feenstra for (;;) { 3440161a56a9SVinzenz Feenstra user_info = getutxent(); 3441161a56a9SVinzenz Feenstra if (user_info == NULL) { 3442161a56a9SVinzenz Feenstra break; 3443161a56a9SVinzenz Feenstra } else if (user_info->ut_type != USER_PROCESS) { 3444161a56a9SVinzenz Feenstra continue; 3445161a56a9SVinzenz Feenstra } else if (g_hash_table_contains(cache, user_info->ut_user)) { 3446161a56a9SVinzenz Feenstra value = g_hash_table_lookup(cache, user_info->ut_user); 3447161a56a9SVinzenz Feenstra user = (GuestUser *)value; 3448161a56a9SVinzenz Feenstra login_time = ga_get_login_time(user_info); 3449161a56a9SVinzenz Feenstra /* We're ensuring the earliest login time to be sent */ 3450161a56a9SVinzenz Feenstra if (login_time < user->login_time) { 3451161a56a9SVinzenz Feenstra user->login_time = login_time; 3452161a56a9SVinzenz Feenstra } 3453161a56a9SVinzenz Feenstra continue; 3454161a56a9SVinzenz Feenstra } 3455161a56a9SVinzenz Feenstra 345695b3a8c8SEric Blake user = g_new0(GuestUser, 1); 345795b3a8c8SEric Blake user->user = g_strdup(user_info->ut_user); 345895b3a8c8SEric Blake user->login_time = ga_get_login_time(user_info); 3459161a56a9SVinzenz Feenstra 346095b3a8c8SEric Blake g_hash_table_insert(cache, user->user, user); 3461161a56a9SVinzenz Feenstra 346295b3a8c8SEric Blake QAPI_LIST_APPEND(tail, user); 3463161a56a9SVinzenz Feenstra } 3464161a56a9SVinzenz Feenstra endutxent(); 3465161a56a9SVinzenz Feenstra g_hash_table_destroy(cache); 3466161a56a9SVinzenz Feenstra return head; 3467161a56a9SVinzenz Feenstra } 3468e674605fSTomáš Golembiovský 3469e674605fSTomáš Golembiovský #else 3470e674605fSTomáš Golembiovský 3471e674605fSTomáš Golembiovský GuestUserList *qmp_guest_get_users(Error **errp) 3472e674605fSTomáš Golembiovský { 3473e674605fSTomáš Golembiovský error_setg(errp, QERR_UNSUPPORTED); 3474e674605fSTomáš Golembiovský return NULL; 3475e674605fSTomáš Golembiovský } 3476e674605fSTomáš Golembiovský 3477e674605fSTomáš Golembiovský #endif 34789848f797STomáš Golembiovský 34799848f797STomáš Golembiovský /* Replace escaped special characters with theire real values. The replacement 34809848f797STomáš Golembiovský * is done in place -- returned value is in the original string. 34819848f797STomáš Golembiovský */ 34829848f797STomáš Golembiovský static void ga_osrelease_replace_special(gchar *value) 34839848f797STomáš Golembiovský { 34849848f797STomáš Golembiovský gchar *p, *p2, quote; 34859848f797STomáš Golembiovský 34869848f797STomáš Golembiovský /* Trim the string at first space or semicolon if it is not enclosed in 34879848f797STomáš Golembiovský * single or double quotes. */ 34889848f797STomáš Golembiovský if ((value[0] != '"') || (value[0] == '\'')) { 34899848f797STomáš Golembiovský p = strchr(value, ' '); 34909848f797STomáš Golembiovský if (p != NULL) { 34919848f797STomáš Golembiovský *p = 0; 34929848f797STomáš Golembiovský } 34939848f797STomáš Golembiovský p = strchr(value, ';'); 34949848f797STomáš Golembiovský if (p != NULL) { 34959848f797STomáš Golembiovský *p = 0; 34969848f797STomáš Golembiovský } 34979848f797STomáš Golembiovský return; 34989848f797STomáš Golembiovský } 34999848f797STomáš Golembiovský 35009848f797STomáš Golembiovský quote = value[0]; 35019848f797STomáš Golembiovský p2 = value; 35029848f797STomáš Golembiovský p = value + 1; 35039848f797STomáš Golembiovský while (*p != 0) { 35049848f797STomáš Golembiovský if (*p == '\\') { 35059848f797STomáš Golembiovský p++; 35069848f797STomáš Golembiovský switch (*p) { 35079848f797STomáš Golembiovský case '$': 35089848f797STomáš Golembiovský case '\'': 35099848f797STomáš Golembiovský case '"': 35109848f797STomáš Golembiovský case '\\': 35119848f797STomáš Golembiovský case '`': 35129848f797STomáš Golembiovský break; 35139848f797STomáš Golembiovský default: 35149848f797STomáš Golembiovský /* Keep literal backslash followed by whatever is there */ 35159848f797STomáš Golembiovský p--; 35169848f797STomáš Golembiovský break; 35179848f797STomáš Golembiovský } 35189848f797STomáš Golembiovský } else if (*p == quote) { 35199848f797STomáš Golembiovský *p2 = 0; 35209848f797STomáš Golembiovský break; 35219848f797STomáš Golembiovský } 35229848f797STomáš Golembiovský *(p2++) = *(p++); 35239848f797STomáš Golembiovský } 35249848f797STomáš Golembiovský } 35259848f797STomáš Golembiovský 35269848f797STomáš Golembiovský static GKeyFile *ga_parse_osrelease(const char *fname) 35279848f797STomáš Golembiovský { 35289848f797STomáš Golembiovský gchar *content = NULL; 35299848f797STomáš Golembiovský gchar *content2 = NULL; 35309848f797STomáš Golembiovský GError *err = NULL; 35319848f797STomáš Golembiovský GKeyFile *keys = g_key_file_new(); 35329848f797STomáš Golembiovský const char *group = "[os-release]\n"; 35339848f797STomáš Golembiovský 35349848f797STomáš Golembiovský if (!g_file_get_contents(fname, &content, NULL, &err)) { 35359848f797STomáš Golembiovský slog("failed to read '%s', error: %s", fname, err->message); 35369848f797STomáš Golembiovský goto fail; 35379848f797STomáš Golembiovský } 35389848f797STomáš Golembiovský 35399848f797STomáš Golembiovský if (!g_utf8_validate(content, -1, NULL)) { 35409848f797STomáš Golembiovský slog("file is not utf-8 encoded: %s", fname); 35419848f797STomáš Golembiovský goto fail; 35429848f797STomáš Golembiovský } 35439848f797STomáš Golembiovský content2 = g_strdup_printf("%s%s", group, content); 35449848f797STomáš Golembiovský 35459848f797STomáš Golembiovský if (!g_key_file_load_from_data(keys, content2, -1, G_KEY_FILE_NONE, 35469848f797STomáš Golembiovský &err)) { 35479848f797STomáš Golembiovský slog("failed to parse file '%s', error: %s", fname, err->message); 35489848f797STomáš Golembiovský goto fail; 35499848f797STomáš Golembiovský } 35509848f797STomáš Golembiovský 35519848f797STomáš Golembiovský g_free(content); 35529848f797STomáš Golembiovský g_free(content2); 35539848f797STomáš Golembiovský return keys; 35549848f797STomáš Golembiovský 35559848f797STomáš Golembiovský fail: 35569848f797STomáš Golembiovský g_error_free(err); 35579848f797STomáš Golembiovský g_free(content); 35589848f797STomáš Golembiovský g_free(content2); 35599848f797STomáš Golembiovský g_key_file_free(keys); 35609848f797STomáš Golembiovský return NULL; 35619848f797STomáš Golembiovský } 35629848f797STomáš Golembiovský 35639848f797STomáš Golembiovský GuestOSInfo *qmp_guest_get_osinfo(Error **errp) 35649848f797STomáš Golembiovský { 35659848f797STomáš Golembiovský GuestOSInfo *info = NULL; 35669848f797STomáš Golembiovský struct utsname kinfo; 3567339ca68bSTomáš Golembiovský GKeyFile *osrelease = NULL; 3568339ca68bSTomáš Golembiovský const char *qga_os_release = g_getenv("QGA_OS_RELEASE"); 35699848f797STomáš Golembiovský 35709848f797STomáš Golembiovský info = g_new0(GuestOSInfo, 1); 35719848f797STomáš Golembiovský 35729848f797STomáš Golembiovský if (uname(&kinfo) != 0) { 35739848f797STomáš Golembiovský error_setg_errno(errp, errno, "uname failed"); 35749848f797STomáš Golembiovský } else { 35759848f797STomáš Golembiovský info->has_kernel_version = true; 35769848f797STomáš Golembiovský info->kernel_version = g_strdup(kinfo.version); 35779848f797STomáš Golembiovský info->has_kernel_release = true; 35789848f797STomáš Golembiovský info->kernel_release = g_strdup(kinfo.release); 35799848f797STomáš Golembiovský info->has_machine = true; 35809848f797STomáš Golembiovský info->machine = g_strdup(kinfo.machine); 35819848f797STomáš Golembiovský } 35829848f797STomáš Golembiovský 3583339ca68bSTomáš Golembiovský if (qga_os_release != NULL) { 3584339ca68bSTomáš Golembiovský osrelease = ga_parse_osrelease(qga_os_release); 3585339ca68bSTomáš Golembiovský } else { 35869848f797STomáš Golembiovský osrelease = ga_parse_osrelease("/etc/os-release"); 35879848f797STomáš Golembiovský if (osrelease == NULL) { 35889848f797STomáš Golembiovský osrelease = ga_parse_osrelease("/usr/lib/os-release"); 35899848f797STomáš Golembiovský } 3590339ca68bSTomáš Golembiovský } 35919848f797STomáš Golembiovský 35929848f797STomáš Golembiovský if (osrelease != NULL) { 35939848f797STomáš Golembiovský char *value; 35949848f797STomáš Golembiovský 35959848f797STomáš Golembiovský #define GET_FIELD(field, osfield) do { \ 35969848f797STomáš Golembiovský value = g_key_file_get_value(osrelease, "os-release", osfield, NULL); \ 35979848f797STomáš Golembiovský if (value != NULL) { \ 35989848f797STomáš Golembiovský ga_osrelease_replace_special(value); \ 35999848f797STomáš Golembiovský info->has_ ## field = true; \ 36009848f797STomáš Golembiovský info->field = value; \ 36019848f797STomáš Golembiovský } \ 36029848f797STomáš Golembiovský } while (0) 36039848f797STomáš Golembiovský GET_FIELD(id, "ID"); 36049848f797STomáš Golembiovský GET_FIELD(name, "NAME"); 36059848f797STomáš Golembiovský GET_FIELD(pretty_name, "PRETTY_NAME"); 36069848f797STomáš Golembiovský GET_FIELD(version, "VERSION"); 36079848f797STomáš Golembiovský GET_FIELD(version_id, "VERSION_ID"); 36089848f797STomáš Golembiovský GET_FIELD(variant, "VARIANT"); 36099848f797STomáš Golembiovský GET_FIELD(variant_id, "VARIANT_ID"); 36109848f797STomáš Golembiovský #undef GET_FIELD 36119848f797STomáš Golembiovský 36129848f797STomáš Golembiovský g_key_file_free(osrelease); 36139848f797STomáš Golembiovský } 36149848f797STomáš Golembiovský 36159848f797STomáš Golembiovský return info; 36169848f797STomáš Golembiovský } 36172e4211ceSTomáš Golembiovský 36182e4211ceSTomáš Golembiovský GuestDeviceInfoList *qmp_guest_get_devices(Error **errp) 36192e4211ceSTomáš Golembiovský { 36202e4211ceSTomáš Golembiovský error_setg(errp, QERR_UNSUPPORTED); 36212e4211ceSTomáš Golembiovský 36222e4211ceSTomáš Golembiovský return NULL; 36232e4211ceSTomáš Golembiovský } 3624548fb0daSMarc-André Lureau 3625548fb0daSMarc-André Lureau #ifndef HOST_NAME_MAX 3626548fb0daSMarc-André Lureau # ifdef _POSIX_HOST_NAME_MAX 3627548fb0daSMarc-André Lureau # define HOST_NAME_MAX _POSIX_HOST_NAME_MAX 3628548fb0daSMarc-André Lureau # else 3629548fb0daSMarc-André Lureau # define HOST_NAME_MAX 255 3630548fb0daSMarc-André Lureau # endif 3631548fb0daSMarc-André Lureau #endif 3632548fb0daSMarc-André Lureau 3633548fb0daSMarc-André Lureau char *qga_get_host_name(Error **errp) 3634548fb0daSMarc-André Lureau { 3635548fb0daSMarc-André Lureau long len = -1; 3636548fb0daSMarc-André Lureau g_autofree char *hostname = NULL; 3637548fb0daSMarc-André Lureau 3638548fb0daSMarc-André Lureau #ifdef _SC_HOST_NAME_MAX 3639548fb0daSMarc-André Lureau len = sysconf(_SC_HOST_NAME_MAX); 3640548fb0daSMarc-André Lureau #endif /* _SC_HOST_NAME_MAX */ 3641548fb0daSMarc-André Lureau 3642548fb0daSMarc-André Lureau if (len < 0) { 3643548fb0daSMarc-André Lureau len = HOST_NAME_MAX; 3644548fb0daSMarc-André Lureau } 3645548fb0daSMarc-André Lureau 3646548fb0daSMarc-André Lureau /* Unfortunately, gethostname() below does not guarantee a 3647548fb0daSMarc-André Lureau * NULL terminated string. Therefore, allocate one byte more 3648548fb0daSMarc-André Lureau * to be sure. */ 3649548fb0daSMarc-André Lureau hostname = g_new0(char, len + 1); 3650548fb0daSMarc-André Lureau 3651548fb0daSMarc-André Lureau if (gethostname(hostname, len) < 0) { 3652548fb0daSMarc-André Lureau error_setg_errno(errp, errno, 3653548fb0daSMarc-André Lureau "cannot get hostname"); 3654548fb0daSMarc-André Lureau return NULL; 3655548fb0daSMarc-André Lureau } 3656548fb0daSMarc-André Lureau 3657548fb0daSMarc-André Lureau return g_steal_pointer(&hostname); 3658548fb0daSMarc-André Lureau } 3659