[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
Re: [PATCH 3/6] tests/qtest: migration: Add migrate_incoming_qmp helper
From: |
Peter Xu |
Subject: |
Re: [PATCH 3/6] tests/qtest: migration: Add migrate_incoming_qmp helper |
Date: |
Thu, 29 Jun 2023 17:16:36 -0400 |
On Wed, Jun 28, 2023 at 01:55:39PM -0300, Fabiano Rosas wrote:
> file-based migration requires the target to initiate its migration after
> the source has finished writing out the data in the file. Currently
> there's no easy way to initiate 'migrate-incoming', allow this by
> introducing migrate_incoming_qmp helper, similarly to migrate_qmp.
>
> Also make sure migration events are enabled and wait for the incoming
> migration to start before returning. This avoid a race when querying
> the migration status too soon after issuing the command.
>
> Signed-off-by: Fabiano Rosas <farosas@suse.de>
> ---
> tests/qtest/migration-helpers.c | 28 ++++++++++++++++++++++++++++
> tests/qtest/migration-helpers.h | 4 ++++
> 2 files changed, 32 insertions(+)
>
> diff --git a/tests/qtest/migration-helpers.c b/tests/qtest/migration-helpers.c
> index 2df198c99e..bc54b29184 100644
> --- a/tests/qtest/migration-helpers.c
> +++ b/tests/qtest/migration-helpers.c
> @@ -81,6 +81,34 @@ void migrate_set_capability(QTestState *who, const char
> *capability,
> capability, value);
> }
>
> +void migrate_incoming_qmp(QTestState *to, const char *uri, const char *fmt,
> ...)
> +{
> + va_list ap;
> + QDict *args, *rsp, *data;
> +
> + va_start(ap, fmt);
> + args = qdict_from_vjsonf_nofail(fmt, ap);
> + va_end(ap);
> +
> + g_assert(!qdict_haskey(args, "uri"));
> + qdict_put_str(args, "uri", uri);
> +
> + migrate_set_capability(to, "events", true);
> +
> + rsp = qtest_qmp(to, "{ 'execute': 'migrate-incoming', 'arguments': %p}",
> + args);
> + g_assert(qdict_haskey(rsp, "return"));
rsp leaked?
> +
> + rsp = qtest_qmp_eventwait_ref(to, "MIGRATION");
> + g_assert(qdict_haskey(rsp, "data"));
> +
> + data = qdict_get_qdict(rsp, "data");
> + g_assert(qdict_haskey(data, "status"));
> + g_assert_cmpstr(qdict_get_str(data, "status"), ==, "setup");
> +
> + qobject_unref(rsp);
> +}
> +
> /*
> * Note: caller is responsible to free the returned object via
> * qobject_unref() after use
> diff --git a/tests/qtest/migration-helpers.h b/tests/qtest/migration-helpers.h
> index 484d7c960f..57d295a4fe 100644
> --- a/tests/qtest/migration-helpers.h
> +++ b/tests/qtest/migration-helpers.h
> @@ -23,6 +23,10 @@ bool migrate_watch_for_resume(QTestState *who, const char
> *name,
> G_GNUC_PRINTF(3, 4)
> void migrate_qmp(QTestState *who, const char *uri, const char *fmt, ...);
>
> +G_GNUC_PRINTF(3, 4)
> +void migrate_incoming_qmp(QTestState *who, const char *uri,
> + const char *fmt, ...);
> +
> void migrate_set_capability(QTestState *who, const char *capability,
> bool value);
>
> --
> 2.35.3
>
--
Peter Xu
- Re: [PATCH 1/6] migration: Set migration status early in incoming side, (continued)
- [PATCH 3/6] tests/qtest: migration: Add migrate_incoming_qmp helper, Fabiano Rosas, 2023/06/26
- [PATCH 4/6] tests/qtest: migration: Use migrate_incoming_qmp where appropriate, Fabiano Rosas, 2023/06/26
- [PATCH 5/6] tests/qtest: migration: Add support for negative testing of qmp_migrate, Fabiano Rosas, 2023/06/26
- [PATCH 6/6] tests/qtest: migration-test: Add tests for file-based migration, Fabiano Rosas, 2023/06/26
- [PATCH 0/6] migration: Test the new "file:" migration, Fabiano Rosas, 2023/06/28
- [PATCH 2/6] tests/qtest: migration: Expose migrate_set_capability, Fabiano Rosas, 2023/06/28
- [PATCH 5/6] tests/qtest: migration: Add support for negative testing of qmp_migrate, Fabiano Rosas, 2023/06/28
- [PATCH 6/6] tests/qtest: migration-test: Add tests for file-based migration, Fabiano Rosas, 2023/06/28
[PATCH 1/6] migration: Set migration status early in incoming side, Fabiano Rosas, 2023/06/28