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> 19a8d25326SMarkus Armbruster #include "qemu-common.h" 20dc03272dSMichael S. Tsirkin #include "guest-agent-core.h" 21eb815e24SMarkus Armbruster #include "qga-qapi-commands.h" 22e688df6bSMarkus Armbruster #include "qapi/error.h" 237b1b5d19SPaolo Bonzini #include "qapi/qmp/qerror.h" 241de7afc9SPaolo Bonzini #include "qemu/queue.h" 251de7afc9SPaolo Bonzini #include "qemu/host-utils.h" 2612505396SDenis V. Lunev #include "qemu/sockets.h" 27920639caSDaniel P. Berrange #include "qemu/base64.h" 28f348b6d1SVeronia Bahaa #include "qemu/cutils.h" 295d3586b8SPhilippe Mathieu-Daudé #include "commands-common.h" 30c216e5adSMichael Roth 31e674605fSTomáš Golembiovský #ifdef HAVE_UTMPX 32e674605fSTomáš Golembiovský #include <utmpx.h> 33e674605fSTomáš Golembiovský #endif 34e674605fSTomáš Golembiovský 352c02cbf6SLuiz Capitulino #ifndef CONFIG_HAS_ENVIRON 36eecae147SAndreas Färber #ifdef __APPLE__ 37eecae147SAndreas Färber #include <crt_externs.h> 38eecae147SAndreas Färber #define environ (*_NSGetEnviron()) 39eecae147SAndreas Färber #else 402c02cbf6SLuiz Capitulino extern char **environ; 412c02cbf6SLuiz Capitulino #endif 42eecae147SAndreas Färber #endif 432c02cbf6SLuiz Capitulino 44e72c3f2eSMichael Roth #if defined(__linux__) 45e72c3f2eSMichael Roth #include <mntent.h> 46e72c3f2eSMichael Roth #include <linux/fs.h> 47e72c3f2eSMichael Roth #include <ifaddrs.h> 48e72c3f2eSMichael Roth #include <arpa/inet.h> 49e72c3f2eSMichael Roth #include <sys/socket.h> 50e72c3f2eSMichael Roth #include <net/if.h> 5125b5ff1aSChen Hanxiao #include <sys/statvfs.h> 52e72c3f2eSMichael Roth 53b616105aSTomáš Golembiovský #ifdef CONFIG_LIBUDEV 54b616105aSTomáš Golembiovský #include <libudev.h> 55b616105aSTomáš Golembiovský #endif 56b616105aSTomáš Golembiovský 57eab5fd59SPaolo Bonzini #ifdef FIFREEZE 58e72c3f2eSMichael Roth #define CONFIG_FSFREEZE 59e72c3f2eSMichael Roth #endif 60eab5fd59SPaolo Bonzini #ifdef FITRIM 61eab5fd59SPaolo Bonzini #define CONFIG_FSTRIM 62eab5fd59SPaolo Bonzini #endif 63e72c3f2eSMichael Roth #endif 64e72c3f2eSMichael Roth 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 91c216e5adSMichael Roth slog("guest-shutdown called, mode: %s", mode); 92c216e5adSMichael Roth if (!has_mode || strcmp(mode, "powerdown") == 0) { 93c216e5adSMichael Roth shutdown_flag = "-P"; 94c216e5adSMichael Roth } else if (strcmp(mode, "halt") == 0) { 95c216e5adSMichael Roth shutdown_flag = "-H"; 96c216e5adSMichael Roth } else if (strcmp(mode, "reboot") == 0) { 97c216e5adSMichael Roth shutdown_flag = "-r"; 98c216e5adSMichael Roth } else { 9977dbc81bSMarkus Armbruster error_setg(errp, 100d220a6dfSLuiz Capitulino "mode is invalid (valid values are: halt|powerdown|reboot"); 101c216e5adSMichael Roth return; 102c216e5adSMichael Roth } 103c216e5adSMichael Roth 104d5dd3498SLuiz Capitulino pid = fork(); 105d5dd3498SLuiz Capitulino if (pid == 0) { 106c216e5adSMichael Roth /* child, start the shutdown */ 107c216e5adSMichael Roth setsid(); 1083674838cSLuiz Capitulino reopen_fd_to_null(0); 1093674838cSLuiz Capitulino reopen_fd_to_null(1); 1103674838cSLuiz Capitulino reopen_fd_to_null(2); 111c216e5adSMichael Roth 112485e741cSwhitearchey execle("/sbin/shutdown", "shutdown", "-h", shutdown_flag, "+0", 1133674838cSLuiz Capitulino "hypervisor initiated shutdown", (char*)NULL, environ); 1143674838cSLuiz Capitulino _exit(EXIT_FAILURE); 115d5dd3498SLuiz Capitulino } else if (pid < 0) { 11677dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to create child process"); 117d5dd3498SLuiz Capitulino return; 118d5dd3498SLuiz Capitulino } 119d5dd3498SLuiz Capitulino 120d220a6dfSLuiz Capitulino ga_wait_child(pid, &status, &local_err); 12184d18f06SMarkus Armbruster if (local_err) { 12277dbc81bSMarkus Armbruster error_propagate(errp, local_err); 123d220a6dfSLuiz Capitulino return; 124d220a6dfSLuiz Capitulino } 125d220a6dfSLuiz Capitulino 126d220a6dfSLuiz Capitulino if (!WIFEXITED(status)) { 12777dbc81bSMarkus Armbruster error_setg(errp, "child process has terminated abnormally"); 128d220a6dfSLuiz Capitulino return; 129d220a6dfSLuiz Capitulino } 130d220a6dfSLuiz Capitulino 131d220a6dfSLuiz Capitulino if (WEXITSTATUS(status)) { 13277dbc81bSMarkus Armbruster error_setg(errp, "child process has failed to shutdown"); 133d220a6dfSLuiz Capitulino return; 134d220a6dfSLuiz Capitulino } 135d220a6dfSLuiz Capitulino 136085d8134SPeter Maydell /* succeeded */ 137c216e5adSMichael Roth } 138c216e5adSMichael Roth 1396912e6a9SLei Li int64_t qmp_guest_get_time(Error **errp) 1406912e6a9SLei Li { 1416912e6a9SLei Li int ret; 1426912e6a9SLei Li qemu_timeval tq; 1436912e6a9SLei Li 1446912e6a9SLei Li ret = qemu_gettimeofday(&tq); 1456912e6a9SLei Li if (ret < 0) { 1466912e6a9SLei Li error_setg_errno(errp, errno, "Failed to get time"); 1476912e6a9SLei Li return -1; 1486912e6a9SLei Li } 1496912e6a9SLei Li 1509be38598SEduardo Habkost return tq.tv_sec * 1000000000LL + tq.tv_usec * 1000; 1516912e6a9SLei Li } 1526912e6a9SLei Li 1532c958923SMichal Privoznik void qmp_guest_set_time(bool has_time, int64_t time_ns, Error **errp) 154a1bca57fSLei Li { 155a1bca57fSLei Li int ret; 156a1bca57fSLei Li int status; 157a1bca57fSLei Li pid_t pid; 158a1bca57fSLei Li Error *local_err = NULL; 159a1bca57fSLei Li struct timeval tv; 1605c6096e5SCornelia Huck static const char hwclock_path[] = "/sbin/hwclock"; 1615c6096e5SCornelia Huck static int hwclock_available = -1; 1625c6096e5SCornelia Huck 1635c6096e5SCornelia Huck if (hwclock_available < 0) { 1645c6096e5SCornelia Huck hwclock_available = (access(hwclock_path, X_OK) == 0); 1655c6096e5SCornelia Huck } 1665c6096e5SCornelia Huck 1675c6096e5SCornelia Huck if (!hwclock_available) { 1685c6096e5SCornelia Huck error_setg(errp, QERR_UNSUPPORTED); 1695c6096e5SCornelia Huck return; 1705c6096e5SCornelia Huck } 171a1bca57fSLei Li 1722c958923SMichal Privoznik /* If user has passed a time, validate and set it. */ 1732c958923SMichal Privoznik if (has_time) { 17400d2f370SMarc-André Lureau GDate date = { 0, }; 17500d2f370SMarc-André Lureau 176a1bca57fSLei Li /* year-2038 will overflow in case time_t is 32bit */ 177a1bca57fSLei Li if (time_ns / 1000000000 != (time_t)(time_ns / 1000000000)) { 178a1bca57fSLei Li error_setg(errp, "Time %" PRId64 " is too large", time_ns); 179a1bca57fSLei Li return; 180a1bca57fSLei Li } 181a1bca57fSLei Li 182a1bca57fSLei Li tv.tv_sec = time_ns / 1000000000; 183a1bca57fSLei Li tv.tv_usec = (time_ns % 1000000000) / 1000; 18400d2f370SMarc-André Lureau g_date_set_time_t(&date, tv.tv_sec); 18500d2f370SMarc-André Lureau if (date.year < 1970 || date.year >= 2070) { 18600d2f370SMarc-André Lureau error_setg_errno(errp, errno, "Invalid time"); 18700d2f370SMarc-André Lureau return; 18800d2f370SMarc-André Lureau } 189a1bca57fSLei Li 190a1bca57fSLei Li ret = settimeofday(&tv, NULL); 191a1bca57fSLei Li if (ret < 0) { 192a1bca57fSLei Li error_setg_errno(errp, errno, "Failed to set time to guest"); 193a1bca57fSLei Li return; 194a1bca57fSLei Li } 1952c958923SMichal Privoznik } 196a1bca57fSLei Li 1972c958923SMichal Privoznik /* Now, if user has passed a time to set and the system time is set, we 1982c958923SMichal Privoznik * just need to synchronize the hardware clock. However, if no time was 1992c958923SMichal Privoznik * passed, user is requesting the opposite: set the system time from the 2001634df56SAmos Kong * hardware clock (RTC). */ 201a1bca57fSLei Li pid = fork(); 202a1bca57fSLei Li if (pid == 0) { 203a1bca57fSLei Li setsid(); 204a1bca57fSLei Li reopen_fd_to_null(0); 205a1bca57fSLei Li reopen_fd_to_null(1); 206a1bca57fSLei Li reopen_fd_to_null(2); 207a1bca57fSLei Li 2082c958923SMichal Privoznik /* Use '/sbin/hwclock -w' to set RTC from the system time, 2092c958923SMichal Privoznik * or '/sbin/hwclock -s' to set the system time from RTC. */ 2105c6096e5SCornelia Huck execle(hwclock_path, "hwclock", has_time ? "-w" : "-s", 2112c958923SMichal Privoznik NULL, environ); 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 Error *local_err = NULL; 344c689b4f1SLaszlo Ersek int oflag; 345c689b4f1SLaszlo Ersek 346c689b4f1SLaszlo Ersek oflag = find_open_flag(mode, &local_err); 347c689b4f1SLaszlo Ersek if (local_err == NULL) { 348c689b4f1SLaszlo Ersek int fd; 349c689b4f1SLaszlo Ersek 350c689b4f1SLaszlo Ersek /* If the caller wants / allows creation of a new file, we implement it 351c689b4f1SLaszlo Ersek * with a two step process: open() + (open() / fchmod()). 352c689b4f1SLaszlo Ersek * 353c689b4f1SLaszlo Ersek * First we insist on creating the file exclusively as a new file. If 354c689b4f1SLaszlo Ersek * that succeeds, we're free to set any file-mode bits on it. (The 355c689b4f1SLaszlo Ersek * motivation is that we want to set those file-mode bits independently 356c689b4f1SLaszlo Ersek * of the current umask.) 357c689b4f1SLaszlo Ersek * 358c689b4f1SLaszlo Ersek * If the exclusive creation fails because the file already exists 359c689b4f1SLaszlo Ersek * (EEXIST is not possible for any other reason), we just attempt to 360c689b4f1SLaszlo Ersek * open the file, but in this case we won't be allowed to change the 361c689b4f1SLaszlo Ersek * file-mode bits on the preexistent file. 362c689b4f1SLaszlo Ersek * 363c689b4f1SLaszlo Ersek * The pathname should never disappear between the two open()s in 364c689b4f1SLaszlo Ersek * practice. If it happens, then someone very likely tried to race us. 365c689b4f1SLaszlo Ersek * In this case just go ahead and report the ENOENT from the second 366c689b4f1SLaszlo Ersek * open() to the caller. 367c689b4f1SLaszlo Ersek * 368c689b4f1SLaszlo Ersek * If the caller wants to open a preexistent file, then the first 369c689b4f1SLaszlo Ersek * open() is decisive and its third argument is ignored, and the second 370c689b4f1SLaszlo Ersek * open() and the fchmod() are never called. 371c689b4f1SLaszlo Ersek */ 372c689b4f1SLaszlo Ersek fd = open(path, oflag | ((oflag & O_CREAT) ? O_EXCL : 0), 0); 373c689b4f1SLaszlo Ersek if (fd == -1 && errno == EEXIST) { 374c689b4f1SLaszlo Ersek oflag &= ~(unsigned)O_CREAT; 375c689b4f1SLaszlo Ersek fd = open(path, oflag); 376c689b4f1SLaszlo Ersek } 377c689b4f1SLaszlo Ersek 378c689b4f1SLaszlo Ersek if (fd == -1) { 379c689b4f1SLaszlo Ersek error_setg_errno(&local_err, errno, "failed to open file '%s' " 380c689b4f1SLaszlo Ersek "(mode: '%s')", path, mode); 381c689b4f1SLaszlo Ersek } else { 382c689b4f1SLaszlo Ersek qemu_set_cloexec(fd); 383c689b4f1SLaszlo Ersek 384c689b4f1SLaszlo Ersek if ((oflag & O_CREAT) && fchmod(fd, DEFAULT_NEW_FILE_MODE) == -1) { 385c689b4f1SLaszlo Ersek error_setg_errno(&local_err, errno, "failed to set permission " 386c689b4f1SLaszlo Ersek "0%03o on new file '%s' (mode: '%s')", 387c689b4f1SLaszlo Ersek (unsigned)DEFAULT_NEW_FILE_MODE, path, mode); 388c689b4f1SLaszlo Ersek } else { 389c689b4f1SLaszlo Ersek FILE *f; 390c689b4f1SLaszlo Ersek 391c689b4f1SLaszlo Ersek f = fdopen(fd, mode); 392c689b4f1SLaszlo Ersek if (f == NULL) { 393c689b4f1SLaszlo Ersek error_setg_errno(&local_err, errno, "failed to associate " 394c689b4f1SLaszlo Ersek "stdio stream with file descriptor %d, " 395c689b4f1SLaszlo Ersek "file '%s' (mode: '%s')", fd, path, mode); 396c689b4f1SLaszlo Ersek } else { 397c689b4f1SLaszlo Ersek return f; 398c689b4f1SLaszlo Ersek } 399c689b4f1SLaszlo Ersek } 400c689b4f1SLaszlo Ersek 401c689b4f1SLaszlo Ersek close(fd); 4022b720018SLaszlo Ersek if (oflag & O_CREAT) { 4032b720018SLaszlo Ersek unlink(path); 4042b720018SLaszlo Ersek } 405c689b4f1SLaszlo Ersek } 406c689b4f1SLaszlo Ersek } 407c689b4f1SLaszlo Ersek 40877dbc81bSMarkus Armbruster error_propagate(errp, local_err); 409c689b4f1SLaszlo Ersek return NULL; 410c689b4f1SLaszlo Ersek } 411c689b4f1SLaszlo Ersek 41277dbc81bSMarkus Armbruster int64_t qmp_guest_file_open(const char *path, bool has_mode, const char *mode, 41377dbc81bSMarkus Armbruster Error **errp) 414c216e5adSMichael Roth { 415c216e5adSMichael Roth FILE *fh; 416c689b4f1SLaszlo Ersek Error *local_err = NULL; 41785b6f6f5SSimon Zolin int64_t handle; 418c216e5adSMichael Roth 419c216e5adSMichael Roth if (!has_mode) { 420c216e5adSMichael Roth mode = "r"; 421c216e5adSMichael Roth } 422c216e5adSMichael Roth slog("guest-file-open called, filepath: %s, mode: %s", path, mode); 423c689b4f1SLaszlo Ersek fh = safe_open_or_create(path, mode, &local_err); 424c689b4f1SLaszlo Ersek if (local_err != NULL) { 42577dbc81bSMarkus Armbruster error_propagate(errp, local_err); 426c216e5adSMichael Roth return -1; 427c216e5adSMichael Roth } 428c216e5adSMichael Roth 429c216e5adSMichael Roth /* set fd non-blocking to avoid common use cases (like reading from a 430c216e5adSMichael Roth * named pipe) from hanging the agent 431c216e5adSMichael Roth */ 43212505396SDenis V. Lunev qemu_set_nonblock(fileno(fh)); 433c216e5adSMichael Roth 43477dbc81bSMarkus Armbruster handle = guest_file_handle_add(fh, errp); 435a903f40cSMarkus Armbruster if (handle < 0) { 43639097dafSMichael Roth fclose(fh); 43739097dafSMichael Roth return -1; 43839097dafSMichael Roth } 43939097dafSMichael Roth 440d607a523SStefan Weil slog("guest-file-open, handle: %" PRId64, handle); 44139097dafSMichael Roth return handle; 442c216e5adSMichael Roth } 443c216e5adSMichael Roth 44477dbc81bSMarkus Armbruster void qmp_guest_file_close(int64_t handle, Error **errp) 445c216e5adSMichael Roth { 44677dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 447c216e5adSMichael Roth int ret; 448c216e5adSMichael Roth 449d607a523SStefan Weil slog("guest-file-close called, handle: %" PRId64, handle); 450c216e5adSMichael Roth if (!gfh) { 451c216e5adSMichael Roth return; 452c216e5adSMichael Roth } 453c216e5adSMichael Roth 454c216e5adSMichael Roth ret = fclose(gfh->fh); 4553ac4b7c5SLuiz Capitulino if (ret == EOF) { 45677dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to close handle"); 457c216e5adSMichael Roth return; 458c216e5adSMichael Roth } 459c216e5adSMichael Roth 460c216e5adSMichael Roth QTAILQ_REMOVE(&guest_file_state.filehandles, gfh, next); 461c216e5adSMichael Roth g_free(gfh); 462c216e5adSMichael Roth } 463c216e5adSMichael Roth 464ead83a13SPhilippe Mathieu-Daudé GuestFileRead *guest_file_read_unsafe(GuestFileHandle *gfh, 46577dbc81bSMarkus Armbruster int64_t count, Error **errp) 466c216e5adSMichael Roth { 467c216e5adSMichael Roth GuestFileRead *read_data = NULL; 468c216e5adSMichael Roth guchar *buf; 469ead83a13SPhilippe Mathieu-Daudé FILE *fh = gfh->fh; 470c216e5adSMichael Roth size_t read_count; 471c216e5adSMichael Roth 472895b00f6SMarc-André Lureau /* explicitly flush when switching from writing to reading */ 473895b00f6SMarc-André Lureau if (gfh->state == RW_STATE_WRITING) { 474895b00f6SMarc-André Lureau int ret = fflush(fh); 475895b00f6SMarc-André Lureau if (ret == EOF) { 476895b00f6SMarc-André Lureau error_setg_errno(errp, errno, "failed to flush file"); 477895b00f6SMarc-André Lureau return NULL; 478895b00f6SMarc-André Lureau } 479895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 480895b00f6SMarc-André Lureau } 481895b00f6SMarc-André Lureau 482c216e5adSMichael Roth buf = g_malloc0(count+1); 483c216e5adSMichael Roth read_count = fread(buf, 1, count, fh); 484c216e5adSMichael Roth if (ferror(fh)) { 48577dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to read file"); 486c216e5adSMichael Roth } else { 487c216e5adSMichael Roth buf[read_count] = 0; 488f3a06403SMarkus Armbruster read_data = g_new0(GuestFileRead, 1); 489c216e5adSMichael Roth read_data->count = read_count; 490c216e5adSMichael Roth read_data->eof = feof(fh); 491c216e5adSMichael Roth if (read_count) { 492c216e5adSMichael Roth read_data->buf_b64 = g_base64_encode(buf, read_count); 493c216e5adSMichael Roth } 494895b00f6SMarc-André Lureau gfh->state = RW_STATE_READING; 495c216e5adSMichael Roth } 496c216e5adSMichael Roth g_free(buf); 497c216e5adSMichael Roth clearerr(fh); 498c216e5adSMichael Roth 499c216e5adSMichael Roth return read_data; 500c216e5adSMichael Roth } 501c216e5adSMichael Roth 502c216e5adSMichael Roth GuestFileWrite *qmp_guest_file_write(int64_t handle, const char *buf_b64, 50377dbc81bSMarkus Armbruster bool has_count, int64_t count, 50477dbc81bSMarkus Armbruster Error **errp) 505c216e5adSMichael Roth { 506c216e5adSMichael Roth GuestFileWrite *write_data = NULL; 507c216e5adSMichael Roth guchar *buf; 508c216e5adSMichael Roth gsize buf_len; 509c216e5adSMichael Roth int write_count; 51077dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 511c216e5adSMichael Roth FILE *fh; 512c216e5adSMichael Roth 513c216e5adSMichael Roth if (!gfh) { 514c216e5adSMichael Roth return NULL; 515c216e5adSMichael Roth } 516c216e5adSMichael Roth 517c216e5adSMichael Roth fh = gfh->fh; 518895b00f6SMarc-André Lureau 519895b00f6SMarc-André Lureau if (gfh->state == RW_STATE_READING) { 520895b00f6SMarc-André Lureau int ret = fseek(fh, 0, SEEK_CUR); 521895b00f6SMarc-André Lureau if (ret == -1) { 522895b00f6SMarc-André Lureau error_setg_errno(errp, errno, "failed to seek file"); 523895b00f6SMarc-André Lureau return NULL; 524895b00f6SMarc-André Lureau } 525895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 526895b00f6SMarc-André Lureau } 527895b00f6SMarc-André Lureau 528920639caSDaniel P. Berrange buf = qbase64_decode(buf_b64, -1, &buf_len, errp); 529920639caSDaniel P. Berrange if (!buf) { 530920639caSDaniel P. Berrange return NULL; 531920639caSDaniel P. Berrange } 532c216e5adSMichael Roth 533c216e5adSMichael Roth if (!has_count) { 534c216e5adSMichael Roth count = buf_len; 535c216e5adSMichael Roth } else if (count < 0 || count > buf_len) { 53677dbc81bSMarkus Armbruster error_setg(errp, "value '%" PRId64 "' is invalid for argument count", 537db3edb66SLuiz Capitulino count); 538c216e5adSMichael Roth g_free(buf); 539c216e5adSMichael Roth return NULL; 540c216e5adSMichael Roth } 541c216e5adSMichael Roth 542c216e5adSMichael Roth write_count = fwrite(buf, 1, count, fh); 543c216e5adSMichael Roth if (ferror(fh)) { 54477dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to write to file"); 545d607a523SStefan Weil slog("guest-file-write failed, handle: %" PRId64, handle); 546c216e5adSMichael Roth } else { 547f3a06403SMarkus Armbruster write_data = g_new0(GuestFileWrite, 1); 548c216e5adSMichael Roth write_data->count = write_count; 549c216e5adSMichael Roth write_data->eof = feof(fh); 550895b00f6SMarc-André Lureau gfh->state = RW_STATE_WRITING; 551c216e5adSMichael Roth } 552c216e5adSMichael Roth g_free(buf); 553c216e5adSMichael Roth clearerr(fh); 554c216e5adSMichael Roth 555c216e5adSMichael Roth return write_data; 556c216e5adSMichael Roth } 557c216e5adSMichael Roth 558c216e5adSMichael Roth struct GuestFileSeek *qmp_guest_file_seek(int64_t handle, int64_t offset, 5590b4b4938SEric Blake GuestFileWhence *whence_code, 5600b4b4938SEric Blake Error **errp) 561c216e5adSMichael Roth { 56277dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 563c216e5adSMichael Roth GuestFileSeek *seek_data = NULL; 564c216e5adSMichael Roth FILE *fh; 565c216e5adSMichael Roth int ret; 5660a982b1bSEric Blake int whence; 5670b4b4938SEric Blake Error *err = NULL; 568c216e5adSMichael Roth 569c216e5adSMichael Roth if (!gfh) { 570c216e5adSMichael Roth return NULL; 571c216e5adSMichael Roth } 572c216e5adSMichael Roth 5730a982b1bSEric Blake /* We stupidly exposed 'whence':'int' in our qapi */ 5740b4b4938SEric Blake whence = ga_parse_whence(whence_code, &err); 5750b4b4938SEric Blake if (err) { 5760b4b4938SEric Blake error_propagate(errp, err); 5770a982b1bSEric Blake return NULL; 5780a982b1bSEric Blake } 5790a982b1bSEric Blake 580c216e5adSMichael Roth fh = gfh->fh; 581c216e5adSMichael Roth ret = fseek(fh, offset, whence); 582c216e5adSMichael Roth if (ret == -1) { 58377dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to seek file"); 584895b00f6SMarc-André Lureau if (errno == ESPIPE) { 585895b00f6SMarc-André Lureau /* file is non-seekable, stdio shouldn't be buffering anyways */ 586895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 587895b00f6SMarc-André Lureau } 588c216e5adSMichael Roth } else { 58910b7c5ddSMarkus Armbruster seek_data = g_new0(GuestFileSeek, 1); 590c216e5adSMichael Roth seek_data->position = ftell(fh); 591c216e5adSMichael Roth seek_data->eof = feof(fh); 592895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 593c216e5adSMichael Roth } 594c216e5adSMichael Roth clearerr(fh); 595c216e5adSMichael Roth 596c216e5adSMichael Roth return seek_data; 597c216e5adSMichael Roth } 598c216e5adSMichael Roth 59977dbc81bSMarkus Armbruster void qmp_guest_file_flush(int64_t handle, Error **errp) 600c216e5adSMichael Roth { 60177dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 602c216e5adSMichael Roth FILE *fh; 603c216e5adSMichael Roth int ret; 604c216e5adSMichael Roth 605c216e5adSMichael Roth if (!gfh) { 606c216e5adSMichael Roth return; 607c216e5adSMichael Roth } 608c216e5adSMichael Roth 609c216e5adSMichael Roth fh = gfh->fh; 610c216e5adSMichael Roth ret = fflush(fh); 611c216e5adSMichael Roth if (ret == EOF) { 61277dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to flush file"); 613895b00f6SMarc-André Lureau } else { 614895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 615c216e5adSMichael Roth } 616c216e5adSMichael Roth } 617c216e5adSMichael Roth 618e72c3f2eSMichael Roth /* linux-specific implementations. avoid this if at all possible. */ 619e72c3f2eSMichael Roth #if defined(__linux__) 620e72c3f2eSMichael Roth 621eab5fd59SPaolo Bonzini #if defined(CONFIG_FSFREEZE) || defined(CONFIG_FSTRIM) 622af02203fSPaolo Bonzini typedef struct FsMount { 623c216e5adSMichael Roth char *dirname; 624c216e5adSMichael Roth char *devtype; 62546d4c572STomoki Sekiyama unsigned int devmajor, devminor; 626af02203fSPaolo Bonzini QTAILQ_ENTRY(FsMount) next; 627af02203fSPaolo Bonzini } FsMount; 628c216e5adSMichael Roth 629e5d9adbdSTomoki Sekiyama typedef QTAILQ_HEAD(FsMountList, FsMount) FsMountList; 6309e8aded4SMichael Roth 631af02203fSPaolo Bonzini static void free_fs_mount_list(FsMountList *mounts) 632c216e5adSMichael Roth { 633af02203fSPaolo Bonzini FsMount *mount, *temp; 634c216e5adSMichael Roth 6359e8aded4SMichael Roth if (!mounts) { 6369e8aded4SMichael Roth return; 6379e8aded4SMichael Roth } 6389e8aded4SMichael Roth 6399e8aded4SMichael Roth QTAILQ_FOREACH_SAFE(mount, mounts, next, temp) { 6409e8aded4SMichael Roth QTAILQ_REMOVE(mounts, mount, next); 641c216e5adSMichael Roth g_free(mount->dirname); 642c216e5adSMichael Roth g_free(mount->devtype); 643c216e5adSMichael Roth g_free(mount); 644c216e5adSMichael Roth } 6459e8aded4SMichael Roth } 6469e8aded4SMichael Roth 64746d4c572STomoki Sekiyama static int dev_major_minor(const char *devpath, 64846d4c572STomoki Sekiyama unsigned int *devmajor, unsigned int *devminor) 64946d4c572STomoki Sekiyama { 65046d4c572STomoki Sekiyama struct stat st; 65146d4c572STomoki Sekiyama 65246d4c572STomoki Sekiyama *devmajor = 0; 65346d4c572STomoki Sekiyama *devminor = 0; 65446d4c572STomoki Sekiyama 65546d4c572STomoki Sekiyama if (stat(devpath, &st) < 0) { 65646d4c572STomoki Sekiyama slog("failed to stat device file '%s': %s", devpath, strerror(errno)); 65746d4c572STomoki Sekiyama return -1; 65846d4c572STomoki Sekiyama } 65946d4c572STomoki Sekiyama if (S_ISDIR(st.st_mode)) { 66046d4c572STomoki Sekiyama /* It is bind mount */ 66146d4c572STomoki Sekiyama return -2; 66246d4c572STomoki Sekiyama } 66346d4c572STomoki Sekiyama if (S_ISBLK(st.st_mode)) { 66446d4c572STomoki Sekiyama *devmajor = major(st.st_rdev); 66546d4c572STomoki Sekiyama *devminor = minor(st.st_rdev); 66646d4c572STomoki Sekiyama return 0; 66746d4c572STomoki Sekiyama } 66846d4c572STomoki Sekiyama return -1; 66946d4c572STomoki Sekiyama } 67046d4c572STomoki Sekiyama 6719e8aded4SMichael Roth /* 6729e8aded4SMichael Roth * Walk the mount table and build a list of local file systems 6739e8aded4SMichael Roth */ 67446d4c572STomoki Sekiyama static void build_fs_mount_list_from_mtab(FsMountList *mounts, Error **errp) 6759e8aded4SMichael Roth { 6769e8aded4SMichael Roth struct mntent *ment; 677af02203fSPaolo Bonzini FsMount *mount; 6789e2fa418SMichael Roth char const *mtab = "/proc/self/mounts"; 6799e8aded4SMichael Roth FILE *fp; 68046d4c572STomoki Sekiyama unsigned int devmajor, devminor; 681c216e5adSMichael Roth 682c216e5adSMichael Roth fp = setmntent(mtab, "r"); 683c216e5adSMichael Roth if (!fp) { 68477dbc81bSMarkus Armbruster error_setg(errp, "failed to open mtab file: '%s'", mtab); 685261551d1SLuiz Capitulino return; 686c216e5adSMichael Roth } 687c216e5adSMichael Roth 688c216e5adSMichael Roth while ((ment = getmntent(fp))) { 689c216e5adSMichael Roth /* 690c216e5adSMichael Roth * An entry which device name doesn't start with a '/' is 691c216e5adSMichael Roth * either a dummy file system or a network file system. 692c216e5adSMichael Roth * Add special handling for smbfs and cifs as is done by 693c216e5adSMichael Roth * coreutils as well. 694c216e5adSMichael Roth */ 695c216e5adSMichael Roth if ((ment->mnt_fsname[0] != '/') || 696c216e5adSMichael Roth (strcmp(ment->mnt_type, "smbfs") == 0) || 697c216e5adSMichael Roth (strcmp(ment->mnt_type, "cifs") == 0)) { 698c216e5adSMichael Roth continue; 699c216e5adSMichael Roth } 70046d4c572STomoki Sekiyama if (dev_major_minor(ment->mnt_fsname, &devmajor, &devminor) == -2) { 70146d4c572STomoki Sekiyama /* Skip bind mounts */ 70246d4c572STomoki Sekiyama continue; 70346d4c572STomoki Sekiyama } 704c216e5adSMichael Roth 705f3a06403SMarkus Armbruster mount = g_new0(FsMount, 1); 706c216e5adSMichael Roth mount->dirname = g_strdup(ment->mnt_dir); 707c216e5adSMichael Roth mount->devtype = g_strdup(ment->mnt_type); 70846d4c572STomoki Sekiyama mount->devmajor = devmajor; 70946d4c572STomoki Sekiyama mount->devminor = devminor; 710c216e5adSMichael Roth 7119e8aded4SMichael Roth QTAILQ_INSERT_TAIL(mounts, mount, next); 712c216e5adSMichael Roth } 713c216e5adSMichael Roth 714c216e5adSMichael Roth endmntent(fp); 715c216e5adSMichael Roth } 71646d4c572STomoki Sekiyama 71746d4c572STomoki Sekiyama static void decode_mntname(char *name, int len) 71846d4c572STomoki Sekiyama { 71946d4c572STomoki Sekiyama int i, j = 0; 72046d4c572STomoki Sekiyama for (i = 0; i <= len; i++) { 72146d4c572STomoki Sekiyama if (name[i] != '\\') { 72246d4c572STomoki Sekiyama name[j++] = name[i]; 72346d4c572STomoki Sekiyama } else if (name[i + 1] == '\\') { 72446d4c572STomoki Sekiyama name[j++] = '\\'; 72546d4c572STomoki Sekiyama i++; 72646d4c572STomoki Sekiyama } else if (name[i + 1] >= '0' && name[i + 1] <= '3' && 72746d4c572STomoki Sekiyama name[i + 2] >= '0' && name[i + 2] <= '7' && 72846d4c572STomoki Sekiyama name[i + 3] >= '0' && name[i + 3] <= '7') { 72946d4c572STomoki Sekiyama name[j++] = (name[i + 1] - '0') * 64 + 73046d4c572STomoki Sekiyama (name[i + 2] - '0') * 8 + 73146d4c572STomoki Sekiyama (name[i + 3] - '0'); 73246d4c572STomoki Sekiyama i += 3; 73346d4c572STomoki Sekiyama } else { 73446d4c572STomoki Sekiyama name[j++] = name[i]; 73546d4c572STomoki Sekiyama } 73646d4c572STomoki Sekiyama } 73746d4c572STomoki Sekiyama } 73846d4c572STomoki Sekiyama 73946d4c572STomoki Sekiyama static void build_fs_mount_list(FsMountList *mounts, Error **errp) 74046d4c572STomoki Sekiyama { 74146d4c572STomoki Sekiyama FsMount *mount; 74246d4c572STomoki Sekiyama char const *mountinfo = "/proc/self/mountinfo"; 74346d4c572STomoki Sekiyama FILE *fp; 74446d4c572STomoki Sekiyama char *line = NULL, *dash; 74546d4c572STomoki Sekiyama size_t n; 74646d4c572STomoki Sekiyama char check; 74746d4c572STomoki Sekiyama unsigned int devmajor, devminor; 74846d4c572STomoki Sekiyama int ret, dir_s, dir_e, type_s, type_e, dev_s, dev_e; 74946d4c572STomoki Sekiyama 75046d4c572STomoki Sekiyama fp = fopen(mountinfo, "r"); 75146d4c572STomoki Sekiyama if (!fp) { 75246d4c572STomoki Sekiyama build_fs_mount_list_from_mtab(mounts, errp); 75346d4c572STomoki Sekiyama return; 75446d4c572STomoki Sekiyama } 75546d4c572STomoki Sekiyama 75646d4c572STomoki Sekiyama while (getline(&line, &n, fp) != -1) { 75746d4c572STomoki Sekiyama ret = sscanf(line, "%*u %*u %u:%u %*s %n%*s%n%c", 75846d4c572STomoki Sekiyama &devmajor, &devminor, &dir_s, &dir_e, &check); 75946d4c572STomoki Sekiyama if (ret < 3) { 76046d4c572STomoki Sekiyama continue; 76146d4c572STomoki Sekiyama } 76246d4c572STomoki Sekiyama dash = strstr(line + dir_e, " - "); 76346d4c572STomoki Sekiyama if (!dash) { 76446d4c572STomoki Sekiyama continue; 76546d4c572STomoki Sekiyama } 76646d4c572STomoki Sekiyama ret = sscanf(dash, " - %n%*s%n %n%*s%n%c", 76746d4c572STomoki Sekiyama &type_s, &type_e, &dev_s, &dev_e, &check); 76846d4c572STomoki Sekiyama if (ret < 1) { 76946d4c572STomoki Sekiyama continue; 77046d4c572STomoki Sekiyama } 77146d4c572STomoki Sekiyama line[dir_e] = 0; 77246d4c572STomoki Sekiyama dash[type_e] = 0; 77346d4c572STomoki Sekiyama dash[dev_e] = 0; 77446d4c572STomoki Sekiyama decode_mntname(line + dir_s, dir_e - dir_s); 77546d4c572STomoki Sekiyama decode_mntname(dash + dev_s, dev_e - dev_s); 77646d4c572STomoki Sekiyama if (devmajor == 0) { 77746d4c572STomoki Sekiyama /* btrfs reports major number = 0 */ 77846d4c572STomoki Sekiyama if (strcmp("btrfs", dash + type_s) != 0 || 77946d4c572STomoki Sekiyama dev_major_minor(dash + dev_s, &devmajor, &devminor) < 0) { 78046d4c572STomoki Sekiyama continue; 78146d4c572STomoki Sekiyama } 78246d4c572STomoki Sekiyama } 78346d4c572STomoki Sekiyama 784f3a06403SMarkus Armbruster mount = g_new0(FsMount, 1); 78546d4c572STomoki Sekiyama mount->dirname = g_strdup(line + dir_s); 78646d4c572STomoki Sekiyama mount->devtype = g_strdup(dash + type_s); 78746d4c572STomoki Sekiyama mount->devmajor = devmajor; 78846d4c572STomoki Sekiyama mount->devminor = devminor; 78946d4c572STomoki Sekiyama 79046d4c572STomoki Sekiyama QTAILQ_INSERT_TAIL(mounts, mount, next); 79146d4c572STomoki Sekiyama } 79246d4c572STomoki Sekiyama free(line); 79346d4c572STomoki Sekiyama 79446d4c572STomoki Sekiyama fclose(fp); 79546d4c572STomoki Sekiyama } 796eab5fd59SPaolo Bonzini #endif 797eab5fd59SPaolo Bonzini 798eab5fd59SPaolo Bonzini #if defined(CONFIG_FSFREEZE) 799c216e5adSMichael Roth 80046d4c572STomoki Sekiyama static char *get_pci_driver(char const *syspath, int pathlen, Error **errp) 80146d4c572STomoki Sekiyama { 80246d4c572STomoki Sekiyama char *path; 80346d4c572STomoki Sekiyama char *dpath; 80446d4c572STomoki Sekiyama char *driver = NULL; 80546d4c572STomoki Sekiyama char buf[PATH_MAX]; 80646d4c572STomoki Sekiyama ssize_t len; 80746d4c572STomoki Sekiyama 80846d4c572STomoki Sekiyama path = g_strndup(syspath, pathlen); 80946d4c572STomoki Sekiyama dpath = g_strdup_printf("%s/driver", path); 81046d4c572STomoki Sekiyama len = readlink(dpath, buf, sizeof(buf) - 1); 81146d4c572STomoki Sekiyama if (len != -1) { 81246d4c572STomoki Sekiyama buf[len] = 0; 8133e015d81SJulia Suvorova driver = g_path_get_basename(buf); 81446d4c572STomoki Sekiyama } 81546d4c572STomoki Sekiyama g_free(dpath); 81646d4c572STomoki Sekiyama g_free(path); 81746d4c572STomoki Sekiyama return driver; 81846d4c572STomoki Sekiyama } 81946d4c572STomoki Sekiyama 82046d4c572STomoki Sekiyama static int compare_uint(const void *_a, const void *_b) 82146d4c572STomoki Sekiyama { 82246d4c572STomoki Sekiyama unsigned int a = *(unsigned int *)_a; 82346d4c572STomoki Sekiyama unsigned int b = *(unsigned int *)_b; 82446d4c572STomoki Sekiyama 82546d4c572STomoki Sekiyama return a < b ? -1 : a > b ? 1 : 0; 82646d4c572STomoki Sekiyama } 82746d4c572STomoki Sekiyama 82846d4c572STomoki Sekiyama /* Walk the specified sysfs and build a sorted list of host or ata numbers */ 82946d4c572STomoki Sekiyama static int build_hosts(char const *syspath, char const *host, bool ata, 83046d4c572STomoki Sekiyama unsigned int *hosts, int hosts_max, Error **errp) 83146d4c572STomoki Sekiyama { 83246d4c572STomoki Sekiyama char *path; 83346d4c572STomoki Sekiyama DIR *dir; 83446d4c572STomoki Sekiyama struct dirent *entry; 83546d4c572STomoki Sekiyama int i = 0; 83646d4c572STomoki Sekiyama 83746d4c572STomoki Sekiyama path = g_strndup(syspath, host - syspath); 83846d4c572STomoki Sekiyama dir = opendir(path); 83946d4c572STomoki Sekiyama if (!dir) { 84046d4c572STomoki Sekiyama error_setg_errno(errp, errno, "opendir(\"%s\")", path); 84146d4c572STomoki Sekiyama g_free(path); 84246d4c572STomoki Sekiyama return -1; 84346d4c572STomoki Sekiyama } 84446d4c572STomoki Sekiyama 84546d4c572STomoki Sekiyama while (i < hosts_max) { 84646d4c572STomoki Sekiyama entry = readdir(dir); 84746d4c572STomoki Sekiyama if (!entry) { 84846d4c572STomoki Sekiyama break; 84946d4c572STomoki Sekiyama } 85046d4c572STomoki Sekiyama if (ata && sscanf(entry->d_name, "ata%d", hosts + i) == 1) { 85146d4c572STomoki Sekiyama ++i; 85246d4c572STomoki Sekiyama } else if (!ata && sscanf(entry->d_name, "host%d", hosts + i) == 1) { 85346d4c572STomoki Sekiyama ++i; 85446d4c572STomoki Sekiyama } 85546d4c572STomoki Sekiyama } 85646d4c572STomoki Sekiyama 85746d4c572STomoki Sekiyama qsort(hosts, i, sizeof(hosts[0]), compare_uint); 85846d4c572STomoki Sekiyama 85946d4c572STomoki Sekiyama g_free(path); 86046d4c572STomoki Sekiyama closedir(dir); 86146d4c572STomoki Sekiyama return i; 86246d4c572STomoki Sekiyama } 86346d4c572STomoki Sekiyama 864d9fe4f0fSThomas Huth /* 865d9fe4f0fSThomas Huth * Store disk device info for devices on the PCI bus. 866d9fe4f0fSThomas Huth * Returns true if information has been stored, or false for failure. 867d9fe4f0fSThomas Huth */ 868d9fe4f0fSThomas Huth static bool build_guest_fsinfo_for_pci_dev(char const *syspath, 869d9fe4f0fSThomas Huth GuestDiskAddress *disk, 87046d4c572STomoki Sekiyama Error **errp) 87146d4c572STomoki Sekiyama { 87246d4c572STomoki Sekiyama unsigned int pci[4], host, hosts[8], tgt[3]; 87346d4c572STomoki Sekiyama int i, nhosts = 0, pcilen; 874d9fe4f0fSThomas Huth GuestPCIAddress *pciaddr = disk->pci_controller; 87546d4c572STomoki Sekiyama bool has_ata = false, has_host = false, has_tgt = false; 87646d4c572STomoki Sekiyama char *p, *q, *driver = NULL; 877d9fe4f0fSThomas Huth bool ret = false; 87846d4c572STomoki Sekiyama 87946d4c572STomoki Sekiyama p = strstr(syspath, "/devices/pci"); 88046d4c572STomoki Sekiyama if (!p || sscanf(p + 12, "%*x:%*x/%x:%x:%x.%x%n", 88146d4c572STomoki Sekiyama pci, pci + 1, pci + 2, pci + 3, &pcilen) < 4) { 882743c71d0SMarc-André Lureau g_debug("only pci device is supported: sysfs path '%s'", syspath); 883d9fe4f0fSThomas Huth return false; 88446d4c572STomoki Sekiyama } 88546d4c572STomoki Sekiyama 886743c71d0SMarc-André Lureau p += 12 + pcilen; 887743c71d0SMarc-André Lureau while (true) { 888743c71d0SMarc-André Lureau driver = get_pci_driver(syspath, p - syspath, errp); 889743c71d0SMarc-André Lureau if (driver && (g_str_equal(driver, "ata_piix") || 890743c71d0SMarc-André Lureau g_str_equal(driver, "sym53c8xx") || 891743c71d0SMarc-André Lureau g_str_equal(driver, "virtio-pci") || 892743c71d0SMarc-André Lureau g_str_equal(driver, "ahci"))) { 893743c71d0SMarc-André Lureau break; 894743c71d0SMarc-André Lureau } 895743c71d0SMarc-André Lureau 896bb23a736SMarc-André Lureau g_free(driver); 897743c71d0SMarc-André Lureau if (sscanf(p, "/%x:%x:%x.%x%n", 898743c71d0SMarc-André Lureau pci, pci + 1, pci + 2, pci + 3, &pcilen) == 4) { 899743c71d0SMarc-André Lureau p += pcilen; 900743c71d0SMarc-André Lureau continue; 901743c71d0SMarc-André Lureau } 902743c71d0SMarc-André Lureau 903743c71d0SMarc-André Lureau g_debug("unsupported driver or sysfs path '%s'", syspath); 904d9fe4f0fSThomas Huth return false; 90546d4c572STomoki Sekiyama } 90646d4c572STomoki Sekiyama 90746d4c572STomoki Sekiyama p = strstr(syspath, "/target"); 90846d4c572STomoki Sekiyama if (p && sscanf(p + 7, "%*u:%*u:%*u/%*u:%u:%u:%u", 90946d4c572STomoki Sekiyama tgt, tgt + 1, tgt + 2) == 3) { 91046d4c572STomoki Sekiyama has_tgt = true; 91146d4c572STomoki Sekiyama } 91246d4c572STomoki Sekiyama 91346d4c572STomoki Sekiyama p = strstr(syspath, "/ata"); 91446d4c572STomoki Sekiyama if (p) { 91546d4c572STomoki Sekiyama q = p + 4; 91646d4c572STomoki Sekiyama has_ata = true; 91746d4c572STomoki Sekiyama } else { 91846d4c572STomoki Sekiyama p = strstr(syspath, "/host"); 91946d4c572STomoki Sekiyama q = p + 5; 92046d4c572STomoki Sekiyama } 92146d4c572STomoki Sekiyama if (p && sscanf(q, "%u", &host) == 1) { 92246d4c572STomoki Sekiyama has_host = true; 92346d4c572STomoki Sekiyama nhosts = build_hosts(syspath, p, has_ata, hosts, 92401a6df1bSPhilippe Mathieu-Daudé ARRAY_SIZE(hosts), errp); 92546d4c572STomoki Sekiyama if (nhosts < 0) { 92646d4c572STomoki Sekiyama goto cleanup; 92746d4c572STomoki Sekiyama } 92846d4c572STomoki Sekiyama } 92946d4c572STomoki Sekiyama 93046d4c572STomoki Sekiyama pciaddr->domain = pci[0]; 93146d4c572STomoki Sekiyama pciaddr->bus = pci[1]; 93246d4c572STomoki Sekiyama pciaddr->slot = pci[2]; 93346d4c572STomoki Sekiyama pciaddr->function = pci[3]; 93446d4c572STomoki Sekiyama 93546d4c572STomoki Sekiyama if (strcmp(driver, "ata_piix") == 0) { 93646d4c572STomoki Sekiyama /* a host per ide bus, target*:0:<unit>:0 */ 93746d4c572STomoki Sekiyama if (!has_host || !has_tgt) { 93846d4c572STomoki Sekiyama g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver); 93946d4c572STomoki Sekiyama goto cleanup; 94046d4c572STomoki Sekiyama } 94146d4c572STomoki Sekiyama for (i = 0; i < nhosts; i++) { 94246d4c572STomoki Sekiyama if (host == hosts[i]) { 94346d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_IDE; 94446d4c572STomoki Sekiyama disk->bus = i; 94546d4c572STomoki Sekiyama disk->unit = tgt[1]; 94646d4c572STomoki Sekiyama break; 94746d4c572STomoki Sekiyama } 94846d4c572STomoki Sekiyama } 94946d4c572STomoki Sekiyama if (i >= nhosts) { 95046d4c572STomoki Sekiyama g_debug("no host for '%s' (driver '%s')", syspath, driver); 95146d4c572STomoki Sekiyama goto cleanup; 95246d4c572STomoki Sekiyama } 95346d4c572STomoki Sekiyama } else if (strcmp(driver, "sym53c8xx") == 0) { 95446d4c572STomoki Sekiyama /* scsi(LSI Logic): target*:0:<unit>:0 */ 95546d4c572STomoki Sekiyama if (!has_tgt) { 95646d4c572STomoki Sekiyama g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver); 95746d4c572STomoki Sekiyama goto cleanup; 95846d4c572STomoki Sekiyama } 95946d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI; 96046d4c572STomoki Sekiyama disk->unit = tgt[1]; 96146d4c572STomoki Sekiyama } else if (strcmp(driver, "virtio-pci") == 0) { 96246d4c572STomoki Sekiyama if (has_tgt) { 96346d4c572STomoki Sekiyama /* virtio-scsi: target*:0:0:<unit> */ 96446d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI; 96546d4c572STomoki Sekiyama disk->unit = tgt[2]; 96646d4c572STomoki Sekiyama } else { 96746d4c572STomoki Sekiyama /* virtio-blk: 1 disk per 1 device */ 96846d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_VIRTIO; 96946d4c572STomoki Sekiyama } 97046d4c572STomoki Sekiyama } else if (strcmp(driver, "ahci") == 0) { 97146d4c572STomoki Sekiyama /* ahci: 1 host per 1 unit */ 97246d4c572STomoki Sekiyama if (!has_host || !has_tgt) { 97346d4c572STomoki Sekiyama g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver); 97446d4c572STomoki Sekiyama goto cleanup; 97546d4c572STomoki Sekiyama } 97646d4c572STomoki Sekiyama for (i = 0; i < nhosts; i++) { 97746d4c572STomoki Sekiyama if (host == hosts[i]) { 97846d4c572STomoki Sekiyama disk->unit = i; 97946d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_SATA; 98046d4c572STomoki Sekiyama break; 98146d4c572STomoki Sekiyama } 98246d4c572STomoki Sekiyama } 98346d4c572STomoki Sekiyama if (i >= nhosts) { 98446d4c572STomoki Sekiyama g_debug("no host for '%s' (driver '%s')", syspath, driver); 98546d4c572STomoki Sekiyama goto cleanup; 98646d4c572STomoki Sekiyama } 98746d4c572STomoki Sekiyama } else { 98846d4c572STomoki Sekiyama g_debug("unknown driver '%s' (sysfs path '%s')", driver, syspath); 98946d4c572STomoki Sekiyama goto cleanup; 99046d4c572STomoki Sekiyama } 99146d4c572STomoki Sekiyama 992d9fe4f0fSThomas Huth ret = true; 99346d4c572STomoki Sekiyama 99446d4c572STomoki Sekiyama cleanup: 99546d4c572STomoki Sekiyama g_free(driver); 996d9fe4f0fSThomas Huth return ret; 997d9fe4f0fSThomas Huth } 998d9fe4f0fSThomas Huth 99923843c12SThomas Huth /* 100023843c12SThomas Huth * Store disk device info for non-PCI virtio devices (for example s390x 100123843c12SThomas Huth * channel I/O devices). Returns true if information has been stored, or 100223843c12SThomas Huth * false for failure. 100323843c12SThomas Huth */ 100423843c12SThomas Huth static bool build_guest_fsinfo_for_nonpci_virtio(char const *syspath, 100523843c12SThomas Huth GuestDiskAddress *disk, 100623843c12SThomas Huth Error **errp) 100723843c12SThomas Huth { 100823843c12SThomas Huth unsigned int tgt[3]; 100923843c12SThomas Huth char *p; 101023843c12SThomas Huth 101123843c12SThomas Huth if (!strstr(syspath, "/virtio") || !strstr(syspath, "/block")) { 101223843c12SThomas Huth g_debug("Unsupported virtio device '%s'", syspath); 101323843c12SThomas Huth return false; 101423843c12SThomas Huth } 101523843c12SThomas Huth 101623843c12SThomas Huth p = strstr(syspath, "/target"); 101723843c12SThomas Huth if (p && sscanf(p + 7, "%*u:%*u:%*u/%*u:%u:%u:%u", 101823843c12SThomas Huth &tgt[0], &tgt[1], &tgt[2]) == 3) { 101923843c12SThomas Huth /* virtio-scsi: target*:0:<target>:<unit> */ 102023843c12SThomas Huth disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI; 102123843c12SThomas Huth disk->bus = tgt[0]; 102223843c12SThomas Huth disk->target = tgt[1]; 102323843c12SThomas Huth disk->unit = tgt[2]; 102423843c12SThomas Huth } else { 102523843c12SThomas Huth /* virtio-blk: 1 disk per 1 device */ 102623843c12SThomas Huth disk->bus_type = GUEST_DISK_BUS_TYPE_VIRTIO; 102723843c12SThomas Huth } 102823843c12SThomas Huth 102923843c12SThomas Huth return true; 103023843c12SThomas Huth } 103123843c12SThomas Huth 1032*5b723a5dSThomas Huth /* 1033*5b723a5dSThomas Huth * Store disk device info for CCW devices (s390x channel I/O devices). 1034*5b723a5dSThomas Huth * Returns true if information has been stored, or false for failure. 1035*5b723a5dSThomas Huth */ 1036*5b723a5dSThomas Huth static bool build_guest_fsinfo_for_ccw_dev(char const *syspath, 1037*5b723a5dSThomas Huth GuestDiskAddress *disk, 1038*5b723a5dSThomas Huth Error **errp) 1039*5b723a5dSThomas Huth { 1040*5b723a5dSThomas Huth unsigned int cssid, ssid, subchno, devno; 1041*5b723a5dSThomas Huth char *p; 1042*5b723a5dSThomas Huth 1043*5b723a5dSThomas Huth p = strstr(syspath, "/devices/css"); 1044*5b723a5dSThomas Huth if (!p || sscanf(p + 12, "%*x/%x.%x.%x/%*x.%*x.%x/", 1045*5b723a5dSThomas Huth &cssid, &ssid, &subchno, &devno) < 4) { 1046*5b723a5dSThomas Huth g_debug("could not parse ccw device sysfs path: %s", syspath); 1047*5b723a5dSThomas Huth return false; 1048*5b723a5dSThomas Huth } 1049*5b723a5dSThomas Huth 1050*5b723a5dSThomas Huth disk->has_ccw_address = true; 1051*5b723a5dSThomas Huth disk->ccw_address = g_new0(GuestCCWAddress, 1); 1052*5b723a5dSThomas Huth disk->ccw_address->cssid = cssid; 1053*5b723a5dSThomas Huth disk->ccw_address->ssid = ssid; 1054*5b723a5dSThomas Huth disk->ccw_address->subchno = subchno; 1055*5b723a5dSThomas Huth disk->ccw_address->devno = devno; 1056*5b723a5dSThomas Huth 1057*5b723a5dSThomas Huth if (strstr(p, "/virtio")) { 1058*5b723a5dSThomas Huth build_guest_fsinfo_for_nonpci_virtio(syspath, disk, errp); 1059*5b723a5dSThomas Huth } 1060*5b723a5dSThomas Huth 1061*5b723a5dSThomas Huth return true; 1062*5b723a5dSThomas Huth } 1063*5b723a5dSThomas Huth 1064d9fe4f0fSThomas Huth /* Store disk device info specified by @sysfs into @fs */ 1065d9fe4f0fSThomas Huth static void build_guest_fsinfo_for_real_device(char const *syspath, 1066d9fe4f0fSThomas Huth GuestFilesystemInfo *fs, 1067d9fe4f0fSThomas Huth Error **errp) 1068d9fe4f0fSThomas Huth { 1069d9fe4f0fSThomas Huth GuestDiskAddress *disk; 1070d9fe4f0fSThomas Huth GuestPCIAddress *pciaddr; 1071d9fe4f0fSThomas Huth GuestDiskAddressList *list = NULL; 1072d9fe4f0fSThomas Huth bool has_hwinf; 107343dadc43SThomas Huth #ifdef CONFIG_LIBUDEV 107443dadc43SThomas Huth struct udev *udev = NULL; 107543dadc43SThomas Huth struct udev_device *udevice = NULL; 107643dadc43SThomas Huth #endif 1077d9fe4f0fSThomas Huth 1078d9fe4f0fSThomas Huth pciaddr = g_new0(GuestPCIAddress, 1); 107943dadc43SThomas Huth pciaddr->domain = -1; /* -1 means field is invalid */ 108043dadc43SThomas Huth pciaddr->bus = -1; 108143dadc43SThomas Huth pciaddr->slot = -1; 108243dadc43SThomas Huth pciaddr->function = -1; 1083d9fe4f0fSThomas Huth 1084d9fe4f0fSThomas Huth disk = g_new0(GuestDiskAddress, 1); 1085d9fe4f0fSThomas Huth disk->pci_controller = pciaddr; 108643dadc43SThomas Huth disk->bus_type = GUEST_DISK_BUS_TYPE_UNKNOWN; 1087d9fe4f0fSThomas Huth 1088d9fe4f0fSThomas Huth list = g_new0(GuestDiskAddressList, 1); 1089d9fe4f0fSThomas Huth list->value = disk; 1090d9fe4f0fSThomas Huth 109143dadc43SThomas Huth #ifdef CONFIG_LIBUDEV 109243dadc43SThomas Huth udev = udev_new(); 109343dadc43SThomas Huth udevice = udev_device_new_from_syspath(udev, syspath); 109443dadc43SThomas Huth if (udev == NULL || udevice == NULL) { 109543dadc43SThomas Huth g_debug("failed to query udev"); 109643dadc43SThomas Huth } else { 109743dadc43SThomas Huth const char *devnode, *serial; 109843dadc43SThomas Huth devnode = udev_device_get_devnode(udevice); 109943dadc43SThomas Huth if (devnode != NULL) { 110043dadc43SThomas Huth disk->dev = g_strdup(devnode); 110143dadc43SThomas Huth disk->has_dev = true; 110243dadc43SThomas Huth } 110343dadc43SThomas Huth serial = udev_device_get_property_value(udevice, "ID_SERIAL"); 110443dadc43SThomas Huth if (serial != NULL && *serial != 0) { 110543dadc43SThomas Huth disk->serial = g_strdup(serial); 110643dadc43SThomas Huth disk->has_serial = true; 110743dadc43SThomas Huth } 110843dadc43SThomas Huth } 110943dadc43SThomas Huth 111043dadc43SThomas Huth udev_unref(udev); 111143dadc43SThomas Huth udev_device_unref(udevice); 111243dadc43SThomas Huth #endif 111343dadc43SThomas Huth 111423843c12SThomas Huth if (strstr(syspath, "/devices/pci")) { 1115d9fe4f0fSThomas Huth has_hwinf = build_guest_fsinfo_for_pci_dev(syspath, disk, errp); 1116*5b723a5dSThomas Huth } else if (strstr(syspath, "/devices/css")) { 1117*5b723a5dSThomas Huth has_hwinf = build_guest_fsinfo_for_ccw_dev(syspath, disk, errp); 111823843c12SThomas Huth } else if (strstr(syspath, "/virtio")) { 111923843c12SThomas Huth has_hwinf = build_guest_fsinfo_for_nonpci_virtio(syspath, disk, errp); 112023843c12SThomas Huth } else { 112123843c12SThomas Huth g_debug("Unsupported device type for '%s'", syspath); 112223843c12SThomas Huth has_hwinf = false; 112323843c12SThomas Huth } 1124d9fe4f0fSThomas Huth 112543dadc43SThomas Huth if (has_hwinf || disk->has_dev || disk->has_serial) { 1126d9fe4f0fSThomas Huth list->next = fs->disk; 1127d9fe4f0fSThomas Huth fs->disk = list; 1128d9fe4f0fSThomas Huth } else { 1129d9fe4f0fSThomas Huth qapi_free_GuestDiskAddressList(list); 1130d9fe4f0fSThomas Huth } 113146d4c572STomoki Sekiyama } 113246d4c572STomoki Sekiyama 113346d4c572STomoki Sekiyama static void build_guest_fsinfo_for_device(char const *devpath, 113446d4c572STomoki Sekiyama GuestFilesystemInfo *fs, 113546d4c572STomoki Sekiyama Error **errp); 113646d4c572STomoki Sekiyama 113746d4c572STomoki Sekiyama /* Store a list of slave devices of virtual volume specified by @syspath into 113846d4c572STomoki Sekiyama * @fs */ 113946d4c572STomoki Sekiyama static void build_guest_fsinfo_for_virtual_device(char const *syspath, 114046d4c572STomoki Sekiyama GuestFilesystemInfo *fs, 114146d4c572STomoki Sekiyama Error **errp) 114246d4c572STomoki Sekiyama { 1143292743d9SMarkus Armbruster Error *err = NULL; 114446d4c572STomoki Sekiyama DIR *dir; 114546d4c572STomoki Sekiyama char *dirpath; 1146e668d1b8Szhanghailiang struct dirent *entry; 114746d4c572STomoki Sekiyama 114846d4c572STomoki Sekiyama dirpath = g_strdup_printf("%s/slaves", syspath); 114946d4c572STomoki Sekiyama dir = opendir(dirpath); 115046d4c572STomoki Sekiyama if (!dir) { 11518251a72fSMichael Roth if (errno != ENOENT) { 115246d4c572STomoki Sekiyama error_setg_errno(errp, errno, "opendir(\"%s\")", dirpath); 11538251a72fSMichael Roth } 115446d4c572STomoki Sekiyama g_free(dirpath); 115546d4c572STomoki Sekiyama return; 115646d4c572STomoki Sekiyama } 115746d4c572STomoki Sekiyama 115846d4c572STomoki Sekiyama for (;;) { 1159e668d1b8Szhanghailiang errno = 0; 1160e668d1b8Szhanghailiang entry = readdir(dir); 1161e668d1b8Szhanghailiang if (entry == NULL) { 1162e668d1b8Szhanghailiang if (errno) { 1163e668d1b8Szhanghailiang error_setg_errno(errp, errno, "readdir(\"%s\")", dirpath); 116446d4c572STomoki Sekiyama } 116546d4c572STomoki Sekiyama break; 116646d4c572STomoki Sekiyama } 116746d4c572STomoki Sekiyama 1168e668d1b8Szhanghailiang if (entry->d_type == DT_LNK) { 1169e668d1b8Szhanghailiang char *path; 1170e668d1b8Szhanghailiang 1171e668d1b8Szhanghailiang g_debug(" slave device '%s'", entry->d_name); 1172e668d1b8Szhanghailiang path = g_strdup_printf("%s/slaves/%s", syspath, entry->d_name); 1173292743d9SMarkus Armbruster build_guest_fsinfo_for_device(path, fs, &err); 1174e668d1b8Szhanghailiang g_free(path); 117546d4c572STomoki Sekiyama 1176292743d9SMarkus Armbruster if (err) { 1177292743d9SMarkus Armbruster error_propagate(errp, err); 117846d4c572STomoki Sekiyama break; 117946d4c572STomoki Sekiyama } 118046d4c572STomoki Sekiyama } 118146d4c572STomoki Sekiyama } 118246d4c572STomoki Sekiyama 1183e668d1b8Szhanghailiang g_free(dirpath); 118446d4c572STomoki Sekiyama closedir(dir); 118546d4c572STomoki Sekiyama } 118646d4c572STomoki Sekiyama 1187fed39564STomáš Golembiovský static bool is_disk_virtual(const char *devpath, Error **errp) 1188fed39564STomáš Golembiovský { 1189fed39564STomáš Golembiovský g_autofree char *syspath = realpath(devpath, NULL); 1190fed39564STomáš Golembiovský 1191fed39564STomáš Golembiovský if (!syspath) { 1192fed39564STomáš Golembiovský error_setg_errno(errp, errno, "realpath(\"%s\")", devpath); 1193fed39564STomáš Golembiovský return false; 1194fed39564STomáš Golembiovský } 1195fed39564STomáš Golembiovský return strstr(syspath, "/devices/virtual/block/") != NULL; 1196fed39564STomáš Golembiovský } 1197fed39564STomáš Golembiovský 119846d4c572STomoki Sekiyama /* Dispatch to functions for virtual/real device */ 119946d4c572STomoki Sekiyama static void build_guest_fsinfo_for_device(char const *devpath, 120046d4c572STomoki Sekiyama GuestFilesystemInfo *fs, 120146d4c572STomoki Sekiyama Error **errp) 120246d4c572STomoki Sekiyama { 1203fed39564STomáš Golembiovský ERRP_GUARD(); 1204fed39564STomáš Golembiovský g_autofree char *syspath = NULL; 1205fed39564STomáš Golembiovský bool is_virtual = false; 120646d4c572STomoki Sekiyama 1207fed39564STomáš Golembiovský syspath = realpath(devpath, NULL); 120846d4c572STomoki Sekiyama if (!syspath) { 120946d4c572STomoki Sekiyama error_setg_errno(errp, errno, "realpath(\"%s\")", devpath); 121046d4c572STomoki Sekiyama return; 121146d4c572STomoki Sekiyama } 121246d4c572STomoki Sekiyama 121346d4c572STomoki Sekiyama if (!fs->name) { 12143e015d81SJulia Suvorova fs->name = g_path_get_basename(syspath); 121546d4c572STomoki Sekiyama } 121646d4c572STomoki Sekiyama 121746d4c572STomoki Sekiyama g_debug(" parse sysfs path '%s'", syspath); 1218fed39564STomáš Golembiovský is_virtual = is_disk_virtual(syspath, errp); 1219fed39564STomáš Golembiovský if (*errp != NULL) { 1220fed39564STomáš Golembiovský return; 1221fed39564STomáš Golembiovský } 1222fed39564STomáš Golembiovský if (is_virtual) { 122346d4c572STomoki Sekiyama build_guest_fsinfo_for_virtual_device(syspath, fs, errp); 122446d4c572STomoki Sekiyama } else { 122546d4c572STomoki Sekiyama build_guest_fsinfo_for_real_device(syspath, fs, errp); 122646d4c572STomoki Sekiyama } 122746d4c572STomoki Sekiyama } 122846d4c572STomoki Sekiyama 1229fed39564STomáš Golembiovský #ifdef CONFIG_LIBUDEV 1230fed39564STomáš Golembiovský 1231fed39564STomáš Golembiovský /* 1232fed39564STomáš Golembiovský * Wrapper around build_guest_fsinfo_for_device() for getting just 1233fed39564STomáš Golembiovský * the disk address. 1234fed39564STomáš Golembiovský */ 1235fed39564STomáš Golembiovský static GuestDiskAddress *get_disk_address(const char *syspath, Error **errp) 1236fed39564STomáš Golembiovský { 1237fed39564STomáš Golembiovský g_autoptr(GuestFilesystemInfo) fs = NULL; 1238fed39564STomáš Golembiovský 1239fed39564STomáš Golembiovský fs = g_new0(GuestFilesystemInfo, 1); 1240fed39564STomáš Golembiovský build_guest_fsinfo_for_device(syspath, fs, errp); 1241fed39564STomáš Golembiovský if (fs->disk != NULL) { 1242fed39564STomáš Golembiovský return g_steal_pointer(&fs->disk->value); 1243fed39564STomáš Golembiovský } 1244fed39564STomáš Golembiovský return NULL; 1245fed39564STomáš Golembiovský } 1246fed39564STomáš Golembiovský 1247fed39564STomáš Golembiovský static char *get_alias_for_syspath(const char *syspath) 1248fed39564STomáš Golembiovský { 1249fed39564STomáš Golembiovský struct udev *udev = NULL; 1250fed39564STomáš Golembiovský struct udev_device *udevice = NULL; 1251fed39564STomáš Golembiovský char *ret = NULL; 1252fed39564STomáš Golembiovský 1253fed39564STomáš Golembiovský udev = udev_new(); 1254fed39564STomáš Golembiovský if (udev == NULL) { 1255fed39564STomáš Golembiovský g_debug("failed to query udev"); 1256fed39564STomáš Golembiovský goto out; 1257fed39564STomáš Golembiovský } 1258fed39564STomáš Golembiovský udevice = udev_device_new_from_syspath(udev, syspath); 1259fed39564STomáš Golembiovský if (udevice == NULL) { 1260fed39564STomáš Golembiovský g_debug("failed to query udev for path: %s", syspath); 1261fed39564STomáš Golembiovský goto out; 1262fed39564STomáš Golembiovský } else { 1263fed39564STomáš Golembiovský const char *alias = udev_device_get_property_value( 1264fed39564STomáš Golembiovský udevice, "DM_NAME"); 1265fed39564STomáš Golembiovský /* 1266fed39564STomáš Golembiovský * NULL means there was an error and empty string means there is no 1267fed39564STomáš Golembiovský * alias. In case of no alias we return NULL instead of empty string. 1268fed39564STomáš Golembiovský */ 1269fed39564STomáš Golembiovský if (alias == NULL) { 1270fed39564STomáš Golembiovský g_debug("failed to query udev for device alias for: %s", 1271fed39564STomáš Golembiovský syspath); 1272fed39564STomáš Golembiovský } else if (*alias != 0) { 1273fed39564STomáš Golembiovský ret = g_strdup(alias); 1274fed39564STomáš Golembiovský } 1275fed39564STomáš Golembiovský } 1276fed39564STomáš Golembiovský 1277fed39564STomáš Golembiovský out: 1278fed39564STomáš Golembiovský udev_unref(udev); 1279fed39564STomáš Golembiovský udev_device_unref(udevice); 1280fed39564STomáš Golembiovský return ret; 1281fed39564STomáš Golembiovský } 1282fed39564STomáš Golembiovský 1283fed39564STomáš Golembiovský static char *get_device_for_syspath(const char *syspath) 1284fed39564STomáš Golembiovský { 1285fed39564STomáš Golembiovský struct udev *udev = NULL; 1286fed39564STomáš Golembiovský struct udev_device *udevice = NULL; 1287fed39564STomáš Golembiovský char *ret = NULL; 1288fed39564STomáš Golembiovský 1289fed39564STomáš Golembiovský udev = udev_new(); 1290fed39564STomáš Golembiovský if (udev == NULL) { 1291fed39564STomáš Golembiovský g_debug("failed to query udev"); 1292fed39564STomáš Golembiovský goto out; 1293fed39564STomáš Golembiovský } 1294fed39564STomáš Golembiovský udevice = udev_device_new_from_syspath(udev, syspath); 1295fed39564STomáš Golembiovský if (udevice == NULL) { 1296fed39564STomáš Golembiovský g_debug("failed to query udev for path: %s", syspath); 1297fed39564STomáš Golembiovský goto out; 1298fed39564STomáš Golembiovský } else { 1299fed39564STomáš Golembiovský ret = g_strdup(udev_device_get_devnode(udevice)); 1300fed39564STomáš Golembiovský } 1301fed39564STomáš Golembiovský 1302fed39564STomáš Golembiovský out: 1303fed39564STomáš Golembiovský udev_unref(udev); 1304fed39564STomáš Golembiovský udev_device_unref(udevice); 1305fed39564STomáš Golembiovský return ret; 1306fed39564STomáš Golembiovský } 1307fed39564STomáš Golembiovský 1308fed39564STomáš Golembiovský static void get_disk_deps(const char *disk_dir, GuestDiskInfo *disk) 1309fed39564STomáš Golembiovský { 1310fed39564STomáš Golembiovský g_autofree char *deps_dir = NULL; 1311fed39564STomáš Golembiovský const gchar *dep; 1312fed39564STomáš Golembiovský GDir *dp_deps = NULL; 1313fed39564STomáš Golembiovský 1314fed39564STomáš Golembiovský /* List dependent disks */ 1315fed39564STomáš Golembiovský deps_dir = g_strdup_printf("%s/slaves", disk_dir); 1316fed39564STomáš Golembiovský g_debug(" listing entries in: %s", deps_dir); 1317fed39564STomáš Golembiovský dp_deps = g_dir_open(deps_dir, 0, NULL); 1318fed39564STomáš Golembiovský if (dp_deps == NULL) { 1319fed39564STomáš Golembiovský g_debug("failed to list entries in %s", deps_dir); 1320fed39564STomáš Golembiovský return; 1321fed39564STomáš Golembiovský } 1322a8aa94b5SMichael Roth disk->has_dependencies = true; 1323fed39564STomáš Golembiovský while ((dep = g_dir_read_name(dp_deps)) != NULL) { 1324fed39564STomáš Golembiovský g_autofree char *dep_dir = NULL; 1325fed39564STomáš Golembiovský strList *dep_item = NULL; 1326fed39564STomáš Golembiovský char *dev_name; 1327fed39564STomáš Golembiovský 1328fed39564STomáš Golembiovský /* Add dependent disks */ 1329fed39564STomáš Golembiovský dep_dir = g_strdup_printf("%s/%s", deps_dir, dep); 1330fed39564STomáš Golembiovský dev_name = get_device_for_syspath(dep_dir); 1331fed39564STomáš Golembiovský if (dev_name != NULL) { 1332fed39564STomáš Golembiovský g_debug(" adding dependent device: %s", dev_name); 1333fed39564STomáš Golembiovský dep_item = g_new0(strList, 1); 1334fed39564STomáš Golembiovský dep_item->value = dev_name; 1335a8aa94b5SMichael Roth dep_item->next = disk->dependencies; 1336a8aa94b5SMichael Roth disk->dependencies = dep_item; 1337fed39564STomáš Golembiovský } 1338fed39564STomáš Golembiovský } 1339fed39564STomáš Golembiovský g_dir_close(dp_deps); 1340fed39564STomáš Golembiovský } 1341fed39564STomáš Golembiovský 1342fed39564STomáš Golembiovský /* 1343fed39564STomáš Golembiovský * Detect partitions subdirectory, name is "<disk_name><number>" or 1344fed39564STomáš Golembiovský * "<disk_name>p<number>" 1345fed39564STomáš Golembiovský * 1346fed39564STomáš Golembiovský * @disk_name -- last component of /sys path (e.g. sda) 1347fed39564STomáš Golembiovský * @disk_dir -- sys path of the disk (e.g. /sys/block/sda) 1348fed39564STomáš Golembiovský * @disk_dev -- device node of the disk (e.g. /dev/sda) 1349fed39564STomáš Golembiovský */ 1350fed39564STomáš Golembiovský static GuestDiskInfoList *get_disk_partitions( 1351fed39564STomáš Golembiovský GuestDiskInfoList *list, 1352fed39564STomáš Golembiovský const char *disk_name, const char *disk_dir, 1353fed39564STomáš Golembiovský const char *disk_dev) 1354fed39564STomáš Golembiovský { 1355fed39564STomáš Golembiovský GuestDiskInfoList *item, *ret = list; 1356fed39564STomáš Golembiovský struct dirent *de_disk; 1357fed39564STomáš Golembiovský DIR *dp_disk = NULL; 1358fed39564STomáš Golembiovský size_t len = strlen(disk_name); 1359fed39564STomáš Golembiovský 1360fed39564STomáš Golembiovský dp_disk = opendir(disk_dir); 1361fed39564STomáš Golembiovský while ((de_disk = readdir(dp_disk)) != NULL) { 1362fed39564STomáš Golembiovský g_autofree char *partition_dir = NULL; 1363fed39564STomáš Golembiovský char *dev_name; 1364fed39564STomáš Golembiovský GuestDiskInfo *partition; 1365fed39564STomáš Golembiovský 1366fed39564STomáš Golembiovský if (!(de_disk->d_type & DT_DIR)) { 1367fed39564STomáš Golembiovský continue; 1368fed39564STomáš Golembiovský } 1369fed39564STomáš Golembiovský 1370fed39564STomáš Golembiovský if (!(strncmp(disk_name, de_disk->d_name, len) == 0 && 1371fed39564STomáš Golembiovský ((*(de_disk->d_name + len) == 'p' && 1372fed39564STomáš Golembiovský isdigit(*(de_disk->d_name + len + 1))) || 1373fed39564STomáš Golembiovský isdigit(*(de_disk->d_name + len))))) { 1374fed39564STomáš Golembiovský continue; 1375fed39564STomáš Golembiovský } 1376fed39564STomáš Golembiovský 1377fed39564STomáš Golembiovský partition_dir = g_strdup_printf("%s/%s", 1378fed39564STomáš Golembiovský disk_dir, de_disk->d_name); 1379fed39564STomáš Golembiovský dev_name = get_device_for_syspath(partition_dir); 1380fed39564STomáš Golembiovský if (dev_name == NULL) { 1381fed39564STomáš Golembiovský g_debug("Failed to get device name for syspath: %s", 1382fed39564STomáš Golembiovský disk_dir); 1383fed39564STomáš Golembiovský continue; 1384fed39564STomáš Golembiovský } 1385fed39564STomáš Golembiovský partition = g_new0(GuestDiskInfo, 1); 1386fed39564STomáš Golembiovský partition->name = dev_name; 1387fed39564STomáš Golembiovský partition->partition = true; 1388fed39564STomáš Golembiovský /* Add parent disk as dependent for easier tracking of hierarchy */ 1389a8aa94b5SMichael Roth partition->dependencies = g_new0(strList, 1); 1390a8aa94b5SMichael Roth partition->dependencies->value = g_strdup(disk_dev); 1391a8aa94b5SMichael Roth partition->has_dependencies = true; 1392fed39564STomáš Golembiovský 1393fed39564STomáš Golembiovský item = g_new0(GuestDiskInfoList, 1); 1394fed39564STomáš Golembiovský item->value = partition; 1395fed39564STomáš Golembiovský item->next = ret; 1396fed39564STomáš Golembiovský ret = item; 1397fed39564STomáš Golembiovský 1398fed39564STomáš Golembiovský } 1399fed39564STomáš Golembiovský closedir(dp_disk); 1400fed39564STomáš Golembiovský 1401fed39564STomáš Golembiovský return ret; 1402fed39564STomáš Golembiovský } 1403fed39564STomáš Golembiovský 1404fed39564STomáš Golembiovský GuestDiskInfoList *qmp_guest_get_disks(Error **errp) 1405fed39564STomáš Golembiovský { 1406fed39564STomáš Golembiovský GuestDiskInfoList *item, *ret = NULL; 1407fed39564STomáš Golembiovský GuestDiskInfo *disk; 1408fed39564STomáš Golembiovský DIR *dp = NULL; 1409fed39564STomáš Golembiovský struct dirent *de = NULL; 1410fed39564STomáš Golembiovský 1411fed39564STomáš Golembiovský g_debug("listing /sys/block directory"); 1412fed39564STomáš Golembiovský dp = opendir("/sys/block"); 1413fed39564STomáš Golembiovský if (dp == NULL) { 1414fed39564STomáš Golembiovský error_setg_errno(errp, errno, "Can't open directory \"/sys/block\""); 1415fed39564STomáš Golembiovský return NULL; 1416fed39564STomáš Golembiovský } 1417fed39564STomáš Golembiovský while ((de = readdir(dp)) != NULL) { 1418fed39564STomáš Golembiovský g_autofree char *disk_dir = NULL, *line = NULL, 1419fed39564STomáš Golembiovský *size_path = NULL; 1420fed39564STomáš Golembiovský char *dev_name; 1421fed39564STomáš Golembiovský Error *local_err = NULL; 1422fed39564STomáš Golembiovský if (de->d_type != DT_LNK) { 1423fed39564STomáš Golembiovský g_debug(" skipping entry: %s", de->d_name); 1424fed39564STomáš Golembiovský continue; 1425fed39564STomáš Golembiovský } 1426fed39564STomáš Golembiovský 1427fed39564STomáš Golembiovský /* Check size and skip zero-sized disks */ 1428fed39564STomáš Golembiovský g_debug(" checking disk size"); 1429fed39564STomáš Golembiovský size_path = g_strdup_printf("/sys/block/%s/size", de->d_name); 1430fed39564STomáš Golembiovský if (!g_file_get_contents(size_path, &line, NULL, NULL)) { 1431fed39564STomáš Golembiovský g_debug(" failed to read disk size"); 1432fed39564STomáš Golembiovský continue; 1433fed39564STomáš Golembiovský } 1434fed39564STomáš Golembiovský if (g_strcmp0(line, "0\n") == 0) { 1435fed39564STomáš Golembiovský g_debug(" skipping zero-sized disk"); 1436fed39564STomáš Golembiovský continue; 1437fed39564STomáš Golembiovský } 1438fed39564STomáš Golembiovský 1439fed39564STomáš Golembiovský g_debug(" adding %s", de->d_name); 1440fed39564STomáš Golembiovský disk_dir = g_strdup_printf("/sys/block/%s", de->d_name); 1441fed39564STomáš Golembiovský dev_name = get_device_for_syspath(disk_dir); 1442fed39564STomáš Golembiovský if (dev_name == NULL) { 1443fed39564STomáš Golembiovský g_debug("Failed to get device name for syspath: %s", 1444fed39564STomáš Golembiovský disk_dir); 1445fed39564STomáš Golembiovský continue; 1446fed39564STomáš Golembiovský } 1447fed39564STomáš Golembiovský disk = g_new0(GuestDiskInfo, 1); 1448fed39564STomáš Golembiovský disk->name = dev_name; 1449fed39564STomáš Golembiovský disk->partition = false; 1450fed39564STomáš Golembiovský disk->alias = get_alias_for_syspath(disk_dir); 1451fed39564STomáš Golembiovský disk->has_alias = (disk->alias != NULL); 1452fed39564STomáš Golembiovský item = g_new0(GuestDiskInfoList, 1); 1453fed39564STomáš Golembiovský item->value = disk; 1454fed39564STomáš Golembiovský item->next = ret; 1455fed39564STomáš Golembiovský ret = item; 1456fed39564STomáš Golembiovský 1457fed39564STomáš Golembiovský /* Get address for non-virtual devices */ 1458fed39564STomáš Golembiovský bool is_virtual = is_disk_virtual(disk_dir, &local_err); 1459fed39564STomáš Golembiovský if (local_err != NULL) { 1460fed39564STomáš Golembiovský g_debug(" failed to check disk path, ignoring error: %s", 1461fed39564STomáš Golembiovský error_get_pretty(local_err)); 1462fed39564STomáš Golembiovský error_free(local_err); 1463fed39564STomáš Golembiovský local_err = NULL; 1464fed39564STomáš Golembiovský /* Don't try to get the address */ 1465fed39564STomáš Golembiovský is_virtual = true; 1466fed39564STomáš Golembiovský } 1467fed39564STomáš Golembiovský if (!is_virtual) { 1468fed39564STomáš Golembiovský disk->address = get_disk_address(disk_dir, &local_err); 1469fed39564STomáš Golembiovský if (local_err != NULL) { 1470fed39564STomáš Golembiovský g_debug(" failed to get device info, ignoring error: %s", 1471fed39564STomáš Golembiovský error_get_pretty(local_err)); 1472fed39564STomáš Golembiovský error_free(local_err); 1473fed39564STomáš Golembiovský local_err = NULL; 1474fed39564STomáš Golembiovský } else if (disk->address != NULL) { 1475fed39564STomáš Golembiovský disk->has_address = true; 1476fed39564STomáš Golembiovský } 1477fed39564STomáš Golembiovský } 1478fed39564STomáš Golembiovský 1479fed39564STomáš Golembiovský get_disk_deps(disk_dir, disk); 1480fed39564STomáš Golembiovský ret = get_disk_partitions(ret, de->d_name, disk_dir, dev_name); 1481fed39564STomáš Golembiovský } 1482b1b9ab1cSMichael Roth 1483b1b9ab1cSMichael Roth closedir(dp); 1484b1b9ab1cSMichael Roth 1485fed39564STomáš Golembiovský return ret; 1486fed39564STomáš Golembiovský } 1487fed39564STomáš Golembiovský 1488fed39564STomáš Golembiovský #else 1489fed39564STomáš Golembiovský 1490fed39564STomáš Golembiovský GuestDiskInfoList *qmp_guest_get_disks(Error **errp) 1491fed39564STomáš Golembiovský { 1492fed39564STomáš Golembiovský error_setg(errp, QERR_UNSUPPORTED); 1493fed39564STomáš Golembiovský return NULL; 1494fed39564STomáš Golembiovský } 1495fed39564STomáš Golembiovský 1496fed39564STomáš Golembiovský #endif 1497fed39564STomáš Golembiovský 149846d4c572STomoki Sekiyama /* Return a list of the disk device(s)' info which @mount lies on */ 149946d4c572STomoki Sekiyama static GuestFilesystemInfo *build_guest_fsinfo(struct FsMount *mount, 150046d4c572STomoki Sekiyama Error **errp) 150146d4c572STomoki Sekiyama { 150246d4c572STomoki Sekiyama GuestFilesystemInfo *fs = g_malloc0(sizeof(*fs)); 150325b5ff1aSChen Hanxiao struct statvfs buf; 150425b5ff1aSChen Hanxiao unsigned long used, nonroot_total, fr_size; 150546d4c572STomoki Sekiyama char *devpath = g_strdup_printf("/sys/dev/block/%u:%u", 150646d4c572STomoki Sekiyama mount->devmajor, mount->devminor); 150746d4c572STomoki Sekiyama 150846d4c572STomoki Sekiyama fs->mountpoint = g_strdup(mount->dirname); 150946d4c572STomoki Sekiyama fs->type = g_strdup(mount->devtype); 151046d4c572STomoki Sekiyama build_guest_fsinfo_for_device(devpath, fs, errp); 151146d4c572STomoki Sekiyama 151225b5ff1aSChen Hanxiao if (statvfs(fs->mountpoint, &buf) == 0) { 151325b5ff1aSChen Hanxiao fr_size = buf.f_frsize; 151425b5ff1aSChen Hanxiao used = buf.f_blocks - buf.f_bfree; 151525b5ff1aSChen Hanxiao nonroot_total = used + buf.f_bavail; 151625b5ff1aSChen Hanxiao fs->used_bytes = used * fr_size; 151725b5ff1aSChen Hanxiao fs->total_bytes = nonroot_total * fr_size; 151825b5ff1aSChen Hanxiao 151925b5ff1aSChen Hanxiao fs->has_total_bytes = true; 152025b5ff1aSChen Hanxiao fs->has_used_bytes = true; 152125b5ff1aSChen Hanxiao } 152225b5ff1aSChen Hanxiao 152346d4c572STomoki Sekiyama g_free(devpath); 152425b5ff1aSChen Hanxiao 152546d4c572STomoki Sekiyama return fs; 152646d4c572STomoki Sekiyama } 152746d4c572STomoki Sekiyama 152846d4c572STomoki Sekiyama GuestFilesystemInfoList *qmp_guest_get_fsinfo(Error **errp) 152946d4c572STomoki Sekiyama { 153046d4c572STomoki Sekiyama FsMountList mounts; 153146d4c572STomoki Sekiyama struct FsMount *mount; 153246d4c572STomoki Sekiyama GuestFilesystemInfoList *new, *ret = NULL; 153346d4c572STomoki Sekiyama Error *local_err = NULL; 153446d4c572STomoki Sekiyama 153546d4c572STomoki Sekiyama QTAILQ_INIT(&mounts); 153646d4c572STomoki Sekiyama build_fs_mount_list(&mounts, &local_err); 153746d4c572STomoki Sekiyama if (local_err) { 153846d4c572STomoki Sekiyama error_propagate(errp, local_err); 153946d4c572STomoki Sekiyama return NULL; 154046d4c572STomoki Sekiyama } 154146d4c572STomoki Sekiyama 154246d4c572STomoki Sekiyama QTAILQ_FOREACH(mount, &mounts, next) { 154346d4c572STomoki Sekiyama g_debug("Building guest fsinfo for '%s'", mount->dirname); 154446d4c572STomoki Sekiyama 154546d4c572STomoki Sekiyama new = g_malloc0(sizeof(*ret)); 154646d4c572STomoki Sekiyama new->value = build_guest_fsinfo(mount, &local_err); 154746d4c572STomoki Sekiyama new->next = ret; 154846d4c572STomoki Sekiyama ret = new; 154946d4c572STomoki Sekiyama if (local_err) { 155046d4c572STomoki Sekiyama error_propagate(errp, local_err); 155146d4c572STomoki Sekiyama qapi_free_GuestFilesystemInfoList(ret); 155246d4c572STomoki Sekiyama ret = NULL; 155346d4c572STomoki Sekiyama break; 155446d4c572STomoki Sekiyama } 155546d4c572STomoki Sekiyama } 155646d4c572STomoki Sekiyama 155746d4c572STomoki Sekiyama free_fs_mount_list(&mounts); 155846d4c572STomoki Sekiyama return ret; 155946d4c572STomoki Sekiyama } 156046d4c572STomoki Sekiyama 156146d4c572STomoki Sekiyama 1562ec0f694cSTomoki Sekiyama typedef enum { 1563ec0f694cSTomoki Sekiyama FSFREEZE_HOOK_THAW = 0, 1564ec0f694cSTomoki Sekiyama FSFREEZE_HOOK_FREEZE, 1565ec0f694cSTomoki Sekiyama } FsfreezeHookArg; 1566ec0f694cSTomoki Sekiyama 156713a439ecSStefan Weil static const char *fsfreeze_hook_arg_string[] = { 1568ec0f694cSTomoki Sekiyama "thaw", 1569ec0f694cSTomoki Sekiyama "freeze", 1570ec0f694cSTomoki Sekiyama }; 1571ec0f694cSTomoki Sekiyama 157277dbc81bSMarkus Armbruster static void execute_fsfreeze_hook(FsfreezeHookArg arg, Error **errp) 1573ec0f694cSTomoki Sekiyama { 1574ec0f694cSTomoki Sekiyama int status; 1575ec0f694cSTomoki Sekiyama pid_t pid; 1576ec0f694cSTomoki Sekiyama const char *hook; 1577ec0f694cSTomoki Sekiyama const char *arg_str = fsfreeze_hook_arg_string[arg]; 1578ec0f694cSTomoki Sekiyama Error *local_err = NULL; 1579ec0f694cSTomoki Sekiyama 1580ec0f694cSTomoki Sekiyama hook = ga_fsfreeze_hook(ga_state); 1581ec0f694cSTomoki Sekiyama if (!hook) { 1582ec0f694cSTomoki Sekiyama return; 1583ec0f694cSTomoki Sekiyama } 1584ec0f694cSTomoki Sekiyama if (access(hook, X_OK) != 0) { 158577dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "can't access fsfreeze hook '%s'", hook); 1586ec0f694cSTomoki Sekiyama return; 1587ec0f694cSTomoki Sekiyama } 1588ec0f694cSTomoki Sekiyama 1589ec0f694cSTomoki Sekiyama slog("executing fsfreeze hook with arg '%s'", arg_str); 1590ec0f694cSTomoki Sekiyama pid = fork(); 1591ec0f694cSTomoki Sekiyama if (pid == 0) { 1592ec0f694cSTomoki Sekiyama setsid(); 1593ec0f694cSTomoki Sekiyama reopen_fd_to_null(0); 1594ec0f694cSTomoki Sekiyama reopen_fd_to_null(1); 1595ec0f694cSTomoki Sekiyama reopen_fd_to_null(2); 1596ec0f694cSTomoki Sekiyama 1597ec0f694cSTomoki Sekiyama execle(hook, hook, arg_str, NULL, environ); 1598ec0f694cSTomoki Sekiyama _exit(EXIT_FAILURE); 1599ec0f694cSTomoki Sekiyama } else if (pid < 0) { 160077dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to create child process"); 1601ec0f694cSTomoki Sekiyama return; 1602ec0f694cSTomoki Sekiyama } 1603ec0f694cSTomoki Sekiyama 1604ec0f694cSTomoki Sekiyama ga_wait_child(pid, &status, &local_err); 160584d18f06SMarkus Armbruster if (local_err) { 160677dbc81bSMarkus Armbruster error_propagate(errp, local_err); 1607ec0f694cSTomoki Sekiyama return; 1608ec0f694cSTomoki Sekiyama } 1609ec0f694cSTomoki Sekiyama 1610ec0f694cSTomoki Sekiyama if (!WIFEXITED(status)) { 161177dbc81bSMarkus Armbruster error_setg(errp, "fsfreeze hook has terminated abnormally"); 1612ec0f694cSTomoki Sekiyama return; 1613ec0f694cSTomoki Sekiyama } 1614ec0f694cSTomoki Sekiyama 1615ec0f694cSTomoki Sekiyama status = WEXITSTATUS(status); 1616ec0f694cSTomoki Sekiyama if (status) { 161777dbc81bSMarkus Armbruster error_setg(errp, "fsfreeze hook has failed with status %d", status); 1618ec0f694cSTomoki Sekiyama return; 1619ec0f694cSTomoki Sekiyama } 1620ec0f694cSTomoki Sekiyama } 1621ec0f694cSTomoki Sekiyama 1622c216e5adSMichael Roth /* 1623c216e5adSMichael Roth * Return status of freeze/thaw 1624c216e5adSMichael Roth */ 162577dbc81bSMarkus Armbruster GuestFsfreezeStatus qmp_guest_fsfreeze_status(Error **errp) 1626c216e5adSMichael Roth { 1627f22d85e9SMichael Roth if (ga_is_frozen(ga_state)) { 1628f22d85e9SMichael Roth return GUEST_FSFREEZE_STATUS_FROZEN; 1629f22d85e9SMichael Roth } 1630f22d85e9SMichael Roth 1631f22d85e9SMichael Roth return GUEST_FSFREEZE_STATUS_THAWED; 1632c216e5adSMichael Roth } 1633c216e5adSMichael Roth 1634e99bce20STomoki Sekiyama int64_t qmp_guest_fsfreeze_freeze(Error **errp) 1635e99bce20STomoki Sekiyama { 1636e99bce20STomoki Sekiyama return qmp_guest_fsfreeze_freeze_list(false, NULL, errp); 1637e99bce20STomoki Sekiyama } 1638e99bce20STomoki Sekiyama 1639c216e5adSMichael Roth /* 1640c216e5adSMichael Roth * Walk list of mounted file systems in the guest, and freeze the ones which 1641c216e5adSMichael Roth * are real local file systems. 1642c216e5adSMichael Roth */ 1643e99bce20STomoki Sekiyama int64_t qmp_guest_fsfreeze_freeze_list(bool has_mountpoints, 1644e99bce20STomoki Sekiyama strList *mountpoints, 1645e99bce20STomoki Sekiyama Error **errp) 1646c216e5adSMichael Roth { 1647c216e5adSMichael Roth int ret = 0, i = 0; 1648e99bce20STomoki Sekiyama strList *list; 1649af02203fSPaolo Bonzini FsMountList mounts; 1650af02203fSPaolo Bonzini struct FsMount *mount; 1651261551d1SLuiz Capitulino Error *local_err = NULL; 1652c216e5adSMichael Roth int fd; 1653c216e5adSMichael Roth 1654c216e5adSMichael Roth slog("guest-fsfreeze called"); 1655c216e5adSMichael Roth 1656ec0f694cSTomoki Sekiyama execute_fsfreeze_hook(FSFREEZE_HOOK_FREEZE, &local_err); 165784d18f06SMarkus Armbruster if (local_err) { 165877dbc81bSMarkus Armbruster error_propagate(errp, local_err); 1659ec0f694cSTomoki Sekiyama return -1; 1660ec0f694cSTomoki Sekiyama } 1661ec0f694cSTomoki Sekiyama 16629e8aded4SMichael Roth QTAILQ_INIT(&mounts); 1663261551d1SLuiz Capitulino build_fs_mount_list(&mounts, &local_err); 166484d18f06SMarkus Armbruster if (local_err) { 166577dbc81bSMarkus Armbruster error_propagate(errp, local_err); 1666261551d1SLuiz Capitulino return -1; 1667c216e5adSMichael Roth } 1668c216e5adSMichael Roth 1669c216e5adSMichael Roth /* cannot risk guest agent blocking itself on a write in this state */ 1670f22d85e9SMichael Roth ga_set_frozen(ga_state); 1671c216e5adSMichael Roth 1672eae3eb3eSPaolo Bonzini QTAILQ_FOREACH_REVERSE(mount, &mounts, next) { 1673e99bce20STomoki Sekiyama /* To issue fsfreeze in the reverse order of mounts, check if the 1674e99bce20STomoki Sekiyama * mount is listed in the list here */ 1675e99bce20STomoki Sekiyama if (has_mountpoints) { 1676e99bce20STomoki Sekiyama for (list = mountpoints; list; list = list->next) { 1677e99bce20STomoki Sekiyama if (strcmp(list->value, mount->dirname) == 0) { 1678e99bce20STomoki Sekiyama break; 1679e99bce20STomoki Sekiyama } 1680e99bce20STomoki Sekiyama } 1681e99bce20STomoki Sekiyama if (!list) { 1682e99bce20STomoki Sekiyama continue; 1683e99bce20STomoki Sekiyama } 1684e99bce20STomoki Sekiyama } 1685e99bce20STomoki Sekiyama 1686448058aaSDaniel P. Berrangé fd = qemu_open_old(mount->dirname, O_RDONLY); 1687c216e5adSMichael Roth if (fd == -1) { 168877dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to open %s", mount->dirname); 1689c216e5adSMichael Roth goto error; 1690c216e5adSMichael Roth } 1691c216e5adSMichael Roth 1692e35916acSMichael Tokarev /* we try to cull filesystems we know won't work in advance, but other 1693e35916acSMichael Tokarev * filesystems may not implement fsfreeze for less obvious reasons. 16949e8aded4SMichael Roth * these will report EOPNOTSUPP. we simply ignore these when tallying 16959e8aded4SMichael Roth * the number of frozen filesystems. 1696ce2eb6c4SPeter Lieven * if a filesystem is mounted more than once (aka bind mount) a 1697ce2eb6c4SPeter Lieven * consecutive attempt to freeze an already frozen filesystem will 1698ce2eb6c4SPeter Lieven * return EBUSY. 16999e8aded4SMichael Roth * 17009e8aded4SMichael Roth * any other error means a failure to freeze a filesystem we 17019e8aded4SMichael Roth * expect to be freezable, so return an error in those cases 17029e8aded4SMichael Roth * and return system to thawed state. 1703c216e5adSMichael Roth */ 1704c216e5adSMichael Roth ret = ioctl(fd, FIFREEZE); 17059e8aded4SMichael Roth if (ret == -1) { 1706ce2eb6c4SPeter Lieven if (errno != EOPNOTSUPP && errno != EBUSY) { 170777dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to freeze %s", 1708617fbbc1SLuiz Capitulino mount->dirname); 1709c216e5adSMichael Roth close(fd); 1710c216e5adSMichael Roth goto error; 1711c216e5adSMichael Roth } 17129e8aded4SMichael Roth } else { 1713c216e5adSMichael Roth i++; 1714c216e5adSMichael Roth } 17159e8aded4SMichael Roth close(fd); 17169e8aded4SMichael Roth } 1717c216e5adSMichael Roth 1718af02203fSPaolo Bonzini free_fs_mount_list(&mounts); 171965650f01SChen Hanxiao /* We may not issue any FIFREEZE here. 172065650f01SChen Hanxiao * Just unset ga_state here and ready for the next call. 172165650f01SChen Hanxiao */ 172265650f01SChen Hanxiao if (i == 0) { 172365650f01SChen Hanxiao ga_unset_frozen(ga_state); 172465650f01SChen Hanxiao } 1725c216e5adSMichael Roth return i; 1726c216e5adSMichael Roth 1727c216e5adSMichael Roth error: 1728af02203fSPaolo Bonzini free_fs_mount_list(&mounts); 1729c216e5adSMichael Roth qmp_guest_fsfreeze_thaw(NULL); 1730c216e5adSMichael Roth return 0; 1731c216e5adSMichael Roth } 1732c216e5adSMichael Roth 1733c216e5adSMichael Roth /* 1734c216e5adSMichael Roth * Walk list of frozen file systems in the guest, and thaw them. 1735c216e5adSMichael Roth */ 173677dbc81bSMarkus Armbruster int64_t qmp_guest_fsfreeze_thaw(Error **errp) 1737c216e5adSMichael Roth { 1738c216e5adSMichael Roth int ret; 1739af02203fSPaolo Bonzini FsMountList mounts; 1740af02203fSPaolo Bonzini FsMount *mount; 17419e8aded4SMichael Roth int fd, i = 0, logged; 1742261551d1SLuiz Capitulino Error *local_err = NULL; 1743c216e5adSMichael Roth 17449e8aded4SMichael Roth QTAILQ_INIT(&mounts); 1745261551d1SLuiz Capitulino build_fs_mount_list(&mounts, &local_err); 174684d18f06SMarkus Armbruster if (local_err) { 174777dbc81bSMarkus Armbruster error_propagate(errp, local_err); 17489e8aded4SMichael Roth return 0; 17499e8aded4SMichael Roth } 17509e8aded4SMichael Roth 17519e8aded4SMichael Roth QTAILQ_FOREACH(mount, &mounts, next) { 17529e8aded4SMichael Roth logged = false; 1753448058aaSDaniel P. Berrangé fd = qemu_open_old(mount->dirname, O_RDONLY); 1754c216e5adSMichael Roth if (fd == -1) { 1755c216e5adSMichael Roth continue; 1756c216e5adSMichael Roth } 17579e8aded4SMichael Roth /* we have no way of knowing whether a filesystem was actually unfrozen 17589e8aded4SMichael Roth * as a result of a successful call to FITHAW, only that if an error 17599e8aded4SMichael Roth * was returned the filesystem was *not* unfrozen by that particular 17609e8aded4SMichael Roth * call. 17619e8aded4SMichael Roth * 1762a31f0531SJim Meyering * since multiple preceding FIFREEZEs require multiple calls to FITHAW 17639e8aded4SMichael Roth * to unfreeze, continuing issuing FITHAW until an error is returned, 17649e8aded4SMichael Roth * in which case either the filesystem is in an unfreezable state, or, 17659e8aded4SMichael Roth * more likely, it was thawed previously (and remains so afterward). 17669e8aded4SMichael Roth * 17679e8aded4SMichael Roth * also, since the most recent successful call is the one that did 17689e8aded4SMichael Roth * the actual unfreeze, we can use this to provide an accurate count 17699e8aded4SMichael Roth * of the number of filesystems unfrozen by guest-fsfreeze-thaw, which 17709e8aded4SMichael Roth * may * be useful for determining whether a filesystem was unfrozen 17719e8aded4SMichael Roth * during the freeze/thaw phase by a process other than qemu-ga. 17729e8aded4SMichael Roth */ 17739e8aded4SMichael Roth do { 1774c216e5adSMichael Roth ret = ioctl(fd, FITHAW); 17759e8aded4SMichael Roth if (ret == 0 && !logged) { 1776c216e5adSMichael Roth i++; 17779e8aded4SMichael Roth logged = true; 17789e8aded4SMichael Roth } 17799e8aded4SMichael Roth } while (ret == 0); 17809e8aded4SMichael Roth close(fd); 1781c216e5adSMichael Roth } 1782c216e5adSMichael Roth 1783f22d85e9SMichael Roth ga_unset_frozen(ga_state); 1784af02203fSPaolo Bonzini free_fs_mount_list(&mounts); 1785ec0f694cSTomoki Sekiyama 178677dbc81bSMarkus Armbruster execute_fsfreeze_hook(FSFREEZE_HOOK_THAW, errp); 1787ec0f694cSTomoki Sekiyama 1788c216e5adSMichael Roth return i; 1789c216e5adSMichael Roth } 1790c216e5adSMichael Roth 1791c216e5adSMichael Roth static void guest_fsfreeze_cleanup(void) 1792c216e5adSMichael Roth { 1793c216e5adSMichael Roth Error *err = NULL; 1794c216e5adSMichael Roth 1795f22d85e9SMichael Roth if (ga_is_frozen(ga_state) == GUEST_FSFREEZE_STATUS_FROZEN) { 17966f686749SMarkus Armbruster qmp_guest_fsfreeze_thaw(&err); 17976f686749SMarkus Armbruster if (err) { 17986f686749SMarkus Armbruster slog("failed to clean up frozen filesystems: %s", 17996f686749SMarkus Armbruster error_get_pretty(err)); 18006f686749SMarkus Armbruster error_free(err); 1801c216e5adSMichael Roth } 1802c216e5adSMichael Roth } 1803c216e5adSMichael Roth } 1804e72c3f2eSMichael Roth #endif /* CONFIG_FSFREEZE */ 1805c216e5adSMichael Roth 1806eab5fd59SPaolo Bonzini #if defined(CONFIG_FSTRIM) 1807eab5fd59SPaolo Bonzini /* 1808eab5fd59SPaolo Bonzini * Walk list of mounted file systems in the guest, and trim them. 1809eab5fd59SPaolo Bonzini */ 1810e82855d9SJustin Ossevoort GuestFilesystemTrimResponse * 1811e82855d9SJustin Ossevoort qmp_guest_fstrim(bool has_minimum, int64_t minimum, Error **errp) 1812eab5fd59SPaolo Bonzini { 1813e82855d9SJustin Ossevoort GuestFilesystemTrimResponse *response; 1814e82855d9SJustin Ossevoort GuestFilesystemTrimResultList *list; 1815e82855d9SJustin Ossevoort GuestFilesystemTrimResult *result; 1816eab5fd59SPaolo Bonzini int ret = 0; 1817eab5fd59SPaolo Bonzini FsMountList mounts; 1818eab5fd59SPaolo Bonzini struct FsMount *mount; 1819eab5fd59SPaolo Bonzini int fd; 1820261551d1SLuiz Capitulino Error *local_err = NULL; 182173a652a1SJustin Ossevoort struct fstrim_range r; 1822eab5fd59SPaolo Bonzini 1823eab5fd59SPaolo Bonzini slog("guest-fstrim called"); 1824eab5fd59SPaolo Bonzini 1825eab5fd59SPaolo Bonzini QTAILQ_INIT(&mounts); 1826261551d1SLuiz Capitulino build_fs_mount_list(&mounts, &local_err); 182784d18f06SMarkus Armbruster if (local_err) { 182877dbc81bSMarkus Armbruster error_propagate(errp, local_err); 1829e82855d9SJustin Ossevoort return NULL; 1830eab5fd59SPaolo Bonzini } 1831eab5fd59SPaolo Bonzini 1832e82855d9SJustin Ossevoort response = g_malloc0(sizeof(*response)); 1833e82855d9SJustin Ossevoort 1834eab5fd59SPaolo Bonzini QTAILQ_FOREACH(mount, &mounts, next) { 1835e82855d9SJustin Ossevoort result = g_malloc0(sizeof(*result)); 1836e82855d9SJustin Ossevoort result->path = g_strdup(mount->dirname); 1837e82855d9SJustin Ossevoort 1838e82855d9SJustin Ossevoort list = g_malloc0(sizeof(*list)); 1839e82855d9SJustin Ossevoort list->value = result; 1840e82855d9SJustin Ossevoort list->next = response->paths; 1841e82855d9SJustin Ossevoort response->paths = list; 1842e82855d9SJustin Ossevoort 1843448058aaSDaniel P. Berrangé fd = qemu_open_old(mount->dirname, O_RDONLY); 1844eab5fd59SPaolo Bonzini if (fd == -1) { 1845e82855d9SJustin Ossevoort result->error = g_strdup_printf("failed to open: %s", 1846e82855d9SJustin Ossevoort strerror(errno)); 1847e82855d9SJustin Ossevoort result->has_error = true; 1848e82855d9SJustin Ossevoort continue; 1849eab5fd59SPaolo Bonzini } 1850eab5fd59SPaolo Bonzini 1851e35916acSMichael Tokarev /* We try to cull filesystems we know won't work in advance, but other 1852e35916acSMichael Tokarev * filesystems may not implement fstrim for less obvious reasons. 1853e35916acSMichael Tokarev * These will report EOPNOTSUPP; while in some other cases ENOTTY 1854e35916acSMichael Tokarev * will be reported (e.g. CD-ROMs). 1855e82855d9SJustin Ossevoort * Any other error means an unexpected error. 1856eab5fd59SPaolo Bonzini */ 185773a652a1SJustin Ossevoort r.start = 0; 185873a652a1SJustin Ossevoort r.len = -1; 185973a652a1SJustin Ossevoort r.minlen = has_minimum ? minimum : 0; 1860eab5fd59SPaolo Bonzini ret = ioctl(fd, FITRIM, &r); 1861eab5fd59SPaolo Bonzini if (ret == -1) { 1862e82855d9SJustin Ossevoort result->has_error = true; 1863e82855d9SJustin Ossevoort if (errno == ENOTTY || errno == EOPNOTSUPP) { 1864e82855d9SJustin Ossevoort result->error = g_strdup("trim not supported"); 1865e82855d9SJustin Ossevoort } else { 1866e82855d9SJustin Ossevoort result->error = g_strdup_printf("failed to trim: %s", 1867e82855d9SJustin Ossevoort strerror(errno)); 1868e82855d9SJustin Ossevoort } 1869eab5fd59SPaolo Bonzini close(fd); 1870e82855d9SJustin Ossevoort continue; 1871eab5fd59SPaolo Bonzini } 1872e82855d9SJustin Ossevoort 1873e82855d9SJustin Ossevoort result->has_minimum = true; 1874e82855d9SJustin Ossevoort result->minimum = r.minlen; 1875e82855d9SJustin Ossevoort result->has_trimmed = true; 1876e82855d9SJustin Ossevoort result->trimmed = r.len; 1877eab5fd59SPaolo Bonzini close(fd); 1878eab5fd59SPaolo Bonzini } 1879eab5fd59SPaolo Bonzini 1880eab5fd59SPaolo Bonzini free_fs_mount_list(&mounts); 1881e82855d9SJustin Ossevoort return response; 1882eab5fd59SPaolo Bonzini } 1883eab5fd59SPaolo Bonzini #endif /* CONFIG_FSTRIM */ 1884eab5fd59SPaolo Bonzini 1885eab5fd59SPaolo Bonzini 188611d0f125SLuiz Capitulino #define LINUX_SYS_STATE_FILE "/sys/power/state" 188711d0f125SLuiz Capitulino #define SUSPEND_SUPPORTED 0 188811d0f125SLuiz Capitulino #define SUSPEND_NOT_SUPPORTED 1 188911d0f125SLuiz Capitulino 18908b020b5eSDaniel Henrique Barboza typedef enum { 18918b020b5eSDaniel Henrique Barboza SUSPEND_MODE_DISK = 0, 18928b020b5eSDaniel Henrique Barboza SUSPEND_MODE_RAM = 1, 18938b020b5eSDaniel Henrique Barboza SUSPEND_MODE_HYBRID = 2, 18948b020b5eSDaniel Henrique Barboza } SuspendMode; 18958b020b5eSDaniel Henrique Barboza 18968b020b5eSDaniel Henrique Barboza /* 18978b020b5eSDaniel Henrique Barboza * Executes a command in a child process using g_spawn_sync, 18988b020b5eSDaniel Henrique Barboza * returning an int >= 0 representing the exit status of the 18998b020b5eSDaniel Henrique Barboza * process. 19008b020b5eSDaniel Henrique Barboza * 19018b020b5eSDaniel Henrique Barboza * If the program wasn't found in path, returns -1. 19028b020b5eSDaniel Henrique Barboza * 19038b020b5eSDaniel Henrique Barboza * If a problem happened when creating the child process, 19048b020b5eSDaniel Henrique Barboza * returns -1 and errp is set. 19058b020b5eSDaniel Henrique Barboza */ 19068b020b5eSDaniel Henrique Barboza static int run_process_child(const char *command[], Error **errp) 19078b020b5eSDaniel Henrique Barboza { 19088b020b5eSDaniel Henrique Barboza int exit_status, spawn_flag; 19098b020b5eSDaniel Henrique Barboza GError *g_err = NULL; 19108b020b5eSDaniel Henrique Barboza bool success; 19118b020b5eSDaniel Henrique Barboza 19128b020b5eSDaniel Henrique Barboza spawn_flag = G_SPAWN_SEARCH_PATH | G_SPAWN_STDOUT_TO_DEV_NULL | 19138b020b5eSDaniel Henrique Barboza G_SPAWN_STDERR_TO_DEV_NULL; 19148b020b5eSDaniel Henrique Barboza 19158b020b5eSDaniel Henrique Barboza success = g_spawn_sync(NULL, (char **)command, environ, spawn_flag, 19168b020b5eSDaniel Henrique Barboza NULL, NULL, NULL, NULL, 19178b020b5eSDaniel Henrique Barboza &exit_status, &g_err); 19188b020b5eSDaniel Henrique Barboza 19198b020b5eSDaniel Henrique Barboza if (success) { 19208b020b5eSDaniel Henrique Barboza return WEXITSTATUS(exit_status); 19218b020b5eSDaniel Henrique Barboza } 19228b020b5eSDaniel Henrique Barboza 19238b020b5eSDaniel Henrique Barboza if (g_err && (g_err->code != G_SPAWN_ERROR_NOENT)) { 19248b020b5eSDaniel Henrique Barboza error_setg(errp, "failed to create child process, error '%s'", 19258b020b5eSDaniel Henrique Barboza g_err->message); 19268b020b5eSDaniel Henrique Barboza } 19278b020b5eSDaniel Henrique Barboza 19288b020b5eSDaniel Henrique Barboza g_error_free(g_err); 19298b020b5eSDaniel Henrique Barboza return -1; 19308b020b5eSDaniel Henrique Barboza } 19318b020b5eSDaniel Henrique Barboza 1932067927d6SDaniel Henrique Barboza static bool systemd_supports_mode(SuspendMode mode, Error **errp) 1933067927d6SDaniel Henrique Barboza { 1934067927d6SDaniel Henrique Barboza const char *systemctl_args[3] = {"systemd-hibernate", "systemd-suspend", 1935067927d6SDaniel Henrique Barboza "systemd-hybrid-sleep"}; 1936067927d6SDaniel Henrique Barboza const char *cmd[4] = {"systemctl", "status", systemctl_args[mode], NULL}; 1937067927d6SDaniel Henrique Barboza int status; 1938067927d6SDaniel Henrique Barboza 1939992861fbSMarkus Armbruster status = run_process_child(cmd, errp); 1940067927d6SDaniel Henrique Barboza 1941067927d6SDaniel Henrique Barboza /* 1942067927d6SDaniel Henrique Barboza * systemctl status uses LSB return codes so we can expect 1943067927d6SDaniel Henrique Barboza * status > 0 and be ok. To assert if the guest has support 1944067927d6SDaniel Henrique Barboza * for the selected suspend mode, status should be < 4. 4 is 1945067927d6SDaniel Henrique Barboza * the code for unknown service status, the return value when 1946067927d6SDaniel Henrique Barboza * the service does not exist. A common value is status = 3 1947067927d6SDaniel Henrique Barboza * (program is not running). 1948067927d6SDaniel Henrique Barboza */ 1949067927d6SDaniel Henrique Barboza if (status > 0 && status < 4) { 1950067927d6SDaniel Henrique Barboza return true; 1951067927d6SDaniel Henrique Barboza } 1952067927d6SDaniel Henrique Barboza 1953067927d6SDaniel Henrique Barboza return false; 1954067927d6SDaniel Henrique Barboza } 1955067927d6SDaniel Henrique Barboza 1956067927d6SDaniel Henrique Barboza static void systemd_suspend(SuspendMode mode, Error **errp) 1957067927d6SDaniel Henrique Barboza { 1958067927d6SDaniel Henrique Barboza Error *local_err = NULL; 1959067927d6SDaniel Henrique Barboza const char *systemctl_args[3] = {"hibernate", "suspend", "hybrid-sleep"}; 1960067927d6SDaniel Henrique Barboza const char *cmd[3] = {"systemctl", systemctl_args[mode], NULL}; 1961067927d6SDaniel Henrique Barboza int status; 1962067927d6SDaniel Henrique Barboza 1963067927d6SDaniel Henrique Barboza status = run_process_child(cmd, &local_err); 1964067927d6SDaniel Henrique Barboza 1965067927d6SDaniel Henrique Barboza if (status == 0) { 1966067927d6SDaniel Henrique Barboza return; 1967067927d6SDaniel Henrique Barboza } 1968067927d6SDaniel Henrique Barboza 1969067927d6SDaniel Henrique Barboza if ((status == -1) && !local_err) { 1970067927d6SDaniel Henrique Barboza error_setg(errp, "the helper program 'systemctl %s' was not found", 1971067927d6SDaniel Henrique Barboza systemctl_args[mode]); 1972067927d6SDaniel Henrique Barboza return; 1973067927d6SDaniel Henrique Barboza } 1974067927d6SDaniel Henrique Barboza 1975067927d6SDaniel Henrique Barboza if (local_err) { 1976067927d6SDaniel Henrique Barboza error_propagate(errp, local_err); 1977067927d6SDaniel Henrique Barboza } else { 1978067927d6SDaniel Henrique Barboza error_setg(errp, "the helper program 'systemctl %s' returned an " 1979067927d6SDaniel Henrique Barboza "unexpected exit status code (%d)", 1980067927d6SDaniel Henrique Barboza systemctl_args[mode], status); 1981067927d6SDaniel Henrique Barboza } 1982067927d6SDaniel Henrique Barboza } 1983067927d6SDaniel Henrique Barboza 19848b020b5eSDaniel Henrique Barboza static bool pmutils_supports_mode(SuspendMode mode, Error **errp) 198511d0f125SLuiz Capitulino { 19866b26e837SLuiz Capitulino Error *local_err = NULL; 19878b020b5eSDaniel Henrique Barboza const char *pmutils_args[3] = {"--hibernate", "--suspend", 19888b020b5eSDaniel Henrique Barboza "--suspend-hybrid"}; 19898b020b5eSDaniel Henrique Barboza const char *cmd[3] = {"pm-is-supported", pmutils_args[mode], NULL}; 1990dc8764f0SLuiz Capitulino int status; 199111d0f125SLuiz Capitulino 19928b020b5eSDaniel Henrique Barboza status = run_process_child(cmd, &local_err); 1993304a0fcbSDaniel Henrique Barboza 19948b020b5eSDaniel Henrique Barboza if (status == SUSPEND_SUPPORTED) { 19958b020b5eSDaniel Henrique Barboza return true; 1996304a0fcbSDaniel Henrique Barboza } 1997304a0fcbSDaniel Henrique Barboza 19988b020b5eSDaniel Henrique Barboza if ((status == -1) && !local_err) { 19998b020b5eSDaniel Henrique Barboza return false; 2000a5fcf0e3SDaniel Henrique Barboza } 200111d0f125SLuiz Capitulino 200284d18f06SMarkus Armbruster if (local_err) { 200377dbc81bSMarkus Armbruster error_propagate(errp, local_err); 20048b020b5eSDaniel Henrique Barboza } else { 200577dbc81bSMarkus Armbruster error_setg(errp, 20068b020b5eSDaniel Henrique Barboza "the helper program '%s' returned an unexpected exit" 20078b020b5eSDaniel Henrique Barboza " status code (%d)", "pm-is-supported", status); 2008dc8764f0SLuiz Capitulino } 200911d0f125SLuiz Capitulino 20108b020b5eSDaniel Henrique Barboza return false; 2011a5fcf0e3SDaniel Henrique Barboza } 2012a5fcf0e3SDaniel Henrique Barboza 20138b020b5eSDaniel Henrique Barboza static void pmutils_suspend(SuspendMode mode, Error **errp) 2014246d76ebSDaniel Henrique Barboza { 2015246d76ebSDaniel Henrique Barboza Error *local_err = NULL; 20168b020b5eSDaniel Henrique Barboza const char *pmutils_binaries[3] = {"pm-hibernate", "pm-suspend", 20178b020b5eSDaniel Henrique Barboza "pm-suspend-hybrid"}; 20188b020b5eSDaniel Henrique Barboza const char *cmd[2] = {pmutils_binaries[mode], NULL}; 2019246d76ebSDaniel Henrique Barboza int status; 2020246d76ebSDaniel Henrique Barboza 20218b020b5eSDaniel Henrique Barboza status = run_process_child(cmd, &local_err); 2022246d76ebSDaniel Henrique Barboza 20238b020b5eSDaniel Henrique Barboza if (status == 0) { 2024246d76ebSDaniel Henrique Barboza return; 2025246d76ebSDaniel Henrique Barboza } 2026246d76ebSDaniel Henrique Barboza 20278b020b5eSDaniel Henrique Barboza if ((status == -1) && !local_err) { 20288b020b5eSDaniel Henrique Barboza error_setg(errp, "the helper program '%s' was not found", 20298b020b5eSDaniel Henrique Barboza pmutils_binaries[mode]); 2030246d76ebSDaniel Henrique Barboza return; 2031246d76ebSDaniel Henrique Barboza } 2032246d76ebSDaniel Henrique Barboza 2033246d76ebSDaniel Henrique Barboza if (local_err) { 2034246d76ebSDaniel Henrique Barboza error_propagate(errp, local_err); 20358b020b5eSDaniel Henrique Barboza } else { 2036246d76ebSDaniel Henrique Barboza error_setg(errp, 20378b020b5eSDaniel Henrique Barboza "the helper program '%s' returned an unexpected exit" 20388b020b5eSDaniel Henrique Barboza " status code (%d)", pmutils_binaries[mode], status); 20398b020b5eSDaniel Henrique Barboza } 2040246d76ebSDaniel Henrique Barboza } 2041246d76ebSDaniel Henrique Barboza 20428b020b5eSDaniel Henrique Barboza static bool linux_sys_state_supports_mode(SuspendMode mode, Error **errp) 2043a5fcf0e3SDaniel Henrique Barboza { 20448b020b5eSDaniel Henrique Barboza const char *sysfile_strs[3] = {"disk", "mem", NULL}; 20458b020b5eSDaniel Henrique Barboza const char *sysfile_str = sysfile_strs[mode]; 2046a5fcf0e3SDaniel Henrique Barboza char buf[32]; /* hopefully big enough */ 2047a5fcf0e3SDaniel Henrique Barboza int fd; 2048a5fcf0e3SDaniel Henrique Barboza ssize_t ret; 2049a5fcf0e3SDaniel Henrique Barboza 20508b020b5eSDaniel Henrique Barboza if (!sysfile_str) { 20518b020b5eSDaniel Henrique Barboza error_setg(errp, "unknown guest suspend mode"); 2052a5fcf0e3SDaniel Henrique Barboza return false; 2053a5fcf0e3SDaniel Henrique Barboza } 2054a5fcf0e3SDaniel Henrique Barboza 2055a5fcf0e3SDaniel Henrique Barboza fd = open(LINUX_SYS_STATE_FILE, O_RDONLY); 2056a5fcf0e3SDaniel Henrique Barboza if (fd < 0) { 2057a5fcf0e3SDaniel Henrique Barboza return false; 2058a5fcf0e3SDaniel Henrique Barboza } 2059a5fcf0e3SDaniel Henrique Barboza 2060a5fcf0e3SDaniel Henrique Barboza ret = read(fd, buf, sizeof(buf) - 1); 2061d9c745c1SPaolo Bonzini close(fd); 2062a5fcf0e3SDaniel Henrique Barboza if (ret <= 0) { 2063a5fcf0e3SDaniel Henrique Barboza return false; 2064a5fcf0e3SDaniel Henrique Barboza } 2065a5fcf0e3SDaniel Henrique Barboza buf[ret] = '\0'; 2066a5fcf0e3SDaniel Henrique Barboza 2067a5fcf0e3SDaniel Henrique Barboza if (strstr(buf, sysfile_str)) { 2068a5fcf0e3SDaniel Henrique Barboza return true; 2069a5fcf0e3SDaniel Henrique Barboza } 2070a5fcf0e3SDaniel Henrique Barboza return false; 2071a5fcf0e3SDaniel Henrique Barboza } 2072a5fcf0e3SDaniel Henrique Barboza 20738b020b5eSDaniel Henrique Barboza static void linux_sys_state_suspend(SuspendMode mode, Error **errp) 2074246d76ebSDaniel Henrique Barboza { 2075246d76ebSDaniel Henrique Barboza Error *local_err = NULL; 20768b020b5eSDaniel Henrique Barboza const char *sysfile_strs[3] = {"disk", "mem", NULL}; 20778b020b5eSDaniel Henrique Barboza const char *sysfile_str = sysfile_strs[mode]; 2078246d76ebSDaniel Henrique Barboza pid_t pid; 2079246d76ebSDaniel Henrique Barboza int status; 2080246d76ebSDaniel Henrique Barboza 20818b020b5eSDaniel Henrique Barboza if (!sysfile_str) { 2082246d76ebSDaniel Henrique Barboza error_setg(errp, "unknown guest suspend mode"); 2083246d76ebSDaniel Henrique Barboza return; 2084246d76ebSDaniel Henrique Barboza } 2085246d76ebSDaniel Henrique Barboza 2086246d76ebSDaniel Henrique Barboza pid = fork(); 2087246d76ebSDaniel Henrique Barboza if (!pid) { 2088246d76ebSDaniel Henrique Barboza /* child */ 2089246d76ebSDaniel Henrique Barboza int fd; 2090246d76ebSDaniel Henrique Barboza 2091246d76ebSDaniel Henrique Barboza setsid(); 2092246d76ebSDaniel Henrique Barboza reopen_fd_to_null(0); 2093246d76ebSDaniel Henrique Barboza reopen_fd_to_null(1); 2094246d76ebSDaniel Henrique Barboza reopen_fd_to_null(2); 2095246d76ebSDaniel Henrique Barboza 2096246d76ebSDaniel Henrique Barboza fd = open(LINUX_SYS_STATE_FILE, O_WRONLY); 2097246d76ebSDaniel Henrique Barboza if (fd < 0) { 2098246d76ebSDaniel Henrique Barboza _exit(EXIT_FAILURE); 2099246d76ebSDaniel Henrique Barboza } 2100246d76ebSDaniel Henrique Barboza 2101246d76ebSDaniel Henrique Barboza if (write(fd, sysfile_str, strlen(sysfile_str)) < 0) { 2102246d76ebSDaniel Henrique Barboza _exit(EXIT_FAILURE); 2103246d76ebSDaniel Henrique Barboza } 2104246d76ebSDaniel Henrique Barboza 2105246d76ebSDaniel Henrique Barboza _exit(EXIT_SUCCESS); 2106246d76ebSDaniel Henrique Barboza } else if (pid < 0) { 2107246d76ebSDaniel Henrique Barboza error_setg_errno(errp, errno, "failed to create child process"); 2108246d76ebSDaniel Henrique Barboza return; 2109246d76ebSDaniel Henrique Barboza } 2110246d76ebSDaniel Henrique Barboza 2111246d76ebSDaniel Henrique Barboza ga_wait_child(pid, &status, &local_err); 2112246d76ebSDaniel Henrique Barboza if (local_err) { 2113246d76ebSDaniel Henrique Barboza error_propagate(errp, local_err); 2114246d76ebSDaniel Henrique Barboza return; 2115246d76ebSDaniel Henrique Barboza } 2116246d76ebSDaniel Henrique Barboza 2117246d76ebSDaniel Henrique Barboza if (WEXITSTATUS(status)) { 2118246d76ebSDaniel Henrique Barboza error_setg(errp, "child process has failed to suspend"); 2119246d76ebSDaniel Henrique Barboza } 2120246d76ebSDaniel Henrique Barboza 2121246d76ebSDaniel Henrique Barboza } 2122246d76ebSDaniel Henrique Barboza 21238b020b5eSDaniel Henrique Barboza static void guest_suspend(SuspendMode mode, Error **errp) 212411d0f125SLuiz Capitulino { 21257b376087SLuiz Capitulino Error *local_err = NULL; 212673e1d8ebSDaniel Henrique Barboza bool mode_supported = false; 212711d0f125SLuiz Capitulino 212873e1d8ebSDaniel Henrique Barboza if (systemd_supports_mode(mode, &local_err)) { 212973e1d8ebSDaniel Henrique Barboza mode_supported = true; 2130067927d6SDaniel Henrique Barboza systemd_suspend(mode, &local_err); 213173e1d8ebSDaniel Henrique Barboza } 213273e1d8ebSDaniel Henrique Barboza 2133067927d6SDaniel Henrique Barboza if (!local_err) { 2134067927d6SDaniel Henrique Barboza return; 2135067927d6SDaniel Henrique Barboza } 2136067927d6SDaniel Henrique Barboza 2137067927d6SDaniel Henrique Barboza error_free(local_err); 21386a4a3853SVladimir Sementsov-Ogievskiy local_err = NULL; 2139067927d6SDaniel Henrique Barboza 214073e1d8ebSDaniel Henrique Barboza if (pmutils_supports_mode(mode, &local_err)) { 214173e1d8ebSDaniel Henrique Barboza mode_supported = true; 21428b020b5eSDaniel Henrique Barboza pmutils_suspend(mode, &local_err); 214373e1d8ebSDaniel Henrique Barboza } 214473e1d8ebSDaniel Henrique Barboza 2145246d76ebSDaniel Henrique Barboza if (!local_err) { 2146304a0fcbSDaniel Henrique Barboza return; 2147304a0fcbSDaniel Henrique Barboza } 2148304a0fcbSDaniel Henrique Barboza 2149246d76ebSDaniel Henrique Barboza error_free(local_err); 21506a4a3853SVladimir Sementsov-Ogievskiy local_err = NULL; 215111d0f125SLuiz Capitulino 215273e1d8ebSDaniel Henrique Barboza if (linux_sys_state_supports_mode(mode, &local_err)) { 215373e1d8ebSDaniel Henrique Barboza mode_supported = true; 21548b020b5eSDaniel Henrique Barboza linux_sys_state_suspend(mode, &local_err); 215573e1d8ebSDaniel Henrique Barboza } 215673e1d8ebSDaniel Henrique Barboza 215773e1d8ebSDaniel Henrique Barboza if (!mode_supported) { 21586a4a3853SVladimir Sementsov-Ogievskiy error_free(local_err); 215973e1d8ebSDaniel Henrique Barboza error_setg(errp, 216073e1d8ebSDaniel Henrique Barboza "the requested suspend mode is not supported by the guest"); 2161b2322003SMarkus Armbruster } else { 216277dbc81bSMarkus Armbruster error_propagate(errp, local_err); 21637b376087SLuiz Capitulino } 216411d0f125SLuiz Capitulino } 216511d0f125SLuiz Capitulino 216677dbc81bSMarkus Armbruster void qmp_guest_suspend_disk(Error **errp) 216711d0f125SLuiz Capitulino { 2168304a0fcbSDaniel Henrique Barboza guest_suspend(SUSPEND_MODE_DISK, errp); 216911d0f125SLuiz Capitulino } 217011d0f125SLuiz Capitulino 217177dbc81bSMarkus Armbruster void qmp_guest_suspend_ram(Error **errp) 2172fbf42210SLuiz Capitulino { 2173304a0fcbSDaniel Henrique Barboza guest_suspend(SUSPEND_MODE_RAM, errp); 2174fbf42210SLuiz Capitulino } 2175fbf42210SLuiz Capitulino 217677dbc81bSMarkus Armbruster void qmp_guest_suspend_hybrid(Error **errp) 217795f4f404SLuiz Capitulino { 2178304a0fcbSDaniel Henrique Barboza guest_suspend(SUSPEND_MODE_HYBRID, errp); 217995f4f404SLuiz Capitulino } 218095f4f404SLuiz Capitulino 21813424fc9fSMichal Privoznik static GuestNetworkInterfaceList * 21823424fc9fSMichal Privoznik guest_find_interface(GuestNetworkInterfaceList *head, 21833424fc9fSMichal Privoznik const char *name) 21843424fc9fSMichal Privoznik { 21853424fc9fSMichal Privoznik for (; head; head = head->next) { 21863424fc9fSMichal Privoznik if (strcmp(head->value->name, name) == 0) { 21873424fc9fSMichal Privoznik break; 21883424fc9fSMichal Privoznik } 21893424fc9fSMichal Privoznik } 21903424fc9fSMichal Privoznik 21913424fc9fSMichal Privoznik return head; 21923424fc9fSMichal Privoznik } 21933424fc9fSMichal Privoznik 219453f9fcb2SZhiPeng Lu static int guest_get_network_stats(const char *name, 219553f9fcb2SZhiPeng Lu GuestNetworkInterfaceStat *stats) 219653f9fcb2SZhiPeng Lu { 219753f9fcb2SZhiPeng Lu int name_len; 219853f9fcb2SZhiPeng Lu char const *devinfo = "/proc/net/dev"; 219953f9fcb2SZhiPeng Lu FILE *fp; 220053f9fcb2SZhiPeng Lu char *line = NULL, *colon; 220153f9fcb2SZhiPeng Lu size_t n = 0; 220253f9fcb2SZhiPeng Lu fp = fopen(devinfo, "r"); 220353f9fcb2SZhiPeng Lu if (!fp) { 220453f9fcb2SZhiPeng Lu return -1; 220553f9fcb2SZhiPeng Lu } 220653f9fcb2SZhiPeng Lu name_len = strlen(name); 220753f9fcb2SZhiPeng Lu while (getline(&line, &n, fp) != -1) { 220853f9fcb2SZhiPeng Lu long long dummy; 220953f9fcb2SZhiPeng Lu long long rx_bytes; 221053f9fcb2SZhiPeng Lu long long rx_packets; 221153f9fcb2SZhiPeng Lu long long rx_errs; 221253f9fcb2SZhiPeng Lu long long rx_dropped; 221353f9fcb2SZhiPeng Lu long long tx_bytes; 221453f9fcb2SZhiPeng Lu long long tx_packets; 221553f9fcb2SZhiPeng Lu long long tx_errs; 221653f9fcb2SZhiPeng Lu long long tx_dropped; 221753f9fcb2SZhiPeng Lu char *trim_line; 221853f9fcb2SZhiPeng Lu trim_line = g_strchug(line); 221953f9fcb2SZhiPeng Lu if (trim_line[0] == '\0') { 222053f9fcb2SZhiPeng Lu continue; 222153f9fcb2SZhiPeng Lu } 222253f9fcb2SZhiPeng Lu colon = strchr(trim_line, ':'); 222353f9fcb2SZhiPeng Lu if (!colon) { 222453f9fcb2SZhiPeng Lu continue; 222553f9fcb2SZhiPeng Lu } 222653f9fcb2SZhiPeng Lu if (colon - name_len == trim_line && 222753f9fcb2SZhiPeng Lu strncmp(trim_line, name, name_len) == 0) { 222853f9fcb2SZhiPeng Lu if (sscanf(colon + 1, 222953f9fcb2SZhiPeng Lu "%lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld", 223053f9fcb2SZhiPeng Lu &rx_bytes, &rx_packets, &rx_errs, &rx_dropped, 223153f9fcb2SZhiPeng Lu &dummy, &dummy, &dummy, &dummy, 223253f9fcb2SZhiPeng Lu &tx_bytes, &tx_packets, &tx_errs, &tx_dropped, 223353f9fcb2SZhiPeng Lu &dummy, &dummy, &dummy, &dummy) != 16) { 223453f9fcb2SZhiPeng Lu continue; 223553f9fcb2SZhiPeng Lu } 223653f9fcb2SZhiPeng Lu stats->rx_bytes = rx_bytes; 223753f9fcb2SZhiPeng Lu stats->rx_packets = rx_packets; 223853f9fcb2SZhiPeng Lu stats->rx_errs = rx_errs; 223953f9fcb2SZhiPeng Lu stats->rx_dropped = rx_dropped; 224053f9fcb2SZhiPeng Lu stats->tx_bytes = tx_bytes; 224153f9fcb2SZhiPeng Lu stats->tx_packets = tx_packets; 224253f9fcb2SZhiPeng Lu stats->tx_errs = tx_errs; 224353f9fcb2SZhiPeng Lu stats->tx_dropped = tx_dropped; 224453f9fcb2SZhiPeng Lu fclose(fp); 224553f9fcb2SZhiPeng Lu g_free(line); 224653f9fcb2SZhiPeng Lu return 0; 224753f9fcb2SZhiPeng Lu } 224853f9fcb2SZhiPeng Lu } 224953f9fcb2SZhiPeng Lu fclose(fp); 225053f9fcb2SZhiPeng Lu g_free(line); 225153f9fcb2SZhiPeng Lu g_debug("/proc/net/dev: Interface '%s' not found", name); 225253f9fcb2SZhiPeng Lu return -1; 225353f9fcb2SZhiPeng Lu } 225453f9fcb2SZhiPeng Lu 22553424fc9fSMichal Privoznik /* 22563424fc9fSMichal Privoznik * Build information about guest interfaces 22573424fc9fSMichal Privoznik */ 22583424fc9fSMichal Privoznik GuestNetworkInterfaceList *qmp_guest_network_get_interfaces(Error **errp) 22593424fc9fSMichal Privoznik { 22603424fc9fSMichal Privoznik GuestNetworkInterfaceList *head = NULL, *cur_item = NULL; 22613424fc9fSMichal Privoznik struct ifaddrs *ifap, *ifa; 22623424fc9fSMichal Privoznik 22633424fc9fSMichal Privoznik if (getifaddrs(&ifap) < 0) { 2264878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, "getifaddrs failed"); 22653424fc9fSMichal Privoznik goto error; 22663424fc9fSMichal Privoznik } 22673424fc9fSMichal Privoznik 22683424fc9fSMichal Privoznik for (ifa = ifap; ifa; ifa = ifa->ifa_next) { 22693424fc9fSMichal Privoznik GuestNetworkInterfaceList *info; 22703424fc9fSMichal Privoznik GuestIpAddressList **address_list = NULL, *address_item = NULL; 227153f9fcb2SZhiPeng Lu GuestNetworkInterfaceStat *interface_stat = NULL; 22723424fc9fSMichal Privoznik char addr4[INET_ADDRSTRLEN]; 22733424fc9fSMichal Privoznik char addr6[INET6_ADDRSTRLEN]; 22743424fc9fSMichal Privoznik int sock; 22753424fc9fSMichal Privoznik struct ifreq ifr; 22763424fc9fSMichal Privoznik unsigned char *mac_addr; 22773424fc9fSMichal Privoznik void *p; 22783424fc9fSMichal Privoznik 22793424fc9fSMichal Privoznik g_debug("Processing %s interface", ifa->ifa_name); 22803424fc9fSMichal Privoznik 22813424fc9fSMichal Privoznik info = guest_find_interface(head, ifa->ifa_name); 22823424fc9fSMichal Privoznik 22833424fc9fSMichal Privoznik if (!info) { 22843424fc9fSMichal Privoznik info = g_malloc0(sizeof(*info)); 22853424fc9fSMichal Privoznik info->value = g_malloc0(sizeof(*info->value)); 22863424fc9fSMichal Privoznik info->value->name = g_strdup(ifa->ifa_name); 22873424fc9fSMichal Privoznik 22883424fc9fSMichal Privoznik if (!cur_item) { 22893424fc9fSMichal Privoznik head = cur_item = info; 22903424fc9fSMichal Privoznik } else { 22913424fc9fSMichal Privoznik cur_item->next = info; 22923424fc9fSMichal Privoznik cur_item = info; 22933424fc9fSMichal Privoznik } 22943424fc9fSMichal Privoznik } 22953424fc9fSMichal Privoznik 22963424fc9fSMichal Privoznik if (!info->value->has_hardware_address && 22973424fc9fSMichal Privoznik ifa->ifa_flags & SIOCGIFHWADDR) { 22983424fc9fSMichal Privoznik /* we haven't obtained HW address yet */ 22993424fc9fSMichal Privoznik sock = socket(PF_INET, SOCK_STREAM, 0); 23003424fc9fSMichal Privoznik if (sock == -1) { 2301878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, "failed to create socket"); 23023424fc9fSMichal Privoznik goto error; 23033424fc9fSMichal Privoznik } 23043424fc9fSMichal Privoznik 23053424fc9fSMichal Privoznik memset(&ifr, 0, sizeof(ifr)); 23061ab516edSJim Meyering pstrcpy(ifr.ifr_name, IF_NAMESIZE, info->value->name); 23073424fc9fSMichal Privoznik if (ioctl(sock, SIOCGIFHWADDR, &ifr) == -1) { 2308878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, 2309878a0ae0SLuiz Capitulino "failed to get MAC address of %s", 2310878a0ae0SLuiz Capitulino ifa->ifa_name); 231110a2158fSMarkus Armbruster close(sock); 23123424fc9fSMichal Privoznik goto error; 23133424fc9fSMichal Privoznik } 23143424fc9fSMichal Privoznik 231510a2158fSMarkus Armbruster close(sock); 23163424fc9fSMichal Privoznik mac_addr = (unsigned char *) &ifr.ifr_hwaddr.sa_data; 23173424fc9fSMichal Privoznik 2318e4ada482SStefan Weil info->value->hardware_address = 2319e4ada482SStefan Weil g_strdup_printf("%02x:%02x:%02x:%02x:%02x:%02x", 23203424fc9fSMichal Privoznik (int) mac_addr[0], (int) mac_addr[1], 23213424fc9fSMichal Privoznik (int) mac_addr[2], (int) mac_addr[3], 2322e4ada482SStefan Weil (int) mac_addr[4], (int) mac_addr[5]); 23233424fc9fSMichal Privoznik 23243424fc9fSMichal Privoznik info->value->has_hardware_address = true; 23253424fc9fSMichal Privoznik } 23263424fc9fSMichal Privoznik 23273424fc9fSMichal Privoznik if (ifa->ifa_addr && 23283424fc9fSMichal Privoznik ifa->ifa_addr->sa_family == AF_INET) { 23293424fc9fSMichal Privoznik /* interface with IPv4 address */ 23303424fc9fSMichal Privoznik p = &((struct sockaddr_in *)ifa->ifa_addr)->sin_addr; 23313424fc9fSMichal Privoznik if (!inet_ntop(AF_INET, p, addr4, sizeof(addr4))) { 2332878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, "inet_ntop failed"); 23333424fc9fSMichal Privoznik goto error; 23343424fc9fSMichal Privoznik } 23353424fc9fSMichal Privoznik 233610a2158fSMarkus Armbruster address_item = g_malloc0(sizeof(*address_item)); 233710a2158fSMarkus Armbruster address_item->value = g_malloc0(sizeof(*address_item->value)); 23383424fc9fSMichal Privoznik address_item->value->ip_address = g_strdup(addr4); 23393424fc9fSMichal Privoznik address_item->value->ip_address_type = GUEST_IP_ADDRESS_TYPE_IPV4; 23403424fc9fSMichal Privoznik 23413424fc9fSMichal Privoznik if (ifa->ifa_netmask) { 23423424fc9fSMichal Privoznik /* Count the number of set bits in netmask. 23433424fc9fSMichal Privoznik * This is safe as '1' and '0' cannot be shuffled in netmask. */ 23443424fc9fSMichal Privoznik p = &((struct sockaddr_in *)ifa->ifa_netmask)->sin_addr; 23453424fc9fSMichal Privoznik address_item->value->prefix = ctpop32(((uint32_t *) p)[0]); 23463424fc9fSMichal Privoznik } 23473424fc9fSMichal Privoznik } else if (ifa->ifa_addr && 23483424fc9fSMichal Privoznik ifa->ifa_addr->sa_family == AF_INET6) { 23493424fc9fSMichal Privoznik /* interface with IPv6 address */ 23503424fc9fSMichal Privoznik p = &((struct sockaddr_in6 *)ifa->ifa_addr)->sin6_addr; 23513424fc9fSMichal Privoznik if (!inet_ntop(AF_INET6, p, addr6, sizeof(addr6))) { 2352878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, "inet_ntop failed"); 23533424fc9fSMichal Privoznik goto error; 23543424fc9fSMichal Privoznik } 23553424fc9fSMichal Privoznik 235610a2158fSMarkus Armbruster address_item = g_malloc0(sizeof(*address_item)); 235710a2158fSMarkus Armbruster address_item->value = g_malloc0(sizeof(*address_item->value)); 23583424fc9fSMichal Privoznik address_item->value->ip_address = g_strdup(addr6); 23593424fc9fSMichal Privoznik address_item->value->ip_address_type = GUEST_IP_ADDRESS_TYPE_IPV6; 23603424fc9fSMichal Privoznik 23613424fc9fSMichal Privoznik if (ifa->ifa_netmask) { 23623424fc9fSMichal Privoznik /* Count the number of set bits in netmask. 23633424fc9fSMichal Privoznik * This is safe as '1' and '0' cannot be shuffled in netmask. */ 23643424fc9fSMichal Privoznik p = &((struct sockaddr_in6 *)ifa->ifa_netmask)->sin6_addr; 23653424fc9fSMichal Privoznik address_item->value->prefix = 23663424fc9fSMichal Privoznik ctpop32(((uint32_t *) p)[0]) + 23673424fc9fSMichal Privoznik ctpop32(((uint32_t *) p)[1]) + 23683424fc9fSMichal Privoznik ctpop32(((uint32_t *) p)[2]) + 23693424fc9fSMichal Privoznik ctpop32(((uint32_t *) p)[3]); 23703424fc9fSMichal Privoznik } 23713424fc9fSMichal Privoznik } 23723424fc9fSMichal Privoznik 23733424fc9fSMichal Privoznik if (!address_item) { 23743424fc9fSMichal Privoznik continue; 23753424fc9fSMichal Privoznik } 23763424fc9fSMichal Privoznik 23773424fc9fSMichal Privoznik address_list = &info->value->ip_addresses; 23783424fc9fSMichal Privoznik 23793424fc9fSMichal Privoznik while (*address_list && (*address_list)->next) { 23803424fc9fSMichal Privoznik address_list = &(*address_list)->next; 23813424fc9fSMichal Privoznik } 23823424fc9fSMichal Privoznik 23833424fc9fSMichal Privoznik if (!*address_list) { 23843424fc9fSMichal Privoznik *address_list = address_item; 23853424fc9fSMichal Privoznik } else { 23863424fc9fSMichal Privoznik (*address_list)->next = address_item; 23873424fc9fSMichal Privoznik } 23883424fc9fSMichal Privoznik 23893424fc9fSMichal Privoznik info->value->has_ip_addresses = true; 23903424fc9fSMichal Privoznik 239153f9fcb2SZhiPeng Lu if (!info->value->has_statistics) { 239253f9fcb2SZhiPeng Lu interface_stat = g_malloc0(sizeof(*interface_stat)); 239353f9fcb2SZhiPeng Lu if (guest_get_network_stats(info->value->name, 239453f9fcb2SZhiPeng Lu interface_stat) == -1) { 239553f9fcb2SZhiPeng Lu info->value->has_statistics = false; 239653f9fcb2SZhiPeng Lu g_free(interface_stat); 239753f9fcb2SZhiPeng Lu } else { 239853f9fcb2SZhiPeng Lu info->value->statistics = interface_stat; 239953f9fcb2SZhiPeng Lu info->value->has_statistics = true; 240053f9fcb2SZhiPeng Lu } 240153f9fcb2SZhiPeng Lu } 24023424fc9fSMichal Privoznik } 24033424fc9fSMichal Privoznik 24043424fc9fSMichal Privoznik freeifaddrs(ifap); 24053424fc9fSMichal Privoznik return head; 24063424fc9fSMichal Privoznik 24073424fc9fSMichal Privoznik error: 24083424fc9fSMichal Privoznik freeifaddrs(ifap); 24093424fc9fSMichal Privoznik qapi_free_GuestNetworkInterfaceList(head); 24103424fc9fSMichal Privoznik return NULL; 24113424fc9fSMichal Privoznik } 24123424fc9fSMichal Privoznik 241377dbc81bSMarkus Armbruster #define SYSCONF_EXACT(name, errp) sysconf_exact((name), #name, (errp)) 2414d2baff62SLaszlo Ersek 241577dbc81bSMarkus Armbruster static long sysconf_exact(int name, const char *name_str, Error **errp) 2416d2baff62SLaszlo Ersek { 2417d2baff62SLaszlo Ersek long ret; 2418d2baff62SLaszlo Ersek 2419d2baff62SLaszlo Ersek errno = 0; 2420d2baff62SLaszlo Ersek ret = sysconf(name); 2421d2baff62SLaszlo Ersek if (ret == -1) { 2422d2baff62SLaszlo Ersek if (errno == 0) { 242377dbc81bSMarkus Armbruster error_setg(errp, "sysconf(%s): value indefinite", name_str); 2424d2baff62SLaszlo Ersek } else { 242577dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "sysconf(%s)", name_str); 2426d2baff62SLaszlo Ersek } 2427d2baff62SLaszlo Ersek } 2428d2baff62SLaszlo Ersek return ret; 2429d2baff62SLaszlo Ersek } 2430d2baff62SLaszlo Ersek 2431d2baff62SLaszlo Ersek /* Transfer online/offline status between @vcpu and the guest system. 2432d2baff62SLaszlo Ersek * 2433d2baff62SLaszlo Ersek * On input either @errp or *@errp must be NULL. 2434d2baff62SLaszlo Ersek * 2435d2baff62SLaszlo Ersek * In system-to-@vcpu direction, the following @vcpu fields are accessed: 2436d2baff62SLaszlo Ersek * - R: vcpu->logical_id 2437d2baff62SLaszlo Ersek * - W: vcpu->online 2438d2baff62SLaszlo Ersek * - W: vcpu->can_offline 2439d2baff62SLaszlo Ersek * 2440d2baff62SLaszlo Ersek * In @vcpu-to-system direction, the following @vcpu fields are accessed: 2441d2baff62SLaszlo Ersek * - R: vcpu->logical_id 2442d2baff62SLaszlo Ersek * - R: vcpu->online 2443d2baff62SLaszlo Ersek * 2444d2baff62SLaszlo Ersek * Written members remain unmodified on error. 2445d2baff62SLaszlo Ersek */ 2446d2baff62SLaszlo Ersek static void transfer_vcpu(GuestLogicalProcessor *vcpu, bool sys2vcpu, 2447b4bf912aSIgor Mammedov char *dirpath, Error **errp) 2448d2baff62SLaszlo Ersek { 2449b4bf912aSIgor Mammedov int fd; 2450b4bf912aSIgor Mammedov int res; 2451d2baff62SLaszlo Ersek int dirfd; 2452b4bf912aSIgor Mammedov static const char fn[] = "online"; 2453d2baff62SLaszlo Ersek 2454d2baff62SLaszlo Ersek dirfd = open(dirpath, O_RDONLY | O_DIRECTORY); 2455d2baff62SLaszlo Ersek if (dirfd == -1) { 2456d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "open(\"%s\")", dirpath); 2457b4bf912aSIgor Mammedov return; 2458b4bf912aSIgor Mammedov } 2459d2baff62SLaszlo Ersek 2460d2baff62SLaszlo Ersek fd = openat(dirfd, fn, sys2vcpu ? O_RDONLY : O_RDWR); 2461d2baff62SLaszlo Ersek if (fd == -1) { 2462d2baff62SLaszlo Ersek if (errno != ENOENT) { 2463d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "open(\"%s/%s\")", dirpath, fn); 2464d2baff62SLaszlo Ersek } else if (sys2vcpu) { 2465d2baff62SLaszlo Ersek vcpu->online = true; 2466d2baff62SLaszlo Ersek vcpu->can_offline = false; 2467d2baff62SLaszlo Ersek } else if (!vcpu->online) { 2468d2baff62SLaszlo Ersek error_setg(errp, "logical processor #%" PRId64 " can't be " 2469d2baff62SLaszlo Ersek "offlined", vcpu->logical_id); 2470d2baff62SLaszlo Ersek } /* otherwise pretend successful re-onlining */ 2471d2baff62SLaszlo Ersek } else { 2472d2baff62SLaszlo Ersek unsigned char status; 2473d2baff62SLaszlo Ersek 2474d2baff62SLaszlo Ersek res = pread(fd, &status, 1, 0); 2475d2baff62SLaszlo Ersek if (res == -1) { 2476d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "pread(\"%s/%s\")", dirpath, fn); 2477d2baff62SLaszlo Ersek } else if (res == 0) { 2478d2baff62SLaszlo Ersek error_setg(errp, "pread(\"%s/%s\"): unexpected EOF", dirpath, 2479d2baff62SLaszlo Ersek fn); 2480d2baff62SLaszlo Ersek } else if (sys2vcpu) { 2481d2baff62SLaszlo Ersek vcpu->online = (status != '0'); 2482d2baff62SLaszlo Ersek vcpu->can_offline = true; 2483d2baff62SLaszlo Ersek } else if (vcpu->online != (status != '0')) { 2484d2baff62SLaszlo Ersek status = '0' + vcpu->online; 2485d2baff62SLaszlo Ersek if (pwrite(fd, &status, 1, 0) == -1) { 2486d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "pwrite(\"%s/%s\")", dirpath, 2487d2baff62SLaszlo Ersek fn); 2488d2baff62SLaszlo Ersek } 2489d2baff62SLaszlo Ersek } /* otherwise pretend successful re-(on|off)-lining */ 2490d2baff62SLaszlo Ersek 2491d2baff62SLaszlo Ersek res = close(fd); 2492d2baff62SLaszlo Ersek g_assert(res == 0); 2493d2baff62SLaszlo Ersek } 2494d2baff62SLaszlo Ersek 2495d2baff62SLaszlo Ersek res = close(dirfd); 2496d2baff62SLaszlo Ersek g_assert(res == 0); 2497d2baff62SLaszlo Ersek } 2498d2baff62SLaszlo Ersek 2499d2baff62SLaszlo Ersek GuestLogicalProcessorList *qmp_guest_get_vcpus(Error **errp) 2500d2baff62SLaszlo Ersek { 2501d2baff62SLaszlo Ersek int64_t current; 2502d2baff62SLaszlo Ersek GuestLogicalProcessorList *head, **link; 2503d2baff62SLaszlo Ersek long sc_max; 2504d2baff62SLaszlo Ersek Error *local_err = NULL; 2505d2baff62SLaszlo Ersek 2506d2baff62SLaszlo Ersek current = 0; 2507d2baff62SLaszlo Ersek head = NULL; 2508d2baff62SLaszlo Ersek link = &head; 2509d2baff62SLaszlo Ersek sc_max = SYSCONF_EXACT(_SC_NPROCESSORS_CONF, &local_err); 2510d2baff62SLaszlo Ersek 2511d2baff62SLaszlo Ersek while (local_err == NULL && current < sc_max) { 2512d2baff62SLaszlo Ersek GuestLogicalProcessor *vcpu; 2513d2baff62SLaszlo Ersek GuestLogicalProcessorList *entry; 2514b4bf912aSIgor Mammedov int64_t id = current++; 2515b4bf912aSIgor Mammedov char *path = g_strdup_printf("/sys/devices/system/cpu/cpu%" PRId64 "/", 2516b4bf912aSIgor Mammedov id); 2517d2baff62SLaszlo Ersek 2518b4bf912aSIgor Mammedov if (g_file_test(path, G_FILE_TEST_EXISTS)) { 2519d2baff62SLaszlo Ersek vcpu = g_malloc0(sizeof *vcpu); 2520b4bf912aSIgor Mammedov vcpu->logical_id = id; 2521d2baff62SLaszlo Ersek vcpu->has_can_offline = true; /* lolspeak ftw */ 2522b4bf912aSIgor Mammedov transfer_vcpu(vcpu, true, path, &local_err); 2523d2baff62SLaszlo Ersek entry = g_malloc0(sizeof *entry); 2524d2baff62SLaszlo Ersek entry->value = vcpu; 2525d2baff62SLaszlo Ersek *link = entry; 2526d2baff62SLaszlo Ersek link = &entry->next; 2527d2baff62SLaszlo Ersek } 2528b4bf912aSIgor Mammedov g_free(path); 2529b4bf912aSIgor Mammedov } 2530d2baff62SLaszlo Ersek 2531d2baff62SLaszlo Ersek if (local_err == NULL) { 2532d2baff62SLaszlo Ersek /* there's no guest with zero VCPUs */ 2533d2baff62SLaszlo Ersek g_assert(head != NULL); 2534d2baff62SLaszlo Ersek return head; 2535d2baff62SLaszlo Ersek } 2536d2baff62SLaszlo Ersek 2537d2baff62SLaszlo Ersek qapi_free_GuestLogicalProcessorList(head); 2538d2baff62SLaszlo Ersek error_propagate(errp, local_err); 2539d2baff62SLaszlo Ersek return NULL; 2540d2baff62SLaszlo Ersek } 2541d2baff62SLaszlo Ersek 2542cbb65fc2SLaszlo Ersek int64_t qmp_guest_set_vcpus(GuestLogicalProcessorList *vcpus, Error **errp) 2543cbb65fc2SLaszlo Ersek { 2544cbb65fc2SLaszlo Ersek int64_t processed; 2545cbb65fc2SLaszlo Ersek Error *local_err = NULL; 2546cbb65fc2SLaszlo Ersek 2547cbb65fc2SLaszlo Ersek processed = 0; 2548cbb65fc2SLaszlo Ersek while (vcpus != NULL) { 2549b4bf912aSIgor Mammedov char *path = g_strdup_printf("/sys/devices/system/cpu/cpu%" PRId64 "/", 2550b4bf912aSIgor Mammedov vcpus->value->logical_id); 2551b4bf912aSIgor Mammedov 2552b4bf912aSIgor Mammedov transfer_vcpu(vcpus->value, false, path, &local_err); 2553b4bf912aSIgor Mammedov g_free(path); 2554cbb65fc2SLaszlo Ersek if (local_err != NULL) { 2555cbb65fc2SLaszlo Ersek break; 2556cbb65fc2SLaszlo Ersek } 2557cbb65fc2SLaszlo Ersek ++processed; 2558cbb65fc2SLaszlo Ersek vcpus = vcpus->next; 2559cbb65fc2SLaszlo Ersek } 2560cbb65fc2SLaszlo Ersek 2561cbb65fc2SLaszlo Ersek if (local_err != NULL) { 2562cbb65fc2SLaszlo Ersek if (processed == 0) { 2563cbb65fc2SLaszlo Ersek error_propagate(errp, local_err); 2564cbb65fc2SLaszlo Ersek } else { 2565cbb65fc2SLaszlo Ersek error_free(local_err); 2566cbb65fc2SLaszlo Ersek } 2567cbb65fc2SLaszlo Ersek } 2568cbb65fc2SLaszlo Ersek 2569cbb65fc2SLaszlo Ersek return processed; 2570cbb65fc2SLaszlo Ersek } 2571cbb65fc2SLaszlo Ersek 2572215a2771SDaniel P. Berrange void qmp_guest_set_user_password(const char *username, 2573215a2771SDaniel P. Berrange const char *password, 2574215a2771SDaniel P. Berrange bool crypted, 2575215a2771SDaniel P. Berrange Error **errp) 2576215a2771SDaniel P. Berrange { 2577215a2771SDaniel P. Berrange Error *local_err = NULL; 2578215a2771SDaniel P. Berrange char *passwd_path = NULL; 2579215a2771SDaniel P. Berrange pid_t pid; 2580215a2771SDaniel P. Berrange int status; 2581215a2771SDaniel P. Berrange int datafd[2] = { -1, -1 }; 2582215a2771SDaniel P. Berrange char *rawpasswddata = NULL; 2583215a2771SDaniel P. Berrange size_t rawpasswdlen; 2584215a2771SDaniel P. Berrange char *chpasswddata = NULL; 2585215a2771SDaniel P. Berrange size_t chpasswdlen; 2586215a2771SDaniel P. Berrange 2587920639caSDaniel P. Berrange rawpasswddata = (char *)qbase64_decode(password, -1, &rawpasswdlen, errp); 2588920639caSDaniel P. Berrange if (!rawpasswddata) { 2589920639caSDaniel P. Berrange return; 2590920639caSDaniel P. Berrange } 2591215a2771SDaniel P. Berrange rawpasswddata = g_renew(char, rawpasswddata, rawpasswdlen + 1); 2592215a2771SDaniel P. Berrange rawpasswddata[rawpasswdlen] = '\0'; 2593215a2771SDaniel P. Berrange 2594215a2771SDaniel P. Berrange if (strchr(rawpasswddata, '\n')) { 2595215a2771SDaniel P. Berrange error_setg(errp, "forbidden characters in raw password"); 2596215a2771SDaniel P. Berrange goto out; 2597215a2771SDaniel P. Berrange } 2598215a2771SDaniel P. Berrange 2599215a2771SDaniel P. Berrange if (strchr(username, '\n') || 2600215a2771SDaniel P. Berrange strchr(username, ':')) { 2601215a2771SDaniel P. Berrange error_setg(errp, "forbidden characters in username"); 2602215a2771SDaniel P. Berrange goto out; 2603215a2771SDaniel P. Berrange } 2604215a2771SDaniel P. Berrange 2605215a2771SDaniel P. Berrange chpasswddata = g_strdup_printf("%s:%s\n", username, rawpasswddata); 2606215a2771SDaniel P. Berrange chpasswdlen = strlen(chpasswddata); 2607215a2771SDaniel P. Berrange 2608215a2771SDaniel P. Berrange passwd_path = g_find_program_in_path("chpasswd"); 2609215a2771SDaniel P. Berrange 2610215a2771SDaniel P. Berrange if (!passwd_path) { 2611215a2771SDaniel P. Berrange error_setg(errp, "cannot find 'passwd' program in PATH"); 2612215a2771SDaniel P. Berrange goto out; 2613215a2771SDaniel P. Berrange } 2614215a2771SDaniel P. Berrange 2615215a2771SDaniel P. Berrange if (pipe(datafd) < 0) { 2616215a2771SDaniel P. Berrange error_setg(errp, "cannot create pipe FDs"); 2617215a2771SDaniel P. Berrange goto out; 2618215a2771SDaniel P. Berrange } 2619215a2771SDaniel P. Berrange 2620215a2771SDaniel P. Berrange pid = fork(); 2621215a2771SDaniel P. Berrange if (pid == 0) { 2622215a2771SDaniel P. Berrange close(datafd[1]); 2623215a2771SDaniel P. Berrange /* child */ 2624215a2771SDaniel P. Berrange setsid(); 2625215a2771SDaniel P. Berrange dup2(datafd[0], 0); 2626215a2771SDaniel P. Berrange reopen_fd_to_null(1); 2627215a2771SDaniel P. Berrange reopen_fd_to_null(2); 2628215a2771SDaniel P. Berrange 2629215a2771SDaniel P. Berrange if (crypted) { 2630215a2771SDaniel P. Berrange execle(passwd_path, "chpasswd", "-e", NULL, environ); 2631215a2771SDaniel P. Berrange } else { 2632215a2771SDaniel P. Berrange execle(passwd_path, "chpasswd", NULL, environ); 2633215a2771SDaniel P. Berrange } 2634215a2771SDaniel P. Berrange _exit(EXIT_FAILURE); 2635215a2771SDaniel P. Berrange } else if (pid < 0) { 2636215a2771SDaniel P. Berrange error_setg_errno(errp, errno, "failed to create child process"); 2637215a2771SDaniel P. Berrange goto out; 2638215a2771SDaniel P. Berrange } 2639215a2771SDaniel P. Berrange close(datafd[0]); 2640215a2771SDaniel P. Berrange datafd[0] = -1; 2641215a2771SDaniel P. Berrange 2642215a2771SDaniel P. Berrange if (qemu_write_full(datafd[1], chpasswddata, chpasswdlen) != chpasswdlen) { 2643215a2771SDaniel P. Berrange error_setg_errno(errp, errno, "cannot write new account password"); 2644215a2771SDaniel P. Berrange goto out; 2645215a2771SDaniel P. Berrange } 2646215a2771SDaniel P. Berrange close(datafd[1]); 2647215a2771SDaniel P. Berrange datafd[1] = -1; 2648215a2771SDaniel P. Berrange 2649215a2771SDaniel P. Berrange ga_wait_child(pid, &status, &local_err); 2650215a2771SDaniel P. Berrange if (local_err) { 2651215a2771SDaniel P. Berrange error_propagate(errp, local_err); 2652215a2771SDaniel P. Berrange goto out; 2653215a2771SDaniel P. Berrange } 2654215a2771SDaniel P. Berrange 2655215a2771SDaniel P. Berrange if (!WIFEXITED(status)) { 2656215a2771SDaniel P. Berrange error_setg(errp, "child process has terminated abnormally"); 2657215a2771SDaniel P. Berrange goto out; 2658215a2771SDaniel P. Berrange } 2659215a2771SDaniel P. Berrange 2660215a2771SDaniel P. Berrange if (WEXITSTATUS(status)) { 2661215a2771SDaniel P. Berrange error_setg(errp, "child process has failed to set user password"); 2662215a2771SDaniel P. Berrange goto out; 2663215a2771SDaniel P. Berrange } 2664215a2771SDaniel P. Berrange 2665215a2771SDaniel P. Berrange out: 2666215a2771SDaniel P. Berrange g_free(chpasswddata); 2667215a2771SDaniel P. Berrange g_free(rawpasswddata); 2668215a2771SDaniel P. Berrange g_free(passwd_path); 2669215a2771SDaniel P. Berrange if (datafd[0] != -1) { 2670215a2771SDaniel P. Berrange close(datafd[0]); 2671215a2771SDaniel P. Berrange } 2672215a2771SDaniel P. Berrange if (datafd[1] != -1) { 2673215a2771SDaniel P. Berrange close(datafd[1]); 2674215a2771SDaniel P. Berrange } 2675215a2771SDaniel P. Berrange } 2676215a2771SDaniel P. Berrange 2677bd240fcaSzhanghailiang static void ga_read_sysfs_file(int dirfd, const char *pathname, char *buf, 2678bd240fcaSzhanghailiang int size, Error **errp) 2679bd240fcaSzhanghailiang { 2680bd240fcaSzhanghailiang int fd; 2681bd240fcaSzhanghailiang int res; 2682bd240fcaSzhanghailiang 2683bd240fcaSzhanghailiang errno = 0; 2684bd240fcaSzhanghailiang fd = openat(dirfd, pathname, O_RDONLY); 2685bd240fcaSzhanghailiang if (fd == -1) { 2686bd240fcaSzhanghailiang error_setg_errno(errp, errno, "open sysfs file \"%s\"", pathname); 2687bd240fcaSzhanghailiang return; 2688bd240fcaSzhanghailiang } 2689bd240fcaSzhanghailiang 2690bd240fcaSzhanghailiang res = pread(fd, buf, size, 0); 2691bd240fcaSzhanghailiang if (res == -1) { 2692bd240fcaSzhanghailiang error_setg_errno(errp, errno, "pread sysfs file \"%s\"", pathname); 2693bd240fcaSzhanghailiang } else if (res == 0) { 2694bd240fcaSzhanghailiang error_setg(errp, "pread sysfs file \"%s\": unexpected EOF", pathname); 2695bd240fcaSzhanghailiang } 2696bd240fcaSzhanghailiang close(fd); 2697bd240fcaSzhanghailiang } 2698bd240fcaSzhanghailiang 2699bd240fcaSzhanghailiang static void ga_write_sysfs_file(int dirfd, const char *pathname, 2700bd240fcaSzhanghailiang const char *buf, int size, Error **errp) 2701bd240fcaSzhanghailiang { 2702bd240fcaSzhanghailiang int fd; 2703bd240fcaSzhanghailiang 2704bd240fcaSzhanghailiang errno = 0; 2705bd240fcaSzhanghailiang fd = openat(dirfd, pathname, O_WRONLY); 2706bd240fcaSzhanghailiang if (fd == -1) { 2707bd240fcaSzhanghailiang error_setg_errno(errp, errno, "open sysfs file \"%s\"", pathname); 2708bd240fcaSzhanghailiang return; 2709bd240fcaSzhanghailiang } 2710bd240fcaSzhanghailiang 2711bd240fcaSzhanghailiang if (pwrite(fd, buf, size, 0) == -1) { 2712bd240fcaSzhanghailiang error_setg_errno(errp, errno, "pwrite sysfs file \"%s\"", pathname); 2713bd240fcaSzhanghailiang } 2714bd240fcaSzhanghailiang 2715bd240fcaSzhanghailiang close(fd); 2716bd240fcaSzhanghailiang } 2717bd240fcaSzhanghailiang 2718bd240fcaSzhanghailiang /* Transfer online/offline status between @mem_blk and the guest system. 2719bd240fcaSzhanghailiang * 2720bd240fcaSzhanghailiang * On input either @errp or *@errp must be NULL. 2721bd240fcaSzhanghailiang * 2722bd240fcaSzhanghailiang * In system-to-@mem_blk direction, the following @mem_blk fields are accessed: 2723bd240fcaSzhanghailiang * - R: mem_blk->phys_index 2724bd240fcaSzhanghailiang * - W: mem_blk->online 2725bd240fcaSzhanghailiang * - W: mem_blk->can_offline 2726bd240fcaSzhanghailiang * 2727bd240fcaSzhanghailiang * In @mem_blk-to-system direction, the following @mem_blk fields are accessed: 2728bd240fcaSzhanghailiang * - R: mem_blk->phys_index 2729bd240fcaSzhanghailiang * - R: mem_blk->online 2730bd240fcaSzhanghailiang *- R: mem_blk->can_offline 2731bd240fcaSzhanghailiang * Written members remain unmodified on error. 2732bd240fcaSzhanghailiang */ 2733bd240fcaSzhanghailiang static void transfer_memory_block(GuestMemoryBlock *mem_blk, bool sys2memblk, 2734bd240fcaSzhanghailiang GuestMemoryBlockResponse *result, 2735bd240fcaSzhanghailiang Error **errp) 2736bd240fcaSzhanghailiang { 2737bd240fcaSzhanghailiang char *dirpath; 2738bd240fcaSzhanghailiang int dirfd; 2739bd240fcaSzhanghailiang char *status; 2740bd240fcaSzhanghailiang Error *local_err = NULL; 2741bd240fcaSzhanghailiang 2742bd240fcaSzhanghailiang if (!sys2memblk) { 2743bd240fcaSzhanghailiang DIR *dp; 2744bd240fcaSzhanghailiang 2745bd240fcaSzhanghailiang if (!result) { 2746bd240fcaSzhanghailiang error_setg(errp, "Internal error, 'result' should not be NULL"); 2747bd240fcaSzhanghailiang return; 2748bd240fcaSzhanghailiang } 2749bd240fcaSzhanghailiang errno = 0; 2750bd240fcaSzhanghailiang dp = opendir("/sys/devices/system/memory/"); 2751bd240fcaSzhanghailiang /* if there is no 'memory' directory in sysfs, 2752bd240fcaSzhanghailiang * we think this VM does not support online/offline memory block, 2753bd240fcaSzhanghailiang * any other solution? 2754bd240fcaSzhanghailiang */ 27559879f5acSPhilippe Mathieu-Daudé if (!dp) { 27569879f5acSPhilippe Mathieu-Daudé if (errno == ENOENT) { 2757bd240fcaSzhanghailiang result->response = 2758bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_NOT_SUPPORTED; 27599879f5acSPhilippe Mathieu-Daudé } 2760bd240fcaSzhanghailiang goto out1; 2761bd240fcaSzhanghailiang } 2762bd240fcaSzhanghailiang closedir(dp); 2763bd240fcaSzhanghailiang } 2764bd240fcaSzhanghailiang 2765bd240fcaSzhanghailiang dirpath = g_strdup_printf("/sys/devices/system/memory/memory%" PRId64 "/", 2766bd240fcaSzhanghailiang mem_blk->phys_index); 2767bd240fcaSzhanghailiang dirfd = open(dirpath, O_RDONLY | O_DIRECTORY); 2768bd240fcaSzhanghailiang if (dirfd == -1) { 2769bd240fcaSzhanghailiang if (sys2memblk) { 2770bd240fcaSzhanghailiang error_setg_errno(errp, errno, "open(\"%s\")", dirpath); 2771bd240fcaSzhanghailiang } else { 2772bd240fcaSzhanghailiang if (errno == ENOENT) { 2773bd240fcaSzhanghailiang result->response = GUEST_MEMORY_BLOCK_RESPONSE_TYPE_NOT_FOUND; 2774bd240fcaSzhanghailiang } else { 2775bd240fcaSzhanghailiang result->response = 2776bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_FAILED; 2777bd240fcaSzhanghailiang } 2778bd240fcaSzhanghailiang } 2779bd240fcaSzhanghailiang g_free(dirpath); 2780bd240fcaSzhanghailiang goto out1; 2781bd240fcaSzhanghailiang } 2782bd240fcaSzhanghailiang g_free(dirpath); 2783bd240fcaSzhanghailiang 2784bd240fcaSzhanghailiang status = g_malloc0(10); 2785bd240fcaSzhanghailiang ga_read_sysfs_file(dirfd, "state", status, 10, &local_err); 2786bd240fcaSzhanghailiang if (local_err) { 2787bd240fcaSzhanghailiang /* treat with sysfs file that not exist in old kernel */ 2788bd240fcaSzhanghailiang if (errno == ENOENT) { 2789bd240fcaSzhanghailiang error_free(local_err); 2790bd240fcaSzhanghailiang if (sys2memblk) { 2791bd240fcaSzhanghailiang mem_blk->online = true; 2792bd240fcaSzhanghailiang mem_blk->can_offline = false; 2793bd240fcaSzhanghailiang } else if (!mem_blk->online) { 2794bd240fcaSzhanghailiang result->response = 2795bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_NOT_SUPPORTED; 2796bd240fcaSzhanghailiang } 2797bd240fcaSzhanghailiang } else { 2798bd240fcaSzhanghailiang if (sys2memblk) { 2799bd240fcaSzhanghailiang error_propagate(errp, local_err); 2800bd240fcaSzhanghailiang } else { 2801b368123dSMarkus Armbruster error_free(local_err); 2802bd240fcaSzhanghailiang result->response = 2803bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_FAILED; 2804bd240fcaSzhanghailiang } 2805bd240fcaSzhanghailiang } 2806bd240fcaSzhanghailiang goto out2; 2807bd240fcaSzhanghailiang } 2808bd240fcaSzhanghailiang 2809bd240fcaSzhanghailiang if (sys2memblk) { 2810bd240fcaSzhanghailiang char removable = '0'; 2811bd240fcaSzhanghailiang 2812bd240fcaSzhanghailiang mem_blk->online = (strncmp(status, "online", 6) == 0); 2813bd240fcaSzhanghailiang 2814bd240fcaSzhanghailiang ga_read_sysfs_file(dirfd, "removable", &removable, 1, &local_err); 2815bd240fcaSzhanghailiang if (local_err) { 281667cc32ebSVeres Lajos /* if no 'removable' file, it doesn't support offline mem blk */ 2817bd240fcaSzhanghailiang if (errno == ENOENT) { 2818bd240fcaSzhanghailiang error_free(local_err); 2819bd240fcaSzhanghailiang mem_blk->can_offline = false; 2820bd240fcaSzhanghailiang } else { 2821bd240fcaSzhanghailiang error_propagate(errp, local_err); 2822bd240fcaSzhanghailiang } 2823bd240fcaSzhanghailiang } else { 2824bd240fcaSzhanghailiang mem_blk->can_offline = (removable != '0'); 2825bd240fcaSzhanghailiang } 2826bd240fcaSzhanghailiang } else { 2827bd240fcaSzhanghailiang if (mem_blk->online != (strncmp(status, "online", 6) == 0)) { 28287064024dSMarc-André Lureau const char *new_state = mem_blk->online ? "online" : "offline"; 2829bd240fcaSzhanghailiang 2830bd240fcaSzhanghailiang ga_write_sysfs_file(dirfd, "state", new_state, strlen(new_state), 2831bd240fcaSzhanghailiang &local_err); 2832bd240fcaSzhanghailiang if (local_err) { 2833bd240fcaSzhanghailiang error_free(local_err); 2834bd240fcaSzhanghailiang result->response = 2835bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_FAILED; 2836bd240fcaSzhanghailiang goto out2; 2837bd240fcaSzhanghailiang } 2838bd240fcaSzhanghailiang 2839bd240fcaSzhanghailiang result->response = GUEST_MEMORY_BLOCK_RESPONSE_TYPE_SUCCESS; 2840bd240fcaSzhanghailiang result->has_error_code = false; 2841bd240fcaSzhanghailiang } /* otherwise pretend successful re-(on|off)-lining */ 2842bd240fcaSzhanghailiang } 2843bd240fcaSzhanghailiang g_free(status); 2844bd240fcaSzhanghailiang close(dirfd); 2845bd240fcaSzhanghailiang return; 2846bd240fcaSzhanghailiang 2847bd240fcaSzhanghailiang out2: 2848bd240fcaSzhanghailiang g_free(status); 2849bd240fcaSzhanghailiang close(dirfd); 2850bd240fcaSzhanghailiang out1: 2851bd240fcaSzhanghailiang if (!sys2memblk) { 2852bd240fcaSzhanghailiang result->has_error_code = true; 2853bd240fcaSzhanghailiang result->error_code = errno; 2854bd240fcaSzhanghailiang } 2855bd240fcaSzhanghailiang } 2856bd240fcaSzhanghailiang 2857a065aaa9Szhanghailiang GuestMemoryBlockList *qmp_guest_get_memory_blocks(Error **errp) 2858a065aaa9Szhanghailiang { 2859bd240fcaSzhanghailiang GuestMemoryBlockList *head, **link; 2860bd240fcaSzhanghailiang Error *local_err = NULL; 2861bd240fcaSzhanghailiang struct dirent *de; 2862bd240fcaSzhanghailiang DIR *dp; 2863bd240fcaSzhanghailiang 2864bd240fcaSzhanghailiang head = NULL; 2865bd240fcaSzhanghailiang link = &head; 2866bd240fcaSzhanghailiang 2867bd240fcaSzhanghailiang dp = opendir("/sys/devices/system/memory/"); 2868bd240fcaSzhanghailiang if (!dp) { 2869f693fe6eSMichael Roth /* it's ok if this happens to be a system that doesn't expose 2870f693fe6eSMichael Roth * memory blocks via sysfs, but otherwise we should report 2871f693fe6eSMichael Roth * an error 2872f693fe6eSMichael Roth */ 2873f693fe6eSMichael Roth if (errno != ENOENT) { 2874bd240fcaSzhanghailiang error_setg_errno(errp, errno, "Can't open directory" 28759af9e0feSMarkus Armbruster "\"/sys/devices/system/memory/\""); 2876f693fe6eSMichael Roth } 2877bd240fcaSzhanghailiang return NULL; 2878bd240fcaSzhanghailiang } 2879bd240fcaSzhanghailiang 2880bd240fcaSzhanghailiang /* Note: the phys_index of memory block may be discontinuous, 2881bd240fcaSzhanghailiang * this is because a memblk is the unit of the Sparse Memory design, which 2882bd240fcaSzhanghailiang * allows discontinuous memory ranges (ex. NUMA), so here we should 2883bd240fcaSzhanghailiang * traverse the memory block directory. 2884bd240fcaSzhanghailiang */ 2885bd240fcaSzhanghailiang while ((de = readdir(dp)) != NULL) { 2886bd240fcaSzhanghailiang GuestMemoryBlock *mem_blk; 2887bd240fcaSzhanghailiang GuestMemoryBlockList *entry; 2888bd240fcaSzhanghailiang 2889bd240fcaSzhanghailiang if ((strncmp(de->d_name, "memory", 6) != 0) || 2890bd240fcaSzhanghailiang !(de->d_type & DT_DIR)) { 2891bd240fcaSzhanghailiang continue; 2892bd240fcaSzhanghailiang } 2893bd240fcaSzhanghailiang 2894bd240fcaSzhanghailiang mem_blk = g_malloc0(sizeof *mem_blk); 2895bd240fcaSzhanghailiang /* The d_name is "memoryXXX", phys_index is block id, same as XXX */ 2896bd240fcaSzhanghailiang mem_blk->phys_index = strtoul(&de->d_name[6], NULL, 10); 2897bd240fcaSzhanghailiang mem_blk->has_can_offline = true; /* lolspeak ftw */ 2898bd240fcaSzhanghailiang transfer_memory_block(mem_blk, true, NULL, &local_err); 28994155c998SMarkus Armbruster if (local_err) { 29004155c998SMarkus Armbruster break; 29014155c998SMarkus Armbruster } 2902bd240fcaSzhanghailiang 2903bd240fcaSzhanghailiang entry = g_malloc0(sizeof *entry); 2904bd240fcaSzhanghailiang entry->value = mem_blk; 2905bd240fcaSzhanghailiang 2906bd240fcaSzhanghailiang *link = entry; 2907bd240fcaSzhanghailiang link = &entry->next; 2908bd240fcaSzhanghailiang } 2909bd240fcaSzhanghailiang 2910bd240fcaSzhanghailiang closedir(dp); 2911bd240fcaSzhanghailiang if (local_err == NULL) { 2912bd240fcaSzhanghailiang /* there's no guest with zero memory blocks */ 2913bd240fcaSzhanghailiang if (head == NULL) { 2914bd240fcaSzhanghailiang error_setg(errp, "guest reported zero memory blocks!"); 2915bd240fcaSzhanghailiang } 2916bd240fcaSzhanghailiang return head; 2917bd240fcaSzhanghailiang } 2918bd240fcaSzhanghailiang 2919bd240fcaSzhanghailiang qapi_free_GuestMemoryBlockList(head); 2920bd240fcaSzhanghailiang error_propagate(errp, local_err); 2921a065aaa9Szhanghailiang return NULL; 2922a065aaa9Szhanghailiang } 2923a065aaa9Szhanghailiang 2924a065aaa9Szhanghailiang GuestMemoryBlockResponseList * 2925a065aaa9Szhanghailiang qmp_guest_set_memory_blocks(GuestMemoryBlockList *mem_blks, Error **errp) 2926a065aaa9Szhanghailiang { 292732ca7927Szhanghailiang GuestMemoryBlockResponseList *head, **link; 292832ca7927Szhanghailiang Error *local_err = NULL; 292932ca7927Szhanghailiang 293032ca7927Szhanghailiang head = NULL; 293132ca7927Szhanghailiang link = &head; 293232ca7927Szhanghailiang 293332ca7927Szhanghailiang while (mem_blks != NULL) { 293432ca7927Szhanghailiang GuestMemoryBlockResponse *result; 293532ca7927Szhanghailiang GuestMemoryBlockResponseList *entry; 293632ca7927Szhanghailiang GuestMemoryBlock *current_mem_blk = mem_blks->value; 293732ca7927Szhanghailiang 293832ca7927Szhanghailiang result = g_malloc0(sizeof(*result)); 293932ca7927Szhanghailiang result->phys_index = current_mem_blk->phys_index; 294032ca7927Szhanghailiang transfer_memory_block(current_mem_blk, false, result, &local_err); 294132ca7927Szhanghailiang if (local_err) { /* should never happen */ 294232ca7927Szhanghailiang goto err; 294332ca7927Szhanghailiang } 294432ca7927Szhanghailiang entry = g_malloc0(sizeof *entry); 294532ca7927Szhanghailiang entry->value = result; 294632ca7927Szhanghailiang 294732ca7927Szhanghailiang *link = entry; 294832ca7927Szhanghailiang link = &entry->next; 294932ca7927Szhanghailiang mem_blks = mem_blks->next; 295032ca7927Szhanghailiang } 295132ca7927Szhanghailiang 295232ca7927Szhanghailiang return head; 295332ca7927Szhanghailiang err: 295432ca7927Szhanghailiang qapi_free_GuestMemoryBlockResponseList(head); 295532ca7927Szhanghailiang error_propagate(errp, local_err); 2956a065aaa9Szhanghailiang return NULL; 2957a065aaa9Szhanghailiang } 2958a065aaa9Szhanghailiang 2959a065aaa9Szhanghailiang GuestMemoryBlockInfo *qmp_guest_get_memory_block_info(Error **errp) 2960a065aaa9Szhanghailiang { 2961ef82b60bSzhanghailiang Error *local_err = NULL; 2962ef82b60bSzhanghailiang char *dirpath; 2963ef82b60bSzhanghailiang int dirfd; 2964ef82b60bSzhanghailiang char *buf; 2965ef82b60bSzhanghailiang GuestMemoryBlockInfo *info; 2966ef82b60bSzhanghailiang 2967ef82b60bSzhanghailiang dirpath = g_strdup_printf("/sys/devices/system/memory/"); 2968ef82b60bSzhanghailiang dirfd = open(dirpath, O_RDONLY | O_DIRECTORY); 2969ef82b60bSzhanghailiang if (dirfd == -1) { 2970ef82b60bSzhanghailiang error_setg_errno(errp, errno, "open(\"%s\")", dirpath); 2971ef82b60bSzhanghailiang g_free(dirpath); 2972a065aaa9Szhanghailiang return NULL; 2973a065aaa9Szhanghailiang } 2974ef82b60bSzhanghailiang g_free(dirpath); 2975ef82b60bSzhanghailiang 2976ef82b60bSzhanghailiang buf = g_malloc0(20); 2977ef82b60bSzhanghailiang ga_read_sysfs_file(dirfd, "block_size_bytes", buf, 20, &local_err); 29788ce1ee46SShannon Zhao close(dirfd); 2979ef82b60bSzhanghailiang if (local_err) { 2980ef82b60bSzhanghailiang g_free(buf); 2981ef82b60bSzhanghailiang error_propagate(errp, local_err); 2982ef82b60bSzhanghailiang return NULL; 2983ef82b60bSzhanghailiang } 2984ef82b60bSzhanghailiang 2985ef82b60bSzhanghailiang info = g_new0(GuestMemoryBlockInfo, 1); 2986ef82b60bSzhanghailiang info->size = strtol(buf, NULL, 16); /* the unit is bytes */ 2987ef82b60bSzhanghailiang 2988ef82b60bSzhanghailiang g_free(buf); 2989ef82b60bSzhanghailiang 2990ef82b60bSzhanghailiang return info; 2991ef82b60bSzhanghailiang } 2992a065aaa9Szhanghailiang 2993e72c3f2eSMichael Roth #else /* defined(__linux__) */ 2994e72c3f2eSMichael Roth 299577dbc81bSMarkus Armbruster void qmp_guest_suspend_disk(Error **errp) 2996e72c3f2eSMichael Roth { 2997c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2998e72c3f2eSMichael Roth } 2999e72c3f2eSMichael Roth 300077dbc81bSMarkus Armbruster void qmp_guest_suspend_ram(Error **errp) 3001e72c3f2eSMichael Roth { 3002c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3003e72c3f2eSMichael Roth } 3004e72c3f2eSMichael Roth 300577dbc81bSMarkus Armbruster void qmp_guest_suspend_hybrid(Error **errp) 3006e72c3f2eSMichael Roth { 3007c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3008e72c3f2eSMichael Roth } 3009e72c3f2eSMichael Roth 3010e72c3f2eSMichael Roth GuestNetworkInterfaceList *qmp_guest_network_get_interfaces(Error **errp) 3011e72c3f2eSMichael Roth { 3012c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3013e72c3f2eSMichael Roth return NULL; 3014e72c3f2eSMichael Roth } 3015e72c3f2eSMichael Roth 3016d2baff62SLaszlo Ersek GuestLogicalProcessorList *qmp_guest_get_vcpus(Error **errp) 3017d2baff62SLaszlo Ersek { 3018c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3019d2baff62SLaszlo Ersek return NULL; 3020d2baff62SLaszlo Ersek } 3021d2baff62SLaszlo Ersek 3022cbb65fc2SLaszlo Ersek int64_t qmp_guest_set_vcpus(GuestLogicalProcessorList *vcpus, Error **errp) 3023cbb65fc2SLaszlo Ersek { 3024c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3025cbb65fc2SLaszlo Ersek return -1; 3026cbb65fc2SLaszlo Ersek } 3027cbb65fc2SLaszlo Ersek 3028215a2771SDaniel P. Berrange void qmp_guest_set_user_password(const char *username, 3029215a2771SDaniel P. Berrange const char *password, 3030215a2771SDaniel P. Berrange bool crypted, 3031215a2771SDaniel P. Berrange Error **errp) 3032215a2771SDaniel P. Berrange { 3033c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3034215a2771SDaniel P. Berrange } 3035215a2771SDaniel P. Berrange 3036a065aaa9Szhanghailiang GuestMemoryBlockList *qmp_guest_get_memory_blocks(Error **errp) 3037a065aaa9Szhanghailiang { 3038c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3039a065aaa9Szhanghailiang return NULL; 3040a065aaa9Szhanghailiang } 3041a065aaa9Szhanghailiang 3042a065aaa9Szhanghailiang GuestMemoryBlockResponseList * 3043a065aaa9Szhanghailiang qmp_guest_set_memory_blocks(GuestMemoryBlockList *mem_blks, Error **errp) 3044a065aaa9Szhanghailiang { 3045c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3046a065aaa9Szhanghailiang return NULL; 3047a065aaa9Szhanghailiang } 3048a065aaa9Szhanghailiang 3049a065aaa9Szhanghailiang GuestMemoryBlockInfo *qmp_guest_get_memory_block_info(Error **errp) 3050a065aaa9Szhanghailiang { 3051c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3052a065aaa9Szhanghailiang return NULL; 3053a065aaa9Szhanghailiang } 3054a065aaa9Szhanghailiang 3055e72c3f2eSMichael Roth #endif 3056e72c3f2eSMichael Roth 3057d35d4cb5SMichael Roth #if !defined(CONFIG_FSFREEZE) 3058d35d4cb5SMichael Roth 305946d4c572STomoki Sekiyama GuestFilesystemInfoList *qmp_guest_get_fsinfo(Error **errp) 306046d4c572STomoki Sekiyama { 3061c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 306246d4c572STomoki Sekiyama return NULL; 306346d4c572STomoki Sekiyama } 306446d4c572STomoki Sekiyama 306577dbc81bSMarkus Armbruster GuestFsfreezeStatus qmp_guest_fsfreeze_status(Error **errp) 3066d35d4cb5SMichael Roth { 3067c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3068d35d4cb5SMichael Roth 3069d35d4cb5SMichael Roth return 0; 3070d35d4cb5SMichael Roth } 3071d35d4cb5SMichael Roth 307277dbc81bSMarkus Armbruster int64_t qmp_guest_fsfreeze_freeze(Error **errp) 3073d35d4cb5SMichael Roth { 3074c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3075d35d4cb5SMichael Roth 3076d35d4cb5SMichael Roth return 0; 3077d35d4cb5SMichael Roth } 3078d35d4cb5SMichael Roth 3079e99bce20STomoki Sekiyama int64_t qmp_guest_fsfreeze_freeze_list(bool has_mountpoints, 3080e99bce20STomoki Sekiyama strList *mountpoints, 3081e99bce20STomoki Sekiyama Error **errp) 3082e99bce20STomoki Sekiyama { 3083c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3084e99bce20STomoki Sekiyama 3085e99bce20STomoki Sekiyama return 0; 3086e99bce20STomoki Sekiyama } 3087e99bce20STomoki Sekiyama 308877dbc81bSMarkus Armbruster int64_t qmp_guest_fsfreeze_thaw(Error **errp) 3089d35d4cb5SMichael Roth { 3090c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3091d35d4cb5SMichael Roth 3092d35d4cb5SMichael Roth return 0; 3093d35d4cb5SMichael Roth } 3094fed39564STomáš Golembiovský 3095fed39564STomáš Golembiovský GuestDiskInfoList *qmp_guest_get_disks(Error **errp) 3096fed39564STomáš Golembiovský { 3097fed39564STomáš Golembiovský error_setg(errp, QERR_UNSUPPORTED); 3098fed39564STomáš Golembiovský return NULL; 3099fed39564STomáš Golembiovský } 3100fed39564STomáš Golembiovský 3101eab5fd59SPaolo Bonzini #endif /* CONFIG_FSFREEZE */ 3102d35d4cb5SMichael Roth 3103eab5fd59SPaolo Bonzini #if !defined(CONFIG_FSTRIM) 3104e82855d9SJustin Ossevoort GuestFilesystemTrimResponse * 3105e82855d9SJustin Ossevoort qmp_guest_fstrim(bool has_minimum, int64_t minimum, Error **errp) 3106eab5fd59SPaolo Bonzini { 3107c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3108e82855d9SJustin Ossevoort return NULL; 3109eab5fd59SPaolo Bonzini } 3110d35d4cb5SMichael Roth #endif 3111d35d4cb5SMichael Roth 31121281c08aSTomoki Sekiyama /* add unsupported commands to the blacklist */ 31131281c08aSTomoki Sekiyama GList *ga_command_blacklist_init(GList *blacklist) 31141281c08aSTomoki Sekiyama { 31151281c08aSTomoki Sekiyama #if !defined(__linux__) 31161281c08aSTomoki Sekiyama { 31171281c08aSTomoki Sekiyama const char *list[] = { 31181281c08aSTomoki Sekiyama "guest-suspend-disk", "guest-suspend-ram", 31191281c08aSTomoki Sekiyama "guest-suspend-hybrid", "guest-network-get-interfaces", 31200dd38a03Szhanghailiang "guest-get-vcpus", "guest-set-vcpus", 31210dd38a03Szhanghailiang "guest-get-memory-blocks", "guest-set-memory-blocks", 312228d8dd35SBasil Salman "guest-get-memory-block-size", "guest-get-memory-block-info", 312328d8dd35SBasil Salman NULL}; 31241281c08aSTomoki Sekiyama char **p = (char **)list; 31251281c08aSTomoki Sekiyama 31261281c08aSTomoki Sekiyama while (*p) { 31274bca81ceSMarc-André Lureau blacklist = g_list_append(blacklist, g_strdup(*p++)); 31281281c08aSTomoki Sekiyama } 31291281c08aSTomoki Sekiyama } 31301281c08aSTomoki Sekiyama #endif 31311281c08aSTomoki Sekiyama 31321281c08aSTomoki Sekiyama #if !defined(CONFIG_FSFREEZE) 31331281c08aSTomoki Sekiyama { 31341281c08aSTomoki Sekiyama const char *list[] = { 31351281c08aSTomoki Sekiyama "guest-get-fsinfo", "guest-fsfreeze-status", 31361281c08aSTomoki Sekiyama "guest-fsfreeze-freeze", "guest-fsfreeze-freeze-list", 3137fed39564STomáš Golembiovský "guest-fsfreeze-thaw", "guest-get-fsinfo", 3138fed39564STomáš Golembiovský "guest-get-disks", NULL}; 31391281c08aSTomoki Sekiyama char **p = (char **)list; 31401281c08aSTomoki Sekiyama 31411281c08aSTomoki Sekiyama while (*p) { 31424bca81ceSMarc-André Lureau blacklist = g_list_append(blacklist, g_strdup(*p++)); 31431281c08aSTomoki Sekiyama } 31441281c08aSTomoki Sekiyama } 31451281c08aSTomoki Sekiyama #endif 31461281c08aSTomoki Sekiyama 31471281c08aSTomoki Sekiyama #if !defined(CONFIG_FSTRIM) 31484bca81ceSMarc-André Lureau blacklist = g_list_append(blacklist, g_strdup("guest-fstrim")); 31491281c08aSTomoki Sekiyama #endif 31501281c08aSTomoki Sekiyama 31512e4211ceSTomáš Golembiovský blacklist = g_list_append(blacklist, g_strdup("guest-get-devices")); 31522e4211ceSTomáš Golembiovský 31531281c08aSTomoki Sekiyama return blacklist; 31541281c08aSTomoki Sekiyama } 31551281c08aSTomoki Sekiyama 3156c216e5adSMichael Roth /* register init/cleanup routines for stateful command groups */ 3157c216e5adSMichael Roth void ga_command_state_init(GAState *s, GACommandState *cs) 3158c216e5adSMichael Roth { 3159c216e5adSMichael Roth #if defined(CONFIG_FSFREEZE) 3160f22d85e9SMichael Roth ga_command_state_add(cs, NULL, guest_fsfreeze_cleanup); 3161c216e5adSMichael Roth #endif 3162c216e5adSMichael Roth } 3163161a56a9SVinzenz Feenstra 3164e674605fSTomáš Golembiovský #ifdef HAVE_UTMPX 3165e674605fSTomáš Golembiovský 3166161a56a9SVinzenz Feenstra #define QGA_MICRO_SECOND_TO_SECOND 1000000 3167161a56a9SVinzenz Feenstra 3168161a56a9SVinzenz Feenstra static double ga_get_login_time(struct utmpx *user_info) 3169161a56a9SVinzenz Feenstra { 3170161a56a9SVinzenz Feenstra double seconds = (double)user_info->ut_tv.tv_sec; 3171161a56a9SVinzenz Feenstra double useconds = (double)user_info->ut_tv.tv_usec; 3172161a56a9SVinzenz Feenstra useconds /= QGA_MICRO_SECOND_TO_SECOND; 3173161a56a9SVinzenz Feenstra return seconds + useconds; 3174161a56a9SVinzenz Feenstra } 3175161a56a9SVinzenz Feenstra 3176b90abbacSVladimir Sementsov-Ogievskiy GuestUserList *qmp_guest_get_users(Error **errp) 3177161a56a9SVinzenz Feenstra { 3178161a56a9SVinzenz Feenstra GHashTable *cache = NULL; 3179161a56a9SVinzenz Feenstra GuestUserList *head = NULL, *cur_item = NULL; 3180161a56a9SVinzenz Feenstra struct utmpx *user_info = NULL; 3181161a56a9SVinzenz Feenstra gpointer value = NULL; 3182161a56a9SVinzenz Feenstra GuestUser *user = NULL; 3183161a56a9SVinzenz Feenstra GuestUserList *item = NULL; 3184161a56a9SVinzenz Feenstra double login_time = 0; 3185161a56a9SVinzenz Feenstra 3186161a56a9SVinzenz Feenstra cache = g_hash_table_new(g_str_hash, g_str_equal); 3187161a56a9SVinzenz Feenstra setutxent(); 3188161a56a9SVinzenz Feenstra 3189161a56a9SVinzenz Feenstra for (;;) { 3190161a56a9SVinzenz Feenstra user_info = getutxent(); 3191161a56a9SVinzenz Feenstra if (user_info == NULL) { 3192161a56a9SVinzenz Feenstra break; 3193161a56a9SVinzenz Feenstra } else if (user_info->ut_type != USER_PROCESS) { 3194161a56a9SVinzenz Feenstra continue; 3195161a56a9SVinzenz Feenstra } else if (g_hash_table_contains(cache, user_info->ut_user)) { 3196161a56a9SVinzenz Feenstra value = g_hash_table_lookup(cache, user_info->ut_user); 3197161a56a9SVinzenz Feenstra user = (GuestUser *)value; 3198161a56a9SVinzenz Feenstra login_time = ga_get_login_time(user_info); 3199161a56a9SVinzenz Feenstra /* We're ensuring the earliest login time to be sent */ 3200161a56a9SVinzenz Feenstra if (login_time < user->login_time) { 3201161a56a9SVinzenz Feenstra user->login_time = login_time; 3202161a56a9SVinzenz Feenstra } 3203161a56a9SVinzenz Feenstra continue; 3204161a56a9SVinzenz Feenstra } 3205161a56a9SVinzenz Feenstra 3206161a56a9SVinzenz Feenstra item = g_new0(GuestUserList, 1); 3207161a56a9SVinzenz Feenstra item->value = g_new0(GuestUser, 1); 3208161a56a9SVinzenz Feenstra item->value->user = g_strdup(user_info->ut_user); 3209161a56a9SVinzenz Feenstra item->value->login_time = ga_get_login_time(user_info); 3210161a56a9SVinzenz Feenstra 3211161a56a9SVinzenz Feenstra g_hash_table_insert(cache, item->value->user, item->value); 3212161a56a9SVinzenz Feenstra 3213161a56a9SVinzenz Feenstra if (!cur_item) { 3214161a56a9SVinzenz Feenstra head = cur_item = item; 3215161a56a9SVinzenz Feenstra } else { 3216161a56a9SVinzenz Feenstra cur_item->next = item; 3217161a56a9SVinzenz Feenstra cur_item = item; 3218161a56a9SVinzenz Feenstra } 3219161a56a9SVinzenz Feenstra } 3220161a56a9SVinzenz Feenstra endutxent(); 3221161a56a9SVinzenz Feenstra g_hash_table_destroy(cache); 3222161a56a9SVinzenz Feenstra return head; 3223161a56a9SVinzenz Feenstra } 3224e674605fSTomáš Golembiovský 3225e674605fSTomáš Golembiovský #else 3226e674605fSTomáš Golembiovský 3227e674605fSTomáš Golembiovský GuestUserList *qmp_guest_get_users(Error **errp) 3228e674605fSTomáš Golembiovský { 3229e674605fSTomáš Golembiovský error_setg(errp, QERR_UNSUPPORTED); 3230e674605fSTomáš Golembiovský return NULL; 3231e674605fSTomáš Golembiovský } 3232e674605fSTomáš Golembiovský 3233e674605fSTomáš Golembiovský #endif 32349848f797STomáš Golembiovský 32359848f797STomáš Golembiovský /* Replace escaped special characters with theire real values. The replacement 32369848f797STomáš Golembiovský * is done in place -- returned value is in the original string. 32379848f797STomáš Golembiovský */ 32389848f797STomáš Golembiovský static void ga_osrelease_replace_special(gchar *value) 32399848f797STomáš Golembiovský { 32409848f797STomáš Golembiovský gchar *p, *p2, quote; 32419848f797STomáš Golembiovský 32429848f797STomáš Golembiovský /* Trim the string at first space or semicolon if it is not enclosed in 32439848f797STomáš Golembiovský * single or double quotes. */ 32449848f797STomáš Golembiovský if ((value[0] != '"') || (value[0] == '\'')) { 32459848f797STomáš Golembiovský p = strchr(value, ' '); 32469848f797STomáš Golembiovský if (p != NULL) { 32479848f797STomáš Golembiovský *p = 0; 32489848f797STomáš Golembiovský } 32499848f797STomáš Golembiovský p = strchr(value, ';'); 32509848f797STomáš Golembiovský if (p != NULL) { 32519848f797STomáš Golembiovský *p = 0; 32529848f797STomáš Golembiovský } 32539848f797STomáš Golembiovský return; 32549848f797STomáš Golembiovský } 32559848f797STomáš Golembiovský 32569848f797STomáš Golembiovský quote = value[0]; 32579848f797STomáš Golembiovský p2 = value; 32589848f797STomáš Golembiovský p = value + 1; 32599848f797STomáš Golembiovský while (*p != 0) { 32609848f797STomáš Golembiovský if (*p == '\\') { 32619848f797STomáš Golembiovský p++; 32629848f797STomáš Golembiovský switch (*p) { 32639848f797STomáš Golembiovský case '$': 32649848f797STomáš Golembiovský case '\'': 32659848f797STomáš Golembiovský case '"': 32669848f797STomáš Golembiovský case '\\': 32679848f797STomáš Golembiovský case '`': 32689848f797STomáš Golembiovský break; 32699848f797STomáš Golembiovský default: 32709848f797STomáš Golembiovský /* Keep literal backslash followed by whatever is there */ 32719848f797STomáš Golembiovský p--; 32729848f797STomáš Golembiovský break; 32739848f797STomáš Golembiovský } 32749848f797STomáš Golembiovský } else if (*p == quote) { 32759848f797STomáš Golembiovský *p2 = 0; 32769848f797STomáš Golembiovský break; 32779848f797STomáš Golembiovský } 32789848f797STomáš Golembiovský *(p2++) = *(p++); 32799848f797STomáš Golembiovský } 32809848f797STomáš Golembiovský } 32819848f797STomáš Golembiovský 32829848f797STomáš Golembiovský static GKeyFile *ga_parse_osrelease(const char *fname) 32839848f797STomáš Golembiovský { 32849848f797STomáš Golembiovský gchar *content = NULL; 32859848f797STomáš Golembiovský gchar *content2 = NULL; 32869848f797STomáš Golembiovský GError *err = NULL; 32879848f797STomáš Golembiovský GKeyFile *keys = g_key_file_new(); 32889848f797STomáš Golembiovský const char *group = "[os-release]\n"; 32899848f797STomáš Golembiovský 32909848f797STomáš Golembiovský if (!g_file_get_contents(fname, &content, NULL, &err)) { 32919848f797STomáš Golembiovský slog("failed to read '%s', error: %s", fname, err->message); 32929848f797STomáš Golembiovský goto fail; 32939848f797STomáš Golembiovský } 32949848f797STomáš Golembiovský 32959848f797STomáš Golembiovský if (!g_utf8_validate(content, -1, NULL)) { 32969848f797STomáš Golembiovský slog("file is not utf-8 encoded: %s", fname); 32979848f797STomáš Golembiovský goto fail; 32989848f797STomáš Golembiovský } 32999848f797STomáš Golembiovský content2 = g_strdup_printf("%s%s", group, content); 33009848f797STomáš Golembiovský 33019848f797STomáš Golembiovský if (!g_key_file_load_from_data(keys, content2, -1, G_KEY_FILE_NONE, 33029848f797STomáš Golembiovský &err)) { 33039848f797STomáš Golembiovský slog("failed to parse file '%s', error: %s", fname, err->message); 33049848f797STomáš Golembiovský goto fail; 33059848f797STomáš Golembiovský } 33069848f797STomáš Golembiovský 33079848f797STomáš Golembiovský g_free(content); 33089848f797STomáš Golembiovský g_free(content2); 33099848f797STomáš Golembiovský return keys; 33109848f797STomáš Golembiovský 33119848f797STomáš Golembiovský fail: 33129848f797STomáš Golembiovský g_error_free(err); 33139848f797STomáš Golembiovský g_free(content); 33149848f797STomáš Golembiovský g_free(content2); 33159848f797STomáš Golembiovský g_key_file_free(keys); 33169848f797STomáš Golembiovský return NULL; 33179848f797STomáš Golembiovský } 33189848f797STomáš Golembiovský 33199848f797STomáš Golembiovský GuestOSInfo *qmp_guest_get_osinfo(Error **errp) 33209848f797STomáš Golembiovský { 33219848f797STomáš Golembiovský GuestOSInfo *info = NULL; 33229848f797STomáš Golembiovský struct utsname kinfo; 3323339ca68bSTomáš Golembiovský GKeyFile *osrelease = NULL; 3324339ca68bSTomáš Golembiovský const char *qga_os_release = g_getenv("QGA_OS_RELEASE"); 33259848f797STomáš Golembiovský 33269848f797STomáš Golembiovský info = g_new0(GuestOSInfo, 1); 33279848f797STomáš Golembiovský 33289848f797STomáš Golembiovský if (uname(&kinfo) != 0) { 33299848f797STomáš Golembiovský error_setg_errno(errp, errno, "uname failed"); 33309848f797STomáš Golembiovský } else { 33319848f797STomáš Golembiovský info->has_kernel_version = true; 33329848f797STomáš Golembiovský info->kernel_version = g_strdup(kinfo.version); 33339848f797STomáš Golembiovský info->has_kernel_release = true; 33349848f797STomáš Golembiovský info->kernel_release = g_strdup(kinfo.release); 33359848f797STomáš Golembiovský info->has_machine = true; 33369848f797STomáš Golembiovský info->machine = g_strdup(kinfo.machine); 33379848f797STomáš Golembiovský } 33389848f797STomáš Golembiovský 3339339ca68bSTomáš Golembiovský if (qga_os_release != NULL) { 3340339ca68bSTomáš Golembiovský osrelease = ga_parse_osrelease(qga_os_release); 3341339ca68bSTomáš Golembiovský } else { 33429848f797STomáš Golembiovský osrelease = ga_parse_osrelease("/etc/os-release"); 33439848f797STomáš Golembiovský if (osrelease == NULL) { 33449848f797STomáš Golembiovský osrelease = ga_parse_osrelease("/usr/lib/os-release"); 33459848f797STomáš Golembiovský } 3346339ca68bSTomáš Golembiovský } 33479848f797STomáš Golembiovský 33489848f797STomáš Golembiovský if (osrelease != NULL) { 33499848f797STomáš Golembiovský char *value; 33509848f797STomáš Golembiovský 33519848f797STomáš Golembiovský #define GET_FIELD(field, osfield) do { \ 33529848f797STomáš Golembiovský value = g_key_file_get_value(osrelease, "os-release", osfield, NULL); \ 33539848f797STomáš Golembiovský if (value != NULL) { \ 33549848f797STomáš Golembiovský ga_osrelease_replace_special(value); \ 33559848f797STomáš Golembiovský info->has_ ## field = true; \ 33569848f797STomáš Golembiovský info->field = value; \ 33579848f797STomáš Golembiovský } \ 33589848f797STomáš Golembiovský } while (0) 33599848f797STomáš Golembiovský GET_FIELD(id, "ID"); 33609848f797STomáš Golembiovský GET_FIELD(name, "NAME"); 33619848f797STomáš Golembiovský GET_FIELD(pretty_name, "PRETTY_NAME"); 33629848f797STomáš Golembiovský GET_FIELD(version, "VERSION"); 33639848f797STomáš Golembiovský GET_FIELD(version_id, "VERSION_ID"); 33649848f797STomáš Golembiovský GET_FIELD(variant, "VARIANT"); 33659848f797STomáš Golembiovský GET_FIELD(variant_id, "VARIANT_ID"); 33669848f797STomáš Golembiovský #undef GET_FIELD 33679848f797STomáš Golembiovský 33689848f797STomáš Golembiovský g_key_file_free(osrelease); 33699848f797STomáš Golembiovský } 33709848f797STomáš Golembiovský 33719848f797STomáš Golembiovský return info; 33729848f797STomáš Golembiovský } 33732e4211ceSTomáš Golembiovský 33742e4211ceSTomáš Golembiovský GuestDeviceInfoList *qmp_guest_get_devices(Error **errp) 33752e4211ceSTomáš Golembiovský { 33762e4211ceSTomáš Golembiovský error_setg(errp, QERR_UNSUPPORTED); 33772e4211ceSTomáš Golembiovský 33782e4211ceSTomáš Golembiovský return NULL; 33792e4211ceSTomáš Golembiovský } 3380