Statistics
| Branch: | Revision:

root / monitor.c @ ef845c3b

History | View | Annotate | Download (95 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 "qemu-char.h"
36
#include "sysemu.h"
37
#include "monitor.h"
38
#include "readline.h"
39
#include "console.h"
40
#include "block.h"
41
#include "audio/audio.h"
42
#include "disas.h"
43
#include "balloon.h"
44
#include "qemu-timer.h"
45
#include "migration.h"
46
#include "kvm.h"
47
#include "acl.h"
48
#include "qint.h"
49
#include "qlist.h"
50
#include "qdict.h"
51
#include "qstring.h"
52

    
53
//#define DEBUG
54
//#define DEBUG_COMPLETION
55

    
56
/*
57
 * Supported types:
58
 *
59
 * 'F'          filename
60
 * 'B'          block device name
61
 * 's'          string (accept optional quote)
62
 * 'i'          32 bit integer
63
 * 'l'          target long (32 or 64 bit)
64
 * '/'          optional gdb-like print format (like "/10x")
65
 *
66
 * '?'          optional type (for all types, except '/')
67
 * '.'          other form of optional type (for 'i' and 'l')
68
 * '-'          optional parameter (eg. '-f')
69
 *
70
 */
71

    
72
typedef struct mon_cmd_t {
73
    const char *name;
74
    const char *args_type;
75
    const char *params;
76
    const char *help;
77
    void (*user_print)(Monitor *mon, const QObject *data);
78
    union {
79
        void (*info)(Monitor *mon);
80
        void (*info_new)(Monitor *mon, QObject **ret_data);
81
        void (*cmd)(Monitor *mon, const QDict *qdict);
82
        void (*cmd_new)(Monitor *mon, const QDict *params, QObject **ret_data);
83
    } mhandler;
84
} mon_cmd_t;
85

    
86
/* file descriptors passed via SCM_RIGHTS */
87
typedef struct mon_fd_t mon_fd_t;
88
struct mon_fd_t {
89
    char *name;
90
    int fd;
91
    QLIST_ENTRY(mon_fd_t) next;
92
};
93

    
94
struct Monitor {
95
    CharDriverState *chr;
96
    int mux_out;
97
    int reset_seen;
98
    int flags;
99
    int suspend_cnt;
100
    uint8_t outbuf[1024];
101
    int outbuf_index;
102
    ReadLineState *rs;
103
    CPUState *mon_cpu;
104
    BlockDriverCompletionFunc *password_completion_cb;
105
    void *password_opaque;
106
    QLIST_HEAD(,mon_fd_t) fds;
107
    QLIST_ENTRY(Monitor) entry;
108
};
109

    
110
static QLIST_HEAD(mon_list, Monitor) mon_list;
111

    
112
static const mon_cmd_t mon_cmds[];
113
static const mon_cmd_t info_cmds[];
114

    
115
Monitor *cur_mon = NULL;
116

    
117
static void monitor_command_cb(Monitor *mon, const char *cmdline,
118
                               void *opaque);
119

    
120
static void monitor_read_command(Monitor *mon, int show_prompt)
121
{
122
    readline_start(mon->rs, "(qemu) ", 0, monitor_command_cb, NULL);
123
    if (show_prompt)
124
        readline_show_prompt(mon->rs);
125
}
126

    
127
static int monitor_read_password(Monitor *mon, ReadLineFunc *readline_func,
128
                                 void *opaque)
129
{
130
    if (mon->rs) {
131
        readline_start(mon->rs, "Password: ", 1, readline_func, opaque);
132
        /* prompt is printed on return from the command handler */
133
        return 0;
134
    } else {
135
        monitor_printf(mon, "terminal does not support password prompting\n");
136
        return -ENOTTY;
137
    }
138
}
139

    
140
void monitor_flush(Monitor *mon)
141
{
142
    if (mon && mon->outbuf_index != 0 && !mon->mux_out) {
143
        qemu_chr_write(mon->chr, mon->outbuf, mon->outbuf_index);
144
        mon->outbuf_index = 0;
145
    }
146
}
147

    
148
/* flush at every end of line or if the buffer is full */
149
static void monitor_puts(Monitor *mon, const char *str)
150
{
151
    char c;
152

    
153
    if (!mon)
154
        return;
155

    
156
    for(;;) {
157
        c = *str++;
158
        if (c == '\0')
159
            break;
160
        if (c == '\n')
161
            mon->outbuf[mon->outbuf_index++] = '\r';
162
        mon->outbuf[mon->outbuf_index++] = c;
163
        if (mon->outbuf_index >= (sizeof(mon->outbuf) - 1)
164
            || c == '\n')
165
            monitor_flush(mon);
166
    }
167
}
168

    
169
void monitor_vprintf(Monitor *mon, const char *fmt, va_list ap)
170
{
171
    char buf[4096];
172
    vsnprintf(buf, sizeof(buf), fmt, ap);
173
    monitor_puts(mon, buf);
174
}
175

    
176
void monitor_printf(Monitor *mon, const char *fmt, ...)
177
{
178
    va_list ap;
179
    va_start(ap, fmt);
180
    monitor_vprintf(mon, fmt, ap);
181
    va_end(ap);
182
}
183

    
184
void monitor_print_filename(Monitor *mon, const char *filename)
185
{
186
    int i;
187

    
188
    for (i = 0; filename[i]; i++) {
189
        switch (filename[i]) {
190
        case ' ':
191
        case '"':
192
        case '\\':
193
            monitor_printf(mon, "\\%c", filename[i]);
194
            break;
195
        case '\t':
196
            monitor_printf(mon, "\\t");
197
            break;
198
        case '\r':
199
            monitor_printf(mon, "\\r");
200
            break;
201
        case '\n':
202
            monitor_printf(mon, "\\n");
203
            break;
204
        default:
205
            monitor_printf(mon, "%c", filename[i]);
206
            break;
207
        }
208
    }
209
}
210

    
211
static int monitor_fprintf(FILE *stream, const char *fmt, ...)
212
{
213
    va_list ap;
214
    va_start(ap, fmt);
215
    monitor_vprintf((Monitor *)stream, fmt, ap);
216
    va_end(ap);
217
    return 0;
218
}
219

    
220
static void monitor_user_noop(Monitor *mon, const QObject *data) { }
221

    
222
static inline int monitor_handler_ported(const mon_cmd_t *cmd)
223
{
224
    return cmd->user_print != NULL;
225
}
226

    
227
static void monitor_print_qobject(Monitor *mon, const QObject *data)
228
{
229
    switch (qobject_type(data)) {
230
        case QTYPE_QSTRING:
231
            monitor_printf(mon, "%s",qstring_get_str(qobject_to_qstring(data)));
232
            break;
233
        case QTYPE_QINT:
234
            monitor_printf(mon, "%" PRId64,qint_get_int(qobject_to_qint(data)));
235
            break;
236
        default:
237
            monitor_printf(mon, "ERROR: unsupported type: %d",
238
                                                        qobject_type(data));
239
            break;
240
    }
241

    
242
    monitor_puts(mon, "\n");
243
}
244

    
245
static int compare_cmd(const char *name, const char *list)
246
{
247
    const char *p, *pstart;
248
    int len;
249
    len = strlen(name);
250
    p = list;
251
    for(;;) {
252
        pstart = p;
253
        p = strchr(p, '|');
254
        if (!p)
255
            p = pstart + strlen(pstart);
256
        if ((p - pstart) == len && !memcmp(pstart, name, len))
257
            return 1;
258
        if (*p == '\0')
259
            break;
260
        p++;
261
    }
262
    return 0;
263
}
264

    
265
static void help_cmd_dump(Monitor *mon, const mon_cmd_t *cmds,
266
                          const char *prefix, const char *name)
267
{
268
    const mon_cmd_t *cmd;
269

    
270
    for(cmd = cmds; cmd->name != NULL; cmd++) {
271
        if (!name || !strcmp(name, cmd->name))
272
            monitor_printf(mon, "%s%s %s -- %s\n", prefix, cmd->name,
273
                           cmd->params, cmd->help);
274
    }
275
}
276

    
277
static void help_cmd(Monitor *mon, const char *name)
278
{
279
    if (name && !strcmp(name, "info")) {
280
        help_cmd_dump(mon, info_cmds, "info ", NULL);
281
    } else {
282
        help_cmd_dump(mon, mon_cmds, "", name);
283
        if (name && !strcmp(name, "log")) {
284
            const CPULogItem *item;
285
            monitor_printf(mon, "Log items (comma separated):\n");
286
            monitor_printf(mon, "%-10s %s\n", "none", "remove all logs");
287
            for(item = cpu_log_items; item->mask != 0; item++) {
288
                monitor_printf(mon, "%-10s %s\n", item->name, item->help);
289
            }
290
        }
291
    }
292
}
293

    
294
static void do_help_cmd(Monitor *mon, const QDict *qdict)
295
{
296
    help_cmd(mon, qdict_get_try_str(qdict, "name"));
297
}
298

    
299
static void do_commit(Monitor *mon, const QDict *qdict)
300
{
301
    int all_devices;
302
    DriveInfo *dinfo;
303
    const char *device = qdict_get_str(qdict, "device");
304

    
305
    all_devices = !strcmp(device, "all");
306
    QTAILQ_FOREACH(dinfo, &drives, next) {
307
        if (!all_devices)
308
            if (strcmp(bdrv_get_device_name(dinfo->bdrv), device))
309
                continue;
310
        bdrv_commit(dinfo->bdrv);
311
    }
312
}
313

    
314
static void do_info(Monitor *mon, const QDict *qdict, QObject **ret_data)
315
{
316
    const mon_cmd_t *cmd;
317
    const char *item = qdict_get_try_str(qdict, "item");
318

    
319
    if (!item)
320
        goto help;
321

    
322
    for (cmd = info_cmds; cmd->name != NULL; cmd++) {
323
        if (compare_cmd(item, cmd->name))
324
            break;
325
    }
326

    
327
    if (cmd->name == NULL)
328
        goto help;
329

    
330
    if (monitor_handler_ported(cmd)) {
331
        cmd->mhandler.info_new(mon, ret_data);
332
        if (*ret_data)
333
            cmd->user_print(mon, *ret_data);
334
    } else {
335
        cmd->mhandler.info(mon);
336
    }
337

    
338
    return;
339

    
340
help:
341
    help_cmd(mon, "info");
342
}
343

    
344
/**
345
 * do_info_version(): Show QEMU version
346
 */
347
static void do_info_version(Monitor *mon, QObject **ret_data)
348
{
349
    *ret_data = QOBJECT(qstring_from_str(QEMU_VERSION QEMU_PKGVERSION));
350
}
351

    
352
static void do_info_name(Monitor *mon)
353
{
354
    if (qemu_name)
355
        monitor_printf(mon, "%s\n", qemu_name);
356
}
357

    
358
#if defined(TARGET_I386)
359
static void do_info_hpet(Monitor *mon)
360
{
361
    monitor_printf(mon, "HPET is %s by QEMU\n",
362
                   (no_hpet) ? "disabled" : "enabled");
363
}
364
#endif
365

    
366
static void do_info_uuid(Monitor *mon)
367
{
368
    monitor_printf(mon, UUID_FMT "\n", qemu_uuid[0], qemu_uuid[1],
369
                   qemu_uuid[2], qemu_uuid[3], qemu_uuid[4], qemu_uuid[5],
370
                   qemu_uuid[6], qemu_uuid[7], qemu_uuid[8], qemu_uuid[9],
371
                   qemu_uuid[10], qemu_uuid[11], qemu_uuid[12], qemu_uuid[13],
372
                   qemu_uuid[14], qemu_uuid[15]);
373
}
374

    
375
/* get the current CPU defined by the user */
376
static int mon_set_cpu(int cpu_index)
377
{
378
    CPUState *env;
379

    
380
    for(env = first_cpu; env != NULL; env = env->next_cpu) {
381
        if (env->cpu_index == cpu_index) {
382
            cur_mon->mon_cpu = env;
383
            return 0;
384
        }
385
    }
386
    return -1;
387
}
388

    
389
static CPUState *mon_get_cpu(void)
390
{
391
    if (!cur_mon->mon_cpu) {
392
        mon_set_cpu(0);
393
    }
394
    cpu_synchronize_state(cur_mon->mon_cpu);
395
    return cur_mon->mon_cpu;
396
}
397

    
398
static void do_info_registers(Monitor *mon)
399
{
400
    CPUState *env;
401
    env = mon_get_cpu();
402
    if (!env)
403
        return;
404
#ifdef TARGET_I386
405
    cpu_dump_state(env, (FILE *)mon, monitor_fprintf,
406
                   X86_DUMP_FPU);
407
#else
408
    cpu_dump_state(env, (FILE *)mon, monitor_fprintf,
409
                   0);
410
#endif
411
}
412

    
413
static void print_cpu_iter(QObject *obj, void *opaque)
414
{
415
    QDict *cpu;
416
    int active = ' ';
417
    Monitor *mon = opaque;
418

    
419
    assert(qobject_type(obj) == QTYPE_QDICT);
420
    cpu = qobject_to_qdict(obj);
421

    
422
    if (strcmp(qdict_get_str(cpu, "current"), "yes") == 0)
423
        active = '*';
424

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

    
427
#if defined(TARGET_I386)
428
    monitor_printf(mon, "pc=0x" TARGET_FMT_lx,
429
                   (target_ulong) qdict_get_int(cpu, "pc"));
430
#elif defined(TARGET_PPC)
431
    monitor_printf(mon, "nip=0x" TARGET_FMT_lx,
432
                   (target_long) qdict_get_int(cpu, "nip"));
433
#elif defined(TARGET_SPARC)
434
    monitor_printf(mon, "pc=0x " TARGET_FMT_lx,
435
                   (target_long) qdict_get_int(cpu, "pc"));
436
    monitor_printf(mon, "npc=0x" TARGET_FMT_lx,
437
                   (target_long) qdict_get_int(cpu, "npc"));
438
#elif defined(TARGET_MIPS)
439
    monitor_printf(mon, "PC=0x" TARGET_FMT_lx,
440
                   (target_long) qdict_get_int(cpu, "PC"));
441
#endif
442

    
443
    if (strcmp(qdict_get_str(cpu, "halted"), "yes") == 0)
444
        monitor_printf(mon, " (halted)");
445

    
446
    monitor_printf(mon, "\n");
447
}
448

    
449
static void monitor_print_cpus(Monitor *mon, const QObject *data)
450
{
451
    QList *cpu_list;
452

    
453
    assert(qobject_type(data) == QTYPE_QLIST);
454
    cpu_list = qobject_to_qlist(data);
455
    qlist_iter(cpu_list, print_cpu_iter, mon);
456
}
457

    
458
/**
459
 * do_info_cpus(): Show CPU information
460
 *
461
 * Return a QList with a QDict for each CPU.
462
 *
463
 * For example:
464
 *
465
 * [ { "CPU": 0, "current": "yes", "pc": 0x..., "halted": "no" },
466
 *   { "CPU": 1, "current": "no",  "pc": 0x..., "halted": "yes" } ]
467
 */
468
static void do_info_cpus(Monitor *mon, QObject **ret_data)
469
{
470
    CPUState *env;
471
    QList *cpu_list;
472

    
473
    cpu_list = qlist_new();
474

    
475
    /* just to set the default cpu if not already done */
476
    mon_get_cpu();
477

    
478
    for(env = first_cpu; env != NULL; env = env->next_cpu) {
479
        const char *answer;
480
        QDict *cpu = qdict_new();
481

    
482
        cpu_synchronize_state(env);
483

    
484
        qdict_put(cpu, "CPU", qint_from_int(env->cpu_index));
485
        answer = (env == mon->mon_cpu) ? "yes" : "no";
486
        qdict_put(cpu, "current", qstring_from_str(answer));
487

    
488
#if defined(TARGET_I386)
489
        qdict_put(cpu, "pc", qint_from_int(env->eip + env->segs[R_CS].base));
490
#elif defined(TARGET_PPC)
491
        qdict_put(cpu, "nip", qint_from_int(env->nip));
492
#elif defined(TARGET_SPARC)
493
        qdict_put(cpu, "pc", qint_from_int(env->pc));
494
        qdict_put(cpu, "npc", qint_from_int(env->npc));
495
#elif defined(TARGET_MIPS)
496
        qdict_put(cpu, "PC", qint_from_int(env->active_tc.PC));
497
#endif
498
        answer = env->halted ? "yes" : "no";
499
        qdict_put(cpu, "halted", qstring_from_str(answer));
500

    
501
        qlist_append(cpu_list, cpu);
502
    }
503

    
504
    *ret_data = QOBJECT(cpu_list);
505
}
506

    
507
static void do_cpu_set(Monitor *mon, const QDict *qdict)
508
{
509
    int index = qdict_get_int(qdict, "index");
510
    if (mon_set_cpu(index) < 0)
511
        monitor_printf(mon, "Invalid CPU index\n");
512
}
513

    
514
static void do_info_jit(Monitor *mon)
515
{
516
    dump_exec_info((FILE *)mon, monitor_fprintf);
517
}
518

    
519
static void do_info_history(Monitor *mon)
520
{
521
    int i;
522
    const char *str;
523

    
524
    if (!mon->rs)
525
        return;
526
    i = 0;
527
    for(;;) {
528
        str = readline_get_history(mon->rs, i);
529
        if (!str)
530
            break;
531
        monitor_printf(mon, "%d: '%s'\n", i, str);
532
        i++;
533
    }
534
}
535

    
536
#if defined(TARGET_PPC)
537
/* XXX: not implemented in other targets */
538
static void do_info_cpu_stats(Monitor *mon)
539
{
540
    CPUState *env;
541

    
542
    env = mon_get_cpu();
543
    cpu_dump_statistics(env, (FILE *)mon, &monitor_fprintf, 0);
544
}
545
#endif
546

    
547
/**
548
 * do_quit(): Quit QEMU execution
549
 */
550
static void do_quit(Monitor *mon, const QDict *qdict, QObject **ret_data)
551
{
552
    exit(0);
553
}
554

    
555
static int eject_device(Monitor *mon, BlockDriverState *bs, int force)
556
{
557
    if (bdrv_is_inserted(bs)) {
558
        if (!force) {
559
            if (!bdrv_is_removable(bs)) {
560
                monitor_printf(mon, "device is not removable\n");
561
                return -1;
562
            }
563
            if (bdrv_is_locked(bs)) {
564
                monitor_printf(mon, "device is locked\n");
565
                return -1;
566
            }
567
        }
568
        bdrv_close(bs);
569
    }
570
    return 0;
571
}
572

    
573
static void do_eject(Monitor *mon, const QDict *qdict)
574
{
575
    BlockDriverState *bs;
576
    int force = qdict_get_int(qdict, "force");
577
    const char *filename = qdict_get_str(qdict, "filename");
578

    
579
    bs = bdrv_find(filename);
580
    if (!bs) {
581
        monitor_printf(mon, "device not found\n");
582
        return;
583
    }
584
    eject_device(mon, bs, force);
585
}
586

    
587
static void do_change_block(Monitor *mon, const char *device,
588
                            const char *filename, const char *fmt)
589
{
590
    BlockDriverState *bs;
591
    BlockDriver *drv = NULL;
592

    
593
    bs = bdrv_find(device);
594
    if (!bs) {
595
        monitor_printf(mon, "device not found\n");
596
        return;
597
    }
598
    if (fmt) {
599
        drv = bdrv_find_format(fmt);
600
        if (!drv) {
601
            monitor_printf(mon, "invalid format %s\n", fmt);
602
            return;
603
        }
604
    }
605
    if (eject_device(mon, bs, 0) < 0)
606
        return;
607
    bdrv_open2(bs, filename, 0, drv);
608
    monitor_read_bdrv_key_start(mon, bs, NULL, NULL);
609
}
610

    
611
static void change_vnc_password_cb(Monitor *mon, const char *password,
612
                                   void *opaque)
613
{
614
    if (vnc_display_password(NULL, password) < 0)
615
        monitor_printf(mon, "could not set VNC server password\n");
616

    
617
    monitor_read_command(mon, 1);
618
}
619

    
620
static void do_change_vnc(Monitor *mon, const char *target, const char *arg)
621
{
622
    if (strcmp(target, "passwd") == 0 ||
623
        strcmp(target, "password") == 0) {
624
        if (arg) {
625
            char password[9];
626
            strncpy(password, arg, sizeof(password));
627
            password[sizeof(password) - 1] = '\0';
628
            change_vnc_password_cb(mon, password, NULL);
629
        } else {
630
            monitor_read_password(mon, change_vnc_password_cb, NULL);
631
        }
632
    } else {
633
        if (vnc_display_open(NULL, target) < 0)
634
            monitor_printf(mon, "could not start VNC server on %s\n", target);
635
    }
636
}
637

    
638
static void do_change(Monitor *mon, const QDict *qdict)
639
{
640
    const char *device = qdict_get_str(qdict, "device");
641
    const char *target = qdict_get_str(qdict, "target");
642
    const char *arg = qdict_get_try_str(qdict, "arg");
643
    if (strcmp(device, "vnc") == 0) {
644
        do_change_vnc(mon, target, arg);
645
    } else {
646
        do_change_block(mon, device, target, arg);
647
    }
648
}
649

    
650
static void do_screen_dump(Monitor *mon, const QDict *qdict)
651
{
652
    vga_hw_screen_dump(qdict_get_str(qdict, "filename"));
653
}
654

    
655
static void do_logfile(Monitor *mon, const QDict *qdict)
656
{
657
    cpu_set_log_filename(qdict_get_str(qdict, "filename"));
658
}
659

    
660
static void do_log(Monitor *mon, const QDict *qdict)
661
{
662
    int mask;
663
    const char *items = qdict_get_str(qdict, "items");
664

    
665
    if (!strcmp(items, "none")) {
666
        mask = 0;
667
    } else {
668
        mask = cpu_str_to_log_mask(items);
669
        if (!mask) {
670
            help_cmd(mon, "log");
671
            return;
672
        }
673
    }
674
    cpu_set_log(mask);
675
}
676

    
677
static void do_singlestep(Monitor *mon, const QDict *qdict)
678
{
679
    const char *option = qdict_get_try_str(qdict, "option");
680
    if (!option || !strcmp(option, "on")) {
681
        singlestep = 1;
682
    } else if (!strcmp(option, "off")) {
683
        singlestep = 0;
684
    } else {
685
        monitor_printf(mon, "unexpected option %s\n", option);
686
    }
687
}
688

    
689
/**
690
 * do_stop(): Stop VM execution
691
 */
692
static void do_stop(Monitor *mon, const QDict *qdict, QObject **ret_data)
693
{
694
    vm_stop(EXCP_INTERRUPT);
695
}
696

    
697
static void encrypted_bdrv_it(void *opaque, BlockDriverState *bs);
698

    
699
struct bdrv_iterate_context {
700
    Monitor *mon;
701
    int err;
702
};
703

    
704
/**
705
 * do_cont(): Resume emulation.
706
 */
707
static void do_cont(Monitor *mon, const QDict *qdict, QObject **ret_data)
708
{
709
    struct bdrv_iterate_context context = { mon, 0 };
710

    
711
    bdrv_iterate(encrypted_bdrv_it, &context);
712
    /* only resume the vm if all keys are set and valid */
713
    if (!context.err)
714
        vm_start();
715
}
716

    
717
static void bdrv_key_cb(void *opaque, int err)
718
{
719
    Monitor *mon = opaque;
720

    
721
    /* another key was set successfully, retry to continue */
722
    if (!err)
723
        do_cont(mon, NULL, NULL);
724
}
725

    
726
static void encrypted_bdrv_it(void *opaque, BlockDriverState *bs)
727
{
728
    struct bdrv_iterate_context *context = opaque;
729

    
730
    if (!context->err && bdrv_key_required(bs)) {
731
        context->err = -EBUSY;
732
        monitor_read_bdrv_key_start(context->mon, bs, bdrv_key_cb,
733
                                    context->mon);
734
    }
735
}
736

    
737
static void do_gdbserver(Monitor *mon, const QDict *qdict)
738
{
739
    const char *device = qdict_get_try_str(qdict, "device");
740
    if (!device)
741
        device = "tcp::" DEFAULT_GDBSTUB_PORT;
742
    if (gdbserver_start(device) < 0) {
743
        monitor_printf(mon, "Could not open gdbserver on device '%s'\n",
744
                       device);
745
    } else if (strcmp(device, "none") == 0) {
746
        monitor_printf(mon, "Disabled gdbserver\n");
747
    } else {
748
        monitor_printf(mon, "Waiting for gdb connection on device '%s'\n",
749
                       device);
750
    }
751
}
752

    
753
static void do_watchdog_action(Monitor *mon, const QDict *qdict)
754
{
755
    const char *action = qdict_get_str(qdict, "action");
756
    if (select_watchdog_action(action) == -1) {
757
        monitor_printf(mon, "Unknown watchdog action '%s'\n", action);
758
    }
759
}
760

    
761
static void monitor_printc(Monitor *mon, int c)
762
{
763
    monitor_printf(mon, "'");
764
    switch(c) {
765
    case '\'':
766
        monitor_printf(mon, "\\'");
767
        break;
768
    case '\\':
769
        monitor_printf(mon, "\\\\");
770
        break;
771
    case '\n':
772
        monitor_printf(mon, "\\n");
773
        break;
774
    case '\r':
775
        monitor_printf(mon, "\\r");
776
        break;
777
    default:
778
        if (c >= 32 && c <= 126) {
779
            monitor_printf(mon, "%c", c);
780
        } else {
781
            monitor_printf(mon, "\\x%02x", c);
782
        }
783
        break;
784
    }
785
    monitor_printf(mon, "'");
786
}
787

    
788
static void memory_dump(Monitor *mon, int count, int format, int wsize,
789
                        target_phys_addr_t addr, int is_physical)
790
{
791
    CPUState *env;
792
    int nb_per_line, l, line_size, i, max_digits, len;
793
    uint8_t buf[16];
794
    uint64_t v;
795

    
796
    if (format == 'i') {
797
        int flags;
798
        flags = 0;
799
        env = mon_get_cpu();
800
        if (!env && !is_physical)
801
            return;
802
#ifdef TARGET_I386
803
        if (wsize == 2) {
804
            flags = 1;
805
        } else if (wsize == 4) {
806
            flags = 0;
807
        } else {
808
            /* as default we use the current CS size */
809
            flags = 0;
810
            if (env) {
811
#ifdef TARGET_X86_64
812
                if ((env->efer & MSR_EFER_LMA) &&
813
                    (env->segs[R_CS].flags & DESC_L_MASK))
814
                    flags = 2;
815
                else
816
#endif
817
                if (!(env->segs[R_CS].flags & DESC_B_MASK))
818
                    flags = 1;
819
            }
820
        }
821
#endif
822
        monitor_disas(mon, env, addr, count, is_physical, flags);
823
        return;
824
    }
825

    
826
    len = wsize * count;
827
    if (wsize == 1)
828
        line_size = 8;
829
    else
830
        line_size = 16;
831
    nb_per_line = line_size / wsize;
832
    max_digits = 0;
833

    
834
    switch(format) {
835
    case 'o':
836
        max_digits = (wsize * 8 + 2) / 3;
837
        break;
838
    default:
839
    case 'x':
840
        max_digits = (wsize * 8) / 4;
841
        break;
842
    case 'u':
843
    case 'd':
844
        max_digits = (wsize * 8 * 10 + 32) / 33;
845
        break;
846
    case 'c':
847
        wsize = 1;
848
        break;
849
    }
850

    
851
    while (len > 0) {
852
        if (is_physical)
853
            monitor_printf(mon, TARGET_FMT_plx ":", addr);
854
        else
855
            monitor_printf(mon, TARGET_FMT_lx ":", (target_ulong)addr);
856
        l = len;
857
        if (l > line_size)
858
            l = line_size;
859
        if (is_physical) {
860
            cpu_physical_memory_rw(addr, buf, l, 0);
861
        } else {
862
            env = mon_get_cpu();
863
            if (!env)
864
                break;
865
            if (cpu_memory_rw_debug(env, addr, buf, l, 0) < 0) {
866
                monitor_printf(mon, " Cannot access memory\n");
867
                break;
868
            }
869
        }
870
        i = 0;
871
        while (i < l) {
872
            switch(wsize) {
873
            default:
874
            case 1:
875
                v = ldub_raw(buf + i);
876
                break;
877
            case 2:
878
                v = lduw_raw(buf + i);
879
                break;
880
            case 4:
881
                v = (uint32_t)ldl_raw(buf + i);
882
                break;
883
            case 8:
884
                v = ldq_raw(buf + i);
885
                break;
886
            }
887
            monitor_printf(mon, " ");
888
            switch(format) {
889
            case 'o':
890
                monitor_printf(mon, "%#*" PRIo64, max_digits, v);
891
                break;
892
            case 'x':
893
                monitor_printf(mon, "0x%0*" PRIx64, max_digits, v);
894
                break;
895
            case 'u':
896
                monitor_printf(mon, "%*" PRIu64, max_digits, v);
897
                break;
898
            case 'd':
899
                monitor_printf(mon, "%*" PRId64, max_digits, v);
900
                break;
901
            case 'c':
902
                monitor_printc(mon, v);
903
                break;
904
            }
905
            i += wsize;
906
        }
907
        monitor_printf(mon, "\n");
908
        addr += l;
909
        len -= l;
910
    }
911
}
912

    
913
static void do_memory_dump(Monitor *mon, const QDict *qdict)
914
{
915
    int count = qdict_get_int(qdict, "count");
916
    int format = qdict_get_int(qdict, "format");
917
    int size = qdict_get_int(qdict, "size");
918
    target_long addr = qdict_get_int(qdict, "addr");
919

    
920
    memory_dump(mon, count, format, size, addr, 0);
921
}
922

    
923
static void do_physical_memory_dump(Monitor *mon, const QDict *qdict)
924
{
925
    int count = qdict_get_int(qdict, "count");
926
    int format = qdict_get_int(qdict, "format");
927
    int size = qdict_get_int(qdict, "size");
928
    target_phys_addr_t addr = qdict_get_int(qdict, "addr");
929

    
930
    memory_dump(mon, count, format, size, addr, 1);
931
}
932

    
933
static void do_print(Monitor *mon, const QDict *qdict)
934
{
935
    int format = qdict_get_int(qdict, "format");
936
    target_phys_addr_t val = qdict_get_int(qdict, "val");
937

    
938
#if TARGET_PHYS_ADDR_BITS == 32
939
    switch(format) {
940
    case 'o':
941
        monitor_printf(mon, "%#o", val);
942
        break;
943
    case 'x':
944
        monitor_printf(mon, "%#x", val);
945
        break;
946
    case 'u':
947
        monitor_printf(mon, "%u", val);
948
        break;
949
    default:
950
    case 'd':
951
        monitor_printf(mon, "%d", val);
952
        break;
953
    case 'c':
954
        monitor_printc(mon, val);
955
        break;
956
    }
957
#else
958
    switch(format) {
959
    case 'o':
960
        monitor_printf(mon, "%#" PRIo64, val);
961
        break;
962
    case 'x':
963
        monitor_printf(mon, "%#" PRIx64, val);
964
        break;
965
    case 'u':
966
        monitor_printf(mon, "%" PRIu64, val);
967
        break;
968
    default:
969
    case 'd':
970
        monitor_printf(mon, "%" PRId64, val);
971
        break;
972
    case 'c':
973
        monitor_printc(mon, val);
974
        break;
975
    }
976
#endif
977
    monitor_printf(mon, "\n");
978
}
979

    
980
static void do_memory_save(Monitor *mon, const QDict *qdict)
981
{
982
    FILE *f;
983
    uint32_t size = qdict_get_int(qdict, "size");
984
    const char *filename = qdict_get_str(qdict, "filename");
985
    target_long addr = qdict_get_int(qdict, "val");
986
    uint32_t l;
987
    CPUState *env;
988
    uint8_t buf[1024];
989

    
990
    env = mon_get_cpu();
991
    if (!env)
992
        return;
993

    
994
    f = fopen(filename, "wb");
995
    if (!f) {
996
        monitor_printf(mon, "could not open '%s'\n", filename);
997
        return;
998
    }
999
    while (size != 0) {
1000
        l = sizeof(buf);
1001
        if (l > size)
1002
            l = size;
1003
        cpu_memory_rw_debug(env, addr, buf, l, 0);
1004
        fwrite(buf, 1, l, f);
1005
        addr += l;
1006
        size -= l;
1007
    }
1008
    fclose(f);
1009
}
1010

    
1011
static void do_physical_memory_save(Monitor *mon, const QDict *qdict)
1012
{
1013
    FILE *f;
1014
    uint32_t l;
1015
    uint8_t buf[1024];
1016
    uint32_t size = qdict_get_int(qdict, "size");
1017
    const char *filename = qdict_get_str(qdict, "filename");
1018
    target_phys_addr_t addr = qdict_get_int(qdict, "val");
1019

    
1020
    f = fopen(filename, "wb");
1021
    if (!f) {
1022
        monitor_printf(mon, "could not open '%s'\n", filename);
1023
        return;
1024
    }
1025
    while (size != 0) {
1026
        l = sizeof(buf);
1027
        if (l > size)
1028
            l = size;
1029
        cpu_physical_memory_rw(addr, buf, l, 0);
1030
        fwrite(buf, 1, l, f);
1031
        fflush(f);
1032
        addr += l;
1033
        size -= l;
1034
    }
1035
    fclose(f);
1036
}
1037

    
1038
static void do_sum(Monitor *mon, const QDict *qdict)
1039
{
1040
    uint32_t addr;
1041
    uint8_t buf[1];
1042
    uint16_t sum;
1043
    uint32_t start = qdict_get_int(qdict, "start");
1044
    uint32_t size = qdict_get_int(qdict, "size");
1045

    
1046
    sum = 0;
1047
    for(addr = start; addr < (start + size); addr++) {
1048
        cpu_physical_memory_rw(addr, buf, 1, 0);
1049
        /* BSD sum algorithm ('sum' Unix command) */
1050
        sum = (sum >> 1) | (sum << 15);
1051
        sum += buf[0];
1052
    }
1053
    monitor_printf(mon, "%05d\n", sum);
1054
}
1055

    
1056
typedef struct {
1057
    int keycode;
1058
    const char *name;
1059
} KeyDef;
1060

    
1061
static const KeyDef key_defs[] = {
1062
    { 0x2a, "shift" },
1063
    { 0x36, "shift_r" },
1064

    
1065
    { 0x38, "alt" },
1066
    { 0xb8, "alt_r" },
1067
    { 0x64, "altgr" },
1068
    { 0xe4, "altgr_r" },
1069
    { 0x1d, "ctrl" },
1070
    { 0x9d, "ctrl_r" },
1071

    
1072
    { 0xdd, "menu" },
1073

    
1074
    { 0x01, "esc" },
1075

    
1076
    { 0x02, "1" },
1077
    { 0x03, "2" },
1078
    { 0x04, "3" },
1079
    { 0x05, "4" },
1080
    { 0x06, "5" },
1081
    { 0x07, "6" },
1082
    { 0x08, "7" },
1083
    { 0x09, "8" },
1084
    { 0x0a, "9" },
1085
    { 0x0b, "0" },
1086
    { 0x0c, "minus" },
1087
    { 0x0d, "equal" },
1088
    { 0x0e, "backspace" },
1089

    
1090
    { 0x0f, "tab" },
1091
    { 0x10, "q" },
1092
    { 0x11, "w" },
1093
    { 0x12, "e" },
1094
    { 0x13, "r" },
1095
    { 0x14, "t" },
1096
    { 0x15, "y" },
1097
    { 0x16, "u" },
1098
    { 0x17, "i" },
1099
    { 0x18, "o" },
1100
    { 0x19, "p" },
1101

    
1102
    { 0x1c, "ret" },
1103

    
1104
    { 0x1e, "a" },
1105
    { 0x1f, "s" },
1106
    { 0x20, "d" },
1107
    { 0x21, "f" },
1108
    { 0x22, "g" },
1109
    { 0x23, "h" },
1110
    { 0x24, "j" },
1111
    { 0x25, "k" },
1112
    { 0x26, "l" },
1113

    
1114
    { 0x2c, "z" },
1115
    { 0x2d, "x" },
1116
    { 0x2e, "c" },
1117
    { 0x2f, "v" },
1118
    { 0x30, "b" },
1119
    { 0x31, "n" },
1120
    { 0x32, "m" },
1121
    { 0x33, "comma" },
1122
    { 0x34, "dot" },
1123
    { 0x35, "slash" },
1124

    
1125
    { 0x37, "asterisk" },
1126

    
1127
    { 0x39, "spc" },
1128
    { 0x3a, "caps_lock" },
1129
    { 0x3b, "f1" },
1130
    { 0x3c, "f2" },
1131
    { 0x3d, "f3" },
1132
    { 0x3e, "f4" },
1133
    { 0x3f, "f5" },
1134
    { 0x40, "f6" },
1135
    { 0x41, "f7" },
1136
    { 0x42, "f8" },
1137
    { 0x43, "f9" },
1138
    { 0x44, "f10" },
1139
    { 0x45, "num_lock" },
1140
    { 0x46, "scroll_lock" },
1141

    
1142
    { 0xb5, "kp_divide" },
1143
    { 0x37, "kp_multiply" },
1144
    { 0x4a, "kp_subtract" },
1145
    { 0x4e, "kp_add" },
1146
    { 0x9c, "kp_enter" },
1147
    { 0x53, "kp_decimal" },
1148
    { 0x54, "sysrq" },
1149

    
1150
    { 0x52, "kp_0" },
1151
    { 0x4f, "kp_1" },
1152
    { 0x50, "kp_2" },
1153
    { 0x51, "kp_3" },
1154
    { 0x4b, "kp_4" },
1155
    { 0x4c, "kp_5" },
1156
    { 0x4d, "kp_6" },
1157
    { 0x47, "kp_7" },
1158
    { 0x48, "kp_8" },
1159
    { 0x49, "kp_9" },
1160

    
1161
    { 0x56, "<" },
1162

    
1163
    { 0x57, "f11" },
1164
    { 0x58, "f12" },
1165

    
1166
    { 0xb7, "print" },
1167

    
1168
    { 0xc7, "home" },
1169
    { 0xc9, "pgup" },
1170
    { 0xd1, "pgdn" },
1171
    { 0xcf, "end" },
1172

    
1173
    { 0xcb, "left" },
1174
    { 0xc8, "up" },
1175
    { 0xd0, "down" },
1176
    { 0xcd, "right" },
1177

    
1178
    { 0xd2, "insert" },
1179
    { 0xd3, "delete" },
1180
#if defined(TARGET_SPARC) && !defined(TARGET_SPARC64)
1181
    { 0xf0, "stop" },
1182
    { 0xf1, "again" },
1183
    { 0xf2, "props" },
1184
    { 0xf3, "undo" },
1185
    { 0xf4, "front" },
1186
    { 0xf5, "copy" },
1187
    { 0xf6, "open" },
1188
    { 0xf7, "paste" },
1189
    { 0xf8, "find" },
1190
    { 0xf9, "cut" },
1191
    { 0xfa, "lf" },
1192
    { 0xfb, "help" },
1193
    { 0xfc, "meta_l" },
1194
    { 0xfd, "meta_r" },
1195
    { 0xfe, "compose" },
1196
#endif
1197
    { 0, NULL },
1198
};
1199

    
1200
static int get_keycode(const char *key)
1201
{
1202
    const KeyDef *p;
1203
    char *endp;
1204
    int ret;
1205

    
1206
    for(p = key_defs; p->name != NULL; p++) {
1207
        if (!strcmp(key, p->name))
1208
            return p->keycode;
1209
    }
1210
    if (strstart(key, "0x", NULL)) {
1211
        ret = strtoul(key, &endp, 0);
1212
        if (*endp == '\0' && ret >= 0x01 && ret <= 0xff)
1213
            return ret;
1214
    }
1215
    return -1;
1216
}
1217

    
1218
#define MAX_KEYCODES 16
1219
static uint8_t keycodes[MAX_KEYCODES];
1220
static int nb_pending_keycodes;
1221
static QEMUTimer *key_timer;
1222

    
1223
static void release_keys(void *opaque)
1224
{
1225
    int keycode;
1226

    
1227
    while (nb_pending_keycodes > 0) {
1228
        nb_pending_keycodes--;
1229
        keycode = keycodes[nb_pending_keycodes];
1230
        if (keycode & 0x80)
1231
            kbd_put_keycode(0xe0);
1232
        kbd_put_keycode(keycode | 0x80);
1233
    }
1234
}
1235

    
1236
static void do_sendkey(Monitor *mon, const QDict *qdict)
1237
{
1238
    char keyname_buf[16];
1239
    char *separator;
1240
    int keyname_len, keycode, i;
1241
    const char *string = qdict_get_str(qdict, "string");
1242
    int has_hold_time = qdict_haskey(qdict, "hold_time");
1243
    int hold_time = qdict_get_try_int(qdict, "hold_time", -1);
1244

    
1245
    if (nb_pending_keycodes > 0) {
1246
        qemu_del_timer(key_timer);
1247
        release_keys(NULL);
1248
    }
1249
    if (!has_hold_time)
1250
        hold_time = 100;
1251
    i = 0;
1252
    while (1) {
1253
        separator = strchr(string, '-');
1254
        keyname_len = separator ? separator - string : strlen(string);
1255
        if (keyname_len > 0) {
1256
            pstrcpy(keyname_buf, sizeof(keyname_buf), string);
1257
            if (keyname_len > sizeof(keyname_buf) - 1) {
1258
                monitor_printf(mon, "invalid key: '%s...'\n", keyname_buf);
1259
                return;
1260
            }
1261
            if (i == MAX_KEYCODES) {
1262
                monitor_printf(mon, "too many keys\n");
1263
                return;
1264
            }
1265
            keyname_buf[keyname_len] = 0;
1266
            keycode = get_keycode(keyname_buf);
1267
            if (keycode < 0) {
1268
                monitor_printf(mon, "unknown key: '%s'\n", keyname_buf);
1269
                return;
1270
            }
1271
            keycodes[i++] = keycode;
1272
        }
1273
        if (!separator)
1274
            break;
1275
        string = separator + 1;
1276
    }
1277
    nb_pending_keycodes = i;
1278
    /* key down events */
1279
    for (i = 0; i < nb_pending_keycodes; i++) {
1280
        keycode = keycodes[i];
1281
        if (keycode & 0x80)
1282
            kbd_put_keycode(0xe0);
1283
        kbd_put_keycode(keycode & 0x7f);
1284
    }
1285
    /* delayed key up events */
1286
    qemu_mod_timer(key_timer, qemu_get_clock(vm_clock) +
1287
                   muldiv64(get_ticks_per_sec(), hold_time, 1000));
1288
}
1289

    
1290
static int mouse_button_state;
1291

    
1292
static void do_mouse_move(Monitor *mon, const QDict *qdict)
1293
{
1294
    int dx, dy, dz;
1295
    const char *dx_str = qdict_get_str(qdict, "dx_str");
1296
    const char *dy_str = qdict_get_str(qdict, "dy_str");
1297
    const char *dz_str = qdict_get_try_str(qdict, "dz_str");
1298
    dx = strtol(dx_str, NULL, 0);
1299
    dy = strtol(dy_str, NULL, 0);
1300
    dz = 0;
1301
    if (dz_str)
1302
        dz = strtol(dz_str, NULL, 0);
1303
    kbd_mouse_event(dx, dy, dz, mouse_button_state);
1304
}
1305

    
1306
static void do_mouse_button(Monitor *mon, const QDict *qdict)
1307
{
1308
    int button_state = qdict_get_int(qdict, "button_state");
1309
    mouse_button_state = button_state;
1310
    kbd_mouse_event(0, 0, 0, mouse_button_state);
1311
}
1312

    
1313
static void do_ioport_read(Monitor *mon, const QDict *qdict)
1314
{
1315
    int size = qdict_get_int(qdict, "size");
1316
    int addr = qdict_get_int(qdict, "addr");
1317
    int has_index = qdict_haskey(qdict, "index");
1318
    uint32_t val;
1319
    int suffix;
1320

    
1321
    if (has_index) {
1322
        int index = qdict_get_int(qdict, "index");
1323
        cpu_outb(addr & IOPORTS_MASK, index & 0xff);
1324
        addr++;
1325
    }
1326
    addr &= 0xffff;
1327

    
1328
    switch(size) {
1329
    default:
1330
    case 1:
1331
        val = cpu_inb(addr);
1332
        suffix = 'b';
1333
        break;
1334
    case 2:
1335
        val = cpu_inw(addr);
1336
        suffix = 'w';
1337
        break;
1338
    case 4:
1339
        val = cpu_inl(addr);
1340
        suffix = 'l';
1341
        break;
1342
    }
1343
    monitor_printf(mon, "port%c[0x%04x] = %#0*x\n",
1344
                   suffix, addr, size * 2, val);
1345
}
1346

    
1347
static void do_ioport_write(Monitor *mon, const QDict *qdict)
1348
{
1349
    int size = qdict_get_int(qdict, "size");
1350
    int addr = qdict_get_int(qdict, "addr");
1351
    int val = qdict_get_int(qdict, "val");
1352

    
1353
    addr &= IOPORTS_MASK;
1354

    
1355
    switch (size) {
1356
    default:
1357
    case 1:
1358
        cpu_outb(addr, val);
1359
        break;
1360
    case 2:
1361
        cpu_outw(addr, val);
1362
        break;
1363
    case 4:
1364
        cpu_outl(addr, val);
1365
        break;
1366
    }
1367
}
1368

    
1369
static void do_boot_set(Monitor *mon, const QDict *qdict)
1370
{
1371
    int res;
1372
    const char *bootdevice = qdict_get_str(qdict, "bootdevice");
1373

    
1374
    res = qemu_boot_set(bootdevice);
1375
    if (res == 0) {
1376
        monitor_printf(mon, "boot device list now set to %s\n", bootdevice);
1377
    } else if (res > 0) {
1378
        monitor_printf(mon, "setting boot device list failed\n");
1379
    } else {
1380
        monitor_printf(mon, "no function defined to set boot device list for "
1381
                       "this architecture\n");
1382
    }
1383
}
1384

    
1385
/**
1386
 * do_system_reset(): Issue a machine reset
1387
 */
1388
static void do_system_reset(Monitor *mon, const QDict *qdict,
1389
                            QObject **ret_data)
1390
{
1391
    qemu_system_reset_request();
1392
}
1393

    
1394
/**
1395
 * do_system_powerdown(): Issue a machine powerdown
1396
 */
1397
static void do_system_powerdown(Monitor *mon, const QDict *qdict,
1398
                                QObject **ret_data)
1399
{
1400
    qemu_system_powerdown_request();
1401
}
1402

    
1403
#if defined(TARGET_I386)
1404
static void print_pte(Monitor *mon, uint32_t addr, uint32_t pte, uint32_t mask)
1405
{
1406
    monitor_printf(mon, "%08x: %08x %c%c%c%c%c%c%c%c\n",
1407
                   addr,
1408
                   pte & mask,
1409
                   pte & PG_GLOBAL_MASK ? 'G' : '-',
1410
                   pte & PG_PSE_MASK ? 'P' : '-',
1411
                   pte & PG_DIRTY_MASK ? 'D' : '-',
1412
                   pte & PG_ACCESSED_MASK ? 'A' : '-',
1413
                   pte & PG_PCD_MASK ? 'C' : '-',
1414
                   pte & PG_PWT_MASK ? 'T' : '-',
1415
                   pte & PG_USER_MASK ? 'U' : '-',
1416
                   pte & PG_RW_MASK ? 'W' : '-');
1417
}
1418

    
1419
static void tlb_info(Monitor *mon)
1420
{
1421
    CPUState *env;
1422
    int l1, l2;
1423
    uint32_t pgd, pde, pte;
1424

    
1425
    env = mon_get_cpu();
1426
    if (!env)
1427
        return;
1428

    
1429
    if (!(env->cr[0] & CR0_PG_MASK)) {
1430
        monitor_printf(mon, "PG disabled\n");
1431
        return;
1432
    }
1433
    pgd = env->cr[3] & ~0xfff;
1434
    for(l1 = 0; l1 < 1024; l1++) {
1435
        cpu_physical_memory_read(pgd + l1 * 4, (uint8_t *)&pde, 4);
1436
        pde = le32_to_cpu(pde);
1437
        if (pde & PG_PRESENT_MASK) {
1438
            if ((pde & PG_PSE_MASK) && (env->cr[4] & CR4_PSE_MASK)) {
1439
                print_pte(mon, (l1 << 22), pde, ~((1 << 20) - 1));
1440
            } else {
1441
                for(l2 = 0; l2 < 1024; l2++) {
1442
                    cpu_physical_memory_read((pde & ~0xfff) + l2 * 4,
1443
                                             (uint8_t *)&pte, 4);
1444
                    pte = le32_to_cpu(pte);
1445
                    if (pte & PG_PRESENT_MASK) {
1446
                        print_pte(mon, (l1 << 22) + (l2 << 12),
1447
                                  pte & ~PG_PSE_MASK,
1448
                                  ~0xfff);
1449
                    }
1450
                }
1451
            }
1452
        }
1453
    }
1454
}
1455

    
1456
static void mem_print(Monitor *mon, uint32_t *pstart, int *plast_prot,
1457
                      uint32_t end, int prot)
1458
{
1459
    int prot1;
1460
    prot1 = *plast_prot;
1461
    if (prot != prot1) {
1462
        if (*pstart != -1) {
1463
            monitor_printf(mon, "%08x-%08x %08x %c%c%c\n",
1464
                           *pstart, end, end - *pstart,
1465
                           prot1 & PG_USER_MASK ? 'u' : '-',
1466
                           'r',
1467
                           prot1 & PG_RW_MASK ? 'w' : '-');
1468
        }
1469
        if (prot != 0)
1470
            *pstart = end;
1471
        else
1472
            *pstart = -1;
1473
        *plast_prot = prot;
1474
    }
1475
}
1476

    
1477
static void mem_info(Monitor *mon)
1478
{
1479
    CPUState *env;
1480
    int l1, l2, prot, last_prot;
1481
    uint32_t pgd, pde, pte, start, end;
1482

    
1483
    env = mon_get_cpu();
1484
    if (!env)
1485
        return;
1486

    
1487
    if (!(env->cr[0] & CR0_PG_MASK)) {
1488
        monitor_printf(mon, "PG disabled\n");
1489
        return;
1490
    }
1491
    pgd = env->cr[3] & ~0xfff;
1492
    last_prot = 0;
1493
    start = -1;
1494
    for(l1 = 0; l1 < 1024; l1++) {
1495
        cpu_physical_memory_read(pgd + l1 * 4, (uint8_t *)&pde, 4);
1496
        pde = le32_to_cpu(pde);
1497
        end = l1 << 22;
1498
        if (pde & PG_PRESENT_MASK) {
1499
            if ((pde & PG_PSE_MASK) && (env->cr[4] & CR4_PSE_MASK)) {
1500
                prot = pde & (PG_USER_MASK | PG_RW_MASK | PG_PRESENT_MASK);
1501
                mem_print(mon, &start, &last_prot, end, prot);
1502
            } else {
1503
                for(l2 = 0; l2 < 1024; l2++) {
1504
                    cpu_physical_memory_read((pde & ~0xfff) + l2 * 4,
1505
                                             (uint8_t *)&pte, 4);
1506
                    pte = le32_to_cpu(pte);
1507
                    end = (l1 << 22) + (l2 << 12);
1508
                    if (pte & PG_PRESENT_MASK) {
1509
                        prot = pte & (PG_USER_MASK | PG_RW_MASK | PG_PRESENT_MASK);
1510
                    } else {
1511
                        prot = 0;
1512
                    }
1513
                    mem_print(mon, &start, &last_prot, end, prot);
1514
                }
1515
            }
1516
        } else {
1517
            prot = 0;
1518
            mem_print(mon, &start, &last_prot, end, prot);
1519
        }
1520
    }
1521
}
1522
#endif
1523

    
1524
#if defined(TARGET_SH4)
1525

    
1526
static void print_tlb(Monitor *mon, int idx, tlb_t *tlb)
1527
{
1528
    monitor_printf(mon, " tlb%i:\t"
1529
                   "asid=%hhu vpn=%x\tppn=%x\tsz=%hhu size=%u\t"
1530
                   "v=%hhu shared=%hhu cached=%hhu prot=%hhu "
1531
                   "dirty=%hhu writethrough=%hhu\n",
1532
                   idx,
1533
                   tlb->asid, tlb->vpn, tlb->ppn, tlb->sz, tlb->size,
1534
                   tlb->v, tlb->sh, tlb->c, tlb->pr,
1535
                   tlb->d, tlb->wt);
1536
}
1537

    
1538
static void tlb_info(Monitor *mon)
1539
{
1540
    CPUState *env = mon_get_cpu();
1541
    int i;
1542

    
1543
    monitor_printf (mon, "ITLB:\n");
1544
    for (i = 0 ; i < ITLB_SIZE ; i++)
1545
        print_tlb (mon, i, &env->itlb[i]);
1546
    monitor_printf (mon, "UTLB:\n");
1547
    for (i = 0 ; i < UTLB_SIZE ; i++)
1548
        print_tlb (mon, i, &env->utlb[i]);
1549
}
1550

    
1551
#endif
1552

    
1553
static void do_info_kvm(Monitor *mon)
1554
{
1555
#ifdef CONFIG_KVM
1556
    monitor_printf(mon, "kvm support: ");
1557
    if (kvm_enabled())
1558
        monitor_printf(mon, "enabled\n");
1559
    else
1560
        monitor_printf(mon, "disabled\n");
1561
#else
1562
    monitor_printf(mon, "kvm support: not compiled\n");
1563
#endif
1564
}
1565

    
1566
static void do_info_numa(Monitor *mon)
1567
{
1568
    int i;
1569
    CPUState *env;
1570

    
1571
    monitor_printf(mon, "%d nodes\n", nb_numa_nodes);
1572
    for (i = 0; i < nb_numa_nodes; i++) {
1573
        monitor_printf(mon, "node %d cpus:", i);
1574
        for (env = first_cpu; env != NULL; env = env->next_cpu) {
1575
            if (env->numa_node == i) {
1576
                monitor_printf(mon, " %d", env->cpu_index);
1577
            }
1578
        }
1579
        monitor_printf(mon, "\n");
1580
        monitor_printf(mon, "node %d size: %" PRId64 " MB\n", i,
1581
            node_mem[i] >> 20);
1582
    }
1583
}
1584

    
1585
#ifdef CONFIG_PROFILER
1586

    
1587
int64_t qemu_time;
1588
int64_t dev_time;
1589

    
1590
static void do_info_profile(Monitor *mon)
1591
{
1592
    int64_t total;
1593
    total = qemu_time;
1594
    if (total == 0)
1595
        total = 1;
1596
    monitor_printf(mon, "async time  %" PRId64 " (%0.3f)\n",
1597
                   dev_time, dev_time / (double)get_ticks_per_sec());
1598
    monitor_printf(mon, "qemu time   %" PRId64 " (%0.3f)\n",
1599
                   qemu_time, qemu_time / (double)get_ticks_per_sec());
1600
    qemu_time = 0;
1601
    dev_time = 0;
1602
}
1603
#else
1604
static void do_info_profile(Monitor *mon)
1605
{
1606
    monitor_printf(mon, "Internal profiler not compiled\n");
1607
}
1608
#endif
1609

    
1610
/* Capture support */
1611
static QLIST_HEAD (capture_list_head, CaptureState) capture_head;
1612

    
1613
static void do_info_capture(Monitor *mon)
1614
{
1615
    int i;
1616
    CaptureState *s;
1617

    
1618
    for (s = capture_head.lh_first, i = 0; s; s = s->entries.le_next, ++i) {
1619
        monitor_printf(mon, "[%d]: ", i);
1620
        s->ops.info (s->opaque);
1621
    }
1622
}
1623

    
1624
#ifdef HAS_AUDIO
1625
static void do_stop_capture(Monitor *mon, const QDict *qdict)
1626
{
1627
    int i;
1628
    int n = qdict_get_int(qdict, "n");
1629
    CaptureState *s;
1630

    
1631
    for (s = capture_head.lh_first, i = 0; s; s = s->entries.le_next, ++i) {
1632
        if (i == n) {
1633
            s->ops.destroy (s->opaque);
1634
            QLIST_REMOVE (s, entries);
1635
            qemu_free (s);
1636
            return;
1637
        }
1638
    }
1639
}
1640

    
1641
static void do_wav_capture(Monitor *mon, const QDict *qdict)
1642
{
1643
    const char *path = qdict_get_str(qdict, "path");
1644
    int has_freq = qdict_haskey(qdict, "freq");
1645
    int freq = qdict_get_try_int(qdict, "freq", -1);
1646
    int has_bits = qdict_haskey(qdict, "bits");
1647
    int bits = qdict_get_try_int(qdict, "bits", -1);
1648
    int has_channels = qdict_haskey(qdict, "nchannels");
1649
    int nchannels = qdict_get_try_int(qdict, "nchannels", -1);
1650
    CaptureState *s;
1651

    
1652
    s = qemu_mallocz (sizeof (*s));
1653

    
1654
    freq = has_freq ? freq : 44100;
1655
    bits = has_bits ? bits : 16;
1656
    nchannels = has_channels ? nchannels : 2;
1657

    
1658
    if (wav_start_capture (s, path, freq, bits, nchannels)) {
1659
        monitor_printf(mon, "Faied to add wave capture\n");
1660
        qemu_free (s);
1661
    }
1662
    QLIST_INSERT_HEAD (&capture_head, s, entries);
1663
}
1664
#endif
1665

    
1666
#if defined(TARGET_I386)
1667
static void do_inject_nmi(Monitor *mon, const QDict *qdict)
1668
{
1669
    CPUState *env;
1670
    int cpu_index = qdict_get_int(qdict, "cpu_index");
1671

    
1672
    for (env = first_cpu; env != NULL; env = env->next_cpu)
1673
        if (env->cpu_index == cpu_index) {
1674
            cpu_interrupt(env, CPU_INTERRUPT_NMI);
1675
            break;
1676
        }
1677
}
1678
#endif
1679

    
1680
static void do_info_status(Monitor *mon)
1681
{
1682
    if (vm_running) {
1683
        if (singlestep) {
1684
            monitor_printf(mon, "VM status: running (single step mode)\n");
1685
        } else {
1686
            monitor_printf(mon, "VM status: running\n");
1687
        }
1688
    } else
1689
       monitor_printf(mon, "VM status: paused\n");
1690
}
1691

    
1692
/**
1693
 * do_balloon(): Request VM to change its memory allocation
1694
 */
1695
static void do_balloon(Monitor *mon, const QDict *qdict, QObject **ret_data)
1696
{
1697
    int value = qdict_get_int(qdict, "value");
1698
    ram_addr_t target = value;
1699
    qemu_balloon(target << 20);
1700
}
1701

    
1702
static void monitor_print_balloon(Monitor *mon, const QObject *data)
1703
{
1704
    monitor_printf(mon, "balloon: actual=%d\n",
1705
                                     (int)qint_get_int(qobject_to_qint(data)));
1706
}
1707

    
1708
/**
1709
 * do_info_balloon(): Balloon information
1710
 */
1711
static void do_info_balloon(Monitor *mon, QObject **ret_data)
1712
{
1713
    ram_addr_t actual;
1714

    
1715
    actual = qemu_balloon_status();
1716
    if (kvm_enabled() && !kvm_has_sync_mmu())
1717
        monitor_printf(mon, "Using KVM without synchronous MMU, "
1718
                       "ballooning disabled\n");
1719
    else if (actual == 0)
1720
        monitor_printf(mon, "Ballooning not activated in VM\n");
1721
    else
1722
        *ret_data = QOBJECT(qint_from_int((int)(actual >> 20)));
1723
}
1724

    
1725
static qemu_acl *find_acl(Monitor *mon, const char *name)
1726
{
1727
    qemu_acl *acl = qemu_acl_find(name);
1728

    
1729
    if (!acl) {
1730
        monitor_printf(mon, "acl: unknown list '%s'\n", name);
1731
    }
1732
    return acl;
1733
}
1734

    
1735
static void do_acl_show(Monitor *mon, const QDict *qdict)
1736
{
1737
    const char *aclname = qdict_get_str(qdict, "aclname");
1738
    qemu_acl *acl = find_acl(mon, aclname);
1739
    qemu_acl_entry *entry;
1740
    int i = 0;
1741

    
1742
    if (acl) {
1743
        monitor_printf(mon, "policy: %s\n",
1744
                       acl->defaultDeny ? "deny" : "allow");
1745
        QTAILQ_FOREACH(entry, &acl->entries, next) {
1746
            i++;
1747
            monitor_printf(mon, "%d: %s %s\n", i,
1748
                           entry->deny ? "deny" : "allow", entry->match);
1749
        }
1750
    }
1751
}
1752

    
1753
static void do_acl_reset(Monitor *mon, const QDict *qdict)
1754
{
1755
    const char *aclname = qdict_get_str(qdict, "aclname");
1756
    qemu_acl *acl = find_acl(mon, aclname);
1757

    
1758
    if (acl) {
1759
        qemu_acl_reset(acl);
1760
        monitor_printf(mon, "acl: removed all rules\n");
1761
    }
1762
}
1763

    
1764
static void do_acl_policy(Monitor *mon, const QDict *qdict)
1765
{
1766
    const char *aclname = qdict_get_str(qdict, "aclname");
1767
    const char *policy = qdict_get_str(qdict, "policy");
1768
    qemu_acl *acl = find_acl(mon, aclname);
1769

    
1770
    if (acl) {
1771
        if (strcmp(policy, "allow") == 0) {
1772
            acl->defaultDeny = 0;
1773
            monitor_printf(mon, "acl: policy set to 'allow'\n");
1774
        } else if (strcmp(policy, "deny") == 0) {
1775
            acl->defaultDeny = 1;
1776
            monitor_printf(mon, "acl: policy set to 'deny'\n");
1777
        } else {
1778
            monitor_printf(mon, "acl: unknown policy '%s', "
1779
                           "expected 'deny' or 'allow'\n", policy);
1780
        }
1781
    }
1782
}
1783

    
1784
static void do_acl_add(Monitor *mon, const QDict *qdict)
1785
{
1786
    const char *aclname = qdict_get_str(qdict, "aclname");
1787
    const char *match = qdict_get_str(qdict, "match");
1788
    const char *policy = qdict_get_str(qdict, "policy");
1789
    int has_index = qdict_haskey(qdict, "index");
1790
    int index = qdict_get_try_int(qdict, "index", -1);
1791
    qemu_acl *acl = find_acl(mon, aclname);
1792
    int deny, ret;
1793

    
1794
    if (acl) {
1795
        if (strcmp(policy, "allow") == 0) {
1796
            deny = 0;
1797
        } else if (strcmp(policy, "deny") == 0) {
1798
            deny = 1;
1799
        } else {
1800
            monitor_printf(mon, "acl: unknown policy '%s', "
1801
                           "expected 'deny' or 'allow'\n", policy);
1802
            return;
1803
        }
1804
        if (has_index)
1805
            ret = qemu_acl_insert(acl, deny, match, index);
1806
        else
1807
            ret = qemu_acl_append(acl, deny, match);
1808
        if (ret < 0)
1809
            monitor_printf(mon, "acl: unable to add acl entry\n");
1810
        else
1811
            monitor_printf(mon, "acl: added rule at position %d\n", ret);
1812
    }
1813
}
1814

    
1815
static void do_acl_remove(Monitor *mon, const QDict *qdict)
1816
{
1817
    const char *aclname = qdict_get_str(qdict, "aclname");
1818
    const char *match = qdict_get_str(qdict, "match");
1819
    qemu_acl *acl = find_acl(mon, aclname);
1820
    int ret;
1821

    
1822
    if (acl) {
1823
        ret = qemu_acl_remove(acl, match);
1824
        if (ret < 0)
1825
            monitor_printf(mon, "acl: no matching acl entry\n");
1826
        else
1827
            monitor_printf(mon, "acl: removed rule at position %d\n", ret);
1828
    }
1829
}
1830

    
1831
#if defined(TARGET_I386)
1832
static void do_inject_mce(Monitor *mon, const QDict *qdict)
1833
{
1834
    CPUState *cenv;
1835
    int cpu_index = qdict_get_int(qdict, "cpu_index");
1836
    int bank = qdict_get_int(qdict, "bank");
1837
    uint64_t status = qdict_get_int(qdict, "status");
1838
    uint64_t mcg_status = qdict_get_int(qdict, "mcg_status");
1839
    uint64_t addr = qdict_get_int(qdict, "addr");
1840
    uint64_t misc = qdict_get_int(qdict, "misc");
1841

    
1842
    for (cenv = first_cpu; cenv != NULL; cenv = cenv->next_cpu)
1843
        if (cenv->cpu_index == cpu_index && cenv->mcg_cap) {
1844
            cpu_inject_x86_mce(cenv, bank, status, mcg_status, addr, misc);
1845
            break;
1846
        }
1847
}
1848
#endif
1849

    
1850
static void do_getfd(Monitor *mon, const QDict *qdict)
1851
{
1852
    const char *fdname = qdict_get_str(qdict, "fdname");
1853
    mon_fd_t *monfd;
1854
    int fd;
1855

    
1856
    fd = qemu_chr_get_msgfd(mon->chr);
1857
    if (fd == -1) {
1858
        monitor_printf(mon, "getfd: no file descriptor supplied via SCM_RIGHTS\n");
1859
        return;
1860
    }
1861

    
1862
    if (qemu_isdigit(fdname[0])) {
1863
        monitor_printf(mon, "getfd: monitor names may not begin with a number\n");
1864
        return;
1865
    }
1866

    
1867
    fd = dup(fd);
1868
    if (fd == -1) {
1869
        monitor_printf(mon, "Failed to dup() file descriptor: %s\n",
1870
                       strerror(errno));
1871
        return;
1872
    }
1873

    
1874
    QLIST_FOREACH(monfd, &mon->fds, next) {
1875
        if (strcmp(monfd->name, fdname) != 0) {
1876
            continue;
1877
        }
1878

    
1879
        close(monfd->fd);
1880
        monfd->fd = fd;
1881
        return;
1882
    }
1883

    
1884
    monfd = qemu_mallocz(sizeof(mon_fd_t));
1885
    monfd->name = qemu_strdup(fdname);
1886
    monfd->fd = fd;
1887

    
1888
    QLIST_INSERT_HEAD(&mon->fds, monfd, next);
1889
}
1890

    
1891
static void do_closefd(Monitor *mon, const QDict *qdict)
1892
{
1893
    const char *fdname = qdict_get_str(qdict, "fdname");
1894
    mon_fd_t *monfd;
1895

    
1896
    QLIST_FOREACH(monfd, &mon->fds, next) {
1897
        if (strcmp(monfd->name, fdname) != 0) {
1898
            continue;
1899
        }
1900

    
1901
        QLIST_REMOVE(monfd, next);
1902
        close(monfd->fd);
1903
        qemu_free(monfd->name);
1904
        qemu_free(monfd);
1905
        return;
1906
    }
1907

    
1908
    monitor_printf(mon, "Failed to find file descriptor named %s\n",
1909
                   fdname);
1910
}
1911

    
1912
static void do_loadvm(Monitor *mon, const QDict *qdict)
1913
{
1914
    int saved_vm_running  = vm_running;
1915
    const char *name = qdict_get_str(qdict, "name");
1916

    
1917
    vm_stop(0);
1918

    
1919
    if (load_vmstate(mon, name) >= 0 && saved_vm_running)
1920
        vm_start();
1921
}
1922

    
1923
int monitor_get_fd(Monitor *mon, const char *fdname)
1924
{
1925
    mon_fd_t *monfd;
1926

    
1927
    QLIST_FOREACH(monfd, &mon->fds, next) {
1928
        int fd;
1929

    
1930
        if (strcmp(monfd->name, fdname) != 0) {
1931
            continue;
1932
        }
1933

    
1934
        fd = monfd->fd;
1935

    
1936
        /* caller takes ownership of fd */
1937
        QLIST_REMOVE(monfd, next);
1938
        qemu_free(monfd->name);
1939
        qemu_free(monfd);
1940

    
1941
        return fd;
1942
    }
1943

    
1944
    return -1;
1945
}
1946

    
1947
static const mon_cmd_t mon_cmds[] = {
1948
#include "qemu-monitor.h"
1949
    { NULL, NULL, },
1950
};
1951

    
1952
/* Please update qemu-monitor.hx when adding or changing commands */
1953
static const mon_cmd_t info_cmds[] = {
1954
    {
1955
        .name       = "version",
1956
        .args_type  = "",
1957
        .params     = "",
1958
        .help       = "show the version of QEMU",
1959
        .user_print = monitor_print_qobject,
1960
        .mhandler.info_new = do_info_version,
1961
    },
1962
    {
1963
        .name       = "network",
1964
        .args_type  = "",
1965
        .params     = "",
1966
        .help       = "show the network state",
1967
        .mhandler.info = do_info_network,
1968
    },
1969
    {
1970
        .name       = "chardev",
1971
        .args_type  = "",
1972
        .params     = "",
1973
        .help       = "show the character devices",
1974
        .mhandler.info = qemu_chr_info,
1975
    },
1976
    {
1977
        .name       = "block",
1978
        .args_type  = "",
1979
        .params     = "",
1980
        .help       = "show the block devices",
1981
        .mhandler.info = bdrv_info,
1982
    },
1983
    {
1984
        .name       = "blockstats",
1985
        .args_type  = "",
1986
        .params     = "",
1987
        .help       = "show block device statistics",
1988
        .mhandler.info = bdrv_info_stats,
1989
    },
1990
    {
1991
        .name       = "registers",
1992
        .args_type  = "",
1993
        .params     = "",
1994
        .help       = "show the cpu registers",
1995
        .mhandler.info = do_info_registers,
1996
    },
1997
    {
1998
        .name       = "cpus",
1999
        .args_type  = "",
2000
        .params     = "",
2001
        .help       = "show infos for each CPU",
2002
        .user_print = monitor_print_cpus,
2003
        .mhandler.info_new = do_info_cpus,
2004
    },
2005
    {
2006
        .name       = "history",
2007
        .args_type  = "",
2008
        .params     = "",
2009
        .help       = "show the command line history",
2010
        .mhandler.info = do_info_history,
2011
    },
2012
    {
2013
        .name       = "irq",
2014
        .args_type  = "",
2015
        .params     = "",
2016
        .help       = "show the interrupts statistics (if available)",
2017
        .mhandler.info = irq_info,
2018
    },
2019
    {
2020
        .name       = "pic",
2021
        .args_type  = "",
2022
        .params     = "",
2023
        .help       = "show i8259 (PIC) state",
2024
        .mhandler.info = pic_info,
2025
    },
2026
    {
2027
        .name       = "pci",
2028
        .args_type  = "",
2029
        .params     = "",
2030
        .help       = "show PCI info",
2031
        .mhandler.info = pci_info,
2032
    },
2033
#if defined(TARGET_I386) || defined(TARGET_SH4)
2034
    {
2035
        .name       = "tlb",
2036
        .args_type  = "",
2037
        .params     = "",
2038
        .help       = "show virtual to physical memory mappings",
2039
        .mhandler.info = tlb_info,
2040
    },
2041
#endif
2042
#if defined(TARGET_I386)
2043
    {
2044
        .name       = "mem",
2045
        .args_type  = "",
2046
        .params     = "",
2047
        .help       = "show the active virtual memory mappings",
2048
        .mhandler.info = mem_info,
2049
    },
2050
    {
2051
        .name       = "hpet",
2052
        .args_type  = "",
2053
        .params     = "",
2054
        .help       = "show state of HPET",
2055
        .mhandler.info = do_info_hpet,
2056
    },
2057
#endif
2058
    {
2059
        .name       = "jit",
2060
        .args_type  = "",
2061
        .params     = "",
2062
        .help       = "show dynamic compiler info",
2063
        .mhandler.info = do_info_jit,
2064
    },
2065
    {
2066
        .name       = "kvm",
2067
        .args_type  = "",
2068
        .params     = "",
2069
        .help       = "show KVM information",
2070
        .mhandler.info = do_info_kvm,
2071
    },
2072
    {
2073
        .name       = "numa",
2074
        .args_type  = "",
2075
        .params     = "",
2076
        .help       = "show NUMA information",
2077
        .mhandler.info = do_info_numa,
2078
    },
2079
    {
2080
        .name       = "usb",
2081
        .args_type  = "",
2082
        .params     = "",
2083
        .help       = "show guest USB devices",
2084
        .mhandler.info = usb_info,
2085
    },
2086
    {
2087
        .name       = "usbhost",
2088
        .args_type  = "",
2089
        .params     = "",
2090
        .help       = "show host USB devices",
2091
        .mhandler.info = usb_host_info,
2092
    },
2093
    {
2094
        .name       = "profile",
2095
        .args_type  = "",
2096
        .params     = "",
2097
        .help       = "show profiling information",
2098
        .mhandler.info = do_info_profile,
2099
    },
2100
    {
2101
        .name       = "capture",
2102
        .args_type  = "",
2103
        .params     = "",
2104
        .help       = "show capture information",
2105
        .mhandler.info = do_info_capture,
2106
    },
2107
    {
2108
        .name       = "snapshots",
2109
        .args_type  = "",
2110
        .params     = "",
2111
        .help       = "show the currently saved VM snapshots",
2112
        .mhandler.info = do_info_snapshots,
2113
    },
2114
    {
2115
        .name       = "status",
2116
        .args_type  = "",
2117
        .params     = "",
2118
        .help       = "show the current VM status (running|paused)",
2119
        .mhandler.info = do_info_status,
2120
    },
2121
    {
2122
        .name       = "pcmcia",
2123
        .args_type  = "",
2124
        .params     = "",
2125
        .help       = "show guest PCMCIA status",
2126
        .mhandler.info = pcmcia_info,
2127
    },
2128
    {
2129
        .name       = "mice",
2130
        .args_type  = "",
2131
        .params     = "",
2132
        .help       = "show which guest mouse is receiving events",
2133
        .mhandler.info = do_info_mice,
2134
    },
2135
    {
2136
        .name       = "vnc",
2137
        .args_type  = "",
2138
        .params     = "",
2139
        .help       = "show the vnc server status",
2140
        .mhandler.info = do_info_vnc,
2141
    },
2142
    {
2143
        .name       = "name",
2144
        .args_type  = "",
2145
        .params     = "",
2146
        .help       = "show the current VM name",
2147
        .mhandler.info = do_info_name,
2148
    },
2149
    {
2150
        .name       = "uuid",
2151
        .args_type  = "",
2152
        .params     = "",
2153
        .help       = "show the current VM UUID",
2154
        .mhandler.info = do_info_uuid,
2155
    },
2156
#if defined(TARGET_PPC)
2157
    {
2158
        .name       = "cpustats",
2159
        .args_type  = "",
2160
        .params     = "",
2161
        .help       = "show CPU statistics",
2162
        .mhandler.info = do_info_cpu_stats,
2163
    },
2164
#endif
2165
#if defined(CONFIG_SLIRP)
2166
    {
2167
        .name       = "usernet",
2168
        .args_type  = "",
2169
        .params     = "",
2170
        .help       = "show user network stack connection states",
2171
        .mhandler.info = do_info_usernet,
2172
    },
2173
#endif
2174
    {
2175
        .name       = "migrate",
2176
        .args_type  = "",
2177
        .params     = "",
2178
        .help       = "show migration status",
2179
        .mhandler.info = do_info_migrate,
2180
    },
2181
    {
2182
        .name       = "balloon",
2183
        .args_type  = "",
2184
        .params     = "",
2185
        .help       = "show balloon information",
2186
        .user_print = monitor_print_balloon,
2187
        .mhandler.info_new = do_info_balloon,
2188
    },
2189
    {
2190
        .name       = "qtree",
2191
        .args_type  = "",
2192
        .params     = "",
2193
        .help       = "show device tree",
2194
        .mhandler.info = do_info_qtree,
2195
    },
2196
    {
2197
        .name       = "qdm",
2198
        .args_type  = "",
2199
        .params     = "",
2200
        .help       = "show qdev device model list",
2201
        .mhandler.info = do_info_qdm,
2202
    },
2203
    {
2204
        .name       = "roms",
2205
        .args_type  = "",
2206
        .params     = "",
2207
        .help       = "show roms",
2208
        .mhandler.info = do_info_roms,
2209
    },
2210
    {
2211
        .name       = NULL,
2212
    },
2213
};
2214

    
2215
/*******************************************************************/
2216

    
2217
static const char *pch;
2218
static jmp_buf expr_env;
2219

    
2220
#define MD_TLONG 0
2221
#define MD_I32   1
2222

    
2223
typedef struct MonitorDef {
2224
    const char *name;
2225
    int offset;
2226
    target_long (*get_value)(const struct MonitorDef *md, int val);
2227
    int type;
2228
} MonitorDef;
2229

    
2230
#if defined(TARGET_I386)
2231
static target_long monitor_get_pc (const struct MonitorDef *md, int val)
2232
{
2233
    CPUState *env = mon_get_cpu();
2234
    if (!env)
2235
        return 0;
2236
    return env->eip + env->segs[R_CS].base;
2237
}
2238
#endif
2239

    
2240
#if defined(TARGET_PPC)
2241
static target_long monitor_get_ccr (const struct MonitorDef *md, int val)
2242
{
2243
    CPUState *env = mon_get_cpu();
2244
    unsigned int u;
2245
    int i;
2246

    
2247
    if (!env)
2248
        return 0;
2249

    
2250
    u = 0;
2251
    for (i = 0; i < 8; i++)
2252
        u |= env->crf[i] << (32 - (4 * i));
2253

    
2254
    return u;
2255
}
2256

    
2257
static target_long monitor_get_msr (const struct MonitorDef *md, int val)
2258
{
2259
    CPUState *env = mon_get_cpu();
2260
    if (!env)
2261
        return 0;
2262
    return env->msr;
2263
}
2264

    
2265
static target_long monitor_get_xer (const struct MonitorDef *md, int val)
2266
{
2267
    CPUState *env = mon_get_cpu();
2268
    if (!env)
2269
        return 0;
2270
    return env->xer;
2271
}
2272

    
2273
static target_long monitor_get_decr (const struct MonitorDef *md, int val)
2274
{
2275
    CPUState *env = mon_get_cpu();
2276
    if (!env)
2277
        return 0;
2278
    return cpu_ppc_load_decr(env);
2279
}
2280

    
2281
static target_long monitor_get_tbu (const struct MonitorDef *md, int val)
2282
{
2283
    CPUState *env = mon_get_cpu();
2284
    if (!env)
2285
        return 0;
2286
    return cpu_ppc_load_tbu(env);
2287
}
2288

    
2289
static target_long monitor_get_tbl (const struct MonitorDef *md, int val)
2290
{
2291
    CPUState *env = mon_get_cpu();
2292
    if (!env)
2293
        return 0;
2294
    return cpu_ppc_load_tbl(env);
2295
}
2296
#endif
2297

    
2298
#if defined(TARGET_SPARC)
2299
#ifndef TARGET_SPARC64
2300
static target_long monitor_get_psr (const struct MonitorDef *md, int val)
2301
{
2302
    CPUState *env = mon_get_cpu();
2303
    if (!env)
2304
        return 0;
2305
    return GET_PSR(env);
2306
}
2307
#endif
2308

    
2309
static target_long monitor_get_reg(const struct MonitorDef *md, int val)
2310
{
2311
    CPUState *env = mon_get_cpu();
2312
    if (!env)
2313
        return 0;
2314
    return env->regwptr[val];
2315
}
2316
#endif
2317

    
2318
static const MonitorDef monitor_defs[] = {
2319
#ifdef TARGET_I386
2320

    
2321
#define SEG(name, seg) \
2322
    { name, offsetof(CPUState, segs[seg].selector), NULL, MD_I32 },\
2323
    { name ".base", offsetof(CPUState, segs[seg].base) },\
2324
    { name ".limit", offsetof(CPUState, segs[seg].limit), NULL, MD_I32 },
2325

    
2326
    { "eax", offsetof(CPUState, regs[0]) },
2327
    { "ecx", offsetof(CPUState, regs[1]) },
2328
    { "edx", offsetof(CPUState, regs[2]) },
2329
    { "ebx", offsetof(CPUState, regs[3]) },
2330
    { "esp|sp", offsetof(CPUState, regs[4]) },
2331
    { "ebp|fp", offsetof(CPUState, regs[5]) },
2332
    { "esi", offsetof(CPUState, regs[6]) },
2333
    { "edi", offsetof(CPUState, regs[7]) },
2334
#ifdef TARGET_X86_64
2335
    { "r8", offsetof(CPUState, regs[8]) },
2336
    { "r9", offsetof(CPUState, regs[9]) },
2337
    { "r10", offsetof(CPUState, regs[10]) },
2338
    { "r11", offsetof(CPUState, regs[11]) },
2339
    { "r12", offsetof(CPUState, regs[12]) },
2340
    { "r13", offsetof(CPUState, regs[13]) },
2341
    { "r14", offsetof(CPUState, regs[14]) },
2342
    { "r15", offsetof(CPUState, regs[15]) },
2343
#endif
2344
    { "eflags", offsetof(CPUState, eflags) },
2345
    { "eip", offsetof(CPUState, eip) },
2346
    SEG("cs", R_CS)
2347
    SEG("ds", R_DS)
2348
    SEG("es", R_ES)
2349
    SEG("ss", R_SS)
2350
    SEG("fs", R_FS)
2351
    SEG("gs", R_GS)
2352
    { "pc", 0, monitor_get_pc, },
2353
#elif defined(TARGET_PPC)
2354
    /* General purpose registers */
2355
    { "r0", offsetof(CPUState, gpr[0]) },
2356
    { "r1", offsetof(CPUState, gpr[1]) },
2357
    { "r2", offsetof(CPUState, gpr[2]) },
2358
    { "r3", offsetof(CPUState, gpr[3]) },
2359
    { "r4", offsetof(CPUState, gpr[4]) },
2360
    { "r5", offsetof(CPUState, gpr[5]) },
2361
    { "r6", offsetof(CPUState, gpr[6]) },
2362
    { "r7", offsetof(CPUState, gpr[7]) },
2363
    { "r8", offsetof(CPUState, gpr[8]) },
2364
    { "r9", offsetof(CPUState, gpr[9]) },
2365
    { "r10", offsetof(CPUState, gpr[10]) },
2366
    { "r11", offsetof(CPUState, gpr[11]) },
2367
    { "r12", offsetof(CPUState, gpr[12]) },
2368
    { "r13", offsetof(CPUState, gpr[13]) },
2369
    { "r14", offsetof(CPUState, gpr[14]) },
2370
    { "r15", offsetof(CPUState, gpr[15]) },
2371
    { "r16", offsetof(CPUState, gpr[16]) },
2372
    { "r17", offsetof(CPUState, gpr[17]) },
2373
    { "r18", offsetof(CPUState, gpr[18]) },
2374
    { "r19", offsetof(CPUState, gpr[19]) },
2375
    { "r20", offsetof(CPUState, gpr[20]) },
2376
    { "r21", offsetof(CPUState, gpr[21]) },
2377
    { "r22", offsetof(CPUState, gpr[22]) },
2378
    { "r23", offsetof(CPUState, gpr[23]) },
2379
    { "r24", offsetof(CPUState, gpr[24]) },
2380
    { "r25", offsetof(CPUState, gpr[25]) },
2381
    { "r26", offsetof(CPUState, gpr[26]) },
2382
    { "r27", offsetof(CPUState, gpr[27]) },
2383
    { "r28", offsetof(CPUState, gpr[28]) },
2384
    { "r29", offsetof(CPUState, gpr[29]) },
2385
    { "r30", offsetof(CPUState, gpr[30]) },
2386
    { "r31", offsetof(CPUState, gpr[31]) },
2387
    /* Floating point registers */
2388
    { "f0", offsetof(CPUState, fpr[0]) },
2389
    { "f1", offsetof(CPUState, fpr[1]) },
2390
    { "f2", offsetof(CPUState, fpr[2]) },
2391
    { "f3", offsetof(CPUState, fpr[3]) },
2392
    { "f4", offsetof(CPUState, fpr[4]) },
2393
    { "f5", offsetof(CPUState, fpr[5]) },
2394
    { "f6", offsetof(CPUState, fpr[6]) },
2395
    { "f7", offsetof(CPUState, fpr[7]) },
2396
    { "f8", offsetof(CPUState, fpr[8]) },
2397
    { "f9", offsetof(CPUState, fpr[9]) },
2398
    { "f10", offsetof(CPUState, fpr[10]) },
2399
    { "f11", offsetof(CPUState, fpr[11]) },
2400
    { "f12", offsetof(CPUState, fpr[12]) },
2401
    { "f13", offsetof(CPUState, fpr[13]) },
2402
    { "f14", offsetof(CPUState, fpr[14]) },
2403
    { "f15", offsetof(CPUState, fpr[15]) },
2404
    { "f16", offsetof(CPUState, fpr[16]) },
2405
    { "f17", offsetof(CPUState, fpr[17]) },
2406
    { "f18", offsetof(CPUState, fpr[18]) },
2407
    { "f19", offsetof(CPUState, fpr[19]) },
2408
    { "f20", offsetof(CPUState, fpr[20]) },
2409
    { "f21", offsetof(CPUState, fpr[21]) },
2410
    { "f22", offsetof(CPUState, fpr[22]) },
2411
    { "f23", offsetof(CPUState, fpr[23]) },
2412
    { "f24", offsetof(CPUState, fpr[24]) },
2413
    { "f25", offsetof(CPUState, fpr[25]) },
2414
    { "f26", offsetof(CPUState, fpr[26]) },
2415
    { "f27", offsetof(CPUState, fpr[27]) },
2416
    { "f28", offsetof(CPUState, fpr[28]) },
2417
    { "f29", offsetof(CPUState, fpr[29]) },
2418
    { "f30", offsetof(CPUState, fpr[30]) },
2419
    { "f31", offsetof(CPUState, fpr[31]) },
2420
    { "fpscr", offsetof(CPUState, fpscr) },
2421
    /* Next instruction pointer */
2422
    { "nip|pc", offsetof(CPUState, nip) },
2423
    { "lr", offsetof(CPUState, lr) },
2424
    { "ctr", offsetof(CPUState, ctr) },
2425
    { "decr", 0, &monitor_get_decr, },
2426
    { "ccr", 0, &monitor_get_ccr, },
2427
    /* Machine state register */
2428
    { "msr", 0, &monitor_get_msr, },
2429
    { "xer", 0, &monitor_get_xer, },
2430
    { "tbu", 0, &monitor_get_tbu, },
2431
    { "tbl", 0, &monitor_get_tbl, },
2432
#if defined(TARGET_PPC64)
2433
    /* Address space register */
2434
    { "asr", offsetof(CPUState, asr) },
2435
#endif
2436
    /* Segment registers */
2437
    { "sdr1", offsetof(CPUState, sdr1) },
2438
    { "sr0", offsetof(CPUState, sr[0]) },
2439
    { "sr1", offsetof(CPUState, sr[1]) },
2440
    { "sr2", offsetof(CPUState, sr[2]) },
2441
    { "sr3", offsetof(CPUState, sr[3]) },
2442
    { "sr4", offsetof(CPUState, sr[4]) },
2443
    { "sr5", offsetof(CPUState, sr[5]) },
2444
    { "sr6", offsetof(CPUState, sr[6]) },
2445
    { "sr7", offsetof(CPUState, sr[7]) },
2446
    { "sr8", offsetof(CPUState, sr[8]) },
2447
    { "sr9", offsetof(CPUState, sr[9]) },
2448
    { "sr10", offsetof(CPUState, sr[10]) },
2449
    { "sr11", offsetof(CPUState, sr[11]) },
2450
    { "sr12", offsetof(CPUState, sr[12]) },
2451
    { "sr13", offsetof(CPUState, sr[13]) },
2452
    { "sr14", offsetof(CPUState, sr[14]) },
2453
    { "sr15", offsetof(CPUState, sr[15]) },
2454
    /* Too lazy to put BATs and SPRs ... */
2455
#elif defined(TARGET_SPARC)
2456
    { "g0", offsetof(CPUState, gregs[0]) },
2457
    { "g1", offsetof(CPUState, gregs[1]) },
2458
    { "g2", offsetof(CPUState, gregs[2]) },
2459
    { "g3", offsetof(CPUState, gregs[3]) },
2460
    { "g4", offsetof(CPUState, gregs[4]) },
2461
    { "g5", offsetof(CPUState, gregs[5]) },
2462
    { "g6", offsetof(CPUState, gregs[6]) },
2463
    { "g7", offsetof(CPUState, gregs[7]) },
2464
    { "o0", 0, monitor_get_reg },
2465
    { "o1", 1, monitor_get_reg },
2466
    { "o2", 2, monitor_get_reg },
2467
    { "o3", 3, monitor_get_reg },
2468
    { "o4", 4, monitor_get_reg },
2469
    { "o5", 5, monitor_get_reg },
2470
    { "o6", 6, monitor_get_reg },
2471
    { "o7", 7, monitor_get_reg },
2472
    { "l0", 8, monitor_get_reg },
2473
    { "l1", 9, monitor_get_reg },
2474
    { "l2", 10, monitor_get_reg },
2475
    { "l3", 11, monitor_get_reg },
2476
    { "l4", 12, monitor_get_reg },
2477
    { "l5", 13, monitor_get_reg },
2478
    { "l6", 14, monitor_get_reg },
2479
    { "l7", 15, monitor_get_reg },
2480
    { "i0", 16, monitor_get_reg },
2481
    { "i1", 17, monitor_get_reg },
2482
    { "i2", 18, monitor_get_reg },
2483
    { "i3", 19, monitor_get_reg },
2484
    { "i4", 20, monitor_get_reg },
2485
    { "i5", 21, monitor_get_reg },
2486
    { "i6", 22, monitor_get_reg },
2487
    { "i7", 23, monitor_get_reg },
2488
    { "pc", offsetof(CPUState, pc) },
2489
    { "npc", offsetof(CPUState, npc) },
2490
    { "y", offsetof(CPUState, y) },
2491
#ifndef TARGET_SPARC64
2492
    { "psr", 0, &monitor_get_psr, },
2493
    { "wim", offsetof(CPUState, wim) },
2494
#endif
2495
    { "tbr", offsetof(CPUState, tbr) },
2496
    { "fsr", offsetof(CPUState, fsr) },
2497
    { "f0", offsetof(CPUState, fpr[0]) },
2498
    { "f1", offsetof(CPUState, fpr[1]) },
2499
    { "f2", offsetof(CPUState, fpr[2]) },
2500
    { "f3", offsetof(CPUState, fpr[3]) },
2501
    { "f4", offsetof(CPUState, fpr[4]) },
2502
    { "f5", offsetof(CPUState, fpr[5]) },
2503
    { "f6", offsetof(CPUState, fpr[6]) },
2504
    { "f7", offsetof(CPUState, fpr[7]) },
2505
    { "f8", offsetof(CPUState, fpr[8]) },
2506
    { "f9", offsetof(CPUState, fpr[9]) },
2507
    { "f10", offsetof(CPUState, fpr[10]) },
2508
    { "f11", offsetof(CPUState, fpr[11]) },
2509
    { "f12", offsetof(CPUState, fpr[12]) },
2510
    { "f13", offsetof(CPUState, fpr[13]) },
2511
    { "f14", offsetof(CPUState, fpr[14]) },
2512
    { "f15", offsetof(CPUState, fpr[15]) },
2513
    { "f16", offsetof(CPUState, fpr[16]) },
2514
    { "f17", offsetof(CPUState, fpr[17]) },
2515
    { "f18", offsetof(CPUState, fpr[18]) },
2516
    { "f19", offsetof(CPUState, fpr[19]) },
2517
    { "f20", offsetof(CPUState, fpr[20]) },
2518
    { "f21", offsetof(CPUState, fpr[21]) },
2519
    { "f22", offsetof(CPUState, fpr[22]) },
2520
    { "f23", offsetof(CPUState, fpr[23]) },
2521
    { "f24", offsetof(CPUState, fpr[24]) },
2522
    { "f25", offsetof(CPUState, fpr[25]) },
2523
    { "f26", offsetof(CPUState, fpr[26]) },
2524
    { "f27", offsetof(CPUState, fpr[27]) },
2525
    { "f28", offsetof(CPUState, fpr[28]) },
2526
    { "f29", offsetof(CPUState, fpr[29]) },
2527
    { "f30", offsetof(CPUState, fpr[30]) },
2528
    { "f31", offsetof(CPUState, fpr[31]) },
2529
#ifdef TARGET_SPARC64
2530
    { "f32", offsetof(CPUState, fpr[32]) },
2531
    { "f34", offsetof(CPUState, fpr[34]) },
2532
    { "f36", offsetof(CPUState, fpr[36]) },
2533
    { "f38", offsetof(CPUState, fpr[38]) },
2534
    { "f40", offsetof(CPUState, fpr[40]) },
2535
    { "f42", offsetof(CPUState, fpr[42]) },
2536
    { "f44", offsetof(CPUState, fpr[44]) },
2537
    { "f46", offsetof(CPUState, fpr[46]) },
2538
    { "f48", offsetof(CPUState, fpr[48]) },
2539
    { "f50", offsetof(CPUState, fpr[50]) },
2540
    { "f52", offsetof(CPUState, fpr[52]) },
2541
    { "f54", offsetof(CPUState, fpr[54]) },
2542
    { "f56", offsetof(CPUState, fpr[56]) },
2543
    { "f58", offsetof(CPUState, fpr[58]) },
2544
    { "f60", offsetof(CPUState, fpr[60]) },
2545
    { "f62", offsetof(CPUState, fpr[62]) },
2546
    { "asi", offsetof(CPUState, asi) },
2547
    { "pstate", offsetof(CPUState, pstate) },
2548
    { "cansave", offsetof(CPUState, cansave) },
2549
    { "canrestore", offsetof(CPUState, canrestore) },
2550
    { "otherwin", offsetof(CPUState, otherwin) },
2551
    { "wstate", offsetof(CPUState, wstate) },
2552
    { "cleanwin", offsetof(CPUState, cleanwin) },
2553
    { "fprs", offsetof(CPUState, fprs) },
2554
#endif
2555
#endif
2556
    { NULL },
2557
};
2558

    
2559
static void expr_error(Monitor *mon, const char *msg)
2560
{
2561
    monitor_printf(mon, "%s\n", msg);
2562
    longjmp(expr_env, 1);
2563
}
2564

    
2565
/* return 0 if OK, -1 if not found, -2 if no CPU defined */
2566
static int get_monitor_def(target_long *pval, const char *name)
2567
{
2568
    const MonitorDef *md;
2569
    void *ptr;
2570

    
2571
    for(md = monitor_defs; md->name != NULL; md++) {
2572
        if (compare_cmd(name, md->name)) {
2573
            if (md->get_value) {
2574
                *pval = md->get_value(md, md->offset);
2575
            } else {
2576
                CPUState *env = mon_get_cpu();
2577
                if (!env)
2578
                    return -2;
2579
                ptr = (uint8_t *)env + md->offset;
2580
                switch(md->type) {
2581
                case MD_I32:
2582
                    *pval = *(int32_t *)ptr;
2583
                    break;
2584
                case MD_TLONG:
2585
                    *pval = *(target_long *)ptr;
2586
                    break;
2587
                default:
2588
                    *pval = 0;
2589
                    break;
2590
                }
2591
            }
2592
            return 0;
2593
        }
2594
    }
2595
    return -1;
2596
}
2597

    
2598
static void next(void)
2599
{
2600
    if (*pch != '\0') {
2601
        pch++;
2602
        while (qemu_isspace(*pch))
2603
            pch++;
2604
    }
2605
}
2606

    
2607
static int64_t expr_sum(Monitor *mon);
2608

    
2609
static int64_t expr_unary(Monitor *mon)
2610
{
2611
    int64_t n;
2612
    char *p;
2613
    int ret;
2614

    
2615
    switch(*pch) {
2616
    case '+':
2617
        next();
2618
        n = expr_unary(mon);
2619
        break;
2620
    case '-':
2621
        next();
2622
        n = -expr_unary(mon);
2623
        break;
2624
    case '~':
2625
        next();
2626
        n = ~expr_unary(mon);
2627
        break;
2628
    case '(':
2629
        next();
2630
        n = expr_sum(mon);
2631
        if (*pch != ')') {
2632
            expr_error(mon, "')' expected");
2633
        }
2634
        next();
2635
        break;
2636
    case '\'':
2637
        pch++;
2638
        if (*pch == '\0')
2639
            expr_error(mon, "character constant expected");
2640
        n = *pch;
2641
        pch++;
2642
        if (*pch != '\'')
2643
            expr_error(mon, "missing terminating \' character");
2644
        next();
2645
        break;
2646
    case '$':
2647
        {
2648
            char buf[128], *q;
2649
            target_long reg=0;
2650

    
2651
            pch++;
2652
            q = buf;
2653
            while ((*pch >= 'a' && *pch <= 'z') ||
2654
                   (*pch >= 'A' && *pch <= 'Z') ||
2655
                   (*pch >= '0' && *pch <= '9') ||
2656
                   *pch == '_' || *pch == '.') {
2657
                if ((q - buf) < sizeof(buf) - 1)
2658
                    *q++ = *pch;
2659
                pch++;
2660
            }
2661
            while (qemu_isspace(*pch))
2662
                pch++;
2663
            *q = 0;
2664
            ret = get_monitor_def(&reg, buf);
2665
            if (ret == -1)
2666
                expr_error(mon, "unknown register");
2667
            else if (ret == -2)
2668
                expr_error(mon, "no cpu defined");
2669
            n = reg;
2670
        }
2671
        break;
2672
    case '\0':
2673
        expr_error(mon, "unexpected end of expression");
2674
        n = 0;
2675
        break;
2676
    default:
2677
#if TARGET_PHYS_ADDR_BITS > 32
2678
        n = strtoull(pch, &p, 0);
2679
#else
2680
        n = strtoul(pch, &p, 0);
2681
#endif
2682
        if (pch == p) {
2683
            expr_error(mon, "invalid char in expression");
2684
        }
2685
        pch = p;
2686
        while (qemu_isspace(*pch))
2687
            pch++;
2688
        break;
2689
    }
2690
    return n;
2691
}
2692

    
2693

    
2694
static int64_t expr_prod(Monitor *mon)
2695
{
2696
    int64_t val, val2;
2697
    int op;
2698

    
2699
    val = expr_unary(mon);
2700
    for(;;) {
2701
        op = *pch;
2702
        if (op != '*' && op != '/' && op != '%')
2703
            break;
2704
        next();
2705
        val2 = expr_unary(mon);
2706
        switch(op) {
2707
        default:
2708
        case '*':
2709
            val *= val2;
2710
            break;
2711
        case '/':
2712
        case '%':
2713
            if (val2 == 0)
2714
                expr_error(mon, "division by zero");
2715
            if (op == '/')
2716
                val /= val2;
2717
            else
2718
                val %= val2;
2719
            break;
2720
        }
2721
    }
2722
    return val;
2723
}
2724

    
2725
static int64_t expr_logic(Monitor *mon)
2726
{
2727
    int64_t val, val2;
2728
    int op;
2729

    
2730
    val = expr_prod(mon);
2731
    for(;;) {
2732
        op = *pch;
2733
        if (op != '&' && op != '|' && op != '^')
2734
            break;
2735
        next();
2736
        val2 = expr_prod(mon);
2737
        switch(op) {
2738
        default:
2739
        case '&':
2740
            val &= val2;
2741
            break;
2742
        case '|':
2743
            val |= val2;
2744
            break;
2745
        case '^':
2746
            val ^= val2;
2747
            break;
2748
        }
2749
    }
2750
    return val;
2751
}
2752

    
2753
static int64_t expr_sum(Monitor *mon)
2754
{
2755
    int64_t val, val2;
2756
    int op;
2757

    
2758
    val = expr_logic(mon);
2759
    for(;;) {
2760
        op = *pch;
2761
        if (op != '+' && op != '-')
2762
            break;
2763
        next();
2764
        val2 = expr_logic(mon);
2765
        if (op == '+')
2766
            val += val2;
2767
        else
2768
            val -= val2;
2769
    }
2770
    return val;
2771
}
2772

    
2773
static int get_expr(Monitor *mon, int64_t *pval, const char **pp)
2774
{
2775
    pch = *pp;
2776
    if (setjmp(expr_env)) {
2777
        *pp = pch;
2778
        return -1;
2779
    }
2780
    while (qemu_isspace(*pch))
2781
        pch++;
2782
    *pval = expr_sum(mon);
2783
    *pp = pch;
2784
    return 0;
2785
}
2786

    
2787
static int get_str(char *buf, int buf_size, const char **pp)
2788
{
2789
    const char *p;
2790
    char *q;
2791
    int c;
2792

    
2793
    q = buf;
2794
    p = *pp;
2795
    while (qemu_isspace(*p))
2796
        p++;
2797
    if (*p == '\0') {
2798
    fail:
2799
        *q = '\0';
2800
        *pp = p;
2801
        return -1;
2802
    }
2803
    if (*p == '\"') {
2804
        p++;
2805
        while (*p != '\0' && *p != '\"') {
2806
            if (*p == '\\') {
2807
                p++;
2808
                c = *p++;
2809
                switch(c) {
2810
                case 'n':
2811
                    c = '\n';
2812
                    break;
2813
                case 'r':
2814
                    c = '\r';
2815
                    break;
2816
                case '\\':
2817
                case '\'':
2818
                case '\"':
2819
                    break;
2820
                default:
2821
                    qemu_printf("unsupported escape code: '\\%c'\n", c);
2822
                    goto fail;
2823
                }
2824
                if ((q - buf) < buf_size - 1) {
2825
                    *q++ = c;
2826
                }
2827
            } else {
2828
                if ((q - buf) < buf_size - 1) {
2829
                    *q++ = *p;
2830
                }
2831
                p++;
2832
            }
2833
        }
2834
        if (*p != '\"') {
2835
            qemu_printf("unterminated string\n");
2836
            goto fail;
2837
        }
2838
        p++;
2839
    } else {
2840
        while (*p != '\0' && !qemu_isspace(*p)) {
2841
            if ((q - buf) < buf_size - 1) {
2842
                *q++ = *p;
2843
            }
2844
            p++;
2845
        }
2846
    }
2847
    *q = '\0';
2848
    *pp = p;
2849
    return 0;
2850
}
2851

    
2852
/*
2853
 * Store the command-name in cmdname, and return a pointer to
2854
 * the remaining of the command string.
2855
 */
2856
static const char *get_command_name(const char *cmdline,
2857
                                    char *cmdname, size_t nlen)
2858
{
2859
    size_t len;
2860
    const char *p, *pstart;
2861

    
2862
    p = cmdline;
2863
    while (qemu_isspace(*p))
2864
        p++;
2865
    if (*p == '\0')
2866
        return NULL;
2867
    pstart = p;
2868
    while (*p != '\0' && *p != '/' && !qemu_isspace(*p))
2869
        p++;
2870
    len = p - pstart;
2871
    if (len > nlen - 1)
2872
        len = nlen - 1;
2873
    memcpy(cmdname, pstart, len);
2874
    cmdname[len] = '\0';
2875
    return p;
2876
}
2877

    
2878
/**
2879
 * Read key of 'type' into 'key' and return the current
2880
 * 'type' pointer.
2881
 */
2882
static char *key_get_info(const char *type, char **key)
2883
{
2884
    size_t len;
2885
    char *p, *str;
2886

    
2887
    if (*type == ',')
2888
        type++;
2889

    
2890
    p = strchr(type, ':');
2891
    if (!p) {
2892
        *key = NULL;
2893
        return NULL;
2894
    }
2895
    len = p - type;
2896

    
2897
    str = qemu_malloc(len + 1);
2898
    memcpy(str, type, len);
2899
    str[len] = '\0';
2900

    
2901
    *key = str;
2902
    return ++p;
2903
}
2904

    
2905
static int default_fmt_format = 'x';
2906
static int default_fmt_size = 4;
2907

    
2908
#define MAX_ARGS 16
2909

    
2910
static const mon_cmd_t *monitor_parse_command(Monitor *mon,
2911
                                              const char *cmdline,
2912
                                              QDict *qdict)
2913
{
2914
    const char *p, *typestr;
2915
    int c;
2916
    const mon_cmd_t *cmd;
2917
    char cmdname[256];
2918
    char buf[1024];
2919
    char *key;
2920

    
2921
#ifdef DEBUG
2922
    monitor_printf(mon, "command='%s'\n", cmdline);
2923
#endif
2924

    
2925
    /* extract the command name */
2926
    p = get_command_name(cmdline, cmdname, sizeof(cmdname));
2927
    if (!p)
2928
        return NULL;
2929

    
2930
    /* find the command */
2931
    for(cmd = mon_cmds; cmd->name != NULL; cmd++) {
2932
        if (compare_cmd(cmdname, cmd->name))
2933
            break;
2934
    }
2935

    
2936
    if (cmd->name == NULL) {
2937
        monitor_printf(mon, "unknown command: '%s'\n", cmdname);
2938
        return NULL;
2939
    }
2940

    
2941
    /* parse the parameters */
2942
    typestr = cmd->args_type;
2943
    for(;;) {
2944
        typestr = key_get_info(typestr, &key);
2945
        if (!typestr)
2946
            break;
2947
        c = *typestr;
2948
        typestr++;
2949
        switch(c) {
2950
        case 'F':
2951
        case 'B':
2952
        case 's':
2953
            {
2954
                int ret;
2955

    
2956
                while (qemu_isspace(*p))
2957
                    p++;
2958
                if (*typestr == '?') {
2959
                    typestr++;
2960
                    if (*p == '\0') {
2961
                        /* no optional string: NULL argument */
2962
                        break;
2963
                    }
2964
                }
2965
                ret = get_str(buf, sizeof(buf), &p);
2966
                if (ret < 0) {
2967
                    switch(c) {
2968
                    case 'F':
2969
                        monitor_printf(mon, "%s: filename expected\n",
2970
                                       cmdname);
2971
                        break;
2972
                    case 'B':
2973
                        monitor_printf(mon, "%s: block device name expected\n",
2974
                                       cmdname);
2975
                        break;
2976
                    default:
2977
                        monitor_printf(mon, "%s: string expected\n", cmdname);
2978
                        break;
2979
                    }
2980
                    goto fail;
2981
                }
2982
                qdict_put(qdict, key, qstring_from_str(buf));
2983
            }
2984
            break;
2985
        case '/':
2986
            {
2987
                int count, format, size;
2988

    
2989
                while (qemu_isspace(*p))
2990
                    p++;
2991
                if (*p == '/') {
2992
                    /* format found */
2993
                    p++;
2994
                    count = 1;
2995
                    if (qemu_isdigit(*p)) {
2996
                        count = 0;
2997
                        while (qemu_isdigit(*p)) {
2998
                            count = count * 10 + (*p - '0');
2999
                            p++;
3000
                        }
3001
                    }
3002
                    size = -1;
3003
                    format = -1;
3004
                    for(;;) {
3005
                        switch(*p) {
3006
                        case 'o':
3007
                        case 'd':
3008
                        case 'u':
3009
                        case 'x':
3010
                        case 'i':
3011
                        case 'c':
3012
                            format = *p++;
3013
                            break;
3014
                        case 'b':
3015
                            size = 1;
3016
                            p++;
3017
                            break;
3018
                        case 'h':
3019
                            size = 2;
3020
                            p++;
3021
                            break;
3022
                        case 'w':
3023
                            size = 4;
3024
                            p++;
3025
                            break;
3026
                        case 'g':
3027
                        case 'L':
3028
                            size = 8;
3029
                            p++;
3030
                            break;
3031
                        default:
3032
                            goto next;
3033
                        }
3034
                    }
3035
                next:
3036
                    if (*p != '\0' && !qemu_isspace(*p)) {
3037
                        monitor_printf(mon, "invalid char in format: '%c'\n",
3038
                                       *p);
3039
                        goto fail;
3040
                    }
3041
                    if (format < 0)
3042
                        format = default_fmt_format;
3043
                    if (format != 'i') {
3044
                        /* for 'i', not specifying a size gives -1 as size */
3045
                        if (size < 0)
3046
                            size = default_fmt_size;
3047
                        default_fmt_size = size;
3048
                    }
3049
                    default_fmt_format = format;
3050
                } else {
3051
                    count = 1;
3052
                    format = default_fmt_format;
3053
                    if (format != 'i') {
3054
                        size = default_fmt_size;
3055
                    } else {
3056
                        size = -1;
3057
                    }
3058
                }
3059
                qdict_put(qdict, "count", qint_from_int(count));
3060
                qdict_put(qdict, "format", qint_from_int(format));
3061
                qdict_put(qdict, "size", qint_from_int(size));
3062
            }
3063
            break;
3064
        case 'i':
3065
        case 'l':
3066
            {
3067
                int64_t val;
3068

    
3069
                while (qemu_isspace(*p))
3070
                    p++;
3071
                if (*typestr == '?' || *typestr == '.') {
3072
                    if (*typestr == '?') {
3073
                        if (*p == '\0') {
3074
                            typestr++;
3075
                            break;
3076
                        }
3077
                    } else {
3078
                        if (*p == '.') {
3079
                            p++;
3080
                            while (qemu_isspace(*p))
3081
                                p++;
3082
                        } else {
3083
                            typestr++;
3084
                            break;
3085
                        }
3086
                    }
3087
                    typestr++;
3088
                }
3089
                if (get_expr(mon, &val, &p))
3090
                    goto fail;
3091
                /* Check if 'i' is greater than 32-bit */
3092
                if ((c == 'i') && ((val >> 32) & 0xffffffff)) {
3093
                    monitor_printf(mon, "\'%s\' has failed: ", cmdname);
3094
                    monitor_printf(mon, "integer is for 32-bit values\n");
3095
                    goto fail;
3096
                }
3097
                qdict_put(qdict, key, qint_from_int(val));
3098
            }
3099
            break;
3100
        case '-':
3101
            {
3102
                int has_option;
3103
                /* option */
3104

    
3105
                c = *typestr++;
3106
                if (c == '\0')
3107
                    goto bad_type;
3108
                while (qemu_isspace(*p))
3109
                    p++;
3110
                has_option = 0;
3111
                if (*p == '-') {
3112
                    p++;
3113
                    if (*p != c) {
3114
                        monitor_printf(mon, "%s: unsupported option -%c\n",
3115
                                       cmdname, *p);
3116
                        goto fail;
3117
                    }
3118
                    p++;
3119
                    has_option = 1;
3120
                }
3121
                qdict_put(qdict, key, qint_from_int(has_option));
3122
            }
3123
            break;
3124
        default:
3125
        bad_type:
3126
            monitor_printf(mon, "%s: unknown type '%c'\n", cmdname, c);
3127
            goto fail;
3128
        }
3129
        qemu_free(key);
3130
        key = NULL;
3131
    }
3132
    /* check that all arguments were parsed */
3133
    while (qemu_isspace(*p))
3134
        p++;
3135
    if (*p != '\0') {
3136
        monitor_printf(mon, "%s: extraneous characters at the end of line\n",
3137
                       cmdname);
3138
        goto fail;
3139
    }
3140

    
3141
    return cmd;
3142

    
3143
fail:
3144
    qemu_free(key);
3145
    return NULL;
3146
}
3147

    
3148
static void monitor_handle_command(Monitor *mon, const char *cmdline)
3149
{
3150
    QDict *qdict;
3151
    const mon_cmd_t *cmd;
3152

    
3153
    qdict = qdict_new();
3154

    
3155
    cmd = monitor_parse_command(mon, cmdline, qdict);
3156
    if (!cmd)
3157
        goto out;
3158

    
3159
    qemu_errors_to_mon(mon);
3160

    
3161
    if (monitor_handler_ported(cmd)) {
3162
        QObject *data = NULL;
3163

    
3164
        cmd->mhandler.cmd_new(mon, qdict, &data);
3165
        if (data)
3166
            cmd->user_print(mon, data);
3167

    
3168
        qobject_decref(data);
3169
    } else {
3170
        cmd->mhandler.cmd(mon, qdict);
3171
    }
3172

    
3173
   qemu_errors_to_previous();
3174

    
3175
out:
3176
    QDECREF(qdict);
3177
}
3178

    
3179
static void cmd_completion(const char *name, const char *list)
3180
{
3181
    const char *p, *pstart;
3182
    char cmd[128];
3183
    int len;
3184

    
3185
    p = list;
3186
    for(;;) {
3187
        pstart = p;
3188
        p = strchr(p, '|');
3189
        if (!p)
3190
            p = pstart + strlen(pstart);
3191
        len = p - pstart;
3192
        if (len > sizeof(cmd) - 2)
3193
            len = sizeof(cmd) - 2;
3194
        memcpy(cmd, pstart, len);
3195
        cmd[len] = '\0';
3196
        if (name[0] == '\0' || !strncmp(name, cmd, strlen(name))) {
3197
            readline_add_completion(cur_mon->rs, cmd);
3198
        }
3199
        if (*p == '\0')
3200
            break;
3201
        p++;
3202
    }
3203
}
3204

    
3205
static void file_completion(const char *input)
3206
{
3207
    DIR *ffs;
3208
    struct dirent *d;
3209
    char path[1024];
3210
    char file[1024], file_prefix[1024];
3211
    int input_path_len;
3212
    const char *p;
3213

    
3214
    p = strrchr(input, '/');
3215
    if (!p) {
3216
        input_path_len = 0;
3217
        pstrcpy(file_prefix, sizeof(file_prefix), input);
3218
        pstrcpy(path, sizeof(path), ".");
3219
    } else {
3220
        input_path_len = p - input + 1;
3221
        memcpy(path, input, input_path_len);
3222
        if (input_path_len > sizeof(path) - 1)
3223
            input_path_len = sizeof(path) - 1;
3224
        path[input_path_len] = '\0';
3225
        pstrcpy(file_prefix, sizeof(file_prefix), p + 1);
3226
    }
3227
#ifdef DEBUG_COMPLETION
3228
    monitor_printf(cur_mon, "input='%s' path='%s' prefix='%s'\n",
3229
                   input, path, file_prefix);
3230
#endif
3231
    ffs = opendir(path);
3232
    if (!ffs)
3233
        return;
3234
    for(;;) {
3235
        struct stat sb;
3236
        d = readdir(ffs);
3237
        if (!d)
3238
            break;
3239
        if (strstart(d->d_name, file_prefix, NULL)) {
3240
            memcpy(file, input, input_path_len);
3241
            if (input_path_len < sizeof(file))
3242
                pstrcpy(file + input_path_len, sizeof(file) - input_path_len,
3243
                        d->d_name);
3244
            /* stat the file to find out if it's a directory.
3245
             * In that case add a slash to speed up typing long paths
3246
             */
3247
            stat(file, &sb);
3248
            if(S_ISDIR(sb.st_mode))
3249
                pstrcat(file, sizeof(file), "/");
3250
            readline_add_completion(cur_mon->rs, file);
3251
        }
3252
    }
3253
    closedir(ffs);
3254
}
3255

    
3256
static void block_completion_it(void *opaque, BlockDriverState *bs)
3257
{
3258
    const char *name = bdrv_get_device_name(bs);
3259
    const char *input = opaque;
3260

    
3261
    if (input[0] == '\0' ||
3262
        !strncmp(name, (char *)input, strlen(input))) {
3263
        readline_add_completion(cur_mon->rs, name);
3264
    }
3265
}
3266

    
3267
/* NOTE: this parser is an approximate form of the real command parser */
3268
static void parse_cmdline(const char *cmdline,
3269
                         int *pnb_args, char **args)
3270
{
3271
    const char *p;
3272
    int nb_args, ret;
3273
    char buf[1024];
3274

    
3275
    p = cmdline;
3276
    nb_args = 0;
3277
    for(;;) {
3278
        while (qemu_isspace(*p))
3279
            p++;
3280
        if (*p == '\0')
3281
            break;
3282
        if (nb_args >= MAX_ARGS)
3283
            break;
3284
        ret = get_str(buf, sizeof(buf), &p);
3285
        args[nb_args] = qemu_strdup(buf);
3286
        nb_args++;
3287
        if (ret < 0)
3288
            break;
3289
    }
3290
    *pnb_args = nb_args;
3291
}
3292

    
3293
static const char *next_arg_type(const char *typestr)
3294
{
3295
    const char *p = strchr(typestr, ':');
3296
    return (p != NULL ? ++p : typestr);
3297
}
3298

    
3299
static void monitor_find_completion(const char *cmdline)
3300
{
3301
    const char *cmdname;
3302
    char *args[MAX_ARGS];
3303
    int nb_args, i, len;
3304
    const char *ptype, *str;
3305
    const mon_cmd_t *cmd;
3306
    const KeyDef *key;
3307

    
3308
    parse_cmdline(cmdline, &nb_args, args);
3309
#ifdef DEBUG_COMPLETION
3310
    for(i = 0; i < nb_args; i++) {
3311
        monitor_printf(cur_mon, "arg%d = '%s'\n", i, (char *)args[i]);
3312
    }
3313
#endif
3314

    
3315
    /* if the line ends with a space, it means we want to complete the
3316
       next arg */
3317
    len = strlen(cmdline);
3318
    if (len > 0 && qemu_isspace(cmdline[len - 1])) {
3319
        if (nb_args >= MAX_ARGS)
3320
            return;
3321
        args[nb_args++] = qemu_strdup("");
3322
    }
3323
    if (nb_args <= 1) {
3324
        /* command completion */
3325
        if (nb_args == 0)
3326
            cmdname = "";
3327
        else
3328
            cmdname = args[0];
3329
        readline_set_completion_index(cur_mon->rs, strlen(cmdname));
3330
        for(cmd = mon_cmds; cmd->name != NULL; cmd++) {
3331
            cmd_completion(cmdname, cmd->name);
3332
        }
3333
    } else {
3334
        /* find the command */
3335
        for(cmd = mon_cmds; cmd->name != NULL; cmd++) {
3336
            if (compare_cmd(args[0], cmd->name))
3337
                goto found;
3338
        }
3339
        return;
3340
    found:
3341
        ptype = next_arg_type(cmd->args_type);
3342
        for(i = 0; i < nb_args - 2; i++) {
3343
            if (*ptype != '\0') {
3344
                ptype = next_arg_type(ptype);
3345
                while (*ptype == '?')
3346
                    ptype = next_arg_type(ptype);
3347
            }
3348
        }
3349
        str = args[nb_args - 1];
3350
        if (*ptype == '-' && ptype[1] != '\0') {
3351
            ptype += 2;
3352
        }
3353
        switch(*ptype) {
3354
        case 'F':
3355
            /* file completion */
3356
            readline_set_completion_index(cur_mon->rs, strlen(str));
3357
            file_completion(str);
3358
            break;
3359
        case 'B':
3360
            /* block device name completion */
3361
            readline_set_completion_index(cur_mon->rs, strlen(str));
3362
            bdrv_iterate(block_completion_it, (void *)str);
3363
            break;
3364
        case 's':
3365
            /* XXX: more generic ? */
3366
            if (!strcmp(cmd->name, "info")) {
3367
                readline_set_completion_index(cur_mon->rs, strlen(str));
3368
                for(cmd = info_cmds; cmd->name != NULL; cmd++) {
3369
                    cmd_completion(str, cmd->name);
3370
                }
3371
            } else if (!strcmp(cmd->name, "sendkey")) {
3372
                char *sep = strrchr(str, '-');
3373
                if (sep)
3374
                    str = sep + 1;
3375
                readline_set_completion_index(cur_mon->rs, strlen(str));
3376
                for(key = key_defs; key->name != NULL; key++) {
3377
                    cmd_completion(str, key->name);
3378
                }
3379
            } else if (!strcmp(cmd->name, "help|?")) {
3380
                readline_set_completion_index(cur_mon->rs, strlen(str));
3381
                for (cmd = mon_cmds; cmd->name != NULL; cmd++) {
3382
                    cmd_completion(str, cmd->name);
3383
                }
3384
            }
3385
            break;
3386
        default:
3387
            break;
3388
        }
3389
    }
3390
    for(i = 0; i < nb_args; i++)
3391
        qemu_free(args[i]);
3392
}
3393

    
3394
static int monitor_can_read(void *opaque)
3395
{
3396
    Monitor *mon = opaque;
3397

    
3398
    return (mon->suspend_cnt == 0) ? 128 : 0;
3399
}
3400

    
3401
static void monitor_read(void *opaque, const uint8_t *buf, int size)
3402
{
3403
    Monitor *old_mon = cur_mon;
3404
    int i;
3405

    
3406
    cur_mon = opaque;
3407

    
3408
    if (cur_mon->rs) {
3409
        for (i = 0; i < size; i++)
3410
            readline_handle_byte(cur_mon->rs, buf[i]);
3411
    } else {
3412
        if (size == 0 || buf[size - 1] != 0)
3413
            monitor_printf(cur_mon, "corrupted command\n");
3414
        else
3415
            monitor_handle_command(cur_mon, (char *)buf);
3416
    }
3417

    
3418
    cur_mon = old_mon;
3419
}
3420

    
3421
static void monitor_command_cb(Monitor *mon, const char *cmdline, void *opaque)
3422
{
3423
    monitor_suspend(mon);
3424
    monitor_handle_command(mon, cmdline);
3425
    monitor_resume(mon);
3426
}
3427

    
3428
int monitor_suspend(Monitor *mon)
3429
{
3430
    if (!mon->rs)
3431
        return -ENOTTY;
3432
    mon->suspend_cnt++;
3433
    return 0;
3434
}
3435

    
3436
void monitor_resume(Monitor *mon)
3437
{
3438
    if (!mon->rs)
3439
        return;
3440
    if (--mon->suspend_cnt == 0)
3441
        readline_show_prompt(mon->rs);
3442
}
3443

    
3444
static void monitor_event(void *opaque, int event)
3445
{
3446
    Monitor *mon = opaque;
3447

    
3448
    switch (event) {
3449
    case CHR_EVENT_MUX_IN:
3450
        mon->mux_out = 0;
3451
        if (mon->reset_seen) {
3452
            readline_restart(mon->rs);
3453
            monitor_resume(mon);
3454
            monitor_flush(mon);
3455
        } else {
3456
            mon->suspend_cnt = 0;
3457
        }
3458
        break;
3459

    
3460
    case CHR_EVENT_MUX_OUT:
3461
        if (mon->reset_seen) {
3462
            if (mon->suspend_cnt == 0) {
3463
                monitor_printf(mon, "\n");
3464
            }
3465
            monitor_flush(mon);
3466
            monitor_suspend(mon);
3467
        } else {
3468
            mon->suspend_cnt++;
3469
        }
3470
        mon->mux_out = 1;
3471
        break;
3472

    
3473
    case CHR_EVENT_RESET:
3474
        monitor_printf(mon, "QEMU %s monitor - type 'help' for more "
3475
                       "information\n", QEMU_VERSION);
3476
        if (!mon->mux_out) {
3477
            readline_show_prompt(mon->rs);
3478
        }
3479
        mon->reset_seen = 1;
3480
        break;
3481
    }
3482
}
3483

    
3484

    
3485
/*
3486
 * Local variables:
3487
 *  c-indent-level: 4
3488
 *  c-basic-offset: 4
3489
 *  tab-width: 8
3490
 * End:
3491
 */
3492

    
3493
void monitor_init(CharDriverState *chr, int flags)
3494
{
3495
    static int is_first_init = 1;
3496
    Monitor *mon;
3497

    
3498
    if (is_first_init) {
3499
        key_timer = qemu_new_timer(vm_clock, release_keys, NULL);
3500
        is_first_init = 0;
3501
    }
3502

    
3503
    mon = qemu_mallocz(sizeof(*mon));
3504

    
3505
    mon->chr = chr;
3506
    mon->flags = flags;
3507
    if (flags & MONITOR_USE_READLINE) {
3508
        mon->rs = readline_init(mon, monitor_find_completion);
3509
        monitor_read_command(mon, 0);
3510
    }
3511

    
3512
    qemu_chr_add_handlers(chr, monitor_can_read, monitor_read, monitor_event,
3513
                          mon);
3514

    
3515
    QLIST_INSERT_HEAD(&mon_list, mon, entry);
3516
    if (!cur_mon || (flags & MONITOR_IS_DEFAULT))
3517
        cur_mon = mon;
3518
}
3519

    
3520
static void bdrv_password_cb(Monitor *mon, const char *password, void *opaque)
3521
{
3522
    BlockDriverState *bs = opaque;
3523
    int ret = 0;
3524

    
3525
    if (bdrv_set_key(bs, password) != 0) {
3526
        monitor_printf(mon, "invalid password\n");
3527
        ret = -EPERM;
3528
    }
3529
    if (mon->password_completion_cb)
3530
        mon->password_completion_cb(mon->password_opaque, ret);
3531

    
3532
    monitor_read_command(mon, 1);
3533
}
3534

    
3535
void monitor_read_bdrv_key_start(Monitor *mon, BlockDriverState *bs,
3536
                                 BlockDriverCompletionFunc *completion_cb,
3537
                                 void *opaque)
3538
{
3539
    int err;
3540

    
3541
    if (!bdrv_key_required(bs)) {
3542
        if (completion_cb)
3543
            completion_cb(opaque, 0);
3544
        return;
3545
    }
3546

    
3547
    monitor_printf(mon, "%s (%s) is encrypted.\n", bdrv_get_device_name(bs),
3548
                   bdrv_get_encrypted_filename(bs));
3549

    
3550
    mon->password_completion_cb = completion_cb;
3551
    mon->password_opaque = opaque;
3552

    
3553
    err = monitor_read_password(mon, bdrv_password_cb, bs);
3554

    
3555
    if (err && completion_cb)
3556
        completion_cb(opaque, err);
3557
}
3558

    
3559
typedef struct QemuErrorSink QemuErrorSink;
3560
struct QemuErrorSink {
3561
    enum {
3562
        ERR_SINK_FILE,
3563
        ERR_SINK_MONITOR,
3564
    } dest;
3565
    union {
3566
        FILE    *fp;
3567
        Monitor *mon;
3568
    };
3569
    QemuErrorSink *previous;
3570
};
3571

    
3572
static QemuErrorSink *qemu_error_sink;
3573

    
3574
void qemu_errors_to_file(FILE *fp)
3575
{
3576
    QemuErrorSink *sink;
3577

    
3578
    sink = qemu_mallocz(sizeof(*sink));
3579
    sink->dest = ERR_SINK_FILE;
3580
    sink->fp = fp;
3581
    sink->previous = qemu_error_sink;
3582
    qemu_error_sink = sink;
3583
}
3584

    
3585
void qemu_errors_to_mon(Monitor *mon)
3586
{
3587
    QemuErrorSink *sink;
3588

    
3589
    sink = qemu_mallocz(sizeof(*sink));
3590
    sink->dest = ERR_SINK_MONITOR;
3591
    sink->mon = mon;
3592
    sink->previous = qemu_error_sink;
3593
    qemu_error_sink = sink;
3594
}
3595

    
3596
void qemu_errors_to_previous(void)
3597
{
3598
    QemuErrorSink *sink;
3599

    
3600
    assert(qemu_error_sink != NULL);
3601
    sink = qemu_error_sink;
3602
    qemu_error_sink = sink->previous;
3603
    qemu_free(sink);
3604
}
3605

    
3606
void qemu_error(const char *fmt, ...)
3607
{
3608
    va_list args;
3609

    
3610
    assert(qemu_error_sink != NULL);
3611
    switch (qemu_error_sink->dest) {
3612
    case ERR_SINK_FILE:
3613
        va_start(args, fmt);
3614
        vfprintf(qemu_error_sink->fp, fmt, args);
3615
        va_end(args);
3616
        break;
3617
    case ERR_SINK_MONITOR:
3618
        va_start(args, fmt);
3619
        monitor_vprintf(qemu_error_sink->mon, fmt, args);
3620
        va_end(args);
3621
        break;
3622
    }
3623
}