setting network partition id in LBClusterMonitor
Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/6be7c93a Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/6be7c93a Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/6be7c93a Branch: refs/heads/master Commit: 6be7c93a80224a121566ec1abf700589fc044af6 Parents: 151ddd0 Author: Nirmal Fernando <[email protected]> Authored: Sun Dec 15 00:34:03 2013 +0530 Committer: Nirmal Fernando <[email protected]> Committed: Sun Dec 15 00:34:03 2013 +0530 ---------------------------------------------------------------------- .../autoscaler/client/cloud/controller/CloudControllerClient.java | 3 ++- .../java/org/apache/stratos/autoscaler/util/AutoscalerUtil.java | 1 + 2 files changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/6be7c93a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/client/cloud/controller/CloudControllerClient.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/client/cloud/controller/CloudControllerClient.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/client/cloud/controller/CloudControllerClient.java index b690f91..904b38d 100644 --- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/client/cloud/controller/CloudControllerClient.java +++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/client/cloud/controller/CloudControllerClient.java @@ -127,7 +127,8 @@ public class CloudControllerClient { member.setInitTime(System.currentTimeMillis()); member.setNetworkPartitionId(networkPartitionId); - log.info("Trying to spawn an instance of [cluster] "+clusterId+" [partition] "+partition.getId()+ " [lb cluster] "+lbClusterId); + log.info("Trying to spawn an instance of [cluster] "+clusterId+" [partition] "+partition.getId()+ + " [lb cluster] "+lbClusterId+" [Network Partition Id] "+networkPartitionId); return stub.startInstance(member); } catch (CloudControllerServiceIllegalArgumentExceptionException e) { log.error(e.getMessage()); http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/6be7c93a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/util/AutoscalerUtil.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/util/AutoscalerUtil.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/util/AutoscalerUtil.java index 4bfa271..b3358af 100644 --- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/util/AutoscalerUtil.java +++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/util/AutoscalerUtil.java @@ -208,6 +208,7 @@ public class AutoscalerUtil { PartitionContext partitionContext = new PartitionContext(partition); partitionContext.setServiceName(cluster.getServiceName()); partitionContext.setProperties(cluster.getProperties()); + partitionContext.setNetworkPartitionId(partitionGroup.getId()); for (Member member : cluster.getMembers()) { String memberId = member.getMemberId();
