Home
last modified time | relevance | path

Searched refs:nread (Results 1 - 25 of 296) sorted by relevance

12345678910>>...12

/third_party/node/deps/ngtcp2/ngtcp2/lib/
H A Dngtcp2_crypto.c458 ngtcp2_ssize nread; in decode_varint_param() local
462 nread = decode_varint(&valuelen, p, end); in decode_varint_param()
463 if (nread < 0) { in decode_varint_param()
467 p += nread; in decode_varint_param()
499 ngtcp2_ssize nread = decode_varint(&valuelen, p, end); in decode_cid_param() local
501 if (nread < 0) { in decode_cid_param()
505 p += nread; in decode_cid_param()
526 ngtcp2_ssize nread; in ngtcp2_decode_transport_params_versioned() local
563 nread = decode_varint(&param_type, p, end); in ngtcp2_decode_transport_params_versioned()
564 if (nread < in ngtcp2_decode_transport_params_versioned()
[all...]
/third_party/node/test/parallel/
H A Dtest-tls-onread-static-buffer.js32 callback: function(nread, buf) {
34 received += nread;
35 buffers.push(Buffer.from(buf.slice(0, nread)));
57 callback: function(nread, buf) {
59 received += nread;
60 const newIncoming = new Uint8Array(incoming.length + nread);
62 newIncoming.set(buf.slice(0, nread), incoming.length);
91 callback: function(nread, buf) {
93 received += nread;
94 incoming.push(Buffer.from(buf.slice(0, nread)));
[all...]
/third_party/nghttp2/src/
H A Dshrpx_connection.cc223 auto nread = conn->read_clear(buf, len); in shrpx_bio_read() local
224 if (nread < 0) { in shrpx_bio_read()
227 if (nread == 0) { in shrpx_bio_read()
231 return nread; in shrpx_bio_read()
352 auto nread = read_clear(buf.data(), buf.size()); in tls_handshake() local
353 if (nread < 0) { in tls_handshake()
359 tls.rbuf.append(buf.data(), nread); in tls_handshake()
415 size_t nread; in tls_handshake() local
417 rv = SSL_read_early_data(tls.ssl, buf.data(), buf.size(), &nread); in tls_handshake()
436 LOG(INFO) << "tls: read early data " << nread << " byte in tls_handshake()
555 auto nread = SSL_read(tls.ssl, buf.data(), buf.size()); tls_handshake() local
626 size_t nread; tls_handshake_simple() local
710 auto nread = SSL_read(tls.ssl, buf.data(), buf.size()); tls_handshake_simple() local
1029 size_t nread; read_tls() local
1167 ssize_t nread; read_clear() local
1187 ssize_t nread; read_nolim_clear() local
1205 ssize_t nread; peek_clear() local
[all...]
H A Dshrpx_router_test.cc162 size_t nread; in test_shrpx_router_match_prefix() local
166 idx = router.match_prefix(&nread, &node, in test_shrpx_router_match_prefix()
170 CU_ASSERT(12 == nread); in test_shrpx_router_match_prefix()
172 idx = router.match_prefix(&nread, &node, in test_shrpx_router_match_prefix()
176 CU_ASSERT(4 == nread); in test_shrpx_router_match_prefix()
178 idx = router.match_prefix(&nread, &node, StringRef::from_lit("ahpla.ovarb")); in test_shrpx_router_match_prefix()
181 CU_ASSERT(6 == nread); in test_shrpx_router_match_prefix()
/third_party/elfutils/libdwfl/
H A Dlinux-proc-maps.c72 ssize_t nread = pread_retry (fd, &buf, sizeof buf, 0); in get_pid_class() local
74 if (nread != sizeof buf || buf[EI_MAG0] != ELFMAG0 in get_pid_class()
112 ssize_t nread; in grovel_auxv() local
121 nread = pread_retry (fd, d.a64, sizeof d.a64, offset); in grovel_auxv()
122 if (nread < 0) in grovel_auxv()
128 for (size_t a32i = 0; a32i < nread / sizeof d.a32[0]; a32i++) in grovel_auxv()
141 for (size_t a64i = 0; a64i < nread / sizeof d.a64[0]; a64i++) in grovel_auxv()
154 offset += nread; in grovel_auxv()
156 while (nread == sizeof d.a64); in grovel_auxv()
218 int nread in proc_maps_report() local
[all...]
/third_party/node/deps/ngtcp2/nghttp3/lib/
H A Dnghttp3_conn.c484 nghttp3_ssize nread; in conn_read_type() local
489 nread = nghttp3_read_varint(rvint, src, srclen, fin); in conn_read_type()
490 if (nread < 0) { in conn_read_type()
495 return nread; in conn_read_type()
533 return nread; in conn_read_type()
541 nghttp3_ssize nread = 0; in nghttp3_conn_read_uni() local
561 nread = conn_read_type(conn, stream, src, srclen, fin); in nghttp3_conn_read_uni()
562 if (nread < 0) { in nghttp3_conn_read_uni()
563 return (int)nread; in nghttp3_conn_read_uni()
566 assert((size_t)nread in nghttp3_conn_read_uni()
628 nghttp3_ssize nread; nghttp3_conn_read_control() local
1177 nghttp3_ssize nread; nghttp3_conn_read_bidi() local
1529 nghttp3_ssize nread; conn_decode_headers() local
[all...]
/third_party/libuv/docs/code/multi-echo-server/
H A Dworker.c34 void echo_read(uv_stream_t *client, ssize_t nread, const uv_buf_t *buf) { in echo_read() argument
35 if (nread > 0) { in echo_read()
37 req->buf = uv_buf_init(buf->base, nread); in echo_read()
42 if (nread < 0) { in echo_read()
43 if (nread != UV_EOF) in echo_read()
44 fprintf(stderr, "Read error %s\n", uv_err_name(nread)); in echo_read()
51 void on_new_connection(uv_stream_t *q, ssize_t nread, const uv_buf_t *buf) { in on_new_connection() argument
52 if (nread < 0) { in on_new_connection()
53 if (nread != UV_EOF) in on_new_connection()
54 fprintf(stderr, "Read error %s\n", uv_err_name(nread)); in on_new_connection()
[all...]
/third_party/node/src/
H A Dstring_decoder.cc71 size_t nread = *nread_ptr; in DecodeData() local
89 for (size_t i = 0; i < nread && i < MissingBytes(); ++i) { in DecodeData()
99 nread -= i; in DecodeData()
106 std::min(nread, static_cast<size_t>(MissingBytes())); in DecodeData()
112 nread -= found_bytes; in DecodeData()
135 if (UNLIKELY(nread == 0)) { in DecodeData()
145 if (Encoding() == UTF8 && data[nread - 1] & 0x80) { in DecodeData()
149 for (size_t i = nread - 1; ; --i) { in DecodeData()
150 DCHECK_LT(i, nread); in DecodeData()
195 if ((nread in DecodeData()
215 memcpy(IncompleteCharacterBuffer(), data + nread, BufferedBytes()); DecodeData() local
[all...]
/third_party/curl/tests/http/clients/
H A Dws-data.c106 size_t r_offset, nread; in recv_binary() local
112 result = curl_ws_recv(curl, recvbuf, sizeof(recvbuf), &nread, &frame); in recv_binary()
119 (long)r_offset, (long)sizeof(recvbuf), result, (long)nread); in recv_binary()
125 (long)nread, frame->flags); in recv_binary()
133 if(frame->bytesleft != (curl_off_t)(exp_len - r_offset - nread)) { in recv_binary()
135 (long)(exp_len - r_offset - nread), (long)frame->bytesleft); in recv_binary()
138 if(r_offset + nread > exp_len) { in recv_binary()
140 (long)exp_len, (long)(r_offset + nread)); in recv_binary()
143 if(memcmp(exp_data + r_offset, recvbuf, nread)) { in recv_binary()
145 (long)r_offset, (long)nread); in recv_binary()
[all...]
/third_party/libuv/test/
H A Dtest-ipc.c144 ssize_t nread, in on_read()
153 if (nread == 0) { in on_read()
159 if (nread < 0) { in on_read()
160 if (nread == UV_EOF) { in on_read()
165 printf("error recving on channel: %s\n", uv_strerror(nread)); in on_read()
169 fprintf(stderr, "got %d bytes\n", (int)nread); in on_read()
174 ASSERT_GT(nread, 0); in on_read()
193 ASSERT_MEM_EQ("hello\n", buf->base, nread); in on_read()
201 } else if (memcmp("accepted_connection\n", buf->base, nread) == 0) { in on_read()
214 ssize_t nread, in on_read_listen_after_bound_twice()
143 on_read(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) on_read() argument
213 on_read_listen_after_bound_twice(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) on_read_listen_after_bound_twice() argument
337 on_tcp_read(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) on_tcp_read() argument
350 on_read_connection(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) on_read_connection() argument
409 on_read_send_zero(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) on_read_send_zero() argument
570 on_tcp_child_process_read(uv_stream_t* tcp, ssize_t nread, const uv_buf_t* buf) on_tcp_child_process_read() argument
[all...]
H A Dtest-udp-send-and-recv.c63 ssize_t nread, in cl_recv_cb()
70 if (nread < 0) { in cl_recv_cb()
74 if (nread == 0) { in cl_recv_cb()
81 ASSERT_EQ(4, nread); in cl_recv_cb()
82 ASSERT(!memcmp("PONG", buf->base, nread)); in cl_recv_cb()
117 ssize_t nread, in sv_recv_cb()
125 if (nread < 0) { in sv_recv_cb()
129 if (nread == 0) { in sv_recv_cb()
139 ASSERT_EQ(4, nread); in sv_recv_cb()
140 ASSERT(!memcmp("PING", rcvbuf->base, nread)); in sv_recv_cb()
62 cl_recv_cb(uv_udp_t* handle, ssize_t nread, const uv_buf_t* buf, const struct sockaddr* addr, unsigned flags) cl_recv_cb() argument
116 sv_recv_cb(uv_udp_t* handle, ssize_t nread, const uv_buf_t* rcvbuf, const struct sockaddr* addr, unsigned flags) sv_recv_cb() argument
[all...]
H A Decho-server.c43 static void after_read(uv_stream_t*, ssize_t nread, const uv_buf_t* buf);
81 ssize_t nread, in after_read()
88 if (nread < 0) { in after_read()
90 ASSERT_EQ(nread, UV_EOF); in after_read()
100 if (nread == 0) { in after_read()
112 for (i = 0; i < nread; i++) { in after_read()
114 if (i + 1 < nread && buf->base[i + 1] == 'S') { in after_read()
116 if (i + 2 < nread && buf->base[i + 2] == 'S') in after_read()
118 if (i + 2 < nread && buf->base[i + 2] == 'H') in after_read()
137 wr->buf = uv_buf_init(buf->base, nread); in after_read()
80 after_read(uv_stream_t* handle, ssize_t nread, const uv_buf_t* buf) after_read() argument
229 on_recv(uv_udp_t* handle, ssize_t nread, const uv_buf_t* rcvbuf, const struct sockaddr* addr, unsigned flags) on_recv() argument
[all...]
H A Dtest-udp-ipv6.c110 ssize_t nread, in ipv6_recv_fail()
114 printf("got %d %.*s\n", (int) nread, nread > 0 ? (int) nread : 0, buf->base); in ipv6_recv_fail()
115 if (!is_from_client(addr) || (nread == 0 && addr == NULL)) in ipv6_recv_fail()
122 ssize_t nread, in ipv6_recv_ok()
128 printf("got %d %.*s\n", (int) nread, nread > 0 ? (int) nread : 0, buf->base); in ipv6_recv_ok()
129 if (!is_from_client(addr) || (nread in ipv6_recv_ok()
109 ipv6_recv_fail(uv_udp_t* handle, ssize_t nread, const uv_buf_t* buf, const struct sockaddr* addr, unsigned flags) ipv6_recv_fail() argument
121 ipv6_recv_ok(uv_udp_t* handle, ssize_t nread, const uv_buf_t* buf, const struct sockaddr* addr, unsigned flags) ipv6_recv_ok() argument
[all...]
H A Dtest-udp-alloc-cb-fail.c69 ssize_t nread, in cl_recv_cb()
75 ASSERT_EQ(nread, UV_ENOBUFS); in cl_recv_cb()
110 ssize_t nread, in sv_recv_cb()
118 if (nread < 0) { in sv_recv_cb()
122 if (nread == 0) { in sv_recv_cb()
132 ASSERT_EQ(4, nread); in sv_recv_cb()
133 ASSERT(!memcmp("PING", rcvbuf->base, nread)); in sv_recv_cb()
68 cl_recv_cb(uv_udp_t* handle, ssize_t nread, const uv_buf_t* buf, const struct sockaddr* addr, unsigned flags) cl_recv_cb() argument
109 sv_recv_cb(uv_udp_t* handle, ssize_t nread, const uv_buf_t* rcvbuf, const struct sockaddr* addr, unsigned flags) sv_recv_cb() argument
/third_party/libuv/docs/code/dns/
H A Dmain.c13 void on_read(uv_stream_t *client, ssize_t nread, const uv_buf_t *buf) { in on_read() argument
14 if (nread < 0) { in on_read()
15 if (nread != UV_EOF) in on_read()
16 fprintf(stderr, "Read error %s\n", uv_err_name(nread)); in on_read()
23 char *data = (char*) malloc(sizeof(char) * (nread+1)); in on_read()
24 data[nread] = '\0'; in on_read()
25 strncpy(data, buf->base, nread); in on_read()
/third_party/libinput/src/
H A Dbuilddir.h40 ssize_t nread; in builddir_lookup() local
47 nread = readlink("/proc/self/exe", execdir, sizeof(execdir) - 1); in builddir_lookup()
48 if (nread <= 0 || nread == sizeof(execdir) - 1) in builddir_lookup()
53 execdir[nread] = '\0'; in builddir_lookup()
/third_party/toybox/toys/posix/
H A Dstrings.c41 int nread, i, wlen = TT.n, count = 0; in do_strings() local
52 for (i = nread = 0; ;i++) { in do_strings()
53 if (i >= nread) { in do_strings()
54 nread = read(fd, toybuf, sizeof(toybuf)); in do_strings()
56 if (nread < 0) perror_msg_raw(filename); in do_strings()
57 if (nread < 1) { in do_strings()
/third_party/wpa_supplicant/wpa_supplicant-2.9/src/wps/
H A Dhttpread.c370 int nread; in httpread_read_handler() local
380 nread = read(h->sd, readbuf, sizeof(readbuf)); in httpread_read_handler()
381 if (nread < 0) { in httpread_read_handler()
385 wpa_hexdump_ascii(MSG_MSGDUMP, "httpread - read", readbuf, nread); in httpread_read_handler()
386 if (nread == 0) { in httpread_read_handler()
425 if (nread == 0) in httpread_read_handler()
433 nread--; in httpread_read_handler()
480 if (nread == 0) in httpread_read_handler()
487 if (h->body_alloc_nbytes < (h->body_nbytes + nread + 1)) { in httpread_read_handler()
601 if (nread < in httpread_read_handler()
[all...]
/third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/wps/
H A Dhttpread.c370 int nread; in httpread_read_handler() local
380 nread = read(h->sd, readbuf, sizeof(readbuf)); in httpread_read_handler()
381 if (nread < 0) { in httpread_read_handler()
385 wpa_hexdump_ascii(MSG_MSGDUMP, "httpread - read", readbuf, nread); in httpread_read_handler()
386 if (nread == 0) { in httpread_read_handler()
425 if (nread == 0) in httpread_read_handler()
433 nread--; in httpread_read_handler()
480 if (nread == 0) in httpread_read_handler()
487 if (h->body_alloc_nbytes < (h->body_nbytes + nread + 1)) { in httpread_read_handler()
601 if (nread < in httpread_read_handler()
[all...]
/third_party/libuv/docs/code/tcp-echo-server/
H A Dmain.c39 void echo_read(uv_stream_t *client, ssize_t nread, const uv_buf_t *buf) { in echo_read() argument
40 if (nread > 0) { in echo_read()
42 req->buf = uv_buf_init(buf->base, nread); in echo_read()
46 if (nread < 0) { in echo_read()
47 if (nread != UV_EOF) in echo_read()
48 fprintf(stderr, "Read error %s\n", uv_err_name(nread)); in echo_read()
/third_party/curl/lib/
H A Dhttp1.c106 ssize_t nread = 0; in next_line() local
114 nread = detect_line(parser, buf, buflen, err); in next_line()
115 if(nread >= 0) { in next_line()
131 nread = (*err)? -1 : (ssize_t)buflen; in next_line()
133 return nread; in next_line()
266 ssize_t nread = 0, n; in Curl_h1_req_parse_read() local
273 nread = -1; in Curl_h1_req_parse_read()
280 nread += (size_t)n; in Curl_h1_req_parse_read()
292 nread = -1; in Curl_h1_req_parse_read()
300 nread in Curl_h1_req_parse_read()
[all...]
H A Dbufq.c100 ssize_t nread; in chunk_slurpn() local
109 nread = reader(reader_ctx, p, n, err); in chunk_slurpn()
110 if(nread > 0) { in chunk_slurpn()
111 DEBUGASSERT((size_t)nread <= n); in chunk_slurpn()
112 chunk->w_offset += nread; in chunk_slurpn()
114 return nread; in chunk_slurpn()
423 ssize_t nread = 0; in Curl_bufq_read() local
430 nread += n; in Curl_bufq_read()
436 if(nread == 0) { in Curl_bufq_read()
440 return nread; in Curl_bufq_read()
580 ssize_t nread; Curl_bufq_sipn() local
618 ssize_t nread = 0, n; bufq_slurpn() local
[all...]
H A Dfile.c344 size_t nread; in file_upload() local
355 nread = readcount; in file_upload()
359 if((curl_off_t)nread <= data->state.resume_from) { in file_upload()
360 data->state.resume_from -= nread; in file_upload()
361 nread = 0; in file_upload()
366 nread -= (size_t)data->state.resume_from; in file_upload()
374 nwrite = write(fd, sendbuf, nread); in file_upload()
375 if((size_t)nwrite != nread) { in file_upload()
380 bytecount += nread; in file_upload()
548 ssize_t nread; in file_do() local
[all...]
H A Dtransfer.c165 size_t nread; in Curl_fillreadbuffer() local
237 nread = readfunc(data->req.upload_fromhere, 1, buffersize, extra_data); in Curl_fillreadbuffer()
240 data->req.fread_eof[eof_index] = !nread; in Curl_fillreadbuffer()
243 nread = 0; in Curl_fillreadbuffer()
245 if(nread == CURL_READFUNC_ABORT) { in Curl_fillreadbuffer()
250 if(nread == CURL_READFUNC_PAUSE) { in Curl_fillreadbuffer()
271 else if(nread > buffersize) { in Curl_fillreadbuffer()
318 "%zx%s", nread, endofline_native); in Curl_fillreadbuffer()
322 nread += hexlen; in Curl_fillreadbuffer()
329 if((nread in Curl_fillreadbuffer()
430 ssize_t nread; Curl_xfer_recv_resp() local
483 ssize_t nread; readwrite_data() local
617 ssize_t nread; /* number of bytes read */ readwrite_upload() local
[all...]
/third_party/libunwind/libunwind/src/
H A Dos-linux.h209 ssize_t i, nread; in maps_next() local
236 nread = read (mi->fd, mi->buf + bytes_left, in maps_next()
238 if (nread <= 0) in maps_next()
240 else if ((size_t) (nread + bytes_left) < mi->buf_size) in maps_next()
245 memmove (mi->buf_end - nread - bytes_left, mi->buf, in maps_next()
246 nread + bytes_left); in maps_next()
247 mi->buf = mi->buf_end - nread - bytes_left; in maps_next()
250 eol = mi->buf + bytes_left + nread - 1; in maps_next()
252 for (i = bytes_left; i < bytes_left + nread; ++i) in maps_next()

Completed in 15 milliseconds

12345678910>>...12