Lines Matching defs:std
154 std::array<iovec, 2> iov;
359 auto nread = std::min(left_connhd_len_, rb_.rleft());
388 auto nread = std::min(left_connhd_len_, rb_.rleft());
516 p = std::copy(std::begin(ipaddr), std::end(ipaddr), p);
537 upstream_ = std::make_unique<HttpsUpstream>(this);
548 std::unique_ptr<Http3Upstream> &&upstream) {
549 upstream_ = std::move(upstream);
656 auto http2_upstream = std::make_unique<Http2Upstream>(this);
658 upstream_ = std::move(http2_upstream);
672 upstream_ = std::make_unique<HttpsUpstream>(this);
716 std::unique_ptr<DownstreamConnection> dconn) {
732 dconn_pool->add_downstream_connection(std::move(dconn));
739 std::array<uint8_t, 32> buf;
755 const std::shared_ptr<DownstreamAddrGroup> &group, DownstreamAddr *addr) {
814 auto d = std::uniform_int_distribution<uint32_t>(1);
826 std::priority_queue<DownstreamAddrEntry, std::vector<DownstreamAddrEntry>,
840 std::priority_queue<WeightGroupEntry, std::vector<WeightGroupEntry>,
892 auto it = std::lower_bound(
893 std::begin(affinity_hash), std::end(affinity_hash), hash,
896 if (it == std::end(affinity_hash)) {
897 it = std::begin(affinity_hash);
901 static_cast<size_t>(std::distance(std::begin(affinity_hash), it));
961 int &err, const std::shared_ptr<SharedDownstreamAddr> &shared_addr,
968 if (it != std::end(shared_addr->affinity_hash_map)) {
975 auto d = std::uniform_int_distribution<uint32_t>(1);
986 auto it = std::lower_bound(
987 std::begin(affinity_hash), std::end(affinity_hash), h,
990 if (it == std::end(affinity_hash)) {
991 it = std::begin(affinity_hash);
995 static_cast<size_t>(std::distance(std::begin(affinity_hash), it));
1022 std::unique_ptr<DownstreamConnection>
1037 auto dconn = std::make_unique<APIDownstreamConnection>(worker_);
1042 auto dconn = std::make_unique<HealthMonitorDownstreamConnection>();
1109 auto dconn = std::make_unique<NullDownstreamConnection>(group);
1139 dconn = std::make_unique<HttpDownstreamConnection>(group, addr, conn_.loop,
1151 auto dconn = std::make_unique<Http2DownstreamConnection>(http2session);
1161 upstream_ = std::make_unique<Http2Upstream>(this);
1168 auto upstream = std::make_unique<Http2Upstream>(this);
1200 upstream_ = std::move(upstream);
1227 lgconf->update_tstamp(std::chrono::system_clock::now());
1239 std::chrono::high_resolution_clock::now(), // request_end_time
1338 auto chrs = std::array<char, 2>{'\n', '\0'};
1342 auto bufend = rb_.pos() + std::min(MAX_PROXY_LINELEN, rb_.rleft());
1345 std::find_first_of(rb_.pos(), bufend, std::begin(chrs), std::end(chrs));
1426 auto token_end = std::find(rb_.pos(), end, ' ');
1448 token_end = std::find(rb_.pos(), end, ' ');
1565 std::array<char, std::max(INET_ADDRSTRLEN, INET6_ADDRSTRLEN)> src_addr,