Lines Matching refs:conn_
187 conn_(loop, -1, nullptr, worker->get_mcpool(),
248 conn_.rlimit.stopw();
249 conn_.wlimit.stopw();
251 ev_prepare_stop(conn_.loop, &prep_);
253 ev_timer_stop(conn_.loop, &initiate_connection_timer_);
254 ev_timer_stop(conn_.loop, &settings_timer_);
255 ev_timer_stop(conn_.loop, &connchk_timer_);
262 conn_.disconnect();
396 conn_.fd = util::create_nonblock_socket(proxy.addr.su.storage.ss_family);
398 if (conn_.fd == -1) {
408 rv = connect(conn_.fd, &proxy.addr.su.sa, proxy.addr.len);
424 ev_io_set(&conn_.rev, conn_.fd, EV_READ);
425 ev_io_set(&conn_.wev, conn_.fd, EV_WRITE);
427 conn_.wlimit.startw();
429 conn_.wt.repeat = downstreamconf.timeout.connect;
430 ev_timer_again(conn_.loop, &conn_.wt);
465 conn_.set_ssl(ssl);
466 conn_.tls.client_session_cache = &addr_->tls_session_cache;
475 SSL_set_tlsext_host_name(conn_.tls.ssl, sni_name.c_str());
480 SSL_set_session(conn_.tls.ssl, tls_session);
513 // connected to the proxy using conn_.fd and tunnel has been
516 assert(conn_.fd == -1);
518 conn_.fd = util::create_nonblock_socket(raddr_->su.storage.ss_family);
519 if (conn_.fd == -1) {
531 rv = connect(conn_.fd,
544 ev_io_set(&conn_.rev, conn_.fd, EV_READ);
545 ev_io_set(&conn_.wev, conn_.fd, EV_WRITE);
548 conn_.prepare_client_handshake();
580 assert(conn_.fd == -1);
582 conn_.fd = util::create_nonblock_socket(raddr_->su.storage.ss_family);
584 if (conn_.fd == -1) {
596 rv = connect(conn_.fd, const_cast<sockaddr *>(&raddr_->su.sa),
608 ev_io_set(&conn_.rev, conn_.fd, EV_READ);
609 ev_io_set(&conn_.wev, conn_.fd, EV_WRITE);
624 conn_.wlimit.startw();
626 conn_.wt.repeat = downstreamconf.timeout.connect;
627 ev_timer_again(conn_.loop, &conn_.wt);
893 ev_timer_start(conn_.loop, &settings_timer_);
897 ev_timer_stop(conn_.loop, &settings_timer_);
1676 SSL_get0_next_proto_negotiated(conn_.tls.ssl, &next_proto, &next_proto_len);
1680 SSL_get0_alpn_selected(conn_.tls.ssl, &next_proto, &next_proto_len);
1825 ev_timer_start(conn_.loop, &initiate_connection_timer_);
1826 ev_feed_event(conn_.loop, &initiate_connection_timer_, 0);
1830 conn_.wlimit.startw();
1838 return conn_.loop;
1841 ev_io *Http2Session::get_wev() { return &conn_.wev; }
1856 SSL *Http2Session::get_ssl() const { return conn_.tls.ssl; }
1904 ev_timer_again(conn_.loop, &connchk_timer_);
1976 auto sock_error = util::get_socket_error(conn_.fd);
1992 conn_.wt.repeat = group_->shared_addr->timeout.write;
1993 ev_timer_again(conn_.loop, &conn_.wt);
1995 conn_.rlimit.startw();
1996 conn_.again_rt();
2005 if (conn_.tls.ssl) {
2021 conn_.last_read = std::chrono::steady_clock::now();
2026 auto nread = conn_.read_clear(buf.data(), buf.size());
2043 conn_.last_read = std::chrono::steady_clock::now();
2050 auto nwrite = conn_.writev_clear(iov.data(), iovcnt);
2060 ev_feed_event(conn_.loop, &conn_.rev, EV_READ);
2077 conn_.wlimit.stopw();
2078 ev_timer_stop(conn_.loop, &conn_.wt);
2084 conn_.last_read = std::chrono::steady_clock::now();
2088 auto rv = conn_.tls_handshake();
2105 tls::check_cert(conn_.tls.ssl, addr_, raddr_) != 0) {
2123 conn_.last_read = std::chrono::steady_clock::now();
2130 auto nread = conn_.read_tls(buf.data(), buf.size());
2147 conn_.last_read = std::chrono::steady_clock::now();
2160 auto nwrite = conn_.write_tls(iov.iov_base, iov.iov_len);
2170 ev_feed_event(conn_.loop, &conn_.rev, EV_READ);
2184 conn_.start_tls_write_idle();
2189 conn_.wlimit.stopw();
2190 ev_timer_stop(conn_.loop, &conn_.wt);
2196 conn_.wlimit.stopw();
2396 ev_prepare_stop(conn_.loop, &prep_);