[qemu.git] / arch_init.c

/*
 * QEMU System Emulator
 *
 * Copyright (c) 2003-2008 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 <stdint.h>
#include <stdarg.h>
#include <stdlib.h>
#ifndef _WIN32
#include <sys/types.h>
#include <sys/mman.h>
#endif
#include "config.h"
#include "monitor.h"
#include "sysemu.h"
#include "arch_init.h"
#include "audio/audio.h"
#include "hw/pc.h"
#include "hw/pci.h"
#include "hw/audiodev.h"
#include "kvm.h"
#include "migration.h"
#include "net.h"
#include "gdbstub.h"
#include "hw/smbios.h"

#ifdef TARGET_SPARC
int graphic_width = 1024;
int graphic_height = 768;
int graphic_depth = 8;
#else
int graphic_width = 800;
int graphic_height = 600;
int graphic_depth = 15;
#endif

const char arch_config_name[] = CONFIG_QEMU_CONFDIR "/target-" TARGET_ARCH ".conf";

#if defined(TARGET_ALPHA)
#define QEMU_ARCH QEMU_ARCH_ALPHA
#elif defined(TARGET_ARM)
#define QEMU_ARCH QEMU_ARCH_ARM
#elif defined(TARGET_CRIS)
#define QEMU_ARCH QEMU_ARCH_CRIS
#elif defined(TARGET_I386)
#define QEMU_ARCH QEMU_ARCH_I386
#elif defined(TARGET_M68K)
#define QEMU_ARCH QEMU_ARCH_M68K
#elif defined(TARGET_LM32)
#define QEMU_ARCH QEMU_ARCH_LM32
#elif defined(TARGET_MICROBLAZE)
#define QEMU_ARCH QEMU_ARCH_MICROBLAZE
#elif defined(TARGET_MIPS)
#define QEMU_ARCH QEMU_ARCH_MIPS
#elif defined(TARGET_PPC)
#define QEMU_ARCH QEMU_ARCH_PPC
#elif defined(TARGET_S390X)
#define QEMU_ARCH QEMU_ARCH_S390X
#elif defined(TARGET_SH4)
#define QEMU_ARCH QEMU_ARCH_SH4
#elif defined(TARGET_SPARC)
#define QEMU_ARCH QEMU_ARCH_SPARC
#elif defined(TARGET_XTENSA)
#define QEMU_ARCH QEMU_ARCH_XTENSA
#endif

const uint32_t arch_type = QEMU_ARCH;

/***********************************************************/
/* ram save/restore */

#define RAM_SAVE_FLAG_FULL     0x01 /* Obsolete, not used anymore */
#define RAM_SAVE_FLAG_COMPRESS 0x02
#define RAM_SAVE_FLAG_MEM_SIZE 0x04
#define RAM_SAVE_FLAG_PAGE     0x08
#define RAM_SAVE_FLAG_EOS      0x10
#define RAM_SAVE_FLAG_CONTINUE 0x20

static int is_dup_page(uint8_t *page, uint8_t ch)
{
    uint32_t val = ch << 24 | ch << 16 | ch << 8 | ch;
    uint32_t *array = (uint32_t *)page;
    int i;

    for (i = 0; i < (TARGET_PAGE_SIZE / 4); i++) {
        if (array[i] != val) {
            return 0;
        }
    }

    return 1;
}

static RAMBlock *last_block;
static ram_addr_t last_offset;

static int ram_save_block(QEMUFile *f)
{
    RAMBlock *block = last_block;
    ram_addr_t offset = last_offset;
    ram_addr_t current_addr;
    int bytes_sent = 0;

    if (!block)
        block = QLIST_FIRST(&ram_list.blocks);

    current_addr = block->offset + offset;

    do {
        if (cpu_physical_memory_get_dirty(current_addr, MIGRATION_DIRTY_FLAG)) {
            uint8_t *p;
            int cont = (block == last_block) ? RAM_SAVE_FLAG_CONTINUE : 0;

            cpu_physical_memory_reset_dirty(current_addr,
                                            current_addr + TARGET_PAGE_SIZE,
                                            MIGRATION_DIRTY_FLAG);

            p = block->host + offset;

            if (is_dup_page(p, *p)) {
                qemu_put_be64(f, offset | cont | RAM_SAVE_FLAG_COMPRESS);
                if (!cont) {
                    qemu_put_byte(f, strlen(block->idstr));
                    qemu_put_buffer(f, (uint8_t *)block->idstr,
                                    strlen(block->idstr));
                }
                qemu_put_byte(f, *p);
                bytes_sent = 1;
            } else {
                qemu_put_be64(f, offset | cont | RAM_SAVE_FLAG_PAGE);
                if (!cont) {
                    qemu_put_byte(f, strlen(block->idstr));
                    qemu_put_buffer(f, (uint8_t *)block->idstr,
                                    strlen(block->idstr));
                }
                qemu_put_buffer(f, p, TARGET_PAGE_SIZE);
                bytes_sent = TARGET_PAGE_SIZE;
            }

            break;
        }

        offset += TARGET_PAGE_SIZE;
        if (offset >= block->length) {
            offset = 0;
            block = QLIST_NEXT(block, next);
            if (!block)
                block = QLIST_FIRST(&ram_list.blocks);
        }

        current_addr = block->offset + offset;

    } while (current_addr != last_block->offset + last_offset);

    last_block = block;
    last_offset = offset;

    return bytes_sent;
}

static uint64_t bytes_transferred;

