Home
last modified time | relevance | path

Searched refs:buffer_ (Results 1 – 25 of 28) sorted by relevance

12

/system/connectivity/wifilogd/tests/
Dmessage_buffer_unittest.cpp37 MessageBufferTest() : buffer_{kBufferSizeBytes} {} in MessageBufferTest()
48 EXPECT_TRUE(buffer_.Append(message.data(), message.size())); in FillBufferWithMultipleMessages()
50 EXPECT_EQ(0U, buffer_.GetFreeSize()); in FillBufferWithMultipleMessages()
57 std::tie(start, len) = buffer_.ConsumeNextMessage(); in GetNextMessageAsByteVector()
61 MessageBuffer buffer_; member in android::wifilogd::__anon980c6a940111::MessageBufferTest
67 EXPECT_TRUE(buffer_.Append(kSmallestMessage.data(), kSmallestMessage.size())); in TEST_F()
71 EXPECT_TRUE(buffer_.Append(kLargestMessage.data(), kLargestMessage.size())); in TEST_F()
75 ASSERT_TRUE(buffer_.Append(kLargestMessage.data(), kLargestMessage.size())); in TEST_F()
76 ASSERT_FALSE(buffer_.CanFitNow(1)); in TEST_F()
78 buffer_.Clear(); in TEST_F()
[all …]
Dbyte_buffer_unittest.cpp38 ByteBuffer<kBufferSizeBytes> buffer_; member in android::wifilogd::__anon97c88b830111::ByteBufferTest
44 buffer_.AppendOrDie(kSmallestMessage.data(), kSmallestMessage.size()); in TEST_F()
48 buffer_.AppendOrDie(kLargestMessage.data(), kLargestMessage.size()); in TEST_F()
54 buffer_.AppendOrDie(message1.data(), message1.size()); in TEST_F()
55 buffer_.AppendOrDie(message2.data(), message2.size()); in TEST_F()
58 EXPECT_EQ(0, std::memcmp(buffer_.data(), expected.data(), expected.size())); in TEST_F()
63 buffer_.AppendOrDie(message1.data(), message1.size()); in TEST_F()
66 ASSERT_NE(buffer_.size(), copy.size()); in TEST_F()
68 copy = buffer_; in TEST_F()
69 ASSERT_EQ(buffer_.size(), copy.size()); in TEST_F()
[all …]
/system/extras/memory_replay/
DLineBuffer.cpp23 LineBuffer::LineBuffer(int fd, char* buffer, size_t buffer_len) : fd_(fd), buffer_(buffer), buffer_… in LineBuffer()
29 char* newline = reinterpret_cast<char*>(memchr(buffer_ + start_, '\n', bytes_)); in GetLine()
32 *line = buffer_ + start_; in GetLine()
33 start_ = newline - buffer_ + 1; in GetLine()
41 memmove(buffer_, buffer_ + start_, bytes_); in GetLine()
44 ssize_t bytes = TEMP_FAILURE_RETRY(read(fd_, buffer_ + bytes_, buffer_len_ - bytes_ - 1)); in GetLine()
48 buffer_[bytes_] = '\0'; in GetLine()
49 *line = buffer_ + start_; in GetLine()
DLineBuffer.h30 char* buffer_ = nullptr; variable
/system/core/libmemunreachable/
DLineBuffer.cpp29 : fd_(fd), buffer_(buffer), buffer_len_(buffer_len) {} in LineBuffer()
34 char* newline = reinterpret_cast<char*>(memchr(buffer_ + start_, '\n', bytes_)); in GetLine()
37 *line = buffer_ + start_; in GetLine()
38 start_ = newline - buffer_ + 1; in GetLine()
46 memmove(buffer_, buffer_ + start_, bytes_); in GetLine()
49 ssize_t bytes = TEMP_FAILURE_RETRY(read(fd_, buffer_ + bytes_, buffer_len_ - bytes_ - 1)); in GetLine()
53 buffer_[bytes_] = '\0'; in GetLine()
54 *line = buffer_ + start_; in GetLine()
DLineBuffer.h32 char* buffer_ = nullptr; variable
/system/keymaster/
Dserializable.cpp76 memcpy(new_buffer, buffer_.get() + read_position_, available_read()); in reserve()
77 memset_s(buffer_.get(), 0, buffer_size_); in reserve()
78 buffer_.reset(new_buffer); in reserve()
88 buffer_.reset(new (std::nothrow) uint8_t[size]); in Reinitialize()
89 if (!buffer_.get()) in Reinitialize()
101 buffer_.reset(new (std::nothrow) uint8_t[data_len]); in Reinitialize()
102 if (!buffer_.get()) in Reinitialize()
105 memcpy(buffer_.get(), data, data_len); in Reinitialize()
125 memcpy(buffer_.get() + write_position_, src, write_length); in write()
133 memcpy(dest, buffer_.get() + read_position_, read_length); in read()
[all …]
/system/core/adb/
Dshell_service_protocol.cpp26 buffer_[0] = kIdInvalid; in ShellProtocol()
35 if (!ReadFdExactly(fd_, buffer_, kHeaderSize)) { in Read()
40 memcpy(&packet_length, &buffer_[1], sizeof(packet_length)); in Read()
57 buffer_[0] = id; in Write()
59 memcpy(&buffer_[1], &typed_length, sizeof(typed_length)); in Write()
61 return WriteFdExactly(fd_, buffer_, kHeaderSize + length); in Write()
Dshell_service.h76 const char* data() const { return buffer_ + kHeaderSize; } in data()
77 char* data() { return buffer_ + kHeaderSize; } in data()
92 int id() const { return buffer_[0]; } in id()
116 char buffer_[kBufferSize]; variable
121 char* buffer_end_ = buffer_ + sizeof(buffer_);
/system/core/libappfuse/
DFuseBridgeLoop.cc134 switch (buffer_.response.ReadOrAgain(proxy_fd_)) { in ReadFromProxy()
143 if (!buffer_.response.Write(device_fd_)) { in ReadFromProxy()
144 LogResponseError("Failed to write a reply from proxy to device", buffer_.response); in ReadFromProxy()
148 auto it = opcode_map_.find(buffer_.response.header.unique); in ReadFromProxy()
152 if (buffer_.response.header.error == fuse::kFuseSuccess) { in ReadFromProxy()
177 if (!buffer_.request.Read(device_fd_)) { in ReadFromDevice()
181 const uint32_t opcode = buffer_.request.header.opcode; in ReadFromDevice()
182 const uint64_t unique = buffer_.request.header.unique; in ReadFromDevice()
200 opcode_map_.emplace(buffer_.request.header.unique, opcode); in ReadFromDevice()
205 buffer_.HandleInit(); in ReadFromDevice()
[all …]
/system/core/debuggerd/libdebuggerd/test/
DBacktraceMock.h61 size_t bytes_available = buffer_.size() - offset; in Read()
76 memcpy(buffer, buffer_.data() + offset, bytes); in Read()
84 buffer_.resize(bytes); in SetReadData()
85 memcpy(buffer_.data(), buffer, bytes); in SetReadData()
92 if (bytes > buffer_.size()) { in SetPartialReadAmount()
100 std::vector<uint8_t> buffer_;
/system/core/libziparchive/
Dzip_writer.cc91 buffer_(kBufSize) { in ZipWriter()
107 buffer_(std::move(writer.buffer_)) { in ZipWriter()
119 buffer_ = std::move(writer.buffer_); in operator =()
314 z_stream_->next_out = buffer_.data(); in PrepareDeflate()
315 z_stream_->avail_out = buffer_.size(); in PrepareDeflate()
371 size_t write_bytes = z_stream_->next_out - buffer_.data(); in CompressBytes()
372 if (fwrite(buffer_.data(), 1, write_bytes, file_) != write_bytes) { in CompressBytes()
379 z_stream_->next_out = buffer_.data(); in CompressBytes()
380 z_stream_->avail_out = buffer_.size(); in CompressBytes()
397 size_t write_bytes = z_stream_->next_out - buffer_.data(); in FlushCompressedBytes()
[all …]
/system/update_engine/common/
Dfile_fetcher.cc106 buffer_.resize(kReadBufferSize); in ScheduleRead()
107 size_t bytes_to_read = buffer_.size(); in ScheduleRead()
119 buffer_.data(), in ScheduleRead()
142 delegate_->ReceivedBytes(this, buffer_.data(), bytes_read); in OnReadDoneCallback()
180 buffer_ = brillo::Blob(); in CleanUp()
Dfile_fetcher.h112 brillo::Blob buffer_; variable
/system/connectivity/wifilogd/
Dmessage_buffer.h40 explicit ScopedRewinder(NONNULL MessageBuffer* buffer) : buffer_(buffer) {} in ScopedRewinder()
41 ~ScopedRewinder() { buffer_->Rewind(); } in ~ScopedRewinder()
44 MessageBuffer* const buffer_;
/system/update_engine/payload_consumer/
Dfilesystem_verifier_action.cc80 buffer_.clear(); in Cleanup()
125 buffer_.resize(kReadFileBufferSize); in StartPartitionHashing()
134 size_t bytes_to_read = std::min(static_cast<int64_t>(buffer_.size()), in ScheduleRead()
142 buffer_.data(), in ScheduleRead()
162 if (!hasher_->Update(buffer_.data(), bytes_read)) { in OnReadDoneCallback()
257 buffer_.clear(); in FinishPartitionHashing()
Ddelta_performer.cc271 size_t read_len = min(count, max - buffer_.size()); in CopyDataToBuffer()
274 buffer_.insert(buffer_.end(), bytes_start, bytes_end); in CopyDataToBuffer()
303 if (!buffer_.empty()) { in Close()
304 LOG(INFO) << "Discarding " << buffer_.size() << " unused downloaded bytes"; in Close()
605 MetadataParseResult result = ParsePayloadMetadata(buffer_, error); in Write()
773 if (buffer_.size() < manifest_.signatures_size()) in Write()
897 buffer_offset_ + buffer_.size()); in CanPerformInstallOperation()
909 TEST_AND_RETURN_FALSE(buffer_.size() >= operation.data_length()); in PerformReplaceOperation()
937 TEST_AND_RETURN_FALSE(writer->Write(buffer_.data(), operation.data_length())); in PerformReplaceOperation()
941 DiscardBuffer(true, buffer_.size()); in PerformReplaceOperation()
[all …]
Dfilesystem_verifier_action.h100 brillo::Blob buffer_; variable
/system/keymaster/include/keymaster/
Dserializable.h204 Buffer() : buffer_(NULL), buffer_size_(0), read_position_(0), write_position_(0) {} in Buffer()
205 explicit Buffer(size_t size) : buffer_(NULL) { Reinitialize(size); } in Buffer()
206 Buffer(const void* buf, size_t size) : buffer_(NULL) { Reinitialize(buf, size); } in Buffer()
230 const uint8_t* peek_read() const { return buffer_.get() + read_position_; } in peek_read()
238 uint8_t* peek_write() { return buffer_.get() + write_position_; } in peek_write()
256 UniquePtr<uint8_t[]> buffer_; variable
/system/core/libunwindstack/include/unwindstack/
DMaps.h80 BufferMaps(const char* buffer) : buffer_(buffer) {} in BufferMaps()
86 const char* buffer_;
/system/tools/aidl/
Daidl_language.cpp255 yy_delete_buffer(buffer_, scanner_); in ~Parser()
271 yy_delete_buffer(buffer_, scanner_); in ParseFile()
284 buffer_ = yy_scan_buffer(&(*raw_buffer_)[0], raw_buffer_->length(), scanner_); in ParseFile()
/system/core/base/
Dlogging.cpp375 return buffer_; in GetBuffer()
379 return buffer_.str(); in ToString()
383 std::ostringstream buffer_; member in android::base::LogMessageData
/system/extras/memtrack/
Dmemtrack.h105 char buffer_[kBufferLen]; variable
Dmemtrack.cpp140 FileData smaps(proc_file_, buffer_, sizeof(buffer_)); in getInformation()
/system/core/libziparchive/include/ziparchive/
Dzip_writer.h184 std::vector<uint8_t> buffer_; variable

12