Lines Matching refs:ClientHandler
69 auto handler = static_cast<ClientHandler *>(conn->data); in timeoutcb()
81 auto handler = static_cast<ClientHandler *>(w->data); in shutdowncb()
94 auto handler = static_cast<ClientHandler *>(conn->data); in readcb()
106 auto handler = static_cast<ClientHandler *>(conn->data); in writecb()
115 int ClientHandler::noop() { return 0; } in noop()
117 int ClientHandler::read_clear() { in read_clear()
153 int ClientHandler::write_clear() { in write_clear()
184 int ClientHandler::proxy_protocol_peek_clear() { in proxy_protocol_peek_clear()
213 int ClientHandler::tls_handshake() { in tls_handshake()
236 read_ = &ClientHandler::read_tls; in tls_handshake()
237 write_ = &ClientHandler::write_tls; in tls_handshake()
242 int ClientHandler::read_tls() { in read_tls()
283 int ClientHandler::write_tls() { in write_tls()
322 int ClientHandler::read_quic(const UpstreamAddr *faddr, in read_quic()
332 int ClientHandler::write_quic() { return upstream_->on_write(); } in write_quic()
335 int ClientHandler::upstream_noop() { return 0; } in upstream_noop()
337 int ClientHandler::upstream_read() { in upstream_read()
345 int ClientHandler::upstream_write() { in upstream_write()
358 int ClientHandler::upstream_http2_connhd_read() { in upstream_http2_connhd_read()
375 on_read_ = &ClientHandler::upstream_read; in upstream_http2_connhd_read()
387 int ClientHandler::upstream_http1_connhd_read() { in upstream_http1_connhd_read()
398 on_read_ = &ClientHandler::upstream_read; in upstream_http1_connhd_read()
399 on_write_ = &ClientHandler::upstream_write; in upstream_http1_connhd_read()
418 on_read_ = &ClientHandler::upstream_read; in upstream_http1_connhd_read()
419 on_write_ = &ClientHandler::upstream_write; in upstream_http1_connhd_read()
433 ClientHandler::ClientHandler(Worker *worker, int fd, SSL *ssl, in ClientHandler() function in shrpx::ClientHandler
478 read_ = &ClientHandler::proxy_protocol_peek_clear; in ClientHandler()
479 write_ = &ClientHandler::noop; in ClientHandler()
480 on_read_ = &ClientHandler::proxy_protocol_read; in ClientHandler()
481 on_write_ = &ClientHandler::upstream_noop; in ClientHandler()
508 void ClientHandler::init_forwarded_for(int family, const StringRef &ipaddr) { in init_forwarded_for()
527 void ClientHandler::setup_upstream_io_callback() { in setup_upstream_io_callback()
530 read_ = write_ = &ClientHandler::tls_handshake; in setup_upstream_io_callback()
531 on_read_ = &ClientHandler::upstream_noop; in setup_upstream_io_callback()
532 on_write_ = &ClientHandler::upstream_write; in setup_upstream_io_callback()
539 read_ = &ClientHandler::read_clear; in setup_upstream_io_callback()
540 write_ = &ClientHandler::write_clear; in setup_upstream_io_callback()
541 on_read_ = &ClientHandler::upstream_http1_connhd_read; in setup_upstream_io_callback()
542 on_write_ = &ClientHandler::upstream_noop; in setup_upstream_io_callback()
547 void ClientHandler::setup_http3_upstream( in setup_http3_upstream()
550 write_ = &ClientHandler::write_quic; in setup_http3_upstream()
558 ClientHandler::~ClientHandler() { in ~ClientHandler()
588 Upstream *ClientHandler::get_upstream() { return upstream_.get(); } in get_upstream()
590 struct ev_loop *ClientHandler::get_loop() const { in get_loop()
594 void ClientHandler::reset_upstream_read_timeout(ev_tstamp t) { in reset_upstream_read_timeout()
601 void ClientHandler::reset_upstream_write_timeout(ev_tstamp t) { in reset_upstream_write_timeout()
608 void ClientHandler::repeat_read_timer() { in repeat_read_timer()
612 void ClientHandler::stop_read_timer() { ev_timer_stop(conn_.loop, &conn_.rt); } in stop_read_timer()
614 int ClientHandler::validate_next_proto() { in validate_next_proto()
619 on_read_ = &ClientHandler::upstream_read; in validate_next_proto()
654 on_read_ = &ClientHandler::upstream_http2_connhd_read; in validate_next_proto()
690 int ClientHandler::do_read() { return read_(*this); } in do_read()
691 int ClientHandler::do_write() { return write_(*this); } in do_write()
693 int ClientHandler::on_read() { in on_read()
703 int ClientHandler::on_write() { return on_write_(*this); } in on_write()
705 const StringRef &ClientHandler::get_ipaddr() const { return ipaddr_; } in get_ipaddr()
707 bool ClientHandler::get_should_close_after_write() const { in get_should_close_after_write()
711 void ClientHandler::set_should_close_after_write(bool f) { in set_should_close_after_write()
715 void ClientHandler::pool_downstream_connection( in pool_downstream_connection()
754 Http2Session *ClientHandler::get_http2_session( in get_http2_session()
807 uint32_t ClientHandler::get_affinity_cookie(Downstream *downstream, in get_affinity_cookie()
852 DownstreamAddr *ClientHandler::get_downstream_addr(int &err, in get_downstream_addr()
960 DownstreamAddr *ClientHandler::get_downstream_addr_strict_affinity( in get_downstream_addr_strict_affinity()
1023 ClientHandler::get_downstream_connection(int &err, Downstream *downstream) { in get_downstream_connection()
1156 MemchunkPool *ClientHandler::get_mcpool() { return worker_->get_mcpool(); } in get_mcpool()
1158 SSL *ClientHandler::get_ssl() const { return conn_.tls.ssl; } in get_ssl()
1160 void ClientHandler::direct_http2_upgrade() { in direct_http2_upgrade()
1163 on_read_ = &ClientHandler::upstream_read; in direct_http2_upgrade()
1164 write_ = &ClientHandler::write_clear; in direct_http2_upgrade()
1167 int ClientHandler::perform_http2_upgrade(HttpsUpstream *http) { in perform_http2_upgrade()
1188 on_read_ = &ClientHandler::upstream_http2_connhd_read; in perform_http2_upgrade()
1189 write_ = &ClientHandler::write_clear; in perform_http2_upgrade()
1206 bool ClientHandler::get_http2_upgrade_allowed() const { return !conn_.tls.ssl; } in get_http2_upgrade_allowed()
1208 StringRef ClientHandler::get_upstream_scheme() const { in get_upstream_scheme()
1216 void ClientHandler::start_immediate_shutdown() { in start_immediate_shutdown()
1220 void ClientHandler::write_accesslog(Downstream *downstream) { in write_accesslog()
1246 ClientHandler::ReadBuf *ClientHandler::get_rb() { return &rb_; } in get_rb()
1248 void ClientHandler::signal_write() { conn_.wlimit.startw(); } in signal_write()
1250 RateLimit *ClientHandler::get_rlimit() { return &conn_.rlimit; } in get_rlimit()
1251 RateLimit *ClientHandler::get_wlimit() { return &conn_.wlimit; } in get_wlimit()
1253 ev_io *ClientHandler::get_wev() { return &conn_.wev; } in get_wev()
1255 Worker *ClientHandler::get_worker() const { return worker_; } in get_worker()
1286 int ClientHandler::on_proxy_protocol_finish() { in on_proxy_protocol_finish()
1320 int ClientHandler::proxy_protocol_read() { in proxy_protocol_read()
1516 int ClientHandler::proxy_protocol_v2_read() { in proxy_protocol_v2_read()
1677 StringRef ClientHandler::get_forwarded_by() const { in get_forwarded_by()
1687 StringRef ClientHandler::get_forwarded_for() const { return forwarded_for_; } in get_forwarded_for()
1689 const UpstreamAddr *ClientHandler::get_upstream_addr() const { return faddr_; } in get_upstream_addr()
1691 Connection *ClientHandler::get_connection() { return &conn_; }; in get_connection()
1693 void ClientHandler::set_tls_sni(const StringRef &sni) { in set_tls_sni()
1697 StringRef ClientHandler::get_tls_sni() const { return sni_; } in get_tls_sni()
1699 StringRef ClientHandler::get_alpn() const { return alpn_; } in get_alpn()
1701 BlockAllocator &ClientHandler::get_block_allocator() { return balloc_; } in get_block_allocator()
1703 void ClientHandler::set_alpn_from_conn() { in set_alpn_from_conn()