/AliOS-Things-master/components/mqtt/MQTTPacket/ |
A D | MQTTFormat.c | 33 return MQTTPacket_names[packetid]; in MQTTPacket_getName() 94 dup, packetid, count, in MQTTStringFormat_subscribe() 112 dup, packetid, count, in MQTTStringFormat_unsubscribe() 141 unsigned short packetid; in MQTTFormat_toClientString() local 156 unsigned short packetid; in MQTTFormat_toClientString() local 163 unsigned short packetid; in MQTTFormat_toClientString() local 172 unsigned short packetid; in MQTTFormat_toClientString() local 211 unsigned short packetid; in MQTTFormat_toServerString() local 226 unsigned short packetid; in MQTTFormat_toServerString() local 234 unsigned short packetid; in MQTTFormat_toServerString() local [all …]
|
A D | MQTTSerializePublish.c | 55 …char* buf, int buflen, unsigned char dup, int qos, unsigned char retained, unsigned short packetid, in MQTTSerialize_publish() argument 81 writeInt(&ptr, packetid); in MQTTSerialize_publish() 104 …signed char* buf, int buflen, unsigned char packettype, unsigned char dup, unsigned short packetid) in MQTTSerialize_ack() argument 122 writeInt(&ptr, packetid); in MQTTSerialize_ack() 137 int MQTTSerialize_puback(unsigned char* buf, int buflen, unsigned short packetid) in MQTTSerialize_puback() argument 139 return MQTTSerialize_ack(buf, buflen, PUBACK, 0, packetid); in MQTTSerialize_puback() 151 int MQTTSerialize_pubrel(unsigned char* buf, int buflen, unsigned char dup, unsigned short packetid) in MQTTSerialize_pubrel() argument 153 return MQTTSerialize_ack(buf, buflen, PUBREL, dup, packetid); in MQTTSerialize_pubrel() 164 int MQTTSerialize_pubcomp(unsigned char* buf, int buflen, unsigned short packetid) in MQTTSerialize_pubcomp() argument 166 return MQTTSerialize_ack(buf, buflen, PUBCOMP, 0, packetid); in MQTTSerialize_pubcomp()
|
A D | MQTTFormat.h | 23 const char* MQTTPacket_getName(unsigned short packetid); 27 unsigned short packetid, MQTTString topicName, unsigned char* payload, int payloadlen); 28 …char* strbuf, int strbuflen, unsigned char packettype, unsigned char dup, unsigned short packetid); 29 …ormat_subscribe(char* strbuf, int strbuflen, unsigned char dup, unsigned short packetid, int count, 31 int MQTTStringFormat_suback(char* strbuf, int strbuflen, unsigned short packetid, int count, int* g… 32 …TTStringFormat_unsubscribe(char* strbuf, int strbuflen, unsigned char dup, unsigned short packetid,
|
A D | MQTTPublish.h | 28 …char* buf, int buflen, unsigned char dup, int qos, unsigned char retained, unsigned short packetid, 31 …(unsigned char* dup, int* qos, unsigned char* retained, unsigned short* packetid, MQTTString* topi… 34 DLLExport int MQTTSerialize_puback(unsigned char* buf, int buflen, unsigned short packetid); 35 …t MQTTSerialize_pubrel(unsigned char* buf, int buflen, unsigned char dup, unsigned short packetid); 36 DLLExport int MQTTSerialize_pubcomp(unsigned char* buf, int buflen, unsigned short packetid);
|
A D | MQTTUnsubscribe.h | 28 …TTSerialize_unsubscribe(unsigned char* buf, int buflen, unsigned char dup, unsigned short packetid, 31 DLLExport int MQTTDeserialize_unsubscribe(unsigned char* dup, unsigned short* packetid, int max_cou… 34 DLLExport int MQTTSerialize_unsuback(unsigned char* buf, int buflen, unsigned short packetid); 36 DLLExport int MQTTDeserialize_unsuback(unsigned short* packetid, unsigned char* buf, int len);
|
A D | MQTTSubscribe.h | 28 …MQTTSerialize_subscribe(unsigned char* buf, int buflen, unsigned char dup, unsigned short packetid, 31 DLLExport int MQTTDeserialize_subscribe(unsigned char* dup, unsigned short* packetid, 34 DLLExport int MQTTSerialize_suback(unsigned char* buf, int buflen, unsigned short packetid, int cou… 36 DLLExport int MQTTDeserialize_suback(unsigned short* packetid, int maxcount, int* count, int grante…
|
A D | MQTTUnsubscribeServer.c | 34 int MQTTDeserialize_unsubscribe(unsigned char* dup, unsigned short* packetid, int maxcount, int* co… in MQTTDeserialize_unsubscribe() argument 52 *packetid = readInt(&curdata); in MQTTDeserialize_unsubscribe() 76 int MQTTSerialize_unsuback(unsigned char* buf, int buflen, unsigned short packetid) in MQTTSerialize_unsuback() argument 94 writeInt(&ptr, packetid); in MQTTSerialize_unsuback()
|
A D | MQTTUnsubscribeClient.c | 49 …TTSerialize_unsubscribe(unsigned char* buf, int buflen, unsigned char dup, unsigned short packetid, in MQTTSerialize_unsubscribe() argument 73 writeInt(&ptr, packetid); in MQTTSerialize_unsubscribe() 92 int MQTTDeserialize_unsuback(unsigned short* packetid, unsigned char* buf, int buflen) in MQTTDeserialize_unsuback() argument 99 rc = MQTTDeserialize_ack(&type, &dup, packetid, buf, buflen); in MQTTDeserialize_unsuback()
|
A D | MQTTSubscribeServer.c | 35 int MQTTDeserialize_subscribe(unsigned char* dup, unsigned short* packetid, int maxcount, int* coun… in MQTTDeserialize_subscribe() argument 53 *packetid = readInt(&curdata); in MQTTDeserialize_subscribe() 82 int MQTTSerialize_suback(unsigned char* buf, int buflen, unsigned short packetid, int count, int* g… in MQTTSerialize_suback() argument 101 writeInt(&ptr, packetid); in MQTTSerialize_suback()
|
A D | MQTTDeserializePublish.c | 36 …(unsigned char* dup, int* qos, unsigned char* retained, unsigned short* packetid, MQTTString* topi… in MQTTDeserialize_publish() argument 61 *packetid = readInt(&curdata); in MQTTDeserialize_publish() 82 int MQTTDeserialize_ack(unsigned char* packettype, unsigned char* dup, unsigned short* packetid, un… in MQTTDeserialize_ack() argument 100 *packetid = readInt(&curdata); in MQTTDeserialize_ack()
|
A D | MQTTSubscribeClient.c | 50 …ze_subscribe(unsigned char* buf, int buflen, unsigned char dup, unsigned short packetid, int count, in MQTTSerialize_subscribe() argument 74 writeInt(&ptr, packetid); in MQTTSerialize_subscribe() 100 int MQTTDeserialize_suback(unsigned short* packetid, int maxcount, int* count, int grantedQoSs[], u… in MQTTDeserialize_suback() argument 118 *packetid = readInt(&curdata); in MQTTDeserialize_suback()
|
A D | MQTTPacket.h | 97 …ck(unsigned char* buf, int buflen, unsigned char type, unsigned char dup, unsigned short packetid); 98 …lize_ack(unsigned char* packettype, unsigned char* dup, unsigned short* packetid, unsigned char* b…
|
/AliOS-Things-master/components/linkkit/mqtt/impl/ |
A D | MQTTSerializePublish.c | 59 unsigned short packetid, MQTTString topicName, in MQTTSerialize_publish() argument 85 writeInt(&ptr, packetid); in MQTTSerialize_publish() 107 unsigned char dup, unsigned short packetid) in MQTTSerialize_ack() argument 123 writeInt(&ptr, packetid); in MQTTSerialize_ack() 152 unsigned short packetid) in MQTTSerialize_pubrel() argument 154 return MQTTSerialize_ack(buf, buflen, PUBREL, dup, packetid); in MQTTSerialize_pubrel() 165 unsigned short packetid) in MQTTSerialize_pubcomp() argument 167 return MQTTSerialize_ack(buf, buflen, PUBCOMP, 0, packetid); in MQTTSerialize_pubcomp()
|
A D | MQTTUnsubscribe.h | 30 unsigned short packetid, int count, 34 unsigned short *packetid, 40 unsigned short packetid); 42 DLLExport int MQTTDeserialize_unsuback(unsigned short *packetid,
|
A D | MQTTPublish.h | 31 unsigned short packetid, 37 unsigned short *packetid, 45 unsigned char dup, unsigned short packetid); 47 unsigned short packetid);
|
A D | MQTTSubscribe.h | 30 unsigned short packetid, int count, 35 unsigned short *packetid, int maxcount, 41 unsigned short packetid, int count, 44 DLLExport int MQTTDeserialize_suback(unsigned short *packetid, int maxcount,
|
A D | MQTTUnsubscribeClient.c | 55 unsigned short packetid, int count, in MQTTSerialize_unsubscribe() argument 79 writeInt(&ptr, packetid); in MQTTSerialize_unsubscribe() 98 int MQTTDeserialize_unsuback(unsigned short *packetid, unsigned char *buf, in MQTTDeserialize_unsuback() argument 105 rc = MQTTDeserialize_ack(&type, &dup, packetid, buf, buflen); in MQTTDeserialize_unsuback()
|
A D | MQTTDeserializePublish.c | 38 unsigned char *retained, unsigned short *packetid, in MQTTDeserialize_publish() argument 67 *packetid = readInt(&curdata); in MQTTDeserialize_publish() 88 unsigned short *packetid, unsigned char *buf, in MQTTDeserialize_ack() argument 108 *packetid = readInt(&curdata); in MQTTDeserialize_ack()
|
A D | MQTTSubscribeClient.c | 56 unsigned short packetid, int count, in MQTTSerialize_subscribe() argument 80 writeInt(&ptr, packetid); in MQTTSerialize_subscribe() 105 int MQTTDeserialize_suback(unsigned short *packetid, int maxcount, int *count, in MQTTDeserialize_suback() argument 126 *packetid = readInt(&curdata); in MQTTDeserialize_suback()
|
A D | MQTTPacket.h | 118 unsigned char dup, unsigned short packetid); 120 unsigned short *packetid, unsigned char *buf,
|