X-Git-Url: https://git.tokkee.org/?a=blobdiff_plain;f=src%2Fcore%2Fplugin.c;h=96df9fe6b77fdc89377da0efee47cd159ad6cccb;hb=e04534362b8993b5400e0859aae9a38cfcc08aa6;hp=f581eb1629fbe3f043c02e13f6a4f3799de9b6d4;hpb=e39a0c24a894f9e04cbf7698429dc23293c7ced9;p=sysdb.git

diff --git a/src/core/plugin.c b/src/core/plugin.c
index f581eb1..96df9fe 100644
--- a/src/core/plugin.c
+++ b/src/core/plugin.c
@@ -1344,10 +1344,12 @@ sdb_plugin_store_host(const char *name, sdb_time_t last_update)
 	iter = sdb_llist_get_iter(writer_list);
 	while (sdb_llist_iter_has_next(iter)) {
 		sdb_plugin_writer_t *writer;
+		int s;
 		writer = SDB_PLUGIN_WRITER(sdb_llist_iter_get_next(iter));
 		assert(writer);
-		if (writer->impl.store_host(name, last_update, writer->w_user_data))
-			status = -1;
+		s = writer->impl.store_host(name, last_update, writer->w_user_data);
+		if (((s > 0) && (status >= 0)) || (s < 0))
+			status = s;
 	}
 	sdb_llist_iter_destroy(iter);
 	return status;
@@ -1366,11 +1368,13 @@ sdb_plugin_store_service(const char *hostname, const char *name,
 	iter = sdb_llist_get_iter(writer_list);
 	while (sdb_llist_iter_has_next(iter)) {
 		sdb_plugin_writer_t *writer;
+		int s;
 		writer = SDB_PLUGIN_WRITER(sdb_llist_iter_get_next(iter));
 		assert(writer);
-		if (writer->impl.store_service(hostname, name, last_update,
-					writer->w_user_data))
-			status = -1;
+		s = writer->impl.store_service(hostname, name, last_update,
+				writer->w_user_data);
+		if (((s > 0) && (status >= 0)) || (s < 0))
+			status = s;
 	}
 	sdb_llist_iter_destroy(iter);
 	return status;
@@ -1392,11 +1396,13 @@ sdb_plugin_store_metric(const char *hostname, const char *name,
 	iter = sdb_llist_get_iter(writer_list);
 	while (sdb_llist_iter_has_next(iter)) {
 		sdb_plugin_writer_t *writer;
+		int s;
 		writer = SDB_PLUGIN_WRITER(sdb_llist_iter_get_next(iter));
 		assert(writer);
-		if (writer->impl.store_metric(hostname, name, store, last_update,
-					writer->w_user_data))
-			status = -1;
+		s = writer->impl.store_metric(hostname, name, store, last_update,
+				writer->w_user_data);
+		if (((s > 0) && (status >= 0)) || (s < 0))
+			status = s;
 	}
 	sdb_llist_iter_destroy(iter);
 	return status;
@@ -1415,11 +1421,13 @@ sdb_plugin_store_attribute(const char *hostname, const char *key,
 	iter = sdb_llist_get_iter(writer_list);
 	while (sdb_llist_iter_has_next(iter)) {
 		sdb_plugin_writer_t *writer;
+		int s;
 		writer = SDB_PLUGIN_WRITER(sdb_llist_iter_get_next(iter));
 		assert(writer);
-		if (writer->impl.store_attribute(hostname, key, value, last_update,
-					writer->w_user_data))
-			status = -1;
+		s = writer->impl.store_attribute(hostname, key, value, last_update,
+				writer->w_user_data);
+		if (((s > 0) && (status >= 0)) || (s < 0))
+			status = s;
 	}
 	sdb_llist_iter_destroy(iter);
 	return status;
@@ -1438,11 +1446,13 @@ sdb_plugin_store_service_attribute(const char *hostname, const char *service,
 	iter = sdb_llist_get_iter(writer_list);
 	while (sdb_llist_iter_has_next(iter)) {
 		sdb_plugin_writer_t *writer;
+		int s;
 		writer = SDB_PLUGIN_WRITER(sdb_llist_iter_get_next(iter));
 		assert(writer);
-		if (writer->impl.store_service_attr(hostname, service,
-					key, value, last_update, writer->w_user_data))
-			status = -1;
+		s = writer->impl.store_service_attr(hostname, service,
+				key, value, last_update, writer->w_user_data);
+		if (((s > 0) && (status >= 0)) || (s < 0))
+			status = s;
 	}
 	sdb_llist_iter_destroy(iter);
 	return status;
@@ -1461,11 +1471,13 @@ sdb_plugin_store_metric_attribute(const char *hostname, const char *metric,
 	iter = sdb_llist_get_iter(writer_list);
 	while (sdb_llist_iter_has_next(iter)) {
 		sdb_plugin_writer_t *writer;
+		int s;
 		writer = SDB_PLUGIN_WRITER(sdb_llist_iter_get_next(iter));
 		assert(writer);
-		if (writer->impl.store_metric_attr(hostname, metric,
-					key, value, last_update, writer->w_user_data))
-			status = -1;
+		s = writer->impl.store_metric_attr(hostname, metric,
+				key, value, last_update, writer->w_user_data);
+		if (((s > 0) && (status >= 0)) || (s < 0))
+			status = s;
 	}
 	sdb_llist_iter_destroy(iter);
 	return status;