| /developtools/smartperf_host/trace_streamer/sdk/demo_sdk/rpc/ |
| D | rpc_server.cpp | 34 ts_->SetCancel(false); in SqlOperate()
38 int32_t ret = ts_->OperateDatabase(sql); in SqlOperate()
51 ts_->SetCancel(false); in SqlQuery()
55 int32_t ret = ts_->SearchDatabase(sql, resultCallBack); in SqlQuery()
59 ts_->SetCancel(false); in SqlQuery()
65 ts_->SetCancel(true); in CancelSqlQuery()
73 ts_->WaitForParserEnd(); in Reset()
74 ts_ = std::make_unique<TraceStreamerSelector>(); in Reset()
83 ts_->SetCancel(false); in WasmSqlQuery()
86 int32_t ret = ts_->SearchDatabase(sql, out, outLen); in WasmSqlQuery()
[all …]
|
| D | rpc_server.h | 41 std::unique_ptr<TraceStreamerSelector> ts_ = std::make_unique<TraceStreamerSelector>();
|
| /developtools/smartperf_host/trace_streamer/sdk/dubai_sdk/rpc/ |
| D | rpc_server.cpp | 34 ts_->SetCancel(false); in SqlOperate()
38 int32_t ret = ts_->OperateDatabase(sql); in SqlOperate()
51 ts_->SetCancel(false); in SqlQuery()
55 int32_t ret = ts_->SearchDatabase(sql, resultCallBack); in SqlQuery()
59 ts_->SetCancel(false); in SqlQuery()
65 ts_->SetCancel(true); in CancelSqlQuery()
74 ts_->WaitForParserEnd(); in Reset()
75 ts_ = std::make_unique<TraceStreamerSelector>(); in Reset()
84 ts_->SetCancel(false); in WasmSqlQuery()
87 int32_t ret = ts_->SearchDatabase(sql, out, outLen); in WasmSqlQuery()
[all …]
|
| D | rpc_server.h | 41 std::unique_ptr<TraceStreamerSelector> ts_ = std::make_unique<TraceStreamerSelector>();
|
| /developtools/smartperf_host/trace_streamer/src/rpc/ |
| D | rpc_server.cpp | 59 if (!ts_->ParseTraceDataSegment(std::move(buf), parseSize)) { in ParseData()
79 ts_->UpdateTraceRangeTime(buf.get(), len); in UpdateTraceTime()
107 MetaData* metaData = ts_->GetMetaData(); in ParseDataOver()
113 …metaData->SetTraceType((ts_->DataType() == TRACE_FILETYPE_H_TRACE) ? "proto-based-trace" : "txt-ba… in ParseDataOver()
116 ts_->WaitForParserEnd(); in ParseDataOver()
118 ts_->Clear(); in ParseDataOver()
130 ts_->SetCancel(false); in SqlOperate()
134 int32_t ret = ts_->OperateDatabase(sql); in SqlOperate()
147 ts_->SetCancel(false); in SqlQuery()
151 int32_t ret = ts_->SearchDatabase(sql, resultCallBack); in SqlQuery()
[all …]
|
| /developtools/profiler/host/smartperf/trace_streamer/src/rpc/ |
| D | rpc_server.cpp | 44 if (!ts_->ParseTraceDataSegment(std::move(buf), parseSize)) { in ParseData()
64 ts_->UpdateTraceRangeTime(buf.get(), len); in UpdateTraceTime()
92 MetaData* metaData = ts_->GetMetaData(); in ParseDataOver()
98 …metaData->SetTraceType((ts_->DataType() == TRACE_FILETYPE_H_TRACE) ? "proto-based-trace" : "txt-ba… in ParseDataOver()
101 ts_->WaitForParserEnd(); in ParseDataOver()
103 ts_->Clear(); in ParseDataOver()
115 ts_->SetCancel(false); in SqlOperate()
119 int32_t ret = ts_->OperateDatabase(sql); in SqlOperate()
132 ts_->SetCancel(false); in SqlQuery()
136 int32_t ret = ts_->SearchDatabase(sql, resultCallBack); in SqlQuery()
[all …]
|
| /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/sdk/dubai_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/profiler/host/smartperf/trace_streamer/src/parser/htrace_pbreader_parser/ |
| D | htrace_process_parser.cpp | 71 return a->ts_ < b->ts_; in Finish()
81 auto tsOld = (*itor)->ts_; in Finish()
82 … (*itor)->ts_ = streamFilters_->clockFilter_->ToPrimaryTraceTime(TS_CLOCK_REALTIME, (*itor)->ts_); in Finish()
83 UpdatePluginTimeRange(TS_CLOCK_REALTIME, tsOld, (*itor)->ts_); in Finish()
85 lastTs = (*itor)->ts_; in Finish()
89 auto dur = (*itor)->ts_ - lastTs; in Finish()
90 lastTs = (*itor)->ts_; in Finish()
95 …(*itor)->ts_, dur, (*itor)->processInfo_->pid_, (*itor)->processInfo_->name_, (*itor)->processInfo… in Finish()
|
| D | htrace_cpu_data_parser.h | 41 ts_ = 0; in TsCpuData()
46 ts_ = ts; in SetCpuUsage()
51 ts_ = ts; in SetThreadInfo()
62 uint64_t ts_; variable
|
| D | htrace_cpu_data_parser.cpp | 54 …st std::unique_ptr<TsCpuData>& a, const std::unique_ptr<TsCpuData>& b) { return a->ts_ < b->ts_; }; in Finish()
63 auto newTimeStamp = (*itor)->ts_; in Finish()
|
| D | htrace_process_parser.h | 88 ts_ = ts; in SetLiveProcess()
94 uint64_t ts_; member
|
| /developtools/smartperf_host/trace_streamer/src/parser/htrace_pbreader_parser/ |
| D | htrace_process_parser.cpp | 71 return a->ts_ < b->ts_; in Finish()
81 auto tsOld = (*itor)->ts_; in Finish()
82 … (*itor)->ts_ = streamFilters_->clockFilter_->ToPrimaryTraceTime(TS_CLOCK_REALTIME, (*itor)->ts_); in Finish()
83 UpdatePluginTimeRange(TS_CLOCK_REALTIME, tsOld, (*itor)->ts_); in Finish()
85 lastTs = (*itor)->ts_; in Finish()
89 auto dur = (*itor)->ts_ - lastTs; in Finish()
90 lastTs = (*itor)->ts_; in Finish()
95 …(*itor)->ts_, dur, (*itor)->processInfo_->pid_, (*itor)->processInfo_->name_, (*itor)->processInfo… in Finish()
|
| D | htrace_cpu_data_parser.h | 41 ts_ = 0; in TsCpuData()
46 ts_ = ts; in SetCpuUsage()
51 ts_ = ts; in SetThreadInfo()
62 uint64_t ts_; variable
|
| D | htrace_cpu_data_parser.cpp | 53 …st std::unique_ptr<TsCpuData>& a, const std::unique_ptr<TsCpuData>& b) { return a->ts_ < b->ts_; }; in Finish()
62 auto newTimeStamp = (*itor)->ts_; in Finish()
|
| D | htrace_process_parser.h | 88 ts_ = ts; in SetLiveProcess()
94 uint64_t ts_; member
|
| /developtools/smartperf_host/trace_streamer/sdk/demo_sdk/sdk/ |
| D | ts_sdk_api.cpp | 26 …rpcServer_->ts_->sdkDataParser_->SetTableName(counterTableName, counterObjectTableName, sliceTable… in SDK_SetTableName()
36 return rpcServer_->ts_->sdkDataParser_->AppendCounterObject(counterId, columnName); in SDK_AppendCounterObject()
40 return rpcServer_->ts_->sdkDataParser_->AppendCounter(counterId, ts, value); in SDK_AppendCounter()
44 return rpcServer_->ts_->sdkDataParser_->AppendSliceObject(sliceId, columnName); in SDK_AppendSliceObject()
48 return rpcServer_->ts_->sdkDataParser_->AppendSlice(sliceId, ts, endTs, value); in SDK_AppendSlice()
|
| D | wasm_func.cpp | 53 g_wasmTraceStreamer.ts_->sdkDataParser_->CreateTableByJson(); in Init()
72 g_wasmTraceStreamer.ts_->sdkDataParser_->GetPluginName(pluginNameStr); in TraceStreamer_In_PluginName()
93 MetaData* metaData = g_wasmTraceStreamer.ts_->GetMetaData(); in TraceStreamer_In_ParseDataOver()
97 g_wasmTraceStreamer.ts_->sdkDataParser_->ParseDataOver(&TraceRangeCallback); in TraceStreamer_In_ParseDataOver()
104 g_wasmTraceStreamer.ts_->sdkDataParser_->GetJsonConfig(&QueryResultCallback); in TraceStreamer_In_JsonConfig()
126 g_wasmTraceStreamer.ts_->sdkDataParser_->ParserData(g_reqBuf, len, componentId); in ParserData()
|
| /developtools/smartperf_host/trace_streamer/sdk/dubai_sdk/sdk/ |
| D | ts_sdk_api.cpp | 26 …rpcServer_->ts_->sdkDataParser_->SetTableName(counterTableName, counterObjectTableName, sliceTable… in SDK_SetTableName()
36 return rpcServer_->ts_->sdkDataParser_->AppendCounterObject(counterId, columnName); in SDK_AppendCounterObject()
40 return rpcServer_->ts_->sdkDataParser_->AppendCounter(counterId, ts, value); in SDK_AppendCounter()
44 return rpcServer_->ts_->sdkDataParser_->AppendSliceObject(sliceId, columnName); in SDK_AppendSliceObject()
53 …return rpcServer_->ts_->sdkDataParser_->AppendSlice(sliceId, ts, endTs, start_time, end_time, valu… in SDK_AppendSlice()
|
| D | wasm_func.cpp | 53 g_wasmTraceStreamer.ts_->sdkDataParser_->CreateTableByJson(); in Init()
72 g_wasmTraceStreamer.ts_->sdkDataParser_->GetPluginName(pluginNameStr); in TraceStreamer_In_PluginName()
93 MetaData* metaData = g_wasmTraceStreamer.ts_->GetMetaData(); in TraceStreamer_In_ParseDataOver()
97 g_wasmTraceStreamer.ts_->sdkDataParser_->ParseDataOver(&TraceRangeCallback); in TraceStreamer_In_ParseDataOver()
104 g_wasmTraceStreamer.ts_->sdkDataParser_->GetJsonConfig(&QueryResultCallback); in TraceStreamer_In_JsonConfig()
127 g_wasmTraceStreamer.ts_->sdkDataParser_->ParserData(g_reqBuf, len, componentId); in ParserData()
|
| /developtools/smartperf_host/trace_streamer/src/table/base/ |
| D | span_join.cpp | 273 ts_ = endTs_; in GetNextState()
290 ts_ = 0; in GetNextState()
293 ts_ = sqlite3_column_int64(stmt_, static_cast<int32_t>(desc_->tsIdx)); in GetNextState()
294 endTs_ = ts_ + sqlite3_column_int64(stmt_, static_cast<int32_t>(desc_->durIdx)); in GetNextState()
303 ts_ = 0; in GetNextState()
359 if (tableFirst_.ts_ >= tableSecond_.ts_) { in CaclOverLap()
362 tableFirst_.ts_ < tableSecond_.endTs_) { in CaclOverLap()
365 } else if (tableFirst_.ts_ <= tableSecond_.ts_ && tableSecond_.ts_ < tableFirst_.endTs_) { in CaclOverLap()
406 …e3_result_int64(context_, static_cast<sqlite3_int64>(std::max(tableFirst_.ts_, tableSecond_.ts_))); in Column()
412 … std::max(tableFirst_.ts_, tableSecond_.ts_))); in Column()
|
| /developtools/profiler/host/smartperf/trace_streamer/src/table/base/ |
| D | span_join.cpp | 273 ts_ = endTs_; in GetNextState()
290 ts_ = 0; in GetNextState()
293 ts_ = sqlite3_column_int64(stmt_, static_cast<int32_t>(desc_->tsIdx)); in GetNextState()
294 endTs_ = ts_ + sqlite3_column_int64(stmt_, static_cast<int32_t>(desc_->durIdx)); in GetNextState()
303 ts_ = 0; in GetNextState()
359 if (tableFirst_.ts_ >= tableSecond_.ts_) { in CaclOverLap()
362 tableFirst_.ts_ < tableSecond_.endTs_) { in CaclOverLap()
365 } else if (tableFirst_.ts_ <= tableSecond_.ts_ && tableSecond_.ts_ < tableFirst_.endTs_) { in CaclOverLap()
406 …e3_result_int64(context_, static_cast<sqlite3_int64>(std::max(tableFirst_.ts_, tableSecond_.ts_))); in Column()
412 … std::max(tableFirst_.ts_, tableSecond_.ts_))); in Column()
|
| /developtools/smartperf_host/trace_streamer/test/unittest/ |
| D | rpc_server_test.cpp | 106 EXPECT_EQ(rpcServer.ts_->traceDataCache_->taskPoolTraceEnabled_, true);
107 …PrintEventParser printEvent(rpcServer.ts_->traceDataCache_.get(), rpcServer.ts_->streamFilters_.ge…
109 auto res = rpcServer.ts_->traceDataCache_->GetConstTaskPoolData().prioritys_[0];
|
| /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()
|
| /developtools/smartperf_host/trace_streamer/sdk/dubai_sdk/trace_data/ |
| D | trace_stdtype.cpp | 24 ts_.emplace_back(ts); in AppendNewData()
31 return ts_; in TimeStamp()
|