From: Sebastian Harl <sh@tokkee.org>
Date: Sat, 5 Jul 2014 08:40:44 +0000 (+0200)
Subject: collectd::unixsock backend: Store plugin identifier as service attributes.
X-Git-Tag: sysdb-0.3.0~79
X-Git-Url: https://git.tokkee.org/?p=sysdb.git;a=commitdiff_plain;h=9ee01933d67999e9a197131ad1be2ec666f24bf5

collectd::unixsock backend: Store plugin identifier as service attributes.
---

diff --git a/src/backend/collectd/unixsock.c b/src/backend/collectd/unixsock.c
index 1faa9c8..7145e9d 100644
--- a/src/backend/collectd/unixsock.c
+++ b/src/backend/collectd/unixsock.c
@@ -112,10 +112,14 @@ sdb_collectd_store_host(sdb_collectd_state_t *state,
 } /* sdb_collectd_store_host */
 
 static int
-sdb_collectd_add_svc(const char *hostname, const char *plugin,
-		const char *type, sdb_time_t last_update)
+sdb_collectd_add_svc(const char *hostname, char *plugin, char *type,
+		sdb_time_t last_update)
 {
-	char name[strlen(plugin) + strlen(type) + 2];
+	char  name[strlen(plugin) + strlen(type) + 2];
+	char *plugin_instance, *type_instance;
+
+	sdb_data_t data = { SDB_TYPE_STRING, { .string = NULL } };
+
 	int  status;
 
 	snprintf(name, sizeof(name), "%s/%s", plugin, type);
@@ -126,6 +130,31 @@ sdb_collectd_add_svc(const char *hostname, const char *plugin,
 				"store/update service '%s/%s'.", hostname, name);
 		return -1;
 	}
+
+	plugin_instance = strchr(plugin, '-');
+	if (plugin_instance) {
+		*plugin_instance = '\0';
+		++plugin_instance;
+
+		data.data.string = plugin_instance;
+		sdb_store_service_attr(hostname, name,
+				"plugin_instance", &data, last_update);
+	}
+
+	type_instance = strchr(type, '-');
+	if (type_instance) {
+		*type_instance = '\0';
+		++type_instance;
+
+		data.data.string = type_instance;
+		sdb_store_service_attr(hostname, name,
+				"type_instance", &data, last_update);
+	}
+
+	data.data.string = plugin;
+	sdb_store_service_attr(hostname, name, "plugin", &data, last_update);
+	data.data.string = type;
+	sdb_store_service_attr(hostname, name, "type", &data, last_update);
 	return 0;
 } /* sdb_collectd_add_svc */
 
@@ -134,11 +163,11 @@ sdb_collectd_get_data(sdb_unixsock_client_t __attribute__((unused)) *client,
 		size_t n, sdb_data_t *data, sdb_object_t *user_data)
 {
 	sdb_collectd_state_t *state;
+	sdb_data_t last_update;
 
 	char *hostname;
-	const char *plugin;
-	const char *type;
-	sdb_data_t last_update;
+	char *plugin;
+	char *type;
 
 	assert(user_data);