hmp.c 71.1 KB
Newer Older
A
Anthony Liguori 已提交
1 2 3 4 5 6 7 8 9 10 11
/*
 * Human Monitor Interface
 *
 * Copyright IBM, Corp. 2011
 *
 * Authors:
 *  Anthony Liguori   <aliguori@us.ibm.com>
 *
 * This work is licensed under the terms of the GNU GPL, version 2.  See
 * the COPYING file in the top-level directory.
 *
12 13
 * Contributions after 2012-01-13 are licensed under the terms of the
 * GNU GPL, version 2 or (at your option) any later version.
A
Anthony Liguori 已提交
14 15
 */

P
Peter Maydell 已提交
16
#include "qemu/osdep.h"
A
Anthony Liguori 已提交
17
#include "hmp.h"
P
Paolo Bonzini 已提交
18
#include "net/net.h"
19
#include "net/eth.h"
20
#include "sysemu/char.h"
M
Max Reitz 已提交
21
#include "sysemu/block-backend.h"
22 23
#include "qemu/option.h"
#include "qemu/timer.h"
A
Anthony Liguori 已提交
24
#include "qmp-commands.h"
25
#include "qemu/sockets.h"
26
#include "monitor/monitor.h"
27
#include "monitor/qdev.h"
28
#include "qapi/opts-visitor.h"
29
#include "qapi/qmp/qerror.h"
H
Hu Tao 已提交
30
#include "qapi/string-output-visitor.h"
31
#include "qapi/util.h"
H
Hu Tao 已提交
32
#include "qapi-visit.h"
33
#include "ui/console.h"
34
#include "block/qapi.h"
35
#include "qemu-io.h"
A
Anthony Liguori 已提交
36

37 38 39 40
#ifdef CONFIG_SPICE
#include <spice/enums.h>
#endif

L
Luiz Capitulino 已提交
41 42
static void hmp_handle_error(Monitor *mon, Error **errp)
{
43 44
    assert(errp);
    if (*errp) {
45
        error_report_err(*errp);
L
Luiz Capitulino 已提交
46 47 48
    }
}

49
void hmp_info_name(Monitor *mon, const QDict *qdict)
A
Anthony Liguori 已提交
50 51 52 53 54 55 56 57 58
{
    NameInfo *info;

    info = qmp_query_name(NULL);
    if (info->has_name) {
        monitor_printf(mon, "%s\n", info->name);
    }
    qapi_free_NameInfo(info);
}
L
Luiz Capitulino 已提交
59

60
void hmp_info_version(Monitor *mon, const QDict *qdict)
L
Luiz Capitulino 已提交
61 62 63 64 65 66
{
    VersionInfo *info;

    info = qmp_query_version(NULL);

    monitor_printf(mon, "%" PRId64 ".%" PRId64 ".%" PRId64 "%s\n",
67
                   info->qemu->major, info->qemu->minor, info->qemu->micro,
L
Luiz Capitulino 已提交
68 69 70 71
                   info->package);

    qapi_free_VersionInfo(info);
}
L
Luiz Capitulino 已提交
72

73
void hmp_info_kvm(Monitor *mon, const QDict *qdict)
L
Luiz Capitulino 已提交
74 75 76 77 78 79 80 81 82 83 84 85 86 87
{
    KvmInfo *info;

    info = qmp_query_kvm(NULL);
    monitor_printf(mon, "kvm support: ");
    if (info->present) {
        monitor_printf(mon, "%s\n", info->enabled ? "enabled" : "disabled");
    } else {
        monitor_printf(mon, "not compiled\n");
    }

    qapi_free_KvmInfo(info);
}

88
void hmp_info_status(Monitor *mon, const QDict *qdict)
L
Luiz Capitulino 已提交
89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106
{
    StatusInfo *info;

    info = qmp_query_status(NULL);

    monitor_printf(mon, "VM status: %s%s",
                   info->running ? "running" : "paused",
                   info->singlestep ? " (single step mode)" : "");

    if (!info->running && info->status != RUN_STATE_PAUSED) {
        monitor_printf(mon, " (%s)", RunState_lookup[info->status]);
    }

    monitor_printf(mon, "\n");

    qapi_free_StatusInfo(info);
}

107
void hmp_info_uuid(Monitor *mon, const QDict *qdict)
L
Luiz Capitulino 已提交
108 109 110 111 112 113 114
{
    UuidInfo *info;

    info = qmp_query_uuid(NULL);
    monitor_printf(mon, "%s\n", info->UUID);
    qapi_free_UuidInfo(info);
}
L
Luiz Capitulino 已提交
115

116
void hmp_info_chardev(Monitor *mon, const QDict *qdict)
L
Luiz Capitulino 已提交
117 118 119 120 121 122 123 124 125 126 127
{
    ChardevInfoList *char_info, *info;

    char_info = qmp_query_chardev(NULL);
    for (info = char_info; info; info = info->next) {
        monitor_printf(mon, "%s: filename=%s\n", info->value->label,
                                                 info->value->filename);
    }

    qapi_free_ChardevInfoList(char_info);
}
L
Luiz Capitulino 已提交
128

129
void hmp_info_mice(Monitor *mon, const QDict *qdict)
L
Luiz Capitulino 已提交
130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148
{
    MouseInfoList *mice_list, *mouse;

    mice_list = qmp_query_mice(NULL);
    if (!mice_list) {
        monitor_printf(mon, "No mouse devices connected\n");
        return;
    }

    for (mouse = mice_list; mouse; mouse = mouse->next) {
        monitor_printf(mon, "%c Mouse #%" PRId64 ": %s%s\n",
                       mouse->value->current ? '*' : ' ',
                       mouse->value->index, mouse->value->name,
                       mouse->value->absolute ? " (absolute)" : "");
    }

    qapi_free_MouseInfoList(mice_list);
}

149
void hmp_info_migrate(Monitor *mon, const QDict *qdict)
L
Luiz Capitulino 已提交
150 151
{
    MigrationInfo *info;
O
Orit Wasserman 已提交
152
    MigrationCapabilityStatusList *caps, *cap;
L
Luiz Capitulino 已提交
153 154

    info = qmp_query_migrate(NULL);
O
Orit Wasserman 已提交
155 156 157 158 159 160 161 162 163 164 165 166
    caps = qmp_query_migrate_capabilities(NULL);

    /* do not display parameters during setup */
    if (info->has_status && caps) {
        monitor_printf(mon, "capabilities: ");
        for (cap = caps; cap; cap = cap->next) {
            monitor_printf(mon, "%s: %s ",
                           MigrationCapability_lookup[cap->value->capability],
                           cap->value->state ? "on" : "off");
        }
        monitor_printf(mon, "\n");
    }
L
Luiz Capitulino 已提交
167 168

    if (info->has_status) {
169 170
        monitor_printf(mon, "Migration status: %s\n",
                       MigrationStatus_lookup[info->status]);
171 172
        monitor_printf(mon, "total time: %" PRIu64 " milliseconds\n",
                       info->total_time);
173 174 175 176
        if (info->has_expected_downtime) {
            monitor_printf(mon, "expected downtime: %" PRIu64 " milliseconds\n",
                           info->expected_downtime);
        }
177 178 179 180
        if (info->has_downtime) {
            monitor_printf(mon, "downtime: %" PRIu64 " milliseconds\n",
                           info->downtime);
        }
181 182 183 184
        if (info->has_setup_time) {
            monitor_printf(mon, "setup: %" PRIu64 " milliseconds\n",
                           info->setup_time);
        }
L
Luiz Capitulino 已提交
185 186 187 188 189
    }

    if (info->has_ram) {
        monitor_printf(mon, "transferred ram: %" PRIu64 " kbytes\n",
                       info->ram->transferred >> 10);
190 191
        monitor_printf(mon, "throughput: %0.2f mbps\n",
                       info->ram->mbps);
L
Luiz Capitulino 已提交
192 193 194 195
        monitor_printf(mon, "remaining ram: %" PRIu64 " kbytes\n",
                       info->ram->remaining >> 10);
        monitor_printf(mon, "total ram: %" PRIu64 " kbytes\n",
                       info->ram->total >> 10);
196 197
        monitor_printf(mon, "duplicate: %" PRIu64 " pages\n",
                       info->ram->duplicate);
198 199
        monitor_printf(mon, "skipped: %" PRIu64 " pages\n",
                       info->ram->skipped);
200 201 202 203
        monitor_printf(mon, "normal: %" PRIu64 " pages\n",
                       info->ram->normal);
        monitor_printf(mon, "normal bytes: %" PRIu64 " kbytes\n",
                       info->ram->normal_bytes >> 10);
204 205
        monitor_printf(mon, "dirty sync count: %" PRIu64 "\n",
                       info->ram->dirty_sync_count);
206 207 208 209
        if (info->ram->dirty_pages_rate) {
            monitor_printf(mon, "dirty pages rate: %" PRIu64 " pages\n",
                           info->ram->dirty_pages_rate);
        }
L
Luiz Capitulino 已提交
210 211 212 213 214 215 216 217 218 219 220
    }

    if (info->has_disk) {
        monitor_printf(mon, "transferred disk: %" PRIu64 " kbytes\n",
                       info->disk->transferred >> 10);
        monitor_printf(mon, "remaining disk: %" PRIu64 " kbytes\n",
                       info->disk->remaining >> 10);
        monitor_printf(mon, "total disk: %" PRIu64 " kbytes\n",
                       info->disk->total >> 10);
    }

O
Orit Wasserman 已提交
221 222 223 224 225 226 227 228 229
    if (info->has_xbzrle_cache) {
        monitor_printf(mon, "cache size: %" PRIu64 " bytes\n",
                       info->xbzrle_cache->cache_size);
        monitor_printf(mon, "xbzrle transferred: %" PRIu64 " kbytes\n",
                       info->xbzrle_cache->bytes >> 10);
        monitor_printf(mon, "xbzrle pages: %" PRIu64 " pages\n",
                       info->xbzrle_cache->pages);
        monitor_printf(mon, "xbzrle cache miss: %" PRIu64 "\n",
                       info->xbzrle_cache->cache_miss);
230 231
        monitor_printf(mon, "xbzrle cache miss rate: %0.2f\n",
                       info->xbzrle_cache->cache_miss_rate);
O
Orit Wasserman 已提交
232 233 234 235
        monitor_printf(mon, "xbzrle overflow : %" PRIu64 "\n",
                       info->xbzrle_cache->overflow);
    }

236 237 238 239 240
    if (info->has_x_cpu_throttle_percentage) {
        monitor_printf(mon, "cpu throttle percentage: %" PRIu64 "\n",
                       info->x_cpu_throttle_percentage);
    }

L
Luiz Capitulino 已提交
241
    qapi_free_MigrationInfo(info);
O
Orit Wasserman 已提交
242 243 244
    qapi_free_MigrationCapabilityStatusList(caps);
}

245
void hmp_info_migrate_capabilities(Monitor *mon, const QDict *qdict)
O
Orit Wasserman 已提交
246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261
{
    MigrationCapabilityStatusList *caps, *cap;

    caps = qmp_query_migrate_capabilities(NULL);

    if (caps) {
        monitor_printf(mon, "capabilities: ");
        for (cap = caps; cap; cap = cap->next) {
            monitor_printf(mon, "%s: %s ",
                           MigrationCapability_lookup[cap->value->capability],
                           cap->value->state ? "on" : "off");
        }
        monitor_printf(mon, "\n");
    }

    qapi_free_MigrationCapabilityStatusList(caps);
L
Luiz Capitulino 已提交
262 263
}

264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280
void hmp_info_migrate_parameters(Monitor *mon, const QDict *qdict)
{
    MigrationParameters *params;

    params = qmp_query_migrate_parameters(NULL);

    if (params) {
        monitor_printf(mon, "parameters:");
        monitor_printf(mon, " %s: %" PRId64,
            MigrationParameter_lookup[MIGRATION_PARAMETER_COMPRESS_LEVEL],
            params->compress_level);
        monitor_printf(mon, " %s: %" PRId64,
            MigrationParameter_lookup[MIGRATION_PARAMETER_COMPRESS_THREADS],
            params->compress_threads);
        monitor_printf(mon, " %s: %" PRId64,
            MigrationParameter_lookup[MIGRATION_PARAMETER_DECOMPRESS_THREADS],
            params->decompress_threads);
281 282 283 284 285 286
        monitor_printf(mon, " %s: %" PRId64,
            MigrationParameter_lookup[MIGRATION_PARAMETER_X_CPU_THROTTLE_INITIAL],
            params->x_cpu_throttle_initial);
        monitor_printf(mon, " %s: %" PRId64,
            MigrationParameter_lookup[MIGRATION_PARAMETER_X_CPU_THROTTLE_INCREMENT],
            params->x_cpu_throttle_increment);
287 288 289 290 291 292
        monitor_printf(mon, "\n");
    }

    qapi_free_MigrationParameters(params);
}

