Updated ActivationThrottler to compute limit and compare against totalInflightActivations in cluster

common/scala/src/main/scala/org/apache/openwhisk/http/ErrorResponse.scala

@@ -72,7 +72,7 @@ object Messages {
 
   /** Standard message for too many concurrent activation requests within a time window. */
   def tooManyConcurrentRequests(count: Int, allowed: Int) =
-    s"Too many concurrent requests in flight (currently running: $count, allowed per controller: $allowed)."
+    s"Too many concurrent requests in flight (count: $count, allowed: $allowed)."
 
   /** System overload message. */
   val systemOverloaded = "System is overloaded, try again later."

core/controller/src/main/scala/org/apache/openwhisk/core/entitlement/ActivationThrottler.scala

@@ -39,12 +39,12 @@ class ActivationThrottler(loadBalancer: LoadBalancer, concurrencyLimit: Identity
    * Checks whether the operation should be allowed to proceed.
    */
   def check(user: Identity)(implicit tid: TransactionId): Future[RateLimit] = {
-    loadBalancer.activeActivationsFor(user.namespace.uuid).map { concurrentActivations =>
-      val currentLimit = concurrencyLimit(user)
+    loadBalancer.totalActiveActivations.map { totalInflightActivations =>
+      val currentLimit = concurrencyLimit(user) * loadBalancer.clusterSize
       logging.debug(
         this,
-        s"namespace = ${user.namespace.uuid.asString}, concurrent activations = $concurrentActivations, below limit = $currentLimit")
-      ConcurrentRateLimit(concurrentActivations, currentLimit)
+        s"namespace = ${user.namespace.uuid.asString}, total inflight activations = $totalInflightActivations, limit = $currentLimit")
+      ConcurrentRateLimit(totalInflightActivations, currentLimit)
     }
   }
 }

tests/src/test/scala/limits/ThrottleTests.scala

@@ -467,7 +467,7 @@ class NamespaceSpecificThrottleTests
     }
 
     wsk.action.invoke(actionName, expectedExitCode = TooManyRequests.intValue).stderr should {
-      include(prefix(tooManyConcurrentRequests(0, 0))) and include("allowed per controller: 0")
+      include(prefix(tooManyConcurrentRequests(0, 0))) and include("allowed: 0")
     }
   }