Statistics
| Branch: | Revision:

root / monitor.c @ e7c5e893

History | View | Annotate | Download (143.1 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 (*info_new)(Monitor *mon, QObject **ret_data);
127
        int  (*info_async)(Monitor *mon, MonitorCompletion *cb, void *opaque);
128
        void (*cmd)(Monitor *mon, const QDict *qdict);
129
        int  (*cmd_new)(Monitor *mon, const QDict *params, QObject **ret_data);
130
        int  (*cmd_async)(Monitor *mon, const QDict *params,
131
                          MonitorCompletion *cb, void *opaque);
132
    } mhandler;
133
    bool qapi;
134
    int flags;
135
} mon_cmd_t;
136

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

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

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

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

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

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

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

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

    
199
/* QMP checker flags */
200
#define QMP_ACCEPT_UNKNOWNS 1
201

    
202
static QLIST_HEAD(mon_list, Monitor) mon_list;
203

    
204
static const mon_cmd_t mon_cmds[];
205
static const mon_cmd_t info_cmds[];
206

    
207
static const mon_cmd_t qmp_cmds[];
208
static const mon_cmd_t qmp_query_cmds[];
209

    
210
Monitor *cur_mon;
211
Monitor *default_mon;
212

    
213
static void monitor_command_cb(Monitor *mon, const char *cmdline,
214
                               void *opaque);
215

    
216
static inline int qmp_cmd_mode(const Monitor *mon)
217
{
218
    return (mon->mc ? mon->mc->command_mode : 0);
219
}
220

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

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

    
233
static void monitor_read_command(Monitor *mon, int show_prompt)
234
{
235
    if (!mon->rs)
236
        return;
237

    
238
    readline_start(mon->rs, "(qemu) ", 0, monitor_command_cb, NULL);
239
    if (show_prompt)
240
        readline_show_prompt(mon->rs);
241
}
242

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

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

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

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

    
285
void monitor_vprintf(Monitor *mon, const char *fmt, va_list ap)
286
{
287
    char buf[4096];
288

    
289
    if (!mon)
290
        return;
291

    
292
    mon_print_count_inc(mon);
293

    
294
    if (monitor_ctrl_mode(mon)) {
295
        return;
296
    }
297

    
298
    vsnprintf(buf, sizeof(buf), fmt, ap);
299
    monitor_puts(mon, buf);
300
}
301

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

    
310
void monitor_print_filename(Monitor *mon, const char *filename)
311
{
312
    int i;
313

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

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

    
347
static void monitor_user_noop(Monitor *mon, const QObject *data) { }
348

    
349
static inline int handler_is_qobject(const mon_cmd_t *cmd)
350
{
351
    return cmd->user_print != NULL;
352
}
353

    
354
static inline bool handler_is_async(const mon_cmd_t *cmd)
355
{
356
    return cmd->flags & MONITOR_CMD_ASYNC;
357
}
358

    
359
static inline int monitor_has_error(const Monitor *mon)
360
{
361
    return mon->error != NULL;
362
}
363

    
364
static void monitor_json_emitter(Monitor *mon, const QObject *data)
365
{
366
    QString *json;
367

    
368
    json = mon->flags & MONITOR_USE_PRETTY ? qobject_to_json_pretty(data) :
369
                                             qobject_to_json(data);
370
    assert(json != NULL);
371

    
372
    qstring_append_chr(json, '\n');
373
    monitor_puts(mon, qstring_get_str(json));
374

    
375
    QDECREF(json);
376
}
377

    
378
static void monitor_protocol_emitter(Monitor *mon, QObject *data)
379
{
380
    QDict *qmp;
381

    
382
    trace_monitor_protocol_emitter(mon);
383

    
384
    qmp = qdict_new();
385

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

    
404
    if (mon->mc->id) {
405
        qdict_put_obj(qmp, "id", mon->mc->id);
406
        mon->mc->id = NULL;
407
    }
408

    
409
    monitor_json_emitter(mon, QOBJECT(qmp));
410
    QDECREF(qmp);
411
}
412

    
413
static void timestamp_put(QDict *qdict)
414
{
415
    int err;
416
    QObject *obj;
417
    qemu_timeval tv;
418

    
419
    err = qemu_gettimeofday(&tv);
420
    if (err < 0)
421
        return;
422

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

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

    
440
    assert(event < QEVENT_MAX);
441

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

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

    
498
    QLIST_FOREACH(mon, &mon_list, entry) {
499
        if (monitor_ctrl_mode(mon) && qmp_cmd_mode(mon)) {
500
            monitor_json_emitter(mon, QOBJECT(qmp));
501
        }
502
    }
503
    QDECREF(qmp);
504
}
505

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

    
514
    return 0;
515
}
516

    
517
static int mon_set_cpu(int cpu_index);
518
static void handle_user_command(Monitor *mon, const char *cmdline);
519

    
520
static int do_hmp_passthrough(Monitor *mon, const QDict *params,
521
                              QObject **ret_data)
522
{
523
    int ret = 0;
524
    Monitor *old_mon, hmp;
525
    CharDriverState mchar;
526

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

    
531
    old_mon = cur_mon;
532
    cur_mon = &hmp;
533

    
534
    if (qdict_haskey(params, "cpu-index")) {
535
        ret = mon_set_cpu(qdict_get_int(params, "cpu-index"));
536
        if (ret < 0) {
537
            cur_mon = old_mon;
538
            qerror_report(QERR_INVALID_PARAMETER_VALUE, "cpu-index", "a CPU number");
539
            goto out;
540
        }
541
    }
542

    
543
    handle_user_command(&hmp, qdict_get_str(params, "command-line"));
544
    cur_mon = old_mon;
545

    
546
    if (qemu_chr_mem_osize(hmp.chr) > 0) {
547
        *ret_data = QOBJECT(qemu_chr_mem_to_qs(hmp.chr));
548
    }
549

    
550
out:
551
    qemu_chr_close_mem(hmp.chr);
552
    return ret;
553
}
554

    
555
static int compare_cmd(const char *name, const char *list)
556
{
557
    const char *p, *pstart;
558
    int len;
559
    len = strlen(name);
560
    p = list;
561
    for(;;) {
562
        pstart = p;
563
        p = strchr(p, '|');
564
        if (!p)
565
            p = pstart + strlen(pstart);
566
        if ((p - pstart) == len && !memcmp(pstart, name, len))
567
            return 1;
568
        if (*p == '\0')
569
            break;
570
        p++;
571
    }
572
    return 0;
573
}
574

    
575
static void help_cmd_dump(Monitor *mon, const mon_cmd_t *cmds,
576
                          const char *prefix, const char *name)
577
{
578
    const mon_cmd_t *cmd;
579

    
580
    for(cmd = cmds; cmd->name != NULL; cmd++) {
581
        if (!name || !strcmp(name, cmd->name))
582
            monitor_printf(mon, "%s%s %s -- %s\n", prefix, cmd->name,
583
                           cmd->params, cmd->help);
584
    }
585
}
586

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

    
604
static void do_help_cmd(Monitor *mon, const QDict *qdict)
605
{
606
    help_cmd(mon, qdict_get_try_str(qdict, "name"));
607
}
608

    
609
static void do_trace_event_set_state(Monitor *mon, const QDict *qdict)
610
{
611
    const char *tp_name = qdict_get_str(qdict, "name");
612
    bool new_state = qdict_get_bool(qdict, "option");
613
    int ret = trace_event_set_state(tp_name, new_state);
614

    
615
    if (!ret) {
616
        monitor_printf(mon, "unknown event name \"%s\"\n", tp_name);
617
    }
618
}
619

    
620
#ifdef CONFIG_TRACE_SIMPLE
621
static void do_trace_file(Monitor *mon, const QDict *qdict)
622
{
623
    const char *op = qdict_get_try_str(qdict, "op");
624
    const char *arg = qdict_get_try_str(qdict, "arg");
625

    
626
    if (!op) {
627
        st_print_trace_file_status((FILE *)mon, &monitor_fprintf);
628
    } else if (!strcmp(op, "on")) {
629
        st_set_trace_file_enabled(true);
630
    } else if (!strcmp(op, "off")) {
631
        st_set_trace_file_enabled(false);
632
    } else if (!strcmp(op, "flush")) {
633
        st_flush_trace_buffer();
634
    } else if (!strcmp(op, "set")) {
635
        if (arg) {
636
            st_set_trace_file(arg);
637
        }
638
    } else {
639
        monitor_printf(mon, "unexpected argument \"%s\"\n", op);
640
        help_cmd(mon, "trace-file");
641
    }
642
}
643
#endif
644

    
645
static void user_monitor_complete(void *opaque, QObject *ret_data)
646
{
647
    MonitorCompletionData *data = (MonitorCompletionData *)opaque; 
648

    
649
    if (ret_data) {
650
        data->user_print(data->mon, ret_data);
651
    }
652
    monitor_resume(data->mon);
653
    g_free(data);
654
}
655

    
656
static void qmp_monitor_complete(void *opaque, QObject *ret_data)
657
{
658
    monitor_protocol_emitter(opaque, ret_data);
659
}
660

    
661
static int qmp_async_cmd_handler(Monitor *mon, const mon_cmd_t *cmd,
662
                                 const QDict *params)
663
{
664
    return cmd->mhandler.cmd_async(mon, params, qmp_monitor_complete, mon);
665
}
666

    
667
static void qmp_async_info_handler(Monitor *mon, const mon_cmd_t *cmd)
668
{
669
    cmd->mhandler.info_async(mon, qmp_monitor_complete, mon);
670
}
671

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

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

    
689
static void user_async_info_handler(Monitor *mon, const mon_cmd_t *cmd)
690
{
691
    int ret;
692

    
693
    MonitorCompletionData *cb_data = g_malloc(sizeof(*cb_data));
694
    cb_data->mon = mon;
695
    cb_data->user_print = cmd->user_print;
696
    monitor_suspend(mon);
697
    ret = cmd->mhandler.info_async(mon, user_monitor_complete, cb_data);
698
    if (ret < 0) {
699
        monitor_resume(mon);
700
        g_free(cb_data);
701
    }
702
}
703

    
704
static void do_info(Monitor *mon, const QDict *qdict)
705
{
706
    const mon_cmd_t *cmd;
707
    const char *item = qdict_get_try_str(qdict, "item");
708

    
709
    if (!item) {
710
        goto help;
711
    }
712

    
713
    for (cmd = info_cmds; cmd->name != NULL; cmd++) {
714
        if (compare_cmd(item, cmd->name))
715
            break;
716
    }
717

    
718
    if (cmd->name == NULL) {
719
        goto help;
720
    }
721

    
722
    if (handler_is_async(cmd)) {
723
        user_async_info_handler(mon, cmd);
724
    } else if (handler_is_qobject(cmd)) {
725
        QObject *info_data = NULL;
726

    
727
        cmd->mhandler.info_new(mon, &info_data);
728
        if (info_data) {
729
            cmd->user_print(mon, info_data);
730
            qobject_decref(info_data);
731
        }
732
    } else {
733
        cmd->mhandler.info(mon);
734
    }
735

    
736
    return;
737

    
738
help:
739
    help_cmd(mon, "info");
740
}
741

    
742
static CommandInfoList *alloc_cmd_entry(const char *cmd_name)
743
{
744
    CommandInfoList *info;
745

    
746
    info = g_malloc0(sizeof(*info));
747
    info->value = g_malloc0(sizeof(*info->value));
748
    info->value->name = g_strdup(cmd_name);
749

    
750
    return info;
751
}
752

    
753
CommandInfoList *qmp_query_commands(Error **errp)
754
{
755
    CommandInfoList *info, *cmd_list = NULL;
756
    const mon_cmd_t *cmd;
757

    
758
    for (cmd = qmp_cmds; cmd->name != NULL; cmd++) {
759
        info = alloc_cmd_entry(cmd->name);
760
        info->next = cmd_list;
761
        cmd_list = info;
762
    }
763

    
764
    for (cmd = qmp_query_cmds; cmd->name != NULL; cmd++) {
765
        char buf[128];
766
        snprintf(buf, sizeof(buf), "query-%s", cmd->name);
767
        info = alloc_cmd_entry(buf);
768
        info->next = cmd_list;
769
        cmd_list = info;
770
    }
771

    
772
    return cmd_list;
773
}
774

    
775
/* get the current CPU defined by the user */
776
static int mon_set_cpu(int cpu_index)
777
{
778
    CPUState *env;
779

    
780
    for(env = first_cpu; env != NULL; env = env->next_cpu) {
781
        if (env->cpu_index == cpu_index) {
782
            cur_mon->mon_cpu = env;
783
            return 0;
784
        }
785
    }
786
    return -1;
787
}
788

    
789
static CPUState *mon_get_cpu(void)
790
{
791
    if (!cur_mon->mon_cpu) {
792
        mon_set_cpu(0);
793
    }
794
    cpu_synchronize_state(cur_mon->mon_cpu);
795
    return cur_mon->mon_cpu;
796
}
797

    
798
static void do_info_registers(Monitor *mon)
799
{
800
    CPUState *env;
801
    env = mon_get_cpu();
802
#ifdef TARGET_I386
803
    cpu_dump_state(env, (FILE *)mon, monitor_fprintf,
804
                   X86_DUMP_FPU);
805
#else
806
    cpu_dump_state(env, (FILE *)mon, monitor_fprintf,
807
                   0);
808
#endif
809
}
810

    
811
static void print_cpu_iter(QObject *obj, void *opaque)
812
{
813
    QDict *cpu;
814
    int active = ' ';
815
    Monitor *mon = opaque;
816

    
817
    assert(qobject_type(obj) == QTYPE_QDICT);
818
    cpu = qobject_to_qdict(obj);
819

    
820
    if (qdict_get_bool(cpu, "current")) {
821
        active = '*';
822
    }
823

    
824
    monitor_printf(mon, "%c CPU #%d: ", active, (int)qdict_get_int(cpu, "CPU"));
825

    
826
#if defined(TARGET_I386)
827
    monitor_printf(mon, "pc=0x" TARGET_FMT_lx,
828
                   (target_ulong) qdict_get_int(cpu, "pc"));
829
#elif defined(TARGET_PPC)
830
    monitor_printf(mon, "nip=0x" TARGET_FMT_lx,
831
                   (target_long) qdict_get_int(cpu, "nip"));
832
#elif defined(TARGET_SPARC)
833
    monitor_printf(mon, "pc=0x" TARGET_FMT_lx,
834
                   (target_long) qdict_get_int(cpu, "pc"));
835
    monitor_printf(mon, "npc=0x" TARGET_FMT_lx,
836
                   (target_long) qdict_get_int(cpu, "npc"));
837
#elif defined(TARGET_MIPS)
838
    monitor_printf(mon, "PC=0x" TARGET_FMT_lx,
839
                   (target_long) qdict_get_int(cpu, "PC"));
840
#endif
841

    
842
    if (qdict_get_bool(cpu, "halted")) {
843
        monitor_printf(mon, " (halted)");
844
    }
845

    
846
    monitor_printf(mon, " thread_id=%" PRId64 " ",
847
                   qdict_get_int(cpu, "thread_id"));
848

    
849
    monitor_printf(mon, "\n");
850
}
851

    
852
static void monitor_print_cpus(Monitor *mon, const QObject *data)
853
{
854
    QList *cpu_list;
855

    
856
    assert(qobject_type(data) == QTYPE_QLIST);
857
    cpu_list = qobject_to_qlist(data);
858
    qlist_iter(cpu_list, print_cpu_iter, mon);
859
}
860

    
861
static void do_info_cpus(Monitor *mon, QObject **ret_data)
862
{
863
    CPUState *env;
864
    QList *cpu_list;
865

    
866
    cpu_list = qlist_new();
867

    
868
    /* just to set the default cpu if not already done */
869
    mon_get_cpu();
870

    
871
    for(env = first_cpu; env != NULL; env = env->next_cpu) {
872
        QDict *cpu;
873
        QObject *obj;
874

    
875
        cpu_synchronize_state(env);
876

    
877
        obj = qobject_from_jsonf("{ 'CPU': %d, 'current': %i, 'halted': %i }",
878
                                 env->cpu_index, env == mon->mon_cpu,
879
                                 env->halted);
880

    
881
        cpu = qobject_to_qdict(obj);
882

    
883
#if defined(TARGET_I386)
884
        qdict_put(cpu, "pc", qint_from_int(env->eip + env->segs[R_CS].base));
885
#elif defined(TARGET_PPC)
886
        qdict_put(cpu, "nip", qint_from_int(env->nip));
887
#elif defined(TARGET_SPARC)
888
        qdict_put(cpu, "pc", qint_from_int(env->pc));
889
        qdict_put(cpu, "npc", qint_from_int(env->npc));
890
#elif defined(TARGET_MIPS)
891
        qdict_put(cpu, "PC", qint_from_int(env->active_tc.PC));
892
#endif
893
        qdict_put(cpu, "thread_id", qint_from_int(env->thread_id));
894

    
895
        qlist_append(cpu_list, cpu);
896
    }
897

    
898
    *ret_data = QOBJECT(cpu_list);
899
}
900

    
901
static int do_cpu_set(Monitor *mon, const QDict *qdict, QObject **ret_data)
902
{
903
    int index = qdict_get_int(qdict, "index");
904
    if (mon_set_cpu(index) < 0) {
905
        qerror_report(QERR_INVALID_PARAMETER_VALUE, "index",
906
                      "a CPU number");
907
        return -1;
908
    }
909
    return 0;
910
}
911

    
912
static void do_info_jit(Monitor *mon)
913
{
914
    dump_exec_info((FILE *)mon, monitor_fprintf);
915
}
916

    
917
static void do_info_history(Monitor *mon)
918
{
919
    int i;
920
    const char *str;
921

    
922
    if (!mon->rs)
923
        return;
924
    i = 0;
925
    for(;;) {
926
        str = readline_get_history(mon->rs, i);
927
        if (!str)
928
            break;
929
        monitor_printf(mon, "%d: '%s'\n", i, str);
930
        i++;
931
    }
932
}
933

    
934
#if defined(TARGET_PPC)
935
/* XXX: not implemented in other targets */
936
static void do_info_cpu_stats(Monitor *mon)
937
{
938
    CPUState *env;
939

    
940
    env = mon_get_cpu();
941
    cpu_dump_statistics(env, (FILE *)mon, &monitor_fprintf, 0);
942
}
943
#endif
944

    
945
#if defined(CONFIG_TRACE_SIMPLE)
946
static void do_info_trace(Monitor *mon)
947
{
948
    st_print_trace((FILE *)mon, &monitor_fprintf);
949
}
950
#endif
951

    
952
static void do_trace_print_events(Monitor *mon)
953
{
954
    trace_print_events((FILE *)mon, &monitor_fprintf);
955
}
956

    
957
#ifdef CONFIG_VNC
958
static int change_vnc_password(const char *password)
959
{
960
    if (!password || !password[0]) {
961
        if (vnc_display_disable_login(NULL)) {
962
            qerror_report(QERR_SET_PASSWD_FAILED);
963
            return -1;
964
        }
965
        return 0;
966
    }
967

    
968
    if (vnc_display_password(NULL, password) < 0) {
969
        qerror_report(QERR_SET_PASSWD_FAILED);
970
        return -1;
971
    }
972

    
973
    return 0;
974
}
975

    
976
static void change_vnc_password_cb(Monitor *mon, const char *password,
977
                                   void *opaque)
978
{
979
    change_vnc_password(password);
980
    monitor_read_command(mon, 1);
981
}
982

    
983
static int do_change_vnc(Monitor *mon, const char *target, const char *arg)
984
{
985
    if (strcmp(target, "passwd") == 0 ||
986
        strcmp(target, "password") == 0) {
987
        if (arg) {
988
            char password[9];
989
            strncpy(password, arg, sizeof(password));
990
            password[sizeof(password) - 1] = '\0';
991
            return change_vnc_password(password);
992
        } else {
993
            return monitor_read_password(mon, change_vnc_password_cb, NULL);
994
        }
995
    } else {
996
        if (vnc_display_open(NULL, target) < 0) {
997
            qerror_report(QERR_VNC_SERVER_FAILED, target);
998
            return -1;
999
        }
1000
    }
1001

    
1002
    return 0;
1003
}
1004
#else
1005
static int do_change_vnc(Monitor *mon, const char *target, const char *arg)
1006
{
1007
    qerror_report(QERR_FEATURE_DISABLED, "vnc");
1008
    return -ENODEV;
1009
}
1010
#endif
1011

    
1012
/**
1013
 * do_change(): Change a removable medium, or VNC configuration
1014
 */
