--- mqtt/src/dl.c 2011/11/24 01:13:27 1.1.2.6 +++ mqtt/src/dl.c 2012/02/01 15:44:40 1.2.2.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,17 +78,44 @@ 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_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.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: 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; }