Lines Matching refs:conn_
105 : conn_(loop, -1, nullptr, worker->get_mcpool(),
135 ev_timer_stop(conn_.loop, &backoff_timer_);
149 conn_.rlimit.stopw();
150 conn_.wlimit.stopw();
152 ev_timer_stop(conn_.loop, &settings_timer_);
156 conn_.disconnect();
187 ev_timer_start(conn_.loop, &backoff_timer_);
224 conn_.set_ssl(ssl);
225 conn_.tls.client_session_cache = &addr_->tls_session_cache;
278 conn_.fd = util::create_nonblock_socket(raddr_->su.storage.ss_family);
280 if (conn_.fd == -1) {
287 rv = connect(conn_.fd, &raddr_->su.sa, raddr_->len);
293 close(conn_.fd);
294 conn_.fd = -1;
303 SSL_set_tlsext_host_name(conn_.tls.ssl, sni_name.c_str());
308 SSL_set_session(conn_.tls.ssl, session);
312 conn_.prepare_client_handshake();
317 ev_io_set(&conn_.wev, conn_.fd, EV_WRITE);
318 ev_io_set(&conn_.rev, conn_.fd, EV_READ);
320 conn_.wlimit.startw();
324 conn_.wt.repeat = downstreamconf.timeout.connect;
325 ev_timer_again(conn_.loop, &conn_.wt);
331 auto sock_error = util::get_socket_error(conn_.fd);
348 conn_.wt.repeat = downstreamconf.timeout.write;
349 ev_timer_again(conn_.loop, &conn_.wt);
351 conn_.rlimit.startw();
352 conn_.again_rt();
354 if (conn_.tls.ssl) {
380 conn_.last_read = std::chrono::steady_clock::now();
384 auto rv = conn_.tls_handshake();
399 tls::check_cert(conn_.tls.ssl, addr_, raddr_) != 0) {
409 SSL_get0_next_proto_negotiated(conn_.tls.ssl, &next_proto, &next_proto_len);
413 SSL_get0_alpn_selected(conn_.tls.ssl, &next_proto, &next_proto_len);
449 conn_.last_read = std::chrono::steady_clock::now();
456 auto nread = conn_.read_tls(buf.data(), buf.size());
473 conn_.last_read = std::chrono::steady_clock::now();
486 auto nwrite = conn_.write_tls(iov.iov_base, iov.iov_len);
506 conn_.start_tls_write_idle();
511 conn_.wlimit.stopw();
512 ev_timer_stop(conn_.loop, &conn_.wt);
522 conn_.last_read = std::chrono::steady_clock::now();
527 auto nread = conn_.read_clear(buf.data(), buf.size());
544 conn_.last_read = std::chrono::steady_clock::now();
555 auto nwrite = conn_.write_clear(iov.iov_base, iov.iov_len);
579 conn_.wlimit.stopw();
580 ev_timer_stop(conn_.loop, &conn_.wt);
708 ev_timer_start(conn_.loop, &settings_timer_);
712 ev_timer_stop(conn_.loop, &settings_timer_);
778 addr_->tls && !nghttp2::tls::check_http2_requirement(conn_.tls.ssl);
797 void LiveCheck::signal_write() { conn_.wlimit.startw(); }