1015
static int do_change(Monitor *mon, const QDict *qdict, QObject **ret_data)
1016
{
1017
    const char *device = qdict_get_str(qdict, "device");
1018
    const char *target = qdict_get_str(qdict, "target");
1019
    const char *arg = qdict_get_try_str(qdict, "arg");
1020
    int ret;
1021

    
1022
    if (strcmp(device, "vnc") == 0) {
1023
        ret = do_change_vnc(mon, target, arg);
1024
    } else {
1025
        ret = do_change_block(mon, device, target, arg);
1026
    }
1027

    
1028
    return ret;
1029
}
1030

    
1031
static int set_password(Monitor *mon, const QDict *qdict, QObject **ret_data)
1032
{
1033
    const char *protocol  = qdict_get_str(qdict, "protocol");
1034
    const char *password  = qdict_get_str(qdict, "password");
1035
    const char *connected = qdict_get_try_str(qdict, "connected");
1036
    int disconnect_if_connected = 0;
1037
    int fail_if_connected = 0;
1038
    int rc;
1039

    
1040
    if (connected) {
1041
        if (strcmp(connected, "fail") == 0) {
1042
            fail_if_connected = 1;
1043
        } else if (strcmp(connected, "disconnect") == 0) {
1044
            disconnect_if_connected = 1;
1045
        } else if (strcmp(connected, "keep") == 0) {
1046
            /* nothing */
1047
        } else {
1048
            qerror_report(QERR_INVALID_PARAMETER, "connected");
1049
            return -1;
1050
        }
1051
    }
1052

    
1053
    if (strcmp(protocol, "spice") == 0) {
1054
        if (!using_spice) {
1055
            /* correct one? spice isn't a device ,,, */
1056
            qerror_report(QERR_DEVICE_NOT_ACTIVE, "spice");
1057
            return -1;
1058
        }
1059
        rc = qemu_spice_set_passwd(password, fail_if_connected,
1060
                                   disconnect_if_connected);
1061
        if (rc != 0) {
1062
            qerror_report(QERR_SET_PASSWD_FAILED);
1063
            return -1;
1064
        }
1065
        return 0;
1066
    }
1067

    
1068
    if (strcmp(protocol, "vnc") == 0) {
1069
        if (fail_if_connected || disconnect_if_connected) {
1070
            /* vnc supports "connected=keep" only */
1071
            qerror_report(QERR_INVALID_PARAMETER, "connected");
1072
            return -1;
1073
        }
1074
        /* Note that setting an empty password will not disable login through
1075
         * this interface. */
1076
        return vnc_display_password(NULL, password);
1077
    }
1078

    
1079
    qerror_report(QERR_INVALID_PARAMETER, "protocol");
1080
    return -1;
1081
}
1082

    
1083
static int expire_password(Monitor *mon, const QDict *qdict, QObject **ret_data)
1084
{
1085
    const char *protocol  = qdict_get_str(qdict, "protocol");
1086
    const char *whenstr = qdict_get_str(qdict, "time");
1087
    time_t when;
1088
    int rc;
1089

    
1090
    if (strcmp(whenstr, "now") == 0) {
1091
        when = 0;
1092
    } else if (strcmp(whenstr, "never") == 0) {
1093
        when = TIME_MAX;
1094
    } else if (whenstr[0] == '+') {
1095
        when = time(NULL) + strtoull(whenstr+1, NULL, 10);
1096
    } else {
1097
        when = strtoull(whenstr, NULL, 10);
1098
    }
1099

    
1100
    if (strcmp(protocol, "spice") == 0) {
1101
        if (!using_spice) {
1102
            /* correct one? spice isn't a device ,,, */
1103
            qerror_report(QERR_DEVICE_NOT_ACTIVE, "spice");
1104
            return -1;
1105
        }
1106
        rc = qemu_spice_set_pw_expire(when);
1107
        if (rc != 0) {
1108
            qerror_report(QERR_SET_PASSWD_FAILED);
1109
            return -1;
1110
        }
1111
        return 0;
1112
    }
1113

    
1114
    if (strcmp(protocol, "vnc") == 0) {
1115
        return vnc_display_pw_expire(NULL, when);
1116
    }
1117

    
1118
    qerror_report(QERR_INVALID_PARAMETER, "protocol");
1119
    return -1;
1120
}
1121

    
1122
static int add_graphics_client(Monitor *mon, const QDict *qdict, QObject **ret_data)
1123
{
1124
    const char *protocol  = qdict_get_str(qdict, "protocol");
1125
    const char *fdname = qdict_get_str(qdict, "fdname");
1126
    CharDriverState *s;
1127

    
1128
    if (strcmp(protocol, "spice") == 0) {
1129
        if (!using_spice) {
1130
            /* correct one? spice isn't a device ,,, */
1131
            qerror_report(QERR_DEVICE_NOT_ACTIVE, "spice");
1132
            return -1;
1133
        }
1134
        qerror_report(QERR_ADD_CLIENT_FAILED);
1135
        return -1;
1136
#ifdef CONFIG_VNC
1137
    } else if (strcmp(protocol, "vnc") == 0) {
1138
        int fd = monitor_get_fd(mon, fdname);
1139
        int skipauth = qdict_get_try_bool(qdict, "skipauth", 0);
1140
        vnc_display_add_client(NULL, fd, skipauth);
1141
        return 0;
1142
#endif
1143
    } else if ((s = qemu_chr_find(protocol)) != NULL) {
1144
        int fd = monitor_get_fd(mon, fdname);
1145
        if (qemu_chr_add_client(s, fd) < 0) {
1146
            qerror_report(QERR_ADD_CLIENT_FAILED);
1147
            return -1;
1148
        }
1149
        return 0;
1150
    }
1151

    
1152
    qerror_report(QERR_INVALID_PARAMETER, "protocol");
1153
    return -1;
1154
}
1155

    
1156
static int client_migrate_info(Monitor *mon, const QDict *qdict, QObject **ret_data)
1157
{
1158
    const char *protocol = qdict_get_str(qdict, "protocol");
1159
    const char *hostname = qdict_get_str(qdict, "hostname");
1160
    const char *subject  = qdict_get_try_str(qdict, "cert-subject");
1161
    int port             = qdict_get_try_int(qdict, "port", -1);
1162
    int tls_port         = qdict_get_try_int(qdict, "tls-port", -1);
1163
    int ret;
1164

    
1165
    if (strcmp(protocol, "spice") == 0) {
1166
        if (!using_spice) {
1167
            qerror_report(QERR_DEVICE_NOT_ACTIVE, "spice");
1168
            return -1;
1169
        }
1170

    
1171
        ret = qemu_spice_migrate_info(hostname, port, tls_port, subject);
1172
        if (ret != 0) {
1173
            qerror_report(QERR_UNDEFINED_ERROR);
1174
            return -1;
1175
        }
1176
        return 0;
1177
    }
1178

    
1179
    qerror_report(QERR_INVALID_PARAMETER, "protocol");
1180
    return -1;
1181
}
1182

    
1183
static int do_screen_dump(Monitor *mon, const QDict *qdict, QObject **ret_data)
1184
{
1185
    vga_hw_screen_dump(qdict_get_str(qdict, "filename"));
1186
    return 0;
1187
}
1188

    
1189
static void do_logfile(Monitor *mon, const QDict *qdict)
1190
{
1191
    cpu_set_log_filename(qdict_get_str(qdict, "filename"));
1192
}
1193

    
1194
static void do_log(Monitor *mon, const QDict *qdict)
1195
{
1196
    int mask;
1197
    const char *items = qdict_get_str(qdict, "items");
1198

    
1199
    if (!strcmp(items, "none")) {
1200
        mask = 0;
1201
    } else {
1202
        mask = cpu_str_to_log_mask(items);
1203
        if (!mask) {
1204
            help_cmd(mon, "log");
1205
            return;
1206
        }
1207
    }
1208
    cpu_set_log(mask);
1209
}
1210

    
1211
static void do_singlestep(Monitor *mon, const QDict *qdict)
1212
{
1213
    const char *option = qdict_get_try_str(qdict, "option");
1214
    if (!option || !strcmp(option, "on")) {
1215
        singlestep = 1;
1216
    } else if (!strcmp(option, "off")) {
1217
        singlestep = 0;
1218
    } else {
1219
        monitor_printf(mon, "unexpected option %s\n", option);
1220
    }
1221
}
1222

    
1223
static void encrypted_bdrv_it(void *opaque, BlockDriverState *bs);
1224

    
1225
struct bdrv_iterate_context {
1226
    Monitor *mon;
1227
    int err;
1228
};
1229

    
1230
static void iostatus_bdrv_it(void *opaque, BlockDriverState *bs)
1231
{
1232
    bdrv_iostatus_reset(bs);
1233
}
1234

    
1235
/**
1236
 * do_cont(): Resume emulation.
1237
 */
1238
static int do_cont(Monitor *mon, const QDict *qdict, QObject **ret_data)
1239
{
1240
    struct bdrv_iterate_context context = { mon, 0 };
1241

    
1242
    if (runstate_check(RUN_STATE_INMIGRATE)) {
1243
        qerror_report(QERR_MIGRATION_EXPECTED);
1244
        return -1;
1245
    } else if (runstate_check(RUN_STATE_INTERNAL_ERROR) ||
1246
               runstate_check(RUN_STATE_SHUTDOWN)) {
1247
        qerror_report(QERR_RESET_REQUIRED);
1248
        return -1;
1249
    }
1250

    
1251
    bdrv_iterate(iostatus_bdrv_it, NULL);
1252
    bdrv_iterate(encrypted_bdrv_it, &context);
1253
    /* only resume the vm if all keys are set and valid */
1254
    if (!context.err) {
1255
        vm_start();
1256
        return 0;
1257
    } else {
1258
        return -1;
1259
    }
1260
}
1261

    
1262
static void bdrv_key_cb(void *opaque, int err)
1263
{
1264
    Monitor *mon = opaque;
1265

    
1266
    /* another key was set successfully, retry to continue */
1267
    if (!err)
1268
        do_cont(mon, NULL, NULL);
1269
}
1270

    
1271
static void encrypted_bdrv_it(void *opaque, BlockDriverState *bs)
1272
{
1273
    struct bdrv_iterate_context *context = opaque;
1274

    
1275
    if (!context->err && bdrv_key_required(bs)) {
1276
        context->err = -EBUSY;
1277
        monitor_read_bdrv_key_start(context->mon, bs, bdrv_key_cb,
1278
                                    context->mon);
1279
    }
1280
}
1281

    
1282
static void do_gdbserver(Monitor *mon, const QDict *qdict)
1283
{
1284
    const char *device = qdict_get_try_str(qdict, "device");
1285
    if (!device)
1286
        device = "tcp::" DEFAULT_GDBSTUB_PORT;
1287
    if (gdbserver_start(device) < 0) {
1288
        monitor_printf(mon, "Could not open gdbserver on device '%s'\n",
1289
                       device);
1290
    } else if (strcmp(device, "none") == 0) {
1291
        monitor_printf(mon, "Disabled gdbserver\n");
1292
    } else {
1293
        monitor_printf(mon, "Waiting for gdb connection on device '%s'\n",
1294
                       device);
1295
    }
1296
}
1297

    
1298
static void do_watchdog_action(Monitor *mon, const QDict *qdict)
1299
{
1300
    const char *action = qdict_get_str(qdict, "action");
1301
    if (select_watchdog_action(action) == -1) {
1302
        monitor_printf(mon, "Unknown watchdog action '%s'\n", action);
1303
    }
1304
}
1305

    
1306
static void monitor_printc(Monitor *mon, int c)
1307
{
1308
    monitor_printf(mon, "'");
1309
    switch(c) {
1310
    case '\'':
1311
        monitor_printf(mon, "\\'");
1312
        break;
1313
    case '\\':
1314
        monitor_printf(mon, "\\\\");
1315
        break;
1316
    case '\n':
1317
        monitor_printf(mon, "\\n");
1318
        break;
1319
    case '\r':
1320
        monitor_printf(mon, "\\r");
1321
        break;
1322
    default:
1323
        if (c >= 32 && c <= 126) {
1324
            monitor_printf(mon, "%c", c);
1325
        } else {
1326
            monitor_printf(mon, "\\x%02x", c);
1327
        }
1328
        break;
1329
    }
1330
    monitor_printf(mon, "'");
1331
}
1332

    
1333
static void memory_dump(Monitor *mon, int count, int format, int wsize,
1334
                        target_phys_addr_t addr, int is_physical)
1335
{
1336
    CPUState *env;
1337
    int l, line_size, i, max_digits, len;
1338
    uint8_t buf[16];
1339
    uint64_t v;
1340

    
1341
    if (format == 'i') {
1342
        int flags;
1343
        flags = 0;
1344
        env = mon_get_cpu();
1345
#ifdef TARGET_I386
1346
        if (wsize == 2) {
1347
            flags = 1;
1348
        } else if (wsize == 4) {
1349
            flags = 0;
1350
        } else {
1351
            /* as default we use the current CS size */
1352
            flags = 0;
1353
            if (env) {
1354
#ifdef TARGET_X86_64
1355
                if ((env->efer & MSR_EFER_LMA) &&
1356
                    (env->segs[R_CS].flags & DESC_L_MASK))
1357
                    flags = 2;
1358
                else
1359
#endif
1360
                if (!(env->segs[R_CS].flags & DESC_B_MASK))
1361
                    flags = 1;
1362
            }
1363
        }
1364
#endif
1365
        monitor_disas(mon, env, addr, count, is_physical, flags);
1366
        return;
1367
    }
1368

    
1369
    len = wsize * count;
1370
    if (wsize == 1)
1371
        line_size = 8;
1372
    else
1373
        line_size = 16;
1374
    max_digits = 0;
1375

    
1376
    switch(format) {
1377
    case 'o':
1378
        max_digits = (wsize * 8 + 2) / 3;
1379
        break;
1380
    default:
1381
    case 'x':
1382
        max_digits = (wsize * 8) / 4;
1383
        break;
1384
    case 'u':
1385
    case 'd':
1386
        max_digits = (wsize * 8 * 10 + 32) / 33;
1387
        break;
1388
    case 'c':
1389
        wsize = 1;
1390
        break;
1391
    }
1392

    
1393
    while (len > 0) {
1394
        if (is_physical)
1395
            monitor_printf(mon, TARGET_FMT_plx ":", addr);
1396
        else
1397
            monitor_printf(mon, TARGET_FMT_lx ":", (target_ulong)addr);
1398
        l = len;
1399
        if (l > line_size)
1400
            l = line_size;
1401
        if (is_physical) {
1402
            cpu_physical_memory_read(addr, buf, l);
1403
        } else {
1404
            env = mon_get_cpu();
1405
            if (cpu_memory_rw_debug(env, addr, buf, l, 0) < 0) {
1406
                monitor_printf(mon, " Cannot access memory\n");
1407
                break;
1408
            }
1409
        }
1410
        i = 0;
1411
        while (i < l) {
1412
            switch(wsize) {
1413
            default:
1414
            case 1:
1415
                v = ldub_raw(buf + i);
1416
                break;
1417
            case 2:
1418
                v = lduw_raw(buf + i);
1419
                break;
1420
            case 4:
1421
                v = (uint32_t)ldl_raw(buf + i);
1422
                break;
1423
            case 8:
1424
                v = ldq_raw(buf + i);
1425
                break;
1426
            }
1427
            monitor_printf(mon, " ");
1428
            switch(format) {
1429
            case 'o':
1430
                monitor_printf(mon, "%#*" PRIo64, max_digits, v);
1431
                break;
1432
            case 'x':
1433
                monitor_printf(mon, "0x%0*" PRIx64, max_digits, v);
1434
                break;
1435
            case 'u':
1436
                monitor_printf(mon, "%*" PRIu64, max_digits, v);
1437
                break;
1438
            case 'd':
1439
                monitor_printf(mon, "%*" PRId64, max_digits, v);
1440
                break;
1441
            case 'c':
1442
                monitor_printc(mon, v);
1443
                break;
1444
            }
1445
            i += wsize;
1446
        }
1447
        monitor_printf(mon, "\n");
1448
        addr += l;
1449
        len -= l;
1450
    }
1451
}
1452

    
1453
static void do_memory_dump(Monitor *mon, const QDict *qdict)
1454
{
1455
    int count = qdict_get_int(qdict, "count");
1456
    int format = qdict_get_int(qdict, "format");
1457
    int size = qdict_get_int(qdict, "size");
1458
    target_long addr = qdict_get_int(qdict, "addr");
1459

    
1460
    memory_dump(mon, count, format, size, addr, 0);
1461
}
1462

    
1463
static void do_physical_memory_dump(Monitor *mon, const QDict *qdict)
1464
{
1465
    int count = qdict_get_int(qdict, "count");
1466
    int format = qdict_get_int(qdict, "format");
1467
    int size = qdict_get_int(qdict, "size");
1468
    target_phys_addr_t addr = qdict_get_int(qdict, "addr");
1469

    
1470
    memory_dump(mon, count, format, size, addr, 1);
1471
}
1472

    
1473
static void do_print(Monitor *mon, const QDict *qdict)
1474
{
1475
    int format = qdict_get_int(qdict, "format");
1476
    target_phys_addr_t val = qdict_get_int(qdict, "val");
1477

    
1478
#if TARGET_PHYS_ADDR_BITS == 32
1479
    switch(format) {
1480
    case 'o':
1481
        monitor_printf(mon, "%#o", val);
1482
        break;
1483
    case 'x':
1484
        monitor_printf(mon, "%#x", val);
1485
        break;
1486
    case 'u':
1487
        monitor_printf(mon, "%u", val);
1488
        break;
1489
    default:
1490
    case 'd':
1491
        monitor_printf(mon, "%d", val);
1492
        break;
1493
    case 'c':
1494
        monitor_printc(mon, val);
1495
        break;
1496
    }
1497
#else
1498
    switch(format) {
1499
    case 'o':
1500
        monitor_printf(mon, "%#" PRIo64, val);
1501
        break;
1502
    case 'x':
1503
        monitor_printf(mon, "%#" PRIx64, val);
1504
        break;
1505
    case 'u':
1506
        monitor_printf(mon, "%" PRIu64, val);
1507
        break;
1508
    default:
1509
    case 'd':
1510
        monitor_printf(mon, "%" PRId64, val);
1511
        break;
1512
    case 'c':
1513
        monitor_printc(mon, val);
1514
        break;
1515
    }
1516
#endif
1517
    monitor_printf(mon, "\n");
1518
}
1519

    
1520
static int do_memory_save(Monitor *mon, const QDict *qdict, QObject **ret_data)
1521
{
1522
    FILE *f;
1523
    uint32_t size = qdict_get_int(qdict, "size");
1524
    const char *filename = qdict_get_str(qdict, "filename");
1525
    target_long addr = qdict_get_int(qdict, "val");
1526
    uint32_t l;
1527
    CPUState *env;
1528
    uint8_t buf[1024];
1529
    int ret = -1;
1530

    
1531
    env = mon_get_cpu();
1532

    
1533
    f = fopen(filename, "wb");
1534
    if (!f) {
1535
        qerror_report(QERR_OPEN_FILE_FAILED, filename);
1536
        return -1;
1537
    }
1538
    while (size != 0) {
1539
        l = sizeof(buf);
1540
        if (l > size)
1541
            l = size;
1542
        cpu_memory_rw_debug(env, addr, buf, l, 0);
1543
        if (fwrite(buf, 1, l, f) != l) {
1544
            monitor_printf(mon, "fwrite() error in do_memory_save\n");
1545
            goto exit;
1546
        }
1547
        addr += l;
1548
        size -= l;
1549
    }
1550

    
1551
    ret = 0;
1552

    
1553
exit:
1554
    fclose(f);
1555
    return ret;
1556
}
1557

    
1558
static int do_physical_memory_save(Monitor *mon, const QDict *qdict,
1559
                                    QObject **ret_data)
