| /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,
|
| /kernel/linux/linux-6.6/tools/perf/pmu-events/ |
| H A D | pmu-events.h | 46 const char *topic; member
|
| /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);
|
| /foundation/distributedhardware/distributed_screen/services/screenservice/sourceservice/dscreenmgr/2.0/include/ |
| H A D | dscreen_manager.h | 75 void PublishMessage(const DHTopic topic, const std::shared_ptr<DScreen> &dScreen);
|
| /kernel/linux/linux-5.10/tools/perf/util/ |
| H A D | pmu.h | 64 char *topic; member
|
| /device/soc/hisilicon/hi3861v100/sdk_liteos/third_party/paho.mqtt.c/include/mqtt/ |
| H A D | MQTTPacket.h | 125 *willTopic, /**< will topic */
203 char* topic; /**< topic string */ member
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/include/utils/ |
| H A D | dh_context.h | 132 void OnMessage(const DHTopic topic, const std::string &message) override;
|
| /kernel/linux/linux-6.6/tools/perf/util/ |
| H A D | pmu.h | 184 const char *topic; member
|
| /third_party/libwebsockets/include/libwebsockets/ |
| H A D | lws-secure-streams-policy.h | 309 const char *topic; /* stream sends on this topic */ member
310 const char *subscribe; /* stream subscribes to this topic */
|
| /foundation/distributedhardware/distributed_input/services/source/sourcemanager/src/ |
| H A D | distributed_input_source_manager.cpp | 1562 void DistributedInputSourceManager::StartDScreenListener::OnMessage(const DHTopic topic, const std::string &message) in OnMessage() argument
1565 if (topic != DHTopic::TOPIC_START_DSCREEN) { in OnMessage()
1566 DHLOGE("this topic is wrong, %{public}d", static_cast<uint32_t>(topic)); in OnMessage()
1674 void DistributedInputSourceManager::StopDScreenListener::OnMessage(const DHTopic topic, const std::string &message) in OnMessage() argument
1677 if (topic != DHTopic::TOPIC_STOP_DSCREEN) { in OnMessage()
1678 DHLOGE("this topic is wrong, %{public}u", static_cast<uint32_t>(topic)); in OnMessage()
1742 void DistributedInputSourceManager::DeviceOfflineListener::OnMessage(const DHTopic topic, const std::string &message) in OnMessage() argument
1745 if (topic ! in OnMessage()
[all...] |
| /foundation/distributedhardware/distributed_screen/services/screenservice/sinkservice/screenregionmgr/2.0/src/ |
| H A D | screenregion.cpp | 264 void ScreenRegion::PublishMessage(const DHTopic topic, const uint64_t &screenId, in PublishMessage() argument
288 DScreenFwkKit::GetInstance().GetDHFwkKit()->PublishMessage(topic, message); in PublishMessage()
|
| /third_party/libwebsockets/lib/roles/mqtt/ |
| H A D | ops-mqtt.c | 466 lws_mqtt_str_free(&c->will.topic); in rops_close_role_mqtt()
493 lws_free_set_NULL(pub->topic); in rops_close_role_mqtt()
|
| /foundation/distributedhardware/distributed_input/services/source/sourcemanager/include/ |
| H A D | distributed_input_source_manager.h | 204 void OnMessage(const DHTopic topic, const std::string &message) override;
215 void OnMessage(const DHTopic topic, const std::string &message) override;
226 void OnMessage(const DHTopic topic, const std::string &message) override;
|
| /third_party/gn/src/gn/ |
| H A D | command_check.cc | 50 The topic "gn help check" has general information on how checking works and
|