[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index] [Xen-devel] [PATCH 3 of 11] libxl: introduce libxl_set_relative_memory_target
Introduce libxl_set_relative_memory_target to modify the memory target of a domain by a relative amount of memory in a single xenstore transaction. The first time we are reading/writing dom0 memory target, fill the informations in xenstore if they are missing. Signed-off-by: Stefano Stabellini <stefano.stabellini@xxxxxxxxxxxxx> diff -r 2731a625a7b1 tools/libxl/libxl.c --- a/tools/libxl/libxl.c Wed Sep 01 12:53:24 2010 +0100 +++ b/tools/libxl/libxl.c Wed Sep 01 12:53:53 2010 +0100 @@ -2720,6 +2720,53 @@ int libxl_device_vfb_hard_shutdown(libxl /******************************************************************************/ +static int libxl__fill_dom0_memory_info(libxl_gc *gc, uint32_t *target_memkb) +{ + int rc; + xc_domaininfo_t info; + char *target = NULL, *endptr = NULL; + char *target_path = "/local/domain/0/memory/target"; + char *max_path = "/local/domain/0/memory/static-max"; + xs_transaction_t t; + libxl_ctx *ctx = libxl_gc_owner(gc); + +retry_transaction: + t = xs_transaction_start(ctx->xsh); + + target = libxl_xs_read(gc, t, target_path); + if (target) { + *target_memkb = strtoul(target, &endptr, 10); + if (*endptr != '\0') { + XL_LOG_ERRNO(ctx, XL_LOG_ERROR, + "invalid memory target %s from %s\n", target, target_path); + rc = ERROR_FAIL; + goto out; + } + rc = 0; + goto out; + } + + rc = xc_domain_getinfolist(ctx->xch, 0, 1, &info); + if (rc < 0) + return rc; + + libxl_xs_write(gc, t, target_path, "%"PRIu32, + (uint32_t) PAGE_TO_MEMKB(info.tot_pages)); + libxl_xs_write(gc, t, max_path, "%"PRIu32, + (uint32_t) PAGE_TO_MEMKB(info.max_pages)); + + *target_memkb = (uint32_t) PAGE_TO_MEMKB(info.tot_pages); + rc = 0; + +out: + if (!xs_transaction_end(ctx->xsh, t, 0)) + if (errno == EAGAIN) + goto retry_transaction; + + + return rc; +} + int libxl_set_memory_target(libxl_ctx *ctx, uint32_t domid, uint32_t target_memkb, int enforce) { @@ -2787,6 +2834,163 @@ out: return rc; } +int libxl_set_relative_memory_target(libxl_ctx *ctx, uint32_t domid, + int32_t relative_target_memkb, int enforce) +{ + libxl_gc gc = LIBXL_INIT_GC(ctx); + int rc = 1, abort = 0; + uint32_t memorykb = 0, videoram = 0, target_memkb = 0, new_target_memkb = 0; + char *memmax, *endptr, *videoram_s = NULL, *target = NULL; + char *dompath = libxl_xs_get_dompath(&gc, domid); + xc_domaininfo_t info; + libxl_dominfo ptr; + char *uuid; + xs_transaction_t t; + +retry_transaction: + t = xs_transaction_start(ctx->xsh); + + target = libxl_xs_read(&gc, t, libxl_sprintf(&gc, + "%s/memory/target", dompath)); + if (!target && !domid) { + xs_transaction_end(ctx->xsh, t, 1); + rc = libxl__fill_dom0_memory_info(&gc, &target_memkb); + if (rc < 0) { + abort = 1; + goto out; + } + goto retry_transaction; + } else if (!target) { + XL_LOG_ERRNO(ctx, XL_LOG_ERROR, + "cannot get target memory info from %s/memory/target\n", + dompath); + abort = 1; + goto out; + } else { + target_memkb = strtoul(target, &endptr, 10); + if (*endptr != '\0') { + XL_LOG_ERRNO(ctx, XL_LOG_ERROR, + "invalid memory target %s from %s/memory/target\n", + target, dompath); + abort = 1; + goto out; + } + } + memmax = libxl_xs_read(&gc, t, libxl_sprintf(&gc, + "%s/memory/static-max", dompath)); + if (!memmax) { + XL_LOG_ERRNO(ctx, XL_LOG_ERROR, + "cannot get memory info from %s/memory/static-max\n", + dompath); + abort = 1; + goto out; + } + memorykb = strtoul(memmax, &endptr, 10); + if (*endptr != '\0') { + XL_LOG_ERRNO(ctx, XL_LOG_ERROR, + "invalid max memory %s from %s/memory/static-max\n", + memmax, dompath); + abort = 1; + goto out; + } + + new_target_memkb = target_memkb + relative_target_memkb; + if (new_target_memkb > memorykb) { + XL_LOG(ctx, XL_LOG_ERROR, + "memory_dynamic_max must be less than or equal to" + " memory_static_max\n"); + abort = 1; + goto out; + } + + videoram_s = libxl_xs_read(&gc, t, libxl_sprintf(&gc, + "%s/memory/videoram", dompath)); + videoram = videoram_s ? atoi(videoram_s) : 0; + + if (enforce) { + memorykb = new_target_memkb; + rc = xc_domain_setmaxmem(ctx->xch, domid, memorykb + + LIBXL_MAXMEM_CONSTANT); + if (rc != 0) { + XL_LOG_ERRNO(ctx, XL_LOG_ERROR, + "xc_domain_setmaxmem domid=%d memkb=%d failed " + "rc=%d\n", domid, memorykb + LIBXL_MAXMEM_CONSTANT, rc); + abort = 1; + goto out; + } + libxl_xs_write(&gc, t, libxl_sprintf(&gc, + "%s/memory/static-max", dompath), "%"PRIu32, + memorykb); + } + + rc = xc_domain_memory_set_pod_target(ctx->xch, domid, + (new_target_memkb - videoram) / 4, NULL, NULL, NULL); + if (rc != 0) { + XL_LOG_ERRNO(ctx, XL_LOG_ERROR, + "xc_domain_memory_set_pod_target domid=%d, memkb=%d " + "failed rc=%d\n", domid, (new_target_memkb - videoram) / 4, + rc); + abort = 1; + goto out; + } + + libxl_xs_write(&gc, t, libxl_sprintf(&gc, "%s/memory/target", + dompath), "%"PRIu32, new_target_memkb); + rc = xc_domain_getinfolist(ctx->xch, domid, 1, &info); + if (rc != 1 || info.domain != domid) { + abort = 1; + goto out; + } + xcinfo2xlinfo(&info, &ptr); + uuid = libxl_uuid2string(&gc, ptr.uuid); + libxl_xs_write(&gc, t, libxl_sprintf(&gc, "/vm/%s/memory", uuid), + "%"PRIu32, new_target_memkb / 1024); + +out: + if (!xs_transaction_end(ctx->xsh, t, abort) && !abort) + if (errno == EAGAIN) + goto retry_transaction; + + libxl_free_all(&gc); + return rc; +} + +int libxl_get_memory_target(libxl_ctx *ctx, uint32_t domid, uint32_t *out_target) +{ + libxl_gc gc = LIBXL_INIT_GC(ctx); + int rc = 1; + char *target = NULL, *endptr = NULL; + char *dompath = libxl_xs_get_dompath(&gc, domid); + uint32_t target_memkb; + + target = libxl_xs_read(&gc, XBT_NULL, libxl_sprintf(&gc, + "%s/memory/target", dompath)); + if (!target && !domid) { + rc = libxl__fill_dom0_memory_info(&gc, &target_memkb); + if (rc < 0) + goto out; + } else if (!target) { + XL_LOG_ERRNO(ctx, XL_LOG_ERROR, + "cannot get target memory info from %s/memory/target\n", + dompath); + goto out; + } else { + target_memkb = strtoul(target, &endptr, 10); + if (*endptr != '\0') { + XL_LOG_ERRNO(ctx, XL_LOG_ERROR, + "invalid memory target %s from %s/memory/target\n", + target, dompath); + goto out; + } + } + *out_target = target_memkb; + rc = 0; + +out: + libxl_free_all(&gc); + return rc; +} + int libxl_button_press(libxl_ctx *ctx, uint32_t domid, libxl_button button) { int rc = -1; diff -r 2731a625a7b1 tools/libxl/libxl.h --- a/tools/libxl/libxl.h Wed Sep 01 12:53:24 2010 +0100 +++ b/tools/libxl/libxl.h Wed Sep 01 12:53:53 2010 +0100 @@ -321,6 +321,8 @@ int libxl_domain_unpause(libxl_ctx *ctx, int libxl_domain_core_dump(libxl_ctx *ctx, uint32_t domid, const char *filename); int libxl_set_memory_target(libxl_ctx *ctx, uint32_t domid, uint32_t target_memkb, int enforce); +int libxl_set_relative_memory_target(libxl_ctx *ctx, uint32_t domid, int32_t relative_target_memkb, int enforce); +int libxl_get_memory_target(libxl_ctx *ctx, uint32_t domid, uint32_t *out_target); int libxl_vncviewer_exec(libxl_ctx *ctx, uint32_t domid, int autopass); int libxl_console_exec(libxl_ctx *ctx, uint32_t domid, int cons_num, libxl_console_constype type); _______________________________________________ Xen-devel mailing list Xen-devel@xxxxxxxxxxxxxxxxxxx http://lists.xensource.com/xen-devel
|
Lists.xenproject.org is hosted with RackSpace, monitoring our |