1560
{
1561
    FILE *f;
1562
    uint32_t l;
1563
    uint8_t buf[1024];
1564
    uint32_t size = qdict_get_int(qdict, "size");
1565
    const char *filename = qdict_get_str(qdict, "filename");
1566
    target_phys_addr_t addr = qdict_get_int(qdict, "val");
1567
    int ret = -1;
1568

    
1569
    f = fopen(filename, "wb");
1570
    if (!f) {
1571
        qerror_report(QERR_OPEN_FILE_FAILED, filename);
1572
        return -1;
1573
    }
1574
    while (size != 0) {
1575
        l = sizeof(buf);
1576
        if (l > size)
1577
            l = size;
1578
        cpu_physical_memory_read(addr, buf, l);
1579
        if (fwrite(buf, 1, l, f) != l) {
1580
            monitor_printf(mon, "fwrite() error in do_physical_memory_save\n");
1581
            goto exit;
1582
        }
1583
        fflush(f);
1584
        addr += l;
1585
        size -= l;
1586
    }
1587

    
1588
    ret = 0;
1589

    
1590
exit:
1591
    fclose(f);
1592
    return ret;
1593
}
1594

    
1595
static void do_sum(Monitor *mon, const QDict *qdict)
1596
{
1597
    uint32_t addr;
1598
    uint16_t sum;
1599
    uint32_t start = qdict_get_int(qdict, "start");
1600
    uint32_t size = qdict_get_int(qdict, "size");
1601

    
1602
    sum = 0;
1603
    for(addr = start; addr < (start + size); addr++) {
1604
        uint8_t val = ldub_phys(addr);
1605
        /* BSD sum algorithm ('sum' Unix command) */
1606
        sum = (sum >> 1) | (sum << 15);
1607
        sum += val;
1608
    }
1609
    monitor_printf(mon, "%05d\n", sum);
1610
}
1611

    
1612
typedef struct {
1613
    int keycode;
1614
    const char *name;
1615
} KeyDef;
1616

    
1617
static const KeyDef key_defs[] = {
1618
    { 0x2a, "shift" },
1619
    { 0x36, "shift_r" },
1620

    
1621
    { 0x38, "alt" },
1622
    { 0xb8, "alt_r" },
1623
    { 0x64, "altgr" },
1624
    { 0xe4, "altgr_r" },
1625
    { 0x1d, "ctrl" },
1626
    { 0x9d, "ctrl_r" },
1627

    
1628
    { 0xdd, "menu" },
1629

    
1630
    { 0x01, "esc" },
1631

    
1632
    { 0x02, "1" },
1633
    { 0x03, "2" },
1634
    { 0x04, "3" },
1635
    { 0x05, "4" },
1636
    { 0x06, "5" },
1637
    { 0x07, "6" },
1638
    { 0x08, "7" },
1639
    { 0x09, "8" },
1640
    { 0x0a, "9" },
1641
    { 0x0b, "0" },
1642
    { 0x0c, "minus" },
1643
    { 0x0d, "equal" },
1644
    { 0x0e, "backspace" },
1645

    
1646
    { 0x0f, "tab" },
1647
    { 0x10, "q" },
1648
    { 0x11, "w" },
1649
    { 0x12, "e" },
1650
    { 0x13, "r" },
1651
    { 0x14, "t" },
1652
    { 0x15, "y" },
1653
    { 0x16, "u" },
1654
    { 0x17, "i" },
1655
    { 0x18, "o" },
1656
    { 0x19, "p" },
1657
    { 0x1a, "bracket_left" },
1658
    { 0x1b, "bracket_right" },
1659
    { 0x1c, "ret" },
1660

    
1661
    { 0x1e, "a" },
1662
    { 0x1f, "s" },
1663
    { 0x20, "d" },
1664
    { 0x21, "f" },
1665
    { 0x22, "g" },
1666
    { 0x23, "h" },
1667
    { 0x24, "j" },
1668
    { 0x25, "k" },
1669
    { 0x26, "l" },
1670
    { 0x27, "semicolon" },
1671
    { 0x28, "apostrophe" },
1672
    { 0x29, "grave_accent" },
1673

    
1674
    { 0x2b, "backslash" },
1675
    { 0x2c, "z" },
1676
    { 0x2d, "x" },
1677
    { 0x2e, "c" },
1678
    { 0x2f, "v" },
1679
    { 0x30, "b" },
1680
    { 0x31, "n" },
1681
    { 0x32, "m" },
1682
    { 0x33, "comma" },
1683
    { 0x34, "dot" },
1684
    { 0x35, "slash" },
1685

    
1686
    { 0x37, "asterisk" },
1687

    
1688
    { 0x39, "spc" },
1689
    { 0x3a, "caps_lock" },
1690
    { 0x3b, "f1" },
1691
    { 0x3c, "f2" },
1692
    { 0x3d, "f3" },
1693
    { 0x3e, "f4" },
1694
    { 0x3f, "f5" },
1695
    { 0x40, "f6" },
1696
    { 0x41, "f7" },
1697
    { 0x42, "f8" },
1698
    { 0x43, "f9" },
1699
    { 0x44, "f10" },
1700
    { 0x45, "num_lock" },
1701
    { 0x46, "scroll_lock" },
1702

    
1703
    { 0xb5, "kp_divide" },
1704
    { 0x37, "kp_multiply" },
1705
    { 0x4a, "kp_subtract" },
1706
    { 0x4e, "kp_add" },
1707
    { 0x9c, "kp_enter" },
1708
    { 0x53, "kp_decimal" },
1709
    { 0x54, "sysrq" },
1710

    
1711
    { 0x52, "kp_0" },
1712
    { 0x4f, "kp_1" },
1713
    { 0x50, "kp_2" },
1714
    { 0x51, "kp_3" },
1715
    { 0x4b, "kp_4" },
1716
    { 0x4c, "kp_5" },
1717
    { 0x4d, "kp_6" },
1718
    { 0x47, "kp_7" },
1719
    { 0x48, "kp_8" },
1720
    { 0x49, "kp_9" },
1721

    
1722
    { 0x56, "<" },
1723

    
1724
    { 0x57, "f11" },
1725
    { 0x58, "f12" },
1726

    
1727
    { 0xb7, "print" },
1728

    
1729
    { 0xc7, "home" },
1730
    { 0xc9, "pgup" },
1731
    { 0xd1, "pgdn" },
1732
    { 0xcf, "end" },
1733

    
1734
    { 0xcb, "left" },
1735
    { 0xc8, "up" },
1736
    { 0xd0, "down" },
1737
    { 0xcd, "right" },
1738

    
1739
    { 0xd2, "insert" },
1740
    { 0xd3, "delete" },
1741
#if defined(TARGET_SPARC) && !defined(TARGET_SPARC64)
1742
    { 0xf0, "stop" },
1743
    { 0xf1, "again" },
1744
    { 0xf2, "props" },
1745
    { 0xf3, "undo" },
1746
    { 0xf4, "front" },
1747
    { 0xf5, "copy" },
1748
    { 0xf6, "open" },
1749
    { 0xf7, "paste" },
1750
    { 0xf8, "find" },
1751
    { 0xf9, "cut" },
1752
    { 0xfa, "lf" },
1753
    { 0xfb, "help" },
1754
    { 0xfc, "meta_l" },
1755
    { 0xfd, "meta_r" },
1756
    { 0xfe, "compose" },
1757
#endif
1758
    { 0, NULL },
1759
};
1760

    
1761
static int get_keycode(const char *key)
1762
{
1763
    const KeyDef *p;
1764
    char *endp;
1765
    int ret;
1766

    
1767
    for(p = key_defs; p->name != NULL; p++) {
1768
        if (!strcmp(key, p->name))
1769
            return p->keycode;
1770
    }
1771
    if (strstart(key, "0x", NULL)) {
1772
        ret = strtoul(key, &endp, 0);
1773
        if (*endp == '\0' && ret >= 0x01 && ret <= 0xff)
1774
            return ret;
1775
    }
1776
    return -1;
1777
}
1778

    
1779
#define MAX_KEYCODES 16
1780
static uint8_t keycodes[MAX_KEYCODES];
1781
static int nb_pending_keycodes;
1782
static QEMUTimer *key_timer;
1783

    
1784
static void release_keys(void *opaque)
1785
{
1786
    int keycode;
1787

    
1788
    while (nb_pending_keycodes > 0) {
1789
        nb_pending_keycodes--;
1790
        keycode = keycodes[nb_pending_keycodes];
1791
        if (keycode & 0x80)
1792
            kbd_put_keycode(0xe0);
1793
        kbd_put_keycode(keycode | 0x80);
1794
    }
1795
}
1796

    
1797
static void do_sendkey(Monitor *mon, const QDict *qdict)
1798
{
1799
    char keyname_buf[16];
1800
    char *separator;
1801
    int keyname_len, keycode, i;
1802
    const char *string = qdict_get_str(qdict, "string");
1803
    int has_hold_time = qdict_haskey(qdict, "hold_time");
1804
    int hold_time = qdict_get_try_int(qdict, "hold_time", -1);
1805

    
1806
    if (nb_pending_keycodes > 0) {
1807
        qemu_del_timer(key_timer);
1808
        release_keys(NULL);
1809
    }
1810
    if (!has_hold_time)
1811
        hold_time = 100;
1812
    i = 0;
1813
    while (1) {
1814
        separator = strchr(string, '-');
1815
        keyname_len = separator ? separator - string : strlen(string);
1816
        if (keyname_len > 0) {
1817
            pstrcpy(keyname_buf, sizeof(keyname_buf), string);
1818
            if (keyname_len > sizeof(keyname_buf) - 1) {
1819
                monitor_printf(mon, "invalid key: '%s...'\n", keyname_buf);
1820
                return;
1821
            }
1822
            if (i == MAX_KEYCODES) {
1823
                monitor_printf(mon, "too many keys\n");
1824
                return;
1825
            }
1826
            keyname_buf[keyname_len] = 0;
1827
            keycode = get_keycode(keyname_buf);
1828
            if (keycode < 0) {
1829
                monitor_printf(mon, "unknown key: '%s'\n", keyname_buf);
1830
                return;
1831
            }
1832
            keycodes[i++] = keycode;
1833
        }
1834
        if (!separator)
1835
            break;
1836
        string = separator + 1;
1837
    }
1838
    nb_pending_keycodes = i;
1839
    /* key down events */
1840
    for (i = 0; i < nb_pending_keycodes; i++) {
1841
        keycode = keycodes[i];
1842
        if (keycode & 0x80)
1843
            kbd_put_keycode(0xe0);
1844
        kbd_put_keycode(keycode & 0x7f);
1845
    }
1846
    /* delayed key up events */
1847
    qemu_mod_timer(key_timer, qemu_get_clock_ns(vm_clock) +
1848
                   muldiv64(get_ticks_per_sec(), hold_time, 1000));
1849
}
1850

    
1851
static int mouse_button_state;
1852

    
1853
static void do_mouse_move(Monitor *mon, const QDict *qdict)
1854
{
1855
    int dx, dy, dz;
1856
    const char *dx_str = qdict_get_str(qdict, "dx_str");
1857
    const char *dy_str = qdict_get_str(qdict, "dy_str");
1858
    const char *dz_str = qdict_get_try_str(qdict, "dz_str");
1859
    dx = strtol(dx_str, NULL, 0);
1860
    dy = strtol(dy_str, NULL, 0);
1861
    dz = 0;
1862
    if (dz_str)
1863
        dz = strtol(dz_str, NULL, 0);
1864
    kbd_mouse_event(dx, dy, dz, mouse_button_state);
1865
}
1866

    
1867
static void do_mouse_button(Monitor *mon, const QDict *qdict)
1868
{
1869
    int button_state = qdict_get_int(qdict, "button_state");
1870
    mouse_button_state = button_state;
1871
    kbd_mouse_event(0, 0, 0, mouse_button_state);
1872
}
1873

    
1874
static void do_ioport_read(Monitor *mon, const QDict *qdict)
1875
{
1876
    int size = qdict_get_int(qdict, "size");
1877
    int addr = qdict_get_int(qdict, "addr");
1878
    int has_index = qdict_haskey(qdict, "index");
1879
    uint32_t val;
1880
    int suffix;
1881

    
1882
    if (has_index) {
1883
        int index = qdict_get_int(qdict, "index");
1884
        cpu_outb(addr & IOPORTS_MASK, index & 0xff);
1885
        addr++;
1886
    }
1887
    addr &= 0xffff;
1888

    
1889
    switch(size) {
1890
    default:
1891
    case 1:
1892
        val = cpu_inb(addr);
1893
        suffix = 'b';
1894
        break;
1895
    case 2:
1896
        val = cpu_inw(addr);
1897
        suffix = 'w';
1898
        break;
1899
    case 4:
1900
        val = cpu_inl(addr);
1901
        suffix = 'l';
1902
        break;
1903
    }
1904
    monitor_printf(mon, "port%c[0x%04x] = %#0*x\n",
1905
                   suffix, addr, size * 2, val);
1906
}
1907

    
1908
static void do_ioport_write(Monitor *mon, const QDict *qdict)
1909
{
1910
    int size = qdict_get_int(qdict, "size");
1911
    int addr = qdict_get_int(qdict, "addr");
1912
    int val = qdict_get_int(qdict, "val");
1913

    
1914
    addr &= IOPORTS_MASK;
1915

    
1916
    switch (size) {
1917
    default:
1918
    case 1:
1919
        cpu_outb(addr, val);
1920
        break;
1921
    case 2:
1922
        cpu_outw(addr, val);
1923
        break;
1924
    case 4:
1925
        cpu_outl(addr, val);
1926
        break;
1927
    }
1928
}
1929

    
1930
static void do_boot_set(Monitor *mon, const QDict *qdict)
1931
{
1932
    int res;
1933
    const char *bootdevice = qdict_get_str(qdict, "bootdevice");
1934

    
1935
    res = qemu_boot_set(bootdevice);
1936
    if (res == 0) {
1937
        monitor_printf(mon, "boot device list now set to %s\n", bootdevice);
1938
    } else if (res > 0) {
1939
        monitor_printf(mon, "setting boot device list failed\n");
1940
    } else {
1941
        monitor_printf(mon, "no function defined to set boot device list for "
1942
                       "this architecture\n");
1943
    }
1944
}
1945

    
1946
/**
1947
 * do_system_powerdown(): Issue a machine powerdown
1948
 */
1949
static int do_system_powerdown(Monitor *mon, const QDict *qdict,
1950
                               QObject **ret_data)
1951
{
1952
    qemu_system_powerdown_request();
1953
    return 0;
1954
}
1955

    
1956
#if defined(TARGET_I386)
1957
static void print_pte(Monitor *mon, target_phys_addr_t addr,
1958
                      target_phys_addr_t pte,
1959
                      target_phys_addr_t mask)
1960
{
1961
#ifdef TARGET_X86_64
1962
    if (addr & (1ULL << 47)) {
1963
        addr |= -1LL << 48;
1964
    }
1965
#endif
1966
    monitor_printf(mon, TARGET_FMT_plx ": " TARGET_FMT_plx
1967
                   " %c%c%c%c%c%c%c%c%c\n",
1968
                   addr,
1969
                   pte & mask,
1970
                   pte & PG_NX_MASK ? 'X' : '-',
1971
                   pte & PG_GLOBAL_MASK ? 'G' : '-',
1972
                   pte & PG_PSE_MASK ? 'P' : '-',
1973
                   pte & PG_DIRTY_MASK ? 'D' : '-',
1974
                   pte & PG_ACCESSED_MASK ? 'A' : '-',
1975
                   pte & PG_PCD_MASK ? 'C' : '-',
1976
                   pte & PG_PWT_MASK ? 'T' : '-',
1977
                   pte & PG_USER_MASK ? 'U' : '-',
1978
                   pte & PG_RW_MASK ? 'W' : '-');
1979
}
1980

    
1981
static void tlb_info_32(Monitor *mon, CPUState *env)
1982
{
1983
    unsigned int l1, l2;
1984
    uint32_t pgd, pde, pte;
1985

    
1986
    pgd = env->cr[3] & ~0xfff;
1987
    for(l1 = 0; l1 < 1024; l1++) {
1988
        cpu_physical_memory_read(pgd + l1 * 4, &pde, 4);
1989
        pde = le32_to_cpu(pde);
1990
        if (pde & PG_PRESENT_MASK) {
1991
            if ((pde & PG_PSE_MASK) && (env->cr[4] & CR4_PSE_MASK)) {
1992
                /* 4M pages */
1993
                print_pte(mon, (l1 << 22), pde, ~((1 << 21) - 1));
1994
            } else {
1995
                for(l2 = 0; l2 < 1024; l2++) {
1996
                    cpu_physical_memory_read((pde & ~0xfff) + l2 * 4, &pte, 4);
1997
                    pte = le32_to_cpu(pte);
1998
                    if (pte & PG_PRESENT_MASK) {
1999
                        print_pte(mon, (l1 << 22) + (l2 << 12),
2000
                                  pte & ~PG_PSE_MASK,
2001
                                  ~0xfff);
2002
                    }
2003
                }
2004
            }
2005
        }
2006
    }
2007
}
2008

    
2009
static void tlb_info_pae32(Monitor *mon, CPUState *env)
2010
{
2011
    unsigned int l1, l2, l3;
2012
    uint64_t pdpe, pde, pte;
2013
    uint64_t pdp_addr, pd_addr, pt_addr;
2014

    
2015
    pdp_addr = env->cr[3] & ~0x1f;
2016
    for (l1 = 0; l1 < 4; l1++) {
2017
        cpu_physical_memory_read(pdp_addr + l1 * 8, &pdpe, 8);
2018
        pdpe = le64_to_cpu(pdpe);
2019
        if (pdpe & PG_PRESENT_MASK) {
2020
            pd_addr = pdpe & 0x3fffffffff000ULL;
2021
            for (l2 = 0; l2 < 512; l2++) {
2022
                cpu_physical_memory_read(pd_addr + l2 * 8, &pde, 8);
2023
                pde = le64_to_cpu(pde);
2024
                if (pde & PG_PRESENT_MASK) {
2025
                    if (pde & PG_PSE_MASK) {
2026
                        /* 2M pages with PAE, CR4.PSE is ignored */
2027
                        print_pte(mon, (l1 << 30 ) + (l2 << 21), pde,
2028
                                  ~((target_phys_addr_t)(1 << 20) - 1));
2029
                    } else {
2030
                        pt_addr = pde & 0x3fffffffff000ULL;
2031
                        for (l3 = 0; l3 < 512; l3++) {
2032
                            cpu_physical_memory_read(pt_addr + l3 * 8, &pte, 8);
2033
                            pte = le64_to_cpu(pte);
2034
                            if (pte & PG_PRESENT_MASK) {
2035
                                print_pte(mon, (l1 << 30 ) + (l2 << 21)
2036
                                          + (l3 << 12),
2037
                                          pte & ~PG_PSE_MASK,
2038
                                          ~(target_phys_addr_t)0xfff);
2039
                            }
2040
                        }
2041
                    }
2042
                }
2043
            }
2044
        }
2045
    }
2046
}
2047

    
2048
#ifdef TARGET_X86_64
2049
static void tlb_info_64(Monitor *mon, CPUState *env)
2050
{
2051
    uint64_t l1, l2, l3, l4;
2052
    uint64_t pml4e, pdpe, pde, pte;
2053
    uint64_t pml4_addr, pdp_addr, pd_addr, pt_addr;
2054

    
2055
    pml4_addr = env->cr[3] & 0x3fffffffff000ULL;
2056
    for (l1 = 0; l1 < 512; l1++) {
2057
        cpu_physical_memory_read(pml4_addr + l1 * 8, &pml4e, 8);
2058
        pml4e = le64_to_cpu(pml4e);
2059
        if (pml4e & PG_PRESENT_MASK) {
2060
            pdp_addr = pml4e & 0x3fffffffff000ULL;
2061
            for (l2 = 0; l2 < 512; l2++) {
2062
                cpu_physical_memory_read(pdp_addr + l2 * 8, &pdpe, 8);
2063
                pdpe = le64_to_cpu(pdpe);
2064
                if (pdpe & PG_PRESENT_MASK) {
2065
                    if (pdpe & PG_PSE_MASK) {
2066
                        /* 1G pages, CR4.PSE is ignored */
2067
                        print_pte(mon, (l1 << 39) + (l2 << 30), pdpe,
2068
                                  0x3ffffc0000000ULL);
2069
                    } else {
2070
                        pd_addr = pdpe & 0x3fffffffff000ULL;
2071
                        for (l3 = 0; l3 < 512; l3++) {
2072
                            cpu_physical_memory_read(pd_addr + l3 * 8, &pde, 8);
2073
                            pde = le64_to_cpu(pde);
2074
                            if (pde & PG_PRESENT_MASK) {
2075
                                if (pde & PG_PSE_MASK) {
2076
                                    /* 2M pages, CR4.PSE is ignored */
2077
                                    print_pte(mon, (l1 << 39) + (l2 << 30) +
2078
                                              (l3 << 21), pde,
2079
                                              0x3ffffffe00000ULL);
2080
                                } else {
2081
                                    pt_addr = pde & 0x3fffffffff000ULL;
2082
                                    for (l4 = 0; l4 < 512; l4++) {
2083
                                        cpu_physical_memory_read(pt_addr
2084
                                                                 + l4 * 8,
2085
                                                                 &pte, 8);
2086
                                        pte = le64_to_cpu(pte);
2087
                                        if (pte & PG_PRESENT_MASK) {
2088
                                            print_pte(mon, (l1 << 39) +
2089
                                                      (l2 << 30) +
2090
                                                      (l3 << 21) + (l4 << 12),
2091
                                                      pte & ~PG_PSE_MASK,
2092
                                                      0x3fffffffff000ULL);
2093
                                        }
2094
                                    }
2095
                                }
2096
                            }
2097
                        }
2098
                    }
2099
                }
2100
            }
2101
        }
2102
    }
2103
}
2104
#endif
2105

    
2106
static void tlb_info(Monitor *mon)
2107
{
2108
    CPUState *env;
2109

    
2110
    env = mon_get_cpu();
2111

    
2112
    if (!(env->cr[0] & CR0_PG_MASK)) {
2113
        monitor_printf(mon, "PG disabled\n");
2114
        return;
2115
    }
2116
    if (env->cr[4] & CR4_PAE_MASK) {
2117
#ifdef TARGET_X86_64
2118
        if (env->hflags & HF_LMA_MASK) {
2119
            tlb_info_64(mon, env);
2120
        } else
2121
#endif
2122
        {
2123
            tlb_info_pae32(mon, env);
2124
        }
2125
    } else {
2126
        tlb_info_32(mon, env);
2127
    }
2128
}
2129

    
2130
static void mem_print(Monitor *mon, target_phys_addr_t *pstart,
2131
                      int *plast_prot,
2132
                      target_phys_addr_t end, int prot)
