From f17bb1aa296036c33ca80758032f23e3abcd6476 Mon Sep 17 00:00:00 2001
From: Sakthi Kannan <saktr@amazon.com>
Date: Fri, 22 Jan 2021 18:55:32 +0000
Subject: [PATCH] mqtt: destroy PUBLISH pointers each time

---
 lib/roles/mqtt/mqtt.c | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/lib/roles/mqtt/mqtt.c b/lib/roles/mqtt/mqtt.c
index 20ebf9844..bbf70dbef 100644
--- a/lib/roles/mqtt/mqtt.c
+++ b/lib/roles/mqtt/mqtt.c
@@ -1276,8 +1276,12 @@ bail1:
 							    w, (enum lws_callback_reasons)n,
 							    w->user_space,
 							    (void *)pub,
-							    chunk))
-							return 1;
+							    chunk)) {
+								par->payload_consumed = 0;
+								lws_free_set_NULL(pub->topic);
+								lws_free_set_NULL(wsi->mqtt->rx_cpkt_param);
+								return 1;
+							}
 				} lws_end_foreach_ll(w, mux.sibling_list);