Home
last modified time | relevance | path

Searched refs:shared_addr (Results 1 – 8 of 8) sorted by relevance

/third_party/nghttp2/src/
Dshrpx_worker.cc89 create_downstream_key(const std::shared_ptr<SharedDownstreamAddr> &shared_addr, in create_downstream_key() argument
94 addrs.resize(shared_addr->addrs.size()); in create_downstream_key()
96 for (auto &a : shared_addr->addrs) { in create_downstream_key()
114 std::get<1>(dkey) = shared_addr->redirect_if_not_tls; in create_downstream_key()
116 auto &affinity = shared_addr->affinity; in create_downstream_key()
121 auto &timeout = shared_addr->timeout; in create_downstream_key()
209 auto &shared_addr = g->shared_addr; in replace_downstream_config() local
210 for (auto &addr : shared_addr->addrs) { in replace_downstream_config()
240 auto shared_addr = std::make_shared<SharedDownstreamAddr>(); in replace_downstream_config() local
242 shared_addr->addrs.resize(src.addrs.size()); in replace_downstream_config()
[all …]
Dshrpx_client_handler.cc691 auto &shared_addr = group->shared_addr; in get_http2_session() local
695 << ", index=" << (addr - shared_addr->addrs.data()); in get_http2_session()
801 auto &shared_addr = group->shared_addr; in get_downstream_addr() local
803 if (shared_addr->affinity.type != SessionAffinity::NONE) { in get_downstream_addr()
805 switch (shared_addr->affinity.type) { in get_downstream_addr()
814 hash = get_affinity_cookie(downstream, shared_addr->affinity.cookie.name); in get_downstream_addr()
820 const auto &affinity_hash = shared_addr->affinity_hash; in get_downstream_addr()
833 auto addr = &shared_addr->addrs[idx]; in get_downstream_addr()
838 if (i == shared_addr->affinity_hash.size()) { in get_downstream_addr()
841 addr = &shared_addr->addrs[shared_addr->affinity_hash[i].idx]; in get_downstream_addr()
[all …]
Dshrpx_http_downstream_connection.cc206 group->shared_addr->timeout.write, group->shared_addr->timeout.read, in HttpDownstreamConnection()
436 if (conn_.read_timeout < group_->shared_addr->timeout.read) { in initiate_connection()
437 conn_.read_timeout = group_->shared_addr->timeout.read; in initiate_connection()
440 conn_.again_rt(group_->shared_addr->timeout.read); in initiate_connection()
1493 conn_.wt.repeat = group_->shared_addr->timeout.write; in connected()
Dshrpx_https_upstream.cc484 const auto &dmruby_ctx = group->shared_addr->mruby_ctx; in htp_hdrs_completecb()
1090 const auto &dmruby_ctx = group->shared_addr->mruby_ctx; in on_downstream_header_complete()
1250 auto &shared_addr = group->shared_addr; in on_downstream_header_complete() local
1251 auto &cookieconf = shared_addr->affinity.cookie; in on_downstream_header_complete()
Dshrpx_worker.h236 std::shared_ptr<SharedDownstreamAddr> shared_addr; member
Dshrpx_downstream.cc196 const auto &mruby_ctx = group->shared_addr->mruby_ctx; in ~Downstream()
234 const auto &mruby_ctx = group->shared_addr->mruby_ctx; in detach_downstream_connection()
259 const auto &mruby_ctx = group->shared_addr->mruby_ctx; in pop_downstream_connection()
Dshrpx_http2_upstream.cc495 const auto &mruby_ctx = group->shared_addr->mruby_ctx; in initiate_downstream()
1668 const auto &dmruby_ctx = group->shared_addr->mruby_ctx; in on_downstream_header_complete()
1789 auto &shared_addr = group->shared_addr; in on_downstream_header_complete() local
1790 auto &cookieconf = shared_addr->affinity.cookie; in on_downstream_header_complete()
Dshrpx_http2_session.cc188 group->shared_addr->timeout.write, group->shared_addr->timeout.read, in Http2Session()
1976 conn_.wt.repeat = group_->shared_addr->timeout.write; in connected()