Lines Matching defs:MemcachedConnection
44 auto mconn = static_cast<MemcachedConnection *>(conn->data);
61 auto mconn = static_cast<MemcachedConnection *>(conn->data);
73 auto mconn = static_cast<MemcachedConnection *>(conn->data);
85 auto mconn = static_cast<MemcachedConnection *>(conn->data);
99 MemcachedConnection::MemcachedConnection(const Address *addr,
106 do_read_(&MemcachedConnection::noop),
107 do_write_(&MemcachedConnection::noop),
118 MemcachedConnection::~MemcachedConnection() { conn_.disconnect(); }
132 void MemcachedConnection::disconnect() {
148 do_read_ = do_write_ = &MemcachedConnection::noop;
151 int MemcachedConnection::initiate_connection() {
213 int MemcachedConnection::connected() {
238 do_read_ = &MemcachedConnection::tls_handshake;
239 do_write_ = &MemcachedConnection::tls_handshake;
250 do_read_ = &MemcachedConnection::read_clear;
251 do_write_ = &MemcachedConnection::write_clear;
256 int MemcachedConnection::on_write() { return do_write_(*this); }
257 int MemcachedConnection::on_read() { return do_read_(*this); }
259 int MemcachedConnection::tls_handshake() {
293 do_read_ = &MemcachedConnection::read_tls;
294 do_write_ = &MemcachedConnection::write_tls;
299 int MemcachedConnection::write_tls() {
338 int MemcachedConnection::read_tls() {
366 int MemcachedConnection::write_clear() {
394 int MemcachedConnection::read_clear() {
422 int MemcachedConnection::parse_packet() {
591 size_t MemcachedConnection::fill_request_buffer(struct iovec *iov,
633 void MemcachedConnection::drain_send_queue(size_t nwrite) {
667 size_t MemcachedConnection::serialized_size(MemcachedRequest *req) {
677 void MemcachedConnection::make_request(MemcachedSendbuf *sendbuf,
705 int MemcachedConnection::add_request(std::unique_ptr<MemcachedRequest> req) {
727 void MemcachedConnection::signal_write() { conn_.wlimit.startw(); }
729 int MemcachedConnection::noop() { return 0; }
731 void MemcachedConnection::reconnect_or_fail() {