Home
last modified time | relevance | path

Searched refs:bytes_read (Results 1 – 25 of 70) 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()
105 bytes_read = read(fd, &command_name_raw[0], command_name_size); in OnCommandReady()
106 if (bytes_read != command_name_size) { in OnCommandReady()
107 LOG_INFO("Unexpected (command_name) bytes_read: %d != %d", bytes_read, command_name_size); in OnCommandReady()
119 bytes_read = read(fd, &num_args, 1); in OnCommandReady()
120 if (bytes_read != 1) { in OnCommandReady()
121 LOG_INFO("Unexpected (num_args) bytes_read: %d != %d", bytes_read, 1); in OnCommandReady()
126 bytes_read = read(fd, &arg_size, 1); in OnCommandReady()
[all …]
/system/bt/vendor_libs/test_vendor_lib/model/devices/
Dh4_packetizer.cc99 ssize_t bytes_read = TEMP_FAILURE_RETRY(read(fd, buffer, 1)); in OnDataReady() local
100 if (bytes_read == 0) { in OnDataReady()
104 } else if (bytes_read < 0) { in OnDataReady()
114 } else if (bytes_read > 1) { in OnDataReady()
115 …_FATAL("%s: More bytes read than expected (%u)!", __func__, static_cast<unsigned int>(bytes_read)); in OnDataReady()
134 …ssize_t bytes_read = TEMP_FAILURE_RETRY(read(fd, preamble_ + bytes_read_, preamble_bytes - bytes_r… in OnDataReady() local
135 if (bytes_read == 0) { in OnDataReady()
139 if (bytes_read < 0) { in OnDataReady()
146 bytes_read_ += bytes_read; in OnDataReady()
166 ssize_t bytes_read = in OnDataReady() local
[all …]
Dhci_packetizer.cc68 ssize_t bytes_read = TEMP_FAILURE_RETRY( in OnDataReady() local
70 if (bytes_read == 0) { in OnDataReady()
74 if (bytes_read < 0) { in OnDataReady()
81 bytes_read_ += bytes_read; in OnDataReady()
102 ssize_t bytes_read = TEMP_FAILURE_RETRY( in OnDataReady() local
104 if (bytes_read == 0) { in OnDataReady()
108 if (bytes_read < 0) { in OnDataReady()
115 bytes_remaining_ -= bytes_read; in OnDataReady()
116 bytes_read_ += bytes_read; in OnDataReady()
Dh4_protocol.cc78 ssize_t bytes_read = TEMP_FAILURE_RETRY(read(fd, buffer, 1)); in OnDataReady() local
79 if (bytes_read != 1) { in OnDataReady()
80 if (bytes_read == 0) { in OnDataReady()
83 } else if (bytes_read < 0) { in OnDataReady()
91 …_FATAL("%s: More bytes read than expected (%u)!", __func__, static_cast<unsigned int>(bytes_read)); in OnDataReady()
/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/core/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()
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()
Dverity_writer_android.cc156 ssize_t bytes_read = 0; in EncodeFEC() local
161 &bytes_read)); in EncodeFEC()
162 TEST_AND_RETURN_FALSE(bytes_read == in EncodeFEC()
180 ssize_t bytes_read = 0; in EncodeFEC() local
182 fd, fec_read.data(), fec_read.size(), fec_offset, &bytes_read)); in EncodeFEC()
183 TEST_AND_RETURN_FALSE(bytes_read == in EncodeFEC()
Dfilesystem_verifier_action.cc208 void FilesystemVerifierAction::OnReadDoneCallback(size_t bytes_read) { in OnReadDoneCallback() argument
213 if (bytes_read == 0) { in OnReadDoneCallback()
221 if (!hasher_->Update(buffer_.data(), bytes_read)) { in OnReadDoneCallback()
236 if (!verity_writer_->Update(offset_, buffer_.data(), bytes_read)) { in OnReadDoneCallback()
242 offset_ += bytes_read; in OnReadDoneCallback()
Dpostinstall_runner_action.cc232 size_t bytes_read; in OnProgressFdReady() local
234 bytes_read = 0; in OnProgressFdReady()
237 utils::ReadAll(progress_fd_, buf, base::size(buf), &bytes_read, &eof); in OnProgressFdReady()
238 progress_buffer_.append(buf, bytes_read); in OnProgressFdReady()
255 } while (bytes_read); in OnProgressFdReady()
/system/update_engine/payload_generator/
Dblob_file_writer_unittest.cc48 ssize_t bytes_read; in TEST() local
50 utils::PReadAll(blob_fd, stored_blob.data(), blob_size, 0, &bytes_read)); in TEST()
51 EXPECT_EQ(bytes_read, blob_size); 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/update_engine/common/
Dutils.cc146 size_t bytes_read = 0; in ReadAll() local
148 while (bytes_read < count) { in ReadAll()
149 ssize_t rc = HANDLE_EINTR(read(fd, c_buf + bytes_read, count - bytes_read)); in ReadAll()
155 *out_bytes_read = bytes_read; in ReadAll()
165 bytes_read += rc; in ReadAll()
168 *out_bytes_read = bytes_read; in ReadAll()
228 ssize_t bytes_read = 0; in PReadAll() local
229 while (bytes_read < static_cast<ssize_t>(count)) { in PReadAll()
231 pread(fd, c_buf + bytes_read, count - bytes_read, offset + bytes_read); in PReadAll()
236 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.cc122 size_t bytes_read; in OnStdoutReady() local
124 bytes_read = 0; in OnStdoutReady()
127 record->stdout_fd, buf, base::size(buf), &bytes_read, &eof); in OnStdoutReady()
128 record->stdout.append(buf, bytes_read); in OnStdoutReady()
135 } 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/bt/bta/hearing_aid/
Dhearing_aid_audio_source.cc70 uint32_t bytes_read; in send_audio_data() local
72 bytes_read = bluetooth::audio::hearing_aid::read(p_buf, bytes_per_tick); in send_audio_data()
74 bytes_read = UIPC_Read(*uipc_hearing_aid, UIPC_CH_ID_AV_AUDIO, &event, in send_audio_data()
78 VLOG(2) << "bytes_read: " << bytes_read; in send_audio_data()
79 if (bytes_read < bytes_per_tick) { in send_audio_data()
80 stats.media_read_total_underflow_bytes += bytes_per_tick - bytes_read; in send_audio_data()
86 std::vector<uint8_t> data(p_buf, p_buf + bytes_read); in send_audio_data()
/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/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