LXR qemu/xen-common.c

   1/*
   2 * Copyright (C) 2014       Citrix Systems UK Ltd.
   3 *
   4 * This work is licensed under the terms of the GNU GPL, version 2.  See
   5 * the COPYING file in the top-level directory.
   6 *
   7 * Contributions after 2012-01-13 are licensed under the terms of the
   8 * GNU GPL, version 2 or (at your option) any later version.
   9 */
  10
  11#include "qemu/osdep.h"
  12#include "hw/xen/xen_backend.h"
  13#include "qmp-commands.h"
  14#include "sysemu/char.h"
  15#include "sysemu/accel.h"
  16#include "migration/migration.h"
  17
  18//#define DEBUG_XEN
  19
  20#ifdef DEBUG_XEN
  21#define DPRINTF(fmt, ...) \
  22    do { fprintf(stderr, "xen: " fmt, ## __VA_ARGS__); } while (0)
  23#else
  24#define DPRINTF(fmt, ...) \
  25    do { } while (0)
  26#endif
  27
  28static int store_dev_info(int domid, CharDriverState *cs, const char *string)
  29{
  30    struct xs_handle *xs = NULL;
  31    char *path = NULL;
  32    char *newpath = NULL;
  33    char *pts = NULL;
  34    int ret = -1;
  35
  36    /* Only continue if we're talking to a pty. */
  37    if (strncmp(cs->filename, "pty:", 4)) {
  38        return 0;
  39    }
  40    pts = cs->filename + 4;
  41
  42    /* We now have everything we need to set the xenstore entry. */
  43    xs = xs_open(0);
  44    if (xs == NULL) {
  45        fprintf(stderr, "Could not contact XenStore\n");
  46        goto out;
  47    }
  48
  49    path = xs_get_domain_path(xs, domid);
  50    if (path == NULL) {
  51        fprintf(stderr, "xs_get_domain_path() error\n");
  52        goto out;
  53    }
  54    newpath = realloc(path, (strlen(path) + strlen(string) +
  55                strlen("/tty") + 1));
  56    if (newpath == NULL) {
  57        fprintf(stderr, "realloc error\n");
  58        goto out;
  59    }
  60    path = newpath;
  61
  62    strcat(path, string);
  63    strcat(path, "/tty");
  64    if (!xs_write(xs, XBT_NULL, path, pts, strlen(pts))) {
  65        fprintf(stderr, "xs_write for '%s' fail", string);
  66        goto out;
  67    }
  68    ret = 0;
  69
  70out:
  71    free(path);
  72    xs_close(xs);
  73
  74    return ret;
  75}
  76
  77void xenstore_store_pv_console_info(int i, CharDriverState *chr)
  78{
  79    if (i == 0) {
  80        store_dev_info(xen_domid, chr, "/console");
  81    } else {
  82        char buf[32];
  83        snprintf(buf, sizeof(buf), "/device/console/%d", i);
  84        store_dev_info(xen_domid, chr, buf);
  85    }
  86}
  87
  88
  89static void xenstore_record_dm_state(struct xs_handle *xs, const char *state)
  90{
  91    char path[50];
  92
  93    if (xs == NULL) {
  94        fprintf(stderr, "xenstore connection not initialized\n");
  95        exit(1);
  96    }
  97
  98    snprintf(path, sizeof (path), "device-model/%u/state", xen_domid);
  99    if (!xs_write(xs, XBT_NULL, path, state, strlen(state))) {
 100        fprintf(stderr, "error recording dm state\n");
 101        exit(1);
 102    }
 103}
 104
 105
 106static void xen_change_state_handler(void *opaque, int running,
 107                                     RunState state)
 108{
 109    if (running) {
 110        /* record state running */
 111        xenstore_record_dm_state(xenstore, "running");
 112    }
 113}
 114
 115static int xen_init(MachineState *ms)
 116{
 117    xen_xc = xc_interface_open(0, 0, 0);
 118    if (xen_xc == NULL) {
 119        xen_be_printf(NULL, 0, "can't open xen interface\n");
 120        return -1;
 121    }
 122    xen_fmem = xenforeignmemory_open(0, 0);
 123    if (xen_fmem == NULL) {
 124        xen_be_printf(NULL, 0, "can't open xen fmem interface\n");
 125        xc_interface_close(xen_xc);
 126        return -1;
 127    }
 128    qemu_add_vm_change_state_handler(xen_change_state_handler, NULL);
 129
 130    global_state_set_optional();
 131    savevm_skip_configuration();
 132    savevm_skip_section_footers();
 133
 134    return 0;
 135}
 136
 137static void xen_accel_class_init(ObjectClass *oc, void *data)
 138{
 139    AccelClass *ac = ACCEL_CLASS(oc);
 140    ac->name = "Xen";
 141    ac->init_machine = xen_init;
 142    ac->allowed = &xen_allowed;
 143}
 144
 145#define TYPE_XEN_ACCEL ACCEL_CLASS_NAME("xen")
 146
 147static const TypeInfo xen_accel_type = {
 148    .name = TYPE_XEN_ACCEL,
 149    .parent = TYPE_ACCEL,
 150    .class_init = xen_accel_class_init,
 151};
 152
 153static void xen_type_init(void)
 154{
 155    type_register_static(&xen_accel_type);
 156}
 157
 158type_init(xen_type_init);
 159