keir@20462: /* keir@20462: * Copyright (C) 2009 Citrix Ltd. keir@20462: * Author Vincent Hanquez keir@20462: * Author Stefano Stabellini keir@20462: * keir@20462: * This program is free software; you can redistribute it and/or modify keir@20462: * it under the terms of the GNU Lesser General Public License as published keir@20462: * by the Free Software Foundation; version 2.1 only. with the special keir@20462: * exception on linking described in file LICENSE. keir@20462: * keir@20462: * This program is distributed in the hope that it will be useful, keir@20462: * but WITHOUT ANY WARRANTY; without even the implied warranty of keir@20462: * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the keir@20462: * GNU Lesser General Public License for more details. keir@20462: */ keir@20462: keir@20513: #include "libxl_osdeps.h" keir@20513: keir@20462: #include keir@20462: #include keir@20462: #include keir@20462: #include keir@20462: #include keir@20462: #include keir@20514: #include keir@20462: #include keir@20468: #include /* for write, unlink and close */ keir@20509: #include keir@20509: #include keir@20514: #include keir@20513: keir@20462: #include "libxl.h" keir@20462: #include "libxl_utils.h" keir@20462: #include "libxl_internal.h" keir@20462: #include "flexarray.h" keir@20462: keir@20462: int libxl_ctx_init(struct libxl_ctx *ctx) keir@20462: { keir@20462: memset(ctx, 0, sizeof(struct libxl_ctx)); keir@20462: ctx->alloc_maxsize = 256; keir@20462: ctx->alloc_ptrs = calloc(ctx->alloc_maxsize, sizeof(void *)); keir@20462: if (!ctx->alloc_ptrs) keir@20462: return ERROR_NOMEM; keir@20462: keir@20462: ctx->xch = xc_interface_open(); keir@20462: ctx->xsh = xs_daemon_open(); keir@20514: keir@20779: ctx->waitpid_instead = libxl_waitpid_instead_default; keir@20462: return 0; keir@20462: } keir@20462: keir@20462: int libxl_ctx_free(struct libxl_ctx *ctx) keir@20462: { keir@20462: libxl_free_all(ctx); keir@20462: free(ctx->alloc_ptrs); keir@20462: xc_interface_close(ctx->xch); keir@20545: xs_daemon_close(ctx->xsh); keir@20462: return 0; keir@20462: } keir@20462: keir@20462: int libxl_ctx_set_log(struct libxl_ctx *ctx, libxl_log_callback log_callback, void *log_data) keir@20462: { keir@20462: ctx->log_callback = log_callback; keir@20462: ctx->log_userdata = log_data; keir@20462: return 0; keir@20462: } keir@20462: keir@20462: /******************************************************************************/ keir@20462: keir@20462: int libxl_domain_make(struct libxl_ctx *ctx, libxl_domain_create_info *info, keir@20462: uint32_t *domid) keir@20462: { keir@20462: int flags, ret, i; keir@20468: char *uuid_string; keir@20646: char *rw_paths[] = { "device", "device/suspend/event-channel" , "data"}; keir@20462: char *ro_paths[] = { "cpu", "memory", "device", "error", "drivers", keir@20646: "control", "attr", "messages" }; keir@20462: char *dom_path, *vm_path, *vss_path; keir@20462: struct xs_permissions roperm[2]; keir@20462: struct xs_permissions rwperm[1]; keir@20462: xs_transaction_t t; keir@20468: xen_domain_handle_t handle; keir@20462: keir@20468: uuid_string = libxl_uuid_to_string(ctx, info->uuid); keir@20462: if (!uuid_string) { keir@20462: XL_LOG(ctx, XL_LOG_ERROR, "missing uuid"); keir@20462: return ERROR_FAIL; keir@20462: } keir@20462: keir@20462: flags = info->hvm ? XEN_DOMCTL_CDF_hvm_guest : 0; keir@20462: flags |= info->hap ? XEN_DOMCTL_CDF_hap : 0; keir@20462: *domid = 0; keir@20462: keir@20580: /* keir@20468: * info->uuid != xen_domain_handle_t keir@20468: * See: keir@20468: * http://www.opengroup.org/dce/info/draft-leach-uuids-guids-01.txt keir@20468: * http://www.opengroup.org/onlinepubs/009629399/apdxa.htm keir@20468: * keir@20468: * A DCE 1.1 compatible source representation of UUIDs. keir@20468: * keir@20468: * struct uuid { keir@20468: * uint32_t time_low; keir@20468: * uint16_t time_mid; keir@20468: * uint16_t time_hi_and_version; keir@20468: * uint8_t clock_seq_hi_and_reserved; keir@20468: * uint8_t clock_seq_low; keir@20468: * uint8_t node[_UUID_NODE_LEN]; keir@20468: * }; keir@20468: */ keir@20580: /* Ultimately, handle is an array of 16 uint8_t, same as uuid */ keir@20580: memcpy(handle, info->uuid, sizeof(xen_domain_handle_t)); keir@20468: keir@20468: ret = xc_domain_create(ctx->xch, info->ssidref, handle, flags, domid); keir@20462: if (ret < 0) { keir@20512: XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, ret, "domain creation fail"); keir@20462: return ERROR_FAIL; keir@20462: } keir@20462: keir@20462: dom_path = libxl_xs_get_dompath(ctx, *domid); keir@20512: if (!dom_path) keir@20512: return ERROR_FAIL; keir@20512: keir@20462: vm_path = libxl_sprintf(ctx, "/vm/%s", uuid_string); keir@20462: vss_path = libxl_sprintf(ctx, "/vss/%s", uuid_string); keir@20512: if (!vm_path || !vss_path) { keir@20462: XL_LOG(ctx, XL_LOG_ERROR, "cannot allocate create paths"); keir@20462: return ERROR_FAIL; keir@20462: } keir@20462: keir@20462: roperm[0].id = 0; keir@20462: roperm[0].perms = XS_PERM_NONE; keir@20462: roperm[1].id = *domid; keir@20462: roperm[1].perms = XS_PERM_READ; keir@20462: rwperm[0].id = *domid; keir@20462: rwperm[0].perms = XS_PERM_NONE; keir@20462: keir@20462: retry_transaction: keir@20462: t = xs_transaction_start(ctx->xsh); keir@20462: xs_rm(ctx->xsh, t, dom_path); keir@20462: xs_mkdir(ctx->xsh, t, dom_path); keir@20462: xs_set_permissions(ctx->xsh, t, dom_path, roperm, ARRAY_SIZE(roperm)); keir@20462: keir@20462: xs_rm(ctx->xsh, t, vm_path); keir@20462: xs_mkdir(ctx->xsh, t, vm_path); keir@20462: xs_set_permissions(ctx->xsh, t, vm_path, roperm, ARRAY_SIZE(roperm)); keir@20462: keir@20462: xs_rm(ctx->xsh, t, vss_path); keir@20462: xs_mkdir(ctx->xsh, t, vss_path); keir@20462: xs_set_permissions(ctx->xsh, t, vss_path, rwperm, ARRAY_SIZE(rwperm)); keir@20462: keir@20462: xs_write(ctx->xsh, t, libxl_sprintf(ctx, "%s/vm", dom_path), vm_path, strlen(vm_path)); keir@20462: xs_write(ctx->xsh, t, libxl_sprintf(ctx, "%s/vss", dom_path), vss_path, strlen(vss_path)); keir@20462: xs_write(ctx->xsh, t, libxl_sprintf(ctx, "%s/name", dom_path), info->name, strlen(info->name)); keir@20462: keir@20462: for (i = 0; i < ARRAY_SIZE(rw_paths); i++) { keir@20462: char *path = libxl_sprintf(ctx, "%s/%s", dom_path, rw_paths[i]); keir@20462: xs_mkdir(ctx->xsh, t, path); keir@20462: xs_set_permissions(ctx->xsh, t, path, rwperm, ARRAY_SIZE(rwperm)); keir@20462: libxl_free(ctx, path); keir@20462: } keir@20462: for (i = 0; i < ARRAY_SIZE(ro_paths); i++) { keir@20462: char *path = libxl_sprintf(ctx, "%s/%s", dom_path, ro_paths[i]); keir@20462: xs_mkdir(ctx->xsh, t, path); keir@20462: xs_set_permissions(ctx->xsh, t, path, roperm, ARRAY_SIZE(roperm)); keir@20462: libxl_free(ctx, path); keir@20462: } keir@20462: keir@20462: xs_write(ctx->xsh, t, libxl_sprintf(ctx, "%s/uuid", vm_path), uuid_string, strlen(uuid_string)); keir@20462: xs_write(ctx->xsh, t, libxl_sprintf(ctx, "%s/name", vm_path), info->name, strlen(info->name)); keir@20462: keir@20462: libxl_xs_writev(ctx, t, dom_path, info->xsdata); keir@20462: libxl_xs_writev(ctx, t, libxl_sprintf(ctx, "%s/platform", dom_path), info->platformdata); keir@20462: keir@20462: xs_write(ctx->xsh, t, libxl_sprintf(ctx, "%s/control/platform-feature-multiprocessor-suspend", dom_path), "1", 1); keir@20462: keir@20462: if (!xs_transaction_end(ctx->xsh, t, 0)) keir@20462: if (errno == EAGAIN) keir@20462: goto retry_transaction; keir@20462: return 0; keir@20462: } keir@20462: keir@20516: int libxl_domain_build(struct libxl_ctx *ctx, libxl_domain_build_info *info, uint32_t domid, libxl_domain_build_state *state) keir@20462: { keir@20462: char **vments = NULL, **localents = NULL; keir@20578: int i; keir@20462: keir@20509: build_pre(ctx, domid, info, state); keir@20462: if (info->hvm) { keir@20509: build_hvm(ctx, domid, info, state); keir@20509: vments = libxl_calloc(ctx, 5, sizeof(char *)); keir@20516: vments[0] = "rtc/timeoffset"; keir@20516: vments[1] = (info->u.hvm.timeoffset) ? info->u.hvm.timeoffset : ""; keir@20516: vments[2] = "image/ostype"; keir@20516: vments[3] = "hvm"; keir@20462: } else { keir@20509: build_pv(ctx, domid, info, state); keir@20509: vments = libxl_calloc(ctx, 9, sizeof(char *)); keir@20578: i = 0; keir@20578: vments[i++] = "image/ostype"; keir@20578: vments[i++] = "linux"; keir@20578: vments[i++] = "image/kernel"; keir@20578: vments[i++] = (char*) info->kernel; keir@20578: if (info->u.pv.ramdisk) { keir@20578: vments[i++] = "image/ramdisk"; keir@20578: vments[i++] = (char*) info->u.pv.ramdisk; keir@20578: } keir@20578: if (info->u.pv.cmdline) { keir@20578: vments[i++] = "image/cmdline"; keir@20578: vments[i++] = (char*) info->u.pv.cmdline; keir@20578: } keir@20462: } keir@20509: build_post(ctx, domid, info, state, vments, localents); keir@20516: return 0; keir@20462: } keir@20462: keir@20462: int libxl_domain_restore(struct libxl_ctx *ctx, libxl_domain_build_info *info, keir@20565: uint32_t domid, int fd, libxl_domain_build_state *state, keir@20565: libxl_device_model_info *dm_info) keir@20462: { keir@20462: char **vments = NULL, **localents = NULL; keir@20627: int i; keir@20462: keir@20565: build_pre(ctx, domid, info, state); keir@20565: restore_common(ctx, domid, info, state, fd); keir@20462: if (info->hvm) { keir@20565: vments = libxl_calloc(ctx, 5, sizeof(char *)); keir@20516: vments[0] = "rtc/timeoffset"; keir@20516: vments[1] = (info->u.hvm.timeoffset) ? info->u.hvm.timeoffset : ""; keir@20565: vments[2] = "image/ostype"; keir@20565: vments[3] = "hvm"; keir@20462: } else { keir@20565: vments = libxl_calloc(ctx, 9, sizeof(char *)); keir@20627: i = 0; keir@20627: vments[i++] = "image/ostype"; keir@20627: vments[i++] = "linux"; keir@20627: vments[i++] = "image/kernel"; keir@20627: vments[i++] = (char*) info->kernel; keir@20627: if (info->u.pv.ramdisk) { keir@20627: vments[i++] = "image/ramdisk"; keir@20627: vments[i++] = (char*) info->u.pv.ramdisk; keir@20627: } keir@20627: if (info->u.pv.cmdline) { keir@20627: vments[i++] = "image/cmdline"; keir@20627: vments[i++] = (char*) info->u.pv.cmdline; keir@20627: } keir@20462: } keir@20565: build_post(ctx, domid, info, state, vments, localents); keir@20565: if (info->hvm) keir@20565: asprintf(&(dm_info->saved_state), "/var/lib/xen/qemu-save.%d", domid); keir@20565: else keir@20565: dm_info->saved_state = NULL; keir@20565: keir@20462: return 0; keir@20462: } keir@20462: keir@20629: int libxl_domain_resume(struct libxl_ctx *ctx, uint32_t domid) keir@20629: { keir@20629: if (is_hvm(ctx, domid)) { keir@20629: XL_LOG(ctx, XL_LOG_DEBUG, "Called domain_resume on " keir@20629: "non-cooperative hvm domain %u", domid); keir@20629: return ERROR_NI; keir@20629: } keir@20629: if (xc_domain_resume(ctx->xch, domid, 1)) { keir@20629: XL_LOG_ERRNO(ctx, XL_LOG_ERROR, keir@20629: "xc_domain_resume failed for domain %u", keir@20629: domid); keir@20629: return ERROR_FAIL; keir@20629: } keir@20629: if (!xs_resume_domain(ctx->xsh, domid)) { keir@20629: XL_LOG_ERRNO(ctx, XL_LOG_ERROR, keir@20629: "xs_resume_domain failed for domain %u", keir@20629: domid); keir@20629: return ERROR_FAIL; keir@20629: } keir@20629: return 0; keir@20629: } keir@20629: keir@20462: struct libxl_dominfo * libxl_domain_list(struct libxl_ctx *ctx, int *nb_domain) keir@20462: { keir@20462: struct libxl_dominfo *ptr; keir@20462: int index, i, ret, first_domain; keir@20462: xc_domaininfo_t info[16]; keir@20462: int size = 16; keir@20462: keir@20462: first_domain = 1; keir@20462: index = 0; keir@20516: ptr = calloc(size, sizeof(struct libxl_dominfo)); keir@20462: if (!ptr) keir@20462: return NULL; keir@20462: redo: keir@20462: ret = xc_domain_getinfolist(ctx->xch, first_domain, 16, info); keir@20462: for (i = 0; i < ret; i++) { keir@20462: if (index == size) { keir@20462: struct libxl_dominfo *ptr2; keir@20462: keir@20516: ptr2 = calloc(size * 2, sizeof(struct libxl_dominfo)); keir@20462: if (!ptr2) { keir@20516: free(ptr); keir@20462: return NULL; keir@20462: } keir@20462: memcpy(ptr2, ptr, sizeof(struct libxl_dominfo) * size); keir@20516: free(ptr); keir@20462: ptr = ptr2; keir@20462: size *= 2; keir@20462: } keir@20579: memcpy(&(ptr[index].uuid), info[i].handle, sizeof(xen_domain_handle_t)); keir@20462: ptr[index].domid = info[i].domain; keir@20462: first_domain = info[i].domain + 1; keir@20462: index++; keir@20462: } keir@20462: if (ret == 16) keir@20462: goto redo; keir@20462: *nb_domain = index; keir@20462: return ptr; keir@20462: } keir@20462: keir@20462: xc_dominfo_t * libxl_domain_infolist(struct libxl_ctx *ctx, int *nb_domain) keir@20462: { keir@20462: int index, first_domain; keir@20462: xc_dominfo_t *info; keir@20462: int size = 1024; keir@20462: keir@20462: first_domain = 0; keir@20462: index = 0; keir@20516: info = (xc_dominfo_t *) calloc(size, sizeof(xc_dominfo_t)); keir@20462: if (!info) { keir@20462: *nb_domain = 0; keir@20462: return NULL; keir@20462: } keir@20462: *nb_domain = xc_domain_getinfo(ctx->xch, first_domain, 1024, info); keir@20462: return info; keir@20462: } keir@20462: keir@20630: xc_dominfo_t *libxl_domain_info(struct libxl_ctx *ctx, uint32_t domid) keir@20630: { keir@20630: xc_dominfo_t *info; keir@20630: int rc; keir@20630: keir@20630: info = (xc_dominfo_t *) calloc(1, sizeof(xc_dominfo_t)); keir@20630: if (!info) { keir@20630: return NULL; keir@20630: } keir@20630: rc = xc_domain_getinfo(ctx->xch, domid, 1, info); keir@20630: if (rc != 1) { keir@20630: free(info); keir@20630: XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "Failed to get info for domain %u", keir@20630: domid); keir@20630: return NULL; keir@20630: } keir@20630: if (info->domid != domid) { keir@20630: free(info); keir@20630: XL_LOG(ctx, XL_LOG_ERROR, "Failed to get info for domain %u" keir@20630: ", seems to not exist anymore", domid); keir@20630: return NULL; keir@20630: } keir@20630: keir@20630: return info; keir@20630: } keir@20779: keir@20462: int libxl_domain_suspend(struct libxl_ctx *ctx, libxl_domain_suspend_info *info, keir@20462: uint32_t domid, int fd) keir@20462: { keir@20565: int hvm = is_hvm(ctx, domid); keir@20565: int live = info != NULL && info->flags & XL_SUSPEND_LIVE; keir@20565: int debug = info != NULL && info->flags & XL_SUSPEND_LIVE; keir@20462: keir@20462: core_suspend(ctx, domid, fd, hvm, live, debug); keir@20565: if (hvm) keir@20779: save_device_model(ctx, domid, fd); keir@20462: return 0; keir@20462: } keir@20462: keir@20462: int libxl_domain_pause(struct libxl_ctx *ctx, uint32_t domid) keir@20462: { keir@20462: xc_domain_pause(ctx->xch, domid); keir@20462: return 0; keir@20462: } keir@20462: keir@20462: int libxl_domain_unpause(struct libxl_ctx *ctx, uint32_t domid) keir@20462: { keir@20779: char *path; keir@20565: char *state; keir@20565: keir@20565: if (is_hvm(ctx, domid)) { keir@20779: path = libxl_sprintf(ctx, "/local/domain/0/device-model/%d/state", domid); keir@20565: state = libxl_xs_read(ctx, XBT_NULL, path); keir@20565: if (state != NULL && !strcmp(state, "paused")) { keir@20565: libxl_xs_write(ctx, XBT_NULL, libxl_sprintf(ctx, "/local/domain/0/device-model/%d/command", domid), "continue", strlen("continue")); keir@20565: libxl_wait_for_device_model(ctx, domid, "running", NULL, NULL); keir@20565: } keir@20565: } keir@20462: xc_domain_unpause(ctx->xch, domid); keir@20565: keir@20462: return 0; keir@20462: } keir@20462: keir@20462: static char *req_table[] = { keir@20462: [0] = "poweroff", keir@20462: [1] = "reboot", keir@20462: [2] = "suspend", keir@20462: [3] = "crash", keir@20462: [4] = "halt", keir@20462: }; keir@20462: keir@20462: int libxl_domain_shutdown(struct libxl_ctx *ctx, uint32_t domid, int req) keir@20462: { keir@20462: char *shutdown_path; keir@20462: char *dom_path; keir@20462: keir@20462: if (req > ARRAY_SIZE(req_table)) keir@20462: return ERROR_INVAL; keir@20462: keir@20462: dom_path = libxl_xs_get_dompath(ctx, domid); keir@20512: if (!dom_path) keir@20512: return ERROR_FAIL; keir@20512: keir@20462: shutdown_path = libxl_sprintf(ctx, "%s/control/shutdown", dom_path); keir@20462: keir@20462: xs_write(ctx->xsh, XBT_NULL, shutdown_path, req_table[req], strlen(req_table[req])); keir@20462: if (/* hvm */ 0) { keir@20462: unsigned long acpi_s_state = 0; keir@20462: unsigned long pvdriver = 0; keir@20462: xc_get_hvm_param(ctx->xch, domid, HVM_PARAM_ACPI_S_STATE, &acpi_s_state); keir@20462: xc_get_hvm_param(ctx->xch, domid, HVM_PARAM_CALLBACK_IRQ, &pvdriver); keir@20462: if (!pvdriver && acpi_s_state != 0) keir@20462: xc_domain_shutdown(ctx->xch, domid, req); keir@20462: } keir@20462: return 0; keir@20462: } keir@20462: keir@20637: int libxl_get_wait_fd(struct libxl_ctx *ctx, int *fd) keir@20545: { keir@20545: *fd = xs_fileno(ctx->xsh); keir@20545: return 0; keir@20545: } keir@20545: keir@20637: int libxl_wait_for_domain_death(struct libxl_ctx *ctx, uint32_t domid, libxl_waiter *waiter) keir@20637: { keir@20637: waiter->path = strdup("@releaseDomain"); keir@20637: asprintf(&(waiter->token), "%d", DOMAIN_DEATH); keir@20637: if (!xs_watch(ctx->xsh, waiter->path, waiter->token)) keir@20637: return -1; keir@20637: return 0; keir@20637: } keir@20637: keir@20637: int libxl_wait_for_disk_ejects(struct libxl_ctx *ctx, uint32_t guest_domid, libxl_device_disk *disks, int num_disks, libxl_waiter *waiter) keir@20637: { keir@20637: int i; keir@20637: uint32_t domid = libxl_get_stubdom_id(ctx, guest_domid); keir@20637: keir@20637: if (!domid) keir@20637: domid = guest_domid; keir@20637: keir@20637: for (i = 0; i < num_disks; i++) { keir@20637: asprintf(&(waiter[i].path), "%s/device/vbd/%d/eject", libxl_xs_get_dompath(ctx, domid), device_disk_dev_number(disks[i].virtpath)); keir@20637: asprintf(&(waiter[i].token), "%d", DISK_EJECT); keir@20637: xs_watch(ctx->xsh, waiter->path, waiter->token); keir@20637: } keir@20637: return 0; keir@20637: } keir@20637: keir@20637: int libxl_get_event(struct libxl_ctx *ctx, libxl_event *event) keir@20545: { keir@20545: unsigned int num; keir@20637: char **events = xs_read_watch(ctx->xsh, &num); keir@20637: if (num != 2) { keir@20637: free(events); keir@20637: return -1; keir@20637: } keir@20637: event->path = strdup(events[XS_WATCH_PATH]); keir@20637: event->token = strdup(events[XS_WATCH_TOKEN]); keir@20637: event->type = atoi(event->token); keir@20637: free(events); keir@20637: return 0; keir@20637: } keir@20637: keir@20637: int libxl_stop_waiting(struct libxl_ctx *ctx, libxl_waiter *waiter) keir@20637: { keir@20637: if (!xs_unwatch(ctx->xsh, waiter->path, waiter->token)) keir@20637: return -1; keir@20637: else keir@20637: return 0; keir@20637: } keir@20637: keir@20637: int libxl_free_event(libxl_event *event) keir@20637: { keir@20637: free(event->path); keir@20637: free(event->token); keir@20637: return 0; keir@20637: } keir@20637: keir@20637: int libxl_free_waiter(libxl_waiter *waiter) keir@20637: { keir@20637: free(waiter->path); keir@20637: free(waiter->token); keir@20637: return 0; keir@20637: } keir@20637: keir@20637: int libxl_event_get_domain_death_info(struct libxl_ctx *ctx, uint32_t domid, libxl_event *event, xc_dominfo_t *info) keir@20637: { keir@20545: int nb_domain, i, rc = 0; keir@20545: xc_dominfo_t *list = NULL; keir@20545: keir@20637: if (event && event->type == DOMAIN_DEATH) { keir@20545: list = libxl_domain_infolist(ctx, &nb_domain); keir@20545: for (i = 0; i < nb_domain; i++) { keir@20545: if (domid == list[i].domid) { keir@20545: if (list[i].running || (!list[i].shutdown && !list[i].crashed && !list[i].dying)) keir@20545: goto out; keir@20545: *info = list[i]; keir@20545: rc = 1; keir@20545: goto out; keir@20545: } keir@20545: } keir@20545: memset(info, 0x00, sizeof(xc_dominfo_t)); keir@20545: rc = 1; keir@20545: goto out; keir@20545: } keir@20545: out: keir@20545: free(list); keir@20545: return rc; keir@20545: } keir@20545: keir@20637: int libxl_event_get_disk_eject_info(struct libxl_ctx *ctx, uint32_t domid, libxl_event *event, libxl_device_disk *disk) keir@20637: { keir@20637: if (event && event->type == DISK_EJECT) { keir@20637: char *path; keir@20637: char *backend; keir@20637: char *value = libxl_xs_read(ctx, XBT_NULL, event->path); keir@20637: keir@20637: if (!value || strcmp(value, "eject")) keir@20637: return 0; keir@20637: keir@20637: path = strdup(event->path); keir@20637: path[strlen(path) - 6] = '\0'; keir@20637: backend = libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/backend", path)); keir@20637: keir@20637: disk->backend_domid = 0; keir@20637: disk->domid = domid; keir@20637: disk->physpath = NULL; keir@20637: disk->phystype = 0; keir@20637: /* this value is returned to the user: do not free right away */ keir@20637: disk->virtpath = libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/dev", backend)); keir@20637: disk->unpluggable = 1; keir@20637: disk->readwrite = 0; keir@20637: disk->is_cdrom = 1; keir@20637: keir@20637: free(path); keir@20637: return 1; keir@20637: } keir@20637: return 0; keir@20637: } keir@20637: keir@20462: static int libxl_destroy_device_model(struct libxl_ctx *ctx, uint32_t domid) keir@20462: { keir@20462: char *pid; keir@20462: int ret; keir@20462: keir@20462: pid = libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "/local/domain/%d/image/device-model-pid", domid)); keir@20462: if (!pid) { keir@20542: int stubdomid = libxl_get_stubdom_id(ctx, domid); keir@20542: if (!stubdomid) { keir@20542: XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "Couldn't find device model's pid"); keir@20542: return -1; keir@20542: } keir@20542: XL_LOG(ctx, XL_LOG_ERROR, "Device model is a stubdom, domid=%d\n", stubdomid); keir@20542: return libxl_domain_destroy(ctx, stubdomid, 0); keir@20462: } keir@20462: xs_rm(ctx->xsh, XBT_NULL, libxl_sprintf(ctx, "/local/domain/0/device-model/%d", domid)); keir@20462: keir@20462: ret = kill(atoi(pid), SIGHUP); keir@20462: if (ret < 0 && errno == ESRCH) { keir@20512: XL_LOG(ctx, XL_LOG_DEBUG, "Device Model already exited"); keir@20462: ret = 0; keir@20462: } else if (ret == 0) { keir@20512: XL_LOG(ctx, XL_LOG_DEBUG, "Device Model signaled"); keir@20462: ret = 0; keir@20462: } else { keir@20512: XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "failed to kill Device Model [%d]", keir@20512: atoi(pid)); keir@20462: } keir@20462: return ret; keir@20462: } keir@20462: keir@20462: int libxl_domain_destroy(struct libxl_ctx *ctx, uint32_t domid, int force) keir@20462: { keir@20581: char *dom_path, *uuid_str; keir@20779: char *vm_path, *vss_path, *xapi_path; keir@20468: xen_uuid_t *uuid; keir@20628: int rc, dm_present; keir@20628: keir@20628: if (is_hvm(ctx, domid)) { keir@20628: dm_present = 1; keir@20628: } else { keir@20628: char *pid; keir@20628: pid = libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "/local/domain/%d/image/device-model-pid", domid)); keir@20628: dm_present = (pid != NULL); keir@20628: libxl_free(ctx, pid); keir@20628: } keir@20462: keir@20462: dom_path = libxl_xs_get_dompath(ctx, domid); keir@20512: if (!dom_path) keir@20462: return -1; keir@20512: keir@20462: if (libxl_domid_to_uuid(ctx, &uuid, domid) < 0) { keir@20512: XL_LOG(ctx, XL_LOG_ERROR, "failed ot get uuid for %d", domid); keir@20462: return -1; keir@20462: } keir@20482: if (libxl_device_pci_shutdown(ctx, domid) < 0) keir@20512: XL_LOG(ctx, XL_LOG_ERROR, "pci shutdown failed for domid %d", domid); keir@20628: if (dm_present) { keir@20628: xs_write(ctx->xsh, XBT_NULL, keir@20628: libxl_sprintf(ctx, "/local/domain/0/device-model/%d/command", domid), keir@20628: "shutdown", strlen("shutdown")); keir@20628: } keir@20512: rc = xc_domain_pause(ctx->xch, domid); keir@20512: if (rc < 0) { keir@20512: XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "xc_domain_pause failed for %d", domid); keir@20462: return -1; keir@20462: } keir@20628: if (dm_present) { keir@20628: if (libxl_destroy_device_model(ctx, domid) < 0) keir@20628: XL_LOG(ctx, XL_LOG_ERROR, "libxl_destroy_device_model failed for %d", domid); keir@20628: } keir@20462: if (libxl_devices_destroy(ctx, domid, force) < 0) keir@20512: XL_LOG(ctx, XL_LOG_ERROR, "libxl_destroy_devices failed for %d", domid); keir@20462: if (!xs_rm(ctx->xsh, XBT_NULL, dom_path)) keir@20512: XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "xs_rm failed for %s", dom_path); keir@20779: keir@20581: uuid_str = libxl_uuid_to_string(ctx, uuid); keir@20779: keir@20779: vm_path = libxl_sprintf(ctx, "/vm/%s", uuid_str); keir@20462: if (!xs_rm(ctx->xsh, XBT_NULL, vm_path)) keir@20512: XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "xs_rm failed for %s", vm_path); keir@20779: keir@20779: vss_path = libxl_sprintf(ctx, "/vss/%s", uuid_str); keir@20581: if (!xs_rm(ctx->xsh, XBT_NULL, vss_path)) keir@20581: XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "xs_rm failed for %s", vss_path); keir@20779: keir@20779: xapi_path = libxl_sprintf(ctx, "/xapi/%u", domid); keir@20581: if (!xs_rm(ctx->xsh, XBT_NULL, xapi_path)) keir@20581: XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "xs_rm failed for %s", xapi_path); keir@20779: keir@20545: rc = xc_domain_destroy(ctx->xch, domid); keir@20545: if (rc < 0) { keir@20545: XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "xc_domain_destroy failed for %d", domid); keir@20545: return -1; keir@20545: } keir@20462: return 0; keir@20462: } keir@20462: keir@20564: int libxl_console_attach(struct libxl_ctx *ctx, uint32_t domid, int cons_num) keir@20564: { keir@20564: struct stat st; keir@20564: const char *XENCONSOLE = "/usr/lib/xen/bin/xenconsole"; keir@20564: char *cmd; keir@20564: keir@20564: if (stat(XENCONSOLE, &st) != 0) { keir@20564: XL_LOG(ctx, XL_LOG_ERROR, "could not access %s", XENCONSOLE); keir@20564: return ERROR_FAIL; keir@20564: } keir@20564: keir@20564: cmd = libxl_sprintf(ctx, "%s %d --num %d", XENCONSOLE, domid, cons_num); keir@20564: return (system(cmd) != 0) ? ERROR_FAIL : 0; keir@20564: } keir@20564: keir@20462: static char ** libxl_build_device_model_args(struct libxl_ctx *ctx, keir@20462: libxl_device_model_info *info, keir@20462: libxl_device_nic *vifs, keir@20462: int num_vifs) keir@20462: { keir@20462: int num = 0, i; keir@20462: flexarray_t *dm_args; keir@20462: dm_args = flexarray_make(16, 1); keir@20462: if (!dm_args) keir@20462: return NULL; keir@20462: keir@20516: flexarray_set(dm_args, num++, "qemu-dm"); keir@20516: flexarray_set(dm_args, num++, "-d"); keir@20462: keir@20462: flexarray_set(dm_args, num++, libxl_sprintf(ctx, "%d", info->domid)); keir@20462: keir@20462: if (info->dom_name) { keir@20516: flexarray_set(dm_args, num++, "-domain-name"); keir@20516: flexarray_set(dm_args, num++, info->dom_name); keir@20462: } keir@20462: if (info->vnc || info->vncdisplay || info->vnclisten || info->vncunused) { keir@20516: flexarray_set(dm_args, num++, "-vnc"); keir@20462: if (info->vncdisplay) { keir@20462: if (info->vnclisten && strchr(info->vnclisten, ':') == NULL) { keir@20462: flexarray_set(dm_args, num++, libxl_sprintf(ctx, "%s:%d", info->vnclisten, info->vncdisplay)); keir@20462: } else { keir@20462: flexarray_set(dm_args, num++, libxl_sprintf(ctx, "127.0.0.1:%d", info->vncdisplay)); keir@20462: } keir@20462: } else if (info->vnclisten) { keir@20462: if (strchr(info->vnclisten, ':') != NULL) { keir@20516: flexarray_set(dm_args, num++, info->vnclisten); keir@20462: } else { keir@20462: flexarray_set(dm_args, num++, libxl_sprintf(ctx, "%s:0", info->vnclisten)); keir@20462: } keir@20462: } else { keir@20516: flexarray_set(dm_args, num++, "127.0.0.1:0"); keir@20462: } keir@20462: if (info->vncunused) { keir@20516: flexarray_set(dm_args, num++, "-vncunused"); keir@20462: } keir@20462: } keir@20462: if (info->sdl || info->opengl) { keir@20516: flexarray_set(dm_args, num++, "-sdl"); keir@20462: if (info->opengl) { keir@20516: flexarray_set(dm_args, num++, "-disable-opengl"); keir@20462: } keir@20462: } keir@20462: if (info->keymap) { keir@20516: flexarray_set(dm_args, num++, "-k"); keir@20516: flexarray_set(dm_args, num++, info->keymap); keir@20462: } keir@20462: if (info->nographic && (!info->sdl && !info->vnc)) { keir@20516: flexarray_set(dm_args, num++, "-nographic"); keir@20462: } keir@20462: if (info->serial) { keir@20516: flexarray_set(dm_args, num++, "-serial"); keir@20516: flexarray_set(dm_args, num++, info->serial); keir@20462: } keir@20509: if (info->type == XENFV) { keir@20509: if (info->videoram) { keir@20516: flexarray_set(dm_args, num++, "-videoram"); keir@20509: flexarray_set(dm_args, num++, libxl_sprintf(ctx, "%d", info->videoram)); keir@20509: } keir@20509: if (info->stdvga) { keir@20516: flexarray_set(dm_args, num++, "-std-vga"); keir@20509: } keir@20509: keir@20509: if (info->boot) { keir@20516: flexarray_set(dm_args, num++, "-boot"); keir@20516: flexarray_set(dm_args, num++, info->boot); keir@20509: } keir@20509: if (info->usb) { keir@20516: flexarray_set(dm_args, num++, "-usb"); keir@20509: if (info->usbdevice) { keir@20516: flexarray_set(dm_args, num++, "-usbdevice"); keir@20516: flexarray_set(dm_args, num++, info->usbdevice); keir@20509: } keir@20509: } keir@20509: if (info->apic) { keir@20516: flexarray_set(dm_args, num++, "-acpi"); keir@20509: } keir@20509: for (i = 0; i < num_vifs; i++) { keir@20509: if (vifs[i].nictype == NICTYPE_IOEMU) { keir@20516: flexarray_set(dm_args, num++, "-net"); keir@20509: flexarray_set(dm_args, num++, libxl_sprintf(ctx, "nic,vlan=%d,macaddr=%s,model=%s", keir@20509: vifs[i].devid, vifs[i].smac, vifs[i].model)); keir@20516: flexarray_set(dm_args, num++, "-net"); keir@20509: flexarray_set(dm_args, num++, libxl_sprintf(ctx, "tap,vlan=%d,ifname=%s,bridge=%s", keir@20509: vifs[i].devid, vifs[i].ifname, vifs[i].bridge)); keir@20509: } keir@20462: } keir@20462: } keir@20565: if (info->saved_state) { keir@20565: flexarray_set(dm_args, num++, "-loadvm"); keir@20565: flexarray_set(dm_args, num++, info->saved_state); keir@20565: } keir@20509: for (i = 0; info->extra && info->extra[i] != NULL; i++) keir@20509: flexarray_set(dm_args, num++, info->extra[i]); keir@20516: flexarray_set(dm_args, num++, "-M"); keir@20509: if (info->type == XENPV) keir@20516: flexarray_set(dm_args, num++, "xenpv"); keir@20509: else keir@20516: flexarray_set(dm_args, num++, "xenfv"); keir@20462: flexarray_set(dm_args, num++, NULL); keir@20462: keir@20462: return (char **) flexarray_contents(dm_args); keir@20462: } keir@20462: keir@20514: void dm_xenstore_record_pid(struct libxl_ctx *ctx, void *for_spawn, keir@20514: pid_t innerchild) { keir@20514: struct libxl_device_model_starting *starting = for_spawn; keir@20514: struct libxl_ctx clone; keir@20514: char *kvs[3]; keir@20624: int rc, cloned; keir@20514: keir@20624: if (libxl_clone_context_xs(ctx, &clone)) { keir@20624: XL_LOG(ctx, XL_LOG_ERROR, "Out of memory when cloning context"); keir@20624: /* Throw a prayer fallback */ keir@20624: clone = *ctx; keir@20624: clone.xsh = xs_daemon_open(); keir@20624: cloned = 0; keir@20624: } else { keir@20624: cloned = 1; keir@20624: } keir@20514: /* we mustn't use the parent's handle in the child */ keir@20514: keir@20514: kvs[0] = "image/device-model-pid"; keir@20610: kvs[1] = libxl_sprintf(&clone, "%d", innerchild); keir@20514: kvs[2] = NULL; keir@20610: rc = libxl_xs_writev(&clone, XBT_NULL, starting->dom_path, kvs); keir@20610: if (rc) XL_LOG_ERRNO(&clone, XL_LOG_ERROR, keir@20514: "Couldn't record device model pid %ld at %s/%s", keir@20514: (unsigned long)innerchild, starting->dom_path, kvs); keir@20624: if (cloned) { keir@20624: libxl_discard_cloned_context_xs(&clone); keir@20624: } else { keir@20624: xs_daemon_close(clone.xsh); keir@20624: } keir@20514: } keir@20514: keir@20542: static int libxl_vfb_and_vkb_from_device_model_info(struct libxl_ctx *ctx, keir@20542: libxl_device_model_info *info, keir@20542: libxl_device_vfb *vfb, keir@20542: libxl_device_vkb *vkb) keir@20542: { keir@20542: memset(vfb, 0x00, sizeof(libxl_device_vfb)); keir@20542: memset(vkb, 0x00, sizeof(libxl_device_vkb)); keir@20542: keir@20542: vfb->backend_domid = 0; keir@20542: vfb->devid = 0; keir@20542: vfb->vnc = info->vnc; keir@20542: vfb->vnclisten = info->vnclisten; keir@20542: vfb->vncdisplay = info->vncdisplay; keir@20542: vfb->vncunused = info->vncunused; keir@20542: vfb->keymap = info->keymap; keir@20542: vfb->sdl = info->sdl; keir@20542: vfb->opengl = info->opengl; keir@20542: keir@20542: vkb->backend_domid = 0; keir@20542: vkb->devid = 0; keir@20542: return 0; keir@20542: } keir@20542: keir@20542: static int libxl_write_dmargs(struct libxl_ctx *ctx, int domid, int guest_domid, char **args) keir@20542: { keir@20542: int i; keir@20542: char *vm_path; keir@20542: char *dmargs, *path; keir@20542: int dmargs_size; keir@20542: struct xs_permissions roperm[2]; keir@20542: xs_transaction_t t; keir@20542: keir@20542: roperm[0].id = 0; keir@20542: roperm[0].perms = XS_PERM_NONE; keir@20542: roperm[1].id = domid; keir@20542: roperm[1].perms = XS_PERM_READ; keir@20542: keir@20542: vm_path = libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "/local/domain/%d/vm", guest_domid)); keir@20542: keir@20542: i = 0; keir@20542: dmargs_size = 0; keir@20542: while (args[i] != NULL) { keir@20542: dmargs_size = dmargs_size + strlen(args[i]) + 1; keir@20542: i++; keir@20542: } keir@20542: dmargs_size++; keir@20542: dmargs = (char *) malloc(dmargs_size); keir@20542: i = 1; keir@20542: dmargs[0] = '\0'; keir@20542: while (args[i] != NULL) { keir@20542: if (strcmp(args[i], "-sdl") && strcmp(args[i], "-M") && strcmp(args[i], "xenfv")) { keir@20542: strcat(dmargs, " "); keir@20542: strcat(dmargs, args[i]); keir@20542: } keir@20542: i++; keir@20542: } keir@20542: path = libxl_sprintf(ctx, "%s/image/dmargs", vm_path); keir@20542: keir@20542: retry_transaction: keir@20542: t = xs_transaction_start(ctx->xsh); keir@20542: xs_write(ctx->xsh, t, path, dmargs, strlen(dmargs)); keir@20542: xs_set_permissions(ctx->xsh, t, path, roperm, ARRAY_SIZE(roperm)); keir@20542: xs_set_permissions(ctx->xsh, t, libxl_sprintf(ctx, "%s/rtc/timeoffset", vm_path), roperm, ARRAY_SIZE(roperm)); keir@20542: if (!xs_transaction_end(ctx->xsh, t, 0)) keir@20542: if (errno == EAGAIN) keir@20542: goto retry_transaction; keir@20542: free(dmargs); keir@20542: return 0; keir@20542: } keir@20542: keir@20542: static int libxl_create_stubdom(struct libxl_ctx *ctx, keir@20542: libxl_device_model_info *info, keir@20542: libxl_device_disk *disks, int num_disks, keir@20542: libxl_device_nic *vifs, int num_vifs, keir@20542: libxl_device_vfb *vfb, keir@20542: libxl_device_vkb *vkb, keir@20542: libxl_device_model_starting **starting_r) keir@20542: { keir@20570: int i, num_console = 1; keir@20570: libxl_device_console *console; keir@20542: libxl_domain_create_info c_info; keir@20542: libxl_domain_build_info b_info; keir@20542: libxl_domain_build_state state; keir@20542: uint32_t domid; keir@20542: char **args; keir@20542: xen_uuid_t uuid[16]; keir@20542: struct xs_permissions perm[2]; keir@20542: xs_transaction_t t; keir@20594: libxl_device_model_starting *dm_starting = 0; keir@20542: keir@20542: args = libxl_build_device_model_args(ctx, info, vifs, num_vifs); keir@20542: if (!args) keir@20542: return ERROR_FAIL; keir@20542: keir@20542: memset(&c_info, 0x00, sizeof(libxl_domain_create_info)); keir@20542: c_info.hvm = 0; keir@20542: c_info.name = libxl_sprintf(ctx, "%s-dm", libxl_domid_to_name(ctx, info->domid)); keir@20542: xen_uuid_generate(uuid); keir@20542: c_info.uuid = uuid; keir@20542: keir@20542: memset(&b_info, 0x00, sizeof(libxl_domain_build_info)); keir@20542: b_info.max_vcpus = 1; keir@20542: b_info.max_memkb = 32 * 1024; keir@20647: b_info.target_memkb = b_info.max_memkb; keir@20542: b_info.kernel = "/usr/lib/xen/boot/ioemu-stubdom.gz"; keir@20542: b_info.u.pv.cmdline = libxl_sprintf(ctx, " -d %d", info->domid); keir@20542: b_info.u.pv.ramdisk = ""; keir@20542: b_info.u.pv.features = ""; keir@20542: b_info.hvm = 0; keir@20542: keir@20542: libxl_domain_make(ctx, &c_info, &domid); keir@20542: libxl_domain_build(ctx, &b_info, domid, &state); keir@20542: keir@20542: libxl_write_dmargs(ctx, domid, info->domid, args); keir@20542: libxl_xs_write(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/image/device-model-domid", libxl_xs_get_dompath(ctx, info->domid)), "%d", domid); keir@20542: libxl_xs_write(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/target", libxl_xs_get_dompath(ctx, domid)), "%d", info->domid); keir@20542: xc_domain_set_target(ctx->xch, domid, info->domid); keir@20542: xs_set_target(ctx->xsh, domid, info->domid); keir@20542: keir@20542: perm[0].id = domid; keir@20542: perm[0].perms = XS_PERM_NONE; keir@20542: perm[1].id = info->domid; keir@20542: perm[1].perms = XS_PERM_READ; keir@20542: retry_transaction: keir@20542: t = xs_transaction_start(ctx->xsh); keir@20542: xs_mkdir(ctx->xsh, t, libxl_sprintf(ctx, "/local/domain/0/device-model/%d", info->domid)); keir@20542: xs_set_permissions(ctx->xsh, t, libxl_sprintf(ctx, "/local/domain/0/device-model/%d", info->domid), perm, ARRAY_SIZE(perm)); keir@20635: xs_mkdir(ctx->xsh, t, libxl_sprintf(ctx, "/local/domain/%d/device/vfs", domid)); keir@20635: xs_set_permissions(ctx->xsh, t, libxl_sprintf(ctx, "/local/domain/%d/device/vfs",domid), perm, ARRAY_SIZE(perm)); keir@20542: if (!xs_transaction_end(ctx->xsh, t, 0)) keir@20542: if (errno == EAGAIN) keir@20542: goto retry_transaction; keir@20542: keir@20542: for (i = 0; i < num_disks; i++) { keir@20542: libxl_device_disk disk = disks[i]; keir@20542: disk_info_domid_fixup(&disk, domid); keir@20542: libxl_device_disk_add(ctx, domid, &disk); keir@20542: } keir@20542: for (i = 0; i < num_vifs; i++) { keir@20542: libxl_device_nic nic = vifs[i]; keir@20542: nic_info_domid_fixup(&nic, domid); keir@20542: libxl_device_nic_add(ctx, domid, &nic); keir@20542: } keir@20542: vfb_info_domid_fixup(vfb, domid); keir@20542: libxl_device_vfb_add(ctx, domid, vfb); keir@20542: vkb_info_domid_fixup(vkb, domid); keir@20542: libxl_device_vkb_add(ctx, domid, vkb); keir@20542: keir@20570: if (info->serial) keir@20570: num_console++; keir@20570: console = libxl_calloc(ctx, num_console, sizeof(libxl_device_console)); keir@20570: for (i = 0; i < num_console; i++) { keir@20570: if (!i) keir@20570: init_console_info(&console[i], i, &state); keir@20570: else keir@20570: init_console_info(&console[i], i, NULL); keir@20570: console_info_domid_fixup(&console[i], domid); keir@20570: console[i].constype = CONSTYPE_IOEMU; keir@20570: libxl_device_console_add(ctx, domid, &console[i]); keir@20570: } keir@20594: if (libxl_create_xenpv_qemu(ctx, vfb, num_console, console, &dm_starting) < 0) { keir@20594: free(args); keir@20594: return -1; keir@20594: } keir@20594: if (libxl_confirm_device_model_startup(ctx, dm_starting) < 0) { keir@20594: free(args); keir@20594: return -1; keir@20594: } keir@20542: keir@20542: libxl_domain_unpause(ctx, domid); keir@20542: keir@20594: if (starting_r) { keir@20594: *starting_r = libxl_calloc(ctx, sizeof(libxl_device_model_starting), 1); keir@20598: (*starting_r)->domid = info->domid; keir@20594: (*starting_r)->dom_path = libxl_xs_get_dompath(ctx, info->domid); keir@20594: (*starting_r)->for_spawn = NULL; keir@20594: } keir@20594: keir@20542: free(args); keir@20542: return 0; keir@20542: } keir@20542: keir@20462: int libxl_create_device_model(struct libxl_ctx *ctx, keir@20462: libxl_device_model_info *info, keir@20542: libxl_device_disk *disks, int num_disks, keir@20514: libxl_device_nic *vifs, int num_vifs, keir@20514: libxl_device_model_starting **starting_r) keir@20462: { keir@20546: char *path, *logfile; keir@20514: int logfile_w, null; keir@20546: int rc; keir@20462: char **args; keir@20594: struct libxl_device_model_starting buf_starting, *p; keir@20514: keir@20542: if (strstr(info->device_model, "stubdom-dm")) { keir@20542: libxl_device_vfb vfb; keir@20542: libxl_device_vkb vkb; keir@20542: keir@20542: libxl_vfb_and_vkb_from_device_model_info(ctx, info, &vfb, &vkb); keir@20542: return libxl_create_stubdom(ctx, info, disks, num_disks, vifs, num_vifs, &vfb, &vkb, starting_r); keir@20542: } keir@20542: keir@20462: args = libxl_build_device_model_args(ctx, info, vifs, num_vifs); keir@20462: if (!args) keir@20462: return ERROR_FAIL; keir@20462: keir@20462: path = libxl_sprintf(ctx, "/local/domain/0/device-model/%d", info->domid); keir@20462: xs_mkdir(ctx->xsh, XBT_NULL, path); keir@20462: keir@20546: libxl_create_logfile(ctx, libxl_sprintf(ctx, "qemu-dm-%s", info->dom_name), &logfile); keir@20467: logfile_w = open(logfile, O_WRONLY|O_CREAT, 0644); keir@20546: free(logfile); keir@20462: null = open("/dev/null", O_RDONLY); keir@20514: keir@20514: if (starting_r) { keir@20516: rc = ERROR_NOMEM; keir@20594: *starting_r = libxl_calloc(ctx, sizeof(libxl_device_model_starting), 1); keir@20516: if (!*starting_r) goto xit; keir@20594: p = *starting_r; keir@20611: p->for_spawn = libxl_calloc(ctx, sizeof(struct libxl_spawn_starting), 1); keir@20594: } else { keir@20594: p = &buf_starting; keir@20594: p->for_spawn = NULL; keir@20594: } keir@20514: keir@20594: p->domid = info->domid; keir@20594: p->dom_path = libxl_xs_get_dompath(ctx, info->domid); keir@20594: if (!p->dom_path) { libxl_free(ctx, p); return ERROR_FAIL; } keir@20594: keir@20594: rc = libxl_spawn_spawn(ctx, p, "device model", dm_xenstore_record_pid); keir@20514: if (rc < 0) goto xit; keir@20514: if (!rc) { /* inner child */ keir@20514: libxl_exec(ctx, null, logfile_w, logfile_w, keir@20514: info->device_model, args); keir@20514: } keir@20514: keir@20514: rc = 0; keir@20514: xit: keir@20516: free(args); keir@20462: close(null); keir@20462: close(logfile_w); keir@20462: keir@20514: return rc; keir@20514: } keir@20514: keir@20514: int libxl_detach_device_model(struct libxl_ctx *ctx, keir@20779: libxl_device_model_starting *starting) keir@20779: { keir@20514: int rc; keir@20594: rc = libxl_spawn_detach(ctx, starting->for_spawn); keir@20594: if (starting->for_spawn) libxl_free(ctx, starting->for_spawn); keir@20514: libxl_free(ctx, starting); keir@20514: return rc; keir@20514: } keir@20462: keir@20514: keir@20514: int libxl_confirm_device_model_startup(struct libxl_ctx *ctx, keir@20779: libxl_device_model_starting *starting) keir@20779: { keir@20514: int problem = libxl_wait_for_device_model(ctx, starting->domid, "running", keir@20514: libxl_spawn_check, keir@20594: starting->for_spawn); keir@20514: int detach = libxl_detach_device_model(ctx, starting); keir@20514: return problem ? problem : detach; keir@20542: return 0; keir@20462: } keir@20462: keir@20514: keir@20462: /******************************************************************************/ keir@20566: keir@20566: static int is_blktap2_supported(void) keir@20566: { keir@20566: char buf[1024]; keir@20566: FILE *f = fopen("/proc/devices", "r"); keir@20566: keir@20566: keir@20566: while (fgets(buf, sizeof(buf), f) != NULL) { keir@20566: if (strstr(buf, "blktap2")) { keir@20566: fclose(f); keir@20566: return 1; keir@20566: } keir@20566: } keir@20566: fclose(f); keir@20566: return 0; keir@20566: } keir@20566: keir@20566: static char *get_blktap2_device(struct libxl_ctx *ctx, char *name, char *type) keir@20566: { keir@20566: char buf[1024]; keir@20566: char *p; keir@20566: int devnum; keir@20566: FILE *f = fopen("/sys/class/blktap2/devices", "r"); keir@20566: keir@20566: keir@20566: while (!feof(f)) { keir@20566: fscanf(f, "%d %s", &devnum, buf); keir@20566: p = strchr(buf, ':'); keir@20571: if (p == NULL) keir@20571: continue; keir@20566: p++; keir@20566: if (!strcmp(p, name) && !strncmp(buf, type, 3)) { keir@20566: fclose(f); keir@20566: return libxl_sprintf(ctx, "/dev/xen/blktap-2/tapdev%d", devnum); keir@20566: } keir@20566: } keir@20566: fclose(f); keir@20566: return NULL; keir@20566: } keir@20566: keir@20462: int libxl_device_disk_add(struct libxl_ctx *ctx, uint32_t domid, libxl_device_disk *disk) keir@20462: { keir@20462: flexarray_t *front; keir@20462: flexarray_t *back; keir@20462: char *backend_type; keir@20462: unsigned int boffset = 0; keir@20462: unsigned int foffset = 0; keir@20462: int devid; keir@20462: libxl_device device; keir@20566: int major, minor; keir@20462: keir@20462: front = flexarray_make(16, 1); keir@20462: if (!front) keir@20462: return ERROR_NOMEM; keir@20462: back = flexarray_make(16, 1); keir@20462: if (!back) /* leaks front if error */ keir@20462: return ERROR_NOMEM; keir@20462: keir@20462: backend_type = device_disk_backend_type_of_phystype(disk->phystype); keir@20462: devid = device_disk_dev_number(disk->virtpath); keir@20462: keir@20462: device.backend_devid = devid; keir@20462: device.backend_domid = disk->backend_domid; keir@20462: device.devid = devid; keir@20462: device.domid = disk->domid; keir@20462: device.kind = DEVICE_VBD; keir@20462: keir@20462: switch (disk->phystype) { keir@20462: case PHYSTYPE_PHY: { keir@20462: keir@20509: device_physdisk_major_minor(disk->physpath, &major, &minor); keir@20516: flexarray_set(back, boffset++, "physical-device"); keir@20462: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%x:%x", major, minor)); keir@20462: keir@20516: flexarray_set(back, boffset++, "params"); keir@20516: flexarray_set(back, boffset++, disk->physpath); keir@20462: keir@20462: device.backend_kind = DEVICE_VBD; keir@20462: break; keir@20462: } keir@20566: case PHYSTYPE_FILE: keir@20566: /* let's pretend is tap:aio for the moment */ keir@20566: disk->phystype = PHYSTYPE_AIO; keir@20462: case PHYSTYPE_AIO: case PHYSTYPE_QCOW: case PHYSTYPE_QCOW2: case PHYSTYPE_VHD: keir@20566: if (is_blktap2_supported()) { keir@20566: int rc, c, p[2], tot; keir@20566: char buf[1024], *dev; keir@20779: dev = get_blktap2_device(ctx, disk->physpath, device_disk_string_of_phystype(disk->phystype)); keir@20779: if (dev == NULL) { keir@20566: if (pipe(p) < 0) { keir@20566: XL_LOG(ctx, XL_LOG_ERROR, "Failed to create a pipe"); keir@20566: return -1; keir@20566: } keir@20566: rc = fork(); keir@20566: if (rc < 0) { keir@20566: XL_LOG(ctx, XL_LOG_ERROR, "Failed to fork a new process"); keir@20566: return -1; keir@20566: } else if (!rc) { /* child */ keir@20566: int null_r, null_w; keir@20566: char *args[4]; keir@20566: args[0] = "tapdisk2"; keir@20566: args[1] = "-n"; keir@20566: args[2] = libxl_sprintf(ctx, "%s:%s", device_disk_string_of_phystype(disk->phystype), disk->physpath); keir@20566: args[3] = NULL; keir@20566: keir@20566: null_r = open("/dev/null", O_RDONLY); keir@20566: null_w = open("/dev/null", O_WRONLY); keir@20566: libxl_exec(ctx, null_r, p[1], null_w, "/usr/sbin/tapdisk2", args); keir@20566: XL_LOG(ctx, XL_LOG_ERROR, "Error execing tapdisk2"); keir@20566: } keir@20566: close(p[1]); keir@20566: tot = 0; keir@20566: while ((c = read(p[0], buf + tot, sizeof(buf) - tot)) > 0) keir@20566: tot = tot + c; keir@20566: close(p[0]); keir@20566: buf[tot - 1] = '\0'; keir@20566: dev = buf; keir@20566: } keir@20566: flexarray_set(back, boffset++, "tapdisk-params"); keir@20566: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%s:%s", device_disk_string_of_phystype(disk->phystype), disk->physpath)); keir@20566: flexarray_set(back, boffset++, "params"); keir@20566: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%s", dev)); keir@20566: backend_type = "phy"; keir@20566: device_physdisk_major_minor(dev, &major, &minor); keir@20566: flexarray_set(back, boffset++, "physical-device"); keir@20566: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%x:%x", major, minor)); keir@20566: device.backend_kind = DEVICE_VBD; keir@20566: keir@20566: break; keir@20566: } keir@20516: flexarray_set(back, boffset++, "params"); keir@20462: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%s:%s", keir@20462: device_disk_string_of_phystype(disk->phystype), disk->physpath)); keir@20462: keir@20462: device.backend_kind = DEVICE_TAP; keir@20462: break; keir@20462: } keir@20462: keir@20516: flexarray_set(back, boffset++, "frontend-id"); keir@20462: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", disk->domid)); keir@20516: flexarray_set(back, boffset++, "online"); keir@20516: flexarray_set(back, boffset++, "1"); keir@20516: flexarray_set(back, boffset++, "removable"); keir@20462: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", (disk->unpluggable) ? 1 : 0)); keir@20516: flexarray_set(back, boffset++, "bootable"); keir@20509: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", 1)); keir@20516: flexarray_set(back, boffset++, "state"); keir@20462: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", 1)); keir@20516: flexarray_set(back, boffset++, "dev"); keir@20516: flexarray_set(back, boffset++, disk->virtpath); keir@20516: flexarray_set(back, boffset++, "type"); keir@20516: flexarray_set(back, boffset++, backend_type); keir@20516: flexarray_set(back, boffset++, "mode"); keir@20516: flexarray_set(back, boffset++, disk->readwrite ? "w" : "r"); keir@20462: keir@20516: flexarray_set(front, foffset++, "backend-id"); keir@20462: flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", disk->backend_domid)); keir@20516: flexarray_set(front, foffset++, "state"); keir@20462: flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", 1)); keir@20516: flexarray_set(front, foffset++, "virtual-device"); keir@20462: flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", devid)); keir@20516: flexarray_set(front, foffset++, "device-type"); keir@20516: flexarray_set(front, foffset++, disk->is_cdrom ? "cdrom" : "disk"); keir@20462: keir@20462: if (0 /* protocol != native*/) { keir@20516: flexarray_set(front, foffset++, "protocol"); keir@20516: flexarray_set(front, foffset++, "x86_32-abi"); /* hardcoded ! */ keir@20462: } keir@20462: keir@20462: libxl_device_generic_add(ctx, &device, keir@20462: libxl_xs_kvs_of_flexarray(ctx, back, boffset), keir@20462: libxl_xs_kvs_of_flexarray(ctx, front, foffset)); keir@20516: flexarray_free(back); keir@20516: flexarray_free(front); keir@20462: return 0; keir@20462: } keir@20462: keir@20626: int libxl_device_disk_del(struct libxl_ctx *ctx, keir@20626: libxl_device_disk *disk, int wait) keir@20462: { keir@20626: libxl_device device; keir@20626: int devid; keir@20462: keir@20626: devid = device_disk_dev_number(disk->virtpath); keir@20626: device.backend_domid = disk->backend_domid; keir@20626: device.backend_devid = devid; keir@20626: device.backend_kind = keir@20626: (disk->phystype == PHYSTYPE_PHY) ? DEVICE_VBD : DEVICE_TAP; keir@20626: device.domid = disk->domid; keir@20626: device.devid = devid; keir@20626: device.kind = DEVICE_VBD; keir@20626: return libxl_device_del(ctx, &device, wait); keir@20462: } keir@20462: keir@20462: /******************************************************************************/ keir@20462: int libxl_device_nic_add(struct libxl_ctx *ctx, uint32_t domid, libxl_device_nic *nic) keir@20462: { keir@20462: flexarray_t *front; keir@20462: flexarray_t *back; keir@20462: unsigned int boffset = 0; keir@20462: unsigned int foffset = 0; keir@20462: libxl_device device; keir@20462: keir@20462: front = flexarray_make(16, 1); keir@20462: if (!front) keir@20462: return ERROR_NOMEM; keir@20462: back = flexarray_make(16, 1); keir@20462: if (!back) keir@20462: return ERROR_NOMEM; keir@20462: keir@20462: device.backend_devid = nic->devid; keir@20462: device.backend_domid = nic->backend_domid; keir@20462: device.backend_kind = DEVICE_VIF; keir@20462: device.devid = nic->devid; keir@20462: device.domid = nic->domid; keir@20462: device.kind = DEVICE_VIF; keir@20462: keir@20516: flexarray_set(back, boffset++, "frontend-id"); keir@20462: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", nic->domid)); keir@20516: flexarray_set(back, boffset++, "online"); keir@20516: flexarray_set(back, boffset++, "1"); keir@20516: flexarray_set(back, boffset++, "state"); keir@20462: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", 1)); keir@20516: flexarray_set(back, boffset++, "script"); keir@20516: flexarray_set(back, boffset++, nic->script); keir@20516: flexarray_set(back, boffset++, "mac"); keir@20462: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%02x:%02x:%02x:%02x:%02x:%02x", keir@20462: nic->mac[0], nic->mac[1], nic->mac[2], keir@20462: nic->mac[3], nic->mac[4], nic->mac[5])); keir@20516: flexarray_set(back, boffset++, "handle"); keir@20462: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", nic->devid)); keir@20462: keir@20516: flexarray_set(front, foffset++, "backend-id"); keir@20462: flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", nic->backend_domid)); keir@20516: flexarray_set(front, foffset++, "state"); keir@20462: flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", 1)); keir@20516: flexarray_set(front, foffset++, "handle"); keir@20462: flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", nic->devid)); keir@20516: flexarray_set(front, foffset++, "mac"); keir@20462: flexarray_set(front, foffset++, libxl_sprintf(ctx, "%02x:%02x:%02x:%02x:%02x:%02x", keir@20462: nic->mac[0], nic->mac[1], nic->mac[2], keir@20462: nic->mac[3], nic->mac[4], nic->mac[5])); keir@20462: if (0 /* protocol != native*/) { keir@20516: flexarray_set(front, foffset++, "protocol"); keir@20516: flexarray_set(front, foffset++, "x86_32-abi"); /* hardcoded ! */ keir@20462: } keir@20462: keir@20462: libxl_device_generic_add(ctx, &device, keir@20462: libxl_xs_kvs_of_flexarray(ctx, back, boffset), keir@20462: libxl_xs_kvs_of_flexarray(ctx, front, foffset)); keir@20462: keir@20462: /* FIXME: wait for plug */ keir@20516: flexarray_free(back); keir@20516: flexarray_free(front); keir@20462: return 0; keir@20462: } keir@20462: keir@20626: int libxl_device_nic_del(struct libxl_ctx *ctx, keir@20626: libxl_device_nic *nic, int wait) keir@20462: { keir@20626: libxl_device device; keir@20462: keir@20626: device.backend_devid = nic->devid; keir@20626: device.backend_domid = nic->backend_domid; keir@20626: device.backend_kind = DEVICE_VIF; keir@20626: device.devid = nic->devid; keir@20626: device.domid = nic->domid; keir@20626: device.kind = DEVICE_VIF; keir@20626: keir@20626: return libxl_device_del(ctx, &device, wait); keir@20462: } keir@20462: keir@20462: /******************************************************************************/ keir@20509: int libxl_device_console_add(struct libxl_ctx *ctx, uint32_t domid, libxl_device_console *console) keir@20462: { keir@20509: flexarray_t *front; keir@20509: flexarray_t *back; keir@20509: unsigned int boffset = 0; keir@20509: unsigned int foffset = 0; keir@20509: libxl_device device; keir@20509: keir@20509: if (console->build_state) { keir@20509: xs_transaction_t t; keir@20509: char **ents = (char **) libxl_calloc(ctx, 9, sizeof(char *)); keir@20516: ents[0] = "console/port"; keir@20509: ents[1] = libxl_sprintf(ctx, "%"PRIu32, console->build_state->console_port); keir@20516: ents[2] = "console/ring-ref"; keir@20509: ents[3] = libxl_sprintf(ctx, "%lu", console->build_state->console_mfn); keir@20516: ents[4] = "console/limit"; keir@20509: ents[5] = libxl_sprintf(ctx, "%d", LIBXL_XENCONSOLE_LIMIT); keir@20516: ents[6] = "console/type"; keir@20509: if (console->constype == CONSTYPE_XENCONSOLED) keir@20509: ents[7] = "xenconsoled"; keir@20509: else keir@20509: ents[7] = "ioemu"; keir@20509: retry_transaction: keir@20509: t = xs_transaction_start(ctx->xsh); keir@20516: libxl_xs_writev(ctx, t, libxl_xs_get_dompath(ctx, console->domid), ents); keir@20509: if (!xs_transaction_end(ctx->xsh, t, 0)) keir@20509: if (errno == EAGAIN) keir@20509: goto retry_transaction; keir@20509: } keir@20509: keir@20509: front = flexarray_make(16, 1); keir@20509: if (!front) keir@20509: return ERROR_NOMEM; keir@20509: back = flexarray_make(16, 1); keir@20509: if (!back) keir@20509: return ERROR_NOMEM; keir@20509: keir@20509: device.backend_devid = console->devid; keir@20509: device.backend_domid = console->backend_domid; keir@20509: device.backend_kind = DEVICE_CONSOLE; keir@20509: device.devid = console->devid; keir@20509: device.domid = console->domid; keir@20509: device.kind = DEVICE_CONSOLE; keir@20509: keir@20516: flexarray_set(back, boffset++, "frontend-id"); keir@20509: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", console->domid)); keir@20516: flexarray_set(back, boffset++, "online"); keir@20516: flexarray_set(back, boffset++, "1"); keir@20516: flexarray_set(back, boffset++, "state"); keir@20509: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", 1)); keir@20516: flexarray_set(back, boffset++, "domain"); keir@20516: flexarray_set(back, boffset++, libxl_domid_to_name(ctx, domid)); keir@20516: flexarray_set(back, boffset++, "protocol"); keir@20516: flexarray_set(back, boffset++, LIBXL_XENCONSOLE_PROTOCOL); keir@20509: keir@20516: flexarray_set(front, foffset++, "backend-id"); keir@20509: flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", console->backend_domid)); keir@20516: flexarray_set(front, foffset++, "state"); keir@20509: flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", 1)); keir@20516: flexarray_set(front, foffset++, "limit"); keir@20509: flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", LIBXL_XENCONSOLE_LIMIT)); keir@20516: flexarray_set(front, foffset++, "protocol"); keir@20516: flexarray_set(front, foffset++, LIBXL_XENCONSOLE_PROTOCOL); keir@20516: flexarray_set(front, foffset++, "type"); keir@20509: if (console->constype == CONSTYPE_XENCONSOLED) keir@20516: flexarray_set(front, foffset++, "xenconsoled"); keir@20509: else keir@20516: flexarray_set(front, foffset++, "ioemu"); keir@20509: keir@20509: libxl_device_generic_add(ctx, &device, keir@20509: libxl_xs_kvs_of_flexarray(ctx, back, boffset), keir@20509: libxl_xs_kvs_of_flexarray(ctx, front, foffset)); keir@20516: flexarray_free(back); keir@20516: flexarray_free(front); keir@20509: keir@20509: return 0; keir@20509: } keir@20509: keir@20509: /******************************************************************************/ keir@20509: int libxl_device_vkb_add(struct libxl_ctx *ctx, uint32_t domid, libxl_device_vkb *vkb) keir@20509: { keir@20509: flexarray_t *front; keir@20509: flexarray_t *back; keir@20509: unsigned int boffset = 0; keir@20509: unsigned int foffset = 0; keir@20509: libxl_device device; keir@20509: keir@20509: front = flexarray_make(16, 1); keir@20509: if (!front) keir@20509: return ERROR_NOMEM; keir@20509: back = flexarray_make(16, 1); keir@20509: if (!back) keir@20509: return ERROR_NOMEM; keir@20509: keir@20509: device.backend_devid = vkb->devid; keir@20509: device.backend_domid = vkb->backend_domid; keir@20509: device.backend_kind = DEVICE_VKBD; keir@20509: device.devid = vkb->devid; keir@20509: device.domid = vkb->domid; keir@20509: device.kind = DEVICE_VKBD; keir@20509: keir@20516: flexarray_set(back, boffset++, "frontend-id"); keir@20509: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", vkb->domid)); keir@20516: flexarray_set(back, boffset++, "online"); keir@20516: flexarray_set(back, boffset++, "1"); keir@20516: flexarray_set(back, boffset++, "state"); keir@20509: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", 1)); keir@20516: flexarray_set(back, boffset++, "domain"); keir@20516: flexarray_set(back, boffset++, libxl_domid_to_name(ctx, domid)); keir@20509: keir@20516: flexarray_set(front, foffset++, "backend-id"); keir@20509: flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", vkb->backend_domid)); keir@20516: flexarray_set(front, foffset++, "state"); keir@20509: flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", 1)); keir@20509: keir@20509: libxl_device_generic_add(ctx, &device, keir@20509: libxl_xs_kvs_of_flexarray(ctx, back, boffset), keir@20509: libxl_xs_kvs_of_flexarray(ctx, front, foffset)); keir@20516: flexarray_free(back); keir@20516: flexarray_free(front); keir@20509: keir@20509: return 0; keir@20462: } keir@20462: keir@20462: int libxl_device_vkb_clean_shutdown(struct libxl_ctx *ctx, uint32_t domid) keir@20462: { keir@20462: return ERROR_NI; keir@20462: } keir@20462: keir@20462: int libxl_device_vkb_hard_shutdown(struct libxl_ctx *ctx, uint32_t domid) keir@20462: { keir@20462: return ERROR_NI; keir@20462: } keir@20462: keir@20637: libxl_device_disk *libxl_device_disk_list(struct libxl_ctx *ctx, uint32_t domid, int *num) keir@20637: { keir@20637: char *be_path_tap, *be_path_vbd; keir@20637: libxl_device_disk *disks = NULL; keir@20637: char **l = NULL; keir@20637: unsigned int numl; keir@20637: int num_disks = 0, i; keir@20637: char *type; keir@20637: keir@20637: be_path_vbd = libxl_sprintf(ctx, "%s/backend/vbd/%d", libxl_xs_get_dompath(ctx, 0), domid); keir@20637: be_path_tap = libxl_sprintf(ctx, "%s/backend/tap/%d", libxl_xs_get_dompath(ctx, 0), domid); keir@20637: keir@20637: l = libxl_xs_directory(ctx, XBT_NULL, be_path_vbd, &numl); keir@20637: if (l) { keir@20637: num_disks += numl; keir@20637: disks = realloc(disks, sizeof(libxl_device_disk) * num_disks); keir@20637: for (i = 0; i < numl; i++) { keir@20637: disks[i].backend_domid = 0; keir@20637: disks[i].domid = domid; keir@20637: disks[i].physpath = libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/%s/params", be_path_vbd, l[i])); keir@20637: libxl_string_to_phystype(ctx, libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/%s/type", be_path_vbd, l[i])), &(disks[i].phystype)); keir@20637: disks[i].virtpath = libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/%s/dev", be_path_vbd, l[i])); keir@20637: disks[i].unpluggable = atoi(libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/%s/removable", be_path_vbd, l[i]))); keir@20637: if (!strcmp(libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/%s/mode", be_path_vbd, l[i])), "w")) keir@20637: disks[i].readwrite = 1; keir@20637: else keir@20637: disks[i].readwrite = 0; keir@20637: type = libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/device-type", libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/%s/frontend", be_path_vbd, l[i])))); keir@20637: disks[i].is_cdrom = !strcmp(type, "cdrom"); keir@20637: } keir@20637: free(l); keir@20637: } keir@20637: l = libxl_xs_directory(ctx, XBT_NULL, be_path_tap, &numl); keir@20637: if (l) { keir@20637: num_disks += numl; keir@20637: disks = realloc(disks, sizeof(libxl_device_disk) * num_disks); keir@20637: for (i = 0; i < numl; i++) { keir@20637: disks[i].backend_domid = 0; keir@20637: disks[i].domid = domid; keir@20637: disks[i].physpath = libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/%s/params", be_path_tap, l[i])); keir@20637: libxl_string_to_phystype(ctx, libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/%s/type", be_path_tap, l[i])), &(disks[i].phystype)); keir@20637: disks[i].virtpath = libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/%s/dev", be_path_tap, l[i])); keir@20637: disks[i].unpluggable = atoi(libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/%s/removable", be_path_tap, l[i]))); keir@20637: if (!strcmp(libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/%s/mode", be_path_tap, l[i])), "w")) keir@20637: disks[i].readwrite = 1; keir@20637: else keir@20637: disks[i].readwrite = 0; keir@20637: type = libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/device-type", libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/%s/frontend", be_path_vbd, l[i])))); keir@20637: disks[i].is_cdrom = !strcmp(type, "cdrom"); keir@20637: } keir@20637: free(l); keir@20637: } keir@20637: *num = num_disks; keir@20637: return disks; keir@20637: } keir@20637: keir@20637: int libxl_cdrom_insert(struct libxl_ctx *ctx, uint32_t domid, libxl_device_disk *disk) keir@20637: { keir@20637: int num, i; keir@20637: uint32_t stubdomid; keir@20637: libxl_device_disk *disks; keir@20637: keir@20637: if (!disk->physpath) { keir@20637: disk->physpath = ""; keir@20637: disk->phystype = PHYSTYPE_PHY; keir@20637: } keir@20637: disks = libxl_device_disk_list(ctx, domid, &num); keir@20637: for (i = 0; i < num; i++) { keir@20637: if (disks[i].is_cdrom && !strcmp(disk->virtpath, disks[i].virtpath)) keir@20637: /* found */ keir@20637: break; keir@20637: } keir@20637: if (i == num) { keir@20637: XL_LOG(ctx, XL_LOG_ERROR, "Virtual device not found"); keir@20637: return -1; keir@20637: } keir@20637: libxl_device_disk_del(ctx, disks + i, 1); keir@20637: libxl_device_disk_add(ctx, domid, disk); keir@20637: stubdomid = libxl_get_stubdom_id(ctx, domid); keir@20637: if (stubdomid) { keir@20637: disk_info_domid_fixup(disks + i, stubdomid); keir@20637: libxl_device_disk_del(ctx, disks + i, 1); keir@20637: disk_info_domid_fixup(disk, stubdomid); keir@20637: libxl_device_disk_add(ctx, stubdomid, disk); keir@20637: disk_info_domid_fixup(disk, domid); keir@20637: } keir@20637: return 0; keir@20637: } keir@20637: keir@20462: /******************************************************************************/ keir@20509: static int libxl_build_xenpv_qemu_args(struct libxl_ctx *ctx, keir@20509: libxl_device_vfb *vfb, keir@20509: int num_console, keir@20509: libxl_device_console *console, keir@20509: libxl_device_model_info *info) { keir@20509: int i = 0, j = 0, num = 0; keir@20509: memset(info, 0x00, sizeof(libxl_device_model_info)); keir@20509: keir@20509: info->vnc = vfb->vnc; keir@20509: if (vfb->vnclisten) keir@20509: info->vnclisten = libxl_sprintf(ctx, "%s", vfb->vnclisten); keir@20509: info->vncdisplay = vfb->vncdisplay; keir@20509: info->vncunused = vfb->vncunused; keir@20509: if (vfb->keymap) keir@20509: info->keymap = libxl_sprintf(ctx, "%s", vfb->keymap); keir@20509: info->sdl = vfb->sdl; keir@20509: info->opengl = vfb->opengl; keir@20509: for (i = 0; i < num_console; i++) { keir@20509: if (console->constype == CONSTYPE_IOEMU) keir@20509: num++; keir@20509: } keir@20509: if (num > 0) { keir@20599: uint32_t guest_domid = libxl_is_stubdom(ctx, vfb->domid); keir@20599: if (guest_domid) { keir@20599: char *filename; keir@20599: char *name = libxl_sprintf(ctx, "qemu-dm-%s", libxl_domid_to_name(ctx, guest_domid)); keir@20599: libxl_create_logfile(ctx, name, &filename); keir@20599: info->serial = libxl_sprintf(ctx, "file:%s", filename); keir@20599: free(filename); keir@20599: } else { keir@20599: info->serial = "pty"; keir@20599: } keir@20509: num--; keir@20509: } keir@20509: if (num > 0) { keir@20509: info->extra = (char **) libxl_calloc(ctx, num * 2 + 1, sizeof(char *)); keir@20509: for (j = 0; j < num * 2; j = j + 2) { keir@20509: info->extra[j] = "-serial"; keir@20509: info->extra[j + 1] = "pty"; keir@20509: } keir@20509: info->extra[j] = NULL; keir@20509: } keir@20509: info->domid = vfb->domid; keir@20509: info->dom_name = libxl_domid_to_name(ctx, vfb->domid); keir@20509: info->device_model = "/usr/lib/xen/bin/qemu-dm"; keir@20509: info->type = XENPV; keir@20509: return 0; keir@20509: } keir@20509: keir@20509: int libxl_create_xenpv_qemu(struct libxl_ctx *ctx, libxl_device_vfb *vfb, keir@20514: int num_console, libxl_device_console *console, keir@20514: struct libxl_device_model_starting **starting_r) keir@20509: { keir@20509: libxl_device_model_info info; keir@20509: keir@20509: libxl_build_xenpv_qemu_args(ctx, vfb, num_console, console, &info); keir@20542: libxl_create_device_model(ctx, &info, NULL, 0, NULL, 0, starting_r); keir@20509: return 0; keir@20509: } keir@20509: keir@20509: int libxl_device_vfb_add(struct libxl_ctx *ctx, uint32_t domid, libxl_device_vfb *vfb) keir@20462: { keir@20509: flexarray_t *front; keir@20509: flexarray_t *back; keir@20509: unsigned int boffset = 0; keir@20509: unsigned int foffset = 0; keir@20509: libxl_device device; keir@20509: keir@20509: front = flexarray_make(16, 1); keir@20509: if (!front) keir@20509: return ERROR_NOMEM; keir@20509: back = flexarray_make(16, 1); keir@20509: if (!back) keir@20509: return ERROR_NOMEM; keir@20509: keir@20509: device.backend_devid = vfb->devid; keir@20509: device.backend_domid = vfb->backend_domid; keir@20509: device.backend_kind = DEVICE_VFB; keir@20509: device.devid = vfb->devid; keir@20509: device.domid = vfb->domid; keir@20509: device.kind = DEVICE_VFB; keir@20509: keir@20516: flexarray_set(back, boffset++, "frontend-id"); keir@20509: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", vfb->domid)); keir@20516: flexarray_set(back, boffset++, "online"); keir@20516: flexarray_set(back, boffset++, "1"); keir@20516: flexarray_set(back, boffset++, "state"); keir@20509: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", 1)); keir@20516: flexarray_set(back, boffset++, "domain"); keir@20516: flexarray_set(back, boffset++, libxl_domid_to_name(ctx, domid)); keir@20516: flexarray_set(back, boffset++, "vnc"); keir@20509: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", vfb->vnc)); keir@20516: flexarray_set(back, boffset++, "vnclisten"); keir@20516: flexarray_set(back, boffset++, vfb->vnclisten); keir@20516: flexarray_set(back, boffset++, "vncdisplay"); keir@20509: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", vfb->vncdisplay)); keir@20516: flexarray_set(back, boffset++, "vncunused"); keir@20509: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", vfb->vncunused)); keir@20516: flexarray_set(back, boffset++, "sdl"); keir@20509: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", vfb->sdl)); keir@20516: flexarray_set(back, boffset++, "opengl"); keir@20509: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", vfb->opengl)); keir@20509: if (vfb->xauthority) { keir@20516: flexarray_set(back, boffset++, "xauthority"); keir@20516: flexarray_set(back, boffset++, vfb->xauthority); keir@20509: } keir@20509: if (vfb->display) { keir@20516: flexarray_set(back, boffset++, "display"); keir@20516: flexarray_set(back, boffset++, vfb->display); keir@20509: } keir@20509: keir@20516: flexarray_set(front, foffset++, "backend-id"); keir@20509: flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", vfb->backend_domid)); keir@20516: flexarray_set(front, foffset++, "state"); keir@20509: flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", 1)); keir@20509: keir@20509: libxl_device_generic_add(ctx, &device, keir@20509: libxl_xs_kvs_of_flexarray(ctx, back, boffset), keir@20509: libxl_xs_kvs_of_flexarray(ctx, front, foffset)); keir@20509: flexarray_free(front); keir@20509: flexarray_free(back); keir@20509: keir@20509: return 0; keir@20462: } keir@20462: keir@20462: int libxl_device_vfb_clean_shutdown(struct libxl_ctx *ctx, uint32_t domid) keir@20462: { keir@20462: return ERROR_NI; keir@20462: } keir@20462: keir@20462: int libxl_device_vfb_hard_shutdown(struct libxl_ctx *ctx, uint32_t domid) keir@20462: { keir@20462: return ERROR_NI; keir@20462: } keir@20462: keir@20462: /******************************************************************************/ keir@20482: keir@20482: int libxl_device_pci_init(libxl_device_pci *pcidev, unsigned int domain, keir@20482: unsigned int bus, unsigned int dev, keir@20482: unsigned int func, unsigned int vdevfn) keir@20482: { keir@20482: pcidev->domain = domain; keir@20482: pcidev->bus = bus; keir@20482: pcidev->dev = dev; keir@20482: pcidev->func = func; keir@20482: pcidev->vdevfn = vdevfn; keir@20482: return 0; keir@20482: } keir@20482: keir@20482: static int libxl_create_pci_backend(struct libxl_ctx *ctx, uint32_t domid, libxl_device_pci *pcidev, int num) keir@20482: { keir@20482: flexarray_t *front; keir@20482: flexarray_t *back; keir@20482: unsigned int boffset = 0; keir@20482: unsigned int foffset = 0; keir@20482: libxl_device device; keir@20482: int i; keir@20482: keir@20482: front = flexarray_make(16, 1); keir@20482: if (!front) keir@20482: return ERROR_NOMEM; keir@20482: back = flexarray_make(16, 1); keir@20482: if (!back) keir@20482: return ERROR_NOMEM; keir@20482: keir@20512: XL_LOG(ctx, XL_LOG_DEBUG, "Creating pci backend"); keir@20482: keir@20482: /* add pci device */ keir@20482: device.backend_devid = 0; keir@20482: device.backend_domid = 0; keir@20482: device.backend_kind = DEVICE_PCI; keir@20482: device.devid = 0; keir@20482: device.domid = domid; keir@20482: device.kind = DEVICE_PCI; keir@20482: keir@20516: flexarray_set(back, boffset++, "frontend-id"); keir@20482: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", domid)); keir@20516: flexarray_set(back, boffset++, "online"); keir@20516: flexarray_set(back, boffset++, "1"); keir@20516: flexarray_set(back, boffset++, "state"); keir@20482: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", 1)); keir@20516: flexarray_set(back, boffset++, "domain"); keir@20516: flexarray_set(back, boffset++, libxl_domid_to_name(ctx, domid)); keir@20482: for (i = 0; i < num; i++) { keir@20482: flexarray_set(back, boffset++, libxl_sprintf(ctx, "key-%d", i)); keir@20482: flexarray_set(back, boffset++, libxl_sprintf(ctx, PCI_BDF, pcidev->domain, pcidev->bus, pcidev->dev, pcidev->func)); keir@20482: flexarray_set(back, boffset++, libxl_sprintf(ctx, "dev-%d", i)); keir@20482: flexarray_set(back, boffset++, libxl_sprintf(ctx, PCI_BDF, pcidev->domain, pcidev->bus, pcidev->dev, pcidev->func)); keir@20482: if (pcidev->vdevfn) { keir@20482: flexarray_set(back, boffset++, libxl_sprintf(ctx, "vdevfn-%d", i)); keir@20482: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%x", pcidev->vdevfn)); keir@20482: } keir@20482: flexarray_set(back, boffset++, libxl_sprintf(ctx, "opts-%d", i)); keir@20482: flexarray_set(back, boffset++, libxl_sprintf(ctx, "msitranslate=%d,power_mgmt=%d", pcidev->msitranslate, pcidev->power_mgmt)); keir@20482: flexarray_set(back, boffset++, libxl_sprintf(ctx, "state-%d", i)); keir@20482: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", 1)); keir@20482: } keir@20516: flexarray_set(back, boffset++, "num_devs"); keir@20482: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", num)); keir@20482: keir@20516: flexarray_set(front, foffset++, "backend-id"); keir@20482: flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", 0)); keir@20516: flexarray_set(front, foffset++, "state"); keir@20482: flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", 1)); keir@20482: keir@20482: libxl_device_generic_add(ctx, &device, keir@20482: libxl_xs_kvs_of_flexarray(ctx, back, boffset), keir@20482: libxl_xs_kvs_of_flexarray(ctx, front, foffset)); keir@20482: keir@20482: flexarray_free(back); keir@20482: flexarray_free(front); keir@20482: return 0; keir@20482: } keir@20482: keir@20482: static int libxl_device_pci_add_xenstore(struct libxl_ctx *ctx, uint32_t domid, libxl_device_pci *pcidev) keir@20462: { keir@20482: flexarray_t *back; keir@20482: char *num_devs, *be_path; keir@20482: int num = 0; keir@20482: unsigned int boffset = 0; keir@20482: xs_transaction_t t; keir@20482: keir@20516: be_path = libxl_sprintf(ctx, "%s/backend/pci/%d/0", libxl_xs_get_dompath(ctx, 0), domid); keir@20482: num_devs = libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/num_devs", be_path)); keir@20482: if (!num_devs) keir@20482: return libxl_create_pci_backend(ctx, domid, pcidev, 1); keir@20482: keir@20482: if (!is_hvm(ctx, domid)) { keir@20482: if (libxl_wait_for_backend(ctx, be_path, "4") < 0) keir@20482: return -1; keir@20482: } keir@20482: keir@20482: back = flexarray_make(16, 1); keir@20482: if (!back) keir@20482: return ERROR_NOMEM; keir@20482: keir@20512: XL_LOG(ctx, XL_LOG_DEBUG, "Adding new pci device to xenstore"); keir@20482: num = atoi(num_devs); keir@20482: flexarray_set(back, boffset++, libxl_sprintf(ctx, "key-%d", num)); keir@20482: flexarray_set(back, boffset++, libxl_sprintf(ctx, PCI_BDF, pcidev->domain, pcidev->bus, pcidev->dev, pcidev->func)); keir@20482: flexarray_set(back, boffset++, libxl_sprintf(ctx, "dev-%d", num)); keir@20482: flexarray_set(back, boffset++, libxl_sprintf(ctx, PCI_BDF, pcidev->domain, pcidev->bus, pcidev->dev, pcidev->func)); keir@20482: if (pcidev->vdevfn) { keir@20482: flexarray_set(back, boffset++, libxl_sprintf(ctx, "vdevfn-%d", num)); keir@20482: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%x", pcidev->vdevfn)); keir@20482: } keir@20482: flexarray_set(back, boffset++, libxl_sprintf(ctx, "opts-%d", num)); keir@20482: flexarray_set(back, boffset++, libxl_sprintf(ctx, "msitranslate=%d,power_mgmt=%d", pcidev->msitranslate, pcidev->power_mgmt)); keir@20482: flexarray_set(back, boffset++, libxl_sprintf(ctx, "state-%d", num)); keir@20482: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", 1)); keir@20516: flexarray_set(back, boffset++, "num_devs"); keir@20482: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", num + 1)); keir@20516: flexarray_set(back, boffset++, "state"); keir@20482: flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", 7)); keir@20482: keir@20482: retry_transaction: keir@20482: t = xs_transaction_start(ctx->xsh); keir@20482: libxl_xs_writev(ctx, t, be_path, keir@20482: libxl_xs_kvs_of_flexarray(ctx, back, boffset)); keir@20482: if (!xs_transaction_end(ctx->xsh, t, 0)) keir@20482: if (errno == EAGAIN) keir@20482: goto retry_transaction; keir@20482: keir@20482: flexarray_free(back); keir@20482: return 0; keir@20482: } keir@20482: keir@20482: static int libxl_device_pci_remove_xenstore(struct libxl_ctx *ctx, uint32_t domid, libxl_device_pci *pcidev) keir@20482: { keir@20542: char *be_path, *num_devs_path, *num_devs, *xsdev, *tmp, *tmppath; keir@20542: int num, i, j; keir@20482: xs_transaction_t t; keir@20482: unsigned int domain = 0, bus = 0, dev = 0, func = 0; keir@20482: keir@20516: be_path = libxl_sprintf(ctx, "%s/backend/pci/%d/0", libxl_xs_get_dompath(ctx, 0), domid); keir@20482: num_devs_path = libxl_sprintf(ctx, "%s/num_devs", be_path); keir@20482: num_devs = libxl_xs_read(ctx, XBT_NULL, num_devs_path); keir@20482: if (!num_devs) keir@20482: return -1; keir@20482: num = atoi(num_devs); keir@20482: keir@20482: if (!is_hvm(ctx, domid)) { keir@20482: if (libxl_wait_for_backend(ctx, be_path, "4") < 0) { keir@20542: XL_LOG(ctx, XL_LOG_DEBUG, "pci backend at %s is not ready", be_path); keir@20482: return -1; keir@20482: } keir@20482: } keir@20482: keir@20482: for (i = 0; i < num; i++) { keir@20482: xsdev = libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/dev-%d", be_path, i)); keir@20482: sscanf(xsdev, PCI_BDF, &domain, &bus, &dev, &func); keir@20482: if (domain == pcidev->domain && bus == pcidev->bus && keir@20482: pcidev->dev == dev && pcidev->func == func) { keir@20482: break; keir@20482: } keir@20482: } keir@20482: if (i == num) { keir@20512: XL_LOG(ctx, XL_LOG_ERROR, "Couldn't find the device on xenstore"); keir@20482: return -1; keir@20482: } keir@20482: keir@20482: retry_transaction: keir@20482: t = xs_transaction_start(ctx->xsh); keir@20542: xs_write(ctx->xsh, t, libxl_sprintf(ctx, "%s/state-%d", be_path, i), "5", strlen("5")); keir@20482: xs_write(ctx->xsh, t, libxl_sprintf(ctx, "%s/state", be_path), "7", strlen("7")); keir@20482: if (!xs_transaction_end(ctx->xsh, t, 0)) keir@20482: if (errno == EAGAIN) keir@20482: goto retry_transaction; keir@20542: keir@20542: if (!is_hvm(ctx, domid)) { keir@20542: if (libxl_wait_for_backend(ctx, be_path, "4") < 0) { keir@20542: XL_LOG(ctx, XL_LOG_DEBUG, "pci backend at %s is not ready", be_path); keir@20542: return -1; keir@20542: } keir@20542: } keir@20542: keir@20542: retry_transaction2: keir@20542: t = xs_transaction_start(ctx->xsh); keir@20542: xs_rm(ctx->xsh, t, libxl_sprintf(ctx, "%s/state-%d", be_path, i)); keir@20542: xs_rm(ctx->xsh, t, libxl_sprintf(ctx, "%s/key-%d", be_path, i)); keir@20542: xs_rm(ctx->xsh, t, libxl_sprintf(ctx, "%s/dev-%d", be_path, i)); keir@20542: xs_rm(ctx->xsh, t, libxl_sprintf(ctx, "%s/vdev-%d", be_path, i)); keir@20542: xs_rm(ctx->xsh, t, libxl_sprintf(ctx, "%s/opts-%d", be_path, i)); keir@20542: xs_rm(ctx->xsh, t, libxl_sprintf(ctx, "%s/vdevfn-%d", be_path, i)); keir@20542: libxl_xs_write(ctx, t, num_devs_path, "%d", num - 1); keir@20542: for (j = i + 1; j < num; j++) { keir@20542: tmppath = libxl_sprintf(ctx, "%s/state-%d", be_path, j); keir@20542: tmp = libxl_xs_read(ctx, t, tmppath); keir@20542: xs_write(ctx->xsh, t, libxl_sprintf(ctx, "%s/state-%d", be_path, j - 1), tmp, strlen(tmp)); keir@20542: xs_rm(ctx->xsh, t, tmppath); keir@20542: tmppath = libxl_sprintf(ctx, "%s/dev-%d", be_path, j); keir@20542: tmp = libxl_xs_read(ctx, t, tmppath); keir@20542: xs_write(ctx->xsh, t, libxl_sprintf(ctx, "%s/dev-%d", be_path, j - 1), tmp, strlen(tmp)); keir@20542: xs_rm(ctx->xsh, t, tmppath); keir@20542: tmppath = libxl_sprintf(ctx, "%s/key-%d", be_path, j); keir@20542: tmp = libxl_xs_read(ctx, t, tmppath); keir@20542: xs_write(ctx->xsh, t, libxl_sprintf(ctx, "%s/key-%d", be_path, j - 1), tmp, strlen(tmp)); keir@20542: xs_rm(ctx->xsh, t, tmppath); keir@20542: tmppath = libxl_sprintf(ctx, "%s/vdev-%d", be_path, j); keir@20542: tmp = libxl_xs_read(ctx, t, tmppath); keir@20542: if (tmp) { keir@20542: xs_write(ctx->xsh, t, libxl_sprintf(ctx, "%s/vdev-%d", be_path, j - 1), tmp, strlen(tmp)); keir@20542: xs_rm(ctx->xsh, t, tmppath); keir@20542: } keir@20542: tmppath = libxl_sprintf(ctx, "%s/opts-%d", be_path, j); keir@20542: tmp = libxl_xs_read(ctx, t, tmppath); keir@20542: if (tmp) { keir@20542: xs_write(ctx->xsh, t, libxl_sprintf(ctx, "%s/opts-%d", be_path, j - 1), tmp, strlen(tmp)); keir@20542: xs_rm(ctx->xsh, t, tmppath); keir@20542: } keir@20542: tmppath = libxl_sprintf(ctx, "%s/vdevfn-%d", be_path, j); keir@20542: tmp = libxl_xs_read(ctx, t, tmppath); keir@20542: if (tmp) { keir@20542: xs_write(ctx->xsh, t, libxl_sprintf(ctx, "%s/vdevfn-%d", be_path, j - 1), tmp, strlen(tmp)); keir@20542: xs_rm(ctx->xsh, t, tmppath); keir@20542: } keir@20542: } keir@20542: if (!xs_transaction_end(ctx->xsh, t, 0)) keir@20542: if (errno == EAGAIN) keir@20542: goto retry_transaction2; keir@20542: keir@20542: if (num == 1) { keir@20542: char *fe_path = libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/frontend", be_path)); keir@20542: libxl_device_destroy(ctx, be_path, 1); keir@20542: xs_rm(ctx->xsh, XBT_NULL, be_path); keir@20542: xs_rm(ctx->xsh, XBT_NULL, fe_path); keir@20542: return 0; keir@20542: } keir@20542: keir@20482: return 0; keir@20462: } keir@20462: keir@20482: int libxl_device_pci_add(struct libxl_ctx *ctx, uint32_t domid, libxl_device_pci *pcidev) keir@20462: { keir@20779: char *path; keir@20482: char *state, *vdevfn; keir@20482: int rc, hvm; keir@20542: int stubdomid = 0; keir@20482: keir@20482: /* TODO: check if the device can be assigned */ keir@20482: keir@20482: libxl_device_pci_flr(ctx, pcidev->domain, pcidev->bus, pcidev->dev, pcidev->func); keir@20482: keir@20779: stubdomid = libxl_get_stubdom_id(ctx, domid); keir@20779: if (stubdomid != 0) { keir@20542: libxl_device_pci pcidev_s = *pcidev; keir@20542: libxl_device_pci_add(ctx, stubdomid, &pcidev_s); keir@20542: } keir@20542: keir@20482: hvm = is_hvm(ctx, domid); keir@20482: if (hvm) { keir@20514: if (libxl_wait_for_device_model(ctx, domid, "running", 0,0) < 0) { keir@20482: return -1; keir@20482: } keir@20779: path = libxl_sprintf(ctx, "/local/domain/0/device-model/%d/state", domid); keir@20482: state = libxl_xs_read(ctx, XBT_NULL, path); keir@20779: path = libxl_sprintf(ctx, "/local/domain/0/device-model/%d/parameter", domid); keir@20482: if (pcidev->vdevfn) keir@20482: libxl_xs_write(ctx, XBT_NULL, path, PCI_BDF_VDEVFN, pcidev->domain, keir@20482: pcidev->bus, pcidev->dev, pcidev->func, pcidev->vdevfn); keir@20482: else keir@20482: libxl_xs_write(ctx, XBT_NULL, path, PCI_BDF, pcidev->domain, keir@20482: pcidev->bus, pcidev->dev, pcidev->func); keir@20779: path = libxl_sprintf(ctx, "/local/domain/0/device-model/%d/command", domid); keir@20482: xs_write(ctx->xsh, XBT_NULL, path, "pci-ins", strlen("pci-ins")); keir@20514: if (libxl_wait_for_device_model(ctx, domid, "pci-inserted", 0,0) < 0) keir@20512: XL_LOG(ctx, XL_LOG_ERROR, "Device Model didn't respond in time"); keir@20779: path = libxl_sprintf(ctx, "/local/domain/0/device-model/%d/parameter", domid); keir@20482: vdevfn = libxl_xs_read(ctx, XBT_NULL, path); keir@20482: sscanf(vdevfn + 2, "%x", &pcidev->vdevfn); keir@20779: path = libxl_sprintf(ctx, "/local/domain/0/device-model/%d/state", domid); keir@20482: xs_write(ctx->xsh, XBT_NULL, path, state, strlen(state)); keir@20482: } else { keir@20542: char *sysfs_path = libxl_sprintf(ctx, SYSFS_PCI_DEV"/"PCI_BDF"/resource", pcidev->domain, keir@20482: pcidev->bus, pcidev->dev, pcidev->func); keir@20482: FILE *f = fopen(sysfs_path, "r"); keir@20482: unsigned int start = 0, end = 0, flags = 0, size = 0; keir@20482: int irq = 0; keir@20482: int i; keir@20482: keir@20482: if (f == NULL) { keir@20512: XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "Couldn't open %s", sysfs_path); keir@20482: return -1; keir@20482: } keir@20482: for (i = 0; i < PROC_PCI_NUM_RESOURCES; i++) { keir@20512: fscanf(f, "0x%x 0x%x 0x%x", &start, &end, &flags); keir@20482: size = end - start + 1; keir@20482: if (start) { keir@20482: if (flags & PCI_BAR_IO) { keir@20482: rc = xc_domain_ioport_permission(ctx->xch, domid, start, size, 1); keir@20482: if (rc < 0) keir@20512: XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "Error: xc_domain_ioport_permission error 0x%x/0x%x", start, size); keir@20482: } else { keir@20482: rc = xc_domain_iomem_permission(ctx->xch, domid, start>>XC_PAGE_SHIFT, keir@20482: (size+(XC_PAGE_SIZE-1))>>XC_PAGE_SHIFT, 1); keir@20482: if (rc < 0) keir@20512: XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "Error: xc_domain_iomem_permission error 0x%x/0x%x", start, size); keir@20482: } keir@20482: } keir@20482: } keir@20482: fclose(f); keir@20542: sysfs_path = libxl_sprintf(ctx, SYSFS_PCI_DEV"/"PCI_BDF"/irq", pcidev->domain, keir@20482: pcidev->bus, pcidev->dev, pcidev->func); keir@20482: f = fopen(sysfs_path, "r"); keir@20482: if (f == NULL) { keir@20512: XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "Couldn't open %s", sysfs_path); keir@20482: goto out; keir@20482: } keir@20482: fscanf(f, "%u", &irq); keir@20482: if (irq) { keir@20482: rc = xc_physdev_map_pirq(ctx->xch, domid, irq, &irq); keir@20482: if (rc < 0) { keir@20512: XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "Error: xc_physdev_map_pirq irq=%d", irq); keir@20482: } keir@20482: rc = xc_domain_irq_permission(ctx->xch, domid, irq, 1); keir@20482: if (rc < 0) { keir@20512: XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "Error: xc_domain_irq_permission irq=%d", irq); keir@20482: } keir@20482: } keir@20482: fclose(f); keir@20482: } keir@20482: out: keir@20542: if (!libxl_is_stubdom(ctx, domid)) { keir@20779: rc = xc_assign_device(ctx->xch, domid, pcidev->value); keir@20779: if (rc < 0) keir@20542: XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "xc_assign_device failed"); keir@20542: } keir@20482: keir@20482: libxl_device_pci_add_xenstore(ctx, domid, pcidev); keir@20482: return 0; keir@20462: } keir@20462: keir@20482: int libxl_device_pci_remove(struct libxl_ctx *ctx, uint32_t domid, libxl_device_pci *pcidev) keir@20462: { keir@20779: char *path; keir@20482: char *state; keir@20482: int hvm, rc; keir@20542: int stubdomid = 0; keir@20482: keir@20482: /* TODO: check if the device can be detached */ keir@20542: libxl_device_pci_remove_xenstore(ctx, domid, pcidev); keir@20482: keir@20482: hvm = is_hvm(ctx, domid); keir@20482: if (hvm) { keir@20514: if (libxl_wait_for_device_model(ctx, domid, "running", 0,0) < 0) { keir@20482: return -1; keir@20482: } keir@20779: path = libxl_sprintf(ctx, "/local/domain/0/device-model/%d/state", domid); keir@20482: state = libxl_xs_read(ctx, XBT_NULL, path); keir@20779: path = libxl_sprintf(ctx, "/local/domain/0/device-model/%d/parameter", domid); keir@20482: libxl_xs_write(ctx, XBT_NULL, path, PCI_BDF, pcidev->domain, keir@20482: pcidev->bus, pcidev->dev, pcidev->func); keir@20779: path = libxl_sprintf(ctx, "/local/domain/0/device-model/%d/command", domid); keir@20482: xs_write(ctx->xsh, XBT_NULL, path, "pci-rem", strlen("pci-rem")); keir@20514: if (libxl_wait_for_device_model(ctx, domid, "pci-removed", 0,0) < 0) { keir@20512: XL_LOG(ctx, XL_LOG_ERROR, "Device Model didn't respond in time"); keir@20482: return -1; keir@20482: } keir@20779: path = libxl_sprintf(ctx, "/local/domain/0/device-model/%d/state", domid); keir@20482: xs_write(ctx->xsh, XBT_NULL, path, state, strlen(state)); keir@20482: } else { keir@20542: char *sysfs_path = libxl_sprintf(ctx, SYSFS_PCI_DEV"/"PCI_BDF"/resource", pcidev->domain, keir@20482: pcidev->bus, pcidev->dev, pcidev->func); keir@20482: FILE *f = fopen(sysfs_path, "r"); keir@20482: unsigned int start = 0, end = 0, flags = 0, size = 0; keir@20482: int irq = 0; keir@20482: int i; keir@20482: keir@20482: if (f == NULL) { keir@20512: XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "Couldn't open %s", sysfs_path); keir@20482: goto skip1; keir@20482: } keir@20482: for (i = 0; i < PROC_PCI_NUM_RESOURCES; i++) { keir@20482: fscanf(f, "0x%x 0x%x 0x%x\n", &start, &end, &flags); keir@20482: size = end - start + 1; keir@20482: if (start) { keir@20482: if (flags & PCI_BAR_IO) { keir@20482: rc = xc_domain_ioport_permission(ctx->xch, domid, start, size, 0); keir@20482: if (rc < 0) keir@20512: XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "xc_domain_ioport_permission error 0x%x/0x%x", start, size); keir@20482: } else { keir@20482: rc = xc_domain_iomem_permission(ctx->xch, domid, start>>XC_PAGE_SHIFT, keir@20482: (size+(XC_PAGE_SIZE-1))>>XC_PAGE_SHIFT, 0); keir@20482: if (rc < 0) keir@20512: XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "xc_domain_iomem_permission error 0x%x/0x%x", start, size); keir@20482: } keir@20482: } keir@20482: } keir@20482: fclose(f); keir@20482: skip1: keir@20542: sysfs_path = libxl_sprintf(ctx, SYSFS_PCI_DEV"/"PCI_BDF"/irq", pcidev->domain, keir@20482: pcidev->bus, pcidev->dev, pcidev->func); keir@20482: f = fopen(sysfs_path, "r"); keir@20482: if (f == NULL) { keir@20512: XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "Couldn't open %s", sysfs_path); keir@20482: goto out; keir@20482: } keir@20482: fscanf(f, "%u", &irq); keir@20482: if (irq) { keir@20482: rc = xc_physdev_unmap_pirq(ctx->xch, domid, irq); keir@20482: if (rc < 0) { keir@20512: XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "xc_physdev_map_pirq irq=%d", irq); keir@20482: } keir@20482: rc = xc_domain_irq_permission(ctx->xch, domid, irq, 0); keir@20482: if (rc < 0) { keir@20512: XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "xc_domain_irq_permission irq=%d", irq); keir@20482: } keir@20482: } keir@20482: fclose(f); keir@20482: } keir@20482: out: keir@20482: libxl_device_pci_flr(ctx, pcidev->domain, pcidev->bus, pcidev->dev, pcidev->func); keir@20482: keir@20542: if (!libxl_is_stubdom(ctx, domid)) { keir@20779: rc = xc_deassign_device(ctx->xch, domid, pcidev->value); keir@20779: if (rc < 0) keir@20542: XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "xc_deassign_device failed"); keir@20542: } keir@20542: keir@20779: stubdomid = libxl_get_stubdom_id(ctx, domid); keir@20779: if (stubdomid != 0) { keir@20542: libxl_device_pci pcidev_s = *pcidev; keir@20542: libxl_device_pci_remove(ctx, stubdomid, &pcidev_s); keir@20542: } keir@20542: keir@20482: return 0; keir@20462: } keir@20482: keir@20482: libxl_device_pci *libxl_device_pci_list(struct libxl_ctx *ctx, uint32_t domid, int *num) keir@20482: { keir@20482: char *be_path, *num_devs, *xsdev, *xsvdevfn, *xsopts; keir@20482: int n, i; keir@20482: unsigned int domain = 0, bus = 0, dev = 0, func = 0, vdevfn = 0; keir@20482: libxl_device_pci *pcidevs; keir@20482: keir@20516: be_path = libxl_sprintf(ctx, "%s/backend/pci/%d/0", libxl_xs_get_dompath(ctx, 0), domid); keir@20482: num_devs = libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/num_devs", be_path)); keir@20482: if (!num_devs) { keir@20482: *num = 0; keir@20482: return NULL; keir@20482: } keir@20482: n = atoi(num_devs); keir@20779: pcidevs = calloc(n, sizeof(libxl_device_pci)); keir@20482: *num = n; keir@20482: keir@20482: for (i = 0; i < n; i++) { keir@20482: xsdev = libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/dev-%d", be_path, i)); keir@20482: sscanf(xsdev, PCI_BDF, &domain, &bus, &dev, &func); keir@20482: xsvdevfn = libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/vdevfn-%d", be_path, i)); keir@20482: if (xsvdevfn) keir@20482: vdevfn = strtol(xsvdevfn, (char **) NULL, 16); keir@20482: libxl_device_pci_init(pcidevs + i, domain, bus, dev, func, vdevfn); keir@20482: xsopts = libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/opts-%d", be_path, i)); keir@20482: if (xsopts) { keir@20482: char *saveptr; keir@20482: char *p = strtok_r(xsopts, ",=", &saveptr); keir@20482: do { keir@20482: while (*p == ' ') keir@20482: p++; keir@20482: if (!strcmp(p, "msitranslate")) { keir@20482: p = strtok_r(NULL, ",=", &saveptr); keir@20482: pcidevs[i].msitranslate = atoi(p); keir@20482: } else if (!strcmp(p, "power_mgmt")) { keir@20482: p = strtok_r(NULL, ",=", &saveptr); keir@20482: pcidevs[i].power_mgmt = atoi(p); keir@20482: } keir@20482: } while ((p = strtok_r(NULL, ",=", &saveptr)) != NULL); keir@20482: } keir@20482: } keir@20482: return pcidevs; keir@20482: } keir@20482: keir@20482: int libxl_device_pci_shutdown(struct libxl_ctx *ctx, uint32_t domid) keir@20482: { keir@20482: libxl_device_pci *pcidevs; keir@20482: int num, i; keir@20482: keir@20482: pcidevs = libxl_device_pci_list(ctx, domid, &num); keir@20482: for (i = 0; i < num; i++) { keir@20482: if (libxl_device_pci_remove(ctx, domid, pcidevs + i) < 0) keir@20482: return -1; keir@20482: } keir@20516: free(pcidevs); keir@20482: return 0; keir@20482: } keir@20482: keir@20542: void nic_info_domid_fixup(libxl_device_nic *nic_info, int domid) keir@20542: { keir@20542: nic_info->domid = domid; keir@20542: asprintf(&(nic_info->ifname), "tap%d.%d", domid, nic_info->devid - 1); keir@20542: } keir@20542: keir@20542: void disk_info_domid_fixup(libxl_device_disk *disk_info, int domid) keir@20542: { keir@20542: disk_info->domid = domid; keir@20542: } keir@20542: keir@20542: void vfb_info_domid_fixup(libxl_device_vfb *vfb, int domid) keir@20542: { keir@20542: vfb->domid = domid; keir@20542: } keir@20542: keir@20542: void vkb_info_domid_fixup(libxl_device_vkb *vkb, int domid) keir@20542: { keir@20542: vkb->domid = domid; keir@20542: } keir@20542: keir@20542: void console_info_domid_fixup(libxl_device_console *console, int domid) keir@20542: { keir@20542: console->domid = domid; keir@20542: } keir@20542: keir@20542: void device_model_info_domid_fixup(libxl_device_model_info *dm_info, int domid) keir@20542: { keir@20542: dm_info->domid = domid; keir@20542: } keir@20542: keir@20542: void init_create_info(libxl_domain_create_info *c_info) keir@20542: { keir@20542: memset(c_info, '\0', sizeof(*c_info)); keir@20542: c_info->xsdata = NULL; keir@20542: c_info->platformdata = NULL; keir@20542: c_info->hvm = 1; keir@20542: c_info->ssidref = 0; keir@20542: } keir@20542: keir@20542: void init_build_info(libxl_domain_build_info *b_info, libxl_domain_create_info *c_info) keir@20542: { keir@20542: memset(b_info, '\0', sizeof(*b_info)); keir@20542: b_info->timer_mode = -1; keir@20542: b_info->hpet = 1; keir@20542: b_info->vpt_align = -1; keir@20542: b_info->max_vcpus = 1; keir@20542: b_info->max_memkb = 32 * 1024; keir@20647: b_info->target_memkb = b_info->max_memkb; keir@20542: if (c_info->hvm) { keir@20542: b_info->shadow_memkb = libxl_get_required_shadow_memory(b_info->max_memkb, b_info->max_vcpus); keir@20542: b_info->video_memkb = 8 * 1024; keir@20542: b_info->kernel = "/usr/lib/xen/boot/hvmloader"; keir@20542: b_info->hvm = 1; keir@20542: b_info->u.hvm.pae = 1; keir@20542: b_info->u.hvm.apic = 1; keir@20542: b_info->u.hvm.acpi = 1; keir@20542: b_info->u.hvm.nx = 1; keir@20542: b_info->u.hvm.viridian = 0; keir@20632: } else { keir@20632: b_info->u.pv.slack_memkb = 8 * 1024; keir@20542: } keir@20542: } keir@20542: keir@20542: void init_dm_info(libxl_device_model_info *dm_info, keir@20542: libxl_domain_create_info *c_info, libxl_domain_build_info *b_info) keir@20542: { keir@20542: memset(dm_info, '\0', sizeof(*dm_info)); keir@20542: keir@20542: dm_info->dom_name = c_info->name; keir@20542: dm_info->device_model = "/usr/lib/xen/bin/qemu-dm"; keir@20542: dm_info->videoram = b_info->video_memkb / 1024; keir@20542: dm_info->apic = b_info->u.hvm.apic; keir@20542: keir@20542: dm_info->stdvga = 0; keir@20542: dm_info->vnc = 1; keir@20542: dm_info->vnclisten = "127.0.0.1"; keir@20542: dm_info->vncdisplay = 0; keir@20542: dm_info->vncunused = 0; keir@20542: dm_info->keymap = NULL; keir@20542: dm_info->sdl = 0; keir@20542: dm_info->opengl = 0; keir@20542: dm_info->nographic = 0; keir@20542: dm_info->serial = NULL; keir@20542: dm_info->boot = "cda"; keir@20542: dm_info->usb = 0; keir@20542: dm_info->usbdevice = NULL; keir@20542: } keir@20542: keir@20542: void init_nic_info(libxl_device_nic *nic_info, int devnum) keir@20542: { keir@20542: memset(nic_info, '\0', sizeof(*nic_info)); keir@20542: keir@20542: keir@20542: nic_info->backend_domid = 0; keir@20542: nic_info->domid = 0; keir@20542: nic_info->devid = devnum; keir@20542: nic_info->mtu = 1492; keir@20542: nic_info->model = "e1000"; keir@20542: srand(time(0)); keir@20542: nic_info->mac[0] = 0x00; keir@20542: nic_info->mac[1] = 0x16; keir@20542: nic_info->mac[2] = 0x3e; keir@20542: nic_info->mac[3] = 1 + (int) (0x7f * (rand() / (RAND_MAX + 1.0))); keir@20542: nic_info->mac[4] = 1 + (int) (0xff * (rand() / (RAND_MAX + 1.0))); keir@20542: nic_info->mac[5] = 1 + (int) (0xff * (rand() / (RAND_MAX + 1.0))); keir@20542: asprintf(&(nic_info->smac), "%02x:%02x:%02x:%02x:%02x:%02x", nic_info->mac[0], nic_info->mac[1], nic_info->mac[2], nic_info->mac[3], nic_info->mac[4], nic_info->mac[5]); keir@20542: nic_info->ifname = NULL; keir@20542: nic_info->bridge = "xenbr0"; keir@20542: nic_info->script = "/etc/xen/scripts/vif-bridge"; keir@20542: nic_info->nictype = NICTYPE_IOEMU; keir@20542: } keir@20542: keir@20542: void init_vfb_info(libxl_device_vfb *vfb, int dev_num) keir@20542: { keir@20542: memset(vfb, 0x00, sizeof(libxl_device_vfb)); keir@20542: vfb->devid = dev_num; keir@20542: vfb->vnc = 1; keir@20542: vfb->vnclisten = "127.0.0.1"; keir@20542: vfb->vncdisplay = 0; keir@20542: vfb->vncunused = 1; keir@20542: vfb->keymap = NULL; keir@20542: vfb->sdl = 0; keir@20542: vfb->opengl = 0; keir@20542: } keir@20542: keir@20542: void init_vkb_info(libxl_device_vkb *vkb, int dev_num) keir@20542: { keir@20542: memset(vkb, 0x00, sizeof(libxl_device_vkb)); keir@20542: vkb->devid = dev_num; keir@20542: } keir@20542: keir@20542: void init_console_info(libxl_device_console *console, int dev_num, libxl_domain_build_state *state) keir@20542: { keir@20542: memset(console, 0x00, sizeof(libxl_device_console)); keir@20542: console->devid = dev_num; keir@20542: console->constype = CONSTYPE_XENCONSOLED; keir@20542: if (state) keir@20542: console->build_state = state; keir@20542: } keir@20542: keir@20647: int libxl_set_memory_target(struct libxl_ctx *ctx, uint32_t domid, uint32_t target_memkb) keir@20647: { keir@20647: int rc = 0; keir@20647: uint32_t videoram; keir@20647: char *videoram_s = NULL; keir@20647: char *dompath = libxl_xs_get_dompath(ctx, domid); keir@20542: keir@20647: videoram_s = libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/memory/videoram", dompath)); keir@20647: if (!videoram_s) keir@20647: return -1; keir@20647: videoram = atoi(videoram_s); keir@20647: keir@20647: libxl_xs_write(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/memory/target", dompath), "%lu", target_memkb); keir@20779: rc = xc_domain_setmaxmem(ctx->xch, domid, target_memkb + LIBXL_MAXMEM_CONSTANT); keir@20779: if (rc != 0) keir@20779: return rc; keir@20647: rc = xc_domain_memory_set_pod_target(ctx->xch, domid, (target_memkb - videoram) / 4, NULL, NULL, NULL); keir@20647: return rc; keir@20647: } keir@20647: keir@20647: