/curl/tests/libtest/ |
H A D | lib2302.c | 32 size_t blen; member 45 for(i = 0; i < wd->blen; ++i) in flush_data() 53 wd->blen = 0; in flush_data() 57 static size_t add_data(struct ws_data *wd, const char *buf, size_t blen, in add_data() argument 69 if(wd->blen + blen > sizeof(wd->buf)) { in add_data() 72 memcpy(wd->buf + wd->blen, buf, blen); in add_data() 73 wd->blen += blen; in add_data() 75 return blen; in add_data()
|
/curl/lib/ |
H A D | http_chunks.c | 145 while(blen) { in httpchunk_readwrite() 157 blen--; in httpchunk_readwrite() 197 blen--; in httpchunk_readwrite() 205 piece = blen; in httpchunk_readwrite() 248 blen--; in httpchunk_readwrite() 306 blen--; in httpchunk_readwrite() 314 blen--; in httpchunk_readwrite() 335 blen--; in httpchunk_readwrite() 344 blen--; in httpchunk_readwrite() 447 blen -= consumed; in cw_chunked_write() [all …]
|
H A D | request.c | 193 DEBUGASSERT(hds_len <= blen); in xfer_send() 223 if(eos && (blen == *pnwritten)) in xfer_send() 244 size_t blen; in req_send_buffer_flush() local 258 if(nwritten < blen) in req_send_buffer_flush() 376 DEBUGASSERT((size_t)n == blen); in req_send_buffer_add() 385 size_t blen, nwritten; in Curl_req_send() local 391 blen = Curl_dyn_len(req); in Curl_req_send() 395 result = xfer_send(data, buf, blen, blen, &nwritten); in Curl_req_send() 399 blen -= nwritten; in Curl_req_send() 402 if(blen) { in Curl_req_send() [all …]
|
H A D | cw-out.c | 213 *pconsumed = blen; in cw_out_ptr_flush() 218 while(blen && !ctx->paused) { in cw_out_ptr_flush() 219 if(!flush_all && blen < min_write) in cw_out_ptr_flush() 221 wlen = max_write ? CURLMIN(blen, max_write) : blen; in cw_out_ptr_flush() 252 blen -= nwritten; in cw_out_ptr_flush() 332 if(cw_out_bufs_len(ctx) + blen > DYN_PAUSE_BUFFER) in cw_out_append() 346 return Curl_dyn_addn(&ctx->buf->b, buf, blen); in cw_out_append() 367 result = cw_out_append(ctx, otype, buf, blen); in cw_out_do_write() 378 buf, blen, &consumed); in cw_out_do_write() 381 if(consumed < blen) { in cw_out_do_write() [all …]
|
H A D | rtsp.c | 638 while(blen) { in rtsp_filter_rtp() 649 if(strncmp(buf, "RTSP/", (blen < 5) ? blen : 5) == 0) { in rtsp_filter_rtp() 663 --blen; in rtsp_filter_rtp() 682 --blen; in rtsp_filter_rtp() 721 --blen; in rtsp_filter_rtp() 736 --blen; in rtsp_filter_rtp() 774 buf += blen; in rtsp_filter_rtp() 775 blen = 0; in rtsp_filter_rtp() 802 if(!blen) { in rtsp_rtp_write_resp() 815 blen -= consumed; in rtsp_rtp_write_resp() [all …]
|
H A D | transfer.c | 214 DEBUGASSERT(blen > 0); in xfer_recv_resp() 220 blen = 0; in xfer_recv_resp() 222 blen = (size_t)totalleft; in xfer_recv_resp() 226 blen = 0; in xfer_recv_resp() 229 if(!blen) { in xfer_recv_resp() 269 size_t blen, xfer_blen; in sendrecv_dl() local 322 blen = (size_t)nread; in sendrecv_dl() 323 is_eos = (blen == 0); in sendrecv_dl() 326 if(!blen) { in sendrecv_dl() 339 total_received += blen; in sendrecv_dl() [all …]
|
H A D | sendf.c | 674 blen = 0; in cr_in_read() 676 blen = (size_t)remain; in cr_in_read() 724 if(nread > blen) { in cr_in_read() 1185 DEBUGASSERT(blen); in Curl_client_read() 1224 (void)blen; in cr_null_read() 1270 size_t blen; member 1288 if(nread > blen) in cr_buf_read() 1289 nread = blen; in cr_buf_read() 1331 if(boffset > ctx->blen) in cr_buf_resume_from() 1335 ctx->blen -= boffset; in cr_buf_resume_from() [all …]
|
H A D | transfer.h | 64 const char *buf, size_t blen, 132 const void *buf, size_t blen, bool eos, 141 char *buf, size_t blen,
|
H A D | sendf.h | 212 char *buf, size_t blen, size_t *nread, bool *eos); 259 char *buf, size_t blen, 283 char *buf, size_t blen, size_t *nread, bool *eos); 325 CURLcode Curl_client_read(struct Curl_easy *data, char *buf, size_t blen, 413 const char *buf, size_t blen);
|
H A D | content_encoding.h | 30 void Curl_all_content_encodings(char *buf, size_t blen);
|
H A D | cf-h2-proxy.c | 449 size_t blen; in proxy_h2_process_pending_input() local 452 while(Curl_bufq_peek(&ctx->inbufq, &buf, &blen)) { in proxy_h2_process_pending_input() 575 char *buffer, size_t blen) in proxy_h2_fr_print() argument 579 return msnprintf(buffer, blen, in proxy_h2_fr_print() 586 return msnprintf(buffer, blen, in proxy_h2_fr_print() 593 return msnprintf(buffer, blen, in proxy_h2_fr_print() 598 return msnprintf(buffer, blen, in proxy_h2_fr_print() 607 return msnprintf(buffer, blen, in proxy_h2_fr_print() 611 return msnprintf(buffer, blen, in proxy_h2_fr_print() 616 return msnprintf(buffer, blen, in proxy_h2_fr_print() [all …]
|
H A D | http2.c | 642 size_t blen; in h2_process_pending_input() local 1213 return msnprintf(buffer, blen, in fr_print() 1220 return msnprintf(buffer, blen, in fr_print() 1227 return msnprintf(buffer, blen, in fr_print() 1232 return msnprintf(buffer, blen, in fr_print() 1241 return msnprintf(buffer, blen, in fr_print() 1245 return msnprintf(buffer, blen, in fr_print() 1251 return msnprintf(buffer, blen, in fr_print() 1269 return msnprintf(buffer, blen, in fr_print() 1732 size_t blen; in Curl_http2_request_upgrade() local [all …]
|
H A D | http_chunks.h | 127 char *buf, size_t blen, size_t *pconsumed);
|
H A D | http.h | 134 const char *buf, size_t blen, 193 const char *buf, size_t blen,
|
H A D | content_encoding.c | 864 void Curl_all_content_encodings(char *buf, size_t blen) in Curl_all_content_encodings() argument 871 DEBUGASSERT(blen); in Curl_all_content_encodings() 881 if(blen >= sizeof(CONTENT_ENCODING_DEFAULT)) in Curl_all_content_encodings() 884 else if(blen > len) { in Curl_all_content_encodings() 1075 void Curl_all_content_encodings(char *buf, size_t blen) in Curl_all_content_encodings() argument 1078 DEBUGASSERT(blen); in Curl_all_content_encodings() 1079 if(blen < sizeof(CONTENT_ENCODING_DEFAULT)) in Curl_all_content_encodings()
|
H A D | multiif.h | 163 size_t blen, char **pbuf);
|
H A D | http.c | 3448 *pconsumed += blen; in http_on_response() 3857 while(blen && k->header) { in http_parse_headers() 3860 end_ptr = memchr(buf, '\n', blen); in http_parse_headers() 3867 *pconsumed += blen; in http_parse_headers() 3900 blen -= consumed; in http_parse_headers() 3932 buf, blen, &consumed); in http_parse_headers() 3938 blen -= consumed; in http_parse_headers() 4015 DEBUGASSERT(consumed <= blen); in Curl_http_write_resp() 4016 blen -= consumed; in Curl_http_write_resp() 4020 DEBUGASSERT(!blen || !data->req.header); in Curl_http_write_resp() [all …]
|
H A D | mime.c | 1946 char *buf, size_t blen, in cr_mime_read() argument 1956 blen, ctx->error_result); in cr_mime_read() 1971 blen = 0; in cr_mime_read() 1972 else if(remain < (curl_off_t)blen) in cr_mime_read() 1973 blen = (size_t)remain; in cr_mime_read() 1976 if(blen <= 4) { in cr_mime_read() 1981 CURL_TRC_READ(data, "cr_mime_read(len=%zu), too small, return", blen); in cr_mime_read() 1987 nread = Curl_mime_read(buf, 1, blen, ctx->part); in cr_mime_read() 1989 blen, nread); in cr_mime_read() 2014 CURL_TRC_READ(data, "cr_mime_read(len=%zu), paused by callback", blen); in cr_mime_read() [all …]
|
/curl/lib/vtls/ |
H A D | gtls.c | 108 blen, nwritten, result); in gtls_push() 140 blen, nread, result); in gtls_pull() 1762 if(blen) { in gtls_set_earlydata() 1767 blen, nwritten); in gtls_set_earlydata() 1784 size_t blen; in gtls_send_earlydata() local 1792 blen, n); in gtls_send_earlydata() 1804 n = (ssize_t)blen; in gtls_send_earlydata() 2011 rc = (ssize_t)blen; in gtls_send() 2022 while(blen) { in gtls_send() 2041 DEBUGASSERT(nwritten <= blen); in gtls_send() [all …]
|
H A D | wolfssl.c | 312 const char *buf, int blen) in wolfssl_bio_cf_out_write() argument 324 (backend->io_send_blocked_len < blen)) { in wolfssl_bio_cf_out_write() 330 skiplen = (ssize_t)(blen - backend->io_send_blocked_len); in wolfssl_bio_cf_out_write() 331 blen = backend->io_send_blocked_len; in wolfssl_bio_cf_out_write() 336 blen, nwritten, result); in wolfssl_bio_cf_out_write() 343 backend->io_send_blocked_len = blen; in wolfssl_bio_cf_out_write() 365 nread = Curl_conn_cf_recv(cf->next, data, buf, blen, &result); in wolfssl_bio_cf_in_read() 1459 size_t blen = 0; in wolfssl_connect_step2() local 1462 &b64str, &blen); in wolfssl_connect_step2() 1736 char *buf, size_t blen, in wolfssl_recv() argument [all …]
|
H A D | rustls.c | 333 size_t blen = plainlen; in cr_send() local 352 if(blen > backend->plain_out_buffered) { in cr_send() 353 blen -= backend->plain_out_buffered; in cr_send() 357 blen = 0; in cr_send() 362 if(blen > 0) { in cr_send() 363 CURL_TRC_CF(data, cf, "cf_send: adding %zu plain bytes to Rustls", blen); in cr_send() 364 rresult = rustls_connection_write(rconn, buf, blen, &plainwritten); in cr_send() 384 " bytes already to Rustls", blen); in cr_send()
|
/curl/tests/http/clients/ |
H A D | hx-upload.c | 181 size_t blen = (nitems * buflen); in my_write_cb() local 185 t->idx, (long)blen, (long)t->recv_size, (long)t->pause_at); in my_write_cb() 195 if(nwritten < blen) { in my_write_cb() 207 size_t blen = (nitems * buflen); in my_read_cb() local 212 else if((t->send_total - t->send_size) < (curl_off_t)blen) in my_read_cb() 215 nread = blen; in my_read_cb() 222 ((t->send_size + (curl_off_t)blen) >= t->pause_at)) { in my_read_cb()
|
H A D | hx-download.c | 178 size_t blen = (nitems * buflen); in my_write_cb() local 182 t->idx, (long)blen, (long)t->recv_size, (long)t->pause_at); in my_write_cb() 193 ((t->recv_size + (curl_off_t)blen) >= t->pause_at)) { in my_write_cb() 200 if(nwritten < blen) { in my_write_cb()
|
/curl/lib/vquic/ |
H A D | vquic.c | 273 size_t blen, sent; in vquic_flush() local 277 while(Curl_bufq_peek(&qctx->sendbuf, &buf, &blen)) { in vquic_flush() 281 if(blen > qctx->split_len) in vquic_flush() 282 blen = qctx->split_len; in vquic_flush() 285 result = vquic_send_packets(cf, data, qctx, buf, blen, gsolen, &sent); in vquic_flush() 287 blen, gsolen, result, sent); in vquic_flush()
|
/curl/src/ |
H A D | tool_doswin.c | 539 size_t blen = strlen(base); in rename_if_reserved_dos() local 540 if(blen) { in rename_if_reserved_dos() 543 memmove(base + 1, base, blen + 1); in rename_if_reserved_dos()
|