mqtt/src/mqtt_subs.c - diff

Return to mqtt_subs.c CVS log

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

version 1.2, 2012/01/27 15:05:38	version 1.2.2.2, 2012/04/24 13:54:50
Line 7	Line 7
io_enableDEBUG;	io_enableDEBUG;

extern char compiled[], compiledby[], compilehost[];	extern char compiled[], compiledby[], compilehost[];
intptr_t Kill;	volatile intptr_t Kill;

struct tagArgs *args;	struct tagArgs *args;

Line 181 main(int argc, char **argv)	Line 181 main(int argc, char **argv)
Usage();	Usage();
return 1;	return 1;
}	}
ioVERBOSE(1) printf("Connecting to %s:%d ...\n", io_n2addr(&args->addr, &val), io_n2port(&args->addr));	printf("Connecting to %s:%d ... ", io_n2addr(&args->addr, &val), io_n2port(&args->addr));
	AIT_FREE_VAL(&val);

if ((sock = InitClient()) == -1) {	if ((sock = InitClient()) == -1) {
args->free(args);	args->free(args);
Line 189 main(int argc, char **argv)	Line 190 main(int argc, char **argv)
return 2;	return 2;
}	}

printf("Connected ... ");
switch ((ret = ConnectClient(sock))) {	switch ((ret = ConnectClient(sock))) {
case -1:	case -1:
printf(">> FAILED!\n");	printf(">> FAILED!\n");
Line 222 main(int argc, char **argv)	Line 222 main(int argc, char **argv)
if (lf) {	if (lf) {
ret = Subscribe(sock, lf);	ret = Subscribe(sock, lf);
fclose(lf);	fclose(lf);
shutdown(sock, SHUT_RDWR);
} else	} else
printf("Error:: in subscribe file #%d - %s\n", errno, strerror(errno));	printf("Error:: in subscribe file #%d - %s\n", errno, strerror(errno));
CloseClient(sock);	CloseClient(sock);