Home
last modified time | relevance | path

Searched refs:receivers (Results 1 - 12 of 12) sorted by relevance

/base/hiviewdfx/hiview/plugins/sysevent_source/include/
H A Devent_server.h38 int ReceiveMsg(std::vector<std::shared_ptr<EventReceiver>> &receivers) override;
58 int ReceiveMsg(std::vector<std::shared_ptr<EventReceiver>> &receivers) override;
/base/notification/common_event_service/services/src/
H A Dcommon_event_control_manager.cpp208 for (auto vec : eventRecord->receivers) { in NotifyUnorderedEventLocked()
251 eventRecord->receivers.size(), succCnt, failCnt, freezeCnt); in NotifyUnorderedEventLocked()
298 eventRecordPtr->receivers.emplace_back(subscriberRecord); in ProcessUnorderedEvent()
300 eventRecordPtr->receivers = spinstance->GetSubscriberRecords(eventRecord); in ProcessUnorderedEvent()
303 for (auto vec : eventRecordPtr->receivers) { in ProcessUnorderedEvent()
386 eventRecordPtr->receivers = subscribers; in ProcessOrderedEvent()
387 for (auto vec : eventRecordPtr->receivers) { in ProcessOrderedEvent()
453 for (auto vec : eventRecordPtr->receivers) { in EnqueueHistoryEventRecord()
466 record.receivers.emplace_back(receiver); in EnqueueHistoryEventRecord()
512 size_t receiverNum = eventRecordPtr->receivers in NotifyOrderedEvent()
[all...]
/base/hiviewdfx/hiview/core/include/
H A Ddevice_node.h42 virtual int ReceiveMsg(std::vector<std::shared_ptr<EventReceiver>> &receivers) = 0;
/base/account/os_account/services/accountmgr/include/appaccount/
H A Dapp_account_event_record.h39 std::vector<AppAccountSubscribeRecordPtr> receivers; member
/base/notification/common_event_service/services/include/
H A Dordered_event_record.h38 std::vector<std::shared_ptr<EventSubscriberRecord>> receivers; member
H A Dhistory_event_record.h66 std::vector<HistorySubscriberRecord> receivers; member
/base/hiviewdfx/hiview/plugins/sysevent_source/
H A Devent_server.cpp235 int SocketDevice::ReceiveMsg(std::vector<std::shared_ptr<EventReceiver>> &receivers) in ReceiveMsg() argument
256 for (auto receiver = receivers.begin(); receiver != receivers.end(); receiver++) { in ReceiveMsg()
315 int BBoxDevice::ReceiveMsg(std::vector<std::shared_ptr<EventReceiver>> &receivers) in ReceiveMsg() argument
323 for (auto receiver = receivers.begin(); receiver != receivers.end(); receiver++) { in ReceiveMsg()
/base/location/services/location_locator/locator/source/
H A Drequest_manager.cpp149 auto receivers = locatorAbility->GetReceivers(); in RestorRequest() local
150 if (receivers == nullptr) { in RestorRequest()
151 LBSLOGE(REQUEST_MANAGER, "receivers is empty"); in RestorRequest()
164 auto iterator = receivers->find(newCallback); in RestorRequest()
165 if (iterator == receivers->end()) { in RestorRequest()
168 receivers->insert(make_pair(newCallback, requestList)); in RestorRequest()
276 auto receivers = locatorAbility->GetReceivers(); in HandleStopLocating() local
277 if (receivers == nullptr) { in HandleStopLocating()
278 LBSLOGE(REQUEST_MANAGER, "receivers map is empty"); in HandleStopLocating()
285 auto iterator = receivers in HandleStopLocating()
[all...]
/base/notification/common_event_service/services/test/unittest/
H A Dcommon_event_freeze_unit_test.cpp275 eventRecord->receivers.emplace_back(eventSubscriberRecord); in HWTEST_F()
318 eventRecord->receivers.emplace_back(eventSubscriberRecord); in HWTEST_F()
361 eventRecord->receivers.emplace_back(eventSubscriberRecord); in HWTEST_F()
404 eventRecord->receivers.emplace_back(eventSubscriberRecord); in HWTEST_F()
H A Dcommon_event_publish_ordered_event_unit_test.cpp519 eventRecord->receivers.emplace_back(subscriberRecord); in HWTEST_F()
/base/account/os_account/services/accountmgr/src/appaccount/
H A Dapp_account_subscribe_manager.cpp264 eventRecordPtr->receivers = GetSubscribeRecords(bundleName); in PublishAccount()
287 for (auto receiver : record->receivers) { in OnAccountsChanged()
/base/notification/common_event_service/services/test/unittest/common_event_control_manager_branch_test/
H A Dcommon_event_control_manager_branch_test.cpp848 * @tc.desc: test DumpStateBySubscriberRecord and record->receivers is empty.
875 // set record->receivers is not empty in HWTEST_F()
877 record->receivers.emplace_back(rec); in HWTEST_F()
897 // set record->receivers is not empty in HWTEST_F()
899 record->receivers.emplace_back(rec); in HWTEST_F()
919 // set record->receivers is not empty in HWTEST_F()
921 record->receivers.emplace_back(rec); in HWTEST_F()
941 // set record->receivers is not empty in HWTEST_F()
943 record->receivers.emplace_back(rec); in HWTEST_F()
963 // set record.receivers i in HWTEST_F()
[all...]

Completed in 10 milliseconds