X-Git-Url: https://git.octo.it/?p=collectd.git;a=blobdiff_plain;f=src%2Futils_cmd_flush.c;h=089ab7065e360f3acdbcbdec3e59ce3107832931;hp=30da63005b7cf5652562a2c04d97812be4c8afa2;hb=ca316d91e178412604ea8462dc60a8bc32cbfc87;hpb=681a607a4b1a95df1d53d3e6922ec70bd52f87cf

diff --git a/src/utils_cmd_flush.c b/src/utils_cmd_flush.c
index 30da6300..089ab706 100644
--- a/src/utils_cmd_flush.c
+++ b/src/utils_cmd_flush.c
@@ -32,12 +32,15 @@
 #include "utils_parse_option.h"
 
 #define print_to_socket(fh, ...) \
-	if (fprintf (fh, __VA_ARGS__) < 0) { \
-		char errbuf[1024]; \
-		WARNING ("handle_flush: failed to write to socket #%i: %s", \
-				fileno (fh), sstrerror (errno, errbuf, sizeof (errbuf))); \
-		return -1; \
-	}
+	do { \
+		if (fprintf (fh, __VA_ARGS__) < 0) { \
+			char errbuf[1024]; \
+			WARNING ("handle_flush: failed to write to socket #%i: %s", \
+					fileno (fh), sstrerror (errno, errbuf, sizeof (errbuf))); \
+			return -1; \
+		} \
+		fflush(fh); \
+	} while (0)
 
 static int add_to_array (char ***array, int *array_num, char *value)
 {