[BACK]Return to dl.c CVS log [TXT] [DIR] Up to [ELWIX - Embedded LightWeight unIX -] / mqtt / src

Diff for /mqtt/src/dl.c between versions 1.1.2.3 and 1.1.2.4

version 1.1.2.3, 2011/11/23 08:09:40 version 1.1.2.4, 2011/11/23 08:50:03
Line 2 Line 2
 #include "rtlm.h"  #include "rtlm.h"
   
   
static void *acc_rtlm, *pub_rtlm;static void *acc_rtlm, *pub_rtlm, *log_rtlm;
   
   
 /*  /*
Line 25  mqttLog(const char *fmt, ...) Line 25  mqttLog(const char *fmt, ...)
 void *  void *
 mqttLoadRTLM(sl_config *cfg, int modtype)  mqttLoadRTLM(sl_config *cfg, int modtype)
 {  {
        const char *str;        const char *str, *attr;
         void *rtlm = NULL;          void *rtlm = NULL;
           void *(*mqttOpenRTLM)(sl_config *);
           void (*mqttCloseRTLM)(void *);
   
         if (!cfg)          if (!cfg)
                 return NULL;                  return NULL;
   
        str = (const char*) 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 = (const char*) CFG(cfg_GetAttribute(cfg, CFG("mqttd"), CFG(attr)));
         if (!str) {          if (!str) {
                 mqttLog("Error:: RTL module not found\n");                  mqttLog("Error:: RTL module not found\n");
                 return NULL;                  return NULL;
Line 43  mqttLoadRTLM(sl_config *cfg, int modtype) Line 57  mqttLoadRTLM(sl_config *cfg, int modtype)
                 return NULL;                  return NULL;
         }          }
   
        mqttOpenDB = dlsym(rtlm, "mqtt_db_open");        mqttOpenRTLM = dlsym(rtlm, "mqtt_rtlm_open");
        if (!mqttOpenDB) {        if (!mqttOpenRTLM) {
                 mqttLog("Error:: Can't found mqtt_db_open call\n");                  mqttLog("Error:: Can't found mqtt_db_open call\n");
                 dlclose(rtlm);                  dlclose(rtlm);
                 return NULL;                  return NULL;
         }          }
        mqttCloseDB = dlsym(rtlm, "mqtt_db_close");        mqttCloseRTLM = dlsym(rtlm, "mqtt_rtlm_close");
        if (!mqttCloseDB) {        if (!mqttCloseRTLM) {
                 mqttLog("Error:: Can't found mqtt_db_close call\n");                  mqttLog("Error:: Can't found mqtt_db_close call\n");
                 dlclose(rtlm);                  dlclose(rtlm);
                 return NULL;                  return NULL;
         }          }
   
        if (modtype) {        switch (modtype) {
                pub_rtlm = rtlm;                case 0:
        } else {                        acc_rtlm = rtlm;
                acc_rtlm = rtlm;                        mqttOpenACC = mqttOpenRTLM;
                         mqttCloseACC = mqttCloseRTLM;
                         break;
                 case 1:
                         pub_rtlm = rtlm;
                         mqttOpenPUB = mqttOpenRTLM;
                         mqttClosePUB = mqttCloseRTLM;
                         break;
                 default:
                         log_rtlm = rtlm;
                         mqttOpenLOG = mqttOpenRTLM;
                         mqttCloseLOG = mqttCloseRTLM;
                         break;
         }          }
   
         return rtlm;          return rtlm;
Line 68  mqttLoadRTLM(sl_config *cfg, int modtype) Line 94  mqttLoadRTLM(sl_config *cfg, int modtype)
 void  void
 mqttUnloadRTLM(int modtype)  mqttUnloadRTLM(int modtype)
 {  {
        dlclose((modtype ? pub_rtlm : acc_rtlm));        switch (modtype) {
                 case 0:
                         dlclose(acc_rtlm);
                         break;
                 case 1:
                         dlclose(pub_rtlm);
                         break;
                 default:
                         dlclose(log_rtlm);
                         break;
         }
 }  }
   
 inline int  inline int
Removed from v.1.1.2.3  
changed lines
  Added in v.1.1.2.4

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