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

Diff for /mqtt/src/accmqtt.c between versions 1.2 and 1.2.2.3

version 1.2, 2012/01/27 15:05:38 version 1.2.2.3, 2012/04/25 12:04:30
Line 20  mqtt_rtlm_log(const char *fmt, ...) Line 20  mqtt_rtlm_log(const char *fmt, ...)
         vsyslog(LOG_ERR, fmt, lst);          vsyslog(LOG_ERR, fmt, lst);
         va_end(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))))                                          sqlite3_errcode((_sql)), sqlite3_errmsg((_sql))))
   
   
Line 31  mqtt_rtlm_log(const char *fmt, ...) Line 32  mqtt_rtlm_log(const char *fmt, ...)
  * return: NULL error or SQL handle   * return: NULL error or SQL handle
  */   */
 sqlite3 *  sqlite3 *
mqtt_rtlm_open(sl_config *cfg)mqtt_rtlm_open(cfg_root_t *cfg)
 {  {
         sqlite3 *sql = NULL;          sqlite3 *sql = NULL;
         const char *str = NULL;          const char *str = NULL;
Line 39  mqtt_rtlm_open(sl_config *cfg) Line 40  mqtt_rtlm_open(sl_config *cfg)
         if (!cfg)          if (!cfg)
                 return NULL;                  return NULL;
   
        if (!sqlite3_threadsafe() || sqlite3_config(SQLITE_CONFIG_SERIALIZED))        sqlite3_config(SQLITE_CONFIG_SERIALIZED);
         if (!sqlite3_threadsafe())
                 return NULL;                  return NULL;
   
        str = (const char*) cfg_GetAttribute(cfg, CFG("mqtt_acc"), CFG("name"));        str = (const char*) cfg_getAttribute(cfg, "mqtt_acc", "name");
         if (!str) {          if (!str) {
                 mqtt_rtlm_log("Error:: Unknown database name ...\n");                  mqtt_rtlm_log("Error:: Unknown database name ...\n");
                 return NULL;                  return NULL;
Line 54  mqtt_rtlm_open(sl_config *cfg) Line 56  mqtt_rtlm_open(sl_config *cfg)
                 return NULL;                  return NULL;
         }          }
   
           sqlite3_mutex_enter(sqlite3_db_mutex(sql));
         if (sqlite3_exec(sql, sql_schema, NULL, NULL, NULL)) {          if (sqlite3_exec(sql, sql_schema, NULL, NULL, NULL)) {
                 MQTT_RTLM_LOG(sql);                  MQTT_RTLM_LOG(sql);
                   sqlite3_mutex_leave(sqlite3_db_mutex(sql));
                 sqlite3_close(sql);                  sqlite3_close(sql);
                 return NULL;                  return NULL;
         }          }
           sqlite3_mutex_leave(sqlite3_db_mutex(sql));
         return sql;          return sql;
 }  }
   
Line 84  mqtt_rtlm_close(sqlite3 *sql) Line 89  mqtt_rtlm_close(sqlite3 *sql)
  * return: -1 error, 0 ALLOW and 1 REJECT   * return: -1 error, 0 ALLOW and 1 REJECT
  */   */
 int  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')); */          /* insert into Users values (NULL, "", "", 1, strftime('%s','now')); */
         int ret = 0;          int ret = 0;
Line 94  mqtt_rtlm_login(sl_config *cfg, sqlite3 *sql, const ch Line 99  mqtt_rtlm_login(sl_config *cfg, sqlite3 *sql, const ch
         if (!sql)          if (!sql)
                 return -1;                  return -1;
   
        str = (char*) cfg_GetAttribute(cfg, CFG("mqtt_acc"), CFG("tbl_users"));        str = (char*) cfg_getAttribute(cfg, "mqtt_acc", "tbl_users");
         if (!str) {          if (!str) {
                 mqtt_rtlm_log("Error:: not found users table name");                  mqtt_rtlm_log("Error:: not found users table name");
                 return -1;                  return -1;
Line 102  mqtt_rtlm_login(sl_config *cfg, sqlite3 *sql, const ch Line 107  mqtt_rtlm_login(sl_config *cfg, sqlite3 *sql, const ch
         snprintf(szStmt, sizeof szStmt, "SELECT DISTINCT Username, Password, Access FROM %s "          snprintf(szStmt, sizeof szStmt, "SELECT DISTINCT Username, Password, Access FROM %s "
                         "WHERE Username = '%s' AND Password = '%s' AND Access > 0;", str, user, pass);                          "WHERE Username = '%s' AND Password = '%s' AND Access > 0;", str, user, pass);
   
           sqlite3_mutex_enter(sqlite3_db_mutex(sql));
         if (sqlite3_prepare_v2(sql, szStmt, strlen(szStmt), &stmt, NULL)) {          if (sqlite3_prepare_v2(sql, szStmt, strlen(szStmt), &stmt, NULL)) {
                 MQTT_RTLM_LOG(sql);                  MQTT_RTLM_LOG(sql);
                   sqlite3_mutex_leave(sqlite3_db_mutex(sql));
                 return -1;                  return -1;
         }          }
         while (sqlite3_step(stmt) == SQLITE_ROW) {          while (sqlite3_step(stmt) == SQLITE_ROW) {
Line 114  mqtt_rtlm_login(sl_config *cfg, sqlite3 *sql, const ch Line 121  mqtt_rtlm_login(sl_config *cfg, sqlite3 *sql, const ch
                 break;                  break;
         }          }
         sqlite3_finalize(stmt);          sqlite3_finalize(stmt);
           sqlite3_mutex_leave(sqlite3_db_mutex(sql));
   
         return ret;          return ret;
 }  }
Removed from v.1.2  
changed lines
  Added in v.1.2.2.3

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