|
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index] [Xen-devel] [PATCH 11 of 29 RFC] libxl: execute hotplug scripts directly from libxl
# HG changeset patch
# User Roger Pau Monne <roger.pau@xxxxxxxxxxxxx>
# Date 1317386335 -7200
# Node ID 5e488e0c02b8c769e94c2f734c0c209739d9cb01
# Parent 80835b6fed80331703a525a3b6ac98153d9868f6
libxl: execute hotplug scripts directly from libxl.
Added the necessary handlers to execute hotplug scripts when necessary
from libxl. Split NetBSD and Linux hotplug calls into two separate
files, because parameters for hotplug scripts are different. This
patch adds the necessary functions to call hotplug scripts, but the
implementation of those functions is left empty and will be filled in
future patches.
Signed-off-by: Roger Pau Monne <roger.pau@xxxxxxxxxxxxx>
diff -r 80835b6fed80 -r 5e488e0c02b8 tools/libxl/libxl.c
--- a/tools/libxl/libxl.c Thu Feb 02 11:04:06 2012 +0100
+++ b/tools/libxl/libxl.c Fri Sep 30 14:38:55 2011 +0200
@@ -1049,6 +1049,11 @@ int libxl_device_disk_add(libxl_ctx *ctx
flexarray_append(back, "params");
flexarray_append(back, dev);
+ flexarray_append(back, "script");
+ flexarray_append(back, libxl__sprintf(gc, "%s/%s",
+ libxl_xen_script_dir_path(),
+ "block"));
+
assert(device.backend_kind == LIBXL__DEVICE_KIND_VBD);
break;
case LIBXL_DISK_BACKEND_TAP:
@@ -1061,6 +1066,10 @@ int libxl_device_disk_add(libxl_ctx *ctx
flexarray_append(back, libxl__sprintf(gc, "%s:%s",
libxl__device_disk_string_of_format(disk->format),
disk->pdev_path));
+ flexarray_append(back, "script");
+ flexarray_append(back, libxl__sprintf(gc, "%s/%s",
+ libxl_xen_script_dir_path(),
+ "blktap"));
/* now create a phy device to export the device to the guest */
goto do_backend_phy;
@@ -1129,6 +1138,16 @@ int libxl_device_disk_add(libxl_ctx *ctx
}
}
}
+
+ /* Call hotplug scripts to attach device */
+ if (libxl__device_hotplug(gc, &device, CONNECT) < 0) {
+ LIBXL__LOG(ctx, LIBXL__LOG_ERROR,
+ "unable to execute hotplug script for disk: %s",
+ disk->pdev_path);
+ rc = -1;
+ goto out_free;
+ }
+
rc = 0;
out_free:
@@ -1597,6 +1616,16 @@ int libxl_device_nic_add(libxl_ctx *ctx,
goto out_free;
}
}
+
+ /* Call hotplug scripts to attach device */
+ if (libxl__device_hotplug(gc, &device, CONNECT) < 0) {
+ LIBXL__LOG(ctx, LIBXL__LOG_ERROR,
+ "unable to execute hotplug script for nic: %s\n",
+ nic->ifname);
+ rc = -1;
+ goto out_free;
+ }
+
rc = 0;
out_free:
diff -r 80835b6fed80 -r 5e488e0c02b8 tools/libxl/libxl_device.c
--- a/tools/libxl/libxl_device.c Thu Feb 02 11:04:06 2012 +0100
+++ b/tools/libxl/libxl_device.c Fri Sep 30 14:38:55 2011 +0200
@@ -448,10 +448,15 @@ static int destroy_device(libxl__gc *gc,
goto out;
}
+ rc = libxl__device_hotplug(gc, &dev, DISCONNECT);
+ if (rc < 0) {
+ LIBXL__LOG(ctx, LIBXL__LOG_ERROR,
+ "failed to execute hotplug script for "
+ "device with backend path %s", l1[0]);
+ goto out;
+ }
+
libxl__xs_path_cleanup(gc, libxl__device_backend_path(gc, &dev));
- LIBXL__LOG(ctx, LIBXL__LOG_DEBUG,
- "Destroyed device backend at %s",
- l1[XS_WATCH_TOKEN]);
rc = 0;
out:
return rc;
@@ -480,6 +485,12 @@ retry_transaction:
}
if (atoi(state) != 4) {
xs_transaction_end(ctx->xsh, t, 0);
+ rc = libxl__device_hotplug(gc, dev, DISCONNECT);
+ if (rc < 0) {
+ LIBXL__LOG(ctx, LIBXL__LOG_ERROR,
+ "failed to execute hotplug script for "
+ "device with backend path %s", be_path);
+ }
libxl__device_destroy_tapdisk(gc, be_path);
libxl__xs_path_cleanup(gc, be_path);
goto out;
@@ -524,13 +535,16 @@ int libxl__device_destroy(libxl__gc *gc,
{
char *be_path = libxl__device_backend_path(gc, dev);
char *fe_path = libxl__device_frontend_path(gc, dev);
+ int rc;
+ libxl__xs_path_cleanup(gc, fe_path);
+ /* Wait for backend status to disconnect */
+ rc = libxl__device_remove(gc, dev);
libxl__xs_path_cleanup(gc, be_path);
- libxl__xs_path_cleanup(gc, fe_path);
libxl__device_destroy_tapdisk(gc, be_path);
- return 0;
+ return rc;
}
int libxl__devices_destroy(libxl__gc *gc, uint32_t domid)
diff -r 80835b6fed80 -r 5e488e0c02b8 tools/libxl/libxl_internal.h
--- a/tools/libxl/libxl_internal.h Thu Feb 02 11:04:06 2012 +0100
+++ b/tools/libxl/libxl_internal.h Fri Sep 30 14:38:55 2011 +0200
@@ -342,6 +342,25 @@ typedef int libxl__device_state_handler(
*/
_hidden int libxl__try_phy_backend(mode_t st_mode);
+/* hotplug functions */
+
+/* Action to pass to hotplug caller functions */
+typedef enum {
+ CONNECT = 1,
+ DISCONNECT = 2
+} libxl__hotplug_action;
+
+/*
+ * libxl__device_hotplug - generic function to execute hotplug scripts
+ * gc: allocation pool
+ * dev: reference to the device that executes the hotplug scripts
+ * action: action to execute
+ *
+ * Returns 0 on success, and < 0 on error.
+ */
+_hidden int libxl__device_hotplug(libxl__gc *gc, libxl__device *dev,
+ libxl__hotplug_action action);
+
/* from libxl_pci */
_hidden int libxl__device_pci_add(libxl__gc *gc, uint32_t domid,
libxl_device_pci *pcidev, int starting);
diff -r 80835b6fed80 -r 5e488e0c02b8 tools/libxl/libxl_linux.c
--- a/tools/libxl/libxl_linux.c Thu Feb 02 11:04:06 2012 +0100
+++ b/tools/libxl/libxl_linux.c Fri Sep 30 14:38:55 2011 +0200
@@ -25,3 +25,11 @@ int libxl__try_phy_backend(mode_t st_mod
return 1;
}
+
+/* Hotplug scripts caller functions */
+
+int libxl__device_hotplug(libxl__gc *gc, libxl__device *dev,
+ libxl__hotplug_action action)
+{
+ return 0;
+}
diff -r 80835b6fed80 -r 5e488e0c02b8 tools/libxl/libxl_netbsd.c
--- a/tools/libxl/libxl_netbsd.c Thu Feb 02 11:04:06 2012 +0100
+++ b/tools/libxl/libxl_netbsd.c Fri Sep 30 14:38:55 2011 +0200
@@ -24,3 +24,11 @@ int libxl__try_phy_backend(mode_t st_mod
return 0;
}
+
+/* Hotplug scripts call function */
+
+int libxl__device_hotplug(libxl__gc *gc, libxl__device *dev,
+ libxl__hotplug_action action)
+{
+ return 0;
+}
_______________________________________________
Xen-devel mailing list
Xen-devel@xxxxxxxxxxxxxxxxxxx
http://lists.xensource.com/xen-devel
|
 |
Lists.xenproject.org is hosted with RackSpace, monitoring our |