hmp.c

   1 /*
   2  * Human Monitor Interface
   3  *
   4  * Copyright IBM, Corp. 2011
   5  *
   6  * Authors:
   7  *  Anthony Liguori   <aliguori@us.ibm.com>
   8  *
   9  * This work is licensed under the terms of the GNU GPL, version 2.  See
  10  * the COPYING file in the top-level directory.
  11  *
  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.
  14  */
  15
  16 #include "hmp.h"
  17 #include "net.h"
  18 #include "qemu-option.h"
  19 #include "qemu-timer.h"
  20 #include "qmp-commands.h"
  21 #include "monitor.h"
  22
  23 static void hmp_handle_error(Monitor *mon, Error **errp)
  24 {
  25     if (error_is_set(errp)) {
  26         monitor_printf(mon, "%s\n", error_get_pretty(*errp));
  27         error_free(*errp);
  28     }
  29 }
  30
  31 void hmp_info_name(Monitor *mon)
  32 {
  33     NameInfo *info;
  34
  35     info = qmp_query_name(NULL);
  36     if (info->has_name) {
  37         monitor_printf(mon, "%s\n", info->name);
  38     }
  39     qapi_free_NameInfo(info);
  40 }
  41
  42 void hmp_info_version(Monitor *mon)
  43 {
  44     VersionInfo *info;
  45
  46     info = qmp_query_version(NULL);
  47
  48     monitor_printf(mon, "%" PRId64 ".%" PRId64 ".%" PRId64 "%s\n",
  49                    info->qemu.major, info->qemu.minor, info->qemu.micro,
  50                    info->package);
  51
  52     qapi_free_VersionInfo(info);
  53 }
  54
  55 void hmp_info_kvm(Monitor *mon)
  56 {
  57     KvmInfo *info;
  58
  59     info = qmp_query_kvm(NULL);
  60     monitor_printf(mon, "kvm support: ");
  61     if (info->present) {
  62         monitor_printf(mon, "%s\n", info->enabled ? "enabled" : "disabled");
  63     } else {
  64         monitor_printf(mon, "not compiled\n");
  65     }
  66
  67     qapi_free_KvmInfo(info);
  68 }
  69
  70 void hmp_info_status(Monitor *mon)
  71 {
  72     StatusInfo *info;
  73
  74     info = qmp_query_status(NULL);
  75
  76     monitor_printf(mon, "VM status: %s%s",
  77                    info->running ? "running" : "paused",
  78                    info->singlestep ? " (single step mode)" : "");
  79
  80     if (!info->running && info->status != RUN_STATE_PAUSED) {
  81         monitor_printf(mon, " (%s)", RunState_lookup[info->status]);
  82     }
  83
  84     monitor_printf(mon, "\n");
  85
  86     qapi_free_StatusInfo(info);
  87 }
  88
  89 void hmp_info_uuid(Monitor *mon)
  90 {
  91     UuidInfo *info;
  92
  93     info = qmp_query_uuid(NULL);
  94     monitor_printf(mon, "%s\n", info->UUID);
  95     qapi_free_UuidInfo(info);
  96 }
  97
  98 void hmp_info_chardev(Monitor *mon)
  99 {
 100     ChardevInfoList *char_info, *info;
 101
 102     char_info = qmp_query_chardev(NULL);
 103     for (info = char_info; info; info = info->next) {
 104         monitor_printf(mon, "%s: filename=%s\n", info->value->label,
 105                                                  info->value->filename);
 106     }
 107
 108     qapi_free_ChardevInfoList(char_info);
 109 }
 110
 111 void hmp_info_mice(Monitor *mon)
 112 {
 113     MouseInfoList *mice_list, *mouse;
 114
 115     mice_list = qmp_query_mice(NULL);
 116     if (!mice_list) {
 117         monitor_printf(mon, "No mouse devices connected\n");
 118         return;
 119     }
 120
 121     for (mouse = mice_list; mouse; mouse = mouse->next) {
 122         monitor_printf(mon, "%c Mouse #%" PRId64 ": %s%s\n",
 123                        mouse->value->current ? '*' : ' ',
 124                        mouse->value->index, mouse->value->name,
 125                        mouse->value->absolute ? " (absolute)" : "");
 126     }
 127
 128     qapi_free_MouseInfoList(mice_list);
 129 }
 130
 131 void hmp_info_migrate(Monitor *mon)
 132 {
 133     MigrationInfo *info;
 134
 135     info = qmp_query_migrate(NULL);
 136
 137     if (info->has_status) {
 138         monitor_printf(mon, "Migration status: %s\n", info->status);
 139     }
 140
 141     if (info->has_ram) {
 142         monitor_printf(mon, "transferred ram: %" PRIu64 " kbytes\n",
 143                        info->ram->transferred >> 10);
 144         monitor_printf(mon, "remaining ram: %" PRIu64 " kbytes\n",
 145                        info->ram->remaining >> 10);
 146         monitor_printf(mon, "total ram: %" PRIu64 " kbytes\n",
 147                        info->ram->total >> 10);
 148         monitor_printf(mon, "total time: %" PRIu64 " milliseconds\n",
 149                        info->ram->total_time);
 150     }
 151
 152     if (info->has_disk) {
 153         monitor_printf(mon, "transferred disk: %" PRIu64 " kbytes\n",
 154                        info->disk->transferred >> 10);
 155         monitor_printf(mon, "remaining disk: %" PRIu64 " kbytes\n",
 156                        info->disk->remaining >> 10);
 157         monitor_printf(mon, "total disk: %" PRIu64 " kbytes\n",
 158                        info->disk->total >> 10);
 159     }
 160
 161     qapi_free_MigrationInfo(info);
 162 }
 163
 164 void hmp_info_cpus(Monitor *mon)
 165 {
 166     CpuInfoList *cpu_list, *cpu;
 167
 168     cpu_list = qmp_query_cpus(NULL);
 169
 170     for (cpu = cpu_list; cpu; cpu = cpu->next) {
 171         int active = ' ';
 172
 173         if (cpu->value->CPU == monitor_get_cpu_index()) {
 174             active = '*';
 175         }
 176
 177         monitor_printf(mon, "%c CPU #%" PRId64 ": ", active, cpu->value->CPU);
 178
 179         if (cpu->value->has_pc) {
 180             monitor_printf(mon, "pc=0x%016" PRIx64, cpu->value->pc);
 181         }
 182         if (cpu->value->has_nip) {
 183             monitor_printf(mon, "nip=0x%016" PRIx64, cpu->value->nip);
 184         }
 185         if (cpu->value->has_npc) {
 186             monitor_printf(mon, "pc=0x%016" PRIx64, cpu->value->pc);
 187             monitor_printf(mon, "npc=0x%016" PRIx64, cpu->value->npc);
 188         }
 189         if (cpu->value->has_PC) {
 190             monitor_printf(mon, "PC=0x%016" PRIx64, cpu->value->PC);
 191         }
 192
 193         if (cpu->value->halted) {
 194             monitor_printf(mon, " (halted)");
 195         }
 196
 197         monitor_printf(mon, " thread_id=%" PRId64 "\n", cpu->value->thread_id);
 198     }
 199
 200     qapi_free_CpuInfoList(cpu_list);
 201 }
 202
 203 void hmp_info_block(Monitor *mon)
 204 {
 205     BlockInfoList *block_list, *info;
 206
 207     block_list = qmp_query_block(NULL);
 208
 209     for (info = block_list; info; info = info->next) {
 210         monitor_printf(mon, "%s: removable=%d",
 211                        info->value->device, info->value->removable);
 212
 213         if (info->value->removable) {
 214             monitor_printf(mon, " locked=%d", info->value->locked);
 215             monitor_printf(mon, " tray-open=%d", info->value->tray_open);
 216         }
 217
 218         if (info->value->has_io_status) {
 219             monitor_printf(mon, " io-status=%s",
 220                            BlockDeviceIoStatus_lookup[info->value->io_status]);
 221         }
 222
 223         if (info->value->has_inserted) {
 224             monitor_printf(mon, " file=");
 225             monitor_print_filename(mon, info->value->inserted->file);
 226
 227             if (info->value->inserted->has_backing_file) {
 228                 monitor_printf(mon, " backing_file=");
 229                 monitor_print_filename(mon, info->value->inserted->backing_file);
 230                 monitor_printf(mon, " backing_file_depth=%" PRId64,
 231                     info->value->inserted->backing_file_depth);
 232             }
 233             monitor_printf(mon, " ro=%d drv=%s encrypted=%d",
 234                            info->value->inserted->ro,
 235                            info->value->inserted->drv,
 236                            info->value->inserted->encrypted);
 237
 238             monitor_printf(mon, " bps=%" PRId64 " bps_rd=%" PRId64
 239                             " bps_wr=%" PRId64 " iops=%" PRId64
 240                             " iops_rd=%" PRId64 " iops_wr=%" PRId64,
 241                             info->value->inserted->bps,
 242                             info->value->inserted->bps_rd,
 243                             info->value->inserted->bps_wr,
 244                             info->value->inserted->iops,
 245                             info->value->inserted->iops_rd,
 246                             info->value->inserted->iops_wr);
 247         } else {
 248             monitor_printf(mon, " [not inserted]");
 249         }
 250
 251         monitor_printf(mon, "\n");
 252     }
 253
 254     qapi_free_BlockInfoList(block_list);
 255 }
 256
 257 void hmp_info_blockstats(Monitor *mon)
 258 {
 259     BlockStatsList *stats_list, *stats;
 260
 261     stats_list = qmp_query_blockstats(NULL);
 262
 263     for (stats = stats_list; stats; stats = stats->next) {
 264         if (!stats->value->has_device) {
 265             continue;
 266         }
 267
 268         monitor_printf(mon, "%s:", stats->value->device);
 269         monitor_printf(mon, " rd_bytes=%" PRId64
 270                        " wr_bytes=%" PRId64
 271                        " rd_operations=%" PRId64
 272                        " wr_operations=%" PRId64
 273                        " flush_operations=%" PRId64
 274                        " wr_total_time_ns=%" PRId64
 275                        " rd_total_time_ns=%" PRId64
 276                        " flush_total_time_ns=%" PRId64
 277                        "\n",
 278                        stats->value->stats->rd_bytes,
 279                        stats->value->stats->wr_bytes,
 280                        stats->value->stats->rd_operations,
 281                        stats->value->stats->wr_operations,
 282                        stats->value->stats->flush_operations,
 283                        stats->value->stats->wr_total_time_ns,
 284                        stats->value->stats->rd_total_time_ns,
 285                        stats->value->stats->flush_total_time_ns);
 286     }
 287
 288     qapi_free_BlockStatsList(stats_list);
 289 }
 290
 291 void hmp_info_vnc(Monitor *mon)
 292 {
 293     VncInfo *info;
 294     Error *err = NULL;
 295     VncClientInfoList *client;
 296
 297     info = qmp_query_vnc(&err);
 298     if (err) {
 299         monitor_printf(mon, "%s\n", error_get_pretty(err));
 300         error_free(err);
 301         return;
 302     }
 303
 304     if (!info->enabled) {
 305         monitor_printf(mon, "Server: disabled\n");
 306         goto out;
 307     }
 308
 309     monitor_printf(mon, "Server:\n");
 310     if (info->has_host && info->has_service) {
 311         monitor_printf(mon, "     address: %s:%s\n", info->host, info->service);
 312     }
 313     if (info->has_auth) {
 314         monitor_printf(mon, "        auth: %s\n", info->auth);
 315     }
 316
 317     if (!info->has_clients || info->clients == NULL) {
 318         monitor_printf(mon, "Client: none\n");
 319     } else {
 320         for (client = info->clients; client; client = client->next) {
 321             monitor_printf(mon, "Client:\n");
 322             monitor_printf(mon, "     address: %s:%s\n",
 323                            client->value->host, client->value->service);
 324             monitor_printf(mon, "  x509_dname: %s\n",
 325                            client->value->x509_dname ?
 326                            client->value->x509_dname : "none");
 327             monitor_printf(mon, "    username: %s\n",
 328                            client->value->has_sasl_username ?
 329                            client->value->sasl_username : "none");
 330         }
 331     }
 332
 333 out:
 334     qapi_free_VncInfo(info);
 335 }
 336
 337 void hmp_info_spice(Monitor *mon)
 338 {
 339     SpiceChannelList *chan;
 340     SpiceInfo *info;
 341
 342     info = qmp_query_spice(NULL);
 343
 344     if (!info->enabled) {
 345         monitor_printf(mon, "Server: disabled\n");
 346         goto out;
 347     }
 348
 349     monitor_printf(mon, "Server:\n");
 350     if (info->has_port) {
 351         monitor_printf(mon, "     address: %s:%" PRId64 "\n",
 352                        info->host, info->port);
 353     }
 354     if (info->has_tls_port) {
 355         monitor_printf(mon, "     address: %s:%" PRId64 " [tls]\n",
 356                        info->host, info->tls_port);
 357     }
 358     monitor_printf(mon, "        auth: %s\n", info->auth);
 359     monitor_printf(mon, "    compiled: %s\n", info->compiled_version);
 360     monitor_printf(mon, "  mouse-mode: %s\n",
 361                    SpiceQueryMouseMode_lookup[info->mouse_mode]);
 362
 363     if (!info->has_channels || info->channels == NULL) {
 364         monitor_printf(mon, "Channels: none\n");
 365     } else {
 366         for (chan = info->channels; chan; chan = chan->next) {
 367             monitor_printf(mon, "Channel:\n");
 368             monitor_printf(mon, "     address: %s:%s%s\n",
 369                            chan->value->host, chan->value->port,
 370                            chan->value->tls ? " [tls]" : "");
 371             monitor_printf(mon, "     session: %" PRId64 "\n",
 372                            chan->value->connection_id);
 373             monitor_printf(mon, "     channel: %" PRId64 ":%" PRId64 "\n",
 374                            chan->value->channel_type, chan->value->channel_id);
 375         }
 376     }
 377
 378 out:
 379     qapi_free_SpiceInfo(info);
 380 }
 381
 382 void hmp_info_balloon(Monitor *mon)
 383 {
 384     BalloonInfo *info;
 385     Error *err = NULL;
 386
 387     info = qmp_query_balloon(&err);
 388     if (err) {
 389         monitor_printf(mon, "%s\n", error_get_pretty(err));
 390         error_free(err);
 391         return;
 392     }
 393
 394     monitor_printf(mon, "balloon: actual=%" PRId64, info->actual >> 20);
 395     if (info->has_mem_swapped_in) {
 396         monitor_printf(mon, " mem_swapped_in=%" PRId64, info->mem_swapped_in);
 397     }
 398     if (info->has_mem_swapped_out) {
 399         monitor_printf(mon, " mem_swapped_out=%" PRId64, info->mem_swapped_out);
 400     }
 401     if (info->has_major_page_faults) {
 402         monitor_printf(mon, " major_page_faults=%" PRId64,
 403                        info->major_page_faults);
 404     }
 405     if (info->has_minor_page_faults) {
 406         monitor_printf(mon, " minor_page_faults=%" PRId64,
 407                        info->minor_page_faults);
 408     }
 409     if (info->has_free_mem) {
 410         monitor_printf(mon, " free_mem=%" PRId64, info->free_mem);
 411     }
 412     if (info->has_total_mem) {
 413         monitor_printf(mon, " total_mem=%" PRId64, info->total_mem);
 414     }
 415
 416     monitor_printf(mon, "\n");
 417
 418     qapi_free_BalloonInfo(info);
 419 }
 420
 421 static void hmp_info_pci_device(Monitor *mon, const PciDeviceInfo *dev)
 422 {
 423     PciMemoryRegionList *region;
 424
 425     monitor_printf(mon, "  Bus %2" PRId64 ", ", dev->bus);
 426     monitor_printf(mon, "device %3" PRId64 ", function %" PRId64 ":\n",
 427                    dev->slot, dev->function);
 428     monitor_printf(mon, "    ");
 429
 430     if (dev->class_info.has_desc) {
 431         monitor_printf(mon, "%s", dev->class_info.desc);
 432     } else {
 433         monitor_printf(mon, "Class %04" PRId64, dev->class_info.class);
 434     }
 435
 436     monitor_printf(mon, ": PCI device %04" PRIx64 ":%04" PRIx64 "\n",
 437                    dev->id.vendor, dev->id.device);
 438
 439     if (dev->has_irq) {
 440         monitor_printf(mon, "      IRQ %" PRId64 ".\n", dev->irq);
 441     }
 442
 443     if (dev->has_pci_bridge) {
 444         monitor_printf(mon, "      BUS %" PRId64 ".\n",
 445                        dev->pci_bridge->bus.number);
 446         monitor_printf(mon, "      secondary bus %" PRId64 ".\n",
 447                        dev->pci_bridge->bus.secondary);
 448         monitor_printf(mon, "      subordinate bus %" PRId64 ".\n",
 449                        dev->pci_bridge->bus.subordinate);
 450
 451         monitor_printf(mon, "      IO range [0x%04"PRIx64", 0x%04"PRIx64"]\n",
 452                        dev->pci_bridge->bus.io_range->base,
 453                        dev->pci_bridge->bus.io_range->limit);
 454
 455         monitor_printf(mon,
 456                        "      memory range [0x%08"PRIx64", 0x%08"PRIx64"]\n",
 457                        dev->pci_bridge->bus.memory_range->base,
 458                        dev->pci_bridge->bus.memory_range->limit);
 459
 460         monitor_printf(mon, "      prefetchable memory range "
 461                        "[0x%08"PRIx64", 0x%08"PRIx64"]\n",
 462                        dev->pci_bridge->bus.prefetchable_range->base,
 463                        dev->pci_bridge->bus.prefetchable_range->limit);
 464     }
 465
 466     for (region = dev->regions; region; region = region->next) {
 467         uint64_t addr, size;
 468
 469         addr = region->value->address;
 470         size = region->value->size;
 471
 472         monitor_printf(mon, "      BAR%" PRId64 ": ", region->value->bar);
 473
 474         if (!strcmp(region->value->type, "io")) {
 475             monitor_printf(mon, "I/O at 0x%04" PRIx64
 476                                 " [0x%04" PRIx64 "].\n",
 477                            addr, addr + size - 1);
 478         } else {
 479             monitor_printf(mon, "%d bit%s memory at 0x%08" PRIx64
 480                                " [0x%08" PRIx64 "].\n",
 481                            region->value->mem_type_64 ? 64 : 32,
 482                            region->value->prefetch ? " prefetchable" : "",
 483                            addr, addr + size - 1);
 484         }
 485     }
 486
 487     monitor_printf(mon, "      id \"%s\"\n", dev->qdev_id);
 488
 489     if (dev->has_pci_bridge) {
 490         if (dev->pci_bridge->has_devices) {
 491             PciDeviceInfoList *cdev;
 492             for (cdev = dev->pci_bridge->devices; cdev; cdev = cdev->next) {
 493                 hmp_info_pci_device(mon, cdev->value);
 494             }
 495         }
 496     }
 497 }
 498
 499 void hmp_info_pci(Monitor *mon)
 500 {
 501     PciInfoList *info_list, *info;
 502     Error *err = NULL;
 503
 504     info_list = qmp_query_pci(&err);
 505     if (err) {
 506         monitor_printf(mon, "PCI devices not supported\n");
 507         error_free(err);
 508         return;
 509     }
 510
 511     for (info = info_list; info; info = info->next) {
 512         PciDeviceInfoList *dev;
 513
 514         for (dev = info->value->devices; dev; dev = dev->next) {
 515             hmp_info_pci_device(mon, dev->value);
 516         }
 517     }
 518
 519     qapi_free_PciInfoList(info_list);
 520 }
 521
 522 void hmp_info_block_jobs(Monitor *mon)
 523 {
 524     BlockJobInfoList *list;
 525     Error *err = NULL;
 526
 527     list = qmp_query_block_jobs(&err);
 528     assert(!err);
 529
 530     if (!list) {
 531         monitor_printf(mon, "No active jobs\n");
 532         return;
 533     }
 534
 535     while (list) {
 536         if (strcmp(list->value->type, "stream") == 0) {
 537             monitor_printf(mon, "Streaming device %s: Completed %" PRId64
 538                            " of %" PRId64 " bytes, speed limit %" PRId64
 539                            " bytes/s\n",
 540                            list->value->device,
 541                            list->value->offset,
 542                            list->value->len,
 543                            list->value->speed);
 544         } else {
 545             monitor_printf(mon, "Type %s, device %s: Completed %" PRId64
 546                            " of %" PRId64 " bytes, speed limit %" PRId64
 547                            " bytes/s\n",
 548                            list->value->type,
 549                            list->value->device,
 550                            list->value->offset,
 551                            list->value->len,
 552                            list->value->speed);
 553         }
 554         list = list->next;
 555     }
 556 }
 557
 558 void hmp_quit(Monitor *mon, const QDict *qdict)
 559 {
 560     monitor_suspend(mon);
 561     qmp_quit(NULL);
 562 }
 563
 564 void hmp_stop(Monitor *mon, const QDict *qdict)
 565 {
 566     qmp_stop(NULL);
 567 }
 568
 569 void hmp_system_reset(Monitor *mon, const QDict *qdict)
 570 {
 571     qmp_system_reset(NULL);
 572 }
 573
 574 void hmp_system_powerdown(Monitor *mon, const QDict *qdict)
 575 {
 576     qmp_system_powerdown(NULL);
 577 }
 578
 579 void hmp_cpu(Monitor *mon, const QDict *qdict)
 580 {
 581     int64_t cpu_index;
 582
 583     /* XXX: drop the monitor_set_cpu() usage when all HMP commands that
 584             use it are converted to the QAPI */
 585     cpu_index = qdict_get_int(qdict, "index");
 586     if (monitor_set_cpu(cpu_index) < 0) {
 587         monitor_printf(mon, "invalid CPU index\n");
 588     }
 589 }
 590
 591 void hmp_memsave(Monitor *mon, const QDict *qdict)
 592 {
 593     uint32_t size = qdict_get_int(qdict, "size");
 594     const char *filename = qdict_get_str(qdict, "filename");
 595     uint64_t addr = qdict_get_int(qdict, "val");
 596     Error *errp = NULL;
 597
 598     qmp_memsave(addr, size, filename, true, monitor_get_cpu_index(), &errp);
 599     hmp_handle_error(mon, &errp);
 600 }
 601
 602 void hmp_pmemsave(Monitor *mon, const QDict *qdict)
 603 {
 604     uint32_t size = qdict_get_int(qdict, "size");
 605     const char *filename = qdict_get_str(qdict, "filename");
 606     uint64_t addr = qdict_get_int(qdict, "val");
 607     Error *errp = NULL;
 608
 609     qmp_pmemsave(addr, size, filename, &errp);
 610     hmp_handle_error(mon, &errp);
 611 }
 612
 613 static void hmp_cont_cb(void *opaque, int err)
 614 {
 615     if (!err) {
 616         qmp_cont(NULL);
 617     }
 618 }
 619
 620 static bool key_is_missing(const BlockInfo *bdev)
 621 {
 622     return (bdev->inserted && bdev->inserted->encryption_key_missing);
 623 }
 624
 625 void hmp_cont(Monitor *mon, const QDict *qdict)
 626 {
 627     BlockInfoList *bdev_list, *bdev;
 628     Error *errp = NULL;
 629
 630     bdev_list = qmp_query_block(NULL);
 631     for (bdev = bdev_list; bdev; bdev = bdev->next) {
 632         if (key_is_missing(bdev->value)) {
 633             monitor_read_block_device_key(mon, bdev->value->device,
 634                                           hmp_cont_cb, NULL);
 635             goto out;
 636         }
 637     }
 638
 639     qmp_cont(&errp);
 640     hmp_handle_error(mon, &errp);
 641
 642 out:
 643     qapi_free_BlockInfoList(bdev_list);
 644 }
 645
 646 void hmp_system_wakeup(Monitor *mon, const QDict *qdict)
 647 {
 648     qmp_system_wakeup(NULL);
 649 }
 650
 651 void hmp_inject_nmi(Monitor *mon, const QDict *qdict)
 652 {
 653     Error *errp = NULL;
 654
 655     qmp_inject_nmi(&errp);
 656     hmp_handle_error(mon, &errp);
 657 }
 658
 659 void hmp_set_link(Monitor *mon, const QDict *qdict)
 660 {
 661     const char *name = qdict_get_str(qdict, "name");
 662     int up = qdict_get_bool(qdict, "up");
 663     Error *errp = NULL;
 664
 665     qmp_set_link(name, up, &errp);
 666     hmp_handle_error(mon, &errp);
 667 }
 668
 669 void hmp_block_passwd(Monitor *mon, const QDict *qdict)
 670 {
 671     const char *device = qdict_get_str(qdict, "device");
 672     const char *password = qdict_get_str(qdict, "password");
 673     Error *errp = NULL;
 674
 675     qmp_block_passwd(device, password, &errp);
 676     hmp_handle_error(mon, &errp);
 677 }
 678
 679 void hmp_balloon(Monitor *mon, const QDict *qdict)
 680 {
 681     int64_t value = qdict_get_int(qdict, "value");
 682     Error *errp = NULL;
 683
 684     qmp_balloon(value, &errp);
 685     if (error_is_set(&errp)) {
 686         monitor_printf(mon, "balloon: %s\n", error_get_pretty(errp));
 687         error_free(errp);
 688     }
 689 }
 690
 691 void hmp_block_resize(Monitor *mon, const QDict *qdict)
 692 {
 693     const char *device = qdict_get_str(qdict, "device");
 694     int64_t size = qdict_get_int(qdict, "size");
 695     Error *errp = NULL;
 696
 697     qmp_block_resize(device, size, &errp);
 698     hmp_handle_error(mon, &errp);
 699 }
 700
 701 void hmp_snapshot_blkdev(Monitor *mon, const QDict *qdict)
 702 {
 703     const char *device = qdict_get_str(qdict, "device");
 704     const char *filename = qdict_get_try_str(qdict, "snapshot-file");
 705     const char *format = qdict_get_try_str(qdict, "format");
 706     int reuse = qdict_get_try_bool(qdict, "reuse", 0);
 707     enum NewImageMode mode;
 708     Error *errp = NULL;
 709
 710     if (!filename) {
 711         /* In the future, if 'snapshot-file' is not specified, the snapshot
 712            will be taken internally. Today it's actually required. */
 713         error_set(&errp, QERR_MISSING_PARAMETER, "snapshot-file");
 714         hmp_handle_error(mon, &errp);
 715         return;
 716     }
 717
 718     mode = reuse ? NEW_IMAGE_MODE_EXISTING : NEW_IMAGE_MODE_ABSOLUTE_PATHS;
 719     qmp_blockdev_snapshot_sync(device, filename, !!format, format,
 720                                true, mode, &errp);
 721     hmp_handle_error(mon, &errp);
 722 }
 723
 724 void hmp_migrate_cancel(Monitor *mon, const QDict *qdict)
 725 {
 726     qmp_migrate_cancel(NULL);
 727 }
 728
 729 void hmp_migrate_set_downtime(Monitor *mon, const QDict *qdict)
 730 {
 731     double value = qdict_get_double(qdict, "value");
 732     qmp_migrate_set_downtime(value, NULL);
 733 }
 734
 735 void hmp_migrate_set_speed(Monitor *mon, const QDict *qdict)
 736 {
 737     int64_t value = qdict_get_int(qdict, "value");
 738     qmp_migrate_set_speed(value, NULL);
 739 }
 740
 741 void hmp_set_password(Monitor *mon, const QDict *qdict)
 742 {
 743     const char *protocol  = qdict_get_str(qdict, "protocol");
 744     const char *password  = qdict_get_str(qdict, "password");
 745     const char *connected = qdict_get_try_str(qdict, "connected");
 746     Error *err = NULL;
 747
 748     qmp_set_password(protocol, password, !!connected, connected, &err);
 749     hmp_handle_error(mon, &err);
 750 }
 751
 752 void hmp_expire_password(Monitor *mon, const QDict *qdict)
 753 {
 754     const char *protocol  = qdict_get_str(qdict, "protocol");
 755     const char *whenstr = qdict_get_str(qdict, "time");
 756     Error *err = NULL;
 757
 758     qmp_expire_password(protocol, whenstr, &err);
 759     hmp_handle_error(mon, &err);
 760 }
 761
 762 void hmp_eject(Monitor *mon, const QDict *qdict)
 763 {
 764     int force = qdict_get_try_bool(qdict, "force", 0);
 765     const char *device = qdict_get_str(qdict, "device");
 766     Error *err = NULL;
 767
 768     qmp_eject(device, true, force, &err);
 769     hmp_handle_error(mon, &err);
 770 }
 771
 772 static void hmp_change_read_arg(Monitor *mon, const char *password,
 773                                 void *opaque)
 774 {
 775     qmp_change_vnc_password(password, NULL);
 776     monitor_read_command(mon, 1);
 777 }
 778
 779 static void cb_hmp_change_bdrv_pwd(Monitor *mon, const char *password,
 780                                    void *opaque)
 781 {
 782     Error *encryption_err = opaque;
 783     Error *err = NULL;
 784     const char *device;
 785
 786     device = error_get_field(encryption_err, "device");
 787
 788     qmp_block_passwd(device, password, &err);
 789     hmp_handle_error(mon, &err);
 790     error_free(encryption_err);
 791
 792     monitor_read_command(mon, 1);
 793 }
 794
 795 void hmp_change(Monitor *mon, const QDict *qdict)
 796 {
 797     const char *device = qdict_get_str(qdict, "device");
 798     const char *target = qdict_get_str(qdict, "target");
 799     const char *arg = qdict_get_try_str(qdict, "arg");
 800     Error *err = NULL;
 801
 802     if (strcmp(device, "vnc") == 0 &&
 803             (strcmp(target, "passwd") == 0 ||
 804              strcmp(target, "password") == 0)) {
 805         if (!arg) {
 806             monitor_read_password(mon, hmp_change_read_arg, NULL);
 807             return;
 808         }
 809     }
 810
 811     qmp_change(device, target, !!arg, arg, &err);
 812     if (error_is_type(err, QERR_DEVICE_ENCRYPTED)) {
 813         monitor_printf(mon, "%s (%s) is encrypted.\n",
 814                        error_get_field(err, "device"),
 815                        error_get_field(err, "filename"));
 816         if (!monitor_get_rs(mon)) {
 817             monitor_printf(mon,
 818                     "terminal does not support password prompting\n");
 819             error_free(err);
 820             return;
 821         }
 822         readline_start(monitor_get_rs(mon), "Password: ", 1,
 823                        cb_hmp_change_bdrv_pwd, err);
 824         return;
 825     }
 826     hmp_handle_error(mon, &err);
 827 }
 828
 829 void hmp_block_set_io_throttle(Monitor *mon, const QDict *qdict)
 830 {
 831     Error *err = NULL;
 832
 833     qmp_block_set_io_throttle(qdict_get_str(qdict, "device"),
 834                               qdict_get_int(qdict, "bps"),
 835                               qdict_get_int(qdict, "bps_rd"),
 836                               qdict_get_int(qdict, "bps_wr"),
 837                               qdict_get_int(qdict, "iops"),
 838                               qdict_get_int(qdict, "iops_rd"),
 839                               qdict_get_int(qdict, "iops_wr"), &err);
 840     hmp_handle_error(mon, &err);
 841 }
 842
 843 void hmp_block_stream(Monitor *mon, const QDict *qdict)
 844 {
 845     Error *error = NULL;
 846     const char *device = qdict_get_str(qdict, "device");
 847     const char *base = qdict_get_try_str(qdict, "base");
 848     int64_t speed = qdict_get_try_int(qdict, "speed", 0);
 849
 850     qmp_block_stream(device, base != NULL, base,
 851                      qdict_haskey(qdict, "speed"), speed, &error);
 852
 853     hmp_handle_error(mon, &error);
 854 }
 855
 856 void hmp_block_job_set_speed(Monitor *mon, const QDict *qdict)
 857 {
 858     Error *error = NULL;
 859     const char *device = qdict_get_str(qdict, "device");
 860     int64_t value = qdict_get_int(qdict, "speed");
 861
 862     qmp_block_job_set_speed(device, value, &error);
 863
 864     hmp_handle_error(mon, &error);
 865 }
 866
 867 void hmp_block_job_cancel(Monitor *mon, const QDict *qdict)
 868 {
 869     Error *error = NULL;
 870     const char *device = qdict_get_str(qdict, "device");
 871
 872     qmp_block_job_cancel(device, &error);
 873
 874     hmp_handle_error(mon, &error);
 875 }
 876
 877 typedef struct MigrationStatus
 878 {
 879     QEMUTimer *timer;
 880     Monitor *mon;
 881     bool is_block_migration;
 882 } MigrationStatus;
 883
 884 static void hmp_migrate_status_cb(void *opaque)
 885 {
 886     MigrationStatus *status = opaque;
 887     MigrationInfo *info;
 888
 889     info = qmp_query_migrate(NULL);
 890     if (!info->has_status || strcmp(info->status, "active") == 0) {
 891         if (info->has_disk) {
 892             int progress;
 893
 894             if (info->disk->remaining) {
 895                 progress = info->disk->transferred * 100 / info->disk->total;
 896             } else {
 897                 progress = 100;
 898             }
 899
 900             monitor_printf(status->mon, "Completed %d %%\r", progress);
 901             monitor_flush(status->mon);
 902         }
 903
 904         qemu_mod_timer(status->timer, qemu_get_clock_ms(rt_clock) + 1000);
 905     } else {
 906         if (status->is_block_migration) {
 907             monitor_printf(status->mon, "\n");
 908         }
 909         monitor_resume(status->mon);
 910         qemu_del_timer(status->timer);
 911         g_free(status);
 912     }
 913
 914     qapi_free_MigrationInfo(info);
 915 }
 916
 917 void hmp_migrate(Monitor *mon, const QDict *qdict)
 918 {
 919     int detach = qdict_get_try_bool(qdict, "detach", 0);
 920     int blk = qdict_get_try_bool(qdict, "blk", 0);
 921     int inc = qdict_get_try_bool(qdict, "inc", 0);
 922     const char *uri = qdict_get_str(qdict, "uri");
 923     Error *err = NULL;
 924
 925     qmp_migrate(uri, !!blk, blk, !!inc, inc, false, false, &err);
 926     if (err) {
 927         monitor_printf(mon, "migrate: %s\n", error_get_pretty(err));
 928         error_free(err);
 929         return;
 930     }
 931
 932     if (!detach) {
 933         MigrationStatus *status;
 934
 935         if (monitor_suspend(mon) < 0) {
 936             monitor_printf(mon, "terminal does not allow synchronous "
 937                            "migration, continuing detached\n");
 938             return;
 939         }
 940
 941         status = g_malloc0(sizeof(*status));
 942         status->mon = mon;
 943         status->is_block_migration = blk || inc;
 944         status->timer = qemu_new_timer_ms(rt_clock, hmp_migrate_status_cb,
 945                                           status);
 946         qemu_mod_timer(status->timer, qemu_get_clock_ms(rt_clock));
 947     }
 948 }
 949
 950 void hmp_device_del(Monitor *mon, const QDict *qdict)
 951 {
 952     const char *id = qdict_get_str(qdict, "id");
 953     Error *err = NULL;
 954
 955     qmp_device_del(id, &err);
 956     hmp_handle_error(mon, &err);
 957 }
 958
 959 void hmp_dump_guest_memory(Monitor *mon, const QDict *qdict)
 960 {
 961     Error *errp = NULL;
 962     int paging = qdict_get_try_bool(qdict, "paging", 0);
 963     const char *file = qdict_get_str(qdict, "protocol");
 964     bool has_begin = qdict_haskey(qdict, "begin");
 965     bool has_length = qdict_haskey(qdict, "length");
 966     int64_t begin = 0;
 967     int64_t length = 0;
 968
 969     if (has_begin) {
 970         begin = qdict_get_int(qdict, "begin");
 971     }
 972     if (has_length) {
 973         length = qdict_get_int(qdict, "length");
 974     }
 975
 976     qmp_dump_guest_memory(paging, file, has_begin, begin, has_length, length,
 977                           &errp);
 978     hmp_handle_error(mon, &errp);
 979 }
 980
 981 void hmp_netdev_add(Monitor *mon, const QDict *qdict)
 982 {
 983     Error *err = NULL;
 984     QemuOpts *opts;
 985
 986     opts = qemu_opts_from_qdict(qemu_find_opts("netdev"), qdict, &err);
 987     if (error_is_set(&err)) {
 988         goto out;
 989     }
 990
 991     netdev_add(opts, &err);
 992     if (error_is_set(&err)) {
 993         qemu_opts_del(opts);
 994     }
 995
 996 out:
 997     hmp_handle_error(mon, &err);
 998 }
 999
1000 void hmp_netdev_del(Monitor *mon, const QDict *qdict)
1001 {
1002     const char *id = qdict_get_str(qdict, "id");
1003     Error *err = NULL;
1004
1005     qmp_netdev_del(id, &err);
1006     hmp_handle_error(mon, &err);
1007 }
1008
1009 void hmp_getfd(Monitor *mon, const QDict *qdict)
1010 {
1011     const char *fdname = qdict_get_str(qdict, "fdname");
1012     Error *errp = NULL;
1013
1014     qmp_getfd(fdname, &errp);
1015     hmp_handle_error(mon, &errp);
1016 }
1017
1018 void hmp_closefd(Monitor *mon, const QDict *qdict)
1019 {
1020     const char *fdname = qdict_get_str(qdict, "fdname");
1021     Error *errp = NULL;
1022
1023     qmp_closefd(fdname, &errp);
1024     hmp_handle_error(mon, &errp);
1025 }