|
|
| 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: |