Repository: incubator-stratos Updated Branches: refs/heads/master eed199ba1 -> 5db10fe85
chekcing for responding memebers in the unsusbcription Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/5db10fe8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/5db10fe8 Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/5db10fe8 Branch: refs/heads/master Commit: 5db10fe856dde93b11e84adf56dcb6215f2b3fba Parents: eed199b Author: rekathiru <[email protected]> Authored: Fri Feb 21 18:57:41 2014 +0530 Committer: rekathiru <[email protected]> Committed: Fri Feb 21 18:57:41 2014 +0530 ---------------------------------------------------------------------- .../cloud/controller/impl/CloudControllerServiceImpl.java | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/5db10fe8/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/impl/CloudControllerServiceImpl.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/impl/CloudControllerServiceImpl.java b/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/impl/CloudControllerServiceImpl.java index ae37667..3b86525 100644 --- a/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/impl/CloudControllerServiceImpl.java +++ b/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/impl/CloudControllerServiceImpl.java @@ -1036,7 +1036,15 @@ public class CloudControllerServiceImpl implements CloudControllerService { } Collection<Member> members = TopologyManager.getTopology(). getService(ctxt.getCartridgeType()).getCluster(clusterId_).getMembers(); - long endTime = System.currentTimeMillis() + ctxt.getTimeoutInMillis() * members.size(); + //finding the responding members from the existing members in the topology. + int sizeOfRespondingMembers = 0; + for(Member member : members) { + if(member.getStatus().getCode() >= MemberStatus.Activated.getCode()) { + sizeOfRespondingMembers ++; + } + } + + long endTime = System.currentTimeMillis() + ctxt.getTimeoutInMillis() * sizeOfRespondingMembers; while(System.currentTimeMillis()< endTime) { CloudControllerUtil.sleep(1000);
