Home
last modified time | relevance | path

Searched refs:buffer_ (Results 1 – 25 of 37) 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::__anon279f30200111::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::__anon725a5c8f0111::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/keymaster/android_keymaster/
Dserializable.cpp84 memcpy(new_buffer, buffer_.get() + read_position_, available_read()); in reserve()
85 memset_s(buffer_.get(), 0, buffer_size_); in reserve()
86 buffer_.reset(new_buffer); in reserve()
96 buffer_.reset(new (std::nothrow) uint8_t[size]); in Reinitialize()
97 if (!buffer_.get()) in Reinitialize()
109 buffer_.reset(new (std::nothrow) uint8_t[data_len]); in Reinitialize()
110 if (!buffer_.get()) in Reinitialize()
113 memcpy(buffer_.get(), data, data_len); in Reinitialize()
133 memcpy(buffer_.get() + write_position_, src, write_length); in write()
141 memcpy(dest, buffer_.get() + read_position_, read_length); in read()
[all …]
/system/teeui/libteeui_jni/
Dlibteeui_jni.cpp74 element_type* buffer_; member in JArray
77 JArray(JNIEnv* env, array_type jarray) : env_(env), jarray_(jarray), buffer_(nullptr) { in JArray()
79 buffer_ = (env_->*JTypeTraits<T>::getArrayElements)(jarray, nullptr); in JArray()
82 JArray(JArray&& rhs) : env_(rhs.env_), jarray_(rhs.jarray_), buffer_(rhs.buffer_) { in JArray()
84 rhs.buffer_ = nullptr; in JArray()
93 buffer_ = rhs.buffer_; in operator =()
95 rhs.buffer_ = nullptr; in operator =()
100 operator bool() const { return buffer_ != nullptr; } in operator bool()
101 const jint& operator[](size_t offset) const { return buffer_[offset]; } in operator []()
102 element_type& operator[](size_t offset) { return buffer_[offset]; } in operator []()
[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_protocol.h68 const char* data() const { return buffer_ + kHeaderSize; } in data()
69 char* data() { return buffer_ + kHeaderSize; } in data()
84 int id() const { return buffer_[0]; } in id()
108 char buffer_[kBufferSize]; variable
113 char* buffer_end_ = buffer_ + sizeof(buffer_);
/system/core/libappfuse/
DFuseBridgeLoop.cc135 switch (buffer_.response.ReadOrAgain(proxy_fd_)) { in ReadFromProxy()
144 if (!buffer_.response.Write(device_fd_)) { in ReadFromProxy()
145 LogResponseError("Failed to write a reply from proxy to device", buffer_.response); in ReadFromProxy()
149 auto it = opcode_map_.find(buffer_.response.header.unique); in ReadFromProxy()
153 if (buffer_.response.header.error == fuse::kFuseSuccess) { in ReadFromProxy()
178 if (!buffer_.request.Read(device_fd_)) { in ReadFromDevice()
182 const uint32_t opcode = buffer_.request.header.opcode; in ReadFromDevice()
183 const uint64_t unique = buffer_.request.header.unique; in ReadFromDevice()
201 opcode_map_.emplace(buffer_.request.header.unique, opcode); in ReadFromDevice()
206 buffer_.HandleInit(); in ReadFromDevice()
[all …]
/system/bt/gd/os/
Dqueue.h111 buffer_.push(std::move(t)); in Enqueue()
112 if (buffer_.size() == 1) { in Enqueue()
119 if (!buffer_.empty()) { in Clear()
122 std::swap(buffer_, empty); in Clear()
129 std::unique_ptr<T> enqueued_t = std::move(buffer_.front()); in enqueue_callback()
130 buffer_.pop(); in enqueue_callback()
131 if (buffer_.empty()) { in enqueue_callback()
139 std::queue<std::unique_ptr<T>> buffer_; variable
Dqueue_benchmark.cc70 buffer_.push(std::move(data)); in push()
72 if (buffer_.size() == 1) { in push()
79 std::unique_ptr<std::string> data = std::make_unique<std::string>(std::move(buffer_.front())); in EnqueueCallbackForTest()
80 buffer_.pop(); in EnqueueCallbackForTest()
82 if (buffer_.empty()) { in EnqueueCallbackForTest()
94 std::queue<std::string> buffer_; member in bluetooth::os::TestEnqueueEnd
119 buffer_.push(data); in DequeueCallbackForTest()
128 std::queue<std::string> buffer_; member in bluetooth::os::TestDequeueEnd
/system/core/libunwindstack/tests/
DMemoryOfflineBufferTest.cpp30 memory_.reset(new MemoryOfflineBuffer(buffer_.data(), kStart, kEnd)); in SetUp()
34 buffer_.resize(kLength); in SetUpTestSuite()
36 buffer_[i] = i % 189; in SetUpTestSuite()
45 static std::vector<uint8_t> buffer_; member in unwindstack::MemoryOfflineBufferTest
48 std::vector<uint8_t> MemoryOfflineBufferTest::buffer_; member in unwindstack::MemoryOfflineBufferTest
88 memory_->Reset(&buffer_[10], 0x12000, 0x13000); in TEST_F()
/system/core/libziparchive/
Dzip_writer.cc93 buffer_(kBufSize) { in ZipWriter()
109 buffer_(std::move(writer.buffer_)) { in ZipWriter()
121 buffer_ = std::move(writer.buffer_); in operator =()
340 z_stream_->next_out = buffer_.data(); in PrepareDeflate()
341 DCHECK_EQ(buffer_.size(), kBufSize); in PrepareDeflate()
342 z_stream_->avail_out = static_cast<uint32_t>(buffer_.size()); in PrepareDeflate()
404 size_t write_bytes = z_stream_->next_out - buffer_.data(); in CompressBytes()
405 if (fwrite(buffer_.data(), 1, write_bytes, file_) != write_bytes) { in CompressBytes()
412 z_stream_->next_out = buffer_.data(); in CompressBytes()
413 DCHECK_EQ(buffer_.size(), kBufSize); in CompressBytes()
[all …]
/system/bt/gd/os/linux_generic/
Dqueue_unittest.cc90 std::unique_ptr<std::string> data = std::move(buffer_.front()); in EnqueueCallbackForTest()
91 buffer_.pop(); in EnqueueCallbackForTest()
93 if (buffer_.empty()) { in EnqueueCallbackForTest()
97 auto pair = promise_map_->find(buffer_.size()); in EnqueueCallbackForTest()
109 std::queue<std::unique_ptr<std::string>> buffer_; member in bluetooth::os::__anon2da05ee10111::TestEnqueueEnd
156 buffer_.push(std::move(data)); in DequeueCallbackForTest()
158 if (buffer_.size() == capacity_) { in DequeueCallbackForTest()
162 auto pair = promise_map_->find(buffer_.size()); in DequeueCallbackForTest()
173 std::queue<std::unique_ptr<std::string>> buffer_; member in bluetooth::os::__anon2da05ee10111::TestDequeueEnd
208 test_enqueue_end.buffer_.push(std::move(data)); in TEST_F()
[all …]
/system/update_engine/common/
Dfile_fetcher.cc115 buffer_.resize(kReadBufferSize); in ScheduleRead()
116 size_t bytes_to_read = buffer_.size(); in ScheduleRead()
128 buffer_.data(), in ScheduleRead()
151 !delegate_->ReceivedBytes(this, buffer_.data(), bytes_read)) in OnReadDoneCallback()
190 buffer_ = brillo::Blob(); in CleanUp()
/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.cc73 buffer_.clear(); in Cleanup()
133 buffer_.resize(kReadFileBufferSize); in StartPartitionHashing()
164 std::min(static_cast<uint64_t>(buffer_.size()), read_end - offset_); in ScheduleRead()
171 buffer_.data(), in ScheduleRead()
199 if (!hasher_->Update(buffer_.data(), bytes_read)) { in OnReadDoneCallback()
207 if (!verity_writer_->Update(offset_, buffer_.data(), bytes_read)) { in OnReadDoneCallback()
298 buffer_.clear(); in FinishPartitionHashing()
Ddelta_performer.cc279 size_t read_len = min(count, max - buffer_.size()); in CopyDataToBuffer()
282 buffer_.reserve(max); in CopyDataToBuffer()
283 buffer_.insert(buffer_.end(), bytes_start, bytes_end); in CopyDataToBuffer()
313 if (!buffer_.empty()) { in Close()
314 LOG(INFO) << "Discarding " << buffer_.size() << " unused downloaded bytes"; in Close()
596 MetadataParseResult result = ParsePayloadMetadata(buffer_, error); in Write()
782 if (buffer_.size() < manifest_.signatures_size()) in Write()
1017 buffer_offset_ + buffer_.size()); in CanPerformInstallOperation()
1029 TEST_AND_RETURN_FALSE(buffer_.size() >= operation.data_length()); in PerformReplaceOperation()
1050 TEST_AND_RETURN_FALSE(writer->Write(buffer_.data(), operation.data_length())); in PerformReplaceOperation()
[all …]
/system/core/adb/client/
Dincremental_server.cpp200 buffer_.reserve(kReadBufferSize); in IncrementalServer()
234 void erase_buffer_head(int count) { buffer_.erase(buffer_.begin(), buffer_.begin() + count); } in erase_buffer_head()
255 std::vector<char> buffer_; member in incremental::IncrementalServer
275 int bsize = buffer_.size(); in SkipToRequest()
277 uint32_t magic = be32toh(*(uint32_t*)(buffer_.data() + bcur)); in SkipToRequest()
286 (void)WriteFdExactly(output_fd_, buffer_.data(), bcur); in SkipToRequest()
290 if (magic_found && buffer_.size() >= *size + sizeof(INCR)) { in SkipToRequest()
292 memcpy(buffer, buffer_.data() + sizeof(INCR), *size); in SkipToRequest()
302 (void)WriteFdExactly(output_fd_, buffer_.data(), buffer_.size()); in SkipToRequest()
318 bsize = buffer_.size(); in SkipToRequest()
[all …]
/system/keymaster/include/keymaster/
Dserializable.h207 Buffer() : buffer_(nullptr), buffer_size_(0), read_position_(0), write_position_(0) {} in Buffer()
208 explicit Buffer(size_t size) : buffer_(nullptr) { Reinitialize(size); } in Buffer()
209 Buffer(const void* buf, size_t size) : buffer_(nullptr) { Reinitialize(buf, size); } in Buffer()
233 const uint8_t* peek_read() const { return buffer_.get() + read_position_; } in peek_read()
241 uint8_t* peek_write() { return buffer_.get() + write_position_; } in peek_write()
259 UniquePtr<uint8_t[]> buffer_; variable
/system/core/adb/fastdeploy/deploypatchgenerator/
Dapk_archive.cpp46 buffer_.resize(length); in FileRegion()
47 if (auto err = adb_pread(fd.get(), buffer_.data(), length, offset); size_t(err) != length) { in FileRegion()
50 buffer_.clear(); in FileRegion()
55 const char* data() const { return mapped_ ? mapped_->data() : buffer_.data(); } in data()
56 size_t size() const { return mapped_ ? mapped_->size() : buffer_.size(); } in size()
63 std::string buffer_; member
/system/extras/simpleperf/
DRecordReadThread.cpp36 : read_head_(0), write_head_(0), buffer_size_(buffer_size), buffer_(new char[buffer_size]) { in RecordBuffer()
66 memset(buffer_.get() + write_head, 0, sizeof(perf_event_header)); in AllocWriteSpace()
71 return buffer_.get() + write_head; in AllocWriteSpace()
89 (memcpy(&header, buffer_.get() + read_head, sizeof(header)) && header.size == 0)) { in GetCurrentRecord()
93 memcpy(&header, buffer_.get(), sizeof(header)); in GetCurrentRecord()
96 memcpy(&header, buffer_.get() + read_head, sizeof(header)); in GetCurrentRecord()
99 return buffer_.get() + read_head; in GetCurrentRecord()
173 buffer_ = event_fd_->GetMappedBuffer(buffer_size); in KernelRecordReader()
190 memcpy(dest, buffer_ + pos, copy_size); in ReadRecord()
192 memcpy(static_cast<char*>(dest) + copy_size, buffer_, size - copy_size); in ReadRecord()
DRecordReadThread.h63 std::unique_ptr<char> buffer_; variable
116 char* buffer_; variable
/system/teeui/libteeui/example/
Dteeui.cpp67 uint32_t* buffer_; member
78 auto acc = buffer_[pos]; in drawPixel()
79 buffer_[pos] = alfaCombineChannel(0, alfa, color, acc) | in drawPixel()
173 fb.buffer_ = buffer; in renderUIIntoBuffer()
/system/core/libunwindstack/include/unwindstack/
DMaps.h114 BufferMaps(const char* buffer) : buffer_(buffer) {} in BufferMaps()
120 const char* buffer_;
/system/core/debuggerd/libdebuggerd/test/
Ddump_memory_test.cpp115 size_t bytes_available = buffer_.size() - offset; in Read()
126 memcpy(buffer, buffer_.data() + offset, bytes); in Read()
134 buffer_.resize(bytes); in SetReadData()
135 memcpy(buffer_.data(), buffer, bytes); in SetReadData()
141 if (bytes > buffer_.size()) { in SetPartialReadAmount()
149 std::vector<uint8_t> buffer_; member in MemoryMock
/system/incremental_delivery/incfs/include/
Dincfs.h147 : buffer_(std::move(buffer)), rawFilledRanges_(ranges) {} in FilledRanges()
160 return std::move(buffer_); in extractInternalBufferAndClear()
163 constexpr const RangeBuffer& internalBuffer() const { return buffer_; } in internalBuffer()
167 RangeBuffer buffer_;

12