| /AliOS-Things-master/components/mqtt/MQTTPacket/ |
| A D | MQTTFormat.c | 73 dup, qos, retained, packetid, in MQTTStringFormat_publish()
83 if (dup) in MQTTStringFormat_ack()
94 dup, packetid, count, in MQTTStringFormat_subscribe()
112 dup, packetid, count, in MQTTStringFormat_unsubscribe()
140 unsigned char dup, retained, *payload; in MQTTFormat_toClientString() local
155 unsigned char packettype, dup; in MQTTFormat_toClientString() local
210 unsigned char dup, retained, *payload; in MQTTFormat_toServerString() local
225 unsigned char packettype, dup; in MQTTFormat_toServerString() local
233 unsigned char dup; in MQTTFormat_toServerString() local
238 if (MQTTDeserialize_subscribe(&dup, &packetid, maxcount, &count, in MQTTFormat_toServerString()
[all …]
|
| A D | MQTTSerializePublish.c | 55 int MQTTSerialize_publish(unsigned char* buf, int buflen, unsigned char dup, int qos, unsigned char… in MQTTSerialize_publish() argument
71 header.bits.dup = dup; in MQTTSerialize_publish()
104 int MQTTSerialize_ack(unsigned char* buf, int buflen, unsigned char packettype, unsigned char dup, … in MQTTSerialize_ack() argument
117 header.bits.dup = dup; in MQTTSerialize_ack()
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()
|
| A D | MQTTDeserializePublish.c | 36 int MQTTDeserialize_publish(unsigned char* dup, int* qos, unsigned char* retained, unsigned short* … in MQTTDeserialize_publish() argument
49 *dup = header.bits.dup; in MQTTDeserialize_publish()
82 int MQTTDeserialize_ack(unsigned char* packettype, unsigned char* dup, unsigned short* packetid, un… in MQTTDeserialize_ack() argument
92 *dup = header.bits.dup; in MQTTDeserialize_ack()
|
| A D | MQTTUnsubscribeClient.c | 49 int MQTTSerialize_unsubscribe(unsigned char* buf, int buflen, unsigned char dup, unsigned short pac… in MQTTSerialize_unsubscribe() argument
67 header.bits.dup = dup; in MQTTSerialize_unsubscribe()
95 unsigned char dup = 0; in MQTTDeserialize_unsuback() local
99 rc = MQTTDeserialize_ack(&type, &dup, packetid, buf, buflen); in MQTTDeserialize_unsuback()
|
| A D | MQTTFormat.h | 26 int MQTTStringFormat_publish(char* strbuf, int strbuflen, unsigned char dup, int qos, unsigned char…
28 int MQTTStringFormat_ack(char* strbuf, int strbuflen, unsigned char packettype, unsigned char dup, …
29 int MQTTStringFormat_subscribe(char* strbuf, int strbuflen, unsigned char dup, unsigned short packe…
32 int MQTTStringFormat_unsubscribe(char* strbuf, int strbuflen, unsigned char dup, unsigned short pac…
|
| A D | MQTTPublish.h | 28 DLLExport int MQTTSerialize_publish(unsigned char* buf, int buflen, unsigned char dup, int qos, uns…
31 DLLExport int MQTTDeserialize_publish(unsigned char* dup, int* qos, unsigned char* retained, unsign…
35 DLLExport int MQTTSerialize_pubrel(unsigned char* buf, int buflen, unsigned char dup, unsigned shor…
|
| A D | MQTTPacket.h | 60 unsigned int dup : 1; /**< DUP flag bit */ member
69 unsigned int dup : 1; /**< DUP flag bit */ member
97 …lize_ack(unsigned char* buf, int buflen, unsigned char type, unsigned char dup, unsigned short pac…
98 DLLExport int MQTTDeserialize_ack(unsigned char* packettype, unsigned char* dup, unsigned short* pa…
|
| A D | MQTTUnsubscribeServer.c | 34 int MQTTDeserialize_unsubscribe(unsigned char* dup, unsigned short* packetid, int maxcount, int* co… in MQTTDeserialize_unsubscribe() argument
47 *dup = header.bits.dup; in MQTTDeserialize_unsubscribe()
|
| A D | MQTTSubscribeServer.c | 35 int MQTTDeserialize_subscribe(unsigned char* dup, unsigned short* packetid, int maxcount, int* coun… in MQTTDeserialize_subscribe() argument
48 *dup = header.bits.dup; in MQTTDeserialize_subscribe()
|
| A D | MQTTSubscribeClient.c | 50 int MQTTSerialize_subscribe(unsigned char* buf, int buflen, unsigned char dup, unsigned short packe… in MQTTSerialize_subscribe() argument
68 header.bits.dup = dup; in MQTTSerialize_subscribe()
|
| A D | MQTTUnsubscribe.h | 28 DLLExport int MQTTSerialize_unsubscribe(unsigned char* buf, int buflen, unsigned char dup, unsigned…
31 DLLExport int MQTTDeserialize_unsubscribe(unsigned char* dup, unsigned short* packetid, int max_cou…
|
| A D | MQTTSubscribe.h | 28 DLLExport int MQTTSerialize_subscribe(unsigned char* buf, int buflen, unsigned char dup, unsigned s…
31 DLLExport int MQTTDeserialize_subscribe(unsigned char* dup, unsigned short* packetid,
|
| /AliOS-Things-master/components/linkkit/mqtt/impl/ |
| A D | MQTTSerializePublish.c | 57 int MQTTSerialize_publish(unsigned char *buf, int buflen, unsigned char dup, in MQTTSerialize_publish() argument
74 MQTT_HEADER_SET_DUP(header.byte, dup); in MQTTSerialize_publish()
107 unsigned char dup, unsigned short packetid) in MQTTSerialize_ack() argument
118 MQTT_HEADER_SET_DUP(header.byte, dup); in MQTTSerialize_ack()
151 int MQTTSerialize_pubrel(unsigned char *buf, int buflen, unsigned char dup, in MQTTSerialize_pubrel() argument
154 return MQTTSerialize_ack(buf, buflen, PUBREL, dup, packetid); in MQTTSerialize_pubrel()
|
| A D | MQTTUnsubscribeClient.c | 54 int MQTTSerialize_unsubscribe(unsigned char *buf, int buflen, unsigned char dup, in MQTTSerialize_unsubscribe() argument
72 MQTT_HEADER_SET_DUP(header.byte, dup); in MQTTSerialize_unsubscribe()
102 unsigned char dup = 0; in MQTTDeserialize_unsuback() local
105 rc = MQTTDeserialize_ack(&type, &dup, packetid, buf, buflen); in MQTTDeserialize_unsuback()
|
| A D | MQTTPublish.h | 29 unsigned char dup, int qos,
35 DLLExport int MQTTDeserialize_publish(unsigned char *dup, int *qos,
45 unsigned char dup, unsigned short packetid);
|
| A D | MQTTDeserializePublish.c | 37 int MQTTDeserialize_publish(unsigned char *dup, int *qos, in MQTTDeserialize_publish() argument
52 *dup = MQTT_HEADER_GET_DUP(header.byte); in MQTTDeserialize_publish()
87 int MQTTDeserialize_ack(unsigned char *packettype, unsigned char *dup, in MQTTDeserialize_ack() argument
98 *dup = MQTT_HEADER_GET_DUP(header.byte); in MQTTDeserialize_ack()
|
| A D | MQTTPacket.h | 75 #define MQTT_HEADER_SET_DUP(head, dup) \ argument
77 head |= ((dup << 3) & 0x08); \
118 unsigned char dup, unsigned short packetid);
119 int MQTTDeserialize_ack(unsigned char *packettype, unsigned char *dup,
|
| A D | MQTTUnsubscribe.h | 29 unsigned char dup,
33 DLLExport int MQTTDeserialize_unsubscribe(unsigned char *dup,
|
| A D | MQTTSubscribe.h | 29 unsigned char dup,
34 DLLExport int MQTTDeserialize_subscribe(unsigned char *dup,
|
| A D | MQTTSubscribeClient.c | 55 int MQTTSerialize_subscribe(unsigned char *buf, int buflen, unsigned char dup, in MQTTSerialize_subscribe() argument
73 MQTT_HEADER_SET_DUP(header.byte, dup); in MQTTSerialize_subscribe()
|
| /AliOS-Things-master/components/mqtt/MQTTClient-C/ |
| A D | MQTTClient.c | 283 if (MQTTDeserialize_publish(&msg.dup, &intQoS, &msg.retained, &msg.id, &topicName, in cycle()
307 unsigned char dup, type; in cycle() local
308 if (MQTTDeserialize_ack(&type, &dup, &mypacketid, c->readbuf, c->readbuf_size) != 1) in cycle()
649 unsigned char dup, type; in MQTTPublish() local
650 if (MQTTDeserialize_ack(&type, &dup, &mypacketid, c->readbuf, c->readbuf_size) != 1) in MQTTPublish()
661 unsigned char dup, type; in MQTTPublish() local
662 if (MQTTDeserialize_ack(&type, &dup, &mypacketid, c->readbuf, c->readbuf_size) != 1) in MQTTPublish()
|
| A D | MQTTClient.h | 81 unsigned char dup; member
|
| /AliOS-Things-master/components/ota/hal/ |
| A D | ota_hal_trans.h | 19 unsigned char dup; member
|
| /AliOS-Things-master/components/linkkit/include/linkkit/ |
| A D | mqtt_api.h | 81 uint8_t dup; member
|
| /AliOS-Things-master/components/linkkit/dev_model/alcs/ |
| A D | alcs_server.c | 587 int dup = 0; in alcs_resource_register_secure() local
609 dup = 1; in alcs_resource_register_secure()
614 dup = 1; in alcs_resource_register_secure()
618 if (dup == 0) { in alcs_resource_register_secure()
|