A stream with no measurement subsection has the shape of every stream written before that subsection existed; loading one exercises the conversion back from the register form. The temperature is picked so that form reproduces it exactly, and picked in the extended range, where the top register bit is part of the value rather than a sign.
Signed-off-by: Emmanuel Blot <[email protected]> --- tests/qtest/tmp421-test.c | 66 +++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 66 insertions(+) diff --git a/tests/qtest/tmp421-test.c b/tests/qtest/tmp421-test.c index 6c5332211b..5be2abc822 100644 --- a/tests/qtest/tmp421-test.c +++ b/tests/qtest/tmp421-test.c @@ -8,6 +8,8 @@ #include "qemu/osdep.h" +#include <glib/gstdio.h> +#include "libqtest.h" #include "libqtest-single.h" #include "libqos/qgraph.h" #include "libqos/i2c.h" @@ -224,6 +226,69 @@ static void test_n_correct(void *obj, void *data, QGuestAllocator *alloc) } } +static int qtest_get_temperature(QTestState *qts, const char *id, + unsigned channel) +{ + g_autofree char *prop = g_strdup_printf("temperature%u", channel); + QDict *response; + int ret; + + response = qtest_qmp(qts, "{ 'execute': 'qom-get', 'arguments': " + "{ 'path': %s, 'property': %s } }", id, prop); + g_assert(qdict_haskey(response, "return")); + ret = qdict_get_int(response, "return"); + qobject_unref(response); + return ret; +} + +/* + * A stream written before the measurement was held in millidegrees carries + * only the register form. The subsection holding the measurement is left out + * whenever that form can reproduce it, so an exactly representable extended + * range temperature -- whose register value has its top bit set, and is not + * a negative number -- travels the same path such a stream takes. + */ +static void test_migration(void *obj, void *data, QGuestAllocator *alloc) +{ + QI2CDevice *i2cdev = obj; + g_autofree char *tmpfs = NULL; + g_autofree char *mig_path = NULL; + g_autofree char *uri = NULL; + GString *dest_cmdline; + GError *err = NULL; + QTestState *to; + QDict *rsp; + + tmpfs = g_dir_make_tmp("tmp421-test-XXXXXX", &err); + g_assert_no_error(err); + g_assert(tmpfs); + + mig_path = g_strdup_printf("%s/socket.mig", tmpfs); + uri = g_strdup_printf("unix:%s", mig_path); + + i2c_set8(i2cdev, TMP421_CONFIG_REG_1, TMP421_CONFIG_RANGE); + set_temperature(TMP421_TEST_ID, 0, 100000); + g_assert_cmphex(i2c_get16(i2cdev, TMP421_TEMP_MSB0), ==, 0xA400); + + dest_cmdline = g_string_new(qos_get_current_command_line()); + g_string_append_printf(dest_cmdline, " -incoming %s", uri); + to = qtest_init(dest_cmdline->str); + + rsp = qmp("{ 'execute': 'migrate', 'arguments': { 'uri': %s } }", uri); + g_assert(qdict_haskey(rsp, "return")); + qobject_unref(rsp); + + qmp_eventwait("STOP"); + qtest_qmp_eventwait(to, "RESUME"); + + g_assert_cmpint(qtest_get_temperature(to, TMP421_TEST_ID, 0), ==, 100000); + + qtest_quit(to); + g_unlink(mig_path); + g_rmdir(tmpfs); + g_string_free(dest_cmdline, true); +} + static void tmp421_register_node(const TMP421Variant *var, const char *type, uint8_t addr) { @@ -255,6 +320,7 @@ static void tmp421_register_nodes(void) /* Temperature encoding is variant-independent; exercise it once. */ qos_add_test("temperature", "tmp421", test_temperature, NULL); qos_add_test("range-saturation", "tmp421", test_range_saturation, NULL); + qos_add_test("migration", "tmp421", test_migration, NULL); } libqos_init(tmp421_register_nodes); -- 2.53.0-Meta
