Lines Matching refs:conn_
127 conn_.rlimit.stopw(); in read_clear()
131 if (!ev_is_active(&conn_.rev) || should_break) { in read_clear()
135 auto nread = conn_.read_clear(rb_.last(), rb_.wleft()); in read_clear()
166 auto nwrite = conn_.writev_clear(iov.data(), iovcnt); in write_clear()
178 conn_.wlimit.stopw(); in write_clear()
179 ev_timer_stop(conn_.loop, &conn_.wt); in write_clear()
189 auto nread = conn_.peek_clear(rb_.last(), rb_.wleft()); in proxy_protocol_peek_clear()
214 ev_timer_again(conn_.loop, &conn_.rt); in tls_handshake()
218 auto rv = conn_.tls_handshake(); in tls_handshake()
257 conn_.rlimit.stopw(); in read_tls()
261 if (!ev_is_active(&conn_.rev) || should_break) { in read_tls()
265 auto nread = conn_.read_tls(rb_.last(), rb_.wleft()); in read_tls()
294 conn_.start_tls_write_idle(); in write_tls()
296 conn_.wlimit.stopw(); in write_tls()
297 ev_timer_stop(conn_.loop, &conn_.wt); in write_tls()
303 auto nwrite = conn_.write_tls(iov.iov_base, iov.iov_len); in write_tls()
372 conn_.rlimit.startw(); in upstream_http2_connhd_read()
410 conn_.rlimit.startw(); in upstream_http1_connhd_read()
445 conn_(worker->get_loop(), fd, ssl, worker->get_mcpool(), in ClientHandler()
469 conn_.rlimit.startw(); in ClientHandler()
471 ev_timer_again(conn_.loop, &conn_.rt); in ClientHandler()
528 if (conn_.tls.ssl) { in setup_upstream_io_callback()
529 conn_.prepare_server_handshake(); in setup_upstream_io_callback()
574 ev_timer_stop(conn_.loop, &reneg_shutdown_timer_); in ~ClientHandler()
580 ev_break(conn_.loop); in ~ClientHandler()
591 return conn_.loop; in get_loop()
595 conn_.rt.repeat = t; in reset_upstream_read_timeout()
596 if (ev_is_active(&conn_.rt)) { in reset_upstream_read_timeout()
597 ev_timer_again(conn_.loop, &conn_.rt); in reset_upstream_read_timeout()
602 conn_.wt.repeat = t; in reset_upstream_write_timeout()
603 if (ev_is_active(&conn_.wt)) { in reset_upstream_write_timeout()
604 ev_timer_again(conn_.loop, &conn_.wt); in reset_upstream_write_timeout()
609 ev_timer_again(conn_.loop, &conn_.rt); in repeat_read_timer()
612 void ClientHandler::stop_read_timer() { ev_timer_stop(conn_.loop, &conn_.rt); } in stop_read_timer()
622 SSL_get0_next_proto_negotiated(conn_.tls.ssl, &next_proto, &next_proto_len); in validate_next_proto()
626 SSL_get0_alpn_selected(conn_.tls.ssl, &next_proto, &next_proto_len); in validate_next_proto()
700 conn_.handle_tls_pending_read(); in on_read()
795 auto session = new Http2Session(conn_.loop, worker_->get_cl_ssl_ctx(), in get_http2_session()
1097 if (groups[group_idx]->shared_addr->redirect_if_not_tls && !conn_.tls.ssl) { in get_downstream_connection()
1139 dconn = std::make_unique<HttpDownstreamConnection>(group, addr, conn_.loop, in get_downstream_connection()
1158 SSL *ClientHandler::get_ssl() const { return conn_.tls.ssl; } in get_ssl()
1206 bool ClientHandler::get_http2_upgrade_allowed() const { return !conn_.tls.ssl; } in get_http2_upgrade_allowed()
1209 if (conn_.tls.ssl) { in get_upstream_scheme()
1217 ev_timer_start(conn_.loop, &reneg_shutdown_timer_); in start_immediate_shutdown()
1238 conn_.tls.ssl, in write_accesslog()
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()
1298 if (conn_.read_nolim_clear(rb_.pos(), len) < 0) { in on_proxy_protocol_finish()
1691 Connection *ClientHandler::get_connection() { return &conn_; }; in get_connection()
1707 SSL_get0_alpn_selected(conn_.tls.ssl, &alpn, &alpnlen); in set_alpn_from_conn()