| /developtools/smartperf_host/trace_streamer/src/parser/htrace_pbreader_parser/ |
| D | htrace_disk_io_parser.cpp | 61 for (auto itor = diskIOData_.begin(); itor != diskIOData_.end(); itor++) { in Finish() local
62 itor->ts = streamFilters_->clockFilter_->ToPrimaryTraceTime(TS_CLOCK_REALTIME, itor->ts); in Finish()
63 UpdatePluginTimeRange(TS_CLOCK_REALTIME, itor->ts, itor->ts); in Finish()
65 lastTs = itor->ts; in Finish()
69 auto dur = itor->ts - lastTs; in Finish()
72 itor->ts, itor->ts - lastTs, itor->rdSectorsKb, itor->wrSectorsKb, in Finish()
73 1.0 * (itor->rdSectorsKb - itor->prevRdSectorsKb) / durS, in Finish()
74 …1.0 * (itor->wrSectorsKb - itor->prevWrSectorsKb) / durS, itor->rdCountPerSec, itor->wrCountPerSec, in Finish()
75 itor->rdCount, itor->wrCount); in Finish()
76 lastTs = itor->ts; in Finish()
|
| D | htrace_network_parser.cpp | 59 for (auto itor = networkData_.begin(); itor != networkData_.end(); itor++) { in Finish() local
60 auto newTimeStamp = itor->ts; in Finish()
61 UpdatePluginTimeRange(TS_CLOCK_REALTIME, itor->ts, newTimeStamp); in Finish()
64 lastRx = itor->rx_bytes; in Finish()
65 lastTx = itor->tx_bytes; in Finish()
66 lastPacketIn = itor->rx_packets; in Finish()
67 lastPacketOut = itor->tx_packets; in Finish()
74 … newTimeStamp, itor->tx_bytes, itor->rx_bytes, dur, 1.0 * (itor->rx_bytes - lastRx) / durS, in Finish()
75 …1.0 * (itor->tx_bytes - lastTx) / durS, itor->rx_packets, 1.0 * (itor->rx_packets - lastPacketIn) … in Finish()
76 itor->tx_packets, 1.0 * (itor->tx_packets - lastPacketOut) / durS, "undefined"); in Finish()
[all …]
|
| D | htrace_process_parser.cpp | 76 for (auto itor = liveProcessData_.begin(); itor != liveProcessData_.end(); itor++) { in Finish() local
77 auto tsOld = (*itor)->ts_; in Finish()
78 … (*itor)->ts_ = streamFilters_->clockFilter_->ToPrimaryTraceTime(TS_CLOCK_REALTIME, (*itor)->ts_); in Finish()
79 UpdatePluginTimeRange(TS_CLOCK_REALTIME, tsOld, (*itor)->ts_); in Finish()
81 lastTs = (*itor)->ts_; in Finish()
85 auto dur = (*itor)->ts_ - lastTs; in Finish()
86 lastTs = (*itor)->ts_; in Finish()
87 if (!(*itor)->processInfo_->pid) { in Finish()
91 …(*itor)->ts_, dur, (*itor)->processInfo_->pid, (*itor)->processInfo_->name, (*itor)->processInfo_-… in Finish()
92 …(*itor)->processInfo_->uid, std::to_string((*itor)->processInfo_->uid), (*itor)->cpuUsageData_->cp… in Finish()
[all …]
|
| D | htrace_cpu_data_parser.cpp | 57 for (auto itor = cpuData_.begin(); itor != cpuData_.end(); itor++) { in Finish() local
58 auto newTimeStamp = (*itor)->ts_; in Finish()
66 …newTimeStamp, dur, (*itor)->totalLoad_, (*itor)->userLoad_, (*itor)->sysLoad_, (*itor)->processNum… in Finish()
|
| D | htrace_native_hook_parser.cpp | 51 auto itor = stackMapReader.frame_map_id(&parseError); in ParseStackMap() local
53 while (itor) { in ParseStackMap()
54 frames.emplace_back(*itor); in ParseStackMap()
55 itor++; in ParseStackMap()
58 auto itor = stackMapReader.ip(&parseError); in ParseStackMap() local
61 while (itor) { in ParseStackMap()
62 frames.emplace_back(*itor); in ParseStackMap()
63 itor++; in ParseStackMap()
166 for (auto itor = batchNativeHookDataReader.events(); itor; itor++) { in Parse() local
167 … auto nativeHookDataReader = std::make_unique<ProtoReader::NativeHookData_Reader>(itor->ToBytes()); in Parse()
|
| /developtools/smartperf_host/trace_streamer/src/filter/ |
| D | native_hook_filter.cpp | 125 auto itor = sourceMap.find(key); in UpdateMap() local
126 if (itor != sourceMap.end()) { in UpdateMap()
127 itor->second = value; in UpdateMap()
160 for (auto itor = frames; itor; itor++) { in CompressStackAndFrames() local
161 std::string_view frameStr(reinterpret_cast<const char*>(itor->Data()), itor->Size()); in CompressStackAndFrames()
165 auto frameInfo = ParseFrame(row, itor.GetDataArea()); in CompressStackAndFrames()
512 auto itor = tsToMainEventsMap_.begin(); in FilterNativeHookMainEvent() local
513 for (; itor != tsToMainEventsMap_.end() && num; num--, itor++) { in FilterNativeHookMainEvent()
514 auto nativeHookDataReader = itor->second->reader_.get(); in FilterNativeHookMainEvent()
515 auto timeStamp = itor->first; in FilterNativeHookMainEvent()
[all …]
|
| D | app_start_filter.cpp | 105 for (auto itor = mAPPStartupData.begin(); itor != mAPPStartupData.end(); ++itor) { in AppendData() local
106 if (!(itor->second).count(UI_ABILITY_LAUNCHING)) { in AppendData()
109 … for (auto itorSecond = itor->second.begin(); itorSecond != itor->second.end(); ++itorSecond) { in AppendData()
114 if ((++item) != itor->second.end() && num == item->first) { in AppendData()
122 itorSecond->second->startTime_, endTime, itorSecond->first, itor->first); in AppendData()
236 auto itor = it->second.begin(); in CalcDepthByTimeStamp() local
237 if (itor->first > startTime) { in CalcDepthByTimeStamp()
241 depth = itor->second; in CalcDepthByTimeStamp()
242 for (auto itorSecond = itor; itorSecond != it->second.end(); ++itorSecond) { in CalcDepthByTimeStamp()
245 itor = itorSecond; in CalcDepthByTimeStamp()
[all …]
|
| D | hi_sysevent_measure_filter.cpp | 202 for (auto itor = noArrayIndex.begin(); itor != noArrayIndex.end(); itor++) { in NoArrayDataParse() local
203 auto value = jData.value[*itor]; in NoArrayDataParse()
204 auto key = jData.key[*itor]; in NoArrayDataParse()
216 for (auto itor = arrayIndex.begin(); itor != arrayIndex.end(); itor++) { in ArrayDataParse() local
217 auto value = jData.value[*itor][i]; in ArrayDataParse()
218 std::string key = jData.key[*itor]; in ArrayDataParse()
|
| D | cpu_filter.cpp | 259 auto itor = internalTidToRowThreadState_.find(uid); in RowOfInternalTidInStateTable() local
260 if (itor != internalTidToRowThreadState_.end()) { in RowOfInternalTidInStateTable()
261 return (*itor).second.row_; in RowOfInternalTidInStateTable()
267 auto itor = internalTidToRowThreadState_.find(uid); in ClearInternalTidInStateTable() local
268 if (itor != internalTidToRowThreadState_.end()) { in ClearInternalTidInStateTable()
269 internalTidToRowThreadState_.erase(itor); in ClearInternalTidInStateTable()
274 auto itor = internalTidToRowThreadState_.find(uid); in StateOfInternalTidInStateTable() local
275 if (itor != internalTidToRowThreadState_.end()) { in StateOfInternalTidInStateTable()
276 return (*itor).second.state_; in StateOfInternalTidInStateTable()
|
| D | offline_symbolization_filter.cpp | 35 for (auto itor = ips->begin(); (itor + 1) != ips->end(); itor++) { in OfflineSymbolization() local
36 auto frameInfo = OfflineSymbolizationByIp(ipid, *itor); in OfflineSymbolization()
|
| /developtools/smartperf_host/trace_streamer/src/trace_data/trace_stdtype/ftrace/ |
| D | sched_stdtype.cpp | 63 for (auto itor = timeStampsToIdMap.begin(); itor != timeStampsToIdMap.end(); itor++) { in SortAllRowByTs() local
64 timeStamps_.emplace_back(timeStampsTemp[itor->second]); in SortAllRowByTs()
65 durations_.emplace_back(durationsTemp[itor->second]); in SortAllRowByTs()
66 itids_.emplace_back(itidsTemp[itor->second]); in SortAllRowByTs()
67 tids_.emplace_back(tidsTemp[itor->second]); in SortAllRowByTs()
68 pids_.emplace_back(pidsTemp[itor->second]); in SortAllRowByTs()
69 states_.emplace_back(statesTemp[itor->second]); in SortAllRowByTs()
70 cpus_.emplace_back(cpusTemp[itor->second]); in SortAllRowByTs()
71 argSetIds_.emplace_back(argSetIdsTemp[itor->second]); in SortAllRowByTs()
|
| /developtools/smartperf_host/trace_streamer/src/trace_data/ |
| D | trace_data_db.cpp | 119 for (auto itor = internalTables_.begin(); itor != internalTables_.end(); itor++) { in CreatEmptyBatchDB() local
120 if (*itor == "meta" && !exportMetaTable_) { in CreatEmptyBatchDB()
123 … std::string exportSql("CREATE TABLE systuning_export." + (*itor) + "_ AS SELECT * FROM " + *itor); in CreatEmptyBatchDB()
145 for (auto itor = internalTables_.begin(); itor != internalTables_.end(); itor++) { in BatchExportDatabase() local
146 if (*itor == "meta" && !exportMetaTable_) { in BatchExportDatabase()
149 if (needClearTable_.count(*itor)) { in BatchExportDatabase()
150 std::string clearSql("DELETE FROM systuning_export." + (*itor) + "_"); in BatchExportDatabase()
153 … std::string exportSql("INSERT INTO systuning_export." + (*itor) + "_ SELECT * FROM " + *itor); in BatchExportDatabase()
180 for (auto itor = internalTables_.begin(); itor != internalTables_.end(); itor++) { in RevertTableName() local
181 if (*itor == "meta" && !exportMetaTable_) { in RevertTableName()
[all …]
|
| /developtools/smartperf_host/trace_streamer/src/parser/ebpf_parser/ |
| D | ebpf_base.cpp | 36 auto itor = ebpfToTSClockType_.find(clockId); in InitEbpfDataParser() local
37 if (itor == ebpfToTSClockType_.end()) { in InitEbpfDataParser()
117 auto itor = filePathIndexToPidAndIpMap_.find(filePathIndex); in UpdateFilePathIndexToPidAndIpMap() local
118 if (itor != filePathIndexToPidAndIpMap_.end()) { in UpdateFilePathIndexToPidAndIpMap()
119 itor->second->insert(std::make_tuple(pid, ip)); in UpdateFilePathIndexToPidAndIpMap()
156 auto itor = reader_->GetElfPathIndexToElfAddr().find(ebpfSymbolInfo.filePathIndex); in GetSymbolSave() local
157 if (itor == reader_->GetElfPathIndexToElfAddr().end()) { in GetSymbolSave()
162 … uint64_t symVaddr = ip - vmStart + vmOffset + itor->second->textVaddr - itor->second->textOffset; in GetSymbolSave()
164 auto symbolIndex = GetSymbolNameIndexFromSymVaddr(itor->second, symVaddr); in GetSymbolSave()
|
| /developtools/smartperf_host/trace_streamer/src/proto_reader/include/ |
| D | proto_reader.h | 83 RepeatedDataAreaIterator itor(*this);
85 return itor;
118 auto itor = fixedTypeToSizeMap_.find(wireType); in PackedRepeatedDataAreaIterator() local
119 if (itor != fixedTypeToSizeMap_.end() && (length % itor->second)) { in PackedRepeatedDataAreaIterator()
169 PackedRepeatedDataAreaIterator itor(*this);
171 return itor;
|
| /developtools/smartperf_host/trace_streamer/test/unittest/pbreader/ |
| D | proto_reader_test.cpp | 102 auto itor = cpuInfoTest.test(); variable
103 Test_Reader cpuInfoReader1(itor->ToBytes());
134 auto itor = cpuInfoTest.test(); variable
135 Test_Reader cpuInfoReader1(itor->ToBytes());
142 itor++;
143 Test_Reader cpuInfoReader2(itor->ToBytes());
150 itor++;
151 Test_Reader cpuInfoReader3(itor->ToBytes());
177 auto itor = cpuInfoTest.test(); variable
178 Test_Reader cpuInfoReader1(itor->ToBytes());
[all …]
|
| /developtools/smartperf_host/trace_streamer/src/cfg/ |
| D | trace_streamer_config.cpp | 77 for (auto itor = eventNameMap_.begin(); itor != eventNameMap_.end(); itor++) { in PrintInfo() local
78 printf("%s\n", itor->second.c_str()); in PrintInfo()
82 for (auto itor = memNameMap_.begin(); itor != memNameMap_.end(); itor++) { in PrintInfo() local
83 printf("%s\n", itor->second.c_str()); in PrintInfo()
87 for (auto itor = sysMemNameMap_.begin(); itor != sysMemNameMap_.end(); itor++) { in PrintInfo() local
88 printf("%s\n", itor->second.c_str()); in PrintInfo()
92 for (auto itor = sysVirtualMemNameMap_.begin(); itor != sysVirtualMemNameMap_.end(); itor++) { in PrintInfo() local
93 printf("%s\n", itor->second.c_str()); in PrintInfo()
|
| /developtools/smartperf_host/trace_streamer/src/ |
| D | main.cpp | 429 for (auto itor = seqToFilePathMap.begin(); itor != seqToFilePathMap.end(); itor++) { in GetLongTraceFilePaths() local
430 if (itor->first != seq++) { in GetLongTraceFilePaths()
431 seqToFilePathMap.erase(itor, seqToFilePathMap.end()); in GetLongTraceFilePaths()
491 for (auto itor = seqToFilePathMap.begin(); itor != seqToFilePathMap.end(); itor++) { in ParseLongTrace() local
493 if (!OpenAndParserLongTraceFile(ts, itor->second)) { in ParseLongTrace()
496 if (std::distance(itor, seqToFilePathMap.end()) == 1) { in ParseLongTrace()
504 if (std::distance(itor, seqToFilePathMap.end()) == 1) { in ParseLongTrace()
|
| /developtools/smartperf_host/trace_streamer/src/trace_data/trace_stdtype/ |
| D | common_stdtype.cpp | 84 auto itor = dataDictInnerMap_.find(str); in GetStringIndex() local
85 if (itor != dataDictInnerMap_.end()) { in GetStringIndex()
86 return itor->second; in GetStringIndex()
97 auto itor = dataDictInnerMap_.find(str); in GetStringIndexNoWrite() local
98 if (itor != dataDictInnerMap_.end()) { in GetStringIndexNoWrite()
99 return itor->second; in GetStringIndexNoWrite()
|
| /developtools/smartperf_host/trace_streamer/sdk/demo_sdk/trace_data/ |
| D | demo_trace_data_db.cpp | 97 for (auto itor = demoInternalTables_.begin(); itor != demoInternalTables_.end(); itor++) { in DemoExportDatabase() local
98 if (*itor == "meta" && !demoExportMetaTable_) { in DemoExportDatabase()
101 …d::string demoExportSql("CREATE TABLE systuning_export." + (*itor) + " AS SELECT * FROM " + *itor); in DemoExportDatabase()
|
| /developtools/smartperf_host/trace_streamer/src/rpc/ |
| D | wasm_func.cpp | 191 std::map<int32_t, std::string>::iterator itor = g_wasmTraceStreamer.g_thirdPartyConfig.begin(); in TraceStreamer_Plugin_Out_Filter() local
193 for (; itor != g_wasmTraceStreamer.g_thirdPartyConfig.end(); ++itor) { in TraceStreamer_Plugin_Out_Filter()
194 if (itor->second == componentName) { in TraceStreamer_Plugin_Out_Filter()
195 componentId = itor->first; in TraceStreamer_Plugin_Out_Filter()
|
| /developtools/smartperf_host/trace_streamer/src/base/ |
| D | index_map.cpp | 46 for (auto itor = rowIndex_.begin(); itor != rowIndex_.end(); itor++) { in Print() local
47 (void)fprintf(stdout, "%d,", *itor); in Print()
|
| /developtools/smartperf_host/trace_streamer/src/proto_reader/ |
| D | proto_reader.cpp | 158 auto itor = DATA_AREA_TYPE_TO_PARSE_FUNC_MAP.find(static_cast<ProtoWireType>(dataAreaType)); in ParseOneDataArea() local
159 if (itor == DATA_AREA_TYPE_TO_PARSE_FUNC_MAP.end()) { in ParseOneDataArea()
162 itor->second(result, cursor, endAddr_); in ParseOneDataArea()
|
| /developtools/smartperf_host/trace_streamer/src/parser/bytrace_parser/ |
| D | bytrace_event_parser.cpp | 753 for (auto itor = eventList_.begin(); itor != endOfList; itor++) { in FilterAllEventsTemp() local
754 EventInfo* event = itor->get(); in FilterAllEventsTemp()
756 itor->reset(); in FilterAllEventsTemp()
771 for (auto itor = eventList_.begin(); itor != endOfList; itor++) { in FilterAllEvents() local
772 EventInfo* event = itor->get(); in FilterAllEvents()
774 itor->reset(); in FilterAllEvents()
|
| /developtools/smartperf_host/trace_streamer/src/parser/rawtrace_parser/ |
| D | rawtrace_parser.cpp | 50 auto itor = uniqueCpuIdSet.find(schedSlice.CpusData()[i]); in UpdateTraceMinRange() local
51 if (itor != uniqueCpuIdSet.end()) { in UpdateTraceMinRange()
|
| /developtools/smartperf_host/trace_streamer/src/trace_streamer/ |
| D | trace_streamer_selector.cpp | 388 auto itor = metricsMap.find(metrics); in MetricsSqlQuery() local
389 if (itor == metricsMap.end()) { in MetricsSqlQuery()
393 return itor->second; in MetricsSqlQuery()
|