| /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 | 382 …_ptr<CommonEventSubscribeInfo> &sp, const std::shared_ptr<EventSubscriberRecord> &subscriberRecord) in PublishStickyEvent() argument
392 if (!subscriberRecord) { in PublishStickyEvent()
411 … commonEventRecord->publishInfo->GetBundleName() != subscriberRecord->eventRecordInfo.bundleName) { in PublishStickyEvent()
422 controlPtr_->PublishStickyCommonEvent(*commonEventRecord, subscriberRecord); in PublishStickyEvent()
484 …auto subscriberRecord = DelayedSingleton<CommonEventSubscriberManager>::GetInstance()->GetSubscrib… in SendUnSubscribeHiSysEvent() local
486 if (subscriberRecord == nullptr) { in SendUnSubscribeHiSysEvent()
491 if (subscriberRecord->eventSubscribeInfo != nullptr) { in SendUnSubscribeHiSysEvent()
492 eventInfo.userId = subscriberRecord->eventSubscribeInfo->GetUserId(); in SendUnSubscribeHiSysEvent()
493 …std::vector<std::string> events = subscriberRecord->eventSubscribeInfo->GetMatchingSkills().GetEve… in SendUnSubscribeHiSysEvent()
499 eventInfo.subscriberName = subscriberRecord->eventRecordInfo.bundleName; in SendUnSubscribeHiSysEvent()
[all …]
|
| D | common_event_subscriber_manager.cpp | 442 const SubscriberRecordPtr &subscriberRecord, const CommonEventRecord &eventRecord) in InsertFrozenEvents() argument
446 if (subscriberRecord == nullptr) { in InsertFrozenEvents()
453 auto frozenRecordsItem = frozenEvents_.find(subscriberRecord->eventRecordInfo.uid); in InsertFrozenEvents()
455 auto eventRecordsItem = frozenRecordsItem->second.find(subscriberRecord); in InsertFrozenEvents()
467 frozenRecordsItem->second[subscriberRecord] = EventRecords; in InsertFrozenEvents()
473 frozenRecords[subscriberRecord] = EventRecords; in InsertFrozenEvents()
474 frozenEvents_[subscriberRecord->eventRecordInfo.uid] = frozenRecords; in InsertFrozenEvents()
511 …EventSubscriberManager::RemoveFrozenEventsBySubscriber(const SubscriberRecordPtr &subscriberRecord) in RemoveFrozenEventsBySubscriber() argument
515 auto frozenRecordsItem = frozenEvents_.find(subscriberRecord->eventRecordInfo.uid); in RemoveFrozenEventsBySubscriber()
517 auto eventRecordsItems = frozenRecordsItem->second.find(subscriberRecord); in RemoveFrozenEventsBySubscriber()
[all …]
|
| /base/notification/common_event_service/services/include/ |
| D | common_event_control_manager.h | 51 …st CommonEventRecord &eventRecord, const std::shared_ptr<EventSubscriberRecord> &subscriberRecord);
122 …ventRecord &eventRecord, const std::shared_ptr<EventSubscriberRecord> &subscriberRecord = nullptr);
150 …int8_t CheckPermission(const EventSubscriberRecord &subscriberRecord, const CommonEventRecord &eve…
152 …bool CheckSubscriberPermission(const EventSubscriberRecord &subscriberRecord, const CommonEventRec…
155 const CommonEventRecord &eventRecord, const EventSubscriberRecord &subscriberRecord);
158 const EventSubscriberRecord &subscriberRecord, const CommonEventRecord &eventRecord);
160 …bool NotifyFreezeEvents(const EventSubscriberRecord &subscriberRecord, const CommonEventRecord &ev…
183 …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 | 184 void RemoveFrozenEventsBySubscriber(const SubscriberRecordPtr &subscriberRecord);
|
| /base/notification/common_event_service/services/test/unittest/common_event_control_manager_branch_test/ |
| D | common_event_control_manager_branch_test.cpp | 86 EventSubscriberRecord subscriberRecord; in HWTEST_F() local
87 subscriberRecord.eventRecordInfo.isProxy = true; in HWTEST_F()
88 subscriberRecord.eventRecordInfo.isSubsystem = true; in HWTEST_F()
89 subscriberRecord.eventRecordInfo.isSystemApp = true; in HWTEST_F()
95 …EXPECT_EQ(false, commonEventControlManager.CheckSubscriberPermission(subscriberRecord, eventRecord… in HWTEST_F()
108 EventSubscriberRecord subscriberRecord; in HWTEST_F() local
109 subscriberRecord.eventRecordInfo.isProxy = true; in HWTEST_F()
110 subscriberRecord.eventRecordInfo.isSubsystem = true; in HWTEST_F()
111 subscriberRecord.eventRecordInfo.isSystemApp = true; in HWTEST_F()
117 …EXPECT_EQ(true, commonEventControlManager.CheckSubscriberPermission(subscriberRecord, eventRecord)… in HWTEST_F()
[all …]
|
| /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);
|