293
void hmp_info_migrate_cache_size(Monitor *mon, const QDict *qdict)
294 295 296 297 298
{
    monitor_printf(mon, "xbzrel cache size: %" PRId64 " kbytes\n",
                   qmp_query_migrate_cache_size(NULL) >> 10);
}

299
void hmp_info_cpus(Monitor *mon, const QDict *qdict)
L
Luiz Capitulino 已提交
300 301 302 303 304 305 306 307 308 309 310 311
{
    CpuInfoList *cpu_list, *cpu;

    cpu_list = qmp_query_cpus(NULL);

    for (cpu = cpu_list; cpu; cpu = cpu->next) {
        int active = ' ';

        if (cpu->value->CPU == monitor_get_cpu_index()) {
            active = '*';
        }

312
        monitor_printf(mon, "%c CPU #%" PRId64 ":", active, cpu->value->CPU);
L
Luiz Capitulino 已提交
313

E
Eric Blake 已提交
314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332
        switch (cpu->value->arch) {
        case CPU_INFO_ARCH_X86:
            monitor_printf(mon, " pc=0x%016" PRIx64, cpu->value->u.x86->pc);
            break;
        case CPU_INFO_ARCH_PPC:
            monitor_printf(mon, " nip=0x%016" PRIx64, cpu->value->u.ppc->nip);
            break;
        case CPU_INFO_ARCH_SPARC:
            monitor_printf(mon, " pc=0x%016" PRIx64, cpu->value->u.sparc->pc);
            monitor_printf(mon, " npc=0x%016" PRIx64, cpu->value->u.sparc->npc);
            break;
        case CPU_INFO_ARCH_MIPS:
            monitor_printf(mon, " PC=0x%016" PRIx64, cpu->value->u.mips->PC);
            break;
        case CPU_INFO_ARCH_TRICORE:
            monitor_printf(mon, " PC=0x%016" PRIx64, cpu->value->u.tricore->PC);
            break;
        default:
            break;
L
Luiz Capitulino 已提交
333 334 335 336 337 338 339 340 341 342 343 344
        }

        if (cpu->value->halted) {
            monitor_printf(mon, " (halted)");
        }

        monitor_printf(mon, " thread_id=%" PRId64 "\n", cpu->value->thread_id);
    }

    qapi_free_CpuInfoList(cpu_list);
}

345 346
static void print_block_info(Monitor *mon, BlockInfo *info,
                             BlockDeviceInfo *inserted, bool verbose)
L
Luiz Capitulino 已提交
347
{
348
    ImageInfo *image_info;
L
Luiz Capitulino 已提交
349

350 351 352 353 354 355 356 357 358 359 360 361 362 363 364
    assert(!info || !info->has_inserted || info->inserted == inserted);

    if (info) {
        monitor_printf(mon, "%s", info->device);
        if (inserted && inserted->has_node_name) {
            monitor_printf(mon, " (%s)", inserted->node_name);
        }
    } else {
        assert(inserted);
        monitor_printf(mon, "%s",
                       inserted->has_node_name
                       ? inserted->node_name
                       : "<anonymous>");
    }

365 366 367 368 369 370 371 372 373
    if (inserted) {
        monitor_printf(mon, ": %s (%s%s%s)\n",
                       inserted->file,
                       inserted->drv,
                       inserted->ro ? ", read-only" : "",
                       inserted->encrypted ? ", encrypted" : "");
    } else {
        monitor_printf(mon, ": [not inserted]\n");
    }
L
Luiz Capitulino 已提交
374

375 376 377 378 379
    if (info) {
        if (info->has_io_status && info->io_status != BLOCK_DEVICE_IO_STATUS_OK) {
            monitor_printf(mon, "    I/O status:       %s\n",
                           BlockDeviceIoStatus_lookup[info->io_status]);
        }
L
Luiz Capitulino 已提交
380

381 382 383 384 385
        if (info->removable) {
            monitor_printf(mon, "    Removable device: %slocked, tray %s\n",
                           info->locked ? "" : "not ",
                           info->tray_open ? "open" : "closed");
        }
386
    }
387

L
Luiz Capitulino 已提交
388

389 390 391
    if (!inserted) {
        return;
    }
L
Luiz Capitulino 已提交
392

393 394 395 396 397 398 399 400 401 402 403 404
    monitor_printf(mon, "    Cache mode:       %s%s%s\n",
                   inserted->cache->writeback ? "writeback" : "writethrough",
                   inserted->cache->direct ? ", direct" : "",
                   inserted->cache->no_flush ? ", ignore flushes" : "");

    if (inserted->has_backing_file) {
        monitor_printf(mon,
                       "    Backing file:     %s "
                       "(chain depth: %" PRId64 ")\n",
                       inserted->backing_file,
                       inserted->backing_file_depth);
    }
Z
Zhi Yong Wu 已提交
405

406 407 408 409
    if (inserted->detect_zeroes != BLOCKDEV_DETECT_ZEROES_OPTIONS_OFF) {
        monitor_printf(mon, "    Detect zeroes:    %s\n",
                       BlockdevDetectZeroesOptions_lookup[inserted->detect_zeroes]);
    }
410

411 412 413 414 415 416 417 418 419 420 421 422 423
    if (inserted->bps  || inserted->bps_rd  || inserted->bps_wr  ||
        inserted->iops || inserted->iops_rd || inserted->iops_wr)
    {
        monitor_printf(mon, "    I/O throttling:   bps=%" PRId64
                        " bps_rd=%" PRId64  " bps_wr=%" PRId64
                        " bps_max=%" PRId64
                        " bps_rd_max=%" PRId64
                        " bps_wr_max=%" PRId64
                        " iops=%" PRId64 " iops_rd=%" PRId64
                        " iops_wr=%" PRId64
                        " iops_max=%" PRId64
                        " iops_rd_max=%" PRId64
                        " iops_wr_max=%" PRId64
424 425
                        " iops_size=%" PRId64
                        " group=%s\n",
426 427 428 429 430 431 432 433 434 435 436 437
                        inserted->bps,
                        inserted->bps_rd,
                        inserted->bps_wr,
                        inserted->bps_max,
                        inserted->bps_rd_max,
                        inserted->bps_wr_max,
                        inserted->iops,
                        inserted->iops_rd,
                        inserted->iops_wr,
                        inserted->iops_max,
                        inserted->iops_rd_max,
                        inserted->iops_wr_max,
438 439
                        inserted->iops_size,
                        inserted->group);
440
    }
441

442
    if (verbose) {
443 444 445 446 447 448 449 450 451 452 453 454 455
        monitor_printf(mon, "\nImages:\n");
        image_info = inserted->image;
        while (1) {
                bdrv_image_info_dump((fprintf_function)monitor_printf,
                                     mon, image_info);
            if (image_info->has_backing_image) {
                image_info = image_info->backing_image;
            } else {
                break;
            }
        }
    }
}
456

457 458 459
void hmp_info_block(Monitor *mon, const QDict *qdict)
{
    BlockInfoList *block_list, *info;
460
    BlockDeviceInfoList *blockdev_list, *blockdev;
461
    const char *device = qdict_get_try_str(qdict, "device");
E
Eric Blake 已提交
462 463
    bool verbose = qdict_get_try_bool(qdict, "verbose", false);
    bool nodes = qdict_get_try_bool(qdict, "nodes", false);
464
    bool printed = false;
465

466 467
    /* Print BlockBackend information */
    if (!nodes) {
468
        block_list = qmp_query_block(NULL);
469 470 471
    } else {
        block_list = NULL;
    }
472

473 474 475
    for (info = block_list; info; info = info->next) {
        if (device && strcmp(device, info->value->device)) {
            continue;
476 477
        }

478 479
        if (info != block_list) {
            monitor_printf(mon, "\n");
480
        }
481

482 483 484
        print_block_info(mon, info->value, info->value->has_inserted
                                           ? info->value->inserted : NULL,
                         verbose);
485
        printed = true;
L
Luiz Capitulino 已提交
486 487 488
    }

    qapi_free_BlockInfoList(block_list);
489 490 491 492 493 494 495 496 497 498 499 500 501 502 503 504 505 506 507 508

    if ((!device && !nodes) || printed) {
        return;
    }

    /* Print node information */
    blockdev_list = qmp_query_named_block_nodes(NULL);
    for (blockdev = blockdev_list; blockdev; blockdev = blockdev->next) {
        assert(blockdev->value->has_node_name);
        if (device && strcmp(device, blockdev->value->node_name)) {
            continue;
        }

        if (blockdev != blockdev_list) {
            monitor_printf(mon, "\n");
        }

        print_block_info(mon, NULL, blockdev->value, verbose);
    }
    qapi_free_BlockDeviceInfoList(blockdev_list);
L
Luiz Capitulino 已提交
509 510
}

511
void hmp_info_blockstats(Monitor *mon, const QDict *qdict)
L
Luiz Capitulino 已提交
512 513 514
{
    BlockStatsList *stats_list, *stats;

515
    stats_list = qmp_query_blockstats(false, false, NULL);
L
Luiz Capitulino 已提交
516 517 518 519 520 521 522 523 524 525 526 527 528 529 530

    for (stats = stats_list; stats; stats = stats->next) {
        if (!stats->value->has_device) {
            continue;
        }

        monitor_printf(mon, "%s:", stats->value->device);
        monitor_printf(mon, " rd_bytes=%" PRId64
                       " wr_bytes=%" PRId64
                       " rd_operations=%" PRId64
                       " wr_operations=%" PRId64
                       " flush_operations=%" PRId64
                       " wr_total_time_ns=%" PRId64
                       " rd_total_time_ns=%" PRId64
                       " flush_total_time_ns=%" PRId64
531 532
                       " rd_merged=%" PRId64
                       " wr_merged=%" PRId64
533
                       " idle_time_ns=%" PRId64
L
Luiz Capitulino 已提交
534 535 536 537 538 539 540 541
                       "\n",
                       stats->value->stats->rd_bytes,
                       stats->value->stats->wr_bytes,
                       stats->value->stats->rd_operations,
                       stats->value->stats->wr_operations,
                       stats->value->stats->flush_operations,
                       stats->value->stats->wr_total_time_ns,
                       stats->value->stats->rd_total_time_ns,
542 543
                       stats->value->stats->flush_total_time_ns,
                       stats->value->stats->rd_merged,
544 545
                       stats->value->stats->wr_merged,
                       stats->value->stats->idle_time_ns);
L
Luiz Capitulino 已提交
546 547 548 549 550
    }

    qapi_free_BlockStatsList(stats_list);
}

551
void hmp_info_vnc(Monitor *mon, const QDict *qdict)
L
Luiz Capitulino 已提交
552 553 554 555 556 557 558
{
    VncInfo *info;
    Error *err = NULL;
    VncClientInfoList *client;

    info = qmp_query_vnc(&err);
    if (err) {
559
        error_report_err(err);
L
Luiz Capitulino 已提交
560 561 562 563 564 565 566 567 568 569 570 571 572 573 574 575 576 577 578 579 580 581
        return;
    }

    if (!info->enabled) {
        monitor_printf(mon, "Server: disabled\n");
        goto out;
    }

    monitor_printf(mon, "Server:\n");
    if (info->has_host && info->has_service) {
        monitor_printf(mon, "     address: %s:%s\n", info->host, info->service);
    }
    if (info->has_auth) {
        monitor_printf(mon, "        auth: %s\n", info->auth);
    }

    if (!info->has_clients || info->clients == NULL) {
        monitor_printf(mon, "Client: none\n");
    } else {
        for (client = info->clients; client; client = client->next) {
            monitor_printf(mon, "Client:\n");
            monitor_printf(mon, "     address: %s:%s\n",
E
Eric Blake 已提交
582 583
                           client->value->host,
                           client->value->service);
L
Luiz Capitulino 已提交
584 585 586 587 588 589 590 591 592 593 594 595 596
            monitor_printf(mon, "  x509_dname: %s\n",
                           client->value->x509_dname ?
                           client->value->x509_dname : "none");
            monitor_printf(mon, "    username: %s\n",
                           client->value->has_sasl_username ?
                           client->value->sasl_username : "none");
        }
    }

out:
    qapi_free_VncInfo(info);
}

