| /developtools/smartperf_host/trace_streamer/src/parser/pbreader_parser/network_parser/ |
| D | pbreader_network_parser.cpp | 58 for (auto itor = networkData_.begin(); itor != networkData_.end(); itor++) { in Finish() local
59 auto newTimeStamp = itor->ts; in Finish()
60 UpdatePluginTimeRange(TS_CLOCK_REALTIME, itor->ts, newTimeStamp); in Finish()
63 lastRx = itor->rx_bytes; in Finish()
64 lastTx = itor->tx_bytes; in Finish()
65 lastPacketIn = itor->rx_packets; in Finish()
66 lastPacketOut = itor->tx_packets; in Finish()
74 row.tx = itor->tx_bytes; in Finish()
75 row.rx = itor->rx_bytes; in Finish()
77 row.rxSpeed = 1.0 * (itor->rx_bytes - lastRx) / durS; in Finish()
[all …]
|
| /developtools/smartperf_host/trace_streamer/src/parser/pbreader_parser/process_parser/ |
| D | pbreader_process_parser.cpp | 71 for (auto itor = liveProcessData_.begin(); itor != liveProcessData_.end(); itor++) { in Finish() local
72 auto tsOld = (*itor)->ts_; in Finish()
73 … (*itor)->ts_ = streamFilters_->clockFilter_->ToPrimaryTraceTime(TS_CLOCK_REALTIME, (*itor)->ts_); in Finish()
74 UpdatePluginTimeRange(TS_CLOCK_REALTIME, tsOld, (*itor)->ts_); in Finish()
76 lastTs = (*itor)->ts_; in Finish()
80 auto dur = (*itor)->ts_ - lastTs; in Finish()
81 lastTs = (*itor)->ts_; in Finish()
82 if (!(*itor)->processInfo_->pid) { in Finish()
86 row.newTimeStamp = (*itor)->ts_; in Finish()
88 row.processID = (*itor)->processInfo_->pid; in Finish()
[all …]
|
| /developtools/smartperf_host/trace_streamer/src/parser/pbreader_parser/disk_io_parser/ |
| D | pbreader_disk_io_parser.cpp | 60 for (auto itor = diskIOData_.begin(); itor != diskIOData_.end(); itor++) { in Finish() local
62 row.ts = streamFilters_->clockFilter_->ToPrimaryTraceTime(TS_CLOCK_REALTIME, itor->ts); in Finish()
71 row.rd = itor->rdSectorsKb; in Finish()
72 row.wr = itor->wrSectorsKb; in Finish()
73 row.rdPerSec = 1.0 * (itor->rdSectorsKb - itor->prevRdSectorsKb) / durS; in Finish()
74 row.wrPerSec = 1.0 * (itor->wrSectorsKb - itor->prevWrSectorsKb) / durS; in Finish()
75 row.rdCountPerSec = itor->rdCountPerSec; in Finish()
76 row.wrCountPerSec = itor->wrCountPerSec; in Finish()
77 row.rdCount = itor->rdCount; in Finish()
78 row.wrCount = itor->wrCount; in Finish()
|
| /developtools/smartperf_host/trace_streamer/src/parser/pbreader_parser/cpu_data_parser/ |
| D | pbreader_cpu_data_parser.cpp | 56 for (auto itor = cpuData_.begin(); itor != cpuData_.end(); itor++) { in Finish() local
57 auto newTimeStamp = (*itor)->ts_; in Finish()
66 row.totalLoad = (*itor)->totalLoad_; in Finish()
67 row.userLoad = (*itor)->userLoad_; in Finish()
68 row.systemLoad = (*itor)->sysLoad_; in Finish()
69 row.threads = (*itor)->processNum_; in Finish()
|
| /developtools/smartperf_host/trace_streamer/src/trace_data/ |
| D | trace_data_db.cpp | 143 for (auto itor = internalTables_.begin(); itor != internalTables_.end(); itor++) { in CreatEmptyBatchDB() local
144 if (*itor == "meta" && !exportMetaTable_) { in CreatEmptyBatchDB()
147 … std::string exportSql("CREATE TABLE systuning_export." + (*itor) + "_ AS SELECT * FROM " + *itor); in CreatEmptyBatchDB()
172 for (auto itor = internalTables_.begin(); itor != internalTables_.end(); itor++) { in BatchExportDatabase() local
173 if (*itor == "meta" && !exportMetaTable_) { in BatchExportDatabase()
176 if (needClearTable_.count(*itor)) { in BatchExportDatabase()
177 std::string clearSql("DELETE FROM systuning_export." + (*itor) + "_"); in BatchExportDatabase()
180 if (tableToCompletedSize_.count(*itor)) { in BatchExportDatabase()
181 … std::string exportSql("INSERT INTO systuning_export." + (*itor) + "_ SELECT * FROM " + *itor + in BatchExportDatabase()
182 " LIMIT " + std::to_string(tableToCompletedSize_.at(*itor))); in BatchExportDatabase()
[all …]
|
| /developtools/smartperf_host/trace_streamer/src/filter/hook_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()
170 for (auto itor = frames; itor; itor++) { in CompressStackAndFrames() local
171 std::string_view frameStr(reinterpret_cast<const char *>(itor->Data()), itor->Size()); in CompressStackAndFrames()
175 auto frameInfo = ParseFrame(row, itor.GetDataArea()); in CompressStackAndFrames()
546 auto itor = tsToMainEventsMap_.begin(); in FilterNativeHookMainEvent() local
547 for (; itor != tsToMainEventsMap_.end() && num; num--, itor++) { in FilterNativeHookMainEvent()
548 auto nativeHookDataReader = itor->second->reader_.get(); in FilterNativeHookMainEvent()
549 auto timeStamp = itor->first; in FilterNativeHookMainEvent()
[all …]
|
| /developtools/smartperf_host/trace_streamer/src/trace_data/trace_stdtype/ftrace/ |
| D | sched_stdtype.cpp | 64 for (auto itor = timeStampsToIdMap.begin(); itor != timeStampsToIdMap.end(); itor++) { in SortAllRowByTs() local
65 timeStamps_.emplace_back(timeStampsTemp[itor->second]); in SortAllRowByTs()
66 durations_.emplace_back(durationsTemp[itor->second]); in SortAllRowByTs()
67 itids_.emplace_back(itidsTemp[itor->second]); in SortAllRowByTs()
68 tids_.emplace_back(tidsTemp[itor->second]); in SortAllRowByTs()
69 pids_.emplace_back(pidsTemp[itor->second]); in SortAllRowByTs()
70 states_.emplace_back(statesTemp[itor->second]); in SortAllRowByTs()
71 cpus_.emplace_back(cpusTemp[itor->second]); in SortAllRowByTs()
72 argSetIds_.emplace_back(argSetIdsTemp[itor->second]); in SortAllRowByTs()
|
| /developtools/smartperf_host/trace_streamer/src/parser/pbreader_parser/native_hook_parser/ |
| D | pbreader_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()
167 for (auto itor = batchNativeHookDataReader.events(); itor; itor++) { in Parse() local
168 … auto nativeHookDataReader = std::make_unique<ProtoReader::NativeHookData_Reader>(itor->ToBytes()); in Parse()
|
| /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()
119 auto itor = filePathIndexToPidAndIpMap_.find(filePathIndex); in UpdateFilePathIndexToPidAndIpMap() local
120 if (itor != filePathIndexToPidAndIpMap_.end()) { in UpdateFilePathIndexToPidAndIpMap()
121 itor->second->insert(std::make_tuple(pid, ip)); in UpdateFilePathIndexToPidAndIpMap()
158 auto itor = reader_->GetElfPathIndexToElfAddr().find(ebpfSymbolInfo.filePathIndex); in GetSymbolSave() local
159 if (itor == reader_->GetElfPathIndexToElfAddr().end()) { in GetSymbolSave()
164 … uint64_t symVaddr = ip - vmStart + vmOffset + itor->second->textVaddr - itor->second->textOffset; in GetSymbolSave()
166 auto symbolIndex = GetSymbolNameIndexFromSymVaddr(itor->second, symVaddr); in GetSymbolSave()
|
| /developtools/smartperf_host/trace_streamer/src/filter/ |
| D | app_start_filter.cpp | 131 for (auto itor = mAPPStartupData.begin(); itor != mAPPStartupData.end(); ++itor) { in AppenAllData() local
132 if (!(itor->second).count(UI_ABILITY_LAUNCHING)) { in AppenAllData()
135 AppendAssociatedData(itor->first, itor->second); in AppenAllData()
249 auto itor = it->second.begin(); in CalcDepthByTimeStamp() local
250 if (itor->first > startTime) { in CalcDepthByTimeStamp()
255 depth = itor->second; in CalcDepthByTimeStamp()
256 for (auto itorSecond = itor; itorSecond != it->second.end(); ++itorSecond) { in CalcDepthByTimeStamp()
259 itor = itorSecond; in CalcDepthByTimeStamp()
262 it->second.erase(itor); in CalcDepthByTimeStamp()
|
| D | cpu_filter.cpp | 242 auto itor = internalTidToRowThreadState_.find(uid); in RowOfInternalTidInStateTable() local
243 if (itor != internalTidToRowThreadState_.end()) { in RowOfInternalTidInStateTable()
244 return (*itor).second.row_; in RowOfInternalTidInStateTable()
250 auto itor = internalTidToRowThreadState_.find(uid); in ClearInternalTidInStateTable() local
251 if (itor != internalTidToRowThreadState_.end()) { in ClearInternalTidInStateTable()
252 internalTidToRowThreadState_.erase(itor); in ClearInternalTidInStateTable()
257 auto itor = internalTidToRowThreadState_.find(uid); in StateOfInternalTidInStateTable() local
258 if (itor != internalTidToRowThreadState_.end()) { in StateOfInternalTidInStateTable()
259 return (*itor).second.state_; in StateOfInternalTidInStateTable()
|
| /developtools/smartperf_host/trace_streamer/src/filter/hi_sysevent_filter/ |
| D | hi_sysevent_measure_filter.cpp | 205 for (auto itor = noArrayIndex.begin(); itor != noArrayIndex.end(); itor++) { in NoArrayDataParse() local
206 auto value = jData.value[*itor]; in NoArrayDataParse()
207 auto key = jData.key[*itor]; in NoArrayDataParse()
219 for (auto itor = arrayIndex.begin(); itor != arrayIndex.end(); itor++) { in ArrayDataParse() local
220 auto value = jData.value[*itor][i]; in ArrayDataParse()
221 std::string key = jData.key[*itor]; in ArrayDataParse()
|
| /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 | 81 for (auto itor = eventNameMap_.begin(); itor != eventNameMap_.end(); itor++) { in PrintInfo() local
82 printf("%s\n", itor->second.c_str()); in PrintInfo()
86 for (auto itor = memNameMap_.begin(); itor != memNameMap_.end(); itor++) { in PrintInfo() local
87 printf("%s\n", itor->second.c_str()); in PrintInfo()
91 for (auto itor = sysMemNameMap_.begin(); itor != sysMemNameMap_.end(); itor++) { in PrintInfo() local
92 printf("%s\n", itor->second.c_str()); in PrintInfo()
96 for (auto itor = sysVirtualMemNameMap_.begin(); itor != sysVirtualMemNameMap_.end(); itor++) { in PrintInfo() local
97 printf("%s\n", itor->second.c_str()); in PrintInfo()
|
| /developtools/smartperf_host/trace_streamer/src/trace_data/trace_stdtype/ |
| D | common_stdtype.cpp | 87 auto itor = dataDictInnerMap_.find(str); in GetStringIndex() local
88 if (itor != dataDictInnerMap_.end()) { in GetStringIndex()
89 return itor->second; in GetStringIndex()
98 auto itor = dataDictInnerMap_.find(str); in GetStringIndexNoWrite() local
99 if (itor != dataDictInnerMap_.end()) { in GetStringIndexNoWrite()
100 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 TraceStreamerPluginOutFilter() local
193 for (; itor != g_wasmTraceStreamer.g_thirdPartyConfig.end(); ++itor) { in TraceStreamerPluginOutFilter()
194 if (itor->second == componentName) { in TraceStreamerPluginOutFilter()
195 componentId = itor->first; in TraceStreamerPluginOutFilter()
|
| /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/ |
| D | main.cpp | 567 for (auto itor = seqToFilePathMap.begin(); itor != seqToFilePathMap.end(); itor++) { in GetLongTraceFilePaths() local
568 if (itor->first != seq++) { in GetLongTraceFilePaths()
569 seqToFilePathMap.erase(itor, seqToFilePathMap.end()); in GetLongTraceFilePaths()
626 for (auto itor = seqToFilePathMap.begin(); itor != seqToFilePathMap.end(); itor++) { in ParseLongTrace() local
627 if (!OpenAndParserLongTraceFile(ts, itor->second)) { in ParseLongTrace()
630 if (itor == std::prev(seqToFilePathMap.end())) { in ParseLongTrace()
646 if (itor == std::prev(seqToFilePathMap.end())) { in ParseLongTrace()
|
| /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/ptreader_parser/bytrace_parser/ |
| D | bytrace_event_parser.cpp | 719 for (auto itor = eventList_.begin(); itor != endOfList; itor++) { in ParseDataItem() local
720 EventInfo *event = itor->get(); in ParseDataItem()
722 itor->reset(); in ParseDataItem()
766 for (auto itor = eventList_.begin(); itor != endOfList; itor++) { in FilterAllEvents() local
767 EventInfo *event = itor->get(); in FilterAllEvents()
769 itor->reset(); in FilterAllEvents()
|
| /developtools/smartperf_host/trace_streamer/src/trace_streamer/ |
| D | trace_streamer_selector.cpp | 482 auto itor = metricsMap.find(metrics); in MetricsSqlQuery() local
483 if (itor == metricsMap.end()) { in MetricsSqlQuery()
487 return itor->second; in MetricsSqlQuery()
|
| /developtools/smartperf_host/trace_streamer/src/parser/pbreader_parser/mem_parser/ |
| D | pbreader_mem_parser.cpp | 684 auto itor = memConfigData.pid(&parseError); in ParseMemoryConfig() local
689 while (itor) { in ParseMemoryConfig()
690 int32_t pid = *itor; in ParseMemoryConfig()
693 itor++; in ParseMemoryConfig()
|