version 1.2.2.13, 2012/04/25 13:33:53
|
version 1.2.2.14, 2012/04/25 13:40:02
|
Line 248 thrSession(struct tagSession *sess)
|
Line 248 thrSession(struct tagSession *sess)
|
break; |
break; |
case MQTT_TYPE_DISCONNECT: |
case MQTT_TYPE_DISCONNECT: |
ioDEBUG(5, "Exec DISCONNECT session"); |
ioDEBUG(5, "Exec DISCONNECT session"); |
finiSession(sess); |
|
|
|
SESS_LOCK; |
SESS_LOCK; |
TAILQ_REMOVE(&Sessions, sess, sess_node); |
TAILQ_REMOVE(&Sessions, sess, sess_node); |
SESS_UNLOCK; |
SESS_UNLOCK; |
|
|
|
finiSession(sess); |
locKill ^= locKill; |
locKill ^= locKill; |
continue; |
continue; |
case MQTT_TYPE_PUBLISH: |
case MQTT_TYPE_PUBLISH: |