Patchwork [V7,14/15] xen: Set running state in xenstore.

login
register
mail settings
Submitter Anthony PERARD
Date Nov. 23, 2010, 7:51 p.m.
Message ID <1290541910-11332-15-git-send-email-anthony.perard@citrix.com>
Download mbox | patch
Permalink /patch/72756/
State New
Headers show

Comments

Anthony PERARD - Nov. 23, 2010, 7:51 p.m.
From: Anthony PERARD <anthony.perard@citrix.com>

This tells to the xen management tool that the machine can begin run.

Signed-off-by: Anthony PERARD <anthony.perard@citrix.com>
---
 xen-all.c |   27 +++++++++++++++++++++++++++
 1 files changed, 27 insertions(+), 0 deletions(-)

Patch

diff --git a/xen-all.c b/xen-all.c
index 36bdf30..b94d56e 100644
--- a/xen-all.c
+++ b/xen-all.c
@@ -58,6 +58,8 @@  typedef struct XenIOState {
     /* which vcpu we are serving */
     int send_vcpu;
 
+    struct xs_handle *xenstore;
+
     Notifier exit;
 } XenIOState;
 
@@ -426,6 +428,21 @@  static void cpu_handle_ioreq(void *opaque)
     }
 }
 
+static void xenstore_record_dm_state(XenIOState *s, const char *state)
+{
+    char *path = NULL;
+
+    if (asprintf(&path, "/local/domain/0/device-model/%u/state", xen_domid) == -1) {
+        fprintf(stderr, "out of memory recording dm state\n");
+        exit(1);
+    }
+    if (!xs_write(s->xenstore, XBT_NULL, path, state, strlen(state))) {
+        fprintf(stderr, "error recording dm state\n");
+        exit(1);
+    }
+    free(path);
+}
+
 static void xen_main_loop_prepare(XenIOState *state)
 {
     int evtchn_fd = state->xce_handle == -1 ? -1 : xc_evtchn_fd(state->xce_handle);
@@ -437,6 +454,9 @@  static void xen_main_loop_prepare(XenIOState *state)
     if (evtchn_fd != -1) {
         qemu_set_fd_handler(evtchn_fd, cpu_handle_ioreq, NULL, state);
     }
+
+    /* record state running */
+    xenstore_record_dm_state(state, "running");
 }
 
 
@@ -455,6 +475,7 @@  static void xen_exit_notifier(Notifier *n)
     XenIOState *state = container_of(n, XenIOState, exit);
 
     xc_evtchn_close(state->xce_handle);
+    xs_daemon_close(state->xenstore);
 }
 
 int xen_init(int smp_cpus)
@@ -480,6 +501,12 @@  int xen_init(int smp_cpus)
         return -errno;
     }
 
+    state->xenstore = xs_daemon_open();
+    if (state->xenstore == NULL) {
+        perror("xen: xenstore open");
+        return -errno;
+    }
+
     state->exit.notify = xen_exit_notifier;
     qemu_add_exit_notifier(&state->exit);