Home
last modified time | relevance | path

Searched refs:topic (Results 26 - 50 of 1249) sorted by relevance

12345678910>>...50

/foundation/distributedhardware/distributed_hardware_fwk/interfaces/inner_kits/src/ipc/
H A Ddistributed_hardware_proxy.cpp39 int32_t DistributedHardwareProxy::RegisterPublisherListener(const DHTopic topic, in RegisterPublisherListener() argument
52 if (topic < DHTopic::TOPIC_MIN || topic > DHTopic::TOPIC_MAX) { in RegisterPublisherListener()
65 if (!data.WriteUint32((uint32_t)topic)) { in RegisterPublisherListener()
66 DHLOGE("DistributedHardwareProxy write topic failed"); in RegisterPublisherListener()
88 int32_t DistributedHardwareProxy::UnregisterPublisherListener(const DHTopic topic, in UnregisterPublisherListener() argument
101 if (topic < DHTopic::TOPIC_MIN || topic > DHTopic::TOPIC_MAX) { in UnregisterPublisherListener()
114 if (!data.WriteUint32((uint32_t)topic)) { in UnregisterPublisherListener()
115 DHLOGE("DistributedHardwareProxy write topic faile in UnregisterPublisherListener()
137 PublishMessage(const DHTopic topic, const std::string &msg) PublishMessage() argument
[all...]
H A Ddhfwk_sa_manager.cpp161 DHLOGE("Register publisher listener failed, topic: %{public}" PRIu32, (uint32_t)entry.first); in RestoreListener()
180 int32_t DHFWKSAManager::AddPublisherListenerToCache(const DHTopic topic, sptr<IPublisherListener> listener) in AddPublisherListenerToCache() argument
184 publisherListenersCache_[topic].size() >= MAX_LISTENER_SIZE) { in AddPublisherListenerToCache()
188 publisherListenersCache_[topic].insert(listener); in AddPublisherListenerToCache()
192 void DHFWKSAManager::RemovePublisherListenerFromCache(const DHTopic topic, sptr<IPublisherListener> listener) in RemovePublisherListenerFromCache() argument
195 publisherListenersCache_[topic].erase(listener); in RemovePublisherListenerFromCache()
/device/soc/hisilicon/hi3861v100/sdk_liteos/third_party/paho.mqtt.c/include/mqtt/
H A DMQTTClient.h164 * Return code: The topic has been truncated (the topic string includes
165 * embedded NULL characters). String functions will not access the full topic.
166 * Use the topic length value to access the full topic.
264 * message topic is not part of this structure (see MQTTClient_publishMessage(),
300 * transmitted to new subscribers to a topic that matches the message topic.
341 * @param topicName The topic associated with the received message.
342 * @param topicLen The length of the topic i
[all...]
H A DClients.h48 char *topic; member
76 char *topic; member
H A DMQTTAsync.h148 * Return code: The topic has been truncated (the topic string includes
149 * embedded NULL characters). String functions will not access the full topic.
150 * Use the topic length value to access the full topic.
255 * message topic is not part of this structure (see MQTTAsync_publishMessage(),
291 * transmitted to new subscribers to a topic that matches the message topic.
332 * @param topicName The topic associated with the received message.
333 * @param topicLen The length of the topic i
[all...]
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/publisher/
H A Dpublisher_item.cpp28 PublisherItem::PublisherItem(DHTopic topic) : topic_(topic) in PublisherItem() argument
30 DHLOGE("Ctor PublisherItem, topic: %{public}d", topic); in PublisherItem()
35 DHLOGE("Dtor PublisherItem, topic: %{public}d", topic_); in ~PublisherItem()
/foundation/distributedhardware/distributed_hardware_fwk/common/utils/include/
H A Didistributed_hardware.h37 virtual int32_t RegisterPublisherListener(const DHTopic topic, const sptr<IPublisherListener> listener) = 0;
38 virtual int32_t UnregisterPublisherListener(const DHTopic topic, const sptr<IPublisherListener> listener) = 0;
39 virtual int32_t PublishMessage(const DHTopic topic, const std::string &msg) = 0;
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/include/
H A Ddistributed_hardware_service.h40 int32_t RegisterPublisherListener(const DHTopic topic, const sptr<IPublisherListener> listener) override;
41 int32_t UnregisterPublisherListener(const DHTopic topic, const sptr<IPublisherListener> listener) override;
42 int32_t PublishMessage(const DHTopic topic, const std::string &msg) override;
/foundation/distributedhardware/distributed_hardware_fwk/interfaces/inner_kits/include/ipc/
H A Ddistributed_hardware_proxy.h36 int32_t RegisterPublisherListener(const DHTopic topic, const sptr<IPublisherListener> listener) override;
37 int32_t UnregisterPublisherListener(const DHTopic topic, const sptr<IPublisherListener> listener) override;
38 int32_t PublishMessage(const DHTopic topic, const std::string &msg) override;
H A Ddhfwk_sa_manager.h43 int32_t AddPublisherListenerToCache(const DHTopic topic, sptr<IPublisherListener> listener);
44 void RemovePublisherListenerFromCache(const DHTopic topic, sptr<IPublisherListener> listener);
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/distributedhardwareservice/include/
H A Dmock_publisher_listener.h27 void OnMessage(const DHTopic topic, const std::string& message) in OnMessage() argument
29 (void) topic; in OnMessage()
/third_party/libwebsockets/minimal-examples/mqtt-client/minimal-mqtt-client/
H A Dminimal-mqtt-client.c24 STATE_SUBSCRIBE, /* subscribe to the topic */
48 .topic = "good/bye",
65 .topic = &topics[0],
216 pub_param.topic = "test/topic"; in callback_mqtt()
217 pub_param.topic_len = (uint16_t)strlen(pub_param.topic); in callback_mqtt()
287 lwsl_hexdump_notice(pub->topic, pub->topic_len); in callback_mqtt()
/foundation/systemabilitymgr/samgr_lite/communication/broadcast/source/
H A Dpub_sub_feature.h39 Topic topic; member
45 Relation *(*GetRelation)(PubSubFeature *feature, const Topic *topic);
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/publisher/include/
H A Dpublisher_item_test.h41 void OnMessage(const DHTopic topic, const std::string& message) in OnMessage() argument
43 (void)topic; in OnMessage()
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/
H A Ddistributed_hardware_service.cpp161 int32_t DistributedHardwareService::RegisterPublisherListener(const DHTopic topic, in RegisterPublisherListener() argument
164 Publisher::GetInstance().RegisterListener(topic, listener); in RegisterPublisherListener()
168 int32_t DistributedHardwareService::UnregisterPublisherListener(const DHTopic topic, in UnregisterPublisherListener() argument
171 Publisher::GetInstance().UnregisterListener(topic, listener); in UnregisterPublisherListener()
175 int32_t DistributedHardwareService::PublishMessage(const DHTopic topic, const std::string &msg) in PublishMessage() argument
178 Publisher::GetInstance().PublishMessage(topic, msg); in PublishMessage()
/third_party/libwebsockets/lib/roles/mqtt/client/
H A Dclient-mqtt.c136 if (cp->will_param.topic && in lws_create_client_mqtt_object()
137 *cp->will_param.topic) { in lws_create_client_mqtt_object()
138 c->will.topic = lws_mqtt_str_create_cstr_dup( in lws_create_client_mqtt_object()
139 cp->will_param.topic, 0); in lws_create_client_mqtt_object()
140 if (!c->will.topic) in lws_create_client_mqtt_object()
178 lws_mqtt_str_free(&c->will.topic); in lws_create_client_mqtt_object()
/foundation/distributedhardware/distributed_hardware_fwk/interfaces/inner_kits/test/unittest/common/ipc/publisher_listener_stub/include/
H A Dpublisher_listener_stub_test.h45 void OnMessage(const DHTopic topic, const std::string& message) in OnMessage() argument
47 (void)topic; in OnMessage()
/foundation/distributedhardware/distributed_hardware_fwk/interfaces/inner_kits/test/unittest/common/distributedhardwarefwkkit/include/
H A Ddistributed_hardware_fwk_kit_test.h46 void OnMessage(const DHTopic topic, const std::string& message);
47 uint32_t GetTopicMsgCnt(const DHTopic topic);
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/ipc/include/
H A Dpublisher_listener_proxy_test.h44 void OnMessage(const DHTopic topic, const std::string& message) in OnMessage() argument
46 (void)topic; in OnMessage()
/third_party/lwip/src/apps/mqtt/
H A Dmqtt.c43 * - Fix restriction of a single topic in each (UN)SUBSCRIBE message (protocol has support for multiple topics)
717 /* Should have topic and pkt id*/ in mqtt_message_received()
718 u8_t *topic; in mqtt_message_received() local
731 LWIP_DEBUGF(MQTT_DEBUG_WARN,( "mqtt_message_received: Received short PUBLISH packet (topic)\n")); in mqtt_message_received()
735 topic = var_hdr_payload + 2; in mqtt_message_received()
739 LWIP_DEBUGF(MQTT_DEBUG_WARN, ("mqtt_message_received: Receive buffer can not fit topic + pkt_id\n")); in mqtt_message_received()
754 /* Take backup of byte after topic */ in mqtt_message_received()
755 bkp = topic[topic_len]; in mqtt_message_received()
757 topic[topic_len] = 0; in mqtt_message_received()
762 LWIP_DEBUGF(MQTT_DEBUG_TRACE, ("mqtt_incomming_publish: Received message with QoS %d at topic in mqtt_message_received()
1096 mqtt_publish(mqtt_client_t *client, const char *topic, const void *payload, u16_t payload_length, u8_t qos, u8_t retain, mqtt_request_cb_t cb, void *arg) mqtt_publish() argument
1172 mqtt_sub_unsub(mqtt_client_t *client, const char *topic, u8_t qos, mqtt_request_cb_t cb, void *arg, u8_t sub) mqtt_sub_unsub() argument
[all...]
/third_party/libwebsockets/include/libwebsockets/
H A Dlws-mqtt.h105 const char *topic; member
112 const char *topic; member
127 char *topic; /* Topic Name */ member
156 lws_mqtt_topic_elem_t *topic; /* Array of topic elements */ member
351 * \param sub: which topic(s) we want to subscribe to
367 * \param sub: which topic(s) we want to unsubscribe from
/third_party/libwebsockets/minimal-examples/mqtt-client/minimal-mqtt-client-multi/
H A Dminimal-mqtt-client-multi.c32 STATE_SUBSCRIBE, /* subscribe to the topic */
60 .topic = "good/bye",
75 .topic = &topics[0],
273 pss->pub_param.topic = pss->state == STATE_PUBLISH_QOS0 ? in callback_mqtt()
275 pss->pub_param.topic_len = (uint16_t)strlen(pss->pub_param.topic); in callback_mqtt()
354 (int)(item - &items[0]), pub->topic, (int)pub->payload_pos, in callback_mqtt()
/third_party/ffmpeg/fftools/
H A Dopt_common.c576 char *topic, *par; in show_help() local
579 topic = av_strdup(arg ? arg : ""); in show_help()
580 if (!topic) in show_help()
582 par = strchr(topic, '='); in show_help()
586 if (!*topic) { in show_help()
587 show_help_default(topic, par); in show_help()
588 } else if (!strcmp(topic, "decoder")) { in show_help()
590 } else if (!strcmp(topic, "encoder")) { in show_help()
592 } else if (!strcmp(topic, "demuxer")) { in show_help()
594 } else if (!strcmp(topic, "muxe in show_help()
[all...]
/third_party/curl/lib/
H A Dmqtt.c419 char **topic, size_t *topiclen) in mqtt_get_topic()
424 result = Curl_urldecode(path + 1, 0, topic, topiclen, REJECT_NADA); in mqtt_get_topic()
426 failf(data, "Too long MQTT topic"); in mqtt_get_topic()
431 failf(data, "No MQTT topic found. Forgot to URL encode it?"); in mqtt_get_topic()
439 char *topic = NULL; in mqtt_subscribe() local
447 result = mqtt_get_topic(data, &topic, &topiclen); in mqtt_subscribe()
453 packetlen = topiclen + 5; /* packetid + topic (has a two byte length field) in mqtt_subscribe()
454 + 2 bytes topic length + QoS byte */ in mqtt_subscribe()
470 memcpy(&packet[5 + n], topic, topiclen); in mqtt_subscribe()
476 free(topic); in mqtt_subscribe()
418 mqtt_get_topic(struct Curl_easy *data, char **topic, size_t *topiclen) mqtt_get_topic() argument
518 char *topic = NULL; mqtt_publish() local
[all...]
/test/xts/acts/distributed_schedule_lite/system_ability_manager_posix/src/
H A DBroadcastPublishTest.cpp28 static void C1Callback(Consumer *consumer, const Topic *topic, const Request *request) in C1Callback() argument
31 (void)topic; in C1Callback()
33 static void C2Callback(Consumer *consumer, const Topic *topic, const Request *request) in C2Callback() argument
36 (void)topic; in C2Callback()
160 * @tc.name : Provider failed to publish broadcast for the specified topic not exist

Completed in 14 milliseconds

12345678910>>...50