2133
{
2134
    int prot1;
2135
    prot1 = *plast_prot;
2136
    if (prot != prot1) {
2137
        if (*pstart != -1) {
2138
            monitor_printf(mon, TARGET_FMT_plx "-" TARGET_FMT_plx " "
2139
                           TARGET_FMT_plx " %c%c%c\n",
2140
                           *pstart, end, end - *pstart,
2141
                           prot1 & PG_USER_MASK ? 'u' : '-',
2142
                           'r',
2143
                           prot1 & PG_RW_MASK ? 'w' : '-');
2144
        }
2145
        if (prot != 0)
2146
            *pstart = end;
2147
        else
2148
            *pstart = -1;
2149
        *plast_prot = prot;
2150
    }
2151
}
2152

    
2153
static void mem_info_32(Monitor *mon, CPUState *env)
2154
{
2155
    unsigned int l1, l2;
2156
    int prot, last_prot;
2157
    uint32_t pgd, pde, pte;
2158
    target_phys_addr_t start, end;
2159

    
2160
    pgd = env->cr[3] & ~0xfff;
2161
    last_prot = 0;
2162
    start = -1;
2163
    for(l1 = 0; l1 < 1024; l1++) {
2164
        cpu_physical_memory_read(pgd + l1 * 4, &pde, 4);
2165
        pde = le32_to_cpu(pde);
2166
        end = l1 << 22;
2167
        if (pde & PG_PRESENT_MASK) {
2168
            if ((pde & PG_PSE_MASK) && (env->cr[4] & CR4_PSE_MASK)) {
2169
                prot = pde & (PG_USER_MASK | PG_RW_MASK | PG_PRESENT_MASK);
2170
                mem_print(mon, &start, &last_prot, end, prot);
2171
            } else {
2172
                for(l2 = 0; l2 < 1024; l2++) {
2173
                    cpu_physical_memory_read((pde & ~0xfff) + l2 * 4, &pte, 4);
2174
                    pte = le32_to_cpu(pte);
2175
                    end = (l1 << 22) + (l2 << 12);
2176
                    if (pte & PG_PRESENT_MASK) {
2177
                        prot = pte & pde &
2178
                            (PG_USER_MASK | PG_RW_MASK | PG_PRESENT_MASK);
2179
                    } else {
2180
                        prot = 0;
2181
                    }
2182
                    mem_print(mon, &start, &last_prot, end, prot);
2183
                }
2184
            }
2185
        } else {
2186
            prot = 0;
2187
            mem_print(mon, &start, &last_prot, end, prot);
2188
        }
2189
    }
2190
    /* Flush last range */
2191
    mem_print(mon, &start, &last_prot, (target_phys_addr_t)1 << 32, 0);
2192
}
2193

    
2194
static void mem_info_pae32(Monitor *mon, CPUState *env)
2195
{
2196
    unsigned int l1, l2, l3;
2197
    int prot, last_prot;
2198
    uint64_t pdpe, pde, pte;
2199
    uint64_t pdp_addr, pd_addr, pt_addr;
2200
    target_phys_addr_t start, end;
2201

    
2202
    pdp_addr = env->cr[3] & ~0x1f;
2203
    last_prot = 0;
2204
    start = -1;
2205
    for (l1 = 0; l1 < 4; l1++) {
2206
        cpu_physical_memory_read(pdp_addr + l1 * 8, &pdpe, 8);
2207
        pdpe = le64_to_cpu(pdpe);
2208
        end = l1 << 30;
2209
        if (pdpe & PG_PRESENT_MASK) {
2210
            pd_addr = pdpe & 0x3fffffffff000ULL;
2211
            for (l2 = 0; l2 < 512; l2++) {
2212
                cpu_physical_memory_read(pd_addr + l2 * 8, &pde, 8);
2213
                pde = le64_to_cpu(pde);
2214
                end = (l1 << 30) + (l2 << 21);
2215
                if (pde & PG_PRESENT_MASK) {
2216
                    if (pde & PG_PSE_MASK) {
2217
                        prot = pde & (PG_USER_MASK | PG_RW_MASK |
2218
                                      PG_PRESENT_MASK);
2219
                        mem_print(mon, &start, &last_prot, end, prot);
2220
                    } else {
2221
                        pt_addr = pde & 0x3fffffffff000ULL;
2222
                        for (l3 = 0; l3 < 512; l3++) {
2223
                            cpu_physical_memory_read(pt_addr + l3 * 8, &pte, 8);
2224
                            pte = le64_to_cpu(pte);
2225
                            end = (l1 << 30) + (l2 << 21) + (l3 << 12);
2226
                            if (pte & PG_PRESENT_MASK) {
2227
                                prot = pte & pde & (PG_USER_MASK | PG_RW_MASK |
2228
                                                    PG_PRESENT_MASK);
2229
                            } else {
2230
                                prot = 0;
2231
                            }
2232
                            mem_print(mon, &start, &last_prot, end, prot);
2233
                        }
2234
                    }
2235
                } else {
2236
                    prot = 0;
2237
                    mem_print(mon, &start, &last_prot, end, prot);
2238
                }
2239
            }
2240
        } else {
2241
            prot = 0;
2242
            mem_print(mon, &start, &last_prot, end, prot);
2243
        }
2244
    }
2245
    /* Flush last range */
2246
    mem_print(mon, &start, &last_prot, (target_phys_addr_t)1 << 32, 0);
2247
}
2248

    
2249

    
2250
#ifdef TARGET_X86_64
2251
static void mem_info_64(Monitor *mon, CPUState *env)
2252
{
2253
    int prot, last_prot;
2254
    uint64_t l1, l2, l3, l4;
2255
    uint64_t pml4e, pdpe, pde, pte;
2256
    uint64_t pml4_addr, pdp_addr, pd_addr, pt_addr, start, end;
2257

    
2258
    pml4_addr = env->cr[3] & 0x3fffffffff000ULL;
2259
    last_prot = 0;
2260
    start = -1;
2261
    for (l1 = 0; l1 < 512; l1++) {
2262
        cpu_physical_memory_read(pml4_addr + l1 * 8, &pml4e, 8);
2263
        pml4e = le64_to_cpu(pml4e);
2264
        end = l1 << 39;
2265
        if (pml4e & PG_PRESENT_MASK) {
2266
            pdp_addr = pml4e & 0x3fffffffff000ULL;
2267
            for (l2 = 0; l2 < 512; l2++) {
2268
                cpu_physical_memory_read(pdp_addr + l2 * 8, &pdpe, 8);
2269
                pdpe = le64_to_cpu(pdpe);
2270
                end = (l1 << 39) + (l2 << 30);
2271
                if (pdpe & PG_PRESENT_MASK) {
2272
                    if (pdpe & PG_PSE_MASK) {
2273
                        prot = pdpe & (PG_USER_MASK | PG_RW_MASK |
2274
                                       PG_PRESENT_MASK);
2275
                        prot &= pml4e;
2276
                        mem_print(mon, &start, &last_prot, end, prot);
2277
                    } else {
2278
                        pd_addr = pdpe & 0x3fffffffff000ULL;
2279
                        for (l3 = 0; l3 < 512; l3++) {
2280
                            cpu_physical_memory_read(pd_addr + l3 * 8, &pde, 8);
2281
                            pde = le64_to_cpu(pde);
2282
                            end = (l1 << 39) + (l2 << 30) + (l3 << 21);
2283
                            if (pde & PG_PRESENT_MASK) {
2284
                                if (pde & PG_PSE_MASK) {
2285
                                    prot = pde & (PG_USER_MASK | PG_RW_MASK |
2286
                                                  PG_PRESENT_MASK);
2287
                                    prot &= pml4e & pdpe;
2288
                                    mem_print(mon, &start, &last_prot, end, prot);
2289
                                } else {
2290
                                    pt_addr = pde & 0x3fffffffff000ULL;
2291
                                    for (l4 = 0; l4 < 512; l4++) {
2292
                                        cpu_physical_memory_read(pt_addr
2293
                                                                 + l4 * 8,
2294
                                                                 &pte, 8);
2295
                                        pte = le64_to_cpu(pte);
2296
                                        end = (l1 << 39) + (l2 << 30) +
2297
                                            (l3 << 21) + (l4 << 12);
2298
                                        if (pte & PG_PRESENT_MASK) {
2299
                                            prot = pte & (PG_USER_MASK | PG_RW_MASK |
2300
                                                          PG_PRESENT_MASK);
2301
                                            prot &= pml4e & pdpe & pde;
2302
                                        } else {
2303
                                            prot = 0;
2304
                                        }
2305
                                        mem_print(mon, &start, &last_prot, end, prot);
2306
                                    }
2307
                                }
2308
                            } else {
2309
                                prot = 0;
2310
                                mem_print(mon, &start, &last_prot, end, prot);
2311
                            }
2312
                        }
2313
                    }
2314
                } else {
2315
                    prot = 0;
2316
                    mem_print(mon, &start, &last_prot, end, prot);
2317
                }
2318
            }
2319
        } else {
2320
            prot = 0;
2321
            mem_print(mon, &start, &last_prot, end, prot);
2322
        }
2323
    }
2324
    /* Flush last range */
2325
    mem_print(mon, &start, &last_prot, (target_phys_addr_t)1 << 48, 0);
2326
}
2327
#endif
2328

    
2329
static void mem_info(Monitor *mon)
2330
{
2331
    CPUState *env;
2332

    
2333
    env = mon_get_cpu();
2334

    
2335
    if (!(env->cr[0] & CR0_PG_MASK)) {
2336
        monitor_printf(mon, "PG disabled\n");
2337
        return;
2338
    }
2339
    if (env->cr[4] & CR4_PAE_MASK) {
2340
#ifdef TARGET_X86_64
2341
        if (env->hflags & HF_LMA_MASK) {
2342
            mem_info_64(mon, env);
2343
        } else
2344
#endif
2345
        {
2346
            mem_info_pae32(mon, env);
2347
        }
2348
    } else {
2349
        mem_info_32(mon, env);
2350
    }
2351
}
2352
#endif
2353

    
2354
#if defined(TARGET_SH4)
2355

    
2356
static void print_tlb(Monitor *mon, int idx, tlb_t *tlb)
2357
{
2358
    monitor_printf(mon, " tlb%i:\t"
2359
                   "asid=%hhu vpn=%x\tppn=%x\tsz=%hhu size=%u\t"
2360
                   "v=%hhu shared=%hhu cached=%hhu prot=%hhu "
2361
                   "dirty=%hhu writethrough=%hhu\n",
2362
                   idx,
2363
                   tlb->asid, tlb->vpn, tlb->ppn, tlb->sz, tlb->size,
2364
                   tlb->v, tlb->sh, tlb->c, tlb->pr,
2365
                   tlb->d, tlb->wt);
2366
}
2367

    
2368
static void tlb_info(Monitor *mon)
2369
{
2370
    CPUState *env = mon_get_cpu();
2371
    int i;
2372

    
2373
    monitor_printf (mon, "ITLB:\n");
2374
    for (i = 0 ; i < ITLB_SIZE ; i++)
2375
        print_tlb (mon, i, &env->itlb[i]);
2376
    monitor_printf (mon, "UTLB:\n");
2377
    for (i = 0 ; i < UTLB_SIZE ; i++)
2378
        print_tlb (mon, i, &env->utlb[i]);
2379
}
2380

    
2381
#endif
2382

    
2383
#if defined(TARGET_SPARC) || defined(TARGET_PPC)
2384
static void tlb_info(Monitor *mon)
2385
{
2386
    CPUState *env1 = mon_get_cpu();
2387

    
2388
    dump_mmu((FILE*)mon, (fprintf_function)monitor_printf, env1);
2389
}
2390
#endif
2391

    
2392
static void do_info_mtree(Monitor *mon)
2393
{
2394
    mtree_info((fprintf_function)monitor_printf, mon);
2395
}
2396

    
2397
static void do_info_numa(Monitor *mon)
2398
{
2399
    int i;
2400
    CPUState *env;
2401

    
2402
    monitor_printf(mon, "%d nodes\n", nb_numa_nodes);
2403
    for (i = 0; i < nb_numa_nodes; i++) {
2404
        monitor_printf(mon, "node %d cpus:", i);
2405
        for (env = first_cpu; env != NULL; env = env->next_cpu) {
2406
            if (env->numa_node == i) {
2407
                monitor_printf(mon, " %d", env->cpu_index);
2408
            }
2409
        }
2410
        monitor_printf(mon, "\n");
2411
        monitor_printf(mon, "node %d size: %" PRId64 " MB\n", i,
2412
            node_mem[i] >> 20);
2413
    }
2414
}
2415

    
2416
#ifdef CONFIG_PROFILER
2417

    
2418
int64_t qemu_time;
2419
int64_t dev_time;
2420

    
2421
static void do_info_profile(Monitor *mon)
2422
{
2423
    int64_t total;
2424
    total = qemu_time;
2425
    if (total == 0)
2426
        total = 1;
2427
    monitor_printf(mon, "async time  %" PRId64 " (%0.3f)\n",
2428
                   dev_time, dev_time / (double)get_ticks_per_sec());
2429
    monitor_printf(mon, "qemu time   %" PRId64 " (%0.3f)\n",
2430
                   qemu_time, qemu_time / (double)get_ticks_per_sec());
2431
    qemu_time = 0;
2432
    dev_time = 0;
2433
}
2434
#else
2435
static void do_info_profile(Monitor *mon)
2436
{
2437
    monitor_printf(mon, "Internal profiler not compiled\n");
2438
}
2439
#endif
2440

    
2441
/* Capture support */
2442
static QLIST_HEAD (capture_list_head, CaptureState) capture_head;
2443

    
2444
static void do_info_capture(Monitor *mon)
2445
{
2446
    int i;
2447
    CaptureState *s;
2448

    
2449
    for (s = capture_head.lh_first, i = 0; s; s = s->entries.le_next, ++i) {
2450
        monitor_printf(mon, "[%d]: ", i);
2451
        s->ops.info (s->opaque);
2452
    }
2453
}
2454

    
2455
#ifdef HAS_AUDIO
2456
static void do_stop_capture(Monitor *mon, const QDict *qdict)
2457
{
2458
    int i;
2459
    int n = qdict_get_int(qdict, "n");
2460
    CaptureState *s;
2461

    
2462
    for (s = capture_head.lh_first, i = 0; s; s = s->entries.le_next, ++i) {
2463
        if (i == n) {
2464
            s->ops.destroy (s->opaque);
2465
            QLIST_REMOVE (s, entries);
2466
            g_free (s);
2467
            return;
2468
        }
2469
    }
2470
}
2471

    
2472
static void do_wav_capture(Monitor *mon, const QDict *qdict)
2473
{
2474
    const char *path = qdict_get_str(qdict, "path");
2475
    int has_freq = qdict_haskey(qdict, "freq");
2476
    int freq = qdict_get_try_int(qdict, "freq", -1);
2477
    int has_bits = qdict_haskey(qdict, "bits");
2478
    int bits = qdict_get_try_int(qdict, "bits", -1);
2479
    int has_channels = qdict_haskey(qdict, "nchannels");
2480
    int nchannels = qdict_get_try_int(qdict, "nchannels", -1);
2481
    CaptureState *s;
2482

    
2483
    s = g_malloc0 (sizeof (*s));
2484

    
2485
    freq = has_freq ? freq : 44100;
2486
    bits = has_bits ? bits : 16;
2487
    nchannels = has_channels ? nchannels : 2;
2488

    
2489
    if (wav_start_capture (s, path, freq, bits, nchannels)) {
2490
        monitor_printf(mon, "Failed to add wave capture\n");
2491
        g_free (s);
2492
        return;
2493
    }
2494
    QLIST_INSERT_HEAD (&capture_head, s, entries);
2495
}
2496
#endif
2497

    
2498
#if defined(TARGET_I386)
2499
static int do_inject_nmi(Monitor *mon, const QDict *qdict, QObject **ret_data)
2500
{
2501
    CPUState *env;
2502

    
2503
    for (env = first_cpu; env != NULL; env = env->next_cpu) {
2504
        cpu_interrupt(env, CPU_INTERRUPT_NMI);
2505
    }
2506

    
2507
    return 0;
2508
}
2509
#else
2510
static int do_inject_nmi(Monitor *mon, const QDict *qdict, QObject **ret_data)
2511
{
2512
    qerror_report(QERR_UNSUPPORTED);
2513
    return -1;
2514
}
2515
#endif
2516

    
2517
static qemu_acl *find_acl(Monitor *mon, const char *name)
2518
{
2519
    qemu_acl *acl = qemu_acl_find(name);
2520

    
2521
    if (!acl) {
2522
        monitor_printf(mon, "acl: unknown list '%s'\n", name);
2523
    }
2524
    return acl;
2525
}
2526

    
2527
static void do_acl_show(Monitor *mon, const QDict *qdict)
2528
{
2529
    const char *aclname = qdict_get_str(qdict, "aclname");
2530
    qemu_acl *acl = find_acl(mon, aclname);
2531
    qemu_acl_entry *entry;
2532
    int i = 0;
2533

    
2534
    if (acl) {
2535
        monitor_printf(mon, "policy: %s\n",
2536
                       acl->defaultDeny ? "deny" : "allow");
2537
        QTAILQ_FOREACH(entry, &acl->entries, next) {
2538
            i++;
2539
            monitor_printf(mon, "%d: %s %s\n", i,
2540
                           entry->deny ? "deny" : "allow", entry->match);
2541
        }
2542
    }
2543
}
2544

    
2545
static void do_acl_reset(Monitor *mon, const QDict *qdict)
2546
{
2547
    const char *aclname = qdict_get_str(qdict, "aclname");
2548
    qemu_acl *acl = find_acl(mon, aclname);
2549

    
2550
    if (acl) {
2551
        qemu_acl_reset(acl);
2552
        monitor_printf(mon, "acl: removed all rules\n");
2553
    }
2554
}
2555

    
2556
static void do_acl_policy(Monitor *mon, const QDict *qdict)
2557
{
2558
    const char *aclname = qdict_get_str(qdict, "aclname");
2559
    const char *policy = qdict_get_str(qdict, "policy");
2560
    qemu_acl *acl = find_acl(mon, aclname);
2561

    
2562
    if (acl) {
2563
        if (strcmp(policy, "allow") == 0) {
2564
            acl->defaultDeny = 0;
2565
            monitor_printf(mon, "acl: policy set to 'allow'\n");
2566
        } else if (strcmp(policy, "deny") == 0) {
2567
            acl->defaultDeny = 1;
2568
            monitor_printf(mon, "acl: policy set to 'deny'\n");
2569
        } else {
2570
            monitor_printf(mon, "acl: unknown policy '%s', "
2571
                           "expected 'deny' or 'allow'\n", policy);
2572
        }
2573
    }
2574
}
2575

    
2576
static void do_acl_add(Monitor *mon, const QDict *qdict)
2577
{
2578
    const char *aclname = qdict_get_str(qdict, "aclname");
2579
    const char *match = qdict_get_str(qdict, "match");
2580
    const char *policy = qdict_get_str(qdict, "policy");
2581
    int has_index = qdict_haskey(qdict, "index");
2582
    int index = qdict_get_try_int(qdict, "index", -1);
2583
    qemu_acl *acl = find_acl(mon, aclname);
2584
    int deny, ret;
2585

    
2586
    if (acl) {
2587
        if (strcmp(policy, "allow") == 0) {
2588
            deny = 0;
2589
        } else if (strcmp(policy, "deny") == 0) {
2590
            deny = 1;
2591
        } else {
2592
            monitor_printf(mon, "acl: unknown policy '%s', "
2593
                           "expected 'deny' or 'allow'\n", policy);
2594
            return;
2595
        }
2596
        if (has_index)
2597
            ret = qemu_acl_insert(acl, deny, match, index);
2598
        else
2599
            ret = qemu_acl_append(acl, deny, match);
2600
        if (ret < 0)
2601
            monitor_printf(mon, "acl: unable to add acl entry\n");
2602
        else
2603
            monitor_printf(mon, "acl: added rule at position %d\n", ret);
2604
    }
2605
}
2606

    
2607
static void do_acl_remove(Monitor *mon, const QDict *qdict)
2608
{
2609
    const char *aclname = qdict_get_str(qdict, "aclname");
2610
    const char *match = qdict_get_str(qdict, "match");
2611
    qemu_acl *acl = find_acl(mon, aclname);
2612
    int ret;
2613

    
2614
    if (acl) {
2615
        ret = qemu_acl_remove(acl, match);
2616
        if (ret < 0)
2617
            monitor_printf(mon, "acl: no matching acl entry\n");
2618
        else
2619
            monitor_printf(mon, "acl: removed rule at position %d\n", ret);
2620
    }
2621
}
2622

    
2623
#if defined(TARGET_I386)
2624
static void do_inject_mce(Monitor *mon, const QDict *qdict)
2625
{
2626
    CPUState *cenv;
2627
    int cpu_index = qdict_get_int(qdict, "cpu_index");
2628
    int bank = qdict_get_int(qdict, "bank");
2629
    uint64_t status = qdict_get_int(qdict, "status");
2630
    uint64_t mcg_status = qdict_get_int(qdict, "mcg_status");
2631
    uint64_t addr = qdict_get_int(qdict, "addr");
2632
    uint64_t misc = qdict_get_int(qdict, "misc");
2633
    int flags = MCE_INJECT_UNCOND_AO;
2634

    
2635
    if (qdict_get_try_bool(qdict, "broadcast", 0)) {
2636
        flags |= MCE_INJECT_BROADCAST;
2637
    }
2638
    for (cenv = first_cpu; cenv != NULL; cenv = cenv->next_cpu) {
2639
        if (cenv->cpu_index == cpu_index) {
2640
            cpu_x86_inject_mce(mon, cenv, bank, status, mcg_status, addr, misc,
2641
                               flags);
2642
            break;
2643
        }
2644
    }
2645
}
2646
#endif
2647

    
2648
static int do_getfd(Monitor *mon, const QDict *qdict, QObject **ret_data)
2649
{
2650
    const char *fdname = qdict_get_str(qdict, "fdname");
2651
    mon_fd_t *monfd;
2652
    int fd;
2653

    
2654
    fd = qemu_chr_fe_get_msgfd(mon->chr);
2655
    if (fd == -1) {
2656
        qerror_report(QERR_FD_NOT_SUPPLIED);
2657
        return -1;
2658
    }
2659

    
2660
    if (qemu_isdigit(fdname[0])) {
2661
        qerror_report(QERR_INVALID_PARAMETER_VALUE, "fdname",
2662
                      "a name not starting with a digit");
2663
        return -1;
2664
    }
2665

    
2666
    QLIST_FOREACH(monfd, &mon->fds, next) {
2667
        if (strcmp(monfd->name, fdname) != 0) {
2668
            continue;
2669
        }
2670

    
2671
        close(monfd->fd);
2672
        monfd->fd = fd;
2673
        return 0;
2674
    }
2675

    
2676
    monfd = g_malloc0(sizeof(mon_fd_t));
2677
    monfd->name = g_strdup(fdname);
2678
    monfd->fd = fd;
2679

    
2680
    QLIST_INSERT_HEAD(&mon->fds, monfd, next);
2681
    return 0;
2682
}
2683

    
2684
static int do_closefd(Monitor *mon, const QDict *qdict, QObject **ret_data)
2685
{
2686
    const char *fdname = qdict_get_str(qdict, "fdname");
2687
    mon_fd_t *monfd;
2688

    
2689
    QLIST_FOREACH(monfd, &mon->fds, next) {
2690
        if (strcmp(monfd->name, fdname) != 0) {
2691
            continue;
2692
        }
2693

    
2694
        QLIST_REMOVE(monfd, next);
2695
        close(monfd->fd);
2696
        g_free(monfd->name);
2697
        g_free(monfd);
2698
        return 0;
2699
    }
2700

    
2701
    qerror_report(QERR_FD_NOT_FOUND, fdname);
2702
    return -1;
2703
}
2704

    
2705
static void do_loadvm(Monitor *mon, const QDict *qdict)
2706
{
2707
    int saved_vm_running  = runstate_is_running();
2708
    const char *name = qdict_get_str(qdict, "name");
2709

    
2710
    vm_stop(RUN_STATE_RESTORE_VM);
2711

    
2712
    if (load_vmstate(name) == 0 && saved_vm_running) {
2713
        vm_start();
2714
    }
2715
}
2716

    
2717
int monitor_get_fd(Monitor *mon, const char *fdname)
2718
{
2719
    mon_fd_t *monfd;
2720

    
2721
    QLIST_FOREACH(monfd, &mon->fds, next) {
2722
        int fd;
2723

    
2724
        if (strcmp(monfd->name, fdname) != 0) {
2725
            continue;
2726
        }
2727

    
2728
        fd = monfd->fd;
2729

    
2730
        /* caller takes ownership of fd */
2731
        QLIST_REMOVE(monfd, next);
2732
        g_free(monfd->name);
2733
        g_free(monfd);
2734

    
2735
        return fd;
2736
    }
2737

    
2738
    return -1;
2739
}
2740

    
2741
static const mon_cmd_t mon_cmds[] = {
2742
#include "hmp-commands.h"
2743
    { NULL, NULL, },
2744
};
2745

    
2746
/* Please update hmp-commands.hx when adding or changing commands */
2747
static const mon_cmd_t info_cmds[] = {
2748
    {
2749
        .name       = "version",
2750
        .args_type  = "",
2751
        .params     = "",
2752
        .help       = "show the version of QEMU",
2753
        .mhandler.info = hmp_info_version,
2754
    },
2755
    {
2756
        .name       = "network",
2757
        .args_type  = "",
2758
        .params     = "",
2759
        .help       = "show the network state",
2760
        .mhandler.info = do_info_network,
2761
    },
2762
    {
2763
        .name       = "chardev",
2764
        .args_type  = "",
2765
        .params     = "",
2766
        .help       = "show the character devices",
2767
        .mhandler.info = hmp_info_chardev,
2768
    },
2769
    {
2770
        .name       = "block",
2771
        .args_type  = "",
2772
        .params     = "",
2773
        .help       = "show the block devices",
2774
        .user_print = bdrv_info_print,
2775
        .mhandler.info_new = bdrv_info,
2776
    },
2777
    {
2778
        .name       = "blockstats",
2779
        .args_type  = "",
2780
        .params     = "",
2781
        .help       = "show block device statistics",
2782
        .user_print = bdrv_stats_print,
2783
        .mhandler.info_new = bdrv_info_stats,
2784
    },
2785
    {
2786
        .name       = "registers",
2787
        .args_type  = "",
2788
        .params     = "",
2789
        .help       = "show the cpu registers",
2790
        .mhandler.info = do_info_registers,
2791
    },
2792
    {
2793
        .name       = "cpus",
2794
        .args_type  = "",
2795
        .params     = "",
2796
        .help       = "show infos for each CPU",
2797
        .user_print = monitor_print_cpus,
2798
        .mhandler.info_new = do_info_cpus,
2799
    },
2800
    {
2801
        .name       = "history",
2802
        .args_type  = "",
2803
        .params     = "",
2804
        .help       = "show the command line history",
2805
        .mhandler.info = do_info_history,
2806
    },
2807
#if defined(TARGET_I386) || defined(TARGET_PPC) || defined(TARGET_MIPS) || \
2808
    defined(TARGET_LM32) || (defined(TARGET_SPARC) && !defined(TARGET_SPARC64))
2809
    {
2810
        .name       = "irq",
2811
        .args_type  = "",
2812
        .params     = "",
2813
        .help       = "show the interrupts statistics (if available)",
2814
#ifdef TARGET_SPARC
2815
        .mhandler.info = sun4m_irq_info,
2816
#elif defined(TARGET_LM32)
2817
        .mhandler.info = lm32_irq_info,
2818
#else
2819
        .mhandler.info = irq_info,
2820
#endif
2821
    },
2822
    {
2823
        .name       = "pic",
2824
        .args_type  = "",
2825
        .params     = "",
2826
        .help       = "show i8259 (PIC) state",
2827
#ifdef TARGET_SPARC
2828
        .mhandler.info = sun4m_pic_info,
2829
#elif defined(TARGET_LM32)
2830
        .mhandler.info = lm32_do_pic_info,
2831
#else
2832
        .mhandler.info = pic_info,
2833
#endif
2834
    },
2835
#endif
2836
    {
2837
        .name       = "pci",
2838
        .args_type  = "",
2839
        .params     = "",
2840
        .help       = "show PCI info",
2841
        .user_print = do_pci_info_print,
2842
        .mhandler.info_new = do_pci_info,
2843
    },
2844
#if defined(TARGET_I386) || defined(TARGET_SH4) || defined(TARGET_SPARC) || \
2845
    defined(TARGET_PPC)
2846
    {
2847
        .name       = "tlb",
2848
        .args_type  = "",
2849
        .params     = "",
2850
        .help       = "show virtual to physical memory mappings",
2851
        .mhandler.info = tlb_info,
2852
    },
2853
#endif
2854
#if defined(TARGET_I386)
2855
    {
2856
        .name       = "mem",
2857
        .args_type  = "",
2858
        .params     = "",
2859
        .help       = "show the active virtual memory mappings",
2860
        .mhandler.info = mem_info,
2861
    },
2862
#endif
2863
    {
2864
        .name       = "mtree",
2865
        .args_type  = "",
2866
        .params     = "",
2867
        .help       = "show memory tree",
2868
        .mhandler.info = do_info_mtree,
2869
    },
2870
    {
2871
        .name       = "jit",
2872
        .args_type  = "",
2873
        .params     = "",
2874
        .help       = "show dynamic compiler info",
2875
        .mhandler.info = do_info_jit,
2876
    },
2877
    {
2878
        .name       = "kvm",
2879
        .args_type  = "",
2880
        .params     = "",
2881
        .help       = "show KVM information",
2882
        .mhandler.info = hmp_info_kvm,
2883
    },
2884
    {
2885
        .name       = "numa",
2886
        .args_type  = "",
2887
        .params     = "",
2888
        .help       = "show NUMA information",
2889
        .mhandler.info = do_info_numa,
2890
    },
2891
    {
2892
        .name       = "usb",
2893
        .args_type  = "",
2894
        .params     = "",
2895
        .help       = "show guest USB devices",
2896
        .mhandler.info = usb_info,
2897
    },
2898
    {
2899
        .name       = "usbhost",
2900
        .args_type  = "",
2901
        .params     = "",
2902
        .help       = "show host USB devices",
2903
        .mhandler.info = usb_host_info,
2904
    },
2905
    {
2906
        .name       = "profile",
2907
        .args_type  = "",
2908
        .params     = "",
2909
        .help       = "show profiling information",
2910
        .mhandler.info = do_info_profile,
2911
    },
2912
    {
2913
        .name       = "capture",
2914
        .args_type  = "",
2915
        .params     = "",
2916
        .help       = "show capture information",
2917
        .mhandler.info = do_info_capture,
2918
    },
2919
    {
2920
        .name       = "snapshots",
2921
        .args_type  = "",
2922
        .params     = "",
2923
        .help       = "show the currently saved VM snapshots",
2924
        .mhandler.info = do_info_snapshots,
2925
    },
2926
    {
2927
        .name       = "status",
2928
        .args_type  = "",
2929
        .params     = "",
2930
        .help       = "show the current VM status (running|paused)",
2931
        .mhandler.info = hmp_info_status,
2932
    },
2933
    {
2934
        .name       = "pcmcia",
2935
        .args_type  = "",
2936
        .params     = "",
2937
        .help       = "show guest PCMCIA status",
2938
        .mhandler.info = pcmcia_info,
2939
    },
2940
    {
2941
        .name       = "mice",
2942
        .args_type  = "",
2943
        .params     = "",
2944
        .help       = "show which guest mouse is receiving events",
2945
        .user_print = do_info_mice_print,
2946
        .mhandler.info_new = do_info_mice,
2947
    },
2948
    {
2949
        .name       = "vnc",
2950
        .args_type  = "",
2951
        .params     = "",
2952
        .help       = "show the vnc server status",
2953
        .user_print = do_info_vnc_print,
2954
        .mhandler.info_new = do_info_vnc,
2955
    },
2956
#if defined(CONFIG_SPICE)
2957
    {
2958
        .name       = "spice",
2959
        .args_type  = "",
2960
        .params     = "",
2961
        .help       = "show the spice server status",
2962
        .user_print = do_info_spice_print,
2963
        .mhandler.info_new = do_info_spice,
2964
    },
2965
#endif
2966
    {
2967
        .name       = "name",
2968
        .args_type  = "",
2969
        .params     = "",
2970
        .help       = "show the current VM name",
2971
        .mhandler.info = hmp_info_name,
2972
    },
2973
    {
2974
        .name       = "uuid",
2975
        .args_type  = "",
2976
        .params     = "",
2977
        .help       = "show the current VM UUID",
2978
        .mhandler.info = hmp_info_uuid,
2979
    },
2980
#if defined(TARGET_PPC)
2981
    {
2982
        .name       = "cpustats",
2983
        .args_type  = "",
2984
        .params     = "",
2985
        .help       = "show CPU statistics",
2986
        .mhandler.info = do_info_cpu_stats,
2987
    },
2988
#endif
2989
#if defined(CONFIG_SLIRP)
2990
    {
2991
        .name       = "usernet",
2992
        .args_type  = "",
2993
        .params     = "",
2994
        .help       = "show user network stack connection states",
2995
        .mhandler.info = do_info_usernet,
2996
    },
2997
#endif
2998
    {
2999
        .name       = "migrate",
3000
        .args_type  = "",
3001
        .params     = "",
3002
        .help       = "show migration status",
3003
        .user_print = do_info_migrate_print,
3004
        .mhandler.info_new = do_info_migrate,
3005
    },
3006
    {
3007
        .name       = "balloon",
3008
        .args_type  = "",
3009
        .params     = "",
3010
        .help       = "show balloon information",
3011
        .user_print = monitor_print_balloon,
3012
        .mhandler.info_async = do_info_balloon,
3013
        .flags      = MONITOR_CMD_ASYNC,
3014
    },
3015
    {
3016
        .name       = "qtree",
3017
        .args_type  = "",
3018
        .params     = "",
3019
        .help       = "show device tree",
3020
        .mhandler.info = do_info_qtree,
3021
    },
3022
    {
3023
        .name       = "qdm",
3024
        .args_type  = "",
3025
        .params     = "",
3026
        .help       = "show qdev device model list",
3027
        .mhandler.info = do_info_qdm,
3028
    },
3029
    {
3030
        .name       = "roms",
3031
        .args_type  = "",
3032
        .params     = "",
3033
        .help       = "show roms",
3034
        .mhandler.info = do_info_roms,
3035
    },
3036
#if defined(CONFIG_TRACE_SIMPLE)
3037
    {
3038
        .name       = "trace",
3039
        .args_type  = "",
3040
        .params     = "",
3041
        .help       = "show current contents of trace buffer",
3042
        .mhandler.info = do_info_trace,
3043
    },
3044
#endif
3045
    {
3046
        .name       = "trace-events",
3047
        .args_type  = "",
3048
        .params     = "",
3049
        .help       = "show available trace-events & their state",
3050
        .mhandler.info = do_trace_print_events,
3051
    },
3052
    {
3053
        .name       = NULL,
3054
    },
3055
};
3056

    
3057
static const mon_cmd_t qmp_cmds[] = {
3058
#include "qmp-commands-old.h"
3059
    { /* NULL */ },
3060
};
3061

    
3062
static const mon_cmd_t qmp_query_cmds[] = {
3063
    {
3064
        .name       = "block",
3065
        .args_type  = "",
3066
        .params     = "",
3067
        .help       = "show the block devices",
3068
        .user_print = bdrv_info_print,
3069
        .mhandler.info_new = bdrv_info,
3070
    },
3071
    {
3072
        .name       = "blockstats",
3073
        .args_type  = "",
3074
        .params     = "",
3075
        .help       = "show block device statistics",
3076
        .user_print = bdrv_stats_print,
3077
        .mhandler.info_new = bdrv_info_stats,
3078
    },
3079
    {
3080
        .name       = "cpus",
3081
        .args_type  = "",
3082
        .params     = "",
3083
        .help       = "show infos for each CPU",
3084
        .user_print = monitor_print_cpus,
3085
        .mhandler.info_new = do_info_cpus,
3086
    },
3087
    {
3088
        .name       = "pci",
3089
        .args_type  = "",
3090
        .params     = "",
3091
        .help       = "show PCI info",
3092
        .user_print = do_pci_info_print,
3093
        .mhandler.info_new = do_pci_info,
3094
    },
3095
    {
3096
        .name       = "mice",
3097
        .args_type  = "",
3098
        .params     = "",
3099
        .help       = "show which guest mouse is receiving events",
3100
        .user_print = do_info_mice_print,
3101
        .mhandler.info_new = do_info_mice,
3102
    },
3103
    {
3104
        .name       = "vnc",
3105
        .args_type  = "",
3106
        .params     = "",
3107
        .help       = "show the vnc server status",
3108
        .user_print = do_info_vnc_print,
3109
        .mhandler.info_new = do_info_vnc,
3110
    },
3111
#if defined(CONFIG_SPICE)
3112
    {
3113
        .name       = "spice",
3114
        .args_type  = "",
3115
        .params     = "",
3116
        .help       = "show the spice server status",
3117
        .user_print = do_info_spice_print,
3118
        .mhandler.info_new = do_info_spice,
3119
    },
3120
#endif
3121
    {
3122
        .name       = "migrate",
3123
        .args_type  = "",
3124
        .params     = "",
3125
        .help       = "show migration status",
3126
        .user_print = do_info_migrate_print,
3127
        .mhandler.info_new = do_info_migrate,
3128
    },
3129
    {
3130
        .name       = "balloon",
3131
        .args_type  = "",
3132
        .params     = "",
3133
        .help       = "show balloon information",
3134
        .user_print = monitor_print_balloon,
3135
        .mhandler.info_async = do_info_balloon,
3136
        .flags      = MONITOR_CMD_ASYNC,
3137
    },
3138
    { /* NULL */ },
3139
};
3140

    
3141
/*******************************************************************/
3142

    
3143
static const char *pch;
3144
static jmp_buf expr_env;
3145

    
3146
#define MD_TLONG 0
3147
#define MD_I32   1
3148

    
3149
typedef struct MonitorDef {
3150
    const char *name;
3151
    int offset;
3152
    target_long (*get_value)(const struct MonitorDef *md, int val);
3153
    int type;
3154
} MonitorDef;
3155

    
3156
#if defined(TARGET_I386)
3157
static target_long monitor_get_pc (const struct MonitorDef *md, int val)
3158
{
3159
    CPUState *env = mon_get_cpu();
3160
    return env->eip + env->segs[R_CS].base;
3161
}
3162
#endif
3163

    
3164
#if defined(TARGET_PPC)
3165
static target_long monitor_get_ccr (const struct MonitorDef *md, int val)
3166
{
3167
    CPUState *env = mon_get_cpu();
3168
    unsigned int u;
3169
    int i;
3170

    
3171
    u = 0;
3172
    for (i = 0; i < 8; i++)
3173
        u |= env->crf[i] << (32 - (4 * i));
3174

    
3175
    return u;
3176
}
3177

    
3178
static target_long monitor_get_msr (const struct MonitorDef *md, int val)
3179
{
3180
    CPUState *env = mon_get_cpu();
3181
    return env->msr;
3182
}
3183

    
3184
static target_long monitor_get_xer (const struct MonitorDef *md, int val)
3185
{
3186
    CPUState *env = mon_get_cpu();
3187
    return env->xer;
3188
}
3189

    
3190
static target_long monitor_get_decr (const struct MonitorDef *md, int val)
3191
{
3192
    CPUState *env = mon_get_cpu();
3193
    return cpu_ppc_load_decr(env);
3194
}
3195

    
3196
static target_long monitor_get_tbu (const struct MonitorDef *md, int val)
3197
{
3198
    CPUState *env = mon_get_cpu();
3199
    return cpu_ppc_load_tbu(env);
3200
}
3201

    
3202
static target_long monitor_get_tbl (const struct MonitorDef *md, int val)
3203
{
3204
    CPUState *env = mon_get_cpu();
3205
    return cpu_ppc_load_tbl(env);
3206
}
3207
#endif
3208

    
3209
#if defined(TARGET_SPARC)
3210
#ifndef TARGET_SPARC64
3211
static target_long monitor_get_psr (const struct MonitorDef *md, int val)
3212
{
3213
    CPUState *env = mon_get_cpu();
3214

    
3215
    return cpu_get_psr(env);
3216
}
3217
#endif
3218

    
3219
static target_long monitor_get_reg(const struct MonitorDef *md, int val)
3220
{
3221
    CPUState *env = mon_get_cpu();
3222
    return env->regwptr[val];
3223
}
3224
#endif
3225

    
3226
static const MonitorDef monitor_defs[] = {
3227
#ifdef TARGET_I386
3228

    
3229
#define SEG(name, seg) \
3230
    { name, offsetof(CPUState, segs[seg].selector), NULL, MD_I32 },\
3231
    { name ".base", offsetof(CPUState, segs[seg].base) },\
3232
    { name ".limit", offsetof(CPUState, segs[seg].limit), NULL, MD_I32 },
3233

    
3234
    { "eax", offsetof(CPUState, regs[0]) },
3235
    { "ecx", offsetof(CPUState, regs[1]) },
3236
    { "edx", offsetof(CPUState, regs[2]) },
3237
    { "ebx", offsetof(CPUState, regs[3]) },
3238
    { "esp|sp", offsetof(CPUState, regs[4]) },
3239
    { "ebp|fp", offsetof(CPUState, regs[5]) },
3240
    { "esi", offsetof(CPUState, regs[6]) },
3241
    { "edi", offsetof(CPUState, regs[7]) },
3242
#ifdef TARGET_X86_64
3243
    { "r8", offsetof(CPUState, regs[8]) },
3244
    { "r9", offsetof(CPUState, regs[9]) },
3245
    { "r10", offsetof(CPUState, regs[10]) },
3246
    { "r11", offsetof(CPUState, regs[11]) },
3247
    { "r12", offsetof(CPUState, regs[12]) },
3248
    { "r13", offsetof(CPUState, regs[13]) },
3249
    { "r14", offsetof(CPUState, regs[14]) },
3250
    { "r15", offsetof(CPUState, regs[15]) },
3251
#endif
3252
    { "eflags", offsetof(CPUState, eflags) },
3253
    { "eip", offsetof(CPUState, eip) },
3254
    SEG("cs", R_CS)
3255
    SEG("ds", R_DS)
3256
    SEG("es", R_ES)
3257
    SEG("ss", R_SS)
3258
    SEG("fs", R_FS)
3259
    SEG("gs", R_GS)
3260
    { "pc", 0, monitor_get_pc, },
3261
#elif defined(TARGET_PPC)
3262
    /* General purpose registers */
3263
    { "r0", offsetof(CPUState, gpr[0]) },
3264
    { "r1", offsetof(CPUState, gpr[1]) },
3265
    { "r2", offsetof(CPUState, gpr[2]) },
3266
    { "r3", offsetof(CPUState, gpr[3]) },
3267
    { "r4", offsetof(CPUState, gpr[4]) },
3268
    { "r5", offsetof(CPUState, gpr[5]) },
3269
    { "r6", offsetof(CPUState, gpr[6]) },
3270
    { "r7", offsetof(CPUState, gpr[7]) },
3271
    { "r8", offsetof(CPUState, gpr[8]) },
3272
    { "r9", offsetof(CPUState, gpr[9]) },
3273
    { "r10", offsetof(CPUState, gpr[10]) },
3274
    { "r11", offsetof(CPUState, gpr[11]) },
3275
    { "r12", offsetof(CPUState, gpr[12]) },
3276
    { "r13", offsetof(CPUState, gpr[13]) },
3277
    { "r14", offsetof(CPUState, gpr[14]) },
3278
    { "r15", offsetof(CPUState, gpr[15]) },
3279
    { "r16", offsetof(CPUState, gpr[16]) },
3280
    { "r17", offsetof(CPUState, gpr[17]) },
3281
    { "r18", offsetof(CPUState, gpr[18]) },
3282
    { "r19", offsetof(CPUState, gpr[19]) },
3283
    { "r20", offsetof(CPUState, gpr[20]) },
3284
    { "r21", offsetof(CPUState, gpr[21]) },
3285
    { "r22", offsetof(CPUState, gpr[22]) },
3286
    { "r23", offsetof(CPUState, gpr[23]) },
3287
    { "r24", offsetof(CPUState, gpr[24]) },
3288
    { "r25", offsetof(CPUState, gpr[25]) },
3289
    { "r26", offsetof(CPUState, gpr[26]) },
3290
    { "r27", offsetof(CPUState, gpr[27]) },
3291
    { "r28", offsetof(CPUState, gpr[28]) },
3292
    { "r29", offsetof(CPUState, gpr[29]) },
3293
    { "r30", offsetof(CPUState, gpr[30]) },
3294
    { "r31", offsetof(CPUState, gpr[31]) },
3295
    /* Floating point registers */
3296
    { "f0", offsetof(CPUState, fpr[0]) },
3297
    { "f1", offsetof(CPUState, fpr[1]) },
3298
    { "f2", offsetof(CPUState, fpr[2]) },
3299
    { "f3", offsetof(CPUState, fpr[3]) },
3300
    { "f4", offsetof(CPUState, fpr[4]) },
3301
    { "f5", offsetof(CPUState, fpr[5]) },
3302
    { "f6", offsetof(CPUState, fpr[6]) },
3303
    { "f7", offsetof(CPUState, fpr[7]) },
3304
    { "f8", offsetof(CPUState, fpr[8]) },
3305
    { "f9", offsetof(CPUState, fpr[9]) },
3306
    { "f10", offsetof(CPUState, fpr[10]) },
3307
    { "f11", offsetof(CPUState, fpr[11]) },
3308
    { "f12", offsetof(CPUState, fpr[12]) },
3309
    { "f13", offsetof(CPUState, fpr[13]) },
3310
    { "f14", offsetof(CPUState, fpr[14]) },
3311
    { "f15", offsetof(CPUState, fpr[15]) },
3312
    { "f16", offsetof(CPUState, fpr[16]) },
3313
    { "f17", offsetof(CPUState, fpr[17]) },
3314
    { "f18", offsetof(CPUState, fpr[18]) },
3315
    { "f19", offsetof(CPUState, fpr[19]) },
3316
    { "f20", offsetof(CPUState, fpr[20]) },
3317
    { "f21", offsetof(CPUState, fpr[21]) },
3318
    { "f22", offsetof(CPUState, fpr[22]) },
3319
    { "f23", offsetof(CPUState, fpr[23]) },
3320
    { "f24", offsetof(CPUState, fpr[24]) },
3321
    { "f25", offsetof(CPUState, fpr[25]) },
3322
    { "f26", offsetof(CPUState, fpr[26]) },
3323
    { "f27", offsetof(CPUState, fpr[27]) },
3324
    { "f28", offsetof(CPUState, fpr[28]) },
3325
    { "f29", offsetof(CPUState, fpr[29]) },
3326
    { "f30", offsetof(CPUState, fpr[30]) },
3327
    { "f31", offsetof(CPUState, fpr[31]) },
3328
    { "fpscr", offsetof(CPUState, fpscr) },
3329
    /* Next instruction pointer */
3330
    { "nip|pc", offsetof(CPUState, nip) },
3331
    { "lr", offsetof(CPUState, lr) },
3332
    { "ctr", offsetof(CPUState, ctr) },
3333
    { "decr", 0, &monitor_get_decr, },
3334
    { "ccr", 0, &monitor_get_ccr, },
3335
    /* Machine state register */
3336
    { "msr", 0, &monitor_get_msr, },
3337
    { "xer", 0, &monitor_get_xer, },
3338
    { "tbu", 0, &monitor_get_tbu, },
3339
    { "tbl", 0, &monitor_get_tbl, },
3340
#if defined(TARGET_PPC64)
3341
    /* Address space register */
3342
    { "asr", offsetof(CPUState, asr) },
3343
#endif
3344
    /* Segment registers */
3345
    { "sdr1", offsetof(CPUState, spr[SPR_SDR1]) },
3346
    { "sr0", offsetof(CPUState, sr[0]) },
3347
    { "sr1", offsetof(CPUState, sr[1]) },
3348
    { "sr2", offsetof(CPUState, sr[2]) },
3349
    { "sr3", offsetof(CPUState, sr[3]) },
3350
    { "sr4", offsetof(CPUState, sr[4]) },
3351
    { "sr5", offsetof(CPUState, sr[5]) },
3352
    { "sr6", offsetof(CPUState, sr[6]) },
3353
    { "sr7", offsetof(CPUState, sr[7]) },
3354
    { "sr8", offsetof(CPUState, sr[8]) },
3355
    { "sr9", offsetof(CPUState, sr[9]) },
3356
    { "sr10", offsetof(CPUState, sr[10]) },
3357
    { "sr11", offsetof(CPUState, sr[11]) },
3358
    { "sr12", offsetof(CPUState, sr[12]) },
3359
    { "sr13", offsetof(CPUState, sr[13]) },
3360
    { "sr14", offsetof(CPUState, sr[14]) },
3361
    { "sr15", offsetof(CPUState, sr[15]) },
3362
    /* Too lazy to put BATs... */
3363
    { "pvr", offsetof(CPUState, spr[SPR_PVR]) },
3364

    
3365
    { "srr0", offsetof(CPUState, spr[SPR_SRR0]) },
3366
    { "srr1", offsetof(CPUState, spr[SPR_SRR1]) },
3367
    { "sprg0", offsetof(CPUState, spr[SPR_SPRG0]) },
3368
    { "sprg1", offsetof(CPUState, spr[SPR_SPRG1]) },
3369
    { "sprg2", offsetof(CPUState, spr[SPR_SPRG2]) },
3370
    { "sprg3", offsetof(CPUState, spr[SPR_SPRG3]) },
3371
    { "sprg4", offsetof(CPUState, spr[SPR_SPRG4]) },
3372
    { "sprg5", offsetof(CPUState, spr[SPR_SPRG5]) },
3373
    { "sprg6", offsetof(CPUState, spr[SPR_SPRG6]) },
3374
    { "sprg7", offsetof(CPUState, spr[SPR_SPRG7]) },
3375
    { "pid", offsetof(CPUState, spr[SPR_BOOKE_PID]) },
3376
    { "csrr0", offsetof(CPUState, spr[SPR_BOOKE_CSRR0]) },
3377
    { "csrr1", offsetof(CPUState, spr[SPR_BOOKE_CSRR1]) },
3378
    { "esr", offsetof(CPUState, spr[SPR_BOOKE_ESR]) },
3379
    { "dear", offsetof(CPUState, spr[SPR_BOOKE_DEAR]) },
3380
    { "mcsr", offsetof(CPUState, spr[SPR_BOOKE_MCSR]) },
3381
    { "tsr", offsetof(CPUState, spr[SPR_BOOKE_TSR]) },
3382
    { "tcr", offsetof(CPUState, spr[SPR_BOOKE_TCR]) },
3383
    { "vrsave", offsetof(CPUState, spr[SPR_VRSAVE]) },
3384
    { "pir", offsetof(CPUState, spr[SPR_BOOKE_PIR]) },
3385
    { "mcsrr0", offsetof(CPUState, spr[SPR_BOOKE_MCSRR0]) },
3386
    { "mcsrr1", offsetof(CPUState, spr[SPR_BOOKE_MCSRR1]) },
3387
    { "decar", offsetof(CPUState, spr[SPR_BOOKE_DECAR]) },
3388
    { "ivpr", offsetof(CPUState, spr[SPR_BOOKE_IVPR]) },
3389
    { "epcr", offsetof(CPUState, spr[SPR_BOOKE_EPCR]) },
3390
    { "sprg8", offsetof(CPUState, spr[SPR_BOOKE_SPRG8]) },
3391
    { "ivor0", offsetof(CPUState, spr[SPR_BOOKE_IVOR0]) },
3392
    { "ivor1", offsetof(CPUState, spr[SPR_BOOKE_IVOR1]) },
3393
    { "ivor2", offsetof(CPUState, spr[SPR_BOOKE_IVOR2]) },
3394
    { "ivor3", offsetof(CPUState, spr[SPR_BOOKE_IVOR3]) },
3395
    { "ivor4", offsetof(CPUState, spr[SPR_BOOKE_IVOR4]) },
3396
    { "ivor5", offsetof(CPUState, spr[SPR_BOOKE_IVOR5]) },
3397
    { "ivor6", offsetof(CPUState, spr[SPR_BOOKE_IVOR6]) },
3398
    { "ivor7", offsetof(CPUState, spr[SPR_BOOKE_IVOR7]) },
3399
    { "ivor8", offsetof(CPUState, spr[SPR_BOOKE_IVOR8]) },
3400
    { "ivor9", offsetof(CPUState, spr[SPR_BOOKE_IVOR9]) },
3401
    { "ivor10", offsetof(CPUState, spr[SPR_BOOKE_IVOR10]) },
3402
    { "ivor11", offsetof(CPUState, spr[SPR_BOOKE_IVOR11]) },
3403
    { "ivor12", offsetof(CPUState, spr[SPR_BOOKE_IVOR12]) },
3404
    { "ivor13", offsetof(CPUState, spr[SPR_BOOKE_IVOR13]) },
3405
    { "ivor14", offsetof(CPUState, spr[SPR_BOOKE_IVOR14]) },
3406
    { "ivor15", offsetof(CPUState, spr[SPR_BOOKE_IVOR15]) },
3407
    { "ivor32", offsetof(CPUState, spr[SPR_BOOKE_IVOR32]) },
3408
    { "ivor33", offsetof(CPUState, spr[SPR_BOOKE_IVOR33]) },
3409
    { "ivor34", offsetof(CPUState, spr[SPR_BOOKE_IVOR34]) },
3410
    { "ivor35", offsetof(CPUState, spr[SPR_BOOKE_IVOR35]) },
3411
    { "ivor36", offsetof(CPUState, spr[SPR_BOOKE_IVOR36]) },
3412
    { "ivor37", offsetof(CPUState, spr[SPR_BOOKE_IVOR37]) },
3413
    { "mas0", offsetof(CPUState, spr[SPR_BOOKE_MAS0]) },
3414
    { "mas1", offsetof(CPUState, spr[SPR_BOOKE_MAS1]) },
3415
    { "mas2", offsetof(CPUState, spr[SPR_BOOKE_MAS2]) },
3416
    { "mas3", offsetof(CPUState, spr[SPR_BOOKE_MAS3]) },
3417
    { "mas4", offsetof(CPUState, spr[SPR_BOOKE_MAS4]) },
3418
    { "mas6", offsetof(CPUState, spr[SPR_BOOKE_MAS6]) },
3419
    { "mas7", offsetof(CPUState, spr[SPR_BOOKE_MAS7]) },
3420
    { "mmucfg", offsetof(CPUState, spr[SPR_MMUCFG]) },
3421
    { "tlb0cfg", offsetof(CPUState, spr[SPR_BOOKE_TLB0CFG]) },
3422
    { "tlb1cfg", offsetof(CPUState, spr[SPR_BOOKE_TLB1CFG]) },
3423
    { "epr", offsetof(CPUState, spr[SPR_BOOKE_EPR]) },
3424
    { "eplc", offsetof(CPUState, spr[SPR_BOOKE_EPLC]) },
3425
    { "epsc", offsetof(CPUState, spr[SPR_BOOKE_EPSC]) },
3426
    { "svr", offsetof(CPUState, spr[SPR_E500_SVR]) },
3427
    { "mcar", offsetof(CPUState, spr[SPR_Exxx_MCAR]) },
3428
    { "pid1", offsetof(CPUState, spr[SPR_BOOKE_PID1]) },
3429
    { "pid2", offsetof(CPUState, spr[SPR_BOOKE_PID2]) },
3430
    { "hid0", offsetof(CPUState, spr[SPR_HID0]) },
3431

    
3432
#elif defined(TARGET_SPARC)
3433
    { "g0", offsetof(CPUState, gregs[0]) },
3434
    { "g1", offsetof(CPUState, gregs[1]) },
3435
    { "g2", offsetof(CPUState, gregs[2]) },
3436
    { "g3", offsetof(CPUState, gregs[3]) },
3437
    { "g4", offsetof(CPUState, gregs[4]) },
3438
    { "g5", offsetof(CPUState, gregs[5]) },
3439
    { "g6", offsetof(CPUState, gregs[6]) },
3440
    { "g7", offsetof(CPUState, gregs[7]) },
3441
    { "o0", 0, monitor_get_reg },
3442
    { "o1", 1, monitor_get_reg },
3443
    { "o2", 2, monitor_get_reg },
3444
    { "o3", 3, monitor_get_reg },
3445
    { "o4", 4, monitor_get_reg },
3446
    { "o5", 5, monitor_get_reg },
3447
    { "o6", 6, monitor_get_reg },
3448
    { "o7", 7, monitor_get_reg },
3449
    { "l0", 8, monitor_get_reg },
3450
    { "l1", 9, monitor_get_reg },
3451
    { "l2", 10, monitor_get_reg },
3452
    { "l3", 11, monitor_get_reg },
3453
    { "l4", 12, monitor_get_reg },
3454
    { "l5", 13, monitor_get_reg },
3455
    { "l6", 14, monitor_get_reg },
3456
    { "l7", 15, monitor_get_reg },
3457
    { "i0", 16, monitor_get_reg },
3458
    { "i1", 17, monitor_get_reg },
3459
    { "i2", 18, monitor_get_reg },
3460
    { "i3", 19, monitor_get_reg },
3461
    { "i4", 20, monitor_get_reg },
3462
    { "i5", 21, monitor_get_reg },
3463
    { "i6", 22, monitor_get_reg },
3464
    { "i7", 23, monitor_get_reg },
3465
    { "pc", offsetof(CPUState, pc) },
3466
    { "npc", offsetof(CPUState, npc) },
3467
    { "y", offsetof(CPUState, y) },
3468
#ifndef TARGET_SPARC64
3469
    { "psr", 0, &monitor_get_psr, },
3470
    { "wim", offsetof(CPUState, wim) },
3471
#endif
3472
    { "tbr", offsetof(CPUState, tbr) },
3473
    { "fsr", offsetof(CPUState, fsr) },
3474
    { "f0", offsetof(CPUState, fpr[0]) },
3475
    { "f1", offsetof(CPUState, fpr[1]) },
3476
    { "f2", offsetof(CPUState, fpr[2]) },
3477
    { "f3", offsetof(CPUState, fpr[3]) },
3478
    { "f4", offsetof(CPUState, fpr[4]) },
3479
    { "f5", offsetof(CPUState, fpr[5]) },
3480
    { "f6", offsetof(CPUState, fpr[6]) },
3481
    { "f7", offsetof(CPUState, fpr[7]) },
3482
    { "f8", offsetof(CPUState, fpr[8]) },
3483
    { "f9", offsetof(CPUState, fpr[9]) },
3484
    { "f10", offsetof(CPUState, fpr[10]) },
3485
    { "f11", offsetof(CPUState, fpr[11]) },
3486
    { "f12", offsetof(CPUState, fpr[12]) },
3487
    { "f13", offsetof(CPUState, fpr[13]) },
3488
    { "f14", offsetof(CPUState, fpr[14]) },
3489
    { "f15", offsetof(CPUState, fpr[15]) },
3490
    { "f16", offsetof(CPUState, fpr[16]) },
3491
    { "f17", offsetof(CPUState, fpr[17]) },
3492
    { "f18", offsetof(CPUState, fpr[18]) },
3493
    { "f19", offsetof(CPUState, fpr[19]) },
3494
    { "f20", offsetof(CPUState, fpr[20]) },
3495
    { "f21", offsetof(CPUState, fpr[21]) },
3496
    { "f22", offsetof(CPUState, fpr[22]) },
3497
    { "f23", offsetof(CPUState, fpr[23]) },
3498
    { "f24", offsetof(CPUState, fpr[24]) },
3499
    { "f25", offsetof(CPUState, fpr[25]) },
3500
    { "f26", offsetof(CPUState, fpr[26]) },
3501
    { "f27", offsetof(CPUState, fpr[27]) },
3502
    { "f28", offsetof(CPUState, fpr[28]) },
3503
    { "f29", offsetof(CPUState, fpr[29]) },
3504
    { "f30", offsetof(CPUState, fpr[30]) },
3505
    { "f31", offsetof(CPUState, fpr[31]) },
3506
#ifdef TARGET_SPARC64
3507
    { "f32", offsetof(CPUState, fpr[32]) },
3508
    { "f34", offsetof(CPUState, fpr[34]) },
3509
    { "f36", offsetof(CPUState, fpr[36]) },
3510
    { "f38", offsetof(CPUState, fpr[38]) },
3511
    { "f40", offsetof(CPUState, fpr[40]) },
3512
    { "f42", offsetof(CPUState, fpr[42]) },
3513
    { "f44", offsetof(CPUState, fpr[44]) },
3514
    { "f46", offsetof(CPUState, fpr[46]) },
3515
    { "f48", offsetof(CPUState, fpr[48]) },
3516
    { "f50", offsetof(CPUState, fpr[50]) },
3517
    { "f52", offsetof(CPUState, fpr[52]) },
3518
    { "f54", offsetof(CPUState, fpr[54]) },
3519
    { "f56", offsetof(CPUState, fpr[56]) },
3520
    { "f58", offsetof(CPUState, fpr[58]) },
3521
    { "f60", offsetof(CPUState, fpr[60]) },
3522
    { "f62", offsetof(CPUState, fpr[62]) },
3523
    { "asi", offsetof(CPUState, asi) },
3524
    { "pstate", offsetof(CPUState, pstate) },
3525
    { "cansave", offsetof(CPUState, cansave) },
3526
    { "canrestore", offsetof(CPUState, canrestore) },
3527
    { "otherwin", offsetof(CPUState, otherwin) },
3528
    { "wstate", offsetof(CPUState, wstate) },
3529
    { "cleanwin", offsetof(CPUState, cleanwin) },
3530
    { "fprs", offsetof(CPUState, fprs) },
3531
#endif
3532
#endif
3533
    { NULL },
3534
};
3535

    
3536
static void expr_error(Monitor *mon, const char *msg)
3537
{
3538
    monitor_printf(mon, "%s\n", msg);
3539
    longjmp(expr_env, 1);
3540
}
3541

    
3542
/* return 0 if OK, -1 if not found */
3543
static int get_monitor_def(target_long *pval, const char *name)
3544
{
3545
    const MonitorDef *md;
3546
    void *ptr;
3547

    
3548
    for(md = monitor_defs; md->name != NULL; md++) {
3549
        if (compare_cmd(name, md->name)) {
3550
            if (md->get_value) {
3551
                *pval = md->get_value(md, md->offset);
3552
            } else {
3553
                CPUState *env = mon_get_cpu();
3554
                ptr = (uint8_t *)env + md->offset;
3555
                switch(md->type) {
3556
                case MD_I32:
3557
                    *pval = *(int32_t *)ptr;
3558
                    break;
3559
                case MD_TLONG:
3560
                    *pval = *(target_long *)ptr;
3561
                    break;
3562
                default:
3563
                    *pval = 0;
3564
                    break;
3565
                }
3566
            }
3567
            return 0;
3568
        }
3569
    }
3570
    return -1;
3571
}
3572

    
3573
static void next(void)
3574
{
3575
    if (*pch != '\0') {
3576
        pch++;
3577
        while (qemu_isspace(*pch))
3578
            pch++;
3579
    }
3580
}
3581

    
3582
static int64_t expr_sum(Monitor *mon);
3583

    
3584
static int64_t expr_unary(Monitor *mon)
3585
{
3586
    int64_t n;
3587
    char *p;
3588
    int ret;
3589

    
3590
    switch(*pch) {
3591
    case '+':
3592
        next();
3593
        n = expr_unary(mon);
3594
        break;
3595
    case '-':
3596
        next();
3597
        n = -expr_unary(mon);
3598
        break;
3599
    case '~':
3600
        next();
3601
        n = ~expr_unary(mon);
3602
        break;
3603
    case '(':
3604
        next();
3605
        n = expr_sum(mon);
3606
        if (*pch != ')') {
3607
            expr_error(mon, "')' expected");
3608
        }
3609
        next();
3610
        break;
3611
    case '\'':
3612
        pch++;
3613
        if (*pch == '\0')
3614
            expr_error(mon, "character constant expected");
3615
        n = *pch;
3616
        pch++;
3617
        if (*pch != '\'')
3618
            expr_error(mon, "missing terminating \' character");
3619
        next();
3620
        break;
3621
    case '$':
3622
        {
3623
            char buf[128], *q;
3624
            target_long reg=0;
3625

    
3626
            pch++;
3627
            q = buf;
3628
            while ((*pch >= 'a' && *pch <= 'z') ||
3629
                   (*pch >= 'A' && *pch <= 'Z') ||
3630
                   (*pch >= '0' && *pch <= '9') ||
3631
                   *pch == '_' || *pch == '.') {
3632
                if ((q - buf) < sizeof(buf) - 1)
3633
                    *q++ = *pch;
3634
                pch++;
3635
            }
3636
            while (qemu_isspace(*pch))
3637
                pch++;
3638
            *q = 0;
3639
            ret = get_monitor_def(&reg, buf);
3640
            if (ret < 0)
3641
                expr_error(mon, "unknown register");
3642
            n = reg;
3643
        }
3644
        break;
3645
    case '\0':
3646
        expr_error(mon, "unexpected end of expression");
3647
        n = 0;
3648
        break;
3649
    default:
3650
#if TARGET_PHYS_ADDR_BITS > 32
3651
        n = strtoull(pch, &p, 0);
3652
#else
3653
        n = strtoul(pch, &p, 0);
3654
#endif
3655
        if (pch == p) {
3656
            expr_error(mon, "invalid char in expression");
3657
        }
3658
        pch = p;
3659
        while (qemu_isspace(*pch))
3660
            pch++;
3661
        break;
3662
    }
3663
    return n;
3664
}
3665

    
3666

    
3667
static int64_t expr_prod(Monitor *mon)
3668
{
3669
    int64_t val, val2;
3670
    int op;
3671

    
3672
    val = expr_unary(mon);
3673
    for(;;) {
3674
        op = *pch;
3675
        if (op != '*' && op != '/' && op != '%')
3676
            break;
3677
        next();
3678
        val2 = expr_unary(mon);
3679
        switch(op) {
3680
        default:
3681
        case '*':
3682
            val *= val2;
3683
            break;
3684
        case '/':
3685
        case '%':
3686
            if (val2 == 0)
3687
                expr_error(mon, "division by zero");
3688
            if (op == '/')
3689
                val /= val2;
3690
            else
3691
                val %= val2;
3692
            break;
3693
        }
3694
    }
3695
    return val;
3696
}
3697

    
3698
static int64_t expr_logic(Monitor *mon)
3699
{
3700
    int64_t val, val2;
3701
    int op;
3702

    
3703
    val = expr_prod(mon);
3704
    for(;;) {
3705
        op = *pch;
3706
        if (op != '&' && op != '|' && op != '^')
3707
            break;
3708
        next();
3709
        val2 = expr_prod(mon);
3710
        switch(op) {
3711
        default:
3712
        case '&':
3713
            val &= val2;
3714
            break;
3715
        case '|':
3716
            val |= val2;
3717
            break;
3718
        case '^':
3719
            val ^= val2;
3720
            break;
3721
        }
3722
    }
3723
    return val;
3724
}
3725

    
3726
static int64_t expr_sum(Monitor *mon)
3727
{
3728
    int64_t val, val2;
3729
    int op;
3730

    
3731
    val = expr_logic(mon);
3732
    for(;;) {
3733
        op = *pch;
3734
        if (op != '+' && op != '-')
3735
            break;
3736
        next();
3737
        val2 = expr_logic(mon);
3738
        if (op == '+')
3739
            val += val2;
3740
        else
3741
            val -= val2;
3742
    }
3743
    return val;
3744
}
3745

    
3746
static int get_expr(Monitor *mon, int64_t *pval, const char **pp)
3747
{
3748
    pch = *pp;
3749
    if (setjmp(expr_env)) {
3750
        *pp = pch;
3751
        return -1;
3752
    }
3753
    while (qemu_isspace(*pch))
3754
        pch++;
3755
    *pval = expr_sum(mon);
3756
    *pp = pch;
3757
    return 0;
3758
}
3759

    
3760
static int get_double(Monitor *mon, double *pval, const char **pp)
3761
{
3762
    const char *p = *pp;
3763
    char *tailp;
3764
    double d;
3765

    
3766
    d = strtod(p, &tailp);
3767
    if (tailp == p) {
3768
        monitor_printf(mon, "Number expected\n");
3769
        return -1;
3770
    }
3771
    if (d != d || d - d != 0) {
3772
        /* NaN or infinity */
3773
        monitor_printf(mon, "Bad number\n");
3774
        return -1;
3775
    }
3776
    *pval = d;
3777
    *pp = tailp;
3778
    return 0;
3779
}
3780

    
3781
static int get_str(char *buf, int buf_size, const char **pp)
3782
{
3783
    const char *p;
3784
    char *q;
3785
    int c;
3786

    
3787
    q = buf;
3788
    p = *pp;
3789
    while (qemu_isspace(*p))
3790
        p++;
3791
    if (*p == '\0') {
3792
    fail:
3793
        *q = '\0';
3794
        *pp = p;
3795
        return -1;
3796
    }
3797
    if (*p == '\"') {
3798
        p++;
3799
        while (*p != '\0' && *p != '\"') {
3800
            if (*p == '\\') {
3801
                p++;
3802
                c = *p++;
3803
                switch(c) {
3804
                case 'n':
3805
                    c = '\n';
3806
                    break;
3807
                case 'r':
3808
                    c = '\r';
3809
                    break;
3810
                case '\\':
3811
                case '\'':
3812
                case '\"':
3813
                    break;
3814
                default:
3815
                    qemu_printf("unsupported escape code: '\\%c'\n", c);
3816
                    goto fail;
3817
                }
3818
                if ((q - buf) < buf_size - 1) {
3819
                    *q++ = c;
3820
                }
3821
            } else {
3822
                if ((q - buf) < buf_size - 1) {
3823
                    *q++ = *p;
3824
                }
3825
                p++;
3826
            }
3827
        }
3828
        if (*p != '\"') {
3829
            qemu_printf("unterminated string\n");
3830
            goto fail;
3831
        }
3832
        p++;
3833
    } else {
3834
        while (*p != '\0' && !qemu_isspace(*p)) {
3835
            if ((q - buf) < buf_size - 1) {
3836
                *q++ = *p;
3837
            }
3838
            p++;
3839
        }
3840
    }
3841
    *q = '\0';
3842
    *pp = p;
3843
    return 0;
3844
}
3845

    
3846
/*
3847
 * Store the command-name in cmdname, and return a pointer to
3848
 * the remaining of the command string.
3849
 */
