From 2bb6e407a309f5aec8461507a28875a91c89a1dc Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Arnim=20L=C3=A4uger?= Date: Sat, 21 May 2016 14:25:16 +0200 Subject: [PATCH] Initialize cb for unsubscribe and unref it upon socket deletion. (#1305) Thank you. --- app/modules/mqtt.c | 3 +++ 1 file changed, 3 insertions(+) diff --git a/app/modules/mqtt.c b/app/modules/mqtt.c index d74404a6..d4437a49 100644 --- a/app/modules/mqtt.c +++ b/app/modules/mqtt.c @@ -674,6 +674,7 @@ static int mqtt_socket_client( lua_State* L ) mud->cb_message_ref = LUA_NOREF; mud->cb_suback_ref = LUA_NOREF; + mud->cb_unsuback_ref = LUA_NOREF; mud->cb_puback_ref = LUA_NOREF; mud->pesp_conn = NULL; #ifdef CLIENT_SSL_ENABLE @@ -842,6 +843,8 @@ static int mqtt_delete( lua_State* L ) mud->cb_message_ref = LUA_NOREF; luaL_unref(L, LUA_REGISTRYINDEX, mud->cb_suback_ref); mud->cb_suback_ref = LUA_NOREF; + luaL_unref(L, LUA_REGISTRYINDEX, mud->cb_unsuback_ref); + mud->cb_unsuback_ref = LUA_NOREF; luaL_unref(L, LUA_REGISTRYINDEX, mud->cb_puback_ref); mud->cb_puback_ref = LUA_NOREF; lua_gc(L, LUA_GCSTOP, 0);