Searched refs:mypacketid (Results 1 – 2 of 2) sorted by relevance
| /device/board/isoftstone/yangfan/common/mqtt/mqttclient/src/ |
| D | MQTTClient.h | 643 unsigned short mypacketid; in cycle() local
645 if (MQTTDeserialize_ack(&type, &dup, &mypacketid, readbuf, MAX_MQTT_PACKET_SIZE) != 1) in cycle()
648 (packet_type == PUBREC) ? PUBREL : PUBCOMP, 0, mypacketid)) <= 0) in cycle()
655 freeQoS2msgid(mypacketid); in cycle()
873 unsigned short mypacketid; in subscribe() local
875 …if (MQTTDeserialize_suback(&mypacketid, 1, &count, &data.grantedQoS, readbuf, MAX_MQTT_PACKET_SIZE… in subscribe()
917 unsigned short mypacketid; // should be the same as the packetid above in unsubscribe() local
918 if (MQTTDeserialize_unsuback(&mypacketid, readbuf, MAX_MQTT_PACKET_SIZE) == 1) in unsubscribe()
947 unsigned short mypacketid; in publish() local
949 if (MQTTDeserialize_ack(&type, &dup, &mypacketid, readbuf, MAX_MQTT_PACKET_SIZE) != 1) in publish()
[all …]
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttclient_c/src/ |
| D | MQTTClient.c | 360 unsigned short mypacketid; in cycle() local
362 if (MQTTDeserialize_ack(&type, &dup, &mypacketid, c->readbuf, c->readbuf_size) != 1) in cycle()
365 (packet_type == PUBREC) ? PUBREL : PUBCOMP, 0, mypacketid)) <= 0) in cycle()
632 unsigned short mypacketid; in MQTTSubscribeWithResults() local
634 …if (MQTTDeserialize_suback(&mypacketid, 1, &count, (int*)&data->grantedQoS, c->readbuf, c->readbuf… in MQTTSubscribeWithResults()
717 unsigned short mypacketid; // should be the same as the packetid above in MQTTUnsubscribe() local
718 if (MQTTDeserialize_unsuback(&mypacketid, c->readbuf, c->readbuf_size) == 1) in MQTTUnsubscribe()
806 unsigned short mypacketid; in MQTTPublish() local
808 if (MQTTDeserialize_ack(&type, &dup, &mypacketid, c->readbuf, c->readbuf_size) != 1) in MQTTPublish()
818 unsigned short mypacketid; in MQTTPublish() local
[all …]
|