mqtt/example/cmds.c - diff

Return to cmds.c CVS log

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

version 1.1.2.17, 2011/12/09 09:53:54	version 1.1.2.18, 2011/12/09 11:46:48
Line 11 main()	Line 11 main()
mqtt_msg_t *m;	mqtt_msg_t *m;
mqtt_subscr_t s[4], *ss;	mqtt_subscr_t s[4], *ss;
mqtthdr_connflgs_t flg;	mqtthdr_connflgs_t flg;
	mqtthdr_connack_t cack;
u_short ka, msgID;	u_short ka, msgID;
int i, len;	int i, len;
char cid[BUFSIZ], user[BUFSIZ], pass[BUFSIZ], topic[BUFSIZ], message[BUFSIZ], t, msg;	char cid[BUFSIZ], user[BUFSIZ], pass[BUFSIZ], topic[BUFSIZ], message[BUFSIZ], t, msg;
Line 23 main()	Line 24 main()
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]);
t = msg = NULL;	t = msg = NULL;
flg = mqtt_readCONNECT(m, &ka, cid, sizeof cid, user, sizeof user, pass, sizeof pass, &t, &msg);	cack = mqtt_readCONNECT(m, &ka, cid, sizeof cid, user, sizeof user, pass, sizeof pass, &t, &msg);
printf("read connect flags:: clean=%d will=%d qos=%d retain=%d pass=%d user=%d\n",	flg.flags = cack.reserved;
	printf("read connect %d flags:: clean=%d will=%d qos=%d retain=%d pass=%d user=%d\n", cack.retcode,
flg.clean_sess, flg.will_flg, flg.will_qos, flg.will_retain, flg.password, flg.username);	flg.clean_sess, flg.will_flg, flg.will_qos, flg.will_retain, flg.password, flg.username);
if (flg.reserved) {	if (flg.reserved) {
printf("Error:: mqtt_readCONNECT() #%d - %s\n", mqtt_GetErrno(), mqtt_GetError());	printf("Error:: mqtt_readCONNECT() #%d - %s\n", mqtt_GetErrno(), mqtt_GetError());