Home
last modified time | relevance | path

Searched refs:topic (Results 76 - 100 of 1265) sorted by relevance

12345678910>>...51

/third_party/libwebsockets/lib/roles/mqtt/
H A Dprivate-lib-roles-mqtt.h327 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 DMQTTProtocolOut.h34 size_t MQTTProtocol_addressPort(const char* uri, int* port, const char **topic);
H A DSocketBuffer.h86 pending_writes* SocketBuffer_updateWrite(int socket, char* topic, char* payload);
/foundation/distributedhardware/distributed_hardware_fwk/common/utils/include/
H A Dipublisher_listener.h27 // 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 Dpublisher_item.h33 explicit PublisherItem(DHTopic topic);
/third_party/gn/src/gn/
H A Dstandard_out.h35 const std::string& topic,
/foundation/distributedhardware/distributed_screen/services/screenservice/sourceservice/dscreenmgr/2.0/src/
H A Ddscreen_manager.cpp369 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 Dbroadcast_subscribe_func_test.c28 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 Ddistributed_input_sink_manager.h98 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 Dscreenregionmgr_test.cpp99 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 Ddistributed_hardware_stub.h45 bool ValidTopic(uint32_t topic);
/foundation/distributedhardware/distributed_hardware_fwk/interfaces/inner_kits/test/fuzztest/distributedhardwarefwkstub_fuzzer/
H A Ddistributedhardwarefwkstub_fuzzer.cpp35 void OnMessage(const DHTopic topic, const std::string& message) override
/foundation/distributedhardware/distributed_screen/services/screenservice/sinkservice/screenregionmgr/1.0/include/
H A Dscreenregionmgr.h37 void PublishMessage(const DHTopic topic, const uint64_t &screenId, const std::string &remoteDevId,
/third_party/libuv/docs/src/sphinx-plugins/
H A Dmanpage.py24 ref = s.substitute(num=manpage_num, topic=name)
/foundation/distributedhardware/distributed_screen/services/screenservice/sourceservice/dscreenmgr/1.0/src/
H A Ddscreen_manager.cpp448 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 DBroadcastSubscribeTest.cpp27 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 Dscreenregion.h62 void PublishMessage(const DHTopic topic, const uint64_t &screenId, const std::string &remoteDevId,
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/utils/
H A Ddh_context.cpp356 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 Dtest-lz4-speed.py76 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 Dapp_demo_iot.c129 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 Ddistributed_hardware_stub_test.cpp329 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 Dscreenregionmgr.cpp251 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 Ddistributed_input_sink_manager.cpp787 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 Ddistributedfwkservices_fuzzer.cpp46 void OnMessage(const DHTopic topic, const std::string& message) override
/foundation/distributedhardware/distributed_screen/services/screenservice/sourceservice/dscreenmgr/1.0/include/
H A Ddscreen_manager.h67 void PublishMessage(const DHTopic topic, const std::shared_ptr<DScreen> &dScreen);

Completed in 19 milliseconds

12345678910>>...51