mqtt/src/accmqtt.c - diff

Return to accmqtt.c CVS log

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

Diff for /mqtt/src/accmqtt.c between versions 1.2.2.3 and 1.2.2.6

version 1.2.2.3, 2012/04/25 12:04:30	version 1.2.2.6, 2012/06/26 08:05:58
Line 24 mqtt_rtlm_log(const char *fmt, ...)	Line 24 mqtt_rtlm_log(const char *fmt, ...)
__func__, __LINE__, \	__func__, __LINE__, \
sqlite3_errcode((_sql)), sqlite3_errmsg((_sql))))	sqlite3_errcode((_sql)), sqlite3_errmsg((_sql))))

	/* library pre-loaded actions */
	void
	_init()
	{
	sqlite3_initialize();
	}

	void
	_fini()
	{
	sqlite3_shutdown();
	}


/*	/*
* mqtt_rtlm_open() Open database connection	* mqtt_rtlm_open() Open database connection
*	*
Line 40 mqtt_rtlm_open(cfg_root_t *cfg)	Line 53 mqtt_rtlm_open(cfg_root_t *cfg)
if (!cfg)	if (!cfg)
return NULL;	return NULL;

sqlite3_config(SQLITE_CONFIG_SERIALIZED);
if (!sqlite3_threadsafe())
return NULL;

str = (const char*) cfg_getAttribute(cfg, "mqtt_acc", "name");	str = (const char*) cfg_getAttribute(cfg, "mqtt_acc", "name");
if (!str) {	if (!str) {
mqtt_rtlm_log("Error:: Unknown database name ...\n");	mqtt_rtlm_log("Error:: Unknown database name ...\n");
Line 56 mqtt_rtlm_open(cfg_root_t *cfg)	Line 65 mqtt_rtlm_open(cfg_root_t *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 94 mqtt_rtlm_login(cfg_root_t cfg, sqlite3 sql, const c	Line 101 mqtt_rtlm_login(cfg_root_t cfg, sqlite3 sql, const c
/* insert into Users values (NULL, "", "", 1, strftime('%s','now')); */	/* insert into Users values (NULL, "", "", 1, strftime('%s','now')); */
int ret = 0;	int ret = 0;
sqlite3_stmt *stmt;	sqlite3_stmt *stmt;
char *str, szStmt[BUFSIZ] = { 0 };	char str, psStmt;

if (!sql)	if (!sql)
return -1;	return -1;
Line 104 mqtt_rtlm_login(cfg_root_t cfg, sqlite3 sql, const c	Line 111 mqtt_rtlm_login(cfg_root_t cfg, sqlite3 sql, const c
mqtt_rtlm_log("Error:: not found users table name");	mqtt_rtlm_log("Error:: not found users table name");
return -1;	return -1;
}	}
snprintf(szStmt, sizeof szStmt, "SELECT DISTINCT Username, Password, Access FROM %s "	psStmt = sqlite3_mprintf("SELECT DISTINCT Username, Password, Access FROM %s "
"WHERE Username = '%s' AND Password = '%s' AND Access > 0;", str, user, pass);	"WHERE Username = '%q' AND Password = '%q' AND Access > 0;", str, user, pass);

sqlite3_mutex_enter(sqlite3_db_mutex(sql));	if (sqlite3_prepare_v2(sql, psStmt, strlen(psStmt), &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));	sqlite3_free(psStmt);
return -1;	return -1;
}	} else
	sqlite3_free(psStmt);
while (sqlite3_step(stmt) == SQLITE_ROW) {	while (sqlite3_step(stmt) == SQLITE_ROW) {
if (sqlite3_data_count(stmt) < 1)	if (sqlite3_data_count(stmt) < 1)
ret = 0;	ret = 0;
Line 121 mqtt_rtlm_login(cfg_root_t cfg, sqlite3 sql, const c	Line 128 mqtt_rtlm_login(cfg_root_t cfg, sqlite3 sql, const c
break;	break;
}	}
sqlite3_finalize(stmt);	sqlite3_finalize(stmt);
sqlite3_mutex_leave(sqlite3_db_mutex(sql));

return ret;	return ret;
}	}

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

Removed from v.1.2.2.3
changed lines
	Added in v.1.2.2.6