Home
last modified time | relevance | path

Searched refs:bytes_read (Results 1 – 25 of 47) sorted by relevance

12

/system/update_engine/payload_consumer/
Dextent_reader.cc69 uint64_t bytes_read = 0; in Read() local
70 while (bytes_read < count) { in Read()
72 TEST_AND_RETURN_FALSE(bytes_read == count); in Read()
77 std::min(count - bytes_read, cur_extent_bytes_left); in Read()
82 bytes + bytes_read, in Read()
89 bytes_read += bytes_to_read; in Read()
Dverity_writer_android.cc88 ssize_t bytes_read = 0; in Compute() local
93 &bytes_read)); in Compute()
94 TEST_AND_RETURN_FALSE(bytes_read >= 0); in Compute()
95 TEST_AND_RETURN_FALSE(static_cast<size_t>(bytes_read) == in Compute()
111 ssize_t bytes_read = 0; in Compute() local
116 &bytes_read)); in Compute()
117 TEST_AND_RETURN_FALSE(bytes_read >= 0); in Compute()
118 TEST_AND_RETURN_FALSE(static_cast<size_t>(bytes_read) == in Compute()
365 ssize_t bytes_read = 0; in EncodeFEC() local
370 &bytes_read)); in EncodeFEC()
[all …]
Dmount_history.cc38 ssize_t bytes_read; in LogMountHistory() local
41 blockdevice_fd, block0_buffer.data(), kBlockSize, 0, &bytes_read)) { in LogMountHistory()
46 if (bytes_read != kBlockSize) { in LogMountHistory()
Dfilesystem_verifier_action.cc284 const auto bytes_read = fd->Read(buffer, read_size); in WriteVerityAndHashPartition() local
285 if (bytes_read < 0 || static_cast<size_t>(bytes_read) != read_size) { in WriteVerityAndHashPartition()
287 << read_size << " bytes, actual: " << bytes_read; in WriteVerityAndHashPartition()
297 UpdatePartitionProgress((start_offset + bytes_read) * 1.0f / partition_size_ * in WriteVerityAndHashPartition()
303 start_offset + bytes_read, in WriteVerityAndHashPartition()
330 const auto bytes_read = fd->Read(buffer, read_size); in HashPartition() local
331 if (bytes_read < 0 || static_cast<size_t>(bytes_read) != read_size) { in HashPartition()
333 << read_size << " bytes, actual: " << bytes_read; in HashPartition()
342 const auto progress = (start_offset + bytes_read) * 1.0f / partition_size_; in HashPartition()
357 start_offset + bytes_read, in HashPartition()
Dxor_extent_writer.cc85 ssize_t bytes_read = 0; in WriteExtent() local
91 &bytes_read)); in WriteExtent()
92 if (bytes_read != static_cast<ssize_t>(xor_block_data.size())) { in WriteExtent()
93 LOG(ERROR) << "bytes_read: " << bytes_read << ", expected to read " in WriteExtent()
Dvabc_partition_writer.cc324 ssize_t bytes_read = 0; in PerformSourceCopyOperation() local
329 &bytes_read)); in PerformSourceCopyOperation()
330 if (bytes_read <= 0 || static_cast<size_t>(bytes_read) != buffer.size()) { in PerformSourceCopyOperation()
331 LOG(ERROR) << "source_fd->Read failed: " << bytes_read; in PerformSourceCopyOperation()
Dpostinstall_runner_action.cc322 size_t bytes_read; in OnProgressFdReady() local
324 bytes_read = 0; in OnProgressFdReady()
327 utils::ReadAll(progress_fd_, buf, base::size(buf), &bytes_read, &eof); in OnProgressFdReady()
328 progress_buffer_.append(buf, bytes_read); in OnProgressFdReady()
345 } while (bytes_read); in OnProgressFdReady()
/system/update_engine/payload_generator/
Dblob_file_writer_unittest.cc45 ssize_t bytes_read; in TEST() local
47 blob_file.fd(), stored_blob.data(), kBlobSize, 0, &bytes_read)); in TEST()
48 EXPECT_EQ(bytes_read, kBlobSize); in TEST()
Dblock_mapping.cc50 ssize_t bytes_read = 0; in AddDiskBlock() local
51 if (!utils::PReadAll(fd, blob.data(), block_size_, byte_offset, &bytes_read)) in AddDiskBlock()
53 if (static_cast<size_t>(bytes_read) != block_size_) in AddDiskBlock()
122 ssize_t bytes_read = 0; in CompareData() local
123 if (!utils::PReadAll(fd, blob.data(), block_size, byte_offset, &bytes_read)) in CompareData()
125 if (static_cast<size_t>(bytes_read) != block_size) in CompareData()
Dcow_size_estimator.cc68 ssize_t bytes_read = 0; in CowDryRun() local
74 &bytes_read)) { in CowDryRun()
84 &bytes_read)) { in CowDryRun()
122 ssize_t bytes_read = 0; in CowDryRun() local
127 &bytes_read)) { in CowDryRun()
Dfull_update_generator.cc97 ssize_t bytes_read = -1; in ProcessChunk() local
99 fd_, buffer_in_.data(), buffer_in_.size(), offset_, &bytes_read)); in ProcessChunk()
100 TEST_AND_RETURN_FALSE(bytes_read == static_cast<ssize_t>(size_)); in ProcessChunk()
/system/core/fs_mgr/libsnapshot/libsnapshot_cow/
Dcow_decompress.cpp278 size_t bytes_read = 0; in Decompress() local
279 stream_->Read(output_buffer, output_size, &bytes_read); in Decompress()
280 if (bytes_read != output_size) { in Decompress()
282 << " actual: " << bytes_read; in Decompress()
290 size_t bytes_read = 0; in Decompress() local
291 stream_->Read(input_buffer.data(), input_buffer.size(), &bytes_read); in Decompress()
292 if (bytes_read != input_buffer.size()) { in Decompress()
294 << " actual: " << bytes_read; in Decompress()
/system/extras/tests/directiotest/
Ddirectiotest.c74 size_t bytes_read = 0; in do_read() local
79 ret = read(fd, (char *)buf + bytes_read, count - bytes_read); in do_read()
87 bytes_read += ret; in do_read()
88 } while (bytes_read < count); in do_read()
90 return bytes_read; in do_read()
/system/update_engine/common/
Dutils.cc125 size_t bytes_read = 0; in ReadAll() local
127 while (bytes_read < count) { in ReadAll()
128 ssize_t rc = HANDLE_EINTR(read(fd, c_buf + bytes_read, count - bytes_read)); in ReadAll()
134 *out_bytes_read = bytes_read; in ReadAll()
144 bytes_read += rc; in ReadAll()
147 *out_bytes_read = bytes_read; in ReadAll()
207 ssize_t bytes_read = 0; in PReadAll() local
208 while (bytes_read < static_cast<ssize_t>(count)) { in PReadAll()
210 pread(fd, c_buf + bytes_read, count - bytes_read, offset + bytes_read); in PReadAll()
215 bytes_read += rc; in PReadAll()
[all …]
Dfile_fetcher.cc142 void FileFetcher::OnReadDoneCallback(size_t bytes_read) { in OnReadDoneCallback() argument
144 if (bytes_read == 0) { in OnReadDoneCallback()
149 bytes_copied_ += bytes_read; in OnReadDoneCallback()
151 !delegate_->ReceivedBytes(this, buffer_.data(), bytes_read)) in OnReadDoneCallback()
Dsubprocess.cc121 size_t bytes_read; in OnStdoutReady() local
123 bytes_read = 0; in OnStdoutReady()
126 record->stdout_fd, buf, base::size(buf), &bytes_read, &eof); in OnStdoutReady()
127 record->stdout_str.append(buf, bytes_read); in OnStdoutReady()
134 } while (bytes_read); in OnStdoutReady()
/system/core/fastboot/device/
Dtcp_client.cpp85 ssize_t bytes_read = in Read() local
87 if (bytes_read == -1) { in Read()
91 message_bytes_left_ -= bytes_read; in Read()
92 total_read += bytes_read; in Read()
Dfastboot_device.cpp210 auto bytes_read = transport_->Read(command, FB_RESPONSE_SZ); in ExecuteCommands() local
211 if (bytes_read == -1) { in ExecuteCommands()
215 if (std::count_if(command, command + bytes_read, iscntrl) != 0) { in ExecuteCommands()
220 command[bytes_read] = '\0'; in ExecuteCommands()
/system/update_engine/aosp/
Dota_extractor.cc83 ssize_t bytes_read; in WriteVerity() local
85 utils::ReadAll(fd, buffer.data(), bytes_to_read, offset, &bytes_read)); in WriteVerity()
86 CHECK_EQ(bytes_read, bytes_to_read) in WriteVerity()
89 writer.Update(offset, buffer.data(), bytes_read); in WriteVerity()
90 offset += bytes_read; in WriteVerity()
148 ssize_t bytes_read = 0; in ExtractImagesFromOTA() local
150 payload_fd, blob.data(), blob.size(), op_data_offset, &bytes_read)); in ExtractImagesFromOTA()
/system/nvram/hal/
Dfake_nvram.cpp117 ssize_t bytes_read = in ProcessCommand() local
119 if (bytes_read == 0) { in ProcessCommand()
123 if (bytes_read < 0) { in ProcessCommand()
129 if (!nvram::Decode(command_buffer, bytes_read, &request)) { in ProcessCommand()
/system/core/fastboot/
Dtcp.cpp147 ssize_t bytes_read = socket_->ReceiveAll(data, length, 0); in Read() local
148 if (bytes_read == -1) { in Read()
151 message_bytes_left_ -= bytes_read; in Read()
153 return bytes_read; in Read()
/system/core/fs_mgr/libsnapshot/
Dsnapshot_writer_test.cpp57 const auto bytes_read = cow_reader->Read(read_back.data(), read_back.size()); in TEST_F() local
58 ASSERT_EQ((size_t)(bytes_read), BLOCK_SIZE); in TEST_F()
/system/update_engine/liburing_cpp/tests/
DBasicTests.cpp110 const auto bytes_read = pread(fd, buffer.data(), buffer.size(), 0); in TEST_F() local
112 ASSERT_EQ(bytes_read, buffer.size()); in TEST_F()
125 const auto bytes_read = pread(fd, buffer.data(), buffer.size(), 0); in TEST_F() local
127 ASSERT_EQ(bytes_read, buffer.size()); in TEST_F()
/system/core/trusty/utils/acvp/
Dtrusty_modulewrapper.cpp155 int bytes_read = read(tipc_fd_, &resp, sizeof(struct acvp_resp)); in ForwardResponse() local
156 if (bytes_read < 0) { in ForwardResponse()
160 if (bytes_read != sizeof(struct acvp_resp)) { in ForwardResponse()
/system/core/fs_mgr/libsnapshot/snapuserd/user-space-merge/
Dsnapuserd_verify.cpp117 uint64_t bytes_read = 0; in VerifyBlocks() local
130 bytes_read += to_read; in VerifyBlocks()
137 SNAP_LOG(DEBUG) << "Verification success with bytes-read: " << bytes_read in VerifyBlocks()

12