Home
last modified time | relevance | path

Searched refs:eventRecordPtr (Results 1 - 4 of 4) sorted by relevance

/base/notification/common_event_service/services/src/
H A Dcommon_event_control_manager.cpp287 std::shared_ptr<OrderedEventRecord> eventRecordPtr = std::make_shared<OrderedEventRecord>(); in ProcessUnorderedEvent() local
288 if (eventRecordPtr == nullptr) { in ProcessUnorderedEvent()
289 EVENT_LOGE("eventRecordPtr is null"); in ProcessUnorderedEvent()
296 eventRecordPtr->FillCommonEventRecord(eventRecord); in ProcessUnorderedEvent()
298 eventRecordPtr->receivers.emplace_back(subscriberRecord); in ProcessUnorderedEvent()
300 eventRecordPtr->receivers = spinstance->GetSubscriberRecords(eventRecord); in ProcessUnorderedEvent()
303 for (auto vec : eventRecordPtr->receivers) { in ProcessUnorderedEvent()
304 eventRecordPtr->deliveryState.emplace_back(OrderedEventRecord::PENDING); in ProcessUnorderedEvent()
307 EnqueueUnorderedRecord(eventRecordPtr); in ProcessUnorderedEvent()
310 auto innerCallback = [weak, eventRecordPtr]() { in ProcessUnorderedEvent()
367 std::shared_ptr<OrderedEventRecord> eventRecordPtr = std::make_shared<OrderedEventRecord>(); ProcessOrderedEvent() local
398 EnqueueUnorderedRecord(const std::shared_ptr<OrderedEventRecord> &eventRecordPtr) EnqueueUnorderedRecord() argument
412 EnqueueOrderedRecord(const std::shared_ptr<OrderedEventRecord> &eventRecordPtr) EnqueueOrderedRecord() argument
426 EnqueueHistoryEventRecord( const std::shared_ptr<OrderedEventRecord> &eventRecordPtr, bool hasLastSubscribe) EnqueueHistoryEventRecord() argument
504 NotifyOrderedEvent(std::shared_ptr<OrderedEventRecord> &eventRecordPtr, size_t index) NotifyOrderedEvent() argument
[all...]
/base/account/os_account/services/accountmgr/src/appaccount/
H A Dapp_account_subscribe_manager.cpp258 auto eventRecordPtr = std::make_shared<AppAccountEventRecord>(); in PublishAccount() local
259 if (eventRecordPtr == nullptr) { in PublishAccount()
263 eventRecordPtr->info = std::make_shared<AppAccountInfo>(appAccountInfo); in PublishAccount()
264 eventRecordPtr->receivers = GetSubscribeRecords(bundleName); in PublishAccount()
265 eventRecordPtr->uid = uid; in PublishAccount()
266 eventRecordPtr->bundleName = bundleName; in PublishAccount()
267 eventRecordPtr->appIndex = appIndex; in PublishAccount()
269 auto callback = [this, eventRecordPtr] { this->OnAccountsChanged(eventRecordPtr); }; in PublishAccount()
/base/notification/common_event_service/services/include/
H A Dcommon_event_control_manager.h144 bool EnqueueOrderedRecord(const std::shared_ptr<OrderedEventRecord> &eventRecordPtr);
146 bool EnqueueUnorderedRecord(const std::shared_ptr<OrderedEventRecord> &eventRecordPtr);
150 bool NotifyOrderedEvent(std::shared_ptr<OrderedEventRecord> &eventRecordPtr, size_t index);
191 void EnqueueHistoryEventRecord(const std::shared_ptr<OrderedEventRecord> &eventRecordPtr,
/base/notification/common_event_service/services/test/unittest/
H A Dcommon_event_control_manager_test.cpp87 * @tc.desc: test EnqueueUnorderedRecord function and eventRecordPtr is nullptr.
94 std::shared_ptr<OrderedEventRecord> eventRecordPtr = nullptr; in HWTEST_F() local
95 bool sticky = commonEventControlManager.EnqueueUnorderedRecord(eventRecordPtr); in HWTEST_F()
102 * @tc.desc: test EnqueueHistoryEventRecord function and eventRecordPtr is nullptr.
111 std::shared_ptr<OrderedEventRecord> eventRecordPtr = nullptr; in HWTEST_F() local
113 commonEventControlManager->EnqueueHistoryEventRecord(eventRecordPtr, hasLastSubscribe); in HWTEST_F()
119 * @tc.desc: test NotifyOrderedEvent function and eventRecordPtr is nullptr.
126 std::shared_ptr<OrderedEventRecord> eventRecordPtr = nullptr; in HWTEST_F() local
128 EXPECT_EQ(false, commonEventControlManager.NotifyOrderedEvent(eventRecordPtr, index)); in HWTEST_F()
141 std::shared_ptr<OrderedEventRecord> eventRecordPtr in HWTEST_F() local
156 std::shared_ptr<OrderedEventRecord> eventRecordPtr = std::make_shared<OrderedEventRecord>(); HWTEST_F() local
[all...]

Completed in 5 milliseconds