/curl/lib/ |
H A D | request.c | 75 Curl_bufq_reset(&req->sendbuf); in Curl_req_soft_reset() 77 Curl_bufq_free(&req->sendbuf); in Curl_req_soft_reset() 115 Curl_bufq_reset(&req->sendbuf); in Curl_req_hard_reset() 168 Curl_bufq_free(&req->sendbuf); in Curl_req_free() 238 Curl_bufq_skip(&data->req.sendbuf, nwritten); in req_send_buffer_flush() 283 if(!Curl_bufq_is_empty(&data->req.sendbuf)) { in req_flush() 287 if(!Curl_bufq_is_empty(&data->req.sendbuf)) { in req_flush() 293 Curl_bufq_is_empty(&data->req.sendbuf)) { in req_flush() 323 n = Curl_bufq_write(&data->req.sendbuf, in req_send_buffer_add() 376 DEBUGASSERT(Curl_bufq_is_empty(&data->req.sendbuf)); in Curl_req_done_sending() [all …]
|
H A D | pingpong.c | 148 Curl_dyn_init(&pp->sendbuf, DYN_PINGPPONG_CMD); in Curl_pp_init() 185 Curl_dyn_reset(&pp->sendbuf); in Curl_pp_vsendf() 186 result = Curl_dyn_vaddf(&pp->sendbuf, fmt, args); in Curl_pp_vsendf() 191 result = Curl_dyn_addn(&pp->sendbuf, "\r\n", 2); in Curl_pp_vsendf() 196 write_len = Curl_dyn_len(&pp->sendbuf); in Curl_pp_vsendf() 197 s = Curl_dyn_ptr(&pp->sendbuf); in Curl_pp_vsendf() 428 Curl_dyn_free(&pp->sendbuf); in Curl_pp_disconnect()
|
H A D | ws.h | 72 struct bufq sendbuf; /* raw data to be sent to the server */ member
|
H A D | file.c | 307 const char *sendbuf; in file_upload() local 375 sendbuf = xfer_ulbuf; in file_upload() 378 sendbuf = xfer_ulbuf + data->state.resume_from; in file_upload() 384 sendbuf = xfer_ulbuf; in file_upload() 387 nwrite = write(fd, sendbuf, nread); in file_upload()
|
H A D | ws.c | 779 Curl_bufq_init2(&ws->sendbuf, chunk_size, WS_CHUNK_COUNT, in Curl_ws_accept() 1013 if(!Curl_bufq_is_empty(&ws->sendbuf)) { in ws_flush() 1018 while(Curl_bufq_peek(&ws->sendbuf, &out, &outlen)) { in ws_flush() 1031 Curl_bufq_len(&ws->sendbuf)); in ws_flush() 1046 Curl_bufq_skip(&ws->sendbuf, n); in ws_flush() 1109 space = Curl_bufq_space(&ws->sendbuf); in curl_ws_send() 1111 buflen, Curl_bufq_len(&ws->sendbuf), space)); in curl_ws_send() 1119 &ws->sendbuf, &result); in curl_ws_send() 1133 &ws->sendbuf, &result); in curl_ws_send() 1139 buffer, buflen, &ws->sendbuf, &result); in curl_ws_send() [all …]
|
H A D | pingpong.h | 61 struct dynbuf sendbuf; member
|
H A D | request.h | 93 struct bufq sendbuf; /* data which needs to be send to the server */ member
|
H A D | cf-h2-proxy.c | 72 struct bufq sendbuf; member 95 Curl_bufq_init(&ts->sendbuf, PROXY_H2_CHUNK_SIZE, H2_TUNNEL_SEND_CHUNKS); in tunnel_stream_init() 113 Curl_bufq_free(&ts->sendbuf); in tunnel_stream_clear() 831 nread = Curl_bufq_read(&ts->sendbuf, buf, length, &result); in tunnel_send_callback() 837 if(ts->closed && Curl_bufq_is_empty(&ts->sendbuf)) in tunnel_send_callback() 1374 nwritten = Curl_bufq_write(&ctx->tunnel.sendbuf, buf, len, err); in cf_h2_proxy_send() 1382 if(!Curl_bufq_is_empty(&ctx->tunnel.sendbuf)) { in cf_h2_proxy_send() 1410 else if(!Curl_bufq_is_empty(&ctx->tunnel.sendbuf)) { in cf_h2_proxy_send() 1474 Curl_bufq_len(&ctx->tunnel.sendbuf), in cf_h2_proxy_send()
|
H A D | http2.c | 182 struct bufq sendbuf; /* request buffer */ member 221 Curl_bufq_initp(&stream->sendbuf, &ctx->stream_bufcp, in h2_stream_ctx_create() 248 Curl_bufq_free(&stream->sendbuf); in h2_stream_ctx_free() 1601 nread = Curl_bufq_read(&stream->sendbuf, buf, length, &result); in req_body_read_callback() 1691 stream->upload_left = Curl_bufq_len(&stream->sendbuf); in http2_data_done_send() 2167 ssize_t n = Curl_bufq_write(&stream->sendbuf, body, bodylen, err); in h2_submit() 2241 nwritten = Curl_bufq_write(&stream->sendbuf, buf, len, err); in cf_h2_send() 2246 if(!Curl_bufq_is_empty(&stream->sendbuf)) { in cf_h2_send() 2284 else if(stream && !Curl_bufq_is_empty(&stream->sendbuf)) { in cf_h2_send() 2342 Curl_bufq_len(&stream->sendbuf), in cf_h2_send() [all …]
|
/curl/lib/vquic/ |
H A D | vquic.c | 89 Curl_bufq_init2(&qctx->sendbuf, NW_CHUNK_SIZE, NW_SEND_CHUNKS, in vquic_ctx_init() 113 Curl_bufq_free(&qctx->sendbuf); in vquic_ctx_free() 285 while(Curl_bufq_peek(&qctx->sendbuf, &buf, &blen)) { in vquic_flush() 298 Curl_bufq_skip(&qctx->sendbuf, sent); in vquic_flush() 304 Curl_bufq_skip(&qctx->sendbuf, sent); in vquic_flush() 322 DEBUGASSERT(Curl_bufq_len(&qctx->sendbuf) > tail_len); in vquic_send_tail_split() 323 qctx->split_len = Curl_bufq_len(&qctx->sendbuf) - tail_len; in vquic_send_tail_split()
|
H A D | vquic_int.h | 42 struct bufq sendbuf; /* buffer for sending one or more packets */ member
|
H A D | curl_ngtcp2.c | 162 struct bufq sendbuf; /* h3 request body */ member 184 Curl_bufq_free(&stream->sendbuf); in h3_stream_ctx_free() 215 Curl_bufq_initp(&stream->sendbuf, &ctx->stream_bufcp, in h3_data_setup() 830 !Curl_bufq_is_empty(&ctx->q.sendbuf); in cf_ngtcp2_adjust_pollset() 1268 Curl_bufq_skip(&stream->sendbuf, skiplen); in cb_h3_acked_req_body() 1311 Curl_bufq_peek_at(&stream->sendbuf, in cb_h3_read_req_body() 1343 nwritten, Curl_bufq_len(&stream->sendbuf), in cb_h3_read_req_body() 1568 sent = Curl_bufq_write(&stream->sendbuf, buf, len, err); in cf_ngtcp2_send() 1846 ctx->q.sendbuf.chunk_size / max_payload_size); in cf_progress_egress() 1850 nread = Curl_bufq_sipn(&ctx->q.sendbuf, max_payload_size, in cf_progress_egress() [all …]
|
H A D | curl_osslq.c | 483 struct bufq sendbuf; /* h3 request body */ member 506 Curl_bufq_free(&stream->sendbuf); in h3_stream_ctx_free() 538 Curl_bufq_initp(&stream->sendbuf, &ctx->stream_bufcp, in h3_data_setup() 917 if(stream->sendbuf_len_in_flight < Curl_bufq_len(&stream->sendbuf)) { in cb_h3_read_req_body() 920 Curl_bufq_peek_at(&stream->sendbuf, in cb_h3_read_req_body() 952 nwritten, Curl_bufq_len(&stream->sendbuf), in cb_h3_read_req_body() 977 Curl_bufq_skip(&stream->sendbuf, skiplen); in cb_h3_acked_stream_data() 1905 nwritten = Curl_bufq_write(&stream->sendbuf, buf, len, err); in cf_osslq_send() 2093 stream->upload_left = Curl_bufq_len(&stream->sendbuf); in cf_osslq_data_event()
|
H A D | curl_quiche.c | 745 nread = Curl_bufq_sipn(&ctx->q.sendbuf, 0, in cf_flush_egress() 1158 !Curl_bufq_is_empty(&ctx->q.sendbuf); in cf_quiche_adjust_pollset()
|