From 26cdc6e58adccbef47c4af8cee71877ba651a027 Mon Sep 17 00:00:00 2001
From: Marvin Klimke <marvin.klimke@rwth-aachen.de>
Date: Wed, 19 Dec 2018 18:40:53 +0100
Subject: [PATCH] add proper queue destruction

---
 lib/nodes/rtp.c | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/lib/nodes/rtp.c b/lib/nodes/rtp.c
index 5e448f74a..5dd0cad46 100644
--- a/lib/nodes/rtp.c
+++ b/lib/nodes/rtp.c
@@ -160,10 +160,19 @@ int rtp_start(struct node *n)
 
 int rtp_stop(struct node *n)
 {
+	int ret;
 	struct rtp *r = (struct rtp *) n->_vd;
 
 	/*mem_deref(r->rs);*/
 
+	ret = queue_close(&r->recv_queue);
+	if (ret)
+		warn("Problem closing queue");
+
+	ret = queue_destroy(&r->recv_queue);
+	if (ret)
+		warn("Problem destroying queue");
+
 	return io_destroy(&r->io);
 }