Lines Matching refs:recvbuf
215 struct bufq recvbuf; /* QUIC war data recv buffer */
229 Curl_bufq_initp(&s->recvbuf, bufcp, 1, BUFQ_OPT_NONE);
245 Curl_bufq_free(&s->recvbuf);
368 Curl_bufq_initp(&nstream->recvbuf, &ctx->stream_bufcp, 1, BUFQ_OPT_NONE);
482 struct bufq recvbuf; /* h3 response body */
530 Curl_bufq_initp(&stream->recvbuf, &ctx->stream_bufcp,
557 Curl_bufq_free(&stream->recvbuf);
671 nwritten = Curl_bufq_write(&stream->recvbuf, mem, memlen, &result);
1188 if(Curl_bufq_is_empty(&s->recvbuf) && !s->recvd_eos) {
1189 while(!eagain && !s->recvd_eos && !Curl_bufq_is_full(&s->recvbuf)) {
1190 nread = Curl_bufq_sipn(&s->recvbuf, 0, h3_quic_recv, &x, &result);
1201 if(!Curl_bufq_is_empty(&s->recvbuf)) {
1205 while(Curl_bufq_peek(&s->recvbuf, &buf, &blen)) {
1219 Curl_bufq_skip(&s->recvbuf, blen);
1225 if(Curl_bufq_is_empty(&s->recvbuf) && !s->closed) {
1308 !Curl_bufq_is_full(&stream->recvbuf)) {
1928 if(!Curl_bufq_is_empty(&stream->recvbuf)) {
1929 nread = Curl_bufq_read(&stream->recvbuf,
1932 CURL_TRC_CF(data, cf, "[%" PRId64 "] read recvbuf(len=%zu) "
1945 /* recvbuf had nothing before, maybe after progressing ingress? */
1946 if(nread < 0 && !Curl_bufq_is_empty(&stream->recvbuf)) {
1947 nread = Curl_bufq_read(&stream->recvbuf,
1950 CURL_TRC_CF(data, cf, "[%" PRId64 "] read recvbuf(len=%zu) "
1995 return stream && !Curl_bufq_is_empty(&stream->recvbuf);