static ram_addr_t ram_save_remaining(void)
{
    RAMBlock *block;
    ram_addr_t count = 0;

    QLIST_FOREACH(block, &ram_list.blocks, next) {
        ram_addr_t addr;
        for (addr = block->offset; addr < block->offset + block->length;
             addr += TARGET_PAGE_SIZE) {
            if (cpu_physical_memory_get_dirty(addr, MIGRATION_DIRTY_FLAG)) {
                count++;
            }
        }
    }

    return count;
}

uint64_t ram_bytes_remaining(void)
{
    return ram_save_remaining() * TARGET_PAGE_SIZE;
}

uint64_t ram_bytes_transferred(void)
{
    return bytes_transferred;
}

uint64_t ram_bytes_total(void)
{
    RAMBlock *block;
    uint64_t total = 0;

    QLIST_FOREACH(block, &ram_list.blocks, next)
        total += block->length;

    return total;
}

static int block_compar(const void *a, const void *b)
{
    RAMBlock * const *ablock = a;
    RAMBlock * const *bblock = b;
    if ((*ablock)->offset < (*bblock)->offset) {
        return -1;
    } else if ((*ablock)->offset > (*bblock)->offset) {
        return 1;
    }
    return 0;
}

static void sort_ram_list(void)
{
    RAMBlock *block, *nblock, **blocks;
    int n;
    n = 0;
    QLIST_FOREACH(block, &ram_list.blocks, next) {
        ++n;
    }
    blocks = g_malloc(n * sizeof *blocks);
    n = 0;
    QLIST_FOREACH_SAFE(block, &ram_list.blocks, next, nblock) {
        blocks[n++] = block;
        QLIST_REMOVE(block, next);
    }
    qsort(blocks, n, sizeof *blocks, block_compar);
    while (--n >= 0) {
        QLIST_INSERT_HEAD(&ram_list.blocks, blocks[n], next);
    }
    g_free(blocks);
}

int ram_save_live(Monitor *mon, QEMUFile *f, int stage, void *opaque)
{
    ram_addr_t addr;
    uint64_t bytes_transferred_last;
    double bwidth = 0;
    uint64_t expected_time = 0;
    int ret;

    if (stage < 0) {
        cpu_physical_memory_set_dirty_tracking(0);
        return 0;
    }

    if (cpu_physical_sync_dirty_bitmap(0, TARGET_PHYS_ADDR_MAX) != 0) {
        qemu_file_set_error(f, -EINVAL);
        return -EINVAL;
    }

    if (stage == 1) {
        RAMBlock *block;
        bytes_transferred = 0;
        last_block = NULL;
        last_offset = 0;
        sort_ram_list();

        /* Make sure all dirty bits are set */
        QLIST_FOREACH(block, &ram_list.blocks, next) {
            for (addr = block->offset; addr < block->offset + block->length;
                 addr += TARGET_PAGE_SIZE) {
                if (!cpu_physical_memory_get_dirty(addr,
                                                   MIGRATION_DIRTY_FLAG)) {
                    cpu_physical_memory_set_dirty(addr);
                }
            }
        }

        /* Enable dirty memory tracking */
        cpu_physical_memory_set_dirty_tracking(1);

        qemu_put_be64(f, ram_bytes_total() | RAM_SAVE_FLAG_MEM_SIZE);

        QLIST_FOREACH(block, &ram_list.blocks, next) {
            qemu_put_byte(f, strlen(block->idstr));
            qemu_put_buffer(f, (uint8_t *)block->idstr, strlen(block->idstr));
            qemu_put_be64(f, block->length);
        }
    }

    bytes_transferred_last = bytes_transferred;
    bwidth = qemu_get_clock_ns(rt_clock);

    while ((ret = qemu_file_rate_limit(f)) == 0) {
        int bytes_sent;

        bytes_sent = ram_save_block(f);
        bytes_transferred += bytes_sent;
        if (bytes_sent == 0) { /* no more blocks */
            break;
        }
    }

    if (ret < 0) {
        return ret;
    }

    bwidth = qemu_get_clock_ns(rt_clock) - bwidth;
    bwidth = (bytes_transferred - bytes_transferred_last) / bwidth;

    /* if we haven't transferred anything this round, force expected_time to a
     * a very high value, but without crashing */
    if (bwidth == 0) {
        bwidth = 0.000001;
    }

    /* try transferring iterative blocks of memory */
    if (stage == 3) {
        int bytes_sent;

        /* flush all remaining blocks regardless of rate limiting */
        while ((bytes_sent = ram_save_block(f)) != 0) {
            bytes_transferred += bytes_sent;
        }
        cpu_physical_memory_set_dirty_tracking(0);
    }

    qemu_put_be64(f, RAM_SAVE_FLAG_EOS);

    expected_time = ram_save_remaining() * TARGET_PAGE_SIZE / bwidth;

    return (stage == 2) && (expected_time <= migrate_max_downtime());
}

static inline void *host_from_stream_offset(QEMUFile *f,
                                            ram_addr_t offset,
                                            int flags)
{
    static RAMBlock *block = NULL;
    char id[256];
    uint8_t len;

    if (flags & RAM_SAVE_FLAG_CONTINUE) {
        if (!block) {
            fprintf(stderr, "Ack, bad migration stream!\n");
            return NULL;
        }

        return block->host + offset;
    }

    len = qemu_get_byte(f);
    qemu_get_buffer(f, (uint8_t *)id, len);
    id[len] = 0;

    QLIST_FOREACH(block, &ram_list.blocks, next) {
        if (!strncmp(id, block->idstr, sizeof(id)))
            return block->host + offset;
    }

    fprintf(stderr, "Can't find block %s!\n", id);
    return NULL;
}

