Commit 5f32dc8e authored by Alexey Perevalov's avatar Alexey Perevalov Committed by Juan Quintela
Browse files

migration: add blocktime calculation into migration-test 



This patch just requests blocktime calculation,
and check it in case when UFFD_FEATURE_THREAD_ID feature is set
on the host.

Reviewed-by: default avatarDr. David Alan Gilbert <dgilbert@redhat.com>
Signed-off-by: default avatarAlexey Perevalov <a.perevalov@samsung.com>
Reviewed-by: default avatarJuan Quintela <quintela@redhat.com>
Signed-off-by: default avatarJuan Quintela <quintela@redhat.com>
parent 2f7dae9d

tests/migration-test.c

+16 −0
Original line number Diff line number Diff line
@@ -25,6 +25,7 @@ 
const unsigned start_address = 1024 * 1024;

const unsigned end_address = 100 * 1024 * 1024;

bool got_stop;

static bool uffd_feature_thread_id;



#if defined(__linux__)

#include <sys/syscall.h>
@@ -54,6 +55,7 @@ static bool ufd_version_check(void) 
        g_test_message("Skipping test: UFFDIO_API failed");

        return false;

    }

    uffd_feature_thread_id = api_struct.features & UFFD_FEATURE_THREAD_ID;



    ioctl_mask = (__u64)1 << _UFFDIO_REGISTER |

                 (__u64)1 << _UFFDIO_UNREGISTER;
@@ -266,6 +268,16 @@ static uint64_t get_migration_pass(QTestState *who) 
    return result;

}



static void read_blocktime(QTestState *who)

{

    QDict *rsp, *rsp_return;



    rsp = wait_command(who, "{ 'execute': 'query-migrate' }");

    rsp_return = qdict_get_qdict(rsp, "return");

    g_assert(qdict_haskey(rsp_return, "postcopy-blocktime"));

    QDECREF(rsp);

}



static void wait_for_migration_complete(QTestState *who)

{

    QDict *rsp, *rsp_return;
@@ -525,6 +537,7 @@ static void test_migrate(void) 


    migrate_set_capability(from, "postcopy-ram", "true");

    migrate_set_capability(to, "postcopy-ram", "true");

    migrate_set_capability(to, "postcopy-blocktime", "true");



    /* We want to pick a speed slow enough that the test completes

     * quickly, but that it doesn't complete precopy even on a slow
@@ -553,6 +566,9 @@ static void test_migrate(void) 
    wait_for_serial("dest_serial");

    wait_for_migration_complete(from);



    if (uffd_feature_thread_id) {

        read_blocktime(to);

    }

    g_free(uri);



    test_migrate_end(from, to);