Home
last modified time | relevance | path

Searched defs:topic (Results 1 – 25 of 34) sorted by relevance

12

/foundation/distributedhardware/distributed_hardware_fwk/interfaces/inner_kits/test/unittest/common/ipc/distributed_hardware_proxy/src/
Ddistributed_hardware_proxy_test.cpp49 DHTopic topic = DHTopic::TOPIC_STOP_DSCREEN; variable
64 DHTopic topic = static_cast<DHTopic>(invalid); variable
78 DHTopic topic = DHTopic::TOPIC_STOP_DSCREEN; variable
92 DHTopic topic = DHTopic::TOPIC_STOP_DSCREEN; variable
107 DHTopic topic = static_cast<DHTopic>(invalid); variable
121 DHTopic topic = DHTopic::TOPIC_STOP_DSCREEN; variable
137 DHTopic topic = static_cast<DHTopic>(invalid); variable
150 DHTopic topic = DHTopic::TOPIC_STOP_DSCREEN; variable
164 DHTopic topic = DHTopic::TOPIC_STOP_DSCREEN; variable
/foundation/distributedhardware/distributed_hardware_fwk/interfaces/inner_kits/test/unittest/common/distributedhardwarefwkkit/src/
Ddistributed_hardware_fwk_kit_test.cpp64 void DistributedHardwareFwkKitTest::TestPublisherListener::OnMessage(const DHTopic topic, const std… in OnMessage()
70 uint32_t DistributedHardwareFwkKitTest::TestPublisherListener::GetTopicMsgCnt(const DHTopic topic) in GetTopicMsgCnt()
122 DHTopic topic = static_cast<DHTopic>(invalid); variable
135 DHTopic topic = DHTopic::TOPIC_STOP_DSCREEN; variable
148 DHTopic topic = DHTopic::TOPIC_STOP_DSCREEN; variable
161 DHTopic topic = DHTopic::TOPIC_STOP_DSCREEN; variable
190 DHTopic topic = static_cast<DHTopic>(invalid); variable
204 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; variable
219 DHTopic topic = static_cast<DHTopic>(invalid); variable
233 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; variable
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/lowlatency/lowlatencylistener/src/
Dlow_latency_listener_test.cpp49 DHTopic topic = DHTopic::TOPIC_MIN; variable
63 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; variable
77 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; variable
91 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; variable
112 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; variable
128 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; variable
148 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; variable
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/publisher/
Dpublisher.cpp36 void Publisher::RegisterListener(const DHTopic topic, const sptr<IPublisherListener> &listener) in RegisterListener()
41 void Publisher::UnregisterListener(const DHTopic topic, const sptr<IPublisherListener> &listener) in UnregisterListener()
46 void Publisher::PublishMessage(const DHTopic topic, const std::string &message) in PublishMessage()
Dpublisher_item.cpp26 PublisherItem::PublisherItem(DHTopic topic) : topic_(topic) in PublisherItem()
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/ipc/src/
Dpublisher_listener_proxy_test.cpp50 DHTopic topic = static_cast<DHTopic>(invalid); variable
64 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; variable
78 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; variable
/foundation/systemabilitymgr/samgr_lite/communication/broadcast/source/
Dpub_sub_implement.c47 static int AddTopic(IUnknown *iUnknown, const Topic *topic) in AddTopic()
77 static int Subscribe(IUnknown *iUnknown, const Topic *topic, Consumer *consumer) in Subscribe()
116 static Consumer *ModifyConsumer(IUnknown *iUnknown, const Topic *topic, Consumer *oldConsumer, Cons… in ModifyConsumer()
146 static Consumer *Unsubscribe(IUnknown *iUnknown, const Topic *topic, const Consumer *consumer) in Unsubscribe()
178 static BOOL Publish(IUnknown *iUnknown, const Topic *topic, uint8 *data, int16 len) in Publish()
206 static BOOL ImmediatelyPublish(PubSubFeature *feature, const Topic *topic, const Request *request) in ImmediatelyPublish()
255 Topic topic = request->msgValue; in DefaultHandle() local
Dpub_sub_feature.c74 Topic topic = request->msgValue; in OnMessage() local
95 static Relation *GetRelation(PubSubFeature *feature, const Topic *topic) in GetRelation()
/foundation/distributedhardware/distributed_hardware_fwk/interfaces/inner_kits/test/unittest/common/ipc/distributed_hardware_proxy/include/
Ddistributed_hardware_proxy_test.h49 int32_t RegisterPublisherListener(const DHTopic topic, const sptr<IPublisherListener> &listener) in RegisterPublisherListener()
56 … int32_t UnregisterPublisherListener(const DHTopic topic, const sptr<IPublisherListener> &listener) in UnregisterPublisherListener()
63 int32_t PublishMessage(const DHTopic topic, const std::string &msg) in PublishMessage()
118 void OnMessage(const DHTopic topic, const std::string& message) in OnMessage()
/foundation/distributedhardware/distributed_hardware_fwk/interfaces/inner_kits/test/unittest/common/ipc/dhfwk_sa_manager/include/
Ddhfwk_sa_manager_test.h48 int32_t RegisterPublisherListener(const DHTopic topic, const sptr<IPublisherListener> &listener) in RegisterPublisherListener()
55 int32_t UnregisterPublisherListener(const DHTopic topic, const sptr<IPublisherListener> &listener) in UnregisterPublisherListener()
62 int32_t PublishMessage(const DHTopic topic, const std::string &msg) in PublishMessage()
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/distributedhardwarestub/include/
Ddistributed_hardware_stub_test.h40 int32_t RegisterPublisherListener(const DHTopic topic, const sptr<IPublisherListener> &listener) in RegisterPublisherListener()
47 int32_t UnregisterPublisherListener(const DHTopic topic, const sptr<IPublisherListener> &listener) in UnregisterPublisherListener()
54 int32_t PublishMessage(const DHTopic topic, const std::string &msg) in PublishMessage()
/foundation/distributedhardware/distributed_hardware_fwk/interfaces/inner_kits/src/
Ddistributed_hardware_fwk_kit.cpp42 int32_t DistributedHardwareFwkKit::RegisterPublisherListener(const DHTopic topic, sptr<IPublisherLi… in RegisterPublisherListener()
68 int32_t DistributedHardwareFwkKit::UnregisterPublisherListener(const DHTopic topic, sptr<IPublisher… in UnregisterPublisherListener()
88 int32_t DistributedHardwareFwkKit::PublishMessage(const DHTopic topic, const std::string &message) in PublishMessage()
111 bool DistributedHardwareFwkKit::IsDHTopicValid(DHTopic topic) in IsDHTopicValid()
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/fuzztest/publisher_fuzzer/
Dpublisher_fuzzer.cpp38 void MockPublisherListener::OnMessage(const DHTopic topic, const std::string &message) in OnMessage()
60 DHTopic topic = topicFuzz[data[0] % TOPIC_SIZE]; in PublisherListenerFuzzTest() local
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/fuzztest/publisheritem_fuzzer/
Dpublisheritem_fuzzer.cpp38 void MockPublisherItemListener::OnMessage(const DHTopic topic, const std::string &message) in OnMessage()
60 DHTopic topic = topicFuzz[data[0] % TOPIC_SIZE]; in PublisherItemFuzzTest() local
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/distributedhardwareservice/include/
Dmock_publisher_listener.h27 void OnMessage(const DHTopic topic, const std::string& message) in OnMessage()
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/
Ddistributed_hardware_stub.cpp81 DHTopic topic = (DHTopic)topicInt; in RegisterPublisherListenerInner() local
103 DHTopic topic = (DHTopic)topicInt; in UnregisterPublisherListenerInner() local
125 DHTopic topic = (DHTopic)topicInt; in PublishMessageInner() local
220 bool DistributedHardwareStub::ValidTopic(uint32_t topic) in ValidTopic()
Ddistributed_hardware_service.cpp100 int32_t DistributedHardwareService::RegisterPublisherListener(const DHTopic topic, in RegisterPublisherListener()
107 int32_t DistributedHardwareService::UnregisterPublisherListener(const DHTopic topic, in UnregisterPublisherListener()
114 int32_t DistributedHardwareService::PublishMessage(const DHTopic topic, const std::string &msg) in PublishMessage()
/foundation/distributedhardware/distributed_hardware_fwk/interfaces/inner_kits/test/unittest/common/ipc/publisher_listener_stub/include/
Dpublisher_listener_stub_test.h47 void OnMessage(const DHTopic topic, const std::string& message) in OnMessage()
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/publisher/include/
Dpublisher_item_test.h43 void OnMessage(const DHTopic topic, const std::string& message) in OnMessage()
/foundation/distributedhardware/distributed_hardware_fwk/interfaces/inner_kits/src/ipc/
Dpublisher_listener_stub.cpp42 DHTopic topic = static_cast<DHTopic>(data.ReadUint32()); in OnRemoteRequest() local
Ddistributed_hardware_proxy.cpp39 int32_t DistributedHardwareProxy::RegisterPublisherListener(const DHTopic topic, in RegisterPublisherListener()
88 int32_t DistributedHardwareProxy::UnregisterPublisherListener(const DHTopic topic, in UnregisterPublisherListener()
137 int32_t DistributedHardwareProxy::PublishMessage(const DHTopic topic, const std::string &msg) in PublishMessage()
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/lowlatency/
Dlow_latency_listener.cpp39 void LowLatencyListener::OnMessage(const DHTopic topic, const std::string& message) in OnMessage()
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/ipc/
Dpublisher_listener_proxy.cpp31 void PublisherListenerProxy::OnMessage(const DHTopic topic, const std::string& message) in OnMessage()
/foundation/distributedhardware/distributed_hardware_fwk/interfaces/inner_kits/test/fuzztest/distributedhardwarefwkkit_fuzzer/
Ddistributedhardwarefwkkit_fuzzer.cpp43 void TestPublisherListener::OnMessage(const DHTopic topic, const std::string &message) in OnMessage()
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/ipc/include/
Dpublisher_listener_proxy_test.h46 void OnMessage(const DHTopic topic, const std::string& message) in OnMessage()

12