[Libvirt-cim] [PATCH 6 of 6] Add resource indication provider

[Sharad Mishra]

# HG changeset patch
# User Sharad Mishra <snmishra at us.ibm.com>
# Date 1253031558 25200
# Node ID 335b5e307df79e4e4cfdfc15d13424c759da8b53
# Parent  cbcf788b362077e7ed289895dc1ce851e405b1ae
Add resource indication provider.

Signed-off-by: Sharad Mishra <snmishra at us.ibm.com>

diff -r cbcf788b3620 -r 335b5e307df7 src/Virt_ResourceAllocationSettingDataIndication.c
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/Virt_ResourceAllocationSettingDataIndication.c	Tue Sep 15 09:19:18 2009 -0700
@@ -0,0 +1,155 @@
+/*
+ * Copyright IBM Corp. 2007
+ *
+ * Authors:
+ *  Sharad Mishra <snmishra at us.ibm.com>
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 2.1 of the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, write to the Free Software
+ * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307  USA
+ */
+#include <stdio.h>
+#include <string.h>
+
+#include <cmpidt.h>
+#include <cmpift.h>
+#include <cmpimacs.h>
+
+#include <libvirt/libvirt.h>
+#include <libcmpiutil/libcmpiutil.h>
+#include <libcmpiutil/std_indication.h>
+#include <misc_util.h>
+#include <cs_util.h>
+
+static const CMPIBroker *_BROKER;
+
+DECLARE_FILTER(xen_created,
+               "Xen_ResourceAllocationSettingDataCreatedIndication");
+DECLARE_FILTER(xen_deleted,
+               "Xen_ResourceAllocationSettingDataDeletedIndication");
+DECLARE_FILTER(xen_modified,
+               "Xen_ResourceAllocationSettingDataModifiedIndication");
+DECLARE_FILTER(kvm_created,
+               "KVM_ResourceAllocationSettingDataCreatedIndication");
+DECLARE_FILTER(kvm_deleted,
+               "KVM_ResourceAllocationSettingDataDeletedIndication");
+DECLARE_FILTER(kvm_modified,
+               "KVM_ResourceAllocationSettingDataModifiedIndication");
+DECLARE_FILTER(lxc_created,
+               "LXC_ResourceAllocationSettingDataCreatedIndication");
+DECLARE_FILTER(lxc_deleted,
+               "LXC_ResourceAllocationSettingDataDeletedIndication");
+DECLARE_FILTER(lxc_modified,
+               "LXC_ResourceAllocationSettingDataModifiedIndication");
+
+static struct std_ind_filter *filters[] = {
+        &xen_created,
+        &xen_deleted,
+        &xen_modified,
+        &kvm_created,
+        &kvm_deleted,
+        &kvm_modified,
+        &lxc_created,
+        &lxc_deleted,
+        &lxc_modified,
+        NULL,
+};
+
+
+static CMPIStatus raise_indication(const CMPIBroker *broker,
+                                   const CMPIContext *ctx,
+                                   const CMPIInstance *ind)
+{
+        struct std_indication_ctx *_ctx = NULL;
+        CMPIStatus s = {CMPI_RC_OK, NULL};
+        struct ind_args *args = NULL;
+        CMPIObjectPath *ref = NULL;
+
+        _ctx = malloc(sizeof(struct std_indication_ctx));
+        if (_ctx == NULL) {
+                cu_statusf(broker, &s,
+                           CMPI_RC_ERR_FAILED,
+                           "Unable to allocate indication context");
+                goto out;
+        }
+
+        _ctx->brkr = broker;
+        _ctx->handler = NULL;
+        _ctx->filters = filters;
+        _ctx->enabled = 1;
+
+        args = malloc(sizeof(struct ind_args));
+        if (args == NULL) {
+                cu_statusf(broker, &s,
+                           CMPI_RC_ERR_FAILED,
+                           "Unable to allocate ind_args");
+                goto out;
+        }
+
+        ref = CMGetObjectPath(ind, &s);
+        if (ref == NULL) {
+                cu_statusf(broker, &s,
+                           CMPI_RC_ERR_FAILED,
+                           "Got a null object path");
+                goto out;
+        }
+
+        /* FIXME:  This is a Pegasus work around. Pegsus loses the namespace
+                   when an ObjectPath is pulled from an instance */
+
+
+        CMSetNameSpace(ref, "root/virt");
+        args->ns = strdup(NAMESPACE(ref));
+        args->classname = strdup(CLASSNAME(ref));
+        args->_ctx = _ctx;
+
+        s = stdi_deliver(broker, ctx, args, (CMPIInstance *)ind);
+        if (s.rc == CMPI_RC_OK) {
+                CU_DEBUG("Indication delivered");
+        } else {
+                CU_DEBUG("Not delivered: %s", CMGetCharPtr(s.msg));
+        }
+
+ out:
+        return s;
+}
+
+static struct std_indication_handler rasdi = {
+        .raise_fn = raise_indication,
+        .trigger_fn = NULL,
+        .activate_fn = NULL,
+        .deactivate_fn = NULL,
+        .enable_fn = NULL,
+        .disable_fn = NULL,
+};
+
+DEFAULT_IND_CLEANUP();
+DEFAULT_AF();
+DEFAULT_MP();
+
+STDI_IndicationMIStub(,
+                      Virt_ResourceAllocationSettingDataIndicationProvider,
+                      _BROKER,
+                      libvirt_cim_init(),
+                      &rasdi,
+                      filters);
+
+/*
+ * Local Variables:
+ * mode: C
+ * c-set-style: "K&R"
+ * tab-width: 8
+ * c-basic-offset: 8
+ * indent-tabs-mode: nil
+ * End:
+ */