| /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()
56 void QuerySysEventCallbackProxy::OnComplete(int32_t reason, int32_t total, int64_t seq) in OnComplete() argument
73 ret = data.WriteInt64(seq); in OnComplete()
|
| /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()
|
| /base/hiviewdfx/hicollie/frameworks/native/ |
| D | timer_ring.cpp | 49 void TimerRing::InitTaskNode(struct TaskNode* taskNode, unsigned int seq) in InitTaskNode() argument
52 taskNode->seq = seq; in InitTaskNode()
99 InitTaskNode(node, node->seq); in TryRecycle()
179 …>id = (((static_cast<unsigned int>(timestamp) % MAX_XCOLLIE_NUM) << COOKIE_SHIFT) | taskNode->seq); in AddTask()
211 unsigned int seq = WRAP_SEQ(static_cast<unsigned int>(id)); in CancelTask() local
212 if (seq >= MAX_XCOLLIE_NUM) { in CancelTask()
213 XCOLLIE_LOGE("cancel task failed, seq %u limit, id 0x%x valid", seq, id); in CancelTask()
219 struct TaskNode* taskNode = &taskNodes_[seq]; in CancelTask()
228 InitTaskNode(taskNode, taskNode->seq); in CancelTask()
244 unsigned int seq = WRAP_SEQ(static_cast<unsigned int>(id)); in UpdateTask() local
[all …]
|
| D | timer_ring.h | 52 unsigned int seq; member
87 void InitTaskNode(struct TaskNode* taskNode, unsigned int 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/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/adapter/plugins/eventservice/service/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 | 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);
|
| /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 | 49 WatchPoint::Builder& WatchPoint::Builder::InitSeq(long seq) in InitSeq() argument
51 seq_ = seq; in InitSeq()
181 void WatchPoint::SetSeq(long seq) in SetSeq() argument
183 seq_ = seq; in SetSeq()
|
| /base/hiviewdfx/hiview/adapter/plugins/eventservice/service/ |
| D | sys_event_service_adapter.cpp | 46 void SysEventServiceAdapter::UpdateEventSeq(int64_t seq) in UpdateEventSeq() argument
53 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/plugins/eventservice/test/fuzztest/common/eventservice_fuzzer/ |
| D | eventservice_fuzzer.cpp | 35 …void OnQuery(const std::vector<std::u16string>& sysEvent, const std::vector<int64_t>& seq) overrid… in OnQuery() argument
37 void OnComplete(int32_t reason, int32_t total, int64_t seq) override {} in OnComplete() argument
|
| /base/hiviewdfx/hisysevent/test/moduletest/common/ |
| D | hisysevent_adapter_native_test.cpp | 75 void OnQuery(const std::vector<std::u16string>& sysEvent, const std::vector<int64_t>& seq) {} in OnQuery() argument
76 void OnComplete(int32_t reason, int32_t total, int64_t seq) {} in OnComplete() argument
251 std::vector<int64_t> seq {}; variable
252 proxy.OnQuery(sysEvent, seq);
255 seq.emplace_back(1);
256 proxy.OnQuery(sysEvent, seq);
440 std::vector<int64_t> seq {}; variable
441 proxy.OnQuery(sysEvent, seq);
|
| /base/hiviewdfx/hiview/plugins/eventservice/ |
| D | event_json_parser.cpp | 366 void EventJsonParser::ReadSeqFromFile(int64_t& seq) in EventJsonParser() argument
374 seq = static_cast<int64_t>(strtoll(content.c_str(), nullptr, 0)); in EventJsonParser()
375 HIVIEW_LOGI("read max sequence from local file successful, value is %{public}" PRId64 ".", seq); in EventJsonParser()
376 SysEventServiceAdapter::UpdateEventSeq(seq); in EventJsonParser()
379 void EventJsonParser::WriteSeqToFile(int64_t seq) const in EventJsonParser()
382 std::string content = std::to_string(seq); in EventJsonParser()
386 SysEventServiceAdapter::UpdateEventSeq(seq); in EventJsonParser()
|