Home
last modified time | relevance | path

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

123

/system/bt/vendor_libs/test_vendor_lib/model/setup/
Dtest_channel_transport.cc99 int bytes_read = read(fd, &command_name_size, 1); in OnCommandReady() local
100 if (bytes_read != 1) { in OnCommandReady()
101 LOG_INFO("Unexpected (command_name_size) bytes_read: %d != %d", bytes_read, 1); in OnCommandReady()
106 bytes_read = read(fd, &command_name_raw[0], command_name_size); in OnCommandReady()
107 if (bytes_read != command_name_size) { in OnCommandReady()
108 LOG_INFO("Unexpected (command_name) bytes_read: %d != %d", bytes_read, command_name_size); in OnCommandReady()
120 bytes_read = read(fd, &num_args, 1); in OnCommandReady()
121 if (bytes_read != 1) { in OnCommandReady()
122 LOG_INFO("Unexpected (num_args) bytes_read: %d != %d", bytes_read, 1); in OnCommandReady()
127 bytes_read = read(fd, &arg_size, 1); in OnCommandReady()
[all …]
/system/bt/vendor_libs/linux/interface/
Dhci_packetizer.cc58 size_t bytes_read = TEMP_FAILURE_RETRY( in OnDataReady() local
61 CHECK(bytes_read > 0); in OnDataReady()
62 bytes_read_ += bytes_read; in OnDataReady()
76 size_t bytes_read = TEMP_FAILURE_RETRY(read( in OnDataReady() local
80 CHECK(bytes_read > 0); in OnDataReady()
81 bytes_remaining_ -= bytes_read; in OnDataReady()
82 bytes_read_ += bytes_read; in OnDataReady()
Dh4_protocol.cc100 size_t bytes_read = TEMP_FAILURE_RETRY(read(fd, tpkt.data(), max_plen)); in OnDataReady() local
102 hci_packetizer_.CbHciPacket(tpkt.data()+1, bytes_read-1); in OnDataReady()
/system/unwinding/libbacktrace/
DBacktracePtrace.cpp76 size_t bytes_read = 0; in Read()
88 bytes_read += copy_bytes; in Read()
94 return bytes_read; in Read()
99 bytes_read += sizeof(word_t); in Read()
105 return bytes_read; in Read()
108 bytes_read += left_over; in Read()
110 return bytes_read; in Read()
Dbacktrace_read_benchmarks.cpp94 size_t bytes_read = 0; in PtraceRead() local
98 return bytes_read; in PtraceRead()
103 bytes_read += sizeof(long); in PtraceRead()
109 return bytes_read; in PtraceRead()
112 bytes_read += left_over; in PtraceRead()
114 return bytes_read; in PtraceRead()
/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()
Dvabc_partition_writer.cc114 ssize_t bytes_read = 0; in WriteAllCowOps() local
119 &bytes_read)); in WriteAllCowOps()
120 if (bytes_read <= 0 || static_cast<size_t>(bytes_read) != block_size) { in WriteAllCowOps()
121 LOG(ERROR) << "source_fd->Read failed: " << bytes_read; in WriteAllCowOps()
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.cc234 const auto bytes_read = fd->Read(buffer, read_size); in WriteVerityAndHashPartition() local
235 if (bytes_read < 0 || static_cast<size_t>(bytes_read) != read_size) { in WriteVerityAndHashPartition()
237 << read_size << " bytes, actual: " << bytes_read; in WriteVerityAndHashPartition()
247 UpdatePartitionProgress((start_offset + bytes_read) * 1.0f / partition_size_ * in WriteVerityAndHashPartition()
254 start_offset + bytes_read, in WriteVerityAndHashPartition()
280 const auto bytes_read = fd->Read(buffer, read_size); in HashPartition() local
281 if (bytes_read < 0 || static_cast<size_t>(bytes_read) != read_size) { in HashPartition()
283 << read_size << " bytes, actual: " << bytes_read; in HashPartition()
292 const auto progress = (start_offset + bytes_read) * 1.0f / partition_size_; in HashPartition()
300 start_offset + bytes_read, in HashPartition()
Dverity_writer_android.cc180 ssize_t bytes_read = 0; in EncodeFEC() local
185 &bytes_read)); in EncodeFEC()
186 TEST_AND_RETURN_FALSE(bytes_read >= 0); in EncodeFEC()
187 TEST_AND_RETURN_FALSE(static_cast<size_t>(bytes_read) == buffer.size()); in EncodeFEC()
204 ssize_t bytes_read = 0; in EncodeFEC() local
206 read_fd, fec_read.data(), fec_read.size(), fec_offset, &bytes_read)); in EncodeFEC()
207 TEST_AND_RETURN_FALSE(bytes_read >= 0); in EncodeFEC()
208 TEST_AND_RETURN_FALSE(static_cast<size_t>(bytes_read) == fec_read.size()); in EncodeFEC()
/system/update_engine/payload_generator/
Dcow_size_estimator.cc43 ssize_t bytes_read = 0; in PerformReplaceOp() local
48 &bytes_read); in PerformReplaceOp()
50 CHECK_EQ(static_cast<size_t>(bytes_read), buffer.size()); in PerformReplaceOp()
83 ssize_t bytes_read = 0; in WriteAllCowOps() local
89 &bytes_read)); in WriteAllCowOps()
90 if (bytes_read <= 0 || static_cast<size_t>(bytes_read) != block_size) { in WriteAllCowOps()
91 LOG(ERROR) << "source_fd->Read failed: " << bytes_read; in WriteAllCowOps()
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()
/system/bt/vendor_libs/test_vendor_lib/model/devices/
Dh4_packetizer.cc132 ssize_t bytes_read = in OnDataReady() local
134 if (bytes_read == 0) { in OnDataReady()
139 } else if (bytes_read < 0) { in OnDataReady()
156 } else if (bytes_read > bytes_to_read) { in OnDataReady()
158 static_cast<int>(bytes_read), in OnDataReady()
177 bytes_read_ += bytes_read; in OnDataReady()
191 bytes_read_ += bytes_read; in OnDataReady()
/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.append(buf, bytes_read); in OnStdoutReady()
134 } while (bytes_read); in OnStdoutReady()
/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()
/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/bt/bta/hearing_aid/
Dhearing_aid_audio_source.cc93 uint32_t bytes_read; in send_audio_data() local
95 bytes_read = bluetooth::audio::hearing_aid::read(p_buf, bytes_per_tick); in send_audio_data()
97 bytes_read = UIPC_Read(*uipc_hearing_aid, UIPC_CH_ID_AV_AUDIO, &event, in send_audio_data()
101 VLOG(2) << "bytes_read: " << bytes_read; in send_audio_data()
102 if (bytes_read < bytes_per_tick) { in send_audio_data()
103 stats.media_read_total_underflow_bytes += bytes_per_tick - bytes_read; in send_audio_data()
109 std::vector<uint8_t> data(p_buf, p_buf + bytes_read); in send_audio_data()
/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/bt/gd/os/linux_generic/
Drepeating_alarm.cc76 auto bytes_read = read(fd_, &times_invoked, sizeof(uint64_t)); in on_fire() local
79 ASSERT(bytes_read == static_cast<ssize_t>(sizeof(uint64_t))); in on_fire()
/system/bt/stack/a2dp/
Da2dp_vendor_aptx_hd_encoder.cc382 uint32_t bytes_read = 0; in a2dp_vendor_aptx_hd_send_frames() local
390 bytes_read = a2dp_aptx_hd_encoder_cb.read_callback((uint8_t*)read_buffer32, in a2dp_vendor_aptx_hd_send_frames()
393 bytes_read; in a2dp_vendor_aptx_hd_send_frames()
394 if (bytes_read < expected_read_bytes) { in a2dp_vendor_aptx_hd_send_frames()
396 __func__, bytes_read, expected_read_bytes); in a2dp_vendor_aptx_hd_send_frames()
428 a2dp_aptx_hd_encoder_cb.enqueue_callback(p_buf, 1, bytes_read); in a2dp_vendor_aptx_hd_send_frames()

123