d5ee387de9
Alter migrate_qmp() to allow use of channels parameter, but only fill the uri with correct port number if there are no channels. Here we don't want to allow the wrong cases of having both or none (ex: migrate_qmp_fail). Signed-off-by: Het Gala <het.gala@nutanix.com> Suggested-by: Fabiano Rosas <farosas@suse.de> Reviewed-by: Fabiano Rosas <farosas@suse.de> Link: https://lore.kernel.org/r/20240312202634.63349-7-het.gala@nutanix.com Signed-off-by: Peter Xu <peterx@redhat.com>
59 lines
1.8 KiB
C
59 lines
1.8 KiB
C
/*
|
|
* QTest migration helpers
|
|
*
|
|
* Copyright (c) 2016-2018 Red Hat, Inc. and/or its affiliates
|
|
* based on the vhost-user-test.c that is:
|
|
* Copyright (c) 2014 Virtual Open Systems Sarl.
|
|
*
|
|
* This work is licensed under the terms of the GNU GPL, version 2 or later.
|
|
* See the COPYING file in the top-level directory.
|
|
*
|
|
*/
|
|
|
|
#ifndef MIGRATION_HELPERS_H
|
|
#define MIGRATION_HELPERS_H
|
|
|
|
#include "libqtest.h"
|
|
|
|
typedef struct QTestMigrationState {
|
|
bool stop_seen;
|
|
bool resume_seen;
|
|
bool suspend_seen;
|
|
bool suspend_me;
|
|
} QTestMigrationState;
|
|
|
|
bool migrate_watch_for_events(QTestState *who, const char *name,
|
|
QDict *event, void *opaque);
|
|
|
|
G_GNUC_PRINTF(5, 6)
|
|
void migrate_qmp(QTestState *who, QTestState *to, const char *uri,
|
|
const char *channels, const char *fmt, ...);
|
|
|
|
G_GNUC_PRINTF(3, 4)
|
|
void migrate_incoming_qmp(QTestState *who, const char *uri,
|
|
const char *fmt, ...);
|
|
|
|
G_GNUC_PRINTF(4, 5)
|
|
void migrate_qmp_fail(QTestState *who, const char *uri,
|
|
const char *channels, const char *fmt, ...);
|
|
|
|
void migrate_set_capability(QTestState *who, const char *capability,
|
|
bool value);
|
|
|
|
QDict *migrate_query(QTestState *who);
|
|
QDict *migrate_query_not_failed(QTestState *who);
|
|
|
|
void wait_for_migration_status(QTestState *who,
|
|
const char *goal, const char **ungoals);
|
|
|
|
void wait_for_migration_complete(QTestState *who);
|
|
|
|
void wait_for_migration_fail(QTestState *from, bool allow_active);
|
|
|
|
char *find_common_machine_version(const char *mtype, const char *var1,
|
|
const char *var2);
|
|
char *resolve_machine_version(const char *alias, const char *var1,
|
|
const char *var2);
|
|
void migration_test_add(const char *path, void (*fn)(void));
|
|
#endif /* MIGRATION_HELPERS_H */
|