--- mqtt/src/dl.c	2012/02/01 15:44:40	1.2.2.2
+++ mqtt/src/dl.c	2012/07/03 12:46:00	1.4
@@ -1,9 +1,52 @@
+/*************************************************************************
+* (C) 2011 AITNET ltd - Sofia/Bulgaria - <misho@aitbg.com>
+*  by Michael Pounov <misho@openbsd-bg.org>
+*
+* $Author: misho $
+* $Id: dl.c,v 1.4 2012/07/03 12:46:00 misho Exp $
+*
+**************************************************************************
+The ELWIX and AITNET software is distributed under the following
+terms:
+
+All of the documentation and software included in the ELWIX and AITNET
+Releases is copyrighted by ELWIX - Sofia/Bulgaria <info@elwix.org>
+
+Copyright 2004, 2005, 2006, 2007, 2008, 2009, 2010, 2011, 2012
+	by Michael Pounov <misho@elwix.org>.  All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions
+are met:
+1. Redistributions of source code must retain the above copyright
+   notice, this list of conditions and the following disclaimer.
+2. Redistributions in binary form must reproduce the above copyright
+   notice, this list of conditions and the following disclaimer in the
+   documentation and/or other materials provided with the distribution.
+3. All advertising materials mentioning features or use of this software
+   must display the following acknowledgement:
+This product includes software developed by Michael Pounov <misho@elwix.org>
+ELWIX - Embedded LightWeight unIX and its contributors.
+4. Neither the name of AITNET nor the names of its contributors
+   may be used to endorse or promote products derived from this software
+   without specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY AITNET AND CONTRIBUTORS ``AS IS'' AND
+ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
+ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
+FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
+OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
+HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
+LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
+OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
+SUCH DAMAGE.
+*/
 #include "global.h"
 #include "rtlm.h"
 
 
-static void *acc_rtlm, *pub_rtlm, *log_rtlm;
-
 struct tagCallbacks call;
 
 
@@ -25,11 +68,11 @@ mqttLog(const char *fmt, ...)
 }
 
 void *
-mqttLoadRTLM(sl_config *cfg, int modtype)
+mqttLoadRTLM(cfg_root_t *cfg, int modtype)
 {
 	const char *str, *attr;
 	void *rtlm = NULL;
-	void *(*mqttOpenRTLM)(sl_config *);
+	void *(*mqttOpenRTLM)(cfg_root_t *);
 	void (*mqttCloseRTLM)(void *);
 
 	if (!cfg)
@@ -47,13 +90,13 @@ mqttLoadRTLM(sl_config *cfg, int modtype)
 			break;
 	}
 
-	str = (const char*) CFG(cfg_GetAttribute(cfg, CFG("mqttd"), CFG(attr)));
+	str = cfg_getAttribute(cfg, "mqttd", attr);
 	if (!str) {
 		mqttLog("Error:: RTL module not found\n");
 		return NULL;
 	}
 
-	rtlm = dlopen(str, RTLD_LAZY);
+	rtlm = dlopen(str, RTLD_NOW);
 	if (!rtlm) {
 		mqttLog("Error:: RTL module %s not found %s\n", str, dlerror());
 		return NULL;
@@ -61,20 +104,19 @@ mqttLoadRTLM(sl_config *cfg, int modtype)
 
 	mqttOpenRTLM = dlsym(rtlm, "mqtt_rtlm_open");
 	if (!mqttOpenRTLM) {
-		mqttLog("Error:: Can't found mqtt_db_open call\n");
+		mqttLog("Error:: Can't found mqtt_rtlm_open call\n");
 		dlclose(rtlm);
 		return NULL;
 	}
 	mqttCloseRTLM = dlsym(rtlm, "mqtt_rtlm_close");
 	if (!mqttCloseRTLM) {
-		mqttLog("Error:: Can't found mqtt_db_close call\n");
+		mqttLog("Error:: Can't found mqtt_rtlm_close call\n");
 		dlclose(rtlm);
 		return NULL;
 	}
 
 	switch (modtype) {
 		case 0:
-			acc_rtlm = rtlm;
 			call.OpenACC = mqttOpenRTLM;
 			call.CloseACC = mqttCloseRTLM;
 			call.LoginACC = dlsym(rtlm, "mqtt_rtlm_login");
@@ -85,7 +127,6 @@ mqttLoadRTLM(sl_config *cfg, int modtype)
 			}
 			break;
 		case 1:
-			pub_rtlm = rtlm;
 			call.OpenPUB = mqttOpenRTLM;
 			call.ClosePUB = mqttCloseRTLM;
 			call.InitSessPUB = dlsym(rtlm, "mqtt_rtlm_init_session");
@@ -94,6 +135,7 @@ mqttLoadRTLM(sl_config *cfg, int modtype)
 			call.WritePUB_topic = dlsym(rtlm, "mqtt_rtlm_write_topic");
 			call.ReadPUB_topic = dlsym(rtlm, "mqtt_rtlm_read_topic");
 			call.DeletePUB_topic = dlsym(rtlm, "mqtt_rtlm_delete_topic");
+			call.WipePUB_topic = dlsym(rtlm, "mqtt_rtlm_wipe_topic");
 			call.WritePUB_subscribe = dlsym(rtlm, "mqtt_rtlm_write_subscribe");
 			call.ReadPUB_subscribe = dlsym(rtlm, "mqtt_rtlm_read_subscribe");
 			call.DeletePUB_subscribe = dlsym(rtlm, "mqtt_rtlm_delete_subscribe");
@@ -107,7 +149,6 @@ mqttLoadRTLM(sl_config *cfg, int modtype)
 			}
 			break;
 		default:
-			log_rtlm = rtlm;
 			call.OpenLOG = mqttOpenRTLM;
 			call.CloseLOG = mqttCloseRTLM;
 			call.LOG = dlsym(rtlm, "mqtt_rtlm_logger");
@@ -123,30 +164,21 @@ mqttLoadRTLM(sl_config *cfg, int modtype)
 }
 
 void
-mqttUnloadRTLM(int modtype)
+mqttUnloadRTLM(void *rtlm)
 {
-	switch (modtype) {
-		case 0:
-			dlclose(acc_rtlm);
-			break;
-		case 1:
-			dlclose(pub_rtlm);
-			break;
-		default:
-			dlclose(log_rtlm);
-			break;
-	}
+	if (rtlm)
+		dlclose(rtlm);
 }
 
 inline int
-mqttMkDir(sl_config *cfg)
+mqttMkDir(cfg_root_t *cfg)
 {
 	const char *str;
 
 	if (!cfg)
 		return -1;
 
-	str = (const char*) cfg_GetAttribute(cfg, CFG("mqttd"), CFG("statedir"));
+	str = (const char*) cfg_getAttribute(cfg, "mqttd", "statedir");
 	if (!str)
 		return -1;