| /device/board/isoftstone/yangfan/common/mqtt/mqttpacket/src/ |
| D | MQTTFormat.c | 48 data->will.qos, data->will.retained, in MQTTStringFormat_connect()
68 …ringFormat_publish(char* strbuf, int strbuflen, unsigned char dup, int qos, unsigned char retained, in MQTTStringFormat_publish() argument
73 dup, qos, retained, packetid, in MQTTStringFormat_publish()
140 unsigned char dup, retained, *payload; in MQTTFormat_toClientString() local
144 if (MQTTDeserialize_publish(&dup, &qos, &retained, &packetid, &topicName, in MQTTFormat_toClientString()
146 strindex = MQTTStringFormat_publish(strbuf, strbuflen, dup, qos, retained, packetid, in MQTTFormat_toClientString()
210 unsigned char dup, retained, *payload; in MQTTFormat_toServerString() local
214 if (MQTTDeserialize_publish(&dup, &qos, &retained, &packetid, &topicName, in MQTTFormat_toServerString()
216 strindex = MQTTStringFormat_publish(strbuf, strbuflen, dup, qos, retained, packetid, in MQTTFormat_toServerString()
|
| D | MQTTPublish.h | 28 …signed char* buf, int buflen, unsigned char dup, int qos, unsigned char retained, unsigned short p…
31 DLLExport int MQTTDeserialize_publish(unsigned char* dup, int* qos, unsigned char* retained, unsign…
|
| D | MQTTDeserializePublish.c | 36 int MQTTDeserialize_publish(unsigned char* dup, int* qos, unsigned char* retained, unsigned short* … in MQTTDeserialize_publish() argument
51 *retained = header.bits.retain; in MQTTDeserialize_publish()
|
| D | MQTTSerializePublish.c | 55 …signed char* buf, int buflen, unsigned char dup, int qos, unsigned char retained, unsigned short p… in MQTTSerialize_publish() argument
73 header.bits.retain = retained; in MQTTSerialize_publish()
|
| D | MQTTFormat.h | 26 …ringFormat_publish(char* strbuf, int strbuflen, unsigned char dup, int qos, unsigned char retained,
|
| D | MQTTConnect.h | 88 unsigned char retained; member
|
| /device/board/bearpi/bearpi_hm_nano/third_party/paho_mqtt/MQTTPacket/src/ |
| D | MQTTPublish.h | 28 …rialize_publish(unsigned char* buf, int buflen, unsigned char dup, int qos, unsigned char retained,
31 DLLExport int MQTTDeserialize_publish(unsigned char* dup, int* qos, unsigned char* retained, unsign…
|
| D | MQTTConnect.h | 81 unsigned char retained; member
|
| /device/soc/hisilicon/hi3861v100/sdk_liteos/third_party/paho.mqtt.c/include/mqtt/ |
| D | MQTTProtocolClient.h | 34 int MQTTProtocol_startPublish(Clients* pubclient, Publish* publish, int qos, int retained, Messages…
35 Messages* MQTTProtocol_createMessage(Publish* publish, Messages** mm, int qos, int retained);
|
| D | MQTTClient.h | 311 int retained; member
619 int retained; member
1111 …TTClient handle, const char* topicName, int payloadlen, const void* payload, int qos, int retained,
1115 int qos, int retained, MQTTProperties* properties, MQTTClient_deliveryToken* dt);
|
| D | MQTTAsync.h | 302 int retained; member
874 int retained; member
1384 int retained, MQTTAsync_responseOptions* response);
|
| D | MQTTPersistence.h | 73 int retained; member
|
| D | Clients.h | 79 int retained; member
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttclient/src/ |
| D | MQTTClient.h | 52 bool retained; member
180 …nst char* topicName, void* payload, size_t payloadlen, enum QoS qos = QOS0, bool retained = false);
191 … void* payload, size_t payloadlen, unsigned short& id, enum QoS qos = QOS1, bool retained = false);
606 …rialize_publish((unsigned char*)&msg.dup, &intQoS, (unsigned char*)&msg.retained, (unsigned short*… in cycle()
984 …char* topicName, void* payload, size_t payloadlen, unsigned short& id, enum QoS qos, bool retained) in publish() argument
1001 len = MQTTSerialize_publish(sendbuf, MAX_MQTT_PACKET_SIZE, 0, qos, retained, id, in publish()
1026 …, b>::publish(const char* topicName, void* payload, size_t payloadlen, enum QoS qos, bool retained) 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/samples/linux/ |
| D | hello.cpp | 18 ++arrivedcount, message.qos, message.retained, message.dup, message.id); in messageArrived()
59 message.retained = false; in main()
|
| D | main.cpp | 210 ++arrivedcount, message.qos, message.retained, message.dup, message.id); in messageArrived()
251 message.retained = false; in main()
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttpacket/test/ |
| D | test1.c | 292 … before->will.retained == after->will.retained, "retained flags were different\n", rc); in checkConnectPackets()
328 data.will.retained = 0; in test1()
357 unsigned char retained = 0; in test2() local
377 rc = MQTTSerialize_publish(buf, buflen, dup, qos, retained, msgid, topicString, in test2()
388 …assert("retaineds should be the same", retained == retained2, "retaineds were different %d\n", ret… in test2()
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttpacket/samples/ |
| D | pub0sub1.c | 128 unsigned char retained; in main() local
135 rc = MQTTDeserialize_publish(&dup, &qos, &retained, &msgid, &receivedTopic, in main()
|
| D | pub0sub1_nb.c | 134 unsigned char retained; in main() local
141 rc = MQTTDeserialize_publish(&dup, &qos, &retained, &msgid, &receivedTopic, in main()
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttclient/samples/ardunio/hello/ |
| D | Hello.ino | 34 sprintf(printbuf, "Message %d arrived: qos %d, retained %d, dup %d, packetid %d\n",
35 ++arrivedcount, message.qos, message.retained, message.dup, message.id);
104 message.retained = false;
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttpacket/samples/baremetalserial/ |
| D | pub0sub1_nb.c | 148 unsigned char retained; in main() local
155 rc = MQTTDeserialize_publish(&dup, &qos, &retained, &msgid, &receivedTopic, in main()
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttclient_c/test/ |
| D | test1.c | 319 pubmsg.retained = 0; in test1_sendAndReceive()
382 data.will.retained = 0; in test1()
461 data.will.retained = 0; in test2()
558 pubmsg.retained = 0; in check_subs_exist()
617 data.will.retained = 0; in test3()
699 pubmsg.retained = 0; in test3()
825 opts.will->retained = 0;
933 opts.will->retained = 0;
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttclient/test/ |
| D | test1.cpp | 314 pubmsg.retained = false; in test1_sendAndReceive()
370 data.will.retained = 0; in test1()
447 data.will.retained = 0; in test2()
559 pubmsg.retained = false; in check_subs_exist()
612 data.will.retained = 0; in test3()
696 pubmsg.retained = false; in test3()
823 opts.will->retained = 0;
|
| /device/board/isoftstone/yangfan/common/mqtt/mqttclient_c/samples/freertos/ |
| D | MQTTEcho.c | 65 message.retained = 0; in prvMQTTEchoTask()
|
| /device/board/bearpi/bearpi_hm_nano/app/D5_iot_mqtt/ |
| D | iot_mqtt.c | 93 message.retained = 0; in MQTTDemoTask()
|