mqtt/src/pubmqtt.c - diff

Return to pubmqtt.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / mqtt / src

version 1.2, 2012/01/27 15:05:38	version 1.2.2.1, 2012/01/27 15:18:12
Line 390 mqtt_rtlm_read_topic(sl_config cfg, sqlite3 sql, u_s	Line 390 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 = (u_char) strdup((char) sqlite3_column_text(stmt, 1));	s[j].sub_topic.msg_base = (u_char) strdup((char) sqlite3_column_text(stmt, 1));
s[j].sub_topic._size = strlen((char*) s[j].sub_topic._base);	s[j].sub_topic.msg_len = strlen((char*) s[j].sub_topic.msg_base);
s[j].sub_value._base = (u_char) strdup((char) sqlite3_column_text(stmt, 2));	s[j].sub_value.msg_base = (u_char) strdup((char) sqlite3_column_text(stmt, 2));
s[j].sub_value._size = strlen((char*) s[j].sub_value._base);	s[j].sub_value.msg_len = strlen((char*) s[j].sub_value.msg_base);
}	}
end:	end:
sqlite3_finalize(stmt);	sqlite3_finalize(stmt);