Home
last modified time | relevance | path

Searched refs:sendbuf (Results 1 – 14 of 14) sorted by relevance

/curl/lib/
H A Drequest.c80 Curl_bufq_reset(&req->sendbuf); in Curl_req_soft_reset()
82 Curl_bufq_free(&req->sendbuf); in Curl_req_soft_reset()
123 Curl_bufq_reset(&req->sendbuf); in Curl_req_hard_reset()
177 Curl_bufq_free(&req->sendbuf); in Curl_req_free()
216 (Curl_bufq_is_empty(&data->req.sendbuf) || in xfer_send()
252 Curl_bufq_skip(&data->req.sendbuf, nwritten); in req_send_buffer_flush()
274 Curl_bufq_reset(&data->req.sendbuf); in Curl_req_set_upload_done()
301 if(!Curl_bufq_is_empty(&data->req.sendbuf)) { in req_flush()
371 n = Curl_bufq_write(&data->req.sendbuf, in req_send_buffer_add()
446 !Curl_bufq_is_full(&data->req.sendbuf)) { in Curl_req_send_more()
[all …]
H A Dpingpong.c148 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()
444 Curl_dyn_free(&pp->sendbuf); in Curl_pp_disconnect()
H A Dws.c1016 if(!Curl_bufq_is_empty(&ws->sendbuf)) { in ws_flush()
1021 while(Curl_bufq_peek(&ws->sendbuf, &out, &outlen)) { in ws_flush()
1036 Curl_bufq_len(&ws->sendbuf)); in ws_flush()
1045 Curl_bufq_skip(&ws->sendbuf, n); in ws_flush()
1178 space = Curl_bufq_space(&ws->sendbuf); in curl_ws_send()
1180 buflen, Curl_bufq_len(&ws->sendbuf), space); in curl_ws_send()
1190 &ws->sendbuf, &result); in curl_ws_send()
1204 &ws->sendbuf, &result); in curl_ws_send()
1230 payload_added = Curl_bufq_len(&ws->sendbuf); in curl_ws_send()
1255 result = Curl_bufq_unwrite(&ws->sendbuf, 1); in curl_ws_send()
[all …]
H A Dws.h72 struct bufq sendbuf; /* raw data to be sent to the server */ member
H A Dfile.c307 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 Dcf-h2-proxy.c72 struct bufq sendbuf; member
113 Curl_bufq_free(&ts->sendbuf); in tunnel_stream_clear()
226 !Curl_bufq_is_empty(&ctx->tunnel.sendbuf)) in drain_tunnel()
840 if(ts->closed && Curl_bufq_is_empty(&ts->sendbuf)) in tunnel_send_callback()
1239 !Curl_bufq_is_empty(&ctx->tunnel.sendbuf); in cf_h2_proxy_adjust_pollset()
1257 !Curl_bufq_is_empty(&ctx->tunnel.sendbuf); in cf_h2_proxy_adjust_pollset()
1427 if(!Curl_bufq_is_empty(&ctx->tunnel.sendbuf)) { in cf_h2_proxy_send()
1480 Curl_bufq_len(&ctx->tunnel.sendbuf), in cf_h2_proxy_send()
1494 if(!Curl_bufq_is_empty(&ctx->tunnel.sendbuf)) { in cf_h2_proxy_flush()
1512 Curl_bufq_len(&ctx->tunnel.sendbuf), in cf_h2_proxy_flush()
[all …]
H A Dpingpong.h61 struct dynbuf sendbuf; member
H A Drequest.h96 struct bufq sendbuf; /* data which needs to be send to the server */ member
H A Dhttp2.c202 struct bufq sendbuf; /* request buffer */ member
239 Curl_bufq_initp(&stream->sendbuf, &ctx->stream_bufcp, in h2_stream_ctx_create()
265 Curl_bufq_free(&stream->sendbuf); in h2_stream_ctx_free()
361 (!stream->body_eos || !Curl_bufq_is_empty(&stream->sendbuf))) in drain_stream()
1179 else if(!Curl_bufq_is_empty(&stream->sendbuf)) { in on_stream_frame()
2139 nwritten = Curl_bufq_write(&stream->sendbuf, buf, blen, err); in cf_h2_body_send()
2146 if(eos || !Curl_bufq_is_empty(&stream->sendbuf)) { in cf_h2_body_send()
2360 Curl_bufq_len(&stream->sendbuf), in cf_h2_send()
2383 if(stream && !Curl_bufq_is_empty(&stream->sendbuf)) { in cf_h2_flush()
2403 Curl_bufq_len(&stream->sendbuf), in cf_h2_flush()
[all …]
/curl/lib/vquic/
H A Dvquic.c81 Curl_bufq_init2(&qctx->sendbuf, NW_CHUNK_SIZE, NW_SEND_CHUNKS, in vquic_ctx_init()
105 Curl_bufq_free(&qctx->sendbuf); in vquic_ctx_free()
277 while(Curl_bufq_peek(&qctx->sendbuf, &buf, &blen)) { in vquic_flush()
290 Curl_bufq_skip(&qctx->sendbuf, sent); in vquic_flush()
296 Curl_bufq_skip(&qctx->sendbuf, sent); in vquic_flush()
314 DEBUGASSERT(Curl_bufq_len(&qctx->sendbuf) > tail_len); in vquic_send_tail_split()
315 qctx->split_len = Curl_bufq_len(&qctx->sendbuf) - tail_len; in vquic_send_tail_split()
H A Dvquic_int.h42 struct bufq sendbuf; /* buffer for sending one or more packets */ member
H A Dcurl_ngtcp2.c191 struct bufq sendbuf; /* h3 request body */ member
212 Curl_bufq_free(&stream->sendbuf); in h3_stream_ctx_free()
241 Curl_bufq_initp(&stream->sendbuf, &ctx->stream_bufcp, in h3_data_setup()
852 if(!want_send && !Curl_bufq_is_empty(&ctx->q.sendbuf)) in cf_ngtcp2_adjust_pollset()
867 !Curl_bufq_is_empty(&ctx->q.sendbuf); in cf_ngtcp2_adjust_pollset()
1304 Curl_bufq_skip(&stream->sendbuf, skiplen); in cb_h3_acked_req_body()
1347 Curl_bufq_peek_at(&stream->sendbuf, in cb_h3_read_req_body()
2022 if(!Curl_bufq_is_empty(&ctx->q.sendbuf)) { in cf_ngtcp2_shutdown()
2025 if(!Curl_bufq_is_empty(&ctx->q.sendbuf)) { in cf_ngtcp2_shutdown()
2060 if(!Curl_bufq_is_empty(&ctx->q.sendbuf)) { in cf_ngtcp2_shutdown()
[all …]
H A Dcurl_osslq.c575 struct bufq sendbuf; /* h3 request body */ member
597 Curl_bufq_free(&stream->sendbuf); in h3_stream_ctx_free()
627 Curl_bufq_initp(&stream->sendbuf, &ctx->stream_bufcp, in h3_data_setup()
1007 if(stream->sendbuf_len_in_flight < Curl_bufq_len(&stream->sendbuf)) { in cb_h3_read_req_body()
1010 Curl_bufq_peek_at(&stream->sendbuf, in cb_h3_read_req_body()
1041 nwritten, Curl_bufq_len(&stream->sendbuf), in cb_h3_read_req_body()
1066 Curl_bufq_skip(&stream->sendbuf, skiplen); in cb_h3_acked_stream_data()
1070 if(stream->sendbuf_len_in_flight < Curl_bufq_len(&stream->sendbuf)) { in cb_h3_acked_stream_data()
1976 nwritten = Curl_bufq_write(&stream->sendbuf, buf, len, err); in cf_osslq_send()
2152 stream->upload_left = Curl_bufq_len(&stream->sendbuf) - in cf_osslq_data_event()
H A Dcurl_quiche.c769 nread = Curl_bufq_sipn(&ctx->q.sendbuf, 0, in cf_flush_egress()
1184 !Curl_bufq_is_empty(&ctx->q.sendbuf); in cf_quiche_adjust_pollset()
1499 if(!Curl_bufq_is_empty(&ctx->q.sendbuf)) { in cf_quiche_shutdown()
1506 if(Curl_bufq_is_empty(&ctx->q.sendbuf)) { in cf_quiche_shutdown()

Completed in 46 milliseconds