237 static void *migrate_hook_start_fd(QTestState *from,  in migrate_hook_start_fd()  argument
253     /* Start incoming migration from the 1st socket */  in migrate_hook_start_fd()
257     qtest_qmp_fds_assert_success(from, &pair[1], 1,  in migrate_hook_start_fd()
265 static void migrate_hook_end_fd(QTestState *from,  in migrate_hook_end_fd()  argument
274      * We assume, that QEMU removes named fd from its list,  in migrate_hook_end_fd()
277     rsp = qtest_qmp(from,  in migrate_hook_end_fd()
305 static void *migrate_hook_start_precopy_fd_file(QTestState *from,  in migrate_hook_start_precopy_fd_file()  argument
324     qtest_qmp_fds_assert_success(from, &fds[1], 1,  in migrate_hook_start_precopy_fd_file()
365     QTestState *from, *to;  in test_auto_converge()  local
377     if (migrate_start(&from, &to, uri, &args)) {  in test_auto_converge()
381     migrate_set_capability(from, "auto-converge", true);  in test_auto_converge()
382     migrate_set_parameter_int(from, "cpu-throttle-initial", init_pct);  in test_auto_converge()
383     migrate_set_parameter_int(from, "cpu-throttle-increment", inc_pct);  in test_auto_converge()
384     migrate_set_parameter_int(from, "max-cpu-throttle", max_pct);  in test_auto_converge()
390     migrate_ensure_non_converge(from);  in test_auto_converge()
393     migrate_set_capability(from, "pause-before-switchover", true);  in test_auto_converge()
395     /* Wait for the first serial output from the source */  in test_auto_converge()
398     migrate_qmp(from, to, uri, NULL, "{}");  in test_auto_converge()
403         percentage = read_migrate_property_int(from, "cpu-throttle-percentage");  in test_auto_converge()
416     while ((dirty_sync_cnt = get_migration_pass(from)) < 2) {  in test_auto_converge()
432         dirty_sync_cnt = get_migration_pass(from);  in test_auto_converge()
443     migrate_ensure_converge(from);  in test_auto_converge()
449     wait_for_migration_status(from, "pre-switchover", NULL);  in test_auto_converge()
452     percentage = read_migrate_property_int(from, "cpu-throttle-percentage");  in test_auto_converge()
454     migrate_continue(from, "pre-switchover");  in test_auto_converge()
459     wait_for_migration_complete(from);  in test_auto_converge()
461     migrate_end(from, to, true);  in test_auto_converge()
465 migrate_hook_start_precopy_tcp_multifd(QTestState *from,  in migrate_hook_start_precopy_tcp_multifd()  argument
468     return migrate_hook_start_precopy_tcp_multifd_common(from, to, "none");  in migrate_hook_start_precopy_tcp_multifd()
472 migrate_hook_start_precopy_tcp_multifd_zero_page_legacy(QTestState *from,  in migrate_hook_start_precopy_tcp_multifd_zero_page_legacy()  argument
475     migrate_hook_start_precopy_tcp_multifd_common(from, to, "none");  in migrate_hook_start_precopy_tcp_multifd_zero_page_legacy()
476     migrate_set_parameter_str(from, "zero-page-detection", "legacy");  in migrate_hook_start_precopy_tcp_multifd_zero_page_legacy()
481 migrate_hook_start_precopy_tcp_multifd_no_zero_page(QTestState *from,  in migrate_hook_start_precopy_tcp_multifd_no_zero_page()  argument
484     migrate_hook_start_precopy_tcp_multifd_common(from, to, "none");  in migrate_hook_start_precopy_tcp_multifd_no_zero_page()
485     migrate_set_parameter_str(from, "zero-page-detection", "none");  in migrate_hook_start_precopy_tcp_multifd_no_zero_page()
577     QTestState *from, *to, *to2;  in test_multifd_tcp_cancel()  local
579     if (migrate_start(&from, &to, "defer", &args)) {  in test_multifd_tcp_cancel()
583     migrate_ensure_non_converge(from);  in test_multifd_tcp_cancel()
584     migrate_prepare_for_dirty_mem(from);  in test_multifd_tcp_cancel()
587         migrate_set_capability(from, "postcopy-ram", true);  in test_multifd_tcp_cancel()
591     migrate_set_parameter_int(from, "multifd-channels", 16);  in test_multifd_tcp_cancel()
594     migrate_set_capability(from, "multifd", true);  in test_multifd_tcp_cancel()
597     /* Start incoming migration from the 1st socket */  in test_multifd_tcp_cancel()
600     /* Wait for the first serial output from the source */  in test_multifd_tcp_cancel()
603     migrate_qmp(from, to, NULL, NULL, "{}");  in test_multifd_tcp_cancel()
605     migrate_wait_for_dirty_mem(from, to);  in test_multifd_tcp_cancel()
607     migrate_cancel(from);  in test_multifd_tcp_cancel()
622     wait_for_migration_status(from, "cancelled", NULL);  in test_multifd_tcp_cancel()
628     if (migrate_start(&from, &to2, "defer", &args)) {  in test_multifd_tcp_cancel()
640     /* Start incoming migration from the 1st socket */  in test_multifd_tcp_cancel()
643     migrate_ensure_non_converge(from);  in test_multifd_tcp_cancel()
645     migrate_qmp(from, to2, NULL, NULL, "{}");  in test_multifd_tcp_cancel()
647     migrate_wait_for_dirty_mem(from, to2);  in test_multifd_tcp_cancel()
649     migrate_ensure_converge(from);  in test_multifd_tcp_cancel()
651     wait_for_stop(from, get_src());  in test_multifd_tcp_cancel()
655     wait_for_migration_complete(from);  in test_multifd_tcp_cancel()
656     migrate_end(from, to2, true);  in test_multifd_tcp_cancel()
669 static void test_cancel_src_after_failed(QTestState *from, QTestState *to,  in test_cancel_src_after_failed()  argument
678     migrate_ensure_converge(from);  in test_cancel_src_after_failed()
680     migrate_qmp(from, to, uri, NULL, "{}");  in test_cancel_src_after_failed()
682     migration_event_wait(from, phase);  in test_cancel_src_after_failed()
683     migrate_cancel(from);  in test_cancel_src_after_failed()
687     wait_for_migration_status(from, "failed",  in test_cancel_src_after_failed()
696 static void test_cancel_src_after_cancelled(QTestState *from, QTestState *to,  in test_cancel_src_after_cancelled()  argument
702     migrate_ensure_converge(from);  in test_cancel_src_after_cancelled()
704     migrate_qmp(from, to, uri, NULL, "{}");  in test_cancel_src_after_cancelled()
707     migrate_cancel(from);  in test_cancel_src_after_cancelled()
708     migration_event_wait(from, phase);  in test_cancel_src_after_cancelled()
711     migrate_cancel(from);  in test_cancel_src_after_cancelled()
713     wait_for_migration_status(from, "cancelled",  in test_cancel_src_after_cancelled()
720 static void test_cancel_src_after_complete(QTestState *from, QTestState *to,  in test_cancel_src_after_complete()  argument
726     migrate_ensure_converge(from);  in test_cancel_src_after_complete()
728     migrate_qmp(from, to, uri, NULL, "{}");  in test_cancel_src_after_complete()
730     migration_event_wait(from, phase);  in test_cancel_src_after_complete()
731     migrate_cancel(from);  in test_cancel_src_after_complete()
737     wait_for_migration_complete(from);  in test_cancel_src_after_complete()
741 static void test_cancel_src_after_none(QTestState *from, QTestState *to,  in test_cancel_src_after_none()  argument
751     migrate_cancel(from);  in test_cancel_src_after_none()
755     migrate_ensure_converge(from);  in test_cancel_src_after_none()
756     migrate_qmp(from, to, uri, NULL, "{}");  in test_cancel_src_after_none()
758     wait_for_migration_complete(from);  in test_cancel_src_after_none()
762 static void test_cancel_src_pre_switchover(QTestState *from, QTestState *to,  in test_cancel_src_pre_switchover()  argument
765     migrate_set_capability(from, "pause-before-switchover", true);  in test_cancel_src_pre_switchover()
768     migrate_set_capability(from, "multifd", true);  in test_cancel_src_pre_switchover()
774     migrate_ensure_converge(from);  in test_cancel_src_pre_switchover()
776     migrate_qmp(from, to, uri, NULL, "{}");  in test_cancel_src_pre_switchover()
778     migration_event_wait(from, phase);  in test_cancel_src_pre_switchover()
779     migrate_cancel(from);  in test_cancel_src_pre_switchover()
780     migration_event_wait(from, "cancelling");  in test_cancel_src_pre_switchover()
782     wait_for_migration_status(from, "cancelled",  in test_cancel_src_pre_switchover()
794     QTestState *from, *to;  in test_cancel_src_after_status()  local
799     if (migrate_start(&from, &to, "defer", &args)) {  in test_cancel_src_after_status()
805         test_cancel_src_after_cancelled(from, to, uri, phase);  in test_cancel_src_after_status()
808         test_cancel_src_after_complete(from, to, uri, phase);  in test_cancel_src_after_status()
811         test_cancel_src_after_failed(from, to, uri, phase);  in test_cancel_src_after_status()
814         test_cancel_src_after_none(from, to, uri, phase);  in test_cancel_src_after_status()
818         test_cancel_src_pre_switchover(from, to, uri, phase);  in test_cancel_src_after_status()
821     migrate_end(from, to, false);  in test_cancel_src_after_status()
995     /* Wait for the first serial output from the vm*/  in test_vcpu_dirty_limit()
1007     /* VM booted from bootsect should dirty memory steadily */  in test_vcpu_dirty_limit()
1071 static void migrate_dirty_limit_wait_showup(QTestState *from,  in migrate_dirty_limit_wait_showup()  argument
1076     migrate_set_capability(from, "dirty-limit", true);  in migrate_dirty_limit_wait_showup()
1079     migrate_set_parameter_int(from, "x-vcpu-dirty-limit-period", period);  in migrate_dirty_limit_wait_showup()
1080     migrate_set_parameter_int(from, "vcpu-dirty-limit", value);  in migrate_dirty_limit_wait_showup()
1083     migrate_ensure_non_converge(from);  in migrate_dirty_limit_wait_showup()
1086     migrate_set_capability(from, "pause-before-switchover", true);  in migrate_dirty_limit_wait_showup()
1088     /* Wait for the serial output from the source */  in migrate_dirty_limit_wait_showup()
1113     QTestState *from, *to;  in test_dirty_limit()  local
1141     if (migrate_start(&from, &to, args.listen_uri, &args.start)) {  in test_dirty_limit()
1146     migrate_dirty_limit_wait_showup(from, dirtylimit_period, dirtylimit_value);  in test_dirty_limit()
1149     migrate_qmp(from, to, args.connect_uri, NULL, "{}");  in test_dirty_limit()
1155             read_migrate_property_int(from,  in test_dirty_limit()
1162     migrate_cancel(from);  in test_dirty_limit()
1163     wait_for_migration_status(from, "cancelled", NULL);  in test_dirty_limit()
1173             read_migrate_property_int(from,  in test_dirty_limit()
1192     if (migrate_start(&from, &to, args.listen_uri, &args.start)) {  in test_dirty_limit()
1197     migrate_qmp(from, to, args.connect_uri, NULL, "{}");  in test_dirty_limit()
1203             read_migrate_property_int(from,  in test_dirty_limit()
1213     g_assert_cmpint(dirtylimit_value, ==, get_limit_rate(from));  in test_dirty_limit()
1216     migrate_set_parameter_int(from, "downtime-limit", downtime_limit);  in test_dirty_limit()
1217     migrate_set_parameter_int(from, "max-bandwidth", max_bandwidth);  in test_dirty_limit()
1223     wait_for_migration_status(from, "pre-switchover", NULL);  in test_dirty_limit()
1225     remaining = read_ram_property_int(from, "remaining");  in test_dirty_limit()
1229     migrate_continue(from, "pre-switchover");  in test_dirty_limit()
1234     wait_for_migration_complete(from);  in test_dirty_limit()
1236     migrate_end(from, to, true);  in test_dirty_limit()