|
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index] [Xen-changelog] [xen-unstable] libxl: consistent handling of libxc errors
# HG changeset patch
# User Gianni Tedesco <gianni.tedesco@xxxxxxxxxx>
# Date 1279902388 -3600
# Node ID e23302fcb83c72f93ec01285bd7f4f1641eb67e4
# Parent 098dacea3ae0318e9fdec5e66f51fc1742980ead
libxl: consistent handling of libxc errors
Lots of places in libxl return -1 as an error which is inconsistent with
libxl error codes since that is ERROR_VERSION. Also in other places the
xc_* function to implement a command is called but the return value is
either never checked or not passed on.
This patch makes callers of libxc functions use XL_LOG_ERRNO to log a
suitable message including the contents of errno, before returning
ERROR_FAIL, if an xc call fails. (Except for pci device removals and
domain destroys where release of resources ought to continue even if
an error occurs in an early step. In this case the error is still
logged at least.)
Also a bug is fixed where a caller depends on errno being set but is
cleared by cleanup code which calls in to library functions which modify
errno as a side-effect.
This is version 2 of the patch previously applied as 91c486918e02.
Changed since then: Removed mapping from libxc error codes to libxl -
this is redundant because libxl ought to return -1 with errno set to a
meaningful value.
Signed-off-by: Gianni Tedesco <gianni.tedesco@xxxxxxxxxx>
Signed-off-by: Ian Jackson <ian.jackson@xxxxxxxxxxxxx>
Committed-by: Ian Jackson <ian.jackson@xxxxxxxxxxxxx>
---
tools/libxl/libxl.c | 228 ++++++++++++++++++++++++++++++-------------
tools/libxl/libxl_dom.c | 23 ++--
tools/libxl/libxl_internal.h | 3
3 files changed, 179 insertions(+), 75 deletions(-)
diff -r 098dacea3ae0 -r e23302fcb83c tools/libxl/libxl.c
--- a/tools/libxl/libxl.c Fri Jul 23 17:06:16 2010 +0100
+++ b/tools/libxl/libxl.c Fri Jul 23 17:26:28 2010 +0100
@@ -433,10 +433,16 @@ struct libxl_dominfo * libxl_list_domain
int size = 1024;
ptr = calloc(size, sizeof(struct libxl_dominfo));
- if (!ptr) return NULL;
+ if (!ptr) {
+ XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "allocating domain info");
+ return NULL;
+ }
ret = xc_domain_getinfolist(ctx->xch, 0, 1024, info);
- if (ret<0) return NULL;
+ if (ret<0) {
+ XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "geting domain info list");
+ return NULL;
+ }
for (i = 0; i < ret; i++) {
xcinfo2xlinfo(&info[i], &ptr[i]);
@@ -451,7 +457,10 @@ int libxl_domain_info(struct libxl_ctx *
int ret;
ret = xc_domain_getinfolist(ctx->xch, domid, 1, &xcinfo);
- if (ret<0) return ERROR_FAIL;
+ if (ret<0) {
+ XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "geting domain info list");
+ return ERROR_FAIL;
+ }
if (ret==0 || xcinfo.domain != domid) return ERROR_INVAL;
xcinfo2xlinfo(&xcinfo, info_r);
@@ -466,10 +475,16 @@ struct libxl_poolinfo * libxl_list_pool(
int size = 256;
ptr = calloc(size, sizeof(struct libxl_poolinfo));
- if (!ptr) return NULL;
+ if (!ptr) {
+ XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "allocating cpupool info");
+ return NULL;
+ }
ret = xc_cpupool_getinfo(ctx->xch, 0, 256, info);
- if (ret<0) return NULL;
+ if (ret<0) {
+ XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "getting cpupool info");
+ return NULL;
+ }
for (i = 0; i < ret; i++) {
ptr[i].poolid = info[i].cpupool_id;
@@ -491,6 +506,10 @@ struct libxl_vminfo * libxl_list_vm(stru
return NULL;
ret = xc_domain_getinfolist(ctx->xch, 1, 1024, info);
+ if (ret<0) {
+ XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "geting domain info list");
+ return NULL;
+ }
for (index = i = 0; i < ret; i++) {
if (libxl_is_stubdom(ctx, info[i].domain, NULL))
continue;
@@ -518,14 +537,25 @@ int libxl_domain_suspend(struct libxl_ct
int libxl_domain_pause(struct libxl_ctx *ctx, uint32_t domid)
{
- xc_domain_pause(ctx->xch, domid);
- return 0;
-}
-
-int libxl_domain_core_dump(struct libxl_ctx *ctx, uint32_t domid, const char
*filename)
-{
- if ( xc_domain_dumpcore(ctx->xch, domid, filename) )
- return ERROR_FAIL;
+ int ret;
+ ret = xc_domain_pause(ctx->xch, domid);
+ if (ret<0) {
+ XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "pausing domain %d", domid);
+ return ERROR_FAIL;
+ }
+ return 0;
+}
+
+int libxl_domain_core_dump(struct libxl_ctx *ctx, uint32_t domid,
+ const char *filename)
+{
+ int ret;
+ ret = xc_domain_dumpcore(ctx->xch, domid, filename);
+ if (ret<0) {
+ XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "core dumping domain %d to %s",
+ domid, filename);
+ return ERROR_FAIL;
+ }
return 0;
}
@@ -533,6 +563,7 @@ int libxl_domain_unpause(struct libxl_ct
{
char *path;
char *state;
+ int ret;
if (is_hvm(ctx, domid)) {
path = libxl_sprintf(ctx, "/local/domain/0/device-model/%d/state",
domid);
@@ -542,8 +573,11 @@ int libxl_domain_unpause(struct libxl_ct
libxl_wait_for_device_model(ctx, domid, "running", NULL, NULL);
}
}
- xc_domain_unpause(ctx->xch, domid);
-
+ ret = xc_domain_unpause(ctx->xch, domid);
+ if (ret<0) {
+ XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "unpausing domain %d", domid);
+ return ERROR_FAIL;
+ }
return 0;
}
@@ -573,10 +607,24 @@ int libxl_domain_shutdown(struct libxl_c
if (is_hvm(ctx,domid)) {
unsigned long acpi_s_state = 0;
unsigned long pvdriver = 0;
- xc_get_hvm_param(ctx->xch, domid, HVM_PARAM_ACPI_S_STATE,
&acpi_s_state);
- xc_get_hvm_param(ctx->xch, domid, HVM_PARAM_CALLBACK_IRQ, &pvdriver);
- if (!pvdriver || acpi_s_state != 0)
- xc_domain_shutdown(ctx->xch, domid, req);
+ int ret;
+ ret = xc_get_hvm_param(ctx->xch, domid, HVM_PARAM_ACPI_S_STATE,
&acpi_s_state);
+ if (ret<0) {
+ XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "getting ACPI S-state");
+ return ERROR_FAIL;
+ }
+ ret = xc_get_hvm_param(ctx->xch, domid, HVM_PARAM_CALLBACK_IRQ,
&pvdriver);
+ if (ret<0) {
+ XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "getting HVM callback IRQ");
+ return ERROR_FAIL;
+ }
+ if (!pvdriver || acpi_s_state != 0) {
+ ret = xc_domain_shutdown(ctx->xch, domid, req);
+ if (ret<0) {
+ XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "unpausing domain");
+ return ERROR_FAIL;
+ }
+ }
}
return 0;
}
@@ -623,7 +671,7 @@ int libxl_get_event(struct libxl_ctx *ct
char **events = xs_read_watch(ctx->xsh, &num);
if (num != 2) {
free(events);
- return -1;
+ return ERROR_FAIL;
}
event->path = strdup(events[XS_WATCH_PATH]);
event->token = strdup(events[XS_WATCH_TOKEN]);
@@ -635,7 +683,7 @@ int libxl_stop_waiting(struct libxl_ctx
int libxl_stop_waiting(struct libxl_ctx *ctx, libxl_waiter *waiter)
{
if (!xs_unwatch(ctx->xsh, waiter->path, waiter->token))
- return -1;
+ return ERROR_FAIL;
else
return 0;
}
@@ -715,7 +763,7 @@ static int libxl_destroy_device_model(st
int stubdomid = libxl_get_stubdom_id(ctx, domid);
if (!stubdomid) {
XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "Couldn't find device model's
pid");
- return -1;
+ return ERROR_INVAL;
}
XL_LOG(ctx, XL_LOG_ERROR, "Device model is a stubdom, domid=%d\n",
stubdomid);
return libxl_domain_destroy(ctx, stubdomid, 0);
@@ -753,7 +801,7 @@ int libxl_domain_destroy(struct libxl_ct
dom_path = libxl_xs_get_dompath(ctx, domid);
if (!dom_path)
- return -1;
+ return ERROR_FAIL;
if (libxl_device_pci_shutdown(ctx, domid) < 0)
XL_LOG(ctx, XL_LOG_ERROR, "pci shutdown failed for domid %d", domid);
@@ -765,7 +813,6 @@ int libxl_domain_destroy(struct libxl_ct
rc = xc_domain_pause(ctx->xch, domid);
if (rc < 0) {
XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "xc_domain_pause failed for
%d", domid);
- return -1;
}
if (dm_present) {
if (libxl_destroy_device_model(ctx, domid) < 0)
@@ -797,7 +844,7 @@ int libxl_domain_destroy(struct libxl_ct
rc = xc_domain_destroy(ctx->xch, domid);
if (rc < 0) {
XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "xc_domain_destroy failed for
%d", domid);
- return -1;
+ return ERROR_FAIL;
}
return 0;
}
@@ -1163,7 +1210,11 @@ static int libxl_create_stubdom(struct l
libxl_xs_write(ctx, XBT_NULL,
libxl_sprintf(ctx, "%s/target", libxl_xs_get_dompath(ctx,
domid)),
"%d", info->domid);
- xc_domain_set_target(ctx->xch, domid, info->domid);
+ ret = xc_domain_set_target(ctx->xch, domid, info->domid);
+ if (ret<0) {
+ XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "setting target domain %d -> %d",
domid, info->domid);
+ return ERROR_FAIL;
+ }
xs_set_target(ctx->xsh, domid, info->domid);
perm[0].id = domid;
@@ -1215,11 +1266,11 @@ retry_transaction:
}
if (libxl_create_xenpv_qemu(ctx, vfb, num_console, console, &dm_starting)
< 0) {
free(args);
- return -1;
+ return ERROR_FAIL;
}
if (libxl_confirm_device_model_startup(ctx, dm_starting) < 0) {
free(args);
- return -1;
+ return ERROR_FAIL;
}
libxl_domain_unpause(ctx, domid);
@@ -1401,7 +1452,7 @@ int libxl_device_disk_add(struct libxl_c
const char *dev = libxl_blktap_devpath(ctx,
disk->physpath, disk->phystype);
if (!dev)
- return -1;
+ return ERROR_FAIL;
flexarray_set(back, boffset++, "tapdisk-params");
flexarray_set(back, boffset++, libxl_sprintf(ctx, "%s:%s",
device_disk_string_of_phystype(disk->phystype), disk->physpath));
flexarray_set(back, boffset++, "params");
@@ -2099,7 +2150,7 @@ int libxl_cdrom_insert(struct libxl_ctx
}
if (i == num) {
XL_LOG(ctx, XL_LOG_ERROR, "Virtual device not found");
- return -1;
+ return ERROR_FAIL;
}
libxl_device_disk_del(ctx, disks + i, 1);
libxl_device_disk_add(ctx, domid, disk);
@@ -2349,7 +2400,7 @@ static int libxl_device_pci_add_xenstore
if (!is_hvm(ctx, domid)) {
if (libxl_wait_for_backend(ctx, be_path, "4") < 0)
- return -1;
+ return ERROR_FAIL;
}
back = flexarray_make(16, 1);
@@ -2398,13 +2449,13 @@ static int libxl_device_pci_remove_xenst
num_devs_path = libxl_sprintf(ctx, "%s/num_devs", be_path);
num_devs = libxl_xs_read(ctx, XBT_NULL, num_devs_path);
if (!num_devs)
- return -1;
+ return ERROR_INVAL;
num = atoi(num_devs);
if (!is_hvm(ctx, domid)) {
if (libxl_wait_for_backend(ctx, be_path, "4") < 0) {
XL_LOG(ctx, XL_LOG_DEBUG, "pci backend at %s is not ready",
be_path);
- return -1;
+ return ERROR_FAIL;
}
}
@@ -2418,7 +2469,7 @@ static int libxl_device_pci_remove_xenst
}
if (i == num) {
XL_LOG(ctx, XL_LOG_ERROR, "Couldn't find the device on xenstore");
- return -1;
+ return ERROR_INVAL;
}
retry_transaction:
@@ -2432,7 +2483,7 @@ retry_transaction:
if (!is_hvm(ctx, domid)) {
if (libxl_wait_for_backend(ctx, be_path, "4") < 0) {
XL_LOG(ctx, XL_LOG_DEBUG, "pci backend at %s is not ready",
be_path);
- return -1;
+ return ERROR_FAIL;
}
}
@@ -2512,7 +2563,7 @@ int libxl_device_pci_add(struct libxl_ct
hvm = is_hvm(ctx, domid);
if (hvm) {
if (libxl_wait_for_device_model(ctx, domid, "running", NULL, NULL) <
0) {
- return -1;
+ return ERROR_FAIL;
}
path = libxl_sprintf(ctx, "/local/domain/0/device-model/%d/state",
domid);
state = libxl_xs_read(ctx, XBT_NULL, path);
@@ -2542,7 +2593,7 @@ int libxl_device_pci_add(struct libxl_ct
if (f == NULL) {
XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "Couldn't open %s", sysfs_path);
- return -1;
+ return ERROR_FAIL;
}
for (i = 0; i < PROC_PCI_NUM_RESOURCES; i++) {
if (fscanf(f, "0x%llx 0x%llx 0x%llx\n", &start, &end, &flags) != 3)
@@ -2551,13 +2602,19 @@ int libxl_device_pci_add(struct libxl_ct
if (start) {
if (flags & PCI_BAR_IO) {
rc = xc_domain_ioport_permission(ctx->xch, domid, start,
size, 1);
- if (rc < 0)
+ if (rc < 0) {
XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "Error:
xc_domain_ioport_permission error 0x%llx/0x%llx", start, size);
+ fclose(f);
+ return ERROR_FAIL;
+ }
} else {
rc = xc_domain_iomem_permission(ctx->xch, domid,
start>>XC_PAGE_SHIFT,
(size+(XC_PAGE_SIZE-1))>>XC_PAGE_SHIFT, 1);
- if (rc < 0)
+ if (rc < 0) {
XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "Error:
xc_domain_iomem_permission error 0x%llx/0x%llx", start, size);
+ fclose(f);
+ return ERROR_FAIL;
+ }
}
}
}
@@ -2573,10 +2630,14 @@ int libxl_device_pci_add(struct libxl_ct
rc = xc_physdev_map_pirq(ctx->xch, domid, irq, &irq);
if (rc < 0) {
XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "Error:
xc_physdev_map_pirq irq=%d", irq);
+ fclose(f);
+ return ERROR_FAIL;
}
rc = xc_domain_irq_permission(ctx->xch, domid, irq, 1);
if (rc < 0) {
XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "Error:
xc_domain_irq_permission irq=%d", irq);
+ fclose(f);
+ return ERROR_FAIL;
}
}
fclose(f);
@@ -2584,8 +2645,10 @@ out:
out:
if (!libxl_is_stubdom(ctx, domid, NULL)) {
rc = xc_assign_device(ctx->xch, domid, pcidev->value);
- if (rc < 0)
+ if (rc < 0) {
XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc, "xc_assign_device failed");
+ return ERROR_FAIL;
+ }
}
libxl_device_pci_add_xenstore(ctx, domid, pcidev);
@@ -2605,7 +2668,7 @@ int libxl_device_pci_remove(struct libxl
hvm = is_hvm(ctx, domid);
if (hvm) {
if (libxl_wait_for_device_model(ctx, domid, "running", NULL, NULL) <
0) {
- return -1;
+ return ERROR_FAIL;
}
path = libxl_sprintf(ctx, "/local/domain/0/device-model/%d/state",
domid);
state = libxl_xs_read(ctx, XBT_NULL, path);
@@ -2616,7 +2679,7 @@ int libxl_device_pci_remove(struct libxl
xs_write(ctx->xsh, XBT_NULL, path, "pci-rem", strlen("pci-rem"));
if (libxl_wait_for_device_model(ctx, domid, "pci-removed", NULL, NULL)
< 0) {
XL_LOG(ctx, XL_LOG_ERROR, "Device Model didn't respond in time");
- return -1;
+ return ERROR_FAIL;
}
path = libxl_sprintf(ctx, "/local/domain/0/device-model/%d/state",
domid);
xs_write(ctx->xsh, XBT_NULL, path, state, strlen(state));
@@ -2740,7 +2803,7 @@ int libxl_device_pci_shutdown(struct lib
pcidevs = libxl_device_pci_list(ctx, domid, &num);
for (i = 0; i < num; i++) {
if (libxl_device_pci_remove(ctx, domid, pcidevs + i) < 0)
- return -1;
+ return ERROR_FAIL;
}
free(pcidevs);
return 0;
@@ -2851,7 +2914,8 @@ int libxl_get_physinfo(struct libxl_ctx
rc = xc_physinfo(ctx->xch, &xcphysinfo);
if (rc != 0) {
- return rc;
+ XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "getting physinfo");
+ return ERROR_FAIL;
}
physinfo->threads_per_core = xcphysinfo.threads_per_core;
physinfo->cores_per_socket = xcphysinfo.cores_per_socket;
@@ -2922,9 +2986,11 @@ struct libxl_vcpuinfo *libxl_list_vcpu(s
xc_physinfo_t physinfo = { 0 };
if (xc_domain_getinfolist(ctx->xch, domid, 1, &domaininfo) != 1) {
+ XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "getting infolist");
return NULL;
}
if (xc_physinfo(ctx->xch, &physinfo) == -1) {
+ XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "getting physinfo");
return NULL;
}
*cpusize = physinfo.max_cpu_id + 1;
@@ -2940,9 +3006,11 @@ struct libxl_vcpuinfo *libxl_list_vcpu(s
return NULL;
}
if (xc_vcpu_getinfo(ctx->xch, domid, *nb_vcpu, &vcpuinfo) == -1) {
+ XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "getting vcpu info");
return NULL;
}
if (xc_vcpu_getaffinity(ctx->xch, domid, *nb_vcpu, ptr->cpumap,
*cpusize) == -1) {
+ XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "getting vcpu affinity");
return NULL;
}
ptr->vcpuid = *nb_vcpu;
@@ -2958,7 +3026,11 @@ int libxl_set_vcpuaffinity(struct libxl_
int libxl_set_vcpuaffinity(struct libxl_ctx *ctx, uint32_t domid, uint32_t
vcpuid,
uint64_t *cpumap, int cpusize)
{
- return (xc_vcpu_setaffinity(ctx->xch, domid, vcpuid, cpumap, cpusize));
+ if (xc_vcpu_setaffinity(ctx->xch, domid, vcpuid, cpumap, cpusize)) {
+ XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "setting vcpu affinity");
+ return ERROR_FAIL;
+ }
+ return 0;
}
int libxl_set_vcpucount(struct libxl_ctx *ctx, uint32_t domid, uint32_t count)
@@ -2968,6 +3040,7 @@ int libxl_set_vcpucount(struct libxl_ctx
int i;
if (xc_domain_getinfolist(ctx->xch, domid, 1, &domaininfo) != 1) {
+ XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "getting domain info list");
return ERROR_FAIL;
}
if (!count || ((domaininfo.max_vcpu_id + 1) < count)) {
@@ -2986,14 +3059,15 @@ int libxl_set_vcpucount(struct libxl_ctx
/*
* returns one of the XEN_SCHEDULER_* constants from public/domctl.h
- * or -1 if an error occured.
*/
int libxl_get_sched_id(struct libxl_ctx *ctx)
{
int sched, ret;
- if ((ret = xc_sched_id(ctx->xch, &sched)) != 0)
- return ret;
+ if ((ret = xc_sched_id(ctx->xch, &sched)) != 0) {
+ XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "getting domain info list");
+ return ERROR_FAIL;
+ }
return sched;
}
@@ -3003,8 +3077,10 @@ int libxl_sched_credit_domain_get(struct
int rc;
rc = xc_sched_credit_domain_get(ctx->xch, domid, &sdom);
- if (rc != 0)
- return rc;
+ if (rc != 0) {
+ XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "setting domain sched credit");
+ return ERROR_FAIL;
+ }
scinfo->weight = sdom.weight;
scinfo->cap = sdom.cap;
@@ -3019,29 +3095,35 @@ int libxl_sched_credit_domain_set(struct
int rc;
rc = xc_domain_getinfolist(ctx->xch, domid, 1, &domaininfo);
+ if (rc < 0) {
+ XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "getting domain info list");
+ return ERROR_FAIL;
+ }
if (rc != 1 || domaininfo.domain != domid)
- return rc;
+ return ERROR_INVAL;
if (scinfo->weight < 1 || scinfo->weight > 65535) {
XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc,
"Cpu weight out of range, valid values are within range from 1 to
65535");
- return -1;
+ return ERROR_INVAL;
}
if (scinfo->cap < 0 || scinfo->cap > (domaininfo.max_vcpu_id + 1) * 100) {
XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc,
"Cpu cap out of range, valid range is from 0 to %d for specified
number of vcpus",
((domaininfo.max_vcpu_id + 1) * 100));
- return -1;
+ return ERROR_INVAL;
}
sdom.weight = scinfo->weight;
sdom.cap = scinfo->cap;
rc = xc_sched_credit_domain_set(ctx->xch, domid, &sdom);
- if (rc != 0)
- return rc;
+ if ( rc < 0 ) {
+ XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "setting domain sched credit");
+ return ERROR_FAIL;
+ }
return 0;
}
@@ -3070,15 +3152,17 @@ int libxl_send_trigger(struct libxl_ctx
if (trigger_type == -1) {
XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, -1,
"Invalid trigger, valid triggers are
<nmi|reset|init|power|sleep>");
- return -1;
+ return ERROR_INVAL;
}
rc = xc_domain_send_trigger(ctx->xch, domid, trigger_type, vcpuid);
- if (rc != 0)
+ if (rc != 0) {
XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc,
"Send trigger '%s' failed", trigger_name);
-
- return rc;
+ return ERROR_FAIL;
+ }
+
+ return 0;
}
int libxl_send_sysrq(struct libxl_ctx *ctx, uint32_t domid, char sysrq)
@@ -3092,7 +3176,13 @@ int libxl_send_sysrq(struct libxl_ctx *c
int libxl_send_debug_keys(struct libxl_ctx *ctx, char *keys)
{
- return xc_send_debug_keys(ctx->xch, keys);
+ int ret;
+ ret = xc_send_debug_keys(ctx->xch, keys);
+ if ( ret < 0 ) {
+ XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "sending debug keys");
+ return ERROR_FAIL;
+ }
+ return 0;
}
struct libxl_xen_console_reader *
@@ -3141,6 +3231,10 @@ int libxl_xen_console_read_line(struct l
memset(cr->buffer, 0, cr->size);
ret = xc_readconsolering(ctx->xch, &cr->buffer, &cr->count,
cr->clear, cr->incremental, &cr->index);
+ if (ret < 0) {
+ XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "reading console ring buffer");
+ return ERROR_FAIL;
+ }
if (!ret) {
if (cr->count) {
*line_r = cr->buffer;
@@ -3204,7 +3298,7 @@ int libxl_tmem_freeze(struct libxl_ctx *
if (rc < 0) {
XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc,
"Can not freeze tmem pools");
- return -1;
+ return ERROR_FAIL;
}
return rc;
@@ -3219,7 +3313,7 @@ int libxl_tmem_destroy(struct libxl_ctx
if (rc < 0) {
XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc,
"Can not destroy tmem pools");
- return -1;
+ return ERROR_FAIL;
}
return rc;
@@ -3234,7 +3328,7 @@ int libxl_tmem_thaw(struct libxl_ctx *ct
if (rc < 0) {
XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc,
"Can not thaw tmem pools");
- return -1;
+ return ERROR_FAIL;
}
return rc;
@@ -3260,13 +3354,13 @@ int libxl_tmem_set(struct libxl_ctx *ctx
if (subop == -1) {
XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, -1,
"Invalid set, valid sets are <weight|cap|compress>");
- return -1;
+ return ERROR_INVAL;
}
rc = xc_tmem_control(ctx->xch, -1, subop, domid, set, 0, 0, NULL);
if (rc < 0) {
XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc,
"Can not set tmem %s", name);
- return -1;
+ return ERROR_FAIL;
}
return rc;
@@ -3281,7 +3375,7 @@ int libxl_tmem_shared_auth(struct libxl_
if (rc < 0) {
XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc,
"Can not set tmem shared auth");
- return -1;
+ return ERROR_FAIL;
}
return rc;
@@ -3295,7 +3389,7 @@ int libxl_tmem_freeable(struct libxl_ctx
if (rc < 0) {
XL_LOG_ERRNOVAL(ctx, XL_LOG_ERROR, rc,
"Can not get tmem freeable memory");
- return -1;
+ return ERROR_FAIL;
}
return rc;
diff -r 098dacea3ae0 -r e23302fcb83c tools/libxl/libxl_dom.c
--- a/tools/libxl/libxl_dom.c Fri Jul 23 17:06:16 2010 +0100
+++ b/tools/libxl/libxl_dom.c Fri Jul 23 17:26:28 2010 +0100
@@ -250,10 +250,16 @@ int restore_common(struct libxl_ctx *ctx
int fd)
{
/* read signature */
- return xc_domain_restore(ctx->xch, fd, domid,
+ int rc;
+ rc = xc_domain_restore(ctx->xch, fd, domid,
state->store_port, &state->store_mfn,
state->console_port, &state->console_mfn,
info->hvm, info->u.hvm.pae, 0);
+ if ( rc < 0 ) {
+ XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "restoring domain");
+ return ERROR_FAIL;
+ }
+ return 0;
}
struct suspendinfo {
@@ -359,7 +365,7 @@ int core_suspend(struct libxl_ctx *ctx,
si.xce = xc_evtchn_open();
if (si.xce < 0)
- return -1;
+ return ERROR_FAIL;
if (si.xce > 0) {
port = xs_suspend_evtchn_port(si.domid);
@@ -438,7 +444,7 @@ static const char *userdata_path(struct
if (rc) {
XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "unable to find domain info"
" for domain %"PRIu32, domid);
- return 0;
+ return NULL;
}
uuid_string = string_of_uuid(ctx, info.uuid);
@@ -493,13 +499,13 @@ int libxl_userdata_store(struct libxl_ct
size_t rs;
filename = userdata_path(ctx, domid, userdata_userid, "d");
- if (!filename) return ENOMEM;
+ if (!filename) return ERROR_NOMEM;
if (!datalen)
return userdata_delete(ctx, filename);
newfilename = userdata_path(ctx, domid, userdata_userid, "n");
- if (!newfilename) return ENOMEM;
+ if (!newfilename) return ERROR_NOMEM;
fd= open(newfilename, O_RDWR|O_CREAT|O_TRUNC, 0600);
if (fd<0) goto xe;
@@ -523,9 +529,10 @@ int libxl_userdata_store(struct libxl_ct
if (f) fclose(f);
if (fd>=0) close(fd);
+ errno = e;
XL_LOG_ERRNO(ctx, XL_LOG_ERROR, "cannot write %s for %s",
newfilename, filename);
- return e;
+ return ERROR_FAIL;
}
int libxl_userdata_retrieve(struct libxl_ctx *ctx, uint32_t domid,
@@ -537,14 +544,14 @@ int libxl_userdata_retrieve(struct libxl
void *data = 0;
filename = userdata_path(ctx, domid, userdata_userid, "d");
- if (!filename) return ENOMEM;
+ if (!filename) return ERROR_NOMEM;
e = libxl_read_file_contents(ctx, filename, data_r ? &data : 0, &datalen);
if (!e && !datalen) {
XL_LOG(ctx, XL_LOG_ERROR, "userdata file %s is empty", filename);
if (data_r) assert(!*data_r);
- return EPROTO;
+ return ERROR_FAIL;
}
if (data_r) *data_r = data;
diff -r 098dacea3ae0 -r e23302fcb83c tools/libxl/libxl_internal.h
--- a/tools/libxl/libxl_internal.h Fri Jul 23 17:06:16 2010 +0100
+++ b/tools/libxl/libxl_internal.h Fri Jul 23 17:26:28 2010 +0100
@@ -222,5 +222,8 @@ char *libxl_abs_path(struct libxl_ctx *c
#define XL_LOG_WARNING XTL_WARN
#define XL_LOG_ERROR XTL_ERROR
+/* Error handling */
+int libxl_xc_error(int xc_err);
+
#endif
_______________________________________________
Xen-changelog mailing list
Xen-changelog@xxxxxxxxxxxxxxxxxxx
http://lists.xensource.com/xen-changelog
|
 |
Lists.xenproject.org is hosted with RackSpace, monitoring our |