| /developtools/smartperf_host/trace_streamer/src/rpc/ |
| H A D | rpc_server.h | 33 bool ParseData(const uint8_t *data, size_t len, ResultCallBack resultCallBack, bool isFinish);
36 int32_t isFinish,
44 bool ParseDataWithoutCallback(const uint8_t *data, size_t len, int32_t isFinish, bool isSplitFile);
67 int32_t isFinish,
79 bool SendRawtraceSplitFileData(SplitFileCallBack splitFileCallBack, int32_t isFinish);
82 bool SaveAndParseFfrtData(const uint8_t *data, size_t len, ResultCallBack resultCallBack, bool isFinish);
83 bool SaveAndParseZipTraceData(const uint8_t *data, size_t len, ResultCallBack resultCallBack, bool isFinish);
103 bool SendBytraceSplitFileData(SplitFileCallBack splitFileCallBack, int32_t isFinish);
|
| H A D | wasm_func.cpp | 33 using SplitFileFunction = void (*)(const char *data, uint32_t len, int32_t dataType, int32_t isFinish);
114 EMSCRIPTEN_KEEPALIVE int TraceStreamerReciveFileEx(int32_t dataLen, int32_t isFinish) in TraceStreamerReciveFileEx() argument
116 if (g_wasmTraceStreamer.ParseSplitFileData(g_splitFileBuf, dataLen, isFinish, &SplitFileCallback, true)) { in TraceStreamerReciveFileEx()
149 EMSCRIPTEN_KEEPALIVE int TraceStreamerLongTraceSplitFileEx(int dataLen, int32_t isFinish, uint32_t pageNum) in TraceStreamerLongTraceSplitFileEx() argument
151 if (g_wasmTraceStreamer.LongTraceSplitFile(g_splitFileBuf, dataLen, isFinish, pageNum, &SplitFileCallback)) { in TraceStreamerLongTraceSplitFileEx()
239 EMSCRIPTEN_KEEPALIVE int32_t TraceStreamerParseDataEx(int32_t dataLen, bool isFinish) in TraceStreamerParseDataEx() argument
248 return g_wasmTraceStreamer.SaveAndParseFfrtData(g_reqBuf, dataLen, &FfrtConvertedResultCallback, isFinish); in TraceStreamerParseDataEx()
251 return g_wasmTraceStreamer.SaveAndParseZipTraceData(g_reqBuf, dataLen, &FfrtConvertedResultCallback, isFinish); in TraceStreamerParseDataEx()
252 } else if (g_wasmTraceStreamer.ParseData(g_reqBuf, dataLen, nullptr, isFinish)) { in TraceStreamerParseDataEx()
|
| H A D | rpc_server.cpp | 74 bool RpcServer::SaveAndParseFfrtData(const uint8_t *data, size_t len, ResultCallBack resultCallBack, bool isFinish) in SaveAndParseFfrtData() argument
88 if (!isFinish) { in SaveAndParseFfrtData()
116 bool RpcServer::SaveAndParseZipTraceData(const uint8_t *data, size_t len, ResultCallBack resultCallBack, bool isFinish) in SaveAndParseZipTraceData() argument
130 if (!isFinish) { in SaveAndParseZipTraceData()
187 bool RpcServer::ParseData(const uint8_t *data, size_t len, ResultCallBack resultCallBack, bool isFinish) in ParseData() argument
194 if (!ts_->ParseTraceDataSegment(std::move(buf), parseSize, false, isFinish && (len <= G_CHUNK_SIZE))) { in ParseData()
209 bool RpcServer::ParseDataWithoutCallback(const uint8_t *data, size_t len, int32_t isFinish, bool isSplitFile) in ParseDataWithoutCallback() argument
216 if (!ts_->ParseTraceDataSegment(std::move(buf), parseSize, isSplitFile, isFinish && (len == parseSize))) { in ParseDataWithoutCallback()
264 int32_t isFinish, in LongTraceSplitFile()
273 ParseSplitFileData(data, len, isFinish, splitFileCallBac in LongTraceSplitFile()
262 LongTraceSplitFile(const uint8_t *data, size_t len, int32_t isFinish, uint32_t pageNum, SplitFileCallBack splitFileCallBack) LongTraceSplitFile() argument
304 SendBytraceSplitFileData(SplitFileCallBack splitFileCallBack, int32_t isFinish) SendBytraceSplitFileData() argument
339 SendRawtraceSplitFileData(SplitFileCallBack splitFileCallBack, int32_t isFinish) SendRawtraceSplitFileData() argument
368 ParseSplitFileData(const uint8_t *data, size_t len, int32_t isFinish, SplitFileCallBack splitFileCallBack, bool isSplitFile) ParseSplitFileData() argument
[all...] |
| H A D | wasm_func.h | 39 int32_t TraceStreamerParseDataEx(int32_t dataLen, bool isFinish);
|
| /developtools/smartperf_host/trace_streamer/test/unittest/base/ |
| H A D | export_test.cpp | 54 auto isFinish = false; in ParseTraceFile() local
59 if (isFinish && ts.GetFileType() == TRACE_FILETYPE_RAW_TRACE && curParseCnt < RAW_TRACE_PARSE_MAX) { in ParseTraceFile()
61 isFinish = false; in ParseTraceFile()
77 isFinish = true; in ParseTraceFile()
79 if (!ts.ParseTraceDataSegment(std::move(buf), static_cast<size_t>(rsize), false, isFinish)) { in ParseTraceFile()
|
| /developtools/smartperf_host/trace_streamer/src/parser/ |
| H A D | parser_base.h | 28 virtual void ParseTraceDataSegment(std::unique_ptr<uint8_t[]>, size_t size, bool isFinish = false) = 0;
|
| /developtools/smartperf_host/trace_streamer/src/parser/ptreader_parser/ |
| H A D | ptreader_parser.cpp | 89 bool isFinish) in WhileDetermine()
93 if (isFinish) { in WhileDetermine()
170 void PtreaderParser::ParseTraceDataSegment(std::unique_ptr<uint8_t[]> bufferStr, size_t size, bool isFinish) in ParseTraceDataSegment() argument
179 int32_t determine = WhileDetermine(packagesLine, packagesBegin, isParsingOver_, isFinish); in ParseTraceDataSegment()
86 WhileDetermine(Iterator &packagesLine, Iterator &packagesBegin, bool &isParsingOver_, bool isFinish) WhileDetermine() argument
|
| H A D | ptreader_parser.h | 51 int32_t WhileDetermine(Iterator &determine, Iterator &packagesBegin, bool &isParsingOver_, bool isFinish);
54 void ParseTraceDataSegment(std::unique_ptr<uint8_t[]> bufferStr, size_t size, bool isFinish = false) override;
|
| /developtools/smartperf_host/trace_streamer/src/parser/hiperf_parser/ |
| H A D | perf_data_parser.h | 59 bool isFinish);
114 uint64_t SplitPerfData(const std::deque<uint8_t> &dequeBuffer, uint64_t size, uint64_t offset, bool isFinish);
119 bool isFinish);
|
| H A D | perf_data_parser.cpp | 42 bool isFinish) in InitPerfDataAndLoad()
45 return SplitPerfData(dequeBuffer, size, offset, isFinish); in InitPerfDataAndLoad()
59 bool isFinish) in DataProcessingLength()
81 if (isFinish && splitState_ == SplitPerfState::WAIT_FOR_FINISH) { in DataProcessingLength()
98 if (isFinish) { in DataProcessingLength()
112 bool isFinish) in SplitPerfData()
123 uint64_t datalength = DataProcessingLength(dequeBuffer, size, offset, isFinish); in SplitPerfData()
38 InitPerfDataAndLoad(const std::deque<uint8_t> &dequeBuffer, uint64_t size, uint64_t offset, bool isSplitFile, bool isFinish) InitPerfDataAndLoad() argument
56 DataProcessingLength(const std::deque<uint8_t> &dequeBuffer, uint64_t size, uint64_t offset, bool isFinish) DataProcessingLength() argument
109 SplitPerfData(const std::deque<uint8_t> &dequeBuffer, uint64_t size, uint64_t offset, bool isFinish) SplitPerfData() argument
|
| /developtools/smartperf_host/trace_streamer/src/trace_streamer/ |
| H A D | trace_streamer_selector.cpp | 292 void TraceStreamerSelector::ProcessTraceData(std::unique_ptr<uint8_t[]> data, size_t size, int32_t isFinish) in ProcessTraceData() argument
298 ptreaderParser_->ParseTraceDataSegment(std::move(data), size, isFinish); in ProcessTraceData() local
302 pbreaderParser_->StoreTraceDataSegment(std::move(data), size, isFinish); in ProcessTraceData() local
306 rawTraceParser_->ParseTraceDataSegment(std::move(data), size, isFinish); in ProcessTraceData() local
316 int32_t isFinish) in ParseTraceDataSegment()
347 ProcessTraceData(std::move(data), size, isFinish); in ParseTraceDataSegment() local
350 // in the linux,isFinish = 1,clear markinfo in ParseTraceDataSegment()
351 if (isFinish) { in ParseTraceDataSegment()
313 ParseTraceDataSegment(std::unique_ptr<uint8_t[]> data, size_t size, bool isSplitFile, int32_t isFinish) ParseTraceDataSegment() argument
|
| H A D | trace_streamer_selector.h | 35 bool ParseTraceDataSegment(std::unique_ptr<uint8_t[]> data, size_t size, bool isSplitFile, int32_t isFinish);
98 void ProcessTraceData(std::unique_ptr<uint8_t[]> data, size_t size, int32_t isFinish);
|
| /developtools/smartperf_host/trace_streamer/src/parser/rawtrace_parser/ |
| H A D | rawtrace_parser.h | 31 void ParseTraceDataSegment(std::unique_ptr<uint8_t[]> bufferStr, size_t size, bool isFinish = false) override;
|
| H A D | rawtrace_parser.cpp | 238 void RawTraceParser::ParseTraceDataSegment(std::unique_ptr<uint8_t[]> bufferStr, size_t size, bool isFinish) in ParseTraceDataSegment() argument
245 if (isFinish) { in ParseTraceDataSegment()
|
| /developtools/smartperf_host/trace_streamer/src/ |
| H A D | main.cpp | 224 auto isFinish = false; in ReadAndParser() local
229 if (isFinish && ta.GetFileType() == TRACE_FILETYPE_RAW_TRACE && curParseCnt < RAW_TRACE_PARSE_MAX) { in ReadAndParser()
231 isFinish = false; in ReadAndParser()
247 isFinish = true; in ReadAndParser()
249 if (!ta.ParseTraceDataSegment(std::move(buf), static_cast<size_t>(rsize), false, isFinish)) { in ReadAndParser()
|
| /developtools/smartperf_host/trace_streamer/src/parser/pbreader_parser/ |
| H A D | pbreader_parser.cpp | 1043 void PbreaderParser::ParseTraceDataSegment(std::unique_ptr<uint8_t[]> bufferStr, size_t size, bool isFinish) in ParseTraceDataSegment() argument
1069 bool isFinish = perfProcessedLen_ + packagesBuffer_.size() >= profilerDataLength_ - packetHeaderLength_; in ParseHiperfData() local
1071 if (isFinish) { in ParseHiperfData()
1074 auto ret = perfDataParser_->InitPerfDataAndLoad(packagesBuffer_, size, processedDataLen_, true, isFinish); in ParseHiperfData()
1078 if (isFinish) { in ParseHiperfData()
1084 void PbreaderParser::StoreTraceDataSegment(std::unique_ptr<uint8_t[]> bufferStr, size_t size, int32_t isFinish) in StoreTraceDataSegment() argument
1092 auto ret = perfDataParser_->InitPerfDataAndLoad(packagesBuffer_, length, 0, true, isFinish); in StoreTraceDataSegment()
|
| H A D | pbreader_parser.h | 106 void ParseTraceDataSegment(std::unique_ptr<uint8_t[]> bufferStr, size_t size, bool isFinish = false) override;
117 void StoreTraceDataSegment(std::unique_ptr<uint8_t[]> bufferStr, size_t size, int32_t isFinish);
|
| /developtools/smartperf_host/trace_streamer/src/filter/ |
| H A D | cpu_filter.h | 57 void UpdateProcessData(bool isFinish = false) const;
|
| H A D | cpu_filter.cpp | 330 void CpuFilter::UpdateProcessData(bool isFinish) const in UpdateProcessData()
335 if (!isFinish) { in UpdateProcessData()
|
| /developtools/smartperf_host/trace_streamer/src/trace_data/ |
| H A D | sqllite_prepar_cache_data.cpp | 340 const int32_t isFinish, in SendDBProto()
346 tLVResultCallBack(bufferData.data(), bufferData.size(), type, isFinish); in SendDBProto()
339 SendDBProto(uint32_t type, const int32_t isFinish, T &sphData, SqllitePreparCacheData::TLVResultCallBack tLVResultCallBack) SendDBProto() argument
|