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/22 11:13:08 UTC
[2/2] stratos git commit: fixing group instance termination state
issue when group scaling happens
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 <rt...@gmail.com>
Authored: Mon Jun 22 14:35:46 2015 +0530
Committer: reka <rt...@gmail.com>
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;