| /developtools/profiler/hiebpf/src/ |
| D | ringbuffer.cpp | 61 ssize_t RingBuffer::Read(const int fd, const std::size_t len) in Read() argument
66 if (len == 0) { in Read()
73 while (len >= FreeSize()) { in Read()
81 if (tail_ + len < bufSize_) { in Read()
83 destBufs[0].iov_len = len; in Read()
84 destBufs[1].iov_base = buffer_ + tail_ + len; in Read()
90 destBufs[1].iov_len = len + tail_ - bufSize_; in Read()
103 ssize_t RingBuffer::Write(const int fd, std::size_t len) in Write() argument
112 if (dataSize < len) { in Write()
113 len = dataSize; in Write()
[all …]
|
| /developtools/smartperf_host/trace_streamer/sdk/dubai_sdk/rpc/ |
| D | rpc_server.cpp | 32 bool RpcServer::SqlOperate(const uint8_t* data, size_t len, ResultCallBack resultCallBack) in SqlOperate() argument
35 std::string sql(reinterpret_cast<const char*>(data), len); in SqlOperate()
36 TS_LOGI("RPC SqlOperate(%s, %zu)", sql.c_str(), len); in SqlOperate()
49 bool RpcServer::SqlQuery(const uint8_t* data, size_t len, ResultCallBack resultCallBack) in SqlQuery() argument
52 std::string sql(reinterpret_cast<const char*>(data), len); in SqlQuery()
53 TS_LOGI("RPC SqlQuery %zu:%s", len, sql.c_str()); in SqlQuery()
68 bool RpcServer::Reset(const uint8_t* data, size_t len, ResultCallBack resultCallBack) in Reset() argument
71 UNUSED(len); in Reset()
82 int32_t RpcServer::WasmSqlQuery(const uint8_t* data, size_t len, uint8_t* out, int32_t outLen) in WasmSqlQuery() argument
85 std::string sql(reinterpret_cast<const char*>(data), len); in WasmSqlQuery()
[all …]
|
| /developtools/smartperf_host/trace_streamer/sdk/demo_sdk/rpc/ |
| D | rpc_server.cpp | 32 bool RpcServer::SqlOperate(const uint8_t* data, size_t len, ResultCallBack resultCallBack) in SqlOperate() argument
35 std::string sql(reinterpret_cast<const char*>(data), len); in SqlOperate()
36 TS_LOGI("RPC SqlOperate(%s, %zu)", sql.c_str(), len); in SqlOperate()
49 bool RpcServer::SqlQuery(const uint8_t* data, size_t len, ResultCallBack resultCallBack) in SqlQuery() argument
52 std::string sql(reinterpret_cast<const char*>(data), len); in SqlQuery()
53 TS_LOGI("RPC SqlQuery %zu:%s", len, sql.c_str()); in SqlQuery()
68 bool RpcServer::Reset(const uint8_t* data, size_t len, ResultCallBack resultCallBack) in Reset() argument
71 UNUSED(len); in Reset()
81 int32_t RpcServer::WasmSqlQuery(const uint8_t* data, size_t len, uint8_t* out, int32_t outLen) in WasmSqlQuery() argument
84 std::string sql(reinterpret_cast<const char*>(data), len); in WasmSqlQuery()
[all …]
|
| /developtools/profiler/proto_encoder/test/unittest/ |
| D | varint_encode_unittest.cpp | 43 uint32_t len = 0; variable
46 EXPECT_EQ(GetPackedVarintLenSize(itemCount, itemSize, len), (uint32_t)1);
47 EXPECT_EQ(len, (uint32_t)0);
50 EXPECT_EQ(GetPackedVarintLenSize(itemCount, itemSize, len), (uint32_t)1);
51 EXPECT_EQ(len, itemCount * itemSize);
54 EXPECT_EQ(GetPackedVarintLenSize(itemCount, itemSize, len), (uint32_t)1);
55 EXPECT_EQ(len, itemCount * itemSize);
59 EXPECT_EQ(GetPackedVarintLenSize(itemCount, itemSize, len), (uint32_t)1);
60 EXPECT_EQ(len, itemCount * itemSize);
63 EXPECT_EQ(GetPackedVarintLenSize(itemCount, itemSize, len), two);
[all …]
|
| /developtools/profiler/device/plugins/ftrace_plugin/tools/device_kernel_version/default/event_formatters/ |
| D | ftrace_ext4_event_formatter.cpp | 31 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon3fb332d90302() local
35 if (len >= BUFFER_SIZE - 1) { in __anon3fb332d90302()
48 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon3fb332d90502() local
57 …msg.len(), msg.block(), msg.logical(), msg.goal(), msg.lleft(), msg.lright(), msg.pleft(), msg.pri… in __anon3fb332d90502()
58 if (len >= BUFFER_SIZE - 1) { in __anon3fb332d90502()
71 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon3fb332d90702() local
75 if (len >= BUFFER_SIZE - 1) { in __anon3fb332d90702()
88 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon3fb332d90902() local
92 if (len >= BUFFER_SIZE - 1) { in __anon3fb332d90902()
105 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon3fb332d90b02() local
[all …]
|
| D | ftrace_binder_event_formatter.cpp | 32 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anonfa41cb480302() local
34 if (len >= BUFFER_SIZE - 1) { in __anonfa41cb480302()
47 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anonfa41cb480502() local
49 if (len >= BUFFER_SIZE - 1) { in __anonfa41cb480502()
62 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anonfa41cb480702() local
64 if (len >= BUFFER_SIZE - 1) { in __anonfa41cb480702()
77 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anonfa41cb480902() local
79 if (len >= BUFFER_SIZE - 1) { in __anonfa41cb480902()
92 … int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "binder_command: cmd=0x%x", msg.cmd()); in __anonfa41cb480b02() local
93 if (len >= BUFFER_SIZE - 1) { in __anonfa41cb480b02()
[all …]
|
| D | ftrace_clk_event_formatter.cpp | 31 … int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "clk_disable: %s", msg.name().c_str()); in __anon7c57e90e0302() local
32 if (len >= BUFFER_SIZE - 1) { in __anon7c57e90e0302()
44 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "clk_disable_complete: %s", msg.name().… in __anon7c57e90e0502() local
45 if (len >= BUFFER_SIZE - 1) { in __anon7c57e90e0502()
58 … int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "clk_enable: %s", msg.name().c_str()); in __anon7c57e90e0702() local
59 if (len >= BUFFER_SIZE - 1) { in __anon7c57e90e0702()
71 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "clk_enable_complete: %s", msg.name().c… in __anon7c57e90e0902() local
72 if (len >= BUFFER_SIZE - 1) { in __anon7c57e90e0902()
85 … int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "clk_prepare: %s", msg.name().c_str()); in __anon7c57e90e0b02() local
86 if (len >= BUFFER_SIZE - 1) { in __anon7c57e90e0b02()
[all …]
|
| D | ftrace_power_event_formatter.cpp | 32 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "clock_disable: %s state=%lu cpu_id=%lu… in __anon71a8eb010302() local
34 if (len >= BUFFER_SIZE - 1) { in __anon71a8eb010302()
46 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "clock_enable: %s state=%lu cpu_id=%lu", in __anon71a8eb010502() local
48 if (len >= BUFFER_SIZE - 1) { in __anon71a8eb010502()
60 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "clock_set_rate: %s state=%lu cpu_id=%l… in __anon71a8eb010702() local
62 if (len >= BUFFER_SIZE - 1) { in __anon71a8eb010702()
74 … int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "cpu_frequency: state=%lu cpu_id=%lu", in __anon71a8eb010902() local
76 if (len >= BUFFER_SIZE - 1) { in __anon71a8eb010902()
88 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "cpu_frequency_limits: min=%lu max=%lu … in __anon71a8eb010b02() local
90 if (len >= BUFFER_SIZE - 1) { in __anon71a8eb010b02()
[all …]
|
| D | ftrace_timer_event_formatter.cpp | 32 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "hrtimer_cancel: hrtimer=%p", msg.hrtim… in __anon76793a350302() local
33 if (len >= BUFFER_SIZE - 1) { in __anon76793a350302()
45 int len = 0; in __anon76793a350502() local
52 len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon76793a350502()
56 len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon76793a350502()
60 if (len >= BUFFER_SIZE - 1) { in __anon76793a350502()
73 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "hrtimer_expire_exit: hrtimer=%p", msg.… in __anon76793a350702() local
74 if (len >= BUFFER_SIZE - 1) { in __anon76793a350702()
87 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "hrtimer_init: hrtimer=%p clockid=%s mo… in __anon76793a350902() local
95 if (len >= BUFFER_SIZE - 1) { in __anon76793a350902()
[all …]
|
| D | ftrace_sched_event_formatter.cpp | 31 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "sched_blocked_reason: pid=%d iowait=%d… in __anon9926511b0302() local
33 if (len >= BUFFER_SIZE - 1) { in __anon9926511b0302()
46 int len = snprintf_s( in __anon9926511b0502() local
48 if (len >= BUFFER_SIZE - 1) { in __anon9926511b0502()
61 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "sched_kthread_stop_ret: ret=%d", msg.r… in __anon9926511b0702() local
62 if (len >= BUFFER_SIZE - 1) { in __anon9926511b0702()
75 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon9926511b0902() local
78 if (len >= BUFFER_SIZE - 1) { in __anon9926511b0902()
91 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon9926511b0b02() local
94 if (len >= BUFFER_SIZE - 1) { in __anon9926511b0b02()
[all …]
|
| D | ftrace_sunrpc_event_formatter.cpp | 31 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "rpc_call_status: task:%u@%u status=%d", in __anon4d46ca6f0302() local
33 if (len >= BUFFER_SIZE - 1) { in __anon4d46ca6f0302()
45 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "rpc_connect_status: task:%u@%u status=… in __anon4d46ca6f0502() local
47 if (len >= BUFFER_SIZE - 1) { in __anon4d46ca6f0502()
60 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon4d46ca6f0702() local
69 if (len >= BUFFER_SIZE - 1) { in __anon4d46ca6f0702()
81 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon4d46ca6f0902() local
90 if (len >= BUFFER_SIZE - 1) { in __anon4d46ca6f0902()
103 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon4d46ca6f0b02() local
112 if (len >= BUFFER_SIZE - 1) { in __anon4d46ca6f0b02()
[all …]
|
| D | ftrace_ftrace_event_formatter.cpp | 31 int len = 0; in __anonfbdbda490302() local
38 len = snprintf_s( in __anonfbdbda490302()
41 …len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "bputs: %p: %s", (void*)msg.ip(), msg.str()… in __anonfbdbda490302()
43 if (len >= BUFFER_SIZE - 1) { in __anonfbdbda490302()
55 … int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "branch: %u:%s:%s (%u)%s", msg.line(), in __anonfbdbda490502() local
57 if (len >= BUFFER_SIZE - 1) { in __anonfbdbda490502()
69 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "context_switch: %u:%u:%u ==> %u:%u:%u… in __anonfbdbda490702() local
72 if (len >= BUFFER_SIZE - 1) { in __anonfbdbda490702()
84 int len = 0; in __anonfbdbda490902() local
91 len = snprintf_s( in __anonfbdbda490902()
[all …]
|
| D | ftrace_regulator_event_formatter.cpp | 31 int len = in __anon43d2b6290302() local
33 if (len >= BUFFER_SIZE - 1) { in __anon43d2b6290302()
46 int len = snprintf_s( in __anon43d2b6290502() local
48 if (len >= BUFFER_SIZE - 1) { in __anon43d2b6290502()
61 int len = in __anon43d2b6290702() local
63 if (len >= BUFFER_SIZE - 1) { in __anon43d2b6290702()
76 int len = snprintf_s( in __anon43d2b6290902() local
78 if (len >= BUFFER_SIZE - 1) { in __anon43d2b6290902()
91 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "regulator_disable: name=%s", msg.name(… in __anon43d2b6290b02() local
92 if (len >= BUFFER_SIZE - 1) { in __anon43d2b6290b02()
[all …]
|
| D | ftrace_net_event_formatter.cpp | 31 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anoncd647f7b0302() local
36 …msg.vlan_tci(), msg.protocol(), msg.ip_summed(), msg.hash(), msg.l4_hash(), msg.len(), msg.data_le… in __anoncd647f7b0302()
38 if (len >= BUFFER_SIZE - 1) { in __anoncd647f7b0302()
51 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anoncd647f7b0502() local
56 …msg.vlan_tci(), msg.protocol(), msg.ip_summed(), msg.hash(), msg.l4_hash(), msg.len(), msg.data_le… in __anoncd647f7b0502()
58 if (len >= BUFFER_SIZE - 1) { in __anoncd647f7b0502()
71 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "net_dev_queue: dev=%s skbaddr=%p len=%… in __anoncd647f7b0702() local
72 msg.name().c_str(), msg.skbaddr(), msg.len()); in __anoncd647f7b0702()
73 if (len >= BUFFER_SIZE - 1) { in __anoncd647f7b0702()
85 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anoncd647f7b0902() local
[all …]
|
| D | ftrace_block_event_formatter.cpp | 31 int len = in __anon3d37977f0302() local
35 if (len >= BUFFER_SIZE - 1) { in __anon3d37977f0302()
48 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "block_bio_bounce: %d,%d %s %" PRIu64 "… in __anon3d37977f0502() local
51 if (len >= BUFFER_SIZE - 1) { in __anon3d37977f0502()
63 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "block_bio_complete: %d,%d %s %" PRIu64… in __anon3d37977f0702() local
66 if (len >= BUFFER_SIZE - 1) { in __anon3d37977f0702()
79 int len = in __anon3d37977f0902() local
83 if (len >= BUFFER_SIZE - 1) { in __anon3d37977f0902()
96 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "block_bio_queue: %d,%d %s %" PRIu64 " … in __anon3d37977f0b02() local
99 if (len >= BUFFER_SIZE - 1) { in __anon3d37977f0b02()
[all …]
|
| D | ftrace_writeback_event_formatter.cpp | 32 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anonb2efd3700302() local
40 if (len >= BUFFER_SIZE - 1) { in __anonb2efd3700302()
53 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anonb2efd3700502() local
59 if (len >= BUFFER_SIZE - 1) { in __anonb2efd3700502()
72 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anonb2efd3700702() local
77 if (len >= BUFFER_SIZE - 1) { in __anonb2efd3700702()
90 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anonb2efd3700902() local
96 if (len >= BUFFER_SIZE - 1) { in __anonb2efd3700902()
108 int len = in __anonb2efd3700b02() local
110 if (len >= BUFFER_SIZE - 1) { in __anonb2efd3700b02()
[all …]
|
| D | ftrace_cgroup_event_formatter.cpp | 31 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon2fd23b440302() local
34 if (len >= BUFFER_SIZE - 1) { in __anon2fd23b440302()
47 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "cgroup_destroy_root: root=%d ss_mask=%… in __anon2fd23b440502() local
49 if (len >= BUFFER_SIZE - 1) { in __anon2fd23b440502()
62 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "cgroup_freeze: root=%d id=%d level=%d … in __anon2fd23b440702() local
64 if (len >= BUFFER_SIZE - 1) { in __anon2fd23b440702()
76 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "cgroup_mkdir: root=%d id=%d level=%d p… in __anon2fd23b440902() local
78 if (len >= BUFFER_SIZE - 1) { in __anon2fd23b440902()
90 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon2fd23b440b02() local
93 if (len >= BUFFER_SIZE - 1) { in __anon2fd23b440b02()
[all …]
|
| D | ftrace_i2c_event_formatter.cpp | 31 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "i2c_read: i2c-%d #%u a=%03x f=%04x l=%… in __anonaa28e5120302() local
32 msg.adapter_nr(), msg.msg_nr(), msg.addr(), msg.flags(), msg.len()); in __anonaa28e5120302()
33 if (len >= BUFFER_SIZE - 1) { in __anonaa28e5120302()
45 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anonaa28e5120502() local
47 msg.addr(), msg.flags(), msg.len(), msg.buf()); in __anonaa28e5120502()
48 if (len >= BUFFER_SIZE - 1) { in __anonaa28e5120502()
60 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "i2c_result: i2c-%d n=%u ret=%d", msg.a… in __anonaa28e5120702() local
62 if (len >= BUFFER_SIZE - 1) { in __anonaa28e5120702()
74 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anonaa28e5120902() local
76 msg.addr(), msg.flags(), msg.len(), msg.buf()); in __anonaa28e5120902()
[all …]
|
| D | ftrace_workqueue_event_formatter.cpp | 31 int len = in __anone942ec7c0302() local
33 if (len >= BUFFER_SIZE - 1) { in __anone942ec7c0302()
46 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "workqueue_execute_end: work struct %p"… in __anone942ec7c0502() local
47 if (len >= BUFFER_SIZE - 1) { in __anone942ec7c0502()
60 int len = 0; in __anone942ec7c0702() local
67 len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anone942ec7c0702()
70 len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anone942ec7c0702()
73 if (len >= BUFFER_SIZE - 1) { in __anone942ec7c0702()
86 int len = 0; in __anone942ec7c0902() local
93 len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anone942ec7c0902()
[all …]
|
| /developtools/profiler/host/smartperf/trace_streamer/src/rpc/ |
| D | rpc_server.cpp | 36 bool RpcServer::ParseData(const uint8_t* data, size_t len, ResultCallBack resultCallBack) in ParseData() argument
38 g_loadSize += len; in ParseData()
41 size_t parseSize = std::min(len, blockSize); in ParseData()
51 len -= parseSize; in ParseData()
53 } while (len > 0); in ParseData()
60 int32_t RpcServer::UpdateTraceTime(const uint8_t* data, int32_t len) in UpdateTraceTime() argument
62 std::unique_ptr<uint8_t[]> buf = std::make_unique<uint8_t[]>(len); in UpdateTraceTime()
63 std::copy(data, data + len, buf.get()); in UpdateTraceTime()
64 ts_->UpdateTraceRangeTime(buf.get(), len); in UpdateTraceTime()
68 int32_t RpcServer::TraceStreamer_Init_ThirdParty_Config(const uint8_t* data, int32_t len) in TraceStreamer_Init_ThirdParty_Config() argument
[all …]
|
| D | rpc_server.h | 30 bool ParseData(const uint8_t* data, size_t len, ResultCallBack resultCallBack);
31 bool ParseDataOver(const uint8_t* data, size_t len, ResultCallBack resultCallBack);
32 bool SqlOperate(const uint8_t* data, size_t len, ResultCallBack resultCallBack);
33 bool SqlQuery(const uint8_t* data, size_t len, ResultCallBack resultCallBack);
34 bool Reset(const uint8_t* data, size_t len, ResultCallBack resultCallBack);
38 int32_t WasmSqlQuery(const uint8_t* data, size_t len, uint8_t* out, int32_t outLen);
39 … int32_t WasmSqlQueryWithCallback(const uint8_t* data, size_t len, ResultCallBack callback) const;
40 int32_t UpdateTraceTime(const uint8_t* data, int32_t len);
41 int32_t TraceStreamer_Init_ThirdParty_Config(const uint8_t* data, int32_t len);
47 size_t len,
|
| /developtools/smartperf_host/trace_streamer/src/rpc/ |
| D | rpc_server.cpp | 51 bool RpcServer::ParseData(const uint8_t* data, size_t len, ResultCallBack resultCallBack) in ParseData() argument
53 g_loadSize += len; in ParseData()
56 size_t parseSize = std::min(len, blockSize); in ParseData()
66 len -= parseSize; in ParseData()
68 } while (len > 0); in ParseData()
75 int32_t RpcServer::UpdateTraceTime(const uint8_t* data, int32_t len) in UpdateTraceTime() argument
77 std::unique_ptr<uint8_t[]> buf = std::make_unique<uint8_t[]>(len); in UpdateTraceTime()
78 std::copy(data, data + len, buf.get()); in UpdateTraceTime()
79 ts_->UpdateTraceRangeTime(buf.get(), len); in UpdateTraceTime()
83 int32_t RpcServer::TraceStreamer_Init_ThirdParty_Config(const uint8_t* data, int32_t len) in TraceStreamer_Init_ThirdParty_Config() argument
[all …]
|
| /developtools/smartperf_host/trace_streamer/src/base/ |
| D | codec_cov.cpp | 41 bool IsUTF8(const uint8_t* data, int32_t len) in IsUTF8() argument
48 while (i < len) { in IsUTF8()
67 bool IsGBK(const uint8_t* data, int32_t len) in IsGBK() argument
77 while (i < len) { in IsGBK()
94 CODING GetCoding(const uint8_t* data, int32_t len) in GetCoding() argument
97 if (IsUTF8(data, len)) { in GetCoding()
99 } else if (IsGBK(data, len)) { in GetCoding()
110 int32_t len = MultiByteToWideChar(CP_ACP, 0, srcStr, -1, NULL, 0); in GbkToUtf8() local
111 std::unique_ptr<wchar_t[]> wstr = std::make_unique<wchar_t[]>(len + 1); in GbkToUtf8()
112 MultiByteToWideChar(CP_ACP, 0, srcStr, -1, wstr.get(), len); in GbkToUtf8()
[all …]
|
| /developtools/profiler/host/smartperf/trace_streamer/src/base/ |
| D | codec_cov.cpp | 41 bool IsUTF8(const uint8_t* data, int32_t len) in IsUTF8() argument
48 while (i < len) { in IsUTF8()
67 bool IsGBK(const uint8_t* data, int32_t len) in IsGBK() argument
77 while (i < len) { in IsGBK()
94 CODING GetCoding(const uint8_t* data, int32_t len) in GetCoding() argument
97 if (IsUTF8(data, len)) { in GetCoding()
99 } else if (IsGBK(data, len)) { in GetCoding()
110 int32_t len = MultiByteToWideChar(CP_ACP, 0, srcStr, -1, NULL, 0); in GbkToUtf8() local
111 std::unique_ptr<wchar_t[]> wstr = std::make_unique<wchar_t[]>(len + 1); in GbkToUtf8()
112 MultiByteToWideChar(CP_ACP, 0, srcStr, -1, wstr.get(), len); in GbkToUtf8()
[all …]
|
| /developtools/profiler/hiebpf/include/ |
| D | ringbuffer.h | 65 const std::size_t len {sizeof(T)}; in Peek()
70 if (len == 0) { in Peek()
75 if (dataSize < len) { in Peek()
78 if (head_ + len > bufSize_) { in Peek()
80 int ret = memcpy_s(dest, len, buffer_ + head_, bufSize_ - head_); in Peek()
84 … ret = memcpy_s(dest + bufSize_ - head_, len + head_ - bufSize_, buffer_, len + head_ - bufSize_); in Peek()
89 if (memcpy_s(dest, len, buffer_ + head_, len) != EOK) { in Peek()
96 ssize_t Read(const int fd, const std::size_t len);
97 ssize_t Write(const int fd, const std::size_t len);
98 std::size_t Get(char* dest, const std::size_t len);
[all …]
|