| /base/hiviewdfx/hiview/adapter/plugins/eventservice/service/idl/src/ |
| D | query_sys_event_callback_stub.cpp | 43 std::vector<int64_t> seq; in OnRemoteRequest() local
44 ret = data.ReadInt64Vector(&seq); in OnRemoteRequest()
49 OnQuery(sysEvent, seq); in OnRemoteRequest()
65 int64_t seq = 0; in OnRemoteRequest() local
66 ret = data.ReadInt64(seq); in OnRemoteRequest()
71 OnComplete(reason, total, seq); in OnRemoteRequest()
|
| D | query_sys_event_callback_proxy.cpp | 25 …allbackProxy::OnQuery(const std::vector<std::u16string>& sysEvent, const std::vector<int64_t>& seq) in OnQuery() argument
43 auto ret = data.WriteInt64Vector(seq); in OnQuery()
57 void QuerySysEventCallbackProxy::OnComplete(int32_t reason, int32_t total, int64_t seq) in OnComplete() argument
74 ret = data.WriteInt64(seq); in OnComplete()
|
| D | data_publisher_sys_event_callback.cpp | 36 const std::vector<int64_t>& seq) in OnQuery() argument
66 void DataPublisherSysEventCallback::OnComplete(int32_t reason, int32_t total, int64_t seq) in OnComplete() argument
|
| /base/hiviewdfx/hisysevent/adapter/native/idl/src/ |
| D | query_sys_event_callback_stub.cpp | 49 std::vector<int64_t> seq; in OnRemoteRequest() local
50 ret = data.ReadInt64Vector(&seq); in OnRemoteRequest()
55 OnQuery(sysEvent, seq); in OnRemoteRequest()
71 int64_t seq = 0; in OnRemoteRequest() local
72 ret = data.ReadInt64(seq); in OnRemoteRequest()
77 OnComplete(reason, total, seq); in OnRemoteRequest()
|
| D | hisysevent_query_proxy.cpp | 23 const ::std::vector<int64_t>& seq) in OnQuery()
30 queryCallback->OnQuery(destSysEvents, seq); in OnQuery()
34 void HiSysEventQueryProxy::OnComplete(int32_t reason, int32_t total, int64_t seq) in OnComplete() argument
37 queryCallback->OnComplete(reason, total, seq); in OnComplete()
|
| D | query_sys_event_callback_proxy.cpp | 27 …allbackProxy::OnQuery(const std::vector<std::u16string>& sysEvent, const std::vector<int64_t>& seq) in OnQuery() argument
45 auto ret = data.WriteInt64Vector(seq); in OnQuery()
58 void QuerySysEventCallbackProxy::OnComplete(int32_t reason, int32_t total, int64_t seq) in OnComplete() argument
75 ret = data.WriteInt64(seq); in OnComplete()
|
| /base/hiviewdfx/hiview/base/include/ |
| D | event_priority_queue.h | 24 bool remove(uint64_t seq) in remove() argument
26 auto it = std::find_if(this->c.begin(), this->c.end(), [seq](T event) { in remove()
27 return event.seq == seq; in remove()
|
| D | event_loop.h | 58 uint64_t seq = 0; member
72 event.seq = now; in CreateLoopEvent()
121 bool RemoveEvent(uint64_t seq);
|
| /base/hiviewdfx/hiappevent/frameworks/native/libhiappevent/cache/ |
| D | app_event_block.cpp | 44 int64_t seq = 0; in Take() local
45 int result = blockDao_->GetPackagesBySize(size, packages, seq); in Take()
48 } else if (result > 0 && blockDao_->DeletePackageBySeq(seq) == DB_SUCC) { in Take()
|
| D | app_event_block_dao.cpp | 51 int64_t seq = 0; in InsertPackage() local
52 if (int ret = dbStore->Insert(seq, table_, values); ret != NativeRdb::E_OK) { in InsertPackage()
59 int AppEventBlockDao::DeletePackageBySeq(int64_t seq) in DeletePackageBySeq() argument
67 HiLog::Debug(LABEL, "start to delete %{public}s, seq=%{public}" PRId64, table_.c_str(), seq); in DeletePackageBySeq()
72 std::vector<std::string> fields = { std::to_string(seq) }; in DeletePackageBySeq()
101 int AppEventBlockDao::GetPackagesBySize(int size, std::vector<std::string> &packages, int64_t& seq) in GetPackagesBySize() argument
125 resultSet->GetLong(0, seq); // 0 means seq field in GetPackagesBySize()
|
| /base/hiviewdfx/hiview/adapter/plugins/eventservice/service/idl/include/ |
| D | iquery_base_callback.h | 29 …ual void OnQuery(const std::vector<std::u16string>& sysEvent, const std::vector<int64_t>& seq) = 0;
30 virtual void OnComplete(int32_t reason, int32_t total, int64_t seq) = 0;
|
| D | query_sys_event_callback_proxy.h | 34 void OnQuery(const std::vector<std::u16string>& sysEvent, const std::vector<int64_t>& seq);
35 void OnComplete(int32_t reason, int32_t total, int64_t seq);
|
| D | data_publisher_sys_event_callback.h | 33 …void OnQuery(const std::vector<std::u16string>& sysEvent, const std::vector<int64_t>& seq) overrid…
34 void OnComplete(int32_t reason, int32_t total, int64_t seq) override;
|
| /base/hiviewdfx/hisysevent/interfaces/js/kits/napi/src/ |
| D | napi_hisysevent_querier.cpp | 50 const std::vector<int64_t>& seq) in OnQuery() argument
53 [this, sysEvents, seq] (const napi_env env, const napi_ref ref, pid_t threadId) { in OnQuery()
73 void NapiHiSysEventQuerier::OnComplete(int32_t reason, int32_t total, int64_t seq) in OnComplete() argument
76 [this, reason, total, seq] (const napi_env env, const napi_ref ref, pid_t threadId) { in OnComplete()
85 NapiHiSysEventUtil::CreateInt64Value(env, seq, seqJsParm); in OnComplete()
|
| /base/hiviewdfx/hisysevent/adapter/native/idl/include/ |
| D | iquery_sys_event_callback.h | 27 …ual void OnQuery(const std::vector<std::u16string>& sysEvent, const std::vector<int64_t>& seq) = 0;
28 virtual void OnComplete(int32_t reason, int32_t total, int64_t seq) = 0;
|
| D | hisysevent_query_proxy.h | 35 const ::std::vector<int64_t>& seq) override;
36 void OnComplete(int32_t reason, int32_t total, int64_t seq) override;
|
| D | query_sys_event_callback_proxy.h | 41 void OnQuery(const std::vector<std::u16string>& sysEvent, const std::vector<int64_t>& seq);
42 void OnComplete(int32_t reason, int32_t total, int64_t seq);
|
| /base/hiviewdfx/hiview/base/ |
| D | pipeline.cpp | 125 auto seq = caller->GetHiviewContext()->GetPipelineSequenceByName(pipelineName); in FillPipelineInfo() local
127 while (!seq.empty()) { in FillPipelineInfo()
128 auto& plugin = seq.front(); in FillPipelineInfo()
134 seq.pop_front(); in FillPipelineInfo()
137 event->SetPipelineInfo(pipelineName, seq); in FillPipelineInfo()
|
| /base/hiviewdfx/hiappevent/frameworks/native/libhiappevent/cache/include/ |
| D | app_event_block_dao.h | 36 int DeletePackageBySeq(int64_t seq);
42 int GetPackagesBySize(int size, std::vector<std::string> &packages, int64_t& seq);
|
| /base/hiviewdfx/hisysevent/interfaces/js/kits/napi/include/ |
| D | napi_hisysevent_querier.h | 41 const std::vector<int64_t>& seq) override;
42 virtual void OnComplete(int32_t reason, int32_t total, int64_t seq) override;
|
| /base/hiviewdfx/hiview/plugins/freeze_detector/ |
| D | watch_point.cpp | 51 WatchPoint::Builder& WatchPoint::Builder::InitSeq(long seq) in InitSeq() argument
53 seq_ = seq; in InitSeq()
205 void WatchPoint::SetSeq(long seq) in SetSeq() argument
207 seq_ = seq; in SetSeq()
|
| /base/hiviewdfx/hiview/adapter/plugins/eventservice/service/ |
| D | sys_event_service_adapter.cpp | 47 void SysEventServiceAdapter::UpdateEventSeq(int64_t seq) in UpdateEventSeq() argument
54 service->UpdateEventSeq(seq); in UpdateEventSeq()
|
| /base/hiviewdfx/hiview/base/event_pool/ |
| D | event_thread_pool.h | 35 seq = TimeUtil::GetNanoTime(); in TaskEvent()
43 uint64_t seq; variable
|
| /base/hiviewdfx/hiview/base/event_store/utility/reader/ |
| D | sys_event_doc_reader.cpp | 320 …cReader::BuildEventJson(std::string& eventJson, uint8_t* rawEvent, uint32_t eventSize, int64_t seq) in BuildEventJson() argument
330 if (seq < 0) { in BuildEventJson()
331 HIVIEW_LOGE("event seq is invalid, seq=%{public}" PRId64, seq); in BuildEventJson()
338 AppendJsonValue(eventJson, EventCol::SEQ, seq); in BuildEventJson()
350 int64_t seq = *(reinterpret_cast<int64_t*>(content + BLOCK_SIZE)); in TryToAddEntry() local
370 if (BuildEventJson(eventJson, rawEvent, eventSize, seq) != DOC_STORE_SUCCESS) { in TryToAddEntry()
376 entry.id = seq; in TryToAddEntry()
|
| /base/hiviewdfx/hiview/core/ |
| D | event_json_parser.cpp | 358 void EventJsonParser::ReadSeqFromFile(int64_t& seq) in ReadSeqFromFile() argument
366 seq = static_cast<int64_t>(strtoll(content.c_str(), nullptr, 0)); in ReadSeqFromFile()
367 HIVIEW_LOGI("read max sequence from local file successful, value is %{public}" PRId64 ".", seq); in ReadSeqFromFile()
368 SysEventServiceAdapter::UpdateEventSeq(seq); in ReadSeqFromFile()
371 void EventJsonParser::WriteSeqToFile(int64_t seq) const in WriteSeqToFile()
374 std::string content = std::to_string(seq); in WriteSeqToFile()
378 SysEventServiceAdapter::UpdateEventSeq(seq); in WriteSeqToFile()
|