Lines Matching refs:nwritten
268 ssize_t nwritten; in ws_dec_pass_payload() local
276 nwritten = write_payload(inbuf, inlen, dec->frame_age, dec->frame_flags, in ws_dec_pass_payload()
279 if(nwritten < 0) in ws_dec_pass_payload()
281 Curl_bufq_skip(inraw, (size_t)nwritten); in ws_dec_pass_payload()
282 dec->payload_offset += (curl_off_t)nwritten; in ws_dec_pass_payload()
285 FMT_OFF_T " remain", nwritten, remain); in ws_dec_pass_payload()
321 ssize_t nwritten; in ws_dec_pass() local
324 nwritten = write_payload(&tmp, 0, dec->frame_age, dec->frame_flags, in ws_dec_pass()
326 if(nwritten < 0) in ws_dec_pass()
443 ssize_t nwritten; in ws_cw_write() local
444 nwritten = Curl_bufq_write(&ctx->buf, (const unsigned char *)buf, in ws_cw_write()
446 if(nwritten < 0) { in ws_cw_write()
833 ssize_t nwritten; in Curl_ws_accept() local
837 nwritten = Curl_bufq_write(&ws->recvbuf, (const unsigned char *)mem, in Curl_ws_accept()
839 if(nwritten < 0) in Curl_ws_accept()
874 size_t nwritten; in ws_client_collect() local
893 nwritten = bytes; in ws_client_collect()
898 nwritten = CURLMIN(buflen, ctx->buflen - ctx->bufidx); in ws_client_collect()
899 if(!nwritten) { in ws_client_collect()
908 memcpy(ctx->buffer + ctx->bufidx, buf, nwritten); in ws_client_collect()
909 ctx->bufidx += nwritten; in ws_client_collect()
911 return nwritten; in ws_client_collect()
1056 size_t nwritten; in ws_send_raw_blocking() local
1061 result = Curl_xfer_send(data, buffer, buflen, FALSE, &nwritten); in ws_send_raw_blocking()
1064 DEBUGASSERT(nwritten <= buflen); in ws_send_raw_blocking()
1065 buffer += nwritten; in ws_send_raw_blocking()
1066 buflen -= nwritten; in ws_send_raw_blocking()
