| /base/hiviewdfx/hiappevent/test/unittest/common/native/ |
| H A D | hiappevent_cache_test.cpp | 66 int64_t eventSeq = AppEventStore::GetInstance().InsertEvent(CreateAppEventPack());
in HWTEST_F() local
67 ASSERT_GT(eventSeq, 0);
in HWTEST_F()
70 int64_t mappingSeq = AppEventStore::GetInstance().InsertEventMapping(eventSeq, observerSeq);
in HWTEST_F()
107 auto eventSeq = AppEventStore::GetInstance().InsertEvent(CreateAppEventPack());
in HWTEST_F() local
108 ASSERT_GT(eventSeq, 0);
in HWTEST_F()
111 auto mappingSeq = AppEventStore::GetInstance().InsertEventMapping(eventSeq, observerSeq);
in HWTEST_F()
147 auto eventSeq = AppEventStore::GetInstance().InsertEvent(CreateAppEventPack());
in HWTEST_F() local
148 ASSERT_GT(eventSeq, 0);
in HWTEST_F()
151 auto mappingSeq = AppEventStore::GetInstance().InsertEventMapping(eventSeq, observerSeq);
in HWTEST_F()
161 result = AppEventStore::GetInstance().DeleteEventMapping(observerSeq, {eventSeq});
in HWTEST_F()
188 int64_t eventSeq = AppEventStore::GetInstance().InsertEvent(CreateAppEventPack()); HWTEST_F() local
257 int64_t eventSeq = AppEventStore::GetInstance().InsertEvent(event); HWTEST_F() local
[all...] |
| /base/hiviewdfx/hiview/base/event_store/test/unittest/common/ |
| H A D | sys_event_sequence_mgr_test.cpp | 54 auto eventSeq = EventStore::SysEventSequenceManager::GetInstance().GetSequence(); in HWTEST_F() local
55 EventStore::SysEventSequenceManager::GetInstance().SetSequence(eventSeq + 1000); // 1000 is a test offset in HWTEST_F()
57 ASSERT_NE(eventSeq, eventSeqNew); in HWTEST_F()
|
| /base/hiviewdfx/hiappevent/frameworks/native/libhiappevent/cache/ |
| H A D | app_event_mapping_dao.cpp | 65 int64_t AppEventMappingDao::Insert(int64_t eventSeq, int64_t observerSeq)
in Insert() argument
68 bucket.PutLong(FIELD_EVENT_SEQ, eventSeq);
in Insert()
85 std::transform(eventSeqs.begin(), eventSeqs.end(), eventSeqStrs.begin(), [](int64_t eventSeq) {
in Delete()
86 return std::to_string(eventSeq);
in Delete()
107 std::transform(eventSeqs.begin(), eventSeqs.end(), eventSeqStrs.begin(), [](int64_t eventSeq) {
in QueryExistEvent()
108 return std::to_string(eventSeq);
in QueryExistEvent()
|
| H A D | app_event_dao.cpp | 102 int AppEventDao::Delete(int64_t eventSeq)
in Delete() argument
105 if (eventSeq > 0) {
in Delete()
106 predicates.EqualTo(Events::FIELD_SEQ, eventSeq);
in Delete()
112 HILOG_INFO(LOG_CORE, "delete %{public}d records, eventSeq=%{public}" PRId64, deleteRows, eventSeq);
in Delete()
123 std::transform(eventSeqs.begin(), eventSeqs.end(), eventSeqStrs.begin(), [](int64_t eventSeq) {
in Delete()
124 return std::to_string(eventSeq);
in Delete()
|
| H A D | app_event_store.cpp | 228 int64_t AppEventStore::InsertEventMapping(int64_t eventSeq, int64_t observerSeq)
in InsertEventMapping() argument
234 return appEventMappingDao_->Insert(eventSeq, observerSeq);
in InsertEventMapping()
480 int AppEventStore::DeleteEvent(int64_t eventSeq)
in DeleteEvent() argument
486 return appEventDao_->Delete(eventSeq);
in DeleteEvent()
|
| /base/hiviewdfx/hiview/plugins/event_store/ |
| H A D | sys_event_store.cpp | 109 int64_t eventSeq = EventStore::SysEventSequenceManager::GetInstance().GetSequence(); in OnEvent() local
110 sysEvent->SetEventSeq(eventSeq); in OnEvent()
113 sysEvent->domain_.c_str(), sysEvent->eventName_.c_str(), eventSeq); in OnEvent()
115 EventStore::SysEventSequenceManager::GetInstance().SetSequence(++eventSeq); in OnEvent()
|
| /base/hiviewdfx/hiview/plugins/event_store/event_export/database/ |
| H A D | export_db_manager.cpp | 75 void ExportDbManager::HandleExportTaskFinished(const std::string& moduleName, int64_t eventSeq) in HandleExportTaskFinished() argument
78 moduleName.c_str(), eventSeq); in HandleExportTaskFinished()
84 .exportedMaxSeq = eventSeq, in HandleExportTaskFinished()
91 .exportedMaxSeq = eventSeq, in HandleExportTaskFinished()
|
| /base/hiviewdfx/hiview/plugins/event_store/event_export/database/include/ |
| H A D | export_db_manager.h | 37 void HandleExportTaskFinished(const std::string& moduleName, int64_t eventSeq);
|
| /base/hiviewdfx/hiappevent/frameworks/native/libhiappevent/cache/include/ |
| H A D | app_event_mapping_dao.h | 30 int64_t Insert(int64_t eventSeq, int64_t observerSeq);
|
| H A D | app_event_dao.h | 33 int Delete(int64_t eventSeq);
|
| H A D | app_event_store.h | 46 int64_t InsertEventMapping(int64_t eventSeq, int64_t observerSeq);
65 int DeleteEvent(int64_t eventSeq = 0);
|
| /base/hiviewdfx/hiview/base/event_store/utility/writer/ |
| H A D | sys_event_doc_writer.cpp | 179 const auto eventSeq = sysEvent->GetEventSeq();
in WriteContent() local
180 out_.write(reinterpret_cast<const char*>(&eventSeq), sizeof(eventSeq));
in WriteContent()
|
| /base/hiviewdfx/hiappevent/frameworks/native/libhiappevent/observer/ |
| H A D | os_event_listener.cpp | 94 int64_t eventSeq = AppEventStore::GetInstance().InsertEvent(event); in Init() local
95 if (eventSeq <= 0) { in Init()
99 event->SetSeq(eventSeq); in Init()
|
| H A D | app_event_observer_mgr.cpp | 43 int64_t eventSeq = AppEventStore::GetInstance().InsertEvent(event);
in StoreEventsToDb() local
44 if (eventSeq <= 0) {
in StoreEventsToDb()
48 event->SetSeq(eventSeq);
in StoreEventsToDb()
|
| /base/hiviewdfx/hiview/base/event_store/store/ |
| H A D | sys_event_database.cpp | 385 long long eventSeq = std::strtoll(splitStrs[EVENT_SEQ_INDEX].c_str(), nullptr, 0); in IsContainQueryArg() local
390 nameSeqMap[eventName] = eventSeq; in IsContainQueryArg()
400 if (queryArg.toSeq != INVALID_VALUE_INT && eventSeq >= queryArg.toSeq) { in IsContainQueryArg()
|
| /base/hiviewdfx/hiview/base/include/ |
| H A D | sys_event.h | 82 void SetEventSeq(int64_t eventSeq);
|
| /base/hiviewdfx/hiview/base/ |
| H A D | sys_event.cpp | 221 void SysEvent::SetEventSeq(int64_t eventSeq) in SetEventSeq() argument
223 eventSeq_ = eventSeq; in SetEventSeq()
|