Move loadvm_handlers into MigrationIncomingState

In postcopy we need the loadvm_handlers to be used in a couple
of different instances of the loadvm loop/routine, and thus
it can't be local any more.

Signed-off-by: Dr. David Alan Gilbert <dgilbert@redhat.com>
Reviewed-by: David Gibson <david@gibson.dropbear.id.au>
Reviewed-by: Juan Quintela <quintela@redhat.com>
Signed-off-by: Juan Quintela <quintela@redhat.com>
This commit is contained in:
Dr. David Alan Gilbert 2015-05-21 13:24:16 +01:00 committed by Juan Quintela
parent 7c1e52ba6f
commit 1a8f46f8d6
5 changed files with 26 additions and 12 deletions

View File

@ -42,9 +42,14 @@ struct MigrationParams {
typedef struct MigrationState MigrationState; typedef struct MigrationState MigrationState;
typedef QLIST_HEAD(, LoadStateEntry) LoadStateEntry_Head;
/* State for the incoming migration */ /* State for the incoming migration */
struct MigrationIncomingState { struct MigrationIncomingState {
QEMUFile *file; QEMUFile *file;
/* See savevm.c */
LoadStateEntry_Head loadvm_handlers;
}; };
MigrationIncomingState *migration_incoming_get_current(void); MigrationIncomingState *migration_incoming_get_current(void);

View File

@ -808,6 +808,8 @@ extern const VMStateInfo vmstate_info_bitmap;
#define SELF_ANNOUNCE_ROUNDS 5 #define SELF_ANNOUNCE_ROUNDS 5
void loadvm_free_handlers(MigrationIncomingState *mis);
int vmstate_load_state(QEMUFile *f, const VMStateDescription *vmsd, int vmstate_load_state(QEMUFile *f, const VMStateDescription *vmsd,
void *opaque, int version_id); void *opaque, int version_id);
void vmstate_save_state(QEMUFile *f, const VMStateDescription *vmsd, void vmstate_save_state(QEMUFile *f, const VMStateDescription *vmsd,

View File

@ -31,6 +31,7 @@ typedef struct I2CBus I2CBus;
typedef struct I2SCodec I2SCodec; typedef struct I2SCodec I2SCodec;
typedef struct ISABus ISABus; typedef struct ISABus ISABus;
typedef struct ISADevice ISADevice; typedef struct ISADevice ISADevice;
typedef struct LoadStateEntry LoadStateEntry;
typedef struct MACAddr MACAddr; typedef struct MACAddr MACAddr;
typedef struct MachineClass MachineClass; typedef struct MachineClass MachineClass;
typedef struct MachineState MachineState; typedef struct MachineState MachineState;

View File

@ -84,12 +84,14 @@ MigrationIncomingState *migration_incoming_state_new(QEMUFile* f)
{ {
mis_current = g_malloc0(sizeof(MigrationIncomingState)); mis_current = g_malloc0(sizeof(MigrationIncomingState));
mis_current->file = f; mis_current->file = f;
QLIST_INIT(&mis_current->loadvm_handlers);
return mis_current; return mis_current;
} }
void migration_incoming_state_destroy(void) void migration_incoming_state_destroy(void)
{ {
loadvm_free_handlers(mis_current);
g_free(mis_current); g_free(mis_current);
mis_current = NULL; mis_current = NULL;
} }

View File

@ -936,18 +936,26 @@ static SaveStateEntry *find_se(const char *idstr, int instance_id)
return NULL; return NULL;
} }
typedef struct LoadStateEntry { struct LoadStateEntry {
QLIST_ENTRY(LoadStateEntry) entry; QLIST_ENTRY(LoadStateEntry) entry;
SaveStateEntry *se; SaveStateEntry *se;
int section_id; int section_id;
int version_id; int version_id;
} LoadStateEntry; };
void loadvm_free_handlers(MigrationIncomingState *mis)
{
LoadStateEntry *le, *new_le;
QLIST_FOREACH_SAFE(le, &mis->loadvm_handlers, entry, new_le) {
QLIST_REMOVE(le, entry);
g_free(le);
}
}
int qemu_loadvm_state(QEMUFile *f) int qemu_loadvm_state(QEMUFile *f)
{ {
QLIST_HEAD(, LoadStateEntry) loadvm_handlers = MigrationIncomingState *mis = migration_incoming_get_current();
QLIST_HEAD_INITIALIZER(loadvm_handlers);
LoadStateEntry *le, *new_le;
Error *local_err = NULL; Error *local_err = NULL;
uint8_t section_type; uint8_t section_type;
unsigned int v; unsigned int v;
@ -978,6 +986,7 @@ int qemu_loadvm_state(QEMUFile *f)
while ((section_type = qemu_get_byte(f)) != QEMU_VM_EOF) { while ((section_type = qemu_get_byte(f)) != QEMU_VM_EOF) {
uint32_t instance_id, version_id, section_id; uint32_t instance_id, version_id, section_id;
SaveStateEntry *se; SaveStateEntry *se;
LoadStateEntry *le;
char idstr[256]; char idstr[256];
trace_qemu_loadvm_state_section(section_type); trace_qemu_loadvm_state_section(section_type);
@ -1019,7 +1028,7 @@ int qemu_loadvm_state(QEMUFile *f)
le->se = se; le->se = se;
le->section_id = section_id; le->section_id = section_id;
le->version_id = version_id; le->version_id = version_id;
QLIST_INSERT_HEAD(&loadvm_handlers, le, entry); QLIST_INSERT_HEAD(&mis->loadvm_handlers, le, entry);
ret = vmstate_load(f, le->se, le->version_id); ret = vmstate_load(f, le->se, le->version_id);
if (ret < 0) { if (ret < 0) {
@ -1033,7 +1042,7 @@ int qemu_loadvm_state(QEMUFile *f)
section_id = qemu_get_be32(f); section_id = qemu_get_be32(f);
trace_qemu_loadvm_state_section_partend(section_id); trace_qemu_loadvm_state_section_partend(section_id);
QLIST_FOREACH(le, &loadvm_handlers, entry) { QLIST_FOREACH(le, &mis->loadvm_handlers, entry) {
if (le->section_id == section_id) { if (le->section_id == section_id) {
break; break;
} }
@ -1081,11 +1090,6 @@ int qemu_loadvm_state(QEMUFile *f)
ret = 0; ret = 0;
out: out:
QLIST_FOREACH_SAFE(le, &loadvm_handlers, entry, new_le) {
QLIST_REMOVE(le, entry);
g_free(le);
}
if (ret == 0) { if (ret == 0) {
/* We may not have a VMDESC section, so ignore relative errors */ /* We may not have a VMDESC section, so ignore relative errors */
ret = file_error_after_eof; ret = file_error_after_eof;