version 1.1.2.14, 2011/12/08 17:02:25
|
version 1.1.2.16, 2011/12/14 12:45:30
|
Line 39 mqtt_rtlm_open(sl_config *cfg)
|
Line 39 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)) |
| return NULL; |
| */ |
|
|
str = (const char*) cfg_GetAttribute(cfg, CFG("mqtt_pub"), CFG("name")); |
str = (const char*) cfg_GetAttribute(cfg, CFG("mqtt_pub"), CFG("name")); |
if (!str) { |
if (!str) { |
Line 388 mqtt_rtlm_read_topic(sl_config *cfg, sqlite3 *sql, u_s
|
Line 391 mqtt_rtlm_read_topic(sl_config *cfg, sqlite3 *sql, u_s
|
/* fill with data */ |
/* fill with data */ |
for (j = 0; j < rowz && sqlite3_step(stmt) == SQLITE_ROW; j++) { |
for (j = 0; j < rowz && sqlite3_step(stmt) == SQLITE_ROW; j++) { |
s[j].sub_ret = (char) sqlite3_column_int(stmt, 0); |
s[j].sub_ret = (char) sqlite3_column_int(stmt, 0); |
s[j].sub_topic._base = strdup(sqlite3_column_text(stmt, 1)); | s[j].sub_topic._base = (u_char*) strdup((char*) sqlite3_column_text(stmt, 1)); |
s[j].sub_topic._size = strlen(s[j].sub_topic._base); | s[j].sub_topic._size = strlen((char*) s[j].sub_topic._base); |
s[j].sub_value._base = strdup(sqlite3_column_text(stmt, 2)); | s[j].sub_value._base = (u_char*) strdup((char*) sqlite3_column_text(stmt, 2)); |
s[j].sub_value._size = strlen(s[j].sub_value._base); | s[j].sub_value._size = strlen((char*) s[j].sub_value._base); |
} |
} |
end: |
end: |
sqlite3_finalize(stmt); |
sqlite3_finalize(stmt); |