From 4a581a5e845ee4f50449c5d12808f48005209b06 Mon Sep 17 00:00:00 2001 From: Steffen Vogel Date: Sat, 26 May 2018 02:33:41 +0200 Subject: [PATCH] pipe: fix memleak if failed to sent samples --- src/pipe.c | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/pipe.c b/src/pipe.c index 4c887d3a0..ee27df078 100644 --- a/src/pipe.c +++ b/src/pipe.c @@ -160,10 +160,10 @@ static void * send_loop(void *ctx) } sent = node_write(node, smps, scanned); - if (sent < 0) { + if (sent < 0) warn("Failed to sent samples to node %s: reason=%d", node_name(node), sent); - continue; - } + else if (sent < scanned) + warn("Failed to sent %d out of %d samples to node %s", scanned-sent, scanned, node_name(node)); sample_put_many(smps, ready);