Home
last modified time | relevance | path

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

12

/curl/tests/unit/
H A 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");
/curl/docs/examples/
H A Dsendrecv.c124 if(res == CURLE_AGAIN && !wait_on_socket(sockfd, 0, 60000L)) { in main()
128 } while(res == CURLE_AGAIN); in main()
149 if(res == CURLE_AGAIN && !wait_on_socket(sockfd, 1, 60000L)) { in main()
153 } while(res == CURLE_AGAIN); in main()
/curl/lib/
H A Dbufq.c104 *err = CURLE_AGAIN; in chunk_slurpn()
413 *err = CURLE_AGAIN; in Curl_bufq_write()
448 *err = CURLE_AGAIN; in Curl_bufq_read()
534 *err = CURLE_AGAIN; in Curl_bufq_pass()
558 if(*err != CURLE_AGAIN) { in Curl_bufq_write_pass()
570 if(*err != CURLE_AGAIN) { in Curl_bufq_write_pass()
589 *err = CURLE_AGAIN; in Curl_bufq_write_pass()
603 *err = CURLE_AGAIN; in Curl_bufq_sipn()
611 *err = CURLE_AGAIN; in Curl_bufq_sipn()
641 *err = CURLE_AGAIN; in bufq_slurpn()
[all …]
H A Dws.c253 return CURLE_AGAIN; in ws_dec_read_head()
284 return remain? CURLE_AGAIN : CURLE_OK; in ws_dec_pass_payload()
296 return CURLE_AGAIN; in ws_dec_pass()
306 if(result != CURLE_AGAIN) { in ws_dec_pass()
456 if(result == CURLE_AGAIN) { in ws_cw_write()
645 *err = CURLE_AGAIN; in ws_enc_write_payload()
658 if((*err != CURLE_AGAIN) || !i) in ws_enc_write_payload()
979 if(result == CURLE_AGAIN) { in curl_ws_recv()
1024 result = CURLE_AGAIN; in ws_flush()
1028 if(result == CURLE_AGAIN) { in ws_flush()
[all …]
H A Dcf-h2-proxy.c422 if(result == CURLE_AGAIN) { in proxy_h2_nw_out_flush()
498 if(result != CURLE_AGAIN) { in proxy_h2_progress_ingress()
555 if(result == CURLE_AGAIN) { in on_session_send()
833 if(result != CURLE_AGAIN) in tunnel_send_callback()
863 if(result != CURLE_AGAIN) in tunnel_recv_callback()
1247 *err = CURLE_AGAIN; in tunnel_recv()
1268 *err = CURLE_AGAIN; in tunnel_recv()
1308 if(result == CURLE_AGAIN) { in cf_h2_proxy_recv()
1376 if(*err != CURLE_AGAIN) in cf_h2_proxy_send()
1402 if(result == CURLE_AGAIN) { in cf_h2_proxy_send()
[all …]
H A 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()
H A Dpingpong.c203 if(result == CURLE_AGAIN) { in Curl_pp_vsendf()
307 if(result == CURLE_AGAIN) in Curl_pp_readresp()
407 if(result == CURLE_AGAIN) { in Curl_pp_flushsend()
H A Drequest.c288 return CURLE_AGAIN; in req_flush()
390 if(nread < 0 && result != CURLE_AGAIN) in Curl_req_send_more()
395 if(result == CURLE_AGAIN) in Curl_req_send_more()
H A Dhttp2.c633 else if(result != CURLE_AGAIN) { in http2_connisalive()
686 if(result == CURLE_AGAIN) { in nw_out_flush()
718 if(result == CURLE_AGAIN) { in send_callback()
1603 if(result != CURLE_AGAIN) in req_body_read_callback()
1869 *err = CURLE_AGAIN; in stream_recv()
1887 if(nread < 0 && *err != CURLE_AGAIN) in stream_recv()
1927 if(result != CURLE_AGAIN) { in h2_progress_ingress()
2017 if(result == CURLE_AGAIN) { in cf_h2_recv()
2276 else if(result == CURLE_AGAIN) { in cf_h2_send()
2313 *err = CURLE_AGAIN; in cf_h2_send()
[all …]
H A Dsmb.c821 if(result && result != CURLE_AGAIN) in smb_send_and_recv()
840 return CURLE_AGAIN; in smb_send_and_recv()
859 if(result && result != CURLE_AGAIN) in smb_connection_state()
877 if(result && result != CURLE_AGAIN) { in smb_connection_state()
974 if(result && result != CURLE_AGAIN) { in smb_request_state()
H A Dcf-haproxy.c136 if(result == CURLE_AGAIN) { in cf_haproxy_connect()
H A Dmqtt.c378 return (rlen >= nbytes)? CURLE_OK : CURLE_AGAIN; in mqtt_recv_atleast()
683 if(CURLE_AGAIN == result) { in mqtt_read_publish()
837 if(result == CURLE_AGAIN) in mqtt_doing()
/curl/docs/libcurl/
H A Dcurl_easy_recv.md45 The call returns **CURLE_AGAIN** if there is no data to read - the socket is
46 used in non-blocking mode internally. When **CURLE_AGAIN** is returned, use
51 Wait on the socket only if curl_easy_recv(3) returns **CURLE_AGAIN**.
57 curl_easy_recv(3) may return **CURLE_AGAIN** if the only data that was
99 The function may return **CURLE_AGAIN**. In this case, use your operating
H A Dcurl_easy_send.md45 The call returns **CURLE_AGAIN** if it is not possible to send data right now
46 - the socket is used in non-blocking mode internally. When **CURLE_AGAIN**
52 curl_easy_send(3) may return **CURLE_AGAIN** if the only data that was sent
93 This function may return **CURLE_AGAIN**. In this case, use your operating
H A Dcurl_ws_recv.md73 Instead of blocking, the function returns **CURLE_AGAIN**. The correct
/curl/lib/vtls/
H A Drustls.c97 if(CURLE_AGAIN == result) in read_cb()
120 if(CURLE_AGAIN == result) in write_cb()
147 *err = CURLE_AGAIN; in tls_recv_more()
206 if(*err != CURLE_AGAIN) { in cr_recv()
259 *err = CURLE_AGAIN; in cr_recv()
287 return CURLE_AGAIN; in cr_flush_out()
375 if(CURLE_AGAIN == *err) { in cr_send()
616 if(tmperr == CURLE_AGAIN) { in cr_connect_common()
675 if(tmperr == CURLE_AGAIN) { in cr_connect_common()
687 if(tmperr == CURLE_AGAIN) { in cr_connect_common()
H A Dwolfssl.c299 if(nwritten < 0 && CURLE_AGAIN == result) in wolfssl_bio_cf_out_write()
323 if(nread < 0 && CURLE_AGAIN == result) in wolfssl_bio_cf_in_read()
1157 else if(backend->io_result == CURLE_AGAIN) { in wolfssl_connect_step2()
1324 *curlcode = CURLE_AGAIN; in wolfssl_send()
1327 if(backend->io_result == CURLE_AGAIN) { in wolfssl_send()
1329 *curlcode = CURLE_AGAIN; in wolfssl_send()
1402 *curlcode = CURLE_AGAIN; in wolfssl_recv()
1405 if(backend->io_result == CURLE_AGAIN) { in wolfssl_recv()
1407 *curlcode = CURLE_AGAIN; in wolfssl_recv()
H A Dmbedtls.c204 if(nwritten < 0 && CURLE_AGAIN == result) { in mbedtls_bio_cf_write()
227 if(nread < 0 && CURLE_AGAIN == result) { in mbedtls_bio_cf_read()
1189 )? CURLE_AGAIN : CURLE_SEND_ERROR;
1260 ) ? CURLE_AGAIN : CURLE_RECV_ERROR;
1261 if(*curlcode != CURLE_AGAIN) {
/curl/tests/libtest/
H A Dlib556.c86 } while((res == CURLE_OK && iolen) || (res == CURLE_AGAIN)); in test()
H A Dlib2305.c55 if(result == CURLE_AGAIN) in websocket()
/curl/tests/http/clients/
H A Dws-pingpong.c104 if(res == CURLE_AGAIN) { in pingpong()
H A Dws-data.c113 if(result == CURLE_AGAIN) { in recv_binary()
/curl/lib/vquic/
H A Dcurl_quiche.c408 *err = CURLE_AGAIN; in stream_resp_read()
437 if(nwritten < 0 && result != CURLE_AGAIN) { in cf_recv_body()
686 *err = CURLE_AGAIN; in read_pkt_to_send()
731 if(result == CURLE_AGAIN) { in cf_flush_egress()
748 if(result != CURLE_AGAIN) in cf_flush_egress()
753 if(result == CURLE_AGAIN) { in cf_flush_egress()
766 if(result == CURLE_AGAIN) { in cf_flush_egress()
874 *err = CURLE_AGAIN; in cf_quiche_recv()
982 *err = CURLE_AGAIN; in h3_open_stream()
1075 *err = CURLE_AGAIN; in cf_quiche_send()
[all …]
H A 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()
/curl/lib/vssh/
H A Dwolfssh.c270 *err = CURLE_AGAIN; in wsftp_send()
275 *err = CURLE_AGAIN; in wsftp_send()
313 *err = CURLE_AGAIN; in wsftp_recv()
318 *err = CURLE_AGAIN; in wsftp_recv()

Completed in 93 milliseconds

12