/curl/tests/libtest/ |
H A D | lib556.c | 70 size_t nwritten = 0, nread = 0; in test() local 76 res = curl_easy_send(curl, sbuf, sblen, &nwritten); in test() 79 if(nwritten > 0) { in test() 80 sbuf += nwritten; in test() 81 sblen -= nwritten; in test()
|
/curl/tests/unit/ |
H A D | unit2601.c | 100 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 …]
|
/curl/lib/vquic/ |
H A D | curl_quiche.c | 348 ssize_t nwritten; in write_resp_raw() local 354 if(nwritten < 0) in write_resp_raw() 442 ssize_t nwritten; in cf_recv_body() local 720 return nwritten; in read_pkt_to_send() 998 if(nwritten < 0) in h3_open_stream() 1008 nwritten = -1; in h3_open_stream() 1018 nwritten = -1; in h3_open_stream() 1050 nwritten = -1; in h3_open_stream() 1071 if(nwritten > 0 && ((size_t)nwritten < len)) { in h3_open_stream() 1090 return nwritten; in h3_open_stream() [all …]
|
H A D | curl_osslq.c | 773 ssize_t nwritten; in write_resp_raw() local 1816 if(nwritten < 0) in h3_stream_open() 1826 nwritten = -1; in h3_stream_open() 1836 nwritten = -1; in h3_stream_open() 1896 nwritten = -1; in h3_stream_open() 1914 return nwritten; in h3_stream_open() 1937 nwritten = -1; in cf_osslq_send() 1944 nwritten = -1; in cf_osslq_send() 1972 nwritten = -1; in cf_osslq_send() 1990 nwritten = -1; in cf_osslq_send() [all …]
|
H A D | curl_msh3.c | 356 ssize_t nwritten; in write_resp_raw() local 362 if(nwritten < 0) { in write_resp_raw() 366 if((size_t)nwritten < memlen) { in write_resp_raw() 627 ssize_t nwritten = -1; in cf_msh3_send() local 643 nwritten = Curl_h1_req_parse_read(&h1, buf, len, NULL, 0, err); in cf_msh3_send() 644 if(nwritten < 0) in cf_msh3_send() 651 nwritten = -1; in cf_msh3_send() 659 nwritten = -1; in cf_msh3_send() 682 nwritten = len; in cf_msh3_send() 701 nwritten = len; in cf_msh3_send() [all …]
|
H A D | curl_ngtcp2.c | 1367 else if(!nwritten) { in cb_h3_read_req_body() 1417 if(nwritten < 0) in h3_stream_open() 1427 nwritten = -1; in h3_stream_open() 1437 nwritten = -1; in h3_stream_open() 1454 nwritten = -1; in h3_stream_open() 1498 nwritten = -1; in h3_stream_open() 1515 return nwritten; in h3_stream_open() 1711 nwritten = 0; in read_pkt_to_send() 1736 nwritten = -1; in read_pkt_to_send() 1787 nwritten = n; in read_pkt_to_send() [all …]
|
/curl/lib/ |
H A D | cw-out.c | 204 size_t wlen, nwritten; in cw_out_ptr_flush() local 223 nwritten = wcb((char *)buf, 1, wlen, wcb_data); in cw_out_ptr_flush() 227 nwritten); in cw_out_ptr_flush() 228 if(CURL_WRITEFUNC_PAUSE == nwritten) { in cw_out_ptr_flush() 242 else if(CURL_WRITEFUNC_ERROR == nwritten) { in cw_out_ptr_flush() 246 else if(nwritten != wlen) { in cw_out_ptr_flush() 248 "passed %zu returned %zd", wlen, nwritten); in cw_out_ptr_flush() 251 *pconsumed += nwritten; in cw_out_ptr_flush() 252 blen -= nwritten; in cw_out_ptr_flush() 253 buf += nwritten; in cw_out_ptr_flush()
|
H A D | ws.c | 268 ssize_t nwritten; in ws_dec_pass_payload() local 279 if(nwritten < 0) in ws_dec_pass_payload() 326 if(nwritten < 0) in ws_dec_pass() 443 ssize_t nwritten; in ws_cw_write() local 833 ssize_t nwritten; in Curl_ws_accept() local 839 if(nwritten < 0) in Curl_ws_accept() 874 size_t nwritten; in ws_client_collect() local 893 nwritten = bytes; in ws_client_collect() 899 if(!nwritten) { in ws_client_collect() 911 return nwritten; in ws_client_collect() [all …]
|
H A D | request.c | 247 size_t nwritten, hds_len = CURLMIN(data->req.sendbuf_hds_len, blen); in req_send_buffer_flush() local 248 result = xfer_send(data, (const char *)buf, blen, hds_len, &nwritten); in req_send_buffer_flush() 252 Curl_bufq_skip(&data->req.sendbuf, nwritten); in req_send_buffer_flush() 254 data->req.sendbuf_hds_len -= CURLMIN(hds_len, nwritten); in req_send_buffer_flush() 258 if(nwritten < blen) in req_send_buffer_flush() 318 size_t nwritten; in req_flush() local 319 result = xfer_send(data, &tmp, 0, 0, &nwritten); in req_flush() 385 size_t blen, nwritten; in Curl_req_send() local 395 result = xfer_send(data, buf, blen, blen, &nwritten); in Curl_req_send() 398 buf += nwritten; in Curl_req_send() [all …]
|
H A D | socks_gssapi.c | 113 ssize_t nwritten; in Curl_SOCKS5_gssapi_negotiate() local 207 nwritten = Curl_conn_cf_send(cf->next, data, (char *)socksreq, 4, in Curl_SOCKS5_gssapi_negotiate() 209 if(code || (4 != nwritten)) { in Curl_SOCKS5_gssapi_negotiate() 218 nwritten = Curl_conn_cf_send(cf->next, data, in Curl_SOCKS5_gssapi_negotiate() 221 if(code || ((ssize_t)gss_send_token.length != nwritten)) { in Curl_SOCKS5_gssapi_negotiate() 415 nwritten = Curl_conn_cf_send(cf->next, data, (char *)socksreq, 4, FALSE, in Curl_SOCKS5_gssapi_negotiate() 417 if(code || (4 != nwritten)) { in Curl_SOCKS5_gssapi_negotiate() 426 nwritten = Curl_conn_cf_send(cf->next, data, (char *)socksreq, 1, FALSE, in Curl_SOCKS5_gssapi_negotiate() 428 if(code || ( 1 != nwritten)) { in Curl_SOCKS5_gssapi_negotiate() 435 nwritten = Curl_conn_cf_send(cf->next, data, in Curl_SOCKS5_gssapi_negotiate() [all …]
|
H A D | cf-haproxy.c | 134 ssize_t nwritten; in cf_haproxy_connect() local 135 nwritten = Curl_conn_cf_send(cf->next, data, in cf_haproxy_connect() 138 if(nwritten < 0) { in cf_haproxy_connect() 142 nwritten = 0; in cf_haproxy_connect() 144 Curl_dyn_tail(&ctx->data_out, len - (size_t)nwritten); in cf_haproxy_connect()
|
H A D | bufq.c | 452 ssize_t nwritten = 0; in Curl_bufq_write() local 468 nwritten += n; in Curl_bufq_write() 477 return nwritten; in Curl_bufq_write() 587 ssize_t nwritten = 0; in Curl_bufq_pass() local 596 nwritten = -1; in Curl_bufq_pass() 601 if(!nwritten) { in Curl_bufq_pass() 604 nwritten = -1; in Curl_bufq_pass() 611 return nwritten; in Curl_bufq_pass() 619 ssize_t nwritten = 0, n; in Curl_bufq_write_pass() local 657 if(!nwritten && len) { in Curl_bufq_write_pass() [all …]
|
H A D | cf-h2-proxy.c | 260 ssize_t nwritten; in proxy_h2_nw_out_writer() local 270 nwritten = 0; in proxy_h2_nw_out_writer() 272 return nwritten; in proxy_h2_nw_out_writer() 417 ssize_t nwritten; in proxy_h2_nw_out_flush() local 550 ssize_t nwritten; in on_session_send() local 567 if(!nwritten) in on_session_send() 570 return nwritten; in on_session_send() 868 nwritten = 0; in tunnel_recv_callback() 1417 nwritten = -1; in cf_h2_proxy_send() 1440 nwritten = -1; in cf_h2_proxy_send() [all …]
|
H A D | http2.c | 756 ssize_t nwritten; in nw_out_flush() local 787 ssize_t nwritten; in send_callback() local 808 if(!nwritten) { in send_callback() 812 return nwritten; in send_callback() 2140 if(nwritten < 0) in cf_h2_body_send() 2154 return nwritten; in cf_h2_body_send() 2177 nwritten = -1; in h2_submit() 2182 if(nwritten < 0) in h2_submit() 2192 nwritten = -1; in h2_submit() 2201 nwritten = -1; in h2_submit() [all …]
|
H A D | cfilters.c | 277 ssize_t nwritten = cf->cft->do_send(cf, data, mem, len, eos, code); in Curl_cf_send() local 278 DEBUGASSERT(nwritten >= 0 || *code); in Curl_cf_send() 279 DEBUGASSERT(nwritten < 0 || !*code || !len); in Curl_cf_send() 280 return nwritten; in Curl_cf_send() 867 ssize_t nwritten; in Curl_conn_send() local 890 nwritten = conn->send[sockindex](data, sockindex, buf, write_len, eos, in Curl_conn_send() 892 DEBUGASSERT((nwritten >= 0) || result); in Curl_conn_send() 893 *pnwritten = (nwritten < 0) ? 0 : (size_t)nwritten; in Curl_conn_send()
|
H A D | socks.c | 216 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()
|
H A D | cf-h1-proxy.c | 261 ssize_t nwritten; in send_CONNECT() local 269 nwritten = cf->next->cft->do_send(cf->next, data, buf, blen, FALSE, &result); in send_CONNECT() 270 if(nwritten < 0) { in send_CONNECT() 277 DEBUGASSERT(blen >= (size_t)nwritten); in send_CONNECT() 278 ts->nsent += (size_t)nwritten; in send_CONNECT() 279 Curl_debug(data, CURLINFO_HEADER_OUT, buf, (size_t)nwritten); in send_CONNECT()
|
H A D | cf-socket.c | 1481 ssize_t nwritten; in cf_socket_send() local 1497 nwritten = -1; in cf_socket_send() 1499 return nwritten; in cf_socket_send() 1513 nwritten = sendto(ctx->sock, buf, len, MSG_FASTOPEN, in cf_socket_send() 1520 nwritten = swrite(ctx->sock, buf, len); in cf_socket_send() 1522 if(-1 == nwritten) { in cf_socket_send() 1555 orig_len, (int)nwritten, *err); in cf_socket_send() 1557 return nwritten; in cf_socket_send()
|
/curl/lib/vtls/ |
H A D | rustls.c | 123 if(nwritten < 0) { in write_cb() 124 nwritten = 0; in write_cb() 130 *out_n = (uintptr_t)nwritten; in write_cb() 132 len, nwritten, result); in write_cb() 334 ssize_t nwritten = 0; in cr_send() local 386 if(nwritten) { in cr_send() 388 return (ssize_t)nwritten; in cr_send() 394 nwritten += (ssize_t)plainwritten; in cr_send() 398 return nwritten; in cr_send() 976 ssize_t nwritten, nread; in cr_shutdown() local [all …]
|
H A D | gtls.c | 102 ssize_t nwritten; in gtls_push() local 110 if(nwritten < 0) { in gtls_push() 113 nwritten = -1; in gtls_push() 115 return nwritten; in gtls_push() 1757 ssize_t nwritten = 0; in gtls_set_earlydata() local 1767 blen, nwritten); in gtls_set_earlydata() 1768 if(nwritten < 0) in gtls_set_earlydata() 2039 nwritten = (size_t)rc; in gtls_send() 2040 total_written += nwritten; in gtls_send() 2042 buf = (char *)buf + nwritten; in gtls_send() [all …]
|
H A D | mbedtls.c | 189 ssize_t nwritten; in mbedtls_bio_cf_write() local 196 nwritten = Curl_conn_cf_send(cf->next, data, (char *)buf, blen, FALSE, in mbedtls_bio_cf_write() 199 blen, nwritten, result); in mbedtls_bio_cf_write() 200 if(nwritten < 0 && CURLE_AGAIN == result) { in mbedtls_bio_cf_write() 201 nwritten = MBEDTLS_ERR_SSL_WANT_WRITE; in mbedtls_bio_cf_write() 203 return (int)nwritten; in mbedtls_bio_cf_write()
|
H A D | wolfssl.c | 319 ssize_t nwritten, skiplen = 0; in wolfssl_bio_cf_out_write() local 333 nwritten = Curl_conn_cf_send(cf->next, data, buf, blen, FALSE, &result); in wolfssl_bio_cf_out_write() 336 blen, nwritten, result); in wolfssl_bio_cf_out_write() 340 if(nwritten < 0 && CURLE_AGAIN == result) { in wolfssl_bio_cf_out_write() 346 nwritten += skiplen; in wolfssl_bio_cf_out_write() 347 return (int)nwritten; in wolfssl_bio_cf_out_write()
|
/curl/tests/http/clients/ |
H A D | ws-data.c | 98 size_t nwritten; in send_binary() local 100 curl_ws_send(curl, buf, buflen, &nwritten, 0, CURLWS_BINARY); in send_binary() 102 (long)buflen, result, (long)nwritten); in send_binary()
|
H A D | hx-download.c | 179 size_t nwritten; in my_write_cb() local 199 nwritten = fwrite(buf, nitems, buflen, t->out); in my_write_cb() 200 if(nwritten < blen) { in my_write_cb() 204 t->recv_size += (curl_off_t)nwritten; in my_write_cb() 211 return (size_t)nwritten; in my_write_cb()
|
H A D | hx-upload.c | 182 size_t nwritten; in my_write_cb() local 194 nwritten = fwrite(buf, nitems, buflen, t->out); in my_write_cb() 195 if(nwritten < blen) { in my_write_cb() 199 t->recv_size += (curl_off_t)nwritten; in my_write_cb() 200 return (size_t)nwritten; in my_write_cb()
|