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