Home
last modified time | relevance | path

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

/curl/lib/
H A Drequest.c75 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 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()
428 Curl_dyn_free(&pp->sendbuf); in Curl_pp_disconnect()
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 Dws.c779 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 Dpingpong.h61 struct dynbuf sendbuf; member
H A Drequest.h93 struct bufq sendbuf; /* data which needs to be send to the server */ member
H A Dcf-h2-proxy.c72 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 Dhttp2.c182 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 Dvquic.c89 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 Dvquic_int.h42 struct bufq sendbuf; /* buffer for sending one or more packets */ member
H A Dcurl_ngtcp2.c162 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 Dcurl_osslq.c483 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 Dcurl_quiche.c745 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()

Completed in 84 milliseconds