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> 21c689b4f1SLaszlo Ersek #include <stdio.h> 22c689b4f1SLaszlo Ersek #include <string.h> 23c689b4f1SLaszlo Ersek #include <sys/stat.h> 24d2baff62SLaszlo Ersek #include <inttypes.h> 25c216e5adSMichael Roth #include "qga/guest-agent-core.h" 26c216e5adSMichael Roth #include "qga-qmp-commands.h" 277b1b5d19SPaolo Bonzini #include "qapi/qmp/qerror.h" 281de7afc9SPaolo Bonzini #include "qemu/queue.h" 291de7afc9SPaolo Bonzini #include "qemu/host-utils.h" 30c216e5adSMichael Roth 312c02cbf6SLuiz Capitulino #ifndef CONFIG_HAS_ENVIRON 32eecae147SAndreas Färber #ifdef __APPLE__ 33eecae147SAndreas Färber #include <crt_externs.h> 34eecae147SAndreas Färber #define environ (*_NSGetEnviron()) 35eecae147SAndreas Färber #else 362c02cbf6SLuiz Capitulino extern char **environ; 372c02cbf6SLuiz Capitulino #endif 38eecae147SAndreas Färber #endif 392c02cbf6SLuiz Capitulino 40e72c3f2eSMichael Roth #if defined(__linux__) 41e72c3f2eSMichael Roth #include <mntent.h> 42e72c3f2eSMichael Roth #include <linux/fs.h> 43e72c3f2eSMichael Roth #include <ifaddrs.h> 44e72c3f2eSMichael Roth #include <arpa/inet.h> 45e72c3f2eSMichael Roth #include <sys/socket.h> 46e72c3f2eSMichael Roth #include <net/if.h> 47e72c3f2eSMichael Roth 48eab5fd59SPaolo Bonzini #ifdef FIFREEZE 49e72c3f2eSMichael Roth #define CONFIG_FSFREEZE 50e72c3f2eSMichael Roth #endif 51eab5fd59SPaolo Bonzini #ifdef FITRIM 52eab5fd59SPaolo Bonzini #define CONFIG_FSTRIM 53eab5fd59SPaolo Bonzini #endif 54e72c3f2eSMichael Roth #endif 55e72c3f2eSMichael Roth 56*77dbc81bSMarkus Armbruster static void ga_wait_child(pid_t pid, int *status, Error **errp) 57d220a6dfSLuiz Capitulino { 58d220a6dfSLuiz Capitulino pid_t rpid; 59d220a6dfSLuiz Capitulino 60d220a6dfSLuiz Capitulino *status = 0; 61d220a6dfSLuiz Capitulino 62d220a6dfSLuiz Capitulino do { 63d220a6dfSLuiz Capitulino rpid = waitpid(pid, status, 0); 64d220a6dfSLuiz Capitulino } while (rpid == -1 && errno == EINTR); 65d220a6dfSLuiz Capitulino 66d220a6dfSLuiz Capitulino if (rpid == -1) { 67*77dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to wait for child (pid: %d)", 68*77dbc81bSMarkus Armbruster pid); 69d220a6dfSLuiz Capitulino return; 70d220a6dfSLuiz Capitulino } 71d220a6dfSLuiz Capitulino 72d220a6dfSLuiz Capitulino g_assert(rpid == pid); 73d220a6dfSLuiz Capitulino } 74d220a6dfSLuiz Capitulino 75*77dbc81bSMarkus Armbruster void qmp_guest_shutdown(bool has_mode, const char *mode, Error **errp) 76c216e5adSMichael Roth { 77c216e5adSMichael Roth const char *shutdown_flag; 78d220a6dfSLuiz Capitulino Error *local_err = NULL; 79d220a6dfSLuiz Capitulino pid_t pid; 803674838cSLuiz Capitulino int status; 81c216e5adSMichael Roth 82c216e5adSMichael Roth slog("guest-shutdown called, mode: %s", mode); 83c216e5adSMichael Roth if (!has_mode || strcmp(mode, "powerdown") == 0) { 84c216e5adSMichael Roth shutdown_flag = "-P"; 85c216e5adSMichael Roth } else if (strcmp(mode, "halt") == 0) { 86c216e5adSMichael Roth shutdown_flag = "-H"; 87c216e5adSMichael Roth } else if (strcmp(mode, "reboot") == 0) { 88c216e5adSMichael Roth shutdown_flag = "-r"; 89c216e5adSMichael Roth } else { 90*77dbc81bSMarkus Armbruster error_setg(errp, 91d220a6dfSLuiz Capitulino "mode is invalid (valid values are: halt|powerdown|reboot"); 92c216e5adSMichael Roth return; 93c216e5adSMichael Roth } 94c216e5adSMichael Roth 95d5dd3498SLuiz Capitulino pid = fork(); 96d5dd3498SLuiz Capitulino if (pid == 0) { 97c216e5adSMichael Roth /* child, start the shutdown */ 98c216e5adSMichael Roth setsid(); 993674838cSLuiz Capitulino reopen_fd_to_null(0); 1003674838cSLuiz Capitulino reopen_fd_to_null(1); 1013674838cSLuiz Capitulino reopen_fd_to_null(2); 102c216e5adSMichael Roth 103485e741cSwhitearchey execle("/sbin/shutdown", "shutdown", "-h", shutdown_flag, "+0", 1043674838cSLuiz Capitulino "hypervisor initiated shutdown", (char*)NULL, environ); 1053674838cSLuiz Capitulino _exit(EXIT_FAILURE); 106d5dd3498SLuiz Capitulino } else if (pid < 0) { 107*77dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to create child process"); 108d5dd3498SLuiz Capitulino return; 109d5dd3498SLuiz Capitulino } 110d5dd3498SLuiz Capitulino 111d220a6dfSLuiz Capitulino ga_wait_child(pid, &status, &local_err); 11284d18f06SMarkus Armbruster if (local_err) { 113*77dbc81bSMarkus Armbruster error_propagate(errp, local_err); 114d220a6dfSLuiz Capitulino return; 115d220a6dfSLuiz Capitulino } 116d220a6dfSLuiz Capitulino 117d220a6dfSLuiz Capitulino if (!WIFEXITED(status)) { 118*77dbc81bSMarkus Armbruster error_setg(errp, "child process has terminated abnormally"); 119d220a6dfSLuiz Capitulino return; 120d220a6dfSLuiz Capitulino } 121d220a6dfSLuiz Capitulino 122d220a6dfSLuiz Capitulino if (WEXITSTATUS(status)) { 123*77dbc81bSMarkus Armbruster error_setg(errp, "child process has failed to shutdown"); 124d220a6dfSLuiz Capitulino return; 125d220a6dfSLuiz Capitulino } 126d220a6dfSLuiz Capitulino 127085d8134SPeter Maydell /* succeeded */ 128c216e5adSMichael Roth } 129c216e5adSMichael Roth 1306912e6a9SLei Li int64_t qmp_guest_get_time(Error **errp) 1316912e6a9SLei Li { 1326912e6a9SLei Li int ret; 1336912e6a9SLei Li qemu_timeval tq; 1346912e6a9SLei Li int64_t time_ns; 1356912e6a9SLei Li 1366912e6a9SLei Li ret = qemu_gettimeofday(&tq); 1376912e6a9SLei Li if (ret < 0) { 1386912e6a9SLei Li error_setg_errno(errp, errno, "Failed to get time"); 1396912e6a9SLei Li return -1; 1406912e6a9SLei Li } 1416912e6a9SLei Li 1426912e6a9SLei Li time_ns = tq.tv_sec * 1000000000LL + tq.tv_usec * 1000; 1436912e6a9SLei Li return time_ns; 1446912e6a9SLei Li } 1456912e6a9SLei Li 1462c958923SMichal Privoznik void qmp_guest_set_time(bool has_time, int64_t time_ns, Error **errp) 147a1bca57fSLei Li { 148a1bca57fSLei Li int ret; 149a1bca57fSLei Li int status; 150a1bca57fSLei Li pid_t pid; 151a1bca57fSLei Li Error *local_err = NULL; 152a1bca57fSLei Li struct timeval tv; 153a1bca57fSLei Li 1542c958923SMichal Privoznik /* If user has passed a time, validate and set it. */ 1552c958923SMichal Privoznik if (has_time) { 156a1bca57fSLei Li /* year-2038 will overflow in case time_t is 32bit */ 157a1bca57fSLei Li if (time_ns / 1000000000 != (time_t)(time_ns / 1000000000)) { 158a1bca57fSLei Li error_setg(errp, "Time %" PRId64 " is too large", time_ns); 159a1bca57fSLei Li return; 160a1bca57fSLei Li } 161a1bca57fSLei Li 162a1bca57fSLei Li tv.tv_sec = time_ns / 1000000000; 163a1bca57fSLei Li tv.tv_usec = (time_ns % 1000000000) / 1000; 164a1bca57fSLei Li 165a1bca57fSLei Li ret = settimeofday(&tv, NULL); 166a1bca57fSLei Li if (ret < 0) { 167a1bca57fSLei Li error_setg_errno(errp, errno, "Failed to set time to guest"); 168a1bca57fSLei Li return; 169a1bca57fSLei Li } 1702c958923SMichal Privoznik } 171a1bca57fSLei Li 1722c958923SMichal Privoznik /* Now, if user has passed a time to set and the system time is set, we 1732c958923SMichal Privoznik * just need to synchronize the hardware clock. However, if no time was 1742c958923SMichal Privoznik * passed, user is requesting the opposite: set the system time from the 1751634df56SAmos Kong * hardware clock (RTC). */ 176a1bca57fSLei Li pid = fork(); 177a1bca57fSLei Li if (pid == 0) { 178a1bca57fSLei Li setsid(); 179a1bca57fSLei Li reopen_fd_to_null(0); 180a1bca57fSLei Li reopen_fd_to_null(1); 181a1bca57fSLei Li reopen_fd_to_null(2); 182a1bca57fSLei Li 1832c958923SMichal Privoznik /* Use '/sbin/hwclock -w' to set RTC from the system time, 1842c958923SMichal Privoznik * or '/sbin/hwclock -s' to set the system time from RTC. */ 1852c958923SMichal Privoznik execle("/sbin/hwclock", "hwclock", has_time ? "-w" : "-s", 1862c958923SMichal Privoznik NULL, environ); 187a1bca57fSLei Li _exit(EXIT_FAILURE); 188a1bca57fSLei Li } else if (pid < 0) { 189a1bca57fSLei Li error_setg_errno(errp, errno, "failed to create child process"); 190a1bca57fSLei Li return; 191a1bca57fSLei Li } 192a1bca57fSLei Li 193a1bca57fSLei Li ga_wait_child(pid, &status, &local_err); 19484d18f06SMarkus Armbruster if (local_err) { 195a1bca57fSLei Li error_propagate(errp, local_err); 196a1bca57fSLei Li return; 197a1bca57fSLei Li } 198a1bca57fSLei Li 199a1bca57fSLei Li if (!WIFEXITED(status)) { 200a1bca57fSLei Li error_setg(errp, "child process has terminated abnormally"); 201a1bca57fSLei Li return; 202a1bca57fSLei Li } 203a1bca57fSLei Li 204a1bca57fSLei Li if (WEXITSTATUS(status)) { 205a1bca57fSLei Li error_setg(errp, "hwclock failed to set hardware clock to system time"); 206a1bca57fSLei Li return; 207a1bca57fSLei Li } 208a1bca57fSLei Li } 209a1bca57fSLei Li 210c216e5adSMichael Roth typedef struct GuestFileHandle { 211c216e5adSMichael Roth uint64_t id; 212c216e5adSMichael Roth FILE *fh; 213c216e5adSMichael Roth QTAILQ_ENTRY(GuestFileHandle) next; 214c216e5adSMichael Roth } GuestFileHandle; 215c216e5adSMichael Roth 216c216e5adSMichael Roth static struct { 217c216e5adSMichael Roth QTAILQ_HEAD(, GuestFileHandle) filehandles; 218c216e5adSMichael Roth } guest_file_state; 219c216e5adSMichael Roth 22039097dafSMichael Roth static int64_t guest_file_handle_add(FILE *fh, Error **errp) 221c216e5adSMichael Roth { 222c216e5adSMichael Roth GuestFileHandle *gfh; 22339097dafSMichael Roth int64_t handle; 22439097dafSMichael Roth 22539097dafSMichael Roth handle = ga_get_fd_handle(ga_state, errp); 22639097dafSMichael Roth if (error_is_set(errp)) { 22739097dafSMichael Roth return 0; 22839097dafSMichael Roth } 229c216e5adSMichael Roth 230c216e5adSMichael Roth gfh = g_malloc0(sizeof(GuestFileHandle)); 23139097dafSMichael Roth gfh->id = handle; 232c216e5adSMichael Roth gfh->fh = fh; 233c216e5adSMichael Roth QTAILQ_INSERT_TAIL(&guest_file_state.filehandles, gfh, next); 23439097dafSMichael Roth 23539097dafSMichael Roth return handle; 236c216e5adSMichael Roth } 237c216e5adSMichael Roth 238*77dbc81bSMarkus Armbruster static GuestFileHandle *guest_file_handle_find(int64_t id, Error **errp) 239c216e5adSMichael Roth { 240c216e5adSMichael Roth GuestFileHandle *gfh; 241c216e5adSMichael Roth 242c216e5adSMichael Roth QTAILQ_FOREACH(gfh, &guest_file_state.filehandles, next) 243c216e5adSMichael Roth { 244c216e5adSMichael Roth if (gfh->id == id) { 245c216e5adSMichael Roth return gfh; 246c216e5adSMichael Roth } 247c216e5adSMichael Roth } 248c216e5adSMichael Roth 249*77dbc81bSMarkus Armbruster error_setg(errp, "handle '%" PRId64 "' has not been found", id); 250c216e5adSMichael Roth return NULL; 251c216e5adSMichael Roth } 252c216e5adSMichael Roth 253c689b4f1SLaszlo Ersek typedef const char * const ccpc; 254c689b4f1SLaszlo Ersek 2558fe6bbcaSLaszlo Ersek #ifndef O_BINARY 2568fe6bbcaSLaszlo Ersek #define O_BINARY 0 2578fe6bbcaSLaszlo Ersek #endif 2588fe6bbcaSLaszlo Ersek 259c689b4f1SLaszlo Ersek /* http://pubs.opengroup.org/onlinepubs/9699919799/functions/fopen.html */ 260c689b4f1SLaszlo Ersek static const struct { 261c689b4f1SLaszlo Ersek ccpc *forms; 262c689b4f1SLaszlo Ersek int oflag_base; 263c689b4f1SLaszlo Ersek } guest_file_open_modes[] = { 2648fe6bbcaSLaszlo Ersek { (ccpc[]){ "r", NULL }, O_RDONLY }, 2658fe6bbcaSLaszlo Ersek { (ccpc[]){ "rb", NULL }, O_RDONLY | O_BINARY }, 2668fe6bbcaSLaszlo Ersek { (ccpc[]){ "w", NULL }, O_WRONLY | O_CREAT | O_TRUNC }, 2678fe6bbcaSLaszlo Ersek { (ccpc[]){ "wb", NULL }, O_WRONLY | O_CREAT | O_TRUNC | O_BINARY }, 2688fe6bbcaSLaszlo Ersek { (ccpc[]){ "a", NULL }, O_WRONLY | O_CREAT | O_APPEND }, 2698fe6bbcaSLaszlo Ersek { (ccpc[]){ "ab", NULL }, O_WRONLY | O_CREAT | O_APPEND | O_BINARY }, 2708fe6bbcaSLaszlo Ersek { (ccpc[]){ "r+", NULL }, O_RDWR }, 2718fe6bbcaSLaszlo Ersek { (ccpc[]){ "rb+", "r+b", NULL }, O_RDWR | O_BINARY }, 2728fe6bbcaSLaszlo Ersek { (ccpc[]){ "w+", NULL }, O_RDWR | O_CREAT | O_TRUNC }, 2738fe6bbcaSLaszlo Ersek { (ccpc[]){ "wb+", "w+b", NULL }, O_RDWR | O_CREAT | O_TRUNC | O_BINARY }, 2748fe6bbcaSLaszlo Ersek { (ccpc[]){ "a+", NULL }, O_RDWR | O_CREAT | O_APPEND }, 2758fe6bbcaSLaszlo Ersek { (ccpc[]){ "ab+", "a+b", NULL }, O_RDWR | O_CREAT | O_APPEND | O_BINARY } 276c689b4f1SLaszlo Ersek }; 277c689b4f1SLaszlo Ersek 278c689b4f1SLaszlo Ersek static int 279*77dbc81bSMarkus Armbruster find_open_flag(const char *mode_str, Error **errp) 280c689b4f1SLaszlo Ersek { 281c689b4f1SLaszlo Ersek unsigned mode; 282c689b4f1SLaszlo Ersek 283c689b4f1SLaszlo Ersek for (mode = 0; mode < ARRAY_SIZE(guest_file_open_modes); ++mode) { 284c689b4f1SLaszlo Ersek ccpc *form; 285c689b4f1SLaszlo Ersek 286c689b4f1SLaszlo Ersek form = guest_file_open_modes[mode].forms; 287c689b4f1SLaszlo Ersek while (*form != NULL && strcmp(*form, mode_str) != 0) { 288c689b4f1SLaszlo Ersek ++form; 289c689b4f1SLaszlo Ersek } 290c689b4f1SLaszlo Ersek if (*form != NULL) { 291c689b4f1SLaszlo Ersek break; 292c689b4f1SLaszlo Ersek } 293c689b4f1SLaszlo Ersek } 294c689b4f1SLaszlo Ersek 295c689b4f1SLaszlo Ersek if (mode == ARRAY_SIZE(guest_file_open_modes)) { 296*77dbc81bSMarkus Armbruster error_setg(errp, "invalid file open mode '%s'", mode_str); 297c689b4f1SLaszlo Ersek return -1; 298c689b4f1SLaszlo Ersek } 299c689b4f1SLaszlo Ersek return guest_file_open_modes[mode].oflag_base | O_NOCTTY | O_NONBLOCK; 300c689b4f1SLaszlo Ersek } 301c689b4f1SLaszlo Ersek 302c689b4f1SLaszlo Ersek #define DEFAULT_NEW_FILE_MODE (S_IRUSR | S_IWUSR | \ 303c689b4f1SLaszlo Ersek S_IRGRP | S_IWGRP | \ 304c689b4f1SLaszlo Ersek S_IROTH | S_IWOTH) 305c689b4f1SLaszlo Ersek 306c689b4f1SLaszlo Ersek static FILE * 307*77dbc81bSMarkus Armbruster safe_open_or_create(const char *path, const char *mode, Error **errp) 308c689b4f1SLaszlo Ersek { 309c689b4f1SLaszlo Ersek Error *local_err = NULL; 310c689b4f1SLaszlo Ersek int oflag; 311c689b4f1SLaszlo Ersek 312c689b4f1SLaszlo Ersek oflag = find_open_flag(mode, &local_err); 313c689b4f1SLaszlo Ersek if (local_err == NULL) { 314c689b4f1SLaszlo Ersek int fd; 315c689b4f1SLaszlo Ersek 316c689b4f1SLaszlo Ersek /* If the caller wants / allows creation of a new file, we implement it 317c689b4f1SLaszlo Ersek * with a two step process: open() + (open() / fchmod()). 318c689b4f1SLaszlo Ersek * 319c689b4f1SLaszlo Ersek * First we insist on creating the file exclusively as a new file. If 320c689b4f1SLaszlo Ersek * that succeeds, we're free to set any file-mode bits on it. (The 321c689b4f1SLaszlo Ersek * motivation is that we want to set those file-mode bits independently 322c689b4f1SLaszlo Ersek * of the current umask.) 323c689b4f1SLaszlo Ersek * 324c689b4f1SLaszlo Ersek * If the exclusive creation fails because the file already exists 325c689b4f1SLaszlo Ersek * (EEXIST is not possible for any other reason), we just attempt to 326c689b4f1SLaszlo Ersek * open the file, but in this case we won't be allowed to change the 327c689b4f1SLaszlo Ersek * file-mode bits on the preexistent file. 328c689b4f1SLaszlo Ersek * 329c689b4f1SLaszlo Ersek * The pathname should never disappear between the two open()s in 330c689b4f1SLaszlo Ersek * practice. If it happens, then someone very likely tried to race us. 331c689b4f1SLaszlo Ersek * In this case just go ahead and report the ENOENT from the second 332c689b4f1SLaszlo Ersek * open() to the caller. 333c689b4f1SLaszlo Ersek * 334c689b4f1SLaszlo Ersek * If the caller wants to open a preexistent file, then the first 335c689b4f1SLaszlo Ersek * open() is decisive and its third argument is ignored, and the second 336c689b4f1SLaszlo Ersek * open() and the fchmod() are never called. 337c689b4f1SLaszlo Ersek */ 338c689b4f1SLaszlo Ersek fd = open(path, oflag | ((oflag & O_CREAT) ? O_EXCL : 0), 0); 339c689b4f1SLaszlo Ersek if (fd == -1 && errno == EEXIST) { 340c689b4f1SLaszlo Ersek oflag &= ~(unsigned)O_CREAT; 341c689b4f1SLaszlo Ersek fd = open(path, oflag); 342c689b4f1SLaszlo Ersek } 343c689b4f1SLaszlo Ersek 344c689b4f1SLaszlo Ersek if (fd == -1) { 345c689b4f1SLaszlo Ersek error_setg_errno(&local_err, errno, "failed to open file '%s' " 346c689b4f1SLaszlo Ersek "(mode: '%s')", path, mode); 347c689b4f1SLaszlo Ersek } else { 348c689b4f1SLaszlo Ersek qemu_set_cloexec(fd); 349c689b4f1SLaszlo Ersek 350c689b4f1SLaszlo Ersek if ((oflag & O_CREAT) && fchmod(fd, DEFAULT_NEW_FILE_MODE) == -1) { 351c689b4f1SLaszlo Ersek error_setg_errno(&local_err, errno, "failed to set permission " 352c689b4f1SLaszlo Ersek "0%03o on new file '%s' (mode: '%s')", 353c689b4f1SLaszlo Ersek (unsigned)DEFAULT_NEW_FILE_MODE, path, mode); 354c689b4f1SLaszlo Ersek } else { 355c689b4f1SLaszlo Ersek FILE *f; 356c689b4f1SLaszlo Ersek 357c689b4f1SLaszlo Ersek f = fdopen(fd, mode); 358c689b4f1SLaszlo Ersek if (f == NULL) { 359c689b4f1SLaszlo Ersek error_setg_errno(&local_err, errno, "failed to associate " 360c689b4f1SLaszlo Ersek "stdio stream with file descriptor %d, " 361c689b4f1SLaszlo Ersek "file '%s' (mode: '%s')", fd, path, mode); 362c689b4f1SLaszlo Ersek } else { 363c689b4f1SLaszlo Ersek return f; 364c689b4f1SLaszlo Ersek } 365c689b4f1SLaszlo Ersek } 366c689b4f1SLaszlo Ersek 367c689b4f1SLaszlo Ersek close(fd); 3682b720018SLaszlo Ersek if (oflag & O_CREAT) { 3692b720018SLaszlo Ersek unlink(path); 3702b720018SLaszlo Ersek } 371c689b4f1SLaszlo Ersek } 372c689b4f1SLaszlo Ersek } 373c689b4f1SLaszlo Ersek 374*77dbc81bSMarkus Armbruster error_propagate(errp, local_err); 375c689b4f1SLaszlo Ersek return NULL; 376c689b4f1SLaszlo Ersek } 377c689b4f1SLaszlo Ersek 378*77dbc81bSMarkus Armbruster int64_t qmp_guest_file_open(const char *path, bool has_mode, const char *mode, 379*77dbc81bSMarkus Armbruster Error **errp) 380c216e5adSMichael Roth { 381c216e5adSMichael Roth FILE *fh; 382c689b4f1SLaszlo Ersek Error *local_err = NULL; 383c216e5adSMichael Roth int fd; 38439097dafSMichael Roth int64_t ret = -1, handle; 385c216e5adSMichael Roth 386c216e5adSMichael Roth if (!has_mode) { 387c216e5adSMichael Roth mode = "r"; 388c216e5adSMichael Roth } 389c216e5adSMichael Roth slog("guest-file-open called, filepath: %s, mode: %s", path, mode); 390c689b4f1SLaszlo Ersek fh = safe_open_or_create(path, mode, &local_err); 391c689b4f1SLaszlo Ersek if (local_err != NULL) { 392*77dbc81bSMarkus Armbruster error_propagate(errp, local_err); 393c216e5adSMichael Roth return -1; 394c216e5adSMichael Roth } 395c216e5adSMichael Roth 396c216e5adSMichael Roth /* set fd non-blocking to avoid common use cases (like reading from a 397c216e5adSMichael Roth * named pipe) from hanging the agent 398c216e5adSMichael Roth */ 399c216e5adSMichael Roth fd = fileno(fh); 400c216e5adSMichael Roth ret = fcntl(fd, F_GETFL); 401c216e5adSMichael Roth ret = fcntl(fd, F_SETFL, ret | O_NONBLOCK); 402c216e5adSMichael Roth if (ret == -1) { 403*77dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to make file '%s' non-blocking", 404db3edb66SLuiz Capitulino path); 405c216e5adSMichael Roth fclose(fh); 406c216e5adSMichael Roth return -1; 407c216e5adSMichael Roth } 408c216e5adSMichael Roth 409*77dbc81bSMarkus Armbruster handle = guest_file_handle_add(fh, errp); 410*77dbc81bSMarkus Armbruster if (error_is_set(errp)) { 41139097dafSMichael Roth fclose(fh); 41239097dafSMichael Roth return -1; 41339097dafSMichael Roth } 41439097dafSMichael Roth 415d607a523SStefan Weil slog("guest-file-open, handle: %" PRId64, handle); 41639097dafSMichael Roth return handle; 417c216e5adSMichael Roth } 418c216e5adSMichael Roth 419*77dbc81bSMarkus Armbruster void qmp_guest_file_close(int64_t handle, Error **errp) 420c216e5adSMichael Roth { 421*77dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 422c216e5adSMichael Roth int ret; 423c216e5adSMichael Roth 424d607a523SStefan Weil slog("guest-file-close called, handle: %" PRId64, handle); 425c216e5adSMichael Roth if (!gfh) { 426c216e5adSMichael Roth return; 427c216e5adSMichael Roth } 428c216e5adSMichael Roth 429c216e5adSMichael Roth ret = fclose(gfh->fh); 4303ac4b7c5SLuiz Capitulino if (ret == EOF) { 431*77dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to close handle"); 432c216e5adSMichael Roth return; 433c216e5adSMichael Roth } 434c216e5adSMichael Roth 435c216e5adSMichael Roth QTAILQ_REMOVE(&guest_file_state.filehandles, gfh, next); 436c216e5adSMichael Roth g_free(gfh); 437c216e5adSMichael Roth } 438c216e5adSMichael Roth 439c216e5adSMichael Roth struct GuestFileRead *qmp_guest_file_read(int64_t handle, bool has_count, 440*77dbc81bSMarkus Armbruster int64_t count, Error **errp) 441c216e5adSMichael Roth { 442*77dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 443c216e5adSMichael Roth GuestFileRead *read_data = NULL; 444c216e5adSMichael Roth guchar *buf; 445c216e5adSMichael Roth FILE *fh; 446c216e5adSMichael Roth size_t read_count; 447c216e5adSMichael Roth 448c216e5adSMichael Roth if (!gfh) { 449c216e5adSMichael Roth return NULL; 450c216e5adSMichael Roth } 451c216e5adSMichael Roth 452c216e5adSMichael Roth if (!has_count) { 453c216e5adSMichael Roth count = QGA_READ_COUNT_DEFAULT; 454c216e5adSMichael Roth } else if (count < 0) { 455*77dbc81bSMarkus Armbruster error_setg(errp, "value '%" PRId64 "' is invalid for argument count", 456db3edb66SLuiz Capitulino count); 457c216e5adSMichael Roth return NULL; 458c216e5adSMichael Roth } 459c216e5adSMichael Roth 460c216e5adSMichael Roth fh = gfh->fh; 461c216e5adSMichael Roth buf = g_malloc0(count+1); 462c216e5adSMichael Roth read_count = fread(buf, 1, count, fh); 463c216e5adSMichael Roth if (ferror(fh)) { 464*77dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to read file"); 465d607a523SStefan Weil slog("guest-file-read failed, handle: %" PRId64, handle); 466c216e5adSMichael Roth } else { 467c216e5adSMichael Roth buf[read_count] = 0; 468c216e5adSMichael Roth read_data = g_malloc0(sizeof(GuestFileRead)); 469c216e5adSMichael Roth read_data->count = read_count; 470c216e5adSMichael Roth read_data->eof = feof(fh); 471c216e5adSMichael Roth if (read_count) { 472c216e5adSMichael Roth read_data->buf_b64 = g_base64_encode(buf, read_count); 473c216e5adSMichael Roth } 474c216e5adSMichael Roth } 475c216e5adSMichael Roth g_free(buf); 476c216e5adSMichael Roth clearerr(fh); 477c216e5adSMichael Roth 478c216e5adSMichael Roth return read_data; 479c216e5adSMichael Roth } 480c216e5adSMichael Roth 481c216e5adSMichael Roth GuestFileWrite *qmp_guest_file_write(int64_t handle, const char *buf_b64, 482*77dbc81bSMarkus Armbruster bool has_count, int64_t count, 483*77dbc81bSMarkus Armbruster Error **errp) 484c216e5adSMichael Roth { 485c216e5adSMichael Roth GuestFileWrite *write_data = NULL; 486c216e5adSMichael Roth guchar *buf; 487c216e5adSMichael Roth gsize buf_len; 488c216e5adSMichael Roth int write_count; 489*77dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 490c216e5adSMichael Roth FILE *fh; 491c216e5adSMichael Roth 492c216e5adSMichael Roth if (!gfh) { 493c216e5adSMichael Roth return NULL; 494c216e5adSMichael Roth } 495c216e5adSMichael Roth 496c216e5adSMichael Roth fh = gfh->fh; 497c216e5adSMichael Roth buf = g_base64_decode(buf_b64, &buf_len); 498c216e5adSMichael Roth 499c216e5adSMichael Roth if (!has_count) { 500c216e5adSMichael Roth count = buf_len; 501c216e5adSMichael Roth } else if (count < 0 || count > buf_len) { 502*77dbc81bSMarkus Armbruster error_setg(errp, "value '%" PRId64 "' is invalid for argument count", 503db3edb66SLuiz Capitulino count); 504c216e5adSMichael Roth g_free(buf); 505c216e5adSMichael Roth return NULL; 506c216e5adSMichael Roth } 507c216e5adSMichael Roth 508c216e5adSMichael Roth write_count = fwrite(buf, 1, count, fh); 509c216e5adSMichael Roth if (ferror(fh)) { 510*77dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to write to file"); 511d607a523SStefan Weil slog("guest-file-write failed, handle: %" PRId64, handle); 512c216e5adSMichael Roth } else { 513c216e5adSMichael Roth write_data = g_malloc0(sizeof(GuestFileWrite)); 514c216e5adSMichael Roth write_data->count = write_count; 515c216e5adSMichael Roth write_data->eof = feof(fh); 516c216e5adSMichael Roth } 517c216e5adSMichael Roth g_free(buf); 518c216e5adSMichael Roth clearerr(fh); 519c216e5adSMichael Roth 520c216e5adSMichael Roth return write_data; 521c216e5adSMichael Roth } 522c216e5adSMichael Roth 523c216e5adSMichael Roth struct GuestFileSeek *qmp_guest_file_seek(int64_t handle, int64_t offset, 524*77dbc81bSMarkus Armbruster int64_t whence, Error **errp) 525c216e5adSMichael Roth { 526*77dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 527c216e5adSMichael Roth GuestFileSeek *seek_data = NULL; 528c216e5adSMichael Roth FILE *fh; 529c216e5adSMichael Roth int ret; 530c216e5adSMichael Roth 531c216e5adSMichael Roth if (!gfh) { 532c216e5adSMichael Roth return NULL; 533c216e5adSMichael Roth } 534c216e5adSMichael Roth 535c216e5adSMichael Roth fh = gfh->fh; 536c216e5adSMichael Roth ret = fseek(fh, offset, whence); 537c216e5adSMichael Roth if (ret == -1) { 538*77dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to seek file"); 539c216e5adSMichael Roth } else { 54010b7c5ddSMarkus Armbruster seek_data = g_new0(GuestFileSeek, 1); 541c216e5adSMichael Roth seek_data->position = ftell(fh); 542c216e5adSMichael Roth seek_data->eof = feof(fh); 543c216e5adSMichael Roth } 544c216e5adSMichael Roth clearerr(fh); 545c216e5adSMichael Roth 546c216e5adSMichael Roth return seek_data; 547c216e5adSMichael Roth } 548c216e5adSMichael Roth 549*77dbc81bSMarkus Armbruster void qmp_guest_file_flush(int64_t handle, Error **errp) 550c216e5adSMichael Roth { 551*77dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 552c216e5adSMichael Roth FILE *fh; 553c216e5adSMichael Roth int ret; 554c216e5adSMichael Roth 555c216e5adSMichael Roth if (!gfh) { 556c216e5adSMichael Roth return; 557c216e5adSMichael Roth } 558c216e5adSMichael Roth 559c216e5adSMichael Roth fh = gfh->fh; 560c216e5adSMichael Roth ret = fflush(fh); 561c216e5adSMichael Roth if (ret == EOF) { 562*77dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to flush file"); 563c216e5adSMichael Roth } 564c216e5adSMichael Roth } 565c216e5adSMichael Roth 566c216e5adSMichael Roth static void guest_file_init(void) 567c216e5adSMichael Roth { 568c216e5adSMichael Roth QTAILQ_INIT(&guest_file_state.filehandles); 569c216e5adSMichael Roth } 570c216e5adSMichael Roth 571e72c3f2eSMichael Roth /* linux-specific implementations. avoid this if at all possible. */ 572e72c3f2eSMichael Roth #if defined(__linux__) 573e72c3f2eSMichael Roth 574eab5fd59SPaolo Bonzini #if defined(CONFIG_FSFREEZE) || defined(CONFIG_FSTRIM) 575af02203fSPaolo Bonzini typedef struct FsMount { 576c216e5adSMichael Roth char *dirname; 577c216e5adSMichael Roth char *devtype; 578af02203fSPaolo Bonzini QTAILQ_ENTRY(FsMount) next; 579af02203fSPaolo Bonzini } FsMount; 580c216e5adSMichael Roth 581e5d9adbdSTomoki Sekiyama typedef QTAILQ_HEAD(FsMountList, FsMount) FsMountList; 5829e8aded4SMichael Roth 583af02203fSPaolo Bonzini static void free_fs_mount_list(FsMountList *mounts) 584c216e5adSMichael Roth { 585af02203fSPaolo Bonzini FsMount *mount, *temp; 586c216e5adSMichael Roth 5879e8aded4SMichael Roth if (!mounts) { 5889e8aded4SMichael Roth return; 5899e8aded4SMichael Roth } 5909e8aded4SMichael Roth 5919e8aded4SMichael Roth QTAILQ_FOREACH_SAFE(mount, mounts, next, temp) { 5929e8aded4SMichael Roth QTAILQ_REMOVE(mounts, mount, next); 593c216e5adSMichael Roth g_free(mount->dirname); 594c216e5adSMichael Roth g_free(mount->devtype); 595c216e5adSMichael Roth g_free(mount); 596c216e5adSMichael Roth } 5979e8aded4SMichael Roth } 5989e8aded4SMichael Roth 5999e8aded4SMichael Roth /* 6009e8aded4SMichael Roth * Walk the mount table and build a list of local file systems 6019e8aded4SMichael Roth */ 602*77dbc81bSMarkus Armbruster static void build_fs_mount_list(FsMountList *mounts, Error **errp) 6039e8aded4SMichael Roth { 6049e8aded4SMichael Roth struct mntent *ment; 605af02203fSPaolo Bonzini FsMount *mount; 6069e2fa418SMichael Roth char const *mtab = "/proc/self/mounts"; 6079e8aded4SMichael Roth FILE *fp; 608c216e5adSMichael Roth 609c216e5adSMichael Roth fp = setmntent(mtab, "r"); 610c216e5adSMichael Roth if (!fp) { 611*77dbc81bSMarkus Armbruster error_setg(errp, "failed to open mtab file: '%s'", mtab); 612261551d1SLuiz Capitulino return; 613c216e5adSMichael Roth } 614c216e5adSMichael Roth 615c216e5adSMichael Roth while ((ment = getmntent(fp))) { 616c216e5adSMichael Roth /* 617c216e5adSMichael Roth * An entry which device name doesn't start with a '/' is 618c216e5adSMichael Roth * either a dummy file system or a network file system. 619c216e5adSMichael Roth * Add special handling for smbfs and cifs as is done by 620c216e5adSMichael Roth * coreutils as well. 621c216e5adSMichael Roth */ 622c216e5adSMichael Roth if ((ment->mnt_fsname[0] != '/') || 623c216e5adSMichael Roth (strcmp(ment->mnt_type, "smbfs") == 0) || 624c216e5adSMichael Roth (strcmp(ment->mnt_type, "cifs") == 0)) { 625c216e5adSMichael Roth continue; 626c216e5adSMichael Roth } 627c216e5adSMichael Roth 628af02203fSPaolo Bonzini mount = g_malloc0(sizeof(FsMount)); 629c216e5adSMichael Roth mount->dirname = g_strdup(ment->mnt_dir); 630c216e5adSMichael Roth mount->devtype = g_strdup(ment->mnt_type); 631c216e5adSMichael Roth 6329e8aded4SMichael Roth QTAILQ_INSERT_TAIL(mounts, mount, next); 633c216e5adSMichael Roth } 634c216e5adSMichael Roth 635c216e5adSMichael Roth endmntent(fp); 636c216e5adSMichael Roth } 637eab5fd59SPaolo Bonzini #endif 638eab5fd59SPaolo Bonzini 639eab5fd59SPaolo Bonzini #if defined(CONFIG_FSFREEZE) 640c216e5adSMichael Roth 641ec0f694cSTomoki Sekiyama typedef enum { 642ec0f694cSTomoki Sekiyama FSFREEZE_HOOK_THAW = 0, 643ec0f694cSTomoki Sekiyama FSFREEZE_HOOK_FREEZE, 644ec0f694cSTomoki Sekiyama } FsfreezeHookArg; 645ec0f694cSTomoki Sekiyama 646ec0f694cSTomoki Sekiyama const char *fsfreeze_hook_arg_string[] = { 647ec0f694cSTomoki Sekiyama "thaw", 648ec0f694cSTomoki Sekiyama "freeze", 649ec0f694cSTomoki Sekiyama }; 650ec0f694cSTomoki Sekiyama 651*77dbc81bSMarkus Armbruster static void execute_fsfreeze_hook(FsfreezeHookArg arg, Error **errp) 652ec0f694cSTomoki Sekiyama { 653ec0f694cSTomoki Sekiyama int status; 654ec0f694cSTomoki Sekiyama pid_t pid; 655ec0f694cSTomoki Sekiyama const char *hook; 656ec0f694cSTomoki Sekiyama const char *arg_str = fsfreeze_hook_arg_string[arg]; 657ec0f694cSTomoki Sekiyama Error *local_err = NULL; 658ec0f694cSTomoki Sekiyama 659ec0f694cSTomoki Sekiyama hook = ga_fsfreeze_hook(ga_state); 660ec0f694cSTomoki Sekiyama if (!hook) { 661ec0f694cSTomoki Sekiyama return; 662ec0f694cSTomoki Sekiyama } 663ec0f694cSTomoki Sekiyama if (access(hook, X_OK) != 0) { 664*77dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "can't access fsfreeze hook '%s'", hook); 665ec0f694cSTomoki Sekiyama return; 666ec0f694cSTomoki Sekiyama } 667ec0f694cSTomoki Sekiyama 668ec0f694cSTomoki Sekiyama slog("executing fsfreeze hook with arg '%s'", arg_str); 669ec0f694cSTomoki Sekiyama pid = fork(); 670ec0f694cSTomoki Sekiyama if (pid == 0) { 671ec0f694cSTomoki Sekiyama setsid(); 672ec0f694cSTomoki Sekiyama reopen_fd_to_null(0); 673ec0f694cSTomoki Sekiyama reopen_fd_to_null(1); 674ec0f694cSTomoki Sekiyama reopen_fd_to_null(2); 675ec0f694cSTomoki Sekiyama 676ec0f694cSTomoki Sekiyama execle(hook, hook, arg_str, NULL, environ); 677ec0f694cSTomoki Sekiyama _exit(EXIT_FAILURE); 678ec0f694cSTomoki Sekiyama } else if (pid < 0) { 679*77dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to create child process"); 680ec0f694cSTomoki Sekiyama return; 681ec0f694cSTomoki Sekiyama } 682ec0f694cSTomoki Sekiyama 683ec0f694cSTomoki Sekiyama ga_wait_child(pid, &status, &local_err); 68484d18f06SMarkus Armbruster if (local_err) { 685*77dbc81bSMarkus Armbruster error_propagate(errp, local_err); 686ec0f694cSTomoki Sekiyama return; 687ec0f694cSTomoki Sekiyama } 688ec0f694cSTomoki Sekiyama 689ec0f694cSTomoki Sekiyama if (!WIFEXITED(status)) { 690*77dbc81bSMarkus Armbruster error_setg(errp, "fsfreeze hook has terminated abnormally"); 691ec0f694cSTomoki Sekiyama return; 692ec0f694cSTomoki Sekiyama } 693ec0f694cSTomoki Sekiyama 694ec0f694cSTomoki Sekiyama status = WEXITSTATUS(status); 695ec0f694cSTomoki Sekiyama if (status) { 696*77dbc81bSMarkus Armbruster error_setg(errp, "fsfreeze hook has failed with status %d", status); 697ec0f694cSTomoki Sekiyama return; 698ec0f694cSTomoki Sekiyama } 699ec0f694cSTomoki Sekiyama } 700ec0f694cSTomoki Sekiyama 701c216e5adSMichael Roth /* 702c216e5adSMichael Roth * Return status of freeze/thaw 703c216e5adSMichael Roth */ 704*77dbc81bSMarkus Armbruster GuestFsfreezeStatus qmp_guest_fsfreeze_status(Error **errp) 705c216e5adSMichael Roth { 706f22d85e9SMichael Roth if (ga_is_frozen(ga_state)) { 707f22d85e9SMichael Roth return GUEST_FSFREEZE_STATUS_FROZEN; 708f22d85e9SMichael Roth } 709f22d85e9SMichael Roth 710f22d85e9SMichael Roth return GUEST_FSFREEZE_STATUS_THAWED; 711c216e5adSMichael Roth } 712c216e5adSMichael Roth 713c216e5adSMichael Roth /* 714c216e5adSMichael Roth * Walk list of mounted file systems in the guest, and freeze the ones which 715c216e5adSMichael Roth * are real local file systems. 716c216e5adSMichael Roth */ 717*77dbc81bSMarkus Armbruster int64_t qmp_guest_fsfreeze_freeze(Error **errp) 718c216e5adSMichael Roth { 719c216e5adSMichael Roth int ret = 0, i = 0; 720af02203fSPaolo Bonzini FsMountList mounts; 721af02203fSPaolo Bonzini struct FsMount *mount; 722261551d1SLuiz Capitulino Error *local_err = NULL; 723c216e5adSMichael Roth int fd; 724c216e5adSMichael Roth 725c216e5adSMichael Roth slog("guest-fsfreeze called"); 726c216e5adSMichael Roth 727ec0f694cSTomoki Sekiyama execute_fsfreeze_hook(FSFREEZE_HOOK_FREEZE, &local_err); 72884d18f06SMarkus Armbruster if (local_err) { 729*77dbc81bSMarkus Armbruster error_propagate(errp, local_err); 730ec0f694cSTomoki Sekiyama return -1; 731ec0f694cSTomoki Sekiyama } 732ec0f694cSTomoki Sekiyama 7339e8aded4SMichael Roth QTAILQ_INIT(&mounts); 734261551d1SLuiz Capitulino build_fs_mount_list(&mounts, &local_err); 73584d18f06SMarkus Armbruster if (local_err) { 736*77dbc81bSMarkus Armbruster error_propagate(errp, local_err); 737261551d1SLuiz Capitulino return -1; 738c216e5adSMichael Roth } 739c216e5adSMichael Roth 740c216e5adSMichael Roth /* cannot risk guest agent blocking itself on a write in this state */ 741f22d85e9SMichael Roth ga_set_frozen(ga_state); 742c216e5adSMichael Roth 743e5d9adbdSTomoki Sekiyama QTAILQ_FOREACH_REVERSE(mount, &mounts, FsMountList, next) { 744c216e5adSMichael Roth fd = qemu_open(mount->dirname, O_RDONLY); 745c216e5adSMichael Roth if (fd == -1) { 746*77dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to open %s", mount->dirname); 747c216e5adSMichael Roth goto error; 748c216e5adSMichael Roth } 749c216e5adSMichael Roth 750c216e5adSMichael Roth /* we try to cull filesytems we know won't work in advance, but other 751c216e5adSMichael Roth * filesytems may not implement fsfreeze for less obvious reasons. 7529e8aded4SMichael Roth * these will report EOPNOTSUPP. we simply ignore these when tallying 7539e8aded4SMichael Roth * the number of frozen filesystems. 7549e8aded4SMichael Roth * 7559e8aded4SMichael Roth * any other error means a failure to freeze a filesystem we 7569e8aded4SMichael Roth * expect to be freezable, so return an error in those cases 7579e8aded4SMichael Roth * and return system to thawed state. 758c216e5adSMichael Roth */ 759c216e5adSMichael Roth ret = ioctl(fd, FIFREEZE); 7609e8aded4SMichael Roth if (ret == -1) { 7619e8aded4SMichael Roth if (errno != EOPNOTSUPP) { 762*77dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to freeze %s", 763617fbbc1SLuiz Capitulino mount->dirname); 764c216e5adSMichael Roth close(fd); 765c216e5adSMichael Roth goto error; 766c216e5adSMichael Roth } 7679e8aded4SMichael Roth } else { 768c216e5adSMichael Roth i++; 769c216e5adSMichael Roth } 7709e8aded4SMichael Roth close(fd); 7719e8aded4SMichael Roth } 772c216e5adSMichael Roth 773af02203fSPaolo Bonzini free_fs_mount_list(&mounts); 774c216e5adSMichael Roth return i; 775c216e5adSMichael Roth 776c216e5adSMichael Roth error: 777af02203fSPaolo Bonzini free_fs_mount_list(&mounts); 778c216e5adSMichael Roth qmp_guest_fsfreeze_thaw(NULL); 779c216e5adSMichael Roth return 0; 780c216e5adSMichael Roth } 781c216e5adSMichael Roth 782c216e5adSMichael Roth /* 783c216e5adSMichael Roth * Walk list of frozen file systems in the guest, and thaw them. 784c216e5adSMichael Roth */ 785*77dbc81bSMarkus Armbruster int64_t qmp_guest_fsfreeze_thaw(Error **errp) 786c216e5adSMichael Roth { 787c216e5adSMichael Roth int ret; 788af02203fSPaolo Bonzini FsMountList mounts; 789af02203fSPaolo Bonzini FsMount *mount; 7909e8aded4SMichael Roth int fd, i = 0, logged; 791261551d1SLuiz Capitulino Error *local_err = NULL; 792c216e5adSMichael Roth 7939e8aded4SMichael Roth QTAILQ_INIT(&mounts); 794261551d1SLuiz Capitulino build_fs_mount_list(&mounts, &local_err); 79584d18f06SMarkus Armbruster if (local_err) { 796*77dbc81bSMarkus Armbruster error_propagate(errp, local_err); 7979e8aded4SMichael Roth return 0; 7989e8aded4SMichael Roth } 7999e8aded4SMichael Roth 8009e8aded4SMichael Roth QTAILQ_FOREACH(mount, &mounts, next) { 8019e8aded4SMichael Roth logged = false; 802c216e5adSMichael Roth fd = qemu_open(mount->dirname, O_RDONLY); 803c216e5adSMichael Roth if (fd == -1) { 804c216e5adSMichael Roth continue; 805c216e5adSMichael Roth } 8069e8aded4SMichael Roth /* we have no way of knowing whether a filesystem was actually unfrozen 8079e8aded4SMichael Roth * as a result of a successful call to FITHAW, only that if an error 8089e8aded4SMichael Roth * was returned the filesystem was *not* unfrozen by that particular 8099e8aded4SMichael Roth * call. 8109e8aded4SMichael Roth * 811a31f0531SJim Meyering * since multiple preceding FIFREEZEs require multiple calls to FITHAW 8129e8aded4SMichael Roth * to unfreeze, continuing issuing FITHAW until an error is returned, 8139e8aded4SMichael Roth * in which case either the filesystem is in an unfreezable state, or, 8149e8aded4SMichael Roth * more likely, it was thawed previously (and remains so afterward). 8159e8aded4SMichael Roth * 8169e8aded4SMichael Roth * also, since the most recent successful call is the one that did 8179e8aded4SMichael Roth * the actual unfreeze, we can use this to provide an accurate count 8189e8aded4SMichael Roth * of the number of filesystems unfrozen by guest-fsfreeze-thaw, which 8199e8aded4SMichael Roth * may * be useful for determining whether a filesystem was unfrozen 8209e8aded4SMichael Roth * during the freeze/thaw phase by a process other than qemu-ga. 8219e8aded4SMichael Roth */ 8229e8aded4SMichael Roth do { 823c216e5adSMichael Roth ret = ioctl(fd, FITHAW); 8249e8aded4SMichael Roth if (ret == 0 && !logged) { 825c216e5adSMichael Roth i++; 8269e8aded4SMichael Roth logged = true; 8279e8aded4SMichael Roth } 8289e8aded4SMichael Roth } while (ret == 0); 8299e8aded4SMichael Roth close(fd); 830c216e5adSMichael Roth } 831c216e5adSMichael Roth 832f22d85e9SMichael Roth ga_unset_frozen(ga_state); 833af02203fSPaolo Bonzini free_fs_mount_list(&mounts); 834ec0f694cSTomoki Sekiyama 835*77dbc81bSMarkus Armbruster execute_fsfreeze_hook(FSFREEZE_HOOK_THAW, errp); 836ec0f694cSTomoki Sekiyama 837c216e5adSMichael Roth return i; 838c216e5adSMichael Roth } 839c216e5adSMichael Roth 840c216e5adSMichael Roth static void guest_fsfreeze_cleanup(void) 841c216e5adSMichael Roth { 842c216e5adSMichael Roth Error *err = NULL; 843c216e5adSMichael Roth 844f22d85e9SMichael Roth if (ga_is_frozen(ga_state) == GUEST_FSFREEZE_STATUS_FROZEN) { 8456f686749SMarkus Armbruster qmp_guest_fsfreeze_thaw(&err); 8466f686749SMarkus Armbruster if (err) { 8476f686749SMarkus Armbruster slog("failed to clean up frozen filesystems: %s", 8486f686749SMarkus Armbruster error_get_pretty(err)); 8496f686749SMarkus Armbruster error_free(err); 850c216e5adSMichael Roth } 851c216e5adSMichael Roth } 852c216e5adSMichael Roth } 853e72c3f2eSMichael Roth #endif /* CONFIG_FSFREEZE */ 854c216e5adSMichael Roth 855eab5fd59SPaolo Bonzini #if defined(CONFIG_FSTRIM) 856eab5fd59SPaolo Bonzini /* 857eab5fd59SPaolo Bonzini * Walk list of mounted file systems in the guest, and trim them. 858eab5fd59SPaolo Bonzini */ 859*77dbc81bSMarkus Armbruster void qmp_guest_fstrim(bool has_minimum, int64_t minimum, Error **errp) 860eab5fd59SPaolo Bonzini { 861eab5fd59SPaolo Bonzini int ret = 0; 862eab5fd59SPaolo Bonzini FsMountList mounts; 863eab5fd59SPaolo Bonzini struct FsMount *mount; 864eab5fd59SPaolo Bonzini int fd; 865261551d1SLuiz Capitulino Error *local_err = NULL; 866eab5fd59SPaolo Bonzini struct fstrim_range r = { 867eab5fd59SPaolo Bonzini .start = 0, 868eab5fd59SPaolo Bonzini .len = -1, 869eab5fd59SPaolo Bonzini .minlen = has_minimum ? minimum : 0, 870eab5fd59SPaolo Bonzini }; 871eab5fd59SPaolo Bonzini 872eab5fd59SPaolo Bonzini slog("guest-fstrim called"); 873eab5fd59SPaolo Bonzini 874eab5fd59SPaolo Bonzini QTAILQ_INIT(&mounts); 875261551d1SLuiz Capitulino build_fs_mount_list(&mounts, &local_err); 87684d18f06SMarkus Armbruster if (local_err) { 877*77dbc81bSMarkus Armbruster error_propagate(errp, local_err); 878eab5fd59SPaolo Bonzini return; 879eab5fd59SPaolo Bonzini } 880eab5fd59SPaolo Bonzini 881eab5fd59SPaolo Bonzini QTAILQ_FOREACH(mount, &mounts, next) { 882eab5fd59SPaolo Bonzini fd = qemu_open(mount->dirname, O_RDONLY); 883eab5fd59SPaolo Bonzini if (fd == -1) { 884*77dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to open %s", mount->dirname); 885eab5fd59SPaolo Bonzini goto error; 886eab5fd59SPaolo Bonzini } 887eab5fd59SPaolo Bonzini 888eab5fd59SPaolo Bonzini /* We try to cull filesytems we know won't work in advance, but other 889eab5fd59SPaolo Bonzini * filesytems may not implement fstrim for less obvious reasons. These 890eab5fd59SPaolo Bonzini * will report EOPNOTSUPP; we simply ignore these errors. Any other 891eab5fd59SPaolo Bonzini * error means an unexpected error, so return it in those cases. In 892eab5fd59SPaolo Bonzini * some other cases ENOTTY will be reported (e.g. CD-ROMs). 893eab5fd59SPaolo Bonzini */ 894eab5fd59SPaolo Bonzini ret = ioctl(fd, FITRIM, &r); 895eab5fd59SPaolo Bonzini if (ret == -1) { 896eab5fd59SPaolo Bonzini if (errno != ENOTTY && errno != EOPNOTSUPP) { 897*77dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to trim %s", 898071673b0SLuiz Capitulino mount->dirname); 899eab5fd59SPaolo Bonzini close(fd); 900eab5fd59SPaolo Bonzini goto error; 901eab5fd59SPaolo Bonzini } 902eab5fd59SPaolo Bonzini } 903eab5fd59SPaolo Bonzini close(fd); 904eab5fd59SPaolo Bonzini } 905eab5fd59SPaolo Bonzini 906eab5fd59SPaolo Bonzini error: 907eab5fd59SPaolo Bonzini free_fs_mount_list(&mounts); 908eab5fd59SPaolo Bonzini } 909eab5fd59SPaolo Bonzini #endif /* CONFIG_FSTRIM */ 910eab5fd59SPaolo Bonzini 911eab5fd59SPaolo Bonzini 91211d0f125SLuiz Capitulino #define LINUX_SYS_STATE_FILE "/sys/power/state" 91311d0f125SLuiz Capitulino #define SUSPEND_SUPPORTED 0 91411d0f125SLuiz Capitulino #define SUSPEND_NOT_SUPPORTED 1 91511d0f125SLuiz Capitulino 91611d0f125SLuiz Capitulino static void bios_supports_mode(const char *pmutils_bin, const char *pmutils_arg, 917*77dbc81bSMarkus Armbruster const char *sysfile_str, Error **errp) 91811d0f125SLuiz Capitulino { 9196b26e837SLuiz Capitulino Error *local_err = NULL; 92011d0f125SLuiz Capitulino char *pmutils_path; 9216b26e837SLuiz Capitulino pid_t pid; 922dc8764f0SLuiz Capitulino int status; 92311d0f125SLuiz Capitulino 92411d0f125SLuiz Capitulino pmutils_path = g_find_program_in_path(pmutils_bin); 92511d0f125SLuiz Capitulino 92611d0f125SLuiz Capitulino pid = fork(); 92711d0f125SLuiz Capitulino if (!pid) { 928dc8764f0SLuiz Capitulino char buf[32]; /* hopefully big enough */ 929dc8764f0SLuiz Capitulino ssize_t ret; 930dc8764f0SLuiz Capitulino int fd; 93111d0f125SLuiz Capitulino 93211d0f125SLuiz Capitulino setsid(); 93311d0f125SLuiz Capitulino reopen_fd_to_null(0); 93411d0f125SLuiz Capitulino reopen_fd_to_null(1); 93511d0f125SLuiz Capitulino reopen_fd_to_null(2); 93611d0f125SLuiz Capitulino 93711d0f125SLuiz Capitulino if (pmutils_path) { 93811d0f125SLuiz Capitulino execle(pmutils_path, pmutils_bin, pmutils_arg, NULL, environ); 93911d0f125SLuiz Capitulino } 94011d0f125SLuiz Capitulino 94111d0f125SLuiz Capitulino /* 94211d0f125SLuiz Capitulino * If we get here either pm-utils is not installed or execle() has 94311d0f125SLuiz Capitulino * failed. Let's try the manual method if the caller wants it. 94411d0f125SLuiz Capitulino */ 94511d0f125SLuiz Capitulino 94611d0f125SLuiz Capitulino if (!sysfile_str) { 94711d0f125SLuiz Capitulino _exit(SUSPEND_NOT_SUPPORTED); 94811d0f125SLuiz Capitulino } 94911d0f125SLuiz Capitulino 95011d0f125SLuiz Capitulino fd = open(LINUX_SYS_STATE_FILE, O_RDONLY); 95111d0f125SLuiz Capitulino if (fd < 0) { 95211d0f125SLuiz Capitulino _exit(SUSPEND_NOT_SUPPORTED); 95311d0f125SLuiz Capitulino } 95411d0f125SLuiz Capitulino 95511d0f125SLuiz Capitulino ret = read(fd, buf, sizeof(buf)-1); 95611d0f125SLuiz Capitulino if (ret <= 0) { 95711d0f125SLuiz Capitulino _exit(SUSPEND_NOT_SUPPORTED); 95811d0f125SLuiz Capitulino } 95911d0f125SLuiz Capitulino buf[ret] = '\0'; 96011d0f125SLuiz Capitulino 96111d0f125SLuiz Capitulino if (strstr(buf, sysfile_str)) { 96211d0f125SLuiz Capitulino _exit(SUSPEND_SUPPORTED); 96311d0f125SLuiz Capitulino } 96411d0f125SLuiz Capitulino 96511d0f125SLuiz Capitulino _exit(SUSPEND_NOT_SUPPORTED); 9666b26e837SLuiz Capitulino } else if (pid < 0) { 967*77dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to create child process"); 9686b26e837SLuiz Capitulino goto out; 96911d0f125SLuiz Capitulino } 97011d0f125SLuiz Capitulino 9716b26e837SLuiz Capitulino ga_wait_child(pid, &status, &local_err); 97284d18f06SMarkus Armbruster if (local_err) { 973*77dbc81bSMarkus Armbruster error_propagate(errp, local_err); 9746b26e837SLuiz Capitulino goto out; 97511d0f125SLuiz Capitulino } 97611d0f125SLuiz Capitulino 9776b26e837SLuiz Capitulino if (!WIFEXITED(status)) { 978*77dbc81bSMarkus Armbruster error_setg(errp, "child process has terminated abnormally"); 9796b26e837SLuiz Capitulino goto out; 9806b26e837SLuiz Capitulino } 9816b26e837SLuiz Capitulino 982dc8764f0SLuiz Capitulino switch (WEXITSTATUS(status)) { 983dc8764f0SLuiz Capitulino case SUSPEND_SUPPORTED: 9846b26e837SLuiz Capitulino goto out; 985dc8764f0SLuiz Capitulino case SUSPEND_NOT_SUPPORTED: 986*77dbc81bSMarkus Armbruster error_setg(errp, 9876b26e837SLuiz Capitulino "the requested suspend mode is not supported by the guest"); 9886b26e837SLuiz Capitulino goto out; 989dc8764f0SLuiz Capitulino default: 990*77dbc81bSMarkus Armbruster error_setg(errp, 9916b26e837SLuiz Capitulino "the helper program '%s' returned an unexpected exit status" 9926b26e837SLuiz Capitulino " code (%d)", pmutils_path, WEXITSTATUS(status)); 9936b26e837SLuiz Capitulino goto out; 994dc8764f0SLuiz Capitulino } 99511d0f125SLuiz Capitulino 9966b26e837SLuiz Capitulino out: 9976b26e837SLuiz Capitulino g_free(pmutils_path); 99811d0f125SLuiz Capitulino } 99911d0f125SLuiz Capitulino 100011d0f125SLuiz Capitulino static void guest_suspend(const char *pmutils_bin, const char *sysfile_str, 1001*77dbc81bSMarkus Armbruster Error **errp) 100211d0f125SLuiz Capitulino { 10037b376087SLuiz Capitulino Error *local_err = NULL; 100411d0f125SLuiz Capitulino char *pmutils_path; 10057b376087SLuiz Capitulino pid_t pid; 1006dc8764f0SLuiz Capitulino int status; 100711d0f125SLuiz Capitulino 100811d0f125SLuiz Capitulino pmutils_path = g_find_program_in_path(pmutils_bin); 100911d0f125SLuiz Capitulino 101011d0f125SLuiz Capitulino pid = fork(); 101111d0f125SLuiz Capitulino if (pid == 0) { 101211d0f125SLuiz Capitulino /* child */ 101311d0f125SLuiz Capitulino int fd; 101411d0f125SLuiz Capitulino 101511d0f125SLuiz Capitulino setsid(); 101611d0f125SLuiz Capitulino reopen_fd_to_null(0); 101711d0f125SLuiz Capitulino reopen_fd_to_null(1); 101811d0f125SLuiz Capitulino reopen_fd_to_null(2); 101911d0f125SLuiz Capitulino 102011d0f125SLuiz Capitulino if (pmutils_path) { 102111d0f125SLuiz Capitulino execle(pmutils_path, pmutils_bin, NULL, environ); 102211d0f125SLuiz Capitulino } 102311d0f125SLuiz Capitulino 102411d0f125SLuiz Capitulino /* 102511d0f125SLuiz Capitulino * If we get here either pm-utils is not installed or execle() has 102611d0f125SLuiz Capitulino * failed. Let's try the manual method if the caller wants it. 102711d0f125SLuiz Capitulino */ 102811d0f125SLuiz Capitulino 102911d0f125SLuiz Capitulino if (!sysfile_str) { 103011d0f125SLuiz Capitulino _exit(EXIT_FAILURE); 103111d0f125SLuiz Capitulino } 103211d0f125SLuiz Capitulino 103311d0f125SLuiz Capitulino fd = open(LINUX_SYS_STATE_FILE, O_WRONLY); 103411d0f125SLuiz Capitulino if (fd < 0) { 103511d0f125SLuiz Capitulino _exit(EXIT_FAILURE); 103611d0f125SLuiz Capitulino } 103711d0f125SLuiz Capitulino 103811d0f125SLuiz Capitulino if (write(fd, sysfile_str, strlen(sysfile_str)) < 0) { 103911d0f125SLuiz Capitulino _exit(EXIT_FAILURE); 104011d0f125SLuiz Capitulino } 104111d0f125SLuiz Capitulino 104211d0f125SLuiz Capitulino _exit(EXIT_SUCCESS); 10437b376087SLuiz Capitulino } else if (pid < 0) { 1044*77dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to create child process"); 10457b376087SLuiz Capitulino goto out; 104611d0f125SLuiz Capitulino } 104711d0f125SLuiz Capitulino 10487b376087SLuiz Capitulino ga_wait_child(pid, &status, &local_err); 104984d18f06SMarkus Armbruster if (local_err) { 1050*77dbc81bSMarkus Armbruster error_propagate(errp, local_err); 10517b376087SLuiz Capitulino goto out; 10527b376087SLuiz Capitulino } 10537b376087SLuiz Capitulino 10547b376087SLuiz Capitulino if (!WIFEXITED(status)) { 1055*77dbc81bSMarkus Armbruster error_setg(errp, "child process has terminated abnormally"); 10567b376087SLuiz Capitulino goto out; 10577b376087SLuiz Capitulino } 10587b376087SLuiz Capitulino 10597b376087SLuiz Capitulino if (WEXITSTATUS(status)) { 1060*77dbc81bSMarkus Armbruster error_setg(errp, "child process has failed to suspend"); 10617b376087SLuiz Capitulino goto out; 10627b376087SLuiz Capitulino } 10637b376087SLuiz Capitulino 10647b376087SLuiz Capitulino out: 106511d0f125SLuiz Capitulino g_free(pmutils_path); 106611d0f125SLuiz Capitulino } 106711d0f125SLuiz Capitulino 1068*77dbc81bSMarkus Armbruster void qmp_guest_suspend_disk(Error **errp) 106911d0f125SLuiz Capitulino { 1070*77dbc81bSMarkus Armbruster bios_supports_mode("pm-is-supported", "--hibernate", "disk", errp); 1071*77dbc81bSMarkus Armbruster if (error_is_set(errp)) { 107211d0f125SLuiz Capitulino return; 107311d0f125SLuiz Capitulino } 107411d0f125SLuiz Capitulino 1075*77dbc81bSMarkus Armbruster guest_suspend("pm-hibernate", "disk", errp); 107611d0f125SLuiz Capitulino } 107711d0f125SLuiz Capitulino 1078*77dbc81bSMarkus Armbruster void qmp_guest_suspend_ram(Error **errp) 1079fbf42210SLuiz Capitulino { 1080*77dbc81bSMarkus Armbruster bios_supports_mode("pm-is-supported", "--suspend", "mem", errp); 1081*77dbc81bSMarkus Armbruster if (error_is_set(errp)) { 1082fbf42210SLuiz Capitulino return; 1083fbf42210SLuiz Capitulino } 1084fbf42210SLuiz Capitulino 1085*77dbc81bSMarkus Armbruster guest_suspend("pm-suspend", "mem", errp); 1086fbf42210SLuiz Capitulino } 1087fbf42210SLuiz Capitulino 1088*77dbc81bSMarkus Armbruster void qmp_guest_suspend_hybrid(Error **errp) 108995f4f404SLuiz Capitulino { 1090*77dbc81bSMarkus Armbruster bios_supports_mode("pm-is-supported", "--suspend-hybrid", NULL, errp); 1091*77dbc81bSMarkus Armbruster if (error_is_set(errp)) { 109295f4f404SLuiz Capitulino return; 109395f4f404SLuiz Capitulino } 109495f4f404SLuiz Capitulino 1095*77dbc81bSMarkus Armbruster guest_suspend("pm-suspend-hybrid", NULL, errp); 109695f4f404SLuiz Capitulino } 109795f4f404SLuiz Capitulino 10983424fc9fSMichal Privoznik static GuestNetworkInterfaceList * 10993424fc9fSMichal Privoznik guest_find_interface(GuestNetworkInterfaceList *head, 11003424fc9fSMichal Privoznik const char *name) 11013424fc9fSMichal Privoznik { 11023424fc9fSMichal Privoznik for (; head; head = head->next) { 11033424fc9fSMichal Privoznik if (strcmp(head->value->name, name) == 0) { 11043424fc9fSMichal Privoznik break; 11053424fc9fSMichal Privoznik } 11063424fc9fSMichal Privoznik } 11073424fc9fSMichal Privoznik 11083424fc9fSMichal Privoznik return head; 11093424fc9fSMichal Privoznik } 11103424fc9fSMichal Privoznik 11113424fc9fSMichal Privoznik /* 11123424fc9fSMichal Privoznik * Build information about guest interfaces 11133424fc9fSMichal Privoznik */ 11143424fc9fSMichal Privoznik GuestNetworkInterfaceList *qmp_guest_network_get_interfaces(Error **errp) 11153424fc9fSMichal Privoznik { 11163424fc9fSMichal Privoznik GuestNetworkInterfaceList *head = NULL, *cur_item = NULL; 11173424fc9fSMichal Privoznik struct ifaddrs *ifap, *ifa; 11183424fc9fSMichal Privoznik 11193424fc9fSMichal Privoznik if (getifaddrs(&ifap) < 0) { 1120878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, "getifaddrs failed"); 11213424fc9fSMichal Privoznik goto error; 11223424fc9fSMichal Privoznik } 11233424fc9fSMichal Privoznik 11243424fc9fSMichal Privoznik for (ifa = ifap; ifa; ifa = ifa->ifa_next) { 11253424fc9fSMichal Privoznik GuestNetworkInterfaceList *info; 11263424fc9fSMichal Privoznik GuestIpAddressList **address_list = NULL, *address_item = NULL; 11273424fc9fSMichal Privoznik char addr4[INET_ADDRSTRLEN]; 11283424fc9fSMichal Privoznik char addr6[INET6_ADDRSTRLEN]; 11293424fc9fSMichal Privoznik int sock; 11303424fc9fSMichal Privoznik struct ifreq ifr; 11313424fc9fSMichal Privoznik unsigned char *mac_addr; 11323424fc9fSMichal Privoznik void *p; 11333424fc9fSMichal Privoznik 11343424fc9fSMichal Privoznik g_debug("Processing %s interface", ifa->ifa_name); 11353424fc9fSMichal Privoznik 11363424fc9fSMichal Privoznik info = guest_find_interface(head, ifa->ifa_name); 11373424fc9fSMichal Privoznik 11383424fc9fSMichal Privoznik if (!info) { 11393424fc9fSMichal Privoznik info = g_malloc0(sizeof(*info)); 11403424fc9fSMichal Privoznik info->value = g_malloc0(sizeof(*info->value)); 11413424fc9fSMichal Privoznik info->value->name = g_strdup(ifa->ifa_name); 11423424fc9fSMichal Privoznik 11433424fc9fSMichal Privoznik if (!cur_item) { 11443424fc9fSMichal Privoznik head = cur_item = info; 11453424fc9fSMichal Privoznik } else { 11463424fc9fSMichal Privoznik cur_item->next = info; 11473424fc9fSMichal Privoznik cur_item = info; 11483424fc9fSMichal Privoznik } 11493424fc9fSMichal Privoznik } 11503424fc9fSMichal Privoznik 11513424fc9fSMichal Privoznik if (!info->value->has_hardware_address && 11523424fc9fSMichal Privoznik ifa->ifa_flags & SIOCGIFHWADDR) { 11533424fc9fSMichal Privoznik /* we haven't obtained HW address yet */ 11543424fc9fSMichal Privoznik sock = socket(PF_INET, SOCK_STREAM, 0); 11553424fc9fSMichal Privoznik if (sock == -1) { 1156878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, "failed to create socket"); 11573424fc9fSMichal Privoznik goto error; 11583424fc9fSMichal Privoznik } 11593424fc9fSMichal Privoznik 11603424fc9fSMichal Privoznik memset(&ifr, 0, sizeof(ifr)); 11611ab516edSJim Meyering pstrcpy(ifr.ifr_name, IF_NAMESIZE, info->value->name); 11623424fc9fSMichal Privoznik if (ioctl(sock, SIOCGIFHWADDR, &ifr) == -1) { 1163878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, 1164878a0ae0SLuiz Capitulino "failed to get MAC address of %s", 1165878a0ae0SLuiz Capitulino ifa->ifa_name); 116610a2158fSMarkus Armbruster close(sock); 11673424fc9fSMichal Privoznik goto error; 11683424fc9fSMichal Privoznik } 11693424fc9fSMichal Privoznik 117010a2158fSMarkus Armbruster close(sock); 11713424fc9fSMichal Privoznik mac_addr = (unsigned char *) &ifr.ifr_hwaddr.sa_data; 11723424fc9fSMichal Privoznik 1173e4ada482SStefan Weil info->value->hardware_address = 1174e4ada482SStefan Weil g_strdup_printf("%02x:%02x:%02x:%02x:%02x:%02x", 11753424fc9fSMichal Privoznik (int) mac_addr[0], (int) mac_addr[1], 11763424fc9fSMichal Privoznik (int) mac_addr[2], (int) mac_addr[3], 1177e4ada482SStefan Weil (int) mac_addr[4], (int) mac_addr[5]); 11783424fc9fSMichal Privoznik 11793424fc9fSMichal Privoznik info->value->has_hardware_address = true; 11803424fc9fSMichal Privoznik } 11813424fc9fSMichal Privoznik 11823424fc9fSMichal Privoznik if (ifa->ifa_addr && 11833424fc9fSMichal Privoznik ifa->ifa_addr->sa_family == AF_INET) { 11843424fc9fSMichal Privoznik /* interface with IPv4 address */ 11853424fc9fSMichal Privoznik p = &((struct sockaddr_in *)ifa->ifa_addr)->sin_addr; 11863424fc9fSMichal Privoznik if (!inet_ntop(AF_INET, p, addr4, sizeof(addr4))) { 1187878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, "inet_ntop failed"); 11883424fc9fSMichal Privoznik goto error; 11893424fc9fSMichal Privoznik } 11903424fc9fSMichal Privoznik 119110a2158fSMarkus Armbruster address_item = g_malloc0(sizeof(*address_item)); 119210a2158fSMarkus Armbruster address_item->value = g_malloc0(sizeof(*address_item->value)); 11933424fc9fSMichal Privoznik address_item->value->ip_address = g_strdup(addr4); 11943424fc9fSMichal Privoznik address_item->value->ip_address_type = GUEST_IP_ADDRESS_TYPE_IPV4; 11953424fc9fSMichal Privoznik 11963424fc9fSMichal Privoznik if (ifa->ifa_netmask) { 11973424fc9fSMichal Privoznik /* Count the number of set bits in netmask. 11983424fc9fSMichal Privoznik * This is safe as '1' and '0' cannot be shuffled in netmask. */ 11993424fc9fSMichal Privoznik p = &((struct sockaddr_in *)ifa->ifa_netmask)->sin_addr; 12003424fc9fSMichal Privoznik address_item->value->prefix = ctpop32(((uint32_t *) p)[0]); 12013424fc9fSMichal Privoznik } 12023424fc9fSMichal Privoznik } else if (ifa->ifa_addr && 12033424fc9fSMichal Privoznik ifa->ifa_addr->sa_family == AF_INET6) { 12043424fc9fSMichal Privoznik /* interface with IPv6 address */ 12053424fc9fSMichal Privoznik p = &((struct sockaddr_in6 *)ifa->ifa_addr)->sin6_addr; 12063424fc9fSMichal Privoznik if (!inet_ntop(AF_INET6, p, addr6, sizeof(addr6))) { 1207878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, "inet_ntop failed"); 12083424fc9fSMichal Privoznik goto error; 12093424fc9fSMichal Privoznik } 12103424fc9fSMichal Privoznik 121110a2158fSMarkus Armbruster address_item = g_malloc0(sizeof(*address_item)); 121210a2158fSMarkus Armbruster address_item->value = g_malloc0(sizeof(*address_item->value)); 12133424fc9fSMichal Privoznik address_item->value->ip_address = g_strdup(addr6); 12143424fc9fSMichal Privoznik address_item->value->ip_address_type = GUEST_IP_ADDRESS_TYPE_IPV6; 12153424fc9fSMichal Privoznik 12163424fc9fSMichal Privoznik if (ifa->ifa_netmask) { 12173424fc9fSMichal Privoznik /* Count the number of set bits in netmask. 12183424fc9fSMichal Privoznik * This is safe as '1' and '0' cannot be shuffled in netmask. */ 12193424fc9fSMichal Privoznik p = &((struct sockaddr_in6 *)ifa->ifa_netmask)->sin6_addr; 12203424fc9fSMichal Privoznik address_item->value->prefix = 12213424fc9fSMichal Privoznik ctpop32(((uint32_t *) p)[0]) + 12223424fc9fSMichal Privoznik ctpop32(((uint32_t *) p)[1]) + 12233424fc9fSMichal Privoznik ctpop32(((uint32_t *) p)[2]) + 12243424fc9fSMichal Privoznik ctpop32(((uint32_t *) p)[3]); 12253424fc9fSMichal Privoznik } 12263424fc9fSMichal Privoznik } 12273424fc9fSMichal Privoznik 12283424fc9fSMichal Privoznik if (!address_item) { 12293424fc9fSMichal Privoznik continue; 12303424fc9fSMichal Privoznik } 12313424fc9fSMichal Privoznik 12323424fc9fSMichal Privoznik address_list = &info->value->ip_addresses; 12333424fc9fSMichal Privoznik 12343424fc9fSMichal Privoznik while (*address_list && (*address_list)->next) { 12353424fc9fSMichal Privoznik address_list = &(*address_list)->next; 12363424fc9fSMichal Privoznik } 12373424fc9fSMichal Privoznik 12383424fc9fSMichal Privoznik if (!*address_list) { 12393424fc9fSMichal Privoznik *address_list = address_item; 12403424fc9fSMichal Privoznik } else { 12413424fc9fSMichal Privoznik (*address_list)->next = address_item; 12423424fc9fSMichal Privoznik } 12433424fc9fSMichal Privoznik 12443424fc9fSMichal Privoznik info->value->has_ip_addresses = true; 12453424fc9fSMichal Privoznik 12463424fc9fSMichal Privoznik 12473424fc9fSMichal Privoznik } 12483424fc9fSMichal Privoznik 12493424fc9fSMichal Privoznik freeifaddrs(ifap); 12503424fc9fSMichal Privoznik return head; 12513424fc9fSMichal Privoznik 12523424fc9fSMichal Privoznik error: 12533424fc9fSMichal Privoznik freeifaddrs(ifap); 12543424fc9fSMichal Privoznik qapi_free_GuestNetworkInterfaceList(head); 12553424fc9fSMichal Privoznik return NULL; 12563424fc9fSMichal Privoznik } 12573424fc9fSMichal Privoznik 1258*77dbc81bSMarkus Armbruster #define SYSCONF_EXACT(name, errp) sysconf_exact((name), #name, (errp)) 1259d2baff62SLaszlo Ersek 1260*77dbc81bSMarkus Armbruster static long sysconf_exact(int name, const char *name_str, Error **errp) 1261d2baff62SLaszlo Ersek { 1262d2baff62SLaszlo Ersek long ret; 1263d2baff62SLaszlo Ersek 1264d2baff62SLaszlo Ersek errno = 0; 1265d2baff62SLaszlo Ersek ret = sysconf(name); 1266d2baff62SLaszlo Ersek if (ret == -1) { 1267d2baff62SLaszlo Ersek if (errno == 0) { 1268*77dbc81bSMarkus Armbruster error_setg(errp, "sysconf(%s): value indefinite", name_str); 1269d2baff62SLaszlo Ersek } else { 1270*77dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "sysconf(%s)", name_str); 1271d2baff62SLaszlo Ersek } 1272d2baff62SLaszlo Ersek } 1273d2baff62SLaszlo Ersek return ret; 1274d2baff62SLaszlo Ersek } 1275d2baff62SLaszlo Ersek 1276d2baff62SLaszlo Ersek /* Transfer online/offline status between @vcpu and the guest system. 1277d2baff62SLaszlo Ersek * 1278d2baff62SLaszlo Ersek * On input either @errp or *@errp must be NULL. 1279d2baff62SLaszlo Ersek * 1280d2baff62SLaszlo Ersek * In system-to-@vcpu direction, the following @vcpu fields are accessed: 1281d2baff62SLaszlo Ersek * - R: vcpu->logical_id 1282d2baff62SLaszlo Ersek * - W: vcpu->online 1283d2baff62SLaszlo Ersek * - W: vcpu->can_offline 1284d2baff62SLaszlo Ersek * 1285d2baff62SLaszlo Ersek * In @vcpu-to-system direction, the following @vcpu fields are accessed: 1286d2baff62SLaszlo Ersek * - R: vcpu->logical_id 1287d2baff62SLaszlo Ersek * - R: vcpu->online 1288d2baff62SLaszlo Ersek * 1289d2baff62SLaszlo Ersek * Written members remain unmodified on error. 1290d2baff62SLaszlo Ersek */ 1291d2baff62SLaszlo Ersek static void transfer_vcpu(GuestLogicalProcessor *vcpu, bool sys2vcpu, 1292d2baff62SLaszlo Ersek Error **errp) 1293d2baff62SLaszlo Ersek { 1294d2baff62SLaszlo Ersek char *dirpath; 1295d2baff62SLaszlo Ersek int dirfd; 1296d2baff62SLaszlo Ersek 1297d2baff62SLaszlo Ersek dirpath = g_strdup_printf("/sys/devices/system/cpu/cpu%" PRId64 "/", 1298d2baff62SLaszlo Ersek vcpu->logical_id); 1299d2baff62SLaszlo Ersek dirfd = open(dirpath, O_RDONLY | O_DIRECTORY); 1300d2baff62SLaszlo Ersek if (dirfd == -1) { 1301d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "open(\"%s\")", dirpath); 1302d2baff62SLaszlo Ersek } else { 1303d2baff62SLaszlo Ersek static const char fn[] = "online"; 1304d2baff62SLaszlo Ersek int fd; 1305d2baff62SLaszlo Ersek int res; 1306d2baff62SLaszlo Ersek 1307d2baff62SLaszlo Ersek fd = openat(dirfd, fn, sys2vcpu ? O_RDONLY : O_RDWR); 1308d2baff62SLaszlo Ersek if (fd == -1) { 1309d2baff62SLaszlo Ersek if (errno != ENOENT) { 1310d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "open(\"%s/%s\")", dirpath, fn); 1311d2baff62SLaszlo Ersek } else if (sys2vcpu) { 1312d2baff62SLaszlo Ersek vcpu->online = true; 1313d2baff62SLaszlo Ersek vcpu->can_offline = false; 1314d2baff62SLaszlo Ersek } else if (!vcpu->online) { 1315d2baff62SLaszlo Ersek error_setg(errp, "logical processor #%" PRId64 " can't be " 1316d2baff62SLaszlo Ersek "offlined", vcpu->logical_id); 1317d2baff62SLaszlo Ersek } /* otherwise pretend successful re-onlining */ 1318d2baff62SLaszlo Ersek } else { 1319d2baff62SLaszlo Ersek unsigned char status; 1320d2baff62SLaszlo Ersek 1321d2baff62SLaszlo Ersek res = pread(fd, &status, 1, 0); 1322d2baff62SLaszlo Ersek if (res == -1) { 1323d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "pread(\"%s/%s\")", dirpath, fn); 1324d2baff62SLaszlo Ersek } else if (res == 0) { 1325d2baff62SLaszlo Ersek error_setg(errp, "pread(\"%s/%s\"): unexpected EOF", dirpath, 1326d2baff62SLaszlo Ersek fn); 1327d2baff62SLaszlo Ersek } else if (sys2vcpu) { 1328d2baff62SLaszlo Ersek vcpu->online = (status != '0'); 1329d2baff62SLaszlo Ersek vcpu->can_offline = true; 1330d2baff62SLaszlo Ersek } else if (vcpu->online != (status != '0')) { 1331d2baff62SLaszlo Ersek status = '0' + vcpu->online; 1332d2baff62SLaszlo Ersek if (pwrite(fd, &status, 1, 0) == -1) { 1333d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "pwrite(\"%s/%s\")", dirpath, 1334d2baff62SLaszlo Ersek fn); 1335d2baff62SLaszlo Ersek } 1336d2baff62SLaszlo Ersek } /* otherwise pretend successful re-(on|off)-lining */ 1337d2baff62SLaszlo Ersek 1338d2baff62SLaszlo Ersek res = close(fd); 1339d2baff62SLaszlo Ersek g_assert(res == 0); 1340d2baff62SLaszlo Ersek } 1341d2baff62SLaszlo Ersek 1342d2baff62SLaszlo Ersek res = close(dirfd); 1343d2baff62SLaszlo Ersek g_assert(res == 0); 1344d2baff62SLaszlo Ersek } 1345d2baff62SLaszlo Ersek 1346d2baff62SLaszlo Ersek g_free(dirpath); 1347d2baff62SLaszlo Ersek } 1348d2baff62SLaszlo Ersek 1349d2baff62SLaszlo Ersek GuestLogicalProcessorList *qmp_guest_get_vcpus(Error **errp) 1350d2baff62SLaszlo Ersek { 1351d2baff62SLaszlo Ersek int64_t current; 1352d2baff62SLaszlo Ersek GuestLogicalProcessorList *head, **link; 1353d2baff62SLaszlo Ersek long sc_max; 1354d2baff62SLaszlo Ersek Error *local_err = NULL; 1355d2baff62SLaszlo Ersek 1356d2baff62SLaszlo Ersek current = 0; 1357d2baff62SLaszlo Ersek head = NULL; 1358d2baff62SLaszlo Ersek link = &head; 1359d2baff62SLaszlo Ersek sc_max = SYSCONF_EXACT(_SC_NPROCESSORS_CONF, &local_err); 1360d2baff62SLaszlo Ersek 1361d2baff62SLaszlo Ersek while (local_err == NULL && current < sc_max) { 1362d2baff62SLaszlo Ersek GuestLogicalProcessor *vcpu; 1363d2baff62SLaszlo Ersek GuestLogicalProcessorList *entry; 1364d2baff62SLaszlo Ersek 1365d2baff62SLaszlo Ersek vcpu = g_malloc0(sizeof *vcpu); 1366d2baff62SLaszlo Ersek vcpu->logical_id = current++; 1367d2baff62SLaszlo Ersek vcpu->has_can_offline = true; /* lolspeak ftw */ 1368d2baff62SLaszlo Ersek transfer_vcpu(vcpu, true, &local_err); 1369d2baff62SLaszlo Ersek 1370d2baff62SLaszlo Ersek entry = g_malloc0(sizeof *entry); 1371d2baff62SLaszlo Ersek entry->value = vcpu; 1372d2baff62SLaszlo Ersek 1373d2baff62SLaszlo Ersek *link = entry; 1374d2baff62SLaszlo Ersek link = &entry->next; 1375d2baff62SLaszlo Ersek } 1376d2baff62SLaszlo Ersek 1377d2baff62SLaszlo Ersek if (local_err == NULL) { 1378d2baff62SLaszlo Ersek /* there's no guest with zero VCPUs */ 1379d2baff62SLaszlo Ersek g_assert(head != NULL); 1380d2baff62SLaszlo Ersek return head; 1381d2baff62SLaszlo Ersek } 1382d2baff62SLaszlo Ersek 1383d2baff62SLaszlo Ersek qapi_free_GuestLogicalProcessorList(head); 1384d2baff62SLaszlo Ersek error_propagate(errp, local_err); 1385d2baff62SLaszlo Ersek return NULL; 1386d2baff62SLaszlo Ersek } 1387d2baff62SLaszlo Ersek 1388cbb65fc2SLaszlo Ersek int64_t qmp_guest_set_vcpus(GuestLogicalProcessorList *vcpus, Error **errp) 1389cbb65fc2SLaszlo Ersek { 1390cbb65fc2SLaszlo Ersek int64_t processed; 1391cbb65fc2SLaszlo Ersek Error *local_err = NULL; 1392cbb65fc2SLaszlo Ersek 1393cbb65fc2SLaszlo Ersek processed = 0; 1394cbb65fc2SLaszlo Ersek while (vcpus != NULL) { 1395cbb65fc2SLaszlo Ersek transfer_vcpu(vcpus->value, false, &local_err); 1396cbb65fc2SLaszlo Ersek if (local_err != NULL) { 1397cbb65fc2SLaszlo Ersek break; 1398cbb65fc2SLaszlo Ersek } 1399cbb65fc2SLaszlo Ersek ++processed; 1400cbb65fc2SLaszlo Ersek vcpus = vcpus->next; 1401cbb65fc2SLaszlo Ersek } 1402cbb65fc2SLaszlo Ersek 1403cbb65fc2SLaszlo Ersek if (local_err != NULL) { 1404cbb65fc2SLaszlo Ersek if (processed == 0) { 1405cbb65fc2SLaszlo Ersek error_propagate(errp, local_err); 1406cbb65fc2SLaszlo Ersek } else { 1407cbb65fc2SLaszlo Ersek error_free(local_err); 1408cbb65fc2SLaszlo Ersek } 1409cbb65fc2SLaszlo Ersek } 1410cbb65fc2SLaszlo Ersek 1411cbb65fc2SLaszlo Ersek return processed; 1412cbb65fc2SLaszlo Ersek } 1413cbb65fc2SLaszlo Ersek 1414e72c3f2eSMichael Roth #else /* defined(__linux__) */ 1415e72c3f2eSMichael Roth 1416*77dbc81bSMarkus Armbruster void qmp_guest_suspend_disk(Error **errp) 1417e72c3f2eSMichael Roth { 1418*77dbc81bSMarkus Armbruster error_set(errp, QERR_UNSUPPORTED); 1419e72c3f2eSMichael Roth } 1420e72c3f2eSMichael Roth 1421*77dbc81bSMarkus Armbruster void qmp_guest_suspend_ram(Error **errp) 1422e72c3f2eSMichael Roth { 1423*77dbc81bSMarkus Armbruster error_set(errp, QERR_UNSUPPORTED); 1424e72c3f2eSMichael Roth } 1425e72c3f2eSMichael Roth 1426*77dbc81bSMarkus Armbruster void qmp_guest_suspend_hybrid(Error **errp) 1427e72c3f2eSMichael Roth { 1428*77dbc81bSMarkus Armbruster error_set(errp, QERR_UNSUPPORTED); 1429e72c3f2eSMichael Roth } 1430e72c3f2eSMichael Roth 1431e72c3f2eSMichael Roth GuestNetworkInterfaceList *qmp_guest_network_get_interfaces(Error **errp) 1432e72c3f2eSMichael Roth { 1433e72c3f2eSMichael Roth error_set(errp, QERR_UNSUPPORTED); 1434e72c3f2eSMichael Roth return NULL; 1435e72c3f2eSMichael Roth } 1436e72c3f2eSMichael Roth 1437d2baff62SLaszlo Ersek GuestLogicalProcessorList *qmp_guest_get_vcpus(Error **errp) 1438d2baff62SLaszlo Ersek { 1439d2baff62SLaszlo Ersek error_set(errp, QERR_UNSUPPORTED); 1440d2baff62SLaszlo Ersek return NULL; 1441d2baff62SLaszlo Ersek } 1442d2baff62SLaszlo Ersek 1443cbb65fc2SLaszlo Ersek int64_t qmp_guest_set_vcpus(GuestLogicalProcessorList *vcpus, Error **errp) 1444cbb65fc2SLaszlo Ersek { 1445cbb65fc2SLaszlo Ersek error_set(errp, QERR_UNSUPPORTED); 1446cbb65fc2SLaszlo Ersek return -1; 1447cbb65fc2SLaszlo Ersek } 1448cbb65fc2SLaszlo Ersek 1449e72c3f2eSMichael Roth #endif 1450e72c3f2eSMichael Roth 1451d35d4cb5SMichael Roth #if !defined(CONFIG_FSFREEZE) 1452d35d4cb5SMichael Roth 1453*77dbc81bSMarkus Armbruster GuestFsfreezeStatus qmp_guest_fsfreeze_status(Error **errp) 1454d35d4cb5SMichael Roth { 1455*77dbc81bSMarkus Armbruster error_set(errp, QERR_UNSUPPORTED); 1456d35d4cb5SMichael Roth 1457d35d4cb5SMichael Roth return 0; 1458d35d4cb5SMichael Roth } 1459d35d4cb5SMichael Roth 1460*77dbc81bSMarkus Armbruster int64_t qmp_guest_fsfreeze_freeze(Error **errp) 1461d35d4cb5SMichael Roth { 1462*77dbc81bSMarkus Armbruster error_set(errp, QERR_UNSUPPORTED); 1463d35d4cb5SMichael Roth 1464d35d4cb5SMichael Roth return 0; 1465d35d4cb5SMichael Roth } 1466d35d4cb5SMichael Roth 1467*77dbc81bSMarkus Armbruster int64_t qmp_guest_fsfreeze_thaw(Error **errp) 1468d35d4cb5SMichael Roth { 1469*77dbc81bSMarkus Armbruster error_set(errp, QERR_UNSUPPORTED); 1470d35d4cb5SMichael Roth 1471d35d4cb5SMichael Roth return 0; 1472d35d4cb5SMichael Roth } 1473eab5fd59SPaolo Bonzini #endif /* CONFIG_FSFREEZE */ 1474d35d4cb5SMichael Roth 1475eab5fd59SPaolo Bonzini #if !defined(CONFIG_FSTRIM) 1476*77dbc81bSMarkus Armbruster void qmp_guest_fstrim(bool has_minimum, int64_t minimum, Error **errp) 1477eab5fd59SPaolo Bonzini { 1478*77dbc81bSMarkus Armbruster error_set(errp, QERR_UNSUPPORTED); 1479eab5fd59SPaolo Bonzini } 1480d35d4cb5SMichael Roth #endif 1481d35d4cb5SMichael Roth 1482c216e5adSMichael Roth /* register init/cleanup routines for stateful command groups */ 1483c216e5adSMichael Roth void ga_command_state_init(GAState *s, GACommandState *cs) 1484c216e5adSMichael Roth { 1485c216e5adSMichael Roth #if defined(CONFIG_FSFREEZE) 1486f22d85e9SMichael Roth ga_command_state_add(cs, NULL, guest_fsfreeze_cleanup); 1487c216e5adSMichael Roth #endif 1488c216e5adSMichael Roth ga_command_state_add(cs, guest_file_init, NULL); 1489c216e5adSMichael Roth } 1490