debuggers.hg
annotate tools/libxl/libxl.c @ 20594:fef6d531f04f
libxenlight: wait for pv qemu initialization
this patch makes libxl_create_stubdom wait for pv qemu to be properly
initialized before unpausing the stubdom.
A new libxl_device_model_starting pointer is used to wait for pv qemu
initialization while the libxl_device_model_starting pointer given by
the user is initialized to a new structure with an empty for_spawn
member, because nothing that was spawn has to be waited for anymore.
Signed-off-by: Stefano Stabellini <stefano.stabellini@eu.citrix.com>
this patch makes libxl_create_stubdom wait for pv qemu to be properly
initialized before unpausing the stubdom.
A new libxl_device_model_starting pointer is used to wait for pv qemu
initialization while the libxl_device_model_starting pointer given by
the user is initialized to a new structure with an empty for_spawn
member, because nothing that was spawn has to be waited for anymore.
Signed-off-by: Stefano Stabellini <stefano.stabellini@eu.citrix.com>
author | Keir Fraser <keir.fraser@citrix.com> |
---|---|
date | Tue Dec 01 14:03:42 2009 +0000 (2009-12-01) |
parents | 72ad0f6bb3b6 |
children | 7183cd08d71b |
rev | line source |
---|---|
keir@20462 | 1 /* |
keir@20462 | 2 * Copyright (C) 2009 Citrix Ltd. |
keir@20462 | 3 * Author Vincent Hanquez <vincent.hanquez@eu.citrix.com> |
keir@20462 | 4 * Author Stefano Stabellini <stefano.stabellini@eu.citrix.com> |
keir@20462 | 5 * |
keir@20462 | 6 * This program is free software; you can redistribute it and/or modify |
keir@20462 | 7 * it under the terms of the GNU Lesser General Public License as published |
keir@20462 | 8 * by the Free Software Foundation; version 2.1 only. with the special |
keir@20462 | 9 * exception on linking described in file LICENSE. |
keir@20462 | 10 * |
keir@20462 | 11 * This program is distributed in the hope that it will be useful, |
keir@20462 | 12 * but WITHOUT ANY WARRANTY; without even the implied warranty of |
keir@20462 | 13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
keir@20462 | 14 * GNU Lesser General Public License for more details. |
keir@20462 | 15 */ |
keir@20462 | 16 |
keir@20513 | 17 #include "libxl_osdeps.h" |
keir@20513 | 18 |
keir@20462 | 19 #include <stdio.h> |
keir@20462 | 20 #include <string.h> |
keir@20462 | 21 #include <stdlib.h> |
keir@20462 | 22 #include <sys/types.h> |
keir@20462 | 23 #include <fcntl.h> |
keir@20462 | 24 #include <sys/select.h> |
keir@20514 | 25 #include <sys/wait.h> |
keir@20462 | 26 #include <signal.h> |
keir@20468 | 27 #include <unistd.h> /* for write, unlink and close */ |
keir@20509 | 28 #include <stdint.h> |
keir@20509 | 29 #include <inttypes.h> |
keir@20514 | 30 #include <assert.h> |
keir@20513 | 31 |
keir@20462 | 32 #include "libxl.h" |
keir@20462 | 33 #include "libxl_utils.h" |
keir@20462 | 34 #include "libxl_internal.h" |
keir@20462 | 35 #include "flexarray.h" |
keir@20462 | 36 |
keir@20462 | 37 int libxl_ctx_init(struct libxl_ctx *ctx) |
keir@20462 | 38 { |
keir@20462 | 39 memset(ctx, 0, sizeof(struct libxl_ctx)); |
keir@20462 | 40 ctx->alloc_maxsize = 256; |
keir@20462 | 41 ctx->alloc_ptrs = calloc(ctx->alloc_maxsize, sizeof(void *)); |
keir@20462 | 42 if (!ctx->alloc_ptrs) |
keir@20462 | 43 return ERROR_NOMEM; |
keir@20462 | 44 |
keir@20462 | 45 ctx->xch = xc_interface_open(); |
keir@20462 | 46 ctx->xsh = xs_daemon_open(); |
keir@20514 | 47 |
keir@20514 | 48 ctx->waitpid_instead= libxl_waitpid_instead_default; |
keir@20462 | 49 return 0; |
keir@20462 | 50 } |
keir@20462 | 51 |
keir@20462 | 52 int libxl_ctx_free(struct libxl_ctx *ctx) |
keir@20462 | 53 { |
keir@20462 | 54 libxl_free_all(ctx); |
keir@20462 | 55 free(ctx->alloc_ptrs); |
keir@20545 | 56 ctx->alloc_ptrs = calloc(ctx->alloc_maxsize, sizeof(void *)); |
keir@20545 | 57 if (!ctx->alloc_ptrs) |
keir@20545 | 58 return ERROR_NOMEM; |
keir@20545 | 59 return 0; |
keir@20545 | 60 } |
keir@20545 | 61 |
keir@20545 | 62 int libxl_ctx_close(struct libxl_ctx *ctx) |
keir@20545 | 63 { |
keir@20545 | 64 libxl_ctx_free(ctx); |
keir@20545 | 65 free(ctx->alloc_ptrs); |
keir@20462 | 66 xc_interface_close(ctx->xch); |
keir@20545 | 67 xs_daemon_close(ctx->xsh); |
keir@20462 | 68 return 0; |
keir@20462 | 69 } |
keir@20462 | 70 |
keir@20462 | 71 int libxl_ctx_set_log(struct libxl_ctx *ctx, libxl_log_callback log_callback, void *log_data) |
keir@20462 | 72 { |
keir@20462 | 73 ctx->log_callback = log_callback; |
keir@20462 | 74 ctx->log_userdata = log_data; |
keir@20462 | 75 return 0; |
keir@20462 | 76 } |
keir@20462 | 77 |
keir@20462 | 78 /******************************************************************************/ |
keir@20462 | 79 |
keir@20462 | 80 int libxl_domain_make(struct libxl_ctx *ctx, libxl_domain_create_info *info, |
keir@20462 | 81 uint32_t *domid) |
keir@20462 | 82 { |
keir@20462 | 83 int flags, ret, i; |
keir@20468 | 84 char *uuid_string; |
keir@20583 | 85 char *rw_paths[] = { "device", "device/suspend/event-channel" }; |
keir@20462 | 86 char *ro_paths[] = { "cpu", "memory", "device", "error", "drivers", |
keir@20462 | 87 "control", "attr", "data", "messages" }; |
keir@20462 | 88 char *dom_path, *vm_path, *vss_path; |
keir@20462 | 89 struct xs_permissions roperm[2]; |
keir@20462 | 90 struct xs_permissions rwperm[1]; |
keir@20462 | 91 xs_transaction_t t; |
keir@20468 | 92 xen_domain_handle_t handle; |
keir@20462 | 93 |
keir@20468 | 94 uuid_string = libxl_uuid_to_string(ctx, info->uuid); |
keir@20462 | 95 if (!uuid_string) { |
keir@20462 | 96 XL_LOG(ctx, XL_LOG_ERROR, "missing uuid"); |
keir@20462 | 97 return ERROR_FAIL; |
keir@20462 | 98 } |
keir@20462 | 99 |
keir@20462 | 100 flags = info->hvm ? XEN_DOMCTL_CDF_hvm_guest : 0; |
keir@20462 | 101 flags |= info->hap ? XEN_DOMCTL_CDF_hap : 0; |
keir@20462 | 102 *domid = 0; |
keir@20462 | 103 |
keir@20580 | 104 /* |
keir@20468 | 105 * info->uuid != xen_domain_handle_t |
keir@20468 | 106 * See: |
keir@20468 | 107 * http://www.opengroup.org/dce/info/draft-leach-uuids-guids-01.txt |
keir@20468 | 108 * http://www.opengroup.org/onlinepubs/009629399/apdxa.htm |
keir@20468 | 109 * |
keir@20468 | 110 * A DCE 1.1 compatible source representation of UUIDs. |
keir@20468 | 111 * |
keir@20468 | 112 * struct uuid { |
keir@20468 | 113 * uint32_t time_low; |
keir@20468 | 114 * uint16_t time_mid; |
keir@20468 | 115 * uint16_t time_hi_and_version; |
keir@20468 | 116 * uint8_t clock_seq_hi_and_reserved; |
keir@20468 | 117 * uint8_t clock_seq_low; |
keir@20468 | 118 * uint8_t node[_UUID_NODE_LEN]; |
keir@20468 | 119 * }; |
keir@20468 | 120 */ |
keir@20580 | 121 /* Ultimately, handle is an array of 16 uint8_t, same as uuid */ |
keir@20580 | 122 memcpy(handle, info->uuid, sizeof(xen_domain_handle_t)); |
keir@20468 | 123 |
keir@20468 | 124 ret = xc_domain_create(ctx->xch, info->ssidref, handle, flags, domid); |
keir@20462 | 125 if (ret < 0) { |
keir@20512 | 126 XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, ret, "domain creation fail"); |
keir@20462 | 127 return ERROR_FAIL; |
keir@20462 | 128 } |
keir@20462 | 129 |
keir@20462 | 130 dom_path = libxl_xs_get_dompath(ctx, *domid); |
keir@20512 | 131 if (!dom_path) |
keir@20512 | 132 return ERROR_FAIL; |
keir@20512 | 133 |
keir@20462 | 134 vm_path = libxl_sprintf(ctx, "/vm/%s", uuid_string); |
keir@20462 | 135 vss_path = libxl_sprintf(ctx, "/vss/%s", uuid_string); |
keir@20512 | 136 if (!vm_path || !vss_path) { |
keir@20462 | 137 XL_LOG(ctx, XL_LOG_ERROR, "cannot allocate create paths"); |
keir@20462 | 138 return ERROR_FAIL; |
keir@20462 | 139 } |
keir@20462 | 140 |
keir@20462 | 141 roperm[0].id = 0; |
keir@20462 | 142 roperm[0].perms = XS_PERM_NONE; |
keir@20462 | 143 roperm[1].id = *domid; |
keir@20462 | 144 roperm[1].perms = XS_PERM_READ; |
keir@20462 | 145 rwperm[0].id = *domid; |
keir@20462 | 146 rwperm[0].perms = XS_PERM_NONE; |
keir@20462 | 147 |
keir@20462 | 148 retry_transaction: |
keir@20462 | 149 t = xs_transaction_start(ctx->xsh); |
keir@20462 | 150 xs_rm(ctx->xsh, t, dom_path); |
keir@20462 | 151 xs_mkdir(ctx->xsh, t, dom_path); |
keir@20462 | 152 xs_set_permissions(ctx->xsh, t, dom_path, roperm, ARRAY_SIZE(roperm)); |
keir@20462 | 153 |
keir@20462 | 154 xs_rm(ctx->xsh, t, vm_path); |
keir@20462 | 155 xs_mkdir(ctx->xsh, t, vm_path); |
keir@20462 | 156 xs_set_permissions(ctx->xsh, t, vm_path, roperm, ARRAY_SIZE(roperm)); |
keir@20462 | 157 |
keir@20462 | 158 xs_rm(ctx->xsh, t, vss_path); |
keir@20462 | 159 xs_mkdir(ctx->xsh, t, vss_path); |
keir@20462 | 160 xs_set_permissions(ctx->xsh, t, vss_path, rwperm, ARRAY_SIZE(rwperm)); |
keir@20462 | 161 |
keir@20462 | 162 xs_write(ctx->xsh, t, libxl_sprintf(ctx, "%s/vm", dom_path), vm_path, strlen(vm_path)); |
keir@20462 | 163 xs_write(ctx->xsh, t, libxl_sprintf(ctx, "%s/vss", dom_path), vss_path, strlen(vss_path)); |
keir@20462 | 164 xs_write(ctx->xsh, t, libxl_sprintf(ctx, "%s/name", dom_path), info->name, strlen(info->name)); |
keir@20462 | 165 |
keir@20462 | 166 for (i = 0; i < ARRAY_SIZE(rw_paths); i++) { |
keir@20462 | 167 char *path = libxl_sprintf(ctx, "%s/%s", dom_path, rw_paths[i]); |
keir@20462 | 168 xs_mkdir(ctx->xsh, t, path); |
keir@20462 | 169 xs_set_permissions(ctx->xsh, t, path, rwperm, ARRAY_SIZE(rwperm)); |
keir@20462 | 170 libxl_free(ctx, path); |
keir@20462 | 171 } |
keir@20462 | 172 for (i = 0; i < ARRAY_SIZE(ro_paths); i++) { |
keir@20462 | 173 char *path = libxl_sprintf(ctx, "%s/%s", dom_path, ro_paths[i]); |
keir@20462 | 174 xs_mkdir(ctx->xsh, t, path); |
keir@20462 | 175 xs_set_permissions(ctx->xsh, t, path, roperm, ARRAY_SIZE(roperm)); |
keir@20462 | 176 libxl_free(ctx, path); |
keir@20462 | 177 } |
keir@20462 | 178 |
keir@20462 | 179 xs_write(ctx->xsh, t, libxl_sprintf(ctx, "%s/uuid", vm_path), uuid_string, strlen(uuid_string)); |
keir@20462 | 180 xs_write(ctx->xsh, t, libxl_sprintf(ctx, "%s/name", vm_path), info->name, strlen(info->name)); |
keir@20462 | 181 |
keir@20462 | 182 libxl_xs_writev(ctx, t, dom_path, info->xsdata); |
keir@20462 | 183 libxl_xs_writev(ctx, t, libxl_sprintf(ctx, "%s/platform", dom_path), info->platformdata); |
keir@20462 | 184 |
keir@20462 | 185 xs_write(ctx->xsh, t, libxl_sprintf(ctx, "%s/control/platform-feature-multiprocessor-suspend", dom_path), "1", 1); |
keir@20462 | 186 |
keir@20462 | 187 if (!xs_transaction_end(ctx->xsh, t, 0)) |
keir@20462 | 188 if (errno == EAGAIN) |
keir@20462 | 189 goto retry_transaction; |
keir@20462 | 190 return 0; |
keir@20462 | 191 } |
keir@20462 | 192 |
keir@20516 | 193 int libxl_domain_build(struct libxl_ctx *ctx, libxl_domain_build_info *info, uint32_t domid, libxl_domain_build_state *state) |
keir@20462 | 194 { |
keir@20462 | 195 char **vments = NULL, **localents = NULL; |
keir@20578 | 196 int i; |
keir@20462 | 197 |
keir@20509 | 198 build_pre(ctx, domid, info, state); |
keir@20462 | 199 if (info->hvm) { |
keir@20509 | 200 build_hvm(ctx, domid, info, state); |
keir@20509 | 201 vments = libxl_calloc(ctx, 5, sizeof(char *)); |
keir@20516 | 202 vments[0] = "rtc/timeoffset"; |
keir@20516 | 203 vments[1] = (info->u.hvm.timeoffset) ? info->u.hvm.timeoffset : ""; |
keir@20516 | 204 vments[2] = "image/ostype"; |
keir@20516 | 205 vments[3] = "hvm"; |
keir@20462 | 206 } else { |
keir@20509 | 207 build_pv(ctx, domid, info, state); |
keir@20509 | 208 vments = libxl_calloc(ctx, 9, sizeof(char *)); |
keir@20578 | 209 i = 0; |
keir@20578 | 210 vments[i++] = "image/ostype"; |
keir@20578 | 211 vments[i++] = "linux"; |
keir@20578 | 212 vments[i++] = "image/kernel"; |
keir@20578 | 213 vments[i++] = (char*) info->kernel; |
keir@20578 | 214 if (info->u.pv.ramdisk) { |
keir@20578 | 215 vments[i++] = "image/ramdisk"; |
keir@20578 | 216 vments[i++] = (char*) info->u.pv.ramdisk; |
keir@20578 | 217 } |
keir@20578 | 218 if (info->u.pv.cmdline) { |
keir@20578 | 219 vments[i++] = "image/cmdline"; |
keir@20578 | 220 vments[i++] = (char*) info->u.pv.cmdline; |
keir@20578 | 221 } |
keir@20462 | 222 } |
keir@20509 | 223 build_post(ctx, domid, info, state, vments, localents); |
keir@20516 | 224 return 0; |
keir@20462 | 225 } |
keir@20462 | 226 |
keir@20462 | 227 int libxl_domain_restore(struct libxl_ctx *ctx, libxl_domain_build_info *info, |
keir@20565 | 228 uint32_t domid, int fd, libxl_domain_build_state *state, |
keir@20565 | 229 libxl_device_model_info *dm_info) |
keir@20462 | 230 { |
keir@20462 | 231 char **vments = NULL, **localents = NULL; |
keir@20462 | 232 |
keir@20565 | 233 build_pre(ctx, domid, info, state); |
keir@20565 | 234 restore_common(ctx, domid, info, state, fd); |
keir@20462 | 235 if (info->hvm) { |
keir@20565 | 236 vments = libxl_calloc(ctx, 5, sizeof(char *)); |
keir@20516 | 237 vments[0] = "rtc/timeoffset"; |
keir@20516 | 238 vments[1] = (info->u.hvm.timeoffset) ? info->u.hvm.timeoffset : ""; |
keir@20565 | 239 vments[2] = "image/ostype"; |
keir@20565 | 240 vments[3] = "hvm"; |
keir@20462 | 241 } else { |
keir@20565 | 242 vments = libxl_calloc(ctx, 9, sizeof(char *)); |
keir@20565 | 243 vments[0] = "image/ostype"; |
keir@20565 | 244 vments[1] = "linux"; |
keir@20565 | 245 vments[2] = "image/kernel"; |
keir@20565 | 246 vments[3] = (char*) info->kernel; |
keir@20565 | 247 vments[4] = "image/ramdisk"; |
keir@20565 | 248 vments[5] = (char*) info->u.pv.ramdisk; |
keir@20565 | 249 vments[6] = "image/cmdline"; |
keir@20565 | 250 vments[7] = (char*) info->u.pv.cmdline; |
keir@20462 | 251 } |
keir@20565 | 252 build_post(ctx, domid, info, state, vments, localents); |
keir@20565 | 253 if (info->hvm) |
keir@20565 | 254 asprintf(&(dm_info->saved_state), "/var/lib/xen/qemu-save.%d", domid); |
keir@20565 | 255 else |
keir@20565 | 256 dm_info->saved_state = NULL; |
keir@20565 | 257 |
keir@20462 | 258 return 0; |
keir@20462 | 259 } |
keir@20462 | 260 |
keir@20462 | 261 struct libxl_dominfo * libxl_domain_list(struct libxl_ctx *ctx, int *nb_domain) |
keir@20462 | 262 { |
keir@20462 | 263 struct libxl_dominfo *ptr; |
keir@20462 | 264 int index, i, ret, first_domain; |
keir@20462 | 265 xc_domaininfo_t info[16]; |
keir@20462 | 266 int size = 16; |
keir@20462 | 267 |
keir@20462 | 268 first_domain = 1; |
keir@20462 | 269 index = 0; |
keir@20516 | 270 ptr = calloc(size, sizeof(struct libxl_dominfo)); |
keir@20462 | 271 if (!ptr) |
keir@20462 | 272 return NULL; |
keir@20462 | 273 redo: |
keir@20462 | 274 ret = xc_domain_getinfolist(ctx->xch, first_domain, 16, info); |
keir@20462 | 275 for (i = 0; i < ret; i++) { |
keir@20462 | 276 if (index == size) { |
keir@20462 | 277 struct libxl_dominfo *ptr2; |
keir@20462 | 278 |
keir@20516 | 279 ptr2 = calloc(size * 2, sizeof(struct libxl_dominfo)); |
keir@20462 | 280 if (!ptr2) { |
keir@20516 | 281 free(ptr); |
keir@20462 | 282 return NULL; |
keir@20462 | 283 } |
keir@20462 | 284 memcpy(ptr2, ptr, sizeof(struct libxl_dominfo) * size); |
keir@20516 | 285 free(ptr); |
keir@20462 | 286 ptr = ptr2; |
keir@20462 | 287 size *= 2; |
keir@20462 | 288 } |
keir@20579 | 289 memcpy(&(ptr[index].uuid), info[i].handle, sizeof(xen_domain_handle_t)); |
keir@20462 | 290 ptr[index].domid = info[i].domain; |
keir@20462 | 291 first_domain = info[i].domain + 1; |
keir@20462 | 292 index++; |
keir@20462 | 293 } |
keir@20462 | 294 if (ret == 16) |
keir@20462 | 295 goto redo; |
keir@20462 | 296 *nb_domain = index; |
keir@20462 | 297 return ptr; |
keir@20462 | 298 } |
keir@20462 | 299 |
keir@20462 | 300 xc_dominfo_t * libxl_domain_infolist(struct libxl_ctx *ctx, int *nb_domain) |
keir@20462 | 301 { |
keir@20462 | 302 int index, first_domain; |
keir@20462 | 303 xc_dominfo_t *info; |
keir@20462 | 304 int size = 1024; |
keir@20462 | 305 |
keir@20462 | 306 first_domain = 0; |
keir@20462 | 307 index = 0; |
keir@20516 | 308 info = (xc_dominfo_t *) calloc(size, sizeof(xc_dominfo_t)); |
keir@20462 | 309 if (!info) { |
keir@20462 | 310 *nb_domain = 0; |
keir@20462 | 311 return NULL; |
keir@20462 | 312 } |
keir@20462 | 313 *nb_domain = xc_domain_getinfo(ctx->xch, first_domain, 1024, info); |
keir@20462 | 314 return info; |
keir@20462 | 315 } |
keir@20462 | 316 |
keir@20565 | 317 static int libxl_save_device_model(struct libxl_ctx *ctx, uint32_t domid, int fd) |
keir@20565 | 318 { |
keir@20565 | 319 int fd2, c; |
keir@20565 | 320 char buf[1024]; |
keir@20565 | 321 char *filename = libxl_sprintf(ctx, "/var/lib/xen/qemu-save.%d", domid); |
keir@20565 | 322 |
keir@20565 | 323 XL_LOG(ctx, XL_LOG_DEBUG, "Saving device model state to %s", filename); |
keir@20565 | 324 libxl_xs_write(ctx, XBT_NULL, libxl_sprintf(ctx, "/local/domain/0/device-model/%d/command", domid), "save", strlen("save")); |
keir@20565 | 325 libxl_wait_for_device_model(ctx, domid, "paused", NULL, NULL); |
keir@20565 | 326 |
keir@20565 | 327 write(fd, QEMU_SIGNATURE, strlen(QEMU_SIGNATURE)); |
keir@20565 | 328 fd2 = open(filename, O_RDONLY); |
keir@20565 | 329 while ((c = read(fd2, buf, sizeof(buf))) != 0) { |
keir@20565 | 330 write(fd, buf, c); |
keir@20565 | 331 } |
keir@20565 | 332 close(fd2); |
keir@20565 | 333 unlink(filename); |
keir@20565 | 334 return 0; |
keir@20565 | 335 } |
keir@20565 | 336 |
keir@20462 | 337 int libxl_domain_suspend(struct libxl_ctx *ctx, libxl_domain_suspend_info *info, |
keir@20462 | 338 uint32_t domid, int fd) |
keir@20462 | 339 { |
keir@20565 | 340 int hvm = is_hvm(ctx, domid); |
keir@20565 | 341 int live = info != NULL && info->flags & XL_SUSPEND_LIVE; |
keir@20565 | 342 int debug = info != NULL && info->flags & XL_SUSPEND_LIVE; |
keir@20462 | 343 |
keir@20462 | 344 |
keir@20462 | 345 core_suspend(ctx, domid, fd, hvm, live, debug); |
keir@20565 | 346 if (hvm) |
keir@20565 | 347 libxl_save_device_model(ctx, domid, fd); |
keir@20462 | 348 |
keir@20462 | 349 return 0; |
keir@20462 | 350 } |
keir@20462 | 351 |
keir@20462 | 352 int libxl_domain_pause(struct libxl_ctx *ctx, uint32_t domid) |
keir@20462 | 353 { |
keir@20462 | 354 xc_domain_pause(ctx->xch, domid); |
keir@20462 | 355 return 0; |
keir@20462 | 356 } |
keir@20462 | 357 |
keir@20462 | 358 int libxl_domain_unpause(struct libxl_ctx *ctx, uint32_t domid) |
keir@20462 | 359 { |
keir@20565 | 360 char path[50]; |
keir@20565 | 361 char *state; |
keir@20565 | 362 |
keir@20565 | 363 if (is_hvm(ctx, domid)) { |
keir@20565 | 364 snprintf(path, sizeof(path), "/local/domain/0/device-model/%d/state", domid); |
keir@20565 | 365 state = libxl_xs_read(ctx, XBT_NULL, path); |
keir@20565 | 366 if (state != NULL && !strcmp(state, "paused")) { |
keir@20565 | 367 libxl_xs_write(ctx, XBT_NULL, libxl_sprintf(ctx, "/local/domain/0/device-model/%d/command", domid), "continue", strlen("continue")); |
keir@20565 | 368 libxl_wait_for_device_model(ctx, domid, "running", NULL, NULL); |
keir@20565 | 369 } |
keir@20565 | 370 } |
keir@20462 | 371 xc_domain_unpause(ctx->xch, domid); |
keir@20565 | 372 |
keir@20462 | 373 return 0; |
keir@20462 | 374 } |
keir@20462 | 375 |
keir@20462 | 376 static char *req_table[] = { |
keir@20462 | 377 [0] = "poweroff", |
keir@20462 | 378 [1] = "reboot", |
keir@20462 | 379 [2] = "suspend", |
keir@20462 | 380 [3] = "crash", |
keir@20462 | 381 [4] = "halt", |
keir@20462 | 382 }; |
keir@20462 | 383 |
keir@20462 | 384 int libxl_domain_shutdown(struct libxl_ctx *ctx, uint32_t domid, int req) |
keir@20462 | 385 { |
keir@20462 | 386 char *shutdown_path; |
keir@20462 | 387 char *dom_path; |
keir@20462 | 388 |
keir@20462 | 389 if (req > ARRAY_SIZE(req_table)) |
keir@20462 | 390 return ERROR_INVAL; |
keir@20462 | 391 |
keir@20462 | 392 dom_path = libxl_xs_get_dompath(ctx, domid); |
keir@20512 | 393 if (!dom_path) |
keir@20512 | 394 return ERROR_FAIL; |
keir@20512 | 395 |
keir@20462 | 396 shutdown_path = libxl_sprintf(ctx, "%s/control/shutdown", dom_path); |
keir@20462 | 397 |
keir@20462 | 398 xs_write(ctx->xsh, XBT_NULL, shutdown_path, req_table[req], strlen(req_table[req])); |
keir@20462 | 399 if (/* hvm */ 0) { |
keir@20462 | 400 unsigned long acpi_s_state = 0; |
keir@20462 | 401 unsigned long pvdriver = 0; |
keir@20462 | 402 xc_get_hvm_param(ctx->xch, domid, HVM_PARAM_ACPI_S_STATE, &acpi_s_state); |
keir@20462 | 403 xc_get_hvm_param(ctx->xch, domid, HVM_PARAM_CALLBACK_IRQ, &pvdriver); |
keir@20462 | 404 if (!pvdriver && acpi_s_state != 0) |
keir@20462 | 405 xc_domain_shutdown(ctx->xch, domid, req); |
keir@20462 | 406 } |
keir@20462 | 407 return 0; |
keir@20462 | 408 } |
keir@20462 | 409 |
keir@20545 | 410 int libxl_wait_for_domain_death(struct libxl_ctx *ctx, uint32_t domid, int *fd) |
keir@20545 | 411 { |
keir@20545 | 412 if (!xs_watch(ctx->xsh, "@releaseDomain", "domain_death")) |
keir@20545 | 413 return -1; |
keir@20545 | 414 *fd = xs_fileno(ctx->xsh); |
keir@20545 | 415 return 0; |
keir@20545 | 416 } |
keir@20545 | 417 |
keir@20545 | 418 int libxl_is_domain_dead(struct libxl_ctx *ctx, uint32_t domid, xc_dominfo_t *info) |
keir@20545 | 419 { |
keir@20545 | 420 unsigned int num; |
keir@20545 | 421 int nb_domain, i, rc = 0; |
keir@20545 | 422 char **vec = NULL; |
keir@20545 | 423 xc_dominfo_t *list = NULL; |
keir@20545 | 424 |
keir@20545 | 425 vec = xs_read_watch(ctx->xsh, &num); |
keir@20545 | 426 if (!vec) |
keir@20545 | 427 return 0; |
keir@20545 | 428 if (!strcmp(vec[XS_WATCH_TOKEN], "domain_death")) { |
keir@20545 | 429 list = libxl_domain_infolist(ctx, &nb_domain); |
keir@20545 | 430 for (i = 0; i < nb_domain; i++) { |
keir@20545 | 431 if (domid == list[i].domid) { |
keir@20545 | 432 if (list[i].running || (!list[i].shutdown && !list[i].crashed && !list[i].dying)) |
keir@20545 | 433 goto out; |
keir@20545 | 434 *info = list[i]; |
keir@20545 | 435 rc = 1; |
keir@20545 | 436 goto out; |
keir@20545 | 437 } |
keir@20545 | 438 } |
keir@20545 | 439 memset(info, 0x00, sizeof(xc_dominfo_t)); |
keir@20545 | 440 rc = 1; |
keir@20545 | 441 goto out; |
keir@20545 | 442 } |
keir@20545 | 443 |
keir@20545 | 444 out: |
keir@20545 | 445 free(list); |
keir@20545 | 446 free(vec); |
keir@20545 | 447 return rc; |
keir@20545 | 448 } |
keir@20545 | 449 |
keir@20462 | 450 static int libxl_destroy_device_model(struct libxl_ctx *ctx, uint32_t domid) |
keir@20462 | 451 { |
keir@20462 | 452 char *pid; |
keir@20462 | 453 int ret; |
keir@20462 | 454 |
keir@20462 | 455 pid = libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "/local/domain/%d/image/device-model-pid", domid)); |
keir@20462 | 456 if (!pid) { |
keir@20542 | 457 int stubdomid = libxl_get_stubdom_id(ctx, domid); |
keir@20542 | 458 if (!stubdomid) { |
keir@20542 | 459 XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "Couldn't find device model's pid"); |
keir@20542 | 460 return -1; |
keir@20542 | 461 } |
keir@20542 | 462 XL_LOG(ctx, XL_LOG_ERROR, "Device model is a stubdom, domid=%d\n", stubdomid); |
keir@20542 | 463 return libxl_domain_destroy(ctx, stubdomid, 0); |
keir@20462 | 464 } |
keir@20462 | 465 xs_rm(ctx->xsh, XBT_NULL, libxl_sprintf(ctx, "/local/domain/0/device-model/%d", domid)); |
keir@20462 | 466 |
keir@20462 | 467 ret = kill(atoi(pid), SIGHUP); |
keir@20462 | 468 if (ret < 0 && errno == ESRCH) { |
keir@20512 | 469 XL_LOG(ctx, XL_LOG_DEBUG, "Device Model already exited"); |
keir@20462 | 470 ret = 0; |
keir@20462 | 471 } else if (ret == 0) { |
keir@20512 | 472 XL_LOG(ctx, XL_LOG_DEBUG, "Device Model signaled"); |
keir@20462 | 473 ret = 0; |
keir@20462 | 474 } else { |
keir@20512 | 475 XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "failed to kill Device Model [%d]", |
keir@20512 | 476 atoi(pid)); |
keir@20462 | 477 } |
keir@20462 | 478 return ret; |
keir@20462 | 479 } |
keir@20462 | 480 |
keir@20462 | 481 int libxl_domain_destroy(struct libxl_ctx *ctx, uint32_t domid, int force) |
keir@20462 | 482 { |
keir@20581 | 483 char *dom_path, *uuid_str; |
keir@20581 | 484 char vm_path[UUID_LEN_STR + 5], vss_path[UUID_LEN_STR + 6], xapi_path[20]; |
keir@20468 | 485 xen_uuid_t *uuid; |
keir@20512 | 486 int rc; |
keir@20462 | 487 |
keir@20462 | 488 dom_path = libxl_xs_get_dompath(ctx, domid); |
keir@20512 | 489 if (!dom_path) |
keir@20462 | 490 return -1; |
keir@20512 | 491 |
keir@20462 | 492 if (libxl_domid_to_uuid(ctx, &uuid, domid) < 0) { |
keir@20512 | 493 XL_LOG(ctx, XL_LOG_ERROR, "failed ot get uuid for %d", domid); |
keir@20462 | 494 return -1; |
keir@20462 | 495 } |
keir@20482 | 496 if (libxl_device_pci_shutdown(ctx, domid) < 0) |
keir@20512 | 497 XL_LOG(ctx, XL_LOG_ERROR, "pci shutdown failed for domid %d", domid); |
keir@20462 | 498 xs_write(ctx->xsh, XBT_NULL, |
keir@20462 | 499 libxl_sprintf(ctx, "/local/domain/0/device-model/%d/command", domid), |
keir@20462 | 500 "shutdown", strlen("shutdown")); |
keir@20512 | 501 rc = xc_domain_pause(ctx->xch, domid); |
keir@20512 | 502 if (rc < 0) { |
keir@20512 | 503 XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "xc_domain_pause failed for %d", domid); |
keir@20462 | 504 return -1; |
keir@20462 | 505 } |
keir@20542 | 506 if (libxl_destroy_device_model(ctx, domid) < 0) |
keir@20542 | 507 XL_LOG(ctx, XL_LOG_ERROR, "libxl_destroy_device_model failed for %d", domid); |
keir@20462 | 508 if (libxl_devices_destroy(ctx, domid, force) < 0) |
keir@20512 | 509 XL_LOG(ctx, XL_LOG_ERROR, "libxl_destroy_devices failed for %d", domid); |
keir@20462 | 510 if (!xs_rm(ctx->xsh, XBT_NULL, dom_path)) |
keir@20512 | 511 XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "xs_rm failed for %s", dom_path); |
keir@20581 | 512 uuid_str = libxl_uuid_to_string(ctx, uuid); |
keir@20581 | 513 snprintf(vm_path, sizeof(vm_path), "/vm/%s", uuid_str); |
keir@20462 | 514 if (!xs_rm(ctx->xsh, XBT_NULL, vm_path)) |
keir@20512 | 515 XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "xs_rm failed for %s", vm_path); |
keir@20581 | 516 snprintf(vss_path, sizeof(vss_path), "/vss/%s", uuid_str); |
keir@20581 | 517 if (!xs_rm(ctx->xsh, XBT_NULL, vss_path)) |
keir@20581 | 518 XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "xs_rm failed for %s", vss_path); |
keir@20581 | 519 libxl_free(ctx, uuid_str); |
keir@20581 | 520 snprintf(xapi_path, sizeof(xapi_path), "/xapi/%u", domid); |
keir@20581 | 521 if (!xs_rm(ctx->xsh, XBT_NULL, xapi_path)) |
keir@20581 | 522 XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "xs_rm failed for %s", xapi_path); |
keir@20545 | 523 rc = xc_domain_destroy(ctx->xch, domid); |
keir@20545 | 524 if (rc < 0) { |
keir@20545 | 525 XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "xc_domain_destroy failed for %d", domid); |
keir@20545 | 526 return -1; |
keir@20545 | 527 } |
keir@20462 | 528 return 0; |
keir@20462 | 529 } |
keir@20462 | 530 |
keir@20564 | 531 int libxl_console_attach(struct libxl_ctx *ctx, uint32_t domid, int cons_num) |
keir@20564 | 532 { |
keir@20564 | 533 struct stat st; |
keir@20564 | 534 const char *XENCONSOLE = "/usr/lib/xen/bin/xenconsole"; |
keir@20564 | 535 char *cmd; |
keir@20564 | 536 |
keir@20564 | 537 if (stat(XENCONSOLE, &st) != 0) { |
keir@20564 | 538 XL_LOG(ctx, XL_LOG_ERROR, "could not access %s", XENCONSOLE); |
keir@20564 | 539 return ERROR_FAIL; |
keir@20564 | 540 } |
keir@20564 | 541 |
keir@20564 | 542 cmd = libxl_sprintf(ctx, "%s %d --num %d", XENCONSOLE, domid, cons_num); |
keir@20564 | 543 return (system(cmd) != 0) ? ERROR_FAIL : 0; |
keir@20564 | 544 } |
keir@20564 | 545 |
keir@20462 | 546 static char ** libxl_build_device_model_args(struct libxl_ctx *ctx, |
keir@20462 | 547 libxl_device_model_info *info, |
keir@20462 | 548 libxl_device_nic *vifs, |
keir@20462 | 549 int num_vifs) |
keir@20462 | 550 { |
keir@20462 | 551 int num = 0, i; |
keir@20462 | 552 flexarray_t *dm_args; |
keir@20462 | 553 dm_args = flexarray_make(16, 1); |
keir@20462 | 554 if (!dm_args) |
keir@20462 | 555 return NULL; |
keir@20462 | 556 |
keir@20516 | 557 flexarray_set(dm_args, num++, "qemu-dm"); |
keir@20516 | 558 flexarray_set(dm_args, num++, "-d"); |
keir@20462 | 559 |
keir@20462 | 560 flexarray_set(dm_args, num++, libxl_sprintf(ctx, "%d", info->domid)); |
keir@20462 | 561 |
keir@20462 | 562 if (info->dom_name) { |
keir@20516 | 563 flexarray_set(dm_args, num++, "-domain-name"); |
keir@20516 | 564 flexarray_set(dm_args, num++, info->dom_name); |
keir@20462 | 565 } |
keir@20462 | 566 if (info->vnc || info->vncdisplay || info->vnclisten || info->vncunused) { |
keir@20516 | 567 flexarray_set(dm_args, num++, "-vnc"); |
keir@20462 | 568 if (info->vncdisplay) { |
keir@20462 | 569 if (info->vnclisten && strchr(info->vnclisten, ':') == NULL) { |
keir@20462 | 570 flexarray_set(dm_args, num++, libxl_sprintf(ctx, "%s:%d", info->vnclisten, info->vncdisplay)); |
keir@20462 | 571 } else { |
keir@20462 | 572 flexarray_set(dm_args, num++, libxl_sprintf(ctx, "127.0.0.1:%d", info->vncdisplay)); |
keir@20462 | 573 } |
keir@20462 | 574 } else if (info->vnclisten) { |
keir@20462 | 575 if (strchr(info->vnclisten, ':') != NULL) { |
keir@20516 | 576 flexarray_set(dm_args, num++, info->vnclisten); |
keir@20462 | 577 } else { |
keir@20462 | 578 flexarray_set(dm_args, num++, libxl_sprintf(ctx, "%s:0", info->vnclisten)); |
keir@20462 | 579 } |
keir@20462 | 580 } else { |
keir@20516 | 581 flexarray_set(dm_args, num++, "127.0.0.1:0"); |
keir@20462 | 582 } |
keir@20462 | 583 if (info->vncunused) { |
keir@20516 | 584 flexarray_set(dm_args, num++, "-vncunused"); |
keir@20462 | 585 } |
keir@20462 | 586 } |
keir@20462 | 587 if (info->sdl || info->opengl) { |
keir@20516 | 588 flexarray_set(dm_args, num++, "-sdl"); |
keir@20462 | 589 if (info->opengl) { |
keir@20516 | 590 flexarray_set(dm_args, num++, "-disable-opengl"); |
keir@20462 | 591 } |
keir@20462 | 592 } |
keir@20462 | 593 if (info->keymap) { |
keir@20516 | 594 flexarray_set(dm_args, num++, "-k"); |
keir@20516 | 595 flexarray_set(dm_args, num++, info->keymap); |
keir@20462 | 596 } |
keir@20462 | 597 if (info->nographic && (!info->sdl && !info->vnc)) { |
keir@20516 | 598 flexarray_set(dm_args, num++, "-nographic"); |
keir@20462 | 599 } |
keir@20462 | 600 if (info->serial) { |
keir@20516 | 601 flexarray_set(dm_args, num++, "-serial"); |
keir@20516 | 602 flexarray_set(dm_args, num++, info->serial); |
keir@20462 | 603 } |
keir@20509 | 604 if (info->type == XENFV) { |
keir@20509 | 605 if (info->videoram) { |
keir@20516 | 606 flexarray_set(dm_args, num++, "-videoram"); |
keir@20509 | 607 flexarray_set(dm_args, num++, libxl_sprintf(ctx, "%d", info->videoram)); |
keir@20509 | 608 } |
keir@20509 | 609 if (info->stdvga) { |
keir@20516 | 610 flexarray_set(dm_args, num++, "-std-vga"); |
keir@20509 | 611 } |
keir@20509 | 612 |
keir@20509 | 613 if (info->boot) { |
keir@20516 | 614 flexarray_set(dm_args, num++, "-boot"); |
keir@20516 | 615 flexarray_set(dm_args, num++, info->boot); |
keir@20509 | 616 } |
keir@20509 | 617 if (info->usb) { |
keir@20516 | 618 flexarray_set(dm_args, num++, "-usb"); |
keir@20509 | 619 if (info->usbdevice) { |
keir@20516 | 620 flexarray_set(dm_args, num++, "-usbdevice"); |
keir@20516 | 621 flexarray_set(dm_args, num++, info->usbdevice); |
keir@20509 | 622 } |
keir@20509 | 623 } |
keir@20509 | 624 if (info->apic) { |
keir@20516 | 625 flexarray_set(dm_args, num++, "-acpi"); |
keir@20509 | 626 } |
keir@20509 | 627 for (i = 0; i < num_vifs; i++) { |
keir@20509 | 628 if (vifs[i].nictype == NICTYPE_IOEMU) { |
keir@20516 | 629 flexarray_set(dm_args, num++, "-net"); |
keir@20509 | 630 flexarray_set(dm_args, num++, libxl_sprintf(ctx, "nic,vlan=%d,macaddr=%s,model=%s", |
keir@20509 | 631 vifs[i].devid, vifs[i].smac, vifs[i].model)); |
keir@20516 | 632 flexarray_set(dm_args, num++, "-net"); |
keir@20509 | 633 flexarray_set(dm_args, num++, libxl_sprintf(ctx, "tap,vlan=%d,ifname=%s,bridge=%s", |
keir@20509 | 634 vifs[i].devid, vifs[i].ifname, vifs[i].bridge)); |
keir@20509 | 635 } |
keir@20462 | 636 } |
keir@20462 | 637 } |
keir@20565 | 638 if (info->saved_state) { |
keir@20565 | 639 flexarray_set(dm_args, num++, "-loadvm"); |
keir@20565 | 640 flexarray_set(dm_args, num++, info->saved_state); |
keir@20565 | 641 } |
keir@20509 | 642 for (i = 0; info->extra && info->extra[i] != NULL; i++) |
keir@20509 | 643 flexarray_set(dm_args, num++, info->extra[i]); |
keir@20516 | 644 flexarray_set(dm_args, num++, "-M"); |
keir@20509 | 645 if (info->type == XENPV) |
keir@20516 | 646 flexarray_set(dm_args, num++, "xenpv"); |
keir@20509 | 647 else |
keir@20516 | 648 flexarray_set(dm_args, num++, "xenfv"); |
keir@20462 | 649 flexarray_set(dm_args, num++, NULL); |
keir@20462 | 650 |
keir@20462 | 651 return (char **) flexarray_contents(dm_args); |
keir@20462 | 652 } |
keir@20462 | 653 |
keir@20514 | 654 void dm_xenstore_record_pid(struct libxl_ctx *ctx, void *for_spawn, |
keir@20514 | 655 pid_t innerchild) { |
keir@20514 | 656 struct libxl_device_model_starting *starting = for_spawn; |
keir@20514 | 657 struct libxl_ctx clone; |
keir@20514 | 658 char *kvs[3]; |
keir@20514 | 659 int rc; |
keir@20514 | 660 |
keir@20514 | 661 clone = *ctx; |
keir@20514 | 662 clone.xsh = xs_daemon_open(); |
keir@20514 | 663 /* we mustn't use the parent's handle in the child */ |
keir@20514 | 664 |
keir@20514 | 665 kvs[0] = "image/device-model-pid"; |
keir@20514 | 666 kvs[1] = libxl_sprintf(ctx, "%d", innerchild); |
keir@20514 | 667 kvs[2] = NULL; |
keir@20514 | 668 rc = libxl_xs_writev(ctx, XBT_NULL, starting->dom_path, kvs); |
keir@20514 | 669 if (rc) XL_LOG_ERRNO(ctx, XL_LOG_ERROR, |
keir@20514 | 670 "Couldn't record device model pid %ld at %s/%s", |
keir@20514 | 671 (unsigned long)innerchild, starting->dom_path, kvs); |
keir@20594 | 672 xs_daemon_close(clone.xsh); |
keir@20514 | 673 } |
keir@20514 | 674 |
keir@20542 | 675 static int libxl_vfb_and_vkb_from_device_model_info(struct libxl_ctx *ctx, |
keir@20542 | 676 libxl_device_model_info *info, |
keir@20542 | 677 libxl_device_vfb *vfb, |
keir@20542 | 678 libxl_device_vkb *vkb) |
keir@20542 | 679 { |
keir@20542 | 680 memset(vfb, 0x00, sizeof(libxl_device_vfb)); |
keir@20542 | 681 memset(vkb, 0x00, sizeof(libxl_device_vkb)); |
keir@20542 | 682 |
keir@20542 | 683 vfb->backend_domid = 0; |
keir@20542 | 684 vfb->devid = 0; |
keir@20542 | 685 vfb->vnc = info->vnc; |
keir@20542 | 686 vfb->vnclisten = info->vnclisten; |
keir@20542 | 687 vfb->vncdisplay = info->vncdisplay; |
keir@20542 | 688 vfb->vncunused = info->vncunused; |
keir@20542 | 689 vfb->keymap = info->keymap; |
keir@20542 | 690 vfb->sdl = info->sdl; |
keir@20542 | 691 vfb->opengl = info->opengl; |
keir@20542 | 692 |
keir@20542 | 693 vkb->backend_domid = 0; |
keir@20542 | 694 vkb->devid = 0; |
keir@20542 | 695 return 0; |
keir@20542 | 696 } |
keir@20542 | 697 |
keir@20542 | 698 static int libxl_write_dmargs(struct libxl_ctx *ctx, int domid, int guest_domid, char **args) |
keir@20542 | 699 { |
keir@20542 | 700 int i; |
keir@20542 | 701 char *vm_path; |
keir@20542 | 702 char *dmargs, *path; |
keir@20542 | 703 int dmargs_size; |
keir@20542 | 704 struct xs_permissions roperm[2]; |
keir@20542 | 705 xs_transaction_t t; |
keir@20542 | 706 |
keir@20542 | 707 roperm[0].id = 0; |
keir@20542 | 708 roperm[0].perms = XS_PERM_NONE; |
keir@20542 | 709 roperm[1].id = domid; |
keir@20542 | 710 roperm[1].perms = XS_PERM_READ; |
keir@20542 | 711 |
keir@20542 | 712 vm_path = libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "/local/domain/%d/vm", guest_domid)); |
keir@20542 | 713 |
keir@20542 | 714 i = 0; |
keir@20542 | 715 dmargs_size = 0; |
keir@20542 | 716 while (args[i] != NULL) { |
keir@20542 | 717 dmargs_size = dmargs_size + strlen(args[i]) + 1; |
keir@20542 | 718 i++; |
keir@20542 | 719 } |
keir@20542 | 720 dmargs_size++; |
keir@20542 | 721 dmargs = (char *) malloc(dmargs_size); |
keir@20542 | 722 i = 1; |
keir@20542 | 723 dmargs[0] = '\0'; |
keir@20542 | 724 while (args[i] != NULL) { |
keir@20542 | 725 if (strcmp(args[i], "-sdl") && strcmp(args[i], "-M") && strcmp(args[i], "xenfv")) { |
keir@20542 | 726 strcat(dmargs, " "); |
keir@20542 | 727 strcat(dmargs, args[i]); |
keir@20542 | 728 } |
keir@20542 | 729 i++; |
keir@20542 | 730 } |
keir@20542 | 731 path = libxl_sprintf(ctx, "%s/image/dmargs", vm_path); |
keir@20542 | 732 |
keir@20542 | 733 retry_transaction: |
keir@20542 | 734 t = xs_transaction_start(ctx->xsh); |
keir@20542 | 735 xs_write(ctx->xsh, t, path, dmargs, strlen(dmargs)); |
keir@20542 | 736 xs_set_permissions(ctx->xsh, t, path, roperm, ARRAY_SIZE(roperm)); |
keir@20542 | 737 xs_set_permissions(ctx->xsh, t, libxl_sprintf(ctx, "%s/rtc/timeoffset", vm_path), roperm, ARRAY_SIZE(roperm)); |
keir@20542 | 738 if (!xs_transaction_end(ctx->xsh, t, 0)) |
keir@20542 | 739 if (errno == EAGAIN) |
keir@20542 | 740 goto retry_transaction; |
keir@20542 | 741 free(dmargs); |
keir@20542 | 742 return 0; |
keir@20542 | 743 } |
keir@20542 | 744 |
keir@20542 | 745 static int libxl_create_stubdom(struct libxl_ctx *ctx, |
keir@20542 | 746 libxl_device_model_info *info, |
keir@20542 | 747 libxl_device_disk *disks, int num_disks, |
keir@20542 | 748 libxl_device_nic *vifs, int num_vifs, |
keir@20542 | 749 libxl_device_vfb *vfb, |
keir@20542 | 750 libxl_device_vkb *vkb, |
keir@20542 | 751 libxl_device_model_starting **starting_r) |
keir@20542 | 752 { |
keir@20570 | 753 int i, num_console = 1; |
keir@20570 | 754 libxl_device_console *console; |
keir@20542 | 755 libxl_domain_create_info c_info; |
keir@20542 | 756 libxl_domain_build_info b_info; |
keir@20542 | 757 libxl_domain_build_state state; |
keir@20542 | 758 uint32_t domid; |
keir@20542 | 759 char **args; |
keir@20542 | 760 xen_uuid_t uuid[16]; |
keir@20542 | 761 struct xs_permissions perm[2]; |
keir@20542 | 762 xs_transaction_t t; |
keir@20594 | 763 libxl_device_model_starting *dm_starting = 0; |
keir@20542 | 764 |
keir@20542 | 765 args = libxl_build_device_model_args(ctx, info, vifs, num_vifs); |
keir@20542 | 766 if (!args) |
keir@20542 | 767 return ERROR_FAIL; |
keir@20542 | 768 |
keir@20542 | 769 memset(&c_info, 0x00, sizeof(libxl_domain_create_info)); |
keir@20542 | 770 c_info.hvm = 0; |
keir@20542 | 771 c_info.name = libxl_sprintf(ctx, "%s-dm", libxl_domid_to_name(ctx, info->domid)); |
keir@20542 | 772 xen_uuid_generate(uuid); |
keir@20542 | 773 c_info.uuid = uuid; |
keir@20542 | 774 |
keir@20542 | 775 memset(&b_info, 0x00, sizeof(libxl_domain_build_info)); |
keir@20542 | 776 b_info.max_vcpus = 1; |
keir@20542 | 777 b_info.max_memkb = 32 * 1024; |
keir@20542 | 778 b_info.kernel = "/usr/lib/xen/boot/ioemu-stubdom.gz"; |
keir@20542 | 779 b_info.u.pv.cmdline = libxl_sprintf(ctx, " -d %d", info->domid); |
keir@20542 | 780 b_info.u.pv.ramdisk = ""; |
keir@20542 | 781 b_info.u.pv.features = ""; |
keir@20542 | 782 b_info.hvm = 0; |
keir@20542 | 783 |
keir@20542 | 784 libxl_domain_make(ctx, &c_info, &domid); |
keir@20542 | 785 libxl_domain_build(ctx, &b_info, domid, &state); |
keir@20542 | 786 |
keir@20542 | 787 libxl_write_dmargs(ctx, domid, info->domid, args); |
keir@20542 | 788 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 | 789 libxl_xs_write(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/target", libxl_xs_get_dompath(ctx, domid)), "%d", info->domid); |
keir@20542 | 790 xc_domain_set_target(ctx->xch, domid, info->domid); |
keir@20542 | 791 xs_set_target(ctx->xsh, domid, info->domid); |
keir@20542 | 792 |
keir@20542 | 793 perm[0].id = domid; |
keir@20542 | 794 perm[0].perms = XS_PERM_NONE; |
keir@20542 | 795 perm[1].id = info->domid; |
keir@20542 | 796 perm[1].perms = XS_PERM_READ; |
keir@20542 | 797 retry_transaction: |
keir@20542 | 798 t = xs_transaction_start(ctx->xsh); |
keir@20542 | 799 xs_mkdir(ctx->xsh, t, libxl_sprintf(ctx, "/local/domain/0/device-model/%d", info->domid)); |
keir@20542 | 800 xs_set_permissions(ctx->xsh, t, libxl_sprintf(ctx, "/local/domain/0/device-model/%d", info->domid), perm, ARRAY_SIZE(perm)); |
keir@20542 | 801 if (!xs_transaction_end(ctx->xsh, t, 0)) |
keir@20542 | 802 if (errno == EAGAIN) |
keir@20542 | 803 goto retry_transaction; |
keir@20542 | 804 |
keir@20542 | 805 for (i = 0; i < num_disks; i++) { |
keir@20542 | 806 libxl_device_disk disk = disks[i]; |
keir@20542 | 807 disk_info_domid_fixup(&disk, domid); |
keir@20542 | 808 libxl_device_disk_add(ctx, domid, &disk); |
keir@20542 | 809 } |
keir@20542 | 810 for (i = 0; i < num_vifs; i++) { |
keir@20542 | 811 libxl_device_nic nic = vifs[i]; |
keir@20542 | 812 nic_info_domid_fixup(&nic, domid); |
keir@20542 | 813 libxl_device_nic_add(ctx, domid, &nic); |
keir@20542 | 814 } |
keir@20542 | 815 vfb_info_domid_fixup(vfb, domid); |
keir@20542 | 816 libxl_device_vfb_add(ctx, domid, vfb); |
keir@20542 | 817 vkb_info_domid_fixup(vkb, domid); |
keir@20542 | 818 libxl_device_vkb_add(ctx, domid, vkb); |
keir@20542 | 819 |
keir@20570 | 820 if (info->serial) |
keir@20570 | 821 num_console++; |
keir@20570 | 822 console = libxl_calloc(ctx, num_console, sizeof(libxl_device_console)); |
keir@20570 | 823 for (i = 0; i < num_console; i++) { |
keir@20570 | 824 if (!i) |
keir@20570 | 825 init_console_info(&console[i], i, &state); |
keir@20570 | 826 else |
keir@20570 | 827 init_console_info(&console[i], i, NULL); |
keir@20570 | 828 console_info_domid_fixup(&console[i], domid); |
keir@20570 | 829 console[i].constype = CONSTYPE_IOEMU; |
keir@20570 | 830 libxl_device_console_add(ctx, domid, &console[i]); |
keir@20570 | 831 } |
keir@20594 | 832 if (libxl_create_xenpv_qemu(ctx, vfb, num_console, console, &dm_starting) < 0) { |
keir@20594 | 833 free(args); |
keir@20594 | 834 return -1; |
keir@20594 | 835 } |
keir@20594 | 836 if (libxl_confirm_device_model_startup(ctx, dm_starting) < 0) { |
keir@20594 | 837 free(args); |
keir@20594 | 838 return -1; |
keir@20594 | 839 } |
keir@20542 | 840 |
keir@20542 | 841 libxl_domain_unpause(ctx, domid); |
keir@20542 | 842 |
keir@20594 | 843 if (starting_r) { |
keir@20594 | 844 *starting_r = libxl_calloc(ctx, sizeof(libxl_device_model_starting), 1); |
keir@20594 | 845 (*starting_r)->domid = domid; |
keir@20594 | 846 (*starting_r)->dom_path = libxl_xs_get_dompath(ctx, info->domid); |
keir@20594 | 847 (*starting_r)->for_spawn = NULL; |
keir@20594 | 848 } |
keir@20594 | 849 |
keir@20542 | 850 free(args); |
keir@20542 | 851 return 0; |
keir@20542 | 852 } |
keir@20542 | 853 |
keir@20462 | 854 int libxl_create_device_model(struct libxl_ctx *ctx, |
keir@20462 | 855 libxl_device_model_info *info, |
keir@20542 | 856 libxl_device_disk *disks, int num_disks, |
keir@20514 | 857 libxl_device_nic *vifs, int num_vifs, |
keir@20514 | 858 libxl_device_model_starting **starting_r) |
keir@20462 | 859 { |
keir@20546 | 860 char *path, *logfile; |
keir@20514 | 861 int logfile_w, null; |
keir@20546 | 862 int rc; |
keir@20462 | 863 char **args; |
keir@20594 | 864 struct libxl_device_model_starting buf_starting, *p; |
keir@20514 | 865 |
keir@20542 | 866 if (strstr(info->device_model, "stubdom-dm")) { |
keir@20542 | 867 libxl_device_vfb vfb; |
keir@20542 | 868 libxl_device_vkb vkb; |
keir@20542 | 869 |
keir@20542 | 870 libxl_vfb_and_vkb_from_device_model_info(ctx, info, &vfb, &vkb); |
keir@20542 | 871 return libxl_create_stubdom(ctx, info, disks, num_disks, vifs, num_vifs, &vfb, &vkb, starting_r); |
keir@20542 | 872 } |
keir@20542 | 873 |
keir@20462 | 874 args = libxl_build_device_model_args(ctx, info, vifs, num_vifs); |
keir@20462 | 875 if (!args) |
keir@20462 | 876 return ERROR_FAIL; |
keir@20462 | 877 |
keir@20462 | 878 path = libxl_sprintf(ctx, "/local/domain/0/device-model/%d", info->domid); |
keir@20462 | 879 xs_mkdir(ctx->xsh, XBT_NULL, path); |
keir@20462 | 880 |
keir@20546 | 881 libxl_create_logfile(ctx, libxl_sprintf(ctx, "qemu-dm-%s", info->dom_name), &logfile); |
keir@20467 | 882 logfile_w = open(logfile, O_WRONLY|O_CREAT, 0644); |
keir@20546 | 883 free(logfile); |
keir@20462 | 884 null = open("/dev/null", O_RDONLY); |
keir@20514 | 885 |
keir@20514 | 886 if (starting_r) { |
keir@20516 | 887 rc = ERROR_NOMEM; |
keir@20594 | 888 *starting_r = libxl_calloc(ctx, sizeof(libxl_device_model_starting), 1); |
keir@20516 | 889 if (!*starting_r) goto xit; |
keir@20594 | 890 p = *starting_r; |
keir@20594 | 891 } else { |
keir@20594 | 892 p = &buf_starting; |
keir@20594 | 893 p->for_spawn = NULL; |
keir@20594 | 894 } |
keir@20514 | 895 |
keir@20594 | 896 p->domid = info->domid; |
keir@20594 | 897 p->dom_path = libxl_xs_get_dompath(ctx, info->domid); |
keir@20594 | 898 if (!p->dom_path) { libxl_free(ctx, p); return ERROR_FAIL; } |
keir@20594 | 899 |
keir@20594 | 900 rc = libxl_spawn_spawn(ctx, p, "device model", dm_xenstore_record_pid); |
keir@20514 | 901 if (rc < 0) goto xit; |
keir@20514 | 902 if (!rc) { /* inner child */ |
keir@20514 | 903 libxl_exec(ctx, null, logfile_w, logfile_w, |
keir@20514 | 904 info->device_model, args); |
keir@20514 | 905 } |
keir@20514 | 906 |
keir@20514 | 907 rc = 0; |
keir@20514 | 908 xit: |
keir@20516 | 909 free(args); |
keir@20462 | 910 close(null); |
keir@20462 | 911 close(logfile_w); |
keir@20462 | 912 |
keir@20514 | 913 return rc; |
keir@20514 | 914 } |
keir@20514 | 915 |
keir@20514 | 916 int libxl_detach_device_model(struct libxl_ctx *ctx, |
keir@20514 | 917 libxl_device_model_starting *starting) { |
keir@20514 | 918 int rc; |
keir@20594 | 919 rc = libxl_spawn_detach(ctx, starting->for_spawn); |
keir@20594 | 920 if (starting->for_spawn) libxl_free(ctx, starting->for_spawn); |
keir@20514 | 921 libxl_free(ctx, starting); |
keir@20514 | 922 return rc; |
keir@20514 | 923 } |
keir@20462 | 924 |
keir@20514 | 925 |
keir@20514 | 926 int libxl_confirm_device_model_startup(struct libxl_ctx *ctx, |
keir@20514 | 927 libxl_device_model_starting *starting) { |
keir@20514 | 928 int problem = libxl_wait_for_device_model(ctx, starting->domid, "running", |
keir@20514 | 929 libxl_spawn_check, |
keir@20594 | 930 starting->for_spawn); |
keir@20514 | 931 int detach = libxl_detach_device_model(ctx, starting); |
keir@20514 | 932 return problem ? problem : detach; |
keir@20542 | 933 return 0; |
keir@20462 | 934 } |
keir@20462 | 935 |
keir@20514 | 936 |
keir@20462 | 937 /******************************************************************************/ |
keir@20566 | 938 |
keir@20566 | 939 static int is_blktap2_supported(void) |
keir@20566 | 940 { |
keir@20566 | 941 char buf[1024]; |
keir@20566 | 942 FILE *f = fopen("/proc/devices", "r"); |
keir@20566 | 943 |
keir@20566 | 944 |
keir@20566 | 945 while (fgets(buf, sizeof(buf), f) != NULL) { |
keir@20566 | 946 if (strstr(buf, "blktap2")) { |
keir@20566 | 947 fclose(f); |
keir@20566 | 948 return 1; |
keir@20566 | 949 } |
keir@20566 | 950 } |
keir@20566 | 951 fclose(f); |
keir@20566 | 952 return 0; |
keir@20566 | 953 } |
keir@20566 | 954 |
keir@20566 | 955 static char *get_blktap2_device(struct libxl_ctx *ctx, char *name, char *type) |
keir@20566 | 956 { |
keir@20566 | 957 char buf[1024]; |
keir@20566 | 958 char *p; |
keir@20566 | 959 int devnum; |
keir@20566 | 960 FILE *f = fopen("/sys/class/blktap2/devices", "r"); |
keir@20566 | 961 |
keir@20566 | 962 |
keir@20566 | 963 while (!feof(f)) { |
keir@20566 | 964 fscanf(f, "%d %s", &devnum, buf); |
keir@20566 | 965 p = strchr(buf, ':'); |
keir@20571 | 966 if (p == NULL) |
keir@20571 | 967 continue; |
keir@20566 | 968 p++; |
keir@20566 | 969 if (!strcmp(p, name) && !strncmp(buf, type, 3)) { |
keir@20566 | 970 fclose(f); |
keir@20566 | 971 return libxl_sprintf(ctx, "/dev/xen/blktap-2/tapdev%d", devnum); |
keir@20566 | 972 } |
keir@20566 | 973 } |
keir@20566 | 974 fclose(f); |
keir@20566 | 975 return NULL; |
keir@20566 | 976 } |
keir@20566 | 977 |
keir@20462 | 978 int libxl_device_disk_add(struct libxl_ctx *ctx, uint32_t domid, libxl_device_disk *disk) |
keir@20462 | 979 { |
keir@20462 | 980 flexarray_t *front; |
keir@20462 | 981 flexarray_t *back; |
keir@20462 | 982 char *backend_type; |
keir@20462 | 983 unsigned int boffset = 0; |
keir@20462 | 984 unsigned int foffset = 0; |
keir@20462 | 985 int devid; |
keir@20462 | 986 libxl_device device; |
keir@20566 | 987 int major, minor; |
keir@20462 | 988 |
keir@20462 | 989 front = flexarray_make(16, 1); |
keir@20462 | 990 if (!front) |
keir@20462 | 991 return ERROR_NOMEM; |
keir@20462 | 992 back = flexarray_make(16, 1); |
keir@20462 | 993 if (!back) /* leaks front if error */ |
keir@20462 | 994 return ERROR_NOMEM; |
keir@20462 | 995 |
keir@20462 | 996 backend_type = device_disk_backend_type_of_phystype(disk->phystype); |
keir@20462 | 997 devid = device_disk_dev_number(disk->virtpath); |
keir@20462 | 998 |
keir@20462 | 999 device.backend_devid = devid; |
keir@20462 | 1000 device.backend_domid = disk->backend_domid; |
keir@20462 | 1001 device.devid = devid; |
keir@20462 | 1002 device.domid = disk->domid; |
keir@20462 | 1003 device.kind = DEVICE_VBD; |
keir@20462 | 1004 |
keir@20462 | 1005 switch (disk->phystype) { |
keir@20462 | 1006 case PHYSTYPE_PHY: { |
keir@20462 | 1007 |
keir@20509 | 1008 device_physdisk_major_minor(disk->physpath, &major, &minor); |
keir@20516 | 1009 flexarray_set(back, boffset++, "physical-device"); |
keir@20462 | 1010 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%x:%x", major, minor)); |
keir@20462 | 1011 |
keir@20516 | 1012 flexarray_set(back, boffset++, "params"); |
keir@20516 | 1013 flexarray_set(back, boffset++, disk->physpath); |
keir@20462 | 1014 |
keir@20462 | 1015 device.backend_kind = DEVICE_VBD; |
keir@20462 | 1016 break; |
keir@20462 | 1017 } |
keir@20566 | 1018 case PHYSTYPE_FILE: |
keir@20566 | 1019 /* let's pretend is tap:aio for the moment */ |
keir@20566 | 1020 disk->phystype = PHYSTYPE_AIO; |
keir@20462 | 1021 case PHYSTYPE_AIO: case PHYSTYPE_QCOW: case PHYSTYPE_QCOW2: case PHYSTYPE_VHD: |
keir@20566 | 1022 if (is_blktap2_supported()) { |
keir@20566 | 1023 int rc, c, p[2], tot; |
keir@20566 | 1024 char buf[1024], *dev; |
keir@20566 | 1025 if ((dev = get_blktap2_device(ctx, disk->physpath, device_disk_string_of_phystype(disk->phystype))) == NULL) { |
keir@20566 | 1026 if (pipe(p) < 0) { |
keir@20566 | 1027 XL_LOG(ctx, XL_LOG_ERROR, "Failed to create a pipe"); |
keir@20566 | 1028 return -1; |
keir@20566 | 1029 } |
keir@20566 | 1030 rc = fork(); |
keir@20566 | 1031 if (rc < 0) { |
keir@20566 | 1032 XL_LOG(ctx, XL_LOG_ERROR, "Failed to fork a new process"); |
keir@20566 | 1033 return -1; |
keir@20566 | 1034 } else if (!rc) { /* child */ |
keir@20566 | 1035 int null_r, null_w; |
keir@20566 | 1036 char *args[4]; |
keir@20566 | 1037 args[0] = "tapdisk2"; |
keir@20566 | 1038 args[1] = "-n"; |
keir@20566 | 1039 args[2] = libxl_sprintf(ctx, "%s:%s", device_disk_string_of_phystype(disk->phystype), disk->physpath); |
keir@20566 | 1040 args[3] = NULL; |
keir@20566 | 1041 |
keir@20566 | 1042 null_r = open("/dev/null", O_RDONLY); |
keir@20566 | 1043 null_w = open("/dev/null", O_WRONLY); |
keir@20566 | 1044 libxl_exec(ctx, null_r, p[1], null_w, "/usr/sbin/tapdisk2", args); |
keir@20566 | 1045 XL_LOG(ctx, XL_LOG_ERROR, "Error execing tapdisk2"); |
keir@20566 | 1046 } |
keir@20566 | 1047 close(p[1]); |
keir@20566 | 1048 tot = 0; |
keir@20566 | 1049 while ((c = read(p[0], buf + tot, sizeof(buf) - tot)) > 0) |
keir@20566 | 1050 tot = tot + c; |
keir@20566 | 1051 close(p[0]); |
keir@20566 | 1052 buf[tot - 1] = '\0'; |
keir@20566 | 1053 dev = buf; |
keir@20566 | 1054 } |
keir@20566 | 1055 flexarray_set(back, boffset++, "tapdisk-params"); |
keir@20566 | 1056 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%s:%s", device_disk_string_of_phystype(disk->phystype), disk->physpath)); |
keir@20566 | 1057 flexarray_set(back, boffset++, "params"); |
keir@20566 | 1058 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%s", dev)); |
keir@20566 | 1059 backend_type = "phy"; |
keir@20566 | 1060 device_physdisk_major_minor(dev, &major, &minor); |
keir@20566 | 1061 flexarray_set(back, boffset++, "physical-device"); |
keir@20566 | 1062 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%x:%x", major, minor)); |
keir@20566 | 1063 device.backend_kind = DEVICE_VBD; |
keir@20566 | 1064 |
keir@20566 | 1065 break; |
keir@20566 | 1066 } |
keir@20516 | 1067 flexarray_set(back, boffset++, "params"); |
keir@20462 | 1068 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%s:%s", |
keir@20462 | 1069 device_disk_string_of_phystype(disk->phystype), disk->physpath)); |
keir@20462 | 1070 |
keir@20462 | 1071 device.backend_kind = DEVICE_TAP; |
keir@20462 | 1072 break; |
keir@20462 | 1073 } |
keir@20462 | 1074 |
keir@20516 | 1075 flexarray_set(back, boffset++, "frontend-id"); |
keir@20462 | 1076 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", disk->domid)); |
keir@20516 | 1077 flexarray_set(back, boffset++, "online"); |
keir@20516 | 1078 flexarray_set(back, boffset++, "1"); |
keir@20516 | 1079 flexarray_set(back, boffset++, "removable"); |
keir@20462 | 1080 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", (disk->unpluggable) ? 1 : 0)); |
keir@20516 | 1081 flexarray_set(back, boffset++, "bootable"); |
keir@20509 | 1082 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", 1)); |
keir@20516 | 1083 flexarray_set(back, boffset++, "state"); |
keir@20462 | 1084 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", 1)); |
keir@20516 | 1085 flexarray_set(back, boffset++, "dev"); |
keir@20516 | 1086 flexarray_set(back, boffset++, disk->virtpath); |
keir@20516 | 1087 flexarray_set(back, boffset++, "type"); |
keir@20516 | 1088 flexarray_set(back, boffset++, backend_type); |
keir@20516 | 1089 flexarray_set(back, boffset++, "mode"); |
keir@20516 | 1090 flexarray_set(back, boffset++, disk->readwrite ? "w" : "r"); |
keir@20462 | 1091 |
keir@20516 | 1092 flexarray_set(front, foffset++, "backend-id"); |
keir@20462 | 1093 flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", disk->backend_domid)); |
keir@20516 | 1094 flexarray_set(front, foffset++, "state"); |
keir@20462 | 1095 flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", 1)); |
keir@20516 | 1096 flexarray_set(front, foffset++, "virtual-device"); |
keir@20462 | 1097 flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", devid)); |
keir@20516 | 1098 flexarray_set(front, foffset++, "device-type"); |
keir@20516 | 1099 flexarray_set(front, foffset++, disk->is_cdrom ? "cdrom" : "disk"); |
keir@20462 | 1100 |
keir@20462 | 1101 if (0 /* protocol != native*/) { |
keir@20516 | 1102 flexarray_set(front, foffset++, "protocol"); |
keir@20516 | 1103 flexarray_set(front, foffset++, "x86_32-abi"); /* hardcoded ! */ |
keir@20462 | 1104 } |
keir@20462 | 1105 |
keir@20462 | 1106 libxl_device_generic_add(ctx, &device, |
keir@20462 | 1107 libxl_xs_kvs_of_flexarray(ctx, back, boffset), |
keir@20462 | 1108 libxl_xs_kvs_of_flexarray(ctx, front, foffset)); |
keir@20516 | 1109 flexarray_free(back); |
keir@20516 | 1110 flexarray_free(front); |
keir@20462 | 1111 return 0; |
keir@20462 | 1112 } |
keir@20462 | 1113 |
keir@20462 | 1114 int libxl_device_disk_clean_shutdown(struct libxl_ctx *ctx, uint32_t domid) |
keir@20462 | 1115 { |
keir@20462 | 1116 return ERROR_NI; |
keir@20462 | 1117 } |
keir@20462 | 1118 |
keir@20462 | 1119 int libxl_device_disk_hard_shutdown(struct libxl_ctx *ctx, uint32_t domid) |
keir@20462 | 1120 { |
keir@20462 | 1121 return ERROR_NI; |
keir@20462 | 1122 } |
keir@20462 | 1123 |
keir@20462 | 1124 /******************************************************************************/ |
keir@20462 | 1125 int libxl_device_nic_add(struct libxl_ctx *ctx, uint32_t domid, libxl_device_nic *nic) |
keir@20462 | 1126 { |
keir@20462 | 1127 flexarray_t *front; |
keir@20462 | 1128 flexarray_t *back; |
keir@20462 | 1129 unsigned int boffset = 0; |
keir@20462 | 1130 unsigned int foffset = 0; |
keir@20462 | 1131 libxl_device device; |
keir@20462 | 1132 |
keir@20462 | 1133 front = flexarray_make(16, 1); |
keir@20462 | 1134 if (!front) |
keir@20462 | 1135 return ERROR_NOMEM; |
keir@20462 | 1136 back = flexarray_make(16, 1); |
keir@20462 | 1137 if (!back) |
keir@20462 | 1138 return ERROR_NOMEM; |
keir@20462 | 1139 |
keir@20462 | 1140 device.backend_devid = nic->devid; |
keir@20462 | 1141 device.backend_domid = nic->backend_domid; |
keir@20462 | 1142 device.backend_kind = DEVICE_VIF; |
keir@20462 | 1143 device.devid = nic->devid; |
keir@20462 | 1144 device.domid = nic->domid; |
keir@20462 | 1145 device.kind = DEVICE_VIF; |
keir@20462 | 1146 |
keir@20516 | 1147 flexarray_set(back, boffset++, "frontend-id"); |
keir@20462 | 1148 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", nic->domid)); |
keir@20516 | 1149 flexarray_set(back, boffset++, "online"); |
keir@20516 | 1150 flexarray_set(back, boffset++, "1"); |
keir@20516 | 1151 flexarray_set(back, boffset++, "state"); |
keir@20462 | 1152 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", 1)); |
keir@20516 | 1153 flexarray_set(back, boffset++, "script"); |
keir@20516 | 1154 flexarray_set(back, boffset++, nic->script); |
keir@20516 | 1155 flexarray_set(back, boffset++, "mac"); |
keir@20462 | 1156 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%02x:%02x:%02x:%02x:%02x:%02x", |
keir@20462 | 1157 nic->mac[0], nic->mac[1], nic->mac[2], |
keir@20462 | 1158 nic->mac[3], nic->mac[4], nic->mac[5])); |
keir@20516 | 1159 flexarray_set(back, boffset++, "handle"); |
keir@20462 | 1160 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", nic->devid)); |
keir@20462 | 1161 |
keir@20516 | 1162 flexarray_set(front, foffset++, "backend-id"); |
keir@20462 | 1163 flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", nic->backend_domid)); |
keir@20516 | 1164 flexarray_set(front, foffset++, "state"); |
keir@20462 | 1165 flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", 1)); |
keir@20516 | 1166 flexarray_set(front, foffset++, "handle"); |
keir@20462 | 1167 flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", nic->devid)); |
keir@20516 | 1168 flexarray_set(front, foffset++, "mac"); |
keir@20462 | 1169 flexarray_set(front, foffset++, libxl_sprintf(ctx, "%02x:%02x:%02x:%02x:%02x:%02x", |
keir@20462 | 1170 nic->mac[0], nic->mac[1], nic->mac[2], |
keir@20462 | 1171 nic->mac[3], nic->mac[4], nic->mac[5])); |
keir@20462 | 1172 if (0 /* protocol != native*/) { |
keir@20516 | 1173 flexarray_set(front, foffset++, "protocol"); |
keir@20516 | 1174 flexarray_set(front, foffset++, "x86_32-abi"); /* hardcoded ! */ |
keir@20462 | 1175 } |
keir@20462 | 1176 |
keir@20462 | 1177 libxl_device_generic_add(ctx, &device, |
keir@20462 | 1178 libxl_xs_kvs_of_flexarray(ctx, back, boffset), |
keir@20462 | 1179 libxl_xs_kvs_of_flexarray(ctx, front, foffset)); |
keir@20462 | 1180 |
keir@20462 | 1181 /* FIXME: wait for plug */ |
keir@20516 | 1182 flexarray_free(back); |
keir@20516 | 1183 flexarray_free(front); |
keir@20462 | 1184 return 0; |
keir@20462 | 1185 } |
keir@20462 | 1186 |
keir@20462 | 1187 int libxl_device_nic_clean_shutdown(struct libxl_ctx *ctx, uint32_t domid) |
keir@20462 | 1188 { |
keir@20462 | 1189 return ERROR_NI; |
keir@20462 | 1190 } |
keir@20462 | 1191 |
keir@20462 | 1192 int libxl_device_nic_hard_shutdown(struct libxl_ctx *ctx, uint32_t domid) |
keir@20462 | 1193 { |
keir@20462 | 1194 return ERROR_NI; |
keir@20462 | 1195 } |
keir@20462 | 1196 |
keir@20462 | 1197 /******************************************************************************/ |
keir@20509 | 1198 int libxl_device_console_add(struct libxl_ctx *ctx, uint32_t domid, libxl_device_console *console) |
keir@20462 | 1199 { |
keir@20509 | 1200 flexarray_t *front; |
keir@20509 | 1201 flexarray_t *back; |
keir@20509 | 1202 unsigned int boffset = 0; |
keir@20509 | 1203 unsigned int foffset = 0; |
keir@20509 | 1204 libxl_device device; |
keir@20509 | 1205 |
keir@20509 | 1206 if (console->build_state) { |
keir@20509 | 1207 xs_transaction_t t; |
keir@20509 | 1208 char **ents = (char **) libxl_calloc(ctx, 9, sizeof(char *)); |
keir@20516 | 1209 ents[0] = "console/port"; |
keir@20509 | 1210 ents[1] = libxl_sprintf(ctx, "%"PRIu32, console->build_state->console_port); |
keir@20516 | 1211 ents[2] = "console/ring-ref"; |
keir@20509 | 1212 ents[3] = libxl_sprintf(ctx, "%lu", console->build_state->console_mfn); |
keir@20516 | 1213 ents[4] = "console/limit"; |
keir@20509 | 1214 ents[5] = libxl_sprintf(ctx, "%d", LIBXL_XENCONSOLE_LIMIT); |
keir@20516 | 1215 ents[6] = "console/type"; |
keir@20509 | 1216 if (console->constype == CONSTYPE_XENCONSOLED) |
keir@20509 | 1217 ents[7] = "xenconsoled"; |
keir@20509 | 1218 else |
keir@20509 | 1219 ents[7] = "ioemu"; |
keir@20509 | 1220 retry_transaction: |
keir@20509 | 1221 t = xs_transaction_start(ctx->xsh); |
keir@20516 | 1222 libxl_xs_writev(ctx, t, libxl_xs_get_dompath(ctx, console->domid), ents); |
keir@20509 | 1223 if (!xs_transaction_end(ctx->xsh, t, 0)) |
keir@20509 | 1224 if (errno == EAGAIN) |
keir@20509 | 1225 goto retry_transaction; |
keir@20509 | 1226 } |
keir@20509 | 1227 |
keir@20509 | 1228 front = flexarray_make(16, 1); |
keir@20509 | 1229 if (!front) |
keir@20509 | 1230 return ERROR_NOMEM; |
keir@20509 | 1231 back = flexarray_make(16, 1); |
keir@20509 | 1232 if (!back) |
keir@20509 | 1233 return ERROR_NOMEM; |
keir@20509 | 1234 |
keir@20509 | 1235 device.backend_devid = console->devid; |
keir@20509 | 1236 device.backend_domid = console->backend_domid; |
keir@20509 | 1237 device.backend_kind = DEVICE_CONSOLE; |
keir@20509 | 1238 device.devid = console->devid; |
keir@20509 | 1239 device.domid = console->domid; |
keir@20509 | 1240 device.kind = DEVICE_CONSOLE; |
keir@20509 | 1241 |
keir@20516 | 1242 flexarray_set(back, boffset++, "frontend-id"); |
keir@20509 | 1243 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", console->domid)); |
keir@20516 | 1244 flexarray_set(back, boffset++, "online"); |
keir@20516 | 1245 flexarray_set(back, boffset++, "1"); |
keir@20516 | 1246 flexarray_set(back, boffset++, "state"); |
keir@20509 | 1247 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", 1)); |
keir@20516 | 1248 flexarray_set(back, boffset++, "domain"); |
keir@20516 | 1249 flexarray_set(back, boffset++, libxl_domid_to_name(ctx, domid)); |
keir@20516 | 1250 flexarray_set(back, boffset++, "protocol"); |
keir@20516 | 1251 flexarray_set(back, boffset++, LIBXL_XENCONSOLE_PROTOCOL); |
keir@20509 | 1252 |
keir@20516 | 1253 flexarray_set(front, foffset++, "backend-id"); |
keir@20509 | 1254 flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", console->backend_domid)); |
keir@20516 | 1255 flexarray_set(front, foffset++, "state"); |
keir@20509 | 1256 flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", 1)); |
keir@20516 | 1257 flexarray_set(front, foffset++, "limit"); |
keir@20509 | 1258 flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", LIBXL_XENCONSOLE_LIMIT)); |
keir@20516 | 1259 flexarray_set(front, foffset++, "protocol"); |
keir@20516 | 1260 flexarray_set(front, foffset++, LIBXL_XENCONSOLE_PROTOCOL); |
keir@20516 | 1261 flexarray_set(front, foffset++, "type"); |
keir@20509 | 1262 if (console->constype == CONSTYPE_XENCONSOLED) |
keir@20516 | 1263 flexarray_set(front, foffset++, "xenconsoled"); |
keir@20509 | 1264 else |
keir@20516 | 1265 flexarray_set(front, foffset++, "ioemu"); |
keir@20509 | 1266 |
keir@20509 | 1267 libxl_device_generic_add(ctx, &device, |
keir@20509 | 1268 libxl_xs_kvs_of_flexarray(ctx, back, boffset), |
keir@20509 | 1269 libxl_xs_kvs_of_flexarray(ctx, front, foffset)); |
keir@20516 | 1270 flexarray_free(back); |
keir@20516 | 1271 flexarray_free(front); |
keir@20509 | 1272 |
keir@20509 | 1273 return 0; |
keir@20509 | 1274 } |
keir@20509 | 1275 |
keir@20509 | 1276 /******************************************************************************/ |
keir@20509 | 1277 int libxl_device_vkb_add(struct libxl_ctx *ctx, uint32_t domid, libxl_device_vkb *vkb) |
keir@20509 | 1278 { |
keir@20509 | 1279 flexarray_t *front; |
keir@20509 | 1280 flexarray_t *back; |
keir@20509 | 1281 unsigned int boffset = 0; |
keir@20509 | 1282 unsigned int foffset = 0; |
keir@20509 | 1283 libxl_device device; |
keir@20509 | 1284 |
keir@20509 | 1285 front = flexarray_make(16, 1); |
keir@20509 | 1286 if (!front) |
keir@20509 | 1287 return ERROR_NOMEM; |
keir@20509 | 1288 back = flexarray_make(16, 1); |
keir@20509 | 1289 if (!back) |
keir@20509 | 1290 return ERROR_NOMEM; |
keir@20509 | 1291 |
keir@20509 | 1292 device.backend_devid = vkb->devid; |
keir@20509 | 1293 device.backend_domid = vkb->backend_domid; |
keir@20509 | 1294 device.backend_kind = DEVICE_VKBD; |
keir@20509 | 1295 device.devid = vkb->devid; |
keir@20509 | 1296 device.domid = vkb->domid; |
keir@20509 | 1297 device.kind = DEVICE_VKBD; |
keir@20509 | 1298 |
keir@20516 | 1299 flexarray_set(back, boffset++, "frontend-id"); |
keir@20509 | 1300 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", vkb->domid)); |
keir@20516 | 1301 flexarray_set(back, boffset++, "online"); |
keir@20516 | 1302 flexarray_set(back, boffset++, "1"); |
keir@20516 | 1303 flexarray_set(back, boffset++, "state"); |
keir@20509 | 1304 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", 1)); |
keir@20516 | 1305 flexarray_set(back, boffset++, "domain"); |
keir@20516 | 1306 flexarray_set(back, boffset++, libxl_domid_to_name(ctx, domid)); |
keir@20509 | 1307 |
keir@20516 | 1308 flexarray_set(front, foffset++, "backend-id"); |
keir@20509 | 1309 flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", vkb->backend_domid)); |
keir@20516 | 1310 flexarray_set(front, foffset++, "state"); |
keir@20509 | 1311 flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", 1)); |
keir@20509 | 1312 |
keir@20509 | 1313 libxl_device_generic_add(ctx, &device, |
keir@20509 | 1314 libxl_xs_kvs_of_flexarray(ctx, back, boffset), |
keir@20509 | 1315 libxl_xs_kvs_of_flexarray(ctx, front, foffset)); |
keir@20516 | 1316 flexarray_free(back); |
keir@20516 | 1317 flexarray_free(front); |
keir@20509 | 1318 |
keir@20509 | 1319 return 0; |
keir@20462 | 1320 } |
keir@20462 | 1321 |
keir@20462 | 1322 int libxl_device_vkb_clean_shutdown(struct libxl_ctx *ctx, uint32_t domid) |
keir@20462 | 1323 { |
keir@20462 | 1324 return ERROR_NI; |
keir@20462 | 1325 } |
keir@20462 | 1326 |
keir@20462 | 1327 int libxl_device_vkb_hard_shutdown(struct libxl_ctx *ctx, uint32_t domid) |
keir@20462 | 1328 { |
keir@20462 | 1329 return ERROR_NI; |
keir@20462 | 1330 } |
keir@20462 | 1331 |
keir@20462 | 1332 /******************************************************************************/ |
keir@20509 | 1333 static int libxl_build_xenpv_qemu_args(struct libxl_ctx *ctx, |
keir@20509 | 1334 libxl_device_vfb *vfb, |
keir@20509 | 1335 int num_console, |
keir@20509 | 1336 libxl_device_console *console, |
keir@20509 | 1337 libxl_device_model_info *info) { |
keir@20509 | 1338 int i = 0, j = 0, num = 0; |
keir@20509 | 1339 memset(info, 0x00, sizeof(libxl_device_model_info)); |
keir@20509 | 1340 |
keir@20509 | 1341 info->vnc = vfb->vnc; |
keir@20509 | 1342 if (vfb->vnclisten) |
keir@20509 | 1343 info->vnclisten = libxl_sprintf(ctx, "%s", vfb->vnclisten); |
keir@20509 | 1344 info->vncdisplay = vfb->vncdisplay; |
keir@20509 | 1345 info->vncunused = vfb->vncunused; |
keir@20509 | 1346 if (vfb->keymap) |
keir@20509 | 1347 info->keymap = libxl_sprintf(ctx, "%s", vfb->keymap); |
keir@20509 | 1348 info->sdl = vfb->sdl; |
keir@20509 | 1349 info->opengl = vfb->opengl; |
keir@20509 | 1350 for (i = 0; i < num_console; i++) { |
keir@20509 | 1351 if (console->constype == CONSTYPE_IOEMU) |
keir@20509 | 1352 num++; |
keir@20509 | 1353 } |
keir@20509 | 1354 if (num > 0) { |
keir@20509 | 1355 info->serial = "pty"; |
keir@20509 | 1356 num--; |
keir@20509 | 1357 } |
keir@20509 | 1358 if (num > 0) { |
keir@20509 | 1359 info->extra = (char **) libxl_calloc(ctx, num * 2 + 1, sizeof(char *)); |
keir@20509 | 1360 for (j = 0; j < num * 2; j = j + 2) { |
keir@20509 | 1361 info->extra[j] = "-serial"; |
keir@20509 | 1362 info->extra[j + 1] = "pty"; |
keir@20509 | 1363 } |
keir@20509 | 1364 info->extra[j] = NULL; |
keir@20509 | 1365 } |
keir@20509 | 1366 info->domid = vfb->domid; |
keir@20509 | 1367 info->dom_name = libxl_domid_to_name(ctx, vfb->domid); |
keir@20509 | 1368 info->device_model = "/usr/lib/xen/bin/qemu-dm"; |
keir@20509 | 1369 info->type = XENPV; |
keir@20509 | 1370 return 0; |
keir@20509 | 1371 } |
keir@20509 | 1372 |
keir@20509 | 1373 int libxl_create_xenpv_qemu(struct libxl_ctx *ctx, libxl_device_vfb *vfb, |
keir@20514 | 1374 int num_console, libxl_device_console *console, |
keir@20514 | 1375 struct libxl_device_model_starting **starting_r) |
keir@20509 | 1376 { |
keir@20509 | 1377 libxl_device_model_info info; |
keir@20509 | 1378 |
keir@20509 | 1379 libxl_build_xenpv_qemu_args(ctx, vfb, num_console, console, &info); |
keir@20542 | 1380 libxl_create_device_model(ctx, &info, NULL, 0, NULL, 0, starting_r); |
keir@20509 | 1381 return 0; |
keir@20509 | 1382 } |
keir@20509 | 1383 |
keir@20509 | 1384 int libxl_device_vfb_add(struct libxl_ctx *ctx, uint32_t domid, libxl_device_vfb *vfb) |
keir@20462 | 1385 { |
keir@20509 | 1386 flexarray_t *front; |
keir@20509 | 1387 flexarray_t *back; |
keir@20509 | 1388 unsigned int boffset = 0; |
keir@20509 | 1389 unsigned int foffset = 0; |
keir@20509 | 1390 libxl_device device; |
keir@20509 | 1391 |
keir@20509 | 1392 front = flexarray_make(16, 1); |
keir@20509 | 1393 if (!front) |
keir@20509 | 1394 return ERROR_NOMEM; |
keir@20509 | 1395 back = flexarray_make(16, 1); |
keir@20509 | 1396 if (!back) |
keir@20509 | 1397 return ERROR_NOMEM; |
keir@20509 | 1398 |
keir@20509 | 1399 device.backend_devid = vfb->devid; |
keir@20509 | 1400 device.backend_domid = vfb->backend_domid; |
keir@20509 | 1401 device.backend_kind = DEVICE_VFB; |
keir@20509 | 1402 device.devid = vfb->devid; |
keir@20509 | 1403 device.domid = vfb->domid; |
keir@20509 | 1404 device.kind = DEVICE_VFB; |
keir@20509 | 1405 |
keir@20516 | 1406 flexarray_set(back, boffset++, "frontend-id"); |
keir@20509 | 1407 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", vfb->domid)); |
keir@20516 | 1408 flexarray_set(back, boffset++, "online"); |
keir@20516 | 1409 flexarray_set(back, boffset++, "1"); |
keir@20516 | 1410 flexarray_set(back, boffset++, "state"); |
keir@20509 | 1411 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", 1)); |
keir@20516 | 1412 flexarray_set(back, boffset++, "domain"); |
keir@20516 | 1413 flexarray_set(back, boffset++, libxl_domid_to_name(ctx, domid)); |
keir@20516 | 1414 flexarray_set(back, boffset++, "vnc"); |
keir@20509 | 1415 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", vfb->vnc)); |
keir@20516 | 1416 flexarray_set(back, boffset++, "vnclisten"); |
keir@20516 | 1417 flexarray_set(back, boffset++, vfb->vnclisten); |
keir@20516 | 1418 flexarray_set(back, boffset++, "vncdisplay"); |
keir@20509 | 1419 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", vfb->vncdisplay)); |
keir@20516 | 1420 flexarray_set(back, boffset++, "vncunused"); |
keir@20509 | 1421 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", vfb->vncunused)); |
keir@20516 | 1422 flexarray_set(back, boffset++, "sdl"); |
keir@20509 | 1423 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", vfb->sdl)); |
keir@20516 | 1424 flexarray_set(back, boffset++, "opengl"); |
keir@20509 | 1425 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", vfb->opengl)); |
keir@20509 | 1426 if (vfb->xauthority) { |
keir@20516 | 1427 flexarray_set(back, boffset++, "xauthority"); |
keir@20516 | 1428 flexarray_set(back, boffset++, vfb->xauthority); |
keir@20509 | 1429 } |
keir@20509 | 1430 if (vfb->display) { |
keir@20516 | 1431 flexarray_set(back, boffset++, "display"); |
keir@20516 | 1432 flexarray_set(back, boffset++, vfb->display); |
keir@20509 | 1433 } |
keir@20509 | 1434 |
keir@20516 | 1435 flexarray_set(front, foffset++, "backend-id"); |
keir@20509 | 1436 flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", vfb->backend_domid)); |
keir@20516 | 1437 flexarray_set(front, foffset++, "state"); |
keir@20509 | 1438 flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", 1)); |
keir@20509 | 1439 |
keir@20509 | 1440 libxl_device_generic_add(ctx, &device, |
keir@20509 | 1441 libxl_xs_kvs_of_flexarray(ctx, back, boffset), |
keir@20509 | 1442 libxl_xs_kvs_of_flexarray(ctx, front, foffset)); |
keir@20509 | 1443 flexarray_free(front); |
keir@20509 | 1444 flexarray_free(back); |
keir@20509 | 1445 |
keir@20509 | 1446 return 0; |
keir@20462 | 1447 } |
keir@20462 | 1448 |
keir@20462 | 1449 int libxl_device_vfb_clean_shutdown(struct libxl_ctx *ctx, uint32_t domid) |
keir@20462 | 1450 { |
keir@20462 | 1451 return ERROR_NI; |
keir@20462 | 1452 } |
keir@20462 | 1453 |
keir@20462 | 1454 int libxl_device_vfb_hard_shutdown(struct libxl_ctx *ctx, uint32_t domid) |
keir@20462 | 1455 { |
keir@20462 | 1456 return ERROR_NI; |
keir@20462 | 1457 } |
keir@20462 | 1458 |
keir@20462 | 1459 /******************************************************************************/ |
keir@20482 | 1460 |
keir@20482 | 1461 int libxl_device_pci_init(libxl_device_pci *pcidev, unsigned int domain, |
keir@20482 | 1462 unsigned int bus, unsigned int dev, |
keir@20482 | 1463 unsigned int func, unsigned int vdevfn) |
keir@20482 | 1464 { |
keir@20482 | 1465 pcidev->domain = domain; |
keir@20482 | 1466 pcidev->bus = bus; |
keir@20482 | 1467 pcidev->dev = dev; |
keir@20482 | 1468 pcidev->func = func; |
keir@20482 | 1469 pcidev->vdevfn = vdevfn; |
keir@20482 | 1470 return 0; |
keir@20482 | 1471 } |
keir@20482 | 1472 |
keir@20482 | 1473 static int libxl_create_pci_backend(struct libxl_ctx *ctx, uint32_t domid, libxl_device_pci *pcidev, int num) |
keir@20482 | 1474 { |
keir@20482 | 1475 flexarray_t *front; |
keir@20482 | 1476 flexarray_t *back; |
keir@20482 | 1477 unsigned int boffset = 0; |
keir@20482 | 1478 unsigned int foffset = 0; |
keir@20482 | 1479 libxl_device device; |
keir@20482 | 1480 int i; |
keir@20482 | 1481 |
keir@20482 | 1482 front = flexarray_make(16, 1); |
keir@20482 | 1483 if (!front) |
keir@20482 | 1484 return ERROR_NOMEM; |
keir@20482 | 1485 back = flexarray_make(16, 1); |
keir@20482 | 1486 if (!back) |
keir@20482 | 1487 return ERROR_NOMEM; |
keir@20482 | 1488 |
keir@20512 | 1489 XL_LOG(ctx, XL_LOG_DEBUG, "Creating pci backend"); |
keir@20482 | 1490 |
keir@20482 | 1491 /* add pci device */ |
keir@20482 | 1492 device.backend_devid = 0; |
keir@20482 | 1493 device.backend_domid = 0; |
keir@20482 | 1494 device.backend_kind = DEVICE_PCI; |
keir@20482 | 1495 device.devid = 0; |
keir@20482 | 1496 device.domid = domid; |
keir@20482 | 1497 device.kind = DEVICE_PCI; |
keir@20482 | 1498 |
keir@20516 | 1499 flexarray_set(back, boffset++, "frontend-id"); |
keir@20482 | 1500 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", domid)); |
keir@20516 | 1501 flexarray_set(back, boffset++, "online"); |
keir@20516 | 1502 flexarray_set(back, boffset++, "1"); |
keir@20516 | 1503 flexarray_set(back, boffset++, "state"); |
keir@20482 | 1504 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", 1)); |
keir@20516 | 1505 flexarray_set(back, boffset++, "domain"); |
keir@20516 | 1506 flexarray_set(back, boffset++, libxl_domid_to_name(ctx, domid)); |
keir@20482 | 1507 for (i = 0; i < num; i++) { |
keir@20482 | 1508 flexarray_set(back, boffset++, libxl_sprintf(ctx, "key-%d", i)); |
keir@20482 | 1509 flexarray_set(back, boffset++, libxl_sprintf(ctx, PCI_BDF, pcidev->domain, pcidev->bus, pcidev->dev, pcidev->func)); |
keir@20482 | 1510 flexarray_set(back, boffset++, libxl_sprintf(ctx, "dev-%d", i)); |
keir@20482 | 1511 flexarray_set(back, boffset++, libxl_sprintf(ctx, PCI_BDF, pcidev->domain, pcidev->bus, pcidev->dev, pcidev->func)); |
keir@20482 | 1512 if (pcidev->vdevfn) { |
keir@20482 | 1513 flexarray_set(back, boffset++, libxl_sprintf(ctx, "vdevfn-%d", i)); |
keir@20482 | 1514 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%x", pcidev->vdevfn)); |
keir@20482 | 1515 } |
keir@20482 | 1516 flexarray_set(back, boffset++, libxl_sprintf(ctx, "opts-%d", i)); |
keir@20482 | 1517 flexarray_set(back, boffset++, libxl_sprintf(ctx, "msitranslate=%d,power_mgmt=%d", pcidev->msitranslate, pcidev->power_mgmt)); |
keir@20482 | 1518 flexarray_set(back, boffset++, libxl_sprintf(ctx, "state-%d", i)); |
keir@20482 | 1519 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", 1)); |
keir@20482 | 1520 } |
keir@20516 | 1521 flexarray_set(back, boffset++, "num_devs"); |
keir@20482 | 1522 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", num)); |
keir@20482 | 1523 |
keir@20516 | 1524 flexarray_set(front, foffset++, "backend-id"); |
keir@20482 | 1525 flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", 0)); |
keir@20516 | 1526 flexarray_set(front, foffset++, "state"); |
keir@20482 | 1527 flexarray_set(front, foffset++, libxl_sprintf(ctx, "%d", 1)); |
keir@20482 | 1528 |
keir@20482 | 1529 libxl_device_generic_add(ctx, &device, |
keir@20482 | 1530 libxl_xs_kvs_of_flexarray(ctx, back, boffset), |
keir@20482 | 1531 libxl_xs_kvs_of_flexarray(ctx, front, foffset)); |
keir@20482 | 1532 |
keir@20482 | 1533 flexarray_free(back); |
keir@20482 | 1534 flexarray_free(front); |
keir@20482 | 1535 return 0; |
keir@20482 | 1536 } |
keir@20482 | 1537 |
keir@20482 | 1538 static int libxl_device_pci_add_xenstore(struct libxl_ctx *ctx, uint32_t domid, libxl_device_pci *pcidev) |
keir@20462 | 1539 { |
keir@20482 | 1540 flexarray_t *back; |
keir@20482 | 1541 char *num_devs, *be_path; |
keir@20482 | 1542 int num = 0; |
keir@20482 | 1543 unsigned int boffset = 0; |
keir@20482 | 1544 xs_transaction_t t; |
keir@20482 | 1545 |
keir@20516 | 1546 be_path = libxl_sprintf(ctx, "%s/backend/pci/%d/0", libxl_xs_get_dompath(ctx, 0), domid); |
keir@20482 | 1547 num_devs = libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/num_devs", be_path)); |
keir@20482 | 1548 if (!num_devs) |
keir@20482 | 1549 return libxl_create_pci_backend(ctx, domid, pcidev, 1); |
keir@20482 | 1550 |
keir@20482 | 1551 if (!is_hvm(ctx, domid)) { |
keir@20482 | 1552 if (libxl_wait_for_backend(ctx, be_path, "4") < 0) |
keir@20482 | 1553 return -1; |
keir@20482 | 1554 } |
keir@20482 | 1555 |
keir@20482 | 1556 back = flexarray_make(16, 1); |
keir@20482 | 1557 if (!back) |
keir@20482 | 1558 return ERROR_NOMEM; |
keir@20482 | 1559 |
keir@20512 | 1560 XL_LOG(ctx, XL_LOG_DEBUG, "Adding new pci device to xenstore"); |
keir@20482 | 1561 num = atoi(num_devs); |
keir@20482 | 1562 flexarray_set(back, boffset++, libxl_sprintf(ctx, "key-%d", num)); |
keir@20482 | 1563 flexarray_set(back, boffset++, libxl_sprintf(ctx, PCI_BDF, pcidev->domain, pcidev->bus, pcidev->dev, pcidev->func)); |
keir@20482 | 1564 flexarray_set(back, boffset++, libxl_sprintf(ctx, "dev-%d", num)); |
keir@20482 | 1565 flexarray_set(back, boffset++, libxl_sprintf(ctx, PCI_BDF, pcidev->domain, pcidev->bus, pcidev->dev, pcidev->func)); |
keir@20482 | 1566 if (pcidev->vdevfn) { |
keir@20482 | 1567 flexarray_set(back, boffset++, libxl_sprintf(ctx, "vdevfn-%d", num)); |
keir@20482 | 1568 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%x", pcidev->vdevfn)); |
keir@20482 | 1569 } |
keir@20482 | 1570 flexarray_set(back, boffset++, libxl_sprintf(ctx, "opts-%d", num)); |
keir@20482 | 1571 flexarray_set(back, boffset++, libxl_sprintf(ctx, "msitranslate=%d,power_mgmt=%d", pcidev->msitranslate, pcidev->power_mgmt)); |
keir@20482 | 1572 flexarray_set(back, boffset++, libxl_sprintf(ctx, "state-%d", num)); |
keir@20482 | 1573 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", 1)); |
keir@20516 | 1574 flexarray_set(back, boffset++, "num_devs"); |
keir@20482 | 1575 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", num + 1)); |
keir@20516 | 1576 flexarray_set(back, boffset++, "state"); |
keir@20482 | 1577 flexarray_set(back, boffset++, libxl_sprintf(ctx, "%d", 7)); |
keir@20482 | 1578 |
keir@20482 | 1579 retry_transaction: |
keir@20482 | 1580 t = xs_transaction_start(ctx->xsh); |
keir@20482 | 1581 libxl_xs_writev(ctx, t, be_path, |
keir@20482 | 1582 libxl_xs_kvs_of_flexarray(ctx, back, boffset)); |
keir@20482 | 1583 if (!xs_transaction_end(ctx->xsh, t, 0)) |
keir@20482 | 1584 if (errno == EAGAIN) |
keir@20482 | 1585 goto retry_transaction; |
keir@20482 | 1586 |
keir@20482 | 1587 flexarray_free(back); |
keir@20482 | 1588 return 0; |
keir@20482 | 1589 } |
keir@20482 | 1590 |
keir@20482 | 1591 static int libxl_device_pci_remove_xenstore(struct libxl_ctx *ctx, uint32_t domid, libxl_device_pci *pcidev) |
keir@20482 | 1592 { |
keir@20542 | 1593 char *be_path, *num_devs_path, *num_devs, *xsdev, *tmp, *tmppath; |
keir@20542 | 1594 int num, i, j; |
keir@20482 | 1595 xs_transaction_t t; |
keir@20482 | 1596 unsigned int domain = 0, bus = 0, dev = 0, func = 0; |
keir@20482 | 1597 |
keir@20516 | 1598 be_path = libxl_sprintf(ctx, "%s/backend/pci/%d/0", libxl_xs_get_dompath(ctx, 0), domid); |
keir@20482 | 1599 num_devs_path = libxl_sprintf(ctx, "%s/num_devs", be_path); |
keir@20482 | 1600 num_devs = libxl_xs_read(ctx, XBT_NULL, num_devs_path); |
keir@20482 | 1601 if (!num_devs) |
keir@20482 | 1602 return -1; |
keir@20482 | 1603 num = atoi(num_devs); |
keir@20482 | 1604 |
keir@20482 | 1605 if (!is_hvm(ctx, domid)) { |
keir@20482 | 1606 if (libxl_wait_for_backend(ctx, be_path, "4") < 0) { |
keir@20542 | 1607 XL_LOG(ctx, XL_LOG_DEBUG, "pci backend at %s is not ready", be_path); |
keir@20482 | 1608 return -1; |
keir@20482 | 1609 } |
keir@20482 | 1610 } |
keir@20482 | 1611 |
keir@20482 | 1612 for (i = 0; i < num; i++) { |
keir@20482 | 1613 xsdev = libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/dev-%d", be_path, i)); |
keir@20482 | 1614 sscanf(xsdev, PCI_BDF, &domain, &bus, &dev, &func); |
keir@20482 | 1615 if (domain == pcidev->domain && bus == pcidev->bus && |
keir@20482 | 1616 pcidev->dev == dev && pcidev->func == func) { |
keir@20482 | 1617 break; |
keir@20482 | 1618 } |
keir@20482 | 1619 } |
keir@20482 | 1620 if (i == num) { |
keir@20512 | 1621 XL_LOG(ctx, XL_LOG_ERROR, "Couldn't find the device on xenstore"); |
keir@20482 | 1622 return -1; |
keir@20482 | 1623 } |
keir@20482 | 1624 |
keir@20482 | 1625 retry_transaction: |
keir@20482 | 1626 t = xs_transaction_start(ctx->xsh); |
keir@20542 | 1627 xs_write(ctx->xsh, t, libxl_sprintf(ctx, "%s/state-%d", be_path, i), "5", strlen("5")); |
keir@20482 | 1628 xs_write(ctx->xsh, t, libxl_sprintf(ctx, "%s/state", be_path), "7", strlen("7")); |
keir@20482 | 1629 if (!xs_transaction_end(ctx->xsh, t, 0)) |
keir@20482 | 1630 if (errno == EAGAIN) |
keir@20482 | 1631 goto retry_transaction; |
keir@20542 | 1632 |
keir@20542 | 1633 if (!is_hvm(ctx, domid)) { |
keir@20542 | 1634 if (libxl_wait_for_backend(ctx, be_path, "4") < 0) { |
keir@20542 | 1635 XL_LOG(ctx, XL_LOG_DEBUG, "pci backend at %s is not ready", be_path); |
keir@20542 | 1636 return -1; |
keir@20542 | 1637 } |
keir@20542 | 1638 } |
keir@20542 | 1639 |
keir@20542 | 1640 retry_transaction2: |
keir@20542 | 1641 t = xs_transaction_start(ctx->xsh); |
keir@20542 | 1642 xs_rm(ctx->xsh, t, libxl_sprintf(ctx, "%s/state-%d", be_path, i)); |
keir@20542 | 1643 xs_rm(ctx->xsh, t, libxl_sprintf(ctx, "%s/key-%d", be_path, i)); |
keir@20542 | 1644 xs_rm(ctx->xsh, t, libxl_sprintf(ctx, "%s/dev-%d", be_path, i)); |
keir@20542 | 1645 xs_rm(ctx->xsh, t, libxl_sprintf(ctx, "%s/vdev-%d", be_path, i)); |
keir@20542 | 1646 xs_rm(ctx->xsh, t, libxl_sprintf(ctx, "%s/opts-%d", be_path, i)); |
keir@20542 | 1647 xs_rm(ctx->xsh, t, libxl_sprintf(ctx, "%s/vdevfn-%d", be_path, i)); |
keir@20542 | 1648 libxl_xs_write(ctx, t, num_devs_path, "%d", num - 1); |
keir@20542 | 1649 for (j = i + 1; j < num; j++) { |
keir@20542 | 1650 tmppath = libxl_sprintf(ctx, "%s/state-%d", be_path, j); |
keir@20542 | 1651 tmp = libxl_xs_read(ctx, t, tmppath); |
keir@20542 | 1652 xs_write(ctx->xsh, t, libxl_sprintf(ctx, "%s/state-%d", be_path, j - 1), tmp, strlen(tmp)); |
keir@20542 | 1653 xs_rm(ctx->xsh, t, tmppath); |
keir@20542 | 1654 tmppath = libxl_sprintf(ctx, "%s/dev-%d", be_path, j); |
keir@20542 | 1655 tmp = libxl_xs_read(ctx, t, tmppath); |
keir@20542 | 1656 xs_write(ctx->xsh, t, libxl_sprintf(ctx, "%s/dev-%d", be_path, j - 1), tmp, strlen(tmp)); |
keir@20542 | 1657 xs_rm(ctx->xsh, t, tmppath); |
keir@20542 | 1658 tmppath = libxl_sprintf(ctx, "%s/key-%d", be_path, j); |
keir@20542 | 1659 tmp = libxl_xs_read(ctx, t, tmppath); |
keir@20542 | 1660 xs_write(ctx->xsh, t, libxl_sprintf(ctx, "%s/key-%d", be_path, j - 1), tmp, strlen(tmp)); |
keir@20542 | 1661 xs_rm(ctx->xsh, t, tmppath); |
keir@20542 | 1662 tmppath = libxl_sprintf(ctx, "%s/vdev-%d", be_path, j); |
keir@20542 | 1663 tmp = libxl_xs_read(ctx, t, tmppath); |
keir@20542 | 1664 if (tmp) { |
keir@20542 | 1665 xs_write(ctx->xsh, t, libxl_sprintf(ctx, "%s/vdev-%d", be_path, j - 1), tmp, strlen(tmp)); |
keir@20542 | 1666 xs_rm(ctx->xsh, t, tmppath); |
keir@20542 | 1667 } |
keir@20542 | 1668 tmppath = libxl_sprintf(ctx, "%s/opts-%d", be_path, j); |
keir@20542 | 1669 tmp = libxl_xs_read(ctx, t, tmppath); |
keir@20542 | 1670 if (tmp) { |
keir@20542 | 1671 xs_write(ctx->xsh, t, libxl_sprintf(ctx, "%s/opts-%d", be_path, j - 1), tmp, strlen(tmp)); |
keir@20542 | 1672 xs_rm(ctx->xsh, t, tmppath); |
keir@20542 | 1673 } |
keir@20542 | 1674 tmppath = libxl_sprintf(ctx, "%s/vdevfn-%d", be_path, j); |
keir@20542 | 1675 tmp = libxl_xs_read(ctx, t, tmppath); |
keir@20542 | 1676 if (tmp) { |
keir@20542 | 1677 xs_write(ctx->xsh, t, libxl_sprintf(ctx, "%s/vdevfn-%d", be_path, j - 1), tmp, strlen(tmp)); |
keir@20542 | 1678 xs_rm(ctx->xsh, t, tmppath); |
keir@20542 | 1679 } |
keir@20542 | 1680 } |
keir@20542 | 1681 if (!xs_transaction_end(ctx->xsh, t, 0)) |
keir@20542 | 1682 if (errno == EAGAIN) |
keir@20542 | 1683 goto retry_transaction2; |
keir@20542 | 1684 |
keir@20542 | 1685 if (num == 1) { |
keir@20542 | 1686 char *fe_path = libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/frontend", be_path)); |
keir@20542 | 1687 libxl_device_destroy(ctx, be_path, 1); |
keir@20542 | 1688 xs_rm(ctx->xsh, XBT_NULL, be_path); |
keir@20542 | 1689 xs_rm(ctx->xsh, XBT_NULL, fe_path); |
keir@20542 | 1690 return 0; |
keir@20542 | 1691 } |
keir@20542 | 1692 |
keir@20482 | 1693 return 0; |
keir@20462 | 1694 } |
keir@20462 | 1695 |
keir@20482 | 1696 int libxl_device_pci_add(struct libxl_ctx *ctx, uint32_t domid, libxl_device_pci *pcidev) |
keir@20462 | 1697 { |
keir@20482 | 1698 char path[50]; |
keir@20482 | 1699 char *state, *vdevfn; |
keir@20482 | 1700 int rc, hvm; |
keir@20542 | 1701 int stubdomid = 0; |
keir@20482 | 1702 |
keir@20482 | 1703 /* TODO: check if the device can be assigned */ |
keir@20482 | 1704 |
keir@20482 | 1705 libxl_device_pci_flr(ctx, pcidev->domain, pcidev->bus, pcidev->dev, pcidev->func); |
keir@20482 | 1706 |
keir@20542 | 1707 if ((stubdomid = libxl_get_stubdom_id(ctx, domid)) != 0) { |
keir@20542 | 1708 libxl_device_pci pcidev_s = *pcidev; |
keir@20542 | 1709 libxl_device_pci_add(ctx, stubdomid, &pcidev_s); |
keir@20542 | 1710 } |
keir@20542 | 1711 |
keir@20482 | 1712 hvm = is_hvm(ctx, domid); |
keir@20482 | 1713 if (hvm) { |
keir@20514 | 1714 if (libxl_wait_for_device_model(ctx, domid, "running", 0,0) < 0) { |
keir@20482 | 1715 return -1; |
keir@20482 | 1716 } |
keir@20482 | 1717 snprintf(path, sizeof(path), "/local/domain/0/device-model/%d/state", domid); |
keir@20482 | 1718 state = libxl_xs_read(ctx, XBT_NULL, path); |
keir@20482 | 1719 snprintf(path, sizeof(path), "/local/domain/0/device-model/%d/parameter", domid); |
keir@20482 | 1720 if (pcidev->vdevfn) |
keir@20482 | 1721 libxl_xs_write(ctx, XBT_NULL, path, PCI_BDF_VDEVFN, pcidev->domain, |
keir@20482 | 1722 pcidev->bus, pcidev->dev, pcidev->func, pcidev->vdevfn); |
keir@20482 | 1723 else |
keir@20482 | 1724 libxl_xs_write(ctx, XBT_NULL, path, PCI_BDF, pcidev->domain, |
keir@20482 | 1725 pcidev->bus, pcidev->dev, pcidev->func); |
keir@20482 | 1726 snprintf(path, sizeof(path), "/local/domain/0/device-model/%d/command", domid); |
keir@20482 | 1727 xs_write(ctx->xsh, XBT_NULL, path, "pci-ins", strlen("pci-ins")); |
keir@20514 | 1728 if (libxl_wait_for_device_model(ctx, domid, "pci-inserted", 0,0) < 0) |
keir@20512 | 1729 XL_LOG(ctx, XL_LOG_ERROR, "Device Model didn't respond in time"); |
keir@20482 | 1730 snprintf(path, sizeof(path), "/local/domain/0/device-model/%d/parameter", domid); |
keir@20482 | 1731 vdevfn = libxl_xs_read(ctx, XBT_NULL, path); |
keir@20482 | 1732 sscanf(vdevfn + 2, "%x", &pcidev->vdevfn); |
keir@20482 | 1733 snprintf(path, sizeof(path), "/local/domain/0/device-model/%d/state", domid); |
keir@20482 | 1734 xs_write(ctx->xsh, XBT_NULL, path, state, strlen(state)); |
keir@20482 | 1735 } else { |
keir@20542 | 1736 char *sysfs_path = libxl_sprintf(ctx, SYSFS_PCI_DEV"/"PCI_BDF"/resource", pcidev->domain, |
keir@20482 | 1737 pcidev->bus, pcidev->dev, pcidev->func); |
keir@20482 | 1738 FILE *f = fopen(sysfs_path, "r"); |
keir@20482 | 1739 unsigned int start = 0, end = 0, flags = 0, size = 0; |
keir@20482 | 1740 int irq = 0; |
keir@20482 | 1741 int i; |
keir@20482 | 1742 |
keir@20482 | 1743 if (f == NULL) { |
keir@20512 | 1744 XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "Couldn't open %s", sysfs_path); |
keir@20482 | 1745 return -1; |
keir@20482 | 1746 } |
keir@20482 | 1747 for (i = 0; i < PROC_PCI_NUM_RESOURCES; i++) { |
keir@20512 | 1748 fscanf(f, "0x%x 0x%x 0x%x", &start, &end, &flags); |
keir@20482 | 1749 size = end - start + 1; |
keir@20482 | 1750 if (start) { |
keir@20482 | 1751 if (flags & PCI_BAR_IO) { |
keir@20482 | 1752 rc = xc_domain_ioport_permission(ctx->xch, domid, start, size, 1); |
keir@20482 | 1753 if (rc < 0) |
keir@20512 | 1754 XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "Error: xc_domain_ioport_permission error 0x%x/0x%x", start, size); |
keir@20482 | 1755 } else { |
keir@20482 | 1756 rc = xc_domain_iomem_permission(ctx->xch, domid, start>>XC_PAGE_SHIFT, |
keir@20482 | 1757 (size+(XC_PAGE_SIZE-1))>>XC_PAGE_SHIFT, 1); |
keir@20482 | 1758 if (rc < 0) |
keir@20512 | 1759 XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "Error: xc_domain_iomem_permission error 0x%x/0x%x", start, size); |
keir@20482 | 1760 } |
keir@20482 | 1761 } |
keir@20482 | 1762 } |
keir@20482 | 1763 fclose(f); |
keir@20542 | 1764 sysfs_path = libxl_sprintf(ctx, SYSFS_PCI_DEV"/"PCI_BDF"/irq", pcidev->domain, |
keir@20482 | 1765 pcidev->bus, pcidev->dev, pcidev->func); |
keir@20482 | 1766 f = fopen(sysfs_path, "r"); |
keir@20482 | 1767 if (f == NULL) { |
keir@20512 | 1768 XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "Couldn't open %s", sysfs_path); |
keir@20482 | 1769 goto out; |
keir@20482 | 1770 } |
keir@20482 | 1771 fscanf(f, "%u", &irq); |
keir@20482 | 1772 if (irq) { |
keir@20482 | 1773 rc = xc_physdev_map_pirq(ctx->xch, domid, irq, &irq); |
keir@20482 | 1774 if (rc < 0) { |
keir@20512 | 1775 XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "Error: xc_physdev_map_pirq irq=%d", irq); |
keir@20482 | 1776 } |
keir@20482 | 1777 rc = xc_domain_irq_permission(ctx->xch, domid, irq, 1); |
keir@20482 | 1778 if (rc < 0) { |
keir@20512 | 1779 XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "Error: xc_domain_irq_permission irq=%d", irq); |
keir@20482 | 1780 } |
keir@20482 | 1781 } |
keir@20482 | 1782 fclose(f); |
keir@20482 | 1783 } |
keir@20482 | 1784 out: |
keir@20542 | 1785 if (!libxl_is_stubdom(ctx, domid)) { |
keir@20542 | 1786 if ((rc = xc_assign_device(ctx->xch, domid, pcidev->value)) < 0) |
keir@20542 | 1787 XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "xc_assign_device failed"); |
keir@20542 | 1788 } |
keir@20482 | 1789 |
keir@20482 | 1790 libxl_device_pci_add_xenstore(ctx, domid, pcidev); |
keir@20482 | 1791 return 0; |
keir@20462 | 1792 } |
keir@20462 | 1793 |
keir@20482 | 1794 int libxl_device_pci_remove(struct libxl_ctx *ctx, uint32_t domid, libxl_device_pci *pcidev) |
keir@20462 | 1795 { |
keir@20482 | 1796 char path[50]; |
keir@20482 | 1797 char *state; |
keir@20482 | 1798 int hvm, rc; |
keir@20542 | 1799 int stubdomid = 0; |
keir@20482 | 1800 |
keir@20482 | 1801 /* TODO: check if the device can be detached */ |
keir@20542 | 1802 libxl_device_pci_remove_xenstore(ctx, domid, pcidev); |
keir@20482 | 1803 |
keir@20482 | 1804 hvm = is_hvm(ctx, domid); |
keir@20482 | 1805 if (hvm) { |
keir@20514 | 1806 if (libxl_wait_for_device_model(ctx, domid, "running", 0,0) < 0) { |
keir@20482 | 1807 return -1; |
keir@20482 | 1808 } |
keir@20482 | 1809 snprintf(path, sizeof(path), "/local/domain/0/device-model/%d/state", domid); |
keir@20482 | 1810 state = libxl_xs_read(ctx, XBT_NULL, path); |
keir@20482 | 1811 snprintf(path, sizeof(path), "/local/domain/0/device-model/%d/parameter", domid); |
keir@20482 | 1812 libxl_xs_write(ctx, XBT_NULL, path, PCI_BDF, pcidev->domain, |
keir@20482 | 1813 pcidev->bus, pcidev->dev, pcidev->func); |
keir@20482 | 1814 snprintf(path, sizeof(path), "/local/domain/0/device-model/%d/command", domid); |
keir@20482 | 1815 xs_write(ctx->xsh, XBT_NULL, path, "pci-rem", strlen("pci-rem")); |
keir@20514 | 1816 if (libxl_wait_for_device_model(ctx, domid, "pci-removed", 0,0) < 0) { |
keir@20512 | 1817 XL_LOG(ctx, XL_LOG_ERROR, "Device Model didn't respond in time"); |
keir@20482 | 1818 return -1; |
keir@20482 | 1819 } |
keir@20482 | 1820 snprintf(path, sizeof(path), "/local/domain/0/device-model/%d/state", domid); |
keir@20482 | 1821 xs_write(ctx->xsh, XBT_NULL, path, state, strlen(state)); |
keir@20482 | 1822 } else { |
keir@20542 | 1823 char *sysfs_path = libxl_sprintf(ctx, SYSFS_PCI_DEV"/"PCI_BDF"/resource", pcidev->domain, |
keir@20482 | 1824 pcidev->bus, pcidev->dev, pcidev->func); |
keir@20482 | 1825 FILE *f = fopen(sysfs_path, "r"); |
keir@20482 | 1826 unsigned int start = 0, end = 0, flags = 0, size = 0; |
keir@20482 | 1827 int irq = 0; |
keir@20482 | 1828 int i; |
keir@20482 | 1829 |
keir@20482 | 1830 if (f == NULL) { |
keir@20512 | 1831 XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "Couldn't open %s", sysfs_path); |
keir@20482 | 1832 goto skip1; |
keir@20482 | 1833 } |
keir@20482 | 1834 for (i = 0; i < PROC_PCI_NUM_RESOURCES; i++) { |
keir@20482 | 1835 fscanf(f, "0x%x 0x%x 0x%x\n", &start, &end, &flags); |
keir@20482 | 1836 size = end - start + 1; |
keir@20482 | 1837 if (start) { |
keir@20482 | 1838 if (flags & PCI_BAR_IO) { |
keir@20482 | 1839 rc = xc_domain_ioport_permission(ctx->xch, domid, start, size, 0); |
keir@20482 | 1840 if (rc < 0) |
keir@20512 | 1841 XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "xc_domain_ioport_permission error 0x%x/0x%x", start, size); |
keir@20482 | 1842 } else { |
keir@20482 | 1843 rc = xc_domain_iomem_permission(ctx->xch, domid, start>>XC_PAGE_SHIFT, |
keir@20482 | 1844 (size+(XC_PAGE_SIZE-1))>>XC_PAGE_SHIFT, 0); |
keir@20482 | 1845 if (rc < 0) |
keir@20512 | 1846 XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "xc_domain_iomem_permission error 0x%x/0x%x", start, size); |
keir@20482 | 1847 } |
keir@20482 | 1848 } |
keir@20482 | 1849 } |
keir@20482 | 1850 fclose(f); |
keir@20482 | 1851 skip1: |
keir@20542 | 1852 sysfs_path = libxl_sprintf(ctx, SYSFS_PCI_DEV"/"PCI_BDF"/irq", pcidev->domain, |
keir@20482 | 1853 pcidev->bus, pcidev->dev, pcidev->func); |
keir@20482 | 1854 f = fopen(sysfs_path, "r"); |
keir@20482 | 1855 if (f == NULL) { |
keir@20512 | 1856 XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "Couldn't open %s", sysfs_path); |
keir@20482 | 1857 goto out; |
keir@20482 | 1858 } |
keir@20482 | 1859 fscanf(f, "%u", &irq); |
keir@20482 | 1860 if (irq) { |
keir@20482 | 1861 rc = xc_physdev_unmap_pirq(ctx->xch, domid, irq); |
keir@20482 | 1862 if (rc < 0) { |
keir@20512 | 1863 XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "xc_physdev_map_pirq irq=%d", irq); |
keir@20482 | 1864 } |
keir@20482 | 1865 rc = xc_domain_irq_permission(ctx->xch, domid, irq, 0); |
keir@20482 | 1866 if (rc < 0) { |
keir@20512 | 1867 XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "xc_domain_irq_permission irq=%d", irq); |
keir@20482 | 1868 } |
keir@20482 | 1869 } |
keir@20482 | 1870 fclose(f); |
keir@20482 | 1871 } |
keir@20482 | 1872 out: |
keir@20482 | 1873 libxl_device_pci_flr(ctx, pcidev->domain, pcidev->bus, pcidev->dev, pcidev->func); |
keir@20482 | 1874 |
keir@20542 | 1875 if (!libxl_is_stubdom(ctx, domid)) { |
keir@20542 | 1876 if ((rc = xc_deassign_device(ctx->xch, domid, pcidev->value)) < 0) |
keir@20542 | 1877 XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "xc_deassign_device failed"); |
keir@20542 | 1878 } |
keir@20542 | 1879 |
keir@20542 | 1880 if ((stubdomid = libxl_get_stubdom_id(ctx, domid)) != 0) { |
keir@20542 | 1881 libxl_device_pci pcidev_s = *pcidev; |
keir@20542 | 1882 libxl_device_pci_remove(ctx, stubdomid, &pcidev_s); |
keir@20542 | 1883 } |
keir@20542 | 1884 |
keir@20482 | 1885 return 0; |
keir@20462 | 1886 } |
keir@20482 | 1887 |
keir@20482 | 1888 libxl_device_pci *libxl_device_pci_list(struct libxl_ctx *ctx, uint32_t domid, int *num) |
keir@20482 | 1889 { |
keir@20482 | 1890 char *be_path, *num_devs, *xsdev, *xsvdevfn, *xsopts; |
keir@20482 | 1891 int n, i; |
keir@20482 | 1892 unsigned int domain = 0, bus = 0, dev = 0, func = 0, vdevfn = 0; |
keir@20482 | 1893 libxl_device_pci *pcidevs; |
keir@20482 | 1894 |
keir@20516 | 1895 be_path = libxl_sprintf(ctx, "%s/backend/pci/%d/0", libxl_xs_get_dompath(ctx, 0), domid); |
keir@20482 | 1896 num_devs = libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/num_devs", be_path)); |
keir@20482 | 1897 if (!num_devs) { |
keir@20482 | 1898 *num = 0; |
keir@20482 | 1899 return NULL; |
keir@20482 | 1900 } |
keir@20482 | 1901 n = atoi(num_devs); |
keir@20516 | 1902 pcidevs = (libxl_device_pci *) calloc(n, sizeof(libxl_device_pci)); |
keir@20482 | 1903 *num = n; |
keir@20482 | 1904 |
keir@20482 | 1905 for (i = 0; i < n; i++) { |
keir@20482 | 1906 xsdev = libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/dev-%d", be_path, i)); |
keir@20482 | 1907 sscanf(xsdev, PCI_BDF, &domain, &bus, &dev, &func); |
keir@20482 | 1908 xsvdevfn = libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/vdevfn-%d", be_path, i)); |
keir@20482 | 1909 if (xsvdevfn) |
keir@20482 | 1910 vdevfn = strtol(xsvdevfn, (char **) NULL, 16); |
keir@20482 | 1911 libxl_device_pci_init(pcidevs + i, domain, bus, dev, func, vdevfn); |
keir@20482 | 1912 xsopts = libxl_xs_read(ctx, XBT_NULL, libxl_sprintf(ctx, "%s/opts-%d", be_path, i)); |
keir@20482 | 1913 if (xsopts) { |
keir@20482 | 1914 char *saveptr; |
keir@20482 | 1915 char *p = strtok_r(xsopts, ",=", &saveptr); |
keir@20482 | 1916 do { |
keir@20482 | 1917 while (*p == ' ') |
keir@20482 | 1918 p++; |
keir@20482 | 1919 if (!strcmp(p, "msitranslate")) { |
keir@20482 | 1920 p = strtok_r(NULL, ",=", &saveptr); |
keir@20482 | 1921 pcidevs[i].msitranslate = atoi(p); |
keir@20482 | 1922 } else if (!strcmp(p, "power_mgmt")) { |
keir@20482 | 1923 p = strtok_r(NULL, ",=", &saveptr); |
keir@20482 | 1924 pcidevs[i].power_mgmt = atoi(p); |
keir@20482 | 1925 } |
keir@20482 | 1926 } while ((p = strtok_r(NULL, ",=", &saveptr)) != NULL); |
keir@20482 | 1927 } |
keir@20482 | 1928 } |
keir@20482 | 1929 return pcidevs; |
keir@20482 | 1930 } |
keir@20482 | 1931 |
keir@20482 | 1932 int libxl_device_pci_shutdown(struct libxl_ctx *ctx, uint32_t domid) |
keir@20482 | 1933 { |
keir@20482 | 1934 libxl_device_pci *pcidevs; |
keir@20482 | 1935 int num, i; |
keir@20482 | 1936 |
keir@20482 | 1937 pcidevs = libxl_device_pci_list(ctx, domid, &num); |
keir@20482 | 1938 for (i = 0; i < num; i++) { |
keir@20482 | 1939 if (libxl_device_pci_remove(ctx, domid, pcidevs + i) < 0) |
keir@20482 | 1940 return -1; |
keir@20482 | 1941 } |
keir@20516 | 1942 free(pcidevs); |
keir@20482 | 1943 return 0; |
keir@20482 | 1944 } |
keir@20482 | 1945 |
keir@20542 | 1946 void nic_info_domid_fixup(libxl_device_nic *nic_info, int domid) |
keir@20542 | 1947 { |
keir@20542 | 1948 nic_info->domid = domid; |
keir@20542 | 1949 asprintf(&(nic_info->ifname), "tap%d.%d", domid, nic_info->devid - 1); |
keir@20542 | 1950 } |
keir@20542 | 1951 |
keir@20542 | 1952 void disk_info_domid_fixup(libxl_device_disk *disk_info, int domid) |
keir@20542 | 1953 { |
keir@20542 | 1954 disk_info->domid = domid; |
keir@20542 | 1955 } |
keir@20542 | 1956 |
keir@20542 | 1957 void vfb_info_domid_fixup(libxl_device_vfb *vfb, int domid) |
keir@20542 | 1958 { |
keir@20542 | 1959 vfb->domid = domid; |
keir@20542 | 1960 } |
keir@20542 | 1961 |
keir@20542 | 1962 void vkb_info_domid_fixup(libxl_device_vkb *vkb, int domid) |
keir@20542 | 1963 { |
keir@20542 | 1964 vkb->domid = domid; |
keir@20542 | 1965 } |
keir@20542 | 1966 |
keir@20542 | 1967 void console_info_domid_fixup(libxl_device_console *console, int domid) |
keir@20542 | 1968 { |
keir@20542 | 1969 console->domid = domid; |
keir@20542 | 1970 } |
keir@20542 | 1971 |
keir@20542 | 1972 void device_model_info_domid_fixup(libxl_device_model_info *dm_info, int domid) |
keir@20542 | 1973 { |
keir@20542 | 1974 dm_info->domid = domid; |
keir@20542 | 1975 } |
keir@20542 | 1976 |
keir@20542 | 1977 void init_create_info(libxl_domain_create_info *c_info) |
keir@20542 | 1978 { |
keir@20542 | 1979 memset(c_info, '\0', sizeof(*c_info)); |
keir@20542 | 1980 c_info->xsdata = NULL; |
keir@20542 | 1981 c_info->platformdata = NULL; |
keir@20542 | 1982 c_info->hvm = 1; |
keir@20542 | 1983 c_info->ssidref = 0; |
keir@20542 | 1984 } |
keir@20542 | 1985 |
keir@20542 | 1986 void init_build_info(libxl_domain_build_info *b_info, libxl_domain_create_info *c_info) |
keir@20542 | 1987 { |
keir@20542 | 1988 memset(b_info, '\0', sizeof(*b_info)); |
keir@20542 | 1989 b_info->timer_mode = -1; |
keir@20542 | 1990 b_info->hpet = 1; |
keir@20542 | 1991 b_info->vpt_align = -1; |
keir@20542 | 1992 b_info->max_vcpus = 1; |
keir@20542 | 1993 b_info->max_memkb = 32 * 1024; |
keir@20542 | 1994 if (c_info->hvm) { |
keir@20542 | 1995 b_info->shadow_memkb = libxl_get_required_shadow_memory(b_info->max_memkb, b_info->max_vcpus); |
keir@20542 | 1996 b_info->video_memkb = 8 * 1024; |
keir@20542 | 1997 b_info->kernel = "/usr/lib/xen/boot/hvmloader"; |
keir@20542 | 1998 b_info->hvm = 1; |
keir@20542 | 1999 b_info->u.hvm.pae = 1; |
keir@20542 | 2000 b_info->u.hvm.apic = 1; |
keir@20542 | 2001 b_info->u.hvm.acpi = 1; |
keir@20542 | 2002 b_info->u.hvm.nx = 1; |
keir@20542 | 2003 b_info->u.hvm.viridian = 0; |
keir@20542 | 2004 } |
keir@20542 | 2005 } |
keir@20542 | 2006 |
keir@20542 | 2007 void init_dm_info(libxl_device_model_info *dm_info, |
keir@20542 | 2008 libxl_domain_create_info *c_info, libxl_domain_build_info *b_info) |
keir@20542 | 2009 { |
keir@20542 | 2010 memset(dm_info, '\0', sizeof(*dm_info)); |
keir@20542 | 2011 |
keir@20542 | 2012 dm_info->dom_name = c_info->name; |
keir@20542 | 2013 dm_info->device_model = "/usr/lib/xen/bin/qemu-dm"; |
keir@20542 | 2014 dm_info->videoram = b_info->video_memkb / 1024; |
keir@20542 | 2015 dm_info->apic = b_info->u.hvm.apic; |
keir@20542 | 2016 |
keir@20542 | 2017 dm_info->stdvga = 0; |
keir@20542 | 2018 dm_info->vnc = 1; |
keir@20542 | 2019 dm_info->vnclisten = "127.0.0.1"; |
keir@20542 | 2020 dm_info->vncdisplay = 0; |
keir@20542 | 2021 dm_info->vncunused = 0; |
keir@20542 | 2022 dm_info->keymap = NULL; |
keir@20542 | 2023 dm_info->sdl = 0; |
keir@20542 | 2024 dm_info->opengl = 0; |
keir@20542 | 2025 dm_info->nographic = 0; |
keir@20542 | 2026 dm_info->serial = NULL; |
keir@20542 | 2027 dm_info->boot = "cda"; |
keir@20542 | 2028 dm_info->usb = 0; |
keir@20542 | 2029 dm_info->usbdevice = NULL; |
keir@20542 | 2030 } |
keir@20542 | 2031 |
keir@20542 | 2032 void init_nic_info(libxl_device_nic *nic_info, int devnum) |
keir@20542 | 2033 { |
keir@20542 | 2034 memset(nic_info, '\0', sizeof(*nic_info)); |
keir@20542 | 2035 |
keir@20542 | 2036 |
keir@20542 | 2037 nic_info->backend_domid = 0; |
keir@20542 | 2038 nic_info->domid = 0; |
keir@20542 | 2039 nic_info->devid = devnum; |
keir@20542 | 2040 nic_info->mtu = 1492; |
keir@20542 | 2041 nic_info->model = "e1000"; |
keir@20542 | 2042 srand(time(0)); |
keir@20542 | 2043 nic_info->mac[0] = 0x00; |
keir@20542 | 2044 nic_info->mac[1] = 0x16; |
keir@20542 | 2045 nic_info->mac[2] = 0x3e; |
keir@20542 | 2046 nic_info->mac[3] = 1 + (int) (0x7f * (rand() / (RAND_MAX + 1.0))); |
keir@20542 | 2047 nic_info->mac[4] = 1 + (int) (0xff * (rand() / (RAND_MAX + 1.0))); |
keir@20542 | 2048 nic_info->mac[5] = 1 + (int) (0xff * (rand() / (RAND_MAX + 1.0))); |
keir@20542 | 2049 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 | 2050 nic_info->ifname = NULL; |
keir@20542 | 2051 nic_info->bridge = "xenbr0"; |
keir@20542 | 2052 nic_info->script = "/etc/xen/scripts/vif-bridge"; |
keir@20542 | 2053 nic_info->nictype = NICTYPE_IOEMU; |
keir@20542 | 2054 } |
keir@20542 | 2055 |
keir@20542 | 2056 void init_vfb_info(libxl_device_vfb *vfb, int dev_num) |
keir@20542 | 2057 { |
keir@20542 | 2058 memset(vfb, 0x00, sizeof(libxl_device_vfb)); |
keir@20542 | 2059 vfb->devid = dev_num; |
keir@20542 | 2060 vfb->vnc = 1; |
keir@20542 | 2061 vfb->vnclisten = "127.0.0.1"; |
keir@20542 | 2062 vfb->vncdisplay = 0; |
keir@20542 | 2063 vfb->vncunused = 1; |
keir@20542 | 2064 vfb->keymap = NULL; |
keir@20542 | 2065 vfb->sdl = 0; |
keir@20542 | 2066 vfb->opengl = 0; |
keir@20542 | 2067 } |
keir@20542 | 2068 |
keir@20542 | 2069 void init_vkb_info(libxl_device_vkb *vkb, int dev_num) |
keir@20542 | 2070 { |
keir@20542 | 2071 memset(vkb, 0x00, sizeof(libxl_device_vkb)); |
keir@20542 | 2072 vkb->devid = dev_num; |
keir@20542 | 2073 } |
keir@20542 | 2074 |
keir@20542 | 2075 void init_console_info(libxl_device_console *console, int dev_num, libxl_domain_build_state *state) |
keir@20542 | 2076 { |
keir@20542 | 2077 memset(console, 0x00, sizeof(libxl_device_console)); |
keir@20542 | 2078 console->devid = dev_num; |
keir@20542 | 2079 console->constype = CONSTYPE_XENCONSOLED; |
keir@20542 | 2080 if (state) |
keir@20542 | 2081 console->build_state = state; |
keir@20542 | 2082 } |
keir@20542 | 2083 |
keir@20542 | 2084 |