nghttpx: Check worker wide blocker before creating new downstream con…

…nection
orbea · Sep 19, 2020 · 7b4de40 · 7b4de40
1 parent 1570d5f
commit 7b4de40
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/src/shrpx_client_handler.cc b/src/shrpx_client_handler.cc
@@ -985,6 +985,14 @@ ClientHandler::get_downstream_connection(int &err, Downstream *downstream) {
       return dconn;
     }
 
+    if (worker_->get_connect_blocker()->blocked()) {
+      if (LOG_ENABLED(INFO)) {
+        DCLOG(INFO, this)
+            << "Worker wide backend connection was blocked temporarily";
+      }
+      return nullptr;
+    }
+
     if (LOG_ENABLED(INFO)) {
       CLOG(INFO, this) << "Downstream connection pool is empty."
                        << " Create new one";