From 498536ddf18ae2b301fc2f8727037cc0e7162a97 Mon Sep 17 00:00:00 2001 From: Vishanth Date: Thu, 9 Apr 2015 12:11:00 +0530 Subject: [PATCH 1/2] Fixing the improvements on cloud controller --- .../parser/DefaultApplicationParser.java | 3 +- .../context/CloudControllerContext.java | 6 +- .../resources/CloudControllerService.wsdl | 368 +++++++++--------- 3 files changed, 189 insertions(+), 188 deletions(-) diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/applications/parser/DefaultApplicationParser.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/applications/parser/DefaultApplicationParser.java index 9ae5f3bbbb..cde9a9792e 100644 --- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/applications/parser/DefaultApplicationParser.java +++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/applications/parser/DefaultApplicationParser.java @@ -58,6 +58,7 @@ public class DefaultApplicationParser implements ApplicationParser { private static final String METADATA_APPENDER = "-"; public static final String ALIAS = "alias"; public static final String CARTRIDGE_TYPE = "type"; + public static final String LOAD_BALANCER = "lb"; private static Log log = LogFactory.getLog(DefaultApplicationParser.class); private List applicationClusterContexts; @@ -438,7 +439,7 @@ private Map> parseLeafLevelSubscriptions( // Find tenant range of cluster String tenantRange = AutoscalerUtil.findTenantRange(tenantId, cartridge.getTenantPartitions()); Boolean isLB = false; - if (cartridge.getCategory().equals("lb")) { + if (cartridge.getCategory().equals(LOAD_BALANCER)) { isLB = true; } // create and collect this cluster's information diff --git a/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/context/CloudControllerContext.java b/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/context/CloudControllerContext.java index 57d729df28..04c76371eb 100644 --- a/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/context/CloudControllerContext.java +++ b/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/context/CloudControllerContext.java @@ -727,16 +727,16 @@ public void addIaasProvider(String cartridgeType, String partitionId, IaasProvid partitionToIaasProviderByCartridge.put(cartridgeType, partitionToIaasProvider); } - public void addIaasProviders(String cartridgeType, Map map) { + public void addIaasProviders(String cartridgeType, Map partitionToIaasProvidersMap) { Map partitionToIaasProviders; if (partitionToIaasProviderByCartridge.get(cartridgeType) != null) { partitionToIaasProviders = partitionToIaasProviderByCartridge.get(cartridgeType); } else { partitionToIaasProviders = new ConcurrentHashMap(); } - for (Iterator iterator = map.keySet().iterator(); iterator.hasNext(); ) { + for (Iterator iterator = partitionToIaasProvidersMap.keySet().iterator(); iterator.hasNext(); ) { String key = iterator.next(); - IaasProvider value = map.get(key); + IaasProvider value = partitionToIaasProvidersMap.get(key); partitionToIaasProviders.put(key, value); } diff --git a/service-stubs/org.apache.stratos.cloud.controller.service.stub/src/main/resources/CloudControllerService.wsdl b/service-stubs/org.apache.stratos.cloud.controller.service.stub/src/main/resources/CloudControllerService.wsdl index 1adf2f339c..c3aa6691aa 100644 --- a/service-stubs/org.apache.stratos.cloud.controller.service.stub/src/main/resources/CloudControllerService.wsdl +++ b/service-stubs/org.apache.stratos.cloud.controller.service.stub/src/main/resources/CloudControllerService.wsdl @@ -1,75 +1,26 @@ - + - + - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - + - - - + - + - + - - - - - - + - + @@ -94,6 +45,13 @@ + + + + + + + @@ -162,6 +120,13 @@ + + + + + + + @@ -321,31 +286,38 @@ - + - + - + - + - + - + - + - + + + + + + + + @@ -370,6 +342,20 @@ + + + + + + + + + + + + + + @@ -413,6 +399,20 @@ + + + + + + + + + + + + + + @@ -636,29 +636,12 @@ - - - - - - - - - - - - - - - - - - + - + @@ -672,6 +655,11 @@ + + + + + @@ -697,6 +685,18 @@ + + + + + + + + + + + + @@ -738,16 +738,31 @@ - + + + + + + + + + + + + + + + + - - - - + + + + @@ -755,13 +770,13 @@ - + - + @@ -775,101 +790,9 @@ - - - - - - - - - - - - - - - - + - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - @@ -945,6 +868,18 @@ + + + + + + + + + + + + @@ -963,6 +898,17 @@ + + + + + + + + + + + @@ -993,6 +939,60 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + From 5bda3ab13ca9fee405059ec569322c2b33f922c4 Mon Sep 17 00:00:00 2001 From: Vishanth Date: Fri, 10 Apr 2015 13:50:41 +0530 Subject: [PATCH 2/2] Throwing Autoscaler exception --- .../stratos/autoscaler/registry/RegistryManager.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/registry/RegistryManager.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/registry/RegistryManager.java index 2fc6d08a6a..a8df794274 100644 --- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/registry/RegistryManager.java +++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/registry/RegistryManager.java @@ -178,9 +178,10 @@ public void persistAutoscalerPolicy(AutoscalePolicy autoscalePolicy) { log.debug(String.format("Autoscaler policy written to registry: [id] %s [name] %s [description] %s", autoscalePolicy.getId(), autoscalePolicy.getDisplayName(), autoscalePolicy.getDescription())); } - } catch (Exception e) { - throw new AutoScalerException((String.format("Unable to persist autoscaler policy [autoscaler-policy-id] %s" - , autoscalePolicy.getId())), e); + } catch (AutoScalerException e) { + String message = "Unable to persist autoscaler policy [autoscaler-policy-id] " + autoscalePolicy.getId(); + log.error(message, e); + throw e; } finally { endTenantFlow(); }