mqtt/src/mqtt_subs.c - diff

Return to mqtt_subs.c CVS log

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

version 1.2.2.9, 2012/05/27 10:04:05	version 1.2.2.11, 2012/06/01 13:13:40
Line 56 Subscribe(int sock, FILE *lf)	Line 56 Subscribe(int sock, FILE *lf)
u_short mid;	u_short mid;
mqtt_subscr_t *sub;	mqtt_subscr_t *sub;

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

printf(" > Execute SUBSCRIBE request #%d ... ", mid);	printf(" > Execute SUBSCRIBE request #%d ... ", mid);
Line 80 Unsubscribe(int sock)	Line 84 Unsubscribe(int sock)
{	{
u_short mid;	u_short mid;

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

printf(" > Execute UNSUBSCRIBE request #%d ... ", mid);	printf(" > Execute UNSUBSCRIBE request #%d ... ", mid);
Line 173 main(int argc, char **argv)	Line 181 main(int argc, char **argv)
sub->sub_ret = (u_char) *str;	sub->sub_ret = (u_char) *str;
} else	} else
sub->sub_ret = (u_char) args->QoS;	sub->sub_ret = (u_char) args->QoS;
sub->sub_topic.msg_base = io_strdup(szStr);	sub->sub_topic.msg_base = strdup(szStr);
sub->sub_topic.msg_len = strlen(szStr);	sub->sub_topic.msg_len = strlen(szStr);
break;	break;
case 'q':	case 'q':