|
|
| version 1.2.2.18, 2012/04/26 09:15:26 | version 1.2.2.19, 2012/04/27 10:07:50 |
|---|---|
| Line 176 thrSession(struct tagSession *sess) | Line 176 thrSession(struct tagSession *sess) |
| finiSession(sess); | finiSession(sess); |
| locKill ^= locKill; | locKill ^= locKill; |
| continue; | continue; |
| case MQTT_TYPE_SUBSCRIBE: | |
| case MQTT_TYPE_PINGREQ: | |
| break; | |
| case MQTT_TYPE_PUBLISH: | case MQTT_TYPE_PUBLISH: |
| ioDEBUG(5, "Exec PUBLISH topic QoS=%d", hdr->mqtt_msg.qos); | ioDEBUG(5, "Exec PUBLISH topic QoS=%d", hdr->mqtt_msg.qos); |
| /* | /* |
| Line 185 thrSession(struct tagSession *sess) | Line 188 thrSession(struct tagSession *sess) |
| break; | break; |
| case MQTT_TYPE_PUBREL: | case MQTT_TYPE_PUBREL: |
| break; | break; |
| case MQTT_TYPE_SUBSCRIBE: | |
| break; | |
| case MQTT_TYPE_UNSUBSCRIBE: | case MQTT_TYPE_UNSUBSCRIBE: |
| break; | |
| case MQTT_TYPE_PINGREQ: | |
| ioDEBUG(5, "Exec PINGREQ session"); | |
| break; | |
| case MQTT_TYPE_PINGRESP: | |
| ioDEBUG(5, "Exec PINGRESP session"); | |
| break; | break; |
| default: | default: |
| ioDEBUG(5, "Error:: Session %s, wrong command %d - DISCARDED", | ioDEBUG(5, "Error:: Session %s, wrong command %d - DISCARDED", |