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