3850
static const char *get_command_name(const char *cmdline,
3851
                                    char *cmdname, size_t nlen)
3852
{
3853
    size_t len;
3854
    const char *p, *pstart;
3855

    
3856
    p = cmdline;
3857
    while (qemu_isspace(*p))
3858
        p++;
3859
    if (*p == '\0')
3860
        return NULL;
3861
    pstart = p;
3862
    while (*p != '\0' && *p != '/' && !qemu_isspace(*p))
3863
        p++;
3864
    len = p - pstart;
3865
    if (len > nlen - 1)
3866
        len = nlen - 1;
3867
    memcpy(cmdname, pstart, len);
3868
    cmdname[len] = '\0';
3869
    return p;
3870
}
3871

    
3872
/**
3873
 * Read key of 'type' into 'key' and return the current
3874
 * 'type' pointer.
3875
 */
3876
static char *key_get_info(const char *type, char **key)
3877
{
3878
    size_t len;
3879
    char *p, *str;
3880

    
3881
    if (*type == ',')
3882
        type++;
3883

    
3884
    p = strchr(type, ':');
3885
    if (!p) {
3886
        *key = NULL;
3887
        return NULL;
3888
    }
3889
    len = p - type;
3890

    
3891
    str = g_malloc(len + 1);
3892
    memcpy(str, type, len);
3893
    str[len] = '\0';
3894

    
3895
    *key = str;
3896
    return ++p;
3897
}
3898

    
3899
static int default_fmt_format = 'x';
3900
static int default_fmt_size = 4;
3901

    
3902
#define MAX_ARGS 16
3903

    
3904
static int is_valid_option(const char *c, const char *typestr)
3905
{
3906
    char option[3];
3907
  
3908
    option[0] = '-';
3909
    option[1] = *c;
3910
    option[2] = '\0';
3911
  
3912
    typestr = strstr(typestr, option);
3913
    return (typestr != NULL);
3914
}
3915

    
3916
static const mon_cmd_t *search_dispatch_table(const mon_cmd_t *disp_table,
3917
                                              const char *cmdname)
