139 typedef ssize_t ws_write_payload(const unsigned char *buf, size_t buflen,
496                                     const unsigned char *buf, size_t buflen,  in ws_enc_write_payload()  argument
508   len = buflen;  in ws_enc_write_payload()
674 static ssize_t ws_client_write(const unsigned char *buf, size_t buflen,  in ws_client_write()  argument
684   curl_off_t remain = (payload_len - (payload_offset + buflen));  in ws_client_write()
698     *err = curl_ws_send(data, buf, buflen, &bytes, 0, CURLWS_PONG);  in ws_client_write()
702   else if(buflen || !remain) {  in ws_client_write()
706                 payload_len, buflen);  in ws_client_write()
709                                   buflen, data->set.out);  in ws_client_write()
711     if(wrote != buflen) {  in ws_client_write()
717   return (ssize_t)buflen;  in ws_client_write()
773   size_t buflen;  member
782 static ssize_t ws_client_collect(const unsigned char *buf, size_t buflen,  in ws_client_collect()  argument
791   curl_off_t remain = (payload_len - (payload_offset + buflen));  in ws_client_collect()
806     *err = curl_ws_send(ctx->data, buf, buflen, &bytes, 0, CURLWS_PONG);  in ws_client_collect()
813     DEBUGASSERT(ctx->buflen >= ctx->bufidx);  in ws_client_collect()
814     nwritten = CURLMIN(buflen, ctx->buflen - ctx->bufidx);  in ws_client_collect()
816       if(!buflen) {  /* 0 length write, we accept that */  in ws_client_collect()
831                           unsigned char *buf, size_t buflen,  in nw_in_recv()  argument
837   *err = curl_easy_recv(data, buf, buflen, &nread);  in nw_in_recv()
844                                   size_t buflen, size_t *nread,  in curl_ws_recv()  argument
882   ctx.buflen = buflen;  in curl_ws_recv()
974                                   size_t buflen, size_t *sent,  in curl_ws_send()  argument
1002     if(!buflen)  in curl_ws_send()
1008       result = Curl_write(data, data->conn->writesockfd, buffer, buflen,  in curl_ws_send()
1012       result = Curl_senddata(data, buffer, buflen, &nwritten);  in curl_ws_send()
1015           buflen, nwritten);  in curl_ws_send()
1029                buflen, Curl_bufq_len(&ws->sendbuf), space));  in curl_ws_send()
1042       if((curl_off_t)buflen > ws->enc.payload_remain) {  in curl_ws_send()
1045               buflen, ws->enc.payload_remain);  in curl_ws_send()
1050     n = ws_enc_write_head(data, &ws->enc, flags, (curl_off_t)buflen,  in curl_ws_send()
1057                            buffer, buflen, &ws->sendbuf, &result);  in curl_ws_send()
1101 CURL_EXTERN CURLcode curl_ws_recv(CURL *curl, void *buffer, size_t buflen,  in curl_ws_recv()  argument
1107   (void)buflen;  in curl_ws_recv()
1114                                   size_t buflen, size_t *sent,  in curl_ws_send()  argument
1120   (void)buflen;  in curl_ws_send()