gwj / at91sam9263 · Files

/*
 * QEMU monitor

 *

 * Copyright (c) 2003-2004 Fabrice Bellard

 *

 * Permission is hereby granted, free of charge, to any person obtaining a copy
 * of this software and associated documentation files (the "Software"), to deal
 * in the Software without restriction, including without limitation the rights
 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
 * copies of the Software, and to permit persons to whom the Software is
 * furnished to do so, subject to the following conditions:
 *
 * The above copyright notice and this permission notice shall be included in
 * all copies or substantial portions of the Software.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
 * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 * THE SOFTWARE.
 */

#include "hw/hw.h"
#include "hw/usb.h"
#include "hw/pcmcia.h"
#include "hw/pc.h"
#include "hw/pci.h"
#include "gdbstub.h"
#include "net.h"
#include "qemu-char.h"
#include "sysemu.h"

#include "monitor.h"
#include "readline.h"

#include "console.h"
#include "block.h"
#include "audio/audio.h"

#include "disas.h"

#include "balloon.h"

#include <dirent.h>

#include "qemu-timer.h"

#include "migration.h"

#include "kvm.h"

//#define DEBUG

//#define DEBUG_COMPLETION

/*
 * Supported types:

 *

 * 'F'          filename

 * 'B'          block device name

 * 's'          string (accept optional quote)

 * 'i'          32 bit integer
 * 'l'          target long (32 or 64 bit)

 * '/'          optional gdb-like print format (like "/10x")
 *
 * '?'          optional type (for 'F', 's' and 'i')
 *
 */

typedef struct mon_cmd_t {

    const char *name;

    const char *args_type;

    void *handler;

    const char *params;
    const char *help;

} mon_cmd_t;

struct Monitor {
    CharDriverState *chr;

    int flags;
    int suspend_cnt;
    uint8_t outbuf[1024];
    int outbuf_index;
    ReadLineState *rs;
    CPUState *mon_cpu;
    BlockDriverCompletionFunc *password_completion_cb;
    void *password_opaque;

    LIST_ENTRY(Monitor) entry;
};

static LIST_HEAD(mon_list, Monitor) mon_list;

static const mon_cmd_t mon_cmds[];
static const mon_cmd_t info_cmds[];

Monitor *cur_mon = NULL;

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

static void monitor_read_command(Monitor *mon, int show_prompt)
{
    readline_start(mon->rs, "(qemu) ", 0, monitor_command_cb, NULL);
    if (show_prompt)
        readline_show_prompt(mon->rs);
}

static int monitor_read_password(Monitor *mon, ReadLineFunc *readline_func,
                                 void *opaque)

{

    if (mon->rs) {
        readline_start(mon->rs, "Password: ", 1, readline_func, opaque);
        /* prompt is printed on return from the command handler */
        return 0;
    } else {
        monitor_printf(mon, "terminal does not support password prompting\n");
        return -ENOTTY;
    }

}

void monitor_flush(Monitor *mon)

{

    if (mon && mon->outbuf_index != 0 && mon->chr->focus == 0) {
        qemu_chr_write(mon->chr, mon->outbuf, mon->outbuf_index);
        mon->outbuf_index = 0;

    }
}

/* flush at every end of line or if the buffer is full */

static void monitor_puts(Monitor *mon, const char *str)

{

    char c;

    if (!mon)
        return;

    for(;;) {
        c = *str++;
        if (c == '\0')
            break;

        if (c == '\n')

            mon->outbuf[mon->outbuf_index++] = '\r';
        mon->outbuf[mon->outbuf_index++] = c;
        if (mon->outbuf_index >= (sizeof(mon->outbuf) - 1)
            || c == '\n')

            monitor_flush(mon);

    }
}

void monitor_vprintf(Monitor *mon, const char *fmt, va_list ap)

{

    char buf[4096];
    vsnprintf(buf, sizeof(buf), fmt, ap);

    monitor_puts(mon, buf);

}

void monitor_printf(Monitor *mon, const char *fmt, ...)

{

    va_list ap;
    va_start(ap, fmt);

    monitor_vprintf(mon, fmt, ap);

    va_end(ap);

}

void monitor_print_filename(Monitor *mon, const char *filename)

{
    int i;

    for (i = 0; filename[i]; i++) {
	switch (filename[i]) {
	case ' ':
	case '"':
	case '\\':

	    monitor_printf(mon, "\\%c", filename[i]);

	    break;
	case '\t':

	    monitor_printf(mon, "\\t");

	    break;
	case '\r':

	    monitor_printf(mon, "\\r");

	    break;
	case '\n':

	    monitor_printf(mon, "\\n");

	    break;
	default:

	    monitor_printf(mon, "%c", filename[i]);

	    break;
	}
    }
}

static int monitor_fprintf(FILE *stream, const char *fmt, ...)
{
    va_list ap;
    va_start(ap, fmt);

    monitor_vprintf((Monitor *)stream, fmt, ap);

    va_end(ap);
    return 0;
}

