--- mqtt/src/dl.c 2011/11/24 13:57:11 1.1.2.7 +++ mqtt/src/dl.c 2012/01/27 15:05:38 1.2 @@ -55,7 +55,7 @@ mqttLoadRTLM(sl_config *cfg, int modtype) rtlm = dlopen(str, RTLD_LAZY); if (!rtlm) { - mqttLog("Error:: RTL module not found %s\n", dlerror()); + mqttLog("Error:: RTL module %s not found %s\n", str, dlerror()); return NULL; } @@ -78,18 +78,39 @@ mqttLoadRTLM(sl_config *cfg, int modtype) 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: pub_rtlm = rtlm; 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 = dlsym(rtlm, "mqtt_rtlm_write_topic"); + call.ReadPUB = dlsym(rtlm, "mqtt_rtlm_read_topic"); + call.DeletePUB = dlsym(rtlm, "mqtt_rtlm_delete_topic"); + if (!call.InitSessPUB || !call.FiniSessPUB || !call.ChkSessPUB || + !call.WritePUB || !call.ReadPUB || !call.DeletePUB) { + mqttLog("Error:: incorrect module ...\n"); + dlclose(rtlm); + return NULL; + } break; default: log_rtlm = rtlm; 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; }