Diff for /mqtt/src/dl.c between versions 1.2.2.3 and 1.2.2.6

version 1.2.2.3, 2012/04/11 15:08:27 version 1.2.2.6, 2012/05/08 14:27:46
Line 53  mqttLoadRTLM(cfg_root_t *cfg, int modtype) Line 53  mqttLoadRTLM(cfg_root_t *cfg, int modtype)
                 return NULL;                  return NULL;
         }          }
   
        rtlm = dlopen(str, RTLD_LAZY);        rtlm = dlopen(str, RTLD_NOW);
         if (!rtlm) {          if (!rtlm) {
                 mqttLog("Error:: RTL module %s not found %s\n", str, dlerror());                  mqttLog("Error:: RTL module %s not found %s\n", str, dlerror());
                 return NULL;                  return NULL;
Line 61  mqttLoadRTLM(cfg_root_t *cfg, int modtype) Line 61  mqttLoadRTLM(cfg_root_t *cfg, int modtype)
   
         mqttOpenRTLM = dlsym(rtlm, "mqtt_rtlm_open");          mqttOpenRTLM = dlsym(rtlm, "mqtt_rtlm_open");
         if (!mqttOpenRTLM) {          if (!mqttOpenRTLM) {
                mqttLog("Error:: Can't found mqtt_db_open call\n");                mqttLog("Error:: Can't found mqtt_rtlm_open call\n");
                 dlclose(rtlm);                  dlclose(rtlm);
                 return NULL;                  return NULL;
         }          }
         mqttCloseRTLM = dlsym(rtlm, "mqtt_rtlm_close");          mqttCloseRTLM = dlsym(rtlm, "mqtt_rtlm_close");
         if (!mqttCloseRTLM) {          if (!mqttCloseRTLM) {
                mqttLog("Error:: Can't found mqtt_db_close call\n");                mqttLog("Error:: Can't found mqtt_rtlm_close call\n");
                 dlclose(rtlm);                  dlclose(rtlm);
                 return NULL;                  return NULL;
         }          }
Line 94  mqttLoadRTLM(cfg_root_t *cfg, int modtype) Line 94  mqttLoadRTLM(cfg_root_t *cfg, int modtype)
                         call.WritePUB_topic = dlsym(rtlm, "mqtt_rtlm_write_topic");                          call.WritePUB_topic = dlsym(rtlm, "mqtt_rtlm_write_topic");
                         call.ReadPUB_topic = dlsym(rtlm, "mqtt_rtlm_read_topic");                          call.ReadPUB_topic = dlsym(rtlm, "mqtt_rtlm_read_topic");
                         call.DeletePUB_topic = dlsym(rtlm, "mqtt_rtlm_delete_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.WritePUB_subscribe = dlsym(rtlm, "mqtt_rtlm_write_subscribe");
                         call.ReadPUB_subscribe = dlsym(rtlm, "mqtt_rtlm_read_subscribe");                          call.ReadPUB_subscribe = dlsym(rtlm, "mqtt_rtlm_read_subscribe");
                         call.DeletePUB_subscribe = dlsym(rtlm, "mqtt_rtlm_delete_subscribe");                          call.DeletePUB_subscribe = dlsym(rtlm, "mqtt_rtlm_delete_subscribe");

Removed from v.1.2.2.3  
changed lines
  Added in v.1.2.2.6


FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>