mqtt/src/mqtt.c - diff - 1.1.1.1.2.12

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.9 and 1.1.1.1.2.12

version 1.1.1.1.2.9, 2011/11/23 14:51:14	version 1.1.1.1.2.12, 2011/11/24 13:57:12
Line 10 main(int argc, char **argv)	Line 10 main(int argc, char **argv)
{	{
sqlite3 acc = NULL, pub = NULL;	sqlite3 acc = NULL, pub = NULL;
FILE *logg = NULL;	FILE *logg = NULL;
	int ret = 0;

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());
Line 34 main(int argc, char **argv)	Line 35 main(int argc, char **argv)
return 2;	return 2;
}	}

acc = mqttOpenACC(&cfg);	acc = call.OpenACC(&cfg);
if (!acc)	if (!acc)
goto end;	goto end;
pub = mqttOpenPUB(&cfg);	pub = call.OpenPUB(&cfg);
if (!pub)	if (!pub)
goto end;	goto end;
logg = mqttOpenLOG(&cfg);	logg = call.OpenLOG(&cfg);
if (!logg)	if (!logg)
goto end;	goto end;

Line 49 main(int argc, char **argv)	Line 50 main(int argc, char **argv)
goto end;	goto end;
}	}

printf("success!\n");	call.LOG(logg, "success!\n");
	if ((ret = call.LoginACC(&cfg, acc, "misho", "test123")) == -1) {
	printf("Error:: Authentication problem\n");
	goto end;
	} else
	call.LOG(logg, "Login: %s\n", ret ? "ALLOW" : "DENIED");

	if ((ret = call.InitSessPUB(&cfg, pub, "misho", "127.0.0.1", 12345)) == -1) {
	printf("Error:: Session problem\n");
	goto end;
	} else
	call.LOG(logg, "InitSess: %d\n", ret);

end:	end:
mqttCloseLOG(logg);	call.CloseLOG(logg);
mqttClosePUB(pub);	call.ClosePUB(pub);
mqttCloseACC(acc);	call.CloseACC(acc);
mqttUnloadRTLM(2);	mqttUnloadRTLM(2);
mqttUnloadRTLM(1);	mqttUnloadRTLM(1);
mqttUnloadRTLM(0);	mqttUnloadRTLM(0);

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

Removed from v.1.1.1.1.2.9
changed lines
	Added in v.1.1.1.1.2.12