| /AliOS-Things-master/components/mqtt/MQTTPacket/ |
| A D | MQTTFormat.c | 49 data->will.topicName.lenstring.len, data->will.topicName.lenstring.data, in MQTTStringFormat_connect()
69 unsigned short packetid, MQTTString topicName, unsigned char* payload, int payloadlen) in MQTTStringFormat_publish() argument
74 (topicName.lenstring.len < 20) ? topicName.lenstring.len : 20, topicName.lenstring.data, in MQTTStringFormat_publish()
143 MQTTString topicName = MQTTString_initializer; in MQTTFormat_toClientString() local
144 if (MQTTDeserialize_publish(&dup, &qos, &retained, &packetid, &topicName, in MQTTFormat_toClientString()
147 topicName, payload, payloadlen); in MQTTFormat_toClientString()
213 MQTTString topicName = MQTTString_initializer; in MQTTFormat_toServerString() local
214 if (MQTTDeserialize_publish(&dup, &qos, &retained, &packetid, &topicName, in MQTTFormat_toServerString()
217 topicName, payload, payloadlen); in MQTTFormat_toServerString()
|
| A D | MQTTSerializePublish.c | 31 int MQTTSerialize_publishLength(int qos, MQTTString topicName, int payloadlen) in MQTTSerialize_publishLength() argument
35 len += 2 + MQTTstrlen(topicName) + payloadlen; in MQTTSerialize_publishLength()
56 MQTTString topicName, unsigned char* payload, int payloadlen) in MQTTSerialize_publish() argument
64 if (MQTTPacket_len(rem_len = MQTTSerialize_publishLength(qos, topicName, payloadlen)) > buflen) in MQTTSerialize_publish()
78 writeMQTTString(&ptr, topicName); in MQTTSerialize_publish()
|
| 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 | MQTTDeserializePublish.c | 36 …gned char* dup, int* qos, unsigned char* retained, unsigned short* packetid, MQTTString* topicName, in MQTTDeserialize_publish() argument
56 if (!readMQTTLenString(topicName, &curdata, enddata) || in MQTTDeserialize_publish()
|
| A D | MQTTConnectClient.c | 40 len += MQTTstrlen(options->will.topicName)+2 + MQTTstrlen(options->will.message)+2; in MQTTSerialize_connectLength()
109 writeMQTTString(&ptr, options->will.topicName); in MQTTSerialize_connect()
|
| A D | MQTTFormat.h | 27 unsigned short packetid, MQTTString topicName, unsigned char* payload, int payloadlen);
|
| A D | MQTTConnect.h | 82 MQTTString topicName; member
|
| A D | MQTTConnectServer.c | 89 if (!readMQTTLenString(&data->will.topicName, &curdata, enddata) || in MQTTDeserialize_connect()
|
| /AliOS-Things-master/components/linkkit/mqtt/impl/ |
| A D | MQTTSerializePublish.c | 32 int MQTTSerialize_publishLength(int qos, MQTTString topicName, int payloadlen) in MQTTSerialize_publishLength() argument
36 len += 2 + MQTTstrlen(topicName) + payloadlen; in MQTTSerialize_publishLength()
59 unsigned short packetid, MQTTString topicName, in MQTTSerialize_publish() argument
67 rem_len = MQTTSerialize_publishLength(qos, topicName, payloadlen); in MQTTSerialize_publish()
82 writeMQTTString(&ptr, topicName); in MQTTSerialize_publish()
|
| A D | iotx_mqtt_client.c | 71 pClient->connect_data.will.topicName = pConnectParams->will.topicName; in iotx_mc_set_connect_params()
1184 if (!topicFilter || !topicName) { in iotx_mc_is_topic_matched()
1189 curn = topicName->lenstring.data; in iotx_mc_is_topic_matched()
1243 if (topicName->cstring) { in iotx_mc_deliver_message()
1244 net_topic = topicName->cstring; in iotx_mc_deliver_message()
1257 compare_topic = topicName; in iotx_mc_deliver_message()
1382 MQTTString topicName; in iotx_mc_handle_recv_PUBLISH() local
1408 if (topicName.lenstring.len == 0 || topicName.lenstring.data == NULL) { in iotx_mc_handle_recv_PUBLISH()
2329 if (NULL == topicName || '/' != topicName[0]) { in iotx_mc_check_topic()
2574 topic.cstring = (char *)topicName; in MQTTPublish()
[all …]
|
| A D | MQTTPublish.h | 32 MQTTString topicName,
38 MQTTString *topicName,
|
| A D | MQTTDeserializePublish.c | 39 MQTTString *topicName, unsigned char **payload, in MQTTDeserialize_publish() argument
60 if (!readMQTTLenString(topicName, &curdata, enddata) || in MQTTDeserialize_publish()
|
| A D | MQTTConnectClient.c | 41 len += MQTTstrlen(options->will.topicName) + 2 + in MQTTSerialize_connectLength()
110 writeMQTTString(&ptr, options->will.topicName); in MQTTSerialize_connect()
|
| A D | MQTTConnect.h | 69 MQTTString topicName; member
|
| /AliOS-Things-master/components/mqtt/MQTTClient-C/ |
| A D | MQTTClient.c | 24 md->topicName = aTopicName; in NewMessageData()
151 static char isTopicMatched(char* topicFilter, MQTTString* topicName) in isTopicMatched() argument
154 char* curn = topicName->lenstring.data; in isTopicMatched()
155 char* curn_end = curn + topicName->lenstring.len; in isTopicMatched()
179 int deliverMessage(MQTTClient* c, MQTTString* topicName, MQTTMessage* message) in deliverMessage() argument
193 NewMessageData(&md, topicName, message); in deliverMessage()
203 NewMessageData(&md, topicName, message); in deliverMessage()
279 MQTTString topicName; in cycle() local
287 deliverMessage(c, &topicName, &msg); in cycle()
617 int MQTTPublish(MQTTClient* c, const char* topicName, MQTTMessage* message) in MQTTPublish() argument
[all …]
|
| A D | MQTTClient.h | 90 MQTTString* topicName; member
|
| /AliOS-Things-master/components/mqtt/example/ |
| A D | mqtt_example.c | 29 printf("%.*s\t", md->topicName->lenstring.len, md->topicName->lenstring.data); in messageArrived()
|
| /AliOS-Things-master/components/py_engine/modules/mqtt/ |
| A D | mqttclient.c | 46 printf("%.*s\n", md->topicName->lenstring.len, in messageArrived()
47 md->topicName->lenstring.data); in messageArrived()
53 mp_obj_new_str(md->topicName->lenstring.data, in messageArrived()
54 md->topicName->lenstring.len), in messageArrived()
|
| /AliOS-Things-master/components/linkkit/mqtt/ |
| A D | mqtt_wrapper.h | 21 int wrapper_mqtt_publish(void *client, const char *topicName,
|