You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by ni...@apache.org on 2013/12/14 20:07:18 UTC

[3/5] git commit: setting network partition id in LBClusterMonitor

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 <ni...@apache.org>
Authored: Sun Dec 15 00:34:03 2013 +0530
Committer: Nirmal Fernando <ni...@apache.org>
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();