| /device/board/isoftstone/yangfan/common/mqtt/mqttpacket/src/ |
| D | MQTTFormat.c | 90 MQTTString topicFilters[], int requestedQoSs[]) in MQTTStringFormat_subscribe() argument
95 topicFilters[0].lenstring.len, topicFilters[0].lenstring.data, in MQTTStringFormat_subscribe()
108 int count, MQTTString topicFilters[]) in MQTTStringFormat_unsubscribe() argument
113 topicFilters[0].lenstring.len, topicFilters[0].lenstring.data); in MQTTStringFormat_unsubscribe()
236 MQTTString topicFilters[1]; in MQTTFormat_toServerString() local
239 topicFilters, requestedQoSs, buf, buflen) == 1) in MQTTFormat_toServerString()
240 …= MQTTStringFormat_subscribe(strbuf, strbuflen, dup, packetid, count, topicFilters, requestedQoSs)… in MQTTFormat_toServerString()
248 MQTTString topicFilters[1]; in MQTTFormat_toServerString() local
249 …if (MQTTDeserialize_unsubscribe(&dup, &packetid, maxcount, &count, topicFilters, buf, buflen) == 1) in MQTTFormat_toServerString()
250 … strindex = MQTTStringFormat_unsubscribe(strbuf, strbuflen, dup, packetid, count, topicFilters); in MQTTFormat_toServerString()
|
| D | MQTTUnsubscribeClient.c | 28 int MQTTSerialize_unsubscribeLength(int count, MQTTString topicFilters[]) in MQTTSerialize_unsubscribeLength() argument
34 len += 2 + MQTTstrlen(topicFilters[i]); /* length + topic */ in MQTTSerialize_unsubscribeLength()
50 int count, MQTTString topicFilters[]) in MQTTSerialize_unsubscribe() argument
59 if (MQTTPacket_len(rem_len = MQTTSerialize_unsubscribeLength(count, topicFilters)) > buflen) { in MQTTSerialize_unsubscribe()
76 writeMQTTString(&ptr, topicFilters[i]); in MQTTSerialize_unsubscribe()
|
| D | MQTTSubscribeClient.c | 28 int MQTTSerialize_subscribeLength(int count, MQTTString topicFilters[]) in MQTTSerialize_subscribeLength() argument
34 len += 2 + MQTTstrlen(topicFilters[i]) + 1; /* length + topic + req_qos */ in MQTTSerialize_subscribeLength()
51 MQTTString topicFilters[], int requestedQoSs[]) in MQTTSerialize_subscribe() argument
60 if (MQTTPacket_len(rem_len = MQTTSerialize_subscribeLength(count, topicFilters)) > buflen) in MQTTSerialize_subscribe()
78 writeMQTTString(&ptr, topicFilters[i]); in MQTTSerialize_subscribe()
|
| 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 | MQTTFormat.h | 30 MQTTString topicFilters[], int requestedQoSs[]);
33 int count, MQTTString topicFilters[]);
|
| D | MQTTUnsubscribeServer.c | 35 int* count, MQTTString topicFilters[], in MQTTDeserialize_unsubscribe() argument
58 if (!readMQTTLenString(&topicFilters[*count], &curdata, enddata)) in MQTTDeserialize_unsubscribe()
|
| D | MQTTSubscribeServer.c | 35 …(unsigned char* dup, unsigned short* packetid, int maxcount, int* count, MQTTString topicFilters[], in MQTTDeserialize_subscribe() argument
58 if (!readMQTTLenString(&topicFilters[*count], &curdata, enddata)) in MQTTDeserialize_subscribe()
|
| /device/board/bearpi/bearpi_hm_nano/third_party/paho_mqtt/MQTTPacket/src/ |
| 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 …
|