You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by ra...@apache.org on 2015/02/27 15:47:01 UTC
[38/50] [abbrv] stratos git commit: Fixing member context not found
issues, STRATOS-1110
Fixing member context not found issues, STRATOS-1110
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/dd8b2d17
Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/dd8b2d17
Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/dd8b2d17
Branch: refs/heads/master-deployment-policy-fix-merge
Commit: dd8b2d173ae894cf608722c613af510ed2b562f3
Parents: d0ea5d8
Author: Lahiru Sandaruwan <la...@apache.org>
Authored: Thu Feb 26 18:59:09 2015 +0530
Committer: R-Rajkumar <rr...@gmail.com>
Committed: Fri Feb 27 19:42:44 2015 +0530
----------------------------------------------------------------------
.../impl/CloudControllerServiceImpl.java | 44 --------------------
1 file changed, 44 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/stratos/blob/dd8b2d17/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/services/impl/CloudControllerServiceImpl.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/services/impl/CloudControllerServiceImpl.java b/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/services/impl/CloudControllerServiceImpl.java
index 5518aaa..3f17439 100644
--- a/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/services/impl/CloudControllerServiceImpl.java
+++ b/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/services/impl/CloudControllerServiceImpl.java
@@ -583,11 +583,6 @@ public class CloudControllerServiceImpl implements CloudControllerService {
if (cluster != null) {
Member member = cluster.getMember(memberId);
if (member != null) {
- // change member status if termination on a faulty member
- if (fixMemberStatus(member, topology)) {
- // set the time this member was added to ReadyToShutdown status
- memberContext.setObsoleteInitTime(System.currentTimeMillis());
- }
// check if ready to shutdown member is expired and send
// member terminated if it is.
@@ -643,45 +638,6 @@ public class CloudControllerServiceImpl implements CloudControllerService {
return false;
}
-
- /**
- * Corrects the member status upon termination call if the member is in an Active state
- *
- * @param member The {@link org.apache.stratos.messaging.domain.topology.Member} object that is being
- * checked for status
- * @param topology The {@link org.apache.stratos.messaging.domain.topology.Topology} object to update
- * the topology if needed.
- */
- private boolean fixMemberStatus(Member member, Topology topology) {
- if (member.getStatus() == MemberStatus.Active) {
- MemberReadyToShutdownEvent memberReadyToShutdownEvent = new MemberReadyToShutdownEvent(
- member.getServiceName(),
- member.getClusterId(),
- member.getClusterInstanceId(), member.getMemberId(),
- member.getNetworkPartitionId(),
- member.getPartitionId());
-
- member.setStatus(MemberStatus.ReadyToShutDown);
- log.info("Member Ready to shut down event adding status started");
-
- TopologyManager.updateTopology(topology);
-
- TopologyEventPublisher.sendMemberReadyToShutdownEvent(memberReadyToShutdownEvent);
- //publishing data
- StatisticsDataPublisher.publish(member.getMemberId(),
- member.getPartitionId(),
- member.getNetworkPartitionId(),
- member.getClusterId(),
- member.getServiceName(),
- MemberStatus.ReadyToShutDown.toString(),
- null);
-
- return true;
- }
-
- return false;
- }
-
@Override
public void terminateInstances(String clusterId) throws InvalidClusterException {