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