/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/lowlatency/lowlatencylistener/src/ |
H A D | low_latency_listener_test.cpp | 52 DHTopic topic = DHTopic::TOPIC_MIN; variable 69 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; variable 86 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; variable 103 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; variable 136 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; variable 155 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; variable 187 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; variable
|
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/interfaces/inner_kits/test/unittest/common/ipc/distributed_hardware_proxy/src/ |
H A D | distributed_hardware_proxy_test.cpp | 52 DHTopic topic = DHTopic::TOPIC_STOP_DSCREEN; variable 70 DHTopic topic = static_cast<DHTopic>(invalid); variable 87 DHTopic topic = DHTopic::TOPIC_STOP_DSCREEN; variable 104 DHTopic topic = DHTopic::TOPIC_STOP_DSCREEN; variable 122 DHTopic topic = static_cast<DHTopic>(invalid); variable 139 DHTopic topic = DHTopic::TOPIC_STOP_DSCREEN; variable 158 DHTopic topic = static_cast<DHTopic>(invalid); variable 174 DHTopic topic = DHTopic::TOPIC_STOP_DSCREEN; variable 191 DHTopic topic = DHTopic::TOPIC_STOP_DSCREEN; variable
|
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/interfaces/inner_kits/test/unittest/common/distributedhardwarefwkkit/src/ |
H A D | distributed_hardware_fwk_kit_test.cpp | 64 void DistributedHardwareFwkKitTest::TestPublisherListener::OnMessage(const DHTopic topic, const std… in OnMessage() 70 uint32_t DistributedHardwareFwkKitTest::TestPublisherListener::GetTopicMsgCnt(const DHTopic topic) in GetTopicMsgCnt() 128 DHTopic topic = static_cast<DHTopic>(invalid); variable 144 DHTopic topic = DHTopic::TOPIC_STOP_DSCREEN; variable 160 DHTopic topic = DHTopic::TOPIC_STOP_DSCREEN; variable 176 DHTopic topic = DHTopic::TOPIC_STOP_DSCREEN; variable 210 DHTopic topic = DHTopic::TOPIC_MIN; variable 227 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; variable 244 DHTopic topic = DHTopic::TOPIC_MIN; variable 261 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; variable
|
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/publisher/ |
H A D | publisher.cpp | 39 void Publisher::RegisterListener(const DHTopic topic, const sptr<IPublisherListener> listener) in RegisterListener() 44 void Publisher::UnregisterListener(const DHTopic topic, const sptr<IPublisherListener> listener) in UnregisterListener() 49 void Publisher::PublishMessage(const DHTopic topic, const std::string &message) in PublishMessage()
|
H A D | publisher_item.cpp | 28 PublisherItem::PublisherItem(DHTopic topic) : topic_(topic) in PublisherItem()
|
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/ipc/src/ |
H A D | publisher_listener_proxy_test.cpp | 53 DHTopic topic = static_cast<DHTopic>(invalid); variable 70 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; variable 87 DHTopic topic = DHTopic::TOPIC_START_DSCREEN; variable
|
/ohos5.0/foundation/systemabilitymgr/samgr_lite/communication/broadcast/source/ |
H A D | pub_sub_implement.c | 47 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
|
H A D | pub_sub_feature.c | 74 Topic topic = request->msgValue; in OnMessage() local 95 static Relation *GetRelation(PubSubFeature *feature, const Topic *topic) in GetRelation()
|
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/interfaces/inner_kits/test/unittest/common/ipc/distributed_hardware_proxy/include/ |
H A D | distributed_hardware_proxy_test.h | 47 int32_t RegisterPublisherListener(const DHTopic topic, const sptr<IPublisherListener> listener) in RegisterPublisherListener() 54 … int32_t UnregisterPublisherListener(const DHTopic topic, const sptr<IPublisherListener> listener) in UnregisterPublisherListener() 61 int32_t PublishMessage(const DHTopic topic, const std::string &msg) in PublishMessage() 137 void OnMessage(const DHTopic topic, const std::string& message) in OnMessage()
|
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/interfaces/inner_kits/src/ |
H A D | distributed_hardware_fwk_kit.cpp | 43 int32_t DistributedHardwareFwkKit::RegisterPublisherListener(const DHTopic topic, sptr<IPublisherLi… in RegisterPublisherListener() 67 int32_t DistributedHardwareFwkKit::UnregisterPublisherListener(const DHTopic topic, sptr<IPublisher… in UnregisterPublisherListener() 86 int32_t DistributedHardwareFwkKit::PublishMessage(const DHTopic topic, const std::string &message) in PublishMessage() 108 bool DistributedHardwareFwkKit::IsDHTopicValid(DHTopic topic) in IsDHTopicValid()
|
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/interfaces/inner_kits/test/unittest/common/ipc/dhfwk_sa_manager/include/ |
H A D | dhfwk_sa_manager_test.h | 46 int32_t RegisterPublisherListener(const DHTopic topic, const sptr<IPublisherListener> listener) in RegisterPublisherListener() 53 int32_t UnregisterPublisherListener(const DHTopic topic, const sptr<IPublisherListener> listener) in UnregisterPublisherListener() 60 int32_t PublishMessage(const DHTopic topic, const std::string &msg) in PublishMessage()
|
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/distributedhardwarestub/include/ |
H A D | distributed_hardware_stub_test.h | 38 int32_t RegisterPublisherListener(const DHTopic topic, const sptr<IPublisherListener> listener) in RegisterPublisherListener() 45 int32_t UnregisterPublisherListener(const DHTopic topic, const sptr<IPublisherListener> listener) in UnregisterPublisherListener() 52 int32_t PublishMessage(const DHTopic topic, const std::string &msg) in PublishMessage()
|
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/fuzztest/publisher_fuzzer/ |
H A D | publisher_fuzzer.cpp | 38 void MockPublisherListener::OnMessage(const DHTopic topic, const std::string &message) in OnMessage() 60 DHTopic topic = topicFuzz[data[0] % TOPIC_SIZE]; in PublisherListenerFuzzTest() local
|
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/fuzztest/publisheritem_fuzzer/ |
H A D | publisheritem_fuzzer.cpp | 38 void MockPublisherItemListener::OnMessage(const DHTopic topic, const std::string &message) in OnMessage() 60 DHTopic topic = topicFuzz[data[0] % TOPIC_SIZE]; in PublisherItemFuzzTest() local
|
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/interfaces/inner_kits/test/unittest/common/ipc/publisher_listener_stub/include/ |
H A D | publisher_listener_stub_test.h | 45 void OnMessage(const DHTopic topic, const std::string& message) in OnMessage()
|
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/distributedhardwareservice/include/ |
H A D | mock_publisher_listener.h | 27 void OnMessage(const DHTopic topic, const std::string& message) in OnMessage()
|
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/publisher/include/ |
H A D | publisher_item_test.h | 41 void OnMessage(const DHTopic topic, const std::string& message) in OnMessage()
|
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/interfaces/inner_kits/test/fuzztest/distributedhardwarefwkkit_fuzzer/ |
H A D | distributedhardwarefwkkit_fuzzer.cpp | 37 void TestPublisherListener::OnMessage(const DHTopic topic, const std::string &message) in OnMessage() 51 DHTopic topic = static_cast<DHTopic>(*(reinterpret_cast<const uint32_t*>(data))); in RegisterPublisherListenerFuzzTest() local 64 DHTopic topic = static_cast<DHTopic>(*(reinterpret_cast<const uint32_t*>(data))); in PublishMessageFuzzTest() local 78 DHTopic topic = static_cast<DHTopic>(*(reinterpret_cast<const uint32_t*>(data))); in UnregisterPublisherListenerFuzzTest() local
|
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/interfaces/inner_kits/src/ipc/ |
H A D | publisher_listener_stub.cpp | 42 DHTopic topic = static_cast<DHTopic>(data.ReadUint32()); in OnRemoteRequest() local
|
H A D | dhfwk_sa_manager.cpp | 180 int32_t DHFWKSAManager::AddPublisherListenerToCache(const DHTopic topic, sptr<IPublisherListener> l… in AddPublisherListenerToCache() 192 void DHFWKSAManager::RemovePublisherListenerFromCache(const DHTopic topic, sptr<IPublisherListener>… in RemovePublisherListenerFromCache()
|
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/lowlatency/ |
H A D | low_latency_listener.cpp | 39 void LowLatencyListener::OnMessage(const DHTopic topic, const std::string& message) in OnMessage()
|
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/ |
H A D | distributed_hardware_stub.cpp | 104 DHTopic topic = (DHTopic)topicInt; in RegisterPublisherListenerInner() local 131 DHTopic topic = (DHTopic)topicInt; in UnregisterPublisherListenerInner() local 158 DHTopic topic = (DHTopic)topicInt; in PublishMessageInner() local 316 bool DistributedHardwareStub::ValidTopic(uint32_t topic) in ValidTopic()
|
H A D | distributed_hardware_service.cpp | 161 int32_t DistributedHardwareService::RegisterPublisherListener(const DHTopic topic, in RegisterPublisherListener() 168 int32_t DistributedHardwareService::UnregisterPublisherListener(const DHTopic topic, in UnregisterPublisherListener() 175 int32_t DistributedHardwareService::PublishMessage(const DHTopic topic, const std::string &msg) in PublishMessage()
|
/ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/ipc/ |
H A D | publisher_listener_proxy.cpp | 32 void PublisherListenerProxy::OnMessage(const DHTopic topic, const std::string& message) in OnMessage()
|
/ohos5.0/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 in OnMessage()
|