2011-09-02 17:34:48 +00:00
|
|
|
/*
|
|
|
|
* 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.
|
|
|
|
*
|
2012-01-13 16:44:23 +00:00
|
|
|
* Contributions after 2012-01-13 are licensed under the terms of the
|
|
|
|
* GNU GPL, version 2 or (at your option) any later version.
|
2011-09-02 17:34:48 +00:00
|
|
|
*/
|
|
|
|
|
|
|
|
#include "hmp.h"
|
2012-10-24 06:43:34 +00:00
|
|
|
#include "net/net.h"
|
2013-04-08 14:55:25 +00:00
|
|
|
#include "sysemu/char.h"
|
2012-12-17 17:20:00 +00:00
|
|
|
#include "qemu/option.h"
|
|
|
|
#include "qemu/timer.h"
|
2011-09-02 17:34:48 +00:00
|
|
|
#include "qmp-commands.h"
|
2012-12-17 17:20:00 +00:00
|
|
|
#include "qemu/sockets.h"
|
2012-12-17 17:19:49 +00:00
|
|
|
#include "monitor/monitor.h"
|
2012-11-28 11:06:30 +00:00
|
|
|
#include "ui/console.h"
|
2013-06-06 04:28:00 +00:00
|
|
|
#include "block/qapi.h"
|
2013-06-05 12:19:41 +00:00
|
|
|
#include "qemu-io.h"
|
2011-09-02 17:34:48 +00:00
|
|
|
|
2011-11-22 18:32:37 +00:00
|
|
|
static void hmp_handle_error(Monitor *mon, Error **errp)
|
|
|
|
{
|
|
|
|
if (error_is_set(errp)) {
|
|
|
|
monitor_printf(mon, "%s\n", error_get_pretty(*errp));
|
|
|
|
error_free(*errp);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2013-01-14 06:06:25 +00:00
|
|
|
void hmp_info_name(Monitor *mon, const QDict *qdict)
|
2011-09-02 17:34:48 +00:00
|
|
|
{
|
|
|
|
NameInfo *info;
|
|
|
|
|
|
|
|
info = qmp_query_name(NULL);
|
|
|
|
if (info->has_name) {
|
|
|
|
monitor_printf(mon, "%s\n", info->name);
|
|
|
|
}
|
|
|
|
qapi_free_NameInfo(info);
|
|
|
|
}
|
2011-08-26 20:38:13 +00:00
|
|
|
|
2013-01-14 06:06:25 +00:00
|
|
|
void hmp_info_version(Monitor *mon, const QDict *qdict)
|
2011-08-26 20:38:13 +00:00
|
|
|
{
|
|
|
|
VersionInfo *info;
|
|
|
|
|
|
|
|
info = qmp_query_version(NULL);
|
|
|
|
|
|
|
|
monitor_printf(mon, "%" PRId64 ".%" PRId64 ".%" PRId64 "%s\n",
|
|
|
|
info->qemu.major, info->qemu.minor, info->qemu.micro,
|
|
|
|
info->package);
|
|
|
|
|
|
|
|
qapi_free_VersionInfo(info);
|
|
|
|
}
|
2011-09-12 18:10:53 +00:00
|
|
|
|
2013-01-14 06:06:25 +00:00
|
|
|
void hmp_info_kvm(Monitor *mon, const QDict *qdict)
|
2011-09-12 18:10:53 +00:00
|
|
|
{
|
|
|
|
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);
|
|
|
|
}
|
|
|
|
|
2013-01-14 06:06:25 +00:00
|
|
|
void hmp_info_status(Monitor *mon, const QDict *qdict)
|
2011-09-12 20:54:20 +00:00
|
|
|
{
|
|
|
|
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);
|
|
|
|
}
|
|
|
|
|
2013-01-14 06:06:25 +00:00
|
|
|
void hmp_info_uuid(Monitor *mon, const QDict *qdict)
|
2011-09-13 20:16:25 +00:00
|
|
|
{
|
|
|
|
UuidInfo *info;
|
|
|
|
|
|
|
|
info = qmp_query_uuid(NULL);
|
|
|
|
monitor_printf(mon, "%s\n", info->UUID);
|
|
|
|
qapi_free_UuidInfo(info);
|
|
|
|
}
|
2011-09-14 19:05:49 +00:00
|
|
|
|
2013-01-14 06:06:25 +00:00
|
|
|
void hmp_info_chardev(Monitor *mon, const QDict *qdict)
|
2011-09-14 19:05:49 +00:00
|
|
|
{
|
|
|
|
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);
|
|
|
|
}
|
2011-09-15 17:20:28 +00:00
|
|
|
|
2013-01-14 06:06:25 +00:00
|
|
|
void hmp_info_mice(Monitor *mon, const QDict *qdict)
|
2011-09-21 18:29:55 +00:00
|
|
|
{
|
|
|
|
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);
|
|
|
|
}
|
|
|
|
|
2013-01-14 06:06:25 +00:00
|
|
|
void hmp_info_migrate(Monitor *mon, const QDict *qdict)
|
2011-09-13 20:37:16 +00:00
|
|
|
{
|
|
|
|
MigrationInfo *info;
|
2012-08-06 18:42:47 +00:00
|
|
|
MigrationCapabilityStatusList *caps, *cap;
|
2011-09-13 20:37:16 +00:00
|
|
|
|
|
|
|
info = qmp_query_migrate(NULL);
|
2012-08-06 18:42:47 +00:00
|
|
|
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");
|
|
|
|
}
|
2011-09-13 20:37:16 +00:00
|
|
|
|
|
|
|
if (info->has_status) {
|
|
|
|
monitor_printf(mon, "Migration status: %s\n", info->status);
|
2012-08-18 11:17:10 +00:00
|
|
|
monitor_printf(mon, "total time: %" PRIu64 " milliseconds\n",
|
|
|
|
info->total_time);
|
2012-08-13 07:53:12 +00:00
|
|
|
if (info->has_expected_downtime) {
|
|
|
|
monitor_printf(mon, "expected downtime: %" PRIu64 " milliseconds\n",
|
|
|
|
info->expected_downtime);
|
|
|
|
}
|
2012-08-13 07:35:16 +00:00
|
|
|
if (info->has_downtime) {
|
|
|
|
monitor_printf(mon, "downtime: %" PRIu64 " milliseconds\n",
|
|
|
|
info->downtime);
|
|
|
|
}
|
2013-07-22 14:01:58 +00:00
|
|
|
if (info->has_setup_time) {
|
|
|
|
monitor_printf(mon, "setup: %" PRIu64 " milliseconds\n",
|
|
|
|
info->setup_time);
|
|
|
|
}
|
2011-09-13 20:37:16 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
if (info->has_ram) {
|
|
|
|
monitor_printf(mon, "transferred ram: %" PRIu64 " kbytes\n",
|
|
|
|
info->ram->transferred >> 10);
|
2013-06-26 01:35:30 +00:00
|
|
|
monitor_printf(mon, "throughput: %0.2f mbps\n",
|
|
|
|
info->ram->mbps);
|
2011-09-13 20:37:16 +00:00
|
|
|
monitor_printf(mon, "remaining ram: %" PRIu64 " kbytes\n",
|
|
|
|
info->ram->remaining >> 10);
|
|
|
|
monitor_printf(mon, "total ram: %" PRIu64 " kbytes\n",
|
|
|
|
info->ram->total >> 10);
|
2012-08-06 18:42:56 +00:00
|
|
|
monitor_printf(mon, "duplicate: %" PRIu64 " pages\n",
|
|
|
|
info->ram->duplicate);
|
2013-03-26 09:58:37 +00:00
|
|
|
monitor_printf(mon, "skipped: %" PRIu64 " pages\n",
|
|
|
|
info->ram->skipped);
|
2012-08-06 18:42:56 +00:00
|
|
|
monitor_printf(mon, "normal: %" PRIu64 " pages\n",
|
|
|
|
info->ram->normal);
|
|
|
|
monitor_printf(mon, "normal bytes: %" PRIu64 " kbytes\n",
|
|
|
|
info->ram->normal_bytes >> 10);
|
2012-08-13 10:31:25 +00:00
|
|
|
if (info->ram->dirty_pages_rate) {
|
|
|
|
monitor_printf(mon, "dirty pages rate: %" PRIu64 " pages\n",
|
|
|
|
info->ram->dirty_pages_rate);
|
|
|
|
}
|
2011-09-13 20:37:16 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
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);
|
|
|
|
}
|
|
|
|
|
2012-08-06 18:42:57 +00:00
|
|
|
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);
|
|
|
|
monitor_printf(mon, "xbzrle overflow : %" PRIu64 "\n",
|
|
|
|
info->xbzrle_cache->overflow);
|
|
|
|
}
|
|
|
|
|
2011-09-13 20:37:16 +00:00
|
|
|
qapi_free_MigrationInfo(info);
|
2012-08-06 18:42:47 +00:00
|
|
|
qapi_free_MigrationCapabilityStatusList(caps);
|
|
|
|
}
|
|
|
|
|
2013-01-14 06:06:25 +00:00
|
|
|
void hmp_info_migrate_capabilities(Monitor *mon, const QDict *qdict)
|
2012-08-06 18:42:47 +00:00
|
|
|
{
|
|
|
|
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);
|
2011-09-13 20:37:16 +00:00
|
|
|
}
|
|
|
|
|
2013-01-14 06:06:25 +00:00
|
|
|
void hmp_info_migrate_cache_size(Monitor *mon, const QDict *qdict)
|
2012-08-06 18:42:54 +00:00
|
|
|
{
|
|
|
|
monitor_printf(mon, "xbzrel cache size: %" PRId64 " kbytes\n",
|
|
|
|
qmp_query_migrate_cache_size(NULL) >> 10);
|
|
|
|
}
|
|
|
|
|
2013-01-14 06:06:25 +00:00
|
|
|
void hmp_info_cpus(Monitor *mon, const QDict *qdict)
|
2011-09-21 19:38:35 +00:00
|
|
|
{
|
|
|
|
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 = '*';
|
|
|
|
}
|
|
|
|
|
2012-10-19 21:19:19 +00:00
|
|
|
monitor_printf(mon, "%c CPU #%" PRId64 ":", active, cpu->value->CPU);
|
2011-09-21 19:38:35 +00:00
|
|
|
|
|
|
|
if (cpu->value->has_pc) {
|
2012-10-19 21:19:19 +00:00
|
|
|
monitor_printf(mon, " pc=0x%016" PRIx64, cpu->value->pc);
|
2011-09-21 19:38:35 +00:00
|
|
|
}
|
|
|
|
if (cpu->value->has_nip) {
|
2012-10-19 21:19:19 +00:00
|
|
|
monitor_printf(mon, " nip=0x%016" PRIx64, cpu->value->nip);
|
2011-09-21 19:38:35 +00:00
|
|
|
}
|
|
|
|
if (cpu->value->has_npc) {
|
2012-10-19 21:19:19 +00:00
|
|
|
monitor_printf(mon, " npc=0x%016" PRIx64, cpu->value->npc);
|
2011-09-21 19:38:35 +00:00
|
|
|
}
|
|
|
|
if (cpu->value->has_PC) {
|
2012-10-19 21:19:19 +00:00
|
|
|
monitor_printf(mon, " PC=0x%016" PRIx64, cpu->value->PC);
|
2011-09-21 19:38:35 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
if (cpu->value->halted) {
|
|
|
|
monitor_printf(mon, " (halted)");
|
|
|
|
}
|
|
|
|
|
|
|
|
monitor_printf(mon, " thread_id=%" PRId64 "\n", cpu->value->thread_id);
|
|
|
|
}
|
|
|
|
|
|
|
|
qapi_free_CpuInfoList(cpu_list);
|
|
|
|
}
|
|
|
|
|
2013-01-14 06:06:25 +00:00
|
|
|
void hmp_info_block(Monitor *mon, const QDict *qdict)
|
2011-09-21 20:16:47 +00:00
|
|
|
{
|
|
|
|
BlockInfoList *block_list, *info;
|
2013-06-06 04:28:00 +00:00
|
|
|
ImageInfo *image_info;
|
2013-06-06 04:28:01 +00:00
|
|
|
const char *device = qdict_get_try_str(qdict, "device");
|
|
|
|
bool verbose = qdict_get_try_bool(qdict, "verbose", 0);
|
2011-09-21 20:16:47 +00:00
|
|
|
|
|
|
|
block_list = qmp_query_block(NULL);
|
|
|
|
|
|
|
|
for (info = block_list; info; info = info->next) {
|
2013-06-06 04:28:01 +00:00
|
|
|
if (device && strcmp(device, info->value->device)) {
|
|
|
|
continue;
|
|
|
|
}
|
2011-09-21 20:16:47 +00:00
|
|
|
|
2013-06-19 14:10:55 +00:00
|
|
|
if (info != block_list) {
|
|
|
|
monitor_printf(mon, "\n");
|
|
|
|
}
|
|
|
|
|
|
|
|
monitor_printf(mon, "%s", info->value->device);
|
|
|
|
if (info->value->has_inserted) {
|
|
|
|
monitor_printf(mon, ": %s (%s%s%s)\n",
|
|
|
|
info->value->inserted->file,
|
|
|
|
info->value->inserted->drv,
|
|
|
|
info->value->inserted->ro ? ", read-only" : "",
|
|
|
|
info->value->inserted->encrypted ? ", encrypted" : "");
|
|
|
|
} else {
|
|
|
|
monitor_printf(mon, ": [not inserted]\n");
|
2011-09-21 20:16:47 +00:00
|
|
|
}
|
|
|
|
|
2013-06-19 14:10:55 +00:00
|
|
|
if (info->value->has_io_status && info->value->io_status != BLOCK_DEVICE_IO_STATUS_OK) {
|
|
|
|
monitor_printf(mon, " I/O status: %s\n",
|
2011-09-21 20:16:47 +00:00
|
|
|
BlockDeviceIoStatus_lookup[info->value->io_status]);
|
|
|
|
}
|
|
|
|
|
2013-06-19 14:10:55 +00:00
|
|
|
if (info->value->removable) {
|
|
|
|
monitor_printf(mon, " Removable device: %slocked, tray %s\n",
|
|
|
|
info->value->locked ? "" : "not ",
|
|
|
|
info->value->tray_open ? "open" : "closed");
|
|
|
|
}
|
2011-11-08 05:00:31 +00:00
|
|
|
|
2013-06-19 14:10:55 +00:00
|
|
|
|
|
|
|
if (!info->value->has_inserted) {
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (info->value->inserted->has_backing_file) {
|
|
|
|
monitor_printf(mon,
|
|
|
|
" Backing file: %s "
|
|
|
|
"(chain depth: %" PRId64 ")\n",
|
|
|
|
info->value->inserted->backing_file,
|
|
|
|
info->value->inserted->backing_file_depth);
|
|
|
|
}
|
|
|
|
|
|
|
|
if (info->value->inserted->bps
|
|
|
|
|| info->value->inserted->bps_rd
|
|
|
|
|| info->value->inserted->bps_wr
|
|
|
|
|| info->value->inserted->iops
|
|
|
|
|| info->value->inserted->iops_rd
|
|
|
|
|| info->value->inserted->iops_wr)
|
|
|
|
{
|
|
|
|
monitor_printf(mon, " I/O throttling: bps=%" PRId64
|
|
|
|
" bps_rd=%" PRId64 " bps_wr=%" PRId64
|
|
|
|
" iops=%" PRId64 " iops_rd=%" PRId64
|
|
|
|
" iops_wr=%" PRId64 "\n",
|
2011-11-08 05:00:31 +00:00
|
|
|
info->value->inserted->bps,
|
|
|
|
info->value->inserted->bps_rd,
|
|
|
|
info->value->inserted->bps_wr,
|
|
|
|
info->value->inserted->iops,
|
|
|
|
info->value->inserted->iops_rd,
|
|
|
|
info->value->inserted->iops_wr);
|
2013-06-19 14:10:55 +00:00
|
|
|
}
|
2013-06-06 04:28:00 +00:00
|
|
|
|
2013-06-19 14:10:55 +00:00
|
|
|
if (verbose) {
|
|
|
|
monitor_printf(mon, "\nImages:\n");
|
|
|
|
image_info = info->value->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;
|
2013-06-06 04:28:00 +00:00
|
|
|
}
|
|
|
|
}
|
2011-09-21 20:16:47 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
qapi_free_BlockInfoList(block_list);
|
|
|
|
}
|
|
|
|
|
2013-01-14 06:06:25 +00:00
|
|
|
void hmp_info_blockstats(Monitor *mon, const QDict *qdict)
|
2011-09-22 18:56:36 +00:00
|
|
|
{
|
|
|
|
BlockStatsList *stats_list, *stats;
|
|
|
|
|
|
|
|
stats_list = qmp_query_blockstats(NULL);
|
|
|
|
|
|
|
|
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
|
|
|
|
"\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,
|
|
|
|
stats->value->stats->flush_total_time_ns);
|
|
|
|
}
|
|
|
|
|
|
|
|
qapi_free_BlockStatsList(stats_list);
|
|
|
|
}
|
|
|
|
|
2013-01-14 06:06:25 +00:00
|
|
|
void hmp_info_vnc(Monitor *mon, const QDict *qdict)
|
2011-10-17 18:41:22 +00:00
|
|
|
{
|
|
|
|
VncInfo *info;
|
|
|
|
Error *err = NULL;
|
|
|
|
VncClientInfoList *client;
|
|
|
|
|
|
|
|
info = qmp_query_vnc(&err);
|
|
|
|
if (err) {
|
|
|
|
monitor_printf(mon, "%s\n", error_get_pretty(err));
|
|
|
|
error_free(err);
|
|
|
|
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",
|
|
|
|
client->value->host, client->value->service);
|
|
|
|
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);
|
|
|
|
}
|
|
|
|
|
2013-01-14 06:06:25 +00:00
|
|
|
void hmp_info_spice(Monitor *mon, const QDict *qdict)
|
2011-10-20 19:01:33 +00:00
|
|
|
{
|
|
|
|
SpiceChannelList *chan;
|
|
|
|
SpiceInfo *info;
|
|
|
|
|
|
|
|
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);
|
|
|
|
}
|
2012-08-21 08:51:58 +00:00
|
|
|
monitor_printf(mon, " migrated: %s\n",
|
|
|
|
info->migrated ? "true" : "false");
|
2011-10-20 19:01:33 +00:00
|
|
|
monitor_printf(mon, " auth: %s\n", info->auth);
|
|
|
|
monitor_printf(mon, " compiled: %s\n", info->compiled_version);
|
2012-03-29 21:23:14 +00:00
|
|
|
monitor_printf(mon, " mouse-mode: %s\n",
|
|
|
|
SpiceQueryMouseMode_lookup[info->mouse_mode]);
|
2011-10-20 19:01:33 +00:00
|
|
|
|
|
|
|
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",
|
|
|
|
chan->value->host, chan->value->port,
|
|
|
|
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);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
out:
|
|
|
|
qapi_free_SpiceInfo(info);
|
|
|
|
}
|
|
|
|
|
2013-01-14 06:06:25 +00:00
|
|
|
void hmp_info_balloon(Monitor *mon, const QDict *qdict)
|
2011-10-21 13:41:37 +00:00
|
|
|
{
|
|
|
|
BalloonInfo *info;
|
|
|
|
Error *err = NULL;
|
|
|
|
|
|
|
|
info = qmp_query_balloon(&err);
|
|
|
|
if (err) {
|
|
|
|
monitor_printf(mon, "%s\n", error_get_pretty(err));
|
|
|
|
error_free(err);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2012-12-03 17:56:41 +00:00
|
|
|
monitor_printf(mon, "balloon: actual=%" PRId64 "\n", info->actual >> 20);
|
2011-10-21 13:41:37 +00:00
|
|
|
|
|
|
|
qapi_free_BalloonInfo(info);
|
|
|
|
}
|
|
|
|
|
2011-10-21 16:15:33 +00:00
|
|
|
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, " ");
|
|
|
|
|
|
|
|
if (dev->class_info.has_desc) {
|
|
|
|
monitor_printf(mon, "%s", dev->class_info.desc);
|
|
|
|
} else {
|
|
|
|
monitor_printf(mon, "Class %04" PRId64, dev->class_info.class);
|
|
|
|
}
|
|
|
|
|
|
|
|
monitor_printf(mon, ": PCI device %04" PRIx64 ":%04" PRIx64 "\n",
|
|
|
|
dev->id.vendor, dev->id.device);
|
|
|
|
|
|
|
|
if (dev->has_irq) {
|
|
|
|
monitor_printf(mon, " IRQ %" PRId64 ".\n", dev->irq);
|
|
|
|
}
|
|
|
|
|
|
|
|
if (dev->has_pci_bridge) {
|
|
|
|
monitor_printf(mon, " BUS %" PRId64 ".\n",
|
|
|
|
dev->pci_bridge->bus.number);
|
|
|
|
monitor_printf(mon, " secondary bus %" PRId64 ".\n",
|
|
|
|
dev->pci_bridge->bus.secondary);
|
|
|
|
monitor_printf(mon, " subordinate bus %" PRId64 ".\n",
|
|
|
|
dev->pci_bridge->bus.subordinate);
|
|
|
|
|
|
|
|
monitor_printf(mon, " IO range [0x%04"PRIx64", 0x%04"PRIx64"]\n",
|
|
|
|
dev->pci_bridge->bus.io_range->base,
|
|
|
|
dev->pci_bridge->bus.io_range->limit);
|
|
|
|
|
|
|
|
monitor_printf(mon,
|
|
|
|
" memory range [0x%08"PRIx64", 0x%08"PRIx64"]\n",
|
|
|
|
dev->pci_bridge->bus.memory_range->base,
|
|
|
|
dev->pci_bridge->bus.memory_range->limit);
|
|
|
|
|
|
|
|
monitor_printf(mon, " prefetchable memory range "
|
|
|
|
"[0x%08"PRIx64", 0x%08"PRIx64"]\n",
|
|
|
|
dev->pci_bridge->bus.prefetchable_range->base,
|
|
|
|
dev->pci_bridge->bus.prefetchable_range->limit);
|
|
|
|
}
|
|
|
|
|
|
|
|
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);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2013-01-14 06:06:25 +00:00
|
|
|
void hmp_info_pci(Monitor *mon, const QDict *qdict)
|
2011-10-21 16:15:33 +00:00
|
|
|
{
|
2012-01-11 15:51:52 +00:00
|
|
|
PciInfoList *info_list, *info;
|
2011-10-21 16:15:33 +00:00
|
|
|
Error *err = NULL;
|
|
|
|
|
2012-01-11 15:51:52 +00:00
|
|
|
info_list = qmp_query_pci(&err);
|
2011-10-21 16:15:33 +00:00
|
|
|
if (err) {
|
|
|
|
monitor_printf(mon, "PCI devices not supported\n");
|
|
|
|
error_free(err);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2012-01-11 15:51:52 +00:00
|
|
|
for (info = info_list; info; info = info->next) {
|
2011-10-21 16:15:33 +00:00
|
|
|
PciDeviceInfoList *dev;
|
|
|
|
|
|
|
|
for (dev = info->value->devices; dev; dev = dev->next) {
|
|
|
|
hmp_info_pci_device(mon, dev->value);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2012-01-11 15:51:52 +00:00
|
|
|
qapi_free_PciInfoList(info_list);
|
2011-10-21 16:15:33 +00:00
|
|
|
}
|
|
|
|
|
2013-01-14 06:06:25 +00:00
|
|
|
void hmp_info_block_jobs(Monitor *mon, const QDict *qdict)
|
2012-01-18 14:40:49 +00:00
|
|
|
{
|
|
|
|
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;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
Support for TPM command line options
This patch adds support for TPM command line options.
The command line options supported here are
./qemu-... -tpmdev passthrough,path=<path to TPM device>,id=<id>
-device tpm-tis,tpmdev=<id>,id=<other id>
and
./qemu-... -tpmdev help
where the latter works similar to -soundhw help and shows a list of
available TPM backends (for example 'passthrough').
Using the type parameter, the backend is chosen, i.e., 'passthrough' for the
passthrough driver. The interpretation of the other parameters along
with determining whether enough parameters were provided is pushed into
the backend driver, which needs to implement the interface function
'create' and return a TPMDriverOpts structure if the VM can be started or
'NULL' if not enough or bad parameters were provided.
Monitor support for 'info tpm' has been added. It for example prints the
following:
(qemu) info tpm
TPM devices:
tpm0: model=tpm-tis
\ tpm0: type=passthrough,path=/dev/tpm0,cancel-path=/sys/devices/pnp0/00:09/cancel
Signed-off-by: Stefan Berger <stefanb@linux.vnet.ibm.com>
Reviewed-by: Corey Bryant <coreyb@linux.vnet.ibm.com>
Reviewed-by: Joel Schopp <jschopp@linux.vnet.ibm.com>
Message-id: 1361987275-26289-2-git-send-email-stefanb@linux.vnet.ibm.com
Signed-off-by: Anthony Liguori <aliguori@us.ibm.com>
2013-02-27 17:47:49 +00:00
|
|
|
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",
|
2013-03-20 16:34:48 +00:00
|
|
|
ti->id, TpmTypeOptionsKind_lookup[ti->options->kind]);
|
Support for TPM command line options
This patch adds support for TPM command line options.
The command line options supported here are
./qemu-... -tpmdev passthrough,path=<path to TPM device>,id=<id>
-device tpm-tis,tpmdev=<id>,id=<other id>
and
./qemu-... -tpmdev help
where the latter works similar to -soundhw help and shows a list of
available TPM backends (for example 'passthrough').
Using the type parameter, the backend is chosen, i.e., 'passthrough' for the
passthrough driver. The interpretation of the other parameters along
with determining whether enough parameters were provided is pushed into
the backend driver, which needs to implement the interface function
'create' and return a TPMDriverOpts structure if the VM can be started or
'NULL' if not enough or bad parameters were provided.
Monitor support for 'info tpm' has been added. It for example prints the
following:
(qemu) info tpm
TPM devices:
tpm0: model=tpm-tis
\ tpm0: type=passthrough,path=/dev/tpm0,cancel-path=/sys/devices/pnp0/00:09/cancel
Signed-off-by: Stefan Berger <stefanb@linux.vnet.ibm.com>
Reviewed-by: Corey Bryant <coreyb@linux.vnet.ibm.com>
Reviewed-by: Joel Schopp <jschopp@linux.vnet.ibm.com>
Message-id: 1361987275-26289-2-git-send-email-stefanb@linux.vnet.ibm.com
Signed-off-by: Anthony Liguori <aliguori@us.ibm.com>
2013-02-27 17:47:49 +00:00
|
|
|
|
2013-03-20 16:34:48 +00:00
|
|
|
switch (ti->options->kind) {
|
|
|
|
case TPM_TYPE_OPTIONS_KIND_PASSTHROUGH:
|
|
|
|
tpo = ti->options->passthrough;
|
Support for TPM command line options
This patch adds support for TPM command line options.
The command line options supported here are
./qemu-... -tpmdev passthrough,path=<path to TPM device>,id=<id>
-device tpm-tis,tpmdev=<id>,id=<other id>
and
./qemu-... -tpmdev help
where the latter works similar to -soundhw help and shows a list of
available TPM backends (for example 'passthrough').
Using the type parameter, the backend is chosen, i.e., 'passthrough' for the
passthrough driver. The interpretation of the other parameters along
with determining whether enough parameters were provided is pushed into
the backend driver, which needs to implement the interface function
'create' and return a TPMDriverOpts structure if the VM can be started or
'NULL' if not enough or bad parameters were provided.
Monitor support for 'info tpm' has been added. It for example prints the
following:
(qemu) info tpm
TPM devices:
tpm0: model=tpm-tis
\ tpm0: type=passthrough,path=/dev/tpm0,cancel-path=/sys/devices/pnp0/00:09/cancel
Signed-off-by: Stefan Berger <stefanb@linux.vnet.ibm.com>
Reviewed-by: Corey Bryant <coreyb@linux.vnet.ibm.com>
Reviewed-by: Joel Schopp <jschopp@linux.vnet.ibm.com>
Message-id: 1361987275-26289-2-git-send-email-stefanb@linux.vnet.ibm.com
Signed-off-by: Anthony Liguori <aliguori@us.ibm.com>
2013-02-27 17:47:49 +00:00
|
|
|
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;
|
|
|
|
case TPM_TYPE_OPTIONS_KIND_MAX:
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
monitor_printf(mon, "\n");
|
|
|
|
c++;
|
|
|
|
}
|
|
|
|
qapi_free_TPMInfoList(info_list);
|
|
|
|
}
|
|
|
|
|
2011-09-15 17:20:28 +00:00
|
|
|
void hmp_quit(Monitor *mon, const QDict *qdict)
|
|
|
|
{
|
|
|
|
monitor_suspend(mon);
|
|
|
|
qmp_quit(NULL);
|
|
|
|
}
|
2011-09-15 17:34:39 +00:00
|
|
|
|
|
|
|
void hmp_stop(Monitor *mon, const QDict *qdict)
|
|
|
|
{
|
|
|
|
qmp_stop(NULL);
|
|
|
|
}
|
2011-09-15 17:41:46 +00:00
|
|
|
|
|
|
|
void hmp_system_reset(Monitor *mon, const QDict *qdict)
|
|
|
|
{
|
|
|
|
qmp_system_reset(NULL);
|
|
|
|
}
|
2011-09-28 14:06:15 +00:00
|
|
|
|
|
|
|
void hmp_system_powerdown(Monitor *mon, const QDict *qdict)
|
|
|
|
{
|
|
|
|
qmp_system_powerdown(NULL);
|
|
|
|
}
|
2011-10-06 17:31:39 +00:00
|
|
|
|
|
|
|
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");
|
|
|
|
}
|
|
|
|
}
|
2011-11-22 18:32:37 +00:00
|
|
|
|
|
|
|
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");
|
|
|
|
Error *errp = NULL;
|
|
|
|
|
|
|
|
qmp_memsave(addr, size, filename, true, monitor_get_cpu_index(), &errp);
|
|
|
|
hmp_handle_error(mon, &errp);
|
|
|
|
}
|
2011-11-22 19:26:46 +00:00
|
|
|
|
|
|
|
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");
|
|
|
|
Error *errp = NULL;
|
|
|
|
|
|
|
|
qmp_pmemsave(addr, size, filename, &errp);
|
|
|
|
hmp_handle_error(mon, &errp);
|
2013-01-24 16:03:20 +00:00
|
|
|
}
|
|
|
|
|
qemu-char: Saner naming of memchar stuff & doc fixes
New device, has never been released, so we can still improve things
without worrying about compatibility.
Naming is a mess. The code calls the device driver CirMemCharDriver,
the public API calls it "memory", "memchardev", or "memchar", and the
special commands are named like "memchar-FOO". "memory" is a
particularly unfortunate choice, because there's another character
device driver called MemoryDriver. Moreover, the device's distinctive
property is that it's a ring buffer, not that's in memory. Therefore:
* Rename CirMemCharDriver to RingBufCharDriver, and call the thing a
"ringbuf" in the API.
* Rename QMP and HMP commands from memchar-FOO to ringbuf-FOO.
* Rename device parameter from maxcapacity to size (simple words are
good for you).
* Clearly mark the parameter as optional in documentation.
* Fix error reporting so that chardev-add reports to current monitor,
not stderr.
* Replace cirmem in C identifiers by ringbuf.
* Rework documentation. Document the impact of our crappy UTF-8
handling on reading.
* QMP examples that even work.
I could split this up into multiple commits, but they'd change the
same documentation lines multiple times. Not worth it.
Signed-off-by: Markus Armbruster <armbru@redhat.com>
Reviewed-by: Eric Blake <eblake@redhat.com>
Signed-off-by: Anthony Liguori <aliguori@us.ibm.com>
2013-02-06 20:27:24 +00:00
|
|
|
void hmp_ringbuf_write(Monitor *mon, const QDict *qdict)
|
2013-01-24 16:03:20 +00:00
|
|
|
{
|
|
|
|
const char *chardev = qdict_get_str(qdict, "device");
|
|
|
|
const char *data = qdict_get_str(qdict, "data");
|
|
|
|
Error *errp = NULL;
|
|
|
|
|
qemu-char: Saner naming of memchar stuff & doc fixes
New device, has never been released, so we can still improve things
without worrying about compatibility.
Naming is a mess. The code calls the device driver CirMemCharDriver,
the public API calls it "memory", "memchardev", or "memchar", and the
special commands are named like "memchar-FOO". "memory" is a
particularly unfortunate choice, because there's another character
device driver called MemoryDriver. Moreover, the device's distinctive
property is that it's a ring buffer, not that's in memory. Therefore:
* Rename CirMemCharDriver to RingBufCharDriver, and call the thing a
"ringbuf" in the API.
* Rename QMP and HMP commands from memchar-FOO to ringbuf-FOO.
* Rename device parameter from maxcapacity to size (simple words are
good for you).
* Clearly mark the parameter as optional in documentation.
* Fix error reporting so that chardev-add reports to current monitor,
not stderr.
* Replace cirmem in C identifiers by ringbuf.
* Rework documentation. Document the impact of our crappy UTF-8
handling on reading.
* QMP examples that even work.
I could split this up into multiple commits, but they'd change the
same documentation lines multiple times. Not worth it.
Signed-off-by: Markus Armbruster <armbru@redhat.com>
Reviewed-by: Eric Blake <eblake@redhat.com>
Signed-off-by: Anthony Liguori <aliguori@us.ibm.com>
2013-02-06 20:27:24 +00:00
|
|
|
qmp_ringbuf_write(chardev, data, false, 0, &errp);
|
2013-01-24 16:03:20 +00:00
|
|
|
|
|
|
|
hmp_handle_error(mon, &errp);
|
2011-11-22 19:26:46 +00:00
|
|
|
}
|
2011-11-22 19:58:31 +00:00
|
|
|
|
qemu-char: Saner naming of memchar stuff & doc fixes
New device, has never been released, so we can still improve things
without worrying about compatibility.
Naming is a mess. The code calls the device driver CirMemCharDriver,
the public API calls it "memory", "memchardev", or "memchar", and the
special commands are named like "memchar-FOO". "memory" is a
particularly unfortunate choice, because there's another character
device driver called MemoryDriver. Moreover, the device's distinctive
property is that it's a ring buffer, not that's in memory. Therefore:
* Rename CirMemCharDriver to RingBufCharDriver, and call the thing a
"ringbuf" in the API.
* Rename QMP and HMP commands from memchar-FOO to ringbuf-FOO.
* Rename device parameter from maxcapacity to size (simple words are
good for you).
* Clearly mark the parameter as optional in documentation.
* Fix error reporting so that chardev-add reports to current monitor,
not stderr.
* Replace cirmem in C identifiers by ringbuf.
* Rework documentation. Document the impact of our crappy UTF-8
handling on reading.
* QMP examples that even work.
I could split this up into multiple commits, but they'd change the
same documentation lines multiple times. Not worth it.
Signed-off-by: Markus Armbruster <armbru@redhat.com>
Reviewed-by: Eric Blake <eblake@redhat.com>
Signed-off-by: Anthony Liguori <aliguori@us.ibm.com>
2013-02-06 20:27:24 +00:00
|
|
|
void hmp_ringbuf_read(Monitor *mon, const QDict *qdict)
|
2013-01-24 16:03:21 +00:00
|
|
|
{
|
|
|
|
uint32_t size = qdict_get_int(qdict, "size");
|
|
|
|
const char *chardev = qdict_get_str(qdict, "device");
|
2013-02-06 20:27:15 +00:00
|
|
|
char *data;
|
2013-01-24 16:03:21 +00:00
|
|
|
Error *errp = NULL;
|
2013-02-06 20:27:26 +00:00
|
|
|
int i;
|
2013-01-24 16:03:21 +00:00
|
|
|
|
qemu-char: Saner naming of memchar stuff & doc fixes
New device, has never been released, so we can still improve things
without worrying about compatibility.
Naming is a mess. The code calls the device driver CirMemCharDriver,
the public API calls it "memory", "memchardev", or "memchar", and the
special commands are named like "memchar-FOO". "memory" is a
particularly unfortunate choice, because there's another character
device driver called MemoryDriver. Moreover, the device's distinctive
property is that it's a ring buffer, not that's in memory. Therefore:
* Rename CirMemCharDriver to RingBufCharDriver, and call the thing a
"ringbuf" in the API.
* Rename QMP and HMP commands from memchar-FOO to ringbuf-FOO.
* Rename device parameter from maxcapacity to size (simple words are
good for you).
* Clearly mark the parameter as optional in documentation.
* Fix error reporting so that chardev-add reports to current monitor,
not stderr.
* Replace cirmem in C identifiers by ringbuf.
* Rework documentation. Document the impact of our crappy UTF-8
handling on reading.
* QMP examples that even work.
I could split this up into multiple commits, but they'd change the
same documentation lines multiple times. Not worth it.
Signed-off-by: Markus Armbruster <armbru@redhat.com>
Reviewed-by: Eric Blake <eblake@redhat.com>
Signed-off-by: Anthony Liguori <aliguori@us.ibm.com>
2013-02-06 20:27:24 +00:00
|
|
|
data = qmp_ringbuf_read(chardev, size, false, 0, &errp);
|
2013-01-24 16:03:21 +00:00
|
|
|
if (errp) {
|
|
|
|
monitor_printf(mon, "%s\n", error_get_pretty(errp));
|
|
|
|
error_free(errp);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2013-02-06 20:27:26 +00:00
|
|
|
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");
|
2013-02-06 20:27:15 +00:00
|
|
|
g_free(data);
|
2013-01-24 16:03:21 +00:00
|
|
|
}
|
|
|
|
|
2011-11-22 19:58:31 +00:00
|
|
|
static void hmp_cont_cb(void *opaque, int err)
|
|
|
|
{
|
|
|
|
if (!err) {
|
2012-07-26 23:41:53 +00:00
|
|
|
qmp_cont(NULL);
|
2011-11-22 19:58:31 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2012-07-26 23:41:53 +00:00
|
|
|
static bool key_is_missing(const BlockInfo *bdev)
|
|
|
|
{
|
|
|
|
return (bdev->inserted && bdev->inserted->encryption_key_missing);
|
|
|
|
}
|
|
|
|
|
2011-11-22 19:58:31 +00:00
|
|
|
void hmp_cont(Monitor *mon, const QDict *qdict)
|
|
|
|
{
|
2012-07-26 23:41:53 +00:00
|
|
|
BlockInfoList *bdev_list, *bdev;
|
2011-11-22 19:58:31 +00:00
|
|
|
Error *errp = NULL;
|
|
|
|
|
2012-07-26 23:41:53 +00:00
|
|
|
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;
|
2011-11-22 19:58:31 +00:00
|
|
|
}
|
|
|
|
}
|
2012-07-26 23:41:53 +00:00
|
|
|
|
|
|
|
qmp_cont(&errp);
|
|
|
|
hmp_handle_error(mon, &errp);
|
|
|
|
|
|
|
|
out:
|
|
|
|
qapi_free_BlockInfoList(bdev_list);
|
2011-11-22 19:58:31 +00:00
|
|
|
}
|
2011-11-23 14:55:53 +00:00
|
|
|
|
2012-02-23 12:45:21 +00:00
|
|
|
void hmp_system_wakeup(Monitor *mon, const QDict *qdict)
|
|
|
|
{
|
|
|
|
qmp_system_wakeup(NULL);
|
|
|
|
}
|
|
|
|
|
2011-11-23 14:55:53 +00:00
|
|
|
void hmp_inject_nmi(Monitor *mon, const QDict *qdict)
|
|
|
|
{
|
|
|
|
Error *errp = NULL;
|
|
|
|
|
|
|
|
qmp_inject_nmi(&errp);
|
|
|
|
hmp_handle_error(mon, &errp);
|
|
|
|
}
|
2011-11-23 15:11:55 +00:00
|
|
|
|
|
|
|
void hmp_set_link(Monitor *mon, const QDict *qdict)
|
|
|
|
{
|
|
|
|
const char *name = qdict_get_str(qdict, "name");
|
|
|
|
int up = qdict_get_bool(qdict, "up");
|
|
|
|
Error *errp = NULL;
|
|
|
|
|
|
|
|
qmp_set_link(name, up, &errp);
|
|
|
|
hmp_handle_error(mon, &errp);
|
|
|
|
}
|
2011-11-23 15:28:21 +00:00
|
|
|
|
|
|
|
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");
|
|
|
|
Error *errp = NULL;
|
|
|
|
|
|
|
|
qmp_block_passwd(device, password, &errp);
|
|
|
|
hmp_handle_error(mon, &errp);
|
|
|
|
}
|
2011-11-25 16:38:09 +00:00
|
|
|
|
|
|
|
void hmp_balloon(Monitor *mon, const QDict *qdict)
|
|
|
|
{
|
|
|
|
int64_t value = qdict_get_int(qdict, "value");
|
|
|
|
Error *errp = NULL;
|
|
|
|
|
|
|
|
qmp_balloon(value, &errp);
|
|
|
|
if (error_is_set(&errp)) {
|
|
|
|
monitor_printf(mon, "balloon: %s\n", error_get_pretty(errp));
|
|
|
|
error_free(errp);
|
|
|
|
}
|
|
|
|
}
|
2011-11-25 16:57:10 +00:00
|
|
|
|
|
|
|
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");
|
|
|
|
Error *errp = NULL;
|
|
|
|
|
|
|
|
qmp_block_resize(device, size, &errp);
|
|
|
|
hmp_handle_error(mon, &errp);
|
|
|
|
}
|
2011-11-25 18:15:19 +00:00
|
|
|
|
2012-10-18 14:49:24 +00:00
|
|
|
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");
|
|
|
|
int reuse = qdict_get_try_bool(qdict, "reuse", 0);
|
|
|
|
int full = qdict_get_try_bool(qdict, "full", 0);
|
|
|
|
enum NewImageMode mode;
|
|
|
|
Error *errp = NULL;
|
|
|
|
|
|
|
|
if (!filename) {
|
|
|
|
error_set(&errp, QERR_MISSING_PARAMETER, "target");
|
|
|
|
hmp_handle_error(mon, &errp);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (reuse) {
|
|
|
|
mode = NEW_IMAGE_MODE_EXISTING;
|
|
|
|
} else {
|
|
|
|
mode = NEW_IMAGE_MODE_ABSOLUTE_PATHS;
|
|
|
|
}
|
|
|
|
|
|
|
|
qmp_drive_mirror(device, filename, !!format, format,
|
|
|
|
full ? MIRROR_SYNC_MODE_FULL : MIRROR_SYNC_MODE_TOP,
|
2013-01-22 08:03:13 +00:00
|
|
|
true, mode, false, 0, false, 0, false, 0,
|
2012-10-18 14:49:28 +00:00
|
|
|
false, 0, false, 0, &errp);
|
2012-10-18 14:49:24 +00:00
|
|
|
hmp_handle_error(mon, &errp);
|
|
|
|
}
|
|
|
|
|
2013-06-26 12:11:58 +00:00
|
|
|
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");
|
|
|
|
int reuse = qdict_get_try_bool(qdict, "reuse", 0);
|
|
|
|
int full = qdict_get_try_bool(qdict, "full", 0);
|
|
|
|
enum NewImageMode mode;
|
|
|
|
Error *errp = NULL;
|
|
|
|
|
|
|
|
if (!filename) {
|
|
|
|
error_set(&errp, QERR_MISSING_PARAMETER, "target");
|
|
|
|
hmp_handle_error(mon, &errp);
|
|
|
|
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,
|
|
|
|
true, mode, false, 0, false, 0, false, 0, &errp);
|
|
|
|
hmp_handle_error(mon, &errp);
|
|
|
|
}
|
|
|
|
|
2011-11-25 18:15:19 +00:00
|
|
|
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");
|
2012-03-06 17:55:59 +00:00
|
|
|
int reuse = qdict_get_try_bool(qdict, "reuse", 0);
|
|
|
|
enum NewImageMode mode;
|
2011-11-25 18:15:19 +00:00
|
|
|
Error *errp = NULL;
|
|
|
|
|
|
|
|
if (!filename) {
|
|
|
|
/* In the future, if 'snapshot-file' is not specified, the snapshot
|
|
|
|
will be taken internally. Today it's actually required. */
|
|
|
|
error_set(&errp, QERR_MISSING_PARAMETER, "snapshot-file");
|
|
|
|
hmp_handle_error(mon, &errp);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2012-03-06 17:55:59 +00:00
|
|
|
mode = reuse ? NEW_IMAGE_MODE_EXISTING : NEW_IMAGE_MODE_ABSOLUTE_PATHS;
|
|
|
|
qmp_blockdev_snapshot_sync(device, filename, !!format, format,
|
|
|
|
true, mode, &errp);
|
2011-11-25 18:15:19 +00:00
|
|
|
hmp_handle_error(mon, &errp);
|
|
|
|
}
|
2011-11-28 00:54:09 +00:00
|
|
|
|
|
|
|
void hmp_migrate_cancel(Monitor *mon, const QDict *qdict)
|
|
|
|
{
|
|
|
|
qmp_migrate_cancel(NULL);
|
|
|
|
}
|
2011-11-28 01:18:01 +00:00
|
|
|
|
|
|
|
void hmp_migrate_set_downtime(Monitor *mon, const QDict *qdict)
|
|
|
|
{
|
|
|
|
double value = qdict_get_double(qdict, "value");
|
|
|
|
qmp_migrate_set_downtime(value, NULL);
|
|
|
|
}
|
2011-11-28 13:59:37 +00:00
|
|
|
|
2012-08-06 18:42:54 +00:00
|
|
|
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) {
|
|
|
|
monitor_printf(mon, "%s\n", error_get_pretty(err));
|
|
|
|
error_free(err);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2011-11-28 13:59:37 +00:00
|
|
|
void hmp_migrate_set_speed(Monitor *mon, const QDict *qdict)
|
|
|
|
{
|
|
|
|
int64_t value = qdict_get_int(qdict, "value");
|
|
|
|
qmp_migrate_set_speed(value, NULL);
|
|
|
|
}
|
2011-12-07 13:17:51 +00:00
|
|
|
|
2012-08-06 18:42:48 +00:00
|
|
|
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;
|
|
|
|
|
|
|
|
for (i = 0; i < MIGRATION_CAPABILITY_MAX; i++) {
|
|
|
|
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;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if (i == MIGRATION_CAPABILITY_MAX) {
|
|
|
|
error_set(&err, QERR_INVALID_PARAMETER, cap);
|
|
|
|
}
|
|
|
|
|
|
|
|
qapi_free_MigrationCapabilityStatusList(caps);
|
|
|
|
|
|
|
|
if (err) {
|
2013-01-31 07:12:19 +00:00
|
|
|
monitor_printf(mon, "migrate_set_capability: %s\n",
|
2012-08-06 18:42:48 +00:00
|
|
|
error_get_pretty(err));
|
|
|
|
error_free(err);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2011-12-07 13:17:51 +00:00
|
|
|
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);
|
|
|
|
}
|
2011-12-07 13:47:57 +00:00
|
|
|
|
|
|
|
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);
|
|
|
|
}
|
2011-12-07 18:02:36 +00:00
|
|
|
|
|
|
|
void hmp_eject(Monitor *mon, const QDict *qdict)
|
|
|
|
{
|
|
|
|
int force = qdict_get_try_bool(qdict, "force", 0);
|
|
|
|
const char *device = qdict_get_str(qdict, "device");
|
|
|
|
Error *err = NULL;
|
|
|
|
|
|
|
|
qmp_eject(device, true, force, &err);
|
|
|
|
hmp_handle_error(mon, &err);
|
|
|
|
}
|
2011-12-08 13:13:50 +00:00
|
|
|
|
|
|
|
static void hmp_change_read_arg(Monitor *mon, const char *password,
|
|
|
|
void *opaque)
|
|
|
|
{
|
|
|
|
qmp_change_vnc_password(password, NULL);
|
|
|
|
monitor_read_command(mon, 1);
|
|
|
|
}
|
|
|
|
|
|
|
|
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");
|
|
|
|
Error *err = NULL;
|
|
|
|
|
|
|
|
if (strcmp(device, "vnc") == 0 &&
|
|
|
|
(strcmp(target, "passwd") == 0 ||
|
|
|
|
strcmp(target, "password") == 0)) {
|
|
|
|
if (!arg) {
|
|
|
|
monitor_read_password(mon, hmp_change_read_arg, NULL);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
qmp_change(device, target, !!arg, arg, &err);
|
2012-08-06 18:55:22 +00:00
|
|
|
if (error_is_set(&err) &&
|
|
|
|
error_get_class(err) == ERROR_CLASS_DEVICE_ENCRYPTED) {
|
2012-08-06 18:49:34 +00:00
|
|
|
error_free(err);
|
|
|
|
monitor_read_block_device_key(mon, device, NULL, NULL);
|
2011-12-08 13:13:50 +00:00
|
|
|
return;
|
|
|
|
}
|
|
|
|
hmp_handle_error(mon, &err);
|
|
|
|
}
|
2011-12-14 18:49:14 +00:00
|
|
|
|
|
|
|
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"),
|
|
|
|
qdict_get_int(qdict, "iops_wr"), &err);
|
|
|
|
hmp_handle_error(mon, &err);
|
|
|
|
}
|
2012-01-18 14:40:46 +00:00
|
|
|
|
|
|
|
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");
|
2012-04-25 15:51:03 +00:00
|
|
|
int64_t speed = qdict_get_try_int(qdict, "speed", 0);
|
2012-01-18 14:40:46 +00:00
|
|
|
|
2012-04-25 15:51:03 +00:00
|
|
|
qmp_block_stream(device, base != NULL, base,
|
2012-09-28 15:22:59 +00:00
|
|
|
qdict_haskey(qdict, "speed"), speed,
|
|
|
|
BLOCKDEV_ON_ERROR_REPORT, true, &error);
|
2012-01-18 14:40:46 +00:00
|
|
|
|
|
|
|
hmp_handle_error(mon, &error);
|
|
|
|
}
|
2012-01-18 14:40:47 +00:00
|
|
|
|
|
|
|
void hmp_block_job_set_speed(Monitor *mon, const QDict *qdict)
|
|
|
|
{
|
|
|
|
Error *error = NULL;
|
|
|
|
const char *device = qdict_get_str(qdict, "device");
|
2012-05-08 14:51:56 +00:00
|
|
|
int64_t value = qdict_get_int(qdict, "speed");
|
2012-01-18 14:40:47 +00:00
|
|
|
|
|
|
|
qmp_block_job_set_speed(device, value, &error);
|
|
|
|
|
|
|
|
hmp_handle_error(mon, &error);
|
|
|
|
}
|
2012-01-18 14:40:48 +00:00
|
|
|
|
|
|
|
void hmp_block_job_cancel(Monitor *mon, const QDict *qdict)
|
|
|
|
{
|
|
|
|
Error *error = NULL;
|
|
|
|
const char *device = qdict_get_str(qdict, "device");
|
2012-09-28 15:22:51 +00:00
|
|
|
bool force = qdict_get_try_bool(qdict, "force", 0);
|
2012-01-18 14:40:48 +00:00
|
|
|
|
2012-09-28 15:22:51 +00:00
|
|
|
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);
|
2012-01-18 14:40:48 +00:00
|
|
|
|
|
|
|
hmp_handle_error(mon, &error);
|
|
|
|
}
|
2011-12-05 16:48:01 +00:00
|
|
|
|
2012-10-18 14:49:21 +00:00
|
|
|
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);
|
|
|
|
}
|
|
|
|
|
2011-12-05 16:48:01 +00:00
|
|
|
typedef struct MigrationStatus
|
|
|
|
{
|
|
|
|
QEMUTimer *timer;
|
|
|
|
Monitor *mon;
|
|
|
|
bool is_block_migration;
|
|
|
|
} MigrationStatus;
|
|
|
|
|
|
|
|
static void hmp_migrate_status_cb(void *opaque)
|
|
|
|
{
|
|
|
|
MigrationStatus *status = opaque;
|
|
|
|
MigrationInfo *info;
|
|
|
|
|
|
|
|
info = qmp_query_migrate(NULL);
|
|
|
|
if (!info->has_status || strcmp(info->status, "active") == 0) {
|
|
|
|
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);
|
|
|
|
}
|
|
|
|
|
|
|
|
qemu_mod_timer(status->timer, qemu_get_clock_ms(rt_clock) + 1000);
|
|
|
|
} else {
|
|
|
|
if (status->is_block_migration) {
|
|
|
|
monitor_printf(status->mon, "\n");
|
|
|
|
}
|
|
|
|
monitor_resume(status->mon);
|
|
|
|
qemu_del_timer(status->timer);
|
|
|
|
g_free(status);
|
|
|
|
}
|
|
|
|
|
|
|
|
qapi_free_MigrationInfo(info);
|
|
|
|
}
|
|
|
|
|
|
|
|
void hmp_migrate(Monitor *mon, const QDict *qdict)
|
|
|
|
{
|
|
|
|
int detach = qdict_get_try_bool(qdict, "detach", 0);
|
|
|
|
int blk = qdict_get_try_bool(qdict, "blk", 0);
|
|
|
|
int inc = qdict_get_try_bool(qdict, "inc", 0);
|
|
|
|
const char *uri = qdict_get_str(qdict, "uri");
|
|
|
|
Error *err = NULL;
|
|
|
|
|
|
|
|
qmp_migrate(uri, !!blk, blk, !!inc, inc, false, false, &err);
|
|
|
|
if (err) {
|
|
|
|
monitor_printf(mon, "migrate: %s\n", error_get_pretty(err));
|
|
|
|
error_free(err);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (!detach) {
|
|
|
|
MigrationStatus *status;
|
|
|
|
|
|
|
|
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;
|
|
|
|
status->timer = qemu_new_timer_ms(rt_clock, hmp_migrate_status_cb,
|
|
|
|
status);
|
|
|
|
qemu_mod_timer(status->timer, qemu_get_clock_ms(rt_clock));
|
|
|
|
}
|
|
|
|
}
|
2012-03-29 15:38:50 +00:00
|
|
|
|
|
|
|
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);
|
|
|
|
}
|
2012-05-07 04:10:47 +00:00
|
|
|
|
|
|
|
void hmp_dump_guest_memory(Monitor *mon, const QDict *qdict)
|
|
|
|
{
|
|
|
|
Error *errp = NULL;
|
|
|
|
int paging = qdict_get_try_bool(qdict, "paging", 0);
|
2012-09-21 16:53:00 +00:00
|
|
|
const char *file = qdict_get_str(qdict, "filename");
|
2012-05-07 04:10:47 +00:00
|
|
|
bool has_begin = qdict_haskey(qdict, "begin");
|
|
|
|
bool has_length = qdict_haskey(qdict, "length");
|
|
|
|
int64_t begin = 0;
|
|
|
|
int64_t length = 0;
|
2012-09-21 16:53:00 +00:00
|
|
|
char *prot;
|
2012-05-07 04:10:47 +00:00
|
|
|
|
|
|
|
if (has_begin) {
|
|
|
|
begin = qdict_get_int(qdict, "begin");
|
|
|
|
}
|
|
|
|
if (has_length) {
|
|
|
|
length = qdict_get_int(qdict, "length");
|
|
|
|
}
|
|
|
|
|
2012-09-21 16:53:00 +00:00
|
|
|
prot = g_strconcat("file:", file, NULL);
|
|
|
|
|
|
|
|
qmp_dump_guest_memory(paging, prot, has_begin, begin, has_length, length,
|
2012-05-07 04:10:47 +00:00
|
|
|
&errp);
|
|
|
|
hmp_handle_error(mon, &errp);
|
2012-09-21 16:53:00 +00:00
|
|
|
g_free(prot);
|
2012-05-07 04:10:47 +00:00
|
|
|
}
|
2012-04-18 20:34:15 +00:00
|
|
|
|
|
|
|
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);
|
|
|
|
if (error_is_set(&err)) {
|
|
|
|
goto out;
|
|
|
|
}
|
|
|
|
|
|
|
|
netdev_add(opts, &err);
|
|
|
|
if (error_is_set(&err)) {
|
|
|
|
qemu_opts_del(opts);
|
|
|
|
}
|
|
|
|
|
|
|
|
out:
|
|
|
|
hmp_handle_error(mon, &err);
|
|
|
|
}
|
2012-04-16 17:36:32 +00:00
|
|
|
|
|
|
|
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);
|
|
|
|
}
|
2012-06-22 18:36:09 +00:00
|
|
|
|
|
|
|
void hmp_getfd(Monitor *mon, const QDict *qdict)
|
|
|
|
{
|
|
|
|
const char *fdname = qdict_get_str(qdict, "fdname");
|
|
|
|
Error *errp = NULL;
|
|
|
|
|
|
|
|
qmp_getfd(fdname, &errp);
|
|
|
|
hmp_handle_error(mon, &errp);
|
|
|
|
}
|
|
|
|
|
|
|
|
void hmp_closefd(Monitor *mon, const QDict *qdict)
|
|
|
|
{
|
|
|
|
const char *fdname = qdict_get_str(qdict, "fdname");
|
|
|
|
Error *errp = NULL;
|
|
|
|
|
|
|
|
qmp_closefd(fdname, &errp);
|
|
|
|
hmp_handle_error(mon, &errp);
|
|
|
|
}
|
2012-08-31 02:56:26 +00:00
|
|
|
|
|
|
|
void hmp_send_key(Monitor *mon, const QDict *qdict)
|
|
|
|
{
|
|
|
|
const char *keys = qdict_get_str(qdict, "keys");
|
2012-09-20 17:19:47 +00:00
|
|
|
KeyValueList *keylist, *head = NULL, *tmp = NULL;
|
2012-08-31 02:56:26 +00:00
|
|
|
int has_hold_time = qdict_haskey(qdict, "hold-time");
|
|
|
|
int hold_time = qdict_get_try_int(qdict, "hold-time", -1);
|
|
|
|
Error *err = NULL;
|
|
|
|
char keyname_buf[16];
|
|
|
|
char *separator;
|
2012-09-20 17:19:47 +00:00
|
|
|
int keyname_len;
|
2012-08-31 02:56:26 +00:00
|
|
|
|
|
|
|
while (1) {
|
|
|
|
separator = strchr(keys, '-');
|
|
|
|
keyname_len = separator ? separator - keys : strlen(keys);
|
|
|
|
pstrcpy(keyname_buf, sizeof(keyname_buf), keys);
|
|
|
|
|
|
|
|
/* Be compatible with old interface, convert user inputted "<" */
|
|
|
|
if (!strncmp(keyname_buf, "<", 1) && keyname_len == 1) {
|
|
|
|
pstrcpy(keyname_buf, sizeof(keyname_buf), "less");
|
|
|
|
keyname_len = 4;
|
|
|
|
}
|
|
|
|
keyname_buf[keyname_len] = 0;
|
|
|
|
|
|
|
|
keylist = g_malloc0(sizeof(*keylist));
|
2012-09-20 17:19:47 +00:00
|
|
|
keylist->value = g_malloc0(sizeof(*keylist->value));
|
2012-08-31 02:56:26 +00:00
|
|
|
|
|
|
|
if (!head) {
|
|
|
|
head = keylist;
|
|
|
|
}
|
|
|
|
if (tmp) {
|
|
|
|
tmp->next = keylist;
|
|
|
|
}
|
|
|
|
tmp = keylist;
|
|
|
|
|
2012-09-20 17:19:47 +00:00
|
|
|
if (strstart(keyname_buf, "0x", NULL)) {
|
|
|
|
char *endp;
|
|
|
|
int value = strtoul(keyname_buf, &endp, 0);
|
|
|
|
if (*endp != '\0') {
|
|
|
|
goto err_out;
|
|
|
|
}
|
|
|
|
keylist->value->kind = KEY_VALUE_KIND_NUMBER;
|
|
|
|
keylist->value->number = value;
|
|
|
|
} else {
|
|
|
|
int idx = index_from_key(keyname_buf);
|
|
|
|
if (idx == Q_KEY_CODE_MAX) {
|
|
|
|
goto err_out;
|
|
|
|
}
|
|
|
|
keylist->value->kind = KEY_VALUE_KIND_QCODE;
|
|
|
|
keylist->value->qcode = idx;
|
|
|
|
}
|
|
|
|
|
2012-08-31 02:56:26 +00:00
|
|
|
if (!separator) {
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
keys = separator + 1;
|
|
|
|
}
|
|
|
|
|
2012-09-20 17:19:47 +00:00
|
|
|
qmp_send_key(head, has_hold_time, hold_time, &err);
|
2012-08-31 02:56:26 +00:00
|
|
|
hmp_handle_error(mon, &err);
|
2012-09-20 17:19:47 +00:00
|
|
|
|
|
|
|
out:
|
|
|
|
qapi_free_KeyValueList(head);
|
|
|
|
return;
|
|
|
|
|
|
|
|
err_out:
|
|
|
|
monitor_printf(mon, "invalid parameter: %s\n", keyname_buf);
|
|
|
|
goto out;
|
2012-08-31 02:56:26 +00:00
|
|
|
}
|
2012-05-24 16:48:23 +00:00
|
|
|
|
|
|
|
void hmp_screen_dump(Monitor *mon, const QDict *qdict)
|
|
|
|
{
|
|
|
|
const char *filename = qdict_get_str(qdict, "filename");
|
|
|
|
Error *err = NULL;
|
|
|
|
|
|
|
|
qmp_screendump(filename, &err);
|
|
|
|
hmp_handle_error(mon, &err);
|
|
|
|
}
|
2012-08-23 09:53:04 +00:00
|
|
|
|
|
|
|
void hmp_nbd_server_start(Monitor *mon, const QDict *qdict)
|
|
|
|
{
|
|
|
|
const char *uri = qdict_get_str(qdict, "uri");
|
|
|
|
int writable = qdict_get_try_bool(qdict, "writable", 0);
|
|
|
|
int all = qdict_get_try_bool(qdict, "all", 0);
|
|
|
|
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");
|
|
|
|
int writable = qdict_get_try_bool(qdict, "writable", 0);
|
|
|
|
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)
|
|
|
|
{
|
|
|
|
Error *errp = NULL;
|
|
|
|
|
|
|
|
qmp_nbd_server_stop(&errp);
|
|
|
|
hmp_handle_error(mon, &errp);
|
|
|
|
}
|
2012-12-19 09:33:40 +00:00
|
|
|
|
|
|
|
void hmp_chardev_add(Monitor *mon, const QDict *qdict)
|
|
|
|
{
|
|
|
|
const char *args = qdict_get_str(qdict, "args");
|
|
|
|
Error *err = NULL;
|
|
|
|
QemuOpts *opts;
|
|
|
|
|
|
|
|
opts = qemu_opts_parse(qemu_find_opts("chardev"), args, 1);
|
|
|
|
if (opts == NULL) {
|
error: Strip trailing '\n' from error string arguments (again)
Commit 6daf194d and be62a2eb got rid of a bunch, but they keep coming
back. Tracked down with this Coccinelle semantic patch:
@r@
expression err, eno, cls, fmt;
position p;
@@
(
error_report(fmt, ...)@p
|
error_set(err, cls, fmt, ...)@p
|
error_set_errno(err, eno, cls, fmt, ...)@p
|
error_setg(err, fmt, ...)@p
|
error_setg_errno(err, eno, fmt, ...)@p
)
@script:python@
fmt << r.fmt;
p << r.p;
@@
if "\\n" in str(fmt):
print "%s:%s:%s:%s" % (p[0].file, p[0].line, p[0].column, fmt)
Signed-off-by: Markus Armbruster <armbru@redhat.com>
Message-id: 1360354939-10994-4-git-send-email-armbru@redhat.com
Signed-off-by: Anthony Liguori <aliguori@us.ibm.com>
2013-02-08 20:22:16 +00:00
|
|
|
error_setg(&err, "Parsing chardev args failed");
|
2012-12-19 09:33:40 +00:00
|
|
|
} 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);
|
|
|
|
}
|
2013-06-05 12:19:41 +00:00
|
|
|
|
|
|
|
void hmp_qemu_io(Monitor *mon, const QDict *qdict)
|
|
|
|
{
|
|
|
|
BlockDriverState *bs;
|
|
|
|
const char* device = qdict_get_str(qdict, "device");
|
|
|
|
const char* command = qdict_get_str(qdict, "command");
|
|
|
|
Error *err = NULL;
|
|
|
|
|
|
|
|
bs = bdrv_find(device);
|
|
|
|
if (bs) {
|
|
|
|
qemuio_command(bs, command);
|
|
|
|
} else {
|
|
|
|
error_set(&err, QERR_DEVICE_NOT_FOUND, device);
|
|
|
|
}
|
|
|
|
|
|
|
|
hmp_handle_error(mon, &err);
|
|
|
|
}
|