| /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/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/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/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 __anon2a10a1f80302() local
35 if (len >= BUFFER_SIZE - 1) { in __anon2a10a1f80302()
48 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon2a10a1f80502() local
57 …msg.len(), msg.block(), msg.logical(), msg.goal(), msg.lleft(), msg.lright(), msg.pleft(), msg.pri… in __anon2a10a1f80502()
58 if (len >= BUFFER_SIZE - 1) { in __anon2a10a1f80502()
71 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon2a10a1f80702() local
75 if (len >= BUFFER_SIZE - 1) { in __anon2a10a1f80702()
88 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon2a10a1f80902() local
92 if (len >= BUFFER_SIZE - 1) { in __anon2a10a1f80902()
105 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon2a10a1f80b02() local
[all …]
|
| D | ftrace_binder_event_formatter.cpp | 32 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anonf1b77e270302() local
34 if (len >= BUFFER_SIZE - 1) { in __anonf1b77e270302()
47 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anonf1b77e270502() local
49 if (len >= BUFFER_SIZE - 1) { in __anonf1b77e270502()
62 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anonf1b77e270702() local
64 if (len >= BUFFER_SIZE - 1) { in __anonf1b77e270702()
77 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anonf1b77e270902() local
79 if (len >= BUFFER_SIZE - 1) { in __anonf1b77e270902()
92 … int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "binder_command: cmd=0x%x", msg.cmd()); in __anonf1b77e270b02() local
93 if (len >= BUFFER_SIZE - 1) { in __anonf1b77e270b02()
[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 __anon4d24704d0302() local
32 if (len >= BUFFER_SIZE - 1) { in __anon4d24704d0302()
44 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "clk_disable_complete: %s", msg.name().… in __anon4d24704d0502() local
45 if (len >= BUFFER_SIZE - 1) { in __anon4d24704d0502()
58 … int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "clk_enable: %s", msg.name().c_str()); in __anon4d24704d0702() local
59 if (len >= BUFFER_SIZE - 1) { in __anon4d24704d0702()
71 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "clk_enable_complete: %s", msg.name().c… in __anon4d24704d0902() local
72 if (len >= BUFFER_SIZE - 1) { in __anon4d24704d0902()
85 … int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "clk_prepare: %s", msg.name().c_str()); in __anon4d24704d0b02() local
86 if (len >= BUFFER_SIZE - 1) { in __anon4d24704d0b02()
[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 __anona7b43e000302() local
34 if (len >= BUFFER_SIZE - 1) { in __anona7b43e000302()
46 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "clock_enable: %s state=%lu cpu_id=%lu", in __anona7b43e000502() local
48 if (len >= BUFFER_SIZE - 1) { in __anona7b43e000502()
60 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "clock_set_rate: %s state=%lu cpu_id=%l… in __anona7b43e000702() local
62 if (len >= BUFFER_SIZE - 1) { in __anona7b43e000702()
74 … int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "cpu_frequency: state=%lu cpu_id=%lu", in __anona7b43e000902() local
76 if (len >= BUFFER_SIZE - 1) { in __anona7b43e000902()
88 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "cpu_frequency_limits: min=%lu max=%lu … in __anona7b43e000b02() local
90 if (len >= BUFFER_SIZE - 1) { in __anona7b43e000b02()
[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 __anonac848d340302() local
33 if (len >= BUFFER_SIZE - 1) { in __anonac848d340302()
45 int len = 0; in __anonac848d340502() local
52 len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anonac848d340502()
56 len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anonac848d340502()
60 if (len >= BUFFER_SIZE - 1) { in __anonac848d340502()
73 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "hrtimer_expire_exit: hrtimer=%p", msg.… in __anonac848d340702() local
74 if (len >= BUFFER_SIZE - 1) { in __anonac848d340702()
87 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "hrtimer_init: hrtimer=%p clockid=%s mo… in __anonac848d340902() local
95 if (len >= BUFFER_SIZE - 1) { in __anonac848d340902()
[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 __anoncf31a41a0302() local
33 if (len >= BUFFER_SIZE - 1) { in __anoncf31a41a0302()
46 int len = snprintf_s( in __anoncf31a41a0502() local
48 if (len >= BUFFER_SIZE - 1) { in __anoncf31a41a0502()
61 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "sched_kthread_stop_ret: ret=%d", msg.r… in __anoncf31a41a0702() local
62 if (len >= BUFFER_SIZE - 1) { in __anoncf31a41a0702()
75 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anoncf31a41a0902() local
78 if (len >= BUFFER_SIZE - 1) { in __anoncf31a41a0902()
91 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anoncf31a41a0b02() local
94 if (len >= BUFFER_SIZE - 1) { in __anoncf31a41a0b02()
[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 __anon44bc7d4e0302() local
33 if (len >= BUFFER_SIZE - 1) { in __anon44bc7d4e0302()
45 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "rpc_connect_status: task:%u@%u status=… in __anon44bc7d4e0502() local
47 if (len >= BUFFER_SIZE - 1) { in __anon44bc7d4e0502()
60 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon44bc7d4e0702() local
69 if (len >= BUFFER_SIZE - 1) { in __anon44bc7d4e0702()
81 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon44bc7d4e0902() local
90 if (len >= BUFFER_SIZE - 1) { in __anon44bc7d4e0902()
103 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon44bc7d4e0b02() local
112 if (len >= BUFFER_SIZE - 1) { in __anon44bc7d4e0b02()
[all …]
|
| D | ftrace_ftrace_event_formatter.cpp | 31 int len = 0; in __anonf3518d280302() local
38 len = snprintf_s( in __anonf3518d280302()
41 …len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "bputs: %p: %s", (void*)msg.ip(), msg.str()… in __anonf3518d280302()
43 if (len >= BUFFER_SIZE - 1) { in __anonf3518d280302()
55 … int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "branch: %u:%s:%s (%u)%s", msg.line(), in __anonf3518d280502() local
57 if (len >= BUFFER_SIZE - 1) { in __anonf3518d280502()
69 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "context_switch: %u:%u:%u ==> %u:%u:%u… in __anonf3518d280702() local
72 if (len >= BUFFER_SIZE - 1) { in __anonf3518d280702()
84 int len = 0; in __anonf3518d280902() local
91 len = snprintf_s( in __anonf3518d280902()
[all …]
|
| D | ftrace_regulator_event_formatter.cpp | 31 int len = in __anon653d70a80302() local
33 if (len >= BUFFER_SIZE - 1) { in __anon653d70a80302()
46 int len = snprintf_s( in __anon653d70a80502() local
48 if (len >= BUFFER_SIZE - 1) { in __anon653d70a80502()
61 int len = in __anon653d70a80702() local
63 if (len >= BUFFER_SIZE - 1) { in __anon653d70a80702()
76 int len = snprintf_s( in __anon653d70a80902() local
78 if (len >= BUFFER_SIZE - 1) { in __anon653d70a80902()
91 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "regulator_disable: name=%s", msg.name(… in __anon653d70a80b02() local
92 if (len >= BUFFER_SIZE - 1) { in __anon653d70a80b02()
[all …]
|
| D | ftrace_net_event_formatter.cpp | 31 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon9e3106ba0302() local
36 …msg.vlan_tci(), msg.protocol(), msg.ip_summed(), msg.hash(), msg.l4_hash(), msg.len(), msg.data_le… in __anon9e3106ba0302()
38 if (len >= BUFFER_SIZE - 1) { in __anon9e3106ba0302()
51 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon9e3106ba0502() local
56 …msg.vlan_tci(), msg.protocol(), msg.ip_summed(), msg.hash(), msg.l4_hash(), msg.len(), msg.data_le… in __anon9e3106ba0502()
58 if (len >= BUFFER_SIZE - 1) { in __anon9e3106ba0502()
71 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "net_dev_queue: dev=%s skbaddr=%p len=%… in __anon9e3106ba0702() local
72 msg.name().c_str(), msg.skbaddr(), msg.len()); in __anon9e3106ba0702()
73 if (len >= BUFFER_SIZE - 1) { in __anon9e3106ba0702()
85 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon9e3106ba0902() local
[all …]
|
| D | ftrace_block_event_formatter.cpp | 31 int len = in __anon7342ea7e0302() local
35 if (len >= BUFFER_SIZE - 1) { in __anon7342ea7e0302()
48 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "block_bio_bounce: %d,%d %s %" PRIu64 "… in __anon7342ea7e0502() local
51 if (len >= BUFFER_SIZE - 1) { in __anon7342ea7e0502()
63 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "block_bio_complete: %d,%d %s %" PRIu64… in __anon7342ea7e0702() local
66 if (len >= BUFFER_SIZE - 1) { in __anon7342ea7e0702()
79 int len = in __anon7342ea7e0902() local
83 if (len >= BUFFER_SIZE - 1) { in __anon7342ea7e0902()
96 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "block_bio_queue: %d,%d %s %" PRIu64 " … in __anon7342ea7e0b02() local
99 if (len >= BUFFER_SIZE - 1) { in __anon7342ea7e0b02()
[all …]
|
| D | ftrace_writeback_event_formatter.cpp | 32 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anond45a8def0302() local
40 if (len >= BUFFER_SIZE - 1) { in __anond45a8def0302()
53 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anond45a8def0502() local
59 if (len >= BUFFER_SIZE - 1) { in __anond45a8def0502()
72 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anond45a8def0702() local
77 if (len >= BUFFER_SIZE - 1) { in __anond45a8def0702()
90 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anond45a8def0902() local
96 if (len >= BUFFER_SIZE - 1) { in __anond45a8def0902()
108 int len = in __anond45a8def0b02() local
110 if (len >= BUFFER_SIZE - 1) { in __anond45a8def0b02()
[all …]
|
| D | ftrace_cgroup_event_formatter.cpp | 31 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon2747ee230302() local
34 if (len >= BUFFER_SIZE - 1) { in __anon2747ee230302()
47 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "cgroup_destroy_root: root=%d ss_mask=%… in __anon2747ee230502() local
49 if (len >= BUFFER_SIZE - 1) { in __anon2747ee230502()
62 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "cgroup_freeze: root=%d id=%d level=%d … in __anon2747ee230702() local
64 if (len >= BUFFER_SIZE - 1) { in __anon2747ee230702()
76 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "cgroup_mkdir: root=%d id=%d level=%d p… in __anon2747ee230902() local
78 if (len >= BUFFER_SIZE - 1) { in __anon2747ee230902()
90 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon2747ee230b02() local
93 if (len >= BUFFER_SIZE - 1) { in __anon2747ee230b02()
[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 __anon7af56c510302() local
32 msg.adapter_nr(), msg.msg_nr(), msg.addr(), msg.flags(), msg.len()); in __anon7af56c510302()
33 if (len >= BUFFER_SIZE - 1) { in __anon7af56c510302()
45 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon7af56c510502() local
47 msg.addr(), msg.flags(), msg.len(), msg.buf()); in __anon7af56c510502()
48 if (len >= BUFFER_SIZE - 1) { in __anon7af56c510502()
60 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "i2c_result: i2c-%d n=%u ret=%d", msg.a… in __anon7af56c510702() local
62 if (len >= BUFFER_SIZE - 1) { in __anon7af56c510702()
74 int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon7af56c510902() local
76 msg.addr(), msg.flags(), msg.len(), msg.buf()); in __anon7af56c510902()
[all …]
|
| D | ftrace_workqueue_event_formatter.cpp | 31 int len = in __anon0aada6fb0302() local
33 if (len >= BUFFER_SIZE - 1) { in __anon0aada6fb0302()
46 …int len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, "workqueue_execute_end: work struct %p"… in __anon0aada6fb0502() local
47 if (len >= BUFFER_SIZE - 1) { in __anon0aada6fb0502()
60 int len = 0; in __anon0aada6fb0702() local
67 len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon0aada6fb0702()
70 len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon0aada6fb0702()
73 if (len >= BUFFER_SIZE - 1) { in __anon0aada6fb0702()
86 int len = 0; in __anon0aada6fb0902() local
93 len = snprintf_s(buffer, BUFFER_SIZE, BUFFER_SIZE - 1, in __anon0aada6fb0902()
[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 …]
|