| /AliOS-Things-master/components/linkkit/mqtt/impl/ |
| A D | MQTTUnsubscribeClient.c | 31 int MQTTSerialize_unsubscribeLength(int count, MQTTString topicFilters[]) in MQTTSerialize_unsubscribeLength() argument
37 len += 2 + MQTTstrlen(topicFilters[i]); /* length + topic*/ in MQTTSerialize_unsubscribeLength()
56 MQTTString topicFilters[]) in MQTTSerialize_unsubscribe() argument
64 rem_len = MQTTSerialize_unsubscribeLength(count, topicFilters); in MQTTSerialize_unsubscribe()
82 writeMQTTString(&ptr, topicFilters[i]); in MQTTSerialize_unsubscribe()
|
| A D | MQTTSubscribeClient.c | 31 int MQTTSerialize_subscribeLength(int count, MQTTString topicFilters[]) in MQTTSerialize_subscribeLength() argument
38 2 + MQTTstrlen(topicFilters[i]) + 1; /* length + topic + req_qos */ in MQTTSerialize_subscribeLength()
57 MQTTString topicFilters[], int requestedQoSs[]) in MQTTSerialize_subscribe() argument
66 count, topicFilters)) > buflen) { in MQTTSerialize_subscribe()
83 writeMQTTString(&ptr, topicFilters[i]); in MQTTSerialize_subscribe()
|
| A D | MQTTUnsubscribe.h | 31 MQTTString topicFilters[]);
36 MQTTString topicFilters[],
|
| A D | MQTTSubscribe.h | 31 MQTTString topicFilters[],
36 int *count, MQTTString topicFilters[],
|
| /AliOS-Things-master/components/mqtt/MQTTPacket/ |
| A 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()
|
| A 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 …strindex = MQTTStringFormat_subscribe(strbuf, strbuflen, dup, packetid, count, topicFilters, reque… 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()
|
| A 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()
|
| 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 | MQTTFormat.h | 30 MQTTString topicFilters[], int requestedQoSs[]);
33 int count, MQTTString topicFilters[]);
|
| A D | MQTTUnsubscribeServer.c | 34 …(unsigned char* dup, unsigned short* packetid, int maxcount, int* count, MQTTString topicFilters[], in MQTTDeserialize_unsubscribe() argument
57 if (!readMQTTLenString(&topicFilters[*count], &curdata, enddata)) in MQTTDeserialize_unsubscribe()
|
| A 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()
|