You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by re...@apache.org on 2015/06/21 20:45:07 UTC

[2/3] stratos git commit: Handling scale down when having one instance

Handling scale down when having one instance


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

Branch: refs/heads/master
Commit: 966a4371000c0ca593b9184b1bd41f85ce129f42
Parents: c919c66
Author: reka <rt...@gmail.com>
Authored: Fri Jun 19 19:37:24 2015 +0530
Committer: reka <rt...@gmail.com>
Committed: Mon Jun 22 00:09:51 2015 +0530

----------------------------------------------------------------------
 .../stratos/modules/distribution/src/main/conf/drools/scaling.drl | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/stratos/blob/966a4371/products/stratos/modules/distribution/src/main/conf/drools/scaling.drl
----------------------------------------------------------------------
diff --git a/products/stratos/modules/distribution/src/main/conf/drools/scaling.drl b/products/stratos/modules/distribution/src/main/conf/drools/scaling.drl
index 07da870..b9258e7 100644
--- a/products/stratos/modules/distribution/src/main/conf/drools/scaling.drl
+++ b/products/stratos/modules/distribution/src/main/conf/drools/scaling.drl
@@ -106,7 +106,8 @@ dialect "mvel"
 
 
         scaleUp : Boolean() from (activeInstancesCount < numberOfRequiredInstances)
-        scaleDown : Boolean() from (activeInstancesCount > numberOfRequiredInstances)
+        scaleDown : Boolean() from (activeInstancesCount > numberOfRequiredInstances || (numberOfRequiredInstances == 1 && activeInstancesCount == 1))
+
 
         eval(log.debug("[scaling] " + "[cluster] " + clusterId + " RIF Resetted?: " + rifReset))
         eval(log.debug("[scaling] " + "[cluster] " + clusterId + " RIF predicted value: " + rifPredictedValue))