1c216e5adSMichael Roth /* 2c216e5adSMichael Roth * QEMU Guest Agent POSIX-specific command implementations 3c216e5adSMichael Roth * 4c216e5adSMichael Roth * Copyright IBM Corp. 2011 5c216e5adSMichael Roth * 6c216e5adSMichael Roth * Authors: 7c216e5adSMichael Roth * Michael Roth <mdroth@linux.vnet.ibm.com> 83424fc9fSMichal Privoznik * Michal Privoznik <mprivozn@redhat.com> 9c216e5adSMichael Roth * 10c216e5adSMichael Roth * This work is licensed under the terms of the GNU GPL, version 2 or later. 11c216e5adSMichael Roth * See the COPYING file in the top-level directory. 12c216e5adSMichael Roth */ 13c216e5adSMichael Roth 144459bf38SPeter Maydell #include "qemu/osdep.h" 15c216e5adSMichael Roth #include <sys/ioctl.h> 169848f797STomáš Golembiovský #include <sys/utsname.h> 172c02cbf6SLuiz Capitulino #include <sys/wait.h> 1846d4c572STomoki Sekiyama #include <dirent.h> 19dc03272dSMichael S. Tsirkin #include "guest-agent-core.h" 20eb815e24SMarkus Armbruster #include "qga-qapi-commands.h" 21e688df6bSMarkus Armbruster #include "qapi/error.h" 227b1b5d19SPaolo Bonzini #include "qapi/qmp/qerror.h" 231de7afc9SPaolo Bonzini #include "qemu/queue.h" 241de7afc9SPaolo Bonzini #include "qemu/host-utils.h" 2512505396SDenis V. Lunev #include "qemu/sockets.h" 26920639caSDaniel P. Berrange #include "qemu/base64.h" 27f348b6d1SVeronia Bahaa #include "qemu/cutils.h" 285d3586b8SPhilippe Mathieu-Daudé #include "commands-common.h" 29c216e5adSMichael Roth 30e674605fSTomáš Golembiovský #ifdef HAVE_UTMPX 31e674605fSTomáš Golembiovský #include <utmpx.h> 32e674605fSTomáš Golembiovský #endif 33e674605fSTomáš Golembiovský 34e72c3f2eSMichael Roth #if defined(__linux__) 35e72c3f2eSMichael Roth #include <mntent.h> 36e72c3f2eSMichael Roth #include <linux/fs.h> 3725b5ff1aSChen Hanxiao #include <sys/statvfs.h> 38e72c3f2eSMichael Roth 39b616105aSTomáš Golembiovský #ifdef CONFIG_LIBUDEV 40b616105aSTomáš Golembiovský #include <libudev.h> 41b616105aSTomáš Golembiovský #endif 42b616105aSTomáš Golembiovský 43eab5fd59SPaolo Bonzini #ifdef FIFREEZE 44e72c3f2eSMichael Roth #define CONFIG_FSFREEZE 45e72c3f2eSMichael Roth #endif 46eab5fd59SPaolo Bonzini #ifdef FITRIM 47eab5fd59SPaolo Bonzini #define CONFIG_FSTRIM 48eab5fd59SPaolo Bonzini #endif 49e72c3f2eSMichael Roth #endif 50e72c3f2eSMichael Roth 51*59e35c7bSAndrew Deason #ifdef HAVE_GETIFADDRS 52*59e35c7bSAndrew Deason #include <arpa/inet.h> 53*59e35c7bSAndrew Deason #include <sys/socket.h> 54*59e35c7bSAndrew Deason #include <net/if.h> 55*59e35c7bSAndrew Deason #include <sys/types.h> 56*59e35c7bSAndrew Deason #include <ifaddrs.h> 57*59e35c7bSAndrew Deason #ifdef CONFIG_SOLARIS 58*59e35c7bSAndrew Deason #include <sys/sockio.h> 59*59e35c7bSAndrew Deason #endif 60*59e35c7bSAndrew Deason #endif 61*59e35c7bSAndrew Deason 6277dbc81bSMarkus Armbruster static void ga_wait_child(pid_t pid, int *status, Error **errp) 63d220a6dfSLuiz Capitulino { 64d220a6dfSLuiz Capitulino pid_t rpid; 65d220a6dfSLuiz Capitulino 66d220a6dfSLuiz Capitulino *status = 0; 67d220a6dfSLuiz Capitulino 68d220a6dfSLuiz Capitulino do { 69d220a6dfSLuiz Capitulino rpid = waitpid(pid, status, 0); 70d220a6dfSLuiz Capitulino } while (rpid == -1 && errno == EINTR); 71d220a6dfSLuiz Capitulino 72d220a6dfSLuiz Capitulino if (rpid == -1) { 7377dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to wait for child (pid: %d)", 7477dbc81bSMarkus Armbruster pid); 75d220a6dfSLuiz Capitulino return; 76d220a6dfSLuiz Capitulino } 77d220a6dfSLuiz Capitulino 78d220a6dfSLuiz Capitulino g_assert(rpid == pid); 79d220a6dfSLuiz Capitulino } 80d220a6dfSLuiz Capitulino 8177dbc81bSMarkus Armbruster void qmp_guest_shutdown(bool has_mode, const char *mode, Error **errp) 82c216e5adSMichael Roth { 83c216e5adSMichael Roth const char *shutdown_flag; 84d220a6dfSLuiz Capitulino Error *local_err = NULL; 85d220a6dfSLuiz Capitulino pid_t pid; 863674838cSLuiz Capitulino int status; 87c216e5adSMichael Roth 88c216e5adSMichael Roth slog("guest-shutdown called, mode: %s", mode); 89c216e5adSMichael Roth if (!has_mode || strcmp(mode, "powerdown") == 0) { 90c216e5adSMichael Roth shutdown_flag = "-P"; 91c216e5adSMichael Roth } else if (strcmp(mode, "halt") == 0) { 92c216e5adSMichael Roth shutdown_flag = "-H"; 93c216e5adSMichael Roth } else if (strcmp(mode, "reboot") == 0) { 94c216e5adSMichael Roth shutdown_flag = "-r"; 95c216e5adSMichael Roth } else { 9677dbc81bSMarkus Armbruster error_setg(errp, 97d220a6dfSLuiz Capitulino "mode is invalid (valid values are: halt|powerdown|reboot"); 98c216e5adSMichael Roth return; 99c216e5adSMichael Roth } 100c216e5adSMichael Roth 101d5dd3498SLuiz Capitulino pid = fork(); 102d5dd3498SLuiz Capitulino if (pid == 0) { 103c216e5adSMichael Roth /* child, start the shutdown */ 104c216e5adSMichael Roth setsid(); 1053674838cSLuiz Capitulino reopen_fd_to_null(0); 1063674838cSLuiz Capitulino reopen_fd_to_null(1); 1073674838cSLuiz Capitulino reopen_fd_to_null(2); 108c216e5adSMichael Roth 109fcc41961SMarc-André Lureau execl("/sbin/shutdown", "shutdown", "-h", shutdown_flag, "+0", 110fcc41961SMarc-André Lureau "hypervisor initiated shutdown", (char *)NULL); 1113674838cSLuiz Capitulino _exit(EXIT_FAILURE); 112d5dd3498SLuiz Capitulino } else if (pid < 0) { 11377dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to create child process"); 114d5dd3498SLuiz Capitulino return; 115d5dd3498SLuiz Capitulino } 116d5dd3498SLuiz Capitulino 117d220a6dfSLuiz Capitulino ga_wait_child(pid, &status, &local_err); 11884d18f06SMarkus Armbruster if (local_err) { 11977dbc81bSMarkus Armbruster error_propagate(errp, local_err); 120d220a6dfSLuiz Capitulino return; 121d220a6dfSLuiz Capitulino } 122d220a6dfSLuiz Capitulino 123d220a6dfSLuiz Capitulino if (!WIFEXITED(status)) { 12477dbc81bSMarkus Armbruster error_setg(errp, "child process has terminated abnormally"); 125d220a6dfSLuiz Capitulino return; 126d220a6dfSLuiz Capitulino } 127d220a6dfSLuiz Capitulino 128d220a6dfSLuiz Capitulino if (WEXITSTATUS(status)) { 12977dbc81bSMarkus Armbruster error_setg(errp, "child process has failed to shutdown"); 130d220a6dfSLuiz Capitulino return; 131d220a6dfSLuiz Capitulino } 132d220a6dfSLuiz Capitulino 133085d8134SPeter Maydell /* succeeded */ 134c216e5adSMichael Roth } 135c216e5adSMichael Roth 1362c958923SMichal Privoznik void qmp_guest_set_time(bool has_time, int64_t time_ns, Error **errp) 137a1bca57fSLei Li { 138a1bca57fSLei Li int ret; 139a1bca57fSLei Li int status; 140a1bca57fSLei Li pid_t pid; 141a1bca57fSLei Li Error *local_err = NULL; 142a1bca57fSLei Li struct timeval tv; 1435c6096e5SCornelia Huck static const char hwclock_path[] = "/sbin/hwclock"; 1445c6096e5SCornelia Huck static int hwclock_available = -1; 1455c6096e5SCornelia Huck 1465c6096e5SCornelia Huck if (hwclock_available < 0) { 1475c6096e5SCornelia Huck hwclock_available = (access(hwclock_path, X_OK) == 0); 1485c6096e5SCornelia Huck } 1495c6096e5SCornelia Huck 1505c6096e5SCornelia Huck if (!hwclock_available) { 1515c6096e5SCornelia Huck error_setg(errp, QERR_UNSUPPORTED); 1525c6096e5SCornelia Huck return; 1535c6096e5SCornelia Huck } 154a1bca57fSLei Li 1552c958923SMichal Privoznik /* If user has passed a time, validate and set it. */ 1562c958923SMichal Privoznik if (has_time) { 15700d2f370SMarc-André Lureau GDate date = { 0, }; 15800d2f370SMarc-André Lureau 159a1bca57fSLei Li /* year-2038 will overflow in case time_t is 32bit */ 160a1bca57fSLei Li if (time_ns / 1000000000 != (time_t)(time_ns / 1000000000)) { 161a1bca57fSLei Li error_setg(errp, "Time %" PRId64 " is too large", time_ns); 162a1bca57fSLei Li return; 163a1bca57fSLei Li } 164a1bca57fSLei Li 165a1bca57fSLei Li tv.tv_sec = time_ns / 1000000000; 166a1bca57fSLei Li tv.tv_usec = (time_ns % 1000000000) / 1000; 16700d2f370SMarc-André Lureau g_date_set_time_t(&date, tv.tv_sec); 16800d2f370SMarc-André Lureau if (date.year < 1970 || date.year >= 2070) { 16900d2f370SMarc-André Lureau error_setg_errno(errp, errno, "Invalid time"); 17000d2f370SMarc-André Lureau return; 17100d2f370SMarc-André Lureau } 172a1bca57fSLei Li 173a1bca57fSLei Li ret = settimeofday(&tv, NULL); 174a1bca57fSLei Li if (ret < 0) { 175a1bca57fSLei Li error_setg_errno(errp, errno, "Failed to set time to guest"); 176a1bca57fSLei Li return; 177a1bca57fSLei Li } 1782c958923SMichal Privoznik } 179a1bca57fSLei Li 1802c958923SMichal Privoznik /* Now, if user has passed a time to set and the system time is set, we 1812c958923SMichal Privoznik * just need to synchronize the hardware clock. However, if no time was 1822c958923SMichal Privoznik * passed, user is requesting the opposite: set the system time from the 1831634df56SAmos Kong * hardware clock (RTC). */ 184a1bca57fSLei Li pid = fork(); 185a1bca57fSLei Li if (pid == 0) { 186a1bca57fSLei Li setsid(); 187a1bca57fSLei Li reopen_fd_to_null(0); 188a1bca57fSLei Li reopen_fd_to_null(1); 189a1bca57fSLei Li reopen_fd_to_null(2); 190a1bca57fSLei Li 1912c958923SMichal Privoznik /* Use '/sbin/hwclock -w' to set RTC from the system time, 1922c958923SMichal Privoznik * or '/sbin/hwclock -s' to set the system time from RTC. */ 193fcc41961SMarc-André Lureau execl(hwclock_path, "hwclock", has_time ? "-w" : "-s", NULL); 194a1bca57fSLei Li _exit(EXIT_FAILURE); 195a1bca57fSLei Li } else if (pid < 0) { 196a1bca57fSLei Li error_setg_errno(errp, errno, "failed to create child process"); 197a1bca57fSLei Li return; 198a1bca57fSLei Li } 199a1bca57fSLei Li 200a1bca57fSLei Li ga_wait_child(pid, &status, &local_err); 20184d18f06SMarkus Armbruster if (local_err) { 202a1bca57fSLei Li error_propagate(errp, local_err); 203a1bca57fSLei Li return; 204a1bca57fSLei Li } 205a1bca57fSLei Li 206a1bca57fSLei Li if (!WIFEXITED(status)) { 207a1bca57fSLei Li error_setg(errp, "child process has terminated abnormally"); 208a1bca57fSLei Li return; 209a1bca57fSLei Li } 210a1bca57fSLei Li 211a1bca57fSLei Li if (WEXITSTATUS(status)) { 212a1bca57fSLei Li error_setg(errp, "hwclock failed to set hardware clock to system time"); 213a1bca57fSLei Li return; 214a1bca57fSLei Li } 215a1bca57fSLei Li } 216a1bca57fSLei Li 217895b00f6SMarc-André Lureau typedef enum { 218895b00f6SMarc-André Lureau RW_STATE_NEW, 219895b00f6SMarc-André Lureau RW_STATE_READING, 220895b00f6SMarc-André Lureau RW_STATE_WRITING, 221895b00f6SMarc-André Lureau } RwState; 222895b00f6SMarc-André Lureau 2235d3586b8SPhilippe Mathieu-Daudé struct GuestFileHandle { 224c216e5adSMichael Roth uint64_t id; 225c216e5adSMichael Roth FILE *fh; 226895b00f6SMarc-André Lureau RwState state; 227c216e5adSMichael Roth QTAILQ_ENTRY(GuestFileHandle) next; 2285d3586b8SPhilippe Mathieu-Daudé }; 229c216e5adSMichael Roth 230c216e5adSMichael Roth static struct { 231c216e5adSMichael Roth QTAILQ_HEAD(, GuestFileHandle) filehandles; 232b4fe97c8SDenis V. Lunev } guest_file_state = { 233b4fe97c8SDenis V. Lunev .filehandles = QTAILQ_HEAD_INITIALIZER(guest_file_state.filehandles), 234b4fe97c8SDenis V. Lunev }; 235c216e5adSMichael Roth 23639097dafSMichael Roth static int64_t guest_file_handle_add(FILE *fh, Error **errp) 237c216e5adSMichael Roth { 238c216e5adSMichael Roth GuestFileHandle *gfh; 23939097dafSMichael Roth int64_t handle; 24039097dafSMichael Roth 24139097dafSMichael Roth handle = ga_get_fd_handle(ga_state, errp); 242a903f40cSMarkus Armbruster if (handle < 0) { 243a903f40cSMarkus Armbruster return -1; 24439097dafSMichael Roth } 245c216e5adSMichael Roth 246f3a06403SMarkus Armbruster gfh = g_new0(GuestFileHandle, 1); 24739097dafSMichael Roth gfh->id = handle; 248c216e5adSMichael Roth gfh->fh = fh; 249c216e5adSMichael Roth QTAILQ_INSERT_TAIL(&guest_file_state.filehandles, gfh, next); 25039097dafSMichael Roth 25139097dafSMichael Roth return handle; 252c216e5adSMichael Roth } 253c216e5adSMichael Roth 2545d3586b8SPhilippe Mathieu-Daudé GuestFileHandle *guest_file_handle_find(int64_t id, Error **errp) 255c216e5adSMichael Roth { 256c216e5adSMichael Roth GuestFileHandle *gfh; 257c216e5adSMichael Roth 258c216e5adSMichael Roth QTAILQ_FOREACH(gfh, &guest_file_state.filehandles, next) 259c216e5adSMichael Roth { 260c216e5adSMichael Roth if (gfh->id == id) { 261c216e5adSMichael Roth return gfh; 262c216e5adSMichael Roth } 263c216e5adSMichael Roth } 264c216e5adSMichael Roth 26577dbc81bSMarkus Armbruster error_setg(errp, "handle '%" PRId64 "' has not been found", id); 266c216e5adSMichael Roth return NULL; 267c216e5adSMichael Roth } 268c216e5adSMichael Roth 269c689b4f1SLaszlo Ersek typedef const char * const ccpc; 270c689b4f1SLaszlo Ersek 2718fe6bbcaSLaszlo Ersek #ifndef O_BINARY 2728fe6bbcaSLaszlo Ersek #define O_BINARY 0 2738fe6bbcaSLaszlo Ersek #endif 2748fe6bbcaSLaszlo Ersek 275c689b4f1SLaszlo Ersek /* http://pubs.opengroup.org/onlinepubs/9699919799/functions/fopen.html */ 276c689b4f1SLaszlo Ersek static const struct { 277c689b4f1SLaszlo Ersek ccpc *forms; 278c689b4f1SLaszlo Ersek int oflag_base; 279c689b4f1SLaszlo Ersek } guest_file_open_modes[] = { 2808fe6bbcaSLaszlo Ersek { (ccpc[]){ "r", NULL }, O_RDONLY }, 2818fe6bbcaSLaszlo Ersek { (ccpc[]){ "rb", NULL }, O_RDONLY | O_BINARY }, 2828fe6bbcaSLaszlo Ersek { (ccpc[]){ "w", NULL }, O_WRONLY | O_CREAT | O_TRUNC }, 2838fe6bbcaSLaszlo Ersek { (ccpc[]){ "wb", NULL }, O_WRONLY | O_CREAT | O_TRUNC | O_BINARY }, 2848fe6bbcaSLaszlo Ersek { (ccpc[]){ "a", NULL }, O_WRONLY | O_CREAT | O_APPEND }, 2858fe6bbcaSLaszlo Ersek { (ccpc[]){ "ab", NULL }, O_WRONLY | O_CREAT | O_APPEND | O_BINARY }, 2868fe6bbcaSLaszlo Ersek { (ccpc[]){ "r+", NULL }, O_RDWR }, 2878fe6bbcaSLaszlo Ersek { (ccpc[]){ "rb+", "r+b", NULL }, O_RDWR | O_BINARY }, 2888fe6bbcaSLaszlo Ersek { (ccpc[]){ "w+", NULL }, O_RDWR | O_CREAT | O_TRUNC }, 2898fe6bbcaSLaszlo Ersek { (ccpc[]){ "wb+", "w+b", NULL }, O_RDWR | O_CREAT | O_TRUNC | O_BINARY }, 2908fe6bbcaSLaszlo Ersek { (ccpc[]){ "a+", NULL }, O_RDWR | O_CREAT | O_APPEND }, 2918fe6bbcaSLaszlo Ersek { (ccpc[]){ "ab+", "a+b", NULL }, O_RDWR | O_CREAT | O_APPEND | O_BINARY } 292c689b4f1SLaszlo Ersek }; 293c689b4f1SLaszlo Ersek 294c689b4f1SLaszlo Ersek static int 29577dbc81bSMarkus Armbruster find_open_flag(const char *mode_str, Error **errp) 296c689b4f1SLaszlo Ersek { 297c689b4f1SLaszlo Ersek unsigned mode; 298c689b4f1SLaszlo Ersek 299c689b4f1SLaszlo Ersek for (mode = 0; mode < ARRAY_SIZE(guest_file_open_modes); ++mode) { 300c689b4f1SLaszlo Ersek ccpc *form; 301c689b4f1SLaszlo Ersek 302c689b4f1SLaszlo Ersek form = guest_file_open_modes[mode].forms; 303c689b4f1SLaszlo Ersek while (*form != NULL && strcmp(*form, mode_str) != 0) { 304c689b4f1SLaszlo Ersek ++form; 305c689b4f1SLaszlo Ersek } 306c689b4f1SLaszlo Ersek if (*form != NULL) { 307c689b4f1SLaszlo Ersek break; 308c689b4f1SLaszlo Ersek } 309c689b4f1SLaszlo Ersek } 310c689b4f1SLaszlo Ersek 311c689b4f1SLaszlo Ersek if (mode == ARRAY_SIZE(guest_file_open_modes)) { 31277dbc81bSMarkus Armbruster error_setg(errp, "invalid file open mode '%s'", mode_str); 313c689b4f1SLaszlo Ersek return -1; 314c689b4f1SLaszlo Ersek } 315c689b4f1SLaszlo Ersek return guest_file_open_modes[mode].oflag_base | O_NOCTTY | O_NONBLOCK; 316c689b4f1SLaszlo Ersek } 317c689b4f1SLaszlo Ersek 318c689b4f1SLaszlo Ersek #define DEFAULT_NEW_FILE_MODE (S_IRUSR | S_IWUSR | \ 319c689b4f1SLaszlo Ersek S_IRGRP | S_IWGRP | \ 320c689b4f1SLaszlo Ersek S_IROTH | S_IWOTH) 321c689b4f1SLaszlo Ersek 322c689b4f1SLaszlo Ersek static FILE * 32377dbc81bSMarkus Armbruster safe_open_or_create(const char *path, const char *mode, Error **errp) 324c689b4f1SLaszlo Ersek { 325c689b4f1SLaszlo Ersek Error *local_err = NULL; 326c689b4f1SLaszlo Ersek int oflag; 327c689b4f1SLaszlo Ersek 328c689b4f1SLaszlo Ersek oflag = find_open_flag(mode, &local_err); 329c689b4f1SLaszlo Ersek if (local_err == NULL) { 330c689b4f1SLaszlo Ersek int fd; 331c689b4f1SLaszlo Ersek 332c689b4f1SLaszlo Ersek /* If the caller wants / allows creation of a new file, we implement it 333c689b4f1SLaszlo Ersek * with a two step process: open() + (open() / fchmod()). 334c689b4f1SLaszlo Ersek * 335c689b4f1SLaszlo Ersek * First we insist on creating the file exclusively as a new file. If 336c689b4f1SLaszlo Ersek * that succeeds, we're free to set any file-mode bits on it. (The 337c689b4f1SLaszlo Ersek * motivation is that we want to set those file-mode bits independently 338c689b4f1SLaszlo Ersek * of the current umask.) 339c689b4f1SLaszlo Ersek * 340c689b4f1SLaszlo Ersek * If the exclusive creation fails because the file already exists 341c689b4f1SLaszlo Ersek * (EEXIST is not possible for any other reason), we just attempt to 342c689b4f1SLaszlo Ersek * open the file, but in this case we won't be allowed to change the 343c689b4f1SLaszlo Ersek * file-mode bits on the preexistent file. 344c689b4f1SLaszlo Ersek * 345c689b4f1SLaszlo Ersek * The pathname should never disappear between the two open()s in 346c689b4f1SLaszlo Ersek * practice. If it happens, then someone very likely tried to race us. 347c689b4f1SLaszlo Ersek * In this case just go ahead and report the ENOENT from the second 348c689b4f1SLaszlo Ersek * open() to the caller. 349c689b4f1SLaszlo Ersek * 350c689b4f1SLaszlo Ersek * If the caller wants to open a preexistent file, then the first 351c689b4f1SLaszlo Ersek * open() is decisive and its third argument is ignored, and the second 352c689b4f1SLaszlo Ersek * open() and the fchmod() are never called. 353c689b4f1SLaszlo Ersek */ 354c689b4f1SLaszlo Ersek fd = open(path, oflag | ((oflag & O_CREAT) ? O_EXCL : 0), 0); 355c689b4f1SLaszlo Ersek if (fd == -1 && errno == EEXIST) { 356c689b4f1SLaszlo Ersek oflag &= ~(unsigned)O_CREAT; 357c689b4f1SLaszlo Ersek fd = open(path, oflag); 358c689b4f1SLaszlo Ersek } 359c689b4f1SLaszlo Ersek 360c689b4f1SLaszlo Ersek if (fd == -1) { 361c689b4f1SLaszlo Ersek error_setg_errno(&local_err, errno, "failed to open file '%s' " 362c689b4f1SLaszlo Ersek "(mode: '%s')", path, mode); 363c689b4f1SLaszlo Ersek } else { 364c689b4f1SLaszlo Ersek qemu_set_cloexec(fd); 365c689b4f1SLaszlo Ersek 366c689b4f1SLaszlo Ersek if ((oflag & O_CREAT) && fchmod(fd, DEFAULT_NEW_FILE_MODE) == -1) { 367c689b4f1SLaszlo Ersek error_setg_errno(&local_err, errno, "failed to set permission " 368c689b4f1SLaszlo Ersek "0%03o on new file '%s' (mode: '%s')", 369c689b4f1SLaszlo Ersek (unsigned)DEFAULT_NEW_FILE_MODE, path, mode); 370c689b4f1SLaszlo Ersek } else { 371c689b4f1SLaszlo Ersek FILE *f; 372c689b4f1SLaszlo Ersek 373c689b4f1SLaszlo Ersek f = fdopen(fd, mode); 374c689b4f1SLaszlo Ersek if (f == NULL) { 375c689b4f1SLaszlo Ersek error_setg_errno(&local_err, errno, "failed to associate " 376c689b4f1SLaszlo Ersek "stdio stream with file descriptor %d, " 377c689b4f1SLaszlo Ersek "file '%s' (mode: '%s')", fd, path, mode); 378c689b4f1SLaszlo Ersek } else { 379c689b4f1SLaszlo Ersek return f; 380c689b4f1SLaszlo Ersek } 381c689b4f1SLaszlo Ersek } 382c689b4f1SLaszlo Ersek 383c689b4f1SLaszlo Ersek close(fd); 3842b720018SLaszlo Ersek if (oflag & O_CREAT) { 3852b720018SLaszlo Ersek unlink(path); 3862b720018SLaszlo Ersek } 387c689b4f1SLaszlo Ersek } 388c689b4f1SLaszlo Ersek } 389c689b4f1SLaszlo Ersek 39077dbc81bSMarkus Armbruster error_propagate(errp, local_err); 391c689b4f1SLaszlo Ersek return NULL; 392c689b4f1SLaszlo Ersek } 393c689b4f1SLaszlo Ersek 39477dbc81bSMarkus Armbruster int64_t qmp_guest_file_open(const char *path, bool has_mode, const char *mode, 39577dbc81bSMarkus Armbruster Error **errp) 396c216e5adSMichael Roth { 397c216e5adSMichael Roth FILE *fh; 398c689b4f1SLaszlo Ersek Error *local_err = NULL; 39985b6f6f5SSimon Zolin int64_t handle; 400c216e5adSMichael Roth 401c216e5adSMichael Roth if (!has_mode) { 402c216e5adSMichael Roth mode = "r"; 403c216e5adSMichael Roth } 404c216e5adSMichael Roth slog("guest-file-open called, filepath: %s, mode: %s", path, mode); 405c689b4f1SLaszlo Ersek fh = safe_open_or_create(path, mode, &local_err); 406c689b4f1SLaszlo Ersek if (local_err != NULL) { 40777dbc81bSMarkus Armbruster error_propagate(errp, local_err); 408c216e5adSMichael Roth return -1; 409c216e5adSMichael Roth } 410c216e5adSMichael Roth 411c216e5adSMichael Roth /* set fd non-blocking to avoid common use cases (like reading from a 412c216e5adSMichael Roth * named pipe) from hanging the agent 413c216e5adSMichael Roth */ 414b0a8f9adSMarc-André Lureau if (!g_unix_set_fd_nonblocking(fileno(fh), true, NULL)) { 415b0a8f9adSMarc-André Lureau fclose(fh); 416b0a8f9adSMarc-André Lureau error_setg_errno(errp, errno, "Failed to set FD nonblocking"); 417b0a8f9adSMarc-André Lureau return -1; 418b0a8f9adSMarc-André Lureau } 419c216e5adSMichael Roth 42077dbc81bSMarkus Armbruster handle = guest_file_handle_add(fh, errp); 421a903f40cSMarkus Armbruster if (handle < 0) { 42239097dafSMichael Roth fclose(fh); 42339097dafSMichael Roth return -1; 42439097dafSMichael Roth } 42539097dafSMichael Roth 426d607a523SStefan Weil slog("guest-file-open, handle: %" PRId64, handle); 42739097dafSMichael Roth return handle; 428c216e5adSMichael Roth } 429c216e5adSMichael Roth 43077dbc81bSMarkus Armbruster void qmp_guest_file_close(int64_t handle, Error **errp) 431c216e5adSMichael Roth { 43277dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 433c216e5adSMichael Roth int ret; 434c216e5adSMichael Roth 435d607a523SStefan Weil slog("guest-file-close called, handle: %" PRId64, handle); 436c216e5adSMichael Roth if (!gfh) { 437c216e5adSMichael Roth return; 438c216e5adSMichael Roth } 439c216e5adSMichael Roth 440c216e5adSMichael Roth ret = fclose(gfh->fh); 4413ac4b7c5SLuiz Capitulino if (ret == EOF) { 44277dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to close handle"); 443c216e5adSMichael Roth return; 444c216e5adSMichael Roth } 445c216e5adSMichael Roth 446c216e5adSMichael Roth QTAILQ_REMOVE(&guest_file_state.filehandles, gfh, next); 447c216e5adSMichael Roth g_free(gfh); 448c216e5adSMichael Roth } 449c216e5adSMichael Roth 450ead83a13SPhilippe Mathieu-Daudé GuestFileRead *guest_file_read_unsafe(GuestFileHandle *gfh, 45177dbc81bSMarkus Armbruster int64_t count, Error **errp) 452c216e5adSMichael Roth { 453c216e5adSMichael Roth GuestFileRead *read_data = NULL; 454c216e5adSMichael Roth guchar *buf; 455ead83a13SPhilippe Mathieu-Daudé FILE *fh = gfh->fh; 456c216e5adSMichael Roth size_t read_count; 457c216e5adSMichael Roth 458895b00f6SMarc-André Lureau /* explicitly flush when switching from writing to reading */ 459895b00f6SMarc-André Lureau if (gfh->state == RW_STATE_WRITING) { 460895b00f6SMarc-André Lureau int ret = fflush(fh); 461895b00f6SMarc-André Lureau if (ret == EOF) { 462895b00f6SMarc-André Lureau error_setg_errno(errp, errno, "failed to flush file"); 463895b00f6SMarc-André Lureau return NULL; 464895b00f6SMarc-André Lureau } 465895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 466895b00f6SMarc-André Lureau } 467895b00f6SMarc-André Lureau 468c216e5adSMichael Roth buf = g_malloc0(count + 1); 469c216e5adSMichael Roth read_count = fread(buf, 1, count, fh); 470c216e5adSMichael Roth if (ferror(fh)) { 47177dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to read file"); 472c216e5adSMichael Roth } else { 473c216e5adSMichael Roth buf[read_count] = 0; 474f3a06403SMarkus Armbruster read_data = g_new0(GuestFileRead, 1); 475c216e5adSMichael Roth read_data->count = read_count; 476c216e5adSMichael Roth read_data->eof = feof(fh); 477c216e5adSMichael Roth if (read_count) { 478c216e5adSMichael Roth read_data->buf_b64 = g_base64_encode(buf, read_count); 479c216e5adSMichael Roth } 480895b00f6SMarc-André Lureau gfh->state = RW_STATE_READING; 481c216e5adSMichael Roth } 482c216e5adSMichael Roth g_free(buf); 483c216e5adSMichael Roth clearerr(fh); 484c216e5adSMichael Roth 485c216e5adSMichael Roth return read_data; 486c216e5adSMichael Roth } 487c216e5adSMichael Roth 488c216e5adSMichael Roth GuestFileWrite *qmp_guest_file_write(int64_t handle, const char *buf_b64, 48977dbc81bSMarkus Armbruster bool has_count, int64_t count, 49077dbc81bSMarkus Armbruster Error **errp) 491c216e5adSMichael Roth { 492c216e5adSMichael Roth GuestFileWrite *write_data = NULL; 493c216e5adSMichael Roth guchar *buf; 494c216e5adSMichael Roth gsize buf_len; 495c216e5adSMichael Roth int write_count; 49677dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 497c216e5adSMichael Roth FILE *fh; 498c216e5adSMichael Roth 499c216e5adSMichael Roth if (!gfh) { 500c216e5adSMichael Roth return NULL; 501c216e5adSMichael Roth } 502c216e5adSMichael Roth 503c216e5adSMichael Roth fh = gfh->fh; 504895b00f6SMarc-André Lureau 505895b00f6SMarc-André Lureau if (gfh->state == RW_STATE_READING) { 506895b00f6SMarc-André Lureau int ret = fseek(fh, 0, SEEK_CUR); 507895b00f6SMarc-André Lureau if (ret == -1) { 508895b00f6SMarc-André Lureau error_setg_errno(errp, errno, "failed to seek file"); 509895b00f6SMarc-André Lureau return NULL; 510895b00f6SMarc-André Lureau } 511895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 512895b00f6SMarc-André Lureau } 513895b00f6SMarc-André Lureau 514920639caSDaniel P. Berrange buf = qbase64_decode(buf_b64, -1, &buf_len, errp); 515920639caSDaniel P. Berrange if (!buf) { 516920639caSDaniel P. Berrange return NULL; 517920639caSDaniel P. Berrange } 518c216e5adSMichael Roth 519c216e5adSMichael Roth if (!has_count) { 520c216e5adSMichael Roth count = buf_len; 521c216e5adSMichael Roth } else if (count < 0 || count > buf_len) { 52277dbc81bSMarkus Armbruster error_setg(errp, "value '%" PRId64 "' is invalid for argument count", 523db3edb66SLuiz Capitulino count); 524c216e5adSMichael Roth g_free(buf); 525c216e5adSMichael Roth return NULL; 526c216e5adSMichael Roth } 527c216e5adSMichael Roth 528c216e5adSMichael Roth write_count = fwrite(buf, 1, count, fh); 529c216e5adSMichael Roth if (ferror(fh)) { 53077dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to write to file"); 531d607a523SStefan Weil slog("guest-file-write failed, handle: %" PRId64, handle); 532c216e5adSMichael Roth } else { 533f3a06403SMarkus Armbruster write_data = g_new0(GuestFileWrite, 1); 534c216e5adSMichael Roth write_data->count = write_count; 535c216e5adSMichael Roth write_data->eof = feof(fh); 536895b00f6SMarc-André Lureau gfh->state = RW_STATE_WRITING; 537c216e5adSMichael Roth } 538c216e5adSMichael Roth g_free(buf); 539c216e5adSMichael Roth clearerr(fh); 540c216e5adSMichael Roth 541c216e5adSMichael Roth return write_data; 542c216e5adSMichael Roth } 543c216e5adSMichael Roth 544c216e5adSMichael Roth struct GuestFileSeek *qmp_guest_file_seek(int64_t handle, int64_t offset, 5450b4b4938SEric Blake GuestFileWhence *whence_code, 5460b4b4938SEric Blake Error **errp) 547c216e5adSMichael Roth { 54877dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 549c216e5adSMichael Roth GuestFileSeek *seek_data = NULL; 550c216e5adSMichael Roth FILE *fh; 551c216e5adSMichael Roth int ret; 5520a982b1bSEric Blake int whence; 5530b4b4938SEric Blake Error *err = NULL; 554c216e5adSMichael Roth 555c216e5adSMichael Roth if (!gfh) { 556c216e5adSMichael Roth return NULL; 557c216e5adSMichael Roth } 558c216e5adSMichael Roth 5590a982b1bSEric Blake /* We stupidly exposed 'whence':'int' in our qapi */ 5600b4b4938SEric Blake whence = ga_parse_whence(whence_code, &err); 5610b4b4938SEric Blake if (err) { 5620b4b4938SEric Blake error_propagate(errp, err); 5630a982b1bSEric Blake return NULL; 5640a982b1bSEric Blake } 5650a982b1bSEric Blake 566c216e5adSMichael Roth fh = gfh->fh; 567c216e5adSMichael Roth ret = fseek(fh, offset, whence); 568c216e5adSMichael Roth if (ret == -1) { 56977dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to seek file"); 570895b00f6SMarc-André Lureau if (errno == ESPIPE) { 571895b00f6SMarc-André Lureau /* file is non-seekable, stdio shouldn't be buffering anyways */ 572895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 573895b00f6SMarc-André Lureau } 574c216e5adSMichael Roth } else { 57510b7c5ddSMarkus Armbruster seek_data = g_new0(GuestFileSeek, 1); 576c216e5adSMichael Roth seek_data->position = ftell(fh); 577c216e5adSMichael Roth seek_data->eof = feof(fh); 578895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 579c216e5adSMichael Roth } 580c216e5adSMichael Roth clearerr(fh); 581c216e5adSMichael Roth 582c216e5adSMichael Roth return seek_data; 583c216e5adSMichael Roth } 584c216e5adSMichael Roth 58577dbc81bSMarkus Armbruster void qmp_guest_file_flush(int64_t handle, Error **errp) 586c216e5adSMichael Roth { 58777dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 588c216e5adSMichael Roth FILE *fh; 589c216e5adSMichael Roth int ret; 590c216e5adSMichael Roth 591c216e5adSMichael Roth if (!gfh) { 592c216e5adSMichael Roth return; 593c216e5adSMichael Roth } 594c216e5adSMichael Roth 595c216e5adSMichael Roth fh = gfh->fh; 596c216e5adSMichael Roth ret = fflush(fh); 597c216e5adSMichael Roth if (ret == EOF) { 59877dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to flush file"); 599895b00f6SMarc-André Lureau } else { 600895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 601c216e5adSMichael Roth } 602c216e5adSMichael Roth } 603c216e5adSMichael Roth 604e72c3f2eSMichael Roth /* linux-specific implementations. avoid this if at all possible. */ 605e72c3f2eSMichael Roth #if defined(__linux__) 606e72c3f2eSMichael Roth 607eab5fd59SPaolo Bonzini #if defined(CONFIG_FSFREEZE) || defined(CONFIG_FSTRIM) 608af02203fSPaolo Bonzini typedef struct FsMount { 609c216e5adSMichael Roth char *dirname; 610c216e5adSMichael Roth char *devtype; 61146d4c572STomoki Sekiyama unsigned int devmajor, devminor; 612af02203fSPaolo Bonzini QTAILQ_ENTRY(FsMount) next; 613af02203fSPaolo Bonzini } FsMount; 614c216e5adSMichael Roth 615e5d9adbdSTomoki Sekiyama typedef QTAILQ_HEAD(FsMountList, FsMount) FsMountList; 6169e8aded4SMichael Roth 617af02203fSPaolo Bonzini static void free_fs_mount_list(FsMountList *mounts) 618c216e5adSMichael Roth { 619af02203fSPaolo Bonzini FsMount *mount, *temp; 620c216e5adSMichael Roth 6219e8aded4SMichael Roth if (!mounts) { 6229e8aded4SMichael Roth return; 6239e8aded4SMichael Roth } 6249e8aded4SMichael Roth 6259e8aded4SMichael Roth QTAILQ_FOREACH_SAFE(mount, mounts, next, temp) { 6269e8aded4SMichael Roth QTAILQ_REMOVE(mounts, mount, next); 627c216e5adSMichael Roth g_free(mount->dirname); 628c216e5adSMichael Roth g_free(mount->devtype); 629c216e5adSMichael Roth g_free(mount); 630c216e5adSMichael Roth } 6319e8aded4SMichael Roth } 6329e8aded4SMichael Roth 63346d4c572STomoki Sekiyama static int dev_major_minor(const char *devpath, 63446d4c572STomoki Sekiyama unsigned int *devmajor, unsigned int *devminor) 63546d4c572STomoki Sekiyama { 63646d4c572STomoki Sekiyama struct stat st; 63746d4c572STomoki Sekiyama 63846d4c572STomoki Sekiyama *devmajor = 0; 63946d4c572STomoki Sekiyama *devminor = 0; 64046d4c572STomoki Sekiyama 64146d4c572STomoki Sekiyama if (stat(devpath, &st) < 0) { 64246d4c572STomoki Sekiyama slog("failed to stat device file '%s': %s", devpath, strerror(errno)); 64346d4c572STomoki Sekiyama return -1; 64446d4c572STomoki Sekiyama } 64546d4c572STomoki Sekiyama if (S_ISDIR(st.st_mode)) { 64646d4c572STomoki Sekiyama /* It is bind mount */ 64746d4c572STomoki Sekiyama return -2; 64846d4c572STomoki Sekiyama } 64946d4c572STomoki Sekiyama if (S_ISBLK(st.st_mode)) { 65046d4c572STomoki Sekiyama *devmajor = major(st.st_rdev); 65146d4c572STomoki Sekiyama *devminor = minor(st.st_rdev); 65246d4c572STomoki Sekiyama return 0; 65346d4c572STomoki Sekiyama } 65446d4c572STomoki Sekiyama return -1; 65546d4c572STomoki Sekiyama } 65646d4c572STomoki Sekiyama 6579e8aded4SMichael Roth /* 6589e8aded4SMichael Roth * Walk the mount table and build a list of local file systems 6599e8aded4SMichael Roth */ 66046d4c572STomoki Sekiyama static void build_fs_mount_list_from_mtab(FsMountList *mounts, Error **errp) 6619e8aded4SMichael Roth { 6629e8aded4SMichael Roth struct mntent *ment; 663af02203fSPaolo Bonzini FsMount *mount; 6649e2fa418SMichael Roth char const *mtab = "/proc/self/mounts"; 6659e8aded4SMichael Roth FILE *fp; 66646d4c572STomoki Sekiyama unsigned int devmajor, devminor; 667c216e5adSMichael Roth 668c216e5adSMichael Roth fp = setmntent(mtab, "r"); 669c216e5adSMichael Roth if (!fp) { 67077dbc81bSMarkus Armbruster error_setg(errp, "failed to open mtab file: '%s'", mtab); 671261551d1SLuiz Capitulino return; 672c216e5adSMichael Roth } 673c216e5adSMichael Roth 674c216e5adSMichael Roth while ((ment = getmntent(fp))) { 675c216e5adSMichael Roth /* 676c216e5adSMichael Roth * An entry which device name doesn't start with a '/' is 677c216e5adSMichael Roth * either a dummy file system or a network file system. 678c216e5adSMichael Roth * Add special handling for smbfs and cifs as is done by 679c216e5adSMichael Roth * coreutils as well. 680c216e5adSMichael Roth */ 681c216e5adSMichael Roth if ((ment->mnt_fsname[0] != '/') || 682c216e5adSMichael Roth (strcmp(ment->mnt_type, "smbfs") == 0) || 683c216e5adSMichael Roth (strcmp(ment->mnt_type, "cifs") == 0)) { 684c216e5adSMichael Roth continue; 685c216e5adSMichael Roth } 68646d4c572STomoki Sekiyama if (dev_major_minor(ment->mnt_fsname, &devmajor, &devminor) == -2) { 68746d4c572STomoki Sekiyama /* Skip bind mounts */ 68846d4c572STomoki Sekiyama continue; 68946d4c572STomoki Sekiyama } 690c216e5adSMichael Roth 691f3a06403SMarkus Armbruster mount = g_new0(FsMount, 1); 692c216e5adSMichael Roth mount->dirname = g_strdup(ment->mnt_dir); 693c216e5adSMichael Roth mount->devtype = g_strdup(ment->mnt_type); 69446d4c572STomoki Sekiyama mount->devmajor = devmajor; 69546d4c572STomoki Sekiyama mount->devminor = devminor; 696c216e5adSMichael Roth 6979e8aded4SMichael Roth QTAILQ_INSERT_TAIL(mounts, mount, next); 698c216e5adSMichael Roth } 699c216e5adSMichael Roth 700c216e5adSMichael Roth endmntent(fp); 701c216e5adSMichael Roth } 70246d4c572STomoki Sekiyama 70346d4c572STomoki Sekiyama static void decode_mntname(char *name, int len) 70446d4c572STomoki Sekiyama { 70546d4c572STomoki Sekiyama int i, j = 0; 70646d4c572STomoki Sekiyama for (i = 0; i <= len; i++) { 70746d4c572STomoki Sekiyama if (name[i] != '\\') { 70846d4c572STomoki Sekiyama name[j++] = name[i]; 70946d4c572STomoki Sekiyama } else if (name[i + 1] == '\\') { 71046d4c572STomoki Sekiyama name[j++] = '\\'; 71146d4c572STomoki Sekiyama i++; 71246d4c572STomoki Sekiyama } else if (name[i + 1] >= '0' && name[i + 1] <= '3' && 71346d4c572STomoki Sekiyama name[i + 2] >= '0' && name[i + 2] <= '7' && 71446d4c572STomoki Sekiyama name[i + 3] >= '0' && name[i + 3] <= '7') { 71546d4c572STomoki Sekiyama name[j++] = (name[i + 1] - '0') * 64 + 71646d4c572STomoki Sekiyama (name[i + 2] - '0') * 8 + 71746d4c572STomoki Sekiyama (name[i + 3] - '0'); 71846d4c572STomoki Sekiyama i += 3; 71946d4c572STomoki Sekiyama } else { 72046d4c572STomoki Sekiyama name[j++] = name[i]; 72146d4c572STomoki Sekiyama } 72246d4c572STomoki Sekiyama } 72346d4c572STomoki Sekiyama } 72446d4c572STomoki Sekiyama 72546d4c572STomoki Sekiyama static void build_fs_mount_list(FsMountList *mounts, Error **errp) 72646d4c572STomoki Sekiyama { 72746d4c572STomoki Sekiyama FsMount *mount; 72846d4c572STomoki Sekiyama char const *mountinfo = "/proc/self/mountinfo"; 72946d4c572STomoki Sekiyama FILE *fp; 73046d4c572STomoki Sekiyama char *line = NULL, *dash; 73146d4c572STomoki Sekiyama size_t n; 73246d4c572STomoki Sekiyama char check; 73346d4c572STomoki Sekiyama unsigned int devmajor, devminor; 73446d4c572STomoki Sekiyama int ret, dir_s, dir_e, type_s, type_e, dev_s, dev_e; 73546d4c572STomoki Sekiyama 73646d4c572STomoki Sekiyama fp = fopen(mountinfo, "r"); 73746d4c572STomoki Sekiyama if (!fp) { 73846d4c572STomoki Sekiyama build_fs_mount_list_from_mtab(mounts, errp); 73946d4c572STomoki Sekiyama return; 74046d4c572STomoki Sekiyama } 74146d4c572STomoki Sekiyama 74246d4c572STomoki Sekiyama while (getline(&line, &n, fp) != -1) { 74346d4c572STomoki Sekiyama ret = sscanf(line, "%*u %*u %u:%u %*s %n%*s%n%c", 74446d4c572STomoki Sekiyama &devmajor, &devminor, &dir_s, &dir_e, &check); 74546d4c572STomoki Sekiyama if (ret < 3) { 74646d4c572STomoki Sekiyama continue; 74746d4c572STomoki Sekiyama } 74846d4c572STomoki Sekiyama dash = strstr(line + dir_e, " - "); 74946d4c572STomoki Sekiyama if (!dash) { 75046d4c572STomoki Sekiyama continue; 75146d4c572STomoki Sekiyama } 75246d4c572STomoki Sekiyama ret = sscanf(dash, " - %n%*s%n %n%*s%n%c", 75346d4c572STomoki Sekiyama &type_s, &type_e, &dev_s, &dev_e, &check); 75446d4c572STomoki Sekiyama if (ret < 1) { 75546d4c572STomoki Sekiyama continue; 75646d4c572STomoki Sekiyama } 75746d4c572STomoki Sekiyama line[dir_e] = 0; 75846d4c572STomoki Sekiyama dash[type_e] = 0; 75946d4c572STomoki Sekiyama dash[dev_e] = 0; 76046d4c572STomoki Sekiyama decode_mntname(line + dir_s, dir_e - dir_s); 76146d4c572STomoki Sekiyama decode_mntname(dash + dev_s, dev_e - dev_s); 76246d4c572STomoki Sekiyama if (devmajor == 0) { 76346d4c572STomoki Sekiyama /* btrfs reports major number = 0 */ 76446d4c572STomoki Sekiyama if (strcmp("btrfs", dash + type_s) != 0 || 76546d4c572STomoki Sekiyama dev_major_minor(dash + dev_s, &devmajor, &devminor) < 0) { 76646d4c572STomoki Sekiyama continue; 76746d4c572STomoki Sekiyama } 76846d4c572STomoki Sekiyama } 76946d4c572STomoki Sekiyama 770f3a06403SMarkus Armbruster mount = g_new0(FsMount, 1); 77146d4c572STomoki Sekiyama mount->dirname = g_strdup(line + dir_s); 77246d4c572STomoki Sekiyama mount->devtype = g_strdup(dash + type_s); 77346d4c572STomoki Sekiyama mount->devmajor = devmajor; 77446d4c572STomoki Sekiyama mount->devminor = devminor; 77546d4c572STomoki Sekiyama 77646d4c572STomoki Sekiyama QTAILQ_INSERT_TAIL(mounts, mount, next); 77746d4c572STomoki Sekiyama } 77846d4c572STomoki Sekiyama free(line); 77946d4c572STomoki Sekiyama 78046d4c572STomoki Sekiyama fclose(fp); 78146d4c572STomoki Sekiyama } 782eab5fd59SPaolo Bonzini #endif 783eab5fd59SPaolo Bonzini 784eab5fd59SPaolo Bonzini #if defined(CONFIG_FSFREEZE) 785c216e5adSMichael Roth 78646d4c572STomoki Sekiyama static char *get_pci_driver(char const *syspath, int pathlen, Error **errp) 78746d4c572STomoki Sekiyama { 78846d4c572STomoki Sekiyama char *path; 78946d4c572STomoki Sekiyama char *dpath; 79046d4c572STomoki Sekiyama char *driver = NULL; 79146d4c572STomoki Sekiyama char buf[PATH_MAX]; 79246d4c572STomoki Sekiyama ssize_t len; 79346d4c572STomoki Sekiyama 79446d4c572STomoki Sekiyama path = g_strndup(syspath, pathlen); 79546d4c572STomoki Sekiyama dpath = g_strdup_printf("%s/driver", path); 79646d4c572STomoki Sekiyama len = readlink(dpath, buf, sizeof(buf) - 1); 79746d4c572STomoki Sekiyama if (len != -1) { 79846d4c572STomoki Sekiyama buf[len] = 0; 7993e015d81SJulia Suvorova driver = g_path_get_basename(buf); 80046d4c572STomoki Sekiyama } 80146d4c572STomoki Sekiyama g_free(dpath); 80246d4c572STomoki Sekiyama g_free(path); 80346d4c572STomoki Sekiyama return driver; 80446d4c572STomoki Sekiyama } 80546d4c572STomoki Sekiyama 80646d4c572STomoki Sekiyama static int compare_uint(const void *_a, const void *_b) 80746d4c572STomoki Sekiyama { 80846d4c572STomoki Sekiyama unsigned int a = *(unsigned int *)_a; 80946d4c572STomoki Sekiyama unsigned int b = *(unsigned int *)_b; 81046d4c572STomoki Sekiyama 81146d4c572STomoki Sekiyama return a < b ? -1 : a > b ? 1 : 0; 81246d4c572STomoki Sekiyama } 81346d4c572STomoki Sekiyama 81446d4c572STomoki Sekiyama /* Walk the specified sysfs and build a sorted list of host or ata numbers */ 81546d4c572STomoki Sekiyama static int build_hosts(char const *syspath, char const *host, bool ata, 81646d4c572STomoki Sekiyama unsigned int *hosts, int hosts_max, Error **errp) 81746d4c572STomoki Sekiyama { 81846d4c572STomoki Sekiyama char *path; 81946d4c572STomoki Sekiyama DIR *dir; 82046d4c572STomoki Sekiyama struct dirent *entry; 82146d4c572STomoki Sekiyama int i = 0; 82246d4c572STomoki Sekiyama 82346d4c572STomoki Sekiyama path = g_strndup(syspath, host - syspath); 82446d4c572STomoki Sekiyama dir = opendir(path); 82546d4c572STomoki Sekiyama if (!dir) { 82646d4c572STomoki Sekiyama error_setg_errno(errp, errno, "opendir(\"%s\")", path); 82746d4c572STomoki Sekiyama g_free(path); 82846d4c572STomoki Sekiyama return -1; 82946d4c572STomoki Sekiyama } 83046d4c572STomoki Sekiyama 83146d4c572STomoki Sekiyama while (i < hosts_max) { 83246d4c572STomoki Sekiyama entry = readdir(dir); 83346d4c572STomoki Sekiyama if (!entry) { 83446d4c572STomoki Sekiyama break; 83546d4c572STomoki Sekiyama } 83646d4c572STomoki Sekiyama if (ata && sscanf(entry->d_name, "ata%d", hosts + i) == 1) { 83746d4c572STomoki Sekiyama ++i; 83846d4c572STomoki Sekiyama } else if (!ata && sscanf(entry->d_name, "host%d", hosts + i) == 1) { 83946d4c572STomoki Sekiyama ++i; 84046d4c572STomoki Sekiyama } 84146d4c572STomoki Sekiyama } 84246d4c572STomoki Sekiyama 84346d4c572STomoki Sekiyama qsort(hosts, i, sizeof(hosts[0]), compare_uint); 84446d4c572STomoki Sekiyama 84546d4c572STomoki Sekiyama g_free(path); 84646d4c572STomoki Sekiyama closedir(dir); 84746d4c572STomoki Sekiyama return i; 84846d4c572STomoki Sekiyama } 84946d4c572STomoki Sekiyama 850d9fe4f0fSThomas Huth /* 851d9fe4f0fSThomas Huth * Store disk device info for devices on the PCI bus. 852d9fe4f0fSThomas Huth * Returns true if information has been stored, or false for failure. 853d9fe4f0fSThomas Huth */ 854d9fe4f0fSThomas Huth static bool build_guest_fsinfo_for_pci_dev(char const *syspath, 855d9fe4f0fSThomas Huth GuestDiskAddress *disk, 85646d4c572STomoki Sekiyama Error **errp) 85746d4c572STomoki Sekiyama { 85846d4c572STomoki Sekiyama unsigned int pci[4], host, hosts[8], tgt[3]; 85946d4c572STomoki Sekiyama int i, nhosts = 0, pcilen; 860d9fe4f0fSThomas Huth GuestPCIAddress *pciaddr = disk->pci_controller; 86146d4c572STomoki Sekiyama bool has_ata = false, has_host = false, has_tgt = false; 86246d4c572STomoki Sekiyama char *p, *q, *driver = NULL; 863d9fe4f0fSThomas Huth bool ret = false; 86446d4c572STomoki Sekiyama 86546d4c572STomoki Sekiyama p = strstr(syspath, "/devices/pci"); 86646d4c572STomoki Sekiyama if (!p || sscanf(p + 12, "%*x:%*x/%x:%x:%x.%x%n", 86746d4c572STomoki Sekiyama pci, pci + 1, pci + 2, pci + 3, &pcilen) < 4) { 868743c71d0SMarc-André Lureau g_debug("only pci device is supported: sysfs path '%s'", syspath); 869d9fe4f0fSThomas Huth return false; 87046d4c572STomoki Sekiyama } 87146d4c572STomoki Sekiyama 872743c71d0SMarc-André Lureau p += 12 + pcilen; 873743c71d0SMarc-André Lureau while (true) { 874743c71d0SMarc-André Lureau driver = get_pci_driver(syspath, p - syspath, errp); 875743c71d0SMarc-André Lureau if (driver && (g_str_equal(driver, "ata_piix") || 876743c71d0SMarc-André Lureau g_str_equal(driver, "sym53c8xx") || 877743c71d0SMarc-André Lureau g_str_equal(driver, "virtio-pci") || 878743c71d0SMarc-André Lureau g_str_equal(driver, "ahci"))) { 879743c71d0SMarc-André Lureau break; 880743c71d0SMarc-André Lureau } 881743c71d0SMarc-André Lureau 882bb23a736SMarc-André Lureau g_free(driver); 883743c71d0SMarc-André Lureau if (sscanf(p, "/%x:%x:%x.%x%n", 884743c71d0SMarc-André Lureau pci, pci + 1, pci + 2, pci + 3, &pcilen) == 4) { 885743c71d0SMarc-André Lureau p += pcilen; 886743c71d0SMarc-André Lureau continue; 887743c71d0SMarc-André Lureau } 888743c71d0SMarc-André Lureau 889743c71d0SMarc-André Lureau g_debug("unsupported driver or sysfs path '%s'", syspath); 890d9fe4f0fSThomas Huth return false; 89146d4c572STomoki Sekiyama } 89246d4c572STomoki Sekiyama 89346d4c572STomoki Sekiyama p = strstr(syspath, "/target"); 89446d4c572STomoki Sekiyama if (p && sscanf(p + 7, "%*u:%*u:%*u/%*u:%u:%u:%u", 89546d4c572STomoki Sekiyama tgt, tgt + 1, tgt + 2) == 3) { 89646d4c572STomoki Sekiyama has_tgt = true; 89746d4c572STomoki Sekiyama } 89846d4c572STomoki Sekiyama 89946d4c572STomoki Sekiyama p = strstr(syspath, "/ata"); 90046d4c572STomoki Sekiyama if (p) { 90146d4c572STomoki Sekiyama q = p + 4; 90246d4c572STomoki Sekiyama has_ata = true; 90346d4c572STomoki Sekiyama } else { 90446d4c572STomoki Sekiyama p = strstr(syspath, "/host"); 90546d4c572STomoki Sekiyama q = p + 5; 90646d4c572STomoki Sekiyama } 90746d4c572STomoki Sekiyama if (p && sscanf(q, "%u", &host) == 1) { 90846d4c572STomoki Sekiyama has_host = true; 90946d4c572STomoki Sekiyama nhosts = build_hosts(syspath, p, has_ata, hosts, 91001a6df1bSPhilippe Mathieu-Daudé ARRAY_SIZE(hosts), errp); 91146d4c572STomoki Sekiyama if (nhosts < 0) { 91246d4c572STomoki Sekiyama goto cleanup; 91346d4c572STomoki Sekiyama } 91446d4c572STomoki Sekiyama } 91546d4c572STomoki Sekiyama 91646d4c572STomoki Sekiyama pciaddr->domain = pci[0]; 91746d4c572STomoki Sekiyama pciaddr->bus = pci[1]; 91846d4c572STomoki Sekiyama pciaddr->slot = pci[2]; 91946d4c572STomoki Sekiyama pciaddr->function = pci[3]; 92046d4c572STomoki Sekiyama 92146d4c572STomoki Sekiyama if (strcmp(driver, "ata_piix") == 0) { 92246d4c572STomoki Sekiyama /* a host per ide bus, target*:0:<unit>:0 */ 92346d4c572STomoki Sekiyama if (!has_host || !has_tgt) { 92446d4c572STomoki Sekiyama g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver); 92546d4c572STomoki Sekiyama goto cleanup; 92646d4c572STomoki Sekiyama } 92746d4c572STomoki Sekiyama for (i = 0; i < nhosts; i++) { 92846d4c572STomoki Sekiyama if (host == hosts[i]) { 92946d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_IDE; 93046d4c572STomoki Sekiyama disk->bus = i; 93146d4c572STomoki Sekiyama disk->unit = tgt[1]; 93246d4c572STomoki Sekiyama break; 93346d4c572STomoki Sekiyama } 93446d4c572STomoki Sekiyama } 93546d4c572STomoki Sekiyama if (i >= nhosts) { 93646d4c572STomoki Sekiyama g_debug("no host for '%s' (driver '%s')", syspath, driver); 93746d4c572STomoki Sekiyama goto cleanup; 93846d4c572STomoki Sekiyama } 93946d4c572STomoki Sekiyama } else if (strcmp(driver, "sym53c8xx") == 0) { 94046d4c572STomoki Sekiyama /* scsi(LSI Logic): target*:0:<unit>:0 */ 94146d4c572STomoki Sekiyama if (!has_tgt) { 94246d4c572STomoki Sekiyama g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver); 94346d4c572STomoki Sekiyama goto cleanup; 94446d4c572STomoki Sekiyama } 94546d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI; 94646d4c572STomoki Sekiyama disk->unit = tgt[1]; 94746d4c572STomoki Sekiyama } else if (strcmp(driver, "virtio-pci") == 0) { 94846d4c572STomoki Sekiyama if (has_tgt) { 94946d4c572STomoki Sekiyama /* virtio-scsi: target*:0:0:<unit> */ 95046d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI; 95146d4c572STomoki Sekiyama disk->unit = tgt[2]; 95246d4c572STomoki Sekiyama } else { 95346d4c572STomoki Sekiyama /* virtio-blk: 1 disk per 1 device */ 95446d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_VIRTIO; 95546d4c572STomoki Sekiyama } 95646d4c572STomoki Sekiyama } else if (strcmp(driver, "ahci") == 0) { 95746d4c572STomoki Sekiyama /* ahci: 1 host per 1 unit */ 95846d4c572STomoki Sekiyama if (!has_host || !has_tgt) { 95946d4c572STomoki Sekiyama g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver); 96046d4c572STomoki Sekiyama goto cleanup; 96146d4c572STomoki Sekiyama } 96246d4c572STomoki Sekiyama for (i = 0; i < nhosts; i++) { 96346d4c572STomoki Sekiyama if (host == hosts[i]) { 96446d4c572STomoki Sekiyama disk->unit = i; 96546d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_SATA; 96646d4c572STomoki Sekiyama break; 96746d4c572STomoki Sekiyama } 96846d4c572STomoki Sekiyama } 96946d4c572STomoki Sekiyama if (i >= nhosts) { 97046d4c572STomoki Sekiyama g_debug("no host for '%s' (driver '%s')", syspath, driver); 97146d4c572STomoki Sekiyama goto cleanup; 97246d4c572STomoki Sekiyama } 97346d4c572STomoki Sekiyama } else { 97446d4c572STomoki Sekiyama g_debug("unknown driver '%s' (sysfs path '%s')", driver, syspath); 97546d4c572STomoki Sekiyama goto cleanup; 97646d4c572STomoki Sekiyama } 97746d4c572STomoki Sekiyama 978d9fe4f0fSThomas Huth ret = true; 97946d4c572STomoki Sekiyama 98046d4c572STomoki Sekiyama cleanup: 98146d4c572STomoki Sekiyama g_free(driver); 982d9fe4f0fSThomas Huth return ret; 983d9fe4f0fSThomas Huth } 984d9fe4f0fSThomas Huth 98523843c12SThomas Huth /* 98623843c12SThomas Huth * Store disk device info for non-PCI virtio devices (for example s390x 98723843c12SThomas Huth * channel I/O devices). Returns true if information has been stored, or 98823843c12SThomas Huth * false for failure. 98923843c12SThomas Huth */ 99023843c12SThomas Huth static bool build_guest_fsinfo_for_nonpci_virtio(char const *syspath, 99123843c12SThomas Huth GuestDiskAddress *disk, 99223843c12SThomas Huth Error **errp) 99323843c12SThomas Huth { 99423843c12SThomas Huth unsigned int tgt[3]; 99523843c12SThomas Huth char *p; 99623843c12SThomas Huth 99723843c12SThomas Huth if (!strstr(syspath, "/virtio") || !strstr(syspath, "/block")) { 99823843c12SThomas Huth g_debug("Unsupported virtio device '%s'", syspath); 99923843c12SThomas Huth return false; 100023843c12SThomas Huth } 100123843c12SThomas Huth 100223843c12SThomas Huth p = strstr(syspath, "/target"); 100323843c12SThomas Huth if (p && sscanf(p + 7, "%*u:%*u:%*u/%*u:%u:%u:%u", 100423843c12SThomas Huth &tgt[0], &tgt[1], &tgt[2]) == 3) { 100523843c12SThomas Huth /* virtio-scsi: target*:0:<target>:<unit> */ 100623843c12SThomas Huth disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI; 100723843c12SThomas Huth disk->bus = tgt[0]; 100823843c12SThomas Huth disk->target = tgt[1]; 100923843c12SThomas Huth disk->unit = tgt[2]; 101023843c12SThomas Huth } else { 101123843c12SThomas Huth /* virtio-blk: 1 disk per 1 device */ 101223843c12SThomas Huth disk->bus_type = GUEST_DISK_BUS_TYPE_VIRTIO; 101323843c12SThomas Huth } 101423843c12SThomas Huth 101523843c12SThomas Huth return true; 101623843c12SThomas Huth } 101723843c12SThomas Huth 10185b723a5dSThomas Huth /* 10195b723a5dSThomas Huth * Store disk device info for CCW devices (s390x channel I/O devices). 10205b723a5dSThomas Huth * Returns true if information has been stored, or false for failure. 10215b723a5dSThomas Huth */ 10225b723a5dSThomas Huth static bool build_guest_fsinfo_for_ccw_dev(char const *syspath, 10235b723a5dSThomas Huth GuestDiskAddress *disk, 10245b723a5dSThomas Huth Error **errp) 10255b723a5dSThomas Huth { 10265b723a5dSThomas Huth unsigned int cssid, ssid, subchno, devno; 10275b723a5dSThomas Huth char *p; 10285b723a5dSThomas Huth 10295b723a5dSThomas Huth p = strstr(syspath, "/devices/css"); 10305b723a5dSThomas Huth if (!p || sscanf(p + 12, "%*x/%x.%x.%x/%*x.%*x.%x/", 10315b723a5dSThomas Huth &cssid, &ssid, &subchno, &devno) < 4) { 10325b723a5dSThomas Huth g_debug("could not parse ccw device sysfs path: %s", syspath); 10335b723a5dSThomas Huth return false; 10345b723a5dSThomas Huth } 10355b723a5dSThomas Huth 10365b723a5dSThomas Huth disk->has_ccw_address = true; 10375b723a5dSThomas Huth disk->ccw_address = g_new0(GuestCCWAddress, 1); 10385b723a5dSThomas Huth disk->ccw_address->cssid = cssid; 10395b723a5dSThomas Huth disk->ccw_address->ssid = ssid; 10405b723a5dSThomas Huth disk->ccw_address->subchno = subchno; 10415b723a5dSThomas Huth disk->ccw_address->devno = devno; 10425b723a5dSThomas Huth 10435b723a5dSThomas Huth if (strstr(p, "/virtio")) { 10445b723a5dSThomas Huth build_guest_fsinfo_for_nonpci_virtio(syspath, disk, errp); 10455b723a5dSThomas Huth } 10465b723a5dSThomas Huth 10475b723a5dSThomas Huth return true; 10485b723a5dSThomas Huth } 10495b723a5dSThomas Huth 1050d9fe4f0fSThomas Huth /* Store disk device info specified by @sysfs into @fs */ 1051d9fe4f0fSThomas Huth static void build_guest_fsinfo_for_real_device(char const *syspath, 1052d9fe4f0fSThomas Huth GuestFilesystemInfo *fs, 1053d9fe4f0fSThomas Huth Error **errp) 1054d9fe4f0fSThomas Huth { 1055d9fe4f0fSThomas Huth GuestDiskAddress *disk; 1056d9fe4f0fSThomas Huth GuestPCIAddress *pciaddr; 1057d9fe4f0fSThomas Huth bool has_hwinf; 105843dadc43SThomas Huth #ifdef CONFIG_LIBUDEV 105943dadc43SThomas Huth struct udev *udev = NULL; 106043dadc43SThomas Huth struct udev_device *udevice = NULL; 106143dadc43SThomas Huth #endif 1062d9fe4f0fSThomas Huth 1063d9fe4f0fSThomas Huth pciaddr = g_new0(GuestPCIAddress, 1); 106443dadc43SThomas Huth pciaddr->domain = -1; /* -1 means field is invalid */ 106543dadc43SThomas Huth pciaddr->bus = -1; 106643dadc43SThomas Huth pciaddr->slot = -1; 106743dadc43SThomas Huth pciaddr->function = -1; 1068d9fe4f0fSThomas Huth 1069d9fe4f0fSThomas Huth disk = g_new0(GuestDiskAddress, 1); 1070d9fe4f0fSThomas Huth disk->pci_controller = pciaddr; 107143dadc43SThomas Huth disk->bus_type = GUEST_DISK_BUS_TYPE_UNKNOWN; 1072d9fe4f0fSThomas Huth 107343dadc43SThomas Huth #ifdef CONFIG_LIBUDEV 107443dadc43SThomas Huth udev = udev_new(); 107543dadc43SThomas Huth udevice = udev_device_new_from_syspath(udev, syspath); 107643dadc43SThomas Huth if (udev == NULL || udevice == NULL) { 107743dadc43SThomas Huth g_debug("failed to query udev"); 107843dadc43SThomas Huth } else { 107943dadc43SThomas Huth const char *devnode, *serial; 108043dadc43SThomas Huth devnode = udev_device_get_devnode(udevice); 108143dadc43SThomas Huth if (devnode != NULL) { 108243dadc43SThomas Huth disk->dev = g_strdup(devnode); 108343dadc43SThomas Huth disk->has_dev = true; 108443dadc43SThomas Huth } 108543dadc43SThomas Huth serial = udev_device_get_property_value(udevice, "ID_SERIAL"); 108643dadc43SThomas Huth if (serial != NULL && *serial != 0) { 108743dadc43SThomas Huth disk->serial = g_strdup(serial); 108843dadc43SThomas Huth disk->has_serial = true; 108943dadc43SThomas Huth } 109043dadc43SThomas Huth } 109143dadc43SThomas Huth 109243dadc43SThomas Huth udev_unref(udev); 109343dadc43SThomas Huth udev_device_unref(udevice); 109443dadc43SThomas Huth #endif 109543dadc43SThomas Huth 109623843c12SThomas Huth if (strstr(syspath, "/devices/pci")) { 1097d9fe4f0fSThomas Huth has_hwinf = build_guest_fsinfo_for_pci_dev(syspath, disk, errp); 10985b723a5dSThomas Huth } else if (strstr(syspath, "/devices/css")) { 10995b723a5dSThomas Huth has_hwinf = build_guest_fsinfo_for_ccw_dev(syspath, disk, errp); 110023843c12SThomas Huth } else if (strstr(syspath, "/virtio")) { 110123843c12SThomas Huth has_hwinf = build_guest_fsinfo_for_nonpci_virtio(syspath, disk, errp); 110223843c12SThomas Huth } else { 110323843c12SThomas Huth g_debug("Unsupported device type for '%s'", syspath); 110423843c12SThomas Huth has_hwinf = false; 110523843c12SThomas Huth } 1106d9fe4f0fSThomas Huth 110743dadc43SThomas Huth if (has_hwinf || disk->has_dev || disk->has_serial) { 110854aa3de7SEric Blake QAPI_LIST_PREPEND(fs->disk, disk); 1109d9fe4f0fSThomas Huth } else { 111054aa3de7SEric Blake qapi_free_GuestDiskAddress(disk); 1111d9fe4f0fSThomas Huth } 111246d4c572STomoki Sekiyama } 111346d4c572STomoki Sekiyama 111446d4c572STomoki Sekiyama static void build_guest_fsinfo_for_device(char const *devpath, 111546d4c572STomoki Sekiyama GuestFilesystemInfo *fs, 111646d4c572STomoki Sekiyama Error **errp); 111746d4c572STomoki Sekiyama 111846d4c572STomoki Sekiyama /* Store a list of slave devices of virtual volume specified by @syspath into 111946d4c572STomoki Sekiyama * @fs */ 112046d4c572STomoki Sekiyama static void build_guest_fsinfo_for_virtual_device(char const *syspath, 112146d4c572STomoki Sekiyama GuestFilesystemInfo *fs, 112246d4c572STomoki Sekiyama Error **errp) 112346d4c572STomoki Sekiyama { 1124292743d9SMarkus Armbruster Error *err = NULL; 112546d4c572STomoki Sekiyama DIR *dir; 112646d4c572STomoki Sekiyama char *dirpath; 1127e668d1b8Szhanghailiang struct dirent *entry; 112846d4c572STomoki Sekiyama 112946d4c572STomoki Sekiyama dirpath = g_strdup_printf("%s/slaves", syspath); 113046d4c572STomoki Sekiyama dir = opendir(dirpath); 113146d4c572STomoki Sekiyama if (!dir) { 11328251a72fSMichael Roth if (errno != ENOENT) { 113346d4c572STomoki Sekiyama error_setg_errno(errp, errno, "opendir(\"%s\")", dirpath); 11348251a72fSMichael Roth } 113546d4c572STomoki Sekiyama g_free(dirpath); 113646d4c572STomoki Sekiyama return; 113746d4c572STomoki Sekiyama } 113846d4c572STomoki Sekiyama 113946d4c572STomoki Sekiyama for (;;) { 1140e668d1b8Szhanghailiang errno = 0; 1141e668d1b8Szhanghailiang entry = readdir(dir); 1142e668d1b8Szhanghailiang if (entry == NULL) { 1143e668d1b8Szhanghailiang if (errno) { 1144e668d1b8Szhanghailiang error_setg_errno(errp, errno, "readdir(\"%s\")", dirpath); 114546d4c572STomoki Sekiyama } 114646d4c572STomoki Sekiyama break; 114746d4c572STomoki Sekiyama } 114846d4c572STomoki Sekiyama 1149e668d1b8Szhanghailiang if (entry->d_type == DT_LNK) { 1150e668d1b8Szhanghailiang char *path; 1151e668d1b8Szhanghailiang 1152e668d1b8Szhanghailiang g_debug(" slave device '%s'", entry->d_name); 1153e668d1b8Szhanghailiang path = g_strdup_printf("%s/slaves/%s", syspath, entry->d_name); 1154292743d9SMarkus Armbruster build_guest_fsinfo_for_device(path, fs, &err); 1155e668d1b8Szhanghailiang g_free(path); 115646d4c572STomoki Sekiyama 1157292743d9SMarkus Armbruster if (err) { 1158292743d9SMarkus Armbruster error_propagate(errp, err); 115946d4c572STomoki Sekiyama break; 116046d4c572STomoki Sekiyama } 116146d4c572STomoki Sekiyama } 116246d4c572STomoki Sekiyama } 116346d4c572STomoki Sekiyama 1164e668d1b8Szhanghailiang g_free(dirpath); 116546d4c572STomoki Sekiyama closedir(dir); 116646d4c572STomoki Sekiyama } 116746d4c572STomoki Sekiyama 1168fed39564STomáš Golembiovský static bool is_disk_virtual(const char *devpath, Error **errp) 1169fed39564STomáš Golembiovský { 1170fed39564STomáš Golembiovský g_autofree char *syspath = realpath(devpath, NULL); 1171fed39564STomáš Golembiovský 1172fed39564STomáš Golembiovský if (!syspath) { 1173fed39564STomáš Golembiovský error_setg_errno(errp, errno, "realpath(\"%s\")", devpath); 1174fed39564STomáš Golembiovský return false; 1175fed39564STomáš Golembiovský } 1176fed39564STomáš Golembiovský return strstr(syspath, "/devices/virtual/block/") != NULL; 1177fed39564STomáš Golembiovský } 1178fed39564STomáš Golembiovský 117946d4c572STomoki Sekiyama /* Dispatch to functions for virtual/real device */ 118046d4c572STomoki Sekiyama static void build_guest_fsinfo_for_device(char const *devpath, 118146d4c572STomoki Sekiyama GuestFilesystemInfo *fs, 118246d4c572STomoki Sekiyama Error **errp) 118346d4c572STomoki Sekiyama { 1184fed39564STomáš Golembiovský ERRP_GUARD(); 1185fed39564STomáš Golembiovský g_autofree char *syspath = NULL; 1186fed39564STomáš Golembiovský bool is_virtual = false; 118746d4c572STomoki Sekiyama 1188fed39564STomáš Golembiovský syspath = realpath(devpath, NULL); 118946d4c572STomoki Sekiyama if (!syspath) { 119046d4c572STomoki Sekiyama error_setg_errno(errp, errno, "realpath(\"%s\")", devpath); 119146d4c572STomoki Sekiyama return; 119246d4c572STomoki Sekiyama } 119346d4c572STomoki Sekiyama 119446d4c572STomoki Sekiyama if (!fs->name) { 11953e015d81SJulia Suvorova fs->name = g_path_get_basename(syspath); 119646d4c572STomoki Sekiyama } 119746d4c572STomoki Sekiyama 119846d4c572STomoki Sekiyama g_debug(" parse sysfs path '%s'", syspath); 1199fed39564STomáš Golembiovský is_virtual = is_disk_virtual(syspath, errp); 1200fed39564STomáš Golembiovský if (*errp != NULL) { 1201fed39564STomáš Golembiovský return; 1202fed39564STomáš Golembiovský } 1203fed39564STomáš Golembiovský if (is_virtual) { 120446d4c572STomoki Sekiyama build_guest_fsinfo_for_virtual_device(syspath, fs, errp); 120546d4c572STomoki Sekiyama } else { 120646d4c572STomoki Sekiyama build_guest_fsinfo_for_real_device(syspath, fs, errp); 120746d4c572STomoki Sekiyama } 120846d4c572STomoki Sekiyama } 120946d4c572STomoki Sekiyama 1210fed39564STomáš Golembiovský #ifdef CONFIG_LIBUDEV 1211fed39564STomáš Golembiovský 1212fed39564STomáš Golembiovský /* 1213fed39564STomáš Golembiovský * Wrapper around build_guest_fsinfo_for_device() for getting just 1214fed39564STomáš Golembiovský * the disk address. 1215fed39564STomáš Golembiovský */ 1216fed39564STomáš Golembiovský static GuestDiskAddress *get_disk_address(const char *syspath, Error **errp) 1217fed39564STomáš Golembiovský { 1218fed39564STomáš Golembiovský g_autoptr(GuestFilesystemInfo) fs = NULL; 1219fed39564STomáš Golembiovský 1220fed39564STomáš Golembiovský fs = g_new0(GuestFilesystemInfo, 1); 1221fed39564STomáš Golembiovský build_guest_fsinfo_for_device(syspath, fs, errp); 1222fed39564STomáš Golembiovský if (fs->disk != NULL) { 1223fed39564STomáš Golembiovský return g_steal_pointer(&fs->disk->value); 1224fed39564STomáš Golembiovský } 1225fed39564STomáš Golembiovský return NULL; 1226fed39564STomáš Golembiovský } 1227fed39564STomáš Golembiovský 1228fed39564STomáš Golembiovský static char *get_alias_for_syspath(const char *syspath) 1229fed39564STomáš Golembiovský { 1230fed39564STomáš Golembiovský struct udev *udev = NULL; 1231fed39564STomáš Golembiovský struct udev_device *udevice = NULL; 1232fed39564STomáš Golembiovský char *ret = NULL; 1233fed39564STomáš Golembiovský 1234fed39564STomáš Golembiovský udev = udev_new(); 1235fed39564STomáš Golembiovský if (udev == NULL) { 1236fed39564STomáš Golembiovský g_debug("failed to query udev"); 1237fed39564STomáš Golembiovský goto out; 1238fed39564STomáš Golembiovský } 1239fed39564STomáš Golembiovský udevice = udev_device_new_from_syspath(udev, syspath); 1240fed39564STomáš Golembiovský if (udevice == NULL) { 1241fed39564STomáš Golembiovský g_debug("failed to query udev for path: %s", syspath); 1242fed39564STomáš Golembiovský goto out; 1243fed39564STomáš Golembiovský } else { 1244fed39564STomáš Golembiovský const char *alias = udev_device_get_property_value( 1245fed39564STomáš Golembiovský udevice, "DM_NAME"); 1246fed39564STomáš Golembiovský /* 1247fed39564STomáš Golembiovský * NULL means there was an error and empty string means there is no 1248fed39564STomáš Golembiovský * alias. In case of no alias we return NULL instead of empty string. 1249fed39564STomáš Golembiovský */ 1250fed39564STomáš Golembiovský if (alias == NULL) { 1251fed39564STomáš Golembiovský g_debug("failed to query udev for device alias for: %s", 1252fed39564STomáš Golembiovský syspath); 1253fed39564STomáš Golembiovský } else if (*alias != 0) { 1254fed39564STomáš Golembiovský ret = g_strdup(alias); 1255fed39564STomáš Golembiovský } 1256fed39564STomáš Golembiovský } 1257fed39564STomáš Golembiovský 1258fed39564STomáš Golembiovský out: 1259fed39564STomáš Golembiovský udev_unref(udev); 1260fed39564STomáš Golembiovský udev_device_unref(udevice); 1261fed39564STomáš Golembiovský return ret; 1262fed39564STomáš Golembiovský } 1263fed39564STomáš Golembiovský 1264fed39564STomáš Golembiovský static char *get_device_for_syspath(const char *syspath) 1265fed39564STomáš Golembiovský { 1266fed39564STomáš Golembiovský struct udev *udev = NULL; 1267fed39564STomáš Golembiovský struct udev_device *udevice = NULL; 1268fed39564STomáš Golembiovský char *ret = NULL; 1269fed39564STomáš Golembiovský 1270fed39564STomáš Golembiovský udev = udev_new(); 1271fed39564STomáš Golembiovský if (udev == NULL) { 1272fed39564STomáš Golembiovský g_debug("failed to query udev"); 1273fed39564STomáš Golembiovský goto out; 1274fed39564STomáš Golembiovský } 1275fed39564STomáš Golembiovský udevice = udev_device_new_from_syspath(udev, syspath); 1276fed39564STomáš Golembiovský if (udevice == NULL) { 1277fed39564STomáš Golembiovský g_debug("failed to query udev for path: %s", syspath); 1278fed39564STomáš Golembiovský goto out; 1279fed39564STomáš Golembiovský } else { 1280fed39564STomáš Golembiovský ret = g_strdup(udev_device_get_devnode(udevice)); 1281fed39564STomáš Golembiovský } 1282fed39564STomáš Golembiovský 1283fed39564STomáš Golembiovský out: 1284fed39564STomáš Golembiovský udev_unref(udev); 1285fed39564STomáš Golembiovský udev_device_unref(udevice); 1286fed39564STomáš Golembiovský return ret; 1287fed39564STomáš Golembiovský } 1288fed39564STomáš Golembiovský 1289fed39564STomáš Golembiovský static void get_disk_deps(const char *disk_dir, GuestDiskInfo *disk) 1290fed39564STomáš Golembiovský { 1291fed39564STomáš Golembiovský g_autofree char *deps_dir = NULL; 1292fed39564STomáš Golembiovský const gchar *dep; 1293fed39564STomáš Golembiovský GDir *dp_deps = NULL; 1294fed39564STomáš Golembiovský 1295fed39564STomáš Golembiovský /* List dependent disks */ 1296fed39564STomáš Golembiovský deps_dir = g_strdup_printf("%s/slaves", disk_dir); 1297fed39564STomáš Golembiovský g_debug(" listing entries in: %s", deps_dir); 1298fed39564STomáš Golembiovský dp_deps = g_dir_open(deps_dir, 0, NULL); 1299fed39564STomáš Golembiovský if (dp_deps == NULL) { 1300fed39564STomáš Golembiovský g_debug("failed to list entries in %s", deps_dir); 1301fed39564STomáš Golembiovský return; 1302fed39564STomáš Golembiovský } 1303a8aa94b5SMichael Roth disk->has_dependencies = true; 1304fed39564STomáš Golembiovský while ((dep = g_dir_read_name(dp_deps)) != NULL) { 1305fed39564STomáš Golembiovský g_autofree char *dep_dir = NULL; 1306fed39564STomáš Golembiovský char *dev_name; 1307fed39564STomáš Golembiovský 1308fed39564STomáš Golembiovský /* Add dependent disks */ 1309fed39564STomáš Golembiovský dep_dir = g_strdup_printf("%s/%s", deps_dir, dep); 1310fed39564STomáš Golembiovský dev_name = get_device_for_syspath(dep_dir); 1311fed39564STomáš Golembiovský if (dev_name != NULL) { 1312fed39564STomáš Golembiovský g_debug(" adding dependent device: %s", dev_name); 131354aa3de7SEric Blake QAPI_LIST_PREPEND(disk->dependencies, dev_name); 1314fed39564STomáš Golembiovský } 1315fed39564STomáš Golembiovský } 1316fed39564STomáš Golembiovský g_dir_close(dp_deps); 1317fed39564STomáš Golembiovský } 1318fed39564STomáš Golembiovský 1319fed39564STomáš Golembiovský /* 1320fed39564STomáš Golembiovský * Detect partitions subdirectory, name is "<disk_name><number>" or 1321fed39564STomáš Golembiovský * "<disk_name>p<number>" 1322fed39564STomáš Golembiovský * 1323fed39564STomáš Golembiovský * @disk_name -- last component of /sys path (e.g. sda) 1324fed39564STomáš Golembiovský * @disk_dir -- sys path of the disk (e.g. /sys/block/sda) 1325fed39564STomáš Golembiovský * @disk_dev -- device node of the disk (e.g. /dev/sda) 1326fed39564STomáš Golembiovský */ 1327fed39564STomáš Golembiovský static GuestDiskInfoList *get_disk_partitions( 1328fed39564STomáš Golembiovský GuestDiskInfoList *list, 1329fed39564STomáš Golembiovský const char *disk_name, const char *disk_dir, 1330fed39564STomáš Golembiovský const char *disk_dev) 1331fed39564STomáš Golembiovský { 133254aa3de7SEric Blake GuestDiskInfoList *ret = list; 1333fed39564STomáš Golembiovský struct dirent *de_disk; 1334fed39564STomáš Golembiovský DIR *dp_disk = NULL; 1335fed39564STomáš Golembiovský size_t len = strlen(disk_name); 1336fed39564STomáš Golembiovský 1337fed39564STomáš Golembiovský dp_disk = opendir(disk_dir); 1338fed39564STomáš Golembiovský while ((de_disk = readdir(dp_disk)) != NULL) { 1339fed39564STomáš Golembiovský g_autofree char *partition_dir = NULL; 1340fed39564STomáš Golembiovský char *dev_name; 1341fed39564STomáš Golembiovský GuestDiskInfo *partition; 1342fed39564STomáš Golembiovský 1343fed39564STomáš Golembiovský if (!(de_disk->d_type & DT_DIR)) { 1344fed39564STomáš Golembiovský continue; 1345fed39564STomáš Golembiovský } 1346fed39564STomáš Golembiovský 1347fed39564STomáš Golembiovský if (!(strncmp(disk_name, de_disk->d_name, len) == 0 && 1348fed39564STomáš Golembiovský ((*(de_disk->d_name + len) == 'p' && 1349fed39564STomáš Golembiovský isdigit(*(de_disk->d_name + len + 1))) || 1350fed39564STomáš Golembiovský isdigit(*(de_disk->d_name + len))))) { 1351fed39564STomáš Golembiovský continue; 1352fed39564STomáš Golembiovský } 1353fed39564STomáš Golembiovský 1354fed39564STomáš Golembiovský partition_dir = g_strdup_printf("%s/%s", 1355fed39564STomáš Golembiovský disk_dir, de_disk->d_name); 1356fed39564STomáš Golembiovský dev_name = get_device_for_syspath(partition_dir); 1357fed39564STomáš Golembiovský if (dev_name == NULL) { 1358fed39564STomáš Golembiovský g_debug("Failed to get device name for syspath: %s", 1359fed39564STomáš Golembiovský disk_dir); 1360fed39564STomáš Golembiovský continue; 1361fed39564STomáš Golembiovský } 1362fed39564STomáš Golembiovský partition = g_new0(GuestDiskInfo, 1); 1363fed39564STomáš Golembiovský partition->name = dev_name; 1364fed39564STomáš Golembiovský partition->partition = true; 1365bac9b87bSMarc-André Lureau partition->has_dependencies = true; 1366fed39564STomáš Golembiovský /* Add parent disk as dependent for easier tracking of hierarchy */ 136754aa3de7SEric Blake QAPI_LIST_PREPEND(partition->dependencies, g_strdup(disk_dev)); 1368fed39564STomáš Golembiovský 136954aa3de7SEric Blake QAPI_LIST_PREPEND(ret, partition); 1370fed39564STomáš Golembiovský } 1371fed39564STomáš Golembiovský closedir(dp_disk); 1372fed39564STomáš Golembiovský 1373fed39564STomáš Golembiovský return ret; 1374fed39564STomáš Golembiovský } 1375fed39564STomáš Golembiovský 1376fed39564STomáš Golembiovský GuestDiskInfoList *qmp_guest_get_disks(Error **errp) 1377fed39564STomáš Golembiovský { 137854aa3de7SEric Blake GuestDiskInfoList *ret = NULL; 1379fed39564STomáš Golembiovský GuestDiskInfo *disk; 1380fed39564STomáš Golembiovský DIR *dp = NULL; 1381fed39564STomáš Golembiovský struct dirent *de = NULL; 1382fed39564STomáš Golembiovský 1383fed39564STomáš Golembiovský g_debug("listing /sys/block directory"); 1384fed39564STomáš Golembiovský dp = opendir("/sys/block"); 1385fed39564STomáš Golembiovský if (dp == NULL) { 1386fed39564STomáš Golembiovský error_setg_errno(errp, errno, "Can't open directory \"/sys/block\""); 1387fed39564STomáš Golembiovský return NULL; 1388fed39564STomáš Golembiovský } 1389fed39564STomáš Golembiovský while ((de = readdir(dp)) != NULL) { 1390fed39564STomáš Golembiovský g_autofree char *disk_dir = NULL, *line = NULL, 1391fed39564STomáš Golembiovský *size_path = NULL; 1392fed39564STomáš Golembiovský char *dev_name; 1393fed39564STomáš Golembiovský Error *local_err = NULL; 1394fed39564STomáš Golembiovský if (de->d_type != DT_LNK) { 1395fed39564STomáš Golembiovský g_debug(" skipping entry: %s", de->d_name); 1396fed39564STomáš Golembiovský continue; 1397fed39564STomáš Golembiovský } 1398fed39564STomáš Golembiovský 1399fed39564STomáš Golembiovský /* Check size and skip zero-sized disks */ 1400fed39564STomáš Golembiovský g_debug(" checking disk size"); 1401fed39564STomáš Golembiovský size_path = g_strdup_printf("/sys/block/%s/size", de->d_name); 1402fed39564STomáš Golembiovský if (!g_file_get_contents(size_path, &line, NULL, NULL)) { 1403fed39564STomáš Golembiovský g_debug(" failed to read disk size"); 1404fed39564STomáš Golembiovský continue; 1405fed39564STomáš Golembiovský } 1406fed39564STomáš Golembiovský if (g_strcmp0(line, "0\n") == 0) { 1407fed39564STomáš Golembiovský g_debug(" skipping zero-sized disk"); 1408fed39564STomáš Golembiovský continue; 1409fed39564STomáš Golembiovský } 1410fed39564STomáš Golembiovský 1411fed39564STomáš Golembiovský g_debug(" adding %s", de->d_name); 1412fed39564STomáš Golembiovský disk_dir = g_strdup_printf("/sys/block/%s", de->d_name); 1413fed39564STomáš Golembiovský dev_name = get_device_for_syspath(disk_dir); 1414fed39564STomáš Golembiovský if (dev_name == NULL) { 1415fed39564STomáš Golembiovský g_debug("Failed to get device name for syspath: %s", 1416fed39564STomáš Golembiovský disk_dir); 1417fed39564STomáš Golembiovský continue; 1418fed39564STomáš Golembiovský } 1419fed39564STomáš Golembiovský disk = g_new0(GuestDiskInfo, 1); 1420fed39564STomáš Golembiovský disk->name = dev_name; 1421fed39564STomáš Golembiovský disk->partition = false; 1422fed39564STomáš Golembiovský disk->alias = get_alias_for_syspath(disk_dir); 1423fed39564STomáš Golembiovský disk->has_alias = (disk->alias != NULL); 142454aa3de7SEric Blake QAPI_LIST_PREPEND(ret, disk); 1425fed39564STomáš Golembiovský 1426fed39564STomáš Golembiovský /* Get address for non-virtual devices */ 1427fed39564STomáš Golembiovský bool is_virtual = is_disk_virtual(disk_dir, &local_err); 1428fed39564STomáš Golembiovský if (local_err != NULL) { 1429fed39564STomáš Golembiovský g_debug(" failed to check disk path, ignoring error: %s", 1430fed39564STomáš Golembiovský error_get_pretty(local_err)); 1431fed39564STomáš Golembiovský error_free(local_err); 1432fed39564STomáš Golembiovský local_err = NULL; 1433fed39564STomáš Golembiovský /* Don't try to get the address */ 1434fed39564STomáš Golembiovský is_virtual = true; 1435fed39564STomáš Golembiovský } 1436fed39564STomáš Golembiovský if (!is_virtual) { 1437fed39564STomáš Golembiovský disk->address = get_disk_address(disk_dir, &local_err); 1438fed39564STomáš Golembiovský if (local_err != NULL) { 1439fed39564STomáš Golembiovský g_debug(" failed to get device info, ignoring error: %s", 1440fed39564STomáš Golembiovský error_get_pretty(local_err)); 1441fed39564STomáš Golembiovský error_free(local_err); 1442fed39564STomáš Golembiovský local_err = NULL; 1443fed39564STomáš Golembiovský } else if (disk->address != NULL) { 1444fed39564STomáš Golembiovský disk->has_address = true; 1445fed39564STomáš Golembiovský } 1446fed39564STomáš Golembiovský } 1447fed39564STomáš Golembiovský 1448fed39564STomáš Golembiovský get_disk_deps(disk_dir, disk); 1449fed39564STomáš Golembiovský ret = get_disk_partitions(ret, de->d_name, disk_dir, dev_name); 1450fed39564STomáš Golembiovský } 1451b1b9ab1cSMichael Roth 1452b1b9ab1cSMichael Roth closedir(dp); 1453b1b9ab1cSMichael Roth 1454fed39564STomáš Golembiovský return ret; 1455fed39564STomáš Golembiovský } 1456fed39564STomáš Golembiovský 1457fed39564STomáš Golembiovský #else 1458fed39564STomáš Golembiovský 1459fed39564STomáš Golembiovský GuestDiskInfoList *qmp_guest_get_disks(Error **errp) 1460fed39564STomáš Golembiovský { 1461fed39564STomáš Golembiovský error_setg(errp, QERR_UNSUPPORTED); 1462fed39564STomáš Golembiovský return NULL; 1463fed39564STomáš Golembiovský } 1464fed39564STomáš Golembiovský 1465fed39564STomáš Golembiovský #endif 1466fed39564STomáš Golembiovský 146746d4c572STomoki Sekiyama /* Return a list of the disk device(s)' info which @mount lies on */ 146846d4c572STomoki Sekiyama static GuestFilesystemInfo *build_guest_fsinfo(struct FsMount *mount, 146946d4c572STomoki Sekiyama Error **errp) 147046d4c572STomoki Sekiyama { 147146d4c572STomoki Sekiyama GuestFilesystemInfo *fs = g_malloc0(sizeof(*fs)); 147225b5ff1aSChen Hanxiao struct statvfs buf; 147325b5ff1aSChen Hanxiao unsigned long used, nonroot_total, fr_size; 147446d4c572STomoki Sekiyama char *devpath = g_strdup_printf("/sys/dev/block/%u:%u", 147546d4c572STomoki Sekiyama mount->devmajor, mount->devminor); 147646d4c572STomoki Sekiyama 147746d4c572STomoki Sekiyama fs->mountpoint = g_strdup(mount->dirname); 147846d4c572STomoki Sekiyama fs->type = g_strdup(mount->devtype); 147946d4c572STomoki Sekiyama build_guest_fsinfo_for_device(devpath, fs, errp); 148046d4c572STomoki Sekiyama 148125b5ff1aSChen Hanxiao if (statvfs(fs->mountpoint, &buf) == 0) { 148225b5ff1aSChen Hanxiao fr_size = buf.f_frsize; 148325b5ff1aSChen Hanxiao used = buf.f_blocks - buf.f_bfree; 148425b5ff1aSChen Hanxiao nonroot_total = used + buf.f_bavail; 148525b5ff1aSChen Hanxiao fs->used_bytes = used * fr_size; 148625b5ff1aSChen Hanxiao fs->total_bytes = nonroot_total * fr_size; 148725b5ff1aSChen Hanxiao 148825b5ff1aSChen Hanxiao fs->has_total_bytes = true; 148925b5ff1aSChen Hanxiao fs->has_used_bytes = true; 149025b5ff1aSChen Hanxiao } 149125b5ff1aSChen Hanxiao 149246d4c572STomoki Sekiyama g_free(devpath); 149325b5ff1aSChen Hanxiao 149446d4c572STomoki Sekiyama return fs; 149546d4c572STomoki Sekiyama } 149646d4c572STomoki Sekiyama 149746d4c572STomoki Sekiyama GuestFilesystemInfoList *qmp_guest_get_fsinfo(Error **errp) 149846d4c572STomoki Sekiyama { 149946d4c572STomoki Sekiyama FsMountList mounts; 150046d4c572STomoki Sekiyama struct FsMount *mount; 150154aa3de7SEric Blake GuestFilesystemInfoList *ret = NULL; 150246d4c572STomoki Sekiyama Error *local_err = NULL; 150346d4c572STomoki Sekiyama 150446d4c572STomoki Sekiyama QTAILQ_INIT(&mounts); 150546d4c572STomoki Sekiyama build_fs_mount_list(&mounts, &local_err); 150646d4c572STomoki Sekiyama if (local_err) { 150746d4c572STomoki Sekiyama error_propagate(errp, local_err); 150846d4c572STomoki Sekiyama return NULL; 150946d4c572STomoki Sekiyama } 151046d4c572STomoki Sekiyama 151146d4c572STomoki Sekiyama QTAILQ_FOREACH(mount, &mounts, next) { 151246d4c572STomoki Sekiyama g_debug("Building guest fsinfo for '%s'", mount->dirname); 151346d4c572STomoki Sekiyama 151454aa3de7SEric Blake QAPI_LIST_PREPEND(ret, build_guest_fsinfo(mount, &local_err)); 151546d4c572STomoki Sekiyama if (local_err) { 151646d4c572STomoki Sekiyama error_propagate(errp, local_err); 151746d4c572STomoki Sekiyama qapi_free_GuestFilesystemInfoList(ret); 151846d4c572STomoki Sekiyama ret = NULL; 151946d4c572STomoki Sekiyama break; 152046d4c572STomoki Sekiyama } 152146d4c572STomoki Sekiyama } 152246d4c572STomoki Sekiyama 152346d4c572STomoki Sekiyama free_fs_mount_list(&mounts); 152446d4c572STomoki Sekiyama return ret; 152546d4c572STomoki Sekiyama } 152646d4c572STomoki Sekiyama 152746d4c572STomoki Sekiyama 1528ec0f694cSTomoki Sekiyama typedef enum { 1529ec0f694cSTomoki Sekiyama FSFREEZE_HOOK_THAW = 0, 1530ec0f694cSTomoki Sekiyama FSFREEZE_HOOK_FREEZE, 1531ec0f694cSTomoki Sekiyama } FsfreezeHookArg; 1532ec0f694cSTomoki Sekiyama 153313a439ecSStefan Weil static const char *fsfreeze_hook_arg_string[] = { 1534ec0f694cSTomoki Sekiyama "thaw", 1535ec0f694cSTomoki Sekiyama "freeze", 1536ec0f694cSTomoki Sekiyama }; 1537ec0f694cSTomoki Sekiyama 153877dbc81bSMarkus Armbruster static void execute_fsfreeze_hook(FsfreezeHookArg arg, Error **errp) 1539ec0f694cSTomoki Sekiyama { 1540ec0f694cSTomoki Sekiyama int status; 1541ec0f694cSTomoki Sekiyama pid_t pid; 1542ec0f694cSTomoki Sekiyama const char *hook; 1543ec0f694cSTomoki Sekiyama const char *arg_str = fsfreeze_hook_arg_string[arg]; 1544ec0f694cSTomoki Sekiyama Error *local_err = NULL; 1545ec0f694cSTomoki Sekiyama 1546ec0f694cSTomoki Sekiyama hook = ga_fsfreeze_hook(ga_state); 1547ec0f694cSTomoki Sekiyama if (!hook) { 1548ec0f694cSTomoki Sekiyama return; 1549ec0f694cSTomoki Sekiyama } 1550ec0f694cSTomoki Sekiyama if (access(hook, X_OK) != 0) { 155177dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "can't access fsfreeze hook '%s'", hook); 1552ec0f694cSTomoki Sekiyama return; 1553ec0f694cSTomoki Sekiyama } 1554ec0f694cSTomoki Sekiyama 1555ec0f694cSTomoki Sekiyama slog("executing fsfreeze hook with arg '%s'", arg_str); 1556ec0f694cSTomoki Sekiyama pid = fork(); 1557ec0f694cSTomoki Sekiyama if (pid == 0) { 1558ec0f694cSTomoki Sekiyama setsid(); 1559ec0f694cSTomoki Sekiyama reopen_fd_to_null(0); 1560ec0f694cSTomoki Sekiyama reopen_fd_to_null(1); 1561ec0f694cSTomoki Sekiyama reopen_fd_to_null(2); 1562ec0f694cSTomoki Sekiyama 1563fcc41961SMarc-André Lureau execl(hook, hook, arg_str, NULL); 1564ec0f694cSTomoki Sekiyama _exit(EXIT_FAILURE); 1565ec0f694cSTomoki Sekiyama } else if (pid < 0) { 156677dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to create child process"); 1567ec0f694cSTomoki Sekiyama return; 1568ec0f694cSTomoki Sekiyama } 1569ec0f694cSTomoki Sekiyama 1570ec0f694cSTomoki Sekiyama ga_wait_child(pid, &status, &local_err); 157184d18f06SMarkus Armbruster if (local_err) { 157277dbc81bSMarkus Armbruster error_propagate(errp, local_err); 1573ec0f694cSTomoki Sekiyama return; 1574ec0f694cSTomoki Sekiyama } 1575ec0f694cSTomoki Sekiyama 1576ec0f694cSTomoki Sekiyama if (!WIFEXITED(status)) { 157777dbc81bSMarkus Armbruster error_setg(errp, "fsfreeze hook has terminated abnormally"); 1578ec0f694cSTomoki Sekiyama return; 1579ec0f694cSTomoki Sekiyama } 1580ec0f694cSTomoki Sekiyama 1581ec0f694cSTomoki Sekiyama status = WEXITSTATUS(status); 1582ec0f694cSTomoki Sekiyama if (status) { 158377dbc81bSMarkus Armbruster error_setg(errp, "fsfreeze hook has failed with status %d", status); 1584ec0f694cSTomoki Sekiyama return; 1585ec0f694cSTomoki Sekiyama } 1586ec0f694cSTomoki Sekiyama } 1587ec0f694cSTomoki Sekiyama 1588c216e5adSMichael Roth /* 1589c216e5adSMichael Roth * Return status of freeze/thaw 1590c216e5adSMichael Roth */ 159177dbc81bSMarkus Armbruster GuestFsfreezeStatus qmp_guest_fsfreeze_status(Error **errp) 1592c216e5adSMichael Roth { 1593f22d85e9SMichael Roth if (ga_is_frozen(ga_state)) { 1594f22d85e9SMichael Roth return GUEST_FSFREEZE_STATUS_FROZEN; 1595f22d85e9SMichael Roth } 1596f22d85e9SMichael Roth 1597f22d85e9SMichael Roth return GUEST_FSFREEZE_STATUS_THAWED; 1598c216e5adSMichael Roth } 1599c216e5adSMichael Roth 1600e99bce20STomoki Sekiyama int64_t qmp_guest_fsfreeze_freeze(Error **errp) 1601e99bce20STomoki Sekiyama { 1602e99bce20STomoki Sekiyama return qmp_guest_fsfreeze_freeze_list(false, NULL, errp); 1603e99bce20STomoki Sekiyama } 1604e99bce20STomoki Sekiyama 1605c216e5adSMichael Roth /* 1606c216e5adSMichael Roth * Walk list of mounted file systems in the guest, and freeze the ones which 1607c216e5adSMichael Roth * are real local file systems. 1608c216e5adSMichael Roth */ 1609e99bce20STomoki Sekiyama int64_t qmp_guest_fsfreeze_freeze_list(bool has_mountpoints, 1610e99bce20STomoki Sekiyama strList *mountpoints, 1611e99bce20STomoki Sekiyama Error **errp) 1612c216e5adSMichael Roth { 1613c216e5adSMichael Roth int ret = 0, i = 0; 1614e99bce20STomoki Sekiyama strList *list; 1615af02203fSPaolo Bonzini FsMountList mounts; 1616af02203fSPaolo Bonzini struct FsMount *mount; 1617261551d1SLuiz Capitulino Error *local_err = NULL; 1618c216e5adSMichael Roth int fd; 1619c216e5adSMichael Roth 1620c216e5adSMichael Roth slog("guest-fsfreeze called"); 1621c216e5adSMichael Roth 1622ec0f694cSTomoki Sekiyama execute_fsfreeze_hook(FSFREEZE_HOOK_FREEZE, &local_err); 162384d18f06SMarkus Armbruster if (local_err) { 162477dbc81bSMarkus Armbruster error_propagate(errp, local_err); 1625ec0f694cSTomoki Sekiyama return -1; 1626ec0f694cSTomoki Sekiyama } 1627ec0f694cSTomoki Sekiyama 16289e8aded4SMichael Roth QTAILQ_INIT(&mounts); 1629261551d1SLuiz Capitulino build_fs_mount_list(&mounts, &local_err); 163084d18f06SMarkus Armbruster if (local_err) { 163177dbc81bSMarkus Armbruster error_propagate(errp, local_err); 1632261551d1SLuiz Capitulino return -1; 1633c216e5adSMichael Roth } 1634c216e5adSMichael Roth 1635c216e5adSMichael Roth /* cannot risk guest agent blocking itself on a write in this state */ 1636f22d85e9SMichael Roth ga_set_frozen(ga_state); 1637c216e5adSMichael Roth 1638eae3eb3eSPaolo Bonzini QTAILQ_FOREACH_REVERSE(mount, &mounts, next) { 1639e99bce20STomoki Sekiyama /* To issue fsfreeze in the reverse order of mounts, check if the 1640e99bce20STomoki Sekiyama * mount is listed in the list here */ 1641e99bce20STomoki Sekiyama if (has_mountpoints) { 1642e99bce20STomoki Sekiyama for (list = mountpoints; list; list = list->next) { 1643e99bce20STomoki Sekiyama if (strcmp(list->value, mount->dirname) == 0) { 1644e99bce20STomoki Sekiyama break; 1645e99bce20STomoki Sekiyama } 1646e99bce20STomoki Sekiyama } 1647e99bce20STomoki Sekiyama if (!list) { 1648e99bce20STomoki Sekiyama continue; 1649e99bce20STomoki Sekiyama } 1650e99bce20STomoki Sekiyama } 1651e99bce20STomoki Sekiyama 1652448058aaSDaniel P. Berrangé fd = qemu_open_old(mount->dirname, O_RDONLY); 1653c216e5adSMichael Roth if (fd == -1) { 165477dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to open %s", mount->dirname); 1655c216e5adSMichael Roth goto error; 1656c216e5adSMichael Roth } 1657c216e5adSMichael Roth 1658e35916acSMichael Tokarev /* we try to cull filesystems we know won't work in advance, but other 1659e35916acSMichael Tokarev * filesystems may not implement fsfreeze for less obvious reasons. 16609e8aded4SMichael Roth * these will report EOPNOTSUPP. we simply ignore these when tallying 16619e8aded4SMichael Roth * the number of frozen filesystems. 1662ce2eb6c4SPeter Lieven * if a filesystem is mounted more than once (aka bind mount) a 1663ce2eb6c4SPeter Lieven * consecutive attempt to freeze an already frozen filesystem will 1664ce2eb6c4SPeter Lieven * return EBUSY. 16659e8aded4SMichael Roth * 16669e8aded4SMichael Roth * any other error means a failure to freeze a filesystem we 16679e8aded4SMichael Roth * expect to be freezable, so return an error in those cases 16689e8aded4SMichael Roth * and return system to thawed state. 1669c216e5adSMichael Roth */ 1670c216e5adSMichael Roth ret = ioctl(fd, FIFREEZE); 16719e8aded4SMichael Roth if (ret == -1) { 1672ce2eb6c4SPeter Lieven if (errno != EOPNOTSUPP && errno != EBUSY) { 167377dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to freeze %s", 1674617fbbc1SLuiz Capitulino mount->dirname); 1675c216e5adSMichael Roth close(fd); 1676c216e5adSMichael Roth goto error; 1677c216e5adSMichael Roth } 16789e8aded4SMichael Roth } else { 1679c216e5adSMichael Roth i++; 1680c216e5adSMichael Roth } 16819e8aded4SMichael Roth close(fd); 16829e8aded4SMichael Roth } 1683c216e5adSMichael Roth 1684af02203fSPaolo Bonzini free_fs_mount_list(&mounts); 168565650f01SChen Hanxiao /* We may not issue any FIFREEZE here. 168665650f01SChen Hanxiao * Just unset ga_state here and ready for the next call. 168765650f01SChen Hanxiao */ 168865650f01SChen Hanxiao if (i == 0) { 168965650f01SChen Hanxiao ga_unset_frozen(ga_state); 169065650f01SChen Hanxiao } 1691c216e5adSMichael Roth return i; 1692c216e5adSMichael Roth 1693c216e5adSMichael Roth error: 1694af02203fSPaolo Bonzini free_fs_mount_list(&mounts); 1695c216e5adSMichael Roth qmp_guest_fsfreeze_thaw(NULL); 1696c216e5adSMichael Roth return 0; 1697c216e5adSMichael Roth } 1698c216e5adSMichael Roth 1699c216e5adSMichael Roth /* 1700c216e5adSMichael Roth * Walk list of frozen file systems in the guest, and thaw them. 1701c216e5adSMichael Roth */ 170277dbc81bSMarkus Armbruster int64_t qmp_guest_fsfreeze_thaw(Error **errp) 1703c216e5adSMichael Roth { 1704c216e5adSMichael Roth int ret; 1705af02203fSPaolo Bonzini FsMountList mounts; 1706af02203fSPaolo Bonzini FsMount *mount; 17079e8aded4SMichael Roth int fd, i = 0, logged; 1708261551d1SLuiz Capitulino Error *local_err = NULL; 1709c216e5adSMichael Roth 17109e8aded4SMichael Roth QTAILQ_INIT(&mounts); 1711261551d1SLuiz Capitulino build_fs_mount_list(&mounts, &local_err); 171284d18f06SMarkus Armbruster if (local_err) { 171377dbc81bSMarkus Armbruster error_propagate(errp, local_err); 17149e8aded4SMichael Roth return 0; 17159e8aded4SMichael Roth } 17169e8aded4SMichael Roth 17179e8aded4SMichael Roth QTAILQ_FOREACH(mount, &mounts, next) { 17189e8aded4SMichael Roth logged = false; 1719448058aaSDaniel P. Berrangé fd = qemu_open_old(mount->dirname, O_RDONLY); 1720c216e5adSMichael Roth if (fd == -1) { 1721c216e5adSMichael Roth continue; 1722c216e5adSMichael Roth } 17239e8aded4SMichael Roth /* we have no way of knowing whether a filesystem was actually unfrozen 17249e8aded4SMichael Roth * as a result of a successful call to FITHAW, only that if an error 17259e8aded4SMichael Roth * was returned the filesystem was *not* unfrozen by that particular 17269e8aded4SMichael Roth * call. 17279e8aded4SMichael Roth * 1728a31f0531SJim Meyering * since multiple preceding FIFREEZEs require multiple calls to FITHAW 17299e8aded4SMichael Roth * to unfreeze, continuing issuing FITHAW until an error is returned, 17309e8aded4SMichael Roth * in which case either the filesystem is in an unfreezable state, or, 17319e8aded4SMichael Roth * more likely, it was thawed previously (and remains so afterward). 17329e8aded4SMichael Roth * 17339e8aded4SMichael Roth * also, since the most recent successful call is the one that did 17349e8aded4SMichael Roth * the actual unfreeze, we can use this to provide an accurate count 17359e8aded4SMichael Roth * of the number of filesystems unfrozen by guest-fsfreeze-thaw, which 17369e8aded4SMichael Roth * may * be useful for determining whether a filesystem was unfrozen 17379e8aded4SMichael Roth * during the freeze/thaw phase by a process other than qemu-ga. 17389e8aded4SMichael Roth */ 17399e8aded4SMichael Roth do { 1740c216e5adSMichael Roth ret = ioctl(fd, FITHAW); 17419e8aded4SMichael Roth if (ret == 0 && !logged) { 1742c216e5adSMichael Roth i++; 17439e8aded4SMichael Roth logged = true; 17449e8aded4SMichael Roth } 17459e8aded4SMichael Roth } while (ret == 0); 17469e8aded4SMichael Roth close(fd); 1747c216e5adSMichael Roth } 1748c216e5adSMichael Roth 1749f22d85e9SMichael Roth ga_unset_frozen(ga_state); 1750af02203fSPaolo Bonzini free_fs_mount_list(&mounts); 1751ec0f694cSTomoki Sekiyama 175277dbc81bSMarkus Armbruster execute_fsfreeze_hook(FSFREEZE_HOOK_THAW, errp); 1753ec0f694cSTomoki Sekiyama 1754c216e5adSMichael Roth return i; 1755c216e5adSMichael Roth } 1756c216e5adSMichael Roth 1757c216e5adSMichael Roth static void guest_fsfreeze_cleanup(void) 1758c216e5adSMichael Roth { 1759c216e5adSMichael Roth Error *err = NULL; 1760c216e5adSMichael Roth 1761f22d85e9SMichael Roth if (ga_is_frozen(ga_state) == GUEST_FSFREEZE_STATUS_FROZEN) { 17626f686749SMarkus Armbruster qmp_guest_fsfreeze_thaw(&err); 17636f686749SMarkus Armbruster if (err) { 17646f686749SMarkus Armbruster slog("failed to clean up frozen filesystems: %s", 17656f686749SMarkus Armbruster error_get_pretty(err)); 17666f686749SMarkus Armbruster error_free(err); 1767c216e5adSMichael Roth } 1768c216e5adSMichael Roth } 1769c216e5adSMichael Roth } 1770e72c3f2eSMichael Roth #endif /* CONFIG_FSFREEZE */ 1771c216e5adSMichael Roth 1772eab5fd59SPaolo Bonzini #if defined(CONFIG_FSTRIM) 1773eab5fd59SPaolo Bonzini /* 1774eab5fd59SPaolo Bonzini * Walk list of mounted file systems in the guest, and trim them. 1775eab5fd59SPaolo Bonzini */ 1776e82855d9SJustin Ossevoort GuestFilesystemTrimResponse * 1777e82855d9SJustin Ossevoort qmp_guest_fstrim(bool has_minimum, int64_t minimum, Error **errp) 1778eab5fd59SPaolo Bonzini { 1779e82855d9SJustin Ossevoort GuestFilesystemTrimResponse *response; 1780e82855d9SJustin Ossevoort GuestFilesystemTrimResult *result; 1781eab5fd59SPaolo Bonzini int ret = 0; 1782eab5fd59SPaolo Bonzini FsMountList mounts; 1783eab5fd59SPaolo Bonzini struct FsMount *mount; 1784eab5fd59SPaolo Bonzini int fd; 1785261551d1SLuiz Capitulino Error *local_err = NULL; 178673a652a1SJustin Ossevoort struct fstrim_range r; 1787eab5fd59SPaolo Bonzini 1788eab5fd59SPaolo Bonzini slog("guest-fstrim called"); 1789eab5fd59SPaolo Bonzini 1790eab5fd59SPaolo Bonzini QTAILQ_INIT(&mounts); 1791261551d1SLuiz Capitulino build_fs_mount_list(&mounts, &local_err); 179284d18f06SMarkus Armbruster if (local_err) { 179377dbc81bSMarkus Armbruster error_propagate(errp, local_err); 1794e82855d9SJustin Ossevoort return NULL; 1795eab5fd59SPaolo Bonzini } 1796eab5fd59SPaolo Bonzini 1797e82855d9SJustin Ossevoort response = g_malloc0(sizeof(*response)); 1798e82855d9SJustin Ossevoort 1799eab5fd59SPaolo Bonzini QTAILQ_FOREACH(mount, &mounts, next) { 1800e82855d9SJustin Ossevoort result = g_malloc0(sizeof(*result)); 1801e82855d9SJustin Ossevoort result->path = g_strdup(mount->dirname); 1802e82855d9SJustin Ossevoort 180354aa3de7SEric Blake QAPI_LIST_PREPEND(response->paths, result); 1804e82855d9SJustin Ossevoort 1805448058aaSDaniel P. Berrangé fd = qemu_open_old(mount->dirname, O_RDONLY); 1806eab5fd59SPaolo Bonzini if (fd == -1) { 1807e82855d9SJustin Ossevoort result->error = g_strdup_printf("failed to open: %s", 1808e82855d9SJustin Ossevoort strerror(errno)); 1809e82855d9SJustin Ossevoort result->has_error = true; 1810e82855d9SJustin Ossevoort continue; 1811eab5fd59SPaolo Bonzini } 1812eab5fd59SPaolo Bonzini 1813e35916acSMichael Tokarev /* We try to cull filesystems we know won't work in advance, but other 1814e35916acSMichael Tokarev * filesystems may not implement fstrim for less obvious reasons. 1815e35916acSMichael Tokarev * These will report EOPNOTSUPP; while in some other cases ENOTTY 1816e35916acSMichael Tokarev * will be reported (e.g. CD-ROMs). 1817e82855d9SJustin Ossevoort * Any other error means an unexpected error. 1818eab5fd59SPaolo Bonzini */ 181973a652a1SJustin Ossevoort r.start = 0; 182073a652a1SJustin Ossevoort r.len = -1; 182173a652a1SJustin Ossevoort r.minlen = has_minimum ? minimum : 0; 1822eab5fd59SPaolo Bonzini ret = ioctl(fd, FITRIM, &r); 1823eab5fd59SPaolo Bonzini if (ret == -1) { 1824e82855d9SJustin Ossevoort result->has_error = true; 1825e82855d9SJustin Ossevoort if (errno == ENOTTY || errno == EOPNOTSUPP) { 1826e82855d9SJustin Ossevoort result->error = g_strdup("trim not supported"); 1827e82855d9SJustin Ossevoort } else { 1828e82855d9SJustin Ossevoort result->error = g_strdup_printf("failed to trim: %s", 1829e82855d9SJustin Ossevoort strerror(errno)); 1830e82855d9SJustin Ossevoort } 1831eab5fd59SPaolo Bonzini close(fd); 1832e82855d9SJustin Ossevoort continue; 1833eab5fd59SPaolo Bonzini } 1834e82855d9SJustin Ossevoort 1835e82855d9SJustin Ossevoort result->has_minimum = true; 1836e82855d9SJustin Ossevoort result->minimum = r.minlen; 1837e82855d9SJustin Ossevoort result->has_trimmed = true; 1838e82855d9SJustin Ossevoort result->trimmed = r.len; 1839eab5fd59SPaolo Bonzini close(fd); 1840eab5fd59SPaolo Bonzini } 1841eab5fd59SPaolo Bonzini 1842eab5fd59SPaolo Bonzini free_fs_mount_list(&mounts); 1843e82855d9SJustin Ossevoort return response; 1844eab5fd59SPaolo Bonzini } 1845eab5fd59SPaolo Bonzini #endif /* CONFIG_FSTRIM */ 1846eab5fd59SPaolo Bonzini 1847eab5fd59SPaolo Bonzini 184811d0f125SLuiz Capitulino #define LINUX_SYS_STATE_FILE "/sys/power/state" 184911d0f125SLuiz Capitulino #define SUSPEND_SUPPORTED 0 185011d0f125SLuiz Capitulino #define SUSPEND_NOT_SUPPORTED 1 185111d0f125SLuiz Capitulino 18528b020b5eSDaniel Henrique Barboza typedef enum { 18538b020b5eSDaniel Henrique Barboza SUSPEND_MODE_DISK = 0, 18548b020b5eSDaniel Henrique Barboza SUSPEND_MODE_RAM = 1, 18558b020b5eSDaniel Henrique Barboza SUSPEND_MODE_HYBRID = 2, 18568b020b5eSDaniel Henrique Barboza } SuspendMode; 18578b020b5eSDaniel Henrique Barboza 18588b020b5eSDaniel Henrique Barboza /* 18598b020b5eSDaniel Henrique Barboza * Executes a command in a child process using g_spawn_sync, 18608b020b5eSDaniel Henrique Barboza * returning an int >= 0 representing the exit status of the 18618b020b5eSDaniel Henrique Barboza * process. 18628b020b5eSDaniel Henrique Barboza * 18638b020b5eSDaniel Henrique Barboza * If the program wasn't found in path, returns -1. 18648b020b5eSDaniel Henrique Barboza * 18658b020b5eSDaniel Henrique Barboza * If a problem happened when creating the child process, 18668b020b5eSDaniel Henrique Barboza * returns -1 and errp is set. 18678b020b5eSDaniel Henrique Barboza */ 18688b020b5eSDaniel Henrique Barboza static int run_process_child(const char *command[], Error **errp) 18698b020b5eSDaniel Henrique Barboza { 18708b020b5eSDaniel Henrique Barboza int exit_status, spawn_flag; 18718b020b5eSDaniel Henrique Barboza GError *g_err = NULL; 18728b020b5eSDaniel Henrique Barboza bool success; 18738b020b5eSDaniel Henrique Barboza 18748b020b5eSDaniel Henrique Barboza spawn_flag = G_SPAWN_SEARCH_PATH | G_SPAWN_STDOUT_TO_DEV_NULL | 18758b020b5eSDaniel Henrique Barboza G_SPAWN_STDERR_TO_DEV_NULL; 18768b020b5eSDaniel Henrique Barboza 1877fcc41961SMarc-André Lureau success = g_spawn_sync(NULL, (char **)command, NULL, spawn_flag, 18788b020b5eSDaniel Henrique Barboza NULL, NULL, NULL, NULL, 18798b020b5eSDaniel Henrique Barboza &exit_status, &g_err); 18808b020b5eSDaniel Henrique Barboza 18818b020b5eSDaniel Henrique Barboza if (success) { 18828b020b5eSDaniel Henrique Barboza return WEXITSTATUS(exit_status); 18838b020b5eSDaniel Henrique Barboza } 18848b020b5eSDaniel Henrique Barboza 18858b020b5eSDaniel Henrique Barboza if (g_err && (g_err->code != G_SPAWN_ERROR_NOENT)) { 18868b020b5eSDaniel Henrique Barboza error_setg(errp, "failed to create child process, error '%s'", 18878b020b5eSDaniel Henrique Barboza g_err->message); 18888b020b5eSDaniel Henrique Barboza } 18898b020b5eSDaniel Henrique Barboza 18908b020b5eSDaniel Henrique Barboza g_error_free(g_err); 18918b020b5eSDaniel Henrique Barboza return -1; 18928b020b5eSDaniel Henrique Barboza } 18938b020b5eSDaniel Henrique Barboza 1894067927d6SDaniel Henrique Barboza static bool systemd_supports_mode(SuspendMode mode, Error **errp) 1895067927d6SDaniel Henrique Barboza { 1896067927d6SDaniel Henrique Barboza const char *systemctl_args[3] = {"systemd-hibernate", "systemd-suspend", 1897067927d6SDaniel Henrique Barboza "systemd-hybrid-sleep"}; 1898067927d6SDaniel Henrique Barboza const char *cmd[4] = {"systemctl", "status", systemctl_args[mode], NULL}; 1899067927d6SDaniel Henrique Barboza int status; 1900067927d6SDaniel Henrique Barboza 1901992861fbSMarkus Armbruster status = run_process_child(cmd, errp); 1902067927d6SDaniel Henrique Barboza 1903067927d6SDaniel Henrique Barboza /* 1904067927d6SDaniel Henrique Barboza * systemctl status uses LSB return codes so we can expect 1905067927d6SDaniel Henrique Barboza * status > 0 and be ok. To assert if the guest has support 1906067927d6SDaniel Henrique Barboza * for the selected suspend mode, status should be < 4. 4 is 1907067927d6SDaniel Henrique Barboza * the code for unknown service status, the return value when 1908067927d6SDaniel Henrique Barboza * the service does not exist. A common value is status = 3 1909067927d6SDaniel Henrique Barboza * (program is not running). 1910067927d6SDaniel Henrique Barboza */ 1911067927d6SDaniel Henrique Barboza if (status > 0 && status < 4) { 1912067927d6SDaniel Henrique Barboza return true; 1913067927d6SDaniel Henrique Barboza } 1914067927d6SDaniel Henrique Barboza 1915067927d6SDaniel Henrique Barboza return false; 1916067927d6SDaniel Henrique Barboza } 1917067927d6SDaniel Henrique Barboza 1918067927d6SDaniel Henrique Barboza static void systemd_suspend(SuspendMode mode, Error **errp) 1919067927d6SDaniel Henrique Barboza { 1920067927d6SDaniel Henrique Barboza Error *local_err = NULL; 1921067927d6SDaniel Henrique Barboza const char *systemctl_args[3] = {"hibernate", "suspend", "hybrid-sleep"}; 1922067927d6SDaniel Henrique Barboza const char *cmd[3] = {"systemctl", systemctl_args[mode], NULL}; 1923067927d6SDaniel Henrique Barboza int status; 1924067927d6SDaniel Henrique Barboza 1925067927d6SDaniel Henrique Barboza status = run_process_child(cmd, &local_err); 1926067927d6SDaniel Henrique Barboza 1927067927d6SDaniel Henrique Barboza if (status == 0) { 1928067927d6SDaniel Henrique Barboza return; 1929067927d6SDaniel Henrique Barboza } 1930067927d6SDaniel Henrique Barboza 1931067927d6SDaniel Henrique Barboza if ((status == -1) && !local_err) { 1932067927d6SDaniel Henrique Barboza error_setg(errp, "the helper program 'systemctl %s' was not found", 1933067927d6SDaniel Henrique Barboza systemctl_args[mode]); 1934067927d6SDaniel Henrique Barboza return; 1935067927d6SDaniel Henrique Barboza } 1936067927d6SDaniel Henrique Barboza 1937067927d6SDaniel Henrique Barboza if (local_err) { 1938067927d6SDaniel Henrique Barboza error_propagate(errp, local_err); 1939067927d6SDaniel Henrique Barboza } else { 1940067927d6SDaniel Henrique Barboza error_setg(errp, "the helper program 'systemctl %s' returned an " 1941067927d6SDaniel Henrique Barboza "unexpected exit status code (%d)", 1942067927d6SDaniel Henrique Barboza systemctl_args[mode], status); 1943067927d6SDaniel Henrique Barboza } 1944067927d6SDaniel Henrique Barboza } 1945067927d6SDaniel Henrique Barboza 19468b020b5eSDaniel Henrique Barboza static bool pmutils_supports_mode(SuspendMode mode, Error **errp) 194711d0f125SLuiz Capitulino { 19486b26e837SLuiz Capitulino Error *local_err = NULL; 19498b020b5eSDaniel Henrique Barboza const char *pmutils_args[3] = {"--hibernate", "--suspend", 19508b020b5eSDaniel Henrique Barboza "--suspend-hybrid"}; 19518b020b5eSDaniel Henrique Barboza const char *cmd[3] = {"pm-is-supported", pmutils_args[mode], NULL}; 1952dc8764f0SLuiz Capitulino int status; 195311d0f125SLuiz Capitulino 19548b020b5eSDaniel Henrique Barboza status = run_process_child(cmd, &local_err); 1955304a0fcbSDaniel Henrique Barboza 19568b020b5eSDaniel Henrique Barboza if (status == SUSPEND_SUPPORTED) { 19578b020b5eSDaniel Henrique Barboza return true; 1958304a0fcbSDaniel Henrique Barboza } 1959304a0fcbSDaniel Henrique Barboza 19608b020b5eSDaniel Henrique Barboza if ((status == -1) && !local_err) { 19618b020b5eSDaniel Henrique Barboza return false; 1962a5fcf0e3SDaniel Henrique Barboza } 196311d0f125SLuiz Capitulino 196484d18f06SMarkus Armbruster if (local_err) { 196577dbc81bSMarkus Armbruster error_propagate(errp, local_err); 19668b020b5eSDaniel Henrique Barboza } else { 196777dbc81bSMarkus Armbruster error_setg(errp, 19688b020b5eSDaniel Henrique Barboza "the helper program '%s' returned an unexpected exit" 19698b020b5eSDaniel Henrique Barboza " status code (%d)", "pm-is-supported", status); 1970dc8764f0SLuiz Capitulino } 197111d0f125SLuiz Capitulino 19728b020b5eSDaniel Henrique Barboza return false; 1973a5fcf0e3SDaniel Henrique Barboza } 1974a5fcf0e3SDaniel Henrique Barboza 19758b020b5eSDaniel Henrique Barboza static void pmutils_suspend(SuspendMode mode, Error **errp) 1976246d76ebSDaniel Henrique Barboza { 1977246d76ebSDaniel Henrique Barboza Error *local_err = NULL; 19788b020b5eSDaniel Henrique Barboza const char *pmutils_binaries[3] = {"pm-hibernate", "pm-suspend", 19798b020b5eSDaniel Henrique Barboza "pm-suspend-hybrid"}; 19808b020b5eSDaniel Henrique Barboza const char *cmd[2] = {pmutils_binaries[mode], NULL}; 1981246d76ebSDaniel Henrique Barboza int status; 1982246d76ebSDaniel Henrique Barboza 19838b020b5eSDaniel Henrique Barboza status = run_process_child(cmd, &local_err); 1984246d76ebSDaniel Henrique Barboza 19858b020b5eSDaniel Henrique Barboza if (status == 0) { 1986246d76ebSDaniel Henrique Barboza return; 1987246d76ebSDaniel Henrique Barboza } 1988246d76ebSDaniel Henrique Barboza 19898b020b5eSDaniel Henrique Barboza if ((status == -1) && !local_err) { 19908b020b5eSDaniel Henrique Barboza error_setg(errp, "the helper program '%s' was not found", 19918b020b5eSDaniel Henrique Barboza pmutils_binaries[mode]); 1992246d76ebSDaniel Henrique Barboza return; 1993246d76ebSDaniel Henrique Barboza } 1994246d76ebSDaniel Henrique Barboza 1995246d76ebSDaniel Henrique Barboza if (local_err) { 1996246d76ebSDaniel Henrique Barboza error_propagate(errp, local_err); 19978b020b5eSDaniel Henrique Barboza } else { 1998246d76ebSDaniel Henrique Barboza error_setg(errp, 19998b020b5eSDaniel Henrique Barboza "the helper program '%s' returned an unexpected exit" 20008b020b5eSDaniel Henrique Barboza " status code (%d)", pmutils_binaries[mode], status); 20018b020b5eSDaniel Henrique Barboza } 2002246d76ebSDaniel Henrique Barboza } 2003246d76ebSDaniel Henrique Barboza 20048b020b5eSDaniel Henrique Barboza static bool linux_sys_state_supports_mode(SuspendMode mode, Error **errp) 2005a5fcf0e3SDaniel Henrique Barboza { 20068b020b5eSDaniel Henrique Barboza const char *sysfile_strs[3] = {"disk", "mem", NULL}; 20078b020b5eSDaniel Henrique Barboza const char *sysfile_str = sysfile_strs[mode]; 2008a5fcf0e3SDaniel Henrique Barboza char buf[32]; /* hopefully big enough */ 2009a5fcf0e3SDaniel Henrique Barboza int fd; 2010a5fcf0e3SDaniel Henrique Barboza ssize_t ret; 2011a5fcf0e3SDaniel Henrique Barboza 20128b020b5eSDaniel Henrique Barboza if (!sysfile_str) { 20138b020b5eSDaniel Henrique Barboza error_setg(errp, "unknown guest suspend mode"); 2014a5fcf0e3SDaniel Henrique Barboza return false; 2015a5fcf0e3SDaniel Henrique Barboza } 2016a5fcf0e3SDaniel Henrique Barboza 2017a5fcf0e3SDaniel Henrique Barboza fd = open(LINUX_SYS_STATE_FILE, O_RDONLY); 2018a5fcf0e3SDaniel Henrique Barboza if (fd < 0) { 2019a5fcf0e3SDaniel Henrique Barboza return false; 2020a5fcf0e3SDaniel Henrique Barboza } 2021a5fcf0e3SDaniel Henrique Barboza 2022a5fcf0e3SDaniel Henrique Barboza ret = read(fd, buf, sizeof(buf) - 1); 2023d9c745c1SPaolo Bonzini close(fd); 2024a5fcf0e3SDaniel Henrique Barboza if (ret <= 0) { 2025a5fcf0e3SDaniel Henrique Barboza return false; 2026a5fcf0e3SDaniel Henrique Barboza } 2027a5fcf0e3SDaniel Henrique Barboza buf[ret] = '\0'; 2028a5fcf0e3SDaniel Henrique Barboza 2029a5fcf0e3SDaniel Henrique Barboza if (strstr(buf, sysfile_str)) { 2030a5fcf0e3SDaniel Henrique Barboza return true; 2031a5fcf0e3SDaniel Henrique Barboza } 2032a5fcf0e3SDaniel Henrique Barboza return false; 2033a5fcf0e3SDaniel Henrique Barboza } 2034a5fcf0e3SDaniel Henrique Barboza 20358b020b5eSDaniel Henrique Barboza static void linux_sys_state_suspend(SuspendMode mode, Error **errp) 2036246d76ebSDaniel Henrique Barboza { 2037246d76ebSDaniel Henrique Barboza Error *local_err = NULL; 20388b020b5eSDaniel Henrique Barboza const char *sysfile_strs[3] = {"disk", "mem", NULL}; 20398b020b5eSDaniel Henrique Barboza const char *sysfile_str = sysfile_strs[mode]; 2040246d76ebSDaniel Henrique Barboza pid_t pid; 2041246d76ebSDaniel Henrique Barboza int status; 2042246d76ebSDaniel Henrique Barboza 20438b020b5eSDaniel Henrique Barboza if (!sysfile_str) { 2044246d76ebSDaniel Henrique Barboza error_setg(errp, "unknown guest suspend mode"); 2045246d76ebSDaniel Henrique Barboza return; 2046246d76ebSDaniel Henrique Barboza } 2047246d76ebSDaniel Henrique Barboza 2048246d76ebSDaniel Henrique Barboza pid = fork(); 2049246d76ebSDaniel Henrique Barboza if (!pid) { 2050246d76ebSDaniel Henrique Barboza /* child */ 2051246d76ebSDaniel Henrique Barboza int fd; 2052246d76ebSDaniel Henrique Barboza 2053246d76ebSDaniel Henrique Barboza setsid(); 2054246d76ebSDaniel Henrique Barboza reopen_fd_to_null(0); 2055246d76ebSDaniel Henrique Barboza reopen_fd_to_null(1); 2056246d76ebSDaniel Henrique Barboza reopen_fd_to_null(2); 2057246d76ebSDaniel Henrique Barboza 2058246d76ebSDaniel Henrique Barboza fd = open(LINUX_SYS_STATE_FILE, O_WRONLY); 2059246d76ebSDaniel Henrique Barboza if (fd < 0) { 2060246d76ebSDaniel Henrique Barboza _exit(EXIT_FAILURE); 2061246d76ebSDaniel Henrique Barboza } 2062246d76ebSDaniel Henrique Barboza 2063246d76ebSDaniel Henrique Barboza if (write(fd, sysfile_str, strlen(sysfile_str)) < 0) { 2064246d76ebSDaniel Henrique Barboza _exit(EXIT_FAILURE); 2065246d76ebSDaniel Henrique Barboza } 2066246d76ebSDaniel Henrique Barboza 2067246d76ebSDaniel Henrique Barboza _exit(EXIT_SUCCESS); 2068246d76ebSDaniel Henrique Barboza } else if (pid < 0) { 2069246d76ebSDaniel Henrique Barboza error_setg_errno(errp, errno, "failed to create child process"); 2070246d76ebSDaniel Henrique Barboza return; 2071246d76ebSDaniel Henrique Barboza } 2072246d76ebSDaniel Henrique Barboza 2073246d76ebSDaniel Henrique Barboza ga_wait_child(pid, &status, &local_err); 2074246d76ebSDaniel Henrique Barboza if (local_err) { 2075246d76ebSDaniel Henrique Barboza error_propagate(errp, local_err); 2076246d76ebSDaniel Henrique Barboza return; 2077246d76ebSDaniel Henrique Barboza } 2078246d76ebSDaniel Henrique Barboza 2079246d76ebSDaniel Henrique Barboza if (WEXITSTATUS(status)) { 2080246d76ebSDaniel Henrique Barboza error_setg(errp, "child process has failed to suspend"); 2081246d76ebSDaniel Henrique Barboza } 2082246d76ebSDaniel Henrique Barboza 2083246d76ebSDaniel Henrique Barboza } 2084246d76ebSDaniel Henrique Barboza 20858b020b5eSDaniel Henrique Barboza static void guest_suspend(SuspendMode mode, Error **errp) 208611d0f125SLuiz Capitulino { 20877b376087SLuiz Capitulino Error *local_err = NULL; 208873e1d8ebSDaniel Henrique Barboza bool mode_supported = false; 208911d0f125SLuiz Capitulino 209073e1d8ebSDaniel Henrique Barboza if (systemd_supports_mode(mode, &local_err)) { 209173e1d8ebSDaniel Henrique Barboza mode_supported = true; 2092067927d6SDaniel Henrique Barboza systemd_suspend(mode, &local_err); 209373e1d8ebSDaniel Henrique Barboza } 209473e1d8ebSDaniel Henrique Barboza 2095067927d6SDaniel Henrique Barboza if (!local_err) { 2096067927d6SDaniel Henrique Barboza return; 2097067927d6SDaniel Henrique Barboza } 2098067927d6SDaniel Henrique Barboza 2099067927d6SDaniel Henrique Barboza error_free(local_err); 21006a4a3853SVladimir Sementsov-Ogievskiy local_err = NULL; 2101067927d6SDaniel Henrique Barboza 210273e1d8ebSDaniel Henrique Barboza if (pmutils_supports_mode(mode, &local_err)) { 210373e1d8ebSDaniel Henrique Barboza mode_supported = true; 21048b020b5eSDaniel Henrique Barboza pmutils_suspend(mode, &local_err); 210573e1d8ebSDaniel Henrique Barboza } 210673e1d8ebSDaniel Henrique Barboza 2107246d76ebSDaniel Henrique Barboza if (!local_err) { 2108304a0fcbSDaniel Henrique Barboza return; 2109304a0fcbSDaniel Henrique Barboza } 2110304a0fcbSDaniel Henrique Barboza 2111246d76ebSDaniel Henrique Barboza error_free(local_err); 21126a4a3853SVladimir Sementsov-Ogievskiy local_err = NULL; 211311d0f125SLuiz Capitulino 211473e1d8ebSDaniel Henrique Barboza if (linux_sys_state_supports_mode(mode, &local_err)) { 211573e1d8ebSDaniel Henrique Barboza mode_supported = true; 21168b020b5eSDaniel Henrique Barboza linux_sys_state_suspend(mode, &local_err); 211773e1d8ebSDaniel Henrique Barboza } 211873e1d8ebSDaniel Henrique Barboza 211973e1d8ebSDaniel Henrique Barboza if (!mode_supported) { 21206a4a3853SVladimir Sementsov-Ogievskiy error_free(local_err); 212173e1d8ebSDaniel Henrique Barboza error_setg(errp, 212273e1d8ebSDaniel Henrique Barboza "the requested suspend mode is not supported by the guest"); 2123b2322003SMarkus Armbruster } else { 212477dbc81bSMarkus Armbruster error_propagate(errp, local_err); 21257b376087SLuiz Capitulino } 212611d0f125SLuiz Capitulino } 212711d0f125SLuiz Capitulino 212877dbc81bSMarkus Armbruster void qmp_guest_suspend_disk(Error **errp) 212911d0f125SLuiz Capitulino { 2130304a0fcbSDaniel Henrique Barboza guest_suspend(SUSPEND_MODE_DISK, errp); 213111d0f125SLuiz Capitulino } 213211d0f125SLuiz Capitulino 213377dbc81bSMarkus Armbruster void qmp_guest_suspend_ram(Error **errp) 2134fbf42210SLuiz Capitulino { 2135304a0fcbSDaniel Henrique Barboza guest_suspend(SUSPEND_MODE_RAM, errp); 2136fbf42210SLuiz Capitulino } 2137fbf42210SLuiz Capitulino 213877dbc81bSMarkus Armbruster void qmp_guest_suspend_hybrid(Error **errp) 213995f4f404SLuiz Capitulino { 2140304a0fcbSDaniel Henrique Barboza guest_suspend(SUSPEND_MODE_HYBRID, errp); 214195f4f404SLuiz Capitulino } 214295f4f404SLuiz Capitulino 2143d2baff62SLaszlo Ersek /* Transfer online/offline status between @vcpu and the guest system. 2144d2baff62SLaszlo Ersek * 2145d2baff62SLaszlo Ersek * On input either @errp or *@errp must be NULL. 2146d2baff62SLaszlo Ersek * 2147d2baff62SLaszlo Ersek * In system-to-@vcpu direction, the following @vcpu fields are accessed: 2148d2baff62SLaszlo Ersek * - R: vcpu->logical_id 2149d2baff62SLaszlo Ersek * - W: vcpu->online 2150d2baff62SLaszlo Ersek * - W: vcpu->can_offline 2151d2baff62SLaszlo Ersek * 2152d2baff62SLaszlo Ersek * In @vcpu-to-system direction, the following @vcpu fields are accessed: 2153d2baff62SLaszlo Ersek * - R: vcpu->logical_id 2154d2baff62SLaszlo Ersek * - R: vcpu->online 2155d2baff62SLaszlo Ersek * 2156d2baff62SLaszlo Ersek * Written members remain unmodified on error. 2157d2baff62SLaszlo Ersek */ 2158d2baff62SLaszlo Ersek static void transfer_vcpu(GuestLogicalProcessor *vcpu, bool sys2vcpu, 2159b4bf912aSIgor Mammedov char *dirpath, Error **errp) 2160d2baff62SLaszlo Ersek { 2161b4bf912aSIgor Mammedov int fd; 2162b4bf912aSIgor Mammedov int res; 2163d2baff62SLaszlo Ersek int dirfd; 2164b4bf912aSIgor Mammedov static const char fn[] = "online"; 2165d2baff62SLaszlo Ersek 2166d2baff62SLaszlo Ersek dirfd = open(dirpath, O_RDONLY | O_DIRECTORY); 2167d2baff62SLaszlo Ersek if (dirfd == -1) { 2168d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "open(\"%s\")", dirpath); 2169b4bf912aSIgor Mammedov return; 2170b4bf912aSIgor Mammedov } 2171d2baff62SLaszlo Ersek 2172d2baff62SLaszlo Ersek fd = openat(dirfd, fn, sys2vcpu ? O_RDONLY : O_RDWR); 2173d2baff62SLaszlo Ersek if (fd == -1) { 2174d2baff62SLaszlo Ersek if (errno != ENOENT) { 2175d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "open(\"%s/%s\")", dirpath, fn); 2176d2baff62SLaszlo Ersek } else if (sys2vcpu) { 2177d2baff62SLaszlo Ersek vcpu->online = true; 2178d2baff62SLaszlo Ersek vcpu->can_offline = false; 2179d2baff62SLaszlo Ersek } else if (!vcpu->online) { 2180d2baff62SLaszlo Ersek error_setg(errp, "logical processor #%" PRId64 " can't be " 2181d2baff62SLaszlo Ersek "offlined", vcpu->logical_id); 2182d2baff62SLaszlo Ersek } /* otherwise pretend successful re-onlining */ 2183d2baff62SLaszlo Ersek } else { 2184d2baff62SLaszlo Ersek unsigned char status; 2185d2baff62SLaszlo Ersek 2186d2baff62SLaszlo Ersek res = pread(fd, &status, 1, 0); 2187d2baff62SLaszlo Ersek if (res == -1) { 2188d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "pread(\"%s/%s\")", dirpath, fn); 2189d2baff62SLaszlo Ersek } else if (res == 0) { 2190d2baff62SLaszlo Ersek error_setg(errp, "pread(\"%s/%s\"): unexpected EOF", dirpath, 2191d2baff62SLaszlo Ersek fn); 2192d2baff62SLaszlo Ersek } else if (sys2vcpu) { 2193d2baff62SLaszlo Ersek vcpu->online = (status != '0'); 2194d2baff62SLaszlo Ersek vcpu->can_offline = true; 2195d2baff62SLaszlo Ersek } else if (vcpu->online != (status != '0')) { 2196d2baff62SLaszlo Ersek status = '0' + vcpu->online; 2197d2baff62SLaszlo Ersek if (pwrite(fd, &status, 1, 0) == -1) { 2198d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "pwrite(\"%s/%s\")", dirpath, 2199d2baff62SLaszlo Ersek fn); 2200d2baff62SLaszlo Ersek } 2201d2baff62SLaszlo Ersek } /* otherwise pretend successful re-(on|off)-lining */ 2202d2baff62SLaszlo Ersek 2203d2baff62SLaszlo Ersek res = close(fd); 2204d2baff62SLaszlo Ersek g_assert(res == 0); 2205d2baff62SLaszlo Ersek } 2206d2baff62SLaszlo Ersek 2207d2baff62SLaszlo Ersek res = close(dirfd); 2208d2baff62SLaszlo Ersek g_assert(res == 0); 2209d2baff62SLaszlo Ersek } 2210d2baff62SLaszlo Ersek 2211d2baff62SLaszlo Ersek GuestLogicalProcessorList *qmp_guest_get_vcpus(Error **errp) 2212d2baff62SLaszlo Ersek { 2213c3033fd3SEric Blake GuestLogicalProcessorList *head, **tail; 221427e7de3cSLin Ma const char *cpu_dir = "/sys/devices/system/cpu"; 221527e7de3cSLin Ma const gchar *line; 221627e7de3cSLin Ma g_autoptr(GDir) cpu_gdir = NULL; 2217d2baff62SLaszlo Ersek Error *local_err = NULL; 2218d2baff62SLaszlo Ersek 2219d2baff62SLaszlo Ersek head = NULL; 2220c3033fd3SEric Blake tail = &head; 222127e7de3cSLin Ma cpu_gdir = g_dir_open(cpu_dir, 0, NULL); 2222d2baff62SLaszlo Ersek 222327e7de3cSLin Ma if (cpu_gdir == NULL) { 222427e7de3cSLin Ma error_setg_errno(errp, errno, "failed to list entries: %s", cpu_dir); 222527e7de3cSLin Ma return NULL; 222627e7de3cSLin Ma } 222727e7de3cSLin Ma 222827e7de3cSLin Ma while (local_err == NULL && (line = g_dir_read_name(cpu_gdir)) != NULL) { 2229d2baff62SLaszlo Ersek GuestLogicalProcessor *vcpu; 223027e7de3cSLin Ma int64_t id; 223127e7de3cSLin Ma if (sscanf(line, "cpu%" PRId64, &id)) { 223227e7de3cSLin Ma g_autofree char *path = g_strdup_printf("/sys/devices/system/cpu/" 223327e7de3cSLin Ma "cpu%" PRId64 "/", id); 2234d2baff62SLaszlo Ersek vcpu = g_malloc0(sizeof *vcpu); 2235b4bf912aSIgor Mammedov vcpu->logical_id = id; 2236d2baff62SLaszlo Ersek vcpu->has_can_offline = true; /* lolspeak ftw */ 2237b4bf912aSIgor Mammedov transfer_vcpu(vcpu, true, path, &local_err); 2238c3033fd3SEric Blake QAPI_LIST_APPEND(tail, vcpu); 2239d2baff62SLaszlo Ersek } 2240b4bf912aSIgor Mammedov } 2241d2baff62SLaszlo Ersek 2242d2baff62SLaszlo Ersek if (local_err == NULL) { 2243d2baff62SLaszlo Ersek /* there's no guest with zero VCPUs */ 2244d2baff62SLaszlo Ersek g_assert(head != NULL); 2245d2baff62SLaszlo Ersek return head; 2246d2baff62SLaszlo Ersek } 2247d2baff62SLaszlo Ersek 2248d2baff62SLaszlo Ersek qapi_free_GuestLogicalProcessorList(head); 2249d2baff62SLaszlo Ersek error_propagate(errp, local_err); 2250d2baff62SLaszlo Ersek return NULL; 2251d2baff62SLaszlo Ersek } 2252d2baff62SLaszlo Ersek 2253cbb65fc2SLaszlo Ersek int64_t qmp_guest_set_vcpus(GuestLogicalProcessorList *vcpus, Error **errp) 2254cbb65fc2SLaszlo Ersek { 2255cbb65fc2SLaszlo Ersek int64_t processed; 2256cbb65fc2SLaszlo Ersek Error *local_err = NULL; 2257cbb65fc2SLaszlo Ersek 2258cbb65fc2SLaszlo Ersek processed = 0; 2259cbb65fc2SLaszlo Ersek while (vcpus != NULL) { 2260b4bf912aSIgor Mammedov char *path = g_strdup_printf("/sys/devices/system/cpu/cpu%" PRId64 "/", 2261b4bf912aSIgor Mammedov vcpus->value->logical_id); 2262b4bf912aSIgor Mammedov 2263b4bf912aSIgor Mammedov transfer_vcpu(vcpus->value, false, path, &local_err); 2264b4bf912aSIgor Mammedov g_free(path); 2265cbb65fc2SLaszlo Ersek if (local_err != NULL) { 2266cbb65fc2SLaszlo Ersek break; 2267cbb65fc2SLaszlo Ersek } 2268cbb65fc2SLaszlo Ersek ++processed; 2269cbb65fc2SLaszlo Ersek vcpus = vcpus->next; 2270cbb65fc2SLaszlo Ersek } 2271cbb65fc2SLaszlo Ersek 2272cbb65fc2SLaszlo Ersek if (local_err != NULL) { 2273cbb65fc2SLaszlo Ersek if (processed == 0) { 2274cbb65fc2SLaszlo Ersek error_propagate(errp, local_err); 2275cbb65fc2SLaszlo Ersek } else { 2276cbb65fc2SLaszlo Ersek error_free(local_err); 2277cbb65fc2SLaszlo Ersek } 2278cbb65fc2SLaszlo Ersek } 2279cbb65fc2SLaszlo Ersek 2280cbb65fc2SLaszlo Ersek return processed; 2281cbb65fc2SLaszlo Ersek } 2282cbb65fc2SLaszlo Ersek 2283215a2771SDaniel P. Berrange void qmp_guest_set_user_password(const char *username, 2284215a2771SDaniel P. Berrange const char *password, 2285215a2771SDaniel P. Berrange bool crypted, 2286215a2771SDaniel P. Berrange Error **errp) 2287215a2771SDaniel P. Berrange { 2288215a2771SDaniel P. Berrange Error *local_err = NULL; 2289215a2771SDaniel P. Berrange char *passwd_path = NULL; 2290215a2771SDaniel P. Berrange pid_t pid; 2291215a2771SDaniel P. Berrange int status; 2292215a2771SDaniel P. Berrange int datafd[2] = { -1, -1 }; 2293215a2771SDaniel P. Berrange char *rawpasswddata = NULL; 2294215a2771SDaniel P. Berrange size_t rawpasswdlen; 2295215a2771SDaniel P. Berrange char *chpasswddata = NULL; 2296215a2771SDaniel P. Berrange size_t chpasswdlen; 2297215a2771SDaniel P. Berrange 2298920639caSDaniel P. Berrange rawpasswddata = (char *)qbase64_decode(password, -1, &rawpasswdlen, errp); 2299920639caSDaniel P. Berrange if (!rawpasswddata) { 2300920639caSDaniel P. Berrange return; 2301920639caSDaniel P. Berrange } 2302215a2771SDaniel P. Berrange rawpasswddata = g_renew(char, rawpasswddata, rawpasswdlen + 1); 2303215a2771SDaniel P. Berrange rawpasswddata[rawpasswdlen] = '\0'; 2304215a2771SDaniel P. Berrange 2305215a2771SDaniel P. Berrange if (strchr(rawpasswddata, '\n')) { 2306215a2771SDaniel P. Berrange error_setg(errp, "forbidden characters in raw password"); 2307215a2771SDaniel P. Berrange goto out; 2308215a2771SDaniel P. Berrange } 2309215a2771SDaniel P. Berrange 2310215a2771SDaniel P. Berrange if (strchr(username, '\n') || 2311215a2771SDaniel P. Berrange strchr(username, ':')) { 2312215a2771SDaniel P. Berrange error_setg(errp, "forbidden characters in username"); 2313215a2771SDaniel P. Berrange goto out; 2314215a2771SDaniel P. Berrange } 2315215a2771SDaniel P. Berrange 2316215a2771SDaniel P. Berrange chpasswddata = g_strdup_printf("%s:%s\n", username, rawpasswddata); 2317215a2771SDaniel P. Berrange chpasswdlen = strlen(chpasswddata); 2318215a2771SDaniel P. Berrange 2319215a2771SDaniel P. Berrange passwd_path = g_find_program_in_path("chpasswd"); 2320215a2771SDaniel P. Berrange 2321215a2771SDaniel P. Berrange if (!passwd_path) { 2322215a2771SDaniel P. Berrange error_setg(errp, "cannot find 'passwd' program in PATH"); 2323215a2771SDaniel P. Berrange goto out; 2324215a2771SDaniel P. Berrange } 2325215a2771SDaniel P. Berrange 2326ed78331dSMarc-André Lureau if (!g_unix_open_pipe(datafd, FD_CLOEXEC, NULL)) { 2327215a2771SDaniel P. Berrange error_setg(errp, "cannot create pipe FDs"); 2328215a2771SDaniel P. Berrange goto out; 2329215a2771SDaniel P. Berrange } 2330215a2771SDaniel P. Berrange 2331215a2771SDaniel P. Berrange pid = fork(); 2332215a2771SDaniel P. Berrange if (pid == 0) { 2333215a2771SDaniel P. Berrange close(datafd[1]); 2334215a2771SDaniel P. Berrange /* child */ 2335215a2771SDaniel P. Berrange setsid(); 2336215a2771SDaniel P. Berrange dup2(datafd[0], 0); 2337215a2771SDaniel P. Berrange reopen_fd_to_null(1); 2338215a2771SDaniel P. Berrange reopen_fd_to_null(2); 2339215a2771SDaniel P. Berrange 2340215a2771SDaniel P. Berrange if (crypted) { 2341fcc41961SMarc-André Lureau execl(passwd_path, "chpasswd", "-e", NULL); 2342215a2771SDaniel P. Berrange } else { 2343fcc41961SMarc-André Lureau execl(passwd_path, "chpasswd", NULL); 2344215a2771SDaniel P. Berrange } 2345215a2771SDaniel P. Berrange _exit(EXIT_FAILURE); 2346215a2771SDaniel P. Berrange } else if (pid < 0) { 2347215a2771SDaniel P. Berrange error_setg_errno(errp, errno, "failed to create child process"); 2348215a2771SDaniel P. Berrange goto out; 2349215a2771SDaniel P. Berrange } 2350215a2771SDaniel P. Berrange close(datafd[0]); 2351215a2771SDaniel P. Berrange datafd[0] = -1; 2352215a2771SDaniel P. Berrange 2353215a2771SDaniel P. Berrange if (qemu_write_full(datafd[1], chpasswddata, chpasswdlen) != chpasswdlen) { 2354215a2771SDaniel P. Berrange error_setg_errno(errp, errno, "cannot write new account password"); 2355215a2771SDaniel P. Berrange goto out; 2356215a2771SDaniel P. Berrange } 2357215a2771SDaniel P. Berrange close(datafd[1]); 2358215a2771SDaniel P. Berrange datafd[1] = -1; 2359215a2771SDaniel P. Berrange 2360215a2771SDaniel P. Berrange ga_wait_child(pid, &status, &local_err); 2361215a2771SDaniel P. Berrange if (local_err) { 2362215a2771SDaniel P. Berrange error_propagate(errp, local_err); 2363215a2771SDaniel P. Berrange goto out; 2364215a2771SDaniel P. Berrange } 2365215a2771SDaniel P. Berrange 2366215a2771SDaniel P. Berrange if (!WIFEXITED(status)) { 2367215a2771SDaniel P. Berrange error_setg(errp, "child process has terminated abnormally"); 2368215a2771SDaniel P. Berrange goto out; 2369215a2771SDaniel P. Berrange } 2370215a2771SDaniel P. Berrange 2371215a2771SDaniel P. Berrange if (WEXITSTATUS(status)) { 2372215a2771SDaniel P. Berrange error_setg(errp, "child process has failed to set user password"); 2373215a2771SDaniel P. Berrange goto out; 2374215a2771SDaniel P. Berrange } 2375215a2771SDaniel P. Berrange 2376215a2771SDaniel P. Berrange out: 2377215a2771SDaniel P. Berrange g_free(chpasswddata); 2378215a2771SDaniel P. Berrange g_free(rawpasswddata); 2379215a2771SDaniel P. Berrange g_free(passwd_path); 2380215a2771SDaniel P. Berrange if (datafd[0] != -1) { 2381215a2771SDaniel P. Berrange close(datafd[0]); 2382215a2771SDaniel P. Berrange } 2383215a2771SDaniel P. Berrange if (datafd[1] != -1) { 2384215a2771SDaniel P. Berrange close(datafd[1]); 2385215a2771SDaniel P. Berrange } 2386215a2771SDaniel P. Berrange } 2387215a2771SDaniel P. Berrange 2388bd240fcaSzhanghailiang static void ga_read_sysfs_file(int dirfd, const char *pathname, char *buf, 2389bd240fcaSzhanghailiang int size, Error **errp) 2390bd240fcaSzhanghailiang { 2391bd240fcaSzhanghailiang int fd; 2392bd240fcaSzhanghailiang int res; 2393bd240fcaSzhanghailiang 2394bd240fcaSzhanghailiang errno = 0; 2395bd240fcaSzhanghailiang fd = openat(dirfd, pathname, O_RDONLY); 2396bd240fcaSzhanghailiang if (fd == -1) { 2397bd240fcaSzhanghailiang error_setg_errno(errp, errno, "open sysfs file \"%s\"", pathname); 2398bd240fcaSzhanghailiang return; 2399bd240fcaSzhanghailiang } 2400bd240fcaSzhanghailiang 2401bd240fcaSzhanghailiang res = pread(fd, buf, size, 0); 2402bd240fcaSzhanghailiang if (res == -1) { 2403bd240fcaSzhanghailiang error_setg_errno(errp, errno, "pread sysfs file \"%s\"", pathname); 2404bd240fcaSzhanghailiang } else if (res == 0) { 2405bd240fcaSzhanghailiang error_setg(errp, "pread sysfs file \"%s\": unexpected EOF", pathname); 2406bd240fcaSzhanghailiang } 2407bd240fcaSzhanghailiang close(fd); 2408bd240fcaSzhanghailiang } 2409bd240fcaSzhanghailiang 2410bd240fcaSzhanghailiang static void ga_write_sysfs_file(int dirfd, const char *pathname, 2411bd240fcaSzhanghailiang const char *buf, int size, Error **errp) 2412bd240fcaSzhanghailiang { 2413bd240fcaSzhanghailiang int fd; 2414bd240fcaSzhanghailiang 2415bd240fcaSzhanghailiang errno = 0; 2416bd240fcaSzhanghailiang fd = openat(dirfd, pathname, O_WRONLY); 2417bd240fcaSzhanghailiang if (fd == -1) { 2418bd240fcaSzhanghailiang error_setg_errno(errp, errno, "open sysfs file \"%s\"", pathname); 2419bd240fcaSzhanghailiang return; 2420bd240fcaSzhanghailiang } 2421bd240fcaSzhanghailiang 2422bd240fcaSzhanghailiang if (pwrite(fd, buf, size, 0) == -1) { 2423bd240fcaSzhanghailiang error_setg_errno(errp, errno, "pwrite sysfs file \"%s\"", pathname); 2424bd240fcaSzhanghailiang } 2425bd240fcaSzhanghailiang 2426bd240fcaSzhanghailiang close(fd); 2427bd240fcaSzhanghailiang } 2428bd240fcaSzhanghailiang 2429bd240fcaSzhanghailiang /* Transfer online/offline status between @mem_blk and the guest system. 2430bd240fcaSzhanghailiang * 2431bd240fcaSzhanghailiang * On input either @errp or *@errp must be NULL. 2432bd240fcaSzhanghailiang * 2433bd240fcaSzhanghailiang * In system-to-@mem_blk direction, the following @mem_blk fields are accessed: 2434bd240fcaSzhanghailiang * - R: mem_blk->phys_index 2435bd240fcaSzhanghailiang * - W: mem_blk->online 2436bd240fcaSzhanghailiang * - W: mem_blk->can_offline 2437bd240fcaSzhanghailiang * 2438bd240fcaSzhanghailiang * In @mem_blk-to-system direction, the following @mem_blk fields are accessed: 2439bd240fcaSzhanghailiang * - R: mem_blk->phys_index 2440bd240fcaSzhanghailiang * - R: mem_blk->online 2441bd240fcaSzhanghailiang *- R: mem_blk->can_offline 2442bd240fcaSzhanghailiang * Written members remain unmodified on error. 2443bd240fcaSzhanghailiang */ 2444bd240fcaSzhanghailiang static void transfer_memory_block(GuestMemoryBlock *mem_blk, bool sys2memblk, 2445bd240fcaSzhanghailiang GuestMemoryBlockResponse *result, 2446bd240fcaSzhanghailiang Error **errp) 2447bd240fcaSzhanghailiang { 2448bd240fcaSzhanghailiang char *dirpath; 2449bd240fcaSzhanghailiang int dirfd; 2450bd240fcaSzhanghailiang char *status; 2451bd240fcaSzhanghailiang Error *local_err = NULL; 2452bd240fcaSzhanghailiang 2453bd240fcaSzhanghailiang if (!sys2memblk) { 2454bd240fcaSzhanghailiang DIR *dp; 2455bd240fcaSzhanghailiang 2456bd240fcaSzhanghailiang if (!result) { 2457bd240fcaSzhanghailiang error_setg(errp, "Internal error, 'result' should not be NULL"); 2458bd240fcaSzhanghailiang return; 2459bd240fcaSzhanghailiang } 2460bd240fcaSzhanghailiang errno = 0; 2461bd240fcaSzhanghailiang dp = opendir("/sys/devices/system/memory/"); 2462bd240fcaSzhanghailiang /* if there is no 'memory' directory in sysfs, 2463bd240fcaSzhanghailiang * we think this VM does not support online/offline memory block, 2464bd240fcaSzhanghailiang * any other solution? 2465bd240fcaSzhanghailiang */ 24669879f5acSPhilippe Mathieu-Daudé if (!dp) { 24679879f5acSPhilippe Mathieu-Daudé if (errno == ENOENT) { 2468bd240fcaSzhanghailiang result->response = 2469bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_NOT_SUPPORTED; 24709879f5acSPhilippe Mathieu-Daudé } 2471bd240fcaSzhanghailiang goto out1; 2472bd240fcaSzhanghailiang } 2473bd240fcaSzhanghailiang closedir(dp); 2474bd240fcaSzhanghailiang } 2475bd240fcaSzhanghailiang 2476bd240fcaSzhanghailiang dirpath = g_strdup_printf("/sys/devices/system/memory/memory%" PRId64 "/", 2477bd240fcaSzhanghailiang mem_blk->phys_index); 2478bd240fcaSzhanghailiang dirfd = open(dirpath, O_RDONLY | O_DIRECTORY); 2479bd240fcaSzhanghailiang if (dirfd == -1) { 2480bd240fcaSzhanghailiang if (sys2memblk) { 2481bd240fcaSzhanghailiang error_setg_errno(errp, errno, "open(\"%s\")", dirpath); 2482bd240fcaSzhanghailiang } else { 2483bd240fcaSzhanghailiang if (errno == ENOENT) { 2484bd240fcaSzhanghailiang result->response = GUEST_MEMORY_BLOCK_RESPONSE_TYPE_NOT_FOUND; 2485bd240fcaSzhanghailiang } else { 2486bd240fcaSzhanghailiang result->response = 2487bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_FAILED; 2488bd240fcaSzhanghailiang } 2489bd240fcaSzhanghailiang } 2490bd240fcaSzhanghailiang g_free(dirpath); 2491bd240fcaSzhanghailiang goto out1; 2492bd240fcaSzhanghailiang } 2493bd240fcaSzhanghailiang g_free(dirpath); 2494bd240fcaSzhanghailiang 2495bd240fcaSzhanghailiang status = g_malloc0(10); 2496bd240fcaSzhanghailiang ga_read_sysfs_file(dirfd, "state", status, 10, &local_err); 2497bd240fcaSzhanghailiang if (local_err) { 2498bd240fcaSzhanghailiang /* treat with sysfs file that not exist in old kernel */ 2499bd240fcaSzhanghailiang if (errno == ENOENT) { 2500bd240fcaSzhanghailiang error_free(local_err); 2501bd240fcaSzhanghailiang if (sys2memblk) { 2502bd240fcaSzhanghailiang mem_blk->online = true; 2503bd240fcaSzhanghailiang mem_blk->can_offline = false; 2504bd240fcaSzhanghailiang } else if (!mem_blk->online) { 2505bd240fcaSzhanghailiang result->response = 2506bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_NOT_SUPPORTED; 2507bd240fcaSzhanghailiang } 2508bd240fcaSzhanghailiang } else { 2509bd240fcaSzhanghailiang if (sys2memblk) { 2510bd240fcaSzhanghailiang error_propagate(errp, local_err); 2511bd240fcaSzhanghailiang } else { 2512b368123dSMarkus Armbruster error_free(local_err); 2513bd240fcaSzhanghailiang result->response = 2514bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_FAILED; 2515bd240fcaSzhanghailiang } 2516bd240fcaSzhanghailiang } 2517bd240fcaSzhanghailiang goto out2; 2518bd240fcaSzhanghailiang } 2519bd240fcaSzhanghailiang 2520bd240fcaSzhanghailiang if (sys2memblk) { 2521bd240fcaSzhanghailiang char removable = '0'; 2522bd240fcaSzhanghailiang 2523bd240fcaSzhanghailiang mem_blk->online = (strncmp(status, "online", 6) == 0); 2524bd240fcaSzhanghailiang 2525bd240fcaSzhanghailiang ga_read_sysfs_file(dirfd, "removable", &removable, 1, &local_err); 2526bd240fcaSzhanghailiang if (local_err) { 252767cc32ebSVeres Lajos /* if no 'removable' file, it doesn't support offline mem blk */ 2528bd240fcaSzhanghailiang if (errno == ENOENT) { 2529bd240fcaSzhanghailiang error_free(local_err); 2530bd240fcaSzhanghailiang mem_blk->can_offline = false; 2531bd240fcaSzhanghailiang } else { 2532bd240fcaSzhanghailiang error_propagate(errp, local_err); 2533bd240fcaSzhanghailiang } 2534bd240fcaSzhanghailiang } else { 2535bd240fcaSzhanghailiang mem_blk->can_offline = (removable != '0'); 2536bd240fcaSzhanghailiang } 2537bd240fcaSzhanghailiang } else { 2538bd240fcaSzhanghailiang if (mem_blk->online != (strncmp(status, "online", 6) == 0)) { 25397064024dSMarc-André Lureau const char *new_state = mem_blk->online ? "online" : "offline"; 2540bd240fcaSzhanghailiang 2541bd240fcaSzhanghailiang ga_write_sysfs_file(dirfd, "state", new_state, strlen(new_state), 2542bd240fcaSzhanghailiang &local_err); 2543bd240fcaSzhanghailiang if (local_err) { 2544bd240fcaSzhanghailiang error_free(local_err); 2545bd240fcaSzhanghailiang result->response = 2546bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_FAILED; 2547bd240fcaSzhanghailiang goto out2; 2548bd240fcaSzhanghailiang } 2549bd240fcaSzhanghailiang 2550bd240fcaSzhanghailiang result->response = GUEST_MEMORY_BLOCK_RESPONSE_TYPE_SUCCESS; 2551bd240fcaSzhanghailiang result->has_error_code = false; 2552bd240fcaSzhanghailiang } /* otherwise pretend successful re-(on|off)-lining */ 2553bd240fcaSzhanghailiang } 2554bd240fcaSzhanghailiang g_free(status); 2555bd240fcaSzhanghailiang close(dirfd); 2556bd240fcaSzhanghailiang return; 2557bd240fcaSzhanghailiang 2558bd240fcaSzhanghailiang out2: 2559bd240fcaSzhanghailiang g_free(status); 2560bd240fcaSzhanghailiang close(dirfd); 2561bd240fcaSzhanghailiang out1: 2562bd240fcaSzhanghailiang if (!sys2memblk) { 2563bd240fcaSzhanghailiang result->has_error_code = true; 2564bd240fcaSzhanghailiang result->error_code = errno; 2565bd240fcaSzhanghailiang } 2566bd240fcaSzhanghailiang } 2567bd240fcaSzhanghailiang 2568a065aaa9Szhanghailiang GuestMemoryBlockList *qmp_guest_get_memory_blocks(Error **errp) 2569a065aaa9Szhanghailiang { 2570c3033fd3SEric Blake GuestMemoryBlockList *head, **tail; 2571bd240fcaSzhanghailiang Error *local_err = NULL; 2572bd240fcaSzhanghailiang struct dirent *de; 2573bd240fcaSzhanghailiang DIR *dp; 2574bd240fcaSzhanghailiang 2575bd240fcaSzhanghailiang head = NULL; 2576c3033fd3SEric Blake tail = &head; 2577bd240fcaSzhanghailiang 2578bd240fcaSzhanghailiang dp = opendir("/sys/devices/system/memory/"); 2579bd240fcaSzhanghailiang if (!dp) { 2580f693fe6eSMichael Roth /* it's ok if this happens to be a system that doesn't expose 2581f693fe6eSMichael Roth * memory blocks via sysfs, but otherwise we should report 2582f693fe6eSMichael Roth * an error 2583f693fe6eSMichael Roth */ 2584f693fe6eSMichael Roth if (errno != ENOENT) { 2585bd240fcaSzhanghailiang error_setg_errno(errp, errno, "Can't open directory" 25869af9e0feSMarkus Armbruster "\"/sys/devices/system/memory/\""); 2587f693fe6eSMichael Roth } 2588bd240fcaSzhanghailiang return NULL; 2589bd240fcaSzhanghailiang } 2590bd240fcaSzhanghailiang 2591bd240fcaSzhanghailiang /* Note: the phys_index of memory block may be discontinuous, 2592bd240fcaSzhanghailiang * this is because a memblk is the unit of the Sparse Memory design, which 2593bd240fcaSzhanghailiang * allows discontinuous memory ranges (ex. NUMA), so here we should 2594bd240fcaSzhanghailiang * traverse the memory block directory. 2595bd240fcaSzhanghailiang */ 2596bd240fcaSzhanghailiang while ((de = readdir(dp)) != NULL) { 2597bd240fcaSzhanghailiang GuestMemoryBlock *mem_blk; 2598bd240fcaSzhanghailiang 2599bd240fcaSzhanghailiang if ((strncmp(de->d_name, "memory", 6) != 0) || 2600bd240fcaSzhanghailiang !(de->d_type & DT_DIR)) { 2601bd240fcaSzhanghailiang continue; 2602bd240fcaSzhanghailiang } 2603bd240fcaSzhanghailiang 2604bd240fcaSzhanghailiang mem_blk = g_malloc0(sizeof *mem_blk); 2605bd240fcaSzhanghailiang /* The d_name is "memoryXXX", phys_index is block id, same as XXX */ 2606bd240fcaSzhanghailiang mem_blk->phys_index = strtoul(&de->d_name[6], NULL, 10); 2607bd240fcaSzhanghailiang mem_blk->has_can_offline = true; /* lolspeak ftw */ 2608bd240fcaSzhanghailiang transfer_memory_block(mem_blk, true, NULL, &local_err); 26094155c998SMarkus Armbruster if (local_err) { 26104155c998SMarkus Armbruster break; 26114155c998SMarkus Armbruster } 2612bd240fcaSzhanghailiang 2613c3033fd3SEric Blake QAPI_LIST_APPEND(tail, mem_blk); 2614bd240fcaSzhanghailiang } 2615bd240fcaSzhanghailiang 2616bd240fcaSzhanghailiang closedir(dp); 2617bd240fcaSzhanghailiang if (local_err == NULL) { 2618bd240fcaSzhanghailiang /* there's no guest with zero memory blocks */ 2619bd240fcaSzhanghailiang if (head == NULL) { 2620bd240fcaSzhanghailiang error_setg(errp, "guest reported zero memory blocks!"); 2621bd240fcaSzhanghailiang } 2622bd240fcaSzhanghailiang return head; 2623bd240fcaSzhanghailiang } 2624bd240fcaSzhanghailiang 2625bd240fcaSzhanghailiang qapi_free_GuestMemoryBlockList(head); 2626bd240fcaSzhanghailiang error_propagate(errp, local_err); 2627a065aaa9Szhanghailiang return NULL; 2628a065aaa9Szhanghailiang } 2629a065aaa9Szhanghailiang 2630a065aaa9Szhanghailiang GuestMemoryBlockResponseList * 2631a065aaa9Szhanghailiang qmp_guest_set_memory_blocks(GuestMemoryBlockList *mem_blks, Error **errp) 2632a065aaa9Szhanghailiang { 2633c3033fd3SEric Blake GuestMemoryBlockResponseList *head, **tail; 263432ca7927Szhanghailiang Error *local_err = NULL; 263532ca7927Szhanghailiang 263632ca7927Szhanghailiang head = NULL; 2637c3033fd3SEric Blake tail = &head; 263832ca7927Szhanghailiang 263932ca7927Szhanghailiang while (mem_blks != NULL) { 264032ca7927Szhanghailiang GuestMemoryBlockResponse *result; 264132ca7927Szhanghailiang GuestMemoryBlock *current_mem_blk = mem_blks->value; 264232ca7927Szhanghailiang 264332ca7927Szhanghailiang result = g_malloc0(sizeof(*result)); 264432ca7927Szhanghailiang result->phys_index = current_mem_blk->phys_index; 264532ca7927Szhanghailiang transfer_memory_block(current_mem_blk, false, result, &local_err); 264632ca7927Szhanghailiang if (local_err) { /* should never happen */ 264732ca7927Szhanghailiang goto err; 264832ca7927Szhanghailiang } 264932ca7927Szhanghailiang 2650c3033fd3SEric Blake QAPI_LIST_APPEND(tail, result); 265132ca7927Szhanghailiang mem_blks = mem_blks->next; 265232ca7927Szhanghailiang } 265332ca7927Szhanghailiang 265432ca7927Szhanghailiang return head; 265532ca7927Szhanghailiang err: 265632ca7927Szhanghailiang qapi_free_GuestMemoryBlockResponseList(head); 265732ca7927Szhanghailiang error_propagate(errp, local_err); 2658a065aaa9Szhanghailiang return NULL; 2659a065aaa9Szhanghailiang } 2660a065aaa9Szhanghailiang 2661a065aaa9Szhanghailiang GuestMemoryBlockInfo *qmp_guest_get_memory_block_info(Error **errp) 2662a065aaa9Szhanghailiang { 2663ef82b60bSzhanghailiang Error *local_err = NULL; 2664ef82b60bSzhanghailiang char *dirpath; 2665ef82b60bSzhanghailiang int dirfd; 2666ef82b60bSzhanghailiang char *buf; 2667ef82b60bSzhanghailiang GuestMemoryBlockInfo *info; 2668ef82b60bSzhanghailiang 2669ef82b60bSzhanghailiang dirpath = g_strdup_printf("/sys/devices/system/memory/"); 2670ef82b60bSzhanghailiang dirfd = open(dirpath, O_RDONLY | O_DIRECTORY); 2671ef82b60bSzhanghailiang if (dirfd == -1) { 2672ef82b60bSzhanghailiang error_setg_errno(errp, errno, "open(\"%s\")", dirpath); 2673ef82b60bSzhanghailiang g_free(dirpath); 2674a065aaa9Szhanghailiang return NULL; 2675a065aaa9Szhanghailiang } 2676ef82b60bSzhanghailiang g_free(dirpath); 2677ef82b60bSzhanghailiang 2678ef82b60bSzhanghailiang buf = g_malloc0(20); 2679ef82b60bSzhanghailiang ga_read_sysfs_file(dirfd, "block_size_bytes", buf, 20, &local_err); 26808ce1ee46SShannon Zhao close(dirfd); 2681ef82b60bSzhanghailiang if (local_err) { 2682ef82b60bSzhanghailiang g_free(buf); 2683ef82b60bSzhanghailiang error_propagate(errp, local_err); 2684ef82b60bSzhanghailiang return NULL; 2685ef82b60bSzhanghailiang } 2686ef82b60bSzhanghailiang 2687ef82b60bSzhanghailiang info = g_new0(GuestMemoryBlockInfo, 1); 2688ef82b60bSzhanghailiang info->size = strtol(buf, NULL, 16); /* the unit is bytes */ 2689ef82b60bSzhanghailiang 2690ef82b60bSzhanghailiang g_free(buf); 2691ef82b60bSzhanghailiang 2692ef82b60bSzhanghailiang return info; 2693ef82b60bSzhanghailiang } 2694a065aaa9Szhanghailiang 2695e72c3f2eSMichael Roth #else /* defined(__linux__) */ 2696e72c3f2eSMichael Roth 269777dbc81bSMarkus Armbruster void qmp_guest_suspend_disk(Error **errp) 2698e72c3f2eSMichael Roth { 2699c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2700e72c3f2eSMichael Roth } 2701e72c3f2eSMichael Roth 270277dbc81bSMarkus Armbruster void qmp_guest_suspend_ram(Error **errp) 2703e72c3f2eSMichael Roth { 2704c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2705e72c3f2eSMichael Roth } 2706e72c3f2eSMichael Roth 270777dbc81bSMarkus Armbruster void qmp_guest_suspend_hybrid(Error **errp) 2708e72c3f2eSMichael Roth { 2709c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2710e72c3f2eSMichael Roth } 2711e72c3f2eSMichael Roth 2712d2baff62SLaszlo Ersek GuestLogicalProcessorList *qmp_guest_get_vcpus(Error **errp) 2713d2baff62SLaszlo Ersek { 2714c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2715d2baff62SLaszlo Ersek return NULL; 2716d2baff62SLaszlo Ersek } 2717d2baff62SLaszlo Ersek 2718cbb65fc2SLaszlo Ersek int64_t qmp_guest_set_vcpus(GuestLogicalProcessorList *vcpus, Error **errp) 2719cbb65fc2SLaszlo Ersek { 2720c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2721cbb65fc2SLaszlo Ersek return -1; 2722cbb65fc2SLaszlo Ersek } 2723cbb65fc2SLaszlo Ersek 2724215a2771SDaniel P. Berrange void qmp_guest_set_user_password(const char *username, 2725215a2771SDaniel P. Berrange const char *password, 2726215a2771SDaniel P. Berrange bool crypted, 2727215a2771SDaniel P. Berrange Error **errp) 2728215a2771SDaniel P. Berrange { 2729c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2730215a2771SDaniel P. Berrange } 2731215a2771SDaniel P. Berrange 2732a065aaa9Szhanghailiang GuestMemoryBlockList *qmp_guest_get_memory_blocks(Error **errp) 2733a065aaa9Szhanghailiang { 2734c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2735a065aaa9Szhanghailiang return NULL; 2736a065aaa9Szhanghailiang } 2737a065aaa9Szhanghailiang 2738a065aaa9Szhanghailiang GuestMemoryBlockResponseList * 2739a065aaa9Szhanghailiang qmp_guest_set_memory_blocks(GuestMemoryBlockList *mem_blks, Error **errp) 2740a065aaa9Szhanghailiang { 2741c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2742a065aaa9Szhanghailiang return NULL; 2743a065aaa9Szhanghailiang } 2744a065aaa9Szhanghailiang 2745a065aaa9Szhanghailiang GuestMemoryBlockInfo *qmp_guest_get_memory_block_info(Error **errp) 2746a065aaa9Szhanghailiang { 2747c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2748a065aaa9Szhanghailiang return NULL; 2749a065aaa9Szhanghailiang } 2750a065aaa9Szhanghailiang 2751e72c3f2eSMichael Roth #endif 2752e72c3f2eSMichael Roth 2753*59e35c7bSAndrew Deason #ifdef HAVE_GETIFADDRS 2754*59e35c7bSAndrew Deason static GuestNetworkInterface * 2755*59e35c7bSAndrew Deason guest_find_interface(GuestNetworkInterfaceList *head, 2756*59e35c7bSAndrew Deason const char *name) 2757*59e35c7bSAndrew Deason { 2758*59e35c7bSAndrew Deason for (; head; head = head->next) { 2759*59e35c7bSAndrew Deason if (strcmp(head->value->name, name) == 0) { 2760*59e35c7bSAndrew Deason return head->value; 2761*59e35c7bSAndrew Deason } 2762*59e35c7bSAndrew Deason } 2763*59e35c7bSAndrew Deason 2764*59e35c7bSAndrew Deason return NULL; 2765*59e35c7bSAndrew Deason } 2766*59e35c7bSAndrew Deason 2767*59e35c7bSAndrew Deason static int guest_get_network_stats(const char *name, 2768*59e35c7bSAndrew Deason GuestNetworkInterfaceStat *stats) 2769*59e35c7bSAndrew Deason { 2770*59e35c7bSAndrew Deason int name_len; 2771*59e35c7bSAndrew Deason char const *devinfo = "/proc/net/dev"; 2772*59e35c7bSAndrew Deason FILE *fp; 2773*59e35c7bSAndrew Deason char *line = NULL, *colon; 2774*59e35c7bSAndrew Deason size_t n = 0; 2775*59e35c7bSAndrew Deason fp = fopen(devinfo, "r"); 2776*59e35c7bSAndrew Deason if (!fp) { 2777*59e35c7bSAndrew Deason return -1; 2778*59e35c7bSAndrew Deason } 2779*59e35c7bSAndrew Deason name_len = strlen(name); 2780*59e35c7bSAndrew Deason while (getline(&line, &n, fp) != -1) { 2781*59e35c7bSAndrew Deason long long dummy; 2782*59e35c7bSAndrew Deason long long rx_bytes; 2783*59e35c7bSAndrew Deason long long rx_packets; 2784*59e35c7bSAndrew Deason long long rx_errs; 2785*59e35c7bSAndrew Deason long long rx_dropped; 2786*59e35c7bSAndrew Deason long long tx_bytes; 2787*59e35c7bSAndrew Deason long long tx_packets; 2788*59e35c7bSAndrew Deason long long tx_errs; 2789*59e35c7bSAndrew Deason long long tx_dropped; 2790*59e35c7bSAndrew Deason char *trim_line; 2791*59e35c7bSAndrew Deason trim_line = g_strchug(line); 2792*59e35c7bSAndrew Deason if (trim_line[0] == '\0') { 2793*59e35c7bSAndrew Deason continue; 2794*59e35c7bSAndrew Deason } 2795*59e35c7bSAndrew Deason colon = strchr(trim_line, ':'); 2796*59e35c7bSAndrew Deason if (!colon) { 2797*59e35c7bSAndrew Deason continue; 2798*59e35c7bSAndrew Deason } 2799*59e35c7bSAndrew Deason if (colon - name_len == trim_line && 2800*59e35c7bSAndrew Deason strncmp(trim_line, name, name_len) == 0) { 2801*59e35c7bSAndrew Deason if (sscanf(colon + 1, 2802*59e35c7bSAndrew Deason "%lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld", 2803*59e35c7bSAndrew Deason &rx_bytes, &rx_packets, &rx_errs, &rx_dropped, 2804*59e35c7bSAndrew Deason &dummy, &dummy, &dummy, &dummy, 2805*59e35c7bSAndrew Deason &tx_bytes, &tx_packets, &tx_errs, &tx_dropped, 2806*59e35c7bSAndrew Deason &dummy, &dummy, &dummy, &dummy) != 16) { 2807*59e35c7bSAndrew Deason continue; 2808*59e35c7bSAndrew Deason } 2809*59e35c7bSAndrew Deason stats->rx_bytes = rx_bytes; 2810*59e35c7bSAndrew Deason stats->rx_packets = rx_packets; 2811*59e35c7bSAndrew Deason stats->rx_errs = rx_errs; 2812*59e35c7bSAndrew Deason stats->rx_dropped = rx_dropped; 2813*59e35c7bSAndrew Deason stats->tx_bytes = tx_bytes; 2814*59e35c7bSAndrew Deason stats->tx_packets = tx_packets; 2815*59e35c7bSAndrew Deason stats->tx_errs = tx_errs; 2816*59e35c7bSAndrew Deason stats->tx_dropped = tx_dropped; 2817*59e35c7bSAndrew Deason fclose(fp); 2818*59e35c7bSAndrew Deason g_free(line); 2819*59e35c7bSAndrew Deason return 0; 2820*59e35c7bSAndrew Deason } 2821*59e35c7bSAndrew Deason } 2822*59e35c7bSAndrew Deason fclose(fp); 2823*59e35c7bSAndrew Deason g_free(line); 2824*59e35c7bSAndrew Deason g_debug("/proc/net/dev: Interface '%s' not found", name); 2825*59e35c7bSAndrew Deason return -1; 2826*59e35c7bSAndrew Deason } 2827*59e35c7bSAndrew Deason 2828*59e35c7bSAndrew Deason /* 2829*59e35c7bSAndrew Deason * Build information about guest interfaces 2830*59e35c7bSAndrew Deason */ 2831*59e35c7bSAndrew Deason GuestNetworkInterfaceList *qmp_guest_network_get_interfaces(Error **errp) 2832*59e35c7bSAndrew Deason { 2833*59e35c7bSAndrew Deason GuestNetworkInterfaceList *head = NULL, **tail = &head; 2834*59e35c7bSAndrew Deason struct ifaddrs *ifap, *ifa; 2835*59e35c7bSAndrew Deason 2836*59e35c7bSAndrew Deason if (getifaddrs(&ifap) < 0) { 2837*59e35c7bSAndrew Deason error_setg_errno(errp, errno, "getifaddrs failed"); 2838*59e35c7bSAndrew Deason goto error; 2839*59e35c7bSAndrew Deason } 2840*59e35c7bSAndrew Deason 2841*59e35c7bSAndrew Deason for (ifa = ifap; ifa; ifa = ifa->ifa_next) { 2842*59e35c7bSAndrew Deason GuestNetworkInterface *info; 2843*59e35c7bSAndrew Deason GuestIpAddressList **address_tail; 2844*59e35c7bSAndrew Deason GuestIpAddress *address_item = NULL; 2845*59e35c7bSAndrew Deason GuestNetworkInterfaceStat *interface_stat = NULL; 2846*59e35c7bSAndrew Deason char addr4[INET_ADDRSTRLEN]; 2847*59e35c7bSAndrew Deason char addr6[INET6_ADDRSTRLEN]; 2848*59e35c7bSAndrew Deason int sock; 2849*59e35c7bSAndrew Deason struct ifreq ifr; 2850*59e35c7bSAndrew Deason unsigned char *mac_addr; 2851*59e35c7bSAndrew Deason void *p; 2852*59e35c7bSAndrew Deason 2853*59e35c7bSAndrew Deason g_debug("Processing %s interface", ifa->ifa_name); 2854*59e35c7bSAndrew Deason 2855*59e35c7bSAndrew Deason info = guest_find_interface(head, ifa->ifa_name); 2856*59e35c7bSAndrew Deason 2857*59e35c7bSAndrew Deason if (!info) { 2858*59e35c7bSAndrew Deason info = g_malloc0(sizeof(*info)); 2859*59e35c7bSAndrew Deason info->name = g_strdup(ifa->ifa_name); 2860*59e35c7bSAndrew Deason 2861*59e35c7bSAndrew Deason QAPI_LIST_APPEND(tail, info); 2862*59e35c7bSAndrew Deason } 2863*59e35c7bSAndrew Deason 2864*59e35c7bSAndrew Deason if (!info->has_hardware_address && ifa->ifa_flags & SIOCGIFHWADDR) { 2865*59e35c7bSAndrew Deason /* we haven't obtained HW address yet */ 2866*59e35c7bSAndrew Deason sock = socket(PF_INET, SOCK_STREAM, 0); 2867*59e35c7bSAndrew Deason if (sock == -1) { 2868*59e35c7bSAndrew Deason error_setg_errno(errp, errno, "failed to create socket"); 2869*59e35c7bSAndrew Deason goto error; 2870*59e35c7bSAndrew Deason } 2871*59e35c7bSAndrew Deason 2872*59e35c7bSAndrew Deason memset(&ifr, 0, sizeof(ifr)); 2873*59e35c7bSAndrew Deason pstrcpy(ifr.ifr_name, IF_NAMESIZE, info->name); 2874*59e35c7bSAndrew Deason if (ioctl(sock, SIOCGIFHWADDR, &ifr) == -1) { 2875*59e35c7bSAndrew Deason error_setg_errno(errp, errno, 2876*59e35c7bSAndrew Deason "failed to get MAC address of %s", 2877*59e35c7bSAndrew Deason ifa->ifa_name); 2878*59e35c7bSAndrew Deason close(sock); 2879*59e35c7bSAndrew Deason goto error; 2880*59e35c7bSAndrew Deason } 2881*59e35c7bSAndrew Deason 2882*59e35c7bSAndrew Deason close(sock); 2883*59e35c7bSAndrew Deason mac_addr = (unsigned char *) &ifr.ifr_hwaddr.sa_data; 2884*59e35c7bSAndrew Deason 2885*59e35c7bSAndrew Deason info->hardware_address = 2886*59e35c7bSAndrew Deason g_strdup_printf("%02x:%02x:%02x:%02x:%02x:%02x", 2887*59e35c7bSAndrew Deason (int) mac_addr[0], (int) mac_addr[1], 2888*59e35c7bSAndrew Deason (int) mac_addr[2], (int) mac_addr[3], 2889*59e35c7bSAndrew Deason (int) mac_addr[4], (int) mac_addr[5]); 2890*59e35c7bSAndrew Deason 2891*59e35c7bSAndrew Deason info->has_hardware_address = true; 2892*59e35c7bSAndrew Deason } 2893*59e35c7bSAndrew Deason 2894*59e35c7bSAndrew Deason if (ifa->ifa_addr && 2895*59e35c7bSAndrew Deason ifa->ifa_addr->sa_family == AF_INET) { 2896*59e35c7bSAndrew Deason /* interface with IPv4 address */ 2897*59e35c7bSAndrew Deason p = &((struct sockaddr_in *)ifa->ifa_addr)->sin_addr; 2898*59e35c7bSAndrew Deason if (!inet_ntop(AF_INET, p, addr4, sizeof(addr4))) { 2899*59e35c7bSAndrew Deason error_setg_errno(errp, errno, "inet_ntop failed"); 2900*59e35c7bSAndrew Deason goto error; 2901*59e35c7bSAndrew Deason } 2902*59e35c7bSAndrew Deason 2903*59e35c7bSAndrew Deason address_item = g_malloc0(sizeof(*address_item)); 2904*59e35c7bSAndrew Deason address_item->ip_address = g_strdup(addr4); 2905*59e35c7bSAndrew Deason address_item->ip_address_type = GUEST_IP_ADDRESS_TYPE_IPV4; 2906*59e35c7bSAndrew Deason 2907*59e35c7bSAndrew Deason if (ifa->ifa_netmask) { 2908*59e35c7bSAndrew Deason /* Count the number of set bits in netmask. 2909*59e35c7bSAndrew Deason * This is safe as '1' and '0' cannot be shuffled in netmask. */ 2910*59e35c7bSAndrew Deason p = &((struct sockaddr_in *)ifa->ifa_netmask)->sin_addr; 2911*59e35c7bSAndrew Deason address_item->prefix = ctpop32(((uint32_t *) p)[0]); 2912*59e35c7bSAndrew Deason } 2913*59e35c7bSAndrew Deason } else if (ifa->ifa_addr && 2914*59e35c7bSAndrew Deason ifa->ifa_addr->sa_family == AF_INET6) { 2915*59e35c7bSAndrew Deason /* interface with IPv6 address */ 2916*59e35c7bSAndrew Deason p = &((struct sockaddr_in6 *)ifa->ifa_addr)->sin6_addr; 2917*59e35c7bSAndrew Deason if (!inet_ntop(AF_INET6, p, addr6, sizeof(addr6))) { 2918*59e35c7bSAndrew Deason error_setg_errno(errp, errno, "inet_ntop failed"); 2919*59e35c7bSAndrew Deason goto error; 2920*59e35c7bSAndrew Deason } 2921*59e35c7bSAndrew Deason 2922*59e35c7bSAndrew Deason address_item = g_malloc0(sizeof(*address_item)); 2923*59e35c7bSAndrew Deason address_item->ip_address = g_strdup(addr6); 2924*59e35c7bSAndrew Deason address_item->ip_address_type = GUEST_IP_ADDRESS_TYPE_IPV6; 2925*59e35c7bSAndrew Deason 2926*59e35c7bSAndrew Deason if (ifa->ifa_netmask) { 2927*59e35c7bSAndrew Deason /* Count the number of set bits in netmask. 2928*59e35c7bSAndrew Deason * This is safe as '1' and '0' cannot be shuffled in netmask. */ 2929*59e35c7bSAndrew Deason p = &((struct sockaddr_in6 *)ifa->ifa_netmask)->sin6_addr; 2930*59e35c7bSAndrew Deason address_item->prefix = 2931*59e35c7bSAndrew Deason ctpop32(((uint32_t *) p)[0]) + 2932*59e35c7bSAndrew Deason ctpop32(((uint32_t *) p)[1]) + 2933*59e35c7bSAndrew Deason ctpop32(((uint32_t *) p)[2]) + 2934*59e35c7bSAndrew Deason ctpop32(((uint32_t *) p)[3]); 2935*59e35c7bSAndrew Deason } 2936*59e35c7bSAndrew Deason } 2937*59e35c7bSAndrew Deason 2938*59e35c7bSAndrew Deason if (!address_item) { 2939*59e35c7bSAndrew Deason continue; 2940*59e35c7bSAndrew Deason } 2941*59e35c7bSAndrew Deason 2942*59e35c7bSAndrew Deason address_tail = &info->ip_addresses; 2943*59e35c7bSAndrew Deason while (*address_tail) { 2944*59e35c7bSAndrew Deason address_tail = &(*address_tail)->next; 2945*59e35c7bSAndrew Deason } 2946*59e35c7bSAndrew Deason QAPI_LIST_APPEND(address_tail, address_item); 2947*59e35c7bSAndrew Deason 2948*59e35c7bSAndrew Deason info->has_ip_addresses = true; 2949*59e35c7bSAndrew Deason 2950*59e35c7bSAndrew Deason if (!info->has_statistics) { 2951*59e35c7bSAndrew Deason interface_stat = g_malloc0(sizeof(*interface_stat)); 2952*59e35c7bSAndrew Deason if (guest_get_network_stats(info->name, interface_stat) == -1) { 2953*59e35c7bSAndrew Deason info->has_statistics = false; 2954*59e35c7bSAndrew Deason g_free(interface_stat); 2955*59e35c7bSAndrew Deason } else { 2956*59e35c7bSAndrew Deason info->statistics = interface_stat; 2957*59e35c7bSAndrew Deason info->has_statistics = true; 2958*59e35c7bSAndrew Deason } 2959*59e35c7bSAndrew Deason } 2960*59e35c7bSAndrew Deason } 2961*59e35c7bSAndrew Deason 2962*59e35c7bSAndrew Deason freeifaddrs(ifap); 2963*59e35c7bSAndrew Deason return head; 2964*59e35c7bSAndrew Deason 2965*59e35c7bSAndrew Deason error: 2966*59e35c7bSAndrew Deason freeifaddrs(ifap); 2967*59e35c7bSAndrew Deason qapi_free_GuestNetworkInterfaceList(head); 2968*59e35c7bSAndrew Deason return NULL; 2969*59e35c7bSAndrew Deason } 2970*59e35c7bSAndrew Deason 2971*59e35c7bSAndrew Deason #else 2972*59e35c7bSAndrew Deason 2973*59e35c7bSAndrew Deason GuestNetworkInterfaceList *qmp_guest_network_get_interfaces(Error **errp) 2974*59e35c7bSAndrew Deason { 2975*59e35c7bSAndrew Deason error_setg(errp, QERR_UNSUPPORTED); 2976*59e35c7bSAndrew Deason return NULL; 2977*59e35c7bSAndrew Deason } 2978*59e35c7bSAndrew Deason 2979*59e35c7bSAndrew Deason #endif /* HAVE_GETIFADDRS */ 2980*59e35c7bSAndrew Deason 2981d35d4cb5SMichael Roth #if !defined(CONFIG_FSFREEZE) 2982d35d4cb5SMichael Roth 298346d4c572STomoki Sekiyama GuestFilesystemInfoList *qmp_guest_get_fsinfo(Error **errp) 298446d4c572STomoki Sekiyama { 2985c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 298646d4c572STomoki Sekiyama return NULL; 298746d4c572STomoki Sekiyama } 298846d4c572STomoki Sekiyama 298977dbc81bSMarkus Armbruster GuestFsfreezeStatus qmp_guest_fsfreeze_status(Error **errp) 2990d35d4cb5SMichael Roth { 2991c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2992d35d4cb5SMichael Roth 2993d35d4cb5SMichael Roth return 0; 2994d35d4cb5SMichael Roth } 2995d35d4cb5SMichael Roth 299677dbc81bSMarkus Armbruster int64_t qmp_guest_fsfreeze_freeze(Error **errp) 2997d35d4cb5SMichael Roth { 2998c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2999d35d4cb5SMichael Roth 3000d35d4cb5SMichael Roth return 0; 3001d35d4cb5SMichael Roth } 3002d35d4cb5SMichael Roth 3003e99bce20STomoki Sekiyama int64_t qmp_guest_fsfreeze_freeze_list(bool has_mountpoints, 3004e99bce20STomoki Sekiyama strList *mountpoints, 3005e99bce20STomoki Sekiyama Error **errp) 3006e99bce20STomoki Sekiyama { 3007c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3008e99bce20STomoki Sekiyama 3009e99bce20STomoki Sekiyama return 0; 3010e99bce20STomoki Sekiyama } 3011e99bce20STomoki Sekiyama 301277dbc81bSMarkus Armbruster int64_t qmp_guest_fsfreeze_thaw(Error **errp) 3013d35d4cb5SMichael Roth { 3014c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3015d35d4cb5SMichael Roth 3016d35d4cb5SMichael Roth return 0; 3017d35d4cb5SMichael Roth } 3018fed39564STomáš Golembiovský 3019fed39564STomáš Golembiovský GuestDiskInfoList *qmp_guest_get_disks(Error **errp) 3020fed39564STomáš Golembiovský { 3021fed39564STomáš Golembiovský error_setg(errp, QERR_UNSUPPORTED); 3022fed39564STomáš Golembiovský return NULL; 3023fed39564STomáš Golembiovský } 3024fed39564STomáš Golembiovský 3025eab5fd59SPaolo Bonzini #endif /* CONFIG_FSFREEZE */ 3026d35d4cb5SMichael Roth 3027eab5fd59SPaolo Bonzini #if !defined(CONFIG_FSTRIM) 3028e82855d9SJustin Ossevoort GuestFilesystemTrimResponse * 3029e82855d9SJustin Ossevoort qmp_guest_fstrim(bool has_minimum, int64_t minimum, Error **errp) 3030eab5fd59SPaolo Bonzini { 3031c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 3032e82855d9SJustin Ossevoort return NULL; 3033eab5fd59SPaolo Bonzini } 3034d35d4cb5SMichael Roth #endif 3035d35d4cb5SMichael Roth 30361281c08aSTomoki Sekiyama /* add unsupported commands to the blacklist */ 30371281c08aSTomoki Sekiyama GList *ga_command_blacklist_init(GList *blacklist) 30381281c08aSTomoki Sekiyama { 30391281c08aSTomoki Sekiyama #if !defined(__linux__) 30401281c08aSTomoki Sekiyama { 30411281c08aSTomoki Sekiyama const char *list[] = { 30421281c08aSTomoki Sekiyama "guest-suspend-disk", "guest-suspend-ram", 3043*59e35c7bSAndrew Deason "guest-suspend-hybrid", "guest-get-vcpus", "guest-set-vcpus", 30440dd38a03Szhanghailiang "guest-get-memory-blocks", "guest-set-memory-blocks", 304528d8dd35SBasil Salman "guest-get-memory-block-size", "guest-get-memory-block-info", 304628d8dd35SBasil Salman NULL}; 30471281c08aSTomoki Sekiyama char **p = (char **)list; 30481281c08aSTomoki Sekiyama 30491281c08aSTomoki Sekiyama while (*p) { 30504bca81ceSMarc-André Lureau blacklist = g_list_append(blacklist, g_strdup(*p++)); 30511281c08aSTomoki Sekiyama } 30521281c08aSTomoki Sekiyama } 30531281c08aSTomoki Sekiyama #endif 30541281c08aSTomoki Sekiyama 3055*59e35c7bSAndrew Deason #if !defined(HAVE_GETIFADDRS) 3056*59e35c7bSAndrew Deason blacklist = g_list_append(blacklist, 3057*59e35c7bSAndrew Deason g_strdup("guest-network-get-interfaces")); 3058*59e35c7bSAndrew Deason #endif 3059*59e35c7bSAndrew Deason 30601281c08aSTomoki Sekiyama #if !defined(CONFIG_FSFREEZE) 30611281c08aSTomoki Sekiyama { 30621281c08aSTomoki Sekiyama const char *list[] = { 30631281c08aSTomoki Sekiyama "guest-get-fsinfo", "guest-fsfreeze-status", 30641281c08aSTomoki Sekiyama "guest-fsfreeze-freeze", "guest-fsfreeze-freeze-list", 3065fed39564STomáš Golembiovský "guest-fsfreeze-thaw", "guest-get-fsinfo", 3066fed39564STomáš Golembiovský "guest-get-disks", NULL}; 30671281c08aSTomoki Sekiyama char **p = (char **)list; 30681281c08aSTomoki Sekiyama 30691281c08aSTomoki Sekiyama while (*p) { 30704bca81ceSMarc-André Lureau blacklist = g_list_append(blacklist, g_strdup(*p++)); 30711281c08aSTomoki Sekiyama } 30721281c08aSTomoki Sekiyama } 30731281c08aSTomoki Sekiyama #endif 30741281c08aSTomoki Sekiyama 30751281c08aSTomoki Sekiyama #if !defined(CONFIG_FSTRIM) 30764bca81ceSMarc-André Lureau blacklist = g_list_append(blacklist, g_strdup("guest-fstrim")); 30771281c08aSTomoki Sekiyama #endif 30781281c08aSTomoki Sekiyama 30792e4211ceSTomáš Golembiovský blacklist = g_list_append(blacklist, g_strdup("guest-get-devices")); 30802e4211ceSTomáš Golembiovský 30811281c08aSTomoki Sekiyama return blacklist; 30821281c08aSTomoki Sekiyama } 30831281c08aSTomoki Sekiyama 3084c216e5adSMichael Roth /* register init/cleanup routines for stateful command groups */ 3085c216e5adSMichael Roth void ga_command_state_init(GAState *s, GACommandState *cs) 3086c216e5adSMichael Roth { 3087c216e5adSMichael Roth #if defined(CONFIG_FSFREEZE) 3088f22d85e9SMichael Roth ga_command_state_add(cs, NULL, guest_fsfreeze_cleanup); 3089c216e5adSMichael Roth #endif 3090c216e5adSMichael Roth } 3091161a56a9SVinzenz Feenstra 3092e674605fSTomáš Golembiovský #ifdef HAVE_UTMPX 3093e674605fSTomáš Golembiovský 3094161a56a9SVinzenz Feenstra #define QGA_MICRO_SECOND_TO_SECOND 1000000 3095161a56a9SVinzenz Feenstra 3096161a56a9SVinzenz Feenstra static double ga_get_login_time(struct utmpx *user_info) 3097161a56a9SVinzenz Feenstra { 3098161a56a9SVinzenz Feenstra double seconds = (double)user_info->ut_tv.tv_sec; 3099161a56a9SVinzenz Feenstra double useconds = (double)user_info->ut_tv.tv_usec; 3100161a56a9SVinzenz Feenstra useconds /= QGA_MICRO_SECOND_TO_SECOND; 3101161a56a9SVinzenz Feenstra return seconds + useconds; 3102161a56a9SVinzenz Feenstra } 3103161a56a9SVinzenz Feenstra 3104b90abbacSVladimir Sementsov-Ogievskiy GuestUserList *qmp_guest_get_users(Error **errp) 3105161a56a9SVinzenz Feenstra { 3106161a56a9SVinzenz Feenstra GHashTable *cache = NULL; 310795b3a8c8SEric Blake GuestUserList *head = NULL, **tail = &head; 3108161a56a9SVinzenz Feenstra struct utmpx *user_info = NULL; 3109161a56a9SVinzenz Feenstra gpointer value = NULL; 3110161a56a9SVinzenz Feenstra GuestUser *user = NULL; 3111161a56a9SVinzenz Feenstra double login_time = 0; 3112161a56a9SVinzenz Feenstra 3113161a56a9SVinzenz Feenstra cache = g_hash_table_new(g_str_hash, g_str_equal); 3114161a56a9SVinzenz Feenstra setutxent(); 3115161a56a9SVinzenz Feenstra 3116161a56a9SVinzenz Feenstra for (;;) { 3117161a56a9SVinzenz Feenstra user_info = getutxent(); 3118161a56a9SVinzenz Feenstra if (user_info == NULL) { 3119161a56a9SVinzenz Feenstra break; 3120161a56a9SVinzenz Feenstra } else if (user_info->ut_type != USER_PROCESS) { 3121161a56a9SVinzenz Feenstra continue; 3122161a56a9SVinzenz Feenstra } else if (g_hash_table_contains(cache, user_info->ut_user)) { 3123161a56a9SVinzenz Feenstra value = g_hash_table_lookup(cache, user_info->ut_user); 3124161a56a9SVinzenz Feenstra user = (GuestUser *)value; 3125161a56a9SVinzenz Feenstra login_time = ga_get_login_time(user_info); 3126161a56a9SVinzenz Feenstra /* We're ensuring the earliest login time to be sent */ 3127161a56a9SVinzenz Feenstra if (login_time < user->login_time) { 3128161a56a9SVinzenz Feenstra user->login_time = login_time; 3129161a56a9SVinzenz Feenstra } 3130161a56a9SVinzenz Feenstra continue; 3131161a56a9SVinzenz Feenstra } 3132161a56a9SVinzenz Feenstra 313395b3a8c8SEric Blake user = g_new0(GuestUser, 1); 313495b3a8c8SEric Blake user->user = g_strdup(user_info->ut_user); 313595b3a8c8SEric Blake user->login_time = ga_get_login_time(user_info); 3136161a56a9SVinzenz Feenstra 313795b3a8c8SEric Blake g_hash_table_insert(cache, user->user, user); 3138161a56a9SVinzenz Feenstra 313995b3a8c8SEric Blake QAPI_LIST_APPEND(tail, user); 3140161a56a9SVinzenz Feenstra } 3141161a56a9SVinzenz Feenstra endutxent(); 3142161a56a9SVinzenz Feenstra g_hash_table_destroy(cache); 3143161a56a9SVinzenz Feenstra return head; 3144161a56a9SVinzenz Feenstra } 3145e674605fSTomáš Golembiovský 3146e674605fSTomáš Golembiovský #else 3147e674605fSTomáš Golembiovský 3148e674605fSTomáš Golembiovský GuestUserList *qmp_guest_get_users(Error **errp) 3149e674605fSTomáš Golembiovský { 3150e674605fSTomáš Golembiovský error_setg(errp, QERR_UNSUPPORTED); 3151e674605fSTomáš Golembiovský return NULL; 3152e674605fSTomáš Golembiovský } 3153e674605fSTomáš Golembiovský 3154e674605fSTomáš Golembiovský #endif 31559848f797STomáš Golembiovský 31569848f797STomáš Golembiovský /* Replace escaped special characters with theire real values. The replacement 31579848f797STomáš Golembiovský * is done in place -- returned value is in the original string. 31589848f797STomáš Golembiovský */ 31599848f797STomáš Golembiovský static void ga_osrelease_replace_special(gchar *value) 31609848f797STomáš Golembiovský { 31619848f797STomáš Golembiovský gchar *p, *p2, quote; 31629848f797STomáš Golembiovský 31639848f797STomáš Golembiovský /* Trim the string at first space or semicolon if it is not enclosed in 31649848f797STomáš Golembiovský * single or double quotes. */ 31659848f797STomáš Golembiovský if ((value[0] != '"') || (value[0] == '\'')) { 31669848f797STomáš Golembiovský p = strchr(value, ' '); 31679848f797STomáš Golembiovský if (p != NULL) { 31689848f797STomáš Golembiovský *p = 0; 31699848f797STomáš Golembiovský } 31709848f797STomáš Golembiovský p = strchr(value, ';'); 31719848f797STomáš Golembiovský if (p != NULL) { 31729848f797STomáš Golembiovský *p = 0; 31739848f797STomáš Golembiovský } 31749848f797STomáš Golembiovský return; 31759848f797STomáš Golembiovský } 31769848f797STomáš Golembiovský 31779848f797STomáš Golembiovský quote = value[0]; 31789848f797STomáš Golembiovský p2 = value; 31799848f797STomáš Golembiovský p = value + 1; 31809848f797STomáš Golembiovský while (*p != 0) { 31819848f797STomáš Golembiovský if (*p == '\\') { 31829848f797STomáš Golembiovský p++; 31839848f797STomáš Golembiovský switch (*p) { 31849848f797STomáš Golembiovský case '$': 31859848f797STomáš Golembiovský case '\'': 31869848f797STomáš Golembiovský case '"': 31879848f797STomáš Golembiovský case '\\': 31889848f797STomáš Golembiovský case '`': 31899848f797STomáš Golembiovský break; 31909848f797STomáš Golembiovský default: 31919848f797STomáš Golembiovský /* Keep literal backslash followed by whatever is there */ 31929848f797STomáš Golembiovský p--; 31939848f797STomáš Golembiovský break; 31949848f797STomáš Golembiovský } 31959848f797STomáš Golembiovský } else if (*p == quote) { 31969848f797STomáš Golembiovský *p2 = 0; 31979848f797STomáš Golembiovský break; 31989848f797STomáš Golembiovský } 31999848f797STomáš Golembiovský *(p2++) = *(p++); 32009848f797STomáš Golembiovský } 32019848f797STomáš Golembiovský } 32029848f797STomáš Golembiovský 32039848f797STomáš Golembiovský static GKeyFile *ga_parse_osrelease(const char *fname) 32049848f797STomáš Golembiovský { 32059848f797STomáš Golembiovský gchar *content = NULL; 32069848f797STomáš Golembiovský gchar *content2 = NULL; 32079848f797STomáš Golembiovský GError *err = NULL; 32089848f797STomáš Golembiovský GKeyFile *keys = g_key_file_new(); 32099848f797STomáš Golembiovský const char *group = "[os-release]\n"; 32109848f797STomáš Golembiovský 32119848f797STomáš Golembiovský if (!g_file_get_contents(fname, &content, NULL, &err)) { 32129848f797STomáš Golembiovský slog("failed to read '%s', error: %s", fname, err->message); 32139848f797STomáš Golembiovský goto fail; 32149848f797STomáš Golembiovský } 32159848f797STomáš Golembiovský 32169848f797STomáš Golembiovský if (!g_utf8_validate(content, -1, NULL)) { 32179848f797STomáš Golembiovský slog("file is not utf-8 encoded: %s", fname); 32189848f797STomáš Golembiovský goto fail; 32199848f797STomáš Golembiovský } 32209848f797STomáš Golembiovský content2 = g_strdup_printf("%s%s", group, content); 32219848f797STomáš Golembiovský 32229848f797STomáš Golembiovský if (!g_key_file_load_from_data(keys, content2, -1, G_KEY_FILE_NONE, 32239848f797STomáš Golembiovský &err)) { 32249848f797STomáš Golembiovský slog("failed to parse file '%s', error: %s", fname, err->message); 32259848f797STomáš Golembiovský goto fail; 32269848f797STomáš Golembiovský } 32279848f797STomáš Golembiovský 32289848f797STomáš Golembiovský g_free(content); 32299848f797STomáš Golembiovský g_free(content2); 32309848f797STomáš Golembiovský return keys; 32319848f797STomáš Golembiovský 32329848f797STomáš Golembiovský fail: 32339848f797STomáš Golembiovský g_error_free(err); 32349848f797STomáš Golembiovský g_free(content); 32359848f797STomáš Golembiovský g_free(content2); 32369848f797STomáš Golembiovský g_key_file_free(keys); 32379848f797STomáš Golembiovský return NULL; 32389848f797STomáš Golembiovský } 32399848f797STomáš Golembiovský 32409848f797STomáš Golembiovský GuestOSInfo *qmp_guest_get_osinfo(Error **errp) 32419848f797STomáš Golembiovský { 32429848f797STomáš Golembiovský GuestOSInfo *info = NULL; 32439848f797STomáš Golembiovský struct utsname kinfo; 3244339ca68bSTomáš Golembiovský GKeyFile *osrelease = NULL; 3245339ca68bSTomáš Golembiovský const char *qga_os_release = g_getenv("QGA_OS_RELEASE"); 32469848f797STomáš Golembiovský 32479848f797STomáš Golembiovský info = g_new0(GuestOSInfo, 1); 32489848f797STomáš Golembiovský 32499848f797STomáš Golembiovský if (uname(&kinfo) != 0) { 32509848f797STomáš Golembiovský error_setg_errno(errp, errno, "uname failed"); 32519848f797STomáš Golembiovský } else { 32529848f797STomáš Golembiovský info->has_kernel_version = true; 32539848f797STomáš Golembiovský info->kernel_version = g_strdup(kinfo.version); 32549848f797STomáš Golembiovský info->has_kernel_release = true; 32559848f797STomáš Golembiovský info->kernel_release = g_strdup(kinfo.release); 32569848f797STomáš Golembiovský info->has_machine = true; 32579848f797STomáš Golembiovský info->machine = g_strdup(kinfo.machine); 32589848f797STomáš Golembiovský } 32599848f797STomáš Golembiovský 3260339ca68bSTomáš Golembiovský if (qga_os_release != NULL) { 3261339ca68bSTomáš Golembiovský osrelease = ga_parse_osrelease(qga_os_release); 3262339ca68bSTomáš Golembiovský } else { 32639848f797STomáš Golembiovský osrelease = ga_parse_osrelease("/etc/os-release"); 32649848f797STomáš Golembiovský if (osrelease == NULL) { 32659848f797STomáš Golembiovský osrelease = ga_parse_osrelease("/usr/lib/os-release"); 32669848f797STomáš Golembiovský } 3267339ca68bSTomáš Golembiovský } 32689848f797STomáš Golembiovský 32699848f797STomáš Golembiovský if (osrelease != NULL) { 32709848f797STomáš Golembiovský char *value; 32719848f797STomáš Golembiovský 32729848f797STomáš Golembiovský #define GET_FIELD(field, osfield) do { \ 32739848f797STomáš Golembiovský value = g_key_file_get_value(osrelease, "os-release", osfield, NULL); \ 32749848f797STomáš Golembiovský if (value != NULL) { \ 32759848f797STomáš Golembiovský ga_osrelease_replace_special(value); \ 32769848f797STomáš Golembiovský info->has_ ## field = true; \ 32779848f797STomáš Golembiovský info->field = value; \ 32789848f797STomáš Golembiovský } \ 32799848f797STomáš Golembiovský } while (0) 32809848f797STomáš Golembiovský GET_FIELD(id, "ID"); 32819848f797STomáš Golembiovský GET_FIELD(name, "NAME"); 32829848f797STomáš Golembiovský GET_FIELD(pretty_name, "PRETTY_NAME"); 32839848f797STomáš Golembiovský GET_FIELD(version, "VERSION"); 32849848f797STomáš Golembiovský GET_FIELD(version_id, "VERSION_ID"); 32859848f797STomáš Golembiovský GET_FIELD(variant, "VARIANT"); 32869848f797STomáš Golembiovský GET_FIELD(variant_id, "VARIANT_ID"); 32879848f797STomáš Golembiovský #undef GET_FIELD 32889848f797STomáš Golembiovský 32899848f797STomáš Golembiovský g_key_file_free(osrelease); 32909848f797STomáš Golembiovský } 32919848f797STomáš Golembiovský 32929848f797STomáš Golembiovský return info; 32939848f797STomáš Golembiovský } 32942e4211ceSTomáš Golembiovský 32952e4211ceSTomáš Golembiovský GuestDeviceInfoList *qmp_guest_get_devices(Error **errp) 32962e4211ceSTomáš Golembiovský { 32972e4211ceSTomáš Golembiovský error_setg(errp, QERR_UNSUPPORTED); 32982e4211ceSTomáš Golembiovský 32992e4211ceSTomáš Golembiovský return NULL; 33002e4211ceSTomáš Golembiovský } 3301548fb0daSMarc-André Lureau 3302548fb0daSMarc-André Lureau #ifndef HOST_NAME_MAX 3303548fb0daSMarc-André Lureau # ifdef _POSIX_HOST_NAME_MAX 3304548fb0daSMarc-André Lureau # define HOST_NAME_MAX _POSIX_HOST_NAME_MAX 3305548fb0daSMarc-André Lureau # else 3306548fb0daSMarc-André Lureau # define HOST_NAME_MAX 255 3307548fb0daSMarc-André Lureau # endif 3308548fb0daSMarc-André Lureau #endif 3309548fb0daSMarc-André Lureau 3310548fb0daSMarc-André Lureau char *qga_get_host_name(Error **errp) 3311548fb0daSMarc-André Lureau { 3312548fb0daSMarc-André Lureau long len = -1; 3313548fb0daSMarc-André Lureau g_autofree char *hostname = NULL; 3314548fb0daSMarc-André Lureau 3315548fb0daSMarc-André Lureau #ifdef _SC_HOST_NAME_MAX 3316548fb0daSMarc-André Lureau len = sysconf(_SC_HOST_NAME_MAX); 3317548fb0daSMarc-André Lureau #endif /* _SC_HOST_NAME_MAX */ 3318548fb0daSMarc-André Lureau 3319548fb0daSMarc-André Lureau if (len < 0) { 3320548fb0daSMarc-André Lureau len = HOST_NAME_MAX; 3321548fb0daSMarc-André Lureau } 3322548fb0daSMarc-André Lureau 3323548fb0daSMarc-André Lureau /* Unfortunately, gethostname() below does not guarantee a 3324548fb0daSMarc-André Lureau * NULL terminated string. Therefore, allocate one byte more 3325548fb0daSMarc-André Lureau * to be sure. */ 3326548fb0daSMarc-André Lureau hostname = g_new0(char, len + 1); 3327548fb0daSMarc-André Lureau 3328548fb0daSMarc-André Lureau if (gethostname(hostname, len) < 0) { 3329548fb0daSMarc-André Lureau error_setg_errno(errp, errno, 3330548fb0daSMarc-André Lureau "cannot get hostname"); 3331548fb0daSMarc-André Lureau return NULL; 3332548fb0daSMarc-André Lureau } 3333548fb0daSMarc-André Lureau 3334548fb0daSMarc-André Lureau return g_steal_pointer(&hostname); 3335548fb0daSMarc-André Lureau } 3336