--- mqtt/src/dl.c 2012/04/11 15:08:27 1.2.2.3 +++ mqtt/src/dl.c 2012/05/08 14:27:46 1.2.2.6 @@ -53,7 +53,7 @@ mqttLoadRTLM(cfg_root_t *cfg, int modtype) 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,13 +61,13 @@ mqttLoadRTLM(cfg_root_t *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; } @@ -94,6 +94,7 @@ mqttLoadRTLM(cfg_root_t *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");