int ram_load(QEMUFile *f, void *opaque, int version_id)
{
    ram_addr_t addr;
    int flags;
    int error;

    if (version_id < 3 || version_id > 4) {
        return -EINVAL;
    }

    do {
        addr = qemu_get_be64(f);

        flags = addr & ~TARGET_PAGE_MASK;
        addr &= TARGET_PAGE_MASK;

        if (flags & RAM_SAVE_FLAG_MEM_SIZE) {
            if (version_id == 3) {
                if (addr != ram_bytes_total()) {
                    return -EINVAL;
                }
            } else {
                /* Synchronize RAM block list */
                char id[256];
                ram_addr_t length;
                ram_addr_t total_ram_bytes = addr;

                while (total_ram_bytes) {
                    RAMBlock *block;
                    uint8_t len;

                    len = qemu_get_byte(f);
                    qemu_get_buffer(f, (uint8_t *)id, len);
                    id[len] = 0;
                    length = qemu_get_be64(f);

                    QLIST_FOREACH(block, &ram_list.blocks, next) {
                        if (!strncmp(id, block->idstr, sizeof(id))) {
                            if (block->length != length)
                                return -EINVAL;
                            break;
                        }
                    }

                    if (!block) {
                        fprintf(stderr, "Unknown ramblock \"%s\", cannot "
                                "accept migration\n", id);
                        return -EINVAL;
                    }

                    total_ram_bytes -= length;
                }
            }
        }

        if (flags & RAM_SAVE_FLAG_COMPRESS) {
            void *host;
            uint8_t ch;

            if (version_id == 3)
                host = qemu_get_ram_ptr(addr);
            else
                host = host_from_stream_offset(f, addr, flags);
            if (!host) {
                return -EINVAL;
            }

            ch = qemu_get_byte(f);
            memset(host, ch, TARGET_PAGE_SIZE);
#ifndef _WIN32
            if (ch == 0 &&
                (!kvm_enabled() || kvm_has_sync_mmu())) {
                qemu_madvise(host, TARGET_PAGE_SIZE, QEMU_MADV_DONTNEED);
            }
#endif
        } else if (flags & RAM_SAVE_FLAG_PAGE) {
            void *host;

            if (version_id == 3)
                host = qemu_get_ram_ptr(addr);
            else
                host = host_from_stream_offset(f, addr, flags);

            qemu_get_buffer(f, host, TARGET_PAGE_SIZE);
        }
        error = qemu_file_get_error(f);
        if (error) {
            return error;
        }
    } while (!(flags & RAM_SAVE_FLAG_EOS));

    return 0;
}

#ifdef HAS_AUDIO
struct soundhw {
    const char *name;
    const char *descr;
    int enabled;
    int isa;
    union {
        int (*init_isa) (qemu_irq *pic);
        int (*init_pci) (PCIBus *bus);
    } init;
};

static struct soundhw soundhw[] = {
#ifdef HAS_AUDIO_CHOICE
#if defined(TARGET_I386) || defined(TARGET_MIPS)
    {
        "pcspk",
        "PC speaker",
        0,
        1,
        { .init_isa = pcspk_audio_init }
    },
#endif

#ifdef CONFIG_SB16
    {
        "sb16",
        "Creative Sound Blaster 16",
        0,
        1,
        { .init_isa = SB16_init }
    },
#endif

#ifdef CONFIG_CS4231A
    {
        "cs4231a",
        "CS4231A",
        0,
        1,
        { .init_isa = cs4231a_init }
    },
#endif

#ifdef CONFIG_ADLIB
    {
        "adlib",
#ifdef HAS_YMF262
        "Yamaha YMF262 (OPL3)",
#else
        "Yamaha YM3812 (OPL2)",
#endif
        0,
        1,
        { .init_isa = Adlib_init }
    },
#endif

#ifdef CONFIG_GUS
    {
        "gus",
        "Gravis Ultrasound GF1",
        0,
        1,
        { .init_isa = GUS_init }
    },
#endif

#ifdef CONFIG_AC97
    {
        "ac97",
        "Intel 82801AA AC97 Audio",
        0,
        0,
        { .init_pci = ac97_init }
    },
#endif

#ifdef CONFIG_ES1370
    {
        "es1370",
        "ENSONIQ AudioPCI ES1370",
        0,
        0,
        { .init_pci = es1370_init }
    },
#endif

#ifdef CONFIG_HDA
    {
        "hda",
        "Intel HD Audio",
        0,
        0,
        { .init_pci = intel_hda_and_codec_init }
    },
#endif

#endif /* HAS_AUDIO_CHOICE */

    { NULL, NULL, 0, 0, { NULL } }
};

void select_soundhw(const char *optarg)
{
    struct soundhw *c;

    if (*optarg == '?') {
    show_valid_cards:

        printf("Valid sound card names (comma separated):\n");
        for (c = soundhw; c->name; ++c) {
            printf ("%-11s %s\n", c->name, c->descr);
        }
        printf("\n-soundhw all will enable all of the above\n");
        exit(*optarg != '?');
    }
    else {
        size_t l;
        const char *p;
        char *e;
        int bad_card = 0;

        if (!strcmp(optarg, "all")) {
            for (c = soundhw; c->name; ++c) {
                c->enabled = 1;
            }
            return;
        }

        p = optarg;
        while (*p) {
            e = strchr(p, ',');
            l = !e ? strlen(p) : (size_t) (e - p);

            for (c = soundhw; c->name; ++c) {
                if (!strncmp(c->name, p, l) && !c->name[l]) {
                    c->enabled = 1;
                    break;
                }
            }

            if (!c->name) {
                if (l > 80) {
                    fprintf(stderr,
                            "Unknown sound card name (too big to show)\n");
                }
                else {
                    fprintf(stderr, "Unknown sound card name `%.*s'\n",
                            (int) l, p);
                }
                bad_card = 1;
            }
            p += l + (e != NULL);
        }

        if (bad_card) {
            goto show_valid_cards;
        }
    }
}

