| /third_party/libwebsockets/lib/roles/mqtt/ |
| H A D | private-lib-roles-mqtt.h | 327 char topic[]; member
344 struct lws_mqtt_str_st *topic; member
443 lws_mqtt_find_sub(struct _lws_mqtt_related *mqtt, const char *topic);
|
| /device/soc/hisilicon/hi3861v100/sdk_liteos/third_party/paho.mqtt.c/include/mqtt/ |
| H A D | MQTTProtocolOut.h | 34 size_t MQTTProtocol_addressPort(const char* uri, int* port, const char **topic);
|
| H A D | SocketBuffer.h | 86 pending_writes* SocketBuffer_updateWrite(int socket, char* topic, char* payload);
|
| /foundation/distributedhardware/distributed_hardware_fwk/common/utils/include/ |
| H A D | ipublisher_listener.h | 27 // Topic min border, not use for real topic
43 // Topic max border, not use for real topic
50 virtual void OnMessage(const DHTopic topic, const std::string& message) = 0;
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/include/publisher/ |
| H A D | publisher_item.h | 33 explicit PublisherItem(DHTopic topic);
|
| /third_party/gn/src/gn/ |
| H A D | standard_out.h | 35 const std::string& topic,
|
| /foundation/distributedhardware/distributed_screen/services/screenservice/sourceservice/dscreenmgr/2.0/src/ |
| H A D | dscreen_manager.cpp | 369 void DScreenManager::PublishMessage(const DHTopic topic, const std::shared_ptr<DScreen> &dScreen) in PublishMessage() argument
378 if (topic == DHTopic::TOPIC_START_DSCREEN) { in PublishMessage()
389 } else if (topic == DHTopic::TOPIC_STOP_DSCREEN) { in PublishMessage()
394 DScreenFwkKit::GetInstance().GetDHFwkKit()->PublishMessage(topic, message); in PublishMessage()
|
| /test/xts/acts/distributed_schedule_lite/system_ability_manager_hal/src/ |
| H A D | broadcast_subscribe_func_test.c | 28 static void C1Callback(Consumer *consumer, const Topic *topic, const Request *request)
in C1Callback() argument
31 (void)topic;
in C1Callback()
34 static void C2Callback(Consumer *consumer, const Topic *topic, const Request *request)
in C2Callback() argument
37 (void)topic;
in C2Callback()
125 * @tc.name : Valid topic can be added successfully
176 * @tc.name : Consumer can subscribe to a topic
203 * @tc.name : Consumer can not subscribe to the topic which is NULL or does not exist
228 * @tc.name : Consumer which is NULL can not subscribe to a topic
255 * @tc.name : Consumer can not subscribe to the same topic twice
283 * @tc.name : Consumer can unsubscribe a topic
[all...] |
| /foundation/distributedhardware/distributed_input/services/sink/sinkmanager/include/ |
| H A D | distributed_input_sink_manager.h | 98 void OnMessage(const DHTopic topic, const std::string &message) override;
118 void OnMessage(const DHTopic topic, const std::string &message) override;
|
| /foundation/distributedhardware/distributed_screen/services/screenservice/test/unittest/sinkservice/screenregionmgr/1.0/src/ |
| H A D | screenregionmgr_test.cpp | 99 DHTopic topic = DHTopic::TOPIC_SINK_PROJECT_WINDOW_INFO; in HWTEST_F() local
106 ScreenRegionManager::GetInstance().PublishMessage(topic, screenId, remoteDevId, windowId, windowProperty); in HWTEST_F()
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/include/ |
| H A D | distributed_hardware_stub.h | 45 bool ValidTopic(uint32_t topic);
|
| /foundation/distributedhardware/distributed_hardware_fwk/interfaces/inner_kits/test/fuzztest/distributedhardwarefwkstub_fuzzer/ |
| H A D | distributedhardwarefwkstub_fuzzer.cpp | 35 void OnMessage(const DHTopic topic, const std::string& message) override
|
| /foundation/distributedhardware/distributed_screen/services/screenservice/sinkservice/screenregionmgr/1.0/include/ |
| H A D | screenregionmgr.h | 37 void PublishMessage(const DHTopic topic, const uint64_t &screenId, const std::string &remoteDevId,
|
| /third_party/libuv/docs/src/sphinx-plugins/ |
| H A D | manpage.py | 24 ref = s.substitute(num=manpage_num, topic=name)
|
| /foundation/distributedhardware/distributed_screen/services/screenservice/sourceservice/dscreenmgr/1.0/src/ |
| H A D | dscreen_manager.cpp | 448 void DScreenManager::PublishMessage(const DHTopic topic, const std::shared_ptr<DScreen> &dScreen) in PublishMessage() argument
458 if (topic == DHTopic::TOPIC_START_DSCREEN) { in PublishMessage()
469 } else if (topic == DHTopic::TOPIC_STOP_DSCREEN) { in PublishMessage()
475 DScreenFwkKit::GetInstance().GetDHFwkKit()->PublishMessage(topic, message); in PublishMessage()
|
| /test/xts/acts/distributed_schedule_lite/system_ability_manager_posix/src/ |
| H A D | BroadcastSubscribeTest.cpp | 27 static void C1Callback(Consumer *consumer, const Topic *topic, const Request *request) in C1Callback() argument
30 (void)topic; in C1Callback()
32 static void C2Callback(Consumer *consumer, const Topic *topic, const Request *request) in C2Callback() argument
35 (void)topic; in C2Callback()
125 * @tc.name : Valid topic can be added successfully
176 * @tc.name : Consumer can subscribe to a topic
203 * @tc.name : Consumer can not subscribe to the topic which is nullptr or does not exist
232 * @tc.name : Consumer which is nullptr can not subscribe to a topic
259 * @tc.name : Consumer can not subscribe to the same topic twice
287 * @tc.name : Consumer can unsubscribe a topic
[all...] |
| /foundation/distributedhardware/distributed_screen/services/screenservice/sinkservice/screenregionmgr/2.0/include/ |
| H A D | screenregion.h | 62 void PublishMessage(const DHTopic topic, const uint64_t &screenId, const std::string &remoteDevId,
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/utils/ |
| H A D | dh_context.cpp | 356 void DHContext::DHFWKIsomerismListener::OnMessage(const DHTopic topic, const std::string &message) in OnMessage() argument
361 DHLOGI("OnMessage topic: %{public}u", static_cast<uint32_t>(topic)); in OnMessage()
362 if (topic != DHTopic::TOPIC_ISOMERISM) { in OnMessage()
363 DHLOGE("OnMessage topic is wrong"); in OnMessage()
|
| /third_party/lz4/tests/ |
| H A D | test-lz4-speed.py | 76 def send_email(emails, topic, text, have_mutt, have_mail):
82 execute('mutt -s "' + topic + '" ' + emails + ' < ' + logFileName, verbose)
84 execute('mail -s "' + topic + '" ' + emails + ' < ' + logFileName, verbose)
|
| /vendor/hisilicon/hispark_pegasus/demo/oc_demo/ |
| H A D | app_demo_iot.c | 129 static void DemoMsgRcvCallBack(int qos, const char *topic, char *payload) in DemoMsgRcvCallBack() argument
134 IOT_LOG_DEBUG("RCVMSG:QOS:%d TOPIC:%s PAYLOAD:%s\r\n", qos, topic, payload); in DemoMsgRcvCallBack()
137 tmp = strstr(topic, CN_COMMAND_INDEX); in DemoMsgRcvCallBack()
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/distributedhardwarestub/src/ |
| H A D | distributed_hardware_stub_test.cpp | 329 uint32_t topic = static_cast<uint32_t>(DHTopic::TOPIC_MIN); in HWTEST_F() local
330 EXPECT_EQ(false, stubTest_->ValidTopic(topic)); in HWTEST_F()
|
| /foundation/distributedhardware/distributed_screen/services/screenservice/sinkservice/screenregionmgr/1.0/src/ |
| H A D | screenregionmgr.cpp | 251 void ScreenRegionManager::PublishMessage(const DHTopic topic, const uint64_t &screenId, in PublishMessage() argument
271 DScreenFwkKit::GetInstance().GetDHFwkKit()->PublishMessage(topic, message); in PublishMessage()
|
| /foundation/distributedhardware/distributed_input/services/sink/sinkmanager/src/ |
| H A D | distributed_input_sink_manager.cpp | 787 void DistributedInputSinkManager::ProjectWindowListener::OnMessage(const DHTopic topic, const std::string &message) in OnMessage() argument
790 if (topic != DHTopic::TOPIC_SINK_PROJECT_WINDOW_INFO) { in OnMessage()
791 DHLOGE("this topic is wrong, %{public}u", static_cast<uint32_t>(topic)); in OnMessage()
923 void DistributedInputSinkManager::PluginStartListener::OnMessage(const DHTopic topic, in OnMessage() argument
927 if (topic != DHTopic::TOPIC_PHY_DEV_PLUGIN) { in OnMessage()
928 DHLOGE("this topic is wrong, %{public}u", static_cast<uint32_t>(topic)); in OnMessage()
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/fuzztest/distributedfwkservices_fuzzer/ |
| H A D | distributedfwkservices_fuzzer.cpp | 46 void OnMessage(const DHTopic topic, const std::string& message) override
|
| /foundation/distributedhardware/distributed_screen/services/screenservice/sourceservice/dscreenmgr/1.0/include/ |
| H A D | dscreen_manager.h | 67 void PublishMessage(const DHTopic topic, const std::shared_ptr<DScreen> &dScreen);
|