Statistics
| Branch: | Revision:

root / monitor.c @ fb5458cd

History | View | Annotate | Download (129 kB)

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 "hw/qdev.h"
27
#include "hw/usb.h"
28
#include "hw/pcmcia.h"
29
#include "hw/pc.h"
30
#include "hw/pci.h"
31
#include "hw/watchdog.h"
32
#include "hw/loader.h"
33
#include "gdbstub.h"
34
#include "net.h"
35
#include "net/slirp.h"
36
#include "qemu-char.h"
37
#include "ui/qemu-spice.h"
38
#include "sysemu.h"
39
#include "monitor.h"
40
#include "readline.h"
41
#include "console.h"
42
#include "blockdev.h"
43
#include "audio/audio.h"
44
#include "disas.h"
45
#include "balloon.h"
46
#include "qemu-timer.h"
47
#include "migration.h"
48
#include "kvm.h"
49
#include "acl.h"
50
#include "qint.h"
51
#include "qfloat.h"
52
#include "qlist.h"
53
#include "qbool.h"
54
#include "qstring.h"
55
#include "qjson.h"
56
#include "json-streamer.h"
57
#include "json-parser.h"
58
#include "osdep.h"
59
#include "cpu.h"
60
#include "trace.h"
61
#include "trace/control.h"
62
#ifdef CONFIG_TRACE_SIMPLE
63
#include "trace/simple.h"
64
#endif
65
#include "ui/qemu-spice.h"
66
#include "memory.h"
67
#include "qmp-commands.h"
68
#include "hmp.h"
69

    
70
/* for pic/irq_info */
71
#if defined(TARGET_SPARC)
72
#include "hw/sun4m.h"
73
#endif
74
#include "hw/lm32_pic.h"
75

    
76
//#define DEBUG
77
//#define DEBUG_COMPLETION
78

    
79
/*
80
 * Supported types:
81
 *
82
 * 'F'          filename
83
 * 'B'          block device name
84
 * 's'          string (accept optional quote)
85
 * 'O'          option string of the form NAME=VALUE,...
86
 *              parsed according to QemuOptsList given by its name
87
 *              Example: 'device:O' uses qemu_device_opts.
88
 *              Restriction: only lists with empty desc are supported
89
 *              TODO lift the restriction
90
 * 'i'          32 bit integer
91
 * 'l'          target long (32 or 64 bit)
92
 * 'M'          just like 'l', except in user mode the value is
93
 *              multiplied by 2^20 (think Mebibyte)
94
 * 'o'          octets (aka bytes)
95
 *              user mode accepts an optional T, t, G, g, M, m, K, k
96
 *              suffix, which multiplies the value by 2^40 for
97
 *              suffixes T and t, 2^30 for suffixes G and g, 2^20 for
98
 *              M and m, 2^10 for K and k
99
 * 'T'          double
100
 *              user mode accepts an optional ms, us, ns suffix,
101
 *              which divides the value by 1e3, 1e6, 1e9, respectively
102
 * '/'          optional gdb-like print format (like "/10x")
103
 *
104
 * '?'          optional type (for all types, except '/')
105
 * '.'          other form of optional type (for 'i' and 'l')
106
 * 'b'          boolean
107
 *              user mode accepts "on" or "off"
108
 * '-'          optional parameter (eg. '-f')
109
 *
110
 */
111

    
112
typedef struct MonitorCompletionData MonitorCompletionData;
113
struct MonitorCompletionData {
114
    Monitor *mon;
115
    void (*user_print)(Monitor *mon, const QObject *data);
116
};
117

    
118
typedef struct mon_cmd_t {
119
    const char *name;
120
    const char *args_type;
121
    const char *params;
122
    const char *help;
123
    void (*user_print)(Monitor *mon, const QObject *data);
124
    union {
125
        void (*info)(Monitor *mon);
126
        void (*cmd)(Monitor *mon, const QDict *qdict);
127
        int  (*cmd_new)(Monitor *mon, const QDict *params, QObject **ret_data);
128
        int  (*cmd_async)(Monitor *mon, const QDict *params,
129
                          MonitorCompletion *cb, void *opaque);
130
    } mhandler;
131
    bool qapi;
132
    int flags;
133
} mon_cmd_t;
134

    
135
/* file descriptors passed via SCM_RIGHTS */
136
typedef struct mon_fd_t mon_fd_t;
137
struct mon_fd_t {
138
    char *name;
139
    int fd;
140
    QLIST_ENTRY(mon_fd_t) next;
141
};
142

    
143
typedef struct MonitorControl {
144
    QObject *id;
145
    JSONMessageParser parser;
146
    int command_mode;
147
} MonitorControl;
148

    
149
struct Monitor {
150
    CharDriverState *chr;
151
    int mux_out;
152
    int reset_seen;
153
    int flags;
154
    int suspend_cnt;
155
    uint8_t outbuf[1024];
156
    int outbuf_index;
157
    ReadLineState *rs;
158
    MonitorControl *mc;
159
    CPUState *mon_cpu;
160
    BlockDriverCompletionFunc *password_completion_cb;
161
    void *password_opaque;
162
#ifdef CONFIG_DEBUG_MONITOR
163
    int print_calls_nr;
164
#endif
165
    QError *error;
166
    QLIST_HEAD(,mon_fd_t) fds;
167
    QLIST_ENTRY(Monitor) entry;
168
};
169

    
170
#ifdef CONFIG_DEBUG_MONITOR
171
#define MON_DEBUG(fmt, ...) do {    \
172
    fprintf(stderr, "Monitor: ");       \
