Lines Matching refs:nread
241 ssize_t nread; in proxy_nw_in_reader() local
245 nread = Curl_conn_cf_recv(cf->next, data, (char *)buf, buflen, err); in proxy_nw_in_reader()
247 buflen, nread, *err); in proxy_nw_in_reader()
250 nread = 0; in proxy_nw_in_reader()
252 return nread; in proxy_nw_in_reader()
482 ssize_t nread; in proxy_h2_progress_ingress() local
499 nread = Curl_bufq_slurp(&ctx->inbufq, proxy_nw_in_reader, cf, &result); in proxy_h2_progress_ingress()
501 Curl_bufq_len(&ctx->inbufq), nread, result); in proxy_h2_progress_ingress()
502 if(nread < 0) { in proxy_h2_progress_ingress()
509 else if(nread == 0) { in proxy_h2_progress_ingress()
820 ssize_t nread; in tunnel_send_callback() local
834 nread = Curl_bufq_read(&ts->sendbuf, buf, length, &result); in tunnel_send_callback()
835 if(nread < 0) { in tunnel_send_callback()
844 ts->stream_id, nread); in tunnel_send_callback()
845 return nread; in tunnel_send_callback()
1316 ssize_t nread = -1; in tunnel_recv() local
1320 nread = Curl_bufq_read(&ctx->tunnel.recvbuf, in tunnel_recv()
1322 if(nread < 0) in tunnel_recv()
1324 DEBUGASSERT(nread > 0); in tunnel_recv()
1327 if(nread < 0) { in tunnel_recv()
1329 nread = h2_handle_tunnel_close(cf, data, err); in tunnel_recv()
1336 nread = -1; in tunnel_recv()
1339 else if(nread == 0) { in tunnel_recv()
1341 nread = -1; in tunnel_recv()
1346 ctx->tunnel.stream_id, len, nread, *err); in tunnel_recv()
1347 return nread; in tunnel_recv()
1355 ssize_t nread = -1; in cf_h2_proxy_recv() local
1371 nread = tunnel_recv(cf, data, buf, len, err); in cf_h2_proxy_recv()
1373 if(nread > 0) { in cf_h2_proxy_recv()
1375 ctx->tunnel.stream_id, nread); in cf_h2_proxy_recv()
1376 nghttp2_session_consume(ctx->h2, ctx->tunnel.stream_id, (size_t)nread); in cf_h2_proxy_recv()
1382 nread = -1; in cf_h2_proxy_recv()
1387 (nread >= 0 || *err == CURLE_AGAIN)) { in cf_h2_proxy_recv()
1393 ctx->tunnel.stream_id, len, nread, *err); in cf_h2_proxy_recv()
1395 return nread; in cf_h2_proxy_recv()
1534 ssize_t nread = -1; in proxy_h2_connisalive() local
1537 nread = Curl_bufq_slurp(&ctx->inbufq, proxy_nw_in_reader, cf, &result); in proxy_h2_connisalive()
1538 if(nread != -1) { in proxy_h2_connisalive()
