1c216e5adSMichael Roth /* 2c216e5adSMichael Roth * QEMU Guest Agent POSIX-specific command implementations 3c216e5adSMichael Roth * 4c216e5adSMichael Roth * Copyright IBM Corp. 2011 5c216e5adSMichael Roth * 6c216e5adSMichael Roth * Authors: 7c216e5adSMichael Roth * Michael Roth <mdroth@linux.vnet.ibm.com> 83424fc9fSMichal Privoznik * Michal Privoznik <mprivozn@redhat.com> 9c216e5adSMichael Roth * 10c216e5adSMichael Roth * This work is licensed under the terms of the GNU GPL, version 2 or later. 11c216e5adSMichael Roth * See the COPYING file in the top-level directory. 12c216e5adSMichael Roth */ 13c216e5adSMichael Roth 144459bf38SPeter Maydell #include "qemu/osdep.h" 15c216e5adSMichael Roth #include <sys/ioctl.h> 162c02cbf6SLuiz Capitulino #include <sys/wait.h> 1746d4c572STomoki Sekiyama #include <dirent.h> 18161a56a9SVinzenz Feenstra #include <utmpx.h> 19c216e5adSMichael Roth #include "qga/guest-agent-core.h" 20c216e5adSMichael Roth #include "qga-qmp-commands.h" 217b1b5d19SPaolo Bonzini #include "qapi/qmp/qerror.h" 221de7afc9SPaolo Bonzini #include "qemu/queue.h" 231de7afc9SPaolo Bonzini #include "qemu/host-utils.h" 2412505396SDenis V. Lunev #include "qemu/sockets.h" 25920639caSDaniel P. Berrange #include "qemu/base64.h" 26f348b6d1SVeronia Bahaa #include "qemu/cutils.h" 27c216e5adSMichael Roth 282c02cbf6SLuiz Capitulino #ifndef CONFIG_HAS_ENVIRON 29eecae147SAndreas Färber #ifdef __APPLE__ 30eecae147SAndreas Färber #include <crt_externs.h> 31eecae147SAndreas Färber #define environ (*_NSGetEnviron()) 32eecae147SAndreas Färber #else 332c02cbf6SLuiz Capitulino extern char **environ; 342c02cbf6SLuiz Capitulino #endif 35eecae147SAndreas Färber #endif 362c02cbf6SLuiz Capitulino 37e72c3f2eSMichael Roth #if defined(__linux__) 38e72c3f2eSMichael Roth #include <mntent.h> 39e72c3f2eSMichael Roth #include <linux/fs.h> 40e72c3f2eSMichael Roth #include <ifaddrs.h> 41e72c3f2eSMichael Roth #include <arpa/inet.h> 42e72c3f2eSMichael Roth #include <sys/socket.h> 43e72c3f2eSMichael Roth #include <net/if.h> 44e72c3f2eSMichael Roth 45eab5fd59SPaolo Bonzini #ifdef FIFREEZE 46e72c3f2eSMichael Roth #define CONFIG_FSFREEZE 47e72c3f2eSMichael Roth #endif 48eab5fd59SPaolo Bonzini #ifdef FITRIM 49eab5fd59SPaolo Bonzini #define CONFIG_FSTRIM 50eab5fd59SPaolo Bonzini #endif 51e72c3f2eSMichael Roth #endif 52e72c3f2eSMichael Roth 5377dbc81bSMarkus Armbruster static void ga_wait_child(pid_t pid, int *status, Error **errp) 54d220a6dfSLuiz Capitulino { 55d220a6dfSLuiz Capitulino pid_t rpid; 56d220a6dfSLuiz Capitulino 57d220a6dfSLuiz Capitulino *status = 0; 58d220a6dfSLuiz Capitulino 59d220a6dfSLuiz Capitulino do { 60d220a6dfSLuiz Capitulino rpid = waitpid(pid, status, 0); 61d220a6dfSLuiz Capitulino } while (rpid == -1 && errno == EINTR); 62d220a6dfSLuiz Capitulino 63d220a6dfSLuiz Capitulino if (rpid == -1) { 6477dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to wait for child (pid: %d)", 6577dbc81bSMarkus Armbruster pid); 66d220a6dfSLuiz Capitulino return; 67d220a6dfSLuiz Capitulino } 68d220a6dfSLuiz Capitulino 69d220a6dfSLuiz Capitulino g_assert(rpid == pid); 70d220a6dfSLuiz Capitulino } 71d220a6dfSLuiz Capitulino 7277dbc81bSMarkus Armbruster void qmp_guest_shutdown(bool has_mode, const char *mode, Error **errp) 73c216e5adSMichael Roth { 74c216e5adSMichael Roth const char *shutdown_flag; 75d220a6dfSLuiz Capitulino Error *local_err = NULL; 76d220a6dfSLuiz Capitulino pid_t pid; 773674838cSLuiz Capitulino int status; 78c216e5adSMichael Roth 79c216e5adSMichael Roth slog("guest-shutdown called, mode: %s", mode); 80c216e5adSMichael Roth if (!has_mode || strcmp(mode, "powerdown") == 0) { 81c216e5adSMichael Roth shutdown_flag = "-P"; 82c216e5adSMichael Roth } else if (strcmp(mode, "halt") == 0) { 83c216e5adSMichael Roth shutdown_flag = "-H"; 84c216e5adSMichael Roth } else if (strcmp(mode, "reboot") == 0) { 85c216e5adSMichael Roth shutdown_flag = "-r"; 86c216e5adSMichael Roth } else { 8777dbc81bSMarkus Armbruster error_setg(errp, 88d220a6dfSLuiz Capitulino "mode is invalid (valid values are: halt|powerdown|reboot"); 89c216e5adSMichael Roth return; 90c216e5adSMichael Roth } 91c216e5adSMichael Roth 92d5dd3498SLuiz Capitulino pid = fork(); 93d5dd3498SLuiz Capitulino if (pid == 0) { 94c216e5adSMichael Roth /* child, start the shutdown */ 95c216e5adSMichael Roth setsid(); 963674838cSLuiz Capitulino reopen_fd_to_null(0); 973674838cSLuiz Capitulino reopen_fd_to_null(1); 983674838cSLuiz Capitulino reopen_fd_to_null(2); 99c216e5adSMichael Roth 100485e741cSwhitearchey execle("/sbin/shutdown", "shutdown", "-h", shutdown_flag, "+0", 1013674838cSLuiz Capitulino "hypervisor initiated shutdown", (char*)NULL, environ); 1023674838cSLuiz Capitulino _exit(EXIT_FAILURE); 103d5dd3498SLuiz Capitulino } else if (pid < 0) { 10477dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to create child process"); 105d5dd3498SLuiz Capitulino return; 106d5dd3498SLuiz Capitulino } 107d5dd3498SLuiz Capitulino 108d220a6dfSLuiz Capitulino ga_wait_child(pid, &status, &local_err); 10984d18f06SMarkus Armbruster if (local_err) { 11077dbc81bSMarkus Armbruster error_propagate(errp, local_err); 111d220a6dfSLuiz Capitulino return; 112d220a6dfSLuiz Capitulino } 113d220a6dfSLuiz Capitulino 114d220a6dfSLuiz Capitulino if (!WIFEXITED(status)) { 11577dbc81bSMarkus Armbruster error_setg(errp, "child process has terminated abnormally"); 116d220a6dfSLuiz Capitulino return; 117d220a6dfSLuiz Capitulino } 118d220a6dfSLuiz Capitulino 119d220a6dfSLuiz Capitulino if (WEXITSTATUS(status)) { 12077dbc81bSMarkus Armbruster error_setg(errp, "child process has failed to shutdown"); 121d220a6dfSLuiz Capitulino return; 122d220a6dfSLuiz Capitulino } 123d220a6dfSLuiz Capitulino 124085d8134SPeter Maydell /* succeeded */ 125c216e5adSMichael Roth } 126c216e5adSMichael Roth 1276912e6a9SLei Li int64_t qmp_guest_get_time(Error **errp) 1286912e6a9SLei Li { 1296912e6a9SLei Li int ret; 1306912e6a9SLei Li qemu_timeval tq; 1316912e6a9SLei Li 1326912e6a9SLei Li ret = qemu_gettimeofday(&tq); 1336912e6a9SLei Li if (ret < 0) { 1346912e6a9SLei Li error_setg_errno(errp, errno, "Failed to get time"); 1356912e6a9SLei Li return -1; 1366912e6a9SLei Li } 1376912e6a9SLei Li 1389be38598SEduardo Habkost return tq.tv_sec * 1000000000LL + tq.tv_usec * 1000; 1396912e6a9SLei Li } 1406912e6a9SLei Li 1412c958923SMichal Privoznik void qmp_guest_set_time(bool has_time, int64_t time_ns, Error **errp) 142a1bca57fSLei Li { 143a1bca57fSLei Li int ret; 144a1bca57fSLei Li int status; 145a1bca57fSLei Li pid_t pid; 146a1bca57fSLei Li Error *local_err = NULL; 147a1bca57fSLei Li struct timeval tv; 148a1bca57fSLei Li 1492c958923SMichal Privoznik /* If user has passed a time, validate and set it. */ 1502c958923SMichal Privoznik if (has_time) { 15100d2f370SMarc-André Lureau GDate date = { 0, }; 15200d2f370SMarc-André Lureau 153a1bca57fSLei Li /* year-2038 will overflow in case time_t is 32bit */ 154a1bca57fSLei Li if (time_ns / 1000000000 != (time_t)(time_ns / 1000000000)) { 155a1bca57fSLei Li error_setg(errp, "Time %" PRId64 " is too large", time_ns); 156a1bca57fSLei Li return; 157a1bca57fSLei Li } 158a1bca57fSLei Li 159a1bca57fSLei Li tv.tv_sec = time_ns / 1000000000; 160a1bca57fSLei Li tv.tv_usec = (time_ns % 1000000000) / 1000; 16100d2f370SMarc-André Lureau g_date_set_time_t(&date, tv.tv_sec); 16200d2f370SMarc-André Lureau if (date.year < 1970 || date.year >= 2070) { 16300d2f370SMarc-André Lureau error_setg_errno(errp, errno, "Invalid time"); 16400d2f370SMarc-André Lureau return; 16500d2f370SMarc-André Lureau } 166a1bca57fSLei Li 167a1bca57fSLei Li ret = settimeofday(&tv, NULL); 168a1bca57fSLei Li if (ret < 0) { 169a1bca57fSLei Li error_setg_errno(errp, errno, "Failed to set time to guest"); 170a1bca57fSLei Li return; 171a1bca57fSLei Li } 1722c958923SMichal Privoznik } 173a1bca57fSLei Li 1742c958923SMichal Privoznik /* Now, if user has passed a time to set and the system time is set, we 1752c958923SMichal Privoznik * just need to synchronize the hardware clock. However, if no time was 1762c958923SMichal Privoznik * passed, user is requesting the opposite: set the system time from the 1771634df56SAmos Kong * hardware clock (RTC). */ 178a1bca57fSLei Li pid = fork(); 179a1bca57fSLei Li if (pid == 0) { 180a1bca57fSLei Li setsid(); 181a1bca57fSLei Li reopen_fd_to_null(0); 182a1bca57fSLei Li reopen_fd_to_null(1); 183a1bca57fSLei Li reopen_fd_to_null(2); 184a1bca57fSLei Li 1852c958923SMichal Privoznik /* Use '/sbin/hwclock -w' to set RTC from the system time, 1862c958923SMichal Privoznik * or '/sbin/hwclock -s' to set the system time from RTC. */ 1872c958923SMichal Privoznik execle("/sbin/hwclock", "hwclock", has_time ? "-w" : "-s", 1882c958923SMichal Privoznik NULL, environ); 189a1bca57fSLei Li _exit(EXIT_FAILURE); 190a1bca57fSLei Li } else if (pid < 0) { 191a1bca57fSLei Li error_setg_errno(errp, errno, "failed to create child process"); 192a1bca57fSLei Li return; 193a1bca57fSLei Li } 194a1bca57fSLei Li 195a1bca57fSLei Li ga_wait_child(pid, &status, &local_err); 19684d18f06SMarkus Armbruster if (local_err) { 197a1bca57fSLei Li error_propagate(errp, local_err); 198a1bca57fSLei Li return; 199a1bca57fSLei Li } 200a1bca57fSLei Li 201a1bca57fSLei Li if (!WIFEXITED(status)) { 202a1bca57fSLei Li error_setg(errp, "child process has terminated abnormally"); 203a1bca57fSLei Li return; 204a1bca57fSLei Li } 205a1bca57fSLei Li 206a1bca57fSLei Li if (WEXITSTATUS(status)) { 207a1bca57fSLei Li error_setg(errp, "hwclock failed to set hardware clock to system time"); 208a1bca57fSLei Li return; 209a1bca57fSLei Li } 210a1bca57fSLei Li } 211a1bca57fSLei Li 212895b00f6SMarc-André Lureau typedef enum { 213895b00f6SMarc-André Lureau RW_STATE_NEW, 214895b00f6SMarc-André Lureau RW_STATE_READING, 215895b00f6SMarc-André Lureau RW_STATE_WRITING, 216895b00f6SMarc-André Lureau } RwState; 217895b00f6SMarc-André Lureau 218c216e5adSMichael Roth typedef struct GuestFileHandle { 219c216e5adSMichael Roth uint64_t id; 220c216e5adSMichael Roth FILE *fh; 221895b00f6SMarc-André Lureau RwState state; 222c216e5adSMichael Roth QTAILQ_ENTRY(GuestFileHandle) next; 223c216e5adSMichael Roth } GuestFileHandle; 224c216e5adSMichael Roth 225c216e5adSMichael Roth static struct { 226c216e5adSMichael Roth QTAILQ_HEAD(, GuestFileHandle) filehandles; 227b4fe97c8SDenis V. Lunev } guest_file_state = { 228b4fe97c8SDenis V. Lunev .filehandles = QTAILQ_HEAD_INITIALIZER(guest_file_state.filehandles), 229b4fe97c8SDenis V. Lunev }; 230c216e5adSMichael Roth 23139097dafSMichael Roth static int64_t guest_file_handle_add(FILE *fh, Error **errp) 232c216e5adSMichael Roth { 233c216e5adSMichael Roth GuestFileHandle *gfh; 23439097dafSMichael Roth int64_t handle; 23539097dafSMichael Roth 23639097dafSMichael Roth handle = ga_get_fd_handle(ga_state, errp); 237a903f40cSMarkus Armbruster if (handle < 0) { 238a903f40cSMarkus Armbruster return -1; 23939097dafSMichael Roth } 240c216e5adSMichael Roth 241f3a06403SMarkus Armbruster gfh = g_new0(GuestFileHandle, 1); 24239097dafSMichael Roth gfh->id = handle; 243c216e5adSMichael Roth gfh->fh = fh; 244c216e5adSMichael Roth QTAILQ_INSERT_TAIL(&guest_file_state.filehandles, gfh, next); 24539097dafSMichael Roth 24639097dafSMichael Roth return handle; 247c216e5adSMichael Roth } 248c216e5adSMichael Roth 24977dbc81bSMarkus Armbruster static GuestFileHandle *guest_file_handle_find(int64_t id, Error **errp) 250c216e5adSMichael Roth { 251c216e5adSMichael Roth GuestFileHandle *gfh; 252c216e5adSMichael Roth 253c216e5adSMichael Roth QTAILQ_FOREACH(gfh, &guest_file_state.filehandles, next) 254c216e5adSMichael Roth { 255c216e5adSMichael Roth if (gfh->id == id) { 256c216e5adSMichael Roth return gfh; 257c216e5adSMichael Roth } 258c216e5adSMichael Roth } 259c216e5adSMichael Roth 26077dbc81bSMarkus Armbruster error_setg(errp, "handle '%" PRId64 "' has not been found", id); 261c216e5adSMichael Roth return NULL; 262c216e5adSMichael Roth } 263c216e5adSMichael Roth 264c689b4f1SLaszlo Ersek typedef const char * const ccpc; 265c689b4f1SLaszlo Ersek 2668fe6bbcaSLaszlo Ersek #ifndef O_BINARY 2678fe6bbcaSLaszlo Ersek #define O_BINARY 0 2688fe6bbcaSLaszlo Ersek #endif 2698fe6bbcaSLaszlo Ersek 270c689b4f1SLaszlo Ersek /* http://pubs.opengroup.org/onlinepubs/9699919799/functions/fopen.html */ 271c689b4f1SLaszlo Ersek static const struct { 272c689b4f1SLaszlo Ersek ccpc *forms; 273c689b4f1SLaszlo Ersek int oflag_base; 274c689b4f1SLaszlo Ersek } guest_file_open_modes[] = { 2758fe6bbcaSLaszlo Ersek { (ccpc[]){ "r", NULL }, O_RDONLY }, 2768fe6bbcaSLaszlo Ersek { (ccpc[]){ "rb", NULL }, O_RDONLY | O_BINARY }, 2778fe6bbcaSLaszlo Ersek { (ccpc[]){ "w", NULL }, O_WRONLY | O_CREAT | O_TRUNC }, 2788fe6bbcaSLaszlo Ersek { (ccpc[]){ "wb", NULL }, O_WRONLY | O_CREAT | O_TRUNC | O_BINARY }, 2798fe6bbcaSLaszlo Ersek { (ccpc[]){ "a", NULL }, O_WRONLY | O_CREAT | O_APPEND }, 2808fe6bbcaSLaszlo Ersek { (ccpc[]){ "ab", NULL }, O_WRONLY | O_CREAT | O_APPEND | O_BINARY }, 2818fe6bbcaSLaszlo Ersek { (ccpc[]){ "r+", NULL }, O_RDWR }, 2828fe6bbcaSLaszlo Ersek { (ccpc[]){ "rb+", "r+b", NULL }, O_RDWR | O_BINARY }, 2838fe6bbcaSLaszlo Ersek { (ccpc[]){ "w+", NULL }, O_RDWR | O_CREAT | O_TRUNC }, 2848fe6bbcaSLaszlo Ersek { (ccpc[]){ "wb+", "w+b", NULL }, O_RDWR | O_CREAT | O_TRUNC | O_BINARY }, 2858fe6bbcaSLaszlo Ersek { (ccpc[]){ "a+", NULL }, O_RDWR | O_CREAT | O_APPEND }, 2868fe6bbcaSLaszlo Ersek { (ccpc[]){ "ab+", "a+b", NULL }, O_RDWR | O_CREAT | O_APPEND | O_BINARY } 287c689b4f1SLaszlo Ersek }; 288c689b4f1SLaszlo Ersek 289c689b4f1SLaszlo Ersek static int 29077dbc81bSMarkus Armbruster find_open_flag(const char *mode_str, Error **errp) 291c689b4f1SLaszlo Ersek { 292c689b4f1SLaszlo Ersek unsigned mode; 293c689b4f1SLaszlo Ersek 294c689b4f1SLaszlo Ersek for (mode = 0; mode < ARRAY_SIZE(guest_file_open_modes); ++mode) { 295c689b4f1SLaszlo Ersek ccpc *form; 296c689b4f1SLaszlo Ersek 297c689b4f1SLaszlo Ersek form = guest_file_open_modes[mode].forms; 298c689b4f1SLaszlo Ersek while (*form != NULL && strcmp(*form, mode_str) != 0) { 299c689b4f1SLaszlo Ersek ++form; 300c689b4f1SLaszlo Ersek } 301c689b4f1SLaszlo Ersek if (*form != NULL) { 302c689b4f1SLaszlo Ersek break; 303c689b4f1SLaszlo Ersek } 304c689b4f1SLaszlo Ersek } 305c689b4f1SLaszlo Ersek 306c689b4f1SLaszlo Ersek if (mode == ARRAY_SIZE(guest_file_open_modes)) { 30777dbc81bSMarkus Armbruster error_setg(errp, "invalid file open mode '%s'", mode_str); 308c689b4f1SLaszlo Ersek return -1; 309c689b4f1SLaszlo Ersek } 310c689b4f1SLaszlo Ersek return guest_file_open_modes[mode].oflag_base | O_NOCTTY | O_NONBLOCK; 311c689b4f1SLaszlo Ersek } 312c689b4f1SLaszlo Ersek 313c689b4f1SLaszlo Ersek #define DEFAULT_NEW_FILE_MODE (S_IRUSR | S_IWUSR | \ 314c689b4f1SLaszlo Ersek S_IRGRP | S_IWGRP | \ 315c689b4f1SLaszlo Ersek S_IROTH | S_IWOTH) 316c689b4f1SLaszlo Ersek 317c689b4f1SLaszlo Ersek static FILE * 31877dbc81bSMarkus Armbruster safe_open_or_create(const char *path, const char *mode, Error **errp) 319c689b4f1SLaszlo Ersek { 320c689b4f1SLaszlo Ersek Error *local_err = NULL; 321c689b4f1SLaszlo Ersek int oflag; 322c689b4f1SLaszlo Ersek 323c689b4f1SLaszlo Ersek oflag = find_open_flag(mode, &local_err); 324c689b4f1SLaszlo Ersek if (local_err == NULL) { 325c689b4f1SLaszlo Ersek int fd; 326c689b4f1SLaszlo Ersek 327c689b4f1SLaszlo Ersek /* If the caller wants / allows creation of a new file, we implement it 328c689b4f1SLaszlo Ersek * with a two step process: open() + (open() / fchmod()). 329c689b4f1SLaszlo Ersek * 330c689b4f1SLaszlo Ersek * First we insist on creating the file exclusively as a new file. If 331c689b4f1SLaszlo Ersek * that succeeds, we're free to set any file-mode bits on it. (The 332c689b4f1SLaszlo Ersek * motivation is that we want to set those file-mode bits independently 333c689b4f1SLaszlo Ersek * of the current umask.) 334c689b4f1SLaszlo Ersek * 335c689b4f1SLaszlo Ersek * If the exclusive creation fails because the file already exists 336c689b4f1SLaszlo Ersek * (EEXIST is not possible for any other reason), we just attempt to 337c689b4f1SLaszlo Ersek * open the file, but in this case we won't be allowed to change the 338c689b4f1SLaszlo Ersek * file-mode bits on the preexistent file. 339c689b4f1SLaszlo Ersek * 340c689b4f1SLaszlo Ersek * The pathname should never disappear between the two open()s in 341c689b4f1SLaszlo Ersek * practice. If it happens, then someone very likely tried to race us. 342c689b4f1SLaszlo Ersek * In this case just go ahead and report the ENOENT from the second 343c689b4f1SLaszlo Ersek * open() to the caller. 344c689b4f1SLaszlo Ersek * 345c689b4f1SLaszlo Ersek * If the caller wants to open a preexistent file, then the first 346c689b4f1SLaszlo Ersek * open() is decisive and its third argument is ignored, and the second 347c689b4f1SLaszlo Ersek * open() and the fchmod() are never called. 348c689b4f1SLaszlo Ersek */ 349c689b4f1SLaszlo Ersek fd = open(path, oflag | ((oflag & O_CREAT) ? O_EXCL : 0), 0); 350c689b4f1SLaszlo Ersek if (fd == -1 && errno == EEXIST) { 351c689b4f1SLaszlo Ersek oflag &= ~(unsigned)O_CREAT; 352c689b4f1SLaszlo Ersek fd = open(path, oflag); 353c689b4f1SLaszlo Ersek } 354c689b4f1SLaszlo Ersek 355c689b4f1SLaszlo Ersek if (fd == -1) { 356c689b4f1SLaszlo Ersek error_setg_errno(&local_err, errno, "failed to open file '%s' " 357c689b4f1SLaszlo Ersek "(mode: '%s')", path, mode); 358c689b4f1SLaszlo Ersek } else { 359c689b4f1SLaszlo Ersek qemu_set_cloexec(fd); 360c689b4f1SLaszlo Ersek 361c689b4f1SLaszlo Ersek if ((oflag & O_CREAT) && fchmod(fd, DEFAULT_NEW_FILE_MODE) == -1) { 362c689b4f1SLaszlo Ersek error_setg_errno(&local_err, errno, "failed to set permission " 363c689b4f1SLaszlo Ersek "0%03o on new file '%s' (mode: '%s')", 364c689b4f1SLaszlo Ersek (unsigned)DEFAULT_NEW_FILE_MODE, path, mode); 365c689b4f1SLaszlo Ersek } else { 366c689b4f1SLaszlo Ersek FILE *f; 367c689b4f1SLaszlo Ersek 368c689b4f1SLaszlo Ersek f = fdopen(fd, mode); 369c689b4f1SLaszlo Ersek if (f == NULL) { 370c689b4f1SLaszlo Ersek error_setg_errno(&local_err, errno, "failed to associate " 371c689b4f1SLaszlo Ersek "stdio stream with file descriptor %d, " 372c689b4f1SLaszlo Ersek "file '%s' (mode: '%s')", fd, path, mode); 373c689b4f1SLaszlo Ersek } else { 374c689b4f1SLaszlo Ersek return f; 375c689b4f1SLaszlo Ersek } 376c689b4f1SLaszlo Ersek } 377c689b4f1SLaszlo Ersek 378c689b4f1SLaszlo Ersek close(fd); 3792b720018SLaszlo Ersek if (oflag & O_CREAT) { 3802b720018SLaszlo Ersek unlink(path); 3812b720018SLaszlo Ersek } 382c689b4f1SLaszlo Ersek } 383c689b4f1SLaszlo Ersek } 384c689b4f1SLaszlo Ersek 38577dbc81bSMarkus Armbruster error_propagate(errp, local_err); 386c689b4f1SLaszlo Ersek return NULL; 387c689b4f1SLaszlo Ersek } 388c689b4f1SLaszlo Ersek 38977dbc81bSMarkus Armbruster int64_t qmp_guest_file_open(const char *path, bool has_mode, const char *mode, 39077dbc81bSMarkus Armbruster Error **errp) 391c216e5adSMichael Roth { 392c216e5adSMichael Roth FILE *fh; 393c689b4f1SLaszlo Ersek Error *local_err = NULL; 39485b6f6f5SSimon Zolin int64_t handle; 395c216e5adSMichael Roth 396c216e5adSMichael Roth if (!has_mode) { 397c216e5adSMichael Roth mode = "r"; 398c216e5adSMichael Roth } 399c216e5adSMichael Roth slog("guest-file-open called, filepath: %s, mode: %s", path, mode); 400c689b4f1SLaszlo Ersek fh = safe_open_or_create(path, mode, &local_err); 401c689b4f1SLaszlo Ersek if (local_err != NULL) { 40277dbc81bSMarkus Armbruster error_propagate(errp, local_err); 403c216e5adSMichael Roth return -1; 404c216e5adSMichael Roth } 405c216e5adSMichael Roth 406c216e5adSMichael Roth /* set fd non-blocking to avoid common use cases (like reading from a 407c216e5adSMichael Roth * named pipe) from hanging the agent 408c216e5adSMichael Roth */ 40912505396SDenis V. Lunev qemu_set_nonblock(fileno(fh)); 410c216e5adSMichael Roth 41177dbc81bSMarkus Armbruster handle = guest_file_handle_add(fh, errp); 412a903f40cSMarkus Armbruster if (handle < 0) { 41339097dafSMichael Roth fclose(fh); 41439097dafSMichael Roth return -1; 41539097dafSMichael Roth } 41639097dafSMichael Roth 417d607a523SStefan Weil slog("guest-file-open, handle: %" PRId64, handle); 41839097dafSMichael Roth return handle; 419c216e5adSMichael Roth } 420c216e5adSMichael Roth 42177dbc81bSMarkus Armbruster void qmp_guest_file_close(int64_t handle, Error **errp) 422c216e5adSMichael Roth { 42377dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 424c216e5adSMichael Roth int ret; 425c216e5adSMichael Roth 426d607a523SStefan Weil slog("guest-file-close called, handle: %" PRId64, handle); 427c216e5adSMichael Roth if (!gfh) { 428c216e5adSMichael Roth return; 429c216e5adSMichael Roth } 430c216e5adSMichael Roth 431c216e5adSMichael Roth ret = fclose(gfh->fh); 4323ac4b7c5SLuiz Capitulino if (ret == EOF) { 43377dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to close handle"); 434c216e5adSMichael Roth return; 435c216e5adSMichael Roth } 436c216e5adSMichael Roth 437c216e5adSMichael Roth QTAILQ_REMOVE(&guest_file_state.filehandles, gfh, next); 438c216e5adSMichael Roth g_free(gfh); 439c216e5adSMichael Roth } 440c216e5adSMichael Roth 441c216e5adSMichael Roth struct GuestFileRead *qmp_guest_file_read(int64_t handle, bool has_count, 44277dbc81bSMarkus Armbruster int64_t count, Error **errp) 443c216e5adSMichael Roth { 44477dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 445c216e5adSMichael Roth GuestFileRead *read_data = NULL; 446c216e5adSMichael Roth guchar *buf; 447c216e5adSMichael Roth FILE *fh; 448c216e5adSMichael Roth size_t read_count; 449c216e5adSMichael Roth 450c216e5adSMichael Roth if (!gfh) { 451c216e5adSMichael Roth return NULL; 452c216e5adSMichael Roth } 453c216e5adSMichael Roth 454c216e5adSMichael Roth if (!has_count) { 455c216e5adSMichael Roth count = QGA_READ_COUNT_DEFAULT; 456c216e5adSMichael Roth } else if (count < 0) { 45777dbc81bSMarkus Armbruster error_setg(errp, "value '%" PRId64 "' is invalid for argument count", 458db3edb66SLuiz Capitulino count); 459c216e5adSMichael Roth return NULL; 460c216e5adSMichael Roth } 461c216e5adSMichael Roth 462c216e5adSMichael Roth fh = gfh->fh; 463895b00f6SMarc-André Lureau 464895b00f6SMarc-André Lureau /* explicitly flush when switching from writing to reading */ 465895b00f6SMarc-André Lureau if (gfh->state == RW_STATE_WRITING) { 466895b00f6SMarc-André Lureau int ret = fflush(fh); 467895b00f6SMarc-André Lureau if (ret == EOF) { 468895b00f6SMarc-André Lureau error_setg_errno(errp, errno, "failed to flush file"); 469895b00f6SMarc-André Lureau return NULL; 470895b00f6SMarc-André Lureau } 471895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 472895b00f6SMarc-André Lureau } 473895b00f6SMarc-André Lureau 474c216e5adSMichael Roth buf = g_malloc0(count+1); 475c216e5adSMichael Roth read_count = fread(buf, 1, count, fh); 476c216e5adSMichael Roth if (ferror(fh)) { 47777dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to read file"); 478d607a523SStefan Weil slog("guest-file-read failed, handle: %" PRId64, handle); 479c216e5adSMichael Roth } else { 480c216e5adSMichael Roth buf[read_count] = 0; 481f3a06403SMarkus Armbruster read_data = g_new0(GuestFileRead, 1); 482c216e5adSMichael Roth read_data->count = read_count; 483c216e5adSMichael Roth read_data->eof = feof(fh); 484c216e5adSMichael Roth if (read_count) { 485c216e5adSMichael Roth read_data->buf_b64 = g_base64_encode(buf, read_count); 486c216e5adSMichael Roth } 487895b00f6SMarc-André Lureau gfh->state = RW_STATE_READING; 488c216e5adSMichael Roth } 489c216e5adSMichael Roth g_free(buf); 490c216e5adSMichael Roth clearerr(fh); 491c216e5adSMichael Roth 492c216e5adSMichael Roth return read_data; 493c216e5adSMichael Roth } 494c216e5adSMichael Roth 495c216e5adSMichael Roth GuestFileWrite *qmp_guest_file_write(int64_t handle, const char *buf_b64, 49677dbc81bSMarkus Armbruster bool has_count, int64_t count, 49777dbc81bSMarkus Armbruster Error **errp) 498c216e5adSMichael Roth { 499c216e5adSMichael Roth GuestFileWrite *write_data = NULL; 500c216e5adSMichael Roth guchar *buf; 501c216e5adSMichael Roth gsize buf_len; 502c216e5adSMichael Roth int write_count; 50377dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 504c216e5adSMichael Roth FILE *fh; 505c216e5adSMichael Roth 506c216e5adSMichael Roth if (!gfh) { 507c216e5adSMichael Roth return NULL; 508c216e5adSMichael Roth } 509c216e5adSMichael Roth 510c216e5adSMichael Roth fh = gfh->fh; 511895b00f6SMarc-André Lureau 512895b00f6SMarc-André Lureau if (gfh->state == RW_STATE_READING) { 513895b00f6SMarc-André Lureau int ret = fseek(fh, 0, SEEK_CUR); 514895b00f6SMarc-André Lureau if (ret == -1) { 515895b00f6SMarc-André Lureau error_setg_errno(errp, errno, "failed to seek file"); 516895b00f6SMarc-André Lureau return NULL; 517895b00f6SMarc-André Lureau } 518895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 519895b00f6SMarc-André Lureau } 520895b00f6SMarc-André Lureau 521920639caSDaniel P. Berrange buf = qbase64_decode(buf_b64, -1, &buf_len, errp); 522920639caSDaniel P. Berrange if (!buf) { 523920639caSDaniel P. Berrange return NULL; 524920639caSDaniel P. Berrange } 525c216e5adSMichael Roth 526c216e5adSMichael Roth if (!has_count) { 527c216e5adSMichael Roth count = buf_len; 528c216e5adSMichael Roth } else if (count < 0 || count > buf_len) { 52977dbc81bSMarkus Armbruster error_setg(errp, "value '%" PRId64 "' is invalid for argument count", 530db3edb66SLuiz Capitulino count); 531c216e5adSMichael Roth g_free(buf); 532c216e5adSMichael Roth return NULL; 533c216e5adSMichael Roth } 534c216e5adSMichael Roth 535c216e5adSMichael Roth write_count = fwrite(buf, 1, count, fh); 536c216e5adSMichael Roth if (ferror(fh)) { 53777dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to write to file"); 538d607a523SStefan Weil slog("guest-file-write failed, handle: %" PRId64, handle); 539c216e5adSMichael Roth } else { 540f3a06403SMarkus Armbruster write_data = g_new0(GuestFileWrite, 1); 541c216e5adSMichael Roth write_data->count = write_count; 542c216e5adSMichael Roth write_data->eof = feof(fh); 543895b00f6SMarc-André Lureau gfh->state = RW_STATE_WRITING; 544c216e5adSMichael Roth } 545c216e5adSMichael Roth g_free(buf); 546c216e5adSMichael Roth clearerr(fh); 547c216e5adSMichael Roth 548c216e5adSMichael Roth return write_data; 549c216e5adSMichael Roth } 550c216e5adSMichael Roth 551c216e5adSMichael Roth struct GuestFileSeek *qmp_guest_file_seek(int64_t handle, int64_t offset, 5520b4b4938SEric Blake GuestFileWhence *whence_code, 5530b4b4938SEric Blake Error **errp) 554c216e5adSMichael Roth { 55577dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 556c216e5adSMichael Roth GuestFileSeek *seek_data = NULL; 557c216e5adSMichael Roth FILE *fh; 558c216e5adSMichael Roth int ret; 5590a982b1bSEric Blake int whence; 5600b4b4938SEric Blake Error *err = NULL; 561c216e5adSMichael Roth 562c216e5adSMichael Roth if (!gfh) { 563c216e5adSMichael Roth return NULL; 564c216e5adSMichael Roth } 565c216e5adSMichael Roth 5660a982b1bSEric Blake /* We stupidly exposed 'whence':'int' in our qapi */ 5670b4b4938SEric Blake whence = ga_parse_whence(whence_code, &err); 5680b4b4938SEric Blake if (err) { 5690b4b4938SEric Blake error_propagate(errp, err); 5700a982b1bSEric Blake return NULL; 5710a982b1bSEric Blake } 5720a982b1bSEric Blake 573c216e5adSMichael Roth fh = gfh->fh; 574c216e5adSMichael Roth ret = fseek(fh, offset, whence); 575c216e5adSMichael Roth if (ret == -1) { 57677dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to seek file"); 577895b00f6SMarc-André Lureau if (errno == ESPIPE) { 578895b00f6SMarc-André Lureau /* file is non-seekable, stdio shouldn't be buffering anyways */ 579895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 580895b00f6SMarc-André Lureau } 581c216e5adSMichael Roth } else { 58210b7c5ddSMarkus Armbruster seek_data = g_new0(GuestFileSeek, 1); 583c216e5adSMichael Roth seek_data->position = ftell(fh); 584c216e5adSMichael Roth seek_data->eof = feof(fh); 585895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 586c216e5adSMichael Roth } 587c216e5adSMichael Roth clearerr(fh); 588c216e5adSMichael Roth 589c216e5adSMichael Roth return seek_data; 590c216e5adSMichael Roth } 591c216e5adSMichael Roth 59277dbc81bSMarkus Armbruster void qmp_guest_file_flush(int64_t handle, Error **errp) 593c216e5adSMichael Roth { 59477dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 595c216e5adSMichael Roth FILE *fh; 596c216e5adSMichael Roth int ret; 597c216e5adSMichael Roth 598c216e5adSMichael Roth if (!gfh) { 599c216e5adSMichael Roth return; 600c216e5adSMichael Roth } 601c216e5adSMichael Roth 602c216e5adSMichael Roth fh = gfh->fh; 603c216e5adSMichael Roth ret = fflush(fh); 604c216e5adSMichael Roth if (ret == EOF) { 60577dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to flush file"); 606895b00f6SMarc-André Lureau } else { 607895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 608c216e5adSMichael Roth } 609c216e5adSMichael Roth } 610c216e5adSMichael Roth 611e72c3f2eSMichael Roth /* linux-specific implementations. avoid this if at all possible. */ 612e72c3f2eSMichael Roth #if defined(__linux__) 613e72c3f2eSMichael Roth 614eab5fd59SPaolo Bonzini #if defined(CONFIG_FSFREEZE) || defined(CONFIG_FSTRIM) 615af02203fSPaolo Bonzini typedef struct FsMount { 616c216e5adSMichael Roth char *dirname; 617c216e5adSMichael Roth char *devtype; 61846d4c572STomoki Sekiyama unsigned int devmajor, devminor; 619af02203fSPaolo Bonzini QTAILQ_ENTRY(FsMount) next; 620af02203fSPaolo Bonzini } FsMount; 621c216e5adSMichael Roth 622e5d9adbdSTomoki Sekiyama typedef QTAILQ_HEAD(FsMountList, FsMount) FsMountList; 6239e8aded4SMichael Roth 624af02203fSPaolo Bonzini static void free_fs_mount_list(FsMountList *mounts) 625c216e5adSMichael Roth { 626af02203fSPaolo Bonzini FsMount *mount, *temp; 627c216e5adSMichael Roth 6289e8aded4SMichael Roth if (!mounts) { 6299e8aded4SMichael Roth return; 6309e8aded4SMichael Roth } 6319e8aded4SMichael Roth 6329e8aded4SMichael Roth QTAILQ_FOREACH_SAFE(mount, mounts, next, temp) { 6339e8aded4SMichael Roth QTAILQ_REMOVE(mounts, mount, next); 634c216e5adSMichael Roth g_free(mount->dirname); 635c216e5adSMichael Roth g_free(mount->devtype); 636c216e5adSMichael Roth g_free(mount); 637c216e5adSMichael Roth } 6389e8aded4SMichael Roth } 6399e8aded4SMichael Roth 64046d4c572STomoki Sekiyama static int dev_major_minor(const char *devpath, 64146d4c572STomoki Sekiyama unsigned int *devmajor, unsigned int *devminor) 64246d4c572STomoki Sekiyama { 64346d4c572STomoki Sekiyama struct stat st; 64446d4c572STomoki Sekiyama 64546d4c572STomoki Sekiyama *devmajor = 0; 64646d4c572STomoki Sekiyama *devminor = 0; 64746d4c572STomoki Sekiyama 64846d4c572STomoki Sekiyama if (stat(devpath, &st) < 0) { 64946d4c572STomoki Sekiyama slog("failed to stat device file '%s': %s", devpath, strerror(errno)); 65046d4c572STomoki Sekiyama return -1; 65146d4c572STomoki Sekiyama } 65246d4c572STomoki Sekiyama if (S_ISDIR(st.st_mode)) { 65346d4c572STomoki Sekiyama /* It is bind mount */ 65446d4c572STomoki Sekiyama return -2; 65546d4c572STomoki Sekiyama } 65646d4c572STomoki Sekiyama if (S_ISBLK(st.st_mode)) { 65746d4c572STomoki Sekiyama *devmajor = major(st.st_rdev); 65846d4c572STomoki Sekiyama *devminor = minor(st.st_rdev); 65946d4c572STomoki Sekiyama return 0; 66046d4c572STomoki Sekiyama } 66146d4c572STomoki Sekiyama return -1; 66246d4c572STomoki Sekiyama } 66346d4c572STomoki Sekiyama 6649e8aded4SMichael Roth /* 6659e8aded4SMichael Roth * Walk the mount table and build a list of local file systems 6669e8aded4SMichael Roth */ 66746d4c572STomoki Sekiyama static void build_fs_mount_list_from_mtab(FsMountList *mounts, Error **errp) 6689e8aded4SMichael Roth { 6699e8aded4SMichael Roth struct mntent *ment; 670af02203fSPaolo Bonzini FsMount *mount; 6719e2fa418SMichael Roth char const *mtab = "/proc/self/mounts"; 6729e8aded4SMichael Roth FILE *fp; 67346d4c572STomoki Sekiyama unsigned int devmajor, devminor; 674c216e5adSMichael Roth 675c216e5adSMichael Roth fp = setmntent(mtab, "r"); 676c216e5adSMichael Roth if (!fp) { 67777dbc81bSMarkus Armbruster error_setg(errp, "failed to open mtab file: '%s'", mtab); 678261551d1SLuiz Capitulino return; 679c216e5adSMichael Roth } 680c216e5adSMichael Roth 681c216e5adSMichael Roth while ((ment = getmntent(fp))) { 682c216e5adSMichael Roth /* 683c216e5adSMichael Roth * An entry which device name doesn't start with a '/' is 684c216e5adSMichael Roth * either a dummy file system or a network file system. 685c216e5adSMichael Roth * Add special handling for smbfs and cifs as is done by 686c216e5adSMichael Roth * coreutils as well. 687c216e5adSMichael Roth */ 688c216e5adSMichael Roth if ((ment->mnt_fsname[0] != '/') || 689c216e5adSMichael Roth (strcmp(ment->mnt_type, "smbfs") == 0) || 690c216e5adSMichael Roth (strcmp(ment->mnt_type, "cifs") == 0)) { 691c216e5adSMichael Roth continue; 692c216e5adSMichael Roth } 69346d4c572STomoki Sekiyama if (dev_major_minor(ment->mnt_fsname, &devmajor, &devminor) == -2) { 69446d4c572STomoki Sekiyama /* Skip bind mounts */ 69546d4c572STomoki Sekiyama continue; 69646d4c572STomoki Sekiyama } 697c216e5adSMichael Roth 698f3a06403SMarkus Armbruster mount = g_new0(FsMount, 1); 699c216e5adSMichael Roth mount->dirname = g_strdup(ment->mnt_dir); 700c216e5adSMichael Roth mount->devtype = g_strdup(ment->mnt_type); 70146d4c572STomoki Sekiyama mount->devmajor = devmajor; 70246d4c572STomoki Sekiyama mount->devminor = devminor; 703c216e5adSMichael Roth 7049e8aded4SMichael Roth QTAILQ_INSERT_TAIL(mounts, mount, next); 705c216e5adSMichael Roth } 706c216e5adSMichael Roth 707c216e5adSMichael Roth endmntent(fp); 708c216e5adSMichael Roth } 70946d4c572STomoki Sekiyama 71046d4c572STomoki Sekiyama static void decode_mntname(char *name, int len) 71146d4c572STomoki Sekiyama { 71246d4c572STomoki Sekiyama int i, j = 0; 71346d4c572STomoki Sekiyama for (i = 0; i <= len; i++) { 71446d4c572STomoki Sekiyama if (name[i] != '\\') { 71546d4c572STomoki Sekiyama name[j++] = name[i]; 71646d4c572STomoki Sekiyama } else if (name[i + 1] == '\\') { 71746d4c572STomoki Sekiyama name[j++] = '\\'; 71846d4c572STomoki Sekiyama i++; 71946d4c572STomoki Sekiyama } else if (name[i + 1] >= '0' && name[i + 1] <= '3' && 72046d4c572STomoki Sekiyama name[i + 2] >= '0' && name[i + 2] <= '7' && 72146d4c572STomoki Sekiyama name[i + 3] >= '0' && name[i + 3] <= '7') { 72246d4c572STomoki Sekiyama name[j++] = (name[i + 1] - '0') * 64 + 72346d4c572STomoki Sekiyama (name[i + 2] - '0') * 8 + 72446d4c572STomoki Sekiyama (name[i + 3] - '0'); 72546d4c572STomoki Sekiyama i += 3; 72646d4c572STomoki Sekiyama } else { 72746d4c572STomoki Sekiyama name[j++] = name[i]; 72846d4c572STomoki Sekiyama } 72946d4c572STomoki Sekiyama } 73046d4c572STomoki Sekiyama } 73146d4c572STomoki Sekiyama 73246d4c572STomoki Sekiyama static void build_fs_mount_list(FsMountList *mounts, Error **errp) 73346d4c572STomoki Sekiyama { 73446d4c572STomoki Sekiyama FsMount *mount; 73546d4c572STomoki Sekiyama char const *mountinfo = "/proc/self/mountinfo"; 73646d4c572STomoki Sekiyama FILE *fp; 73746d4c572STomoki Sekiyama char *line = NULL, *dash; 73846d4c572STomoki Sekiyama size_t n; 73946d4c572STomoki Sekiyama char check; 74046d4c572STomoki Sekiyama unsigned int devmajor, devminor; 74146d4c572STomoki Sekiyama int ret, dir_s, dir_e, type_s, type_e, dev_s, dev_e; 74246d4c572STomoki Sekiyama 74346d4c572STomoki Sekiyama fp = fopen(mountinfo, "r"); 74446d4c572STomoki Sekiyama if (!fp) { 74546d4c572STomoki Sekiyama build_fs_mount_list_from_mtab(mounts, errp); 74646d4c572STomoki Sekiyama return; 74746d4c572STomoki Sekiyama } 74846d4c572STomoki Sekiyama 74946d4c572STomoki Sekiyama while (getline(&line, &n, fp) != -1) { 75046d4c572STomoki Sekiyama ret = sscanf(line, "%*u %*u %u:%u %*s %n%*s%n%c", 75146d4c572STomoki Sekiyama &devmajor, &devminor, &dir_s, &dir_e, &check); 75246d4c572STomoki Sekiyama if (ret < 3) { 75346d4c572STomoki Sekiyama continue; 75446d4c572STomoki Sekiyama } 75546d4c572STomoki Sekiyama dash = strstr(line + dir_e, " - "); 75646d4c572STomoki Sekiyama if (!dash) { 75746d4c572STomoki Sekiyama continue; 75846d4c572STomoki Sekiyama } 75946d4c572STomoki Sekiyama ret = sscanf(dash, " - %n%*s%n %n%*s%n%c", 76046d4c572STomoki Sekiyama &type_s, &type_e, &dev_s, &dev_e, &check); 76146d4c572STomoki Sekiyama if (ret < 1) { 76246d4c572STomoki Sekiyama continue; 76346d4c572STomoki Sekiyama } 76446d4c572STomoki Sekiyama line[dir_e] = 0; 76546d4c572STomoki Sekiyama dash[type_e] = 0; 76646d4c572STomoki Sekiyama dash[dev_e] = 0; 76746d4c572STomoki Sekiyama decode_mntname(line + dir_s, dir_e - dir_s); 76846d4c572STomoki Sekiyama decode_mntname(dash + dev_s, dev_e - dev_s); 76946d4c572STomoki Sekiyama if (devmajor == 0) { 77046d4c572STomoki Sekiyama /* btrfs reports major number = 0 */ 77146d4c572STomoki Sekiyama if (strcmp("btrfs", dash + type_s) != 0 || 77246d4c572STomoki Sekiyama dev_major_minor(dash + dev_s, &devmajor, &devminor) < 0) { 77346d4c572STomoki Sekiyama continue; 77446d4c572STomoki Sekiyama } 77546d4c572STomoki Sekiyama } 77646d4c572STomoki Sekiyama 777f3a06403SMarkus Armbruster mount = g_new0(FsMount, 1); 77846d4c572STomoki Sekiyama mount->dirname = g_strdup(line + dir_s); 77946d4c572STomoki Sekiyama mount->devtype = g_strdup(dash + type_s); 78046d4c572STomoki Sekiyama mount->devmajor = devmajor; 78146d4c572STomoki Sekiyama mount->devminor = devminor; 78246d4c572STomoki Sekiyama 78346d4c572STomoki Sekiyama QTAILQ_INSERT_TAIL(mounts, mount, next); 78446d4c572STomoki Sekiyama } 78546d4c572STomoki Sekiyama free(line); 78646d4c572STomoki Sekiyama 78746d4c572STomoki Sekiyama fclose(fp); 78846d4c572STomoki Sekiyama } 789eab5fd59SPaolo Bonzini #endif 790eab5fd59SPaolo Bonzini 791eab5fd59SPaolo Bonzini #if defined(CONFIG_FSFREEZE) 792c216e5adSMichael Roth 79346d4c572STomoki Sekiyama static char *get_pci_driver(char const *syspath, int pathlen, Error **errp) 79446d4c572STomoki Sekiyama { 79546d4c572STomoki Sekiyama char *path; 79646d4c572STomoki Sekiyama char *dpath; 79746d4c572STomoki Sekiyama char *driver = NULL; 79846d4c572STomoki Sekiyama char buf[PATH_MAX]; 79946d4c572STomoki Sekiyama ssize_t len; 80046d4c572STomoki Sekiyama 80146d4c572STomoki Sekiyama path = g_strndup(syspath, pathlen); 80246d4c572STomoki Sekiyama dpath = g_strdup_printf("%s/driver", path); 80346d4c572STomoki Sekiyama len = readlink(dpath, buf, sizeof(buf) - 1); 80446d4c572STomoki Sekiyama if (len != -1) { 80546d4c572STomoki Sekiyama buf[len] = 0; 80646d4c572STomoki Sekiyama driver = g_strdup(basename(buf)); 80746d4c572STomoki Sekiyama } 80846d4c572STomoki Sekiyama g_free(dpath); 80946d4c572STomoki Sekiyama g_free(path); 81046d4c572STomoki Sekiyama return driver; 81146d4c572STomoki Sekiyama } 81246d4c572STomoki Sekiyama 81346d4c572STomoki Sekiyama static int compare_uint(const void *_a, const void *_b) 81446d4c572STomoki Sekiyama { 81546d4c572STomoki Sekiyama unsigned int a = *(unsigned int *)_a; 81646d4c572STomoki Sekiyama unsigned int b = *(unsigned int *)_b; 81746d4c572STomoki Sekiyama 81846d4c572STomoki Sekiyama return a < b ? -1 : a > b ? 1 : 0; 81946d4c572STomoki Sekiyama } 82046d4c572STomoki Sekiyama 82146d4c572STomoki Sekiyama /* Walk the specified sysfs and build a sorted list of host or ata numbers */ 82246d4c572STomoki Sekiyama static int build_hosts(char const *syspath, char const *host, bool ata, 82346d4c572STomoki Sekiyama unsigned int *hosts, int hosts_max, Error **errp) 82446d4c572STomoki Sekiyama { 82546d4c572STomoki Sekiyama char *path; 82646d4c572STomoki Sekiyama DIR *dir; 82746d4c572STomoki Sekiyama struct dirent *entry; 82846d4c572STomoki Sekiyama int i = 0; 82946d4c572STomoki Sekiyama 83046d4c572STomoki Sekiyama path = g_strndup(syspath, host - syspath); 83146d4c572STomoki Sekiyama dir = opendir(path); 83246d4c572STomoki Sekiyama if (!dir) { 83346d4c572STomoki Sekiyama error_setg_errno(errp, errno, "opendir(\"%s\")", path); 83446d4c572STomoki Sekiyama g_free(path); 83546d4c572STomoki Sekiyama return -1; 83646d4c572STomoki Sekiyama } 83746d4c572STomoki Sekiyama 83846d4c572STomoki Sekiyama while (i < hosts_max) { 83946d4c572STomoki Sekiyama entry = readdir(dir); 84046d4c572STomoki Sekiyama if (!entry) { 84146d4c572STomoki Sekiyama break; 84246d4c572STomoki Sekiyama } 84346d4c572STomoki Sekiyama if (ata && sscanf(entry->d_name, "ata%d", hosts + i) == 1) { 84446d4c572STomoki Sekiyama ++i; 84546d4c572STomoki Sekiyama } else if (!ata && sscanf(entry->d_name, "host%d", hosts + i) == 1) { 84646d4c572STomoki Sekiyama ++i; 84746d4c572STomoki Sekiyama } 84846d4c572STomoki Sekiyama } 84946d4c572STomoki Sekiyama 85046d4c572STomoki Sekiyama qsort(hosts, i, sizeof(hosts[0]), compare_uint); 85146d4c572STomoki Sekiyama 85246d4c572STomoki Sekiyama g_free(path); 85346d4c572STomoki Sekiyama closedir(dir); 85446d4c572STomoki Sekiyama return i; 85546d4c572STomoki Sekiyama } 85646d4c572STomoki Sekiyama 85746d4c572STomoki Sekiyama /* Store disk device info specified by @sysfs into @fs */ 85846d4c572STomoki Sekiyama static void build_guest_fsinfo_for_real_device(char const *syspath, 85946d4c572STomoki Sekiyama GuestFilesystemInfo *fs, 86046d4c572STomoki Sekiyama Error **errp) 86146d4c572STomoki Sekiyama { 86246d4c572STomoki Sekiyama unsigned int pci[4], host, hosts[8], tgt[3]; 86346d4c572STomoki Sekiyama int i, nhosts = 0, pcilen; 86446d4c572STomoki Sekiyama GuestDiskAddress *disk; 86546d4c572STomoki Sekiyama GuestPCIAddress *pciaddr; 86646d4c572STomoki Sekiyama GuestDiskAddressList *list = NULL; 86746d4c572STomoki Sekiyama bool has_ata = false, has_host = false, has_tgt = false; 86846d4c572STomoki Sekiyama char *p, *q, *driver = NULL; 86946d4c572STomoki Sekiyama 87046d4c572STomoki Sekiyama p = strstr(syspath, "/devices/pci"); 87146d4c572STomoki Sekiyama if (!p || sscanf(p + 12, "%*x:%*x/%x:%x:%x.%x%n", 87246d4c572STomoki Sekiyama pci, pci + 1, pci + 2, pci + 3, &pcilen) < 4) { 87346d4c572STomoki Sekiyama g_debug("only pci device is supported: sysfs path \"%s\"", syspath); 87446d4c572STomoki Sekiyama return; 87546d4c572STomoki Sekiyama } 87646d4c572STomoki Sekiyama 87746d4c572STomoki Sekiyama driver = get_pci_driver(syspath, (p + 12 + pcilen) - syspath, errp); 87846d4c572STomoki Sekiyama if (!driver) { 87946d4c572STomoki Sekiyama goto cleanup; 88046d4c572STomoki Sekiyama } 88146d4c572STomoki Sekiyama 88246d4c572STomoki Sekiyama p = strstr(syspath, "/target"); 88346d4c572STomoki Sekiyama if (p && sscanf(p + 7, "%*u:%*u:%*u/%*u:%u:%u:%u", 88446d4c572STomoki Sekiyama tgt, tgt + 1, tgt + 2) == 3) { 88546d4c572STomoki Sekiyama has_tgt = true; 88646d4c572STomoki Sekiyama } 88746d4c572STomoki Sekiyama 88846d4c572STomoki Sekiyama p = strstr(syspath, "/ata"); 88946d4c572STomoki Sekiyama if (p) { 89046d4c572STomoki Sekiyama q = p + 4; 89146d4c572STomoki Sekiyama has_ata = true; 89246d4c572STomoki Sekiyama } else { 89346d4c572STomoki Sekiyama p = strstr(syspath, "/host"); 89446d4c572STomoki Sekiyama q = p + 5; 89546d4c572STomoki Sekiyama } 89646d4c572STomoki Sekiyama if (p && sscanf(q, "%u", &host) == 1) { 89746d4c572STomoki Sekiyama has_host = true; 89846d4c572STomoki Sekiyama nhosts = build_hosts(syspath, p, has_ata, hosts, 89946d4c572STomoki Sekiyama sizeof(hosts) / sizeof(hosts[0]), errp); 90046d4c572STomoki Sekiyama if (nhosts < 0) { 90146d4c572STomoki Sekiyama goto cleanup; 90246d4c572STomoki Sekiyama } 90346d4c572STomoki Sekiyama } 90446d4c572STomoki Sekiyama 90546d4c572STomoki Sekiyama pciaddr = g_malloc0(sizeof(*pciaddr)); 90646d4c572STomoki Sekiyama pciaddr->domain = pci[0]; 90746d4c572STomoki Sekiyama pciaddr->bus = pci[1]; 90846d4c572STomoki Sekiyama pciaddr->slot = pci[2]; 90946d4c572STomoki Sekiyama pciaddr->function = pci[3]; 91046d4c572STomoki Sekiyama 91146d4c572STomoki Sekiyama disk = g_malloc0(sizeof(*disk)); 91246d4c572STomoki Sekiyama disk->pci_controller = pciaddr; 91346d4c572STomoki Sekiyama 91446d4c572STomoki Sekiyama list = g_malloc0(sizeof(*list)); 91546d4c572STomoki Sekiyama list->value = disk; 91646d4c572STomoki Sekiyama 91746d4c572STomoki Sekiyama if (strcmp(driver, "ata_piix") == 0) { 91846d4c572STomoki Sekiyama /* a host per ide bus, target*:0:<unit>:0 */ 91946d4c572STomoki Sekiyama if (!has_host || !has_tgt) { 92046d4c572STomoki Sekiyama g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver); 92146d4c572STomoki Sekiyama goto cleanup; 92246d4c572STomoki Sekiyama } 92346d4c572STomoki Sekiyama for (i = 0; i < nhosts; i++) { 92446d4c572STomoki Sekiyama if (host == hosts[i]) { 92546d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_IDE; 92646d4c572STomoki Sekiyama disk->bus = i; 92746d4c572STomoki Sekiyama disk->unit = tgt[1]; 92846d4c572STomoki Sekiyama break; 92946d4c572STomoki Sekiyama } 93046d4c572STomoki Sekiyama } 93146d4c572STomoki Sekiyama if (i >= nhosts) { 93246d4c572STomoki Sekiyama g_debug("no host for '%s' (driver '%s')", syspath, driver); 93346d4c572STomoki Sekiyama goto cleanup; 93446d4c572STomoki Sekiyama } 93546d4c572STomoki Sekiyama } else if (strcmp(driver, "sym53c8xx") == 0) { 93646d4c572STomoki Sekiyama /* scsi(LSI Logic): target*:0:<unit>:0 */ 93746d4c572STomoki Sekiyama if (!has_tgt) { 93846d4c572STomoki Sekiyama g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver); 93946d4c572STomoki Sekiyama goto cleanup; 94046d4c572STomoki Sekiyama } 94146d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI; 94246d4c572STomoki Sekiyama disk->unit = tgt[1]; 94346d4c572STomoki Sekiyama } else if (strcmp(driver, "virtio-pci") == 0) { 94446d4c572STomoki Sekiyama if (has_tgt) { 94546d4c572STomoki Sekiyama /* virtio-scsi: target*:0:0:<unit> */ 94646d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI; 94746d4c572STomoki Sekiyama disk->unit = tgt[2]; 94846d4c572STomoki Sekiyama } else { 94946d4c572STomoki Sekiyama /* virtio-blk: 1 disk per 1 device */ 95046d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_VIRTIO; 95146d4c572STomoki Sekiyama } 95246d4c572STomoki Sekiyama } else if (strcmp(driver, "ahci") == 0) { 95346d4c572STomoki Sekiyama /* ahci: 1 host per 1 unit */ 95446d4c572STomoki Sekiyama if (!has_host || !has_tgt) { 95546d4c572STomoki Sekiyama g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver); 95646d4c572STomoki Sekiyama goto cleanup; 95746d4c572STomoki Sekiyama } 95846d4c572STomoki Sekiyama for (i = 0; i < nhosts; i++) { 95946d4c572STomoki Sekiyama if (host == hosts[i]) { 96046d4c572STomoki Sekiyama disk->unit = i; 96146d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_SATA; 96246d4c572STomoki Sekiyama break; 96346d4c572STomoki Sekiyama } 96446d4c572STomoki Sekiyama } 96546d4c572STomoki Sekiyama if (i >= nhosts) { 96646d4c572STomoki Sekiyama g_debug("no host for '%s' (driver '%s')", syspath, driver); 96746d4c572STomoki Sekiyama goto cleanup; 96846d4c572STomoki Sekiyama } 96946d4c572STomoki Sekiyama } else { 97046d4c572STomoki Sekiyama g_debug("unknown driver '%s' (sysfs path '%s')", driver, syspath); 97146d4c572STomoki Sekiyama goto cleanup; 97246d4c572STomoki Sekiyama } 97346d4c572STomoki Sekiyama 97446d4c572STomoki Sekiyama list->next = fs->disk; 97546d4c572STomoki Sekiyama fs->disk = list; 97646d4c572STomoki Sekiyama g_free(driver); 97746d4c572STomoki Sekiyama return; 97846d4c572STomoki Sekiyama 97946d4c572STomoki Sekiyama cleanup: 98046d4c572STomoki Sekiyama if (list) { 98146d4c572STomoki Sekiyama qapi_free_GuestDiskAddressList(list); 98246d4c572STomoki Sekiyama } 98346d4c572STomoki Sekiyama g_free(driver); 98446d4c572STomoki Sekiyama } 98546d4c572STomoki Sekiyama 98646d4c572STomoki Sekiyama static void build_guest_fsinfo_for_device(char const *devpath, 98746d4c572STomoki Sekiyama GuestFilesystemInfo *fs, 98846d4c572STomoki Sekiyama Error **errp); 98946d4c572STomoki Sekiyama 99046d4c572STomoki Sekiyama /* Store a list of slave devices of virtual volume specified by @syspath into 99146d4c572STomoki Sekiyama * @fs */ 99246d4c572STomoki Sekiyama static void build_guest_fsinfo_for_virtual_device(char const *syspath, 99346d4c572STomoki Sekiyama GuestFilesystemInfo *fs, 99446d4c572STomoki Sekiyama Error **errp) 99546d4c572STomoki Sekiyama { 99646d4c572STomoki Sekiyama DIR *dir; 99746d4c572STomoki Sekiyama char *dirpath; 998e668d1b8Szhanghailiang struct dirent *entry; 99946d4c572STomoki Sekiyama 100046d4c572STomoki Sekiyama dirpath = g_strdup_printf("%s/slaves", syspath); 100146d4c572STomoki Sekiyama dir = opendir(dirpath); 100246d4c572STomoki Sekiyama if (!dir) { 10038251a72fSMichael Roth if (errno != ENOENT) { 100446d4c572STomoki Sekiyama error_setg_errno(errp, errno, "opendir(\"%s\")", dirpath); 10058251a72fSMichael Roth } 100646d4c572STomoki Sekiyama g_free(dirpath); 100746d4c572STomoki Sekiyama return; 100846d4c572STomoki Sekiyama } 100946d4c572STomoki Sekiyama 101046d4c572STomoki Sekiyama for (;;) { 1011e668d1b8Szhanghailiang errno = 0; 1012e668d1b8Szhanghailiang entry = readdir(dir); 1013e668d1b8Szhanghailiang if (entry == NULL) { 1014e668d1b8Szhanghailiang if (errno) { 1015e668d1b8Szhanghailiang error_setg_errno(errp, errno, "readdir(\"%s\")", dirpath); 101646d4c572STomoki Sekiyama } 101746d4c572STomoki Sekiyama break; 101846d4c572STomoki Sekiyama } 101946d4c572STomoki Sekiyama 1020e668d1b8Szhanghailiang if (entry->d_type == DT_LNK) { 1021e668d1b8Szhanghailiang char *path; 1022e668d1b8Szhanghailiang 1023e668d1b8Szhanghailiang g_debug(" slave device '%s'", entry->d_name); 1024e668d1b8Szhanghailiang path = g_strdup_printf("%s/slaves/%s", syspath, entry->d_name); 1025e668d1b8Szhanghailiang build_guest_fsinfo_for_device(path, fs, errp); 1026e668d1b8Szhanghailiang g_free(path); 102746d4c572STomoki Sekiyama 102846d4c572STomoki Sekiyama if (*errp) { 102946d4c572STomoki Sekiyama break; 103046d4c572STomoki Sekiyama } 103146d4c572STomoki Sekiyama } 103246d4c572STomoki Sekiyama } 103346d4c572STomoki Sekiyama 1034e668d1b8Szhanghailiang g_free(dirpath); 103546d4c572STomoki Sekiyama closedir(dir); 103646d4c572STomoki Sekiyama } 103746d4c572STomoki Sekiyama 103846d4c572STomoki Sekiyama /* Dispatch to functions for virtual/real device */ 103946d4c572STomoki Sekiyama static void build_guest_fsinfo_for_device(char const *devpath, 104046d4c572STomoki Sekiyama GuestFilesystemInfo *fs, 104146d4c572STomoki Sekiyama Error **errp) 104246d4c572STomoki Sekiyama { 104346d4c572STomoki Sekiyama char *syspath = realpath(devpath, NULL); 104446d4c572STomoki Sekiyama 104546d4c572STomoki Sekiyama if (!syspath) { 104646d4c572STomoki Sekiyama error_setg_errno(errp, errno, "realpath(\"%s\")", devpath); 104746d4c572STomoki Sekiyama return; 104846d4c572STomoki Sekiyama } 104946d4c572STomoki Sekiyama 105046d4c572STomoki Sekiyama if (!fs->name) { 105146d4c572STomoki Sekiyama fs->name = g_strdup(basename(syspath)); 105246d4c572STomoki Sekiyama } 105346d4c572STomoki Sekiyama 105446d4c572STomoki Sekiyama g_debug(" parse sysfs path '%s'", syspath); 105546d4c572STomoki Sekiyama 105646d4c572STomoki Sekiyama if (strstr(syspath, "/devices/virtual/block/")) { 105746d4c572STomoki Sekiyama build_guest_fsinfo_for_virtual_device(syspath, fs, errp); 105846d4c572STomoki Sekiyama } else { 105946d4c572STomoki Sekiyama build_guest_fsinfo_for_real_device(syspath, fs, errp); 106046d4c572STomoki Sekiyama } 106146d4c572STomoki Sekiyama 106246d4c572STomoki Sekiyama free(syspath); 106346d4c572STomoki Sekiyama } 106446d4c572STomoki Sekiyama 106546d4c572STomoki Sekiyama /* Return a list of the disk device(s)' info which @mount lies on */ 106646d4c572STomoki Sekiyama static GuestFilesystemInfo *build_guest_fsinfo(struct FsMount *mount, 106746d4c572STomoki Sekiyama Error **errp) 106846d4c572STomoki Sekiyama { 106946d4c572STomoki Sekiyama GuestFilesystemInfo *fs = g_malloc0(sizeof(*fs)); 107046d4c572STomoki Sekiyama char *devpath = g_strdup_printf("/sys/dev/block/%u:%u", 107146d4c572STomoki Sekiyama mount->devmajor, mount->devminor); 107246d4c572STomoki Sekiyama 107346d4c572STomoki Sekiyama fs->mountpoint = g_strdup(mount->dirname); 107446d4c572STomoki Sekiyama fs->type = g_strdup(mount->devtype); 107546d4c572STomoki Sekiyama build_guest_fsinfo_for_device(devpath, fs, errp); 107646d4c572STomoki Sekiyama 107746d4c572STomoki Sekiyama g_free(devpath); 107846d4c572STomoki Sekiyama return fs; 107946d4c572STomoki Sekiyama } 108046d4c572STomoki Sekiyama 108146d4c572STomoki Sekiyama GuestFilesystemInfoList *qmp_guest_get_fsinfo(Error **errp) 108246d4c572STomoki Sekiyama { 108346d4c572STomoki Sekiyama FsMountList mounts; 108446d4c572STomoki Sekiyama struct FsMount *mount; 108546d4c572STomoki Sekiyama GuestFilesystemInfoList *new, *ret = NULL; 108646d4c572STomoki Sekiyama Error *local_err = NULL; 108746d4c572STomoki Sekiyama 108846d4c572STomoki Sekiyama QTAILQ_INIT(&mounts); 108946d4c572STomoki Sekiyama build_fs_mount_list(&mounts, &local_err); 109046d4c572STomoki Sekiyama if (local_err) { 109146d4c572STomoki Sekiyama error_propagate(errp, local_err); 109246d4c572STomoki Sekiyama return NULL; 109346d4c572STomoki Sekiyama } 109446d4c572STomoki Sekiyama 109546d4c572STomoki Sekiyama QTAILQ_FOREACH(mount, &mounts, next) { 109646d4c572STomoki Sekiyama g_debug("Building guest fsinfo for '%s'", mount->dirname); 109746d4c572STomoki Sekiyama 109846d4c572STomoki Sekiyama new = g_malloc0(sizeof(*ret)); 109946d4c572STomoki Sekiyama new->value = build_guest_fsinfo(mount, &local_err); 110046d4c572STomoki Sekiyama new->next = ret; 110146d4c572STomoki Sekiyama ret = new; 110246d4c572STomoki Sekiyama if (local_err) { 110346d4c572STomoki Sekiyama error_propagate(errp, local_err); 110446d4c572STomoki Sekiyama qapi_free_GuestFilesystemInfoList(ret); 110546d4c572STomoki Sekiyama ret = NULL; 110646d4c572STomoki Sekiyama break; 110746d4c572STomoki Sekiyama } 110846d4c572STomoki Sekiyama } 110946d4c572STomoki Sekiyama 111046d4c572STomoki Sekiyama free_fs_mount_list(&mounts); 111146d4c572STomoki Sekiyama return ret; 111246d4c572STomoki Sekiyama } 111346d4c572STomoki Sekiyama 111446d4c572STomoki Sekiyama 1115ec0f694cSTomoki Sekiyama typedef enum { 1116ec0f694cSTomoki Sekiyama FSFREEZE_HOOK_THAW = 0, 1117ec0f694cSTomoki Sekiyama FSFREEZE_HOOK_FREEZE, 1118ec0f694cSTomoki Sekiyama } FsfreezeHookArg; 1119ec0f694cSTomoki Sekiyama 112013a439ecSStefan Weil static const char *fsfreeze_hook_arg_string[] = { 1121ec0f694cSTomoki Sekiyama "thaw", 1122ec0f694cSTomoki Sekiyama "freeze", 1123ec0f694cSTomoki Sekiyama }; 1124ec0f694cSTomoki Sekiyama 112577dbc81bSMarkus Armbruster static void execute_fsfreeze_hook(FsfreezeHookArg arg, Error **errp) 1126ec0f694cSTomoki Sekiyama { 1127ec0f694cSTomoki Sekiyama int status; 1128ec0f694cSTomoki Sekiyama pid_t pid; 1129ec0f694cSTomoki Sekiyama const char *hook; 1130ec0f694cSTomoki Sekiyama const char *arg_str = fsfreeze_hook_arg_string[arg]; 1131ec0f694cSTomoki Sekiyama Error *local_err = NULL; 1132ec0f694cSTomoki Sekiyama 1133ec0f694cSTomoki Sekiyama hook = ga_fsfreeze_hook(ga_state); 1134ec0f694cSTomoki Sekiyama if (!hook) { 1135ec0f694cSTomoki Sekiyama return; 1136ec0f694cSTomoki Sekiyama } 1137ec0f694cSTomoki Sekiyama if (access(hook, X_OK) != 0) { 113877dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "can't access fsfreeze hook '%s'", hook); 1139ec0f694cSTomoki Sekiyama return; 1140ec0f694cSTomoki Sekiyama } 1141ec0f694cSTomoki Sekiyama 1142ec0f694cSTomoki Sekiyama slog("executing fsfreeze hook with arg '%s'", arg_str); 1143ec0f694cSTomoki Sekiyama pid = fork(); 1144ec0f694cSTomoki Sekiyama if (pid == 0) { 1145ec0f694cSTomoki Sekiyama setsid(); 1146ec0f694cSTomoki Sekiyama reopen_fd_to_null(0); 1147ec0f694cSTomoki Sekiyama reopen_fd_to_null(1); 1148ec0f694cSTomoki Sekiyama reopen_fd_to_null(2); 1149ec0f694cSTomoki Sekiyama 1150ec0f694cSTomoki Sekiyama execle(hook, hook, arg_str, NULL, environ); 1151ec0f694cSTomoki Sekiyama _exit(EXIT_FAILURE); 1152ec0f694cSTomoki Sekiyama } else if (pid < 0) { 115377dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to create child process"); 1154ec0f694cSTomoki Sekiyama return; 1155ec0f694cSTomoki Sekiyama } 1156ec0f694cSTomoki Sekiyama 1157ec0f694cSTomoki Sekiyama ga_wait_child(pid, &status, &local_err); 115884d18f06SMarkus Armbruster if (local_err) { 115977dbc81bSMarkus Armbruster error_propagate(errp, local_err); 1160ec0f694cSTomoki Sekiyama return; 1161ec0f694cSTomoki Sekiyama } 1162ec0f694cSTomoki Sekiyama 1163ec0f694cSTomoki Sekiyama if (!WIFEXITED(status)) { 116477dbc81bSMarkus Armbruster error_setg(errp, "fsfreeze hook has terminated abnormally"); 1165ec0f694cSTomoki Sekiyama return; 1166ec0f694cSTomoki Sekiyama } 1167ec0f694cSTomoki Sekiyama 1168ec0f694cSTomoki Sekiyama status = WEXITSTATUS(status); 1169ec0f694cSTomoki Sekiyama if (status) { 117077dbc81bSMarkus Armbruster error_setg(errp, "fsfreeze hook has failed with status %d", status); 1171ec0f694cSTomoki Sekiyama return; 1172ec0f694cSTomoki Sekiyama } 1173ec0f694cSTomoki Sekiyama } 1174ec0f694cSTomoki Sekiyama 1175c216e5adSMichael Roth /* 1176c216e5adSMichael Roth * Return status of freeze/thaw 1177c216e5adSMichael Roth */ 117877dbc81bSMarkus Armbruster GuestFsfreezeStatus qmp_guest_fsfreeze_status(Error **errp) 1179c216e5adSMichael Roth { 1180f22d85e9SMichael Roth if (ga_is_frozen(ga_state)) { 1181f22d85e9SMichael Roth return GUEST_FSFREEZE_STATUS_FROZEN; 1182f22d85e9SMichael Roth } 1183f22d85e9SMichael Roth 1184f22d85e9SMichael Roth return GUEST_FSFREEZE_STATUS_THAWED; 1185c216e5adSMichael Roth } 1186c216e5adSMichael Roth 1187e99bce20STomoki Sekiyama int64_t qmp_guest_fsfreeze_freeze(Error **errp) 1188e99bce20STomoki Sekiyama { 1189e99bce20STomoki Sekiyama return qmp_guest_fsfreeze_freeze_list(false, NULL, errp); 1190e99bce20STomoki Sekiyama } 1191e99bce20STomoki Sekiyama 1192c216e5adSMichael Roth /* 1193c216e5adSMichael Roth * Walk list of mounted file systems in the guest, and freeze the ones which 1194c216e5adSMichael Roth * are real local file systems. 1195c216e5adSMichael Roth */ 1196e99bce20STomoki Sekiyama int64_t qmp_guest_fsfreeze_freeze_list(bool has_mountpoints, 1197e99bce20STomoki Sekiyama strList *mountpoints, 1198e99bce20STomoki Sekiyama Error **errp) 1199c216e5adSMichael Roth { 1200c216e5adSMichael Roth int ret = 0, i = 0; 1201e99bce20STomoki Sekiyama strList *list; 1202af02203fSPaolo Bonzini FsMountList mounts; 1203af02203fSPaolo Bonzini struct FsMount *mount; 1204261551d1SLuiz Capitulino Error *local_err = NULL; 1205c216e5adSMichael Roth int fd; 1206c216e5adSMichael Roth 1207c216e5adSMichael Roth slog("guest-fsfreeze called"); 1208c216e5adSMichael Roth 1209ec0f694cSTomoki Sekiyama execute_fsfreeze_hook(FSFREEZE_HOOK_FREEZE, &local_err); 121084d18f06SMarkus Armbruster if (local_err) { 121177dbc81bSMarkus Armbruster error_propagate(errp, local_err); 1212ec0f694cSTomoki Sekiyama return -1; 1213ec0f694cSTomoki Sekiyama } 1214ec0f694cSTomoki Sekiyama 12159e8aded4SMichael Roth QTAILQ_INIT(&mounts); 1216261551d1SLuiz Capitulino build_fs_mount_list(&mounts, &local_err); 121784d18f06SMarkus Armbruster if (local_err) { 121877dbc81bSMarkus Armbruster error_propagate(errp, local_err); 1219261551d1SLuiz Capitulino return -1; 1220c216e5adSMichael Roth } 1221c216e5adSMichael Roth 1222c216e5adSMichael Roth /* cannot risk guest agent blocking itself on a write in this state */ 1223f22d85e9SMichael Roth ga_set_frozen(ga_state); 1224c216e5adSMichael Roth 1225e5d9adbdSTomoki Sekiyama QTAILQ_FOREACH_REVERSE(mount, &mounts, FsMountList, next) { 1226e99bce20STomoki Sekiyama /* To issue fsfreeze in the reverse order of mounts, check if the 1227e99bce20STomoki Sekiyama * mount is listed in the list here */ 1228e99bce20STomoki Sekiyama if (has_mountpoints) { 1229e99bce20STomoki Sekiyama for (list = mountpoints; list; list = list->next) { 1230e99bce20STomoki Sekiyama if (strcmp(list->value, mount->dirname) == 0) { 1231e99bce20STomoki Sekiyama break; 1232e99bce20STomoki Sekiyama } 1233e99bce20STomoki Sekiyama } 1234e99bce20STomoki Sekiyama if (!list) { 1235e99bce20STomoki Sekiyama continue; 1236e99bce20STomoki Sekiyama } 1237e99bce20STomoki Sekiyama } 1238e99bce20STomoki Sekiyama 1239c216e5adSMichael Roth fd = qemu_open(mount->dirname, O_RDONLY); 1240c216e5adSMichael Roth if (fd == -1) { 124177dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to open %s", mount->dirname); 1242c216e5adSMichael Roth goto error; 1243c216e5adSMichael Roth } 1244c216e5adSMichael Roth 1245e35916acSMichael Tokarev /* we try to cull filesystems we know won't work in advance, but other 1246e35916acSMichael Tokarev * filesystems may not implement fsfreeze for less obvious reasons. 12479e8aded4SMichael Roth * these will report EOPNOTSUPP. we simply ignore these when tallying 12489e8aded4SMichael Roth * the number of frozen filesystems. 1249ce2eb6c4SPeter Lieven * if a filesystem is mounted more than once (aka bind mount) a 1250ce2eb6c4SPeter Lieven * consecutive attempt to freeze an already frozen filesystem will 1251ce2eb6c4SPeter Lieven * return EBUSY. 12529e8aded4SMichael Roth * 12539e8aded4SMichael Roth * any other error means a failure to freeze a filesystem we 12549e8aded4SMichael Roth * expect to be freezable, so return an error in those cases 12559e8aded4SMichael Roth * and return system to thawed state. 1256c216e5adSMichael Roth */ 1257c216e5adSMichael Roth ret = ioctl(fd, FIFREEZE); 12589e8aded4SMichael Roth if (ret == -1) { 1259ce2eb6c4SPeter Lieven if (errno != EOPNOTSUPP && errno != EBUSY) { 126077dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to freeze %s", 1261617fbbc1SLuiz Capitulino mount->dirname); 1262c216e5adSMichael Roth close(fd); 1263c216e5adSMichael Roth goto error; 1264c216e5adSMichael Roth } 12659e8aded4SMichael Roth } else { 1266c216e5adSMichael Roth i++; 1267c216e5adSMichael Roth } 12689e8aded4SMichael Roth close(fd); 12699e8aded4SMichael Roth } 1270c216e5adSMichael Roth 1271af02203fSPaolo Bonzini free_fs_mount_list(&mounts); 1272c216e5adSMichael Roth return i; 1273c216e5adSMichael Roth 1274c216e5adSMichael Roth error: 1275af02203fSPaolo Bonzini free_fs_mount_list(&mounts); 1276c216e5adSMichael Roth qmp_guest_fsfreeze_thaw(NULL); 1277c216e5adSMichael Roth return 0; 1278c216e5adSMichael Roth } 1279c216e5adSMichael Roth 1280c216e5adSMichael Roth /* 1281c216e5adSMichael Roth * Walk list of frozen file systems in the guest, and thaw them. 1282c216e5adSMichael Roth */ 128377dbc81bSMarkus Armbruster int64_t qmp_guest_fsfreeze_thaw(Error **errp) 1284c216e5adSMichael Roth { 1285c216e5adSMichael Roth int ret; 1286af02203fSPaolo Bonzini FsMountList mounts; 1287af02203fSPaolo Bonzini FsMount *mount; 12889e8aded4SMichael Roth int fd, i = 0, logged; 1289261551d1SLuiz Capitulino Error *local_err = NULL; 1290c216e5adSMichael Roth 12919e8aded4SMichael Roth QTAILQ_INIT(&mounts); 1292261551d1SLuiz Capitulino build_fs_mount_list(&mounts, &local_err); 129384d18f06SMarkus Armbruster if (local_err) { 129477dbc81bSMarkus Armbruster error_propagate(errp, local_err); 12959e8aded4SMichael Roth return 0; 12969e8aded4SMichael Roth } 12979e8aded4SMichael Roth 12989e8aded4SMichael Roth QTAILQ_FOREACH(mount, &mounts, next) { 12999e8aded4SMichael Roth logged = false; 1300c216e5adSMichael Roth fd = qemu_open(mount->dirname, O_RDONLY); 1301c216e5adSMichael Roth if (fd == -1) { 1302c216e5adSMichael Roth continue; 1303c216e5adSMichael Roth } 13049e8aded4SMichael Roth /* we have no way of knowing whether a filesystem was actually unfrozen 13059e8aded4SMichael Roth * as a result of a successful call to FITHAW, only that if an error 13069e8aded4SMichael Roth * was returned the filesystem was *not* unfrozen by that particular 13079e8aded4SMichael Roth * call. 13089e8aded4SMichael Roth * 1309a31f0531SJim Meyering * since multiple preceding FIFREEZEs require multiple calls to FITHAW 13109e8aded4SMichael Roth * to unfreeze, continuing issuing FITHAW until an error is returned, 13119e8aded4SMichael Roth * in which case either the filesystem is in an unfreezable state, or, 13129e8aded4SMichael Roth * more likely, it was thawed previously (and remains so afterward). 13139e8aded4SMichael Roth * 13149e8aded4SMichael Roth * also, since the most recent successful call is the one that did 13159e8aded4SMichael Roth * the actual unfreeze, we can use this to provide an accurate count 13169e8aded4SMichael Roth * of the number of filesystems unfrozen by guest-fsfreeze-thaw, which 13179e8aded4SMichael Roth * may * be useful for determining whether a filesystem was unfrozen 13189e8aded4SMichael Roth * during the freeze/thaw phase by a process other than qemu-ga. 13199e8aded4SMichael Roth */ 13209e8aded4SMichael Roth do { 1321c216e5adSMichael Roth ret = ioctl(fd, FITHAW); 13229e8aded4SMichael Roth if (ret == 0 && !logged) { 1323c216e5adSMichael Roth i++; 13249e8aded4SMichael Roth logged = true; 13259e8aded4SMichael Roth } 13269e8aded4SMichael Roth } while (ret == 0); 13279e8aded4SMichael Roth close(fd); 1328c216e5adSMichael Roth } 1329c216e5adSMichael Roth 1330f22d85e9SMichael Roth ga_unset_frozen(ga_state); 1331af02203fSPaolo Bonzini free_fs_mount_list(&mounts); 1332ec0f694cSTomoki Sekiyama 133377dbc81bSMarkus Armbruster execute_fsfreeze_hook(FSFREEZE_HOOK_THAW, errp); 1334ec0f694cSTomoki Sekiyama 1335c216e5adSMichael Roth return i; 1336c216e5adSMichael Roth } 1337c216e5adSMichael Roth 1338c216e5adSMichael Roth static void guest_fsfreeze_cleanup(void) 1339c216e5adSMichael Roth { 1340c216e5adSMichael Roth Error *err = NULL; 1341c216e5adSMichael Roth 1342f22d85e9SMichael Roth if (ga_is_frozen(ga_state) == GUEST_FSFREEZE_STATUS_FROZEN) { 13436f686749SMarkus Armbruster qmp_guest_fsfreeze_thaw(&err); 13446f686749SMarkus Armbruster if (err) { 13456f686749SMarkus Armbruster slog("failed to clean up frozen filesystems: %s", 13466f686749SMarkus Armbruster error_get_pretty(err)); 13476f686749SMarkus Armbruster error_free(err); 1348c216e5adSMichael Roth } 1349c216e5adSMichael Roth } 1350c216e5adSMichael Roth } 1351e72c3f2eSMichael Roth #endif /* CONFIG_FSFREEZE */ 1352c216e5adSMichael Roth 1353eab5fd59SPaolo Bonzini #if defined(CONFIG_FSTRIM) 1354eab5fd59SPaolo Bonzini /* 1355eab5fd59SPaolo Bonzini * Walk list of mounted file systems in the guest, and trim them. 1356eab5fd59SPaolo Bonzini */ 1357e82855d9SJustin Ossevoort GuestFilesystemTrimResponse * 1358e82855d9SJustin Ossevoort qmp_guest_fstrim(bool has_minimum, int64_t minimum, Error **errp) 1359eab5fd59SPaolo Bonzini { 1360e82855d9SJustin Ossevoort GuestFilesystemTrimResponse *response; 1361e82855d9SJustin Ossevoort GuestFilesystemTrimResultList *list; 1362e82855d9SJustin Ossevoort GuestFilesystemTrimResult *result; 1363eab5fd59SPaolo Bonzini int ret = 0; 1364eab5fd59SPaolo Bonzini FsMountList mounts; 1365eab5fd59SPaolo Bonzini struct FsMount *mount; 1366eab5fd59SPaolo Bonzini int fd; 1367261551d1SLuiz Capitulino Error *local_err = NULL; 136873a652a1SJustin Ossevoort struct fstrim_range r; 1369eab5fd59SPaolo Bonzini 1370eab5fd59SPaolo Bonzini slog("guest-fstrim called"); 1371eab5fd59SPaolo Bonzini 1372eab5fd59SPaolo Bonzini QTAILQ_INIT(&mounts); 1373261551d1SLuiz Capitulino build_fs_mount_list(&mounts, &local_err); 137484d18f06SMarkus Armbruster if (local_err) { 137577dbc81bSMarkus Armbruster error_propagate(errp, local_err); 1376e82855d9SJustin Ossevoort return NULL; 1377eab5fd59SPaolo Bonzini } 1378eab5fd59SPaolo Bonzini 1379e82855d9SJustin Ossevoort response = g_malloc0(sizeof(*response)); 1380e82855d9SJustin Ossevoort 1381eab5fd59SPaolo Bonzini QTAILQ_FOREACH(mount, &mounts, next) { 1382e82855d9SJustin Ossevoort result = g_malloc0(sizeof(*result)); 1383e82855d9SJustin Ossevoort result->path = g_strdup(mount->dirname); 1384e82855d9SJustin Ossevoort 1385e82855d9SJustin Ossevoort list = g_malloc0(sizeof(*list)); 1386e82855d9SJustin Ossevoort list->value = result; 1387e82855d9SJustin Ossevoort list->next = response->paths; 1388e82855d9SJustin Ossevoort response->paths = list; 1389e82855d9SJustin Ossevoort 1390eab5fd59SPaolo Bonzini fd = qemu_open(mount->dirname, O_RDONLY); 1391eab5fd59SPaolo Bonzini if (fd == -1) { 1392e82855d9SJustin Ossevoort result->error = g_strdup_printf("failed to open: %s", 1393e82855d9SJustin Ossevoort strerror(errno)); 1394e82855d9SJustin Ossevoort result->has_error = true; 1395e82855d9SJustin Ossevoort continue; 1396eab5fd59SPaolo Bonzini } 1397eab5fd59SPaolo Bonzini 1398e35916acSMichael Tokarev /* We try to cull filesystems we know won't work in advance, but other 1399e35916acSMichael Tokarev * filesystems may not implement fstrim for less obvious reasons. 1400e35916acSMichael Tokarev * These will report EOPNOTSUPP; while in some other cases ENOTTY 1401e35916acSMichael Tokarev * will be reported (e.g. CD-ROMs). 1402e82855d9SJustin Ossevoort * Any other error means an unexpected error. 1403eab5fd59SPaolo Bonzini */ 140473a652a1SJustin Ossevoort r.start = 0; 140573a652a1SJustin Ossevoort r.len = -1; 140673a652a1SJustin Ossevoort r.minlen = has_minimum ? minimum : 0; 1407eab5fd59SPaolo Bonzini ret = ioctl(fd, FITRIM, &r); 1408eab5fd59SPaolo Bonzini if (ret == -1) { 1409e82855d9SJustin Ossevoort result->has_error = true; 1410e82855d9SJustin Ossevoort if (errno == ENOTTY || errno == EOPNOTSUPP) { 1411e82855d9SJustin Ossevoort result->error = g_strdup("trim not supported"); 1412e82855d9SJustin Ossevoort } else { 1413e82855d9SJustin Ossevoort result->error = g_strdup_printf("failed to trim: %s", 1414e82855d9SJustin Ossevoort strerror(errno)); 1415e82855d9SJustin Ossevoort } 1416eab5fd59SPaolo Bonzini close(fd); 1417e82855d9SJustin Ossevoort continue; 1418eab5fd59SPaolo Bonzini } 1419e82855d9SJustin Ossevoort 1420e82855d9SJustin Ossevoort result->has_minimum = true; 1421e82855d9SJustin Ossevoort result->minimum = r.minlen; 1422e82855d9SJustin Ossevoort result->has_trimmed = true; 1423e82855d9SJustin Ossevoort result->trimmed = r.len; 1424eab5fd59SPaolo Bonzini close(fd); 1425eab5fd59SPaolo Bonzini } 1426eab5fd59SPaolo Bonzini 1427eab5fd59SPaolo Bonzini free_fs_mount_list(&mounts); 1428e82855d9SJustin Ossevoort return response; 1429eab5fd59SPaolo Bonzini } 1430eab5fd59SPaolo Bonzini #endif /* CONFIG_FSTRIM */ 1431eab5fd59SPaolo Bonzini 1432eab5fd59SPaolo Bonzini 143311d0f125SLuiz Capitulino #define LINUX_SYS_STATE_FILE "/sys/power/state" 143411d0f125SLuiz Capitulino #define SUSPEND_SUPPORTED 0 143511d0f125SLuiz Capitulino #define SUSPEND_NOT_SUPPORTED 1 143611d0f125SLuiz Capitulino 143711d0f125SLuiz Capitulino static void bios_supports_mode(const char *pmutils_bin, const char *pmutils_arg, 143877dbc81bSMarkus Armbruster const char *sysfile_str, Error **errp) 143911d0f125SLuiz Capitulino { 14406b26e837SLuiz Capitulino Error *local_err = NULL; 144111d0f125SLuiz Capitulino char *pmutils_path; 14426b26e837SLuiz Capitulino pid_t pid; 1443dc8764f0SLuiz Capitulino int status; 144411d0f125SLuiz Capitulino 144511d0f125SLuiz Capitulino pmutils_path = g_find_program_in_path(pmutils_bin); 144611d0f125SLuiz Capitulino 144711d0f125SLuiz Capitulino pid = fork(); 144811d0f125SLuiz Capitulino if (!pid) { 1449dc8764f0SLuiz Capitulino char buf[32]; /* hopefully big enough */ 1450dc8764f0SLuiz Capitulino ssize_t ret; 1451dc8764f0SLuiz Capitulino int fd; 145211d0f125SLuiz Capitulino 145311d0f125SLuiz Capitulino setsid(); 145411d0f125SLuiz Capitulino reopen_fd_to_null(0); 145511d0f125SLuiz Capitulino reopen_fd_to_null(1); 145611d0f125SLuiz Capitulino reopen_fd_to_null(2); 145711d0f125SLuiz Capitulino 145811d0f125SLuiz Capitulino if (pmutils_path) { 145911d0f125SLuiz Capitulino execle(pmutils_path, pmutils_bin, pmutils_arg, NULL, environ); 146011d0f125SLuiz Capitulino } 146111d0f125SLuiz Capitulino 146211d0f125SLuiz Capitulino /* 146311d0f125SLuiz Capitulino * If we get here either pm-utils is not installed or execle() has 146411d0f125SLuiz Capitulino * failed. Let's try the manual method if the caller wants it. 146511d0f125SLuiz Capitulino */ 146611d0f125SLuiz Capitulino 146711d0f125SLuiz Capitulino if (!sysfile_str) { 146811d0f125SLuiz Capitulino _exit(SUSPEND_NOT_SUPPORTED); 146911d0f125SLuiz Capitulino } 147011d0f125SLuiz Capitulino 147111d0f125SLuiz Capitulino fd = open(LINUX_SYS_STATE_FILE, O_RDONLY); 147211d0f125SLuiz Capitulino if (fd < 0) { 147311d0f125SLuiz Capitulino _exit(SUSPEND_NOT_SUPPORTED); 147411d0f125SLuiz Capitulino } 147511d0f125SLuiz Capitulino 147611d0f125SLuiz Capitulino ret = read(fd, buf, sizeof(buf)-1); 147711d0f125SLuiz Capitulino if (ret <= 0) { 147811d0f125SLuiz Capitulino _exit(SUSPEND_NOT_SUPPORTED); 147911d0f125SLuiz Capitulino } 148011d0f125SLuiz Capitulino buf[ret] = '\0'; 148111d0f125SLuiz Capitulino 148211d0f125SLuiz Capitulino if (strstr(buf, sysfile_str)) { 148311d0f125SLuiz Capitulino _exit(SUSPEND_SUPPORTED); 148411d0f125SLuiz Capitulino } 148511d0f125SLuiz Capitulino 148611d0f125SLuiz Capitulino _exit(SUSPEND_NOT_SUPPORTED); 14876b26e837SLuiz Capitulino } else if (pid < 0) { 148877dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to create child process"); 14896b26e837SLuiz Capitulino goto out; 149011d0f125SLuiz Capitulino } 149111d0f125SLuiz Capitulino 14926b26e837SLuiz Capitulino ga_wait_child(pid, &status, &local_err); 149384d18f06SMarkus Armbruster if (local_err) { 149477dbc81bSMarkus Armbruster error_propagate(errp, local_err); 14956b26e837SLuiz Capitulino goto out; 149611d0f125SLuiz Capitulino } 149711d0f125SLuiz Capitulino 14986b26e837SLuiz Capitulino if (!WIFEXITED(status)) { 149977dbc81bSMarkus Armbruster error_setg(errp, "child process has terminated abnormally"); 15006b26e837SLuiz Capitulino goto out; 15016b26e837SLuiz Capitulino } 15026b26e837SLuiz Capitulino 1503dc8764f0SLuiz Capitulino switch (WEXITSTATUS(status)) { 1504dc8764f0SLuiz Capitulino case SUSPEND_SUPPORTED: 15056b26e837SLuiz Capitulino goto out; 1506dc8764f0SLuiz Capitulino case SUSPEND_NOT_SUPPORTED: 150777dbc81bSMarkus Armbruster error_setg(errp, 15086b26e837SLuiz Capitulino "the requested suspend mode is not supported by the guest"); 15096b26e837SLuiz Capitulino goto out; 1510dc8764f0SLuiz Capitulino default: 151177dbc81bSMarkus Armbruster error_setg(errp, 15126b26e837SLuiz Capitulino "the helper program '%s' returned an unexpected exit status" 15136b26e837SLuiz Capitulino " code (%d)", pmutils_path, WEXITSTATUS(status)); 15146b26e837SLuiz Capitulino goto out; 1515dc8764f0SLuiz Capitulino } 151611d0f125SLuiz Capitulino 15176b26e837SLuiz Capitulino out: 15186b26e837SLuiz Capitulino g_free(pmutils_path); 151911d0f125SLuiz Capitulino } 152011d0f125SLuiz Capitulino 152111d0f125SLuiz Capitulino static void guest_suspend(const char *pmutils_bin, const char *sysfile_str, 152277dbc81bSMarkus Armbruster Error **errp) 152311d0f125SLuiz Capitulino { 15247b376087SLuiz Capitulino Error *local_err = NULL; 152511d0f125SLuiz Capitulino char *pmutils_path; 15267b376087SLuiz Capitulino pid_t pid; 1527dc8764f0SLuiz Capitulino int status; 152811d0f125SLuiz Capitulino 152911d0f125SLuiz Capitulino pmutils_path = g_find_program_in_path(pmutils_bin); 153011d0f125SLuiz Capitulino 153111d0f125SLuiz Capitulino pid = fork(); 153211d0f125SLuiz Capitulino if (pid == 0) { 153311d0f125SLuiz Capitulino /* child */ 153411d0f125SLuiz Capitulino int fd; 153511d0f125SLuiz Capitulino 153611d0f125SLuiz Capitulino setsid(); 153711d0f125SLuiz Capitulino reopen_fd_to_null(0); 153811d0f125SLuiz Capitulino reopen_fd_to_null(1); 153911d0f125SLuiz Capitulino reopen_fd_to_null(2); 154011d0f125SLuiz Capitulino 154111d0f125SLuiz Capitulino if (pmutils_path) { 154211d0f125SLuiz Capitulino execle(pmutils_path, pmutils_bin, NULL, environ); 154311d0f125SLuiz Capitulino } 154411d0f125SLuiz Capitulino 154511d0f125SLuiz Capitulino /* 154611d0f125SLuiz Capitulino * If we get here either pm-utils is not installed or execle() has 154711d0f125SLuiz Capitulino * failed. Let's try the manual method if the caller wants it. 154811d0f125SLuiz Capitulino */ 154911d0f125SLuiz Capitulino 155011d0f125SLuiz Capitulino if (!sysfile_str) { 155111d0f125SLuiz Capitulino _exit(EXIT_FAILURE); 155211d0f125SLuiz Capitulino } 155311d0f125SLuiz Capitulino 155411d0f125SLuiz Capitulino fd = open(LINUX_SYS_STATE_FILE, O_WRONLY); 155511d0f125SLuiz Capitulino if (fd < 0) { 155611d0f125SLuiz Capitulino _exit(EXIT_FAILURE); 155711d0f125SLuiz Capitulino } 155811d0f125SLuiz Capitulino 155911d0f125SLuiz Capitulino if (write(fd, sysfile_str, strlen(sysfile_str)) < 0) { 156011d0f125SLuiz Capitulino _exit(EXIT_FAILURE); 156111d0f125SLuiz Capitulino } 156211d0f125SLuiz Capitulino 156311d0f125SLuiz Capitulino _exit(EXIT_SUCCESS); 15647b376087SLuiz Capitulino } else if (pid < 0) { 156577dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to create child process"); 15667b376087SLuiz Capitulino goto out; 156711d0f125SLuiz Capitulino } 156811d0f125SLuiz Capitulino 15697b376087SLuiz Capitulino ga_wait_child(pid, &status, &local_err); 157084d18f06SMarkus Armbruster if (local_err) { 157177dbc81bSMarkus Armbruster error_propagate(errp, local_err); 15727b376087SLuiz Capitulino goto out; 15737b376087SLuiz Capitulino } 15747b376087SLuiz Capitulino 15757b376087SLuiz Capitulino if (!WIFEXITED(status)) { 157677dbc81bSMarkus Armbruster error_setg(errp, "child process has terminated abnormally"); 15777b376087SLuiz Capitulino goto out; 15787b376087SLuiz Capitulino } 15797b376087SLuiz Capitulino 15807b376087SLuiz Capitulino if (WEXITSTATUS(status)) { 158177dbc81bSMarkus Armbruster error_setg(errp, "child process has failed to suspend"); 15827b376087SLuiz Capitulino goto out; 15837b376087SLuiz Capitulino } 15847b376087SLuiz Capitulino 15857b376087SLuiz Capitulino out: 158611d0f125SLuiz Capitulino g_free(pmutils_path); 158711d0f125SLuiz Capitulino } 158811d0f125SLuiz Capitulino 158977dbc81bSMarkus Armbruster void qmp_guest_suspend_disk(Error **errp) 159011d0f125SLuiz Capitulino { 15910f230bf7SMarkus Armbruster Error *local_err = NULL; 15920f230bf7SMarkus Armbruster 15930f230bf7SMarkus Armbruster bios_supports_mode("pm-is-supported", "--hibernate", "disk", &local_err); 15940f230bf7SMarkus Armbruster if (local_err) { 15950f230bf7SMarkus Armbruster error_propagate(errp, local_err); 159611d0f125SLuiz Capitulino return; 159711d0f125SLuiz Capitulino } 159811d0f125SLuiz Capitulino 159977dbc81bSMarkus Armbruster guest_suspend("pm-hibernate", "disk", errp); 160011d0f125SLuiz Capitulino } 160111d0f125SLuiz Capitulino 160277dbc81bSMarkus Armbruster void qmp_guest_suspend_ram(Error **errp) 1603fbf42210SLuiz Capitulino { 16040f230bf7SMarkus Armbruster Error *local_err = NULL; 16050f230bf7SMarkus Armbruster 16060f230bf7SMarkus Armbruster bios_supports_mode("pm-is-supported", "--suspend", "mem", &local_err); 16070f230bf7SMarkus Armbruster if (local_err) { 16080f230bf7SMarkus Armbruster error_propagate(errp, local_err); 1609fbf42210SLuiz Capitulino return; 1610fbf42210SLuiz Capitulino } 1611fbf42210SLuiz Capitulino 161277dbc81bSMarkus Armbruster guest_suspend("pm-suspend", "mem", errp); 1613fbf42210SLuiz Capitulino } 1614fbf42210SLuiz Capitulino 161577dbc81bSMarkus Armbruster void qmp_guest_suspend_hybrid(Error **errp) 161695f4f404SLuiz Capitulino { 16170f230bf7SMarkus Armbruster Error *local_err = NULL; 16180f230bf7SMarkus Armbruster 16190f230bf7SMarkus Armbruster bios_supports_mode("pm-is-supported", "--suspend-hybrid", NULL, 16200f230bf7SMarkus Armbruster &local_err); 16210f230bf7SMarkus Armbruster if (local_err) { 16220f230bf7SMarkus Armbruster error_propagate(errp, local_err); 162395f4f404SLuiz Capitulino return; 162495f4f404SLuiz Capitulino } 162595f4f404SLuiz Capitulino 162677dbc81bSMarkus Armbruster guest_suspend("pm-suspend-hybrid", NULL, errp); 162795f4f404SLuiz Capitulino } 162895f4f404SLuiz Capitulino 16293424fc9fSMichal Privoznik static GuestNetworkInterfaceList * 16303424fc9fSMichal Privoznik guest_find_interface(GuestNetworkInterfaceList *head, 16313424fc9fSMichal Privoznik const char *name) 16323424fc9fSMichal Privoznik { 16333424fc9fSMichal Privoznik for (; head; head = head->next) { 16343424fc9fSMichal Privoznik if (strcmp(head->value->name, name) == 0) { 16353424fc9fSMichal Privoznik break; 16363424fc9fSMichal Privoznik } 16373424fc9fSMichal Privoznik } 16383424fc9fSMichal Privoznik 16393424fc9fSMichal Privoznik return head; 16403424fc9fSMichal Privoznik } 16413424fc9fSMichal Privoznik 16423424fc9fSMichal Privoznik /* 16433424fc9fSMichal Privoznik * Build information about guest interfaces 16443424fc9fSMichal Privoznik */ 16453424fc9fSMichal Privoznik GuestNetworkInterfaceList *qmp_guest_network_get_interfaces(Error **errp) 16463424fc9fSMichal Privoznik { 16473424fc9fSMichal Privoznik GuestNetworkInterfaceList *head = NULL, *cur_item = NULL; 16483424fc9fSMichal Privoznik struct ifaddrs *ifap, *ifa; 16493424fc9fSMichal Privoznik 16503424fc9fSMichal Privoznik if (getifaddrs(&ifap) < 0) { 1651878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, "getifaddrs failed"); 16523424fc9fSMichal Privoznik goto error; 16533424fc9fSMichal Privoznik } 16543424fc9fSMichal Privoznik 16553424fc9fSMichal Privoznik for (ifa = ifap; ifa; ifa = ifa->ifa_next) { 16563424fc9fSMichal Privoznik GuestNetworkInterfaceList *info; 16573424fc9fSMichal Privoznik GuestIpAddressList **address_list = NULL, *address_item = NULL; 16583424fc9fSMichal Privoznik char addr4[INET_ADDRSTRLEN]; 16593424fc9fSMichal Privoznik char addr6[INET6_ADDRSTRLEN]; 16603424fc9fSMichal Privoznik int sock; 16613424fc9fSMichal Privoznik struct ifreq ifr; 16623424fc9fSMichal Privoznik unsigned char *mac_addr; 16633424fc9fSMichal Privoznik void *p; 16643424fc9fSMichal Privoznik 16653424fc9fSMichal Privoznik g_debug("Processing %s interface", ifa->ifa_name); 16663424fc9fSMichal Privoznik 16673424fc9fSMichal Privoznik info = guest_find_interface(head, ifa->ifa_name); 16683424fc9fSMichal Privoznik 16693424fc9fSMichal Privoznik if (!info) { 16703424fc9fSMichal Privoznik info = g_malloc0(sizeof(*info)); 16713424fc9fSMichal Privoznik info->value = g_malloc0(sizeof(*info->value)); 16723424fc9fSMichal Privoznik info->value->name = g_strdup(ifa->ifa_name); 16733424fc9fSMichal Privoznik 16743424fc9fSMichal Privoznik if (!cur_item) { 16753424fc9fSMichal Privoznik head = cur_item = info; 16763424fc9fSMichal Privoznik } else { 16773424fc9fSMichal Privoznik cur_item->next = info; 16783424fc9fSMichal Privoznik cur_item = info; 16793424fc9fSMichal Privoznik } 16803424fc9fSMichal Privoznik } 16813424fc9fSMichal Privoznik 16823424fc9fSMichal Privoznik if (!info->value->has_hardware_address && 16833424fc9fSMichal Privoznik ifa->ifa_flags & SIOCGIFHWADDR) { 16843424fc9fSMichal Privoznik /* we haven't obtained HW address yet */ 16853424fc9fSMichal Privoznik sock = socket(PF_INET, SOCK_STREAM, 0); 16863424fc9fSMichal Privoznik if (sock == -1) { 1687878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, "failed to create socket"); 16883424fc9fSMichal Privoznik goto error; 16893424fc9fSMichal Privoznik } 16903424fc9fSMichal Privoznik 16913424fc9fSMichal Privoznik memset(&ifr, 0, sizeof(ifr)); 16921ab516edSJim Meyering pstrcpy(ifr.ifr_name, IF_NAMESIZE, info->value->name); 16933424fc9fSMichal Privoznik if (ioctl(sock, SIOCGIFHWADDR, &ifr) == -1) { 1694878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, 1695878a0ae0SLuiz Capitulino "failed to get MAC address of %s", 1696878a0ae0SLuiz Capitulino ifa->ifa_name); 169710a2158fSMarkus Armbruster close(sock); 16983424fc9fSMichal Privoznik goto error; 16993424fc9fSMichal Privoznik } 17003424fc9fSMichal Privoznik 170110a2158fSMarkus Armbruster close(sock); 17023424fc9fSMichal Privoznik mac_addr = (unsigned char *) &ifr.ifr_hwaddr.sa_data; 17033424fc9fSMichal Privoznik 1704e4ada482SStefan Weil info->value->hardware_address = 1705e4ada482SStefan Weil g_strdup_printf("%02x:%02x:%02x:%02x:%02x:%02x", 17063424fc9fSMichal Privoznik (int) mac_addr[0], (int) mac_addr[1], 17073424fc9fSMichal Privoznik (int) mac_addr[2], (int) mac_addr[3], 1708e4ada482SStefan Weil (int) mac_addr[4], (int) mac_addr[5]); 17093424fc9fSMichal Privoznik 17103424fc9fSMichal Privoznik info->value->has_hardware_address = true; 17113424fc9fSMichal Privoznik } 17123424fc9fSMichal Privoznik 17133424fc9fSMichal Privoznik if (ifa->ifa_addr && 17143424fc9fSMichal Privoznik ifa->ifa_addr->sa_family == AF_INET) { 17153424fc9fSMichal Privoznik /* interface with IPv4 address */ 17163424fc9fSMichal Privoznik p = &((struct sockaddr_in *)ifa->ifa_addr)->sin_addr; 17173424fc9fSMichal Privoznik if (!inet_ntop(AF_INET, p, addr4, sizeof(addr4))) { 1718878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, "inet_ntop failed"); 17193424fc9fSMichal Privoznik goto error; 17203424fc9fSMichal Privoznik } 17213424fc9fSMichal Privoznik 172210a2158fSMarkus Armbruster address_item = g_malloc0(sizeof(*address_item)); 172310a2158fSMarkus Armbruster address_item->value = g_malloc0(sizeof(*address_item->value)); 17243424fc9fSMichal Privoznik address_item->value->ip_address = g_strdup(addr4); 17253424fc9fSMichal Privoznik address_item->value->ip_address_type = GUEST_IP_ADDRESS_TYPE_IPV4; 17263424fc9fSMichal Privoznik 17273424fc9fSMichal Privoznik if (ifa->ifa_netmask) { 17283424fc9fSMichal Privoznik /* Count the number of set bits in netmask. 17293424fc9fSMichal Privoznik * This is safe as '1' and '0' cannot be shuffled in netmask. */ 17303424fc9fSMichal Privoznik p = &((struct sockaddr_in *)ifa->ifa_netmask)->sin_addr; 17313424fc9fSMichal Privoznik address_item->value->prefix = ctpop32(((uint32_t *) p)[0]); 17323424fc9fSMichal Privoznik } 17333424fc9fSMichal Privoznik } else if (ifa->ifa_addr && 17343424fc9fSMichal Privoznik ifa->ifa_addr->sa_family == AF_INET6) { 17353424fc9fSMichal Privoznik /* interface with IPv6 address */ 17363424fc9fSMichal Privoznik p = &((struct sockaddr_in6 *)ifa->ifa_addr)->sin6_addr; 17373424fc9fSMichal Privoznik if (!inet_ntop(AF_INET6, p, addr6, sizeof(addr6))) { 1738878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, "inet_ntop failed"); 17393424fc9fSMichal Privoznik goto error; 17403424fc9fSMichal Privoznik } 17413424fc9fSMichal Privoznik 174210a2158fSMarkus Armbruster address_item = g_malloc0(sizeof(*address_item)); 174310a2158fSMarkus Armbruster address_item->value = g_malloc0(sizeof(*address_item->value)); 17443424fc9fSMichal Privoznik address_item->value->ip_address = g_strdup(addr6); 17453424fc9fSMichal Privoznik address_item->value->ip_address_type = GUEST_IP_ADDRESS_TYPE_IPV6; 17463424fc9fSMichal Privoznik 17473424fc9fSMichal Privoznik if (ifa->ifa_netmask) { 17483424fc9fSMichal Privoznik /* Count the number of set bits in netmask. 17493424fc9fSMichal Privoznik * This is safe as '1' and '0' cannot be shuffled in netmask. */ 17503424fc9fSMichal Privoznik p = &((struct sockaddr_in6 *)ifa->ifa_netmask)->sin6_addr; 17513424fc9fSMichal Privoznik address_item->value->prefix = 17523424fc9fSMichal Privoznik ctpop32(((uint32_t *) p)[0]) + 17533424fc9fSMichal Privoznik ctpop32(((uint32_t *) p)[1]) + 17543424fc9fSMichal Privoznik ctpop32(((uint32_t *) p)[2]) + 17553424fc9fSMichal Privoznik ctpop32(((uint32_t *) p)[3]); 17563424fc9fSMichal Privoznik } 17573424fc9fSMichal Privoznik } 17583424fc9fSMichal Privoznik 17593424fc9fSMichal Privoznik if (!address_item) { 17603424fc9fSMichal Privoznik continue; 17613424fc9fSMichal Privoznik } 17623424fc9fSMichal Privoznik 17633424fc9fSMichal Privoznik address_list = &info->value->ip_addresses; 17643424fc9fSMichal Privoznik 17653424fc9fSMichal Privoznik while (*address_list && (*address_list)->next) { 17663424fc9fSMichal Privoznik address_list = &(*address_list)->next; 17673424fc9fSMichal Privoznik } 17683424fc9fSMichal Privoznik 17693424fc9fSMichal Privoznik if (!*address_list) { 17703424fc9fSMichal Privoznik *address_list = address_item; 17713424fc9fSMichal Privoznik } else { 17723424fc9fSMichal Privoznik (*address_list)->next = address_item; 17733424fc9fSMichal Privoznik } 17743424fc9fSMichal Privoznik 17753424fc9fSMichal Privoznik info->value->has_ip_addresses = true; 17763424fc9fSMichal Privoznik 17773424fc9fSMichal Privoznik 17783424fc9fSMichal Privoznik } 17793424fc9fSMichal Privoznik 17803424fc9fSMichal Privoznik freeifaddrs(ifap); 17813424fc9fSMichal Privoznik return head; 17823424fc9fSMichal Privoznik 17833424fc9fSMichal Privoznik error: 17843424fc9fSMichal Privoznik freeifaddrs(ifap); 17853424fc9fSMichal Privoznik qapi_free_GuestNetworkInterfaceList(head); 17863424fc9fSMichal Privoznik return NULL; 17873424fc9fSMichal Privoznik } 17883424fc9fSMichal Privoznik 178977dbc81bSMarkus Armbruster #define SYSCONF_EXACT(name, errp) sysconf_exact((name), #name, (errp)) 1790d2baff62SLaszlo Ersek 179177dbc81bSMarkus Armbruster static long sysconf_exact(int name, const char *name_str, Error **errp) 1792d2baff62SLaszlo Ersek { 1793d2baff62SLaszlo Ersek long ret; 1794d2baff62SLaszlo Ersek 1795d2baff62SLaszlo Ersek errno = 0; 1796d2baff62SLaszlo Ersek ret = sysconf(name); 1797d2baff62SLaszlo Ersek if (ret == -1) { 1798d2baff62SLaszlo Ersek if (errno == 0) { 179977dbc81bSMarkus Armbruster error_setg(errp, "sysconf(%s): value indefinite", name_str); 1800d2baff62SLaszlo Ersek } else { 180177dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "sysconf(%s)", name_str); 1802d2baff62SLaszlo Ersek } 1803d2baff62SLaszlo Ersek } 1804d2baff62SLaszlo Ersek return ret; 1805d2baff62SLaszlo Ersek } 1806d2baff62SLaszlo Ersek 1807d2baff62SLaszlo Ersek /* Transfer online/offline status between @vcpu and the guest system. 1808d2baff62SLaszlo Ersek * 1809d2baff62SLaszlo Ersek * On input either @errp or *@errp must be NULL. 1810d2baff62SLaszlo Ersek * 1811d2baff62SLaszlo Ersek * In system-to-@vcpu direction, the following @vcpu fields are accessed: 1812d2baff62SLaszlo Ersek * - R: vcpu->logical_id 1813d2baff62SLaszlo Ersek * - W: vcpu->online 1814d2baff62SLaszlo Ersek * - W: vcpu->can_offline 1815d2baff62SLaszlo Ersek * 1816d2baff62SLaszlo Ersek * In @vcpu-to-system direction, the following @vcpu fields are accessed: 1817d2baff62SLaszlo Ersek * - R: vcpu->logical_id 1818d2baff62SLaszlo Ersek * - R: vcpu->online 1819d2baff62SLaszlo Ersek * 1820d2baff62SLaszlo Ersek * Written members remain unmodified on error. 1821d2baff62SLaszlo Ersek */ 1822d2baff62SLaszlo Ersek static void transfer_vcpu(GuestLogicalProcessor *vcpu, bool sys2vcpu, 1823d2baff62SLaszlo Ersek Error **errp) 1824d2baff62SLaszlo Ersek { 1825d2baff62SLaszlo Ersek char *dirpath; 1826d2baff62SLaszlo Ersek int dirfd; 1827d2baff62SLaszlo Ersek 1828d2baff62SLaszlo Ersek dirpath = g_strdup_printf("/sys/devices/system/cpu/cpu%" PRId64 "/", 1829d2baff62SLaszlo Ersek vcpu->logical_id); 1830d2baff62SLaszlo Ersek dirfd = open(dirpath, O_RDONLY | O_DIRECTORY); 1831d2baff62SLaszlo Ersek if (dirfd == -1) { 1832d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "open(\"%s\")", dirpath); 1833d2baff62SLaszlo Ersek } else { 1834d2baff62SLaszlo Ersek static const char fn[] = "online"; 1835d2baff62SLaszlo Ersek int fd; 1836d2baff62SLaszlo Ersek int res; 1837d2baff62SLaszlo Ersek 1838d2baff62SLaszlo Ersek fd = openat(dirfd, fn, sys2vcpu ? O_RDONLY : O_RDWR); 1839d2baff62SLaszlo Ersek if (fd == -1) { 1840d2baff62SLaszlo Ersek if (errno != ENOENT) { 1841d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "open(\"%s/%s\")", dirpath, fn); 1842d2baff62SLaszlo Ersek } else if (sys2vcpu) { 1843d2baff62SLaszlo Ersek vcpu->online = true; 1844d2baff62SLaszlo Ersek vcpu->can_offline = false; 1845d2baff62SLaszlo Ersek } else if (!vcpu->online) { 1846d2baff62SLaszlo Ersek error_setg(errp, "logical processor #%" PRId64 " can't be " 1847d2baff62SLaszlo Ersek "offlined", vcpu->logical_id); 1848d2baff62SLaszlo Ersek } /* otherwise pretend successful re-onlining */ 1849d2baff62SLaszlo Ersek } else { 1850d2baff62SLaszlo Ersek unsigned char status; 1851d2baff62SLaszlo Ersek 1852d2baff62SLaszlo Ersek res = pread(fd, &status, 1, 0); 1853d2baff62SLaszlo Ersek if (res == -1) { 1854d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "pread(\"%s/%s\")", dirpath, fn); 1855d2baff62SLaszlo Ersek } else if (res == 0) { 1856d2baff62SLaszlo Ersek error_setg(errp, "pread(\"%s/%s\"): unexpected EOF", dirpath, 1857d2baff62SLaszlo Ersek fn); 1858d2baff62SLaszlo Ersek } else if (sys2vcpu) { 1859d2baff62SLaszlo Ersek vcpu->online = (status != '0'); 1860d2baff62SLaszlo Ersek vcpu->can_offline = true; 1861d2baff62SLaszlo Ersek } else if (vcpu->online != (status != '0')) { 1862d2baff62SLaszlo Ersek status = '0' + vcpu->online; 1863d2baff62SLaszlo Ersek if (pwrite(fd, &status, 1, 0) == -1) { 1864d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "pwrite(\"%s/%s\")", dirpath, 1865d2baff62SLaszlo Ersek fn); 1866d2baff62SLaszlo Ersek } 1867d2baff62SLaszlo Ersek } /* otherwise pretend successful re-(on|off)-lining */ 1868d2baff62SLaszlo Ersek 1869d2baff62SLaszlo Ersek res = close(fd); 1870d2baff62SLaszlo Ersek g_assert(res == 0); 1871d2baff62SLaszlo Ersek } 1872d2baff62SLaszlo Ersek 1873d2baff62SLaszlo Ersek res = close(dirfd); 1874d2baff62SLaszlo Ersek g_assert(res == 0); 1875d2baff62SLaszlo Ersek } 1876d2baff62SLaszlo Ersek 1877d2baff62SLaszlo Ersek g_free(dirpath); 1878d2baff62SLaszlo Ersek } 1879d2baff62SLaszlo Ersek 1880d2baff62SLaszlo Ersek GuestLogicalProcessorList *qmp_guest_get_vcpus(Error **errp) 1881d2baff62SLaszlo Ersek { 1882d2baff62SLaszlo Ersek int64_t current; 1883d2baff62SLaszlo Ersek GuestLogicalProcessorList *head, **link; 1884d2baff62SLaszlo Ersek long sc_max; 1885d2baff62SLaszlo Ersek Error *local_err = NULL; 1886d2baff62SLaszlo Ersek 1887d2baff62SLaszlo Ersek current = 0; 1888d2baff62SLaszlo Ersek head = NULL; 1889d2baff62SLaszlo Ersek link = &head; 1890d2baff62SLaszlo Ersek sc_max = SYSCONF_EXACT(_SC_NPROCESSORS_CONF, &local_err); 1891d2baff62SLaszlo Ersek 1892d2baff62SLaszlo Ersek while (local_err == NULL && current < sc_max) { 1893d2baff62SLaszlo Ersek GuestLogicalProcessor *vcpu; 1894d2baff62SLaszlo Ersek GuestLogicalProcessorList *entry; 1895d2baff62SLaszlo Ersek 1896d2baff62SLaszlo Ersek vcpu = g_malloc0(sizeof *vcpu); 1897d2baff62SLaszlo Ersek vcpu->logical_id = current++; 1898d2baff62SLaszlo Ersek vcpu->has_can_offline = true; /* lolspeak ftw */ 1899d2baff62SLaszlo Ersek transfer_vcpu(vcpu, true, &local_err); 1900d2baff62SLaszlo Ersek 1901d2baff62SLaszlo Ersek entry = g_malloc0(sizeof *entry); 1902d2baff62SLaszlo Ersek entry->value = vcpu; 1903d2baff62SLaszlo Ersek 1904d2baff62SLaszlo Ersek *link = entry; 1905d2baff62SLaszlo Ersek link = &entry->next; 1906d2baff62SLaszlo Ersek } 1907d2baff62SLaszlo Ersek 1908d2baff62SLaszlo Ersek if (local_err == NULL) { 1909d2baff62SLaszlo Ersek /* there's no guest with zero VCPUs */ 1910d2baff62SLaszlo Ersek g_assert(head != NULL); 1911d2baff62SLaszlo Ersek return head; 1912d2baff62SLaszlo Ersek } 1913d2baff62SLaszlo Ersek 1914d2baff62SLaszlo Ersek qapi_free_GuestLogicalProcessorList(head); 1915d2baff62SLaszlo Ersek error_propagate(errp, local_err); 1916d2baff62SLaszlo Ersek return NULL; 1917d2baff62SLaszlo Ersek } 1918d2baff62SLaszlo Ersek 1919cbb65fc2SLaszlo Ersek int64_t qmp_guest_set_vcpus(GuestLogicalProcessorList *vcpus, Error **errp) 1920cbb65fc2SLaszlo Ersek { 1921cbb65fc2SLaszlo Ersek int64_t processed; 1922cbb65fc2SLaszlo Ersek Error *local_err = NULL; 1923cbb65fc2SLaszlo Ersek 1924cbb65fc2SLaszlo Ersek processed = 0; 1925cbb65fc2SLaszlo Ersek while (vcpus != NULL) { 1926cbb65fc2SLaszlo Ersek transfer_vcpu(vcpus->value, false, &local_err); 1927cbb65fc2SLaszlo Ersek if (local_err != NULL) { 1928cbb65fc2SLaszlo Ersek break; 1929cbb65fc2SLaszlo Ersek } 1930cbb65fc2SLaszlo Ersek ++processed; 1931cbb65fc2SLaszlo Ersek vcpus = vcpus->next; 1932cbb65fc2SLaszlo Ersek } 1933cbb65fc2SLaszlo Ersek 1934cbb65fc2SLaszlo Ersek if (local_err != NULL) { 1935cbb65fc2SLaszlo Ersek if (processed == 0) { 1936cbb65fc2SLaszlo Ersek error_propagate(errp, local_err); 1937cbb65fc2SLaszlo Ersek } else { 1938cbb65fc2SLaszlo Ersek error_free(local_err); 1939cbb65fc2SLaszlo Ersek } 1940cbb65fc2SLaszlo Ersek } 1941cbb65fc2SLaszlo Ersek 1942cbb65fc2SLaszlo Ersek return processed; 1943cbb65fc2SLaszlo Ersek } 1944cbb65fc2SLaszlo Ersek 1945215a2771SDaniel P. Berrange void qmp_guest_set_user_password(const char *username, 1946215a2771SDaniel P. Berrange const char *password, 1947215a2771SDaniel P. Berrange bool crypted, 1948215a2771SDaniel P. Berrange Error **errp) 1949215a2771SDaniel P. Berrange { 1950215a2771SDaniel P. Berrange Error *local_err = NULL; 1951215a2771SDaniel P. Berrange char *passwd_path = NULL; 1952215a2771SDaniel P. Berrange pid_t pid; 1953215a2771SDaniel P. Berrange int status; 1954215a2771SDaniel P. Berrange int datafd[2] = { -1, -1 }; 1955215a2771SDaniel P. Berrange char *rawpasswddata = NULL; 1956215a2771SDaniel P. Berrange size_t rawpasswdlen; 1957215a2771SDaniel P. Berrange char *chpasswddata = NULL; 1958215a2771SDaniel P. Berrange size_t chpasswdlen; 1959215a2771SDaniel P. Berrange 1960920639caSDaniel P. Berrange rawpasswddata = (char *)qbase64_decode(password, -1, &rawpasswdlen, errp); 1961920639caSDaniel P. Berrange if (!rawpasswddata) { 1962920639caSDaniel P. Berrange return; 1963920639caSDaniel P. Berrange } 1964215a2771SDaniel P. Berrange rawpasswddata = g_renew(char, rawpasswddata, rawpasswdlen + 1); 1965215a2771SDaniel P. Berrange rawpasswddata[rawpasswdlen] = '\0'; 1966215a2771SDaniel P. Berrange 1967215a2771SDaniel P. Berrange if (strchr(rawpasswddata, '\n')) { 1968215a2771SDaniel P. Berrange error_setg(errp, "forbidden characters in raw password"); 1969215a2771SDaniel P. Berrange goto out; 1970215a2771SDaniel P. Berrange } 1971215a2771SDaniel P. Berrange 1972215a2771SDaniel P. Berrange if (strchr(username, '\n') || 1973215a2771SDaniel P. Berrange strchr(username, ':')) { 1974215a2771SDaniel P. Berrange error_setg(errp, "forbidden characters in username"); 1975215a2771SDaniel P. Berrange goto out; 1976215a2771SDaniel P. Berrange } 1977215a2771SDaniel P. Berrange 1978215a2771SDaniel P. Berrange chpasswddata = g_strdup_printf("%s:%s\n", username, rawpasswddata); 1979215a2771SDaniel P. Berrange chpasswdlen = strlen(chpasswddata); 1980215a2771SDaniel P. Berrange 1981215a2771SDaniel P. Berrange passwd_path = g_find_program_in_path("chpasswd"); 1982215a2771SDaniel P. Berrange 1983215a2771SDaniel P. Berrange if (!passwd_path) { 1984215a2771SDaniel P. Berrange error_setg(errp, "cannot find 'passwd' program in PATH"); 1985215a2771SDaniel P. Berrange goto out; 1986215a2771SDaniel P. Berrange } 1987215a2771SDaniel P. Berrange 1988215a2771SDaniel P. Berrange if (pipe(datafd) < 0) { 1989215a2771SDaniel P. Berrange error_setg(errp, "cannot create pipe FDs"); 1990215a2771SDaniel P. Berrange goto out; 1991215a2771SDaniel P. Berrange } 1992215a2771SDaniel P. Berrange 1993215a2771SDaniel P. Berrange pid = fork(); 1994215a2771SDaniel P. Berrange if (pid == 0) { 1995215a2771SDaniel P. Berrange close(datafd[1]); 1996215a2771SDaniel P. Berrange /* child */ 1997215a2771SDaniel P. Berrange setsid(); 1998215a2771SDaniel P. Berrange dup2(datafd[0], 0); 1999215a2771SDaniel P. Berrange reopen_fd_to_null(1); 2000215a2771SDaniel P. Berrange reopen_fd_to_null(2); 2001215a2771SDaniel P. Berrange 2002215a2771SDaniel P. Berrange if (crypted) { 2003215a2771SDaniel P. Berrange execle(passwd_path, "chpasswd", "-e", NULL, environ); 2004215a2771SDaniel P. Berrange } else { 2005215a2771SDaniel P. Berrange execle(passwd_path, "chpasswd", NULL, environ); 2006215a2771SDaniel P. Berrange } 2007215a2771SDaniel P. Berrange _exit(EXIT_FAILURE); 2008215a2771SDaniel P. Berrange } else if (pid < 0) { 2009215a2771SDaniel P. Berrange error_setg_errno(errp, errno, "failed to create child process"); 2010215a2771SDaniel P. Berrange goto out; 2011215a2771SDaniel P. Berrange } 2012215a2771SDaniel P. Berrange close(datafd[0]); 2013215a2771SDaniel P. Berrange datafd[0] = -1; 2014215a2771SDaniel P. Berrange 2015215a2771SDaniel P. Berrange if (qemu_write_full(datafd[1], chpasswddata, chpasswdlen) != chpasswdlen) { 2016215a2771SDaniel P. Berrange error_setg_errno(errp, errno, "cannot write new account password"); 2017215a2771SDaniel P. Berrange goto out; 2018215a2771SDaniel P. Berrange } 2019215a2771SDaniel P. Berrange close(datafd[1]); 2020215a2771SDaniel P. Berrange datafd[1] = -1; 2021215a2771SDaniel P. Berrange 2022215a2771SDaniel P. Berrange ga_wait_child(pid, &status, &local_err); 2023215a2771SDaniel P. Berrange if (local_err) { 2024215a2771SDaniel P. Berrange error_propagate(errp, local_err); 2025215a2771SDaniel P. Berrange goto out; 2026215a2771SDaniel P. Berrange } 2027215a2771SDaniel P. Berrange 2028215a2771SDaniel P. Berrange if (!WIFEXITED(status)) { 2029215a2771SDaniel P. Berrange error_setg(errp, "child process has terminated abnormally"); 2030215a2771SDaniel P. Berrange goto out; 2031215a2771SDaniel P. Berrange } 2032215a2771SDaniel P. Berrange 2033215a2771SDaniel P. Berrange if (WEXITSTATUS(status)) { 2034215a2771SDaniel P. Berrange error_setg(errp, "child process has failed to set user password"); 2035215a2771SDaniel P. Berrange goto out; 2036215a2771SDaniel P. Berrange } 2037215a2771SDaniel P. Berrange 2038215a2771SDaniel P. Berrange out: 2039215a2771SDaniel P. Berrange g_free(chpasswddata); 2040215a2771SDaniel P. Berrange g_free(rawpasswddata); 2041215a2771SDaniel P. Berrange g_free(passwd_path); 2042215a2771SDaniel P. Berrange if (datafd[0] != -1) { 2043215a2771SDaniel P. Berrange close(datafd[0]); 2044215a2771SDaniel P. Berrange } 2045215a2771SDaniel P. Berrange if (datafd[1] != -1) { 2046215a2771SDaniel P. Berrange close(datafd[1]); 2047215a2771SDaniel P. Berrange } 2048215a2771SDaniel P. Berrange } 2049215a2771SDaniel P. Berrange 2050bd240fcaSzhanghailiang static void ga_read_sysfs_file(int dirfd, const char *pathname, char *buf, 2051bd240fcaSzhanghailiang int size, Error **errp) 2052bd240fcaSzhanghailiang { 2053bd240fcaSzhanghailiang int fd; 2054bd240fcaSzhanghailiang int res; 2055bd240fcaSzhanghailiang 2056bd240fcaSzhanghailiang errno = 0; 2057bd240fcaSzhanghailiang fd = openat(dirfd, pathname, O_RDONLY); 2058bd240fcaSzhanghailiang if (fd == -1) { 2059bd240fcaSzhanghailiang error_setg_errno(errp, errno, "open sysfs file \"%s\"", pathname); 2060bd240fcaSzhanghailiang return; 2061bd240fcaSzhanghailiang } 2062bd240fcaSzhanghailiang 2063bd240fcaSzhanghailiang res = pread(fd, buf, size, 0); 2064bd240fcaSzhanghailiang if (res == -1) { 2065bd240fcaSzhanghailiang error_setg_errno(errp, errno, "pread sysfs file \"%s\"", pathname); 2066bd240fcaSzhanghailiang } else if (res == 0) { 2067bd240fcaSzhanghailiang error_setg(errp, "pread sysfs file \"%s\": unexpected EOF", pathname); 2068bd240fcaSzhanghailiang } 2069bd240fcaSzhanghailiang close(fd); 2070bd240fcaSzhanghailiang } 2071bd240fcaSzhanghailiang 2072bd240fcaSzhanghailiang static void ga_write_sysfs_file(int dirfd, const char *pathname, 2073bd240fcaSzhanghailiang const char *buf, int size, Error **errp) 2074bd240fcaSzhanghailiang { 2075bd240fcaSzhanghailiang int fd; 2076bd240fcaSzhanghailiang 2077bd240fcaSzhanghailiang errno = 0; 2078bd240fcaSzhanghailiang fd = openat(dirfd, pathname, O_WRONLY); 2079bd240fcaSzhanghailiang if (fd == -1) { 2080bd240fcaSzhanghailiang error_setg_errno(errp, errno, "open sysfs file \"%s\"", pathname); 2081bd240fcaSzhanghailiang return; 2082bd240fcaSzhanghailiang } 2083bd240fcaSzhanghailiang 2084bd240fcaSzhanghailiang if (pwrite(fd, buf, size, 0) == -1) { 2085bd240fcaSzhanghailiang error_setg_errno(errp, errno, "pwrite sysfs file \"%s\"", pathname); 2086bd240fcaSzhanghailiang } 2087bd240fcaSzhanghailiang 2088bd240fcaSzhanghailiang close(fd); 2089bd240fcaSzhanghailiang } 2090bd240fcaSzhanghailiang 2091bd240fcaSzhanghailiang /* Transfer online/offline status between @mem_blk and the guest system. 2092bd240fcaSzhanghailiang * 2093bd240fcaSzhanghailiang * On input either @errp or *@errp must be NULL. 2094bd240fcaSzhanghailiang * 2095bd240fcaSzhanghailiang * In system-to-@mem_blk direction, the following @mem_blk fields are accessed: 2096bd240fcaSzhanghailiang * - R: mem_blk->phys_index 2097bd240fcaSzhanghailiang * - W: mem_blk->online 2098bd240fcaSzhanghailiang * - W: mem_blk->can_offline 2099bd240fcaSzhanghailiang * 2100bd240fcaSzhanghailiang * In @mem_blk-to-system direction, the following @mem_blk fields are accessed: 2101bd240fcaSzhanghailiang * - R: mem_blk->phys_index 2102bd240fcaSzhanghailiang * - R: mem_blk->online 2103bd240fcaSzhanghailiang *- R: mem_blk->can_offline 2104bd240fcaSzhanghailiang * Written members remain unmodified on error. 2105bd240fcaSzhanghailiang */ 2106bd240fcaSzhanghailiang static void transfer_memory_block(GuestMemoryBlock *mem_blk, bool sys2memblk, 2107bd240fcaSzhanghailiang GuestMemoryBlockResponse *result, 2108bd240fcaSzhanghailiang Error **errp) 2109bd240fcaSzhanghailiang { 2110bd240fcaSzhanghailiang char *dirpath; 2111bd240fcaSzhanghailiang int dirfd; 2112bd240fcaSzhanghailiang char *status; 2113bd240fcaSzhanghailiang Error *local_err = NULL; 2114bd240fcaSzhanghailiang 2115bd240fcaSzhanghailiang if (!sys2memblk) { 2116bd240fcaSzhanghailiang DIR *dp; 2117bd240fcaSzhanghailiang 2118bd240fcaSzhanghailiang if (!result) { 2119bd240fcaSzhanghailiang error_setg(errp, "Internal error, 'result' should not be NULL"); 2120bd240fcaSzhanghailiang return; 2121bd240fcaSzhanghailiang } 2122bd240fcaSzhanghailiang errno = 0; 2123bd240fcaSzhanghailiang dp = opendir("/sys/devices/system/memory/"); 2124bd240fcaSzhanghailiang /* if there is no 'memory' directory in sysfs, 2125bd240fcaSzhanghailiang * we think this VM does not support online/offline memory block, 2126bd240fcaSzhanghailiang * any other solution? 2127bd240fcaSzhanghailiang */ 21289879f5acSPhilippe Mathieu-Daudé if (!dp) { 21299879f5acSPhilippe Mathieu-Daudé if (errno == ENOENT) { 2130bd240fcaSzhanghailiang result->response = 2131bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_NOT_SUPPORTED; 21329879f5acSPhilippe Mathieu-Daudé } 2133bd240fcaSzhanghailiang goto out1; 2134bd240fcaSzhanghailiang } 2135bd240fcaSzhanghailiang closedir(dp); 2136bd240fcaSzhanghailiang } 2137bd240fcaSzhanghailiang 2138bd240fcaSzhanghailiang dirpath = g_strdup_printf("/sys/devices/system/memory/memory%" PRId64 "/", 2139bd240fcaSzhanghailiang mem_blk->phys_index); 2140bd240fcaSzhanghailiang dirfd = open(dirpath, O_RDONLY | O_DIRECTORY); 2141bd240fcaSzhanghailiang if (dirfd == -1) { 2142bd240fcaSzhanghailiang if (sys2memblk) { 2143bd240fcaSzhanghailiang error_setg_errno(errp, errno, "open(\"%s\")", dirpath); 2144bd240fcaSzhanghailiang } else { 2145bd240fcaSzhanghailiang if (errno == ENOENT) { 2146bd240fcaSzhanghailiang result->response = GUEST_MEMORY_BLOCK_RESPONSE_TYPE_NOT_FOUND; 2147bd240fcaSzhanghailiang } else { 2148bd240fcaSzhanghailiang result->response = 2149bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_FAILED; 2150bd240fcaSzhanghailiang } 2151bd240fcaSzhanghailiang } 2152bd240fcaSzhanghailiang g_free(dirpath); 2153bd240fcaSzhanghailiang goto out1; 2154bd240fcaSzhanghailiang } 2155bd240fcaSzhanghailiang g_free(dirpath); 2156bd240fcaSzhanghailiang 2157bd240fcaSzhanghailiang status = g_malloc0(10); 2158bd240fcaSzhanghailiang ga_read_sysfs_file(dirfd, "state", status, 10, &local_err); 2159bd240fcaSzhanghailiang if (local_err) { 2160bd240fcaSzhanghailiang /* treat with sysfs file that not exist in old kernel */ 2161bd240fcaSzhanghailiang if (errno == ENOENT) { 2162bd240fcaSzhanghailiang error_free(local_err); 2163bd240fcaSzhanghailiang if (sys2memblk) { 2164bd240fcaSzhanghailiang mem_blk->online = true; 2165bd240fcaSzhanghailiang mem_blk->can_offline = false; 2166bd240fcaSzhanghailiang } else if (!mem_blk->online) { 2167bd240fcaSzhanghailiang result->response = 2168bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_NOT_SUPPORTED; 2169bd240fcaSzhanghailiang } 2170bd240fcaSzhanghailiang } else { 2171bd240fcaSzhanghailiang if (sys2memblk) { 2172bd240fcaSzhanghailiang error_propagate(errp, local_err); 2173bd240fcaSzhanghailiang } else { 2174bd240fcaSzhanghailiang result->response = 2175bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_FAILED; 2176bd240fcaSzhanghailiang } 2177bd240fcaSzhanghailiang } 2178bd240fcaSzhanghailiang goto out2; 2179bd240fcaSzhanghailiang } 2180bd240fcaSzhanghailiang 2181bd240fcaSzhanghailiang if (sys2memblk) { 2182bd240fcaSzhanghailiang char removable = '0'; 2183bd240fcaSzhanghailiang 2184bd240fcaSzhanghailiang mem_blk->online = (strncmp(status, "online", 6) == 0); 2185bd240fcaSzhanghailiang 2186bd240fcaSzhanghailiang ga_read_sysfs_file(dirfd, "removable", &removable, 1, &local_err); 2187bd240fcaSzhanghailiang if (local_err) { 218867cc32ebSVeres Lajos /* if no 'removable' file, it doesn't support offline mem blk */ 2189bd240fcaSzhanghailiang if (errno == ENOENT) { 2190bd240fcaSzhanghailiang error_free(local_err); 2191bd240fcaSzhanghailiang mem_blk->can_offline = false; 2192bd240fcaSzhanghailiang } else { 2193bd240fcaSzhanghailiang error_propagate(errp, local_err); 2194bd240fcaSzhanghailiang } 2195bd240fcaSzhanghailiang } else { 2196bd240fcaSzhanghailiang mem_blk->can_offline = (removable != '0'); 2197bd240fcaSzhanghailiang } 2198bd240fcaSzhanghailiang } else { 2199bd240fcaSzhanghailiang if (mem_blk->online != (strncmp(status, "online", 6) == 0)) { 2200*7064024dSMarc-André Lureau const char *new_state = mem_blk->online ? "online" : "offline"; 2201bd240fcaSzhanghailiang 2202bd240fcaSzhanghailiang ga_write_sysfs_file(dirfd, "state", new_state, strlen(new_state), 2203bd240fcaSzhanghailiang &local_err); 2204bd240fcaSzhanghailiang if (local_err) { 2205bd240fcaSzhanghailiang error_free(local_err); 2206bd240fcaSzhanghailiang result->response = 2207bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_FAILED; 2208bd240fcaSzhanghailiang goto out2; 2209bd240fcaSzhanghailiang } 2210bd240fcaSzhanghailiang 2211bd240fcaSzhanghailiang result->response = GUEST_MEMORY_BLOCK_RESPONSE_TYPE_SUCCESS; 2212bd240fcaSzhanghailiang result->has_error_code = false; 2213bd240fcaSzhanghailiang } /* otherwise pretend successful re-(on|off)-lining */ 2214bd240fcaSzhanghailiang } 2215bd240fcaSzhanghailiang g_free(status); 2216bd240fcaSzhanghailiang close(dirfd); 2217bd240fcaSzhanghailiang return; 2218bd240fcaSzhanghailiang 2219bd240fcaSzhanghailiang out2: 2220bd240fcaSzhanghailiang g_free(status); 2221bd240fcaSzhanghailiang close(dirfd); 2222bd240fcaSzhanghailiang out1: 2223bd240fcaSzhanghailiang if (!sys2memblk) { 2224bd240fcaSzhanghailiang result->has_error_code = true; 2225bd240fcaSzhanghailiang result->error_code = errno; 2226bd240fcaSzhanghailiang } 2227bd240fcaSzhanghailiang } 2228bd240fcaSzhanghailiang 2229a065aaa9Szhanghailiang GuestMemoryBlockList *qmp_guest_get_memory_blocks(Error **errp) 2230a065aaa9Szhanghailiang { 2231bd240fcaSzhanghailiang GuestMemoryBlockList *head, **link; 2232bd240fcaSzhanghailiang Error *local_err = NULL; 2233bd240fcaSzhanghailiang struct dirent *de; 2234bd240fcaSzhanghailiang DIR *dp; 2235bd240fcaSzhanghailiang 2236bd240fcaSzhanghailiang head = NULL; 2237bd240fcaSzhanghailiang link = &head; 2238bd240fcaSzhanghailiang 2239bd240fcaSzhanghailiang dp = opendir("/sys/devices/system/memory/"); 2240bd240fcaSzhanghailiang if (!dp) { 2241f693fe6eSMichael Roth /* it's ok if this happens to be a system that doesn't expose 2242f693fe6eSMichael Roth * memory blocks via sysfs, but otherwise we should report 2243f693fe6eSMichael Roth * an error 2244f693fe6eSMichael Roth */ 2245f693fe6eSMichael Roth if (errno != ENOENT) { 2246bd240fcaSzhanghailiang error_setg_errno(errp, errno, "Can't open directory" 22479af9e0feSMarkus Armbruster "\"/sys/devices/system/memory/\""); 2248f693fe6eSMichael Roth } 2249bd240fcaSzhanghailiang return NULL; 2250bd240fcaSzhanghailiang } 2251bd240fcaSzhanghailiang 2252bd240fcaSzhanghailiang /* Note: the phys_index of memory block may be discontinuous, 2253bd240fcaSzhanghailiang * this is because a memblk is the unit of the Sparse Memory design, which 2254bd240fcaSzhanghailiang * allows discontinuous memory ranges (ex. NUMA), so here we should 2255bd240fcaSzhanghailiang * traverse the memory block directory. 2256bd240fcaSzhanghailiang */ 2257bd240fcaSzhanghailiang while ((de = readdir(dp)) != NULL) { 2258bd240fcaSzhanghailiang GuestMemoryBlock *mem_blk; 2259bd240fcaSzhanghailiang GuestMemoryBlockList *entry; 2260bd240fcaSzhanghailiang 2261bd240fcaSzhanghailiang if ((strncmp(de->d_name, "memory", 6) != 0) || 2262bd240fcaSzhanghailiang !(de->d_type & DT_DIR)) { 2263bd240fcaSzhanghailiang continue; 2264bd240fcaSzhanghailiang } 2265bd240fcaSzhanghailiang 2266bd240fcaSzhanghailiang mem_blk = g_malloc0(sizeof *mem_blk); 2267bd240fcaSzhanghailiang /* The d_name is "memoryXXX", phys_index is block id, same as XXX */ 2268bd240fcaSzhanghailiang mem_blk->phys_index = strtoul(&de->d_name[6], NULL, 10); 2269bd240fcaSzhanghailiang mem_blk->has_can_offline = true; /* lolspeak ftw */ 2270bd240fcaSzhanghailiang transfer_memory_block(mem_blk, true, NULL, &local_err); 2271bd240fcaSzhanghailiang 2272bd240fcaSzhanghailiang entry = g_malloc0(sizeof *entry); 2273bd240fcaSzhanghailiang entry->value = mem_blk; 2274bd240fcaSzhanghailiang 2275bd240fcaSzhanghailiang *link = entry; 2276bd240fcaSzhanghailiang link = &entry->next; 2277bd240fcaSzhanghailiang } 2278bd240fcaSzhanghailiang 2279bd240fcaSzhanghailiang closedir(dp); 2280bd240fcaSzhanghailiang if (local_err == NULL) { 2281bd240fcaSzhanghailiang /* there's no guest with zero memory blocks */ 2282bd240fcaSzhanghailiang if (head == NULL) { 2283bd240fcaSzhanghailiang error_setg(errp, "guest reported zero memory blocks!"); 2284bd240fcaSzhanghailiang } 2285bd240fcaSzhanghailiang return head; 2286bd240fcaSzhanghailiang } 2287bd240fcaSzhanghailiang 2288bd240fcaSzhanghailiang qapi_free_GuestMemoryBlockList(head); 2289bd240fcaSzhanghailiang error_propagate(errp, local_err); 2290a065aaa9Szhanghailiang return NULL; 2291a065aaa9Szhanghailiang } 2292a065aaa9Szhanghailiang 2293a065aaa9Szhanghailiang GuestMemoryBlockResponseList * 2294a065aaa9Szhanghailiang qmp_guest_set_memory_blocks(GuestMemoryBlockList *mem_blks, Error **errp) 2295a065aaa9Szhanghailiang { 229632ca7927Szhanghailiang GuestMemoryBlockResponseList *head, **link; 229732ca7927Szhanghailiang Error *local_err = NULL; 229832ca7927Szhanghailiang 229932ca7927Szhanghailiang head = NULL; 230032ca7927Szhanghailiang link = &head; 230132ca7927Szhanghailiang 230232ca7927Szhanghailiang while (mem_blks != NULL) { 230332ca7927Szhanghailiang GuestMemoryBlockResponse *result; 230432ca7927Szhanghailiang GuestMemoryBlockResponseList *entry; 230532ca7927Szhanghailiang GuestMemoryBlock *current_mem_blk = mem_blks->value; 230632ca7927Szhanghailiang 230732ca7927Szhanghailiang result = g_malloc0(sizeof(*result)); 230832ca7927Szhanghailiang result->phys_index = current_mem_blk->phys_index; 230932ca7927Szhanghailiang transfer_memory_block(current_mem_blk, false, result, &local_err); 231032ca7927Szhanghailiang if (local_err) { /* should never happen */ 231132ca7927Szhanghailiang goto err; 231232ca7927Szhanghailiang } 231332ca7927Szhanghailiang entry = g_malloc0(sizeof *entry); 231432ca7927Szhanghailiang entry->value = result; 231532ca7927Szhanghailiang 231632ca7927Szhanghailiang *link = entry; 231732ca7927Szhanghailiang link = &entry->next; 231832ca7927Szhanghailiang mem_blks = mem_blks->next; 231932ca7927Szhanghailiang } 232032ca7927Szhanghailiang 232132ca7927Szhanghailiang return head; 232232ca7927Szhanghailiang err: 232332ca7927Szhanghailiang qapi_free_GuestMemoryBlockResponseList(head); 232432ca7927Szhanghailiang error_propagate(errp, local_err); 2325a065aaa9Szhanghailiang return NULL; 2326a065aaa9Szhanghailiang } 2327a065aaa9Szhanghailiang 2328a065aaa9Szhanghailiang GuestMemoryBlockInfo *qmp_guest_get_memory_block_info(Error **errp) 2329a065aaa9Szhanghailiang { 2330ef82b60bSzhanghailiang Error *local_err = NULL; 2331ef82b60bSzhanghailiang char *dirpath; 2332ef82b60bSzhanghailiang int dirfd; 2333ef82b60bSzhanghailiang char *buf; 2334ef82b60bSzhanghailiang GuestMemoryBlockInfo *info; 2335ef82b60bSzhanghailiang 2336ef82b60bSzhanghailiang dirpath = g_strdup_printf("/sys/devices/system/memory/"); 2337ef82b60bSzhanghailiang dirfd = open(dirpath, O_RDONLY | O_DIRECTORY); 2338ef82b60bSzhanghailiang if (dirfd == -1) { 2339ef82b60bSzhanghailiang error_setg_errno(errp, errno, "open(\"%s\")", dirpath); 2340ef82b60bSzhanghailiang g_free(dirpath); 2341a065aaa9Szhanghailiang return NULL; 2342a065aaa9Szhanghailiang } 2343ef82b60bSzhanghailiang g_free(dirpath); 2344ef82b60bSzhanghailiang 2345ef82b60bSzhanghailiang buf = g_malloc0(20); 2346ef82b60bSzhanghailiang ga_read_sysfs_file(dirfd, "block_size_bytes", buf, 20, &local_err); 23478ce1ee46SShannon Zhao close(dirfd); 2348ef82b60bSzhanghailiang if (local_err) { 2349ef82b60bSzhanghailiang g_free(buf); 2350ef82b60bSzhanghailiang error_propagate(errp, local_err); 2351ef82b60bSzhanghailiang return NULL; 2352ef82b60bSzhanghailiang } 2353ef82b60bSzhanghailiang 2354ef82b60bSzhanghailiang info = g_new0(GuestMemoryBlockInfo, 1); 2355ef82b60bSzhanghailiang info->size = strtol(buf, NULL, 16); /* the unit is bytes */ 2356ef82b60bSzhanghailiang 2357ef82b60bSzhanghailiang g_free(buf); 2358ef82b60bSzhanghailiang 2359ef82b60bSzhanghailiang return info; 2360ef82b60bSzhanghailiang } 2361a065aaa9Szhanghailiang 2362e72c3f2eSMichael Roth #else /* defined(__linux__) */ 2363e72c3f2eSMichael Roth 236477dbc81bSMarkus Armbruster void qmp_guest_suspend_disk(Error **errp) 2365e72c3f2eSMichael Roth { 2366c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2367e72c3f2eSMichael Roth } 2368e72c3f2eSMichael Roth 236977dbc81bSMarkus Armbruster void qmp_guest_suspend_ram(Error **errp) 2370e72c3f2eSMichael Roth { 2371c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2372e72c3f2eSMichael Roth } 2373e72c3f2eSMichael Roth 237477dbc81bSMarkus Armbruster void qmp_guest_suspend_hybrid(Error **errp) 2375e72c3f2eSMichael Roth { 2376c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2377e72c3f2eSMichael Roth } 2378e72c3f2eSMichael Roth 2379e72c3f2eSMichael Roth GuestNetworkInterfaceList *qmp_guest_network_get_interfaces(Error **errp) 2380e72c3f2eSMichael Roth { 2381c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2382e72c3f2eSMichael Roth return NULL; 2383e72c3f2eSMichael Roth } 2384e72c3f2eSMichael Roth 2385d2baff62SLaszlo Ersek GuestLogicalProcessorList *qmp_guest_get_vcpus(Error **errp) 2386d2baff62SLaszlo Ersek { 2387c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2388d2baff62SLaszlo Ersek return NULL; 2389d2baff62SLaszlo Ersek } 2390d2baff62SLaszlo Ersek 2391cbb65fc2SLaszlo Ersek int64_t qmp_guest_set_vcpus(GuestLogicalProcessorList *vcpus, Error **errp) 2392cbb65fc2SLaszlo Ersek { 2393c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2394cbb65fc2SLaszlo Ersek return -1; 2395cbb65fc2SLaszlo Ersek } 2396cbb65fc2SLaszlo Ersek 2397215a2771SDaniel P. Berrange void qmp_guest_set_user_password(const char *username, 2398215a2771SDaniel P. Berrange const char *password, 2399215a2771SDaniel P. Berrange bool crypted, 2400215a2771SDaniel P. Berrange Error **errp) 2401215a2771SDaniel P. Berrange { 2402c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2403215a2771SDaniel P. Berrange } 2404215a2771SDaniel P. Berrange 2405a065aaa9Szhanghailiang GuestMemoryBlockList *qmp_guest_get_memory_blocks(Error **errp) 2406a065aaa9Szhanghailiang { 2407c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2408a065aaa9Szhanghailiang return NULL; 2409a065aaa9Szhanghailiang } 2410a065aaa9Szhanghailiang 2411a065aaa9Szhanghailiang GuestMemoryBlockResponseList * 2412a065aaa9Szhanghailiang qmp_guest_set_memory_blocks(GuestMemoryBlockList *mem_blks, Error **errp) 2413a065aaa9Szhanghailiang { 2414c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2415a065aaa9Szhanghailiang return NULL; 2416a065aaa9Szhanghailiang } 2417a065aaa9Szhanghailiang 2418a065aaa9Szhanghailiang GuestMemoryBlockInfo *qmp_guest_get_memory_block_info(Error **errp) 2419a065aaa9Szhanghailiang { 2420c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2421a065aaa9Szhanghailiang return NULL; 2422a065aaa9Szhanghailiang } 2423a065aaa9Szhanghailiang 2424e72c3f2eSMichael Roth #endif 2425e72c3f2eSMichael Roth 2426d35d4cb5SMichael Roth #if !defined(CONFIG_FSFREEZE) 2427d35d4cb5SMichael Roth 242846d4c572STomoki Sekiyama GuestFilesystemInfoList *qmp_guest_get_fsinfo(Error **errp) 242946d4c572STomoki Sekiyama { 2430c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 243146d4c572STomoki Sekiyama return NULL; 243246d4c572STomoki Sekiyama } 243346d4c572STomoki Sekiyama 243477dbc81bSMarkus Armbruster GuestFsfreezeStatus qmp_guest_fsfreeze_status(Error **errp) 2435d35d4cb5SMichael Roth { 2436c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2437d35d4cb5SMichael Roth 2438d35d4cb5SMichael Roth return 0; 2439d35d4cb5SMichael Roth } 2440d35d4cb5SMichael Roth 244177dbc81bSMarkus Armbruster int64_t qmp_guest_fsfreeze_freeze(Error **errp) 2442d35d4cb5SMichael Roth { 2443c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2444d35d4cb5SMichael Roth 2445d35d4cb5SMichael Roth return 0; 2446d35d4cb5SMichael Roth } 2447d35d4cb5SMichael Roth 2448e99bce20STomoki Sekiyama int64_t qmp_guest_fsfreeze_freeze_list(bool has_mountpoints, 2449e99bce20STomoki Sekiyama strList *mountpoints, 2450e99bce20STomoki Sekiyama Error **errp) 2451e99bce20STomoki Sekiyama { 2452c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2453e99bce20STomoki Sekiyama 2454e99bce20STomoki Sekiyama return 0; 2455e99bce20STomoki Sekiyama } 2456e99bce20STomoki Sekiyama 245777dbc81bSMarkus Armbruster int64_t qmp_guest_fsfreeze_thaw(Error **errp) 2458d35d4cb5SMichael Roth { 2459c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2460d35d4cb5SMichael Roth 2461d35d4cb5SMichael Roth return 0; 2462d35d4cb5SMichael Roth } 2463eab5fd59SPaolo Bonzini #endif /* CONFIG_FSFREEZE */ 2464d35d4cb5SMichael Roth 2465eab5fd59SPaolo Bonzini #if !defined(CONFIG_FSTRIM) 2466e82855d9SJustin Ossevoort GuestFilesystemTrimResponse * 2467e82855d9SJustin Ossevoort qmp_guest_fstrim(bool has_minimum, int64_t minimum, Error **errp) 2468eab5fd59SPaolo Bonzini { 2469c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2470e82855d9SJustin Ossevoort return NULL; 2471eab5fd59SPaolo Bonzini } 2472d35d4cb5SMichael Roth #endif 2473d35d4cb5SMichael Roth 24741281c08aSTomoki Sekiyama /* add unsupported commands to the blacklist */ 24751281c08aSTomoki Sekiyama GList *ga_command_blacklist_init(GList *blacklist) 24761281c08aSTomoki Sekiyama { 24771281c08aSTomoki Sekiyama #if !defined(__linux__) 24781281c08aSTomoki Sekiyama { 24791281c08aSTomoki Sekiyama const char *list[] = { 24801281c08aSTomoki Sekiyama "guest-suspend-disk", "guest-suspend-ram", 24811281c08aSTomoki Sekiyama "guest-suspend-hybrid", "guest-network-get-interfaces", 24820dd38a03Szhanghailiang "guest-get-vcpus", "guest-set-vcpus", 24830dd38a03Szhanghailiang "guest-get-memory-blocks", "guest-set-memory-blocks", 24840dd38a03Szhanghailiang "guest-get-memory-block-size", NULL}; 24851281c08aSTomoki Sekiyama char **p = (char **)list; 24861281c08aSTomoki Sekiyama 24871281c08aSTomoki Sekiyama while (*p) { 24884bca81ceSMarc-André Lureau blacklist = g_list_append(blacklist, g_strdup(*p++)); 24891281c08aSTomoki Sekiyama } 24901281c08aSTomoki Sekiyama } 24911281c08aSTomoki Sekiyama #endif 24921281c08aSTomoki Sekiyama 24931281c08aSTomoki Sekiyama #if !defined(CONFIG_FSFREEZE) 24941281c08aSTomoki Sekiyama { 24951281c08aSTomoki Sekiyama const char *list[] = { 24961281c08aSTomoki Sekiyama "guest-get-fsinfo", "guest-fsfreeze-status", 24971281c08aSTomoki Sekiyama "guest-fsfreeze-freeze", "guest-fsfreeze-freeze-list", 24981281c08aSTomoki Sekiyama "guest-fsfreeze-thaw", "guest-get-fsinfo", NULL}; 24991281c08aSTomoki Sekiyama char **p = (char **)list; 25001281c08aSTomoki Sekiyama 25011281c08aSTomoki Sekiyama while (*p) { 25024bca81ceSMarc-André Lureau blacklist = g_list_append(blacklist, g_strdup(*p++)); 25031281c08aSTomoki Sekiyama } 25041281c08aSTomoki Sekiyama } 25051281c08aSTomoki Sekiyama #endif 25061281c08aSTomoki Sekiyama 25071281c08aSTomoki Sekiyama #if !defined(CONFIG_FSTRIM) 25084bca81ceSMarc-André Lureau blacklist = g_list_append(blacklist, g_strdup("guest-fstrim")); 25091281c08aSTomoki Sekiyama #endif 25101281c08aSTomoki Sekiyama 25111281c08aSTomoki Sekiyama return blacklist; 25121281c08aSTomoki Sekiyama } 25131281c08aSTomoki Sekiyama 2514c216e5adSMichael Roth /* register init/cleanup routines for stateful command groups */ 2515c216e5adSMichael Roth void ga_command_state_init(GAState *s, GACommandState *cs) 2516c216e5adSMichael Roth { 2517c216e5adSMichael Roth #if defined(CONFIG_FSFREEZE) 2518f22d85e9SMichael Roth ga_command_state_add(cs, NULL, guest_fsfreeze_cleanup); 2519c216e5adSMichael Roth #endif 2520c216e5adSMichael Roth } 2521161a56a9SVinzenz Feenstra 2522161a56a9SVinzenz Feenstra #define QGA_MICRO_SECOND_TO_SECOND 1000000 2523161a56a9SVinzenz Feenstra 2524161a56a9SVinzenz Feenstra static double ga_get_login_time(struct utmpx *user_info) 2525161a56a9SVinzenz Feenstra { 2526161a56a9SVinzenz Feenstra double seconds = (double)user_info->ut_tv.tv_sec; 2527161a56a9SVinzenz Feenstra double useconds = (double)user_info->ut_tv.tv_usec; 2528161a56a9SVinzenz Feenstra useconds /= QGA_MICRO_SECOND_TO_SECOND; 2529161a56a9SVinzenz Feenstra return seconds + useconds; 2530161a56a9SVinzenz Feenstra } 2531161a56a9SVinzenz Feenstra 2532161a56a9SVinzenz Feenstra GuestUserList *qmp_guest_get_users(Error **err) 2533161a56a9SVinzenz Feenstra { 2534161a56a9SVinzenz Feenstra GHashTable *cache = NULL; 2535161a56a9SVinzenz Feenstra GuestUserList *head = NULL, *cur_item = NULL; 2536161a56a9SVinzenz Feenstra struct utmpx *user_info = NULL; 2537161a56a9SVinzenz Feenstra gpointer value = NULL; 2538161a56a9SVinzenz Feenstra GuestUser *user = NULL; 2539161a56a9SVinzenz Feenstra GuestUserList *item = NULL; 2540161a56a9SVinzenz Feenstra double login_time = 0; 2541161a56a9SVinzenz Feenstra 2542161a56a9SVinzenz Feenstra cache = g_hash_table_new(g_str_hash, g_str_equal); 2543161a56a9SVinzenz Feenstra setutxent(); 2544161a56a9SVinzenz Feenstra 2545161a56a9SVinzenz Feenstra for (;;) { 2546161a56a9SVinzenz Feenstra user_info = getutxent(); 2547161a56a9SVinzenz Feenstra if (user_info == NULL) { 2548161a56a9SVinzenz Feenstra break; 2549161a56a9SVinzenz Feenstra } else if (user_info->ut_type != USER_PROCESS) { 2550161a56a9SVinzenz Feenstra continue; 2551161a56a9SVinzenz Feenstra } else if (g_hash_table_contains(cache, user_info->ut_user)) { 2552161a56a9SVinzenz Feenstra value = g_hash_table_lookup(cache, user_info->ut_user); 2553161a56a9SVinzenz Feenstra user = (GuestUser *)value; 2554161a56a9SVinzenz Feenstra login_time = ga_get_login_time(user_info); 2555161a56a9SVinzenz Feenstra /* We're ensuring the earliest login time to be sent */ 2556161a56a9SVinzenz Feenstra if (login_time < user->login_time) { 2557161a56a9SVinzenz Feenstra user->login_time = login_time; 2558161a56a9SVinzenz Feenstra } 2559161a56a9SVinzenz Feenstra continue; 2560161a56a9SVinzenz Feenstra } 2561161a56a9SVinzenz Feenstra 2562161a56a9SVinzenz Feenstra item = g_new0(GuestUserList, 1); 2563161a56a9SVinzenz Feenstra item->value = g_new0(GuestUser, 1); 2564161a56a9SVinzenz Feenstra item->value->user = g_strdup(user_info->ut_user); 2565161a56a9SVinzenz Feenstra item->value->login_time = ga_get_login_time(user_info); 2566161a56a9SVinzenz Feenstra 2567161a56a9SVinzenz Feenstra g_hash_table_insert(cache, item->value->user, item->value); 2568161a56a9SVinzenz Feenstra 2569161a56a9SVinzenz Feenstra if (!cur_item) { 2570161a56a9SVinzenz Feenstra head = cur_item = item; 2571161a56a9SVinzenz Feenstra } else { 2572161a56a9SVinzenz Feenstra cur_item->next = item; 2573161a56a9SVinzenz Feenstra cur_item = item; 2574161a56a9SVinzenz Feenstra } 2575161a56a9SVinzenz Feenstra } 2576161a56a9SVinzenz Feenstra endutxent(); 2577161a56a9SVinzenz Feenstra g_hash_table_destroy(cache); 2578161a56a9SVinzenz Feenstra return head; 2579161a56a9SVinzenz Feenstra } 2580