3918
{
3919
    const mon_cmd_t *cmd;
3920

    
3921
    for (cmd = disp_table; cmd->name != NULL; cmd++) {
3922
        if (compare_cmd(cmdname, cmd->name)) {
3923
            return cmd;
3924
        }
3925
    }
3926

    
3927
    return NULL;
3928
}
3929

    
3930
static const mon_cmd_t *monitor_find_command(const char *cmdname)
3931
{
3932
    return search_dispatch_table(mon_cmds, cmdname);
3933
}
3934

    
3935
static const mon_cmd_t *qmp_find_query_cmd(const char *info_item)
3936
{
3937
    return search_dispatch_table(qmp_query_cmds, info_item);
3938
}
3939

    
3940
static const mon_cmd_t *qmp_find_cmd(const char *cmdname)
3941
{
3942
    return search_dispatch_table(qmp_cmds, cmdname);
3943
}
3944

    
3945
static const mon_cmd_t *monitor_parse_command(Monitor *mon,
3946
                                              const char *cmdline,
3947
                                              QDict *qdict)
3948
{
3949
    const char *p, *typestr;
3950
    int c;
3951
    const mon_cmd_t *cmd;
3952
    char cmdname[256];
3953
    char buf[1024];
3954
    char *key;
3955

    
3956
#ifdef DEBUG
3957
    monitor_printf(mon, "command='%s'\n", cmdline);
3958
#endif
3959

    
3960
    /* extract the command name */
3961
    p = get_command_name(cmdline, cmdname, sizeof(cmdname));
3962
    if (!p)
3963
        return NULL;
3964

    
3965
    cmd = monitor_find_command(cmdname);
3966
    if (!cmd) {
3967
        monitor_printf(mon, "unknown command: '%s'\n", cmdname);
3968
        return NULL;
3969
    }
3970

    
3971
    /* parse the parameters */
3972
    typestr = cmd->args_type;
3973
    for(;;) {
3974
        typestr = key_get_info(typestr, &key);
3975
        if (!typestr)
3976
            break;
3977
        c = *typestr;
3978
        typestr++;
3979
        switch(c) {
3980
        case 'F':
3981
        case 'B':
3982
        case 's':
3983
            {
3984
                int ret;
3985

    
3986
                while (qemu_isspace(*p))
3987
                    p++;
3988
                if (*typestr == '?') {
3989
                    typestr++;
3990
                    if (*p == '\0') {
3991
                        /* no optional string: NULL argument */
3992
                        break;
3993
                    }
3994
                }
3995
                ret = get_str(buf, sizeof(buf), &p);
3996
                if (ret < 0) {
3997
                    switch(c) {
3998
                    case 'F':
3999
                        monitor_printf(mon, "%s: filename expected\n",
4000
                                       cmdname);
4001
                        break;
4002
                    case 'B':
4003
                        monitor_printf(mon, "%s: block device name expected\n",
4004
                                       cmdname);
4005
                        break;
4006
                    default:
4007
                        monitor_printf(mon, "%s: string expected\n", cmdname);
4008
                        break;
4009
                    }
4010
                    goto fail;
4011
                }
4012
                qdict_put(qdict, key, qstring_from_str(buf));
4013
            }
4014
            break;
4015
        case 'O':
4016
            {
4017
                QemuOptsList *opts_list;
4018
                QemuOpts *opts;
4019

    
4020
                opts_list = qemu_find_opts(key);
4021
                if (!opts_list || opts_list->desc->name) {
4022
                    goto bad_type;
4023
                }
4024
                while (qemu_isspace(*p)) {
4025
                    p++;
4026
                }
4027
                if (!*p)
4028
                    break;
4029
                if (get_str(buf, sizeof(buf), &p) < 0) {
4030
                    goto fail;
4031
                }
4032
                opts = qemu_opts_parse(opts_list, buf, 1);
4033
                if (!opts) {
4034
                    goto fail;
4035
                }
4036
                qemu_opts_to_qdict(opts, qdict);
4037
                qemu_opts_del(opts);
4038
            }
4039
            break;
4040
        case '/':
4041
            {
4042
                int count, format, size;
4043

    
4044
                while (qemu_isspace(*p))
4045
                    p++;
4046
                if (*p == '/') {
4047
                    /* format found */
4048
                    p++;
4049
                    count = 1;
4050
                    if (qemu_isdigit(*p)) {
4051
                        count = 0;
4052
                        while (qemu_isdigit(*p)) {
4053
                            count = count * 10 + (*p - '0');
4054
                            p++;
4055
                        }
4056
                    }
4057
                    size = -1;
4058
                    format = -1;
4059
                    for(;;) {
4060
                        switch(*p) {
4061
                        case 'o':
4062
                        case 'd':
4063
                        case 'u':
4064
                        case 'x':
4065
                        case 'i':
4066
                        case 'c':
4067
                            format = *p++;
4068
                            break;
4069
                        case 'b':
4070
                            size = 1;
4071
                            p++;
4072
                            break;
4073
                        case 'h':
4074
                            size = 2;
4075
                            p++;
4076
                            break;
4077
                        case 'w':
4078
                            size = 4;
4079
                            p++;
4080
                            break;
4081
                        case 'g':
4082
                        case 'L':
4083
                            size = 8;
4084
                            p++;
4085
                            break;
4086
                        default:
4087
                            goto next;
4088
                        }
4089
                    }
4090
                next:
4091
                    if (*p != '\0' && !qemu_isspace(*p)) {
4092
                        monitor_printf(mon, "invalid char in format: '%c'\n",
4093
                                       *p);
4094
                        goto fail;
4095
                    }
4096
                    if (format < 0)
4097
                        format = default_fmt_format;
4098
                    if (format != 'i') {
4099
                        /* for 'i', not specifying a size gives -1 as size */
4100
                        if (size < 0)
4101
                            size = default_fmt_size;
4102
                        default_fmt_size = size;
4103
                    }
4104
                    default_fmt_format = format;
4105
                } else {
4106
                    count = 1;
4107
                    format = default_fmt_format;
4108
                    if (format != 'i') {
4109
                        size = default_fmt_size;
4110
                    } else {
4111
                        size = -1;
4112
                    }
4113
                }
4114
                qdict_put(qdict, "count", qint_from_int(count));
4115
                qdict_put(qdict, "format", qint_from_int(format));
4116
                qdict_put(qdict, "size", qint_from_int(size));
4117
            }
4118
            break;
4119
        case 'i':
4120
        case 'l':
4121
        case 'M':
4122
            {
4123
                int64_t val;
4124

    
4125
                while (qemu_isspace(*p))
4126
                    p++;
4127
                if (*typestr == '?' || *typestr == '.') {
4128
                    if (*typestr == '?') {
4129
                        if (*p == '\0') {
4130
                            typestr++;
4131
                            break;
4132
                        }
4133
                    } else {
4134
                        if (*p == '.') {
4135
                            p++;
4136
                            while (qemu_isspace(*p))
4137
                                p++;
4138
                        } else {
4139
                            typestr++;
4140
                            break;
4141
                        }
4142
                    }
4143
                    typestr++;
4144
                }
4145
                if (get_expr(mon, &val, &p))
4146
                    goto fail;
4147
                /* Check if 'i' is greater than 32-bit */
4148
                if ((c == 'i') && ((val >> 32) & 0xffffffff)) {
4149
                    monitor_printf(mon, "\'%s\' has failed: ", cmdname);
4150
                    monitor_printf(mon, "integer is for 32-bit values\n");
4151
                    goto fail;
4152
                } else if (c == 'M') {
4153
                    val <<= 20;
4154
                }
4155
                qdict_put(qdict, key, qint_from_int(val));
4156
            }
4157
            break;
4158
        case 'o':
4159
            {
4160
                int64_t val;
4161
                char *end;
4162

    
4163
                while (qemu_isspace(*p)) {
4164
                    p++;
4165
                }
4166
                if (*typestr == '?') {
4167
                    typestr++;
4168
                    if (*p == '\0') {
4169
                        break;
4170
                    }
4171
                }
4172
                val = strtosz(p, &end);
4173
                if (val < 0) {
4174
                    monitor_printf(mon, "invalid size\n");
4175
                    goto fail;
4176
                }
4177
                qdict_put(qdict, key, qint_from_int(val));
4178
                p = end;
4179
            }
4180
            break;
4181
        case 'T':
4182
            {
4183
                double val;
4184

    
4185
                while (qemu_isspace(*p))
4186
                    p++;
4187
                if (*typestr == '?') {
4188
                    typestr++;
4189
                    if (*p == '\0') {
4190
                        break;
4191
                    }
4192
                }
4193
                if (get_double(mon, &val, &p) < 0) {
4194
                    goto fail;
4195
                }
4196
                if (p[0] && p[1] == 's') {
4197
                    switch (*p) {
4198
                    case 'm':
4199
                        val /= 1e3; p += 2; break;
4200
                    case 'u':
4201
                        val /= 1e6; p += 2; break;
4202
                    case 'n':
4203
                        val /= 1e9; p += 2; break;
4204
                    }
4205
                }
4206
                if (*p && !qemu_isspace(*p)) {
4207
                    monitor_printf(mon, "Unknown unit suffix\n");
4208
                    goto fail;
4209
                }
4210
                qdict_put(qdict, key, qfloat_from_double(val));
4211
            }
4212
            break;
4213
        case 'b':
4214
            {
4215
                const char *beg;
4216
                int val;
4217

    
4218
                while (qemu_isspace(*p)) {
4219
                    p++;
4220
                }
4221
                beg = p;
4222
                while (qemu_isgraph(*p)) {
4223
                    p++;
4224
                }
4225
                if (p - beg == 2 && !memcmp(beg, "on", p - beg)) {
4226
                    val = 1;
4227
                } else if (p - beg == 3 && !memcmp(beg, "off", p - beg)) {
4228
                    val = 0;
4229
                } else {
4230
                    monitor_printf(mon, "Expected 'on' or 'off'\n");
4231
                    goto fail;
4232
                }
4233
                qdict_put(qdict, key, qbool_from_int(val));
4234
            }
4235
            break;
4236
        case '-':
4237
            {
4238
                const char *tmp = p;
4239
                int skip_key = 0;
4240
                /* option */
4241

    
4242
                c = *typestr++;
4243
                if (c == '\0')
4244
                    goto bad_type;
4245
                while (qemu_isspace(*p))
4246
                    p++;
4247
                if (*p == '-') {
4248
                    p++;
4249
                    if(c != *p) {
4250
                        if(!is_valid_option(p, typestr)) {
4251
                  
4252
                            monitor_printf(mon, "%s: unsupported option -%c\n",
4253
                                           cmdname, *p);
4254
                            goto fail;
4255
                        } else {
4256
                            skip_key = 1;
4257
                        }
4258
                    }
4259
                    if(skip_key) {
4260
                        p = tmp;
4261
                    } else {
4262
                        /* has option */
4263
                        p++;
4264
                        qdict_put(qdict, key, qbool_from_int(1));
4265
                    }
4266
                }
4267
            }
4268
            break;
4269
        default:
4270
        bad_type:
4271
            monitor_printf(mon, "%s: unknown type '%c'\n", cmdname, c);
4272
            goto fail;
4273
        }
4274
        g_free(key);
4275
        key = NULL;
4276
    }
4277
    /* check that all arguments were parsed */
4278
    while (qemu_isspace(*p))
4279
        p++;
4280
    if (*p != '\0') {
4281
        monitor_printf(mon, "%s: extraneous characters at the end of line\n",
4282
                       cmdname);
4283
        goto fail;
4284
    }
4285

    
4286
    return cmd;
4287

    
4288
fail:
4289
    g_free(key);
4290
    return NULL;
4291
}
4292

    
4293
void monitor_set_error(Monitor *mon, QError *qerror)
4294
{
4295
    /* report only the first error */
4296
    if (!mon->error) {
4297
        mon->error = qerror;
4298
    } else {
4299
        MON_DEBUG("Additional error report at %s:%d\n",
4300
                  qerror->file, qerror->linenr);
4301
        QDECREF(qerror);
4302
    }
4303
}
4304

    
4305
static void handler_audit(Monitor *mon, const mon_cmd_t *cmd, int ret)
4306
{
4307
    if (ret && !monitor_has_error(mon)) {
4308
        /*
4309
         * If it returns failure, it must have passed on error.
4310
         *
4311
         * Action: Report an internal error to the client if in QMP.
4312
         */
4313
        qerror_report(QERR_UNDEFINED_ERROR);
4314
        MON_DEBUG("command '%s' returned failure but did not pass an error\n",
4315
                  cmd->name);
4316
    }
4317

    
4318
#ifdef CONFIG_DEBUG_MONITOR
4319
    if (!ret && monitor_has_error(mon)) {
4320
        /*
4321
         * If it returns success, it must not have passed an error.
4322
         *
4323
         * Action: Report the passed error to the client.
4324
         */
4325
        MON_DEBUG("command '%s' returned success but passed an error\n",
4326
                  cmd->name);
4327
    }
4328

    
4329
    if (mon_print_count_get(mon) > 0 && strcmp(cmd->name, "info") != 0) {
4330
        /*
4331
         * Handlers should not call Monitor print functions.
4332
         *
4333
         * Action: Ignore them in QMP.
4334
         *
4335
         * (XXX: we don't check any 'info' or 'query' command here
4336
         * because the user print function _is_ called by do_info(), hence
4337
         * we will trigger this check. This problem will go away when we
4338
         * make 'query' commands real and kill do_info())
4339
         */
4340
        MON_DEBUG("command '%s' called print functions %d time(s)\n",
4341
                  cmd->name, mon_print_count_get(mon));
4342
    }
4343
#endif
4344
}
4345

    
4346
static void handle_user_command(Monitor *mon, const char *cmdline)
4347
{
4348
    QDict *qdict;
4349
    const mon_cmd_t *cmd;
4350

    
4351
    qdict = qdict_new();
4352

    
4353
    cmd = monitor_parse_command(mon, cmdline, qdict);
4354
    if (!cmd)
4355
        goto out;
4356

    
4357
    if (handler_is_async(cmd)) {
4358
        user_async_cmd_handler(mon, cmd, qdict);
4359
    } else if (handler_is_qobject(cmd)) {
4360
        QObject *data = NULL;
4361

    
4362
        /* XXX: ignores the error code */
4363
        cmd->mhandler.cmd_new(mon, qdict, &data);
4364
        assert(!monitor_has_error(mon));
4365
        if (data) {
4366
            cmd->user_print(mon, data);
4367
            qobject_decref(data);
4368
        }
4369
    } else {
4370
        cmd->mhandler.cmd(mon, qdict);
4371
    }
4372

    
4373
out:
4374
    QDECREF(qdict);
4375
}
4376

    
4377
static void cmd_completion(const char *name, const char *list)
4378
{
4379
    const char *p, *pstart;
4380
    char cmd[128];
4381
    int len;
4382

    
4383
    p = list;
4384
    for(;;) {
4385
        pstart = p;
4386
        p = strchr(p, '|');
4387
        if (!p)
4388
            p = pstart + strlen(pstart);
4389
        len = p - pstart;
4390
        if (len > sizeof(cmd) - 2)
4391
            len = sizeof(cmd) - 2;
4392
        memcpy(cmd, pstart, len);
4393
        cmd[len] = '\0';
4394
        if (name[0] == '\0' || !strncmp(name, cmd, strlen(name))) {
4395
            readline_add_completion(cur_mon->rs, cmd);
4396
        }
4397
        if (*p == '\0')
4398
            break;
4399
        p++;
4400
    }
4401
}
4402

    
4403
static void file_completion(const char *input)
4404
{
4405
    DIR *ffs;
4406
    struct dirent *d;
4407
    char path[1024];
4408
    char file[1024], file_prefix[1024];
4409
    int input_path_len;
4410
    const char *p;
4411

    
4412
    p = strrchr(input, '/');
4413
    if (!p) {
4414
        input_path_len = 0;
4415
        pstrcpy(file_prefix, sizeof(file_prefix), input);
4416
        pstrcpy(path, sizeof(path), ".");
4417
    } else {
4418
        input_path_len = p - input + 1;
4419
        memcpy(path, input, input_path_len);
4420
        if (input_path_len > sizeof(path) - 1)
4421
            input_path_len = sizeof(path) - 1;
4422
        path[input_path_len] = '\0';
4423
        pstrcpy(file_prefix, sizeof(file_prefix), p + 1);
4424
    }
4425
#ifdef DEBUG_COMPLETION
4426
    monitor_printf(cur_mon, "input='%s' path='%s' prefix='%s'\n",
4427
                   input, path, file_prefix);
4428
#endif
4429
    ffs = opendir(path);
4430
    if (!ffs)
4431
        return;
4432
    for(;;) {
4433
        struct stat sb;
4434
        d = readdir(ffs);
4435
        if (!d)
4436
            break;
4437

    
4438
        if (strcmp(d->d_name, ".") == 0 || strcmp(d->d_name, "..") == 0) {
4439
            continue;
4440
        }
4441

    
4442
        if (strstart(d->d_name, file_prefix, NULL)) {
4443
            memcpy(file, input, input_path_len);
4444
            if (input_path_len < sizeof(file))
4445
                pstrcpy(file + input_path_len, sizeof(file) - input_path_len,
4446
                        d->d_name);
4447
            /* stat the file to find out if it's a directory.
4448
             * In that case add a slash to speed up typing long paths
4449
             */
4450
            stat(file, &sb);
4451
            if(S_ISDIR(sb.st_mode))
4452
                pstrcat(file, sizeof(file), "/");
4453
            readline_add_completion(cur_mon->rs, file);
4454
        }
4455
    }
4456
    closedir(ffs);
4457
}
4458

    
4459
static void block_completion_it(void *opaque, BlockDriverState *bs)
4460
{
4461
    const char *name = bdrv_get_device_name(bs);
4462
    const char *input = opaque;
4463

    
4464
    if (input[0] == '\0' ||
4465
        !strncmp(name, (char *)input, strlen(input))) {
4466
        readline_add_completion(cur_mon->rs, name);
4467
    }
4468
}
4469

    
4470
/* NOTE: this parser is an approximate form of the real command parser */
4471
static void parse_cmdline(const char *cmdline,
4472
                         int *pnb_args, char **args)
