savevm: Live migration handlers register the struct directly

Notice that the live migration users never unregister, so no problem
about freeing the ops structure.

Signed-off-by: Juan Quintela <quintela@redhat.com>
This commit is contained in:
Juan Quintela 2012-06-26 18:46:10 +02:00
parent 22ea40f4ff
commit 7908c78d3e
6 changed files with 26 additions and 23 deletions

View File

@ -298,7 +298,7 @@ static void migration_end(void)
#define MAX_WAIT 50 /* ms, half buffered_file limit */ #define MAX_WAIT 50 /* ms, half buffered_file limit */
int ram_save_live(QEMUFile *f, int stage, void *opaque) static int ram_save_live(QEMUFile *f, int stage, void *opaque)
{ {
ram_addr_t addr; ram_addr_t addr;
uint64_t bytes_transferred_last; uint64_t bytes_transferred_last;
@ -437,7 +437,7 @@ static inline void *host_from_stream_offset(QEMUFile *f,
return NULL; return NULL;
} }
int ram_load(QEMUFile *f, void *opaque, int version_id) static int ram_load(QEMUFile *f, void *opaque, int version_id)
{ {
ram_addr_t addr; ram_addr_t addr;
int flags, ret = 0; int flags, ret = 0;
@ -534,6 +534,11 @@ done:
return ret; return ret;
} }
SaveVMHandlers savevm_ram_handlers = {
.save_live_state = ram_save_live,
.load_state = ram_load,
};
#ifdef HAS_AUDIO #ifdef HAS_AUDIO
struct soundhw { struct soundhw {
const char *name; const char *name;

View File

@ -709,11 +709,17 @@ static void block_set_params(const MigrationParams *params, void *opaque)
block_mig_state.blk_enable |= params->shared; block_mig_state.blk_enable |= params->shared;
} }
SaveVMHandlers savevm_block_handlers = {
.set_params = block_set_params,
.save_live_state = block_save_live,
.load_state = block_load,
};
void blk_mig_init(void) void blk_mig_init(void)
{ {
QSIMPLEQ_INIT(&block_mig_state.bmds_list); QSIMPLEQ_INIT(&block_mig_state.bmds_list);
QSIMPLEQ_INIT(&block_mig_state.blk_list); QSIMPLEQ_INIT(&block_mig_state.blk_list);
register_savevm_live(NULL, "block", 0, 1, block_set_params, register_savevm_live(NULL, "block", 0, 1, &savevm_block_handlers,
block_save_live, NULL, block_load, &block_mig_state); &block_mig_state);
} }

View File

@ -18,6 +18,7 @@
#include "qemu-common.h" #include "qemu-common.h"
#include "notify.h" #include "notify.h"
#include "error.h" #include "error.h"
#include "vmstate.h"
struct MigrationParams { struct MigrationParams {
bool blk; bool blk;
@ -81,8 +82,7 @@ uint64_t ram_bytes_remaining(void);
uint64_t ram_bytes_transferred(void); uint64_t ram_bytes_transferred(void);
uint64_t ram_bytes_total(void); uint64_t ram_bytes_total(void);
int ram_save_live(QEMUFile *f, int stage, void *opaque); extern SaveVMHandlers savevm_ram_handlers;
int ram_load(QEMUFile *f, void *opaque, int version_id);
/** /**
* @migrate_add_blocker - prevent migration from proceeding * @migrate_add_blocker - prevent migration from proceeding

View File

@ -1223,10 +1223,7 @@ int register_savevm_live(DeviceState *dev,
const char *idstr, const char *idstr,
int instance_id, int instance_id,
int version_id, int version_id,
SaveSetParamsHandler *set_params, SaveVMHandlers *ops,
SaveLiveStateHandler *save_live_state,
SaveStateHandler *save_state,
LoadStateHandler *load_state,
void *opaque) void *opaque)
{ {
SaveStateEntry *se; SaveStateEntry *se;
@ -1234,16 +1231,12 @@ int register_savevm_live(DeviceState *dev,
se = g_malloc0(sizeof(SaveStateEntry)); se = g_malloc0(sizeof(SaveStateEntry));
se->version_id = version_id; se->version_id = version_id;
se->section_id = global_section_id++; se->section_id = global_section_id++;
se->ops = g_malloc0(sizeof(SaveVMHandlers)); se->ops = ops;
se->ops->set_params = set_params;
se->ops->save_live_state = save_live_state;
se->ops->save_state = save_state;
se->ops->load_state = load_state;
se->opaque = opaque; se->opaque = opaque;
se->vmsd = NULL; se->vmsd = NULL;
se->no_migrate = 0; se->no_migrate = 0;
/* if this is a live_savem then set is_ram */ /* if this is a live_savem then set is_ram */
if (save_live_state != NULL) { if (ops->save_live_state != NULL) {
se->is_ram = 1; se->is_ram = 1;
} }
@ -1282,8 +1275,11 @@ int register_savevm(DeviceState *dev,
LoadStateHandler *load_state, LoadStateHandler *load_state,
void *opaque) void *opaque)
{ {
SaveVMHandlers *ops = g_malloc0(sizeof(SaveVMHandlers));
ops->save_state = save_state;
ops->load_state = load_state;
return register_savevm_live(dev, idstr, instance_id, version_id, return register_savevm_live(dev, idstr, instance_id, version_id,
NULL, NULL, save_state, load_state, opaque); ops, opaque);
} }
void unregister_savevm(DeviceState *dev, const char *idstr, void *opaque) void unregister_savevm(DeviceState *dev, const char *idstr, void *opaque)

3
vl.c
View File

@ -3437,8 +3437,7 @@ int main(int argc, char **argv, char **envp)
default_drive(default_sdcard, snapshot, machine->use_scsi, default_drive(default_sdcard, snapshot, machine->use_scsi,
IF_SD, 0, SD_OPTS); IF_SD, 0, SD_OPTS);
register_savevm_live(NULL, "ram", 0, 4, NULL, ram_save_live, NULL, register_savevm_live(NULL, "ram", 0, 4, &savevm_ram_handlers, NULL);
ram_load, NULL);
if (nb_numa_nodes > 0) { if (nb_numa_nodes > 0) {
int i; int i;

View File

@ -50,10 +50,7 @@ int register_savevm_live(DeviceState *dev,
const char *idstr, const char *idstr,
int instance_id, int instance_id,
int version_id, int version_id,
SaveSetParamsHandler *set_params, SaveVMHandlers *ops,
SaveLiveStateHandler *save_live_state,
SaveStateHandler *save_state,
LoadStateHandler *load_state,
void *opaque); void *opaque);
void unregister_savevm(DeviceState *dev, const char *idstr, void *opaque); void unregister_savevm(DeviceState *dev, const char *idstr, void *opaque);