| /base/notification/common_event_service/services/include/ |
| H A D | common_event_control_manager.h | 50 * @param subscriberRecord Indicates the subscriber object.
54 const CommonEventRecord &eventRecord, const std::shared_ptr<EventSubscriberRecord> &subscriberRecord);
133 const CommonEventRecord &eventRecord, const std::shared_ptr<EventSubscriberRecord> &subscriberRecord = nullptr);
161 int8_t CheckPermission(const EventSubscriberRecord &subscriberRecord, const CommonEventRecord &eventRecord);
163 bool CheckSubscriberPermission(const EventSubscriberRecord &subscriberRecord,
167 const CommonEventRecord &eventRecord, const EventSubscriberRecord &subscriberRecord);
170 const EventSubscriberRecord &subscriberRecord, const CommonEventRecord &eventRecord);
172 bool NotifyFreezeEvents(const EventSubscriberRecord &subscriberRecord, const CommonEventRecord &eventRecord);
196 void SendOrderedEventProcTimeoutHiSysEvent(const std::shared_ptr<EventSubscriberRecord> &subscriberRecord,
|
| H A D | common_event_subscriber_manager.h | 228 void RemoveFrozenEventsBySubscriber(const SubscriberRecordPtr &subscriberRecord);
232 void RemoveFrozenEventsMapBySubscriber(const SubscriberRecordPtr &subscriberRecord);
|
| H A D | inner_common_event_manager.h | 181 const std::shared_ptr<EventSubscriberRecord> &subscriberRecord);
|
| /base/notification/common_event_service/services/test/unittest/common_event_control_manager_branch_test/ |
| H A 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 in HWTEST_F()
147 EventSubscriberRecord subscriberRecord; HWTEST_F() local
177 EventSubscriberRecord subscriberRecord; HWTEST_F() local
203 EventSubscriberRecord subscriberRecord; HWTEST_F() local
253 EventSubscriberRecord subscriberRecord; HWTEST_F() local
280 EventSubscriberRecord subscriberRecord; HWTEST_F() local
1028 std::shared_ptr<EventSubscriberRecord> subscriberRecord = nullptr; HWTEST_F() local
1045 std::shared_ptr<EventSubscriberRecord> subscriberRecord = std::make_shared<EventSubscriberRecord>(); HWTEST_F() local
[all...] |
| /base/notification/common_event_service/services/src/ |
| H A D | common_event_control_manager.cpp | 66 const CommonEventRecord &eventRecord, const std::shared_ptr<EventSubscriberRecord> &subscriberRecord) in PublishStickyCommonEvent()
71 if (!subscriberRecord) { in PublishStickyCommonEvent()
72 EVENT_LOGE("subscriberRecord is null"); in PublishStickyCommonEvent()
75 return ProcessUnorderedEvent(eventRecord, subscriberRecord); in PublishStickyCommonEvent()
140 EventSubscriberRecord subscriberRecord = record.first; in PublishFrozenEventsInner() local
143 auto innerCallback = [weak, subscriberRecord, eventRecord]() { in PublishFrozenEventsInner()
149 control->NotifyFreezeEvents(subscriberRecord, eventRecord); in PublishFrozenEventsInner()
157 const EventSubscriberRecord &subscriberRecord, const CommonEventRecord &eventRecord) in NotifyFreezeEvents()
161 sptr<IEventReceive> commonEventListenerProxy = iface_cast<IEventReceive>(subscriberRecord.commonEventListener); in NotifyFreezeEvents()
167 int8_t ret = CheckPermission(subscriberRecord, eventRecor in NotifyFreezeEvents()
65 PublishStickyCommonEvent( const CommonEventRecord &eventRecord, const std::shared_ptr<EventSubscriberRecord> &subscriberRecord) PublishStickyCommonEvent() argument
156 NotifyFreezeEvents( const EventSubscriberRecord &subscriberRecord, const CommonEventRecord &eventRecord) NotifyFreezeEvents() argument
274 ProcessUnorderedEvent( const CommonEventRecord &eventRecord, const std::shared_ptr<EventSubscriberRecord> &subscriberRecord) ProcessUnorderedEvent() argument
703 std::shared_ptr<EventSubscriberRecord> subscriberRecord = sp->receivers[sp->nextReceiver - 1]; CurrentOrderedEventTimeout() local
766 CheckPermission( const EventSubscriberRecord &subscriberRecord, const CommonEventRecord &eventRecord) CheckPermission() argument
796 CheckSubscriberPermission( const EventSubscriberRecord &subscriberRecord, const CommonEventRecord &eventRecord) CheckSubscriberPermission() argument
849 CheckSubscriberRequiredPermission(const std::string &subscriberRequiredPermission, const CommonEventRecord &eventRecord, const EventSubscriberRecord &subscriberRecord) CheckSubscriberRequiredPermission() argument
879 CheckPublisherRequiredPermissions( const std::vector<std::string> &publisherRequiredPermissions, const EventSubscriberRecord &subscriberRecord, const CommonEventRecord &eventRecord) CheckPublisherRequiredPermissions() argument
1375 std::string subscriberRecord; DumpState() local
1408 std::string subscriberRecord; DumpHistoryState() local
1415 SendOrderedEventProcTimeoutHiSysEvent( const std::shared_ptr<EventSubscriberRecord> &subscriberRecord, const std::string &eventName) SendOrderedEventProcTimeoutHiSysEvent() argument
[all...] |
| H A D | common_event_subscriber_manager.cpp | 553 const SubscriberRecordPtr &subscriberRecord, const CommonEventRecord &eventRecord) in InsertFrozenEvents()
557 if (subscriberRecord == nullptr) { in InsertFrozenEvents()
558 EVENT_LOGE("subscriberRecord is null"); in InsertFrozenEvents()
564 auto frozenRecordsItem = frozenEvents_.find(subscriberRecord->eventRecordInfo.uid); in InsertFrozenEvents()
566 auto eventRecordsItem = frozenRecordsItem->second.find(*subscriberRecord); in InsertFrozenEvents()
578 frozenRecordsItem->second[*subscriberRecord] = EventRecords; in InsertFrozenEvents()
584 frozenRecords[*subscriberRecord] = EventRecords; in InsertFrozenEvents()
585 frozenEvents_[subscriberRecord->eventRecordInfo.uid] = frozenRecords; in InsertFrozenEvents()
622 void CommonEventSubscriberManager::RemoveFrozenEventsBySubscriber(const SubscriberRecordPtr &subscriberRecord) in RemoveFrozenEventsBySubscriber() argument
626 auto frozenRecordsItem = frozenEvents_.find(subscriberRecord in RemoveFrozenEventsBySubscriber()
552 InsertFrozenEvents( const SubscriberRecordPtr &subscriberRecord, const CommonEventRecord &eventRecord) InsertFrozenEvents() argument
635 InsertFrozenEventsMap( const SubscriberRecordPtr &subscriberRecord, const CommonEventRecord &eventRecord) InsertFrozenEventsMap() argument
705 RemoveFrozenEventsMapBySubscriber(const SubscriberRecordPtr &subscriberRecord) RemoveFrozenEventsMapBySubscriber() argument
[all...] |
| H A D | inner_common_event_manager.cpp | 578 const std::shared_ptr<CommonEventSubscribeInfo> &sp, const std::shared_ptr<EventSubscriberRecord> &subscriberRecord) in PublishStickyEvent()
588 if (!subscriberRecord) { in PublishStickyEvent()
589 EVENT_LOGE("subscriberRecord is null"); in PublishStickyEvent()
607 commonEventRecord->publishInfo->GetBundleName() != subscriberRecord->eventRecordInfo.bundleName) { in PublishStickyEvent()
618 controlPtr_->PublishStickyCommonEvent(*commonEventRecord, subscriberRecord); in PublishStickyEvent()
680 auto subscriberRecord = DelayedSingleton<CommonEventSubscriberManager>::GetInstance()->GetSubscriberRecord( in SendUnSubscribeHiSysEvent() local
682 if (subscriberRecord == nullptr) { in SendUnSubscribeHiSysEvent()
687 if (subscriberRecord->eventSubscribeInfo != nullptr) { in SendUnSubscribeHiSysEvent()
688 eventInfo.userId = subscriberRecord->eventSubscribeInfo->GetUserId(); in SendUnSubscribeHiSysEvent()
689 std::vector<std::string> events = subscriberRecord in SendUnSubscribeHiSysEvent()
577 PublishStickyEvent( const std::shared_ptr<CommonEventSubscribeInfo> &sp, const std::shared_ptr<EventSubscriberRecord> &subscriberRecord) PublishStickyEvent() argument
[all...] |
| /base/notification/common_event_service/services/test/unittest/ |
| H A D | common_event_control_manager_test.cpp | 56 * @tc.desc: test PublishStickyCommonEvent function and subscriberRecord is nullptr.
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 in HWTEST_F()
245 EventSubscriberRecord subscriberRecord; HWTEST_F() local
[all...] |
| H A 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()
|
| H A 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()
|
| H A D | common_event_publish_ordered_event_unit_test.cpp | 510 std::shared_ptr<EventSubscriberRecord> subscriberRecord = std::make_shared<EventSubscriberRecord>(); in HWTEST_F() local
519 eventRecord->receivers.emplace_back(subscriberRecord); in HWTEST_F()
|