Repository: stratos Updated Branches: refs/heads/master 217a3845b -> 4f5a671ca
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/4f5a671c Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/4f5a671c Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/4f5a671c Branch: refs/heads/master Commit: 4f5a671ca2757823e7e65f9db5d42d00f16811cb Parents: 437c872 Author: reka <[email protected]> Authored: Mon Jun 22 14:40:34 2015 +0530 Committer: reka <[email protected]> Committed: Mon Jun 22 14:41:12 2015 +0530 ---------------------------------------------------------------------- .../status/processor/group/GroupStatusProcessor.java | 12 ++++-------- 1 file changed, 4 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/4f5a671c/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 1d2abc8..e4ae474 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,17 +75,13 @@ public abstract class GroupStatusProcessor extends StatusProcessor { if (contexts == null || contexts.isEmpty() && status == GroupStatus.Terminated) { groupStat = true; } else { - int sameStateInstances = 0; for (Instance context1 : contexts) { - if (((GroupInstance) context1).getStatus().equals(status)) { - sameStateInstances++; + if (!((GroupInstance) context1).getStatus().equals(status)) { + return false; + } else { + groupStat = true; } } - if (sameStateInstances == contexts.size()) { - groupStat = true; - } else { - return false; - } } } }
