4  * Copyright (c) 2016-2018 Red Hat, Inc. and/or its affiliates
5  *   based on the vhost-user-test.c that is:
9  * See the COPYING file in the top-level directory.
15 #include "qapi/qapi-visit-sockets.h"
16 #include "qapi/qobject-input-visitor.h"
23 #include "migration/migration-util.h"
36 /* For dirty ring test; so far only x86_64 is supported */
44     switch (addr->type) {  in SocketAddress_to_str()
47                                addr->u.inet.host,  in SocketAddress_to_str()
48                                addr->u.inet.port);  in SocketAddress_to_str()
51                                addr->u.q_unix.path);  in SocketAddress_to_str()
53         return g_strdup_printf("fd:%s", addr->u.fd.str);  in SocketAddress_to_str()
56                                addr->u.vsock.cid,  in SocketAddress_to_str()
57                                addr->u.vsock.port);  in SocketAddress_to_str()
67     switch (addr->type) {  in SocketAddress_to_qdict()
70         qdict_put_str(dict, "host", addr->u.inet.host);  in SocketAddress_to_qdict()
71         qdict_put_str(dict, "port", addr->u.inet.port);  in SocketAddress_to_qdict()
75         qdict_put_str(dict, "path", addr->u.q_unix.path);  in SocketAddress_to_qdict()
79         qdict_put_str(dict, "str", addr->u.fd.str);  in SocketAddress_to_qdict()
83         qdict_put_str(dict, "cid", addr->u.vsock.cid);  in SocketAddress_to_qdict()
84         qdict_put_str(dict, "port", addr->u.vsock.port);  in SocketAddress_to_qdict()
101     object = qdict_get(rsp, "socket-address");  in migrate_get_socket_address()
117     connect_uri = SocketAddress_to_str(addrs->value);  in migrate_get_connect_uri()
130     connect_qdict = SocketAddress_to_qdict(addrs->value);  in migrate_get_connect_qdict()
172         state->stop_seen = true;  in migrate_watch_for_events()
175         state->suspend_seen = true;  in migrate_watch_for_events()
178         state->resume_seen = true;  in migrate_watch_for_events()
218         const char *dash = strrchr(mname, '-');  in resolve_machine_version()
244     MigrationTest *test = (MigrationTest *)data;  in migration_test_destroy()  local
246     g_free(test->name);  in migration_test_destroy()
247     g_free(test);  in migration_test_destroy()
252     MigrationTest *test = (MigrationTest *)data;  in migration_test_wrapper()  local
254     g_test_message("Running /%s%s", qtest_get_arch(), test->name);  in migration_test_wrapper()
255     test->func();  in migration_test_wrapper()
258 void migration_test_add(const char *path, void (*fn)(void))  in migration_test_add()  argument
260     MigrationTest *test = g_new0(MigrationTest, 1);  in migration_test_add()  local
262     test->func = fn;  in migration_test_add()
263     test->name = g_strdup(path);  in migration_test_add()
265     qtest_add_data_func_full(path, test, migration_test_wrapper,  in migration_test_add()
271     MigrationTest *test = (MigrationTest *)data;  in migration_test_wrapper_full()  local
273     g_test_message("Running /%s%s", qtest_get_arch(), test->name);  in migration_test_wrapper_full()
274     test->func_full(test->name);  in migration_test_wrapper_full()
277 void migration_test_add_suffix(const char *path, const char *suffix,  in migration_test_add_suffix()  argument
280     MigrationTest *test = g_new0(MigrationTest, 1);  in migration_test_add_suffix()  local
282     g_assert(g_str_has_suffix(path, "/"));  in migration_test_add_suffix()
285     test->func_full = fn;  in migration_test_add_suffix()
286     test->name = g_strconcat(path, suffix, NULL);  in migration_test_add_suffix()
288     qtest_add_data_func_full(test->name, test, migration_test_wrapper_full,  in migration_test_add_suffix()
300     g_autofree char *filename = g_strdup_printf("%s/probe-o-direct", tmpfs);  in probe_o_direct_support()
344     if (ufd == -1) {  in ufd_version_check()
345         g_test_message("Skipping test: userfaultfd not available");  in ufd_version_check()
352         g_test_message("Skipping test: UFFDIO_API failed");  in ufd_version_check()
363         g_test_message("Skipping test: Missing userfault feature");  in ufd_version_check()
372     g_test_message("Skipping test: Userfault not available (builtdtime)");  in ufd_version_check()
389     /* We test with 4096 slots */  in kvm_dirty_ring_supported()