4473
{
4474
    const char *p;
4475
    int nb_args, ret;
4476
    char buf[1024];
4477

    
4478
    p = cmdline;
4479
    nb_args = 0;
4480
    for(;;) {
4481
        while (qemu_isspace(*p))
4482
            p++;
4483
        if (*p == '\0')
4484
            break;
4485
        if (nb_args >= MAX_ARGS)
4486
            break;
4487
        ret = get_str(buf, sizeof(buf), &p);
4488
        args[nb_args] = g_strdup(buf);
4489
        nb_args++;
4490
        if (ret < 0)
4491
            break;
4492
    }
4493
    *pnb_args = nb_args;
4494
}
4495

    
4496
static const char *next_arg_type(const char *typestr)
4497
{
4498
    const char *p = strchr(typestr, ':');
4499
    return (p != NULL ? ++p : typestr);
4500
}
4501

    
4502
static void monitor_find_completion(const char *cmdline)
4503
{
4504
    const char *cmdname;
4505
    char *args[MAX_ARGS];
4506
    int nb_args, i, len;
4507
    const char *ptype, *str;
4508
    const mon_cmd_t *cmd;
4509
    const KeyDef *key;
4510

    
4511
    parse_cmdline(cmdline, &nb_args, args);
4512
#ifdef DEBUG_COMPLETION
4513
    for(i = 0; i < nb_args; i++) {
4514
        monitor_printf(cur_mon, "arg%d = '%s'\n", i, (char *)args[i]);
4515
    }
4516
#endif
4517

    
4518
    /* if the line ends with a space, it means we want to complete the
4519
       next arg */
4520
    len = strlen(cmdline);
4521
    if (len > 0 && qemu_isspace(cmdline[len - 1])) {
4522
        if (nb_args >= MAX_ARGS) {
4523
            goto cleanup;
4524
        }
4525
        args[nb_args++] = g_strdup("");
4526
    }
4527
    if (nb_args <= 1) {
4528
        /* command completion */
4529
        if (nb_args == 0)
4530
            cmdname = "";
4531
        else
4532
            cmdname = args[0];
4533
        readline_set_completion_index(cur_mon->rs, strlen(cmdname));
4534
        for(cmd = mon_cmds; cmd->name != NULL; cmd++) {
4535
            cmd_completion(cmdname, cmd->name);
4536
        }
4537
    } else {
4538
        /* find the command */
4539
        for (cmd = mon_cmds; cmd->name != NULL; cmd++) {
4540
            if (compare_cmd(args[0], cmd->name)) {
4541
                break;
4542
            }
4543
        }
4544
        if (!cmd->name) {
4545
            goto cleanup;
4546
        }
4547

    
4548
        ptype = next_arg_type(cmd->args_type);
4549
        for(i = 0; i < nb_args - 2; i++) {
4550
            if (*ptype != '\0') {
4551
                ptype = next_arg_type(ptype);
4552
                while (*ptype == '?')
4553
                    ptype = next_arg_type(ptype);
4554
            }
4555
        }
4556
        str = args[nb_args - 1];
4557
        if (*ptype == '-' && ptype[1] != '\0') {
4558
            ptype = next_arg_type(ptype);
4559
        }
4560
        switch(*ptype) {
4561
        case 'F':
4562
            /* file completion */
4563
            readline_set_completion_index(cur_mon->rs, strlen(str));
4564
            file_completion(str);
4565
            break;
4566
        case 'B':
4567
            /* block device name completion */
4568
            readline_set_completion_index(cur_mon->rs, strlen(str));
4569
            bdrv_iterate(block_completion_it, (void *)str);
4570
            break;
4571
        case 's':
4572
            /* XXX: more generic ? */
4573
            if (!strcmp(cmd->name, "info")) {
4574
                readline_set_completion_index(cur_mon->rs, strlen(str));
4575
                for(cmd = info_cmds; cmd->name != NULL; cmd++) {
4576
                    cmd_completion(str, cmd->name);
4577
                }
4578
            } else if (!strcmp(cmd->name, "sendkey")) {
4579
                char *sep = strrchr(str, '-');
4580
                if (sep)
4581
                    str = sep + 1;
4582
                readline_set_completion_index(cur_mon->rs, strlen(str));
4583
                for(key = key_defs; key->name != NULL; key++) {
4584
                    cmd_completion(str, key->name);
4585
                }
4586
            } else if (!strcmp(cmd->name, "help|?")) {
4587
                readline_set_completion_index(cur_mon->rs, strlen(str));
4588
                for (cmd = mon_cmds; cmd->name != NULL; cmd++) {
4589
                    cmd_completion(str, cmd->name);
4590
                }
4591
            }
4592
            break;
4593
        default:
4594
            break;
4595
        }
4596
    }
4597

    
4598
cleanup:
4599
    for (i = 0; i < nb_args; i++) {
4600
        g_free(args[i]);
4601
    }
4602
}
4603

    
4604
static int monitor_can_read(void *opaque)
4605
{
4606
    Monitor *mon = opaque;
4607

    
4608
    return (mon->suspend_cnt == 0) ? 1 : 0;
4609
}
4610

    
4611
static int invalid_qmp_mode(const Monitor *mon, const char *cmd_name)
4612
{
4613
    int is_cap = compare_cmd(cmd_name, "qmp_capabilities");
4614
    return (qmp_cmd_mode(mon) ? is_cap : !is_cap);
4615
}
4616

    
4617
/*
4618
 * Argument validation rules:
4619
 *
4620
 * 1. The argument must exist in cmd_args qdict
4621
 * 2. The argument type must be the expected one
4622
 *
4623
 * Special case: If the argument doesn't exist in cmd_args and
4624
 *               the QMP_ACCEPT_UNKNOWNS flag is set, then the
4625
 *               checking is skipped for it.
4626
 */
