Home
last modified time | relevance | path

Searched refs:connect_blocker (Results 1 – 7 of 7) sorted by relevance

/third_party/nghttp2/src/
Dshrpx_connect_blocker.cc33 auto connect_blocker = static_cast<ConnectBlocker *>(w->data); in connect_blocker_cb() local
38 connect_blocker->call_unblock_func(); in connect_blocker_cb()
Dshrpx_http_downstream_connection.cc313 auto &connect_blocker = addr_->connect_blocker; in initiate_connection() local
315 if (connect_blocker->blocked()) { in initiate_connection()
1360 auto &connect_blocker = addr_->connect_blocker; in tls_handshake() local
1364 connect_blocker->on_success(); in tls_handshake()
1541 auto &connect_blocker = addr_->connect_blocker; in connected() local
1578 connect_blocker->on_success(); in connected()
Dshrpx_worker.cc344 addr.connect_blocker = std::make_unique<ConnectBlocker>( in replace_downstream_config()
1304 const auto &connect_blocker = addr->connect_blocker; in downstream_failure() local
1306 if (connect_blocker->in_offline()) { in downstream_failure()
1310 connect_blocker->on_failure(); in downstream_failure()
1316 auto fail_count = connect_blocker->get_fail_count(); in downstream_failure()
1329 connect_blocker->offline(); in downstream_failure()
Dshrpx_client_handler.cc905 if (addr->connect_blocker->blocked()) { in get_downstream_addr()
912 if (addr->connect_blocker->blocked()) { in get_downstream_addr()
948 if (addr->connect_blocker->blocked()) { in get_downstream_addr()
970 if (!addr->connect_blocker->blocked()) { in get_downstream_addr_strict_affinity()
999 if (addr->connect_blocker->blocked()) { in get_downstream_addr_strict_affinity()
1006 if (addr->connect_blocker->blocked()) { in get_downstream_addr_strict_affinity()
Dshrpx_worker.h100 std::unique_ptr<ConnectBlocker> connect_blocker; member
Dshrpx_http2_session.cc1331 auto &connect_blocker = addr->connect_blocker; in on_frame_recv_callback() local
1333 connect_blocker->on_success(); in on_frame_recv_callback()
Dshrpx_live_check.cc694 addr_->connect_blocker->online(); in on_success()