Lines Matching refs:std
103 std::mt19937 &gen)
121 void clear_request(std::deque<std::unique_ptr<MemcachedRequest>> &q) {
262 conn_.last_read = std::chrono::steady_clock::now();
304 conn_.last_read = std::chrono::steady_clock::now();
306 std::array<struct iovec, MAX_WR_IOVCNT> iov;
307 std::array<uint8_t, 16_k> buf;
311 auto p = std::begin(buf);
314 auto n = std::min(static_cast<size_t>(std::end(buf) - p), v.iov_len);
315 p = std::copy_n(static_cast<uint8_t *>(v.iov_base), n, p);
316 if (p == std::end(buf)) {
321 auto nwrite = conn_.write_tls(buf.data(), p - std::begin(buf));
343 conn_.last_read = std::chrono::steady_clock::now();
371 conn_.last_read = std::chrono::steady_clock::now();
373 std::array<struct iovec, MAX_WR_IOVCNT> iov;
399 conn_.last_read = std::chrono::steady_clock::now();
514 auto n = std::min(static_cast<size_t>(recvbuf_.last - in),
532 auto n = std::min(static_cast<size_t>(recvbuf_.last - in),
535 parse_state_.value.insert(std::end(parse_state_.value), in, in + n);
554 auto req = std::move(recvq_.front());
563 std::move(parse_state_.value)));
644 auto n = std::min(static_cast<size_t>(nwrite), buf.headbuf.rleft());
647 n = std::min(static_cast<size_t>(nwrite), buf.send_value_left);
655 recvq_.push_back(std::move(sendq_.front()));
681 std::fill(std::begin(headbuf.buf), std::end(headbuf.buf), 0);
705 int MemcachedConnection::add_request(std::unique_ptr<MemcachedRequest> req) {
710 sendq_.push_back(std::move(req));
749 std::vector<std::unique_ptr<MemcachedRequest>> q;
757 q.insert(std::end(q), std::make_move_iterator(std::begin(recvq_)),
758 std::make_move_iterator(std::end(recvq_)));
759 q.insert(std::end(q), std::make_move_iterator(std::begin(sendq_)),
760 std::make_move_iterator(std::end(sendq_)));
767 sendq_.insert(std::end(sendq_), std::make_move_iterator(std::begin(q)),
768 std::make_move_iterator(std::end(q)));