| /AliOS-Things-master/components/linkkit/mqtt/impl/ |
| A D | MQTTConnect.h | 69 MQTTString topicName;
71 MQTTString message;
97 MQTTString clientID;
102 MQTTString username;
103 MQTTString password;
|
| A D | MQTTPacket.h | 103 } MQTTString; typedef
110 int MQTTstrlen(MQTTString mqttstring);
124 int MQTTPacket_equals(MQTTString *a, char *b);
134 int readMQTTLenString(MQTTString *mqttstring, unsigned char **pptr,
137 void writeMQTTString(unsigned char **pptr, MQTTString mqttstring);
|
| A D | MQTTPacket.c | 187 void writeMQTTString(unsigned char **pptr, MQTTString mqttstring) in writeMQTTString()
207 int readMQTTLenString(MQTTString *mqttstring, unsigned char **pptr, in readMQTTLenString()
232 int MQTTstrlen(MQTTString mqttstring) in MQTTstrlen()
250 int MQTTPacket_equals(MQTTString *a, char *bptr) in MQTTPacket_equals()
|
| A D | MQTTUnsubscribe.h | 31 MQTTString topicFilters[]);
36 MQTTString topicFilters[],
|
| A D | MQTTPublish.h | 32 MQTTString topicName,
38 MQTTString *topicName,
|
| A D | MQTTSubscribe.h | 31 MQTTString topicFilters[],
36 int *count, MQTTString topicFilters[],
|
| A D | MQTTUnsubscribeClient.c | 31 int MQTTSerialize_unsubscribeLength(int count, MQTTString topicFilters[]) in MQTTSerialize_unsubscribeLength()
56 MQTTString topicFilters[]) in MQTTSerialize_unsubscribe()
|
| A D | MQTTSubscribeClient.c | 31 int MQTTSerialize_subscribeLength(int count, MQTTString topicFilters[]) in MQTTSerialize_subscribeLength()
57 MQTTString topicFilters[], int requestedQoSs[]) in MQTTSerialize_subscribe()
|
| A D | MQTTSerializePublish.c | 32 int MQTTSerialize_publishLength(int qos, MQTTString topicName, int payloadlen) in MQTTSerialize_publishLength()
59 unsigned short packetid, MQTTString topicName, in MQTTSerialize_publish()
|
| A D | MQTTDeserializePublish.c | 39 MQTTString *topicName, unsigned char **payload, in MQTTDeserialize_publish()
|
| /AliOS-Things-master/components/mqtt/MQTTPacket/ |
| A D | MQTTConnect.h | 82 MQTTString topicName;
84 MQTTString message;
109 MQTTString clientID;
114 MQTTString username;
115 MQTTString password;
|
| A D | MQTTPacket.h | 85 } MQTTString; typedef
89 int MQTTstrlen(MQTTString mqttstring);
101 DLLExport int MQTTPacket_equals(MQTTString* a, char* b);
111 int readMQTTLenString(MQTTString* mqttstring, unsigned char** pptr, unsigned char* enddata);
113 void writeMQTTString(unsigned char** pptr, MQTTString mqttstring);
|
| A D | MQTTFormat.h | 27 unsigned short packetid, MQTTString topicName, unsigned char* payload, int payloadlen);
30 MQTTString topicFilters[], int requestedQoSs[]);
33 int count, MQTTString topicFilters[]);
|
| A D | MQTTFormat.c | 69 unsigned short packetid, MQTTString topicName, unsigned char* payload, int payloadlen) in MQTTStringFormat_publish()
90 MQTTString topicFilters[], int requestedQoSs[]) in MQTTStringFormat_subscribe()
108 int count, MQTTString topicFilters[]) in MQTTStringFormat_unsubscribe()
143 MQTTString topicName = MQTTString_initializer; in MQTTFormat_toClientString()
213 MQTTString topicName = MQTTString_initializer; in MQTTFormat_toServerString()
236 MQTTString topicFilters[1]; in MQTTFormat_toServerString()
248 MQTTString topicFilters[1]; in MQTTFormat_toServerString()
|
| A D | MQTTUnsubscribe.h | 29 int count, MQTTString topicFilters[]);
31 …unsigned char* dup, unsigned short* packetid, int max_count, int* count, MQTTString topicFilters[],
|
| A D | MQTTSubscribe.h | 29 int count, MQTTString topicFilters[], int requestedQoSs[]);
32 …int maxcount, int* count, MQTTString topicFilters[], int requestedQoSs[], unsigned char* buf, int …
|
| A D | MQTTPublish.h | 29 MQTTString topicName, unsigned char* payload, int payloadlen);
31 …gned char* dup, int* qos, unsigned char* retained, unsigned short* packetid, MQTTString* topicName,
|
| A D | MQTTUnsubscribeClient.c | 28 int MQTTSerialize_unsubscribeLength(int count, MQTTString topicFilters[]) in MQTTSerialize_unsubscribeLength()
50 int count, MQTTString topicFilters[]) in MQTTSerialize_unsubscribe()
|
| A D | MQTTPacket.c | 194 void writeMQTTString(unsigned char** pptr, MQTTString mqttstring) in writeMQTTString()
215 int readMQTTLenString(MQTTString* mqttstring, unsigned char** pptr, unsigned char* enddata) in readMQTTLenString()
242 int MQTTstrlen(MQTTString mqttstring) in MQTTstrlen()
260 int MQTTPacket_equals(MQTTString* a, char* bptr) in MQTTPacket_equals()
|
| A D | MQTTSubscribeClient.c | 28 int MQTTSerialize_subscribeLength(int count, MQTTString topicFilters[]) in MQTTSerialize_subscribeLength()
51 MQTTString topicFilters[], int requestedQoSs[]) in MQTTSerialize_subscribe()
|
| A D | MQTTSerializePublish.c | 31 int MQTTSerialize_publishLength(int qos, MQTTString topicName, int payloadlen) in MQTTSerialize_publishLength()
56 MQTTString topicName, unsigned char* payload, int payloadlen) in MQTTSerialize_publish()
|
| A D | MQTTConnectServer.c | 30 int MQTTPacket_checkVersion(MQTTString* protocol, int version) in MQTTPacket_checkVersion()
58 MQTTString Protocol; in MQTTDeserialize_connect()
|
| A D | MQTTUnsubscribeServer.c | 34 …(unsigned char* dup, unsigned short* packetid, int maxcount, int* count, MQTTString topicFilters[], in MQTTDeserialize_unsubscribe()
|
| A D | MQTTSubscribeServer.c | 35 …(unsigned char* dup, unsigned short* packetid, int maxcount, int* count, MQTTString topicFilters[], in MQTTDeserialize_subscribe()
|
| /AliOS-Things-master/components/mqtt/MQTTClient-C/ |
| A D | MQTTClient.c | 23 static void NewMessageData(MessageData* md, MQTTString* aTopicName, MQTTMessage* aMessage) { in NewMessageData()
151 static char isTopicMatched(char* topicFilter, MQTTString* topicName) in isTopicMatched()
179 int deliverMessage(MQTTClient* c, MQTTString* topicName, MQTTMessage* message) in deliverMessage()
279 MQTTString topicName; in cycle()
523 MQTTString topic = MQTTString_initializer; in MQTTSubscribeWithResults()
577 MQTTString topic = MQTTString_initializer; in MQTTUnsubscribe()
621 MQTTString topic = MQTTString_initializer; in MQTTPublish()
|