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" 29*5d3586b8SPhilippe 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 241*5d3586b8SPhilippe Mathieu-Daudé struct GuestFileHandle { 242c216e5adSMichael Roth uint64_t id; 243c216e5adSMichael Roth FILE *fh; 244895b00f6SMarc-André Lureau RwState state; 245c216e5adSMichael Roth QTAILQ_ENTRY(GuestFileHandle) next; 246*5d3586b8SPhilippe 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 272*5d3586b8SPhilippe 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 464c216e5adSMichael Roth struct GuestFileRead *qmp_guest_file_read(int64_t handle, bool has_count, 46577dbc81bSMarkus Armbruster int64_t count, Error **errp) 466c216e5adSMichael Roth { 46777dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 468c216e5adSMichael Roth GuestFileRead *read_data = NULL; 469c216e5adSMichael Roth guchar *buf; 470c216e5adSMichael Roth FILE *fh; 471c216e5adSMichael Roth size_t read_count; 472c216e5adSMichael Roth 473c216e5adSMichael Roth if (!gfh) { 474c216e5adSMichael Roth return NULL; 475c216e5adSMichael Roth } 476c216e5adSMichael Roth 477c216e5adSMichael Roth if (!has_count) { 478c216e5adSMichael Roth count = QGA_READ_COUNT_DEFAULT; 479141b1974SPrasad J Pandit } else if (count < 0 || count >= UINT32_MAX) { 48077dbc81bSMarkus Armbruster error_setg(errp, "value '%" PRId64 "' is invalid for argument count", 481db3edb66SLuiz Capitulino count); 482c216e5adSMichael Roth return NULL; 483c216e5adSMichael Roth } 484c216e5adSMichael Roth 485c216e5adSMichael Roth fh = gfh->fh; 486895b00f6SMarc-André Lureau 487895b00f6SMarc-André Lureau /* explicitly flush when switching from writing to reading */ 488895b00f6SMarc-André Lureau if (gfh->state == RW_STATE_WRITING) { 489895b00f6SMarc-André Lureau int ret = fflush(fh); 490895b00f6SMarc-André Lureau if (ret == EOF) { 491895b00f6SMarc-André Lureau error_setg_errno(errp, errno, "failed to flush file"); 492895b00f6SMarc-André Lureau return NULL; 493895b00f6SMarc-André Lureau } 494895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 495895b00f6SMarc-André Lureau } 496895b00f6SMarc-André Lureau 497c216e5adSMichael Roth buf = g_malloc0(count+1); 498c216e5adSMichael Roth read_count = fread(buf, 1, count, fh); 499c216e5adSMichael Roth if (ferror(fh)) { 50077dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to read file"); 501d607a523SStefan Weil slog("guest-file-read failed, handle: %" PRId64, handle); 502c216e5adSMichael Roth } else { 503c216e5adSMichael Roth buf[read_count] = 0; 504f3a06403SMarkus Armbruster read_data = g_new0(GuestFileRead, 1); 505c216e5adSMichael Roth read_data->count = read_count; 506c216e5adSMichael Roth read_data->eof = feof(fh); 507c216e5adSMichael Roth if (read_count) { 508c216e5adSMichael Roth read_data->buf_b64 = g_base64_encode(buf, read_count); 509c216e5adSMichael Roth } 510895b00f6SMarc-André Lureau gfh->state = RW_STATE_READING; 511c216e5adSMichael Roth } 512c216e5adSMichael Roth g_free(buf); 513c216e5adSMichael Roth clearerr(fh); 514c216e5adSMichael Roth 515c216e5adSMichael Roth return read_data; 516c216e5adSMichael Roth } 517c216e5adSMichael Roth 518c216e5adSMichael Roth GuestFileWrite *qmp_guest_file_write(int64_t handle, const char *buf_b64, 51977dbc81bSMarkus Armbruster bool has_count, int64_t count, 52077dbc81bSMarkus Armbruster Error **errp) 521c216e5adSMichael Roth { 522c216e5adSMichael Roth GuestFileWrite *write_data = NULL; 523c216e5adSMichael Roth guchar *buf; 524c216e5adSMichael Roth gsize buf_len; 525c216e5adSMichael Roth int write_count; 52677dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 527c216e5adSMichael Roth FILE *fh; 528c216e5adSMichael Roth 529c216e5adSMichael Roth if (!gfh) { 530c216e5adSMichael Roth return NULL; 531c216e5adSMichael Roth } 532c216e5adSMichael Roth 533c216e5adSMichael Roth fh = gfh->fh; 534895b00f6SMarc-André Lureau 535895b00f6SMarc-André Lureau if (gfh->state == RW_STATE_READING) { 536895b00f6SMarc-André Lureau int ret = fseek(fh, 0, SEEK_CUR); 537895b00f6SMarc-André Lureau if (ret == -1) { 538895b00f6SMarc-André Lureau error_setg_errno(errp, errno, "failed to seek file"); 539895b00f6SMarc-André Lureau return NULL; 540895b00f6SMarc-André Lureau } 541895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 542895b00f6SMarc-André Lureau } 543895b00f6SMarc-André Lureau 544920639caSDaniel P. Berrange buf = qbase64_decode(buf_b64, -1, &buf_len, errp); 545920639caSDaniel P. Berrange if (!buf) { 546920639caSDaniel P. Berrange return NULL; 547920639caSDaniel P. Berrange } 548c216e5adSMichael Roth 549c216e5adSMichael Roth if (!has_count) { 550c216e5adSMichael Roth count = buf_len; 551c216e5adSMichael Roth } else if (count < 0 || count > buf_len) { 55277dbc81bSMarkus Armbruster error_setg(errp, "value '%" PRId64 "' is invalid for argument count", 553db3edb66SLuiz Capitulino count); 554c216e5adSMichael Roth g_free(buf); 555c216e5adSMichael Roth return NULL; 556c216e5adSMichael Roth } 557c216e5adSMichael Roth 558c216e5adSMichael Roth write_count = fwrite(buf, 1, count, fh); 559c216e5adSMichael Roth if (ferror(fh)) { 56077dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to write to file"); 561d607a523SStefan Weil slog("guest-file-write failed, handle: %" PRId64, handle); 562c216e5adSMichael Roth } else { 563f3a06403SMarkus Armbruster write_data = g_new0(GuestFileWrite, 1); 564c216e5adSMichael Roth write_data->count = write_count; 565c216e5adSMichael Roth write_data->eof = feof(fh); 566895b00f6SMarc-André Lureau gfh->state = RW_STATE_WRITING; 567c216e5adSMichael Roth } 568c216e5adSMichael Roth g_free(buf); 569c216e5adSMichael Roth clearerr(fh); 570c216e5adSMichael Roth 571c216e5adSMichael Roth return write_data; 572c216e5adSMichael Roth } 573c216e5adSMichael Roth 574c216e5adSMichael Roth struct GuestFileSeek *qmp_guest_file_seek(int64_t handle, int64_t offset, 5750b4b4938SEric Blake GuestFileWhence *whence_code, 5760b4b4938SEric Blake Error **errp) 577c216e5adSMichael Roth { 57877dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 579c216e5adSMichael Roth GuestFileSeek *seek_data = NULL; 580c216e5adSMichael Roth FILE *fh; 581c216e5adSMichael Roth int ret; 5820a982b1bSEric Blake int whence; 5830b4b4938SEric Blake Error *err = NULL; 584c216e5adSMichael Roth 585c216e5adSMichael Roth if (!gfh) { 586c216e5adSMichael Roth return NULL; 587c216e5adSMichael Roth } 588c216e5adSMichael Roth 5890a982b1bSEric Blake /* We stupidly exposed 'whence':'int' in our qapi */ 5900b4b4938SEric Blake whence = ga_parse_whence(whence_code, &err); 5910b4b4938SEric Blake if (err) { 5920b4b4938SEric Blake error_propagate(errp, err); 5930a982b1bSEric Blake return NULL; 5940a982b1bSEric Blake } 5950a982b1bSEric Blake 596c216e5adSMichael Roth fh = gfh->fh; 597c216e5adSMichael Roth ret = fseek(fh, offset, whence); 598c216e5adSMichael Roth if (ret == -1) { 59977dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to seek file"); 600895b00f6SMarc-André Lureau if (errno == ESPIPE) { 601895b00f6SMarc-André Lureau /* file is non-seekable, stdio shouldn't be buffering anyways */ 602895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 603895b00f6SMarc-André Lureau } 604c216e5adSMichael Roth } else { 60510b7c5ddSMarkus Armbruster seek_data = g_new0(GuestFileSeek, 1); 606c216e5adSMichael Roth seek_data->position = ftell(fh); 607c216e5adSMichael Roth seek_data->eof = feof(fh); 608895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 609c216e5adSMichael Roth } 610c216e5adSMichael Roth clearerr(fh); 611c216e5adSMichael Roth 612c216e5adSMichael Roth return seek_data; 613c216e5adSMichael Roth } 614c216e5adSMichael Roth 61577dbc81bSMarkus Armbruster void qmp_guest_file_flush(int64_t handle, Error **errp) 616c216e5adSMichael Roth { 61777dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 618c216e5adSMichael Roth FILE *fh; 619c216e5adSMichael Roth int ret; 620c216e5adSMichael Roth 621c216e5adSMichael Roth if (!gfh) { 622c216e5adSMichael Roth return; 623c216e5adSMichael Roth } 624c216e5adSMichael Roth 625c216e5adSMichael Roth fh = gfh->fh; 626c216e5adSMichael Roth ret = fflush(fh); 627c216e5adSMichael Roth if (ret == EOF) { 62877dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to flush file"); 629895b00f6SMarc-André Lureau } else { 630895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 631c216e5adSMichael Roth } 632c216e5adSMichael Roth } 633c216e5adSMichael Roth 634e72c3f2eSMichael Roth /* linux-specific implementations. avoid this if at all possible. */ 635e72c3f2eSMichael Roth #if defined(__linux__) 636e72c3f2eSMichael Roth 637eab5fd59SPaolo Bonzini #if defined(CONFIG_FSFREEZE) || defined(CONFIG_FSTRIM) 638af02203fSPaolo Bonzini typedef struct FsMount { 639c216e5adSMichael Roth char *dirname; 640c216e5adSMichael Roth char *devtype; 64146d4c572STomoki Sekiyama unsigned int devmajor, devminor; 642af02203fSPaolo Bonzini QTAILQ_ENTRY(FsMount) next; 643af02203fSPaolo Bonzini } FsMount; 644c216e5adSMichael Roth 645e5d9adbdSTomoki Sekiyama typedef QTAILQ_HEAD(FsMountList, FsMount) FsMountList; 6469e8aded4SMichael Roth 647af02203fSPaolo Bonzini static void free_fs_mount_list(FsMountList *mounts) 648c216e5adSMichael Roth { 649af02203fSPaolo Bonzini FsMount *mount, *temp; 650c216e5adSMichael Roth 6519e8aded4SMichael Roth if (!mounts) { 6529e8aded4SMichael Roth return; 6539e8aded4SMichael Roth } 6549e8aded4SMichael Roth 6559e8aded4SMichael Roth QTAILQ_FOREACH_SAFE(mount, mounts, next, temp) { 6569e8aded4SMichael Roth QTAILQ_REMOVE(mounts, mount, next); 657c216e5adSMichael Roth g_free(mount->dirname); 658c216e5adSMichael Roth g_free(mount->devtype); 659c216e5adSMichael Roth g_free(mount); 660c216e5adSMichael Roth } 6619e8aded4SMichael Roth } 6629e8aded4SMichael Roth 66346d4c572STomoki Sekiyama static int dev_major_minor(const char *devpath, 66446d4c572STomoki Sekiyama unsigned int *devmajor, unsigned int *devminor) 66546d4c572STomoki Sekiyama { 66646d4c572STomoki Sekiyama struct stat st; 66746d4c572STomoki Sekiyama 66846d4c572STomoki Sekiyama *devmajor = 0; 66946d4c572STomoki Sekiyama *devminor = 0; 67046d4c572STomoki Sekiyama 67146d4c572STomoki Sekiyama if (stat(devpath, &st) < 0) { 67246d4c572STomoki Sekiyama slog("failed to stat device file '%s': %s", devpath, strerror(errno)); 67346d4c572STomoki Sekiyama return -1; 67446d4c572STomoki Sekiyama } 67546d4c572STomoki Sekiyama if (S_ISDIR(st.st_mode)) { 67646d4c572STomoki Sekiyama /* It is bind mount */ 67746d4c572STomoki Sekiyama return -2; 67846d4c572STomoki Sekiyama } 67946d4c572STomoki Sekiyama if (S_ISBLK(st.st_mode)) { 68046d4c572STomoki Sekiyama *devmajor = major(st.st_rdev); 68146d4c572STomoki Sekiyama *devminor = minor(st.st_rdev); 68246d4c572STomoki Sekiyama return 0; 68346d4c572STomoki Sekiyama } 68446d4c572STomoki Sekiyama return -1; 68546d4c572STomoki Sekiyama } 68646d4c572STomoki Sekiyama 6879e8aded4SMichael Roth /* 6889e8aded4SMichael Roth * Walk the mount table and build a list of local file systems 6899e8aded4SMichael Roth */ 69046d4c572STomoki Sekiyama static void build_fs_mount_list_from_mtab(FsMountList *mounts, Error **errp) 6919e8aded4SMichael Roth { 6929e8aded4SMichael Roth struct mntent *ment; 693af02203fSPaolo Bonzini FsMount *mount; 6949e2fa418SMichael Roth char const *mtab = "/proc/self/mounts"; 6959e8aded4SMichael Roth FILE *fp; 69646d4c572STomoki Sekiyama unsigned int devmajor, devminor; 697c216e5adSMichael Roth 698c216e5adSMichael Roth fp = setmntent(mtab, "r"); 699c216e5adSMichael Roth if (!fp) { 70077dbc81bSMarkus Armbruster error_setg(errp, "failed to open mtab file: '%s'", mtab); 701261551d1SLuiz Capitulino return; 702c216e5adSMichael Roth } 703c216e5adSMichael Roth 704c216e5adSMichael Roth while ((ment = getmntent(fp))) { 705c216e5adSMichael Roth /* 706c216e5adSMichael Roth * An entry which device name doesn't start with a '/' is 707c216e5adSMichael Roth * either a dummy file system or a network file system. 708c216e5adSMichael Roth * Add special handling for smbfs and cifs as is done by 709c216e5adSMichael Roth * coreutils as well. 710c216e5adSMichael Roth */ 711c216e5adSMichael Roth if ((ment->mnt_fsname[0] != '/') || 712c216e5adSMichael Roth (strcmp(ment->mnt_type, "smbfs") == 0) || 713c216e5adSMichael Roth (strcmp(ment->mnt_type, "cifs") == 0)) { 714c216e5adSMichael Roth continue; 715c216e5adSMichael Roth } 71646d4c572STomoki Sekiyama if (dev_major_minor(ment->mnt_fsname, &devmajor, &devminor) == -2) { 71746d4c572STomoki Sekiyama /* Skip bind mounts */ 71846d4c572STomoki Sekiyama continue; 71946d4c572STomoki Sekiyama } 720c216e5adSMichael Roth 721f3a06403SMarkus Armbruster mount = g_new0(FsMount, 1); 722c216e5adSMichael Roth mount->dirname = g_strdup(ment->mnt_dir); 723c216e5adSMichael Roth mount->devtype = g_strdup(ment->mnt_type); 72446d4c572STomoki Sekiyama mount->devmajor = devmajor; 72546d4c572STomoki Sekiyama mount->devminor = devminor; 726c216e5adSMichael Roth 7279e8aded4SMichael Roth QTAILQ_INSERT_TAIL(mounts, mount, next); 728c216e5adSMichael Roth } 729c216e5adSMichael Roth 730c216e5adSMichael Roth endmntent(fp); 731c216e5adSMichael Roth } 73246d4c572STomoki Sekiyama 73346d4c572STomoki Sekiyama static void decode_mntname(char *name, int len) 73446d4c572STomoki Sekiyama { 73546d4c572STomoki Sekiyama int i, j = 0; 73646d4c572STomoki Sekiyama for (i = 0; i <= len; i++) { 73746d4c572STomoki Sekiyama if (name[i] != '\\') { 73846d4c572STomoki Sekiyama name[j++] = name[i]; 73946d4c572STomoki Sekiyama } else if (name[i + 1] == '\\') { 74046d4c572STomoki Sekiyama name[j++] = '\\'; 74146d4c572STomoki Sekiyama i++; 74246d4c572STomoki Sekiyama } else if (name[i + 1] >= '0' && name[i + 1] <= '3' && 74346d4c572STomoki Sekiyama name[i + 2] >= '0' && name[i + 2] <= '7' && 74446d4c572STomoki Sekiyama name[i + 3] >= '0' && name[i + 3] <= '7') { 74546d4c572STomoki Sekiyama name[j++] = (name[i + 1] - '0') * 64 + 74646d4c572STomoki Sekiyama (name[i + 2] - '0') * 8 + 74746d4c572STomoki Sekiyama (name[i + 3] - '0'); 74846d4c572STomoki Sekiyama i += 3; 74946d4c572STomoki Sekiyama } else { 75046d4c572STomoki Sekiyama name[j++] = name[i]; 75146d4c572STomoki Sekiyama } 75246d4c572STomoki Sekiyama } 75346d4c572STomoki Sekiyama } 75446d4c572STomoki Sekiyama 75546d4c572STomoki Sekiyama static void build_fs_mount_list(FsMountList *mounts, Error **errp) 75646d4c572STomoki Sekiyama { 75746d4c572STomoki Sekiyama FsMount *mount; 75846d4c572STomoki Sekiyama char const *mountinfo = "/proc/self/mountinfo"; 75946d4c572STomoki Sekiyama FILE *fp; 76046d4c572STomoki Sekiyama char *line = NULL, *dash; 76146d4c572STomoki Sekiyama size_t n; 76246d4c572STomoki Sekiyama char check; 76346d4c572STomoki Sekiyama unsigned int devmajor, devminor; 76446d4c572STomoki Sekiyama int ret, dir_s, dir_e, type_s, type_e, dev_s, dev_e; 76546d4c572STomoki Sekiyama 76646d4c572STomoki Sekiyama fp = fopen(mountinfo, "r"); 76746d4c572STomoki Sekiyama if (!fp) { 76846d4c572STomoki Sekiyama build_fs_mount_list_from_mtab(mounts, errp); 76946d4c572STomoki Sekiyama return; 77046d4c572STomoki Sekiyama } 77146d4c572STomoki Sekiyama 77246d4c572STomoki Sekiyama while (getline(&line, &n, fp) != -1) { 77346d4c572STomoki Sekiyama ret = sscanf(line, "%*u %*u %u:%u %*s %n%*s%n%c", 77446d4c572STomoki Sekiyama &devmajor, &devminor, &dir_s, &dir_e, &check); 77546d4c572STomoki Sekiyama if (ret < 3) { 77646d4c572STomoki Sekiyama continue; 77746d4c572STomoki Sekiyama } 77846d4c572STomoki Sekiyama dash = strstr(line + dir_e, " - "); 77946d4c572STomoki Sekiyama if (!dash) { 78046d4c572STomoki Sekiyama continue; 78146d4c572STomoki Sekiyama } 78246d4c572STomoki Sekiyama ret = sscanf(dash, " - %n%*s%n %n%*s%n%c", 78346d4c572STomoki Sekiyama &type_s, &type_e, &dev_s, &dev_e, &check); 78446d4c572STomoki Sekiyama if (ret < 1) { 78546d4c572STomoki Sekiyama continue; 78646d4c572STomoki Sekiyama } 78746d4c572STomoki Sekiyama line[dir_e] = 0; 78846d4c572STomoki Sekiyama dash[type_e] = 0; 78946d4c572STomoki Sekiyama dash[dev_e] = 0; 79046d4c572STomoki Sekiyama decode_mntname(line + dir_s, dir_e - dir_s); 79146d4c572STomoki Sekiyama decode_mntname(dash + dev_s, dev_e - dev_s); 79246d4c572STomoki Sekiyama if (devmajor == 0) { 79346d4c572STomoki Sekiyama /* btrfs reports major number = 0 */ 79446d4c572STomoki Sekiyama if (strcmp("btrfs", dash + type_s) != 0 || 79546d4c572STomoki Sekiyama dev_major_minor(dash + dev_s, &devmajor, &devminor) < 0) { 79646d4c572STomoki Sekiyama continue; 79746d4c572STomoki Sekiyama } 79846d4c572STomoki Sekiyama } 79946d4c572STomoki Sekiyama 800f3a06403SMarkus Armbruster mount = g_new0(FsMount, 1); 80146d4c572STomoki Sekiyama mount->dirname = g_strdup(line + dir_s); 80246d4c572STomoki Sekiyama mount->devtype = g_strdup(dash + type_s); 80346d4c572STomoki Sekiyama mount->devmajor = devmajor; 80446d4c572STomoki Sekiyama mount->devminor = devminor; 80546d4c572STomoki Sekiyama 80646d4c572STomoki Sekiyama QTAILQ_INSERT_TAIL(mounts, mount, next); 80746d4c572STomoki Sekiyama } 80846d4c572STomoki Sekiyama free(line); 80946d4c572STomoki Sekiyama 81046d4c572STomoki Sekiyama fclose(fp); 81146d4c572STomoki Sekiyama } 812eab5fd59SPaolo Bonzini #endif 813eab5fd59SPaolo Bonzini 814eab5fd59SPaolo Bonzini #if defined(CONFIG_FSFREEZE) 815c216e5adSMichael Roth 81646d4c572STomoki Sekiyama static char *get_pci_driver(char const *syspath, int pathlen, Error **errp) 81746d4c572STomoki Sekiyama { 81846d4c572STomoki Sekiyama char *path; 81946d4c572STomoki Sekiyama char *dpath; 82046d4c572STomoki Sekiyama char *driver = NULL; 82146d4c572STomoki Sekiyama char buf[PATH_MAX]; 82246d4c572STomoki Sekiyama ssize_t len; 82346d4c572STomoki Sekiyama 82446d4c572STomoki Sekiyama path = g_strndup(syspath, pathlen); 82546d4c572STomoki Sekiyama dpath = g_strdup_printf("%s/driver", path); 82646d4c572STomoki Sekiyama len = readlink(dpath, buf, sizeof(buf) - 1); 82746d4c572STomoki Sekiyama if (len != -1) { 82846d4c572STomoki Sekiyama buf[len] = 0; 8293e015d81SJulia Suvorova driver = g_path_get_basename(buf); 83046d4c572STomoki Sekiyama } 83146d4c572STomoki Sekiyama g_free(dpath); 83246d4c572STomoki Sekiyama g_free(path); 83346d4c572STomoki Sekiyama return driver; 83446d4c572STomoki Sekiyama } 83546d4c572STomoki Sekiyama 83646d4c572STomoki Sekiyama static int compare_uint(const void *_a, const void *_b) 83746d4c572STomoki Sekiyama { 83846d4c572STomoki Sekiyama unsigned int a = *(unsigned int *)_a; 83946d4c572STomoki Sekiyama unsigned int b = *(unsigned int *)_b; 84046d4c572STomoki Sekiyama 84146d4c572STomoki Sekiyama return a < b ? -1 : a > b ? 1 : 0; 84246d4c572STomoki Sekiyama } 84346d4c572STomoki Sekiyama 84446d4c572STomoki Sekiyama /* Walk the specified sysfs and build a sorted list of host or ata numbers */ 84546d4c572STomoki Sekiyama static int build_hosts(char const *syspath, char const *host, bool ata, 84646d4c572STomoki Sekiyama unsigned int *hosts, int hosts_max, Error **errp) 84746d4c572STomoki Sekiyama { 84846d4c572STomoki Sekiyama char *path; 84946d4c572STomoki Sekiyama DIR *dir; 85046d4c572STomoki Sekiyama struct dirent *entry; 85146d4c572STomoki Sekiyama int i = 0; 85246d4c572STomoki Sekiyama 85346d4c572STomoki Sekiyama path = g_strndup(syspath, host - syspath); 85446d4c572STomoki Sekiyama dir = opendir(path); 85546d4c572STomoki Sekiyama if (!dir) { 85646d4c572STomoki Sekiyama error_setg_errno(errp, errno, "opendir(\"%s\")", path); 85746d4c572STomoki Sekiyama g_free(path); 85846d4c572STomoki Sekiyama return -1; 85946d4c572STomoki Sekiyama } 86046d4c572STomoki Sekiyama 86146d4c572STomoki Sekiyama while (i < hosts_max) { 86246d4c572STomoki Sekiyama entry = readdir(dir); 86346d4c572STomoki Sekiyama if (!entry) { 86446d4c572STomoki Sekiyama break; 86546d4c572STomoki Sekiyama } 86646d4c572STomoki Sekiyama if (ata && sscanf(entry->d_name, "ata%d", hosts + i) == 1) { 86746d4c572STomoki Sekiyama ++i; 86846d4c572STomoki Sekiyama } else if (!ata && sscanf(entry->d_name, "host%d", hosts + i) == 1) { 86946d4c572STomoki Sekiyama ++i; 87046d4c572STomoki Sekiyama } 87146d4c572STomoki Sekiyama } 87246d4c572STomoki Sekiyama 87346d4c572STomoki Sekiyama qsort(hosts, i, sizeof(hosts[0]), compare_uint); 87446d4c572STomoki Sekiyama 87546d4c572STomoki Sekiyama g_free(path); 87646d4c572STomoki Sekiyama closedir(dir); 87746d4c572STomoki Sekiyama return i; 87846d4c572STomoki Sekiyama } 87946d4c572STomoki Sekiyama 88046d4c572STomoki Sekiyama /* Store disk device info specified by @sysfs into @fs */ 88146d4c572STomoki Sekiyama static void build_guest_fsinfo_for_real_device(char const *syspath, 88246d4c572STomoki Sekiyama GuestFilesystemInfo *fs, 88346d4c572STomoki Sekiyama Error **errp) 88446d4c572STomoki Sekiyama { 88546d4c572STomoki Sekiyama unsigned int pci[4], host, hosts[8], tgt[3]; 88646d4c572STomoki Sekiyama int i, nhosts = 0, pcilen; 88746d4c572STomoki Sekiyama GuestDiskAddress *disk; 88846d4c572STomoki Sekiyama GuestPCIAddress *pciaddr; 88946d4c572STomoki Sekiyama GuestDiskAddressList *list = NULL; 89046d4c572STomoki Sekiyama bool has_ata = false, has_host = false, has_tgt = false; 89146d4c572STomoki Sekiyama char *p, *q, *driver = NULL; 892b616105aSTomáš Golembiovský #ifdef CONFIG_LIBUDEV 893b616105aSTomáš Golembiovský struct udev *udev = NULL; 894b616105aSTomáš Golembiovský struct udev_device *udevice = NULL; 895b616105aSTomáš Golembiovský #endif 89646d4c572STomoki Sekiyama 89746d4c572STomoki Sekiyama p = strstr(syspath, "/devices/pci"); 89846d4c572STomoki Sekiyama if (!p || sscanf(p + 12, "%*x:%*x/%x:%x:%x.%x%n", 89946d4c572STomoki Sekiyama pci, pci + 1, pci + 2, pci + 3, &pcilen) < 4) { 900743c71d0SMarc-André Lureau g_debug("only pci device is supported: sysfs path '%s'", syspath); 90146d4c572STomoki Sekiyama return; 90246d4c572STomoki Sekiyama } 90346d4c572STomoki Sekiyama 904743c71d0SMarc-André Lureau p += 12 + pcilen; 905743c71d0SMarc-André Lureau while (true) { 906743c71d0SMarc-André Lureau driver = get_pci_driver(syspath, p - syspath, errp); 907743c71d0SMarc-André Lureau if (driver && (g_str_equal(driver, "ata_piix") || 908743c71d0SMarc-André Lureau g_str_equal(driver, "sym53c8xx") || 909743c71d0SMarc-André Lureau g_str_equal(driver, "virtio-pci") || 910743c71d0SMarc-André Lureau g_str_equal(driver, "ahci"))) { 911743c71d0SMarc-André Lureau break; 912743c71d0SMarc-André Lureau } 913743c71d0SMarc-André Lureau 914bb23a736SMarc-André Lureau g_free(driver); 915743c71d0SMarc-André Lureau if (sscanf(p, "/%x:%x:%x.%x%n", 916743c71d0SMarc-André Lureau pci, pci + 1, pci + 2, pci + 3, &pcilen) == 4) { 917743c71d0SMarc-André Lureau p += pcilen; 918743c71d0SMarc-André Lureau continue; 919743c71d0SMarc-André Lureau } 920743c71d0SMarc-André Lureau 921743c71d0SMarc-André Lureau g_debug("unsupported driver or sysfs path '%s'", syspath); 922743c71d0SMarc-André Lureau return; 92346d4c572STomoki Sekiyama } 92446d4c572STomoki Sekiyama 92546d4c572STomoki Sekiyama p = strstr(syspath, "/target"); 92646d4c572STomoki Sekiyama if (p && sscanf(p + 7, "%*u:%*u:%*u/%*u:%u:%u:%u", 92746d4c572STomoki Sekiyama tgt, tgt + 1, tgt + 2) == 3) { 92846d4c572STomoki Sekiyama has_tgt = true; 92946d4c572STomoki Sekiyama } 93046d4c572STomoki Sekiyama 93146d4c572STomoki Sekiyama p = strstr(syspath, "/ata"); 93246d4c572STomoki Sekiyama if (p) { 93346d4c572STomoki Sekiyama q = p + 4; 93446d4c572STomoki Sekiyama has_ata = true; 93546d4c572STomoki Sekiyama } else { 93646d4c572STomoki Sekiyama p = strstr(syspath, "/host"); 93746d4c572STomoki Sekiyama q = p + 5; 93846d4c572STomoki Sekiyama } 93946d4c572STomoki Sekiyama if (p && sscanf(q, "%u", &host) == 1) { 94046d4c572STomoki Sekiyama has_host = true; 94146d4c572STomoki Sekiyama nhosts = build_hosts(syspath, p, has_ata, hosts, 94201a6df1bSPhilippe Mathieu-Daudé ARRAY_SIZE(hosts), errp); 94346d4c572STomoki Sekiyama if (nhosts < 0) { 94446d4c572STomoki Sekiyama goto cleanup; 94546d4c572STomoki Sekiyama } 94646d4c572STomoki Sekiyama } 94746d4c572STomoki Sekiyama 94846d4c572STomoki Sekiyama pciaddr = g_malloc0(sizeof(*pciaddr)); 94946d4c572STomoki Sekiyama pciaddr->domain = pci[0]; 95046d4c572STomoki Sekiyama pciaddr->bus = pci[1]; 95146d4c572STomoki Sekiyama pciaddr->slot = pci[2]; 95246d4c572STomoki Sekiyama pciaddr->function = pci[3]; 95346d4c572STomoki Sekiyama 95446d4c572STomoki Sekiyama disk = g_malloc0(sizeof(*disk)); 95546d4c572STomoki Sekiyama disk->pci_controller = pciaddr; 95646d4c572STomoki Sekiyama 95746d4c572STomoki Sekiyama list = g_malloc0(sizeof(*list)); 95846d4c572STomoki Sekiyama list->value = disk; 95946d4c572STomoki Sekiyama 960b616105aSTomáš Golembiovský #ifdef CONFIG_LIBUDEV 961b616105aSTomáš Golembiovský udev = udev_new(); 962b616105aSTomáš Golembiovský udevice = udev_device_new_from_syspath(udev, syspath); 963b616105aSTomáš Golembiovský if (udev == NULL || udevice == NULL) { 964b616105aSTomáš Golembiovský g_debug("failed to query udev"); 965b616105aSTomáš Golembiovský } else { 9666589ce35STomáš Golembiovský const char *devnode, *serial; 9676589ce35STomáš Golembiovský devnode = udev_device_get_devnode(udevice); 9686589ce35STomáš Golembiovský if (devnode != NULL) { 9696589ce35STomáš Golembiovský disk->dev = g_strdup(devnode); 9706589ce35STomáš Golembiovský disk->has_dev = true; 9716589ce35STomáš Golembiovský } 972b616105aSTomáš Golembiovský serial = udev_device_get_property_value(udevice, "ID_SERIAL"); 973b616105aSTomáš Golembiovský if (serial != NULL && *serial != 0) { 974b616105aSTomáš Golembiovský disk->serial = g_strdup(serial); 975b616105aSTomáš Golembiovský disk->has_serial = true; 976b616105aSTomáš Golembiovský } 977b616105aSTomáš Golembiovský } 978b616105aSTomáš Golembiovský #endif 979b616105aSTomáš Golembiovský 98046d4c572STomoki Sekiyama if (strcmp(driver, "ata_piix") == 0) { 98146d4c572STomoki Sekiyama /* a host per ide bus, target*:0:<unit>:0 */ 98246d4c572STomoki Sekiyama if (!has_host || !has_tgt) { 98346d4c572STomoki Sekiyama g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver); 98446d4c572STomoki Sekiyama goto cleanup; 98546d4c572STomoki Sekiyama } 98646d4c572STomoki Sekiyama for (i = 0; i < nhosts; i++) { 98746d4c572STomoki Sekiyama if (host == hosts[i]) { 98846d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_IDE; 98946d4c572STomoki Sekiyama disk->bus = i; 99046d4c572STomoki Sekiyama disk->unit = tgt[1]; 99146d4c572STomoki Sekiyama break; 99246d4c572STomoki Sekiyama } 99346d4c572STomoki Sekiyama } 99446d4c572STomoki Sekiyama if (i >= nhosts) { 99546d4c572STomoki Sekiyama g_debug("no host for '%s' (driver '%s')", syspath, driver); 99646d4c572STomoki Sekiyama goto cleanup; 99746d4c572STomoki Sekiyama } 99846d4c572STomoki Sekiyama } else if (strcmp(driver, "sym53c8xx") == 0) { 99946d4c572STomoki Sekiyama /* scsi(LSI Logic): target*:0:<unit>:0 */ 100046d4c572STomoki Sekiyama if (!has_tgt) { 100146d4c572STomoki Sekiyama g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver); 100246d4c572STomoki Sekiyama goto cleanup; 100346d4c572STomoki Sekiyama } 100446d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI; 100546d4c572STomoki Sekiyama disk->unit = tgt[1]; 100646d4c572STomoki Sekiyama } else if (strcmp(driver, "virtio-pci") == 0) { 100746d4c572STomoki Sekiyama if (has_tgt) { 100846d4c572STomoki Sekiyama /* virtio-scsi: target*:0:0:<unit> */ 100946d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI; 101046d4c572STomoki Sekiyama disk->unit = tgt[2]; 101146d4c572STomoki Sekiyama } else { 101246d4c572STomoki Sekiyama /* virtio-blk: 1 disk per 1 device */ 101346d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_VIRTIO; 101446d4c572STomoki Sekiyama } 101546d4c572STomoki Sekiyama } else if (strcmp(driver, "ahci") == 0) { 101646d4c572STomoki Sekiyama /* ahci: 1 host per 1 unit */ 101746d4c572STomoki Sekiyama if (!has_host || !has_tgt) { 101846d4c572STomoki Sekiyama g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver); 101946d4c572STomoki Sekiyama goto cleanup; 102046d4c572STomoki Sekiyama } 102146d4c572STomoki Sekiyama for (i = 0; i < nhosts; i++) { 102246d4c572STomoki Sekiyama if (host == hosts[i]) { 102346d4c572STomoki Sekiyama disk->unit = i; 102446d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_SATA; 102546d4c572STomoki Sekiyama break; 102646d4c572STomoki Sekiyama } 102746d4c572STomoki Sekiyama } 102846d4c572STomoki Sekiyama if (i >= nhosts) { 102946d4c572STomoki Sekiyama g_debug("no host for '%s' (driver '%s')", syspath, driver); 103046d4c572STomoki Sekiyama goto cleanup; 103146d4c572STomoki Sekiyama } 103246d4c572STomoki Sekiyama } else { 103346d4c572STomoki Sekiyama g_debug("unknown driver '%s' (sysfs path '%s')", driver, syspath); 103446d4c572STomoki Sekiyama goto cleanup; 103546d4c572STomoki Sekiyama } 103646d4c572STomoki Sekiyama 103746d4c572STomoki Sekiyama list->next = fs->disk; 103846d4c572STomoki Sekiyama fs->disk = list; 1039b616105aSTomáš Golembiovský goto out; 104046d4c572STomoki Sekiyama 104146d4c572STomoki Sekiyama cleanup: 104246d4c572STomoki Sekiyama if (list) { 104346d4c572STomoki Sekiyama qapi_free_GuestDiskAddressList(list); 104446d4c572STomoki Sekiyama } 1045b616105aSTomáš Golembiovský out: 104646d4c572STomoki Sekiyama g_free(driver); 1047b616105aSTomáš Golembiovský #ifdef CONFIG_LIBUDEV 1048b616105aSTomáš Golembiovský udev_unref(udev); 1049b616105aSTomáš Golembiovský udev_device_unref(udevice); 1050b616105aSTomáš Golembiovský #endif 1051b616105aSTomáš Golembiovský return; 105246d4c572STomoki Sekiyama } 105346d4c572STomoki Sekiyama 105446d4c572STomoki Sekiyama static void build_guest_fsinfo_for_device(char const *devpath, 105546d4c572STomoki Sekiyama GuestFilesystemInfo *fs, 105646d4c572STomoki Sekiyama Error **errp); 105746d4c572STomoki Sekiyama 105846d4c572STomoki Sekiyama /* Store a list of slave devices of virtual volume specified by @syspath into 105946d4c572STomoki Sekiyama * @fs */ 106046d4c572STomoki Sekiyama static void build_guest_fsinfo_for_virtual_device(char const *syspath, 106146d4c572STomoki Sekiyama GuestFilesystemInfo *fs, 106246d4c572STomoki Sekiyama Error **errp) 106346d4c572STomoki Sekiyama { 1064292743d9SMarkus Armbruster Error *err = NULL; 106546d4c572STomoki Sekiyama DIR *dir; 106646d4c572STomoki Sekiyama char *dirpath; 1067e668d1b8Szhanghailiang struct dirent *entry; 106846d4c572STomoki Sekiyama 106946d4c572STomoki Sekiyama dirpath = g_strdup_printf("%s/slaves", syspath); 107046d4c572STomoki Sekiyama dir = opendir(dirpath); 107146d4c572STomoki Sekiyama if (!dir) { 10728251a72fSMichael Roth if (errno != ENOENT) { 107346d4c572STomoki Sekiyama error_setg_errno(errp, errno, "opendir(\"%s\")", dirpath); 10748251a72fSMichael Roth } 107546d4c572STomoki Sekiyama g_free(dirpath); 107646d4c572STomoki Sekiyama return; 107746d4c572STomoki Sekiyama } 107846d4c572STomoki Sekiyama 107946d4c572STomoki Sekiyama for (;;) { 1080e668d1b8Szhanghailiang errno = 0; 1081e668d1b8Szhanghailiang entry = readdir(dir); 1082e668d1b8Szhanghailiang if (entry == NULL) { 1083e668d1b8Szhanghailiang if (errno) { 1084e668d1b8Szhanghailiang error_setg_errno(errp, errno, "readdir(\"%s\")", dirpath); 108546d4c572STomoki Sekiyama } 108646d4c572STomoki Sekiyama break; 108746d4c572STomoki Sekiyama } 108846d4c572STomoki Sekiyama 1089e668d1b8Szhanghailiang if (entry->d_type == DT_LNK) { 1090e668d1b8Szhanghailiang char *path; 1091e668d1b8Szhanghailiang 1092e668d1b8Szhanghailiang g_debug(" slave device '%s'", entry->d_name); 1093e668d1b8Szhanghailiang path = g_strdup_printf("%s/slaves/%s", syspath, entry->d_name); 1094292743d9SMarkus Armbruster build_guest_fsinfo_for_device(path, fs, &err); 1095e668d1b8Szhanghailiang g_free(path); 109646d4c572STomoki Sekiyama 1097292743d9SMarkus Armbruster if (err) { 1098292743d9SMarkus Armbruster error_propagate(errp, err); 109946d4c572STomoki Sekiyama break; 110046d4c572STomoki Sekiyama } 110146d4c572STomoki Sekiyama } 110246d4c572STomoki Sekiyama } 110346d4c572STomoki Sekiyama 1104e668d1b8Szhanghailiang g_free(dirpath); 110546d4c572STomoki Sekiyama closedir(dir); 110646d4c572STomoki Sekiyama } 110746d4c572STomoki Sekiyama 110846d4c572STomoki Sekiyama /* Dispatch to functions for virtual/real device */ 110946d4c572STomoki Sekiyama static void build_guest_fsinfo_for_device(char const *devpath, 111046d4c572STomoki Sekiyama GuestFilesystemInfo *fs, 111146d4c572STomoki Sekiyama Error **errp) 111246d4c572STomoki Sekiyama { 111346d4c572STomoki Sekiyama char *syspath = realpath(devpath, NULL); 111446d4c572STomoki Sekiyama 111546d4c572STomoki Sekiyama if (!syspath) { 111646d4c572STomoki Sekiyama error_setg_errno(errp, errno, "realpath(\"%s\")", devpath); 111746d4c572STomoki Sekiyama return; 111846d4c572STomoki Sekiyama } 111946d4c572STomoki Sekiyama 112046d4c572STomoki Sekiyama if (!fs->name) { 11213e015d81SJulia Suvorova fs->name = g_path_get_basename(syspath); 112246d4c572STomoki Sekiyama } 112346d4c572STomoki Sekiyama 112446d4c572STomoki Sekiyama g_debug(" parse sysfs path '%s'", syspath); 112546d4c572STomoki Sekiyama 112646d4c572STomoki Sekiyama if (strstr(syspath, "/devices/virtual/block/")) { 112746d4c572STomoki Sekiyama build_guest_fsinfo_for_virtual_device(syspath, fs, errp); 112846d4c572STomoki Sekiyama } else { 112946d4c572STomoki Sekiyama build_guest_fsinfo_for_real_device(syspath, fs, errp); 113046d4c572STomoki Sekiyama } 113146d4c572STomoki Sekiyama 113246d4c572STomoki Sekiyama free(syspath); 113346d4c572STomoki Sekiyama } 113446d4c572STomoki Sekiyama 113546d4c572STomoki Sekiyama /* Return a list of the disk device(s)' info which @mount lies on */ 113646d4c572STomoki Sekiyama static GuestFilesystemInfo *build_guest_fsinfo(struct FsMount *mount, 113746d4c572STomoki Sekiyama Error **errp) 113846d4c572STomoki Sekiyama { 113946d4c572STomoki Sekiyama GuestFilesystemInfo *fs = g_malloc0(sizeof(*fs)); 114025b5ff1aSChen Hanxiao struct statvfs buf; 114125b5ff1aSChen Hanxiao unsigned long used, nonroot_total, fr_size; 114246d4c572STomoki Sekiyama char *devpath = g_strdup_printf("/sys/dev/block/%u:%u", 114346d4c572STomoki Sekiyama mount->devmajor, mount->devminor); 114446d4c572STomoki Sekiyama 114546d4c572STomoki Sekiyama fs->mountpoint = g_strdup(mount->dirname); 114646d4c572STomoki Sekiyama fs->type = g_strdup(mount->devtype); 114746d4c572STomoki Sekiyama build_guest_fsinfo_for_device(devpath, fs, errp); 114846d4c572STomoki Sekiyama 114925b5ff1aSChen Hanxiao if (statvfs(fs->mountpoint, &buf) == 0) { 115025b5ff1aSChen Hanxiao fr_size = buf.f_frsize; 115125b5ff1aSChen Hanxiao used = buf.f_blocks - buf.f_bfree; 115225b5ff1aSChen Hanxiao nonroot_total = used + buf.f_bavail; 115325b5ff1aSChen Hanxiao fs->used_bytes = used * fr_size; 115425b5ff1aSChen Hanxiao fs->total_bytes = nonroot_total * fr_size; 115525b5ff1aSChen Hanxiao 115625b5ff1aSChen Hanxiao fs->has_total_bytes = true; 115725b5ff1aSChen Hanxiao fs->has_used_bytes = true; 115825b5ff1aSChen Hanxiao } 115925b5ff1aSChen Hanxiao 116046d4c572STomoki Sekiyama g_free(devpath); 116125b5ff1aSChen Hanxiao 116246d4c572STomoki Sekiyama return fs; 116346d4c572STomoki Sekiyama } 116446d4c572STomoki Sekiyama 116546d4c572STomoki Sekiyama GuestFilesystemInfoList *qmp_guest_get_fsinfo(Error **errp) 116646d4c572STomoki Sekiyama { 116746d4c572STomoki Sekiyama FsMountList mounts; 116846d4c572STomoki Sekiyama struct FsMount *mount; 116946d4c572STomoki Sekiyama GuestFilesystemInfoList *new, *ret = NULL; 117046d4c572STomoki Sekiyama Error *local_err = NULL; 117146d4c572STomoki Sekiyama 117246d4c572STomoki Sekiyama QTAILQ_INIT(&mounts); 117346d4c572STomoki Sekiyama build_fs_mount_list(&mounts, &local_err); 117446d4c572STomoki Sekiyama if (local_err) { 117546d4c572STomoki Sekiyama error_propagate(errp, local_err); 117646d4c572STomoki Sekiyama return NULL; 117746d4c572STomoki Sekiyama } 117846d4c572STomoki Sekiyama 117946d4c572STomoki Sekiyama QTAILQ_FOREACH(mount, &mounts, next) { 118046d4c572STomoki Sekiyama g_debug("Building guest fsinfo for '%s'", mount->dirname); 118146d4c572STomoki Sekiyama 118246d4c572STomoki Sekiyama new = g_malloc0(sizeof(*ret)); 118346d4c572STomoki Sekiyama new->value = build_guest_fsinfo(mount, &local_err); 118446d4c572STomoki Sekiyama new->next = ret; 118546d4c572STomoki Sekiyama ret = new; 118646d4c572STomoki Sekiyama if (local_err) { 118746d4c572STomoki Sekiyama error_propagate(errp, local_err); 118846d4c572STomoki Sekiyama qapi_free_GuestFilesystemInfoList(ret); 118946d4c572STomoki Sekiyama ret = NULL; 119046d4c572STomoki Sekiyama break; 119146d4c572STomoki Sekiyama } 119246d4c572STomoki Sekiyama } 119346d4c572STomoki Sekiyama 119446d4c572STomoki Sekiyama free_fs_mount_list(&mounts); 119546d4c572STomoki Sekiyama return ret; 119646d4c572STomoki Sekiyama } 119746d4c572STomoki Sekiyama 119846d4c572STomoki Sekiyama 1199ec0f694cSTomoki Sekiyama typedef enum { 1200ec0f694cSTomoki Sekiyama FSFREEZE_HOOK_THAW = 0, 1201ec0f694cSTomoki Sekiyama FSFREEZE_HOOK_FREEZE, 1202ec0f694cSTomoki Sekiyama } FsfreezeHookArg; 1203ec0f694cSTomoki Sekiyama 120413a439ecSStefan Weil static const char *fsfreeze_hook_arg_string[] = { 1205ec0f694cSTomoki Sekiyama "thaw", 1206ec0f694cSTomoki Sekiyama "freeze", 1207ec0f694cSTomoki Sekiyama }; 1208ec0f694cSTomoki Sekiyama 120977dbc81bSMarkus Armbruster static void execute_fsfreeze_hook(FsfreezeHookArg arg, Error **errp) 1210ec0f694cSTomoki Sekiyama { 1211ec0f694cSTomoki Sekiyama int status; 1212ec0f694cSTomoki Sekiyama pid_t pid; 1213ec0f694cSTomoki Sekiyama const char *hook; 1214ec0f694cSTomoki Sekiyama const char *arg_str = fsfreeze_hook_arg_string[arg]; 1215ec0f694cSTomoki Sekiyama Error *local_err = NULL; 1216ec0f694cSTomoki Sekiyama 1217ec0f694cSTomoki Sekiyama hook = ga_fsfreeze_hook(ga_state); 1218ec0f694cSTomoki Sekiyama if (!hook) { 1219ec0f694cSTomoki Sekiyama return; 1220ec0f694cSTomoki Sekiyama } 1221ec0f694cSTomoki Sekiyama if (access(hook, X_OK) != 0) { 122277dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "can't access fsfreeze hook '%s'", hook); 1223ec0f694cSTomoki Sekiyama return; 1224ec0f694cSTomoki Sekiyama } 1225ec0f694cSTomoki Sekiyama 1226ec0f694cSTomoki Sekiyama slog("executing fsfreeze hook with arg '%s'", arg_str); 1227ec0f694cSTomoki Sekiyama pid = fork(); 1228ec0f694cSTomoki Sekiyama if (pid == 0) { 1229ec0f694cSTomoki Sekiyama setsid(); 1230ec0f694cSTomoki Sekiyama reopen_fd_to_null(0); 1231ec0f694cSTomoki Sekiyama reopen_fd_to_null(1); 1232ec0f694cSTomoki Sekiyama reopen_fd_to_null(2); 1233ec0f694cSTomoki Sekiyama 1234ec0f694cSTomoki Sekiyama execle(hook, hook, arg_str, NULL, environ); 1235ec0f694cSTomoki Sekiyama _exit(EXIT_FAILURE); 1236ec0f694cSTomoki Sekiyama } else if (pid < 0) { 123777dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to create child process"); 1238ec0f694cSTomoki Sekiyama return; 1239ec0f694cSTomoki Sekiyama } 1240ec0f694cSTomoki Sekiyama 1241ec0f694cSTomoki Sekiyama ga_wait_child(pid, &status, &local_err); 124284d18f06SMarkus Armbruster if (local_err) { 124377dbc81bSMarkus Armbruster error_propagate(errp, local_err); 1244ec0f694cSTomoki Sekiyama return; 1245ec0f694cSTomoki Sekiyama } 1246ec0f694cSTomoki Sekiyama 1247ec0f694cSTomoki Sekiyama if (!WIFEXITED(status)) { 124877dbc81bSMarkus Armbruster error_setg(errp, "fsfreeze hook has terminated abnormally"); 1249ec0f694cSTomoki Sekiyama return; 1250ec0f694cSTomoki Sekiyama } 1251ec0f694cSTomoki Sekiyama 1252ec0f694cSTomoki Sekiyama status = WEXITSTATUS(status); 1253ec0f694cSTomoki Sekiyama if (status) { 125477dbc81bSMarkus Armbruster error_setg(errp, "fsfreeze hook has failed with status %d", status); 1255ec0f694cSTomoki Sekiyama return; 1256ec0f694cSTomoki Sekiyama } 1257ec0f694cSTomoki Sekiyama } 1258ec0f694cSTomoki Sekiyama 1259c216e5adSMichael Roth /* 1260c216e5adSMichael Roth * Return status of freeze/thaw 1261c216e5adSMichael Roth */ 126277dbc81bSMarkus Armbruster GuestFsfreezeStatus qmp_guest_fsfreeze_status(Error **errp) 1263c216e5adSMichael Roth { 1264f22d85e9SMichael Roth if (ga_is_frozen(ga_state)) { 1265f22d85e9SMichael Roth return GUEST_FSFREEZE_STATUS_FROZEN; 1266f22d85e9SMichael Roth } 1267f22d85e9SMichael Roth 1268f22d85e9SMichael Roth return GUEST_FSFREEZE_STATUS_THAWED; 1269c216e5adSMichael Roth } 1270c216e5adSMichael Roth 1271e99bce20STomoki Sekiyama int64_t qmp_guest_fsfreeze_freeze(Error **errp) 1272e99bce20STomoki Sekiyama { 1273e99bce20STomoki Sekiyama return qmp_guest_fsfreeze_freeze_list(false, NULL, errp); 1274e99bce20STomoki Sekiyama } 1275e99bce20STomoki Sekiyama 1276c216e5adSMichael Roth /* 1277c216e5adSMichael Roth * Walk list of mounted file systems in the guest, and freeze the ones which 1278c216e5adSMichael Roth * are real local file systems. 1279c216e5adSMichael Roth */ 1280e99bce20STomoki Sekiyama int64_t qmp_guest_fsfreeze_freeze_list(bool has_mountpoints, 1281e99bce20STomoki Sekiyama strList *mountpoints, 1282e99bce20STomoki Sekiyama Error **errp) 1283c216e5adSMichael Roth { 1284c216e5adSMichael Roth int ret = 0, i = 0; 1285e99bce20STomoki Sekiyama strList *list; 1286af02203fSPaolo Bonzini FsMountList mounts; 1287af02203fSPaolo Bonzini struct FsMount *mount; 1288261551d1SLuiz Capitulino Error *local_err = NULL; 1289c216e5adSMichael Roth int fd; 1290c216e5adSMichael Roth 1291c216e5adSMichael Roth slog("guest-fsfreeze called"); 1292c216e5adSMichael Roth 1293ec0f694cSTomoki Sekiyama execute_fsfreeze_hook(FSFREEZE_HOOK_FREEZE, &local_err); 129484d18f06SMarkus Armbruster if (local_err) { 129577dbc81bSMarkus Armbruster error_propagate(errp, local_err); 1296ec0f694cSTomoki Sekiyama return -1; 1297ec0f694cSTomoki Sekiyama } 1298ec0f694cSTomoki Sekiyama 12999e8aded4SMichael Roth QTAILQ_INIT(&mounts); 1300261551d1SLuiz Capitulino build_fs_mount_list(&mounts, &local_err); 130184d18f06SMarkus Armbruster if (local_err) { 130277dbc81bSMarkus Armbruster error_propagate(errp, local_err); 1303261551d1SLuiz Capitulino return -1; 1304c216e5adSMichael Roth } 1305c216e5adSMichael Roth 1306c216e5adSMichael Roth /* cannot risk guest agent blocking itself on a write in this state */ 1307f22d85e9SMichael Roth ga_set_frozen(ga_state); 1308c216e5adSMichael Roth 1309eae3eb3eSPaolo Bonzini QTAILQ_FOREACH_REVERSE(mount, &mounts, next) { 1310e99bce20STomoki Sekiyama /* To issue fsfreeze in the reverse order of mounts, check if the 1311e99bce20STomoki Sekiyama * mount is listed in the list here */ 1312e99bce20STomoki Sekiyama if (has_mountpoints) { 1313e99bce20STomoki Sekiyama for (list = mountpoints; list; list = list->next) { 1314e99bce20STomoki Sekiyama if (strcmp(list->value, mount->dirname) == 0) { 1315e99bce20STomoki Sekiyama break; 1316e99bce20STomoki Sekiyama } 1317e99bce20STomoki Sekiyama } 1318e99bce20STomoki Sekiyama if (!list) { 1319e99bce20STomoki Sekiyama continue; 1320e99bce20STomoki Sekiyama } 1321e99bce20STomoki Sekiyama } 1322e99bce20STomoki Sekiyama 1323c216e5adSMichael Roth fd = qemu_open(mount->dirname, O_RDONLY); 1324c216e5adSMichael Roth if (fd == -1) { 132577dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to open %s", mount->dirname); 1326c216e5adSMichael Roth goto error; 1327c216e5adSMichael Roth } 1328c216e5adSMichael Roth 1329e35916acSMichael Tokarev /* we try to cull filesystems we know won't work in advance, but other 1330e35916acSMichael Tokarev * filesystems may not implement fsfreeze for less obvious reasons. 13319e8aded4SMichael Roth * these will report EOPNOTSUPP. we simply ignore these when tallying 13329e8aded4SMichael Roth * the number of frozen filesystems. 1333ce2eb6c4SPeter Lieven * if a filesystem is mounted more than once (aka bind mount) a 1334ce2eb6c4SPeter Lieven * consecutive attempt to freeze an already frozen filesystem will 1335ce2eb6c4SPeter Lieven * return EBUSY. 13369e8aded4SMichael Roth * 13379e8aded4SMichael Roth * any other error means a failure to freeze a filesystem we 13389e8aded4SMichael Roth * expect to be freezable, so return an error in those cases 13399e8aded4SMichael Roth * and return system to thawed state. 1340c216e5adSMichael Roth */ 1341c216e5adSMichael Roth ret = ioctl(fd, FIFREEZE); 13429e8aded4SMichael Roth if (ret == -1) { 1343ce2eb6c4SPeter Lieven if (errno != EOPNOTSUPP && errno != EBUSY) { 134477dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to freeze %s", 1345617fbbc1SLuiz Capitulino mount->dirname); 1346c216e5adSMichael Roth close(fd); 1347c216e5adSMichael Roth goto error; 1348c216e5adSMichael Roth } 13499e8aded4SMichael Roth } else { 1350c216e5adSMichael Roth i++; 1351c216e5adSMichael Roth } 13529e8aded4SMichael Roth close(fd); 13539e8aded4SMichael Roth } 1354c216e5adSMichael Roth 1355af02203fSPaolo Bonzini free_fs_mount_list(&mounts); 135665650f01SChen Hanxiao /* We may not issue any FIFREEZE here. 135765650f01SChen Hanxiao * Just unset ga_state here and ready for the next call. 135865650f01SChen Hanxiao */ 135965650f01SChen Hanxiao if (i == 0) { 136065650f01SChen Hanxiao ga_unset_frozen(ga_state); 136165650f01SChen Hanxiao } 1362c216e5adSMichael Roth return i; 1363c216e5adSMichael Roth 1364c216e5adSMichael Roth error: 1365af02203fSPaolo Bonzini free_fs_mount_list(&mounts); 1366c216e5adSMichael Roth qmp_guest_fsfreeze_thaw(NULL); 1367c216e5adSMichael Roth return 0; 1368c216e5adSMichael Roth } 1369c216e5adSMichael Roth 1370c216e5adSMichael Roth /* 1371c216e5adSMichael Roth * Walk list of frozen file systems in the guest, and thaw them. 1372c216e5adSMichael Roth */ 137377dbc81bSMarkus Armbruster int64_t qmp_guest_fsfreeze_thaw(Error **errp) 1374c216e5adSMichael Roth { 1375c216e5adSMichael Roth int ret; 1376af02203fSPaolo Bonzini FsMountList mounts; 1377af02203fSPaolo Bonzini FsMount *mount; 13789e8aded4SMichael Roth int fd, i = 0, logged; 1379261551d1SLuiz Capitulino Error *local_err = NULL; 1380c216e5adSMichael Roth 13819e8aded4SMichael Roth QTAILQ_INIT(&mounts); 1382261551d1SLuiz Capitulino build_fs_mount_list(&mounts, &local_err); 138384d18f06SMarkus Armbruster if (local_err) { 138477dbc81bSMarkus Armbruster error_propagate(errp, local_err); 13859e8aded4SMichael Roth return 0; 13869e8aded4SMichael Roth } 13879e8aded4SMichael Roth 13889e8aded4SMichael Roth QTAILQ_FOREACH(mount, &mounts, next) { 13899e8aded4SMichael Roth logged = false; 1390c216e5adSMichael Roth fd = qemu_open(mount->dirname, O_RDONLY); 1391c216e5adSMichael Roth if (fd == -1) { 1392c216e5adSMichael Roth continue; 1393c216e5adSMichael Roth } 13949e8aded4SMichael Roth /* we have no way of knowing whether a filesystem was actually unfrozen 13959e8aded4SMichael Roth * as a result of a successful call to FITHAW, only that if an error 13969e8aded4SMichael Roth * was returned the filesystem was *not* unfrozen by that particular 13979e8aded4SMichael Roth * call. 13989e8aded4SMichael Roth * 1399a31f0531SJim Meyering * since multiple preceding FIFREEZEs require multiple calls to FITHAW 14009e8aded4SMichael Roth * to unfreeze, continuing issuing FITHAW until an error is returned, 14019e8aded4SMichael Roth * in which case either the filesystem is in an unfreezable state, or, 14029e8aded4SMichael Roth * more likely, it was thawed previously (and remains so afterward). 14039e8aded4SMichael Roth * 14049e8aded4SMichael Roth * also, since the most recent successful call is the one that did 14059e8aded4SMichael Roth * the actual unfreeze, we can use this to provide an accurate count 14069e8aded4SMichael Roth * of the number of filesystems unfrozen by guest-fsfreeze-thaw, which 14079e8aded4SMichael Roth * may * be useful for determining whether a filesystem was unfrozen 14089e8aded4SMichael Roth * during the freeze/thaw phase by a process other than qemu-ga. 14099e8aded4SMichael Roth */ 14109e8aded4SMichael Roth do { 1411c216e5adSMichael Roth ret = ioctl(fd, FITHAW); 14129e8aded4SMichael Roth if (ret == 0 && !logged) { 1413c216e5adSMichael Roth i++; 14149e8aded4SMichael Roth logged = true; 14159e8aded4SMichael Roth } 14169e8aded4SMichael Roth } while (ret == 0); 14179e8aded4SMichael Roth close(fd); 1418c216e5adSMichael Roth } 1419c216e5adSMichael Roth 1420f22d85e9SMichael Roth ga_unset_frozen(ga_state); 1421af02203fSPaolo Bonzini free_fs_mount_list(&mounts); 1422ec0f694cSTomoki Sekiyama 142377dbc81bSMarkus Armbruster execute_fsfreeze_hook(FSFREEZE_HOOK_THAW, errp); 1424ec0f694cSTomoki Sekiyama 1425c216e5adSMichael Roth return i; 1426c216e5adSMichael Roth } 1427c216e5adSMichael Roth 1428c216e5adSMichael Roth static void guest_fsfreeze_cleanup(void) 1429c216e5adSMichael Roth { 1430c216e5adSMichael Roth Error *err = NULL; 1431c216e5adSMichael Roth 1432f22d85e9SMichael Roth if (ga_is_frozen(ga_state) == GUEST_FSFREEZE_STATUS_FROZEN) { 14336f686749SMarkus Armbruster qmp_guest_fsfreeze_thaw(&err); 14346f686749SMarkus Armbruster if (err) { 14356f686749SMarkus Armbruster slog("failed to clean up frozen filesystems: %s", 14366f686749SMarkus Armbruster error_get_pretty(err)); 14376f686749SMarkus Armbruster error_free(err); 1438c216e5adSMichael Roth } 1439c216e5adSMichael Roth } 1440c216e5adSMichael Roth } 1441e72c3f2eSMichael Roth #endif /* CONFIG_FSFREEZE */ 1442c216e5adSMichael Roth 1443eab5fd59SPaolo Bonzini #if defined(CONFIG_FSTRIM) 1444eab5fd59SPaolo Bonzini /* 1445eab5fd59SPaolo Bonzini * Walk list of mounted file systems in the guest, and trim them. 1446eab5fd59SPaolo Bonzini */ 1447e82855d9SJustin Ossevoort GuestFilesystemTrimResponse * 1448e82855d9SJustin Ossevoort qmp_guest_fstrim(bool has_minimum, int64_t minimum, Error **errp) 1449eab5fd59SPaolo Bonzini { 1450e82855d9SJustin Ossevoort GuestFilesystemTrimResponse *response; 1451e82855d9SJustin Ossevoort GuestFilesystemTrimResultList *list; 1452e82855d9SJustin Ossevoort GuestFilesystemTrimResult *result; 1453eab5fd59SPaolo Bonzini int ret = 0; 1454eab5fd59SPaolo Bonzini FsMountList mounts; 1455eab5fd59SPaolo Bonzini struct FsMount *mount; 1456eab5fd59SPaolo Bonzini int fd; 1457261551d1SLuiz Capitulino Error *local_err = NULL; 145873a652a1SJustin Ossevoort struct fstrim_range r; 1459eab5fd59SPaolo Bonzini 1460eab5fd59SPaolo Bonzini slog("guest-fstrim called"); 1461eab5fd59SPaolo Bonzini 1462eab5fd59SPaolo Bonzini QTAILQ_INIT(&mounts); 1463261551d1SLuiz Capitulino build_fs_mount_list(&mounts, &local_err); 146484d18f06SMarkus Armbruster if (local_err) { 146577dbc81bSMarkus Armbruster error_propagate(errp, local_err); 1466e82855d9SJustin Ossevoort return NULL; 1467eab5fd59SPaolo Bonzini } 1468eab5fd59SPaolo Bonzini 1469e82855d9SJustin Ossevoort response = g_malloc0(sizeof(*response)); 1470e82855d9SJustin Ossevoort 1471eab5fd59SPaolo Bonzini QTAILQ_FOREACH(mount, &mounts, next) { 1472e82855d9SJustin Ossevoort result = g_malloc0(sizeof(*result)); 1473e82855d9SJustin Ossevoort result->path = g_strdup(mount->dirname); 1474e82855d9SJustin Ossevoort 1475e82855d9SJustin Ossevoort list = g_malloc0(sizeof(*list)); 1476e82855d9SJustin Ossevoort list->value = result; 1477e82855d9SJustin Ossevoort list->next = response->paths; 1478e82855d9SJustin Ossevoort response->paths = list; 1479e82855d9SJustin Ossevoort 1480eab5fd59SPaolo Bonzini fd = qemu_open(mount->dirname, O_RDONLY); 1481eab5fd59SPaolo Bonzini if (fd == -1) { 1482e82855d9SJustin Ossevoort result->error = g_strdup_printf("failed to open: %s", 1483e82855d9SJustin Ossevoort strerror(errno)); 1484e82855d9SJustin Ossevoort result->has_error = true; 1485e82855d9SJustin Ossevoort continue; 1486eab5fd59SPaolo Bonzini } 1487eab5fd59SPaolo Bonzini 1488e35916acSMichael Tokarev /* We try to cull filesystems we know won't work in advance, but other 1489e35916acSMichael Tokarev * filesystems may not implement fstrim for less obvious reasons. 1490e35916acSMichael Tokarev * These will report EOPNOTSUPP; while in some other cases ENOTTY 1491e35916acSMichael Tokarev * will be reported (e.g. CD-ROMs). 1492e82855d9SJustin Ossevoort * Any other error means an unexpected error. 1493eab5fd59SPaolo Bonzini */ 149473a652a1SJustin Ossevoort r.start = 0; 149573a652a1SJustin Ossevoort r.len = -1; 149673a652a1SJustin Ossevoort r.minlen = has_minimum ? minimum : 0; 1497eab5fd59SPaolo Bonzini ret = ioctl(fd, FITRIM, &r); 1498eab5fd59SPaolo Bonzini if (ret == -1) { 1499e82855d9SJustin Ossevoort result->has_error = true; 1500e82855d9SJustin Ossevoort if (errno == ENOTTY || errno == EOPNOTSUPP) { 1501e82855d9SJustin Ossevoort result->error = g_strdup("trim not supported"); 1502e82855d9SJustin Ossevoort } else { 1503e82855d9SJustin Ossevoort result->error = g_strdup_printf("failed to trim: %s", 1504e82855d9SJustin Ossevoort strerror(errno)); 1505e82855d9SJustin Ossevoort } 1506eab5fd59SPaolo Bonzini close(fd); 1507e82855d9SJustin Ossevoort continue; 1508eab5fd59SPaolo Bonzini } 1509e82855d9SJustin Ossevoort 1510e82855d9SJustin Ossevoort result->has_minimum = true; 1511e82855d9SJustin Ossevoort result->minimum = r.minlen; 1512e82855d9SJustin Ossevoort result->has_trimmed = true; 1513e82855d9SJustin Ossevoort result->trimmed = r.len; 1514eab5fd59SPaolo Bonzini close(fd); 1515eab5fd59SPaolo Bonzini } 1516eab5fd59SPaolo Bonzini 1517eab5fd59SPaolo Bonzini free_fs_mount_list(&mounts); 1518e82855d9SJustin Ossevoort return response; 1519eab5fd59SPaolo Bonzini } 1520eab5fd59SPaolo Bonzini #endif /* CONFIG_FSTRIM */ 1521eab5fd59SPaolo Bonzini 1522eab5fd59SPaolo Bonzini 152311d0f125SLuiz Capitulino #define LINUX_SYS_STATE_FILE "/sys/power/state" 152411d0f125SLuiz Capitulino #define SUSPEND_SUPPORTED 0 152511d0f125SLuiz Capitulino #define SUSPEND_NOT_SUPPORTED 1 152611d0f125SLuiz Capitulino 15278b020b5eSDaniel Henrique Barboza typedef enum { 15288b020b5eSDaniel Henrique Barboza SUSPEND_MODE_DISK = 0, 15298b020b5eSDaniel Henrique Barboza SUSPEND_MODE_RAM = 1, 15308b020b5eSDaniel Henrique Barboza SUSPEND_MODE_HYBRID = 2, 15318b020b5eSDaniel Henrique Barboza } SuspendMode; 15328b020b5eSDaniel Henrique Barboza 15338b020b5eSDaniel Henrique Barboza /* 15348b020b5eSDaniel Henrique Barboza * Executes a command in a child process using g_spawn_sync, 15358b020b5eSDaniel Henrique Barboza * returning an int >= 0 representing the exit status of the 15368b020b5eSDaniel Henrique Barboza * process. 15378b020b5eSDaniel Henrique Barboza * 15388b020b5eSDaniel Henrique Barboza * If the program wasn't found in path, returns -1. 15398b020b5eSDaniel Henrique Barboza * 15408b020b5eSDaniel Henrique Barboza * If a problem happened when creating the child process, 15418b020b5eSDaniel Henrique Barboza * returns -1 and errp is set. 15428b020b5eSDaniel Henrique Barboza */ 15438b020b5eSDaniel Henrique Barboza static int run_process_child(const char *command[], Error **errp) 15448b020b5eSDaniel Henrique Barboza { 15458b020b5eSDaniel Henrique Barboza int exit_status, spawn_flag; 15468b020b5eSDaniel Henrique Barboza GError *g_err = NULL; 15478b020b5eSDaniel Henrique Barboza bool success; 15488b020b5eSDaniel Henrique Barboza 15498b020b5eSDaniel Henrique Barboza spawn_flag = G_SPAWN_SEARCH_PATH | G_SPAWN_STDOUT_TO_DEV_NULL | 15508b020b5eSDaniel Henrique Barboza G_SPAWN_STDERR_TO_DEV_NULL; 15518b020b5eSDaniel Henrique Barboza 15528b020b5eSDaniel Henrique Barboza success = g_spawn_sync(NULL, (char **)command, environ, spawn_flag, 15538b020b5eSDaniel Henrique Barboza NULL, NULL, NULL, NULL, 15548b020b5eSDaniel Henrique Barboza &exit_status, &g_err); 15558b020b5eSDaniel Henrique Barboza 15568b020b5eSDaniel Henrique Barboza if (success) { 15578b020b5eSDaniel Henrique Barboza return WEXITSTATUS(exit_status); 15588b020b5eSDaniel Henrique Barboza } 15598b020b5eSDaniel Henrique Barboza 15608b020b5eSDaniel Henrique Barboza if (g_err && (g_err->code != G_SPAWN_ERROR_NOENT)) { 15618b020b5eSDaniel Henrique Barboza error_setg(errp, "failed to create child process, error '%s'", 15628b020b5eSDaniel Henrique Barboza g_err->message); 15638b020b5eSDaniel Henrique Barboza } 15648b020b5eSDaniel Henrique Barboza 15658b020b5eSDaniel Henrique Barboza g_error_free(g_err); 15668b020b5eSDaniel Henrique Barboza return -1; 15678b020b5eSDaniel Henrique Barboza } 15688b020b5eSDaniel Henrique Barboza 1569067927d6SDaniel Henrique Barboza static bool systemd_supports_mode(SuspendMode mode, Error **errp) 1570067927d6SDaniel Henrique Barboza { 1571067927d6SDaniel Henrique Barboza Error *local_err = NULL; 1572067927d6SDaniel Henrique Barboza const char *systemctl_args[3] = {"systemd-hibernate", "systemd-suspend", 1573067927d6SDaniel Henrique Barboza "systemd-hybrid-sleep"}; 1574067927d6SDaniel Henrique Barboza const char *cmd[4] = {"systemctl", "status", systemctl_args[mode], NULL}; 1575067927d6SDaniel Henrique Barboza int status; 1576067927d6SDaniel Henrique Barboza 1577067927d6SDaniel Henrique Barboza status = run_process_child(cmd, &local_err); 1578067927d6SDaniel Henrique Barboza 1579067927d6SDaniel Henrique Barboza /* 1580067927d6SDaniel Henrique Barboza * systemctl status uses LSB return codes so we can expect 1581067927d6SDaniel Henrique Barboza * status > 0 and be ok. To assert if the guest has support 1582067927d6SDaniel Henrique Barboza * for the selected suspend mode, status should be < 4. 4 is 1583067927d6SDaniel Henrique Barboza * the code for unknown service status, the return value when 1584067927d6SDaniel Henrique Barboza * the service does not exist. A common value is status = 3 1585067927d6SDaniel Henrique Barboza * (program is not running). 1586067927d6SDaniel Henrique Barboza */ 1587067927d6SDaniel Henrique Barboza if (status > 0 && status < 4) { 1588067927d6SDaniel Henrique Barboza return true; 1589067927d6SDaniel Henrique Barboza } 1590067927d6SDaniel Henrique Barboza 1591067927d6SDaniel Henrique Barboza error_propagate(errp, local_err); 1592067927d6SDaniel Henrique Barboza return false; 1593067927d6SDaniel Henrique Barboza } 1594067927d6SDaniel Henrique Barboza 1595067927d6SDaniel Henrique Barboza static void systemd_suspend(SuspendMode mode, Error **errp) 1596067927d6SDaniel Henrique Barboza { 1597067927d6SDaniel Henrique Barboza Error *local_err = NULL; 1598067927d6SDaniel Henrique Barboza const char *systemctl_args[3] = {"hibernate", "suspend", "hybrid-sleep"}; 1599067927d6SDaniel Henrique Barboza const char *cmd[3] = {"systemctl", systemctl_args[mode], NULL}; 1600067927d6SDaniel Henrique Barboza int status; 1601067927d6SDaniel Henrique Barboza 1602067927d6SDaniel Henrique Barboza status = run_process_child(cmd, &local_err); 1603067927d6SDaniel Henrique Barboza 1604067927d6SDaniel Henrique Barboza if (status == 0) { 1605067927d6SDaniel Henrique Barboza return; 1606067927d6SDaniel Henrique Barboza } 1607067927d6SDaniel Henrique Barboza 1608067927d6SDaniel Henrique Barboza if ((status == -1) && !local_err) { 1609067927d6SDaniel Henrique Barboza error_setg(errp, "the helper program 'systemctl %s' was not found", 1610067927d6SDaniel Henrique Barboza systemctl_args[mode]); 1611067927d6SDaniel Henrique Barboza return; 1612067927d6SDaniel Henrique Barboza } 1613067927d6SDaniel Henrique Barboza 1614067927d6SDaniel Henrique Barboza if (local_err) { 1615067927d6SDaniel Henrique Barboza error_propagate(errp, local_err); 1616067927d6SDaniel Henrique Barboza } else { 1617067927d6SDaniel Henrique Barboza error_setg(errp, "the helper program 'systemctl %s' returned an " 1618067927d6SDaniel Henrique Barboza "unexpected exit status code (%d)", 1619067927d6SDaniel Henrique Barboza systemctl_args[mode], status); 1620067927d6SDaniel Henrique Barboza } 1621067927d6SDaniel Henrique Barboza } 1622067927d6SDaniel Henrique Barboza 16238b020b5eSDaniel Henrique Barboza static bool pmutils_supports_mode(SuspendMode mode, Error **errp) 162411d0f125SLuiz Capitulino { 16256b26e837SLuiz Capitulino Error *local_err = NULL; 16268b020b5eSDaniel Henrique Barboza const char *pmutils_args[3] = {"--hibernate", "--suspend", 16278b020b5eSDaniel Henrique Barboza "--suspend-hybrid"}; 16288b020b5eSDaniel Henrique Barboza const char *cmd[3] = {"pm-is-supported", pmutils_args[mode], NULL}; 1629dc8764f0SLuiz Capitulino int status; 163011d0f125SLuiz Capitulino 16318b020b5eSDaniel Henrique Barboza status = run_process_child(cmd, &local_err); 1632304a0fcbSDaniel Henrique Barboza 16338b020b5eSDaniel Henrique Barboza if (status == SUSPEND_SUPPORTED) { 16348b020b5eSDaniel Henrique Barboza return true; 1635304a0fcbSDaniel Henrique Barboza } 1636304a0fcbSDaniel Henrique Barboza 16378b020b5eSDaniel Henrique Barboza if ((status == -1) && !local_err) { 16388b020b5eSDaniel Henrique Barboza return false; 1639a5fcf0e3SDaniel Henrique Barboza } 164011d0f125SLuiz Capitulino 164184d18f06SMarkus Armbruster if (local_err) { 164277dbc81bSMarkus Armbruster error_propagate(errp, local_err); 16438b020b5eSDaniel Henrique Barboza } else { 164477dbc81bSMarkus Armbruster error_setg(errp, 16458b020b5eSDaniel Henrique Barboza "the helper program '%s' returned an unexpected exit" 16468b020b5eSDaniel Henrique Barboza " status code (%d)", "pm-is-supported", status); 1647dc8764f0SLuiz Capitulino } 164811d0f125SLuiz Capitulino 16498b020b5eSDaniel Henrique Barboza return false; 1650a5fcf0e3SDaniel Henrique Barboza } 1651a5fcf0e3SDaniel Henrique Barboza 16528b020b5eSDaniel Henrique Barboza static void pmutils_suspend(SuspendMode mode, Error **errp) 1653246d76ebSDaniel Henrique Barboza { 1654246d76ebSDaniel Henrique Barboza Error *local_err = NULL; 16558b020b5eSDaniel Henrique Barboza const char *pmutils_binaries[3] = {"pm-hibernate", "pm-suspend", 16568b020b5eSDaniel Henrique Barboza "pm-suspend-hybrid"}; 16578b020b5eSDaniel Henrique Barboza const char *cmd[2] = {pmutils_binaries[mode], NULL}; 1658246d76ebSDaniel Henrique Barboza int status; 1659246d76ebSDaniel Henrique Barboza 16608b020b5eSDaniel Henrique Barboza status = run_process_child(cmd, &local_err); 1661246d76ebSDaniel Henrique Barboza 16628b020b5eSDaniel Henrique Barboza if (status == 0) { 1663246d76ebSDaniel Henrique Barboza return; 1664246d76ebSDaniel Henrique Barboza } 1665246d76ebSDaniel Henrique Barboza 16668b020b5eSDaniel Henrique Barboza if ((status == -1) && !local_err) { 16678b020b5eSDaniel Henrique Barboza error_setg(errp, "the helper program '%s' was not found", 16688b020b5eSDaniel Henrique Barboza pmutils_binaries[mode]); 1669246d76ebSDaniel Henrique Barboza return; 1670246d76ebSDaniel Henrique Barboza } 1671246d76ebSDaniel Henrique Barboza 1672246d76ebSDaniel Henrique Barboza if (local_err) { 1673246d76ebSDaniel Henrique Barboza error_propagate(errp, local_err); 16748b020b5eSDaniel Henrique Barboza } else { 1675246d76ebSDaniel Henrique Barboza error_setg(errp, 16768b020b5eSDaniel Henrique Barboza "the helper program '%s' returned an unexpected exit" 16778b020b5eSDaniel Henrique Barboza " status code (%d)", pmutils_binaries[mode], status); 16788b020b5eSDaniel Henrique Barboza } 1679246d76ebSDaniel Henrique Barboza } 1680246d76ebSDaniel Henrique Barboza 16818b020b5eSDaniel Henrique Barboza static bool linux_sys_state_supports_mode(SuspendMode mode, Error **errp) 1682a5fcf0e3SDaniel Henrique Barboza { 16838b020b5eSDaniel Henrique Barboza const char *sysfile_strs[3] = {"disk", "mem", NULL}; 16848b020b5eSDaniel Henrique Barboza const char *sysfile_str = sysfile_strs[mode]; 1685a5fcf0e3SDaniel Henrique Barboza char buf[32]; /* hopefully big enough */ 1686a5fcf0e3SDaniel Henrique Barboza int fd; 1687a5fcf0e3SDaniel Henrique Barboza ssize_t ret; 1688a5fcf0e3SDaniel Henrique Barboza 16898b020b5eSDaniel Henrique Barboza if (!sysfile_str) { 16908b020b5eSDaniel Henrique Barboza error_setg(errp, "unknown guest suspend mode"); 1691a5fcf0e3SDaniel Henrique Barboza return false; 1692a5fcf0e3SDaniel Henrique Barboza } 1693a5fcf0e3SDaniel Henrique Barboza 1694a5fcf0e3SDaniel Henrique Barboza fd = open(LINUX_SYS_STATE_FILE, O_RDONLY); 1695a5fcf0e3SDaniel Henrique Barboza if (fd < 0) { 1696a5fcf0e3SDaniel Henrique Barboza return false; 1697a5fcf0e3SDaniel Henrique Barboza } 1698a5fcf0e3SDaniel Henrique Barboza 1699a5fcf0e3SDaniel Henrique Barboza ret = read(fd, buf, sizeof(buf) - 1); 1700d9c745c1SPaolo Bonzini close(fd); 1701a5fcf0e3SDaniel Henrique Barboza if (ret <= 0) { 1702a5fcf0e3SDaniel Henrique Barboza return false; 1703a5fcf0e3SDaniel Henrique Barboza } 1704a5fcf0e3SDaniel Henrique Barboza buf[ret] = '\0'; 1705a5fcf0e3SDaniel Henrique Barboza 1706a5fcf0e3SDaniel Henrique Barboza if (strstr(buf, sysfile_str)) { 1707a5fcf0e3SDaniel Henrique Barboza return true; 1708a5fcf0e3SDaniel Henrique Barboza } 1709a5fcf0e3SDaniel Henrique Barboza return false; 1710a5fcf0e3SDaniel Henrique Barboza } 1711a5fcf0e3SDaniel Henrique Barboza 17128b020b5eSDaniel Henrique Barboza static void linux_sys_state_suspend(SuspendMode mode, Error **errp) 1713246d76ebSDaniel Henrique Barboza { 1714246d76ebSDaniel Henrique Barboza Error *local_err = NULL; 17158b020b5eSDaniel Henrique Barboza const char *sysfile_strs[3] = {"disk", "mem", NULL}; 17168b020b5eSDaniel Henrique Barboza const char *sysfile_str = sysfile_strs[mode]; 1717246d76ebSDaniel Henrique Barboza pid_t pid; 1718246d76ebSDaniel Henrique Barboza int status; 1719246d76ebSDaniel Henrique Barboza 17208b020b5eSDaniel Henrique Barboza if (!sysfile_str) { 1721246d76ebSDaniel Henrique Barboza error_setg(errp, "unknown guest suspend mode"); 1722246d76ebSDaniel Henrique Barboza return; 1723246d76ebSDaniel Henrique Barboza } 1724246d76ebSDaniel Henrique Barboza 1725246d76ebSDaniel Henrique Barboza pid = fork(); 1726246d76ebSDaniel Henrique Barboza if (!pid) { 1727246d76ebSDaniel Henrique Barboza /* child */ 1728246d76ebSDaniel Henrique Barboza int fd; 1729246d76ebSDaniel Henrique Barboza 1730246d76ebSDaniel Henrique Barboza setsid(); 1731246d76ebSDaniel Henrique Barboza reopen_fd_to_null(0); 1732246d76ebSDaniel Henrique Barboza reopen_fd_to_null(1); 1733246d76ebSDaniel Henrique Barboza reopen_fd_to_null(2); 1734246d76ebSDaniel Henrique Barboza 1735246d76ebSDaniel Henrique Barboza fd = open(LINUX_SYS_STATE_FILE, O_WRONLY); 1736246d76ebSDaniel Henrique Barboza if (fd < 0) { 1737246d76ebSDaniel Henrique Barboza _exit(EXIT_FAILURE); 1738246d76ebSDaniel Henrique Barboza } 1739246d76ebSDaniel Henrique Barboza 1740246d76ebSDaniel Henrique Barboza if (write(fd, sysfile_str, strlen(sysfile_str)) < 0) { 1741246d76ebSDaniel Henrique Barboza _exit(EXIT_FAILURE); 1742246d76ebSDaniel Henrique Barboza } 1743246d76ebSDaniel Henrique Barboza 1744246d76ebSDaniel Henrique Barboza _exit(EXIT_SUCCESS); 1745246d76ebSDaniel Henrique Barboza } else if (pid < 0) { 1746246d76ebSDaniel Henrique Barboza error_setg_errno(errp, errno, "failed to create child process"); 1747246d76ebSDaniel Henrique Barboza return; 1748246d76ebSDaniel Henrique Barboza } 1749246d76ebSDaniel Henrique Barboza 1750246d76ebSDaniel Henrique Barboza ga_wait_child(pid, &status, &local_err); 1751246d76ebSDaniel Henrique Barboza if (local_err) { 1752246d76ebSDaniel Henrique Barboza error_propagate(errp, local_err); 1753246d76ebSDaniel Henrique Barboza return; 1754246d76ebSDaniel Henrique Barboza } 1755246d76ebSDaniel Henrique Barboza 1756246d76ebSDaniel Henrique Barboza if (WEXITSTATUS(status)) { 1757246d76ebSDaniel Henrique Barboza error_setg(errp, "child process has failed to suspend"); 1758246d76ebSDaniel Henrique Barboza } 1759246d76ebSDaniel Henrique Barboza 1760246d76ebSDaniel Henrique Barboza } 1761246d76ebSDaniel Henrique Barboza 17628b020b5eSDaniel Henrique Barboza static void guest_suspend(SuspendMode mode, Error **errp) 176311d0f125SLuiz Capitulino { 17647b376087SLuiz Capitulino Error *local_err = NULL; 176573e1d8ebSDaniel Henrique Barboza bool mode_supported = false; 176611d0f125SLuiz Capitulino 176773e1d8ebSDaniel Henrique Barboza if (systemd_supports_mode(mode, &local_err)) { 176873e1d8ebSDaniel Henrique Barboza mode_supported = true; 1769067927d6SDaniel Henrique Barboza systemd_suspend(mode, &local_err); 177073e1d8ebSDaniel Henrique Barboza } 177173e1d8ebSDaniel Henrique Barboza 1772067927d6SDaniel Henrique Barboza if (!local_err) { 1773067927d6SDaniel Henrique Barboza return; 1774067927d6SDaniel Henrique Barboza } 1775067927d6SDaniel Henrique Barboza 1776067927d6SDaniel Henrique Barboza error_free(local_err); 17776a4a3853SVladimir Sementsov-Ogievskiy local_err = NULL; 1778067927d6SDaniel Henrique Barboza 177973e1d8ebSDaniel Henrique Barboza if (pmutils_supports_mode(mode, &local_err)) { 178073e1d8ebSDaniel Henrique Barboza mode_supported = true; 17818b020b5eSDaniel Henrique Barboza pmutils_suspend(mode, &local_err); 178273e1d8ebSDaniel Henrique Barboza } 178373e1d8ebSDaniel Henrique Barboza 1784246d76ebSDaniel Henrique Barboza if (!local_err) { 1785304a0fcbSDaniel Henrique Barboza return; 1786304a0fcbSDaniel Henrique Barboza } 1787304a0fcbSDaniel Henrique Barboza 1788246d76ebSDaniel Henrique Barboza error_free(local_err); 17896a4a3853SVladimir Sementsov-Ogievskiy local_err = NULL; 179011d0f125SLuiz Capitulino 179173e1d8ebSDaniel Henrique Barboza if (linux_sys_state_supports_mode(mode, &local_err)) { 179273e1d8ebSDaniel Henrique Barboza mode_supported = true; 17938b020b5eSDaniel Henrique Barboza linux_sys_state_suspend(mode, &local_err); 179473e1d8ebSDaniel Henrique Barboza } 179573e1d8ebSDaniel Henrique Barboza 179673e1d8ebSDaniel Henrique Barboza if (!mode_supported) { 17976a4a3853SVladimir Sementsov-Ogievskiy error_free(local_err); 179873e1d8ebSDaniel Henrique Barboza error_setg(errp, 179973e1d8ebSDaniel Henrique Barboza "the requested suspend mode is not supported by the guest"); 1800b2322003SMarkus Armbruster } else { 180177dbc81bSMarkus Armbruster error_propagate(errp, local_err); 18027b376087SLuiz Capitulino } 180311d0f125SLuiz Capitulino } 180411d0f125SLuiz Capitulino 180577dbc81bSMarkus Armbruster void qmp_guest_suspend_disk(Error **errp) 180611d0f125SLuiz Capitulino { 1807304a0fcbSDaniel Henrique Barboza guest_suspend(SUSPEND_MODE_DISK, errp); 180811d0f125SLuiz Capitulino } 180911d0f125SLuiz Capitulino 181077dbc81bSMarkus Armbruster void qmp_guest_suspend_ram(Error **errp) 1811fbf42210SLuiz Capitulino { 1812304a0fcbSDaniel Henrique Barboza guest_suspend(SUSPEND_MODE_RAM, errp); 1813fbf42210SLuiz Capitulino } 1814fbf42210SLuiz Capitulino 181577dbc81bSMarkus Armbruster void qmp_guest_suspend_hybrid(Error **errp) 181695f4f404SLuiz Capitulino { 1817304a0fcbSDaniel Henrique Barboza guest_suspend(SUSPEND_MODE_HYBRID, errp); 181895f4f404SLuiz Capitulino } 181995f4f404SLuiz Capitulino 18203424fc9fSMichal Privoznik static GuestNetworkInterfaceList * 18213424fc9fSMichal Privoznik guest_find_interface(GuestNetworkInterfaceList *head, 18223424fc9fSMichal Privoznik const char *name) 18233424fc9fSMichal Privoznik { 18243424fc9fSMichal Privoznik for (; head; head = head->next) { 18253424fc9fSMichal Privoznik if (strcmp(head->value->name, name) == 0) { 18263424fc9fSMichal Privoznik break; 18273424fc9fSMichal Privoznik } 18283424fc9fSMichal Privoznik } 18293424fc9fSMichal Privoznik 18303424fc9fSMichal Privoznik return head; 18313424fc9fSMichal Privoznik } 18323424fc9fSMichal Privoznik 183353f9fcb2SZhiPeng Lu static int guest_get_network_stats(const char *name, 183453f9fcb2SZhiPeng Lu GuestNetworkInterfaceStat *stats) 183553f9fcb2SZhiPeng Lu { 183653f9fcb2SZhiPeng Lu int name_len; 183753f9fcb2SZhiPeng Lu char const *devinfo = "/proc/net/dev"; 183853f9fcb2SZhiPeng Lu FILE *fp; 183953f9fcb2SZhiPeng Lu char *line = NULL, *colon; 184053f9fcb2SZhiPeng Lu size_t n = 0; 184153f9fcb2SZhiPeng Lu fp = fopen(devinfo, "r"); 184253f9fcb2SZhiPeng Lu if (!fp) { 184353f9fcb2SZhiPeng Lu return -1; 184453f9fcb2SZhiPeng Lu } 184553f9fcb2SZhiPeng Lu name_len = strlen(name); 184653f9fcb2SZhiPeng Lu while (getline(&line, &n, fp) != -1) { 184753f9fcb2SZhiPeng Lu long long dummy; 184853f9fcb2SZhiPeng Lu long long rx_bytes; 184953f9fcb2SZhiPeng Lu long long rx_packets; 185053f9fcb2SZhiPeng Lu long long rx_errs; 185153f9fcb2SZhiPeng Lu long long rx_dropped; 185253f9fcb2SZhiPeng Lu long long tx_bytes; 185353f9fcb2SZhiPeng Lu long long tx_packets; 185453f9fcb2SZhiPeng Lu long long tx_errs; 185553f9fcb2SZhiPeng Lu long long tx_dropped; 185653f9fcb2SZhiPeng Lu char *trim_line; 185753f9fcb2SZhiPeng Lu trim_line = g_strchug(line); 185853f9fcb2SZhiPeng Lu if (trim_line[0] == '\0') { 185953f9fcb2SZhiPeng Lu continue; 186053f9fcb2SZhiPeng Lu } 186153f9fcb2SZhiPeng Lu colon = strchr(trim_line, ':'); 186253f9fcb2SZhiPeng Lu if (!colon) { 186353f9fcb2SZhiPeng Lu continue; 186453f9fcb2SZhiPeng Lu } 186553f9fcb2SZhiPeng Lu if (colon - name_len == trim_line && 186653f9fcb2SZhiPeng Lu strncmp(trim_line, name, name_len) == 0) { 186753f9fcb2SZhiPeng Lu if (sscanf(colon + 1, 186853f9fcb2SZhiPeng Lu "%lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld", 186953f9fcb2SZhiPeng Lu &rx_bytes, &rx_packets, &rx_errs, &rx_dropped, 187053f9fcb2SZhiPeng Lu &dummy, &dummy, &dummy, &dummy, 187153f9fcb2SZhiPeng Lu &tx_bytes, &tx_packets, &tx_errs, &tx_dropped, 187253f9fcb2SZhiPeng Lu &dummy, &dummy, &dummy, &dummy) != 16) { 187353f9fcb2SZhiPeng Lu continue; 187453f9fcb2SZhiPeng Lu } 187553f9fcb2SZhiPeng Lu stats->rx_bytes = rx_bytes; 187653f9fcb2SZhiPeng Lu stats->rx_packets = rx_packets; 187753f9fcb2SZhiPeng Lu stats->rx_errs = rx_errs; 187853f9fcb2SZhiPeng Lu stats->rx_dropped = rx_dropped; 187953f9fcb2SZhiPeng Lu stats->tx_bytes = tx_bytes; 188053f9fcb2SZhiPeng Lu stats->tx_packets = tx_packets; 188153f9fcb2SZhiPeng Lu stats->tx_errs = tx_errs; 188253f9fcb2SZhiPeng Lu stats->tx_dropped = tx_dropped; 188353f9fcb2SZhiPeng Lu fclose(fp); 188453f9fcb2SZhiPeng Lu g_free(line); 188553f9fcb2SZhiPeng Lu return 0; 188653f9fcb2SZhiPeng Lu } 188753f9fcb2SZhiPeng Lu } 188853f9fcb2SZhiPeng Lu fclose(fp); 188953f9fcb2SZhiPeng Lu g_free(line); 189053f9fcb2SZhiPeng Lu g_debug("/proc/net/dev: Interface '%s' not found", name); 189153f9fcb2SZhiPeng Lu return -1; 189253f9fcb2SZhiPeng Lu } 189353f9fcb2SZhiPeng Lu 18943424fc9fSMichal Privoznik /* 18953424fc9fSMichal Privoznik * Build information about guest interfaces 18963424fc9fSMichal Privoznik */ 18973424fc9fSMichal Privoznik GuestNetworkInterfaceList *qmp_guest_network_get_interfaces(Error **errp) 18983424fc9fSMichal Privoznik { 18993424fc9fSMichal Privoznik GuestNetworkInterfaceList *head = NULL, *cur_item = NULL; 19003424fc9fSMichal Privoznik struct ifaddrs *ifap, *ifa; 19013424fc9fSMichal Privoznik 19023424fc9fSMichal Privoznik if (getifaddrs(&ifap) < 0) { 1903878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, "getifaddrs failed"); 19043424fc9fSMichal Privoznik goto error; 19053424fc9fSMichal Privoznik } 19063424fc9fSMichal Privoznik 19073424fc9fSMichal Privoznik for (ifa = ifap; ifa; ifa = ifa->ifa_next) { 19083424fc9fSMichal Privoznik GuestNetworkInterfaceList *info; 19093424fc9fSMichal Privoznik GuestIpAddressList **address_list = NULL, *address_item = NULL; 191053f9fcb2SZhiPeng Lu GuestNetworkInterfaceStat *interface_stat = NULL; 19113424fc9fSMichal Privoznik char addr4[INET_ADDRSTRLEN]; 19123424fc9fSMichal Privoznik char addr6[INET6_ADDRSTRLEN]; 19133424fc9fSMichal Privoznik int sock; 19143424fc9fSMichal Privoznik struct ifreq ifr; 19153424fc9fSMichal Privoznik unsigned char *mac_addr; 19163424fc9fSMichal Privoznik void *p; 19173424fc9fSMichal Privoznik 19183424fc9fSMichal Privoznik g_debug("Processing %s interface", ifa->ifa_name); 19193424fc9fSMichal Privoznik 19203424fc9fSMichal Privoznik info = guest_find_interface(head, ifa->ifa_name); 19213424fc9fSMichal Privoznik 19223424fc9fSMichal Privoznik if (!info) { 19233424fc9fSMichal Privoznik info = g_malloc0(sizeof(*info)); 19243424fc9fSMichal Privoznik info->value = g_malloc0(sizeof(*info->value)); 19253424fc9fSMichal Privoznik info->value->name = g_strdup(ifa->ifa_name); 19263424fc9fSMichal Privoznik 19273424fc9fSMichal Privoznik if (!cur_item) { 19283424fc9fSMichal Privoznik head = cur_item = info; 19293424fc9fSMichal Privoznik } else { 19303424fc9fSMichal Privoznik cur_item->next = info; 19313424fc9fSMichal Privoznik cur_item = info; 19323424fc9fSMichal Privoznik } 19333424fc9fSMichal Privoznik } 19343424fc9fSMichal Privoznik 19353424fc9fSMichal Privoznik if (!info->value->has_hardware_address && 19363424fc9fSMichal Privoznik ifa->ifa_flags & SIOCGIFHWADDR) { 19373424fc9fSMichal Privoznik /* we haven't obtained HW address yet */ 19383424fc9fSMichal Privoznik sock = socket(PF_INET, SOCK_STREAM, 0); 19393424fc9fSMichal Privoznik if (sock == -1) { 1940878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, "failed to create socket"); 19413424fc9fSMichal Privoznik goto error; 19423424fc9fSMichal Privoznik } 19433424fc9fSMichal Privoznik 19443424fc9fSMichal Privoznik memset(&ifr, 0, sizeof(ifr)); 19451ab516edSJim Meyering pstrcpy(ifr.ifr_name, IF_NAMESIZE, info->value->name); 19463424fc9fSMichal Privoznik if (ioctl(sock, SIOCGIFHWADDR, &ifr) == -1) { 1947878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, 1948878a0ae0SLuiz Capitulino "failed to get MAC address of %s", 1949878a0ae0SLuiz Capitulino ifa->ifa_name); 195010a2158fSMarkus Armbruster close(sock); 19513424fc9fSMichal Privoznik goto error; 19523424fc9fSMichal Privoznik } 19533424fc9fSMichal Privoznik 195410a2158fSMarkus Armbruster close(sock); 19553424fc9fSMichal Privoznik mac_addr = (unsigned char *) &ifr.ifr_hwaddr.sa_data; 19563424fc9fSMichal Privoznik 1957e4ada482SStefan Weil info->value->hardware_address = 1958e4ada482SStefan Weil g_strdup_printf("%02x:%02x:%02x:%02x:%02x:%02x", 19593424fc9fSMichal Privoznik (int) mac_addr[0], (int) mac_addr[1], 19603424fc9fSMichal Privoznik (int) mac_addr[2], (int) mac_addr[3], 1961e4ada482SStefan Weil (int) mac_addr[4], (int) mac_addr[5]); 19623424fc9fSMichal Privoznik 19633424fc9fSMichal Privoznik info->value->has_hardware_address = true; 19643424fc9fSMichal Privoznik } 19653424fc9fSMichal Privoznik 19663424fc9fSMichal Privoznik if (ifa->ifa_addr && 19673424fc9fSMichal Privoznik ifa->ifa_addr->sa_family == AF_INET) { 19683424fc9fSMichal Privoznik /* interface with IPv4 address */ 19693424fc9fSMichal Privoznik p = &((struct sockaddr_in *)ifa->ifa_addr)->sin_addr; 19703424fc9fSMichal Privoznik if (!inet_ntop(AF_INET, p, addr4, sizeof(addr4))) { 1971878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, "inet_ntop failed"); 19723424fc9fSMichal Privoznik goto error; 19733424fc9fSMichal Privoznik } 19743424fc9fSMichal Privoznik 197510a2158fSMarkus Armbruster address_item = g_malloc0(sizeof(*address_item)); 197610a2158fSMarkus Armbruster address_item->value = g_malloc0(sizeof(*address_item->value)); 19773424fc9fSMichal Privoznik address_item->value->ip_address = g_strdup(addr4); 19783424fc9fSMichal Privoznik address_item->value->ip_address_type = GUEST_IP_ADDRESS_TYPE_IPV4; 19793424fc9fSMichal Privoznik 19803424fc9fSMichal Privoznik if (ifa->ifa_netmask) { 19813424fc9fSMichal Privoznik /* Count the number of set bits in netmask. 19823424fc9fSMichal Privoznik * This is safe as '1' and '0' cannot be shuffled in netmask. */ 19833424fc9fSMichal Privoznik p = &((struct sockaddr_in *)ifa->ifa_netmask)->sin_addr; 19843424fc9fSMichal Privoznik address_item->value->prefix = ctpop32(((uint32_t *) p)[0]); 19853424fc9fSMichal Privoznik } 19863424fc9fSMichal Privoznik } else if (ifa->ifa_addr && 19873424fc9fSMichal Privoznik ifa->ifa_addr->sa_family == AF_INET6) { 19883424fc9fSMichal Privoznik /* interface with IPv6 address */ 19893424fc9fSMichal Privoznik p = &((struct sockaddr_in6 *)ifa->ifa_addr)->sin6_addr; 19903424fc9fSMichal Privoznik if (!inet_ntop(AF_INET6, p, addr6, sizeof(addr6))) { 1991878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, "inet_ntop failed"); 19923424fc9fSMichal Privoznik goto error; 19933424fc9fSMichal Privoznik } 19943424fc9fSMichal Privoznik 199510a2158fSMarkus Armbruster address_item = g_malloc0(sizeof(*address_item)); 199610a2158fSMarkus Armbruster address_item->value = g_malloc0(sizeof(*address_item->value)); 19973424fc9fSMichal Privoznik address_item->value->ip_address = g_strdup(addr6); 19983424fc9fSMichal Privoznik address_item->value->ip_address_type = GUEST_IP_ADDRESS_TYPE_IPV6; 19993424fc9fSMichal Privoznik 20003424fc9fSMichal Privoznik if (ifa->ifa_netmask) { 20013424fc9fSMichal Privoznik /* Count the number of set bits in netmask. 20023424fc9fSMichal Privoznik * This is safe as '1' and '0' cannot be shuffled in netmask. */ 20033424fc9fSMichal Privoznik p = &((struct sockaddr_in6 *)ifa->ifa_netmask)->sin6_addr; 20043424fc9fSMichal Privoznik address_item->value->prefix = 20053424fc9fSMichal Privoznik ctpop32(((uint32_t *) p)[0]) + 20063424fc9fSMichal Privoznik ctpop32(((uint32_t *) p)[1]) + 20073424fc9fSMichal Privoznik ctpop32(((uint32_t *) p)[2]) + 20083424fc9fSMichal Privoznik ctpop32(((uint32_t *) p)[3]); 20093424fc9fSMichal Privoznik } 20103424fc9fSMichal Privoznik } 20113424fc9fSMichal Privoznik 20123424fc9fSMichal Privoznik if (!address_item) { 20133424fc9fSMichal Privoznik continue; 20143424fc9fSMichal Privoznik } 20153424fc9fSMichal Privoznik 20163424fc9fSMichal Privoznik address_list = &info->value->ip_addresses; 20173424fc9fSMichal Privoznik 20183424fc9fSMichal Privoznik while (*address_list && (*address_list)->next) { 20193424fc9fSMichal Privoznik address_list = &(*address_list)->next; 20203424fc9fSMichal Privoznik } 20213424fc9fSMichal Privoznik 20223424fc9fSMichal Privoznik if (!*address_list) { 20233424fc9fSMichal Privoznik *address_list = address_item; 20243424fc9fSMichal Privoznik } else { 20253424fc9fSMichal Privoznik (*address_list)->next = address_item; 20263424fc9fSMichal Privoznik } 20273424fc9fSMichal Privoznik 20283424fc9fSMichal Privoznik info->value->has_ip_addresses = true; 20293424fc9fSMichal Privoznik 203053f9fcb2SZhiPeng Lu if (!info->value->has_statistics) { 203153f9fcb2SZhiPeng Lu interface_stat = g_malloc0(sizeof(*interface_stat)); 203253f9fcb2SZhiPeng Lu if (guest_get_network_stats(info->value->name, 203353f9fcb2SZhiPeng Lu interface_stat) == -1) { 203453f9fcb2SZhiPeng Lu info->value->has_statistics = false; 203553f9fcb2SZhiPeng Lu g_free(interface_stat); 203653f9fcb2SZhiPeng Lu } else { 203753f9fcb2SZhiPeng Lu info->value->statistics = interface_stat; 203853f9fcb2SZhiPeng Lu info->value->has_statistics = true; 203953f9fcb2SZhiPeng Lu } 204053f9fcb2SZhiPeng Lu } 20413424fc9fSMichal Privoznik } 20423424fc9fSMichal Privoznik 20433424fc9fSMichal Privoznik freeifaddrs(ifap); 20443424fc9fSMichal Privoznik return head; 20453424fc9fSMichal Privoznik 20463424fc9fSMichal Privoznik error: 20473424fc9fSMichal Privoznik freeifaddrs(ifap); 20483424fc9fSMichal Privoznik qapi_free_GuestNetworkInterfaceList(head); 20493424fc9fSMichal Privoznik return NULL; 20503424fc9fSMichal Privoznik } 20513424fc9fSMichal Privoznik 205277dbc81bSMarkus Armbruster #define SYSCONF_EXACT(name, errp) sysconf_exact((name), #name, (errp)) 2053d2baff62SLaszlo Ersek 205477dbc81bSMarkus Armbruster static long sysconf_exact(int name, const char *name_str, Error **errp) 2055d2baff62SLaszlo Ersek { 2056d2baff62SLaszlo Ersek long ret; 2057d2baff62SLaszlo Ersek 2058d2baff62SLaszlo Ersek errno = 0; 2059d2baff62SLaszlo Ersek ret = sysconf(name); 2060d2baff62SLaszlo Ersek if (ret == -1) { 2061d2baff62SLaszlo Ersek if (errno == 0) { 206277dbc81bSMarkus Armbruster error_setg(errp, "sysconf(%s): value indefinite", name_str); 2063d2baff62SLaszlo Ersek } else { 206477dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "sysconf(%s)", name_str); 2065d2baff62SLaszlo Ersek } 2066d2baff62SLaszlo Ersek } 2067d2baff62SLaszlo Ersek return ret; 2068d2baff62SLaszlo Ersek } 2069d2baff62SLaszlo Ersek 2070d2baff62SLaszlo Ersek /* Transfer online/offline status between @vcpu and the guest system. 2071d2baff62SLaszlo Ersek * 2072d2baff62SLaszlo Ersek * On input either @errp or *@errp must be NULL. 2073d2baff62SLaszlo Ersek * 2074d2baff62SLaszlo Ersek * In system-to-@vcpu direction, the following @vcpu fields are accessed: 2075d2baff62SLaszlo Ersek * - R: vcpu->logical_id 2076d2baff62SLaszlo Ersek * - W: vcpu->online 2077d2baff62SLaszlo Ersek * - W: vcpu->can_offline 2078d2baff62SLaszlo Ersek * 2079d2baff62SLaszlo Ersek * In @vcpu-to-system direction, the following @vcpu fields are accessed: 2080d2baff62SLaszlo Ersek * - R: vcpu->logical_id 2081d2baff62SLaszlo Ersek * - R: vcpu->online 2082d2baff62SLaszlo Ersek * 2083d2baff62SLaszlo Ersek * Written members remain unmodified on error. 2084d2baff62SLaszlo Ersek */ 2085d2baff62SLaszlo Ersek static void transfer_vcpu(GuestLogicalProcessor *vcpu, bool sys2vcpu, 2086b4bf912aSIgor Mammedov char *dirpath, Error **errp) 2087d2baff62SLaszlo Ersek { 2088b4bf912aSIgor Mammedov int fd; 2089b4bf912aSIgor Mammedov int res; 2090d2baff62SLaszlo Ersek int dirfd; 2091b4bf912aSIgor Mammedov static const char fn[] = "online"; 2092d2baff62SLaszlo Ersek 2093d2baff62SLaszlo Ersek dirfd = open(dirpath, O_RDONLY | O_DIRECTORY); 2094d2baff62SLaszlo Ersek if (dirfd == -1) { 2095d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "open(\"%s\")", dirpath); 2096b4bf912aSIgor Mammedov return; 2097b4bf912aSIgor Mammedov } 2098d2baff62SLaszlo Ersek 2099d2baff62SLaszlo Ersek fd = openat(dirfd, fn, sys2vcpu ? O_RDONLY : O_RDWR); 2100d2baff62SLaszlo Ersek if (fd == -1) { 2101d2baff62SLaszlo Ersek if (errno != ENOENT) { 2102d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "open(\"%s/%s\")", dirpath, fn); 2103d2baff62SLaszlo Ersek } else if (sys2vcpu) { 2104d2baff62SLaszlo Ersek vcpu->online = true; 2105d2baff62SLaszlo Ersek vcpu->can_offline = false; 2106d2baff62SLaszlo Ersek } else if (!vcpu->online) { 2107d2baff62SLaszlo Ersek error_setg(errp, "logical processor #%" PRId64 " can't be " 2108d2baff62SLaszlo Ersek "offlined", vcpu->logical_id); 2109d2baff62SLaszlo Ersek } /* otherwise pretend successful re-onlining */ 2110d2baff62SLaszlo Ersek } else { 2111d2baff62SLaszlo Ersek unsigned char status; 2112d2baff62SLaszlo Ersek 2113d2baff62SLaszlo Ersek res = pread(fd, &status, 1, 0); 2114d2baff62SLaszlo Ersek if (res == -1) { 2115d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "pread(\"%s/%s\")", dirpath, fn); 2116d2baff62SLaszlo Ersek } else if (res == 0) { 2117d2baff62SLaszlo Ersek error_setg(errp, "pread(\"%s/%s\"): unexpected EOF", dirpath, 2118d2baff62SLaszlo Ersek fn); 2119d2baff62SLaszlo Ersek } else if (sys2vcpu) { 2120d2baff62SLaszlo Ersek vcpu->online = (status != '0'); 2121d2baff62SLaszlo Ersek vcpu->can_offline = true; 2122d2baff62SLaszlo Ersek } else if (vcpu->online != (status != '0')) { 2123d2baff62SLaszlo Ersek status = '0' + vcpu->online; 2124d2baff62SLaszlo Ersek if (pwrite(fd, &status, 1, 0) == -1) { 2125d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "pwrite(\"%s/%s\")", dirpath, 2126d2baff62SLaszlo Ersek fn); 2127d2baff62SLaszlo Ersek } 2128d2baff62SLaszlo Ersek } /* otherwise pretend successful re-(on|off)-lining */ 2129d2baff62SLaszlo Ersek 2130d2baff62SLaszlo Ersek res = close(fd); 2131d2baff62SLaszlo Ersek g_assert(res == 0); 2132d2baff62SLaszlo Ersek } 2133d2baff62SLaszlo Ersek 2134d2baff62SLaszlo Ersek res = close(dirfd); 2135d2baff62SLaszlo Ersek g_assert(res == 0); 2136d2baff62SLaszlo Ersek } 2137d2baff62SLaszlo Ersek 2138d2baff62SLaszlo Ersek GuestLogicalProcessorList *qmp_guest_get_vcpus(Error **errp) 2139d2baff62SLaszlo Ersek { 2140d2baff62SLaszlo Ersek int64_t current; 2141d2baff62SLaszlo Ersek GuestLogicalProcessorList *head, **link; 2142d2baff62SLaszlo Ersek long sc_max; 2143d2baff62SLaszlo Ersek Error *local_err = NULL; 2144d2baff62SLaszlo Ersek 2145d2baff62SLaszlo Ersek current = 0; 2146d2baff62SLaszlo Ersek head = NULL; 2147d2baff62SLaszlo Ersek link = &head; 2148d2baff62SLaszlo Ersek sc_max = SYSCONF_EXACT(_SC_NPROCESSORS_CONF, &local_err); 2149d2baff62SLaszlo Ersek 2150d2baff62SLaszlo Ersek while (local_err == NULL && current < sc_max) { 2151d2baff62SLaszlo Ersek GuestLogicalProcessor *vcpu; 2152d2baff62SLaszlo Ersek GuestLogicalProcessorList *entry; 2153b4bf912aSIgor Mammedov int64_t id = current++; 2154b4bf912aSIgor Mammedov char *path = g_strdup_printf("/sys/devices/system/cpu/cpu%" PRId64 "/", 2155b4bf912aSIgor Mammedov id); 2156d2baff62SLaszlo Ersek 2157b4bf912aSIgor Mammedov if (g_file_test(path, G_FILE_TEST_EXISTS)) { 2158d2baff62SLaszlo Ersek vcpu = g_malloc0(sizeof *vcpu); 2159b4bf912aSIgor Mammedov vcpu->logical_id = id; 2160d2baff62SLaszlo Ersek vcpu->has_can_offline = true; /* lolspeak ftw */ 2161b4bf912aSIgor Mammedov transfer_vcpu(vcpu, true, path, &local_err); 2162d2baff62SLaszlo Ersek entry = g_malloc0(sizeof *entry); 2163d2baff62SLaszlo Ersek entry->value = vcpu; 2164d2baff62SLaszlo Ersek *link = entry; 2165d2baff62SLaszlo Ersek link = &entry->next; 2166d2baff62SLaszlo Ersek } 2167b4bf912aSIgor Mammedov g_free(path); 2168b4bf912aSIgor Mammedov } 2169d2baff62SLaszlo Ersek 2170d2baff62SLaszlo Ersek if (local_err == NULL) { 2171d2baff62SLaszlo Ersek /* there's no guest with zero VCPUs */ 2172d2baff62SLaszlo Ersek g_assert(head != NULL); 2173d2baff62SLaszlo Ersek return head; 2174d2baff62SLaszlo Ersek } 2175d2baff62SLaszlo Ersek 2176d2baff62SLaszlo Ersek qapi_free_GuestLogicalProcessorList(head); 2177d2baff62SLaszlo Ersek error_propagate(errp, local_err); 2178d2baff62SLaszlo Ersek return NULL; 2179d2baff62SLaszlo Ersek } 2180d2baff62SLaszlo Ersek 2181cbb65fc2SLaszlo Ersek int64_t qmp_guest_set_vcpus(GuestLogicalProcessorList *vcpus, Error **errp) 2182cbb65fc2SLaszlo Ersek { 2183cbb65fc2SLaszlo Ersek int64_t processed; 2184cbb65fc2SLaszlo Ersek Error *local_err = NULL; 2185cbb65fc2SLaszlo Ersek 2186cbb65fc2SLaszlo Ersek processed = 0; 2187cbb65fc2SLaszlo Ersek while (vcpus != NULL) { 2188b4bf912aSIgor Mammedov char *path = g_strdup_printf("/sys/devices/system/cpu/cpu%" PRId64 "/", 2189b4bf912aSIgor Mammedov vcpus->value->logical_id); 2190b4bf912aSIgor Mammedov 2191b4bf912aSIgor Mammedov transfer_vcpu(vcpus->value, false, path, &local_err); 2192b4bf912aSIgor Mammedov g_free(path); 2193cbb65fc2SLaszlo Ersek if (local_err != NULL) { 2194cbb65fc2SLaszlo Ersek break; 2195cbb65fc2SLaszlo Ersek } 2196cbb65fc2SLaszlo Ersek ++processed; 2197cbb65fc2SLaszlo Ersek vcpus = vcpus->next; 2198cbb65fc2SLaszlo Ersek } 2199cbb65fc2SLaszlo Ersek 2200cbb65fc2SLaszlo Ersek if (local_err != NULL) { 2201cbb65fc2SLaszlo Ersek if (processed == 0) { 2202cbb65fc2SLaszlo Ersek error_propagate(errp, local_err); 2203cbb65fc2SLaszlo Ersek } else { 2204cbb65fc2SLaszlo Ersek error_free(local_err); 2205cbb65fc2SLaszlo Ersek } 2206cbb65fc2SLaszlo Ersek } 2207cbb65fc2SLaszlo Ersek 2208cbb65fc2SLaszlo Ersek return processed; 2209cbb65fc2SLaszlo Ersek } 2210cbb65fc2SLaszlo Ersek 2211215a2771SDaniel P. Berrange void qmp_guest_set_user_password(const char *username, 2212215a2771SDaniel P. Berrange const char *password, 2213215a2771SDaniel P. Berrange bool crypted, 2214215a2771SDaniel P. Berrange Error **errp) 2215215a2771SDaniel P. Berrange { 2216215a2771SDaniel P. Berrange Error *local_err = NULL; 2217215a2771SDaniel P. Berrange char *passwd_path = NULL; 2218215a2771SDaniel P. Berrange pid_t pid; 2219215a2771SDaniel P. Berrange int status; 2220215a2771SDaniel P. Berrange int datafd[2] = { -1, -1 }; 2221215a2771SDaniel P. Berrange char *rawpasswddata = NULL; 2222215a2771SDaniel P. Berrange size_t rawpasswdlen; 2223215a2771SDaniel P. Berrange char *chpasswddata = NULL; 2224215a2771SDaniel P. Berrange size_t chpasswdlen; 2225215a2771SDaniel P. Berrange 2226920639caSDaniel P. Berrange rawpasswddata = (char *)qbase64_decode(password, -1, &rawpasswdlen, errp); 2227920639caSDaniel P. Berrange if (!rawpasswddata) { 2228920639caSDaniel P. Berrange return; 2229920639caSDaniel P. Berrange } 2230215a2771SDaniel P. Berrange rawpasswddata = g_renew(char, rawpasswddata, rawpasswdlen + 1); 2231215a2771SDaniel P. Berrange rawpasswddata[rawpasswdlen] = '\0'; 2232215a2771SDaniel P. Berrange 2233215a2771SDaniel P. Berrange if (strchr(rawpasswddata, '\n')) { 2234215a2771SDaniel P. Berrange error_setg(errp, "forbidden characters in raw password"); 2235215a2771SDaniel P. Berrange goto out; 2236215a2771SDaniel P. Berrange } 2237215a2771SDaniel P. Berrange 2238215a2771SDaniel P. Berrange if (strchr(username, '\n') || 2239215a2771SDaniel P. Berrange strchr(username, ':')) { 2240215a2771SDaniel P. Berrange error_setg(errp, "forbidden characters in username"); 2241215a2771SDaniel P. Berrange goto out; 2242215a2771SDaniel P. Berrange } 2243215a2771SDaniel P. Berrange 2244215a2771SDaniel P. Berrange chpasswddata = g_strdup_printf("%s:%s\n", username, rawpasswddata); 2245215a2771SDaniel P. Berrange chpasswdlen = strlen(chpasswddata); 2246215a2771SDaniel P. Berrange 2247215a2771SDaniel P. Berrange passwd_path = g_find_program_in_path("chpasswd"); 2248215a2771SDaniel P. Berrange 2249215a2771SDaniel P. Berrange if (!passwd_path) { 2250215a2771SDaniel P. Berrange error_setg(errp, "cannot find 'passwd' program in PATH"); 2251215a2771SDaniel P. Berrange goto out; 2252215a2771SDaniel P. Berrange } 2253215a2771SDaniel P. Berrange 2254215a2771SDaniel P. Berrange if (pipe(datafd) < 0) { 2255215a2771SDaniel P. Berrange error_setg(errp, "cannot create pipe FDs"); 2256215a2771SDaniel P. Berrange goto out; 2257215a2771SDaniel P. Berrange } 2258215a2771SDaniel P. Berrange 2259215a2771SDaniel P. Berrange pid = fork(); 2260215a2771SDaniel P. Berrange if (pid == 0) { 2261215a2771SDaniel P. Berrange close(datafd[1]); 2262215a2771SDaniel P. Berrange /* child */ 2263215a2771SDaniel P. Berrange setsid(); 2264215a2771SDaniel P. Berrange dup2(datafd[0], 0); 2265215a2771SDaniel P. Berrange reopen_fd_to_null(1); 2266215a2771SDaniel P. Berrange reopen_fd_to_null(2); 2267215a2771SDaniel P. Berrange 2268215a2771SDaniel P. Berrange if (crypted) { 2269215a2771SDaniel P. Berrange execle(passwd_path, "chpasswd", "-e", NULL, environ); 2270215a2771SDaniel P. Berrange } else { 2271215a2771SDaniel P. Berrange execle(passwd_path, "chpasswd", NULL, environ); 2272215a2771SDaniel P. Berrange } 2273215a2771SDaniel P. Berrange _exit(EXIT_FAILURE); 2274215a2771SDaniel P. Berrange } else if (pid < 0) { 2275215a2771SDaniel P. Berrange error_setg_errno(errp, errno, "failed to create child process"); 2276215a2771SDaniel P. Berrange goto out; 2277215a2771SDaniel P. Berrange } 2278215a2771SDaniel P. Berrange close(datafd[0]); 2279215a2771SDaniel P. Berrange datafd[0] = -1; 2280215a2771SDaniel P. Berrange 2281215a2771SDaniel P. Berrange if (qemu_write_full(datafd[1], chpasswddata, chpasswdlen) != chpasswdlen) { 2282215a2771SDaniel P. Berrange error_setg_errno(errp, errno, "cannot write new account password"); 2283215a2771SDaniel P. Berrange goto out; 2284215a2771SDaniel P. Berrange } 2285215a2771SDaniel P. Berrange close(datafd[1]); 2286215a2771SDaniel P. Berrange datafd[1] = -1; 2287215a2771SDaniel P. Berrange 2288215a2771SDaniel P. Berrange ga_wait_child(pid, &status, &local_err); 2289215a2771SDaniel P. Berrange if (local_err) { 2290215a2771SDaniel P. Berrange error_propagate(errp, local_err); 2291215a2771SDaniel P. Berrange goto out; 2292215a2771SDaniel P. Berrange } 2293215a2771SDaniel P. Berrange 2294215a2771SDaniel P. Berrange if (!WIFEXITED(status)) { 2295215a2771SDaniel P. Berrange error_setg(errp, "child process has terminated abnormally"); 2296215a2771SDaniel P. Berrange goto out; 2297215a2771SDaniel P. Berrange } 2298215a2771SDaniel P. Berrange 2299215a2771SDaniel P. Berrange if (WEXITSTATUS(status)) { 2300215a2771SDaniel P. Berrange error_setg(errp, "child process has failed to set user password"); 2301215a2771SDaniel P. Berrange goto out; 2302215a2771SDaniel P. Berrange } 2303215a2771SDaniel P. Berrange 2304215a2771SDaniel P. Berrange out: 2305215a2771SDaniel P. Berrange g_free(chpasswddata); 2306215a2771SDaniel P. Berrange g_free(rawpasswddata); 2307215a2771SDaniel P. Berrange g_free(passwd_path); 2308215a2771SDaniel P. Berrange if (datafd[0] != -1) { 2309215a2771SDaniel P. Berrange close(datafd[0]); 2310215a2771SDaniel P. Berrange } 2311215a2771SDaniel P. Berrange if (datafd[1] != -1) { 2312215a2771SDaniel P. Berrange close(datafd[1]); 2313215a2771SDaniel P. Berrange } 2314215a2771SDaniel P. Berrange } 2315215a2771SDaniel P. Berrange 2316bd240fcaSzhanghailiang static void ga_read_sysfs_file(int dirfd, const char *pathname, char *buf, 2317bd240fcaSzhanghailiang int size, Error **errp) 2318bd240fcaSzhanghailiang { 2319bd240fcaSzhanghailiang int fd; 2320bd240fcaSzhanghailiang int res; 2321bd240fcaSzhanghailiang 2322bd240fcaSzhanghailiang errno = 0; 2323bd240fcaSzhanghailiang fd = openat(dirfd, pathname, O_RDONLY); 2324bd240fcaSzhanghailiang if (fd == -1) { 2325bd240fcaSzhanghailiang error_setg_errno(errp, errno, "open sysfs file \"%s\"", pathname); 2326bd240fcaSzhanghailiang return; 2327bd240fcaSzhanghailiang } 2328bd240fcaSzhanghailiang 2329bd240fcaSzhanghailiang res = pread(fd, buf, size, 0); 2330bd240fcaSzhanghailiang if (res == -1) { 2331bd240fcaSzhanghailiang error_setg_errno(errp, errno, "pread sysfs file \"%s\"", pathname); 2332bd240fcaSzhanghailiang } else if (res == 0) { 2333bd240fcaSzhanghailiang error_setg(errp, "pread sysfs file \"%s\": unexpected EOF", pathname); 2334bd240fcaSzhanghailiang } 2335bd240fcaSzhanghailiang close(fd); 2336bd240fcaSzhanghailiang } 2337bd240fcaSzhanghailiang 2338bd240fcaSzhanghailiang static void ga_write_sysfs_file(int dirfd, const char *pathname, 2339bd240fcaSzhanghailiang const char *buf, int size, Error **errp) 2340bd240fcaSzhanghailiang { 2341bd240fcaSzhanghailiang int fd; 2342bd240fcaSzhanghailiang 2343bd240fcaSzhanghailiang errno = 0; 2344bd240fcaSzhanghailiang fd = openat(dirfd, pathname, O_WRONLY); 2345bd240fcaSzhanghailiang if (fd == -1) { 2346bd240fcaSzhanghailiang error_setg_errno(errp, errno, "open sysfs file \"%s\"", pathname); 2347bd240fcaSzhanghailiang return; 2348bd240fcaSzhanghailiang } 2349bd240fcaSzhanghailiang 2350bd240fcaSzhanghailiang if (pwrite(fd, buf, size, 0) == -1) { 2351bd240fcaSzhanghailiang error_setg_errno(errp, errno, "pwrite sysfs file \"%s\"", pathname); 2352bd240fcaSzhanghailiang } 2353bd240fcaSzhanghailiang 2354bd240fcaSzhanghailiang close(fd); 2355bd240fcaSzhanghailiang } 2356bd240fcaSzhanghailiang 2357bd240fcaSzhanghailiang /* Transfer online/offline status between @mem_blk and the guest system. 2358bd240fcaSzhanghailiang * 2359bd240fcaSzhanghailiang * On input either @errp or *@errp must be NULL. 2360bd240fcaSzhanghailiang * 2361bd240fcaSzhanghailiang * In system-to-@mem_blk direction, the following @mem_blk fields are accessed: 2362bd240fcaSzhanghailiang * - R: mem_blk->phys_index 2363bd240fcaSzhanghailiang * - W: mem_blk->online 2364bd240fcaSzhanghailiang * - W: mem_blk->can_offline 2365bd240fcaSzhanghailiang * 2366bd240fcaSzhanghailiang * In @mem_blk-to-system direction, the following @mem_blk fields are accessed: 2367bd240fcaSzhanghailiang * - R: mem_blk->phys_index 2368bd240fcaSzhanghailiang * - R: mem_blk->online 2369bd240fcaSzhanghailiang *- R: mem_blk->can_offline 2370bd240fcaSzhanghailiang * Written members remain unmodified on error. 2371bd240fcaSzhanghailiang */ 2372bd240fcaSzhanghailiang static void transfer_memory_block(GuestMemoryBlock *mem_blk, bool sys2memblk, 2373bd240fcaSzhanghailiang GuestMemoryBlockResponse *result, 2374bd240fcaSzhanghailiang Error **errp) 2375bd240fcaSzhanghailiang { 2376bd240fcaSzhanghailiang char *dirpath; 2377bd240fcaSzhanghailiang int dirfd; 2378bd240fcaSzhanghailiang char *status; 2379bd240fcaSzhanghailiang Error *local_err = NULL; 2380bd240fcaSzhanghailiang 2381bd240fcaSzhanghailiang if (!sys2memblk) { 2382bd240fcaSzhanghailiang DIR *dp; 2383bd240fcaSzhanghailiang 2384bd240fcaSzhanghailiang if (!result) { 2385bd240fcaSzhanghailiang error_setg(errp, "Internal error, 'result' should not be NULL"); 2386bd240fcaSzhanghailiang return; 2387bd240fcaSzhanghailiang } 2388bd240fcaSzhanghailiang errno = 0; 2389bd240fcaSzhanghailiang dp = opendir("/sys/devices/system/memory/"); 2390bd240fcaSzhanghailiang /* if there is no 'memory' directory in sysfs, 2391bd240fcaSzhanghailiang * we think this VM does not support online/offline memory block, 2392bd240fcaSzhanghailiang * any other solution? 2393bd240fcaSzhanghailiang */ 23949879f5acSPhilippe Mathieu-Daudé if (!dp) { 23959879f5acSPhilippe Mathieu-Daudé if (errno == ENOENT) { 2396bd240fcaSzhanghailiang result->response = 2397bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_NOT_SUPPORTED; 23989879f5acSPhilippe Mathieu-Daudé } 2399bd240fcaSzhanghailiang goto out1; 2400bd240fcaSzhanghailiang } 2401bd240fcaSzhanghailiang closedir(dp); 2402bd240fcaSzhanghailiang } 2403bd240fcaSzhanghailiang 2404bd240fcaSzhanghailiang dirpath = g_strdup_printf("/sys/devices/system/memory/memory%" PRId64 "/", 2405bd240fcaSzhanghailiang mem_blk->phys_index); 2406bd240fcaSzhanghailiang dirfd = open(dirpath, O_RDONLY | O_DIRECTORY); 2407bd240fcaSzhanghailiang if (dirfd == -1) { 2408bd240fcaSzhanghailiang if (sys2memblk) { 2409bd240fcaSzhanghailiang error_setg_errno(errp, errno, "open(\"%s\")", dirpath); 2410bd240fcaSzhanghailiang } else { 2411bd240fcaSzhanghailiang if (errno == ENOENT) { 2412bd240fcaSzhanghailiang result->response = GUEST_MEMORY_BLOCK_RESPONSE_TYPE_NOT_FOUND; 2413bd240fcaSzhanghailiang } else { 2414bd240fcaSzhanghailiang result->response = 2415bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_FAILED; 2416bd240fcaSzhanghailiang } 2417bd240fcaSzhanghailiang } 2418bd240fcaSzhanghailiang g_free(dirpath); 2419bd240fcaSzhanghailiang goto out1; 2420bd240fcaSzhanghailiang } 2421bd240fcaSzhanghailiang g_free(dirpath); 2422bd240fcaSzhanghailiang 2423bd240fcaSzhanghailiang status = g_malloc0(10); 2424bd240fcaSzhanghailiang ga_read_sysfs_file(dirfd, "state", status, 10, &local_err); 2425bd240fcaSzhanghailiang if (local_err) { 2426bd240fcaSzhanghailiang /* treat with sysfs file that not exist in old kernel */ 2427bd240fcaSzhanghailiang if (errno == ENOENT) { 2428bd240fcaSzhanghailiang error_free(local_err); 2429bd240fcaSzhanghailiang if (sys2memblk) { 2430bd240fcaSzhanghailiang mem_blk->online = true; 2431bd240fcaSzhanghailiang mem_blk->can_offline = false; 2432bd240fcaSzhanghailiang } else if (!mem_blk->online) { 2433bd240fcaSzhanghailiang result->response = 2434bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_NOT_SUPPORTED; 2435bd240fcaSzhanghailiang } 2436bd240fcaSzhanghailiang } else { 2437bd240fcaSzhanghailiang if (sys2memblk) { 2438bd240fcaSzhanghailiang error_propagate(errp, local_err); 2439bd240fcaSzhanghailiang } else { 2440bd240fcaSzhanghailiang result->response = 2441bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_FAILED; 2442bd240fcaSzhanghailiang } 2443bd240fcaSzhanghailiang } 2444bd240fcaSzhanghailiang goto out2; 2445bd240fcaSzhanghailiang } 2446bd240fcaSzhanghailiang 2447bd240fcaSzhanghailiang if (sys2memblk) { 2448bd240fcaSzhanghailiang char removable = '0'; 2449bd240fcaSzhanghailiang 2450bd240fcaSzhanghailiang mem_blk->online = (strncmp(status, "online", 6) == 0); 2451bd240fcaSzhanghailiang 2452bd240fcaSzhanghailiang ga_read_sysfs_file(dirfd, "removable", &removable, 1, &local_err); 2453bd240fcaSzhanghailiang if (local_err) { 245467cc32ebSVeres Lajos /* if no 'removable' file, it doesn't support offline mem blk */ 2455bd240fcaSzhanghailiang if (errno == ENOENT) { 2456bd240fcaSzhanghailiang error_free(local_err); 2457bd240fcaSzhanghailiang mem_blk->can_offline = false; 2458bd240fcaSzhanghailiang } else { 2459bd240fcaSzhanghailiang error_propagate(errp, local_err); 2460bd240fcaSzhanghailiang } 2461bd240fcaSzhanghailiang } else { 2462bd240fcaSzhanghailiang mem_blk->can_offline = (removable != '0'); 2463bd240fcaSzhanghailiang } 2464bd240fcaSzhanghailiang } else { 2465bd240fcaSzhanghailiang if (mem_blk->online != (strncmp(status, "online", 6) == 0)) { 24667064024dSMarc-André Lureau const char *new_state = mem_blk->online ? "online" : "offline"; 2467bd240fcaSzhanghailiang 2468bd240fcaSzhanghailiang ga_write_sysfs_file(dirfd, "state", new_state, strlen(new_state), 2469bd240fcaSzhanghailiang &local_err); 2470bd240fcaSzhanghailiang if (local_err) { 2471bd240fcaSzhanghailiang error_free(local_err); 2472bd240fcaSzhanghailiang result->response = 2473bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_FAILED; 2474bd240fcaSzhanghailiang goto out2; 2475bd240fcaSzhanghailiang } 2476bd240fcaSzhanghailiang 2477bd240fcaSzhanghailiang result->response = GUEST_MEMORY_BLOCK_RESPONSE_TYPE_SUCCESS; 2478bd240fcaSzhanghailiang result->has_error_code = false; 2479bd240fcaSzhanghailiang } /* otherwise pretend successful re-(on|off)-lining */ 2480bd240fcaSzhanghailiang } 2481bd240fcaSzhanghailiang g_free(status); 2482bd240fcaSzhanghailiang close(dirfd); 2483bd240fcaSzhanghailiang return; 2484bd240fcaSzhanghailiang 2485bd240fcaSzhanghailiang out2: 2486bd240fcaSzhanghailiang g_free(status); 2487bd240fcaSzhanghailiang close(dirfd); 2488bd240fcaSzhanghailiang out1: 2489bd240fcaSzhanghailiang if (!sys2memblk) { 2490bd240fcaSzhanghailiang result->has_error_code = true; 2491bd240fcaSzhanghailiang result->error_code = errno; 2492bd240fcaSzhanghailiang } 2493bd240fcaSzhanghailiang } 2494bd240fcaSzhanghailiang 2495a065aaa9Szhanghailiang GuestMemoryBlockList *qmp_guest_get_memory_blocks(Error **errp) 2496a065aaa9Szhanghailiang { 2497bd240fcaSzhanghailiang GuestMemoryBlockList *head, **link; 2498bd240fcaSzhanghailiang Error *local_err = NULL; 2499bd240fcaSzhanghailiang struct dirent *de; 2500bd240fcaSzhanghailiang DIR *dp; 2501bd240fcaSzhanghailiang 2502bd240fcaSzhanghailiang head = NULL; 2503bd240fcaSzhanghailiang link = &head; 2504bd240fcaSzhanghailiang 2505bd240fcaSzhanghailiang dp = opendir("/sys/devices/system/memory/"); 2506bd240fcaSzhanghailiang if (!dp) { 2507f693fe6eSMichael Roth /* it's ok if this happens to be a system that doesn't expose 2508f693fe6eSMichael Roth * memory blocks via sysfs, but otherwise we should report 2509f693fe6eSMichael Roth * an error 2510f693fe6eSMichael Roth */ 2511f693fe6eSMichael Roth if (errno != ENOENT) { 2512bd240fcaSzhanghailiang error_setg_errno(errp, errno, "Can't open directory" 25139af9e0feSMarkus Armbruster "\"/sys/devices/system/memory/\""); 2514f693fe6eSMichael Roth } 2515bd240fcaSzhanghailiang return NULL; 2516bd240fcaSzhanghailiang } 2517bd240fcaSzhanghailiang 2518bd240fcaSzhanghailiang /* Note: the phys_index of memory block may be discontinuous, 2519bd240fcaSzhanghailiang * this is because a memblk is the unit of the Sparse Memory design, which 2520bd240fcaSzhanghailiang * allows discontinuous memory ranges (ex. NUMA), so here we should 2521bd240fcaSzhanghailiang * traverse the memory block directory. 2522bd240fcaSzhanghailiang */ 2523bd240fcaSzhanghailiang while ((de = readdir(dp)) != NULL) { 2524bd240fcaSzhanghailiang GuestMemoryBlock *mem_blk; 2525bd240fcaSzhanghailiang GuestMemoryBlockList *entry; 2526bd240fcaSzhanghailiang 2527bd240fcaSzhanghailiang if ((strncmp(de->d_name, "memory", 6) != 0) || 2528bd240fcaSzhanghailiang !(de->d_type & DT_DIR)) { 2529bd240fcaSzhanghailiang continue; 2530bd240fcaSzhanghailiang } 2531bd240fcaSzhanghailiang 2532bd240fcaSzhanghailiang mem_blk = g_malloc0(sizeof *mem_blk); 2533bd240fcaSzhanghailiang /* The d_name is "memoryXXX", phys_index is block id, same as XXX */ 2534bd240fcaSzhanghailiang mem_blk->phys_index = strtoul(&de->d_name[6], NULL, 10); 2535bd240fcaSzhanghailiang mem_blk->has_can_offline = true; /* lolspeak ftw */ 2536bd240fcaSzhanghailiang transfer_memory_block(mem_blk, true, NULL, &local_err); 2537bd240fcaSzhanghailiang 2538bd240fcaSzhanghailiang entry = g_malloc0(sizeof *entry); 2539bd240fcaSzhanghailiang entry->value = mem_blk; 2540bd240fcaSzhanghailiang 2541bd240fcaSzhanghailiang *link = entry; 2542bd240fcaSzhanghailiang link = &entry->next; 2543bd240fcaSzhanghailiang } 2544bd240fcaSzhanghailiang 2545bd240fcaSzhanghailiang closedir(dp); 2546bd240fcaSzhanghailiang if (local_err == NULL) { 2547bd240fcaSzhanghailiang /* there's no guest with zero memory blocks */ 2548bd240fcaSzhanghailiang if (head == NULL) { 2549bd240fcaSzhanghailiang error_setg(errp, "guest reported zero memory blocks!"); 2550bd240fcaSzhanghailiang } 2551bd240fcaSzhanghailiang return head; 2552bd240fcaSzhanghailiang } 2553bd240fcaSzhanghailiang 2554bd240fcaSzhanghailiang qapi_free_GuestMemoryBlockList(head); 2555bd240fcaSzhanghailiang error_propagate(errp, local_err); 2556a065aaa9Szhanghailiang return NULL; 2557a065aaa9Szhanghailiang } 2558a065aaa9Szhanghailiang 2559a065aaa9Szhanghailiang GuestMemoryBlockResponseList * 2560a065aaa9Szhanghailiang qmp_guest_set_memory_blocks(GuestMemoryBlockList *mem_blks, Error **errp) 2561a065aaa9Szhanghailiang { 256232ca7927Szhanghailiang GuestMemoryBlockResponseList *head, **link; 256332ca7927Szhanghailiang Error *local_err = NULL; 256432ca7927Szhanghailiang 256532ca7927Szhanghailiang head = NULL; 256632ca7927Szhanghailiang link = &head; 256732ca7927Szhanghailiang 256832ca7927Szhanghailiang while (mem_blks != NULL) { 256932ca7927Szhanghailiang GuestMemoryBlockResponse *result; 257032ca7927Szhanghailiang GuestMemoryBlockResponseList *entry; 257132ca7927Szhanghailiang GuestMemoryBlock *current_mem_blk = mem_blks->value; 257232ca7927Szhanghailiang 257332ca7927Szhanghailiang result = g_malloc0(sizeof(*result)); 257432ca7927Szhanghailiang result->phys_index = current_mem_blk->phys_index; 257532ca7927Szhanghailiang transfer_memory_block(current_mem_blk, false, result, &local_err); 257632ca7927Szhanghailiang if (local_err) { /* should never happen */ 257732ca7927Szhanghailiang goto err; 257832ca7927Szhanghailiang } 257932ca7927Szhanghailiang entry = g_malloc0(sizeof *entry); 258032ca7927Szhanghailiang entry->value = result; 258132ca7927Szhanghailiang 258232ca7927Szhanghailiang *link = entry; 258332ca7927Szhanghailiang link = &entry->next; 258432ca7927Szhanghailiang mem_blks = mem_blks->next; 258532ca7927Szhanghailiang } 258632ca7927Szhanghailiang 258732ca7927Szhanghailiang return head; 258832ca7927Szhanghailiang err: 258932ca7927Szhanghailiang qapi_free_GuestMemoryBlockResponseList(head); 259032ca7927Szhanghailiang error_propagate(errp, local_err); 2591a065aaa9Szhanghailiang return NULL; 2592a065aaa9Szhanghailiang } 2593a065aaa9Szhanghailiang 2594a065aaa9Szhanghailiang GuestMemoryBlockInfo *qmp_guest_get_memory_block_info(Error **errp) 2595a065aaa9Szhanghailiang { 2596ef82b60bSzhanghailiang Error *local_err = NULL; 2597ef82b60bSzhanghailiang char *dirpath; 2598ef82b60bSzhanghailiang int dirfd; 2599ef82b60bSzhanghailiang char *buf; 2600ef82b60bSzhanghailiang GuestMemoryBlockInfo *info; 2601ef82b60bSzhanghailiang 2602ef82b60bSzhanghailiang dirpath = g_strdup_printf("/sys/devices/system/memory/"); 2603ef82b60bSzhanghailiang dirfd = open(dirpath, O_RDONLY | O_DIRECTORY); 2604ef82b60bSzhanghailiang if (dirfd == -1) { 2605ef82b60bSzhanghailiang error_setg_errno(errp, errno, "open(\"%s\")", dirpath); 2606ef82b60bSzhanghailiang g_free(dirpath); 2607a065aaa9Szhanghailiang return NULL; 2608a065aaa9Szhanghailiang } 2609ef82b60bSzhanghailiang g_free(dirpath); 2610ef82b60bSzhanghailiang 2611ef82b60bSzhanghailiang buf = g_malloc0(20); 2612ef82b60bSzhanghailiang ga_read_sysfs_file(dirfd, "block_size_bytes", buf, 20, &local_err); 26138ce1ee46SShannon Zhao close(dirfd); 2614ef82b60bSzhanghailiang if (local_err) { 2615ef82b60bSzhanghailiang g_free(buf); 2616ef82b60bSzhanghailiang error_propagate(errp, local_err); 2617ef82b60bSzhanghailiang return NULL; 2618ef82b60bSzhanghailiang } 2619ef82b60bSzhanghailiang 2620ef82b60bSzhanghailiang info = g_new0(GuestMemoryBlockInfo, 1); 2621ef82b60bSzhanghailiang info->size = strtol(buf, NULL, 16); /* the unit is bytes */ 2622ef82b60bSzhanghailiang 2623ef82b60bSzhanghailiang g_free(buf); 2624ef82b60bSzhanghailiang 2625ef82b60bSzhanghailiang return info; 2626ef82b60bSzhanghailiang } 2627a065aaa9Szhanghailiang 2628e72c3f2eSMichael Roth #else /* defined(__linux__) */ 2629e72c3f2eSMichael Roth 263077dbc81bSMarkus Armbruster void qmp_guest_suspend_disk(Error **errp) 2631e72c3f2eSMichael Roth { 2632c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2633e72c3f2eSMichael Roth } 2634e72c3f2eSMichael Roth 263577dbc81bSMarkus Armbruster void qmp_guest_suspend_ram(Error **errp) 2636e72c3f2eSMichael Roth { 2637c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2638e72c3f2eSMichael Roth } 2639e72c3f2eSMichael Roth 264077dbc81bSMarkus Armbruster void qmp_guest_suspend_hybrid(Error **errp) 2641e72c3f2eSMichael Roth { 2642c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2643e72c3f2eSMichael Roth } 2644e72c3f2eSMichael Roth 2645e72c3f2eSMichael Roth GuestNetworkInterfaceList *qmp_guest_network_get_interfaces(Error **errp) 2646e72c3f2eSMichael Roth { 2647c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2648e72c3f2eSMichael Roth return NULL; 2649e72c3f2eSMichael Roth } 2650e72c3f2eSMichael Roth 2651d2baff62SLaszlo Ersek GuestLogicalProcessorList *qmp_guest_get_vcpus(Error **errp) 2652d2baff62SLaszlo Ersek { 2653c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2654d2baff62SLaszlo Ersek return NULL; 2655d2baff62SLaszlo Ersek } 2656d2baff62SLaszlo Ersek 2657cbb65fc2SLaszlo Ersek int64_t qmp_guest_set_vcpus(GuestLogicalProcessorList *vcpus, Error **errp) 2658cbb65fc2SLaszlo Ersek { 2659c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2660cbb65fc2SLaszlo Ersek return -1; 2661cbb65fc2SLaszlo Ersek } 2662cbb65fc2SLaszlo Ersek 2663215a2771SDaniel P. Berrange void qmp_guest_set_user_password(const char *username, 2664215a2771SDaniel P. Berrange const char *password, 2665215a2771SDaniel P. Berrange bool crypted, 2666215a2771SDaniel P. Berrange Error **errp) 2667215a2771SDaniel P. Berrange { 2668c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2669215a2771SDaniel P. Berrange } 2670215a2771SDaniel P. Berrange 2671a065aaa9Szhanghailiang GuestMemoryBlockList *qmp_guest_get_memory_blocks(Error **errp) 2672a065aaa9Szhanghailiang { 2673c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2674a065aaa9Szhanghailiang return NULL; 2675a065aaa9Szhanghailiang } 2676a065aaa9Szhanghailiang 2677a065aaa9Szhanghailiang GuestMemoryBlockResponseList * 2678a065aaa9Szhanghailiang qmp_guest_set_memory_blocks(GuestMemoryBlockList *mem_blks, Error **errp) 2679a065aaa9Szhanghailiang { 2680c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2681a065aaa9Szhanghailiang return NULL; 2682a065aaa9Szhanghailiang } 2683a065aaa9Szhanghailiang 2684a065aaa9Szhanghailiang GuestMemoryBlockInfo *qmp_guest_get_memory_block_info(Error **errp) 2685a065aaa9Szhanghailiang { 2686c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2687a065aaa9Szhanghailiang return NULL; 2688a065aaa9Szhanghailiang } 2689a065aaa9Szhanghailiang 2690e72c3f2eSMichael Roth #endif 2691e72c3f2eSMichael Roth 2692d35d4cb5SMichael Roth #if !defined(CONFIG_FSFREEZE) 2693d35d4cb5SMichael Roth 269446d4c572STomoki Sekiyama GuestFilesystemInfoList *qmp_guest_get_fsinfo(Error **errp) 269546d4c572STomoki Sekiyama { 2696c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 269746d4c572STomoki Sekiyama return NULL; 269846d4c572STomoki Sekiyama } 269946d4c572STomoki Sekiyama 270077dbc81bSMarkus Armbruster GuestFsfreezeStatus qmp_guest_fsfreeze_status(Error **errp) 2701d35d4cb5SMichael Roth { 2702c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2703d35d4cb5SMichael Roth 2704d35d4cb5SMichael Roth return 0; 2705d35d4cb5SMichael Roth } 2706d35d4cb5SMichael Roth 270777dbc81bSMarkus Armbruster int64_t qmp_guest_fsfreeze_freeze(Error **errp) 2708d35d4cb5SMichael Roth { 2709c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2710d35d4cb5SMichael Roth 2711d35d4cb5SMichael Roth return 0; 2712d35d4cb5SMichael Roth } 2713d35d4cb5SMichael Roth 2714e99bce20STomoki Sekiyama int64_t qmp_guest_fsfreeze_freeze_list(bool has_mountpoints, 2715e99bce20STomoki Sekiyama strList *mountpoints, 2716e99bce20STomoki Sekiyama Error **errp) 2717e99bce20STomoki Sekiyama { 2718c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2719e99bce20STomoki Sekiyama 2720e99bce20STomoki Sekiyama return 0; 2721e99bce20STomoki Sekiyama } 2722e99bce20STomoki Sekiyama 272377dbc81bSMarkus Armbruster int64_t qmp_guest_fsfreeze_thaw(Error **errp) 2724d35d4cb5SMichael Roth { 2725c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2726d35d4cb5SMichael Roth 2727d35d4cb5SMichael Roth return 0; 2728d35d4cb5SMichael Roth } 2729eab5fd59SPaolo Bonzini #endif /* CONFIG_FSFREEZE */ 2730d35d4cb5SMichael Roth 2731eab5fd59SPaolo Bonzini #if !defined(CONFIG_FSTRIM) 2732e82855d9SJustin Ossevoort GuestFilesystemTrimResponse * 2733e82855d9SJustin Ossevoort qmp_guest_fstrim(bool has_minimum, int64_t minimum, Error **errp) 2734eab5fd59SPaolo Bonzini { 2735c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2736e82855d9SJustin Ossevoort return NULL; 2737eab5fd59SPaolo Bonzini } 2738d35d4cb5SMichael Roth #endif 2739d35d4cb5SMichael Roth 27401281c08aSTomoki Sekiyama /* add unsupported commands to the blacklist */ 27411281c08aSTomoki Sekiyama GList *ga_command_blacklist_init(GList *blacklist) 27421281c08aSTomoki Sekiyama { 27431281c08aSTomoki Sekiyama #if !defined(__linux__) 27441281c08aSTomoki Sekiyama { 27451281c08aSTomoki Sekiyama const char *list[] = { 27461281c08aSTomoki Sekiyama "guest-suspend-disk", "guest-suspend-ram", 27471281c08aSTomoki Sekiyama "guest-suspend-hybrid", "guest-network-get-interfaces", 27480dd38a03Szhanghailiang "guest-get-vcpus", "guest-set-vcpus", 27490dd38a03Szhanghailiang "guest-get-memory-blocks", "guest-set-memory-blocks", 275028d8dd35SBasil Salman "guest-get-memory-block-size", "guest-get-memory-block-info", 275128d8dd35SBasil Salman NULL}; 27521281c08aSTomoki Sekiyama char **p = (char **)list; 27531281c08aSTomoki Sekiyama 27541281c08aSTomoki Sekiyama while (*p) { 27554bca81ceSMarc-André Lureau blacklist = g_list_append(blacklist, g_strdup(*p++)); 27561281c08aSTomoki Sekiyama } 27571281c08aSTomoki Sekiyama } 27581281c08aSTomoki Sekiyama #endif 27591281c08aSTomoki Sekiyama 27601281c08aSTomoki Sekiyama #if !defined(CONFIG_FSFREEZE) 27611281c08aSTomoki Sekiyama { 27621281c08aSTomoki Sekiyama const char *list[] = { 27631281c08aSTomoki Sekiyama "guest-get-fsinfo", "guest-fsfreeze-status", 27641281c08aSTomoki Sekiyama "guest-fsfreeze-freeze", "guest-fsfreeze-freeze-list", 27651281c08aSTomoki Sekiyama "guest-fsfreeze-thaw", "guest-get-fsinfo", NULL}; 27661281c08aSTomoki Sekiyama char **p = (char **)list; 27671281c08aSTomoki Sekiyama 27681281c08aSTomoki Sekiyama while (*p) { 27694bca81ceSMarc-André Lureau blacklist = g_list_append(blacklist, g_strdup(*p++)); 27701281c08aSTomoki Sekiyama } 27711281c08aSTomoki Sekiyama } 27721281c08aSTomoki Sekiyama #endif 27731281c08aSTomoki Sekiyama 27741281c08aSTomoki Sekiyama #if !defined(CONFIG_FSTRIM) 27754bca81ceSMarc-André Lureau blacklist = g_list_append(blacklist, g_strdup("guest-fstrim")); 27761281c08aSTomoki Sekiyama #endif 27771281c08aSTomoki Sekiyama 27781281c08aSTomoki Sekiyama return blacklist; 27791281c08aSTomoki Sekiyama } 27801281c08aSTomoki Sekiyama 2781c216e5adSMichael Roth /* register init/cleanup routines for stateful command groups */ 2782c216e5adSMichael Roth void ga_command_state_init(GAState *s, GACommandState *cs) 2783c216e5adSMichael Roth { 2784c216e5adSMichael Roth #if defined(CONFIG_FSFREEZE) 2785f22d85e9SMichael Roth ga_command_state_add(cs, NULL, guest_fsfreeze_cleanup); 2786c216e5adSMichael Roth #endif 2787c216e5adSMichael Roth } 2788161a56a9SVinzenz Feenstra 2789e674605fSTomáš Golembiovský #ifdef HAVE_UTMPX 2790e674605fSTomáš Golembiovský 2791161a56a9SVinzenz Feenstra #define QGA_MICRO_SECOND_TO_SECOND 1000000 2792161a56a9SVinzenz Feenstra 2793161a56a9SVinzenz Feenstra static double ga_get_login_time(struct utmpx *user_info) 2794161a56a9SVinzenz Feenstra { 2795161a56a9SVinzenz Feenstra double seconds = (double)user_info->ut_tv.tv_sec; 2796161a56a9SVinzenz Feenstra double useconds = (double)user_info->ut_tv.tv_usec; 2797161a56a9SVinzenz Feenstra useconds /= QGA_MICRO_SECOND_TO_SECOND; 2798161a56a9SVinzenz Feenstra return seconds + useconds; 2799161a56a9SVinzenz Feenstra } 2800161a56a9SVinzenz Feenstra 2801b90abbacSVladimir Sementsov-Ogievskiy GuestUserList *qmp_guest_get_users(Error **errp) 2802161a56a9SVinzenz Feenstra { 2803161a56a9SVinzenz Feenstra GHashTable *cache = NULL; 2804161a56a9SVinzenz Feenstra GuestUserList *head = NULL, *cur_item = NULL; 2805161a56a9SVinzenz Feenstra struct utmpx *user_info = NULL; 2806161a56a9SVinzenz Feenstra gpointer value = NULL; 2807161a56a9SVinzenz Feenstra GuestUser *user = NULL; 2808161a56a9SVinzenz Feenstra GuestUserList *item = NULL; 2809161a56a9SVinzenz Feenstra double login_time = 0; 2810161a56a9SVinzenz Feenstra 2811161a56a9SVinzenz Feenstra cache = g_hash_table_new(g_str_hash, g_str_equal); 2812161a56a9SVinzenz Feenstra setutxent(); 2813161a56a9SVinzenz Feenstra 2814161a56a9SVinzenz Feenstra for (;;) { 2815161a56a9SVinzenz Feenstra user_info = getutxent(); 2816161a56a9SVinzenz Feenstra if (user_info == NULL) { 2817161a56a9SVinzenz Feenstra break; 2818161a56a9SVinzenz Feenstra } else if (user_info->ut_type != USER_PROCESS) { 2819161a56a9SVinzenz Feenstra continue; 2820161a56a9SVinzenz Feenstra } else if (g_hash_table_contains(cache, user_info->ut_user)) { 2821161a56a9SVinzenz Feenstra value = g_hash_table_lookup(cache, user_info->ut_user); 2822161a56a9SVinzenz Feenstra user = (GuestUser *)value; 2823161a56a9SVinzenz Feenstra login_time = ga_get_login_time(user_info); 2824161a56a9SVinzenz Feenstra /* We're ensuring the earliest login time to be sent */ 2825161a56a9SVinzenz Feenstra if (login_time < user->login_time) { 2826161a56a9SVinzenz Feenstra user->login_time = login_time; 2827161a56a9SVinzenz Feenstra } 2828161a56a9SVinzenz Feenstra continue; 2829161a56a9SVinzenz Feenstra } 2830161a56a9SVinzenz Feenstra 2831161a56a9SVinzenz Feenstra item = g_new0(GuestUserList, 1); 2832161a56a9SVinzenz Feenstra item->value = g_new0(GuestUser, 1); 2833161a56a9SVinzenz Feenstra item->value->user = g_strdup(user_info->ut_user); 2834161a56a9SVinzenz Feenstra item->value->login_time = ga_get_login_time(user_info); 2835161a56a9SVinzenz Feenstra 2836161a56a9SVinzenz Feenstra g_hash_table_insert(cache, item->value->user, item->value); 2837161a56a9SVinzenz Feenstra 2838161a56a9SVinzenz Feenstra if (!cur_item) { 2839161a56a9SVinzenz Feenstra head = cur_item = item; 2840161a56a9SVinzenz Feenstra } else { 2841161a56a9SVinzenz Feenstra cur_item->next = item; 2842161a56a9SVinzenz Feenstra cur_item = item; 2843161a56a9SVinzenz Feenstra } 2844161a56a9SVinzenz Feenstra } 2845161a56a9SVinzenz Feenstra endutxent(); 2846161a56a9SVinzenz Feenstra g_hash_table_destroy(cache); 2847161a56a9SVinzenz Feenstra return head; 2848161a56a9SVinzenz Feenstra } 2849e674605fSTomáš Golembiovský 2850e674605fSTomáš Golembiovský #else 2851e674605fSTomáš Golembiovský 2852e674605fSTomáš Golembiovský GuestUserList *qmp_guest_get_users(Error **errp) 2853e674605fSTomáš Golembiovský { 2854e674605fSTomáš Golembiovský error_setg(errp, QERR_UNSUPPORTED); 2855e674605fSTomáš Golembiovský return NULL; 2856e674605fSTomáš Golembiovský } 2857e674605fSTomáš Golembiovský 2858e674605fSTomáš Golembiovský #endif 28599848f797STomáš Golembiovský 28609848f797STomáš Golembiovský /* Replace escaped special characters with theire real values. The replacement 28619848f797STomáš Golembiovský * is done in place -- returned value is in the original string. 28629848f797STomáš Golembiovský */ 28639848f797STomáš Golembiovský static void ga_osrelease_replace_special(gchar *value) 28649848f797STomáš Golembiovský { 28659848f797STomáš Golembiovský gchar *p, *p2, quote; 28669848f797STomáš Golembiovský 28679848f797STomáš Golembiovský /* Trim the string at first space or semicolon if it is not enclosed in 28689848f797STomáš Golembiovský * single or double quotes. */ 28699848f797STomáš Golembiovský if ((value[0] != '"') || (value[0] == '\'')) { 28709848f797STomáš Golembiovský p = strchr(value, ' '); 28719848f797STomáš Golembiovský if (p != NULL) { 28729848f797STomáš Golembiovský *p = 0; 28739848f797STomáš Golembiovský } 28749848f797STomáš Golembiovský p = strchr(value, ';'); 28759848f797STomáš Golembiovský if (p != NULL) { 28769848f797STomáš Golembiovský *p = 0; 28779848f797STomáš Golembiovský } 28789848f797STomáš Golembiovský return; 28799848f797STomáš Golembiovský } 28809848f797STomáš Golembiovský 28819848f797STomáš Golembiovský quote = value[0]; 28829848f797STomáš Golembiovský p2 = value; 28839848f797STomáš Golembiovský p = value + 1; 28849848f797STomáš Golembiovský while (*p != 0) { 28859848f797STomáš Golembiovský if (*p == '\\') { 28869848f797STomáš Golembiovský p++; 28879848f797STomáš Golembiovský switch (*p) { 28889848f797STomáš Golembiovský case '$': 28899848f797STomáš Golembiovský case '\'': 28909848f797STomáš Golembiovský case '"': 28919848f797STomáš Golembiovský case '\\': 28929848f797STomáš Golembiovský case '`': 28939848f797STomáš Golembiovský break; 28949848f797STomáš Golembiovský default: 28959848f797STomáš Golembiovský /* Keep literal backslash followed by whatever is there */ 28969848f797STomáš Golembiovský p--; 28979848f797STomáš Golembiovský break; 28989848f797STomáš Golembiovský } 28999848f797STomáš Golembiovský } else if (*p == quote) { 29009848f797STomáš Golembiovský *p2 = 0; 29019848f797STomáš Golembiovský break; 29029848f797STomáš Golembiovský } 29039848f797STomáš Golembiovský *(p2++) = *(p++); 29049848f797STomáš Golembiovský } 29059848f797STomáš Golembiovský } 29069848f797STomáš Golembiovský 29079848f797STomáš Golembiovský static GKeyFile *ga_parse_osrelease(const char *fname) 29089848f797STomáš Golembiovský { 29099848f797STomáš Golembiovský gchar *content = NULL; 29109848f797STomáš Golembiovský gchar *content2 = NULL; 29119848f797STomáš Golembiovský GError *err = NULL; 29129848f797STomáš Golembiovský GKeyFile *keys = g_key_file_new(); 29139848f797STomáš Golembiovský const char *group = "[os-release]\n"; 29149848f797STomáš Golembiovský 29159848f797STomáš Golembiovský if (!g_file_get_contents(fname, &content, NULL, &err)) { 29169848f797STomáš Golembiovský slog("failed to read '%s', error: %s", fname, err->message); 29179848f797STomáš Golembiovský goto fail; 29189848f797STomáš Golembiovský } 29199848f797STomáš Golembiovský 29209848f797STomáš Golembiovský if (!g_utf8_validate(content, -1, NULL)) { 29219848f797STomáš Golembiovský slog("file is not utf-8 encoded: %s", fname); 29229848f797STomáš Golembiovský goto fail; 29239848f797STomáš Golembiovský } 29249848f797STomáš Golembiovský content2 = g_strdup_printf("%s%s", group, content); 29259848f797STomáš Golembiovský 29269848f797STomáš Golembiovský if (!g_key_file_load_from_data(keys, content2, -1, G_KEY_FILE_NONE, 29279848f797STomáš Golembiovský &err)) { 29289848f797STomáš Golembiovský slog("failed to parse file '%s', error: %s", fname, err->message); 29299848f797STomáš Golembiovský goto fail; 29309848f797STomáš Golembiovský } 29319848f797STomáš Golembiovský 29329848f797STomáš Golembiovský g_free(content); 29339848f797STomáš Golembiovský g_free(content2); 29349848f797STomáš Golembiovský return keys; 29359848f797STomáš Golembiovský 29369848f797STomáš Golembiovský fail: 29379848f797STomáš Golembiovský g_error_free(err); 29389848f797STomáš Golembiovský g_free(content); 29399848f797STomáš Golembiovský g_free(content2); 29409848f797STomáš Golembiovský g_key_file_free(keys); 29419848f797STomáš Golembiovský return NULL; 29429848f797STomáš Golembiovský } 29439848f797STomáš Golembiovský 29449848f797STomáš Golembiovský GuestOSInfo *qmp_guest_get_osinfo(Error **errp) 29459848f797STomáš Golembiovský { 29469848f797STomáš Golembiovský GuestOSInfo *info = NULL; 29479848f797STomáš Golembiovský struct utsname kinfo; 2948339ca68bSTomáš Golembiovský GKeyFile *osrelease = NULL; 2949339ca68bSTomáš Golembiovský const char *qga_os_release = g_getenv("QGA_OS_RELEASE"); 29509848f797STomáš Golembiovský 29519848f797STomáš Golembiovský info = g_new0(GuestOSInfo, 1); 29529848f797STomáš Golembiovský 29539848f797STomáš Golembiovský if (uname(&kinfo) != 0) { 29549848f797STomáš Golembiovský error_setg_errno(errp, errno, "uname failed"); 29559848f797STomáš Golembiovský } else { 29569848f797STomáš Golembiovský info->has_kernel_version = true; 29579848f797STomáš Golembiovský info->kernel_version = g_strdup(kinfo.version); 29589848f797STomáš Golembiovský info->has_kernel_release = true; 29599848f797STomáš Golembiovský info->kernel_release = g_strdup(kinfo.release); 29609848f797STomáš Golembiovský info->has_machine = true; 29619848f797STomáš Golembiovský info->machine = g_strdup(kinfo.machine); 29629848f797STomáš Golembiovský } 29639848f797STomáš Golembiovský 2964339ca68bSTomáš Golembiovský if (qga_os_release != NULL) { 2965339ca68bSTomáš Golembiovský osrelease = ga_parse_osrelease(qga_os_release); 2966339ca68bSTomáš Golembiovský } else { 29679848f797STomáš Golembiovský osrelease = ga_parse_osrelease("/etc/os-release"); 29689848f797STomáš Golembiovský if (osrelease == NULL) { 29699848f797STomáš Golembiovský osrelease = ga_parse_osrelease("/usr/lib/os-release"); 29709848f797STomáš Golembiovský } 2971339ca68bSTomáš Golembiovský } 29729848f797STomáš Golembiovský 29739848f797STomáš Golembiovský if (osrelease != NULL) { 29749848f797STomáš Golembiovský char *value; 29759848f797STomáš Golembiovský 29769848f797STomáš Golembiovský #define GET_FIELD(field, osfield) do { \ 29779848f797STomáš Golembiovský value = g_key_file_get_value(osrelease, "os-release", osfield, NULL); \ 29789848f797STomáš Golembiovský if (value != NULL) { \ 29799848f797STomáš Golembiovský ga_osrelease_replace_special(value); \ 29809848f797STomáš Golembiovský info->has_ ## field = true; \ 29819848f797STomáš Golembiovský info->field = value; \ 29829848f797STomáš Golembiovský } \ 29839848f797STomáš Golembiovský } while (0) 29849848f797STomáš Golembiovský GET_FIELD(id, "ID"); 29859848f797STomáš Golembiovský GET_FIELD(name, "NAME"); 29869848f797STomáš Golembiovský GET_FIELD(pretty_name, "PRETTY_NAME"); 29879848f797STomáš Golembiovský GET_FIELD(version, "VERSION"); 29889848f797STomáš Golembiovský GET_FIELD(version_id, "VERSION_ID"); 29899848f797STomáš Golembiovský GET_FIELD(variant, "VARIANT"); 29909848f797STomáš Golembiovský GET_FIELD(variant_id, "VARIANT_ID"); 29919848f797STomáš Golembiovský #undef GET_FIELD 29929848f797STomáš Golembiovský 29939848f797STomáš Golembiovský g_key_file_free(osrelease); 29949848f797STomáš Golembiovský } 29959848f797STomáš Golembiovský 29969848f797STomáš Golembiovský return info; 29979848f797STomáš Golembiovský } 2998