Lines Matching refs:nwritten
260 ssize_t nwritten; in proxy_h2_nw_out_writer() local
264 nwritten = Curl_conn_cf_send(cf->next, data, (const char *)buf, buflen, in proxy_h2_nw_out_writer()
267 buflen, nwritten, *err); in proxy_h2_nw_out_writer()
270 nwritten = 0; in proxy_h2_nw_out_writer()
272 return nwritten; in proxy_h2_nw_out_writer()
417 ssize_t nwritten; in proxy_h2_nw_out_flush() local
424 nwritten = Curl_bufq_pass(&ctx->outbufq, proxy_h2_nw_out_writer, cf, in proxy_h2_nw_out_flush()
426 if(nwritten < 0) { in proxy_h2_nw_out_flush()
550 ssize_t nwritten; in on_session_send() local
557 nwritten = Curl_bufq_write_pass(&ctx->outbufq, buf, blen, in on_session_send()
559 if(nwritten < 0) { in on_session_send()
567 if(!nwritten) in on_session_send()
570 return nwritten; in on_session_send()
854 ssize_t nwritten; in tunnel_recv_callback() local
864 nwritten = Curl_bufq_write(&ctx->tunnel.recvbuf, mem, len, &result); in tunnel_recv_callback()
865 if(nwritten < 0) { in tunnel_recv_callback()
868 nwritten = 0; in tunnel_recv_callback()
870 DEBUGASSERT((size_t)nwritten == len); in tunnel_recv_callback()
1406 ssize_t nwritten; in cf_h2_proxy_send() local
1417 nwritten = -1; in cf_h2_proxy_send()
1422 nwritten = Curl_bufq_write(&ctx->tunnel.sendbuf, buf, len, err); in cf_h2_proxy_send()
1423 if(nwritten < 0 && (*err != CURLE_AGAIN)) in cf_h2_proxy_send()
1432 nwritten = -1; in cf_h2_proxy_send()
1440 nwritten = -1; in cf_h2_proxy_send()
1449 nwritten = -1; in cf_h2_proxy_send()
1458 nwritten = -1; in cf_h2_proxy_send()
1463 nwritten = -1; in cf_h2_proxy_send()
1469 (nwritten >= 0 || *err == CURLE_AGAIN)) { in cf_h2_proxy_send()
1476 ctx->tunnel.stream_id, len, nwritten, *err, in cf_h2_proxy_send()
1483 return nwritten; in cf_h2_proxy_send()
