Home
last modified time | relevance | path

Searched refs:observerSeq (Results 1 - 19 of 19) sorted by relevance

/base/hiviewdfx/hiappevent/test/unittest/common/native/
H A Dhiappevent_cache_test.cpp68 int64_t observerSeq = AppEventStore::GetInstance().InsertObserver(TEST_OBSERVER_NAME); in HWTEST_F() local
69 ASSERT_GT(observerSeq, 0); in HWTEST_F()
70 int64_t mappingSeq = AppEventStore::GetInstance().InsertEventMapping(eventSeq, observerSeq); in HWTEST_F()
74 result = AppEventStore::GetInstance().QueryEvents(events, observerSeq); in HWTEST_F()
85 ASSERT_EQ(observerSeqs[0], observerSeq); in HWTEST_F()
109 auto observerSeq = AppEventStore::GetInstance().InsertObserver(TEST_OBSERVER_NAME); in HWTEST_F() local
110 ASSERT_GT(observerSeq, 0); in HWTEST_F()
111 auto mappingSeq = AppEventStore::GetInstance().InsertEventMapping(eventSeq, observerSeq); in HWTEST_F()
115 result = AppEventStore::GetInstance().TakeEvents(events, observerSeq); in HWTEST_F()
123 result = AppEventStore::GetInstance().QueryEvents(events, observerSeq); in HWTEST_F()
149 auto observerSeq = AppEventStore::GetInstance().InsertObserver(TEST_OBSERVER_NAME); HWTEST_F() local
190 int64_t observerSeq = AppEventStore::GetInstance().InsertObserver(TEST_OBSERVER_NAME); HWTEST_F() local
259 int64_t observerSeq = AppEventStore::GetInstance().InsertObserver(TEST_OBSERVER_NAME); HWTEST_F() local
[all...]
/base/hiviewdfx/hiappevent/frameworks/native/libhiappevent/observer/
H A Dapp_event_observer_mgr.cpp58 int64_t observerSeq = observer->GetSeq(); in StoreEventMappingToDb() local
59 if (AppEventStore::GetInstance().InsertEventMapping(event->GetSeq(), observerSeq) < 0) { in StoreEventMappingToDb()
60 HILOG_ERROR(LOG_CORE, "failed to add mapping record to db, seq=%{public}" PRId64, observerSeq); in StoreEventMappingToDb()
88 int64_t observerSeq = AppEventStore::GetInstance().QueryObserverSeq(name, hashCode); in InitObserverFromDb() local
89 if (observerSeq <= 0) { in InitObserverFromDb()
95 if (AppEventStore::GetInstance().QueryEvents(events, observerSeq, MAX_SIZE_OF_INIT) < 0) { in InitObserverFromDb()
96 HILOG_ERROR(LOG_CORE, "failed to take events, seq=%{public}" PRId64, observerSeq); in InitObserverFromDb()
99 observer->SetSeq(observerSeq); in InitObserverFromDb()
113 return observerSeq; in InitObserverFromDb()
120 int64_t observerSeq in InitObserver() local
206 int64_t observerSeq = InitObserver(observer, isExist); RegisterObserver() local
234 int64_t observerSeq = RegisterObserver(observer); RegisterObserver() local
242 UnregisterObserver(int64_t observerSeq) UnregisterObserver() argument
359 SetReportConfig(int64_t observerSeq, const ReportConfig& config) SetReportConfig() argument
370 GetReportConfig(int64_t observerSeq, ReportConfig& config) GetReportConfig() argument
[all...]
H A Dapp_event_processor_proxy.cpp58 int64_t observerSeq = GetSeq(); in OnEvents() local
62 ffrt::submit([proxyPtr, observerSeq, userIds, userProperties, events]() { in OnEvents()
69 if (proxyPtr->processor_->OnReport(observerSeq, userIds, userProperties, eventInfos) == 0) { in OnEvents()
70 if (!AppEventStore::GetInstance().DeleteData(observerSeq, eventSeqs)) { in OnEvents()
72 observerSeq, eventSeqs.size()); in OnEvents()
76 observerSeq, eventSeqs.size()); in OnEvents()
/base/hiviewdfx/hiappevent/frameworks/native/libhiappevent/cache/
H A Dapp_event_observer_dao.cpp87 int64_t observerSeq = 0; in QuerySeq() local
88 if (resultSet->GoToNextRow() == NativeRdb::E_OK && resultSet->GetLong(0, observerSeq) == NativeRdb::E_OK) { in QuerySeq()
90 observerSeq, observer.c_str(), hashCode); in QuerySeq()
92 return observerSeq; in QuerySeq()
108 int64_t observerSeq = 0; in QuerySeqs() local
109 if (resultSet->GetLong(0, observerSeq) != NativeRdb::E_OK) { in QuerySeqs()
113 observerSeqs.emplace_back(observerSeq); in QuerySeqs()
132 int AppEventObserverDao::Delete(int64_t observerSeq) in Delete() argument
136 predicates.EqualTo(Observers::FIELD_SEQ, observerSeq); in Delete()
138 HILOG_ERROR(LOG_CORE, "failed to delete records, observer seq=%{public}" PRId64, observerSeq); in Delete()
[all...]
H A Dapp_event_mapping_dao.cpp65 int64_t AppEventMappingDao::Insert(int64_t eventSeq, int64_t observerSeq) in Insert() argument
69 bucket.PutLong(FIELD_OBSERVER_SEQ, observerSeq); in Insert()
77 int AppEventMappingDao::Delete(int64_t observerSeq, const std::vector<int64_t>& eventSeqs) in Delete() argument
80 if (observerSeq > 0) { in Delete()
81 predicates.EqualTo(FIELD_OBSERVER_SEQ, observerSeq); in Delete()
95 HILOG_INFO(LOG_CORE, "delete %{public}d records, observerSeq=%{public}" PRId64, deleteRows, observerSeq); in Delete()
H A Dapp_event_store.cpp228 int64_t AppEventStore::InsertEventMapping(int64_t eventSeq, int64_t observerSeq) in InsertEventMapping() argument
234 return appEventMappingDao_->Insert(eventSeq, observerSeq); in InsertEventMapping()
373 int AppEventStore::TakeEvents(std::vector<std::shared_ptr<AppEventPack>>& events, int64_t observerSeq, uint32_t size) in TakeEvents() argument
376 if (int ret = QueryEvents(events, observerSeq, size); ret != DB_SUCC) { in TakeEvents()
388 if (appEventMappingDao_->Delete(observerSeq, eventSeqs) < 0) { in TakeEvents()
389 HILOG_WARN(LOG_CORE, "failed to delete the events mapping data, observer=%{public}" PRId64, observerSeq); in TakeEvents()
395 int AppEventStore::QueryEvents(std::vector<std::shared_ptr<AppEventPack>>& events, int64_t observerSeq, uint32_t size) in QueryEvents() argument
410 resultSet = dbStore_->QuerySql(sql, std::vector<std::string>{std::to_string(observerSeq)}); in QueryEvents()
412 HILOG_WARN(LOG_CORE, "result set is null, observer=%{public}" PRId64, observerSeq); in QueryEvents()
459 int AppEventStore::DeleteObserver(int64_t observerSeq) in DeleteObserver() argument
471 DeleteEventMapping(int64_t observerSeq, const std::vector<int64_t>& eventSeqs) DeleteEventMapping() argument
589 DeleteData(int64_t observerSeq, const std::vector<int64_t>& eventSeqs) DeleteData() argument
[all...]
/base/hiviewdfx/hiappevent/frameworks/cj/ffi/src/
H A Dappevent_packageholder_impl.cpp58 AppEventPackageHolderImpl::AppEventPackageHolderImpl(const std::string& name, int64_t observerSeq) in AppEventPackageHolderImpl() argument
59 : name_(name), observerSeq_(observerSeq) in AppEventPackageHolderImpl()
119 int64_t observerSeq = ERR_CODE_PARAM_INVALID; in GetObserverSeqByName() local
120 if (observerSeq = AppEventStore::GetInstance().QueryObserverSeq(name); observerSeq <= 0) { in GetObserverSeqByName()
124 return observerSeq; in GetObserverSeqByName()
H A Dhiappevent_impl.cpp224 int64_t observerSeq = AppEventObserverMgr::GetInstance().RegisterObserver(watcherPtr); in addWatcher() local
225 if (observerSeq <= 0) { in addWatcher()
/base/hiviewdfx/hiappevent/frameworks/native/libhiappevent/cache/include/
H A Dapp_event_store.h46 int64_t InsertEventMapping(int64_t eventSeq, int64_t observerSeq);
52 int TakeEvents(std::vector<std::shared_ptr<AppEventPack>>& events, int64_t observerSeq, uint32_t eventSize = 0);
53 int QueryEvents(std::vector<std::shared_ptr<AppEventPack>>& events, int64_t observerSeq, uint32_t eventSize = 0);
61 int DeleteObserver(int64_t observerSeq);
62 int DeleteEventMapping(int64_t observerSeq = 0, const std::vector<int64_t>& eventSeqs = {});
71 bool DeleteData(int64_t observerSeq, const std::vector<int64_t>& eventSeqs);
H A Dapp_event_mapping_dao.h30 int64_t Insert(int64_t eventSeq, int64_t observerSeq);
31 int Delete(int64_t observerSeq, const std::vector<int64_t>& eventSeqs);
H A Dapp_event_observer_dao.h34 int Delete(int64_t observerSeq);
/base/hiviewdfx/hiappevent/frameworks/native/libhiappevent/observer/include/
H A Dapp_event_observer_mgr.h49 int UnregisterObserver(int64_t observerSeq);
59 int SetReportConfig(int64_t observerSeq, const ReportConfig& config);
60 int GetReportConfig(int64_t observerSeq, ReportConfig& config);
/base/hiviewdfx/hiappevent/frameworks/native/ndk/src/
H A Dndk_app_event_watcher.cpp99 int64_t observerSeq = GetSeq(); in OnEvents() local
100 ffrt::submit([observerSeq, eventSeqs]() { in OnEvents()
101 if (!AppEventStore::GetInstance().DeleteData(observerSeq, eventSeqs)) { in OnEvents()
103 observerSeq, eventSeqs.size()); in OnEvents()
/base/hiviewdfx/hiappevent/frameworks/js/napi/src/
H A Dnapi_app_event_holder.cpp40 int64_t observerSeq = -1; in GetObserverSeqByName() local
41 if (observerSeq = AppEventStore::GetInstance().QueryObserverSeq(name); observerSeq <= 0) { in GetObserverSeqByName()
45 return observerSeq; in GetObserverSeqByName()
50 NapiAppEventHolder::NapiAppEventHolder(const std::string& name, int64_t observerSeq) in NapiAppEventHolder() argument
51 : name_(name), observerSeq_(observerSeq), hasSetRow_(false), hasSetSize_(false) in NapiAppEventHolder()
H A Dnapi_app_event_watcher.cpp43 void DeleteEventMappingAsync(int64_t observerSeq, const std::vector<std::shared_ptr<AppEventPack>>& events) in DeleteEventMappingAsync() argument
49 ffrt::submit([observerSeq, eventSeqs]() { in DeleteEventMappingAsync()
50 if (!AppEventStore::GetInstance().DeleteData(observerSeq, eventSeqs)) { in DeleteEventMappingAsync()
52 observerSeq, eventSeqs.size()); in DeleteEventMappingAsync()
245 context_->receiveContext->observerSeq = GetSeq(); in OnEvents()
278 DeleteEventMappingAsync(context->observerSeq, context->events); in OnEvents()
H A Dnapi_hiappevent_watch.cpp320 int64_t observerSeq = AppEventObserverMgr::GetInstance().RegisterObserver(watcherPtr); in AddWatcher() local
321 if (observerSeq <= 0) { in AddWatcher()
331 NapiUtil::CreateInt64(env, observerSeq) in AddWatcher()
/base/hiviewdfx/hiappevent/frameworks/cj/ffi/include/
H A Dappevent_packageholder_impl.h36 AppEventPackageHolderImpl(const std::string& name, int64_t observerSeq);
/base/hiviewdfx/hiappevent/frameworks/js/napi/include/
H A Dnapi_app_event_watcher.h39 int64_t observerSeq = 0; member
H A Dnapi_app_event_holder.h40 NapiAppEventHolder(const std::string& name, int64_t observerSeq = -1);

Completed in 8 milliseconds