[mirror_qemu.git] / migration / ram-compress.h

/*
 * QEMU System Emulator
 *
 * Copyright (c) 2003-2008 Fabrice Bellard
 * Copyright (c) 2011-2015 Red Hat Inc
 *
 * Authors:
 *  Juan Quintela <quintela@redhat.com>
 *
 * 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.
 */

#ifndef QEMU_MIGRATION_COMPRESS_H
#define QEMU_MIGRATION_COMPRESS_H

#include "qemu-file.h"
#include "qapi/qapi-types-migration.h"

enum CompressResult {
    RES_NONE = 0,
    RES_ZEROPAGE = 1,
    RES_COMPRESS = 2
};
typedef enum CompressResult CompressResult;

struct CompressParam {
    bool done;
    bool quit;
    bool trigger;
    CompressResult result;
    QEMUFile *file;
    QemuMutex mutex;
    QemuCond cond;
    RAMBlock *block;
    ram_addr_t offset;

    /* internally used fields */
    z_stream stream;
    uint8_t *originbuf;
};
typedef struct CompressParam CompressParam;

void compress_threads_save_cleanup(void);
int compress_threads_save_setup(void);

bool compress_page_with_multi_thread(RAMBlock *block, ram_addr_t offset,
                                      int (send_queued_data(CompressParam *)));

int wait_for_decompress_done(void);
void compress_threads_load_cleanup(void);
int compress_threads_load_setup(QEMUFile *f);
void decompress_data_with_multi_threads(QEMUFile *f, void *host, int len);

void populate_compress(MigrationInfo *info);
uint64_t compress_ram_pages(void);
void update_compress_thread_counts(const CompressParam *param, int bytes_xmit);
void compress_update_rates(uint64_t page_count);
int compress_send_queued_data(CompressParam *param);
void compress_flush_data(void);

#endif
Commit	Line	Data
b5ca3368 LS	1	/*
	2	* QEMU System Emulator
	3	*
	4	* Copyright (c) 2003-2008 Fabrice Bellard
	5	* Copyright (c) 2011-2015 Red Hat Inc
	6	*
	7	* Authors:
	8	* Juan Quintela <quintela@redhat.com>
	9	*
	10	* Permission is hereby granted, free of charge, to any person obtaining a copy
	11	* of this software and associated documentation files (the "Software"), to deal
	12	* in the Software without restriction, including without limitation the rights
	13	* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
	14	* copies of the Software, and to permit persons to whom the Software is
	15	* furnished to do so, subject to the following conditions:
	16	*
	17	* The above copyright notice and this permission notice shall be included in
	18	* all copies or substantial portions of the Software.
	19	*
	20	* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
	21	* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
	22	* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
	23	* THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
	24	* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
	25	* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
	26	* THE SOFTWARE.
	27	*/
	28
	29	#ifndef QEMU_MIGRATION_COMPRESS_H
	30	#define QEMU_MIGRATION_COMPRESS_H
	31
	32	#include "qemu-file.h"
6f609005	33	#include "qapi/qapi-types-migration.h"
b5ca3368 LS	34
	35	enum CompressResult {
	36	RES_NONE = 0,
	37	RES_ZEROPAGE = 1,
	38	RES_COMPRESS = 2
	39	};
	40	typedef enum CompressResult CompressResult;
	41
	42	struct CompressParam {
	43	bool done;
	44	bool quit;
	45	bool trigger;
	46	CompressResult result;
	47	QEMUFile *file;
	48	QemuMutex mutex;
	49	QemuCond cond;
	50	RAMBlock *block;
	51	ram_addr_t offset;
	52
	53	/* internally used fields */
	54	z_stream stream;
	55	uint8_t *originbuf;
	56	};
	57	typedef struct CompressParam CompressParam;
	58
	59	void compress_threads_save_cleanup(void);
	60	int compress_threads_save_setup(void);
	61
83df387d JQ	62	bool compress_page_with_multi_thread(RAMBlock *block, ram_addr_t offset,
83df387d JQ	63	int (send_queued_data(CompressParam *)));
b5ca3368	64
b1f17720 LS	65	int wait_for_decompress_done(void);
	66	void compress_threads_load_cleanup(void);
	67	int compress_threads_load_setup(QEMUFile *f);
	68	void decompress_data_with_multi_threads(QEMUFile f, void host, int len);
	69
6f609005	70	void populate_compress(MigrationInfo *info);
8258f2fa	71	uint64_t compress_ram_pages(void);
1fd03d41	72	void update_compress_thread_counts(const CompressParam *param, int bytes_xmit);
fb36fb27	73	void compress_update_rates(uint64_t page_count);
742ec5f3	74	int compress_send_queued_data(CompressParam *param);
8020bc9a	75	void compress_flush_data(void);
6f609005	76
b5ca3368	77	#endif