| /base/notification/common_event_service/services/src/ |
| D | common_event_control_manager.cpp | 65 …nst CommonEventRecord &eventRecord, const std::shared_ptr<EventSubscriberRecord> &subscriberRecord) in PublishStickyCommonEvent() argument
70 if (!subscriberRecord) { in PublishStickyCommonEvent()
74 return ProcessUnorderedEvent(eventRecord, subscriberRecord); in PublishStickyCommonEvent()
117 EventSubscriberRecord subscriberRecord = record.first; in PublishFrozenEventsInner() local
120 auto innerCallback = [weak, subscriberRecord, eventRecord]() { in PublishFrozenEventsInner()
126 control->NotifyFreezeEvents(subscriberRecord, eventRecord); in PublishFrozenEventsInner()
134 const EventSubscriberRecord &subscriberRecord, const CommonEventRecord &eventRecord) in NotifyFreezeEvents() argument
138 …sptr<IEventReceive> commonEventListenerProxy = iface_cast<IEventReceive>(subscriberRecord.commonEv… in NotifyFreezeEvents()
144 int8_t ret = CheckPermission(subscriberRecord, eventRecord); in NotifyFreezeEvents()
156 subscriberRecord.eventRecordInfo.bundleName.c_str(), in NotifyFreezeEvents()
[all …]
|
| D | inner_common_event_manager.cpp | 390 …_ptr<CommonEventSubscribeInfo> &sp, const std::shared_ptr<EventSubscriberRecord> &subscriberRecord) in PublishStickyEvent() argument
400 if (!subscriberRecord) { in PublishStickyEvent()
419 … commonEventRecord->publishInfo->GetBundleName() != subscriberRecord->eventRecordInfo.bundleName) { in PublishStickyEvent()
430 controlPtr_->PublishStickyCommonEvent(*commonEventRecord, subscriberRecord); in PublishStickyEvent()
492 …auto subscriberRecord = DelayedSingleton<CommonEventSubscriberManager>::GetInstance()->GetSubscrib… in SendUnSubscribeHiSysEvent() local
494 if (subscriberRecord == nullptr) { in SendUnSubscribeHiSysEvent()
499 if (subscriberRecord->eventSubscribeInfo != nullptr) { in SendUnSubscribeHiSysEvent()
500 eventInfo.userId = subscriberRecord->eventSubscribeInfo->GetUserId(); in SendUnSubscribeHiSysEvent()
501 …std::vector<std::string> events = subscriberRecord->eventSubscribeInfo->GetMatchingSkills().GetEve… in SendUnSubscribeHiSysEvent()
507 eventInfo.subscriberName = subscriberRecord->eventRecordInfo.bundleName; in SendUnSubscribeHiSysEvent()
[all …]
|
| D | common_event_subscriber_manager.cpp | 455 const SubscriberRecordPtr &subscriberRecord, const CommonEventRecord &eventRecord) in InsertFrozenEvents() argument
459 if (subscriberRecord == nullptr) { in InsertFrozenEvents()
466 auto frozenRecordsItem = frozenEvents_.find(subscriberRecord->eventRecordInfo.uid); in InsertFrozenEvents()
468 auto eventRecordsItem = frozenRecordsItem->second.find(*subscriberRecord); in InsertFrozenEvents()
480 frozenRecordsItem->second[*subscriberRecord] = EventRecords; in InsertFrozenEvents()
486 frozenRecords[*subscriberRecord] = EventRecords; in InsertFrozenEvents()
487 frozenEvents_[subscriberRecord->eventRecordInfo.uid] = frozenRecords; in InsertFrozenEvents()
524 …EventSubscriberManager::RemoveFrozenEventsBySubscriber(const SubscriberRecordPtr &subscriberRecord) in RemoveFrozenEventsBySubscriber() argument
528 auto frozenRecordsItem = frozenEvents_.find(subscriberRecord->eventRecordInfo.uid); in RemoveFrozenEventsBySubscriber()
530 auto eventRecordsItems = frozenRecordsItem->second.find(*subscriberRecord); in RemoveFrozenEventsBySubscriber()
[all …]
|
| /base/notification/common_event_service/services/test/unittest/common_event_control_manager_branch_test/ |
| D | common_event_control_manager_branch_test.cpp | 89 EventSubscriberRecord subscriberRecord; in HWTEST_F() local
91 subscriberRecord.eventSubscribeInfo = eventSubscribeInfo; in HWTEST_F()
92 subscriberRecord.eventRecordInfo.isProxy = true; in HWTEST_F()
93 subscriberRecord.eventRecordInfo.isSubsystem = true; in HWTEST_F()
94 subscriberRecord.eventRecordInfo.isSystemApp = true; in HWTEST_F()
108 …EXPECT_EQ(false, commonEventControlManager.CheckSubscriberPermission(subscriberRecord, eventRecord… in HWTEST_F()
121 EventSubscriberRecord subscriberRecord; in HWTEST_F() local
123 subscriberRecord.eventSubscribeInfo = eventSubscribeInfo; in HWTEST_F()
124 subscriberRecord.eventRecordInfo.isProxy = true; in HWTEST_F()
125 subscriberRecord.eventRecordInfo.isSubsystem = true; in HWTEST_F()
[all …]
|
| /base/notification/common_event_service/services/include/ |
| D | common_event_control_manager.h | 53 …st CommonEventRecord &eventRecord, const std::shared_ptr<EventSubscriberRecord> &subscriberRecord);
124 …ventRecord &eventRecord, const std::shared_ptr<EventSubscriberRecord> &subscriberRecord = nullptr);
152 …int8_t CheckPermission(const EventSubscriberRecord &subscriberRecord, const CommonEventRecord &eve…
154 …bool CheckSubscriberPermission(const EventSubscriberRecord &subscriberRecord, const CommonEventRec…
157 const CommonEventRecord &eventRecord, const EventSubscriberRecord &subscriberRecord);
160 const EventSubscriberRecord &subscriberRecord, const CommonEventRecord &eventRecord);
162 …bool NotifyFreezeEvents(const EventSubscriberRecord &subscriberRecord, const CommonEventRecord &ev…
185 …ndOrderedEventProcTimeoutHiSysEvent(const std::shared_ptr<EventSubscriberRecord> &subscriberRecord,
|
| D | inner_common_event_manager.h | 161 const std::shared_ptr<EventSubscriberRecord> &subscriberRecord);
|
| D | common_event_subscriber_manager.h | 198 void RemoveFrozenEventsBySubscriber(const SubscriberRecordPtr &subscriberRecord);
|
| /base/notification/common_event_service/services/test/unittest/ |
| D | common_event_control_manager_test.cpp | 64 std::shared_ptr<EventSubscriberRecord> subscriberRecord = nullptr; in HWTEST_F() local
65 bool sticky = commonEventControlManager.PublishStickyCommonEvent(eventRecord, subscriberRecord); in HWTEST_F()
202 EventSubscriberRecord subscriberRecord; in HWTEST_F() local
203 subscriberRecord.eventRecordInfo.isProxy = false; in HWTEST_F()
204 subscriberRecord.eventRecordInfo.isSubsystem = true; in HWTEST_F()
205 subscriberRecord.eventRecordInfo.isSystemApp = true; in HWTEST_F()
210 …EXPECT_EQ(true, commonEventControlManager.CheckSubscriberPermission(subscriberRecord, eventRecord)… in HWTEST_F()
223 EventSubscriberRecord subscriberRecord; in HWTEST_F() local
224 subscriberRecord.eventRecordInfo.isProxy = true; in HWTEST_F()
225 subscriberRecord.eventRecordInfo.isSubsystem = false; in HWTEST_F()
[all …]
|
| D | common_event_subscriber_manager_test.cpp | 516 SubscriberRecordPtr subscriberRecord = std::make_shared<EventSubscriberRecord>(); in HWTEST_F() local
518 subscriberRecord->eventRecordInfo.uid = uids; in HWTEST_F()
522 commonEventSubscriberManager->RemoveFrozenEventsBySubscriber(subscriberRecord); in HWTEST_F()
565 SubscriberRecordPtr subscriberRecord = std::make_shared<EventSubscriberRecord>(); in HWTEST_F() local
567 commonEventSubscriberManager->InsertFrozenEvents(subscriberRecord, eventRecord); in HWTEST_F()
582 SubscriberRecordPtr subscriberRecord = nullptr; in HWTEST_F() local
584 commonEventSubscriberManager->InsertFrozenEvents(subscriberRecord, eventRecord); in HWTEST_F()
|
| D | inner_common_event_manager_test.cpp | 279 std::shared_ptr<EventSubscriberRecord> subscriberRecord = nullptr; in HWTEST_F() local
280 EXPECT_EQ(false, innerCommonEventManager.PublishStickyEvent(sp, subscriberRecord)); in HWTEST_F()
295 std::shared_ptr<EventSubscriberRecord> subscriberRecord = nullptr; in HWTEST_F() local
296 EXPECT_EQ(false, innerCommonEventManager.PublishStickyEvent(sp, subscriberRecord)); in HWTEST_F()
|
| D | common_event_publish_ordered_event_unit_test.cpp | 510 …std::shared_ptr<EventSubscriberRecord> subscriberRecord = std::make_shared<EventSubscriberRecord>(… variable
519 eventRecord->receivers.emplace_back(subscriberRecord);
|