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

Diff for /mqtt/src/pubmqtt.c between versions 1.2.2.2 and 1.2.2.5

version 1.2.2.2, 2012/02/01 15:44:40 version 1.2.2.5, 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;
   
        /*        sqlite3_config(SQLITE_CONFIG_SERIALIZED);
        if (!sqlite3_threadsafe() || sqlite3_config(SQLITE_CONFIG_SERIALIZED))        if (!sqlite3_threadsafe())
                 return NULL;                  return NULL;
                 */  
   
        str = (const char*) cfg_GetAttribute(cfg, CFG("mqtt_pub"), CFG("name"));        str = cfg_getAttribute(cfg, "mqtt_pub", "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 56  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 89  mqtt_rtlm_close(sqlite3 *sql) Line 92  mqtt_rtlm_close(sqlite3 *sql)
  * return: -1 error, 0 session already appears or >0 row changed   * return: -1 error, 0 session already appears or >0 row changed
  */   */
 int  int
mqtt_rtlm_init_session(sl_config *cfg, sqlite3 *sql, const char *connid, const char *user, mqtt_rtlm_init_session(cfg_root_t *cfg, sqlite3 *sql, const char *connid, const char *user, 
                 const char *host, char will, ...)                  const char *host, char will, ...)
 {  {
         va_list lst;          va_list lst;
Line 100  mqtt_rtlm_init_session(sl_config *cfg, sqlite3 *sql, c Line 103  mqtt_rtlm_init_session(sl_config *cfg, sqlite3 *sql, c
         if (!cfg || !sql)          if (!cfg || !sql)
                 return -1;                  return -1;
   
        str = (char*) cfg_GetAttribute(cfg, CFG("mqtt_pub"), CFG("tbl_online"));        str = (char*) cfg_getAttribute(cfg, "mqtt_pub", "tbl_online");
         if (!str) {          if (!str) {
                 mqtt_rtlm_log("Error:: not found online table name");                  mqtt_rtlm_log("Error:: not found online table name");
                 return -1;                  return -1;
Line 118  mqtt_rtlm_init_session(sl_config *cfg, sqlite3 *sql, c Line 121  mqtt_rtlm_init_session(sl_config *cfg, sqlite3 *sql, c
                 va_end(lst);                  va_end(lst);
         }          }
   
           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;
         }          }
         if ((ret = sqlite3_step(stmt)) == SQLITE_DONE)          if ((ret = sqlite3_step(stmt)) == SQLITE_DONE)
Line 130  mqtt_rtlm_init_session(sl_config *cfg, sqlite3 *sql, c Line 135  mqtt_rtlm_init_session(sl_config *cfg, sqlite3 *sql, c
                 ret = 0;                  ret = 0;
         }          }
         sqlite3_finalize(stmt);          sqlite3_finalize(stmt);
           sqlite3_mutex_leave(sqlite3_db_mutex(sql));
   
         return ret;          return ret;
 }  }
Line 145  mqtt_rtlm_init_session(sl_config *cfg, sqlite3 *sql, c Line 151  mqtt_rtlm_init_session(sl_config *cfg, sqlite3 *sql, c
  * return: -1 error, 0 session already appears or >0 row changed   * return: -1 error, 0 session already appears or >0 row changed
  */   */
 int  int
mqtt_rtlm_fini_session(sl_config *cfg, sqlite3 *sql, const char *connid, const char *user, const char *host)mqtt_rtlm_fini_session(cfg_root_t *cfg, sqlite3 *sql, const char *connid, const char *user, const char *host)
 {  {
         int ret = 0;          int ret = 0;
         char *str, szStmt[BUFSIZ] = { 0 };          char *str, szStmt[BUFSIZ] = { 0 };
Line 154  mqtt_rtlm_fini_session(sl_config *cfg, sqlite3 *sql, c Line 160  mqtt_rtlm_fini_session(sl_config *cfg, sqlite3 *sql, c
         if (!cfg || !sql)          if (!cfg || !sql)
                 return -1;                  return -1;
   
        str = (char*) cfg_GetAttribute(cfg, CFG("mqtt_pub"), CFG("tbl_online"));        str = (char*) cfg_getAttribute(cfg, "mqtt_pub", "tbl_online");
         if (!str) {          if (!str) {
                 mqtt_rtlm_log("Error:: not found online table name");                  mqtt_rtlm_log("Error:: not found online table name");
                 return -1;                  return -1;
Line 162  mqtt_rtlm_fini_session(sl_config *cfg, sqlite3 *sql, c Line 168  mqtt_rtlm_fini_session(sl_config *cfg, sqlite3 *sql, c
         snprintf(szStmt, sizeof szStmt, "DELETE FROM %s WHERE ConnID = '%s' AND Username = '%s' "          snprintf(szStmt, sizeof szStmt, "DELETE FROM %s WHERE ConnID = '%s' AND Username = '%s' "
                         "AND RemoteHost LIKE '%s';", str, connid, user, host);                          "AND RemoteHost LIKE '%s';", str, connid, user, host);
   
           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;
         }          }
         if ((ret = sqlite3_step(stmt)) == SQLITE_DONE)          if ((ret = sqlite3_step(stmt)) == SQLITE_DONE)
Line 174  mqtt_rtlm_fini_session(sl_config *cfg, sqlite3 *sql, c Line 182  mqtt_rtlm_fini_session(sl_config *cfg, sqlite3 *sql, c
                 ret = 0;                  ret = 0;
         }          }
         sqlite3_finalize(stmt);          sqlite3_finalize(stmt);
           sqlite3_mutex_leave(sqlite3_db_mutex(sql));
   
         return ret;          return ret;
 }  }
Line 189  mqtt_rtlm_fini_session(sl_config *cfg, sqlite3 *sql, c Line 198  mqtt_rtlm_fini_session(sl_config *cfg, sqlite3 *sql, c
  * return: -1 error, 0 not logged or >0 logged found rows   * return: -1 error, 0 not logged or >0 logged found rows
  */   */
 int  int
mqtt_rtlm_chk_session(sl_config *cfg, sqlite3 *sql, const char *connid, const char *user, const char *host)mqtt_rtlm_chk_session(cfg_root_t *cfg, sqlite3 *sql, const char *connid, const char *user, const char *host)
 {  {
         int ret = 0;          int ret = 0;
         char *str, szStmt[BUFSIZ] = { 0 };          char *str, szStmt[BUFSIZ] = { 0 };
Line 198  mqtt_rtlm_chk_session(sl_config *cfg, sqlite3 *sql, co Line 207  mqtt_rtlm_chk_session(sl_config *cfg, sqlite3 *sql, co
         if (!cfg || !sql)          if (!cfg || !sql)
                 return -1;                  return -1;
   
        str = (char*) cfg_GetAttribute(cfg, CFG("mqtt_pub"), CFG("tbl_online"));        str = (char*) cfg_getAttribute(cfg, "mqtt_pub", "tbl_online");
         if (!str) {          if (!str) {
                 mqtt_rtlm_log("Error:: not found online table name");                  mqtt_rtlm_log("Error:: not found online table name");
                 return -1;                  return -1;
Line 207  mqtt_rtlm_chk_session(sl_config *cfg, sqlite3 *sql, co Line 216  mqtt_rtlm_chk_session(sl_config *cfg, sqlite3 *sql, co
                         "ConnID = '%s' AND Username = '%s' AND RemoteHost LIKE '%s';",                           "ConnID = '%s' AND Username = '%s' AND RemoteHost LIKE '%s';", 
                         str, connid, user, host);                          str, connid, user, host);
   
           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;
         }          }
         if (sqlite3_step(stmt) == SQLITE_ROW)          if (sqlite3_step(stmt) == SQLITE_ROW)
Line 216  mqtt_rtlm_chk_session(sl_config *cfg, sqlite3 *sql, co Line 227  mqtt_rtlm_chk_session(sl_config *cfg, sqlite3 *sql, co
         else          else
                 ret = 0;                  ret = 0;
         sqlite3_finalize(stmt);          sqlite3_finalize(stmt);
           sqlite3_mutex_leave(sqlite3_db_mutex(sql));
   
         return ret;          return ret;
 }  }
Line 234  mqtt_rtlm_chk_session(sl_config *cfg, sqlite3 *sql, co Line 246  mqtt_rtlm_chk_session(sl_config *cfg, sqlite3 *sql, co
  * return: -1 error, 0 no publish or >0 published ok   * return: -1 error, 0 no publish or >0 published ok
  */   */
 int  int
mqtt_rtlm_write_topic(sl_config *cfg, sqlite3 *sql, u_short msgid, const char *topic, const char *txt, mqtt_rtlm_write_topic(cfg_root_t *cfg, sqlite3 *sql, u_short msgid, const char *topic, const char *txt, 
                 const char *user, const char *host, char retain)                  const char *user, const char *host, char retain)
 {  {
         int ret = 0;          int ret = 0;
Line 244  mqtt_rtlm_write_topic(sl_config *cfg, sqlite3 *sql, u_ Line 256  mqtt_rtlm_write_topic(sl_config *cfg, sqlite3 *sql, u_
         if (!cfg || !sql || !topic)          if (!cfg || !sql || !topic)
                 return -1;                  return -1;
   
        str = (char*) cfg_GetAttribute(cfg, CFG("mqtt_pub"), CFG("tbl_topics"));        str = (char*) cfg_getAttribute(cfg, "mqtt_pub", "tbl_topics");
         if (!str) {          if (!str) {
                 mqtt_rtlm_log("Error:: not found topics table name");                  mqtt_rtlm_log("Error:: not found topics table name");
                 return -1;                  return -1;
Line 254  mqtt_rtlm_write_topic(sl_config *cfg, sqlite3 *sql, u_ Line 266  mqtt_rtlm_write_topic(sl_config *cfg, sqlite3 *sql, u_
                         "datetime('now', 'localtime'), '%s');",                           "datetime('now', 'localtime'), '%s');", 
                         str, retain, msgid, topic, txt, user, host);                          str, retain, msgid, topic, txt, user, host);
   
           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;
         }          }
         if ((ret = sqlite3_step(stmt)) == SQLITE_DONE)          if ((ret = sqlite3_step(stmt)) == SQLITE_DONE)
Line 266  mqtt_rtlm_write_topic(sl_config *cfg, sqlite3 *sql, u_ Line 280  mqtt_rtlm_write_topic(sl_config *cfg, sqlite3 *sql, u_
                 ret = 0;                  ret = 0;
         }          }
         sqlite3_finalize(stmt);          sqlite3_finalize(stmt);
           sqlite3_mutex_leave(sqlite3_db_mutex(sql));
   
         return ret;          return ret;
 }  }
Line 283  mqtt_rtlm_write_topic(sl_config *cfg, sqlite3 *sql, u_ Line 298  mqtt_rtlm_write_topic(sl_config *cfg, sqlite3 *sql, u_
  * return: -1 error, 0 no changes or >0 deleted rows   * return: -1 error, 0 no changes or >0 deleted rows
  */   */
 int  int
mqtt_rtlm_delete_topic(sl_config *cfg, sqlite3 *sql, u_short msgid, const char *topic, mqtt_rtlm_delete_topic(cfg_root_t *cfg, sqlite3 *sql, u_short msgid, const char *topic, 
                 const char *user, const char *host, char retain)                  const char *user, const char *host, char retain)
 {  {
         int ret = 0;          int ret = 0;
Line 293  mqtt_rtlm_delete_topic(sl_config *cfg, sqlite3 *sql, u Line 308  mqtt_rtlm_delete_topic(sl_config *cfg, sqlite3 *sql, u
         if (!cfg || !sql || !topic)          if (!cfg || !sql || !topic)
                 return -1;                  return -1;
   
        str = (char*) cfg_GetAttribute(cfg, CFG("mqtt_pub"), CFG("tbl_topics"));        str = (char*) cfg_getAttribute(cfg, "mqtt_pub", "tbl_topics");
         if (!str) {          if (!str) {
                 mqtt_rtlm_log("Error:: not found topics table name");                  mqtt_rtlm_log("Error:: not found topics table name");
                 return -1;                  return -1;
Line 313  mqtt_rtlm_delete_topic(sl_config *cfg, sqlite3 *sql, u Line 328  mqtt_rtlm_delete_topic(sl_config *cfg, sqlite3 *sql, u
                         "PubUser LIKE '%s' AND PubHost LIKE '%s' %s;", str,                           "PubUser LIKE '%s' AND PubHost LIKE '%s' %s;", str, 
                         msgid, topic, user, host, rtn);                          msgid, topic, user, host, rtn);
   
           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;
         }          }
         if ((ret = sqlite3_step(stmt)) == SQLITE_DONE)          if ((ret = sqlite3_step(stmt)) == SQLITE_DONE)
Line 325  mqtt_rtlm_delete_topic(sl_config *cfg, sqlite3 *sql, u Line 342  mqtt_rtlm_delete_topic(sl_config *cfg, sqlite3 *sql, u
                 ret = 0;                  ret = 0;
         }          }
         sqlite3_finalize(stmt);          sqlite3_finalize(stmt);
           sqlite3_mutex_leave(sqlite3_db_mutex(sql));
   
         return ret;          return ret;
 }  }
Line 340  mqtt_rtlm_delete_topic(sl_config *cfg, sqlite3 *sql, u Line 358  mqtt_rtlm_delete_topic(sl_config *cfg, sqlite3 *sql, u
  * return: NULL error or not found and !=NULL allocated subscribe topics   * return: NULL error or not found and !=NULL allocated subscribe topics
  */   */
 mqtt_subscr_t *  mqtt_subscr_t *
mqtt_rtlm_read_topic(sl_config *cfg, sqlite3 *sql, u_short msgid, const char *topic, char retain)mqtt_rtlm_read_topic(cfg_root_t *cfg, sqlite3 *sql, u_short msgid, const char *topic, char retain)
 {  {
         int rowz = 0;          int rowz = 0;
         char *str, szStr[STRSIZ], szStmt[BUFSIZ] = { 0 };          char *str, szStr[STRSIZ], szStmt[BUFSIZ] = { 0 };
Line 363  mqtt_rtlm_read_topic(sl_config *cfg, sqlite3 *sql, u_s Line 381  mqtt_rtlm_read_topic(sl_config *cfg, sqlite3 *sql, u_s
                         break;                          break;
         }          }
   
        str = (char*) cfg_GetAttribute(cfg, CFG("mqtt_pub"), CFG("tbl_topics"));        str = (char*) cfg_getAttribute(cfg, "mqtt_pub", "tbl_topics");
         if (!str) {          if (!str) {
                 mqtt_rtlm_log("Error:: not found topics table name");                  mqtt_rtlm_log("Error:: not found topics table name");
                 return NULL;                  return NULL;
Line 372  mqtt_rtlm_read_topic(sl_config *cfg, sqlite3 *sql, u_s Line 390  mqtt_rtlm_read_topic(sl_config *cfg, sqlite3 *sql, u_s
                         "MsgID = %d AND Topic LIKE '%s' %s;",                           "MsgID = %d AND Topic LIKE '%s' %s;", 
                         str, msgid, topic, szStr);                          str, msgid, topic, szStr);
   
           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 NULL;                  return NULL;
         }          }
   
Line 397  mqtt_rtlm_read_topic(sl_config *cfg, sqlite3 *sql, u_s Line 417  mqtt_rtlm_read_topic(sl_config *cfg, sqlite3 *sql, u_s
         }          }
 end:  end:
         sqlite3_finalize(stmt);          sqlite3_finalize(stmt);
           sqlite3_mutex_leave(sqlite3_db_mutex(sql));
   
         return s;          return s;
 }  }
Line 414  end: Line 435  end:
  * return: -1 error, 0 no publish or >0 published ok   * return: -1 error, 0 no publish or >0 published ok
  */   */
 int  int
mqtt_rtlm_write_subscribe(sl_config *cfg, sqlite3 *sql, u_short msgid, const char *topic, mqtt_rtlm_write_subscribe(cfg_root_t *cfg, sqlite3 *sql, u_short msgid, const char *topic, 
                 const char *user, const char *host, char qos)                  const char *user, const char *host, char qos)
 {  {
         int ret = 0;          int ret = 0;
Line 424  mqtt_rtlm_write_subscribe(sl_config *cfg, sqlite3 *sql Line 445  mqtt_rtlm_write_subscribe(sl_config *cfg, sqlite3 *sql
         if (!cfg || !sql || !topic)          if (!cfg || !sql || !topic)
                 return -1;                  return -1;
   
        str = (char*) cfg_GetAttribute(cfg, CFG("mqtt_pub"), CFG("tbl_subscribes"));        str = (char*) cfg_getAttribute(cfg, "mqtt_pub", "tbl_subscribes");
         if (!str) {          if (!str) {
                 mqtt_rtlm_log("Error:: not found subscribes table name");                  mqtt_rtlm_log("Error:: not found subscribes table name");
                 return -1;                  return -1;
Line 434  mqtt_rtlm_write_subscribe(sl_config *cfg, sqlite3 *sql Line 455  mqtt_rtlm_write_subscribe(sl_config *cfg, sqlite3 *sql
                         "datetime('now', 'localtime'), '%s');", str,                           "datetime('now', 'localtime'), '%s');", str, 
                         msgid, qos, topic, user, host);                          msgid, qos, topic, user, host);
   
           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;
         }          }
         if ((ret = sqlite3_step(stmt)) == SQLITE_DONE)          if ((ret = sqlite3_step(stmt)) == SQLITE_DONE)
Line 446  mqtt_rtlm_write_subscribe(sl_config *cfg, sqlite3 *sql Line 469  mqtt_rtlm_write_subscribe(sl_config *cfg, sqlite3 *sql
                 ret = 0;                  ret = 0;
         }          }
         sqlite3_finalize(stmt);          sqlite3_finalize(stmt);
           sqlite3_mutex_leave(sqlite3_db_mutex(sql));
   
         return ret;          return ret;
 }  }
Line 462  mqtt_rtlm_write_subscribe(sl_config *cfg, sqlite3 *sql Line 486  mqtt_rtlm_write_subscribe(sl_config *cfg, sqlite3 *sql
  * return: -1 error, 0 no changes or >0 deleted rows   * return: -1 error, 0 no changes or >0 deleted rows
  */   */
 int  int
mqtt_rtlm_delete_subscribe(sl_config *cfg, sqlite3 *sql, const char *topic, mqtt_rtlm_delete_subscribe(cfg_root_t *cfg, sqlite3 *sql, const char *topic, 
                 const char *user, const char *host, char qos)                  const char *user, const char *host, char qos)
 {  {
         int ret = 0;          int ret = 0;
Line 472  mqtt_rtlm_delete_subscribe(sl_config *cfg, sqlite3 *sq Line 496  mqtt_rtlm_delete_subscribe(sl_config *cfg, sqlite3 *sq
         if (!cfg || !sql || !topic)          if (!cfg || !sql || !topic)
                 return -1;                  return -1;
   
        str = (char*) cfg_GetAttribute(cfg, CFG("mqtt_pub"), CFG("tbl_subscribes"));        str = (char*) cfg_getAttribute(cfg, "mqtt_pub", "tbl_subscribes");
         if (!str) {          if (!str) {
                 mqtt_rtlm_log("Error:: not found subscribes table name");                  mqtt_rtlm_log("Error:: not found subscribes table name");
                 return -1;                  return -1;
Line 483  mqtt_rtlm_delete_subscribe(sl_config *cfg, sqlite3 *sq Line 507  mqtt_rtlm_delete_subscribe(sl_config *cfg, sqlite3 *sq
                         "PubUser LIKE '%s' AND PubHost LIKE '%s' %s;", str,                           "PubUser LIKE '%s' AND PubHost LIKE '%s' %s;", str, 
                         topic, user, host, szStr);                          topic, user, host, szStr);
   
           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;
         }          }
         if ((ret = sqlite3_step(stmt)) == SQLITE_DONE)          if ((ret = sqlite3_step(stmt)) == SQLITE_DONE)
Line 495  mqtt_rtlm_delete_subscribe(sl_config *cfg, sqlite3 *sq Line 521  mqtt_rtlm_delete_subscribe(sl_config *cfg, sqlite3 *sq
                 ret = 0;                  ret = 0;
         }          }
         sqlite3_finalize(stmt);          sqlite3_finalize(stmt);
           sqlite3_mutex_leave(sqlite3_db_mutex(sql));
   
         return ret;          return ret;
 }  }
Line 508  mqtt_rtlm_delete_subscribe(sl_config *cfg, sqlite3 *sq Line 535  mqtt_rtlm_delete_subscribe(sl_config *cfg, sqlite3 *sq
  * return: NULL error or not found and !=NULL allocated subscribe topics   * return: NULL error or not found and !=NULL allocated subscribe topics
  */   */
 mqtt_subscr_t *  mqtt_subscr_t *
mqtt_rtlm_read_subscribe(sl_config *cfg, sqlite3 *sql, const char *topic)mqtt_rtlm_read_subscribe(cfg_root_t *cfg, sqlite3 *sql, const char *topic)
 {  {
         int rowz = 0;          int rowz = 0;
         char *str, szStmt[BUFSIZ] = { 0 };          char *str, szStmt[BUFSIZ] = { 0 };
Line 519  mqtt_rtlm_read_subscribe(sl_config *cfg, sqlite3 *sql, Line 546  mqtt_rtlm_read_subscribe(sl_config *cfg, sqlite3 *sql,
         if (!cfg || !sql || !topic)          if (!cfg || !sql || !topic)
                 return NULL;                  return NULL;
   
        str = (char*) cfg_GetAttribute(cfg, CFG("mqtt_pub"), CFG("tbl_subscribes"));        str = (char*) cfg_getAttribute(cfg, "mqtt_pub", "tbl_subscribes");
         if (!str) {          if (!str) {
                 mqtt_rtlm_log("Error:: not found subscribes table name");                  mqtt_rtlm_log("Error:: not found subscribes table name");
                 return NULL;                  return NULL;
         }          }
         snprintf(szStmt, sizeof szStmt, "SELECT QoS, Topic FROM %s WHERE Topic LIKE '%s';", str, topic);          snprintf(szStmt, sizeof szStmt, "SELECT QoS, Topic FROM %s WHERE Topic LIKE '%s';", str, topic);
   
           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 NULL;                  return NULL;
         }          }
   
Line 551  mqtt_rtlm_read_subscribe(sl_config *cfg, sqlite3 *sql, Line 580  mqtt_rtlm_read_subscribe(sl_config *cfg, sqlite3 *sql,
         }          }
 end:  end:
         sqlite3_finalize(stmt);          sqlite3_finalize(stmt);
           sqlite3_mutex_leave(sqlite3_db_mutex(sql));
   
         return s;          return s;
 }  }
Removed from v.1.2.2.2  
changed lines
  Added in v.1.2.2.5

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