void audio_init(qemu_irq *isa_pic, PCIBus *pci_bus)
{
    struct soundhw *c;

    for (c = soundhw; c->name; ++c) {
        if (c->enabled) {
            if (c->isa) {
                if (isa_pic) {
                    c->init.init_isa(isa_pic);
                }
            } else {
                if (pci_bus) {
                    c->init.init_pci(pci_bus);
                }
            }
        }
    }
}
#else
void select_soundhw(const char *optarg)
{
}
void audio_init(qemu_irq *isa_pic, PCIBus *pci_bus)
{
}
#endif

int qemu_uuid_parse(const char *str, uint8_t *uuid)
{
    int ret;

    if (strlen(str) != 36) {
        return -1;
    }

    ret = sscanf(str, UUID_FMT, &uuid[0], &uuid[1], &uuid[2], &uuid[3],
                 &uuid[4], &uuid[5], &uuid[6], &uuid[7], &uuid[8], &uuid[9],
                 &uuid[10], &uuid[11], &uuid[12], &uuid[13], &uuid[14],
                 &uuid[15]);

    if (ret != 16) {
        return -1;
    }
#ifdef TARGET_I386
    smbios_add_field(1, offsetof(struct smbios_type_1, uuid), 16, uuid);
#endif
    return 0;
}

void do_acpitable_option(const char *optarg)
{
#ifdef TARGET_I386
    if (acpi_table_add(optarg) < 0) {
        fprintf(stderr, "Wrong acpi table provided\n");
        exit(1);
    }
#endif
}

void do_smbios_option(const char *optarg)
{
#ifdef TARGET_I386
    if (smbios_entry_add(optarg) < 0) {
        fprintf(stderr, "Wrong smbios provided\n");
        exit(1);
    }
#endif
}

void cpudef_init(void)
{
#if defined(cpudef_setup)
    cpudef_setup(); /* parse cpu definitions in target config file */
#endif
}

int audio_available(void)
{
#ifdef HAS_AUDIO
    return 1;
#else
    return 0;
#endif
}

int tcg_available(void)
{
    return 1;
}

int kvm_available(void)
{
#ifdef CONFIG_KVM
    return 1;
#else
    return 0;
#endif
}

int xen_available(void)
{
#ifdef CONFIG_XEN
    return 1;
#else
    return 0;
#endif
}
Commit	Line	Data
ad96090a BS	1	/*
	2	* QEMU System Emulator
	3	*
	4	* Copyright (c) 2003-2008 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 <stdint.h>
	25	#include <stdarg.h>
b2e0a138	26	#include <stdlib.h>
ad96090a	27	#ifndef _WIN32
1c47cb16	28	#include <sys/types.h>
ad96090a BS	29	#include <sys/mman.h>
	30	#endif
	31	#include "config.h"
	32	#include "monitor.h"
	33	#include "sysemu.h"
	34	#include "arch_init.h"
	35	#include "audio/audio.h"
	36	#include "hw/pc.h"
	37	#include "hw/pci.h"
	38	#include "hw/audiodev.h"
	39	#include "kvm.h"
	40	#include "migration.h"
	41	#include "net.h"
	42	#include "gdbstub.h"
	43	#include "hw/smbios.h"
	44
	45	#ifdef TARGET_SPARC
	46	int graphic_width = 1024;
	47	int graphic_height = 768;
	48	int graphic_depth = 8;
	49	#else
	50	int graphic_width = 800;
	51	int graphic_height = 600;
	52	int graphic_depth = 15;
	53	#endif
	54
	55	const char arch_config_name[] = CONFIG_QEMU_CONFDIR "/target-" TARGET_ARCH ".conf";
	56
	57	#if defined(TARGET_ALPHA)
	58	#define QEMU_ARCH QEMU_ARCH_ALPHA
	59	#elif defined(TARGET_ARM)
	60	#define QEMU_ARCH QEMU_ARCH_ARM
	61	#elif defined(TARGET_CRIS)
	62	#define QEMU_ARCH QEMU_ARCH_CRIS
	63	#elif defined(TARGET_I386)
	64	#define QEMU_ARCH QEMU_ARCH_I386
	65	#elif defined(TARGET_M68K)
	66	#define QEMU_ARCH QEMU_ARCH_M68K
81ea0e13 MW	67	#elif defined(TARGET_LM32)
81ea0e13 MW	68	#define QEMU_ARCH QEMU_ARCH_LM32
ad96090a BS	69	#elif defined(TARGET_MICROBLAZE)
	70	#define QEMU_ARCH QEMU_ARCH_MICROBLAZE
	71	#elif defined(TARGET_MIPS)
	72	#define QEMU_ARCH QEMU_ARCH_MIPS
	73	#elif defined(TARGET_PPC)
	74	#define QEMU_ARCH QEMU_ARCH_PPC
	75	#elif defined(TARGET_S390X)
	76	#define QEMU_ARCH QEMU_ARCH_S390X
	77	#elif defined(TARGET_SH4)
	78	#define QEMU_ARCH QEMU_ARCH_SH4
	79	#elif defined(TARGET_SPARC)
	80	#define QEMU_ARCH QEMU_ARCH_SPARC
2328826b MF	81	#elif defined(TARGET_XTENSA)
2328826b MF	82	#define QEMU_ARCH QEMU_ARCH_XTENSA
ad96090a BS	83	#endif
	84
	85	const uint32_t arch_type = QEMU_ARCH;
	86
	87	/***********************************************************/
	88	/* ram save/restore */
	89