597
#ifdef CONFIG_SPICE
598
void hmp_info_spice(Monitor *mon, const QDict *qdict)
L
Luiz Capitulino 已提交
599 600 601
{
    SpiceChannelList *chan;
    SpiceInfo *info;
602 603 604 605 606 607 608 609 610 611 612 613
    const char *channel_name;
    const char * const channel_names[] = {
        [SPICE_CHANNEL_MAIN] = "main",
        [SPICE_CHANNEL_DISPLAY] = "display",
        [SPICE_CHANNEL_INPUTS] = "inputs",
        [SPICE_CHANNEL_CURSOR] = "cursor",
        [SPICE_CHANNEL_PLAYBACK] = "playback",
        [SPICE_CHANNEL_RECORD] = "record",
        [SPICE_CHANNEL_TUNNEL] = "tunnel",
        [SPICE_CHANNEL_SMARTCARD] = "smartcard",
        [SPICE_CHANNEL_USBREDIR] = "usbredir",
        [SPICE_CHANNEL_PORT] = "port",
G
Gerd Hoffmann 已提交
614 615 616 617
#if 0
        /* minimum spice-protocol is 0.12.3, webdav was added in 0.12.7,
         * no easy way to #ifdef (SPICE_CHANNEL_* is a enum).  Disable
         * as quick fix for build failures with older versions. */
618
        [SPICE_CHANNEL_WEBDAV] = "webdav",
G
Gerd Hoffmann 已提交
619
#endif
620
    };
L
Luiz Capitulino 已提交
621 622 623 624 625 626 627 628 629 630 631 632 633 634 635 636 637

    info = qmp_query_spice(NULL);

    if (!info->enabled) {
        monitor_printf(mon, "Server: disabled\n");
        goto out;
    }

    monitor_printf(mon, "Server:\n");
    if (info->has_port) {
        monitor_printf(mon, "     address: %s:%" PRId64 "\n",
                       info->host, info->port);
    }
    if (info->has_tls_port) {
        monitor_printf(mon, "     address: %s:%" PRId64 " [tls]\n",
                       info->host, info->tls_port);
    }
638 639
    monitor_printf(mon, "    migrated: %s\n",
                   info->migrated ? "true" : "false");
L
Luiz Capitulino 已提交
640 641
    monitor_printf(mon, "        auth: %s\n", info->auth);
    monitor_printf(mon, "    compiled: %s\n", info->compiled_version);
A
Alon Levy 已提交
642 643
    monitor_printf(mon, "  mouse-mode: %s\n",
                   SpiceQueryMouseMode_lookup[info->mouse_mode]);
L
Luiz Capitulino 已提交
644 645 646 647 648 649 650

    if (!info->has_channels || info->channels == NULL) {
        monitor_printf(mon, "Channels: none\n");
    } else {
        for (chan = info->channels; chan; chan = chan->next) {
            monitor_printf(mon, "Channel:\n");
            monitor_printf(mon, "     address: %s:%s%s\n",
E
Eric Blake 已提交
651
                           chan->value->host, chan->value->port,
L
Luiz Capitulino 已提交
652 653 654 655 656
                           chan->value->tls ? " [tls]" : "");
            monitor_printf(mon, "     session: %" PRId64 "\n",
                           chan->value->connection_id);
            monitor_printf(mon, "     channel: %" PRId64 ":%" PRId64 "\n",
                           chan->value->channel_type, chan->value->channel_id);
657 658 659 660 661 662 663 664 665

            channel_name = "unknown";
            if (chan->value->channel_type > 0 &&
                chan->value->channel_type < ARRAY_SIZE(channel_names) &&
                channel_names[chan->value->channel_type]) {
                channel_name = channel_names[chan->value->channel_type];
            }

            monitor_printf(mon, "     channel name: %s\n", channel_name);
L
Luiz Capitulino 已提交
666 667 668 669 670 671
        }
    }

out:
    qapi_free_SpiceInfo(info);
}
672
#endif
L
Luiz Capitulino 已提交
673

674
void hmp_info_balloon(Monitor *mon, const QDict *qdict)
L
Luiz Capitulino 已提交
675 676 677 678 679 680
{
    BalloonInfo *info;
    Error *err = NULL;

    info = qmp_query_balloon(&err);
    if (err) {
681
        error_report_err(err);
L
Luiz Capitulino 已提交
682 683 684
        return;
    }

685
    monitor_printf(mon, "balloon: actual=%" PRId64 "\n", info->actual >> 20);
L
Luiz Capitulino 已提交
686 687 688 689

    qapi_free_BalloonInfo(info);
}

L
Luiz Capitulino 已提交
690 691 692 693 694 695 696 697 698
static void hmp_info_pci_device(Monitor *mon, const PciDeviceInfo *dev)
{
    PciMemoryRegionList *region;

    monitor_printf(mon, "  Bus %2" PRId64 ", ", dev->bus);
    monitor_printf(mon, "device %3" PRId64 ", function %" PRId64 ":\n",
                   dev->slot, dev->function);
    monitor_printf(mon, "    ");

699 700
    if (dev->class_info->has_desc) {
        monitor_printf(mon, "%s", dev->class_info->desc);
L
Luiz Capitulino 已提交
701
    } else {
702
        monitor_printf(mon, "Class %04" PRId64, dev->class_info->q_class);
L
Luiz Capitulino 已提交
703 704 705
    }

    monitor_printf(mon, ": PCI device %04" PRIx64 ":%04" PRIx64 "\n",
706
                   dev->id->vendor, dev->id->device);
L
Luiz Capitulino 已提交
707 708 709 710 711 712 713

    if (dev->has_irq) {
        monitor_printf(mon, "      IRQ %" PRId64 ".\n", dev->irq);
    }

    if (dev->has_pci_bridge) {
        monitor_printf(mon, "      BUS %" PRId64 ".\n",
714
                       dev->pci_bridge->bus->number);
L
Luiz Capitulino 已提交
715
        monitor_printf(mon, "      secondary bus %" PRId64 ".\n",
716
                       dev->pci_bridge->bus->secondary);
L
Luiz Capitulino 已提交
717
        monitor_printf(mon, "      subordinate bus %" PRId64 ".\n",
718
                       dev->pci_bridge->bus->subordinate);
L
Luiz Capitulino 已提交
719 720

        monitor_printf(mon, "      IO range [0x%04"PRIx64", 0x%04"PRIx64"]\n",
721 722
                       dev->pci_bridge->bus->io_range->base,
                       dev->pci_bridge->bus->io_range->limit);
L
Luiz Capitulino 已提交
723 724 725

        monitor_printf(mon,
                       "      memory range [0x%08"PRIx64", 0x%08"PRIx64"]\n",
726 727
                       dev->pci_bridge->bus->memory_range->base,
                       dev->pci_bridge->bus->memory_range->limit);
L
Luiz Capitulino 已提交
728 729 730

        monitor_printf(mon, "      prefetchable memory range "
                       "[0x%08"PRIx64", 0x%08"PRIx64"]\n",
731 732
                       dev->pci_bridge->bus->prefetchable_range->base,
                       dev->pci_bridge->bus->prefetchable_range->limit);
L
Luiz Capitulino 已提交
733 734 735 736 737 738 739 740 741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767
    }

    for (region = dev->regions; region; region = region->next) {
        uint64_t addr, size;

        addr = region->value->address;
        size = region->value->size;

        monitor_printf(mon, "      BAR%" PRId64 ": ", region->value->bar);

        if (!strcmp(region->value->type, "io")) {
            monitor_printf(mon, "I/O at 0x%04" PRIx64
                                " [0x%04" PRIx64 "].\n",
                           addr, addr + size - 1);
        } else {
            monitor_printf(mon, "%d bit%s memory at 0x%08" PRIx64
                               " [0x%08" PRIx64 "].\n",
                           region->value->mem_type_64 ? 64 : 32,
                           region->value->prefetch ? " prefetchable" : "",
                           addr, addr + size - 1);
        }
    }

    monitor_printf(mon, "      id \"%s\"\n", dev->qdev_id);

    if (dev->has_pci_bridge) {
        if (dev->pci_bridge->has_devices) {
            PciDeviceInfoList *cdev;
            for (cdev = dev->pci_bridge->devices; cdev; cdev = cdev->next) {
                hmp_info_pci_device(mon, cdev->value);
            }
        }
    }
}

768
void hmp_info_pci(Monitor *mon, const QDict *qdict)
L
Luiz Capitulino 已提交
769
{
S
Stefan Berger 已提交
770
    PciInfoList *info_list, *info;
L
Luiz Capitulino 已提交
771 772
    Error *err = NULL;

S
Stefan Berger 已提交
773
    info_list = qmp_query_pci(&err);
L
Luiz Capitulino 已提交
774 775 776 777 778 779
    if (err) {
        monitor_printf(mon, "PCI devices not supported\n");
        error_free(err);
        return;
    }

S
Stefan Berger 已提交
780
    for (info = info_list; info; info = info->next) {
L
Luiz Capitulino 已提交
781 782 783 784 785 786 787
        PciDeviceInfoList *dev;

        for (dev = info->value->devices; dev; dev = dev->next) {
            hmp_info_pci_device(mon, dev->value);
        }
    }

S
Stefan Berger 已提交
788
    qapi_free_PciInfoList(info_list);
L
Luiz Capitulino 已提交
789 790
}

791
void hmp_info_block_jobs(Monitor *mon, const QDict *qdict)
S
Stefan Hajnoczi 已提交
792 793 794 795 796 797 798 799 800 801 802 803 804 805 806 807 808 809 810 811 812 813 814 815 816 817 818 819 820 821 822 823 824
{
    BlockJobInfoList *list;
    Error *err = NULL;

    list = qmp_query_block_jobs(&err);
    assert(!err);

    if (!list) {
        monitor_printf(mon, "No active jobs\n");
        return;
    }

    while (list) {
        if (strcmp(list->value->type, "stream") == 0) {
            monitor_printf(mon, "Streaming device %s: Completed %" PRId64
                           " of %" PRId64 " bytes, speed limit %" PRId64
                           " bytes/s\n",
                           list->value->device,
                           list->value->offset,
                           list->value->len,
                           list->value->speed);
        } else {
            monitor_printf(mon, "Type %s, device %s: Completed %" PRId64
                           " of %" PRId64 " bytes, speed limit %" PRId64
                           " bytes/s\n",
                           list->value->type,
                           list->value->device,
                           list->value->offset,
                           list->value->len,
                           list->value->speed);
        }
        list = list->next;
    }
825 826

    qapi_free_BlockJobInfoList(list);
S
Stefan Hajnoczi 已提交
827 828
}

829 830 831 832 833 834 835 836 837 838 839 840 841 842 843 844 845 846 847 848 849 850 851 852
void hmp_info_tpm(Monitor *mon, const QDict *qdict)
{
    TPMInfoList *info_list, *info;
    Error *err = NULL;
    unsigned int c = 0;
    TPMPassthroughOptions *tpo;

    info_list = qmp_query_tpm(&err);
    if (err) {
        monitor_printf(mon, "TPM device not supported\n");
        error_free(err);
        return;
    }

    if (info_list) {
        monitor_printf(mon, "TPM device:\n");
    }

    for (info = info_list; info; info = info->next) {
        TPMInfo *ti = info->value;
        monitor_printf(mon, " tpm%d: model=%s\n",
                       c, TpmModel_lookup[ti->model]);

        monitor_printf(mon, "  \\ %s: type=%s",
E
Eric Blake 已提交
853
                       ti->id, TpmTypeOptionsKind_lookup[ti->options->type]);
854

E
Eric Blake 已提交
855
        switch (ti->options->type) {
856
        case TPM_TYPE_OPTIONS_KIND_PASSTHROUGH:
E
Eric Blake 已提交
857
            tpo = ti->options->u.passthrough;
858 859 860 861 862 863
            monitor_printf(mon, "%s%s%s%s",
                           tpo->has_path ? ",path=" : "",
                           tpo->has_path ? tpo->path : "",
                           tpo->has_cancel_path ? ",cancel-path=" : "",
                           tpo->has_cancel_path ? tpo->cancel_path : "");
            break;
864
        case TPM_TYPE_OPTIONS_KIND__MAX:
865 866 867 868 869 870 871 872
            break;
        }
        monitor_printf(mon, "\n");
        c++;
    }
    qapi_free_TPMInfoList(info_list);
}

