Home
last modified time | relevance | path

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

/third_party/nghttp2/src/
Dshrpx_connect_blocker.cc33 auto connect_blocker = static_cast<ConnectBlocker *>(w->data); in connect_blocker_cb()
42 ConnectBlocker::ConnectBlocker(std::mt19937 &gen, struct ev_loop *loop, in ConnectBlocker() function in shrpx::ConnectBlocker
55 ConnectBlocker::~ConnectBlocker() { ev_timer_stop(loop_, &timer_); } in ~ConnectBlocker()
57 bool ConnectBlocker::blocked() const { return ev_is_active(&timer_); } in blocked()
59 void ConnectBlocker::on_success() { in on_success()
75 void ConnectBlocker::on_failure() { in on_failure()
101 size_t ConnectBlocker::get_fail_count() const { return fail_count_; } in get_fail_count()
103 void ConnectBlocker::offline() { in offline()
119 void ConnectBlocker::online() { in online()
129 bool ConnectBlocker::in_offline() const { return offline_; } in in_offline()
[all …]
Dshrpx_connect_blocker.h37 class ConnectBlocker {
39 ConnectBlocker(std::mt19937 &gen, struct ev_loop *loop,
42 ~ConnectBlocker();
Dshrpx_worker.h60 class ConnectBlocker; variable
93 std::unique_ptr<ConnectBlocker> connect_blocker;
311 ConnectBlocker *get_connect_blocker() const;
357 std::unique_ptr<ConnectBlocker> connect_blocker_;
Dshrpx_memcached_connection.h142 ConnectBlocker connect_blocker_;
Dshrpx_client_handler.h49 class ConnectBlocker; variable
Dshrpx_connection_handler.h58 class ConnectBlocker; variable
Dshrpx_worker.cc146 std::make_unique<ConnectBlocker>(randgen_, loop_, nullptr, nullptr)),
281 dst_addr.connect_blocker = std::make_unique<ConnectBlocker>( in replace_downstream_config()
565 ConnectBlocker *Worker::get_connect_blocker() const { in get_connect_blocker()
Dshrpx_config.h64 class ConnectBlocker; variable