d20878d2 YT	90	#define RAM_SAVE_FLAG_FULL 0x01 /* Obsolete, not used anymore */
	91	#define RAM_SAVE_FLAG_COMPRESS 0x02
	92	#define RAM_SAVE_FLAG_MEM_SIZE 0x04
	93	#define RAM_SAVE_FLAG_PAGE 0x08
	94	#define RAM_SAVE_FLAG_EOS 0x10
	95	#define RAM_SAVE_FLAG_CONTINUE 0x20
ad96090a BS	96
	97	static int is_dup_page(uint8_t *page, uint8_t ch)
	98	{
	99	uint32_t val = ch << 24 \| ch << 16 \| ch << 8 \| ch;
	100	uint32_t array = (uint32_t )page;
	101	int i;
	102
	103	for (i = 0; i < (TARGET_PAGE_SIZE / 4); i++) {
	104	if (array[i] != val) {
	105	return 0;
	106	}
	107	}
	108
	109	return 1;
	110	}
	111
760e77ea AW	112	static RAMBlock *last_block;
	113	static ram_addr_t last_offset;
	114
ad96090a BS	115	static int ram_save_block(QEMUFile *f)
ad96090a BS	116	{
e44359c3 AW	117	RAMBlock *block = last_block;
	118	ram_addr_t offset = last_offset;
	119	ram_addr_t current_addr;
3fc250b4	120	int bytes_sent = 0;
ad96090a	121
e44359c3 AW	122	if (!block)
	123	block = QLIST_FIRST(&ram_list.blocks);
	124
	125	current_addr = block->offset + offset;
	126
	127	do {
ad96090a BS	128	if (cpu_physical_memory_get_dirty(current_addr, MIGRATION_DIRTY_FLAG)) {
ad96090a BS	129	uint8_t *p;
a55bbe31	130	int cont = (block == last_block) ? RAM_SAVE_FLAG_CONTINUE : 0;
ad96090a BS	131
	132	cpu_physical_memory_reset_dirty(current_addr,
	133	current_addr + TARGET_PAGE_SIZE,
	134	MIGRATION_DIRTY_FLAG);
	135
97ab12d4	136	p = block->host + offset;
ad96090a BS	137
ad96090a BS	138	if (is_dup_page(p, *p)) {
a55bbe31 AW	139	qemu_put_be64(f, offset \| cont \| RAM_SAVE_FLAG_COMPRESS);
	140	if (!cont) {
	141	qemu_put_byte(f, strlen(block->idstr));
	142	qemu_put_buffer(f, (uint8_t *)block->idstr,
	143	strlen(block->idstr));
	144	}
ad96090a	145	qemu_put_byte(f, *p);
3fc250b4	146	bytes_sent = 1;
ad96090a	147	} else {
a55bbe31 AW	148	qemu_put_be64(f, offset \| cont \| RAM_SAVE_FLAG_PAGE);
	149	if (!cont) {
	150	qemu_put_byte(f, strlen(block->idstr));
	151	qemu_put_buffer(f, (uint8_t *)block->idstr,
	152	strlen(block->idstr));
	153	}
ad96090a	154	qemu_put_buffer(f, p, TARGET_PAGE_SIZE);
3fc250b4	155	bytes_sent = TARGET_PAGE_SIZE;
ad96090a BS	156	}
ad96090a BS	157
ad96090a BS	158	break;
ad96090a BS	159	}
e44359c3 AW	160
	161	offset += TARGET_PAGE_SIZE;
	162	if (offset >= block->length) {
	163	offset = 0;
	164	block = QLIST_NEXT(block, next);
	165	if (!block)
	166	block = QLIST_FIRST(&ram_list.blocks);
	167	}
	168
	169	current_addr = block->offset + offset;
	170
	171	} while (current_addr != last_block->offset + last_offset);
	172
	173	last_block = block;
	174	last_offset = offset;
ad96090a	175
3fc250b4	176	return bytes_sent;
ad96090a BS	177	}
	178
	179	static uint64_t bytes_transferred;
	180
	181	static ram_addr_t ram_save_remaining(void)
	182	{
e44359c3	183	RAMBlock *block;
ad96090a BS	184	ram_addr_t count = 0;
ad96090a BS	185
e44359c3 AW	186	QLIST_FOREACH(block, &ram_list.blocks, next) {
	187	ram_addr_t addr;
	188	for (addr = block->offset; addr < block->offset + block->length;
	189	addr += TARGET_PAGE_SIZE) {
	190	if (cpu_physical_memory_get_dirty(addr, MIGRATION_DIRTY_FLAG)) {
	191	count++;
	192	}
ad96090a BS	193	}
	194	}
	195
	196	return count;
	197	}
	198
	199	uint64_t ram_bytes_remaining(void)
	200	{
	201	return ram_save_remaining() * TARGET_PAGE_SIZE;
	202	}
	203
	204	uint64_t ram_bytes_transferred(void)
	205	{
	206	return bytes_transferred;
	207	}
	208
	209	uint64_t ram_bytes_total(void)
	210	{
d17b5288 AW	211	RAMBlock *block;
	212	uint64_t total = 0;
	213
	214	QLIST_FOREACH(block, &ram_list.blocks, next)
	215	total += block->length;
	216
	217	return total;
ad96090a BS	218	}
ad96090a BS	219
b2e0a138 MT	220	static int block_compar(const void a, const void b)
	221	{
	222	RAMBlock * const *ablock = a;
	223	RAMBlock * const *bblock = b;
	224	if ((ablock)->offset < (bblock)->offset) {
	225	return -1;
	226	} else if ((ablock)->offset > (bblock)->offset) {
	227	return 1;
	228	}
	229	return 0;
	230	}
	231
	232	static void sort_ram_list(void)
	233	{
	234	RAMBlock block, nblock, **blocks;
	235	int n;
	236	n = 0;
	237	QLIST_FOREACH(block, &ram_list.blocks, next) {
	238	++n;
	239	}
7267c094	240	blocks = g_malloc(n * sizeof *blocks);
b2e0a138 MT	241	n = 0;
	242	QLIST_FOREACH_SAFE(block, &ram_list.blocks, next, nblock) {
	243	blocks[n++] = block;
	244	QLIST_REMOVE(block, next);
	245	}
	246	qsort(blocks, n, sizeof *blocks, block_compar);
	247	while (--n >= 0) {
	248	QLIST_INSERT_HEAD(&ram_list.blocks, blocks[n], next);
	249	}
7267c094	250	g_free(blocks);
b2e0a138 MT	251	}
b2e0a138 MT	252
ad96090a BS	253	int ram_save_live(Monitor mon, QEMUFile f, int stage, void *opaque)
	254	{
	255	ram_addr_t addr;
	256	uint64_t bytes_transferred_last;
	257	double bwidth = 0;
	258	uint64_t expected_time = 0;
2975725f	259	int ret;
ad96090a BS	260
	261	if (stage < 0) {
	262	cpu_physical_memory_set_dirty_tracking(0);
	263	return 0;
	264	}
	265
	266	if (cpu_physical_sync_dirty_bitmap(0, TARGET_PHYS_ADDR_MAX) != 0) {
dcd1d224	267	qemu_file_set_error(f, -EINVAL);
2975725f	268	return -EINVAL;
ad96090a BS	269	}
	270
	271	if (stage == 1) {
97ab12d4	272	RAMBlock *block;
ad96090a	273	bytes_transferred = 0;
760e77ea AW	274	last_block = NULL;
760e77ea AW	275	last_offset = 0;
b2e0a138	276	sort_ram_list();
ad96090a BS	277
ad96090a BS	278	/* Make sure all dirty bits are set */
e44359c3 AW	279	QLIST_FOREACH(block, &ram_list.blocks, next) {
	280	for (addr = block->offset; addr < block->offset + block->length;
	281	addr += TARGET_PAGE_SIZE) {
	282	if (!cpu_physical_memory_get_dirty(addr,
	283	MIGRATION_DIRTY_FLAG)) {
	284	cpu_physical_memory_set_dirty(addr);
	285	}
ad96090a BS	286	}
	287	}
	288
	289	/* Enable dirty memory tracking */
	290	cpu_physical_memory_set_dirty_tracking(1);
	291
e44359c3	292	qemu_put_be64(f, ram_bytes_total() \| RAM_SAVE_FLAG_MEM_SIZE);
97ab12d4 AW	293
	294	QLIST_FOREACH(block, &ram_list.blocks, next) {
	295	qemu_put_byte(f, strlen(block->idstr));
	296	qemu_put_buffer(f, (uint8_t *)block->idstr, strlen(block->idstr));
	297	qemu_put_be64(f, block->length);
	298	}
ad96090a BS	299	}
	300
	301	bytes_transferred_last = bytes_transferred;
	302	bwidth = qemu_get_clock_ns(rt_clock);
	303
2975725f	304	while ((ret = qemu_file_rate_limit(f)) == 0) {
3fc250b4	305	int bytes_sent;
ad96090a	306
3fc250b4 PR	307	bytes_sent = ram_save_block(f);
	308	bytes_transferred += bytes_sent;
	309	if (bytes_sent == 0) { /* no more blocks */
ad96090a BS	310	break;
	311	}
	312	}
	313
2975725f JQ	314	if (ret < 0) {
	315	return ret;
	316	}
	317
ad96090a BS	318	bwidth = qemu_get_clock_ns(rt_clock) - bwidth;
	319	bwidth = (bytes_transferred - bytes_transferred_last) / bwidth;
	320
	321	/* if we haven't transferred anything this round, force expected_time to a
	322	* a very high value, but without crashing */
	323	if (bwidth == 0) {
	324	bwidth = 0.000001;
	325	}
	326
	327	/* try transferring iterative blocks of memory */
	328	if (stage == 3) {
3fc250b4 PR	329	int bytes_sent;
3fc250b4 PR	330
ad96090a	331	/* flush all remaining blocks regardless of rate limiting */
3fc250b4 PR	332	while ((bytes_sent = ram_save_block(f)) != 0) {
3fc250b4 PR	333	bytes_transferred += bytes_sent;
ad96090a BS	334	}
	335	cpu_physical_memory_set_dirty_tracking(0);
	336	}
	337
	338	qemu_put_be64(f, RAM_SAVE_FLAG_EOS);
	339
	340	expected_time = ram_save_remaining() * TARGET_PAGE_SIZE / bwidth;
	341
	342	return (stage == 2) && (expected_time <= migrate_max_downtime());
	343	}
	344