L
Luiz Capitulino 已提交
873 874 875 876 877
void hmp_quit(Monitor *mon, const QDict *qdict)
{
    monitor_suspend(mon);
    qmp_quit(NULL);
}
L
Luiz Capitulino 已提交
878 879 880 881 882

void hmp_stop(Monitor *mon, const QDict *qdict)
{
    qmp_stop(NULL);
}
L
Luiz Capitulino 已提交
883 884 885 886 887

void hmp_system_reset(Monitor *mon, const QDict *qdict)
{
    qmp_system_reset(NULL);
}
L
Luiz Capitulino 已提交
888 889 890 891 892

void hmp_system_powerdown(Monitor *mon, const QDict *qdict)
{
    qmp_system_powerdown(NULL);
}
L
Luiz Capitulino 已提交
893 894 895 896 897 898 899 900 901 902 903 904

void hmp_cpu(Monitor *mon, const QDict *qdict)
{
    int64_t cpu_index;

    /* XXX: drop the monitor_set_cpu() usage when all HMP commands that
            use it are converted to the QAPI */
    cpu_index = qdict_get_int(qdict, "index");
    if (monitor_set_cpu(cpu_index) < 0) {
        monitor_printf(mon, "invalid CPU index\n");
    }
}
L
Luiz Capitulino 已提交
905 906 907 908 909 910

void hmp_memsave(Monitor *mon, const QDict *qdict)
{
    uint32_t size = qdict_get_int(qdict, "size");
    const char *filename = qdict_get_str(qdict, "filename");
    uint64_t addr = qdict_get_int(qdict, "val");
911
    Error *err = NULL;
L
Luiz Capitulino 已提交
912

913 914
    qmp_memsave(addr, size, filename, true, monitor_get_cpu_index(), &err);
    hmp_handle_error(mon, &err);
L
Luiz Capitulino 已提交
915
}
L
Luiz Capitulino 已提交
916 917 918 919 920 921

void hmp_pmemsave(Monitor *mon, const QDict *qdict)
{
    uint32_t size = qdict_get_int(qdict, "size");
    const char *filename = qdict_get_str(qdict, "filename");
    uint64_t addr = qdict_get_int(qdict, "val");
922
    Error *err = NULL;
L
Luiz Capitulino 已提交
923

924 925
    qmp_pmemsave(addr, size, filename, &err);
    hmp_handle_error(mon, &err);
926 927
}

928
void hmp_ringbuf_write(Monitor *mon, const QDict *qdict)
929 930 931
{
    const char *chardev = qdict_get_str(qdict, "device");
    const char *data = qdict_get_str(qdict, "data");
932
    Error *err = NULL;
933

934
    qmp_ringbuf_write(chardev, data, false, 0, &err);
935

936
    hmp_handle_error(mon, &err);
L
Luiz Capitulino 已提交
937
}
L
Luiz Capitulino 已提交
938

939
void hmp_ringbuf_read(Monitor *mon, const QDict *qdict)
940 941 942
{
    uint32_t size = qdict_get_int(qdict, "size");
    const char *chardev = qdict_get_str(qdict, "device");
943
    char *data;
944
    Error *err = NULL;
945
    int i;
946

947 948
    data = qmp_ringbuf_read(chardev, size, false, 0, &err);
    if (err) {
949
        error_report_err(err);
950 951 952
        return;
    }

953 954 955 956 957 958 959 960 961 962 963 964 965
    for (i = 0; data[i]; i++) {
        unsigned char ch = data[i];

        if (ch == '\\') {
            monitor_printf(mon, "\\\\");
        } else if ((ch < 0x20 && ch != '\n' && ch != '\t') || ch == 0x7F) {
            monitor_printf(mon, "\\u%04X", ch);
        } else {
            monitor_printf(mon, "%c", ch);
        }

    }
    monitor_printf(mon, "\n");
966
    g_free(data);
967 968
}

L
Luiz Capitulino 已提交
969 970 971
static void hmp_cont_cb(void *opaque, int err)
{
    if (!err) {
972
        qmp_cont(NULL);
L
Luiz Capitulino 已提交
973 974 975
    }
}

976 977 978 979 980
static bool key_is_missing(const BlockInfo *bdev)
{
    return (bdev->inserted && bdev->inserted->encryption_key_missing);
}

L
Luiz Capitulino 已提交
981 982
void hmp_cont(Monitor *mon, const QDict *qdict)
{
983
    BlockInfoList *bdev_list, *bdev;
984
    Error *err = NULL;
L
Luiz Capitulino 已提交
985

986 987 988 989 990 991
    bdev_list = qmp_query_block(NULL);
    for (bdev = bdev_list; bdev; bdev = bdev->next) {
        if (key_is_missing(bdev->value)) {
            monitor_read_block_device_key(mon, bdev->value->device,
                                          hmp_cont_cb, NULL);
            goto out;
L
Luiz Capitulino 已提交
992 993
        }
    }
994

995 996
    qmp_cont(&err);
    hmp_handle_error(mon, &err);
997 998 999

out:
    qapi_free_BlockInfoList(bdev_list);
L
Luiz Capitulino 已提交
1000
}
L
Luiz Capitulino 已提交
1001

1002 1003 1004 1005 1006
void hmp_system_wakeup(Monitor *mon, const QDict *qdict)
{
    qmp_system_wakeup(NULL);
}

1007
void hmp_nmi(Monitor *mon, const QDict *qdict)
L
Luiz Capitulino 已提交
1008
{
1009
    Error *err = NULL;
L
Luiz Capitulino 已提交
1010

1011 1012
    qmp_inject_nmi(&err);
    hmp_handle_error(mon, &err);
L
Luiz Capitulino 已提交
1013
}
L
Luiz Capitulino 已提交
1014 1015 1016 1017

void hmp_set_link(Monitor *mon, const QDict *qdict)
{
    const char *name = qdict_get_str(qdict, "name");
E
Eric Blake 已提交
1018
    bool up = qdict_get_bool(qdict, "up");
1019
    Error *err = NULL;
L
Luiz Capitulino 已提交
1020

1021 1022
    qmp_set_link(name, up, &err);
    hmp_handle_error(mon, &err);
L
Luiz Capitulino 已提交
1023
}
L
Luiz Capitulino 已提交
1024 1025 1026 1027 1028

void hmp_block_passwd(Monitor *mon, const QDict *qdict)
{
    const char *device = qdict_get_str(qdict, "device");
    const char *password = qdict_get_str(qdict, "password");
1029
    Error *err = NULL;
L
Luiz Capitulino 已提交
1030

1031 1032
    qmp_block_passwd(true, device, false, NULL, password, &err);
    hmp_handle_error(mon, &err);
L
Luiz Capitulino 已提交
1033
}
L
Luiz Capitulino 已提交
1034 1035 1036 1037

void hmp_balloon(Monitor *mon, const QDict *qdict)
{
    int64_t value = qdict_get_int(qdict, "value");
1038
    Error *err = NULL;
L
Luiz Capitulino 已提交
1039

1040 1041
    qmp_balloon(value, &err);
    if (err) {
1042
        error_report_err(err);
L
Luiz Capitulino 已提交
1043 1044
    }
}
L
Luiz Capitulino 已提交
1045 1046 1047 1048 1049

void hmp_block_resize(Monitor *mon, const QDict *qdict)
{
    const char *device = qdict_get_str(qdict, "device");
    int64_t size = qdict_get_int(qdict, "size");
1050
    Error *err = NULL;
L
Luiz Capitulino 已提交
1051

1052 1053
    qmp_block_resize(true, device, false, NULL, size, &err);
    hmp_handle_error(mon, &err);
L
Luiz Capitulino 已提交
1054
}
1055

P
Paolo Bonzini 已提交
1056 1057 1058 1059 1060
void hmp_drive_mirror(Monitor *mon, const QDict *qdict)
{
    const char *device = qdict_get_str(qdict, "device");
    const char *filename = qdict_get_str(qdict, "target");
    const char *format = qdict_get_try_str(qdict, "format");
E
Eric Blake 已提交
1061 1062
    bool reuse = qdict_get_try_bool(qdict, "reuse", false);
    bool full = qdict_get_try_bool(qdict, "full", false);
P
Paolo Bonzini 已提交
1063
    enum NewImageMode mode;
1064
    Error *err = NULL;
P
Paolo Bonzini 已提交
1065 1066

    if (!filename) {
1067
        error_setg(&err, QERR_MISSING_PARAMETER, "target");
1068
        hmp_handle_error(mon, &err);
P
Paolo Bonzini 已提交
1069 1070 1071 1072 1073 1074 1075 1076 1077 1078
        return;
    }

    if (reuse) {
        mode = NEW_IMAGE_MODE_EXISTING;
    } else {
        mode = NEW_IMAGE_MODE_ABSOLUTE_PATHS;
    }

    qmp_drive_mirror(device, filename, !!format, format,
1079
                     false, NULL, false, NULL,
P
Paolo Bonzini 已提交
1080
                     full ? MIRROR_SYNC_MODE_FULL : MIRROR_SYNC_MODE_TOP,
1081
                     true, mode, false, 0, false, 0, false, 0,
1082
                     false, 0, false, 0, false, true, &err);
1083
    hmp_handle_error(mon, &err);
P
Paolo Bonzini 已提交
1084 1085
}

1086 1087 1088 1089 1090
void hmp_drive_backup(Monitor *mon, const QDict *qdict)
{
    const char *device = qdict_get_str(qdict, "device");
    const char *filename = qdict_get_str(qdict, "target");
    const char *format = qdict_get_try_str(qdict, "format");
E
Eric Blake 已提交
1091 1092
    bool reuse = qdict_get_try_bool(qdict, "reuse", false);
    bool full = qdict_get_try_bool(qdict, "full", false);
1093
    enum NewImageMode mode;
1094
    Error *err = NULL;
1095 1096

    if (!filename) {
1097
        error_setg(&err, QERR_MISSING_PARAMETER, "target");
1098
        hmp_handle_error(mon, &err);
1099 1100 1101 1102 1103 1104 1105 1106 1107 1108 1109
        return;
    }

    if (reuse) {
        mode = NEW_IMAGE_MODE_EXISTING;
    } else {
        mode = NEW_IMAGE_MODE_ABSOLUTE_PATHS;
    }

    qmp_drive_backup(device, filename, !!format, format,
                     full ? MIRROR_SYNC_MODE_FULL : MIRROR_SYNC_MODE_TOP,
1110 1111
                     true, mode, false, 0, false, NULL,
                     false, 0, false, 0, &err);
1112
    hmp_handle_error(mon, &err);
1113 1114
}

1115 1116 1117 1118 1119
void hmp_snapshot_blkdev(Monitor *mon, const QDict *qdict)
{
    const char *device = qdict_get_str(qdict, "device");
    const char *filename = qdict_get_try_str(qdict, "snapshot-file");
    const char *format = qdict_get_try_str(qdict, "format");
E
Eric Blake 已提交
1120
    bool reuse = qdict_get_try_bool(qdict, "reuse", false);
1121
    enum NewImageMode mode;
1122
    Error *err = NULL;
1123 1124 1125 1126

    if (!filename) {
        /* In the future, if 'snapshot-file' is not specified, the snapshot
           will be taken internally. Today it's actually required. */
1127
        error_setg(&err, QERR_MISSING_PARAMETER, "snapshot-file");
1128
        hmp_handle_error(mon, &err);
1129 1130 1131
        return;
    }

1132
    mode = reuse ? NEW_IMAGE_MODE_EXISTING : NEW_IMAGE_MODE_ABSOLUTE_PATHS;
1133 1134 1135
    qmp_blockdev_snapshot_sync(true, device, false, NULL,
                               filename, false, NULL,
                               !!format, format,
1136 1137
                               true, mode, &err);
    hmp_handle_error(mon, &err);
1138
}
L
Luiz Capitulino 已提交
1139

1140 1141 1142 1143
void hmp_snapshot_blkdev_internal(Monitor *mon, const QDict *qdict)
{
    const char *device = qdict_get_str(qdict, "device");
    const char *name = qdict_get_str(qdict, "name");
1144
    Error *err = NULL;
1145

1146 1147
    qmp_blockdev_snapshot_internal_sync(device, name, &err);
    hmp_handle_error(mon, &err);
1148 1149
}

1150 1151 1152 1153 1154
void hmp_snapshot_delete_blkdev_internal(Monitor *mon, const QDict *qdict)
{
    const char *device = qdict_get_str(qdict, "device");
    const char *name = qdict_get_str(qdict, "name");
    const char *id = qdict_get_try_str(qdict, "id");
1155
    Error *err = NULL;
1156 1157

    qmp_blockdev_snapshot_delete_internal_sync(device, !!id, id,
1158 1159
                                               true, name, &err);
    hmp_handle_error(mon, &err);
1160 1161
}

