--- mqtt/src/dl.c 2011/11/23 01:07:18 1.1.2.2 +++ mqtt/src/dl.c 2012/07/03 12:22:56 1.3.2.1 @@ -1,8 +1,53 @@ +/************************************************************************* +* (C) 2011 AITNET ltd - Sofia/Bulgaria - +* by Michael Pounov +* +* $Author: misho $ +* $Id: dl.c,v 1.3.2.1 2012/07/03 12:22:56 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 + +Copyright 2004, 2005, 2006, 2007, 2008, 2009, 2010, 2011, 2012 + by Michael Pounov . 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 +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; +struct tagCallbacks call; /* @@ -23,63 +68,117 @@ mqttLog(const char *fmt, ...) } void * -mqttLoadRTLM(sl_config *cfg, int modtype) +mqttLoadRTLM(cfg_root_t *cfg, int modtype) { - char *str; + const char *str, *attr; void *rtlm = NULL; + void *(*mqttOpenRTLM)(cfg_root_t *); + void (*mqttCloseRTLM)(void *); if (!cfg) return NULL; - str = CFG(cfg_GetAttribute(cfg, CFG("mqttd"), CFG(modtype ? "pub_file" : "acc_file"))); + switch (modtype) { + case 0: + attr = "acc_file"; + break; + case 1: + attr = "pub_file"; + break; + default: + attr = "log_file"; + break; + } + + 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 not found %s\n", dlerror()); + mqttLog("Error:: RTL module %s not found %s\n", str, dlerror()); return NULL; } - mqttOpenDB = dlsym(rtlm, "mqtt_db_open"); - if (!mqttOpenDB) { - mqttLog("Error:: Can't found mqtt_db_open call\n"); + mqttOpenRTLM = dlsym(rtlm, "mqtt_rtlm_open"); + if (!mqttOpenRTLM) { + mqttLog("Error:: Can't found mqtt_rtlm_open call\n"); dlclose(rtlm); return NULL; } - mqttCloseDB = dlsym(rtlm, "mqtt_db_close"); - if (!mqttCloseDB) { - mqttLog("Error:: Can't found mqtt_db_close call\n"); + mqttCloseRTLM = dlsym(rtlm, "mqtt_rtlm_close"); + if (!mqttCloseRTLM) { + mqttLog("Error:: Can't found mqtt_rtlm_close call\n"); dlclose(rtlm); return NULL; } - if (modtype) { - pub_rtlm = rtlm; - } else { - acc_rtlm = rtlm; + switch (modtype) { + case 0: + call.OpenACC = mqttOpenRTLM; + call.CloseACC = mqttCloseRTLM; + call.LoginACC = dlsym(rtlm, "mqtt_rtlm_login"); + if (!call.LoginACC) { + mqttLog("Error:: incorrect module ...\n"); + dlclose(rtlm); + return NULL; + } + break; + case 1: + call.OpenPUB = mqttOpenRTLM; + call.ClosePUB = mqttCloseRTLM; + call.InitSessPUB = dlsym(rtlm, "mqtt_rtlm_init_session"); + call.FiniSessPUB = dlsym(rtlm, "mqtt_rtlm_fini_session"); + call.ChkSessPUB = dlsym(rtlm, "mqtt_rtlm_chk_session"); + 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"); + if (!call.InitSessPUB || !call.FiniSessPUB || !call.ChkSessPUB || + !call.WritePUB_topic || !call.ReadPUB_topic || + !call.DeletePUB_topic || !call.WritePUB_subscribe || + !call.ReadPUB_subscribe || !call.DeletePUB_subscribe) { + mqttLog("Error:: incorrect module ...\n"); + dlclose(rtlm); + return NULL; + } + break; + default: + call.OpenLOG = mqttOpenRTLM; + call.CloseLOG = mqttCloseRTLM; + call.LOG = dlsym(rtlm, "mqtt_rtlm_logger"); + if (!call.LOG) { + mqttLog("Error:: incorrect module ...\n"); + dlclose(rtlm); + return NULL; + } + break; } return rtlm; } void -mqttUnloadRTLM(int modtype) +mqttUnloadRTLM(void *rtlm) { - dlclose((modtype ? pub_rtlm : acc_rtlm)); + if (rtlm) + dlclose(rtlm); } inline int -mqttMkDir(sl_config *cfg) +mqttMkDir(cfg_root_t *cfg) { - char *str; + const char *str; if (!cfg) return -1; - str = CFG(cfg_GetAttribute(cfg, CFG("mqttd"), CFG("statedir"))); + str = (const char*) cfg_getAttribute(cfg, "mqttd", "statedir"); if (!str) return -1;