/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 | 324 ssize_t nwritten; in write_resp_raw() local 330 if(nwritten < 0) in write_resp_raw() 418 ssize_t nwritten; in cf_recv_body() local 696 return nwritten; in read_pkt_to_send() 923 if(nwritten < 0) in h3_open_stream() 933 nwritten = -1; in h3_open_stream() 943 nwritten = -1; in h3_open_stream() 991 nwritten = -1; in h3_open_stream() 1015 return nwritten; in h3_open_stream() 1030 nwritten = -1; in cf_quiche_send() [all …]
|
H A D | curl_osslq.c | 683 ssize_t nwritten; in write_resp_raw() local 1732 if(nwritten < 0) in h3_stream_open() 1742 nwritten = -1; in h3_stream_open() 1752 nwritten = -1; in h3_stream_open() 1812 nwritten = -1; in h3_stream_open() 1830 return nwritten; in h3_stream_open() 1851 nwritten = -1; in cf_osslq_send() 1858 nwritten = -1; in cf_osslq_send() 1901 nwritten = -1; in cf_osslq_send() 1919 nwritten = -1; in cf_osslq_send() [all …]
|
H A D | curl_msh3.c | 334 ssize_t nwritten; in write_resp_raw() local 340 if(nwritten < 0) { in write_resp_raw() 344 if((size_t)nwritten < memlen) { in write_resp_raw() 604 ssize_t nwritten = -1; in cf_msh3_send() local 621 nwritten = Curl_h1_req_parse_read(&h1, buf, len, NULL, 0, err); in cf_msh3_send() 622 if(nwritten < 0) in cf_msh3_send() 629 nwritten = -1; in cf_msh3_send() 637 nwritten = -1; in cf_msh3_send() 675 nwritten = len; in cf_msh3_send() 694 nwritten = len; in cf_msh3_send() [all …]
|
H A D | curl_ngtcp2.c | 1332 else if(!nwritten) { in cb_h3_read_req_body() 1383 if(nwritten < 0) in h3_stream_open() 1393 nwritten = -1; in h3_stream_open() 1403 nwritten = -1; in h3_stream_open() 1420 nwritten = -1; in h3_stream_open() 1464 nwritten = -1; in h3_stream_open() 1481 return nwritten; in h3_stream_open() 1717 nwritten = 0; in read_pkt_to_send() 1742 nwritten = -1; in read_pkt_to_send() 1793 nwritten = n; in read_pkt_to_send() [all …]
|
/curl/lib/ |
H A D | ws.c | 264 ssize_t nwritten; in ws_dec_pass_payload() local 275 if(nwritten < 0) in ws_dec_pass_payload() 322 if(nwritten < 0) in ws_dec_pass() 439 ssize_t nwritten; in ws_cw_write() local 442 if(nwritten < 0) { in ws_cw_write() 830 ssize_t nwritten; in Curl_ws_accept() local 836 if(nwritten < 0) in Curl_ws_accept() 871 size_t nwritten; in ws_client_collect() local 890 nwritten = bytes; in ws_client_collect() 896 if(!nwritten) { in ws_client_collect() [all …]
|
H A D | cf-h2-proxy.c | 257 ssize_t nwritten; in proxy_h2_nw_out_writer() local 267 nwritten = 0; in proxy_h2_nw_out_writer() 269 return nwritten; in proxy_h2_nw_out_writer() 412 ssize_t nwritten; in proxy_h2_nw_out_flush() local 545 ssize_t nwritten; in on_session_send() local 562 if(!nwritten) in on_session_send() 565 return nwritten; in on_session_send() 865 nwritten = 0; in tunnel_recv_callback() 1353 nwritten = -1; in cf_h2_proxy_send() 1395 nwritten = -1; in cf_h2_proxy_send() [all …]
|
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 | bufq.c | 392 ssize_t nwritten = 0; in Curl_bufq_write() local 408 nwritten += n; in Curl_bufq_write() 417 return nwritten; in Curl_bufq_write() 518 ssize_t nwritten = 0; in Curl_bufq_pass() local 527 nwritten = -1; in Curl_bufq_pass() 532 if(!nwritten) { in Curl_bufq_pass() 535 nwritten = -1; in Curl_bufq_pass() 542 return nwritten; in Curl_bufq_pass() 550 ssize_t nwritten = 0, n; in Curl_bufq_write_pass() local 588 if(!nwritten && len) { in Curl_bufq_write_pass() [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, &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 …]
|
H A D | request.c | 233 size_t nwritten, hds_len = CURLMIN(data->req.sendbuf_hds_len, blen); in req_send_buffer_flush() local 234 result = xfer_send(data, (const char *)buf, blen, hds_len, &nwritten); in req_send_buffer_flush() 238 Curl_bufq_skip(&data->req.sendbuf, nwritten); in req_send_buffer_flush() 240 data->req.sendbuf_hds_len -= CURLMIN(hds_len, nwritten); in req_send_buffer_flush() 244 if(nwritten < blen) in req_send_buffer_flush() 337 size_t blen, nwritten; in Curl_req_send() local 347 result = xfer_send(data, buf, blen, blen, &nwritten); in Curl_req_send() 350 buf += nwritten; in Curl_req_send() 351 blen -= nwritten; in Curl_req_send()
|
H A D | http2.c | 390 if(nwritten > 0) in nw_out_writer() 392 return nwritten; in nw_out_writer() 677 ssize_t nwritten; in nw_out_flush() local 708 ssize_t nwritten; in send_callback() local 726 if(!nwritten) { in send_callback() 730 return nwritten; in send_callback() 2063 nwritten = -1; in h2_submit() 2068 if(nwritten < 0) in h2_submit() 2079 nwritten = -1; in h2_submit() 2088 nwritten = -1; in h2_submit() [all …]
|
H A D | cfilters.c | 207 ssize_t nwritten = cf->cft->do_send(cf, data, mem, len, code); in Curl_cf_send() local 208 DEBUGASSERT(nwritten >= 0 || *code); in Curl_cf_send() 209 DEBUGASSERT(nwritten < 0 || !*code || !len); in Curl_cf_send() 210 return nwritten; in Curl_cf_send() 712 ssize_t nwritten; in Curl_conn_send() local 733 nwritten = conn->send[sockindex](data, sockindex, buf, blen, &result); in Curl_conn_send() 734 DEBUGASSERT((nwritten >= 0) || result); in Curl_conn_send() 735 *pnwritten = (nwritten < 0)? 0 : (size_t)nwritten; in Curl_conn_send()
|
H A D | cf-socket.c | 1431 ssize_t nwritten; in cf_socket_send() local 1446 nwritten = -1; in cf_socket_send() 1448 return nwritten; in cf_socket_send() 1462 nwritten = sendto(ctx->sock, buf, len, MSG_FASTOPEN, in cf_socket_send() 1469 nwritten = swrite(ctx->sock, buf, len); in cf_socket_send() 1471 if(-1 == nwritten) { in cf_socket_send() 1504 orig_len, (int)nwritten, *err); in cf_socket_send() 1506 return nwritten; in cf_socket_send() 1555 ssize_t nwritten; in cf_socket_recv() local 1563 else if(nwritten < 0) { in cf_socket_recv() [all …]
|
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 | 262 ssize_t nwritten; in send_CONNECT() local 270 nwritten = cf->next->cft->do_send(cf->next, data, buf, blen, &result); in send_CONNECT() 271 if(nwritten < 0) { in send_CONNECT() 278 DEBUGASSERT(blen >= (size_t)nwritten); in send_CONNECT() 279 ts->nsent += (size_t)nwritten; in send_CONNECT() 280 Curl_debug(data, CURLINFO_HEADER_OUT, buf, (size_t)nwritten); in send_CONNECT()
|
/curl/lib/vtls/ |
H A D | rustls.c | 118 if(nwritten < 0) { in write_cb() 119 nwritten = 0; in write_cb() 125 *out_n = (uintptr_t)nwritten; in write_cb() 127 len, nwritten, result); in write_cb() 329 ssize_t nwritten = 0; in cr_send() local 353 nwritten += (ssize_t)backend->plain_out_buffered; in cr_send() 381 if(nwritten) { in cr_send() 383 return (ssize_t)nwritten; in cr_send() 389 nwritten += (ssize_t)plainwritten; in cr_send() 392 plainlen, *err, nwritten); in cr_send() [all …]
|
H A D | mbedtls.c | 194 ssize_t nwritten; in mbedtls_bio_cf_write() local 201 nwritten = Curl_conn_cf_send(cf->next, data, (char *)buf, blen, &result); in mbedtls_bio_cf_write() 203 blen, nwritten, result); in mbedtls_bio_cf_write() 204 if(nwritten < 0 && CURLE_AGAIN == result) { in mbedtls_bio_cf_write() 205 nwritten = MBEDTLS_ERR_SSL_WANT_WRITE; in mbedtls_bio_cf_write() 207 return (int)nwritten; in mbedtls_bio_cf_write()
|
H A D | wolfssl.c | 290 ssize_t nwritten; in wolfssl_bio_cf_out_write() local 294 nwritten = Curl_conn_cf_send(cf->next, data, buf, blen, &result); in wolfssl_bio_cf_out_write() 297 blen, nwritten, result); in wolfssl_bio_cf_out_write() 299 if(nwritten < 0 && CURLE_AGAIN == result) in wolfssl_bio_cf_out_write() 301 return (int)nwritten; in wolfssl_bio_cf_out_write()
|
H A D | gtls.c | 101 ssize_t nwritten; in gtls_push() local 105 nwritten = Curl_conn_cf_send(cf->next, data, buf, blen, &result); in gtls_push() 107 blen, nwritten, result); in gtls_push() 109 if(nwritten < 0) { in gtls_push() 112 nwritten = -1; in gtls_push() 114 return nwritten; in gtls_push()
|
H A D | sectransp.c | 308 ssize_t nwritten; in sectransp_bio_cf_out_write() local 313 nwritten = Curl_conn_cf_send(cf->next, data, buf, *dataLength, &result); in sectransp_bio_cf_out_write() 315 *dataLength, nwritten, result); in sectransp_bio_cf_out_write() 316 if(nwritten <= 0) { in sectransp_bio_cf_out_write() 324 nwritten = 0; in sectransp_bio_cf_out_write() 326 else if((size_t)nwritten < *dataLength) { in sectransp_bio_cf_out_write() 329 *dataLength = nwritten; in sectransp_bio_cf_out_write()
|
H A D | vtls.c | 1715 ssize_t nwritten; in ssl_cf_send() local 1719 nwritten = Curl_ssl->send_plain(cf, data, buf, len, err); in ssl_cf_send() 1721 return nwritten; in ssl_cf_send()
|
H A D | openssl.c | 719 ssize_t nwritten; in ossl_bio_cf_out_write() local 726 nwritten = Curl_conn_cf_send(cf->next, data, buf, (size_t)blen, &result); in ossl_bio_cf_out_write() 728 blen, (int)nwritten, result); in ossl_bio_cf_out_write() 731 if(nwritten < 0) { in ossl_bio_cf_out_write() 735 return (int)nwritten; in ossl_bio_cf_out_write()
|
/curl/tests/http/clients/ |
H A D | ws-data.c | 94 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()
|
H A D | h2-download.c | 178 size_t nwritten; in my_write_cb() local 198 nwritten = fwrite(buf, nitems, buflen, t->out); in my_write_cb() 199 if(nwritten < blen) { in my_write_cb() 203 t->recv_size += (curl_off_t)nwritten; in my_write_cb() 210 return (size_t)nwritten; in my_write_cb()
|