mqtt/src/pubmqtt.c - diff - 1.2.2.1

Return to pubmqtt.c CVS log

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

Diff for /mqtt/src/pubmqtt.c between versions 1.1.2.17 and 1.2.2.1

version 1.1.2.17, 2011/12/16 02:09:20	version 1.2.2.1, 2012/01/27 15:18:12
Line 160 mqtt_rtlm_fini_session(sl_config cfg, sqlite3 sql, c	Line 160 mqtt_rtlm_fini_session(sl_config cfg, sqlite3 sql, c
return -1;	return -1;
}	}
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, user, connid, host);	"AND RemoteHost LIKE '%s';", str, connid, user, host);

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);
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);

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