pci: Allocate PCIe host bridge PCI ID
[qemu/rayw.git] / hmp.c
blobb47f331f4dbd114bfddf0d26dc11d6a51d794060
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 " rd_merged=%" PRId64
478 " wr_merged=%" PRId64
479 "\n",
480 stats->value->stats->rd_bytes,
481 stats->value->stats->wr_bytes,
482 stats->value->stats->rd_operations,
483 stats->value->stats->wr_operations,
484 stats->value->stats->flush_operations,
485 stats->value->stats->wr_total_time_ns,
486 stats->value->stats->rd_total_time_ns,
487 stats->value->stats->flush_total_time_ns,
488 stats->value->stats->rd_merged,
489 stats->value->stats->wr_merged);
492 qapi_free_BlockStatsList(stats_list);
495 void hmp_info_vnc(Monitor *mon, const QDict *qdict)
497 VncInfo *info;
498 Error *err = NULL;
499 VncClientInfoList *client;
501 info = qmp_query_vnc(&err);
502 if (err) {
503 monitor_printf(mon, "%s\n", error_get_pretty(err));
504 error_free(err);
505 return;
508 if (!info->enabled) {
509 monitor_printf(mon, "Server: disabled\n");
510 goto out;
513 monitor_printf(mon, "Server:\n");
514 if (info->has_host && info->has_service) {
515 monitor_printf(mon, " address: %s:%s\n", info->host, info->service);
517 if (info->has_auth) {
518 monitor_printf(mon, " auth: %s\n", info->auth);
521 if (!info->has_clients || info->clients == NULL) {
522 monitor_printf(mon, "Client: none\n");
523 } else {
524 for (client = info->clients; client; client = client->next) {
525 monitor_printf(mon, "Client:\n");
526 monitor_printf(mon, " address: %s:%s\n",
527 client->value->base->host,
528 client->value->base->service);
529 monitor_printf(mon, " x509_dname: %s\n",
530 client->value->x509_dname ?
531 client->value->x509_dname : "none");
532 monitor_printf(mon, " username: %s\n",
533 client->value->has_sasl_username ?
534 client->value->sasl_username : "none");
538 out:
539 qapi_free_VncInfo(info);
542 #ifdef CONFIG_SPICE
543 void hmp_info_spice(Monitor *mon, const QDict *qdict)
545 SpiceChannelList *chan;
546 SpiceInfo *info;
548 info = qmp_query_spice(NULL);
550 if (!info->enabled) {
551 monitor_printf(mon, "Server: disabled\n");
552 goto out;
555 monitor_printf(mon, "Server:\n");
556 if (info->has_port) {
557 monitor_printf(mon, " address: %s:%" PRId64 "\n",
558 info->host, info->port);
560 if (info->has_tls_port) {
561 monitor_printf(mon, " address: %s:%" PRId64 " [tls]\n",
562 info->host, info->tls_port);
564 monitor_printf(mon, " migrated: %s\n",
565 info->migrated ? "true" : "false");
566 monitor_printf(mon, " auth: %s\n", info->auth);
567 monitor_printf(mon, " compiled: %s\n", info->compiled_version);
568 monitor_printf(mon, " mouse-mode: %s\n",
569 SpiceQueryMouseMode_lookup[info->mouse_mode]);
571 if (!info->has_channels || info->channels == NULL) {
572 monitor_printf(mon, "Channels: none\n");
573 } else {
574 for (chan = info->channels; chan; chan = chan->next) {
575 monitor_printf(mon, "Channel:\n");
576 monitor_printf(mon, " address: %s:%s%s\n",
577 chan->value->base->host, chan->value->base->port,
578 chan->value->tls ? " [tls]" : "");
579 monitor_printf(mon, " session: %" PRId64 "\n",
580 chan->value->connection_id);
581 monitor_printf(mon, " channel: %" PRId64 ":%" PRId64 "\n",
582 chan->value->channel_type, chan->value->channel_id);
586 out:
587 qapi_free_SpiceInfo(info);
589 #endif
591 void hmp_info_balloon(Monitor *mon, const QDict *qdict)
593 BalloonInfo *info;
594 Error *err = NULL;
596 info = qmp_query_balloon(&err);
597 if (err) {
598 monitor_printf(mon, "%s\n", error_get_pretty(err));
599 error_free(err);
600 return;
603 monitor_printf(mon, "balloon: actual=%" PRId64 "\n", info->actual >> 20);
605 qapi_free_BalloonInfo(info);
608 static void hmp_info_pci_device(Monitor *mon, const PciDeviceInfo *dev)
610 PciMemoryRegionList *region;
612 monitor_printf(mon, " Bus %2" PRId64 ", ", dev->bus);
613 monitor_printf(mon, "device %3" PRId64 ", function %" PRId64 ":\n",
614 dev->slot, dev->function);
615 monitor_printf(mon, " ");
617 if (dev->class_info.has_desc) {
618 monitor_printf(mon, "%s", dev->class_info.desc);
619 } else {
620 monitor_printf(mon, "Class %04" PRId64, dev->class_info.q_class);
623 monitor_printf(mon, ": PCI device %04" PRIx64 ":%04" PRIx64 "\n",
624 dev->id.vendor, dev->id.device);
626 if (dev->has_irq) {
627 monitor_printf(mon, " IRQ %" PRId64 ".\n", dev->irq);
630 if (dev->has_pci_bridge) {
631 monitor_printf(mon, " BUS %" PRId64 ".\n",
632 dev->pci_bridge->bus.number);
633 monitor_printf(mon, " secondary bus %" PRId64 ".\n",
634 dev->pci_bridge->bus.secondary);
635 monitor_printf(mon, " subordinate bus %" PRId64 ".\n",
636 dev->pci_bridge->bus.subordinate);
638 monitor_printf(mon, " IO range [0x%04"PRIx64", 0x%04"PRIx64"]\n",
639 dev->pci_bridge->bus.io_range->base,
640 dev->pci_bridge->bus.io_range->limit);
642 monitor_printf(mon,
643 " memory range [0x%08"PRIx64", 0x%08"PRIx64"]\n",
644 dev->pci_bridge->bus.memory_range->base,
645 dev->pci_bridge->bus.memory_range->limit);
647 monitor_printf(mon, " prefetchable memory range "
648 "[0x%08"PRIx64", 0x%08"PRIx64"]\n",
649 dev->pci_bridge->bus.prefetchable_range->base,
650 dev->pci_bridge->bus.prefetchable_range->limit);
653 for (region = dev->regions; region; region = region->next) {
654 uint64_t addr, size;
656 addr = region->value->address;
657 size = region->value->size;
659 monitor_printf(mon, " BAR%" PRId64 ": ", region->value->bar);
661 if (!strcmp(region->value->type, "io")) {
662 monitor_printf(mon, "I/O at 0x%04" PRIx64
663 " [0x%04" PRIx64 "].\n",
664 addr, addr + size - 1);
665 } else {
666 monitor_printf(mon, "%d bit%s memory at 0x%08" PRIx64
667 " [0x%08" PRIx64 "].\n",
668 region->value->mem_type_64 ? 64 : 32,
669 region->value->prefetch ? " prefetchable" : "",
670 addr, addr + size - 1);
674 monitor_printf(mon, " id \"%s\"\n", dev->qdev_id);
676 if (dev->has_pci_bridge) {
677 if (dev->pci_bridge->has_devices) {
678 PciDeviceInfoList *cdev;
679 for (cdev = dev->pci_bridge->devices; cdev; cdev = cdev->next) {
680 hmp_info_pci_device(mon, cdev->value);
686 void hmp_info_pci(Monitor *mon, const QDict *qdict)
688 PciInfoList *info_list, *info;
689 Error *err = NULL;
691 info_list = qmp_query_pci(&err);
692 if (err) {
693 monitor_printf(mon, "PCI devices not supported\n");
694 error_free(err);
695 return;
698 for (info = info_list; info; info = info->next) {
699 PciDeviceInfoList *dev;
701 for (dev = info->value->devices; dev; dev = dev->next) {
702 hmp_info_pci_device(mon, dev->value);
706 qapi_free_PciInfoList(info_list);
709 void hmp_info_block_jobs(Monitor *mon, const QDict *qdict)
711 BlockJobInfoList *list;
712 Error *err = NULL;
714 list = qmp_query_block_jobs(&err);
715 assert(!err);
717 if (!list) {
718 monitor_printf(mon, "No active jobs\n");
719 return;
722 while (list) {
723 if (strcmp(list->value->type, "stream") == 0) {
724 monitor_printf(mon, "Streaming device %s: Completed %" PRId64
725 " of %" PRId64 " bytes, speed limit %" PRId64
726 " bytes/s\n",
727 list->value->device,
728 list->value->offset,
729 list->value->len,
730 list->value->speed);
731 } else {
732 monitor_printf(mon, "Type %s, device %s: Completed %" PRId64
733 " of %" PRId64 " bytes, speed limit %" PRId64
734 " bytes/s\n",
735 list->value->type,
736 list->value->device,
737 list->value->offset,
738 list->value->len,
739 list->value->speed);
741 list = list->next;
744 qapi_free_BlockJobInfoList(list);
747 void hmp_info_tpm(Monitor *mon, const QDict *qdict)
749 TPMInfoList *info_list, *info;
750 Error *err = NULL;
751 unsigned int c = 0;
752 TPMPassthroughOptions *tpo;
754 info_list = qmp_query_tpm(&err);
755 if (err) {
756 monitor_printf(mon, "TPM device not supported\n");
757 error_free(err);
758 return;
761 if (info_list) {
762 monitor_printf(mon, "TPM device:\n");
765 for (info = info_list; info; info = info->next) {
766 TPMInfo *ti = info->value;
767 monitor_printf(mon, " tpm%d: model=%s\n",
768 c, TpmModel_lookup[ti->model]);
770 monitor_printf(mon, " \\ %s: type=%s",
771 ti->id, TpmTypeOptionsKind_lookup[ti->options->kind]);
773 switch (ti->options->kind) {
774 case TPM_TYPE_OPTIONS_KIND_PASSTHROUGH:
775 tpo = ti->options->passthrough;
776 monitor_printf(mon, "%s%s%s%s",
777 tpo->has_path ? ",path=" : "",
778 tpo->has_path ? tpo->path : "",
779 tpo->has_cancel_path ? ",cancel-path=" : "",
780 tpo->has_cancel_path ? tpo->cancel_path : "");
781 break;
782 case TPM_TYPE_OPTIONS_KIND_MAX:
783 break;
785 monitor_printf(mon, "\n");
786 c++;
788 qapi_free_TPMInfoList(info_list);
791 void hmp_quit(Monitor *mon, const QDict *qdict)
793 monitor_suspend(mon);
794 qmp_quit(NULL);
797 void hmp_stop(Monitor *mon, const QDict *qdict)
799 qmp_stop(NULL);
802 void hmp_system_reset(Monitor *mon, const QDict *qdict)
804 qmp_system_reset(NULL);
807 void hmp_system_powerdown(Monitor *mon, const QDict *qdict)
809 qmp_system_powerdown(NULL);
812 void hmp_cpu(Monitor *mon, const QDict *qdict)
814 int64_t cpu_index;
816 /* XXX: drop the monitor_set_cpu() usage when all HMP commands that
817 use it are converted to the QAPI */
818 cpu_index = qdict_get_int(qdict, "index");
819 if (monitor_set_cpu(cpu_index) < 0) {
820 monitor_printf(mon, "invalid CPU index\n");
824 void hmp_memsave(Monitor *mon, const QDict *qdict)
826 uint32_t size = qdict_get_int(qdict, "size");
827 const char *filename = qdict_get_str(qdict, "filename");
828 uint64_t addr = qdict_get_int(qdict, "val");
829 Error *err = NULL;
831 qmp_memsave(addr, size, filename, true, monitor_get_cpu_index(), &err);
832 hmp_handle_error(mon, &err);
835 void hmp_pmemsave(Monitor *mon, const QDict *qdict)
837 uint32_t size = qdict_get_int(qdict, "size");
838 const char *filename = qdict_get_str(qdict, "filename");
839 uint64_t addr = qdict_get_int(qdict, "val");
840 Error *err = NULL;
842 qmp_pmemsave(addr, size, filename, &err);
843 hmp_handle_error(mon, &err);
846 void hmp_ringbuf_write(Monitor *mon, const QDict *qdict)
848 const char *chardev = qdict_get_str(qdict, "device");
849 const char *data = qdict_get_str(qdict, "data");
850 Error *err = NULL;
852 qmp_ringbuf_write(chardev, data, false, 0, &err);
854 hmp_handle_error(mon, &err);
857 void hmp_ringbuf_read(Monitor *mon, const QDict *qdict)
859 uint32_t size = qdict_get_int(qdict, "size");
860 const char *chardev = qdict_get_str(qdict, "device");
861 char *data;
862 Error *err = NULL;
863 int i;
865 data = qmp_ringbuf_read(chardev, size, false, 0, &err);
866 if (err) {
867 monitor_printf(mon, "%s\n", error_get_pretty(err));
868 error_free(err);
869 return;
872 for (i = 0; data[i]; i++) {
873 unsigned char ch = data[i];
875 if (ch == '\\') {
876 monitor_printf(mon, "\\\\");
877 } else if ((ch < 0x20 && ch != '\n' && ch != '\t') || ch == 0x7F) {
878 monitor_printf(mon, "\\u%04X", ch);
879 } else {
880 monitor_printf(mon, "%c", ch);
884 monitor_printf(mon, "\n");
885 g_free(data);
888 static void hmp_cont_cb(void *opaque, int err)
890 if (!err) {
891 qmp_cont(NULL);
895 static bool key_is_missing(const BlockInfo *bdev)
897 return (bdev->inserted && bdev->inserted->encryption_key_missing);
900 void hmp_cont(Monitor *mon, const QDict *qdict)
902 BlockInfoList *bdev_list, *bdev;
903 Error *err = NULL;
905 bdev_list = qmp_query_block(NULL);
906 for (bdev = bdev_list; bdev; bdev = bdev->next) {
907 if (key_is_missing(bdev->value)) {
908 monitor_read_block_device_key(mon, bdev->value->device,
909 hmp_cont_cb, NULL);
910 goto out;
914 qmp_cont(&err);
915 hmp_handle_error(mon, &err);
917 out:
918 qapi_free_BlockInfoList(bdev_list);
921 void hmp_system_wakeup(Monitor *mon, const QDict *qdict)
923 qmp_system_wakeup(NULL);
926 void hmp_inject_nmi(Monitor *mon, const QDict *qdict)
928 Error *err = NULL;
930 qmp_inject_nmi(&err);
931 hmp_handle_error(mon, &err);
934 void hmp_set_link(Monitor *mon, const QDict *qdict)
936 const char *name = qdict_get_str(qdict, "name");
937 int up = qdict_get_bool(qdict, "up");
938 Error *err = NULL;
940 qmp_set_link(name, up, &err);
941 hmp_handle_error(mon, &err);
944 void hmp_block_passwd(Monitor *mon, const QDict *qdict)
946 const char *device = qdict_get_str(qdict, "device");
947 const char *password = qdict_get_str(qdict, "password");
948 Error *err = NULL;
950 qmp_block_passwd(true, device, false, NULL, password, &err);
951 hmp_handle_error(mon, &err);
954 void hmp_balloon(Monitor *mon, const QDict *qdict)
956 int64_t value = qdict_get_int(qdict, "value");
957 Error *err = NULL;
959 qmp_balloon(value, &err);
960 if (err) {
961 monitor_printf(mon, "balloon: %s\n", error_get_pretty(err));
962 error_free(err);
966 void hmp_block_resize(Monitor *mon, const QDict *qdict)
968 const char *device = qdict_get_str(qdict, "device");
969 int64_t size = qdict_get_int(qdict, "size");
970 Error *err = NULL;
972 qmp_block_resize(true, device, false, NULL, size, &err);
973 hmp_handle_error(mon, &err);
976 void hmp_drive_mirror(Monitor *mon, const QDict *qdict)
978 const char *device = qdict_get_str(qdict, "device");
979 const char *filename = qdict_get_str(qdict, "target");
980 const char *format = qdict_get_try_str(qdict, "format");
981 int reuse = qdict_get_try_bool(qdict, "reuse", 0);
982 int full = qdict_get_try_bool(qdict, "full", 0);
983 enum NewImageMode mode;
984 Error *err = NULL;
986 if (!filename) {
987 error_set(&err, QERR_MISSING_PARAMETER, "target");
988 hmp_handle_error(mon, &err);
989 return;
992 if (reuse) {
993 mode = NEW_IMAGE_MODE_EXISTING;
994 } else {
995 mode = NEW_IMAGE_MODE_ABSOLUTE_PATHS;
998 qmp_drive_mirror(device, filename, !!format, format,
999 false, NULL, false, NULL,
1000 full ? MIRROR_SYNC_MODE_FULL : MIRROR_SYNC_MODE_TOP,
1001 true, mode, false, 0, false, 0, false, 0,
1002 false, 0, false, 0, &err);
1003 hmp_handle_error(mon, &err);
1006 void hmp_drive_backup(Monitor *mon, const QDict *qdict)
1008 const char *device = qdict_get_str(qdict, "device");
1009 const char *filename = qdict_get_str(qdict, "target");
1010 const char *format = qdict_get_try_str(qdict, "format");
1011 int reuse = qdict_get_try_bool(qdict, "reuse", 0);
1012 int full = qdict_get_try_bool(qdict, "full", 0);
1013 enum NewImageMode mode;
1014 Error *err = NULL;
1016 if (!filename) {
1017 error_set(&err, QERR_MISSING_PARAMETER, "target");
1018 hmp_handle_error(mon, &err);
1019 return;
1022 if (reuse) {
1023 mode = NEW_IMAGE_MODE_EXISTING;
1024 } else {
1025 mode = NEW_IMAGE_MODE_ABSOLUTE_PATHS;
1028 qmp_drive_backup(device, filename, !!format, format,
1029 full ? MIRROR_SYNC_MODE_FULL : MIRROR_SYNC_MODE_TOP,
1030 true, mode, false, 0, false, 0, false, 0, &err);
1031 hmp_handle_error(mon, &err);
1034 void hmp_snapshot_blkdev(Monitor *mon, const QDict *qdict)
1036 const char *device = qdict_get_str(qdict, "device");
1037 const char *filename = qdict_get_try_str(qdict, "snapshot-file");
1038 const char *format = qdict_get_try_str(qdict, "format");
1039 int reuse = qdict_get_try_bool(qdict, "reuse", 0);
1040 enum NewImageMode mode;
1041 Error *err = NULL;
1043 if (!filename) {
1044 /* In the future, if 'snapshot-file' is not specified, the snapshot
1045 will be taken internally. Today it's actually required. */
1046 error_set(&err, QERR_MISSING_PARAMETER, "snapshot-file");
1047 hmp_handle_error(mon, &err);
1048 return;
1051 mode = reuse ? NEW_IMAGE_MODE_EXISTING : NEW_IMAGE_MODE_ABSOLUTE_PATHS;
1052 qmp_blockdev_snapshot_sync(true, device, false, NULL,
1053 filename, false, NULL,
1054 !!format, format,
1055 true, mode, &err);
1056 hmp_handle_error(mon, &err);
1059 void hmp_snapshot_blkdev_internal(Monitor *mon, const QDict *qdict)
1061 const char *device = qdict_get_str(qdict, "device");
1062 const char *name = qdict_get_str(qdict, "name");
1063 Error *err = NULL;
1065 qmp_blockdev_snapshot_internal_sync(device, name, &err);
1066 hmp_handle_error(mon, &err);
1069 void hmp_snapshot_delete_blkdev_internal(Monitor *mon, const QDict *qdict)
1071 const char *device = qdict_get_str(qdict, "device");
1072 const char *name = qdict_get_str(qdict, "name");
1073 const char *id = qdict_get_try_str(qdict, "id");
1074 Error *err = NULL;
1076 qmp_blockdev_snapshot_delete_internal_sync(device, !!id, id,
1077 true, name, &err);
1078 hmp_handle_error(mon, &err);
1081 void hmp_migrate_cancel(Monitor *mon, const QDict *qdict)
1083 qmp_migrate_cancel(NULL);
1086 void hmp_migrate_set_downtime(Monitor *mon, const QDict *qdict)
1088 double value = qdict_get_double(qdict, "value");
1089 qmp_migrate_set_downtime(value, NULL);
1092 void hmp_migrate_set_cache_size(Monitor *mon, const QDict *qdict)
1094 int64_t value = qdict_get_int(qdict, "value");
1095 Error *err = NULL;
1097 qmp_migrate_set_cache_size(value, &err);
1098 if (err) {
1099 monitor_printf(mon, "%s\n", error_get_pretty(err));
1100 error_free(err);
1101 return;
1105 void hmp_migrate_set_speed(Monitor *mon, const QDict *qdict)
1107 int64_t value = qdict_get_int(qdict, "value");
1108 qmp_migrate_set_speed(value, NULL);
1111 void hmp_migrate_set_capability(Monitor *mon, const QDict *qdict)
1113 const char *cap = qdict_get_str(qdict, "capability");
1114 bool state = qdict_get_bool(qdict, "state");
1115 Error *err = NULL;
1116 MigrationCapabilityStatusList *caps = g_malloc0(sizeof(*caps));
1117 int i;
1119 for (i = 0; i < MIGRATION_CAPABILITY_MAX; i++) {
1120 if (strcmp(cap, MigrationCapability_lookup[i]) == 0) {
1121 caps->value = g_malloc0(sizeof(*caps->value));
1122 caps->value->capability = i;
1123 caps->value->state = state;
1124 caps->next = NULL;
1125 qmp_migrate_set_capabilities(caps, &err);
1126 break;
1130 if (i == MIGRATION_CAPABILITY_MAX) {
1131 error_set(&err, QERR_INVALID_PARAMETER, cap);
1134 qapi_free_MigrationCapabilityStatusList(caps);
1136 if (err) {
1137 monitor_printf(mon, "migrate_set_capability: %s\n",
1138 error_get_pretty(err));
1139 error_free(err);
1143 void hmp_set_password(Monitor *mon, const QDict *qdict)
1145 const char *protocol = qdict_get_str(qdict, "protocol");
1146 const char *password = qdict_get_str(qdict, "password");
1147 const char *connected = qdict_get_try_str(qdict, "connected");
1148 Error *err = NULL;
1150 qmp_set_password(protocol, password, !!connected, connected, &err);
1151 hmp_handle_error(mon, &err);
1154 void hmp_expire_password(Monitor *mon, const QDict *qdict)
1156 const char *protocol = qdict_get_str(qdict, "protocol");
1157 const char *whenstr = qdict_get_str(qdict, "time");
1158 Error *err = NULL;
1160 qmp_expire_password(protocol, whenstr, &err);
1161 hmp_handle_error(mon, &err);
1164 void hmp_eject(Monitor *mon, const QDict *qdict)
1166 int force = qdict_get_try_bool(qdict, "force", 0);
1167 const char *device = qdict_get_str(qdict, "device");
1168 Error *err = NULL;
1170 qmp_eject(device, true, force, &err);
1171 hmp_handle_error(mon, &err);
1174 static void hmp_change_read_arg(void *opaque, const char *password,
1175 void *readline_opaque)
1177 qmp_change_vnc_password(password, NULL);
1178 monitor_read_command(opaque, 1);
1181 void hmp_change(Monitor *mon, const QDict *qdict)
1183 const char *device = qdict_get_str(qdict, "device");
1184 const char *target = qdict_get_str(qdict, "target");
1185 const char *arg = qdict_get_try_str(qdict, "arg");
1186 Error *err = NULL;
1188 if (strcmp(device, "vnc") == 0 &&
1189 (strcmp(target, "passwd") == 0 ||
1190 strcmp(target, "password") == 0)) {
1191 if (!arg) {
1192 monitor_read_password(mon, hmp_change_read_arg, NULL);
1193 return;
1197 qmp_change(device, target, !!arg, arg, &err);
1198 if (err &&
1199 error_get_class(err) == ERROR_CLASS_DEVICE_ENCRYPTED) {
1200 error_free(err);
1201 monitor_read_block_device_key(mon, device, NULL, NULL);
1202 return;
1204 hmp_handle_error(mon, &err);
1207 void hmp_block_set_io_throttle(Monitor *mon, const QDict *qdict)
1209 Error *err = NULL;
1211 qmp_block_set_io_throttle(qdict_get_str(qdict, "device"),
1212 qdict_get_int(qdict, "bps"),
1213 qdict_get_int(qdict, "bps_rd"),
1214 qdict_get_int(qdict, "bps_wr"),
1215 qdict_get_int(qdict, "iops"),
1216 qdict_get_int(qdict, "iops_rd"),
1217 qdict_get_int(qdict, "iops_wr"),
1218 false, /* no burst max via HMP */
1220 false,
1222 false,
1224 false,
1226 false,
1228 false,
1230 false, /* No default I/O size */
1231 0, &err);
1232 hmp_handle_error(mon, &err);
1235 void hmp_block_stream(Monitor *mon, const QDict *qdict)
1237 Error *error = NULL;
1238 const char *device = qdict_get_str(qdict, "device");
1239 const char *base = qdict_get_try_str(qdict, "base");
1240 int64_t speed = qdict_get_try_int(qdict, "speed", 0);
1242 qmp_block_stream(device, base != NULL, base, false, NULL,
1243 qdict_haskey(qdict, "speed"), speed,
1244 true, BLOCKDEV_ON_ERROR_REPORT, &error);
1246 hmp_handle_error(mon, &error);
1249 void hmp_block_job_set_speed(Monitor *mon, const QDict *qdict)
1251 Error *error = NULL;
1252 const char *device = qdict_get_str(qdict, "device");
1253 int64_t value = qdict_get_int(qdict, "speed");
1255 qmp_block_job_set_speed(device, value, &error);
1257 hmp_handle_error(mon, &error);
1260 void hmp_block_job_cancel(Monitor *mon, const QDict *qdict)
1262 Error *error = NULL;
1263 const char *device = qdict_get_str(qdict, "device");
1264 bool force = qdict_get_try_bool(qdict, "force", 0);
1266 qmp_block_job_cancel(device, true, force, &error);
1268 hmp_handle_error(mon, &error);
1271 void hmp_block_job_pause(Monitor *mon, const QDict *qdict)
1273 Error *error = NULL;
1274 const char *device = qdict_get_str(qdict, "device");
1276 qmp_block_job_pause(device, &error);
1278 hmp_handle_error(mon, &error);
1281 void hmp_block_job_resume(Monitor *mon, const QDict *qdict)
1283 Error *error = NULL;
1284 const char *device = qdict_get_str(qdict, "device");
1286 qmp_block_job_resume(device, &error);
1288 hmp_handle_error(mon, &error);
1291 void hmp_block_job_complete(Monitor *mon, const QDict *qdict)
1293 Error *error = NULL;
1294 const char *device = qdict_get_str(qdict, "device");
1296 qmp_block_job_complete(device, &error);
1298 hmp_handle_error(mon, &error);
1301 typedef struct MigrationStatus
1303 QEMUTimer *timer;
1304 Monitor *mon;
1305 bool is_block_migration;
1306 } MigrationStatus;
1308 static void hmp_migrate_status_cb(void *opaque)
1310 MigrationStatus *status = opaque;
1311 MigrationInfo *info;
1313 info = qmp_query_migrate(NULL);
1314 if (!info->has_status || strcmp(info->status, "active") == 0 ||
1315 strcmp(info->status, "setup") == 0) {
1316 if (info->has_disk) {
1317 int progress;
1319 if (info->disk->remaining) {
1320 progress = info->disk->transferred * 100 / info->disk->total;
1321 } else {
1322 progress = 100;
1325 monitor_printf(status->mon, "Completed %d %%\r", progress);
1326 monitor_flush(status->mon);
1329 timer_mod(status->timer, qemu_clock_get_ms(QEMU_CLOCK_REALTIME) + 1000);
1330 } else {
1331 if (status->is_block_migration) {
1332 monitor_printf(status->mon, "\n");
1334 monitor_resume(status->mon);
1335 timer_del(status->timer);
1336 g_free(status);
1339 qapi_free_MigrationInfo(info);
1342 void hmp_migrate(Monitor *mon, const QDict *qdict)
1344 int detach = qdict_get_try_bool(qdict, "detach", 0);
1345 int blk = qdict_get_try_bool(qdict, "blk", 0);
1346 int inc = qdict_get_try_bool(qdict, "inc", 0);
1347 const char *uri = qdict_get_str(qdict, "uri");
1348 Error *err = NULL;
1350 qmp_migrate(uri, !!blk, blk, !!inc, inc, false, false, &err);
1351 if (err) {
1352 monitor_printf(mon, "migrate: %s\n", error_get_pretty(err));
1353 error_free(err);
1354 return;
1357 if (!detach) {
1358 MigrationStatus *status;
1360 if (monitor_suspend(mon) < 0) {
1361 monitor_printf(mon, "terminal does not allow synchronous "
1362 "migration, continuing detached\n");
1363 return;
1366 status = g_malloc0(sizeof(*status));
1367 status->mon = mon;
1368 status->is_block_migration = blk || inc;
1369 status->timer = timer_new_ms(QEMU_CLOCK_REALTIME, hmp_migrate_status_cb,
1370 status);
1371 timer_mod(status->timer, qemu_clock_get_ms(QEMU_CLOCK_REALTIME));
1375 void hmp_device_del(Monitor *mon, const QDict *qdict)
1377 const char *id = qdict_get_str(qdict, "id");
1378 Error *err = NULL;
1380 qmp_device_del(id, &err);
1381 hmp_handle_error(mon, &err);
1384 void hmp_dump_guest_memory(Monitor *mon, const QDict *qdict)
1386 Error *err = NULL;
1387 int paging = qdict_get_try_bool(qdict, "paging", 0);
1388 int zlib = qdict_get_try_bool(qdict, "zlib", 0);
1389 int lzo = qdict_get_try_bool(qdict, "lzo", 0);
1390 int snappy = qdict_get_try_bool(qdict, "snappy", 0);
1391 const char *file = qdict_get_str(qdict, "filename");
1392 bool has_begin = qdict_haskey(qdict, "begin");
1393 bool has_length = qdict_haskey(qdict, "length");
1394 int64_t begin = 0;
1395 int64_t length = 0;
1396 enum DumpGuestMemoryFormat dump_format = DUMP_GUEST_MEMORY_FORMAT_ELF;
1397 char *prot;
1399 if (zlib + lzo + snappy > 1) {
1400 error_setg(&err, "only one of '-z|-l|-s' can be set");
1401 hmp_handle_error(mon, &err);
1402 return;
1405 if (zlib) {
1406 dump_format = DUMP_GUEST_MEMORY_FORMAT_KDUMP_ZLIB;
1409 if (lzo) {
1410 dump_format = DUMP_GUEST_MEMORY_FORMAT_KDUMP_LZO;
1413 if (snappy) {
1414 dump_format = DUMP_GUEST_MEMORY_FORMAT_KDUMP_SNAPPY;
1417 if (has_begin) {
1418 begin = qdict_get_int(qdict, "begin");
1420 if (has_length) {
1421 length = qdict_get_int(qdict, "length");
1424 prot = g_strconcat("file:", file, NULL);
1426 qmp_dump_guest_memory(paging, prot, has_begin, begin, has_length, length,
1427 true, dump_format, &err);
1428 hmp_handle_error(mon, &err);
1429 g_free(prot);
1432 void hmp_netdev_add(Monitor *mon, const QDict *qdict)
1434 Error *err = NULL;
1435 QemuOpts *opts;
1437 opts = qemu_opts_from_qdict(qemu_find_opts("netdev"), qdict, &err);
1438 if (err) {
1439 goto out;
1442 netdev_add(opts, &err);
1443 if (err) {
1444 qemu_opts_del(opts);
1447 out:
1448 hmp_handle_error(mon, &err);
1451 void hmp_netdev_del(Monitor *mon, const QDict *qdict)
1453 const char *id = qdict_get_str(qdict, "id");
1454 Error *err = NULL;
1456 qmp_netdev_del(id, &err);
1457 hmp_handle_error(mon, &err);
1460 void hmp_object_add(Monitor *mon, const QDict *qdict)
1462 Error *err = NULL;
1463 Error *err_end = NULL;
1464 QemuOpts *opts;
1465 char *type = NULL;
1466 char *id = NULL;
1467 void *dummy = NULL;
1468 OptsVisitor *ov;
1469 QDict *pdict;
1471 opts = qemu_opts_from_qdict(qemu_find_opts("object"), qdict, &err);
1472 if (err) {
1473 goto out;
1476 ov = opts_visitor_new(opts);
1477 pdict = qdict_clone_shallow(qdict);
1479 visit_start_struct(opts_get_visitor(ov), &dummy, NULL, NULL, 0, &err);
1480 if (err) {
1481 goto out_clean;
1484 qdict_del(pdict, "qom-type");
1485 visit_type_str(opts_get_visitor(ov), &type, "qom-type", &err);
1486 if (err) {
1487 goto out_end;
1490 qdict_del(pdict, "id");
1491 visit_type_str(opts_get_visitor(ov), &id, "id", &err);
1492 if (err) {
1493 goto out_end;
1496 object_add(type, id, pdict, opts_get_visitor(ov), &err);
1498 out_end:
1499 visit_end_struct(opts_get_visitor(ov), &err_end);
1500 if (!err && err_end) {
1501 qmp_object_del(id, NULL);
1503 error_propagate(&err, err_end);
1504 out_clean:
1505 opts_visitor_cleanup(ov);
1507 QDECREF(pdict);
1508 qemu_opts_del(opts);
1509 g_free(id);
1510 g_free(type);
1511 g_free(dummy);
1513 out:
1514 hmp_handle_error(mon, &err);
1517 void hmp_getfd(Monitor *mon, const QDict *qdict)
1519 const char *fdname = qdict_get_str(qdict, "fdname");
1520 Error *err = NULL;
1522 qmp_getfd(fdname, &err);
1523 hmp_handle_error(mon, &err);
1526 void hmp_closefd(Monitor *mon, const QDict *qdict)
1528 const char *fdname = qdict_get_str(qdict, "fdname");
1529 Error *err = NULL;
1531 qmp_closefd(fdname, &err);
1532 hmp_handle_error(mon, &err);
1535 void hmp_send_key(Monitor *mon, const QDict *qdict)
1537 const char *keys = qdict_get_str(qdict, "keys");
1538 KeyValueList *keylist, *head = NULL, *tmp = NULL;
1539 int has_hold_time = qdict_haskey(qdict, "hold-time");
1540 int hold_time = qdict_get_try_int(qdict, "hold-time", -1);
1541 Error *err = NULL;
1542 char keyname_buf[16];
1543 char *separator;
1544 int keyname_len;
1546 while (1) {
1547 separator = strchr(keys, '-');
1548 keyname_len = separator ? separator - keys : strlen(keys);
1549 pstrcpy(keyname_buf, sizeof(keyname_buf), keys);
1551 /* Be compatible with old interface, convert user inputted "<" */
1552 if (!strncmp(keyname_buf, "<", 1) && keyname_len == 1) {
1553 pstrcpy(keyname_buf, sizeof(keyname_buf), "less");
1554 keyname_len = 4;
1556 keyname_buf[keyname_len] = 0;
1558 keylist = g_malloc0(sizeof(*keylist));
1559 keylist->value = g_malloc0(sizeof(*keylist->value));
1561 if (!head) {
1562 head = keylist;
1564 if (tmp) {
1565 tmp->next = keylist;
1567 tmp = keylist;
1569 if (strstart(keyname_buf, "0x", NULL)) {
1570 char *endp;
1571 int value = strtoul(keyname_buf, &endp, 0);
1572 if (*endp != '\0') {
1573 goto err_out;
1575 keylist->value->kind = KEY_VALUE_KIND_NUMBER;
1576 keylist->value->number = value;
1577 } else {
1578 int idx = index_from_key(keyname_buf);
1579 if (idx == Q_KEY_CODE_MAX) {
1580 goto err_out;
1582 keylist->value->kind = KEY_VALUE_KIND_QCODE;
1583 keylist->value->qcode = idx;
1586 if (!separator) {
1587 break;
1589 keys = separator + 1;
1592 qmp_send_key(head, has_hold_time, hold_time, &err);
1593 hmp_handle_error(mon, &err);
1595 out:
1596 qapi_free_KeyValueList(head);
1597 return;
1599 err_out:
1600 monitor_printf(mon, "invalid parameter: %s\n", keyname_buf);
1601 goto out;
1604 void hmp_screen_dump(Monitor *mon, const QDict *qdict)
1606 const char *filename = qdict_get_str(qdict, "filename");
1607 Error *err = NULL;
1609 qmp_screendump(filename, &err);
1610 hmp_handle_error(mon, &err);
1613 void hmp_nbd_server_start(Monitor *mon, const QDict *qdict)
1615 const char *uri = qdict_get_str(qdict, "uri");
1616 int writable = qdict_get_try_bool(qdict, "writable", 0);
1617 int all = qdict_get_try_bool(qdict, "all", 0);
1618 Error *local_err = NULL;
1619 BlockInfoList *block_list, *info;
1620 SocketAddress *addr;
1622 if (writable && !all) {
1623 error_setg(&local_err, "-w only valid together with -a");
1624 goto exit;
1627 /* First check if the address is valid and start the server. */
1628 addr = socket_parse(uri, &local_err);
1629 if (local_err != NULL) {
1630 goto exit;
1633 qmp_nbd_server_start(addr, &local_err);
1634 qapi_free_SocketAddress(addr);
1635 if (local_err != NULL) {
1636 goto exit;
1639 if (!all) {
1640 return;
1643 /* Then try adding all block devices. If one fails, close all and
1644 * exit.
1646 block_list = qmp_query_block(NULL);
1648 for (info = block_list; info; info = info->next) {
1649 if (!info->value->has_inserted) {
1650 continue;
1653 qmp_nbd_server_add(info->value->device, true, writable, &local_err);
1655 if (local_err != NULL) {
1656 qmp_nbd_server_stop(NULL);
1657 break;
1661 qapi_free_BlockInfoList(block_list);
1663 exit:
1664 hmp_handle_error(mon, &local_err);
1667 void hmp_nbd_server_add(Monitor *mon, const QDict *qdict)
1669 const char *device = qdict_get_str(qdict, "device");
1670 int writable = qdict_get_try_bool(qdict, "writable", 0);
1671 Error *local_err = NULL;
1673 qmp_nbd_server_add(device, true, writable, &local_err);
1675 if (local_err != NULL) {
1676 hmp_handle_error(mon, &local_err);
1680 void hmp_nbd_server_stop(Monitor *mon, const QDict *qdict)
1682 Error *err = NULL;
1684 qmp_nbd_server_stop(&err);
1685 hmp_handle_error(mon, &err);
1688 void hmp_cpu_add(Monitor *mon, const QDict *qdict)
1690 int cpuid;
1691 Error *err = NULL;
1693 cpuid = qdict_get_int(qdict, "id");
1694 qmp_cpu_add(cpuid, &err);
1695 hmp_handle_error(mon, &err);
1698 void hmp_chardev_add(Monitor *mon, const QDict *qdict)
1700 const char *args = qdict_get_str(qdict, "args");
1701 Error *err = NULL;
1702 QemuOpts *opts;
1704 opts = qemu_opts_parse(qemu_find_opts("chardev"), args, 1);
1705 if (opts == NULL) {
1706 error_setg(&err, "Parsing chardev args failed");
1707 } else {
1708 qemu_chr_new_from_opts(opts, NULL, &err);
1710 hmp_handle_error(mon, &err);
1713 void hmp_chardev_remove(Monitor *mon, const QDict *qdict)
1715 Error *local_err = NULL;
1717 qmp_chardev_remove(qdict_get_str(qdict, "id"), &local_err);
1718 hmp_handle_error(mon, &local_err);
1721 void hmp_qemu_io(Monitor *mon, const QDict *qdict)
1723 BlockDriverState *bs;
1724 const char* device = qdict_get_str(qdict, "device");
1725 const char* command = qdict_get_str(qdict, "command");
1726 Error *err = NULL;
1728 bs = bdrv_find(device);
1729 if (bs) {
1730 qemuio_command(bs, command);
1731 } else {
1732 error_set(&err, QERR_DEVICE_NOT_FOUND, device);
1735 hmp_handle_error(mon, &err);
1738 void hmp_object_del(Monitor *mon, const QDict *qdict)
1740 const char *id = qdict_get_str(qdict, "id");
1741 Error *err = NULL;
1743 qmp_object_del(id, &err);
1744 hmp_handle_error(mon, &err);
1747 void hmp_info_memdev(Monitor *mon, const QDict *qdict)
1749 Error *err = NULL;
1750 MemdevList *memdev_list = qmp_query_memdev(&err);
1751 MemdevList *m = memdev_list;
1752 StringOutputVisitor *ov;
1753 char *str;
1754 int i = 0;
1757 while (m) {
1758 ov = string_output_visitor_new(false);
1759 visit_type_uint16List(string_output_get_visitor(ov),
1760 &m->value->host_nodes, NULL, NULL);
1761 monitor_printf(mon, "memory backend: %d\n", i);
1762 monitor_printf(mon, " size: %" PRId64 "\n", m->value->size);
1763 monitor_printf(mon, " merge: %s\n",
1764 m->value->merge ? "true" : "false");
1765 monitor_printf(mon, " dump: %s\n",
1766 m->value->dump ? "true" : "false");
1767 monitor_printf(mon, " prealloc: %s\n",
1768 m->value->prealloc ? "true" : "false");
1769 monitor_printf(mon, " policy: %s\n",
1770 HostMemPolicy_lookup[m->value->policy]);
1771 str = string_output_get_string(ov);
1772 monitor_printf(mon, " host nodes: %s\n", str);
1774 g_free(str);
1775 string_output_visitor_cleanup(ov);
1776 m = m->next;
1777 i++;
1780 monitor_printf(mon, "\n");
1782 qapi_free_MemdevList(memdev_list);
1785 void hmp_info_memory_devices(Monitor *mon, const QDict *qdict)
1787 Error *err = NULL;
1788 MemoryDeviceInfoList *info_list = qmp_query_memory_devices(&err);
1789 MemoryDeviceInfoList *info;
1790 MemoryDeviceInfo *value;
1791 PCDIMMDeviceInfo *di;
1793 for (info = info_list; info; info = info->next) {
1794 value = info->value;
1796 if (value) {
1797 switch (value->kind) {
1798 case MEMORY_DEVICE_INFO_KIND_DIMM:
1799 di = value->dimm;
1801 monitor_printf(mon, "Memory device [%s]: \"%s\"\n",
1802 MemoryDeviceInfoKind_lookup[value->kind],
1803 di->id ? di->id : "");
1804 monitor_printf(mon, " addr: 0x%" PRIx64 "\n", di->addr);
1805 monitor_printf(mon, " slot: %" PRId64 "\n", di->slot);
1806 monitor_printf(mon, " node: %" PRId64 "\n", di->node);
1807 monitor_printf(mon, " size: %" PRIu64 "\n", di->size);
1808 monitor_printf(mon, " memdev: %s\n", di->memdev);
1809 monitor_printf(mon, " hotplugged: %s\n",
1810 di->hotplugged ? "true" : "false");
1811 monitor_printf(mon, " hotpluggable: %s\n",
1812 di->hotpluggable ? "true" : "false");
1813 break;
1814 default:
1815 break;
1820 qapi_free_MemoryDeviceInfoList(info_list);