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 14c216e5adSMichael Roth #include <glib.h> 15c216e5adSMichael Roth #include <sys/types.h> 16c216e5adSMichael Roth #include <sys/ioctl.h> 172c02cbf6SLuiz Capitulino #include <sys/wait.h> 18d2baff62SLaszlo Ersek #include <unistd.h> 19d2baff62SLaszlo Ersek #include <errno.h> 20d2baff62SLaszlo Ersek #include <fcntl.h> 2146d4c572STomoki Sekiyama #include <dirent.h> 22c689b4f1SLaszlo Ersek #include <stdio.h> 23c689b4f1SLaszlo Ersek #include <string.h> 24c689b4f1SLaszlo Ersek #include <sys/stat.h> 25d2baff62SLaszlo Ersek #include <inttypes.h> 26c216e5adSMichael Roth #include "qga/guest-agent-core.h" 27c216e5adSMichael Roth #include "qga-qmp-commands.h" 287b1b5d19SPaolo Bonzini #include "qapi/qmp/qerror.h" 291de7afc9SPaolo Bonzini #include "qemu/queue.h" 301de7afc9SPaolo Bonzini #include "qemu/host-utils.h" 31c216e5adSMichael Roth 322c02cbf6SLuiz Capitulino #ifndef CONFIG_HAS_ENVIRON 33eecae147SAndreas Färber #ifdef __APPLE__ 34eecae147SAndreas Färber #include <crt_externs.h> 35eecae147SAndreas Färber #define environ (*_NSGetEnviron()) 36eecae147SAndreas Färber #else 372c02cbf6SLuiz Capitulino extern char **environ; 382c02cbf6SLuiz Capitulino #endif 39eecae147SAndreas Färber #endif 402c02cbf6SLuiz Capitulino 41e72c3f2eSMichael Roth #if defined(__linux__) 42e72c3f2eSMichael Roth #include <mntent.h> 43e72c3f2eSMichael Roth #include <linux/fs.h> 44e72c3f2eSMichael Roth #include <ifaddrs.h> 45e72c3f2eSMichael Roth #include <arpa/inet.h> 46e72c3f2eSMichael Roth #include <sys/socket.h> 47e72c3f2eSMichael Roth #include <net/if.h> 48e72c3f2eSMichael Roth 49eab5fd59SPaolo Bonzini #ifdef FIFREEZE 50e72c3f2eSMichael Roth #define CONFIG_FSFREEZE 51e72c3f2eSMichael Roth #endif 52eab5fd59SPaolo Bonzini #ifdef FITRIM 53eab5fd59SPaolo Bonzini #define CONFIG_FSTRIM 54eab5fd59SPaolo Bonzini #endif 55e72c3f2eSMichael Roth #endif 56e72c3f2eSMichael Roth 5777dbc81bSMarkus Armbruster static void ga_wait_child(pid_t pid, int *status, Error **errp) 58d220a6dfSLuiz Capitulino { 59d220a6dfSLuiz Capitulino pid_t rpid; 60d220a6dfSLuiz Capitulino 61d220a6dfSLuiz Capitulino *status = 0; 62d220a6dfSLuiz Capitulino 63d220a6dfSLuiz Capitulino do { 64d220a6dfSLuiz Capitulino rpid = waitpid(pid, status, 0); 65d220a6dfSLuiz Capitulino } while (rpid == -1 && errno == EINTR); 66d220a6dfSLuiz Capitulino 67d220a6dfSLuiz Capitulino if (rpid == -1) { 6877dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to wait for child (pid: %d)", 6977dbc81bSMarkus Armbruster pid); 70d220a6dfSLuiz Capitulino return; 71d220a6dfSLuiz Capitulino } 72d220a6dfSLuiz Capitulino 73d220a6dfSLuiz Capitulino g_assert(rpid == pid); 74d220a6dfSLuiz Capitulino } 75d220a6dfSLuiz Capitulino 7677dbc81bSMarkus Armbruster void qmp_guest_shutdown(bool has_mode, const char *mode, Error **errp) 77c216e5adSMichael Roth { 78c216e5adSMichael Roth const char *shutdown_flag; 79d220a6dfSLuiz Capitulino Error *local_err = NULL; 80d220a6dfSLuiz Capitulino pid_t pid; 813674838cSLuiz Capitulino int status; 82c216e5adSMichael Roth 83c216e5adSMichael Roth slog("guest-shutdown called, mode: %s", mode); 84c216e5adSMichael Roth if (!has_mode || strcmp(mode, "powerdown") == 0) { 85c216e5adSMichael Roth shutdown_flag = "-P"; 86c216e5adSMichael Roth } else if (strcmp(mode, "halt") == 0) { 87c216e5adSMichael Roth shutdown_flag = "-H"; 88c216e5adSMichael Roth } else if (strcmp(mode, "reboot") == 0) { 89c216e5adSMichael Roth shutdown_flag = "-r"; 90c216e5adSMichael Roth } else { 9177dbc81bSMarkus Armbruster error_setg(errp, 92d220a6dfSLuiz Capitulino "mode is invalid (valid values are: halt|powerdown|reboot"); 93c216e5adSMichael Roth return; 94c216e5adSMichael Roth } 95c216e5adSMichael Roth 96d5dd3498SLuiz Capitulino pid = fork(); 97d5dd3498SLuiz Capitulino if (pid == 0) { 98c216e5adSMichael Roth /* child, start the shutdown */ 99c216e5adSMichael Roth setsid(); 1003674838cSLuiz Capitulino reopen_fd_to_null(0); 1013674838cSLuiz Capitulino reopen_fd_to_null(1); 1023674838cSLuiz Capitulino reopen_fd_to_null(2); 103c216e5adSMichael Roth 104485e741cSwhitearchey execle("/sbin/shutdown", "shutdown", "-h", shutdown_flag, "+0", 1053674838cSLuiz Capitulino "hypervisor initiated shutdown", (char*)NULL, environ); 1063674838cSLuiz Capitulino _exit(EXIT_FAILURE); 107d5dd3498SLuiz Capitulino } else if (pid < 0) { 10877dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to create child process"); 109d5dd3498SLuiz Capitulino return; 110d5dd3498SLuiz Capitulino } 111d5dd3498SLuiz Capitulino 112d220a6dfSLuiz Capitulino ga_wait_child(pid, &status, &local_err); 11384d18f06SMarkus Armbruster if (local_err) { 11477dbc81bSMarkus Armbruster error_propagate(errp, local_err); 115d220a6dfSLuiz Capitulino return; 116d220a6dfSLuiz Capitulino } 117d220a6dfSLuiz Capitulino 118d220a6dfSLuiz Capitulino if (!WIFEXITED(status)) { 11977dbc81bSMarkus Armbruster error_setg(errp, "child process has terminated abnormally"); 120d220a6dfSLuiz Capitulino return; 121d220a6dfSLuiz Capitulino } 122d220a6dfSLuiz Capitulino 123d220a6dfSLuiz Capitulino if (WEXITSTATUS(status)) { 12477dbc81bSMarkus Armbruster error_setg(errp, "child process has failed to shutdown"); 125d220a6dfSLuiz Capitulino return; 126d220a6dfSLuiz Capitulino } 127d220a6dfSLuiz Capitulino 128085d8134SPeter Maydell /* succeeded */ 129c216e5adSMichael Roth } 130c216e5adSMichael Roth 1316912e6a9SLei Li int64_t qmp_guest_get_time(Error **errp) 1326912e6a9SLei Li { 1336912e6a9SLei Li int ret; 1346912e6a9SLei Li qemu_timeval tq; 1356912e6a9SLei Li int64_t time_ns; 1366912e6a9SLei Li 1376912e6a9SLei Li ret = qemu_gettimeofday(&tq); 1386912e6a9SLei Li if (ret < 0) { 1396912e6a9SLei Li error_setg_errno(errp, errno, "Failed to get time"); 1406912e6a9SLei Li return -1; 1416912e6a9SLei Li } 1426912e6a9SLei Li 1436912e6a9SLei Li time_ns = tq.tv_sec * 1000000000LL + tq.tv_usec * 1000; 1446912e6a9SLei Li return time_ns; 1456912e6a9SLei Li } 1466912e6a9SLei Li 1472c958923SMichal Privoznik void qmp_guest_set_time(bool has_time, int64_t time_ns, Error **errp) 148a1bca57fSLei Li { 149a1bca57fSLei Li int ret; 150a1bca57fSLei Li int status; 151a1bca57fSLei Li pid_t pid; 152a1bca57fSLei Li Error *local_err = NULL; 153a1bca57fSLei Li struct timeval tv; 154a1bca57fSLei Li 1552c958923SMichal Privoznik /* If user has passed a time, validate and set it. */ 1562c958923SMichal Privoznik if (has_time) { 157a1bca57fSLei Li /* year-2038 will overflow in case time_t is 32bit */ 158a1bca57fSLei Li if (time_ns / 1000000000 != (time_t)(time_ns / 1000000000)) { 159a1bca57fSLei Li error_setg(errp, "Time %" PRId64 " is too large", time_ns); 160a1bca57fSLei Li return; 161a1bca57fSLei Li } 162a1bca57fSLei Li 163a1bca57fSLei Li tv.tv_sec = time_ns / 1000000000; 164a1bca57fSLei Li tv.tv_usec = (time_ns % 1000000000) / 1000; 165a1bca57fSLei Li 166a1bca57fSLei Li ret = settimeofday(&tv, NULL); 167a1bca57fSLei Li if (ret < 0) { 168a1bca57fSLei Li error_setg_errno(errp, errno, "Failed to set time to guest"); 169a1bca57fSLei Li return; 170a1bca57fSLei Li } 1712c958923SMichal Privoznik } 172a1bca57fSLei Li 1732c958923SMichal Privoznik /* Now, if user has passed a time to set and the system time is set, we 1742c958923SMichal Privoznik * just need to synchronize the hardware clock. However, if no time was 1752c958923SMichal Privoznik * passed, user is requesting the opposite: set the system time from the 1761634df56SAmos Kong * hardware clock (RTC). */ 177a1bca57fSLei Li pid = fork(); 178a1bca57fSLei Li if (pid == 0) { 179a1bca57fSLei Li setsid(); 180a1bca57fSLei Li reopen_fd_to_null(0); 181a1bca57fSLei Li reopen_fd_to_null(1); 182a1bca57fSLei Li reopen_fd_to_null(2); 183a1bca57fSLei Li 1842c958923SMichal Privoznik /* Use '/sbin/hwclock -w' to set RTC from the system time, 1852c958923SMichal Privoznik * or '/sbin/hwclock -s' to set the system time from RTC. */ 1862c958923SMichal Privoznik execle("/sbin/hwclock", "hwclock", has_time ? "-w" : "-s", 1872c958923SMichal Privoznik NULL, environ); 188a1bca57fSLei Li _exit(EXIT_FAILURE); 189a1bca57fSLei Li } else if (pid < 0) { 190a1bca57fSLei Li error_setg_errno(errp, errno, "failed to create child process"); 191a1bca57fSLei Li return; 192a1bca57fSLei Li } 193a1bca57fSLei Li 194a1bca57fSLei Li ga_wait_child(pid, &status, &local_err); 19584d18f06SMarkus Armbruster if (local_err) { 196a1bca57fSLei Li error_propagate(errp, local_err); 197a1bca57fSLei Li return; 198a1bca57fSLei Li } 199a1bca57fSLei Li 200a1bca57fSLei Li if (!WIFEXITED(status)) { 201a1bca57fSLei Li error_setg(errp, "child process has terminated abnormally"); 202a1bca57fSLei Li return; 203a1bca57fSLei Li } 204a1bca57fSLei Li 205a1bca57fSLei Li if (WEXITSTATUS(status)) { 206a1bca57fSLei Li error_setg(errp, "hwclock failed to set hardware clock to system time"); 207a1bca57fSLei Li return; 208a1bca57fSLei Li } 209a1bca57fSLei Li } 210a1bca57fSLei Li 211c216e5adSMichael Roth typedef struct GuestFileHandle { 212c216e5adSMichael Roth uint64_t id; 213c216e5adSMichael Roth FILE *fh; 214c216e5adSMichael Roth QTAILQ_ENTRY(GuestFileHandle) next; 215c216e5adSMichael Roth } GuestFileHandle; 216c216e5adSMichael Roth 217c216e5adSMichael Roth static struct { 218c216e5adSMichael Roth QTAILQ_HEAD(, GuestFileHandle) filehandles; 219c216e5adSMichael Roth } guest_file_state; 220c216e5adSMichael Roth 22139097dafSMichael Roth static int64_t guest_file_handle_add(FILE *fh, Error **errp) 222c216e5adSMichael Roth { 223c216e5adSMichael Roth GuestFileHandle *gfh; 22439097dafSMichael Roth int64_t handle; 22539097dafSMichael Roth 22639097dafSMichael Roth handle = ga_get_fd_handle(ga_state, errp); 227a903f40cSMarkus Armbruster if (handle < 0) { 228a903f40cSMarkus Armbruster return -1; 22939097dafSMichael Roth } 230c216e5adSMichael Roth 231c216e5adSMichael Roth gfh = g_malloc0(sizeof(GuestFileHandle)); 23239097dafSMichael Roth gfh->id = handle; 233c216e5adSMichael Roth gfh->fh = fh; 234c216e5adSMichael Roth QTAILQ_INSERT_TAIL(&guest_file_state.filehandles, gfh, next); 23539097dafSMichael Roth 23639097dafSMichael Roth return handle; 237c216e5adSMichael Roth } 238c216e5adSMichael Roth 23977dbc81bSMarkus Armbruster static GuestFileHandle *guest_file_handle_find(int64_t id, Error **errp) 240c216e5adSMichael Roth { 241c216e5adSMichael Roth GuestFileHandle *gfh; 242c216e5adSMichael Roth 243c216e5adSMichael Roth QTAILQ_FOREACH(gfh, &guest_file_state.filehandles, next) 244c216e5adSMichael Roth { 245c216e5adSMichael Roth if (gfh->id == id) { 246c216e5adSMichael Roth return gfh; 247c216e5adSMichael Roth } 248c216e5adSMichael Roth } 249c216e5adSMichael Roth 25077dbc81bSMarkus Armbruster error_setg(errp, "handle '%" PRId64 "' has not been found", id); 251c216e5adSMichael Roth return NULL; 252c216e5adSMichael Roth } 253c216e5adSMichael Roth 254c689b4f1SLaszlo Ersek typedef const char * const ccpc; 255c689b4f1SLaszlo Ersek 2568fe6bbcaSLaszlo Ersek #ifndef O_BINARY 2578fe6bbcaSLaszlo Ersek #define O_BINARY 0 2588fe6bbcaSLaszlo Ersek #endif 2598fe6bbcaSLaszlo Ersek 260c689b4f1SLaszlo Ersek /* http://pubs.opengroup.org/onlinepubs/9699919799/functions/fopen.html */ 261c689b4f1SLaszlo Ersek static const struct { 262c689b4f1SLaszlo Ersek ccpc *forms; 263c689b4f1SLaszlo Ersek int oflag_base; 264c689b4f1SLaszlo Ersek } guest_file_open_modes[] = { 2658fe6bbcaSLaszlo Ersek { (ccpc[]){ "r", NULL }, O_RDONLY }, 2668fe6bbcaSLaszlo Ersek { (ccpc[]){ "rb", NULL }, O_RDONLY | O_BINARY }, 2678fe6bbcaSLaszlo Ersek { (ccpc[]){ "w", NULL }, O_WRONLY | O_CREAT | O_TRUNC }, 2688fe6bbcaSLaszlo Ersek { (ccpc[]){ "wb", NULL }, O_WRONLY | O_CREAT | O_TRUNC | O_BINARY }, 2698fe6bbcaSLaszlo Ersek { (ccpc[]){ "a", NULL }, O_WRONLY | O_CREAT | O_APPEND }, 2708fe6bbcaSLaszlo Ersek { (ccpc[]){ "ab", NULL }, O_WRONLY | O_CREAT | O_APPEND | O_BINARY }, 2718fe6bbcaSLaszlo Ersek { (ccpc[]){ "r+", NULL }, O_RDWR }, 2728fe6bbcaSLaszlo Ersek { (ccpc[]){ "rb+", "r+b", NULL }, O_RDWR | O_BINARY }, 2738fe6bbcaSLaszlo Ersek { (ccpc[]){ "w+", NULL }, O_RDWR | O_CREAT | O_TRUNC }, 2748fe6bbcaSLaszlo Ersek { (ccpc[]){ "wb+", "w+b", NULL }, O_RDWR | O_CREAT | O_TRUNC | O_BINARY }, 2758fe6bbcaSLaszlo Ersek { (ccpc[]){ "a+", NULL }, O_RDWR | O_CREAT | O_APPEND }, 2768fe6bbcaSLaszlo Ersek { (ccpc[]){ "ab+", "a+b", NULL }, O_RDWR | O_CREAT | O_APPEND | O_BINARY } 277c689b4f1SLaszlo Ersek }; 278c689b4f1SLaszlo Ersek 279c689b4f1SLaszlo Ersek static int 28077dbc81bSMarkus Armbruster find_open_flag(const char *mode_str, Error **errp) 281c689b4f1SLaszlo Ersek { 282c689b4f1SLaszlo Ersek unsigned mode; 283c689b4f1SLaszlo Ersek 284c689b4f1SLaszlo Ersek for (mode = 0; mode < ARRAY_SIZE(guest_file_open_modes); ++mode) { 285c689b4f1SLaszlo Ersek ccpc *form; 286c689b4f1SLaszlo Ersek 287c689b4f1SLaszlo Ersek form = guest_file_open_modes[mode].forms; 288c689b4f1SLaszlo Ersek while (*form != NULL && strcmp(*form, mode_str) != 0) { 289c689b4f1SLaszlo Ersek ++form; 290c689b4f1SLaszlo Ersek } 291c689b4f1SLaszlo Ersek if (*form != NULL) { 292c689b4f1SLaszlo Ersek break; 293c689b4f1SLaszlo Ersek } 294c689b4f1SLaszlo Ersek } 295c689b4f1SLaszlo Ersek 296c689b4f1SLaszlo Ersek if (mode == ARRAY_SIZE(guest_file_open_modes)) { 29777dbc81bSMarkus Armbruster error_setg(errp, "invalid file open mode '%s'", mode_str); 298c689b4f1SLaszlo Ersek return -1; 299c689b4f1SLaszlo Ersek } 300c689b4f1SLaszlo Ersek return guest_file_open_modes[mode].oflag_base | O_NOCTTY | O_NONBLOCK; 301c689b4f1SLaszlo Ersek } 302c689b4f1SLaszlo Ersek 303c689b4f1SLaszlo Ersek #define DEFAULT_NEW_FILE_MODE (S_IRUSR | S_IWUSR | \ 304c689b4f1SLaszlo Ersek S_IRGRP | S_IWGRP | \ 305c689b4f1SLaszlo Ersek S_IROTH | S_IWOTH) 306c689b4f1SLaszlo Ersek 307c689b4f1SLaszlo Ersek static FILE * 30877dbc81bSMarkus Armbruster safe_open_or_create(const char *path, const char *mode, Error **errp) 309c689b4f1SLaszlo Ersek { 310c689b4f1SLaszlo Ersek Error *local_err = NULL; 311c689b4f1SLaszlo Ersek int oflag; 312c689b4f1SLaszlo Ersek 313c689b4f1SLaszlo Ersek oflag = find_open_flag(mode, &local_err); 314c689b4f1SLaszlo Ersek if (local_err == NULL) { 315c689b4f1SLaszlo Ersek int fd; 316c689b4f1SLaszlo Ersek 317c689b4f1SLaszlo Ersek /* If the caller wants / allows creation of a new file, we implement it 318c689b4f1SLaszlo Ersek * with a two step process: open() + (open() / fchmod()). 319c689b4f1SLaszlo Ersek * 320c689b4f1SLaszlo Ersek * First we insist on creating the file exclusively as a new file. If 321c689b4f1SLaszlo Ersek * that succeeds, we're free to set any file-mode bits on it. (The 322c689b4f1SLaszlo Ersek * motivation is that we want to set those file-mode bits independently 323c689b4f1SLaszlo Ersek * of the current umask.) 324c689b4f1SLaszlo Ersek * 325c689b4f1SLaszlo Ersek * If the exclusive creation fails because the file already exists 326c689b4f1SLaszlo Ersek * (EEXIST is not possible for any other reason), we just attempt to 327c689b4f1SLaszlo Ersek * open the file, but in this case we won't be allowed to change the 328c689b4f1SLaszlo Ersek * file-mode bits on the preexistent file. 329c689b4f1SLaszlo Ersek * 330c689b4f1SLaszlo Ersek * The pathname should never disappear between the two open()s in 331c689b4f1SLaszlo Ersek * practice. If it happens, then someone very likely tried to race us. 332c689b4f1SLaszlo Ersek * In this case just go ahead and report the ENOENT from the second 333c689b4f1SLaszlo Ersek * open() to the caller. 334c689b4f1SLaszlo Ersek * 335c689b4f1SLaszlo Ersek * If the caller wants to open a preexistent file, then the first 336c689b4f1SLaszlo Ersek * open() is decisive and its third argument is ignored, and the second 337c689b4f1SLaszlo Ersek * open() and the fchmod() are never called. 338c689b4f1SLaszlo Ersek */ 339c689b4f1SLaszlo Ersek fd = open(path, oflag | ((oflag & O_CREAT) ? O_EXCL : 0), 0); 340c689b4f1SLaszlo Ersek if (fd == -1 && errno == EEXIST) { 341c689b4f1SLaszlo Ersek oflag &= ~(unsigned)O_CREAT; 342c689b4f1SLaszlo Ersek fd = open(path, oflag); 343c689b4f1SLaszlo Ersek } 344c689b4f1SLaszlo Ersek 345c689b4f1SLaszlo Ersek if (fd == -1) { 346c689b4f1SLaszlo Ersek error_setg_errno(&local_err, errno, "failed to open file '%s' " 347c689b4f1SLaszlo Ersek "(mode: '%s')", path, mode); 348c689b4f1SLaszlo Ersek } else { 349c689b4f1SLaszlo Ersek qemu_set_cloexec(fd); 350c689b4f1SLaszlo Ersek 351c689b4f1SLaszlo Ersek if ((oflag & O_CREAT) && fchmod(fd, DEFAULT_NEW_FILE_MODE) == -1) { 352c689b4f1SLaszlo Ersek error_setg_errno(&local_err, errno, "failed to set permission " 353c689b4f1SLaszlo Ersek "0%03o on new file '%s' (mode: '%s')", 354c689b4f1SLaszlo Ersek (unsigned)DEFAULT_NEW_FILE_MODE, path, mode); 355c689b4f1SLaszlo Ersek } else { 356c689b4f1SLaszlo Ersek FILE *f; 357c689b4f1SLaszlo Ersek 358c689b4f1SLaszlo Ersek f = fdopen(fd, mode); 359c689b4f1SLaszlo Ersek if (f == NULL) { 360c689b4f1SLaszlo Ersek error_setg_errno(&local_err, errno, "failed to associate " 361c689b4f1SLaszlo Ersek "stdio stream with file descriptor %d, " 362c689b4f1SLaszlo Ersek "file '%s' (mode: '%s')", fd, path, mode); 363c689b4f1SLaszlo Ersek } else { 364c689b4f1SLaszlo Ersek return f; 365c689b4f1SLaszlo Ersek } 366c689b4f1SLaszlo Ersek } 367c689b4f1SLaszlo Ersek 368c689b4f1SLaszlo Ersek close(fd); 3692b720018SLaszlo Ersek if (oflag & O_CREAT) { 3702b720018SLaszlo Ersek unlink(path); 3712b720018SLaszlo Ersek } 372c689b4f1SLaszlo Ersek } 373c689b4f1SLaszlo Ersek } 374c689b4f1SLaszlo Ersek 37577dbc81bSMarkus Armbruster error_propagate(errp, local_err); 376c689b4f1SLaszlo Ersek return NULL; 377c689b4f1SLaszlo Ersek } 378c689b4f1SLaszlo Ersek 37985b6f6f5SSimon Zolin static int guest_file_toggle_flags(int fd, int flags, bool set, Error **err) 38085b6f6f5SSimon Zolin { 38185b6f6f5SSimon Zolin int ret, old_flags; 38285b6f6f5SSimon Zolin 38385b6f6f5SSimon Zolin old_flags = fcntl(fd, F_GETFL); 38485b6f6f5SSimon Zolin if (old_flags == -1) { 38585b6f6f5SSimon Zolin error_set_errno(err, errno, QERR_QGA_COMMAND_FAILED, 38685b6f6f5SSimon Zolin "failed to fetch filehandle flags"); 38785b6f6f5SSimon Zolin return -1; 38885b6f6f5SSimon Zolin } 38985b6f6f5SSimon Zolin 39085b6f6f5SSimon Zolin ret = fcntl(fd, F_SETFL, set ? (old_flags | flags) : (old_flags & ~flags)); 39185b6f6f5SSimon Zolin if (ret == -1) { 39285b6f6f5SSimon Zolin error_set_errno(err, errno, QERR_QGA_COMMAND_FAILED, 39385b6f6f5SSimon Zolin "failed to set filehandle flags"); 39485b6f6f5SSimon Zolin return -1; 39585b6f6f5SSimon Zolin } 39685b6f6f5SSimon Zolin 39785b6f6f5SSimon Zolin return ret; 39885b6f6f5SSimon Zolin } 39985b6f6f5SSimon Zolin 40077dbc81bSMarkus Armbruster int64_t qmp_guest_file_open(const char *path, bool has_mode, const char *mode, 40177dbc81bSMarkus Armbruster Error **errp) 402c216e5adSMichael Roth { 403c216e5adSMichael Roth FILE *fh; 404c689b4f1SLaszlo Ersek Error *local_err = NULL; 40585b6f6f5SSimon Zolin int64_t handle; 406c216e5adSMichael Roth 407c216e5adSMichael Roth if (!has_mode) { 408c216e5adSMichael Roth mode = "r"; 409c216e5adSMichael Roth } 410c216e5adSMichael Roth slog("guest-file-open called, filepath: %s, mode: %s", path, mode); 411c689b4f1SLaszlo Ersek fh = safe_open_or_create(path, mode, &local_err); 412c689b4f1SLaszlo Ersek if (local_err != NULL) { 41377dbc81bSMarkus Armbruster error_propagate(errp, local_err); 414c216e5adSMichael Roth return -1; 415c216e5adSMichael Roth } 416c216e5adSMichael Roth 417c216e5adSMichael Roth /* set fd non-blocking to avoid common use cases (like reading from a 418c216e5adSMichael Roth * named pipe) from hanging the agent 419c216e5adSMichael Roth */ 42085b6f6f5SSimon Zolin if (guest_file_toggle_flags(fileno(fh), O_NONBLOCK, true, errp) < 0) { 421c216e5adSMichael Roth fclose(fh); 422c216e5adSMichael Roth return -1; 423c216e5adSMichael Roth } 424c216e5adSMichael Roth 42577dbc81bSMarkus Armbruster handle = guest_file_handle_add(fh, errp); 426a903f40cSMarkus Armbruster if (handle < 0) { 42739097dafSMichael Roth fclose(fh); 42839097dafSMichael Roth return -1; 42939097dafSMichael Roth } 43039097dafSMichael Roth 431d607a523SStefan Weil slog("guest-file-open, handle: %" PRId64, handle); 43239097dafSMichael Roth return handle; 433c216e5adSMichael Roth } 434c216e5adSMichael Roth 43577dbc81bSMarkus Armbruster void qmp_guest_file_close(int64_t handle, Error **errp) 436c216e5adSMichael Roth { 43777dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 438c216e5adSMichael Roth int ret; 439c216e5adSMichael Roth 440d607a523SStefan Weil slog("guest-file-close called, handle: %" PRId64, handle); 441c216e5adSMichael Roth if (!gfh) { 442c216e5adSMichael Roth return; 443c216e5adSMichael Roth } 444c216e5adSMichael Roth 445c216e5adSMichael Roth ret = fclose(gfh->fh); 4463ac4b7c5SLuiz Capitulino if (ret == EOF) { 44777dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to close handle"); 448c216e5adSMichael Roth return; 449c216e5adSMichael Roth } 450c216e5adSMichael Roth 451c216e5adSMichael Roth QTAILQ_REMOVE(&guest_file_state.filehandles, gfh, next); 452c216e5adSMichael Roth g_free(gfh); 453c216e5adSMichael Roth } 454c216e5adSMichael Roth 455c216e5adSMichael Roth struct GuestFileRead *qmp_guest_file_read(int64_t handle, bool has_count, 45677dbc81bSMarkus Armbruster int64_t count, Error **errp) 457c216e5adSMichael Roth { 45877dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 459c216e5adSMichael Roth GuestFileRead *read_data = NULL; 460c216e5adSMichael Roth guchar *buf; 461c216e5adSMichael Roth FILE *fh; 462c216e5adSMichael Roth size_t read_count; 463c216e5adSMichael Roth 464c216e5adSMichael Roth if (!gfh) { 465c216e5adSMichael Roth return NULL; 466c216e5adSMichael Roth } 467c216e5adSMichael Roth 468c216e5adSMichael Roth if (!has_count) { 469c216e5adSMichael Roth count = QGA_READ_COUNT_DEFAULT; 470c216e5adSMichael Roth } else if (count < 0) { 47177dbc81bSMarkus Armbruster error_setg(errp, "value '%" PRId64 "' is invalid for argument count", 472db3edb66SLuiz Capitulino count); 473c216e5adSMichael Roth return NULL; 474c216e5adSMichael Roth } 475c216e5adSMichael Roth 476c216e5adSMichael Roth fh = gfh->fh; 477c216e5adSMichael Roth buf = g_malloc0(count+1); 478c216e5adSMichael Roth read_count = fread(buf, 1, count, fh); 479c216e5adSMichael Roth if (ferror(fh)) { 48077dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to read file"); 481d607a523SStefan Weil slog("guest-file-read failed, handle: %" PRId64, handle); 482c216e5adSMichael Roth } else { 483c216e5adSMichael Roth buf[read_count] = 0; 484c216e5adSMichael Roth read_data = g_malloc0(sizeof(GuestFileRead)); 485c216e5adSMichael Roth read_data->count = read_count; 486c216e5adSMichael Roth read_data->eof = feof(fh); 487c216e5adSMichael Roth if (read_count) { 488c216e5adSMichael Roth read_data->buf_b64 = g_base64_encode(buf, read_count); 489c216e5adSMichael Roth } 490c216e5adSMichael Roth } 491c216e5adSMichael Roth g_free(buf); 492c216e5adSMichael Roth clearerr(fh); 493c216e5adSMichael Roth 494c216e5adSMichael Roth return read_data; 495c216e5adSMichael Roth } 496c216e5adSMichael Roth 497c216e5adSMichael Roth GuestFileWrite *qmp_guest_file_write(int64_t handle, const char *buf_b64, 49877dbc81bSMarkus Armbruster bool has_count, int64_t count, 49977dbc81bSMarkus Armbruster Error **errp) 500c216e5adSMichael Roth { 501c216e5adSMichael Roth GuestFileWrite *write_data = NULL; 502c216e5adSMichael Roth guchar *buf; 503c216e5adSMichael Roth gsize buf_len; 504c216e5adSMichael Roth int write_count; 50577dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 506c216e5adSMichael Roth FILE *fh; 507c216e5adSMichael Roth 508c216e5adSMichael Roth if (!gfh) { 509c216e5adSMichael Roth return NULL; 510c216e5adSMichael Roth } 511c216e5adSMichael Roth 512c216e5adSMichael Roth fh = gfh->fh; 513c216e5adSMichael Roth buf = g_base64_decode(buf_b64, &buf_len); 514c216e5adSMichael Roth 515c216e5adSMichael Roth if (!has_count) { 516c216e5adSMichael Roth count = buf_len; 517c216e5adSMichael Roth } else if (count < 0 || count > buf_len) { 51877dbc81bSMarkus Armbruster error_setg(errp, "value '%" PRId64 "' is invalid for argument count", 519db3edb66SLuiz Capitulino count); 520c216e5adSMichael Roth g_free(buf); 521c216e5adSMichael Roth return NULL; 522c216e5adSMichael Roth } 523c216e5adSMichael Roth 524c216e5adSMichael Roth write_count = fwrite(buf, 1, count, fh); 525c216e5adSMichael Roth if (ferror(fh)) { 52677dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to write to file"); 527d607a523SStefan Weil slog("guest-file-write failed, handle: %" PRId64, handle); 528c216e5adSMichael Roth } else { 529c216e5adSMichael Roth write_data = g_malloc0(sizeof(GuestFileWrite)); 530c216e5adSMichael Roth write_data->count = write_count; 531c216e5adSMichael Roth write_data->eof = feof(fh); 532c216e5adSMichael Roth } 533c216e5adSMichael Roth g_free(buf); 534c216e5adSMichael Roth clearerr(fh); 535c216e5adSMichael Roth 536c216e5adSMichael Roth return write_data; 537c216e5adSMichael Roth } 538c216e5adSMichael Roth 539c216e5adSMichael Roth struct GuestFileSeek *qmp_guest_file_seek(int64_t handle, int64_t offset, 54077dbc81bSMarkus Armbruster int64_t whence, Error **errp) 541c216e5adSMichael Roth { 54277dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 543c216e5adSMichael Roth GuestFileSeek *seek_data = NULL; 544c216e5adSMichael Roth FILE *fh; 545c216e5adSMichael Roth int ret; 546c216e5adSMichael Roth 547c216e5adSMichael Roth if (!gfh) { 548c216e5adSMichael Roth return NULL; 549c216e5adSMichael Roth } 550c216e5adSMichael Roth 551c216e5adSMichael Roth fh = gfh->fh; 552c216e5adSMichael Roth ret = fseek(fh, offset, whence); 553c216e5adSMichael Roth if (ret == -1) { 55477dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to seek file"); 555c216e5adSMichael Roth } else { 55610b7c5ddSMarkus Armbruster seek_data = g_new0(GuestFileSeek, 1); 557c216e5adSMichael Roth seek_data->position = ftell(fh); 558c216e5adSMichael Roth seek_data->eof = feof(fh); 559c216e5adSMichael Roth } 560c216e5adSMichael Roth clearerr(fh); 561c216e5adSMichael Roth 562c216e5adSMichael Roth return seek_data; 563c216e5adSMichael Roth } 564c216e5adSMichael Roth 56577dbc81bSMarkus Armbruster void qmp_guest_file_flush(int64_t handle, Error **errp) 566c216e5adSMichael Roth { 56777dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 568c216e5adSMichael Roth FILE *fh; 569c216e5adSMichael Roth int ret; 570c216e5adSMichael Roth 571c216e5adSMichael Roth if (!gfh) { 572c216e5adSMichael Roth return; 573c216e5adSMichael Roth } 574c216e5adSMichael Roth 575c216e5adSMichael Roth fh = gfh->fh; 576c216e5adSMichael Roth ret = fflush(fh); 577c216e5adSMichael Roth if (ret == EOF) { 57877dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to flush file"); 579c216e5adSMichael Roth } 580c216e5adSMichael Roth } 581c216e5adSMichael Roth 582c216e5adSMichael Roth static void guest_file_init(void) 583c216e5adSMichael Roth { 584c216e5adSMichael Roth QTAILQ_INIT(&guest_file_state.filehandles); 585c216e5adSMichael Roth } 586c216e5adSMichael Roth 587e72c3f2eSMichael Roth /* linux-specific implementations. avoid this if at all possible. */ 588e72c3f2eSMichael Roth #if defined(__linux__) 589e72c3f2eSMichael Roth 590eab5fd59SPaolo Bonzini #if defined(CONFIG_FSFREEZE) || defined(CONFIG_FSTRIM) 591af02203fSPaolo Bonzini typedef struct FsMount { 592c216e5adSMichael Roth char *dirname; 593c216e5adSMichael Roth char *devtype; 59446d4c572STomoki Sekiyama unsigned int devmajor, devminor; 595af02203fSPaolo Bonzini QTAILQ_ENTRY(FsMount) next; 596af02203fSPaolo Bonzini } FsMount; 597c216e5adSMichael Roth 598e5d9adbdSTomoki Sekiyama typedef QTAILQ_HEAD(FsMountList, FsMount) FsMountList; 5999e8aded4SMichael Roth 600af02203fSPaolo Bonzini static void free_fs_mount_list(FsMountList *mounts) 601c216e5adSMichael Roth { 602af02203fSPaolo Bonzini FsMount *mount, *temp; 603c216e5adSMichael Roth 6049e8aded4SMichael Roth if (!mounts) { 6059e8aded4SMichael Roth return; 6069e8aded4SMichael Roth } 6079e8aded4SMichael Roth 6089e8aded4SMichael Roth QTAILQ_FOREACH_SAFE(mount, mounts, next, temp) { 6099e8aded4SMichael Roth QTAILQ_REMOVE(mounts, mount, next); 610c216e5adSMichael Roth g_free(mount->dirname); 611c216e5adSMichael Roth g_free(mount->devtype); 612c216e5adSMichael Roth g_free(mount); 613c216e5adSMichael Roth } 6149e8aded4SMichael Roth } 6159e8aded4SMichael Roth 61646d4c572STomoki Sekiyama static int dev_major_minor(const char *devpath, 61746d4c572STomoki Sekiyama unsigned int *devmajor, unsigned int *devminor) 61846d4c572STomoki Sekiyama { 61946d4c572STomoki Sekiyama struct stat st; 62046d4c572STomoki Sekiyama 62146d4c572STomoki Sekiyama *devmajor = 0; 62246d4c572STomoki Sekiyama *devminor = 0; 62346d4c572STomoki Sekiyama 62446d4c572STomoki Sekiyama if (stat(devpath, &st) < 0) { 62546d4c572STomoki Sekiyama slog("failed to stat device file '%s': %s", devpath, strerror(errno)); 62646d4c572STomoki Sekiyama return -1; 62746d4c572STomoki Sekiyama } 62846d4c572STomoki Sekiyama if (S_ISDIR(st.st_mode)) { 62946d4c572STomoki Sekiyama /* It is bind mount */ 63046d4c572STomoki Sekiyama return -2; 63146d4c572STomoki Sekiyama } 63246d4c572STomoki Sekiyama if (S_ISBLK(st.st_mode)) { 63346d4c572STomoki Sekiyama *devmajor = major(st.st_rdev); 63446d4c572STomoki Sekiyama *devminor = minor(st.st_rdev); 63546d4c572STomoki Sekiyama return 0; 63646d4c572STomoki Sekiyama } 63746d4c572STomoki Sekiyama return -1; 63846d4c572STomoki Sekiyama } 63946d4c572STomoki Sekiyama 6409e8aded4SMichael Roth /* 6419e8aded4SMichael Roth * Walk the mount table and build a list of local file systems 6429e8aded4SMichael Roth */ 64346d4c572STomoki Sekiyama static void build_fs_mount_list_from_mtab(FsMountList *mounts, Error **errp) 6449e8aded4SMichael Roth { 6459e8aded4SMichael Roth struct mntent *ment; 646af02203fSPaolo Bonzini FsMount *mount; 6479e2fa418SMichael Roth char const *mtab = "/proc/self/mounts"; 6489e8aded4SMichael Roth FILE *fp; 64946d4c572STomoki Sekiyama unsigned int devmajor, devminor; 650c216e5adSMichael Roth 651c216e5adSMichael Roth fp = setmntent(mtab, "r"); 652c216e5adSMichael Roth if (!fp) { 65377dbc81bSMarkus Armbruster error_setg(errp, "failed to open mtab file: '%s'", mtab); 654261551d1SLuiz Capitulino return; 655c216e5adSMichael Roth } 656c216e5adSMichael Roth 657c216e5adSMichael Roth while ((ment = getmntent(fp))) { 658c216e5adSMichael Roth /* 659c216e5adSMichael Roth * An entry which device name doesn't start with a '/' is 660c216e5adSMichael Roth * either a dummy file system or a network file system. 661c216e5adSMichael Roth * Add special handling for smbfs and cifs as is done by 662c216e5adSMichael Roth * coreutils as well. 663c216e5adSMichael Roth */ 664c216e5adSMichael Roth if ((ment->mnt_fsname[0] != '/') || 665c216e5adSMichael Roth (strcmp(ment->mnt_type, "smbfs") == 0) || 666c216e5adSMichael Roth (strcmp(ment->mnt_type, "cifs") == 0)) { 667c216e5adSMichael Roth continue; 668c216e5adSMichael Roth } 66946d4c572STomoki Sekiyama if (dev_major_minor(ment->mnt_fsname, &devmajor, &devminor) == -2) { 67046d4c572STomoki Sekiyama /* Skip bind mounts */ 67146d4c572STomoki Sekiyama continue; 67246d4c572STomoki Sekiyama } 673c216e5adSMichael Roth 674af02203fSPaolo Bonzini mount = g_malloc0(sizeof(FsMount)); 675c216e5adSMichael Roth mount->dirname = g_strdup(ment->mnt_dir); 676c216e5adSMichael Roth mount->devtype = g_strdup(ment->mnt_type); 67746d4c572STomoki Sekiyama mount->devmajor = devmajor; 67846d4c572STomoki Sekiyama mount->devminor = devminor; 679c216e5adSMichael Roth 6809e8aded4SMichael Roth QTAILQ_INSERT_TAIL(mounts, mount, next); 681c216e5adSMichael Roth } 682c216e5adSMichael Roth 683c216e5adSMichael Roth endmntent(fp); 684c216e5adSMichael Roth } 68546d4c572STomoki Sekiyama 68646d4c572STomoki Sekiyama static void decode_mntname(char *name, int len) 68746d4c572STomoki Sekiyama { 68846d4c572STomoki Sekiyama int i, j = 0; 68946d4c572STomoki Sekiyama for (i = 0; i <= len; i++) { 69046d4c572STomoki Sekiyama if (name[i] != '\\') { 69146d4c572STomoki Sekiyama name[j++] = name[i]; 69246d4c572STomoki Sekiyama } else if (name[i + 1] == '\\') { 69346d4c572STomoki Sekiyama name[j++] = '\\'; 69446d4c572STomoki Sekiyama i++; 69546d4c572STomoki Sekiyama } else if (name[i + 1] >= '0' && name[i + 1] <= '3' && 69646d4c572STomoki Sekiyama name[i + 2] >= '0' && name[i + 2] <= '7' && 69746d4c572STomoki Sekiyama name[i + 3] >= '0' && name[i + 3] <= '7') { 69846d4c572STomoki Sekiyama name[j++] = (name[i + 1] - '0') * 64 + 69946d4c572STomoki Sekiyama (name[i + 2] - '0') * 8 + 70046d4c572STomoki Sekiyama (name[i + 3] - '0'); 70146d4c572STomoki Sekiyama i += 3; 70246d4c572STomoki Sekiyama } else { 70346d4c572STomoki Sekiyama name[j++] = name[i]; 70446d4c572STomoki Sekiyama } 70546d4c572STomoki Sekiyama } 70646d4c572STomoki Sekiyama } 70746d4c572STomoki Sekiyama 70846d4c572STomoki Sekiyama static void build_fs_mount_list(FsMountList *mounts, Error **errp) 70946d4c572STomoki Sekiyama { 71046d4c572STomoki Sekiyama FsMount *mount; 71146d4c572STomoki Sekiyama char const *mountinfo = "/proc/self/mountinfo"; 71246d4c572STomoki Sekiyama FILE *fp; 71346d4c572STomoki Sekiyama char *line = NULL, *dash; 71446d4c572STomoki Sekiyama size_t n; 71546d4c572STomoki Sekiyama char check; 71646d4c572STomoki Sekiyama unsigned int devmajor, devminor; 71746d4c572STomoki Sekiyama int ret, dir_s, dir_e, type_s, type_e, dev_s, dev_e; 71846d4c572STomoki Sekiyama 71946d4c572STomoki Sekiyama fp = fopen(mountinfo, "r"); 72046d4c572STomoki Sekiyama if (!fp) { 72146d4c572STomoki Sekiyama build_fs_mount_list_from_mtab(mounts, errp); 72246d4c572STomoki Sekiyama return; 72346d4c572STomoki Sekiyama } 72446d4c572STomoki Sekiyama 72546d4c572STomoki Sekiyama while (getline(&line, &n, fp) != -1) { 72646d4c572STomoki Sekiyama ret = sscanf(line, "%*u %*u %u:%u %*s %n%*s%n%c", 72746d4c572STomoki Sekiyama &devmajor, &devminor, &dir_s, &dir_e, &check); 72846d4c572STomoki Sekiyama if (ret < 3) { 72946d4c572STomoki Sekiyama continue; 73046d4c572STomoki Sekiyama } 73146d4c572STomoki Sekiyama dash = strstr(line + dir_e, " - "); 73246d4c572STomoki Sekiyama if (!dash) { 73346d4c572STomoki Sekiyama continue; 73446d4c572STomoki Sekiyama } 73546d4c572STomoki Sekiyama ret = sscanf(dash, " - %n%*s%n %n%*s%n%c", 73646d4c572STomoki Sekiyama &type_s, &type_e, &dev_s, &dev_e, &check); 73746d4c572STomoki Sekiyama if (ret < 1) { 73846d4c572STomoki Sekiyama continue; 73946d4c572STomoki Sekiyama } 74046d4c572STomoki Sekiyama line[dir_e] = 0; 74146d4c572STomoki Sekiyama dash[type_e] = 0; 74246d4c572STomoki Sekiyama dash[dev_e] = 0; 74346d4c572STomoki Sekiyama decode_mntname(line + dir_s, dir_e - dir_s); 74446d4c572STomoki Sekiyama decode_mntname(dash + dev_s, dev_e - dev_s); 74546d4c572STomoki Sekiyama if (devmajor == 0) { 74646d4c572STomoki Sekiyama /* btrfs reports major number = 0 */ 74746d4c572STomoki Sekiyama if (strcmp("btrfs", dash + type_s) != 0 || 74846d4c572STomoki Sekiyama dev_major_minor(dash + dev_s, &devmajor, &devminor) < 0) { 74946d4c572STomoki Sekiyama continue; 75046d4c572STomoki Sekiyama } 75146d4c572STomoki Sekiyama } 75246d4c572STomoki Sekiyama 75346d4c572STomoki Sekiyama mount = g_malloc0(sizeof(FsMount)); 75446d4c572STomoki Sekiyama mount->dirname = g_strdup(line + dir_s); 75546d4c572STomoki Sekiyama mount->devtype = g_strdup(dash + type_s); 75646d4c572STomoki Sekiyama mount->devmajor = devmajor; 75746d4c572STomoki Sekiyama mount->devminor = devminor; 75846d4c572STomoki Sekiyama 75946d4c572STomoki Sekiyama QTAILQ_INSERT_TAIL(mounts, mount, next); 76046d4c572STomoki Sekiyama } 76146d4c572STomoki Sekiyama free(line); 76246d4c572STomoki Sekiyama 76346d4c572STomoki Sekiyama fclose(fp); 76446d4c572STomoki Sekiyama } 765eab5fd59SPaolo Bonzini #endif 766eab5fd59SPaolo Bonzini 767eab5fd59SPaolo Bonzini #if defined(CONFIG_FSFREEZE) 768c216e5adSMichael Roth 76946d4c572STomoki Sekiyama static char *get_pci_driver(char const *syspath, int pathlen, Error **errp) 77046d4c572STomoki Sekiyama { 77146d4c572STomoki Sekiyama char *path; 77246d4c572STomoki Sekiyama char *dpath; 77346d4c572STomoki Sekiyama char *driver = NULL; 77446d4c572STomoki Sekiyama char buf[PATH_MAX]; 77546d4c572STomoki Sekiyama ssize_t len; 77646d4c572STomoki Sekiyama 77746d4c572STomoki Sekiyama path = g_strndup(syspath, pathlen); 77846d4c572STomoki Sekiyama dpath = g_strdup_printf("%s/driver", path); 77946d4c572STomoki Sekiyama len = readlink(dpath, buf, sizeof(buf) - 1); 78046d4c572STomoki Sekiyama if (len != -1) { 78146d4c572STomoki Sekiyama buf[len] = 0; 78246d4c572STomoki Sekiyama driver = g_strdup(basename(buf)); 78346d4c572STomoki Sekiyama } 78446d4c572STomoki Sekiyama g_free(dpath); 78546d4c572STomoki Sekiyama g_free(path); 78646d4c572STomoki Sekiyama return driver; 78746d4c572STomoki Sekiyama } 78846d4c572STomoki Sekiyama 78946d4c572STomoki Sekiyama static int compare_uint(const void *_a, const void *_b) 79046d4c572STomoki Sekiyama { 79146d4c572STomoki Sekiyama unsigned int a = *(unsigned int *)_a; 79246d4c572STomoki Sekiyama unsigned int b = *(unsigned int *)_b; 79346d4c572STomoki Sekiyama 79446d4c572STomoki Sekiyama return a < b ? -1 : a > b ? 1 : 0; 79546d4c572STomoki Sekiyama } 79646d4c572STomoki Sekiyama 79746d4c572STomoki Sekiyama /* Walk the specified sysfs and build a sorted list of host or ata numbers */ 79846d4c572STomoki Sekiyama static int build_hosts(char const *syspath, char const *host, bool ata, 79946d4c572STomoki Sekiyama unsigned int *hosts, int hosts_max, Error **errp) 80046d4c572STomoki Sekiyama { 80146d4c572STomoki Sekiyama char *path; 80246d4c572STomoki Sekiyama DIR *dir; 80346d4c572STomoki Sekiyama struct dirent *entry; 80446d4c572STomoki Sekiyama int i = 0; 80546d4c572STomoki Sekiyama 80646d4c572STomoki Sekiyama path = g_strndup(syspath, host - syspath); 80746d4c572STomoki Sekiyama dir = opendir(path); 80846d4c572STomoki Sekiyama if (!dir) { 80946d4c572STomoki Sekiyama error_setg_errno(errp, errno, "opendir(\"%s\")", path); 81046d4c572STomoki Sekiyama g_free(path); 81146d4c572STomoki Sekiyama return -1; 81246d4c572STomoki Sekiyama } 81346d4c572STomoki Sekiyama 81446d4c572STomoki Sekiyama while (i < hosts_max) { 81546d4c572STomoki Sekiyama entry = readdir(dir); 81646d4c572STomoki Sekiyama if (!entry) { 81746d4c572STomoki Sekiyama break; 81846d4c572STomoki Sekiyama } 81946d4c572STomoki Sekiyama if (ata && sscanf(entry->d_name, "ata%d", hosts + i) == 1) { 82046d4c572STomoki Sekiyama ++i; 82146d4c572STomoki Sekiyama } else if (!ata && sscanf(entry->d_name, "host%d", hosts + i) == 1) { 82246d4c572STomoki Sekiyama ++i; 82346d4c572STomoki Sekiyama } 82446d4c572STomoki Sekiyama } 82546d4c572STomoki Sekiyama 82646d4c572STomoki Sekiyama qsort(hosts, i, sizeof(hosts[0]), compare_uint); 82746d4c572STomoki Sekiyama 82846d4c572STomoki Sekiyama g_free(path); 82946d4c572STomoki Sekiyama closedir(dir); 83046d4c572STomoki Sekiyama return i; 83146d4c572STomoki Sekiyama } 83246d4c572STomoki Sekiyama 83346d4c572STomoki Sekiyama /* Store disk device info specified by @sysfs into @fs */ 83446d4c572STomoki Sekiyama static void build_guest_fsinfo_for_real_device(char const *syspath, 83546d4c572STomoki Sekiyama GuestFilesystemInfo *fs, 83646d4c572STomoki Sekiyama Error **errp) 83746d4c572STomoki Sekiyama { 83846d4c572STomoki Sekiyama unsigned int pci[4], host, hosts[8], tgt[3]; 83946d4c572STomoki Sekiyama int i, nhosts = 0, pcilen; 84046d4c572STomoki Sekiyama GuestDiskAddress *disk; 84146d4c572STomoki Sekiyama GuestPCIAddress *pciaddr; 84246d4c572STomoki Sekiyama GuestDiskAddressList *list = NULL; 84346d4c572STomoki Sekiyama bool has_ata = false, has_host = false, has_tgt = false; 84446d4c572STomoki Sekiyama char *p, *q, *driver = NULL; 84546d4c572STomoki Sekiyama 84646d4c572STomoki Sekiyama p = strstr(syspath, "/devices/pci"); 84746d4c572STomoki Sekiyama if (!p || sscanf(p + 12, "%*x:%*x/%x:%x:%x.%x%n", 84846d4c572STomoki Sekiyama pci, pci + 1, pci + 2, pci + 3, &pcilen) < 4) { 84946d4c572STomoki Sekiyama g_debug("only pci device is supported: sysfs path \"%s\"", syspath); 85046d4c572STomoki Sekiyama return; 85146d4c572STomoki Sekiyama } 85246d4c572STomoki Sekiyama 85346d4c572STomoki Sekiyama driver = get_pci_driver(syspath, (p + 12 + pcilen) - syspath, errp); 85446d4c572STomoki Sekiyama if (!driver) { 85546d4c572STomoki Sekiyama goto cleanup; 85646d4c572STomoki Sekiyama } 85746d4c572STomoki Sekiyama 85846d4c572STomoki Sekiyama p = strstr(syspath, "/target"); 85946d4c572STomoki Sekiyama if (p && sscanf(p + 7, "%*u:%*u:%*u/%*u:%u:%u:%u", 86046d4c572STomoki Sekiyama tgt, tgt + 1, tgt + 2) == 3) { 86146d4c572STomoki Sekiyama has_tgt = true; 86246d4c572STomoki Sekiyama } 86346d4c572STomoki Sekiyama 86446d4c572STomoki Sekiyama p = strstr(syspath, "/ata"); 86546d4c572STomoki Sekiyama if (p) { 86646d4c572STomoki Sekiyama q = p + 4; 86746d4c572STomoki Sekiyama has_ata = true; 86846d4c572STomoki Sekiyama } else { 86946d4c572STomoki Sekiyama p = strstr(syspath, "/host"); 87046d4c572STomoki Sekiyama q = p + 5; 87146d4c572STomoki Sekiyama } 87246d4c572STomoki Sekiyama if (p && sscanf(q, "%u", &host) == 1) { 87346d4c572STomoki Sekiyama has_host = true; 87446d4c572STomoki Sekiyama nhosts = build_hosts(syspath, p, has_ata, hosts, 87546d4c572STomoki Sekiyama sizeof(hosts) / sizeof(hosts[0]), errp); 87646d4c572STomoki Sekiyama if (nhosts < 0) { 87746d4c572STomoki Sekiyama goto cleanup; 87846d4c572STomoki Sekiyama } 87946d4c572STomoki Sekiyama } 88046d4c572STomoki Sekiyama 88146d4c572STomoki Sekiyama pciaddr = g_malloc0(sizeof(*pciaddr)); 88246d4c572STomoki Sekiyama pciaddr->domain = pci[0]; 88346d4c572STomoki Sekiyama pciaddr->bus = pci[1]; 88446d4c572STomoki Sekiyama pciaddr->slot = pci[2]; 88546d4c572STomoki Sekiyama pciaddr->function = pci[3]; 88646d4c572STomoki Sekiyama 88746d4c572STomoki Sekiyama disk = g_malloc0(sizeof(*disk)); 88846d4c572STomoki Sekiyama disk->pci_controller = pciaddr; 88946d4c572STomoki Sekiyama 89046d4c572STomoki Sekiyama list = g_malloc0(sizeof(*list)); 89146d4c572STomoki Sekiyama list->value = disk; 89246d4c572STomoki Sekiyama 89346d4c572STomoki Sekiyama if (strcmp(driver, "ata_piix") == 0) { 89446d4c572STomoki Sekiyama /* a host per ide bus, target*:0:<unit>:0 */ 89546d4c572STomoki Sekiyama if (!has_host || !has_tgt) { 89646d4c572STomoki Sekiyama g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver); 89746d4c572STomoki Sekiyama goto cleanup; 89846d4c572STomoki Sekiyama } 89946d4c572STomoki Sekiyama for (i = 0; i < nhosts; i++) { 90046d4c572STomoki Sekiyama if (host == hosts[i]) { 90146d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_IDE; 90246d4c572STomoki Sekiyama disk->bus = i; 90346d4c572STomoki Sekiyama disk->unit = tgt[1]; 90446d4c572STomoki Sekiyama break; 90546d4c572STomoki Sekiyama } 90646d4c572STomoki Sekiyama } 90746d4c572STomoki Sekiyama if (i >= nhosts) { 90846d4c572STomoki Sekiyama g_debug("no host for '%s' (driver '%s')", syspath, driver); 90946d4c572STomoki Sekiyama goto cleanup; 91046d4c572STomoki Sekiyama } 91146d4c572STomoki Sekiyama } else if (strcmp(driver, "sym53c8xx") == 0) { 91246d4c572STomoki Sekiyama /* scsi(LSI Logic): target*:0:<unit>:0 */ 91346d4c572STomoki Sekiyama if (!has_tgt) { 91446d4c572STomoki Sekiyama g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver); 91546d4c572STomoki Sekiyama goto cleanup; 91646d4c572STomoki Sekiyama } 91746d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI; 91846d4c572STomoki Sekiyama disk->unit = tgt[1]; 91946d4c572STomoki Sekiyama } else if (strcmp(driver, "virtio-pci") == 0) { 92046d4c572STomoki Sekiyama if (has_tgt) { 92146d4c572STomoki Sekiyama /* virtio-scsi: target*:0:0:<unit> */ 92246d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI; 92346d4c572STomoki Sekiyama disk->unit = tgt[2]; 92446d4c572STomoki Sekiyama } else { 92546d4c572STomoki Sekiyama /* virtio-blk: 1 disk per 1 device */ 92646d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_VIRTIO; 92746d4c572STomoki Sekiyama } 92846d4c572STomoki Sekiyama } else if (strcmp(driver, "ahci") == 0) { 92946d4c572STomoki Sekiyama /* ahci: 1 host per 1 unit */ 93046d4c572STomoki Sekiyama if (!has_host || !has_tgt) { 93146d4c572STomoki Sekiyama g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver); 93246d4c572STomoki Sekiyama goto cleanup; 93346d4c572STomoki Sekiyama } 93446d4c572STomoki Sekiyama for (i = 0; i < nhosts; i++) { 93546d4c572STomoki Sekiyama if (host == hosts[i]) { 93646d4c572STomoki Sekiyama disk->unit = i; 93746d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_SATA; 93846d4c572STomoki Sekiyama break; 93946d4c572STomoki Sekiyama } 94046d4c572STomoki Sekiyama } 94146d4c572STomoki Sekiyama if (i >= nhosts) { 94246d4c572STomoki Sekiyama g_debug("no host for '%s' (driver '%s')", syspath, driver); 94346d4c572STomoki Sekiyama goto cleanup; 94446d4c572STomoki Sekiyama } 94546d4c572STomoki Sekiyama } else { 94646d4c572STomoki Sekiyama g_debug("unknown driver '%s' (sysfs path '%s')", driver, syspath); 94746d4c572STomoki Sekiyama goto cleanup; 94846d4c572STomoki Sekiyama } 94946d4c572STomoki Sekiyama 95046d4c572STomoki Sekiyama list->next = fs->disk; 95146d4c572STomoki Sekiyama fs->disk = list; 95246d4c572STomoki Sekiyama g_free(driver); 95346d4c572STomoki Sekiyama return; 95446d4c572STomoki Sekiyama 95546d4c572STomoki Sekiyama cleanup: 95646d4c572STomoki Sekiyama if (list) { 95746d4c572STomoki Sekiyama qapi_free_GuestDiskAddressList(list); 95846d4c572STomoki Sekiyama } 95946d4c572STomoki Sekiyama g_free(driver); 96046d4c572STomoki Sekiyama } 96146d4c572STomoki Sekiyama 96246d4c572STomoki Sekiyama static void build_guest_fsinfo_for_device(char const *devpath, 96346d4c572STomoki Sekiyama GuestFilesystemInfo *fs, 96446d4c572STomoki Sekiyama Error **errp); 96546d4c572STomoki Sekiyama 96646d4c572STomoki Sekiyama /* Store a list of slave devices of virtual volume specified by @syspath into 96746d4c572STomoki Sekiyama * @fs */ 96846d4c572STomoki Sekiyama static void build_guest_fsinfo_for_virtual_device(char const *syspath, 96946d4c572STomoki Sekiyama GuestFilesystemInfo *fs, 97046d4c572STomoki Sekiyama Error **errp) 97146d4c572STomoki Sekiyama { 97246d4c572STomoki Sekiyama DIR *dir; 97346d4c572STomoki Sekiyama char *dirpath; 974e668d1b8Szhanghailiang struct dirent *entry; 97546d4c572STomoki Sekiyama 97646d4c572STomoki Sekiyama dirpath = g_strdup_printf("%s/slaves", syspath); 97746d4c572STomoki Sekiyama dir = opendir(dirpath); 97846d4c572STomoki Sekiyama if (!dir) { 97946d4c572STomoki Sekiyama error_setg_errno(errp, errno, "opendir(\"%s\")", dirpath); 98046d4c572STomoki Sekiyama g_free(dirpath); 98146d4c572STomoki Sekiyama return; 98246d4c572STomoki Sekiyama } 98346d4c572STomoki Sekiyama 98446d4c572STomoki Sekiyama for (;;) { 985e668d1b8Szhanghailiang errno = 0; 986e668d1b8Szhanghailiang entry = readdir(dir); 987e668d1b8Szhanghailiang if (entry == NULL) { 988e668d1b8Szhanghailiang if (errno) { 989e668d1b8Szhanghailiang error_setg_errno(errp, errno, "readdir(\"%s\")", dirpath); 99046d4c572STomoki Sekiyama } 99146d4c572STomoki Sekiyama break; 99246d4c572STomoki Sekiyama } 99346d4c572STomoki Sekiyama 994e668d1b8Szhanghailiang if (entry->d_type == DT_LNK) { 995e668d1b8Szhanghailiang char *path; 996e668d1b8Szhanghailiang 997e668d1b8Szhanghailiang g_debug(" slave device '%s'", entry->d_name); 998e668d1b8Szhanghailiang path = g_strdup_printf("%s/slaves/%s", syspath, entry->d_name); 999e668d1b8Szhanghailiang build_guest_fsinfo_for_device(path, fs, errp); 1000e668d1b8Szhanghailiang g_free(path); 100146d4c572STomoki Sekiyama 100246d4c572STomoki Sekiyama if (*errp) { 100346d4c572STomoki Sekiyama break; 100446d4c572STomoki Sekiyama } 100546d4c572STomoki Sekiyama } 100646d4c572STomoki Sekiyama } 100746d4c572STomoki Sekiyama 1008e668d1b8Szhanghailiang g_free(dirpath); 100946d4c572STomoki Sekiyama closedir(dir); 101046d4c572STomoki Sekiyama } 101146d4c572STomoki Sekiyama 101246d4c572STomoki Sekiyama /* Dispatch to functions for virtual/real device */ 101346d4c572STomoki Sekiyama static void build_guest_fsinfo_for_device(char const *devpath, 101446d4c572STomoki Sekiyama GuestFilesystemInfo *fs, 101546d4c572STomoki Sekiyama Error **errp) 101646d4c572STomoki Sekiyama { 101746d4c572STomoki Sekiyama char *syspath = realpath(devpath, NULL); 101846d4c572STomoki Sekiyama 101946d4c572STomoki Sekiyama if (!syspath) { 102046d4c572STomoki Sekiyama error_setg_errno(errp, errno, "realpath(\"%s\")", devpath); 102146d4c572STomoki Sekiyama return; 102246d4c572STomoki Sekiyama } 102346d4c572STomoki Sekiyama 102446d4c572STomoki Sekiyama if (!fs->name) { 102546d4c572STomoki Sekiyama fs->name = g_strdup(basename(syspath)); 102646d4c572STomoki Sekiyama } 102746d4c572STomoki Sekiyama 102846d4c572STomoki Sekiyama g_debug(" parse sysfs path '%s'", syspath); 102946d4c572STomoki Sekiyama 103046d4c572STomoki Sekiyama if (strstr(syspath, "/devices/virtual/block/")) { 103146d4c572STomoki Sekiyama build_guest_fsinfo_for_virtual_device(syspath, fs, errp); 103246d4c572STomoki Sekiyama } else { 103346d4c572STomoki Sekiyama build_guest_fsinfo_for_real_device(syspath, fs, errp); 103446d4c572STomoki Sekiyama } 103546d4c572STomoki Sekiyama 103646d4c572STomoki Sekiyama free(syspath); 103746d4c572STomoki Sekiyama } 103846d4c572STomoki Sekiyama 103946d4c572STomoki Sekiyama /* Return a list of the disk device(s)' info which @mount lies on */ 104046d4c572STomoki Sekiyama static GuestFilesystemInfo *build_guest_fsinfo(struct FsMount *mount, 104146d4c572STomoki Sekiyama Error **errp) 104246d4c572STomoki Sekiyama { 104346d4c572STomoki Sekiyama GuestFilesystemInfo *fs = g_malloc0(sizeof(*fs)); 104446d4c572STomoki Sekiyama char *devpath = g_strdup_printf("/sys/dev/block/%u:%u", 104546d4c572STomoki Sekiyama mount->devmajor, mount->devminor); 104646d4c572STomoki Sekiyama 104746d4c572STomoki Sekiyama fs->mountpoint = g_strdup(mount->dirname); 104846d4c572STomoki Sekiyama fs->type = g_strdup(mount->devtype); 104946d4c572STomoki Sekiyama build_guest_fsinfo_for_device(devpath, fs, errp); 105046d4c572STomoki Sekiyama 105146d4c572STomoki Sekiyama g_free(devpath); 105246d4c572STomoki Sekiyama return fs; 105346d4c572STomoki Sekiyama } 105446d4c572STomoki Sekiyama 105546d4c572STomoki Sekiyama GuestFilesystemInfoList *qmp_guest_get_fsinfo(Error **errp) 105646d4c572STomoki Sekiyama { 105746d4c572STomoki Sekiyama FsMountList mounts; 105846d4c572STomoki Sekiyama struct FsMount *mount; 105946d4c572STomoki Sekiyama GuestFilesystemInfoList *new, *ret = NULL; 106046d4c572STomoki Sekiyama Error *local_err = NULL; 106146d4c572STomoki Sekiyama 106246d4c572STomoki Sekiyama QTAILQ_INIT(&mounts); 106346d4c572STomoki Sekiyama build_fs_mount_list(&mounts, &local_err); 106446d4c572STomoki Sekiyama if (local_err) { 106546d4c572STomoki Sekiyama error_propagate(errp, local_err); 106646d4c572STomoki Sekiyama return NULL; 106746d4c572STomoki Sekiyama } 106846d4c572STomoki Sekiyama 106946d4c572STomoki Sekiyama QTAILQ_FOREACH(mount, &mounts, next) { 107046d4c572STomoki Sekiyama g_debug("Building guest fsinfo for '%s'", mount->dirname); 107146d4c572STomoki Sekiyama 107246d4c572STomoki Sekiyama new = g_malloc0(sizeof(*ret)); 107346d4c572STomoki Sekiyama new->value = build_guest_fsinfo(mount, &local_err); 107446d4c572STomoki Sekiyama new->next = ret; 107546d4c572STomoki Sekiyama ret = new; 107646d4c572STomoki Sekiyama if (local_err) { 107746d4c572STomoki Sekiyama error_propagate(errp, local_err); 107846d4c572STomoki Sekiyama qapi_free_GuestFilesystemInfoList(ret); 107946d4c572STomoki Sekiyama ret = NULL; 108046d4c572STomoki Sekiyama break; 108146d4c572STomoki Sekiyama } 108246d4c572STomoki Sekiyama } 108346d4c572STomoki Sekiyama 108446d4c572STomoki Sekiyama free_fs_mount_list(&mounts); 108546d4c572STomoki Sekiyama return ret; 108646d4c572STomoki Sekiyama } 108746d4c572STomoki Sekiyama 108846d4c572STomoki Sekiyama 1089ec0f694cSTomoki Sekiyama typedef enum { 1090ec0f694cSTomoki Sekiyama FSFREEZE_HOOK_THAW = 0, 1091ec0f694cSTomoki Sekiyama FSFREEZE_HOOK_FREEZE, 1092ec0f694cSTomoki Sekiyama } FsfreezeHookArg; 1093ec0f694cSTomoki Sekiyama 109413a439ecSStefan Weil static const char *fsfreeze_hook_arg_string[] = { 1095ec0f694cSTomoki Sekiyama "thaw", 1096ec0f694cSTomoki Sekiyama "freeze", 1097ec0f694cSTomoki Sekiyama }; 1098ec0f694cSTomoki Sekiyama 109977dbc81bSMarkus Armbruster static void execute_fsfreeze_hook(FsfreezeHookArg arg, Error **errp) 1100ec0f694cSTomoki Sekiyama { 1101ec0f694cSTomoki Sekiyama int status; 1102ec0f694cSTomoki Sekiyama pid_t pid; 1103ec0f694cSTomoki Sekiyama const char *hook; 1104ec0f694cSTomoki Sekiyama const char *arg_str = fsfreeze_hook_arg_string[arg]; 1105ec0f694cSTomoki Sekiyama Error *local_err = NULL; 1106ec0f694cSTomoki Sekiyama 1107ec0f694cSTomoki Sekiyama hook = ga_fsfreeze_hook(ga_state); 1108ec0f694cSTomoki Sekiyama if (!hook) { 1109ec0f694cSTomoki Sekiyama return; 1110ec0f694cSTomoki Sekiyama } 1111ec0f694cSTomoki Sekiyama if (access(hook, X_OK) != 0) { 111277dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "can't access fsfreeze hook '%s'", hook); 1113ec0f694cSTomoki Sekiyama return; 1114ec0f694cSTomoki Sekiyama } 1115ec0f694cSTomoki Sekiyama 1116ec0f694cSTomoki Sekiyama slog("executing fsfreeze hook with arg '%s'", arg_str); 1117ec0f694cSTomoki Sekiyama pid = fork(); 1118ec0f694cSTomoki Sekiyama if (pid == 0) { 1119ec0f694cSTomoki Sekiyama setsid(); 1120ec0f694cSTomoki Sekiyama reopen_fd_to_null(0); 1121ec0f694cSTomoki Sekiyama reopen_fd_to_null(1); 1122ec0f694cSTomoki Sekiyama reopen_fd_to_null(2); 1123ec0f694cSTomoki Sekiyama 1124ec0f694cSTomoki Sekiyama execle(hook, hook, arg_str, NULL, environ); 1125ec0f694cSTomoki Sekiyama _exit(EXIT_FAILURE); 1126ec0f694cSTomoki Sekiyama } else if (pid < 0) { 112777dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to create child process"); 1128ec0f694cSTomoki Sekiyama return; 1129ec0f694cSTomoki Sekiyama } 1130ec0f694cSTomoki Sekiyama 1131ec0f694cSTomoki Sekiyama ga_wait_child(pid, &status, &local_err); 113284d18f06SMarkus Armbruster if (local_err) { 113377dbc81bSMarkus Armbruster error_propagate(errp, local_err); 1134ec0f694cSTomoki Sekiyama return; 1135ec0f694cSTomoki Sekiyama } 1136ec0f694cSTomoki Sekiyama 1137ec0f694cSTomoki Sekiyama if (!WIFEXITED(status)) { 113877dbc81bSMarkus Armbruster error_setg(errp, "fsfreeze hook has terminated abnormally"); 1139ec0f694cSTomoki Sekiyama return; 1140ec0f694cSTomoki Sekiyama } 1141ec0f694cSTomoki Sekiyama 1142ec0f694cSTomoki Sekiyama status = WEXITSTATUS(status); 1143ec0f694cSTomoki Sekiyama if (status) { 114477dbc81bSMarkus Armbruster error_setg(errp, "fsfreeze hook has failed with status %d", status); 1145ec0f694cSTomoki Sekiyama return; 1146ec0f694cSTomoki Sekiyama } 1147ec0f694cSTomoki Sekiyama } 1148ec0f694cSTomoki Sekiyama 1149c216e5adSMichael Roth /* 1150c216e5adSMichael Roth * Return status of freeze/thaw 1151c216e5adSMichael Roth */ 115277dbc81bSMarkus Armbruster GuestFsfreezeStatus qmp_guest_fsfreeze_status(Error **errp) 1153c216e5adSMichael Roth { 1154f22d85e9SMichael Roth if (ga_is_frozen(ga_state)) { 1155f22d85e9SMichael Roth return GUEST_FSFREEZE_STATUS_FROZEN; 1156f22d85e9SMichael Roth } 1157f22d85e9SMichael Roth 1158f22d85e9SMichael Roth return GUEST_FSFREEZE_STATUS_THAWED; 1159c216e5adSMichael Roth } 1160c216e5adSMichael Roth 1161e99bce20STomoki Sekiyama int64_t qmp_guest_fsfreeze_freeze(Error **errp) 1162e99bce20STomoki Sekiyama { 1163e99bce20STomoki Sekiyama return qmp_guest_fsfreeze_freeze_list(false, NULL, errp); 1164e99bce20STomoki Sekiyama } 1165e99bce20STomoki Sekiyama 1166c216e5adSMichael Roth /* 1167c216e5adSMichael Roth * Walk list of mounted file systems in the guest, and freeze the ones which 1168c216e5adSMichael Roth * are real local file systems. 1169c216e5adSMichael Roth */ 1170e99bce20STomoki Sekiyama int64_t qmp_guest_fsfreeze_freeze_list(bool has_mountpoints, 1171e99bce20STomoki Sekiyama strList *mountpoints, 1172e99bce20STomoki Sekiyama Error **errp) 1173c216e5adSMichael Roth { 1174c216e5adSMichael Roth int ret = 0, i = 0; 1175e99bce20STomoki Sekiyama strList *list; 1176af02203fSPaolo Bonzini FsMountList mounts; 1177af02203fSPaolo Bonzini struct FsMount *mount; 1178261551d1SLuiz Capitulino Error *local_err = NULL; 1179c216e5adSMichael Roth int fd; 1180c216e5adSMichael Roth 1181c216e5adSMichael Roth slog("guest-fsfreeze called"); 1182c216e5adSMichael Roth 1183ec0f694cSTomoki Sekiyama execute_fsfreeze_hook(FSFREEZE_HOOK_FREEZE, &local_err); 118484d18f06SMarkus Armbruster if (local_err) { 118577dbc81bSMarkus Armbruster error_propagate(errp, local_err); 1186ec0f694cSTomoki Sekiyama return -1; 1187ec0f694cSTomoki Sekiyama } 1188ec0f694cSTomoki Sekiyama 11899e8aded4SMichael Roth QTAILQ_INIT(&mounts); 1190261551d1SLuiz Capitulino build_fs_mount_list(&mounts, &local_err); 119184d18f06SMarkus Armbruster if (local_err) { 119277dbc81bSMarkus Armbruster error_propagate(errp, local_err); 1193261551d1SLuiz Capitulino return -1; 1194c216e5adSMichael Roth } 1195c216e5adSMichael Roth 1196c216e5adSMichael Roth /* cannot risk guest agent blocking itself on a write in this state */ 1197f22d85e9SMichael Roth ga_set_frozen(ga_state); 1198c216e5adSMichael Roth 1199e5d9adbdSTomoki Sekiyama QTAILQ_FOREACH_REVERSE(mount, &mounts, FsMountList, next) { 1200e99bce20STomoki Sekiyama /* To issue fsfreeze in the reverse order of mounts, check if the 1201e99bce20STomoki Sekiyama * mount is listed in the list here */ 1202e99bce20STomoki Sekiyama if (has_mountpoints) { 1203e99bce20STomoki Sekiyama for (list = mountpoints; list; list = list->next) { 1204e99bce20STomoki Sekiyama if (strcmp(list->value, mount->dirname) == 0) { 1205e99bce20STomoki Sekiyama break; 1206e99bce20STomoki Sekiyama } 1207e99bce20STomoki Sekiyama } 1208e99bce20STomoki Sekiyama if (!list) { 1209e99bce20STomoki Sekiyama continue; 1210e99bce20STomoki Sekiyama } 1211e99bce20STomoki Sekiyama } 1212e99bce20STomoki Sekiyama 1213c216e5adSMichael Roth fd = qemu_open(mount->dirname, O_RDONLY); 1214c216e5adSMichael Roth if (fd == -1) { 121577dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to open %s", mount->dirname); 1216c216e5adSMichael Roth goto error; 1217c216e5adSMichael Roth } 1218c216e5adSMichael Roth 1219c216e5adSMichael Roth /* we try to cull filesytems we know won't work in advance, but other 1220c216e5adSMichael Roth * filesytems may not implement fsfreeze for less obvious reasons. 12219e8aded4SMichael Roth * these will report EOPNOTSUPP. we simply ignore these when tallying 12229e8aded4SMichael Roth * the number of frozen filesystems. 12239e8aded4SMichael Roth * 12249e8aded4SMichael Roth * any other error means a failure to freeze a filesystem we 12259e8aded4SMichael Roth * expect to be freezable, so return an error in those cases 12269e8aded4SMichael Roth * and return system to thawed state. 1227c216e5adSMichael Roth */ 1228c216e5adSMichael Roth ret = ioctl(fd, FIFREEZE); 12299e8aded4SMichael Roth if (ret == -1) { 12309e8aded4SMichael Roth if (errno != EOPNOTSUPP) { 123177dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to freeze %s", 1232617fbbc1SLuiz Capitulino mount->dirname); 1233c216e5adSMichael Roth close(fd); 1234c216e5adSMichael Roth goto error; 1235c216e5adSMichael Roth } 12369e8aded4SMichael Roth } else { 1237c216e5adSMichael Roth i++; 1238c216e5adSMichael Roth } 12399e8aded4SMichael Roth close(fd); 12409e8aded4SMichael Roth } 1241c216e5adSMichael Roth 1242af02203fSPaolo Bonzini free_fs_mount_list(&mounts); 1243c216e5adSMichael Roth return i; 1244c216e5adSMichael Roth 1245c216e5adSMichael Roth error: 1246af02203fSPaolo Bonzini free_fs_mount_list(&mounts); 1247c216e5adSMichael Roth qmp_guest_fsfreeze_thaw(NULL); 1248c216e5adSMichael Roth return 0; 1249c216e5adSMichael Roth } 1250c216e5adSMichael Roth 1251c216e5adSMichael Roth /* 1252c216e5adSMichael Roth * Walk list of frozen file systems in the guest, and thaw them. 1253c216e5adSMichael Roth */ 125477dbc81bSMarkus Armbruster int64_t qmp_guest_fsfreeze_thaw(Error **errp) 1255c216e5adSMichael Roth { 1256c216e5adSMichael Roth int ret; 1257af02203fSPaolo Bonzini FsMountList mounts; 1258af02203fSPaolo Bonzini FsMount *mount; 12599e8aded4SMichael Roth int fd, i = 0, logged; 1260261551d1SLuiz Capitulino Error *local_err = NULL; 1261c216e5adSMichael Roth 12629e8aded4SMichael Roth QTAILQ_INIT(&mounts); 1263261551d1SLuiz Capitulino build_fs_mount_list(&mounts, &local_err); 126484d18f06SMarkus Armbruster if (local_err) { 126577dbc81bSMarkus Armbruster error_propagate(errp, local_err); 12669e8aded4SMichael Roth return 0; 12679e8aded4SMichael Roth } 12689e8aded4SMichael Roth 12699e8aded4SMichael Roth QTAILQ_FOREACH(mount, &mounts, next) { 12709e8aded4SMichael Roth logged = false; 1271c216e5adSMichael Roth fd = qemu_open(mount->dirname, O_RDONLY); 1272c216e5adSMichael Roth if (fd == -1) { 1273c216e5adSMichael Roth continue; 1274c216e5adSMichael Roth } 12759e8aded4SMichael Roth /* we have no way of knowing whether a filesystem was actually unfrozen 12769e8aded4SMichael Roth * as a result of a successful call to FITHAW, only that if an error 12779e8aded4SMichael Roth * was returned the filesystem was *not* unfrozen by that particular 12789e8aded4SMichael Roth * call. 12799e8aded4SMichael Roth * 1280a31f0531SJim Meyering * since multiple preceding FIFREEZEs require multiple calls to FITHAW 12819e8aded4SMichael Roth * to unfreeze, continuing issuing FITHAW until an error is returned, 12829e8aded4SMichael Roth * in which case either the filesystem is in an unfreezable state, or, 12839e8aded4SMichael Roth * more likely, it was thawed previously (and remains so afterward). 12849e8aded4SMichael Roth * 12859e8aded4SMichael Roth * also, since the most recent successful call is the one that did 12869e8aded4SMichael Roth * the actual unfreeze, we can use this to provide an accurate count 12879e8aded4SMichael Roth * of the number of filesystems unfrozen by guest-fsfreeze-thaw, which 12889e8aded4SMichael Roth * may * be useful for determining whether a filesystem was unfrozen 12899e8aded4SMichael Roth * during the freeze/thaw phase by a process other than qemu-ga. 12909e8aded4SMichael Roth */ 12919e8aded4SMichael Roth do { 1292c216e5adSMichael Roth ret = ioctl(fd, FITHAW); 12939e8aded4SMichael Roth if (ret == 0 && !logged) { 1294c216e5adSMichael Roth i++; 12959e8aded4SMichael Roth logged = true; 12969e8aded4SMichael Roth } 12979e8aded4SMichael Roth } while (ret == 0); 12989e8aded4SMichael Roth close(fd); 1299c216e5adSMichael Roth } 1300c216e5adSMichael Roth 1301f22d85e9SMichael Roth ga_unset_frozen(ga_state); 1302af02203fSPaolo Bonzini free_fs_mount_list(&mounts); 1303ec0f694cSTomoki Sekiyama 130477dbc81bSMarkus Armbruster execute_fsfreeze_hook(FSFREEZE_HOOK_THAW, errp); 1305ec0f694cSTomoki Sekiyama 1306c216e5adSMichael Roth return i; 1307c216e5adSMichael Roth } 1308c216e5adSMichael Roth 1309c216e5adSMichael Roth static void guest_fsfreeze_cleanup(void) 1310c216e5adSMichael Roth { 1311c216e5adSMichael Roth Error *err = NULL; 1312c216e5adSMichael Roth 1313f22d85e9SMichael Roth if (ga_is_frozen(ga_state) == GUEST_FSFREEZE_STATUS_FROZEN) { 13146f686749SMarkus Armbruster qmp_guest_fsfreeze_thaw(&err); 13156f686749SMarkus Armbruster if (err) { 13166f686749SMarkus Armbruster slog("failed to clean up frozen filesystems: %s", 13176f686749SMarkus Armbruster error_get_pretty(err)); 13186f686749SMarkus Armbruster error_free(err); 1319c216e5adSMichael Roth } 1320c216e5adSMichael Roth } 1321c216e5adSMichael Roth } 1322e72c3f2eSMichael Roth #endif /* CONFIG_FSFREEZE */ 1323c216e5adSMichael Roth 1324eab5fd59SPaolo Bonzini #if defined(CONFIG_FSTRIM) 1325eab5fd59SPaolo Bonzini /* 1326eab5fd59SPaolo Bonzini * Walk list of mounted file systems in the guest, and trim them. 1327eab5fd59SPaolo Bonzini */ 132877dbc81bSMarkus Armbruster void qmp_guest_fstrim(bool has_minimum, int64_t minimum, Error **errp) 1329eab5fd59SPaolo Bonzini { 1330eab5fd59SPaolo Bonzini int ret = 0; 1331eab5fd59SPaolo Bonzini FsMountList mounts; 1332eab5fd59SPaolo Bonzini struct FsMount *mount; 1333eab5fd59SPaolo Bonzini int fd; 1334261551d1SLuiz Capitulino Error *local_err = NULL; 1335eab5fd59SPaolo Bonzini struct fstrim_range r = { 1336eab5fd59SPaolo Bonzini .start = 0, 1337eab5fd59SPaolo Bonzini .len = -1, 1338eab5fd59SPaolo Bonzini .minlen = has_minimum ? minimum : 0, 1339eab5fd59SPaolo Bonzini }; 1340eab5fd59SPaolo Bonzini 1341eab5fd59SPaolo Bonzini slog("guest-fstrim called"); 1342eab5fd59SPaolo Bonzini 1343eab5fd59SPaolo Bonzini QTAILQ_INIT(&mounts); 1344261551d1SLuiz Capitulino build_fs_mount_list(&mounts, &local_err); 134584d18f06SMarkus Armbruster if (local_err) { 134677dbc81bSMarkus Armbruster error_propagate(errp, local_err); 1347eab5fd59SPaolo Bonzini return; 1348eab5fd59SPaolo Bonzini } 1349eab5fd59SPaolo Bonzini 1350eab5fd59SPaolo Bonzini QTAILQ_FOREACH(mount, &mounts, next) { 1351eab5fd59SPaolo Bonzini fd = qemu_open(mount->dirname, O_RDONLY); 1352eab5fd59SPaolo Bonzini if (fd == -1) { 135377dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to open %s", mount->dirname); 1354eab5fd59SPaolo Bonzini goto error; 1355eab5fd59SPaolo Bonzini } 1356eab5fd59SPaolo Bonzini 1357eab5fd59SPaolo Bonzini /* We try to cull filesytems we know won't work in advance, but other 1358eab5fd59SPaolo Bonzini * filesytems may not implement fstrim for less obvious reasons. These 1359eab5fd59SPaolo Bonzini * will report EOPNOTSUPP; we simply ignore these errors. Any other 1360eab5fd59SPaolo Bonzini * error means an unexpected error, so return it in those cases. In 1361eab5fd59SPaolo Bonzini * some other cases ENOTTY will be reported (e.g. CD-ROMs). 1362eab5fd59SPaolo Bonzini */ 1363eab5fd59SPaolo Bonzini ret = ioctl(fd, FITRIM, &r); 1364eab5fd59SPaolo Bonzini if (ret == -1) { 1365eab5fd59SPaolo Bonzini if (errno != ENOTTY && errno != EOPNOTSUPP) { 136677dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to trim %s", 1367071673b0SLuiz Capitulino mount->dirname); 1368eab5fd59SPaolo Bonzini close(fd); 1369eab5fd59SPaolo Bonzini goto error; 1370eab5fd59SPaolo Bonzini } 1371eab5fd59SPaolo Bonzini } 1372eab5fd59SPaolo Bonzini close(fd); 1373eab5fd59SPaolo Bonzini } 1374eab5fd59SPaolo Bonzini 1375eab5fd59SPaolo Bonzini error: 1376eab5fd59SPaolo Bonzini free_fs_mount_list(&mounts); 1377eab5fd59SPaolo Bonzini } 1378eab5fd59SPaolo Bonzini #endif /* CONFIG_FSTRIM */ 1379eab5fd59SPaolo Bonzini 1380eab5fd59SPaolo Bonzini 138111d0f125SLuiz Capitulino #define LINUX_SYS_STATE_FILE "/sys/power/state" 138211d0f125SLuiz Capitulino #define SUSPEND_SUPPORTED 0 138311d0f125SLuiz Capitulino #define SUSPEND_NOT_SUPPORTED 1 138411d0f125SLuiz Capitulino 138511d0f125SLuiz Capitulino static void bios_supports_mode(const char *pmutils_bin, const char *pmutils_arg, 138677dbc81bSMarkus Armbruster const char *sysfile_str, Error **errp) 138711d0f125SLuiz Capitulino { 13886b26e837SLuiz Capitulino Error *local_err = NULL; 138911d0f125SLuiz Capitulino char *pmutils_path; 13906b26e837SLuiz Capitulino pid_t pid; 1391dc8764f0SLuiz Capitulino int status; 139211d0f125SLuiz Capitulino 139311d0f125SLuiz Capitulino pmutils_path = g_find_program_in_path(pmutils_bin); 139411d0f125SLuiz Capitulino 139511d0f125SLuiz Capitulino pid = fork(); 139611d0f125SLuiz Capitulino if (!pid) { 1397dc8764f0SLuiz Capitulino char buf[32]; /* hopefully big enough */ 1398dc8764f0SLuiz Capitulino ssize_t ret; 1399dc8764f0SLuiz Capitulino int fd; 140011d0f125SLuiz Capitulino 140111d0f125SLuiz Capitulino setsid(); 140211d0f125SLuiz Capitulino reopen_fd_to_null(0); 140311d0f125SLuiz Capitulino reopen_fd_to_null(1); 140411d0f125SLuiz Capitulino reopen_fd_to_null(2); 140511d0f125SLuiz Capitulino 140611d0f125SLuiz Capitulino if (pmutils_path) { 140711d0f125SLuiz Capitulino execle(pmutils_path, pmutils_bin, pmutils_arg, NULL, environ); 140811d0f125SLuiz Capitulino } 140911d0f125SLuiz Capitulino 141011d0f125SLuiz Capitulino /* 141111d0f125SLuiz Capitulino * If we get here either pm-utils is not installed or execle() has 141211d0f125SLuiz Capitulino * failed. Let's try the manual method if the caller wants it. 141311d0f125SLuiz Capitulino */ 141411d0f125SLuiz Capitulino 141511d0f125SLuiz Capitulino if (!sysfile_str) { 141611d0f125SLuiz Capitulino _exit(SUSPEND_NOT_SUPPORTED); 141711d0f125SLuiz Capitulino } 141811d0f125SLuiz Capitulino 141911d0f125SLuiz Capitulino fd = open(LINUX_SYS_STATE_FILE, O_RDONLY); 142011d0f125SLuiz Capitulino if (fd < 0) { 142111d0f125SLuiz Capitulino _exit(SUSPEND_NOT_SUPPORTED); 142211d0f125SLuiz Capitulino } 142311d0f125SLuiz Capitulino 142411d0f125SLuiz Capitulino ret = read(fd, buf, sizeof(buf)-1); 142511d0f125SLuiz Capitulino if (ret <= 0) { 142611d0f125SLuiz Capitulino _exit(SUSPEND_NOT_SUPPORTED); 142711d0f125SLuiz Capitulino } 142811d0f125SLuiz Capitulino buf[ret] = '\0'; 142911d0f125SLuiz Capitulino 143011d0f125SLuiz Capitulino if (strstr(buf, sysfile_str)) { 143111d0f125SLuiz Capitulino _exit(SUSPEND_SUPPORTED); 143211d0f125SLuiz Capitulino } 143311d0f125SLuiz Capitulino 143411d0f125SLuiz Capitulino _exit(SUSPEND_NOT_SUPPORTED); 14356b26e837SLuiz Capitulino } else if (pid < 0) { 143677dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to create child process"); 14376b26e837SLuiz Capitulino goto out; 143811d0f125SLuiz Capitulino } 143911d0f125SLuiz Capitulino 14406b26e837SLuiz Capitulino ga_wait_child(pid, &status, &local_err); 144184d18f06SMarkus Armbruster if (local_err) { 144277dbc81bSMarkus Armbruster error_propagate(errp, local_err); 14436b26e837SLuiz Capitulino goto out; 144411d0f125SLuiz Capitulino } 144511d0f125SLuiz Capitulino 14466b26e837SLuiz Capitulino if (!WIFEXITED(status)) { 144777dbc81bSMarkus Armbruster error_setg(errp, "child process has terminated abnormally"); 14486b26e837SLuiz Capitulino goto out; 14496b26e837SLuiz Capitulino } 14506b26e837SLuiz Capitulino 1451dc8764f0SLuiz Capitulino switch (WEXITSTATUS(status)) { 1452dc8764f0SLuiz Capitulino case SUSPEND_SUPPORTED: 14536b26e837SLuiz Capitulino goto out; 1454dc8764f0SLuiz Capitulino case SUSPEND_NOT_SUPPORTED: 145577dbc81bSMarkus Armbruster error_setg(errp, 14566b26e837SLuiz Capitulino "the requested suspend mode is not supported by the guest"); 14576b26e837SLuiz Capitulino goto out; 1458dc8764f0SLuiz Capitulino default: 145977dbc81bSMarkus Armbruster error_setg(errp, 14606b26e837SLuiz Capitulino "the helper program '%s' returned an unexpected exit status" 14616b26e837SLuiz Capitulino " code (%d)", pmutils_path, WEXITSTATUS(status)); 14626b26e837SLuiz Capitulino goto out; 1463dc8764f0SLuiz Capitulino } 146411d0f125SLuiz Capitulino 14656b26e837SLuiz Capitulino out: 14666b26e837SLuiz Capitulino g_free(pmutils_path); 146711d0f125SLuiz Capitulino } 146811d0f125SLuiz Capitulino 146911d0f125SLuiz Capitulino static void guest_suspend(const char *pmutils_bin, const char *sysfile_str, 147077dbc81bSMarkus Armbruster Error **errp) 147111d0f125SLuiz Capitulino { 14727b376087SLuiz Capitulino Error *local_err = NULL; 147311d0f125SLuiz Capitulino char *pmutils_path; 14747b376087SLuiz Capitulino pid_t pid; 1475dc8764f0SLuiz Capitulino int status; 147611d0f125SLuiz Capitulino 147711d0f125SLuiz Capitulino pmutils_path = g_find_program_in_path(pmutils_bin); 147811d0f125SLuiz Capitulino 147911d0f125SLuiz Capitulino pid = fork(); 148011d0f125SLuiz Capitulino if (pid == 0) { 148111d0f125SLuiz Capitulino /* child */ 148211d0f125SLuiz Capitulino int fd; 148311d0f125SLuiz Capitulino 148411d0f125SLuiz Capitulino setsid(); 148511d0f125SLuiz Capitulino reopen_fd_to_null(0); 148611d0f125SLuiz Capitulino reopen_fd_to_null(1); 148711d0f125SLuiz Capitulino reopen_fd_to_null(2); 148811d0f125SLuiz Capitulino 148911d0f125SLuiz Capitulino if (pmutils_path) { 149011d0f125SLuiz Capitulino execle(pmutils_path, pmutils_bin, NULL, environ); 149111d0f125SLuiz Capitulino } 149211d0f125SLuiz Capitulino 149311d0f125SLuiz Capitulino /* 149411d0f125SLuiz Capitulino * If we get here either pm-utils is not installed or execle() has 149511d0f125SLuiz Capitulino * failed. Let's try the manual method if the caller wants it. 149611d0f125SLuiz Capitulino */ 149711d0f125SLuiz Capitulino 149811d0f125SLuiz Capitulino if (!sysfile_str) { 149911d0f125SLuiz Capitulino _exit(EXIT_FAILURE); 150011d0f125SLuiz Capitulino } 150111d0f125SLuiz Capitulino 150211d0f125SLuiz Capitulino fd = open(LINUX_SYS_STATE_FILE, O_WRONLY); 150311d0f125SLuiz Capitulino if (fd < 0) { 150411d0f125SLuiz Capitulino _exit(EXIT_FAILURE); 150511d0f125SLuiz Capitulino } 150611d0f125SLuiz Capitulino 150711d0f125SLuiz Capitulino if (write(fd, sysfile_str, strlen(sysfile_str)) < 0) { 150811d0f125SLuiz Capitulino _exit(EXIT_FAILURE); 150911d0f125SLuiz Capitulino } 151011d0f125SLuiz Capitulino 151111d0f125SLuiz Capitulino _exit(EXIT_SUCCESS); 15127b376087SLuiz Capitulino } else if (pid < 0) { 151377dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to create child process"); 15147b376087SLuiz Capitulino goto out; 151511d0f125SLuiz Capitulino } 151611d0f125SLuiz Capitulino 15177b376087SLuiz Capitulino ga_wait_child(pid, &status, &local_err); 151884d18f06SMarkus Armbruster if (local_err) { 151977dbc81bSMarkus Armbruster error_propagate(errp, local_err); 15207b376087SLuiz Capitulino goto out; 15217b376087SLuiz Capitulino } 15227b376087SLuiz Capitulino 15237b376087SLuiz Capitulino if (!WIFEXITED(status)) { 152477dbc81bSMarkus Armbruster error_setg(errp, "child process has terminated abnormally"); 15257b376087SLuiz Capitulino goto out; 15267b376087SLuiz Capitulino } 15277b376087SLuiz Capitulino 15287b376087SLuiz Capitulino if (WEXITSTATUS(status)) { 152977dbc81bSMarkus Armbruster error_setg(errp, "child process has failed to suspend"); 15307b376087SLuiz Capitulino goto out; 15317b376087SLuiz Capitulino } 15327b376087SLuiz Capitulino 15337b376087SLuiz Capitulino out: 153411d0f125SLuiz Capitulino g_free(pmutils_path); 153511d0f125SLuiz Capitulino } 153611d0f125SLuiz Capitulino 153777dbc81bSMarkus Armbruster void qmp_guest_suspend_disk(Error **errp) 153811d0f125SLuiz Capitulino { 15390f230bf7SMarkus Armbruster Error *local_err = NULL; 15400f230bf7SMarkus Armbruster 15410f230bf7SMarkus Armbruster bios_supports_mode("pm-is-supported", "--hibernate", "disk", &local_err); 15420f230bf7SMarkus Armbruster if (local_err) { 15430f230bf7SMarkus Armbruster error_propagate(errp, local_err); 154411d0f125SLuiz Capitulino return; 154511d0f125SLuiz Capitulino } 154611d0f125SLuiz Capitulino 154777dbc81bSMarkus Armbruster guest_suspend("pm-hibernate", "disk", errp); 154811d0f125SLuiz Capitulino } 154911d0f125SLuiz Capitulino 155077dbc81bSMarkus Armbruster void qmp_guest_suspend_ram(Error **errp) 1551fbf42210SLuiz Capitulino { 15520f230bf7SMarkus Armbruster Error *local_err = NULL; 15530f230bf7SMarkus Armbruster 15540f230bf7SMarkus Armbruster bios_supports_mode("pm-is-supported", "--suspend", "mem", &local_err); 15550f230bf7SMarkus Armbruster if (local_err) { 15560f230bf7SMarkus Armbruster error_propagate(errp, local_err); 1557fbf42210SLuiz Capitulino return; 1558fbf42210SLuiz Capitulino } 1559fbf42210SLuiz Capitulino 156077dbc81bSMarkus Armbruster guest_suspend("pm-suspend", "mem", errp); 1561fbf42210SLuiz Capitulino } 1562fbf42210SLuiz Capitulino 156377dbc81bSMarkus Armbruster void qmp_guest_suspend_hybrid(Error **errp) 156495f4f404SLuiz Capitulino { 15650f230bf7SMarkus Armbruster Error *local_err = NULL; 15660f230bf7SMarkus Armbruster 15670f230bf7SMarkus Armbruster bios_supports_mode("pm-is-supported", "--suspend-hybrid", NULL, 15680f230bf7SMarkus Armbruster &local_err); 15690f230bf7SMarkus Armbruster if (local_err) { 15700f230bf7SMarkus Armbruster error_propagate(errp, local_err); 157195f4f404SLuiz Capitulino return; 157295f4f404SLuiz Capitulino } 157395f4f404SLuiz Capitulino 157477dbc81bSMarkus Armbruster guest_suspend("pm-suspend-hybrid", NULL, errp); 157595f4f404SLuiz Capitulino } 157695f4f404SLuiz Capitulino 15773424fc9fSMichal Privoznik static GuestNetworkInterfaceList * 15783424fc9fSMichal Privoznik guest_find_interface(GuestNetworkInterfaceList *head, 15793424fc9fSMichal Privoznik const char *name) 15803424fc9fSMichal Privoznik { 15813424fc9fSMichal Privoznik for (; head; head = head->next) { 15823424fc9fSMichal Privoznik if (strcmp(head->value->name, name) == 0) { 15833424fc9fSMichal Privoznik break; 15843424fc9fSMichal Privoznik } 15853424fc9fSMichal Privoznik } 15863424fc9fSMichal Privoznik 15873424fc9fSMichal Privoznik return head; 15883424fc9fSMichal Privoznik } 15893424fc9fSMichal Privoznik 15903424fc9fSMichal Privoznik /* 15913424fc9fSMichal Privoznik * Build information about guest interfaces 15923424fc9fSMichal Privoznik */ 15933424fc9fSMichal Privoznik GuestNetworkInterfaceList *qmp_guest_network_get_interfaces(Error **errp) 15943424fc9fSMichal Privoznik { 15953424fc9fSMichal Privoznik GuestNetworkInterfaceList *head = NULL, *cur_item = NULL; 15963424fc9fSMichal Privoznik struct ifaddrs *ifap, *ifa; 15973424fc9fSMichal Privoznik 15983424fc9fSMichal Privoznik if (getifaddrs(&ifap) < 0) { 1599878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, "getifaddrs failed"); 16003424fc9fSMichal Privoznik goto error; 16013424fc9fSMichal Privoznik } 16023424fc9fSMichal Privoznik 16033424fc9fSMichal Privoznik for (ifa = ifap; ifa; ifa = ifa->ifa_next) { 16043424fc9fSMichal Privoznik GuestNetworkInterfaceList *info; 16053424fc9fSMichal Privoznik GuestIpAddressList **address_list = NULL, *address_item = NULL; 16063424fc9fSMichal Privoznik char addr4[INET_ADDRSTRLEN]; 16073424fc9fSMichal Privoznik char addr6[INET6_ADDRSTRLEN]; 16083424fc9fSMichal Privoznik int sock; 16093424fc9fSMichal Privoznik struct ifreq ifr; 16103424fc9fSMichal Privoznik unsigned char *mac_addr; 16113424fc9fSMichal Privoznik void *p; 16123424fc9fSMichal Privoznik 16133424fc9fSMichal Privoznik g_debug("Processing %s interface", ifa->ifa_name); 16143424fc9fSMichal Privoznik 16153424fc9fSMichal Privoznik info = guest_find_interface(head, ifa->ifa_name); 16163424fc9fSMichal Privoznik 16173424fc9fSMichal Privoznik if (!info) { 16183424fc9fSMichal Privoznik info = g_malloc0(sizeof(*info)); 16193424fc9fSMichal Privoznik info->value = g_malloc0(sizeof(*info->value)); 16203424fc9fSMichal Privoznik info->value->name = g_strdup(ifa->ifa_name); 16213424fc9fSMichal Privoznik 16223424fc9fSMichal Privoznik if (!cur_item) { 16233424fc9fSMichal Privoznik head = cur_item = info; 16243424fc9fSMichal Privoznik } else { 16253424fc9fSMichal Privoznik cur_item->next = info; 16263424fc9fSMichal Privoznik cur_item = info; 16273424fc9fSMichal Privoznik } 16283424fc9fSMichal Privoznik } 16293424fc9fSMichal Privoznik 16303424fc9fSMichal Privoznik if (!info->value->has_hardware_address && 16313424fc9fSMichal Privoznik ifa->ifa_flags & SIOCGIFHWADDR) { 16323424fc9fSMichal Privoznik /* we haven't obtained HW address yet */ 16333424fc9fSMichal Privoznik sock = socket(PF_INET, SOCK_STREAM, 0); 16343424fc9fSMichal Privoznik if (sock == -1) { 1635878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, "failed to create socket"); 16363424fc9fSMichal Privoznik goto error; 16373424fc9fSMichal Privoznik } 16383424fc9fSMichal Privoznik 16393424fc9fSMichal Privoznik memset(&ifr, 0, sizeof(ifr)); 16401ab516edSJim Meyering pstrcpy(ifr.ifr_name, IF_NAMESIZE, info->value->name); 16413424fc9fSMichal Privoznik if (ioctl(sock, SIOCGIFHWADDR, &ifr) == -1) { 1642878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, 1643878a0ae0SLuiz Capitulino "failed to get MAC address of %s", 1644878a0ae0SLuiz Capitulino ifa->ifa_name); 164510a2158fSMarkus Armbruster close(sock); 16463424fc9fSMichal Privoznik goto error; 16473424fc9fSMichal Privoznik } 16483424fc9fSMichal Privoznik 164910a2158fSMarkus Armbruster close(sock); 16503424fc9fSMichal Privoznik mac_addr = (unsigned char *) &ifr.ifr_hwaddr.sa_data; 16513424fc9fSMichal Privoznik 1652e4ada482SStefan Weil info->value->hardware_address = 1653e4ada482SStefan Weil g_strdup_printf("%02x:%02x:%02x:%02x:%02x:%02x", 16543424fc9fSMichal Privoznik (int) mac_addr[0], (int) mac_addr[1], 16553424fc9fSMichal Privoznik (int) mac_addr[2], (int) mac_addr[3], 1656e4ada482SStefan Weil (int) mac_addr[4], (int) mac_addr[5]); 16573424fc9fSMichal Privoznik 16583424fc9fSMichal Privoznik info->value->has_hardware_address = true; 16593424fc9fSMichal Privoznik } 16603424fc9fSMichal Privoznik 16613424fc9fSMichal Privoznik if (ifa->ifa_addr && 16623424fc9fSMichal Privoznik ifa->ifa_addr->sa_family == AF_INET) { 16633424fc9fSMichal Privoznik /* interface with IPv4 address */ 16643424fc9fSMichal Privoznik p = &((struct sockaddr_in *)ifa->ifa_addr)->sin_addr; 16653424fc9fSMichal Privoznik if (!inet_ntop(AF_INET, p, addr4, sizeof(addr4))) { 1666878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, "inet_ntop failed"); 16673424fc9fSMichal Privoznik goto error; 16683424fc9fSMichal Privoznik } 16693424fc9fSMichal Privoznik 167010a2158fSMarkus Armbruster address_item = g_malloc0(sizeof(*address_item)); 167110a2158fSMarkus Armbruster address_item->value = g_malloc0(sizeof(*address_item->value)); 16723424fc9fSMichal Privoznik address_item->value->ip_address = g_strdup(addr4); 16733424fc9fSMichal Privoznik address_item->value->ip_address_type = GUEST_IP_ADDRESS_TYPE_IPV4; 16743424fc9fSMichal Privoznik 16753424fc9fSMichal Privoznik if (ifa->ifa_netmask) { 16763424fc9fSMichal Privoznik /* Count the number of set bits in netmask. 16773424fc9fSMichal Privoznik * This is safe as '1' and '0' cannot be shuffled in netmask. */ 16783424fc9fSMichal Privoznik p = &((struct sockaddr_in *)ifa->ifa_netmask)->sin_addr; 16793424fc9fSMichal Privoznik address_item->value->prefix = ctpop32(((uint32_t *) p)[0]); 16803424fc9fSMichal Privoznik } 16813424fc9fSMichal Privoznik } else if (ifa->ifa_addr && 16823424fc9fSMichal Privoznik ifa->ifa_addr->sa_family == AF_INET6) { 16833424fc9fSMichal Privoznik /* interface with IPv6 address */ 16843424fc9fSMichal Privoznik p = &((struct sockaddr_in6 *)ifa->ifa_addr)->sin6_addr; 16853424fc9fSMichal Privoznik if (!inet_ntop(AF_INET6, p, addr6, sizeof(addr6))) { 1686878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, "inet_ntop failed"); 16873424fc9fSMichal Privoznik goto error; 16883424fc9fSMichal Privoznik } 16893424fc9fSMichal Privoznik 169010a2158fSMarkus Armbruster address_item = g_malloc0(sizeof(*address_item)); 169110a2158fSMarkus Armbruster address_item->value = g_malloc0(sizeof(*address_item->value)); 16923424fc9fSMichal Privoznik address_item->value->ip_address = g_strdup(addr6); 16933424fc9fSMichal Privoznik address_item->value->ip_address_type = GUEST_IP_ADDRESS_TYPE_IPV6; 16943424fc9fSMichal Privoznik 16953424fc9fSMichal Privoznik if (ifa->ifa_netmask) { 16963424fc9fSMichal Privoznik /* Count the number of set bits in netmask. 16973424fc9fSMichal Privoznik * This is safe as '1' and '0' cannot be shuffled in netmask. */ 16983424fc9fSMichal Privoznik p = &((struct sockaddr_in6 *)ifa->ifa_netmask)->sin6_addr; 16993424fc9fSMichal Privoznik address_item->value->prefix = 17003424fc9fSMichal Privoznik ctpop32(((uint32_t *) p)[0]) + 17013424fc9fSMichal Privoznik ctpop32(((uint32_t *) p)[1]) + 17023424fc9fSMichal Privoznik ctpop32(((uint32_t *) p)[2]) + 17033424fc9fSMichal Privoznik ctpop32(((uint32_t *) p)[3]); 17043424fc9fSMichal Privoznik } 17053424fc9fSMichal Privoznik } 17063424fc9fSMichal Privoznik 17073424fc9fSMichal Privoznik if (!address_item) { 17083424fc9fSMichal Privoznik continue; 17093424fc9fSMichal Privoznik } 17103424fc9fSMichal Privoznik 17113424fc9fSMichal Privoznik address_list = &info->value->ip_addresses; 17123424fc9fSMichal Privoznik 17133424fc9fSMichal Privoznik while (*address_list && (*address_list)->next) { 17143424fc9fSMichal Privoznik address_list = &(*address_list)->next; 17153424fc9fSMichal Privoznik } 17163424fc9fSMichal Privoznik 17173424fc9fSMichal Privoznik if (!*address_list) { 17183424fc9fSMichal Privoznik *address_list = address_item; 17193424fc9fSMichal Privoznik } else { 17203424fc9fSMichal Privoznik (*address_list)->next = address_item; 17213424fc9fSMichal Privoznik } 17223424fc9fSMichal Privoznik 17233424fc9fSMichal Privoznik info->value->has_ip_addresses = true; 17243424fc9fSMichal Privoznik 17253424fc9fSMichal Privoznik 17263424fc9fSMichal Privoznik } 17273424fc9fSMichal Privoznik 17283424fc9fSMichal Privoznik freeifaddrs(ifap); 17293424fc9fSMichal Privoznik return head; 17303424fc9fSMichal Privoznik 17313424fc9fSMichal Privoznik error: 17323424fc9fSMichal Privoznik freeifaddrs(ifap); 17333424fc9fSMichal Privoznik qapi_free_GuestNetworkInterfaceList(head); 17343424fc9fSMichal Privoznik return NULL; 17353424fc9fSMichal Privoznik } 17363424fc9fSMichal Privoznik 173777dbc81bSMarkus Armbruster #define SYSCONF_EXACT(name, errp) sysconf_exact((name), #name, (errp)) 1738d2baff62SLaszlo Ersek 173977dbc81bSMarkus Armbruster static long sysconf_exact(int name, const char *name_str, Error **errp) 1740d2baff62SLaszlo Ersek { 1741d2baff62SLaszlo Ersek long ret; 1742d2baff62SLaszlo Ersek 1743d2baff62SLaszlo Ersek errno = 0; 1744d2baff62SLaszlo Ersek ret = sysconf(name); 1745d2baff62SLaszlo Ersek if (ret == -1) { 1746d2baff62SLaszlo Ersek if (errno == 0) { 174777dbc81bSMarkus Armbruster error_setg(errp, "sysconf(%s): value indefinite", name_str); 1748d2baff62SLaszlo Ersek } else { 174977dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "sysconf(%s)", name_str); 1750d2baff62SLaszlo Ersek } 1751d2baff62SLaszlo Ersek } 1752d2baff62SLaszlo Ersek return ret; 1753d2baff62SLaszlo Ersek } 1754d2baff62SLaszlo Ersek 1755d2baff62SLaszlo Ersek /* Transfer online/offline status between @vcpu and the guest system. 1756d2baff62SLaszlo Ersek * 1757d2baff62SLaszlo Ersek * On input either @errp or *@errp must be NULL. 1758d2baff62SLaszlo Ersek * 1759d2baff62SLaszlo Ersek * In system-to-@vcpu direction, the following @vcpu fields are accessed: 1760d2baff62SLaszlo Ersek * - R: vcpu->logical_id 1761d2baff62SLaszlo Ersek * - W: vcpu->online 1762d2baff62SLaszlo Ersek * - W: vcpu->can_offline 1763d2baff62SLaszlo Ersek * 1764d2baff62SLaszlo Ersek * In @vcpu-to-system direction, the following @vcpu fields are accessed: 1765d2baff62SLaszlo Ersek * - R: vcpu->logical_id 1766d2baff62SLaszlo Ersek * - R: vcpu->online 1767d2baff62SLaszlo Ersek * 1768d2baff62SLaszlo Ersek * Written members remain unmodified on error. 1769d2baff62SLaszlo Ersek */ 1770d2baff62SLaszlo Ersek static void transfer_vcpu(GuestLogicalProcessor *vcpu, bool sys2vcpu, 1771d2baff62SLaszlo Ersek Error **errp) 1772d2baff62SLaszlo Ersek { 1773d2baff62SLaszlo Ersek char *dirpath; 1774d2baff62SLaszlo Ersek int dirfd; 1775d2baff62SLaszlo Ersek 1776d2baff62SLaszlo Ersek dirpath = g_strdup_printf("/sys/devices/system/cpu/cpu%" PRId64 "/", 1777d2baff62SLaszlo Ersek vcpu->logical_id); 1778d2baff62SLaszlo Ersek dirfd = open(dirpath, O_RDONLY | O_DIRECTORY); 1779d2baff62SLaszlo Ersek if (dirfd == -1) { 1780d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "open(\"%s\")", dirpath); 1781d2baff62SLaszlo Ersek } else { 1782d2baff62SLaszlo Ersek static const char fn[] = "online"; 1783d2baff62SLaszlo Ersek int fd; 1784d2baff62SLaszlo Ersek int res; 1785d2baff62SLaszlo Ersek 1786d2baff62SLaszlo Ersek fd = openat(dirfd, fn, sys2vcpu ? O_RDONLY : O_RDWR); 1787d2baff62SLaszlo Ersek if (fd == -1) { 1788d2baff62SLaszlo Ersek if (errno != ENOENT) { 1789d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "open(\"%s/%s\")", dirpath, fn); 1790d2baff62SLaszlo Ersek } else if (sys2vcpu) { 1791d2baff62SLaszlo Ersek vcpu->online = true; 1792d2baff62SLaszlo Ersek vcpu->can_offline = false; 1793d2baff62SLaszlo Ersek } else if (!vcpu->online) { 1794d2baff62SLaszlo Ersek error_setg(errp, "logical processor #%" PRId64 " can't be " 1795d2baff62SLaszlo Ersek "offlined", vcpu->logical_id); 1796d2baff62SLaszlo Ersek } /* otherwise pretend successful re-onlining */ 1797d2baff62SLaszlo Ersek } else { 1798d2baff62SLaszlo Ersek unsigned char status; 1799d2baff62SLaszlo Ersek 1800d2baff62SLaszlo Ersek res = pread(fd, &status, 1, 0); 1801d2baff62SLaszlo Ersek if (res == -1) { 1802d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "pread(\"%s/%s\")", dirpath, fn); 1803d2baff62SLaszlo Ersek } else if (res == 0) { 1804d2baff62SLaszlo Ersek error_setg(errp, "pread(\"%s/%s\"): unexpected EOF", dirpath, 1805d2baff62SLaszlo Ersek fn); 1806d2baff62SLaszlo Ersek } else if (sys2vcpu) { 1807d2baff62SLaszlo Ersek vcpu->online = (status != '0'); 1808d2baff62SLaszlo Ersek vcpu->can_offline = true; 1809d2baff62SLaszlo Ersek } else if (vcpu->online != (status != '0')) { 1810d2baff62SLaszlo Ersek status = '0' + vcpu->online; 1811d2baff62SLaszlo Ersek if (pwrite(fd, &status, 1, 0) == -1) { 1812d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "pwrite(\"%s/%s\")", dirpath, 1813d2baff62SLaszlo Ersek fn); 1814d2baff62SLaszlo Ersek } 1815d2baff62SLaszlo Ersek } /* otherwise pretend successful re-(on|off)-lining */ 1816d2baff62SLaszlo Ersek 1817d2baff62SLaszlo Ersek res = close(fd); 1818d2baff62SLaszlo Ersek g_assert(res == 0); 1819d2baff62SLaszlo Ersek } 1820d2baff62SLaszlo Ersek 1821d2baff62SLaszlo Ersek res = close(dirfd); 1822d2baff62SLaszlo Ersek g_assert(res == 0); 1823d2baff62SLaszlo Ersek } 1824d2baff62SLaszlo Ersek 1825d2baff62SLaszlo Ersek g_free(dirpath); 1826d2baff62SLaszlo Ersek } 1827d2baff62SLaszlo Ersek 1828d2baff62SLaszlo Ersek GuestLogicalProcessorList *qmp_guest_get_vcpus(Error **errp) 1829d2baff62SLaszlo Ersek { 1830d2baff62SLaszlo Ersek int64_t current; 1831d2baff62SLaszlo Ersek GuestLogicalProcessorList *head, **link; 1832d2baff62SLaszlo Ersek long sc_max; 1833d2baff62SLaszlo Ersek Error *local_err = NULL; 1834d2baff62SLaszlo Ersek 1835d2baff62SLaszlo Ersek current = 0; 1836d2baff62SLaszlo Ersek head = NULL; 1837d2baff62SLaszlo Ersek link = &head; 1838d2baff62SLaszlo Ersek sc_max = SYSCONF_EXACT(_SC_NPROCESSORS_CONF, &local_err); 1839d2baff62SLaszlo Ersek 1840d2baff62SLaszlo Ersek while (local_err == NULL && current < sc_max) { 1841d2baff62SLaszlo Ersek GuestLogicalProcessor *vcpu; 1842d2baff62SLaszlo Ersek GuestLogicalProcessorList *entry; 1843d2baff62SLaszlo Ersek 1844d2baff62SLaszlo Ersek vcpu = g_malloc0(sizeof *vcpu); 1845d2baff62SLaszlo Ersek vcpu->logical_id = current++; 1846d2baff62SLaszlo Ersek vcpu->has_can_offline = true; /* lolspeak ftw */ 1847d2baff62SLaszlo Ersek transfer_vcpu(vcpu, true, &local_err); 1848d2baff62SLaszlo Ersek 1849d2baff62SLaszlo Ersek entry = g_malloc0(sizeof *entry); 1850d2baff62SLaszlo Ersek entry->value = vcpu; 1851d2baff62SLaszlo Ersek 1852d2baff62SLaszlo Ersek *link = entry; 1853d2baff62SLaszlo Ersek link = &entry->next; 1854d2baff62SLaszlo Ersek } 1855d2baff62SLaszlo Ersek 1856d2baff62SLaszlo Ersek if (local_err == NULL) { 1857d2baff62SLaszlo Ersek /* there's no guest with zero VCPUs */ 1858d2baff62SLaszlo Ersek g_assert(head != NULL); 1859d2baff62SLaszlo Ersek return head; 1860d2baff62SLaszlo Ersek } 1861d2baff62SLaszlo Ersek 1862d2baff62SLaszlo Ersek qapi_free_GuestLogicalProcessorList(head); 1863d2baff62SLaszlo Ersek error_propagate(errp, local_err); 1864d2baff62SLaszlo Ersek return NULL; 1865d2baff62SLaszlo Ersek } 1866d2baff62SLaszlo Ersek 1867cbb65fc2SLaszlo Ersek int64_t qmp_guest_set_vcpus(GuestLogicalProcessorList *vcpus, Error **errp) 1868cbb65fc2SLaszlo Ersek { 1869cbb65fc2SLaszlo Ersek int64_t processed; 1870cbb65fc2SLaszlo Ersek Error *local_err = NULL; 1871cbb65fc2SLaszlo Ersek 1872cbb65fc2SLaszlo Ersek processed = 0; 1873cbb65fc2SLaszlo Ersek while (vcpus != NULL) { 1874cbb65fc2SLaszlo Ersek transfer_vcpu(vcpus->value, false, &local_err); 1875cbb65fc2SLaszlo Ersek if (local_err != NULL) { 1876cbb65fc2SLaszlo Ersek break; 1877cbb65fc2SLaszlo Ersek } 1878cbb65fc2SLaszlo Ersek ++processed; 1879cbb65fc2SLaszlo Ersek vcpus = vcpus->next; 1880cbb65fc2SLaszlo Ersek } 1881cbb65fc2SLaszlo Ersek 1882cbb65fc2SLaszlo Ersek if (local_err != NULL) { 1883cbb65fc2SLaszlo Ersek if (processed == 0) { 1884cbb65fc2SLaszlo Ersek error_propagate(errp, local_err); 1885cbb65fc2SLaszlo Ersek } else { 1886cbb65fc2SLaszlo Ersek error_free(local_err); 1887cbb65fc2SLaszlo Ersek } 1888cbb65fc2SLaszlo Ersek } 1889cbb65fc2SLaszlo Ersek 1890cbb65fc2SLaszlo Ersek return processed; 1891cbb65fc2SLaszlo Ersek } 1892cbb65fc2SLaszlo Ersek 1893215a2771SDaniel P. Berrange void qmp_guest_set_user_password(const char *username, 1894215a2771SDaniel P. Berrange const char *password, 1895215a2771SDaniel P. Berrange bool crypted, 1896215a2771SDaniel P. Berrange Error **errp) 1897215a2771SDaniel P. Berrange { 1898215a2771SDaniel P. Berrange Error *local_err = NULL; 1899215a2771SDaniel P. Berrange char *passwd_path = NULL; 1900215a2771SDaniel P. Berrange pid_t pid; 1901215a2771SDaniel P. Berrange int status; 1902215a2771SDaniel P. Berrange int datafd[2] = { -1, -1 }; 1903215a2771SDaniel P. Berrange char *rawpasswddata = NULL; 1904215a2771SDaniel P. Berrange size_t rawpasswdlen; 1905215a2771SDaniel P. Berrange char *chpasswddata = NULL; 1906215a2771SDaniel P. Berrange size_t chpasswdlen; 1907215a2771SDaniel P. Berrange 1908215a2771SDaniel P. Berrange rawpasswddata = (char *)g_base64_decode(password, &rawpasswdlen); 1909215a2771SDaniel P. Berrange rawpasswddata = g_renew(char, rawpasswddata, rawpasswdlen + 1); 1910215a2771SDaniel P. Berrange rawpasswddata[rawpasswdlen] = '\0'; 1911215a2771SDaniel P. Berrange 1912215a2771SDaniel P. Berrange if (strchr(rawpasswddata, '\n')) { 1913215a2771SDaniel P. Berrange error_setg(errp, "forbidden characters in raw password"); 1914215a2771SDaniel P. Berrange goto out; 1915215a2771SDaniel P. Berrange } 1916215a2771SDaniel P. Berrange 1917215a2771SDaniel P. Berrange if (strchr(username, '\n') || 1918215a2771SDaniel P. Berrange strchr(username, ':')) { 1919215a2771SDaniel P. Berrange error_setg(errp, "forbidden characters in username"); 1920215a2771SDaniel P. Berrange goto out; 1921215a2771SDaniel P. Berrange } 1922215a2771SDaniel P. Berrange 1923215a2771SDaniel P. Berrange chpasswddata = g_strdup_printf("%s:%s\n", username, rawpasswddata); 1924215a2771SDaniel P. Berrange chpasswdlen = strlen(chpasswddata); 1925215a2771SDaniel P. Berrange 1926215a2771SDaniel P. Berrange passwd_path = g_find_program_in_path("chpasswd"); 1927215a2771SDaniel P. Berrange 1928215a2771SDaniel P. Berrange if (!passwd_path) { 1929215a2771SDaniel P. Berrange error_setg(errp, "cannot find 'passwd' program in PATH"); 1930215a2771SDaniel P. Berrange goto out; 1931215a2771SDaniel P. Berrange } 1932215a2771SDaniel P. Berrange 1933215a2771SDaniel P. Berrange if (pipe(datafd) < 0) { 1934215a2771SDaniel P. Berrange error_setg(errp, "cannot create pipe FDs"); 1935215a2771SDaniel P. Berrange goto out; 1936215a2771SDaniel P. Berrange } 1937215a2771SDaniel P. Berrange 1938215a2771SDaniel P. Berrange pid = fork(); 1939215a2771SDaniel P. Berrange if (pid == 0) { 1940215a2771SDaniel P. Berrange close(datafd[1]); 1941215a2771SDaniel P. Berrange /* child */ 1942215a2771SDaniel P. Berrange setsid(); 1943215a2771SDaniel P. Berrange dup2(datafd[0], 0); 1944215a2771SDaniel P. Berrange reopen_fd_to_null(1); 1945215a2771SDaniel P. Berrange reopen_fd_to_null(2); 1946215a2771SDaniel P. Berrange 1947215a2771SDaniel P. Berrange if (crypted) { 1948215a2771SDaniel P. Berrange execle(passwd_path, "chpasswd", "-e", NULL, environ); 1949215a2771SDaniel P. Berrange } else { 1950215a2771SDaniel P. Berrange execle(passwd_path, "chpasswd", NULL, environ); 1951215a2771SDaniel P. Berrange } 1952215a2771SDaniel P. Berrange _exit(EXIT_FAILURE); 1953215a2771SDaniel P. Berrange } else if (pid < 0) { 1954215a2771SDaniel P. Berrange error_setg_errno(errp, errno, "failed to create child process"); 1955215a2771SDaniel P. Berrange goto out; 1956215a2771SDaniel P. Berrange } 1957215a2771SDaniel P. Berrange close(datafd[0]); 1958215a2771SDaniel P. Berrange datafd[0] = -1; 1959215a2771SDaniel P. Berrange 1960215a2771SDaniel P. Berrange if (qemu_write_full(datafd[1], chpasswddata, chpasswdlen) != chpasswdlen) { 1961215a2771SDaniel P. Berrange error_setg_errno(errp, errno, "cannot write new account password"); 1962215a2771SDaniel P. Berrange goto out; 1963215a2771SDaniel P. Berrange } 1964215a2771SDaniel P. Berrange close(datafd[1]); 1965215a2771SDaniel P. Berrange datafd[1] = -1; 1966215a2771SDaniel P. Berrange 1967215a2771SDaniel P. Berrange ga_wait_child(pid, &status, &local_err); 1968215a2771SDaniel P. Berrange if (local_err) { 1969215a2771SDaniel P. Berrange error_propagate(errp, local_err); 1970215a2771SDaniel P. Berrange goto out; 1971215a2771SDaniel P. Berrange } 1972215a2771SDaniel P. Berrange 1973215a2771SDaniel P. Berrange if (!WIFEXITED(status)) { 1974215a2771SDaniel P. Berrange error_setg(errp, "child process has terminated abnormally"); 1975215a2771SDaniel P. Berrange goto out; 1976215a2771SDaniel P. Berrange } 1977215a2771SDaniel P. Berrange 1978215a2771SDaniel P. Berrange if (WEXITSTATUS(status)) { 1979215a2771SDaniel P. Berrange error_setg(errp, "child process has failed to set user password"); 1980215a2771SDaniel P. Berrange goto out; 1981215a2771SDaniel P. Berrange } 1982215a2771SDaniel P. Berrange 1983215a2771SDaniel P. Berrange out: 1984215a2771SDaniel P. Berrange g_free(chpasswddata); 1985215a2771SDaniel P. Berrange g_free(rawpasswddata); 1986215a2771SDaniel P. Berrange g_free(passwd_path); 1987215a2771SDaniel P. Berrange if (datafd[0] != -1) { 1988215a2771SDaniel P. Berrange close(datafd[0]); 1989215a2771SDaniel P. Berrange } 1990215a2771SDaniel P. Berrange if (datafd[1] != -1) { 1991215a2771SDaniel P. Berrange close(datafd[1]); 1992215a2771SDaniel P. Berrange } 1993215a2771SDaniel P. Berrange } 1994215a2771SDaniel P. Berrange 1995*a065aaa9Szhanghailiang GuestMemoryBlockList *qmp_guest_get_memory_blocks(Error **errp) 1996*a065aaa9Szhanghailiang { 1997*a065aaa9Szhanghailiang error_set(errp, QERR_UNSUPPORTED); 1998*a065aaa9Szhanghailiang return NULL; 1999*a065aaa9Szhanghailiang } 2000*a065aaa9Szhanghailiang 2001*a065aaa9Szhanghailiang GuestMemoryBlockResponseList * 2002*a065aaa9Szhanghailiang qmp_guest_set_memory_blocks(GuestMemoryBlockList *mem_blks, Error **errp) 2003*a065aaa9Szhanghailiang { 2004*a065aaa9Szhanghailiang error_set(errp, QERR_UNSUPPORTED); 2005*a065aaa9Szhanghailiang return NULL; 2006*a065aaa9Szhanghailiang } 2007*a065aaa9Szhanghailiang 2008*a065aaa9Szhanghailiang GuestMemoryBlockInfo *qmp_guest_get_memory_block_info(Error **errp) 2009*a065aaa9Szhanghailiang { 2010*a065aaa9Szhanghailiang error_set(errp, QERR_UNSUPPORTED); 2011*a065aaa9Szhanghailiang return NULL; 2012*a065aaa9Szhanghailiang } 2013*a065aaa9Szhanghailiang 2014e72c3f2eSMichael Roth #else /* defined(__linux__) */ 2015e72c3f2eSMichael Roth 201677dbc81bSMarkus Armbruster void qmp_guest_suspend_disk(Error **errp) 2017e72c3f2eSMichael Roth { 201877dbc81bSMarkus Armbruster error_set(errp, QERR_UNSUPPORTED); 2019e72c3f2eSMichael Roth } 2020e72c3f2eSMichael Roth 202177dbc81bSMarkus Armbruster void qmp_guest_suspend_ram(Error **errp) 2022e72c3f2eSMichael Roth { 202377dbc81bSMarkus Armbruster error_set(errp, QERR_UNSUPPORTED); 2024e72c3f2eSMichael Roth } 2025e72c3f2eSMichael Roth 202677dbc81bSMarkus Armbruster void qmp_guest_suspend_hybrid(Error **errp) 2027e72c3f2eSMichael Roth { 202877dbc81bSMarkus Armbruster error_set(errp, QERR_UNSUPPORTED); 2029e72c3f2eSMichael Roth } 2030e72c3f2eSMichael Roth 2031e72c3f2eSMichael Roth GuestNetworkInterfaceList *qmp_guest_network_get_interfaces(Error **errp) 2032e72c3f2eSMichael Roth { 2033e72c3f2eSMichael Roth error_set(errp, QERR_UNSUPPORTED); 2034e72c3f2eSMichael Roth return NULL; 2035e72c3f2eSMichael Roth } 2036e72c3f2eSMichael Roth 2037d2baff62SLaszlo Ersek GuestLogicalProcessorList *qmp_guest_get_vcpus(Error **errp) 2038d2baff62SLaszlo Ersek { 2039d2baff62SLaszlo Ersek error_set(errp, QERR_UNSUPPORTED); 2040d2baff62SLaszlo Ersek return NULL; 2041d2baff62SLaszlo Ersek } 2042d2baff62SLaszlo Ersek 2043cbb65fc2SLaszlo Ersek int64_t qmp_guest_set_vcpus(GuestLogicalProcessorList *vcpus, Error **errp) 2044cbb65fc2SLaszlo Ersek { 2045cbb65fc2SLaszlo Ersek error_set(errp, QERR_UNSUPPORTED); 2046cbb65fc2SLaszlo Ersek return -1; 2047cbb65fc2SLaszlo Ersek } 2048cbb65fc2SLaszlo Ersek 2049215a2771SDaniel P. Berrange void qmp_guest_set_user_password(const char *username, 2050215a2771SDaniel P. Berrange const char *password, 2051215a2771SDaniel P. Berrange bool crypted, 2052215a2771SDaniel P. Berrange Error **errp) 2053215a2771SDaniel P. Berrange { 2054215a2771SDaniel P. Berrange error_set(errp, QERR_UNSUPPORTED); 2055215a2771SDaniel P. Berrange } 2056215a2771SDaniel P. Berrange 2057*a065aaa9Szhanghailiang GuestMemoryBlockList *qmp_guest_get_memory_blocks(Error **errp) 2058*a065aaa9Szhanghailiang { 2059*a065aaa9Szhanghailiang error_set(errp, QERR_UNSUPPORTED); 2060*a065aaa9Szhanghailiang return NULL; 2061*a065aaa9Szhanghailiang } 2062*a065aaa9Szhanghailiang 2063*a065aaa9Szhanghailiang GuestMemoryBlockResponseList * 2064*a065aaa9Szhanghailiang qmp_guest_set_memory_blocks(GuestMemoryBlockList *mem_blks, Error **errp) 2065*a065aaa9Szhanghailiang { 2066*a065aaa9Szhanghailiang error_set(errp, QERR_UNSUPPORTED); 2067*a065aaa9Szhanghailiang return NULL; 2068*a065aaa9Szhanghailiang } 2069*a065aaa9Szhanghailiang 2070*a065aaa9Szhanghailiang GuestMemoryBlockInfo *qmp_guest_get_memory_block_info(Error **errp) 2071*a065aaa9Szhanghailiang { 2072*a065aaa9Szhanghailiang error_set(errp, QERR_UNSUPPORTED); 2073*a065aaa9Szhanghailiang return NULL; 2074*a065aaa9Szhanghailiang } 2075*a065aaa9Szhanghailiang 2076e72c3f2eSMichael Roth #endif 2077e72c3f2eSMichael Roth 2078d35d4cb5SMichael Roth #if !defined(CONFIG_FSFREEZE) 2079d35d4cb5SMichael Roth 208046d4c572STomoki Sekiyama GuestFilesystemInfoList *qmp_guest_get_fsinfo(Error **errp) 208146d4c572STomoki Sekiyama { 208246d4c572STomoki Sekiyama error_set(errp, QERR_UNSUPPORTED); 208346d4c572STomoki Sekiyama return NULL; 208446d4c572STomoki Sekiyama } 208546d4c572STomoki Sekiyama 208677dbc81bSMarkus Armbruster GuestFsfreezeStatus qmp_guest_fsfreeze_status(Error **errp) 2087d35d4cb5SMichael Roth { 208877dbc81bSMarkus Armbruster error_set(errp, QERR_UNSUPPORTED); 2089d35d4cb5SMichael Roth 2090d35d4cb5SMichael Roth return 0; 2091d35d4cb5SMichael Roth } 2092d35d4cb5SMichael Roth 209377dbc81bSMarkus Armbruster int64_t qmp_guest_fsfreeze_freeze(Error **errp) 2094d35d4cb5SMichael Roth { 209577dbc81bSMarkus Armbruster error_set(errp, QERR_UNSUPPORTED); 2096d35d4cb5SMichael Roth 2097d35d4cb5SMichael Roth return 0; 2098d35d4cb5SMichael Roth } 2099d35d4cb5SMichael Roth 2100e99bce20STomoki Sekiyama int64_t qmp_guest_fsfreeze_freeze_list(bool has_mountpoints, 2101e99bce20STomoki Sekiyama strList *mountpoints, 2102e99bce20STomoki Sekiyama Error **errp) 2103e99bce20STomoki Sekiyama { 2104e99bce20STomoki Sekiyama error_set(errp, QERR_UNSUPPORTED); 2105e99bce20STomoki Sekiyama 2106e99bce20STomoki Sekiyama return 0; 2107e99bce20STomoki Sekiyama } 2108e99bce20STomoki Sekiyama 210977dbc81bSMarkus Armbruster int64_t qmp_guest_fsfreeze_thaw(Error **errp) 2110d35d4cb5SMichael Roth { 211177dbc81bSMarkus Armbruster error_set(errp, QERR_UNSUPPORTED); 2112d35d4cb5SMichael Roth 2113d35d4cb5SMichael Roth return 0; 2114d35d4cb5SMichael Roth } 2115eab5fd59SPaolo Bonzini #endif /* CONFIG_FSFREEZE */ 2116d35d4cb5SMichael Roth 2117eab5fd59SPaolo Bonzini #if !defined(CONFIG_FSTRIM) 211877dbc81bSMarkus Armbruster void qmp_guest_fstrim(bool has_minimum, int64_t minimum, Error **errp) 2119eab5fd59SPaolo Bonzini { 212077dbc81bSMarkus Armbruster error_set(errp, QERR_UNSUPPORTED); 2121eab5fd59SPaolo Bonzini } 2122d35d4cb5SMichael Roth #endif 2123d35d4cb5SMichael Roth 21241281c08aSTomoki Sekiyama /* add unsupported commands to the blacklist */ 21251281c08aSTomoki Sekiyama GList *ga_command_blacklist_init(GList *blacklist) 21261281c08aSTomoki Sekiyama { 21271281c08aSTomoki Sekiyama #if !defined(__linux__) 21281281c08aSTomoki Sekiyama { 21291281c08aSTomoki Sekiyama const char *list[] = { 21301281c08aSTomoki Sekiyama "guest-suspend-disk", "guest-suspend-ram", 21311281c08aSTomoki Sekiyama "guest-suspend-hybrid", "guest-network-get-interfaces", 21321281c08aSTomoki Sekiyama "guest-get-vcpus", "guest-set-vcpus", NULL}; 21331281c08aSTomoki Sekiyama char **p = (char **)list; 21341281c08aSTomoki Sekiyama 21351281c08aSTomoki Sekiyama while (*p) { 21361281c08aSTomoki Sekiyama blacklist = g_list_append(blacklist, *p++); 21371281c08aSTomoki Sekiyama } 21381281c08aSTomoki Sekiyama } 21391281c08aSTomoki Sekiyama #endif 21401281c08aSTomoki Sekiyama 21411281c08aSTomoki Sekiyama #if !defined(CONFIG_FSFREEZE) 21421281c08aSTomoki Sekiyama { 21431281c08aSTomoki Sekiyama const char *list[] = { 21441281c08aSTomoki Sekiyama "guest-get-fsinfo", "guest-fsfreeze-status", 21451281c08aSTomoki Sekiyama "guest-fsfreeze-freeze", "guest-fsfreeze-freeze-list", 21461281c08aSTomoki Sekiyama "guest-fsfreeze-thaw", "guest-get-fsinfo", NULL}; 21471281c08aSTomoki Sekiyama char **p = (char **)list; 21481281c08aSTomoki Sekiyama 21491281c08aSTomoki Sekiyama while (*p) { 21501281c08aSTomoki Sekiyama blacklist = g_list_append(blacklist, *p++); 21511281c08aSTomoki Sekiyama } 21521281c08aSTomoki Sekiyama } 21531281c08aSTomoki Sekiyama #endif 21541281c08aSTomoki Sekiyama 21551281c08aSTomoki Sekiyama #if !defined(CONFIG_FSTRIM) 21561281c08aSTomoki Sekiyama blacklist = g_list_append(blacklist, (char *)"guest-fstrim"); 21571281c08aSTomoki Sekiyama #endif 21581281c08aSTomoki Sekiyama 21591281c08aSTomoki Sekiyama return blacklist; 21601281c08aSTomoki Sekiyama } 21611281c08aSTomoki Sekiyama 2162c216e5adSMichael Roth /* register init/cleanup routines for stateful command groups */ 2163c216e5adSMichael Roth void ga_command_state_init(GAState *s, GACommandState *cs) 2164c216e5adSMichael Roth { 2165c216e5adSMichael Roth #if defined(CONFIG_FSFREEZE) 2166f22d85e9SMichael Roth ga_command_state_add(cs, NULL, guest_fsfreeze_cleanup); 2167c216e5adSMichael Roth #endif 2168c216e5adSMichael Roth ga_command_state_add(cs, guest_file_init, NULL); 2169c216e5adSMichael Roth } 2170