| /developtools/smartperf_host/trace_streamer/src/rpc/ |
| D | rpc_server.cpp | 145 ts_->ParseTraceDataSegment(std::move(buf), readSize, false, inputFile.eof()); in ReadAndParseData()
150 ts_->WaitForParserEnd(); in ReadAndParseData()
162 …if (!ts_->ParseTraceDataSegment(std::move(buf), parseSize, false, isFinish && (len <= G_CHUNK_SIZE… in ParseData()
184 …if (!ts_->ParseTraceDataSegment(std::move(buf), parseSize, isSplitFile, isFinish && (len == parseS… in ParseDataWithoutCallback()
239 ts_->minTs_ = vTraceTimeSnap_[pageNum]->startTime; in LongTraceSplitFile()
240 ts_->maxTs_ = vTraceTimeSnap_[pageNum]->endTime; in LongTraceSplitFile()
266 int32_t firstPos = ts_->GetPtreaderParser()->MinSplitPos(); in SendBytraceSplitFileData()
267 int32_t lastPos = ts_->GetPtreaderParser()->MaxSplitPos(); in SendBytraceSplitFileData()
270 const auto &mTraceDataBytrace = ts_->GetPtreaderParser()->GetPtreaderSplitData(); in SendBytraceSplitFileData()
287 if (result != VALUE_STR && !ts_->GetPtreaderParser()->GetPtreaderSplitData().empty()) { in SendBytraceSplitFileData()
[all …]
|
| D | rpc_server.h | 104 std::unique_ptr<TraceStreamerSelector> ts_ = std::make_unique<TraceStreamerSelector>();
|
| /developtools/smartperf_host/trace_streamer/sdk/demo_sdk/test/unittest/ |
| D | sdk_api_test.cpp | 65 ret = rpcServer->ts_->sdkDataParser_->GetJsonConfig(QueryResultCallback);
67 ret = rpcServer->ts_->sdkDataParser_->CreateTableByJson();
97 auto ret = rpcServer->ts_->sdkDataParser_->GetJsonConfig(QueryResultCallback);
99 ret = rpcServer->ts_->sdkDataParser_->CreateTableByJson();
130 ret = rpcServer->ts_->sdkDataParser_->GetJsonConfig(QueryResultCallback);
132 ret = rpcServer->ts_->sdkDataParser_->CreateTableByJson();
163 ret = rpcServer->ts_->sdkDataParser_->GetJsonConfig(QueryResultCallback);
165 ret = rpcServer->ts_->sdkDataParser_->CreateTableByJson();
196 ret = rpcServer->ts_->sdkDataParser_->GetJsonConfig(QueryResultCallback);
198 ret = rpcServer->ts_->sdkDataParser_->CreateTableByJson();
[all …]
|
| /developtools/smartperf_host/trace_streamer/src/parser/pbreader_parser/process_parser/ |
| D | pbreader_process_parser.cpp | 66 return a->ts_ < b->ts_; in Finish()
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()
86 row.newTimeStamp = (*itor)->ts_; in Finish()
|
| D | pbreader_process_parser.h | 88 ts_ = ts; in SetLiveProcess()
94 uint64_t ts_; member
|
| /developtools/smartperf_host/trace_streamer/test/unittest/base/ |
| D | export_test.cpp | 38 ts_.InitFilter(); in SetUp()
44 TraceStreamerSelector ts_; member in SysTuning::TraceStreamer::ExportTest
98 EXPECT_TRUE(ParseTraceFile(ts_, perfFilePath));
101 EXPECT_EQ(ts_.ExportPerfReadableText(errFilePath), 1);
102 EXPECT_EQ(ts_.ExportPerfReadableText(sucessFilePath), 0);
|
| /developtools/smartperf_host/trace_streamer/src/parser/pbreader_parser/cpu_data_parser/ |
| D | pbreader_cpu_data_parser.h | 40 ts_ = 0; in TsCpuData()
45 ts_ = ts; in SetCpuUsage()
50 ts_ = ts; in SetThreadInfo()
61 uint64_t ts_; variable
|
| D | pbreader_cpu_data_parser.cpp | 52 …st std::unique_ptr<TsCpuData> &a, const std::unique_ptr<TsCpuData> &b) { return a->ts_ < b->ts_; }; in Finish()
57 auto newTimeStamp = (*itor)->ts_; in Finish()
|
| /developtools/smartperf_host/trace_streamer/src/table/base/ |
| D | span_join.cpp | 276 ts_ = endTs_; in GetNextState()
293 ts_ = 0; in GetNextState()
296 ts_ = sqlite3_column_int64(stmt_, static_cast<int32_t>(desc_->tsIdx)); in GetNextState()
297 endTs_ = ts_ + sqlite3_column_int64(stmt_, static_cast<int32_t>(desc_->durIdx)); in GetNextState()
306 ts_ = 0; in GetNextState()
362 if (tableFirst_.ts_ >= tableSecond_.ts_) { in CaclOverLap()
365 tableFirst_.ts_ < tableSecond_.endTs_) { in CaclOverLap()
368 } else if (tableFirst_.ts_ <= tableSecond_.ts_ && tableSecond_.ts_ < tableFirst_.endTs_) { in CaclOverLap()
409 …e3_result_int64(context_, static_cast<sqlite3_int64>(std::max(tableFirst_.ts_, tableSecond_.ts_))); in Column()
415 … std::max(tableFirst_.ts_, tableSecond_.ts_))); in Column()
|
| /developtools/smartperf_host/trace_streamer/test/unittest/interface/ |
| D | rpc_server_test.cpp | 111 EXPECT_EQ(rpcServer.ts_->traceDataCache_->taskPoolTraceEnabled_, true);
112 …PrintEventParser printEvent(rpcServer.ts_->traceDataCache_.get(), rpcServer.ts_->streamFilters_.ge…
114 auto res = rpcServer.ts_->traceDataCache_->GetConstTaskPoolData().prioritys_[0];
|
| /developtools/smartperf_host/trace_streamer/src/trace_data/trace_stdtype/ |
| D | common_stdtype.h | 125 ts_.emplace_back(ts); in AppendNewSnapshot()
127 return ts_.size(); in AppendNewSnapshot()
131 return ts_.size(); in Size()
139 return ts_; in Ts()
148 std::deque<uint64_t> ts_ = {}; variable
|
| /developtools/smartperf_host/trace_streamer/sdk/demo_sdk/trace_data/ |
| D | trace_stdtype.cpp | 24 ts_.emplace_back(ts); in AppendNewData()
31 return ts_; in TimeStamp()
|
| D | trace_stdtype.h | 90 std::deque<uint64_t> ts_ = {};
|
| /developtools/smartperf_host/trace_streamer/src/trace_data/trace_stdtype/hisysevent/ |
| D | hisysevent_stdtype.cpp | 38 ts_.emplace_back(context.ts); in AppendData()
53 return ts_; in Ts()
|
| D | hisysevent_stdtype.h | 64 ts_.clear(); in Clear()
74 std::deque<uint64_t> ts_ = {}; variable
|
| /developtools/smartperf_host/trace_streamer/src/table/base/include/ |
| D | span_join.h | 80 int64_t ts_ = 0; variable
|
| /developtools/smartperf_host/trace_streamer/test/unittest/pbreader_parser/native_memory/ |
| D | native_hook_parser_test.cpp | 35 bool ParseTraceFile(TraceStreamerSelector &ts_, const std::string &tracePath);
|