| /device/board/isoftstone/yangfan/common/mqtt/mqttpacket/src/ |
| 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()
83 memcpy(ptr, payload, payloadlen); in MQTTSerialize_publish()
84 ptr += payloadlen; in MQTTSerialize_publish()
|
| D | MQTTFormat.c | 69 unsigned short packetid, MQTTString topicName, unsigned char* payload, int payloadlen) in MQTTStringFormat_publish() argument
75 payloadlen, (payloadlen < 20) ? payloadlen : 20, payload); in MQTTStringFormat_publish()
142 int qos, payloadlen; in MQTTFormat_toClientString() local
145 &payload, &payloadlen, buf, buflen) == 1) in MQTTFormat_toClientString()
147 topicName, payload, payloadlen); in MQTTFormat_toClientString()
212 int qos, payloadlen; in MQTTFormat_toServerString() local
215 &payload, &payloadlen, buf, buflen) == 1) in MQTTFormat_toServerString()
217 topicName, payload, payloadlen); in MQTTFormat_toServerString()
|
| D | MQTTPublish.h | 29 MQTTString topicName, unsigned char* payload, int payloadlen);
32 unsigned char** payload, int* payloadlen, unsigned char* buf, int len);
|
| D | MQTTDeserializePublish.c | 37 unsigned char** payload, int* payloadlen, unsigned char* buf, int buflen) in MQTTDeserialize_publish() argument
63 *payloadlen = enddata - curdata; in MQTTDeserialize_publish()
|
| D | MQTTFormat.h | 27 unsigned short packetid, MQTTString topicName, unsigned char* payload, int payloadlen);
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttclient/samples/linux/ |
| D | hello.cpp | 19 printf("Payload %.*s\n", (int)message.payloadlen, (char*)message.payload); in messageArrived()
62 message.payloadlen = strlen(buf)+1; in main()
73 message.payloadlen = strlen(buf)+1; in main()
83 message.payloadlen = strlen(buf)+1; in main()
|
| D | main.cpp | 211 printf("Payload %.*s\n", message.payloadlen, (char*)message.payload); in messageArrived()
254 message.payloadlen = strlen(buf)+1; in main()
263 message.payloadlen = strlen(buf)+1; in main()
271 message.payloadlen = strlen(buf)+1; in main()
|
| D | stdoutsub.cpp | 203 printf("%.*s", (int)message.payloadlen, (char*)message.payload); in messageArrived()
205 printf("%.*s%s", (int)message.payloadlen, (char*)message.payload, opts.delimiter); in messageArrived()
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttclient/test/ |
| D | test1.cpp | 286 assert("Good message lengths", pubmsg.payloadlen == m.payloadlen, in messageArrived()
287 "payloadlen was %d", m.payloadlen); in messageArrived()
289 if (pubmsg.payloadlen == m.payloadlen) in messageArrived()
290 assert("Good message contents", memcmp(m.payload, pubmsg.payload, m.payloadlen) == 0, in messageArrived()
312 pubmsg.payloadlen = 11; in test1_sendAndReceive()
541 assert("Good message lengths", pubmsg.payloadlen == m.payloadlen, in messageArrived2()
542 "payloadlen was %d", m.payloadlen); in messageArrived2()
544 if (pubmsg.payloadlen == m.payloadlen) in messageArrived2()
545 assert("Good message contents", memcmp(m.payload, pubmsg.payload, m.payloadlen) == 0, in messageArrived2()
557 pubmsg.payloadlen = 11; in check_subs_exist()
[all …]
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttclient_c/test/ |
| D | test1.c | 291 assert("Good message lengths", pubmsg.payloadlen == m->payloadlen, in messageArrived()
292 "payloadlen was %d", m->payloadlen); in messageArrived()
294 if (pubmsg.payloadlen == m->payloadlen) in messageArrived()
295 assert("Good message contents", memcmp(m->payload, pubmsg.payload, m->payloadlen) == 0, in messageArrived()
317 pubmsg.payloadlen = 11; in test1_sendAndReceive()
540 assert("Good message lengths", pubmsg.payloadlen == m->payloadlen, in messageArrived2()
541 "payloadlen was %d", m->payloadlen); in messageArrived2()
543 if (pubmsg.payloadlen == m->payloadlen) in messageArrived2()
544 assert("Good message contents", memcmp(m->payload, pubmsg.payload, m->payloadlen) == 0, in messageArrived2()
556 pubmsg.payloadlen = 11; in check_subs_exist()
[all …]
|
| /device/board/bearpi/bearpi_hm_nano/third_party/paho_mqtt/MQTTPacket/src/ |
| 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/samples/ |
| D | qos0pub.c | 35 int payloadlen = strlen(payload); in main() local
62 …d char *)(buf + len), buflen - len, 0, 0, 0, 0, topicString, (unsigned char *)payload, payloadlen); in main()
|
| D | pub0sub1.c | 56 int payloadlen = strlen(payload); in main() local
141 …= MQTTSerialize_publish(buf, buflen, 0, 0, 0, 0, topicString, (unsigned char*)payload, payloadlen); in main()
|
| D | pub0sub1_nb.c | 56 int payloadlen = strlen(payload); in main() local
145 …= MQTTSerialize_publish(buf, buflen, 0, 0, 0, 0, topicString, (unsigned char*)payload, payloadlen); in main()
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttclient/src/ |
| D | MQTTClient.h | 56 size_t payloadlen; member
180 …int publish(const char* topicName, void* payload, size_t payloadlen, enum QoS qos = QOS0, bool ret…
191 …int publish(const char* topicName, void* payload, size_t payloadlen, unsigned short& id, enum QoS …
605 msg.payloadlen = 0; /* this is a size_t, but deserialize publish sets this as int */ in cycle()
607 … (unsigned char**)&msg.payload, (int*)&msg.payloadlen, readbuf, MAX_MQTT_PACKET_SIZE) != 1) in cycle()
984 …_PACKET_SIZE, b>::publish(const char* topicName, void* payload, size_t payloadlen, unsigned short&… in publish() argument
1002 topicString, (unsigned char*)payload, payloadlen); in publish()
1026 …_PACKET_SIZE, b>::publish(const char* topicName, void* payload, size_t payloadlen, enum QoS qos, b… in publish() argument
1029 return publish(topicName, payload, payloadlen, id, qos, retained); in publish()
1036 return publish(topicName, message.payload, message.payloadlen, message.qos, message.retained); in publish()
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttclient_c/samples/freertos/ |
| D | MQTTEcho.c | 22 data->message->payloadlen, data->message->payload); in messageArrived()
68 message.payloadlen = strlen(payload); in prvMQTTEchoTask()
|
| /device/soc/hisilicon/hi3861v100/sdk_liteos/third_party/paho.mqtt.c/include/mqtt/ |
| D | Clients.h | 51 int payloadlen; member
77 int payloadlen; member
|
| D | MQTTClient.h | 276 int payloadlen; member
1111 DLLExport int MQTTClient_publish(MQTTClient handle, const char* topicName, int payloadlen, const vo…
1114 DLLExport MQTTResponse MQTTClient_publish5(MQTTClient handle, const char* topicName, int payloadlen…
|
| D | MQTTPersistence.h | 70 int payloadlen; member
|
| /device/board/bearpi/bearpi_hm_nano/app/D5_iot_mqtt/ |
| D | iot_mqtt.c | 46 data->topicName->lenstring.data, data->message->payloadlen, data->message->payload); in messageArrived()
96 message.payloadlen = strlen(payload); in MQTTDemoTask()
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttclient/samples/ardunio/hello/ |
| D | Hello.ino | 107 message.payloadlen = strlen(buf)+1;
116 message.payloadlen = strlen(buf)+1;
125 message.payloadlen = strlen(buf)+1;
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttclient_c/samples/linux/ |
| D | stdoutsub.c | 188 printf("%.*s", (int)message->payloadlen, (char*)message->payload); in messageArrived()
190 printf("%.*s%s", (int)message->payloadlen, (char*)message->payload, opts.delimiter); in messageArrived()
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttpacket/samples/baremetalserial/ |
| D | pub0sub1_nb.c | 62 int payloadlen = strlen(payload); in main() local
160 …= MQTTSerialize_publish(buf, buflen, 0, 0, 0, 0, topicString, (unsigned char*)payload, payloadlen); in main()
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttpacket/test/ |
| D | test1.c | 361 int payloadlen = strlen((char*)payload); in test2() local
378 payload, payloadlen); in test2()
395 payloadlen == payloadlen2, "payload lengths were different %d\n", payloadlen2); in test2()
398 memcmp(payload, payload2, payloadlen) == 0, "payloads were different %s\n", ""); in test2()
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttclient_c/src/ |
| D | MQTTClient.c | 335 msg.payloadlen = 0; /* this is a size_t, but deserialize publish sets this as int */ in cycle()
337 … (unsigned char**)&msg.payload, (int*)&msg.payloadlen, c->readbuf, c->readbuf_size) != 1) in cycle()
340 …e = %{public}s, msg.payloadlen = %{public}d" ,msg.qos, intQoS, topicName.cstring, msg.payloadlen); in cycle()
756 topic, (unsigned char*)message->payload, message->payloadlen); in MQTTAsyncPublish()
796 topic, (unsigned char*)message->payload, message->payloadlen); in MQTTPublish()
|