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_worker.cc281 dst_addr.connect_blocker = std::make_unique<ConnectBlocker>( in replace_downstream_config()
717 const auto &connect_blocker = addr->connect_blocker; in downstream_failure() local
719 if (connect_blocker->in_offline()) { in downstream_failure()
723 connect_blocker->on_failure(); in downstream_failure()
729 auto fail_count = connect_blocker->get_fail_count(); in downstream_failure()
742 connect_blocker->offline(); in downstream_failure()
Dshrpx_http_downstream_connection.cc298 auto &connect_blocker = addr_->connect_blocker; in initiate_connection() local
300 if (connect_blocker->blocked()) { in initiate_connection()
1304 auto &connect_blocker = addr_->connect_blocker; in tls_handshake() local
1308 connect_blocker->on_success(); in tls_handshake()
1473 auto &connect_blocker = addr_->connect_blocker; in connected() local
1510 connect_blocker->on_success(); in connected()
Dshrpx_worker.h93 std::unique_ptr<ConnectBlocker> connect_blocker; member
Dshrpx_client_handler.cc835 if (addr->connect_blocker->blocked()) { in get_downstream_addr()
842 if (addr->connect_blocker->blocked()) { in get_downstream_addr()
879 if (addr->connect_blocker->blocked()) { in get_downstream_addr()
Dshrpx_http2_session.cc1318 auto &connect_blocker = addr->connect_blocker; in on_frame_recv_callback() local
1320 connect_blocker->on_success(); in on_frame_recv_callback()
Dshrpx_live_check.cc694 addr_->connect_blocker->online(); in on_success()