Home
last modified time | relevance | path

Searched refs:CURLE_AGAIN (Results 1 – 25 of 50) sorted by relevance

12

/third_party/curl/tests/unit/
Dunit2601.c130 else if(result != CURLE_AGAIN) { in check_bufq()
131 fail_unless(result == CURLE_AGAIN, "write-loop: unexpected result"); in check_bufq()
149 else if(result != CURLE_AGAIN) { in check_bufq()
150 fail_unless(result == CURLE_AGAIN, "read-loop: unexpected result"); in check_bufq()
167 if(n < 0 && result != CURLE_AGAIN) { in check_bufq()
168 fail_unless(result == CURLE_AGAIN, "rw-loop: unexpected write result"); in check_bufq()
172 if(n < 0 && result != CURLE_AGAIN) { in check_bufq()
173 fail_unless(result == CURLE_AGAIN, "rw-loop: unexpected read result"); in check_bufq()
226 fail_unless(n < 0 && result == CURLE_AGAIN, "read empty fail");
/third_party/curl/lib/
Dbufq.c104 *err = CURLE_AGAIN; in chunk_slurpn()
413 *err = CURLE_AGAIN; in Curl_bufq_write()
437 *err = CURLE_AGAIN; in Curl_bufq_read()
504 if(!nwritten || *err != CURLE_AGAIN) { in Curl_bufq_pass()
513 *err = CURLE_AGAIN; in Curl_bufq_pass()
537 if(*err != CURLE_AGAIN) { in Curl_bufq_write_pass()
549 if(*err != CURLE_AGAIN) { in Curl_bufq_write_pass()
568 *err = CURLE_AGAIN; in Curl_bufq_write_pass()
582 *err = CURLE_AGAIN; in Curl_bufq_sipn()
590 *err = CURLE_AGAIN; in Curl_bufq_sipn()
[all …]
Dcf-h2-proxy.c421 if(result == CURLE_AGAIN) { in proxy_h2_nw_out_flush()
429 return Curl_bufq_is_empty(&ctx->outbufq)? CURLE_OK: CURLE_AGAIN; in proxy_h2_nw_out_flush()
497 if(result != CURLE_AGAIN) { in proxy_h2_progress_ingress()
554 if(result == CURLE_AGAIN) { in on_session_send()
832 if(result != CURLE_AGAIN) in tunnel_send_callback()
862 if(result != CURLE_AGAIN) in tunnel_recv_callback()
1043 if(result && result != CURLE_AGAIN) { in H2_CONNECT()
1238 *err = CURLE_AGAIN; in tunnel_recv()
1259 *err = CURLE_AGAIN; in tunnel_recv()
1299 if(result == CURLE_AGAIN) { in cf_h2_proxy_recv()
[all …]
Dws.c253 return CURLE_AGAIN; in ws_dec_read_head()
285 return remain? CURLE_AGAIN : CURLE_OK; in ws_dec_pass_payload()
297 return CURLE_AGAIN; in ws_dec_pass()
307 if(result != CURLE_AGAIN) { in ws_dec_pass()
457 if(result == CURLE_AGAIN) in ws_cw_write()
644 *err = CURLE_AGAIN; in ws_enc_write_payload()
657 if((*err != CURLE_AGAIN) || !i) in ws_enc_write_payload()
885 *err = CURLE_AGAIN; /* no more space */ in ws_client_collect()
967 if(result == CURLE_AGAIN) { in curl_ws_recv()
1013 if(result == CURLE_AGAIN) { in ws_flush()
[all …]
Dhttp1.c93 *err = CURLE_AGAIN; in detect_line()
128 else if(*err == CURLE_AGAIN) { in next_line()
272 if(*err != CURLE_AGAIN) { in Curl_h1_req_parse_read()
Dhttp2.c617 else if(result != CURLE_AGAIN) { in http2_connisalive()
670 if(result == CURLE_AGAIN) { in nw_out_flush()
677 return Curl_bufq_is_empty(&ctx->outbufq)? CURLE_OK: CURLE_AGAIN; in nw_out_flush()
702 if(result == CURLE_AGAIN) { in send_callback()
1297 if(result != CURLE_AGAIN) in on_data_chunk_recv()
1588 if(result != CURLE_AGAIN) in req_body_read_callback()
1843 *err = CURLE_AGAIN; in stream_recv()
1866 *err = CURLE_AGAIN; in stream_recv()
1871 if(nread < 0 && *err != CURLE_AGAIN) in stream_recv()
1909 if(result != CURLE_AGAIN) { in h2_progress_ingress()
[all …]
Dsmb.c819 if(result && result != CURLE_AGAIN) in smb_send_and_recv()
838 return CURLE_AGAIN; in smb_send_and_recv()
857 if(result && result != CURLE_AGAIN) in smb_connection_state()
875 if(result && result != CURLE_AGAIN) { in smb_connection_state()
972 if(result && result != CURLE_AGAIN) { in smb_request_state()
Dmqtt.c378 return (rlen >= nbytes)? CURLE_OK : CURLE_AGAIN; in mqtt_recv_atleast()
684 if(CURLE_AGAIN == result) { in mqtt_read_publish()
839 if(result == CURLE_AGAIN) in mqtt_doing()
Dopenldap.c985 CURLcode result = CURLE_AGAIN; in oldap_recv()
1126 result = CURLE_AGAIN; in oldap_recv()
1181 if(ret < 0 && err == CURLE_AGAIN) { in ldapsb_tls_read()
1200 if(ret < 0 && err == CURLE_AGAIN) { in ldapsb_tls_write()
/third_party/curl/docs/examples/
Dsendrecv.c125 if(res == CURLE_AGAIN && !wait_on_socket(sockfd, 0, 60000L)) { in main()
129 } while(res == CURLE_AGAIN); in main()
150 if(res == CURLE_AGAIN && !wait_on_socket(sockfd, 1, 60000L)) { in main()
154 } while(res == CURLE_AGAIN); in main()
/third_party/curl/docs/libcurl/
Dcurl_easy_recv.md43 The call returns **CURLE_AGAIN** if there is no data to read - the socket is
44 used in non-blocking mode internally. When **CURLE_AGAIN** is returned, use
49 Wait on the socket only if curl_easy_recv(3) returns **CURLE_AGAIN**.
55 curl_easy_recv(3) may return **CURLE_AGAIN** if the only data that was
97 The function may return **CURLE_AGAIN**. In this case, use your operating
Dcurl_easy_send.md43 The call returns **CURLE_AGAIN** if it is not possible to send data right now
44 - the socket is used in non-blocking mode internally. When **CURLE_AGAIN**
50 curl_easy_send(3) may return **CURLE_AGAIN** if the only data that was sent
91 This function may return **CURLE_AGAIN**. In this case, use your operating
Dcurl_ws_recv.md71 Instead of blocking, the function returns **CURLE_AGAIN**. The correct
/third_party/curl/lib/vtls/
Drustls.c94 if(CURLE_AGAIN == result) in read_cb()
113 if(CURLE_AGAIN == result) in write_cb()
142 *err = CURLE_AGAIN; in tls_recv_more()
201 if(*err != CURLE_AGAIN) { in cr_recv()
254 *err = CURLE_AGAIN; in cr_recv()
321 *err = CURLE_AGAIN; in cr_send()
582 if(tmperr == CURLE_AGAIN) { in cr_connect_common()
595 if(tmperr == CURLE_AGAIN) { in cr_connect_common()
Dwolfssl.c298 if(nwritten < 0 && CURLE_AGAIN == result) in wolfssl_bio_cf_out_write()
322 if(nread < 0 && CURLE_AGAIN == result) in wolfssl_bio_cf_in_read()
855 else if(backend->io_result == CURLE_AGAIN) { in wolfssl_connect_step2()
1027 *curlcode = CURLE_AGAIN; in wolfssl_send()
1030 if(backend->io_result == CURLE_AGAIN) { in wolfssl_send()
1032 *curlcode = CURLE_AGAIN; in wolfssl_send()
1104 *curlcode = CURLE_AGAIN; in wolfssl_recv()
1107 if(backend->io_result == CURLE_AGAIN) { in wolfssl_recv()
1109 *curlcode = CURLE_AGAIN; in wolfssl_recv()
Dgtls.c97 (CURLE_AGAIN == result)? EAGAIN : EINVAL); in gtls_push()
117 (CURLE_AGAIN == result)? EAGAIN : EINVAL); in gtls_pull()
1423 ? CURLE_AGAIN in gtls_send()
1562 *curlcode = CURLE_AGAIN; in gtls_recv()
1575 *curlcode = CURLE_AGAIN; /* then return as if this was a wouldblock */ in gtls_recv()
Dmbedtls.c185 if(nwritten < 0 && CURLE_AGAIN == result) { in mbedtls_bio_cf_write()
208 if(nread < 0 && CURLE_AGAIN == result) { in mbedtls_bio_cf_read()
948 CURLE_AGAIN : CURLE_SEND_ERROR;
1009 CURLE_AGAIN : CURLE_RECV_ERROR;
Dschannel.c1394 if(result == CURLE_AGAIN) { in schannel_connect_step2()
2060 if(result == CURLE_AGAIN) in schannel_send()
2177 if(*err == CURLE_AGAIN) in schannel_recv()
2294 if(*err && *err != CURLE_AGAIN) { in schannel_recv()
2330 *err = CURLE_AGAIN; in schannel_recv()
2382 if(*err && *err != CURLE_AGAIN) in schannel_recv()
2400 *err = CURLE_AGAIN; in schannel_recv()
/third_party/curl/lib/vquic/
Dcurl_quiche.c357 *err = CURLE_AGAIN; in stream_resp_read()
385 if(nwritten < 0 && result != CURLE_AGAIN) { in cf_recv_body()
631 *err = CURLE_AGAIN; in read_pkt_to_send()
670 if(result == CURLE_AGAIN) { in cf_flush_egress()
687 if(result != CURLE_AGAIN) in cf_flush_egress()
692 if(result == CURLE_AGAIN) { in cf_flush_egress()
705 if(result == CURLE_AGAIN) { in cf_flush_egress()
812 *err = CURLE_AGAIN; in cf_quiche_recv()
920 *err = CURLE_AGAIN; in h3_open_stream()
1012 *err = CURLE_AGAIN; in cf_quiche_send()
[all …]
Dvquic.c173 return CURLE_AGAIN; in do_sendmsg()
207 return CURLE_AGAIN; in do_sendmsg()
262 return CURLE_AGAIN; in vquic_send_packets()
297 if(result == CURLE_AGAIN) { in vquic_flush()
Dcurl_ngtcp2.c1176 *err = CURLE_AGAIN; in cf_ngtcp2_recv()
1518 *err = CURLE_AGAIN; in cf_ngtcp2_send()
1681 *err = CURLE_AGAIN; in read_pkt_to_send()
1764 if(curlcode == CURLE_AGAIN) { in cf_progress_egress()
1794 if(curlcode != CURLE_AGAIN) in cf_progress_egress()
1799 if(curlcode == CURLE_AGAIN) { in cf_progress_egress()
1822 if(curlcode == CURLE_AGAIN) { in cf_progress_egress()
1838 if(curlcode == CURLE_AGAIN) { in cf_progress_egress()
/third_party/curl/tests/libtest/
Dlib556.c86 } while((res == CURLE_OK && iolen) || (res == CURLE_AGAIN)); in test()
Dlib2305.c55 if(result == CURLE_AGAIN) in websocket()
/third_party/curl/tests/http/clients/
Dws-pingpong.c104 if(res == CURLE_AGAIN) { in pingpong()
/third_party/curl/lib/vssh/
Dwolfssh.c268 *err = CURLE_AGAIN; in wsftp_send()
273 *err = CURLE_AGAIN; in wsftp_send()
311 *err = CURLE_AGAIN; in wsftp_recv()
316 *err = CURLE_AGAIN; in wsftp_recv()

12