static int compare_cmd(const char *name, const char *list)
{
    const char *p, *pstart;
    int len;
    len = strlen(name);
    p = list;
    for(;;) {
        pstart = p;
        p = strchr(p, '|');
        if (!p)
            p = pstart + strlen(pstart);
        if ((p - pstart) == len && !memcmp(pstart, name, len))
            return 1;
        if (*p == '\0')
            break;
        p++;
    }
    return 0;
}

static void help_cmd_dump(Monitor *mon, const mon_cmd_t *cmds,
                          const char *prefix, const char *name)

{

    const mon_cmd_t *cmd;

    for(cmd = cmds; cmd->name != NULL; cmd++) {
        if (!name || !strcmp(name, cmd->name))

            monitor_printf(mon, "%s%s %s -- %s\n", prefix, cmd->name,
                           cmd->params, cmd->help);

    }
}

static void help_cmd(Monitor *mon, const char *name)

{
    if (name && !strcmp(name, "info")) {

        help_cmd_dump(mon, info_cmds, "info ", NULL);

    } else {

        help_cmd_dump(mon, mon_cmds, "", name);

        if (name && !strcmp(name, "log")) {

            const CPULogItem *item;

            monitor_printf(mon, "Log items (comma separated):\n");
            monitor_printf(mon, "%-10s %s\n", "none", "remove all logs");

            for(item = cpu_log_items; item->mask != 0; item++) {

                monitor_printf(mon, "%-10s %s\n", item->name, item->help);

            }
        }

    }
}

static void do_commit(Monitor *mon, const char *device)

{

    int i, all_devices;

    all_devices = !strcmp(device, "all");

    for (i = 0; i < nb_drives; i++) {

            if (all_devices ||

                !strcmp(bdrv_get_device_name(drives_table[i].bdrv), device))
                bdrv_commit(drives_table[i].bdrv);

    }
}

static void do_info(Monitor *mon, const char *item)

{

    const mon_cmd_t *cmd;
    void (*handler)(Monitor *);

    if (!item)

        goto help;
    for(cmd = info_cmds; cmd->name != NULL; cmd++) {

        if (compare_cmd(item, cmd->name))

            goto found;
    }
 help:

    help_cmd(mon, "info");

    return;
 found:

    handler = cmd->handler;

    handler(mon);

}

static void do_info_version(Monitor *mon)

{

    monitor_printf(mon, "%s\n", QEMU_VERSION);

}

static void do_info_name(Monitor *mon)

{
    if (qemu_name)

        monitor_printf(mon, "%s\n", qemu_name);

}

#if defined(TARGET_I386)

static void do_info_hpet(Monitor *mon)

{

    monitor_printf(mon, "HPET is %s by QEMU\n",
                   (no_hpet) ? "disabled" : "enabled");

}

#endif

static void do_info_uuid(Monitor *mon)

{

    monitor_printf(mon, UUID_FMT "\n", qemu_uuid[0], qemu_uuid[1],
                   qemu_uuid[2], qemu_uuid[3], qemu_uuid[4], qemu_uuid[5],
                   qemu_uuid[6], qemu_uuid[7], qemu_uuid[8], qemu_uuid[9],
                   qemu_uuid[10], qemu_uuid[11], qemu_uuid[12], qemu_uuid[13],
                   qemu_uuid[14], qemu_uuid[15]);

}

/* get the current CPU defined by the user */

static int mon_set_cpu(int cpu_index)

{
    CPUState *env;

    for(env = first_cpu; env != NULL; env = env->next_cpu) {
        if (env->cpu_index == cpu_index) {

            cur_mon->mon_cpu = env;

            return 0;
        }
    }
    return -1;
}

static CPUState *mon_get_cpu(void)

{

    if (!cur_mon->mon_cpu) {

        mon_set_cpu(0);
    }

    return cur_mon->mon_cpu;

}

static void do_info_registers(Monitor *mon)

{

    CPUState *env;
    env = mon_get_cpu();
    if (!env)
        return;

#ifdef TARGET_I386

    cpu_dump_state(env, (FILE *)mon, monitor_fprintf,

                   X86_DUMP_FPU);

#else

    cpu_dump_state(env, (FILE *)mon, monitor_fprintf,

                   0);

#endif
}

static void do_info_cpus(Monitor *mon)

{
    CPUState *env;

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

    for(env = first_cpu; env != NULL; env = env->next_cpu) {

        monitor_printf(mon, "%c CPU #%d:",

                       (env == mon->mon_cpu) ? '*' : ' ',

                       env->cpu_index);

#if defined(TARGET_I386)

        monitor_printf(mon, " pc=0x" TARGET_FMT_lx,
                       env->eip + env->segs[R_CS].base);

#elif defined(TARGET_PPC)

        monitor_printf(mon, " nip=0x" TARGET_FMT_lx, env->nip);

#elif defined(TARGET_SPARC)

        monitor_printf(mon, " pc=0x" TARGET_FMT_lx " npc=0x" TARGET_FMT_lx,
                       env->pc, env->npc);

#elif defined(TARGET_MIPS)

        monitor_printf(mon, " PC=0x" TARGET_FMT_lx, env->active_tc.PC);

#endif

        if (env->halted)

            monitor_printf(mon, " (halted)");
        monitor_printf(mon, "\n");

    }
}

