Lines Matching refs:recvbuf
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()
465 Curl_bufq_initp(&nstream->recvbuf, &ctx->stream_bufcp, 1, BUFQ_OPT_NONE); in cf_osslq_h3conn_add_stream()
576 struct bufq recvbuf; /* h3 response body */ member
598 Curl_bufq_free(&stream->recvbuf); in h3_stream_ctx_free()
632 Curl_bufq_initp(&stream->recvbuf, &ctx->stream_bufcp, in h3_data_setup()
779 nwritten = Curl_bufq_write(&stream->recvbuf, mem, memlen, &result); in write_resp_raw()
1324 if(Curl_bufq_is_empty(&s->recvbuf) && !s->recvd_eos) { in cf_osslq_stream_recv()
1325 while(!eagain && !s->recvd_eos && !Curl_bufq_is_full(&s->recvbuf)) { in cf_osslq_stream_recv()
1326 nread = Curl_bufq_sipn(&s->recvbuf, 0, h3_quic_recv, &x, &result); in cf_osslq_stream_recv()
1337 if(!Curl_bufq_is_empty(&s->recvbuf)) { in cf_osslq_stream_recv()
1341 while(Curl_bufq_peek(&s->recvbuf, &buf, &blen)) { in cf_osslq_stream_recv()
1355 Curl_bufq_skip(&s->recvbuf, blen); in cf_osslq_stream_recv()
1361 if(Curl_bufq_is_empty(&s->recvbuf) && !s->closed) { 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()
2072 if(nread < 0 && !Curl_bufq_is_empty(&stream->recvbuf)) { in cf_osslq_recv()
2073 nread = Curl_bufq_read(&stream->recvbuf, in cf_osslq_recv()
2122 return stream && !Curl_bufq_is_empty(&stream->recvbuf); in cf_osslq_data_pending()
