/curl/tests/unit/ |
H A D | unit2601.c | 130 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 D | sendrecv.c | 124 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 D | bufq.c | 104 *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 D | ws.c | 253 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 D | cf-h2-proxy.c | 422 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 D | http1.c | 93 *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 D | pingpong.c | 203 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 D | request.c | 288 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 D | http2.c | 633 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 D | smb.c | 821 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 D | cf-haproxy.c | 136 if(result == CURLE_AGAIN) { in cf_haproxy_connect()
|
H A D | mqtt.c | 378 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 D | curl_easy_recv.md | 45 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 D | curl_easy_send.md | 45 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 D | curl_ws_recv.md | 73 Instead of blocking, the function returns **CURLE_AGAIN**. The correct
|
/curl/lib/vtls/ |
H A D | rustls.c | 97 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 D | wolfssl.c | 299 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 D | mbedtls.c | 204 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 D | lib556.c | 86 } while((res == CURLE_OK && iolen) || (res == CURLE_AGAIN)); in test()
|
H A D | lib2305.c | 55 if(result == CURLE_AGAIN) in websocket()
|
/curl/tests/http/clients/ |
H A D | ws-pingpong.c | 104 if(res == CURLE_AGAIN) { in pingpong()
|
H A D | ws-data.c | 113 if(result == CURLE_AGAIN) { in recv_binary()
|
/curl/lib/vquic/ |
H A D | curl_quiche.c | 408 *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 D | vquic.c | 173 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 D | wolfssh.c | 270 *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()
|