/curl/lib/ |
H A D | pingpong.c | 149 Curl_dyn_init(&pp->recvbuf, DYN_PINGPPONG_CMD); in Curl_pp_init() 295 size_t full = Curl_dyn_len(&pp->recvbuf); in Curl_pp_readresp() 298 Curl_dyn_tail(&pp->recvbuf, full - pp->nfinal); in Curl_pp_readresp() 318 result = Curl_dyn_addn(&pp->recvbuf, buffer, gotbytes); in Curl_pp_readresp() 328 char *line = Curl_dyn_ptr(&pp->recvbuf); in Curl_pp_readresp() 355 if(Curl_dyn_len(&pp->recvbuf) > length) in Curl_pp_readresp() 356 pp->overflow = Curl_dyn_len(&pp->recvbuf) - length; in Curl_pp_readresp() 363 if(Curl_dyn_len(&pp->recvbuf) > length) in Curl_pp_readresp() 365 Curl_dyn_tail((&pp->recvbuf), Curl_dyn_len(&pp->recvbuf) - length); in Curl_pp_readresp() 367 Curl_dyn_reset(&pp->recvbuf); in Curl_pp_readresp() [all …]
|
H A D | mqtt.c | 113 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 D | mqtt.h | 59 struct dynbuf recvbuf; member
|
H A D | ws.h | 71 struct bufq recvbuf; /* raw data from the server */ member
|
H A D | pingpong.h | 62 struct dynbuf recvbuf; member
|
H A D | ws.c | 777 Curl_bufq_init2(&ws->recvbuf, chunk_size, WS_CHUNK_COUNT, in Curl_ws_accept() 785 Curl_bufq_reset(&ws->recvbuf); in Curl_ws_accept() 834 nwritten = Curl_bufq_write(&ws->recvbuf, (const unsigned char *)mem, in Curl_ws_accept() 963 if(Curl_bufq_is_empty(&ws->recvbuf)) { in curl_ws_recv() 964 ssize_t n = Curl_bufq_slurp(&ws->recvbuf, nw_in_recv, data, &result); in curl_ws_recv() 974 Curl_bufq_len(&ws->recvbuf))); in curl_ws_recv() 977 result = ws_dec_pass(&ws->dec, data, &ws->recvbuf, in curl_ws_recv() 1150 Curl_bufq_free(&conn->proto.ws->recvbuf); in ws_free()
|
H A D | cf-h2-proxy.c | 71 struct bufq recvbuf; member 93 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() 492 !Curl_bufq_is_full(&ctx->tunnel.recvbuf)) { in proxy_h2_progress_ingress() 861 nwritten = Curl_bufq_write(&ctx->tunnel.recvbuf, mem, len, &result); in tunnel_recv_callback() 1175 !Curl_bufq_is_empty(&ctx->tunnel.recvbuf))) in cf_h2_proxy_data_pending() 1248 if(!Curl_bufq_is_empty(&ctx->tunnel.recvbuf)) { in tunnel_recv() 1249 nread = Curl_bufq_read(&ctx->tunnel.recvbuf, in tunnel_recv() 1293 if(Curl_bufq_is_empty(&ctx->tunnel.recvbuf)) { in cf_h2_proxy_recv() 1323 if(!Curl_bufq_is_empty(&ctx->tunnel.recvbuf) && in cf_h2_proxy_recv() [all …]
|
H A D | cf-socket.c | 768 struct bufq recvbuf; /* used when `buffer_recv` is set */ member 799 Curl_bufq_init(&ctx->recvbuf, NW_RECV_CHUNK_SIZE, NW_RECV_CHUNKS); in cf_socket_ctx_init() 893 Curl_bufq_reset(&ctx->recvbuf); in cf_socket_close() 909 Curl_bufq_free(&ctx->recvbuf); in cf_socket_destroy() 1264 if(!Curl_bufq_is_empty(&ctx->recvbuf)) in cf_socket_data_pending() 1413 if(ctx->buffer_recv && !Curl_bufq_is_empty(&ctx->recvbuf)) { in cf_socket_recv() 1415 nread = Curl_bufq_read(&ctx->recvbuf, (unsigned char *)buf, len, err); in cf_socket_recv() 1427 nwritten = Curl_bufq_slurp(&ctx->recvbuf, nw_in_read, &rctx, err); in cf_socket_recv() 1428 if(nwritten < 0 && !Curl_bufq_is_empty(&ctx->recvbuf)) { in cf_socket_recv() 1432 nread = Curl_bufq_read(&ctx->recvbuf, (unsigned char *)buf, len, err); in cf_socket_recv() [all …]
|
H A D | pop3.c | 257 char *message = Curl_dyn_ptr(&data->conn->proto.pop3c.pp.recvbuf); in pop3_get_message() 654 const char *line = Curl_dyn_ptr(&data->conn->proto.pop3c.pp.recvbuf); in pop3_state_servergreet_resp() 704 const char *line = Curl_dyn_ptr(&data->conn->proto.pop3c.pp.recvbuf); in pop3_state_capa_resp() 947 Curl_dyn_tail(&pp->recvbuf, pp->overflow); in pop3_state_command_resp() 951 result = Curl_pop3_write(data, Curl_dyn_ptr(&pp->recvbuf), in pop3_state_command_resp() 952 Curl_dyn_len(&pp->recvbuf)); in pop3_state_command_resp() 958 Curl_dyn_reset(&pp->recvbuf); in pop3_state_command_resp()
|
H A D | imap.c | 360 char *message = Curl_dyn_ptr(&data->conn->proto.imapc.pp.recvbuf); in imap_get_message() 902 const char *line = Curl_dyn_ptr(&imapc->pp.recvbuf); in imap_state_capability_resp() 1064 char *line = Curl_dyn_ptr(&data->conn->proto.imapc.pp.recvbuf); in imap_state_listsearch_resp() 1088 const char *line = Curl_dyn_ptr(&data->conn->proto.imapc.pp.recvbuf); in imap_state_select_resp() 1147 const char *ptr = Curl_dyn_ptr(&data->conn->proto.imapc.pp.recvbuf); in imap_state_fetch_resp() 1182 Curl_dyn_tail(&pp->recvbuf, chunk); in imap_state_fetch_resp() 1195 Curl_dyn_ptr(&pp->recvbuf), chunk); in imap_state_fetch_resp() 1206 Curl_dyn_tail(&pp->recvbuf, pp->overflow); in imap_state_fetch_resp() 1211 Curl_dyn_reset(&pp->recvbuf); in imap_state_fetch_resp()
|
H A D | krb5.c | 240 char *line = Curl_dyn_ptr(&pp->recvbuf); in krb5_auth() 329 size_t len = Curl_dyn_len(&pp->recvbuf); in krb5_auth() 330 p = Curl_dyn_ptr(&pp->recvbuf); in krb5_auth() 787 line = Curl_dyn_ptr(&pp->recvbuf); in sec_set_protection_level()
|
H A D | ftp.c | 558 if(Curl_dyn_len(&pp->recvbuf) && (*Curl_dyn_ptr(&pp->recvbuf) > '3')) { in ReceivedServerConnect() 591 char *r = Curl_dyn_ptr(&pp->recvbuf); in ReceivedServerConnect() 594 Curl_dyn_len(&pp->recvbuf)); in ReceivedServerConnect() 753 char * const buf = Curl_dyn_ptr(&data->conn->proto.ftpc.pp.recvbuf); in ftp_readresp() 859 if(Curl_dyn_len(&pp->recvbuf) && (cache_skip < 2)) { in Curl_GetFTPResponse() 887 if(!nread && Curl_dyn_len(&pp->recvbuf)) in Curl_GetFTPResponse() 1954 Curl_dyn_ptr(&pp->recvbuf) + 4; /* start on the first letter */ in ftp_state_pasv_resp() 2233 char *resp = Curl_dyn_ptr(&pp->recvbuf) + 4; in ftp_state_mdtm_resp() 2445 char *buf = Curl_dyn_ptr(&data->conn->proto.ftpc.pp.recvbuf); in ftp_state_size_resp() 2629 char *buf = Curl_dyn_ptr(&conn->proto.ftpc.pp.recvbuf); in ftp_state_get_resp() [all …]
|
H A D | smtp.c | 256 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 D | http2.c | 181 struct bufq recvbuf; /* response buffer */ member
|
/curl/tests/http/clients/ |
H A D | ws-data.c | 105 char recvbuf[256]; in recv_binary() local 112 result = curl_ws_recv(curl, recvbuf, sizeof(recvbuf), &nread, &frame); in recv_binary() 119 (long)r_offset, (long)sizeof(recvbuf), result, (long)nread); in recv_binary() 143 if(memcmp(exp_data + r_offset, recvbuf, nread)) { in recv_binary() 147 dump("received:", (unsigned char *)recvbuf, nread, 0); in recv_binary()
|
/curl/lib/vquic/ |
H A D | curl_osslq.c | 216 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() 484 struct bufq recvbuf; /* h3 response body */ member 507 Curl_bufq_free(&stream->recvbuf); in h3_stream_ctx_free() 1250 if(!Curl_bufq_is_empty(&s->recvbuf)) { in cf_osslq_stream_recv() 1268 Curl_bufq_skip(&s->recvbuf, blen); in cf_osslq_stream_recv() 1358 !Curl_bufq_is_full(&stream->recvbuf)) { in cf_progress_ingress() 1995 if(!Curl_bufq_is_empty(&stream->recvbuf)) { in cf_osslq_recv() 1996 nread = Curl_bufq_read(&stream->recvbuf, in cf_osslq_recv() [all …]
|
H A D | curl_msh3.c | 144 struct bufq recvbuf; /* h3 response */ member 165 Curl_bufq_free(&stream->recvbuf); in h3_stream_ctx_free() 190 Curl_bufq_init2(&stream->recvbuf, H3_STREAM_CHUNK_SIZE, in h3_data_setup() 339 nwritten = Curl_bufq_write(&stream->recvbuf, mem, memlen, &result); in write_resp_raw() 569 if(!Curl_bufq_is_empty(&stream->recvbuf)) { in cf_msh3_recv() 570 nread = Curl_bufq_read(&stream->recvbuf, in cf_msh3_recv() 741 Curl_bufq_len(&stream->recvbuf)); in cf_msh3_data_pending() 742 pending = !Curl_bufq_is_empty(&stream->recvbuf); in cf_msh3_data_pending()
|
H A D | curl_quiche.c | 148 struct bufq recvbuf; /* h3 response */ member 166 Curl_bufq_free(&stream->recvbuf); in h3_stream_ctx_free() 211 Curl_bufq_initp(&stream->recvbuf, &ctx->stream_bufcp, in h3_data_setup() 329 nwritten = Curl_bufq_write(&stream->recvbuf, mem, memlen, &result); in write_resp_raw() 434 nwritten = Curl_bufq_slurp(&stream->recvbuf, in cf_recv_body() 833 if(!Curl_bufq_is_empty(&stream->recvbuf)) { in cf_quiche_recv() 834 nread = Curl_bufq_read(&stream->recvbuf, in cf_quiche_recv() 850 if(nread < 0 && !Curl_bufq_is_empty(&stream->recvbuf)) { in cf_quiche_recv() 851 nread = Curl_bufq_read(&stream->recvbuf, in cf_quiche_recv() 1174 return stream && !Curl_bufq_is_empty(&stream->recvbuf); in cf_quiche_data_pending()
|