Lines Matching refs:conn_
207 : conn_(loop, -1, nullptr, worker->get_mcpool(),
220 ioctrl_(&conn_.rlimit),
306 if (conn_.fd == -1) {
382 conn_.fd = util::create_nonblock_socket(raddr->su.storage.ss_family);
384 if (conn_.fd == -1) {
396 rv = connect(conn_.fd, &raddr->su.sa, raddr->len);
423 conn_.set_ssl(ssl);
424 conn_.tls.client_session_cache = &addr_->tls_session_cache;
429 SSL_set_tlsext_host_name(conn_.tls.ssl, sni_name.c_str());
434 SSL_set_session(conn_.tls.ssl, session);
438 conn_.prepare_client_handshake();
441 ev_io_set(&conn_.wev, conn_.fd, EV_WRITE);
442 ev_io_set(&conn_.rev, conn_.fd, EV_READ);
444 conn_.wlimit.startw();
446 conn_.wt.repeat = downstreamconf.timeout.connect;
447 ev_timer_again(conn_.loop, &conn_.wt);
450 ev_set_cb(&conn_.rt, timeoutcb);
451 if (conn_.read_timeout < group_->shared_addr->timeout.read) {
452 conn_.read_timeout = group_->shared_addr->timeout.read;
453 conn_.last_read = std::chrono::steady_clock::now();
455 conn_.again_rt(group_->shared_addr->timeout.read);
458 ev_set_cb(&conn_.rev, readcb);
870 ev_set_cb(&conn_.rev, idle_readcb);
875 ev_set_cb(&conn_.rt, idle_timeoutcb);
876 if (conn_.read_timeout < downstreamconf.timeout.idle_read) {
877 conn_.read_timeout = downstreamconf.timeout.idle_read;
878 conn_.last_read = std::chrono::steady_clock::now();
880 conn_.again_rt(downstreamconf.timeout.idle_read);
883 conn_.wlimit.stopw();
884 ev_timer_stop(conn_.loop, &conn_.wt);
1210 if (conn_.tls.ssl) {
1220 if (conn_.tls.ssl) {
1249 conn_.last_read = std::chrono::steady_clock::now();
1255 auto nread = conn_.read_clear(buf.data(), buf.size());
1281 if (!ev_is_active(&conn_.rev)) {
1288 conn_.last_read = std::chrono::steady_clock::now();
1298 auto nwrite = conn_.writev_clear(iov.data(), iovcnt);
1311 ev_feed_event(conn_.loop, &conn_.rev, EV_READ);
1320 conn_.wlimit.stopw();
1321 ev_timer_stop(conn_.loop, &conn_.wt);
1336 conn_.last_read = std::chrono::steady_clock::now();
1338 auto rv = conn_.tls_handshake();
1354 tls::check_cert(conn_.tls.ssl, addr_, raddr_) != 0) {
1366 ev_set_cb(&conn_.rt, timeoutcb);
1367 ev_set_cb(&conn_.wt, timeoutcb);
1378 conn_.last_read = std::chrono::steady_clock::now();
1386 auto nread = conn_.read_tls(buf.data(), buf.size());
1412 if (!ev_is_active(&conn_.rev)) {
1419 conn_.last_read = std::chrono::steady_clock::now();
1434 auto nwrite = conn_.write_tls(iov.iov_base, iov.iov_len);
1447 ev_feed_event(conn_.loop, &conn_.rev, EV_READ);
1456 conn_.wlimit.stopw();
1457 ev_timer_stop(conn_.loop, &conn_.wt);
1543 auto sock_error = util::get_socket_error(conn_.fd);
1545 conn_.wlimit.stopw();
1561 conn_.wt.repeat = group_->shared_addr->timeout.write;
1562 ev_timer_again(conn_.loop, &conn_.wt);
1564 conn_.rlimit.startw();
1565 conn_.again_rt();
1567 ev_set_cb(&conn_.wev, writecb);
1569 if (conn_.tls.ssl) {
1580 ev_set_cb(&conn_.rt, timeoutcb);
1581 ev_set_cb(&conn_.wt, timeoutcb);
1598 ev_feed_event(conn_.loop, &conn_.wev, EV_WRITE);