Home
last modified time | relevance | path

Searched refs:read_size (Results 1 – 25 of 92) sorted by relevance

1234

/external/cronet/net/third_party/quiche/src/quiche/balsa/
Dsimple_buffer.cc45 int read_size = 0; in Read() local
46 GetReadablePtr(&read_ptr, &read_size); in Read()
47 read_size = std::min(read_size, size); in Read()
48 if (read_size == 0) { in Read()
52 memcpy(bytes, read_ptr, read_size); in Read()
53 AdvanceReadablePtr(read_size); in Read()
54 return read_size; in Read()
73 int read_size = 0; in Reserve() local
74 GetReadablePtr(&read_ptr, &read_size); in Reserve()
77 QUICHE_DCHECK_EQ(0, read_size); in Reserve()
[all …]
/external/pigweed/pw_kvs/
Dentry.cc149 const size_t read_size = std::min(buffer.size(), remaining_bytes); in ReadValue() local
153 buffer.subspan(0, read_size)); in ReadValue()
156 if (read_size != remaining_bytes) { in ReadValue()
157 return StatusWithSize::ResourceExhausted(read_size); in ReadValue()
159 return StatusWithSize(read_size); in ReadValue()
173 const size_t read_size = std::min(size_t(end - address), buffer.size()); in ValueMatches() local
174 PW_TRY(partition_->Read(address, span(buffer).first(read_size))); in ValueMatches()
176 if (std::memcmp(buffer.data(), value_ptr, read_size) != 0) { in ValueMatches()
180 address += read_size; in ValueMatches()
181 value_ptr += read_size; in ValueMatches()
[all …]
Dflash_memory.cc159 size_t read_size = std::min(sizeof(read_buffer), length); in IsRegionErased() local
161 Read(source_flash_address + offset, read_size, read_buffer).status()); in IsRegionErased()
163 for (byte b : span(read_buffer, read_size)) { in IsRegionErased()
170 offset += read_size; in IsRegionErased()
171 length -= read_size; in IsRegionErased()
/external/exfatprogs/fsck/
Dde_iter.c24 for (i = 0; i < iter->read_size / iter->write_size; i++) { in write_block()
163 if (block > iter->parent->size / iter->read_size) in read_block()
167 if (prev_desc->offset + 2 * iter->read_size <= in read_block()
170 desc->offset = prev_desc->offset + iter->read_size; in read_block()
184 iter->read_size, device_offset); in read_block()
192 if (desc->buffer[iter->read_size - 32] != EXFAT_LAST) in read_block()
194 (block * iter->read_size) / exfat->clus_size, in read_block()
195 (block * iter->read_size) % exfat->clus_size, in read_block()
208 iter->read_size = exfat->clus_size <= 4*KB ? exfat->clus_size : 4*KB; in exfat_de_iter_init()
222 if (read_block(iter, 0) != (ssize_t)iter->read_size) { in exfat_de_iter_init()
[all …]
/external/vboot_reference/tests/
Dvb21_host_misc_tests.c35 uint32_t read_size; in file_tests() local
42 TEST_EQ(vb2_read_file(testfile, &read_data, &read_size), in file_tests()
49 TEST_SUCC(vb2_read_file(testfile, &read_data, &read_size), in file_tests()
51 TEST_EQ(read_size, sizeof(test_data), " data size"); in file_tests()
52 TEST_EQ(memcmp(read_data, test_data, read_size), 0, " data"); in file_tests()
62 TEST_SUCC(vb2_read_file(testfile, &read_data, &read_size), in file_tests()
64 TEST_EQ(read_size, c->total_size, " data size"); in file_tests()
66 TEST_EQ(memcmp(read_data, c, read_size), 0, " data"); in file_tests()
/external/deqp/external/openglcts/modules/glesext/texture_cube_map_array/
DesextcTextureCubeMapArrayImageTextureSize.cpp480 glw::GLuint read_size[m_n_varyings * m_n_tf_components]; in checkResults() local
481 memcpy(read_size, temp_buff, m_n_varyings * m_n_tf_components * sizeof(glw::GLint)); in checkResults()
489 …if (read_size[0] != width || read_size[1] != height || read_size[2] != (depth / m_n_layers_per_cub… in checkResults()
495 << "[" << read_size[0] << "][" << read_size[1] << "][" << read_size[2] << "] but should be " in checkResults()
502 …if (read_size[3] != width || read_size[4] != height || read_size[5] != (depth / m_n_layers_per_cub… in checkResults()
509 << "[" << read_size[3] << "][" << read_size[4] << "][" << read_size[5] in checkResults()
1176 glw::GLuint read_size[m_n_rt_components]; in checkResults() local
1177 memset(read_size, 0, m_n_rt_components * sizeof(glw::GLuint)); in checkResults()
1188 gl.readPixels(0, 0, 1, 1, GL_RGBA_INTEGER, GL_UNSIGNED_INT, read_size); in checkResults()
1191 …if (read_size[0] != width || read_size[1] != height || read_size[2] != (depth / m_n_layers_per_cub… in checkResults()
[all …]
/external/python/apitools/apitools/base/py/
Dstream_slice.py68 read_size = min(size, self.__remaining_bytes)
70 read_size = self.__remaining_bytes
71 data = self.__stream.read(read_size)
72 if read_size > 0 and not data:
/external/cronet/net/filter/
Dfilter_source_stream_unittest.cc268 size_t read_size = 2; in TEST_P() local
271 for (size_t offset = 0; offset < input.length(); offset += read_size) { in TEST_P()
273 std::min(read_size, input.length() - offset), OK, in TEST_P()
321 size_t read_size = 2; in TEST_P() local
324 for (size_t offset = 0; offset < input.length(); offset += read_size) { in TEST_P()
326 std::min(read_size, input.length() - offset), OK, in TEST_P()
350 size_t read_size = 2; in TEST_P() local
352 for (size_t offset = 0; offset < input.length(); offset += read_size) { in TEST_P()
354 std::min(read_size, input.length() - offset), OK, in TEST_P()
371 ASSERT_GE(static_cast<int>(read_size), rv); in TEST_P()
[all …]
/external/libchrome/mojo/public/cpp/system/
Dfile_data_pipe_producer.cc166 int read_size = file_.ReadAtCurrentPos(static_cast<char*>(pipe_buffer), in TransferSomeBytes() local
169 if (read_size < 0) { in TransferSomeBytes()
177 observer_->OnBytesRead(pipe_buffer, static_cast<size_t>(read_size), in TransferSomeBytes()
182 read_size >= 0 ? static_cast<uint32_t>(read_size) : 0); in TransferSomeBytes()
184 if (read_size < 0) { in TransferSomeBytes()
189 bytes_transferred_ += read_size; in TransferSomeBytes()
192 if (read_size < attempted_read_size) { in TransferSomeBytes()
/external/virglrenderer/src/venus/
Dvkr_ring.c133 uint32_t read_size; in vkr_ring_read_buffer() local
136 read_size = size; in vkr_ring_read_buffer()
139 read_size = buf_avail; in vkr_ring_read_buffer()
150 if (read_size <= buf->cur_iov->iov_len - buf->cur_iov_offset) { in vkr_ring_read_buffer()
152 memcpy(data, src, read_size); in vkr_ring_read_buffer()
157 buf->cur += read_size; in vkr_ring_read_buffer()
158 buf->cur_iov_offset += read_size; in vkr_ring_read_buffer()
163 buf->cur_iov_offset, data, read_size); in vkr_ring_read_buffer()
169 (char *)data + read_size, wrap_size); in vkr_ring_read_buffer()
/external/grpc-grpc/test/core/network_benchmarks/
Dlow_level_ping_pong.cc71 static int read_bytes(int fd, char* buf, size_t read_size, int spin) { in read_bytes() argument
75 err = read(fd, buf + bytes_read, read_size - bytes_read); in read_bytes()
89 } while (bytes_read < read_size); in read_bytes()
102 static int poll_read_bytes(int fd, char* buf, size_t read_size, int spin) { in poll_read_bytes() argument
124 err2 = read(fd, buf + bytes_read, read_size - bytes_read); in poll_read_bytes()
131 } while (bytes_read < read_size); in poll_read_bytes()
150 size_t read_size = args->msg_size; in epoll_read_bytes() local
166 read(args->fds.read_fd, buf + bytes_read, read_size - bytes_read); in epoll_read_bytes()
172 } while (bytes_read < read_size); in epoll_read_bytes()
173 } while (bytes_read < read_size); in epoll_read_bytes()
[all …]
/external/pigweed/pw_ring_buffer/
Dprefixed_entry_ring_buffer_test.cc87 size_t read_size = 500U; in SingleEntryWriteReadTest() local
98 EXPECT_EQ(ring.PeekFront(read_buffer, &read_size), Status::OutOfRange()); in SingleEntryWriteReadTest()
99 EXPECT_EQ(read_size, 0u); in SingleEntryWriteReadTest()
100 read_size = 500U; in SingleEntryWriteReadTest()
101 EXPECT_EQ(ring.PeekFrontWithPreamble(read_buffer, &read_size), in SingleEntryWriteReadTest()
103 EXPECT_EQ(read_size, 0u); in SingleEntryWriteReadTest()
126 read_size = 500U; in SingleEntryWriteReadTest()
127 ASSERT_EQ(ring.PeekFront(read_buffer, &read_size), OkStatus()); in SingleEntryWriteReadTest()
128 ASSERT_EQ(read_size, data_size); in SingleEntryWriteReadTest()
137 read_size = 500U; in SingleEntryWriteReadTest()
[all …]
/external/linux-kselftest/tools/testing/selftests/net/
Drxtimestamp.c175 bool do_recv(int rcv, int read_size, struct tstamps expected) in do_recv() argument
192 recv_iov.iov_base = malloc(read_size); in do_recv()
193 recv_iov.iov_len = read_size; in do_recv()
201 if (r != read_size) in do_recv()
285 int read_size = op_size; in run_test_case() local
298 read_size += 20; /* for IPv4 header */ in run_test_case()
338 failed = do_recv(rcv, read_size, test_cases[test_num].expected); in run_test_case()
/external/puffin/src/
Dmain.cc285 auto read_size = std::min(static_cast<uint64_t>(buffer.size()), in Main() local
287 TEST_AND_RETURN_FALSE(read_puff_stream->Read(buffer.data(), read_size)); in Main()
288 TEST_AND_RETURN_FALSE(huff_writer->Write(buffer.data(), read_size)); in Main()
289 bytes_read += read_size; in Main()
311 auto read_size = std::min(static_cast<uint64_t>(buffer.size()), in Main() local
313 TEST_AND_RETURN_FALSE(src_stream->Read(buffer.data(), read_size)); in Main()
314 TEST_AND_RETURN_FALSE(dst_stream->Write(buffer.data(), read_size)); in Main()
315 bytes_read += read_size; in Main()
/external/cronet/base/debug/
Dproc_maps_linux.cc42 const size_t read_size = static_cast<size_t>(sysconf(_SC_PAGESIZE)); in ReadProcMaps() local
55 proc_maps->resize(pos + read_size); in ReadProcMaps()
58 ssize_t bytes_read = HANDLE_EINTR(read(fd.get(), buffer, read_size)); in ReadProcMaps()
/external/iputils/ninfod/
Dni_ifaddrs.c168 int result = 0, read_size; in nl_getmsg() local
179 result = read_size = nl_recvmsg(sd, request, seq, buff, bufsize, &msg_flags); in nl_getmsg()
180 if (read_size < 0 || (msg_flags & MSG_TRUNC)) { in nl_getmsg()
185 if (read_size == 0) in nl_getmsg()
188 … (nh = (struct nlmsghdr *) buff; NLMSG_OK(nh, read_size); nh = (struct nlmsghdr *) NLMSG_NEXT(nh, … in nl_getmsg()
/external/libbrillo/brillo/http/
Dhttp_connection_curl.cc231 size_t read_size = 0; in read_callback() local
233 &read_size, nullptr); in read_callback()
234 VLOG_IF(3, success) << "Sending data: " << std::string{ptr, read_size}; in read_callback()
235 return success ? read_size : CURL_READFUNC_ABORT; in read_callback()
/external/trace-cmd/lib/trace-cmd/
Dtrace-compress.c670 unsigned long long *read_size, unsigned long long *write_size) in tracecmd_compress_copy_from() argument
691 if (read_size) in tracecmd_compress_copy_from()
692 rmax = *read_size; in tracecmd_compress_copy_from()
772 if (read_size) in tracecmd_compress_copy_from()
773 *read_size = rsize; in tracecmd_compress_copy_from()
915 unsigned long long *read_size, unsigned long long *write_size) in tracecmd_uncompress_copy_to() argument
985 if (read_size) in tracecmd_uncompress_copy_to()
986 *read_size = rsize; in tracecmd_uncompress_copy_to()
/external/cronet/components/metrics/
Dpersistent_system_profile.cc251 size_t read_size = header.as_parts.amount; in ReadData() local
252 if (end_offset_ + sizeof(header) + read_size > alloc_size_) { in ReadData()
258 SCOPED_CRASH_KEY_NUMBER("PersistentSystemProfile", "read_size", read_size); in ReadData()
269 record->append(block + end_offset_ + sizeof(header), read_size); in ReadData()
270 end_offset_ += CalculateRecordSize(read_size); in ReadData()
/external/grpc-grpc/src/core/lib/iomgr/
Dendpoint_cfstream.cc164 CFIndex read_size = in ReadAction() local
166 if (read_size == -1) { in ReadAction()
178 } else if (read_size == 0) { in ReadAction()
185 if (read_size < len) { in ReadAction()
186 grpc_slice_buffer_trim_end(ep->read_slices, len - read_size, nullptr); in ReadAction()
/external/cronet/net/third_party/quiche/src/quiche/quic/masque/
Dmasque_client_bin.cc122 ssize_t read_size = read(fd, datagram, sizeof(datagram)); in OnSocketEvent() local
123 if (read_size < 0) { in OnSocketEvent()
128 session_->SendIpPacket(absl::string_view(datagram, read_size), this); in OnSocketEvent()
/external/pigweed/pw_blob_store/
Dblob_store.cc418 size_t read_size = std::min(available_bytes, dest.size_bytes()); in Read() local
420 return partition_.Read(offset, dest.first(read_size)); in Read()
524 const size_t read_size = std::min(size_t(end - address), buffer.size()); in CalculateChecksumFromFlash() local
525 PW_TRY(partition_.Read(address, span(buffer).first(read_size))); in CalculateChecksumFromFlash()
527 checksum_algo_->Update(buffer.data(), read_size); in CalculateChecksumFromFlash()
528 address += read_size; in CalculateChecksumFromFlash()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/
Dendpoint_cfstream.cc164 CFIndex read_size = in ReadAction() local
166 if (read_size == -1) { in ReadAction()
178 } else if (read_size == 0) { in ReadAction()
185 if (read_size < static_cast<CFIndex>(len)) { in ReadAction()
186 grpc_slice_buffer_trim_end(ep->read_slices, len - read_size, nullptr); in ReadAction()
/external/leveldb/util/
Denv_posix.cc117 ::ssize_t read_size = ::read(fd_, scratch, n); in Read()
118 if (read_size < 0) { // Read error. in Read()
125 *result = Slice(scratch, read_size); in Read()
184 ssize_t read_size = ::pread(fd, scratch, n, static_cast<off_t>(offset)); in Read() local
185 *result = Slice(scratch, (read_size < 0) ? 0 : read_size); in Read()
186 if (read_size < 0) { in Read()
/external/mesa3d/src/gallium/auxiliary/util/
Du_prim_restart.c47 unsigned read_size = 3 * sizeof(uint32_t); in read_indirect_elements() local
51 read_size, in read_indirect_elements()
55 memcpy(&ret, map, read_size); in read_indirect_elements()

1234