/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 | 198 if(altsize && altsize < blen) in xfer_send() 199 blen = altsize; in xfer_send() 230 size_t blen; in req_send_buffer_flush() local 244 if(nwritten < blen) in req_send_buffer_flush() 328 DEBUGASSERT((size_t)n == blen); in req_send_buffer_add() 337 size_t blen, nwritten; in Curl_req_send() local 343 blen = Curl_dyn_len(req); in Curl_req_send() 347 result = xfer_send(data, buf, blen, blen, &nwritten); in Curl_req_send() 351 blen -= nwritten; in Curl_req_send() 354 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 | 637 while(blen) { in rtsp_filter_rtp() 648 if(strncmp(buf, "RTSP/", (blen < 5) ? blen : 5) == 0) { in rtsp_filter_rtp() 662 --blen; in rtsp_filter_rtp() 681 --blen; in rtsp_filter_rtp() 720 --blen; in rtsp_filter_rtp() 735 --blen; in rtsp_filter_rtp() 773 buf += blen; in rtsp_filter_rtp() 774 blen = 0; in rtsp_filter_rtp() 801 if(!blen) { in rtsp_rtp_write_resp() 814 blen -= consumed; in rtsp_rtp_write_resp() [all …]
|
H A D | sendf.c | 662 blen = 0; in cr_in_read() 664 blen = (size_t)remain; in cr_in_read() 711 if(nread > blen) { in cr_in_read() 1142 DEBUGASSERT(blen); in Curl_client_read() 1181 (void)blen; in cr_null_read() 1226 size_t blen; member 1244 if(nread > blen) in cr_buf_read() 1245 nread = blen; in cr_buf_read() 1287 if(boffset > ctx->blen) in cr_buf_resume_from() 1291 ctx->blen -= boffset; in cr_buf_resume_from() [all …]
|
H A D | transfer.h | 67 const char *buf, size_t blen, 101 const void *buf, size_t blen, 110 char *buf, size_t blen,
|
H A D | transfer.c | 179 DEBUGASSERT(blen > 0); in Curl_xfer_recv_resp() 185 blen = 0; in Curl_xfer_recv_resp() 186 else if(totalleft < (curl_off_t)blen) in Curl_xfer_recv_resp() 187 blen = (size_t)totalleft; in Curl_xfer_recv_resp() 190 if(!blen) { in Curl_xfer_recv_resp() 216 size_t blen, xfer_blen; in readwrite_data() local 263 blen = (size_t)nread; in readwrite_data() 264 is_eos = (blen == 0); in readwrite_data() 267 if(!blen) { in readwrite_data() 281 total_received += blen; in readwrite_data() [all …]
|
H A D | sendf.h | 212 char *buf, size_t blen, size_t *nread, bool *eos); 258 char *buf, size_t blen, 280 char *buf, size_t blen, size_t *nread, bool *eos); 322 CURLcode Curl_client_read(struct Curl_easy *data, char *buf, size_t blen, 405 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 | 444 size_t blen; in proxy_h2_process_pending_input() local 447 while(Curl_bufq_peek(&ctx->inbufq, &buf, &blen)) { in proxy_h2_process_pending_input() 570 char *buffer, size_t blen) in proxy_h2_fr_print() argument 574 return msnprintf(buffer, blen, in proxy_h2_fr_print() 581 return msnprintf(buffer, blen, in proxy_h2_fr_print() 588 return msnprintf(buffer, blen, in proxy_h2_fr_print() 593 return msnprintf(buffer, blen, in proxy_h2_fr_print() 602 return msnprintf(buffer, blen, in proxy_h2_fr_print() 606 return msnprintf(buffer, blen, in proxy_h2_fr_print() 612 return msnprintf(buffer, blen, in proxy_h2_fr_print() [all …]
|
H A D | http_chunks.h | 127 char *buf, size_t blen, size_t *pconsumed);
|
H A D | http2.c | 563 size_t blen; in h2_process_pending_input() local 1115 return msnprintf(buffer, blen, in fr_print() 1122 return msnprintf(buffer, blen, in fr_print() 1129 return msnprintf(buffer, blen, in fr_print() 1134 return msnprintf(buffer, blen, in fr_print() 1143 return msnprintf(buffer, blen, in fr_print() 1147 return msnprintf(buffer, blen, in fr_print() 1153 return msnprintf(buffer, blen, in fr_print() 1171 return msnprintf(buffer, blen, in fr_print() 1645 size_t blen; in Curl_http2_request_upgrade() local [all …]
|
H A D | http.h | 135 const char *buf, size_t blen, 198 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 | http.c | 3465 *pconsumed += blen; in http_on_response() 3874 while(blen && k->header) { in http_parse_headers() 3877 end_ptr = memchr(buf, '\n', blen); in http_parse_headers() 3884 *pconsumed += blen; in http_parse_headers() 3917 blen -= consumed; in http_parse_headers() 3949 buf, blen, &consumed); in http_parse_headers() 3955 blen -= consumed; in http_parse_headers() 4032 DEBUGASSERT(consumed <= blen); in Curl_http_write_resp() 4033 blen -= consumed; in Curl_http_write_resp() 4037 DEBUGASSERT(!blen || !data->req.header); in Curl_http_write_resp() [all …]
|
H A D | headers.c | 353 const char *buf, size_t blen) in hds_cw_collect_write() argument 363 htype, blen, result); in hds_cw_collect_write() 367 return Curl_cwriter_write(data, writer->next, type, buf, blen); in hds_cw_collect_write()
|
H A D | cfilters.c | 695 char *buf, size_t blen, ssize_t *n) in Curl_conn_recv() argument 701 nread = data->conn->recv[sockindex](data, sockindex, buf, blen, &result); in Curl_conn_recv() 709 const void *buf, size_t blen, in Curl_conn_send() argument 729 blen = CURLMIN(blen, altsize); in Curl_conn_send() 733 nwritten = conn->send[sockindex](data, sockindex, buf, blen, &result); in Curl_conn_send()
|
H A D | cf-h1-proxy.c | 260 size_t blen = request_len; in send_CONNECT() local 264 if(blen <= ts->nsent) in send_CONNECT() 267 blen -= ts->nsent; in send_CONNECT() 270 nwritten = cf->next->cft->do_send(cf->next, data, buf, blen, &result); in send_CONNECT() 278 DEBUGASSERT(blen >= (size_t)nwritten); in send_CONNECT()
|
/curl/src/ |
H A D | tool_doswin.c | 569 size_t blen = strlen(base); in rename_if_reserved_dos_device_name() local 570 if(blen) { in rename_if_reserved_dos_device_name() 572 --blen; in rename_if_reserved_dos_device_name() 573 if(!(flags & SANITIZE_ALLOW_TRUNCATE) || truncate_dryrun(base, blen)) in rename_if_reserved_dos_device_name() 575 base[blen] = '\0'; in rename_if_reserved_dos_device_name() 577 memmove(base + 1, base, blen + 1); in rename_if_reserved_dos_device_name()
|
/curl/lib/vtls/ |
H A D | rustls.c | 328 size_t blen = plainlen; in cr_send() local 347 if(blen > backend->plain_out_buffered) { in cr_send() 348 blen -= backend->plain_out_buffered; in cr_send() 352 blen = 0; in cr_send() 357 if(blen > 0) { in cr_send() 358 CURL_TRC_CF(data, cf, "cf_send: adding %zu plain bytes to rustls", blen); in cr_send() 359 rresult = rustls_connection_write(rconn, buf, blen, &plainwritten); in cr_send() 379 " bytes already to rustls", blen); in cr_send()
|
H A D | wolfssl.c | 283 const char *buf, int blen) in wolfssl_bio_cf_out_write() argument 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() 304 static int wolfssl_bio_cf_in_read(WOLFSSL_BIO *bio, char *buf, int blen) in wolfssl_bio_cf_in_read() argument 319 nread = Curl_conn_cf_recv(cf->next, data, buf, blen, &result); in wolfssl_bio_cf_in_read() 1146 size_t blen = 0; in wolfssl_connect_step2() local 1149 &b64str, &blen); in wolfssl_connect_step2() 1371 char *buf, size_t blen, in wolfssl_recv() argument 1378 int buffsize = (blen > (size_t)INT_MAX) ? INT_MAX : (int)blen; in wolfssl_recv() 1400 CURL_TRC_CF(data, cf, "wolfssl_recv(len=%zu) -> AGAIN", blen); in wolfssl_recv() [all …]
|
/curl/tests/http/clients/ |
H A D | h2-download.c | 177 size_t blen = (nitems * buflen); in my_write_cb() local 181 t->idx, (long)blen, (long)t->recv_size, (long)t->pause_at); in my_write_cb() 192 ((t->recv_size + (curl_off_t)blen) >= t->pause_at)) { in my_write_cb() 199 if(nwritten < blen) { in my_write_cb()
|
/curl/lib/vquic/ |
H A D | vquic.c | 281 size_t blen, sent; in vquic_flush() local 285 while(Curl_bufq_peek(&qctx->sendbuf, &buf, &blen)) { in vquic_flush() 289 if(blen > qctx->split_len) in vquic_flush() 290 blen = qctx->split_len; in vquic_flush() 293 result = vquic_send_packets(cf, data, qctx, buf, blen, gsolen, &sent); in vquic_flush() 295 blen, gsolen, result, sent); in vquic_flush()
|
H A D | curl_ngtcp2.c | 887 const char *buf, size_t blen, bool eos) in h3_xfer_write_resp() argument 892 stream->xfer_result = Curl_xfer_write_resp(data, buf, blen, eos); in h3_xfer_write_resp() 896 "of data", stream->id, stream->xfer_result, blen); in h3_xfer_write_resp() 902 const uint8_t *buf, size_t blen, in cb_h3_recv_data() argument 916 h3_xfer_write_resp(cf, data, stream, (char *)buf, blen, FALSE); in cb_h3_recv_data() 917 if(blen) { in cb_h3_recv_data() 919 stream->id, blen); in cb_h3_recv_data() 920 ngtcp2_conn_extend_max_stream_offset(ctx->qconn, stream->id, blen); in cb_h3_recv_data() 921 ngtcp2_conn_extend_max_offset(ctx->qconn, blen); in cb_h3_recv_data() 1186 char *buf, size_t blen, CURLcode *err) in cf_ngtcp2_recv() argument [all …]
|