Lines Matching refs:conn_
104 : conn_(loop, -1, nullptr, mcpool, write_timeout, read_timeout, {}, {},
118 MemcachedConnection::~MemcachedConnection() { conn_.disconnect(); }
143 conn_.disconnect();
152 assert(conn_.fd == -1);
159 conn_.set_ssl(ssl);
160 conn_.tls.client_session_cache = &tls_session_cache_;
163 conn_.fd = util::create_nonblock_socket(addr_->su.storage.ss_family);
165 if (conn_.fd == -1) {
173 rv = connect(conn_.fd, &addr_->su.sa, addr_->len);
178 close(conn_.fd);
179 conn_.fd = -1;
186 SSL_set_tlsext_host_name(conn_.tls.ssl, sni_name_.c_str());
191 SSL_set_session(conn_.tls.ssl, session);
195 conn_.prepare_client_handshake();
202 ev_io_set(&conn_.wev, conn_.fd, EV_WRITE);
203 ev_io_set(&conn_.rev, conn_.fd, EV_READ);
205 ev_set_cb(&conn_.wev, connectcb);
207 conn_.wlimit.startw();
208 ev_timer_again(conn_.loop, &conn_.wt);
214 auto sock_error = util::get_socket_error(conn_.fd);
222 conn_.wlimit.stopw();
231 conn_.rlimit.startw();
233 ev_set_cb(&conn_.wev, writecb);
235 if (conn_.tls.ssl) {
236 conn_.again_rt();
244 ev_timer_stop(conn_.loop, &conn_.wt);
262 conn_.last_read = std::chrono::steady_clock::now();
264 auto rv = conn_.tls_handshake();
281 tls::check_cert(conn_.tls.ssl, addr_, sni_name_) != 0) {
286 ev_timer_stop(conn_.loop, &conn_.rt);
287 ev_timer_stop(conn_.loop, &conn_.wt);
304 conn_.last_read = std::chrono::steady_clock::now();
321 auto nwrite = conn_.write_tls(buf.data(), p - std::begin(buf));
332 conn_.wlimit.stopw();
333 ev_timer_stop(conn_.loop, &conn_.wt);
343 conn_.last_read = std::chrono::steady_clock::now();
346 auto nread = conn_.read_tls(recvbuf_.last, recvbuf_.wleft());
371 conn_.last_read = std::chrono::steady_clock::now();
377 auto nwrite = conn_.writev_clear(iov.data(), iovcnt);
388 conn_.wlimit.stopw();
389 ev_timer_stop(conn_.loop, &conn_.wt);
399 conn_.last_read = std::chrono::steady_clock::now();
402 auto nread = conn_.read_clear(recvbuf_.last, recvbuf_.wleft());
558 ev_timer_stop(conn_.loop, &conn_.rt);
661 ev_timer_stop(conn_.loop, &conn_.rt);
662 } else if (!ev_is_active(&conn_.rt)) {
663 conn_.again_rt();
717 if (conn_.fd == -1 && initiate_connection() != 0) {
727 void MemcachedConnection::signal_write() { conn_.wlimit.startw(); }