Home
last modified time | relevance | path

Searched refs:recvbuf (Results 1 – 17 of 17) sorted by relevance

/curl/lib/
H A Dpingpong.c149 Curl_dyn_init(&pp->recvbuf, DYN_PINGPPONG_CMD); in Curl_pp_init()
300 size_t full = Curl_dyn_len(&pp->recvbuf); in Curl_pp_readresp()
303 Curl_dyn_tail(&pp->recvbuf, full - pp->nfinal); in Curl_pp_readresp()
321 result = Curl_dyn_addn(&pp->recvbuf, buffer, gotbytes); in Curl_pp_readresp()
331 char *line = Curl_dyn_ptr(&pp->recvbuf); in Curl_pp_readresp()
358 if(Curl_dyn_len(&pp->recvbuf) > length) in Curl_pp_readresp()
359 pp->overflow = Curl_dyn_len(&pp->recvbuf) - length; in Curl_pp_readresp()
367 if(Curl_dyn_len(&pp->recvbuf) > length) in Curl_pp_readresp()
369 Curl_dyn_tail((&pp->recvbuf), Curl_dyn_len(&pp->recvbuf) - length); in Curl_pp_readresp()
371 Curl_dyn_reset(&pp->recvbuf); in Curl_pp_readresp()
[all …]
H A Dmqtt.c113 Curl_dyn_init(&mq->recvbuf, DYN_MQTT_RECV); in mqtt_setup_conn()
355 Curl_dyn_free(&mq->recvbuf); in mqtt_disconnect()
362 size_t rlen = Curl_dyn_len(&mq->recvbuf); in mqtt_recv_atleast()
376 rlen = Curl_dyn_len(&mq->recvbuf); in mqtt_recv_atleast()
384 size_t rlen = Curl_dyn_len(&mq->recvbuf); in mqtt_recv_consume()
386 Curl_dyn_reset(&mq->recvbuf); in mqtt_recv_consume()
403 ptr = Curl_dyn_ptr(&mq->recvbuf); in mqtt_verify_connack()
409 Curl_dyn_reset(&mq->recvbuf); in mqtt_verify_connack()
498 ptr = Curl_dyn_ptr(&mq->recvbuf); in mqtt_verify_suback()
504 Curl_dyn_reset(&mq->recvbuf); in mqtt_verify_suback()
[all …]
H A Dmqtt.h59 struct dynbuf recvbuf; member
H A Dws.h71 struct bufq recvbuf; /* raw data from the server */ member
H A Dpingpong.h62 struct dynbuf recvbuf; member
H A Dcf-h2-proxy.c71 struct bufq recvbuf; member
92 Curl_bufq_init2(&ts->recvbuf, PROXY_H2_CHUNK_SIZE, H2_TUNNEL_RECV_CHUNKS, in tunnel_stream_init()
112 Curl_bufq_free(&ts->recvbuf); in tunnel_stream_clear()
497 !Curl_bufq_is_full(&ctx->tunnel.recvbuf)) { in proxy_h2_progress_ingress()
864 nwritten = Curl_bufq_write(&ctx->tunnel.recvbuf, mem, len, &result); in tunnel_recv_callback()
1222 !Curl_bufq_is_empty(&ctx->tunnel.recvbuf))) in cf_h2_proxy_data_pending()
1319 if(!Curl_bufq_is_empty(&ctx->tunnel.recvbuf)) { in tunnel_recv()
1320 nread = Curl_bufq_read(&ctx->tunnel.recvbuf, in tunnel_recv()
1365 if(Curl_bufq_is_empty(&ctx->tunnel.recvbuf)) { in cf_h2_proxy_recv()
1386 if(!Curl_bufq_is_empty(&ctx->tunnel.recvbuf) && in cf_h2_proxy_recv()
[all …]
H A Dws.c780 Curl_bufq_init2(&ws->recvbuf, chunk_size, WS_CHUNK_COUNT, in Curl_ws_accept()
788 Curl_bufq_reset(&ws->recvbuf); in Curl_ws_accept()
837 nwritten = Curl_bufq_write(&ws->recvbuf, (const unsigned char *)mem, in Curl_ws_accept()
968 if(Curl_bufq_is_empty(&ws->recvbuf)) { in curl_ws_recv()
969 ssize_t n = Curl_bufq_slurp(&ws->recvbuf, nw_in_recv, data, &result); in curl_ws_recv()
979 Curl_bufq_len(&ws->recvbuf)); in curl_ws_recv()
982 result = ws_dec_pass(&ws->dec, data, &ws->recvbuf, in curl_ws_recv()
1271 Curl_bufq_free(&conn->proto.ws->recvbuf); in ws_free()
H A Dpop3.c313 char *message = Curl_dyn_ptr(&data->conn->proto.pop3c.pp.recvbuf); in pop3_get_message()
712 const char *line = Curl_dyn_ptr(&data->conn->proto.pop3c.pp.recvbuf); in pop3_state_servergreet_resp()
762 const char *line = Curl_dyn_ptr(&data->conn->proto.pop3c.pp.recvbuf); in pop3_state_capa_resp()
1005 Curl_dyn_tail(&pp->recvbuf, pp->overflow); in pop3_state_command_resp()
1009 result = pop3_write(data, Curl_dyn_ptr(&pp->recvbuf), in pop3_state_command_resp()
1010 Curl_dyn_len(&pp->recvbuf), FALSE); in pop3_state_command_resp()
1016 Curl_dyn_reset(&pp->recvbuf); in pop3_state_command_resp()
H A Dimap.c360 char *message = Curl_dyn_ptr(&data->conn->proto.imapc.pp.recvbuf); in imap_get_message()
901 const char *line = Curl_dyn_ptr(&imapc->pp.recvbuf); in imap_state_capability_resp()
1063 char *line = Curl_dyn_ptr(&data->conn->proto.imapc.pp.recvbuf); in imap_state_listsearch_resp()
1087 const char *line = Curl_dyn_ptr(&data->conn->proto.imapc.pp.recvbuf); in imap_state_select_resp()
1146 const char *ptr = Curl_dyn_ptr(&data->conn->proto.imapc.pp.recvbuf); in imap_state_fetch_resp()
1180 Curl_dyn_tail(&pp->recvbuf, chunk); in imap_state_fetch_resp()
1193 Curl_dyn_ptr(&pp->recvbuf), chunk); in imap_state_fetch_resp()
1204 Curl_dyn_tail(&pp->recvbuf, pp->overflow); in imap_state_fetch_resp()
1209 Curl_dyn_reset(&pp->recvbuf); in imap_state_fetch_resp()
H A Dkrb5.c241 char *line = Curl_dyn_ptr(&pp->recvbuf); in krb5_auth()
330 size_t len = Curl_dyn_len(&pp->recvbuf); in krb5_auth()
331 p = Curl_dyn_ptr(&pp->recvbuf); in krb5_auth()
792 line = Curl_dyn_ptr(&pp->recvbuf); in sec_set_protection_level()
H A Dftp.c436 if(Curl_dyn_len(&pp->recvbuf) && (*Curl_dyn_ptr(&pp->recvbuf) > '3')) { in ftp_check_ctrl_on_data_wait()
465 char *r = Curl_dyn_ptr(&pp->recvbuf); in ftp_check_ctrl_on_data_wait()
468 Curl_dyn_len(&pp->recvbuf)); in ftp_check_ctrl_on_data_wait()
567 char * const buf = Curl_dyn_ptr(&data->conn->proto.ftpc.pp.recvbuf); in ftp_readresp()
675 if(Curl_dyn_len(&pp->recvbuf) && (cache_skip < 2)) { in Curl_GetFTPResponse()
709 if(!nread && Curl_dyn_len(&pp->recvbuf)) in Curl_GetFTPResponse()
1788 Curl_dyn_ptr(&pp->recvbuf) + 4; /* start on the first letter */ in ftp_state_pasv_resp()
2067 char *resp = Curl_dyn_ptr(&pp->recvbuf) + 4; in ftp_state_mdtm_resp()
2280 char *buf = Curl_dyn_ptr(&data->conn->proto.ftpc.pp.recvbuf); in ftp_state_size_resp()
2464 char *buf = Curl_dyn_ptr(&conn->proto.ftpc.pp.recvbuf); in ftp_state_get_resp()
[all …]
H A Dsmtp.c256 char *message = Curl_dyn_ptr(&data->conn->proto.smtpc.pp.recvbuf); in smtp_get_message()
888 const char *line = Curl_dyn_ptr(&smtpc->pp.recvbuf); in smtp_state_ehlo_resp()
1038 char *line = Curl_dyn_ptr(&data->conn->proto.smtpc.pp.recvbuf); in smtp_state_command_resp()
H A Dhttp2.c201 struct bufq recvbuf; /* response buffer */ member
/curl/tests/http/clients/
H A Dws-data.c109 char recvbuf[256]; in recv_binary() local
116 result = curl_ws_recv(curl, recvbuf, sizeof(recvbuf), &nread, &frame); in recv_binary()
127 (long)r_offset, (long)sizeof(recvbuf), result, (long)nread); in recv_binary()
151 if(memcmp(exp_data + r_offset, recvbuf, nread)) { in recv_binary()
155 dump("received:", (unsigned char *)recvbuf, nread, 0); in recv_binary()
/curl/lib/vquic/
H A Dcurl_osslq.c216 struct bufq recvbuf; /* QUIC war data recv buffer */ member
230 Curl_bufq_initp(&s->recvbuf, bufcp, 1, BUFQ_OPT_NONE); in cf_osslq_stream_open()
246 Curl_bufq_free(&s->recvbuf); in cf_osslq_stream_cleanup()
576 struct bufq recvbuf; /* h3 response body */ member
598 Curl_bufq_free(&stream->recvbuf); in h3_stream_ctx_free()
1337 if(!Curl_bufq_is_empty(&s->recvbuf)) { in cf_osslq_stream_recv()
1355 Curl_bufq_skip(&s->recvbuf, blen); in cf_osslq_stream_recv()
1447 !Curl_bufq_is_full(&stream->recvbuf)) { in cf_progress_ingress()
2054 if(!Curl_bufq_is_empty(&stream->recvbuf)) { in cf_osslq_recv()
2055 nread = Curl_bufq_read(&stream->recvbuf, in cf_osslq_recv()
[all …]
H A Dcurl_msh3.c166 struct bufq recvbuf; /* h3 response */ member
187 Curl_bufq_free(&stream->recvbuf); in h3_stream_ctx_free()
212 Curl_bufq_init2(&stream->recvbuf, H3_STREAM_CHUNK_SIZE, in h3_data_setup()
361 nwritten = Curl_bufq_write(&stream->recvbuf, mem, memlen, &result); in write_resp_raw()
591 if(!Curl_bufq_is_empty(&stream->recvbuf)) { in cf_msh3_recv()
592 nread = Curl_bufq_read(&stream->recvbuf, in cf_msh3_recv()
748 Curl_bufq_len(&stream->recvbuf)); in cf_msh3_data_pending()
749 pending = !Curl_bufq_is_empty(&stream->recvbuf); in cf_msh3_data_pending()
H A Dcurl_quiche.c171 struct bufq recvbuf; /* h3 response */ member
188 Curl_bufq_free(&stream->recvbuf); in h3_stream_ctx_free()
233 Curl_bufq_initp(&stream->recvbuf, &ctx->stream_bufcp, in h3_data_setup()
353 nwritten = Curl_bufq_write(&stream->recvbuf, mem, memlen, &result); in write_resp_raw()
458 nwritten = Curl_bufq_slurp(&stream->recvbuf, in cf_recv_body()
857 if(!Curl_bufq_is_empty(&stream->recvbuf)) { in cf_quiche_recv()
858 nread = Curl_bufq_read(&stream->recvbuf, in cf_quiche_recv()
874 if(nread < 0 && !Curl_bufq_is_empty(&stream->recvbuf)) { in cf_quiche_recv()
875 nread = Curl_bufq_read(&stream->recvbuf, in cf_quiche_recv()
1200 return stream && !Curl_bufq_is_empty(&stream->recvbuf); in cf_quiche_data_pending()

Completed in 65 milliseconds