Home
last modified time | relevance | path

Searched refs:nwritten (Results 1 – 25 of 43) sorted by relevance

12

/third_party/ltp/testcases/kernel/sched/clisrv/
Dwriten.c30 int nleft, nwritten; in writen() local
34 nwritten = write(fd, ptr, nleft); in writen()
35 if (nwritten <= 0) in writen()
36 return (nwritten); /* error */ in writen()
37 nleft -= nwritten; in writen()
38 ptr += nwritten; in writen()
/third_party/curl/tests/unit/
Dunit2601.c100 size_t nwritten, nread; in check_bufq() local
123 nwritten = 0; in check_bufq()
128 nwritten += (size_t)n; in check_bufq()
135 if(nwritten != max_len) { in check_bufq()
137 nwritten, max_len); in check_bufq()
156 nwritten, max_len); in check_bufq()
181 nwritten = 0; in check_bufq()
188 nwritten += (size_t)n; in check_bufq()
190 if(nwritten < max_len) { in check_bufq()
192 nwritten, max_len); in check_bufq()
[all …]
/third_party/curl/lib/vquic/
Dcurl_quiche.c274 ssize_t nwritten; in write_resp_raw() local
279 nwritten = Curl_bufq_write(&stream->recvbuf, mem, memlen, &result); in write_resp_raw()
280 if(nwritten < 0) in write_resp_raw()
283 if((size_t)nwritten < memlen) { in write_resp_raw()
366 ssize_t nwritten; in cf_recv_body() local
382 nwritten = Curl_bufq_slurp(&stream->recvbuf, in cf_recv_body()
385 if(nwritten < 0 && result != CURLE_AGAIN) { in cf_recv_body()
387 stream->id, nwritten); in cf_recv_body()
627 ssize_t nwritten; in read_pkt_to_send() local
629 nwritten = quiche_conn_send(ctx->qconn, buf, buflen, &x->send_info); in read_pkt_to_send()
[all …]
Dcurl_osslq.c665 ssize_t nwritten; in write_resp_raw() local
671 nwritten = Curl_bufq_write(&stream->recvbuf, mem, memlen, &result); in write_resp_raw()
672 if(nwritten < 0) { in write_resp_raw()
677 stream->recv_buf_nonflow += (size_t)nwritten; in write_resp_raw()
679 if((size_t)nwritten < memlen) { in write_resp_raw()
871 ssize_t nwritten = 0; in cb_h3_read_req_body() local
896 nwritten += vec[nvecs].len; in cb_h3_read_req_body()
902 if(nwritten > 0 && stream->upload_left != -1) in cb_h3_read_req_body()
903 stream->upload_left -= nwritten; in cb_h3_read_req_body()
911 else if(!nwritten) { in cb_h3_read_req_body()
[all …]
Dcurl_msh3.c316 ssize_t nwritten; in write_resp_raw() local
321 nwritten = Curl_bufq_write(&stream->recvbuf, mem, memlen, &result); in write_resp_raw()
322 if(nwritten < 0) { in write_resp_raw()
326 if((size_t)nwritten < memlen) { in write_resp_raw()
578 ssize_t nwritten = -1; in cf_msh3_send() local
595 nwritten = Curl_h1_req_parse_read(&h1, buf, len, NULL, 0, err); in cf_msh3_send()
596 if(nwritten < 0) in cf_msh3_send()
603 nwritten = -1; in cf_msh3_send()
611 nwritten = -1; in cf_msh3_send()
649 nwritten = len; in cf_msh3_send()
[all …]
Dcurl_ngtcp2.c811 ssize_t nwritten; in write_resp_raw() local
817 nwritten = Curl_bufq_write(&stream->recvbuf, mem, memlen, &result); in write_resp_raw()
818 if(nwritten < 0) { in write_resp_raw()
823 stream->recv_buf_nonflow += (size_t)nwritten; in write_resp_raw()
825 if((size_t)nwritten < memlen) { in write_resp_raw()
1239 ssize_t nwritten = 0; in cb_h3_read_req_body() local
1264 nwritten += vec[nvecs].len; in cb_h3_read_req_body()
1270 if(nwritten > 0 && stream->upload_left != -1) in cb_h3_read_req_body()
1271 stream->upload_left -= nwritten; in cb_h3_read_req_body()
1279 else if(!nwritten) { in cb_h3_read_req_body()
[all …]
/third_party/curl/lib/
Dws.c264 ssize_t nwritten; in ws_dec_pass_payload() local
272 nwritten = write_payload(inbuf, inlen, dec->frame_age, dec->frame_flags, in ws_dec_pass_payload()
275 if(nwritten < 0) in ws_dec_pass_payload()
277 Curl_bufq_skip(inraw, (size_t)nwritten); in ws_dec_pass_payload()
278 dec->payload_offset += (curl_off_t)nwritten; in ws_dec_pass_payload()
318 ssize_t nwritten; in ws_dec_pass() local
321 nwritten = write_payload(&tmp, 0, dec->frame_age, dec->frame_flags, in ws_dec_pass()
323 if(nwritten < 0) in ws_dec_pass()
440 ssize_t nwritten; in ws_cw_write() local
441 nwritten = Curl_bufq_write(&ctx->buf, (const unsigned char *)buf, in ws_cw_write()
[all …]
Dcf-h2-proxy.c256 ssize_t nwritten; in proxy_h2_nw_out_writer() local
260 nwritten = Curl_conn_cf_send(cf->next, data, (const char *)buf, buflen, in proxy_h2_nw_out_writer()
263 buflen, nwritten, *err); in proxy_h2_nw_out_writer()
266 nwritten = 0; in proxy_h2_nw_out_writer()
268 return nwritten; in proxy_h2_nw_out_writer()
411 ssize_t nwritten; in proxy_h2_nw_out_flush() local
418 nwritten = Curl_bufq_pass(&ctx->outbufq, proxy_h2_nw_out_writer, cf, in proxy_h2_nw_out_flush()
420 if(nwritten < 0) { in proxy_h2_nw_out_flush()
544 ssize_t nwritten; in on_session_send() local
551 nwritten = Curl_bufq_write_pass(&ctx->outbufq, buf, blen, in on_session_send()
[all …]
Dhttp2.c374 ssize_t nwritten = Curl_conn_cf_send(cf->next, data, in nw_out_writer() local
376 if(nwritten > 0) in nw_out_writer()
377 CURL_TRC_CF(data, cf, "[0] egress: wrote %zd bytes", nwritten); in nw_out_writer()
378 return nwritten; in nw_out_writer()
661 ssize_t nwritten; in nw_out_flush() local
668 nwritten = Curl_bufq_pass(&ctx->outbufq, nw_out_writer, cf, &result); in nw_out_flush()
669 if(nwritten < 0) { in nw_out_flush()
692 ssize_t nwritten; in send_callback() local
699 nwritten = Curl_bufq_write_pass(&ctx->outbufq, buf, blen, in send_callback()
701 if(nwritten < 0) { in send_callback()
[all …]
Dbufq.c392 ssize_t nwritten = 0; in Curl_bufq_write() local
408 nwritten += n; in Curl_bufq_write()
412 if(nwritten == 0 && len) { in Curl_bufq_write()
417 return nwritten; in Curl_bufq_write()
497 ssize_t nwritten = 0; in Curl_bufq_pass() local
504 if(!nwritten || *err != CURLE_AGAIN) { in Curl_bufq_pass()
506 nwritten = -1; in Curl_bufq_pass()
511 if(!nwritten) { in Curl_bufq_pass()
514 nwritten = -1; in Curl_bufq_pass()
519 nwritten += chunk_written; in Curl_bufq_pass()
[all …]
Dsocks_gssapi.c113 ssize_t nwritten; in Curl_SOCKS5_gssapi_negotiate() local
207 nwritten = Curl_conn_cf_send(cf->next, data, (char *)socksreq, 4, &code); in Curl_SOCKS5_gssapi_negotiate()
208 if(code || (4 != nwritten)) { in Curl_SOCKS5_gssapi_negotiate()
217 nwritten = Curl_conn_cf_send(cf->next, data, in Curl_SOCKS5_gssapi_negotiate()
220 if(code || ((ssize_t)gss_send_token.length != nwritten)) { in Curl_SOCKS5_gssapi_negotiate()
413 nwritten = Curl_conn_cf_send(cf->next, data, (char *)socksreq, 4, &code); in Curl_SOCKS5_gssapi_negotiate()
414 if(code || (4 != nwritten)) { in Curl_SOCKS5_gssapi_negotiate()
423 nwritten = Curl_conn_cf_send(cf->next, data, (char *)socksreq, 1, &code); in Curl_SOCKS5_gssapi_negotiate()
424 if(code || ( 1 != nwritten)) { in Curl_SOCKS5_gssapi_negotiate()
431 nwritten = Curl_conn_cf_send(cf->next, data, in Curl_SOCKS5_gssapi_negotiate()
[all …]
Dcf-socket.c1279 ssize_t nwritten; in cf_socket_send() local
1294 nwritten = -1; in cf_socket_send()
1296 return nwritten; in cf_socket_send()
1310 nwritten = sendto(ctx->sock, buf, len, MSG_FASTOPEN, in cf_socket_send()
1317 nwritten = swrite(ctx->sock, buf, len); in cf_socket_send()
1319 if(-1 == nwritten) { in cf_socket_send()
1347 orig_len, (int)nwritten, *err); in cf_socket_send()
1349 return nwritten; in cf_socket_send()
1398 ssize_t nwritten; in cf_socket_recv() local
1399 nwritten = Curl_bufq_slurp(&ctx->recvbuf, nw_in_read, &rctx, err); in cf_socket_recv()
[all …]
Dsendf.c159 ssize_t nwritten; in Curl_nwrite() local
180 nwritten = conn->send[sockindex](data, sockindex, buf, blen, &result); in Curl_nwrite()
182 nwritten = 0; in Curl_nwrite()
186 nwritten = -1; /* make sure */ in Curl_nwrite()
189 DEBUGASSERT(nwritten >= 0); in Curl_nwrite()
192 *pnwritten = nwritten; in Curl_nwrite()
Dsocks.c216 ssize_t nwritten; in socks_state_send() local
219 nwritten = Curl_conn_cf_send(cf->next, data, (char *)sx->outp, in socks_state_send()
221 if(nwritten <= 0) { in socks_state_send()
234 DEBUGASSERT(sx->outstanding >= nwritten); in socks_state_send()
236 sx->outstanding -= nwritten; in socks_state_send()
237 sx->outp += nwritten; in socks_state_send()
Dcf-h1-proxy.c259 ssize_t nwritten; in send_CONNECT() local
267 nwritten = cf->next->cft->do_send(cf->next, data, buf, blen, &result); in send_CONNECT()
268 if(nwritten < 0) { in send_CONNECT()
275 DEBUGASSERT(blen >= (size_t)nwritten); in send_CONNECT()
276 ts->nsent += (size_t)nwritten; in send_CONNECT()
277 Curl_debug(data, CURLINFO_HEADER_OUT, buf, (size_t)nwritten); in send_CONNECT()
/third_party/libuv/test/
Dtest-eintr-handling.c50 int nwritten; in thread_main() local
54 nwritten = write(pipe_fds[1], test_buf, sizeof(test_buf)); in thread_main()
55 while (nwritten == -1 && errno == EINTR); in thread_main()
57 ASSERT(nwritten == sizeof(test_buf)); in thread_main()
Dtest-pipe-set-non-blocking.c71 size_t nwritten; in TEST_IMPL() local
95 nwritten = 0; in TEST_IMPL()
96 while (nwritten < NWRITES) { in TEST_IMPL()
110 nwritten += n; in TEST_IMPL()
/third_party/rust/crates/rustix/src/backend/libc/io/
Dsyscalls.rs48 let nwritten = unsafe { in write() localVariable
55 Ok(nwritten as usize) in write()
81 let nwritten = unsafe { in pwrite() localVariable
89 Ok(nwritten as usize) in pwrite()
104 let nwritten = unsafe { in writev() localVariable
111 Ok(nwritten as usize) in writev()
137 let nwritten = unsafe { in pwritev() localVariable
145 Ok(nwritten as usize) in pwritev()
206 let nwritten = unsafe { in pwritev2() localVariable
215 Ok(nwritten as usize) in pwritev2()
[all …]
/third_party/NuttX/drivers/pipes/
Dpipe_common.c541 ssize_t nwritten = 0; in pipecommon_write() local
628 nwritten++; in pipecommon_write()
629 if ((size_t)nwritten >= len) in pipecommon_write()
651 if (last < nwritten) in pipecommon_write()
665 last = nwritten; in pipecommon_write()
671 if (nwritten == 0) in pipecommon_write()
673 nwritten = -EAGAIN; in pipecommon_write()
677 return nwritten; in pipecommon_write()
/third_party/curl/tests/http/clients/
Dh2-download.c115 size_t nwritten; in my_write_cb() local
133 nwritten = fwrite(buf, nitems, buflen, t->out); in my_write_cb()
134 if(nwritten < buflen) { in my_write_cb()
138 t->recv_size += (curl_off_t)nwritten; in my_write_cb()
139 return (size_t)nwritten; in my_write_cb()
Dws-data.c94 size_t nwritten; in send_binary() local
96 curl_ws_send(curl, buf, buflen, &nwritten, 0, CURLWS_BINARY); in send_binary()
98 (long)buflen, result, (long)nwritten); in send_binary()
/third_party/node/test/wasi/c/
Dwrite_file.c11 int nwritten = fprintf(file, "%s", message); in main() local
12 assert(nwritten == strlen(message)); in main()
/third_party/mksh/
Dshf.c800 ssize_t nwritten = 0; in shf_vfprintf() local
810 nwritten++; in shf_vfprintf()
1039 nwritten++; in shf_vfprintf()
1043 nwritten++; in shf_vfprintf()
1049 nwritten++; in shf_vfprintf()
1055 nwritten += field; in shf_vfprintf()
1064 nwritten += precision; in shf_vfprintf()
1069 nwritten += field; in shf_vfprintf()
1074 return (shf_error(shf) ? -1 : nwritten); in shf_vfprintf()
/third_party/rust/crates/rustix/src/backend/libc/net/
Dsyscalls.rs42 let nwritten = unsafe { in send() localVariable
50 Ok(nwritten as usize) in send()
90 let nwritten = unsafe { in sendto_v4() localVariable
100 Ok(nwritten as usize) in sendto_v4()
110 let nwritten = unsafe { in sendto_v6() localVariable
120 Ok(nwritten as usize) in sendto_v6()
130 let nwritten = unsafe { in sendto_unix() localVariable
140 Ok(nwritten as usize) in sendto_unix()
/third_party/curl/lib/vtls/
Drustls.c109 ssize_t nwritten = Curl_conn_cf_send(io_ctx->cf->next, io_ctx->data, in write_cb() local
111 if(nwritten < 0) { in write_cb()
112 nwritten = 0; in write_cb()
118 *out_n = (int)nwritten; in write_cb()

12