Home
last modified time | relevance | path

Searched refs:EventStore (Results 1 – 25 of 66) sorted by relevance

123

/ohos5.0/base/hiviewdfx/hiview/base/event_store/test/unittest/common/
H A Dsys_event_dao_test.cpp142 Where(EventStore::EventCol::TS, EventStore::Op::EQ, 162027129100).Execute();
177 …EventStore::ResultSet resultSet = sysEventQuery->Where(EventStore::EventCol::SEQ, EventStore::Op::…
178 Where(EventStore::EventCol::PID, EventStore::Op::EQ, 1201). //1201 test pid value
179 Where(EventStore::EventCol::TID, EventStore::Op::EQ, 1201). //1201 test tid value
210 EventStore::Cond timeCond(EventStore::EventCol::TS, EventStore::Op::GE, 100);
211 timeCond.And(EventStore::EventCol::TS, EventStore::Op::LT, 999);
236 sysEventQuery->And(EventStore::EventCol::TS, EventStore::Op::EQ, 100)
237 .And(EventStore::EventCol::TS, EventStore::Op::EQ, 100.1f);
255 EventStore::DbQueryStatus queryStatus = EventStore::DbQueryStatus::SUCCEED;
282 EventStore::DbQueryStatus queryStatus = EventStore::DbQueryStatus::SUCCEED;
[all …]
H A Dsys_event_store_utility_test.cpp32 using namespace OHOS::HiviewDFX::EventStore;
42 int ReadDocDetails(std::ifstream& docStream, EventStore::DocHeader& header, in ReadDocDetails()
71 return sizeof(EventStore::ContentHeader); in GetContentHeaderSize()
204 ASSERT_EQ(version, EventStore::EVENT_DATA_FORMATE_VERSION::VERSION1);
208 EventStore::DocHeader header;
212 ASSERT_EQ(header.version, EventStore::EVENT_DATA_FORMATE_VERSION::VERSION1);
218 ASSERT_EQ(version, EventStore::EVENT_DATA_FORMATE_VERSION::VERSION2);
223 ASSERT_EQ(header.version, EventStore::EVENT_DATA_FORMATE_VERSION::VERSION2);
239 ASSERT_EQ(version, EventStore::EVENT_DATA_FORMATE_VERSION::VERSION3);
243 EventStore::DocHeader header;
[all …]
H A Dsys_event_sequence_mgr_test.cpp26 using namespace OHOS::HiviewDFX::EventStore;
54 auto eventSeq = EventStore::SysEventSequenceManager::GetInstance().GetSequence();
55 …EventStore::SysEventSequenceManager::GetInstance().SetSequence(eventSeq + 1000); // 1000 is a test…
56 auto eventSeqNew = EventStore::SysEventSequenceManager::GetInstance().GetSequence();
H A Dsys_event_repeat_test.cpp79 EventStore::SysEventDao::CheckRepeat(sysEvent);
86 EventStore::SysEventDao::CheckRepeat(repeatSysEvent);
110 EventStore::SysEventDao::CheckRepeat(sysEvent);
118 EventStore::SysEventDao::CheckRepeat(repeatSysEvent);
129 EventStore::SysEventDao::CheckRepeat(repackSysEvent);
151 EventStore::SysEventDao::CheckRepeat(sysEvent);
158 EventStore::SysEventDao::CheckRepeat(repeatSysEvent);
H A Dsys_event_database_test.cpp65 ASSERT_EQ(EventStore::SysEventDatabase::GetInstance().Insert(sysEvent), 0);
66 EventStore::SysEventDatabase::GetInstance().Clear();
/ohos5.0/base/hiviewdfx/hiview/adapter/plugins/eventservice/service/idl/src/
H A Devent_query_wrapper_builder.cpp54 EventStore::Cond cond; in ParseCondition()
79 { "=", EventStore::Op::EQ }, in GetOpEnum()
97 EventStore::Cond& condition) in ParseLogicCondition()
104 EventStore::Cond subCondition; in ParseLogicCondition()
283 EventStore::Cond extraCond; in BuildCondition()
371 EventStore::Cond whereCond; in BuildQuery()
372 whereCond.And(EventStore::EventCol::TS, EventStore::Op::GE, argument_.beginTime) in BuildQuery()
373 .And(EventStore::EventCol::TS, EventStore::Op::LT, argument_.endTime); in BuildQuery()
402 EventStore::Cond whereCond; in BuildQuery()
403 whereCond.And(EventStore::EventCol::SEQ, EventStore::Op::GE, argument_.fromSeq) in BuildQuery()
[all …]
H A Dsys_event_service_ohos.cpp38 using namespace OHOS::HiviewDFX::EventStore;
391 …callback->OnComplete(ERR_NO_PERMISSION, 0, EventStore::SysEventSequenceManager::GetInstance().GetS… in Query()
396 …callback->OnComplete(checkRet, 0, EventStore::SysEventSequenceManager::GetInstance().GetSequence()… in Query()
404 EventStore::SysEventSequenceManager::GetInstance().GetSequence()); in Query()
409 …callback->OnComplete(IPC_CALL_SUCCEED, 0, EventStore::SysEventSequenceManager::GetInstance().GetSe… in Query()
416 EventStore::SysEventSequenceManager::GetInstance().GetSequence()); in Query()
419 queryWrapper->SetMaxSequence(EventStore::SysEventSequenceManager::GetInstance().GetSequence()); in Query()
557 queryWrapper->SetMaxSequence(EventStore::SysEventSequenceManager::GetInstance().GetSequence()); in Export()
/ohos5.0/base/hiviewdfx/hiview/adapter/plugins/eventservice/service/idl/include/
H A Devent_query_wrapper_builder.h32 using ExtraInfoConditionMap = std::unordered_map<std::string, EventStore::Cond>;
36 bool ParseCondition(const std::string& condStr, EventStore::Cond& condition);
39 void SpliceConditionByLogic(EventStore::Cond& condition, const EventStore::Cond& subCond,
43 bool ParseAndCondition(const Json::Value& root, EventStore::Cond& condition);
46 EventStore::Op GetOpEnum(const std::string& op);
61 void SetSysEventQuery(std::shared_ptr<EventStore::SysEventQuery> query);
67 void TransportSysEvent(OHOS::HiviewDFX::EventStore::ResultSet& result,
92 std::shared_ptr<EventStore::SysEventQuery> query_ = nullptr;
105 TimeStampEventQueryWrapper(std::shared_ptr<EventStore::SysEventQuery> query) in TimeStampEventQueryWrapper()
116 SeqEventQueryWrapper(std::shared_ptr<EventStore::SysEventQuery> query) in SeqEventQueryWrapper()
[all …]
/ohos5.0/base/hiviewdfx/hiview/plugins/faultlogger/service/
H A Dfaultlog_database.cpp124 int32_t faultType, EventStore::Cond upperCaseCond, EventStore::Cond lowerCaseCond) in CreateQueries()
126 std::list<std::shared_ptr<EventStore::SysEventQuery>> queries; in CreateQueries()
168 EventStore::Cond hiviewUidCond("uid_", EventStore::Op::EQ, static_cast<int64_t>(getuid())); in GetFaultInfoList()
169 EventStore::Cond uidUpperCond = hiviewUidCond.And("UID", EventStore::Op::EQ, id); in GetFaultInfoList()
170 EventStore::Cond uidLowerCond("uid_", EventStore::Op::EQ, id); in GetFaultInfoList()
174 query->And("MODULE", EventStore::Op::EQ, module); in GetFaultInfoList()
176 EventStore::ResultSet resultSet = query->Execute(maxNum); in GetFaultInfoList()
207 EventStore::Cond hiviewUidCond("uid_", EventStore::Op::EQ, static_cast<int64_t>(getuid())); in IsFaultExist()
208 EventStore::Cond pidUpperCond = hiviewUidCond.And("PID", EventStore::Op::EQ, pid). in IsFaultExist()
209 And("UID", EventStore::Op::EQ, uid); in IsFaultExist()
[all …]
/ohos5.0/base/hiviewdfx/hiview/plugins/event_store/event_export/task/export/
H A Devent_read_handler.cpp90 EventStore::Cond whereCond; in QuerySysEvent()
91 whereCond.And(EventStore::EventCol::SEQ, EventStore::Op::GE, beginSeq) in QuerySysEvent()
92 .And(EventStore::EventCol::SEQ, EventStore::Op::LT, endSeq); in QuerySysEvent()
93 std::shared_ptr<EventStore::SysEventQuery> query = nullptr; in QuerySysEvent()
94 int32_t queryRet = static_cast<int32_t>(EventStore::DbQueryStatus::SUCCEED); in QuerySysEvent()
99 query = EventStore::SysEventDao::BuildQuery(iter->first, iter->second, 0, endSeq, beginSeq); in QuerySysEvent()
101 query->Order(EventStore::EventCol::SEQ, true); in QuerySysEvent()
103 std::make_pair(EventStore::INNER_PROCESS_ID, ""), in QuerySysEvent()
104 [&queryRet] (EventStore::DbQueryStatus status) { in QuerySysEvent()
107 if (queryRet != static_cast<int32_t>(EventStore::DbQueryStatus::SUCCEED)) { in QuerySysEvent()
[all …]
/ohos5.0/base/hiviewdfx/hiview/plugins/freeze_detector/
H A Ddb_helper.cpp29 EventStore::ResultSet& set, std::map<std::string, WatchPoint>& resultMap) in GetResultMap()
48 … long tid = std::strtol(record->GetEventValue(EventStore::EventCol::TID).c_str(), nullptr, 0); in GetResultMap()
56 std::string info = record->GetEventValue(EventStore::EventCol::INFO); in GetResultMap()
81 … auto eventQuery = EventStore::SysEventDao::BuildQuery(result.GetDomain(), {result.GetStringId()}); in SelectEventFromDB()
82 std::vector<std::string> selections { EventStore::EventCol::TS }; in SelectEventFromDB()
85 .Where(EventStore::EventCol::TS, EventStore::Op::GE, static_cast<int64_t>(start)) in SelectEventFromDB()
86 .And(EventStore::EventCol::TS, EventStore::Op::LE, static_cast<int64_t>(end)); in SelectEventFromDB()
91 EventStore::ResultSet set = eventQuery->Execute(); in SelectEventFromDB()
/ohos5.0/base/hiviewdfx/hiview/adapter/plugins/eventservice/service/test/unittest/common/
H A Devent_query_wrapper_builder_test.cpp44 EventStore::Cond condition;
60 EventStore::Cond condition;
75 EventStore::Cond condition;
91 EventStore::Cond condition;
107 EventStore::Cond condition;
123 EventStore::Cond condition;
139 EventStore::Cond condition;
155 EventStore::Cond condition;
/ohos5.0/base/hiviewdfx/hiview/base/event_store/utility/reader/
H A Dcontent_reader_version_3.cpp27 REGISTER_CONTENT_READER(EventStore::EVENT_DATA_FORMATE_VERSION::VERSION3, ContentReaderVersion3);
28 int ContentReaderVersion3::ReadDocDetails(std::ifstream& docStream, EventStore::DocHeader& header, in ReadDocDetails()
35 docStream.read(reinterpret_cast<char*>(&header), sizeof(EventStore::DocHeader)); in ReadDocDetails()
50 int ContentReaderVersion3::GetContentHeader(uint8_t* content, EventStore::ContentHeader& header) in GetContentHeader()
56 header = *(reinterpret_cast<EventStore::ContentHeader*>(content + BLOCK_SIZE)); in GetContentHeader()
62 return sizeof(EventStore::ContentHeader); in GetContentHeaderSize()
H A Dcontent_reader_version_4.cpp26 REGISTER_CONTENT_READER(EventStore::EVENT_DATA_FORMATE_VERSION::VERSION4, ContentReaderVersion4);
27 int ContentReaderVersion4::ReadDocDetails(std::ifstream& docStream, EventStore::DocHeader& header, in ReadDocDetails()
34 docStream.read(reinterpret_cast<char*>(&header), sizeof(EventStore::DocHeader)); in ReadDocDetails()
H A Dcontent_reader.cpp28 using namespace EventStore;
54 return EventStore::EVENT_DATA_FORMATE_VERSION::INVALID; in ReadFmtVersion()
58 uint8_t dataFmtVersion = EventStore::EVENT_DATA_FORMATE_VERSION::INVALID; in ReadFmtVersion()
68 uint32_t eventSize = contentSize - GetContentHeaderSize() + sizeof(EventStore::ContentHeader) - in ReadRawData()
106 EventStore::ContentHeader contentHeader; in AppendContentData()
112 sizeof(EventStore::ContentHeader) - SEQ_SIZE)) { in AppendContentData()
H A Dcontent_reader_version_1.cpp27 REGISTER_CONTENT_READER(EventStore::EVENT_DATA_FORMATE_VERSION::VERSION1, ContentReaderVersion1);
81 int ContentReaderVersion1::ReadDocDetails(std::ifstream& docStream, EventStore::DocHeader& header, in ReadDocDetails()
109 int ContentReaderVersion1::GetContentHeader(uint8_t* content, EventStore::ContentHeader& header) in GetContentHeader()
H A Dcontent_reader_version_2.cpp27 REGISTER_CONTENT_READER(EventStore::EVENT_DATA_FORMATE_VERSION::VERSION2, ContentReaderVersion2);
84 int ContentReaderVersion2::ReadDocDetails(std::ifstream& docStream, EventStore::DocHeader& header, in ReadDocDetails()
111 int ContentReaderVersion2::GetContentHeader(uint8_t* content, EventStore::ContentHeader& header) in GetContentHeader()
/ohos5.0/base/hiviewdfx/hiview/plugins/reliability/bbox_detectors/
H A Dhisysevent_util.cpp25 auto sysEventQuery = EventStore::SysEventDao::BuildQuery("KERNEL_VENDOR", {name}); in IsEventProcessed()
29 std::vector<std::string> selections{EventStore::EventCol::TS}; in IsEventProcessed()
30 EventStore::ResultSet resultSet = sysEventQuery->Select(selections). in IsEventProcessed()
31 Where(key, EventStore::Op::EQ, value).Execute(); in IsEventProcessed()
/ohos5.0/base/hiviewdfx/hiview/base/event_store/sequence/
H A Dsys_event_sequence_mgr.cpp26 namespace EventStore { namespace
58 EventStore::SysEventDao::Restore(); in SysEventSequenceManager()
99 return EventStore::SysEventDao::GetDatabaseDir() + SEQ_PERSISTS_FILE_NAME; in GetSequenceFile()
/ohos5.0/base/hiviewdfx/hiview/plugins/event_store/
H A Dsys_event_store.cpp109 int64_t eventSeq = EventStore::SysEventSequenceManager::GetInstance().GetSequence(); in OnEvent()
115 EventStore::SysEventSequenceManager::GetInstance().SetSequence(++eventSeq); in OnEvent()
120 EventStore::SysEventDao::Backup(); in OnEvent()
/ohos5.0/base/hiviewdfx/hiview/base/event_store/utility/reader/include/
H A Dcontent_reader_version_1.h28 …int ReadDocDetails(std::ifstream& docStream, EventStore::DocHeader& header, uint64_t& docHeaderSiz…
33 int GetContentHeader(uint8_t* content, EventStore::ContentHeader& header) override;
H A Dcontent_reader_version_2.h28 …int ReadDocDetails(std::ifstream& docStream, EventStore::DocHeader& header, uint64_t& docHeaderSiz…
33 virtual int GetContentHeader(uint8_t* content, EventStore::ContentHeader& header) override;
H A Dcontent_reader_version_3.h35 …int ReadDocDetails(std::ifstream& docStream, EventStore::DocHeader& header, uint64_t& docHeaderSiz…
40 virtual int GetContentHeader(uint8_t* content, EventStore::ContentHeader& header) override;
H A Dcontent_reader.h58 virtual int ReadDocDetails(std::ifstream& docStream, EventStore::DocHeader& header,
63 virtual int GetContentHeader(uint8_t* content, EventStore::ContentHeader& header) = 0;
/ohos5.0/base/hiviewdfx/hiview/base/
H A Dlibhiviewbase.map194 "OHOS::HiviewDFX::EventStore::EventCol::NAME";
196 "OHOS::HiviewDFX::EventStore::EventCol::TZ";
197 "OHOS::HiviewDFX::EventStore::EventCol::TS";
198 "OHOS::HiviewDFX::EventStore::EventCol::TID";
199 "OHOS::HiviewDFX::EventStore::EventCol::PID";
200 "OHOS::HiviewDFX::EventStore::EventCol::UID";
203 "OHOS::HiviewDFX::EventStore::EventCol::SEQ";
204 "OHOS::HiviewDFX::EventStore::EventCol::TAG";
254 "OHOS::HiviewDFX::EventStore::Cond::And(OHOS::HiviewDFX::EventStore::Cond const&)";
259 "OHOS::HiviewDFX::EventStore::SysEventQuery::And(OHOS::HiviewDFX::EventStore::Cond const&)";
[all …]

123