Home
last modified time | relevance | path

Searched refs:Curl_cfilter (Results 1 – 25 of 57) sorted by relevance

123

/third_party/curl/lib/
Dcfilters.h28 struct Curl_cfilter;
36 typedef void Curl_cft_destroy_this(struct Curl_cfilter *cf,
39 typedef void Curl_cft_close(struct Curl_cfilter *cf,
42 typedef CURLcode Curl_cft_connect(struct Curl_cfilter *cf,
57 typedef void Curl_cft_get_host(struct Curl_cfilter *cf,
88 typedef void Curl_cft_adjust_pollset(struct Curl_cfilter *cf,
92 typedef bool Curl_cft_data_pending(struct Curl_cfilter *cf,
95 typedef ssize_t Curl_cft_send(struct Curl_cfilter *cf,
101 typedef ssize_t Curl_cft_recv(struct Curl_cfilter *cf,
107 typedef bool Curl_cft_conn_is_alive(struct Curl_cfilter *cf,
[all …]
Dcfilters.c50 void Curl_cf_def_close(struct Curl_cfilter *cf, struct Curl_easy *data) in Curl_cf_def_close()
61 void Curl_cf_def_get_host(struct Curl_cfilter *cf, struct Curl_easy *data, in Curl_cf_def_get_host()
74 void Curl_cf_def_adjust_pollset(struct Curl_cfilter *cf, in Curl_cf_def_adjust_pollset()
84 bool Curl_cf_def_data_pending(struct Curl_cfilter *cf, in Curl_cf_def_data_pending()
91 ssize_t Curl_cf_def_send(struct Curl_cfilter *cf, struct Curl_easy *data, in Curl_cf_def_send()
99 ssize_t Curl_cf_def_recv(struct Curl_cfilter *cf, struct Curl_easy *data, in Curl_cf_def_recv()
107 bool Curl_cf_def_conn_is_alive(struct Curl_cfilter *cf, in Curl_cf_def_conn_is_alive()
116 CURLcode Curl_cf_def_conn_keep_alive(struct Curl_cfilter *cf, in Curl_cf_def_conn_keep_alive()
124 CURLcode Curl_cf_def_query(struct Curl_cfilter *cf, in Curl_cf_def_query()
133 void Curl_conn_cf_discard_chain(struct Curl_cfilter **pcf, in Curl_conn_cf_discard_chain()
[all …]
Dcf-https-connect.c54 struct Curl_cfilter *cf;
110 struct Curl_cfilter *cf, in cf_hc_baller_init()
116 struct Curl_cfilter *save = cf->next; in cf_hc_baller_init()
128 struct Curl_cfilter *cf, in cf_hc_baller_connect()
132 struct Curl_cfilter *save = cf->next; in cf_hc_baller_connect()
141 static void cf_hc_reset(struct Curl_cfilter *cf, struct Curl_easy *data) in cf_hc_reset()
155 static CURLcode baller_connected(struct Curl_cfilter *cf, in baller_connected()
203 static bool time_to_start_h21(struct Curl_cfilter *cf, in time_to_start_h21()
237 static CURLcode cf_hc_connect(struct Curl_cfilter *cf, in cf_hc_connect()
325 static void cf_hc_adjust_pollset(struct Curl_cfilter *cf, in cf_hc_adjust_pollset()
[all …]
Dcf-haproxy.c68 static CURLcode cf_haproxy_date_out_set(struct Curl_cfilter*cf, in cf_haproxy_date_out_set()
104 static CURLcode cf_haproxy_connect(struct Curl_cfilter *cf, in cf_haproxy_connect()
156 static void cf_haproxy_destroy(struct Curl_cfilter *cf, in cf_haproxy_destroy()
164 static void cf_haproxy_close(struct Curl_cfilter *cf, in cf_haproxy_close()
174 static void cf_haproxy_adjust_pollset(struct Curl_cfilter *cf, in cf_haproxy_adjust_pollset()
203 static CURLcode cf_haproxy_create(struct Curl_cfilter **pcf, in cf_haproxy_create()
206 struct Curl_cfilter *cf = NULL; in cf_haproxy_create()
230 CURLcode Curl_cf_haproxy_insert_after(struct Curl_cfilter *cf_at, in Curl_cf_haproxy_insert_after()
233 struct Curl_cfilter *cf; in Curl_cf_haproxy_insert_after()
Dhttp_proxy.c55 CURLcode Curl_http_proxy_get_destination(struct Curl_cfilter *cf, in Curl_http_proxy_get_destination()
85 struct Curl_cfilter *cf, in Curl_http_proxy_create_CONNECT()
164 struct Curl_cfilter *cf_protocol;
167 static CURLcode http_proxy_cf_connect(struct Curl_cfilter *cf, in http_proxy_cf_connect()
187 struct Curl_cfilter *cf_protocol = NULL; in http_proxy_cf_connect()
242 void Curl_cf_http_proxy_get_host(struct Curl_cfilter *cf, in Curl_cf_http_proxy_get_host()
259 static void http_proxy_cf_destroy(struct Curl_cfilter *cf, in http_proxy_cf_destroy()
269 static void http_proxy_cf_close(struct Curl_cfilter *cf, in http_proxy_cf_close()
277 struct Curl_cfilter *f; in http_proxy_cf_close()
312 CURLcode Curl_cf_http_proxy_insert_after(struct Curl_cfilter *cf_at, in Curl_cf_http_proxy_insert_after()
[all …]
Dcf-h2-proxy.c82 static CURLcode tunnel_stream_init(struct Curl_cfilter *cf, in tunnel_stream_init()
118 static void h2_tunnel_go_state(struct Curl_cfilter *cf, in h2_tunnel_go_state()
214 static void drain_tunnel(struct Curl_cfilter *cf, in drain_tunnel()
236 struct Curl_cfilter *cf = reader_ctx; in proxy_nw_in_reader()
255 struct Curl_cfilter *cf = writer_ctx; in proxy_h2_nw_out_writer()
271 static int proxy_h2_client_new(struct Curl_cfilter *cf, in proxy_h2_client_new()
320 static CURLcode cf_h2_proxy_ctx_init(struct Curl_cfilter *cf, in cf_h2_proxy_ctx_init()
407 static CURLcode proxy_h2_nw_out_flush(struct Curl_cfilter *cf, in proxy_h2_nw_out_flush()
437 static int proxy_h2_process_pending_input(struct Curl_cfilter *cf, in proxy_h2_process_pending_input()
471 static CURLcode proxy_h2_progress_ingress(struct Curl_cfilter *cf, in proxy_h2_progress_ingress()
[all …]
Dconnect.c342 struct Curl_cfilter *cf; /* current sub-cfilter connecting */
450 static void baller_initiate(struct Curl_cfilter *cf, in baller_initiate()
455 struct Curl_cfilter *cf_prev = baller->cf; in baller_initiate()
456 struct Curl_cfilter *wcf; in baller_initiate()
495 static CURLcode baller_start(struct Curl_cfilter *cf, in baller_start()
522 static CURLcode baller_start_next(struct Curl_cfilter *cf, in baller_start_next()
545 static CURLcode baller_connect(struct Curl_cfilter *cf, in baller_connect()
580 static CURLcode is_connected(struct Curl_cfilter *cf, in is_connected()
743 static CURLcode start_connect(struct Curl_cfilter *cf, in start_connect()
838 static void cf_he_ctx_clear(struct Curl_cfilter *cf, struct Curl_easy *data) in cf_he_ctx_clear()
[all …]
Dcf-socket.h32 struct Curl_cfilter;
103 CURLcode Curl_cf_tcp_create(struct Curl_cfilter **pcf,
116 CURLcode Curl_cf_udp_create(struct Curl_cfilter **pcf,
129 CURLcode Curl_cf_unix_create(struct Curl_cfilter **pcf,
162 CURLcode Curl_cf_socket_peek(struct Curl_cfilter *cf,
Dhttp_proxy.h33 CURLcode Curl_http_proxy_get_destination(struct Curl_cfilter *cf,
38 struct Curl_cfilter *cf,
45 void Curl_cf_http_proxy_get_host(struct Curl_cfilter *cf,
51 CURLcode Curl_cf_http_proxy_insert_after(struct Curl_cfilter *cf_at,
Dhttp2.c168 static CURLcode h2_progress_egress(struct Curl_cfilter *cf,
211 static void drain_stream(struct Curl_cfilter *cf, in drain_stream()
230 static CURLcode http2_data_setup(struct Curl_cfilter *cf, in http2_data_setup()
283 static void http2_data_done(struct Curl_cfilter *cf, in http2_data_done()
334 static int h2_client_new(struct Curl_cfilter *cf, in h2_client_new()
360 struct Curl_cfilter *cf = reader_ctx; in nw_in_reader()
370 struct Curl_cfilter *cf = writer_ctx; in nw_out_writer()
410 static CURLcode cf_h2_ctx_init(struct Curl_cfilter *cf, in cf_h2_ctx_init()
541 static int h2_process_pending_input(struct Curl_cfilter *cf, in h2_process_pending_input()
588 static bool http2_connisalive(struct Curl_cfilter *cf, struct Curl_easy *data, in http2_connisalive()
[all …]
Dcf-socket.c840 struct Curl_cfilter *cf;
888 static void cf_socket_close(struct Curl_cfilter *cf, struct Curl_easy *data) in cf_socket_close()
911 static void cf_socket_destroy(struct Curl_cfilter *cf, struct Curl_easy *data) in cf_socket_destroy()
922 static CURLcode set_local_ip(struct Curl_cfilter *cf, in set_local_ip()
957 static CURLcode set_remote_ip(struct Curl_cfilter *cf, in set_remote_ip()
976 static CURLcode cf_socket_open(struct Curl_cfilter *cf, in cf_socket_open()
1079 static int do_connect(struct Curl_cfilter *cf, struct Curl_easy *data, in do_connect()
1133 static CURLcode cf_tcp_connect(struct Curl_cfilter *cf, in cf_tcp_connect()
1230 static void cf_socket_get_host(struct Curl_cfilter *cf, in cf_socket_get_host()
1242 static void cf_socket_adjust_pollset(struct Curl_cfilter *cf, in cf_socket_adjust_pollset()
[all …]
Dcf-h1-proxy.c96 static CURLcode tunnel_reinit(struct Curl_cfilter *cf, in tunnel_reinit()
112 static CURLcode tunnel_init(struct Curl_cfilter *cf, in tunnel_init()
144 static void h1_tunnel_go_state(struct Curl_cfilter *cf, in h1_tunnel_go_state()
201 static void tunnel_free(struct Curl_cfilter *cf, in tunnel_free()
216 static CURLcode start_CONNECT(struct Curl_cfilter *cf, in start_CONNECT()
250 static CURLcode send_CONNECT(struct Curl_cfilter *cf, in send_CONNECT()
286 static CURLcode on_resp_header(struct Curl_cfilter *cf, in on_resp_header()
362 static CURLcode recv_CONNECT_resp(struct Curl_cfilter *cf, in recv_CONNECT_resp()
534 static CURLcode CONNECT_host(struct Curl_cfilter *cf, in CONNECT_host()
569 static CURLcode start_CONNECT(struct Curl_cfilter *cf, in start_CONNECT()
[all …]
Dsocks.h40 int Curl_blockread_all(struct Curl_cfilter *cf,
50 CURLcode Curl_SOCKS5_gssapi_negotiate(struct Curl_cfilter *cf,
54 CURLcode Curl_cf_socks_proxy_insert_after(struct Curl_cfilter *cf_at,
Dsocks.c101 int Curl_blockread_all(struct Curl_cfilter *cf, in Curl_blockread_all()
210 static CURLproxycode socks_state_send(struct Curl_cfilter *cf, in socks_state_send()
241 static CURLproxycode socks_state_recv(struct Curl_cfilter *cf, in socks_state_recv()
283 static CURLproxycode do_SOCKS4(struct Curl_cfilter *cf, in do_SOCKS4()
560 static CURLproxycode do_SOCKS5(struct Curl_cfilter *cf, in do_SOCKS5()
1082 static CURLcode connect_SOCKS(struct Curl_cfilter *cf, in connect_SOCKS()
1113 static void socks_proxy_cf_free(struct Curl_cfilter *cf) in socks_proxy_cf_free()
1129 static CURLcode socks_proxy_cf_connect(struct Curl_cfilter *cf, in socks_proxy_cf_connect()
1186 static void socks_cf_adjust_pollset(struct Curl_cfilter *cf, in socks_cf_adjust_pollset()
1211 static void socks_proxy_cf_close(struct Curl_cfilter *cf, in socks_proxy_cf_close()
[all …]
/third_party/curl/lib/vtls/
Dvtls_int.h62 CURLcode Curl_alpn_set_negotiated(struct Curl_cfilter *cf,
102 int (*check_cxn)(struct Curl_cfilter *cf, struct Curl_easy *data);
103 int (*shut_down)(struct Curl_cfilter *cf,
105 bool (*data_pending)(struct Curl_cfilter *cf,
113 CURLcode (*connect_blocking)(struct Curl_cfilter *cf,
115 CURLcode (*connect_nonblocking)(struct Curl_cfilter *cf,
122 void (*adjust_pollset)(struct Curl_cfilter *cf, struct Curl_easy *data,
125 void (*close)(struct Curl_cfilter *cf, struct Curl_easy *data);
137 bool (*attach_data)(struct Curl_cfilter *cf, struct Curl_easy *data);
138 void (*detach_data)(struct Curl_cfilter *cf, struct Curl_easy *data);
[all …]
Dvtls.c482 static CURLcode ssl_connect(struct Curl_cfilter *cf, struct Curl_easy *data) in ssl_connect()
503 ssl_connect_nonblocking(struct Curl_cfilter *cf, struct Curl_easy *data, in ssl_connect_nonblocking()
535 bool Curl_ssl_getsessionid(struct Curl_cfilter *cf, in Curl_ssl_getsessionid()
643 CURLcode Curl_ssl_addsessionid(struct Curl_cfilter *cf, in Curl_ssl_addsessionid()
768 void Curl_ssl_adjust_pollset(struct Curl_cfilter *cf, struct Curl_easy *data, in Curl_ssl_adjust_pollset()
1162 int Curl_none_shutdown(struct Curl_cfilter *cf UNUSED_PARAM, in Curl_none_shutdown()
1170 int Curl_none_check_cxn(struct Curl_cfilter *cf, struct Curl_easy *data) in Curl_none_check_cxn()
1197 bool Curl_none_data_pending(struct Curl_cfilter *cf UNUSED_PARAM, in Curl_none_data_pending()
1242 static CURLcode multissl_connect(struct Curl_cfilter *cf, in multissl_connect()
1250 static CURLcode multissl_connect_nonblocking(struct Curl_cfilter *cf, in multissl_connect_nonblocking()
[all …]
Dvtls.h55 struct Curl_cfilter;
110 CURLcode Curl_ssl_peer_init(struct ssl_peer *peer, struct Curl_cfilter *cf);
190 CURLcode Curl_cf_ssl_insert_after(struct Curl_cfilter *cf_at,
197 CURLcode Curl_cf_ssl_proxy_insert_after(struct Curl_cfilter *cf_at,
221 struct ssl_config_data *Curl_ssl_cf_get_config(struct Curl_cfilter *cf,
228 Curl_ssl_cf_get_primary_config(struct Curl_cfilter *cf);
Drustls.c68 cr_data_pending(struct Curl_cfilter *cf, const struct Curl_easy *data) in cr_data_pending()
80 struct Curl_cfilter *cf;
126 static ssize_t tls_recv_more(struct Curl_cfilter *cf, in tls_recv_more()
182 cr_recv(struct Curl_cfilter *cf, struct Curl_easy *data, in cr_recv()
275 cr_send(struct Curl_cfilter *cf, struct Curl_easy *data, in cr_send()
369 cr_init_backend(struct Curl_cfilter *cf, struct Curl_easy *data, in cr_init_backend()
471 cr_set_negotiated_alpn(struct Curl_cfilter *cf, struct Curl_easy *data, in cr_set_negotiated_alpn()
491 cr_connect_common(struct Curl_cfilter *cf, in cr_connect_common()
615 cr_connect_nonblocking(struct Curl_cfilter *cf, in cr_connect_nonblocking()
622 cr_connect_blocking(struct Curl_cfilter *cf UNUSED_PARAM, in cr_connect_blocking()
[all …]
/third_party/curl/lib/vquic/
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,
Dcurl_ngtcp2.c170 static CURLcode h3_data_setup(struct Curl_cfilter *cf, in h3_data_setup()
204 static void h3_data_done(struct Curl_cfilter *cf, struct Curl_easy *data) in h3_data_done()
229 static struct Curl_easy *get_stream_easy(struct Curl_cfilter *cf, in get_stream_easy()
250 static void h3_drain_stream(struct Curl_cfilter *cf, in h3_drain_stream()
271 struct Curl_cfilter *cf;
279 struct Curl_cfilter *cf) in pktx_update_time()
289 struct Curl_cfilter *cf, in pktx_init()
299 static CURLcode cf_progress_ingress(struct Curl_cfilter *cf,
302 static CURLcode cf_progress_egress(struct Curl_cfilter *cf,
311 struct Curl_cfilter *cf = conn_ref->user_data; in get_conn()
[all …]
Dcurl_msh3.c164 static CURLcode h3_data_setup(struct Curl_cfilter *cf, in h3_data_setup()
185 static void h3_data_done(struct Curl_cfilter *cf, struct Curl_easy *data) in h3_data_done()
213 static void drain_stream(struct Curl_cfilter *cf, in drain_stream()
238 struct Curl_cfilter *cf = IfContext; in msh3_conn_connected()
252 struct Curl_cfilter *cf = IfContext; in msh3_conn_shutdown_complete()
467 static ssize_t recv_closed_stream(struct Curl_cfilter *cf, in recv_closed_stream()
502 static void set_quic_expire(struct Curl_cfilter *cf, struct Curl_easy *data) in set_quic_expire()
518 static ssize_t cf_msh3_recv(struct Curl_cfilter *cf, struct Curl_easy *data, in cf_msh3_recv()
569 static ssize_t cf_msh3_send(struct Curl_cfilter *cf, struct Curl_easy *data, in cf_msh3_send()
680 static void cf_msh3_adjust_pollset(struct Curl_cfilter *cf, in cf_msh3_adjust_pollset()
[all …]
Dcurl_quiche.c161 static void check_resumes(struct Curl_cfilter *cf, in check_resumes()
180 static CURLcode h3_data_setup(struct Curl_cfilter *cf, in h3_data_setup()
201 static void h3_data_done(struct Curl_cfilter *cf, struct Curl_easy *data) in h3_data_done()
226 static void drain_stream(struct Curl_cfilter *cf, in drain_stream()
242 static struct Curl_easy *get_stream_easy(struct Curl_cfilter *cf, in get_stream_easy()
268 static CURLcode write_resp_raw(struct Curl_cfilter *cf, in write_resp_raw()
293 struct Curl_cfilter *cf;
362 static CURLcode cf_recv_body(struct Curl_cfilter *cf, in cf_recv_body()
421 static CURLcode h3_process_event(struct Curl_cfilter *cf, in h3_process_event()
486 static CURLcode cf_poll_events(struct Curl_cfilter *cf, in cf_poll_events()
[all …]
Dvquic-tls.h54 struct Curl_cfilter *cf,
71 struct Curl_cfilter *cf,
84 struct Curl_cfilter *cf,
92 struct Curl_cfilter *cf,
Dcurl_osslq.c100 static CURLcode cf_progress_ingress(struct Curl_cfilter *cf,
315 static void cf_osslq_close(struct Curl_cfilter *cf, struct Curl_easy *data) in cf_osslq_close()
331 static void cf_osslq_destroy(struct Curl_cfilter *cf, struct Curl_easy *data) in cf_osslq_destroy()
350 struct Curl_cfilter *cf, in cf_osslq_h3conn_add_stream()
383 static CURLcode cf_osslq_ssl_err(struct Curl_cfilter *cf, in cf_osslq_ssl_err()
464 static CURLcode cf_osslq_verify_peer(struct Curl_cfilter *cf, in cf_osslq_verify_peer()
505 static CURLcode h3_data_setup(struct Curl_cfilter *cf, in h3_data_setup()
539 static void h3_data_done(struct Curl_cfilter *cf, struct Curl_easy *data) in h3_data_done()
564 static struct cf_osslq_stream *cf_osslq_get_qstream(struct Curl_cfilter *cf, in cf_osslq_get_qstream()
596 static void h3_drain_stream(struct Curl_cfilter *cf, in h3_drain_stream()
[all …]
Dvquic.c121 static CURLcode send_packet_no_gso(struct Curl_cfilter *cf,
127 static CURLcode do_sendmsg(struct Curl_cfilter *cf, in do_sendmsg()
225 static CURLcode send_packet_no_gso(struct Curl_cfilter *cf, in send_packet_no_gso()
248 static CURLcode vquic_send_packets(struct Curl_cfilter *cf, in vquic_send_packets()
277 CURLcode vquic_flush(struct Curl_cfilter *cf, struct Curl_easy *data, in vquic_flush()
311 CURLcode vquic_send(struct Curl_cfilter *cf, struct Curl_easy *data, in vquic_send()
318 CURLcode vquic_send_tail_split(struct Curl_cfilter *cf, struct Curl_easy *data, in vquic_send_tail_split()
333 static CURLcode recvmmsg_packets(struct Curl_cfilter *cf, in recvmmsg_packets()
409 static CURLcode recvmsg_packets(struct Curl_cfilter *cf, in recvmsg_packets()
475 static CURLcode recvfrom_packets(struct Curl_cfilter *cf, in recvfrom_packets()
[all …]

123