fixing group instance termination state issue when group scaling happens
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/437c872e Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/437c872e Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/437c872e Branch: refs/heads/master Commit: 437c872edd8d8b4bb18db3b622f1d3f0e24e497a Parents: 217a384 Author: reka <[email protected]> Authored: Mon Jun 22 14:35:46 2015 +0530 Committer: reka <[email protected]> Committed: Mon Jun 22 14:41:12 2015 +0530 ---------------------------------------------------------------------- .../autoscaler/status/processor/group/GroupStatusProcessor.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/437c872e/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/status/processor/group/GroupStatusProcessor.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/status/processor/group/GroupStatusProcessor.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/status/processor/group/GroupStatusProcessor.java index d14bcbd..1d2abc8 100644 --- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/status/processor/group/GroupStatusProcessor.java +++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/status/processor/group/GroupStatusProcessor.java @@ -75,14 +75,13 @@ public abstract class GroupStatusProcessor extends StatusProcessor { if (contexts == null || contexts.isEmpty() && status == GroupStatus.Terminated) { groupStat = true; } else { - int minGroupInstances = group.getGroupMinInstances(); int sameStateInstances = 0; for (Instance context1 : contexts) { if (((GroupInstance) context1).getStatus().equals(status)) { sameStateInstances++; } } - if (sameStateInstances >= minGroupInstances) { + if (sameStateInstances == contexts.size()) { groupStat = true; } else { return false;
