mqtt/example/cmds.c - diff

Return to cmds.c CVS log

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

Diff for /mqtt/example/Attic/cmds.c between versions 1.1.2.15 and 1.1.2.16

version 1.1.2.15, 2011/12/06 10:33:37	version 1.1.2.16, 2011/12/06 12:36:45
Line 1	Line 1
#include <stdio.h>	#include <stdio.h>
	#include <stdlib.h>
#include <string.h>	#include <string.h>
#include <sys/types.h>	#include <sys/types.h>
#include <aitmqtt.h>	#include <aitmqtt.h>
Line 14 main()	Line 15 main()
int i, len;	int i, len;
char cid[BUFSIZ], user[BUFSIZ], pass[BUFSIZ], topic[BUFSIZ], message[BUFSIZ];	char cid[BUFSIZ], user[BUFSIZ], pass[BUFSIZ], topic[BUFSIZ], message[BUFSIZ];
struct mqtthdr *hdr;	struct mqtthdr *hdr;
	u_char *qoses;

m = mqtt_msgAlloc(0);	m = mqtt_msgAlloc(0);
/* conn* */	/* conn* */
Line 93 main()	Line 95 main()
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]);
	printf("read suback=%d\n", (len = mqtt_readSUBACK(m, &msgID, &qoses)));
	for (i = 0; i < len; i++)
	printf(" >>> QoS=%d\n", qoses[i]);
	free(qoses);
printf("unsubscribe=%d/%d\n", m->msg_len, mqtt_msgUNSUBSCRIBE(m, s, 10, 0, 1));	printf("unsubscribe=%d/%d\n", m->msg_len, mqtt_msgUNSUBSCRIBE(m, s, 10, 0, 1));
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_readUNSUBSCRIBE(m, &msgID, &ss);
	if (!hdr) {
	printf("Error:: mqtt_readUNSUBSCRIBE() #%d - %s\n", mqtt_GetErrno(), mqtt_GetError());
	return 3;
	}
	printf("read unsubscribe: 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(" >>> Topic(%d)=%s\n", ss[i].sub_topic._size, ss[i].sub_topic._base);
	mqtt_subFree(&ss);
printf("unsuback=%d/%d\n", m->msg_len, mqtt_msgUNSUBACK(m, 10));	printf("unsuback=%d/%d\n", m->msg_len, mqtt_msgUNSUBACK(m, 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]);

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

Removed from v.1.1.2.15
changed lines
	Added in v.1.1.2.16