L
Luiz Capitulino 已提交
1162 1163 1164 1165
void hmp_migrate_cancel(Monitor *mon, const QDict *qdict)
{
    qmp_migrate_cancel(NULL);
}
1166

D
Dr. David Alan Gilbert 已提交
1167 1168 1169 1170 1171 1172 1173
void hmp_migrate_incoming(Monitor *mon, const QDict *qdict)
{
    Error *err = NULL;
    const char *uri = qdict_get_str(qdict, "uri");

    qmp_migrate_incoming(uri, &err);

1174
    hmp_handle_error(mon, &err);
D
Dr. David Alan Gilbert 已提交
1175 1176
}

1177 1178 1179 1180 1181
void hmp_migrate_set_downtime(Monitor *mon, const QDict *qdict)
{
    double value = qdict_get_double(qdict, "value");
    qmp_migrate_set_downtime(value, NULL);
}
L
Luiz Capitulino 已提交
1182

1183 1184 1185 1186 1187 1188 1189
void hmp_migrate_set_cache_size(Monitor *mon, const QDict *qdict)
{
    int64_t value = qdict_get_int(qdict, "value");
    Error *err = NULL;

    qmp_migrate_set_cache_size(value, &err);
    if (err) {
1190
        error_report_err(err);
1191 1192 1193 1194
        return;
    }
}

L
Luiz Capitulino 已提交
1195 1196 1197 1198 1199
void hmp_migrate_set_speed(Monitor *mon, const QDict *qdict)
{
    int64_t value = qdict_get_int(qdict, "value");
    qmp_migrate_set_speed(value, NULL);
}
L
Luiz Capitulino 已提交
1200

O
Orit Wasserman 已提交
1201 1202 1203 1204 1205 1206 1207 1208
void hmp_migrate_set_capability(Monitor *mon, const QDict *qdict)
{
    const char *cap = qdict_get_str(qdict, "capability");
    bool state = qdict_get_bool(qdict, "state");
    Error *err = NULL;
    MigrationCapabilityStatusList *caps = g_malloc0(sizeof(*caps));
    int i;

1209
    for (i = 0; i < MIGRATION_CAPABILITY__MAX; i++) {
O
Orit Wasserman 已提交
1210 1211 1212 1213 1214 1215 1216 1217 1218 1219
        if (strcmp(cap, MigrationCapability_lookup[i]) == 0) {
            caps->value = g_malloc0(sizeof(*caps->value));
            caps->value->capability = i;
            caps->value->state = state;
            caps->next = NULL;
            qmp_migrate_set_capabilities(caps, &err);
            break;
        }
    }

1220
    if (i == MIGRATION_CAPABILITY__MAX) {
1221
        error_setg(&err, QERR_INVALID_PARAMETER, cap);
O
Orit Wasserman 已提交
1222 1223 1224 1225 1226
    }

    qapi_free_MigrationCapabilityStatusList(caps);

    if (err) {
1227
        error_report_err(err);
O
Orit Wasserman 已提交
1228 1229 1230
    }
}

1231 1232 1233 1234 1235 1236 1237 1238
void hmp_migrate_set_parameter(Monitor *mon, const QDict *qdict)
{
    const char *param = qdict_get_str(qdict, "parameter");
    int value = qdict_get_int(qdict, "value");
    Error *err = NULL;
    bool has_compress_level = false;
    bool has_compress_threads = false;
    bool has_decompress_threads = false;
1239 1240
    bool has_x_cpu_throttle_initial = false;
    bool has_x_cpu_throttle_increment = false;
1241 1242
    int i;

1243
    for (i = 0; i < MIGRATION_PARAMETER__MAX; i++) {
1244 1245 1246 1247 1248 1249 1250 1251 1252 1253 1254
        if (strcmp(param, MigrationParameter_lookup[i]) == 0) {
            switch (i) {
            case MIGRATION_PARAMETER_COMPRESS_LEVEL:
                has_compress_level = true;
                break;
            case MIGRATION_PARAMETER_COMPRESS_THREADS:
                has_compress_threads = true;
                break;
            case MIGRATION_PARAMETER_DECOMPRESS_THREADS:
                has_decompress_threads = true;
                break;
1255 1256 1257 1258 1259 1260
            case MIGRATION_PARAMETER_X_CPU_THROTTLE_INITIAL:
                has_x_cpu_throttle_initial = true;
                break;
            case MIGRATION_PARAMETER_X_CPU_THROTTLE_INCREMENT:
                has_x_cpu_throttle_increment = true;
                break;
1261 1262 1263 1264
            }
            qmp_migrate_set_parameters(has_compress_level, value,
                                       has_compress_threads, value,
                                       has_decompress_threads, value,
1265 1266
                                       has_x_cpu_throttle_initial, value,
                                       has_x_cpu_throttle_increment, value,
1267 1268 1269 1270 1271
                                       &err);
            break;
        }
    }

1272
    if (i == MIGRATION_PARAMETER__MAX) {
1273
        error_setg(&err, QERR_INVALID_PARAMETER, param);
1274 1275 1276
    }

    if (err) {
1277
        error_report_err(err);
1278 1279 1280
    }
}

1281 1282 1283 1284 1285 1286 1287 1288 1289 1290 1291 1292 1293 1294 1295 1296 1297
void hmp_client_migrate_info(Monitor *mon, const QDict *qdict)
{
    Error *err = NULL;
    const char *protocol = qdict_get_str(qdict, "protocol");
    const char *hostname = qdict_get_str(qdict, "hostname");
    bool has_port        = qdict_haskey(qdict, "port");
    int port             = qdict_get_try_int(qdict, "port", -1);
    bool has_tls_port    = qdict_haskey(qdict, "tls-port");
    int tls_port         = qdict_get_try_int(qdict, "tls-port", -1);
    const char *cert_subject = qdict_get_try_str(qdict, "cert-subject");

    qmp_client_migrate_info(protocol, hostname,
                            has_port, port, has_tls_port, tls_port,
                            !!cert_subject, cert_subject, &err);
    hmp_handle_error(mon, &err);
}

1298 1299 1300 1301 1302 1303 1304
void hmp_migrate_start_postcopy(Monitor *mon, const QDict *qdict)
{
    Error *err = NULL;
    qmp_migrate_start_postcopy(&err);
    hmp_handle_error(mon, &err);
}

L
Luiz Capitulino 已提交
1305 1306 1307 1308 1309 1310 1311 1312 1313 1314
void hmp_set_password(Monitor *mon, const QDict *qdict)
{
    const char *protocol  = qdict_get_str(qdict, "protocol");
    const char *password  = qdict_get_str(qdict, "password");
    const char *connected = qdict_get_try_str(qdict, "connected");
    Error *err = NULL;

    qmp_set_password(protocol, password, !!connected, connected, &err);
    hmp_handle_error(mon, &err);
}
L
Luiz Capitulino 已提交
1315 1316 1317 1318 1319 1320 1321 1322 1323 1324

void hmp_expire_password(Monitor *mon, const QDict *qdict)
{
    const char *protocol  = qdict_get_str(qdict, "protocol");
    const char *whenstr = qdict_get_str(qdict, "time");
    Error *err = NULL;

    qmp_expire_password(protocol, whenstr, &err);
    hmp_handle_error(mon, &err);
}
L
Luiz Capitulino 已提交
1325 1326 1327

void hmp_eject(Monitor *mon, const QDict *qdict)
{
E
Eric Blake 已提交
1328
    bool force = qdict_get_try_bool(qdict, "force", false);
L
Luiz Capitulino 已提交
1329 1330 1331 1332 1333 1334
    const char *device = qdict_get_str(qdict, "device");
    Error *err = NULL;

    qmp_eject(device, true, force, &err);
    hmp_handle_error(mon, &err);
}
L
Luiz Capitulino 已提交
1335

1336 1337
static void hmp_change_read_arg(void *opaque, const char *password,
                                void *readline_opaque)
L
Luiz Capitulino 已提交
1338 1339
{
    qmp_change_vnc_password(password, NULL);
1340
    monitor_read_command(opaque, 1);
L
Luiz Capitulino 已提交
1341 1342 1343 1344 1345 1346 1347
}

void hmp_change(Monitor *mon, const QDict *qdict)
{
    const char *device = qdict_get_str(qdict, "device");
    const char *target = qdict_get_str(qdict, "target");
    const char *arg = qdict_get_try_str(qdict, "arg");
1348 1349
    const char *read_only = qdict_get_try_str(qdict, "read-only-mode");
    BlockdevChangeReadOnlyMode read_only_mode = 0;
L
Luiz Capitulino 已提交
1350 1351
    Error *err = NULL;

1352
    if (strcmp(device, "vnc") == 0) {
1353 1354 1355 1356 1357
        if (read_only) {
            monitor_printf(mon,
                           "Parameter 'read-only-mode' is invalid for VNC\n");
            return;
        }
1358 1359 1360 1361 1362 1363 1364 1365 1366
        if (strcmp(target, "passwd") == 0 ||
            strcmp(target, "password") == 0) {
            if (!arg) {
                monitor_read_password(mon, hmp_change_read_arg, NULL);
                return;
            }
        }
        qmp_change("vnc", target, !!arg, arg, &err);
    } else {
1367 1368 1369
        if (read_only) {
            read_only_mode =
                qapi_enum_parse(BlockdevChangeReadOnlyMode_lookup,
1370
                                read_only, BLOCKDEV_CHANGE_READ_ONLY_MODE__MAX,
1371 1372 1373 1374 1375 1376 1377 1378 1379
                                BLOCKDEV_CHANGE_READ_ONLY_MODE_RETAIN, &err);
            if (err) {
                hmp_handle_error(mon, &err);
                return;
            }
        }

        qmp_blockdev_change_medium(device, target, !!arg, arg,
                                   !!read_only, read_only_mode, &err);
1380 1381 1382 1383
        if (err &&
            error_get_class(err) == ERROR_CLASS_DEVICE_ENCRYPTED) {
            error_free(err);
            monitor_read_block_device_key(mon, device, NULL, NULL);
L
Luiz Capitulino 已提交
1384 1385 1386 1387 1388 1389
            return;
        }
    }

    hmp_handle_error(mon, &err);
}
1390 1391 1392 1393 1394 1395 1396 1397 1398 1399 1400

void hmp_block_set_io_throttle(Monitor *mon, const QDict *qdict)
{
    Error *err = NULL;

    qmp_block_set_io_throttle(qdict_get_str(qdict, "device"),
                              qdict_get_int(qdict, "bps"),
                              qdict_get_int(qdict, "bps_rd"),
                              qdict_get_int(qdict, "bps_wr"),
                              qdict_get_int(qdict, "iops"),
                              qdict_get_int(qdict, "iops_rd"),
1401 1402 1403 1404 1405 1406 1407 1408 1409 1410 1411 1412
                              qdict_get_int(qdict, "iops_wr"),
                              false, /* no burst max via HMP */
                              0,
                              false,
                              0,
                              false,
                              0,
                              false,
                              0,
                              false,
                              0,
                              false,
1413 1414
                              0,
                              false, /* No default I/O size */
1415 1416 1417
                              0,
                              false,
                              NULL, &err);
1418 1419
    hmp_handle_error(mon, &err);
}
S
Stefan Hajnoczi 已提交
1420 1421 1422 1423 1424 1425

void hmp_block_stream(Monitor *mon, const QDict *qdict)
{
    Error *error = NULL;
    const char *device = qdict_get_str(qdict, "device");
    const char *base = qdict_get_try_str(qdict, "base");
1426
    int64_t speed = qdict_get_try_int(qdict, "speed", 0);
S
Stefan Hajnoczi 已提交
1427

1428
    qmp_block_stream(device, base != NULL, base, false, NULL,
P
Paolo Bonzini 已提交
1429
                     qdict_haskey(qdict, "speed"), speed,
A
Anthony Liguori 已提交
1430
                     true, BLOCKDEV_ON_ERROR_REPORT, &error);
S
Stefan Hajnoczi 已提交
1431 1432 1433

    hmp_handle_error(mon, &error);
}
1434 1435 1436 1437 1438

