mqtt/src/pubmqtt.c - diff

Return to pubmqtt.c CVS log

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

version 1.1.2.11, 2011/11/28 13:25:53	version 1.1.2.12, 2011/11/28 22:28:08
Line 1	Line 1
#include "global.h"	#include "global.h"


	extern const char sql_schema[];


/*	/*
* mqtt_db_log() Log database connection message	* mqtt_db_log() Log database connection message
*	*
Line 36 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);

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) {
mqtt_rtlm_log("Error:: Unknown database name ...\n");	mqtt_rtlm_log("Error:: Unknown database name ...\n");
Line 48 mqtt_rtlm_open(sl_config *cfg)	Line 53 mqtt_rtlm_open(sl_config *cfg)
return NULL;	return NULL;
}	}

	if (sqlite3_exec(sql, sql_schema, NULL, NULL, NULL)) {
	MQTT_RTLM_LOG(sql);
	sqlite3_close(sql);
	return NULL;
	}
return sql;	return sql;
}	}