mqtt/src/mqtt.c - diff - 1.1.1.1.2.19

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.18 and 1.1.1.1.2.19

version 1.1.1.1.2.18, 2011/11/28 13:25:53	version 1.1.1.1.2.19, 2011/12/08 17:02:25
Line 58 main(int argc, char **argv)	Line 58 main(int argc, char **argv)
} else	} else
call.LOG(logg, "Login: %s\n", ret ? "ALLOW" : "DENIED");	call.LOG(logg, "Login: %s\n", ret ? "ALLOW" : "DENIED");

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

if ((ret = call.ChkSessPUB(&cfg, pub, "misho", "127.0._.%")) == -1) {	if ((ret = call.ChkSessPUB(&cfg, pub, "misho", "doophenschmerz", "127.0._.%")) == -1) {
printf("Error:: Session check problem\n");	printf("Error:: Session check problem\n");
goto end;	goto end;
} else	} else
call.LOG(logg, "ChkSess: %d\n", ret);	call.LOG(logg, "ChkSess: %d\n", ret);

if ((ret = call.DeletePUB(&cfg, pub, "%", "%", "%", -1)) == -1) {	if ((ret = call.DeletePUB(&cfg, pub, 10, "%", "%", "%", -1)) == -1) {
printf("Error:: Clear problem\n");	printf("Error:: Clear problem\n");
goto end;	goto end;
} else	} else
call.LOG(logg, "Clear: %d\n", ret);	call.LOG(logg, "Clear: %d\n", ret);

if ((ret = call.WritePUB(&cfg, pub, "oho/boho", "MRYN \n tryn brymbryn", "misho", "1.1.1.1", 1)) == -1) {	if ((ret = call.WritePUB(&cfg, pub, 10, "oho/boho", "MRYN \n tryn brymbryn", "misho", "1.1.1.1", 1)) == -1) {
printf("Error:: Publish problem\n");	printf("Error:: Publish problem\n");
goto end;	goto end;
} else	} else
call.LOG(logg, "Publish: %d\n", ret);	call.LOG(logg, "Publish: %d\n", ret);
if ((ret = call.WritePUB(&cfg, pub, "boh", "testing", "misho", "1.1.1.2", 0)) == -1) {	if ((ret = call.WritePUB(&cfg, pub, 11, "boh", "testing", "misho", "1.1.1.2", 0)) == -1) {
printf("Error:: Publish problem\n");	printf("Error:: Publish problem\n");
goto end;	goto end;
} else	} else
call.LOG(logg, "Publish: %d\n", ret);	call.LOG(logg, "Publish: %d\n", ret);
if (!(s = call.ReadPUB(&cfg, pub, "%", -1))) {	if (!(s = call.ReadPUB(&cfg, pub, 10, "%", -1))) {
printf("Error:: Subscribe problem\n");	printf("Error:: Subscribe problem\n");
goto end;	goto end;
} else {	} else {
Line 98 main(int argc, char **argv)	Line 99 main(int argc, char **argv)
}	}
mqtt_subFree(&s);	mqtt_subFree(&s);
}	}
if ((ret = call.DeletePUB(&cfg, pub, "boh", "misho", "1.1.1._", 0)) == -1) {	if ((ret = call.DeletePUB(&cfg, pub, 11, "boh", "misho", "1.1.1._", 0)) == -1) {
printf("Error:: Delete problem\n");	printf("Error:: Delete problem\n");
goto end;	goto end;
} else	} else
call.LOG(logg, "Delete: %d\n", ret);	call.LOG(logg, "Delete: %d\n", ret);

if ((ret = call.FiniSessPUB(&cfg, pub, "misho", "127.0._.1%")) == -1) {	if ((ret = call.FiniSessPUB(&cfg, pub, "misho", "doophenschmerz", "127.0._.1%")) == -1) {
printf("Error:: Session fini problem\n");	printf("Error:: Session fini problem\n");
goto end;	goto end;
} else	} else

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

Removed from v.1.1.1.1.2.18
changed lines
	Added in v.1.1.1.1.2.19