| /developtools/profiler/device/plugins/ftrace_plugin/test/unittest/ |
| D | ftrace_field_parser_test.cpp | 32 std::vector<uint8_t> buffer_; member in __anon48756d7d0111::FtraceFieldParserTest
37 size_t offset = buffer_.size(); in AppendInt()
38 buffer_.resize(buffer_.size() + sizeof(value)); in AppendInt()
39 if (memcpy_s(&buffer_[offset], buffer_.capacity() - offset, &value, sizeof(value))) { in AppendInt()
53 size_t offset = buffer_.size(); in AppendString()
54 buffer_.resize(buffer_.size() + str.size()); in AppendString()
55 if (memcpy_s(&buffer_[offset], buffer_.capacity() - offset, &str[0], str.size())) { in AppendString()
82 … int actual = FtraceFieldParser::ParseIntField<int>(formats_[i], buffer_.data(), buffer_.size());
97 … int actual = FtraceFieldParser::ParseIntField<int>(formats_, i, buffer_.data(), buffer_.size());
112 …std::string actual = FtraceFieldParser::ParseStrField(formats_[i], buffer_.data(), buffer_.size());
[all …]
|
| /developtools/profiler/hiebpf/src/ |
| D | ringbuffer.cpp | 33 buffer_ = new(std::nothrow) char[bufSize_];
40 buffer_ = reinterpret_cast<char *>(temp);
47 buffer_ = reinterpret_cast<char *>(temp);
54 buffer_ = reinterpret_cast<char *>(temp);
80 destBufs[0].iov_base = buffer_ + tail_; in Read()
84 destBufs[1].iov_base = buffer_ + tail_ + len; in Read()
89 destBufs[1].iov_base = buffer_; in Read()
119 srcBufs[0].iov_base = buffer_ + head_; in Write()
123 srcBufs[1].iov_base = buffer_; in Write()
128 srcBufs[1].iov_base = buffer_ + head_ + len; in Write()
[all …]
|
| /developtools/profiler/device/plugins/diskio_plugin/src/ |
| D | diskio_data_plugin.cpp | 29 buffer_ = nullptr; in DiskioDataPlugin()
41 if (buffer_ != nullptr) { in ~DiskioDataPlugin()
42 free(buffer_); in ~DiskioDataPlugin()
43 buffer_ = nullptr; in ~DiskioDataPlugin()
49 buffer_ = malloc(READ_BUFFER_SIZE); in Start()
50 CHECK_NOTNULL(buffer_, RET_FAIL, "%s:malloc buffer_ failed!", __func__); in Start()
86 if (buffer_ != nullptr) { in Stop()
87 free(buffer_); in Stop()
88 buffer_ = nullptr; in Stop()
111 if (buffer_ == nullptr) { in ReadFile()
[all …]
|
| /developtools/profiler/device/plugins/ftrace_plugin/src/ |
| D | result_transporter.cpp | 72 buffer_.resize(size); in Write()
73 CHECK_TRUE(buffer_.size() == size, -1, in Write()
75 __func__, size, buffer_.size(), errno, strerror(errno)); in Write()
77 int ret = packet->SerializeToArray(buffer_.data(), buffer_.size()); in Write()
80 writer_->write(writer_, buffer_.data(), buffer_.size()); in Write()
81 return buffer_.size(); in Write()
|
| /developtools/profiler/hiebpf/include/ |
| D | ringbuffer.h | 37 if (buffer_ != nullptr) { in ~RingBuffer()
38 delete[] buffer_; in ~RingBuffer()
39 buffer_ = nullptr; in ~RingBuffer()
45 return buffer_;
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()
132 char *buffer_ {nullptr};
|
| /developtools/profiler/device/plugins/stream_plugin/src/ |
| D | stream_plugin.cpp | 73 buffer_.resize(dataProto.ByteSizeLong()); in Loop()
74 dataProto.SerializeToArray(buffer_.data(), buffer_.size()); in Loop()
78 resultWriter_->write(resultWriter_, buffer_.data(), buffer_.size()); in Loop()
|
| /developtools/profiler/device/plugins/hidump_plugin/src/ |
| D | hidump_plugin.cpp | 127 buffer_.resize(dataProto.ByteSizeLong()); in Loop()
128 dataProto.SerializeToArray(buffer_.data(), buffer_.size()); in Loop()
129 resultWriter_->write(resultWriter_, buffer_.data(), buffer_.size()); in Loop()
134 buffer_.resize(dataProto.ByteSizeLong()); in Loop()
135 dataProto.SerializeToArray(buffer_.data(), buffer_.size()); in Loop()
136 resultWriter_->write(resultWriter_, buffer_.data(), buffer_.size()); in Loop()
|
| /developtools/profiler/device/plugins/cpu_plugin/src/ |
| D | cpu_data_plugin.cpp | 43 buffer_ = nullptr; in CpuDataPlugin()
56 if (buffer_ != nullptr) { in ~CpuDataPlugin()
57 free(buffer_); in ~CpuDataPlugin()
58 buffer_ = nullptr; in ~CpuDataPlugin()
71 buffer_ = malloc(READ_BUFFER_SIZE); in Start()
72 CHECK_NOTNULL(buffer_, RET_FAIL, "%s:malloc buffer_ failed!", __func__); in Start()
138 if (buffer_ != nullptr) { in Stop()
139 free(buffer_); in Stop()
140 buffer_ = nullptr; in Stop()
182 if (buffer_ == nullptr) { in ReadFile()
[all …]
|
| /developtools/profiler/hiebpf/test/unittest/ |
| D | ringbuffer_test.cpp | 67 ASSERT_TRUE(ringBuffer->buffer_ != nullptr);
81 ASSERT_TRUE(ringBuffer->buffer_ != nullptr);
87 ASSERT_TRUE(ringBuffer->buffer_ != nullptr);
101 ASSERT_TRUE(ringBuffer->buffer_ != nullptr);
109 ASSERT_TRUE(ringBuffer->buffer_ != nullptr);
123 ASSERT_TRUE(ringBuffer->buffer_ != nullptr);
131 ASSERT_TRUE(ringBuffer->buffer_ != nullptr);
145 ASSERT_TRUE(ringBuffer->buffer_ != nullptr);
153 ASSERT_TRUE(ringBuffer->buffer_ != nullptr);
192 ASSERT_TRUE(ringBuffer->buffer_ != nullptr);
[all …]
|
| /developtools/profiler/device/plugins/memory_plugin/src/ |
| D | memory_data_plugin.cpp | 33 : buffer_(new (std::nothrow) uint8_t[READ_BUFFER_SIZE]), meminfoFd_(-1), vmstatFd_(-1), err_(-1) in MemoryDataPlugin()
43 buffer_ = nullptr; in ~MemoryDataPlugin()
139 CHECK_NOTNULL(buffer_, RET_FAIL, "%s:buffer_ == null", __func__); in Start()
185 BufferSplitter totalbuffer((const char*)buffer_.get(), readsize); in WriteMeminfo()
244 BufferSplitter totalbuffer((const char*)buffer_.get(), readsize); in WriteVmstat()
426 WriteProcess(processinfo, (char*)buffer_.get(), readSize, pid); in WriteProcinfoByPidfds()
430 …processinfo->set_oom_score_adj(static_cast<int64_t>(strtol((char*)buffer_.get(), &end, DEC_BASE))); in WriteProcinfoByPidfds()
439 if ((buffer_.get() == nullptr) || (fd == -1)) { in ReadFile()
442 int readsize = pread(fd, buffer_.get(), READ_BUFFER_SIZE - 1, 0); in ReadFile()
570 if (buffer_.get() == nullptr) { in ReadProcPidFile()
[all …]
|
| /developtools/profiler/device/plugins/network_plugin/src/ |
| D | network_plugin.cpp | 28 : buffer_(new (std::nothrow) uint8_t[READ_BUFFER_SIZE]), fp_(nullptr, nullptr) in NetworkPlugin()
35 CHECK_NOTNULL(buffer_, -1, "%s:NetworkPlugin, buffer_ is null", __func__); in Start()
146 buffer_ = nullptr; in Stop()
211 …size_t rsize = static_cast<size_t>(fread(buffer_.get(), sizeof(char), READ_BUFFER_SIZE - 1, fp_.ge… in ReadTxRxBytes()
212 buffer_.get()[rsize] = '\0'; in ReadTxRxBytes()
215 BufferSplitter totalbuffer((const char*)buffer_.get(), rsize + 1); in ReadTxRxBytes()
279 …size_t rsize = static_cast<size_t>(fread(buffer_.get(), sizeof(char), READ_BUFFER_SIZE - 1, fp_.ge… in ReadSystemTxRxBytes()
280 buffer_.get()[rsize] = '\0'; in ReadSystemTxRxBytes()
283 BufferSplitter totalbuffer((const char*)buffer_.get(), rsize + 1); in ReadSystemTxRxBytes()
|
| /developtools/profiler/device/plugins/process_plugin/src/ |
| D | process_data_plugin.cpp | 36 : buffer_(new (std::nothrow) uint8_t[READ_BUFFER_SIZE]), err_(-1) in ProcessDataPlugin()
45 buffer_ = nullptr; in ~ProcessDataPlugin()
52 CHECK_NOTNULL(buffer_, RET_FAIL, "%s:buffer_ == null", __func__); in Start()
138 if (buffer_.get() == nullptr) { in ReadProcPidFile()
144 bytesRead = read(fd, buffer_.get(), READ_BUFFER_SIZE - 1); in ReadProcPidFile()
151 buffer_.get()[bytesRead] = '\0'; in ReadProcPidFile()
243 …processinfo->set_name(reinterpret_cast<char*>(buffer_.get()), strlen(reinterpret_cast<char*>(buffe… in WriteProcess()
253 if ((buffer_.get() == nullptr) || (ret == 0)) { in WriteProcessInfo()
257 WriteProcess(processinfo, (char*)buffer_.get(), ret, pid); in WriteProcessInfo()
|
| /developtools/smartperf_host/trace_streamer/src/parser/hiperf_parser/ |
| D | perf_data_parser.cpp | 38 buffer_ = std::make_unique<uint8_t[]>(size); in InitPerfDataAndLoad()
39 std::copy(dequeBuffer.begin(), dequeBuffer.begin() + size, buffer_.get()); in InitPerfDataAndLoad()
74 buffer_.reset(); in LoadPerfData()
78 if (bufferSize_ != (size_t)write(fd, buffer_.get(), bufferSize_)) { in LoadPerfData()
80 buffer_.reset(); in LoadPerfData()
86 buffer_.reset(); in LoadPerfData()
|
| /developtools/profiler/device/plugins/native_daemon/include/ |
| D | debug_logger.h | 279 return buffer_; in Stream()
285 DebugLogger::GetInstance()->Log(level_, HILOG_TAG, "%s\n", buffer_.str().c_str()); in ~LogMessage()
288 buffer_.str().c_str(), errno, strerror(errno)); in ~LogMessage()
296 std::ostringstream buffer_; variable
|
| /developtools/profiler/device/plugins/stream_plugin/include/ |
| D | stream_plugin.h | 42 std::vector<char> buffer_; variable
|
| /developtools/profiler/device/plugins/arkts_plugin/src/ |
| D | arkts_plugin.cpp | 152 buffer_.resize(data.ByteSizeLong()); in FlushData()
153 data.SerializeToArray(buffer_.data(), buffer_.size()); in FlushData()
154 resultWriter_->write(resultWriter_, buffer_.data(), buffer_.size()); in FlushData()
|
| /developtools/profiler/device/plugins/hidump_plugin/include/ |
| D | hidump_plugin.h | 55 std::vector<char> buffer_; variable
|
| /developtools/profiler/device/plugins/diskio_plugin/include/ |
| D | diskio_data_plugin.h | 62 void* buffer_;
|
| /developtools/profiler/device/plugins/ftrace_plugin/include/ |
| D | result_transporter.h | 63 std::vector<char> buffer_; variable
|
| /developtools/profiler/host/smartperf/trace_streamer/src/parser/hiperf_parser/ |
| D | perf_data_parser.cpp | 38 buffer_ = std::make_unique<uint8_t[]>(size); in InitPerfDataAndLoad()
39 std::copy(dequeBuffer.begin(), dequeBuffer.begin() + size, buffer_.get()); in InitPerfDataAndLoad()
77 if (bufferSize_ != write(fd, buffer_.get(), bufferSize_)) { in LoadPerfData()
83 buffer_.release(); in LoadPerfData()
|
| /developtools/profiler/device/plugins/arkts_plugin/include/ |
| D | arkts_plugin.h | 59 std::vector<char> buffer_; variable
|
| /developtools/profiler/device/plugins/network_plugin/include/ |
| D | network_plugin.h | 106 std::unique_ptr<uint8_t[]> buffer_; variable
|
| /developtools/profiler/device/plugins/process_plugin/include/ |
| D | process_data_plugin.h | 85 std::unique_ptr<uint8_t[]> buffer_; variable
|
| /developtools/smartperf_host/trace_streamer/src/parser/ebpf_parser/ |
| D | ebpf_data_reader.cpp | 36 buffer_ = std::make_unique<uint8_t[]>(size); in InitEbpfData()
37 std::copy(dequeBuffer.begin(), dequeBuffer.begin() + size, buffer_.get()); in InitEbpfData()
39 startAddr_ = buffer_.get(); in InitEbpfData()
|
| /developtools/profiler/host/smartperf/trace_streamer/src/parser/ebpf_parser/ |
| D | ebpf_data_reader.cpp | 35 buffer_ = std::make_unique<uint8_t[]>(size); in InitEbpfData()
36 std::copy(dequeBuffer.begin(), dequeBuffer.begin() + size, buffer_.get()); in InitEbpfData()
38 startAddr_ = buffer_.get(); in InitEbpfData()
|