1c216e5adSMichael Roth /* 2c216e5adSMichael Roth * QEMU Guest Agent POSIX-specific command implementations 3c216e5adSMichael Roth * 4c216e5adSMichael Roth * Copyright IBM Corp. 2011 5c216e5adSMichael Roth * 6c216e5adSMichael Roth * Authors: 7c216e5adSMichael Roth * Michael Roth <mdroth@linux.vnet.ibm.com> 83424fc9fSMichal Privoznik * Michal Privoznik <mprivozn@redhat.com> 9c216e5adSMichael Roth * 10c216e5adSMichael Roth * This work is licensed under the terms of the GNU GPL, version 2 or later. 11c216e5adSMichael Roth * See the COPYING file in the top-level directory. 12c216e5adSMichael Roth */ 13c216e5adSMichael Roth 144459bf38SPeter Maydell #include "qemu/osdep.h" 15c216e5adSMichael Roth #include <sys/ioctl.h> 169848f797STomáš Golembiovský #include <sys/utsname.h> 172c02cbf6SLuiz Capitulino #include <sys/wait.h> 1846d4c572STomoki Sekiyama #include <dirent.h> 19dc03272dSMichael S. Tsirkin #include "guest-agent-core.h" 20eb815e24SMarkus Armbruster #include "qga-qapi-commands.h" 21e688df6bSMarkus Armbruster #include "qapi/error.h" 227b1b5d19SPaolo Bonzini #include "qapi/qmp/qerror.h" 231de7afc9SPaolo Bonzini #include "qemu/queue.h" 241de7afc9SPaolo Bonzini #include "qemu/host-utils.h" 2512505396SDenis V. Lunev #include "qemu/sockets.h" 26920639caSDaniel P. Berrange #include "qemu/base64.h" 27f348b6d1SVeronia Bahaa #include "qemu/cutils.h" 28c216e5adSMichael Roth 29e674605fSTomáš Golembiovský #ifdef HAVE_UTMPX 30e674605fSTomáš Golembiovský #include <utmpx.h> 31e674605fSTomáš Golembiovský #endif 32e674605fSTomáš Golembiovský 332c02cbf6SLuiz Capitulino #ifndef CONFIG_HAS_ENVIRON 34eecae147SAndreas Färber #ifdef __APPLE__ 35eecae147SAndreas Färber #include <crt_externs.h> 36eecae147SAndreas Färber #define environ (*_NSGetEnviron()) 37eecae147SAndreas Färber #else 382c02cbf6SLuiz Capitulino extern char **environ; 392c02cbf6SLuiz Capitulino #endif 40eecae147SAndreas Färber #endif 412c02cbf6SLuiz Capitulino 42e72c3f2eSMichael Roth #if defined(__linux__) 43e72c3f2eSMichael Roth #include <mntent.h> 44e72c3f2eSMichael Roth #include <linux/fs.h> 45e72c3f2eSMichael Roth #include <ifaddrs.h> 46e72c3f2eSMichael Roth #include <arpa/inet.h> 47e72c3f2eSMichael Roth #include <sys/socket.h> 48e72c3f2eSMichael Roth #include <net/if.h> 49*25b5ff1aSChen Hanxiao #include <sys/statvfs.h> 50e72c3f2eSMichael Roth 51eab5fd59SPaolo Bonzini #ifdef FIFREEZE 52e72c3f2eSMichael Roth #define CONFIG_FSFREEZE 53e72c3f2eSMichael Roth #endif 54eab5fd59SPaolo Bonzini #ifdef FITRIM 55eab5fd59SPaolo Bonzini #define CONFIG_FSTRIM 56eab5fd59SPaolo Bonzini #endif 57e72c3f2eSMichael Roth #endif 58e72c3f2eSMichael Roth 5977dbc81bSMarkus Armbruster static void ga_wait_child(pid_t pid, int *status, Error **errp) 60d220a6dfSLuiz Capitulino { 61d220a6dfSLuiz Capitulino pid_t rpid; 62d220a6dfSLuiz Capitulino 63d220a6dfSLuiz Capitulino *status = 0; 64d220a6dfSLuiz Capitulino 65d220a6dfSLuiz Capitulino do { 66d220a6dfSLuiz Capitulino rpid = waitpid(pid, status, 0); 67d220a6dfSLuiz Capitulino } while (rpid == -1 && errno == EINTR); 68d220a6dfSLuiz Capitulino 69d220a6dfSLuiz Capitulino if (rpid == -1) { 7077dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to wait for child (pid: %d)", 7177dbc81bSMarkus Armbruster pid); 72d220a6dfSLuiz Capitulino return; 73d220a6dfSLuiz Capitulino } 74d220a6dfSLuiz Capitulino 75d220a6dfSLuiz Capitulino g_assert(rpid == pid); 76d220a6dfSLuiz Capitulino } 77d220a6dfSLuiz Capitulino 7877dbc81bSMarkus Armbruster void qmp_guest_shutdown(bool has_mode, const char *mode, Error **errp) 79c216e5adSMichael Roth { 80c216e5adSMichael Roth const char *shutdown_flag; 81d220a6dfSLuiz Capitulino Error *local_err = NULL; 82d220a6dfSLuiz Capitulino pid_t pid; 833674838cSLuiz Capitulino int status; 84c216e5adSMichael Roth 85c216e5adSMichael Roth slog("guest-shutdown called, mode: %s", mode); 86c216e5adSMichael Roth if (!has_mode || strcmp(mode, "powerdown") == 0) { 87c216e5adSMichael Roth shutdown_flag = "-P"; 88c216e5adSMichael Roth } else if (strcmp(mode, "halt") == 0) { 89c216e5adSMichael Roth shutdown_flag = "-H"; 90c216e5adSMichael Roth } else if (strcmp(mode, "reboot") == 0) { 91c216e5adSMichael Roth shutdown_flag = "-r"; 92c216e5adSMichael Roth } else { 9377dbc81bSMarkus Armbruster error_setg(errp, 94d220a6dfSLuiz Capitulino "mode is invalid (valid values are: halt|powerdown|reboot"); 95c216e5adSMichael Roth return; 96c216e5adSMichael Roth } 97c216e5adSMichael Roth 98d5dd3498SLuiz Capitulino pid = fork(); 99d5dd3498SLuiz Capitulino if (pid == 0) { 100c216e5adSMichael Roth /* child, start the shutdown */ 101c216e5adSMichael Roth setsid(); 1023674838cSLuiz Capitulino reopen_fd_to_null(0); 1033674838cSLuiz Capitulino reopen_fd_to_null(1); 1043674838cSLuiz Capitulino reopen_fd_to_null(2); 105c216e5adSMichael Roth 106485e741cSwhitearchey execle("/sbin/shutdown", "shutdown", "-h", shutdown_flag, "+0", 1073674838cSLuiz Capitulino "hypervisor initiated shutdown", (char*)NULL, environ); 1083674838cSLuiz Capitulino _exit(EXIT_FAILURE); 109d5dd3498SLuiz Capitulino } else if (pid < 0) { 11077dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to create child process"); 111d5dd3498SLuiz Capitulino return; 112d5dd3498SLuiz Capitulino } 113d5dd3498SLuiz Capitulino 114d220a6dfSLuiz Capitulino ga_wait_child(pid, &status, &local_err); 11584d18f06SMarkus Armbruster if (local_err) { 11677dbc81bSMarkus Armbruster error_propagate(errp, local_err); 117d220a6dfSLuiz Capitulino return; 118d220a6dfSLuiz Capitulino } 119d220a6dfSLuiz Capitulino 120d220a6dfSLuiz Capitulino if (!WIFEXITED(status)) { 12177dbc81bSMarkus Armbruster error_setg(errp, "child process has terminated abnormally"); 122d220a6dfSLuiz Capitulino return; 123d220a6dfSLuiz Capitulino } 124d220a6dfSLuiz Capitulino 125d220a6dfSLuiz Capitulino if (WEXITSTATUS(status)) { 12677dbc81bSMarkus Armbruster error_setg(errp, "child process has failed to shutdown"); 127d220a6dfSLuiz Capitulino return; 128d220a6dfSLuiz Capitulino } 129d220a6dfSLuiz Capitulino 130085d8134SPeter Maydell /* succeeded */ 131c216e5adSMichael Roth } 132c216e5adSMichael Roth 1336912e6a9SLei Li int64_t qmp_guest_get_time(Error **errp) 1346912e6a9SLei Li { 1356912e6a9SLei Li int ret; 1366912e6a9SLei Li qemu_timeval tq; 1376912e6a9SLei Li 1386912e6a9SLei Li ret = qemu_gettimeofday(&tq); 1396912e6a9SLei Li if (ret < 0) { 1406912e6a9SLei Li error_setg_errno(errp, errno, "Failed to get time"); 1416912e6a9SLei Li return -1; 1426912e6a9SLei Li } 1436912e6a9SLei Li 1449be38598SEduardo Habkost return tq.tv_sec * 1000000000LL + tq.tv_usec * 1000; 1456912e6a9SLei Li } 1466912e6a9SLei Li 1472c958923SMichal Privoznik void qmp_guest_set_time(bool has_time, int64_t time_ns, Error **errp) 148a1bca57fSLei Li { 149a1bca57fSLei Li int ret; 150a1bca57fSLei Li int status; 151a1bca57fSLei Li pid_t pid; 152a1bca57fSLei Li Error *local_err = NULL; 153a1bca57fSLei Li struct timeval tv; 154a1bca57fSLei Li 1552c958923SMichal Privoznik /* If user has passed a time, validate and set it. */ 1562c958923SMichal Privoznik if (has_time) { 15700d2f370SMarc-André Lureau GDate date = { 0, }; 15800d2f370SMarc-André Lureau 159a1bca57fSLei Li /* year-2038 will overflow in case time_t is 32bit */ 160a1bca57fSLei Li if (time_ns / 1000000000 != (time_t)(time_ns / 1000000000)) { 161a1bca57fSLei Li error_setg(errp, "Time %" PRId64 " is too large", time_ns); 162a1bca57fSLei Li return; 163a1bca57fSLei Li } 164a1bca57fSLei Li 165a1bca57fSLei Li tv.tv_sec = time_ns / 1000000000; 166a1bca57fSLei Li tv.tv_usec = (time_ns % 1000000000) / 1000; 16700d2f370SMarc-André Lureau g_date_set_time_t(&date, tv.tv_sec); 16800d2f370SMarc-André Lureau if (date.year < 1970 || date.year >= 2070) { 16900d2f370SMarc-André Lureau error_setg_errno(errp, errno, "Invalid time"); 17000d2f370SMarc-André Lureau return; 17100d2f370SMarc-André Lureau } 172a1bca57fSLei Li 173a1bca57fSLei Li ret = settimeofday(&tv, NULL); 174a1bca57fSLei Li if (ret < 0) { 175a1bca57fSLei Li error_setg_errno(errp, errno, "Failed to set time to guest"); 176a1bca57fSLei Li return; 177a1bca57fSLei Li } 1782c958923SMichal Privoznik } 179a1bca57fSLei Li 1802c958923SMichal Privoznik /* Now, if user has passed a time to set and the system time is set, we 1812c958923SMichal Privoznik * just need to synchronize the hardware clock. However, if no time was 1822c958923SMichal Privoznik * passed, user is requesting the opposite: set the system time from the 1831634df56SAmos Kong * hardware clock (RTC). */ 184a1bca57fSLei Li pid = fork(); 185a1bca57fSLei Li if (pid == 0) { 186a1bca57fSLei Li setsid(); 187a1bca57fSLei Li reopen_fd_to_null(0); 188a1bca57fSLei Li reopen_fd_to_null(1); 189a1bca57fSLei Li reopen_fd_to_null(2); 190a1bca57fSLei Li 1912c958923SMichal Privoznik /* Use '/sbin/hwclock -w' to set RTC from the system time, 1922c958923SMichal Privoznik * or '/sbin/hwclock -s' to set the system time from RTC. */ 1932c958923SMichal Privoznik execle("/sbin/hwclock", "hwclock", has_time ? "-w" : "-s", 1942c958923SMichal Privoznik NULL, environ); 195a1bca57fSLei Li _exit(EXIT_FAILURE); 196a1bca57fSLei Li } else if (pid < 0) { 197a1bca57fSLei Li error_setg_errno(errp, errno, "failed to create child process"); 198a1bca57fSLei Li return; 199a1bca57fSLei Li } 200a1bca57fSLei Li 201a1bca57fSLei Li ga_wait_child(pid, &status, &local_err); 20284d18f06SMarkus Armbruster if (local_err) { 203a1bca57fSLei Li error_propagate(errp, local_err); 204a1bca57fSLei Li return; 205a1bca57fSLei Li } 206a1bca57fSLei Li 207a1bca57fSLei Li if (!WIFEXITED(status)) { 208a1bca57fSLei Li error_setg(errp, "child process has terminated abnormally"); 209a1bca57fSLei Li return; 210a1bca57fSLei Li } 211a1bca57fSLei Li 212a1bca57fSLei Li if (WEXITSTATUS(status)) { 213a1bca57fSLei Li error_setg(errp, "hwclock failed to set hardware clock to system time"); 214a1bca57fSLei Li return; 215a1bca57fSLei Li } 216a1bca57fSLei Li } 217a1bca57fSLei Li 218895b00f6SMarc-André Lureau typedef enum { 219895b00f6SMarc-André Lureau RW_STATE_NEW, 220895b00f6SMarc-André Lureau RW_STATE_READING, 221895b00f6SMarc-André Lureau RW_STATE_WRITING, 222895b00f6SMarc-André Lureau } RwState; 223895b00f6SMarc-André Lureau 224c216e5adSMichael Roth typedef struct GuestFileHandle { 225c216e5adSMichael Roth uint64_t id; 226c216e5adSMichael Roth FILE *fh; 227895b00f6SMarc-André Lureau RwState state; 228c216e5adSMichael Roth QTAILQ_ENTRY(GuestFileHandle) next; 229c216e5adSMichael Roth } GuestFileHandle; 230c216e5adSMichael Roth 231c216e5adSMichael Roth static struct { 232c216e5adSMichael Roth QTAILQ_HEAD(, GuestFileHandle) filehandles; 233b4fe97c8SDenis V. Lunev } guest_file_state = { 234b4fe97c8SDenis V. Lunev .filehandles = QTAILQ_HEAD_INITIALIZER(guest_file_state.filehandles), 235b4fe97c8SDenis V. Lunev }; 236c216e5adSMichael Roth 23739097dafSMichael Roth static int64_t guest_file_handle_add(FILE *fh, Error **errp) 238c216e5adSMichael Roth { 239c216e5adSMichael Roth GuestFileHandle *gfh; 24039097dafSMichael Roth int64_t handle; 24139097dafSMichael Roth 24239097dafSMichael Roth handle = ga_get_fd_handle(ga_state, errp); 243a903f40cSMarkus Armbruster if (handle < 0) { 244a903f40cSMarkus Armbruster return -1; 24539097dafSMichael Roth } 246c216e5adSMichael Roth 247f3a06403SMarkus Armbruster gfh = g_new0(GuestFileHandle, 1); 24839097dafSMichael Roth gfh->id = handle; 249c216e5adSMichael Roth gfh->fh = fh; 250c216e5adSMichael Roth QTAILQ_INSERT_TAIL(&guest_file_state.filehandles, gfh, next); 25139097dafSMichael Roth 25239097dafSMichael Roth return handle; 253c216e5adSMichael Roth } 254c216e5adSMichael Roth 25577dbc81bSMarkus Armbruster static GuestFileHandle *guest_file_handle_find(int64_t id, Error **errp) 256c216e5adSMichael Roth { 257c216e5adSMichael Roth GuestFileHandle *gfh; 258c216e5adSMichael Roth 259c216e5adSMichael Roth QTAILQ_FOREACH(gfh, &guest_file_state.filehandles, next) 260c216e5adSMichael Roth { 261c216e5adSMichael Roth if (gfh->id == id) { 262c216e5adSMichael Roth return gfh; 263c216e5adSMichael Roth } 264c216e5adSMichael Roth } 265c216e5adSMichael Roth 26677dbc81bSMarkus Armbruster error_setg(errp, "handle '%" PRId64 "' has not been found", id); 267c216e5adSMichael Roth return NULL; 268c216e5adSMichael Roth } 269c216e5adSMichael Roth 270c689b4f1SLaszlo Ersek typedef const char * const ccpc; 271c689b4f1SLaszlo Ersek 2728fe6bbcaSLaszlo Ersek #ifndef O_BINARY 2738fe6bbcaSLaszlo Ersek #define O_BINARY 0 2748fe6bbcaSLaszlo Ersek #endif 2758fe6bbcaSLaszlo Ersek 276c689b4f1SLaszlo Ersek /* http://pubs.opengroup.org/onlinepubs/9699919799/functions/fopen.html */ 277c689b4f1SLaszlo Ersek static const struct { 278c689b4f1SLaszlo Ersek ccpc *forms; 279c689b4f1SLaszlo Ersek int oflag_base; 280c689b4f1SLaszlo Ersek } guest_file_open_modes[] = { 2818fe6bbcaSLaszlo Ersek { (ccpc[]){ "r", NULL }, O_RDONLY }, 2828fe6bbcaSLaszlo Ersek { (ccpc[]){ "rb", NULL }, O_RDONLY | O_BINARY }, 2838fe6bbcaSLaszlo Ersek { (ccpc[]){ "w", NULL }, O_WRONLY | O_CREAT | O_TRUNC }, 2848fe6bbcaSLaszlo Ersek { (ccpc[]){ "wb", NULL }, O_WRONLY | O_CREAT | O_TRUNC | O_BINARY }, 2858fe6bbcaSLaszlo Ersek { (ccpc[]){ "a", NULL }, O_WRONLY | O_CREAT | O_APPEND }, 2868fe6bbcaSLaszlo Ersek { (ccpc[]){ "ab", NULL }, O_WRONLY | O_CREAT | O_APPEND | O_BINARY }, 2878fe6bbcaSLaszlo Ersek { (ccpc[]){ "r+", NULL }, O_RDWR }, 2888fe6bbcaSLaszlo Ersek { (ccpc[]){ "rb+", "r+b", NULL }, O_RDWR | O_BINARY }, 2898fe6bbcaSLaszlo Ersek { (ccpc[]){ "w+", NULL }, O_RDWR | O_CREAT | O_TRUNC }, 2908fe6bbcaSLaszlo Ersek { (ccpc[]){ "wb+", "w+b", NULL }, O_RDWR | O_CREAT | O_TRUNC | O_BINARY }, 2918fe6bbcaSLaszlo Ersek { (ccpc[]){ "a+", NULL }, O_RDWR | O_CREAT | O_APPEND }, 2928fe6bbcaSLaszlo Ersek { (ccpc[]){ "ab+", "a+b", NULL }, O_RDWR | O_CREAT | O_APPEND | O_BINARY } 293c689b4f1SLaszlo Ersek }; 294c689b4f1SLaszlo Ersek 295c689b4f1SLaszlo Ersek static int 29677dbc81bSMarkus Armbruster find_open_flag(const char *mode_str, Error **errp) 297c689b4f1SLaszlo Ersek { 298c689b4f1SLaszlo Ersek unsigned mode; 299c689b4f1SLaszlo Ersek 300c689b4f1SLaszlo Ersek for (mode = 0; mode < ARRAY_SIZE(guest_file_open_modes); ++mode) { 301c689b4f1SLaszlo Ersek ccpc *form; 302c689b4f1SLaszlo Ersek 303c689b4f1SLaszlo Ersek form = guest_file_open_modes[mode].forms; 304c689b4f1SLaszlo Ersek while (*form != NULL && strcmp(*form, mode_str) != 0) { 305c689b4f1SLaszlo Ersek ++form; 306c689b4f1SLaszlo Ersek } 307c689b4f1SLaszlo Ersek if (*form != NULL) { 308c689b4f1SLaszlo Ersek break; 309c689b4f1SLaszlo Ersek } 310c689b4f1SLaszlo Ersek } 311c689b4f1SLaszlo Ersek 312c689b4f1SLaszlo Ersek if (mode == ARRAY_SIZE(guest_file_open_modes)) { 31377dbc81bSMarkus Armbruster error_setg(errp, "invalid file open mode '%s'", mode_str); 314c689b4f1SLaszlo Ersek return -1; 315c689b4f1SLaszlo Ersek } 316c689b4f1SLaszlo Ersek return guest_file_open_modes[mode].oflag_base | O_NOCTTY | O_NONBLOCK; 317c689b4f1SLaszlo Ersek } 318c689b4f1SLaszlo Ersek 319c689b4f1SLaszlo Ersek #define DEFAULT_NEW_FILE_MODE (S_IRUSR | S_IWUSR | \ 320c689b4f1SLaszlo Ersek S_IRGRP | S_IWGRP | \ 321c689b4f1SLaszlo Ersek S_IROTH | S_IWOTH) 322c689b4f1SLaszlo Ersek 323c689b4f1SLaszlo Ersek static FILE * 32477dbc81bSMarkus Armbruster safe_open_or_create(const char *path, const char *mode, Error **errp) 325c689b4f1SLaszlo Ersek { 326c689b4f1SLaszlo Ersek Error *local_err = NULL; 327c689b4f1SLaszlo Ersek int oflag; 328c689b4f1SLaszlo Ersek 329c689b4f1SLaszlo Ersek oflag = find_open_flag(mode, &local_err); 330c689b4f1SLaszlo Ersek if (local_err == NULL) { 331c689b4f1SLaszlo Ersek int fd; 332c689b4f1SLaszlo Ersek 333c689b4f1SLaszlo Ersek /* If the caller wants / allows creation of a new file, we implement it 334c689b4f1SLaszlo Ersek * with a two step process: open() + (open() / fchmod()). 335c689b4f1SLaszlo Ersek * 336c689b4f1SLaszlo Ersek * First we insist on creating the file exclusively as a new file. If 337c689b4f1SLaszlo Ersek * that succeeds, we're free to set any file-mode bits on it. (The 338c689b4f1SLaszlo Ersek * motivation is that we want to set those file-mode bits independently 339c689b4f1SLaszlo Ersek * of the current umask.) 340c689b4f1SLaszlo Ersek * 341c689b4f1SLaszlo Ersek * If the exclusive creation fails because the file already exists 342c689b4f1SLaszlo Ersek * (EEXIST is not possible for any other reason), we just attempt to 343c689b4f1SLaszlo Ersek * open the file, but in this case we won't be allowed to change the 344c689b4f1SLaszlo Ersek * file-mode bits on the preexistent file. 345c689b4f1SLaszlo Ersek * 346c689b4f1SLaszlo Ersek * The pathname should never disappear between the two open()s in 347c689b4f1SLaszlo Ersek * practice. If it happens, then someone very likely tried to race us. 348c689b4f1SLaszlo Ersek * In this case just go ahead and report the ENOENT from the second 349c689b4f1SLaszlo Ersek * open() to the caller. 350c689b4f1SLaszlo Ersek * 351c689b4f1SLaszlo Ersek * If the caller wants to open a preexistent file, then the first 352c689b4f1SLaszlo Ersek * open() is decisive and its third argument is ignored, and the second 353c689b4f1SLaszlo Ersek * open() and the fchmod() are never called. 354c689b4f1SLaszlo Ersek */ 355c689b4f1SLaszlo Ersek fd = open(path, oflag | ((oflag & O_CREAT) ? O_EXCL : 0), 0); 356c689b4f1SLaszlo Ersek if (fd == -1 && errno == EEXIST) { 357c689b4f1SLaszlo Ersek oflag &= ~(unsigned)O_CREAT; 358c689b4f1SLaszlo Ersek fd = open(path, oflag); 359c689b4f1SLaszlo Ersek } 360c689b4f1SLaszlo Ersek 361c689b4f1SLaszlo Ersek if (fd == -1) { 362c689b4f1SLaszlo Ersek error_setg_errno(&local_err, errno, "failed to open file '%s' " 363c689b4f1SLaszlo Ersek "(mode: '%s')", path, mode); 364c689b4f1SLaszlo Ersek } else { 365c689b4f1SLaszlo Ersek qemu_set_cloexec(fd); 366c689b4f1SLaszlo Ersek 367c689b4f1SLaszlo Ersek if ((oflag & O_CREAT) && fchmod(fd, DEFAULT_NEW_FILE_MODE) == -1) { 368c689b4f1SLaszlo Ersek error_setg_errno(&local_err, errno, "failed to set permission " 369c689b4f1SLaszlo Ersek "0%03o on new file '%s' (mode: '%s')", 370c689b4f1SLaszlo Ersek (unsigned)DEFAULT_NEW_FILE_MODE, path, mode); 371c689b4f1SLaszlo Ersek } else { 372c689b4f1SLaszlo Ersek FILE *f; 373c689b4f1SLaszlo Ersek 374c689b4f1SLaszlo Ersek f = fdopen(fd, mode); 375c689b4f1SLaszlo Ersek if (f == NULL) { 376c689b4f1SLaszlo Ersek error_setg_errno(&local_err, errno, "failed to associate " 377c689b4f1SLaszlo Ersek "stdio stream with file descriptor %d, " 378c689b4f1SLaszlo Ersek "file '%s' (mode: '%s')", fd, path, mode); 379c689b4f1SLaszlo Ersek } else { 380c689b4f1SLaszlo Ersek return f; 381c689b4f1SLaszlo Ersek } 382c689b4f1SLaszlo Ersek } 383c689b4f1SLaszlo Ersek 384c689b4f1SLaszlo Ersek close(fd); 3852b720018SLaszlo Ersek if (oflag & O_CREAT) { 3862b720018SLaszlo Ersek unlink(path); 3872b720018SLaszlo Ersek } 388c689b4f1SLaszlo Ersek } 389c689b4f1SLaszlo Ersek } 390c689b4f1SLaszlo Ersek 39177dbc81bSMarkus Armbruster error_propagate(errp, local_err); 392c689b4f1SLaszlo Ersek return NULL; 393c689b4f1SLaszlo Ersek } 394c689b4f1SLaszlo Ersek 39577dbc81bSMarkus Armbruster int64_t qmp_guest_file_open(const char *path, bool has_mode, const char *mode, 39677dbc81bSMarkus Armbruster Error **errp) 397c216e5adSMichael Roth { 398c216e5adSMichael Roth FILE *fh; 399c689b4f1SLaszlo Ersek Error *local_err = NULL; 40085b6f6f5SSimon Zolin int64_t handle; 401c216e5adSMichael Roth 402c216e5adSMichael Roth if (!has_mode) { 403c216e5adSMichael Roth mode = "r"; 404c216e5adSMichael Roth } 405c216e5adSMichael Roth slog("guest-file-open called, filepath: %s, mode: %s", path, mode); 406c689b4f1SLaszlo Ersek fh = safe_open_or_create(path, mode, &local_err); 407c689b4f1SLaszlo Ersek if (local_err != NULL) { 40877dbc81bSMarkus Armbruster error_propagate(errp, local_err); 409c216e5adSMichael Roth return -1; 410c216e5adSMichael Roth } 411c216e5adSMichael Roth 412c216e5adSMichael Roth /* set fd non-blocking to avoid common use cases (like reading from a 413c216e5adSMichael Roth * named pipe) from hanging the agent 414c216e5adSMichael Roth */ 41512505396SDenis V. Lunev qemu_set_nonblock(fileno(fh)); 416c216e5adSMichael Roth 41777dbc81bSMarkus Armbruster handle = guest_file_handle_add(fh, errp); 418a903f40cSMarkus Armbruster if (handle < 0) { 41939097dafSMichael Roth fclose(fh); 42039097dafSMichael Roth return -1; 42139097dafSMichael Roth } 42239097dafSMichael Roth 423d607a523SStefan Weil slog("guest-file-open, handle: %" PRId64, handle); 42439097dafSMichael Roth return handle; 425c216e5adSMichael Roth } 426c216e5adSMichael Roth 42777dbc81bSMarkus Armbruster void qmp_guest_file_close(int64_t handle, Error **errp) 428c216e5adSMichael Roth { 42977dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 430c216e5adSMichael Roth int ret; 431c216e5adSMichael Roth 432d607a523SStefan Weil slog("guest-file-close called, handle: %" PRId64, handle); 433c216e5adSMichael Roth if (!gfh) { 434c216e5adSMichael Roth return; 435c216e5adSMichael Roth } 436c216e5adSMichael Roth 437c216e5adSMichael Roth ret = fclose(gfh->fh); 4383ac4b7c5SLuiz Capitulino if (ret == EOF) { 43977dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to close handle"); 440c216e5adSMichael Roth return; 441c216e5adSMichael Roth } 442c216e5adSMichael Roth 443c216e5adSMichael Roth QTAILQ_REMOVE(&guest_file_state.filehandles, gfh, next); 444c216e5adSMichael Roth g_free(gfh); 445c216e5adSMichael Roth } 446c216e5adSMichael Roth 447c216e5adSMichael Roth struct GuestFileRead *qmp_guest_file_read(int64_t handle, bool has_count, 44877dbc81bSMarkus Armbruster int64_t count, Error **errp) 449c216e5adSMichael Roth { 45077dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 451c216e5adSMichael Roth GuestFileRead *read_data = NULL; 452c216e5adSMichael Roth guchar *buf; 453c216e5adSMichael Roth FILE *fh; 454c216e5adSMichael Roth size_t read_count; 455c216e5adSMichael Roth 456c216e5adSMichael Roth if (!gfh) { 457c216e5adSMichael Roth return NULL; 458c216e5adSMichael Roth } 459c216e5adSMichael Roth 460c216e5adSMichael Roth if (!has_count) { 461c216e5adSMichael Roth count = QGA_READ_COUNT_DEFAULT; 462141b1974SPrasad J Pandit } else if (count < 0 || count >= UINT32_MAX) { 46377dbc81bSMarkus Armbruster error_setg(errp, "value '%" PRId64 "' is invalid for argument count", 464db3edb66SLuiz Capitulino count); 465c216e5adSMichael Roth return NULL; 466c216e5adSMichael Roth } 467c216e5adSMichael Roth 468c216e5adSMichael Roth fh = gfh->fh; 469895b00f6SMarc-André Lureau 470895b00f6SMarc-André Lureau /* explicitly flush when switching from writing to reading */ 471895b00f6SMarc-André Lureau if (gfh->state == RW_STATE_WRITING) { 472895b00f6SMarc-André Lureau int ret = fflush(fh); 473895b00f6SMarc-André Lureau if (ret == EOF) { 474895b00f6SMarc-André Lureau error_setg_errno(errp, errno, "failed to flush file"); 475895b00f6SMarc-André Lureau return NULL; 476895b00f6SMarc-André Lureau } 477895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 478895b00f6SMarc-André Lureau } 479895b00f6SMarc-André Lureau 480c216e5adSMichael Roth buf = g_malloc0(count+1); 481c216e5adSMichael Roth read_count = fread(buf, 1, count, fh); 482c216e5adSMichael Roth if (ferror(fh)) { 48377dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to read file"); 484d607a523SStefan Weil slog("guest-file-read failed, handle: %" PRId64, handle); 485c216e5adSMichael Roth } else { 486c216e5adSMichael Roth buf[read_count] = 0; 487f3a06403SMarkus Armbruster read_data = g_new0(GuestFileRead, 1); 488c216e5adSMichael Roth read_data->count = read_count; 489c216e5adSMichael Roth read_data->eof = feof(fh); 490c216e5adSMichael Roth if (read_count) { 491c216e5adSMichael Roth read_data->buf_b64 = g_base64_encode(buf, read_count); 492c216e5adSMichael Roth } 493895b00f6SMarc-André Lureau gfh->state = RW_STATE_READING; 494c216e5adSMichael Roth } 495c216e5adSMichael Roth g_free(buf); 496c216e5adSMichael Roth clearerr(fh); 497c216e5adSMichael Roth 498c216e5adSMichael Roth return read_data; 499c216e5adSMichael Roth } 500c216e5adSMichael Roth 501c216e5adSMichael Roth GuestFileWrite *qmp_guest_file_write(int64_t handle, const char *buf_b64, 50277dbc81bSMarkus Armbruster bool has_count, int64_t count, 50377dbc81bSMarkus Armbruster Error **errp) 504c216e5adSMichael Roth { 505c216e5adSMichael Roth GuestFileWrite *write_data = NULL; 506c216e5adSMichael Roth guchar *buf; 507c216e5adSMichael Roth gsize buf_len; 508c216e5adSMichael Roth int write_count; 50977dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 510c216e5adSMichael Roth FILE *fh; 511c216e5adSMichael Roth 512c216e5adSMichael Roth if (!gfh) { 513c216e5adSMichael Roth return NULL; 514c216e5adSMichael Roth } 515c216e5adSMichael Roth 516c216e5adSMichael Roth fh = gfh->fh; 517895b00f6SMarc-André Lureau 518895b00f6SMarc-André Lureau if (gfh->state == RW_STATE_READING) { 519895b00f6SMarc-André Lureau int ret = fseek(fh, 0, SEEK_CUR); 520895b00f6SMarc-André Lureau if (ret == -1) { 521895b00f6SMarc-André Lureau error_setg_errno(errp, errno, "failed to seek file"); 522895b00f6SMarc-André Lureau return NULL; 523895b00f6SMarc-André Lureau } 524895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 525895b00f6SMarc-André Lureau } 526895b00f6SMarc-André Lureau 527920639caSDaniel P. Berrange buf = qbase64_decode(buf_b64, -1, &buf_len, errp); 528920639caSDaniel P. Berrange if (!buf) { 529920639caSDaniel P. Berrange return NULL; 530920639caSDaniel P. Berrange } 531c216e5adSMichael Roth 532c216e5adSMichael Roth if (!has_count) { 533c216e5adSMichael Roth count = buf_len; 534c216e5adSMichael Roth } else if (count < 0 || count > buf_len) { 53577dbc81bSMarkus Armbruster error_setg(errp, "value '%" PRId64 "' is invalid for argument count", 536db3edb66SLuiz Capitulino count); 537c216e5adSMichael Roth g_free(buf); 538c216e5adSMichael Roth return NULL; 539c216e5adSMichael Roth } 540c216e5adSMichael Roth 541c216e5adSMichael Roth write_count = fwrite(buf, 1, count, fh); 542c216e5adSMichael Roth if (ferror(fh)) { 54377dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to write to file"); 544d607a523SStefan Weil slog("guest-file-write failed, handle: %" PRId64, handle); 545c216e5adSMichael Roth } else { 546f3a06403SMarkus Armbruster write_data = g_new0(GuestFileWrite, 1); 547c216e5adSMichael Roth write_data->count = write_count; 548c216e5adSMichael Roth write_data->eof = feof(fh); 549895b00f6SMarc-André Lureau gfh->state = RW_STATE_WRITING; 550c216e5adSMichael Roth } 551c216e5adSMichael Roth g_free(buf); 552c216e5adSMichael Roth clearerr(fh); 553c216e5adSMichael Roth 554c216e5adSMichael Roth return write_data; 555c216e5adSMichael Roth } 556c216e5adSMichael Roth 557c216e5adSMichael Roth struct GuestFileSeek *qmp_guest_file_seek(int64_t handle, int64_t offset, 5580b4b4938SEric Blake GuestFileWhence *whence_code, 5590b4b4938SEric Blake Error **errp) 560c216e5adSMichael Roth { 56177dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 562c216e5adSMichael Roth GuestFileSeek *seek_data = NULL; 563c216e5adSMichael Roth FILE *fh; 564c216e5adSMichael Roth int ret; 5650a982b1bSEric Blake int whence; 5660b4b4938SEric Blake Error *err = NULL; 567c216e5adSMichael Roth 568c216e5adSMichael Roth if (!gfh) { 569c216e5adSMichael Roth return NULL; 570c216e5adSMichael Roth } 571c216e5adSMichael Roth 5720a982b1bSEric Blake /* We stupidly exposed 'whence':'int' in our qapi */ 5730b4b4938SEric Blake whence = ga_parse_whence(whence_code, &err); 5740b4b4938SEric Blake if (err) { 5750b4b4938SEric Blake error_propagate(errp, err); 5760a982b1bSEric Blake return NULL; 5770a982b1bSEric Blake } 5780a982b1bSEric Blake 579c216e5adSMichael Roth fh = gfh->fh; 580c216e5adSMichael Roth ret = fseek(fh, offset, whence); 581c216e5adSMichael Roth if (ret == -1) { 58277dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to seek file"); 583895b00f6SMarc-André Lureau if (errno == ESPIPE) { 584895b00f6SMarc-André Lureau /* file is non-seekable, stdio shouldn't be buffering anyways */ 585895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 586895b00f6SMarc-André Lureau } 587c216e5adSMichael Roth } else { 58810b7c5ddSMarkus Armbruster seek_data = g_new0(GuestFileSeek, 1); 589c216e5adSMichael Roth seek_data->position = ftell(fh); 590c216e5adSMichael Roth seek_data->eof = feof(fh); 591895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 592c216e5adSMichael Roth } 593c216e5adSMichael Roth clearerr(fh); 594c216e5adSMichael Roth 595c216e5adSMichael Roth return seek_data; 596c216e5adSMichael Roth } 597c216e5adSMichael Roth 59877dbc81bSMarkus Armbruster void qmp_guest_file_flush(int64_t handle, Error **errp) 599c216e5adSMichael Roth { 60077dbc81bSMarkus Armbruster GuestFileHandle *gfh = guest_file_handle_find(handle, errp); 601c216e5adSMichael Roth FILE *fh; 602c216e5adSMichael Roth int ret; 603c216e5adSMichael Roth 604c216e5adSMichael Roth if (!gfh) { 605c216e5adSMichael Roth return; 606c216e5adSMichael Roth } 607c216e5adSMichael Roth 608c216e5adSMichael Roth fh = gfh->fh; 609c216e5adSMichael Roth ret = fflush(fh); 610c216e5adSMichael Roth if (ret == EOF) { 61177dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to flush file"); 612895b00f6SMarc-André Lureau } else { 613895b00f6SMarc-André Lureau gfh->state = RW_STATE_NEW; 614c216e5adSMichael Roth } 615c216e5adSMichael Roth } 616c216e5adSMichael Roth 617e72c3f2eSMichael Roth /* linux-specific implementations. avoid this if at all possible. */ 618e72c3f2eSMichael Roth #if defined(__linux__) 619e72c3f2eSMichael Roth 620eab5fd59SPaolo Bonzini #if defined(CONFIG_FSFREEZE) || defined(CONFIG_FSTRIM) 621af02203fSPaolo Bonzini typedef struct FsMount { 622c216e5adSMichael Roth char *dirname; 623c216e5adSMichael Roth char *devtype; 62446d4c572STomoki Sekiyama unsigned int devmajor, devminor; 625af02203fSPaolo Bonzini QTAILQ_ENTRY(FsMount) next; 626af02203fSPaolo Bonzini } FsMount; 627c216e5adSMichael Roth 628e5d9adbdSTomoki Sekiyama typedef QTAILQ_HEAD(FsMountList, FsMount) FsMountList; 6299e8aded4SMichael Roth 630af02203fSPaolo Bonzini static void free_fs_mount_list(FsMountList *mounts) 631c216e5adSMichael Roth { 632af02203fSPaolo Bonzini FsMount *mount, *temp; 633c216e5adSMichael Roth 6349e8aded4SMichael Roth if (!mounts) { 6359e8aded4SMichael Roth return; 6369e8aded4SMichael Roth } 6379e8aded4SMichael Roth 6389e8aded4SMichael Roth QTAILQ_FOREACH_SAFE(mount, mounts, next, temp) { 6399e8aded4SMichael Roth QTAILQ_REMOVE(mounts, mount, next); 640c216e5adSMichael Roth g_free(mount->dirname); 641c216e5adSMichael Roth g_free(mount->devtype); 642c216e5adSMichael Roth g_free(mount); 643c216e5adSMichael Roth } 6449e8aded4SMichael Roth } 6459e8aded4SMichael Roth 64646d4c572STomoki Sekiyama static int dev_major_minor(const char *devpath, 64746d4c572STomoki Sekiyama unsigned int *devmajor, unsigned int *devminor) 64846d4c572STomoki Sekiyama { 64946d4c572STomoki Sekiyama struct stat st; 65046d4c572STomoki Sekiyama 65146d4c572STomoki Sekiyama *devmajor = 0; 65246d4c572STomoki Sekiyama *devminor = 0; 65346d4c572STomoki Sekiyama 65446d4c572STomoki Sekiyama if (stat(devpath, &st) < 0) { 65546d4c572STomoki Sekiyama slog("failed to stat device file '%s': %s", devpath, strerror(errno)); 65646d4c572STomoki Sekiyama return -1; 65746d4c572STomoki Sekiyama } 65846d4c572STomoki Sekiyama if (S_ISDIR(st.st_mode)) { 65946d4c572STomoki Sekiyama /* It is bind mount */ 66046d4c572STomoki Sekiyama return -2; 66146d4c572STomoki Sekiyama } 66246d4c572STomoki Sekiyama if (S_ISBLK(st.st_mode)) { 66346d4c572STomoki Sekiyama *devmajor = major(st.st_rdev); 66446d4c572STomoki Sekiyama *devminor = minor(st.st_rdev); 66546d4c572STomoki Sekiyama return 0; 66646d4c572STomoki Sekiyama } 66746d4c572STomoki Sekiyama return -1; 66846d4c572STomoki Sekiyama } 66946d4c572STomoki Sekiyama 6709e8aded4SMichael Roth /* 6719e8aded4SMichael Roth * Walk the mount table and build a list of local file systems 6729e8aded4SMichael Roth */ 67346d4c572STomoki Sekiyama static void build_fs_mount_list_from_mtab(FsMountList *mounts, Error **errp) 6749e8aded4SMichael Roth { 6759e8aded4SMichael Roth struct mntent *ment; 676af02203fSPaolo Bonzini FsMount *mount; 6779e2fa418SMichael Roth char const *mtab = "/proc/self/mounts"; 6789e8aded4SMichael Roth FILE *fp; 67946d4c572STomoki Sekiyama unsigned int devmajor, devminor; 680c216e5adSMichael Roth 681c216e5adSMichael Roth fp = setmntent(mtab, "r"); 682c216e5adSMichael Roth if (!fp) { 68377dbc81bSMarkus Armbruster error_setg(errp, "failed to open mtab file: '%s'", mtab); 684261551d1SLuiz Capitulino return; 685c216e5adSMichael Roth } 686c216e5adSMichael Roth 687c216e5adSMichael Roth while ((ment = getmntent(fp))) { 688c216e5adSMichael Roth /* 689c216e5adSMichael Roth * An entry which device name doesn't start with a '/' is 690c216e5adSMichael Roth * either a dummy file system or a network file system. 691c216e5adSMichael Roth * Add special handling for smbfs and cifs as is done by 692c216e5adSMichael Roth * coreutils as well. 693c216e5adSMichael Roth */ 694c216e5adSMichael Roth if ((ment->mnt_fsname[0] != '/') || 695c216e5adSMichael Roth (strcmp(ment->mnt_type, "smbfs") == 0) || 696c216e5adSMichael Roth (strcmp(ment->mnt_type, "cifs") == 0)) { 697c216e5adSMichael Roth continue; 698c216e5adSMichael Roth } 69946d4c572STomoki Sekiyama if (dev_major_minor(ment->mnt_fsname, &devmajor, &devminor) == -2) { 70046d4c572STomoki Sekiyama /* Skip bind mounts */ 70146d4c572STomoki Sekiyama continue; 70246d4c572STomoki Sekiyama } 703c216e5adSMichael Roth 704f3a06403SMarkus Armbruster mount = g_new0(FsMount, 1); 705c216e5adSMichael Roth mount->dirname = g_strdup(ment->mnt_dir); 706c216e5adSMichael Roth mount->devtype = g_strdup(ment->mnt_type); 70746d4c572STomoki Sekiyama mount->devmajor = devmajor; 70846d4c572STomoki Sekiyama mount->devminor = devminor; 709c216e5adSMichael Roth 7109e8aded4SMichael Roth QTAILQ_INSERT_TAIL(mounts, mount, next); 711c216e5adSMichael Roth } 712c216e5adSMichael Roth 713c216e5adSMichael Roth endmntent(fp); 714c216e5adSMichael Roth } 71546d4c572STomoki Sekiyama 71646d4c572STomoki Sekiyama static void decode_mntname(char *name, int len) 71746d4c572STomoki Sekiyama { 71846d4c572STomoki Sekiyama int i, j = 0; 71946d4c572STomoki Sekiyama for (i = 0; i <= len; i++) { 72046d4c572STomoki Sekiyama if (name[i] != '\\') { 72146d4c572STomoki Sekiyama name[j++] = name[i]; 72246d4c572STomoki Sekiyama } else if (name[i + 1] == '\\') { 72346d4c572STomoki Sekiyama name[j++] = '\\'; 72446d4c572STomoki Sekiyama i++; 72546d4c572STomoki Sekiyama } else if (name[i + 1] >= '0' && name[i + 1] <= '3' && 72646d4c572STomoki Sekiyama name[i + 2] >= '0' && name[i + 2] <= '7' && 72746d4c572STomoki Sekiyama name[i + 3] >= '0' && name[i + 3] <= '7') { 72846d4c572STomoki Sekiyama name[j++] = (name[i + 1] - '0') * 64 + 72946d4c572STomoki Sekiyama (name[i + 2] - '0') * 8 + 73046d4c572STomoki Sekiyama (name[i + 3] - '0'); 73146d4c572STomoki Sekiyama i += 3; 73246d4c572STomoki Sekiyama } else { 73346d4c572STomoki Sekiyama name[j++] = name[i]; 73446d4c572STomoki Sekiyama } 73546d4c572STomoki Sekiyama } 73646d4c572STomoki Sekiyama } 73746d4c572STomoki Sekiyama 73846d4c572STomoki Sekiyama static void build_fs_mount_list(FsMountList *mounts, Error **errp) 73946d4c572STomoki Sekiyama { 74046d4c572STomoki Sekiyama FsMount *mount; 74146d4c572STomoki Sekiyama char const *mountinfo = "/proc/self/mountinfo"; 74246d4c572STomoki Sekiyama FILE *fp; 74346d4c572STomoki Sekiyama char *line = NULL, *dash; 74446d4c572STomoki Sekiyama size_t n; 74546d4c572STomoki Sekiyama char check; 74646d4c572STomoki Sekiyama unsigned int devmajor, devminor; 74746d4c572STomoki Sekiyama int ret, dir_s, dir_e, type_s, type_e, dev_s, dev_e; 74846d4c572STomoki Sekiyama 74946d4c572STomoki Sekiyama fp = fopen(mountinfo, "r"); 75046d4c572STomoki Sekiyama if (!fp) { 75146d4c572STomoki Sekiyama build_fs_mount_list_from_mtab(mounts, errp); 75246d4c572STomoki Sekiyama return; 75346d4c572STomoki Sekiyama } 75446d4c572STomoki Sekiyama 75546d4c572STomoki Sekiyama while (getline(&line, &n, fp) != -1) { 75646d4c572STomoki Sekiyama ret = sscanf(line, "%*u %*u %u:%u %*s %n%*s%n%c", 75746d4c572STomoki Sekiyama &devmajor, &devminor, &dir_s, &dir_e, &check); 75846d4c572STomoki Sekiyama if (ret < 3) { 75946d4c572STomoki Sekiyama continue; 76046d4c572STomoki Sekiyama } 76146d4c572STomoki Sekiyama dash = strstr(line + dir_e, " - "); 76246d4c572STomoki Sekiyama if (!dash) { 76346d4c572STomoki Sekiyama continue; 76446d4c572STomoki Sekiyama } 76546d4c572STomoki Sekiyama ret = sscanf(dash, " - %n%*s%n %n%*s%n%c", 76646d4c572STomoki Sekiyama &type_s, &type_e, &dev_s, &dev_e, &check); 76746d4c572STomoki Sekiyama if (ret < 1) { 76846d4c572STomoki Sekiyama continue; 76946d4c572STomoki Sekiyama } 77046d4c572STomoki Sekiyama line[dir_e] = 0; 77146d4c572STomoki Sekiyama dash[type_e] = 0; 77246d4c572STomoki Sekiyama dash[dev_e] = 0; 77346d4c572STomoki Sekiyama decode_mntname(line + dir_s, dir_e - dir_s); 77446d4c572STomoki Sekiyama decode_mntname(dash + dev_s, dev_e - dev_s); 77546d4c572STomoki Sekiyama if (devmajor == 0) { 77646d4c572STomoki Sekiyama /* btrfs reports major number = 0 */ 77746d4c572STomoki Sekiyama if (strcmp("btrfs", dash + type_s) != 0 || 77846d4c572STomoki Sekiyama dev_major_minor(dash + dev_s, &devmajor, &devminor) < 0) { 77946d4c572STomoki Sekiyama continue; 78046d4c572STomoki Sekiyama } 78146d4c572STomoki Sekiyama } 78246d4c572STomoki Sekiyama 783f3a06403SMarkus Armbruster mount = g_new0(FsMount, 1); 78446d4c572STomoki Sekiyama mount->dirname = g_strdup(line + dir_s); 78546d4c572STomoki Sekiyama mount->devtype = g_strdup(dash + type_s); 78646d4c572STomoki Sekiyama mount->devmajor = devmajor; 78746d4c572STomoki Sekiyama mount->devminor = devminor; 78846d4c572STomoki Sekiyama 78946d4c572STomoki Sekiyama QTAILQ_INSERT_TAIL(mounts, mount, next); 79046d4c572STomoki Sekiyama } 79146d4c572STomoki Sekiyama free(line); 79246d4c572STomoki Sekiyama 79346d4c572STomoki Sekiyama fclose(fp); 79446d4c572STomoki Sekiyama } 795eab5fd59SPaolo Bonzini #endif 796eab5fd59SPaolo Bonzini 797eab5fd59SPaolo Bonzini #if defined(CONFIG_FSFREEZE) 798c216e5adSMichael Roth 79946d4c572STomoki Sekiyama static char *get_pci_driver(char const *syspath, int pathlen, Error **errp) 80046d4c572STomoki Sekiyama { 80146d4c572STomoki Sekiyama char *path; 80246d4c572STomoki Sekiyama char *dpath; 80346d4c572STomoki Sekiyama char *driver = NULL; 80446d4c572STomoki Sekiyama char buf[PATH_MAX]; 80546d4c572STomoki Sekiyama ssize_t len; 80646d4c572STomoki Sekiyama 80746d4c572STomoki Sekiyama path = g_strndup(syspath, pathlen); 80846d4c572STomoki Sekiyama dpath = g_strdup_printf("%s/driver", path); 80946d4c572STomoki Sekiyama len = readlink(dpath, buf, sizeof(buf) - 1); 81046d4c572STomoki Sekiyama if (len != -1) { 81146d4c572STomoki Sekiyama buf[len] = 0; 8123e015d81SJulia Suvorova driver = g_path_get_basename(buf); 81346d4c572STomoki Sekiyama } 81446d4c572STomoki Sekiyama g_free(dpath); 81546d4c572STomoki Sekiyama g_free(path); 81646d4c572STomoki Sekiyama return driver; 81746d4c572STomoki Sekiyama } 81846d4c572STomoki Sekiyama 81946d4c572STomoki Sekiyama static int compare_uint(const void *_a, const void *_b) 82046d4c572STomoki Sekiyama { 82146d4c572STomoki Sekiyama unsigned int a = *(unsigned int *)_a; 82246d4c572STomoki Sekiyama unsigned int b = *(unsigned int *)_b; 82346d4c572STomoki Sekiyama 82446d4c572STomoki Sekiyama return a < b ? -1 : a > b ? 1 : 0; 82546d4c572STomoki Sekiyama } 82646d4c572STomoki Sekiyama 82746d4c572STomoki Sekiyama /* Walk the specified sysfs and build a sorted list of host or ata numbers */ 82846d4c572STomoki Sekiyama static int build_hosts(char const *syspath, char const *host, bool ata, 82946d4c572STomoki Sekiyama unsigned int *hosts, int hosts_max, Error **errp) 83046d4c572STomoki Sekiyama { 83146d4c572STomoki Sekiyama char *path; 83246d4c572STomoki Sekiyama DIR *dir; 83346d4c572STomoki Sekiyama struct dirent *entry; 83446d4c572STomoki Sekiyama int i = 0; 83546d4c572STomoki Sekiyama 83646d4c572STomoki Sekiyama path = g_strndup(syspath, host - syspath); 83746d4c572STomoki Sekiyama dir = opendir(path); 83846d4c572STomoki Sekiyama if (!dir) { 83946d4c572STomoki Sekiyama error_setg_errno(errp, errno, "opendir(\"%s\")", path); 84046d4c572STomoki Sekiyama g_free(path); 84146d4c572STomoki Sekiyama return -1; 84246d4c572STomoki Sekiyama } 84346d4c572STomoki Sekiyama 84446d4c572STomoki Sekiyama while (i < hosts_max) { 84546d4c572STomoki Sekiyama entry = readdir(dir); 84646d4c572STomoki Sekiyama if (!entry) { 84746d4c572STomoki Sekiyama break; 84846d4c572STomoki Sekiyama } 84946d4c572STomoki Sekiyama if (ata && sscanf(entry->d_name, "ata%d", hosts + i) == 1) { 85046d4c572STomoki Sekiyama ++i; 85146d4c572STomoki Sekiyama } else if (!ata && sscanf(entry->d_name, "host%d", hosts + i) == 1) { 85246d4c572STomoki Sekiyama ++i; 85346d4c572STomoki Sekiyama } 85446d4c572STomoki Sekiyama } 85546d4c572STomoki Sekiyama 85646d4c572STomoki Sekiyama qsort(hosts, i, sizeof(hosts[0]), compare_uint); 85746d4c572STomoki Sekiyama 85846d4c572STomoki Sekiyama g_free(path); 85946d4c572STomoki Sekiyama closedir(dir); 86046d4c572STomoki Sekiyama return i; 86146d4c572STomoki Sekiyama } 86246d4c572STomoki Sekiyama 86346d4c572STomoki Sekiyama /* Store disk device info specified by @sysfs into @fs */ 86446d4c572STomoki Sekiyama static void build_guest_fsinfo_for_real_device(char const *syspath, 86546d4c572STomoki Sekiyama GuestFilesystemInfo *fs, 86646d4c572STomoki Sekiyama Error **errp) 86746d4c572STomoki Sekiyama { 86846d4c572STomoki Sekiyama unsigned int pci[4], host, hosts[8], tgt[3]; 86946d4c572STomoki Sekiyama int i, nhosts = 0, pcilen; 87046d4c572STomoki Sekiyama GuestDiskAddress *disk; 87146d4c572STomoki Sekiyama GuestPCIAddress *pciaddr; 87246d4c572STomoki Sekiyama GuestDiskAddressList *list = NULL; 87346d4c572STomoki Sekiyama bool has_ata = false, has_host = false, has_tgt = false; 87446d4c572STomoki Sekiyama char *p, *q, *driver = NULL; 87546d4c572STomoki Sekiyama 87646d4c572STomoki Sekiyama p = strstr(syspath, "/devices/pci"); 87746d4c572STomoki Sekiyama if (!p || sscanf(p + 12, "%*x:%*x/%x:%x:%x.%x%n", 87846d4c572STomoki Sekiyama pci, pci + 1, pci + 2, pci + 3, &pcilen) < 4) { 87946d4c572STomoki Sekiyama g_debug("only pci device is supported: sysfs path \"%s\"", syspath); 88046d4c572STomoki Sekiyama return; 88146d4c572STomoki Sekiyama } 88246d4c572STomoki Sekiyama 88346d4c572STomoki Sekiyama driver = get_pci_driver(syspath, (p + 12 + pcilen) - syspath, errp); 88446d4c572STomoki Sekiyama if (!driver) { 88546d4c572STomoki Sekiyama goto cleanup; 88646d4c572STomoki Sekiyama } 88746d4c572STomoki Sekiyama 88846d4c572STomoki Sekiyama p = strstr(syspath, "/target"); 88946d4c572STomoki Sekiyama if (p && sscanf(p + 7, "%*u:%*u:%*u/%*u:%u:%u:%u", 89046d4c572STomoki Sekiyama tgt, tgt + 1, tgt + 2) == 3) { 89146d4c572STomoki Sekiyama has_tgt = true; 89246d4c572STomoki Sekiyama } 89346d4c572STomoki Sekiyama 89446d4c572STomoki Sekiyama p = strstr(syspath, "/ata"); 89546d4c572STomoki Sekiyama if (p) { 89646d4c572STomoki Sekiyama q = p + 4; 89746d4c572STomoki Sekiyama has_ata = true; 89846d4c572STomoki Sekiyama } else { 89946d4c572STomoki Sekiyama p = strstr(syspath, "/host"); 90046d4c572STomoki Sekiyama q = p + 5; 90146d4c572STomoki Sekiyama } 90246d4c572STomoki Sekiyama if (p && sscanf(q, "%u", &host) == 1) { 90346d4c572STomoki Sekiyama has_host = true; 90446d4c572STomoki Sekiyama nhosts = build_hosts(syspath, p, has_ata, hosts, 90501a6df1bSPhilippe Mathieu-Daudé ARRAY_SIZE(hosts), errp); 90646d4c572STomoki Sekiyama if (nhosts < 0) { 90746d4c572STomoki Sekiyama goto cleanup; 90846d4c572STomoki Sekiyama } 90946d4c572STomoki Sekiyama } 91046d4c572STomoki Sekiyama 91146d4c572STomoki Sekiyama pciaddr = g_malloc0(sizeof(*pciaddr)); 91246d4c572STomoki Sekiyama pciaddr->domain = pci[0]; 91346d4c572STomoki Sekiyama pciaddr->bus = pci[1]; 91446d4c572STomoki Sekiyama pciaddr->slot = pci[2]; 91546d4c572STomoki Sekiyama pciaddr->function = pci[3]; 91646d4c572STomoki Sekiyama 91746d4c572STomoki Sekiyama disk = g_malloc0(sizeof(*disk)); 91846d4c572STomoki Sekiyama disk->pci_controller = pciaddr; 91946d4c572STomoki Sekiyama 92046d4c572STomoki Sekiyama list = g_malloc0(sizeof(*list)); 92146d4c572STomoki Sekiyama list->value = disk; 92246d4c572STomoki Sekiyama 92346d4c572STomoki Sekiyama if (strcmp(driver, "ata_piix") == 0) { 92446d4c572STomoki Sekiyama /* a host per ide bus, target*:0:<unit>:0 */ 92546d4c572STomoki Sekiyama if (!has_host || !has_tgt) { 92646d4c572STomoki Sekiyama g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver); 92746d4c572STomoki Sekiyama goto cleanup; 92846d4c572STomoki Sekiyama } 92946d4c572STomoki Sekiyama for (i = 0; i < nhosts; i++) { 93046d4c572STomoki Sekiyama if (host == hosts[i]) { 93146d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_IDE; 93246d4c572STomoki Sekiyama disk->bus = i; 93346d4c572STomoki Sekiyama disk->unit = tgt[1]; 93446d4c572STomoki Sekiyama break; 93546d4c572STomoki Sekiyama } 93646d4c572STomoki Sekiyama } 93746d4c572STomoki Sekiyama if (i >= nhosts) { 93846d4c572STomoki Sekiyama g_debug("no host for '%s' (driver '%s')", syspath, driver); 93946d4c572STomoki Sekiyama goto cleanup; 94046d4c572STomoki Sekiyama } 94146d4c572STomoki Sekiyama } else if (strcmp(driver, "sym53c8xx") == 0) { 94246d4c572STomoki Sekiyama /* scsi(LSI Logic): target*:0:<unit>:0 */ 94346d4c572STomoki Sekiyama if (!has_tgt) { 94446d4c572STomoki Sekiyama g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver); 94546d4c572STomoki Sekiyama goto cleanup; 94646d4c572STomoki Sekiyama } 94746d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI; 94846d4c572STomoki Sekiyama disk->unit = tgt[1]; 94946d4c572STomoki Sekiyama } else if (strcmp(driver, "virtio-pci") == 0) { 95046d4c572STomoki Sekiyama if (has_tgt) { 95146d4c572STomoki Sekiyama /* virtio-scsi: target*:0:0:<unit> */ 95246d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_SCSI; 95346d4c572STomoki Sekiyama disk->unit = tgt[2]; 95446d4c572STomoki Sekiyama } else { 95546d4c572STomoki Sekiyama /* virtio-blk: 1 disk per 1 device */ 95646d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_VIRTIO; 95746d4c572STomoki Sekiyama } 95846d4c572STomoki Sekiyama } else if (strcmp(driver, "ahci") == 0) { 95946d4c572STomoki Sekiyama /* ahci: 1 host per 1 unit */ 96046d4c572STomoki Sekiyama if (!has_host || !has_tgt) { 96146d4c572STomoki Sekiyama g_debug("invalid sysfs path '%s' (driver '%s')", syspath, driver); 96246d4c572STomoki Sekiyama goto cleanup; 96346d4c572STomoki Sekiyama } 96446d4c572STomoki Sekiyama for (i = 0; i < nhosts; i++) { 96546d4c572STomoki Sekiyama if (host == hosts[i]) { 96646d4c572STomoki Sekiyama disk->unit = i; 96746d4c572STomoki Sekiyama disk->bus_type = GUEST_DISK_BUS_TYPE_SATA; 96846d4c572STomoki Sekiyama break; 96946d4c572STomoki Sekiyama } 97046d4c572STomoki Sekiyama } 97146d4c572STomoki Sekiyama if (i >= nhosts) { 97246d4c572STomoki Sekiyama g_debug("no host for '%s' (driver '%s')", syspath, driver); 97346d4c572STomoki Sekiyama goto cleanup; 97446d4c572STomoki Sekiyama } 97546d4c572STomoki Sekiyama } else { 97646d4c572STomoki Sekiyama g_debug("unknown driver '%s' (sysfs path '%s')", driver, syspath); 97746d4c572STomoki Sekiyama goto cleanup; 97846d4c572STomoki Sekiyama } 97946d4c572STomoki Sekiyama 98046d4c572STomoki Sekiyama list->next = fs->disk; 98146d4c572STomoki Sekiyama fs->disk = list; 98246d4c572STomoki Sekiyama g_free(driver); 98346d4c572STomoki Sekiyama return; 98446d4c572STomoki Sekiyama 98546d4c572STomoki Sekiyama cleanup: 98646d4c572STomoki Sekiyama if (list) { 98746d4c572STomoki Sekiyama qapi_free_GuestDiskAddressList(list); 98846d4c572STomoki Sekiyama } 98946d4c572STomoki Sekiyama g_free(driver); 99046d4c572STomoki Sekiyama } 99146d4c572STomoki Sekiyama 99246d4c572STomoki Sekiyama static void build_guest_fsinfo_for_device(char const *devpath, 99346d4c572STomoki Sekiyama GuestFilesystemInfo *fs, 99446d4c572STomoki Sekiyama Error **errp); 99546d4c572STomoki Sekiyama 99646d4c572STomoki Sekiyama /* Store a list of slave devices of virtual volume specified by @syspath into 99746d4c572STomoki Sekiyama * @fs */ 99846d4c572STomoki Sekiyama static void build_guest_fsinfo_for_virtual_device(char const *syspath, 99946d4c572STomoki Sekiyama GuestFilesystemInfo *fs, 100046d4c572STomoki Sekiyama Error **errp) 100146d4c572STomoki Sekiyama { 100246d4c572STomoki Sekiyama DIR *dir; 100346d4c572STomoki Sekiyama char *dirpath; 1004e668d1b8Szhanghailiang struct dirent *entry; 100546d4c572STomoki Sekiyama 100646d4c572STomoki Sekiyama dirpath = g_strdup_printf("%s/slaves", syspath); 100746d4c572STomoki Sekiyama dir = opendir(dirpath); 100846d4c572STomoki Sekiyama if (!dir) { 10098251a72fSMichael Roth if (errno != ENOENT) { 101046d4c572STomoki Sekiyama error_setg_errno(errp, errno, "opendir(\"%s\")", dirpath); 10118251a72fSMichael Roth } 101246d4c572STomoki Sekiyama g_free(dirpath); 101346d4c572STomoki Sekiyama return; 101446d4c572STomoki Sekiyama } 101546d4c572STomoki Sekiyama 101646d4c572STomoki Sekiyama for (;;) { 1017e668d1b8Szhanghailiang errno = 0; 1018e668d1b8Szhanghailiang entry = readdir(dir); 1019e668d1b8Szhanghailiang if (entry == NULL) { 1020e668d1b8Szhanghailiang if (errno) { 1021e668d1b8Szhanghailiang error_setg_errno(errp, errno, "readdir(\"%s\")", dirpath); 102246d4c572STomoki Sekiyama } 102346d4c572STomoki Sekiyama break; 102446d4c572STomoki Sekiyama } 102546d4c572STomoki Sekiyama 1026e668d1b8Szhanghailiang if (entry->d_type == DT_LNK) { 1027e668d1b8Szhanghailiang char *path; 1028e668d1b8Szhanghailiang 1029e668d1b8Szhanghailiang g_debug(" slave device '%s'", entry->d_name); 1030e668d1b8Szhanghailiang path = g_strdup_printf("%s/slaves/%s", syspath, entry->d_name); 1031e668d1b8Szhanghailiang build_guest_fsinfo_for_device(path, fs, errp); 1032e668d1b8Szhanghailiang g_free(path); 103346d4c572STomoki Sekiyama 103446d4c572STomoki Sekiyama if (*errp) { 103546d4c572STomoki Sekiyama break; 103646d4c572STomoki Sekiyama } 103746d4c572STomoki Sekiyama } 103846d4c572STomoki Sekiyama } 103946d4c572STomoki Sekiyama 1040e668d1b8Szhanghailiang g_free(dirpath); 104146d4c572STomoki Sekiyama closedir(dir); 104246d4c572STomoki Sekiyama } 104346d4c572STomoki Sekiyama 104446d4c572STomoki Sekiyama /* Dispatch to functions for virtual/real device */ 104546d4c572STomoki Sekiyama static void build_guest_fsinfo_for_device(char const *devpath, 104646d4c572STomoki Sekiyama GuestFilesystemInfo *fs, 104746d4c572STomoki Sekiyama Error **errp) 104846d4c572STomoki Sekiyama { 104946d4c572STomoki Sekiyama char *syspath = realpath(devpath, NULL); 105046d4c572STomoki Sekiyama 105146d4c572STomoki Sekiyama if (!syspath) { 105246d4c572STomoki Sekiyama error_setg_errno(errp, errno, "realpath(\"%s\")", devpath); 105346d4c572STomoki Sekiyama return; 105446d4c572STomoki Sekiyama } 105546d4c572STomoki Sekiyama 105646d4c572STomoki Sekiyama if (!fs->name) { 10573e015d81SJulia Suvorova fs->name = g_path_get_basename(syspath); 105846d4c572STomoki Sekiyama } 105946d4c572STomoki Sekiyama 106046d4c572STomoki Sekiyama g_debug(" parse sysfs path '%s'", syspath); 106146d4c572STomoki Sekiyama 106246d4c572STomoki Sekiyama if (strstr(syspath, "/devices/virtual/block/")) { 106346d4c572STomoki Sekiyama build_guest_fsinfo_for_virtual_device(syspath, fs, errp); 106446d4c572STomoki Sekiyama } else { 106546d4c572STomoki Sekiyama build_guest_fsinfo_for_real_device(syspath, fs, errp); 106646d4c572STomoki Sekiyama } 106746d4c572STomoki Sekiyama 106846d4c572STomoki Sekiyama free(syspath); 106946d4c572STomoki Sekiyama } 107046d4c572STomoki Sekiyama 107146d4c572STomoki Sekiyama /* Return a list of the disk device(s)' info which @mount lies on */ 107246d4c572STomoki Sekiyama static GuestFilesystemInfo *build_guest_fsinfo(struct FsMount *mount, 107346d4c572STomoki Sekiyama Error **errp) 107446d4c572STomoki Sekiyama { 107546d4c572STomoki Sekiyama GuestFilesystemInfo *fs = g_malloc0(sizeof(*fs)); 1076*25b5ff1aSChen Hanxiao struct statvfs buf; 1077*25b5ff1aSChen Hanxiao unsigned long used, nonroot_total, fr_size; 107846d4c572STomoki Sekiyama char *devpath = g_strdup_printf("/sys/dev/block/%u:%u", 107946d4c572STomoki Sekiyama mount->devmajor, mount->devminor); 108046d4c572STomoki Sekiyama 108146d4c572STomoki Sekiyama fs->mountpoint = g_strdup(mount->dirname); 108246d4c572STomoki Sekiyama fs->type = g_strdup(mount->devtype); 108346d4c572STomoki Sekiyama build_guest_fsinfo_for_device(devpath, fs, errp); 108446d4c572STomoki Sekiyama 1085*25b5ff1aSChen Hanxiao if (statvfs(fs->mountpoint, &buf) == 0) { 1086*25b5ff1aSChen Hanxiao fr_size = buf.f_frsize; 1087*25b5ff1aSChen Hanxiao used = buf.f_blocks - buf.f_bfree; 1088*25b5ff1aSChen Hanxiao nonroot_total = used + buf.f_bavail; 1089*25b5ff1aSChen Hanxiao fs->used_bytes = used * fr_size; 1090*25b5ff1aSChen Hanxiao fs->total_bytes = nonroot_total * fr_size; 1091*25b5ff1aSChen Hanxiao 1092*25b5ff1aSChen Hanxiao fs->has_total_bytes = true; 1093*25b5ff1aSChen Hanxiao fs->has_used_bytes = true; 1094*25b5ff1aSChen Hanxiao } 1095*25b5ff1aSChen Hanxiao 109646d4c572STomoki Sekiyama g_free(devpath); 1097*25b5ff1aSChen Hanxiao 109846d4c572STomoki Sekiyama return fs; 109946d4c572STomoki Sekiyama } 110046d4c572STomoki Sekiyama 110146d4c572STomoki Sekiyama GuestFilesystemInfoList *qmp_guest_get_fsinfo(Error **errp) 110246d4c572STomoki Sekiyama { 110346d4c572STomoki Sekiyama FsMountList mounts; 110446d4c572STomoki Sekiyama struct FsMount *mount; 110546d4c572STomoki Sekiyama GuestFilesystemInfoList *new, *ret = NULL; 110646d4c572STomoki Sekiyama Error *local_err = NULL; 110746d4c572STomoki Sekiyama 110846d4c572STomoki Sekiyama QTAILQ_INIT(&mounts); 110946d4c572STomoki Sekiyama build_fs_mount_list(&mounts, &local_err); 111046d4c572STomoki Sekiyama if (local_err) { 111146d4c572STomoki Sekiyama error_propagate(errp, local_err); 111246d4c572STomoki Sekiyama return NULL; 111346d4c572STomoki Sekiyama } 111446d4c572STomoki Sekiyama 111546d4c572STomoki Sekiyama QTAILQ_FOREACH(mount, &mounts, next) { 111646d4c572STomoki Sekiyama g_debug("Building guest fsinfo for '%s'", mount->dirname); 111746d4c572STomoki Sekiyama 111846d4c572STomoki Sekiyama new = g_malloc0(sizeof(*ret)); 111946d4c572STomoki Sekiyama new->value = build_guest_fsinfo(mount, &local_err); 112046d4c572STomoki Sekiyama new->next = ret; 112146d4c572STomoki Sekiyama ret = new; 112246d4c572STomoki Sekiyama if (local_err) { 112346d4c572STomoki Sekiyama error_propagate(errp, local_err); 112446d4c572STomoki Sekiyama qapi_free_GuestFilesystemInfoList(ret); 112546d4c572STomoki Sekiyama ret = NULL; 112646d4c572STomoki Sekiyama break; 112746d4c572STomoki Sekiyama } 112846d4c572STomoki Sekiyama } 112946d4c572STomoki Sekiyama 113046d4c572STomoki Sekiyama free_fs_mount_list(&mounts); 113146d4c572STomoki Sekiyama return ret; 113246d4c572STomoki Sekiyama } 113346d4c572STomoki Sekiyama 113446d4c572STomoki Sekiyama 1135ec0f694cSTomoki Sekiyama typedef enum { 1136ec0f694cSTomoki Sekiyama FSFREEZE_HOOK_THAW = 0, 1137ec0f694cSTomoki Sekiyama FSFREEZE_HOOK_FREEZE, 1138ec0f694cSTomoki Sekiyama } FsfreezeHookArg; 1139ec0f694cSTomoki Sekiyama 114013a439ecSStefan Weil static const char *fsfreeze_hook_arg_string[] = { 1141ec0f694cSTomoki Sekiyama "thaw", 1142ec0f694cSTomoki Sekiyama "freeze", 1143ec0f694cSTomoki Sekiyama }; 1144ec0f694cSTomoki Sekiyama 114577dbc81bSMarkus Armbruster static void execute_fsfreeze_hook(FsfreezeHookArg arg, Error **errp) 1146ec0f694cSTomoki Sekiyama { 1147ec0f694cSTomoki Sekiyama int status; 1148ec0f694cSTomoki Sekiyama pid_t pid; 1149ec0f694cSTomoki Sekiyama const char *hook; 1150ec0f694cSTomoki Sekiyama const char *arg_str = fsfreeze_hook_arg_string[arg]; 1151ec0f694cSTomoki Sekiyama Error *local_err = NULL; 1152ec0f694cSTomoki Sekiyama 1153ec0f694cSTomoki Sekiyama hook = ga_fsfreeze_hook(ga_state); 1154ec0f694cSTomoki Sekiyama if (!hook) { 1155ec0f694cSTomoki Sekiyama return; 1156ec0f694cSTomoki Sekiyama } 1157ec0f694cSTomoki Sekiyama if (access(hook, X_OK) != 0) { 115877dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "can't access fsfreeze hook '%s'", hook); 1159ec0f694cSTomoki Sekiyama return; 1160ec0f694cSTomoki Sekiyama } 1161ec0f694cSTomoki Sekiyama 1162ec0f694cSTomoki Sekiyama slog("executing fsfreeze hook with arg '%s'", arg_str); 1163ec0f694cSTomoki Sekiyama pid = fork(); 1164ec0f694cSTomoki Sekiyama if (pid == 0) { 1165ec0f694cSTomoki Sekiyama setsid(); 1166ec0f694cSTomoki Sekiyama reopen_fd_to_null(0); 1167ec0f694cSTomoki Sekiyama reopen_fd_to_null(1); 1168ec0f694cSTomoki Sekiyama reopen_fd_to_null(2); 1169ec0f694cSTomoki Sekiyama 1170ec0f694cSTomoki Sekiyama execle(hook, hook, arg_str, NULL, environ); 1171ec0f694cSTomoki Sekiyama _exit(EXIT_FAILURE); 1172ec0f694cSTomoki Sekiyama } else if (pid < 0) { 117377dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to create child process"); 1174ec0f694cSTomoki Sekiyama return; 1175ec0f694cSTomoki Sekiyama } 1176ec0f694cSTomoki Sekiyama 1177ec0f694cSTomoki Sekiyama ga_wait_child(pid, &status, &local_err); 117884d18f06SMarkus Armbruster if (local_err) { 117977dbc81bSMarkus Armbruster error_propagate(errp, local_err); 1180ec0f694cSTomoki Sekiyama return; 1181ec0f694cSTomoki Sekiyama } 1182ec0f694cSTomoki Sekiyama 1183ec0f694cSTomoki Sekiyama if (!WIFEXITED(status)) { 118477dbc81bSMarkus Armbruster error_setg(errp, "fsfreeze hook has terminated abnormally"); 1185ec0f694cSTomoki Sekiyama return; 1186ec0f694cSTomoki Sekiyama } 1187ec0f694cSTomoki Sekiyama 1188ec0f694cSTomoki Sekiyama status = WEXITSTATUS(status); 1189ec0f694cSTomoki Sekiyama if (status) { 119077dbc81bSMarkus Armbruster error_setg(errp, "fsfreeze hook has failed with status %d", status); 1191ec0f694cSTomoki Sekiyama return; 1192ec0f694cSTomoki Sekiyama } 1193ec0f694cSTomoki Sekiyama } 1194ec0f694cSTomoki Sekiyama 1195c216e5adSMichael Roth /* 1196c216e5adSMichael Roth * Return status of freeze/thaw 1197c216e5adSMichael Roth */ 119877dbc81bSMarkus Armbruster GuestFsfreezeStatus qmp_guest_fsfreeze_status(Error **errp) 1199c216e5adSMichael Roth { 1200f22d85e9SMichael Roth if (ga_is_frozen(ga_state)) { 1201f22d85e9SMichael Roth return GUEST_FSFREEZE_STATUS_FROZEN; 1202f22d85e9SMichael Roth } 1203f22d85e9SMichael Roth 1204f22d85e9SMichael Roth return GUEST_FSFREEZE_STATUS_THAWED; 1205c216e5adSMichael Roth } 1206c216e5adSMichael Roth 1207e99bce20STomoki Sekiyama int64_t qmp_guest_fsfreeze_freeze(Error **errp) 1208e99bce20STomoki Sekiyama { 1209e99bce20STomoki Sekiyama return qmp_guest_fsfreeze_freeze_list(false, NULL, errp); 1210e99bce20STomoki Sekiyama } 1211e99bce20STomoki Sekiyama 1212c216e5adSMichael Roth /* 1213c216e5adSMichael Roth * Walk list of mounted file systems in the guest, and freeze the ones which 1214c216e5adSMichael Roth * are real local file systems. 1215c216e5adSMichael Roth */ 1216e99bce20STomoki Sekiyama int64_t qmp_guest_fsfreeze_freeze_list(bool has_mountpoints, 1217e99bce20STomoki Sekiyama strList *mountpoints, 1218e99bce20STomoki Sekiyama Error **errp) 1219c216e5adSMichael Roth { 1220c216e5adSMichael Roth int ret = 0, i = 0; 1221e99bce20STomoki Sekiyama strList *list; 1222af02203fSPaolo Bonzini FsMountList mounts; 1223af02203fSPaolo Bonzini struct FsMount *mount; 1224261551d1SLuiz Capitulino Error *local_err = NULL; 1225c216e5adSMichael Roth int fd; 1226c216e5adSMichael Roth 1227c216e5adSMichael Roth slog("guest-fsfreeze called"); 1228c216e5adSMichael Roth 1229ec0f694cSTomoki Sekiyama execute_fsfreeze_hook(FSFREEZE_HOOK_FREEZE, &local_err); 123084d18f06SMarkus Armbruster if (local_err) { 123177dbc81bSMarkus Armbruster error_propagate(errp, local_err); 1232ec0f694cSTomoki Sekiyama return -1; 1233ec0f694cSTomoki Sekiyama } 1234ec0f694cSTomoki Sekiyama 12359e8aded4SMichael Roth QTAILQ_INIT(&mounts); 1236261551d1SLuiz Capitulino build_fs_mount_list(&mounts, &local_err); 123784d18f06SMarkus Armbruster if (local_err) { 123877dbc81bSMarkus Armbruster error_propagate(errp, local_err); 1239261551d1SLuiz Capitulino return -1; 1240c216e5adSMichael Roth } 1241c216e5adSMichael Roth 1242c216e5adSMichael Roth /* cannot risk guest agent blocking itself on a write in this state */ 1243f22d85e9SMichael Roth ga_set_frozen(ga_state); 1244c216e5adSMichael Roth 1245e5d9adbdSTomoki Sekiyama QTAILQ_FOREACH_REVERSE(mount, &mounts, FsMountList, next) { 1246e99bce20STomoki Sekiyama /* To issue fsfreeze in the reverse order of mounts, check if the 1247e99bce20STomoki Sekiyama * mount is listed in the list here */ 1248e99bce20STomoki Sekiyama if (has_mountpoints) { 1249e99bce20STomoki Sekiyama for (list = mountpoints; list; list = list->next) { 1250e99bce20STomoki Sekiyama if (strcmp(list->value, mount->dirname) == 0) { 1251e99bce20STomoki Sekiyama break; 1252e99bce20STomoki Sekiyama } 1253e99bce20STomoki Sekiyama } 1254e99bce20STomoki Sekiyama if (!list) { 1255e99bce20STomoki Sekiyama continue; 1256e99bce20STomoki Sekiyama } 1257e99bce20STomoki Sekiyama } 1258e99bce20STomoki Sekiyama 1259c216e5adSMichael Roth fd = qemu_open(mount->dirname, O_RDONLY); 1260c216e5adSMichael Roth if (fd == -1) { 126177dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to open %s", mount->dirname); 1262c216e5adSMichael Roth goto error; 1263c216e5adSMichael Roth } 1264c216e5adSMichael Roth 1265e35916acSMichael Tokarev /* we try to cull filesystems we know won't work in advance, but other 1266e35916acSMichael Tokarev * filesystems may not implement fsfreeze for less obvious reasons. 12679e8aded4SMichael Roth * these will report EOPNOTSUPP. we simply ignore these when tallying 12689e8aded4SMichael Roth * the number of frozen filesystems. 1269ce2eb6c4SPeter Lieven * if a filesystem is mounted more than once (aka bind mount) a 1270ce2eb6c4SPeter Lieven * consecutive attempt to freeze an already frozen filesystem will 1271ce2eb6c4SPeter Lieven * return EBUSY. 12729e8aded4SMichael Roth * 12739e8aded4SMichael Roth * any other error means a failure to freeze a filesystem we 12749e8aded4SMichael Roth * expect to be freezable, so return an error in those cases 12759e8aded4SMichael Roth * and return system to thawed state. 1276c216e5adSMichael Roth */ 1277c216e5adSMichael Roth ret = ioctl(fd, FIFREEZE); 12789e8aded4SMichael Roth if (ret == -1) { 1279ce2eb6c4SPeter Lieven if (errno != EOPNOTSUPP && errno != EBUSY) { 128077dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to freeze %s", 1281617fbbc1SLuiz Capitulino mount->dirname); 1282c216e5adSMichael Roth close(fd); 1283c216e5adSMichael Roth goto error; 1284c216e5adSMichael Roth } 12859e8aded4SMichael Roth } else { 1286c216e5adSMichael Roth i++; 1287c216e5adSMichael Roth } 12889e8aded4SMichael Roth close(fd); 12899e8aded4SMichael Roth } 1290c216e5adSMichael Roth 1291af02203fSPaolo Bonzini free_fs_mount_list(&mounts); 129265650f01SChen Hanxiao /* We may not issue any FIFREEZE here. 129365650f01SChen Hanxiao * Just unset ga_state here and ready for the next call. 129465650f01SChen Hanxiao */ 129565650f01SChen Hanxiao if (i == 0) { 129665650f01SChen Hanxiao ga_unset_frozen(ga_state); 129765650f01SChen Hanxiao } 1298c216e5adSMichael Roth return i; 1299c216e5adSMichael Roth 1300c216e5adSMichael Roth error: 1301af02203fSPaolo Bonzini free_fs_mount_list(&mounts); 1302c216e5adSMichael Roth qmp_guest_fsfreeze_thaw(NULL); 1303c216e5adSMichael Roth return 0; 1304c216e5adSMichael Roth } 1305c216e5adSMichael Roth 1306c216e5adSMichael Roth /* 1307c216e5adSMichael Roth * Walk list of frozen file systems in the guest, and thaw them. 1308c216e5adSMichael Roth */ 130977dbc81bSMarkus Armbruster int64_t qmp_guest_fsfreeze_thaw(Error **errp) 1310c216e5adSMichael Roth { 1311c216e5adSMichael Roth int ret; 1312af02203fSPaolo Bonzini FsMountList mounts; 1313af02203fSPaolo Bonzini FsMount *mount; 13149e8aded4SMichael Roth int fd, i = 0, logged; 1315261551d1SLuiz Capitulino Error *local_err = NULL; 1316c216e5adSMichael Roth 13179e8aded4SMichael Roth QTAILQ_INIT(&mounts); 1318261551d1SLuiz Capitulino build_fs_mount_list(&mounts, &local_err); 131984d18f06SMarkus Armbruster if (local_err) { 132077dbc81bSMarkus Armbruster error_propagate(errp, local_err); 13219e8aded4SMichael Roth return 0; 13229e8aded4SMichael Roth } 13239e8aded4SMichael Roth 13249e8aded4SMichael Roth QTAILQ_FOREACH(mount, &mounts, next) { 13259e8aded4SMichael Roth logged = false; 1326c216e5adSMichael Roth fd = qemu_open(mount->dirname, O_RDONLY); 1327c216e5adSMichael Roth if (fd == -1) { 1328c216e5adSMichael Roth continue; 1329c216e5adSMichael Roth } 13309e8aded4SMichael Roth /* we have no way of knowing whether a filesystem was actually unfrozen 13319e8aded4SMichael Roth * as a result of a successful call to FITHAW, only that if an error 13329e8aded4SMichael Roth * was returned the filesystem was *not* unfrozen by that particular 13339e8aded4SMichael Roth * call. 13349e8aded4SMichael Roth * 1335a31f0531SJim Meyering * since multiple preceding FIFREEZEs require multiple calls to FITHAW 13369e8aded4SMichael Roth * to unfreeze, continuing issuing FITHAW until an error is returned, 13379e8aded4SMichael Roth * in which case either the filesystem is in an unfreezable state, or, 13389e8aded4SMichael Roth * more likely, it was thawed previously (and remains so afterward). 13399e8aded4SMichael Roth * 13409e8aded4SMichael Roth * also, since the most recent successful call is the one that did 13419e8aded4SMichael Roth * the actual unfreeze, we can use this to provide an accurate count 13429e8aded4SMichael Roth * of the number of filesystems unfrozen by guest-fsfreeze-thaw, which 13439e8aded4SMichael Roth * may * be useful for determining whether a filesystem was unfrozen 13449e8aded4SMichael Roth * during the freeze/thaw phase by a process other than qemu-ga. 13459e8aded4SMichael Roth */ 13469e8aded4SMichael Roth do { 1347c216e5adSMichael Roth ret = ioctl(fd, FITHAW); 13489e8aded4SMichael Roth if (ret == 0 && !logged) { 1349c216e5adSMichael Roth i++; 13509e8aded4SMichael Roth logged = true; 13519e8aded4SMichael Roth } 13529e8aded4SMichael Roth } while (ret == 0); 13539e8aded4SMichael Roth close(fd); 1354c216e5adSMichael Roth } 1355c216e5adSMichael Roth 1356f22d85e9SMichael Roth ga_unset_frozen(ga_state); 1357af02203fSPaolo Bonzini free_fs_mount_list(&mounts); 1358ec0f694cSTomoki Sekiyama 135977dbc81bSMarkus Armbruster execute_fsfreeze_hook(FSFREEZE_HOOK_THAW, errp); 1360ec0f694cSTomoki Sekiyama 1361c216e5adSMichael Roth return i; 1362c216e5adSMichael Roth } 1363c216e5adSMichael Roth 1364c216e5adSMichael Roth static void guest_fsfreeze_cleanup(void) 1365c216e5adSMichael Roth { 1366c216e5adSMichael Roth Error *err = NULL; 1367c216e5adSMichael Roth 1368f22d85e9SMichael Roth if (ga_is_frozen(ga_state) == GUEST_FSFREEZE_STATUS_FROZEN) { 13696f686749SMarkus Armbruster qmp_guest_fsfreeze_thaw(&err); 13706f686749SMarkus Armbruster if (err) { 13716f686749SMarkus Armbruster slog("failed to clean up frozen filesystems: %s", 13726f686749SMarkus Armbruster error_get_pretty(err)); 13736f686749SMarkus Armbruster error_free(err); 1374c216e5adSMichael Roth } 1375c216e5adSMichael Roth } 1376c216e5adSMichael Roth } 1377e72c3f2eSMichael Roth #endif /* CONFIG_FSFREEZE */ 1378c216e5adSMichael Roth 1379eab5fd59SPaolo Bonzini #if defined(CONFIG_FSTRIM) 1380eab5fd59SPaolo Bonzini /* 1381eab5fd59SPaolo Bonzini * Walk list of mounted file systems in the guest, and trim them. 1382eab5fd59SPaolo Bonzini */ 1383e82855d9SJustin Ossevoort GuestFilesystemTrimResponse * 1384e82855d9SJustin Ossevoort qmp_guest_fstrim(bool has_minimum, int64_t minimum, Error **errp) 1385eab5fd59SPaolo Bonzini { 1386e82855d9SJustin Ossevoort GuestFilesystemTrimResponse *response; 1387e82855d9SJustin Ossevoort GuestFilesystemTrimResultList *list; 1388e82855d9SJustin Ossevoort GuestFilesystemTrimResult *result; 1389eab5fd59SPaolo Bonzini int ret = 0; 1390eab5fd59SPaolo Bonzini FsMountList mounts; 1391eab5fd59SPaolo Bonzini struct FsMount *mount; 1392eab5fd59SPaolo Bonzini int fd; 1393261551d1SLuiz Capitulino Error *local_err = NULL; 139473a652a1SJustin Ossevoort struct fstrim_range r; 1395eab5fd59SPaolo Bonzini 1396eab5fd59SPaolo Bonzini slog("guest-fstrim called"); 1397eab5fd59SPaolo Bonzini 1398eab5fd59SPaolo Bonzini QTAILQ_INIT(&mounts); 1399261551d1SLuiz Capitulino build_fs_mount_list(&mounts, &local_err); 140084d18f06SMarkus Armbruster if (local_err) { 140177dbc81bSMarkus Armbruster error_propagate(errp, local_err); 1402e82855d9SJustin Ossevoort return NULL; 1403eab5fd59SPaolo Bonzini } 1404eab5fd59SPaolo Bonzini 1405e82855d9SJustin Ossevoort response = g_malloc0(sizeof(*response)); 1406e82855d9SJustin Ossevoort 1407eab5fd59SPaolo Bonzini QTAILQ_FOREACH(mount, &mounts, next) { 1408e82855d9SJustin Ossevoort result = g_malloc0(sizeof(*result)); 1409e82855d9SJustin Ossevoort result->path = g_strdup(mount->dirname); 1410e82855d9SJustin Ossevoort 1411e82855d9SJustin Ossevoort list = g_malloc0(sizeof(*list)); 1412e82855d9SJustin Ossevoort list->value = result; 1413e82855d9SJustin Ossevoort list->next = response->paths; 1414e82855d9SJustin Ossevoort response->paths = list; 1415e82855d9SJustin Ossevoort 1416eab5fd59SPaolo Bonzini fd = qemu_open(mount->dirname, O_RDONLY); 1417eab5fd59SPaolo Bonzini if (fd == -1) { 1418e82855d9SJustin Ossevoort result->error = g_strdup_printf("failed to open: %s", 1419e82855d9SJustin Ossevoort strerror(errno)); 1420e82855d9SJustin Ossevoort result->has_error = true; 1421e82855d9SJustin Ossevoort continue; 1422eab5fd59SPaolo Bonzini } 1423eab5fd59SPaolo Bonzini 1424e35916acSMichael Tokarev /* We try to cull filesystems we know won't work in advance, but other 1425e35916acSMichael Tokarev * filesystems may not implement fstrim for less obvious reasons. 1426e35916acSMichael Tokarev * These will report EOPNOTSUPP; while in some other cases ENOTTY 1427e35916acSMichael Tokarev * will be reported (e.g. CD-ROMs). 1428e82855d9SJustin Ossevoort * Any other error means an unexpected error. 1429eab5fd59SPaolo Bonzini */ 143073a652a1SJustin Ossevoort r.start = 0; 143173a652a1SJustin Ossevoort r.len = -1; 143273a652a1SJustin Ossevoort r.minlen = has_minimum ? minimum : 0; 1433eab5fd59SPaolo Bonzini ret = ioctl(fd, FITRIM, &r); 1434eab5fd59SPaolo Bonzini if (ret == -1) { 1435e82855d9SJustin Ossevoort result->has_error = true; 1436e82855d9SJustin Ossevoort if (errno == ENOTTY || errno == EOPNOTSUPP) { 1437e82855d9SJustin Ossevoort result->error = g_strdup("trim not supported"); 1438e82855d9SJustin Ossevoort } else { 1439e82855d9SJustin Ossevoort result->error = g_strdup_printf("failed to trim: %s", 1440e82855d9SJustin Ossevoort strerror(errno)); 1441e82855d9SJustin Ossevoort } 1442eab5fd59SPaolo Bonzini close(fd); 1443e82855d9SJustin Ossevoort continue; 1444eab5fd59SPaolo Bonzini } 1445e82855d9SJustin Ossevoort 1446e82855d9SJustin Ossevoort result->has_minimum = true; 1447e82855d9SJustin Ossevoort result->minimum = r.minlen; 1448e82855d9SJustin Ossevoort result->has_trimmed = true; 1449e82855d9SJustin Ossevoort result->trimmed = r.len; 1450eab5fd59SPaolo Bonzini close(fd); 1451eab5fd59SPaolo Bonzini } 1452eab5fd59SPaolo Bonzini 1453eab5fd59SPaolo Bonzini free_fs_mount_list(&mounts); 1454e82855d9SJustin Ossevoort return response; 1455eab5fd59SPaolo Bonzini } 1456eab5fd59SPaolo Bonzini #endif /* CONFIG_FSTRIM */ 1457eab5fd59SPaolo Bonzini 1458eab5fd59SPaolo Bonzini 145911d0f125SLuiz Capitulino #define LINUX_SYS_STATE_FILE "/sys/power/state" 146011d0f125SLuiz Capitulino #define SUSPEND_SUPPORTED 0 146111d0f125SLuiz Capitulino #define SUSPEND_NOT_SUPPORTED 1 146211d0f125SLuiz Capitulino 146311d0f125SLuiz Capitulino static void bios_supports_mode(const char *pmutils_bin, const char *pmutils_arg, 146477dbc81bSMarkus Armbruster const char *sysfile_str, Error **errp) 146511d0f125SLuiz Capitulino { 14666b26e837SLuiz Capitulino Error *local_err = NULL; 146711d0f125SLuiz Capitulino char *pmutils_path; 14686b26e837SLuiz Capitulino pid_t pid; 1469dc8764f0SLuiz Capitulino int status; 147011d0f125SLuiz Capitulino 147111d0f125SLuiz Capitulino pmutils_path = g_find_program_in_path(pmutils_bin); 147211d0f125SLuiz Capitulino 147311d0f125SLuiz Capitulino pid = fork(); 147411d0f125SLuiz Capitulino if (!pid) { 1475dc8764f0SLuiz Capitulino char buf[32]; /* hopefully big enough */ 1476dc8764f0SLuiz Capitulino ssize_t ret; 1477dc8764f0SLuiz Capitulino int fd; 147811d0f125SLuiz Capitulino 147911d0f125SLuiz Capitulino setsid(); 148011d0f125SLuiz Capitulino reopen_fd_to_null(0); 148111d0f125SLuiz Capitulino reopen_fd_to_null(1); 148211d0f125SLuiz Capitulino reopen_fd_to_null(2); 148311d0f125SLuiz Capitulino 148411d0f125SLuiz Capitulino if (pmutils_path) { 148511d0f125SLuiz Capitulino execle(pmutils_path, pmutils_bin, pmutils_arg, NULL, environ); 148611d0f125SLuiz Capitulino } 148711d0f125SLuiz Capitulino 148811d0f125SLuiz Capitulino /* 148911d0f125SLuiz Capitulino * If we get here either pm-utils is not installed or execle() has 149011d0f125SLuiz Capitulino * failed. Let's try the manual method if the caller wants it. 149111d0f125SLuiz Capitulino */ 149211d0f125SLuiz Capitulino 149311d0f125SLuiz Capitulino if (!sysfile_str) { 149411d0f125SLuiz Capitulino _exit(SUSPEND_NOT_SUPPORTED); 149511d0f125SLuiz Capitulino } 149611d0f125SLuiz Capitulino 149711d0f125SLuiz Capitulino fd = open(LINUX_SYS_STATE_FILE, O_RDONLY); 149811d0f125SLuiz Capitulino if (fd < 0) { 149911d0f125SLuiz Capitulino _exit(SUSPEND_NOT_SUPPORTED); 150011d0f125SLuiz Capitulino } 150111d0f125SLuiz Capitulino 150211d0f125SLuiz Capitulino ret = read(fd, buf, sizeof(buf)-1); 150311d0f125SLuiz Capitulino if (ret <= 0) { 150411d0f125SLuiz Capitulino _exit(SUSPEND_NOT_SUPPORTED); 150511d0f125SLuiz Capitulino } 150611d0f125SLuiz Capitulino buf[ret] = '\0'; 150711d0f125SLuiz Capitulino 150811d0f125SLuiz Capitulino if (strstr(buf, sysfile_str)) { 150911d0f125SLuiz Capitulino _exit(SUSPEND_SUPPORTED); 151011d0f125SLuiz Capitulino } 151111d0f125SLuiz Capitulino 151211d0f125SLuiz Capitulino _exit(SUSPEND_NOT_SUPPORTED); 15136b26e837SLuiz Capitulino } else if (pid < 0) { 151477dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to create child process"); 15156b26e837SLuiz Capitulino goto out; 151611d0f125SLuiz Capitulino } 151711d0f125SLuiz Capitulino 15186b26e837SLuiz Capitulino ga_wait_child(pid, &status, &local_err); 151984d18f06SMarkus Armbruster if (local_err) { 152077dbc81bSMarkus Armbruster error_propagate(errp, local_err); 15216b26e837SLuiz Capitulino goto out; 152211d0f125SLuiz Capitulino } 152311d0f125SLuiz Capitulino 15246b26e837SLuiz Capitulino if (!WIFEXITED(status)) { 152577dbc81bSMarkus Armbruster error_setg(errp, "child process has terminated abnormally"); 15266b26e837SLuiz Capitulino goto out; 15276b26e837SLuiz Capitulino } 15286b26e837SLuiz Capitulino 1529dc8764f0SLuiz Capitulino switch (WEXITSTATUS(status)) { 1530dc8764f0SLuiz Capitulino case SUSPEND_SUPPORTED: 15316b26e837SLuiz Capitulino goto out; 1532dc8764f0SLuiz Capitulino case SUSPEND_NOT_SUPPORTED: 153377dbc81bSMarkus Armbruster error_setg(errp, 15346b26e837SLuiz Capitulino "the requested suspend mode is not supported by the guest"); 15356b26e837SLuiz Capitulino goto out; 1536dc8764f0SLuiz Capitulino default: 153777dbc81bSMarkus Armbruster error_setg(errp, 15386b26e837SLuiz Capitulino "the helper program '%s' returned an unexpected exit status" 15396b26e837SLuiz Capitulino " code (%d)", pmutils_path, WEXITSTATUS(status)); 15406b26e837SLuiz Capitulino goto out; 1541dc8764f0SLuiz Capitulino } 154211d0f125SLuiz Capitulino 15436b26e837SLuiz Capitulino out: 15446b26e837SLuiz Capitulino g_free(pmutils_path); 154511d0f125SLuiz Capitulino } 154611d0f125SLuiz Capitulino 154711d0f125SLuiz Capitulino static void guest_suspend(const char *pmutils_bin, const char *sysfile_str, 154877dbc81bSMarkus Armbruster Error **errp) 154911d0f125SLuiz Capitulino { 15507b376087SLuiz Capitulino Error *local_err = NULL; 155111d0f125SLuiz Capitulino char *pmutils_path; 15527b376087SLuiz Capitulino pid_t pid; 1553dc8764f0SLuiz Capitulino int status; 155411d0f125SLuiz Capitulino 155511d0f125SLuiz Capitulino pmutils_path = g_find_program_in_path(pmutils_bin); 155611d0f125SLuiz Capitulino 155711d0f125SLuiz Capitulino pid = fork(); 155811d0f125SLuiz Capitulino if (pid == 0) { 155911d0f125SLuiz Capitulino /* child */ 156011d0f125SLuiz Capitulino int fd; 156111d0f125SLuiz Capitulino 156211d0f125SLuiz Capitulino setsid(); 156311d0f125SLuiz Capitulino reopen_fd_to_null(0); 156411d0f125SLuiz Capitulino reopen_fd_to_null(1); 156511d0f125SLuiz Capitulino reopen_fd_to_null(2); 156611d0f125SLuiz Capitulino 156711d0f125SLuiz Capitulino if (pmutils_path) { 156811d0f125SLuiz Capitulino execle(pmutils_path, pmutils_bin, NULL, environ); 156911d0f125SLuiz Capitulino } 157011d0f125SLuiz Capitulino 157111d0f125SLuiz Capitulino /* 157211d0f125SLuiz Capitulino * If we get here either pm-utils is not installed or execle() has 157311d0f125SLuiz Capitulino * failed. Let's try the manual method if the caller wants it. 157411d0f125SLuiz Capitulino */ 157511d0f125SLuiz Capitulino 157611d0f125SLuiz Capitulino if (!sysfile_str) { 157711d0f125SLuiz Capitulino _exit(EXIT_FAILURE); 157811d0f125SLuiz Capitulino } 157911d0f125SLuiz Capitulino 158011d0f125SLuiz Capitulino fd = open(LINUX_SYS_STATE_FILE, O_WRONLY); 158111d0f125SLuiz Capitulino if (fd < 0) { 158211d0f125SLuiz Capitulino _exit(EXIT_FAILURE); 158311d0f125SLuiz Capitulino } 158411d0f125SLuiz Capitulino 158511d0f125SLuiz Capitulino if (write(fd, sysfile_str, strlen(sysfile_str)) < 0) { 158611d0f125SLuiz Capitulino _exit(EXIT_FAILURE); 158711d0f125SLuiz Capitulino } 158811d0f125SLuiz Capitulino 158911d0f125SLuiz Capitulino _exit(EXIT_SUCCESS); 15907b376087SLuiz Capitulino } else if (pid < 0) { 159177dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "failed to create child process"); 15927b376087SLuiz Capitulino goto out; 159311d0f125SLuiz Capitulino } 159411d0f125SLuiz Capitulino 15957b376087SLuiz Capitulino ga_wait_child(pid, &status, &local_err); 159684d18f06SMarkus Armbruster if (local_err) { 159777dbc81bSMarkus Armbruster error_propagate(errp, local_err); 15987b376087SLuiz Capitulino goto out; 15997b376087SLuiz Capitulino } 16007b376087SLuiz Capitulino 16017b376087SLuiz Capitulino if (!WIFEXITED(status)) { 160277dbc81bSMarkus Armbruster error_setg(errp, "child process has terminated abnormally"); 16037b376087SLuiz Capitulino goto out; 16047b376087SLuiz Capitulino } 16057b376087SLuiz Capitulino 16067b376087SLuiz Capitulino if (WEXITSTATUS(status)) { 160777dbc81bSMarkus Armbruster error_setg(errp, "child process has failed to suspend"); 16087b376087SLuiz Capitulino goto out; 16097b376087SLuiz Capitulino } 16107b376087SLuiz Capitulino 16117b376087SLuiz Capitulino out: 161211d0f125SLuiz Capitulino g_free(pmutils_path); 161311d0f125SLuiz Capitulino } 161411d0f125SLuiz Capitulino 161577dbc81bSMarkus Armbruster void qmp_guest_suspend_disk(Error **errp) 161611d0f125SLuiz Capitulino { 16170f230bf7SMarkus Armbruster Error *local_err = NULL; 16180f230bf7SMarkus Armbruster 16190f230bf7SMarkus Armbruster bios_supports_mode("pm-is-supported", "--hibernate", "disk", &local_err); 16200f230bf7SMarkus Armbruster if (local_err) { 16210f230bf7SMarkus Armbruster error_propagate(errp, local_err); 162211d0f125SLuiz Capitulino return; 162311d0f125SLuiz Capitulino } 162411d0f125SLuiz Capitulino 162577dbc81bSMarkus Armbruster guest_suspend("pm-hibernate", "disk", errp); 162611d0f125SLuiz Capitulino } 162711d0f125SLuiz Capitulino 162877dbc81bSMarkus Armbruster void qmp_guest_suspend_ram(Error **errp) 1629fbf42210SLuiz Capitulino { 16300f230bf7SMarkus Armbruster Error *local_err = NULL; 16310f230bf7SMarkus Armbruster 16320f230bf7SMarkus Armbruster bios_supports_mode("pm-is-supported", "--suspend", "mem", &local_err); 16330f230bf7SMarkus Armbruster if (local_err) { 16340f230bf7SMarkus Armbruster error_propagate(errp, local_err); 1635fbf42210SLuiz Capitulino return; 1636fbf42210SLuiz Capitulino } 1637fbf42210SLuiz Capitulino 163877dbc81bSMarkus Armbruster guest_suspend("pm-suspend", "mem", errp); 1639fbf42210SLuiz Capitulino } 1640fbf42210SLuiz Capitulino 164177dbc81bSMarkus Armbruster void qmp_guest_suspend_hybrid(Error **errp) 164295f4f404SLuiz Capitulino { 16430f230bf7SMarkus Armbruster Error *local_err = NULL; 16440f230bf7SMarkus Armbruster 16450f230bf7SMarkus Armbruster bios_supports_mode("pm-is-supported", "--suspend-hybrid", NULL, 16460f230bf7SMarkus Armbruster &local_err); 16470f230bf7SMarkus Armbruster if (local_err) { 16480f230bf7SMarkus Armbruster error_propagate(errp, local_err); 164995f4f404SLuiz Capitulino return; 165095f4f404SLuiz Capitulino } 165195f4f404SLuiz Capitulino 165277dbc81bSMarkus Armbruster guest_suspend("pm-suspend-hybrid", NULL, errp); 165395f4f404SLuiz Capitulino } 165495f4f404SLuiz Capitulino 16553424fc9fSMichal Privoznik static GuestNetworkInterfaceList * 16563424fc9fSMichal Privoznik guest_find_interface(GuestNetworkInterfaceList *head, 16573424fc9fSMichal Privoznik const char *name) 16583424fc9fSMichal Privoznik { 16593424fc9fSMichal Privoznik for (; head; head = head->next) { 16603424fc9fSMichal Privoznik if (strcmp(head->value->name, name) == 0) { 16613424fc9fSMichal Privoznik break; 16623424fc9fSMichal Privoznik } 16633424fc9fSMichal Privoznik } 16643424fc9fSMichal Privoznik 16653424fc9fSMichal Privoznik return head; 16663424fc9fSMichal Privoznik } 16673424fc9fSMichal Privoznik 166853f9fcb2SZhiPeng Lu static int guest_get_network_stats(const char *name, 166953f9fcb2SZhiPeng Lu GuestNetworkInterfaceStat *stats) 167053f9fcb2SZhiPeng Lu { 167153f9fcb2SZhiPeng Lu int name_len; 167253f9fcb2SZhiPeng Lu char const *devinfo = "/proc/net/dev"; 167353f9fcb2SZhiPeng Lu FILE *fp; 167453f9fcb2SZhiPeng Lu char *line = NULL, *colon; 167553f9fcb2SZhiPeng Lu size_t n = 0; 167653f9fcb2SZhiPeng Lu fp = fopen(devinfo, "r"); 167753f9fcb2SZhiPeng Lu if (!fp) { 167853f9fcb2SZhiPeng Lu return -1; 167953f9fcb2SZhiPeng Lu } 168053f9fcb2SZhiPeng Lu name_len = strlen(name); 168153f9fcb2SZhiPeng Lu while (getline(&line, &n, fp) != -1) { 168253f9fcb2SZhiPeng Lu long long dummy; 168353f9fcb2SZhiPeng Lu long long rx_bytes; 168453f9fcb2SZhiPeng Lu long long rx_packets; 168553f9fcb2SZhiPeng Lu long long rx_errs; 168653f9fcb2SZhiPeng Lu long long rx_dropped; 168753f9fcb2SZhiPeng Lu long long tx_bytes; 168853f9fcb2SZhiPeng Lu long long tx_packets; 168953f9fcb2SZhiPeng Lu long long tx_errs; 169053f9fcb2SZhiPeng Lu long long tx_dropped; 169153f9fcb2SZhiPeng Lu char *trim_line; 169253f9fcb2SZhiPeng Lu trim_line = g_strchug(line); 169353f9fcb2SZhiPeng Lu if (trim_line[0] == '\0') { 169453f9fcb2SZhiPeng Lu continue; 169553f9fcb2SZhiPeng Lu } 169653f9fcb2SZhiPeng Lu colon = strchr(trim_line, ':'); 169753f9fcb2SZhiPeng Lu if (!colon) { 169853f9fcb2SZhiPeng Lu continue; 169953f9fcb2SZhiPeng Lu } 170053f9fcb2SZhiPeng Lu if (colon - name_len == trim_line && 170153f9fcb2SZhiPeng Lu strncmp(trim_line, name, name_len) == 0) { 170253f9fcb2SZhiPeng Lu if (sscanf(colon + 1, 170353f9fcb2SZhiPeng Lu "%lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld %lld", 170453f9fcb2SZhiPeng Lu &rx_bytes, &rx_packets, &rx_errs, &rx_dropped, 170553f9fcb2SZhiPeng Lu &dummy, &dummy, &dummy, &dummy, 170653f9fcb2SZhiPeng Lu &tx_bytes, &tx_packets, &tx_errs, &tx_dropped, 170753f9fcb2SZhiPeng Lu &dummy, &dummy, &dummy, &dummy) != 16) { 170853f9fcb2SZhiPeng Lu continue; 170953f9fcb2SZhiPeng Lu } 171053f9fcb2SZhiPeng Lu stats->rx_bytes = rx_bytes; 171153f9fcb2SZhiPeng Lu stats->rx_packets = rx_packets; 171253f9fcb2SZhiPeng Lu stats->rx_errs = rx_errs; 171353f9fcb2SZhiPeng Lu stats->rx_dropped = rx_dropped; 171453f9fcb2SZhiPeng Lu stats->tx_bytes = tx_bytes; 171553f9fcb2SZhiPeng Lu stats->tx_packets = tx_packets; 171653f9fcb2SZhiPeng Lu stats->tx_errs = tx_errs; 171753f9fcb2SZhiPeng Lu stats->tx_dropped = tx_dropped; 171853f9fcb2SZhiPeng Lu fclose(fp); 171953f9fcb2SZhiPeng Lu g_free(line); 172053f9fcb2SZhiPeng Lu return 0; 172153f9fcb2SZhiPeng Lu } 172253f9fcb2SZhiPeng Lu } 172353f9fcb2SZhiPeng Lu fclose(fp); 172453f9fcb2SZhiPeng Lu g_free(line); 172553f9fcb2SZhiPeng Lu g_debug("/proc/net/dev: Interface '%s' not found", name); 172653f9fcb2SZhiPeng Lu return -1; 172753f9fcb2SZhiPeng Lu } 172853f9fcb2SZhiPeng Lu 17293424fc9fSMichal Privoznik /* 17303424fc9fSMichal Privoznik * Build information about guest interfaces 17313424fc9fSMichal Privoznik */ 17323424fc9fSMichal Privoznik GuestNetworkInterfaceList *qmp_guest_network_get_interfaces(Error **errp) 17333424fc9fSMichal Privoznik { 17343424fc9fSMichal Privoznik GuestNetworkInterfaceList *head = NULL, *cur_item = NULL; 17353424fc9fSMichal Privoznik struct ifaddrs *ifap, *ifa; 17363424fc9fSMichal Privoznik 17373424fc9fSMichal Privoznik if (getifaddrs(&ifap) < 0) { 1738878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, "getifaddrs failed"); 17393424fc9fSMichal Privoznik goto error; 17403424fc9fSMichal Privoznik } 17413424fc9fSMichal Privoznik 17423424fc9fSMichal Privoznik for (ifa = ifap; ifa; ifa = ifa->ifa_next) { 17433424fc9fSMichal Privoznik GuestNetworkInterfaceList *info; 17443424fc9fSMichal Privoznik GuestIpAddressList **address_list = NULL, *address_item = NULL; 174553f9fcb2SZhiPeng Lu GuestNetworkInterfaceStat *interface_stat = NULL; 17463424fc9fSMichal Privoznik char addr4[INET_ADDRSTRLEN]; 17473424fc9fSMichal Privoznik char addr6[INET6_ADDRSTRLEN]; 17483424fc9fSMichal Privoznik int sock; 17493424fc9fSMichal Privoznik struct ifreq ifr; 17503424fc9fSMichal Privoznik unsigned char *mac_addr; 17513424fc9fSMichal Privoznik void *p; 17523424fc9fSMichal Privoznik 17533424fc9fSMichal Privoznik g_debug("Processing %s interface", ifa->ifa_name); 17543424fc9fSMichal Privoznik 17553424fc9fSMichal Privoznik info = guest_find_interface(head, ifa->ifa_name); 17563424fc9fSMichal Privoznik 17573424fc9fSMichal Privoznik if (!info) { 17583424fc9fSMichal Privoznik info = g_malloc0(sizeof(*info)); 17593424fc9fSMichal Privoznik info->value = g_malloc0(sizeof(*info->value)); 17603424fc9fSMichal Privoznik info->value->name = g_strdup(ifa->ifa_name); 17613424fc9fSMichal Privoznik 17623424fc9fSMichal Privoznik if (!cur_item) { 17633424fc9fSMichal Privoznik head = cur_item = info; 17643424fc9fSMichal Privoznik } else { 17653424fc9fSMichal Privoznik cur_item->next = info; 17663424fc9fSMichal Privoznik cur_item = info; 17673424fc9fSMichal Privoznik } 17683424fc9fSMichal Privoznik } 17693424fc9fSMichal Privoznik 17703424fc9fSMichal Privoznik if (!info->value->has_hardware_address && 17713424fc9fSMichal Privoznik ifa->ifa_flags & SIOCGIFHWADDR) { 17723424fc9fSMichal Privoznik /* we haven't obtained HW address yet */ 17733424fc9fSMichal Privoznik sock = socket(PF_INET, SOCK_STREAM, 0); 17743424fc9fSMichal Privoznik if (sock == -1) { 1775878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, "failed to create socket"); 17763424fc9fSMichal Privoznik goto error; 17773424fc9fSMichal Privoznik } 17783424fc9fSMichal Privoznik 17793424fc9fSMichal Privoznik memset(&ifr, 0, sizeof(ifr)); 17801ab516edSJim Meyering pstrcpy(ifr.ifr_name, IF_NAMESIZE, info->value->name); 17813424fc9fSMichal Privoznik if (ioctl(sock, SIOCGIFHWADDR, &ifr) == -1) { 1782878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, 1783878a0ae0SLuiz Capitulino "failed to get MAC address of %s", 1784878a0ae0SLuiz Capitulino ifa->ifa_name); 178510a2158fSMarkus Armbruster close(sock); 17863424fc9fSMichal Privoznik goto error; 17873424fc9fSMichal Privoznik } 17883424fc9fSMichal Privoznik 178910a2158fSMarkus Armbruster close(sock); 17903424fc9fSMichal Privoznik mac_addr = (unsigned char *) &ifr.ifr_hwaddr.sa_data; 17913424fc9fSMichal Privoznik 1792e4ada482SStefan Weil info->value->hardware_address = 1793e4ada482SStefan Weil g_strdup_printf("%02x:%02x:%02x:%02x:%02x:%02x", 17943424fc9fSMichal Privoznik (int) mac_addr[0], (int) mac_addr[1], 17953424fc9fSMichal Privoznik (int) mac_addr[2], (int) mac_addr[3], 1796e4ada482SStefan Weil (int) mac_addr[4], (int) mac_addr[5]); 17973424fc9fSMichal Privoznik 17983424fc9fSMichal Privoznik info->value->has_hardware_address = true; 17993424fc9fSMichal Privoznik } 18003424fc9fSMichal Privoznik 18013424fc9fSMichal Privoznik if (ifa->ifa_addr && 18023424fc9fSMichal Privoznik ifa->ifa_addr->sa_family == AF_INET) { 18033424fc9fSMichal Privoznik /* interface with IPv4 address */ 18043424fc9fSMichal Privoznik p = &((struct sockaddr_in *)ifa->ifa_addr)->sin_addr; 18053424fc9fSMichal Privoznik if (!inet_ntop(AF_INET, p, addr4, sizeof(addr4))) { 1806878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, "inet_ntop failed"); 18073424fc9fSMichal Privoznik goto error; 18083424fc9fSMichal Privoznik } 18093424fc9fSMichal Privoznik 181010a2158fSMarkus Armbruster address_item = g_malloc0(sizeof(*address_item)); 181110a2158fSMarkus Armbruster address_item->value = g_malloc0(sizeof(*address_item->value)); 18123424fc9fSMichal Privoznik address_item->value->ip_address = g_strdup(addr4); 18133424fc9fSMichal Privoznik address_item->value->ip_address_type = GUEST_IP_ADDRESS_TYPE_IPV4; 18143424fc9fSMichal Privoznik 18153424fc9fSMichal Privoznik if (ifa->ifa_netmask) { 18163424fc9fSMichal Privoznik /* Count the number of set bits in netmask. 18173424fc9fSMichal Privoznik * This is safe as '1' and '0' cannot be shuffled in netmask. */ 18183424fc9fSMichal Privoznik p = &((struct sockaddr_in *)ifa->ifa_netmask)->sin_addr; 18193424fc9fSMichal Privoznik address_item->value->prefix = ctpop32(((uint32_t *) p)[0]); 18203424fc9fSMichal Privoznik } 18213424fc9fSMichal Privoznik } else if (ifa->ifa_addr && 18223424fc9fSMichal Privoznik ifa->ifa_addr->sa_family == AF_INET6) { 18233424fc9fSMichal Privoznik /* interface with IPv6 address */ 18243424fc9fSMichal Privoznik p = &((struct sockaddr_in6 *)ifa->ifa_addr)->sin6_addr; 18253424fc9fSMichal Privoznik if (!inet_ntop(AF_INET6, p, addr6, sizeof(addr6))) { 1826878a0ae0SLuiz Capitulino error_setg_errno(errp, errno, "inet_ntop failed"); 18273424fc9fSMichal Privoznik goto error; 18283424fc9fSMichal Privoznik } 18293424fc9fSMichal Privoznik 183010a2158fSMarkus Armbruster address_item = g_malloc0(sizeof(*address_item)); 183110a2158fSMarkus Armbruster address_item->value = g_malloc0(sizeof(*address_item->value)); 18323424fc9fSMichal Privoznik address_item->value->ip_address = g_strdup(addr6); 18333424fc9fSMichal Privoznik address_item->value->ip_address_type = GUEST_IP_ADDRESS_TYPE_IPV6; 18343424fc9fSMichal Privoznik 18353424fc9fSMichal Privoznik if (ifa->ifa_netmask) { 18363424fc9fSMichal Privoznik /* Count the number of set bits in netmask. 18373424fc9fSMichal Privoznik * This is safe as '1' and '0' cannot be shuffled in netmask. */ 18383424fc9fSMichal Privoznik p = &((struct sockaddr_in6 *)ifa->ifa_netmask)->sin6_addr; 18393424fc9fSMichal Privoznik address_item->value->prefix = 18403424fc9fSMichal Privoznik ctpop32(((uint32_t *) p)[0]) + 18413424fc9fSMichal Privoznik ctpop32(((uint32_t *) p)[1]) + 18423424fc9fSMichal Privoznik ctpop32(((uint32_t *) p)[2]) + 18433424fc9fSMichal Privoznik ctpop32(((uint32_t *) p)[3]); 18443424fc9fSMichal Privoznik } 18453424fc9fSMichal Privoznik } 18463424fc9fSMichal Privoznik 18473424fc9fSMichal Privoznik if (!address_item) { 18483424fc9fSMichal Privoznik continue; 18493424fc9fSMichal Privoznik } 18503424fc9fSMichal Privoznik 18513424fc9fSMichal Privoznik address_list = &info->value->ip_addresses; 18523424fc9fSMichal Privoznik 18533424fc9fSMichal Privoznik while (*address_list && (*address_list)->next) { 18543424fc9fSMichal Privoznik address_list = &(*address_list)->next; 18553424fc9fSMichal Privoznik } 18563424fc9fSMichal Privoznik 18573424fc9fSMichal Privoznik if (!*address_list) { 18583424fc9fSMichal Privoznik *address_list = address_item; 18593424fc9fSMichal Privoznik } else { 18603424fc9fSMichal Privoznik (*address_list)->next = address_item; 18613424fc9fSMichal Privoznik } 18623424fc9fSMichal Privoznik 18633424fc9fSMichal Privoznik info->value->has_ip_addresses = true; 18643424fc9fSMichal Privoznik 186553f9fcb2SZhiPeng Lu if (!info->value->has_statistics) { 186653f9fcb2SZhiPeng Lu interface_stat = g_malloc0(sizeof(*interface_stat)); 186753f9fcb2SZhiPeng Lu if (guest_get_network_stats(info->value->name, 186853f9fcb2SZhiPeng Lu interface_stat) == -1) { 186953f9fcb2SZhiPeng Lu info->value->has_statistics = false; 187053f9fcb2SZhiPeng Lu g_free(interface_stat); 187153f9fcb2SZhiPeng Lu } else { 187253f9fcb2SZhiPeng Lu info->value->statistics = interface_stat; 187353f9fcb2SZhiPeng Lu info->value->has_statistics = true; 187453f9fcb2SZhiPeng Lu } 187553f9fcb2SZhiPeng Lu } 18763424fc9fSMichal Privoznik } 18773424fc9fSMichal Privoznik 18783424fc9fSMichal Privoznik freeifaddrs(ifap); 18793424fc9fSMichal Privoznik return head; 18803424fc9fSMichal Privoznik 18813424fc9fSMichal Privoznik error: 18823424fc9fSMichal Privoznik freeifaddrs(ifap); 18833424fc9fSMichal Privoznik qapi_free_GuestNetworkInterfaceList(head); 18843424fc9fSMichal Privoznik return NULL; 18853424fc9fSMichal Privoznik } 18863424fc9fSMichal Privoznik 188777dbc81bSMarkus Armbruster #define SYSCONF_EXACT(name, errp) sysconf_exact((name), #name, (errp)) 1888d2baff62SLaszlo Ersek 188977dbc81bSMarkus Armbruster static long sysconf_exact(int name, const char *name_str, Error **errp) 1890d2baff62SLaszlo Ersek { 1891d2baff62SLaszlo Ersek long ret; 1892d2baff62SLaszlo Ersek 1893d2baff62SLaszlo Ersek errno = 0; 1894d2baff62SLaszlo Ersek ret = sysconf(name); 1895d2baff62SLaszlo Ersek if (ret == -1) { 1896d2baff62SLaszlo Ersek if (errno == 0) { 189777dbc81bSMarkus Armbruster error_setg(errp, "sysconf(%s): value indefinite", name_str); 1898d2baff62SLaszlo Ersek } else { 189977dbc81bSMarkus Armbruster error_setg_errno(errp, errno, "sysconf(%s)", name_str); 1900d2baff62SLaszlo Ersek } 1901d2baff62SLaszlo Ersek } 1902d2baff62SLaszlo Ersek return ret; 1903d2baff62SLaszlo Ersek } 1904d2baff62SLaszlo Ersek 1905d2baff62SLaszlo Ersek /* Transfer online/offline status between @vcpu and the guest system. 1906d2baff62SLaszlo Ersek * 1907d2baff62SLaszlo Ersek * On input either @errp or *@errp must be NULL. 1908d2baff62SLaszlo Ersek * 1909d2baff62SLaszlo Ersek * In system-to-@vcpu direction, the following @vcpu fields are accessed: 1910d2baff62SLaszlo Ersek * - R: vcpu->logical_id 1911d2baff62SLaszlo Ersek * - W: vcpu->online 1912d2baff62SLaszlo Ersek * - W: vcpu->can_offline 1913d2baff62SLaszlo Ersek * 1914d2baff62SLaszlo Ersek * In @vcpu-to-system direction, the following @vcpu fields are accessed: 1915d2baff62SLaszlo Ersek * - R: vcpu->logical_id 1916d2baff62SLaszlo Ersek * - R: vcpu->online 1917d2baff62SLaszlo Ersek * 1918d2baff62SLaszlo Ersek * Written members remain unmodified on error. 1919d2baff62SLaszlo Ersek */ 1920d2baff62SLaszlo Ersek static void transfer_vcpu(GuestLogicalProcessor *vcpu, bool sys2vcpu, 1921d2baff62SLaszlo Ersek Error **errp) 1922d2baff62SLaszlo Ersek { 1923d2baff62SLaszlo Ersek char *dirpath; 1924d2baff62SLaszlo Ersek int dirfd; 1925d2baff62SLaszlo Ersek 1926d2baff62SLaszlo Ersek dirpath = g_strdup_printf("/sys/devices/system/cpu/cpu%" PRId64 "/", 1927d2baff62SLaszlo Ersek vcpu->logical_id); 1928d2baff62SLaszlo Ersek dirfd = open(dirpath, O_RDONLY | O_DIRECTORY); 1929d2baff62SLaszlo Ersek if (dirfd == -1) { 1930d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "open(\"%s\")", dirpath); 1931d2baff62SLaszlo Ersek } else { 1932d2baff62SLaszlo Ersek static const char fn[] = "online"; 1933d2baff62SLaszlo Ersek int fd; 1934d2baff62SLaszlo Ersek int res; 1935d2baff62SLaszlo Ersek 1936d2baff62SLaszlo Ersek fd = openat(dirfd, fn, sys2vcpu ? O_RDONLY : O_RDWR); 1937d2baff62SLaszlo Ersek if (fd == -1) { 1938d2baff62SLaszlo Ersek if (errno != ENOENT) { 1939d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "open(\"%s/%s\")", dirpath, fn); 1940d2baff62SLaszlo Ersek } else if (sys2vcpu) { 1941d2baff62SLaszlo Ersek vcpu->online = true; 1942d2baff62SLaszlo Ersek vcpu->can_offline = false; 1943d2baff62SLaszlo Ersek } else if (!vcpu->online) { 1944d2baff62SLaszlo Ersek error_setg(errp, "logical processor #%" PRId64 " can't be " 1945d2baff62SLaszlo Ersek "offlined", vcpu->logical_id); 1946d2baff62SLaszlo Ersek } /* otherwise pretend successful re-onlining */ 1947d2baff62SLaszlo Ersek } else { 1948d2baff62SLaszlo Ersek unsigned char status; 1949d2baff62SLaszlo Ersek 1950d2baff62SLaszlo Ersek res = pread(fd, &status, 1, 0); 1951d2baff62SLaszlo Ersek if (res == -1) { 1952d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "pread(\"%s/%s\")", dirpath, fn); 1953d2baff62SLaszlo Ersek } else if (res == 0) { 1954d2baff62SLaszlo Ersek error_setg(errp, "pread(\"%s/%s\"): unexpected EOF", dirpath, 1955d2baff62SLaszlo Ersek fn); 1956d2baff62SLaszlo Ersek } else if (sys2vcpu) { 1957d2baff62SLaszlo Ersek vcpu->online = (status != '0'); 1958d2baff62SLaszlo Ersek vcpu->can_offline = true; 1959d2baff62SLaszlo Ersek } else if (vcpu->online != (status != '0')) { 1960d2baff62SLaszlo Ersek status = '0' + vcpu->online; 1961d2baff62SLaszlo Ersek if (pwrite(fd, &status, 1, 0) == -1) { 1962d2baff62SLaszlo Ersek error_setg_errno(errp, errno, "pwrite(\"%s/%s\")", dirpath, 1963d2baff62SLaszlo Ersek fn); 1964d2baff62SLaszlo Ersek } 1965d2baff62SLaszlo Ersek } /* otherwise pretend successful re-(on|off)-lining */ 1966d2baff62SLaszlo Ersek 1967d2baff62SLaszlo Ersek res = close(fd); 1968d2baff62SLaszlo Ersek g_assert(res == 0); 1969d2baff62SLaszlo Ersek } 1970d2baff62SLaszlo Ersek 1971d2baff62SLaszlo Ersek res = close(dirfd); 1972d2baff62SLaszlo Ersek g_assert(res == 0); 1973d2baff62SLaszlo Ersek } 1974d2baff62SLaszlo Ersek 1975d2baff62SLaszlo Ersek g_free(dirpath); 1976d2baff62SLaszlo Ersek } 1977d2baff62SLaszlo Ersek 1978d2baff62SLaszlo Ersek GuestLogicalProcessorList *qmp_guest_get_vcpus(Error **errp) 1979d2baff62SLaszlo Ersek { 1980d2baff62SLaszlo Ersek int64_t current; 1981d2baff62SLaszlo Ersek GuestLogicalProcessorList *head, **link; 1982d2baff62SLaszlo Ersek long sc_max; 1983d2baff62SLaszlo Ersek Error *local_err = NULL; 1984d2baff62SLaszlo Ersek 1985d2baff62SLaszlo Ersek current = 0; 1986d2baff62SLaszlo Ersek head = NULL; 1987d2baff62SLaszlo Ersek link = &head; 1988d2baff62SLaszlo Ersek sc_max = SYSCONF_EXACT(_SC_NPROCESSORS_CONF, &local_err); 1989d2baff62SLaszlo Ersek 1990d2baff62SLaszlo Ersek while (local_err == NULL && current < sc_max) { 1991d2baff62SLaszlo Ersek GuestLogicalProcessor *vcpu; 1992d2baff62SLaszlo Ersek GuestLogicalProcessorList *entry; 1993d2baff62SLaszlo Ersek 1994d2baff62SLaszlo Ersek vcpu = g_malloc0(sizeof *vcpu); 1995d2baff62SLaszlo Ersek vcpu->logical_id = current++; 1996d2baff62SLaszlo Ersek vcpu->has_can_offline = true; /* lolspeak ftw */ 1997d2baff62SLaszlo Ersek transfer_vcpu(vcpu, true, &local_err); 1998d2baff62SLaszlo Ersek 1999d2baff62SLaszlo Ersek entry = g_malloc0(sizeof *entry); 2000d2baff62SLaszlo Ersek entry->value = vcpu; 2001d2baff62SLaszlo Ersek 2002d2baff62SLaszlo Ersek *link = entry; 2003d2baff62SLaszlo Ersek link = &entry->next; 2004d2baff62SLaszlo Ersek } 2005d2baff62SLaszlo Ersek 2006d2baff62SLaszlo Ersek if (local_err == NULL) { 2007d2baff62SLaszlo Ersek /* there's no guest with zero VCPUs */ 2008d2baff62SLaszlo Ersek g_assert(head != NULL); 2009d2baff62SLaszlo Ersek return head; 2010d2baff62SLaszlo Ersek } 2011d2baff62SLaszlo Ersek 2012d2baff62SLaszlo Ersek qapi_free_GuestLogicalProcessorList(head); 2013d2baff62SLaszlo Ersek error_propagate(errp, local_err); 2014d2baff62SLaszlo Ersek return NULL; 2015d2baff62SLaszlo Ersek } 2016d2baff62SLaszlo Ersek 2017cbb65fc2SLaszlo Ersek int64_t qmp_guest_set_vcpus(GuestLogicalProcessorList *vcpus, Error **errp) 2018cbb65fc2SLaszlo Ersek { 2019cbb65fc2SLaszlo Ersek int64_t processed; 2020cbb65fc2SLaszlo Ersek Error *local_err = NULL; 2021cbb65fc2SLaszlo Ersek 2022cbb65fc2SLaszlo Ersek processed = 0; 2023cbb65fc2SLaszlo Ersek while (vcpus != NULL) { 2024cbb65fc2SLaszlo Ersek transfer_vcpu(vcpus->value, false, &local_err); 2025cbb65fc2SLaszlo Ersek if (local_err != NULL) { 2026cbb65fc2SLaszlo Ersek break; 2027cbb65fc2SLaszlo Ersek } 2028cbb65fc2SLaszlo Ersek ++processed; 2029cbb65fc2SLaszlo Ersek vcpus = vcpus->next; 2030cbb65fc2SLaszlo Ersek } 2031cbb65fc2SLaszlo Ersek 2032cbb65fc2SLaszlo Ersek if (local_err != NULL) { 2033cbb65fc2SLaszlo Ersek if (processed == 0) { 2034cbb65fc2SLaszlo Ersek error_propagate(errp, local_err); 2035cbb65fc2SLaszlo Ersek } else { 2036cbb65fc2SLaszlo Ersek error_free(local_err); 2037cbb65fc2SLaszlo Ersek } 2038cbb65fc2SLaszlo Ersek } 2039cbb65fc2SLaszlo Ersek 2040cbb65fc2SLaszlo Ersek return processed; 2041cbb65fc2SLaszlo Ersek } 2042cbb65fc2SLaszlo Ersek 2043215a2771SDaniel P. Berrange void qmp_guest_set_user_password(const char *username, 2044215a2771SDaniel P. Berrange const char *password, 2045215a2771SDaniel P. Berrange bool crypted, 2046215a2771SDaniel P. Berrange Error **errp) 2047215a2771SDaniel P. Berrange { 2048215a2771SDaniel P. Berrange Error *local_err = NULL; 2049215a2771SDaniel P. Berrange char *passwd_path = NULL; 2050215a2771SDaniel P. Berrange pid_t pid; 2051215a2771SDaniel P. Berrange int status; 2052215a2771SDaniel P. Berrange int datafd[2] = { -1, -1 }; 2053215a2771SDaniel P. Berrange char *rawpasswddata = NULL; 2054215a2771SDaniel P. Berrange size_t rawpasswdlen; 2055215a2771SDaniel P. Berrange char *chpasswddata = NULL; 2056215a2771SDaniel P. Berrange size_t chpasswdlen; 2057215a2771SDaniel P. Berrange 2058920639caSDaniel P. Berrange rawpasswddata = (char *)qbase64_decode(password, -1, &rawpasswdlen, errp); 2059920639caSDaniel P. Berrange if (!rawpasswddata) { 2060920639caSDaniel P. Berrange return; 2061920639caSDaniel P. Berrange } 2062215a2771SDaniel P. Berrange rawpasswddata = g_renew(char, rawpasswddata, rawpasswdlen + 1); 2063215a2771SDaniel P. Berrange rawpasswddata[rawpasswdlen] = '\0'; 2064215a2771SDaniel P. Berrange 2065215a2771SDaniel P. Berrange if (strchr(rawpasswddata, '\n')) { 2066215a2771SDaniel P. Berrange error_setg(errp, "forbidden characters in raw password"); 2067215a2771SDaniel P. Berrange goto out; 2068215a2771SDaniel P. Berrange } 2069215a2771SDaniel P. Berrange 2070215a2771SDaniel P. Berrange if (strchr(username, '\n') || 2071215a2771SDaniel P. Berrange strchr(username, ':')) { 2072215a2771SDaniel P. Berrange error_setg(errp, "forbidden characters in username"); 2073215a2771SDaniel P. Berrange goto out; 2074215a2771SDaniel P. Berrange } 2075215a2771SDaniel P. Berrange 2076215a2771SDaniel P. Berrange chpasswddata = g_strdup_printf("%s:%s\n", username, rawpasswddata); 2077215a2771SDaniel P. Berrange chpasswdlen = strlen(chpasswddata); 2078215a2771SDaniel P. Berrange 2079215a2771SDaniel P. Berrange passwd_path = g_find_program_in_path("chpasswd"); 2080215a2771SDaniel P. Berrange 2081215a2771SDaniel P. Berrange if (!passwd_path) { 2082215a2771SDaniel P. Berrange error_setg(errp, "cannot find 'passwd' program in PATH"); 2083215a2771SDaniel P. Berrange goto out; 2084215a2771SDaniel P. Berrange } 2085215a2771SDaniel P. Berrange 2086215a2771SDaniel P. Berrange if (pipe(datafd) < 0) { 2087215a2771SDaniel P. Berrange error_setg(errp, "cannot create pipe FDs"); 2088215a2771SDaniel P. Berrange goto out; 2089215a2771SDaniel P. Berrange } 2090215a2771SDaniel P. Berrange 2091215a2771SDaniel P. Berrange pid = fork(); 2092215a2771SDaniel P. Berrange if (pid == 0) { 2093215a2771SDaniel P. Berrange close(datafd[1]); 2094215a2771SDaniel P. Berrange /* child */ 2095215a2771SDaniel P. Berrange setsid(); 2096215a2771SDaniel P. Berrange dup2(datafd[0], 0); 2097215a2771SDaniel P. Berrange reopen_fd_to_null(1); 2098215a2771SDaniel P. Berrange reopen_fd_to_null(2); 2099215a2771SDaniel P. Berrange 2100215a2771SDaniel P. Berrange if (crypted) { 2101215a2771SDaniel P. Berrange execle(passwd_path, "chpasswd", "-e", NULL, environ); 2102215a2771SDaniel P. Berrange } else { 2103215a2771SDaniel P. Berrange execle(passwd_path, "chpasswd", NULL, environ); 2104215a2771SDaniel P. Berrange } 2105215a2771SDaniel P. Berrange _exit(EXIT_FAILURE); 2106215a2771SDaniel P. Berrange } else if (pid < 0) { 2107215a2771SDaniel P. Berrange error_setg_errno(errp, errno, "failed to create child process"); 2108215a2771SDaniel P. Berrange goto out; 2109215a2771SDaniel P. Berrange } 2110215a2771SDaniel P. Berrange close(datafd[0]); 2111215a2771SDaniel P. Berrange datafd[0] = -1; 2112215a2771SDaniel P. Berrange 2113215a2771SDaniel P. Berrange if (qemu_write_full(datafd[1], chpasswddata, chpasswdlen) != chpasswdlen) { 2114215a2771SDaniel P. Berrange error_setg_errno(errp, errno, "cannot write new account password"); 2115215a2771SDaniel P. Berrange goto out; 2116215a2771SDaniel P. Berrange } 2117215a2771SDaniel P. Berrange close(datafd[1]); 2118215a2771SDaniel P. Berrange datafd[1] = -1; 2119215a2771SDaniel P. Berrange 2120215a2771SDaniel P. Berrange ga_wait_child(pid, &status, &local_err); 2121215a2771SDaniel P. Berrange if (local_err) { 2122215a2771SDaniel P. Berrange error_propagate(errp, local_err); 2123215a2771SDaniel P. Berrange goto out; 2124215a2771SDaniel P. Berrange } 2125215a2771SDaniel P. Berrange 2126215a2771SDaniel P. Berrange if (!WIFEXITED(status)) { 2127215a2771SDaniel P. Berrange error_setg(errp, "child process has terminated abnormally"); 2128215a2771SDaniel P. Berrange goto out; 2129215a2771SDaniel P. Berrange } 2130215a2771SDaniel P. Berrange 2131215a2771SDaniel P. Berrange if (WEXITSTATUS(status)) { 2132215a2771SDaniel P. Berrange error_setg(errp, "child process has failed to set user password"); 2133215a2771SDaniel P. Berrange goto out; 2134215a2771SDaniel P. Berrange } 2135215a2771SDaniel P. Berrange 2136215a2771SDaniel P. Berrange out: 2137215a2771SDaniel P. Berrange g_free(chpasswddata); 2138215a2771SDaniel P. Berrange g_free(rawpasswddata); 2139215a2771SDaniel P. Berrange g_free(passwd_path); 2140215a2771SDaniel P. Berrange if (datafd[0] != -1) { 2141215a2771SDaniel P. Berrange close(datafd[0]); 2142215a2771SDaniel P. Berrange } 2143215a2771SDaniel P. Berrange if (datafd[1] != -1) { 2144215a2771SDaniel P. Berrange close(datafd[1]); 2145215a2771SDaniel P. Berrange } 2146215a2771SDaniel P. Berrange } 2147215a2771SDaniel P. Berrange 2148bd240fcaSzhanghailiang static void ga_read_sysfs_file(int dirfd, const char *pathname, char *buf, 2149bd240fcaSzhanghailiang int size, Error **errp) 2150bd240fcaSzhanghailiang { 2151bd240fcaSzhanghailiang int fd; 2152bd240fcaSzhanghailiang int res; 2153bd240fcaSzhanghailiang 2154bd240fcaSzhanghailiang errno = 0; 2155bd240fcaSzhanghailiang fd = openat(dirfd, pathname, O_RDONLY); 2156bd240fcaSzhanghailiang if (fd == -1) { 2157bd240fcaSzhanghailiang error_setg_errno(errp, errno, "open sysfs file \"%s\"", pathname); 2158bd240fcaSzhanghailiang return; 2159bd240fcaSzhanghailiang } 2160bd240fcaSzhanghailiang 2161bd240fcaSzhanghailiang res = pread(fd, buf, size, 0); 2162bd240fcaSzhanghailiang if (res == -1) { 2163bd240fcaSzhanghailiang error_setg_errno(errp, errno, "pread sysfs file \"%s\"", pathname); 2164bd240fcaSzhanghailiang } else if (res == 0) { 2165bd240fcaSzhanghailiang error_setg(errp, "pread sysfs file \"%s\": unexpected EOF", pathname); 2166bd240fcaSzhanghailiang } 2167bd240fcaSzhanghailiang close(fd); 2168bd240fcaSzhanghailiang } 2169bd240fcaSzhanghailiang 2170bd240fcaSzhanghailiang static void ga_write_sysfs_file(int dirfd, const char *pathname, 2171bd240fcaSzhanghailiang const char *buf, int size, Error **errp) 2172bd240fcaSzhanghailiang { 2173bd240fcaSzhanghailiang int fd; 2174bd240fcaSzhanghailiang 2175bd240fcaSzhanghailiang errno = 0; 2176bd240fcaSzhanghailiang fd = openat(dirfd, pathname, O_WRONLY); 2177bd240fcaSzhanghailiang if (fd == -1) { 2178bd240fcaSzhanghailiang error_setg_errno(errp, errno, "open sysfs file \"%s\"", pathname); 2179bd240fcaSzhanghailiang return; 2180bd240fcaSzhanghailiang } 2181bd240fcaSzhanghailiang 2182bd240fcaSzhanghailiang if (pwrite(fd, buf, size, 0) == -1) { 2183bd240fcaSzhanghailiang error_setg_errno(errp, errno, "pwrite sysfs file \"%s\"", pathname); 2184bd240fcaSzhanghailiang } 2185bd240fcaSzhanghailiang 2186bd240fcaSzhanghailiang close(fd); 2187bd240fcaSzhanghailiang } 2188bd240fcaSzhanghailiang 2189bd240fcaSzhanghailiang /* Transfer online/offline status between @mem_blk and the guest system. 2190bd240fcaSzhanghailiang * 2191bd240fcaSzhanghailiang * On input either @errp or *@errp must be NULL. 2192bd240fcaSzhanghailiang * 2193bd240fcaSzhanghailiang * In system-to-@mem_blk direction, the following @mem_blk fields are accessed: 2194bd240fcaSzhanghailiang * - R: mem_blk->phys_index 2195bd240fcaSzhanghailiang * - W: mem_blk->online 2196bd240fcaSzhanghailiang * - W: mem_blk->can_offline 2197bd240fcaSzhanghailiang * 2198bd240fcaSzhanghailiang * In @mem_blk-to-system direction, the following @mem_blk fields are accessed: 2199bd240fcaSzhanghailiang * - R: mem_blk->phys_index 2200bd240fcaSzhanghailiang * - R: mem_blk->online 2201bd240fcaSzhanghailiang *- R: mem_blk->can_offline 2202bd240fcaSzhanghailiang * Written members remain unmodified on error. 2203bd240fcaSzhanghailiang */ 2204bd240fcaSzhanghailiang static void transfer_memory_block(GuestMemoryBlock *mem_blk, bool sys2memblk, 2205bd240fcaSzhanghailiang GuestMemoryBlockResponse *result, 2206bd240fcaSzhanghailiang Error **errp) 2207bd240fcaSzhanghailiang { 2208bd240fcaSzhanghailiang char *dirpath; 2209bd240fcaSzhanghailiang int dirfd; 2210bd240fcaSzhanghailiang char *status; 2211bd240fcaSzhanghailiang Error *local_err = NULL; 2212bd240fcaSzhanghailiang 2213bd240fcaSzhanghailiang if (!sys2memblk) { 2214bd240fcaSzhanghailiang DIR *dp; 2215bd240fcaSzhanghailiang 2216bd240fcaSzhanghailiang if (!result) { 2217bd240fcaSzhanghailiang error_setg(errp, "Internal error, 'result' should not be NULL"); 2218bd240fcaSzhanghailiang return; 2219bd240fcaSzhanghailiang } 2220bd240fcaSzhanghailiang errno = 0; 2221bd240fcaSzhanghailiang dp = opendir("/sys/devices/system/memory/"); 2222bd240fcaSzhanghailiang /* if there is no 'memory' directory in sysfs, 2223bd240fcaSzhanghailiang * we think this VM does not support online/offline memory block, 2224bd240fcaSzhanghailiang * any other solution? 2225bd240fcaSzhanghailiang */ 22269879f5acSPhilippe Mathieu-Daudé if (!dp) { 22279879f5acSPhilippe Mathieu-Daudé if (errno == ENOENT) { 2228bd240fcaSzhanghailiang result->response = 2229bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_NOT_SUPPORTED; 22309879f5acSPhilippe Mathieu-Daudé } 2231bd240fcaSzhanghailiang goto out1; 2232bd240fcaSzhanghailiang } 2233bd240fcaSzhanghailiang closedir(dp); 2234bd240fcaSzhanghailiang } 2235bd240fcaSzhanghailiang 2236bd240fcaSzhanghailiang dirpath = g_strdup_printf("/sys/devices/system/memory/memory%" PRId64 "/", 2237bd240fcaSzhanghailiang mem_blk->phys_index); 2238bd240fcaSzhanghailiang dirfd = open(dirpath, O_RDONLY | O_DIRECTORY); 2239bd240fcaSzhanghailiang if (dirfd == -1) { 2240bd240fcaSzhanghailiang if (sys2memblk) { 2241bd240fcaSzhanghailiang error_setg_errno(errp, errno, "open(\"%s\")", dirpath); 2242bd240fcaSzhanghailiang } else { 2243bd240fcaSzhanghailiang if (errno == ENOENT) { 2244bd240fcaSzhanghailiang result->response = GUEST_MEMORY_BLOCK_RESPONSE_TYPE_NOT_FOUND; 2245bd240fcaSzhanghailiang } else { 2246bd240fcaSzhanghailiang result->response = 2247bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_FAILED; 2248bd240fcaSzhanghailiang } 2249bd240fcaSzhanghailiang } 2250bd240fcaSzhanghailiang g_free(dirpath); 2251bd240fcaSzhanghailiang goto out1; 2252bd240fcaSzhanghailiang } 2253bd240fcaSzhanghailiang g_free(dirpath); 2254bd240fcaSzhanghailiang 2255bd240fcaSzhanghailiang status = g_malloc0(10); 2256bd240fcaSzhanghailiang ga_read_sysfs_file(dirfd, "state", status, 10, &local_err); 2257bd240fcaSzhanghailiang if (local_err) { 2258bd240fcaSzhanghailiang /* treat with sysfs file that not exist in old kernel */ 2259bd240fcaSzhanghailiang if (errno == ENOENT) { 2260bd240fcaSzhanghailiang error_free(local_err); 2261bd240fcaSzhanghailiang if (sys2memblk) { 2262bd240fcaSzhanghailiang mem_blk->online = true; 2263bd240fcaSzhanghailiang mem_blk->can_offline = false; 2264bd240fcaSzhanghailiang } else if (!mem_blk->online) { 2265bd240fcaSzhanghailiang result->response = 2266bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_NOT_SUPPORTED; 2267bd240fcaSzhanghailiang } 2268bd240fcaSzhanghailiang } else { 2269bd240fcaSzhanghailiang if (sys2memblk) { 2270bd240fcaSzhanghailiang error_propagate(errp, local_err); 2271bd240fcaSzhanghailiang } else { 2272bd240fcaSzhanghailiang result->response = 2273bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_FAILED; 2274bd240fcaSzhanghailiang } 2275bd240fcaSzhanghailiang } 2276bd240fcaSzhanghailiang goto out2; 2277bd240fcaSzhanghailiang } 2278bd240fcaSzhanghailiang 2279bd240fcaSzhanghailiang if (sys2memblk) { 2280bd240fcaSzhanghailiang char removable = '0'; 2281bd240fcaSzhanghailiang 2282bd240fcaSzhanghailiang mem_blk->online = (strncmp(status, "online", 6) == 0); 2283bd240fcaSzhanghailiang 2284bd240fcaSzhanghailiang ga_read_sysfs_file(dirfd, "removable", &removable, 1, &local_err); 2285bd240fcaSzhanghailiang if (local_err) { 228667cc32ebSVeres Lajos /* if no 'removable' file, it doesn't support offline mem blk */ 2287bd240fcaSzhanghailiang if (errno == ENOENT) { 2288bd240fcaSzhanghailiang error_free(local_err); 2289bd240fcaSzhanghailiang mem_blk->can_offline = false; 2290bd240fcaSzhanghailiang } else { 2291bd240fcaSzhanghailiang error_propagate(errp, local_err); 2292bd240fcaSzhanghailiang } 2293bd240fcaSzhanghailiang } else { 2294bd240fcaSzhanghailiang mem_blk->can_offline = (removable != '0'); 2295bd240fcaSzhanghailiang } 2296bd240fcaSzhanghailiang } else { 2297bd240fcaSzhanghailiang if (mem_blk->online != (strncmp(status, "online", 6) == 0)) { 22987064024dSMarc-André Lureau const char *new_state = mem_blk->online ? "online" : "offline"; 2299bd240fcaSzhanghailiang 2300bd240fcaSzhanghailiang ga_write_sysfs_file(dirfd, "state", new_state, strlen(new_state), 2301bd240fcaSzhanghailiang &local_err); 2302bd240fcaSzhanghailiang if (local_err) { 2303bd240fcaSzhanghailiang error_free(local_err); 2304bd240fcaSzhanghailiang result->response = 2305bd240fcaSzhanghailiang GUEST_MEMORY_BLOCK_RESPONSE_TYPE_OPERATION_FAILED; 2306bd240fcaSzhanghailiang goto out2; 2307bd240fcaSzhanghailiang } 2308bd240fcaSzhanghailiang 2309bd240fcaSzhanghailiang result->response = GUEST_MEMORY_BLOCK_RESPONSE_TYPE_SUCCESS; 2310bd240fcaSzhanghailiang result->has_error_code = false; 2311bd240fcaSzhanghailiang } /* otherwise pretend successful re-(on|off)-lining */ 2312bd240fcaSzhanghailiang } 2313bd240fcaSzhanghailiang g_free(status); 2314bd240fcaSzhanghailiang close(dirfd); 2315bd240fcaSzhanghailiang return; 2316bd240fcaSzhanghailiang 2317bd240fcaSzhanghailiang out2: 2318bd240fcaSzhanghailiang g_free(status); 2319bd240fcaSzhanghailiang close(dirfd); 2320bd240fcaSzhanghailiang out1: 2321bd240fcaSzhanghailiang if (!sys2memblk) { 2322bd240fcaSzhanghailiang result->has_error_code = true; 2323bd240fcaSzhanghailiang result->error_code = errno; 2324bd240fcaSzhanghailiang } 2325bd240fcaSzhanghailiang } 2326bd240fcaSzhanghailiang 2327a065aaa9Szhanghailiang GuestMemoryBlockList *qmp_guest_get_memory_blocks(Error **errp) 2328a065aaa9Szhanghailiang { 2329bd240fcaSzhanghailiang GuestMemoryBlockList *head, **link; 2330bd240fcaSzhanghailiang Error *local_err = NULL; 2331bd240fcaSzhanghailiang struct dirent *de; 2332bd240fcaSzhanghailiang DIR *dp; 2333bd240fcaSzhanghailiang 2334bd240fcaSzhanghailiang head = NULL; 2335bd240fcaSzhanghailiang link = &head; 2336bd240fcaSzhanghailiang 2337bd240fcaSzhanghailiang dp = opendir("/sys/devices/system/memory/"); 2338bd240fcaSzhanghailiang if (!dp) { 2339f693fe6eSMichael Roth /* it's ok if this happens to be a system that doesn't expose 2340f693fe6eSMichael Roth * memory blocks via sysfs, but otherwise we should report 2341f693fe6eSMichael Roth * an error 2342f693fe6eSMichael Roth */ 2343f693fe6eSMichael Roth if (errno != ENOENT) { 2344bd240fcaSzhanghailiang error_setg_errno(errp, errno, "Can't open directory" 23459af9e0feSMarkus Armbruster "\"/sys/devices/system/memory/\""); 2346f693fe6eSMichael Roth } 2347bd240fcaSzhanghailiang return NULL; 2348bd240fcaSzhanghailiang } 2349bd240fcaSzhanghailiang 2350bd240fcaSzhanghailiang /* Note: the phys_index of memory block may be discontinuous, 2351bd240fcaSzhanghailiang * this is because a memblk is the unit of the Sparse Memory design, which 2352bd240fcaSzhanghailiang * allows discontinuous memory ranges (ex. NUMA), so here we should 2353bd240fcaSzhanghailiang * traverse the memory block directory. 2354bd240fcaSzhanghailiang */ 2355bd240fcaSzhanghailiang while ((de = readdir(dp)) != NULL) { 2356bd240fcaSzhanghailiang GuestMemoryBlock *mem_blk; 2357bd240fcaSzhanghailiang GuestMemoryBlockList *entry; 2358bd240fcaSzhanghailiang 2359bd240fcaSzhanghailiang if ((strncmp(de->d_name, "memory", 6) != 0) || 2360bd240fcaSzhanghailiang !(de->d_type & DT_DIR)) { 2361bd240fcaSzhanghailiang continue; 2362bd240fcaSzhanghailiang } 2363bd240fcaSzhanghailiang 2364bd240fcaSzhanghailiang mem_blk = g_malloc0(sizeof *mem_blk); 2365bd240fcaSzhanghailiang /* The d_name is "memoryXXX", phys_index is block id, same as XXX */ 2366bd240fcaSzhanghailiang mem_blk->phys_index = strtoul(&de->d_name[6], NULL, 10); 2367bd240fcaSzhanghailiang mem_blk->has_can_offline = true; /* lolspeak ftw */ 2368bd240fcaSzhanghailiang transfer_memory_block(mem_blk, true, NULL, &local_err); 2369bd240fcaSzhanghailiang 2370bd240fcaSzhanghailiang entry = g_malloc0(sizeof *entry); 2371bd240fcaSzhanghailiang entry->value = mem_blk; 2372bd240fcaSzhanghailiang 2373bd240fcaSzhanghailiang *link = entry; 2374bd240fcaSzhanghailiang link = &entry->next; 2375bd240fcaSzhanghailiang } 2376bd240fcaSzhanghailiang 2377bd240fcaSzhanghailiang closedir(dp); 2378bd240fcaSzhanghailiang if (local_err == NULL) { 2379bd240fcaSzhanghailiang /* there's no guest with zero memory blocks */ 2380bd240fcaSzhanghailiang if (head == NULL) { 2381bd240fcaSzhanghailiang error_setg(errp, "guest reported zero memory blocks!"); 2382bd240fcaSzhanghailiang } 2383bd240fcaSzhanghailiang return head; 2384bd240fcaSzhanghailiang } 2385bd240fcaSzhanghailiang 2386bd240fcaSzhanghailiang qapi_free_GuestMemoryBlockList(head); 2387bd240fcaSzhanghailiang error_propagate(errp, local_err); 2388a065aaa9Szhanghailiang return NULL; 2389a065aaa9Szhanghailiang } 2390a065aaa9Szhanghailiang 2391a065aaa9Szhanghailiang GuestMemoryBlockResponseList * 2392a065aaa9Szhanghailiang qmp_guest_set_memory_blocks(GuestMemoryBlockList *mem_blks, Error **errp) 2393a065aaa9Szhanghailiang { 239432ca7927Szhanghailiang GuestMemoryBlockResponseList *head, **link; 239532ca7927Szhanghailiang Error *local_err = NULL; 239632ca7927Szhanghailiang 239732ca7927Szhanghailiang head = NULL; 239832ca7927Szhanghailiang link = &head; 239932ca7927Szhanghailiang 240032ca7927Szhanghailiang while (mem_blks != NULL) { 240132ca7927Szhanghailiang GuestMemoryBlockResponse *result; 240232ca7927Szhanghailiang GuestMemoryBlockResponseList *entry; 240332ca7927Szhanghailiang GuestMemoryBlock *current_mem_blk = mem_blks->value; 240432ca7927Szhanghailiang 240532ca7927Szhanghailiang result = g_malloc0(sizeof(*result)); 240632ca7927Szhanghailiang result->phys_index = current_mem_blk->phys_index; 240732ca7927Szhanghailiang transfer_memory_block(current_mem_blk, false, result, &local_err); 240832ca7927Szhanghailiang if (local_err) { /* should never happen */ 240932ca7927Szhanghailiang goto err; 241032ca7927Szhanghailiang } 241132ca7927Szhanghailiang entry = g_malloc0(sizeof *entry); 241232ca7927Szhanghailiang entry->value = result; 241332ca7927Szhanghailiang 241432ca7927Szhanghailiang *link = entry; 241532ca7927Szhanghailiang link = &entry->next; 241632ca7927Szhanghailiang mem_blks = mem_blks->next; 241732ca7927Szhanghailiang } 241832ca7927Szhanghailiang 241932ca7927Szhanghailiang return head; 242032ca7927Szhanghailiang err: 242132ca7927Szhanghailiang qapi_free_GuestMemoryBlockResponseList(head); 242232ca7927Szhanghailiang error_propagate(errp, local_err); 2423a065aaa9Szhanghailiang return NULL; 2424a065aaa9Szhanghailiang } 2425a065aaa9Szhanghailiang 2426a065aaa9Szhanghailiang GuestMemoryBlockInfo *qmp_guest_get_memory_block_info(Error **errp) 2427a065aaa9Szhanghailiang { 2428ef82b60bSzhanghailiang Error *local_err = NULL; 2429ef82b60bSzhanghailiang char *dirpath; 2430ef82b60bSzhanghailiang int dirfd; 2431ef82b60bSzhanghailiang char *buf; 2432ef82b60bSzhanghailiang GuestMemoryBlockInfo *info; 2433ef82b60bSzhanghailiang 2434ef82b60bSzhanghailiang dirpath = g_strdup_printf("/sys/devices/system/memory/"); 2435ef82b60bSzhanghailiang dirfd = open(dirpath, O_RDONLY | O_DIRECTORY); 2436ef82b60bSzhanghailiang if (dirfd == -1) { 2437ef82b60bSzhanghailiang error_setg_errno(errp, errno, "open(\"%s\")", dirpath); 2438ef82b60bSzhanghailiang g_free(dirpath); 2439a065aaa9Szhanghailiang return NULL; 2440a065aaa9Szhanghailiang } 2441ef82b60bSzhanghailiang g_free(dirpath); 2442ef82b60bSzhanghailiang 2443ef82b60bSzhanghailiang buf = g_malloc0(20); 2444ef82b60bSzhanghailiang ga_read_sysfs_file(dirfd, "block_size_bytes", buf, 20, &local_err); 24458ce1ee46SShannon Zhao close(dirfd); 2446ef82b60bSzhanghailiang if (local_err) { 2447ef82b60bSzhanghailiang g_free(buf); 2448ef82b60bSzhanghailiang error_propagate(errp, local_err); 2449ef82b60bSzhanghailiang return NULL; 2450ef82b60bSzhanghailiang } 2451ef82b60bSzhanghailiang 2452ef82b60bSzhanghailiang info = g_new0(GuestMemoryBlockInfo, 1); 2453ef82b60bSzhanghailiang info->size = strtol(buf, NULL, 16); /* the unit is bytes */ 2454ef82b60bSzhanghailiang 2455ef82b60bSzhanghailiang g_free(buf); 2456ef82b60bSzhanghailiang 2457ef82b60bSzhanghailiang return info; 2458ef82b60bSzhanghailiang } 2459a065aaa9Szhanghailiang 2460e72c3f2eSMichael Roth #else /* defined(__linux__) */ 2461e72c3f2eSMichael Roth 246277dbc81bSMarkus Armbruster void qmp_guest_suspend_disk(Error **errp) 2463e72c3f2eSMichael Roth { 2464c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2465e72c3f2eSMichael Roth } 2466e72c3f2eSMichael Roth 246777dbc81bSMarkus Armbruster void qmp_guest_suspend_ram(Error **errp) 2468e72c3f2eSMichael Roth { 2469c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2470e72c3f2eSMichael Roth } 2471e72c3f2eSMichael Roth 247277dbc81bSMarkus Armbruster void qmp_guest_suspend_hybrid(Error **errp) 2473e72c3f2eSMichael Roth { 2474c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2475e72c3f2eSMichael Roth } 2476e72c3f2eSMichael Roth 2477e72c3f2eSMichael Roth GuestNetworkInterfaceList *qmp_guest_network_get_interfaces(Error **errp) 2478e72c3f2eSMichael Roth { 2479c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2480e72c3f2eSMichael Roth return NULL; 2481e72c3f2eSMichael Roth } 2482e72c3f2eSMichael Roth 2483d2baff62SLaszlo Ersek GuestLogicalProcessorList *qmp_guest_get_vcpus(Error **errp) 2484d2baff62SLaszlo Ersek { 2485c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2486d2baff62SLaszlo Ersek return NULL; 2487d2baff62SLaszlo Ersek } 2488d2baff62SLaszlo Ersek 2489cbb65fc2SLaszlo Ersek int64_t qmp_guest_set_vcpus(GuestLogicalProcessorList *vcpus, Error **errp) 2490cbb65fc2SLaszlo Ersek { 2491c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2492cbb65fc2SLaszlo Ersek return -1; 2493cbb65fc2SLaszlo Ersek } 2494cbb65fc2SLaszlo Ersek 2495215a2771SDaniel P. Berrange void qmp_guest_set_user_password(const char *username, 2496215a2771SDaniel P. Berrange const char *password, 2497215a2771SDaniel P. Berrange bool crypted, 2498215a2771SDaniel P. Berrange Error **errp) 2499215a2771SDaniel P. Berrange { 2500c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2501215a2771SDaniel P. Berrange } 2502215a2771SDaniel P. Berrange 2503a065aaa9Szhanghailiang GuestMemoryBlockList *qmp_guest_get_memory_blocks(Error **errp) 2504a065aaa9Szhanghailiang { 2505c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2506a065aaa9Szhanghailiang return NULL; 2507a065aaa9Szhanghailiang } 2508a065aaa9Szhanghailiang 2509a065aaa9Szhanghailiang GuestMemoryBlockResponseList * 2510a065aaa9Szhanghailiang qmp_guest_set_memory_blocks(GuestMemoryBlockList *mem_blks, Error **errp) 2511a065aaa9Szhanghailiang { 2512c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2513a065aaa9Szhanghailiang return NULL; 2514a065aaa9Szhanghailiang } 2515a065aaa9Szhanghailiang 2516a065aaa9Szhanghailiang GuestMemoryBlockInfo *qmp_guest_get_memory_block_info(Error **errp) 2517a065aaa9Szhanghailiang { 2518c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2519a065aaa9Szhanghailiang return NULL; 2520a065aaa9Szhanghailiang } 2521a065aaa9Szhanghailiang 2522e72c3f2eSMichael Roth #endif 2523e72c3f2eSMichael Roth 2524d35d4cb5SMichael Roth #if !defined(CONFIG_FSFREEZE) 2525d35d4cb5SMichael Roth 252646d4c572STomoki Sekiyama GuestFilesystemInfoList *qmp_guest_get_fsinfo(Error **errp) 252746d4c572STomoki Sekiyama { 2528c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 252946d4c572STomoki Sekiyama return NULL; 253046d4c572STomoki Sekiyama } 253146d4c572STomoki Sekiyama 253277dbc81bSMarkus Armbruster GuestFsfreezeStatus qmp_guest_fsfreeze_status(Error **errp) 2533d35d4cb5SMichael Roth { 2534c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2535d35d4cb5SMichael Roth 2536d35d4cb5SMichael Roth return 0; 2537d35d4cb5SMichael Roth } 2538d35d4cb5SMichael Roth 253977dbc81bSMarkus Armbruster int64_t qmp_guest_fsfreeze_freeze(Error **errp) 2540d35d4cb5SMichael Roth { 2541c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2542d35d4cb5SMichael Roth 2543d35d4cb5SMichael Roth return 0; 2544d35d4cb5SMichael Roth } 2545d35d4cb5SMichael Roth 2546e99bce20STomoki Sekiyama int64_t qmp_guest_fsfreeze_freeze_list(bool has_mountpoints, 2547e99bce20STomoki Sekiyama strList *mountpoints, 2548e99bce20STomoki Sekiyama Error **errp) 2549e99bce20STomoki Sekiyama { 2550c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2551e99bce20STomoki Sekiyama 2552e99bce20STomoki Sekiyama return 0; 2553e99bce20STomoki Sekiyama } 2554e99bce20STomoki Sekiyama 255577dbc81bSMarkus Armbruster int64_t qmp_guest_fsfreeze_thaw(Error **errp) 2556d35d4cb5SMichael Roth { 2557c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2558d35d4cb5SMichael Roth 2559d35d4cb5SMichael Roth return 0; 2560d35d4cb5SMichael Roth } 2561eab5fd59SPaolo Bonzini #endif /* CONFIG_FSFREEZE */ 2562d35d4cb5SMichael Roth 2563eab5fd59SPaolo Bonzini #if !defined(CONFIG_FSTRIM) 2564e82855d9SJustin Ossevoort GuestFilesystemTrimResponse * 2565e82855d9SJustin Ossevoort qmp_guest_fstrim(bool has_minimum, int64_t minimum, Error **errp) 2566eab5fd59SPaolo Bonzini { 2567c6bd8c70SMarkus Armbruster error_setg(errp, QERR_UNSUPPORTED); 2568e82855d9SJustin Ossevoort return NULL; 2569eab5fd59SPaolo Bonzini } 2570d35d4cb5SMichael Roth #endif 2571d35d4cb5SMichael Roth 25721281c08aSTomoki Sekiyama /* add unsupported commands to the blacklist */ 25731281c08aSTomoki Sekiyama GList *ga_command_blacklist_init(GList *blacklist) 25741281c08aSTomoki Sekiyama { 25751281c08aSTomoki Sekiyama #if !defined(__linux__) 25761281c08aSTomoki Sekiyama { 25771281c08aSTomoki Sekiyama const char *list[] = { 25781281c08aSTomoki Sekiyama "guest-suspend-disk", "guest-suspend-ram", 25791281c08aSTomoki Sekiyama "guest-suspend-hybrid", "guest-network-get-interfaces", 25800dd38a03Szhanghailiang "guest-get-vcpus", "guest-set-vcpus", 25810dd38a03Szhanghailiang "guest-get-memory-blocks", "guest-set-memory-blocks", 25820dd38a03Szhanghailiang "guest-get-memory-block-size", NULL}; 25831281c08aSTomoki Sekiyama char **p = (char **)list; 25841281c08aSTomoki Sekiyama 25851281c08aSTomoki Sekiyama while (*p) { 25864bca81ceSMarc-André Lureau blacklist = g_list_append(blacklist, g_strdup(*p++)); 25871281c08aSTomoki Sekiyama } 25881281c08aSTomoki Sekiyama } 25891281c08aSTomoki Sekiyama #endif 25901281c08aSTomoki Sekiyama 25911281c08aSTomoki Sekiyama #if !defined(CONFIG_FSFREEZE) 25921281c08aSTomoki Sekiyama { 25931281c08aSTomoki Sekiyama const char *list[] = { 25941281c08aSTomoki Sekiyama "guest-get-fsinfo", "guest-fsfreeze-status", 25951281c08aSTomoki Sekiyama "guest-fsfreeze-freeze", "guest-fsfreeze-freeze-list", 25961281c08aSTomoki Sekiyama "guest-fsfreeze-thaw", "guest-get-fsinfo", NULL}; 25971281c08aSTomoki Sekiyama char **p = (char **)list; 25981281c08aSTomoki Sekiyama 25991281c08aSTomoki Sekiyama while (*p) { 26004bca81ceSMarc-André Lureau blacklist = g_list_append(blacklist, g_strdup(*p++)); 26011281c08aSTomoki Sekiyama } 26021281c08aSTomoki Sekiyama } 26031281c08aSTomoki Sekiyama #endif 26041281c08aSTomoki Sekiyama 26051281c08aSTomoki Sekiyama #if !defined(CONFIG_FSTRIM) 26064bca81ceSMarc-André Lureau blacklist = g_list_append(blacklist, g_strdup("guest-fstrim")); 26071281c08aSTomoki Sekiyama #endif 26081281c08aSTomoki Sekiyama 26091281c08aSTomoki Sekiyama return blacklist; 26101281c08aSTomoki Sekiyama } 26111281c08aSTomoki Sekiyama 2612c216e5adSMichael Roth /* register init/cleanup routines for stateful command groups */ 2613c216e5adSMichael Roth void ga_command_state_init(GAState *s, GACommandState *cs) 2614c216e5adSMichael Roth { 2615c216e5adSMichael Roth #if defined(CONFIG_FSFREEZE) 2616f22d85e9SMichael Roth ga_command_state_add(cs, NULL, guest_fsfreeze_cleanup); 2617c216e5adSMichael Roth #endif 2618c216e5adSMichael Roth } 2619161a56a9SVinzenz Feenstra 2620e674605fSTomáš Golembiovský #ifdef HAVE_UTMPX 2621e674605fSTomáš Golembiovský 2622161a56a9SVinzenz Feenstra #define QGA_MICRO_SECOND_TO_SECOND 1000000 2623161a56a9SVinzenz Feenstra 2624161a56a9SVinzenz Feenstra static double ga_get_login_time(struct utmpx *user_info) 2625161a56a9SVinzenz Feenstra { 2626161a56a9SVinzenz Feenstra double seconds = (double)user_info->ut_tv.tv_sec; 2627161a56a9SVinzenz Feenstra double useconds = (double)user_info->ut_tv.tv_usec; 2628161a56a9SVinzenz Feenstra useconds /= QGA_MICRO_SECOND_TO_SECOND; 2629161a56a9SVinzenz Feenstra return seconds + useconds; 2630161a56a9SVinzenz Feenstra } 2631161a56a9SVinzenz Feenstra 2632161a56a9SVinzenz Feenstra GuestUserList *qmp_guest_get_users(Error **err) 2633161a56a9SVinzenz Feenstra { 2634161a56a9SVinzenz Feenstra GHashTable *cache = NULL; 2635161a56a9SVinzenz Feenstra GuestUserList *head = NULL, *cur_item = NULL; 2636161a56a9SVinzenz Feenstra struct utmpx *user_info = NULL; 2637161a56a9SVinzenz Feenstra gpointer value = NULL; 2638161a56a9SVinzenz Feenstra GuestUser *user = NULL; 2639161a56a9SVinzenz Feenstra GuestUserList *item = NULL; 2640161a56a9SVinzenz Feenstra double login_time = 0; 2641161a56a9SVinzenz Feenstra 2642161a56a9SVinzenz Feenstra cache = g_hash_table_new(g_str_hash, g_str_equal); 2643161a56a9SVinzenz Feenstra setutxent(); 2644161a56a9SVinzenz Feenstra 2645161a56a9SVinzenz Feenstra for (;;) { 2646161a56a9SVinzenz Feenstra user_info = getutxent(); 2647161a56a9SVinzenz Feenstra if (user_info == NULL) { 2648161a56a9SVinzenz Feenstra break; 2649161a56a9SVinzenz Feenstra } else if (user_info->ut_type != USER_PROCESS) { 2650161a56a9SVinzenz Feenstra continue; 2651161a56a9SVinzenz Feenstra } else if (g_hash_table_contains(cache, user_info->ut_user)) { 2652161a56a9SVinzenz Feenstra value = g_hash_table_lookup(cache, user_info->ut_user); 2653161a56a9SVinzenz Feenstra user = (GuestUser *)value; 2654161a56a9SVinzenz Feenstra login_time = ga_get_login_time(user_info); 2655161a56a9SVinzenz Feenstra /* We're ensuring the earliest login time to be sent */ 2656161a56a9SVinzenz Feenstra if (login_time < user->login_time) { 2657161a56a9SVinzenz Feenstra user->login_time = login_time; 2658161a56a9SVinzenz Feenstra } 2659161a56a9SVinzenz Feenstra continue; 2660161a56a9SVinzenz Feenstra } 2661161a56a9SVinzenz Feenstra 2662161a56a9SVinzenz Feenstra item = g_new0(GuestUserList, 1); 2663161a56a9SVinzenz Feenstra item->value = g_new0(GuestUser, 1); 2664161a56a9SVinzenz Feenstra item->value->user = g_strdup(user_info->ut_user); 2665161a56a9SVinzenz Feenstra item->value->login_time = ga_get_login_time(user_info); 2666161a56a9SVinzenz Feenstra 2667161a56a9SVinzenz Feenstra g_hash_table_insert(cache, item->value->user, item->value); 2668161a56a9SVinzenz Feenstra 2669161a56a9SVinzenz Feenstra if (!cur_item) { 2670161a56a9SVinzenz Feenstra head = cur_item = item; 2671161a56a9SVinzenz Feenstra } else { 2672161a56a9SVinzenz Feenstra cur_item->next = item; 2673161a56a9SVinzenz Feenstra cur_item = item; 2674161a56a9SVinzenz Feenstra } 2675161a56a9SVinzenz Feenstra } 2676161a56a9SVinzenz Feenstra endutxent(); 2677161a56a9SVinzenz Feenstra g_hash_table_destroy(cache); 2678161a56a9SVinzenz Feenstra return head; 2679161a56a9SVinzenz Feenstra } 2680e674605fSTomáš Golembiovský 2681e674605fSTomáš Golembiovský #else 2682e674605fSTomáš Golembiovský 2683e674605fSTomáš Golembiovský GuestUserList *qmp_guest_get_users(Error **errp) 2684e674605fSTomáš Golembiovský { 2685e674605fSTomáš Golembiovský error_setg(errp, QERR_UNSUPPORTED); 2686e674605fSTomáš Golembiovský return NULL; 2687e674605fSTomáš Golembiovský } 2688e674605fSTomáš Golembiovský 2689e674605fSTomáš Golembiovský #endif 26909848f797STomáš Golembiovský 26919848f797STomáš Golembiovský /* Replace escaped special characters with theire real values. The replacement 26929848f797STomáš Golembiovský * is done in place -- returned value is in the original string. 26939848f797STomáš Golembiovský */ 26949848f797STomáš Golembiovský static void ga_osrelease_replace_special(gchar *value) 26959848f797STomáš Golembiovský { 26969848f797STomáš Golembiovský gchar *p, *p2, quote; 26979848f797STomáš Golembiovský 26989848f797STomáš Golembiovský /* Trim the string at first space or semicolon if it is not enclosed in 26999848f797STomáš Golembiovský * single or double quotes. */ 27009848f797STomáš Golembiovský if ((value[0] != '"') || (value[0] == '\'')) { 27019848f797STomáš Golembiovský p = strchr(value, ' '); 27029848f797STomáš Golembiovský if (p != NULL) { 27039848f797STomáš Golembiovský *p = 0; 27049848f797STomáš Golembiovský } 27059848f797STomáš Golembiovský p = strchr(value, ';'); 27069848f797STomáš Golembiovský if (p != NULL) { 27079848f797STomáš Golembiovský *p = 0; 27089848f797STomáš Golembiovský } 27099848f797STomáš Golembiovský return; 27109848f797STomáš Golembiovský } 27119848f797STomáš Golembiovský 27129848f797STomáš Golembiovský quote = value[0]; 27139848f797STomáš Golembiovský p2 = value; 27149848f797STomáš Golembiovský p = value + 1; 27159848f797STomáš Golembiovský while (*p != 0) { 27169848f797STomáš Golembiovský if (*p == '\\') { 27179848f797STomáš Golembiovský p++; 27189848f797STomáš Golembiovský switch (*p) { 27199848f797STomáš Golembiovský case '$': 27209848f797STomáš Golembiovský case '\'': 27219848f797STomáš Golembiovský case '"': 27229848f797STomáš Golembiovský case '\\': 27239848f797STomáš Golembiovský case '`': 27249848f797STomáš Golembiovský break; 27259848f797STomáš Golembiovský default: 27269848f797STomáš Golembiovský /* Keep literal backslash followed by whatever is there */ 27279848f797STomáš Golembiovský p--; 27289848f797STomáš Golembiovský break; 27299848f797STomáš Golembiovský } 27309848f797STomáš Golembiovský } else if (*p == quote) { 27319848f797STomáš Golembiovský *p2 = 0; 27329848f797STomáš Golembiovský break; 27339848f797STomáš Golembiovský } 27349848f797STomáš Golembiovský *(p2++) = *(p++); 27359848f797STomáš Golembiovský } 27369848f797STomáš Golembiovský } 27379848f797STomáš Golembiovský 27389848f797STomáš Golembiovský static GKeyFile *ga_parse_osrelease(const char *fname) 27399848f797STomáš Golembiovský { 27409848f797STomáš Golembiovský gchar *content = NULL; 27419848f797STomáš Golembiovský gchar *content2 = NULL; 27429848f797STomáš Golembiovský GError *err = NULL; 27439848f797STomáš Golembiovský GKeyFile *keys = g_key_file_new(); 27449848f797STomáš Golembiovský const char *group = "[os-release]\n"; 27459848f797STomáš Golembiovský 27469848f797STomáš Golembiovský if (!g_file_get_contents(fname, &content, NULL, &err)) { 27479848f797STomáš Golembiovský slog("failed to read '%s', error: %s", fname, err->message); 27489848f797STomáš Golembiovský goto fail; 27499848f797STomáš Golembiovský } 27509848f797STomáš Golembiovský 27519848f797STomáš Golembiovský if (!g_utf8_validate(content, -1, NULL)) { 27529848f797STomáš Golembiovský slog("file is not utf-8 encoded: %s", fname); 27539848f797STomáš Golembiovský goto fail; 27549848f797STomáš Golembiovský } 27559848f797STomáš Golembiovský content2 = g_strdup_printf("%s%s", group, content); 27569848f797STomáš Golembiovský 27579848f797STomáš Golembiovský if (!g_key_file_load_from_data(keys, content2, -1, G_KEY_FILE_NONE, 27589848f797STomáš Golembiovský &err)) { 27599848f797STomáš Golembiovský slog("failed to parse file '%s', error: %s", fname, err->message); 27609848f797STomáš Golembiovský goto fail; 27619848f797STomáš Golembiovský } 27629848f797STomáš Golembiovský 27639848f797STomáš Golembiovský g_free(content); 27649848f797STomáš Golembiovský g_free(content2); 27659848f797STomáš Golembiovský return keys; 27669848f797STomáš Golembiovský 27679848f797STomáš Golembiovský fail: 27689848f797STomáš Golembiovský g_error_free(err); 27699848f797STomáš Golembiovský g_free(content); 27709848f797STomáš Golembiovský g_free(content2); 27719848f797STomáš Golembiovský g_key_file_free(keys); 27729848f797STomáš Golembiovský return NULL; 27739848f797STomáš Golembiovský } 27749848f797STomáš Golembiovský 27759848f797STomáš Golembiovský GuestOSInfo *qmp_guest_get_osinfo(Error **errp) 27769848f797STomáš Golembiovský { 27779848f797STomáš Golembiovský GuestOSInfo *info = NULL; 27789848f797STomáš Golembiovský struct utsname kinfo; 2779339ca68bSTomáš Golembiovský GKeyFile *osrelease = NULL; 2780339ca68bSTomáš Golembiovský const char *qga_os_release = g_getenv("QGA_OS_RELEASE"); 27819848f797STomáš Golembiovský 27829848f797STomáš Golembiovský info = g_new0(GuestOSInfo, 1); 27839848f797STomáš Golembiovský 27849848f797STomáš Golembiovský if (uname(&kinfo) != 0) { 27859848f797STomáš Golembiovský error_setg_errno(errp, errno, "uname failed"); 27869848f797STomáš Golembiovský } else { 27879848f797STomáš Golembiovský info->has_kernel_version = true; 27889848f797STomáš Golembiovský info->kernel_version = g_strdup(kinfo.version); 27899848f797STomáš Golembiovský info->has_kernel_release = true; 27909848f797STomáš Golembiovský info->kernel_release = g_strdup(kinfo.release); 27919848f797STomáš Golembiovský info->has_machine = true; 27929848f797STomáš Golembiovský info->machine = g_strdup(kinfo.machine); 27939848f797STomáš Golembiovský } 27949848f797STomáš Golembiovský 2795339ca68bSTomáš Golembiovský if (qga_os_release != NULL) { 2796339ca68bSTomáš Golembiovský osrelease = ga_parse_osrelease(qga_os_release); 2797339ca68bSTomáš Golembiovský } else { 27989848f797STomáš Golembiovský osrelease = ga_parse_osrelease("/etc/os-release"); 27999848f797STomáš Golembiovský if (osrelease == NULL) { 28009848f797STomáš Golembiovský osrelease = ga_parse_osrelease("/usr/lib/os-release"); 28019848f797STomáš Golembiovský } 2802339ca68bSTomáš Golembiovský } 28039848f797STomáš Golembiovský 28049848f797STomáš Golembiovský if (osrelease != NULL) { 28059848f797STomáš Golembiovský char *value; 28069848f797STomáš Golembiovský 28079848f797STomáš Golembiovský #define GET_FIELD(field, osfield) do { \ 28089848f797STomáš Golembiovský value = g_key_file_get_value(osrelease, "os-release", osfield, NULL); \ 28099848f797STomáš Golembiovský if (value != NULL) { \ 28109848f797STomáš Golembiovský ga_osrelease_replace_special(value); \ 28119848f797STomáš Golembiovský info->has_ ## field = true; \ 28129848f797STomáš Golembiovský info->field = value; \ 28139848f797STomáš Golembiovský } \ 28149848f797STomáš Golembiovský } while (0) 28159848f797STomáš Golembiovský GET_FIELD(id, "ID"); 28169848f797STomáš Golembiovský GET_FIELD(name, "NAME"); 28179848f797STomáš Golembiovský GET_FIELD(pretty_name, "PRETTY_NAME"); 28189848f797STomáš Golembiovský GET_FIELD(version, "VERSION"); 28199848f797STomáš Golembiovský GET_FIELD(version_id, "VERSION_ID"); 28209848f797STomáš Golembiovský GET_FIELD(variant, "VARIANT"); 28219848f797STomáš Golembiovský GET_FIELD(variant_id, "VARIANT_ID"); 28229848f797STomáš Golembiovský #undef GET_FIELD 28239848f797STomáš Golembiovský 28249848f797STomáš Golembiovský g_key_file_free(osrelease); 28259848f797STomáš Golembiovský } 28269848f797STomáš Golembiovský 28279848f797STomáš Golembiovský return info; 28289848f797STomáš Golembiovský } 2829