mqtt/src/mqtt.c - diff - 1.1.1.1.2.10

Return to mqtt.c CVS log

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

Diff for /mqtt/src/Attic/mqtt.c between versions 1.1.1.1.2.6 and 1.1.1.1.2.10

version 1.1.1.1.2.6, 2011/11/23 00:56:46	version 1.1.1.1.2.10, 2011/11/24 00:08:56
Line 9 int	Line 9 int
main(int argc, char **argv)	main(int argc, char **argv)
{	{
sqlite3 acc = NULL, pub = NULL;	sqlite3 acc = NULL, pub = NULL;
	FILE *logg = NULL;

if (LoadConfig("/etc/mqtt.conf", &cfg)) {	if (LoadConfig("/etc/mqtt.conf", &cfg)) {
printf("Error:: Load config #%d - %s\n", cfg_GetErrno(), cfg_GetError());	printf("Error:: Load config #%d - %s\n", cfg_GetErrno(), cfg_GetError());
return 1;	return 1;
}	}
if (!mqttLoadRTLM(&cfg, 0)) {	if (!mqttLoadRTLM(&cfg, 0)) {
printf("Error:: Can't load RTL module\n");	printf("Error:: Can't load RTL ACC module\n");
	UnloadConfig(&cfg);
return 2;	return 2;
}	}
	if (!mqttLoadRTLM(&cfg, 1)) {
	printf("Error:: Can't load RTL PUB module\n");
	mqttUnloadRTLM(0);
	UnloadConfig(&cfg);
	return 2;
	}
	if (!mqttLoadRTLM(&cfg, 2)) {
	printf("Error:: Can't load RTL LOG module\n");
	mqttUnloadRTLM(1);
	mqttUnloadRTLM(0);
	UnloadConfig(&cfg);
	return 2;
	}

acc = mqttOpenDB(&cfg, 0);	acc = call.OpenACC(&cfg);
if (!acc)	if (!acc)
goto end;	goto end;
pub = mqttOpenDB(&cfg, 1);	pub = call.OpenPUB(&cfg);
if (!pub)	if (!pub)
goto end;	goto end;
	logg = call.OpenLOG(&cfg);
	if (!logg)
	goto end;

printf("success!\n");	if (mqttMkDir(&cfg)) {
	printf("Error:: in statedir #%d - %s\n", errno, strerror(errno));
	goto end;
	}

	call.LOG(logg, "success!\n");

end:	end:
mqttCloseDB(pub);	call.CloseLOG(logg);
mqttCloseDB(acc);	call.ClosePUB(pub);
	call.CloseACC(acc);
	mqttUnloadRTLM(2);
	mqttUnloadRTLM(1);
mqttUnloadRTLM(0);	mqttUnloadRTLM(0);
UnloadConfig(&cfg);	UnloadConfig(&cfg);
return 0;	return 0;

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

Removed from v.1.1.1.1.2.6
changed lines
	Added in v.1.1.1.1.2.10