| /base/hiviewdfx/hiappevent/frameworks/native/libhiappevent/cache/ |
| H A D | app_event_mapping_dao.cpp | 77 int AppEventMappingDao::Delete(int64_t observerSeq, const std::vector<int64_t>& eventSeqs)
in Delete() argument
83 if (!eventSeqs.empty()) {
in Delete()
84 std::vector<std::string> eventSeqStrs(eventSeqs.size());
in Delete()
85 std::transform(eventSeqs.begin(), eventSeqs.end(), eventSeqStrs.begin(), [](int64_t eventSeq) {
in Delete()
99 int AppEventMappingDao::QueryExistEvent(const std::vector<int64_t>& eventSeqs,
in QueryExistEvent() argument
102 if (eventSeqs.empty()) {
in QueryExistEvent()
106 std::vector<std::string> eventSeqStrs(eventSeqs.size());
in QueryExistEvent()
107 std::transform(eventSeqs.begin(), eventSeqs in QueryExistEvent()
[all...] |
| H A D | app_event_dao.cpp | 116 int AppEventDao::Delete(const std::vector<int64_t>& eventSeqs)
in Delete() argument
118 if (eventSeqs.empty()) {
in Delete()
122 std::vector<std::string> eventSeqStrs(eventSeqs.size());
in Delete()
123 std::transform(eventSeqs.begin(), eventSeqs.end(), eventSeqStrs.begin(), [](int64_t eventSeq) {
in Delete()
|
| H A D | app_event_store.cpp | 384 std::vector<int64_t> eventSeqs;
in TakeEvents() local
386 eventSeqs.emplace_back(event->GetSeq());
in TakeEvents()
388 if (appEventMappingDao_->Delete(observerSeq, eventSeqs) < 0) {
in TakeEvents()
471 int AppEventStore::DeleteEventMapping(int64_t observerSeq, const std::vector<int64_t>& eventSeqs)
in DeleteEventMapping() argument
477 return appEventMappingDao_->Delete(observerSeq, eventSeqs);
in DeleteEventMapping()
498 int AppEventStore::DeleteEvent(const std::vector<int64_t>& eventSeqs)
in DeleteEvent() argument
500 if (eventSeqs.empty()) {
in DeleteEvent()
509 if (appEventMappingDao_->QueryExistEvent(eventSeqs, existEventSeqs) == DB_FAILED) {
in DeleteEvent()
514 return appEventDao_->Delete(eventSeqs);
in DeleteEvent()
517 for (const auto& seq : eventSeqs) {
in DeleteEvent()
589 DeleteData(int64_t observerSeq, const std::vector<int64_t>& eventSeqs) DeleteData() argument
[all...] |
| /base/hiviewdfx/hiappevent/frameworks/native/libhiappevent/observer/ |
| H A D | app_event_processor_proxy.cpp | 64 std::vector<int64_t> eventSeqs;
in OnEvents()
67 eventSeqs.emplace_back(event->GetSeq());
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/ndk/src/ |
| H A D | ndk_app_event_watcher.cpp | 79 std::vector<int64_t> eventSeqs; in OnEvents() local
89 eventSeqs.emplace_back(event->GetSeq()); in OnEvents()
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/native/libhiappevent/cache/include/ |
| H A D | app_event_mapping_dao.h | 31 int Delete(int64_t observerSeq, const std::vector<int64_t>& eventSeqs);
32 int QueryExistEvent(const std::vector<int64_t>& eventSeqs, std::unordered_set<int64_t>& existEventSeqs);
|
| H A D | app_event_store.h | 62 int DeleteEventMapping(int64_t observerSeq = 0, const std::vector<int64_t>& eventSeqs = {});
67 int DeleteEvent(const std::vector<int64_t>& eventSeqs);
71 bool DeleteData(int64_t observerSeq, const std::vector<int64_t>& eventSeqs);
|
| H A D | app_event_dao.h | 34 int Delete(const std::vector<int64_t>& eventSeqs);
|
| /base/hiviewdfx/hiappevent/frameworks/cj/ffi/src/ |
| H A D | appevent_packageholder_impl.cpp | 88 std::vector<int64_t> eventSeqs; in TakeNext() local
99 eventSeqs.emplace_back(event->GetSeq()); in TakeNext()
105 if (AppEventStore::GetInstance().DeleteEventMapping(observerSeq_, eventSeqs) < 0) { in TakeNext()
|
| /base/hiviewdfx/hiappevent/frameworks/js/napi/src/ |
| H A D | napi_app_event_watcher.cpp | 45 std::vector<int64_t> eventSeqs;
in DeleteEventMappingAsync() local
47 eventSeqs.emplace_back(event->GetSeq());
in DeleteEventMappingAsync()
49 ffrt::submit([observerSeq, eventSeqs]() {
in DeleteEventMappingAsync()
50 if (!AppEventStore::GetInstance().DeleteData(observerSeq, eventSeqs)) {
in DeleteEventMappingAsync()
52 observerSeq, eventSeqs.size());
in DeleteEventMappingAsync()
|
| H A D | napi_app_event_holder.cpp | 198 std::vector<int64_t> eventSeqs;
in TakeNext() local
211 eventSeqs.emplace_back(event->GetSeq());
in TakeNext()
218 if (!AppEventStore::GetInstance().DeleteData(observerSeq_, eventSeqs)) {
in TakeNext()
|