* @opaque is a pointer to state previously returned
* by the TestMigrateStartHook if any, or NULL.
*/
-typedef void (*TestMigrateFinishHook)(QTestState *from,
- QTestState *to,
- void *opaque);
+typedef void (*TestMigrateEndHook)(QTestState *from,
+ QTestState *to,
+ void *opaque);
typedef struct {
/* Optional: fine tune start parameters */
/* Optional: callback to run at start to set migration parameters */
TestMigrateStartHook start_hook;
/* Optional: callback to run at finish to cleanup */
- TestMigrateFinishHook finish_hook;
+ TestMigrateEndHook end_hook;
/*
* Optional: normally we expect the migration process to complete.
};
static void *
-test_migrate_tls_psk_start_common(QTestState *from,
+migrate_hook_start_tls_psk_common(QTestState *from,
QTestState *to,
bool mismatch)
{
}
static void *
-test_migrate_tls_psk_start_match(QTestState *from,
+migrate_hook_start_tls_psk_match(QTestState *from,
QTestState *to)
{
- return test_migrate_tls_psk_start_common(from, to, false);
+ return migrate_hook_start_tls_psk_common(from, to, false);
}
static void *
-test_migrate_tls_psk_start_mismatch(QTestState *from,
+migrate_hook_start_tls_psk_mismatch(QTestState *from,
QTestState *to)
{
- return test_migrate_tls_psk_start_common(from, to, true);
+ return migrate_hook_start_tls_psk_common(from, to, true);
}
static void
-test_migrate_tls_psk_finish(QTestState *from,
- QTestState *to,
- void *opaque)
+migrate_hook_end_tls_psk(QTestState *from,
+ QTestState *to,
+ void *opaque)
{
struct TestMigrateTLSPSKData *data = opaque;
} TestMigrateTLSX509;
static void *
-test_migrate_tls_x509_start_common(QTestState *from,
+migrate_hook_start_tls_x509_common(QTestState *from,
QTestState *to,
TestMigrateTLSX509 *args)
{
* whatever host we were telling QEMU to connect to (if any)
*/
static void *
-test_migrate_tls_x509_start_default_host(QTestState *from,
+migrate_hook_start_tls_x509_default_host(QTestState *from,
QTestState *to)
{
TestMigrateTLSX509 args = {
.clientcert = true,
.certipaddr = "127.0.0.1"
};
- return test_migrate_tls_x509_start_common(from, to, &args);
+ return migrate_hook_start_tls_x509_common(from, to, &args);
}
/*
* so we must give QEMU an explicit hostname to validate
*/
static void *
-test_migrate_tls_x509_start_override_host(QTestState *from,
+migrate_hook_start_tls_x509_override_host(QTestState *from,
QTestState *to)
{
TestMigrateTLSX509 args = {
.clientcert = true,
.certhostname = "qemu.org",
};
- return test_migrate_tls_x509_start_common(from, to, &args);
+ return migrate_hook_start_tls_x509_common(from, to, &args);
}
/*
* expect the client to reject the server
*/
static void *
-test_migrate_tls_x509_start_mismatch_host(QTestState *from,
+migrate_hook_start_tls_x509_mismatch_host(QTestState *from,
QTestState *to)
{
TestMigrateTLSX509 args = {
.clientcert = true,
.certipaddr = "10.0.0.1",
};
- return test_migrate_tls_x509_start_common(from, to, &args);
+ return migrate_hook_start_tls_x509_common(from, to, &args);
}
static void *
-test_migrate_tls_x509_start_friendly_client(QTestState *from,
+migrate_hook_start_tls_x509_friendly_client(QTestState *from,
QTestState *to)
{
TestMigrateTLSX509 args = {
.authzclient = true,
.certipaddr = "127.0.0.1",
};
- return test_migrate_tls_x509_start_common(from, to, &args);
+ return migrate_hook_start_tls_x509_common(from, to, &args);
}
static void *
-test_migrate_tls_x509_start_hostile_client(QTestState *from,
+migrate_hook_start_tls_x509_hostile_client(QTestState *from,
QTestState *to)
{
TestMigrateTLSX509 args = {
.authzclient = true,
.certipaddr = "127.0.0.1",
};
- return test_migrate_tls_x509_start_common(from, to, &args);
+ return migrate_hook_start_tls_x509_common(from, to, &args);
}
/*
* and no server verification
*/
static void *
-test_migrate_tls_x509_start_allow_anon_client(QTestState *from,
+migrate_hook_start_tls_x509_allow_anon_client(QTestState *from,
QTestState *to)
{
TestMigrateTLSX509 args = {
.certipaddr = "127.0.0.1",
};
- return test_migrate_tls_x509_start_common(from, to, &args);
+ return migrate_hook_start_tls_x509_common(from, to, &args);
}
/*
* and server verification rejecting
*/
static void *
-test_migrate_tls_x509_start_reject_anon_client(QTestState *from,
+migrate_hook_start_tls_x509_reject_anon_client(QTestState *from,
QTestState *to)
{
TestMigrateTLSX509 args = {
.verifyclient = true,
.certipaddr = "127.0.0.1",
};
- return test_migrate_tls_x509_start_common(from, to, &args);
+ return migrate_hook_start_tls_x509_common(from, to, &args);
}
static void
-test_migrate_tls_x509_finish(QTestState *from,
- QTestState *to,
- void *opaque)
+migrate_hook_end_tls_x509(QTestState *from,
+ QTestState *to,
+ void *opaque)
{
TestMigrateTLSX509Data *data = opaque;
read_blocktime(to);
}
- if (args->finish_hook) {
- args->finish_hook(from, to, args->postcopy_data);
+ if (args->end_hook) {
+ args->end_hook(from, to, args->postcopy_data);
args->postcopy_data = NULL;
}
static void test_postcopy_tls_psk(void)
{
MigrateCommon args = {
- .start_hook = test_migrate_tls_psk_start_match,
- .finish_hook = test_migrate_tls_psk_finish,
+ .start_hook = migrate_hook_start_tls_psk_match,
+ .end_hook = migrate_hook_end_tls_psk,
};
test_postcopy_common(&args);
{
MigrateCommon args = {
.postcopy_preempt = true,
- .start_hook = test_migrate_tls_psk_start_match,
- .finish_hook = test_migrate_tls_psk_finish,
+ .start_hook = migrate_hook_start_tls_psk_match,
+ .end_hook = migrate_hook_end_tls_psk,
};
test_postcopy_common(&args);
static void test_postcopy_recovery_tls_psk(void)
{
MigrateCommon args = {
- .start_hook = test_migrate_tls_psk_start_match,
- .finish_hook = test_migrate_tls_psk_finish,
+ .start_hook = migrate_hook_start_tls_psk_match,
+ .end_hook = migrate_hook_end_tls_psk,
};
test_postcopy_recovery_common(&args);
{
MigrateCommon args = {
.postcopy_preempt = true,
- .start_hook = test_migrate_tls_psk_start_match,
- .finish_hook = test_migrate_tls_psk_finish,
+ .start_hook = migrate_hook_start_tls_psk_match,
+ .end_hook = migrate_hook_end_tls_psk,
};
test_postcopy_recovery_common(&args);
}
finish:
- if (args->finish_hook) {
- args->finish_hook(from, to, data_hook);
+ if (args->end_hook) {
+ args->end_hook(from, to, data_hook);
}
test_migrate_end(from, to, args->result == MIG_TEST_SUCCEED);
}
finish:
- if (args->finish_hook) {
- args->finish_hook(from, to, data_hook);
+ if (args->end_hook) {
+ args->end_hook(from, to, data_hook);
}
test_migrate_end(from, to, args->result == MIG_TEST_SUCCEED);
MigrateCommon args = {
.connect_uri = uri,
.listen_uri = uri,
- .start_hook = test_migrate_tls_psk_start_match,
- .finish_hook = test_migrate_tls_psk_finish,
+ .start_hook = migrate_hook_start_tls_psk_match,
+ .end_hook = migrate_hook_end_tls_psk,
};
test_precopy_common(&args);
},
.connect_uri = uri,
.listen_uri = uri,
- .start_hook = test_migrate_tls_x509_start_default_host,
- .finish_hook = test_migrate_tls_x509_finish,
+ .start_hook = migrate_hook_start_tls_x509_default_host,
+ .end_hook = migrate_hook_end_tls_x509,
.result = MIG_TEST_FAIL_DEST_QUIT_ERR,
};
MigrateCommon args = {
.connect_uri = uri,
.listen_uri = uri,
- .start_hook = test_migrate_tls_x509_start_override_host,
- .finish_hook = test_migrate_tls_x509_finish,
+ .start_hook = migrate_hook_start_tls_x509_override_host,
+ .end_hook = migrate_hook_end_tls_x509,
};
test_precopy_common(&args);
#endif
static void *
-test_migrate_xbzrle_start(QTestState *from,
+migrate_hook_start_xbzrle(QTestState *from,
QTestState *to)
{
migrate_set_parameter_int(from, "xbzrle-cache-size", 33554432);
MigrateCommon args = {
.connect_uri = uri,
.listen_uri = uri,
- .start_hook = test_migrate_xbzrle_start,
+ .start_hook = migrate_hook_start_xbzrle,
.iterations = 2,
/*
* XBZRLE needs pages to be modified when doing the 2nd+ round
}
}
-static void *file_offset_fdset_start_hook(QTestState *from, QTestState *to)
+static void *migrate_hook_start_file_offset_fdset(QTestState *from,
+ QTestState *to)
{
g_autofree char *file = g_strdup_printf("%s/%s", tmpfs, FILE_TEST_FILENAME);
MigrateCommon args = {
.connect_uri = uri,
.listen_uri = "defer",
- .start_hook = file_offset_fdset_start_hook,
+ .start_hook = migrate_hook_start_file_offset_fdset,
};
test_file_common(&args, false);
test_file_common(&args, false);
}
-static void *test_mode_reboot_start(QTestState *from, QTestState *to)
+static void *migrate_hook_start_mode_reboot(QTestState *from, QTestState *to)
{
migrate_set_parameter_str(from, "mode", "cpr-reboot");
migrate_set_parameter_str(to, "mode", "cpr-reboot");
return NULL;
}
-static void *migrate_mapped_ram_start(QTestState *from, QTestState *to)
+static void *migrate_hook_start_mapped_ram(QTestState *from, QTestState *to)
{
migrate_set_capability(from, "mapped-ram", true);
migrate_set_capability(to, "mapped-ram", true);
.start.use_shmem = true,
.connect_uri = uri,
.listen_uri = "defer",
- .start_hook = test_mode_reboot_start
+ .start_hook = migrate_hook_start_mode_reboot,
};
test_file_common(&args, true);
MigrateCommon args = {
.connect_uri = uri,
.listen_uri = "defer",
- .start_hook = migrate_mapped_ram_start,
+ .start_hook = migrate_hook_start_mapped_ram,
};
test_file_common(&args, false);
MigrateCommon args = {
.connect_uri = uri,
.listen_uri = "defer",
- .start_hook = migrate_mapped_ram_start,
+ .start_hook = migrate_hook_start_mapped_ram,
};
test_file_common(&args, true);
}
-static void *migrate_multifd_mapped_ram_start(QTestState *from, QTestState *to)
+static void *migrate_hook_start_multifd_mapped_ram(QTestState *from,
+ QTestState *to)
{
- migrate_mapped_ram_start(from, to);
+ migrate_hook_start_mapped_ram(from, to);
migrate_set_parameter_int(from, "multifd-channels", 4);
migrate_set_parameter_int(to, "multifd-channels", 4);
MigrateCommon args = {
.connect_uri = uri,
.listen_uri = "defer",
- .start_hook = migrate_multifd_mapped_ram_start,
+ .start_hook = migrate_hook_start_multifd_mapped_ram,
};
test_file_common(&args, false);
MigrateCommon args = {
.connect_uri = uri,
.listen_uri = "defer",
- .start_hook = migrate_multifd_mapped_ram_start,
+ .start_hook = migrate_hook_start_multifd_mapped_ram,
};
test_file_common(&args, true);
}
-static void *multifd_mapped_ram_dio_start(QTestState *from, QTestState *to)
+static void *migrate_hook_start_multifd_mapped_ram_dio(QTestState *from,
+ QTestState *to)
{
- migrate_multifd_mapped_ram_start(from, to);
+ migrate_hook_start_multifd_mapped_ram(from, to);
migrate_set_parameter_bool(from, "direct-io", true);
migrate_set_parameter_bool(to, "direct-io", true);
MigrateCommon args = {
.connect_uri = uri,
.listen_uri = "defer",
- .start_hook = multifd_mapped_ram_dio_start,
+ .start_hook = migrate_hook_start_multifd_mapped_ram_dio,
};
if (!probe_o_direct_support(tmpfs)) {
}
#ifndef _WIN32
-static void multifd_mapped_ram_fdset_end(QTestState *from, QTestState *to,
- void *opaque)
+static void migrate_hook_end_multifd_mapped_ram_fdset(QTestState *from,
+ QTestState *to,
+ void *opaque)
{
QDict *resp;
QList *fdsets;
qobject_unref(resp);
}
-static void *multifd_mapped_ram_fdset_dio(QTestState *from, QTestState *to)
+static void *migrate_hook_start_multifd_mapped_ram_fdset_dio(QTestState *from,
+ QTestState *to)
{
g_autofree char *file = g_strdup_printf("%s/%s", tmpfs, FILE_TEST_FILENAME);
fdset_add_fds(from, file, O_WRONLY, 2, true);
fdset_add_fds(to, file, O_RDONLY, 2, true);
- migrate_multifd_mapped_ram_start(from, to);
+ migrate_hook_start_multifd_mapped_ram(from, to);
migrate_set_parameter_bool(from, "direct-io", true);
migrate_set_parameter_bool(to, "direct-io", true);
return NULL;
}
-static void *multifd_mapped_ram_fdset(QTestState *from, QTestState *to)
+static void *migrate_hook_start_multifd_mapped_ram_fdset(QTestState *from,
+ QTestState *to)
{
g_autofree char *file = g_strdup_printf("%s/%s", tmpfs, FILE_TEST_FILENAME);
fdset_add_fds(from, file, O_WRONLY, 2, false);
fdset_add_fds(to, file, O_RDONLY, 2, false);
- migrate_multifd_mapped_ram_start(from, to);
+ migrate_hook_start_multifd_mapped_ram(from, to);
return NULL;
}
MigrateCommon args = {
.connect_uri = uri,
.listen_uri = "defer",
- .start_hook = multifd_mapped_ram_fdset,
- .finish_hook = multifd_mapped_ram_fdset_end,
+ .start_hook = migrate_hook_start_multifd_mapped_ram_fdset,
+ .end_hook = migrate_hook_end_multifd_mapped_ram_fdset,
};
test_file_common(&args, true);
MigrateCommon args = {
.connect_uri = uri,
.listen_uri = "defer",
- .start_hook = multifd_mapped_ram_fdset_dio,
- .finish_hook = multifd_mapped_ram_fdset_end,
+ .start_hook = migrate_hook_start_multifd_mapped_ram_fdset_dio,
+ .end_hook = migrate_hook_end_multifd_mapped_ram_fdset,
};
if (!probe_o_direct_support(tmpfs)) {
test_precopy_common(&args);
}
-static void *test_migrate_switchover_ack_start(QTestState *from, QTestState *to)
+static void *migrate_hook_start_switchover_ack(QTestState *from, QTestState *to)
{
migrate_set_capability(from, "return-path", true);
{
MigrateCommon args = {
.listen_uri = "tcp:127.0.0.1:0",
- .start_hook = test_migrate_switchover_ack_start,
+ .start_hook = migrate_hook_start_switchover_ack,
/*
* Source VM must be running in order to consider the switchover ACK
* when deciding to do switchover or not.
{
MigrateCommon args = {
.listen_uri = "tcp:127.0.0.1:0",
- .start_hook = test_migrate_tls_psk_start_match,
- .finish_hook = test_migrate_tls_psk_finish,
+ .start_hook = migrate_hook_start_tls_psk_match,
+ .end_hook = migrate_hook_end_tls_psk,
};
test_precopy_common(&args);
.hide_stderr = true,
},
.listen_uri = "tcp:127.0.0.1:0",
- .start_hook = test_migrate_tls_psk_start_mismatch,
- .finish_hook = test_migrate_tls_psk_finish,
+ .start_hook = migrate_hook_start_tls_psk_mismatch,
+ .end_hook = migrate_hook_end_tls_psk,
.result = MIG_TEST_FAIL,
};
{
MigrateCommon args = {
.listen_uri = "tcp:127.0.0.1:0",
- .start_hook = test_migrate_tls_x509_start_default_host,
- .finish_hook = test_migrate_tls_x509_finish,
+ .start_hook = migrate_hook_start_tls_x509_default_host,
+ .end_hook = migrate_hook_end_tls_x509,
};
test_precopy_common(&args);
{
MigrateCommon args = {
.listen_uri = "tcp:127.0.0.1:0",
- .start_hook = test_migrate_tls_x509_start_override_host,
- .finish_hook = test_migrate_tls_x509_finish,
+ .start_hook = migrate_hook_start_tls_x509_override_host,
+ .end_hook = migrate_hook_end_tls_x509,
};
test_precopy_common(&args);
.hide_stderr = true,
},
.listen_uri = "tcp:127.0.0.1:0",
- .start_hook = test_migrate_tls_x509_start_mismatch_host,
- .finish_hook = test_migrate_tls_x509_finish,
+ .start_hook = migrate_hook_start_tls_x509_mismatch_host,
+ .end_hook = migrate_hook_end_tls_x509,
.result = MIG_TEST_FAIL_DEST_QUIT_ERR,
};
{
MigrateCommon args = {
.listen_uri = "tcp:127.0.0.1:0",
- .start_hook = test_migrate_tls_x509_start_friendly_client,
- .finish_hook = test_migrate_tls_x509_finish,
+ .start_hook = migrate_hook_start_tls_x509_friendly_client,
+ .end_hook = migrate_hook_end_tls_x509,
};
test_precopy_common(&args);
.hide_stderr = true,
},
.listen_uri = "tcp:127.0.0.1:0",
- .start_hook = test_migrate_tls_x509_start_hostile_client,
- .finish_hook = test_migrate_tls_x509_finish,
+ .start_hook = migrate_hook_start_tls_x509_hostile_client,
+ .end_hook = migrate_hook_end_tls_x509,
.result = MIG_TEST_FAIL,
};
{
MigrateCommon args = {
.listen_uri = "tcp:127.0.0.1:0",
- .start_hook = test_migrate_tls_x509_start_allow_anon_client,
- .finish_hook = test_migrate_tls_x509_finish,
+ .start_hook = migrate_hook_start_tls_x509_allow_anon_client,
+ .end_hook = migrate_hook_end_tls_x509,
};
test_precopy_common(&args);
.hide_stderr = true,
},
.listen_uri = "tcp:127.0.0.1:0",
- .start_hook = test_migrate_tls_x509_start_reject_anon_client,
- .finish_hook = test_migrate_tls_x509_finish,
+ .start_hook = migrate_hook_start_tls_x509_reject_anon_client,
+ .end_hook = migrate_hook_end_tls_x509,
.result = MIG_TEST_FAIL,
};
#endif /* CONFIG_GNUTLS */
#ifndef _WIN32
-static void *test_migrate_fd_start_hook(QTestState *from,
- QTestState *to)
+static void *migrate_hook_start_fd(QTestState *from,
+ QTestState *to)
{
int ret;
int pair[2];
return NULL;
}
-static void test_migrate_fd_finish_hook(QTestState *from,
- QTestState *to,
- void *opaque)
+static void migrate_hook_end_fd(QTestState *from,
+ QTestState *to,
+ void *opaque)
{
QDict *rsp;
const char *error_desc;
MigrateCommon args = {
.listen_uri = "defer",
.connect_uri = "fd:fd-mig",
- .start_hook = test_migrate_fd_start_hook,
- .finish_hook = test_migrate_fd_finish_hook
+ .start_hook = migrate_hook_start_fd,
+ .end_hook = migrate_hook_end_fd,
};
test_precopy_common(&args);
}
-static void *migrate_precopy_fd_file_start(QTestState *from, QTestState *to)
+static void *migrate_hook_start_precopy_fd_file(QTestState *from, QTestState *to)
{
g_autofree char *file = g_strdup_printf("%s/%s", tmpfs, FILE_TEST_FILENAME);
int src_flags = O_CREAT | O_RDWR;
MigrateCommon args = {
.listen_uri = "defer",
.connect_uri = "fd:fd-mig",
- .start_hook = migrate_precopy_fd_file_start,
- .finish_hook = test_migrate_fd_finish_hook
+ .start_hook = migrate_hook_start_precopy_fd_file,
+ .end_hook = migrate_hook_end_fd,
};
test_file_common(&args, true);
}
}
static void *
-test_migrate_precopy_tcp_multifd_start_common(QTestState *from,
+migrate_hook_start_precopy_tcp_multifd_common(QTestState *from,
QTestState *to,
const char *method)
{
}
static void *
-test_migrate_precopy_tcp_multifd_start(QTestState *from,
+migrate_hook_start_precopy_tcp_multifd(QTestState *from,
QTestState *to)
{
- return test_migrate_precopy_tcp_multifd_start_common(from, to, "none");
+ return migrate_hook_start_precopy_tcp_multifd_common(from, to, "none");
}
static void *
-test_migrate_precopy_tcp_multifd_start_zero_page_legacy(QTestState *from,
+migrate_hook_start_precopy_tcp_multifd_zero_page_legacy(QTestState *from,
QTestState *to)
{
- test_migrate_precopy_tcp_multifd_start_common(from, to, "none");
+ migrate_hook_start_precopy_tcp_multifd_common(from, to, "none");
migrate_set_parameter_str(from, "zero-page-detection", "legacy");
return NULL;
}
static void *
-test_migration_precopy_tcp_multifd_start_no_zero_page(QTestState *from,
- QTestState *to)
+migrate_hook_start_precopy_tcp_multifd_no_zero_page(QTestState *from,
+ QTestState *to)
{
- test_migrate_precopy_tcp_multifd_start_common(from, to, "none");
+ migrate_hook_start_precopy_tcp_multifd_common(from, to, "none");
migrate_set_parameter_str(from, "zero-page-detection", "none");
return NULL;
}
static void *
-test_migrate_precopy_tcp_multifd_zlib_start(QTestState *from,
+migrate_hook_start_precopy_tcp_multifd_zlib(QTestState *from,
QTestState *to)
{
/*
migrate_set_parameter_int(from, "multifd-zlib-level", 2);
migrate_set_parameter_int(to, "multifd-zlib-level", 2);
- return test_migrate_precopy_tcp_multifd_start_common(from, to, "zlib");
+ return migrate_hook_start_precopy_tcp_multifd_common(from, to, "zlib");
}
#ifdef CONFIG_ZSTD
static void *
-test_migrate_precopy_tcp_multifd_zstd_start(QTestState *from,
+migrate_hook_start_precopy_tcp_multifd_zstd(QTestState *from,
QTestState *to)
{
migrate_set_parameter_int(from, "multifd-zstd-level", 2);
migrate_set_parameter_int(to, "multifd-zstd-level", 2);
- return test_migrate_precopy_tcp_multifd_start_common(from, to, "zstd");
+ return migrate_hook_start_precopy_tcp_multifd_common(from, to, "zstd");
}
#endif /* CONFIG_ZSTD */
#ifdef CONFIG_QATZIP
static void *
-test_migrate_precopy_tcp_multifd_qatzip_start(QTestState *from,
+migrate_hook_start_precopy_tcp_multifd_qatzip(QTestState *from,
QTestState *to)
{
migrate_set_parameter_int(from, "multifd-qatzip-level", 2);
migrate_set_parameter_int(to, "multifd-qatzip-level", 2);
- return test_migrate_precopy_tcp_multifd_start_common(from, to, "qatzip");
+ return migrate_hook_start_precopy_tcp_multifd_common(from, to, "qatzip");
}
#endif
#ifdef CONFIG_QPL
static void *
-test_migrate_precopy_tcp_multifd_qpl_start(QTestState *from,
+migrate_hook_start_precopy_tcp_multifd_qpl(QTestState *from,
QTestState *to)
{
- return test_migrate_precopy_tcp_multifd_start_common(from, to, "qpl");
+ return migrate_hook_start_precopy_tcp_multifd_common(from, to, "qpl");
}
#endif /* CONFIG_QPL */
#ifdef CONFIG_UADK
static void *
-test_migrate_precopy_tcp_multifd_uadk_start(QTestState *from,
+migrate_hook_start_precopy_tcp_multifd_uadk(QTestState *from,
QTestState *to)
{
- return test_migrate_precopy_tcp_multifd_start_common(from, to, "uadk");
+ return migrate_hook_start_precopy_tcp_multifd_common(from, to, "uadk");
}
#endif /* CONFIG_UADK */
{
MigrateCommon args = {
.listen_uri = "defer",
- .start_hook = test_migrate_precopy_tcp_multifd_start,
+ .start_hook = migrate_hook_start_precopy_tcp_multifd,
/*
* Multifd is more complicated than most of the features, it
* directly takes guest page buffers when sending, make sure
{
MigrateCommon args = {
.listen_uri = "defer",
- .start_hook = test_migrate_precopy_tcp_multifd_start_zero_page_legacy,
+ .start_hook = migrate_hook_start_precopy_tcp_multifd_zero_page_legacy,
/*
* Multifd is more complicated than most of the features, it
* directly takes guest page buffers when sending, make sure
{
MigrateCommon args = {
.listen_uri = "defer",
- .start_hook = test_migration_precopy_tcp_multifd_start_no_zero_page,
+ .start_hook = migrate_hook_start_precopy_tcp_multifd_no_zero_page,
/*
* Multifd is more complicated than most of the features, it
* directly takes guest page buffers when sending, make sure
{
MigrateCommon args = {
.listen_uri = "defer",
- .start_hook = test_migrate_precopy_tcp_multifd_start,
+ .start_hook = migrate_hook_start_precopy_tcp_multifd,
.live = true,
.connect_channels = ("[ { 'channel-type': 'main',"
" 'addr': { 'transport': 'socket',"
{
MigrateCommon args = {
.listen_uri = "defer",
- .start_hook = test_migrate_precopy_tcp_multifd_zlib_start,
+ .start_hook = migrate_hook_start_precopy_tcp_multifd_zlib,
};
test_precopy_common(&args);
}
{
MigrateCommon args = {
.listen_uri = "defer",
- .start_hook = test_migrate_precopy_tcp_multifd_zstd_start,
+ .start_hook = migrate_hook_start_precopy_tcp_multifd_zstd,
};
test_precopy_common(&args);
}
{
MigrateCommon args = {
.listen_uri = "defer",
- .start_hook = test_migrate_precopy_tcp_multifd_qatzip_start,
+ .start_hook = migrate_hook_start_precopy_tcp_multifd_qatzip,
};
test_precopy_common(&args);
}
{
MigrateCommon args = {
.listen_uri = "defer",
- .start_hook = test_migrate_precopy_tcp_multifd_qpl_start,
+ .start_hook = migrate_hook_start_precopy_tcp_multifd_qpl,
};
test_precopy_common(&args);
}
{
MigrateCommon args = {
.listen_uri = "defer",
- .start_hook = test_migrate_precopy_tcp_multifd_uadk_start,
+ .start_hook = migrate_hook_start_precopy_tcp_multifd_uadk,
};
test_precopy_common(&args);
}
#ifdef CONFIG_GNUTLS
static void *
-test_migrate_multifd_tcp_tls_psk_start_match(QTestState *from,
+migrate_hook_start_multifd_tcp_tls_psk_match(QTestState *from,
QTestState *to)
{
- test_migrate_precopy_tcp_multifd_start_common(from, to, "none");
- return test_migrate_tls_psk_start_match(from, to);
+ migrate_hook_start_precopy_tcp_multifd_common(from, to, "none");
+ return migrate_hook_start_tls_psk_match(from, to);
}
static void *
-test_migrate_multifd_tcp_tls_psk_start_mismatch(QTestState *from,
+migrate_hook_start_multifd_tcp_tls_psk_mismatch(QTestState *from,
QTestState *to)
{
- test_migrate_precopy_tcp_multifd_start_common(from, to, "none");
- return test_migrate_tls_psk_start_mismatch(from, to);
+ migrate_hook_start_precopy_tcp_multifd_common(from, to, "none");
+ return migrate_hook_start_tls_psk_mismatch(from, to);
}
#ifdef CONFIG_TASN1
static void *
-test_migrate_multifd_tls_x509_start_default_host(QTestState *from,
+migrate_hook_start_multifd_tls_x509_default_host(QTestState *from,
QTestState *to)
{
- test_migrate_precopy_tcp_multifd_start_common(from, to, "none");
- return test_migrate_tls_x509_start_default_host(from, to);
+ migrate_hook_start_precopy_tcp_multifd_common(from, to, "none");
+ return migrate_hook_start_tls_x509_default_host(from, to);
}
static void *
-test_migrate_multifd_tls_x509_start_override_host(QTestState *from,
+migrate_hook_start_multifd_tls_x509_override_host(QTestState *from,
QTestState *to)
{
- test_migrate_precopy_tcp_multifd_start_common(from, to, "none");
- return test_migrate_tls_x509_start_override_host(from, to);
+ migrate_hook_start_precopy_tcp_multifd_common(from, to, "none");
+ return migrate_hook_start_tls_x509_override_host(from, to);
}
static void *
-test_migrate_multifd_tls_x509_start_mismatch_host(QTestState *from,
+migrate_hook_start_multifd_tls_x509_mismatch_host(QTestState *from,
QTestState *to)
{
- test_migrate_precopy_tcp_multifd_start_common(from, to, "none");
- return test_migrate_tls_x509_start_mismatch_host(from, to);
+ migrate_hook_start_precopy_tcp_multifd_common(from, to, "none");
+ return migrate_hook_start_tls_x509_mismatch_host(from, to);
}
static void *
-test_migrate_multifd_tls_x509_start_allow_anon_client(QTestState *from,
+migrate_hook_start_multifd_tls_x509_allow_anon_client(QTestState *from,
QTestState *to)
{
- test_migrate_precopy_tcp_multifd_start_common(from, to, "none");
- return test_migrate_tls_x509_start_allow_anon_client(from, to);
+ migrate_hook_start_precopy_tcp_multifd_common(from, to, "none");
+ return migrate_hook_start_tls_x509_allow_anon_client(from, to);
}
static void *
-test_migrate_multifd_tls_x509_start_reject_anon_client(QTestState *from,
+migrate_hook_start_multifd_tls_x509_reject_anon_client(QTestState *from,
QTestState *to)
{
- test_migrate_precopy_tcp_multifd_start_common(from, to, "none");
- return test_migrate_tls_x509_start_reject_anon_client(from, to);
+ migrate_hook_start_precopy_tcp_multifd_common(from, to, "none");
+ return migrate_hook_start_tls_x509_reject_anon_client(from, to);
}
#endif /* CONFIG_TASN1 */
{
MigrateCommon args = {
.listen_uri = "defer",
- .start_hook = test_migrate_multifd_tcp_tls_psk_start_match,
- .finish_hook = test_migrate_tls_psk_finish,
+ .start_hook = migrate_hook_start_multifd_tcp_tls_psk_match,
+ .end_hook = migrate_hook_end_tls_psk,
};
test_precopy_common(&args);
}
.hide_stderr = true,
},
.listen_uri = "defer",
- .start_hook = test_migrate_multifd_tcp_tls_psk_start_mismatch,
- .finish_hook = test_migrate_tls_psk_finish,
+ .start_hook = migrate_hook_start_multifd_tcp_tls_psk_mismatch,
+ .end_hook = migrate_hook_end_tls_psk,
.result = MIG_TEST_FAIL,
};
test_precopy_common(&args);
{
MigrateCommon args = {
.listen_uri = "defer",
- .start_hook = test_migrate_multifd_tls_x509_start_default_host,
- .finish_hook = test_migrate_tls_x509_finish,
+ .start_hook = migrate_hook_start_multifd_tls_x509_default_host,
+ .end_hook = migrate_hook_end_tls_x509,
};
test_precopy_common(&args);
}
{
MigrateCommon args = {
.listen_uri = "defer",
- .start_hook = test_migrate_multifd_tls_x509_start_override_host,
- .finish_hook = test_migrate_tls_x509_finish,
+ .start_hook = migrate_hook_start_multifd_tls_x509_override_host,
+ .end_hook = migrate_hook_end_tls_x509,
};
test_precopy_common(&args);
}
.hide_stderr = true,
},
.listen_uri = "defer",
- .start_hook = test_migrate_multifd_tls_x509_start_mismatch_host,
- .finish_hook = test_migrate_tls_x509_finish,
+ .start_hook = migrate_hook_start_multifd_tls_x509_mismatch_host,
+ .end_hook = migrate_hook_end_tls_x509,
.result = MIG_TEST_FAIL,
};
test_precopy_common(&args);
{
MigrateCommon args = {
.listen_uri = "defer",
- .start_hook = test_migrate_multifd_tls_x509_start_allow_anon_client,
- .finish_hook = test_migrate_tls_x509_finish,
+ .start_hook = migrate_hook_start_multifd_tls_x509_allow_anon_client,
+ .end_hook = migrate_hook_end_tls_x509,
};
test_precopy_common(&args);
}
.hide_stderr = true,
},
.listen_uri = "defer",
- .start_hook = test_migrate_multifd_tls_x509_start_reject_anon_client,
- .finish_hook = test_migrate_tls_x509_finish,
+ .start_hook = migrate_hook_start_multifd_tls_x509_reject_anon_client,
+ .end_hook = migrate_hook_end_tls_x509,
.result = MIG_TEST_FAIL,
};
test_precopy_common(&args);