rcu: add g_free_rcu
[qemu/rayw.git] / hmp.c
bloba42c5c07be8d0138bb3336c6285675dd400a9c46
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 #ifdef CONFIG_SPICE
539 void hmp_info_spice(Monitor *mon, const QDict *qdict)
541 SpiceChannelList *chan;
542 SpiceInfo *info;
544 info = qmp_query_spice(NULL);
546 if (!info->enabled) {
547 monitor_printf(mon, "Server: disabled\n");
548 goto out;
551 monitor_printf(mon, "Server:\n");
552 if (info->has_port) {
553 monitor_printf(mon, " address: %s:%" PRId64 "\n",
554 info->host, info->port);
556 if (info->has_tls_port) {
557 monitor_printf(mon, " address: %s:%" PRId64 " [tls]\n",
558 info->host, info->tls_port);
560 monitor_printf(mon, " migrated: %s\n",
561 info->migrated ? "true" : "false");
562 monitor_printf(mon, " auth: %s\n", info->auth);
563 monitor_printf(mon, " compiled: %s\n", info->compiled_version);
564 monitor_printf(mon, " mouse-mode: %s\n",
565 SpiceQueryMouseMode_lookup[info->mouse_mode]);
567 if (!info->has_channels || info->channels == NULL) {
568 monitor_printf(mon, "Channels: none\n");
569 } else {
570 for (chan = info->channels; chan; chan = chan->next) {
571 monitor_printf(mon, "Channel:\n");
572 monitor_printf(mon, " address: %s:%s%s\n",
573 chan->value->base->host, chan->value->base->port,
574 chan->value->tls ? " [tls]" : "");
575 monitor_printf(mon, " session: %" PRId64 "\n",
576 chan->value->connection_id);
577 monitor_printf(mon, " channel: %" PRId64 ":%" PRId64 "\n",
578 chan->value->channel_type, chan->value->channel_id);
582 out:
583 qapi_free_SpiceInfo(info);
585 #endif
587 void hmp_info_balloon(Monitor *mon, const QDict *qdict)
589 BalloonInfo *info;
590 Error *err = NULL;
592 info = qmp_query_balloon(&err);
593 if (err) {
594 monitor_printf(mon, "%s\n", error_get_pretty(err));
595 error_free(err);
596 return;
599 monitor_printf(mon, "balloon: actual=%" PRId64 "\n", info->actual >> 20);
601 qapi_free_BalloonInfo(info);
604 static void hmp_info_pci_device(Monitor *mon, const PciDeviceInfo *dev)
606 PciMemoryRegionList *region;
608 monitor_printf(mon, " Bus %2" PRId64 ", ", dev->bus);
609 monitor_printf(mon, "device %3" PRId64 ", function %" PRId64 ":\n",
610 dev->slot, dev->function);
611 monitor_printf(mon, " ");
613 if (dev->class_info.has_desc) {
614 monitor_printf(mon, "%s", dev->class_info.desc);
615 } else {
616 monitor_printf(mon, "Class %04" PRId64, dev->class_info.q_class);
619 monitor_printf(mon, ": PCI device %04" PRIx64 ":%04" PRIx64 "\n",
620 dev->id.vendor, dev->id.device);
622 if (dev->has_irq) {
623 monitor_printf(mon, " IRQ %" PRId64 ".\n", dev->irq);
626 if (dev->has_pci_bridge) {
627 monitor_printf(mon, " BUS %" PRId64 ".\n",
628 dev->pci_bridge->bus.number);
629 monitor_printf(mon, " secondary bus %" PRId64 ".\n",
630 dev->pci_bridge->bus.secondary);
631 monitor_printf(mon, " subordinate bus %" PRId64 ".\n",
632 dev->pci_bridge->bus.subordinate);
634 monitor_printf(mon, " IO range [0x%04"PRIx64", 0x%04"PRIx64"]\n",
635 dev->pci_bridge->bus.io_range->base,
636 dev->pci_bridge->bus.io_range->limit);
638 monitor_printf(mon,
639 " memory range [0x%08"PRIx64", 0x%08"PRIx64"]\n",
640 dev->pci_bridge->bus.memory_range->base,
641 dev->pci_bridge->bus.memory_range->limit);
643 monitor_printf(mon, " prefetchable memory range "
644 "[0x%08"PRIx64", 0x%08"PRIx64"]\n",
645 dev->pci_bridge->bus.prefetchable_range->base,
646 dev->pci_bridge->bus.prefetchable_range->limit);
649 for (region = dev->regions; region; region = region->next) {
650 uint64_t addr, size;
652 addr = region->value->address;
653 size = region->value->size;
655 monitor_printf(mon, " BAR%" PRId64 ": ", region->value->bar);
657 if (!strcmp(region->value->type, "io")) {
658 monitor_printf(mon, "I/O at 0x%04" PRIx64
659 " [0x%04" PRIx64 "].\n",
660 addr, addr + size - 1);
661 } else {
662 monitor_printf(mon, "%d bit%s memory at 0x%08" PRIx64
663 " [0x%08" PRIx64 "].\n",
664 region->value->mem_type_64 ? 64 : 32,
665 region->value->prefetch ? " prefetchable" : "",
666 addr, addr + size - 1);
670 monitor_printf(mon, " id \"%s\"\n", dev->qdev_id);
672 if (dev->has_pci_bridge) {
673 if (dev->pci_bridge->has_devices) {
674 PciDeviceInfoList *cdev;
675 for (cdev = dev->pci_bridge->devices; cdev; cdev = cdev->next) {
676 hmp_info_pci_device(mon, cdev->value);
682 void hmp_info_pci(Monitor *mon, const QDict *qdict)
684 PciInfoList *info_list, *info;
685 Error *err = NULL;
687 info_list = qmp_query_pci(&err);
688 if (err) {
689 monitor_printf(mon, "PCI devices not supported\n");
690 error_free(err);
691 return;
694 for (info = info_list; info; info = info->next) {
695 PciDeviceInfoList *dev;
697 for (dev = info->value->devices; dev; dev = dev->next) {
698 hmp_info_pci_device(mon, dev->value);
702 qapi_free_PciInfoList(info_list);
705 void hmp_info_block_jobs(Monitor *mon, const QDict *qdict)
707 BlockJobInfoList *list;
708 Error *err = NULL;
710 list = qmp_query_block_jobs(&err);
711 assert(!err);
713 if (!list) {
714 monitor_printf(mon, "No active jobs\n");
715 return;
718 while (list) {
719 if (strcmp(list->value->type, "stream") == 0) {
720 monitor_printf(mon, "Streaming device %s: Completed %" PRId64
721 " of %" PRId64 " bytes, speed limit %" PRId64
722 " bytes/s\n",
723 list->value->device,
724 list->value->offset,
725 list->value->len,
726 list->value->speed);
727 } else {
728 monitor_printf(mon, "Type %s, device %s: Completed %" PRId64
729 " of %" PRId64 " bytes, speed limit %" PRId64
730 " bytes/s\n",
731 list->value->type,
732 list->value->device,
733 list->value->offset,
734 list->value->len,
735 list->value->speed);
737 list = list->next;
740 qapi_free_BlockJobInfoList(list);
743 void hmp_info_tpm(Monitor *mon, const QDict *qdict)
745 TPMInfoList *info_list, *info;
746 Error *err = NULL;
747 unsigned int c = 0;
748 TPMPassthroughOptions *tpo;
750 info_list = qmp_query_tpm(&err);
751 if (err) {
752 monitor_printf(mon, "TPM device not supported\n");
753 error_free(err);
754 return;
757 if (info_list) {
758 monitor_printf(mon, "TPM device:\n");
761 for (info = info_list; info; info = info->next) {
762 TPMInfo *ti = info->value;
763 monitor_printf(mon, " tpm%d: model=%s\n",
764 c, TpmModel_lookup[ti->model]);
766 monitor_printf(mon, " \\ %s: type=%s",
767 ti->id, TpmTypeOptionsKind_lookup[ti->options->kind]);
769 switch (ti->options->kind) {
770 case TPM_TYPE_OPTIONS_KIND_PASSTHROUGH:
771 tpo = ti->options->passthrough;
772 monitor_printf(mon, "%s%s%s%s",
773 tpo->has_path ? ",path=" : "",
774 tpo->has_path ? tpo->path : "",
775 tpo->has_cancel_path ? ",cancel-path=" : "",
776 tpo->has_cancel_path ? tpo->cancel_path : "");
777 break;
778 case TPM_TYPE_OPTIONS_KIND_MAX:
779 break;
781 monitor_printf(mon, "\n");
782 c++;
784 qapi_free_TPMInfoList(info_list);
787 void hmp_quit(Monitor *mon, const QDict *qdict)
789 monitor_suspend(mon);
790 qmp_quit(NULL);
793 void hmp_stop(Monitor *mon, const QDict *qdict)
795 qmp_stop(NULL);
798 void hmp_system_reset(Monitor *mon, const QDict *qdict)
800 qmp_system_reset(NULL);
803 void hmp_system_powerdown(Monitor *mon, const QDict *qdict)
805 qmp_system_powerdown(NULL);
808 void hmp_cpu(Monitor *mon, const QDict *qdict)
810 int64_t cpu_index;
812 /* XXX: drop the monitor_set_cpu() usage when all HMP commands that
813 use it are converted to the QAPI */
814 cpu_index = qdict_get_int(qdict, "index");
815 if (monitor_set_cpu(cpu_index) < 0) {
816 monitor_printf(mon, "invalid CPU index\n");
820 void hmp_memsave(Monitor *mon, const QDict *qdict)
822 uint32_t size = qdict_get_int(qdict, "size");
823 const char *filename = qdict_get_str(qdict, "filename");
824 uint64_t addr = qdict_get_int(qdict, "val");
825 Error *err = NULL;
827 qmp_memsave(addr, size, filename, true, monitor_get_cpu_index(), &err);
828 hmp_handle_error(mon, &err);
831 void hmp_pmemsave(Monitor *mon, const QDict *qdict)
833 uint32_t size = qdict_get_int(qdict, "size");
834 const char *filename = qdict_get_str(qdict, "filename");
835 uint64_t addr = qdict_get_int(qdict, "val");
836 Error *err = NULL;
838 qmp_pmemsave(addr, size, filename, &err);
839 hmp_handle_error(mon, &err);
842 void hmp_ringbuf_write(Monitor *mon, const QDict *qdict)
844 const char *chardev = qdict_get_str(qdict, "device");
845 const char *data = qdict_get_str(qdict, "data");
846 Error *err = NULL;
848 qmp_ringbuf_write(chardev, data, false, 0, &err);
850 hmp_handle_error(mon, &err);
853 void hmp_ringbuf_read(Monitor *mon, const QDict *qdict)
855 uint32_t size = qdict_get_int(qdict, "size");
856 const char *chardev = qdict_get_str(qdict, "device");
857 char *data;
858 Error *err = NULL;
859 int i;
861 data = qmp_ringbuf_read(chardev, size, false, 0, &err);
862 if (err) {
863 monitor_printf(mon, "%s\n", error_get_pretty(err));
864 error_free(err);
865 return;
868 for (i = 0; data[i]; i++) {
869 unsigned char ch = data[i];
871 if (ch == '\\') {
872 monitor_printf(mon, "\\\\");
873 } else if ((ch < 0x20 && ch != '\n' && ch != '\t') || ch == 0x7F) {
874 monitor_printf(mon, "\\u%04X", ch);
875 } else {
876 monitor_printf(mon, "%c", ch);
880 monitor_printf(mon, "\n");
881 g_free(data);
884 static void hmp_cont_cb(void *opaque, int err)
886 if (!err) {
887 qmp_cont(NULL);
891 static bool key_is_missing(const BlockInfo *bdev)
893 return (bdev->inserted && bdev->inserted->encryption_key_missing);
896 void hmp_cont(Monitor *mon, const QDict *qdict)
898 BlockInfoList *bdev_list, *bdev;
899 Error *err = NULL;
901 bdev_list = qmp_query_block(NULL);
902 for (bdev = bdev_list; bdev; bdev = bdev->next) {
903 if (key_is_missing(bdev->value)) {
904 monitor_read_block_device_key(mon, bdev->value->device,
905 hmp_cont_cb, NULL);
906 goto out;
910 qmp_cont(&err);
911 hmp_handle_error(mon, &err);
913 out:
914 qapi_free_BlockInfoList(bdev_list);
917 void hmp_system_wakeup(Monitor *mon, const QDict *qdict)
919 qmp_system_wakeup(NULL);
922 void hmp_inject_nmi(Monitor *mon, const QDict *qdict)
924 Error *err = NULL;
926 qmp_inject_nmi(&err);
927 hmp_handle_error(mon, &err);
930 void hmp_set_link(Monitor *mon, const QDict *qdict)
932 const char *name = qdict_get_str(qdict, "name");
933 int up = qdict_get_bool(qdict, "up");
934 Error *err = NULL;
936 qmp_set_link(name, up, &err);
937 hmp_handle_error(mon, &err);
940 void hmp_block_passwd(Monitor *mon, const QDict *qdict)
942 const char *device = qdict_get_str(qdict, "device");
943 const char *password = qdict_get_str(qdict, "password");
944 Error *err = NULL;
946 qmp_block_passwd(true, device, false, NULL, password, &err);
947 hmp_handle_error(mon, &err);
950 void hmp_balloon(Monitor *mon, const QDict *qdict)
952 int64_t value = qdict_get_int(qdict, "value");
953 Error *err = NULL;
955 qmp_balloon(value, &err);
956 if (err) {
957 monitor_printf(mon, "balloon: %s\n", error_get_pretty(err));
958 error_free(err);
962 void hmp_block_resize(Monitor *mon, const QDict *qdict)
964 const char *device = qdict_get_str(qdict, "device");
965 int64_t size = qdict_get_int(qdict, "size");
966 Error *err = NULL;
968 qmp_block_resize(true, device, false, NULL, size, &err);
969 hmp_handle_error(mon, &err);
972 void hmp_drive_mirror(Monitor *mon, const QDict *qdict)
974 const char *device = qdict_get_str(qdict, "device");
975 const char *filename = qdict_get_str(qdict, "target");
976 const char *format = qdict_get_try_str(qdict, "format");
977 int reuse = qdict_get_try_bool(qdict, "reuse", 0);
978 int full = qdict_get_try_bool(qdict, "full", 0);
979 enum NewImageMode mode;
980 Error *err = NULL;
982 if (!filename) {
983 error_set(&err, QERR_MISSING_PARAMETER, "target");
984 hmp_handle_error(mon, &err);
985 return;
988 if (reuse) {
989 mode = NEW_IMAGE_MODE_EXISTING;
990 } else {
991 mode = NEW_IMAGE_MODE_ABSOLUTE_PATHS;
994 qmp_drive_mirror(device, filename, !!format, format,
995 false, NULL, false, NULL,
996 full ? MIRROR_SYNC_MODE_FULL : MIRROR_SYNC_MODE_TOP,
997 true, mode, false, 0, false, 0, false, 0,
998 false, 0, false, 0, &err);
999 hmp_handle_error(mon, &err);
1002 void hmp_drive_backup(Monitor *mon, const QDict *qdict)
1004 const char *device = qdict_get_str(qdict, "device");
1005 const char *filename = qdict_get_str(qdict, "target");
1006 const char *format = qdict_get_try_str(qdict, "format");
1007 int reuse = qdict_get_try_bool(qdict, "reuse", 0);
1008 int full = qdict_get_try_bool(qdict, "full", 0);
1009 enum NewImageMode mode;
1010 Error *err = NULL;
1012 if (!filename) {
1013 error_set(&err, QERR_MISSING_PARAMETER, "target");
1014 hmp_handle_error(mon, &err);
1015 return;
1018 if (reuse) {
1019 mode = NEW_IMAGE_MODE_EXISTING;
1020 } else {
1021 mode = NEW_IMAGE_MODE_ABSOLUTE_PATHS;
1024 qmp_drive_backup(device, filename, !!format, format,
1025 full ? MIRROR_SYNC_MODE_FULL : MIRROR_SYNC_MODE_TOP,
1026 true, mode, false, 0, false, 0, false, 0, &err);
1027 hmp_handle_error(mon, &err);
1030 void hmp_snapshot_blkdev(Monitor *mon, const QDict *qdict)
1032 const char *device = qdict_get_str(qdict, "device");
1033 const char *filename = qdict_get_try_str(qdict, "snapshot-file");
1034 const char *format = qdict_get_try_str(qdict, "format");
1035 int reuse = qdict_get_try_bool(qdict, "reuse", 0);
1036 enum NewImageMode mode;
1037 Error *err = NULL;
1039 if (!filename) {
1040 /* In the future, if 'snapshot-file' is not specified, the snapshot
1041 will be taken internally. Today it's actually required. */
1042 error_set(&err, QERR_MISSING_PARAMETER, "snapshot-file");
1043 hmp_handle_error(mon, &err);
1044 return;
1047 mode = reuse ? NEW_IMAGE_MODE_EXISTING : NEW_IMAGE_MODE_ABSOLUTE_PATHS;
1048 qmp_blockdev_snapshot_sync(true, device, false, NULL,
1049 filename, false, NULL,
1050 !!format, format,
1051 true, mode, &err);
1052 hmp_handle_error(mon, &err);
1055 void hmp_snapshot_blkdev_internal(Monitor *mon, const QDict *qdict)
1057 const char *device = qdict_get_str(qdict, "device");
1058 const char *name = qdict_get_str(qdict, "name");
1059 Error *err = NULL;
1061 qmp_blockdev_snapshot_internal_sync(device, name, &err);
1062 hmp_handle_error(mon, &err);
1065 void hmp_snapshot_delete_blkdev_internal(Monitor *mon, const QDict *qdict)
1067 const char *device = qdict_get_str(qdict, "device");
1068 const char *name = qdict_get_str(qdict, "name");
1069 const char *id = qdict_get_try_str(qdict, "id");
1070 Error *err = NULL;
1072 qmp_blockdev_snapshot_delete_internal_sync(device, !!id, id,
1073 true, name, &err);
1074 hmp_handle_error(mon, &err);
1077 void hmp_migrate_cancel(Monitor *mon, const QDict *qdict)
1079 qmp_migrate_cancel(NULL);
1082 void hmp_migrate_set_downtime(Monitor *mon, const QDict *qdict)
1084 double value = qdict_get_double(qdict, "value");
1085 qmp_migrate_set_downtime(value, NULL);
1088 void hmp_migrate_set_cache_size(Monitor *mon, const QDict *qdict)
1090 int64_t value = qdict_get_int(qdict, "value");
1091 Error *err = NULL;
1093 qmp_migrate_set_cache_size(value, &err);
1094 if (err) {
1095 monitor_printf(mon, "%s\n", error_get_pretty(err));
1096 error_free(err);
1097 return;
1101 void hmp_migrate_set_speed(Monitor *mon, const QDict *qdict)
1103 int64_t value = qdict_get_int(qdict, "value");
1104 qmp_migrate_set_speed(value, NULL);
1107 void hmp_migrate_set_capability(Monitor *mon, const QDict *qdict)
1109 const char *cap = qdict_get_str(qdict, "capability");
1110 bool state = qdict_get_bool(qdict, "state");
1111 Error *err = NULL;
1112 MigrationCapabilityStatusList *caps = g_malloc0(sizeof(*caps));
1113 int i;
1115 for (i = 0; i < MIGRATION_CAPABILITY_MAX; i++) {
1116 if (strcmp(cap, MigrationCapability_lookup[i]) == 0) {
1117 caps->value = g_malloc0(sizeof(*caps->value));
1118 caps->value->capability = i;
1119 caps->value->state = state;
1120 caps->next = NULL;
1121 qmp_migrate_set_capabilities(caps, &err);
1122 break;
1126 if (i == MIGRATION_CAPABILITY_MAX) {
1127 error_set(&err, QERR_INVALID_PARAMETER, cap);
1130 qapi_free_MigrationCapabilityStatusList(caps);
1132 if (err) {
1133 monitor_printf(mon, "migrate_set_capability: %s\n",
1134 error_get_pretty(err));
1135 error_free(err);
1139 void hmp_set_password(Monitor *mon, const QDict *qdict)
1141 const char *protocol = qdict_get_str(qdict, "protocol");
1142 const char *password = qdict_get_str(qdict, "password");
1143 const char *connected = qdict_get_try_str(qdict, "connected");
1144 Error *err = NULL;
1146 qmp_set_password(protocol, password, !!connected, connected, &err);
1147 hmp_handle_error(mon, &err);
1150 void hmp_expire_password(Monitor *mon, const QDict *qdict)
1152 const char *protocol = qdict_get_str(qdict, "protocol");
1153 const char *whenstr = qdict_get_str(qdict, "time");
1154 Error *err = NULL;
1156 qmp_expire_password(protocol, whenstr, &err);
1157 hmp_handle_error(mon, &err);
1160 void hmp_eject(Monitor *mon, const QDict *qdict)
1162 int force = qdict_get_try_bool(qdict, "force", 0);
1163 const char *device = qdict_get_str(qdict, "device");
1164 Error *err = NULL;
1166 qmp_eject(device, true, force, &err);
1167 hmp_handle_error(mon, &err);
1170 static void hmp_change_read_arg(void *opaque, const char *password,
1171 void *readline_opaque)
1173 qmp_change_vnc_password(password, NULL);
1174 monitor_read_command(opaque, 1);
1177 void hmp_change(Monitor *mon, const QDict *qdict)
1179 const char *device = qdict_get_str(qdict, "device");
1180 const char *target = qdict_get_str(qdict, "target");
1181 const char *arg = qdict_get_try_str(qdict, "arg");
1182 Error *err = NULL;
1184 if (strcmp(device, "vnc") == 0 &&
1185 (strcmp(target, "passwd") == 0 ||
1186 strcmp(target, "password") == 0)) {
1187 if (!arg) {
1188 monitor_read_password(mon, hmp_change_read_arg, NULL);
1189 return;
1193 qmp_change(device, target, !!arg, arg, &err);
1194 if (err &&
1195 error_get_class(err) == ERROR_CLASS_DEVICE_ENCRYPTED) {
1196 error_free(err);
1197 monitor_read_block_device_key(mon, device, NULL, NULL);
1198 return;
1200 hmp_handle_error(mon, &err);
1203 void hmp_block_set_io_throttle(Monitor *mon, const QDict *qdict)
1205 Error *err = NULL;
1207 qmp_block_set_io_throttle(qdict_get_str(qdict, "device"),
1208 qdict_get_int(qdict, "bps"),
1209 qdict_get_int(qdict, "bps_rd"),
1210 qdict_get_int(qdict, "bps_wr"),
1211 qdict_get_int(qdict, "iops"),
1212 qdict_get_int(qdict, "iops_rd"),
1213 qdict_get_int(qdict, "iops_wr"),
1214 false, /* no burst max via HMP */
1216 false,
1218 false,
1220 false,
1222 false,
1224 false,
1226 false, /* No default I/O size */
1227 0, &err);
1228 hmp_handle_error(mon, &err);
1231 void hmp_block_stream(Monitor *mon, const QDict *qdict)
1233 Error *error = NULL;
1234 const char *device = qdict_get_str(qdict, "device");
1235 const char *base = qdict_get_try_str(qdict, "base");
1236 int64_t speed = qdict_get_try_int(qdict, "speed", 0);
1238 qmp_block_stream(device, base != NULL, base, false, NULL,
1239 qdict_haskey(qdict, "speed"), speed,
1240 true, BLOCKDEV_ON_ERROR_REPORT, &error);
1242 hmp_handle_error(mon, &error);
1245 void hmp_block_job_set_speed(Monitor *mon, const QDict *qdict)
1247 Error *error = NULL;
1248 const char *device = qdict_get_str(qdict, "device");
1249 int64_t value = qdict_get_int(qdict, "speed");
1251 qmp_block_job_set_speed(device, value, &error);
1253 hmp_handle_error(mon, &error);
1256 void hmp_block_job_cancel(Monitor *mon, const QDict *qdict)
1258 Error *error = NULL;
1259 const char *device = qdict_get_str(qdict, "device");
1260 bool force = qdict_get_try_bool(qdict, "force", 0);
1262 qmp_block_job_cancel(device, true, force, &error);
1264 hmp_handle_error(mon, &error);
1267 void hmp_block_job_pause(Monitor *mon, const QDict *qdict)
1269 Error *error = NULL;
1270 const char *device = qdict_get_str(qdict, "device");
1272 qmp_block_job_pause(device, &error);
1274 hmp_handle_error(mon, &error);
1277 void hmp_block_job_resume(Monitor *mon, const QDict *qdict)
1279 Error *error = NULL;
1280 const char *device = qdict_get_str(qdict, "device");
1282 qmp_block_job_resume(device, &error);
1284 hmp_handle_error(mon, &error);
1287 void hmp_block_job_complete(Monitor *mon, const QDict *qdict)
1289 Error *error = NULL;
1290 const char *device = qdict_get_str(qdict, "device");
1292 qmp_block_job_complete(device, &error);
1294 hmp_handle_error(mon, &error);
1297 typedef struct MigrationStatus
1299 QEMUTimer *timer;
1300 Monitor *mon;
1301 bool is_block_migration;
1302 } MigrationStatus;
1304 static void hmp_migrate_status_cb(void *opaque)
1306 MigrationStatus *status = opaque;
1307 MigrationInfo *info;
1309 info = qmp_query_migrate(NULL);
1310 if (!info->has_status || strcmp(info->status, "active") == 0 ||
1311 strcmp(info->status, "setup") == 0) {
1312 if (info->has_disk) {
1313 int progress;
1315 if (info->disk->remaining) {
1316 progress = info->disk->transferred * 100 / info->disk->total;
1317 } else {
1318 progress = 100;
1321 monitor_printf(status->mon, "Completed %d %%\r", progress);
1322 monitor_flush(status->mon);
1325 timer_mod(status->timer, qemu_clock_get_ms(QEMU_CLOCK_REALTIME) + 1000);
1326 } else {
1327 if (status->is_block_migration) {
1328 monitor_printf(status->mon, "\n");
1330 monitor_resume(status->mon);
1331 timer_del(status->timer);
1332 g_free(status);
1335 qapi_free_MigrationInfo(info);
1338 void hmp_migrate(Monitor *mon, const QDict *qdict)
1340 int detach = qdict_get_try_bool(qdict, "detach", 0);
1341 int blk = qdict_get_try_bool(qdict, "blk", 0);
1342 int inc = qdict_get_try_bool(qdict, "inc", 0);
1343 const char *uri = qdict_get_str(qdict, "uri");
1344 Error *err = NULL;
1346 qmp_migrate(uri, !!blk, blk, !!inc, inc, false, false, &err);
1347 if (err) {
1348 monitor_printf(mon, "migrate: %s\n", error_get_pretty(err));
1349 error_free(err);
1350 return;
1353 if (!detach) {
1354 MigrationStatus *status;
1356 if (monitor_suspend(mon) < 0) {
1357 monitor_printf(mon, "terminal does not allow synchronous "
1358 "migration, continuing detached\n");
1359 return;
1362 status = g_malloc0(sizeof(*status));
1363 status->mon = mon;
1364 status->is_block_migration = blk || inc;
1365 status->timer = timer_new_ms(QEMU_CLOCK_REALTIME, hmp_migrate_status_cb,
1366 status);
1367 timer_mod(status->timer, qemu_clock_get_ms(QEMU_CLOCK_REALTIME));
1371 void hmp_device_del(Monitor *mon, const QDict *qdict)
1373 const char *id = qdict_get_str(qdict, "id");
1374 Error *err = NULL;
1376 qmp_device_del(id, &err);
1377 hmp_handle_error(mon, &err);
1380 void hmp_dump_guest_memory(Monitor *mon, const QDict *qdict)
1382 Error *err = NULL;
1383 int paging = qdict_get_try_bool(qdict, "paging", 0);
1384 int zlib = qdict_get_try_bool(qdict, "zlib", 0);
1385 int lzo = qdict_get_try_bool(qdict, "lzo", 0);
1386 int snappy = qdict_get_try_bool(qdict, "snappy", 0);
1387 const char *file = qdict_get_str(qdict, "filename");
1388 bool has_begin = qdict_haskey(qdict, "begin");
1389 bool has_length = qdict_haskey(qdict, "length");
1390 int64_t begin = 0;
1391 int64_t length = 0;
1392 enum DumpGuestMemoryFormat dump_format = DUMP_GUEST_MEMORY_FORMAT_ELF;
1393 char *prot;
1395 if (zlib + lzo + snappy > 1) {
1396 error_setg(&err, "only one of '-z|-l|-s' can be set");
1397 hmp_handle_error(mon, &err);
1398 return;
1401 if (zlib) {
1402 dump_format = DUMP_GUEST_MEMORY_FORMAT_KDUMP_ZLIB;
1405 if (lzo) {
1406 dump_format = DUMP_GUEST_MEMORY_FORMAT_KDUMP_LZO;
1409 if (snappy) {
1410 dump_format = DUMP_GUEST_MEMORY_FORMAT_KDUMP_SNAPPY;
1413 if (has_begin) {
1414 begin = qdict_get_int(qdict, "begin");
1416 if (has_length) {
1417 length = qdict_get_int(qdict, "length");
1420 prot = g_strconcat("file:", file, NULL);
1422 qmp_dump_guest_memory(paging, prot, has_begin, begin, has_length, length,
1423 true, dump_format, &err);
1424 hmp_handle_error(mon, &err);
1425 g_free(prot);
1428 void hmp_netdev_add(Monitor *mon, const QDict *qdict)
1430 Error *err = NULL;
1431 QemuOpts *opts;
1433 opts = qemu_opts_from_qdict(qemu_find_opts("netdev"), qdict, &err);
1434 if (err) {
1435 goto out;
1438 netdev_add(opts, &err);
1439 if (err) {
1440 qemu_opts_del(opts);
1443 out:
1444 hmp_handle_error(mon, &err);
1447 void hmp_netdev_del(Monitor *mon, const QDict *qdict)
1449 const char *id = qdict_get_str(qdict, "id");
1450 Error *err = NULL;
1452 qmp_netdev_del(id, &err);
1453 hmp_handle_error(mon, &err);
1456 void hmp_object_add(Monitor *mon, const QDict *qdict)
1458 Error *err = NULL;
1459 Error *err_end = NULL;
1460 QemuOpts *opts;
1461 char *type = NULL;
1462 char *id = NULL;
1463 void *dummy = NULL;
1464 OptsVisitor *ov;
1465 QDict *pdict;
1467 opts = qemu_opts_from_qdict(qemu_find_opts("object"), qdict, &err);
1468 if (err) {
1469 goto out;
1472 ov = opts_visitor_new(opts);
1473 pdict = qdict_clone_shallow(qdict);
1475 visit_start_struct(opts_get_visitor(ov), &dummy, NULL, NULL, 0, &err);
1476 if (err) {
1477 goto out_clean;
1480 qdict_del(pdict, "qom-type");
1481 visit_type_str(opts_get_visitor(ov), &type, "qom-type", &err);
1482 if (err) {
1483 goto out_end;
1486 qdict_del(pdict, "id");
1487 visit_type_str(opts_get_visitor(ov), &id, "id", &err);
1488 if (err) {
1489 goto out_end;
1492 object_add(type, id, pdict, opts_get_visitor(ov), &err);
1494 out_end:
1495 visit_end_struct(opts_get_visitor(ov), &err_end);
1496 if (!err && err_end) {
1497 qmp_object_del(id, NULL);
1499 error_propagate(&err, err_end);
1500 out_clean:
1501 opts_visitor_cleanup(ov);
1503 QDECREF(pdict);
1504 qemu_opts_del(opts);
1505 g_free(id);
1506 g_free(type);
1507 g_free(dummy);
1509 out:
1510 hmp_handle_error(mon, &err);
1513 void hmp_getfd(Monitor *mon, const QDict *qdict)
1515 const char *fdname = qdict_get_str(qdict, "fdname");
1516 Error *err = NULL;
1518 qmp_getfd(fdname, &err);
1519 hmp_handle_error(mon, &err);
1522 void hmp_closefd(Monitor *mon, const QDict *qdict)
1524 const char *fdname = qdict_get_str(qdict, "fdname");
1525 Error *err = NULL;
1527 qmp_closefd(fdname, &err);
1528 hmp_handle_error(mon, &err);
1531 void hmp_send_key(Monitor *mon, const QDict *qdict)
1533 const char *keys = qdict_get_str(qdict, "keys");
1534 KeyValueList *keylist, *head = NULL, *tmp = NULL;
1535 int has_hold_time = qdict_haskey(qdict, "hold-time");
1536 int hold_time = qdict_get_try_int(qdict, "hold-time", -1);
1537 Error *err = NULL;
1538 char keyname_buf[16];
1539 char *separator;
1540 int keyname_len;
1542 while (1) {
1543 separator = strchr(keys, '-');
1544 keyname_len = separator ? separator - keys : strlen(keys);
1545 pstrcpy(keyname_buf, sizeof(keyname_buf), keys);
1547 /* Be compatible with old interface, convert user inputted "<" */
1548 if (!strncmp(keyname_buf, "<", 1) && keyname_len == 1) {
1549 pstrcpy(keyname_buf, sizeof(keyname_buf), "less");
1550 keyname_len = 4;
1552 keyname_buf[keyname_len] = 0;
1554 keylist = g_malloc0(sizeof(*keylist));
1555 keylist->value = g_malloc0(sizeof(*keylist->value));
1557 if (!head) {
1558 head = keylist;
1560 if (tmp) {
1561 tmp->next = keylist;
1563 tmp = keylist;
1565 if (strstart(keyname_buf, "0x", NULL)) {
1566 char *endp;
1567 int value = strtoul(keyname_buf, &endp, 0);
1568 if (*endp != '\0') {
1569 goto err_out;
1571 keylist->value->kind = KEY_VALUE_KIND_NUMBER;
1572 keylist->value->number = value;
1573 } else {
1574 int idx = index_from_key(keyname_buf);
1575 if (idx == Q_KEY_CODE_MAX) {
1576 goto err_out;
1578 keylist->value->kind = KEY_VALUE_KIND_QCODE;
1579 keylist->value->qcode = idx;
1582 if (!separator) {
1583 break;
1585 keys = separator + 1;
1588 qmp_send_key(head, has_hold_time, hold_time, &err);
1589 hmp_handle_error(mon, &err);
1591 out:
1592 qapi_free_KeyValueList(head);
1593 return;
1595 err_out:
1596 monitor_printf(mon, "invalid parameter: %s\n", keyname_buf);
1597 goto out;
1600 void hmp_screen_dump(Monitor *mon, const QDict *qdict)
1602 const char *filename = qdict_get_str(qdict, "filename");
1603 Error *err = NULL;
1605 qmp_screendump(filename, &err);
1606 hmp_handle_error(mon, &err);
1609 void hmp_nbd_server_start(Monitor *mon, const QDict *qdict)
1611 const char *uri = qdict_get_str(qdict, "uri");
1612 int writable = qdict_get_try_bool(qdict, "writable", 0);
1613 int all = qdict_get_try_bool(qdict, "all", 0);
1614 Error *local_err = NULL;
1615 BlockInfoList *block_list, *info;
1616 SocketAddress *addr;
1618 if (writable && !all) {
1619 error_setg(&local_err, "-w only valid together with -a");
1620 goto exit;
1623 /* First check if the address is valid and start the server. */
1624 addr = socket_parse(uri, &local_err);
1625 if (local_err != NULL) {
1626 goto exit;
1629 qmp_nbd_server_start(addr, &local_err);
1630 qapi_free_SocketAddress(addr);
1631 if (local_err != NULL) {
1632 goto exit;
1635 if (!all) {
1636 return;
1639 /* Then try adding all block devices. If one fails, close all and
1640 * exit.
1642 block_list = qmp_query_block(NULL);
1644 for (info = block_list; info; info = info->next) {
1645 if (!info->value->has_inserted) {
1646 continue;
1649 qmp_nbd_server_add(info->value->device, true, writable, &local_err);
1651 if (local_err != NULL) {
1652 qmp_nbd_server_stop(NULL);
1653 break;
1657 qapi_free_BlockInfoList(block_list);
1659 exit:
1660 hmp_handle_error(mon, &local_err);
1663 void hmp_nbd_server_add(Monitor *mon, const QDict *qdict)
1665 const char *device = qdict_get_str(qdict, "device");
1666 int writable = qdict_get_try_bool(qdict, "writable", 0);
1667 Error *local_err = NULL;
1669 qmp_nbd_server_add(device, true, writable, &local_err);
1671 if (local_err != NULL) {
1672 hmp_handle_error(mon, &local_err);
1676 void hmp_nbd_server_stop(Monitor *mon, const QDict *qdict)
1678 Error *err = NULL;
1680 qmp_nbd_server_stop(&err);
1681 hmp_handle_error(mon, &err);
1684 void hmp_cpu_add(Monitor *mon, const QDict *qdict)
1686 int cpuid;
1687 Error *err = NULL;
1689 cpuid = qdict_get_int(qdict, "id");
1690 qmp_cpu_add(cpuid, &err);
1691 hmp_handle_error(mon, &err);
1694 void hmp_chardev_add(Monitor *mon, const QDict *qdict)
1696 const char *args = qdict_get_str(qdict, "args");
1697 Error *err = NULL;
1698 QemuOpts *opts;
1700 opts = qemu_opts_parse(qemu_find_opts("chardev"), args, 1);
1701 if (opts == NULL) {
1702 error_setg(&err, "Parsing chardev args failed");
1703 } else {
1704 qemu_chr_new_from_opts(opts, NULL, &err);
1706 hmp_handle_error(mon, &err);
1709 void hmp_chardev_remove(Monitor *mon, const QDict *qdict)
1711 Error *local_err = NULL;
1713 qmp_chardev_remove(qdict_get_str(qdict, "id"), &local_err);
1714 hmp_handle_error(mon, &local_err);
1717 void hmp_qemu_io(Monitor *mon, const QDict *qdict)
1719 BlockDriverState *bs;
1720 const char* device = qdict_get_str(qdict, "device");
1721 const char* command = qdict_get_str(qdict, "command");
1722 Error *err = NULL;
1724 bs = bdrv_find(device);
1725 if (bs) {
1726 qemuio_command(bs, command);
1727 } else {
1728 error_set(&err, QERR_DEVICE_NOT_FOUND, device);
1731 hmp_handle_error(mon, &err);
1734 void hmp_object_del(Monitor *mon, const QDict *qdict)
1736 const char *id = qdict_get_str(qdict, "id");
1737 Error *err = NULL;
1739 qmp_object_del(id, &err);
1740 hmp_handle_error(mon, &err);
1743 void hmp_info_memdev(Monitor *mon, const QDict *qdict)
1745 Error *err = NULL;
1746 MemdevList *memdev_list = qmp_query_memdev(&err);
1747 MemdevList *m = memdev_list;
1748 StringOutputVisitor *ov;
1749 char *str;
1750 int i = 0;
1753 while (m) {
1754 ov = string_output_visitor_new(false);
1755 visit_type_uint16List(string_output_get_visitor(ov),
1756 &m->value->host_nodes, NULL, NULL);
1757 monitor_printf(mon, "memory backend: %d\n", i);
1758 monitor_printf(mon, " size: %" PRId64 "\n", m->value->size);
1759 monitor_printf(mon, " merge: %s\n",
1760 m->value->merge ? "true" : "false");
1761 monitor_printf(mon, " dump: %s\n",
1762 m->value->dump ? "true" : "false");
1763 monitor_printf(mon, " prealloc: %s\n",
1764 m->value->prealloc ? "true" : "false");
1765 monitor_printf(mon, " policy: %s\n",
1766 HostMemPolicy_lookup[m->value->policy]);
1767 str = string_output_get_string(ov);
1768 monitor_printf(mon, " host nodes: %s\n", str);
1770 g_free(str);
1771 string_output_visitor_cleanup(ov);
1772 m = m->next;
1773 i++;
1776 monitor_printf(mon, "\n");
1778 qapi_free_MemdevList(memdev_list);
1781 void hmp_info_memory_devices(Monitor *mon, const QDict *qdict)
1783 Error *err = NULL;
1784 MemoryDeviceInfoList *info_list = qmp_query_memory_devices(&err);
1785 MemoryDeviceInfoList *info;
1786 MemoryDeviceInfo *value;
1787 PCDIMMDeviceInfo *di;
1789 for (info = info_list; info; info = info->next) {
1790 value = info->value;
1792 if (value) {
1793 switch (value->kind) {
1794 case MEMORY_DEVICE_INFO_KIND_DIMM:
1795 di = value->dimm;
1797 monitor_printf(mon, "Memory device [%s]: \"%s\"\n",
1798 MemoryDeviceInfoKind_lookup[value->kind],
1799 di->id ? di->id : "");
1800 monitor_printf(mon, " addr: 0x%" PRIx64 "\n", di->addr);
1801 monitor_printf(mon, " slot: %" PRId64 "\n", di->slot);
1802 monitor_printf(mon, " node: %" PRId64 "\n", di->node);
1803 monitor_printf(mon, " size: %" PRIu64 "\n", di->size);
1804 monitor_printf(mon, " memdev: %s\n", di->memdev);
1805 monitor_printf(mon, " hotplugged: %s\n",
1806 di->hotplugged ? "true" : "false");
1807 monitor_printf(mon, " hotpluggable: %s\n",
1808 di->hotpluggable ? "true" : "false");
1809 break;
1810 default:
1811 break;
1816 qapi_free_MemoryDeviceInfoList(info_list);