X-Git-Url: https://git.verplant.org/?a=blobdiff_plain;f=src%2Fwrite_riemann.c;h=ac4e9f58bf36bcd4070c66eab194d5a70d1df1f0;hb=82e59ce7eb02c78d911dac7663383ce372b79c90;hp=f836b9dfe900d74f9edac4f4d756d4a791af9c6c;hpb=6b247abce8371e3074b5a3595d728871a4f1394a;p=collectd.git

diff --git a/src/write_riemann.c b/src/write_riemann.c
index f836b9df..ac4e9f58 100644
--- a/src/write_riemann.c
+++ b/src/write_riemann.c
@@ -30,7 +30,6 @@
 
 #include <riemann/riemann-client.h>
 #include <errno.h>
-#include <pthread.h>
 
 #include "collectd.h"
 #include "plugin.h"
@@ -461,30 +460,16 @@ static int wrr_batch_flush_nolock(cdtime_t timeout,
 	cdtime_t    now;
 	int         status = 0;
 
+    now = cdtime();
 	if (timeout > 0) {
-		now = cdtime();
-		if ((host->batch_init + timeout) > now)
+		if ((host->batch_init + timeout) > now) {
 			return status;
+        }
 	}
 	wrr_send_nolock(host, host->batch_msg);
 	riemann_message_free(host->batch_msg);
 
-	if (host->client_type != RIEMANN_CLIENT_UDP)
-	{
-		riemann_message_t *response;
-
-		response = riemann_client_recv_message(host->client);
-
-		if (!response)
-		{
-			wrr_disconnect(host);
-			return errno;
-		}
-
-		riemann_message_free(response);
-	}
-
-	host->batch_init = cdtime();
+	host->batch_init = now;
 	host->batch_msg = NULL;
 	return status;
 }
@@ -611,7 +596,7 @@ static int wrr_write(const data_set_t *ds, /* {{{ */
   }
 
   if (host->client_type != RIEMANN_CLIENT_UDP && host->batch_mode) {
-    wrr_batch_add_value_list(host, ds, vl, statuses);
+      wrr_batch_add_value_list(host, ds, vl, statuses);
   } else {
     msg = wrr_value_list_to_message(host, ds, vl, statuses);
     if (msg == NULL)