| /curl/src/ |
| H A D | tool_cb_wrt.c | 234 --rlen; in tool_write_cb()
241 --rlen; in tool_write_cb()
245 --rlen; in tool_write_cb()
253 --rlen; in tool_write_cb()
257 --rlen; in tool_write_cb()
289 if(!outs->utf8seq[0] && rlen && (rbuf[rlen - 1] & 0x80)) { in tool_write_cb()
291 if(0xC0 <= rbuf[rlen - 1] && rbuf[rlen - 1] < 0xF8) { in tool_write_cb()
295 else if(rlen >= 2 && IS_TRAILING_BYTE(rbuf[rlen - 1])) { in tool_write_cb()
297 if(0xE0 <= rbuf[rlen - 2] && rbuf[rlen - 2] < 0xF8) { in tool_write_cb()
304 if(0xF0 <= rbuf[rlen - 3] && rbuf[rlen - 3] < 0xF8) { in tool_write_cb()
[all …]
|
| /curl/docs/examples/ |
| H A D | websocket.c | 50 size_t rlen; in recv_pong() local
53 CURLcode result = curl_ws_recv(curl, buffer, sizeof(buffer), &rlen, &meta); in recv_pong()
58 if(rlen == strlen(expected_payload)) { in recv_pong()
59 if(!memcmp(expected_payload, buffer, rlen)) { in recv_pong()
68 fprintf(stderr, "recv_pong: got %u bytes rflags %x\n", (int)rlen, in recv_pong()
73 (unsigned int)result, (unsigned int)rlen); in recv_pong()
79 size_t rlen; in recv_any() local
83 return curl_ws_recv(curl, buffer, sizeof(buffer), &rlen, &meta); in recv_any()
|
| /curl/tests/libtest/ |
| H A D | lib2304.c | 43 size_t rlen; in recv_pong() local
46 CURLcode result = curl_ws_recv(curl, buffer, sizeof(buffer), &rlen, &meta); in recv_pong()
51 if(rlen == strlen(expected_payload)) { in recv_pong()
52 if(!memcmp(expected_payload, buffer, rlen)) { in recv_pong()
61 fprintf(stderr, "recv_pong: got %d bytes rflags %x\n", (int)rlen, in recv_pong()
66 (int)rlen); in recv_pong()
72 size_t rlen; in recv_any() local
75 CURLcode result = curl_ws_recv(curl, buffer, sizeof(buffer), &rlen, &meta); in recv_any()
79 fprintf(stderr, "recv_any: got %u bytes rflags %x\n", (int)rlen, in recv_any()
|
| H A D | lib2301.c | 43 size_t rlen;
47 curl_ws_recv(curl, buffer, sizeof(buffer), &rlen, &rflags);
51 if(rlen == strlen(expected_payload)) {
52 if(!memcmp(expected_payload, buffer, rlen)) {
61 fprintf(stderr, "recv_pong: got %d bytes rflags %x\n", (int)rlen, rflags);
64 (int)rlen);
|
| /curl/lib/ |
| H A D | curl_get_line.c | 48 size_t rlen = strlen(b); in Curl_get_line() local
50 if(!rlen) in Curl_get_line()
53 result = Curl_dyn_addn(buf, b, rlen); in Curl_get_line()
58 else if(b[rlen-1] == '\n') in Curl_get_line()
|
| H A D | mqtt.c | 362 size_t rlen = Curl_dyn_len(&mq->recvbuf); in mqtt_recv_atleast() local
365 if(rlen < nbytes) { in mqtt_recv_atleast()
369 DEBUGASSERT(nbytes - rlen < sizeof(readbuf)); in mqtt_recv_atleast()
370 result = Curl_xfer_recv(data, (char *)readbuf, nbytes - rlen, &nread); in mqtt_recv_atleast()
376 rlen = Curl_dyn_len(&mq->recvbuf); in mqtt_recv_atleast()
378 return (rlen >= nbytes) ? CURLE_OK : CURLE_AGAIN; in mqtt_recv_atleast()
384 size_t rlen = Curl_dyn_len(&mq->recvbuf); in mqtt_recv_consume() local
385 if(rlen <= nbytes) in mqtt_recv_consume()
388 Curl_dyn_tail(&mq->recvbuf, rlen - nbytes); in mqtt_recv_consume()
|
| H A D | c-hyper.c | 265 const uint8_t *reason, size_t rlen) in status_line() argument
297 (int)rlen, reason); in status_line()
|
| /curl/tests/http/clients/ |
| H A D | ws-pingpong.c | 61 size_t rlen; in recv_pong() local
64 CURLcode result = curl_ws_recv(curl, buffer, sizeof(buffer), &rlen, &meta); in recv_pong()
67 (int)result, (long)rlen); in recv_pong()
73 (int)rlen, meta->flags); in recv_pong()
78 if(rlen == strlen(expected_payload) && in recv_pong()
79 !memcmp(expected_payload, buffer, rlen)) { in recv_pong()
|
| /curl/docs/libcurl/ |
| H A D | curl_ws_recv.md | 56 size_t rlen;
61 CURLcode res = curl_ws_recv(curl, buffer, sizeof(buffer), &rlen, &meta);
|
| /curl/lib/vauth/ |
| H A D | digest.c | 274 char *realm, size_t rlen, in auth_decode_digest_md5_message() argument
289 if(!auth_digest_get_key_value(chlg, "realm=\"", realm, rlen, '\"')) { in auth_decode_digest_md5_message()
|
