syncronous inflightRequest calc

restify · Mar 14, 2019 · b889324 · b889324
1 parent 7db83a5
commit b889324
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/lib/server.js b/lib/server.js
@@ -217,12 +217,14 @@ function Server(options) {
             return;
         }
 
+        self._inflightRequests++;
         if (!options.noWriteContinue) {
             res.writeContinue();
         }
 
         self.earliestChain.run(req, res, function earliestDone(ignore) {
             if (ignore === false || Boolean(ignore)) {
+                self._inflightRequests--;
                 return;
             }
             self._onRequest(req, res);
@@ -231,10 +233,12 @@ function Server(options) {
 
     if (options.handleUpgrades) {
         this.server.on('upgrade', function onUpgrade(req, socket, head) {
+            self._inflightRequests++;
             var res = upgrade.createResponse(req, socket, head);
             req._upgradeRequest = true;
             self.earliestChain.run(req, res, function earliestDone(ignore) {
                 if (ignore === false || Boolean(ignore)) {
+                    self._inflightRequests--;
                     return;
                 }
                 self._onRequest(req, res);
@@ -243,8 +247,10 @@ function Server(options) {
     }
 
     this.server.on('request', function onRequest(req, res) {
+        self._inflightRequests++;
         self.earliestChain.run(req, res, function earliestDone(ignore) {
             if (ignore === false || Boolean(ignore)) {
+                self._inflightRequests--;
                 return;
             }
 
@@ -897,9 +903,6 @@ Server.prototype._onRequest = function _onRequest(req, res) {
     // Decorate req and res objects
     self._setupRequest(req, res);
 
-    // increment number of requests
-    self._inflightRequests++;
-
     // Run in domain to catch async errors
     // It has significant negative performance impact
     // Warning: this feature depends on the deprecated domains module