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