Searched refs:recvq_ (Results 1 – 2 of 2) sorted by relevance
133 clear_request(recvq_); in disconnect()435 if (recvq_.empty()) { in parse_packet()441 auto &req = recvq_.front(); in parse_packet()554 auto req = std::move(recvq_.front()); in parse_packet()555 recvq_.pop_front(); in parse_packet()557 if (sendq_.empty() && recvq_.empty()) { in parse_packet()655 recvq_.push_back(std::move(sendq_.front())); in drain_send_queue()660 if (recvq_.empty()) { in drain_send_queue()732 if (!connected_ || (recvq_.empty() && sendq_.empty())) { in reconnect_or_fail()750 q.reserve(recvq_.size() + sendq_.size()); in reconnect_or_fail()[all …]
136 std::deque<std::unique_ptr<MemcachedRequest>> recvq_; variable