mqtt/src/mqtt_pub.c - diff

Return to mqtt_pub.c CVS log

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

Diff for /mqtt/src/mqtt_pub.c between versions 1.1.2.3 and 1.3

version 1.1.2.3, 2011/12/24 17:30:29	version 1.3, 2012/07/03 09:02:50
Line 49 cleanArgs(struct tagArgs * __restrict args)	Line 49 cleanArgs(struct tagArgs * __restrict args)
static int	static int
Publish(int sock)	Publish(int sock)
{	{
return 0;	int siz = 0;
	u_short mid = 0;

	#ifdef __NetBSD__
	srandom(getpid() ^ time(NULL));
	#else
	srandomdev();
	#endif
	mid = random() % USHRT_MAX;

	printf(" > Execute PUBLISH request #%d ... ", mid);
	siz = mqtt_cli_Publish(args->cli, mid, args->Dup, args->QoS, args->Retain,
	AIT_GET_STR(&args->Publish), AIT_ADDR(&args->Value), AIT_LEN(&args->Value));
	if (siz == -1) {
	printf("Error:: Publish #%d - %s\n", mqtt_GetErrno(), mqtt_GetError());
	return -1;
	} else
	printf("Sended %d bytes \n", siz);

	return siz;
}	}


Line 59 main(int argc, char **argv)	Line 78 main(int argc, char **argv)
char ch;	char ch;
ait_val_t val;	ait_val_t val;
u_short port = atoi(MQTT_PORT);	u_short port = atoi(MQTT_PORT);
int sock, ret = 0;	int ret = 0;

if (!(args = malloc(sizeof(struct tagArgs)))) {	if (!(args = io_malloc(sizeof(struct tagArgs)))) {
printf("Error:: in alloc arguments #%d - %s\n", errno, strerror(errno));	printf("Error:: in alloc arguments #%d - %s\n", errno, strerror(errno));
return 1;	return 1;
} else	} else
Line 71 main(int argc, char **argv)	Line 90 main(int argc, char **argv)
if (!(args->msg = mqtt_msgAlloc(USHRT_MAX))) {	if (!(args->msg = mqtt_msgAlloc(USHRT_MAX))) {
printf("Error:: in mqtt buffer #%d - %s\n", mqtt_GetErrno(), mqtt_GetError());	printf("Error:: in mqtt buffer #%d - %s\n", mqtt_GetErrno(), mqtt_GetError());
args->free(args);	args->free(args);
free(args);	io_free(args);
return 1;	return 1;
}	}

Line 109 main(int argc, char **argv)	Line 128 main(int argc, char **argv)
if (args->QoS > MQTT_QOS_EXACTLY) {	if (args->QoS > MQTT_QOS_EXACTLY) {
printf("Error:: invalid QoS level %d\n", args->QoS);	printf("Error:: invalid QoS level %d\n", args->QoS);
args->free(args);	args->free(args);
free(args);	io_free(args);
return 1;	return 1;
}	}
break;	break;
Line 131 main(int argc, char **argv)	Line 150 main(int argc, char **argv)
case 'h':	case 'h':
default:	default:
args->free(args);	args->free(args);
free(args);	io_free(args);
Usage();	Usage();
return 1;	return 1;
}	}
Line 140 main(int argc, char **argv)	Line 159 main(int argc, char **argv)
if (argc < 4) {	if (argc < 4) {
printf("Error:: host for connect not found, connection id, topic or value not supplied!\n\n");	printf("Error:: host for connect not found, connection id, topic or value not supplied!\n\n");
args->free(args);	args->free(args);
free(args);	io_free(args);
Usage();	Usage();
return 1;	return 1;
} else {	} else {
Line 154 main(int argc, char **argv)	Line 173 main(int argc, char **argv)
if (!io_gethostbyname(*argv, port, &args->addr)) {	if (!io_gethostbyname(*argv, port, &args->addr)) {
printf("Error:: host not valid #%d - %s\n", io_GetErrno(), io_GetError());	printf("Error:: host not valid #%d - %s\n", io_GetErrno(), io_GetError());
args->free(args);	args->free(args);
free(args);	io_free(args);
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 (!(args->cli = mqtt_cli_Open(&args->addr.sa, args->ka))) {
args->free(args);	args->free(args);
free(args);	io_free(args);
return 2;	return 2;
}	}

printf("Connected ... ");	if (args->isFile && !OpenFile()) {
switch ((ret = ConnectClient(sock))) {	mqtt_cli_Close(&args->cli);
	args->free(args);
	io_free(args);
	return 3;
	}

	switch ((ret = ConnectClient(args->cli->sock))) {
case -1:	case -1:
printf(">> FAILED!\n");	printf(">> FAILED!\n");
break;	break;
Line 192 main(int argc, char **argv)	Line 218 main(int argc, char **argv)
}	}

if (ret == MQTT_RETCODE_ACCEPTED) {	if (ret == MQTT_RETCODE_ACCEPTED) {
ret = Publish(sock);	ret = (Publish(args->cli->sock) == -1);
shutdown(sock, SHUT_RDWR);	} else
CloseClient(sock);	ret = 4;
} else {
close(sock);
ret = 3;
}

	mqtt_cli_Close(&args->cli);

	CloseFile();
args->free(args);	args->free(args);
free(args);	io_free(args);
return ret;	return ret;
}	}

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

Removed from v.1.1.2.3
changed lines
	Added in v.1.3