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/05/14 09:51:59 UTC
[3/3] stratos git commit: fixing cluster termination only when all
the members are removed from the topology
fixing cluster termination only when all the members are removed from the topology
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/8b433aa0
Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/8b433aa0
Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/8b433aa0
Branch: refs/heads/master
Commit: 8b433aa08c06ed925487c3c87e07da056d035854
Parents: 60bdd2f
Author: reka <rt...@gmail.com>
Authored: Thu May 14 13:02:28 2015 +0530
Committer: reka <rt...@gmail.com>
Committed: Thu May 14 13:21:45 2015 +0530
----------------------------------------------------------------------
.../processor/cluster/ClusterStatusTerminatedProcessor.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/stratos/blob/8b433aa0/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/status/processor/cluster/ClusterStatusTerminatedProcessor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/status/processor/cluster/ClusterStatusTerminatedProcessor.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/status/processor/cluster/ClusterStatusTerminatedProcessor.java
index f56a29a..4462888 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/status/processor/cluster/ClusterStatusTerminatedProcessor.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/status/processor/cluster/ClusterStatusTerminatedProcessor.java
@@ -128,7 +128,8 @@ public class ClusterStatusTerminatedProcessor extends ClusterStatusProcessor {
if (clusterInstanceContext != null) {
for (ClusterLevelPartitionContext partitionContext :
clusterInstanceContext.getPartitionCtxts()) {
- if (partitionContext.getNonTerminatedMemberCount() > 0) {
+ if (partitionContext.getTotalMemberCount() > 0 ||
+ partitionContext.getObsoletedMembers().values().size() > 0) {
return true;
}
}