4627
static int check_client_args_type(const QDict *client_args,
4628
                                  const QDict *cmd_args, int flags)
4629
{
4630
    const QDictEntry *ent;
4631

    
4632
    for (ent = qdict_first(client_args); ent;ent = qdict_next(client_args,ent)){
4633
        QObject *obj;
4634
        QString *arg_type;
4635
        const QObject *client_arg = qdict_entry_value(ent);
4636
        const char *client_arg_name = qdict_entry_key(ent);
4637

    
4638
        obj = qdict_get(cmd_args, client_arg_name);
4639
        if (!obj) {
4640
            if (flags & QMP_ACCEPT_UNKNOWNS) {
4641
                /* handler accepts unknowns */
4642
                continue;
4643
            }
4644
            /* client arg doesn't exist */
4645
            qerror_report(QERR_INVALID_PARAMETER, client_arg_name);
4646
            return -1;
4647
        }
4648

    
4649
        arg_type = qobject_to_qstring(obj);
4650
        assert(arg_type != NULL);
4651

    
4652
        /* check if argument's type is correct */
4653
        switch (qstring_get_str(arg_type)[0]) {
4654
        case 'F':
4655
        case 'B':
4656
        case 's':
4657
            if (qobject_type(client_arg) != QTYPE_QSTRING) {
4658
                qerror_report(QERR_INVALID_PARAMETER_TYPE, client_arg_name,
4659
                              "string");
4660
                return -1;
4661
            }
4662
        break;
4663
        case 'i':
4664
        case 'l':
4665
        case 'M':
4666
        case 'o':
4667
            if (qobject_type(client_arg) != QTYPE_QINT) {
4668
                qerror_report(QERR_INVALID_PARAMETER_TYPE, client_arg_name,
4669
                              "int");
4670
                return -1; 
4671
            }
4672
            break;
4673
        case 'T':
4674
            if (qobject_type(client_arg) != QTYPE_QINT &&
4675
                qobject_type(client_arg) != QTYPE_QFLOAT) {
4676
                qerror_report(QERR_INVALID_PARAMETER_TYPE, client_arg_name,
4677
                              "number");
4678
               return -1; 
4679
            }
4680
            break;
4681
        case 'b':
4682
        case '-':
4683
            if (qobject_type(client_arg) != QTYPE_QBOOL) {
4684
                qerror_report(QERR_INVALID_PARAMETER_TYPE, client_arg_name,
4685
                              "bool");
4686
               return -1; 
4687
            }
4688
            break;
4689
        case 'O':
4690
            assert(flags & QMP_ACCEPT_UNKNOWNS);
4691
            break;
4692
        case '/':
4693
        case '.':
4694
            /*
4695
             * These types are not supported by QMP and thus are not
4696
             * handled here. Fall through.
4697
             */
4698
        default:
4699
            abort();
4700
        }
4701
    }
4702

    
4703
    return 0;
4704
}
4705

    
4706
/*
4707
 * - Check if the client has passed all mandatory args
4708
 * - Set special flags for argument validation
4709
 */
4710
static int check_mandatory_args(const QDict *cmd_args,
4711
                                const QDict *client_args, int *flags)
4712
{
4713
    const QDictEntry *ent;
4714

    
4715
    for (ent = qdict_first(cmd_args); ent; ent = qdict_next(cmd_args, ent)) {
4716
        const char *cmd_arg_name = qdict_entry_key(ent);
4717
        QString *type = qobject_to_qstring(qdict_entry_value(ent));
4718
        assert(type != NULL);
4719

    
4720
        if (qstring_get_str(type)[0] == 'O') {
4721
            assert((*flags & QMP_ACCEPT_UNKNOWNS) == 0);
4722
            *flags |= QMP_ACCEPT_UNKNOWNS;
4723
        } else if (qstring_get_str(type)[0] != '-' &&
4724
                   qstring_get_str(type)[1] != '?' &&
4725
                   !qdict_haskey(client_args, cmd_arg_name)) {
4726
            qerror_report(QERR_MISSING_PARAMETER, cmd_arg_name);
4727
            return -1;
4728
        }
4729
    }
4730

    
4731
    return 0;
4732
}
4733

    
4734
static QDict *qdict_from_args_type(const char *args_type)
4735
{
4736
    int i;
4737
    QDict *qdict;
4738
    QString *key, *type, *cur_qs;
4739

    
4740
    assert(args_type != NULL);
4741

    
4742
    qdict = qdict_new();
4743

    
4744
    if (args_type == NULL || args_type[0] == '\0') {
4745
        /* no args, empty qdict */
4746
        goto out;
4747
    }
4748

    
4749
    key = qstring_new();
4750
    type = qstring_new();
4751

    
4752
    cur_qs = key;
4753

    
4754
    for (i = 0;; i++) {
4755
        switch (args_type[i]) {
4756
            case ',':
4757
            case '\0':
4758
                qdict_put(qdict, qstring_get_str(key), type);
4759
                QDECREF(key);
4760
                if (args_type[i] == '\0') {
4761
                    goto out;
4762
                }
4763
                type = qstring_new(); /* qdict has ref */
4764
                cur_qs = key = qstring_new();
4765
                break;
4766
            case ':':
4767
                cur_qs = type;
4768
                break;
4769
            default:
4770
                qstring_append_chr(cur_qs, args_type[i]);
4771
                break;
4772
        }
4773
    }
4774

    
4775
out:
4776
    return qdict;
4777
}
4778

    
4779
/*
4780
 * Client argument checking rules:
4781
 *
4782
 * 1. Client must provide all mandatory arguments
4783
 * 2. Each argument provided by the client must be expected
4784
 * 3. Each argument provided by the client must have the type expected
4785
 *    by the command
4786
 */
4787
static int qmp_check_client_args(const mon_cmd_t *cmd, QDict *client_args)
4788
{
4789
    int flags, err;
4790
    QDict *cmd_args;
4791

    
4792
    cmd_args = qdict_from_args_type(cmd->args_type);
4793

    
4794
    flags = 0;
4795
    err = check_mandatory_args(cmd_args, client_args, &flags);
4796
    if (err) {
4797
        goto out;
4798
    }
4799

    
4800
    err = check_client_args_type(client_args, cmd_args, flags);
4801

    
4802
out:
4803
    QDECREF(cmd_args);
4804
    return err;
4805
}
4806

    
4807
/*
4808
 * Input object checking rules
4809
 *
4810
 * 1. Input object must be a dict
4811
 * 2. The "execute" key must exist
4812
 * 3. The "execute" key must be a string
4813
 * 4. If the "arguments" key exists, it must be a dict
4814
 * 5. If the "id" key exists, it can be anything (ie. json-value)
4815
 * 6. Any argument not listed above is considered invalid
4816
 */
4817
static QDict *qmp_check_input_obj(QObject *input_obj)
4818
{
4819
    const QDictEntry *ent;
4820
    int has_exec_key = 0;
4821
    QDict *input_dict;
4822

    
4823
    if (qobject_type(input_obj) != QTYPE_QDICT) {
4824
        qerror_report(QERR_QMP_BAD_INPUT_OBJECT, "object");
4825
        return NULL;
4826
    }
4827

    
4828
    input_dict = qobject_to_qdict(input_obj);
4829

    
4830
    for (ent = qdict_first(input_dict); ent; ent = qdict_next(input_dict, ent)){
4831
        const char *arg_name = qdict_entry_key(ent);
4832
        const QObject *arg_obj = qdict_entry_value(ent);
4833

    
4834
        if (!strcmp(arg_name, "execute")) {
4835
            if (qobject_type(arg_obj) != QTYPE_QSTRING) {
4836
                qerror_report(QERR_QMP_BAD_INPUT_OBJECT_MEMBER, "execute",
4837
                              "string");
4838
                return NULL;
4839
            }
4840
            has_exec_key = 1;
4841
        } else if (!strcmp(arg_name, "arguments")) {
4842
            if (qobject_type(arg_obj) != QTYPE_QDICT) {
4843
                qerror_report(QERR_QMP_BAD_INPUT_OBJECT_MEMBER, "arguments",
4844
                              "object");
4845
                return NULL;
4846
            }
4847
        } else if (!strcmp(arg_name, "id")) {
4848
            /* FIXME: check duplicated IDs for async commands */
4849
        } else {
4850
            qerror_report(QERR_QMP_EXTRA_MEMBER, arg_name);
4851
            return NULL;
4852
        }
4853
    }
4854

    
4855
    if (!has_exec_key) {
4856
        qerror_report(QERR_QMP_BAD_INPUT_OBJECT, "execute");
4857
        return NULL;
4858
    }
4859

    
4860
    return input_dict;
4861
}
4862

    
4863
static void qmp_call_query_cmd(Monitor *mon, const mon_cmd_t *cmd)
4864
{
4865
    QObject *ret_data = NULL;
4866

    
4867
    if (handler_is_async(cmd)) {
4868
        qmp_async_info_handler(mon, cmd);
4869
        if (monitor_has_error(mon)) {
4870
            monitor_protocol_emitter(mon, NULL);
4871
        }
4872
    } else {
4873
        cmd->mhandler.info_new(mon, &ret_data);
4874
        monitor_protocol_emitter(mon, ret_data);
4875
        qobject_decref(ret_data);
4876
    }
4877
}
4878

    
4879
static void qmp_call_cmd(Monitor *mon, const mon_cmd_t *cmd,
4880
                         const QDict *params)
4881
{
4882
    int ret;
4883
    QObject *data = NULL;
4884

    
4885
    mon_print_count_init(mon);
4886

    
4887
    ret = cmd->mhandler.cmd_new(mon, params, &data);
4888
    handler_audit(mon, cmd, ret);
4889
    monitor_protocol_emitter(mon, data);
4890
    qobject_decref(data);
4891
}
4892

    
4893
static void handle_qmp_command(JSONMessageParser *parser, QList *tokens)
4894
{
4895
    int err;
4896
    QObject *obj;
4897
    QDict *input, *args;
4898
    const mon_cmd_t *cmd;
4899
    Monitor *mon = cur_mon;
4900
    const char *cmd_name, *query_cmd;
4901

    
4902
    query_cmd = NULL;
4903
    args = input = NULL;
4904

    
4905
    obj = json_parser_parse(tokens, NULL);
4906
    if (!obj) {
4907
        // FIXME: should be triggered in json_parser_parse()
4908
        qerror_report(QERR_JSON_PARSING);
4909
        goto err_out;
4910
    }
4911

    
4912
    input = qmp_check_input_obj(obj);
4913
    if (!input) {
4914
        qobject_decref(obj);
4915
        goto err_out;
4916
    }
4917

    
4918
    mon->mc->id = qdict_get(input, "id");
4919
    qobject_incref(mon->mc->id);
4920

    
4921
    cmd_name = qdict_get_str(input, "execute");
4922
    trace_handle_qmp_command(mon, cmd_name);
4923
    if (invalid_qmp_mode(mon, cmd_name)) {
4924
        qerror_report(QERR_COMMAND_NOT_FOUND, cmd_name);
4925
        goto err_out;
4926
    }
4927

    
4928
    cmd = qmp_find_cmd(cmd_name);
4929
    if (!cmd && strstart(cmd_name, "query-", &query_cmd)) {
4930
        cmd = qmp_find_query_cmd(query_cmd);
4931
    }
4932
    if (!cmd) {
4933
        qerror_report(QERR_COMMAND_NOT_FOUND, cmd_name);
4934
        goto err_out;
4935
    }
4936

    
4937
    obj = qdict_get(input, "arguments");
4938
    if (!obj) {
4939
        args = qdict_new();
4940
    } else {
4941
        args = qobject_to_qdict(obj);
4942
        QINCREF(args);
4943
    }
4944

    
4945
    err = qmp_check_client_args(cmd, args);
4946
    if (err < 0) {
4947
        goto err_out;
4948
    }
4949

    
4950
    if (query_cmd) {
4951
        qmp_call_query_cmd(mon, cmd);
4952
    } else if (handler_is_async(cmd)) {
4953
        err = qmp_async_cmd_handler(mon, cmd, args);
4954
        if (err) {
4955
            /* emit the error response */
4956
            goto err_out;
4957
        }
4958
    } else {
4959
        qmp_call_cmd(mon, cmd, args);
4960
    }
4961

    
4962
    goto out;
4963

    
4964
err_out:
4965
    monitor_protocol_emitter(mon, NULL);
4966
out:
4967
    QDECREF(input);
4968
    QDECREF(args);
4969
}
4970

    
4971
/**
4972
 * monitor_control_read(): Read and handle QMP input
4973
 */
4974
static void monitor_control_read(void *opaque, const uint8_t *buf, int size)
4975
{
4976
    Monitor *old_mon = cur_mon;
4977

    
4978
    cur_mon = opaque;
4979

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

    
4982
    cur_mon = old_mon;
4983
}
4984

    
4985
static void monitor_read(void *opaque, const uint8_t *buf, int size)
4986
{
4987
    Monitor *old_mon = cur_mon;
4988
    int i;
4989

    
4990
    cur_mon = opaque;
4991

    
4992
    if (cur_mon->rs) {
4993
        for (i = 0; i < size; i++)
4994
            readline_handle_byte(cur_mon->rs, buf[i]);
4995
    } else {
4996
        if (size == 0 || buf[size - 1] != 0)
4997
            monitor_printf(cur_mon, "corrupted command\n");
4998
        else
4999
            handle_user_command(cur_mon, (char *)buf);
5000
    }
5001

    
5002
    cur_mon = old_mon;
5003
}
5004

    
5005
static void monitor_command_cb(Monitor *mon, const char *cmdline, void *opaque)
5006
{
5007
    monitor_suspend(mon);
5008
    handle_user_command(mon, cmdline);
5009
    monitor_resume(mon);
5010
}
5011

    
5012
int monitor_suspend(Monitor *mon)
5013
{
5014
    if (!mon->rs)
5015
        return -ENOTTY;
5016
    mon->suspend_cnt++;
5017
    return 0;
5018
}
5019

    
5020
void monitor_resume(Monitor *mon)
5021
{
5022
    if (!mon->rs)
5023
        return;
5024
    if (--mon->suspend_cnt == 0)
5025
        readline_show_prompt(mon->rs);
5026
}
5027

    
5028
static QObject *get_qmp_greeting(void)
5029
{
5030
    QObject *ver = NULL;
5031

    
5032
    qmp_marshal_input_query_version(NULL, NULL, &ver);
5033
    return qobject_from_jsonf("{'QMP':{'version': %p,'capabilities': []}}",ver);
5034
}
5035

    
5036
/**
5037
 * monitor_control_event(): Print QMP gretting
5038
 */
5039
static void monitor_control_event(void *opaque, int event)
5040
{
5041
    QObject *data;
5042
    Monitor *mon = opaque;
5043

    
5044
    switch (event) {
5045
    case CHR_EVENT_OPENED:
5046
        mon->mc->command_mode = 0;
5047
        json_message_parser_init(&mon->mc->parser, handle_qmp_command);
5048
        data = get_qmp_greeting();
5049
        monitor_json_emitter(mon, data);
5050
        qobject_decref(data);
5051
        break;
5052
    case CHR_EVENT_CLOSED:
5053
        json_message_parser_destroy(&mon->mc->parser);
5054
        break;
5055
    }
5056
}
5057

    
5058
static void monitor_event(void *opaque, int event)
5059
{
5060
    Monitor *mon = opaque;
5061

    
5062
    switch (event) {
5063
    case CHR_EVENT_MUX_IN:
5064
        mon->mux_out = 0;
5065
        if (mon->reset_seen) {
5066
            readline_restart(mon->rs);
5067
            monitor_resume(mon);
5068
            monitor_flush(mon);
5069
        } else {
5070
            mon->suspend_cnt = 0;
5071
        }
5072
        break;
5073

    
5074
    case CHR_EVENT_MUX_OUT:
5075
        if (mon->reset_seen) {
5076
            if (mon->suspend_cnt == 0) {
5077
                monitor_printf(mon, "\n");
5078
            }
5079
            monitor_flush(mon);
5080
            monitor_suspend(mon);
5081
        } else {
5082
            mon->suspend_cnt++;
5083
        }
5084
        mon->mux_out = 1;
5085
        break;
5086

    
5087
    case CHR_EVENT_OPENED:
5088
        monitor_printf(mon, "QEMU %s monitor - type 'help' for more "
5089
                       "information\n", QEMU_VERSION);
5090
        if (!mon->mux_out) {
5091
            readline_show_prompt(mon->rs);
5092
        }
5093
        mon->reset_seen = 1;
5094
        break;
5095
    }
5096
}
5097

    
5098

    
5099
/*
5100
 * Local variables:
5101
 *  c-indent-level: 4
5102
 *  c-basic-offset: 4
5103
 *  tab-width: 8
5104
 * End:
5105
 */
5106

    
5107
void monitor_init(CharDriverState *chr, int flags)
5108
{
5109
    static int is_first_init = 1;
5110
    Monitor *mon;
5111

    
5112
    if (is_first_init) {
5113
        key_timer = qemu_new_timer_ns(vm_clock, release_keys, NULL);
5114
        is_first_init = 0;
5115
    }
5116

    
5117
    mon = g_malloc0(sizeof(*mon));
5118

    
5119
    mon->chr = chr;
5120
    mon->flags = flags;
5121
    if (flags & MONITOR_USE_READLINE) {
5122
        mon->rs = readline_init(mon, monitor_find_completion);
5123
        monitor_read_command(mon, 0);
5124
    }
5125

    
5126
    if (monitor_ctrl_mode(mon)) {
5127
        mon->mc = g_malloc0(sizeof(MonitorControl));
5128
        /* Control mode requires special handlers */
5129
        qemu_chr_add_handlers(chr, monitor_can_read, monitor_control_read,
5130
                              monitor_control_event, mon);
5131
        qemu_chr_fe_set_echo(chr, true);
5132
    } else {
5133
        qemu_chr_add_handlers(chr, monitor_can_read, monitor_read,
5134
                              monitor_event, mon);
5135
    }
5136

    
5137
    QLIST_INSERT_HEAD(&mon_list, mon, entry);
5138
    if (!default_mon || (flags & MONITOR_IS_DEFAULT))
5139
        default_mon = mon;
5140
}
5141

    
5142
static void bdrv_password_cb(Monitor *mon, const char *password, void *opaque)
5143
{
5144
    BlockDriverState *bs = opaque;
5145
    int ret = 0;
5146

    
5147
    if (bdrv_set_key(bs, password) != 0) {
5148
        monitor_printf(mon, "invalid password\n");
5149
        ret = -EPERM;
5150
    }
5151
    if (mon->password_completion_cb)
5152
        mon->password_completion_cb(mon->password_opaque, ret);
5153

    
5154
    monitor_read_command(mon, 1);
5155
}
5156

    
5157
int monitor_read_bdrv_key_start(Monitor *mon, BlockDriverState *bs,
5158
                                BlockDriverCompletionFunc *completion_cb,
5159
                                void *opaque)
5160
{
5161
    int err;
5162

    
5163
    if (!bdrv_key_required(bs)) {
5164
        if (completion_cb)
5165
            completion_cb(opaque, 0);
5166
        return 0;
5167
    }
5168

    
5169
    if (monitor_ctrl_mode(mon)) {
5170
        qerror_report(QERR_DEVICE_ENCRYPTED, bdrv_get_device_name(bs));
5171
        return -1;
5172
    }
5173

    
5174
    monitor_printf(mon, "%s (%s) is encrypted.\n", bdrv_get_device_name(bs),
5175
                   bdrv_get_encrypted_filename(bs));
5176

    
5177
    mon->password_completion_cb = completion_cb;
5178
    mon->password_opaque = opaque;
5179

    
5180
    err = monitor_read_password(mon, bdrv_password_cb, bs);
5181

    
5182
    if (err && completion_cb)
5183
        completion_cb(opaque, err);
5184

    
5185
    return err;
5186
}