Home
last modified time | relevance | path

Searched refs:blen (Results 1 – 25 of 36) sorted by relevance

12

/curl/tests/libtest/
H A Dlib2302.c32 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 Dhttp_chunks.c145 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 Drequest.c198 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 Dcw-out.c213 *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 Drtsp.c637 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 Dsendf.c662 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 Dtransfer.h67 const char *buf, size_t blen,
101 const void *buf, size_t blen,
110 char *buf, size_t blen,
H A Dtransfer.c179 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 Dsendf.h212 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 Dcontent_encoding.h30 void Curl_all_content_encodings(char *buf, size_t blen);
H A Dcf-h2-proxy.c444 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 Dhttp_chunks.h127 char *buf, size_t blen, size_t *pconsumed);
H A Dhttp2.c563 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 Dhttp.h135 const char *buf, size_t blen,
198 const char *buf, size_t blen,
H A Dcontent_encoding.c864 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 Dhttp.c3465 *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 Dheaders.c353 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 Dcfilters.c695 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 Dcf-h1-proxy.c260 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/lib/vtls/
H A Dwolfssl.c289 const char *buf, int blen) in wolfssl_bio_cf_out_write() argument
300 nwritten = Curl_conn_cf_send(cf->next, data, buf, blen, &result); in wolfssl_bio_cf_out_write()
303 blen, nwritten, result); in wolfssl_bio_cf_out_write()
325 nread = Curl_conn_cf_recv(cf->next, data, buf, blen, &result); in wolfssl_bio_cf_in_read()
961 size_t blen = 0; in wolfssl_connect_step2() local
964 &b64str, &blen); in wolfssl_connect_step2()
1186 char *buf, size_t blen, in wolfssl_recv() argument
1193 int buffsize = (blen > (size_t)INT_MAX) ? INT_MAX : (int)blen; in wolfssl_recv()
1208 CURL_TRC_CF(data, cf, "wolfssl_recv(len=%zu) -> CLOSED", blen); in wolfssl_recv()
1215 CURL_TRC_CF(data, cf, "wolfssl_recv(len=%zu) -> AGAIN", blen); in wolfssl_recv()
[all …]
H A Drustls.c328 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()
/curl/src/
H A Dtool_doswin.c569 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/tests/http/clients/
H A Dh2-download.c177 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 Dvquic.c281 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 Dcurl_ngtcp2.c886 const char *buf, size_t blen, bool eos) in h3_xfer_write_resp() argument
891 stream->xfer_result = Curl_xfer_write_resp(data, buf, blen, eos); in h3_xfer_write_resp()
895 "of data", stream->id, stream->xfer_result, blen); in h3_xfer_write_resp()
901 const uint8_t *buf, size_t blen, in cb_h3_recv_data() argument
915 h3_xfer_write_resp(cf, data, stream, (char *)buf, blen, FALSE); in cb_h3_recv_data()
916 if(blen) { in cb_h3_recv_data()
918 stream->id, blen); in cb_h3_recv_data()
919 ngtcp2_conn_extend_max_stream_offset(ctx->qconn, stream->id, blen); in cb_h3_recv_data()
920 ngtcp2_conn_extend_max_offset(ctx->qconn, blen); in cb_h3_recv_data()
1185 char *buf, size_t blen, CURLcode *err) in cf_ngtcp2_recv() argument
[all …]

Completed in 128 milliseconds

12