| /developtools/smartperf_host/trace_streamer/src/filter/ |
| H A D | measure_filter.cpp | 35 uint64_t internalTid, in AppendNewMeasureData()
40 auto filterId = GetOrCreateFilterId(enumType, internalTid, nameIndex); in AppendNewMeasureData()
63 uint32_t MeasureFilter::GetOrCreateFilterId(EnumMeasureFilter enumType, uint64_t internalTid, DataIndex nameIndex) in GetOrCreateFilterId() argument
66 auto filterId = tidStreamIdFilterIdMap.Find(internalTid, nameIndex); in GetOrCreateFilterId()
72 filterTypeValue.at(enumType), traceDataCache_->GetDataFromDict(nameIndex), internalTid); in GetOrCreateFilterId()
73 tidStreamIdFilterIdMap.Insert(internalTid, nameIndex, newFilterId); in GetOrCreateFilterId()
74 AddCertainFilterId(enumType, internalTid, nameIndex, newFilterId); in GetOrCreateFilterId()
79 uint64_t internalTid, in AddCertainFilterId()
85 static_cast<uint32_t>(filterId), static_cast<uint32_t>(nameIndex), static_cast<uint32_t>(internalTid)); in AddCertainFilterId()
87 traceDataCache_->GetCpuMeasuresData()->AppendNewFilter(filterId, static_cast<uint32_t>(nameIndex), internalTid); in AddCertainFilterId()
34 AppendNewMeasureData(EnumMeasureFilter enumType, uint64_t internalTid, DataIndex nameIndex, uint64_t timeStamp, int64_t value) AppendNewMeasureData() argument
78 AddCertainFilterId(EnumMeasureFilter enumType, uint64_t internalTid, DataIndex nameIndex, uint64_t filterId) AddCertainFilterId() argument
[all...] |
| H A D | process_filter.cpp | 70 uint32_t internalTid = GetOrCreateThreadWithPid(tid, pid); in UpdateOrCreateThreadWithPidAndName() local
71 auto thread = traceDataCache_->GetThreadData(internalTid); in UpdateOrCreateThreadWithPidAndName()
78 return internalTid; in UpdateOrCreateThreadWithPidAndName()
84 uint32_t internalTid; in GetOrCreateThreadWithPid() local
86 internalTid = GetInternalTid(tid); in GetOrCreateThreadWithPid()
88 internalTid = GetInternalTid(tid, pid); in GetOrCreateThreadWithPid()
90 if (internalTid != INVALID_ID) { in GetOrCreateThreadWithPid()
91 thread = traceDataCache_->GetThreadData(internalTid); in GetOrCreateThreadWithPid()
93 std::tie(internalTid, thread) = NewThread(tid); in GetOrCreateThreadWithPid()
100 return internalTid; in GetOrCreateThreadWithPid()
112 auto internalTid = GetInternalTid(pid, pid); UpdateOrCreateProcessWithName() local
135 InternalTid internalTid = INVALID_ITID; UpdateOrCreateThreadWithNameIndex() local
147 uint32_t internalTid = INVALID_ID; GetInternalTid() local
171 auto internalTid = std::prev(itRange.second)->second; GetInternalTid() local
212 uint32_t internalTid = traceDataCache_->NewInternalThread(tid); NewThread() local
[all...] |
| H A D | slice_filter.cpp | 46 InternalTid internalTid = INVALID_ITID; in BeginSlice() local
48 internalTid = streamFilters_->processFilter_->UpdateOrCreateThreadWithPidAndName(pid, threadGroupId, comm); in BeginSlice()
51 internalTid = streamFilters_->processFilter_->UpdateOrCreateThreadWithName(timeStamp, pid, comm); in BeginSlice()
53 // make a SliceData DataItem, {timeStamp, dur, internalTid, cat, nameIndex} in BeginSlice()
54 SliceData sliceData = {timeStamp, -1, internalTid, cat, nameIndex}; in BeginSlice()
66 sliceData.internalTid, sliceData.cat, in IrqHandlerEntry()
108 sliceData.internalTid, sliceData.cat, in IpiHandlerEntry()
137 sliceData.internalTid, sliceData.cat, in SoftIrqEntry()
176 void SliceFilter::RememberSliceData(InternalTid internalTid, in RememberSliceData() argument
182 if (stackMap.find(internalTid) in RememberSliceData()
196 InternalTid internalTid = streamFilters_->processFilter_->UpdateOrCreateThread(timeStamp, pid); AsyncBinder() local
200 CurrentDepth(InternalTid internalTid) CurrentDepth() argument
214 UpdateDepth(bool increase, InternalTid internalTid, int32_t depth) UpdateDepth() argument
313 InternalTid internalTid = sliceData.internalTid; StartSlice() local
356 InternalTid internalTid = streamFilters_->processFilter_->UpdateOrCreateThread(timeStamp, pid); BeginBinder() local
361 CompleteSlice(uint64_t timeStamp, uint32_t internalTid, DataIndex category, DataIndex name, ArgsSet args) CompleteSlice() argument
417 auto internalTid = streamFilters_->processFilter_->UpdateOrCreateThread(timeStamp, pid); EndBinder() local
422 InternalTid internalTid = streamFilters_->processFilter_->GetInternalTid(tid); AddArgs() local
447 InternalPid internalTid = streamFilters_->processFilter_->UpdateOrCreateThread(timeStamp, threadGroupId); StartAsyncSlice() local
481 InternalPid internalTid = streamFilters_->processFilter_->UpdateOrCreateThread(timeStamp, threadGroupId); FinishAsyncSlice() local
509 InternalPid internalTid = streamFilters_->processFilter_->UpdateOrCreateThread(timeStamp, threadGroupId); StartGEvent() local
532 InternalPid internalTid = streamFilters_->processFilter_->UpdateOrCreateThread(timeStamp, threadGroupId); FinishHEvent() local
565 uint32_t internalTid = INVALID_UINT32; EndSlice() local
[all...] |
| H A D | cpu_filter.cpp | 229 void CpuFilter::InsertWakeupEvent(uint64_t ts, uint32_t internalTid, bool isWaking) in InsertWakeupEvent() argument
231 if (!isWaking && !toRunnableTid_.count(internalTid)) { in InsertWakeupEvent()
232 toRunnableTid_[internalTid] = ts; in InsertWakeupEvent()
268 void CpuFilter::CheckWakeupEvent(uint32_t internalTid) in CheckWakeupEvent() argument
270 if (toRunnableTid_.count(internalTid)) { in CheckWakeupEvent()
271 uint64_t lastrow = RowOfInternalTidInStateTable(internalTid); in CheckWakeupEvent()
272 auto lastState = StateOfInternalTidInStateTable(internalTid); in CheckWakeupEvent()
274 toRunnableTid_.erase(internalTid); in CheckWakeupEvent()
279 toRunnableTid_.at(internalTid)); in CheckWakeupEvent()
282 toRunnableTid_.at(internalTid), INVALID_TIM in CheckWakeupEvent()
[all...] |
| H A D | measure_filter.h | 51 uint64_t internalTid,
57 uint32_t GetOrCreateFilterId(EnumMeasureFilter enumType, uint64_t internalTid, DataIndex nameIndex);
58 void AddCertainFilterId(EnumMeasureFilter enumType, uint64_t internalTid, DataIndex nameIndex, uint64_t filterId);
|
| H A D | slice_filter.h | 33 InternalTid internalTid; member
113 void RememberSliceData(InternalTid internalTid,
118 uint8_t UpdateDepth(bool increase, InternalTid internalTid, int32_t depth = -1);
121 uint8_t CurrentDepth(InternalTid internalTid);
|
| H A D | cpu_filter.h | 50 void InsertWakeupEvent(uint64_t ts, uint32_t internalTid, bool isWaking = false);
77 void CheckWakeupEvent(uint32_t internalTid);
|
| H A D | binder_filter.cpp | 110 InternalTid internalTid = streamFilters_->processFilter_->UpdateOrCreateThread(ts, pid); in ReceiveTraction() local
111 const auto threadName = traceDataCache_->GetConstThreadData(internalTid).nameIndex_; in ReceiveTraction()
|
| /developtools/smartperf_host/trace_streamer/src/trace_data/trace_stdtype/ftrace/ |
| H A D | callstack_stdtype.cpp | 23 AppendCommonInfo(callStackInternalRow.startT, callStackInternalRow.durationNs, callStackInternalRow.internalTid); in AppendInternalAsyncSlice()
33 AppendCommonInfo(callStackInternalRow.startT, callStackInternalRow.durationNs, callStackInternalRow.internalTid); in AppendInternalSlice()
41 void CallStack::AppendCommonInfo(uint64_t startT, uint64_t durationNs, InternalTid internalTid) in AppendCommonInfo() argument
45 callIds_.emplace_back(internalTid); in AppendCommonInfo()
|
| H A D | sched_stdtype.cpp | 128 internalTids_.emplace_back(schedSliceRow.internalTid); in AppendSchedSlice()
158 size_t Raw::AppendRawData(uint64_t timeStamp, uint32_t name, uint32_t cpu, uint32_t internalTid) in AppendRawData() argument
164 internalTids_.emplace_back(internalTid); in AppendRawData()
170 int64_t internalTid, in AppendInstantEventData()
173 internalTids_.emplace_back(internalTid); in AppendInstantEventData()
168 AppendInstantEventData(uint64_t timeStamp, DataIndex nameIndex, int64_t internalTid, int64_t wakeupFromInternalPid) AppendInstantEventData() argument
|
| H A D | sched_stdtype.h | 94 uint32_t internalTid = INVALID_UINT32; member
158 size_t AppendRawData(uint64_t timeStamp, uint32_t name, uint32_t cpu, uint32_t internalTid);
187 int64_t internalTid,
|
| H A D | callstack_stdtype.h | 28 InternalTid internalTid = INVALID_UINT32; member
90 void AppendCommonInfo(uint64_t startT, uint64_t durationNs, InternalTid internalTid);
|
| /developtools/smartperf_host/trace_streamer/src/trace_data/ |
| H A D | trace_data_cache_reader.cpp | 35 const Thread &TraceDataCacheReader::GetConstThreadData(InternalTid internalTid) const
37 TS_ASSERT(internalTid < internalThreadsData_.size());
38 return internalThreadsData_[internalTid];
|
| H A D | trace_data_cache_writer.cpp | 46 Thread *TraceDataCacheWriter::GetThreadData(InternalTid internalTid)
48 if (internalTid >= internalThreadsData_.size()) {
51 return &internalThreadsData_[internalTid];
|
| H A D | trace_data_cache_reader.h | 52 const Thread &GetConstThreadData(InternalTid internalTid) const;
|
| H A D | trace_data_cache_writer.h | 37 Thread *GetThreadData(InternalTid internalTid);
|
| /developtools/smartperf_host/trace_streamer/src/parser/rawtrace_parser/ |
| H A D | cpu_detail_parser.cpp | 312 InternalTid internalTid = in SchedWakeupEvent() local
316 instants->AppendInstantEventData(event.msgPtr->timestamp(), schedWakeupIndex_, internalTid, wakeupFromPid); in SchedWakeupEvent()
317 streamFilters_->cpuFilter_->InsertWakeupEvent(event.msgPtr->timestamp(), internalTid); in SchedWakeupEvent()
319 internalTid); in SchedWakeupEvent()
327 auto internalTid = in SchedWakingEvent() local
330 streamFilters_->cpuFilter_->InsertWakeupEvent(event.msgPtr->timestamp(), internalTid, true); in SchedWakingEvent()
331 instants->AppendInstantEventData(event.msgPtr->timestamp(), schedWakingIndex_, internalTid, wakeupFromPid); in SchedWakingEvent()
341 auto internalTid = in SchedWakeupNewEvent() local
344 instants->AppendInstantEventData(event.msgPtr->timestamp(), schedWakeupNewIndex_, internalTid, wakeupFromPid); in SchedWakeupNewEvent()
345 streamFilters_->cpuFilter_->InsertWakeupEvent(event.msgPtr->timestamp(), internalTid); in SchedWakeupNewEvent()
[all...] |
| /developtools/smartperf_host/trace_streamer/test/unittest/table/ |
| H A D | table_test.cpp | 126 InternalTid internalTid = 1; in HWTEST_F() local
143 CallStackInternalRow callStackInternalRow = {startT, durationNs, internalTid, cat, name, depth}; in HWTEST_F()
506 int64_t internalTid = 1; in HWTEST_F() local
527 stream_.traceDataCache_->GetInstantsData()->AppendInstantEventData(timeStamp, nameIndex, internalTid, in HWTEST_F()
601 InternalTid internalTid = 1; in HWTEST_F() local
615 CallStackInternalRow callStackInternalRow = {startT, durationNs, internalTid, cat, name, depth}; in HWTEST_F()
711 uint64_t internalTid = 1; in HWTEST_F() local
713 stream_.traceDataCache_->GetProcessMeasureFilterData()->AppendNewFilter(filterId, nameIndex, internalTid); in HWTEST_F()
1066 uint32_t internalTid = 1; in HWTEST_F() local
1073 stream_.traceDataCache_->GetRawData()->AppendRawData(timeStamp, name, cpu, internalTid); in HWTEST_F()
1099 uint64_t internalTid = 1; HWTEST_F() local
[all...] |
| /developtools/smartperf_host/trace_streamer/src/parser/pbreader_parser/htrace_parser/ |
| H A D | htrace_event_parser.cpp | 675 InternalTid internalTid = streamFilters_->processFilter_->UpdateOrCreateThread(event.timeStamp, msg.pid()); in SchedWakeupEvent() local
677 instants->AppendInstantEventData(event.timeStamp, schedWakeupName_, internalTid, wakeupFromPid); in SchedWakeupEvent()
678 streamFilters_->cpuFilter_->InsertWakeupEvent(event.timeStamp, internalTid); in SchedWakeupEvent()
680 traceDataCache_->GetRawData()->AppendRawData(event.timeStamp, RAW_SCHED_WAKEUP, targetCpu, internalTid); in SchedWakeupEvent()
689 auto internalTid = streamFilters_->processFilter_->UpdateOrCreateThread(event.timeStamp, msg.pid()); in SchedWakeupNewEvent() local
691 instants->AppendInstantEventData(event.timeStamp, schedWakeupNewName_, internalTid, wakeupFromPid); in SchedWakeupNewEvent()
692 streamFilters_->cpuFilter_->InsertWakeupEvent(event.timeStamp, internalTid); in SchedWakeupNewEvent()
694 traceDataCache_->GetRawData()->AppendRawData(event.timeStamp, RAW_SCHED_WAKEUP, targetCpu, internalTid); in SchedWakeupNewEvent()
703 auto internalTid = streamFilters_->processFilter_->UpdateOrCreateThread(event.timeStamp, wakePidValue); in SchedWakingEvent() local
705 streamFilters_->cpuFilter_->InsertWakeupEvent(event.timeStamp, internalTid, tru in SchedWakingEvent()
[all...] |
| /developtools/smartperf_host/trace_streamer/src/parser/ptreader_parser/bytrace_parser/ |
| H A D | bytrace_event_parser.cpp | 312 InternalTid internalTid = streamFilters_->processFilter_->UpdateOrCreateThread(line.ts, wakePidValue.value_or(0)); in SchedWakeupEvent() local
313 streamFilters_->cpuFilter_->InsertWakeupEvent(line.ts, internalTid); in SchedWakeupEvent()
317 instants->AppendInstantEventData(line.ts, schedWakeupName_, internalTid, wakeupFromPid); in SchedWakeupEvent()
340 InternalTid internalTid = streamFilters_->processFilter_->UpdateOrCreateThread(line.ts, wakePidValue.value()); in SchedWakingEvent() local
345 streamFilters_->cpuFilter_->InsertWakeupEvent(line.ts, internalTid, true); in SchedWakingEvent()
346 instants->AppendInstantEventData(line.ts, schedWakingName_, internalTid, wakeupFromPid); in SchedWakingEvent()
|