version 1.2.2.9, 2012/05/05 13:39:27
|
version 1.2.2.11, 2012/05/05 15:04:29
|
Line 84 cmdSUBSCRIBE(void *srv, int len, void *arg)
|
Line 84 cmdSUBSCRIBE(void *srv, int len, void *arg)
|
} |
} |
|
|
/* add to cache */ |
/* add to cache */ |
SESS_ELEM_LOCK(sess); |
|
SLIST_INSERT_HEAD(&sess->sess_subscr, store, st_node); |
SLIST_INSERT_HEAD(&sess->sess_subscr, store, st_node); |
SESS_ELEM_UNLOCK(sess); |
|
|
|
subs[i].sub_ret = MQTT_QOS_PASS; |
subs[i].sub_ret = MQTT_QOS_PASS; |
} else |
} else |
Line 163 cmdCONNECT(void *srv, int len, void *arg)
|
Line 161 cmdCONNECT(void *srv, int len, void *arg)
|
return -1; |
return -1; |
|
|
ioDEBUG(5, "Exec CONNECT session"); |
ioDEBUG(5, "Exec CONNECT session"); |
SESS_LOCK; |
|
TAILQ_REMOVE(&Sessions, sess, sess_node); |
TAILQ_REMOVE(&Sessions, sess, sess_node); |
SESS_UNLOCK; |
|
|
|
if (call.FiniSessPUB) |
if (call.FiniSessPUB) |
call.FiniSessPUB(&cfg, pub, sess->sess_cid, sess->sess_user, "%"); |
call.FiniSessPUB(&cfg, pub, sess->sess_cid, sess->sess_user, "%"); |
|
|
SESS_ELEM_LOCK(sess); |
|
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); |
|
|
Line 181 cmdCONNECT(void *srv, int len, void *arg)
|
Line 176 cmdCONNECT(void *srv, int len, void *arg)
|
|
|
free(store); |
free(store); |
} |
} |
SESS_ELEM_UNLOCK(sess); |
|
|
|
if (sess->sess_will.msg) |
if (sess->sess_will.msg) |
free(sess->sess_will.msg); |
free(sess->sess_will.msg); |
Line 206 cmdDISCONNECT(void *srv, int len, void *arg)
|
Line 200 cmdDISCONNECT(void *srv, int len, void *arg)
|
return -1; |
return -1; |
|
|
ioDEBUG(5, "Exec DISCONNECT session"); |
ioDEBUG(5, "Exec DISCONNECT session"); |
SESS_LOCK; |
|
TAILQ_REMOVE(&Sessions, sess, sess_node); |
|
SESS_UNLOCK; |
|
|
|
call.LOG(logg, "Session %s stopped from %s for user %s.\n", sess->sess_cid, |
call.LOG(logg, "Session %s stopped from %s for user %s.\n", sess->sess_cid, |
sess->sess_addr, sess->sess_user); |
sess->sess_addr, sess->sess_user); |
|
|
finiSession(sess); | return -2; /* must terminate dispatcher */ |
return 0; | |
} |
} |