test_domain_create_restore: Add testcase

Signed-off-by: Euan Harris <euan.harris@citrix.com>

diff --git a/test_domain_create_restore.c b/test_domain_create_restore.c
new file mode 100644 (file)
index 0000000..af3f488
--- /dev/null
+++ b/test_domain_create_restore.c
@@ -0,0 +1,127 @@
+#include <assert.h>
+#include <libxl.h>
+#include <libxl_event.h>
+#include <stdlib.h>
+#include <sys/types.h>
+#include <unistd.h>
+#include "testcase_runner.h"
+#include "eventloop_runner.h"
+#include "testcase_utils.h"
+
+/*
+ * This test calls libxl_domain_create_restore() repeatedly, cancelling
+ * it at different points in its lifecycle.   
+ * 
+ * Preconditions:
+ *   No existing domain is called test_domain_create_restore.
+ * 
+ * Postconditions:
+ *   After cancellation, the domain may or may not exist, and may be running.
+ */
+
+void *testcase(struct test *tc)
+{
+    int count;
+
+    libxl_domain_config dc;
+    uint32_t domid = -2;
+    struct event ev;
+
+    int rc;
+    FILE *suspend_file;
+    int suspend_fd;
+
+    init_domain_config(&dc, "test_domain_suspend",
+                       "resources/vmlinuz-4.0.4-301.fc22.x86_64",
+                       "resources/initrd.xen-4.0.4-301.fc22.x86_64",
+                       "resources/Fedora-Cloud-Base-22-20150521.x86_64.qcow2",
+                       "resources/cloudinit.iso");
+
+    do_domain_create(tc, &dc, &domid);
+    wait_for(tc, EV_LIBXL_CALLBACK, &ev);
+    assert(ev.u.callback_event.rc == 0);
+    printf("domid: %d\n", domid);
+
+    libxl_domain_unpause(tc->ctx, domid);
+    printf("domain %d unpaused\n", domid);
+
+    printf("waiting for domain to boot\n");
+    wait_for_n(tc, EV_EVENTLOOP, 10, &ev);     
+
+    suspend_file = tmpfile();
+    if (!suspend_file) {
+        perror("tmpfile");
+        exit(EXIT_FAILURE);
+    }
+    suspend_fd = fileno(suspend_file);
+    do_domain_suspend(tc, domid, suspend_fd);
+    wait_for(tc, EV_LIBXL_CALLBACK, &ev);
+
+    libxl_domain_destroy(tc->ctx, domid, 0);
+    libxl_domain_config_dispose(&dc);
+
+    /* test should wait for some number of fd_events, cancel, then
+       skip all fd_events and cancel on the next non-fd event, or at
+       least the next fd event on a different fd */
+    for (count = 1; count < 100; count++) {
+        libxl_domain_restore_params params;
+
+        printf("\n****** Will cancel after %d events ******\n", count);
+        init_domain_config(&dc, "test_domain_suspend",
+                           "resources/vmlinuz-4.0.4-301.fc22.x86_64",
+                           "resources/initrd.xen-4.0.4-301.fc22.x86_64",
+                           "resources/Fedora-Cloud-Base-22-20150521.x86_64.qcow2",
+                           "resources/cloudinit.iso");
+
+        libxl_domain_restore_params_init(&params);
+       lseek(suspend_fd, 0, SEEK_SET);
+
+       domid = -2;
+       do_domain_create_restore(tc, &dc, &domid, suspend_fd, &params);
+
+        if (wait_until_n(tc, EV_LIBXL_CALLBACK, count, &ev)) {
+            /* The API call returned before we could cancel it.
+               It should have returned successfully.
+             */
+            fclose(suspend_file);
+            printf("libxl_domain_restore returned %d\n",
+                   ev.u.callback_event.rc);
+            assert(ev.u.callback_event.rc == 0);
+            libxl_domain_unpause(tc->ctx, domid);
+
+            /* No operation in progress - cancelling should return an error */
+            rc = libxl_ao_cancel(tc->ctx, &tc->ao_how);
+            printf("libxl_ao_cancel returned %d\n", rc);
+            assert(rc == ERROR_NOTFOUND);
+
+            break;
+        }
+
+        rc = libxl_ao_cancel(tc->ctx, &tc->ao_how);
+
+        /* Calling cancel on a cancellable operation should not return an
+           error, unless the operation happened to complete in the meantime.
+         */
+        printf("libxl_ao_cancel returned %d\n", rc);
+        assert(rc == ERROR_NOTFOUND || rc == 0);
+
+        /* The API call's return code should indicate that it was cancelled */
+        wait_for(tc, EV_LIBXL_CALLBACK, &ev);
+        printf("libxl_domain_restore returned %d\n",
+               ev.u.callback_event.rc);
+        assert(ev.u.callback_event.rc == ERROR_FAIL  /* XXX should be ERROR_CANCELLED */
+               || ev.u.callback_event.rc == 0);
+        assert(domid != (uint32_t) -2);
+
+        /* Restore was cancelled - the domain should not be running */
+        /* assert(!libxl_domain_info(tc->ctx, NULL, domid)); */
+        libxl_domain_destroy(tc->ctx, domid, 0);
+        libxl_domain_config_dispose(&dc);
+    }
+
+    fclose(suspend_file);
+    libxl_domain_destroy(tc->ctx, domid, 0);
+    libxl_domain_config_dispose(&dc);
+    test_exit();
+    return NULL;
+}

diff --git a/testcase_utils.c b/testcase_utils.c
index 35804884befa86fe1100657db7689b55b52b78e4..dc8c975056948e5ceab262903185149e2920b4b1 100644 (file)
--- a/testcase_utils.c
+++ b/testcase_utils.c
@@ -11,6 +11,7 @@ void print_domain_config(libxl_ctx * ctx, char *msg, libxl_domain_config * dc)
     free(json);
 }
 
+
 void
 init_domain_config(libxl_domain_config * dc,
                    char *name, char *kernel, char *ramdisk,
@@ -76,3 +77,14 @@ int do_domain_suspend(struct test *t, uint32_t domid, int fd)
 
     return libxl_domain_suspend(t->ctx, domid, fd, LIBXL_SUSPEND_LIVE, &t->ao_how);
 }
+
+int
+do_domain_create_restore(struct test *t, libxl_domain_config * dc,
+                         uint32_t * domid_out, int restore_fd,
+                         libxl_domain_restore_params *params)
+{
+    t->ao_how.callback = generic_callback;
+    t->ao_how.u.for_callback = t;
+
+    return libxl_domain_create_restore(t->ctx, dc, domid_out, restore_fd, params, &t->ao_how, 0);
+}

diff --git a/testcase_utils.h b/testcase_utils.h
index 23748b7c02eb3d10483869594f6b87622d5a2a85..144654f17bd97f03aeebe2b64af3f3fe0cc333a6 100644 (file)
--- a/testcase_utils.h
+++ b/testcase_utils.h
@@ -8,8 +8,12 @@ struct test;
 void init_domain_config(libxl_domain_config * dc,
                         char *name, char *kernel, char *ramdisk,
                         char *hdd, char *cdrom);
+
 int do_domain_create(struct test *t, libxl_domain_config * dc,
                      uint32_t * domid_out);
+int do_domain_create_restore(struct test *t, libxl_domain_config * dc,
+                             uint32_t * domid_out, int restore_fd,
+                             libxl_domain_restore_params *params);
 int do_domain_suspend(struct test *t, uint32_t domid, int fd);
 
 #endif                          /* __TESTCASE_UTILS */