diff mbox

[v3,09/13] test-char: add hotswap test

Message ID 1496152683-102751-10-git-send-email-anton.nefedov@virtuozzo.com (mailing list archive)
State New, archived
Headers show

Commit Message

Anton Nefedov May 30, 2017, 1:57 p.m. UTC 
Signed-off-by: Anton Nefedov <anton.nefedov@virtuozzo.com>
---
 tests/test-char.c | 68 +++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 68 insertions(+)

Comments

Marc-André Lureau May 31, 2017, 7:25 p.m. UTC | #1 
Hi

On Tue, May 30, 2017 at 6:15 PM Anton Nefedov <anton.nefedov@virtuozzo.com>
wrote:

> Signed-off-by: Anton Nefedov <anton.nefedov@virtuozzo.com>
> ---
>  tests/test-char.c | 68
> +++++++++++++++++++++++++++++++++++++++++++++++++++++++
>  1 file changed, 68 insertions(+)
>
> diff --git a/tests/test-char.c b/tests/test-char.c
> index ed6b18f..cd54f88 100644
> --- a/tests/test-char.c
> +++ b/tests/test-char.c
> @@ -635,6 +635,73 @@ static void char_invalid_test(void)
>      g_assert_null(chr);
>  }
>
> +static int chardev_change(void *opaque)
> +{
> +    return 0;
> +}
> +
> +static int chardev_change_denied(void *opaque)
> +{
> +    return -1;
> +}
> +
> +static void char_hotswap_test(void)
> +{
> +    char *chr_args;
> +    Chardev *chr;
> +    CharBackend be;
> +
> +    gchar *tmp_path = g_dir_make_tmp("qemu-test-char.XXXXXX", NULL);
> +    char *filename = g_build_filename(tmp_path, "file", NULL);
> +    ChardevFile file = { .out = filename };
> +    ChardevBackend backend = { .type = CHARDEV_BACKEND_KIND_FILE,
> +                               .u.file.data = &file };
> +
> +    int port;
> +    int sock = make_udp_socket(&port);
> +    g_assert_cmpint(sock, >, 0);
> +
> +    chr_args = g_strdup_printf("udp:127.0.0.1:%d", port);
> +
> +    chr = qemu_chr_new("chardev", chr_args);
> +    qemu_chr_fe_init(&be, chr, &error_abort);
> +
> +    /* check that chardev operates correctly */
> +    char_udp_test_internal(chr, sock);
> +
> +    /* set the handler that denies the hotswap */
> +    qemu_chr_fe_set_handlers(&be, NULL, NULL,
> +                             NULL, chardev_change_denied, NULL, NULL,
> true);
> +
> +    /* now, change is denied and has to keep the old backend operating */
> +    qmp_chardev_change("chardev", &backend, NULL);
>

Please add qapi_free_ChardevReturn(ret);

other than that:

Reviewed-by: Marc-André Lureau <marcandre.lureau@redhat.com>

+    g_assert(be.chr == chr);
> +
> +    char_udp_test_internal(chr, sock);
> +
> +    /* now allow the change */
> +    qemu_chr_fe_set_handlers(&be, NULL, NULL,
> +                             NULL, chardev_change, NULL, NULL, true);
> +
> +    /* has to succeed now */
> +    qmp_chardev_change("chardev", &backend, &error_abort);
> +    g_assert(be.chr != chr);
> +
> +    close(sock);
> +    chr = be.chr;
> +
> +    /* run the file chardev test */
> +    char_file_test_internal(chr, filename);
> +
> +    object_unparent(OBJECT(chr));
> +
> +    g_unlink(filename);
> +    g_free(filename);
> +    g_rmdir(tmp_path);
> +    g_free(tmp_path);
> +    g_free(chr_args);
> +}
> +
>  int main(int argc, char **argv)
>  {
>      qemu_init_main_loop(&error_abort);
> @@ -666,6 +733,7 @@ int main(int argc, char **argv)
>  #endif
>      g_test_add_func("/char/socket", char_socket_test);
>      g_test_add_func("/char/udp", char_udp_test);
> +    g_test_add_func("/char/hotswap", char_hotswap_test);
>
>      return g_test_run();
>  }
> --
> 2.7.4
>
>
> --
Marc-André Lureau
diff mbox

Patch

diff --git a/tests/test-char.c b/tests/test-char.c
index ed6b18f..cd54f88 100644
--- a/tests/test-char.c
+++ b/tests/test-char.c
@@ -635,6 +635,73 @@  static void char_invalid_test(void)
     g_assert_null(chr);
 }
 
+static int chardev_change(void *opaque)
+{
+    return 0;
+}
+
+static int chardev_change_denied(void *opaque)
+{
+    return -1;
+}
+
+static void char_hotswap_test(void)
+{
+    char *chr_args;
+    Chardev *chr;
+    CharBackend be;
+
+    gchar *tmp_path = g_dir_make_tmp("qemu-test-char.XXXXXX", NULL);
+    char *filename = g_build_filename(tmp_path, "file", NULL);
+    ChardevFile file = { .out = filename };
+    ChardevBackend backend = { .type = CHARDEV_BACKEND_KIND_FILE,
+                               .u.file.data = &file };
+
+    int port;
+    int sock = make_udp_socket(&port);
+    g_assert_cmpint(sock, >, 0);
+
+    chr_args = g_strdup_printf("udp:127.0.0.1:%d", port);
+
+    chr = qemu_chr_new("chardev", chr_args);
+    qemu_chr_fe_init(&be, chr, &error_abort);
+
+    /* check that chardev operates correctly */
+    char_udp_test_internal(chr, sock);
+
+    /* set the handler that denies the hotswap */
+    qemu_chr_fe_set_handlers(&be, NULL, NULL,
+                             NULL, chardev_change_denied, NULL, NULL, true);
+
+    /* now, change is denied and has to keep the old backend operating */
+    qmp_chardev_change("chardev", &backend, NULL);
+    g_assert(be.chr == chr);
+
+    char_udp_test_internal(chr, sock);
+
+    /* now allow the change */
+    qemu_chr_fe_set_handlers(&be, NULL, NULL,
+                             NULL, chardev_change, NULL, NULL, true);
+
+    /* has to succeed now */
+    qmp_chardev_change("chardev", &backend, &error_abort);
+    g_assert(be.chr != chr);
+
+    close(sock);
+    chr = be.chr;
+
+    /* run the file chardev test */
+    char_file_test_internal(chr, filename);
+
+    object_unparent(OBJECT(chr));
+
+    g_unlink(filename);
+    g_free(filename);
+    g_rmdir(tmp_path);
+    g_free(tmp_path);
+    g_free(chr_args);
+}
+
 int main(int argc, char **argv)
 {
     qemu_init_main_loop(&error_abort);
@@ -666,6 +733,7 @@  int main(int argc, char **argv)
 #endif
     g_test_add_func("/char/socket", char_socket_test);
     g_test_add_func("/char/udp", char_udp_test);
+    g_test_add_func("/char/hotswap", char_hotswap_test);
 
     return g_test_run();
 }