You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by ra...@apache.org on 2014/10/24 14:17:06 UTC

git commit: consider RIF in scaling containers

Repository: stratos
Updated Branches:
  refs/heads/master 5dd637493 -> 8caae55b1


consider RIF in scaling containers


Project: http://git-wip-us.apache.org/repos/asf/stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/8caae55b
Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/8caae55b
Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/8caae55b

Branch: refs/heads/master
Commit: 8caae55b1fc77c506787cfba99c489824584dcb9
Parents: 5dd6374
Author: R-Rajkumar <rr...@gmail.com>
Authored: Fri Oct 24 17:46:42 2014 +0530
Committer: R-Rajkumar <rr...@gmail.com>
Committed: Fri Oct 24 17:46:42 2014 +0530

----------------------------------------------------------------------
 .../distribution/src/main/conf/drools/container-scaling.drl  | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/stratos/blob/8caae55b/products/stratos/modules/distribution/src/main/conf/drools/container-scaling.drl
----------------------------------------------------------------------
diff --git a/products/stratos/modules/distribution/src/main/conf/drools/container-scaling.drl b/products/stratos/modules/distribution/src/main/conf/drools/container-scaling.drl
index c5d4272..a1c5712 100644
--- a/products/stratos/modules/distribution/src/main/conf/drools/container-scaling.drl
+++ b/products/stratos/modules/distribution/src/main/conf/drools/container-scaling.drl
@@ -73,7 +73,7 @@ dialect "mvel"
         scaleUpForMc : Boolean() from (mcReset && (mcPredictedValue > mcUpperLimit))
         scaleUpForLa : Boolean() from (laReset && (laPredictedValue > laUpperLimit))
 
-	scaleDownForRif : Boolean() from (rifPredictedValue < rifUpperLimit)
+	scaleDownForRif : Boolean() from (rifReset && (rifPredictedValue < rifUpperLimit))
         scaleDownForMc : Boolean() from (mcReset && (mcPredictedValue < mcUpperLimit)) 
         scaleDownForLa : Boolean() from (laReset && (laPredictedValue < laUpperLimit))
 
@@ -86,9 +86,9 @@ dialect "mvel"
 	eval(log.info("[scaling] " + " [cluster] : " + clusterId + " [Replicas] activeReplicas : " + activeReplicas))
 
         eval(log.debug("[scaling] " + " [cluster] : " + clusterId + " [RequestInFlight] resetted ? : " + rifReset))
-        eval(log.debug("[scaling] " + " [cluster] : " + clusterId + " [RequestInFlight] predicted value : " + rifPredictedValue))
-        eval(log.debug("[scaling] " + " [cluster] : " + clusterId + " [RequestInFlight] upper limit : " + rifUpperLimit))
-        eval(log.debug("[scaling] " + " [cluster] : " + clusterId + " [RequestInFlight] lower limit : " + rifLowerLimit))
+        eval(log.info("[scaling] " + " [cluster] : " + clusterId + " [RequestInFlight] predicted value : " + rifPredictedValue))
+        eval(log.info("[scaling] " + " [cluster] : " + clusterId + " [RequestInFlight] upper limit : " + rifUpperLimit))
+        eval(log.info("[scaling] " + " [cluster] : " + clusterId + " [RequestInFlight] lower limit : " + rifLowerLimit))
 
 	eval(log.debug("[scaling] " + " [cluster] : " + clusterId + " [MemoryConsumption] resetted ? : " + mcReset))
         eval(log.info("[scaling] " + " [cluster] : " + clusterId + " [MemoryConsumption] predicted value : " + mcPredictedValue))