From eca964b554e371f699758ebfa0837f2e7a8cba87 Mon Sep 17 00:00:00 2001 From: Zdenek Kabelac Date: Wed, 18 Jan 2017 09:56:15 +0100 Subject: [PATCH] dmeventd_thin: handling of internal command --- daemons/dmeventd/plugins/lvm2/dmeventd_lvm.c | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) diff --git a/daemons/dmeventd/plugins/lvm2/dmeventd_lvm.c b/daemons/dmeventd/plugins/lvm2/dmeventd_lvm.c index 0cca98f8e..930f9fc8f 100644 --- a/daemons/dmeventd/plugins/lvm2/dmeventd_lvm.c +++ b/daemons/dmeventd/plugins/lvm2/dmeventd_lvm.c @@ -121,6 +121,7 @@ int dmeventd_lvm2_run(const char *cmdline) int dmeventd_lvm2_command(struct dm_pool *mem, char *buffer, size_t size, const char *cmd, const char *device) { + static char _internal_prefix[] = "_dmeventd_"; char *vg = NULL, *lv = NULL, *layer; int r; @@ -135,6 +136,21 @@ int dmeventd_lvm2_command(struct dm_pool *mem, char *buffer, size_t size, (layer = strstr(lv, "_mlog"))) *layer = '\0'; + if (!strncmp(cmd, _internal_prefix, sizeof(_internal_prefix) - 1)) { + dmeventd_lvm2_lock(); + /* output of internal command passed via env var */ + if (!dmeventd_lvm2_run(cmd)) + cmd = NULL; + else if ((cmd = getenv(cmd))) + cmd = dm_pool_strdup(mem, cmd); /* copy with lock */ + dmeventd_lvm2_unlock(); + + if (!cmd) { + log_error("Unable to find configured command."); + return 0; + } + } + r = dm_snprintf(buffer, size, "%s %s/%s", cmd, vg, lv); dm_pool_free(mem, vg); -- 2.43.5