blob: 4275f8aafeaf8d25b4582fede37c88703a65e346 [file] [log] [blame]
Michael Rothd8ca6852012-01-19 22:04:34 -06001/*
2 * QEMU Guest Agent win32-specific command implementations
3 *
4 * Copyright IBM Corp. 2012
5 *
6 * Authors:
7 * Michael Roth <mdroth@linux.vnet.ibm.com>
Gal Hammeraa596372012-01-29 11:53:31 +02008 * Gal Hammer <ghammer@redhat.com>
Michael Rothd8ca6852012-01-19 22:04:34 -06009 *
10 * This work is licensed under the terms of the GNU GPL, version 2 or later.
11 * See the COPYING file in the top-level directory.
12 */
13
14#include <glib.h>
Gal Hammeraa596372012-01-29 11:53:31 +020015#include <wtypes.h>
16#include <powrprof.h>
Olga Krishtalfa193592015-02-06 20:59:55 +030017#include <stdio.h>
18#include <string.h>
Kirk Alland6c55282015-06-02 11:41:07 -060019#include <winsock2.h>
20#include <ws2tcpip.h>
21#include <iptypes.h>
22#include <iphlpapi.h>
Michael Rothd8ca6852012-01-19 22:04:34 -060023#include "qga/guest-agent-core.h"
Tomoki Sekiyama64c00312013-08-07 11:40:25 -040024#include "qga/vss-win32.h"
Michael Rothd8ca6852012-01-19 22:04:34 -060025#include "qga-qmp-commands.h"
Paolo Bonzini7b1b5d12012-12-17 18:19:43 +010026#include "qapi/qmp/qerror.h"
Olga Krishtalfa193592015-02-06 20:59:55 +030027#include "qemu/queue.h"
Kirk Alland6c55282015-06-02 11:41:07 -060028#include "qemu/host-utils.h"
Michael Rothd8ca6852012-01-19 22:04:34 -060029
Michael Roth546b60d2012-01-22 20:24:37 -060030#ifndef SHTDN_REASON_FLAG_PLANNED
31#define SHTDN_REASON_FLAG_PLANNED 0x80000000
32#endif
33
Lei Li3f2a6082013-03-15 17:29:04 +080034/* multiple of 100 nanoseconds elapsed between windows baseline
35 * (1/1/1601) and Unix Epoch (1/1/1970), accounting for leap years */
36#define W32_FT_OFFSET (10000000ULL * 60 * 60 * 24 * \
37 (365 * (1970 - 1601) + \
38 (1970 - 1601) / 4 - 3))
39
Olga Krishtalfa193592015-02-06 20:59:55 +030040#define INVALID_SET_FILE_POINTER ((DWORD)-1)
41
42typedef struct GuestFileHandle {
43 int64_t id;
44 HANDLE fh;
45 QTAILQ_ENTRY(GuestFileHandle) next;
46} GuestFileHandle;
47
48static struct {
49 QTAILQ_HEAD(, GuestFileHandle) filehandles;
50} guest_file_state;
51
52
53typedef struct OpenFlags {
54 const char *forms;
55 DWORD desired_access;
56 DWORD creation_disposition;
57} OpenFlags;
58static OpenFlags guest_file_open_modes[] = {
59 {"r", GENERIC_READ, OPEN_EXISTING},
60 {"rb", GENERIC_READ, OPEN_EXISTING},
61 {"w", GENERIC_WRITE, CREATE_ALWAYS},
62 {"wb", GENERIC_WRITE, CREATE_ALWAYS},
63 {"a", GENERIC_WRITE, OPEN_ALWAYS },
64 {"r+", GENERIC_WRITE|GENERIC_READ, OPEN_EXISTING},
65 {"rb+", GENERIC_WRITE|GENERIC_READ, OPEN_EXISTING},
66 {"r+b", GENERIC_WRITE|GENERIC_READ, OPEN_EXISTING},
67 {"w+", GENERIC_WRITE|GENERIC_READ, CREATE_ALWAYS},
68 {"wb+", GENERIC_WRITE|GENERIC_READ, CREATE_ALWAYS},
69 {"w+b", GENERIC_WRITE|GENERIC_READ, CREATE_ALWAYS},
70 {"a+", GENERIC_WRITE|GENERIC_READ, OPEN_ALWAYS },
71 {"ab+", GENERIC_WRITE|GENERIC_READ, OPEN_ALWAYS },
72 {"a+b", GENERIC_WRITE|GENERIC_READ, OPEN_ALWAYS }
73};
74
75static OpenFlags *find_open_flag(const char *mode_str)
76{
77 int mode;
78 Error **errp = NULL;
79
80 for (mode = 0; mode < ARRAY_SIZE(guest_file_open_modes); ++mode) {
81 OpenFlags *flags = guest_file_open_modes + mode;
82
83 if (strcmp(flags->forms, mode_str) == 0) {
84 return flags;
85 }
86 }
87
88 error_setg(errp, "invalid file open mode '%s'", mode_str);
89 return NULL;
90}
91
92static int64_t guest_file_handle_add(HANDLE fh, Error **errp)
93{
94 GuestFileHandle *gfh;
95 int64_t handle;
96
97 handle = ga_get_fd_handle(ga_state, errp);
98 if (handle < 0) {
99 return -1;
100 }
101 gfh = g_malloc0(sizeof(GuestFileHandle));
102 gfh->id = handle;
103 gfh->fh = fh;
104 QTAILQ_INSERT_TAIL(&guest_file_state.filehandles, gfh, next);
105
106 return handle;
107}
108
109static GuestFileHandle *guest_file_handle_find(int64_t id, Error **errp)
110{
111 GuestFileHandle *gfh;
112 QTAILQ_FOREACH(gfh, &guest_file_state.filehandles, next) {
113 if (gfh->id == id) {
114 return gfh;
115 }
116 }
117 error_setg(errp, "handle '%" PRId64 "' has not been found", id);
118 return NULL;
119}
120
121int64_t qmp_guest_file_open(const char *path, bool has_mode,
122 const char *mode, Error **errp)
123{
124 int64_t fd;
125 HANDLE fh;
126 HANDLE templ_file = NULL;
127 DWORD share_mode = FILE_SHARE_READ;
128 DWORD flags_and_attr = FILE_ATTRIBUTE_NORMAL;
129 LPSECURITY_ATTRIBUTES sa_attr = NULL;
130 OpenFlags *guest_flags;
131
132 if (!has_mode) {
133 mode = "r";
134 }
135 slog("guest-file-open called, filepath: %s, mode: %s", path, mode);
136 guest_flags = find_open_flag(mode);
137 if (guest_flags == NULL) {
138 error_setg(errp, "invalid file open mode");
139 return -1;
140 }
141
142 fh = CreateFile(path, guest_flags->desired_access, share_mode, sa_attr,
143 guest_flags->creation_disposition, flags_and_attr,
144 templ_file);
145 if (fh == INVALID_HANDLE_VALUE) {
146 error_setg_win32(errp, GetLastError(), "failed to open file '%s'",
147 path);
148 return -1;
149 }
150
151 fd = guest_file_handle_add(fh, errp);
152 if (fd < 0) {
153 CloseHandle(&fh);
154 error_setg(errp, "failed to add handle to qmp handle table");
155 return -1;
156 }
157
158 slog("guest-file-open, handle: % " PRId64, fd);
159 return fd;
160}
161
162void qmp_guest_file_close(int64_t handle, Error **errp)
163{
164 bool ret;
165 GuestFileHandle *gfh = guest_file_handle_find(handle, errp);
166 slog("guest-file-close called, handle: %" PRId64, handle);
167 if (gfh == NULL) {
168 return;
169 }
170 ret = CloseHandle(gfh->fh);
171 if (!ret) {
172 error_setg_win32(errp, GetLastError(), "failed close handle");
173 return;
174 }
175
176 QTAILQ_REMOVE(&guest_file_state.filehandles, gfh, next);
177 g_free(gfh);
178}
179
Markus Armbruster77dbc812014-05-02 13:26:30 +0200180static void acquire_privilege(const char *name, Error **errp)
Michael Rothd8ca6852012-01-19 22:04:34 -0600181{
Gonglei374044f2014-05-19 15:26:03 +0800182 HANDLE token = NULL;
Michael Roth546b60d2012-01-22 20:24:37 -0600183 TOKEN_PRIVILEGES priv;
Gal Hammeraa596372012-01-29 11:53:31 +0200184 Error *local_err = NULL;
185
Gal Hammeraa596372012-01-29 11:53:31 +0200186 if (OpenProcessToken(GetCurrentProcess(),
187 TOKEN_ADJUST_PRIVILEGES|TOKEN_QUERY, &token))
188 {
189 if (!LookupPrivilegeValue(NULL, name, &priv.Privileges[0].Luid)) {
Markus Armbrusterc6bd8c72015-03-17 11:54:50 +0100190 error_setg(&local_err, QERR_QGA_COMMAND_FAILED,
191 "no luid for requested privilege");
Gal Hammeraa596372012-01-29 11:53:31 +0200192 goto out;
193 }
194
195 priv.PrivilegeCount = 1;
196 priv.Privileges[0].Attributes = SE_PRIVILEGE_ENABLED;
197
198 if (!AdjustTokenPrivileges(token, FALSE, &priv, 0, NULL, 0)) {
Markus Armbrusterc6bd8c72015-03-17 11:54:50 +0100199 error_setg(&local_err, QERR_QGA_COMMAND_FAILED,
200 "unable to acquire requested privilege");
Gal Hammeraa596372012-01-29 11:53:31 +0200201 goto out;
202 }
203
Gal Hammeraa596372012-01-29 11:53:31 +0200204 } else {
Markus Armbrusterc6bd8c72015-03-17 11:54:50 +0100205 error_setg(&local_err, QERR_QGA_COMMAND_FAILED,
206 "failed to open privilege token");
Gal Hammeraa596372012-01-29 11:53:31 +0200207 }
208
209out:
Gonglei374044f2014-05-19 15:26:03 +0800210 if (token) {
211 CloseHandle(token);
212 }
Gal Hammeraa596372012-01-29 11:53:31 +0200213 if (local_err) {
Markus Armbruster77dbc812014-05-02 13:26:30 +0200214 error_propagate(errp, local_err);
Gal Hammeraa596372012-01-29 11:53:31 +0200215 }
216}
217
Markus Armbruster77dbc812014-05-02 13:26:30 +0200218static void execute_async(DWORD WINAPI (*func)(LPVOID), LPVOID opaque,
219 Error **errp)
Gal Hammeraa596372012-01-29 11:53:31 +0200220{
221 Error *local_err = NULL;
222
Gal Hammeraa596372012-01-29 11:53:31 +0200223 HANDLE thread = CreateThread(NULL, 0, func, opaque, 0, NULL);
224 if (!thread) {
Markus Armbrusterc6bd8c72015-03-17 11:54:50 +0100225 error_setg(&local_err, QERR_QGA_COMMAND_FAILED,
226 "failed to dispatch asynchronous command");
Markus Armbruster77dbc812014-05-02 13:26:30 +0200227 error_propagate(errp, local_err);
Gal Hammeraa596372012-01-29 11:53:31 +0200228 }
229}
230
Markus Armbruster77dbc812014-05-02 13:26:30 +0200231void qmp_guest_shutdown(bool has_mode, const char *mode, Error **errp)
Gal Hammeraa596372012-01-29 11:53:31 +0200232{
Markus Armbruster0f230bf2014-05-02 13:26:38 +0200233 Error *local_err = NULL;
Michael Roth546b60d2012-01-22 20:24:37 -0600234 UINT shutdown_flag = EWX_FORCE;
235
236 slog("guest-shutdown called, mode: %s", mode);
237
238 if (!has_mode || strcmp(mode, "powerdown") == 0) {
239 shutdown_flag |= EWX_POWEROFF;
240 } else if (strcmp(mode, "halt") == 0) {
241 shutdown_flag |= EWX_SHUTDOWN;
242 } else if (strcmp(mode, "reboot") == 0) {
243 shutdown_flag |= EWX_REBOOT;
244 } else {
Markus Armbrusterc6bd8c72015-03-17 11:54:50 +0100245 error_setg(errp, QERR_INVALID_PARAMETER_VALUE, "mode",
246 "halt|powerdown|reboot");
Michael Roth546b60d2012-01-22 20:24:37 -0600247 return;
248 }
249
250 /* Request a shutdown privilege, but try to shut down the system
251 anyway. */
Markus Armbruster0f230bf2014-05-02 13:26:38 +0200252 acquire_privilege(SE_SHUTDOWN_NAME, &local_err);
253 if (local_err) {
254 error_propagate(errp, local_err);
Gal Hammeraa596372012-01-29 11:53:31 +0200255 return;
Michael Roth546b60d2012-01-22 20:24:37 -0600256 }
257
258 if (!ExitWindowsEx(shutdown_flag, SHTDN_REASON_FLAG_PLANNED)) {
Stefan Weil16f4e8f2013-11-25 20:54:17 +0100259 slog("guest-shutdown failed: %lu", GetLastError());
Markus Armbrusterc6bd8c72015-03-17 11:54:50 +0100260 error_setg(errp, QERR_UNDEFINED_ERROR);
Michael Roth546b60d2012-01-22 20:24:37 -0600261 }
Michael Rothd8ca6852012-01-19 22:04:34 -0600262}
263
Michael Rothd8ca6852012-01-19 22:04:34 -0600264GuestFileRead *qmp_guest_file_read(int64_t handle, bool has_count,
Markus Armbruster77dbc812014-05-02 13:26:30 +0200265 int64_t count, Error **errp)
Michael Rothd8ca6852012-01-19 22:04:34 -0600266{
Olga Krishtalfa193592015-02-06 20:59:55 +0300267 GuestFileRead *read_data = NULL;
268 guchar *buf;
269 HANDLE fh;
270 bool is_ok;
271 DWORD read_count;
272 GuestFileHandle *gfh = guest_file_handle_find(handle, errp);
273
274 if (!gfh) {
275 return NULL;
276 }
277 if (!has_count) {
278 count = QGA_READ_COUNT_DEFAULT;
279 } else if (count < 0) {
280 error_setg(errp, "value '%" PRId64
281 "' is invalid for argument count", count);
282 return NULL;
283 }
284
285 fh = gfh->fh;
286 buf = g_malloc0(count+1);
287 is_ok = ReadFile(fh, buf, count, &read_count, NULL);
288 if (!is_ok) {
289 error_setg_win32(errp, GetLastError(), "failed to read file");
290 slog("guest-file-read failed, handle %" PRId64, handle);
291 } else {
292 buf[read_count] = 0;
293 read_data = g_malloc0(sizeof(GuestFileRead));
294 read_data->count = (size_t)read_count;
295 read_data->eof = read_count == 0;
296
297 if (read_count != 0) {
298 read_data->buf_b64 = g_base64_encode(buf, read_count);
299 }
300 }
301 g_free(buf);
302
303 return read_data;
Michael Rothd8ca6852012-01-19 22:04:34 -0600304}
305
306GuestFileWrite *qmp_guest_file_write(int64_t handle, const char *buf_b64,
Markus Armbruster77dbc812014-05-02 13:26:30 +0200307 bool has_count, int64_t count,
308 Error **errp)
Michael Rothd8ca6852012-01-19 22:04:34 -0600309{
Olga Krishtalfa193592015-02-06 20:59:55 +0300310 GuestFileWrite *write_data = NULL;
311 guchar *buf;
312 gsize buf_len;
313 bool is_ok;
314 DWORD write_count;
315 GuestFileHandle *gfh = guest_file_handle_find(handle, errp);
316 HANDLE fh;
317
318 if (!gfh) {
319 return NULL;
320 }
321 fh = gfh->fh;
322 buf = g_base64_decode(buf_b64, &buf_len);
323
324 if (!has_count) {
325 count = buf_len;
326 } else if (count < 0 || count > buf_len) {
327 error_setg(errp, "value '%" PRId64
328 "' is invalid for argument count", count);
329 goto done;
330 }
331
332 is_ok = WriteFile(fh, buf, count, &write_count, NULL);
333 if (!is_ok) {
334 error_setg_win32(errp, GetLastError(), "failed to write to file");
335 slog("guest-file-write-failed, handle: %" PRId64, handle);
336 } else {
337 write_data = g_malloc0(sizeof(GuestFileWrite));
338 write_data->count = (size_t) write_count;
339 }
340
341done:
342 g_free(buf);
343 return write_data;
Michael Rothd8ca6852012-01-19 22:04:34 -0600344}
345
346GuestFileSeek *qmp_guest_file_seek(int64_t handle, int64_t offset,
Markus Armbruster77dbc812014-05-02 13:26:30 +0200347 int64_t whence, Error **errp)
Michael Rothd8ca6852012-01-19 22:04:34 -0600348{
Olga Krishtalfa193592015-02-06 20:59:55 +0300349 GuestFileHandle *gfh;
350 GuestFileSeek *seek_data;
351 HANDLE fh;
352 LARGE_INTEGER new_pos, off_pos;
353 off_pos.QuadPart = offset;
354 BOOL res;
355 gfh = guest_file_handle_find(handle, errp);
356 if (!gfh) {
357 return NULL;
358 }
359
360 fh = gfh->fh;
361 res = SetFilePointerEx(fh, off_pos, &new_pos, whence);
362 if (!res) {
363 error_setg_win32(errp, GetLastError(), "failed to seek file");
364 return NULL;
365 }
366 seek_data = g_new0(GuestFileSeek, 1);
367 seek_data->position = new_pos.QuadPart;
368 return seek_data;
Michael Rothd8ca6852012-01-19 22:04:34 -0600369}
370
Markus Armbruster77dbc812014-05-02 13:26:30 +0200371void qmp_guest_file_flush(int64_t handle, Error **errp)
Michael Rothd8ca6852012-01-19 22:04:34 -0600372{
Olga Krishtalfa193592015-02-06 20:59:55 +0300373 HANDLE fh;
374 GuestFileHandle *gfh = guest_file_handle_find(handle, errp);
375 if (!gfh) {
376 return;
377 }
378
379 fh = gfh->fh;
380 if (!FlushFileBuffers(fh)) {
381 error_setg_win32(errp, GetLastError(), "failed to flush file");
382 }
383}
384
385static void guest_file_init(void)
386{
387 QTAILQ_INIT(&guest_file_state.filehandles);
Michael Rothd8ca6852012-01-19 22:04:34 -0600388}
389
Tomoki Sekiyama46d4c572014-06-30 17:51:34 -0400390GuestFilesystemInfoList *qmp_guest_get_fsinfo(Error **errp)
391{
Markus Armbrusterc6bd8c72015-03-17 11:54:50 +0100392 error_setg(errp, QERR_UNSUPPORTED);
Tomoki Sekiyama46d4c572014-06-30 17:51:34 -0400393 return NULL;
394}
395
Michael Rothd8ca6852012-01-19 22:04:34 -0600396/*
397 * Return status of freeze/thaw
398 */
Markus Armbruster77dbc812014-05-02 13:26:30 +0200399GuestFsfreezeStatus qmp_guest_fsfreeze_status(Error **errp)
Michael Rothd8ca6852012-01-19 22:04:34 -0600400{
Tomoki Sekiyama64c00312013-08-07 11:40:25 -0400401 if (!vss_initialized()) {
Markus Armbrusterc6bd8c72015-03-17 11:54:50 +0100402 error_setg(errp, QERR_UNSUPPORTED);
Tomoki Sekiyama64c00312013-08-07 11:40:25 -0400403 return 0;
404 }
405
406 if (ga_is_frozen(ga_state)) {
407 return GUEST_FSFREEZE_STATUS_FROZEN;
408 }
409
410 return GUEST_FSFREEZE_STATUS_THAWED;
Michael Rothd8ca6852012-01-19 22:04:34 -0600411}
412
413/*
Tomoki Sekiyama64c00312013-08-07 11:40:25 -0400414 * Freeze local file systems using Volume Shadow-copy Service.
415 * The frozen state is limited for up to 10 seconds by VSS.
Michael Rothd8ca6852012-01-19 22:04:34 -0600416 */
Markus Armbruster77dbc812014-05-02 13:26:30 +0200417int64_t qmp_guest_fsfreeze_freeze(Error **errp)
Michael Rothd8ca6852012-01-19 22:04:34 -0600418{
Tomoki Sekiyama64c00312013-08-07 11:40:25 -0400419 int i;
420 Error *local_err = NULL;
421
422 if (!vss_initialized()) {
Markus Armbrusterc6bd8c72015-03-17 11:54:50 +0100423 error_setg(errp, QERR_UNSUPPORTED);
Tomoki Sekiyama64c00312013-08-07 11:40:25 -0400424 return 0;
425 }
426
427 slog("guest-fsfreeze called");
428
429 /* cannot risk guest agent blocking itself on a write in this state */
430 ga_set_frozen(ga_state);
431
Markus Armbruster0f230bf2014-05-02 13:26:38 +0200432 qga_vss_fsfreeze(&i, &local_err, true);
433 if (local_err) {
434 error_propagate(errp, local_err);
Tomoki Sekiyama64c00312013-08-07 11:40:25 -0400435 goto error;
436 }
437
438 return i;
439
440error:
Markus Armbruster0f230bf2014-05-02 13:26:38 +0200441 local_err = NULL;
Tomoki Sekiyama64c00312013-08-07 11:40:25 -0400442 qmp_guest_fsfreeze_thaw(&local_err);
Markus Armbruster84d18f02014-01-30 15:07:28 +0100443 if (local_err) {
Tomoki Sekiyama64c00312013-08-07 11:40:25 -0400444 g_debug("cleanup thaw: %s", error_get_pretty(local_err));
445 error_free(local_err);
446 }
Michael Rothd8ca6852012-01-19 22:04:34 -0600447 return 0;
448}
449
Tomoki Sekiyamae99bce22014-06-30 17:51:27 -0400450int64_t qmp_guest_fsfreeze_freeze_list(bool has_mountpoints,
451 strList *mountpoints,
452 Error **errp)
453{
Markus Armbrusterc6bd8c72015-03-17 11:54:50 +0100454 error_setg(errp, QERR_UNSUPPORTED);
Tomoki Sekiyamae99bce22014-06-30 17:51:27 -0400455
456 return 0;
457}
458
Michael Rothd8ca6852012-01-19 22:04:34 -0600459/*
Tomoki Sekiyama64c00312013-08-07 11:40:25 -0400460 * Thaw local file systems using Volume Shadow-copy Service.
Michael Rothd8ca6852012-01-19 22:04:34 -0600461 */
Markus Armbruster77dbc812014-05-02 13:26:30 +0200462int64_t qmp_guest_fsfreeze_thaw(Error **errp)
Michael Rothd8ca6852012-01-19 22:04:34 -0600463{
Tomoki Sekiyama64c00312013-08-07 11:40:25 -0400464 int i;
465
466 if (!vss_initialized()) {
Markus Armbrusterc6bd8c72015-03-17 11:54:50 +0100467 error_setg(errp, QERR_UNSUPPORTED);
Tomoki Sekiyama64c00312013-08-07 11:40:25 -0400468 return 0;
469 }
470
Markus Armbruster77dbc812014-05-02 13:26:30 +0200471 qga_vss_fsfreeze(&i, errp, false);
Tomoki Sekiyama64c00312013-08-07 11:40:25 -0400472
473 ga_unset_frozen(ga_state);
474 return i;
475}
476
477static void guest_fsfreeze_cleanup(void)
478{
479 Error *err = NULL;
480
481 if (!vss_initialized()) {
482 return;
483 }
484
485 if (ga_is_frozen(ga_state) == GUEST_FSFREEZE_STATUS_FROZEN) {
486 qmp_guest_fsfreeze_thaw(&err);
487 if (err) {
488 slog("failed to clean up frozen filesystems: %s",
489 error_get_pretty(err));
490 error_free(err);
491 }
492 }
493
494 vss_deinit(true);
Michael Rothd8ca6852012-01-19 22:04:34 -0600495}
496
Paolo Bonzinieab5fd52012-06-13 07:41:28 +0200497/*
498 * Walk list of mounted file systems in the guest, and discard unused
499 * areas.
500 */
Justin Ossevoorte82855d2015-05-11 08:58:45 +0200501GuestFilesystemTrimResponse *
502qmp_guest_fstrim(bool has_minimum, int64_t minimum, Error **errp)
Paolo Bonzinieab5fd52012-06-13 07:41:28 +0200503{
Markus Armbrusterc6bd8c72015-03-17 11:54:50 +0100504 error_setg(errp, QERR_UNSUPPORTED);
Justin Ossevoorte82855d2015-05-11 08:58:45 +0200505 return NULL;
Paolo Bonzinieab5fd52012-06-13 07:41:28 +0200506}
507
Gal Hammeraa596372012-01-29 11:53:31 +0200508typedef enum {
Michael Rothf54603b2012-03-12 12:50:02 -0500509 GUEST_SUSPEND_MODE_DISK,
510 GUEST_SUSPEND_MODE_RAM
Gal Hammeraa596372012-01-29 11:53:31 +0200511} GuestSuspendMode;
512
Markus Armbruster77dbc812014-05-02 13:26:30 +0200513static void check_suspend_mode(GuestSuspendMode mode, Error **errp)
Gal Hammeraa596372012-01-29 11:53:31 +0200514{
515 SYSTEM_POWER_CAPABILITIES sys_pwr_caps;
516 Error *local_err = NULL;
517
Gal Hammeraa596372012-01-29 11:53:31 +0200518 ZeroMemory(&sys_pwr_caps, sizeof(sys_pwr_caps));
519 if (!GetPwrCapabilities(&sys_pwr_caps)) {
Markus Armbrusterc6bd8c72015-03-17 11:54:50 +0100520 error_setg(&local_err, QERR_QGA_COMMAND_FAILED,
521 "failed to determine guest suspend capabilities");
Gal Hammeraa596372012-01-29 11:53:31 +0200522 goto out;
523 }
524
Michael Rothf54603b2012-03-12 12:50:02 -0500525 switch (mode) {
526 case GUEST_SUSPEND_MODE_DISK:
527 if (!sys_pwr_caps.SystemS4) {
Markus Armbrusterc6bd8c72015-03-17 11:54:50 +0100528 error_setg(&local_err, QERR_QGA_COMMAND_FAILED,
529 "suspend-to-disk not supported by OS");
Gal Hammeraa596372012-01-29 11:53:31 +0200530 }
Michael Rothf54603b2012-03-12 12:50:02 -0500531 break;
532 case GUEST_SUSPEND_MODE_RAM:
533 if (!sys_pwr_caps.SystemS3) {
Markus Armbrusterc6bd8c72015-03-17 11:54:50 +0100534 error_setg(&local_err, QERR_QGA_COMMAND_FAILED,
535 "suspend-to-ram not supported by OS");
Michael Rothf54603b2012-03-12 12:50:02 -0500536 }
537 break;
538 default:
Markus Armbrusterc6bd8c72015-03-17 11:54:50 +0100539 error_setg(&local_err, QERR_INVALID_PARAMETER_VALUE, "mode",
540 "GuestSuspendMode");
Gal Hammeraa596372012-01-29 11:53:31 +0200541 }
542
Gal Hammeraa596372012-01-29 11:53:31 +0200543out:
544 if (local_err) {
Markus Armbruster77dbc812014-05-02 13:26:30 +0200545 error_propagate(errp, local_err);
Gal Hammeraa596372012-01-29 11:53:31 +0200546 }
547}
548
549static DWORD WINAPI do_suspend(LPVOID opaque)
550{
551 GuestSuspendMode *mode = opaque;
552 DWORD ret = 0;
553
554 if (!SetSuspendState(*mode == GUEST_SUSPEND_MODE_DISK, TRUE, TRUE)) {
Stefan Weil16f4e8f2013-11-25 20:54:17 +0100555 slog("failed to suspend guest, %lu", GetLastError());
Gal Hammeraa596372012-01-29 11:53:31 +0200556 ret = -1;
557 }
558 g_free(mode);
559 return ret;
560}
561
Markus Armbruster77dbc812014-05-02 13:26:30 +0200562void qmp_guest_suspend_disk(Error **errp)
Luiz Capitulino11d0f122012-02-28 11:03:03 -0300563{
Markus Armbruster0f230bf2014-05-02 13:26:38 +0200564 Error *local_err = NULL;
Gal Hammeraa596372012-01-29 11:53:31 +0200565 GuestSuspendMode *mode = g_malloc(sizeof(GuestSuspendMode));
566
567 *mode = GUEST_SUSPEND_MODE_DISK;
Markus Armbruster0f230bf2014-05-02 13:26:38 +0200568 check_suspend_mode(*mode, &local_err);
569 acquire_privilege(SE_SHUTDOWN_NAME, &local_err);
570 execute_async(do_suspend, mode, &local_err);
Gal Hammeraa596372012-01-29 11:53:31 +0200571
Markus Armbruster0f230bf2014-05-02 13:26:38 +0200572 if (local_err) {
573 error_propagate(errp, local_err);
Gal Hammeraa596372012-01-29 11:53:31 +0200574 g_free(mode);
575 }
Luiz Capitulino11d0f122012-02-28 11:03:03 -0300576}
577
Markus Armbruster77dbc812014-05-02 13:26:30 +0200578void qmp_guest_suspend_ram(Error **errp)
Luiz Capitulinofbf42212012-02-28 11:03:04 -0300579{
Markus Armbruster0f230bf2014-05-02 13:26:38 +0200580 Error *local_err = NULL;
Michael Rothf54603b2012-03-12 12:50:02 -0500581 GuestSuspendMode *mode = g_malloc(sizeof(GuestSuspendMode));
582
583 *mode = GUEST_SUSPEND_MODE_RAM;
Markus Armbruster0f230bf2014-05-02 13:26:38 +0200584 check_suspend_mode(*mode, &local_err);
585 acquire_privilege(SE_SHUTDOWN_NAME, &local_err);
586 execute_async(do_suspend, mode, &local_err);
Michael Rothf54603b2012-03-12 12:50:02 -0500587
Markus Armbruster0f230bf2014-05-02 13:26:38 +0200588 if (local_err) {
589 error_propagate(errp, local_err);
Michael Rothf54603b2012-03-12 12:50:02 -0500590 g_free(mode);
591 }
Luiz Capitulinofbf42212012-02-28 11:03:04 -0300592}
593
Markus Armbruster77dbc812014-05-02 13:26:30 +0200594void qmp_guest_suspend_hybrid(Error **errp)
Luiz Capitulino95f4f402012-02-28 11:03:05 -0300595{
Markus Armbrusterc6bd8c72015-03-17 11:54:50 +0100596 error_setg(errp, QERR_UNSUPPORTED);
Luiz Capitulino95f4f402012-02-28 11:03:05 -0300597}
598
Kirk Alland6c55282015-06-02 11:41:07 -0600599static IP_ADAPTER_ADDRESSES *guest_get_adapters_addresses(Error **errp)
600{
601 IP_ADAPTER_ADDRESSES *adptr_addrs = NULL;
602 ULONG adptr_addrs_len = 0;
603 DWORD ret;
604
605 /* Call the first time to get the adptr_addrs_len. */
606 GetAdaptersAddresses(AF_UNSPEC, GAA_FLAG_INCLUDE_PREFIX,
607 NULL, adptr_addrs, &adptr_addrs_len);
608
609 adptr_addrs = g_malloc(adptr_addrs_len);
610 ret = GetAdaptersAddresses(AF_UNSPEC, GAA_FLAG_INCLUDE_PREFIX,
611 NULL, adptr_addrs, &adptr_addrs_len);
612 if (ret != ERROR_SUCCESS) {
613 error_setg_win32(errp, ret, "failed to get adapters addresses");
614 g_free(adptr_addrs);
615 adptr_addrs = NULL;
616 }
617 return adptr_addrs;
618}
619
620static char *guest_wctomb_dup(WCHAR *wstr)
621{
622 char *str;
623 size_t i;
624
625 i = wcslen(wstr) + 1;
626 str = g_malloc(i);
627 WideCharToMultiByte(CP_ACP, WC_COMPOSITECHECK,
628 wstr, -1, str, i, NULL, NULL);
629 return str;
630}
631
632static char *guest_addr_to_str(IP_ADAPTER_UNICAST_ADDRESS *ip_addr,
633 Error **errp)
634{
635 char addr_str[INET6_ADDRSTRLEN + INET_ADDRSTRLEN];
636 DWORD len;
637 int ret;
638
639 if (ip_addr->Address.lpSockaddr->sa_family == AF_INET ||
640 ip_addr->Address.lpSockaddr->sa_family == AF_INET6) {
641 len = sizeof(addr_str);
642 ret = WSAAddressToString(ip_addr->Address.lpSockaddr,
643 ip_addr->Address.iSockaddrLength,
644 NULL,
645 addr_str,
646 &len);
647 if (ret != 0) {
648 error_setg_win32(errp, WSAGetLastError(),
649 "failed address presentation form conversion");
650 return NULL;
651 }
652 return g_strdup(addr_str);
653 }
654 return NULL;
655}
656
657#if (_WIN32_WINNT >= 0x0600)
658static int64_t guest_ip_prefix(IP_ADAPTER_UNICAST_ADDRESS *ip_addr)
659{
660 /* For Windows Vista/2008 and newer, use the OnLinkPrefixLength
661 * field to obtain the prefix.
662 */
663 return ip_addr->OnLinkPrefixLength;
664}
665#else
666/* When using the Windows XP and 2003 build environment, do the best we can to
667 * figure out the prefix.
668 */
669static IP_ADAPTER_INFO *guest_get_adapters_info(void)
670{
671 IP_ADAPTER_INFO *adptr_info = NULL;
672 ULONG adptr_info_len = 0;
673 DWORD ret;
674
675 /* Call the first time to get the adptr_info_len. */
676 GetAdaptersInfo(adptr_info, &adptr_info_len);
677
678 adptr_info = g_malloc(adptr_info_len);
679 ret = GetAdaptersInfo(adptr_info, &adptr_info_len);
680 if (ret != ERROR_SUCCESS) {
681 g_free(adptr_info);
682 adptr_info = NULL;
683 }
684 return adptr_info;
685}
686
687static int64_t guest_ip_prefix(IP_ADAPTER_UNICAST_ADDRESS *ip_addr)
688{
689 int64_t prefix = -1; /* Use for AF_INET6 and unknown/undetermined values. */
690 IP_ADAPTER_INFO *adptr_info, *info;
691 IP_ADDR_STRING *ip;
692 struct in_addr *p;
693
694 if (ip_addr->Address.lpSockaddr->sa_family != AF_INET) {
695 return prefix;
696 }
697 adptr_info = guest_get_adapters_info();
698 if (adptr_info == NULL) {
699 return prefix;
700 }
701
702 /* Match up the passed in ip_addr with one found in adaptr_info.
703 * The matching one in adptr_info will have the netmask.
704 */
705 p = &((struct sockaddr_in *)ip_addr->Address.lpSockaddr)->sin_addr;
706 for (info = adptr_info; info; info = info->Next) {
707 for (ip = &info->IpAddressList; ip; ip = ip->Next) {
708 if (p->S_un.S_addr == inet_addr(ip->IpAddress.String)) {
709 prefix = ctpop32(inet_addr(ip->IpMask.String));
710 goto out;
711 }
712 }
713 }
714out:
715 g_free(adptr_info);
716 return prefix;
717}
718#endif
719
Markus Armbruster77dbc812014-05-02 13:26:30 +0200720GuestNetworkInterfaceList *qmp_guest_network_get_interfaces(Error **errp)
Michal Privoznik3424fc92012-02-29 17:02:23 +0100721{
Kirk Alland6c55282015-06-02 11:41:07 -0600722 IP_ADAPTER_ADDRESSES *adptr_addrs, *addr;
723 IP_ADAPTER_UNICAST_ADDRESS *ip_addr = NULL;
724 GuestNetworkInterfaceList *head = NULL, *cur_item = NULL;
725 GuestIpAddressList *head_addr, *cur_addr;
726 GuestNetworkInterfaceList *info;
727 GuestIpAddressList *address_item = NULL;
728 unsigned char *mac_addr;
729 char *addr_str;
730 WORD wsa_version;
731 WSADATA wsa_data;
732 int ret;
733
734 adptr_addrs = guest_get_adapters_addresses(errp);
735 if (adptr_addrs == NULL) {
736 return NULL;
737 }
738
739 /* Make WSA APIs available. */
740 wsa_version = MAKEWORD(2, 2);
741 ret = WSAStartup(wsa_version, &wsa_data);
742 if (ret != 0) {
743 error_setg_win32(errp, ret, "failed socket startup");
744 goto out;
745 }
746
747 for (addr = adptr_addrs; addr; addr = addr->Next) {
748 info = g_malloc0(sizeof(*info));
749
750 if (cur_item == NULL) {
751 head = cur_item = info;
752 } else {
753 cur_item->next = info;
754 cur_item = info;
755 }
756
757 info->value = g_malloc0(sizeof(*info->value));
758 info->value->name = guest_wctomb_dup(addr->FriendlyName);
759
760 if (addr->PhysicalAddressLength != 0) {
761 mac_addr = addr->PhysicalAddress;
762
763 info->value->hardware_address =
764 g_strdup_printf("%02x:%02x:%02x:%02x:%02x:%02x",
765 (int) mac_addr[0], (int) mac_addr[1],
766 (int) mac_addr[2], (int) mac_addr[3],
767 (int) mac_addr[4], (int) mac_addr[5]);
768
769 info->value->has_hardware_address = true;
770 }
771
772 head_addr = NULL;
773 cur_addr = NULL;
774 for (ip_addr = addr->FirstUnicastAddress;
775 ip_addr;
776 ip_addr = ip_addr->Next) {
777 addr_str = guest_addr_to_str(ip_addr, errp);
778 if (addr_str == NULL) {
779 continue;
780 }
781
782 address_item = g_malloc0(sizeof(*address_item));
783
784 if (!cur_addr) {
785 head_addr = cur_addr = address_item;
786 } else {
787 cur_addr->next = address_item;
788 cur_addr = address_item;
789 }
790
791 address_item->value = g_malloc0(sizeof(*address_item->value));
792 address_item->value->ip_address = addr_str;
793 address_item->value->prefix = guest_ip_prefix(ip_addr);
794 if (ip_addr->Address.lpSockaddr->sa_family == AF_INET) {
795 address_item->value->ip_address_type =
796 GUEST_IP_ADDRESS_TYPE_IPV4;
797 } else if (ip_addr->Address.lpSockaddr->sa_family == AF_INET6) {
798 address_item->value->ip_address_type =
799 GUEST_IP_ADDRESS_TYPE_IPV6;
800 }
801 }
802 if (head_addr) {
803 info->value->has_ip_addresses = true;
804 info->value->ip_addresses = head_addr;
805 }
806 }
807 WSACleanup();
808out:
809 g_free(adptr_addrs);
810 return head;
Michal Privoznik3424fc92012-02-29 17:02:23 +0100811}
812
Lei Li6912e6a2013-03-05 17:39:11 +0800813int64_t qmp_guest_get_time(Error **errp)
814{
Lei Li3f2a6082013-03-15 17:29:04 +0800815 SYSTEMTIME ts = {0};
816 int64_t time_ns;
817 FILETIME tf;
818
819 GetSystemTime(&ts);
820 if (ts.wYear < 1601 || ts.wYear > 30827) {
821 error_setg(errp, "Failed to get time");
822 return -1;
823 }
824
825 if (!SystemTimeToFileTime(&ts, &tf)) {
826 error_setg(errp, "Failed to convert system time: %d", (int)GetLastError());
827 return -1;
828 }
829
830 time_ns = ((((int64_t)tf.dwHighDateTime << 32) | tf.dwLowDateTime)
831 - W32_FT_OFFSET) * 100;
832
833 return time_ns;
Lei Li6912e6a2013-03-05 17:39:11 +0800834}
835
Michal Privoznik2c958922014-01-31 11:29:51 +0100836void qmp_guest_set_time(bool has_time, int64_t time_ns, Error **errp)
Lei Lia1bca572013-03-05 17:39:12 +0800837{
Markus Armbruster0f230bf2014-05-02 13:26:38 +0200838 Error *local_err = NULL;
Lei Lib8f954f2013-03-15 17:29:05 +0800839 SYSTEMTIME ts;
840 FILETIME tf;
841 LONGLONG time;
842
Michal Privoznikee17cbd2015-01-21 12:09:50 +0100843 if (!has_time) {
844 /* Unfortunately, Windows libraries don't provide an easy way to access
845 * RTC yet:
846 *
847 * https://msdn.microsoft.com/en-us/library/aa908981.aspx
848 */
849 error_setg(errp, "Time argument is required on this platform");
850 return;
851 }
Lei Lib8f954f2013-03-15 17:29:05 +0800852
Michal Privoznikee17cbd2015-01-21 12:09:50 +0100853 /* Validate time passed by user. */
854 if (time_ns < 0 || time_ns / 100 > INT64_MAX - W32_FT_OFFSET) {
855 error_setg(errp, "Time %" PRId64 "is invalid", time_ns);
856 return;
857 }
Lei Lib8f954f2013-03-15 17:29:05 +0800858
Michal Privoznikee17cbd2015-01-21 12:09:50 +0100859 time = time_ns / 100 + W32_FT_OFFSET;
Lei Lib8f954f2013-03-15 17:29:05 +0800860
Michal Privoznikee17cbd2015-01-21 12:09:50 +0100861 tf.dwLowDateTime = (DWORD) time;
862 tf.dwHighDateTime = (DWORD) (time >> 32);
863
864 if (!FileTimeToSystemTime(&tf, &ts)) {
865 error_setg(errp, "Failed to convert system time %d",
866 (int)GetLastError());
867 return;
Lei Lib8f954f2013-03-15 17:29:05 +0800868 }
869
Markus Armbruster0f230bf2014-05-02 13:26:38 +0200870 acquire_privilege(SE_SYSTEMTIME_NAME, &local_err);
871 if (local_err) {
872 error_propagate(errp, local_err);
Lei Lib8f954f2013-03-15 17:29:05 +0800873 return;
874 }
875
876 if (!SetSystemTime(&ts)) {
877 error_setg(errp, "Failed to set time to guest: %d", (int)GetLastError());
878 return;
879 }
Lei Lia1bca572013-03-05 17:39:12 +0800880}
881
Laszlo Ersek70e133a2013-03-06 22:59:29 +0100882GuestLogicalProcessorList *qmp_guest_get_vcpus(Error **errp)
883{
Markus Armbrusterc6bd8c72015-03-17 11:54:50 +0100884 error_setg(errp, QERR_UNSUPPORTED);
Laszlo Ersek70e133a2013-03-06 22:59:29 +0100885 return NULL;
886}
887
888int64_t qmp_guest_set_vcpus(GuestLogicalProcessorList *vcpus, Error **errp)
889{
Markus Armbrusterc6bd8c72015-03-17 11:54:50 +0100890 error_setg(errp, QERR_UNSUPPORTED);
Laszlo Ersek70e133a2013-03-06 22:59:29 +0100891 return -1;
892}
893
Daniel P. Berrange215a2772015-02-11 11:26:12 +0000894void qmp_guest_set_user_password(const char *username,
895 const char *password,
896 bool crypted,
897 Error **errp)
898{
Markus Armbrusterc6bd8c72015-03-17 11:54:50 +0100899 error_setg(errp, QERR_UNSUPPORTED);
Daniel P. Berrange215a2772015-02-11 11:26:12 +0000900}
901
zhanghailianga065aaa2015-01-22 10:40:02 +0800902GuestMemoryBlockList *qmp_guest_get_memory_blocks(Error **errp)
903{
Markus Armbrusterc6bd8c72015-03-17 11:54:50 +0100904 error_setg(errp, QERR_UNSUPPORTED);
zhanghailianga065aaa2015-01-22 10:40:02 +0800905 return NULL;
906}
907
908GuestMemoryBlockResponseList *
909qmp_guest_set_memory_blocks(GuestMemoryBlockList *mem_blks, Error **errp)
910{
Markus Armbrusterc6bd8c72015-03-17 11:54:50 +0100911 error_setg(errp, QERR_UNSUPPORTED);
zhanghailianga065aaa2015-01-22 10:40:02 +0800912 return NULL;
913}
914
915GuestMemoryBlockInfo *qmp_guest_get_memory_block_info(Error **errp)
916{
Markus Armbrusterc6bd8c72015-03-17 11:54:50 +0100917 error_setg(errp, QERR_UNSUPPORTED);
zhanghailianga065aaa2015-01-22 10:40:02 +0800918 return NULL;
919}
920
Tomoki Sekiyama1281c082014-06-30 17:51:40 -0400921/* add unsupported commands to the blacklist */
922GList *ga_command_blacklist_init(GList *blacklist)
923{
924 const char *list_unsupported[] = {
Kirk Alland6c55282015-06-02 11:41:07 -0600925 "guest-suspend-hybrid",
Tomoki Sekiyama1281c082014-06-30 17:51:40 -0400926 "guest-get-vcpus", "guest-set-vcpus",
Daniel P. Berrange215a2772015-02-11 11:26:12 +0000927 "guest-set-user-password",
zhanghailiang0dd38a02015-01-22 10:40:06 +0800928 "guest-get-memory-blocks", "guest-set-memory-blocks",
929 "guest-get-memory-block-size",
Tomoki Sekiyama1281c082014-06-30 17:51:40 -0400930 "guest-fsfreeze-freeze-list", "guest-get-fsinfo",
931 "guest-fstrim", NULL};
932 char **p = (char **)list_unsupported;
933
934 while (*p) {
935 blacklist = g_list_append(blacklist, *p++);
936 }
937
938 if (!vss_init(true)) {
Yossi Hindinc69403f2015-05-06 14:57:38 +0300939 g_debug("vss_init failed, vss commands are going to be disabled");
Tomoki Sekiyama1281c082014-06-30 17:51:40 -0400940 const char *list[] = {
941 "guest-get-fsinfo", "guest-fsfreeze-status",
942 "guest-fsfreeze-freeze", "guest-fsfreeze-thaw", NULL};
943 p = (char **)list;
944
945 while (*p) {
946 blacklist = g_list_append(blacklist, *p++);
947 }
948 }
949
950 return blacklist;
951}
952
Michael Rothd8ca6852012-01-19 22:04:34 -0600953/* register init/cleanup routines for stateful command groups */
954void ga_command_state_init(GAState *s, GACommandState *cs)
955{
Tomoki Sekiyama1281c082014-06-30 17:51:40 -0400956 if (!vss_initialized()) {
Tomoki Sekiyama64c00312013-08-07 11:40:25 -0400957 ga_command_state_add(cs, NULL, guest_fsfreeze_cleanup);
958 }
Olga Krishtalfa193592015-02-06 20:59:55 +0300959 ga_command_state_add(cs, guest_file_init, NULL);
Michael Rothd8ca6852012-01-19 22:04:34 -0600960}