Home
last modified time | relevance | path

Searched refs:cf (Results 1 – 25 of 64) sorted by relevance

123

/curl/lib/
H A Dcfilters.c196 cf = cf->next; in Curl_conn_shutdown()
234 cf = cf->next; in Curl_conn_shutdown()
250 cf = cf->next; in Curl_cf_recv()
274 cf = cf->next; in Curl_cf_send()
469 cf = cf->next; in Curl_conn_is_ip_connected()
476 for(; cf; cf = cf->next) { in Curl_conn_cf_is_ssl()
494 for(; cf; cf = cf->next) { in Curl_conn_is_multiplex()
514 cf = cf->next; in Curl_conn_data_pending()
542 while(cf && !cf->connected && cf->next && !cf->next->connected) in Curl_conn_cf_adjust_pollset()
543 cf = cf->next; in Curl_conn_cf_adjust_pollset()
[all …]
H A Dcf-https-connect.c65 if(b->cf) { in cf_hc_baller_reset()
68 b->cf = NULL; in cf_hc_baller_reset()
81 return !!b->cf; in cf_hc_baller_has_started()
88 b->cf->cft->query(b->cf, data, CF_QUERY_CONNECT_REPLY_MS, in cf_hc_baller_reply_ms()
96 return b->cf && !b->result && b->cf->cft->has_data_pending(b->cf, data); in cf_hc_baller_data_pending()
139 b->cf = cf->next; in cf_hc_baller_init()
150 cf->next = b->cf; in cf_hc_baller_connect()
152 b->cf = cf->next; /* it might mutate */ in cf_hc_baller_connect()
194 cf->next = winner->cf; in baller_connected()
413 return cf->next->cft->has_data_pending(cf->next, data); in cf_hc_data_pending()
[all …]
H A Dhttp_proxy.c59 DEBUGASSERT(cf); in Curl_http_proxy_get_destination()
60 DEBUGASSERT(cf->conn); in Curl_http_proxy_get_destination()
174 if(cf->connected) { in http_proxy_cf_connect()
181 result = cf->next->cft->do_connect(cf->next, data, blocking, done); in http_proxy_cf_connect()
236 cf->connected = TRUE; in http_proxy_cf_connect()
249 if(!cf->connected) { in Curl_cf_http_proxy_get_host()
255 cf->next->cft->get_host(cf->next, data, phost, pdisplay_host, pport); in Curl_cf_http_proxy_get_host()
275 cf->connected = FALSE; in http_proxy_cf_close()
289 if(cf->next) in http_proxy_cf_close()
290 cf->next->cft->do_close(cf->next, data); in http_proxy_cf_close()
[all …]
H A Dcf-haproxy.c115 if(cf->connected) { in cf_haproxy_connect()
120 result = cf->next->cft->do_connect(cf->next, data, blocking, done); in cf_haproxy_connect()
159 cf->connected = *done; in cf_haproxy_connect()
168 cf_haproxy_ctx_free(cf->ctx); in cf_haproxy_destroy()
175 cf->connected = FALSE; in cf_haproxy_close()
176 cf_haproxy_ctx_reset(cf->ctx); in cf_haproxy_close()
177 if(cf->next) in cf_haproxy_close()
178 cf->next->cft->do_close(cf->next, data); in cf_haproxy_close()
185 if(cf->next->connected && !cf->connected) { in cf_haproxy_adjust_pollset()
234 *pcf = result ? NULL : cf; in cf_haproxy_create()
[all …]
H A Dcf-h2-proxy.c124 (void)cf; in h2_tunnel_go_state()
223 (void)cf; in drain_tunnel()
243 if(cf) { in proxy_nw_in_reader()
262 if(cf) { in proxy_h2_nw_out_writer()
912 (void)cf; in proxy_h2_submit()
990 (void)cf; in inspect_response()
1156 if(cf->next) in cf_h2_proxy_close()
1157 cf->next->cft->do_close(cf->next, data); in cf_h2_proxy_close()
1224 return cf->next ? cf->next->cft->has_data_pending(cf->next, data) : FALSE; in cf_h2_proxy_data_pending()
1526 if(!cf->next || !cf->next->cft->is_alive(cf->next, data, input_pending)) in proxy_h2_connisalive()
[all …]
H A Dhttp2.c282 (void)cf; in cf_h2_get_desired_local_win()
341 (void)cf; in cf_h2_update_local_win()
358 (void)cf; in drain_stream()
378 (void)cf; in http2_data_setup()
690 if(!cf->next || !cf->next->cft->is_alive(cf->next, data, input_pending)) in http2_connisalive()
1480 (void)cf; in on_begin_headers()
1922 if(!cf->connected && !cf->conn->connect_only) in h2_progress_egress()
1986 if(!cf->next || !cf->next->cft->has_data_pending(cf->next, data)) in h2_progress_ingress()
2527 cf->next->cft->do_close(cf->next, data); in cf_h2_close()
2663 return cf->next ? cf->next->cft->has_data_pending(cf->next, data) : FALSE; in cf_h2_data_pending()
[all …]
H A Dcfilters.h663 #define CF_DATA_SAVE(save, cf, data) \ argument
665 (save) = CF_CTX_CALL_DATA(cf); \
667 CF_CTX_CALL_DATA(cf).depth++; \
671 #define CF_DATA_RESTORE(cf, save) \ argument
675 CF_CTX_CALL_DATA(cf) = (save); \
680 #define CF_DATA_SAVE(save, cf, data) \ argument
682 (save) = CF_CTX_CALL_DATA(cf); \
686 #define CF_DATA_RESTORE(cf, save) \ argument
688 CF_CTX_CALL_DATA(cf) = (save); \
693 #define CF_DATA_CURRENT(cf) \ argument
[all …]
H A Dconnect.c574 (void)cf; in baller_connect()
966 cf->next = ctx->winner->cf; in cf_he_connect()
1004 cf->next->cft->do_close(cf->next, data); in cf_he_close()
1260 if(cf->next && !cf->next->connected) { in cf_setup_connect()
1271 if(!cf->next || !cf->next->connected) in cf_setup_connect()
1282 if(!cf->next || !cf->next->connected) in cf_setup_connect()
1304 if(!cf->next || !cf->next->connected) in cf_setup_connect()
1312 if(Curl_conn_is_ssl(cf->conn, cf->sockindex)) { in cf_setup_connect()
1323 if(!cf->next || !cf->next->connected) in cf_setup_connect()
1339 if(!cf->next || !cf->next->connected) in cf_setup_connect()
[all …]
H A Dcf-h1-proxy.c100 (void)cf; in tunnel_reinit()
197 if(cf) { in tunnel_free()
205 cf->ctx = NULL; in tunnel_free()
295 (void)cf; in on_resp_header()
989 result = cf->next->cft->do_connect(cf->next, data, blocking, done); in cf_h1_proxy_connect()
998 cf->ctx = ts; in cf_h1_proxy_connect()
1060 if(cf) { in cf_h1_proxy_close()
1062 if(cf->ctx) { in cf_h1_proxy_close()
1063 h1_tunnel_go_state(cf, cf->ctx, H1_TUNNEL_INIT, data); in cf_h1_proxy_close()
1065 if(cf->next) in cf_h1_proxy_close()
[all …]
H A Dcf-socket.c1006 if(ctx->sock == cf->conn->sock[cf->sockindex]) in cf_socket_close()
1007 cf->conn->sock[cf->sockindex] = CURL_SOCKET_BAD; in cf_socket_close()
1486 fdsave = cf->conn->sock[cf->sockindex]; in cf_socket_send()
1487 cf->conn->sock[cf->sockindex] = ctx->sock; in cf_socket_send()
1498 cf->conn->sock[cf->sockindex] = fdsave; in cf_socket_send()
1556 cf->conn->sock[cf->sockindex] = fdsave; in cf_socket_send()
1643 cf->conn->sock[cf->sockindex] = ctx->sock; in cf_socket_active()
2158 cf->conn->sock[cf->sockindex] = ctx->sock; in cf_tcp_accept_connect()
2250 cf = cf->next; in Curl_conn_is_tcp_listen()
2260 return cf && (cf->cft == &Curl_cft_tcp || in cf_is_socket()
[all …]
H A Dsocks.c122 if(SOCKET_READABLE(cf->conn->sock[cf->sockindex], timeout_ms) <= 0) { in Curl_blockread_all()
1118 cf->ctx = NULL; in socks_proxy_cf_free()
1138 if(cf->connected) { in socks_proxy_cf_connect()
1143 result = cf->next->cft->do_connect(cf->next, data, blocking, done); in socks_proxy_cf_connect()
1151 cf->ctx = sx; in socks_proxy_cf_connect()
1182 *done = cf->connected; in socks_proxy_cf_connect()
1215 DEBUGASSERT(cf->next); in socks_proxy_cf_close()
1216 cf->connected = FALSE; in socks_proxy_cf_close()
1218 cf->next->cft->do_close(cf->next, data); in socks_proxy_cf_close()
1235 if(!cf->connected) { in socks_cf_get_host()
[all …]
/curl/lib/vquic/
H A Dcurl_ngtcp2.c280 (void)cf; in h3_data_done()
297 (void)cf; in get_stream_easy()
328 (void)cf; in h3_drain_stream()
363 pktx->cf = cf; in pktx_init()
990 (void)cf; in cb_h3_end_headers()
1023 (void)cf; in cb_h3_recv_header()
2131 ctx = cf ? cf->ctx : NULL; in quic_ossl_new_session_cb()
2132 data = cf ? CF_DATA_CURRENT(cf) : NULL; in quic_ossl_new_session_cb()
2148 struct cf_ngtcp2_ctx *ctx = cf ? cf->ctx : NULL; in quic_gtls_handshake_cb()
2517 if(!cf->next || !cf->next->cft->is_alive(cf->next, data, input_pending)) in cf_ngtcp2_conn_is_alive()
[all …]
H A Dcurl_quiche.c251 (void)cf; in h3_data_done()
278 (void)cf; in h3_drain_stream()
296 (void)cf; in get_stream_easy()
350 (void)cf; in write_resp_raw()
456 cb_ctx.cf = cf; in cf_recv_body()
511 cb_ctx.cf = cf; in h3_process_event()
678 rctx.cf = cf; in cf_process_ingress()
762 readx.cf = cf; in cf_flush_egress()
1199 (void)cf; in cf_quiche_data_pending()
1603 if(!cf->next || !cf->next->cft->is_alive(cf->next, data, input_pending)) in cf_quiche_conn_is_alive()
[all …]
H A Dcurl_msh3.c229 (void)cf; in h3_data_done()
258 (void)cf; in h3_drain_stream()
525 (void)cf; in recv_closed_stream()
557 (void)cf; in set_quic_expire()
744 (void)cf; in cf_msh3_data_pending()
959 cf->conn->sock[cf->sockindex] = CURL_SOCKET_BAD; in cf_msh3_close()
987 if(cf->ctx) { in cf_msh3_destroy()
1024 cf->next->cft->query(cf->next, data, query, pres1, pres2) : in cf_msh3_query()
1063 while(cf) { in h3_get_msh3_ctx()
1066 cf = cf->next; in h3_get_msh3_ctx()
[all …]
H A Dcurl_osslq.c650 (void)cf; in h3_data_done()
708 (void)cf; in h3_drain_stream()
775 (void)cf; in write_resp_raw()
859 (void)cf; in cb_h3_recv_header()
918 (void)cf; in cb_h3_end_headers()
992 (void)cf; in cb_h3_read_req_body()
1056 (void)cf; in cb_h3_acked_stream_data()
1319 x.cf = cf; in cf_osslq_stream_recv()
2008 (void)cf; in recv_closed_stream()
2206 if(!cf->next || !cf->next->cft->is_alive(cf->next, data, input_pending)) in cf_osslq_conn_is_alive()
[all …]
H A Dvquic-tls.c80 struct Curl_cfilter *cf, in wssl_init_ctx() argument
88 conn_config = Curl_ssl_cf_get_primary_config(cf); in wssl_init_ctx()
101 result = cb_setup(cf, data, cb_user_data); in wssl_init_ctx()
198 struct Curl_cfilter *cf, in wssl_init_ssl() argument
224 (void)wssl_setup_session(cf, data, &ctx->wssl, peer); in wssl_init_ssl()
232 struct Curl_cfilter *cf, in Curl_vquic_tls_init() argument
248 return Curl_gtls_ctx_init(&ctx->gtls, cf, data, peer, in Curl_vquic_tls_init()
284 struct Curl_cfilter *cf, in Curl_vquic_tls_before_recv() argument
307 (void)ctx; (void)cf; (void)data; in Curl_vquic_tls_before_recv()
313 struct Curl_cfilter *cf, in Curl_vquic_tls_verify_peer() argument
[all …]
H A Dvquic_int.h61 void vquic_push_blocked_pkt(struct Curl_cfilter *cf,
65 CURLcode vquic_send_blocked_pkts(struct Curl_cfilter *cf,
69 CURLcode vquic_send(struct Curl_cfilter *cf, struct Curl_easy *data,
72 CURLcode vquic_send_tail_split(struct Curl_cfilter *cf, struct Curl_easy *data,
76 CURLcode vquic_flush(struct Curl_cfilter *cf, struct Curl_easy *data,
85 CURLcode vquic_recv_packets(struct Curl_cfilter *cf,
/curl/lib/vtls/
H A Dvtls.c1218 (void)cf; in Curl_none_shutdown()
1228 (void)cf; in Curl_none_check_cxn()
1246 (void)cf; in Curl_none_data_pending()
1695 cf->next->cft->do_close(cf->next, data); in ssl_cf_close()
1881 if(cf->connected && !Curl_ssl_cf_is_proxy(cf)) in ssl_cf_query()
2071 for(; cf; cf = cf->next) { in get_ssl_filter()
2092 if(cf) { in Curl_ssl_get_internals()
2162 for(cf = head; cf; cf = cf->next) { in Curl_ssl_cfilter_remove()
2188 (void)cf; in Curl_ssl_cf_get_config()
2202 &cf->conn->proxy_ssl_config : &cf->conn->ssl_config; in Curl_ssl_cf_get_primary_config()
[all …]
H A Dvtls_int.h64 CURLcode Curl_alpn_set_negotiated(struct Curl_cfilter *cf,
126 #define CF_CTX_CALL_DATA(cf) \ argument
127 ((struct ssl_connect_data *)(cf)->ctx)->call_data
148 bool (*data_pending)(struct Curl_cfilter *cf,
156 CURLcode (*connect_blocking)(struct Curl_cfilter *cf,
158 CURLcode (*connect_nonblocking)(struct Curl_cfilter *cf,
167 void (*close)(struct Curl_cfilter *cf, struct Curl_easy *data);
201 bool Curl_none_data_pending(struct Curl_cfilter *cf,
214 bool Curl_ssl_cf_is_proxy(struct Curl_cfilter *cf);
229 bool Curl_ssl_getsessionid(struct Curl_cfilter *cf,
[all …]
H A Drustls.c76 struct ssl_connect_data *ctx = cf->ctx; in cr_data_pending()
86 struct Curl_cfilter *cf; member
147 io_ctx.cf = cf; in tls_recv_more()
210 if(tls_recv_more(cf, data, err) < 0) { in cr_recv()
283 io_ctx.cf = cf; in cr_flush_out()
347 *err = cr_flush_out(cf, data, rconn); in cr_send()
378 *err = cr_flush_out(cf, data, rconn); in cr_send()
815 result = cr_init_backend(cf, data, in cr_connect_common()
968 cr_shutdown(struct Curl_cfilter *cf, in cr_shutdown() argument
981 if(!backend->conn || cf->shutdown) { in cr_shutdown()
[all …]
H A Dwolfssl.c275 (void)cf; in wolfssl_bio_cf_ctrl()
302 return (!cf->next || !cf->next->connected); in wolfssl_bio_cf_ctrl()
315 struct ssl_connect_data *connssl = cf->ctx; in wolfssl_bio_cf_out_write()
458 struct Curl_cfilter *cf; in wssl_vtls_new_session_cb() local
461 DEBUGASSERT(cf != NULL); in wssl_vtls_new_session_cb()
462 if(cf && session) { in wssl_vtls_new_session_cb()
1285 wolfSSL_BIO_set_data(bio, cf); in wolfssl_connect_step1()
1623 if(!wctx->handle || cf->shutdown) { in wolfssl_shutdown()
1646 else if(!cf->next->cft->is_alive(cf->next, data, &input_pending)) { in wolfssl_shutdown()
1710 cf->shutdown = (result || *done); in wolfssl_shutdown()
[all …]
H A Dgtls.c97 struct Curl_cfilter *cf = s; in gtls_push() local
98 struct ssl_connect_data *connssl = cf->ctx; in gtls_push()
101 struct Curl_easy *data = CF_DATA_CURRENT(cf); in gtls_push()
120 struct Curl_cfilter *cf = s; in gtls_pull() local
121 struct ssl_connect_data *connssl = cf->ctx; in gtls_pull()
247 struct ssl_connect_data *connssl = cf->ctx; in handshake()
1854 if(!Curl_ssl_cf_is_proxy(cf)) in gtls_connect_common()
1897 if(!Curl_ssl_cf_is_proxy(cf)) in gtls_connect_common()
1966 struct ssl_connect_data *ctx = cf->ctx; in gtls_data_pending()
2125 cf->shutdown = (result || *done); in gtls_shutdown()
[all …]
H A Dopenssl.h56 typedef CURLcode Curl_ossl_ctx_setup_cb(struct Curl_cfilter *cf,
63 struct Curl_cfilter *cf,
84 CURLcode Curl_ssl_setup_x509_store(struct Curl_cfilter *cf,
88 CURLcode Curl_ossl_ctx_configure(struct Curl_cfilter *cf,
95 CURLcode Curl_ossl_add_session(struct Curl_cfilter *cf,
105 CURLcode Curl_oss_check_peer_cert(struct Curl_cfilter *cf,
H A Dbearssl.c535 struct ssl_connect_data *connssl = cf->ctx; in bearssl_connect_step1()
551 CURL_TRC_CF(data, cf, "connect_step1"); in bearssl_connect_step1()
683 struct ssl_connect_data *connssl = cf->ctx; in bearssl_run_until()
771 CURL_TRC_CF(data, cf, "connect_step2"); in bearssl_connect_step2()
824 CURL_TRC_CF(data, cf, "connect_step3"); in bearssl_connect_step3()
935 ret = bearssl_connect_step1(cf, data); in bearssl_connect_common()
987 ret = bearssl_connect_step2(cf, data); in bearssl_connect_common()
993 ret = bearssl_connect_step3(cf, data); in bearssl_connect_common()
1019 struct ssl_connect_data *ctx = cf->ctx; in bearssl_data_pending()
1089 if(!backend->active || cf->shutdown) { in bearssl_shutdown()
[all …]
H A Dmbedtls.c187 struct Curl_cfilter *cf = bio; in mbedtls_bio_cf_write() local
188 struct Curl_easy *data = CF_DATA_CURRENT(cf); in mbedtls_bio_cf_write()
208 struct Curl_cfilter *cf = bio; in mbedtls_bio_cf_read() local
839 mbedtls_ssl_set_bio(&backend->ssl, cf,
1294 cf->shutdown = (result || *done);
1344 mbed_new_session(cf, data);
1439 retcode = mbed_connect_step1(cf, data);
1491 retcode = mbed_connect_step2(cf, data);
1501 struct ssl_connect_data *ctx = cf->ctx;
1510 retcode = mbed_new_session(cf, data);
[all …]

Completed in 133 milliseconds

123