| /foundation/graphic/graphic_2d/rosen/test/render_service/render_service/unittest/pipeline/ |
| H A D | rs_round_corner_display_test.cpp | 495 std::string topic = "TEST_TOPIC"; in TestMsgBusFunc() local
503 msgBus.RegisterTopic<T1>(topic, objPtr, &TestMsgBusClass::TestFunc1); in TestMsgBusFunc()
504 msgBus.RegisterTopic<T1>(topic, &obj, &TestMsgBusClass::TestFunc1); in TestMsgBusFunc()
506 msgBus.SendMsg(topic, static_cast<T1>(num1)); in TestMsgBusFunc()
507 msgBus.RemoveTopic<T1>(topic); in TestMsgBusFunc()
509 msgBus.RegisterTopic<T1, T2>(topic, &obj, &TestMsgBusClass::TestFunc2); in TestMsgBusFunc()
511 msgBus.SendMsg(topic, static_cast<T1>(num1), static_cast<T2>(num2)); in TestMsgBusFunc()
512 msgBus.RemoveTopic<T1, T2>(topic); in TestMsgBusFunc()
514 msgBus.RegisterTopic<T1, T2, T3>(topic, &obj, &TestMsgBusClass::TestFunc3); in TestMsgBusFunc()
516 msgBus.SendMsg(topic, static_cas in TestMsgBusFunc()
[all...] |
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/include/ipc/ |
| H A D | publisher_listener_proxy.h | 31 virtual void OnMessage(const DHTopic topic, const std::string& message) override;
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/fuzztest/publisheritem_fuzzer/ |
| H A D | publisheritem_fuzzer.h | 33 void OnMessage(const DHTopic topic, const std::string &message) override;
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/fuzztest/publisher_fuzzer/ |
| H A D | publisher_fuzzer.h | 34 void OnMessage(const DHTopic topic, const std::string &message) override;
|
| /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);
|
| /kernel/linux/linux-6.6/tools/perf/util/ |
| H A D | print-events.h | 14 void (*print_event)(void *print_state, const char *topic,
|
| H A D | pmu.c | 50 * @topic: Optional topic such as cache or pipeline, particularly for
53 char *topic; member
405 zfree(&newalias->topic); in perf_pmu_free_alias()
484 assign_str(pe->name, "topic", &data->alias->topic, pe->topic); in update_alias()
506 const char *long_desc = NULL, *topic = NULL, *unit = NULL, *pmu_name = NULL; in perf_pmu__new_alias() local
516 topic = pe->topic; in perf_pmu__new_alias()
[all...] |
| /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_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,
|
| /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_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_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_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()
|
| /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);
|