Home
last modified time | relevance | path

Searched refs:nwritten (Results 1 – 25 of 41) 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.c395 ssize_t nwritten; in write_resp_raw() local
400 nwritten = Curl_bufq_write(&stream->recvbuf, mem, memlen, &result); in write_resp_raw()
401 if(nwritten < 0) in write_resp_raw()
404 if((size_t)nwritten < memlen) { in write_resp_raw()
487 ssize_t nwritten; in cf_recv_body() local
503 nwritten = Curl_bufq_slurp(&stream->recvbuf, in cf_recv_body()
506 if(nwritten < 0 && result != CURLE_AGAIN) { in cf_recv_body()
508 stream->id, nwritten); in cf_recv_body()
749 ssize_t nwritten; in read_pkt_to_send() local
751 nwritten = quiche_conn_send(ctx->qconn, buf, buflen, &x->send_info); in read_pkt_to_send()
[all …]
Dcurl_msh3.c311 ssize_t nwritten; in write_resp_raw() local
316 nwritten = Curl_bufq_write(&stream->recvbuf, mem, memlen, &result); in write_resp_raw()
317 if(nwritten < 0) { in write_resp_raw()
321 if((size_t)nwritten < memlen) { in write_resp_raw()
573 ssize_t nwritten = -1; in cf_msh3_send() local
590 nwritten = Curl_h1_req_parse_read(&h1, buf, len, NULL, 0, err); in cf_msh3_send()
591 if(nwritten < 0) in cf_msh3_send()
598 nwritten = -1; in cf_msh3_send()
606 nwritten = -1; in cf_msh3_send()
644 nwritten = len; in cf_msh3_send()
[all …]
Dcurl_ngtcp2.c1161 ssize_t nwritten; in write_resp_raw() local
1167 nwritten = Curl_bufq_write(&stream->recvbuf, mem, memlen, &result); in write_resp_raw()
1168 if(nwritten < 0) { in write_resp_raw()
1173 stream->recv_buf_nonflow += (size_t)nwritten; in write_resp_raw()
1175 if((size_t)nwritten < memlen) { in write_resp_raw()
1595 ssize_t nwritten = 0; in cb_h3_read_req_body() local
1620 nwritten += vec[nvecs].len; in cb_h3_read_req_body()
1626 if(nwritten > 0 && stream->upload_left != -1) in cb_h3_read_req_body()
1627 stream->upload_left -= nwritten; in cb_h3_read_req_body()
1635 else if(!nwritten) { in cb_h3_read_req_body()
[all …]
/third_party/curl/lib/
Dws.c260 ssize_t nwritten; in ws_dec_pass_payload() local
268 nwritten = write_payload(inbuf, inlen, dec->frame_age, dec->frame_flags, in ws_dec_pass_payload()
271 if(nwritten < 0) in ws_dec_pass_payload()
273 Curl_bufq_skip(inraw, (size_t)nwritten); in ws_dec_pass_payload()
274 dec->payload_offset += (curl_off_t)nwritten; in ws_dec_pass_payload()
314 ssize_t nwritten; in ws_dec_pass() local
317 nwritten = write_payload(&tmp, 0, dec->frame_age, dec->frame_flags, in ws_dec_pass()
319 if(nwritten < 0) in ws_dec_pass()
659 ssize_t nwritten; in Curl_ws_accept() local
663 nwritten = Curl_bufq_write(&ws->recvbuf, (const unsigned char *)mem, in Curl_ws_accept()
[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.c371 ssize_t nwritten; in nw_out_writer() local
373 nwritten = Curl_conn_cf_send(cf->next, data, (const char *)buf, buflen, err); in nw_out_writer()
374 if(nwritten > 0) in nw_out_writer()
375 CURL_TRC_CF(data, cf, "[0] egress: wrote %zd bytes", nwritten); in nw_out_writer()
376 return nwritten; in nw_out_writer()
652 ssize_t nwritten; in nw_out_flush() local
659 nwritten = Curl_bufq_pass(&ctx->outbufq, nw_out_writer, cf, &result); in nw_out_flush()
660 if(nwritten < 0) { in nw_out_flush()
683 ssize_t nwritten; in send_callback() local
690 nwritten = Curl_bufq_write_pass(&ctx->outbufq, buf, blen, 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.c112 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()
414 nwritten = Curl_conn_cf_send(cf->next, data, (char *)socksreq, 4, &code); in Curl_SOCKS5_gssapi_negotiate()
415 if(code || (4 != nwritten)) { in Curl_SOCKS5_gssapi_negotiate()
424 nwritten = Curl_conn_cf_send(cf->next, data, (char *)socksreq, 1, &code); in Curl_SOCKS5_gssapi_negotiate()
425 if(code || ( 1 != nwritten)) { in Curl_SOCKS5_gssapi_negotiate()
432 nwritten = Curl_conn_cf_send(cf->next, data, in Curl_SOCKS5_gssapi_negotiate()
[all …]
Dsendf.c155 ssize_t nwritten; in Curl_nwrite() local
176 nwritten = conn->send[sockindex](data, sockindex, buf, blen, &result); in Curl_nwrite()
178 nwritten = 0; in Curl_nwrite()
182 nwritten = -1; /* make sure */ in Curl_nwrite()
185 DEBUGASSERT(nwritten >= 0); in Curl_nwrite()
188 *pnwritten = nwritten; in Curl_nwrite()
Dcf-socket.c1290 ssize_t nwritten; in cf_socket_send() local
1305 nwritten = -1; in cf_socket_send()
1307 return nwritten; in cf_socket_send()
1321 nwritten = sendto(ctx->sock, buf, len, MSG_FASTOPEN, in cf_socket_send()
1328 nwritten = swrite(ctx->sock, buf, len); in cf_socket_send()
1330 if(-1 == nwritten) { in cf_socket_send()
1358 orig_len, (int)nwritten, *err); in cf_socket_send()
1360 return nwritten; in cf_socket_send()
1409 ssize_t nwritten; in cf_socket_recv() local
1410 nwritten = Curl_bufq_slurp(&ctx->recvbuf, nw_in_read, &rctx, err); in cf_socket_recv()
[all …]
Dsocks.c207 ssize_t nwritten; in socks_state_send() local
210 nwritten = Curl_conn_cf_send(cf->next, data, (char *)sx->outp, in socks_state_send()
212 if(nwritten <= 0) { in socks_state_send()
225 DEBUGASSERT(sx->outstanding >= nwritten); in socks_state_send()
227 sx->outstanding -= nwritten; in socks_state_send()
228 sx->outp += nwritten; in socks_state_send()
Dcf-h1-proxy.c264 ssize_t nwritten; in send_CONNECT() local
272 nwritten = cf->next->cft->do_send(cf->next, data, buf, blen, &result); in send_CONNECT()
273 if(nwritten < 0) { in send_CONNECT()
280 DEBUGASSERT(blen >= (size_t)nwritten); in send_CONNECT()
281 ts->nsent += (size_t)nwritten; in send_CONNECT()
282 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.c116 ssize_t nwritten; in my_write_cb() local
134 nwritten = fwrite(buf, nitems, buflen, t->out); in my_write_cb()
135 if(nwritten < 0) { in my_write_cb()
139 t->recv_size += nwritten; in my_write_cb()
140 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.c116 ssize_t nwritten = Curl_conn_cf_send(io_ctx->cf->next, io_ctx->data, in write_cb() local
118 if(nwritten < 0) { in write_cb()
119 nwritten = 0; in write_cb()
125 *out_n = (int)nwritten; in write_cb()
Dmbedtls.c164 ssize_t nwritten; in mbedtls_bio_cf_write() local
168 nwritten = Curl_conn_cf_send(cf->next, data, (char *)buf, blen, &result); in mbedtls_bio_cf_write()
170 blen, nwritten, result); in mbedtls_bio_cf_write()
171 if(nwritten < 0 && CURLE_AGAIN == result) { in mbedtls_bio_cf_write()
172 nwritten = MBEDTLS_ERR_SSL_WANT_WRITE; in mbedtls_bio_cf_write()
174 return (int)nwritten; in mbedtls_bio_cf_write()

12