[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>
#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_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
#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 int ram_save_block(QEMUFile *f)
{
    static RAMBlock *last_block = NULL;
    static ram_addr_t last_offset = 0;
    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;
}

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;

    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);
        return 0;
    }

    if (stage == 1) {
        RAMBlock *block;
        bytes_transferred = 0;

        /* 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 (!qemu_file_rate_limit(f)) {
        int bytes_sent;

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

    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;

    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);

            ch = qemu_get_byte(f);
            memset(host, ch, TARGET_PAGE_SIZE);
#ifndef _WIN32
            if (ch == 0 &&
                (!kvm_enabled() || kvm_has_sync_mmu())) {
                madvise(host, TARGET_PAGE_SIZE, 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);
        }
        if (qemu_file_has_error(f)) {
            return -EIO;
        }
    } while (!(flags & RAM_SAVE_FLAG_EOS));

    return 0;
}

void qemu_service_io(void)
{
    qemu_notify_event();
}

#ifdef HAS_AUDIO
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

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