| /foundation/systemabilitymgr/samgr_lite/communication/broadcast/source/ |
| H A D | pub_sub_implement.c | 22 static int AddTopic(IUnknown *iUnknown, const Topic *topic);
23 static int Subscribe(IUnknown *iUnknown, const Topic *topic, Consumer *consumer);
24 static Consumer *ModifyConsumer(IUnknown *iUnknown, const Topic *topic, Consumer *oldConsumer, Consumer *newConsumer);
25 static Consumer *Unsubscribe(IUnknown *iUnknown, const Topic *topic, const Consumer *consumer);
26 static BOOL Publish(IUnknown *iUnknown, const Topic *topic, uint8 *data, int16 len);
28 static BOOL ImmediatelyPublish(PubSubFeature *feature, const Topic *topic, const Request *request);
47 static int AddTopic(IUnknown *iUnknown, const Topic *topic)
in AddTopic() argument
49 if (iUnknown == NULL || topic == NULL) {
in AddTopic()
58 if (broadcast->feature->GetRelation(broadcast->feature, topic) != NULL) {
in AddTopic()
67 newRelation->topic in AddTopic()
77 Subscribe(IUnknown *iUnknown, const Topic *topic, Consumer *consumer) Subscribe() argument
116 ModifyConsumer(IUnknown *iUnknown, const Topic *topic, Consumer *oldConsumer, Consumer *newConsumer) ModifyConsumer() argument
146 Unsubscribe(IUnknown *iUnknown, const Topic *topic, const Consumer *consumer) Unsubscribe() argument
178 Publish(IUnknown *iUnknown, const Topic *topic, uint8 *data, int16 len) Publish() argument
206 ImmediatelyPublish(PubSubFeature *feature, const Topic *topic, const Request *request) ImmediatelyPublish() argument
255 Topic topic = request->msgValue; DefaultHandle() local
[all...] |
| H A D | pub_sub_feature.c | 26 static Relation *GetRelation(PubSubFeature *feature, const Topic *topic);
39 feature->relations.topic = -1;
in Init()
74 Topic topic = request->msgValue;
in OnMessage() local
75 Relation *relation = broadcast->GetRelation(broadcast, &topic);
in OnMessage()
83 item->consumer->Notify(item->consumer, &topic, request);
in OnMessage()
95 static Relation *GetRelation(PubSubFeature *feature, const Topic *topic)
in GetRelation() argument
97 if (feature == NULL || topic == NULL) {
in GetRelation()
105 if (IsTopicEqual(&item->topic, topic)) {
in GetRelation()
|
| /foundation/distributedhardware/distributed_hardware_fwk/interfaces/inner_kits/src/ |
| H A D | distributed_hardware_fwk_kit.cpp | 43 int32_t DistributedHardwareFwkKit::RegisterPublisherListener(const DHTopic topic, sptr<IPublisherListener> listener) in RegisterPublisherListener() argument
45 DHLOGI("Register publisher listener, topic: %{public}" PRIu32 ", is DHFWK online: %{public}s", in RegisterPublisherListener()
46 (uint32_t)topic, isDHFWKOnLine_ ? "true" : "false"); in RegisterPublisherListener()
47 if (!IsDHTopicValid(topic)) { in RegisterPublisherListener()
48 DHLOGE("Topic invalid, topic: %{public}" PRIu32, (uint32_t)topic); in RegisterPublisherListener()
54 ret = DHFWKSAManager::GetInstance().GetDHFWKProxy()->RegisterPublisherListener(topic, listener); in RegisterPublisherListener()
57 return DHFWKSAManager::GetInstance().AddPublisherListenerToCache(topic, listener); in RegisterPublisherListener()
61 return DHFWKSAManager::GetInstance().AddPublisherListenerToCache(topic, listener); in RegisterPublisherListener()
67 int32_t DistributedHardwareFwkKit::UnregisterPublisherListener(const DHTopic topic, spt argument
86 PublishMessage(const DHTopic topic, const std::string &message) PublishMessage() argument
108 IsDHTopicValid(DHTopic topic) IsDHTopicValid() argument
[all...] |
| /foundation/distributedhardware/distributed_hardware_fwk/interfaces/inner_kits/test/unittest/common/ipc/distributed_hardware_proxy/src/ |
| H A D | distributed_hardware_proxy_test.cpp | 52 DHTopic topic = DHTopic::TOPIC_STOP_DSCREEN; in HWTEST_F() local
54 int32_t ret = hardwareProxy_->RegisterPublisherListener(topic, listener); in HWTEST_F()
70 DHTopic topic = static_cast<DHTopic>(invalid); in HWTEST_F() local
72 int32_t ret = hardwareProxy_->RegisterPublisherListener(topic, listener); in HWTEST_F()
87 DHTopic topic = DHTopic::TOPIC_STOP_DSCREEN; in HWTEST_F() local
89 int32_t ret = hardwareProxy_->RegisterPublisherListener(topic, listener); in HWTEST_F()
104 DHTopic topic = DHTopic::TOPIC_STOP_DSCREEN; in HWTEST_F() local
106 int32_t ret = hardwareProxy_->UnregisterPublisherListener(topic, listener); in HWTEST_F()
122 DHTopic topic = static_cast<DHTopic>(invalid); in HWTEST_F() local
124 int32_t ret = hardwareProxy_->UnregisterPublisherListener(topic, listene in HWTEST_F()
139 DHTopic topic = DHTopic::TOPIC_STOP_DSCREEN; HWTEST_F() local
158 DHTopic topic = static_cast<DHTopic>(invalid); HWTEST_F() local
174 DHTopic topic = DHTopic::TOPIC_STOP_DSCREEN; HWTEST_F() local
191 DHTopic topic = DHTopic::TOPIC_STOP_DSCREEN; HWTEST_F() local
[all...] |
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/lowlatency/lowlatencylistener/src/ |
| H A D | low_latency_listener_test.cpp | 52 DHTopic topic = DHTopic::TOPIC_MIN; in HWTEST_F() local
54 listener_->OnMessage(topic, message); in HWTEST_F()
69 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; in HWTEST_F() local
71 listener_->OnMessage(topic, message); in HWTEST_F()
86 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; in HWTEST_F() local
88 listener_->OnMessage(topic, message); in HWTEST_F()
103 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; in HWTEST_F() local
119 listener_->OnMessage(topic, message); in HWTEST_F()
136 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; in HWTEST_F() local
140 listener_->OnMessage(topic, messag in HWTEST_F()
155 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; HWTEST_F() local
187 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; HWTEST_F() local
[all...] |
| /foundation/distributedhardware/distributed_hardware_fwk/interfaces/inner_kits/test/unittest/common/distributedhardwarefwkkit/src/ |
| H A D | distributed_hardware_fwk_kit_test.cpp | 64 void DistributedHardwareFwkKitTest::TestPublisherListener::OnMessage(const DHTopic topic, const std::string& message) in OnMessage() argument
67 msgCnts_[topic]++; in OnMessage()
70 uint32_t DistributedHardwareFwkKitTest::TestPublisherListener::GetTopicMsgCnt(const DHTopic topic) in GetTopicMsgCnt() argument
73 return msgCnts_[topic]; in GetTopicMsgCnt()
128 DHTopic topic = static_cast<DHTopic>(invalid); in HWTEST_F() local
130 EXPECT_EQ(ERR_DH_FWK_PARA_INVALID, dhfwkPtr_->PublishMessage(topic, message)); in HWTEST_F()
144 DHTopic topic = DHTopic::TOPIC_STOP_DSCREEN; in HWTEST_F() local
146 EXPECT_EQ(ERR_DH_FWK_PARA_INVALID, dhfwkPtr_->PublishMessage(topic, message)); in HWTEST_F()
160 DHTopic topic = DHTopic::TOPIC_STOP_DSCREEN; in HWTEST_F() local
162 EXPECT_EQ(ERR_DH_FWK_PUBLISH_MSG_FAILED, dhfwkPtr_->PublishMessage(topic, messag in HWTEST_F()
176 DHTopic topic = DHTopic::TOPIC_STOP_DSCREEN; HWTEST_F() local
210 DHTopic topic = DHTopic::TOPIC_MIN; HWTEST_F() local
227 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; HWTEST_F() local
244 DHTopic topic = DHTopic::TOPIC_MIN; HWTEST_F() local
261 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; HWTEST_F() local
[all...] |
| /vendor/hisilicon/hispark_pegasus/demo/iottencent_demo/ |
| H A D | iot_main.c | 63 const char *topic; member
78 /* Tencent iot cloud topic */
85 static int MsgRcvCallBack(char *context, char *topic, int topicLen, MQTTClient_message *message) in MsgRcvCallBack() argument
93 topiLen = strlen(topic); in MsgRcvCallBack()
103 (void)memcpy_s(buf, bufSize, topic, topiLen); in MsgRcvCallBack()
105 msg->topic = buf; in MsgRcvCallBack()
111 IOT_LOG_DEBUG("RCVMSG:QOS:%d TOPIC:%s PAYLOAD:%s\r\n", msg->qos, msg->topic, msg->payload); in MsgRcvCallBack()
119 MQTTClient_free(topic); in MsgRcvCallBack()
140 ret = MQTTClient_publishMessage(client, msg->topic, &pubMsg, &gIoTAppCb.tocken); in MqttProcessQueueMsg()
149 gIoTAppCb.msgCallBack(msg->qos, msg->topic, ms in MqttProcessQueueMsg()
282 IotSendMsg(int qos, const char *topic, const char *payload) IotSendMsg() argument
[all...] |
| /vendor/hisilicon/hispark_pegasus/demo/mqtt_demo/ |
| H A D | iot_main.c | 63 const char *topic; member
78 /* Tencent iot cloud topic */
85 static int MsgRcvCallBack(char *context, char *topic, int topicLen, MQTTClient_message *message) in MsgRcvCallBack() argument
93 topiLen = strlen(topic); in MsgRcvCallBack()
103 (void)memcpy_s(buf, bufSize, topic, topiLen); in MsgRcvCallBack()
105 msg->topic = buf; in MsgRcvCallBack()
111 IOT_LOG_DEBUG("RCVMSG:QOS:%d TOPIC:%s PAYLOAD:%s\r\n", msg->qos, msg->topic, msg->payload); in MsgRcvCallBack()
119 MQTTClient_free(topic); in MsgRcvCallBack()
140 ret = MQTTClient_publishMessage(client, msg->topic, &pubMsg, &gIoTAppCb.tocken); in MqttProcessQueueMsg()
149 gIoTAppCb.msgCallBack(msg->qos, msg->topic, ms in MqttProcessQueueMsg()
282 IotSendMsg(int qos, const char *topic, const char *payload) IotSendMsg() argument
[all...] |
| /vendor/hisilicon/hispark_pegasus/demo/coap_demo/ |
| H A D | iot_main.c | 59 const char *topic; member
84 static int MsgRcvCallBack(unsigned char *context, char *topic, int topicLen, MQTTClient_message *message) in MsgRcvCallBack() argument
93 topicLength = strlen(topic); in MsgRcvCallBack()
103 ret = memcpy_s(buf, bufSize, topic, topicLength); in MsgRcvCallBack()
108 msg->topic = buf; in MsgRcvCallBack()
117 IOT_LOG_DEBUG("RCVMSG:QOS:%d TOPIC:%s PAYLOAD:%s\r\n", msg->qos, msg->topic, msg->payload); in MsgRcvCallBack()
125 MQTTClient_free(topic); in MsgRcvCallBack()
145 ret = MQTTClient_publishMessage(client, msg->topic, &pubmsg, &g_ioTAppCb.tocken); in IoTMsgProcess()
154 g_ioTAppCb.msgCallBack(msg->qos, msg->topic, msg->payload); in IoTMsgProcess()
220 IOT_LOG_ERROR("Subscribe the default topic faile in MqttProcess()
314 IotSendMsg(int qos, const char *topic, const char *payload) IotSendMsg() argument
[all...] |
| H A D | iot_profile.c | 160 // use this function to make a topic to publish
240 const char *topic; in IoTProfileCmdResp() local
247 topic = MakeTopic(CN_PROFILE_TOPICFMT_CMDRESP, deviceID, payload->requestID); in IoTProfileCmdResp()
248 if (topic == NULL) { in IoTProfileCmdResp()
252 if ((topic != NULL) && (msg != NULL)) { in IoTProfileCmdResp()
253 ret = IotSendMsg(0, topic, msg); in IoTProfileCmdResp()
256 hi_free(0, topic); in IoTProfileCmdResp()
292 char *topic; in IoTProfilePropertyReport() local
298 topic = MakeTopic(CN_PROFILE_TOPICFMT_PROPERTYREPORT, deviceID, NULL); in IoTProfilePropertyReport()
299 if (topic in IoTProfilePropertyReport()
[all...] |
| /vendor/hisilicon/hispark_pegasus/demo/oc_demo/ |
| H A D | iot_main.c | 60 const char *topic; member
85 static int MsgRcvCallBack(unsigned char *context, char *topic, int topicLen, MQTTClient_message *message) in MsgRcvCallBack() argument
93 topicLength = strlen(topic); in MsgRcvCallBack()
103 (void)memcpy_s(buf, bufSize, topic, topicLength); in MsgRcvCallBack()
105 msg->topic = buf; in MsgRcvCallBack()
111 IOT_LOG_DEBUG("RCVMSG:QOS:%d TOPIC:%s PAYLOAD:%s\r\n", msg->qos, msg->topic, msg->payload); in MsgRcvCallBack()
119 MQTTClient_free(topic); in MsgRcvCallBack()
139 ret = MQTTClient_publishMessage(client, msg->topic, &pubmsg, &g_ioTAppCb.tocken); in IoTMsgProcess()
148 g_ioTAppCb.msgCallBack(msg->qos, msg->topic, msg->payload); in IoTMsgProcess()
213 IOT_LOG_ERROR("Subscribe the default topic faile in MqttProcess()
303 IotSendMsg(int qos, const char *topic, const char *payload) IotSendMsg() argument
[all...] |
| H A D | iot_profile.c | 154 // use this function to make a topic to publish
240 const char *topic; in IoTProfileCmdResp() local
247 topic = MakeTopic(CN_PROFILE_TOPICFMT_CMDRESP, deviceID, payload->requestID); in IoTProfileCmdResp()
248 if (topic == NULL) { in IoTProfileCmdResp()
252 if ((topic != NULL) && (msg != NULL)) { in IoTProfileCmdResp()
253 ret = IotSendMsg(0, topic, msg); in IoTProfileCmdResp()
256 hi_free(0, topic); in IoTProfileCmdResp()
292 char *topic; in IoTProfilePropertyReport() local
298 topic = MakeTopic(CN_PROFILE_TOPICFMT_PROPERTYREPORT, deviceID, NULL); in IoTProfilePropertyReport()
299 if (topic in IoTProfilePropertyReport()
[all...] |
| /third_party/lwip/src/include/lwip/apps/ |
| H A D | mqtt.h | 77 /** will topic, set to NULL if will is not to be used,
140 * arrives to a subscribed topic @see mqtt_subscribe
155 * arrives to a subscribed topic @see mqtt_subscribe
158 * @param topic Zero terminated Topic text string, topic may not be referenced after callback return
161 typedef void (*mqtt_incoming_publish_cb_t)(void *arg, const char *topic, u32_t tot_len);
189 err_t mqtt_sub_unsub(mqtt_client_t *client, const char *topic, u8_t qos, mqtt_request_cb_t cb, void *arg, u8_t sub);
192 *Subscribe to topic */
193 #define mqtt_subscribe(client, topic, qos, cb, arg) mqtt_sub_unsub(client, topic, qo
[all...] |
| /third_party/libwebsockets/lib/secure-streams/protocols/ |
| H A D | ss-mqtt.c | 37 if (h->u.mqtt.sub_info.topic) { in secstream_mqtt_cleanup()
39 if (h->u.mqtt.sub_info.topic[i].name) { in secstream_mqtt_cleanup()
40 lws_free((void*)h->u.mqtt.sub_info.topic[i].name); in secstream_mqtt_cleanup()
41 h->u.mqtt.sub_info.topic[i].name = NULL; in secstream_mqtt_cleanup()
44 lws_free(h->u.mqtt.sub_info.topic); in secstream_mqtt_cleanup()
45 h->u.mqtt.sub_info.topic = NULL; in secstream_mqtt_cleanup()
81 " topic with no output\n", in secstream_mqtt_subscribe()
90 "topic", in secstream_mqtt_subscribe()
101 lwsl_err("%s, failed to expand MQTT subscribe topic\n", in secstream_mqtt_subscribe()
121 h->u.mqtt.sub_info.topic in secstream_mqtt_subscribe()
145 secstream_mqtt_publish(struct lws *wsi, uint8_t *buf, size_t buf_len, uint32_t payload_len, const char* topic, lws_mqtt_qos_levels_t qos, uint8_t retain, uint8_t dup, int f) secstream_mqtt_publish() argument
350 secstream_mqtt_is_shadow_matched(struct lws *wsi, const char *topic) secstream_mqtt_is_shadow_matched() argument
[all...] |
| /foundation/systemabilitymgr/samgr_lite/interfaces/kits/communication/broadcast/ |
| H A D | broadcast_interface.h | 70 * @brief Indicates the topic of an event or data, which is used to distinguish different types of
82 /** Error code showing that a topic has been subscribed to */
89 * @brief Defines the topic consumer used to receive events and push data. You need to implement
97 * @brief Defines how the consumer will process the events or data of a released topic.
100 * Note that the passed topic must have been subscribed by the consumer. Otherwise, the
104 * @param topic Indicates the pointer to the topic to be processed.
109 void (*Notify)(Consumer *consumer, const Topic *topic, const Request *origin);
114 * You need to implement this function to prevent repeated topic subscription. \n
128 * @brief Defines the provider of events and data of a topic
[all...] |
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/ipc/src/ |
| H A D | publisher_listener_proxy_test.cpp | 53 DHTopic topic = static_cast<DHTopic>(invalid); in HWTEST_F() local
55 proxy_->OnMessage(topic, message); in HWTEST_F()
70 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; in HWTEST_F() local
72 proxy_->OnMessage(topic, message); in HWTEST_F()
87 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; in HWTEST_F() local
89 proxy_->OnMessage(topic, message); in HWTEST_F()
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/publisher/ |
| H A D | publisher.cpp | 39 void Publisher::RegisterListener(const DHTopic topic, const sptr<IPublisherListener> listener) in RegisterListener() argument
41 publisherItems_[topic]->AddListener(listener); in RegisterListener()
44 void Publisher::UnregisterListener(const DHTopic topic, const sptr<IPublisherListener> listener) in UnregisterListener() argument
46 publisherItems_[topic]->RemoveListener(listener); in UnregisterListener()
49 void Publisher::PublishMessage(const DHTopic topic, const std::string &message) in PublishMessage() argument
51 publisherItems_[topic]->PublishMessage(message); in PublishMessage()
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/fuzztest/publisher_fuzzer/ |
| H A D | publisher_fuzzer.cpp | 38 void MockPublisherListener::OnMessage(const DHTopic topic, const std::string &message) in OnMessage() argument
40 (void)topic; in OnMessage()
60 DHTopic topic = topicFuzz[data[0] % TOPIC_SIZE]; in PublisherListenerFuzzTest() local
64 Publisher::GetInstance().RegisterListener(topic, listener); in PublisherListenerFuzzTest()
65 Publisher::GetInstance().PublishMessage(topic, message); in PublisherListenerFuzzTest()
66 Publisher::GetInstance().UnregisterListener(topic, listener); in PublisherListenerFuzzTest()
|
| /foundation/distributedhardware/distributed_hardware_fwk/interfaces/inner_kits/test/unittest/common/ipc/distributed_hardware_proxy/include/ |
| H A D | distributed_hardware_proxy_test.h | 47 int32_t RegisterPublisherListener(const DHTopic topic, const sptr<IPublisherListener> listener) in RegisterPublisherListener() argument
49 (void)topic; in RegisterPublisherListener()
54 int32_t UnregisterPublisherListener(const DHTopic topic, const sptr<IPublisherListener> listener) in UnregisterPublisherListener() argument
56 (void)topic; in UnregisterPublisherListener()
61 int32_t PublishMessage(const DHTopic topic, const std::string &msg) in PublishMessage() argument
63 (void)topic; in PublishMessage()
137 void OnMessage(const DHTopic topic, const std::string& message) in OnMessage() argument
139 (void)topic; in OnMessage()
|
| /foundation/distributedhardware/distributed_hardware_fwk/interfaces/inner_kits/test/unittest/common/ipc/dhfwk_sa_manager/include/ |
| H A D | dhfwk_sa_manager_test.h | 46 int32_t RegisterPublisherListener(const DHTopic topic, const sptr<IPublisherListener> listener) in RegisterPublisherListener() argument
48 (void)topic; in RegisterPublisherListener()
53 int32_t UnregisterPublisherListener(const DHTopic topic, const sptr<IPublisherListener> listener) in UnregisterPublisherListener() argument
55 (void)topic; in UnregisterPublisherListener()
60 int32_t PublishMessage(const DHTopic topic, const std::string &msg) in PublishMessage() argument
62 (void)topic; in PublishMessage()
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/distributedhardwarestub/include/ |
| H A D | distributed_hardware_stub_test.h | 38 int32_t RegisterPublisherListener(const DHTopic topic, const sptr<IPublisherListener> listener) in RegisterPublisherListener() argument
40 (void)topic; in RegisterPublisherListener()
45 int32_t UnregisterPublisherListener(const DHTopic topic, const sptr<IPublisherListener> listener) in UnregisterPublisherListener() argument
47 (void)topic; in UnregisterPublisherListener()
52 int32_t PublishMessage(const DHTopic topic, const std::string &msg) in PublishMessage() argument
54 (void)topic; in PublishMessage()
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/lowlatency/ |
| H A D | low_latency_listener.cpp | 39 void LowLatencyListener::OnMessage(const DHTopic topic, const std::string& message) in OnMessage() argument
41 (void) topic; in OnMessage()
44 if (topic <= DHTopic::TOPIC_MIN || topic >= DHTopic::TOPIC_MAX) { in OnMessage()
45 DHLOGE("Topic is invalid, topic: %{public}" PRIu32, (uint32_t)topic); in OnMessage()
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/ipc/ |
| H A D | publisher_listener_proxy.cpp | 32 void PublisherListenerProxy::OnMessage(const DHTopic topic, const std::string& message) in OnMessage() argument
39 if (topic < DHTopic::TOPIC_MIN || topic > DHTopic::TOPIC_MAX) { in OnMessage()
55 if (!data.WriteUint32((uint32_t)topic)) { in OnMessage()
56 DHLOGE("Parcel write topic failed"); in OnMessage()
|
| /foundation/distributedhardware/distributed_hardware_fwk/interfaces/inner_kits/src/ipc/ |
| H A D | publisher_listener_stub.cpp | 42 DHTopic topic = static_cast<DHTopic>(data.ReadUint32()); in OnRemoteRequest() local
43 if (topic < DHTopic::TOPIC_MIN || topic > DHTopic::TOPIC_MAX) { in OnRemoteRequest()
52 OnMessage(topic, message); in OnRemoteRequest()
|
| /third_party/libwebsockets/lib/roles/mqtt/client/ |
| H A D | client-mqtt-handshake.c | 63 if (c->conn_flags & LMQCFT_WILL_FLAG && c->will.topic) { in lws_mqtt_client_send_connect()
64 len = len + (unsigned int)c->will.topic->len + 2; in lws_mqtt_client_send_connect()
85 * 4. Payload - Client ID, Will topic & message, in lws_mqtt_client_send_connect()
108 if (lws_mqtt_str_is_not_empty(c->will.topic)) { in lws_mqtt_client_send_connect()
109 lws_ser_wu16be(p, c->will.topic->len); in lws_mqtt_client_send_connect()
111 memcpy(p, c->will.topic->buf, c->will.topic->len); in lws_mqtt_client_send_connect()
112 p += c->will.topic->len; in lws_mqtt_client_send_connect()
|