migration: export migration_is_setup_or_active

Delete the MigrationState parameter from migration_is_setup_or_active
and move it to the public API in misc.h.

Signed-off-by: Steve Sistare <steven.sistare@oracle.com>
Reviewed-by: Philippe Mathieu-Daudé <philmd@linaro.org>
Link: https://lore.kernel.org/r/1710179338-294359-3-git-send-email-steven.sistare@oracle.com
Signed-off-by: Peter Xu <peterx@redhat.com>
This commit is contained in:
Steve Sistare 2024-03-11 10:48:49 -07:00 committed by Peter Xu
parent f853fa0714
commit 7dcb3c87d8
6 changed files with 11 additions and 13 deletions

View File

@ -152,7 +152,7 @@ static void vfio_set_migration_error(int err)
{ {
MigrationState *ms = migrate_get_current(); MigrationState *ms = migrate_get_current();
if (migration_is_setup_or_active(ms->state)) { if (migration_is_setup_or_active()) {
WITH_QEMU_LOCK_GUARD(&ms->qemu_file_lock) { WITH_QEMU_LOCK_GUARD(&ms->qemu_file_lock) {
if (ms->to_dst_file) { if (ms->to_dst_file) {
qemu_file_set_error(ms->to_dst_file, err); qemu_file_set_error(ms->to_dst_file, err);

View File

@ -61,6 +61,7 @@ void migration_object_init(void);
void migration_shutdown(void); void migration_shutdown(void);
bool migration_is_idle(void); bool migration_is_idle(void);
bool migration_is_active(MigrationState *); bool migration_is_active(MigrationState *);
bool migration_is_setup_or_active(void);
bool migrate_mode_is_cpr(MigrationState *); bool migrate_mode_is_cpr(MigrationState *);
typedef enum MigrationEventType { typedef enum MigrationEventType {

View File

@ -1081,9 +1081,11 @@ void migrate_send_rp_resume_ack(MigrationIncomingState *mis, uint32_t value)
* Return true if we're already in the middle of a migration * Return true if we're already in the middle of a migration
* (i.e. any of the active or setup states) * (i.e. any of the active or setup states)
*/ */
bool migration_is_setup_or_active(int state) bool migration_is_setup_or_active(void)
{ {
switch (state) { MigrationState *s = current_migration;
switch (s->state) {
case MIGRATION_STATUS_ACTIVE: case MIGRATION_STATUS_ACTIVE:
case MIGRATION_STATUS_POSTCOPY_ACTIVE: case MIGRATION_STATUS_POSTCOPY_ACTIVE:
case MIGRATION_STATUS_POSTCOPY_PAUSED: case MIGRATION_STATUS_POSTCOPY_PAUSED:
@ -1601,10 +1603,8 @@ bool migration_incoming_postcopy_advised(void)
bool migration_in_bg_snapshot(void) bool migration_in_bg_snapshot(void)
{ {
MigrationState *s = migrate_get_current();
return migrate_background_snapshot() && return migrate_background_snapshot() &&
migration_is_setup_or_active(s->state); migration_is_setup_or_active();
} }
bool migration_is_idle(void) bool migration_is_idle(void)
@ -2297,7 +2297,7 @@ static void *source_return_path_thread(void *opaque)
trace_source_return_path_thread_entry(); trace_source_return_path_thread_entry();
rcu_register_thread(); rcu_register_thread();
while (migration_is_setup_or_active(ms->state)) { while (migration_is_setup_or_active()) {
trace_source_return_path_thread_loop_top(); trace_source_return_path_thread_loop_top();
header_type = qemu_get_be16(rp); header_type = qemu_get_be16(rp);

View File

@ -479,7 +479,6 @@ bool migrate_has_error(MigrationState *s);
void migrate_fd_connect(MigrationState *s, Error *error_in); void migrate_fd_connect(MigrationState *s, Error *error_in);
bool migration_is_setup_or_active(int state);
bool migration_is_running(int state); bool migration_is_running(int state);
int migrate_init(MigrationState *s, Error **errp); int migrate_init(MigrationState *s, Error **errp);

View File

@ -2909,10 +2909,9 @@ void qemu_guest_free_page_hint(void *addr, size_t len)
RAMBlock *block; RAMBlock *block;
ram_addr_t offset; ram_addr_t offset;
size_t used_len, start, npages; size_t used_len, start, npages;
MigrationState *s = migrate_get_current();
/* This function is currently expected to be used during live migration */ /* This function is currently expected to be used during live migration */
if (!migration_is_setup_or_active(s->state)) { if (!migration_is_setup_or_active()) {
return; return;
} }
@ -3263,7 +3262,7 @@ static int ram_save_iterate(QEMUFile *f, void *opaque)
out: out:
if (ret >= 0 if (ret >= 0
&& migration_is_setup_or_active(migrate_get_current()->state)) { && migration_is_setup_or_active()) {
if (migrate_multifd() && migrate_multifd_flush_after_each_section() && if (migrate_multifd() && migrate_multifd_flush_after_each_section() &&
!migrate_mapped_ram()) { !migrate_mapped_ram()) {
ret = multifd_send_sync_main(); ret = multifd_send_sync_main();

View File

@ -26,7 +26,6 @@
#include <err.h> #include <err.h>
#include "standard-headers/linux/virtio_net.h" #include "standard-headers/linux/virtio_net.h"
#include "monitor/monitor.h" #include "monitor/monitor.h"
#include "migration/migration.h"
#include "migration/misc.h" #include "migration/misc.h"
#include "hw/virtio/vhost.h" #include "hw/virtio/vhost.h"
@ -355,7 +354,7 @@ static int vhost_vdpa_net_data_start(NetClientState *nc)
assert(nc->info->type == NET_CLIENT_DRIVER_VHOST_VDPA); assert(nc->info->type == NET_CLIENT_DRIVER_VHOST_VDPA);
if (s->always_svq || if (s->always_svq ||
migration_is_setup_or_active(migrate_get_current()->state)) { migration_is_setup_or_active()) {
v->shadow_vqs_enabled = true; v->shadow_vqs_enabled = true;
} else { } else {
v->shadow_vqs_enabled = false; v->shadow_vqs_enabled = false;