Lines Matching defs:addr
201 &session_cacheconf.memcached.addr, loop,
213 WeightGroup *wg, DownstreamAddr *addr) {
222 addr->cycle = cycle;
223 addr->pending_penalty = 0;
224 wg->pq.push(DownstreamAddrEntry{addr, addr->seq, addr->cycle});
225 addr->queued = true;
249 for (auto &addr : shared_addr->addrs) {
250 addr.dconn_pool->remove_all();
304 dst_addr.addr = src_addr.addr;
343 for (auto &addr : shared_addr->addrs) {
344 addr.connect_blocker = std::make_unique<ConnectBlocker>(
345 randgen_, loop_, nullptr, [shared_addr_ptr, &addr]() {
346 if (!addr.queued) {
347 if (!addr.wg) {
350 ensure_enqueue_addr(shared_addr_ptr->pq, addr.wg, &addr);
354 addr.live_check = std::make_unique<LiveCheck>(loop_, cl_ssl_ctx_, this,
355 &addr, randgen_);
359 for (auto &addr : shared_addr->addrs) {
360 addr.dconn_pool = std::make_unique<DownstreamConnectionPool>();
361 addr.seq = seq++;
371 for (auto &addr : shared_addr->addrs) {
372 if (wgs.find(addr.group) == std::end(wgs)) {
374 wgs.emplace(addr.group, nullptr);
380 for (auto &addr : shared_addr->addrs) {
381 auto &wg = wgs[addr.group];
387 wg->weight = addr.group_weight;
388 wg->pq.push(DownstreamAddrEntry{&addr, addr.seq, addr.cycle});
389 addr.queued = true;
390 addr.wg = wg;
709 for (auto &addr : quic_upstream_addrs_) {
710 assert(!addr.host_unix);
711 if (create_quic_server_socket(addr) != 0) {
719 if (addr.hostport == a.hostport) {
722 << addr.hostport;
730 quic_listeners_.emplace_back(std::make_unique<QUICListener>(&addr, this));
1303 void downstream_failure(DownstreamAddr *addr, const Address *raddr) {
1304 const auto &connect_blocker = addr->connect_blocker;
1312 if (addr->fall == 0) {
1318 if (fail_count >= addr->fall) {
1324 LOG(WARN) << "Could not connect to " << addr->host << ":" << addr->port
1331 if (addr->rise) {
1332 addr->live_check->schedule();