Lines Matching refs:curdata
40 unsigned char* curdata = buf; in MQTTDeserialize_publish() local
46 header.byte = readChar(&curdata); in MQTTDeserialize_publish()
53 curdata += (rc = MQTTPacket_decodeBuf(curdata, &mylen)); /* read remaining length */ in MQTTDeserialize_publish()
54 enddata = curdata + mylen; in MQTTDeserialize_publish()
56 if (!readMQTTLenString(topicName, &curdata, enddata) || in MQTTDeserialize_publish()
57 enddata - curdata < 0) /* do we have enough data to read the protocol version byte? */ in MQTTDeserialize_publish()
61 *packetid = readInt(&curdata); in MQTTDeserialize_publish()
63 *payloadlen = enddata - curdata; in MQTTDeserialize_publish()
64 *payload = curdata; in MQTTDeserialize_publish()
85 unsigned char* curdata = buf; in MQTTDeserialize_ack() local
91 header.byte = readChar(&curdata); in MQTTDeserialize_ack()
95 curdata += (rc = MQTTPacket_decodeBuf(curdata, &mylen)); /* read remaining length */ in MQTTDeserialize_ack()
96 enddata = curdata + mylen; in MQTTDeserialize_ack()
98 if (enddata - curdata < 2) in MQTTDeserialize_ack()
100 *packetid = readInt(&curdata); in MQTTDeserialize_ack()