mqtt/src/mqtt_subs.c - diff

Return to mqtt_subs.c CVS log

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

version 1.1.2.1, 2011/12/20 16:04:34	version 1.2.2.1, 2012/02/01 16:18:04
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 = try2Connect(sock))) {
case -1:	case -1:
printf(">> FAILED!\n");	printf(">> FAILED!\n");
break;	break;
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));
} else	CloseClient(sock);
	} else {
	close(sock);
ret = 3;	ret = 3;
	}

close(sock);
args->free(args);	args->free(args);
free(args);	free(args);
return ret;	return ret;