Home
last modified time | relevance | path

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

12345678910>>...31

/aosp_15_r20/external/cronet/net/filter/
H A Dbrotli_source_stream_unittest.cc101 int bytes_read = ReadStream(callback.callback()); in TEST_F() local
103 EXPECT_EQ(static_cast<int>(source_data_len()), bytes_read); in TEST_F()
121 int bytes_read = ReadStream(callback.callback()); in TEST_F() local
122 EXPECT_EQ(0, bytes_read); in TEST_F()
140 int bytes_read = ReadStream(callback.callback()); in TEST_F() local
141 if (bytes_read == OK) in TEST_F()
143 ASSERT_GT(bytes_read, OK); in TEST_F()
144 actual_output.append(out_data(), bytes_read); in TEST_F()
165 int bytes_read = ReadStream(callback.callback()); in TEST_F() local
166 if (bytes_read == OK) in TEST_F()
[all …]
H A Dzstd_source_stream_unittest.cc77 int bytes_read = ReadStream(callback.callback()); in ReadStreamUntilDone() local
78 if (bytes_read <= OK) { in ReadStreamUntilDone()
81 actual_output.append(out_data(), bytes_read); in ReadStreamUntilDone()
129 int bytes_read = ReadStream(callback.callback()); in TEST_F() local
130 EXPECT_EQ(static_cast<int>(source_data_len()), bytes_read); in TEST_F()
179 int bytes_read = ReadStream(callback.callback()); in TEST_F() local
180 EXPECT_EQ(static_cast<int>(source_data_len()), bytes_read); in TEST_F()
194 int bytes_read = 0; in TEST_F() local
197 bytes_read = ReadStream(callback.callback()); in TEST_F()
198 if (bytes_read == ERR_IO_PENDING) { in TEST_F()
[all …]
/aosp_15_r20/external/libaom/common/
H A Dobudec.c77 size_t *bytes_read, bool buffered) { in obudec_read_obu_header() argument
79 !obu_data || !obu_header || !bytes_read) { in obudec_read_obu_header()
82 *bytes_read = buffer_input(input_ctx, 1, obu_data, buffered); in obudec_read_obu_header()
84 if (input_eof(input_ctx) && *bytes_read == 0) { in obudec_read_obu_header()
86 } else if (*bytes_read != 1) { in obudec_read_obu_header()
97 ++*bytes_read; in obudec_read_obu_header()
102 obu_data, *bytes_read, &obu_bytes_parsed, obu_header, is_annexb); in obudec_read_obu_header()
103 if (parse_result != AOM_CODEC_OK || *bytes_read != obu_bytes_parsed) { in obudec_read_obu_header()
117 size_t *bytes_read, bool buffered) { in obudec_read_obu_payload() argument
118 if (!input_ctx || payload_length == 0 || !obu_data || !bytes_read) return -1; in obudec_read_obu_payload()
[all …]
/aosp_15_r20/external/cronet/third_party/apache-portable-runtime/src/test/
H A Dsendfile.c196 apr_size_t bytes_read; in client() local
471 bytes_read = 1; in client()
472 rv = apr_socket_recv(sock, buf, &bytes_read); in client()
476 if (bytes_read != 0) { in client()
479 (long int)bytes_read); in client()
526 apr_size_t bytes_read; in server() local
563 bytes_read = strlen(HDR1); in server()
564 rv = apr_socket_recv(newsock, buf, &bytes_read); in server()
568 if (bytes_read != strlen(HDR1)) { in server()
575 (int)bytes_read, buf, HDR1); in server()
[all …]
/aosp_15_r20/external/bsdiff/
H A Dextents_file_unittest.cc98 size_t bytes_read; in TEST_F() local
99 EXPECT_FALSE(file.Read(nullptr, 1, &bytes_read)); in TEST_F()
125 size_t bytes_read = 0; in TEST_F() local
126 EXPECT_TRUE(file.Read(buf, 100, &bytes_read)); in TEST_F()
127 EXPECT_EQ(15U, bytes_read); in TEST_F()
147 size_t bytes_read = 0; in TEST_F() local
148 EXPECT_TRUE(file.Read(buf, 2, &bytes_read)); in TEST_F()
149 EXPECT_EQ(2U, bytes_read); in TEST_F()
150 EXPECT_TRUE(file.Read(buf, 8, &bytes_read)); in TEST_F()
151 EXPECT_EQ(8U, bytes_read); in TEST_F()
[all …]
/aosp_15_r20/external/openscreen/osp/msgs/
H A Dmessages_unittest.cc28 ssize_t bytes_read = DecodePresentationUrlAvailabilityRequest( in TEST() local
30 ASSERT_EQ(bytes_read, bytes_out); in TEST()
44 ssize_t bytes_read = DecodePresentationUrlAvailabilityRequest( in TEST() local
46 ASSERT_EQ(bytes_read, bytes_out); in TEST()
62 ssize_t bytes_read = DecodePresentationUrlAvailabilityRequest( in TEST() local
64 ASSERT_EQ(bytes_read, bytes_out); in TEST()
97 ssize_t bytes_read = DecodePresentationUrlAvailabilityRequest( in TEST() local
99 ASSERT_GT(0, bytes_read); in TEST()
114 ssize_t bytes_read = in TEST() local
116 ASSERT_EQ(bytes_read, bytes_out); in TEST()
[all …]
/aosp_15_r20/hardware/google/pixel/pixelstats/
DTempResidencyReporter.cpp43 bool updateOffsetAndCheckBound(int *offset, const int &bytes_read, const int &data_len) { in updateOffsetAndCheckBound() argument
44 *offset += bytes_read; in updateOffsetAndCheckBound()
57 int bytes_read; in parse_file_contents() local
59 while (sscanf(data + offset, "THERMAL ZONE: %31s\n%n", sensor_name, &bytes_read) == 1) { in parse_file_contents()
64 if (!updateOffsetAndCheckBound(&offset, bytes_read, data_len)) in parse_file_contents()
70 &bytes_read) || in parse_file_contents()
71 !updateOffsetAndCheckBound(&offset, bytes_read, data_len)) in parse_file_contents()
75 &temp_residency_stats.max_temp_timestamp, &bytes_read) || in parse_file_contents()
76 !updateOffsetAndCheckBound(&offset, bytes_read, data_len)) in parse_file_contents()
80 &bytes_read) || in parse_file_contents()
[all …]
/aosp_15_r20/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, 1, strerror(errno)); in OnCommandReady()
56 bytes_read = socket->Recv(command_name_raw.data(), command_name_size); in OnCommandReady()
57 if (bytes_read != command_name_size) { in OnCommandReady()
58 INFO("Unexpected (command_name) bytes_read: {} != {}, {}", bytes_read, command_name_size, in OnCommandReady()
71 bytes_read = socket->Recv(&num_args, 1); in OnCommandReady()
72 if (bytes_read != 1) { in OnCommandReady()
73 INFO("Unexpected (num_args) bytes_read: {} != {}, {}", bytes_read, 1, strerror(errno)); in OnCommandReady()
78 bytes_read = socket->Recv(&arg_size, 1); in OnCommandReady()
[all …]
/aosp_15_r20/external/sdv/vsomeip/third_party/boost/asio/test/
Dbuffered_write_stream.cpp175 std::size_t bytes_read = 0; in test_sync_operations() local
176 while (bytes_read < sizeof(read_data)) in test_sync_operations()
178 bytes_read += server_socket.read_some( in test_sync_operations()
179 boost::asio::buffer(read_buf + bytes_read)); in test_sync_operations()
183 BOOST_ASIO_CHECK(bytes_read == sizeof(read_data)); in test_sync_operations()
194 bytes_read = 0; in test_sync_operations()
195 while (bytes_read < sizeof(read_data)) in test_sync_operations()
197 bytes_read += client_socket.read_some( in test_sync_operations()
198 boost::asio::buffer(read_buf + bytes_read)); in test_sync_operations()
202 BOOST_ASIO_CHECK(bytes_read == sizeof(read_data)); in test_sync_operations()
[all …]
Dbuffered_read_stream.cpp174 std::size_t bytes_read = 0; in test_sync_operations() local
175 while (bytes_read < sizeof(read_data)) in test_sync_operations()
177 bytes_read += server_socket.read_some( in test_sync_operations()
178 boost::asio::buffer(read_buf + bytes_read)); in test_sync_operations()
182 BOOST_ASIO_CHECK(bytes_read == sizeof(read_data)); in test_sync_operations()
192 bytes_read = 0; in test_sync_operations()
193 while (bytes_read < sizeof(read_data)) in test_sync_operations()
195 bytes_read += client_socket.read_some( in test_sync_operations()
196 boost::asio::buffer(read_buf + bytes_read)); in test_sync_operations()
200 BOOST_ASIO_CHECK(bytes_read == sizeof(read_data)); in test_sync_operations()
[all …]
Dbuffered_stream.cpp186 std::size_t bytes_read = 0; in test_sync_operations() local
187 while (bytes_read < sizeof(read_data)) in test_sync_operations()
189 bytes_read += server_socket.read_some( in test_sync_operations()
190 boost::asio::buffer(read_buf + bytes_read)); in test_sync_operations()
194 BOOST_ASIO_CHECK(bytes_read == sizeof(read_data)); in test_sync_operations()
205 bytes_read = 0; in test_sync_operations()
206 while (bytes_read < sizeof(read_data)) in test_sync_operations()
208 bytes_read += client_socket.read_some( in test_sync_operations()
209 boost::asio::buffer(read_buf + bytes_read)); in test_sync_operations()
213 BOOST_ASIO_CHECK(bytes_read == sizeof(read_data)); in test_sync_operations()
[all …]
/aosp_15_r20/external/cronet/base/files/
H A Dfile_unittest.cc204 int bytes_read = file.Read(kTestDataSize, data_read_1, kTestDataSize); in TEST() local
205 EXPECT_EQ(0, bytes_read); in TEST()
209 bytes_read = file.Read(kPartialReadOffset, data_read_1, kTestDataSize); in TEST()
210 EXPECT_EQ(kTestDataSize - kPartialReadOffset, bytes_read); in TEST()
211 for (int i = 0; i < bytes_read; i++) in TEST()
215 bytes_read = file.Read(0, data_read_1, 0); in TEST()
216 EXPECT_EQ(0, bytes_read); in TEST()
219 bytes_read = file.Read(0, data_read_1, kTestDataSize); in TEST()
220 EXPECT_EQ(kTestDataSize, bytes_read); in TEST()
221 for (int i = 0; i < bytes_read; i++) in TEST()
[all …]
/aosp_15_r20/external/cronet/net/socket/
H A Dtransport_client_socket_unittest.cc142 uint32_t bytes_read; in TEST_F() local
156 bytes_read = DrainStreamSocket(sock_.get(), buf.get(), 1, 1, &callback); in TEST_F()
157 ASSERT_EQ(bytes_read, 1u); in TEST_F()
164 bytes_read = DrainStreamSocket(sock_.get(), buf.get(), 4096, in TEST_F()
166 ASSERT_EQ(bytes_read, strlen(kServerReply) - 1); in TEST_F()
177 bytes_read = DrainStreamSocket(sock_.get(), buf.get(), 1, 1, &callback); in TEST_F()
178 ASSERT_EQ(bytes_read, 1u); in TEST_F()
184 bytes_read = DrainStreamSocket(sock_.get(), buf.get(), 4096, in TEST_F()
186 ASSERT_EQ(bytes_read, strlen(kServerReply) - 1); in TEST_F()
207 uint32_t bytes_read = DrainStreamSocket(sock_.get(), buf.get(), 4096, in TEST_F() local
[all …]
H A Dtransport_client_socket_test_util.cc57 int bytes_read = 0; in ReadDataOfExpectedLength() local
60 while (bytes_read < expected_bytes_read) { in ReadDataOfExpectedLength()
62 int rv = socket->Read(read_buffer.get(), expected_bytes_read - bytes_read, in ReadDataOfExpectedLength()
67 bytes_read += rv; in ReadDataOfExpectedLength()
69 EXPECT_EQ(expected_bytes_read, bytes_read); in ReadDataOfExpectedLength()
70 return std::string(read_buffer->data(), bytes_read); in ReadDataOfExpectedLength()
100 uint32_t bytes_read = 0; in DrainStreamSocket() local
102 while (bytes_read < bytes_to_read) { in DrainStreamSocket()
107 bytes_read += rv; in DrainStreamSocket()
110 return static_cast<int>(bytes_read); in DrainStreamSocket()
/aosp_15_r20/art/libprofile/profile/
H A Dprofile_boot_info.cc66 int bytes_read = TEMP_FAILURE_RETRY(read(fd, &string_length, sizeof(uint8_t))); in Load() local
67 if (bytes_read < 0) { in Load()
70 } else if (bytes_read == 0) { in Load()
83 bytes_read = TEMP_FAILURE_RETRY(read(fd, data.get(), string_length)); in Load()
84 if (bytes_read < 0) { in Load()
87 } else if (bytes_read == 0) { in Load()
111 int bytes_read = TEMP_FAILURE_RETRY(read(fd, &dex_file_index, sizeof(dex_file_index))); in Load() local
112 if (bytes_read <= 0) { in Load()
115 bytes_read = TEMP_FAILURE_RETRY(read(fd, &method_id, sizeof(method_id))); in Load()
116 if (bytes_read <= 0) { in Load()
/aosp_15_r20/frameworks/native/cmds/bugreportz/
H A Dbugreportz.cpp48 ssize_t bytes_read = TEMP_FAILURE_RETRY(read(s, buffer, sizeof(buffer))); in bugreportz() local
49 if (bytes_read == 0) { in bugreportz()
51 } else if (bytes_read == -1) { in bugreportz()
61 for (int i = 0; i < bytes_read; i++) { in bugreportz()
78 ssize_t bytes_read = TEMP_FAILURE_RETRY(read(s, buffer, sizeof(buffer))); in bugreportz_stream() local
79 if (bytes_read == 0) { in bugreportz_stream()
81 } else if (bytes_read == -1) { in bugreportz_stream()
91 bytes_read)) { in bugreportz_stream()
92 printf("Failed to write data to stdout: trying to send %zd bytes (%s)\n", bytes_read, in bugreportz_stream()
/aosp_15_r20/system/update_engine/payload_consumer/
H A 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 …]
/aosp_15_r20/external/e2fsprogs/resize/
H A Dresource_track.c43 track->bytes_read = 0; in init_resource_track()
48 track->bytes_read = io_start->bytes_read; in init_resource_track()
112 unsigned long long bytes_read = 0; in print_resource_track() local
117 bytes_read = delta->bytes_read - track->bytes_read; in print_resource_track()
120 if (bytes_read == 0 && bytes_written == 0) in print_resource_track()
126 mbytes(bytes_read), in print_resource_track()
128 (double)mbytes(bytes_read + bytes_written) / in print_resource_track()
/aosp_15_r20/hardware/interfaces/bluetooth/1.0/default/
H A Dhci_packetizer.cc64 ssize_t bytes_read = TEMP_FAILURE_RETRY( in OnDataReady() local
67 if (bytes_read == 0) { in OnDataReady()
73 if (bytes_read < 0) { in OnDataReady()
77 bytes_read_ += bytes_read; in OnDataReady()
91 ssize_t bytes_read = TEMP_FAILURE_RETRY(read( in OnDataReady() local
95 if (bytes_read == 0) { in OnDataReady()
101 if (bytes_read < 0) { in OnDataReady()
105 bytes_remaining_ -= bytes_read; in OnDataReady()
106 bytes_read_ += bytes_read; in OnDataReady()
/aosp_15_r20/external/perfetto/src/trace_processor/
H A Dread_trace_internal.cc76 uint64_t bytes_read = 0; in ReadTraceUnfinalized() local
89 while (bytes_read < length) { in ReadTraceUnfinalized()
90 progress_callback(bytes_read); in ReadTraceUnfinalized()
91 const size_t bytes_read_z = static_cast<size_t>(bytes_read); in ReadTraceUnfinalized()
95 bytes_read += slice_size; in ReadTraceUnfinalized()
99 if (bytes_read == 0) in ReadTraceUnfinalized()
102 if (bytes_read == 0) { in ReadTraceUnfinalized()
107 ReadTraceUsingRead(tp, *fd, &bytes_read, progress_callback)); in ReadTraceUnfinalized()
112 progress_callback(bytes_read); in ReadTraceUnfinalized()
/aosp_15_r20/device/google/cuttlefish/common/libs/fs/
Dshared_fd_stream.cpp45 ssize_t bytes_read = ReadExact(shared_fd_, in underflow() local
51 read_buffer_.get() + unget_size + bytes_read); in underflow()
53 if (bytes_read <= 0 || in_avail() == 0) { in underflow()
61 std::streamsize bytes_read = 0; in xsgetn() local
62 while (bytes_read < count) { in xsgetn()
69 std::min(static_cast<std::streamsize>(in_avail()), count - bytes_read); in xsgetn()
70 std::memcpy(dst + bytes_read, gptr(), buffer_count); in xsgetn()
72 bytes_read += buffer_count; in xsgetn()
74 return bytes_read; in xsgetn()
/aosp_15_r20/external/ltp/testcases/kernel/fs/fs_di/
H A Dfrag.c48 int bytes_read = 0, bytes_written = 0, fd1 = -1, fd2 = -1; in main() local
78 bytes_read = fread(buff, 1, 1024, fp_data); in main()
79 if (bytes_read < 0) { in main()
84 bytes_written = fwrite(buff, 1, bytes_read, fp_frag1); in main()
85 if (bytes_read != bytes_written) { in main()
90 bytes_written = fwrite(buff, 1, bytes_read, fp_frag2); in main()
91 if (bytes_read != bytes_written) { in main()
104 if (bytes_read < 1024) in main()
/aosp_15_r20/device/google/cuttlefish/host/frontend/webrtc/
Daudio_handler.cpp492 size_t bytes_read = 0; in OnCaptureBuffer() local
497 bytes_read += holding_buffer.Take(rx_buffer + bytes_read, in OnCaptureBuffer()
498 buffer.len() - bytes_read); in OnCaptureBuffer()
500 while (buffer.len() - bytes_read >= bytes_per_request) { in OnCaptureBuffer()
503 auto write_pos = rx_buffer + bytes_read; in OnCaptureBuffer()
515 memset(rx_buffer + bytes_read, 0, buffer.len() - bytes_read); in OnCaptureBuffer()
516 bytes_read = buffer.len(); in OnCaptureBuffer()
520 bytes_read += bytes_received; in OnCaptureBuffer()
522 if (bytes_read < buffer.len()) { in OnCaptureBuffer()
539 memset(rx_buffer + bytes_read, 0, buffer.len() - bytes_read); in OnCaptureBuffer()
[all …]
/aosp_15_r20/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 …]
/aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/balsa/
H A Dsimple_buffer_test.cc140 int bytes_read = 0; in TEST_F() local
141 EXPECT_EQ(4, buffer.Read(obuf + bytes_read, 40)); in TEST_F()
147 bytes_read += 4; in TEST_F()
156 EXPECT_EQ(bytes_written, bytes_read); in TEST_F()
157 for (int i = 0; i < bytes_read; ++i) { in TEST_F()
171 EXPECT_EQ(6, buffer.Read(obuf + bytes_read, 6)); in TEST_F()
176 bytes_read += 6; in TEST_F()
180 EXPECT_EQ(4, buffer.Read(obuf + bytes_read, 7)); in TEST_F()
185 bytes_read += 4; in TEST_F()
189 EXPECT_EQ(bytes_written, bytes_read); in TEST_F()
[all …]

12345678910>>...31