mqtt/src/accmqtt.c - diff

Return to accmqtt.c CVS log

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

version 1.2.2.1, 2012/04/11 15:08:27	version 1.2.2.5, 2012/05/27 10:12:48
Line 20 mqtt_rtlm_log(const char *fmt, ...)	Line 20 mqtt_rtlm_log(const char *fmt, ...)
vsyslog(LOG_ERR, fmt, lst);	vsyslog(LOG_ERR, fmt, lst);
va_end(lst);	va_end(lst);
}	}
#define MQTT_RTLM_LOG(_sql) (assert((_sql)), mqtt_rtlm_log("Error:: SQL #%d - %s", \	#define MQTT_RTLM_LOG(_sql) (assert((_sql)), mqtt_rtlm_log("Error:: %s(%d) SQL #%d - %s", \
	__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 39 mqtt_rtlm_open(cfg_root_t *cfg)	Line 53 mqtt_rtlm_open(cfg_root_t *cfg)
if (!cfg)	if (!cfg)
return NULL;	return NULL;

if (!sqlite3_threadsafe() \|\| sqlite3_config(SQLITE_CONFIG_SERIALIZED))
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 59 mqtt_rtlm_open(cfg_root_t *cfg)	Line 70 mqtt_rtlm_open(cfg_root_t *cfg)
sqlite3_close(sql);	sqlite3_close(sql);
return NULL;	return NULL;
}	}

return sql;	return sql;
}	}