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/net.h"
  18 #include "char/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 "ui/console.h"
  25
  26 static void hmp_handle_error(Monitor *mon, Error **errp)
  27 {
  28     if (error_is_set(errp)) {
  29         monitor_printf(mon, "%s\n", error_get_pretty(*errp));
  30         error_free(*errp);
  31     }
  32 }
  33
  34 void hmp_info_name(Monitor *mon, const QDict *qdict)
  35 {
  36     NameInfo *info;
  37
  38     info = qmp_query_name(NULL);
  39     if (info->has_name) {
  40         monitor_printf(mon, "%s\n", info->name);
  41     }
  42     qapi_free_NameInfo(info);
  43 }
  44
  45 void hmp_info_version(Monitor *mon, const QDict *qdict)
  46 {
  47     VersionInfo *info;
  48
  49     info = qmp_query_version(NULL);
  50
  51     monitor_printf(mon, "%" PRId64 ".%" PRId64 ".%" PRId64 "%s\n",
  52                    info->qemu.major, info->qemu.minor, info->qemu.micro,
  53                    info->package);
  54
  55     qapi_free_VersionInfo(info);
  56 }
  57
  58 void hmp_info_kvm(Monitor *mon, const QDict *qdict)
  59 {
  60     KvmInfo *info;
  61
  62     info = qmp_query_kvm(NULL);
  63     monitor_printf(mon, "kvm support: ");
  64     if (info->present) {
  65         monitor_printf(mon, "%s\n", info->enabled ? "enabled" : "disabled");
  66     } else {
  67         monitor_printf(mon, "not compiled\n");
  68     }
  69
  70     qapi_free_KvmInfo(info);
  71 }
  72
  73 void hmp_info_status(Monitor *mon, const QDict *qdict)
  74 {
  75     StatusInfo *info;
  76
  77     info = qmp_query_status(NULL);
  78
  79     monitor_printf(mon, "VM status: %s%s",
  80                    info->running ? "running" : "paused",
  81                    info->singlestep ? " (single step mode)" : "");
  82
  83     if (!info->running && info->status != RUN_STATE_PAUSED) {
  84         monitor_printf(mon, " (%s)", RunState_lookup[info->status]);
  85     }
  86
  87     monitor_printf(mon, "\n");
  88
  89     qapi_free_StatusInfo(info);
  90 }
  91
  92 void hmp_info_uuid(Monitor *mon, const QDict *qdict)
  93 {
  94     UuidInfo *info;
  95
  96     info = qmp_query_uuid(NULL);
  97     monitor_printf(mon, "%s\n", info->UUID);
  98     qapi_free_UuidInfo(info);
  99 }
 100
 101 void hmp_info_chardev(Monitor *mon, const QDict *qdict)
 102 {
 103     ChardevInfoList *char_info, *info;
 104
 105     char_info = qmp_query_chardev(NULL);
 106     for (info = char_info; info; info = info->next) {
 107         monitor_printf(mon, "%s: filename=%s\n", info->value->label,
 108                                                  info->value->filename);
 109     }
 110
 111     qapi_free_ChardevInfoList(char_info);
 112 }
 113
 114 void hmp_info_mice(Monitor *mon, const QDict *qdict)
 115 {
 116     MouseInfoList *mice_list, *mouse;
 117
 118     mice_list = qmp_query_mice(NULL);
 119     if (!mice_list) {
 120         monitor_printf(mon, "No mouse devices connected\n");
 121         return;
 122     }
 123
 124     for (mouse = mice_list; mouse; mouse = mouse->next) {
 125         monitor_printf(mon, "%c Mouse #%" PRId64 ": %s%s\n",
 126                        mouse->value->current ? '*' : ' ',
 127                        mouse->value->index, mouse->value->name,
 128                        mouse->value->absolute ? " (absolute)" : "");
 129     }
 130
 131     qapi_free_MouseInfoList(mice_list);
 132 }
 133
 134 void hmp_info_migrate(Monitor *mon, const QDict *qdict)
 135 {
 136     MigrationInfo *info;
 137     MigrationCapabilityStatusList *caps, *cap;
 138
 139     info = qmp_query_migrate(NULL);
 140     caps = qmp_query_migrate_capabilities(NULL);
 141
 142     /* do not display parameters during setup */
 143     if (info->has_status && caps) {
 144         monitor_printf(mon, "capabilities: ");
 145         for (cap = caps; cap; cap = cap->next) {
 146             monitor_printf(mon, "%s: %s ",
 147                            MigrationCapability_lookup[cap->value->capability],
 148                            cap->value->state ? "on" : "off");
 149         }
 150         monitor_printf(mon, "\n");
 151     }
 152
 153     if (info->has_status) {
 154         monitor_printf(mon, "Migration status: %s\n", info->status);
 155         monitor_printf(mon, "total time: %" PRIu64 " milliseconds\n",
 156                        info->total_time);
 157         if (info->has_expected_downtime) {
 158             monitor_printf(mon, "expected downtime: %" PRIu64 " milliseconds\n",
 159                            info->expected_downtime);
 160         }
 161         if (info->has_downtime) {
 162             monitor_printf(mon, "downtime: %" PRIu64 " milliseconds\n",
 163                            info->downtime);
 164         }
 165     }
 166
 167     if (info->has_ram) {
 168         monitor_printf(mon, "transferred ram: %" PRIu64 " kbytes\n",
 169                        info->ram->transferred >> 10);
 170         monitor_printf(mon, "remaining ram: %" PRIu64 " kbytes\n",
 171                        info->ram->remaining >> 10);
 172         monitor_printf(mon, "total ram: %" PRIu64 " kbytes\n",
 173                        info->ram->total >> 10);
 174         monitor_printf(mon, "duplicate: %" PRIu64 " pages\n",
 175                        info->ram->duplicate);
 176         monitor_printf(mon, "normal: %" PRIu64 " pages\n",
 177                        info->ram->normal);
 178         monitor_printf(mon, "normal bytes: %" PRIu64 " kbytes\n",
 179                        info->ram->normal_bytes >> 10);
 180         if (info->ram->dirty_pages_rate) {
 181             monitor_printf(mon, "dirty pages rate: %" PRIu64 " pages\n",
 182                            info->ram->dirty_pages_rate);
 183         }
 184     }
 185
 186     if (info->has_disk) {
 187         monitor_printf(mon, "transferred disk: %" PRIu64 " kbytes\n",
 188                        info->disk->transferred >> 10);
 189         monitor_printf(mon, "remaining disk: %" PRIu64 " kbytes\n",
 190                        info->disk->remaining >> 10);
 191         monitor_printf(mon, "total disk: %" PRIu64 " kbytes\n",
 192                        info->disk->total >> 10);
 193     }
 194
 195     if (info->has_xbzrle_cache) {
 196         monitor_printf(mon, "cache size: %" PRIu64 " bytes\n",
 197                        info->xbzrle_cache->cache_size);
 198         monitor_printf(mon, "xbzrle transferred: %" PRIu64 " kbytes\n",
 199                        info->xbzrle_cache->bytes >> 10);
 200         monitor_printf(mon, "xbzrle pages: %" PRIu64 " pages\n",
 201                        info->xbzrle_cache->pages);
 202         monitor_printf(mon, "xbzrle cache miss: %" PRIu64 "\n",
 203                        info->xbzrle_cache->cache_miss);
 204         monitor_printf(mon, "xbzrle overflow : %" PRIu64 "\n",
 205                        info->xbzrle_cache->overflow);
 206     }
 207
 208     qapi_free_MigrationInfo(info);
 209     qapi_free_MigrationCapabilityStatusList(caps);
 210 }
 211
 212 void hmp_info_migrate_capabilities(Monitor *mon, const QDict *qdict)
 213 {
 214     MigrationCapabilityStatusList *caps, *cap;
 215
 216     caps = qmp_query_migrate_capabilities(NULL);
 217
 218     if (caps) {
 219         monitor_printf(mon, "capabilities: ");
 220         for (cap = caps; cap; cap = cap->next) {
 221             monitor_printf(mon, "%s: %s ",
 222                            MigrationCapability_lookup[cap->value->capability],
 223                            cap->value->state ? "on" : "off");
 224         }
 225         monitor_printf(mon, "\n");
 226     }
 227
 228     qapi_free_MigrationCapabilityStatusList(caps);
 229 }
 230
 231 void hmp_info_migrate_cache_size(Monitor *mon, const QDict *qdict)
 232 {
 233     monitor_printf(mon, "xbzrel cache size: %" PRId64 " kbytes\n",
 234                    qmp_query_migrate_cache_size(NULL) >> 10);
 235 }
 236
 237 void hmp_info_cpus(Monitor *mon, const QDict *qdict)
 238 {
 239     CpuInfoList *cpu_list, *cpu;
 240
 241     cpu_list = qmp_query_cpus(NULL);
 242
 243     for (cpu = cpu_list; cpu; cpu = cpu->next) {
 244         int active = ' ';
 245
 246         if (cpu->value->CPU == monitor_get_cpu_index()) {
 247             active = '*';
 248         }
 249
 250         monitor_printf(mon, "%c CPU #%" PRId64 ":", active, cpu->value->CPU);
 251
 252         if (cpu->value->has_pc) {
 253             monitor_printf(mon, " pc=0x%016" PRIx64, cpu->value->pc);
 254         }
 255         if (cpu->value->has_nip) {
 256             monitor_printf(mon, " nip=0x%016" PRIx64, cpu->value->nip);
 257         }
 258         if (cpu->value->has_npc) {
 259             monitor_printf(mon, " npc=0x%016" PRIx64, cpu->value->npc);
 260         }
 261         if (cpu->value->has_PC) {
 262             monitor_printf(mon, " PC=0x%016" PRIx64, cpu->value->PC);
 263         }
 264
 265         if (cpu->value->halted) {
 266             monitor_printf(mon, " (halted)");
 267         }
 268
 269         monitor_printf(mon, " thread_id=%" PRId64 "\n", cpu->value->thread_id);
 270     }
 271
 272     qapi_free_CpuInfoList(cpu_list);
 273 }
 274
 275 void hmp_info_block(Monitor *mon, const QDict *qdict)
 276 {
 277     BlockInfoList *block_list, *info;
 278
 279     block_list = qmp_query_block(NULL);
 280
 281     for (info = block_list; info; info = info->next) {
 282         monitor_printf(mon, "%s: removable=%d",
 283                        info->value->device, info->value->removable);
 284
 285         if (info->value->removable) {
 286             monitor_printf(mon, " locked=%d", info->value->locked);
 287             monitor_printf(mon, " tray-open=%d", info->value->tray_open);
 288         }
 289
 290         if (info->value->has_io_status) {
 291             monitor_printf(mon, " io-status=%s",
 292                            BlockDeviceIoStatus_lookup[info->value->io_status]);
 293         }
 294
 295         if (info->value->has_inserted) {
 296             monitor_printf(mon, " file=");
 297             monitor_print_filename(mon, info->value->inserted->file);
 298
 299             if (info->value->inserted->has_backing_file) {
 300                 monitor_printf(mon, " backing_file=");
 301                 monitor_print_filename(mon, info->value->inserted->backing_file);
 302                 monitor_printf(mon, " backing_file_depth=%" PRId64,
 303                     info->value->inserted->backing_file_depth);
 304             }
 305             monitor_printf(mon, " ro=%d drv=%s encrypted=%d",
 306                            info->value->inserted->ro,
 307                            info->value->inserted->drv,
 308                            info->value->inserted->encrypted);
 309
 310             monitor_printf(mon, " bps=%" PRId64 " bps_rd=%" PRId64
 311                             " bps_wr=%" PRId64 " iops=%" PRId64
 312                             " iops_rd=%" PRId64 " iops_wr=%" PRId64,
 313                             info->value->inserted->bps,
 314                             info->value->inserted->bps_rd,
 315                             info->value->inserted->bps_wr,
 316                             info->value->inserted->iops,
 317                             info->value->inserted->iops_rd,
 318                             info->value->inserted->iops_wr);
 319         } else {
 320             monitor_printf(mon, " [not inserted]");
 321         }
 322
 323         monitor_printf(mon, "\n");
 324     }
 325
 326     qapi_free_BlockInfoList(block_list);
 327 }
 328
 329 void hmp_info_blockstats(Monitor *mon, const QDict *qdict)
 330 {
 331     BlockStatsList *stats_list, *stats;
 332
 333     stats_list = qmp_query_blockstats(NULL);
 334
 335     for (stats = stats_list; stats; stats = stats->next) {
 336         if (!stats->value->has_device) {
 337             continue;
 338         }
 339
 340         monitor_printf(mon, "%s:", stats->value->device);
 341         monitor_printf(mon, " rd_bytes=%" PRId64
 342                        " wr_bytes=%" PRId64
 343                        " rd_operations=%" PRId64
 344                        " wr_operations=%" PRId64
 345                        " flush_operations=%" PRId64
 346                        " wr_total_time_ns=%" PRId64
 347                        " rd_total_time_ns=%" PRId64
 348                        " flush_total_time_ns=%" PRId64
 349                        "\n",
 350                        stats->value->stats->rd_bytes,
 351                        stats->value->stats->wr_bytes,
 352                        stats->value->stats->rd_operations,
 353                        stats->value->stats->wr_operations,
 354                        stats->value->stats->flush_operations,
 355                        stats->value->stats->wr_total_time_ns,
 356                        stats->value->stats->rd_total_time_ns,
 357                        stats->value->stats->flush_total_time_ns);
 358     }
 359
 360     qapi_free_BlockStatsList(stats_list);
 361 }
 362
 363 void hmp_info_vnc(Monitor *mon, const QDict *qdict)
 364 {
 365     VncInfo *info;
 366     Error *err = NULL;
 367     VncClientInfoList *client;
 368
 369     info = qmp_query_vnc(&err);
 370     if (err) {
 371         monitor_printf(mon, "%s\n", error_get_pretty(err));
 372         error_free(err);
 373         return;
 374     }
 375
 376     if (!info->enabled) {
 377         monitor_printf(mon, "Server: disabled\n");
 378         goto out;
 379     }
 380
 381     monitor_printf(mon, "Server:\n");
 382     if (info->has_host && info->has_service) {
 383         monitor_printf(mon, "     address: %s:%s\n", info->host, info->service);
 384     }
 385     if (info->has_auth) {
 386         monitor_printf(mon, "        auth: %s\n", info->auth);
 387     }
 388
 389     if (!info->has_clients || info->clients == NULL) {
 390         monitor_printf(mon, "Client: none\n");
 391     } else {
 392         for (client = info->clients; client; client = client->next) {
 393             monitor_printf(mon, "Client:\n");
 394             monitor_printf(mon, "     address: %s:%s\n",
 395                            client->value->host, client->value->service);
 396             monitor_printf(mon, "  x509_dname: %s\n",
 397                            client->value->x509_dname ?
 398                            client->value->x509_dname : "none");
 399             monitor_printf(mon, "    username: %s\n",
 400                            client->value->has_sasl_username ?
 401                            client->value->sasl_username : "none");
 402         }
 403     }
 404
 405 out:
 406     qapi_free_VncInfo(info);
 407 }
 408
 409 void hmp_info_spice(Monitor *mon, const QDict *qdict)
 410 {
 411     SpiceChannelList *chan;
 412     SpiceInfo *info;
 413
 414     info = qmp_query_spice(NULL);
 415
 416     if (!info->enabled) {
 417         monitor_printf(mon, "Server: disabled\n");
 418         goto out;
 419     }
 420
 421     monitor_printf(mon, "Server:\n");
 422     if (info->has_port) {
 423         monitor_printf(mon, "     address: %s:%" PRId64 "\n",
 424                        info->host, info->port);
 425     }
 426     if (info->has_tls_port) {
 427         monitor_printf(mon, "     address: %s:%" PRId64 " [tls]\n",
 428                        info->host, info->tls_port);
 429     }
 430     monitor_printf(mon, "    migrated: %s\n",
 431                    info->migrated ? "true" : "false");
 432     monitor_printf(mon, "        auth: %s\n", info->auth);
 433     monitor_printf(mon, "    compiled: %s\n", info->compiled_version);
 434     monitor_printf(mon, "  mouse-mode: %s\n",
 435                    SpiceQueryMouseMode_lookup[info->mouse_mode]);
 436
 437     if (!info->has_channels || info->channels == NULL) {
 438         monitor_printf(mon, "Channels: none\n");
 439     } else {
 440         for (chan = info->channels; chan; chan = chan->next) {
 441             monitor_printf(mon, "Channel:\n");
 442             monitor_printf(mon, "     address: %s:%s%s\n",
 443                            chan->value->host, chan->value->port,
 444                            chan->value->tls ? " [tls]" : "");
 445             monitor_printf(mon, "     session: %" PRId64 "\n",
 446                            chan->value->connection_id);
 447             monitor_printf(mon, "     channel: %" PRId64 ":%" PRId64 "\n",
 448                            chan->value->channel_type, chan->value->channel_id);
 449         }
 450     }
 451
 452 out:
 453     qapi_free_SpiceInfo(info);
 454 }
 455
 456 void hmp_info_balloon(Monitor *mon, const QDict *qdict)
 457 {
 458     BalloonInfo *info;
 459     Error *err = NULL;
 460
 461     info = qmp_query_balloon(&err);
 462     if (err) {
 463         monitor_printf(mon, "%s\n", error_get_pretty(err));
 464         error_free(err);
 465         return;
 466     }
 467
 468     monitor_printf(mon, "balloon: actual=%" PRId64 "\n", info->actual >> 20);
 469
 470     qapi_free_BalloonInfo(info);
 471 }
 472
 473 static void hmp_info_pci_device(Monitor *mon, const PciDeviceInfo *dev)
 474 {
 475     PciMemoryRegionList *region;
 476
 477     monitor_printf(mon, "  Bus %2" PRId64 ", ", dev->bus);
 478     monitor_printf(mon, "device %3" PRId64 ", function %" PRId64 ":\n",
 479                    dev->slot, dev->function);
 480     monitor_printf(mon, "    ");
 481
 482     if (dev->class_info.has_desc) {
 483         monitor_printf(mon, "%s", dev->class_info.desc);
 484     } else {
 485         monitor_printf(mon, "Class %04" PRId64, dev->class_info.class);
 486     }
 487
 488     monitor_printf(mon, ": PCI device %04" PRIx64 ":%04" PRIx64 "\n",
 489                    dev->id.vendor, dev->id.device);
 490
 491     if (dev->has_irq) {
 492         monitor_printf(mon, "      IRQ %" PRId64 ".\n", dev->irq);
 493     }
 494
 495     if (dev->has_pci_bridge) {
 496         monitor_printf(mon, "      BUS %" PRId64 ".\n",
 497                        dev->pci_bridge->bus.number);
 498         monitor_printf(mon, "      secondary bus %" PRId64 ".\n",
 499                        dev->pci_bridge->bus.secondary);
 500         monitor_printf(mon, "      subordinate bus %" PRId64 ".\n",
 501                        dev->pci_bridge->bus.subordinate);
 502
 503         monitor_printf(mon, "      IO range [0x%04"PRIx64", 0x%04"PRIx64"]\n",
 504                        dev->pci_bridge->bus.io_range->base,
 505                        dev->pci_bridge->bus.io_range->limit);
 506
 507         monitor_printf(mon,
 508                        "      memory range [0x%08"PRIx64", 0x%08"PRIx64"]\n",
 509                        dev->pci_bridge->bus.memory_range->base,
 510                        dev->pci_bridge->bus.memory_range->limit);
 511
 512         monitor_printf(mon, "      prefetchable memory range "
 513                        "[0x%08"PRIx64", 0x%08"PRIx64"]\n",
 514                        dev->pci_bridge->bus.prefetchable_range->base,
 515                        dev->pci_bridge->bus.prefetchable_range->limit);
 516     }
 517
 518     for (region = dev->regions; region; region = region->next) {
 519         uint64_t addr, size;
 520
 521         addr = region->value->address;
 522         size = region->value->size;
 523
 524         monitor_printf(mon, "      BAR%" PRId64 ": ", region->value->bar);
 525
 526         if (!strcmp(region->value->type, "io")) {
 527             monitor_printf(mon, "I/O at 0x%04" PRIx64
 528                                 " [0x%04" PRIx64 "].\n",
 529                            addr, addr + size - 1);
 530         } else {
 531             monitor_printf(mon, "%d bit%s memory at 0x%08" PRIx64
 532                                " [0x%08" PRIx64 "].\n",
 533                            region->value->mem_type_64 ? 64 : 32,
 534                            region->value->prefetch ? " prefetchable" : "",
 535                            addr, addr + size - 1);
 536         }
 537     }
 538
 539     monitor_printf(mon, "      id \"%s\"\n", dev->qdev_id);
 540
 541     if (dev->has_pci_bridge) {
 542         if (dev->pci_bridge->has_devices) {
 543             PciDeviceInfoList *cdev;
 544             for (cdev = dev->pci_bridge->devices; cdev; cdev = cdev->next) {
 545                 hmp_info_pci_device(mon, cdev->value);
 546             }
 547         }
 548     }
 549 }
 550
 551 void hmp_info_pci(Monitor *mon, const QDict *qdict)
 552 {
 553     PciInfoList *info_list, *info;
 554     Error *err = NULL;
 555
 556     info_list = qmp_query_pci(&err);
 557     if (err) {
 558         monitor_printf(mon, "PCI devices not supported\n");
 559         error_free(err);
 560         return;
 561     }
 562
 563     for (info = info_list; info; info = info->next) {
 564         PciDeviceInfoList *dev;
 565
 566         for (dev = info->value->devices; dev; dev = dev->next) {
 567             hmp_info_pci_device(mon, dev->value);
 568         }
 569     }
 570
 571     qapi_free_PciInfoList(info_list);
 572 }
 573
 574 void hmp_info_block_jobs(Monitor *mon, const QDict *qdict)
 575 {
 576     BlockJobInfoList *list;
 577     Error *err = NULL;
 578
 579     list = qmp_query_block_jobs(&err);
 580     assert(!err);
 581
 582     if (!list) {
 583         monitor_printf(mon, "No active jobs\n");
 584         return;
 585     }
 586
 587     while (list) {
 588         if (strcmp(list->value->type, "stream") == 0) {
 589             monitor_printf(mon, "Streaming device %s: Completed %" PRId64
 590                            " of %" PRId64 " bytes, speed limit %" PRId64
 591                            " bytes/s\n",
 592                            list->value->device,
 593                            list->value->offset,
 594                            list->value->len,
 595                            list->value->speed);
 596         } else {
 597             monitor_printf(mon, "Type %s, device %s: Completed %" PRId64
 598                            " of %" PRId64 " bytes, speed limit %" PRId64
 599                            " bytes/s\n",
 600                            list->value->type,
 601                            list->value->device,
 602                            list->value->offset,
 603                            list->value->len,
 604                            list->value->speed);
 605         }
 606         list = list->next;
 607     }
 608 }
 609
 610 void hmp_quit(Monitor *mon, const QDict *qdict)
 611 {
 612     monitor_suspend(mon);
 613     qmp_quit(NULL);
 614 }
 615
 616 void hmp_stop(Monitor *mon, const QDict *qdict)
 617 {
 618     qmp_stop(NULL);
 619 }
 620
 621 void hmp_system_reset(Monitor *mon, const QDict *qdict)
 622 {
 623     qmp_system_reset(NULL);
 624 }
 625
 626 void hmp_system_powerdown(Monitor *mon, const QDict *qdict)
 627 {
 628     qmp_system_powerdown(NULL);
 629 }
 630
 631 void hmp_cpu(Monitor *mon, const QDict *qdict)
 632 {
 633     int64_t cpu_index;
 634
 635     /* XXX: drop the monitor_set_cpu() usage when all HMP commands that
 636             use it are converted to the QAPI */
 637     cpu_index = qdict_get_int(qdict, "index");
 638     if (monitor_set_cpu(cpu_index) < 0) {
 639         monitor_printf(mon, "invalid CPU index\n");
 640     }
 641 }
 642
 643 void hmp_memsave(Monitor *mon, const QDict *qdict)
 644 {
 645     uint32_t size = qdict_get_int(qdict, "size");
 646     const char *filename = qdict_get_str(qdict, "filename");
 647     uint64_t addr = qdict_get_int(qdict, "val");
 648     Error *errp = NULL;
 649
 650     qmp_memsave(addr, size, filename, true, monitor_get_cpu_index(), &errp);
 651     hmp_handle_error(mon, &errp);
 652 }
 653
 654 void hmp_pmemsave(Monitor *mon, const QDict *qdict)
 655 {
 656     uint32_t size = qdict_get_int(qdict, "size");
 657     const char *filename = qdict_get_str(qdict, "filename");
 658     uint64_t addr = qdict_get_int(qdict, "val");
 659     Error *errp = NULL;
 660
 661     qmp_pmemsave(addr, size, filename, &errp);
 662     hmp_handle_error(mon, &errp);
 663 }
 664
 665 static void hmp_cont_cb(void *opaque, int err)
 666 {
 667     if (!err) {
 668         qmp_cont(NULL);
 669     }
 670 }
 671
 672 static bool key_is_missing(const BlockInfo *bdev)
 673 {
 674     return (bdev->inserted && bdev->inserted->encryption_key_missing);
 675 }
 676
 677 void hmp_cont(Monitor *mon, const QDict *qdict)
 678 {
 679     BlockInfoList *bdev_list, *bdev;
 680     Error *errp = NULL;
 681
 682     bdev_list = qmp_query_block(NULL);
 683     for (bdev = bdev_list; bdev; bdev = bdev->next) {
 684         if (key_is_missing(bdev->value)) {
 685             monitor_read_block_device_key(mon, bdev->value->device,
 686                                           hmp_cont_cb, NULL);
 687             goto out;
 688         }
 689     }
 690
 691     qmp_cont(&errp);
 692     hmp_handle_error(mon, &errp);
 693
 694 out:
 695     qapi_free_BlockInfoList(bdev_list);
 696 }
 697
 698 void hmp_system_wakeup(Monitor *mon, const QDict *qdict)
 699 {
 700     qmp_system_wakeup(NULL);
 701 }
 702
 703 void hmp_inject_nmi(Monitor *mon, const QDict *qdict)
 704 {
 705     Error *errp = NULL;
 706
 707     qmp_inject_nmi(&errp);
 708     hmp_handle_error(mon, &errp);
 709 }
 710
 711 void hmp_set_link(Monitor *mon, const QDict *qdict)
 712 {
 713     const char *name = qdict_get_str(qdict, "name");
 714     int up = qdict_get_bool(qdict, "up");
 715     Error *errp = NULL;
 716
 717     qmp_set_link(name, up, &errp);
 718     hmp_handle_error(mon, &errp);
 719 }
 720
 721 void hmp_block_passwd(Monitor *mon, const QDict *qdict)
 722 {
 723     const char *device = qdict_get_str(qdict, "device");
 724     const char *password = qdict_get_str(qdict, "password");
 725     Error *errp = NULL;
 726
 727     qmp_block_passwd(device, password, &errp);
 728     hmp_handle_error(mon, &errp);
 729 }
 730
 731 void hmp_balloon(Monitor *mon, const QDict *qdict)
 732 {
 733     int64_t value = qdict_get_int(qdict, "value");
 734     Error *errp = NULL;
 735
 736     qmp_balloon(value, &errp);
 737     if (error_is_set(&errp)) {
 738         monitor_printf(mon, "balloon: %s\n", error_get_pretty(errp));
 739         error_free(errp);
 740     }
 741 }
 742
 743 void hmp_block_resize(Monitor *mon, const QDict *qdict)
 744 {
 745     const char *device = qdict_get_str(qdict, "device");
 746     int64_t size = qdict_get_int(qdict, "size");
 747     Error *errp = NULL;
 748
 749     qmp_block_resize(device, size, &errp);
 750     hmp_handle_error(mon, &errp);
 751 }
 752
 753 void hmp_drive_mirror(Monitor *mon, const QDict *qdict)
 754 {
 755     const char *device = qdict_get_str(qdict, "device");
 756     const char *filename = qdict_get_str(qdict, "target");
 757     const char *format = qdict_get_try_str(qdict, "format");
 758     int reuse = qdict_get_try_bool(qdict, "reuse", 0);
 759     int full = qdict_get_try_bool(qdict, "full", 0);
 760     enum NewImageMode mode;
 761     Error *errp = NULL;
 762
 763     if (!filename) {
 764         error_set(&errp, QERR_MISSING_PARAMETER, "target");
 765         hmp_handle_error(mon, &errp);
 766         return;
 767     }
 768
 769     if (reuse) {
 770         mode = NEW_IMAGE_MODE_EXISTING;
 771     } else {
 772         mode = NEW_IMAGE_MODE_ABSOLUTE_PATHS;
 773     }
 774
 775     qmp_drive_mirror(device, filename, !!format, format,
 776                      full ? MIRROR_SYNC_MODE_FULL : MIRROR_SYNC_MODE_TOP,
 777                      true, mode, false, 0,
 778                      false, 0, false, 0, &errp);
 779     hmp_handle_error(mon, &errp);
 780 }
 781
 782 void hmp_snapshot_blkdev(Monitor *mon, const QDict *qdict)
 783 {
 784     const char *device = qdict_get_str(qdict, "device");
 785     const char *filename = qdict_get_try_str(qdict, "snapshot-file");
 786     const char *format = qdict_get_try_str(qdict, "format");
 787     int reuse = qdict_get_try_bool(qdict, "reuse", 0);
 788     enum NewImageMode mode;
 789     Error *errp = NULL;
 790
 791     if (!filename) {
 792         /* In the future, if 'snapshot-file' is not specified, the snapshot
 793            will be taken internally. Today it's actually required. */
 794         error_set(&errp, QERR_MISSING_PARAMETER, "snapshot-file");
 795         hmp_handle_error(mon, &errp);
 796         return;
 797     }
 798
 799     mode = reuse ? NEW_IMAGE_MODE_EXISTING : NEW_IMAGE_MODE_ABSOLUTE_PATHS;
 800     qmp_blockdev_snapshot_sync(device, filename, !!format, format,
 801                                true, mode, &errp);
 802     hmp_handle_error(mon, &errp);
 803 }
 804
 805 void hmp_migrate_cancel(Monitor *mon, const QDict *qdict)
 806 {
 807     qmp_migrate_cancel(NULL);
 808 }
 809
 810 void hmp_migrate_set_downtime(Monitor *mon, const QDict *qdict)
 811 {
 812     double value = qdict_get_double(qdict, "value");
 813     qmp_migrate_set_downtime(value, NULL);
 814 }
 815
 816 void hmp_migrate_set_cache_size(Monitor *mon, const QDict *qdict)
 817 {
 818     int64_t value = qdict_get_int(qdict, "value");
 819     Error *err = NULL;
 820
 821     qmp_migrate_set_cache_size(value, &err);
 822     if (err) {
 823         monitor_printf(mon, "%s\n", error_get_pretty(err));
 824         error_free(err);
 825         return;
 826     }
 827 }
 828
 829 void hmp_migrate_set_speed(Monitor *mon, const QDict *qdict)
 830 {
 831     int64_t value = qdict_get_int(qdict, "value");
 832     qmp_migrate_set_speed(value, NULL);
 833 }
 834
 835 void hmp_migrate_set_capability(Monitor *mon, const QDict *qdict)
 836 {
 837     const char *cap = qdict_get_str(qdict, "capability");
 838     bool state = qdict_get_bool(qdict, "state");
 839     Error *err = NULL;
 840     MigrationCapabilityStatusList *caps = g_malloc0(sizeof(*caps));
 841     int i;
 842
 843     for (i = 0; i < MIGRATION_CAPABILITY_MAX; i++) {
 844         if (strcmp(cap, MigrationCapability_lookup[i]) == 0) {
 845             caps->value = g_malloc0(sizeof(*caps->value));
 846             caps->value->capability = i;
 847             caps->value->state = state;
 848             caps->next = NULL;
 849             qmp_migrate_set_capabilities(caps, &err);
 850             break;
 851         }
 852     }
 853
 854     if (i == MIGRATION_CAPABILITY_MAX) {
 855         error_set(&err, QERR_INVALID_PARAMETER, cap);
 856     }
 857
 858     qapi_free_MigrationCapabilityStatusList(caps);
 859
 860     if (err) {
 861         monitor_printf(mon, "migrate_set_parameter: %s\n",
 862                        error_get_pretty(err));
 863         error_free(err);
 864     }
 865 }
 866
 867 void hmp_set_password(Monitor *mon, const QDict *qdict)
 868 {
 869     const char *protocol  = qdict_get_str(qdict, "protocol");
 870     const char *password  = qdict_get_str(qdict, "password");
 871     const char *connected = qdict_get_try_str(qdict, "connected");
 872     Error *err = NULL;
 873
 874     qmp_set_password(protocol, password, !!connected, connected, &err);
 875     hmp_handle_error(mon, &err);
 876 }
 877
 878 void hmp_expire_password(Monitor *mon, const QDict *qdict)
 879 {
 880     const char *protocol  = qdict_get_str(qdict, "protocol");
 881     const char *whenstr = qdict_get_str(qdict, "time");
 882     Error *err = NULL;
 883
 884     qmp_expire_password(protocol, whenstr, &err);
 885     hmp_handle_error(mon, &err);
 886 }
 887
 888 void hmp_eject(Monitor *mon, const QDict *qdict)
 889 {
 890     int force = qdict_get_try_bool(qdict, "force", 0);
 891     const char *device = qdict_get_str(qdict, "device");
 892     Error *err = NULL;
 893
 894     qmp_eject(device, true, force, &err);
 895     hmp_handle_error(mon, &err);
 896 }
 897
 898 static void hmp_change_read_arg(Monitor *mon, const char *password,
 899                                 void *opaque)
 900 {
 901     qmp_change_vnc_password(password, NULL);
 902     monitor_read_command(mon, 1);
 903 }
 904
 905 void hmp_change(Monitor *mon, const QDict *qdict)
 906 {
 907     const char *device = qdict_get_str(qdict, "device");
 908     const char *target = qdict_get_str(qdict, "target");
 909     const char *arg = qdict_get_try_str(qdict, "arg");
 910     Error *err = NULL;
 911
 912     if (strcmp(device, "vnc") == 0 &&
 913             (strcmp(target, "passwd") == 0 ||
 914              strcmp(target, "password") == 0)) {
 915         if (!arg) {
 916             monitor_read_password(mon, hmp_change_read_arg, NULL);
 917             return;
 918         }
 919     }
 920
 921     qmp_change(device, target, !!arg, arg, &err);
 922     if (error_is_set(&err) &&
 923         error_get_class(err) == ERROR_CLASS_DEVICE_ENCRYPTED) {
 924         error_free(err);
 925         monitor_read_block_device_key(mon, device, NULL, NULL);
 926         return;
 927     }
 928     hmp_handle_error(mon, &err);
 929 }
 930
 931 void hmp_block_set_io_throttle(Monitor *mon, const QDict *qdict)
 932 {
 933     Error *err = NULL;
 934
 935     qmp_block_set_io_throttle(qdict_get_str(qdict, "device"),
 936                               qdict_get_int(qdict, "bps"),
 937                               qdict_get_int(qdict, "bps_rd"),
 938                               qdict_get_int(qdict, "bps_wr"),
 939                               qdict_get_int(qdict, "iops"),
 940                               qdict_get_int(qdict, "iops_rd"),
 941                               qdict_get_int(qdict, "iops_wr"), &err);
 942     hmp_handle_error(mon, &err);
 943 }
 944
 945 void hmp_block_stream(Monitor *mon, const QDict *qdict)
 946 {
 947     Error *error = NULL;
 948     const char *device = qdict_get_str(qdict, "device");
 949     const char *base = qdict_get_try_str(qdict, "base");
 950     int64_t speed = qdict_get_try_int(qdict, "speed", 0);
 951
 952     qmp_block_stream(device, base != NULL, base,
 953                      qdict_haskey(qdict, "speed"), speed,
 954                      BLOCKDEV_ON_ERROR_REPORT, true, &error);
 955
 956     hmp_handle_error(mon, &error);
 957 }
 958
 959 void hmp_block_job_set_speed(Monitor *mon, const QDict *qdict)
 960 {
 961     Error *error = NULL;
 962     const char *device = qdict_get_str(qdict, "device");
 963     int64_t value = qdict_get_int(qdict, "speed");
 964
 965     qmp_block_job_set_speed(device, value, &error);
 966
 967     hmp_handle_error(mon, &error);
 968 }
 969
 970 void hmp_block_job_cancel(Monitor *mon, const QDict *qdict)
 971 {
 972     Error *error = NULL;
 973     const char *device = qdict_get_str(qdict, "device");
 974     bool force = qdict_get_try_bool(qdict, "force", 0);
 975
 976     qmp_block_job_cancel(device, true, force, &error);
 977
 978     hmp_handle_error(mon, &error);
 979 }
 980
 981 void hmp_block_job_pause(Monitor *mon, const QDict *qdict)
 982 {
 983     Error *error = NULL;
 984     const char *device = qdict_get_str(qdict, "device");
 985
 986     qmp_block_job_pause(device, &error);
 987
 988     hmp_handle_error(mon, &error);
 989 }
 990
 991 void hmp_block_job_resume(Monitor *mon, const QDict *qdict)
 992 {
 993     Error *error = NULL;
 994     const char *device = qdict_get_str(qdict, "device");
 995
 996     qmp_block_job_resume(device, &error);
 997
 998     hmp_handle_error(mon, &error);
 999 }