void hmp_block_job_set_speed(Monitor *mon, const QDict *qdict)
{
    Error *error = NULL;
    const char *device = qdict_get_str(qdict, "device");
1439
    int64_t value = qdict_get_int(qdict, "speed");
1440 1441 1442 1443 1444

    qmp_block_job_set_speed(device, value, &error);

    hmp_handle_error(mon, &error);
}
1445 1446 1447 1448 1449

void hmp_block_job_cancel(Monitor *mon, const QDict *qdict)
{
    Error *error = NULL;
    const char *device = qdict_get_str(qdict, "device");
E
Eric Blake 已提交
1450
    bool force = qdict_get_try_bool(qdict, "force", false);
1451

1452 1453 1454 1455 1456 1457 1458 1459 1460 1461 1462 1463 1464 1465 1466 1467 1468 1469 1470 1471 1472
    qmp_block_job_cancel(device, true, force, &error);

    hmp_handle_error(mon, &error);
}

void hmp_block_job_pause(Monitor *mon, const QDict *qdict)
{
    Error *error = NULL;
    const char *device = qdict_get_str(qdict, "device");

    qmp_block_job_pause(device, &error);

    hmp_handle_error(mon, &error);
}

void hmp_block_job_resume(Monitor *mon, const QDict *qdict)
{
    Error *error = NULL;
    const char *device = qdict_get_str(qdict, "device");

    qmp_block_job_resume(device, &error);
1473 1474 1475

    hmp_handle_error(mon, &error);
}
L
Luiz Capitulino 已提交
1476

P
Paolo Bonzini 已提交
1477 1478 1479 1480 1481 1482 1483 1484 1485 1486
void hmp_block_job_complete(Monitor *mon, const QDict *qdict)
{
    Error *error = NULL;
    const char *device = qdict_get_str(qdict, "device");

    qmp_block_job_complete(device, &error);

    hmp_handle_error(mon, &error);
}

1487
typedef struct HMPMigrationStatus
L
Luiz Capitulino 已提交
1488 1489 1490 1491
{
    QEMUTimer *timer;
    Monitor *mon;
    bool is_block_migration;
1492
} HMPMigrationStatus;
L
Luiz Capitulino 已提交
1493 1494 1495

static void hmp_migrate_status_cb(void *opaque)
{
1496
    HMPMigrationStatus *status = opaque;
L
Luiz Capitulino 已提交
1497 1498 1499
    MigrationInfo *info;

    info = qmp_query_migrate(NULL);
1500 1501
    if (!info->has_status || info->status == MIGRATION_STATUS_ACTIVE ||
        info->status == MIGRATION_STATUS_SETUP) {
L
Luiz Capitulino 已提交
1502 1503 1504 1505 1506 1507 1508 1509 1510 1511 1512 1513 1514
        if (info->has_disk) {
            int progress;

            if (info->disk->remaining) {
                progress = info->disk->transferred * 100 / info->disk->total;
            } else {
                progress = 100;
            }

            monitor_printf(status->mon, "Completed %d %%\r", progress);
            monitor_flush(status->mon);
        }

1515
        timer_mod(status->timer, qemu_clock_get_ms(QEMU_CLOCK_REALTIME) + 1000);
L
Luiz Capitulino 已提交
1516 1517 1518 1519 1520
    } else {
        if (status->is_block_migration) {
            monitor_printf(status->mon, "\n");
        }
        monitor_resume(status->mon);
1521
        timer_del(status->timer);
L
Luiz Capitulino 已提交
1522 1523 1524 1525 1526 1527 1528 1529
        g_free(status);
    }

    qapi_free_MigrationInfo(info);
}

void hmp_migrate(Monitor *mon, const QDict *qdict)
{
E
Eric Blake 已提交
1530 1531 1532
    bool detach = qdict_get_try_bool(qdict, "detach", false);
    bool blk = qdict_get_try_bool(qdict, "blk", false);
    bool inc = qdict_get_try_bool(qdict, "inc", false);
L
Luiz Capitulino 已提交
1533 1534 1535 1536 1537
    const char *uri = qdict_get_str(qdict, "uri");
    Error *err = NULL;

    qmp_migrate(uri, !!blk, blk, !!inc, inc, false, false, &err);
    if (err) {
1538
        error_report_err(err);
L
Luiz Capitulino 已提交
1539 1540 1541 1542
        return;
    }

    if (!detach) {
1543
        HMPMigrationStatus *status;
L
Luiz Capitulino 已提交
1544 1545 1546 1547 1548 1549 1550 1551 1552 1553

        if (monitor_suspend(mon) < 0) {
            monitor_printf(mon, "terminal does not allow synchronous "
                           "migration, continuing detached\n");
            return;
        }

        status = g_malloc0(sizeof(*status));
        status->mon = mon;
        status->is_block_migration = blk || inc;
1554
        status->timer = timer_new_ms(QEMU_CLOCK_REALTIME, hmp_migrate_status_cb,
L
Luiz Capitulino 已提交
1555
                                          status);
1556
        timer_mod(status->timer, qemu_clock_get_ms(QEMU_CLOCK_REALTIME));
L
Luiz Capitulino 已提交
1557 1558
    }
}
L
Luiz Capitulino 已提交
1559

1560 1561
void hmp_device_add(Monitor *mon, const QDict *qdict)
{
1562 1563 1564 1565
    Error *err = NULL;

    qmp_device_add((QDict *)qdict, NULL, &err);
    hmp_handle_error(mon, &err);
1566 1567
}

L
Luiz Capitulino 已提交
1568 1569 1570 1571 1572 1573 1574 1575
void hmp_device_del(Monitor *mon, const QDict *qdict)
{
    const char *id = qdict_get_str(qdict, "id");
    Error *err = NULL;

    qmp_device_del(id, &err);
    hmp_handle_error(mon, &err);
}
1576 1577 1578

void hmp_dump_guest_memory(Monitor *mon, const QDict *qdict)
{
1579
    Error *err = NULL;
E
Eric Blake 已提交
1580 1581 1582 1583
    bool paging = qdict_get_try_bool(qdict, "paging", false);
    bool zlib = qdict_get_try_bool(qdict, "zlib", false);
    bool lzo = qdict_get_try_bool(qdict, "lzo", false);
    bool snappy = qdict_get_try_bool(qdict, "snappy", false);
1584
    const char *file = qdict_get_str(qdict, "filename");
1585 1586 1587 1588
    bool has_begin = qdict_haskey(qdict, "begin");
    bool has_length = qdict_haskey(qdict, "length");
    int64_t begin = 0;
    int64_t length = 0;
1589
    enum DumpGuestMemoryFormat dump_format = DUMP_GUEST_MEMORY_FORMAT_ELF;
1590
    char *prot;
1591

1592
    if (zlib + lzo + snappy > 1) {
1593 1594
        error_setg(&err, "only one of '-z|-l|-s' can be set");
        hmp_handle_error(mon, &err);
1595 1596 1597 1598 1599 1600 1601 1602 1603 1604 1605 1606 1607 1608 1609
        return;
    }

    if (zlib) {
        dump_format = DUMP_GUEST_MEMORY_FORMAT_KDUMP_ZLIB;
    }

    if (lzo) {
        dump_format = DUMP_GUEST_MEMORY_FORMAT_KDUMP_LZO;
    }

    if (snappy) {
        dump_format = DUMP_GUEST_MEMORY_FORMAT_KDUMP_SNAPPY;
    }

1610 1611 1612 1613 1614 1615 1616
    if (has_begin) {
        begin = qdict_get_int(qdict, "begin");
    }
    if (has_length) {
        length = qdict_get_int(qdict, "length");
    }

1617 1618 1619
    prot = g_strconcat("file:", file, NULL);

    qmp_dump_guest_memory(paging, prot, has_begin, begin, has_length, length,
1620 1621
                          true, dump_format, &err);
    hmp_handle_error(mon, &err);
1622
    g_free(prot);
1623
}
L
Luiz Capitulino 已提交
1624 1625 1626 1627 1628 1629 1630

void hmp_netdev_add(Monitor *mon, const QDict *qdict)
{
    Error *err = NULL;
    QemuOpts *opts;

    opts = qemu_opts_from_qdict(qemu_find_opts("netdev"), qdict, &err);
1631
    if (err) {
L
Luiz Capitulino 已提交
1632 1633 1634 1635
        goto out;
    }

    netdev_add(opts, &err);
1636
    if (err) {
L
Luiz Capitulino 已提交
1637 1638 1639 1640 1641 1642
        qemu_opts_del(opts);
    }

out:
    hmp_handle_error(mon, &err);
}
L
Luiz Capitulino 已提交
1643 1644 1645 1646 1647 1648 1649 1650 1651

void hmp_netdev_del(Monitor *mon, const QDict *qdict)
{
    const char *id = qdict_get_str(qdict, "id");
    Error *err = NULL;

    qmp_netdev_del(id, &err);
    hmp_handle_error(mon, &err);
}
C
Corey Bryant 已提交
1652

1653 1654 1655
void hmp_object_add(Monitor *mon, const QDict *qdict)
{
    Error *err = NULL;
1656
    Error *err_end = NULL;
1657 1658 1659 1660 1661
    QemuOpts *opts;
    char *type = NULL;
    char *id = NULL;
    OptsVisitor *ov;
    QDict *pdict;
E
Eric Blake 已提交
1662
    Visitor *v;
1663 1664 1665 1666 1667 1668 1669 1670

    opts = qemu_opts_from_qdict(qemu_find_opts("object"), qdict, &err);
    if (err) {
        goto out;
    }

    ov = opts_visitor_new(opts);
    pdict = qdict_clone_shallow(qdict);
E
Eric Blake 已提交
1671
    v = opts_get_visitor(ov);
1672

1673
    visit_start_struct(v, NULL, NULL, 0, &err);
1674 1675 1676 1677 1678
    if (err) {
        goto out_clean;
    }

    qdict_del(pdict, "qom-type");
1679
    visit_type_str(v, "qom-type", &type, &err);
1680
    if (err) {
1681
        goto out_end;
1682 1683 1684
    }

    qdict_del(pdict, "id");
1685
    visit_type_str(v, "id", &id, &err);
1686
    if (err) {
1687
        goto out_end;
1688 1689
    }

E
Eric Blake 已提交
1690
    object_add(type, id, pdict, v, &err);
1691 1692

out_end:
E
Eric Blake 已提交
1693
    visit_end_struct(v, &err_end);
1694
    if (!err && err_end) {
1695 1696
        qmp_object_del(id, NULL);
    }
1697
    error_propagate(&err, err_end);
1698 1699 1700 1701 1702 1703 1704 1705 1706 1707 1708 1709
out_clean:
    opts_visitor_cleanup(ov);

    QDECREF(pdict);
    qemu_opts_del(opts);
    g_free(id);
    g_free(type);

out:
    hmp_handle_error(mon, &err);
}

C
Corey Bryant 已提交
1710 1711 1712
void hmp_getfd(Monitor *mon, const QDict *qdict)
{
    const char *fdname = qdict_get_str(qdict, "fdname");
1713
    Error *err = NULL;
C
Corey Bryant 已提交
1714

1715 1716
    qmp_getfd(fdname, &err);
    hmp_handle_error(mon, &err);
C
Corey Bryant 已提交
1717 1718 1719 1720 1721
}

void hmp_closefd(Monitor *mon, const QDict *qdict)
{
    const char *fdname = qdict_get_str(qdict, "fdname");
1722
    Error *err = NULL;
C
Corey Bryant 已提交
1723

1724 1725
    qmp_closefd(fdname, &err);
    hmp_handle_error(mon, &err);
C
Corey Bryant 已提交
1726
}
A
Amos Kong 已提交
1727

