Home
last modified time | relevance | path

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

12

/packages/modules/Bluetooth/tools/rootcanal/model/setup/
Dtest_channel_transport.cc49 ssize_t bytes_read = socket->Recv(&command_name_size, 1); in OnCommandReady() local
50 if (bytes_read != 1) { in OnCommandReady()
51 INFO("Unexpected (command_name_size) bytes_read: {} != {}, {}", bytes_read, in OnCommandReady()
57 bytes_read = socket->Recv(command_name_raw.data(), command_name_size); in OnCommandReady()
58 if (bytes_read != command_name_size) { in OnCommandReady()
59 INFO("Unexpected (command_name) bytes_read: {} != {}, {}", bytes_read, in OnCommandReady()
72 bytes_read = socket->Recv(&num_args, 1); in OnCommandReady()
73 if (bytes_read != 1) { in OnCommandReady()
74 INFO("Unexpected (num_args) bytes_read: {} != {}, {}", bytes_read, 1, in OnCommandReady()
80 bytes_read = socket->Recv(&arg_size, 1); in OnCommandReady()
[all …]
/packages/services/Car/cpp/bugreport/
Dmain.cpp144 ssize_t bytes_read = TEMP_FAILURE_RETRY(read(fd, buffer, sizeof(buffer))); in zipFilesToFd() local
145 if (bytes_read == 0) { in zipFilesToFd()
148 if (bytes_read == -1) { in zipFilesToFd()
157 error = writer->WriteBytes(buffer, bytes_read); in zipFilesToFd()
178 ssize_t bytes_read = TEMP_FAILURE_RETRY(read(fd_in, buffer, buffer_len)); in copyTo() local
179 if (bytes_read == 0) { in copyTo()
182 if (bytes_read == -1) { in copyTo()
192 if (!android::base::WriteFully(fd_out, buffer, bytes_read)) { in copyTo()
196 return bytes_read; in copyTo()
248 ssize_t bytes_read = copyTo(s, progress_socket, buffer, sizeof(buffer)); in doBugreport() local
[all …]
/packages/modules/Bluetooth/system/gd/hal/
Dsnoop_logger_socket_thread_test.cc187 int bytes_read = -1; in TEST_F() local
196 bytes_read = a.get(); in TEST_F()
197 ASSERT_EQ(bytes_read, -1); in TEST_F()
223 int bytes_read = -1; in TEST_F() local
232 bytes_read = a.get(); in TEST_F()
234 ASSERT_EQ(bytes_read, static_cast<int>(sizeof(SnoopLoggerCommon::FileHeaderType))); in TEST_F()
235 ASSERT_TRUE(std::memcmp(recv_buf, &SnoopLoggerCommon::kBtSnoopFileHeader, bytes_read) == 0); in TEST_F()
264 int bytes_read = -1; in TEST_F() local
275 bytes_read = a.get(); in TEST_F()
279 ASSERT_EQ(bytes_read, static_cast<int>(sizeof(test_data))); in TEST_F()
[all …]
Dhci_hal_host_test.cc242 size_t bytes_read = 0; in read_with_retry() local
245 bytes_read_current = read(socket, data + bytes_read, length - bytes_read); in read_with_retry()
246 bytes_read += bytes_read_current; in read_with_retry()
247 } while (length > bytes_read && bytes_read_current > 0); in read_with_retry()
248 return bytes_read; in read_with_retry()
/packages/modules/Bluetooth/tools/rootcanal/model/hci/
Dh4_parser.cc105 bool H4Parser::Consume(const uint8_t* buffer, int32_t bytes_read) { in Consume() argument
107 if (bytes_read <= 0) { in Consume()
111 if ((uint32_t)bytes_read > BytesRequested()) { in Consume()
112 FATAL("More bytes read ({}) than expected ({})!", bytes_read, in Consume()
162 packet_.insert(packet_.end(), buffer, buffer + bytes_read); in Consume()
163 bytes_wanted_ -= bytes_read; in Consume()
Dh4_data_channel_packetizer.cc75 ssize_t bytes_read = socket->Recv(buffer.data(), bytes_to_read); in OnDataReady() local
76 if (bytes_read == 0) { in OnDataReady()
82 if (bytes_read < 0) { in OnDataReady()
96 h4_parser_.Consume(buffer.data(), bytes_read); in OnDataReady()
/packages/modules/Bluetooth/system/stack/a2dp/
Da2dp_aac_encoder_linux.cc137 static bool a2dp_aac_read_feeding(uint8_t* read_buffer, uint32_t* bytes_read);
316 uint32_t bytes_read = 0; in a2dp_aac_encode_frames() local
317 if (!a2dp_aac_read_feeding(read_buffer, &bytes_read)) { in a2dp_aac_encode_frames()
332 read_buffer, bytes_read, (uint8_t*)(p_buf + 1) + p_buf->offset, in a2dp_aac_encode_frames()
357 if (!a2dp_aac_encoder_cb.enqueue_callback(p_buf, 1, bytes_read)) return; in a2dp_aac_encode_frames()
361 static bool a2dp_aac_read_feeding(uint8_t* read_buffer, uint32_t* bytes_read) { in a2dp_aac_read_feeding() argument
373 *bytes_read = nb_byte_read; in a2dp_aac_read_feeding()
Da2dp_vendor_aptx_hd_encoder.cc308 uint32_t bytes_read = 0; in a2dp_vendor_aptx_hd_send_frames() local
316 bytes_read = a2dp_aptx_hd_encoder_cb.read_callback((uint8_t*)read_buffer32, in a2dp_vendor_aptx_hd_send_frames()
319 bytes_read; in a2dp_vendor_aptx_hd_send_frames()
320 if (bytes_read < expected_read_bytes) { in a2dp_vendor_aptx_hd_send_frames()
322 bytes_read, expected_read_bytes); in a2dp_vendor_aptx_hd_send_frames()
358 a2dp_aptx_hd_encoder_cb.enqueue_callback(p_buf, 1, bytes_read); in a2dp_vendor_aptx_hd_send_frames()
Da2dp_vendor_aptx_encoder.cc323 uint32_t bytes_read = 0; in a2dp_vendor_aptx_send_frames() local
331 bytes_read = a2dp_aptx_encoder_cb.read_callback((uint8_t*)read_buffer16, in a2dp_vendor_aptx_send_frames()
333 a2dp_aptx_encoder_cb.stats.media_read_total_actual_read_bytes += bytes_read; in a2dp_vendor_aptx_send_frames()
334 if (bytes_read < expected_read_bytes) { in a2dp_vendor_aptx_send_frames()
336 bytes_read, expected_read_bytes); in a2dp_vendor_aptx_send_frames()
371 a2dp_aptx_encoder_cb.enqueue_callback(p_buf, 1, bytes_read); in a2dp_vendor_aptx_send_frames()
Da2dp_vendor_opus_encoder.cc98 static bool a2dp_opus_read_feeding(uint8_t* read_buffer, uint32_t* bytes_read);
376 uint32_t bytes_read = 0; in a2dp_opus_encode_frames() local
390 bytes_read += temp_bytes_read; in a2dp_opus_encode_frames()
446 bytes_read)) in a2dp_opus_encode_frames()
455 static bool a2dp_opus_read_feeding(uint8_t* read_buffer, uint32_t* bytes_read) { in a2dp_opus_read_feeding() argument
477 *bytes_read = nb_byte_read; in a2dp_opus_read_feeding()
Da2dp_vendor_ldac_encoder.cc123 static bool a2dp_ldac_read_feeding(uint8_t* read_buffer, uint32_t* bytes_read);
453 uint32_t bytes_read = 0; in a2dp_ldac_encode_frames() local
468 bytes_read += temp_bytes_read; in a2dp_ldac_encode_frames()
524 bytes_read)) in a2dp_ldac_encode_frames()
537 static bool a2dp_ldac_read_feeding(uint8_t* read_buffer, uint32_t* bytes_read) { in a2dp_ldac_read_feeding() argument
559 *bytes_read = nb_byte_read; in a2dp_ldac_read_feeding()
Da2dp_aac_encoder.cc108 static bool a2dp_aac_read_feeding(uint8_t* read_buffer, uint32_t* bytes_read);
585 uint32_t bytes_read = 0; in a2dp_aac_encode_frames() local
586 if (a2dp_aac_read_feeding(read_buffer, &bytes_read)) { in a2dp_aac_encode_frames()
620 total_bytes_read += bytes_read; in a2dp_aac_encode_frames()
653 static bool a2dp_aac_read_feeding(uint8_t* read_buffer, uint32_t* bytes_read) { in a2dp_aac_read_feeding() argument
665 *bytes_read = nb_byte_read; in a2dp_aac_read_feeding()
/packages/modules/Bluetooth/system/bta/hearing_aid/
Dhearing_aid_audio_source.cc107 uint32_t bytes_read; in send_audio_data() local
109 bytes_read = bluetooth::audio::hearing_aid::read(p_buf, bytes_per_tick); in send_audio_data()
111 bytes_read = UIPC_Read(*uipc_hearing_aid, UIPC_CH_ID_AV_AUDIO, p_buf, in send_audio_data()
115 log::debug("bytes_read: {}", bytes_read); in send_audio_data()
116 if (bytes_read < bytes_per_tick) { in send_audio_data()
117 stats.media_read_total_underflow_bytes += bytes_per_tick - bytes_read; in send_audio_data()
123 std::vector<uint8_t> data(p_buf, p_buf + bytes_read); in send_audio_data()
/packages/modules/Bluetooth/system/gd/rust/linux/utils/src/
Dsocket.rs338 let mut bytes_read; in read_mgmt_packet() localVariable
340 bytes_read = libc::read( in read_mgmt_packet()
347 let retry = (bytes_read == -1) in read_mgmt_packet()
356 if bytes_read == -1 { in read_mgmt_packet()
364 if bytes_read < (MGMT_PKT_HEADER_SIZE as isize) { in read_mgmt_packet()
365 debug!("read_mgmt_packet got {} bytes (not enough for header)", bytes_read); in read_mgmt_packet()
370 (bytes_read - (MGMT_PKT_HEADER_SIZE as isize)).try_into().unwrap(); in read_mgmt_packet()
/packages/modules/Bluetooth/system/audio_hal_interface/
Da2dp_encoding_host.cc279 uint32_t bytes_read = 0; in read() local
283 bytes_read = UIPC_Read(*a2dp_uipc, UIPC_CH_ID_AV_AUDIO, p_buf, len); in read()
284 total_bytes_read_ += bytes_read; in read()
288 return bytes_read; in read()
/packages/services/Car/cpp/security/vehicle_binding_util/src/
DVehicleBindingUtil.cpp128 ssize_t bytes_read; in fill() local
130 while ((bytes_read = TEMP_FAILURE_RETRY(read(fd, bufptr, size))) > 0) { in fill()
131 size -= bytes_read; in fill()
132 bufptr += bytes_read; in fill()
/packages/modules/adb/client/
Dincremental.cpp231 int bytes_read; in wait_for_installation() local
234 while ((bytes_read = adb_read(read_fd, child_stdout.data() + buf_size, in wait_for_installation()
237 fprintf(stdout, "%.*s", bytes_read, child_stdout.data() + buf_size); in wait_for_installation()
239 buf_size += bytes_read; in wait_for_installation()
/packages/modules/Bluetooth/system/btif/src/
Dbtif_a2dp_source.cc270 uint32_t bytes_read);
931 uint32_t bytes_read = 0; in btif_a2dp_source_read_callback() local
934 bytes_read = bluetooth::audio::a2dp::read(p_buf, len); in btif_a2dp_source_read_callback()
936 bytes_read = UIPC_Read(*a2dp_uipc, UIPC_CH_ID_AV_AUDIO, p_buf, len); in btif_a2dp_source_read_callback()
939 if (btif_a2dp_source_cb.sw_audio_is_encoding && bytes_read < len) { in btif_a2dp_source_read_callback()
940 log::warn("UNDERFLOW: ONLY READ {} BYTES OUT OF {}", bytes_read, len); in btif_a2dp_source_read_callback()
942 (len - bytes_read); in btif_a2dp_source_read_callback()
948 len - bytes_read); in btif_a2dp_source_read_callback()
951 return bytes_read; in btif_a2dp_source_read_callback()
955 uint32_t bytes_read) { in btif_a2dp_source_enqueue_callback() argument
[all …]
/packages/modules/Bluetooth/system/audio_hal_interface/hidl/
Dhearing_aid_software_encoding_hidl.cc126 void LogBytesRead(size_t bytes_read) override { in LogBytesRead() argument
127 if (bytes_read) { in LogBytesRead()
128 total_bytes_read_ += bytes_read; in LogBytesRead()
/packages/modules/Bluetooth/system/audio_hal_interface/aidl/
Dhearing_aid_software_encoding_aidl.cc132 void LogBytesRead(size_t bytes_read) override { in LogBytesRead() argument
133 if (bytes_read) { in LogBytesRead()
134 total_bytes_read_ += bytes_read; in LogBytesRead()
Dhfp_client_interface_aidl.h73 void LogBytesProcessed(size_t bytes_read);
108 void LogBytesRead(size_t bytes_read) override;
/packages/modules/Virtualization/rialto/src/
Dcommunication.rs103 let bytes_read = in recv() localVariable
109 if buffer_available_bytes == 0 && bytes_read > 0 { in recv()
112 Ok(bytes_read) in recv()
/packages/modules/Bluetooth/system/gd/os/linux_generic/
Drepeating_alarm.cc77 auto bytes_read = read(fd_, &times_invoked, sizeof(uint64_t)); in on_fire() local
81 bytes_read == static_cast<ssize_t>(sizeof(uint64_t)), in on_fire()
Dalarm.cc77 auto bytes_read = read(fd_, &times_invoked, sizeof(uint64_t)); in on_fire() local
80 bytes_read == static_cast<ssize_t>(sizeof(uint64_t)), in on_fire()
/packages/modules/adb/tls/
Dtls_connection.cpp330 int bytes_read = in ReadFully() local
332 if (bytes_read <= 0) { in ReadFully()
336 size -= bytes_read; in ReadFully()
337 offset += bytes_read; in ReadFully()

12