args->start.hide_stderr = true;
- if (migrate_start(&from, &to, "tcp:127.0.0.1:0", &args->start)) {
+ if (migrate_start(&from, &to, "defer", &args->start)) {
return;
}
+
+ migrate_incoming_qmp(to, "tcp:127.0.0.1:0", NULL, "{}");
migrate_qmp(from, to, "tcp:127.0.0.1:0", NULL, "{}");
wait_for_migration_fail(from, false);
migrate_end(from, to, false);
return;
}
- /* dummy url */
- if (migrate_start(&from, &to, "tcp:127.0.0.1:0", &args->start)) {
+ if (migrate_start(&from, &to, "defer", &args->start)) {
return;
}
uri = g_strdup_printf("exec:cat > %s", file);
migrate_ensure_converge(from);
+ migrate_incoming_qmp(to, "tcp:127.0.0.1:0", NULL, "{}");
migrate_qmp(from, to, uri, NULL, "{}");
wait_for_migration_complete(from);
QTestState *from, *to;
QObject *channels;
- if (migrate_start(&from, &to, args->listen_uri, &args->start)) {
+ if (migrate_start(&from, &to, "defer", &args->start)) {
return;
}
/* Wait for the first serial output from the source */
wait_for_serial("src_serial");
+ migrate_incoming_qmp(to, "tcp:127.0.0.1:0", NULL, "{}");
+
/*
* 'uri' and 'channels' validation is checked even before the migration
* starts.
static void test_validate_uri_channels_both_set(char *name, MigrateCommon *args)
{
- args->listen_uri = "defer",
args->connect_uri = "tcp:127.0.0.1:0",
args->connect_channels = ("[ { ""'channel-type': 'main',"
" 'addr': { 'transport': 'socket',"
static void test_validate_uri_channels_none_set(char *name, MigrateCommon *args)
{
- args->listen_uri = "defer";
args->start.hide_stderr = true;
do_test_validate_uri_channel(args);