Searched refs:mypacketid (Results 1 – 2 of 2) sorted by relevance
| /AliOS-Things-master/components/mqtt/MQTTClient-C/ |
| A D | MQTTClient.c | 306 unsigned short mypacketid; in cycle() local
308 if (MQTTDeserialize_ack(&type, &dup, &mypacketid, c->readbuf, c->readbuf_size) != 1) in cycle()
311 (packet_type == PUBREC) ? PUBREL : PUBCOMP, 0, mypacketid)) <= 0) in cycle()
544 unsigned short mypacketid; in MQTTSubscribeWithResults() local
546 …if (MQTTDeserialize_suback(&mypacketid, 1, &count, (int*)&data->grantedQoS, c->readbuf, c->readbuf… in MQTTSubscribeWithResults()
597 unsigned short mypacketid; // should be the same as the packetid above in MQTTUnsubscribe() local
598 if (MQTTDeserialize_unsuback(&mypacketid, c->readbuf, c->readbuf_size) == 1) in MQTTUnsubscribe()
648 unsigned short mypacketid; in MQTTPublish() local
650 if (MQTTDeserialize_ack(&type, &dup, &mypacketid, c->readbuf, c->readbuf_size) != 1) in MQTTPublish()
660 unsigned short mypacketid; in MQTTPublish() local
[all …]
|
| /AliOS-Things-master/components/linkkit/mqtt/impl/ |
| A D | iotx_mqtt_client.c | 1034 unsigned short mypacketid; in iotx_mc_handle_recv_PUBACK() local
1042 if (MQTTDeserialize_ack(&type, &dup, &mypacketid, in iotx_mc_handle_recv_PUBACK()
1048 (void)iotx_mc_mask_pubInfo_from(c, mypacketid); in iotx_mc_handle_recv_PUBACK()
1054 msg.msg = (void *)(uintptr_t)mypacketid; in iotx_mc_handle_recv_PUBACK()
1105 unsigned short mypacketid; in iotx_mc_handle_recv_SUBACK() local
1115 rc = MQTTDeserialize_suback(&mypacketid, MUTLI_SUBSCIRBE_MAX, &count, in iotx_mc_handle_recv_SUBACK()
1126 mqtt_debug("%20s : %d", "Packet ID", mypacketid); in iotx_mc_handle_recv_SUBACK()
1142 msg.msg = (void *)(uintptr_t)mypacketid; in iotx_mc_handle_recv_SUBACK()
1487 unsigned short mypacketid = in iotx_mc_handle_recv_UNSUBACK() local
1493 if (MQTTDeserialize_unsuback(&mypacketid, (unsigned char *)c->buf_read, in iotx_mc_handle_recv_UNSUBACK()
[all …]
|
Completed in 8 milliseconds