Home
last modified time | relevance | path

Searched refs:nwritten (Results 1 - 25 of 44) sorted by relevance

12

/third_party/ltp/testcases/kernel/sched/clisrv/
H A 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/
H A 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()
139 fail_if(TRUE, "write: bufq full but nwritten wrong"); 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_le in check_bufq()
[all...]
/third_party/curl/lib/vquic/
H A 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 in read_pkt_to_send()
846 ssize_t nwritten; h3_open_stream() local
961 ssize_t nwritten; cf_quiche_send() local
[all...]
H A 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()
1651 ssize_t nwritten = -1; h3_stream_open() local
1774 ssize_t nwritten; cf_osslq_send() local
[all...]
H A 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 in cf_msh3_send()
[all...]
H A 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()
1312 ssize_t nwritten = -1; h3_stream_open() local
1643 ssize_t nwritten, n; read_pkt_to_send() local
[all...]
/third_party/curl/lib/
H A 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 < in send_callback()
967 ssize_t nwritten; recvbuf_write_hds() local
1271 ssize_t nwritten; on_data_chunk_recv() local
2037 ssize_t nwritten; h2_submit() local
2171 ssize_t nwritten; cf_h2_send() local
[all...]
H A 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()
282 nwritten, remain); */ 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
814 ssize_t nwritten; Curl_ws_accept() local
855 size_t nwritten; ws_client_collect() local
1044 ssize_t nwritten, n; curl_ws_send() local
[all...]
H A 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 in Curl_bufq_pass()
529 ssize_t nwritten = 0, n; Curl_bufq_write_pass() local
[all...]
H A 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 in Curl_SOCKS5_gssapi_negotiate()
[all...]
H A 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 in on_session_send()
850 ssize_t nwritten; tunnel_recv_callback() local
1333 ssize_t nwritten; cf_h2_proxy_send() local
[all...]
H A Dsendf.c151 * (*nwritten == 0). Otherwise we return regular CURLcode value.
159 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()
H A 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 in cf_socket_recv()
[all...]
H A 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()
/third_party/libuv/test/
H A 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_EQ(nwritten, sizeof(test_buf)); in thread_main()
H A 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()
114 nwritten += n; in TEST_IMPL()
/third_party/rust/crates/rustix/src/backend/libc/io/
H A Dsyscalls.rs48 let nwritten = unsafe {
55 Ok(nwritten as usize)
81 let nwritten = unsafe {
89 Ok(nwritten as usize)
104 let nwritten = unsafe {
111 Ok(nwritten as usize)
137 let nwritten = unsafe {
145 Ok(nwritten as usize)
206 let nwritten = unsafe {
215 Ok(nwritten a
[all...]
/third_party/NuttX/drivers/pipes/
H A 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/node/test/wasi/c/
H A Dwrite_file.c11 int nwritten = fprintf(file, "%s", message); in main() local
12 assert(nwritten == strlen(message)); in main()
/third_party/curl/tests/http/clients/
H A 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()
H A 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/rust/crates/rustix/src/backend/libc/net/
H A Dsyscalls.rs42 let nwritten = unsafe {
50 Ok(nwritten as usize)
90 let nwritten = unsafe {
100 Ok(nwritten as usize)
110 let nwritten = unsafe {
120 Ok(nwritten as usize)
130 let nwritten = unsafe {
140 Ok(nwritten as usize)
/third_party/mksh/
H A 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/backends/sanei/
H A Dsanei_wire.c58 ssize_t nread, nwritten; in sanei_w_space() local
86 nwritten = (*w->io.write) (fd, w->buffer.curr, nbytes); in sanei_w_space()
87 if (nwritten < 0) in sanei_w_space()
93 w->buffer.curr += nwritten; in sanei_w_space()
94 nbytes -= nwritten; in sanei_w_space()
/third_party/curl/lib/vtls/
H A Dmbedtls.c175 ssize_t nwritten; in mbedtls_bio_cf_write() local
182 nwritten = Curl_conn_cf_send(cf->next, data, (char *)buf, blen, &result); in mbedtls_bio_cf_write()
184 blen, nwritten, result); in mbedtls_bio_cf_write()
185 if(nwritten < 0 && CURLE_AGAIN == result) { in mbedtls_bio_cf_write()
186 nwritten = MBEDTLS_ERR_SSL_WANT_WRITE; in mbedtls_bio_cf_write()
188 return (int)nwritten; in mbedtls_bio_cf_write()

Completed in 28 milliseconds

12