1728
void hmp_sendkey(Monitor *mon, const QDict *qdict)
A
Amos Kong 已提交
1729 1730
{
    const char *keys = qdict_get_str(qdict, "keys");
1731
    KeyValueList *keylist, *head = NULL, *tmp = NULL;
A
Amos Kong 已提交
1732 1733 1734 1735
    int has_hold_time = qdict_haskey(qdict, "hold-time");
    int hold_time = qdict_get_try_int(qdict, "hold-time", -1);
    Error *err = NULL;
    char *separator;
1736
    int keyname_len;
A
Amos Kong 已提交
1737 1738 1739 1740 1741 1742

    while (1) {
        separator = strchr(keys, '-');
        keyname_len = separator ? separator - keys : strlen(keys);

        /* Be compatible with old interface, convert user inputted "<" */
1743 1744
        if (keys[0] == '<' && keyname_len == 1) {
            keys = "less";
A
Amos Kong 已提交
1745 1746 1747 1748
            keyname_len = 4;
        }

        keylist = g_malloc0(sizeof(*keylist));
1749
        keylist->value = g_malloc0(sizeof(*keylist->value));
A
Amos Kong 已提交
1750 1751 1752 1753 1754 1755 1756 1757 1758

        if (!head) {
            head = keylist;
        }
        if (tmp) {
            tmp->next = keylist;
        }
        tmp = keylist;

1759
        if (strstart(keys, "0x", NULL)) {
1760
            char *endp;
1761 1762 1763
            int value = strtoul(keys, &endp, 0);
            assert(endp <= keys + keyname_len);
            if (endp != keys + keyname_len) {
1764 1765
                goto err_out;
            }
1766 1767
            keylist->value->type = KEY_VALUE_KIND_NUMBER;
            keylist->value->u.number = value;
1768
        } else {
1769
            int idx = index_from_key(keys, keyname_len);
1770
            if (idx == Q_KEY_CODE__MAX) {
1771 1772
                goto err_out;
            }
1773 1774
            keylist->value->type = KEY_VALUE_KIND_QCODE;
            keylist->value->u.qcode = idx;
1775 1776
        }

A
Amos Kong 已提交
1777 1778 1779 1780 1781 1782
        if (!separator) {
            break;
        }
        keys = separator + 1;
    }

1783
    qmp_send_key(head, has_hold_time, hold_time, &err);
A
Amos Kong 已提交
1784
    hmp_handle_error(mon, &err);
1785 1786 1787 1788 1789 1790

out:
    qapi_free_KeyValueList(head);
    return;

err_out:
1791
    monitor_printf(mon, "invalid parameter: %.*s\n", keyname_len, keys);
1792
    goto out;
A
Amos Kong 已提交
1793
}
L
Luiz Capitulino 已提交
1794

1795
void hmp_screendump(Monitor *mon, const QDict *qdict)
L
Luiz Capitulino 已提交
1796 1797 1798 1799 1800 1801 1802
{
    const char *filename = qdict_get_str(qdict, "filename");
    Error *err = NULL;

    qmp_screendump(filename, &err);
    hmp_handle_error(mon, &err);
}
P
Paolo Bonzini 已提交
1803 1804 1805 1806

void hmp_nbd_server_start(Monitor *mon, const QDict *qdict)
{
    const char *uri = qdict_get_str(qdict, "uri");
E
Eric Blake 已提交
1807 1808
    bool writable = qdict_get_try_bool(qdict, "writable", false);
    bool all = qdict_get_try_bool(qdict, "all", false);
P
Paolo Bonzini 已提交
1809 1810 1811 1812 1813 1814 1815 1816 1817 1818 1819 1820 1821 1822 1823 1824 1825 1826 1827 1828 1829 1830 1831 1832 1833 1834 1835 1836 1837 1838 1839 1840 1841 1842 1843 1844 1845 1846 1847 1848 1849 1850 1851 1852 1853 1854 1855 1856 1857 1858 1859 1860
    Error *local_err = NULL;
    BlockInfoList *block_list, *info;
    SocketAddress *addr;

    if (writable && !all) {
        error_setg(&local_err, "-w only valid together with -a");
        goto exit;
    }

    /* First check if the address is valid and start the server.  */
    addr = socket_parse(uri, &local_err);
    if (local_err != NULL) {
        goto exit;
    }

    qmp_nbd_server_start(addr, &local_err);
    qapi_free_SocketAddress(addr);
    if (local_err != NULL) {
        goto exit;
    }

    if (!all) {
        return;
    }

    /* Then try adding all block devices.  If one fails, close all and
     * exit.
     */
    block_list = qmp_query_block(NULL);

    for (info = block_list; info; info = info->next) {
        if (!info->value->has_inserted) {
            continue;
        }

        qmp_nbd_server_add(info->value->device, true, writable, &local_err);

        if (local_err != NULL) {
            qmp_nbd_server_stop(NULL);
            break;
        }
    }

    qapi_free_BlockInfoList(block_list);

exit:
    hmp_handle_error(mon, &local_err);
}

void hmp_nbd_server_add(Monitor *mon, const QDict *qdict)
{
    const char *device = qdict_get_str(qdict, "device");
E
Eric Blake 已提交
1861
    bool writable = qdict_get_try_bool(qdict, "writable", false);
P
Paolo Bonzini 已提交
1862 1863 1864 1865 1866 1867 1868 1869 1870 1871 1872
    Error *local_err = NULL;

    qmp_nbd_server_add(device, true, writable, &local_err);

    if (local_err != NULL) {
        hmp_handle_error(mon, &local_err);
    }
}

void hmp_nbd_server_stop(Monitor *mon, const QDict *qdict)
{
1873
    Error *err = NULL;
P
Paolo Bonzini 已提交
1874

1875 1876
    qmp_nbd_server_stop(&err);
    hmp_handle_error(mon, &err);
P
Paolo Bonzini 已提交
1877
}
1878

1879 1880 1881 1882 1883 1884 1885 1886 1887 1888
void hmp_cpu_add(Monitor *mon, const QDict *qdict)
{
    int cpuid;
    Error *err = NULL;

    cpuid = qdict_get_int(qdict, "id");
    qmp_cpu_add(cpuid, &err);
    hmp_handle_error(mon, &err);
}

1889 1890 1891 1892 1893 1894
void hmp_chardev_add(Monitor *mon, const QDict *qdict)
{
    const char *args = qdict_get_str(qdict, "args");
    Error *err = NULL;
    QemuOpts *opts;

1895
    opts = qemu_opts_parse_noisily(qemu_find_opts("chardev"), args, true);
1896
    if (opts == NULL) {
1897
        error_setg(&err, "Parsing chardev args failed");
1898 1899 1900 1901 1902 1903 1904 1905 1906 1907 1908 1909 1910
    } else {
        qemu_chr_new_from_opts(opts, NULL, &err);
    }
    hmp_handle_error(mon, &err);
}

void hmp_chardev_remove(Monitor *mon, const QDict *qdict)
{
    Error *local_err = NULL;

    qmp_chardev_remove(qdict_get_str(qdict, "id"), &local_err);
    hmp_handle_error(mon, &local_err);
}
1911 1912 1913

void hmp_qemu_io(Monitor *mon, const QDict *qdict)
{
M
Max Reitz 已提交
1914
    BlockBackend *blk;
1915 1916 1917 1918
    const char* device = qdict_get_str(qdict, "device");
    const char* command = qdict_get_str(qdict, "command");
    Error *err = NULL;

M
Max Reitz 已提交
1919 1920 1921
    blk = blk_by_name(device);
    if (blk) {
        qemuio_command(blk, command);
1922
    } else {
1923 1924
        error_set(&err, ERROR_CLASS_DEVICE_NOT_FOUND,
                  "Device '%s' not found", device);
1925 1926 1927 1928
    }

    hmp_handle_error(mon, &err);
}
1929 1930 1931 1932 1933 1934 1935 1936 1937

void hmp_object_del(Monitor *mon, const QDict *qdict)
{
    const char *id = qdict_get_str(qdict, "id");
    Error *err = NULL;

    qmp_object_del(id, &err);
    hmp_handle_error(mon, &err);
}
H
Hu Tao 已提交
1938 1939 1940 1941 1942 1943 1944

void hmp_info_memdev(Monitor *mon, const QDict *qdict)
{
    Error *err = NULL;
    MemdevList *memdev_list = qmp_query_memdev(&err);
    MemdevList *m = memdev_list;
    StringOutputVisitor *ov;
1945
    char *str;
H
Hu Tao 已提交
1946 1947 1948 1949 1950
    int i = 0;


    while (m) {
        ov = string_output_visitor_new(false);
1951 1952
        visit_type_uint16List(string_output_get_visitor(ov), NULL,
                              &m->value->host_nodes, NULL);
1953
        monitor_printf(mon, "memory backend: %d\n", i);
H
Hu Tao 已提交
1954 1955 1956 1957 1958 1959 1960 1961 1962
        monitor_printf(mon, "  size:  %" PRId64 "\n", m->value->size);
        monitor_printf(mon, "  merge: %s\n",
                       m->value->merge ? "true" : "false");
        monitor_printf(mon, "  dump: %s\n",
                       m->value->dump ? "true" : "false");
        monitor_printf(mon, "  prealloc: %s\n",
                       m->value->prealloc ? "true" : "false");
        monitor_printf(mon, "  policy: %s\n",
                       HostMemPolicy_lookup[m->value->policy]);
1963 1964
        str = string_output_get_string(ov);
        monitor_printf(mon, "  host nodes: %s\n", str);
H
Hu Tao 已提交
1965

1966
        g_free(str);
H
Hu Tao 已提交
1967 1968 1969 1970 1971 1972
        string_output_visitor_cleanup(ov);
        m = m->next;
        i++;
    }

    monitor_printf(mon, "\n");
C
Chen Fan 已提交
1973 1974

    qapi_free_MemdevList(memdev_list);
H
Hu Tao 已提交
1975
}
1976 1977 1978 1979 1980 1981 1982 1983 1984 1985 1986 1987 1988

void hmp_info_memory_devices(Monitor *mon, const QDict *qdict)
{
    Error *err = NULL;
    MemoryDeviceInfoList *info_list = qmp_query_memory_devices(&err);
    MemoryDeviceInfoList *info;
    MemoryDeviceInfo *value;
    PCDIMMDeviceInfo *di;

    for (info = info_list; info; info = info->next) {
        value = info->value;

        if (value) {
1989
            switch (value->type) {
1990
            case MEMORY_DEVICE_INFO_KIND_DIMM:
1991
                di = value->u.dimm;
1992 1993

                monitor_printf(mon, "Memory device [%s]: \"%s\"\n",
1994
                               MemoryDeviceInfoKind_lookup[value->type],
1995 1996 1997 1998 1999 2000 2001 2002 2003 2004 2005 2006 2007 2008 2009 2010 2011 2012 2013
                               di->id ? di->id : "");
                monitor_printf(mon, "  addr: 0x%" PRIx64 "\n", di->addr);
                monitor_printf(mon, "  slot: %" PRId64 "\n", di->slot);
                monitor_printf(mon, "  node: %" PRId64 "\n", di->node);
                monitor_printf(mon, "  size: %" PRIu64 "\n", di->size);
                monitor_printf(mon, "  memdev: %s\n", di->memdev);
                monitor_printf(mon, "  hotplugged: %s\n",
                               di->hotplugged ? "true" : "false");
                monitor_printf(mon, "  hotpluggable: %s\n",
                               di->hotpluggable ? "true" : "false");
                break;
            default:
                break;
            }
        }
    }

    qapi_free_MemoryDeviceInfoList(info_list);
}
2014

T
Ting Wang 已提交
2015 2016 2017 2018 2019 2020 2021 2022 2023 2024 2025 2026 2027
void hmp_info_iothreads(Monitor *mon, const QDict *qdict)
{
    IOThreadInfoList *info_list = qmp_query_iothreads(NULL);
    IOThreadInfoList *info;

    for (info = info_list; info; info = info->next) {
        monitor_printf(mon, "%s: thread_id=%" PRId64 "\n",
                       info->value->id, info->value->thread_id);
    }

    qapi_free_IOThreadInfoList(info_list);
}

2028 2029 2030 2031 2032 2033 2034 2035 2036 2037 2038 2039 2040 2041 2042 2043 2044 2045 2046 2047 2048 2049 2050 2051 2052
void hmp_qom_list(Monitor *mon, const QDict *qdict)
{
    const char *path = qdict_get_try_str(qdict, "path");
    ObjectPropertyInfoList *list;
    Error *err = NULL;

    if (path == NULL) {
        monitor_printf(mon, "/\n");
        return;
    }

    list = qmp_qom_list(path, &err);
    if (err == NULL) {
        ObjectPropertyInfoList *start = list;
        while (list != NULL) {
            ObjectPropertyInfo *value = list->value;

            monitor_printf(mon, "%s (%s)\n",
                           value->name, value->type);
            list = list->next;
        }
        qapi_free_ObjectPropertyInfoList(start);
    }
    hmp_handle_error(mon, &err);
}
2053 2054 2055 2056 2057 2058 2059 2060 2061 2062 2063 2064

