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", |