[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.10 and 1.2.2.11

version 1.2.2.10, 2012/05/27 10:12:48 version 1.2.2.11, 2012/06/26 08:05:58
Line 103  mqtt_rtlm_init_session(cfg_root_t *cfg, sqlite3 *sql,  Line 103  mqtt_rtlm_init_session(cfg_root_t *cfg, sqlite3 *sql, 
 {  {
         va_list lst;          va_list lst;
         int ret = 0;          int ret = 0;
        char *str, szStmt[BUFSIZ] = { 0 };        char *str, *psStmt;
         sqlite3_stmt *stmt;          sqlite3_stmt *stmt;
   
         if (!cfg || !sql)          if (!cfg || !sql)
Line 115  mqtt_rtlm_init_session(cfg_root_t *cfg, sqlite3 *sql,  Line 115  mqtt_rtlm_init_session(cfg_root_t *cfg, sqlite3 *sql, 
                 return -1;                  return -1;
         }          }
         if (!will)          if (!will)
                snprintf(szStmt, sizeof szStmt, "INSERT INTO %s (ConnID, Username, RemoteHost, "                psStmt = sqlite3_mprintf("INSERT INTO %s (ConnID, Username, RemoteHost, "
                                "WillFlag) VALUES ('%s', '%s', '%s', 0);", str, connid, user, host);                                "WillFlag) VALUES ('%q', '%q', '%q', 0);", str, connid, user, host);
         else {          else {
                 va_start(lst, will);                  va_start(lst, will);
                snprintf(szStmt, sizeof szStmt, "INSERT INTO %s (ConnID, Username, RemoteHost, "                psStmt = sqlite3_mprintf("INSERT INTO %s (ConnID, Username, RemoteHost, "
                                 "WillFlag, WillRetain, WillQoS, WillMsg, WillTopic) "                                  "WillFlag, WillRetain, WillQoS, WillMsg, WillTopic) "
                                "VALUES ('%s', '%s', '%s', %d, %d, %d, '%s', '%s');",                                 "VALUES ('%q', '%q', '%q', %d, %d, %d, '%q', '%q');", 
                                 str, connid, user, host, will,                                   str, connid, user, host, will, 
                                 va_arg(lst, int), va_arg(lst, int), va_arg(lst, char*), va_arg(lst, char*));                                  va_arg(lst, int), va_arg(lst, int), va_arg(lst, char*), va_arg(lst, char*));
                 va_end(lst);                  va_end(lst);
         }          }
   
        if (sqlite3_prepare_v2(sql, szStmt, strlen(szStmt), &stmt, NULL)) {        if (sqlite3_prepare_v2(sql, psStmt, strlen(psStmt), &stmt, NULL)) {
                 MQTT_RTLM_LOG(sql);                  MQTT_RTLM_LOG(sql);
                   sqlite3_free(psStmt);
                 return -1;                  return -1;
        }        } else
                 sqlite3_free(psStmt);
         if ((ret = sqlite3_step(stmt)) == SQLITE_DONE)          if ((ret = sqlite3_step(stmt)) == SQLITE_DONE)
                 ret = sqlite3_changes(sql);                  ret = sqlite3_changes(sql);
         else {          else {
Line 157  int Line 159  int
 mqtt_rtlm_fini_session(cfg_root_t *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, *psStmt;
         sqlite3_stmt *stmt;          sqlite3_stmt *stmt;
   
         if (!cfg || !sql)          if (!cfg || !sql)
Line 168  mqtt_rtlm_fini_session(cfg_root_t *cfg, sqlite3 *sql,  Line 170  mqtt_rtlm_fini_session(cfg_root_t *cfg, sqlite3 *sql, 
                 mqtt_rtlm_log("Error:: not found online table name");                  mqtt_rtlm_log("Error:: not found online table name");
                 return -1;                  return -1;
         }          }
        snprintf(szStmt, sizeof szStmt, "DELETE FROM %s WHERE ConnID = '%s' AND Username = '%s' "        psStmt = sqlite3_mprintf("DELETE FROM %s WHERE ConnID = '%q' AND Username = '%q' "
                        "AND RemoteHost LIKE '%s';", str, connid, user, host);                        "AND RemoteHost LIKE '%q';", str, connid, user, host);
   
        if (sqlite3_prepare_v2(sql, szStmt, strlen(szStmt), &stmt, NULL)) {        if (sqlite3_prepare_v2(sql, psStmt, strlen(psStmt), &stmt, NULL)) {
                 MQTT_RTLM_LOG(sql);                  MQTT_RTLM_LOG(sql);
                   sqlite3_free(psStmt);
                 return -1;                  return -1;
        }        } else
                 sqlite3_free(psStmt);
         if ((ret = sqlite3_step(stmt)) == SQLITE_DONE)          if ((ret = sqlite3_step(stmt)) == SQLITE_DONE)
                 ret = sqlite3_changes(sql);                  ret = sqlite3_changes(sql);
         else {          else {
Line 201  int Line 205  int
 mqtt_rtlm_chk_session(cfg_root_t *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, *psStmt;
         sqlite3_stmt *stmt;          sqlite3_stmt *stmt;
   
         if (!cfg || !sql)          if (!cfg || !sql)
Line 212  mqtt_rtlm_chk_session(cfg_root_t *cfg, sqlite3 *sql, c Line 216  mqtt_rtlm_chk_session(cfg_root_t *cfg, sqlite3 *sql, c
                 mqtt_rtlm_log("Error:: not found online table name");                  mqtt_rtlm_log("Error:: not found online table name");
                 return -1;                  return -1;
         }          }
        snprintf(szStmt, sizeof szStmt, "SELECT ConnID, RemoteHost FROM %s WHERE "        psStmt = sqlite3_mprintf("SELECT ConnID, RemoteHost FROM %s WHERE "
                        "ConnID = '%s' AND Username LIKE '%s' AND RemoteHost LIKE '%s';",                         "ConnID = '%q' AND Username LIKE '%q' AND RemoteHost LIKE '%q';", 
                         str, connid, user, host);                          str, connid, user, host);
   
        if (sqlite3_prepare_v2(sql, szStmt, strlen(szStmt), &stmt, NULL)) {        if (sqlite3_prepare_v2(sql, psStmt, strlen(psStmt), &stmt, NULL)) {
                 MQTT_RTLM_LOG(sql);                  MQTT_RTLM_LOG(sql);
                   sqlite3_free(psStmt);
                 return -1;                  return -1;
        }        } else
                 sqlite3_free(psStmt);
         if (sqlite3_step(stmt) == SQLITE_ROW)          if (sqlite3_step(stmt) == SQLITE_ROW)
                 ret = sqlite3_changes(sql);                  ret = sqlite3_changes(sql);
         else          else
Line 238  mqtt_rtlm_chk_session(cfg_root_t *cfg, sqlite3 *sql, c Line 244  mqtt_rtlm_chk_session(cfg_root_t *cfg, sqlite3 *sql, c
  * @msgid = MessageID   * @msgid = MessageID
  * @topic = topic   * @topic = topic
  * @txt = text   * @txt = text
    * @txtlen = text length
  * @user = username   * @user = username
  * @host = hostname   * @host = hostname
  * @retain = !=0 retain message to database   * @retain = !=0 retain message to database
Line 245  mqtt_rtlm_chk_session(cfg_root_t *cfg, sqlite3 *sql, c Line 252  mqtt_rtlm_chk_session(cfg_root_t *cfg, sqlite3 *sql, c
  */   */
 int  int
 mqtt_rtlm_write_topic(cfg_root_t *cfg, sqlite3 *sql, const char *connid, u_short msgid,   mqtt_rtlm_write_topic(cfg_root_t *cfg, sqlite3 *sql, const char *connid, u_short msgid, 
                const char *topic, const char *txt, const char *user, const char *host, char retain)                const char *topic, void *txt, int txtlen, const char *user, const char *host, char retain)
 {  {
         int ret = 0;          int ret = 0;
        char *str, szStmt[BUFSIZ] = { 0 };        char *str, *psStmt;
         sqlite3_stmt *stmt;          sqlite3_stmt *stmt;
   
         if (!cfg || !sql || !topic)          if (!cfg || !sql || !topic)
Line 259  mqtt_rtlm_write_topic(cfg_root_t *cfg, sqlite3 *sql, c Line 266  mqtt_rtlm_write_topic(cfg_root_t *cfg, sqlite3 *sql, c
                 mqtt_rtlm_log("Error:: not found topics table name");                  mqtt_rtlm_log("Error:: not found topics table name");
                 return -1;                  return -1;
         }          }
        snprintf(szStmt, sizeof szStmt, "INSERT INTO %s (Retain, ConnID, MsgID, Topic, Value, PubUser, "        psStmt = sqlite3_mprintf("INSERT INTO %s (Retain, ConnID, MsgID, Topic, Value, PubUser, "
                        "PubDate, PubHost) VALUES (%d, '%s', %d, '%s', '%s', '%s', "                        "PubDate, PubHost) VALUES (%d, '%q', %u, '%q', ?1, '%q', "
                        "datetime('now', 'localtime'), '%s');",                         "datetime('now', 'localtime'), '%q');", 
                         str, retain, connid, msgid, topic, txt, user, host);                          str, retain, connid, msgid, topic, txt, user, host);
   
        if (sqlite3_prepare_v2(sql, szStmt, strlen(szStmt), &stmt, NULL)) {        if (sqlite3_prepare_v2(sql, psStmt, strlen(psStmt), &stmt, NULL)) {
                 MQTT_RTLM_LOG(sql);                  MQTT_RTLM_LOG(sql);
                   sqlite3_free(psStmt);
                 return -1;                  return -1;
           } else
                   sqlite3_free(psStmt);
           if (sqlite3_bind_blob(stmt, 1, txt, txtlen, SQLITE_TRANSIENT)) {
                   MQTT_RTLM_LOG(sql);
                   sqlite3_finalize(stmt);
                   return -1;
         }          }
         if ((ret = sqlite3_step(stmt)) == SQLITE_DONE)          if ((ret = sqlite3_step(stmt)) == SQLITE_DONE)
                 ret = sqlite3_changes(sql);                  ret = sqlite3_changes(sql);
Line 294  int Line 308  int
 mqtt_rtlm_wipe_topic(cfg_root_t *cfg, sqlite3 *sql, const char *connid, const char *user, char retain)  mqtt_rtlm_wipe_topic(cfg_root_t *cfg, sqlite3 *sql, const char *connid, const char *user, char retain)
 {  {
         int ret = 0;          int ret = 0;
        char *str, *rtn, szStmt[BUFSIZ] = { 0 };        char *str, *rtn, *psStmt;
         sqlite3_stmt *stmt;          sqlite3_stmt *stmt;
   
         if (!cfg || !sql || !connid)          if (!cfg || !sql || !connid)
Line 316  mqtt_rtlm_wipe_topic(cfg_root_t *cfg, sqlite3 *sql, co Line 330  mqtt_rtlm_wipe_topic(cfg_root_t *cfg, sqlite3 *sql, co
                         rtn = "AND Retain != 0";                          rtn = "AND Retain != 0";
                         break;                          break;
         }          }
        snprintf(szStmt, sizeof szStmt, "DELETE FROM %s WHERE ConnID = '%s' AND "        psStmt = sqlite3_mprintf("DELETE FROM %s WHERE ConnID = '%q' AND "
                        "PubUser LIKE '%s' %s;", str, connid, user, rtn);                        "PubUser LIKE '%q' %s;", str, connid, user, rtn);
   
        if (sqlite3_prepare_v2(sql, szStmt, strlen(szStmt), &stmt, NULL)) {        if (sqlite3_prepare_v2(sql, psStmt, strlen(psStmt), &stmt, NULL)) {
                 MQTT_RTLM_LOG(sql);                  MQTT_RTLM_LOG(sql);
                   sqlite3_free(psStmt);
                 return -1;                  return -1;
        }        } else
                 sqlite3_free(psStmt);
         if ((ret = sqlite3_step(stmt)) == SQLITE_DONE)          if ((ret = sqlite3_step(stmt)) == SQLITE_DONE)
                 ret = sqlite3_changes(sql);                  ret = sqlite3_changes(sql);
         else {          else {
Line 353  mqtt_rtlm_delete_topic(cfg_root_t *cfg, sqlite3 *sql,  Line 369  mqtt_rtlm_delete_topic(cfg_root_t *cfg, sqlite3 *sql, 
                 const char *topic, const char *user, const char *host, char retain)                  const char *topic, const char *user, const char *host, char retain)
 {  {
         int ret = 0;          int ret = 0;
        char *str, *rtn, szStmt[BUFSIZ] = { 0 };        char *str, *rtn, *psStmt;
         sqlite3_stmt *stmt;          sqlite3_stmt *stmt;
   
         if (!cfg || !sql || !topic)          if (!cfg || !sql || !topic)
Line 375  mqtt_rtlm_delete_topic(cfg_root_t *cfg, sqlite3 *sql,  Line 391  mqtt_rtlm_delete_topic(cfg_root_t *cfg, sqlite3 *sql, 
                         rtn = "AND Retain != 0";                          rtn = "AND Retain != 0";
                         break;                          break;
         }          }
        snprintf(szStmt, sizeof szStmt, "DELETE FROM %s WHERE ConnID = '%s' AND MsgID = %d AND "        psStmt = sqlite3_mprintf("DELETE FROM %s WHERE ConnID = '%q' AND MsgID = %d AND "
                        "Topic LIKE '%s' AND PubUser LIKE '%s' AND PubHost LIKE '%s' %s;", str,                         "Topic LIKE '%q' AND PubUser LIKE '%q' AND PubHost LIKE '%q' %s;", str, 
                         connid, msgid, topic, user, host, rtn);                          connid, msgid, topic, user, host, rtn);
   
        if (sqlite3_prepare_v2(sql, szStmt, strlen(szStmt), &stmt, NULL)) {        if (sqlite3_prepare_v2(sql, psStmt, strlen(psStmt), &stmt, NULL)) {
                 MQTT_RTLM_LOG(sql);                  MQTT_RTLM_LOG(sql);
                   sqlite3_free(psStmt);
                 return -1;                  return -1;
        }        } else
                 sqlite3_free(psStmt);
         if ((ret = sqlite3_step(stmt)) == SQLITE_DONE)          if ((ret = sqlite3_step(stmt)) == SQLITE_DONE)
                 ret = sqlite3_changes(sql);                  ret = sqlite3_changes(sql);
         else {          else {
Line 411  mqtt_rtlm_read_topic(cfg_root_t *cfg, sqlite3 *sql, co Line 429  mqtt_rtlm_read_topic(cfg_root_t *cfg, sqlite3 *sql, co
                 const char *topic, char retain)                  const char *topic, char retain)
 {  {
         int rowz = 0;          int rowz = 0;
        char *str, szStr[STRSIZ], szStmt[BUFSIZ] = { 0 };        char *str, szStr[STRSIZ], *psStmt;
         sqlite3_stmt *stmt;          sqlite3_stmt *stmt;
         register int j;          register int j;
         mqtt_subscr_t *s = NULL;          mqtt_subscr_t *s = NULL;
           ait_val_t v;
   
         if (!cfg || !sql || !topic)          if (!cfg || !sql || !topic)
                 return NULL;                  return NULL;
Line 436  mqtt_rtlm_read_topic(cfg_root_t *cfg, sqlite3 *sql, co Line 455  mqtt_rtlm_read_topic(cfg_root_t *cfg, sqlite3 *sql, co
                 mqtt_rtlm_log("Error:: not found topics table name");                  mqtt_rtlm_log("Error:: not found topics table name");
                 return NULL;                  return NULL;
         }          }
        snprintf(szStmt, sizeof szStmt, "SELECT Retain, Topic, Value FROM %s WHERE "        psStmt = sqlite3_mprintf("SELECT Retain, Topic, Value FROM %s WHERE "
                        "ConnID = '%s' AND MsgID = %d AND Topic LIKE '%s' %s;",                         "ConnID = '%q' AND MsgID = %d AND Topic LIKE '%q' %s;", 
                         str, connid, msgid, topic, szStr);                          str, connid, msgid, topic, szStr);
   
        if (sqlite3_prepare_v2(sql, szStmt, strlen(szStmt), &stmt, NULL)) {        if (sqlite3_prepare_v2(sql, psStmt, strlen(psStmt), &stmt, NULL)) {
                 MQTT_RTLM_LOG(sql);                  MQTT_RTLM_LOG(sql);
                   sqlite3_free(psStmt);
                 return NULL;                  return NULL;
        }        } else
                 sqlite3_free(psStmt);
   
         /* calculate count of rows and allocate subscribe items */          /* calculate count of rows and allocate subscribe items */
         while (sqlite3_step(stmt) == SQLITE_ROW)          while (sqlite3_step(stmt) == SQLITE_ROW)
Line 460  mqtt_rtlm_read_topic(cfg_root_t *cfg, sqlite3 *sql, co Line 481  mqtt_rtlm_read_topic(cfg_root_t *cfg, sqlite3 *sql, co
                 s[j].sub_ret = (char) sqlite3_column_int(stmt, 0);                  s[j].sub_ret = (char) sqlite3_column_int(stmt, 0);
                 s[j].sub_topic.msg_base = (u_char*) io_strdup((char*) sqlite3_column_text(stmt, 1));                  s[j].sub_topic.msg_base = (u_char*) io_strdup((char*) sqlite3_column_text(stmt, 1));
                 s[j].sub_topic.msg_len = strlen((char*) s[j].sub_topic.msg_base);                  s[j].sub_topic.msg_len = strlen((char*) s[j].sub_topic.msg_base);
                s[j].sub_value.msg_base = (u_char*) io_strdup((char*) sqlite3_column_text(stmt, 2));                AIT_SET_PTR(&v, (void*) sqlite3_column_blob(stmt, 2), sqlite3_column_bytes(stmt, 2));
                s[j].sub_value.msg_len = strlen((char*) s[j].sub_value.msg_base);                s[j].sub_value.msg_len = AIT_LEN(&v);
                 s[j].sub_value.msg_base = (u_char*) io_malloc(s[j].sub_value.msg_len);
                 if (s[j].sub_value.msg_base)
                         memcpy(s[j].sub_value.msg_base, AIT_GET_PTR(&v), s[j].sub_value.msg_len);
         }          }
 end:  end:
         sqlite3_finalize(stmt);          sqlite3_finalize(stmt);
Line 487  mqtt_rtlm_write_subscribe(cfg_root_t *cfg, sqlite3 *sq Line 511  mqtt_rtlm_write_subscribe(cfg_root_t *cfg, sqlite3 *sq
                 const char *topic, const char *user, const char *host, char qos)                  const char *topic, const char *user, const char *host, char qos)
 {  {
         int ret = 0;          int ret = 0;
        char *str, szStmt[BUFSIZ] = { 0 };        char *str, *psStmt;
         sqlite3_stmt *stmt;          sqlite3_stmt *stmt;
   
         if (!cfg || !sql || !topic)          if (!cfg || !sql || !topic)
Line 498  mqtt_rtlm_write_subscribe(cfg_root_t *cfg, sqlite3 *sq Line 522  mqtt_rtlm_write_subscribe(cfg_root_t *cfg, sqlite3 *sq
                 mqtt_rtlm_log("Error:: not found subscribes table name");                  mqtt_rtlm_log("Error:: not found subscribes table name");
                 return -1;                  return -1;
         }          }
        snprintf(szStmt, sizeof szStmt, "INSERT INTO %s (ConnID, MsgID, QoS, Topic, PubUser, "        psStmt = sqlite3_mprintf("INSERT INTO %s (ConnID, MsgID, QoS, Topic, PubUser, "
                        "PubDate, PubHost) VALUES ('%s', %d, %d, '%s', '%s', "                        "PubDate, PubHost) VALUES ('%q', %d, %d, '%q', '%q', "
                        "datetime('now', 'localtime'), '%s');", str,                         "datetime('now', 'localtime'), '%q');", str, 
                         connid, msgid, qos, topic, user, host);                          connid, msgid, qos, topic, user, host);
   
        if (sqlite3_prepare_v2(sql, szStmt, strlen(szStmt), &stmt, NULL)) {        if (sqlite3_prepare_v2(sql, psStmt, strlen(psStmt), &stmt, NULL)) {
                 MQTT_RTLM_LOG(sql);                  MQTT_RTLM_LOG(sql);
                   sqlite3_free(psStmt);
                 return -1;                  return -1;
        }        } else
                 sqlite3_free(psStmt);
         if ((ret = sqlite3_step(stmt)) == SQLITE_DONE)          if ((ret = sqlite3_step(stmt)) == SQLITE_DONE)
                 ret = sqlite3_changes(sql);                  ret = sqlite3_changes(sql);
         else {          else {
Line 535  mqtt_rtlm_delete_subscribe(cfg_root_t *cfg, sqlite3 *s Line 561  mqtt_rtlm_delete_subscribe(cfg_root_t *cfg, sqlite3 *s
                 const char *topic, const char *user, const char *host)                  const char *topic, const char *user, const char *host)
 {  {
         int ret = 0;          int ret = 0;
        char *str, szStmt[BUFSIZ] = { 0 };        char *str, *psStmt;
         sqlite3_stmt *stmt;          sqlite3_stmt *stmt;
   
         if (!cfg || !sql || !topic)          if (!cfg || !sql || !topic)
Line 546  mqtt_rtlm_delete_subscribe(cfg_root_t *cfg, sqlite3 *s Line 572  mqtt_rtlm_delete_subscribe(cfg_root_t *cfg, sqlite3 *s
                 mqtt_rtlm_log("Error:: not found subscribes table name");                  mqtt_rtlm_log("Error:: not found subscribes table name");
                 return -1;                  return -1;
         }          }
        snprintf(szStmt, sizeof szStmt, "DELETE FROM %s WHERE ConnID = '%s' AND "        psStmt = sqlite3_mprintf("DELETE FROM %s WHERE ConnID = '%q' AND "
                        "Topic LIKE '%s' AND PubUser LIKE '%s' AND PubHost LIKE '%s';", str,                         "Topic LIKE '%q' AND PubUser LIKE '%q' AND PubHost LIKE '%q';", str, 
                         connid, topic, user, host);                          connid, topic, user, host);
   
        if (sqlite3_prepare_v2(sql, szStmt, strlen(szStmt), &stmt, NULL)) {        if (sqlite3_prepare_v2(sql, psStmt, strlen(psStmt), &stmt, NULL)) {
                 MQTT_RTLM_LOG(sql);                  MQTT_RTLM_LOG(sql);
                   sqlite3_free(psStmt);
                 return -1;                  return -1;
        }        } else
                 sqlite3_free(psStmt);
         if ((ret = sqlite3_step(stmt)) == SQLITE_DONE)          if ((ret = sqlite3_step(stmt)) == SQLITE_DONE)
                 ret = sqlite3_changes(sql);                  ret = sqlite3_changes(sql);
         else {          else {
Line 579  mqtt_subscr_t * Line 607  mqtt_subscr_t *
 mqtt_rtlm_read_subscribe(cfg_root_t *cfg, sqlite3 *sql, const char *connid, const char *topic)  mqtt_rtlm_read_subscribe(cfg_root_t *cfg, sqlite3 *sql, const char *connid, const char *topic)
 {  {
         int rowz = 0;          int rowz = 0;
        char *str, szStmt[BUFSIZ] = { 0 };        char *str, *psStmt;
         sqlite3_stmt *stmt;          sqlite3_stmt *stmt;
         register int j;          register int j;
         mqtt_subscr_t *s = NULL;          mqtt_subscr_t *s = NULL;
Line 592  mqtt_rtlm_read_subscribe(cfg_root_t *cfg, sqlite3 *sql Line 620  mqtt_rtlm_read_subscribe(cfg_root_t *cfg, sqlite3 *sql
                 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 ConnID = '%s' AND "        psStmt = sqlite3_mprintf("SELECT QoS, Topic FROM %s WHERE ConnID = '%q' AND "
                        "Topic LIKE '%s';", str, connid, topic);                        "Topic LIKE '%q';", str, connid, topic);
   
        if (sqlite3_prepare_v2(sql, szStmt, strlen(szStmt), &stmt, NULL)) {        if (sqlite3_prepare_v2(sql, psStmt, strlen(psStmt), &stmt, NULL)) {
                 MQTT_RTLM_LOG(sql);                  MQTT_RTLM_LOG(sql);
                   sqlite3_free(psStmt);
                 return NULL;                  return NULL;
        }        } else
                 sqlite3_free(psStmt);
   
         /* calculate count of rows and allocate subscribe items */          /* calculate count of rows and allocate subscribe items */
         while (sqlite3_step(stmt) == SQLITE_ROW)          while (sqlite3_step(stmt) == SQLITE_ROW)
Removed from v.1.2.2.10  
changed lines
  Added in v.1.2.2.11

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