Home
last modified time | relevance | path

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

/curl/lib/
H A Dpingpong.c149 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 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 Dws.c777 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 Dcf-h2-proxy.c71 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 Dcf-socket.c768 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 Dpop3.c257 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 Dimap.c360 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 Dkrb5.c240 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 Dftp.c558 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 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.c181 struct bufq recvbuf; /* response buffer */ member
/curl/tests/http/clients/
H A Dws-data.c105 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 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()
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 Dcurl_msh3.c144 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 Dcurl_quiche.c148 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()

Completed in 104 milliseconds