--- mqtt/src/accmqtt.c 2011/12/14 12:45:30 1.1.2.7 +++ mqtt/src/accmqtt.c 2012/05/27 10:12:48 1.2.2.5 @@ -20,10 +20,24 @@ mqtt_rtlm_log(const char *fmt, ...) vsyslog(LOG_ERR, fmt, lst); va_end(lst); } -#define MQTT_RTLM_LOG(_sql) (assert((_sql)), mqtt_rtlm_log("Error:: SQL #%d - %s", \ +#define MQTT_RTLM_LOG(_sql) (assert((_sql)), mqtt_rtlm_log("Error:: %s(%d) SQL #%d - %s", \ + __func__, __LINE__, \ sqlite3_errcode((_sql)), sqlite3_errmsg((_sql)))) +/* library pre-loaded actions */ +void +_init() +{ + sqlite3_initialize(); +} +void +_fini() +{ + sqlite3_shutdown(); +} + + /* * mqtt_rtlm_open() Open database connection * @@ -31,7 +45,7 @@ mqtt_rtlm_log(const char *fmt, ...) * return: NULL error or SQL handle */ sqlite3 * -mqtt_rtlm_open(sl_config *cfg) +mqtt_rtlm_open(cfg_root_t *cfg) { sqlite3 *sql = NULL; const char *str = NULL; @@ -39,10 +53,7 @@ mqtt_rtlm_open(sl_config *cfg) if (!cfg) return NULL; - if (!sqlite3_threadsafe() || sqlite3_config(SQLITE_CONFIG_SERIALIZED)) - return NULL; - - str = (const char*) cfg_GetAttribute(cfg, CFG("mqtt_acc"), CFG("name")); + str = (const char*) cfg_getAttribute(cfg, "mqtt_acc", "name"); if (!str) { mqtt_rtlm_log("Error:: Unknown database name ...\n"); return NULL; @@ -59,6 +70,7 @@ mqtt_rtlm_open(sl_config *cfg) sqlite3_close(sql); return NULL; } + return sql; } @@ -84,7 +96,7 @@ mqtt_rtlm_close(sqlite3 *sql) * return: -1 error, 0 ALLOW and 1 REJECT */ int -mqtt_rtlm_login(sl_config *cfg, sqlite3 *sql, const char *user, const char *pass) +mqtt_rtlm_login(cfg_root_t *cfg, sqlite3 *sql, const char *user, const char *pass) { /* insert into Users values (NULL, "", "", 1, strftime('%s','now')); */ int ret = 0; @@ -94,7 +106,7 @@ mqtt_rtlm_login(sl_config *cfg, sqlite3 *sql, const ch if (!sql) return -1; - str = (char*) cfg_GetAttribute(cfg, CFG("mqtt_acc"), CFG("tbl_users")); + str = (char*) cfg_getAttribute(cfg, "mqtt_acc", "tbl_users"); if (!str) { mqtt_rtlm_log("Error:: not found users table name"); return -1;