Return to dl.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / mqtt / src

Annotation of mqtt/src/dl.c, revision 1.1.2.3

1.1.2.1   misho       1: #include "global.h"
                      2: #include "rtlm.h"
                      3: 
                      4: 
                      5: static void *acc_rtlm, *pub_rtlm;
                      6: 
                      7: 
                      8: /*
                      9:  * mqttLog() Log message to syslog
                     10:  *
                     11:  * @fmt = format string
                     12:  * @... = argument list
                     13:  * return: none
                     14:  */
                     15: void
                     16: mqttLog(const char *fmt, ...)
                     17: {
                     18:        va_list lst;
                     19: 
                     20:        va_start(lst, fmt);
                     21:        vsyslog(LOG_ERR, fmt, lst);
                     22:        va_end(lst);
                     23: }
                     24: 
                     25: void *
                     26: mqttLoadRTLM(sl_config *cfg, int modtype)
                     27: {
1.1.2.3 ! misho      28:        const char *str;
1.1.2.1   misho      29:        void *rtlm = NULL;
                     30: 
                     31:        if (!cfg)
                     32:                return NULL;
                     33: 
1.1.2.3 ! misho      34:        str = (const char*) CFG(cfg_GetAttribute(cfg, CFG("mqttd"), CFG(modtype ? "pub_file" : "acc_file")));
1.1.2.1   misho      35:        if (!str) {
                     36:                mqttLog("Error:: RTL module not found\n");
                     37:                return NULL;
                     38:        }
                     39: 
                     40:        rtlm = dlopen(str, RTLD_LAZY);
                     41:        if (!rtlm) {
                     42:                mqttLog("Error:: RTL module not found %s\n", dlerror());
                     43:                return NULL;
                     44:        }
                     45: 
                     46:        mqttOpenDB = dlsym(rtlm, "mqtt_db_open");
                     47:        if (!mqttOpenDB) {
                     48:                mqttLog("Error:: Can't found mqtt_db_open call\n");
                     49:                dlclose(rtlm);
                     50:                return NULL;
                     51:        }
                     52:        mqttCloseDB = dlsym(rtlm, "mqtt_db_close");
                     53:        if (!mqttCloseDB) {
                     54:                mqttLog("Error:: Can't found mqtt_db_close call\n");
                     55:                dlclose(rtlm);
                     56:                return NULL;
                     57:        }
                     58: 
                     59:        if (modtype) {
                     60:                pub_rtlm = rtlm;
                     61:        } else {
                     62:                acc_rtlm = rtlm;
                     63:        }
                     64: 
                     65:        return rtlm;
                     66: }
                     67: 
                     68: void
                     69: mqttUnloadRTLM(int modtype)
                     70: {
                     71:        dlclose((modtype ? pub_rtlm : acc_rtlm));
                     72: }
1.1.2.2   misho      73: 
                     74: inline int
                     75: mqttMkDir(sl_config *cfg)
                     76: {
1.1.2.3 ! misho      77:        const char *str;
1.1.2.2   misho      78: 
                     79:        if (!cfg)
                     80:                return -1;
                     81: 
1.1.2.3 ! misho      82:        str = (const char*) cfg_GetAttribute(cfg, CFG("mqttd"), CFG("statedir"));
1.1.2.2   misho      83:        if (!str)
                     84:                return -1;
                     85: 
                     86:        if (mkdir(str, 0600) == -1 && errno != EEXIST)
                     87:                return -1;
                     88: 
                     89:        return 0;
                     90: }