Home
last modified time | relevance | path

Searched refs:shared_addr (Results 1 - 10 of 10) sorted by relevance

/third_party/nghttp2/src/
H A Dshrpx_worker.cc103 create_downstream_key(const std::shared_ptr<SharedDownstreamAddr> &shared_addr, in create_downstream_key() argument
108 addrs.resize(shared_addr->addrs.size()); in create_downstream_key()
110 for (auto &a : shared_addr->addrs) { in create_downstream_key()
128 std::get<1>(dkey) = shared_addr->redirect_if_not_tls; in create_downstream_key()
130 auto &affinity = shared_addr->affinity; in create_downstream_key()
136 auto &timeout = shared_addr->timeout; in create_downstream_key()
140 std::get<10>(dkey) = shared_addr->dnf; in create_downstream_key()
248 auto &shared_addr = g->shared_addr; in replace_downstream_config() local
249 for (auto &addr : shared_addr in replace_downstream_config()
279 auto shared_addr = std::make_shared<SharedDownstreamAddr>(); replace_downstream_config() local
[all...]
H A Dshrpx_client_handler.cc756 auto &shared_addr = group->shared_addr; in get_http2_session() local
760 << ", index=" << (addr - shared_addr->addrs.data()); in get_http2_session()
865 auto &shared_addr = group->shared_addr; in get_downstream_addr() local
867 if (shared_addr->affinity.type != SessionAffinity::NONE) { in get_downstream_addr()
869 switch (shared_addr->affinity.type) { in get_downstream_addr()
878 if (shared_addr->affinity.cookie.stickiness == in get_downstream_addr()
880 return get_downstream_addr_strict_affinity(err, shared_addr, in get_downstream_addr()
884 hash = get_affinity_cookie(downstream, shared_addr in get_downstream_addr()
960 get_downstream_addr_strict_affinity( int &err, const std::shared_ptr<SharedDownstreamAddr> &shared_addr, Downstream *downstream) get_downstream_addr_strict_affinity() argument
[all...]
H A Dshrpx_http_downstream_connection.cc208 group->shared_addr->timeout.write, group->shared_addr->timeout.read, in HttpDownstreamConnection()
451 if (conn_.read_timeout < group_->shared_addr->timeout.read) { in initiate_connection()
452 conn_.read_timeout = group_->shared_addr->timeout.read; in initiate_connection()
455 conn_.again_rt(group_->shared_addr->timeout.read); in initiate_connection()
1561 conn_.wt.repeat = group_->shared_addr->timeout.write; in connected()
H A Dshrpx_client_handler.h177 int &err, const std::shared_ptr<SharedDownstreamAddr> &shared_addr,
H A Dshrpx_https_upstream.cc524 const auto &dmruby_ctx = group->shared_addr->mruby_ctx; in htp_hdrs_completecb()
1140 const auto &dmruby_ctx = group->shared_addr->mruby_ctx; in on_downstream_header_complete()
1294 auto &shared_addr = group->shared_addr; in on_downstream_header_complete() local
1295 auto &cookieconf = shared_addr->affinity.cookie; in on_downstream_header_complete()
H A Dshrpx_http2_upstream.cc503 const auto &mruby_ctx = group->shared_addr->mruby_ctx; in initiate_downstream()
1678 const auto &dmruby_ctx = group->shared_addr->mruby_ctx; in on_downstream_header_complete()
1799 auto &shared_addr = group->shared_addr; in on_downstream_header_complete() local
1800 auto &cookieconf = shared_addr->affinity.cookie; in on_downstream_header_complete()
H A Dshrpx_worker.h252 std::shared_ptr<SharedDownstreamAddr> shared_addr; member
254 // true, the connection made using one of address in shared_addr
H A Dshrpx_downstream.cc200 const auto &mruby_ctx = group->shared_addr->mruby_ctx; in ~Downstream()
244 const auto &mruby_ctx = group->shared_addr->mruby_ctx; in detach_downstream_connection()
269 const auto &mruby_ctx = group->shared_addr->mruby_ctx; in pop_downstream_connection()
H A Dshrpx_http3_upstream.cc1295 const auto &dmruby_ctx = group->shared_addr->mruby_ctx; in on_downstream_header_complete()
1387 auto &shared_addr = group->shared_addr; in on_downstream_header_complete() local
1388 auto &cookieconf = shared_addr->affinity.cookie; in on_downstream_header_complete()
2383 const auto &mruby_ctx = group->shared_addr->mruby_ctx; in initiate_downstream()
H A Dshrpx_http2_session.cc188 group->shared_addr->timeout.write, group->shared_addr->timeout.read, in Http2Session()
1992 conn_.wt.repeat = group_->shared_addr->timeout.write; in connected()

Completed in 19 milliseconds