| /device/board/bearpi/bearpi_hm_nano/third_party/paho_mqtt/MQTTPacket/src/ |
| D | MQTTConnect.h | 75 MQTTString topicName;
77 MQTTString message;
101 MQTTString clientID;
106 MQTTString username;
107 MQTTString password;
|
| D | MQTTPacket.h | 74 } MQTTString; typedef
78 int MQTTstrlen(MQTTString mqttstring);
91 DLLExport int MQTTPacket_equals(MQTTString* a, char* bptr);
101 int readMQTTLenString(MQTTString* mqttstring, unsigned char** pptr, unsigned char* enddata);
103 void writeMQTTString(unsigned char** pptr, MQTTString mqttstring);
|
| D | MQTTUnsubscribe.h | 29 int count, MQTTString topicFilters[]);
32 MQTTString topicFilters[], unsigned char* buf, int len);
|
| D | MQTTSubscribe.h | 29 int count, MQTTString topicFilters[], int requestedQoSs[]);
32 …int maxcount, int* count, MQTTString topicFilters[], int requestedQoSs[], unsigned char* buf, int …
|
| D | MQTTPublish.h | 29 unsigned short packetid, MQTTString topicName, unsigned char* payload, int payloadlen);
32 … MQTTString* topicName, unsigned char** payload, int* payloadlen, unsigned char* buf, int buflen);
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttpacket/src/ |
| D | MQTTConnect.h | 82 MQTTString topicName;
84 MQTTString message;
109 MQTTString clientID;
114 MQTTString username;
115 MQTTString password;
|
| D | MQTTPacket.h | 89 } MQTTString; typedef
93 int MQTTstrlen(MQTTString mqttstring);
105 DLLExport int MQTTPacket_equals(MQTTString* a, char* b);
115 int readMQTTLenString(MQTTString* mqttstring, unsigned char** pptr, unsigned char* enddata);
117 void writeMQTTString(unsigned char** pptr, MQTTString mqttstring);
|
| D | MQTTFormat.h | 27 unsigned short packetid, MQTTString topicName, unsigned char* payload, int payloadlen);
30 MQTTString topicFilters[], int requestedQoSs[]);
33 int count, MQTTString topicFilters[]);
|
| 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()
|
| D | MQTTUnsubscribe.h | 29 int count, MQTTString topicFilters[]);
31 …(unsigned char* dup, unsigned short* packetid, int maxcount, int* count, MQTTString topicFilters[],
|
| D | MQTTSubscribe.h | 29 int count, MQTTString topicFilters[], int requestedQoSs[]);
32 …int maxcount, int* count, MQTTString topicFilters[], int requestedQoSs[], unsigned char* buf, int …
|
| 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,
|
| 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()
|
| D | MQTTUnsubscribeClient.c | 28 int MQTTSerialize_unsubscribeLength(int count, MQTTString topicFilters[]) in MQTTSerialize_unsubscribeLength()
50 int count, MQTTString topicFilters[]) in MQTTSerialize_unsubscribe()
|
| D | MQTTSubscribeClient.c | 28 int MQTTSerialize_subscribeLength(int count, MQTTString topicFilters[]) in MQTTSerialize_subscribeLength()
51 MQTTString topicFilters[], int requestedQoSs[]) in MQTTSerialize_subscribe()
|
| 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()
|
| D | MQTTConnectServer.c | 30 int MQTTPacket_checkVersion(MQTTString* protocol, int version) in MQTTPacket_checkVersion()
58 MQTTString Protocol; in MQTTDeserialize_connect()
|
| D | MQTTUnsubscribeServer.c | 35 int* count, MQTTString topicFilters[], in MQTTDeserialize_unsubscribe()
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttpacket/test/ |
| D | test1.c | 234 int checkMQTTStrings(MQTTString a, MQTTString b) in checkMQTTStrings()
359 MQTTString topicString = MQTTString_initializer; in test2()
367 MQTTString topicString2 = MQTTString_initializer; in test2()
418 MQTTString topicStrings[TOPIC_COUNT] = { MQTTString_initializer, MQTTString_initializer }; in test3()
424 MQTTString topicStrings2[TOPIC_COUNT] = { MQTTString_initializer, MQTTString_initializer }; in test3()
517 MQTTString topicStrings[TOPIC_COUNT] = { MQTTString_initializer, MQTTString_initializer }; in test5()
522 MQTTString topicStrings2[TOPIC_COUNT] = { MQTTString_initializer, MQTTString_initializer }; in test5()
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttclient_c/src/ |
| D | MQTTClient.c | 24 static void NewMessageData(MessageData* md, MQTTString* aTopicName, MQTTMessage* aMessage) { in NewMessageData()
186 static char isTopicMatched(char* topicFilter, MQTTString* topicName) in isTopicMatched()
214 int deliverMessage(MQTTClient* c, MQTTString* topicName, MQTTMessage* message) in deliverMessage()
332 MQTTString topicName; in cycle()
577 MQTTString topic = MQTTString_initializer; in MQTTAsyncSubscribe()
611 MQTTString topic = MQTTString_initializer; in MQTTSubscribeWithResults()
665 MQTTString topic = MQTTString_initializer; in MQTTAsyncUnsubscribe()
697 MQTTString topic = MQTTString_initializer; in MQTTUnsubscribe()
739 MQTTString topic = MQTTString_initializer; in MQTTAsyncPublish()
779 MQTTString topic = MQTTString_initializer; in MQTTPublish()
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttclient/src/ |
| D | MQTTClient.h | 62 …MessageData(MQTTString &aTopicName, struct Message &aMessage) : message(aMessage), topicName(aTop… in MessageData()
66 MQTTString &topicName;
249 int deliverMessage(MQTTString& topicName, Message& message);
250 bool isTopicMatched(char* topicFilter, MQTTString& topicName);
497 bool MQTT::Client<Network, Timer, a, b>::isTopicMatched(char* topicFilter, MQTTString& topicName) in isTopicMatched()
527 int MQTT::Client<Network, Timer, a, MAX_MESSAGE_HANDLERS>::deliverMessage(MQTTString& topicName, Me… in deliverMessage()
602 MQTTString topicName = MQTTString_initializer; in cycle()
859 MQTTString topic = {(char*)topicFilter, {0, 0}}; in subscribe()
904 MQTTString topic = {(char*)topicFilter, {0, 0}}; in unsubscribe()
988 MQTTString topicString = MQTTString_initializer; in publish()
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttpacket/samples/ |
| D | pub0sub1.c | 53 MQTTString topicString = MQTTString_initializer; in main()
133 MQTTString receivedTopic; in main()
|
| D | pub0sub1_nb.c | 53 MQTTString topicString = MQTTString_initializer; in main()
139 MQTTString receivedTopic; in main()
|
| D | qos0pub.c | 33 MQTTString topicString = MQTTString_initializer; in main()
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttpacket/samples/baremetalserial/ |
| D | pub0sub1_nb.c | 59 MQTTString topicString = MQTTString_initializer; in main()
153 MQTTString receivedTopic; in main()
|