Lines Matching refs:nwritten
348 ssize_t nwritten; in write_resp_raw() local
353 nwritten = Curl_bufq_write(&stream->recvbuf, mem, memlen, &result); in write_resp_raw()
354 if(nwritten < 0) in write_resp_raw()
357 if((size_t)nwritten < memlen) { in write_resp_raw()
442 ssize_t nwritten; in cf_recv_body() local
458 nwritten = Curl_bufq_slurp(&stream->recvbuf, in cf_recv_body()
461 if(nwritten < 0 && result != CURLE_AGAIN) { in cf_recv_body()
463 stream->id, nwritten); in cf_recv_body()
706 ssize_t nwritten; in read_pkt_to_send() local
708 nwritten = quiche_conn_send(ctx->qconn, buf, buflen, &x->send_info); in read_pkt_to_send()
709 if(nwritten == QUICHE_ERR_DONE) { in read_pkt_to_send()
714 if(nwritten < 0) { in read_pkt_to_send()
715 failf(x->data, "quiche_conn_send returned %zd", nwritten); in read_pkt_to_send()
720 return nwritten; in read_pkt_to_send()
924 ssize_t nwritten; in cf_quiche_send_body() local
926 nwritten = quiche_h3_send_body(ctx->h3c, ctx->qconn, stream->id, in cf_quiche_send_body()
928 if(nwritten == QUICHE_H3_ERR_DONE || (nwritten == 0 && len > 0)) { in cf_quiche_send_body()
939 else if(nwritten == QUICHE_H3_TRANSPORT_ERR_INVALID_STREAM_STATE) { in cf_quiche_send_body()
945 else if(nwritten == QUICHE_H3_TRANSPORT_ERR_FINAL_SIZE) { in cf_quiche_send_body()
951 else if(nwritten < 0) { in cf_quiche_send_body()
953 "-> quiche err %zd", stream->id, len, nwritten); in cf_quiche_send_body()
958 if(eos && (len == (size_t)nwritten)) in cf_quiche_send_body()
962 stream->id, len, stream->send_closed, nwritten); in cf_quiche_send_body()
964 return nwritten; in cf_quiche_send_body()
983 ssize_t nwritten; in h3_open_stream() local
997 nwritten = Curl_h1_req_parse_read(&stream->h1, buf, len, NULL, 0, err); in h3_open_stream()
998 if(nwritten < 0) in h3_open_stream()
1008 nwritten = -1; in h3_open_stream()
1018 nwritten = -1; in h3_open_stream()
1030 if(eos && ((size_t)nwritten == len)) in h3_open_stream()
1042 nwritten = -1; in h3_open_stream()
1050 nwritten = -1; in h3_open_stream()
1071 if(nwritten > 0 && ((size_t)nwritten < len)) { in h3_open_stream()
1073 size_t hds_len = (size_t)nwritten; in h3_open_stream()
1080 nwritten = -1; in h3_open_stream()
1083 nwritten += bwritten; in h3_open_stream()
1090 return nwritten; in h3_open_stream()
1100 ssize_t nwritten; in cf_quiche_send() local
1106 nwritten = -1; in cf_quiche_send()
1111 nwritten = h3_open_stream(cf, data, buf, len, eos, err); in cf_quiche_send()
1112 if(nwritten < 0) in cf_quiche_send()
1129 nwritten = (ssize_t)len; in cf_quiche_send()
1135 nwritten = -1; in cf_quiche_send()
1139 nwritten = cf_quiche_send_body(cf, data, stream, buf, len, eos, err); in cf_quiche_send()
1146 nwritten = -1; in cf_quiche_send()
1149 stream ? stream->id : (curl_uint64_t)~0, len, nwritten, *err); in cf_quiche_send()
1150 return nwritten; in cf_quiche_send()