173
    fprintf(stderr, fmt, ## __VA_ARGS__); } while (0)
174

    
175
static inline void mon_print_count_inc(Monitor *mon)
176
{
177
    mon->print_calls_nr++;
178
}
179

    
180
static inline void mon_print_count_init(Monitor *mon)
181
{
182
    mon->print_calls_nr = 0;
183
}
184

    
185
static inline int mon_print_count_get(const Monitor *mon)
186
{
187
    return mon->print_calls_nr;
188
}
189

    
190
#else /* !CONFIG_DEBUG_MONITOR */
191
#define MON_DEBUG(fmt, ...) do { } while (0)
192
static inline void mon_print_count_inc(Monitor *mon) { }
193
static inline void mon_print_count_init(Monitor *mon) { }
194
static inline int mon_print_count_get(const Monitor *mon) { return 0; }
195
#endif /* CONFIG_DEBUG_MONITOR */
196

    
197
/* QMP checker flags */
198
#define QMP_ACCEPT_UNKNOWNS 1
199

    
200
static QLIST_HEAD(mon_list, Monitor) mon_list;
201

    
202
static mon_cmd_t mon_cmds[];
203
static mon_cmd_t info_cmds[];
204

    
205
static const mon_cmd_t qmp_cmds[];
206

    
207
Monitor *cur_mon;
208
Monitor *default_mon;
209

    
210
static void monitor_command_cb(Monitor *mon, const char *cmdline,
211
                               void *opaque);
212

    
213
static inline int qmp_cmd_mode(const Monitor *mon)
214
{
215
    return (mon->mc ? mon->mc->command_mode : 0);
216
}
217

    
218
/* Return true if in control mode, false otherwise */
219
static inline int monitor_ctrl_mode(const Monitor *mon)
220
{
221
    return (mon->flags & MONITOR_USE_CONTROL);
222
}
223

    
224
/* Return non-zero iff we have a current monitor, and it is in QMP mode.  */
225
int monitor_cur_is_qmp(void)
226
{
227
    return cur_mon && monitor_ctrl_mode(cur_mon);
228
}
229

    
230
void monitor_read_command(Monitor *mon, int show_prompt)
231
{
232
    if (!mon->rs)
233
        return;
234

    
235
    readline_start(mon->rs, "(qemu) ", 0, monitor_command_cb, NULL);
236
    if (show_prompt)
237
        readline_show_prompt(mon->rs);
238
}
239

    
240
int monitor_read_password(Monitor *mon, ReadLineFunc *readline_func,
241
                          void *opaque)
242
{
243
    if (monitor_ctrl_mode(mon)) {
244
        qerror_report(QERR_MISSING_PARAMETER, "password");
245
        return -EINVAL;
246
    } else if (mon->rs) {
247
        readline_start(mon->rs, "Password: ", 1, readline_func, opaque);
248
        /* prompt is printed on return from the command handler */
249
        return 0;
250
    } else {
251
        monitor_printf(mon, "terminal does not support password prompting\n");
252
        return -ENOTTY;
253
    }
254
}
255

    
256
void monitor_flush(Monitor *mon)
257
{
258
    if (mon && mon->outbuf_index != 0 && !mon->mux_out) {
259
        qemu_chr_fe_write(mon->chr, mon->outbuf, mon->outbuf_index);
260
        mon->outbuf_index = 0;
261
    }
262
}
263

    
264
/* flush at every end of line or if the buffer is full */
265
static void monitor_puts(Monitor *mon, const char *str)
266
{
267
    char c;
268

    
269
    for(;;) {
270
        c = *str++;
271
        if (c == '\0')
272
            break;
273
        if (c == '\n')
274
            mon->outbuf[mon->outbuf_index++] = '\r';
275
        mon->outbuf[mon->outbuf_index++] = c;
276
        if (mon->outbuf_index >= (sizeof(mon->outbuf) - 1)
277
            || c == '\n')
278
            monitor_flush(mon);
279
    }
280
}
281

    
282
void monitor_vprintf(Monitor *mon, const char *fmt, va_list ap)
283
{
284
    char buf[4096];
285

    
286
    if (!mon)
287
        return;
288

    
289
    mon_print_count_inc(mon);
290

    
291
    if (monitor_ctrl_mode(mon)) {
292
        return;
293
    }
294

    
295
    vsnprintf(buf, sizeof(buf), fmt, ap);
296
    monitor_puts(mon, buf);
297
}
298

    
299
void monitor_printf(Monitor *mon, const char *fmt, ...)
300
{
301
    va_list ap;
302
    va_start(ap, fmt);
303
    monitor_vprintf(mon, fmt, ap);
304
    va_end(ap);
305
}
306

    
307
void monitor_print_filename(Monitor *mon, const char *filename)
308
{
309
    int i;
310

    
311
    for (i = 0; filename[i]; i++) {
312
        switch (filename[i]) {
313
        case ' ':
314
        case '"':
315
        case '\\':
316
            monitor_printf(mon, "\\%c", filename[i]);
317
            break;
318
        case '\t':
319
            monitor_printf(mon, "\\t");
320
            break;
321
        case '\r':
322
            monitor_printf(mon, "\\r");
323
            break;
324
        case '\n':
325
            monitor_printf(mon, "\\n");
326
            break;
327
        default:
328
            monitor_printf(mon, "%c", filename[i]);
329
            break;
330
        }
331
    }
332
}
333

    
334
static int GCC_FMT_ATTR(2, 3) monitor_fprintf(FILE *stream,
335
                                              const char *fmt, ...)
336
{
337
    va_list ap;
338
    va_start(ap, fmt);
339
    monitor_vprintf((Monitor *)stream, fmt, ap);
340
    va_end(ap);
341
    return 0;
342
}
343

    
344
static void monitor_user_noop(Monitor *mon, const QObject *data) { }
345

    
346
static inline int handler_is_qobject(const mon_cmd_t *cmd)
347
{
348
    return cmd->user_print != NULL;
349
}
350

    
351
static inline bool handler_is_async(const mon_cmd_t *cmd)
352
{
353
    return cmd->flags & MONITOR_CMD_ASYNC;
354
}
355

    
356
static inline int monitor_has_error(const Monitor *mon)
357
{
358
    return mon->error != NULL;
359
}
360

    
361
static void monitor_json_emitter(Monitor *mon, const QObject *data)
362
{
363
    QString *json;
364

    
365
    json = mon->flags & MONITOR_USE_PRETTY ? qobject_to_json_pretty(data) :
366
                                             qobject_to_json(data);
367
    assert(json != NULL);
368

    
369
    qstring_append_chr(json, '\n');
370
    monitor_puts(mon, qstring_get_str(json));
371

    
372
    QDECREF(json);
373
}
374

    
375
static void monitor_protocol_emitter(Monitor *mon, QObject *data)
376
{
377
    QDict *qmp;
378

    
379
    trace_monitor_protocol_emitter(mon);
380

    
381
    qmp = qdict_new();
382

    
383
    if (!monitor_has_error(mon)) {
384
        /* success response */
385
        if (data) {
386
            qobject_incref(data);
387
            qdict_put_obj(qmp, "return", data);
388
        } else {
389
            /* return an empty QDict by default */
390
            qdict_put(qmp, "return", qdict_new());
391
        }
392
    } else {
393
        /* error response */
394
        qdict_put(mon->error->error, "desc", qerror_human(mon->error));
395
        qdict_put(qmp, "error", mon->error->error);
396
        QINCREF(mon->error->error);
397
        QDECREF(mon->error);
398
        mon->error = NULL;
399
    }
400

    
401
    if (mon->mc->id) {
402
        qdict_put_obj(qmp, "id", mon->mc->id);
403
        mon->mc->id = NULL;
404
    }
405

    
406
    monitor_json_emitter(mon, QOBJECT(qmp));
407
    QDECREF(qmp);
408
}
409

    
410
static void timestamp_put(QDict *qdict)
411
{
412
    int err;
413
    QObject *obj;
414
    qemu_timeval tv;
415

    
416
    err = qemu_gettimeofday(&tv);
417
    if (err < 0)
418
        return;
419

    
420
    obj = qobject_from_jsonf("{ 'seconds': %" PRId64 ", "
421
                                "'microseconds': %" PRId64 " }",
422
                                (int64_t) tv.tv_sec, (int64_t) tv.tv_usec);
423
    qdict_put_obj(qdict, "timestamp", obj);
424
}
425

    
426
/**
427
 * monitor_protocol_event(): Generate a Monitor event
428
 *
429
 * Event-specific data can be emitted through the (optional) 'data' parameter.
430
 */
431
void monitor_protocol_event(MonitorEvent event, QObject *data)
432
{
433
    QDict *qmp;
434
    const char *event_name;
435
    Monitor *mon;
436

    
437
    assert(event < QEVENT_MAX);
438

    
439
    switch (event) {
440
        case QEVENT_SHUTDOWN:
441
            event_name = "SHUTDOWN";
442
            break;
443
        case QEVENT_RESET:
444
            event_name = "RESET";
445
            break;
446
        case QEVENT_POWERDOWN:
447
            event_name = "POWERDOWN";
448
            break;
449
        case QEVENT_STOP:
450
            event_name = "STOP";
451
            break;
452
        case QEVENT_RESUME:
453
            event_name = "RESUME";
454
            break;
455
        case QEVENT_VNC_CONNECTED:
456
            event_name = "VNC_CONNECTED";
457
            break;
458
        case QEVENT_VNC_INITIALIZED:
459
            event_name = "VNC_INITIALIZED";
460
            break;
461
        case QEVENT_VNC_DISCONNECTED:
462
            event_name = "VNC_DISCONNECTED";
463
            break;
464
        case QEVENT_BLOCK_IO_ERROR:
465
            event_name = "BLOCK_IO_ERROR";
466
            break;
467
        case QEVENT_RTC_CHANGE:
468
            event_name = "RTC_CHANGE";
469
            break;
470
        case QEVENT_WATCHDOG:
471
            event_name = "WATCHDOG";
472
            break;
473
        case QEVENT_SPICE_CONNECTED:
474
            event_name = "SPICE_CONNECTED";
475
            break;
476
        case QEVENT_SPICE_INITIALIZED:
477
            event_name = "SPICE_INITIALIZED";
478
            break;
479
        case QEVENT_SPICE_DISCONNECTED:
480
            event_name = "SPICE_DISCONNECTED";
481
            break;
482
        case QEVENT_BLOCK_JOB_COMPLETED:
483
            event_name = "BLOCK_JOB_COMPLETED";
484
            break;
485
        case QEVENT_BLOCK_JOB_CANCELLED:
486
            event_name = "BLOCK_JOB_CANCELLED";
487
            break;
488
        default:
489
            abort();
490
            break;
491
    }
492

    
493
    qmp = qdict_new();
494
    timestamp_put(qmp);
495
    qdict_put(qmp, "event", qstring_from_str(event_name));
496
    if (data) {
497
        qobject_incref(data);
498
        qdict_put_obj(qmp, "data", data);
499
    }
500

    
501
    QLIST_FOREACH(mon, &mon_list, entry) {
502
        if (monitor_ctrl_mode(mon) && qmp_cmd_mode(mon)) {
503
            monitor_json_emitter(mon, QOBJECT(qmp));
504
        }
505
    }
506
    QDECREF(qmp);
507
}
508

    
509
static int do_qmp_capabilities(Monitor *mon, const QDict *params,
510
                               QObject **ret_data)
511
{
512
    /* Will setup QMP capabilities in the future */
513
    if (monitor_ctrl_mode(mon)) {
514
        mon->mc->command_mode = 1;
515
    }
516

    
517
    return 0;
518
}
519

    
520
static void handle_user_command(Monitor *mon, const char *cmdline);
521

    
522
char *qmp_human_monitor_command(const char *command_line, bool has_cpu_index,
523
                                int64_t cpu_index, Error **errp)
524
{
525
    char *output = NULL;
526
    Monitor *old_mon, hmp;
527
    CharDriverState mchar;
528

    
529
    memset(&hmp, 0, sizeof(hmp));
530
    qemu_chr_init_mem(&mchar);
531
    hmp.chr = &mchar;
532

    
533
    old_mon = cur_mon;
534
    cur_mon = &hmp;
535

    
536
    if (has_cpu_index) {
537
        int ret = monitor_set_cpu(cpu_index);
538
        if (ret < 0) {
539
            cur_mon = old_mon;
540
            error_set(errp, QERR_INVALID_PARAMETER_VALUE, "cpu-index",
541
                      "a CPU number");
542
            goto out;
543
        }
544
    }
545

    
546
    handle_user_command(&hmp, command_line);
547
    cur_mon = old_mon;
548

    
549
    if (qemu_chr_mem_osize(hmp.chr) > 0) {
550
        QString *str = qemu_chr_mem_to_qs(hmp.chr);
551
        output = g_strdup(qstring_get_str(str));
552
        QDECREF(str);
553
    } else {
554
        output = g_strdup("");
555
    }
556

    
557
out:
558
    qemu_chr_close_mem(hmp.chr);
559
    return output;
560
}
561

    
562
static int compare_cmd(const char *name, const char *list)
563
{
564
    const char *p, *pstart;
565
    int len;
566
    len = strlen(name);
567
    p = list;
568
    for(;;) {
569
        pstart = p;
570
        p = strchr(p, '|');
571
        if (!p)
572
            p = pstart + strlen(pstart);
573
        if ((p - pstart) == len && !memcmp(pstart, name, len))
574
            return 1;
575
        if (*p == '\0')
576
            break;
577
        p++;
578
    }
579
    return 0;
580
}
581

    
582
static void help_cmd_dump(Monitor *mon, const mon_cmd_t *cmds,
583
                          const char *prefix, const char *name)
584
{
585
    const mon_cmd_t *cmd;
586

    
587
    for(cmd = cmds; cmd->name != NULL; cmd++) {
588
        if (!name || !strcmp(name, cmd->name))
589
            monitor_printf(mon, "%s%s %s -- %s\n", prefix, cmd->name,
590
                           cmd->params, cmd->help);
591
    }
592
}
593

    
594
static void help_cmd(Monitor *mon, const char *name)
595
{
596
    if (name && !strcmp(name, "info")) {
597
        help_cmd_dump(mon, info_cmds, "info ", NULL);
598
    } else {
599
        help_cmd_dump(mon, mon_cmds, "", name);
600
        if (name && !strcmp(name, "log")) {
601
            const CPULogItem *item;
602
            monitor_printf(mon, "Log items (comma separated):\n");
603
            monitor_printf(mon, "%-10s %s\n", "none", "remove all logs");
604
            for(item = cpu_log_items; item->mask != 0; item++) {
605
                monitor_printf(mon, "%-10s %s\n", item->name, item->help);
606
            }
607
        }
608
    }
609
}
610

    
611
static void do_help_cmd(Monitor *mon, const QDict *qdict)
612
{
613
    help_cmd(mon, qdict_get_try_str(qdict, "name"));
614
}
615

    
616
static void do_trace_event_set_state(Monitor *mon, const QDict *qdict)
617
{
618
    const char *tp_name = qdict_get_str(qdict, "name");
619
    bool new_state = qdict_get_bool(qdict, "option");
620
    int ret = trace_event_set_state(tp_name, new_state);
621

    
622
    if (!ret) {
623
        monitor_printf(mon, "unknown event name \"%s\"\n", tp_name);
624
    }
625
}
626

    
627
#ifdef CONFIG_TRACE_SIMPLE
628
static void do_trace_file(Monitor *mon, const QDict *qdict)
629
{
630
    const char *op = qdict_get_try_str(qdict, "op");
631
    const char *arg = qdict_get_try_str(qdict, "arg");
632

    
633
    if (!op) {
634
        st_print_trace_file_status((FILE *)mon, &monitor_fprintf);
635
    } else if (!strcmp(op, "on")) {
636
        st_set_trace_file_enabled(true);
637
    } else if (!strcmp(op, "off")) {
638
        st_set_trace_file_enabled(false);
639
    } else if (!strcmp(op, "flush")) {
640
        st_flush_trace_buffer();
641
    } else if (!strcmp(op, "set")) {
642
        if (arg) {
643
            st_set_trace_file(arg);
644
        }
645
    } else {
646
        monitor_printf(mon, "unexpected argument \"%s\"\n", op);
647
        help_cmd(mon, "trace-file");
648
    }
649
}
650
#endif
651

    
652
static void user_monitor_complete(void *opaque, QObject *ret_data)
653
{
654
    MonitorCompletionData *data = (MonitorCompletionData *)opaque; 
655

    
656
    if (ret_data) {
657
        data->user_print(data->mon, ret_data);
658
    }
659
    monitor_resume(data->mon);
660
    g_free(data);
661
}
662

    
663
static void qmp_monitor_complete(void *opaque, QObject *ret_data)
664
{
665
    monitor_protocol_emitter(opaque, ret_data);
666
}
667

    
668
static int qmp_async_cmd_handler(Monitor *mon, const mon_cmd_t *cmd,
669
                                 const QDict *params)
670
{
671
    return cmd->mhandler.cmd_async(mon, params, qmp_monitor_complete, mon);
672
}
673

    
674
static void user_async_cmd_handler(Monitor *mon, const mon_cmd_t *cmd,
675
                                   const QDict *params)
676
{
677
    int ret;
678

    
679
    MonitorCompletionData *cb_data = g_malloc(sizeof(*cb_data));
680
    cb_data->mon = mon;
681
    cb_data->user_print = cmd->user_print;
682
    monitor_suspend(mon);
683
    ret = cmd->mhandler.cmd_async(mon, params,
684
                                  user_monitor_complete, cb_data);
685
    if (ret < 0) {
686
        monitor_resume(mon);
687
        g_free(cb_data);
688
    }
689
}
690

    
691
static void do_info(Monitor *mon, const QDict *qdict)
692
{
693
    const mon_cmd_t *cmd;
694
    const char *item = qdict_get_try_str(qdict, "item");
695

    
696
    if (!item) {
697
        goto help;
698
    }
699

    
700
    for (cmd = info_cmds; cmd->name != NULL; cmd++) {
701
        if (compare_cmd(item, cmd->name))
702
            break;
703
    }
704

    
705
    if (cmd->name == NULL) {
706
        goto help;
707
    }
708

    
709
    cmd->mhandler.info(mon);
710
    return;
711

    
712
help:
713
    help_cmd(mon, "info");
714
}
715

    
716
CommandInfoList *qmp_query_commands(Error **errp)
717
{
718
    CommandInfoList *info, *cmd_list = NULL;
719
    const mon_cmd_t *cmd;
720

    
721
    for (cmd = qmp_cmds; cmd->name != NULL; cmd++) {
722
        info = g_malloc0(sizeof(*info));
723
        info->value = g_malloc0(sizeof(*info->value));
724
        info->value->name = g_strdup(cmd->name);
725

    
726
        info->next = cmd_list;
727
        cmd_list = info;
728
    }
729

    
730
    return cmd_list;
731
}
732

    
733
/* set the current CPU defined by the user */
734
int monitor_set_cpu(int cpu_index)
735
{
736
    CPUState *env;
737

    
738
    for(env = first_cpu; env != NULL; env = env->next_cpu) {
739
        if (env->cpu_index == cpu_index) {
740
            cur_mon->mon_cpu = env;
741
            return 0;
742
        }
743
    }
744
    return -1;
745
}
746

    
747
static CPUState *mon_get_cpu(void)
748
{
749
    if (!cur_mon->mon_cpu) {
750
        monitor_set_cpu(0);
751
    }
752
    cpu_synchronize_state(cur_mon->mon_cpu);
753
    return cur_mon->mon_cpu;
754
}
755

    
756
int monitor_get_cpu_index(void)
757
{
758
    return mon_get_cpu()->cpu_index;
759
}
760

    
761
static void do_info_registers(Monitor *mon)
762
{
763
    CPUState *env;
764
    env = mon_get_cpu();
765
#ifdef TARGET_I386
766
    cpu_dump_state(env, (FILE *)mon, monitor_fprintf,
767
                   X86_DUMP_FPU);
768
#else
769
    cpu_dump_state(env, (FILE *)mon, monitor_fprintf,
770
                   0);
771
#endif
772
}
773

    
774
static void do_info_jit(Monitor *mon)
775
{
776
    dump_exec_info((FILE *)mon, monitor_fprintf);
777
}
778

    
779
static void do_info_history(Monitor *mon)
780
{
781
    int i;
782
    const char *str;
783

    
784
    if (!mon->rs)
785
        return;
786
    i = 0;
787
    for(;;) {
788
        str = readline_get_history(mon->rs, i);
789
        if (!str)
790
            break;
791
        monitor_printf(mon, "%d: '%s'\n", i, str);
792
        i++;
793
    }
794
}
795

    
796
#if defined(TARGET_PPC)
797
/* XXX: not implemented in other targets */
798
static void do_info_cpu_stats(Monitor *mon)
799
{
800
    CPUState *env;
801

    
802
    env = mon_get_cpu();
803
    cpu_dump_statistics(env, (FILE *)mon, &monitor_fprintf, 0);
804
}
805
#endif
806

    
807
#if defined(CONFIG_TRACE_SIMPLE)
808
static void do_info_trace(Monitor *mon)
809
{
810
    st_print_trace((FILE *)mon, &monitor_fprintf);
811
}
812
#endif
813

    
814
static void do_trace_print_events(Monitor *mon)
815
{
816
    trace_print_events((FILE *)mon, &monitor_fprintf);
817
}
818

    
819
static int add_graphics_client(Monitor *mon, const QDict *qdict, QObject **ret_data)
820
{
821
    const char *protocol  = qdict_get_str(qdict, "protocol");
822
    const char *fdname = qdict_get_str(qdict, "fdname");
823
    CharDriverState *s;
824

    
825
    if (strcmp(protocol, "spice") == 0) {
826
        if (!using_spice) {
827
            /* correct one? spice isn't a device ,,, */
828
            qerror_report(QERR_DEVICE_NOT_ACTIVE, "spice");
829
            return -1;
830
        }
831
        qerror_report(QERR_ADD_CLIENT_FAILED);
832
        return -1;
833
#ifdef CONFIG_VNC
834
    } else if (strcmp(protocol, "vnc") == 0) {
835
        int fd = monitor_get_fd(mon, fdname);
836
        int skipauth = qdict_get_try_bool(qdict, "skipauth", 0);
837
        vnc_display_add_client(NULL, fd, skipauth);
838
        return 0;
839
#endif
840
    } else if ((s = qemu_chr_find(protocol)) != NULL) {
841
        int fd = monitor_get_fd(mon, fdname);
842
        if (qemu_chr_add_client(s, fd) < 0) {
843
            qerror_report(QERR_ADD_CLIENT_FAILED);
844
            return -1;
845
        }
846
        return 0;
847
    }
848

    
849
    qerror_report(QERR_INVALID_PARAMETER, "protocol");
850
    return -1;
851
}
852

    
853
static int client_migrate_info(Monitor *mon, const QDict *qdict,
854
                               MonitorCompletion cb, void *opaque)
855
{
856
    const char *protocol = qdict_get_str(qdict, "protocol");
857
    const char *hostname = qdict_get_str(qdict, "hostname");
858
    const char *subject  = qdict_get_try_str(qdict, "cert-subject");
859
    int port             = qdict_get_try_int(qdict, "port", -1);
860
    int tls_port         = qdict_get_try_int(qdict, "tls-port", -1);
861
    int ret;
862

    
863
    if (strcmp(protocol, "spice") == 0) {
864
        if (!using_spice) {
865
            qerror_report(QERR_DEVICE_NOT_ACTIVE, "spice");
866
            return -1;
867
        }
868

    
869
        ret = qemu_spice_migrate_info(hostname, port, tls_port, subject,
870
                                      cb, opaque);
871
        if (ret != 0) {
872
            qerror_report(QERR_UNDEFINED_ERROR);
873
            return -1;
874
        }
875
        return 0;
876
    }
877

    
878
    qerror_report(QERR_INVALID_PARAMETER, "protocol");
879
    return -1;
880
}
881

    
882
static int do_screen_dump(Monitor *mon, const QDict *qdict, QObject **ret_data)
883
{
884
    vga_hw_screen_dump(qdict_get_str(qdict, "filename"));
885
    return 0;
886
}
887

    
888
static void do_logfile(Monitor *mon, const QDict *qdict)
889
{
890
    cpu_set_log_filename(qdict_get_str(qdict, "filename"));
891
}
892

    
893
static void do_log(Monitor *mon, const QDict *qdict)
894
{
895
    int mask;
896
    const char *items = qdict_get_str(qdict, "items");
897

    
898
    if (!strcmp(items, "none")) {
899
        mask = 0;
900
    } else {
901
        mask = cpu_str_to_log_mask(items);
902
        if (!mask) {
903
            help_cmd(mon, "log");
904
            return;
905
        }
906
    }
907
    cpu_set_log(mask);
908
}
909

    
910
static void do_singlestep(Monitor *mon, const QDict *qdict)
911
{
912
    const char *option = qdict_get_try_str(qdict, "option");
913
    if (!option || !strcmp(option, "on")) {
914
        singlestep = 1;
915
    } else if (!strcmp(option, "off")) {
916
        singlestep = 0;
917
    } else {
918
        monitor_printf(mon, "unexpected option %s\n", option);
919
    }
920
}
921

    
922
static void do_gdbserver(Monitor *mon, const QDict *qdict)
923
{
924
    const char *device = qdict_get_try_str(qdict, "device");
925
    if (!device)
926
        device = "tcp::" DEFAULT_GDBSTUB_PORT;
927
    if (gdbserver_start(device) < 0) {
928
        monitor_printf(mon, "Could not open gdbserver on device '%s'\n",
929
                       device);
930
    } else if (strcmp(device, "none") == 0) {
931
        monitor_printf(mon, "Disabled gdbserver\n");
932
    } else {
933
        monitor_printf(mon, "Waiting for gdb connection on device '%s'\n",
934
                       device);
935
    }
936
}
937

    
938
static void do_watchdog_action(Monitor *mon, const QDict *qdict)
939
{
940
    const char *action = qdict_get_str(qdict, "action");
941
    if (select_watchdog_action(action) == -1) {
942
        monitor_printf(mon, "Unknown watchdog action '%s'\n", action);
943
    }
944
}
945

    
946
static void monitor_printc(Monitor *mon, int c)
947
{
948
    monitor_printf(mon, "'");
949
    switch(c) {
950
    case '\'':
951
        monitor_printf(mon, "\\'");
952
        break;
953
    case '\\':
954
        monitor_printf(mon, "\\\\");
955
        break;
956
    case '\n':
957
        monitor_printf(mon, "\\n");
958
        break;
959
    case '\r':
960
        monitor_printf(mon, "\\r");
961
        break;
962
    default:
963
        if (c >= 32 && c <= 126) {
964
            monitor_printf(mon, "%c", c);
965
        } else {
966
            monitor_printf(mon, "\\x%02x", c);
967
        }
968
        break;
969
    }
970
    monitor_printf(mon, "'");
971
}
972

    
973
static void memory_dump(Monitor *mon, int count, int format, int wsize,
974
                        target_phys_addr_t addr, int is_physical)
975
{
976
    CPUState *env;
977
    int l, line_size, i, max_digits, len;
978
    uint8_t buf[16];
979
    uint64_t v;
980

    
981
    if (format == 'i') {
982
        int flags;
983
        flags = 0;
984
        env = mon_get_cpu();
985
#ifdef TARGET_I386
986
        if (wsize == 2) {
987
            flags = 1;
988
        } else if (wsize == 4) {
989
            flags = 0;
990
        } else {
991
            /* as default we use the current CS size */
992
            flags = 0;
993
            if (env) {
994
#ifdef TARGET_X86_64
995
                if ((env->efer & MSR_EFER_LMA) &&
996
                    (env->segs[R_CS].flags & DESC_L_MASK))
997
                    flags = 2;
998
                else
999
#endif
1000
                if (!(env->segs[R_CS].flags & DESC_B_MASK))
1001
                    flags = 1;
1002
            }
1003
        }
1004
#endif
1005
        monitor_disas(mon, env, addr, count, is_physical, flags);
1006
        return;
1007
    }
1008

    
1009
    len = wsize * count;
1010
    if (wsize == 1)
1011
        line_size = 8;
1012
    else
1013
        line_size = 16;
1014
    max_digits = 0;
1015

    
1016
    switch(format) {
1017
    case 'o':
1018
        max_digits = (wsize * 8 + 2) / 3;
1019
        break;
1020
    default:
1021
    case 'x':
1022
        max_digits = (wsize * 8) / 4;
1023
        break;
1024
    case 'u':
1025
    case 'd':
1026
        max_digits = (wsize * 8 * 10 + 32) / 33;
1027
        break;
1028
    case 'c':
1029
        wsize = 1;
1030
        break;
1031
    }
1032

    
1033
    while (len > 0) {
1034
        if (is_physical)
1035
            monitor_printf(mon, TARGET_FMT_plx ":", addr);
1036
        else
1037
            monitor_printf(mon, TARGET_FMT_lx ":", (target_ulong)addr);
1038
        l = len;
1039
        if (l > line_size)
1040
            l = line_size;
1041
        if (is_physical) {
1042
            cpu_physical_memory_read(addr, buf, l);
1043
        } else {
1044
            env = mon_get_cpu();
1045
            if (cpu_memory_rw_debug(env, addr, buf, l, 0) < 0) {
1046
                monitor_printf(mon, " Cannot access memory\n");
1047
                break;
1048
            }
1049
        }
1050
        i = 0;
1051
        while (i < l) {
1052
            switch(wsize) {
1053
            default:
1054
            case 1:
1055
                v = ldub_raw(buf + i);
1056
                break;
1057
            case 2:
1058
                v = lduw_raw(buf + i);
1059
                break;
1060
            case 4:
1061
                v = (uint32_t)ldl_raw(buf + i);
1062
                break;
1063
            case 8:
1064
                v = ldq_raw(buf + i);
1065
                break;
1066
            }
1067
            monitor_printf(mon, " ");
1068
            switch(format) {
1069
            case 'o':
1070
                monitor_printf(mon, "%#*" PRIo64, max_digits, v);
1071
                break;
1072
            case 'x':
1073
                monitor_printf(mon, "0x%0*" PRIx64, max_digits, v);
1074
                break;
1075
            case 'u':
1076
                monitor_printf(mon, "%*" PRIu64, max_digits, v);
1077
                break;
1078
            case 'd':
1079
                monitor_printf(mon, "%*" PRId64, max_digits, v);
1080
                break;
1081
            case 'c':
1082
                monitor_printc(mon, v);
1083
                break;
1084
            }
1085
            i += wsize;
1086
        }
1087
        monitor_printf(mon, "\n");
1088
        addr += l;
1089
        len -= l;
1090
    }
1091
}
1092

    
1093
static void do_memory_dump(Monitor *mon, const QDict *qdict)
1094
{
1095
    int count = qdict_get_int(qdict, "count");
1096
    int format = qdict_get_int(qdict, "format");
1097
    int size = qdict_get_int(qdict, "size");
1098
    target_long addr = qdict_get_int(qdict, "addr");
1099

    
1100
    memory_dump(mon, count, format, size, addr, 0);
1101
}
1102

    
1103
static void do_physical_memory_dump(Monitor *mon, const QDict *qdict)
1104
{
1105
    int count = qdict_get_int(qdict, "count");
1106
    int format = qdict_get_int(qdict, "format");
1107
    int size = qdict_get_int(qdict, "size");
1108
    target_phys_addr_t addr = qdict_get_int(qdict, "addr");
1109

    
1110
    memory_dump(mon, count, format, size, addr, 1);
1111
}
1112

    
1113
static void do_print(Monitor *mon, const QDict *qdict)
1114
{
1115
    int format = qdict_get_int(qdict, "format");
1116
    target_phys_addr_t val = qdict_get_int(qdict, "val");
1117

    
1118
#if TARGET_PHYS_ADDR_BITS == 32
1119
    switch(format) {
1120
    case 'o':
1121
        monitor_printf(mon, "%#o", val);
1122
        break;
1123
    case 'x':
1124
        monitor_printf(mon, "%#x", val);
1125
        break;
1126
    case 'u':
1127
        monitor_printf(mon, "%u", val);
1128
        break;
1129
    default:
1130
    case 'd':
1131
        monitor_printf(mon, "%d", val);
1132
        break;
1133
    case 'c':
1134
        monitor_printc(mon, val);
1135
        break;
1136
    }
1137
#else
1138
    switch(format) {
1139
    case 'o':
1140
        monitor_printf(mon, "%#" PRIo64, val);
1141
        break;
1142
    case 'x':
1143
        monitor_printf(mon, "%#" PRIx64, val);
1144
        break;
1145
    case 'u':
1146
        monitor_printf(mon, "%" PRIu64, val);
1147
        break;
1148
    default:
1149
    case 'd':
1150
        monitor_printf(mon, "%" PRId64, val);
1151
        break;
1152
    case 'c':
1153
        monitor_printc(mon, val);
1154
        break;
1155
    }
1156
#endif
1157
    monitor_printf(mon, "\n");
1158
}
1159

    
1160
static void do_sum(Monitor *mon, const QDict *qdict)
1161
{
1162
    uint32_t addr;
1163
    uint16_t sum;
1164
    uint32_t start = qdict_get_int(qdict, "start");
1165
    uint32_t size = qdict_get_int(qdict, "size");
1166

    
1167
    sum = 0;
1168
    for(addr = start; addr < (start + size); addr++) {
1169
        uint8_t val = ldub_phys(addr);
1170
        /* BSD sum algorithm ('sum' Unix command) */
1171
        sum = (sum >> 1) | (sum << 15);
1172
        sum += val;
1173
    }
1174
    monitor_printf(mon, "%05d\n", sum);
1175
}
1176

    
1177
typedef struct {
1178
    int keycode;
1179
    const char *name;
1180
} KeyDef;
1181

    
1182
static const KeyDef key_defs[] = {
1183
    { 0x2a, "shift" },
1184
    { 0x36, "shift_r" },
1185

    
1186
    { 0x38, "alt" },
1187
    { 0xb8, "alt_r" },
1188
    { 0x64, "altgr" },
1189
    { 0xe4, "altgr_r" },
1190
    { 0x1d, "ctrl" },
1191
    { 0x9d, "ctrl_r" },
1192

    
1193
    { 0xdd, "menu" },
1194

    
1195
    { 0x01, "esc" },
1196

    
1197
    { 0x02, "1" },
1198
    { 0x03, "2" },
1199
    { 0x04, "3" },
1200
    { 0x05, "4" },
1201
    { 0x06, "5" },
1202
    { 0x07, "6" },
1203
    { 0x08, "7" },
1204
    { 0x09, "8" },
1205
    { 0x0a, "9" },
1206
    { 0x0b, "0" },
1207
    { 0x0c, "minus" },
1208
    { 0x0d, "equal" },
1209
    { 0x0e, "backspace" },
1210

    
1211
    { 0x0f, "tab" },
1212
    { 0x10, "q" },
1213
    { 0x11, "w" },
1214
    { 0x12, "e" },
1215
    { 0x13, "r" },
1216
    { 0x14, "t" },
1217
    { 0x15, "y" },
1218
    { 0x16, "u" },
1219
    { 0x17, "i" },
1220
    { 0x18, "o" },
1221
    { 0x19, "p" },
1222
    { 0x1a, "bracket_left" },
1223
    { 0x1b, "bracket_right" },
1224
    { 0x1c, "ret" },
1225

    
1226
    { 0x1e, "a" },
1227
    { 0x1f, "s" },
1228
    { 0x20, "d" },
1229
    { 0x21, "f" },
1230
    { 0x22, "g" },
1231
    { 0x23, "h" },
1232
    { 0x24, "j" },
1233
    { 0x25, "k" },
1234
    { 0x26, "l" },
1235
    { 0x27, "semicolon" },
1236
    { 0x28, "apostrophe" },
1237
    { 0x29, "grave_accent" },
1238

    
1239
    { 0x2b, "backslash" },
1240
    { 0x2c, "z" },
1241
    { 0x2d, "x" },
1242
    { 0x2e, "c" },
1243
    { 0x2f, "v" },
1244
    { 0x30, "b" },
1245
    { 0x31, "n" },
1246
    { 0x32, "m" },
1247
    { 0x33, "comma" },
1248
    { 0x34, "dot" },
1249
    { 0x35, "slash" },
1250

    
1251
    { 0x37, "asterisk" },
1252

    
1253
    { 0x39, "spc" },
1254
    { 0x3a, "caps_lock" },
1255
    { 0x3b, "f1" },
1256
    { 0x3c, "f2" },
1257
    { 0x3d, "f3" },
1258
    { 0x3e, "f4" },
1259
    { 0x3f, "f5" },
1260
    { 0x40, "f6" },
1261
    { 0x41, "f7" },
1262
    { 0x42, "f8" },
1263
    { 0x43, "f9" },
1264
    { 0x44, "f10" },
1265
    { 0x45, "num_lock" },
1266
    { 0x46, "scroll_lock" },
1267

    
1268
    { 0xb5, "kp_divide" },
1269
    { 0x37, "kp_multiply" },
1270
    { 0x4a, "kp_subtract" },
1271
    { 0x4e, "kp_add" },
1272
    { 0x9c, "kp_enter" },
1273
    { 0x53, "kp_decimal" },
1274
    { 0x54, "sysrq" },
1275

    
1276
    { 0x52, "kp_0" },
1277
    { 0x4f, "kp_1" },
1278
    { 0x50, "kp_2" },
1279
    { 0x51, "kp_3" },
1280
    { 0x4b, "kp_4" },
1281
    { 0x4c, "kp_5" },
1282
    { 0x4d, "kp_6" },
1283
    { 0x47, "kp_7" },
1284
    { 0x48, "kp_8" },
1285
    { 0x49, "kp_9" },
1286

    
1287
    { 0x56, "<" },
1288

    
1289
    { 0x57, "f11" },
1290
    { 0x58, "f12" },
1291

    
1292
    { 0xb7, "print" },
1293

    
1294
    { 0xc7, "home" },
1295
    { 0xc9, "pgup" },
1296
    { 0xd1, "pgdn" },
1297
    { 0xcf, "end" },
1298

    
1299
    { 0xcb, "left" },
1300
    { 0xc8, "up" },
1301
    { 0xd0, "down" },
1302
    { 0xcd, "right" },
1303

    
1304
    { 0xd2, "insert" },
1305
    { 0xd3, "delete" },
1306
#if defined(TARGET_SPARC) && !defined(TARGET_SPARC64)
1307
    { 0xf0, "stop" },
1308
    { 0xf1, "again" },
1309
    { 0xf2, "props" },
1310
    { 0xf3, "undo" },
1311
    { 0xf4, "front" },
1312
    { 0xf5, "copy" },
1313
    { 0xf6, "open" },
1314
    { 0xf7, "paste" },
1315
    { 0xf8, "find" },
1316
    { 0xf9, "cut" },
1317
    { 0xfa, "lf" },
1318
    { 0xfb, "help" },
1319
    { 0xfc, "meta_l" },
1320
    { 0xfd, "meta_r" },
1321
    { 0xfe, "compose" },
1322
#endif
1323
    { 0, NULL },
1324
};
1325

    
1326
static int get_keycode(const char *key)
1327
{
1328
    const KeyDef *p;
1329
    char *endp;
1330
    int ret;
1331

    
1332
    for(p = key_defs; p->name != NULL; p++) {
1333
        if (!strcmp(key, p->name))
1334
            return p->keycode;
1335
    }
1336
    if (strstart(key, "0x", NULL)) {
1337
        ret = strtoul(key, &endp, 0);
1338
        if (*endp == '\0' && ret >= 0x01 && ret <= 0xff)
1339
            return ret;
1340
    }
1341
    return -1;
1342
}
1343

    
1344
#define MAX_KEYCODES 16
1345
static uint8_t keycodes[MAX_KEYCODES];
1346
static int nb_pending_keycodes;
1347
static QEMUTimer *key_timer;
1348

    
1349
static void release_keys(void *opaque)
1350
{
1351
    int keycode;
1352

    
1353
    while (nb_pending_keycodes > 0) {
1354
        nb_pending_keycodes--;
1355
        keycode = keycodes[nb_pending_keycodes];
1356
        if (keycode & 0x80)
1357
            kbd_put_keycode(0xe0);
1358
        kbd_put_keycode(keycode | 0x80);
1359
    }
1360
}
1361

    
1362
static void do_sendkey(Monitor *mon, const QDict *qdict)
1363
{
1364
    char keyname_buf[16];
1365
    char *separator;
1366
    int keyname_len, keycode, i;
1367
    const char *string = qdict_get_str(qdict, "string");
1368
    int has_hold_time = qdict_haskey(qdict, "hold_time");
1369
    int hold_time = qdict_get_try_int(qdict, "hold_time", -1);
1370

    
1371
    if (nb_pending_keycodes > 0) {
1372
        qemu_del_timer(key_timer);
1373
        release_keys(NULL);
1374
    }
1375
    if (!has_hold_time)
1376
        hold_time = 100;
1377
    i = 0;
1378
    while (1) {
1379
        separator = strchr(string, '-');
1380
        keyname_len = separator ? separator - string : strlen(string);
1381
        if (keyname_len > 0) {
1382
            pstrcpy(keyname_buf, sizeof(keyname_buf), string);
1383
            if (keyname_len > sizeof(keyname_buf) - 1) {
1384
                monitor_printf(mon, "invalid key: '%s...'\n", keyname_buf);
1385
                return;
1386
            }
1387
            if (i == MAX_KEYCODES) {
1388
                monitor_printf(mon, "too many keys\n");
1389
                return;
1390
            }
1391
            keyname_buf[keyname_len] = 0;
1392
            keycode = get_keycode(keyname_buf);
1393
            if (keycode < 0) {
1394
                monitor_printf(mon, "unknown key: '%s'\n", keyname_buf);
1395
                return;
1396
            }
1397
            keycodes[i++] = keycode;
1398
        }
1399
        if (!separator)
1400
            break;
1401
        string = separator + 1;
1402
    }
1403
    nb_pending_keycodes = i;
1404
    /* key down events */
1405
    for (i = 0; i < nb_pending_keycodes; i++) {
1406
        keycode = keycodes[i];
1407
        if (keycode & 0x80)
1408
            kbd_put_keycode(0xe0);
1409
        kbd_put_keycode(keycode & 0x7f);
1410
    }
1411
    /* delayed key up events */
1412
    qemu_mod_timer(key_timer, qemu_get_clock_ns(vm_clock) +
1413
                   muldiv64(get_ticks_per_sec(), hold_time, 1000));
1414
}
1415

    
1416
static int mouse_button_state;
1417

    
1418
static void do_mouse_move(Monitor *mon, const QDict *qdict)
1419
{
1420
    int dx, dy, dz;
1421
    const char *dx_str = qdict_get_str(qdict, "dx_str");
1422
    const char *dy_str = qdict_get_str(qdict, "dy_str");
1423
    const char *dz_str = qdict_get_try_str(qdict, "dz_str");
1424
    dx = strtol(dx_str, NULL, 0);
1425
    dy = strtol(dy_str, NULL, 0);
1426
    dz = 0;
1427
    if (dz_str)
1428
        dz = strtol(dz_str, NULL, 0);
1429
    kbd_mouse_event(dx, dy, dz, mouse_button_state);
1430
}
1431

    
1432
static void do_mouse_button(Monitor *mon, const QDict *qdict)
1433
{
1434
    int button_state = qdict_get_int(qdict, "button_state");
1435
    mouse_button_state = button_state;
1436
    kbd_mouse_event(0, 0, 0, mouse_button_state);
1437
}
1438

    
1439
static void do_ioport_read(Monitor *mon, const QDict *qdict)
1440
{
1441
    int size = qdict_get_int(qdict, "size");
1442
    int addr = qdict_get_int(qdict, "addr");
1443
    int has_index = qdict_haskey(qdict, "index");
1444
    uint32_t val;
1445
    int suffix;
1446

    
1447
    if (has_index) {
1448
        int index = qdict_get_int(qdict, "index");
1449
        cpu_outb(addr & IOPORTS_MASK, index & 0xff);
1450
        addr++;
1451
    }
1452
    addr &= 0xffff;
1453

    
1454
    switch(size) {
1455
    default:
1456
    case 1:
1457
        val = cpu_inb(addr);
1458
        suffix = 'b';
1459
        break;
1460
    case 2:
1461
        val = cpu_inw(addr);
1462
        suffix = 'w';
1463
        break;
1464
    case 4:
1465
        val = cpu_inl(addr);
1466
        suffix = 'l';
1467
        break;
1468
    }
1469
    monitor_printf(mon, "port%c[0x%04x] = %#0*x\n",
1470
                   suffix, addr, size * 2, val);
1471
}
1472

    
1473
static void do_ioport_write(Monitor *mon, const QDict *qdict)
1474
{
1475
    int size = qdict_get_int(qdict, "size");
1476
    int addr = qdict_get_int(qdict, "addr");
1477
    int val = qdict_get_int(qdict, "val");
1478

    
1479
    addr &= IOPORTS_MASK;
1480

    
1481
    switch (size) {
1482
    default:
1483
    case 1:
1484
        cpu_outb(addr, val);
1485
        break;
1486
    case 2:
1487
        cpu_outw(addr, val);
1488
        break;
1489
    case 4:
1490
        cpu_outl(addr, val);
1491
        break;
1492
    }
1493
}
1494

    
1495
static void do_boot_set(Monitor *mon, const QDict *qdict)
1496
{
1497
    int res;
1498
    const char *bootdevice = qdict_get_str(qdict, "bootdevice");
1499

    
1500
    res = qemu_boot_set(bootdevice);
1501
    if (res == 0) {
1502
        monitor_printf(mon, "boot device list now set to %s\n", bootdevice);
1503
    } else if (res > 0) {
1504
        monitor_printf(mon, "setting boot device list failed\n");
1505
    } else {
1506
        monitor_printf(mon, "no function defined to set boot device list for "
1507
                       "this architecture\n");
1508
    }
1509
}
1510

    
1511
#if defined(TARGET_I386)
1512
static void print_pte(Monitor *mon, target_phys_addr_t addr,
1513
                      target_phys_addr_t pte,
1514
                      target_phys_addr_t mask)
1515
{
1516
#ifdef TARGET_X86_64
1517
    if (addr & (1ULL << 47)) {
1518
        addr |= -1LL << 48;
1519
    }
1520
#endif
1521
    monitor_printf(mon, TARGET_FMT_plx ": " TARGET_FMT_plx
1522
                   " %c%c%c%c%c%c%c%c%c\n",
1523
                   addr,
1524
                   pte & mask,
1525
                   pte & PG_NX_MASK ? 'X' : '-',
1526
                   pte & PG_GLOBAL_MASK ? 'G' : '-',
1527
                   pte & PG_PSE_MASK ? 'P' : '-',
1528
                   pte & PG_DIRTY_MASK ? 'D' : '-',
1529
                   pte & PG_ACCESSED_MASK ? 'A' : '-',
1530
                   pte & PG_PCD_MASK ? 'C' : '-',
1531
                   pte & PG_PWT_MASK ? 'T' : '-',
1532
                   pte & PG_USER_MASK ? 'U' : '-',
1533
                   pte & PG_RW_MASK ? 'W' : '-');
1534
}
1535

    
1536
static void tlb_info_32(Monitor *mon, CPUState *env)
1537
{
1538
    unsigned int l1, l2;
1539
    uint32_t pgd, pde, pte;
1540

    
1541
    pgd = env->cr[3] & ~0xfff;
1542
    for(l1 = 0; l1 < 1024; l1++) {
1543
        cpu_physical_memory_read(pgd + l1 * 4, &pde, 4);
1544
        pde = le32_to_cpu(pde);
1545
        if (pde & PG_PRESENT_MASK) {
1546
            if ((pde & PG_PSE_MASK) && (env->cr[4] & CR4_PSE_MASK)) {
1547
                /* 4M pages */
1548
                print_pte(mon, (l1 << 22), pde, ~((1 << 21) - 1));
1549
            } else {
1550
                for(l2 = 0; l2 < 1024; l2++) {
1551
                    cpu_physical_memory_read((pde & ~0xfff) + l2 * 4, &pte, 4);
1552
                    pte = le32_to_cpu(pte);
1553
                    if (pte & PG_PRESENT_MASK) {
1554
                        print_pte(mon, (l1 << 22) + (l2 << 12),
1555
                                  pte & ~PG_PSE_MASK,
1556
                                  ~0xfff);
1557
                    }
1558
                }
1559
            }
1560
        }
1561
    }
1562
}
1563

    
1564
static void tlb_info_pae32(Monitor *mon, CPUState *env)
1565
{
1566
    unsigned int l1, l2, l3;
1567
    uint64_t pdpe, pde, pte;
1568
    uint64_t pdp_addr, pd_addr, pt_addr;
1569

    
1570
    pdp_addr = env->cr[3] & ~0x1f;
1571
    for (l1 = 0; l1 < 4; l1++) {
1572
        cpu_physical_memory_read(pdp_addr + l1 * 8, &pdpe, 8);
1573
        pdpe = le64_to_cpu(pdpe);
1574
        if (pdpe & PG_PRESENT_MASK) {
1575
            pd_addr = pdpe & 0x3fffffffff000ULL;
1576
            for (l2 = 0; l2 < 512; l2++) {
1577
                cpu_physical_memory_read(pd_addr + l2 * 8, &pde, 8);
1578
                pde = le64_to_cpu(pde);
1579
                if (pde & PG_PRESENT_MASK) {
1580
                    if (pde & PG_PSE_MASK) {
1581
                        /* 2M pages with PAE, CR4.PSE is ignored */
1582
                        print_pte(mon, (l1 << 30 ) + (l2 << 21), pde,
1583
                                  ~((target_phys_addr_t)(1 << 20) - 1));
1584
                    } else {
1585
                        pt_addr = pde & 0x3fffffffff000ULL;
1586
                        for (l3 = 0; l3 < 512; l3++) {
1587
                            cpu_physical_memory_read(pt_addr + l3 * 8, &pte, 8);
1588
                            pte = le64_to_cpu(pte);
1589
                            if (pte & PG_PRESENT_MASK) {
1590
                                print_pte(mon, (l1 << 30 ) + (l2 << 21)
1591
                                          + (l3 << 12),
1592
                                          pte & ~PG_PSE_MASK,
1593
                                          ~(target_phys_addr_t)0xfff);
1594
                            }
1595
                        }
1596
                    }
1597
                }
1598
            }
1599
        }
1600
    }
1601
}
1602

    
1603
#ifdef TARGET_X86_64
1604
static void tlb_info_64(Monitor *mon, CPUState *env)
1605
{
1606
    uint64_t l1, l2, l3, l4;
1607
    uint64_t pml4e, pdpe, pde, pte;
1608
    uint64_t pml4_addr, pdp_addr, pd_addr, pt_addr;
1609

    
1610
    pml4_addr = env->cr[3] & 0x3fffffffff000ULL;
1611
    for (l1 = 0; l1 < 512; l1++) {
1612
        cpu_physical_memory_read(pml4_addr + l1 * 8, &pml4e, 8);
1613
        pml4e = le64_to_cpu(pml4e);
1614
        if (pml4e & PG_PRESENT_MASK) {
1615
            pdp_addr = pml4e & 0x3fffffffff000ULL;
1616
            for (l2 = 0; l2 < 512; l2++) {
1617
                cpu_physical_memory_read(pdp_addr + l2 * 8, &pdpe, 8);
1618
                pdpe = le64_to_cpu(pdpe);
1619
                if (pdpe & PG_PRESENT_MASK) {
1620
                    if (pdpe & PG_PSE_MASK) {
1621
                        /* 1G pages, CR4.PSE is ignored */
1622
                        print_pte(mon, (l1 << 39) + (l2 << 30), pdpe,
1623
                                  0x3ffffc0000000ULL);
1624
                    } else {
1625
                        pd_addr = pdpe & 0x3fffffffff000ULL;
1626
                        for (l3 = 0; l3 < 512; l3++) {
1627
                            cpu_physical_memory_read(pd_addr + l3 * 8, &pde, 8);
1628
                            pde = le64_to_cpu(pde);
1629
                            if (pde & PG_PRESENT_MASK) {
1630
                                if (pde & PG_PSE_MASK) {
1631
                                    /* 2M pages, CR4.PSE is ignored */
1632
                                    print_pte(mon, (l1 << 39) + (l2 << 30) +
1633
                                              (l3 << 21), pde,
1634
                                              0x3ffffffe00000ULL);
1635
                                } else {
1636
                                    pt_addr = pde & 0x3fffffffff000ULL;
1637
                                    for (l4 = 0; l4 < 512; l4++) {
1638
                                        cpu_physical_memory_read(pt_addr
1639
                                                                 + l4 * 8,
1640
                                                                 &pte, 8);
1641
                                        pte = le64_to_cpu(pte);
1642
                                        if (pte & PG_PRESENT_MASK) {
1643
                                            print_pte(mon, (l1 << 39) +
1644
                                                      (l2 << 30) +
1645
                                                      (l3 << 21) + (l4 << 12),
1646
                                                      pte & ~PG_PSE_MASK,
1647
                                                      0x3fffffffff000ULL);
1648
                                        }
1649
                                    }
1650
                                }
1651
                            }
1652
                        }
1653
                    }
1654
                }
1655
            }
1656
        }
1657
    }
1658
}
1659
#endif
1660

    
1661
static void tlb_info(Monitor *mon)
1662
{
1663
    CPUState *env;
1664

    
1665
    env = mon_get_cpu();
1666

    
1667
    if (!(env->cr[0] & CR0_PG_MASK)) {
1668
        monitor_printf(mon, "PG disabled\n");
1669
        return;
1670
    }
1671
    if (env->cr[4] & CR4_PAE_MASK) {
1672
#ifdef TARGET_X86_64
1673
        if (env->hflags & HF_LMA_MASK) {
1674
            tlb_info_64(mon, env);
1675
        } else
1676
#endif
1677
        {
1678
            tlb_info_pae32(mon, env);
1679
        }
1680
    } else {
1681
        tlb_info_32(mon, env);
1682
    }
1683
}
1684

    
1685
static void mem_print(Monitor *mon, target_phys_addr_t *pstart,
1686
                      int *plast_prot,
1687
                      target_phys_addr_t end, int prot)
1688
{
1689
    int prot1;
1690
    prot1 = *plast_prot;
1691
    if (prot != prot1) {
1692
        if (*pstart != -1) {
1693
            monitor_printf(mon, TARGET_FMT_plx "-" TARGET_FMT_plx " "
1694
                           TARGET_FMT_plx " %c%c%c\n",
1695
                           *pstart, end, end - *pstart,
1696
                           prot1 & PG_USER_MASK ? 'u' : '-',
1697
                           'r',
1698
                           prot1 & PG_RW_MASK ? 'w' : '-');
1699
        }
1700
        if (prot != 0)
1701
            *pstart = end;
1702
        else
1703
            *pstart = -1;
1704
        *plast_prot = prot;
1705
    }
1706
}
1707

    
1708
static void mem_info_32(Monitor *mon, CPUState *env)
1709
{
1710
    unsigned int l1, l2;
1711
    int prot, last_prot;
1712
    uint32_t pgd, pde, pte;
1713
    target_phys_addr_t start, end;
1714

    
1715
    pgd = env->cr[3] & ~0xfff;
1716
    last_prot = 0;
1717
    start = -1;
1718
    for(l1 = 0; l1 < 1024; l1++) {
1719
        cpu_physical_memory_read(pgd + l1 * 4, &pde, 4);
1720
        pde = le32_to_cpu(pde);
1721
        end = l1 << 22;
1722
        if (pde & PG_PRESENT_MASK) {
1723
            if ((pde & PG_PSE_MASK) && (env->cr[4] & CR4_PSE_MASK)) {
1724
                prot = pde & (PG_USER_MASK | PG_RW_MASK | PG_PRESENT_MASK);
1725
                mem_print(mon, &start, &last_prot, end, prot);
1726
            } else {
1727
                for(l2 = 0; l2 < 1024; l2++) {
1728
                    cpu_physical_memory_read((pde & ~0xfff) + l2 * 4, &pte, 4);
1729
                    pte = le32_to_cpu(pte);
1730
                    end = (l1 << 22) + (l2 << 12);
1731
                    if (pte & PG_PRESENT_MASK) {
1732
                        prot = pte & pde &
1733
                            (PG_USER_MASK | PG_RW_MASK | PG_PRESENT_MASK);
1734
                    } else {
1735
                        prot = 0;
1736
                    }
1737
                    mem_print(mon, &start, &last_prot, end, prot);
1738
                }
1739
            }
1740
        } else {
1741
            prot = 0;
1742
            mem_print(mon, &start, &last_prot, end, prot);
1743
        }
1744
    }
1745
    /* Flush last range */
1746
    mem_print(mon, &start, &last_prot, (target_phys_addr_t)1 << 32, 0);
1747
}
1748

    
1749
static void mem_info_pae32(Monitor *mon, CPUState *env)
1750
{
1751
    unsigned int l1, l2, l3;
1752
    int prot, last_prot;
1753
    uint64_t pdpe, pde, pte;
1754
    uint64_t pdp_addr, pd_addr, pt_addr;
1755
    target_phys_addr_t start, end;
1756

    
1757
    pdp_addr = env->cr[3] & ~0x1f;
1758
    last_prot = 0;
1759
    start = -1;
1760
    for (l1 = 0; l1 < 4; l1++) {
1761
        cpu_physical_memory_read(pdp_addr + l1 * 8, &pdpe, 8);
1762
        pdpe = le64_to_cpu(pdpe);
1763
        end = l1 << 30;
1764
        if (pdpe & PG_PRESENT_MASK) {
1765
            pd_addr = pdpe & 0x3fffffffff000ULL;
1766
            for (l2 = 0; l2 < 512; l2++) {
1767
                cpu_physical_memory_read(pd_addr + l2 * 8, &pde, 8);
1768
                pde = le64_to_cpu(pde);
1769
                end = (l1 << 30) + (l2 << 21);
1770
                if (pde & PG_PRESENT_MASK) {
1771
                    if (pde & PG_PSE_MASK) {
1772
                        prot = pde & (PG_USER_MASK | PG_RW_MASK |
1773
                                      PG_PRESENT_MASK);
1774
                        mem_print(mon, &start, &last_prot, end, prot);
1775
                    } else {
1776
                        pt_addr = pde & 0x3fffffffff000ULL;
1777
                        for (l3 = 0; l3 < 512; l3++) {
1778
                            cpu_physical_memory_read(pt_addr + l3 * 8, &pte, 8);
1779
                            pte = le64_to_cpu(pte);
1780
                            end = (l1 << 30) + (l2 << 21) + (l3 << 12);
1781
                            if (pte & PG_PRESENT_MASK) {
1782
                                prot = pte & pde & (PG_USER_MASK | PG_RW_MASK |
1783
                                                    PG_PRESENT_MASK);
1784
                            } else {
1785
                                prot = 0;
1786
                            }
1787
                            mem_print(mon, &start, &last_prot, end, prot);
1788
                        }
1789
                    }
1790
                } else {
1791
                    prot = 0;
1792
                    mem_print(mon, &start, &last_prot, end, prot);
1793
                }
1794
            }
1795
        } else {
1796
            prot = 0;
1797
            mem_print(mon, &start, &last_prot, end, prot);
1798
        }
1799
    }
1800
    /* Flush last range */
1801
    mem_print(mon, &start, &last_prot, (target_phys_addr_t)1 << 32, 0);
1802
}
1803

    
1804

    
1805
#ifdef TARGET_X86_64
1806
static void mem_info_64(Monitor *mon, CPUState *env)
1807
{
1808
    int prot, last_prot;
1809
    uint64_t l1, l2, l3, l4;
1810
    uint64_t pml4e, pdpe, pde, pte;
1811
    uint64_t pml4_addr, pdp_addr, pd_addr, pt_addr, start, end;
1812

    
1813
    pml4_addr = env->cr[3] & 0x3fffffffff000ULL;
1814
    last_prot = 0;
1815
    start = -1;
1816
    for (l1 = 0; l1 < 512; l1++) {
1817
        cpu_physical_memory_read(pml4_addr + l1 * 8, &pml4e, 8);
1818
        pml4e = le64_to_cpu(pml4e);
1819
        end = l1 << 39;
1820
        if (pml4e & PG_PRESENT_MASK) {
1821
            pdp_addr = pml4e & 0x3fffffffff000ULL;
1822
            for (l2 = 0; l2 < 512; l2++) {
1823
                cpu_physical_memory_read(pdp_addr + l2 * 8, &pdpe, 8);
1824
                pdpe = le64_to_cpu(pdpe);
1825
                end = (l1 << 39) + (l2 << 30);
1826
                if (pdpe & PG_PRESENT_MASK) {
1827
                    if (pdpe & PG_PSE_MASK) {
1828
                        prot = pdpe & (PG_USER_MASK | PG_RW_MASK |
1829
                                       PG_PRESENT_MASK);
1830
                        prot &= pml4e;
1831
                        mem_print(mon, &start, &last_prot, end, prot);
1832
                    } else {
1833
                        pd_addr = pdpe & 0x3fffffffff000ULL;
1834
                        for (l3 = 0; l3 < 512; l3++) {
1835
                            cpu_physical_memory_read(pd_addr + l3 * 8, &pde, 8);
1836
                            pde = le64_to_cpu(pde);
1837
                            end = (l1 << 39) + (l2 << 30) + (l3 << 21);
1838
                            if (pde & PG_PRESENT_MASK) {
1839
                                if (pde & PG_PSE_MASK) {
1840
                                    prot = pde & (PG_USER_MASK | PG_RW_MASK |
1841
                                                  PG_PRESENT_MASK);
1842
                                    prot &= pml4e & pdpe;
1843
                                    mem_print(mon, &start, &last_prot, end, prot);
1844
                                } else {
1845
                                    pt_addr = pde & 0x3fffffffff000ULL;
1846
                                    for (l4 = 0; l4 < 512; l4++) {
1847
                                        cpu_physical_memory_read(pt_addr
1848
                                                                 + l4 * 8,
1849
                                                                 &pte, 8);
1850
                                        pte = le64_to_cpu(pte);
1851
                                        end = (l1 << 39) + (l2 << 30) +
1852
                                            (l3 << 21) + (l4 << 12);
1853
                                        if (pte & PG_PRESENT_MASK) {
1854
                                            prot = pte & (PG_USER_MASK | PG_RW_MASK |
1855
                                                          PG_PRESENT_MASK);
1856
                                            prot &= pml4e & pdpe & pde;
1857
                                        } else {
1858
                                            prot = 0;
1859
                                        }
1860
                                        mem_print(mon, &start, &last_prot, end, prot);
1861
                                    }
1862
                                }
1863
                            } else {
1864
                                prot = 0;
1865
                                mem_print(mon, &start, &last_prot, end, prot);
1866
                            }
1867
                        }
1868
                    }
1869
                } else {
1870
                    prot = 0;
1871
                    mem_print(mon, &start, &last_prot, end, prot);
1872
                }
1873
            }
1874
        } else {
1875
            prot = 0;
1876
            mem_print(mon, &start, &last_prot, end, prot);
1877
        }
1878
    }
1879
    /* Flush last range */
1880
    mem_print(mon, &start, &last_prot, (target_phys_addr_t)1 << 48, 0);
1881
}
1882
#endif
1883

    
1884
static void mem_info(Monitor *mon)
1885
{
1886
    CPUState *env;
1887

    
1888
    env = mon_get_cpu();
1889

    
1890
    if (!(env->cr[0] & CR0_PG_MASK)) {
1891
        monitor_printf(mon, "PG disabled\n");
1892
        return;
1893
    }
1894
    if (env->cr[4] & CR4_PAE_MASK) {
1895
#ifdef TARGET_X86_64
1896
        if (env->hflags & HF_LMA_MASK) {
1897
            mem_info_64(mon, env);
1898
        } else
1899
#endif
1900
        {
1901
            mem_info_pae32(mon, env);
1902
        }
1903
    } else {
1904
        mem_info_32(mon, env);
1905
    }
1906
}
1907
#endif
1908

    
1909
#if defined(TARGET_SH4)
1910

    
1911
static void print_tlb(Monitor *mon, int idx, tlb_t *tlb)
1912
{
1913
    monitor_printf(mon, " tlb%i:\t"
1914
                   "asid=%hhu vpn=%x\tppn=%x\tsz=%hhu size=%u\t"
1915
                   "v=%hhu shared=%hhu cached=%hhu prot=%hhu "
1916
                   "dirty=%hhu writethrough=%hhu\n",
1917
                   idx,
1918
                   tlb->asid, tlb->vpn, tlb->ppn, tlb->sz, tlb->size,
1919
                   tlb->v, tlb->sh, tlb->c, tlb->pr,
1920
                   tlb->d, tlb->wt);
1921
}
1922

    
1923
static void tlb_info(Monitor *mon)
1924
{
1925
    CPUState *env = mon_get_cpu();
1926
    int i;
1927

    
1928
    monitor_printf (mon, "ITLB:\n");
1929
    for (i = 0 ; i < ITLB_SIZE ; i++)
1930
        print_tlb (mon, i, &env->itlb[i]);
1931
    monitor_printf (mon, "UTLB:\n");
1932
    for (i = 0 ; i < UTLB_SIZE ; i++)
1933
        print_tlb (mon, i, &env->utlb[i]);
1934
}
1935

    
1936
#endif
1937

    
1938
#if defined(TARGET_SPARC) || defined(TARGET_PPC)
1939
static void tlb_info(Monitor *mon)
1940
{
1941
    CPUState *env1 = mon_get_cpu();
1942

    
1943
    dump_mmu((FILE*)mon, (fprintf_function)monitor_printf, env1);
1944
}
1945
#endif
1946

    
1947
static void do_info_mtree(Monitor *mon)
1948
{
1949
    mtree_info((fprintf_function)monitor_printf, mon);
1950
}
1951

    
1952
static void do_info_numa(Monitor *mon)
1953
{
1954
    int i;
1955
    CPUState *env;
1956

    
1957
    monitor_printf(mon, "%d nodes\n", nb_numa_nodes);
1958
    for (i = 0; i < nb_numa_nodes; i++) {
1959
        monitor_printf(mon, "node %d cpus:", i);
1960
        for (env = first_cpu; env != NULL; env = env->next_cpu) {
1961
            if (env->numa_node == i) {
1962
                monitor_printf(mon, " %d", env->cpu_index);
1963
            }
1964
        }
1965
        monitor_printf(mon, "\n");
1966
        monitor_printf(mon, "node %d size: %" PRId64 " MB\n", i,
1967
            node_mem[i] >> 20);
1968
    }
1969
}
1970

    
1971
#ifdef CONFIG_PROFILER
1972

    
1973
int64_t qemu_time;
1974
int64_t dev_time;
1975

    
1976
static void do_info_profile(Monitor *mon)
1977
{
1978
    int64_t total;
1979
    total = qemu_time;
1980
    if (total == 0)
1981
        total = 1;
1982
    monitor_printf(mon, "async time  %" PRId64 " (%0.3f)\n",
1983
                   dev_time, dev_time / (double)get_ticks_per_sec());
1984
    monitor_printf(mon, "qemu time   %" PRId64 " (%0.3f)\n",
1985
                   qemu_time, qemu_time / (double)get_ticks_per_sec());
1986
    qemu_time = 0;
1987
    dev_time = 0;
1988
}
1989
#else
1990
static void do_info_profile(Monitor *mon)
1991
{
1992
    monitor_printf(mon, "Internal profiler not compiled\n");
1993
}
1994
#endif
1995

    
1996
/* Capture support */
1997
static QLIST_HEAD (capture_list_head, CaptureState) capture_head;
1998

    
1999
static void do_info_capture(Monitor *mon)
2000
{
2001
    int i;
2002
    CaptureState *s;
2003

    
2004
    for (s = capture_head.lh_first, i = 0; s; s = s->entries.le_next, ++i) {
2005
        monitor_printf(mon, "[%d]: ", i);
2006
        s->ops.info (s->opaque);
2007
    }
2008
}
2009

    
2010
#ifdef HAS_AUDIO
2011
static void do_stop_capture(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 do_wav_capture(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
#endif
2052

    
2053
static qemu_acl *find_acl(Monitor *mon, const char *name)
2054
{
2055
    qemu_acl *acl = qemu_acl_find(name);
2056

    
2057
    if (!acl) {
2058
        monitor_printf(mon, "acl: unknown list '%s'\n", name);
2059
    }
2060
    return acl;
2061
}
2062

    
2063
static void do_acl_show(Monitor *mon, const QDict *qdict)
2064
{
2065
    const char *aclname = qdict_get_str(qdict, "aclname");
2066
    qemu_acl *acl = find_acl(mon, aclname);
2067
    qemu_acl_entry *entry;
2068
    int i = 0;
2069

    
2070
    if (acl) {
2071
        monitor_printf(mon, "policy: %s\n",
2072
                       acl->defaultDeny ? "deny" : "allow");
2073
        QTAILQ_FOREACH(entry, &acl->entries, next) {
2074
            i++;
2075
            monitor_printf(mon, "%d: %s %s\n", i,
2076
                           entry->deny ? "deny" : "allow", entry->match);
2077
        }
2078
    }
2079
}
2080

    
2081
static void do_acl_reset(Monitor *mon, const QDict *qdict)
2082
{
2083
    const char *aclname = qdict_get_str(qdict, "aclname");
2084
    qemu_acl *acl = find_acl(mon, aclname);
2085

    
2086
    if (acl) {
2087
        qemu_acl_reset(acl);
2088
        monitor_printf(mon, "acl: removed all rules\n");
2089
    }
2090
}
2091

    
2092
static void do_acl_policy(Monitor *mon, const QDict *qdict)
2093
{
2094
    const char *aclname = qdict_get_str(qdict, "aclname");
2095
    const char *policy = qdict_get_str(qdict, "policy");
2096
    qemu_acl *acl = find_acl(mon, aclname);
2097

    
2098
    if (acl) {
2099
        if (strcmp(policy, "allow") == 0) {
2100
            acl->defaultDeny = 0;
2101
            monitor_printf(mon, "acl: policy set to 'allow'\n");
2102
        } else if (strcmp(policy, "deny") == 0) {
2103
            acl->defaultDeny = 1;
2104
            monitor_printf(mon, "acl: policy set to 'deny'\n");
2105
        } else {
2106
            monitor_printf(mon, "acl: unknown policy '%s', "
2107
                           "expected 'deny' or 'allow'\n", policy);
2108
        }
2109
    }
2110
}
2111

    
2112
static void do_acl_add(Monitor *mon, const QDict *qdict)
2113
{
2114
    const char *aclname = qdict_get_str(qdict, "aclname");
2115
    const char *match = qdict_get_str(qdict, "match");
2116
    const char *policy = qdict_get_str(qdict, "policy");
2117
    int has_index = qdict_haskey(qdict, "index");
2118
    int index = qdict_get_try_int(qdict, "index", -1);
2119
    qemu_acl *acl = find_acl(mon, aclname);
2120
    int deny, ret;
2121

    
2122
    if (acl) {
2123
        if (strcmp(policy, "allow") == 0) {
2124
            deny = 0;
2125
        } else if (strcmp(policy, "deny") == 0) {
2126
            deny = 1;
2127
        } else {
2128
            monitor_printf(mon, "acl: unknown policy '%s', "
2129
                           "expected 'deny' or 'allow'\n", policy);
2130
            return;
2131
        }
2132
        if (has_index)
2133
            ret = qemu_acl_insert(acl, deny, match, index);
2134
        else
2135
            ret = qemu_acl_append(acl, deny, match);
2136
        if (ret < 0)
2137
            monitor_printf(mon, "acl: unable to add acl entry\n");
2138
        else
2139
            monitor_printf(mon, "acl: added rule at position %d\n", ret);
2140
    }
2141
}
2142

    
2143
static void do_acl_remove(Monitor *mon, const QDict *qdict)
2144
{
2145
    const char *aclname = qdict_get_str(qdict, "aclname");
2146
    const char *match = qdict_get_str(qdict, "match");
2147
    qemu_acl *acl = find_acl(mon, aclname);
2148
    int ret;
2149

    
2150
    if (acl) {
2151
        ret = qemu_acl_remove(acl, match);
2152
        if (ret < 0)
2153
            monitor_printf(mon, "acl: no matching acl entry\n");
2154
        else
2155
            monitor_printf(mon, "acl: removed rule at position %d\n", ret);
2156
    }
2157
}
2158

    
2159
#if defined(TARGET_I386)
2160
static void do_inject_mce(Monitor *mon, const QDict *qdict)
2161
{
2162
    CPUState *cenv;
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
    for (cenv = first_cpu; cenv != NULL; cenv = cenv->next_cpu) {
2175
        if (cenv->cpu_index == cpu_index) {
2176
            cpu_x86_inject_mce(mon, cenv, bank, status, mcg_status, addr, misc,
2177
                               flags);
2178
            break;
2179
        }
2180
    }
2181
}
2182
#endif
2183

    
2184
static int do_getfd(Monitor *mon, const QDict *qdict, QObject **ret_data)
2185
{
2186
    const char *fdname = qdict_get_str(qdict, "fdname");
2187
    mon_fd_t *monfd;
2188
    int fd;
2189

    
2190
    fd = qemu_chr_fe_get_msgfd(mon->chr);
2191
    if (fd == -1) {
2192
        qerror_report(QERR_FD_NOT_SUPPLIED);
2193
        return -1;
2194
    }
2195

    
2196
    if (qemu_isdigit(fdname[0])) {
2197
        qerror_report(QERR_INVALID_PARAMETER_VALUE, "fdname",
2198
                      "a name not starting with a digit");
2199
        return -1;
2200
    }
2201

    
2202
    QLIST_FOREACH(monfd, &mon->fds, next) {
2203
        if (strcmp(monfd->name, fdname) != 0) {
2204
            continue;
2205
        }
2206

    
2207
        close(monfd->fd);
2208
        monfd->fd = fd;
2209
        return 0;
2210
    }
2211

    
2212
    monfd = g_malloc0(sizeof(mon_fd_t));
2213
    monfd->name = g_strdup(fdname);
2214
    monfd->fd = fd;
2215

    
2216
    QLIST_INSERT_HEAD(&mon->fds, monfd, next);
2217
    return 0;
2218
}
2219

    
2220
static int do_closefd(Monitor *mon, const QDict *qdict, QObject **ret_data)
2221
{
2222
    const char *fdname = qdict_get_str(qdict, "fdname");
2223
    mon_fd_t *monfd;
2224

    
2225
    QLIST_FOREACH(monfd, &mon->fds, next) {
2226
        if (strcmp(monfd->name, fdname) != 0) {
2227
            continue;
2228
        }
2229

    
2230
        QLIST_REMOVE(monfd, next);
2231
        close(monfd->fd);
2232
        g_free(monfd->name);
2233
        g_free(monfd);
2234
        return 0;
2235
    }
2236

    
2237
    qerror_report(QERR_FD_NOT_FOUND, fdname);
2238
    return -1;
2239
}
2240

    
2241
static void do_loadvm(Monitor *mon, const QDict *qdict)
2242
{
2243
    int saved_vm_running  = runstate_is_running();
2244
    const char *name = qdict_get_str(qdict, "name");
2245

    
2246
    vm_stop(RUN_STATE_RESTORE_VM);
2247

    
2248
    if (load_vmstate(name) == 0 && saved_vm_running) {
2249
        vm_start();
2250
    }
2251
}
2252

    
2253
int monitor_get_fd(Monitor *mon, const char *fdname)
2254
{
2255
    mon_fd_t *monfd;
2256

    
2257
    QLIST_FOREACH(monfd, &mon->fds, next) {
2258
        int fd;
2259

    
2260
        if (strcmp(monfd->name, fdname) != 0) {
2261
            continue;
2262
        }
2263

    
2264
        fd = monfd->fd;
2265

    
2266
        /* caller takes ownership of fd */
2267
        QLIST_REMOVE(monfd, next);
2268
        g_free(monfd->name);
2269
        g_free(monfd);
2270

    
2271
        return fd;
2272
    }
2273

    
2274
    return -1;
2275
}
2276

    
2277
/* mon_cmds and info_cmds would be sorted at runtime */
2278
static mon_cmd_t mon_cmds[] = {
2279
#include "hmp-commands.h"
2280
    { NULL, NULL, },
2281
};
2282

    
2283
/* Please update hmp-commands.hx when adding or changing commands */
2284
static mon_cmd_t info_cmds[] = {
2285
    {
2286
        .name       = "version",
2287
        .args_type  = "",
2288
        .params     = "",
2289
        .help       = "show the version of QEMU",
2290
        .mhandler.info = hmp_info_version,
2291
    },
2292
    {
2293
        .name       = "network",
2294
        .args_type  = "",
2295
        .params     = "",
2296
        .help       = "show the network state",
2297
        .mhandler.info = do_info_network,
2298
    },
2299
    {
2300
        .name       = "chardev",
2301
        .args_type  = "",
2302
        .params     = "",
2303
        .help       = "show the character devices",
2304
        .mhandler.info = hmp_info_chardev,
2305
    },
2306
    {
2307
        .name       = "block",
2308
        .args_type  = "",
2309
        .params     = "",
2310
        .help       = "show the block devices",
2311
        .mhandler.info = hmp_info_block,
2312
    },
2313
    {
2314
        .name       = "blockstats",
2315
        .args_type  = "",
2316
        .params     = "",
2317
        .help       = "show block device statistics",
2318
        .mhandler.info = hmp_info_blockstats,
2319
    },
2320
    {
2321
        .name       = "block-jobs",
2322
        .args_type  = "",
2323
        .params     = "",
2324
        .help       = "show progress of ongoing block device operations",
2325
        .mhandler.info = hmp_info_block_jobs,
2326
    },
2327
    {
2328
        .name       = "registers",
2329
        .args_type  = "",
2330
        .params     = "",
2331
        .help       = "show the cpu registers",
2332
        .mhandler.info = do_info_registers,
2333
    },
2334
    {
2335
        .name       = "cpus",
2336
        .args_type  = "",
2337
        .params     = "",
2338
        .help       = "show infos for each CPU",
2339
        .mhandler.info = hmp_info_cpus,
2340
    },
2341
    {
2342
        .name       = "history",
2343
        .args_type  = "",
2344
        .params     = "",
2345
        .help       = "show the command line history",
2346
        .mhandler.info = do_info_history,
2347
    },
2348
#if defined(TARGET_I386) || defined(TARGET_PPC) || defined(TARGET_MIPS) || \
2349
    defined(TARGET_LM32) || (defined(TARGET_SPARC) && !defined(TARGET_SPARC64))
2350
    {
2351
        .name       = "irq",
2352
        .args_type  = "",
2353
        .params     = "",
2354
        .help       = "show the interrupts statistics (if available)",
2355
#ifdef TARGET_SPARC
2356
        .mhandler.info = sun4m_irq_info,
2357
#elif defined(TARGET_LM32)
2358
        .mhandler.info = lm32_irq_info,
2359
#else
2360
        .mhandler.info = irq_info,
2361
#endif
2362
    },
2363
    {
2364
        .name       = "pic",
2365
        .args_type  = "",
2366
        .params     = "",
2367
        .help       = "show i8259 (PIC) state",
2368
#ifdef TARGET_SPARC
2369
        .mhandler.info = sun4m_pic_info,
2370
#elif defined(TARGET_LM32)
2371
        .mhandler.info = lm32_do_pic_info,
2372
#else
2373
        .mhandler.info = pic_info,
2374
#endif
2375
    },
2376
#endif
2377
    {
2378
        .name       = "pci",
2379
        .args_type  = "",
2380
        .params     = "",
2381
        .help       = "show PCI info",
2382
        .mhandler.info = hmp_info_pci,
2383
    },
2384
#if defined(TARGET_I386) || defined(TARGET_SH4) || defined(TARGET_SPARC) || \
2385
    defined(TARGET_PPC)
2386
    {
2387
        .name       = "tlb",
2388
        .args_type  = "",
2389
        .params     = "",
2390
        .help       = "show virtual to physical memory mappings",
2391
        .mhandler.info = tlb_info,
2392
    },
2393
#endif
2394
#if defined(TARGET_I386)
2395
    {
2396
        .name       = "mem",
2397
        .args_type  = "",
2398
        .params     = "",
2399
        .help       = "show the active virtual memory mappings",
2400
        .mhandler.info = mem_info,
2401
    },
2402
#endif
2403
    {
2404
        .name       = "mtree",
2405
        .args_type  = "",
2406
        .params     = "",
2407
        .help       = "show memory tree",
2408
        .mhandler.info = do_info_mtree,
2409
    },
2410
    {
2411
        .name       = "jit",
2412
        .args_type  = "",
2413
        .params     = "",
2414
        .help       = "show dynamic compiler info",
2415
        .mhandler.info = do_info_jit,
2416
    },
2417
    {
2418
        .name       = "kvm",
2419
        .args_type  = "",
2420
        .params     = "",
2421
        .help       = "show KVM information",
2422
        .mhandler.info = hmp_info_kvm,
2423
    },
2424
    {
2425
        .name       = "numa",
2426
        .args_type  = "",
2427
        .params     = "",
2428
        .help       = "show NUMA information",
2429
        .mhandler.info = do_info_numa,
2430
    },
2431
    {
2432
        .name       = "usb",
2433
        .args_type  = "",
2434
        .params     = "",
2435
        .help       = "show guest USB devices",
2436
        .mhandler.info = usb_info,
2437
    },
2438
    {
2439
        .name       = "usbhost",
2440
        .args_type  = "",
2441
        .params     = "",
2442
        .help       = "show host USB devices",
2443
        .mhandler.info = usb_host_info,
2444
    },
2445
    {
2446
        .name       = "profile",
2447
        .args_type  = "",
2448
        .params     = "",
2449
        .help       = "show profiling information",
2450
        .mhandler.info = do_info_profile,
2451
    },
2452
    {
2453
        .name       = "capture",
2454
        .args_type  = "",
2455
        .params     = "",
2456
        .help       = "show capture information",
2457
        .mhandler.info = do_info_capture,
2458
    },
2459
    {
2460
        .name       = "snapshots",
2461
        .args_type  = "",
2462
        .params     = "",
2463
        .help       = "show the currently saved VM snapshots",
2464
        .mhandler.info = do_info_snapshots,
2465
    },
2466
    {
2467
        .name       = "status",
2468
        .args_type  = "",
2469
        .params     = "",
2470
        .help       = "show the current VM status (running|paused)",
2471
        .mhandler.info = hmp_info_status,
2472
    },
2473
    {
2474
        .name       = "pcmcia",
2475
        .args_type  = "",
2476
        .params     = "",
2477
        .help       = "show guest PCMCIA status",
2478
        .mhandler.info = pcmcia_info,
2479
    },
2480
    {
2481
        .name       = "mice",
2482
        .args_type  = "",
2483
        .params     = "",
2484
        .help       = "show which guest mouse is receiving events",
2485
        .mhandler.info = hmp_info_mice,
2486
    },
2487
    {
2488
        .name       = "vnc",
2489
        .args_type  = "",
2490
        .params     = "",
2491
        .help       = "show the vnc server status",
2492
        .mhandler.info = hmp_info_vnc,
2493
    },
2494
#if defined(CONFIG_SPICE)
2495
    {
2496
        .name       = "spice",
2497
        .args_type  = "",
2498
        .params     = "",
2499
        .help       = "show the spice server status",
2500
        .mhandler.info = hmp_info_spice,
2501
    },
2502
#endif
2503
    {
2504
        .name       = "name",
2505
        .args_type  = "",
2506
        .params     = "",
2507
        .help       = "show the current VM name",
2508
        .mhandler.info = hmp_info_name,
2509
    },
2510
    {
2511
        .name       = "uuid",
2512
        .args_type  = "",
2513
        .params     = "",
2514
        .help       = "show the current VM UUID",
2515
        .mhandler.info = hmp_info_uuid,
2516
    },
2517
#if defined(TARGET_PPC)
2518
    {
2519
        .name       = "cpustats",
2520
        .args_type  = "",
2521
        .params     = "",
2522
        .help       = "show CPU statistics",
2523
        .mhandler.info = do_info_cpu_stats,
2524
    },
2525
#endif
2526
#if defined(CONFIG_SLIRP)
2527
    {
2528
        .name       = "usernet",
2529
        .args_type  = "",
2530
        .params     = "",
2531
        .help       = "show user network stack connection states",
2532
        .mhandler.info = do_info_usernet,
2533
    },
2534
#endif
2535
    {
2536
        .name       = "migrate",
2537
        .args_type  = "",
2538
        .params     = "",
2539
        .help       = "show migration status",
2540
        .mhandler.info = hmp_info_migrate,
2541
    },
2542
    {
2543
        .name       = "balloon",
2544
        .args_type  = "",
2545
        .params     = "",
2546
        .help       = "show balloon information",
2547
        .mhandler.info = hmp_info_balloon,
2548
    },
2549
    {
2550
        .name       = "qtree",
2551
        .args_type  = "",
2552
        .params     = "",
2553
        .help       = "show device tree",
2554
        .mhandler.info = do_info_qtree,
2555
    },
2556
    {
2557
        .name       = "qdm",
2558
        .args_type  = "",
2559
        .params     = "",
2560
        .help       = "show qdev device model list",
2561
        .mhandler.info = do_info_qdm,
2562
    },
2563
    {
2564
        .name       = "roms",
2565
        .args_type  = "",
2566
        .params     = "",
2567
        .help       = "show roms",
2568
        .mhandler.info = do_info_roms,
2569
    },
2570
#if defined(CONFIG_TRACE_SIMPLE)
2571
    {
2572
        .name       = "trace",
2573
        .args_type  = "",
2574
        .params     = "",
2575
        .help       = "show current contents of trace buffer",
2576
        .mhandler.info = do_info_trace,
2577
    },
2578
#endif
2579
    {
2580
        .name       = "trace-events",
2581
        .args_type  = "",
2582
        .params     = "",
2583
        .help       = "show available trace-events & their state",
2584
        .mhandler.info = do_trace_print_events,
2585
    },
2586
    {
2587
        .name       = NULL,
2588
    },
2589
};
2590

    
2591
static const mon_cmd_t qmp_cmds[] = {
2592
#include "qmp-commands-old.h"
2593
    { /* NULL */ },
2594
};
2595

    
2596
/*******************************************************************/
2597

    
2598
static const char *pch;
2599
static jmp_buf expr_env;
2600

    
2601
#define MD_TLONG 0
2602
#define MD_I32   1
2603

    
2604
typedef struct MonitorDef {
2605
    const char *name;
2606
    int offset;
2607
    target_long (*get_value)(const struct MonitorDef *md, int val);
2608
    int type;
2609
} MonitorDef;
2610

    
2611
#if defined(TARGET_I386)
2612
static target_long monitor_get_pc (const struct MonitorDef *md, int val)
2613
{
2614
    CPUState *env = mon_get_cpu();
2615
    return env->eip + env->segs[R_CS].base;
2616
}
2617
#endif
2618

    
2619
#if defined(TARGET_PPC)
2620
static target_long monitor_get_ccr (const struct MonitorDef *md, int val)
2621
{
2622
    CPUState *env = mon_get_cpu();
2623
    unsigned int u;
2624
    int i;
2625

    
2626
    u = 0;
2627
    for (i = 0; i < 8; i++)
2628
        u |= env->crf[i] << (32 - (4 * i));
2629

    
2630
    return u;
2631
}
2632

    
2633
static target_long monitor_get_msr (const struct MonitorDef *md, int val)
2634
{
2635
    CPUState *env = mon_get_cpu();
2636
    return env->msr;
2637
}
2638

    
2639
static target_long monitor_get_xer (const struct MonitorDef *md, int val)
2640
{
2641
    CPUState *env = mon_get_cpu();
2642
    return env->xer;
2643
}
2644

    
2645
static target_long monitor_get_decr (const struct MonitorDef *md, int val)
2646
{
2647
    CPUState *env = mon_get_cpu();
2648
    return cpu_ppc_load_decr(env);
2649
}
2650

    
2651
static target_long monitor_get_tbu (const struct MonitorDef *md, int val)
2652
{
2653
    CPUState *env = mon_get_cpu();
2654
    return cpu_ppc_load_tbu(env);
2655
}
2656

    
2657
static target_long monitor_get_tbl (const struct MonitorDef *md, int val)
2658
{
2659
    CPUState *env = mon_get_cpu();
2660
    return cpu_ppc_load_tbl(env);
2661
}
2662
#endif
2663

    
2664
#if defined(TARGET_SPARC)
2665
#ifndef TARGET_SPARC64
2666
static target_long monitor_get_psr (const struct MonitorDef *md, int val)
2667
{
2668
    CPUState *env = mon_get_cpu();
2669

    
2670
    return cpu_get_psr(env);
2671
}
2672
#endif
2673

    
2674
static target_long monitor_get_reg(const struct MonitorDef *md, int val)
2675
{
2676
    CPUState *env = mon_get_cpu();
2677
    return env->regwptr[val];
2678
}
2679
#endif
2680

    
2681
static const MonitorDef monitor_defs[] = {
2682
#ifdef TARGET_I386
2683

    
2684
#define SEG(name, seg) \
2685
    { name, offsetof(CPUState, segs[seg].selector), NULL, MD_I32 },\
2686
    { name ".base", offsetof(CPUState, segs[seg].base) },\
2687
    { name ".limit", offsetof(CPUState, segs[seg].limit), NULL, MD_I32 },
2688

    
2689
    { "eax", offsetof(CPUState, regs[0]) },
2690
    { "ecx", offsetof(CPUState, regs[1]) },
2691
    { "edx", offsetof(CPUState, regs[2]) },
2692
    { "ebx", offsetof(CPUState, regs[3]) },
2693
    { "esp|sp", offsetof(CPUState, regs[4]) },
2694
    { "ebp|fp", offsetof(CPUState, regs[5]) },
2695
    { "esi", offsetof(CPUState, regs[6]) },
2696
    { "edi", offsetof(CPUState, regs[7]) },
2697
#ifdef TARGET_X86_64
2698
    { "r8", offsetof(CPUState, regs[8]) },
2699
    { "r9", offsetof(CPUState, regs[9]) },
2700
    { "r10", offsetof(CPUState, regs[10]) },
2701
    { "r11", offsetof(CPUState, regs[11]) },
2702
    { "r12", offsetof(CPUState, regs[12]) },
2703
    { "r13", offsetof(CPUState, regs[13]) },
2704
    { "r14", offsetof(CPUState, regs[14]) },
2705
    { "r15", offsetof(CPUState, regs[15]) },
2706
#endif
2707
    { "eflags", offsetof(CPUState, eflags) },
2708
    { "eip", offsetof(CPUState, eip) },
2709
    SEG("cs", R_CS)
2710
    SEG("ds", R_DS)
2711
    SEG("es", R_ES)
2712
    SEG("ss", R_SS)
2713
    SEG("fs", R_FS)
2714
    SEG("gs", R_GS)
2715
    { "pc", 0, monitor_get_pc, },
2716
#elif defined(TARGET_PPC)
2717
    /* General purpose registers */
2718
    { "r0", offsetof(CPUState, gpr[0]) },
2719
    { "r1", offsetof(CPUState, gpr[1]) },
2720
    { "r2", offsetof(CPUState, gpr[2]) },
2721
    { "r3", offsetof(CPUState, gpr[3]) },
2722
    { "r4", offsetof(CPUState, gpr[4]) },
2723
    { "r5", offsetof(CPUState, gpr[5]) },
2724
    { "r6", offsetof(CPUState, gpr[6]) },
2725
    { "r7", offsetof(CPUState, gpr[7]) },
2726
    { "r8", offsetof(CPUState, gpr[8]) },
2727
    { "r9", offsetof(CPUState, gpr[9]) },
2728
    { "r10", offsetof(CPUState, gpr[10]) },
2729
    { "r11", offsetof(CPUState, gpr[11]) },
2730
    { "r12", offsetof(CPUState, gpr[12]) },
2731
    { "r13", offsetof(CPUState, gpr[13]) },
2732
    { "r14", offsetof(CPUState, gpr[14]) },
2733
    { "r15", offsetof(CPUState, gpr[15]) },
2734
    { "r16", offsetof(CPUState, gpr[16]) },
2735
    { "r17", offsetof(CPUState, gpr[17]) },
2736
    { "r18", offsetof(CPUState, gpr[18]) },
2737
    { "r19", offsetof(CPUState, gpr[19]) },
2738
    { "r20", offsetof(CPUState, gpr[20]) },
2739
    { "r21", offsetof(CPUState, gpr[21]) },
2740
    { "r22", offsetof(CPUState, gpr[22]) },
2741
    { "r23", offsetof(CPUState, gpr[23]) },
2742
    { "r24", offsetof(CPUState, gpr[24]) },
2743
    { "r25", offsetof(CPUState, gpr[25]) },
2744
    { "r26", offsetof(CPUState, gpr[26]) },
2745
    { "r27", offsetof(CPUState, gpr[27]) },
2746
    { "r28", offsetof(CPUState, gpr[28]) },
2747
    { "r29", offsetof(CPUState, gpr[29]) },
2748
    { "r30", offsetof(CPUState, gpr[30]) },
2749
    { "r31", offsetof(CPUState, gpr[31]) },
2750
    /* Floating point registers */
2751
    { "f0", offsetof(CPUState, fpr[0]) },
2752
    { "f1", offsetof(CPUState, fpr[1]) },
2753
    { "f2", offsetof(CPUState, fpr[2]) },
2754
    { "f3", offsetof(CPUState, fpr[3]) },
2755
    { "f4", offsetof(CPUState, fpr[4]) },
2756
    { "f5", offsetof(CPUState, fpr[5]) },
2757
    { "f6", offsetof(CPUState, fpr[6]) },
2758
    { "f7", offsetof(CPUState, fpr[7]) },
2759
    { "f8", offsetof(CPUState, fpr[8]) },
2760
    { "f9", offsetof(CPUState, fpr[9]) },
2761
    { "f10", offsetof(CPUState, fpr[10]) },
2762
    { "f11", offsetof(CPUState, fpr[11]) },
2763
    { "f12", offsetof(CPUState, fpr[12]) },
2764
    { "f13", offsetof(CPUState, fpr[13]) },
2765
    { "f14", offsetof(CPUState, fpr[14]) },
2766
    { "f15", offsetof(CPUState, fpr[15]) },
2767
    { "f16", offsetof(CPUState, fpr[16]) },
2768
    { "f17", offsetof(CPUState, fpr[17]) },
2769
    { "f18", offsetof(CPUState, fpr[18]) },
2770
    { "f19", offsetof(CPUState, fpr[19]) },
2771
    { "f20", offsetof(CPUState, fpr[20]) },
2772
    { "f21", offsetof(CPUState, fpr[21]) },
2773
    { "f22", offsetof(CPUState, fpr[22]) },
2774
    { "f23", offsetof(CPUState, fpr[23]) },
2775
    { "f24", offsetof(CPUState, fpr[24]) },
2776
    { "f25", offsetof(CPUState, fpr[25]) },
2777
    { "f26", offsetof(CPUState, fpr[26]) },
2778
    { "f27", offsetof(CPUState, fpr[27]) },
2779
    { "f28", offsetof(CPUState, fpr[28]) },
2780
    { "f29", offsetof(CPUState, fpr[29]) },
2781
    { "f30", offsetof(CPUState, fpr[30]) },
2782
    { "f31", offsetof(CPUState, fpr[31]) },
2783
    { "fpscr", offsetof(CPUState, fpscr) },
2784
    /* Next instruction pointer */
2785
    { "nip|pc", offsetof(CPUState, nip) },
2786
    { "lr", offsetof(CPUState, lr) },
2787
    { "ctr", offsetof(CPUState, ctr) },
2788
    { "decr", 0, &monitor_get_decr, },
2789
    { "ccr", 0, &monitor_get_ccr, },
2790
    /* Machine state register */
2791
    { "msr", 0, &monitor_get_msr, },
2792
    { "xer", 0, &monitor_get_xer, },
2793
    { "tbu", 0, &monitor_get_tbu, },
2794
    { "tbl", 0, &monitor_get_tbl, },
2795
#if defined(TARGET_PPC64)
2796
    /* Address space register */
2797
    { "asr", offsetof(CPUState, asr) },
2798
#endif
2799
    /* Segment registers */
2800
    { "sdr1", offsetof(CPUState, spr[SPR_SDR1]) },
2801
    { "sr0", offsetof(CPUState, sr[0]) },
2802
    { "sr1", offsetof(CPUState, sr[1]) },
2803
    { "sr2", offsetof(CPUState, sr[2]) },
2804
    { "sr3", offsetof(CPUState, sr[3]) },
2805
    { "sr4", offsetof(CPUState, sr[4]) },
2806
    { "sr5", offsetof(CPUState, sr[5]) },
2807
    { "sr6", offsetof(CPUState, sr[6]) },
2808
    { "sr7", offsetof(CPUState, sr[7]) },
2809
    { "sr8", offsetof(CPUState, sr[8]) },
2810
    { "sr9", offsetof(CPUState, sr[9]) },
2811
    { "sr10", offsetof(CPUState, sr[10]) },
2812
    { "sr11", offsetof(CPUState, sr[11]) },
2813
    { "sr12", offsetof(CPUState, sr[12]) },
2814
    { "sr13", offsetof(CPUState, sr[13]) },
2815
    { "sr14", offsetof(CPUState, sr[14]) },
2816
    { "sr15", offsetof(CPUState, sr[15]) },
2817
    /* Too lazy to put BATs... */
2818
    { "pvr", offsetof(CPUState, spr[SPR_PVR]) },
2819

    
2820
    { "srr0", offsetof(CPUState, spr[SPR_SRR0]) },
2821
    { "srr1", offsetof(CPUState, spr[SPR_SRR1]) },
2822
    { "sprg0", offsetof(CPUState, spr[SPR_SPRG0]) },
2823
    { "sprg1", offsetof(CPUState, spr[SPR_SPRG1]) },
2824
    { "sprg2", offsetof(CPUState, spr[SPR_SPRG2]) },
2825
    { "sprg3", offsetof(CPUState, spr[SPR_SPRG3]) },
2826
    { "sprg4", offsetof(CPUState, spr[SPR_SPRG4]) },
2827
    { "sprg5", offsetof(CPUState, spr[SPR_SPRG5]) },
2828
    { "sprg6", offsetof(CPUState, spr[SPR_SPRG6]) },
2829
    { "sprg7", offsetof(CPUState, spr[SPR_SPRG7]) },
2830
    { "pid", offsetof(CPUState, spr[SPR_BOOKE_PID]) },
2831
    { "csrr0", offsetof(CPUState, spr[SPR_BOOKE_CSRR0]) },
2832
    { "csrr1", offsetof(CPUState, spr[SPR_BOOKE_CSRR1]) },
2833
    { "esr", offsetof(CPUState, spr[SPR_BOOKE_ESR]) },
2834
    { "dear", offsetof(CPUState, spr[SPR_BOOKE_DEAR]) },
2835
    { "mcsr", offsetof(CPUState, spr[SPR_BOOKE_MCSR]) },
2836
    { "tsr", offsetof(CPUState, spr[SPR_BOOKE_TSR]) },
2837
    { "tcr", offsetof(CPUState, spr[SPR_BOOKE_TCR]) },
2838
    { "vrsave", offsetof(CPUState, spr[SPR_VRSAVE]) },
2839
    { "pir", offsetof(CPUState, spr[SPR_BOOKE_PIR]) },
2840
    { "mcsrr0", offsetof(CPUState, spr[SPR_BOOKE_MCSRR0]) },
2841
    { "mcsrr1", offsetof(CPUState, spr[SPR_BOOKE_MCSRR1]) },
2842
    { "decar", offsetof(CPUState, spr[SPR_BOOKE_DECAR]) },
2843
    { "ivpr", offsetof(CPUState, spr[SPR_BOOKE_IVPR]) },
2844
    { "epcr", offsetof(CPUState, spr[SPR_BOOKE_EPCR]) },
2845
    { "sprg8", offsetof(CPUState, spr[SPR_BOOKE_SPRG8]) },
2846
    { "ivor0", offsetof(CPUState, spr[SPR_BOOKE_IVOR0]) },
2847
    { "ivor1", offsetof(CPUState, spr[SPR_BOOKE_IVOR1]) },
2848
    { "ivor2", offsetof(CPUState, spr[SPR_BOOKE_IVOR2]) },
2849
    { "ivor3", offsetof(CPUState, spr[SPR_BOOKE_IVOR3]) },
2850
    { "ivor4", offsetof(CPUState, spr[SPR_BOOKE_IVOR4]) },
2851
    { "ivor5", offsetof(CPUState, spr[SPR_BOOKE_IVOR5]) },
2852
    { "ivor6", offsetof(CPUState, spr[SPR_BOOKE_IVOR6]) },
2853
    { "ivor7", offsetof(CPUState, spr[SPR_BOOKE_IVOR7]) },
2854
    { "ivor8", offsetof(CPUState, spr[SPR_BOOKE_IVOR8]) },
2855
    { "ivor9", offsetof(CPUState, spr[SPR_BOOKE_IVOR9]) },
2856
    { "ivor10", offsetof(CPUState, spr[SPR_BOOKE_IVOR10]) },
2857
    { "ivor11", offsetof(CPUState, spr[SPR_BOOKE_IVOR11]) },
2858
    { "ivor12", offsetof(CPUState, spr[SPR_BOOKE_IVOR12]) },
2859
    { "ivor13", offsetof(CPUState, spr[SPR_BOOKE_IVOR13]) },
2860
    { "ivor14", offsetof(CPUState, spr[SPR_BOOKE_IVOR14]) },
2861
    { "ivor15", offsetof(CPUState, spr[SPR_BOOKE_IVOR15]) },
2862
    { "ivor32", offsetof(CPUState, spr[SPR_BOOKE_IVOR32]) },
2863
    { "ivor33", offsetof(CPUState, spr[SPR_BOOKE_IVOR33]) },
2864
    { "ivor34", offsetof(CPUState, spr[SPR_BOOKE_IVOR34]) },
2865
    { "ivor35", offsetof(CPUState, spr[SPR_BOOKE_IVOR35]) },
2866
    { "ivor36", offsetof(CPUState, spr[SPR_BOOKE_IVOR36]) },
2867
    { "ivor37", offsetof(CPUState, spr[SPR_BOOKE_IVOR37]) },
2868
    { "mas0", offsetof(CPUState, spr[SPR_BOOKE_MAS0]) },
2869
    { "mas1", offsetof(CPUState, spr[SPR_BOOKE_MAS1]) },
2870
    { "mas2", offsetof(CPUState, spr[SPR_BOOKE_MAS2]) },
2871
    { "mas3", offsetof(CPUState, spr[SPR_BOOKE_MAS3]) },
2872
    { "mas4", offsetof(CPUState, spr[SPR_BOOKE_MAS4]) },
2873
    { "mas6", offsetof(CPUState, spr[SPR_BOOKE_MAS6]) },
2874
    { "mas7", offsetof(CPUState, spr[SPR_BOOKE_MAS7]) },
2875
    { "mmucfg", offsetof(CPUState, spr[SPR_MMUCFG]) },
2876
    { "tlb0cfg", offsetof(CPUState, spr[SPR_BOOKE_TLB0CFG]) },
2877
    { "tlb1cfg", offsetof(CPUState, spr[SPR_BOOKE_TLB1CFG]) },
2878
    { "epr", offsetof(CPUState, spr[SPR_BOOKE_EPR]) },
2879
    { "eplc", offsetof(CPUState, spr[SPR_BOOKE_EPLC]) },
2880
    { "epsc", offsetof(CPUState, spr[SPR_BOOKE_EPSC]) },
2881
    { "svr", offsetof(CPUState, spr[SPR_E500_SVR]) },
2882
    { "mcar", offsetof(CPUState, spr[SPR_Exxx_MCAR]) },
2883
    { "pid1", offsetof(CPUState, spr[SPR_BOOKE_PID1]) },
2884
    { "pid2", offsetof(CPUState, spr[SPR_BOOKE_PID2]) },
2885
    { "hid0", offsetof(CPUState, spr[SPR_HID0]) },
2886

    
2887
#elif defined(TARGET_SPARC)
2888
    { "g0", offsetof(CPUState, gregs[0]) },
2889
    { "g1", offsetof(CPUState, gregs[1]) },
2890
    { "g2", offsetof(CPUState, gregs[2]) },
2891
    { "g3", offsetof(CPUState, gregs[3]) },
2892
    { "g4", offsetof(CPUState, gregs[4]) },
2893
    { "g5", offsetof(CPUState, gregs[5]) },
2894
    { "g6", offsetof(CPUState, gregs[6]) },
2895
    { "g7", offsetof(CPUState, gregs[7]) },
2896
    { "o0", 0, monitor_get_reg },
2897
    { "o1", 1, monitor_get_reg },
2898
    { "o2", 2, monitor_get_reg },
2899
    { "o3", 3, monitor_get_reg },
2900
    { "o4", 4, monitor_get_reg },
2901
    { "o5", 5, monitor_get_reg },
2902
    { "o6", 6, monitor_get_reg },
2903
    { "o7", 7, monitor_get_reg },
2904
    { "l0", 8, monitor_get_reg },
2905
    { "l1", 9, monitor_get_reg },
2906
    { "l2", 10, monitor_get_reg },
2907
    { "l3", 11, monitor_get_reg },
2908
    { "l4", 12, monitor_get_reg },
2909
    { "l5", 13, monitor_get_reg },
2910
    { "l6", 14, monitor_get_reg },
2911
    { "l7", 15, monitor_get_reg },
2912
    { "i0", 16, monitor_get_reg },
2913
    { "i1", 17, monitor_get_reg },
2914
    { "i2", 18, monitor_get_reg },
2915
    { "i3", 19, monitor_get_reg },
2916
    { "i4", 20, monitor_get_reg },
2917
    { "i5", 21, monitor_get_reg },
2918
    { "i6", 22, monitor_get_reg },
2919
    { "i7", 23, monitor_get_reg },
2920
    { "pc", offsetof(CPUState, pc) },
2921
    { "npc", offsetof(CPUState, npc) },
2922
    { "y", offsetof(CPUState, y) },
2923
#ifndef TARGET_SPARC64
2924
    { "psr", 0, &monitor_get_psr, },
2925
    { "wim", offsetof(CPUState, wim) },
2926
#endif
2927
    { "tbr", offsetof(CPUState, tbr) },
2928
    { "fsr", offsetof(CPUState, fsr) },
2929
    { "f0", offsetof(CPUState, fpr[0].l.upper) },
2930
    { "f1", offsetof(CPUState, fpr[0].l.lower) },
2931
    { "f2", offsetof(CPUState, fpr[1].l.upper) },
2932
    { "f3", offsetof(CPUState, fpr[1].l.lower) },
2933
    { "f4", offsetof(CPUState, fpr[2].l.upper) },
2934
    { "f5", offsetof(CPUState, fpr[2].l.lower) },
2935
    { "f6", offsetof(CPUState, fpr[3].l.upper) },
2936
    { "f7", offsetof(CPUState, fpr[3].l.lower) },
2937
    { "f8", offsetof(CPUState, fpr[4].l.upper) },
2938
    { "f9", offsetof(CPUState, fpr[4].l.lower) },
2939
    { "f10", offsetof(CPUState, fpr[5].l.upper) },
2940
    { "f11", offsetof(CPUState, fpr[5].l.lower) },
2941
    { "f12", offsetof(CPUState, fpr[6].l.upper) },
2942
    { "f13", offsetof(CPUState, fpr[6].l.lower) },
2943
    { "f14", offsetof(CPUState, fpr[7].l.upper) },
2944
    { "f15", offsetof(CPUState, fpr[7].l.lower) },
2945
    { "f16", offsetof(CPUState, fpr[8].l.upper) },
2946
    { "f17", offsetof(CPUState, fpr[8].l.lower) },
2947
    { "f18", offsetof(CPUState, fpr[9].l.upper) },
2948
    { "f19", offsetof(CPUState, fpr[9].l.lower) },
2949
    { "f20", offsetof(CPUState, fpr[10].l.upper) },
2950
    { "f21", offsetof(CPUState, fpr[10].l.lower) },
2951
    { "f22", offsetof(CPUState, fpr[11].l.upper) },
2952
    { "f23", offsetof(CPUState, fpr[11].l.lower) },
2953
    { "f24", offsetof(CPUState, fpr[12].l.upper) },
2954
    { "f25", offsetof(CPUState, fpr[12].l.lower) },
2955
    { "f26", offsetof(CPUState, fpr[13].l.upper) },
2956
    { "f27", offsetof(CPUState, fpr[13].l.lower) },
2957
    { "f28", offsetof(CPUState, fpr[14].l.upper) },
2958
    { "f29", offsetof(CPUState, fpr[14].l.lower) },
2959
    { "f30", offsetof(CPUState, fpr[15].l.upper) },
2960
    { "f31", offsetof(CPUState, fpr[15].l.lower) },
2961
#ifdef TARGET_SPARC64
2962
    { "f32", offsetof(CPUState, fpr[16]) },
2963
    { "f34", offsetof(CPUState, fpr[17]) },
2964
    { "f36", offsetof(CPUState, fpr[18]) },
2965
    { "f38", offsetof(CPUState, fpr[19]) },
2966
    { "f40", offsetof(CPUState, fpr[20]) },
2967
    { "f42", offsetof(CPUState, fpr[21]) },
2968
    { "f44", offsetof(CPUState, fpr[22]) },
2969
    { "f46", offsetof(CPUState, fpr[23]) },
2970
    { "f48", offsetof(CPUState, fpr[24]) },
2971
    { "f50", offsetof(CPUState, fpr[25]) },
2972
    { "f52", offsetof(CPUState, fpr[26]) },
2973
    { "f54", offsetof(CPUState, fpr[27]) },
2974
    { "f56", offsetof(CPUState, fpr[28]) },
2975
    { "f58", offsetof(CPUState, fpr[29]) },
2976
    { "f60", offsetof(CPUState, fpr[30]) },
2977
    { "f62", offsetof(CPUState, fpr[31]) },
2978
    { "asi", offsetof(CPUState, asi) },
2979
    { "pstate", offsetof(CPUState, pstate) },
2980
    { "cansave", offsetof(CPUState, cansave) },
2981
    { "canrestore", offsetof(CPUState, canrestore) },
2982
    { "otherwin", offsetof(CPUState, otherwin) },
2983
    { "wstate", offsetof(CPUState, wstate) },
2984
    { "cleanwin", offsetof(CPUState, cleanwin) },
2985
    { "fprs", offsetof(CPUState, fprs) },
2986
#endif
2987
#endif
2988
    { NULL },
2989
};
2990

    
2991
static void expr_error(Monitor *mon, const char *msg)
2992
{
2993
    monitor_printf(mon, "%s\n", msg);
2994
    longjmp(expr_env, 1);
2995
}
2996

    
2997
/* return 0 if OK, -1 if not found */
2998
static int get_monitor_def(target_long *pval, const char *name)
2999
{
3000
    const MonitorDef *md;
3001
    void *ptr;
3002

    
3003
    for(md = monitor_defs; md->name != NULL; md++) {
3004
        if (compare_cmd(name, md->name)) {
3005
            if (md->get_value) {
3006
                *pval = md->get_value(md, md->offset);
3007
            } else {
3008
                CPUState *env = mon_get_cpu();
3009
                ptr = (uint8_t *)env + md->offset;
3010
                switch(md->type) {
3011
                case MD_I32:
3012
                    *pval = *(int32_t *)ptr;
3013
                    break;
3014
                case MD_TLONG:
3015
                    *pval = *(target_long *)ptr;
3016
                    break;
3017
                default:
3018
                    *pval = 0;
3019
                    break;
3020
                }
3021
            }
3022
            return 0;
3023
        }
3024
    }
3025
    return -1;
3026
}
3027

    
3028
static void next(void)
3029
{
3030
    if (*pch != '\0') {
3031
        pch++;
3032
        while (qemu_isspace(*pch))
3033
            pch++;
3034
    }
3035
}
3036

    
3037
static int64_t expr_sum(Monitor *mon);
3038

    
3039
static int64_t expr_unary(Monitor *mon)
3040
{
3041
    int64_t n;
3042
    char *p;
3043
    int ret;
3044

    
3045
    switch(*pch) {
3046
    case '+':
3047
        next();
3048
        n = expr_unary(mon);
3049
        break;
3050
    case '-':
3051
        next();
3052
        n = -expr_unary(mon);
3053
        break;
3054
    case '~':
3055
        next();
3056
        n = ~expr_unary(mon);
3057
        break;
3058
    case '(':
3059
        next();
3060
        n = expr_sum(mon);
3061
        if (*pch != ')') {
3062
            expr_error(mon, "')' expected");
3063
        }
3064
        next();
3065
        break;
3066
    case '\'':
3067
        pch++;
3068
        if (*pch == '\0')
3069
            expr_error(mon, "character constant expected");
3070
        n = *pch;
3071
        pch++;
3072
        if (*pch != '\'')
3073
            expr_error(mon, "missing terminating \' character");
3074
        next();
3075
        break;
3076
    case '$':
3077
        {
3078
            char buf[128], *q;
3079
            target_long reg=0;
3080

    
3081
            pch++;
3082
            q = buf;
3083
            while ((*pch >= 'a' && *pch <= 'z') ||
3084
                   (*pch >= 'A' && *pch <= 'Z') ||
3085
                   (*pch >= '0' && *pch <= '9') ||
3086
                   *pch == '_' || *pch == '.') {
3087
                if ((q - buf) < sizeof(buf) - 1)
3088
                    *q++ = *pch;
3089
                pch++;
3090
            }
3091
            while (qemu_isspace(*pch))
3092
                pch++;
3093
            *q = 0;
3094
            ret = get_monitor_def(&reg, buf);
3095
            if (ret < 0)
3096
                expr_error(mon, "unknown register");
3097
            n = reg;
3098
        }
3099
        break;
3100
    case '\0':
3101
        expr_error(mon, "unexpected end of expression");
3102
        n = 0;
3103
        break;
3104
    default:
3105
#if TARGET_PHYS_ADDR_BITS > 32
3106
        n = strtoull(pch, &p, 0);
3107
#else
3108
        n = strtoul(pch, &p, 0);
3109
#endif
3110
        if (pch == p) {
3111
            expr_error(mon, "invalid char in expression");
3112
        }
3113
        pch = p;
3114
        while (qemu_isspace(*pch))
3115
            pch++;
3116
        break;
3117
    }
3118
    return n;
3119
}
3120

    
3121

    
3122
static int64_t expr_prod(Monitor *mon)
3123
{
3124
    int64_t val, val2;
3125
    int op;
3126

    
3127
    val = expr_unary(mon);
3128
    for(;;) {
3129
        op = *pch;
3130
        if (op != '*' && op != '/' && op != '%')
3131
            break;
3132
        next();
3133
        val2 = expr_unary(mon);
3134
        switch(op) {
3135
        default:
3136
        case '*':
3137
            val *= val2;
3138
            break;
3139
        case '/':
3140
        case '%':
3141
            if (val2 == 0)
3142
                expr_error(mon, "division by zero");
3143
            if (op == '/')
3144
                val /= val2;
3145
            else
3146
                val %= val2;
3147
            break;
3148
        }
3149
    }
3150
    return val;
3151
}
3152

    
3153
static int64_t expr_logic(Monitor *mon)
3154
{
3155
    int64_t val, val2;
3156
    int op;
3157

    
3158
    val = expr_prod(mon);
3159
    for(;;) {
3160
        op = *pch;
3161
        if (op != '&' && op != '|' && op != '^')
3162
            break;
3163
        next();
3164
        val2 = expr_prod(mon);
3165
        switch(op) {
3166
        default:
3167
        case '&':
3168
            val &= val2;
3169
            break;
3170
        case '|':
3171
            val |= val2;
3172
            break;
3173
        case '^':
3174
            val ^= val2;
3175
            break;
3176
        }
3177
    }
3178
    return val;
3179
}
3180

    
3181
static int64_t expr_sum(Monitor *mon)
3182
{
3183
    int64_t val, val2;
3184
    int op;
3185

    
3186
    val = expr_logic(mon);
3187
    for(;;) {
3188
        op = *pch;
3189
        if (op != '+' && op != '-')
3190
            break;
3191
        next();
3192
        val2 = expr_logic(mon);
3193
        if (op == '+')
3194
            val += val2;
3195
        else
3196
            val -= val2;
3197
    }
3198
    return val;
3199
}
3200

    
3201
static int get_expr(Monitor *mon, int64_t *pval, const char **pp)
3202
{
3203
    pch = *pp;
3204
    if (setjmp(expr_env)) {
3205
        *pp = pch;
3206
        return -1;
3207
    }
3208
    while (qemu_isspace(*pch))
3209
        pch++;
3210
    *pval = expr_sum(mon);
3211
    *pp = pch;
3212
    return 0;
3213
}
3214

    
3215
static int get_double(Monitor *mon, double *pval, const char **pp)
3216
{
3217
    const char *p = *pp;
3218
    char *tailp;
3219
    double d;
3220

    
3221
    d = strtod(p, &tailp);
3222
    if (tailp == p) {
3223
        monitor_printf(mon, "Number expected\n");
3224
        return -1;
3225
    }
3226
    if (d != d || d - d != 0) {
3227
        /* NaN or infinity */
3228
        monitor_printf(mon, "Bad number\n");
3229
        return -1;
3230
    }
3231
    *pval = d;
3232
    *pp = tailp;
3233
    return 0;
3234
}
3235

    
3236
static int get_str(char *buf, int buf_size, const char **pp)
3237
{
3238
    const char *p;
3239
    char *q;
3240
    int c;
3241

    
3242
    q = buf;
3243
    p = *pp;
3244
    while (qemu_isspace(*p))
3245
        p++;
3246
    if (*p == '\0') {
3247
    fail:
3248
        *q = '\0';
3249
        *pp = p;
3250
        return -1;
3251
    }
3252
    if (*p == '\"') {
3253
        p++;
3254
        while (*p != '\0' && *p != '\"') {
3255
            if (*p == '\\') {
3256
                p++;
3257
                c = *p++;
3258
                switch(c) {
3259
                case 'n':
3260
                    c = '\n';
3261
                    break;
3262
                case 'r':
3263
                    c = '\r';
3264
                    break;
3265
                case '\\':
3266
                case '\'':
3267
                case '\"':
3268
                    break;
3269
                default:
3270
                    qemu_printf("unsupported escape code: '\\%c'\n", c);
3271
                    goto fail;
3272
                }
3273
                if ((q - buf) < buf_size - 1) {
3274
                    *q++ = c;
3275
                }
3276
            } else {
3277
                if ((q - buf) < buf_size - 1) {
3278
                    *q++ = *p;
3279
                }
3280
                p++;
3281
            }
3282
        }
3283
        if (*p != '\"') {
3284
            qemu_printf("unterminated string\n");
3285
            goto fail;
3286
        }
3287
        p++;
3288
    } else {
3289
        while (*p != '\0' && !qemu_isspace(*p)) {
3290
            if ((q - buf) < buf_size - 1) {
3291
                *q++ = *p;
3292
            }
3293
            p++;
3294
        }
3295
    }
3296
    *q = '\0';
3297
    *pp = p;
3298
    return 0;
3299
}
3300

    
3301
/*
3302
 * Store the command-name in cmdname, and return a pointer to
3303
 * the remaining of the command string.
3304
 */
3305
static const char *get_command_name(const char *cmdline,
3306
                                    char *cmdname, size_t nlen)
3307
{
3308
    size_t len;
3309
    const char *p, *pstart;
3310

    
3311
    p = cmdline;
3312
    while (qemu_isspace(*p))
3313
        p++;
3314
    if (*p == '\0')
3315
        return NULL;
3316
    pstart = p;
3317
    while (*p != '\0' && *p != '/' && !qemu_isspace(*p))
3318
        p++;
3319
    len = p - pstart;
3320
    if (len > nlen - 1)
3321
        len = nlen - 1;
3322
    memcpy(cmdname, pstart, len);
3323
    cmdname[len] = '\0';
3324
    return p;
3325
}
3326

    
3327
/**
3328
 * Read key of 'type' into 'key' and return the current
3329
 * 'type' pointer.
3330
 */
3331
static char *key_get_info(const char *type, char **key)
3332
{
3333
    size_t len;
3334
    char *p, *str;
3335

    
3336
    if (*type == ',')
3337
        type++;
3338

    
3339
    p = strchr(type, ':');
3340
    if (!p) {
3341
        *key = NULL;
3342
        return NULL;
3343
    }
3344
    len = p - type;
3345

    
3346
    str = g_malloc(len + 1);
3347
    memcpy(str, type, len);
3348
    str[len] = '\0';
3349

    
3350
    *key = str;
3351
    return ++p;
3352
}
3353

    
3354
static int default_fmt_format = 'x';
3355
static int default_fmt_size = 4;
3356

    
3357
#define MAX_ARGS 16
3358

    
3359
static int is_valid_option(const char *c, const char *typestr)
3360
{
3361
    char option[3];
3362
  
3363
    option[0] = '-';
3364
    option[1] = *c;
3365
    option[2] = '\0';
3366
  
3367
    typestr = strstr(typestr, option);
3368
    return (typestr != NULL);
3369
}
3370

    
3371
static const mon_cmd_t *search_dispatch_table(const mon_cmd_t *disp_table,
3372
                                              const char *cmdname)
3373
{
3374
    const mon_cmd_t *cmd;
3375

    
3376
    for (cmd = disp_table; cmd->name != NULL; cmd++) {
3377
        if (compare_cmd(cmdname, cmd->name)) {
3378
            return cmd;
3379
        }
3380
    }
3381

    
3382
    return NULL;
3383
}
3384

    
3385
static const mon_cmd_t *monitor_find_command(const char *cmdname)
3386
{
3387
    return search_dispatch_table(mon_cmds, cmdname);
3388
}
3389

    
3390
static const mon_cmd_t *qmp_find_cmd(const char *cmdname)
3391
{
3392
    return search_dispatch_table(qmp_cmds, cmdname);
3393
}
3394

    
3395
static const mon_cmd_t *monitor_parse_command(Monitor *mon,
3396
                                              const char *cmdline,
3397
                                              QDict *qdict)
3398
{
3399
    const char *p, *typestr;
3400
    int c;
3401
    const mon_cmd_t *cmd;
3402
    char cmdname[256];
3403
    char buf[1024];
3404
    char *key;
3405

    
3406
#ifdef DEBUG
3407
    monitor_printf(mon, "command='%s'\n", cmdline);
3408
#endif
3409

    
3410
    /* extract the command name */
3411
    p = get_command_name(cmdline, cmdname, sizeof(cmdname));
3412
    if (!p)
3413
        return NULL;
3414

    
3415
    cmd = monitor_find_command(cmdname);
3416
    if (!cmd) {
3417
        monitor_printf(mon, "unknown command: '%s'\n", cmdname);
3418
        return NULL;
3419
    }
3420

    
3421
    /* parse the parameters */
3422
    typestr = cmd->args_type;
3423
    for(;;) {
3424
        typestr = key_get_info(typestr, &key);
3425
        if (!typestr)
3426
            break;
3427
        c = *typestr;
3428
        typestr++;
3429
        switch(c) {
3430
        case 'F':
3431
        case 'B':
3432
        case 's':
3433
            {
3434
                int ret;
3435

    
3436
                while (qemu_isspace(*p))
3437
                    p++;
3438
                if (*typestr == '?') {
3439
                    typestr++;
3440
                    if (*p == '\0') {
3441
                        /* no optional string: NULL argument */
3442
                        break;
3443
                    }
3444
                }
3445
                ret = get_str(buf, sizeof(buf), &p);
3446
                if (ret < 0) {
3447
                    switch(c) {
3448
                    case 'F':
3449
                        monitor_printf(mon, "%s: filename expected\n",
3450
                                       cmdname);
3451
                        break;
3452
                    case 'B':
3453
                        monitor_printf(mon, "%s: block device name expected\n",
3454
                                       cmdname);
3455
                        break;
3456
                    default:
3457
                        monitor_printf(mon, "%s: string expected\n", cmdname);
3458
                        break;
3459
                    }
3460
                    goto fail;
3461
                }
3462
                qdict_put(qdict, key, qstring_from_str(buf));
3463
            }
3464
            break;
3465
        case 'O':
3466
            {
3467
                QemuOptsList *opts_list;
3468
                QemuOpts *opts;
3469

    
3470
                opts_list = qemu_find_opts(key);
3471
                if (!opts_list || opts_list->desc->name) {
3472
                    goto bad_type;
3473
                }
3474
                while (qemu_isspace(*p)) {
3475
                    p++;
3476
                }
3477
                if (!*p)
3478
                    break;
3479
                if (get_str(buf, sizeof(buf), &p) < 0) {
3480
                    goto fail;
3481
                }
3482
                opts = qemu_opts_parse(opts_list, buf, 1);
3483
                if (!opts) {
3484
                    goto fail;
3485
                }
3486
                qemu_opts_to_qdict(opts, qdict);
3487
                qemu_opts_del(opts);
3488
            }
3489
            break;
3490
        case '/':
3491
            {
3492
                int count, format, size;
3493

    
3494
                while (qemu_isspace(*p))
3495
                    p++;
3496
                if (*p == '/') {
3497
                    /* format found */
3498
                    p++;
3499
                    count = 1;
3500
                    if (qemu_isdigit(*p)) {
3501
                        count = 0;
3502
                        while (qemu_isdigit(*p)) {
3503
                            count = count * 10 + (*p - '0');
3504
                            p++;
3505
                        }
3506
                    }
3507
                    size = -1;
3508
                    format = -1;
3509
                    for(;;) {
3510
                        switch(*p) {
3511
                        case 'o':
3512
                        case 'd':
3513
                        case 'u':
3514
                        case 'x':
3515
                        case 'i':
3516
                        case 'c':
3517
                            format = *p++;
3518
                            break;
3519
                        case 'b':
3520
                            size = 1;
3521
                            p++;
3522
                            break;
3523
                        case 'h':
3524
                            size = 2;
3525
                            p++;
3526
                            break;
3527
                        case 'w':
3528
                            size = 4;
3529
                            p++;
3530
                            break;
3531
                        case 'g':
3532
                        case 'L':
3533
                            size = 8;
3534
                            p++;
3535
                            break;
3536
                        default:
3537
                            goto next;
3538
                        }
3539
                    }
3540
                next:
3541
                    if (*p != '\0' && !qemu_isspace(*p)) {
3542
                        monitor_printf(mon, "invalid char in format: '%c'\n",
3543
                                       *p);
3544
                        goto fail;
3545
                    }
3546
                    if (format < 0)
3547
                        format = default_fmt_format;
3548
                    if (format != 'i') {
3549
                        /* for 'i', not specifying a size gives -1 as size */
3550
                        if (size < 0)
3551
                            size = default_fmt_size;
3552
                        default_fmt_size = size;
3553
                    }
3554
                    default_fmt_format = format;
3555
                } else {
3556
                    count = 1;
3557
                    format = default_fmt_format;
3558
                    if (format != 'i') {
3559
                        size = default_fmt_size;
3560
                    } else {
3561
                        size = -1;
3562
                    }
3563
                }
3564
                qdict_put(qdict, "count", qint_from_int(count));
3565
                qdict_put(qdict, "format", qint_from_int(format));
3566
                qdict_put(qdict, "size", qint_from_int(size));
3567
            }
3568
            break;
3569
        case 'i':
3570
        case 'l':
3571
        case 'M':
3572
            {
3573
                int64_t val;
3574

    
3575
                while (qemu_isspace(*p))
3576
                    p++;
3577
                if (*typestr == '?' || *typestr == '.') {
3578
                    if (*typestr == '?') {
3579
                        if (*p == '\0') {
3580
                            typestr++;
3581
                            break;
3582
                        }
3583
                    } else {
3584
                        if (*p == '.') {
3585
                            p++;
3586
                            while (qemu_isspace(*p))
3587
                                p++;
3588
                        } else {
3589
                            typestr++;
3590
                            break;
3591
                        }
3592
                    }
3593
                    typestr++;
3594
                }
3595
                if (get_expr(mon, &val, &p))
3596
                    goto fail;
3597
                /* Check if 'i' is greater than 32-bit */
3598
                if ((c == 'i') && ((val >> 32) & 0xffffffff)) {
3599
                    monitor_printf(mon, "\'%s\' has failed: ", cmdname);
3600
                    monitor_printf(mon, "integer is for 32-bit values\n");
3601
                    goto fail;
3602
                } else if (c == 'M') {
3603
                    val <<= 20;
3604
                }
3605
                qdict_put(qdict, key, qint_from_int(val));
3606
            }
3607
            break;
3608
        case 'o':
3609
            {
3610
                int64_t val;
3611
                char *end;
3612

    
3613
                while (qemu_isspace(*p)) {
3614
                    p++;
3615
                }
3616
                if (*typestr == '?') {
3617
                    typestr++;
3618
                    if (*p == '\0') {
3619
                        break;
3620
                    }
3621
                }
3622
                val = strtosz(p, &end);
3623
                if (val < 0) {
3624
                    monitor_printf(mon, "invalid size\n");
3625
                    goto fail;
3626
                }
3627
                qdict_put(qdict, key, qint_from_int(val));
3628
                p = end;
3629
            }
3630
            break;
3631
        case 'T':
3632
            {
3633
                double val;
3634

    
3635
                while (qemu_isspace(*p))
3636
                    p++;
3637
                if (*typestr == '?') {
3638
                    typestr++;
3639
                    if (*p == '\0') {
3640
                        break;
3641
                    }
3642
                }
3643
                if (get_double(mon, &val, &p) < 0) {
3644
                    goto fail;
3645
                }
3646
                if (p[0] && p[1] == 's') {
3647
                    switch (*p) {
3648
                    case 'm':
3649
                        val /= 1e3; p += 2; break;
3650
                    case 'u':
3651
                        val /= 1e6; p += 2; break;
3652
                    case 'n':
3653
                        val /= 1e9; p += 2; break;
3654
                    }
3655
                }
3656
                if (*p && !qemu_isspace(*p)) {
3657
                    monitor_printf(mon, "Unknown unit suffix\n");
3658
                    goto fail;
3659
                }
3660
                qdict_put(qdict, key, qfloat_from_double(val));
3661
            }
3662
            break;
3663
        case 'b':
3664
            {
3665
                const char *beg;
3666
                int val;
3667

    
3668
                while (qemu_isspace(*p)) {
3669
                    p++;
3670
                }
3671
                beg = p;
3672
                while (qemu_isgraph(*p)) {
3673
                    p++;
3674
                }
3675
                if (p - beg == 2 && !memcmp(beg, "on", p - beg)) {
3676
                    val = 1;
3677
                } else if (p - beg == 3 && !memcmp(beg, "off", p - beg)) {
3678
                    val = 0;
3679
                } else {
3680
                    monitor_printf(mon, "Expected 'on' or 'off'\n");
3681
                    goto fail;
3682
                }
3683
                qdict_put(qdict, key, qbool_from_int(val));
3684
            }
3685
            break;
3686
        case '-':
3687
            {
3688
                const char *tmp = p;
3689
                int skip_key = 0;
3690
                /* option */
3691

    
3692
                c = *typestr++;
3693
                if (c == '\0')
3694
                    goto bad_type;
3695
                while (qemu_isspace(*p))
3696
                    p++;
3697
                if (*p == '-') {
3698
                    p++;
3699
                    if(c != *p) {
3700
                        if(!is_valid_option(p, typestr)) {
3701
                  
3702
                            monitor_printf(mon, "%s: unsupported option -%c\n",
3703
                                           cmdname, *p);
3704
                            goto fail;
3705
                        } else {
3706
                            skip_key = 1;
3707
                        }
3708
                    }
3709
                    if(skip_key) {
3710
                        p = tmp;
3711
                    } else {
3712
                        /* has option */
3713
                        p++;
3714
                        qdict_put(qdict, key, qbool_from_int(1));
3715
                    }
3716
                }
3717
            }
3718
            break;
3719
        default:
3720
        bad_type:
3721
            monitor_printf(mon, "%s: unknown type '%c'\n", cmdname, c);
3722
            goto fail;
3723
        }
3724
        g_free(key);
3725
        key = NULL;
3726
    }
3727
    /* check that all arguments were parsed */
3728
    while (qemu_isspace(*p))
3729
        p++;
3730
    if (*p != '\0') {
3731
        monitor_printf(mon, "%s: extraneous characters at the end of line\n",
3732
                       cmdname);
3733
        goto fail;
3734
    }
3735

    
3736
    return cmd;
3737

    
3738
fail:
3739
    g_free(key);
3740
    return NULL;
3741
}
3742

    
3743
void monitor_set_error(Monitor *mon, QError *qerror)
3744
{
3745
    /* report only the first error */
3746
    if (!mon->error) {
3747
        mon->error = qerror;
3748
    } else {
3749
        MON_DEBUG("Additional error report at %s:%d\n",
3750
                  qerror->file, qerror->linenr);
3751
        QDECREF(qerror);
3752
    }
3753
}
3754

    
3755
static void handler_audit(Monitor *mon, const mon_cmd_t *cmd, int ret)
3756
{
3757
    if (ret && !monitor_has_error(mon)) {
3758
        /*
3759
         * If it returns failure, it must have passed on error.
3760
         *
3761
         * Action: Report an internal error to the client if in QMP.
3762
         */
3763
        qerror_report(QERR_UNDEFINED_ERROR);
3764
        MON_DEBUG("command '%s' returned failure but did not pass an error\n",
3765
                  cmd->name);
3766
    }
3767

    
3768
#ifdef CONFIG_DEBUG_MONITOR
3769
    if (!ret && monitor_has_error(mon)) {
3770
        /*
3771
         * If it returns success, it must not have passed an error.
3772
         *
3773
         * Action: Report the passed error to the client.
3774
         */
3775
        MON_DEBUG("command '%s' returned success but passed an error\n",
3776
                  cmd->name);
3777
    }
3778

    
3779
    if (mon_print_count_get(mon) > 0 && strcmp(cmd->name, "info") != 0) {
3780
        /*
3781
         * Handlers should not call Monitor print functions.
3782
         *
3783
         * Action: Ignore them in QMP.
3784
         *
3785
         * (XXX: we don't check any 'info' or 'query' command here
3786
         * because the user print function _is_ called by do_info(), hence
3787
         * we will trigger this check. This problem will go away when we
3788
         * make 'query' commands real and kill do_info())
3789
         */
3790
        MON_DEBUG("command '%s' called print functions %d time(s)\n",
3791
                  cmd->name, mon_print_count_get(mon));
3792
    }
3793
#endif
3794
}
3795

    
3796
static void handle_user_command(Monitor *mon, const char *cmdline)
3797
{
3798
    QDict *qdict;
3799
    const mon_cmd_t *cmd;
3800

    
3801
    qdict = qdict_new();
3802

    
3803
    cmd = monitor_parse_command(mon, cmdline, qdict);
3804
    if (!cmd)
3805
        goto out;
3806

    
3807
    if (handler_is_async(cmd)) {
3808
        user_async_cmd_handler(mon, cmd, qdict);
3809
    } else if (handler_is_qobject(cmd)) {
3810
        QObject *data = NULL;
3811

    
3812
        /* XXX: ignores the error code */
3813
        cmd->mhandler.cmd_new(mon, qdict, &data);
3814
        assert(!monitor_has_error(mon));
3815
        if (data) {
3816
            cmd->user_print(mon, data);
3817
            qobject_decref(data);
3818
        }
3819
    } else {
3820
        cmd->mhandler.cmd(mon, qdict);
3821
    }
3822

    
3823
out:
3824
    QDECREF(qdict);
3825
}
3826

    
3827
static void cmd_completion(const char *name, const char *list)
3828
{
3829
    const char *p, *pstart;
3830
    char cmd[128];
3831
    int len;
3832

    
3833
    p = list;
3834
    for(;;) {
3835
        pstart = p;
3836
        p = strchr(p, '|');
3837
        if (!p)
3838
            p = pstart + strlen(pstart);
3839
        len = p - pstart;
3840
        if (len > sizeof(cmd) - 2)
3841
            len = sizeof(cmd) - 2;
3842
        memcpy(cmd, pstart, len);
3843
        cmd[len] = '\0';
3844
        if (name[0] == '\0' || !strncmp(name, cmd, strlen(name))) {
3845
            readline_add_completion(cur_mon->rs, cmd);
3846
        }
3847
        if (*p == '\0')
3848
            break;
3849
        p++;
3850
    }
3851
}
3852

    
3853
static void file_completion(const char *input)
3854
{
3855
    DIR *ffs;
3856
    struct dirent *d;
3857
    char path[1024];
3858
    char file[1024], file_prefix[1024];
3859
    int input_path_len;
3860
    const char *p;
3861

    
3862
    p = strrchr(input, '/');
3863
    if (!p) {
3864
        input_path_len = 0;
3865
        pstrcpy(file_prefix, sizeof(file_prefix), input);
3866
        pstrcpy(path, sizeof(path), ".");
3867
    } else {
3868
        input_path_len = p - input + 1;
3869
        memcpy(path, input, input_path_len);
3870
        if (input_path_len > sizeof(path) - 1)
3871
            input_path_len = sizeof(path) - 1;
3872
        path[input_path_len] = '\0';
3873
        pstrcpy(file_prefix, sizeof(file_prefix), p + 1);
3874
    }
3875
#ifdef DEBUG_COMPLETION
3876
    monitor_printf(cur_mon, "input='%s' path='%s' prefix='%s'\n",
3877
                   input, path, file_prefix);
3878
#endif
3879
    ffs = opendir(path);
3880
    if (!ffs)
3881
        return;
3882
    for(;;) {
3883
        struct stat sb;
3884
        d = readdir(ffs);
3885
        if (!d)
3886
            break;
3887

    
3888
        if (strcmp(d->d_name, ".") == 0 || strcmp(d->d_name, "..") == 0) {
3889
            continue;
3890
        }
3891

    
3892
        if (strstart(d->d_name, file_prefix, NULL)) {
3893
            memcpy(file, input, input_path_len);
3894
            if (input_path_len < sizeof(file))
3895
                pstrcpy(file + input_path_len, sizeof(file) - input_path_len,
3896
                        d->d_name);
3897
            /* stat the file to find out if it's a directory.
3898
             * In that case add a slash to speed up typing long paths
3899
             */
3900
            if (stat(file, &sb) == 0 && S_ISDIR(sb.st_mode)) {
3901
                pstrcat(file, sizeof(file), "/");
3902
            }
3903
            readline_add_completion(cur_mon->rs, file);
3904
        }
3905
    }
3906
    closedir(ffs);
3907
}
3908

    
3909
static void block_completion_it(void *opaque, BlockDriverState *bs)
3910
{
3911
    const char *name = bdrv_get_device_name(bs);
3912
    const char *input = opaque;
3913

    
3914
    if (input[0] == '\0' ||
3915
        !strncmp(name, (char *)input, strlen(input))) {
3916
        readline_add_completion(cur_mon->rs, name);
3917
    }
3918
}
3919

    
3920
/* NOTE: this parser is an approximate form of the real command parser */
3921
static void parse_cmdline(const char *cmdline,
3922
                         int *pnb_args, char **args)
3923
{
3924
    const char *p;
3925
    int nb_args, ret;
3926
    char buf[1024];
3927

    
3928
    p = cmdline;
3929
    nb_args = 0;
3930
    for(;;) {
3931
        while (qemu_isspace(*p))
3932
            p++;
3933
        if (*p == '\0')
3934
            break;
3935
        if (nb_args >= MAX_ARGS)
3936
            break;
3937
        ret = get_str(buf, sizeof(buf), &p);
3938
        args[nb_args] = g_strdup(buf);
3939
        nb_args++;
3940
        if (ret < 0)
3941
            break;
3942
    }
3943
    *pnb_args = nb_args;
3944
}
3945

    
3946
static const char *next_arg_type(const char *typestr)
3947
{
3948
    const char *p = strchr(typestr, ':');
3949
    return (p != NULL ? ++p : typestr);
3950
}
3951

    
3952
static void monitor_find_completion(const char *cmdline)
3953
{
3954
    const char *cmdname;
3955
    char *args[MAX_ARGS];
3956
    int nb_args, i, len;
3957
    const char *ptype, *str;
3958
    const mon_cmd_t *cmd;
3959
    const KeyDef *key;
3960

    
3961
    parse_cmdline(cmdline, &nb_args, args);
3962
#ifdef DEBUG_COMPLETION
3963
    for(i = 0; i < nb_args; i++) {
3964
        monitor_printf(cur_mon, "arg%d = '%s'\n", i, (char *)args[i]);
3965
    }
3966
#endif
3967

    
3968
    /* if the line ends with a space, it means we want to complete the
3969
       next arg */
3970
    len = strlen(cmdline);
3971
    if (len > 0 && qemu_isspace(cmdline[len - 1])) {
3972
        if (nb_args >= MAX_ARGS) {
3973
            goto cleanup;
3974
        }
3975
        args[nb_args++] = g_strdup("");
3976
    }
3977
    if (nb_args <= 1) {
3978
        /* command completion */
3979
        if (nb_args == 0)
3980
            cmdname = "";
3981
        else
3982
            cmdname = args[0];
3983
        readline_set_completion_index(cur_mon->rs, strlen(cmdname));
3984
        for(cmd = mon_cmds; cmd->name != NULL; cmd++) {
3985
            cmd_completion(cmdname, cmd->name);
3986
        }
3987
    } else {
3988
        /* find the command */
3989
        for (cmd = mon_cmds; cmd->name != NULL; cmd++) {
3990
            if (compare_cmd(args[0], cmd->name)) {
3991
                break;
3992
            }
3993
        }
3994
        if (!cmd->name) {
3995
            goto cleanup;
3996
        }
3997

    
3998
        ptype = next_arg_type(cmd->args_type);
3999
        for(i = 0; i < nb_args - 2; i++) {
4000
            if (*ptype != '\0') {
4001
                ptype = next_arg_type(ptype);
4002
                while (*ptype == '?')
4003
                    ptype = next_arg_type(ptype);
4004
            }
4005
        }
4006
        str = args[nb_args - 1];
4007
        if (*ptype == '-' && ptype[1] != '\0') {
4008
            ptype = next_arg_type(ptype);
4009
        }
4010
        switch(*ptype) {
4011
        case 'F':
4012
            /* file completion */
4013
            readline_set_completion_index(cur_mon->rs, strlen(str));
4014
            file_completion(str);
4015
            break;
4016
        case 'B':
4017
            /* block device name completion */
4018
            readline_set_completion_index(cur_mon->rs, strlen(str));
4019
            bdrv_iterate(block_completion_it, (void *)str);
4020
            break;
4021
        case 's':
4022
            /* XXX: more generic ? */
4023
            if (!strcmp(cmd->name, "info")) {
4024
                readline_set_completion_index(cur_mon->rs, strlen(str));
4025
                for(cmd = info_cmds; cmd->name != NULL; cmd++) {
4026
                    cmd_completion(str, cmd->name);
4027
                }
4028
            } else if (!strcmp(cmd->name, "sendkey")) {
4029
                char *sep = strrchr(str, '-');
4030
                if (sep)
4031
                    str = sep + 1;
4032
                readline_set_completion_index(cur_mon->rs, strlen(str));
4033
                for(key = key_defs; key->name != NULL; key++) {
4034
                    cmd_completion(str, key->name);
4035
                }
4036
            } else if (!strcmp(cmd->name, "help|?")) {
4037
                readline_set_completion_index(cur_mon->rs, strlen(str));
4038
                for (cmd = mon_cmds; cmd->name != NULL; cmd++) {
4039
                    cmd_completion(str, cmd->name);
4040
                }
4041
            }
4042
            break;
4043
        default:
4044
            break;
4045
        }
4046
    }
4047

    
4048
cleanup:
4049
    for (i = 0; i < nb_args; i++) {
4050
        g_free(args[i]);
4051
    }
4052
}
4053

    
4054
static int monitor_can_read(void *opaque)
4055
{
4056
    Monitor *mon = opaque;
4057

    
4058
    return (mon->suspend_cnt == 0) ? 1 : 0;
4059
}
4060

    
4061
static int invalid_qmp_mode(const Monitor *mon, const char *cmd_name)
4062
{
4063
    int is_cap = compare_cmd(cmd_name, "qmp_capabilities");
4064
    return (qmp_cmd_mode(mon) ? is_cap : !is_cap);
4065
}
4066

    
4067
/*
4068
 * Argument validation rules:
4069
 *
4070
 * 1. The argument must exist in cmd_args qdict
4071
 * 2. The argument type must be the expected one
4072
 *
4073
 * Special case: If the argument doesn't exist in cmd_args and
4074
 *               the QMP_ACCEPT_UNKNOWNS flag is set, then the
4075
 *               checking is skipped for it.
4076
 */
4077
static int check_client_args_type(const QDict *client_args,
4078
                                  const QDict *cmd_args, int flags)
4079
{
4080
    const QDictEntry *ent;
4081

    
4082
    for (ent = qdict_first(client_args); ent;ent = qdict_next(client_args,ent)){
4083
        QObject *obj;
4084
        QString *arg_type;
4085
        const QObject *client_arg = qdict_entry_value(ent);
4086
        const char *client_arg_name = qdict_entry_key(ent);
4087

    
4088
        obj = qdict_get(cmd_args, client_arg_name);
4089
        if (!obj) {
4090
            if (flags & QMP_ACCEPT_UNKNOWNS) {
4091
                /* handler accepts unknowns */
4092
                continue;
4093
            }
4094
            /* client arg doesn't exist */
4095
            qerror_report(QERR_INVALID_PARAMETER, client_arg_name);
4096
            return -1;
4097
        }
4098

    
4099
        arg_type = qobject_to_qstring(obj);
4100
        assert(arg_type != NULL);
4101

    
4102
        /* check if argument's type is correct */
4103
        switch (qstring_get_str(arg_type)[0]) {
4104
        case 'F':
4105
        case 'B':
4106
        case 's':
4107
            if (qobject_type(client_arg) != QTYPE_QSTRING) {
4108
                qerror_report(QERR_INVALID_PARAMETER_TYPE, client_arg_name,
4109
                              "string");
4110
                return -1;
4111
            }
4112
        break;
4113
        case 'i':
4114
        case 'l':
4115
        case 'M':
4116
        case 'o':
4117
            if (qobject_type(client_arg) != QTYPE_QINT) {
4118
                qerror_report(QERR_INVALID_PARAMETER_TYPE, client_arg_name,
4119
                              "int");
4120
                return -1; 
4121
            }
4122
            break;
4123
        case 'T':
4124
            if (qobject_type(client_arg) != QTYPE_QINT &&
4125
                qobject_type(client_arg) != QTYPE_QFLOAT) {
4126
                qerror_report(QERR_INVALID_PARAMETER_TYPE, client_arg_name,
4127
                              "number");
4128
               return -1; 
4129
            }
4130
            break;
4131
        case 'b':
4132
        case '-':
4133
            if (qobject_type(client_arg) != QTYPE_QBOOL) {
4134
                qerror_report(QERR_INVALID_PARAMETER_TYPE, client_arg_name,
4135
                              "bool");
4136
               return -1; 
4137
            }
4138
            break;
4139
        case 'O':
4140
            assert(flags & QMP_ACCEPT_UNKNOWNS);
4141
            break;
4142
        case '/':
4143
        case '.':
4144
            /*
4145
             * These types are not supported by QMP and thus are not
4146
             * handled here. Fall through.
4147
             */
4148
        default:
4149
            abort();
4150
        }
4151
    }
4152

    
4153
    return 0;
4154
}
4155

    
4156
/*
4157
 * - Check if the client has passed all mandatory args
4158
 * - Set special flags for argument validation
4159
 */
4160
static int check_mandatory_args(const QDict *cmd_args,
4161
                                const QDict *client_args, int *flags)
4162
{
4163
    const QDictEntry *ent;
4164

    
4165
    for (ent = qdict_first(cmd_args); ent; ent = qdict_next(cmd_args, ent)) {
4166
        const char *cmd_arg_name = qdict_entry_key(ent);
4167
        QString *type = qobject_to_qstring(qdict_entry_value(ent));
4168
        assert(type != NULL);
4169

    
4170
        if (qstring_get_str(type)[0] == 'O') {
4171
            assert((*flags & QMP_ACCEPT_UNKNOWNS) == 0);
4172
            *flags |= QMP_ACCEPT_UNKNOWNS;
4173
        } else if (qstring_get_str(type)[0] != '-' &&
4174
                   qstring_get_str(type)[1] != '?' &&
4175
                   !qdict_haskey(client_args, cmd_arg_name)) {
4176
            qerror_report(QERR_MISSING_PARAMETER, cmd_arg_name);
4177
            return -1;
4178
        }
4179
    }
4180

    
4181
    return 0;
4182
}
4183

    
4184
static QDict *qdict_from_args_type(const char *args_type)
4185
{
4186
    int i;
4187
    QDict *qdict;
4188
    QString *key, *type, *cur_qs;
4189

    
4190
    assert(args_type != NULL);
4191

    
4192
    qdict = qdict_new();
4193

    
4194
    if (args_type == NULL || args_type[0] == '\0') {
4195
        /* no args, empty qdict */
4196
        goto out;
4197
    }
4198

    
4199
    key = qstring_new();
4200
    type = qstring_new();
4201

    
4202
    cur_qs = key;
4203

    
4204
    for (i = 0;; i++) {
4205
        switch (args_type[i]) {
4206
            case ',':
4207
            case '\0':
4208
                qdict_put(qdict, qstring_get_str(key), type);
4209
                QDECREF(key);
4210
                if (args_type[i] == '\0') {
4211
                    goto out;
4212
                }
4213
                type = qstring_new(); /* qdict has ref */
4214
                cur_qs = key = qstring_new();
4215
                break;
4216
            case ':':
4217
                cur_qs = type;
4218
                break;
4219
            default:
4220
                qstring_append_chr(cur_qs, args_type[i]);
4221
                break;
4222
        }
4223
    }
4224

    
4225
out:
4226
    return qdict;
4227
}
4228

    
4229
/*
4230
 * Client argument checking rules:
4231
 *
4232
 * 1. Client must provide all mandatory arguments
4233
 * 2. Each argument provided by the client must be expected
4234
 * 3. Each argument provided by the client must have the type expected
4235
 *    by the command
4236
 */
4237
static int qmp_check_client_args(const mon_cmd_t *cmd, QDict *client_args)
4238
{
4239
    int flags, err;
4240
    QDict *cmd_args;
4241

    
4242
    cmd_args = qdict_from_args_type(cmd->args_type);
4243

    
4244
    flags = 0;
4245
    err = check_mandatory_args(cmd_args, client_args, &flags);
4246
    if (err) {
4247
        goto out;
4248
    }
4249

    
4250
    err = check_client_args_type(client_args, cmd_args, flags);
4251

    
4252
out:
4253
    QDECREF(cmd_args);
4254
    return err;
4255
}
4256

    
4257
/*
4258
 * Input object checking rules
4259
 *
4260
 * 1. Input object must be a dict
4261
 * 2. The "execute" key must exist
4262
 * 3. The "execute" key must be a string
4263
 * 4. If the "arguments" key exists, it must be a dict
4264
 * 5. If the "id" key exists, it can be anything (ie. json-value)
4265
 * 6. Any argument not listed above is considered invalid
4266
 */
4267
static QDict *qmp_check_input_obj(QObject *input_obj)
4268
{
4269
    const QDictEntry *ent;
4270
    int has_exec_key = 0;
4271
    QDict *input_dict;
4272

    
4273
    if (qobject_type(input_obj) != QTYPE_QDICT) {
4274
        qerror_report(QERR_QMP_BAD_INPUT_OBJECT, "object");
4275
        return NULL;
4276
    }
4277

    
4278
    input_dict = qobject_to_qdict(input_obj);
4279

    
4280
    for (ent = qdict_first(input_dict); ent; ent = qdict_next(input_dict, ent)){
4281
        const char *arg_name = qdict_entry_key(ent);
4282
        const QObject *arg_obj = qdict_entry_value(ent);
4283

    
4284
        if (!strcmp(arg_name, "execute")) {
4285
            if (qobject_type(arg_obj) != QTYPE_QSTRING) {
4286
                qerror_report(QERR_QMP_BAD_INPUT_OBJECT_MEMBER, "execute",
4287
                              "string");
4288
                return NULL;
4289
            }
4290
            has_exec_key = 1;
4291
        } else if (!strcmp(arg_name, "arguments")) {
4292
            if (qobject_type(arg_obj) != QTYPE_QDICT) {
4293
                qerror_report(QERR_QMP_BAD_INPUT_OBJECT_MEMBER, "arguments",
4294
                              "object");
4295
                return NULL;
4296
            }
4297
        } else if (!strcmp(arg_name, "id")) {
4298
            /* FIXME: check duplicated IDs for async commands */
4299
        } else {
4300
            qerror_report(QERR_QMP_EXTRA_MEMBER, arg_name);
4301
            return NULL;
4302
        }
4303
    }
4304

    
4305
    if (!has_exec_key) {
4306
        qerror_report(QERR_QMP_BAD_INPUT_OBJECT, "execute");
4307
        return NULL;
4308
    }
4309

    
4310
    return input_dict;
4311
}
4312

    
4313
static void qmp_call_cmd(Monitor *mon, const mon_cmd_t *cmd,
4314
                         const QDict *params)
4315
{
4316
    int ret;
4317
    QObject *data = NULL;
4318

    
4319
    mon_print_count_init(mon);
4320

    
4321
    ret = cmd->mhandler.cmd_new(mon, params, &data);
4322
    handler_audit(mon, cmd, ret);
4323
    monitor_protocol_emitter(mon, data);
4324
    qobject_decref(data);
4325
}
4326

    
4327
static void handle_qmp_command(JSONMessageParser *parser, QList *tokens)
4328
{
4329
    int err;
4330
    QObject *obj;
4331
    QDict *input, *args;
4332
    const mon_cmd_t *cmd;
4333
    const char *cmd_name;
4334
    Monitor *mon = cur_mon;
4335

    
4336
    args = input = NULL;
4337

    
4338
    obj = json_parser_parse(tokens, NULL);
4339
    if (!obj) {
4340
        // FIXME: should be triggered in json_parser_parse()
4341
        qerror_report(QERR_JSON_PARSING);
4342
        goto err_out;
4343
    }
4344

    
4345
    input = qmp_check_input_obj(obj);
4346
    if (!input) {
4347
        qobject_decref(obj);
4348
        goto err_out;
4349
    }
4350

    
4351
    mon->mc->id = qdict_get(input, "id");
4352
    qobject_incref(mon->mc->id);
4353

    
4354
    cmd_name = qdict_get_str(input, "execute");
4355
    trace_handle_qmp_command(mon, cmd_name);
4356
    if (invalid_qmp_mode(mon, cmd_name)) {
4357
        qerror_report(QERR_COMMAND_NOT_FOUND, cmd_name);
4358
        goto err_out;
4359
    }
4360

    
4361
    cmd = qmp_find_cmd(cmd_name);
4362
    if (!cmd) {
4363
        qerror_report(QERR_COMMAND_NOT_FOUND, cmd_name);
4364
        goto err_out;
4365
    }
4366

    
4367
    obj = qdict_get(input, "arguments");
4368
    if (!obj) {
4369
        args = qdict_new();
4370
    } else {
4371
        args = qobject_to_qdict(obj);
4372
        QINCREF(args);
4373
    }
4374

    
4375
    err = qmp_check_client_args(cmd, args);
4376
    if (err < 0) {
4377
        goto err_out;
4378
    }
4379

    
4380
    if (handler_is_async(cmd)) {
4381
        err = qmp_async_cmd_handler(mon, cmd, args);
4382
        if (err) {
4383
            /* emit the error response */
4384
            goto err_out;
4385
        }
4386
    } else {
4387
        qmp_call_cmd(mon, cmd, args);
4388
    }
4389

    
4390
    goto out;
4391

    
4392
err_out:
4393
    monitor_protocol_emitter(mon, NULL);
4394
out:
4395
    QDECREF(input);
4396
    QDECREF(args);
4397
}
4398

    
4399
/**
4400
 * monitor_control_read(): Read and handle QMP input
4401
 */
4402
static void monitor_control_read(void *opaque, const uint8_t *buf, int size)
4403
{
4404
    Monitor *old_mon = cur_mon;
4405

    
4406
    cur_mon = opaque;
4407

    
4408
    json_message_parser_feed(&cur_mon->mc->parser, (const char *) buf, size);
4409

    
4410
    cur_mon = old_mon;
4411
}
4412

    
4413
static void monitor_read(void *opaque, const uint8_t *buf, int size)
4414
{
4415
    Monitor *old_mon = cur_mon;
4416
    int i;
4417

    
4418
    cur_mon = opaque;
4419

    
4420
    if (cur_mon->rs) {
4421
        for (i = 0; i < size; i++)
4422
            readline_handle_byte(cur_mon->rs, buf[i]);
4423
    } else {
4424
        if (size == 0 || buf[size - 1] != 0)
4425
            monitor_printf(cur_mon, "corrupted command\n");
4426
        else
4427
            handle_user_command(cur_mon, (char *)buf);
4428
    }
4429

    
4430
    cur_mon = old_mon;
4431
}
4432

    
4433
static void monitor_command_cb(Monitor *mon, const char *cmdline, void *opaque)
4434
{
4435
    monitor_suspend(mon);
4436
    handle_user_command(mon, cmdline);
4437
    monitor_resume(mon);
4438
}
4439

    
4440
int monitor_suspend(Monitor *mon)
4441
{
4442
    if (!mon->rs)
4443
        return -ENOTTY;
4444
    mon->suspend_cnt++;
4445
    return 0;
4446
}
4447

    
4448
void monitor_resume(Monitor *mon)
4449
{
4450
    if (!mon->rs)
4451
        return;
4452
    if (--mon->suspend_cnt == 0)
4453
        readline_show_prompt(mon->rs);
4454
}
4455

    
4456
static QObject *get_qmp_greeting(void)
4457
{
4458
    QObject *ver = NULL;
4459

    
4460
    qmp_marshal_input_query_version(NULL, NULL, &ver);
4461
    return qobject_from_jsonf("{'QMP':{'version': %p,'capabilities': []}}",ver);
4462
}
4463

    
4464
/**
4465
 * monitor_control_event(): Print QMP gretting
4466
 */
4467
static void monitor_control_event(void *opaque, int event)
4468
{
4469
    QObject *data;
4470
    Monitor *mon = opaque;
4471

    
4472
    switch (event) {
4473
    case CHR_EVENT_OPENED:
4474
        mon->mc->command_mode = 0;
4475
        json_message_parser_init(&mon->mc->parser, handle_qmp_command);
4476
        data = get_qmp_greeting();
4477
        monitor_json_emitter(mon, data);
4478
        qobject_decref(data);
4479
        break;
4480
    case CHR_EVENT_CLOSED:
4481
        json_message_parser_destroy(&mon->mc->parser);
4482
        break;
4483
    }
4484
}
4485

    
4486
static void monitor_event(void *opaque, int event)
4487
{
4488
    Monitor *mon = opaque;
4489

    
4490
    switch (event) {
4491
    case CHR_EVENT_MUX_IN:
4492
        mon->mux_out = 0;
4493
        if (mon->reset_seen) {
4494
            readline_restart(mon->rs);
4495
            monitor_resume(mon);
4496
            monitor_flush(mon);
4497
        } else {
4498
            mon->suspend_cnt = 0;
4499
        }
4500
        break;
4501

    
4502
    case CHR_EVENT_MUX_OUT:
4503
        if (mon->reset_seen) {
4504
            if (mon->suspend_cnt == 0) {
4505
                monitor_printf(mon, "\n");
4506
            }
4507
            monitor_flush(mon);
4508
            monitor_suspend(mon);
4509
        } else {
4510
            mon->suspend_cnt++;
4511
        }
4512
        mon->mux_out = 1;
4513
        break;
4514

    
4515
    case CHR_EVENT_OPENED:
4516
        monitor_printf(mon, "QEMU %s monitor - type 'help' for more "
4517
                       "information\n", QEMU_VERSION);
4518
        if (!mon->mux_out) {
4519
            readline_show_prompt(mon->rs);
4520
        }
4521
        mon->reset_seen = 1;
4522
        break;
4523
    }
4524
}
4525

    
4526
static int
4527
compare_mon_cmd(const void *a, const void *b)
4528
{
4529
    return strcmp(((const mon_cmd_t *)a)->name,
4530
            ((const mon_cmd_t *)b)->name);
4531
}
4532

    
4533
static void sortcmdlist(void)
4534
{
4535
    int array_num;
4536
    int elem_size = sizeof(mon_cmd_t);
4537

    
4538
    array_num = sizeof(mon_cmds)/elem_size-1;
4539
    qsort((void *)mon_cmds, array_num, elem_size, compare_mon_cmd);
4540

    
4541
    array_num = sizeof(info_cmds)/elem_size-1;
4542
    qsort((void *)info_cmds, array_num, elem_size, compare_mon_cmd);
4543
}
4544

    
4545

    
4546
/*
4547
 * Local variables:
4548
 *  c-indent-level: 4
4549
 *  c-basic-offset: 4
4550
 *  tab-width: 8
4551
 * End:
4552
 */
4553

    
4554
void monitor_init(CharDriverState *chr, int flags)
4555
{
4556
    static int is_first_init = 1;
4557
    Monitor *mon;
4558

    
4559
    if (is_first_init) {
4560
        key_timer = qemu_new_timer_ns(vm_clock, release_keys, NULL);
4561
        is_first_init = 0;
4562
    }
4563

    
4564
    mon = g_malloc0(sizeof(*mon));
4565

    
4566
    mon->chr = chr;
4567
    mon->flags = flags;
4568
    if (flags & MONITOR_USE_READLINE) {
4569
        mon->rs = readline_init(mon, monitor_find_completion);
4570
        monitor_read_command(mon, 0);
4571
    }
4572

    
4573
    if (monitor_ctrl_mode(mon)) {
4574
        mon->mc = g_malloc0(sizeof(MonitorControl));
4575
        /* Control mode requires special handlers */
4576
        qemu_chr_add_handlers(chr, monitor_can_read, monitor_control_read,
4577
                              monitor_control_event, mon);
4578
        qemu_chr_fe_set_echo(chr, true);
4579
    } else {
4580
        qemu_chr_add_handlers(chr, monitor_can_read, monitor_read,
4581
                              monitor_event, mon);
4582
    }
4583

    
4584
    QLIST_INSERT_HEAD(&mon_list, mon, entry);
4585
    if (!default_mon || (flags & MONITOR_IS_DEFAULT))
4586
        default_mon = mon;
4587

    
4588
    sortcmdlist();
4589
}
4590

    
4591
static void bdrv_password_cb(Monitor *mon, const char *password, void *opaque)
4592
{
4593
    BlockDriverState *bs = opaque;
4594
    int ret = 0;
4595

    
4596
    if (bdrv_set_key(bs, password) != 0) {
4597
        monitor_printf(mon, "invalid password\n");
4598
        ret = -EPERM;
4599
    }
4600
    if (mon->password_completion_cb)
4601
        mon->password_completion_cb(mon->password_opaque, ret);
4602

    
4603
    monitor_read_command(mon, 1);
4604
}
4605

    
4606
ReadLineState *monitor_get_rs(Monitor *mon)
4607
{
4608
    return mon->rs;
4609
}
4610

    
4611
int monitor_read_bdrv_key_start(Monitor *mon, BlockDriverState *bs,
4612
                                BlockDriverCompletionFunc *completion_cb,
4613
                                void *opaque)
4614
{
4615
    int err;
4616

    
4617
    if (!bdrv_key_required(bs)) {
4618
        if (completion_cb)
4619
            completion_cb(opaque, 0);
4620
        return 0;
4621
    }
4622

    
4623
    if (monitor_ctrl_mode(mon)) {
4624
        qerror_report(QERR_DEVICE_ENCRYPTED, bdrv_get_device_name(bs),
4625
                      bdrv_get_encrypted_filename(bs));
4626
        return -1;
4627
    }
4628

    
4629
    monitor_printf(mon, "%s (%s) is encrypted.\n", bdrv_get_device_name(bs),
4630
                   bdrv_get_encrypted_filename(bs));
4631

    
4632
    mon->password_completion_cb = completion_cb;
4633
    mon->password_opaque = opaque;
4634

    
4635
    err = monitor_read_password(mon, bdrv_password_cb, bs);
4636

    
4637
    if (err && completion_cb)
4638
        completion_cb(opaque, err);
4639

    
4640
    return err;
4641
}
4642

    
4643
int monitor_read_block_device_key(Monitor *mon, const char *device,
4644
                                  BlockDriverCompletionFunc *completion_cb,
4645
                                  void *opaque)
4646
{
4647
    BlockDriverState *bs;
4648

    
4649
    bs = bdrv_find(device);
4650
    if (!bs) {
4651
        monitor_printf(mon, "Device not found %s\n", device);
4652
        return -1;
4653
    }
4654

    
4655
    return monitor_read_bdrv_key_start(mon, bs, completion_cb, opaque);
4656
}