motorhead/qemu
1
0
Fork 0
mirror of https://github.com/Motorhead1991/qemu.git synced 2025-08-16 06:31:51 -06:00
Code Issues Projects Releases Packages Wiki Activity Actions

migration: notifier error checking

Browse source 
Check the status returned by migration notifiers for event type
MIG_EVENT_PRECOPY_SETUP, and report errors.  None of the notifiers
return an error status at this time.

Signed-off-by: Steve Sistare <steven.sistare@oracle.com>
Reviewed-by: Peter Xu <peterx@redhat.com>
Link: https://lore.kernel.org/r/1708622920-68779-10-git-send-email-steven.sistare@oracle.com
Signed-off-by: Peter Xu <peterx@redhat.com>
This commit is contained in:
Steve Sistare 2024-02-22 09:28:35 -08:00 • committed by Peter Xu
parent bf78a046b9
commit 4af667f87c
2 changed files with 23 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

8
include/migration/misc.h
View file

@ -72,6 +72,11 @@ typedef struct MigrationEvent {
MigrationEventType type; MigrationEventType type;
} MigrationEvent; } MigrationEvent;
/*
* A MigrationNotifyFunc may return an error code and an Error object,
* but only when @e->type is MIG_EVENT_PRECOPY_SETUP. The code is an int
* to allow for different failure modes and recovery actions.
*/
typedef int (*MigrationNotifyFunc)(NotifierWithReturn *notify, typedef int (*MigrationNotifyFunc)(NotifierWithReturn *notify,
MigrationEvent *e, Error **errp); MigrationEvent *e, Error **errp);
@ -93,7 +98,8 @@ void migration_add_notifier_mode(NotifierWithReturn *notify,
MigrationNotifyFunc func, MigMode mode); MigrationNotifyFunc func, MigMode mode);
void migration_remove_notifier(NotifierWithReturn *notify); void migration_remove_notifier(NotifierWithReturn *notify);
void migration_call_notifiers(MigrationState *s, MigrationEventType type); int migration_call_notifiers(MigrationState *s, MigrationEventType type,
Error **errp);
bool migration_in_setup(MigrationState *); bool migration_in_setup(MigrationState *);
bool migration_has_finished(MigrationState *); bool migration_has_finished(MigrationState *);
bool migration_has_failed(MigrationState *); bool migration_has_failed(MigrationState *);

25
migration/migration.c
View file

@ -1376,7 +1376,7 @@ static void migrate_fd_cleanup(MigrationState *s)
} }
type = migration_has_failed(s) ? MIG_EVENT_PRECOPY_FAILED : type = migration_has_failed(s) ? MIG_EVENT_PRECOPY_FAILED :
MIG_EVENT_PRECOPY_DONE; MIG_EVENT_PRECOPY_DONE;
migration_call_notifiers(s, type); migration_call_notifiers(s, type, NULL);
block_cleanup_parameters(); block_cleanup_parameters();
yank_unregister_instance(MIGRATION_YANK_INSTANCE); yank_unregister_instance(MIGRATION_YANK_INSTANCE);
} }
@ -1489,13 +1489,18 @@ void migration_remove_notifier(NotifierWithReturn *notify)
} }
} }
void migration_call_notifiers(MigrationState *s, MigrationEventType type) int migration_call_notifiers(MigrationState *s, MigrationEventType type,
Error **errp)
{ {
MigMode mode = s->parameters.mode; MigMode mode = s->parameters.mode;
MigrationEvent e; MigrationEvent e;
int ret;
e.type = type; e.type = type;
notifier_with_return_list_notify(&migration_state_notifiers[mode], &e, 0); ret = notifier_with_return_list_notify(&migration_state_notifiers[mode],
&e, errp);
assert(!ret || type == MIG_EVENT_PRECOPY_SETUP);
return ret;
} }
bool migration_in_setup(MigrationState *s) bool migration_in_setup(MigrationState *s)
@ -2549,7 +2554,7 @@ static int postcopy_start(MigrationState *ms, Error **errp)
* at the transition to postcopy and after the device state; in particular * at the transition to postcopy and after the device state; in particular
* spice needs to trigger a transition now * spice needs to trigger a transition now
*/ */
migration_call_notifiers(ms, MIG_EVENT_PRECOPY_DONE); migration_call_notifiers(ms, MIG_EVENT_PRECOPY_DONE, NULL);
migration_downtime_end(ms); migration_downtime_end(ms);
@ -2569,11 +2574,10 @@ static int postcopy_start(MigrationState *ms, Error **errp)
ret = qemu_file_get_error(ms->to_dst_file); ret = qemu_file_get_error(ms->to_dst_file);
if (ret) { if (ret) {
error_setg(errp, "postcopy_start: Migration stream errored"); error_setg_errno(errp, -ret, "postcopy_start: Migration stream error");
migrate_set_state(&ms->state, MIGRATION_STATUS_POSTCOPY_ACTIVE, bql_lock();
MIGRATION_STATUS_FAILED); goto fail;
} }
trace_postcopy_preempt_enabled(migrate_postcopy_preempt()); trace_postcopy_preempt_enabled(migrate_postcopy_preempt());
return ret; return ret;
@ -2594,6 +2598,7 @@ fail:
error_report_err(local_err); error_report_err(local_err);
} }
} }
migration_call_notifiers(ms, MIG_EVENT_PRECOPY_FAILED, NULL);
bql_unlock(); bql_unlock();
return -1; return -1;
} }
@ -3613,7 +3618,9 @@ void migrate_fd_connect(MigrationState *s, Error *error_in)
rate_limit = migrate_max_bandwidth(); rate_limit = migrate_max_bandwidth();
/* Notify before starting migration thread */ /* Notify before starting migration thread */
migration_call_notifiers(s, MIG_EVENT_PRECOPY_SETUP); if (migration_call_notifiers(s, MIG_EVENT_PRECOPY_SETUP, &local_err)) {
goto fail;
}
} }
migration_rate_set(rate_limit); migration_rate_set(rate_limit);