a55bbe31 AW	345	static inline void host_from_stream_offset(QEMUFile f,
	346	ram_addr_t offset,
	347	int flags)
	348	{
	349	static RAMBlock *block = NULL;
	350	char id[256];
	351	uint8_t len;
	352
	353	if (flags & RAM_SAVE_FLAG_CONTINUE) {
	354	if (!block) {
	355	fprintf(stderr, "Ack, bad migration stream!\n");
	356	return NULL;
	357	}
	358
	359	return block->host + offset;
	360	}
	361
	362	len = qemu_get_byte(f);
	363	qemu_get_buffer(f, (uint8_t *)id, len);
	364	id[len] = 0;
	365
	366	QLIST_FOREACH(block, &ram_list.blocks, next) {
	367	if (!strncmp(id, block->idstr, sizeof(id)))
	368	return block->host + offset;
	369	}
	370
	371	fprintf(stderr, "Can't find block %s!\n", id);
	372	return NULL;
	373	}
	374
ad96090a BS	375	int ram_load(QEMUFile f, void opaque, int version_id)
	376	{
	377	ram_addr_t addr;
	378	int flags;
42802d47	379	int error;
ad96090a	380
97ab12d4	381	if (version_id < 3 \|\| version_id > 4) {
ad96090a BS	382	return -EINVAL;
	383	}
	384
	385	do {
	386	addr = qemu_get_be64(f);
	387
	388	flags = addr & ~TARGET_PAGE_MASK;
	389	addr &= TARGET_PAGE_MASK;
	390
	391	if (flags & RAM_SAVE_FLAG_MEM_SIZE) {
97ab12d4 AW	392	if (version_id == 3) {
	393	if (addr != ram_bytes_total()) {
	394	return -EINVAL;
	395	}
	396	} else {
	397	/* Synchronize RAM block list */
	398	char id[256];
	399	ram_addr_t length;
	400	ram_addr_t total_ram_bytes = addr;
	401
	402	while (total_ram_bytes) {
	403	RAMBlock *block;
	404	uint8_t len;
	405
	406	len = qemu_get_byte(f);
	407	qemu_get_buffer(f, (uint8_t *)id, len);
	408	id[len] = 0;
	409	length = qemu_get_be64(f);
	410
	411	QLIST_FOREACH(block, &ram_list.blocks, next) {
	412	if (!strncmp(id, block->idstr, sizeof(id))) {
	413	if (block->length != length)
	414	return -EINVAL;
	415	break;
	416	}
	417	}
	418
	419	if (!block) {
fb787f81 AW	420	fprintf(stderr, "Unknown ramblock \"%s\", cannot "
	421	"accept migration\n", id);
	422	return -EINVAL;
97ab12d4 AW	423	}
	424
	425	total_ram_bytes -= length;
	426	}
ad96090a BS	427	}
	428	}
	429
	430	if (flags & RAM_SAVE_FLAG_COMPRESS) {
97ab12d4 AW	431	void *host;
	432	uint8_t ch;
	433
a55bbe31	434	if (version_id == 3)
97ab12d4	435	host = qemu_get_ram_ptr(addr);
a55bbe31 AW	436	else
a55bbe31 AW	437	host = host_from_stream_offset(f, addr, flags);
492fb99c MT	438	if (!host) {
	439	return -EINVAL;
	440	}
97ab12d4	441
97ab12d4 AW	442	ch = qemu_get_byte(f);
97ab12d4 AW	443	memset(host, ch, TARGET_PAGE_SIZE);
ad96090a BS	444	#ifndef _WIN32
	445	if (ch == 0 &&
	446	(!kvm_enabled() \|\| kvm_has_sync_mmu())) {
e78815a5	447	qemu_madvise(host, TARGET_PAGE_SIZE, QEMU_MADV_DONTNEED);
ad96090a BS	448	}
	449	#endif
	450	} else if (flags & RAM_SAVE_FLAG_PAGE) {
97ab12d4 AW	451	void *host;
97ab12d4 AW	452
a55bbe31	453	if (version_id == 3)
97ab12d4	454	host = qemu_get_ram_ptr(addr);
a55bbe31 AW	455	else
a55bbe31 AW	456	host = host_from_stream_offset(f, addr, flags);
97ab12d4	457
97ab12d4	458	qemu_get_buffer(f, host, TARGET_PAGE_SIZE);
ad96090a	459	}
42802d47 JQ	460	error = qemu_file_get_error(f);
	461	if (error) {
	462	return error;
ad96090a BS	463	}
	464	} while (!(flags & RAM_SAVE_FLAG_EOS));
	465
	466	return 0;
	467	}
	468
