Searched refs:topicFilter (Results 1 – 4 of 4) sorted by relevance
| /device/board/isoftstone/yangfan/common/mqtt/mqttclient_c/src/ |
| D | MQTTClient.c | 79 c->messageHandlers[i].topicFilter = 0; in MQTTClientInit()
186 static char isTopicMatched(char* topicFilter, MQTTString* topicName) in isTopicMatched() argument
188 char* curf = topicFilter; in isTopicMatched()
221 …if (c->messageHandlers[i].topicFilter != 0 && (MQTTPacket_equals(topicName, (char*)c->messageHandl… in deliverMessage()
222 isTopicMatched((char*)c->messageHandlers[i].topicFilter, topicName))) in deliverMessage()
294 c->messageHandlers[i].topicFilter = NULL; in MQTTCleanSession()
530 int MQTTSetMessageHandler(MQTTClient* c, const char* topicFilter, messageHandler messageHandler) in MQTTSetMessageHandler() argument
538 …if (c->messageHandlers[i].topicFilter != NULL && strcmp(c->messageHandlers[i].topicFilter, topicFi… in MQTTSetMessageHandler()
542 c->messageHandlers[i].topicFilter = NULL; in MQTTSetMessageHandler()
555 if (c->messageHandlers[i].topicFilter == NULL) in MQTTSetMessageHandler()
[all …]
|
| D | MQTTClient.h | 116 const char* topicFilter; member
173 DLLExport int MQTTSetMessageHandler(MQTTClient* c, const char* topicFilter, messageHandler messageH…
181 DLLExport int MQTTSubscribe(MQTTClient* client, const char* topicFilter, enum QoS, messageHandler);
182 DLLExport int MQTTAsyncSubscribe(MQTTClient* c, const char* topicFilter, enum QoS qos, messageHandl…
190 DLLExport int MQTTSubscribeWithResults(MQTTClient* client, const char* topicFilter, enum QoS, messa…
197 DLLExport int MQTTUnsubscribe(MQTTClient* client, const char* topicFilter);
198 int MQTTAsyncUnsubscribe(MQTTClient* c, const char* topicFilter);
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttclient/src/ |
| D | MQTTClient.h | 141 int setMessageHandler(const char* topicFilter, messageHandler mh);
199 int subscribe(const char* topicFilter, enum QoS qos, messageHandler mh);
208 int subscribe(const char* topicFilter, enum QoS qos, messageHandler mh, subackData &data);
214 int unsubscribe(const char* topicFilter);
250 bool isTopicMatched(char* topicFilter, MQTTString& topicName);
267 const char* topicFilter; member
302 messageHandlers[i].topicFilter = 0; in cleanSession()
497 bool MQTT::Client<Network, Timer, a, b>::isTopicMatched(char* topicFilter, MQTTString& topicName) in isTopicMatched() argument
499 char* curf = topicFilter; in isTopicMatched()
534 …if (messageHandlers[i].topicFilter != 0 && (MQTTPacket_equals(&topicName, (char*)messageHandlers[i… in deliverMessage()
[all …]
|
| /device/board/bearpi/bearpi_hm_nano/third_party/paho_mqtt/MQTTClient-C/src/ |
| D | MQTTClient.h | 103 const char* topicFilter; member
159 DLLExport int MQTTSetMessageHandler(MQTTClient* c, const char* topicFilter, messageHandler messageH…
167 DLLExport int MQTTSubscribe(MQTTClient* client, const char* topicFilter, enum QoS, messageHandler);
176 DLLExport int MQTTSubscribeWithResults(MQTTClient* client, const char* topicFilter, enum QoS, messa…
184 DLLExport int MQTTUnsubscribe(MQTTClient* client, const char* topicFilter);
|