1000
1001 void hmp_block_job_complete(Monitor *mon, const QDict *qdict)
1002 {
1003     Error *error = NULL;
1004     const char *device = qdict_get_str(qdict, "device");
1005
1006     qmp_block_job_complete(device, &error);
1007
1008     hmp_handle_error(mon, &error);
1009 }
1010
1011 typedef struct MigrationStatus
1012 {
1013     QEMUTimer *timer;
1014     Monitor *mon;
1015     bool is_block_migration;
1016 } MigrationStatus;
1017
1018 static void hmp_migrate_status_cb(void *opaque)
1019 {
1020     MigrationStatus *status = opaque;
1021     MigrationInfo *info;
1022
1023     info = qmp_query_migrate(NULL);
1024     if (!info->has_status || strcmp(info->status, "active") == 0) {
1025         if (info->has_disk) {
1026             int progress;
1027
1028             if (info->disk->remaining) {
1029                 progress = info->disk->transferred * 100 / info->disk->total;
1030             } else {
1031                 progress = 100;
1032             }
1033
1034             monitor_printf(status->mon, "Completed %d %%\r", progress);
1035             monitor_flush(status->mon);
1036         }
1037
1038         qemu_mod_timer(status->timer, qemu_get_clock_ms(rt_clock) + 1000);
1039     } else {
1040         if (status->is_block_migration) {
1041             monitor_printf(status->mon, "\n");
1042         }
1043         monitor_resume(status->mon);
1044         qemu_del_timer(status->timer);
1045         g_free(status);
1046     }
1047
1048     qapi_free_MigrationInfo(info);
1049 }
1050
1051 void hmp_migrate(Monitor *mon, const QDict *qdict)
1052 {
1053     int detach = qdict_get_try_bool(qdict, "detach", 0);
1054     int blk = qdict_get_try_bool(qdict, "blk", 0);
1055     int inc = qdict_get_try_bool(qdict, "inc", 0);
1056     const char *uri = qdict_get_str(qdict, "uri");
1057     Error *err = NULL;
1058
1059     qmp_migrate(uri, !!blk, blk, !!inc, inc, false, false, &err);
1060     if (err) {
1061         monitor_printf(mon, "migrate: %s\n", error_get_pretty(err));
1062         error_free(err);
1063         return;
1064     }
1065
1066     if (!detach) {
1067         MigrationStatus *status;
1068
1069         if (monitor_suspend(mon) < 0) {
1070             monitor_printf(mon, "terminal does not allow synchronous "
1071                            "migration, continuing detached\n");
1072             return;
1073         }
1074
1075         status = g_malloc0(sizeof(*status));
1076         status->mon = mon;
1077         status->is_block_migration = blk || inc;
1078         status->timer = qemu_new_timer_ms(rt_clock, hmp_migrate_status_cb,
1079                                           status);
1080         qemu_mod_timer(status->timer, qemu_get_clock_ms(rt_clock));
1081     }
1082 }
1083
1084 void hmp_device_del(Monitor *mon, const QDict *qdict)
1085 {
1086     const char *id = qdict_get_str(qdict, "id");
1087     Error *err = NULL;
1088
1089     qmp_device_del(id, &err);
1090     hmp_handle_error(mon, &err);
1091 }
1092
1093 void hmp_dump_guest_memory(Monitor *mon, const QDict *qdict)
1094 {
1095     Error *errp = NULL;
1096     int paging = qdict_get_try_bool(qdict, "paging", 0);
1097     const char *file = qdict_get_str(qdict, "filename");
1098     bool has_begin = qdict_haskey(qdict, "begin");
1099     bool has_length = qdict_haskey(qdict, "length");
1100     int64_t begin = 0;
1101     int64_t length = 0;
1102     char *prot;
1103
1104     if (has_begin) {
1105         begin = qdict_get_int(qdict, "begin");
1106     }
1107     if (has_length) {
1108         length = qdict_get_int(qdict, "length");
1109     }
1110
1111     prot = g_strconcat("file:", file, NULL);
1112
1113     qmp_dump_guest_memory(paging, prot, has_begin, begin, has_length, length,
1114                           &errp);
1115     hmp_handle_error(mon, &errp);
1116     g_free(prot);
1117 }
1118
1119 void hmp_netdev_add(Monitor *mon, const QDict *qdict)
1120 {
1121     Error *err = NULL;
1122     QemuOpts *opts;
1123
1124     opts = qemu_opts_from_qdict(qemu_find_opts("netdev"), qdict, &err);
1125     if (error_is_set(&err)) {
1126         goto out;
1127     }
1128
1129     netdev_add(opts, &err);
1130     if (error_is_set(&err)) {
1131         qemu_opts_del(opts);
1132     }
1133
1134 out:
1135     hmp_handle_error(mon, &err);
1136 }
1137
1138 void hmp_netdev_del(Monitor *mon, const QDict *qdict)
1139 {
1140     const char *id = qdict_get_str(qdict, "id");
1141     Error *err = NULL;
1142
1143     qmp_netdev_del(id, &err);
1144     hmp_handle_error(mon, &err);
1145 }
1146
1147 void hmp_getfd(Monitor *mon, const QDict *qdict)
1148 {
1149     const char *fdname = qdict_get_str(qdict, "fdname");
1150     Error *errp = NULL;
1151
1152     qmp_getfd(fdname, &errp);
1153     hmp_handle_error(mon, &errp);
1154 }
1155
1156 void hmp_closefd(Monitor *mon, const QDict *qdict)
1157 {
1158     const char *fdname = qdict_get_str(qdict, "fdname");
1159     Error *errp = NULL;
1160
1161     qmp_closefd(fdname, &errp);
1162     hmp_handle_error(mon, &errp);
1163 }
1164
1165 void hmp_send_key(Monitor *mon, const QDict *qdict)
1166 {
1167     const char *keys = qdict_get_str(qdict, "keys");
1168     KeyValueList *keylist, *head = NULL, *tmp = NULL;
1169     int has_hold_time = qdict_haskey(qdict, "hold-time");
1170     int hold_time = qdict_get_try_int(qdict, "hold-time", -1);
1171     Error *err = NULL;
1172     char keyname_buf[16];
1173     char *separator;
1174     int keyname_len;
1175
1176     while (1) {
1177         separator = strchr(keys, '-');
1178         keyname_len = separator ? separator - keys : strlen(keys);
1179         pstrcpy(keyname_buf, sizeof(keyname_buf), keys);
1180
1181         /* Be compatible with old interface, convert user inputted "<" */
1182         if (!strncmp(keyname_buf, "<", 1) && keyname_len == 1) {
1183             pstrcpy(keyname_buf, sizeof(keyname_buf), "less");
1184             keyname_len = 4;
1185         }
1186         keyname_buf[keyname_len] = 0;
1187
1188         keylist = g_malloc0(sizeof(*keylist));
1189         keylist->value = g_malloc0(sizeof(*keylist->value));
1190
1191         if (!head) {
1192             head = keylist;
1193         }
1194         if (tmp) {
1195             tmp->next = keylist;
1196         }
1197         tmp = keylist;
1198
1199         if (strstart(keyname_buf, "0x", NULL)) {
1200             char *endp;
1201             int value = strtoul(keyname_buf, &endp, 0);
1202             if (*endp != '\0') {
1203                 goto err_out;
1204             }
1205             keylist->value->kind = KEY_VALUE_KIND_NUMBER;
1206             keylist->value->number = value;
1207         } else {
1208             int idx = index_from_key(keyname_buf);
1209             if (idx == Q_KEY_CODE_MAX) {
1210                 goto err_out;
1211             }
1212             keylist->value->kind = KEY_VALUE_KIND_QCODE;
1213             keylist->value->qcode = idx;
1214         }
1215
1216         if (!separator) {
1217             break;
1218         }
1219         keys = separator + 1;
1220     }
1221
1222     qmp_send_key(head, has_hold_time, hold_time, &err);
1223     hmp_handle_error(mon, &err);
1224
1225 out:
1226     qapi_free_KeyValueList(head);
1227     return;
1228
1229 err_out:
1230     monitor_printf(mon, "invalid parameter: %s\n", keyname_buf);
1231     goto out;
1232 }
1233
1234 void hmp_screen_dump(Monitor *mon, const QDict *qdict)
1235 {
1236     const char *filename = qdict_get_str(qdict, "filename");
1237     Error *err = NULL;
1238
1239     qmp_screendump(filename, &err);
1240     hmp_handle_error(mon, &err);
1241 }
1242
1243 void hmp_nbd_server_start(Monitor *mon, const QDict *qdict)
1244 {
1245     const char *uri = qdict_get_str(qdict, "uri");
1246     int writable = qdict_get_try_bool(qdict, "writable", 0);
1247     int all = qdict_get_try_bool(qdict, "all", 0);
1248     Error *local_err = NULL;
1249     BlockInfoList *block_list, *info;
1250     SocketAddress *addr;
1251
1252     if (writable && !all) {
1253         error_setg(&local_err, "-w only valid together with -a");
1254         goto exit;
1255     }
1256
1257     /* First check if the address is valid and start the server.  */
1258     addr = socket_parse(uri, &local_err);
1259     if (local_err != NULL) {
1260         goto exit;
1261     }
1262
1263     qmp_nbd_server_start(addr, &local_err);
1264     qapi_free_SocketAddress(addr);
1265     if (local_err != NULL) {
1266         goto exit;
1267     }
1268
1269     if (!all) {
1270         return;
1271     }
1272
1273     /* Then try adding all block devices.  If one fails, close all and
1274      * exit.
1275      */
1276     block_list = qmp_query_block(NULL);
1277
1278     for (info = block_list; info; info = info->next) {
1279         if (!info->value->has_inserted) {
1280             continue;
1281         }
1282
1283         qmp_nbd_server_add(info->value->device, true, writable, &local_err);
1284
1285         if (local_err != NULL) {
1286             qmp_nbd_server_stop(NULL);
1287             break;
1288         }
1289     }
1290
1291     qapi_free_BlockInfoList(block_list);
1292
1293 exit:
1294     hmp_handle_error(mon, &local_err);
1295 }
1296
1297 void hmp_nbd_server_add(Monitor *mon, const QDict *qdict)
1298 {
1299     const char *device = qdict_get_str(qdict, "device");
1300     int writable = qdict_get_try_bool(qdict, "writable", 0);
1301     Error *local_err = NULL;
1302
1303     qmp_nbd_server_add(device, true, writable, &local_err);
1304
1305     if (local_err != NULL) {
1306         hmp_handle_error(mon, &local_err);
1307     }
1308 }
1309
1310 void hmp_nbd_server_stop(Monitor *mon, const QDict *qdict)
1311 {
1312     Error *errp = NULL;
1313
1314     qmp_nbd_server_stop(&errp);
1315     hmp_handle_error(mon, &errp);
1316 }
1317
1318 void hmp_chardev_add(Monitor *mon, const QDict *qdict)
1319 {
1320     const char *args = qdict_get_str(qdict, "args");
1321     Error *err = NULL;
1322     QemuOpts *opts;
1323
1324     opts = qemu_opts_parse(qemu_find_opts("chardev"), args, 1);
1325     if (opts == NULL) {
1326         error_setg(&err, "Parsing chardev args failed\n");
1327     } else {
1328         qemu_chr_new_from_opts(opts, NULL, &err);
1329     }
1330     hmp_handle_error(mon, &err);
1331 }
1332
1333 void hmp_chardev_remove(Monitor *mon, const QDict *qdict)
1334 {
1335     Error *local_err = NULL;
1336
1337     qmp_chardev_remove(qdict_get_str(qdict, "id"), &local_err);
1338     hmp_handle_error(mon, &local_err);
1339 }