ad96090a	469	#ifdef HAS_AUDIO
0dfa5ef9 IY	470	struct soundhw {
	471	const char *name;
	472	const char *descr;
	473	int enabled;
	474	int isa;
	475	union {
	476	int (init_isa) (qemu_irq pic);
	477	int (init_pci) (PCIBus bus);
	478	} init;
	479	};
	480
	481	static struct soundhw soundhw[] = {
ad96090a BS	482	#ifdef HAS_AUDIO_CHOICE
	483	#if defined(TARGET_I386) \|\| defined(TARGET_MIPS)
	484	{
	485	"pcspk",
	486	"PC speaker",
	487	0,
	488	1,
	489	{ .init_isa = pcspk_audio_init }
	490	},
	491	#endif
	492
	493	#ifdef CONFIG_SB16
	494	{
	495	"sb16",
	496	"Creative Sound Blaster 16",
	497	0,
	498	1,
	499	{ .init_isa = SB16_init }
	500	},
	501	#endif
	502
	503	#ifdef CONFIG_CS4231A
	504	{
	505	"cs4231a",
	506	"CS4231A",
	507	0,
	508	1,
	509	{ .init_isa = cs4231a_init }
	510	},
	511	#endif
	512
	513	#ifdef CONFIG_ADLIB
	514	{
	515	"adlib",
	516	#ifdef HAS_YMF262
	517	"Yamaha YMF262 (OPL3)",
	518	#else
	519	"Yamaha YM3812 (OPL2)",
	520	#endif
	521	0,
	522	1,
	523	{ .init_isa = Adlib_init }
	524	},
	525	#endif
	526
	527	#ifdef CONFIG_GUS
	528	{
	529	"gus",
	530	"Gravis Ultrasound GF1",
	531	0,
	532	1,
	533	{ .init_isa = GUS_init }
	534	},
	535	#endif
	536
	537	#ifdef CONFIG_AC97
	538	{
	539	"ac97",
	540	"Intel 82801AA AC97 Audio",
	541	0,
	542	0,
	543	{ .init_pci = ac97_init }
	544	},
	545	#endif
546
547	#ifdef CONFIG_ES1370
548	{
549	"es1370",
550	"ENSONIQ AudioPCI ES1370",
551	0,
552	0,
553	{ .init_pci = es1370_init }
554	},
555	#endif
556
d61a4ce8 GH	557	#ifdef CONFIG_HDA
	558	{
	559	"hda",
	560	"Intel HD Audio",
	561	0,
	562	0,
	563	{ .init_pci = intel_hda_and_codec_init }
	564	},
	565	#endif
	566
ad96090a BS	567	#endif /* HAS_AUDIO_CHOICE */
	568
	569	{ NULL, NULL, 0, 0, { NULL } }
	570	};
	571
	572	void select_soundhw(const char *optarg)
	573	{
	574	struct soundhw *c;
	575
	576	if (*optarg == '?') {
	577	show_valid_cards:
	578
	579	printf("Valid sound card names (comma separated):\n");
	580	for (c = soundhw; c->name; ++c) {
	581	printf ("%-11s %s\n", c->name, c->descr);
	582	}
	583	printf("\n-soundhw all will enable all of the above\n");
	584	exit(*optarg != '?');
	585	}
	586	else {
	587	size_t l;
	588	const char *p;
	589	char *e;
	590	int bad_card = 0;
	591
	592	if (!strcmp(optarg, "all")) {
	593	for (c = soundhw; c->name; ++c) {
	594	c->enabled = 1;
	595	}
	596	return;
	597	}
	598
	599	p = optarg;
	600	while (*p) {
	601	e = strchr(p, ',');
	602	l = !e ? strlen(p) : (size_t) (e - p);
	603
	604	for (c = soundhw; c->name; ++c) {
	605	if (!strncmp(c->name, p, l) && !c->name[l]) {
	606	c->enabled = 1;
	607	break;
	608	}
	609	}
	610
	611	if (!c->name) {
	612	if (l > 80) {
	613	fprintf(stderr,
	614	"Unknown sound card name (too big to show)\n");
	615	}
	616	else {
	617	fprintf(stderr, "Unknown sound card name `%.*s'\n",
	618	(int) l, p);
	619	}
	620	bad_card = 1;
	621	}
	622	p += l + (e != NULL);
	623	}
	624
	625	if (bad_card) {
	626	goto show_valid_cards;
	627	}
	628	}
	629	}
