mqtt/src/mqttd_calls.c - diff

Return to mqttd_calls.c CVS log

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

version 1.2.2.26, 2012/06/26 08:05:58	version 1.2.2.27, 2012/06/26 13:43:59
Line 103 pubAck(struct tagSession sess, u_short mid, char __	Line 103 pubAck(struct tagSession sess, u_short mid, char __
hdr = (struct mqtthdr*) sess->sess_buf->msg_base;	hdr = (struct mqtthdr*) sess->sess_buf->msg_base;

/* write topic to database */	/* write topic to database */
	call.DeletePUB_topic(&cfg, pub, sess->sess_cid, mid, psTopic, sess->sess_user,
	sess->sess_addr, hdr->mqtt_msg.retain);
call.WritePUB_topic(&cfg, pub, sess->sess_cid, mid, psTopic, AIT_GET_BUF(p), AIT_LEN(p),	call.WritePUB_topic(&cfg, pub, sess->sess_cid, mid, psTopic, AIT_GET_BUF(p), AIT_LEN(p),
sess->sess_user, sess->sess_addr, hdr->mqtt_msg.retain);	sess->sess_user, sess->sess_addr, hdr->mqtt_msg.qos, hdr->mqtt_msg.retain);

TAILQ_FOREACH(s, &Sessions, sess_node) {	TAILQ_FOREACH(s, &Sessions, sess_node) {
SLIST_FOREACH(st, &s->sess_subscr, st_node) {	SLIST_FOREACH(st, &s->sess_subscr, st_node) {
Line 127 pubAck(struct tagSession sess, u_short mid, char __	Line 129 pubAck(struct tagSession sess, u_short mid, char __
if (!flg)	if (!flg)
freePkt(&p);	freePkt(&p);

call.DeletePUB_topic(&cfg, pub, sess->sess_cid, mid, psTopic, sess->sess_user, sess->sess_addr, -1);	call.DeletePUB_topic(&cfg, pub, sess->sess_cid, mid, psTopic, sess->sess_user,
	sess->sess_addr, 0);
return 0;	return 0;
}	}