Merge remote-tracking branch 'remotes/spice/tags/pull-spice-20141216-1' into staging
[qemu/qmp-unstable.git] / hmp.c
blob481be8019b499f2a51c7902379685b362b88f272
1 /*
2 * Human Monitor Interface
4 * Copyright IBM, Corp. 2011
6 * Authors:
7 * Anthony Liguori <aliguori@us.ibm.com>
9 * This work is licensed under the terms of the GNU GPL, version 2. See
10 * the COPYING file in the top-level directory.
12 * Contributions after 2012-01-13 are licensed under the terms of the
13 * GNU GPL, version 2 or (at your option) any later version.
16 #include "hmp.h"
17 #include "net/net.h"
18 #include "sysemu/char.h"
19 #include "qemu/option.h"
20 #include "qemu/timer.h"
21 #include "qmp-commands.h"
22 #include "qemu/sockets.h"
23 #include "monitor/monitor.h"
24 #include "qapi/opts-visitor.h"
25 #include "qapi/string-output-visitor.h"
26 #include "qapi-visit.h"
27 #include "ui/console.h"
28 #include "block/qapi.h"
29 #include "qemu-io.h"
31 static void hmp_handle_error(Monitor *mon, Error **errp)
33 assert(errp);
34 if (*errp) {
35 monitor_printf(mon, "%s\n", error_get_pretty(*errp));
36 error_free(*errp);
40 void hmp_info_name(Monitor *mon, const QDict *qdict)
42 NameInfo *info;
44 info = qmp_query_name(NULL);
45 if (info->has_name) {
46 monitor_printf(mon, "%s\n", info->name);
48 qapi_free_NameInfo(info);
51 void hmp_info_version(Monitor *mon, const QDict *qdict)
53 VersionInfo *info;
55 info = qmp_query_version(NULL);
57 monitor_printf(mon, "%" PRId64 ".%" PRId64 ".%" PRId64 "%s\n",
58 info->qemu.major, info->qemu.minor, info->qemu.micro,
59 info->package);
61 qapi_free_VersionInfo(info);
64 void hmp_info_kvm(Monitor *mon, const QDict *qdict)
66 KvmInfo *info;
68 info = qmp_query_kvm(NULL);
69 monitor_printf(mon, "kvm support: ");
70 if (info->present) {
71 monitor_printf(mon, "%s\n", info->enabled ? "enabled" : "disabled");
72 } else {
73 monitor_printf(mon, "not compiled\n");
76 qapi_free_KvmInfo(info);
79 void hmp_info_status(Monitor *mon, const QDict *qdict)
81 StatusInfo *info;
83 info = qmp_query_status(NULL);
85 monitor_printf(mon, "VM status: %s%s",
86 info->running ? "running" : "paused",
87 info->singlestep ? " (single step mode)" : "");
89 if (!info->running && info->status != RUN_STATE_PAUSED) {
90 monitor_printf(mon, " (%s)", RunState_lookup[info->status]);
93 monitor_printf(mon, "\n");
95 qapi_free_StatusInfo(info);
98 void hmp_info_uuid(Monitor *mon, const QDict *qdict)
100 UuidInfo *info;
102 info = qmp_query_uuid(NULL);
103 monitor_printf(mon, "%s\n", info->UUID);
104 qapi_free_UuidInfo(info);
107 void hmp_info_chardev(Monitor *mon, const QDict *qdict)
109 ChardevInfoList *char_info, *info;
111 char_info = qmp_query_chardev(NULL);
112 for (info = char_info; info; info = info->next) {
113 monitor_printf(mon, "%s: filename=%s\n", info->value->label,
114 info->value->filename);
117 qapi_free_ChardevInfoList(char_info);
120 void hmp_info_mice(Monitor *mon, const QDict *qdict)
122 MouseInfoList *mice_list, *mouse;
124 mice_list = qmp_query_mice(NULL);
125 if (!mice_list) {
126 monitor_printf(mon, "No mouse devices connected\n");
127 return;
130 for (mouse = mice_list; mouse; mouse = mouse->next) {
131 monitor_printf(mon, "%c Mouse #%" PRId64 ": %s%s\n",
132 mouse->value->current ? '*' : ' ',
133 mouse->value->index, mouse->value->name,
134 mouse->value->absolute ? " (absolute)" : "");
137 qapi_free_MouseInfoList(mice_list);
140 void hmp_info_migrate(Monitor *mon, const QDict *qdict)
142 MigrationInfo *info;
143 MigrationCapabilityStatusList *caps, *cap;
145 info = qmp_query_migrate(NULL);
146 caps = qmp_query_migrate_capabilities(NULL);
148 /* do not display parameters during setup */
149 if (info->has_status && caps) {
150 monitor_printf(mon, "capabilities: ");
151 for (cap = caps; cap; cap = cap->next) {
152 monitor_printf(mon, "%s: %s ",
153 MigrationCapability_lookup[cap->value->capability],
154 cap->value->state ? "on" : "off");
156 monitor_printf(mon, "\n");
159 if (info->has_status) {
160 monitor_printf(mon, "Migration status: %s\n", info->status);
161 monitor_printf(mon, "total time: %" PRIu64 " milliseconds\n",
162 info->total_time);
163 if (info->has_expected_downtime) {
164 monitor_printf(mon, "expected downtime: %" PRIu64 " milliseconds\n",
165 info->expected_downtime);
167 if (info->has_downtime) {
168 monitor_printf(mon, "downtime: %" PRIu64 " milliseconds\n",
169 info->downtime);
171 if (info->has_setup_time) {
172 monitor_printf(mon, "setup: %" PRIu64 " milliseconds\n",
173 info->setup_time);
177 if (info->has_ram) {
178 monitor_printf(mon, "transferred ram: %" PRIu64 " kbytes\n",
179 info->ram->transferred >> 10);
180 monitor_printf(mon, "throughput: %0.2f mbps\n",
181 info->ram->mbps);
182 monitor_printf(mon, "remaining ram: %" PRIu64 " kbytes\n",
183 info->ram->remaining >> 10);
184 monitor_printf(mon, "total ram: %" PRIu64 " kbytes\n",
185 info->ram->total >> 10);
186 monitor_printf(mon, "duplicate: %" PRIu64 " pages\n",
187 info->ram->duplicate);
188 monitor_printf(mon, "skipped: %" PRIu64 " pages\n",
189 info->ram->skipped);
190 monitor_printf(mon, "normal: %" PRIu64 " pages\n",
191 info->ram->normal);
192 monitor_printf(mon, "normal bytes: %" PRIu64 " kbytes\n",
193 info->ram->normal_bytes >> 10);
194 monitor_printf(mon, "dirty sync count: %" PRIu64 "\n",
195 info->ram->dirty_sync_count);
196 if (info->ram->dirty_pages_rate) {
197 monitor_printf(mon, "dirty pages rate: %" PRIu64 " pages\n",
198 info->ram->dirty_pages_rate);
202 if (info->has_disk) {
203 monitor_printf(mon, "transferred disk: %" PRIu64 " kbytes\n",
204 info->disk->transferred >> 10);
205 monitor_printf(mon, "remaining disk: %" PRIu64 " kbytes\n",
206 info->disk->remaining >> 10);
207 monitor_printf(mon, "total disk: %" PRIu64 " kbytes\n",
208 info->disk->total >> 10);
211 if (info->has_xbzrle_cache) {
212 monitor_printf(mon, "cache size: %" PRIu64 " bytes\n",
213 info->xbzrle_cache->cache_size);
214 monitor_printf(mon, "xbzrle transferred: %" PRIu64 " kbytes\n",
215 info->xbzrle_cache->bytes >> 10);
216 monitor_printf(mon, "xbzrle pages: %" PRIu64 " pages\n",
217 info->xbzrle_cache->pages);
218 monitor_printf(mon, "xbzrle cache miss: %" PRIu64 "\n",
219 info->xbzrle_cache->cache_miss);
220 monitor_printf(mon, "xbzrle cache miss rate: %0.2f\n",
221 info->xbzrle_cache->cache_miss_rate);
222 monitor_printf(mon, "xbzrle overflow : %" PRIu64 "\n",
223 info->xbzrle_cache->overflow);
226 qapi_free_MigrationInfo(info);
227 qapi_free_MigrationCapabilityStatusList(caps);
230 void hmp_info_migrate_capabilities(Monitor *mon, const QDict *qdict)
232 MigrationCapabilityStatusList *caps, *cap;
234 caps = qmp_query_migrate_capabilities(NULL);
236 if (caps) {
237 monitor_printf(mon, "capabilities: ");
238 for (cap = caps; cap; cap = cap->next) {
239 monitor_printf(mon, "%s: %s ",
240 MigrationCapability_lookup[cap->value->capability],
241 cap->value->state ? "on" : "off");
243 monitor_printf(mon, "\n");
246 qapi_free_MigrationCapabilityStatusList(caps);
249 void hmp_info_migrate_cache_size(Monitor *mon, const QDict *qdict)
251 monitor_printf(mon, "xbzrel cache size: %" PRId64 " kbytes\n",
252 qmp_query_migrate_cache_size(NULL) >> 10);
255 void hmp_info_cpus(Monitor *mon, const QDict *qdict)
257 CpuInfoList *cpu_list, *cpu;
259 cpu_list = qmp_query_cpus(NULL);
261 for (cpu = cpu_list; cpu; cpu = cpu->next) {
262 int active = ' ';
264 if (cpu->value->CPU == monitor_get_cpu_index()) {
265 active = '*';
268 monitor_printf(mon, "%c CPU #%" PRId64 ":", active, cpu->value->CPU);
270 if (cpu->value->has_pc) {
271 monitor_printf(mon, " pc=0x%016" PRIx64, cpu->value->pc);
273 if (cpu->value->has_nip) {
274 monitor_printf(mon, " nip=0x%016" PRIx64, cpu->value->nip);
276 if (cpu->value->has_npc) {
277 monitor_printf(mon, " npc=0x%016" PRIx64, cpu->value->npc);
279 if (cpu->value->has_PC) {
280 monitor_printf(mon, " PC=0x%016" PRIx64, cpu->value->PC);
283 if (cpu->value->halted) {
284 monitor_printf(mon, " (halted)");
287 monitor_printf(mon, " thread_id=%" PRId64 "\n", cpu->value->thread_id);
290 qapi_free_CpuInfoList(cpu_list);
293 static void print_block_info(Monitor *mon, BlockInfo *info,
294 BlockDeviceInfo *inserted, bool verbose)
296 ImageInfo *image_info;
298 assert(!info || !info->has_inserted || info->inserted == inserted);
300 if (info) {
301 monitor_printf(mon, "%s", info->device);
302 if (inserted && inserted->has_node_name) {
303 monitor_printf(mon, " (%s)", inserted->node_name);
305 } else {
306 assert(inserted);
307 monitor_printf(mon, "%s",
308 inserted->has_node_name
309 ? inserted->node_name
310 : "<anonymous>");
313 if (inserted) {
314 monitor_printf(mon, ": %s (%s%s%s)\n",
315 inserted->file,
316 inserted->drv,
317 inserted->ro ? ", read-only" : "",
318 inserted->encrypted ? ", encrypted" : "");
319 } else {
320 monitor_printf(mon, ": [not inserted]\n");
323 if (info) {
324 if (info->has_io_status && info->io_status != BLOCK_DEVICE_IO_STATUS_OK) {
325 monitor_printf(mon, " I/O status: %s\n",
326 BlockDeviceIoStatus_lookup[info->io_status]);
329 if (info->removable) {
330 monitor_printf(mon, " Removable device: %slocked, tray %s\n",
331 info->locked ? "" : "not ",
332 info->tray_open ? "open" : "closed");
337 if (!inserted) {
338 return;
341 monitor_printf(mon, " Cache mode: %s%s%s\n",
342 inserted->cache->writeback ? "writeback" : "writethrough",
343 inserted->cache->direct ? ", direct" : "",
344 inserted->cache->no_flush ? ", ignore flushes" : "");
346 if (inserted->has_backing_file) {
347 monitor_printf(mon,
348 " Backing file: %s "
349 "(chain depth: %" PRId64 ")\n",
350 inserted->backing_file,
351 inserted->backing_file_depth);
354 if (inserted->detect_zeroes != BLOCKDEV_DETECT_ZEROES_OPTIONS_OFF) {
355 monitor_printf(mon, " Detect zeroes: %s\n",
356 BlockdevDetectZeroesOptions_lookup[inserted->detect_zeroes]);
359 if (inserted->bps || inserted->bps_rd || inserted->bps_wr ||
360 inserted->iops || inserted->iops_rd || inserted->iops_wr)
362 monitor_printf(mon, " I/O throttling: bps=%" PRId64
363 " bps_rd=%" PRId64 " bps_wr=%" PRId64
364 " bps_max=%" PRId64
365 " bps_rd_max=%" PRId64
366 " bps_wr_max=%" PRId64
367 " iops=%" PRId64 " iops_rd=%" PRId64
368 " iops_wr=%" PRId64
369 " iops_max=%" PRId64
370 " iops_rd_max=%" PRId64
371 " iops_wr_max=%" PRId64
372 " iops_size=%" PRId64 "\n",
373 inserted->bps,
374 inserted->bps_rd,
375 inserted->bps_wr,
376 inserted->bps_max,
377 inserted->bps_rd_max,
378 inserted->bps_wr_max,
379 inserted->iops,
380 inserted->iops_rd,
381 inserted->iops_wr,
382 inserted->iops_max,
383 inserted->iops_rd_max,
384 inserted->iops_wr_max,
385 inserted->iops_size);
388 if (verbose) {
389 monitor_printf(mon, "\nImages:\n");
390 image_info = inserted->image;
391 while (1) {
392 bdrv_image_info_dump((fprintf_function)monitor_printf,
393 mon, image_info);
394 if (image_info->has_backing_image) {
395 image_info = image_info->backing_image;
396 } else {
397 break;
403 void hmp_info_block(Monitor *mon, const QDict *qdict)
405 BlockInfoList *block_list, *info;
406 BlockDeviceInfoList *blockdev_list, *blockdev;
407 const char *device = qdict_get_try_str(qdict, "device");
408 bool verbose = qdict_get_try_bool(qdict, "verbose", 0);
409 bool nodes = qdict_get_try_bool(qdict, "nodes", 0);
410 bool printed = false;
412 /* Print BlockBackend information */
413 if (!nodes) {
414 block_list = qmp_query_block(false);
415 } else {
416 block_list = NULL;
419 for (info = block_list; info; info = info->next) {
420 if (device && strcmp(device, info->value->device)) {
421 continue;
424 if (info != block_list) {
425 monitor_printf(mon, "\n");
428 print_block_info(mon, info->value, info->value->has_inserted
429 ? info->value->inserted : NULL,
430 verbose);
431 printed = true;
434 qapi_free_BlockInfoList(block_list);
436 if ((!device && !nodes) || printed) {
437 return;
440 /* Print node information */
441 blockdev_list = qmp_query_named_block_nodes(NULL);
442 for (blockdev = blockdev_list; blockdev; blockdev = blockdev->next) {
443 assert(blockdev->value->has_node_name);
444 if (device && strcmp(device, blockdev->value->node_name)) {
445 continue;
448 if (blockdev != blockdev_list) {
449 monitor_printf(mon, "\n");
452 print_block_info(mon, NULL, blockdev->value, verbose);
454 qapi_free_BlockDeviceInfoList(blockdev_list);
457 void hmp_info_blockstats(Monitor *mon, const QDict *qdict)
459 BlockStatsList *stats_list, *stats;
461 stats_list = qmp_query_blockstats(false, false, NULL);
463 for (stats = stats_list; stats; stats = stats->next) {
464 if (!stats->value->has_device) {
465 continue;
468 monitor_printf(mon, "%s:", stats->value->device);
469 monitor_printf(mon, " rd_bytes=%" PRId64
470 " wr_bytes=%" PRId64
471 " rd_operations=%" PRId64
472 " wr_operations=%" PRId64
473 " flush_operations=%" PRId64
474 " wr_total_time_ns=%" PRId64
475 " rd_total_time_ns=%" PRId64
476 " flush_total_time_ns=%" PRId64
477 "\n",
478 stats->value->stats->rd_bytes,
479 stats->value->stats->wr_bytes,
480 stats->value->stats->rd_operations,
481 stats->value->stats->wr_operations,
482 stats->value->stats->flush_operations,
483 stats->value->stats->wr_total_time_ns,
484 stats->value->stats->rd_total_time_ns,
485 stats->value->stats->flush_total_time_ns);
488 qapi_free_BlockStatsList(stats_list);
491 void hmp_info_vnc(Monitor *mon, const QDict *qdict)
493 VncInfo *info;
494 Error *err = NULL;
495 VncClientInfoList *client;
497 info = qmp_query_vnc(&err);
498 if (err) {
499 monitor_printf(mon, "%s\n", error_get_pretty(err));
500 error_free(err);
501 return;
504 if (!info->enabled) {
505 monitor_printf(mon, "Server: disabled\n");
506 goto out;
509 monitor_printf(mon, "Server:\n");
510 if (info->has_host && info->has_service) {
511 monitor_printf(mon, " address: %s:%s\n", info->host, info->service);
513 if (info->has_auth) {
514 monitor_printf(mon, " auth: %s\n", info->auth);
517 if (!info->has_clients || info->clients == NULL) {
518 monitor_printf(mon, "Client: none\n");
519 } else {
520 for (client = info->clients; client; client = client->next) {
521 monitor_printf(mon, "Client:\n");
522 monitor_printf(mon, " address: %s:%s\n",
523 client->value->base->host,
524 client->value->base->service);
525 monitor_printf(mon, " x509_dname: %s\n",
526 client->value->x509_dname ?
527 client->value->x509_dname : "none");
528 monitor_printf(mon, " username: %s\n",
529 client->value->has_sasl_username ?
530 client->value->sasl_username : "none");
534 out:
535 qapi_free_VncInfo(info);
538 void hmp_info_spice(Monitor *mon, const QDict *qdict)
540 SpiceChannelList *chan;
541 SpiceInfo *info;
543 info = qmp_query_spice(NULL);
545 if (!info->enabled) {
546 monitor_printf(mon, "Server: disabled\n");
547 goto out;
550 monitor_printf(mon, "Server:\n");
551 if (info->has_port) {
552 monitor_printf(mon, " address: %s:%" PRId64 "\n",
553 info->host, info->port);
555 if (info->has_tls_port) {
556 monitor_printf(mon, " address: %s:%" PRId64 " [tls]\n",
557 info->host, info->tls_port);
559 monitor_printf(mon, " migrated: %s\n",
560 info->migrated ? "true" : "false");
561 monitor_printf(mon, " auth: %s\n", info->auth);
562 monitor_printf(mon, " compiled: %s\n", info->compiled_version);
563 monitor_printf(mon, " mouse-mode: %s\n",
564 SpiceQueryMouseMode_lookup[info->mouse_mode]);
566 if (!info->has_channels || info->channels == NULL) {
567 monitor_printf(mon, "Channels: none\n");
568 } else {
569 for (chan = info->channels; chan; chan = chan->next) {
570 monitor_printf(mon, "Channel:\n");
571 monitor_printf(mon, " address: %s:%s%s\n",
572 chan->value->base->host, chan->value->base->port,
573 chan->value->tls ? " [tls]" : "");
574 monitor_printf(mon, " session: %" PRId64 "\n",
575 chan->value->connection_id);
576 monitor_printf(mon, " channel: %" PRId64 ":%" PRId64 "\n",
577 chan->value->channel_type, chan->value->channel_id);
581 out:
582 qapi_free_SpiceInfo(info);
585 void hmp_info_balloon(Monitor *mon, const QDict *qdict)
587 BalloonInfo *info;
588 Error *err = NULL;
590 info = qmp_query_balloon(&err);
591 if (err) {
592 monitor_printf(mon, "%s\n", error_get_pretty(err));
593 error_free(err);
594 return;
597 monitor_printf(mon, "balloon: actual=%" PRId64 "\n", info->actual >> 20);
599 qapi_free_BalloonInfo(info);
602 static void hmp_info_pci_device(Monitor *mon, const PciDeviceInfo *dev)
604 PciMemoryRegionList *region;
606 monitor_printf(mon, " Bus %2" PRId64 ", ", dev->bus);
607 monitor_printf(mon, "device %3" PRId64 ", function %" PRId64 ":\n",
608 dev->slot, dev->function);
609 monitor_printf(mon, " ");
611 if (dev->class_info.has_desc) {
612 monitor_printf(mon, "%s", dev->class_info.desc);
613 } else {
614 monitor_printf(mon, "Class %04" PRId64, dev->class_info.q_class);
617 monitor_printf(mon, ": PCI device %04" PRIx64 ":%04" PRIx64 "\n",
618 dev->id.vendor, dev->id.device);
620 if (dev->has_irq) {
621 monitor_printf(mon, " IRQ %" PRId64 ".\n", dev->irq);
624 if (dev->has_pci_bridge) {
625 monitor_printf(mon, " BUS %" PRId64 ".\n",
626 dev->pci_bridge->bus.number);
627 monitor_printf(mon, " secondary bus %" PRId64 ".\n",
628 dev->pci_bridge->bus.secondary);
629 monitor_printf(mon, " subordinate bus %" PRId64 ".\n",
630 dev->pci_bridge->bus.subordinate);
632 monitor_printf(mon, " IO range [0x%04"PRIx64", 0x%04"PRIx64"]\n",
633 dev->pci_bridge->bus.io_range->base,
634 dev->pci_bridge->bus.io_range->limit);
636 monitor_printf(mon,
637 " memory range [0x%08"PRIx64", 0x%08"PRIx64"]\n",
638 dev->pci_bridge->bus.memory_range->base,
639 dev->pci_bridge->bus.memory_range->limit);
641 monitor_printf(mon, " prefetchable memory range "
642 "[0x%08"PRIx64", 0x%08"PRIx64"]\n",
643 dev->pci_bridge->bus.prefetchable_range->base,
644 dev->pci_bridge->bus.prefetchable_range->limit);
647 for (region = dev->regions; region; region = region->next) {
648 uint64_t addr, size;
650 addr = region->value->address;
651 size = region->value->size;
653 monitor_printf(mon, " BAR%" PRId64 ": ", region->value->bar);
655 if (!strcmp(region->value->type, "io")) {
656 monitor_printf(mon, "I/O at 0x%04" PRIx64
657 " [0x%04" PRIx64 "].\n",
658 addr, addr + size - 1);
659 } else {
660 monitor_printf(mon, "%d bit%s memory at 0x%08" PRIx64
661 " [0x%08" PRIx64 "].\n",
662 region->value->mem_type_64 ? 64 : 32,
663 region->value->prefetch ? " prefetchable" : "",
664 addr, addr + size - 1);
668 monitor_printf(mon, " id \"%s\"\n", dev->qdev_id);
670 if (dev->has_pci_bridge) {
671 if (dev->pci_bridge->has_devices) {
672 PciDeviceInfoList *cdev;
673 for (cdev = dev->pci_bridge->devices; cdev; cdev = cdev->next) {
674 hmp_info_pci_device(mon, cdev->value);
680 void hmp_info_pci(Monitor *mon, const QDict *qdict)
682 PciInfoList *info_list, *info;
683 Error *err = NULL;
685 info_list = qmp_query_pci(&err);
686 if (err) {
687 monitor_printf(mon, "PCI devices not supported\n");
688 error_free(err);
689 return;
692 for (info = info_list; info; info = info->next) {
693 PciDeviceInfoList *dev;
695 for (dev = info->value->devices; dev; dev = dev->next) {
696 hmp_info_pci_device(mon, dev->value);
700 qapi_free_PciInfoList(info_list);
703 void hmp_info_block_jobs(Monitor *mon, const QDict *qdict)
705 BlockJobInfoList *list;
706 Error *err = NULL;
708 list = qmp_query_block_jobs(&err);
709 assert(!err);
711 if (!list) {
712 monitor_printf(mon, "No active jobs\n");
713 return;
716 while (list) {
717 if (strcmp(list->value->type, "stream") == 0) {
718 monitor_printf(mon, "Streaming device %s: Completed %" PRId64
719 " of %" PRId64 " bytes, speed limit %" PRId64
720 " bytes/s\n",
721 list->value->device,
722 list->value->offset,
723 list->value->len,
724 list->value->speed);
725 } else {
726 monitor_printf(mon, "Type %s, device %s: Completed %" PRId64
727 " of %" PRId64 " bytes, speed limit %" PRId64
728 " bytes/s\n",
729 list->value->type,
730 list->value->device,
731 list->value->offset,
732 list->value->len,
733 list->value->speed);
735 list = list->next;
738 qapi_free_BlockJobInfoList(list);
741 void hmp_info_tpm(Monitor *mon, const QDict *qdict)
743 TPMInfoList *info_list, *info;
744 Error *err = NULL;
745 unsigned int c = 0;
746 TPMPassthroughOptions *tpo;
748 info_list = qmp_query_tpm(&err);
749 if (err) {
750 monitor_printf(mon, "TPM device not supported\n");
751 error_free(err);
752 return;
755 if (info_list) {
756 monitor_printf(mon, "TPM device:\n");
759 for (info = info_list; info; info = info->next) {
760 TPMInfo *ti = info->value;
761 monitor_printf(mon, " tpm%d: model=%s\n",
762 c, TpmModel_lookup[ti->model]);
764 monitor_printf(mon, " \\ %s: type=%s",
765 ti->id, TpmTypeOptionsKind_lookup[ti->options->kind]);
767 switch (ti->options->kind) {
768 case TPM_TYPE_OPTIONS_KIND_PASSTHROUGH:
769 tpo = ti->options->passthrough;
770 monitor_printf(mon, "%s%s%s%s",
771 tpo->has_path ? ",path=" : "",
772 tpo->has_path ? tpo->path : "",
773 tpo->has_cancel_path ? ",cancel-path=" : "",
774 tpo->has_cancel_path ? tpo->cancel_path : "");
775 break;
776 case TPM_TYPE_OPTIONS_KIND_MAX:
777 break;
779 monitor_printf(mon, "\n");
780 c++;
782 qapi_free_TPMInfoList(info_list);
785 void hmp_quit(Monitor *mon, const QDict *qdict)
787 monitor_suspend(mon);
788 qmp_quit(NULL);
791 void hmp_stop(Monitor *mon, const QDict *qdict)
793 qmp_stop(NULL);
796 void hmp_system_reset(Monitor *mon, const QDict *qdict)
798 qmp_system_reset(NULL);
801 void hmp_system_powerdown(Monitor *mon, const QDict *qdict)
803 qmp_system_powerdown(NULL);
806 void hmp_cpu(Monitor *mon, const QDict *qdict)
808 int64_t cpu_index;
810 /* XXX: drop the monitor_set_cpu() usage when all HMP commands that
811 use it are converted to the QAPI */
812 cpu_index = qdict_get_int(qdict, "index");
813 if (monitor_set_cpu(cpu_index) < 0) {
814 monitor_printf(mon, "invalid CPU index\n");
818 void hmp_memsave(Monitor *mon, const QDict *qdict)
820 uint32_t size = qdict_get_int(qdict, "size");
821 const char *filename = qdict_get_str(qdict, "filename");
822 uint64_t addr = qdict_get_int(qdict, "val");
823 Error *err = NULL;
825 qmp_memsave(addr, size, filename, true, monitor_get_cpu_index(), &err);
826 hmp_handle_error(mon, &err);
829 void hmp_pmemsave(Monitor *mon, const QDict *qdict)
831 uint32_t size = qdict_get_int(qdict, "size");
832 const char *filename = qdict_get_str(qdict, "filename");
833 uint64_t addr = qdict_get_int(qdict, "val");
834 Error *err = NULL;
836 qmp_pmemsave(addr, size, filename, &err);
837 hmp_handle_error(mon, &err);
840 void hmp_ringbuf_write(Monitor *mon, const QDict *qdict)
842 const char *chardev = qdict_get_str(qdict, "device");
843 const char *data = qdict_get_str(qdict, "data");
844 Error *err = NULL;
846 qmp_ringbuf_write(chardev, data, false, 0, &err);
848 hmp_handle_error(mon, &err);
851 void hmp_ringbuf_read(Monitor *mon, const QDict *qdict)
853 uint32_t size = qdict_get_int(qdict, "size");
854 const char *chardev = qdict_get_str(qdict, "device");
855 char *data;
856 Error *err = NULL;
857 int i;
859 data = qmp_ringbuf_read(chardev, size, false, 0, &err);
860 if (err) {
861 monitor_printf(mon, "%s\n", error_get_pretty(err));
862 error_free(err);
863 return;
866 for (i = 0; data[i]; i++) {
867 unsigned char ch = data[i];
869 if (ch == '\\') {
870 monitor_printf(mon, "\\\\");
871 } else if ((ch < 0x20 && ch != '\n' && ch != '\t') || ch == 0x7F) {
872 monitor_printf(mon, "\\u%04X", ch);
873 } else {
874 monitor_printf(mon, "%c", ch);
878 monitor_printf(mon, "\n");
879 g_free(data);
882 static void hmp_cont_cb(void *opaque, int err)
884 if (!err) {
885 qmp_cont(NULL);
889 static bool key_is_missing(const BlockInfo *bdev)
891 return (bdev->inserted && bdev->inserted->encryption_key_missing);
894 void hmp_cont(Monitor *mon, const QDict *qdict)
896 BlockInfoList *bdev_list, *bdev;
897 Error *err = NULL;
899 bdev_list = qmp_query_block(NULL);
900 for (bdev = bdev_list; bdev; bdev = bdev->next) {
901 if (key_is_missing(bdev->value)) {
902 monitor_read_block_device_key(mon, bdev->value->device,
903 hmp_cont_cb, NULL);
904 goto out;
908 qmp_cont(&err);
909 hmp_handle_error(mon, &err);
911 out:
912 qapi_free_BlockInfoList(bdev_list);
915 void hmp_system_wakeup(Monitor *mon, const QDict *qdict)
917 qmp_system_wakeup(NULL);
920 void hmp_inject_nmi(Monitor *mon, const QDict *qdict)
922 Error *err = NULL;
924 qmp_inject_nmi(&err);
925 hmp_handle_error(mon, &err);
928 void hmp_set_link(Monitor *mon, const QDict *qdict)
930 const char *name = qdict_get_str(qdict, "name");
931 int up = qdict_get_bool(qdict, "up");
932 Error *err = NULL;
934 qmp_set_link(name, up, &err);
935 hmp_handle_error(mon, &err);
938 void hmp_block_passwd(Monitor *mon, const QDict *qdict)
940 const char *device = qdict_get_str(qdict, "device");
941 const char *password = qdict_get_str(qdict, "password");
942 Error *err = NULL;
944 qmp_block_passwd(true, device, false, NULL, password, &err);
945 hmp_handle_error(mon, &err);
948 void hmp_balloon(Monitor *mon, const QDict *qdict)
950 int64_t value = qdict_get_int(qdict, "value");
951 Error *err = NULL;
953 qmp_balloon(value, &err);
954 if (err) {
955 monitor_printf(mon, "balloon: %s\n", error_get_pretty(err));
956 error_free(err);
960 void hmp_block_resize(Monitor *mon, const QDict *qdict)
962 const char *device = qdict_get_str(qdict, "device");
963 int64_t size = qdict_get_int(qdict, "size");
964 Error *err = NULL;
966 qmp_block_resize(true, device, false, NULL, size, &err);
967 hmp_handle_error(mon, &err);
970 void hmp_drive_mirror(Monitor *mon, const QDict *qdict)
972 const char *device = qdict_get_str(qdict, "device");
973 const char *filename = qdict_get_str(qdict, "target");
974 const char *format = qdict_get_try_str(qdict, "format");
975 int reuse = qdict_get_try_bool(qdict, "reuse", 0);
976 int full = qdict_get_try_bool(qdict, "full", 0);
977 enum NewImageMode mode;
978 Error *err = NULL;
980 if (!filename) {
981 error_set(&err, QERR_MISSING_PARAMETER, "target");
982 hmp_handle_error(mon, &err);
983 return;
986 if (reuse) {
987 mode = NEW_IMAGE_MODE_EXISTING;
988 } else {
989 mode = NEW_IMAGE_MODE_ABSOLUTE_PATHS;
992 qmp_drive_mirror(device, filename, !!format, format,
993 false, NULL, false, NULL,
994 full ? MIRROR_SYNC_MODE_FULL : MIRROR_SYNC_MODE_TOP,
995 true, mode, false, 0, false, 0, false, 0,
996 false, 0, false, 0, &err);
997 hmp_handle_error(mon, &err);
1000 void hmp_drive_backup(Monitor *mon, const QDict *qdict)
1002 const char *device = qdict_get_str(qdict, "device");
1003 const char *filename = qdict_get_str(qdict, "target");
1004 const char *format = qdict_get_try_str(qdict, "format");
1005 int reuse = qdict_get_try_bool(qdict, "reuse", 0);
1006 int full = qdict_get_try_bool(qdict, "full", 0);
1007 enum NewImageMode mode;
1008 Error *err = NULL;
1010 if (!filename) {
1011 error_set(&err, QERR_MISSING_PARAMETER, "target");
1012 hmp_handle_error(mon, &err);
1013 return;
1016 if (reuse) {
1017 mode = NEW_IMAGE_MODE_EXISTING;
1018 } else {
1019 mode = NEW_IMAGE_MODE_ABSOLUTE_PATHS;
1022 qmp_drive_backup(device, filename, !!format, format,
1023 full ? MIRROR_SYNC_MODE_FULL : MIRROR_SYNC_MODE_TOP,
1024 true, mode, false, 0, false, 0, false, 0, &err);
1025 hmp_handle_error(mon, &err);
1028 void hmp_snapshot_blkdev(Monitor *mon, const QDict *qdict)
1030 const char *device = qdict_get_str(qdict, "device");
1031 const char *filename = qdict_get_try_str(qdict, "snapshot-file");
1032 const char *format = qdict_get_try_str(qdict, "format");
1033 int reuse = qdict_get_try_bool(qdict, "reuse", 0);
1034 enum NewImageMode mode;
1035 Error *err = NULL;
1037 if (!filename) {
1038 /* In the future, if 'snapshot-file' is not specified, the snapshot
1039 will be taken internally. Today it's actually required. */
1040 error_set(&err, QERR_MISSING_PARAMETER, "snapshot-file");
1041 hmp_handle_error(mon, &err);
1042 return;
1045 mode = reuse ? NEW_IMAGE_MODE_EXISTING : NEW_IMAGE_MODE_ABSOLUTE_PATHS;
1046 qmp_blockdev_snapshot_sync(true, device, false, NULL,
1047 filename, false, NULL,
1048 !!format, format,
1049 true, mode, &err);
1050 hmp_handle_error(mon, &err);
1053 void hmp_snapshot_blkdev_internal(Monitor *mon, const QDict *qdict)
1055 const char *device = qdict_get_str(qdict, "device");
1056 const char *name = qdict_get_str(qdict, "name");
1057 Error *err = NULL;
1059 qmp_blockdev_snapshot_internal_sync(device, name, &err);
1060 hmp_handle_error(mon, &err);
1063 void hmp_snapshot_delete_blkdev_internal(Monitor *mon, const QDict *qdict)
1065 const char *device = qdict_get_str(qdict, "device");
1066 const char *name = qdict_get_str(qdict, "name");
1067 const char *id = qdict_get_try_str(qdict, "id");
1068 Error *err = NULL;
1070 qmp_blockdev_snapshot_delete_internal_sync(device, !!id, id,
1071 true, name, &err);
1072 hmp_handle_error(mon, &err);
1075 void hmp_migrate_cancel(Monitor *mon, const QDict *qdict)
1077 qmp_migrate_cancel(NULL);
1080 void hmp_migrate_set_downtime(Monitor *mon, const QDict *qdict)
1082 double value = qdict_get_double(qdict, "value");
1083 qmp_migrate_set_downtime(value, NULL);
1086 void hmp_migrate_set_cache_size(Monitor *mon, const QDict *qdict)
1088 int64_t value = qdict_get_int(qdict, "value");
1089 Error *err = NULL;
1091 qmp_migrate_set_cache_size(value, &err);
1092 if (err) {
1093 monitor_printf(mon, "%s\n", error_get_pretty(err));
1094 error_free(err);
1095 return;
1099 void hmp_migrate_set_speed(Monitor *mon, const QDict *qdict)
1101 int64_t value = qdict_get_int(qdict, "value");
1102 qmp_migrate_set_speed(value, NULL);
1105 void hmp_migrate_set_capability(Monitor *mon, const QDict *qdict)
1107 const char *cap = qdict_get_str(qdict, "capability");
1108 bool state = qdict_get_bool(qdict, "state");
1109 Error *err = NULL;
1110 MigrationCapabilityStatusList *caps = g_malloc0(sizeof(*caps));
1111 int i;
1113 for (i = 0; i < MIGRATION_CAPABILITY_MAX; i++) {
1114 if (strcmp(cap, MigrationCapability_lookup[i]) == 0) {
1115 caps->value = g_malloc0(sizeof(*caps->value));
1116 caps->value->capability = i;
1117 caps->value->state = state;
1118 caps->next = NULL;
1119 qmp_migrate_set_capabilities(caps, &err);
1120 break;
1124 if (i == MIGRATION_CAPABILITY_MAX) {
1125 error_set(&err, QERR_INVALID_PARAMETER, cap);
1128 qapi_free_MigrationCapabilityStatusList(caps);
1130 if (err) {
1131 monitor_printf(mon, "migrate_set_capability: %s\n",
1132 error_get_pretty(err));
1133 error_free(err);
1137 void hmp_set_password(Monitor *mon, const QDict *qdict)
1139 const char *protocol = qdict_get_str(qdict, "protocol");
1140 const char *password = qdict_get_str(qdict, "password");
1141 const char *connected = qdict_get_try_str(qdict, "connected");
1142 Error *err = NULL;
1144 qmp_set_password(protocol, password, !!connected, connected, &err);
1145 hmp_handle_error(mon, &err);
1148 void hmp_expire_password(Monitor *mon, const QDict *qdict)
1150 const char *protocol = qdict_get_str(qdict, "protocol");
1151 const char *whenstr = qdict_get_str(qdict, "time");
1152 Error *err = NULL;
1154 qmp_expire_password(protocol, whenstr, &err);
1155 hmp_handle_error(mon, &err);
1158 void hmp_eject(Monitor *mon, const QDict *qdict)
1160 int force = qdict_get_try_bool(qdict, "force", 0);
1161 const char *device = qdict_get_str(qdict, "device");
1162 Error *err = NULL;
1164 qmp_eject(device, true, force, &err);
1165 hmp_handle_error(mon, &err);
1168 static void hmp_change_read_arg(void *opaque, const char *password,
1169 void *readline_opaque)
1171 qmp_change_vnc_password(password, NULL);
1172 monitor_read_command(opaque, 1);
1175 void hmp_change(Monitor *mon, const QDict *qdict)
1177 const char *device = qdict_get_str(qdict, "device");
1178 const char *target = qdict_get_str(qdict, "target");
1179 const char *arg = qdict_get_try_str(qdict, "arg");
1180 Error *err = NULL;
1182 if (strcmp(device, "vnc") == 0 &&
1183 (strcmp(target, "passwd") == 0 ||
1184 strcmp(target, "password") == 0)) {
1185 if (!arg) {
1186 monitor_read_password(mon, hmp_change_read_arg, NULL);
1187 return;
1191 qmp_change(device, target, !!arg, arg, &err);
1192 if (err &&
1193 error_get_class(err) == ERROR_CLASS_DEVICE_ENCRYPTED) {
1194 error_free(err);
1195 monitor_read_block_device_key(mon, device, NULL, NULL);
1196 return;
1198 hmp_handle_error(mon, &err);
1201 void hmp_block_set_io_throttle(Monitor *mon, const QDict *qdict)
1203 Error *err = NULL;
1205 qmp_block_set_io_throttle(qdict_get_str(qdict, "device"),
1206 qdict_get_int(qdict, "bps"),
1207 qdict_get_int(qdict, "bps_rd"),
1208 qdict_get_int(qdict, "bps_wr"),
1209 qdict_get_int(qdict, "iops"),
1210 qdict_get_int(qdict, "iops_rd"),
1211 qdict_get_int(qdict, "iops_wr"),
1212 false, /* no burst max via HMP */
1214 false,
1216 false,
1218 false,
1220 false,
1222 false,
1224 false, /* No default I/O size */
1225 0, &err);
1226 hmp_handle_error(mon, &err);
1229 void hmp_block_stream(Monitor *mon, const QDict *qdict)
1231 Error *error = NULL;
1232 const char *device = qdict_get_str(qdict, "device");
1233 const char *base = qdict_get_try_str(qdict, "base");
1234 int64_t speed = qdict_get_try_int(qdict, "speed", 0);
1236 qmp_block_stream(device, base != NULL, base, false, NULL,
1237 qdict_haskey(qdict, "speed"), speed,
1238 true, BLOCKDEV_ON_ERROR_REPORT, &error);
1240 hmp_handle_error(mon, &error);
1243 void hmp_block_job_set_speed(Monitor *mon, const QDict *qdict)
1245 Error *error = NULL;
1246 const char *device = qdict_get_str(qdict, "device");
1247 int64_t value = qdict_get_int(qdict, "speed");
1249 qmp_block_job_set_speed(device, value, &error);
1251 hmp_handle_error(mon, &error);
1254 void hmp_block_job_cancel(Monitor *mon, const QDict *qdict)
1256 Error *error = NULL;
1257 const char *device = qdict_get_str(qdict, "device");
1258 bool force = qdict_get_try_bool(qdict, "force", 0);
1260 qmp_block_job_cancel(device, true, force, &error);
1262 hmp_handle_error(mon, &error);
1265 void hmp_block_job_pause(Monitor *mon, const QDict *qdict)
1267 Error *error = NULL;
1268 const char *device = qdict_get_str(qdict, "device");
1270 qmp_block_job_pause(device, &error);
1272 hmp_handle_error(mon, &error);
1275 void hmp_block_job_resume(Monitor *mon, const QDict *qdict)
1277 Error *error = NULL;
1278 const char *device = qdict_get_str(qdict, "device");
1280 qmp_block_job_resume(device, &error);
1282 hmp_handle_error(mon, &error);
1285 void hmp_block_job_complete(Monitor *mon, const QDict *qdict)
1287 Error *error = NULL;
1288 const char *device = qdict_get_str(qdict, "device");
1290 qmp_block_job_complete(device, &error);
1292 hmp_handle_error(mon, &error);
1295 typedef struct MigrationStatus
1297 QEMUTimer *timer;
1298 Monitor *mon;
1299 bool is_block_migration;
1300 } MigrationStatus;
1302 static void hmp_migrate_status_cb(void *opaque)
1304 MigrationStatus *status = opaque;
1305 MigrationInfo *info;
1307 info = qmp_query_migrate(NULL);
1308 if (!info->has_status || strcmp(info->status, "active") == 0 ||
1309 strcmp(info->status, "setup") == 0) {
1310 if (info->has_disk) {
1311 int progress;
1313 if (info->disk->remaining) {
1314 progress = info->disk->transferred * 100 / info->disk->total;
1315 } else {
1316 progress = 100;
1319 monitor_printf(status->mon, "Completed %d %%\r", progress);
1320 monitor_flush(status->mon);
1323 timer_mod(status->timer, qemu_clock_get_ms(QEMU_CLOCK_REALTIME) + 1000);
1324 } else {
1325 if (status->is_block_migration) {
1326 monitor_printf(status->mon, "\n");
1328 monitor_resume(status->mon);
1329 timer_del(status->timer);
1330 g_free(status);
1333 qapi_free_MigrationInfo(info);
1336 void hmp_migrate(Monitor *mon, const QDict *qdict)
1338 int detach = qdict_get_try_bool(qdict, "detach", 0);
1339 int blk = qdict_get_try_bool(qdict, "blk", 0);
1340 int inc = qdict_get_try_bool(qdict, "inc", 0);
1341 const char *uri = qdict_get_str(qdict, "uri");
1342 Error *err = NULL;
1344 qmp_migrate(uri, !!blk, blk, !!inc, inc, false, false, &err);
1345 if (err) {
1346 monitor_printf(mon, "migrate: %s\n", error_get_pretty(err));
1347 error_free(err);
1348 return;
1351 if (!detach) {
1352 MigrationStatus *status;
1354 if (monitor_suspend(mon) < 0) {
1355 monitor_printf(mon, "terminal does not allow synchronous "
1356 "migration, continuing detached\n");
1357 return;
1360 status = g_malloc0(sizeof(*status));
1361 status->mon = mon;
1362 status->is_block_migration = blk || inc;
1363 status->timer = timer_new_ms(QEMU_CLOCK_REALTIME, hmp_migrate_status_cb,
1364 status);
1365 timer_mod(status->timer, qemu_clock_get_ms(QEMU_CLOCK_REALTIME));
1369 void hmp_device_del(Monitor *mon, const QDict *qdict)
1371 const char *id = qdict_get_str(qdict, "id");
1372 Error *err = NULL;
1374 qmp_device_del(id, &err);
1375 hmp_handle_error(mon, &err);
1378 void hmp_dump_guest_memory(Monitor *mon, const QDict *qdict)
1380 Error *err = NULL;
1381 int paging = qdict_get_try_bool(qdict, "paging", 0);
1382 int zlib = qdict_get_try_bool(qdict, "zlib", 0);
1383 int lzo = qdict_get_try_bool(qdict, "lzo", 0);
1384 int snappy = qdict_get_try_bool(qdict, "snappy", 0);
1385 const char *file = qdict_get_str(qdict, "filename");
1386 bool has_begin = qdict_haskey(qdict, "begin");
1387 bool has_length = qdict_haskey(qdict, "length");
1388 int64_t begin = 0;
1389 int64_t length = 0;
1390 enum DumpGuestMemoryFormat dump_format = DUMP_GUEST_MEMORY_FORMAT_ELF;
1391 char *prot;
1393 if (zlib + lzo + snappy > 1) {
1394 error_setg(&err, "only one of '-z|-l|-s' can be set");
1395 hmp_handle_error(mon, &err);
1396 return;
1399 if (zlib) {
1400 dump_format = DUMP_GUEST_MEMORY_FORMAT_KDUMP_ZLIB;
1403 if (lzo) {
1404 dump_format = DUMP_GUEST_MEMORY_FORMAT_KDUMP_LZO;
1407 if (snappy) {
1408 dump_format = DUMP_GUEST_MEMORY_FORMAT_KDUMP_SNAPPY;
1411 if (has_begin) {
1412 begin = qdict_get_int(qdict, "begin");
1414 if (has_length) {
1415 length = qdict_get_int(qdict, "length");
1418 prot = g_strconcat("file:", file, NULL);
1420 qmp_dump_guest_memory(paging, prot, has_begin, begin, has_length, length,
1421 true, dump_format, &err);
1422 hmp_handle_error(mon, &err);
1423 g_free(prot);
1426 void hmp_netdev_add(Monitor *mon, const QDict *qdict)
1428 Error *err = NULL;
1429 QemuOpts *opts;
1431 opts = qemu_opts_from_qdict(qemu_find_opts("netdev"), qdict, &err);
1432 if (err) {
1433 goto out;
1436 netdev_add(opts, &err);
1437 if (err) {
1438 qemu_opts_del(opts);
1441 out:
1442 hmp_handle_error(mon, &err);
1445 void hmp_netdev_del(Monitor *mon, const QDict *qdict)
1447 const char *id = qdict_get_str(qdict, "id");
1448 Error *err = NULL;
1450 qmp_netdev_del(id, &err);
1451 hmp_handle_error(mon, &err);
1454 void hmp_object_add(Monitor *mon, const QDict *qdict)
1456 Error *err = NULL;
1457 Error *err_end = NULL;
1458 QemuOpts *opts;
1459 char *type = NULL;
1460 char *id = NULL;
1461 void *dummy = NULL;
1462 OptsVisitor *ov;
1463 QDict *pdict;
1465 opts = qemu_opts_from_qdict(qemu_find_opts("object"), qdict, &err);
1466 if (err) {
1467 goto out;
1470 ov = opts_visitor_new(opts);
1471 pdict = qdict_clone_shallow(qdict);
1473 visit_start_struct(opts_get_visitor(ov), &dummy, NULL, NULL, 0, &err);
1474 if (err) {
1475 goto out_clean;
1478 qdict_del(pdict, "qom-type");
1479 visit_type_str(opts_get_visitor(ov), &type, "qom-type", &err);
1480 if (err) {
1481 goto out_end;
1484 qdict_del(pdict, "id");
1485 visit_type_str(opts_get_visitor(ov), &id, "id", &err);
1486 if (err) {
1487 goto out_end;
1490 object_add(type, id, pdict, opts_get_visitor(ov), &err);
1492 out_end:
1493 visit_end_struct(opts_get_visitor(ov), &err_end);
1494 if (!err && err_end) {
1495 qmp_object_del(id, NULL);
1497 error_propagate(&err, err_end);
1498 out_clean:
1499 opts_visitor_cleanup(ov);
1501 QDECREF(pdict);
1502 qemu_opts_del(opts);
1503 g_free(id);
1504 g_free(type);
1505 g_free(dummy);
1507 out:
1508 hmp_handle_error(mon, &err);
1511 void hmp_getfd(Monitor *mon, const QDict *qdict)
1513 const char *fdname = qdict_get_str(qdict, "fdname");
1514 Error *err = NULL;
1516 qmp_getfd(fdname, &err);
1517 hmp_handle_error(mon, &err);
1520 void hmp_closefd(Monitor *mon, const QDict *qdict)
1522 const char *fdname = qdict_get_str(qdict, "fdname");
1523 Error *err = NULL;
1525 qmp_closefd(fdname, &err);
1526 hmp_handle_error(mon, &err);
1529 void hmp_send_key(Monitor *mon, const QDict *qdict)
1531 const char *keys = qdict_get_str(qdict, "keys");
1532 KeyValueList *keylist, *head = NULL, *tmp = NULL;
1533 int has_hold_time = qdict_haskey(qdict, "hold-time");
1534 int hold_time = qdict_get_try_int(qdict, "hold-time", -1);
1535 Error *err = NULL;
1536 char keyname_buf[16];
1537 char *separator;
1538 int keyname_len;
1540 while (1) {
1541 separator = strchr(keys, '-');
1542 keyname_len = separator ? separator - keys : strlen(keys);
1543 pstrcpy(keyname_buf, sizeof(keyname_buf), keys);
1545 /* Be compatible with old interface, convert user inputted "<" */
1546 if (!strncmp(keyname_buf, "<", 1) && keyname_len == 1) {
1547 pstrcpy(keyname_buf, sizeof(keyname_buf), "less");
1548 keyname_len = 4;
1550 keyname_buf[keyname_len] = 0;
1552 keylist = g_malloc0(sizeof(*keylist));
1553 keylist->value = g_malloc0(sizeof(*keylist->value));
1555 if (!head) {
1556 head = keylist;
1558 if (tmp) {
1559 tmp->next = keylist;
1561 tmp = keylist;
1563 if (strstart(keyname_buf, "0x", NULL)) {
1564 char *endp;
1565 int value = strtoul(keyname_buf, &endp, 0);
1566 if (*endp != '\0') {
1567 goto err_out;
1569 keylist->value->kind = KEY_VALUE_KIND_NUMBER;
1570 keylist->value->number = value;
1571 } else {
1572 int idx = index_from_key(keyname_buf);
1573 if (idx == Q_KEY_CODE_MAX) {
1574 goto err_out;
1576 keylist->value->kind = KEY_VALUE_KIND_QCODE;
1577 keylist->value->qcode = idx;
1580 if (!separator) {
1581 break;
1583 keys = separator + 1;
1586 qmp_send_key(head, has_hold_time, hold_time, &err);
1587 hmp_handle_error(mon, &err);
1589 out:
1590 qapi_free_KeyValueList(head);
1591 return;
1593 err_out:
1594 monitor_printf(mon, "invalid parameter: %s\n", keyname_buf);
1595 goto out;
1598 void hmp_screen_dump(Monitor *mon, const QDict *qdict)
1600 const char *filename = qdict_get_str(qdict, "filename");
1601 Error *err = NULL;
1603 qmp_screendump(filename, &err);
1604 hmp_handle_error(mon, &err);
1607 void hmp_nbd_server_start(Monitor *mon, const QDict *qdict)
1609 const char *uri = qdict_get_str(qdict, "uri");
1610 int writable = qdict_get_try_bool(qdict, "writable", 0);
1611 int all = qdict_get_try_bool(qdict, "all", 0);
1612 Error *local_err = NULL;
1613 BlockInfoList *block_list, *info;
1614 SocketAddress *addr;
1616 if (writable && !all) {
1617 error_setg(&local_err, "-w only valid together with -a");
1618 goto exit;
1621 /* First check if the address is valid and start the server. */
1622 addr = socket_parse(uri, &local_err);
1623 if (local_err != NULL) {
1624 goto exit;
1627 qmp_nbd_server_start(addr, &local_err);
1628 qapi_free_SocketAddress(addr);
1629 if (local_err != NULL) {
1630 goto exit;
1633 if (!all) {
1634 return;
1637 /* Then try adding all block devices. If one fails, close all and
1638 * exit.
1640 block_list = qmp_query_block(NULL);
1642 for (info = block_list; info; info = info->next) {
1643 if (!info->value->has_inserted) {
1644 continue;
1647 qmp_nbd_server_add(info->value->device, true, writable, &local_err);
1649 if (local_err != NULL) {
1650 qmp_nbd_server_stop(NULL);
1651 break;
1655 qapi_free_BlockInfoList(block_list);
1657 exit:
1658 hmp_handle_error(mon, &local_err);
1661 void hmp_nbd_server_add(Monitor *mon, const QDict *qdict)
1663 const char *device = qdict_get_str(qdict, "device");
1664 int writable = qdict_get_try_bool(qdict, "writable", 0);
1665 Error *local_err = NULL;
1667 qmp_nbd_server_add(device, true, writable, &local_err);
1669 if (local_err != NULL) {
1670 hmp_handle_error(mon, &local_err);
1674 void hmp_nbd_server_stop(Monitor *mon, const QDict *qdict)
1676 Error *err = NULL;
1678 qmp_nbd_server_stop(&err);
1679 hmp_handle_error(mon, &err);
1682 void hmp_cpu_add(Monitor *mon, const QDict *qdict)
1684 int cpuid;
1685 Error *err = NULL;
1687 cpuid = qdict_get_int(qdict, "id");
1688 qmp_cpu_add(cpuid, &err);
1689 hmp_handle_error(mon, &err);
1692 void hmp_chardev_add(Monitor *mon, const QDict *qdict)
1694 const char *args = qdict_get_str(qdict, "args");
1695 Error *err = NULL;
1696 QemuOpts *opts;
1698 opts = qemu_opts_parse(qemu_find_opts("chardev"), args, 1);
1699 if (opts == NULL) {
1700 error_setg(&err, "Parsing chardev args failed");
1701 } else {
1702 qemu_chr_new_from_opts(opts, NULL, &err);
1704 hmp_handle_error(mon, &err);
1707 void hmp_chardev_remove(Monitor *mon, const QDict *qdict)
1709 Error *local_err = NULL;
1711 qmp_chardev_remove(qdict_get_str(qdict, "id"), &local_err);
1712 hmp_handle_error(mon, &local_err);
1715 void hmp_qemu_io(Monitor *mon, const QDict *qdict)
1717 BlockDriverState *bs;
1718 const char* device = qdict_get_str(qdict, "device");
1719 const char* command = qdict_get_str(qdict, "command");
1720 Error *err = NULL;
1722 bs = bdrv_find(device);
1723 if (bs) {
1724 qemuio_command(bs, command);
1725 } else {
1726 error_set(&err, QERR_DEVICE_NOT_FOUND, device);
1729 hmp_handle_error(mon, &err);
1732 void hmp_object_del(Monitor *mon, const QDict *qdict)
1734 const char *id = qdict_get_str(qdict, "id");
1735 Error *err = NULL;
1737 qmp_object_del(id, &err);
1738 hmp_handle_error(mon, &err);
1741 void hmp_info_memdev(Monitor *mon, const QDict *qdict)
1743 Error *err = NULL;
1744 MemdevList *memdev_list = qmp_query_memdev(&err);
1745 MemdevList *m = memdev_list;
1746 StringOutputVisitor *ov;
1747 char *str;
1748 int i = 0;
1751 while (m) {
1752 ov = string_output_visitor_new(false);
1753 visit_type_uint16List(string_output_get_visitor(ov),
1754 &m->value->host_nodes, NULL, NULL);
1755 monitor_printf(mon, "memory backend: %d\n", i);
1756 monitor_printf(mon, " size: %" PRId64 "\n", m->value->size);
1757 monitor_printf(mon, " merge: %s\n",
1758 m->value->merge ? "true" : "false");
1759 monitor_printf(mon, " dump: %s\n",
1760 m->value->dump ? "true" : "false");
1761 monitor_printf(mon, " prealloc: %s\n",
1762 m->value->prealloc ? "true" : "false");
1763 monitor_printf(mon, " policy: %s\n",
1764 HostMemPolicy_lookup[m->value->policy]);
1765 str = string_output_get_string(ov);
1766 monitor_printf(mon, " host nodes: %s\n", str);
1768 g_free(str);
1769 string_output_visitor_cleanup(ov);
1770 m = m->next;
1771 i++;
1774 monitor_printf(mon, "\n");
1776 qapi_free_MemdevList(memdev_list);
1779 void hmp_info_memory_devices(Monitor *mon, const QDict *qdict)
1781 Error *err = NULL;
1782 MemoryDeviceInfoList *info_list = qmp_query_memory_devices(&err);
1783 MemoryDeviceInfoList *info;
1784 MemoryDeviceInfo *value;
1785 PCDIMMDeviceInfo *di;
1787 for (info = info_list; info; info = info->next) {
1788 value = info->value;
1790 if (value) {
1791 switch (value->kind) {
1792 case MEMORY_DEVICE_INFO_KIND_DIMM:
1793 di = value->dimm;
1795 monitor_printf(mon, "Memory device [%s]: \"%s\"\n",
1796 MemoryDeviceInfoKind_lookup[value->kind],
1797 di->id ? di->id : "");
1798 monitor_printf(mon, " addr: 0x%" PRIx64 "\n", di->addr);
1799 monitor_printf(mon, " slot: %" PRId64 "\n", di->slot);
1800 monitor_printf(mon, " node: %" PRId64 "\n", di->node);
1801 monitor_printf(mon, " size: %" PRIu64 "\n", di->size);
1802 monitor_printf(mon, " memdev: %s\n", di->memdev);
1803 monitor_printf(mon, " hotplugged: %s\n",
1804 di->hotplugged ? "true" : "false");
1805 monitor_printf(mon, " hotpluggable: %s\n",
1806 di->hotpluggable ? "true" : "false");
1807 break;
1808 default:
1809 break;
1814 qapi_free_MemoryDeviceInfoList(info_list);