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.15, 2012/05/08 14:27:46	version 1.2.2.16, 2012/05/08 14:36:10
Line 210 cmdCONNECT(void srv, int len, void arg)	Line 210 cmdCONNECT(void srv, int len, void arg)
ioDEBUG(5, "Exec CONNECT session");	ioDEBUG(5, "Exec CONNECT session");
TAILQ_REMOVE(&Sessions, sess, sess_node);	TAILQ_REMOVE(&Sessions, sess, sess_node);

if (call.FiniSessPUB)	if (sess->sess_clean) {
call.FiniSessPUB(&cfg, pub, sess->sess_cid, sess->sess_user, "%");	if (call.FiniSessPUB)
	call.FiniSessPUB(&cfg, pub, sess->sess_cid, sess->sess_user, "%");
	if (call.DeletePUB_subscribe)
	call.DeletePUB_subscribe(&cfg, pub, sess->sess_cid, "%", sess->sess_user, "%");
	if (call.WipePUB_topic)
	call.WipePUB_topic(&cfg, pub, sess->sess_cid, sess->sess_user, -1);
	}

while ((store = SLIST_FIRST(&sess->sess_subscr))) {	while ((store = SLIST_FIRST(&sess->sess_subscr))) {
SLIST_REMOVE_HEAD(&sess->sess_subscr, st_node);	SLIST_REMOVE_HEAD(&sess->sess_subscr, st_node);