From 03247eeba863f0a7036c83aa63e62cbc1aacc583 Mon Sep 17 00:00:00 2001 From: Steffen Vogel Date: Thu, 26 Apr 2018 09:31:39 +0200 Subject: [PATCH] mqtt: fix memory leak --- lib/nodes/mqtt.c | 1 + 1 file changed, 1 insertion(+) diff --git a/lib/nodes/mqtt.c b/lib/nodes/mqtt.c index be8e27b87..c21eccc04 100644 --- a/lib/nodes/mqtt.c +++ b/lib/nodes/mqtt.c @@ -476,6 +476,7 @@ int mqtt_read(struct node *n, struct sample *smps[], unsigned cnt) pulled = queue_signalled_pull_many(&m->queue, (void **) smpt, cnt); sample_copy_many(smps, smpt, pulled); + sample_put_many(smpt, pulled); return pulled; }