]> Git Repo - qemu.git/blob - monitor.c
target-mips: Fix warning from Sparse
[qemu.git] / monitor.c
1 /*
2  * QEMU monitor
3  *
4  * Copyright (c) 2003-2004 Fabrice Bellard
5  *
6  * Permission is hereby granted, free of charge, to any person obtaining a copy
7  * of this software and associated documentation files (the "Software"), to deal
8  * in the Software without restriction, including without limitation the rights
9  * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
10  * copies of the Software, and to permit persons to whom the Software is
11  * furnished to do so, subject to the following conditions:
12  *
13  * The above copyright notice and this permission notice shall be included in
14  * all copies or substantial portions of the Software.
15  *
16  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
17  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
18  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
19  * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
20  * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
21  * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
22  * THE SOFTWARE.
23  */
24 #include <dirent.h>
25 #include "hw/hw.h"
26 #include "monitor/qdev.h"
27 #include "hw/usb.h"
28 #include "hw/i386/pc.h"
29 #include "hw/pci/pci.h"
30 #include "sysemu/watchdog.h"
31 #include "hw/loader.h"
32 #include "exec/gdbstub.h"
33 #include "net/net.h"
34 #include "net/slirp.h"
35 #include "sysemu/char.h"
36 #include "ui/qemu-spice.h"
37 #include "sysemu/sysemu.h"
38 #include "sysemu/numa.h"
39 #include "monitor/monitor.h"
40 #include "qemu/readline.h"
41 #include "ui/console.h"
42 #include "ui/input.h"
43 #include "sysemu/blockdev.h"
44 #include "audio/audio.h"
45 #include "disas/disas.h"
46 #include "sysemu/balloon.h"
47 #include "qemu/timer.h"
48 #include "migration/migration.h"
49 #include "sysemu/kvm.h"
50 #include "qemu/acl.h"
51 #include "sysemu/tpm.h"
52 #include "qapi/qmp/qint.h"
53 #include "qapi/qmp/qfloat.h"
54 #include "qapi/qmp/qlist.h"
55 #include "qapi/qmp/qbool.h"
56 #include "qapi/qmp/qstring.h"
57 #include "qapi/qmp/qjson.h"
58 #include "qapi/qmp/json-streamer.h"
59 #include "qapi/qmp/json-parser.h"
60 #include <qom/object_interfaces.h>
61 #include "qemu/osdep.h"
62 #include "cpu.h"
63 #include "trace.h"
64 #include "trace/control.h"
65 #ifdef CONFIG_TRACE_SIMPLE
66 #include "trace/simple.h"
67 #endif
68 #include "exec/memory.h"
69 #include "exec/cpu_ldst.h"
70 #include "qmp-commands.h"
71 #include "hmp.h"
72 #include "qemu/thread.h"
73 #include "block/qapi.h"
74 #include "qapi/qmp-event.h"
75 #include "qapi-event.h"
76 #include "sysemu/block-backend.h"
77
78 /* for hmp_info_irq/pic */
79 #if defined(TARGET_SPARC)
80 #include "hw/sparc/sun4m.h"
81 #endif
82 #include "hw/lm32/lm32_pic.h"
83
84 //#define DEBUG
85 //#define DEBUG_COMPLETION
86
87 /*
88  * Supported types:
89  *
90  * 'F'          filename
91  * 'B'          block device name
92  * 's'          string (accept optional quote)
93  * 'S'          it just appends the rest of the string (accept optional quote)
94  * 'O'          option string of the form NAME=VALUE,...
95  *              parsed according to QemuOptsList given by its name
96  *              Example: 'device:O' uses qemu_device_opts.
97  *              Restriction: only lists with empty desc are supported
98  *              TODO lift the restriction
99  * 'i'          32 bit integer
100  * 'l'          target long (32 or 64 bit)
101  * 'M'          Non-negative target long (32 or 64 bit), in user mode the
102  *              value is multiplied by 2^20 (think Mebibyte)
103  * 'o'          octets (aka bytes)
104  *              user mode accepts an optional E, e, P, p, T, t, G, g, M, m,
105  *              K, k suffix, which multiplies the value by 2^60 for suffixes E
106  *              and e, 2^50 for suffixes P and p, 2^40 for suffixes T and t,
107  *              2^30 for suffixes G and g, 2^20 for M and m, 2^10 for K and k
108  * 'T'          double
109  *              user mode accepts an optional ms, us, ns suffix,
110  *              which divides the value by 1e3, 1e6, 1e9, respectively
111  * '/'          optional gdb-like print format (like "/10x")
112  *
113  * '?'          optional type (for all types, except '/')
114  * '.'          other form of optional type (for 'i' and 'l')
115  * 'b'          boolean
116  *              user mode accepts "on" or "off"
117  * '-'          optional parameter (eg. '-f')
118  *
119  */
120
121 typedef struct MonitorCompletionData MonitorCompletionData;
122 struct MonitorCompletionData {
123     Monitor *mon;
124     void (*user_print)(Monitor *mon, const QObject *data);
125 };
126
127 typedef struct mon_cmd_t {
128     const char *name;
129     const char *args_type;
130     const char *params;
131     const char *help;
132     void (*user_print)(Monitor *mon, const QObject *data);
133     union {
134         void (*cmd)(Monitor *mon, const QDict *qdict);
135         int  (*cmd_new)(Monitor *mon, const QDict *params, QObject **ret_data);
136         int  (*cmd_async)(Monitor *mon, const QDict *params,
137                           MonitorCompletion *cb, void *opaque);
138     } mhandler;
139     int flags;
140     /* @sub_table is a list of 2nd level of commands. If it do not exist,
141      * mhandler should be used. If it exist, sub_table[?].mhandler should be
142      * used, and mhandler of 1st level plays the role of help function.
143      */
144     struct mon_cmd_t *sub_table;
145     void (*command_completion)(ReadLineState *rs, int nb_args, const char *str);
146 } mon_cmd_t;
147
148 /* file descriptors passed via SCM_RIGHTS */
149 typedef struct mon_fd_t mon_fd_t;
150 struct mon_fd_t {
151     char *name;
152     int fd;
153     QLIST_ENTRY(mon_fd_t) next;
154 };
155
156 /* file descriptor associated with a file descriptor set */
157 typedef struct MonFdsetFd MonFdsetFd;
158 struct MonFdsetFd {
159     int fd;
160     bool removed;
161     char *opaque;
162     QLIST_ENTRY(MonFdsetFd) next;
163 };
164
165 /* file descriptor set containing fds passed via SCM_RIGHTS */
166 typedef struct MonFdset MonFdset;
167 struct MonFdset {
168     int64_t id;
169     QLIST_HEAD(, MonFdsetFd) fds;
170     QLIST_HEAD(, MonFdsetFd) dup_fds;
171     QLIST_ENTRY(MonFdset) next;
172 };
173
174 typedef struct MonitorControl {
175     QObject *id;
176     JSONMessageParser parser;
177     int command_mode;
178 } MonitorControl;
179
180 /*
181  * To prevent flooding clients, events can be throttled. The
182  * throttling is calculated globally, rather than per-Monitor
183  * instance.
184  */
185 typedef struct MonitorQAPIEventState {
186     QAPIEvent event;    /* Event being tracked */
187     int64_t rate;       /* Minimum time (in ns) between two events */
188     int64_t last;       /* QEMU_CLOCK_REALTIME value at last emission */
189     QEMUTimer *timer;   /* Timer for handling delayed events */
190     QObject *data;      /* Event pending delayed dispatch */
191 } MonitorQAPIEventState;
192
193 struct Monitor {
194     CharDriverState *chr;
195     int reset_seen;
196     int flags;
197     int suspend_cnt;
198     bool skip_flush;
199
200     QemuMutex out_lock;
201     QString *outbuf;
202     guint out_watch;
203
204     /* Read under either BQL or out_lock, written with BQL+out_lock.  */
205     int mux_out;
206
207     ReadLineState *rs;
208     MonitorControl *mc;
209     CPUState *mon_cpu;
210     BlockCompletionFunc *password_completion_cb;
211     void *password_opaque;
212     mon_cmd_t *cmd_table;
213     QError *error;
214     QLIST_HEAD(,mon_fd_t) fds;
215     QLIST_ENTRY(Monitor) entry;
216 };
217
218 /* QMP checker flags */
219 #define QMP_ACCEPT_UNKNOWNS 1
220
221 /* Protects mon_list, monitor_event_state.  */
222 static QemuMutex monitor_lock;
223
224 static QLIST_HEAD(mon_list, Monitor) mon_list;
225 static QLIST_HEAD(mon_fdsets, MonFdset) mon_fdsets;
226 static int mon_refcount;
227
228 static mon_cmd_t mon_cmds[];
229 static mon_cmd_t info_cmds[];
230
231 static const mon_cmd_t qmp_cmds[];
232
233 Monitor *cur_mon;
234 Monitor *default_mon;
235
236 static void monitor_command_cb(void *opaque, const char *cmdline,
237                                void *readline_opaque);
238
239 static inline int qmp_cmd_mode(const Monitor *mon)
240 {
241     return (mon->mc ? mon->mc->command_mode : 0);
242 }
243
244 /* Return true if in control mode, false otherwise */
245 static inline int monitor_ctrl_mode(const Monitor *mon)
246 {
247     return (mon->flags & MONITOR_USE_CONTROL);
248 }
249
250 /* Return non-zero iff we have a current monitor, and it is in QMP mode.  */
251 int monitor_cur_is_qmp(void)
252 {
253     return cur_mon && monitor_ctrl_mode(cur_mon);
254 }
255
256 void monitor_read_command(Monitor *mon, int show_prompt)
257 {
258     if (!mon->rs)
259         return;
260
261     readline_start(mon->rs, "(qemu) ", 0, monitor_command_cb, NULL);
262     if (show_prompt)
263         readline_show_prompt(mon->rs);
264 }
265
266 int monitor_read_password(Monitor *mon, ReadLineFunc *readline_func,
267                           void *opaque)
268 {
269     if (monitor_ctrl_mode(mon)) {
270         qerror_report(QERR_MISSING_PARAMETER, "password");
271         return -EINVAL;
272     } else if (mon->rs) {
273         readline_start(mon->rs, "Password: ", 1, readline_func, opaque);
274         /* prompt is printed on return from the command handler */
275         return 0;
276     } else {
277         monitor_printf(mon, "terminal does not support password prompting\n");
278         return -ENOTTY;
279     }
280 }
281
282 static void monitor_flush_locked(Monitor *mon);
283
284 static gboolean monitor_unblocked(GIOChannel *chan, GIOCondition cond,
285                                   void *opaque)
286 {
287     Monitor *mon = opaque;
288
289     qemu_mutex_lock(&mon->out_lock);
290     mon->out_watch = 0;
291     monitor_flush_locked(mon);
292     qemu_mutex_unlock(&mon->out_lock);
293     return FALSE;
294 }
295
296 /* Called with mon->out_lock held.  */
297 static void monitor_flush_locked(Monitor *mon)
298 {
299     int rc;
300     size_t len;
301     const char *buf;
302
303     if (mon->skip_flush) {
304         return;
305     }
306
307     buf = qstring_get_str(mon->outbuf);
308     len = qstring_get_length(mon->outbuf);
309
310     if (len && !mon->mux_out) {
311         rc = qemu_chr_fe_write(mon->chr, (const uint8_t *) buf, len);
312         if ((rc < 0 && errno != EAGAIN) || (rc == len)) {
313             /* all flushed or error */
314             QDECREF(mon->outbuf);
315             mon->outbuf = qstring_new();
316             return;
317         }
318         if (rc > 0) {
319             /* partinal write */
320             QString *tmp = qstring_from_str(buf + rc);
321             QDECREF(mon->outbuf);
322             mon->outbuf = tmp;
323         }
324         if (mon->out_watch == 0) {
325             mon->out_watch = qemu_chr_fe_add_watch(mon->chr, G_IO_OUT|G_IO_HUP,
326                                                    monitor_unblocked, mon);
327         }
328     }
329 }
330
331 void monitor_flush(Monitor *mon)
332 {
333     qemu_mutex_lock(&mon->out_lock);
334     monitor_flush_locked(mon);
335     qemu_mutex_unlock(&mon->out_lock);
336 }
337
338 /* flush at every end of line */
339 static void monitor_puts(Monitor *mon, const char *str)
340 {
341     char c;
342
343     qemu_mutex_lock(&mon->out_lock);
344     for(;;) {
345         c = *str++;
346         if (c == '\0')
347             break;
348         if (c == '\n') {
349             qstring_append_chr(mon->outbuf, '\r');
350         }
351         qstring_append_chr(mon->outbuf, c);
352         if (c == '\n') {
353             monitor_flush_locked(mon);
354         }
355     }
356     qemu_mutex_unlock(&mon->out_lock);
357 }
358
359 void monitor_vprintf(Monitor *mon, const char *fmt, va_list ap)
360 {
361     char *buf;
362
363     if (!mon)
364         return;
365
366     if (monitor_ctrl_mode(mon)) {
367         return;
368     }
369
370     buf = g_strdup_vprintf(fmt, ap);
371     monitor_puts(mon, buf);
372     g_free(buf);
373 }
374
375 void monitor_printf(Monitor *mon, const char *fmt, ...)
376 {
377     va_list ap;
378     va_start(ap, fmt);
379     monitor_vprintf(mon, fmt, ap);
380     va_end(ap);
381 }
382
383 static int GCC_FMT_ATTR(2, 3) monitor_fprintf(FILE *stream,
384                                               const char *fmt, ...)
385 {
386     va_list ap;
387     va_start(ap, fmt);
388     monitor_vprintf((Monitor *)stream, fmt, ap);
389     va_end(ap);
390     return 0;
391 }
392
393 static void monitor_user_noop(Monitor *mon, const QObject *data) { }
394
395 static inline int handler_is_qobject(const mon_cmd_t *cmd)
396 {
397     return cmd->user_print != NULL;
398 }
399
400 static inline bool handler_is_async(const mon_cmd_t *cmd)
401 {
402     return cmd->flags & MONITOR_CMD_ASYNC;
403 }
404
405 static inline int monitor_has_error(const Monitor *mon)
406 {
407     return mon->error != NULL;
408 }
409
410 static void monitor_json_emitter(Monitor *mon, const QObject *data)
411 {
412     QString *json;
413
414     json = mon->flags & MONITOR_USE_PRETTY ? qobject_to_json_pretty(data) :
415                                              qobject_to_json(data);
416     assert(json != NULL);
417
418     qstring_append_chr(json, '\n');
419     monitor_puts(mon, qstring_get_str(json));
420
421     QDECREF(json);
422 }
423
424 static QDict *build_qmp_error_dict(const QError *err)
425 {
426     QObject *obj;
427
428     obj = qobject_from_jsonf("{ 'error': { 'class': %s, 'desc': %p } }",
429                              ErrorClass_lookup[err->err_class],
430                              qerror_human(err));
431
432     return qobject_to_qdict(obj);
433 }
434
435 static void monitor_protocol_emitter(Monitor *mon, QObject *data)
436 {
437     QDict *qmp;
438
439     trace_monitor_protocol_emitter(mon);
440
441     if (!monitor_has_error(mon)) {
442         /* success response */
443         qmp = qdict_new();
444         if (data) {
445             qobject_incref(data);
446             qdict_put_obj(qmp, "return", data);
447         } else {
448             /* return an empty QDict by default */
449             qdict_put(qmp, "return", qdict_new());
450         }
451     } else {
452         /* error response */
453         qmp = build_qmp_error_dict(mon->error);
454         QDECREF(mon->error);
455         mon->error = NULL;
456     }
457
458     if (mon->mc->id) {
459         qdict_put_obj(qmp, "id", mon->mc->id);
460         mon->mc->id = NULL;
461     }
462
463     monitor_json_emitter(mon, QOBJECT(qmp));
464     QDECREF(qmp);
465 }
466
467
468 static MonitorQAPIEventState monitor_qapi_event_state[QAPI_EVENT_MAX];
469
470 /*
471  * Emits the event to every monitor instance, @event is only used for trace
472  * Called with monitor_lock held.
473  */
474 static void monitor_qapi_event_emit(QAPIEvent event, QObject *data)
475 {
476     Monitor *mon;
477
478     trace_monitor_protocol_event_emit(event, data);
479     QLIST_FOREACH(mon, &mon_list, entry) {
480         if (monitor_ctrl_mode(mon) && qmp_cmd_mode(mon)) {
481             monitor_json_emitter(mon, data);
482         }
483     }
484 }
485
486 /*
487  * Queue a new event for emission to Monitor instances,
488  * applying any rate limiting if required.
489  */
490 static void
491 monitor_qapi_event_queue(QAPIEvent event, QDict *data, Error **errp)
492 {
493     MonitorQAPIEventState *evstate;
494     assert(event < QAPI_EVENT_MAX);
495     int64_t now = qemu_clock_get_ns(QEMU_CLOCK_REALTIME);
496
497     evstate = &(monitor_qapi_event_state[event]);
498     trace_monitor_protocol_event_queue(event,
499                                        data,
500                                        evstate->rate,
501                                        evstate->last,
502                                        now);
503
504     /* Rate limit of 0 indicates no throttling */
505     qemu_mutex_lock(&monitor_lock);
506     if (!evstate->rate) {
507         monitor_qapi_event_emit(event, QOBJECT(data));
508         evstate->last = now;
509     } else {
510         int64_t delta = now - evstate->last;
511         if (evstate->data ||
512             delta < evstate->rate) {
513             /* If there's an existing event pending, replace
514              * it with the new event, otherwise schedule a
515              * timer for delayed emission
516              */
517             if (evstate->data) {
518                 qobject_decref(evstate->data);
519             } else {
520                 int64_t then = evstate->last + evstate->rate;
521                 timer_mod_ns(evstate->timer, then);
522             }
523             evstate->data = QOBJECT(data);
524             qobject_incref(evstate->data);
525         } else {
526             monitor_qapi_event_emit(event, QOBJECT(data));
527             evstate->last = now;
528         }
529     }
530     qemu_mutex_unlock(&monitor_lock);
531 }
532
533 /*
534  * The callback invoked by QemuTimer when a delayed
535  * event is ready to be emitted
536  */
537 static void monitor_qapi_event_handler(void *opaque)
538 {
539     MonitorQAPIEventState *evstate = opaque;
540     int64_t now = qemu_clock_get_ns(QEMU_CLOCK_REALTIME);
541
542     trace_monitor_protocol_event_handler(evstate->event,
543                                          evstate->data,
544                                          evstate->last,
545                                          now);
546     qemu_mutex_lock(&monitor_lock);
547     if (evstate->data) {
548         monitor_qapi_event_emit(evstate->event, evstate->data);
549         qobject_decref(evstate->data);
550         evstate->data = NULL;
551     }
552     evstate->last = now;
553     qemu_mutex_unlock(&monitor_lock);
554 }
555
556 /*
557  * @event: the event ID to be limited
558  * @rate: the rate limit in milliseconds
559  *
560  * Sets a rate limit on a particular event, so no
561  * more than 1 event will be emitted within @rate
562  * milliseconds
563  */
564 static void
565 monitor_qapi_event_throttle(QAPIEvent event, int64_t rate)
566 {
567     MonitorQAPIEventState *evstate;
568     assert(event < QAPI_EVENT_MAX);
569
570     evstate = &(monitor_qapi_event_state[event]);
571
572     trace_monitor_protocol_event_throttle(event, rate);
573     evstate->event = event;
574     assert(rate * SCALE_MS <= INT64_MAX);
575     evstate->rate = rate * SCALE_MS;
576     evstate->last = 0;
577     evstate->data = NULL;
578     evstate->timer = timer_new(QEMU_CLOCK_REALTIME,
579                                SCALE_MS,
580                                monitor_qapi_event_handler,
581                                evstate);
582 }
583
584 static void monitor_qapi_event_init(void)
585 {
586     /* Limit guest-triggerable events to 1 per second */
587     monitor_qapi_event_throttle(QAPI_EVENT_RTC_CHANGE, 1000);
588     monitor_qapi_event_throttle(QAPI_EVENT_WATCHDOG, 1000);
589     monitor_qapi_event_throttle(QAPI_EVENT_BALLOON_CHANGE, 1000);
590     monitor_qapi_event_throttle(QAPI_EVENT_QUORUM_REPORT_BAD, 1000);
591     monitor_qapi_event_throttle(QAPI_EVENT_QUORUM_FAILURE, 1000);
592     monitor_qapi_event_throttle(QAPI_EVENT_VSERPORT_CHANGE, 1000);
593
594     qmp_event_set_func_emit(monitor_qapi_event_queue);
595 }
596
597 static int do_qmp_capabilities(Monitor *mon, const QDict *params,
598                                QObject **ret_data)
599 {
600     /* Will setup QMP capabilities in the future */
601     if (monitor_ctrl_mode(mon)) {
602         mon->mc->command_mode = 1;
603     }
604
605     return 0;
606 }
607
608 static void handle_user_command(Monitor *mon, const char *cmdline);
609
610 static void monitor_data_init(Monitor *mon)
611 {
612     memset(mon, 0, sizeof(Monitor));
613     qemu_mutex_init(&mon->out_lock);
614     mon->outbuf = qstring_new();
615     /* Use *mon_cmds by default. */
616     mon->cmd_table = mon_cmds;
617 }
618
619 static void monitor_data_destroy(Monitor *mon)
620 {
621     QDECREF(mon->outbuf);
622     qemu_mutex_destroy(&mon->out_lock);
623 }
624
625 char *qmp_human_monitor_command(const char *command_line, bool has_cpu_index,
626                                 int64_t cpu_index, Error **errp)
627 {
628     char *output = NULL;
629     Monitor *old_mon, hmp;
630
631     monitor_data_init(&hmp);
632     hmp.skip_flush = true;
633
634     old_mon = cur_mon;
635     cur_mon = &hmp;
636
637     if (has_cpu_index) {
638         int ret = monitor_set_cpu(cpu_index);
639         if (ret < 0) {
640             cur_mon = old_mon;
641             error_set(errp, QERR_INVALID_PARAMETER_VALUE, "cpu-index",
642                       "a CPU number");
643             goto out;
644         }
645     }
646
647     handle_user_command(&hmp, command_line);
648     cur_mon = old_mon;
649
650     qemu_mutex_lock(&hmp.out_lock);
651     if (qstring_get_length(hmp.outbuf) > 0) {
652         output = g_strdup(qstring_get_str(hmp.outbuf));
653     } else {
654         output = g_strdup("");
655     }
656     qemu_mutex_unlock(&hmp.out_lock);
657
658 out:
659     monitor_data_destroy(&hmp);
660     return output;
661 }
662
663 static int compare_cmd(const char *name, const char *list)
664 {
665     const char *p, *pstart;
666     int len;
667     len = strlen(name);
668     p = list;
669     for(;;) {
670         pstart = p;
671         p = strchr(p, '|');
672         if (!p)
673             p = pstart + strlen(pstart);
674         if ((p - pstart) == len && !memcmp(pstart, name, len))
675             return 1;
676         if (*p == '\0')
677             break;
678         p++;
679     }
680     return 0;
681 }
682
683 static int get_str(char *buf, int buf_size, const char **pp)
684 {
685     const char *p;
686     char *q;
687     int c;
688
689     q = buf;
690     p = *pp;
691     while (qemu_isspace(*p)) {
692         p++;
693     }
694     if (*p == '\0') {
695     fail:
696         *q = '\0';
697         *pp = p;
698         return -1;
699     }
700     if (*p == '\"') {
701         p++;
702         while (*p != '\0' && *p != '\"') {
703             if (*p == '\\') {
704                 p++;
705                 c = *p++;
706                 switch (c) {
707                 case 'n':
708                     c = '\n';
709                     break;
710                 case 'r':
711                     c = '\r';
712                     break;
713                 case '\\':
714                 case '\'':
715                 case '\"':
716                     break;
717                 default:
718                     qemu_printf("unsupported escape code: '\\%c'\n", c);
719                     goto fail;
720                 }
721                 if ((q - buf) < buf_size - 1) {
722                     *q++ = c;
723                 }
724             } else {
725                 if ((q - buf) < buf_size - 1) {
726                     *q++ = *p;
727                 }
728                 p++;
729             }
730         }
731         if (*p != '\"') {
732             qemu_printf("unterminated string\n");
733             goto fail;
734         }
735         p++;
736     } else {
737         while (*p != '\0' && !qemu_isspace(*p)) {
738             if ((q - buf) < buf_size - 1) {
739                 *q++ = *p;
740             }
741             p++;
742         }
743     }
744     *q = '\0';
745     *pp = p;
746     return 0;
747 }
748
749 #define MAX_ARGS 16
750
751 static void free_cmdline_args(char **args, int nb_args)
752 {
753     int i;
754
755     assert(nb_args <= MAX_ARGS);
756
757     for (i = 0; i < nb_args; i++) {
758         g_free(args[i]);
759     }
760
761 }
762
763 /*
764  * Parse the command line to get valid args.
765  * @cmdline: command line to be parsed.
766  * @pnb_args: location to store the number of args, must NOT be NULL.
767  * @args: location to store the args, which should be freed by caller, must
768  *        NOT be NULL.
769  *
770  * Returns 0 on success, negative on failure.
771  *
772  * NOTE: this parser is an approximate form of the real command parser. Number
773  *       of args have a limit of MAX_ARGS. If cmdline contains more, it will
774  *       return with failure.
775  */
776 static int parse_cmdline(const char *cmdline,
777                          int *pnb_args, char **args)
778 {
779     const char *p;
780     int nb_args, ret;
781     char buf[1024];
782
783     p = cmdline;
784     nb_args = 0;
785     for (;;) {
786         while (qemu_isspace(*p)) {
787             p++;
788         }
789         if (*p == '\0') {
790             break;
791         }
792         if (nb_args >= MAX_ARGS) {
793             goto fail;
794         }
795         ret = get_str(buf, sizeof(buf), &p);
796         if (ret < 0) {
797             goto fail;
798         }
799         args[nb_args] = g_strdup(buf);
800         nb_args++;
801     }
802     *pnb_args = nb_args;
803     return 0;
804
805  fail:
806     free_cmdline_args(args, nb_args);
807     return -1;
808 }
809
810 static void help_cmd_dump_one(Monitor *mon,
811                               const mon_cmd_t *cmd,
812                               char **prefix_args,
813                               int prefix_args_nb)
814 {
815     int i;
816
817     for (i = 0; i < prefix_args_nb; i++) {
818         monitor_printf(mon, "%s ", prefix_args[i]);
819     }
820     monitor_printf(mon, "%s %s -- %s\n", cmd->name, cmd->params, cmd->help);
821 }
822
823 /* @args[@arg_index] is the valid command need to find in @cmds */
824 static void help_cmd_dump(Monitor *mon, const mon_cmd_t *cmds,
825                           char **args, int nb_args, int arg_index)
826 {
827     const mon_cmd_t *cmd;
828
829     /* No valid arg need to compare with, dump all in *cmds */
830     if (arg_index >= nb_args) {
831         for (cmd = cmds; cmd->name != NULL; cmd++) {
832             help_cmd_dump_one(mon, cmd, args, arg_index);
833         }
834         return;
835     }
836
837     /* Find one entry to dump */
838     for (cmd = cmds; cmd->name != NULL; cmd++) {
839         if (compare_cmd(args[arg_index], cmd->name)) {
840             if (cmd->sub_table) {
841                 /* continue with next arg */
842                 help_cmd_dump(mon, cmd->sub_table,
843                               args, nb_args, arg_index + 1);
844             } else {
845                 help_cmd_dump_one(mon, cmd, args, arg_index);
846             }
847             break;
848         }
849     }
850 }
851
852 static void help_cmd(Monitor *mon, const char *name)
853 {
854     char *args[MAX_ARGS];
855     int nb_args = 0;
856
857     /* 1. parse user input */
858     if (name) {
859         /* special case for log, directly dump and return */
860         if (!strcmp(name, "log")) {
861             const QEMULogItem *item;
862             monitor_printf(mon, "Log items (comma separated):\n");
863             monitor_printf(mon, "%-10s %s\n", "none", "remove all logs");
864             for (item = qemu_log_items; item->mask != 0; item++) {
865                 monitor_printf(mon, "%-10s %s\n", item->name, item->help);
866             }
867             return;
868         }
869
870         if (parse_cmdline(name, &nb_args, args) < 0) {
871             return;
872         }
873     }
874
875     /* 2. dump the contents according to parsed args */
876     help_cmd_dump(mon, mon->cmd_table, args, nb_args, 0);
877
878     free_cmdline_args(args, nb_args);
879 }
880
881 static void do_help_cmd(Monitor *mon, const QDict *qdict)
882 {
883     help_cmd(mon, qdict_get_try_str(qdict, "name"));
884 }
885
886 static void hmp_trace_event(Monitor *mon, const QDict *qdict)
887 {
888     const char *tp_name = qdict_get_str(qdict, "name");
889     bool new_state = qdict_get_bool(qdict, "option");
890     Error *local_err = NULL;
891
892     qmp_trace_event_set_state(tp_name, new_state, true, true, &local_err);
893     if (local_err) {
894         error_report_err(local_err);
895     }
896 }
897
898 #ifdef CONFIG_TRACE_SIMPLE
899 static void hmp_trace_file(Monitor *mon, const QDict *qdict)
900 {
901     const char *op = qdict_get_try_str(qdict, "op");
902     const char *arg = qdict_get_try_str(qdict, "arg");
903
904     if (!op) {
905         st_print_trace_file_status((FILE *)mon, &monitor_fprintf);
906     } else if (!strcmp(op, "on")) {
907         st_set_trace_file_enabled(true);
908     } else if (!strcmp(op, "off")) {
909         st_set_trace_file_enabled(false);
910     } else if (!strcmp(op, "flush")) {
911         st_flush_trace_buffer();
912     } else if (!strcmp(op, "set")) {
913         if (arg) {
914             st_set_trace_file(arg);
915         }
916     } else {
917         monitor_printf(mon, "unexpected argument \"%s\"\n", op);
918         help_cmd(mon, "trace-file");
919     }
920 }
921 #endif
922
923 static void user_monitor_complete(void *opaque, QObject *ret_data)
924 {
925     MonitorCompletionData *data = (MonitorCompletionData *)opaque; 
926
927     if (ret_data) {
928         data->user_print(data->mon, ret_data);
929     }
930     monitor_resume(data->mon);
931     g_free(data);
932 }
933
934 static void qmp_monitor_complete(void *opaque, QObject *ret_data)
935 {
936     monitor_protocol_emitter(opaque, ret_data);
937 }
938
939 static int qmp_async_cmd_handler(Monitor *mon, const mon_cmd_t *cmd,
940                                  const QDict *params)
941 {
942     return cmd->mhandler.cmd_async(mon, params, qmp_monitor_complete, mon);
943 }
944
945 static void user_async_cmd_handler(Monitor *mon, const mon_cmd_t *cmd,
946                                    const QDict *params)
947 {
948     int ret;
949
950     MonitorCompletionData *cb_data = g_malloc(sizeof(*cb_data));
951     cb_data->mon = mon;
952     cb_data->user_print = cmd->user_print;
953     monitor_suspend(mon);
954     ret = cmd->mhandler.cmd_async(mon, params,
955                                   user_monitor_complete, cb_data);
956     if (ret < 0) {
957         monitor_resume(mon);
958         g_free(cb_data);
959     }
960 }
961
962 static void hmp_info_help(Monitor *mon, const QDict *qdict)
963 {
964     help_cmd(mon, "info");
965 }
966
967 CommandInfoList *qmp_query_commands(Error **errp)
968 {
969     CommandInfoList *info, *cmd_list = NULL;
970     const mon_cmd_t *cmd;
971
972     for (cmd = qmp_cmds; cmd->name != NULL; cmd++) {
973         info = g_malloc0(sizeof(*info));
974         info->value = g_malloc0(sizeof(*info->value));
975         info->value->name = g_strdup(cmd->name);
976
977         info->next = cmd_list;
978         cmd_list = info;
979     }
980
981     return cmd_list;
982 }
983
984 EventInfoList *qmp_query_events(Error **errp)
985 {
986     EventInfoList *info, *ev_list = NULL;
987     QAPIEvent e;
988
989     for (e = 0 ; e < QAPI_EVENT_MAX ; e++) {
990         const char *event_name = QAPIEvent_lookup[e];
991         assert(event_name != NULL);
992         info = g_malloc0(sizeof(*info));
993         info->value = g_malloc0(sizeof(*info->value));
994         info->value->name = g_strdup(event_name);
995
996         info->next = ev_list;
997         ev_list = info;
998     }
999
1000     return ev_list;
1001 }
1002
1003 /* set the current CPU defined by the user */
1004 int monitor_set_cpu(int cpu_index)
1005 {
1006     CPUState *cpu;
1007
1008     cpu = qemu_get_cpu(cpu_index);
1009     if (cpu == NULL) {
1010         return -1;
1011     }
1012     cur_mon->mon_cpu = cpu;
1013     return 0;
1014 }
1015
1016 static CPUArchState *mon_get_cpu(void)
1017 {
1018     if (!cur_mon->mon_cpu) {
1019         monitor_set_cpu(0);
1020     }
1021     cpu_synchronize_state(cur_mon->mon_cpu);
1022     return cur_mon->mon_cpu->env_ptr;
1023 }
1024
1025 int monitor_get_cpu_index(void)
1026 {
1027     CPUState *cpu = ENV_GET_CPU(mon_get_cpu());
1028     return cpu->cpu_index;
1029 }
1030
1031 static void hmp_info_registers(Monitor *mon, const QDict *qdict)
1032 {
1033     CPUState *cpu;
1034     CPUArchState *env;
1035     env = mon_get_cpu();
1036     cpu = ENV_GET_CPU(env);
1037     cpu_dump_state(cpu, (FILE *)mon, monitor_fprintf, CPU_DUMP_FPU);
1038 }
1039
1040 static void hmp_info_jit(Monitor *mon, const QDict *qdict)
1041 {
1042     dump_exec_info((FILE *)mon, monitor_fprintf);
1043     dump_drift_info((FILE *)mon, monitor_fprintf);
1044 }
1045
1046 static void hmp_info_opcount(Monitor *mon, const QDict *qdict)
1047 {
1048     dump_opcount_info((FILE *)mon, monitor_fprintf);
1049 }
1050
1051 static void hmp_info_history(Monitor *mon, const QDict *qdict)
1052 {
1053     int i;
1054     const char *str;
1055
1056     if (!mon->rs)
1057         return;
1058     i = 0;
1059     for(;;) {
1060         str = readline_get_history(mon->rs, i);
1061         if (!str)
1062             break;
1063         monitor_printf(mon, "%d: '%s'\n", i, str);
1064         i++;
1065     }
1066 }
1067
1068 static void hmp_info_cpustats(Monitor *mon, const QDict *qdict)
1069 {
1070     CPUState *cpu;
1071     CPUArchState *env;
1072
1073     env = mon_get_cpu();
1074     cpu = ENV_GET_CPU(env);
1075     cpu_dump_statistics(cpu, (FILE *)mon, &monitor_fprintf, 0);
1076 }
1077
1078 static void hmp_info_trace_events(Monitor *mon, const QDict *qdict)
1079 {
1080     TraceEventInfoList *events = qmp_trace_event_get_state("*", NULL);
1081     TraceEventInfoList *elem;
1082
1083     for (elem = events; elem != NULL; elem = elem->next) {
1084         monitor_printf(mon, "%s : state %u\n",
1085                        elem->value->name,
1086                        elem->value->state == TRACE_EVENT_STATE_ENABLED ? 1 : 0);
1087     }
1088     qapi_free_TraceEventInfoList(events);
1089 }
1090
1091 static int client_migrate_info(Monitor *mon, const QDict *qdict,
1092                                MonitorCompletion cb, void *opaque)
1093 {
1094     const char *protocol = qdict_get_str(qdict, "protocol");
1095     const char *hostname = qdict_get_str(qdict, "hostname");
1096     const char *subject  = qdict_get_try_str(qdict, "cert-subject");
1097     int port             = qdict_get_try_int(qdict, "port", -1);
1098     int tls_port         = qdict_get_try_int(qdict, "tls-port", -1);
1099     Error *err = NULL;
1100     int ret;
1101
1102     if (strcmp(protocol, "spice") == 0) {
1103         if (!qemu_using_spice(&err)) {
1104             qerror_report_err(err);
1105             error_free(err);
1106             return -1;
1107         }
1108
1109         if (port == -1 && tls_port == -1) {
1110             qerror_report(QERR_MISSING_PARAMETER, "port/tls-port");
1111             return -1;
1112         }
1113
1114         ret = qemu_spice_migrate_info(hostname, port, tls_port, subject,
1115                                       cb, opaque);
1116         if (ret != 0) {
1117             qerror_report(QERR_UNDEFINED_ERROR);
1118             return -1;
1119         }
1120         return 0;
1121     }
1122
1123     qerror_report(QERR_INVALID_PARAMETER, "protocol");
1124     return -1;
1125 }
1126
1127 static void hmp_logfile(Monitor *mon, const QDict *qdict)
1128 {
1129     qemu_set_log_filename(qdict_get_str(qdict, "filename"));
1130 }
1131
1132 static void hmp_log(Monitor *mon, const QDict *qdict)
1133 {
1134     int mask;
1135     const char *items = qdict_get_str(qdict, "items");
1136
1137     if (!strcmp(items, "none")) {
1138         mask = 0;
1139     } else {
1140         mask = qemu_str_to_log_mask(items);
1141         if (!mask) {
1142             help_cmd(mon, "log");
1143             return;
1144         }
1145     }
1146     qemu_set_log(mask);
1147 }
1148
1149 static void hmp_singlestep(Monitor *mon, const QDict *qdict)
1150 {
1151     const char *option = qdict_get_try_str(qdict, "option");
1152     if (!option || !strcmp(option, "on")) {
1153         singlestep = 1;
1154     } else if (!strcmp(option, "off")) {
1155         singlestep = 0;
1156     } else {
1157         monitor_printf(mon, "unexpected option %s\n", option);
1158     }
1159 }
1160
1161 static void hmp_gdbserver(Monitor *mon, const QDict *qdict)
1162 {
1163     const char *device = qdict_get_try_str(qdict, "device");
1164     if (!device)
1165         device = "tcp::" DEFAULT_GDBSTUB_PORT;
1166     if (gdbserver_start(device) < 0) {
1167         monitor_printf(mon, "Could not open gdbserver on device '%s'\n",
1168                        device);
1169     } else if (strcmp(device, "none") == 0) {
1170         monitor_printf(mon, "Disabled gdbserver\n");
1171     } else {
1172         monitor_printf(mon, "Waiting for gdb connection on device '%s'\n",
1173                        device);
1174     }
1175 }
1176
1177 static void hmp_watchdog_action(Monitor *mon, const QDict *qdict)
1178 {
1179     const char *action = qdict_get_str(qdict, "action");
1180     if (select_watchdog_action(action) == -1) {
1181         monitor_printf(mon, "Unknown watchdog action '%s'\n", action);
1182     }
1183 }
1184
1185 static void monitor_printc(Monitor *mon, int c)
1186 {
1187     monitor_printf(mon, "'");
1188     switch(c) {
1189     case '\'':
1190         monitor_printf(mon, "\\'");
1191         break;
1192     case '\\':
1193         monitor_printf(mon, "\\\\");
1194         break;
1195     case '\n':
1196         monitor_printf(mon, "\\n");
1197         break;
1198     case '\r':
1199         monitor_printf(mon, "\\r");
1200         break;
1201     default:
1202         if (c >= 32 && c <= 126) {
1203             monitor_printf(mon, "%c", c);
1204         } else {
1205             monitor_printf(mon, "\\x%02x", c);
1206         }
1207         break;
1208     }
1209     monitor_printf(mon, "'");
1210 }
1211
1212 static void memory_dump(Monitor *mon, int count, int format, int wsize,
1213                         hwaddr addr, int is_physical)
1214 {
1215     CPUArchState *env;
1216     int l, line_size, i, max_digits, len;
1217     uint8_t buf[16];
1218     uint64_t v;
1219
1220     if (format == 'i') {
1221         int flags;
1222         flags = 0;
1223         env = mon_get_cpu();
1224 #ifdef TARGET_I386
1225         if (wsize == 2) {
1226             flags = 1;
1227         } else if (wsize == 4) {
1228             flags = 0;
1229         } else {
1230             /* as default we use the current CS size */
1231             flags = 0;
1232             if (env) {
1233 #ifdef TARGET_X86_64
1234                 if ((env->efer & MSR_EFER_LMA) &&
1235                     (env->segs[R_CS].flags & DESC_L_MASK))
1236                     flags = 2;
1237                 else
1238 #endif
1239                 if (!(env->segs[R_CS].flags & DESC_B_MASK))
1240                     flags = 1;
1241             }
1242         }
1243 #endif
1244 #ifdef TARGET_PPC
1245         flags = msr_le << 16;
1246         flags |= env->bfd_mach;
1247 #endif
1248         monitor_disas(mon, env, addr, count, is_physical, flags);
1249         return;
1250     }
1251
1252     len = wsize * count;
1253     if (wsize == 1)
1254         line_size = 8;
1255     else
1256         line_size = 16;
1257     max_digits = 0;
1258
1259     switch(format) {
1260     case 'o':
1261         max_digits = (wsize * 8 + 2) / 3;
1262         break;
1263     default:
1264     case 'x':
1265         max_digits = (wsize * 8) / 4;
1266         break;
1267     case 'u':
1268     case 'd':
1269         max_digits = (wsize * 8 * 10 + 32) / 33;
1270         break;
1271     case 'c':
1272         wsize = 1;
1273         break;
1274     }
1275
1276     while (len > 0) {
1277         if (is_physical)
1278             monitor_printf(mon, TARGET_FMT_plx ":", addr);
1279         else
1280             monitor_printf(mon, TARGET_FMT_lx ":", (target_ulong)addr);
1281         l = len;
1282         if (l > line_size)
1283             l = line_size;
1284         if (is_physical) {
1285             cpu_physical_memory_read(addr, buf, l);
1286         } else {
1287             env = mon_get_cpu();
1288             if (cpu_memory_rw_debug(ENV_GET_CPU(env), addr, buf, l, 0) < 0) {
1289                 monitor_printf(mon, " Cannot access memory\n");
1290                 break;
1291             }
1292         }
1293         i = 0;
1294         while (i < l) {
1295             switch(wsize) {
1296             default:
1297             case 1:
1298                 v = ldub_p(buf + i);
1299                 break;
1300             case 2:
1301                 v = lduw_p(buf + i);
1302                 break;
1303             case 4:
1304                 v = (uint32_t)ldl_p(buf + i);
1305                 break;
1306             case 8:
1307                 v = ldq_p(buf + i);
1308                 break;
1309             }
1310             monitor_printf(mon, " ");
1311             switch(format) {
1312             case 'o':
1313                 monitor_printf(mon, "%#*" PRIo64, max_digits, v);
1314                 break;
1315             case 'x':
1316                 monitor_printf(mon, "0x%0*" PRIx64, max_digits, v);
1317                 break;
1318             case 'u':
1319                 monitor_printf(mon, "%*" PRIu64, max_digits, v);
1320                 break;
1321             case 'd':
1322                 monitor_printf(mon, "%*" PRId64, max_digits, v);
1323                 break;
1324             case 'c':
1325                 monitor_printc(mon, v);
1326                 break;
1327             }
1328             i += wsize;
1329         }
1330         monitor_printf(mon, "\n");
1331         addr += l;
1332         len -= l;
1333     }
1334 }
1335
1336 static void hmp_memory_dump(Monitor *mon, const QDict *qdict)
1337 {
1338     int count = qdict_get_int(qdict, "count");
1339     int format = qdict_get_int(qdict, "format");
1340     int size = qdict_get_int(qdict, "size");
1341     target_long addr = qdict_get_int(qdict, "addr");
1342
1343     memory_dump(mon, count, format, size, addr, 0);
1344 }
1345
1346 static void hmp_physical_memory_dump(Monitor *mon, const QDict *qdict)
1347 {
1348     int count = qdict_get_int(qdict, "count");
1349     int format = qdict_get_int(qdict, "format");
1350     int size = qdict_get_int(qdict, "size");
1351     hwaddr addr = qdict_get_int(qdict, "addr");
1352
1353     memory_dump(mon, count, format, size, addr, 1);
1354 }
1355
1356 static void do_print(Monitor *mon, const QDict *qdict)
1357 {
1358     int format = qdict_get_int(qdict, "format");
1359     hwaddr val = qdict_get_int(qdict, "val");
1360
1361     switch(format) {
1362     case 'o':
1363         monitor_printf(mon, "%#" HWADDR_PRIo, val);
1364         break;
1365     case 'x':
1366         monitor_printf(mon, "%#" HWADDR_PRIx, val);
1367         break;
1368     case 'u':
1369         monitor_printf(mon, "%" HWADDR_PRIu, val);
1370         break;
1371     default:
1372     case 'd':
1373         monitor_printf(mon, "%" HWADDR_PRId, val);
1374         break;
1375     case 'c':
1376         monitor_printc(mon, val);
1377         break;
1378     }
1379     monitor_printf(mon, "\n");
1380 }
1381
1382 static void hmp_sum(Monitor *mon, const QDict *qdict)
1383 {
1384     uint32_t addr;
1385     uint16_t sum;
1386     uint32_t start = qdict_get_int(qdict, "start");
1387     uint32_t size = qdict_get_int(qdict, "size");
1388
1389     sum = 0;
1390     for(addr = start; addr < (start + size); addr++) {
1391         uint8_t val = ldub_phys(&address_space_memory, addr);
1392         /* BSD sum algorithm ('sum' Unix command) */
1393         sum = (sum >> 1) | (sum << 15);
1394         sum += val;
1395     }
1396     monitor_printf(mon, "%05d\n", sum);
1397 }
1398
1399 static int mouse_button_state;
1400
1401 static void hmp_mouse_move(Monitor *mon, const QDict *qdict)
1402 {
1403     int dx, dy, dz, button;
1404     const char *dx_str = qdict_get_str(qdict, "dx_str");
1405     const char *dy_str = qdict_get_str(qdict, "dy_str");
1406     const char *dz_str = qdict_get_try_str(qdict, "dz_str");
1407
1408     dx = strtol(dx_str, NULL, 0);
1409     dy = strtol(dy_str, NULL, 0);
1410     qemu_input_queue_rel(NULL, INPUT_AXIS_X, dx);
1411     qemu_input_queue_rel(NULL, INPUT_AXIS_Y, dy);
1412
1413     if (dz_str) {
1414         dz = strtol(dz_str, NULL, 0);
1415         if (dz != 0) {
1416             button = (dz > 0) ? INPUT_BUTTON_WHEEL_UP : INPUT_BUTTON_WHEEL_DOWN;
1417             qemu_input_queue_btn(NULL, button, true);
1418             qemu_input_event_sync();
1419             qemu_input_queue_btn(NULL, button, false);
1420         }
1421     }
1422     qemu_input_event_sync();
1423 }
1424
1425 static void hmp_mouse_button(Monitor *mon, const QDict *qdict)
1426 {
1427     static uint32_t bmap[INPUT_BUTTON_MAX] = {
1428         [INPUT_BUTTON_LEFT]       = MOUSE_EVENT_LBUTTON,
1429         [INPUT_BUTTON_MIDDLE]     = MOUSE_EVENT_MBUTTON,
1430         [INPUT_BUTTON_RIGHT]      = MOUSE_EVENT_RBUTTON,
1431     };
1432     int button_state = qdict_get_int(qdict, "button_state");
1433
1434     if (mouse_button_state == button_state) {
1435         return;
1436     }
1437     qemu_input_update_buttons(NULL, bmap, mouse_button_state, button_state);
1438     qemu_input_event_sync();
1439     mouse_button_state = button_state;
1440 }
1441
1442 static void hmp_ioport_read(Monitor *mon, const QDict *qdict)
1443 {
1444     int size = qdict_get_int(qdict, "size");
1445     int addr = qdict_get_int(qdict, "addr");
1446     int has_index = qdict_haskey(qdict, "index");
1447     uint32_t val;
1448     int suffix;
1449
1450     if (has_index) {
1451         int index = qdict_get_int(qdict, "index");
1452         cpu_outb(addr & IOPORTS_MASK, index & 0xff);
1453         addr++;
1454     }
1455     addr &= 0xffff;
1456
1457     switch(size) {
1458     default:
1459     case 1:
1460         val = cpu_inb(addr);
1461         suffix = 'b';
1462         break;
1463     case 2:
1464         val = cpu_inw(addr);
1465         suffix = 'w';
1466         break;
1467     case 4:
1468         val = cpu_inl(addr);
1469         suffix = 'l';
1470         break;
1471     }
1472     monitor_printf(mon, "port%c[0x%04x] = %#0*x\n",
1473                    suffix, addr, size * 2, val);
1474 }
1475
1476 static void hmp_ioport_write(Monitor *mon, const QDict *qdict)
1477 {
1478     int size = qdict_get_int(qdict, "size");
1479     int addr = qdict_get_int(qdict, "addr");
1480     int val = qdict_get_int(qdict, "val");
1481
1482     addr &= IOPORTS_MASK;
1483
1484     switch (size) {
1485     default:
1486     case 1:
1487         cpu_outb(addr, val);
1488         break;
1489     case 2:
1490         cpu_outw(addr, val);
1491         break;
1492     case 4:
1493         cpu_outl(addr, val);
1494         break;
1495     }
1496 }
1497
1498 static void hmp_boot_set(Monitor *mon, const QDict *qdict)
1499 {
1500     Error *local_err = NULL;
1501     const char *bootdevice = qdict_get_str(qdict, "bootdevice");
1502
1503     qemu_boot_set(bootdevice, &local_err);
1504     if (local_err) {
1505         monitor_printf(mon, "%s\n", error_get_pretty(local_err));
1506         error_free(local_err);
1507     } else {
1508         monitor_printf(mon, "boot device list now set to %s\n", bootdevice);
1509     }
1510 }
1511
1512 #if defined(TARGET_I386)
1513 static void print_pte(Monitor *mon, hwaddr addr,
1514                       hwaddr pte,
1515                       hwaddr mask)
1516 {
1517 #ifdef TARGET_X86_64
1518     if (addr & (1ULL << 47)) {
1519         addr |= -1LL << 48;
1520     }
1521 #endif
1522     monitor_printf(mon, TARGET_FMT_plx ": " TARGET_FMT_plx
1523                    " %c%c%c%c%c%c%c%c%c\n",
1524                    addr,
1525                    pte & mask,
1526                    pte & PG_NX_MASK ? 'X' : '-',
1527                    pte & PG_GLOBAL_MASK ? 'G' : '-',
1528                    pte & PG_PSE_MASK ? 'P' : '-',
1529                    pte & PG_DIRTY_MASK ? 'D' : '-',
1530                    pte & PG_ACCESSED_MASK ? 'A' : '-',
1531                    pte & PG_PCD_MASK ? 'C' : '-',
1532                    pte & PG_PWT_MASK ? 'T' : '-',
1533                    pte & PG_USER_MASK ? 'U' : '-',
1534                    pte & PG_RW_MASK ? 'W' : '-');
1535 }
1536
1537 static void tlb_info_32(Monitor *mon, CPUArchState *env)
1538 {
1539     unsigned int l1, l2;
1540     uint32_t pgd, pde, pte;
1541
1542     pgd = env->cr[3] & ~0xfff;
1543     for(l1 = 0; l1 < 1024; l1++) {
1544         cpu_physical_memory_read(pgd + l1 * 4, &pde, 4);
1545         pde = le32_to_cpu(pde);
1546         if (pde & PG_PRESENT_MASK) {
1547             if ((pde & PG_PSE_MASK) && (env->cr[4] & CR4_PSE_MASK)) {
1548                 /* 4M pages */
1549                 print_pte(mon, (l1 << 22), pde, ~((1 << 21) - 1));
1550             } else {
1551                 for(l2 = 0; l2 < 1024; l2++) {
1552                     cpu_physical_memory_read((pde & ~0xfff) + l2 * 4, &pte, 4);
1553                     pte = le32_to_cpu(pte);
1554                     if (pte & PG_PRESENT_MASK) {
1555                         print_pte(mon, (l1 << 22) + (l2 << 12),
1556                                   pte & ~PG_PSE_MASK,
1557                                   ~0xfff);
1558                     }
1559                 }
1560             }
1561         }
1562     }
1563 }
1564
1565 static void tlb_info_pae32(Monitor *mon, CPUArchState *env)
1566 {
1567     unsigned int l1, l2, l3;
1568     uint64_t pdpe, pde, pte;
1569     uint64_t pdp_addr, pd_addr, pt_addr;
1570
1571     pdp_addr = env->cr[3] & ~0x1f;
1572     for (l1 = 0; l1 < 4; l1++) {
1573         cpu_physical_memory_read(pdp_addr + l1 * 8, &pdpe, 8);
1574         pdpe = le64_to_cpu(pdpe);
1575         if (pdpe & PG_PRESENT_MASK) {
1576             pd_addr = pdpe & 0x3fffffffff000ULL;
1577             for (l2 = 0; l2 < 512; l2++) {
1578                 cpu_physical_memory_read(pd_addr + l2 * 8, &pde, 8);
1579                 pde = le64_to_cpu(pde);
1580                 if (pde & PG_PRESENT_MASK) {
1581                     if (pde & PG_PSE_MASK) {
1582                         /* 2M pages with PAE, CR4.PSE is ignored */
1583                         print_pte(mon, (l1 << 30 ) + (l2 << 21), pde,
1584                                   ~((hwaddr)(1 << 20) - 1));
1585                     } else {
1586                         pt_addr = pde & 0x3fffffffff000ULL;
1587                         for (l3 = 0; l3 < 512; l3++) {
1588                             cpu_physical_memory_read(pt_addr + l3 * 8, &pte, 8);
1589                             pte = le64_to_cpu(pte);
1590                             if (pte & PG_PRESENT_MASK) {
1591                                 print_pte(mon, (l1 << 30 ) + (l2 << 21)
1592                                           + (l3 << 12),
1593                                           pte & ~PG_PSE_MASK,
1594                                           ~(hwaddr)0xfff);
1595                             }
1596                         }
1597                     }
1598                 }
1599             }
1600         }
1601     }
1602 }
1603
1604 #ifdef TARGET_X86_64
1605 static void tlb_info_64(Monitor *mon, CPUArchState *env)
1606 {
1607     uint64_t l1, l2, l3, l4;
1608     uint64_t pml4e, pdpe, pde, pte;
1609     uint64_t pml4_addr, pdp_addr, pd_addr, pt_addr;
1610
1611     pml4_addr = env->cr[3] & 0x3fffffffff000ULL;
1612     for (l1 = 0; l1 < 512; l1++) {
1613         cpu_physical_memory_read(pml4_addr + l1 * 8, &pml4e, 8);
1614         pml4e = le64_to_cpu(pml4e);
1615         if (pml4e & PG_PRESENT_MASK) {
1616             pdp_addr = pml4e & 0x3fffffffff000ULL;
1617             for (l2 = 0; l2 < 512; l2++) {
1618                 cpu_physical_memory_read(pdp_addr + l2 * 8, &pdpe, 8);
1619                 pdpe = le64_to_cpu(pdpe);
1620                 if (pdpe & PG_PRESENT_MASK) {
1621                     if (pdpe & PG_PSE_MASK) {
1622                         /* 1G pages, CR4.PSE is ignored */
1623                         print_pte(mon, (l1 << 39) + (l2 << 30), pdpe,
1624                                   0x3ffffc0000000ULL);
1625                     } else {
1626                         pd_addr = pdpe & 0x3fffffffff000ULL;
1627                         for (l3 = 0; l3 < 512; l3++) {
1628                             cpu_physical_memory_read(pd_addr + l3 * 8, &pde, 8);
1629                             pde = le64_to_cpu(pde);
1630                             if (pde & PG_PRESENT_MASK) {
1631                                 if (pde & PG_PSE_MASK) {
1632                                     /* 2M pages, CR4.PSE is ignored */
1633                                     print_pte(mon, (l1 << 39) + (l2 << 30) +
1634                                               (l3 << 21), pde,
1635                                               0x3ffffffe00000ULL);
1636                                 } else {
1637                                     pt_addr = pde & 0x3fffffffff000ULL;
1638                                     for (l4 = 0; l4 < 512; l4++) {
1639                                         cpu_physical_memory_read(pt_addr
1640                                                                  + l4 * 8,
1641                                                                  &pte, 8);
1642                                         pte = le64_to_cpu(pte);
1643                                         if (pte & PG_PRESENT_MASK) {
1644                                             print_pte(mon, (l1 << 39) +
1645                                                       (l2 << 30) +
1646                                                       (l3 << 21) + (l4 << 12),
1647                                                       pte & ~PG_PSE_MASK,
1648                                                       0x3fffffffff000ULL);
1649                                         }
1650                                     }
1651                                 }
1652                             }
1653                         }
1654                     }
1655                 }
1656             }
1657         }
1658     }
1659 }
1660 #endif
1661
1662 static void hmp_info_tlb(Monitor *mon, const QDict *qdict)
1663 {
1664     CPUArchState *env;
1665
1666     env = mon_get_cpu();
1667
1668     if (!(env->cr[0] & CR0_PG_MASK)) {
1669         monitor_printf(mon, "PG disabled\n");
1670         return;
1671     }
1672     if (env->cr[4] & CR4_PAE_MASK) {
1673 #ifdef TARGET_X86_64
1674         if (env->hflags & HF_LMA_MASK) {
1675             tlb_info_64(mon, env);
1676         } else
1677 #endif
1678         {
1679             tlb_info_pae32(mon, env);
1680         }
1681     } else {
1682         tlb_info_32(mon, env);
1683     }
1684 }
1685
1686 static void mem_print(Monitor *mon, hwaddr *pstart,
1687                       int *plast_prot,
1688                       hwaddr end, int prot)
1689 {
1690     int prot1;
1691     prot1 = *plast_prot;
1692     if (prot != prot1) {
1693         if (*pstart != -1) {
1694             monitor_printf(mon, TARGET_FMT_plx "-" TARGET_FMT_plx " "
1695                            TARGET_FMT_plx " %c%c%c\n",
1696                            *pstart, end, end - *pstart,
1697                            prot1 & PG_USER_MASK ? 'u' : '-',
1698                            'r',
1699                            prot1 & PG_RW_MASK ? 'w' : '-');
1700         }
1701         if (prot != 0)
1702             *pstart = end;
1703         else
1704             *pstart = -1;
1705         *plast_prot = prot;
1706     }
1707 }
1708
1709 static void mem_info_32(Monitor *mon, CPUArchState *env)
1710 {
1711     unsigned int l1, l2;
1712     int prot, last_prot;
1713     uint32_t pgd, pde, pte;
1714     hwaddr start, end;
1715
1716     pgd = env->cr[3] & ~0xfff;
1717     last_prot = 0;
1718     start = -1;
1719     for(l1 = 0; l1 < 1024; l1++) {
1720         cpu_physical_memory_read(pgd + l1 * 4, &pde, 4);
1721         pde = le32_to_cpu(pde);
1722         end = l1 << 22;
1723         if (pde & PG_PRESENT_MASK) {
1724             if ((pde & PG_PSE_MASK) && (env->cr[4] & CR4_PSE_MASK)) {
1725                 prot = pde & (PG_USER_MASK | PG_RW_MASK | PG_PRESENT_MASK);
1726                 mem_print(mon, &start, &last_prot, end, prot);
1727             } else {
1728                 for(l2 = 0; l2 < 1024; l2++) {
1729                     cpu_physical_memory_read((pde & ~0xfff) + l2 * 4, &pte, 4);
1730                     pte = le32_to_cpu(pte);
1731                     end = (l1 << 22) + (l2 << 12);
1732                     if (pte & PG_PRESENT_MASK) {
1733                         prot = pte & pde &
1734                             (PG_USER_MASK | PG_RW_MASK | PG_PRESENT_MASK);
1735                     } else {
1736                         prot = 0;
1737                     }
1738                     mem_print(mon, &start, &last_prot, end, prot);
1739                 }
1740             }
1741         } else {
1742             prot = 0;
1743             mem_print(mon, &start, &last_prot, end, prot);
1744         }
1745     }
1746     /* Flush last range */
1747     mem_print(mon, &start, &last_prot, (hwaddr)1 << 32, 0);
1748 }
1749
1750 static void mem_info_pae32(Monitor *mon, CPUArchState *env)
1751 {
1752     unsigned int l1, l2, l3;
1753     int prot, last_prot;
1754     uint64_t pdpe, pde, pte;
1755     uint64_t pdp_addr, pd_addr, pt_addr;
1756     hwaddr start, end;
1757
1758     pdp_addr = env->cr[3] & ~0x1f;
1759     last_prot = 0;
1760     start = -1;
1761     for (l1 = 0; l1 < 4; l1++) {
1762         cpu_physical_memory_read(pdp_addr + l1 * 8, &pdpe, 8);
1763         pdpe = le64_to_cpu(pdpe);
1764         end = l1 << 30;
1765         if (pdpe & PG_PRESENT_MASK) {
1766             pd_addr = pdpe & 0x3fffffffff000ULL;
1767             for (l2 = 0; l2 < 512; l2++) {
1768                 cpu_physical_memory_read(pd_addr + l2 * 8, &pde, 8);
1769                 pde = le64_to_cpu(pde);
1770                 end = (l1 << 30) + (l2 << 21);
1771                 if (pde & PG_PRESENT_MASK) {
1772                     if (pde & PG_PSE_MASK) {
1773                         prot = pde & (PG_USER_MASK | PG_RW_MASK |
1774                                       PG_PRESENT_MASK);
1775                         mem_print(mon, &start, &last_prot, end, prot);
1776                     } else {
1777                         pt_addr = pde & 0x3fffffffff000ULL;
1778                         for (l3 = 0; l3 < 512; l3++) {
1779                             cpu_physical_memory_read(pt_addr + l3 * 8, &pte, 8);
1780                             pte = le64_to_cpu(pte);
1781                             end = (l1 << 30) + (l2 << 21) + (l3 << 12);
1782                             if (pte & PG_PRESENT_MASK) {
1783                                 prot = pte & pde & (PG_USER_MASK | PG_RW_MASK |
1784                                                     PG_PRESENT_MASK);
1785                             } else {
1786                                 prot = 0;
1787                             }
1788                             mem_print(mon, &start, &last_prot, end, prot);
1789                         }
1790                     }
1791                 } else {
1792                     prot = 0;
1793                     mem_print(mon, &start, &last_prot, end, prot);
1794                 }
1795             }
1796         } else {
1797             prot = 0;
1798             mem_print(mon, &start, &last_prot, end, prot);
1799         }
1800     }
1801     /* Flush last range */
1802     mem_print(mon, &start, &last_prot, (hwaddr)1 << 32, 0);
1803 }
1804
1805
1806 #ifdef TARGET_X86_64
1807 static void mem_info_64(Monitor *mon, CPUArchState *env)
1808 {
1809     int prot, last_prot;
1810     uint64_t l1, l2, l3, l4;
1811     uint64_t pml4e, pdpe, pde, pte;
1812     uint64_t pml4_addr, pdp_addr, pd_addr, pt_addr, start, end;
1813
1814     pml4_addr = env->cr[3] & 0x3fffffffff000ULL;
1815     last_prot = 0;
1816     start = -1;
1817     for (l1 = 0; l1 < 512; l1++) {
1818         cpu_physical_memory_read(pml4_addr + l1 * 8, &pml4e, 8);
1819         pml4e = le64_to_cpu(pml4e);
1820         end = l1 << 39;
1821         if (pml4e & PG_PRESENT_MASK) {
1822             pdp_addr = pml4e & 0x3fffffffff000ULL;
1823             for (l2 = 0; l2 < 512; l2++) {
1824                 cpu_physical_memory_read(pdp_addr + l2 * 8, &pdpe, 8);
1825                 pdpe = le64_to_cpu(pdpe);
1826                 end = (l1 << 39) + (l2 << 30);
1827                 if (pdpe & PG_PRESENT_MASK) {
1828                     if (pdpe & PG_PSE_MASK) {
1829                         prot = pdpe & (PG_USER_MASK | PG_RW_MASK |
1830                                        PG_PRESENT_MASK);
1831                         prot &= pml4e;
1832                         mem_print(mon, &start, &last_prot, end, prot);
1833                     } else {
1834                         pd_addr = pdpe & 0x3fffffffff000ULL;
1835                         for (l3 = 0; l3 < 512; l3++) {
1836                             cpu_physical_memory_read(pd_addr + l3 * 8, &pde, 8);
1837                             pde = le64_to_cpu(pde);
1838                             end = (l1 << 39) + (l2 << 30) + (l3 << 21);
1839                             if (pde & PG_PRESENT_MASK) {
1840                                 if (pde & PG_PSE_MASK) {
1841                                     prot = pde & (PG_USER_MASK | PG_RW_MASK |
1842                                                   PG_PRESENT_MASK);
1843                                     prot &= pml4e & pdpe;
1844                                     mem_print(mon, &start, &last_prot, end, prot);
1845                                 } else {
1846                                     pt_addr = pde & 0x3fffffffff000ULL;
1847                                     for (l4 = 0; l4 < 512; l4++) {
1848                                         cpu_physical_memory_read(pt_addr
1849                                                                  + l4 * 8,
1850                                                                  &pte, 8);
1851                                         pte = le64_to_cpu(pte);
1852                                         end = (l1 << 39) + (l2 << 30) +
1853                                             (l3 << 21) + (l4 << 12);
1854                                         if (pte & PG_PRESENT_MASK) {
1855                                             prot = pte & (PG_USER_MASK | PG_RW_MASK |
1856                                                           PG_PRESENT_MASK);
1857                                             prot &= pml4e & pdpe & pde;
1858                                         } else {
1859                                             prot = 0;
1860                                         }
1861                                         mem_print(mon, &start, &last_prot, end, prot);
1862                                     }
1863                                 }
1864                             } else {
1865                                 prot = 0;
1866                                 mem_print(mon, &start, &last_prot, end, prot);
1867                             }
1868                         }
1869                     }
1870                 } else {
1871                     prot = 0;
1872                     mem_print(mon, &start, &last_prot, end, prot);
1873                 }
1874             }
1875         } else {
1876             prot = 0;
1877             mem_print(mon, &start, &last_prot, end, prot);
1878         }
1879     }
1880     /* Flush last range */
1881     mem_print(mon, &start, &last_prot, (hwaddr)1 << 48, 0);
1882 }
1883 #endif
1884
1885 static void hmp_info_mem(Monitor *mon, const QDict *qdict)
1886 {
1887     CPUArchState *env;
1888
1889     env = mon_get_cpu();
1890
1891     if (!(env->cr[0] & CR0_PG_MASK)) {
1892         monitor_printf(mon, "PG disabled\n");
1893         return;
1894     }
1895     if (env->cr[4] & CR4_PAE_MASK) {
1896 #ifdef TARGET_X86_64
1897         if (env->hflags & HF_LMA_MASK) {
1898             mem_info_64(mon, env);
1899         } else
1900 #endif
1901         {
1902             mem_info_pae32(mon, env);
1903         }
1904     } else {
1905         mem_info_32(mon, env);
1906     }
1907 }
1908 #endif
1909
1910 #if defined(TARGET_SH4)
1911
1912 static void print_tlb(Monitor *mon, int idx, tlb_t *tlb)
1913 {
1914     monitor_printf(mon, " tlb%i:\t"
1915                    "asid=%hhu vpn=%x\tppn=%x\tsz=%hhu size=%u\t"
1916                    "v=%hhu shared=%hhu cached=%hhu prot=%hhu "
1917                    "dirty=%hhu writethrough=%hhu\n",
1918                    idx,
1919                    tlb->asid, tlb->vpn, tlb->ppn, tlb->sz, tlb->size,
1920                    tlb->v, tlb->sh, tlb->c, tlb->pr,
1921                    tlb->d, tlb->wt);
1922 }
1923
1924 static void hmp_info_tlb(Monitor *mon, const QDict *qdict)
1925 {
1926     CPUArchState *env = mon_get_cpu();
1927     int i;
1928
1929     monitor_printf (mon, "ITLB:\n");
1930     for (i = 0 ; i < ITLB_SIZE ; i++)
1931         print_tlb (mon, i, &env->itlb[i]);
1932     monitor_printf (mon, "UTLB:\n");
1933     for (i = 0 ; i < UTLB_SIZE ; i++)
1934         print_tlb (mon, i, &env->utlb[i]);
1935 }
1936
1937 #endif
1938
1939 #if defined(TARGET_SPARC) || defined(TARGET_PPC) || defined(TARGET_XTENSA)
1940 static void hmp_info_tlb(Monitor *mon, const QDict *qdict)
1941 {
1942     CPUArchState *env1 = mon_get_cpu();
1943
1944     dump_mmu((FILE*)mon, (fprintf_function)monitor_printf, env1);
1945 }
1946 #endif
1947
1948 static void hmp_info_mtree(Monitor *mon, const QDict *qdict)
1949 {
1950     mtree_info((fprintf_function)monitor_printf, mon);
1951 }
1952
1953 static void hmp_info_numa(Monitor *mon, const QDict *qdict)
1954 {
1955     int i;
1956     CPUState *cpu;
1957     uint64_t *node_mem;
1958
1959     node_mem = g_new0(uint64_t, nb_numa_nodes);
1960     query_numa_node_mem(node_mem);
1961     monitor_printf(mon, "%d nodes\n", nb_numa_nodes);
1962     for (i = 0; i < nb_numa_nodes; i++) {
1963         monitor_printf(mon, "node %d cpus:", i);
1964         CPU_FOREACH(cpu) {
1965             if (cpu->numa_node == i) {
1966                 monitor_printf(mon, " %d", cpu->cpu_index);
1967             }
1968         }
1969         monitor_printf(mon, "\n");
1970         monitor_printf(mon, "node %d size: %" PRId64 " MB\n", i,
1971                        node_mem[i] >> 20);
1972     }
1973     g_free(node_mem);
1974 }
1975
1976 #ifdef CONFIG_PROFILER
1977
1978 int64_t qemu_time;
1979 int64_t dev_time;
1980
1981 static void hmp_info_profile(Monitor *mon, const QDict *qdict)
1982 {
1983     monitor_printf(mon, "async time  %" PRId64 " (%0.3f)\n",
1984                    dev_time, dev_time / (double)get_ticks_per_sec());
1985     monitor_printf(mon, "qemu time   %" PRId64 " (%0.3f)\n",
1986                    qemu_time, qemu_time / (double)get_ticks_per_sec());
1987     qemu_time = 0;
1988     dev_time = 0;
1989 }
1990 #else
1991 static void hmp_info_profile(Monitor *mon, const QDict *qdict)
1992 {
1993     monitor_printf(mon, "Internal profiler not compiled\n");
1994 }
1995 #endif
1996
1997 /* Capture support */
1998 static QLIST_HEAD (capture_list_head, CaptureState) capture_head;
1999
2000 static void hmp_info_capture(Monitor *mon, const QDict *qdict)
2001 {
2002     int i;
2003     CaptureState *s;
2004
2005     for (s = capture_head.lh_first, i = 0; s; s = s->entries.le_next, ++i) {
2006         monitor_printf(mon, "[%d]: ", i);
2007         s->ops.info (s->opaque);
2008     }
2009 }
2010
2011 static void hmp_stopcapture(Monitor *mon, const QDict *qdict)
2012 {
2013     int i;
2014     int n = qdict_get_int(qdict, "n");
2015     CaptureState *s;
2016
2017     for (s = capture_head.lh_first, i = 0; s; s = s->entries.le_next, ++i) {
2018         if (i == n) {
2019             s->ops.destroy (s->opaque);
2020             QLIST_REMOVE (s, entries);
2021             g_free (s);
2022             return;
2023         }
2024     }
2025 }
2026
2027 static void hmp_wavcapture(Monitor *mon, const QDict *qdict)
2028 {
2029     const char *path = qdict_get_str(qdict, "path");
2030     int has_freq = qdict_haskey(qdict, "freq");
2031     int freq = qdict_get_try_int(qdict, "freq", -1);
2032     int has_bits = qdict_haskey(qdict, "bits");
2033     int bits = qdict_get_try_int(qdict, "bits", -1);
2034     int has_channels = qdict_haskey(qdict, "nchannels");
2035     int nchannels = qdict_get_try_int(qdict, "nchannels", -1);
2036     CaptureState *s;
2037
2038     s = g_malloc0 (sizeof (*s));
2039
2040     freq = has_freq ? freq : 44100;
2041     bits = has_bits ? bits : 16;
2042     nchannels = has_channels ? nchannels : 2;
2043
2044     if (wav_start_capture (s, path, freq, bits, nchannels)) {
2045         monitor_printf(mon, "Failed to add wave capture\n");
2046         g_free (s);
2047         return;
2048     }
2049     QLIST_INSERT_HEAD (&capture_head, s, entries);
2050 }
2051
2052 static qemu_acl *find_acl(Monitor *mon, const char *name)
2053 {
2054     qemu_acl *acl = qemu_acl_find(name);
2055
2056     if (!acl) {
2057         monitor_printf(mon, "acl: unknown list '%s'\n", name);
2058     }
2059     return acl;
2060 }
2061
2062 static void hmp_acl_show(Monitor *mon, const QDict *qdict)
2063 {
2064     const char *aclname = qdict_get_str(qdict, "aclname");
2065     qemu_acl *acl = find_acl(mon, aclname);
2066     qemu_acl_entry *entry;
2067     int i = 0;
2068
2069     if (acl) {
2070         monitor_printf(mon, "policy: %s\n",
2071                        acl->defaultDeny ? "deny" : "allow");
2072         QTAILQ_FOREACH(entry, &acl->entries, next) {
2073             i++;
2074             monitor_printf(mon, "%d: %s %s\n", i,
2075                            entry->deny ? "deny" : "allow", entry->match);
2076         }
2077     }
2078 }
2079
2080 static void hmp_acl_reset(Monitor *mon, const QDict *qdict)
2081 {
2082     const char *aclname = qdict_get_str(qdict, "aclname");
2083     qemu_acl *acl = find_acl(mon, aclname);
2084
2085     if (acl) {
2086         qemu_acl_reset(acl);
2087         monitor_printf(mon, "acl: removed all rules\n");
2088     }
2089 }
2090
2091 static void hmp_acl_policy(Monitor *mon, const QDict *qdict)
2092 {
2093     const char *aclname = qdict_get_str(qdict, "aclname");
2094     const char *policy = qdict_get_str(qdict, "policy");
2095     qemu_acl *acl = find_acl(mon, aclname);
2096
2097     if (acl) {
2098         if (strcmp(policy, "allow") == 0) {
2099             acl->defaultDeny = 0;
2100             monitor_printf(mon, "acl: policy set to 'allow'\n");
2101         } else if (strcmp(policy, "deny") == 0) {
2102             acl->defaultDeny = 1;
2103             monitor_printf(mon, "acl: policy set to 'deny'\n");
2104         } else {
2105             monitor_printf(mon, "acl: unknown policy '%s', "
2106                            "expected 'deny' or 'allow'\n", policy);
2107         }
2108     }
2109 }
2110
2111 static void hmp_acl_add(Monitor *mon, const QDict *qdict)
2112 {
2113     const char *aclname = qdict_get_str(qdict, "aclname");
2114     const char *match = qdict_get_str(qdict, "match");
2115     const char *policy = qdict_get_str(qdict, "policy");
2116     int has_index = qdict_haskey(qdict, "index");
2117     int index = qdict_get_try_int(qdict, "index", -1);
2118     qemu_acl *acl = find_acl(mon, aclname);
2119     int deny, ret;
2120
2121     if (acl) {
2122         if (strcmp(policy, "allow") == 0) {
2123             deny = 0;
2124         } else if (strcmp(policy, "deny") == 0) {
2125             deny = 1;
2126         } else {
2127             monitor_printf(mon, "acl: unknown policy '%s', "
2128                            "expected 'deny' or 'allow'\n", policy);
2129             return;
2130         }
2131         if (has_index)
2132             ret = qemu_acl_insert(acl, deny, match, index);
2133         else
2134             ret = qemu_acl_append(acl, deny, match);
2135         if (ret < 0)
2136             monitor_printf(mon, "acl: unable to add acl entry\n");
2137         else
2138             monitor_printf(mon, "acl: added rule at position %d\n", ret);
2139     }
2140 }
2141
2142 static void hmp_acl_remove(Monitor *mon, const QDict *qdict)
2143 {
2144     const char *aclname = qdict_get_str(qdict, "aclname");
2145     const char *match = qdict_get_str(qdict, "match");
2146     qemu_acl *acl = find_acl(mon, aclname);
2147     int ret;
2148
2149     if (acl) {
2150         ret = qemu_acl_remove(acl, match);
2151         if (ret < 0)
2152             monitor_printf(mon, "acl: no matching acl entry\n");
2153         else
2154             monitor_printf(mon, "acl: removed rule at position %d\n", ret);
2155     }
2156 }
2157
2158 #if defined(TARGET_I386)
2159 static void hmp_mce(Monitor *mon, const QDict *qdict)
2160 {
2161     X86CPU *cpu;
2162     CPUState *cs;
2163     int cpu_index = qdict_get_int(qdict, "cpu_index");
2164     int bank = qdict_get_int(qdict, "bank");
2165     uint64_t status = qdict_get_int(qdict, "status");
2166     uint64_t mcg_status = qdict_get_int(qdict, "mcg_status");
2167     uint64_t addr = qdict_get_int(qdict, "addr");
2168     uint64_t misc = qdict_get_int(qdict, "misc");
2169     int flags = MCE_INJECT_UNCOND_AO;
2170
2171     if (qdict_get_try_bool(qdict, "broadcast", 0)) {
2172         flags |= MCE_INJECT_BROADCAST;
2173     }
2174     cs = qemu_get_cpu(cpu_index);
2175     if (cs != NULL) {
2176         cpu = X86_CPU(cs);
2177         cpu_x86_inject_mce(mon, cpu, bank, status, mcg_status, addr, misc,
2178                            flags);
2179     }
2180 }
2181 #endif
2182
2183 void qmp_getfd(const char *fdname, Error **errp)
2184 {
2185     mon_fd_t *monfd;
2186     int fd;
2187
2188     fd = qemu_chr_fe_get_msgfd(cur_mon->chr);
2189     if (fd == -1) {
2190         error_set(errp, QERR_FD_NOT_SUPPLIED);
2191         return;
2192     }
2193
2194     if (qemu_isdigit(fdname[0])) {
2195         close(fd);
2196         error_set(errp, QERR_INVALID_PARAMETER_VALUE, "fdname",
2197                   "a name not starting with a digit");
2198         return;
2199     }
2200
2201     QLIST_FOREACH(monfd, &cur_mon->fds, next) {
2202         if (strcmp(monfd->name, fdname) != 0) {
2203             continue;
2204         }
2205
2206         close(monfd->fd);
2207         monfd->fd = fd;
2208         return;
2209     }
2210
2211     monfd = g_malloc0(sizeof(mon_fd_t));
2212     monfd->name = g_strdup(fdname);
2213     monfd->fd = fd;
2214
2215     QLIST_INSERT_HEAD(&cur_mon->fds, monfd, next);
2216 }
2217
2218 void qmp_closefd(const char *fdname, Error **errp)
2219 {
2220     mon_fd_t *monfd;
2221
2222     QLIST_FOREACH(monfd, &cur_mon->fds, next) {
2223         if (strcmp(monfd->name, fdname) != 0) {
2224             continue;
2225         }
2226
2227         QLIST_REMOVE(monfd, next);
2228         close(monfd->fd);
2229         g_free(monfd->name);
2230         g_free(monfd);
2231         return;
2232     }
2233
2234     error_set(errp, QERR_FD_NOT_FOUND, fdname);
2235 }
2236
2237 static void hmp_loadvm(Monitor *mon, const QDict *qdict)
2238 {
2239     int saved_vm_running  = runstate_is_running();
2240     const char *name = qdict_get_str(qdict, "name");
2241
2242     vm_stop(RUN_STATE_RESTORE_VM);
2243
2244     if (load_vmstate(name) == 0 && saved_vm_running) {
2245         vm_start();
2246     }
2247 }
2248
2249 int monitor_get_fd(Monitor *mon, const char *fdname, Error **errp)
2250 {
2251     mon_fd_t *monfd;
2252
2253     QLIST_FOREACH(monfd, &mon->fds, next) {
2254         int fd;
2255
2256         if (strcmp(monfd->name, fdname) != 0) {
2257             continue;
2258         }
2259
2260         fd = monfd->fd;
2261
2262         /* caller takes ownership of fd */
2263         QLIST_REMOVE(monfd, next);
2264         g_free(monfd->name);
2265         g_free(monfd);
2266
2267         return fd;
2268     }
2269
2270     error_setg(errp, "File descriptor named '%s' has not been found", fdname);
2271     return -1;
2272 }
2273
2274 static void monitor_fdset_cleanup(MonFdset *mon_fdset)
2275 {
2276     MonFdsetFd *mon_fdset_fd;
2277     MonFdsetFd *mon_fdset_fd_next;
2278
2279     QLIST_FOREACH_SAFE(mon_fdset_fd, &mon_fdset->fds, next, mon_fdset_fd_next) {
2280         if ((mon_fdset_fd->removed ||
2281                 (QLIST_EMPTY(&mon_fdset->dup_fds) && mon_refcount == 0)) &&
2282                 runstate_is_running()) {
2283             close(mon_fdset_fd->fd);
2284             g_free(mon_fdset_fd->opaque);
2285             QLIST_REMOVE(mon_fdset_fd, next);
2286             g_free(mon_fdset_fd);
2287         }
2288     }
2289
2290     if (QLIST_EMPTY(&mon_fdset->fds) && QLIST_EMPTY(&mon_fdset->dup_fds)) {
2291         QLIST_REMOVE(mon_fdset, next);
2292         g_free(mon_fdset);
2293     }
2294 }
2295
2296 static void monitor_fdsets_cleanup(void)
2297 {
2298     MonFdset *mon_fdset;
2299     MonFdset *mon_fdset_next;
2300
2301     QLIST_FOREACH_SAFE(mon_fdset, &mon_fdsets, next, mon_fdset_next) {
2302         monitor_fdset_cleanup(mon_fdset);
2303     }
2304 }
2305
2306 AddfdInfo *qmp_add_fd(bool has_fdset_id, int64_t fdset_id, bool has_opaque,
2307                       const char *opaque, Error **errp)
2308 {
2309     int fd;
2310     Monitor *mon = cur_mon;
2311     AddfdInfo *fdinfo;
2312
2313     fd = qemu_chr_fe_get_msgfd(mon->chr);
2314     if (fd == -1) {
2315         error_set(errp, QERR_FD_NOT_SUPPLIED);
2316         goto error;
2317     }
2318
2319     fdinfo = monitor_fdset_add_fd(fd, has_fdset_id, fdset_id,
2320                                   has_opaque, opaque, errp);
2321     if (fdinfo) {
2322         return fdinfo;
2323     }
2324
2325 error:
2326     if (fd != -1) {
2327         close(fd);
2328     }
2329     return NULL;
2330 }
2331
2332 void qmp_remove_fd(int64_t fdset_id, bool has_fd, int64_t fd, Error **errp)
2333 {
2334     MonFdset *mon_fdset;
2335     MonFdsetFd *mon_fdset_fd;
2336     char fd_str[60];
2337
2338     QLIST_FOREACH(mon_fdset, &mon_fdsets, next) {
2339         if (mon_fdset->id != fdset_id) {
2340             continue;
2341         }
2342         QLIST_FOREACH(mon_fdset_fd, &mon_fdset->fds, next) {
2343             if (has_fd) {
2344                 if (mon_fdset_fd->fd != fd) {
2345                     continue;
2346                 }
2347                 mon_fdset_fd->removed = true;
2348                 break;
2349             } else {
2350                 mon_fdset_fd->removed = true;
2351             }
2352         }
2353         if (has_fd && !mon_fdset_fd) {
2354             goto error;
2355         }
2356         monitor_fdset_cleanup(mon_fdset);
2357         return;
2358     }
2359
2360 error:
2361     if (has_fd) {
2362         snprintf(fd_str, sizeof(fd_str), "fdset-id:%" PRId64 ", fd:%" PRId64,
2363                  fdset_id, fd);
2364     } else {
2365         snprintf(fd_str, sizeof(fd_str), "fdset-id:%" PRId64, fdset_id);
2366     }
2367     error_set(errp, QERR_FD_NOT_FOUND, fd_str);
2368 }
2369
2370 FdsetInfoList *qmp_query_fdsets(Error **errp)
2371 {
2372     MonFdset *mon_fdset;
2373     MonFdsetFd *mon_fdset_fd;
2374     FdsetInfoList *fdset_list = NULL;
2375
2376     QLIST_FOREACH(mon_fdset, &mon_fdsets, next) {
2377         FdsetInfoList *fdset_info = g_malloc0(sizeof(*fdset_info));
2378         FdsetFdInfoList *fdsetfd_list = NULL;
2379
2380         fdset_info->value = g_malloc0(sizeof(*fdset_info->value));
2381         fdset_info->value->fdset_id = mon_fdset->id;
2382
2383         QLIST_FOREACH(mon_fdset_fd, &mon_fdset->fds, next) {
2384             FdsetFdInfoList *fdsetfd_info;
2385
2386             fdsetfd_info = g_malloc0(sizeof(*fdsetfd_info));
2387             fdsetfd_info->value = g_malloc0(sizeof(*fdsetfd_info->value));
2388             fdsetfd_info->value->fd = mon_fdset_fd->fd;
2389             if (mon_fdset_fd->opaque) {
2390                 fdsetfd_info->value->has_opaque = true;
2391                 fdsetfd_info->value->opaque = g_strdup(mon_fdset_fd->opaque);
2392             } else {
2393                 fdsetfd_info->value->has_opaque = false;
2394             }
2395
2396             fdsetfd_info->next = fdsetfd_list;
2397             fdsetfd_list = fdsetfd_info;
2398         }
2399
2400         fdset_info->value->fds = fdsetfd_list;
2401
2402         fdset_info->next = fdset_list;
2403         fdset_list = fdset_info;
2404     }
2405
2406     return fdset_list;
2407 }
2408
2409 AddfdInfo *monitor_fdset_add_fd(int fd, bool has_fdset_id, int64_t fdset_id,
2410                                 bool has_opaque, const char *opaque,
2411                                 Error **errp)
2412 {
2413     MonFdset *mon_fdset = NULL;
2414     MonFdsetFd *mon_fdset_fd;
2415     AddfdInfo *fdinfo;
2416
2417     if (has_fdset_id) {
2418         QLIST_FOREACH(mon_fdset, &mon_fdsets, next) {
2419             /* Break if match found or match impossible due to ordering by ID */
2420             if (fdset_id <= mon_fdset->id) {
2421                 if (fdset_id < mon_fdset->id) {
2422                     mon_fdset = NULL;
2423                 }
2424                 break;
2425             }
2426         }
2427     }
2428
2429     if (mon_fdset == NULL) {
2430         int64_t fdset_id_prev = -1;
2431         MonFdset *mon_fdset_cur = QLIST_FIRST(&mon_fdsets);
2432
2433         if (has_fdset_id) {
2434             if (fdset_id < 0) {
2435                 error_set(errp, QERR_INVALID_PARAMETER_VALUE, "fdset-id",
2436                           "a non-negative value");
2437                 return NULL;
2438             }
2439             /* Use specified fdset ID */
2440             QLIST_FOREACH(mon_fdset, &mon_fdsets, next) {
2441                 mon_fdset_cur = mon_fdset;
2442                 if (fdset_id < mon_fdset_cur->id) {
2443                     break;
2444                 }
2445             }
2446         } else {
2447             /* Use first available fdset ID */
2448             QLIST_FOREACH(mon_fdset, &mon_fdsets, next) {
2449                 mon_fdset_cur = mon_fdset;
2450                 if (fdset_id_prev == mon_fdset_cur->id - 1) {
2451                     fdset_id_prev = mon_fdset_cur->id;
2452                     continue;
2453                 }
2454                 break;
2455             }
2456         }
2457
2458         mon_fdset = g_malloc0(sizeof(*mon_fdset));
2459         if (has_fdset_id) {
2460             mon_fdset->id = fdset_id;
2461         } else {
2462             mon_fdset->id = fdset_id_prev + 1;
2463         }
2464
2465         /* The fdset list is ordered by fdset ID */
2466         if (!mon_fdset_cur) {
2467             QLIST_INSERT_HEAD(&mon_fdsets, mon_fdset, next);
2468         } else if (mon_fdset->id < mon_fdset_cur->id) {
2469             QLIST_INSERT_BEFORE(mon_fdset_cur, mon_fdset, next);
2470         } else {
2471             QLIST_INSERT_AFTER(mon_fdset_cur, mon_fdset, next);
2472         }
2473     }
2474
2475     mon_fdset_fd = g_malloc0(sizeof(*mon_fdset_fd));
2476     mon_fdset_fd->fd = fd;
2477     mon_fdset_fd->removed = false;
2478     if (has_opaque) {
2479         mon_fdset_fd->opaque = g_strdup(opaque);
2480     }
2481     QLIST_INSERT_HEAD(&mon_fdset->fds, mon_fdset_fd, next);
2482
2483     fdinfo = g_malloc0(sizeof(*fdinfo));
2484     fdinfo->fdset_id = mon_fdset->id;
2485     fdinfo->fd = mon_fdset_fd->fd;
2486
2487     return fdinfo;
2488 }
2489
2490 int monitor_fdset_get_fd(int64_t fdset_id, int flags)
2491 {
2492 #ifndef _WIN32
2493     MonFdset *mon_fdset;
2494     MonFdsetFd *mon_fdset_fd;
2495     int mon_fd_flags;
2496
2497     QLIST_FOREACH(mon_fdset, &mon_fdsets, next) {
2498         if (mon_fdset->id != fdset_id) {
2499             continue;
2500         }
2501         QLIST_FOREACH(mon_fdset_fd, &mon_fdset->fds, next) {
2502             mon_fd_flags = fcntl(mon_fdset_fd->fd, F_GETFL);
2503             if (mon_fd_flags == -1) {
2504                 return -1;
2505             }
2506
2507             if ((flags & O_ACCMODE) == (mon_fd_flags & O_ACCMODE)) {
2508                 return mon_fdset_fd->fd;
2509             }
2510         }
2511         errno = EACCES;
2512         return -1;
2513     }
2514 #endif
2515
2516     errno = ENOENT;
2517     return -1;
2518 }
2519
2520 int monitor_fdset_dup_fd_add(int64_t fdset_id, int dup_fd)
2521 {
2522     MonFdset *mon_fdset;
2523     MonFdsetFd *mon_fdset_fd_dup;
2524
2525     QLIST_FOREACH(mon_fdset, &mon_fdsets, next) {
2526         if (mon_fdset->id != fdset_id) {
2527             continue;
2528         }
2529         QLIST_FOREACH(mon_fdset_fd_dup, &mon_fdset->dup_fds, next) {
2530             if (mon_fdset_fd_dup->fd == dup_fd) {
2531                 return -1;
2532             }
2533         }
2534         mon_fdset_fd_dup = g_malloc0(sizeof(*mon_fdset_fd_dup));
2535         mon_fdset_fd_dup->fd = dup_fd;
2536         QLIST_INSERT_HEAD(&mon_fdset->dup_fds, mon_fdset_fd_dup, next);
2537         return 0;
2538     }
2539     return -1;
2540 }
2541
2542 static int monitor_fdset_dup_fd_find_remove(int dup_fd, bool remove)
2543 {
2544     MonFdset *mon_fdset;
2545     MonFdsetFd *mon_fdset_fd_dup;
2546
2547     QLIST_FOREACH(mon_fdset, &mon_fdsets, next) {
2548         QLIST_FOREACH(mon_fdset_fd_dup, &mon_fdset->dup_fds, next) {
2549             if (mon_fdset_fd_dup->fd == dup_fd) {
2550                 if (remove) {
2551                     QLIST_REMOVE(mon_fdset_fd_dup, next);
2552                     if (QLIST_EMPTY(&mon_fdset->dup_fds)) {
2553                         monitor_fdset_cleanup(mon_fdset);
2554                     }
2555                     return -1;
2556                 } else {
2557                     return mon_fdset->id;
2558                 }
2559             }
2560         }
2561     }
2562     return -1;
2563 }
2564
2565 int monitor_fdset_dup_fd_find(int dup_fd)
2566 {
2567     return monitor_fdset_dup_fd_find_remove(dup_fd, false);
2568 }
2569
2570 void monitor_fdset_dup_fd_remove(int dup_fd)
2571 {
2572     monitor_fdset_dup_fd_find_remove(dup_fd, true);
2573 }
2574
2575 int monitor_fd_param(Monitor *mon, const char *fdname, Error **errp)
2576 {
2577     int fd;
2578     Error *local_err = NULL;
2579
2580     if (!qemu_isdigit(fdname[0]) && mon) {
2581         fd = monitor_get_fd(mon, fdname, &local_err);
2582     } else {
2583         fd = qemu_parse_fd(fdname);
2584         if (fd == -1) {
2585             error_setg(&local_err, "Invalid file descriptor number '%s'",
2586                        fdname);
2587         }
2588     }
2589     if (local_err) {
2590         error_propagate(errp, local_err);
2591         assert(fd == -1);
2592     } else {
2593         assert(fd != -1);
2594     }
2595
2596     return fd;
2597 }
2598
2599 /* Please update hmp-commands.hx when adding or changing commands */
2600 static mon_cmd_t info_cmds[] = {
2601     {
2602         .name       = "version",
2603         .args_type  = "",
2604         .params     = "",
2605         .help       = "show the version of QEMU",
2606         .mhandler.cmd = hmp_info_version,
2607     },
2608     {
2609         .name       = "network",
2610         .args_type  = "",
2611         .params     = "",
2612         .help       = "show the network state",
2613         .mhandler.cmd = hmp_info_network,
2614     },
2615     {
2616         .name       = "chardev",
2617         .args_type  = "",
2618         .params     = "",
2619         .help       = "show the character devices",
2620         .mhandler.cmd = hmp_info_chardev,
2621     },
2622     {
2623         .name       = "block",
2624         .args_type  = "nodes:-n,verbose:-v,device:B?",
2625         .params     = "[-n] [-v] [device]",
2626         .help       = "show info of one block device or all block devices "
2627                       "(-n: show named nodes; -v: show details)",
2628         .mhandler.cmd = hmp_info_block,
2629     },
2630     {
2631         .name       = "blockstats",
2632         .args_type  = "",
2633         .params     = "",
2634         .help       = "show block device statistics",
2635         .mhandler.cmd = hmp_info_blockstats,
2636     },
2637     {
2638         .name       = "block-jobs",
2639         .args_type  = "",
2640         .params     = "",
2641         .help       = "show progress of ongoing block device operations",
2642         .mhandler.cmd = hmp_info_block_jobs,
2643     },
2644     {
2645         .name       = "registers",
2646         .args_type  = "",
2647         .params     = "",
2648         .help       = "show the cpu registers",
2649         .mhandler.cmd = hmp_info_registers,
2650     },
2651     {
2652         .name       = "cpus",
2653         .args_type  = "",
2654         .params     = "",
2655         .help       = "show infos for each CPU",
2656         .mhandler.cmd = hmp_info_cpus,
2657     },
2658     {
2659         .name       = "history",
2660         .args_type  = "",
2661         .params     = "",
2662         .help       = "show the command line history",
2663         .mhandler.cmd = hmp_info_history,
2664     },
2665 #if defined(TARGET_I386) || defined(TARGET_PPC) || defined(TARGET_MIPS) || \
2666     defined(TARGET_LM32) || (defined(TARGET_SPARC) && !defined(TARGET_SPARC64))
2667     {
2668         .name       = "irq",
2669         .args_type  = "",
2670         .params     = "",
2671         .help       = "show the interrupts statistics (if available)",
2672 #ifdef TARGET_SPARC
2673         .mhandler.cmd = sun4m_hmp_info_irq,
2674 #elif defined(TARGET_LM32)
2675         .mhandler.cmd = lm32_hmp_info_irq,
2676 #else
2677         .mhandler.cmd = hmp_info_irq,
2678 #endif
2679     },
2680     {
2681         .name       = "pic",
2682         .args_type  = "",
2683         .params     = "",
2684         .help       = "show i8259 (PIC) state",
2685 #ifdef TARGET_SPARC
2686         .mhandler.cmd = sun4m_hmp_info_pic,
2687 #elif defined(TARGET_LM32)
2688         .mhandler.cmd = lm32_hmp_info_pic,
2689 #else
2690         .mhandler.cmd = hmp_info_pic,
2691 #endif
2692     },
2693 #endif
2694     {
2695         .name       = "pci",
2696         .args_type  = "",
2697         .params     = "",
2698         .help       = "show PCI info",
2699         .mhandler.cmd = hmp_info_pci,
2700     },
2701 #if defined(TARGET_I386) || defined(TARGET_SH4) || defined(TARGET_SPARC) || \
2702     defined(TARGET_PPC) || defined(TARGET_XTENSA)
2703     {
2704         .name       = "tlb",
2705         .args_type  = "",
2706         .params     = "",
2707         .help       = "show virtual to physical memory mappings",
2708         .mhandler.cmd = hmp_info_tlb,
2709     },
2710 #endif
2711 #if defined(TARGET_I386)
2712     {
2713         .name       = "mem",
2714         .args_type  = "",
2715         .params     = "",
2716         .help       = "show the active virtual memory mappings",
2717         .mhandler.cmd = hmp_info_mem,
2718     },
2719 #endif
2720     {
2721         .name       = "mtree",
2722         .args_type  = "",
2723         .params     = "",
2724         .help       = "show memory tree",
2725         .mhandler.cmd = hmp_info_mtree,
2726     },
2727     {
2728         .name       = "jit",
2729         .args_type  = "",
2730         .params     = "",
2731         .help       = "show dynamic compiler info",
2732         .mhandler.cmd = hmp_info_jit,
2733     },
2734     {
2735         .name       = "opcount",
2736         .args_type  = "",
2737         .params     = "",
2738         .help       = "show dynamic compiler opcode counters",
2739         .mhandler.cmd = hmp_info_opcount,
2740     },
2741     {
2742         .name       = "kvm",
2743         .args_type  = "",
2744         .params     = "",
2745         .help       = "show KVM information",
2746         .mhandler.cmd = hmp_info_kvm,
2747     },
2748     {
2749         .name       = "numa",
2750         .args_type  = "",
2751         .params     = "",
2752         .help       = "show NUMA information",
2753         .mhandler.cmd = hmp_info_numa,
2754     },
2755     {
2756         .name       = "usb",
2757         .args_type  = "",
2758         .params     = "",
2759         .help       = "show guest USB devices",
2760         .mhandler.cmd = hmp_info_usb,
2761     },
2762     {
2763         .name       = "usbhost",
2764         .args_type  = "",
2765         .params     = "",
2766         .help       = "show host USB devices",
2767         .mhandler.cmd = hmp_info_usbhost,
2768     },
2769     {
2770         .name       = "profile",
2771         .args_type  = "",
2772         .params     = "",
2773         .help       = "show profiling information",
2774         .mhandler.cmd = hmp_info_profile,
2775     },
2776     {
2777         .name       = "capture",
2778         .args_type  = "",
2779         .params     = "",
2780         .help       = "show capture information",
2781         .mhandler.cmd = hmp_info_capture,
2782     },
2783     {
2784         .name       = "snapshots",
2785         .args_type  = "",
2786         .params     = "",
2787         .help       = "show the currently saved VM snapshots",
2788         .mhandler.cmd = hmp_info_snapshots,
2789     },
2790     {
2791         .name       = "status",
2792         .args_type  = "",
2793         .params     = "",
2794         .help       = "show the current VM status (running|paused)",
2795         .mhandler.cmd = hmp_info_status,
2796     },
2797     {
2798         .name       = "mice",
2799         .args_type  = "",
2800         .params     = "",
2801         .help       = "show which guest mouse is receiving events",
2802         .mhandler.cmd = hmp_info_mice,
2803     },
2804     {
2805         .name       = "vnc",
2806         .args_type  = "",
2807         .params     = "",
2808         .help       = "show the vnc server status",
2809         .mhandler.cmd = hmp_info_vnc,
2810     },
2811 #if defined(CONFIG_SPICE)
2812     {
2813         .name       = "spice",
2814         .args_type  = "",
2815         .params     = "",
2816         .help       = "show the spice server status",
2817         .mhandler.cmd = hmp_info_spice,
2818     },
2819 #endif
2820     {
2821         .name       = "name",
2822         .args_type  = "",
2823         .params     = "",
2824         .help       = "show the current VM name",
2825         .mhandler.cmd = hmp_info_name,
2826     },
2827     {
2828         .name       = "uuid",
2829         .args_type  = "",
2830         .params     = "",
2831         .help       = "show the current VM UUID",
2832         .mhandler.cmd = hmp_info_uuid,
2833     },
2834     {
2835         .name       = "cpustats",
2836         .args_type  = "",
2837         .params     = "",
2838         .help       = "show CPU statistics",
2839         .mhandler.cmd = hmp_info_cpustats,
2840     },
2841 #if defined(CONFIG_SLIRP)
2842     {
2843         .name       = "usernet",
2844         .args_type  = "",
2845         .params     = "",
2846         .help       = "show user network stack connection states",
2847         .mhandler.cmd = hmp_info_usernet,
2848     },
2849 #endif
2850     {
2851         .name       = "migrate",
2852         .args_type  = "",
2853         .params     = "",
2854         .help       = "show migration status",
2855         .mhandler.cmd = hmp_info_migrate,
2856     },
2857     {
2858         .name       = "migrate_capabilities",
2859         .args_type  = "",
2860         .params     = "",
2861         .help       = "show current migration capabilities",
2862         .mhandler.cmd = hmp_info_migrate_capabilities,
2863     },
2864     {
2865         .name       = "migrate_cache_size",
2866         .args_type  = "",
2867         .params     = "",
2868         .help       = "show current migration xbzrle cache size",
2869         .mhandler.cmd = hmp_info_migrate_cache_size,
2870     },
2871     {
2872         .name       = "balloon",
2873         .args_type  = "",
2874         .params     = "",
2875         .help       = "show balloon information",
2876         .mhandler.cmd = hmp_info_balloon,
2877     },
2878     {
2879         .name       = "qtree",
2880         .args_type  = "",
2881         .params     = "",
2882         .help       = "show device tree",
2883         .mhandler.cmd = hmp_info_qtree,
2884     },
2885     {
2886         .name       = "qdm",
2887         .args_type  = "",
2888         .params     = "",
2889         .help       = "show qdev device model list",
2890         .mhandler.cmd = hmp_info_qdm,
2891     },
2892     {
2893         .name       = "qom-tree",
2894         .args_type  = "path:s?",
2895         .params     = "[path]",
2896         .help       = "show QOM composition tree",
2897         .mhandler.cmd = hmp_info_qom_tree,
2898     },
2899     {
2900         .name       = "roms",
2901         .args_type  = "",
2902         .params     = "",
2903         .help       = "show roms",
2904         .mhandler.cmd = hmp_info_roms,
2905     },
2906     {
2907         .name       = "trace-events",
2908         .args_type  = "",
2909         .params     = "",
2910         .help       = "show available trace-events & their state",
2911         .mhandler.cmd = hmp_info_trace_events,
2912     },
2913     {
2914         .name       = "tpm",
2915         .args_type  = "",
2916         .params     = "",
2917         .help       = "show the TPM device",
2918         .mhandler.cmd = hmp_info_tpm,
2919     },
2920     {
2921         .name       = "memdev",
2922         .args_type  = "",
2923         .params     = "",
2924         .help       = "show memory backends",
2925         .mhandler.cmd = hmp_info_memdev,
2926     },
2927     {
2928         .name       = "memory-devices",
2929         .args_type  = "",
2930         .params     = "",
2931         .help       = "show memory devices",
2932         .mhandler.cmd = hmp_info_memory_devices,
2933     },
2934     {
2935         .name       = NULL,
2936     },
2937 };
2938
2939 /* mon_cmds and info_cmds would be sorted at runtime */
2940 static mon_cmd_t mon_cmds[] = {
2941 #include "hmp-commands.h"
2942     { NULL, NULL, },
2943 };
2944
2945 static const mon_cmd_t qmp_cmds[] = {
2946 #include "qmp-commands-old.h"
2947     { /* NULL */ },
2948 };
2949
2950 /*******************************************************************/
2951
2952 static const char *pch;
2953 static sigjmp_buf expr_env;
2954
2955 #define MD_TLONG 0
2956 #define MD_I32   1
2957
2958 typedef struct MonitorDef {
2959     const char *name;
2960     int offset;
2961     target_long (*get_value)(const struct MonitorDef *md, int val);
2962     int type;
2963 } MonitorDef;
2964
2965 #if defined(TARGET_I386)
2966 static target_long monitor_get_pc (const struct MonitorDef *md, int val)
2967 {
2968     CPUArchState *env = mon_get_cpu();
2969     return env->eip + env->segs[R_CS].base;
2970 }
2971 #endif
2972
2973 #if defined(TARGET_PPC)
2974 static target_long monitor_get_ccr (const struct MonitorDef *md, int val)
2975 {
2976     CPUArchState *env = mon_get_cpu();
2977     unsigned int u;
2978     int i;
2979
2980     u = 0;
2981     for (i = 0; i < 8; i++)
2982         u |= env->crf[i] << (32 - (4 * (i + 1)));
2983
2984     return u;
2985 }
2986
2987 static target_long monitor_get_msr (const struct MonitorDef *md, int val)
2988 {
2989     CPUArchState *env = mon_get_cpu();
2990     return env->msr;
2991 }
2992
2993 static target_long monitor_get_xer (const struct MonitorDef *md, int val)
2994 {
2995     CPUArchState *env = mon_get_cpu();
2996     return env->xer;
2997 }
2998
2999 static target_long monitor_get_decr (const struct MonitorDef *md, int val)
3000 {
3001     CPUArchState *env = mon_get_cpu();
3002     return cpu_ppc_load_decr(env);
3003 }
3004
3005 static target_long monitor_get_tbu (const struct MonitorDef *md, int val)
3006 {
3007     CPUArchState *env = mon_get_cpu();
3008     return cpu_ppc_load_tbu(env);
3009 }
3010
3011 static target_long monitor_get_tbl (const struct MonitorDef *md, int val)
3012 {
3013     CPUArchState *env = mon_get_cpu();
3014     return cpu_ppc_load_tbl(env);
3015 }
3016 #endif
3017
3018 #if defined(TARGET_SPARC)
3019 #ifndef TARGET_SPARC64
3020 static target_long monitor_get_psr (const struct MonitorDef *md, int val)
3021 {
3022     CPUArchState *env = mon_get_cpu();
3023
3024     return cpu_get_psr(env);
3025 }
3026 #endif
3027
3028 static target_long monitor_get_reg(const struct MonitorDef *md, int val)
3029 {
3030     CPUArchState *env = mon_get_cpu();
3031     return env->regwptr[val];
3032 }
3033 #endif
3034
3035 static const MonitorDef monitor_defs[] = {
3036 #ifdef TARGET_I386
3037
3038 #define SEG(name, seg) \
3039     { name, offsetof(CPUX86State, segs[seg].selector), NULL, MD_I32 },\
3040     { name ".base", offsetof(CPUX86State, segs[seg].base) },\
3041     { name ".limit", offsetof(CPUX86State, segs[seg].limit), NULL, MD_I32 },
3042
3043     { "eax", offsetof(CPUX86State, regs[0]) },
3044     { "ecx", offsetof(CPUX86State, regs[1]) },
3045     { "edx", offsetof(CPUX86State, regs[2]) },
3046     { "ebx", offsetof(CPUX86State, regs[3]) },
3047     { "esp|sp", offsetof(CPUX86State, regs[4]) },
3048     { "ebp|fp", offsetof(CPUX86State, regs[5]) },
3049     { "esi", offsetof(CPUX86State, regs[6]) },
3050     { "edi", offsetof(CPUX86State, regs[7]) },
3051 #ifdef TARGET_X86_64
3052     { "r8", offsetof(CPUX86State, regs[8]) },
3053     { "r9", offsetof(CPUX86State, regs[9]) },
3054     { "r10", offsetof(CPUX86State, regs[10]) },
3055     { "r11", offsetof(CPUX86State, regs[11]) },
3056     { "r12", offsetof(CPUX86State, regs[12]) },
3057     { "r13", offsetof(CPUX86State, regs[13]) },
3058     { "r14", offsetof(CPUX86State, regs[14]) },
3059     { "r15", offsetof(CPUX86State, regs[15]) },
3060 #endif
3061     { "eflags", offsetof(CPUX86State, eflags) },
3062     { "eip", offsetof(CPUX86State, eip) },
3063     SEG("cs", R_CS)
3064     SEG("ds", R_DS)
3065     SEG("es", R_ES)
3066     SEG("ss", R_SS)
3067     SEG("fs", R_FS)
3068     SEG("gs", R_GS)
3069     { "pc", 0, monitor_get_pc, },
3070 #elif defined(TARGET_PPC)
3071     /* General purpose registers */
3072     { "r0", offsetof(CPUPPCState, gpr[0]) },
3073     { "r1", offsetof(CPUPPCState, gpr[1]) },
3074     { "r2", offsetof(CPUPPCState, gpr[2]) },
3075     { "r3", offsetof(CPUPPCState, gpr[3]) },
3076     { "r4", offsetof(CPUPPCState, gpr[4]) },
3077     { "r5", offsetof(CPUPPCState, gpr[5]) },
3078     { "r6", offsetof(CPUPPCState, gpr[6]) },
3079     { "r7", offsetof(CPUPPCState, gpr[7]) },
3080     { "r8", offsetof(CPUPPCState, gpr[8]) },
3081     { "r9", offsetof(CPUPPCState, gpr[9]) },
3082     { "r10", offsetof(CPUPPCState, gpr[10]) },
3083     { "r11", offsetof(CPUPPCState, gpr[11]) },
3084     { "r12", offsetof(CPUPPCState, gpr[12]) },
3085     { "r13", offsetof(CPUPPCState, gpr[13]) },
3086     { "r14", offsetof(CPUPPCState, gpr[14]) },
3087     { "r15", offsetof(CPUPPCState, gpr[15]) },
3088     { "r16", offsetof(CPUPPCState, gpr[16]) },
3089     { "r17", offsetof(CPUPPCState, gpr[17]) },
3090     { "r18", offsetof(CPUPPCState, gpr[18]) },
3091     { "r19", offsetof(CPUPPCState, gpr[19]) },
3092     { "r20", offsetof(CPUPPCState, gpr[20]) },
3093     { "r21", offsetof(CPUPPCState, gpr[21]) },
3094     { "r22", offsetof(CPUPPCState, gpr[22]) },
3095     { "r23", offsetof(CPUPPCState, gpr[23]) },
3096     { "r24", offsetof(CPUPPCState, gpr[24]) },
3097     { "r25", offsetof(CPUPPCState, gpr[25]) },
3098     { "r26", offsetof(CPUPPCState, gpr[26]) },
3099     { "r27", offsetof(CPUPPCState, gpr[27]) },
3100     { "r28", offsetof(CPUPPCState, gpr[28]) },
3101     { "r29", offsetof(CPUPPCState, gpr[29]) },
3102     { "r30", offsetof(CPUPPCState, gpr[30]) },
3103     { "r31", offsetof(CPUPPCState, gpr[31]) },
3104     /* Floating point registers */
3105     { "f0", offsetof(CPUPPCState, fpr[0]) },
3106     { "f1", offsetof(CPUPPCState, fpr[1]) },
3107     { "f2", offsetof(CPUPPCState, fpr[2]) },
3108     { "f3", offsetof(CPUPPCState, fpr[3]) },
3109     { "f4", offsetof(CPUPPCState, fpr[4]) },
3110     { "f5", offsetof(CPUPPCState, fpr[5]) },
3111     { "f6", offsetof(CPUPPCState, fpr[6]) },
3112     { "f7", offsetof(CPUPPCState, fpr[7]) },
3113     { "f8", offsetof(CPUPPCState, fpr[8]) },
3114     { "f9", offsetof(CPUPPCState, fpr[9]) },
3115     { "f10", offsetof(CPUPPCState, fpr[10]) },
3116     { "f11", offsetof(CPUPPCState, fpr[11]) },
3117     { "f12", offsetof(CPUPPCState, fpr[12]) },
3118     { "f13", offsetof(CPUPPCState, fpr[13]) },
3119     { "f14", offsetof(CPUPPCState, fpr[14]) },
3120     { "f15", offsetof(CPUPPCState, fpr[15]) },
3121     { "f16", offsetof(CPUPPCState, fpr[16]) },
3122     { "f17", offsetof(CPUPPCState, fpr[17]) },
3123     { "f18", offsetof(CPUPPCState, fpr[18]) },
3124     { "f19", offsetof(CPUPPCState, fpr[19]) },
3125     { "f20", offsetof(CPUPPCState, fpr[20]) },
3126     { "f21", offsetof(CPUPPCState, fpr[21]) },
3127     { "f22", offsetof(CPUPPCState, fpr[22]) },
3128     { "f23", offsetof(CPUPPCState, fpr[23]) },
3129     { "f24", offsetof(CPUPPCState, fpr[24]) },
3130     { "f25", offsetof(CPUPPCState, fpr[25]) },
3131     { "f26", offsetof(CPUPPCState, fpr[26]) },
3132     { "f27", offsetof(CPUPPCState, fpr[27]) },
3133     { "f28", offsetof(CPUPPCState, fpr[28]) },
3134     { "f29", offsetof(CPUPPCState, fpr[29]) },
3135     { "f30", offsetof(CPUPPCState, fpr[30]) },
3136     { "f31", offsetof(CPUPPCState, fpr[31]) },
3137     { "fpscr", offsetof(CPUPPCState, fpscr) },
3138     /* Next instruction pointer */
3139     { "nip|pc", offsetof(CPUPPCState, nip) },
3140     { "lr", offsetof(CPUPPCState, lr) },
3141     { "ctr", offsetof(CPUPPCState, ctr) },
3142     { "decr", 0, &monitor_get_decr, },
3143     { "ccr", 0, &monitor_get_ccr, },
3144     /* Machine state register */
3145     { "msr", 0, &monitor_get_msr, },
3146     { "xer", 0, &monitor_get_xer, },
3147     { "tbu", 0, &monitor_get_tbu, },
3148     { "tbl", 0, &monitor_get_tbl, },
3149     /* Segment registers */
3150     { "sdr1", offsetof(CPUPPCState, spr[SPR_SDR1]) },
3151     { "sr0", offsetof(CPUPPCState, sr[0]) },
3152     { "sr1", offsetof(CPUPPCState, sr[1]) },
3153     { "sr2", offsetof(CPUPPCState, sr[2]) },
3154     { "sr3", offsetof(CPUPPCState, sr[3]) },
3155     { "sr4", offsetof(CPUPPCState, sr[4]) },
3156     { "sr5", offsetof(CPUPPCState, sr[5]) },
3157     { "sr6", offsetof(CPUPPCState, sr[6]) },
3158     { "sr7", offsetof(CPUPPCState, sr[7]) },
3159     { "sr8", offsetof(CPUPPCState, sr[8]) },
3160     { "sr9", offsetof(CPUPPCState, sr[9]) },
3161     { "sr10", offsetof(CPUPPCState, sr[10]) },
3162     { "sr11", offsetof(CPUPPCState, sr[11]) },
3163     { "sr12", offsetof(CPUPPCState, sr[12]) },
3164     { "sr13", offsetof(CPUPPCState, sr[13]) },
3165     { "sr14", offsetof(CPUPPCState, sr[14]) },
3166     { "sr15", offsetof(CPUPPCState, sr[15]) },
3167     /* Too lazy to put BATs... */
3168     { "pvr", offsetof(CPUPPCState, spr[SPR_PVR]) },
3169
3170     { "srr0", offsetof(CPUPPCState, spr[SPR_SRR0]) },
3171     { "srr1", offsetof(CPUPPCState, spr[SPR_SRR1]) },
3172     { "dar", offsetof(CPUPPCState, spr[SPR_DAR]) },
3173     { "dsisr", offsetof(CPUPPCState, spr[SPR_DSISR]) },
3174     { "cfar", offsetof(CPUPPCState, spr[SPR_CFAR]) },
3175     { "sprg0", offsetof(CPUPPCState, spr[SPR_SPRG0]) },
3176     { "sprg1", offsetof(CPUPPCState, spr[SPR_SPRG1]) },
3177     { "sprg2", offsetof(CPUPPCState, spr[SPR_SPRG2]) },
3178     { "sprg3", offsetof(CPUPPCState, spr[SPR_SPRG3]) },
3179     { "sprg4", offsetof(CPUPPCState, spr[SPR_SPRG4]) },
3180     { "sprg5", offsetof(CPUPPCState, spr[SPR_SPRG5]) },
3181     { "sprg6", offsetof(CPUPPCState, spr[SPR_SPRG6]) },
3182     { "sprg7", offsetof(CPUPPCState, spr[SPR_SPRG7]) },
3183     { "pid", offsetof(CPUPPCState, spr[SPR_BOOKE_PID]) },
3184     { "csrr0", offsetof(CPUPPCState, spr[SPR_BOOKE_CSRR0]) },
3185     { "csrr1", offsetof(CPUPPCState, spr[SPR_BOOKE_CSRR1]) },
3186     { "esr", offsetof(CPUPPCState, spr[SPR_BOOKE_ESR]) },
3187     { "dear", offsetof(CPUPPCState, spr[SPR_BOOKE_DEAR]) },
3188     { "mcsr", offsetof(CPUPPCState, spr[SPR_BOOKE_MCSR]) },
3189     { "tsr", offsetof(CPUPPCState, spr[SPR_BOOKE_TSR]) },
3190     { "tcr", offsetof(CPUPPCState, spr[SPR_BOOKE_TCR]) },
3191     { "vrsave", offsetof(CPUPPCState, spr[SPR_VRSAVE]) },
3192     { "pir", offsetof(CPUPPCState, spr[SPR_BOOKE_PIR]) },
3193     { "mcsrr0", offsetof(CPUPPCState, spr[SPR_BOOKE_MCSRR0]) },
3194     { "mcsrr1", offsetof(CPUPPCState, spr[SPR_BOOKE_MCSRR1]) },
3195     { "decar", offsetof(CPUPPCState, spr[SPR_BOOKE_DECAR]) },
3196     { "ivpr", offsetof(CPUPPCState, spr[SPR_BOOKE_IVPR]) },
3197     { "epcr", offsetof(CPUPPCState, spr[SPR_BOOKE_EPCR]) },
3198     { "sprg8", offsetof(CPUPPCState, spr[SPR_BOOKE_SPRG8]) },
3199     { "ivor0", offsetof(CPUPPCState, spr[SPR_BOOKE_IVOR0]) },
3200     { "ivor1", offsetof(CPUPPCState, spr[SPR_BOOKE_IVOR1]) },
3201     { "ivor2", offsetof(CPUPPCState, spr[SPR_BOOKE_IVOR2]) },
3202     { "ivor3", offsetof(CPUPPCState, spr[SPR_BOOKE_IVOR3]) },
3203     { "ivor4", offsetof(CPUPPCState, spr[SPR_BOOKE_IVOR4]) },
3204     { "ivor5", offsetof(CPUPPCState, spr[SPR_BOOKE_IVOR5]) },
3205     { "ivor6", offsetof(CPUPPCState, spr[SPR_BOOKE_IVOR6]) },
3206     { "ivor7", offsetof(CPUPPCState, spr[SPR_BOOKE_IVOR7]) },
3207     { "ivor8", offsetof(CPUPPCState, spr[SPR_BOOKE_IVOR8]) },
3208     { "ivor9", offsetof(CPUPPCState, spr[SPR_BOOKE_IVOR9]) },
3209     { "ivor10", offsetof(CPUPPCState, spr[SPR_BOOKE_IVOR10]) },
3210     { "ivor11", offsetof(CPUPPCState, spr[SPR_BOOKE_IVOR11]) },
3211     { "ivor12", offsetof(CPUPPCState, spr[SPR_BOOKE_IVOR12]) },
3212     { "ivor13", offsetof(CPUPPCState, spr[SPR_BOOKE_IVOR13]) },
3213     { "ivor14", offsetof(CPUPPCState, spr[SPR_BOOKE_IVOR14]) },
3214     { "ivor15", offsetof(CPUPPCState, spr[SPR_BOOKE_IVOR15]) },
3215     { "ivor32", offsetof(CPUPPCState, spr[SPR_BOOKE_IVOR32]) },
3216     { "ivor33", offsetof(CPUPPCState, spr[SPR_BOOKE_IVOR33]) },
3217     { "ivor34", offsetof(CPUPPCState, spr[SPR_BOOKE_IVOR34]) },
3218     { "ivor35", offsetof(CPUPPCState, spr[SPR_BOOKE_IVOR35]) },
3219     { "ivor36", offsetof(CPUPPCState, spr[SPR_BOOKE_IVOR36]) },
3220     { "ivor37", offsetof(CPUPPCState, spr[SPR_BOOKE_IVOR37]) },
3221     { "mas0", offsetof(CPUPPCState, spr[SPR_BOOKE_MAS0]) },
3222     { "mas1", offsetof(CPUPPCState, spr[SPR_BOOKE_MAS1]) },
3223     { "mas2", offsetof(CPUPPCState, spr[SPR_BOOKE_MAS2]) },
3224     { "mas3", offsetof(CPUPPCState, spr[SPR_BOOKE_MAS3]) },
3225     { "mas4", offsetof(CPUPPCState, spr[SPR_BOOKE_MAS4]) },
3226     { "mas6", offsetof(CPUPPCState, spr[SPR_BOOKE_MAS6]) },
3227     { "mas7", offsetof(CPUPPCState, spr[SPR_BOOKE_MAS7]) },
3228     { "mmucfg", offsetof(CPUPPCState, spr[SPR_MMUCFG]) },
3229     { "tlb0cfg", offsetof(CPUPPCState, spr[SPR_BOOKE_TLB0CFG]) },
3230     { "tlb1cfg", offsetof(CPUPPCState, spr[SPR_BOOKE_TLB1CFG]) },
3231     { "epr", offsetof(CPUPPCState, spr[SPR_BOOKE_EPR]) },
3232     { "eplc", offsetof(CPUPPCState, spr[SPR_BOOKE_EPLC]) },
3233     { "epsc", offsetof(CPUPPCState, spr[SPR_BOOKE_EPSC]) },
3234     { "svr", offsetof(CPUPPCState, spr[SPR_E500_SVR]) },
3235     { "mcar", offsetof(CPUPPCState, spr[SPR_Exxx_MCAR]) },
3236     { "pid1", offsetof(CPUPPCState, spr[SPR_BOOKE_PID1]) },
3237     { "pid2", offsetof(CPUPPCState, spr[SPR_BOOKE_PID2]) },
3238     { "hid0", offsetof(CPUPPCState, spr[SPR_HID0]) },
3239
3240 #elif defined(TARGET_SPARC)
3241     { "g0", offsetof(CPUSPARCState, gregs[0]) },
3242     { "g1", offsetof(CPUSPARCState, gregs[1]) },
3243     { "g2", offsetof(CPUSPARCState, gregs[2]) },
3244     { "g3", offsetof(CPUSPARCState, gregs[3]) },
3245     { "g4", offsetof(CPUSPARCState, gregs[4]) },
3246     { "g5", offsetof(CPUSPARCState, gregs[5]) },
3247     { "g6", offsetof(CPUSPARCState, gregs[6]) },
3248     { "g7", offsetof(CPUSPARCState, gregs[7]) },
3249     { "o0", 0, monitor_get_reg },
3250     { "o1", 1, monitor_get_reg },
3251     { "o2", 2, monitor_get_reg },
3252     { "o3", 3, monitor_get_reg },
3253     { "o4", 4, monitor_get_reg },
3254     { "o5", 5, monitor_get_reg },
3255     { "o6", 6, monitor_get_reg },
3256     { "o7", 7, monitor_get_reg },
3257     { "l0", 8, monitor_get_reg },
3258     { "l1", 9, monitor_get_reg },
3259     { "l2", 10, monitor_get_reg },
3260     { "l3", 11, monitor_get_reg },
3261     { "l4", 12, monitor_get_reg },
3262     { "l5", 13, monitor_get_reg },
3263     { "l6", 14, monitor_get_reg },
3264     { "l7", 15, monitor_get_reg },
3265     { "i0", 16, monitor_get_reg },
3266     { "i1", 17, monitor_get_reg },
3267     { "i2", 18, monitor_get_reg },
3268     { "i3", 19, monitor_get_reg },
3269     { "i4", 20, monitor_get_reg },
3270     { "i5", 21, monitor_get_reg },
3271     { "i6", 22, monitor_get_reg },
3272     { "i7", 23, monitor_get_reg },
3273     { "pc", offsetof(CPUSPARCState, pc) },
3274     { "npc", offsetof(CPUSPARCState, npc) },
3275     { "y", offsetof(CPUSPARCState, y) },
3276 #ifndef TARGET_SPARC64
3277     { "psr", 0, &monitor_get_psr, },
3278     { "wim", offsetof(CPUSPARCState, wim) },
3279 #endif
3280     { "tbr", offsetof(CPUSPARCState, tbr) },
3281     { "fsr", offsetof(CPUSPARCState, fsr) },
3282     { "f0", offsetof(CPUSPARCState, fpr[0].l.upper) },
3283     { "f1", offsetof(CPUSPARCState, fpr[0].l.lower) },
3284     { "f2", offsetof(CPUSPARCState, fpr[1].l.upper) },
3285     { "f3", offsetof(CPUSPARCState, fpr[1].l.lower) },
3286     { "f4", offsetof(CPUSPARCState, fpr[2].l.upper) },
3287     { "f5", offsetof(CPUSPARCState, fpr[2].l.lower) },
3288     { "f6", offsetof(CPUSPARCState, fpr[3].l.upper) },
3289     { "f7", offsetof(CPUSPARCState, fpr[3].l.lower) },
3290     { "f8", offsetof(CPUSPARCState, fpr[4].l.upper) },
3291     { "f9", offsetof(CPUSPARCState, fpr[4].l.lower) },
3292     { "f10", offsetof(CPUSPARCState, fpr[5].l.upper) },
3293     { "f11", offsetof(CPUSPARCState, fpr[5].l.lower) },
3294     { "f12", offsetof(CPUSPARCState, fpr[6].l.upper) },
3295     { "f13", offsetof(CPUSPARCState, fpr[6].l.lower) },
3296     { "f14", offsetof(CPUSPARCState, fpr[7].l.upper) },
3297     { "f15", offsetof(CPUSPARCState, fpr[7].l.lower) },
3298     { "f16", offsetof(CPUSPARCState, fpr[8].l.upper) },
3299     { "f17", offsetof(CPUSPARCState, fpr[8].l.lower) },
3300     { "f18", offsetof(CPUSPARCState, fpr[9].l.upper) },
3301     { "f19", offsetof(CPUSPARCState, fpr[9].l.lower) },
3302     { "f20", offsetof(CPUSPARCState, fpr[10].l.upper) },
3303     { "f21", offsetof(CPUSPARCState, fpr[10].l.lower) },
3304     { "f22", offsetof(CPUSPARCState, fpr[11].l.upper) },
3305     { "f23", offsetof(CPUSPARCState, fpr[11].l.lower) },
3306     { "f24", offsetof(CPUSPARCState, fpr[12].l.upper) },
3307     { "f25", offsetof(CPUSPARCState, fpr[12].l.lower) },
3308     { "f26", offsetof(CPUSPARCState, fpr[13].l.upper) },
3309     { "f27", offsetof(CPUSPARCState, fpr[13].l.lower) },
3310     { "f28", offsetof(CPUSPARCState, fpr[14].l.upper) },
3311     { "f29", offsetof(CPUSPARCState, fpr[14].l.lower) },
3312     { "f30", offsetof(CPUSPARCState, fpr[15].l.upper) },
3313     { "f31", offsetof(CPUSPARCState, fpr[15].l.lower) },
3314 #ifdef TARGET_SPARC64
3315     { "f32", offsetof(CPUSPARCState, fpr[16]) },
3316     { "f34", offsetof(CPUSPARCState, fpr[17]) },
3317     { "f36", offsetof(CPUSPARCState, fpr[18]) },
3318     { "f38", offsetof(CPUSPARCState, fpr[19]) },
3319     { "f40", offsetof(CPUSPARCState, fpr[20]) },
3320     { "f42", offsetof(CPUSPARCState, fpr[21]) },
3321     { "f44", offsetof(CPUSPARCState, fpr[22]) },
3322     { "f46", offsetof(CPUSPARCState, fpr[23]) },
3323     { "f48", offsetof(CPUSPARCState, fpr[24]) },
3324     { "f50", offsetof(CPUSPARCState, fpr[25]) },
3325     { "f52", offsetof(CPUSPARCState, fpr[26]) },
3326     { "f54", offsetof(CPUSPARCState, fpr[27]) },
3327     { "f56", offsetof(CPUSPARCState, fpr[28]) },
3328     { "f58", offsetof(CPUSPARCState, fpr[29]) },
3329     { "f60", offsetof(CPUSPARCState, fpr[30]) },
3330     { "f62", offsetof(CPUSPARCState, fpr[31]) },
3331     { "asi", offsetof(CPUSPARCState, asi) },
3332     { "pstate", offsetof(CPUSPARCState, pstate) },
3333     { "cansave", offsetof(CPUSPARCState, cansave) },
3334     { "canrestore", offsetof(CPUSPARCState, canrestore) },
3335     { "otherwin", offsetof(CPUSPARCState, otherwin) },
3336     { "wstate", offsetof(CPUSPARCState, wstate) },
3337     { "cleanwin", offsetof(CPUSPARCState, cleanwin) },
3338     { "fprs", offsetof(CPUSPARCState, fprs) },
3339 #endif
3340 #endif
3341     { NULL },
3342 };
3343
3344 static void GCC_FMT_ATTR(2, 3) QEMU_NORETURN
3345 expr_error(Monitor *mon, const char *fmt, ...)
3346 {
3347     va_list ap;
3348     va_start(ap, fmt);
3349     monitor_vprintf(mon, fmt, ap);
3350     monitor_printf(mon, "\n");
3351     va_end(ap);
3352     siglongjmp(expr_env, 1);
3353 }
3354
3355 /* return 0 if OK, -1 if not found */
3356 static int get_monitor_def(target_long *pval, const char *name)
3357 {
3358     const MonitorDef *md;
3359     void *ptr;
3360
3361     for(md = monitor_defs; md->name != NULL; md++) {
3362         if (compare_cmd(name, md->name)) {
3363             if (md->get_value) {
3364                 *pval = md->get_value(md, md->offset);
3365             } else {
3366                 CPUArchState *env = mon_get_cpu();
3367                 ptr = (uint8_t *)env + md->offset;
3368                 switch(md->type) {
3369                 case MD_I32:
3370                     *pval = *(int32_t *)ptr;
3371                     break;
3372                 case MD_TLONG:
3373                     *pval = *(target_long *)ptr;
3374                     break;
3375                 default:
3376                     *pval = 0;
3377                     break;
3378                 }
3379             }
3380             return 0;
3381         }
3382     }
3383     return -1;
3384 }
3385
3386 static void next(void)
3387 {
3388     if (*pch != '\0') {
3389         pch++;
3390         while (qemu_isspace(*pch))
3391             pch++;
3392     }
3393 }
3394
3395 static int64_t expr_sum(Monitor *mon);
3396
3397 static int64_t expr_unary(Monitor *mon)
3398 {
3399     int64_t n;
3400     char *p;
3401     int ret;
3402
3403     switch(*pch) {
3404     case '+':
3405         next();
3406         n = expr_unary(mon);
3407         break;
3408     case '-':
3409         next();
3410         n = -expr_unary(mon);
3411         break;
3412     case '~':
3413         next();
3414         n = ~expr_unary(mon);
3415         break;
3416     case '(':
3417         next();
3418         n = expr_sum(mon);
3419         if (*pch != ')') {
3420             expr_error(mon, "')' expected");
3421         }
3422         next();
3423         break;
3424     case '\'':
3425         pch++;
3426         if (*pch == '\0')
3427             expr_error(mon, "character constant expected");
3428         n = *pch;
3429         pch++;
3430         if (*pch != '\'')
3431             expr_error(mon, "missing terminating \' character");
3432         next();
3433         break;
3434     case '$':
3435         {
3436             char buf[128], *q;
3437             target_long reg=0;
3438
3439             pch++;
3440             q = buf;
3441             while ((*pch >= 'a' && *pch <= 'z') ||
3442                    (*pch >= 'A' && *pch <= 'Z') ||
3443                    (*pch >= '0' && *pch <= '9') ||
3444                    *pch == '_' || *pch == '.') {
3445                 if ((q - buf) < sizeof(buf) - 1)
3446                     *q++ = *pch;
3447                 pch++;
3448             }
3449             while (qemu_isspace(*pch))
3450                 pch++;
3451             *q = 0;
3452             ret = get_monitor_def(&reg, buf);
3453             if (ret < 0)
3454                 expr_error(mon, "unknown register");
3455             n = reg;
3456         }
3457         break;
3458     case '\0':
3459         expr_error(mon, "unexpected end of expression");
3460         n = 0;
3461         break;
3462     default:
3463         errno = 0;
3464         n = strtoull(pch, &p, 0);
3465         if (errno == ERANGE) {
3466             expr_error(mon, "number too large");
3467         }
3468         if (pch == p) {
3469             expr_error(mon, "invalid char '%c' in expression", *p);
3470         }
3471         pch = p;
3472         while (qemu_isspace(*pch))
3473             pch++;
3474         break;
3475     }
3476     return n;
3477 }
3478
3479
3480 static int64_t expr_prod(Monitor *mon)
3481 {
3482     int64_t val, val2;
3483     int op;
3484
3485     val = expr_unary(mon);
3486     for(;;) {
3487         op = *pch;
3488         if (op != '*' && op != '/' && op != '%')
3489             break;
3490         next();
3491         val2 = expr_unary(mon);
3492         switch(op) {
3493         default:
3494         case '*':
3495             val *= val2;
3496             break;
3497         case '/':
3498         case '%':
3499             if (val2 == 0)
3500                 expr_error(mon, "division by zero");
3501             if (op == '/')
3502                 val /= val2;
3503             else
3504                 val %= val2;
3505             break;
3506         }
3507     }
3508     return val;
3509 }
3510
3511 static int64_t expr_logic(Monitor *mon)
3512 {
3513     int64_t val, val2;
3514     int op;
3515
3516     val = expr_prod(mon);
3517     for(;;) {
3518         op = *pch;
3519         if (op != '&' && op != '|' && op != '^')
3520             break;
3521         next();
3522         val2 = expr_prod(mon);
3523         switch(op) {
3524         default:
3525         case '&':
3526             val &= val2;
3527             break;
3528         case '|':
3529             val |= val2;
3530             break;
3531         case '^':
3532             val ^= val2;
3533             break;
3534         }
3535     }
3536     return val;
3537 }
3538
3539 static int64_t expr_sum(Monitor *mon)
3540 {
3541     int64_t val, val2;
3542     int op;
3543
3544     val = expr_logic(mon);
3545     for(;;) {
3546         op = *pch;
3547         if (op != '+' && op != '-')
3548             break;
3549         next();
3550         val2 = expr_logic(mon);
3551         if (op == '+')
3552             val += val2;
3553         else
3554             val -= val2;
3555     }
3556     return val;
3557 }
3558
3559 static int get_expr(Monitor *mon, int64_t *pval, const char **pp)
3560 {
3561     pch = *pp;
3562     if (sigsetjmp(expr_env, 0)) {
3563         *pp = pch;
3564         return -1;
3565     }
3566     while (qemu_isspace(*pch))
3567         pch++;
3568     *pval = expr_sum(mon);
3569     *pp = pch;
3570     return 0;
3571 }
3572
3573 static int get_double(Monitor *mon, double *pval, const char **pp)
3574 {
3575     const char *p = *pp;
3576     char *tailp;
3577     double d;
3578
3579     d = strtod(p, &tailp);
3580     if (tailp == p) {
3581         monitor_printf(mon, "Number expected\n");
3582         return -1;
3583     }
3584     if (d != d || d - d != 0) {
3585         /* NaN or infinity */
3586         monitor_printf(mon, "Bad number\n");
3587         return -1;
3588     }
3589     *pval = d;
3590     *pp = tailp;
3591     return 0;
3592 }
3593
3594 /*
3595  * Store the command-name in cmdname, and return a pointer to
3596  * the remaining of the command string.
3597  */
3598 static const char *get_command_name(const char *cmdline,
3599                                     char *cmdname, size_t nlen)
3600 {
3601     size_t len;
3602     const char *p, *pstart;
3603
3604     p = cmdline;
3605     while (qemu_isspace(*p))
3606         p++;
3607     if (*p == '\0')
3608         return NULL;
3609     pstart = p;
3610     while (*p != '\0' && *p != '/' && !qemu_isspace(*p))
3611         p++;
3612     len = p - pstart;
3613     if (len > nlen - 1)
3614         len = nlen - 1;
3615     memcpy(cmdname, pstart, len);
3616     cmdname[len] = '\0';
3617     return p;
3618 }
3619
3620 /**
3621  * Read key of 'type' into 'key' and return the current
3622  * 'type' pointer.
3623  */
3624 static char *key_get_info(const char *type, char **key)
3625 {
3626     size_t len;
3627     char *p, *str;
3628
3629     if (*type == ',')
3630         type++;
3631
3632     p = strchr(type, ':');
3633     if (!p) {
3634         *key = NULL;
3635         return NULL;
3636     }
3637     len = p - type;
3638
3639     str = g_malloc(len + 1);
3640     memcpy(str, type, len);
3641     str[len] = '\0';
3642
3643     *key = str;
3644     return ++p;
3645 }
3646
3647 static int default_fmt_format = 'x';
3648 static int default_fmt_size = 4;
3649
3650 static int is_valid_option(const char *c, const char *typestr)
3651 {
3652     char option[3];
3653   
3654     option[0] = '-';
3655     option[1] = *c;
3656     option[2] = '\0';
3657   
3658     typestr = strstr(typestr, option);
3659     return (typestr != NULL);
3660 }
3661
3662 static const mon_cmd_t *search_dispatch_table(const mon_cmd_t *disp_table,
3663                                               const char *cmdname)
3664 {
3665     const mon_cmd_t *cmd;
3666
3667     for (cmd = disp_table; cmd->name != NULL; cmd++) {
3668         if (compare_cmd(cmdname, cmd->name)) {
3669             return cmd;
3670         }
3671     }
3672
3673     return NULL;
3674 }
3675
3676 static const mon_cmd_t *qmp_find_cmd(const char *cmdname)
3677 {
3678     return search_dispatch_table(qmp_cmds, cmdname);
3679 }
3680
3681 /*
3682  * Parse @cmdline according to command table @table.
3683  * If @cmdline is blank, return NULL.
3684  * If it can't be parsed, report to @mon, and return NULL.
3685  * Else, insert command arguments into @qdict, and return the command.
3686  * If a sub-command table exists, and if @cmdline contains an additional string
3687  * for a sub-command, this function will try to search the sub-command table.
3688  * If no additional string for a sub-command is present, this function will
3689  * return the command found in @table.
3690  * Do not assume the returned command points into @table!  It doesn't
3691  * when the command is a sub-command.
3692  */
3693 static const mon_cmd_t *monitor_parse_command(Monitor *mon,
3694                                               const char *cmdline,
3695                                               int start,
3696                                               mon_cmd_t *table,
3697                                               QDict *qdict)
3698 {
3699     const char *p, *typestr;
3700     int c;
3701     const mon_cmd_t *cmd;
3702     char cmdname[256];
3703     char buf[1024];
3704     char *key;
3705
3706 #ifdef DEBUG
3707     monitor_printf(mon, "command='%s', start='%d'\n", cmdline, start);
3708 #endif
3709
3710     /* extract the command name */
3711     p = get_command_name(cmdline + start, cmdname, sizeof(cmdname));
3712     if (!p)
3713         return NULL;
3714
3715     cmd = search_dispatch_table(table, cmdname);
3716     if (!cmd) {
3717         monitor_printf(mon, "unknown command: '%.*s'\n",
3718                        (int)(p - cmdline), cmdline);
3719         return NULL;
3720     }
3721
3722     /* filter out following useless space */
3723     while (qemu_isspace(*p)) {
3724         p++;
3725     }
3726     /* search sub command */
3727     if (cmd->sub_table != NULL) {
3728         /* check if user set additional command */
3729         if (*p == '\0') {
3730             return cmd;
3731         }
3732         return monitor_parse_command(mon, cmdline, p - cmdline,
3733                                      cmd->sub_table, qdict);
3734     }
3735
3736     /* parse the parameters */
3737     typestr = cmd->args_type;
3738     for(;;) {
3739         typestr = key_get_info(typestr, &key);
3740         if (!typestr)
3741             break;
3742         c = *typestr;
3743         typestr++;
3744         switch(c) {
3745         case 'F':
3746         case 'B':
3747         case 's':
3748             {
3749                 int ret;
3750
3751                 while (qemu_isspace(*p))
3752                     p++;
3753                 if (*typestr == '?') {
3754                     typestr++;
3755                     if (*p == '\0') {
3756                         /* no optional string: NULL argument */
3757                         break;
3758                     }
3759                 }
3760                 ret = get_str(buf, sizeof(buf), &p);
3761                 if (ret < 0) {
3762                     switch(c) {
3763                     case 'F':
3764                         monitor_printf(mon, "%s: filename expected\n",
3765                                        cmdname);
3766                         break;
3767                     case 'B':
3768                         monitor_printf(mon, "%s: block device name expected\n",
3769                                        cmdname);
3770                         break;
3771                     default:
3772                         monitor_printf(mon, "%s: string expected\n", cmdname);
3773                         break;
3774                     }
3775                     goto fail;
3776                 }
3777                 qdict_put(qdict, key, qstring_from_str(buf));
3778             }
3779             break;
3780         case 'O':
3781             {
3782                 QemuOptsList *opts_list;
3783                 QemuOpts *opts;
3784
3785                 opts_list = qemu_find_opts(key);
3786                 if (!opts_list || opts_list->desc->name) {
3787                     goto bad_type;
3788                 }
3789                 while (qemu_isspace(*p)) {
3790                     p++;
3791                 }
3792                 if (!*p)
3793                     break;
3794                 if (get_str(buf, sizeof(buf), &p) < 0) {
3795                     goto fail;
3796                 }
3797                 opts = qemu_opts_parse(opts_list, buf, 1);
3798                 if (!opts) {
3799                     goto fail;
3800                 }
3801                 qemu_opts_to_qdict(opts, qdict);
3802                 qemu_opts_del(opts);
3803             }
3804             break;
3805         case '/':
3806             {
3807                 int count, format, size;
3808
3809                 while (qemu_isspace(*p))
3810                     p++;
3811                 if (*p == '/') {
3812                     /* format found */
3813                     p++;
3814                     count = 1;
3815                     if (qemu_isdigit(*p)) {
3816                         count = 0;
3817                         while (qemu_isdigit(*p)) {
3818                             count = count * 10 + (*p - '0');
3819                             p++;
3820                         }
3821                     }
3822                     size = -1;
3823                     format = -1;
3824                     for(;;) {
3825                         switch(*p) {
3826                         case 'o':
3827                         case 'd':
3828                         case 'u':
3829                         case 'x':
3830                         case 'i':
3831                         case 'c':
3832                             format = *p++;
3833                             break;
3834                         case 'b':
3835                             size = 1;
3836                             p++;
3837                             break;
3838                         case 'h':
3839                             size = 2;
3840                             p++;
3841                             break;
3842                         case 'w':
3843                             size = 4;
3844                             p++;
3845                             break;
3846                         case 'g':
3847                         case 'L':
3848                             size = 8;
3849                             p++;
3850                             break;
3851                         default:
3852                             goto next;
3853                         }
3854                     }
3855                 next:
3856                     if (*p != '\0' && !qemu_isspace(*p)) {
3857                         monitor_printf(mon, "invalid char in format: '%c'\n",
3858                                        *p);
3859                         goto fail;
3860                     }
3861                     if (format < 0)
3862                         format = default_fmt_format;
3863                     if (format != 'i') {
3864                         /* for 'i', not specifying a size gives -1 as size */
3865                         if (size < 0)
3866                             size = default_fmt_size;
3867                         default_fmt_size = size;
3868                     }
3869                     default_fmt_format = format;
3870                 } else {
3871                     count = 1;
3872                     format = default_fmt_format;
3873                     if (format != 'i') {
3874                         size = default_fmt_size;
3875                     } else {
3876                         size = -1;
3877                     }
3878                 }
3879                 qdict_put(qdict, "count", qint_from_int(count));
3880                 qdict_put(qdict, "format", qint_from_int(format));
3881                 qdict_put(qdict, "size", qint_from_int(size));
3882             }
3883             break;
3884         case 'i':
3885         case 'l':
3886         case 'M':
3887             {
3888                 int64_t val;
3889
3890                 while (qemu_isspace(*p))
3891                     p++;
3892                 if (*typestr == '?' || *typestr == '.') {
3893                     if (*typestr == '?') {
3894                         if (*p == '\0') {
3895                             typestr++;
3896                             break;
3897                         }
3898                     } else {
3899                         if (*p == '.') {
3900                             p++;
3901                             while (qemu_isspace(*p))
3902                                 p++;
3903                         } else {
3904                             typestr++;
3905                             break;
3906                         }
3907                     }
3908                     typestr++;
3909                 }
3910                 if (get_expr(mon, &val, &p))
3911                     goto fail;
3912                 /* Check if 'i' is greater than 32-bit */
3913                 if ((c == 'i') && ((val >> 32) & 0xffffffff)) {
3914                     monitor_printf(mon, "\'%s\' has failed: ", cmdname);
3915                     monitor_printf(mon, "integer is for 32-bit values\n");
3916                     goto fail;
3917                 } else if (c == 'M') {
3918                     if (val < 0) {
3919                         monitor_printf(mon, "enter a positive value\n");
3920                         goto fail;
3921                     }
3922                     val <<= 20;
3923                 }
3924                 qdict_put(qdict, key, qint_from_int(val));
3925             }
3926             break;
3927         case 'o':
3928             {
3929                 int64_t val;
3930                 char *end;
3931
3932                 while (qemu_isspace(*p)) {
3933                     p++;
3934                 }
3935                 if (*typestr == '?') {
3936                     typestr++;
3937                     if (*p == '\0') {
3938                         break;
3939                     }
3940                 }
3941                 val = strtosz(p, &end);
3942                 if (val < 0) {
3943                     monitor_printf(mon, "invalid size\n");
3944                     goto fail;
3945                 }
3946                 qdict_put(qdict, key, qint_from_int(val));
3947                 p = end;
3948             }
3949             break;
3950         case 'T':
3951             {
3952                 double val;
3953
3954                 while (qemu_isspace(*p))
3955                     p++;
3956                 if (*typestr == '?') {
3957                     typestr++;
3958                     if (*p == '\0') {
3959                         break;
3960                     }
3961                 }
3962                 if (get_double(mon, &val, &p) < 0) {
3963                     goto fail;
3964                 }
3965                 if (p[0] && p[1] == 's') {
3966                     switch (*p) {
3967                     case 'm':
3968                         val /= 1e3; p += 2; break;
3969                     case 'u':
3970                         val /= 1e6; p += 2; break;
3971                     case 'n':
3972                         val /= 1e9; p += 2; break;
3973                     }
3974                 }
3975                 if (*p && !qemu_isspace(*p)) {
3976                     monitor_printf(mon, "Unknown unit suffix\n");
3977                     goto fail;
3978                 }
3979                 qdict_put(qdict, key, qfloat_from_double(val));
3980             }
3981             break;
3982         case 'b':
3983             {
3984                 const char *beg;
3985                 int val;
3986
3987                 while (qemu_isspace(*p)) {
3988                     p++;
3989                 }
3990                 beg = p;
3991                 while (qemu_isgraph(*p)) {
3992                     p++;
3993                 }
3994                 if (p - beg == 2 && !memcmp(beg, "on", p - beg)) {
3995                     val = 1;
3996                 } else if (p - beg == 3 && !memcmp(beg, "off", p - beg)) {
3997                     val = 0;
3998                 } else {
3999                     monitor_printf(mon, "Expected 'on' or 'off'\n");
4000                     goto fail;
4001                 }
4002                 qdict_put(qdict, key, qbool_from_int(val));
4003             }
4004             break;
4005         case '-':
4006             {
4007                 const char *tmp = p;
4008                 int skip_key = 0;
4009                 /* option */
4010
4011                 c = *typestr++;
4012                 if (c == '\0')
4013                     goto bad_type;
4014                 while (qemu_isspace(*p))
4015                     p++;
4016                 if (*p == '-') {
4017                     p++;
4018                     if(c != *p) {
4019                         if(!is_valid_option(p, typestr)) {
4020                   
4021                             monitor_printf(mon, "%s: unsupported option -%c\n",
4022                                            cmdname, *p);
4023                             goto fail;
4024                         } else {
4025                             skip_key = 1;
4026                         }
4027                     }
4028                     if(skip_key) {
4029                         p = tmp;
4030                     } else {
4031                         /* has option */
4032                         p++;
4033                         qdict_put(qdict, key, qbool_from_int(1));
4034                     }
4035                 }
4036             }
4037             break;
4038         case 'S':
4039             {
4040                 /* package all remaining string */
4041                 int len;
4042
4043                 while (qemu_isspace(*p)) {
4044                     p++;
4045                 }
4046                 if (*typestr == '?') {
4047                     typestr++;
4048                     if (*p == '\0') {
4049                         /* no remaining string: NULL argument */
4050                         break;
4051                     }
4052                 }
4053                 len = strlen(p);
4054                 if (len <= 0) {
4055                     monitor_printf(mon, "%s: string expected\n",
4056                                    cmdname);
4057                     break;
4058                 }
4059                 qdict_put(qdict, key, qstring_from_str(p));
4060                 p += len;
4061             }
4062             break;
4063         default:
4064         bad_type:
4065             monitor_printf(mon, "%s: unknown type '%c'\n", cmdname, c);
4066             goto fail;
4067         }
4068         g_free(key);
4069         key = NULL;
4070     }
4071     /* check that all arguments were parsed */
4072     while (qemu_isspace(*p))
4073         p++;
4074     if (*p != '\0') {
4075         monitor_printf(mon, "%s: extraneous characters at the end of line\n",
4076                        cmdname);
4077         goto fail;
4078     }
4079
4080     return cmd;
4081
4082 fail:
4083     g_free(key);
4084     return NULL;
4085 }
4086
4087 void monitor_set_error(Monitor *mon, QError *qerror)
4088 {
4089     /* report only the first error */
4090     if (!mon->error) {
4091         mon->error = qerror;
4092     } else {
4093         QDECREF(qerror);
4094     }
4095 }
4096
4097 static void handler_audit(Monitor *mon, const mon_cmd_t *cmd, int ret)
4098 {
4099     if (ret && !monitor_has_error(mon)) {
4100         /*
4101          * If it returns failure, it must have passed on error.
4102          *
4103          * Action: Report an internal error to the client if in QMP.
4104          */
4105         qerror_report(QERR_UNDEFINED_ERROR);
4106     }
4107 }
4108
4109 static void handle_user_command(Monitor *mon, const char *cmdline)
4110 {
4111     QDict *qdict;
4112     const mon_cmd_t *cmd;
4113
4114     qdict = qdict_new();
4115
4116     cmd = monitor_parse_command(mon, cmdline, 0, mon->cmd_table, qdict);
4117     if (!cmd)
4118         goto out;
4119
4120     if (handler_is_async(cmd)) {
4121         user_async_cmd_handler(mon, cmd, qdict);
4122     } else if (handler_is_qobject(cmd)) {
4123         QObject *data = NULL;
4124
4125         /* XXX: ignores the error code */
4126         cmd->mhandler.cmd_new(mon, qdict, &data);
4127         assert(!monitor_has_error(mon));
4128         if (data) {
4129             cmd->user_print(mon, data);
4130             qobject_decref(data);
4131         }
4132     } else {
4133         cmd->mhandler.cmd(mon, qdict);
4134     }
4135
4136 out:
4137     QDECREF(qdict);
4138 }
4139
4140 static void cmd_completion(Monitor *mon, const char *name, const char *list)
4141 {
4142     const char *p, *pstart;
4143     char cmd[128];
4144     int len;
4145
4146     p = list;
4147     for(;;) {
4148         pstart = p;
4149         p = strchr(p, '|');
4150         if (!p)
4151             p = pstart + strlen(pstart);
4152         len = p - pstart;
4153         if (len > sizeof(cmd) - 2)
4154             len = sizeof(cmd) - 2;
4155         memcpy(cmd, pstart, len);
4156         cmd[len] = '\0';
4157         if (name[0] == '\0' || !strncmp(name, cmd, strlen(name))) {
4158             readline_add_completion(mon->rs, cmd);
4159         }
4160         if (*p == '\0')
4161             break;
4162         p++;
4163     }
4164 }
4165
4166 static void file_completion(Monitor *mon, const char *input)
4167 {
4168     DIR *ffs;
4169     struct dirent *d;
4170     char path[1024];
4171     char file[1024], file_prefix[1024];
4172     int input_path_len;
4173     const char *p;
4174
4175     p = strrchr(input, '/');
4176     if (!p) {
4177         input_path_len = 0;
4178         pstrcpy(file_prefix, sizeof(file_prefix), input);
4179         pstrcpy(path, sizeof(path), ".");
4180     } else {
4181         input_path_len = p - input + 1;
4182         memcpy(path, input, input_path_len);
4183         if (input_path_len > sizeof(path) - 1)
4184             input_path_len = sizeof(path) - 1;
4185         path[input_path_len] = '\0';
4186         pstrcpy(file_prefix, sizeof(file_prefix), p + 1);
4187     }
4188 #ifdef DEBUG_COMPLETION
4189     monitor_printf(mon, "input='%s' path='%s' prefix='%s'\n",
4190                    input, path, file_prefix);
4191 #endif
4192     ffs = opendir(path);
4193     if (!ffs)
4194         return;
4195     for(;;) {
4196         struct stat sb;
4197         d = readdir(ffs);
4198         if (!d)
4199             break;
4200
4201         if (strcmp(d->d_name, ".") == 0 || strcmp(d->d_name, "..") == 0) {
4202             continue;
4203         }
4204
4205         if (strstart(d->d_name, file_prefix, NULL)) {
4206             memcpy(file, input, input_path_len);
4207             if (input_path_len < sizeof(file))
4208                 pstrcpy(file + input_path_len, sizeof(file) - input_path_len,
4209                         d->d_name);
4210             /* stat the file to find out if it's a directory.
4211              * In that case add a slash to speed up typing long paths
4212              */
4213             if (stat(file, &sb) == 0 && S_ISDIR(sb.st_mode)) {
4214                 pstrcat(file, sizeof(file), "/");
4215             }
4216             readline_add_completion(mon->rs, file);
4217         }
4218     }
4219     closedir(ffs);
4220 }
4221
4222 static const char *next_arg_type(const char *typestr)
4223 {
4224     const char *p = strchr(typestr, ':');
4225     return (p != NULL ? ++p : typestr);
4226 }
4227
4228 static void add_completion_option(ReadLineState *rs, const char *str,
4229                                   const char *option)
4230 {
4231     if (!str || !option) {
4232         return;
4233     }
4234     if (!strncmp(option, str, strlen(str))) {
4235         readline_add_completion(rs, option);
4236     }
4237 }
4238
4239 void chardev_add_completion(ReadLineState *rs, int nb_args, const char *str)
4240 {
4241     size_t len;
4242     ChardevBackendInfoList *list, *start;
4243
4244     if (nb_args != 2) {
4245         return;
4246     }
4247     len = strlen(str);
4248     readline_set_completion_index(rs, len);
4249
4250     start = list = qmp_query_chardev_backends(NULL);
4251     while (list) {
4252         const char *chr_name = list->value->name;
4253
4254         if (!strncmp(chr_name, str, len)) {
4255             readline_add_completion(rs, chr_name);
4256         }
4257         list = list->next;
4258     }
4259     qapi_free_ChardevBackendInfoList(start);
4260 }
4261
4262 void netdev_add_completion(ReadLineState *rs, int nb_args, const char *str)
4263 {
4264     size_t len;
4265     int i;
4266
4267     if (nb_args != 2) {
4268         return;
4269     }
4270     len = strlen(str);
4271     readline_set_completion_index(rs, len);
4272     for (i = 0; NetClientOptionsKind_lookup[i]; i++) {
4273         add_completion_option(rs, str, NetClientOptionsKind_lookup[i]);
4274     }
4275 }
4276
4277 void device_add_completion(ReadLineState *rs, int nb_args, const char *str)
4278 {
4279     GSList *list, *elt;
4280     size_t len;
4281
4282     if (nb_args != 2) {
4283         return;
4284     }
4285
4286     len = strlen(str);
4287     readline_set_completion_index(rs, len);
4288     list = elt = object_class_get_list(TYPE_DEVICE, false);
4289     while (elt) {
4290         const char *name;
4291         DeviceClass *dc = OBJECT_CLASS_CHECK(DeviceClass, elt->data,
4292                                              TYPE_DEVICE);
4293         name = object_class_get_name(OBJECT_CLASS(dc));
4294
4295         if (!dc->cannot_instantiate_with_device_add_yet
4296             && !strncmp(name, str, len)) {
4297             readline_add_completion(rs, name);
4298         }
4299         elt = elt->next;
4300     }
4301     g_slist_free(list);
4302 }
4303
4304 void object_add_completion(ReadLineState *rs, int nb_args, const char *str)
4305 {
4306     GSList *list, *elt;
4307     size_t len;
4308
4309     if (nb_args != 2) {
4310         return;
4311     }
4312
4313     len = strlen(str);
4314     readline_set_completion_index(rs, len);
4315     list = elt = object_class_get_list(TYPE_USER_CREATABLE, false);
4316     while (elt) {
4317         const char *name;
4318
4319         name = object_class_get_name(OBJECT_CLASS(elt->data));
4320         if (!strncmp(name, str, len) && strcmp(name, TYPE_USER_CREATABLE)) {
4321             readline_add_completion(rs, name);
4322         }
4323         elt = elt->next;
4324     }
4325     g_slist_free(list);
4326 }
4327
4328 static void peripheral_device_del_completion(ReadLineState *rs,
4329                                              const char *str, size_t len)
4330 {
4331     Object *peripheral = container_get(qdev_get_machine(), "/peripheral");
4332     GSList *list, *item;
4333
4334     list = qdev_build_hotpluggable_device_list(peripheral);
4335     if (!list) {
4336         return;
4337     }
4338
4339     for (item = list; item; item = g_slist_next(item)) {
4340         DeviceState *dev = item->data;
4341
4342         if (dev->id && !strncmp(str, dev->id, len)) {
4343             readline_add_completion(rs, dev->id);
4344         }
4345     }
4346
4347     g_slist_free(list);
4348 }
4349
4350 void chardev_remove_completion(ReadLineState *rs, int nb_args, const char *str)
4351 {
4352     size_t len;
4353     ChardevInfoList *list, *start;
4354
4355     if (nb_args != 2) {
4356         return;
4357     }
4358     len = strlen(str);
4359     readline_set_completion_index(rs, len);
4360
4361     start = list = qmp_query_chardev(NULL);
4362     while (list) {
4363         ChardevInfo *chr = list->value;
4364
4365         if (!strncmp(chr->label, str, len)) {
4366             readline_add_completion(rs, chr->label);
4367         }
4368         list = list->next;
4369     }
4370     qapi_free_ChardevInfoList(start);
4371 }
4372
4373 static void ringbuf_completion(ReadLineState *rs, const char *str)
4374 {
4375     size_t len;
4376     ChardevInfoList *list, *start;
4377
4378     len = strlen(str);
4379     readline_set_completion_index(rs, len);
4380
4381     start = list = qmp_query_chardev(NULL);
4382     while (list) {
4383         ChardevInfo *chr_info = list->value;
4384
4385         if (!strncmp(chr_info->label, str, len)) {
4386             CharDriverState *chr = qemu_chr_find(chr_info->label);
4387             if (chr && chr_is_ringbuf(chr)) {
4388                 readline_add_completion(rs, chr_info->label);
4389             }
4390         }
4391         list = list->next;
4392     }
4393     qapi_free_ChardevInfoList(start);
4394 }
4395
4396 void ringbuf_read_completion(ReadLineState *rs, int nb_args, const char *str)
4397 {
4398     if (nb_args != 2) {
4399         return;
4400     }
4401     ringbuf_completion(rs, str);
4402 }
4403
4404 void ringbuf_write_completion(ReadLineState *rs, int nb_args, const char *str)
4405 {
4406     if (nb_args != 2) {
4407         return;
4408     }
4409     ringbuf_completion(rs, str);
4410 }
4411
4412 void device_del_completion(ReadLineState *rs, int nb_args, const char *str)
4413 {
4414     size_t len;
4415
4416     if (nb_args != 2) {
4417         return;
4418     }
4419
4420     len = strlen(str);
4421     readline_set_completion_index(rs, len);
4422     peripheral_device_del_completion(rs, str, len);
4423 }
4424
4425 void object_del_completion(ReadLineState *rs, int nb_args, const char *str)
4426 {
4427     ObjectPropertyInfoList *list, *start;
4428     size_t len;
4429
4430     if (nb_args != 2) {
4431         return;
4432     }
4433     len = strlen(str);
4434     readline_set_completion_index(rs, len);
4435
4436     start = list = qmp_qom_list("/objects", NULL);
4437     while (list) {
4438         ObjectPropertyInfo *info = list->value;
4439
4440         if (!strncmp(info->type, "child<", 5)
4441             && !strncmp(info->name, str, len)) {
4442             readline_add_completion(rs, info->name);
4443         }
4444         list = list->next;
4445     }
4446     qapi_free_ObjectPropertyInfoList(start);
4447 }
4448
4449 void sendkey_completion(ReadLineState *rs, int nb_args, const char *str)
4450 {
4451     int i;
4452     char *sep;
4453     size_t len;
4454
4455     if (nb_args != 2) {
4456         return;
4457     }
4458     sep = strrchr(str, '-');
4459     if (sep) {
4460         str = sep + 1;
4461     }
4462     len = strlen(str);
4463     readline_set_completion_index(rs, len);
4464     for (i = 0; i < Q_KEY_CODE_MAX; i++) {
4465         if (!strncmp(str, QKeyCode_lookup[i], len)) {
4466             readline_add_completion(rs, QKeyCode_lookup[i]);
4467         }
4468     }
4469 }
4470
4471 void set_link_completion(ReadLineState *rs, int nb_args, const char *str)
4472 {
4473     size_t len;
4474
4475     len = strlen(str);
4476     readline_set_completion_index(rs, len);
4477     if (nb_args == 2) {
4478         NetClientState *ncs[255];
4479         int count, i;
4480         count = qemu_find_net_clients_except(NULL, ncs,
4481                                              NET_CLIENT_OPTIONS_KIND_NONE, 255);
4482         for (i = 0; i < count; i++) {
4483             const char *name = ncs[i]->name;
4484             if (!strncmp(str, name, len)) {
4485                 readline_add_completion(rs, name);
4486             }
4487         }
4488     } else if (nb_args == 3) {
4489         add_completion_option(rs, str, "on");
4490         add_completion_option(rs, str, "off");
4491     }
4492 }
4493
4494 void netdev_del_completion(ReadLineState *rs, int nb_args, const char *str)
4495 {
4496     int len, count, i;
4497     NetClientState *ncs[255];
4498
4499     if (nb_args != 2) {
4500         return;
4501     }
4502
4503     len = strlen(str);
4504     readline_set_completion_index(rs, len);
4505     count = qemu_find_net_clients_except(NULL, ncs, NET_CLIENT_OPTIONS_KIND_NIC,
4506                                          255);
4507     for (i = 0; i < count; i++) {
4508         QemuOpts *opts;
4509         const char *name = ncs[i]->name;
4510         if (strncmp(str, name, len)) {
4511             continue;
4512         }
4513         opts = qemu_opts_find(qemu_find_opts_err("netdev", NULL), name);
4514         if (opts) {
4515             readline_add_completion(rs, name);
4516         }
4517     }
4518 }
4519
4520 void watchdog_action_completion(ReadLineState *rs, int nb_args, const char *str)
4521 {
4522     int i;
4523
4524     if (nb_args != 2) {
4525         return;
4526     }
4527     readline_set_completion_index(rs, strlen(str));
4528     for (i = 0; WatchdogExpirationAction_lookup[i]; i++) {
4529         add_completion_option(rs, str, WatchdogExpirationAction_lookup[i]);
4530     }
4531 }
4532
4533 void migrate_set_capability_completion(ReadLineState *rs, int nb_args,
4534                                        const char *str)
4535 {
4536     size_t len;
4537
4538     len = strlen(str);
4539     readline_set_completion_index(rs, len);
4540     if (nb_args == 2) {
4541         int i;
4542         for (i = 0; i < MIGRATION_CAPABILITY_MAX; i++) {
4543             const char *name = MigrationCapability_lookup[i];
4544             if (!strncmp(str, name, len)) {
4545                 readline_add_completion(rs, name);
4546             }
4547         }
4548     } else if (nb_args == 3) {
4549         add_completion_option(rs, str, "on");
4550         add_completion_option(rs, str, "off");
4551     }
4552 }
4553
4554 void host_net_add_completion(ReadLineState *rs, int nb_args, const char *str)
4555 {
4556     int i;
4557     size_t len;
4558     if (nb_args != 2) {
4559         return;
4560     }
4561     len = strlen(str);
4562     readline_set_completion_index(rs, len);
4563     for (i = 0; host_net_devices[i]; i++) {
4564         if (!strncmp(host_net_devices[i], str, len)) {
4565             readline_add_completion(rs, host_net_devices[i]);
4566         }
4567     }
4568 }
4569
4570 void host_net_remove_completion(ReadLineState *rs, int nb_args, const char *str)
4571 {
4572     NetClientState *ncs[255];
4573     int count, i, len;
4574
4575     len = strlen(str);
4576     readline_set_completion_index(rs, len);
4577     if (nb_args == 2) {
4578         count = qemu_find_net_clients_except(NULL, ncs,
4579                                              NET_CLIENT_OPTIONS_KIND_NONE, 255);
4580         for (i = 0; i < count; i++) {
4581             int id;
4582             char name[16];
4583
4584             if (net_hub_id_for_client(ncs[i], &id)) {
4585                 continue;
4586             }
4587             snprintf(name, sizeof(name), "%d", id);
4588             if (!strncmp(str, name, len)) {
4589                 readline_add_completion(rs, name);
4590             }
4591         }
4592         return;
4593     } else if (nb_args == 3) {
4594         count = qemu_find_net_clients_except(NULL, ncs,
4595                                              NET_CLIENT_OPTIONS_KIND_NIC, 255);
4596         for (i = 0; i < count; i++) {
4597             int id;
4598             const char *name;
4599
4600             if (ncs[i]->info->type == NET_CLIENT_OPTIONS_KIND_HUBPORT ||
4601                 net_hub_id_for_client(ncs[i], &id)) {
4602                 continue;
4603             }
4604             name = ncs[i]->name;
4605             if (!strncmp(str, name, len)) {
4606                 readline_add_completion(rs, name);
4607             }
4608         }
4609         return;
4610     }
4611 }
4612
4613 static void vm_completion(ReadLineState *rs, const char *str)
4614 {
4615     size_t len;
4616     BlockDriverState *bs = NULL;
4617
4618     len = strlen(str);
4619     readline_set_completion_index(rs, len);
4620     while ((bs = bdrv_next(bs))) {
4621         SnapshotInfoList *snapshots, *snapshot;
4622
4623         if (!bdrv_can_snapshot(bs)) {
4624             continue;
4625         }
4626         if (bdrv_query_snapshot_info_list(bs, &snapshots, NULL)) {
4627             continue;
4628         }
4629         snapshot = snapshots;
4630         while (snapshot) {
4631             char *completion = snapshot->value->name;
4632             if (!strncmp(str, completion, len)) {
4633                 readline_add_completion(rs, completion);
4634             }
4635             completion = snapshot->value->id;
4636             if (!strncmp(str, completion, len)) {
4637                 readline_add_completion(rs, completion);
4638             }
4639             snapshot = snapshot->next;
4640         }
4641         qapi_free_SnapshotInfoList(snapshots);
4642     }
4643
4644 }
4645
4646 void delvm_completion(ReadLineState *rs, int nb_args, const char *str)
4647 {
4648     if (nb_args == 2) {
4649         vm_completion(rs, str);
4650     }
4651 }
4652
4653 void loadvm_completion(ReadLineState *rs, int nb_args, const char *str)
4654 {
4655     if (nb_args == 2) {
4656         vm_completion(rs, str);
4657     }
4658 }
4659
4660 static void monitor_find_completion_by_table(Monitor *mon,
4661                                              const mon_cmd_t *cmd_table,
4662                                              char **args,
4663                                              int nb_args)
4664 {
4665     const char *cmdname;
4666     int i;
4667     const char *ptype, *str, *name;
4668     const mon_cmd_t *cmd;
4669     BlockDriverState *bs;
4670
4671     if (nb_args <= 1) {
4672         /* command completion */
4673         if (nb_args == 0)
4674             cmdname = "";
4675         else
4676             cmdname = args[0];
4677         readline_set_completion_index(mon->rs, strlen(cmdname));
4678         for (cmd = cmd_table; cmd->name != NULL; cmd++) {
4679             cmd_completion(mon, cmdname, cmd->name);
4680         }
4681     } else {
4682         /* find the command */
4683         for (cmd = cmd_table; cmd->name != NULL; cmd++) {
4684             if (compare_cmd(args[0], cmd->name)) {
4685                 break;
4686             }
4687         }
4688         if (!cmd->name) {
4689             return;
4690         }
4691
4692         if (cmd->sub_table) {
4693             /* do the job again */
4694             return monitor_find_completion_by_table(mon, cmd->sub_table,
4695                                                     &args[1], nb_args - 1);
4696         }
4697         if (cmd->command_completion) {
4698             return cmd->command_completion(mon->rs, nb_args, args[nb_args - 1]);
4699         }
4700
4701         ptype = next_arg_type(cmd->args_type);
4702         for(i = 0; i < nb_args - 2; i++) {
4703             if (*ptype != '\0') {
4704                 ptype = next_arg_type(ptype);
4705                 while (*ptype == '?')
4706                     ptype = next_arg_type(ptype);
4707             }
4708         }
4709         str = args[nb_args - 1];
4710         while (*ptype == '-' && ptype[1] != '\0') {
4711             ptype = next_arg_type(ptype);
4712         }
4713         switch(*ptype) {
4714         case 'F':
4715             /* file completion */
4716             readline_set_completion_index(mon->rs, strlen(str));
4717             file_completion(mon, str);
4718             break;
4719         case 'B':
4720             /* block device name completion */
4721             readline_set_completion_index(mon->rs, strlen(str));
4722             for (bs = bdrv_next(NULL); bs; bs = bdrv_next(bs)) {
4723                 name = bdrv_get_device_name(bs);
4724                 if (str[0] == '\0' ||
4725                     !strncmp(name, str, strlen(str))) {
4726                     readline_add_completion(mon->rs, name);
4727                 }
4728             }
4729             break;
4730         case 's':
4731         case 'S':
4732             if (!strcmp(cmd->name, "help|?")) {
4733                 monitor_find_completion_by_table(mon, cmd_table,
4734                                                  &args[1], nb_args - 1);
4735             }
4736             break;
4737         default:
4738             break;
4739         }
4740     }
4741 }
4742
4743 static void monitor_find_completion(void *opaque,
4744                                     const char *cmdline)
4745 {
4746     Monitor *mon = opaque;
4747     char *args[MAX_ARGS];
4748     int nb_args, len;
4749
4750     /* 1. parse the cmdline */
4751     if (parse_cmdline(cmdline, &nb_args, args) < 0) {
4752         return;
4753     }
4754 #ifdef DEBUG_COMPLETION
4755     {
4756         int i;
4757         for (i = 0; i < nb_args; i++) {
4758             monitor_printf(mon, "arg%d = '%s'\n", i, args[i]);
4759         }
4760     }
4761 #endif
4762
4763     /* if the line ends with a space, it means we want to complete the
4764        next arg */
4765     len = strlen(cmdline);
4766     if (len > 0 && qemu_isspace(cmdline[len - 1])) {
4767         if (nb_args >= MAX_ARGS) {
4768             goto cleanup;
4769         }
4770         args[nb_args++] = g_strdup("");
4771     }
4772
4773     /* 2. auto complete according to args */
4774     monitor_find_completion_by_table(mon, mon->cmd_table, args, nb_args);
4775
4776 cleanup:
4777     free_cmdline_args(args, nb_args);
4778 }
4779
4780 static int monitor_can_read(void *opaque)
4781 {
4782     Monitor *mon = opaque;
4783
4784     return (mon->suspend_cnt == 0) ? 1 : 0;
4785 }
4786
4787 static int invalid_qmp_mode(const Monitor *mon, const mon_cmd_t *cmd)
4788 {
4789     int is_cap = cmd->mhandler.cmd_new == do_qmp_capabilities;
4790     return (qmp_cmd_mode(mon) ? is_cap : !is_cap);
4791 }
4792
4793 /*
4794  * Argument validation rules:
4795  *
4796  * 1. The argument must exist in cmd_args qdict
4797  * 2. The argument type must be the expected one
4798  *
4799  * Special case: If the argument doesn't exist in cmd_args and
4800  *               the QMP_ACCEPT_UNKNOWNS flag is set, then the
4801  *               checking is skipped for it.
4802  */
4803 static int check_client_args_type(const QDict *client_args,
4804                                   const QDict *cmd_args, int flags)
4805 {
4806     const QDictEntry *ent;
4807
4808     for (ent = qdict_first(client_args); ent;ent = qdict_next(client_args,ent)){
4809         QObject *obj;
4810         QString *arg_type;
4811         const QObject *client_arg = qdict_entry_value(ent);
4812         const char *client_arg_name = qdict_entry_key(ent);
4813
4814         obj = qdict_get(cmd_args, client_arg_name);
4815         if (!obj) {
4816             if (flags & QMP_ACCEPT_UNKNOWNS) {
4817                 /* handler accepts unknowns */
4818                 continue;
4819             }
4820             /* client arg doesn't exist */
4821             qerror_report(QERR_INVALID_PARAMETER, client_arg_name);
4822             return -1;
4823         }
4824
4825         arg_type = qobject_to_qstring(obj);
4826         assert(arg_type != NULL);
4827
4828         /* check if argument's type is correct */
4829         switch (qstring_get_str(arg_type)[0]) {
4830         case 'F':
4831         case 'B':
4832         case 's':
4833             if (qobject_type(client_arg) != QTYPE_QSTRING) {
4834                 qerror_report(QERR_INVALID_PARAMETER_TYPE, client_arg_name,
4835                               "string");
4836                 return -1;
4837             }
4838         break;
4839         case 'i':
4840         case 'l':
4841         case 'M':
4842         case 'o':
4843             if (qobject_type(client_arg) != QTYPE_QINT) {
4844                 qerror_report(QERR_INVALID_PARAMETER_TYPE, client_arg_name,
4845                               "int");
4846                 return -1; 
4847             }
4848             break;
4849         case 'T':
4850             if (qobject_type(client_arg) != QTYPE_QINT &&
4851                 qobject_type(client_arg) != QTYPE_QFLOAT) {
4852                 qerror_report(QERR_INVALID_PARAMETER_TYPE, client_arg_name,
4853                               "number");
4854                return -1; 
4855             }
4856             break;
4857         case 'b':
4858         case '-':
4859             if (qobject_type(client_arg) != QTYPE_QBOOL) {
4860                 qerror_report(QERR_INVALID_PARAMETER_TYPE, client_arg_name,
4861                               "bool");
4862                return -1; 
4863             }
4864             break;
4865         case 'O':
4866             assert(flags & QMP_ACCEPT_UNKNOWNS);
4867             break;
4868         case 'q':
4869             /* Any QObject can be passed.  */
4870             break;
4871         case '/':
4872         case '.':
4873             /*
4874              * These types are not supported by QMP and thus are not
4875              * handled here. Fall through.
4876              */
4877         default:
4878             abort();
4879         }
4880     }
4881
4882     return 0;
4883 }
4884
4885 /*
4886  * - Check if the client has passed all mandatory args
4887  * - Set special flags for argument validation
4888  */
4889 static int check_mandatory_args(const QDict *cmd_args,
4890                                 const QDict *client_args, int *flags)
4891 {
4892     const QDictEntry *ent;
4893
4894     for (ent = qdict_first(cmd_args); ent; ent = qdict_next(cmd_args, ent)) {
4895         const char *cmd_arg_name = qdict_entry_key(ent);
4896         QString *type = qobject_to_qstring(qdict_entry_value(ent));
4897         assert(type != NULL);
4898
4899         if (qstring_get_str(type)[0] == 'O') {
4900             assert((*flags & QMP_ACCEPT_UNKNOWNS) == 0);
4901             *flags |= QMP_ACCEPT_UNKNOWNS;
4902         } else if (qstring_get_str(type)[0] != '-' &&
4903                    qstring_get_str(type)[1] != '?' &&
4904                    !qdict_haskey(client_args, cmd_arg_name)) {
4905             qerror_report(QERR_MISSING_PARAMETER, cmd_arg_name);
4906             return -1;
4907         }
4908     }
4909
4910     return 0;
4911 }
4912
4913 static QDict *qdict_from_args_type(const char *args_type)
4914 {
4915     int i;
4916     QDict *qdict;
4917     QString *key, *type, *cur_qs;
4918
4919     assert(args_type != NULL);
4920
4921     qdict = qdict_new();
4922
4923     if (args_type == NULL || args_type[0] == '\0') {
4924         /* no args, empty qdict */
4925         goto out;
4926     }
4927
4928     key = qstring_new();
4929     type = qstring_new();
4930
4931     cur_qs = key;
4932
4933     for (i = 0;; i++) {
4934         switch (args_type[i]) {
4935             case ',':
4936             case '\0':
4937                 qdict_put(qdict, qstring_get_str(key), type);
4938                 QDECREF(key);
4939                 if (args_type[i] == '\0') {
4940                     goto out;
4941                 }
4942                 type = qstring_new(); /* qdict has ref */
4943                 cur_qs = key = qstring_new();
4944                 break;
4945             case ':':
4946                 cur_qs = type;
4947                 break;
4948             default:
4949                 qstring_append_chr(cur_qs, args_type[i]);
4950                 break;
4951         }
4952     }
4953
4954 out:
4955     return qdict;
4956 }
4957
4958 /*
4959  * Client argument checking rules:
4960  *
4961  * 1. Client must provide all mandatory arguments
4962  * 2. Each argument provided by the client must be expected
4963  * 3. Each argument provided by the client must have the type expected
4964  *    by the command
4965  */
4966 static int qmp_check_client_args(const mon_cmd_t *cmd, QDict *client_args)
4967 {
4968     int flags, err;
4969     QDict *cmd_args;
4970
4971     cmd_args = qdict_from_args_type(cmd->args_type);
4972
4973     flags = 0;
4974     err = check_mandatory_args(cmd_args, client_args, &flags);
4975     if (err) {
4976         goto out;
4977     }
4978
4979     err = check_client_args_type(client_args, cmd_args, flags);
4980
4981 out:
4982     QDECREF(cmd_args);
4983     return err;
4984 }
4985
4986 /*
4987  * Input object checking rules
4988  *
4989  * 1. Input object must be a dict
4990  * 2. The "execute" key must exist
4991  * 3. The "execute" key must be a string
4992  * 4. If the "arguments" key exists, it must be a dict
4993  * 5. If the "id" key exists, it can be anything (ie. json-value)
4994  * 6. Any argument not listed above is considered invalid
4995  */
4996 static QDict *qmp_check_input_obj(QObject *input_obj)
4997 {
4998     const QDictEntry *ent;
4999     int has_exec_key = 0;
5000     QDict *input_dict;
5001
5002     if (qobject_type(input_obj) != QTYPE_QDICT) {
5003         qerror_report(QERR_QMP_BAD_INPUT_OBJECT, "object");
5004         return NULL;
5005     }
5006
5007     input_dict = qobject_to_qdict(input_obj);
5008
5009     for (ent = qdict_first(input_dict); ent; ent = qdict_next(input_dict, ent)){
5010         const char *arg_name = qdict_entry_key(ent);
5011         const QObject *arg_obj = qdict_entry_value(ent);
5012
5013         if (!strcmp(arg_name, "execute")) {
5014             if (qobject_type(arg_obj) != QTYPE_QSTRING) {
5015                 qerror_report(QERR_QMP_BAD_INPUT_OBJECT_MEMBER, "execute",
5016                               "string");
5017                 return NULL;
5018             }
5019             has_exec_key = 1;
5020         } else if (!strcmp(arg_name, "arguments")) {
5021             if (qobject_type(arg_obj) != QTYPE_QDICT) {
5022                 qerror_report(QERR_QMP_BAD_INPUT_OBJECT_MEMBER, "arguments",
5023                               "object");
5024                 return NULL;
5025             }
5026         } else if (!strcmp(arg_name, "id")) {
5027             /* FIXME: check duplicated IDs for async commands */
5028         } else {
5029             qerror_report(QERR_QMP_EXTRA_MEMBER, arg_name);
5030             return NULL;
5031         }
5032     }
5033
5034     if (!has_exec_key) {
5035         qerror_report(QERR_QMP_BAD_INPUT_OBJECT, "execute");
5036         return NULL;
5037     }
5038
5039     return input_dict;
5040 }
5041
5042 static void qmp_call_cmd(Monitor *mon, const mon_cmd_t *cmd,
5043                          const QDict *params)
5044 {
5045     int ret;
5046     QObject *data = NULL;
5047
5048     ret = cmd->mhandler.cmd_new(mon, params, &data);
5049     handler_audit(mon, cmd, ret);
5050     monitor_protocol_emitter(mon, data);
5051     qobject_decref(data);
5052 }
5053
5054 static void handle_qmp_command(JSONMessageParser *parser, QList *tokens)
5055 {
5056     int err;
5057     QObject *obj;
5058     QDict *input, *args;
5059     const mon_cmd_t *cmd;
5060     const char *cmd_name;
5061     Monitor *mon = cur_mon;
5062
5063     args = input = NULL;
5064
5065     obj = json_parser_parse(tokens, NULL);
5066     if (!obj) {
5067         // FIXME: should be triggered in json_parser_parse()
5068         qerror_report(QERR_JSON_PARSING);
5069         goto err_out;
5070     }
5071
5072     input = qmp_check_input_obj(obj);
5073     if (!input) {
5074         qobject_decref(obj);
5075         goto err_out;
5076     }
5077
5078     mon->mc->id = qdict_get(input, "id");
5079     qobject_incref(mon->mc->id);
5080
5081     cmd_name = qdict_get_str(input, "execute");
5082     trace_handle_qmp_command(mon, cmd_name);
5083     cmd = qmp_find_cmd(cmd_name);
5084     if (!cmd || invalid_qmp_mode(mon, cmd)) {
5085         qerror_report(ERROR_CLASS_COMMAND_NOT_FOUND,
5086                       "The command %s has not been found", cmd_name);
5087         goto err_out;
5088     }
5089
5090     obj = qdict_get(input, "arguments");
5091     if (!obj) {
5092         args = qdict_new();
5093     } else {
5094         args = qobject_to_qdict(obj);
5095         QINCREF(args);
5096     }
5097
5098     err = qmp_check_client_args(cmd, args);
5099     if (err < 0) {
5100         goto err_out;
5101     }
5102
5103     if (handler_is_async(cmd)) {
5104         err = qmp_async_cmd_handler(mon, cmd, args);
5105         if (err) {
5106             /* emit the error response */
5107             goto err_out;
5108         }
5109     } else {
5110         qmp_call_cmd(mon, cmd, args);
5111     }
5112
5113     goto out;
5114
5115 err_out:
5116     monitor_protocol_emitter(mon, NULL);
5117 out:
5118     QDECREF(input);
5119     QDECREF(args);
5120 }
5121
5122 /**
5123  * monitor_control_read(): Read and handle QMP input
5124  */
5125 static void monitor_control_read(void *opaque, const uint8_t *buf, int size)
5126 {
5127     Monitor *old_mon = cur_mon;
5128
5129     cur_mon = opaque;
5130
5131     json_message_parser_feed(&cur_mon->mc->parser, (const char *) buf, size);
5132
5133     cur_mon = old_mon;
5134 }
5135
5136 static void monitor_read(void *opaque, const uint8_t *buf, int size)
5137 {
5138     Monitor *old_mon = cur_mon;
5139     int i;
5140
5141     cur_mon = opaque;
5142
5143     if (cur_mon->rs) {
5144         for (i = 0; i < size; i++)
5145             readline_handle_byte(cur_mon->rs, buf[i]);
5146     } else {
5147         if (size == 0 || buf[size - 1] != 0)
5148             monitor_printf(cur_mon, "corrupted command\n");
5149         else
5150             handle_user_command(cur_mon, (char *)buf);
5151     }
5152
5153     cur_mon = old_mon;
5154 }
5155
5156 static void monitor_command_cb(void *opaque, const char *cmdline,
5157                                void *readline_opaque)
5158 {
5159     Monitor *mon = opaque;
5160
5161     monitor_suspend(mon);
5162     handle_user_command(mon, cmdline);
5163     monitor_resume(mon);
5164 }
5165
5166 int monitor_suspend(Monitor *mon)
5167 {
5168     if (!mon->rs)
5169         return -ENOTTY;
5170     mon->suspend_cnt++;
5171     return 0;
5172 }
5173
5174 void monitor_resume(Monitor *mon)
5175 {
5176     if (!mon->rs)
5177         return;
5178     if (--mon->suspend_cnt == 0)
5179         readline_show_prompt(mon->rs);
5180 }
5181
5182 static QObject *get_qmp_greeting(void)
5183 {
5184     QObject *ver = NULL;
5185
5186     qmp_marshal_input_query_version(NULL, NULL, &ver);
5187     return qobject_from_jsonf("{'QMP':{'version': %p,'capabilities': []}}",ver);
5188 }
5189
5190 /**
5191  * monitor_control_event(): Print QMP gretting
5192  */
5193 static void monitor_control_event(void *opaque, int event)
5194 {
5195     QObject *data;
5196     Monitor *mon = opaque;
5197
5198     switch (event) {
5199     case CHR_EVENT_OPENED:
5200         mon->mc->command_mode = 0;
5201         data = get_qmp_greeting();
5202         monitor_json_emitter(mon, data);
5203         qobject_decref(data);
5204         mon_refcount++;
5205         break;
5206     case CHR_EVENT_CLOSED:
5207         json_message_parser_destroy(&mon->mc->parser);
5208         json_message_parser_init(&mon->mc->parser, handle_qmp_command);
5209         mon_refcount--;
5210         monitor_fdsets_cleanup();
5211         break;
5212     }
5213 }
5214
5215 static void monitor_event(void *opaque, int event)
5216 {
5217     Monitor *mon = opaque;
5218
5219     switch (event) {
5220     case CHR_EVENT_MUX_IN:
5221         qemu_mutex_lock(&mon->out_lock);
5222         mon->mux_out = 0;
5223         qemu_mutex_unlock(&mon->out_lock);
5224         if (mon->reset_seen) {
5225             readline_restart(mon->rs);
5226             monitor_resume(mon);
5227             monitor_flush(mon);
5228         } else {
5229             mon->suspend_cnt = 0;
5230         }
5231         break;
5232
5233     case CHR_EVENT_MUX_OUT:
5234         if (mon->reset_seen) {
5235             if (mon->suspend_cnt == 0) {
5236                 monitor_printf(mon, "\n");
5237             }
5238             monitor_flush(mon);
5239             monitor_suspend(mon);
5240         } else {
5241             mon->suspend_cnt++;
5242         }
5243         qemu_mutex_lock(&mon->out_lock);
5244         mon->mux_out = 1;
5245         qemu_mutex_unlock(&mon->out_lock);
5246         break;
5247
5248     case CHR_EVENT_OPENED:
5249         monitor_printf(mon, "QEMU %s monitor - type 'help' for more "
5250                        "information\n", QEMU_VERSION);
5251         if (!mon->mux_out) {
5252             readline_restart(mon->rs);
5253             readline_show_prompt(mon->rs);
5254         }
5255         mon->reset_seen = 1;
5256         mon_refcount++;
5257         break;
5258
5259     case CHR_EVENT_CLOSED:
5260         mon_refcount--;
5261         monitor_fdsets_cleanup();
5262         break;
5263     }
5264 }
5265
5266 static int
5267 compare_mon_cmd(const void *a, const void *b)
5268 {
5269     return strcmp(((const mon_cmd_t *)a)->name,
5270             ((const mon_cmd_t *)b)->name);
5271 }
5272
5273 static void sortcmdlist(void)
5274 {
5275     int array_num;
5276     int elem_size = sizeof(mon_cmd_t);
5277
5278     array_num = sizeof(mon_cmds)/elem_size-1;
5279     qsort((void *)mon_cmds, array_num, elem_size, compare_mon_cmd);
5280
5281     array_num = sizeof(info_cmds)/elem_size-1;
5282     qsort((void *)info_cmds, array_num, elem_size, compare_mon_cmd);
5283 }
5284
5285
5286 /*
5287  * Local variables:
5288  *  c-indent-level: 4
5289  *  c-basic-offset: 4
5290  *  tab-width: 8
5291  * End:
5292  */
5293
5294 /* These functions just adapt the readline interface in a typesafe way.  We
5295  * could cast function pointers but that discards compiler checks.
5296  */
5297 static void GCC_FMT_ATTR(2, 3) monitor_readline_printf(void *opaque,
5298                                                        const char *fmt, ...)
5299 {
5300     va_list ap;
5301     va_start(ap, fmt);
5302     monitor_vprintf(opaque, fmt, ap);
5303     va_end(ap);
5304 }
5305
5306 static void monitor_readline_flush(void *opaque)
5307 {
5308     monitor_flush(opaque);
5309 }
5310
5311 static void __attribute__((constructor)) monitor_lock_init(void)
5312 {
5313     qemu_mutex_init(&monitor_lock);
5314 }
5315
5316 void monitor_init(CharDriverState *chr, int flags)
5317 {
5318     static int is_first_init = 1;
5319     Monitor *mon;
5320
5321     if (is_first_init) {
5322         monitor_qapi_event_init();
5323         sortcmdlist();
5324         is_first_init = 0;
5325     }
5326
5327     mon = g_malloc(sizeof(*mon));
5328     monitor_data_init(mon);
5329
5330     mon->chr = chr;
5331     mon->flags = flags;
5332     if (flags & MONITOR_USE_READLINE) {
5333         mon->rs = readline_init(monitor_readline_printf,
5334                                 monitor_readline_flush,
5335                                 mon,
5336                                 monitor_find_completion);
5337         monitor_read_command(mon, 0);
5338     }
5339
5340     if (monitor_ctrl_mode(mon)) {
5341         mon->mc = g_malloc0(sizeof(MonitorControl));
5342         /* Control mode requires special handlers */
5343         qemu_chr_add_handlers(chr, monitor_can_read, monitor_control_read,
5344                               monitor_control_event, mon);
5345         qemu_chr_fe_set_echo(chr, true);
5346
5347         json_message_parser_init(&mon->mc->parser, handle_qmp_command);
5348     } else {
5349         qemu_chr_add_handlers(chr, monitor_can_read, monitor_read,
5350                               monitor_event, mon);
5351     }
5352
5353     qemu_mutex_lock(&monitor_lock);
5354     QLIST_INSERT_HEAD(&mon_list, mon, entry);
5355     qemu_mutex_unlock(&monitor_lock);
5356
5357     if (!default_mon || (flags & MONITOR_IS_DEFAULT))
5358         default_mon = mon;
5359 }
5360
5361 static void bdrv_password_cb(void *opaque, const char *password,
5362                              void *readline_opaque)
5363 {
5364     Monitor *mon = opaque;
5365     BlockDriverState *bs = readline_opaque;
5366     int ret = 0;
5367     Error *local_err = NULL;
5368
5369     bdrv_add_key(bs, password, &local_err);
5370     if (local_err) {
5371         monitor_printf(mon, "%s\n", error_get_pretty(local_err));
5372         error_free(local_err);
5373         ret = -EPERM;
5374     }
5375     if (mon->password_completion_cb)
5376         mon->password_completion_cb(mon->password_opaque, ret);
5377
5378     monitor_read_command(mon, 1);
5379 }
5380
5381 ReadLineState *monitor_get_rs(Monitor *mon)
5382 {
5383     return mon->rs;
5384 }
5385
5386 int monitor_read_bdrv_key_start(Monitor *mon, BlockDriverState *bs,
5387                                 BlockCompletionFunc *completion_cb,
5388                                 void *opaque)
5389 {
5390     Error *local_err = NULL;
5391     int err;
5392
5393     bdrv_add_key(bs, NULL, &local_err);
5394     if (!local_err) {
5395         if (completion_cb)
5396             completion_cb(opaque, 0);
5397         return 0;
5398     }
5399
5400     /* Need a key for @bs */
5401
5402     if (monitor_ctrl_mode(mon)) {
5403         qerror_report_err(local_err);
5404         return -1;
5405     }
5406
5407     monitor_printf(mon, "%s (%s) is encrypted.\n", bdrv_get_device_name(bs),
5408                    bdrv_get_encrypted_filename(bs));
5409
5410     mon->password_completion_cb = completion_cb;
5411     mon->password_opaque = opaque;
5412
5413     err = monitor_read_password(mon, bdrv_password_cb, bs);
5414
5415     if (err && completion_cb)
5416         completion_cb(opaque, err);
5417
5418     return err;
5419 }
5420
5421 int monitor_read_block_device_key(Monitor *mon, const char *device,
5422                                   BlockCompletionFunc *completion_cb,
5423                                   void *opaque)
5424 {
5425     BlockBackend *blk;
5426
5427     blk = blk_by_name(device);
5428     if (!blk) {
5429         monitor_printf(mon, "Device not found %s\n", device);
5430         return -1;
5431     }
5432
5433     return monitor_read_bdrv_key_start(mon, blk_bs(blk), completion_cb, opaque);
5434 }
5435
5436 QemuOptsList qemu_mon_opts = {
5437     .name = "mon",
5438     .implied_opt_name = "chardev",
5439     .head = QTAILQ_HEAD_INITIALIZER(qemu_mon_opts.head),
5440     .desc = {
5441         {
5442             .name = "mode",
5443             .type = QEMU_OPT_STRING,
5444         },{
5445             .name = "chardev",
5446             .type = QEMU_OPT_STRING,
5447         },{
5448             .name = "default",
5449             .type = QEMU_OPT_BOOL,
5450         },{
5451             .name = "pretty",
5452             .type = QEMU_OPT_BOOL,
5453         },
5454         { /* end of list */ }
5455     },
5456 };
5457
5458 #ifndef TARGET_I386
5459 void qmp_rtc_reset_reinjection(Error **errp)
5460 {
5461     error_set(errp, QERR_FEATURE_DISABLED, "rtc-reset-reinjection");
5462 }
5463 #endif
This page took 0.330765 seconds and 4 git commands to generate.