Lines Matching refs:inbufq
134 struct bufq inbufq; /* network input */ member
164 Curl_bufq_initp(&ctx->inbufq, &ctx->stream_bufcp, H2_NW_RECV_CHUNKS, 0); in cf_h2_ctx_init()
176 Curl_bufq_free(&ctx->inbufq); in cf_h2_ctx_free()
645 while(Curl_bufq_peek(&ctx->inbufq, &buf, &blen)) { in h2_process_pending_input()
655 Curl_bufq_skip(&ctx->inbufq, (size_t)rv); in h2_process_pending_input()
656 if(Curl_bufq_is_empty(&ctx->inbufq)) { in h2_process_pending_input()
661 "in connection buffer", Curl_bufq_len(&ctx->inbufq)); in h2_process_pending_input()
701 nread = Curl_bufq_slurp(&ctx->inbufq, nw_in_reader, cf, &result); in http2_connisalive()
1946 (ctx->conn_closed && Curl_bufq_is_empty(&ctx->inbufq)) || in stream_recv()
1969 if(!Curl_bufq_is_empty(&ctx->inbufq)) { in h2_progress_ingress()
1971 Curl_bufq_len(&ctx->inbufq)); in h2_progress_ingress()
1979 while(!ctx->conn_closed && Curl_bufq_is_empty(&ctx->inbufq)) { in h2_progress_ingress()
1991 nread = Curl_bufq_sipn(&ctx->inbufq, 0, nw_in_reader, cf, &result); in h2_progress_ingress()
2014 Curl_bufq_len(&ctx->inbufq)); in h2_progress_ingress()
2017 if(ctx->conn_closed && Curl_bufq_is_empty(&ctx->inbufq)) { in h2_progress_ingress()
2660 if(ctx && (!Curl_bufq_is_empty(&ctx->inbufq) in cf_h2_data_pending()
2927 copied = Curl_bufq_write(&ctx->inbufq, in Curl_http2_upgrade()