void hmp_qom_set(Monitor *mon, const QDict *qdict)
{
    const char *path = qdict_get_str(qdict, "path");
    const char *property = qdict_get_str(qdict, "property");
    const char *value = qdict_get_str(qdict, "value");
    Error *err = NULL;
    bool ambiguous = false;
    Object *obj;

    obj = object_resolve_path(path, &ambiguous);
    if (obj == NULL) {
2065 2066
        error_set(&err, ERROR_CLASS_DEVICE_NOT_FOUND,
                  "Device '%s' not found", path);
2067 2068 2069 2070 2071 2072 2073 2074
    } else {
        if (ambiguous) {
            monitor_printf(mon, "Warning: Path '%s' is ambiguous\n", path);
        }
        object_property_parse(obj, value, property, &err);
    }
    hmp_handle_error(mon, &err);
}
2075 2076 2077 2078 2079

void hmp_rocker(Monitor *mon, const QDict *qdict)
{
    const char *name = qdict_get_str(qdict, "name");
    RockerSwitch *rocker;
2080
    Error *err = NULL;
2081

2082 2083 2084
    rocker = qmp_query_rocker(name, &err);
    if (err != NULL) {
        hmp_handle_error(mon, &err);
2085 2086 2087 2088 2089 2090 2091 2092 2093 2094 2095 2096 2097 2098
        return;
    }

    monitor_printf(mon, "name: %s\n", rocker->name);
    monitor_printf(mon, "id: 0x%" PRIx64 "\n", rocker->id);
    monitor_printf(mon, "ports: %d\n", rocker->ports);

    qapi_free_RockerSwitch(rocker);
}

void hmp_rocker_ports(Monitor *mon, const QDict *qdict)
{
    RockerPortList *list, *port;
    const char *name = qdict_get_str(qdict, "name");
2099
    Error *err = NULL;
2100

2101 2102 2103
    list = qmp_query_rocker_ports(name, &err);
    if (err != NULL) {
        hmp_handle_error(mon, &err);
2104 2105 2106 2107 2108 2109 2110 2111 2112 2113 2114 2115 2116 2117 2118 2119 2120 2121 2122 2123 2124 2125 2126 2127
        return;
    }

    monitor_printf(mon, "            ena/    speed/ auto\n");
    monitor_printf(mon, "      port  link    duplex neg?\n");

    for (port = list; port; port = port->next) {
        monitor_printf(mon, "%10s  %-4s   %-3s  %2s  %-3s\n",
                       port->value->name,
                       port->value->enabled ? port->value->link_up ?
                       "up" : "down" : "!ena",
                       port->value->speed == 10000 ? "10G" : "??",
                       port->value->duplex ? "FD" : "HD",
                       port->value->autoneg ? "Yes" : "No");
    }

    qapi_free_RockerPortList(list);
}

void hmp_rocker_of_dpa_flows(Monitor *mon, const QDict *qdict)
{
    RockerOfDpaFlowList *list, *info;
    const char *name = qdict_get_str(qdict, "name");
    uint32_t tbl_id = qdict_get_try_int(qdict, "tbl_id", -1);
2128
    Error *err = NULL;
2129

2130 2131 2132
    list = qmp_query_rocker_of_dpa_flows(name, tbl_id != -1, tbl_id, &err);
    if (err != NULL) {
        hmp_handle_error(mon, &err);
2133 2134 2135 2136 2137 2138 2139 2140 2141 2142 2143 2144 2145 2146 2147 2148 2149 2150 2151 2152 2153 2154 2155 2156 2157 2158 2159 2160 2161 2162 2163 2164 2165 2166 2167 2168 2169 2170 2171 2172 2173 2174 2175 2176 2177 2178 2179 2180 2181 2182 2183 2184 2185 2186 2187 2188 2189 2190 2191 2192 2193 2194 2195 2196 2197 2198 2199 2200 2201 2202 2203 2204 2205 2206 2207 2208 2209 2210 2211 2212 2213 2214 2215 2216 2217 2218 2219 2220 2221 2222 2223 2224 2225 2226 2227 2228 2229 2230 2231 2232 2233 2234 2235 2236 2237 2238 2239 2240 2241 2242 2243 2244 2245 2246 2247 2248 2249 2250 2251 2252 2253 2254 2255 2256 2257 2258 2259 2260 2261 2262 2263 2264 2265 2266 2267 2268 2269 2270 2271 2272 2273 2274 2275 2276 2277
        return;
    }

    monitor_printf(mon, "prio tbl hits key(mask) --> actions\n");

    for (info = list; info; info = info->next) {
        RockerOfDpaFlow *flow = info->value;
        RockerOfDpaFlowKey *key = flow->key;
        RockerOfDpaFlowMask *mask = flow->mask;
        RockerOfDpaFlowAction *action = flow->action;

        if (flow->hits) {
            monitor_printf(mon, "%-4d %-3d %-4" PRIu64,
                           key->priority, key->tbl_id, flow->hits);
        } else {
            monitor_printf(mon, "%-4d %-3d     ",
                           key->priority, key->tbl_id);
        }

        if (key->has_in_pport) {
            monitor_printf(mon, " pport %d", key->in_pport);
            if (mask->has_in_pport) {
                monitor_printf(mon, "(0x%x)", mask->in_pport);
            }
        }

        if (key->has_vlan_id) {
            monitor_printf(mon, " vlan %d",
                           key->vlan_id & VLAN_VID_MASK);
            if (mask->has_vlan_id) {
                monitor_printf(mon, "(0x%x)", mask->vlan_id);
            }
        }

        if (key->has_tunnel_id) {
            monitor_printf(mon, " tunnel %d", key->tunnel_id);
            if (mask->has_tunnel_id) {
                monitor_printf(mon, "(0x%x)", mask->tunnel_id);
            }
        }

        if (key->has_eth_type) {
            switch (key->eth_type) {
            case 0x0806:
                monitor_printf(mon, " ARP");
                break;
            case 0x0800:
                monitor_printf(mon, " IP");
                break;
            case 0x86dd:
                monitor_printf(mon, " IPv6");
                break;
            case 0x8809:
                monitor_printf(mon, " LACP");
                break;
            case 0x88cc:
                monitor_printf(mon, " LLDP");
                break;
            default:
                monitor_printf(mon, " eth type 0x%04x", key->eth_type);
                break;
            }
        }

        if (key->has_eth_src) {
            if ((strcmp(key->eth_src, "01:00:00:00:00:00") == 0) &&
                (mask->has_eth_src) &&
                (strcmp(mask->eth_src, "01:00:00:00:00:00") == 0)) {
                monitor_printf(mon, " src <any mcast/bcast>");
            } else if ((strcmp(key->eth_src, "00:00:00:00:00:00") == 0) &&
                (mask->has_eth_src) &&
                (strcmp(mask->eth_src, "01:00:00:00:00:00") == 0)) {
                monitor_printf(mon, " src <any ucast>");
            } else {
                monitor_printf(mon, " src %s", key->eth_src);
                if (mask->has_eth_src) {
                    monitor_printf(mon, "(%s)", mask->eth_src);
                }
            }
        }

        if (key->has_eth_dst) {
            if ((strcmp(key->eth_dst, "01:00:00:00:00:00") == 0) &&
                (mask->has_eth_dst) &&
                (strcmp(mask->eth_dst, "01:00:00:00:00:00") == 0)) {
                monitor_printf(mon, " dst <any mcast/bcast>");
            } else if ((strcmp(key->eth_dst, "00:00:00:00:00:00") == 0) &&
                (mask->has_eth_dst) &&
                (strcmp(mask->eth_dst, "01:00:00:00:00:00") == 0)) {
                monitor_printf(mon, " dst <any ucast>");
            } else {
                monitor_printf(mon, " dst %s", key->eth_dst);
                if (mask->has_eth_dst) {
                    monitor_printf(mon, "(%s)", mask->eth_dst);
                }
            }
        }

        if (key->has_ip_proto) {
            monitor_printf(mon, " proto %d", key->ip_proto);
            if (mask->has_ip_proto) {
                monitor_printf(mon, "(0x%x)", mask->ip_proto);
            }
        }

        if (key->has_ip_tos) {
            monitor_printf(mon, " TOS %d", key->ip_tos);
            if (mask->has_ip_tos) {
                monitor_printf(mon, "(0x%x)", mask->ip_tos);
            }
        }

        if (key->has_ip_dst) {
            monitor_printf(mon, " dst %s", key->ip_dst);
        }

        if (action->has_goto_tbl || action->has_group_id ||
            action->has_new_vlan_id) {
            monitor_printf(mon, " -->");
        }

        if (action->has_new_vlan_id) {
            monitor_printf(mon, " apply new vlan %d",
                           ntohs(action->new_vlan_id));
        }

        if (action->has_group_id) {
            monitor_printf(mon, " write group 0x%08x", action->group_id);
        }

        if (action->has_goto_tbl) {
            monitor_printf(mon, " goto tbl %d", action->goto_tbl);
        }

        monitor_printf(mon, "\n");
    }

    qapi_free_RockerOfDpaFlowList(list);
}

void hmp_rocker_of_dpa_groups(Monitor *mon, const QDict *qdict)
{
    RockerOfDpaGroupList *list, *g;
    const char *name = qdict_get_str(qdict, "name");
    uint8_t type = qdict_get_try_int(qdict, "type", 9);
2278
    Error *err = NULL;
2279 2280
    bool set = false;

2281 2282 2283
    list = qmp_query_rocker_of_dpa_groups(name, type != 9, type, &err);
    if (err != NULL) {
        hmp_handle_error(mon, &err);
2284 2285 2286 2287 2288 2289 2290 2291 2292 2293 2294 2295 2296 2297 2298 2299 2300 2301 2302 2303 2304 2305 2306 2307 2308 2309 2310 2311 2312 2313 2314 2315 2316 2317 2318 2319 2320 2321 2322 2323 2324 2325 2326 2327 2328 2329 2330 2331 2332 2333 2334 2335 2336 2337 2338 2339 2340 2341 2342 2343 2344 2345 2346 2347 2348 2349 2350 2351 2352 2353 2354 2355 2356 2357 2358 2359 2360 2361 2362 2363 2364 2365 2366 2367 2368 2369 2370 2371 2372 2373 2374 2375 2376
        return;
    }

    monitor_printf(mon, "id (decode) --> buckets\n");

    for (g = list; g; g = g->next) {
        RockerOfDpaGroup *group = g->value;

        monitor_printf(mon, "0x%08x", group->id);

        monitor_printf(mon, " (type %s", group->type == 0 ? "L2 interface" :
                                         group->type == 1 ? "L2 rewrite" :
                                         group->type == 2 ? "L3 unicast" :
                                         group->type == 3 ? "L2 multicast" :
                                         group->type == 4 ? "L2 flood" :
                                         group->type == 5 ? "L3 interface" :
                                         group->type == 6 ? "L3 multicast" :
                                         group->type == 7 ? "L3 ECMP" :
                                         group->type == 8 ? "L2 overlay" :
                                         "unknown");

        if (group->has_vlan_id) {
            monitor_printf(mon, " vlan %d", group->vlan_id);
        }

        if (group->has_pport) {
            monitor_printf(mon, " pport %d", group->pport);
        }

        if (group->has_index) {
            monitor_printf(mon, " index %d", group->index);
        }

        monitor_printf(mon, ") -->");

        if (group->has_set_vlan_id && group->set_vlan_id) {
            set = true;
            monitor_printf(mon, " set vlan %d",
                           group->set_vlan_id & VLAN_VID_MASK);
        }

        if (group->has_set_eth_src) {
            if (!set) {
                set = true;
                monitor_printf(mon, " set");
            }
            monitor_printf(mon, " src %s", group->set_eth_src);
        }

        if (group->has_set_eth_dst) {
            if (!set) {
                set = true;
                monitor_printf(mon, " set");
            }
            monitor_printf(mon, " dst %s", group->set_eth_dst);
        }

        set = false;

        if (group->has_ttl_check && group->ttl_check) {
            monitor_printf(mon, " check TTL");
        }

        if (group->has_group_id && group->group_id) {
            monitor_printf(mon, " group id 0x%08x", group->group_id);
        }

        if (group->has_pop_vlan && group->pop_vlan) {
            monitor_printf(mon, " pop vlan");
        }

        if (group->has_out_pport) {
            monitor_printf(mon, " out pport %d", group->out_pport);
        }

        if (group->has_group_ids) {
            struct uint32List *id;

            monitor_printf(mon, " groups [");
            for (id = group->group_ids; id; id = id->next) {
                monitor_printf(mon, "0x%08x", id->value);
                if (id->next) {
                    monitor_printf(mon, ",");
                }
            }
            monitor_printf(mon, "]");
        }

        monitor_printf(mon, "\n");
    }

    qapi_free_RockerOfDpaGroupList(list);
}