0dfa5ef9 IY	630
	631	void audio_init(qemu_irq isa_pic, PCIBus pci_bus)
	632	{
	633	struct soundhw *c;
	634
	635	for (c = soundhw; c->name; ++c) {
	636	if (c->enabled) {
	637	if (c->isa) {
	638	if (isa_pic) {
	639	c->init.init_isa(isa_pic);
	640	}
	641	} else {
	642	if (pci_bus) {
	643	c->init.init_pci(pci_bus);
	644	}
	645	}
	646	}
	647	}
	648	}
ad96090a BS	649	#else
	650	void select_soundhw(const char *optarg)
	651	{
	652	}
0dfa5ef9 IY	653	void audio_init(qemu_irq isa_pic, PCIBus pci_bus)
	654	{
	655	}
ad96090a BS	656	#endif
	657
	658	int qemu_uuid_parse(const char str, uint8_t uuid)
	659	{
	660	int ret;
	661
	662	if (strlen(str) != 36) {
	663	return -1;
	664	}
	665
	666	ret = sscanf(str, UUID_FMT, &uuid[0], &uuid[1], &uuid[2], &uuid[3],
	667	&uuid[4], &uuid[5], &uuid[6], &uuid[7], &uuid[8], &uuid[9],
	668	&uuid[10], &uuid[11], &uuid[12], &uuid[13], &uuid[14],
	669	&uuid[15]);
	670
	671	if (ret != 16) {
	672	return -1;
	673	}
	674	#ifdef TARGET_I386
	675	smbios_add_field(1, offsetof(struct smbios_type_1, uuid), 16, uuid);
	676	#endif
	677	return 0;
	678	}
	679
	680	void do_acpitable_option(const char *optarg)
	681	{
	682	#ifdef TARGET_I386
	683	if (acpi_table_add(optarg) < 0) {
	684	fprintf(stderr, "Wrong acpi table provided\n");
	685	exit(1);
	686	}
	687	#endif
	688	}
	689
	690	void do_smbios_option(const char *optarg)
	691	{
	692	#ifdef TARGET_I386
	693	if (smbios_entry_add(optarg) < 0) {
	694	fprintf(stderr, "Wrong smbios provided\n");
	695	exit(1);
	696	}
	697	#endif
	698	}
	699
	700	void cpudef_init(void)
	701	{
	702	#if defined(cpudef_setup)
	703	cpudef_setup(); /* parse cpu definitions in target config file */
	704	#endif
	705	}
	706
	707	int audio_available(void)
	708	{
	709	#ifdef HAS_AUDIO
	710	return 1;
	711	#else
	712	return 0;
	713	#endif
	714	}
	715
303d4e86 AP	716	int tcg_available(void)
	717	{
	718	return 1;
	719	}
	720
ad96090a BS	721	int kvm_available(void)
	722	{
	723	#ifdef CONFIG_KVM
	724	return 1;
	725	#else
	726	return 0;
	727	#endif
	728	}
	729
	730	int xen_available(void)
	731	{
	732	#ifdef CONFIG_XEN
	733	return 1;
	734	#else
	735	return 0;
	736	#endif
	737	}