Home
last modified time | relevance | path

Searched refs:nread (Results 176 - 200 of 343) sorted by relevance

12345678910>>...14

/third_party/libuv/test/
H A Dtest-getsockname.c65 ssize_t nread, in after_read()
240 ssize_t nread, in udp_recv()
248 ASSERT_GE(nread, 0); in udp_recv()
251 if (nread == 0) { in udp_recv()
64 after_read(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) after_read() argument
239 udp_recv(uv_udp_t* handle, ssize_t nread, const uv_buf_t* buf, const struct sockaddr* addr, unsigned flags) udp_recv() argument
H A Dbenchmark-multi-accept.c87 ssize_t nread,
95 static void sv_read_cb(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf);
174 ssize_t nread, in ipc_read_cb()
323 ssize_t nread, in sv_read_cb()
325 ASSERT_EQ(nread, UV_EOF); in sv_read_cb()
173 ipc_read_cb(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) ipc_read_cb() argument
322 sv_read_cb(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) sv_read_cb() argument
H A Dtest-tcp-oob.c58 static void read_cb(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) { in read_cb() argument
64 ASSERT_GE(nread, 0); in read_cb()
70 * triggered on every poll with nread = 0. in read_cb()
H A Dtest-tcp-alloc-cb-fail.c53 ssize_t nread, in conn_read_cb()
55 ASSERT_EQ(nread, UV_ENOBUFS); in conn_read_cb()
52 conn_read_cb(uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) conn_read_cb() argument
H A Dtest-pipe-sendmsg.c74 ssize_t nread, in read_cb()
82 ASSERT_GE(nread, 0); in read_cb()
73 read_cb(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) read_cb() argument
/third_party/ltp/testcases/kernel/io/direct_io/
H A Ddma_thread_diotest.c160 int nread; in worker_thread() local
174 nread = read(fd, buffer, length); in worker_thread()
175 if (nread == -1 || nread != length) { in worker_thread()
/third_party/nghttp2/src/
H A Dshrpx_http_downstream_connection.cc1255 auto nread = conn_.read_clear(buf.data(), buf.size()); in read_clear() local
1256 if (nread == 0) { in read_clear()
1260 if (nread < 0) { in read_clear()
1261 if (nread == SHRPX_ERR_EOF && !downstream_->get_upgraded()) { in read_clear()
1273 return nread; in read_clear()
1276 rv = process_input(buf.data(), nread); in read_clear()
1386 auto nread = conn_.read_tls(buf.data(), buf.size()); in read_tls() local
1387 if (nread == 0) { in read_tls()
1391 if (nread < 0) { in read_tls()
1392 if (nread in read_tls()
[all...]
H A Dshrpx_router.cc350 const RNode *match_prefix(size_t *nread, const RNode *node, const char *first, in match_prefix() argument
375 *nread = p - first; in match_prefix()
382 *nread = p - first; in match_prefix()
391 ssize_t Router::match_prefix(size_t *nread, const RNode **last_node, in match_prefix() argument
398 ::shrpx::match_prefix(nread, *last_node, std::begin(s), std::end(s)); in match_prefix()
/third_party/node/src/
H A Dspawn_sync.h47 inline void OnRead(const uv_buf_t* buf, size_t nread);
101 inline void OnRead(const uv_buf_t* buf, ssize_t nread);
112 ssize_t nread,
H A Dudp_wrap.h48 // information about the source address. If `nread` is negative, an error
50 virtual void OnRecv(ssize_t nread,
154 void OnRecv(ssize_t nread,
207 ssize_t nread,
H A Dstream_wrap.cc209 [](uv_stream_t* stream, ssize_t nread, const uv_buf_t* buf) { in ReadStart() member
213 wrap->OnUvRead(nread, buf); in ReadStart()
254 Maybe<void> LibuvStreamWrap::OnUvRead(ssize_t nread, const uv_buf_t* buf) { in OnUvRead() argument
268 if (nread > 0) { in OnUvRead()
293 EmitRead(nread, *buf); in OnUvRead()
/third_party/node/deps/base64/base64/test/
H A Dbenchmark.c93 ssize_t nread; in get_random_data()
105 if ((nread = read(fd, b->reg + total_read, b->regsz - total_read)) < 0) { in get_random_data()
110 total_read += nread; in get_random_data()
/third_party/node/deps/ngtcp2/ngtcp2/lib/
H A Dngtcp2_conn.c6149 ngtcp2_ssize nread; in conn_recv_handshake_pkt() local
6197 nread = ngtcp2_pkt_decode_hd_long(&hd, pkt, pktlen); in conn_recv_handshake_pkt()
6198 if (nread < 0) { in conn_recv_handshake_pkt()
6203 hdpktlen = (size_t)nread; in conn_recv_handshake_pkt()
6239 hdpktlen = (size_t)nread; in conn_recv_handshake_pkt()
6267 if (pktlen < (size_t)nread + hd.len) { in conn_recv_handshake_pkt()
6271 pktlen = (size_t)nread + hd.len; in conn_recv_handshake_pkt()
6465 rv = conn_ensure_decrypt_hp_buffer(conn, (size_t)nread + 4); in conn_recv_handshake_pkt()
6471 (size_t)nread, hp_ctx, hp_mask); in conn_recv_handshake_pkt()
6593 nread in conn_recv_handshake_pkt()
6720 ngtcp2_ssize nread; conn_recv_handshake_cpkt() local
8614 ngtcp2_ssize nread; conn_recv_delayed_handshake_pkt() local
8754 ngtcp2_ssize nread, nwrite; conn_recv_pkt() local
9337 ngtcp2_ssize nread; conn_process_buffered_protected_pkt() local
9384 ngtcp2_ssize nread; conn_process_buffered_handshake_pkt() local
9508 ngtcp2_ssize nread; conn_recv_cpkt() local
9614 ngtcp2_ssize nread; conn_read_handshake() local
9813 ngtcp2_ssize nread = 0; ngtcp2_conn_read_pkt_versioned() local
10370 ngtcp2_ssize nread; ngtcp2_accept() local
[all...]
/kernel/linux/linux-5.10/drivers/infiniband/hw/hfi1/
H A Dpio_copy.c475 unsigned long nread; in mid_copy_mix() local
478 nread = 8 - pbuf->carry_bytes; in mid_copy_mix()
479 read_extra_bytes(pbuf, from, nread); in mid_copy_mix()
504 bytes_left -= nread; in mid_copy_mix()
505 from += nread; /* from is now not aligned */ in mid_copy_mix()
/kernel/linux/linux-6.6/drivers/infiniband/hw/hfi1/
H A Dpio_copy.c434 unsigned long nread; in mid_copy_mix() local
437 nread = 8 - pbuf->carry_bytes; in mid_copy_mix()
438 read_extra_bytes(pbuf, from, nread); in mid_copy_mix()
463 bytes_left -= nread; in mid_copy_mix()
464 from += nread; /* from is now not aligned */ in mid_copy_mix()
/third_party/backends/backend/
H A Dhp-handle.c657 ssize_t nread; in sanei_hp_handle_read() local
682 if ((nread = read(this->pipe_read_fd, buf, *lengthp)) < 0) in sanei_hp_handle_read()
693 this->bytes_left -= (*lengthp = nread); in sanei_hp_handle_read()
695 if (nread > 0) in sanei_hp_handle_read()
697 DBG(3, "sanei_hp_handle_read: read %lu bytes\n", (unsigned long) nread); in sanei_hp_handle_read()
/third_party/node/deps/icu-small/source/tools/toolutil/
H A Dpkg_gencmn.cpp127 uint32_t i, fileOffset, basenameOffset, length, nread; in createCommonDataFile() local
280 for(nread = 0;;) { in createCommonDataFile()
285 nread += length; in createCommonDataFile()
291 if (nread != files[i].fileSize) { in createCommonDataFile()
292 fprintf(stderr, "gencmn: unable to read %s properly (got %ld/%ld byte%s)\n", files[i].pathname, (long)nread, (long)files[i].fileSize, files[i].fileSize == 1 ? "" : "s"); in createCommonDataFile()
/third_party/icu/icu4c/source/tools/toolutil/
H A Dpkg_gencmn.cpp127 uint32_t i, fileOffset, basenameOffset, length, nread; in createCommonDataFile() local
280 for(nread = 0;;) { in createCommonDataFile()
285 nread += length; in createCommonDataFile()
291 if (nread != files[i].fileSize) { in createCommonDataFile()
292 fprintf(stderr, "gencmn: unable to read %s properly (got %ld/%ld byte%s)\n", files[i].pathname, (long)nread, (long)files[i].fileSize, files[i].fileSize == 1 ? "" : "s"); in createCommonDataFile()
/third_party/skia/third_party/externals/icu/source/tools/toolutil/
H A Dpkg_gencmn.cpp127 uint32_t i, fileOffset, basenameOffset, length, nread; in createCommonDataFile() local
280 for(nread = 0;;) { in createCommonDataFile()
285 nread += length; in createCommonDataFile()
291 if (nread != files[i].fileSize) { in createCommonDataFile()
292 fprintf(stderr, "gencmn: unable to read %s properly (got %ld/%ld byte%s)\n", files[i].pathname, (long)nread, (long)files[i].fileSize, files[i].fileSize == 1 ? "" : "s"); in createCommonDataFile()
/third_party/backends/sanei/
H A Dsanei_wire.c58 ssize_t nread, nwritten; in sanei_w_space() local
123 nread = (*w->io.read) (fd, w->buffer.end, in sanei_w_space()
125 if (nread <= 0) in sanei_w_space()
129 if (nread == 0) in sanei_w_space()
134 left_over += nread; in sanei_w_space()
135 w->buffer.end += nread; in sanei_w_space()
/third_party/curl/lib/
H A Dformdata.c726 size_t nread = Curl_mime_read(buffer, 1, sizeof(buffer), &toppart); in curl_formget() local
728 if(!nread) in curl_formget()
731 if(nread > sizeof(buffer) || append(arg, buffer, nread) != nread) { in curl_formget()
733 if(nread == CURL_READFUNC_ABORT) in curl_formget()
H A Drand.c157 ssize_t nread = read(fd, &randseed, sizeof(randseed)); in randit() local
158 if(nread == sizeof(randseed)) in randit()
/third_party/node/benchmark/net/
H A Dnet-s2c.js66 callback: function(nread, buf) {
67 received += nread;
/kernel/linux/linux-5.10/tools/testing/selftests/bpf/prog_tests/
H A Dselect_reuseport.c411 ssize_t nread; in do_test() local
445 nread = recv(new_fd, &rcv_cmd, sizeof(rcv_cmd), MSG_DONTWAIT); in do_test()
446 RET_IF(nread != sizeof(rcv_cmd), in do_test()
448 "ev.data.u32:%u nread:%zd sizeof(rcv_cmd):%zu errno:%d\n", in do_test()
449 ev.data.u32, nread, sizeof(rcv_cmd), errno); in do_test()
453 nread = recv(srv_fd, &rcv_cmd, sizeof(rcv_cmd), MSG_DONTWAIT); in do_test()
454 RET_IF(nread != sizeof(rcv_cmd), in do_test()
456 "ev.data.u32:%u nread:%zd sizeof(rcv_cmd):%zu errno:%d\n", in do_test()
457 ev.data.u32, nread, sizeof(rcv_cmd), errno); in do_test()
/kernel/linux/linux-6.6/tools/testing/selftests/bpf/prog_tests/
H A Dselect_reuseport.c402 ssize_t nread; in do_test() local
436 nread = recv(new_fd, &rcv_cmd, sizeof(rcv_cmd), MSG_DONTWAIT); in do_test()
437 RET_IF(nread != sizeof(rcv_cmd), in do_test()
439 "ev.data.u32:%u nread:%zd sizeof(rcv_cmd):%zu errno:%d\n", in do_test()
440 ev.data.u32, nread, sizeof(rcv_cmd), errno); in do_test()
444 nread = recv(srv_fd, &rcv_cmd, sizeof(rcv_cmd), MSG_DONTWAIT); in do_test()
445 RET_IF(nread != sizeof(rcv_cmd), in do_test()
447 "ev.data.u32:%u nread:%zd sizeof(rcv_cmd):%zu errno:%d\n", in do_test()
448 ev.data.u32, nread, sizeof(rcv_cmd), errno); in do_test()

Completed in 30 milliseconds

12345678910>>...14