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 …]
Dfilesystem_verifier_action.cc274 const auto bytes_read = fd->Read(buffer, read_size); in WriteVerityAndHashPartition() local
275 if (bytes_read < 0 || static_cast<size_t>(bytes_read) != read_size) { in WriteVerityAndHashPartition()
277 << read_size << " bytes, actual: " << bytes_read; in WriteVerityAndHashPartition()
287 UpdatePartitionProgress((start_offset + bytes_read) * 1.0f / partition_size_ * in WriteVerityAndHashPartition()
293 start_offset + bytes_read, in WriteVerityAndHashPartition()
320 const auto bytes_read = fd->Read(buffer, read_size); in HashPartition() local
321 if (bytes_read < 0 || static_cast<size_t>(bytes_read) != read_size) { in HashPartition()
323 << read_size << " bytes, actual: " << bytes_read; in HashPartition()
332 const auto progress = (start_offset + bytes_read) * 1.0f / partition_size_; in HashPartition()
347 start_offset + bytes_read, in HashPartition()
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()
Dxor_extent_writer.cc34 ssize_t bytes_read = 0; in WriteXorCowOp() local
39 &bytes_read)); in WriteXorCowOp()
40 if (bytes_read != static_cast<ssize_t>(xor_block_data.size())) { in WriteXorCowOp()
41 LOG(ERROR) << "bytes_read: " << bytes_read << ", expected to read " in WriteXorCowOp()
Dvabc_partition_writer.cc155 ssize_t bytes_read = 0; in ProcessSourceCopyOperation() local
160 &bytes_read)); in ProcessSourceCopyOperation()
161 if (bytes_read <= 0 || static_cast<size_t>(bytes_read) != buffer.size()) { in ProcessSourceCopyOperation()
162 LOG(ERROR) << "source_fd->Read failed: " << bytes_read in ProcessSourceCopyOperation()
Dpostinstall_runner_action.cc331 size_t bytes_read; in OnProgressFdReady() local
333 bytes_read = 0; in OnProgressFdReady()
336 utils::ReadAll(progress_fd_, buf, std::size(buf), &bytes_read, &eof); in OnProgressFdReady()
337 progress_buffer_.append(buf, bytes_read); in OnProgressFdReady()
354 } while (bytes_read); in OnProgressFdReady()
/system/update_engine/payload_generator/
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()
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()
Dcow_size_estimator.cc92 ssize_t bytes_read = 0; in CowDryRun() local
98 &bytes_read)) { in CowDryRun()
121 ssize_t bytes_read = 0; in CowDryRun() local
126 &bytes_read)) { in CowDryRun()
171 ssize_t bytes_read = 0; in CowDryRun() local
176 &bytes_read)) { in CowDryRun()
Dfull_update_generator.cc93 ssize_t bytes_read = -1; in ProcessChunk() local
95 fd_, buffer_in_.data(), buffer_in_.size(), offset_, &bytes_read)); in ProcessChunk()
96 TEST_AND_RETURN_FALSE(bytes_read == static_cast<ssize_t>(size_)); in ProcessChunk()
/system/apex/apexd/
Dapex_sha.cpp47 int bytes_read = apex.gcount(); in CalculateSha512() local
48 SHA512_Update(&ctx, buf, bytes_read); in CalculateSha512()
74 int bytes_read = apex.gcount(); in CalculateSha256() local
75 SHA256_Update(&ctx, buf, bytes_read); in CalculateSha256()
/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/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.cpp211 auto bytes_read = transport_->Read(command, FB_RESPONSE_SZ); in ExecuteCommands() local
212 if (bytes_read == -1) { in ExecuteCommands()
216 if (std::count_if(command, command + bytes_read, iscntrl) != 0) { in ExecuteCommands()
221 command[bytes_read] = '\0'; in ExecuteCommands()
/system/update_engine/common/
Dutils.cc126 size_t bytes_read = 0; in ReadAll() local
128 while (bytes_read < count) { in ReadAll()
129 ssize_t rc = HANDLE_EINTR(read(fd, c_buf + bytes_read, count - bytes_read)); in ReadAll()
135 *out_bytes_read = bytes_read; in ReadAll()
145 bytes_read += rc; in ReadAll()
148 *out_bytes_read = bytes_read; in ReadAll()
208 ssize_t bytes_read = 0; in PReadAll() local
209 while (bytes_read < static_cast<ssize_t>(count)) { in PReadAll()
211 pread(fd, c_buf + bytes_read, count - bytes_read, offset + bytes_read); in PReadAll()
216 bytes_read += rc; in PReadAll()
[all …]
Dfile_fetcher.cc139 void FileFetcher::OnReadDoneCallback(size_t bytes_read) { in OnReadDoneCallback() argument
141 if (bytes_read == 0) { in OnReadDoneCallback()
146 bytes_copied_ += bytes_read; in OnReadDoneCallback()
148 !delegate_->ReceivedBytes(this, buffer_.data(), bytes_read)) in OnReadDoneCallback()
Dsubprocess.cc124 size_t bytes_read; in OnStdoutReady() local
126 bytes_read = 0; in OnStdoutReady()
129 record->stdout_fd, buf, std::size(buf), &bytes_read, &eof); in OnStdoutReady()
130 record->stdout_str.append(buf, bytes_read); in OnStdoutReady()
137 } while (bytes_read); in OnStdoutReady()
/system/update_engine/aosp/
Dota_extractor.cc85 ssize_t bytes_read; in WriteVerity() local
87 utils::ReadAll(fd, buffer.data(), bytes_to_read, offset, &bytes_read)); in WriteVerity()
88 CHECK_EQ(bytes_read, bytes_to_read) in WriteVerity()
91 writer.Update(offset, buffer.data(), bytes_read); in WriteVerity()
92 offset += bytes_read; in WriteVerity()
143 ssize_t bytes_read = 0; in ExtractImageFromPartition() local
145 payload_fd, blob.data(), blob.size(), op_data_offset, &bytes_read)); in ExtractImageFromPartition()
/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/media/audio_route/
Daudio_route.c564 int bytes_read = -1; in mixer_get_bytes_from_file() local
579 bytes_read = fread(buf, 1, max_bytes, file); in mixer_get_bytes_from_file()
580 if (bytes_read < 0) { in mixer_get_bytes_from_file()
581 ALOGE("failed to read data from file, rc: %d", bytes_read); in mixer_get_bytes_from_file()
585 values = calloc(bytes_read, sizeof(long)); in mixer_get_bytes_from_file()
588 bytes_read = -1; in mixer_get_bytes_from_file()
592 for (i = 0; i < bytes_read; i++) { in mixer_get_bytes_from_file()
600 return bytes_read; in mixer_get_bytes_from_file()
684 int bytes_read = mixer_get_bytes_from_file(&value_array, attr_bin, num_values); in start_tag() local
685 if (bytes_read <= 0) { in start_tag()
[all …]
/system/core/init/
Dsigchld_handler.cpp143 ssize_t bytes_read = TEMP_FAILURE_RETRY(read(signal_fd, &siginfo, sizeof(siginfo))); in HandleSignal() local
144 if (bytes_read != sizeof(siginfo)) { in HandleSignal()
145 LOG(WARNING) << "Unexpected: " << __func__ << " read " << bytes_read << " bytes instead of " in HandleSignal()
/system/core/trusty/utils/acvp/
Dtrusty_modulewrapper.cpp151 int bytes_read = read(tipc_fd_, &resp, sizeof(struct acvp_resp)); in ForwardResponse() local
152 if (bytes_read < 0) { in ForwardResponse()
156 if (bytes_read != sizeof(struct acvp_resp)) { in ForwardResponse()
/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()

12