mqtt/example/cmds.c - diff

Return to cmds.c CVS log

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

version 1.1.2.14, 2011/12/06 09:04:55	version 1.1.2.15, 2011/12/06 10:33:37
Line 8 int	Line 8 int
main()	main()
{	{
mqtt_msg_t *m;	mqtt_msg_t *m;
mqtt_subscr_t s[4];	mqtt_subscr_t s[4], *ss;
mqtthdr_connflgs_t flg;	mqtthdr_connflgs_t flg;
u_short ka, msgID;	u_short ka, msgID;
int i, len;	int i, len;
Line 80 main()	Line 80 main()
printf("subscribe=%d/%d\n", m->msg_len, mqtt_msgSUBSCRIBE(m, s, 10, 0, 0));	printf("subscribe=%d/%d\n", m->msg_len, mqtt_msgSUBSCRIBE(m, s, 10, 0, 0));
for (i = 0; i < m->msg_len; i++)	for (i = 0; i < m->msg_len; i++)
printf("%d\n", ((u_char*) m->msg_base)[i]);	printf("%d\n", ((u_char*) m->msg_base)[i]);
	hdr = mqtt_readSUBSCRIBE(m, &msgID, &ss);
	if (!hdr) {
	printf("Error:: mqtt_readSUBSCRIBE() #%d - %s\n", mqtt_GetErrno(), mqtt_GetError());
	return 3;
	}
	printf("read subscribe: dup=%d qos=%d retain=%d\n", hdr->mqtt_msg.dup, hdr->mqtt_msg.qos, hdr->mqtt_msg.retain);
	printf("++> MessageID=%d\n", msgID);
	for (i = 0; ss[i].sub_topic._base; i++)
	printf(" >>> QoS=%d Topic(%d)=%s\n", ss[i].sub_ret, ss[i].sub_topic._size, ss[i].sub_topic._base);
	mqtt_subFree(&ss);
printf("suback=%d/%d\n", m->msg_len, mqtt_msgSUBACK(m, s, 10));	printf("suback=%d/%d\n", m->msg_len, mqtt_msgSUBACK(m, s, 10));
for (i = 0; i < m->msg_len; i++)	for (i = 0; i < m->msg_len; i++)
printf("%d\n", ((u_char*) m->msg_base)[i]);	printf("%d\n", ((u_char*) m->msg_base)[i]);