static void do_cpu_set(Monitor *mon, int index)

{
    if (mon_set_cpu(index) < 0)

        monitor_printf(mon, "Invalid CPU index\n");

}

static void do_info_jit(Monitor *mon)

{

    dump_exec_info((FILE *)mon, monitor_fprintf);

}

static void do_info_history(Monitor *mon)

{
    int i;

    const char *str;

    if (!mon->rs)
        return;

    i = 0;
    for(;;) {

        str = readline_get_history(mon->rs, i);

        if (!str)
            break;

        monitor_printf(mon, "%d: '%s'\n", i, str);

        i++;

    }
}

#if defined(TARGET_PPC)
/* XXX: not implemented in other targets */

static void do_info_cpu_stats(Monitor *mon)

{
    CPUState *env;

    env = mon_get_cpu();

    cpu_dump_statistics(env, (FILE *)mon, &monitor_fprintf, 0);

}
#endif

static void do_quit(Monitor *mon)

{
    exit(0);
}

static int eject_device(Monitor *mon, BlockDriverState *bs, int force)

{
    if (bdrv_is_inserted(bs)) {
        if (!force) {
            if (!bdrv_is_removable(bs)) {

                monitor_printf(mon, "device is not removable\n");

                return -1;
            }
            if (bdrv_is_locked(bs)) {

                monitor_printf(mon, "device is locked\n");

                return -1;
            }
        }
        bdrv_close(bs);
    }
    return 0;
}

static void do_eject(Monitor *mon, int force, const char *filename)

{
    BlockDriverState *bs;

    bs = bdrv_find(filename);

    if (!bs) {

        monitor_printf(mon, "device not found\n");

        return;
    }

    eject_device(mon, bs, force);

}

static void do_change_block(Monitor *mon, const char *device,
                            const char *filename, const char *fmt)

{
    BlockDriverState *bs;

    BlockDriver *drv = NULL;

    bs = bdrv_find(device);

    if (!bs) {

        monitor_printf(mon, "device not found\n");

        return;
    }

    if (fmt) {
        drv = bdrv_find_format(fmt);
        if (!drv) {

            monitor_printf(mon, "invalid format %s\n", fmt);

            return;
        }
    }

    if (eject_device(mon, bs, 0) < 0)

        return;

    bdrv_open2(bs, filename, 0, drv);

    monitor_read_bdrv_key_start(mon, bs, NULL, NULL);

}

static void change_vnc_password_cb(Monitor *mon, const char *password,
                                   void *opaque)

{
    if (vnc_display_password(NULL, password) < 0)

        monitor_printf(mon, "could not set VNC server password\n");

    monitor_read_command(mon, 1);

}

static void do_change_vnc(Monitor *mon, const char *target, const char *arg)

{

    if (strcmp(target, "passwd") == 0 ||
	strcmp(target, "password") == 0) {

	if (arg) {

            char password[9];

	    strncpy(password, arg, sizeof(password));
	    password[sizeof(password) - 1] = '\0';

            change_vnc_password_cb(mon, password, NULL);

        } else {

            monitor_read_password(mon, change_vnc_password_cb, NULL);

        }

    } else {
	if (vnc_display_open(NULL, target) < 0)

            monitor_printf(mon, "could not start VNC server on %s\n", target);

    }

}

static void do_change(Monitor *mon, const char *device, const char *target,
                      const char *arg)

{
    if (strcmp(device, "vnc") == 0) {

	do_change_vnc(mon, target, arg);

    } else {

	do_change_block(mon, device, target, arg);

    }
}

static void do_screen_dump(Monitor *mon, const char *filename)

{

    vga_hw_screen_dump(filename);

}

static void do_logfile(Monitor *mon, const char *filename)

{
    cpu_set_log_filename(filename);
}

static void do_log(Monitor *mon, const char *items)

{
    int mask;

    if (!strcmp(items, "none")) {

        mask = 0;
    } else {

        mask = cpu_str_to_log_mask(items);

        if (!mask) {

            help_cmd(mon, "log");

            return;
        }
    }
    cpu_set_log(mask);
}

static void do_stop(Monitor *mon)

{
    vm_stop(EXCP_INTERRUPT);
}

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

struct bdrv_iterate_context {
    Monitor *mon;
    int err;
};

static void do_cont(Monitor *mon)

{

    struct bdrv_iterate_context context = { mon, 0 };

    bdrv_iterate(encrypted_bdrv_it, &context);

    /* only resume the vm if all keys are set and valid */

    if (!context.err)