You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by la...@apache.org on 2015/04/07 07:53:57 UTC
[4/7] stratos git commit: Format autoscaler component code
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/cartridge/NonExistingLBException.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/cartridge/NonExistingLBException.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/cartridge/NonExistingLBException.java
index d571e09..fe2cfdd 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/cartridge/NonExistingLBException.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/cartridge/NonExistingLBException.java
@@ -22,7 +22,7 @@ public class NonExistingLBException extends Exception {
private static final long serialVersionUID = -9163807860189126883L;
private String message;
-
+
public NonExistingLBException(final String message, final Exception exception) {
super(message, exception);
@@ -43,12 +43,12 @@ public class NonExistingLBException extends Exception {
}
- public String getMessage() {
- return message;
- }
+ public String getMessage() {
+ return message;
+ }
- public void setMessage(String message) {
- this.message = message;
- }
+ public void setMessage(String message) {
+ this.message = message;
+ }
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/cartridge/SpawningException.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/cartridge/SpawningException.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/cartridge/SpawningException.java
index e3ad0fc..a6d2695 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/cartridge/SpawningException.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/cartridge/SpawningException.java
@@ -29,23 +29,23 @@ public class SpawningException extends Exception {
private static final long serialVersionUID = 4761501174753405374L;
private String message;
- public SpawningException(String message, Exception exception){
+ public SpawningException(String message, Exception exception) {
super(message, exception);
this.setMessage(message);
}
- public SpawningException(Exception exception){
+ public SpawningException(Exception exception) {
super(exception);
}
- public String getMessage() {
- return message;
- }
+ public String getMessage() {
+ return message;
+ }
- public void setMessage(String message) {
- this.message = message;
- }
+ public void setMessage(String message) {
+ this.message = message;
+ }
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/cartridge/TerminationException.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/cartridge/TerminationException.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/cartridge/TerminationException.java
index cfb9501..18f80ba 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/cartridge/TerminationException.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/cartridge/TerminationException.java
@@ -23,23 +23,23 @@ package org.apache.stratos.autoscaler.exception.cartridge;
public class TerminationException extends Throwable {
- private static final long serialVersionUID = -6038793010380236971L;
- private String message;
-
- public TerminationException(String s, Exception e) {
+ private static final long serialVersionUID = -6038793010380236971L;
+ private String message;
+
+ public TerminationException(String s, Exception e) {
super(s, e);
this.setMessage(s);
}
-
+
public TerminationException(Exception e) {
super(e);
}
- public String getMessage() {
- return message;
- }
+ public String getMessage() {
+ return message;
+ }
- public void setMessage(String message) {
- this.message = message;
- }
+ public void setMessage(String message) {
+ this.message = message;
+ }
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/partition/InvalidPartitionException.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/partition/InvalidPartitionException.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/partition/InvalidPartitionException.java
index 0acc9e9..0bfa81e 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/partition/InvalidPartitionException.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/partition/InvalidPartitionException.java
@@ -29,21 +29,21 @@ public class InvalidPartitionException extends Exception {
private static final long serialVersionUID = -7521673271244696906L;
private String message;
- public InvalidPartitionException(String message, Exception exception){
+ public InvalidPartitionException(String message, Exception exception) {
super(message, exception);
this.message = message;
}
- public InvalidPartitionException(Exception exception){
+ public InvalidPartitionException(Exception exception) {
super(exception);
}
-
- public InvalidPartitionException(String msg){
+
+ public InvalidPartitionException(String msg) {
super(msg);
this.message = msg;
}
-
+
@Override
public String getMessage() {
return this.message;
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/partition/PartitionValidationException.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/partition/PartitionValidationException.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/partition/PartitionValidationException.java
index ae36f34..abeed4a 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/partition/PartitionValidationException.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/partition/PartitionValidationException.java
@@ -26,29 +26,30 @@ package org.apache.stratos.autoscaler.exception.partition;
*/
public class PartitionValidationException extends Exception {
- private static final long serialVersionUID = -3904452358279522141L;
- private String message;
+ private static final long serialVersionUID = -3904452358279522141L;
+ private String message;
- public PartitionValidationException(String message, Exception exception){
+ public PartitionValidationException(String message, Exception exception) {
super(message, exception);
this.setMessage(message);
}
- public PartitionValidationException(String msg) {
- super(msg);
- this.message = msg;
- }
- public PartitionValidationException(Exception exception){
+ public PartitionValidationException(String msg) {
+ super(msg);
+ this.message = msg;
+ }
+
+ public PartitionValidationException(Exception exception) {
super(exception);
}
- public String getMessage() {
- return message;
- }
+ public String getMessage() {
+ return message;
+ }
- public void setMessage(String message) {
- this.message = message;
- }
+ public void setMessage(String message) {
+ this.message = message;
+ }
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/policy/ApplicatioinPolicyNotExistsException.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/policy/ApplicatioinPolicyNotExistsException.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/policy/ApplicatioinPolicyNotExistsException.java
index d8ffc21..ea64a4c 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/policy/ApplicatioinPolicyNotExistsException.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/policy/ApplicatioinPolicyNotExistsException.java
@@ -21,26 +21,26 @@ package org.apache.stratos.autoscaler.exception.policy;
public class ApplicatioinPolicyNotExistsException extends Exception {
- private static final long serialVersionUID = -4326762495239318515L;
- private String message;
-
- public ApplicatioinPolicyNotExistsException(String message) {
- super(message);
- this.message = message;
- }
-
- public ApplicatioinPolicyNotExistsException(String message,Throwable e) {
- super(message,e);
- this.message = message;
- }
-
- public ApplicatioinPolicyNotExistsException(Throwable e) {
- super(e);
- }
-
- @Override
- public String getMessage() {
- return message;
- }
-
+ private static final long serialVersionUID = -4326762495239318515L;
+ private String message;
+
+ public ApplicatioinPolicyNotExistsException(String message) {
+ super(message);
+ this.message = message;
+ }
+
+ public ApplicatioinPolicyNotExistsException(String message, Throwable e) {
+ super(message, e);
+ this.message = message;
+ }
+
+ public ApplicatioinPolicyNotExistsException(Throwable e) {
+ super(e);
+ }
+
+ @Override
+ public String getMessage() {
+ return message;
+ }
+
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/policy/InvalidDeploymentPolicyException.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/policy/InvalidDeploymentPolicyException.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/policy/InvalidDeploymentPolicyException.java
index fb865bc..a6c2dce 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/policy/InvalidDeploymentPolicyException.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/policy/InvalidDeploymentPolicyException.java
@@ -18,9 +18,9 @@
*/
package org.apache.stratos.autoscaler.exception.policy;
-public class InvalidDeploymentPolicyException extends Exception{
-
- public InvalidDeploymentPolicyException(String message) {
- super(message);
- }
+public class InvalidDeploymentPolicyException extends Exception {
+
+ public InvalidDeploymentPolicyException(String message) {
+ super(message);
+ }
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/policy/InvalidPolicyException.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/policy/InvalidPolicyException.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/policy/InvalidPolicyException.java
index c8d4494..32b6348 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/policy/InvalidPolicyException.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/policy/InvalidPolicyException.java
@@ -21,26 +21,26 @@ package org.apache.stratos.autoscaler.exception.policy;
public class InvalidPolicyException extends Exception {
- private static final long serialVersionUID = -4914522749282514366L;
- private String message;
-
- public InvalidPolicyException(String message) {
- super(message);
- this.message = message;
- }
-
- public InvalidPolicyException(String message,Throwable e) {
- super(message,e);
- this.message = message;
- }
-
- public InvalidPolicyException(Throwable e) {
- super(e);
- }
-
- @Override
- public String getMessage() {
- return message;
- }
-
+ private static final long serialVersionUID = -4914522749282514366L;
+ private String message;
+
+ public InvalidPolicyException(String message) {
+ super(message);
+ this.message = message;
+ }
+
+ public InvalidPolicyException(String message, Throwable e) {
+ super(message, e);
+ this.message = message;
+ }
+
+ public InvalidPolicyException(Throwable e) {
+ super(e);
+ }
+
+ @Override
+ public String getMessage() {
+ return message;
+ }
+
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/policy/PolicyValidationException.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/policy/PolicyValidationException.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/policy/PolicyValidationException.java
index c3a5fbe..47317bf 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/policy/PolicyValidationException.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/exception/policy/PolicyValidationException.java
@@ -29,28 +29,28 @@ public class PolicyValidationException extends Exception {
private static final long serialVersionUID = -7423800138697480115L;
private String message;
- public PolicyValidationException(String message, Exception exception){
+ public PolicyValidationException(String message, Exception exception) {
super(message, exception);
this.setMessage(message);
}
- public PolicyValidationException(Exception exception){
+ public PolicyValidationException(Exception exception) {
super(exception);
}
-
- public PolicyValidationException(String msg){
+
+ public PolicyValidationException(String msg) {
super(msg);
this.setMessage(msg);
}
- public String getMessage() {
- return message;
- }
+ public String getMessage() {
+ return message;
+ }
- public void setMessage(String message) {
- this.message = message;
- }
+ public void setMessage(String message) {
+ this.message = message;
+ }
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/internal/ASBundleActivater.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/internal/ASBundleActivater.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/internal/ASBundleActivater.java
index a336201..0ae2a61 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/internal/ASBundleActivater.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/internal/ASBundleActivater.java
@@ -23,19 +23,19 @@ import org.apache.commons.logging.LogFactory;
import org.osgi.framework.BundleActivator;
import org.osgi.framework.BundleContext;
-public class ASBundleActivater implements BundleActivator{
+public class ASBundleActivater implements BundleActivator {
private static final Log log = LogFactory.getLog(ASBundleActivater.class);
-
+
@Override
- public void start(BundleContext context) throws Exception {
- if(log.isDebugEnabled())
- log.debug("AutoScaler bundle is activated.");
+ public void start(BundleContext context) throws Exception {
+ if (log.isDebugEnabled())
+ log.debug("AutoScaler bundle is activated.");
}
- @Override
- public void stop(BundleContext context) throws Exception {
- if(log.isDebugEnabled())
- log.debug("AutoScaler bundle is deActivated.");
- }
+ @Override
+ public void stop(BundleContext context) throws Exception {
+ if (log.isDebugEnabled())
+ log.debug("AutoScaler bundle is deActivated.");
+ }
}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/internal/AutoscalerServiceComponent.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/internal/AutoscalerServiceComponent.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/internal/AutoscalerServiceComponent.java
index a1c038e..d1c4c7c 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/internal/AutoscalerServiceComponent.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/internal/AutoscalerServiceComponent.java
@@ -58,32 +58,32 @@ import java.util.concurrent.TimeUnit;
/**
* @scr.component name=org.apache.stratos.autoscaler.internal.AutoscalerServiceComponent" immediate="true"
* @scr.reference name="registry.service" interface="org.wso2.carbon.registry.core.service.RegistryService"
- * cardinality="1..1" policy="dynamic" bind="setRegistryService" unbind="unsetRegistryService"
+ * cardinality="1..1" policy="dynamic" bind="setRegistryService" unbind="unsetRegistryService"
* @scr.reference name="ntask.component" interface="org.wso2.carbon.ntask.core.service.TaskService"
- * cardinality="1..1" policy="dynamic" bind="setTaskService" unbind="unsetTaskService"
+ * cardinality="1..1" policy="dynamic" bind="setTaskService" unbind="unsetTaskService"
* @scr.reference name="hazelcast.instance.service" interface="com.hazelcast.core.HazelcastInstance"
- * cardinality="0..1"policy="dynamic" bind="setHazelcastInstance" unbind="unsetHazelcastInstance"
+ * cardinality="0..1"policy="dynamic" bind="setHazelcastInstance" unbind="unsetHazelcastInstance"
* @scr.reference name="distributedObjectProvider" interface="org.apache.stratos.common.services.DistributedObjectProvider"
- * cardinality="1..1" policy="dynamic" bind="setDistributedObjectProvider" unbind="unsetDistributedObjectProvider"
+ * cardinality="1..1" policy="dynamic" bind="setDistributedObjectProvider" unbind="unsetDistributedObjectProvider"
* @scr.reference name="componentStartUpSynchronizer" interface="org.apache.stratos.common.services.ComponentStartUpSynchronizer"
- * cardinality="1..1" policy="dynamic" bind="setComponentStartUpSynchronizer" unbind="unsetComponentStartUpSynchronizer"
+ * cardinality="1..1" policy="dynamic" bind="setComponentStartUpSynchronizer" unbind="unsetComponentStartUpSynchronizer"
* @scr.reference name="config.context.service" interface="org.wso2.carbon.utils.ConfigurationContextService"
- * cardinality="1..1" policy="dynamic" bind="setConfigurationContextService" unbind="unsetConfigurationContextService"
+ * cardinality="1..1" policy="dynamic" bind="setConfigurationContextService" unbind="unsetConfigurationContextService"
*/
public class AutoscalerServiceComponent {
private static final Log log = LogFactory.getLog(AutoscalerServiceComponent.class);
- private static final String AUTOSCALER_COORDINATOR_LOCK = "AUTOSCALER_COORDINATOR_LOCK";
+ private static final String AUTOSCALER_COORDINATOR_LOCK = "AUTOSCALER_COORDINATOR_LOCK";
- private AutoscalerTopologyEventReceiver asTopologyReceiver;
- private AutoscalerHealthStatEventReceiver autoscalerHealthStatEventReceiver;
- private ExecutorService executorService;
+ private AutoscalerTopologyEventReceiver asTopologyReceiver;
+ private AutoscalerHealthStatEventReceiver autoscalerHealthStatEventReceiver;
+ private ExecutorService executorService;
private ScheduledExecutorService scheduler;
- protected void activate(ComponentContext componentContext) throws Exception {
- try {
+ protected void activate(ComponentContext componentContext) throws Exception {
+ try {
XMLConfiguration conf = ConfUtil.getInstance(AutoscalerConstants.COMPONENTS_CONFIG).getConfiguration();
int threadPoolSize = conf.getInt(AutoscalerConstants.THREAD_POOL_SIZE_KEY,
AutoscalerConstants.AUTOSCALER_THREAD_POOL_SIZE);
@@ -144,29 +144,29 @@ public class AutoscalerServiceComponent {
};
Thread autoscalerActivatorThread = new Thread(autoscalerActivator);
autoscalerActivatorThread.start();
- } catch (Exception e) {
- log.error("Error in activating autoscaler service component ", e);
- }
- }
-
- private void executeCoordinatorTasks() throws InvalidPolicyException {
-
- // Start topology receiver
- asTopologyReceiver = new AutoscalerTopologyEventReceiver();
- asTopologyReceiver.setExecutorService(executorService);
- asTopologyReceiver.execute();
-
- if (log.isDebugEnabled()) {
- log.debug("Topology receiver executor service started");
- }
-
- // Start health stat receiver
- autoscalerHealthStatEventReceiver = new AutoscalerHealthStatEventReceiver();
- autoscalerHealthStatEventReceiver.setExecutorService(executorService);
- autoscalerHealthStatEventReceiver.execute();
- if (log.isDebugEnabled()) {
- log.debug("Health statistics receiver thread started");
- }
+ } catch (Exception e) {
+ log.error("Error in activating autoscaler service component ", e);
+ }
+ }
+
+ private void executeCoordinatorTasks() throws InvalidPolicyException {
+
+ // Start topology receiver
+ asTopologyReceiver = new AutoscalerTopologyEventReceiver();
+ asTopologyReceiver.setExecutorService(executorService);
+ asTopologyReceiver.execute();
+
+ if (log.isDebugEnabled()) {
+ log.debug("Topology receiver executor service started");
+ }
+
+ // Start health stat receiver
+ autoscalerHealthStatEventReceiver = new AutoscalerHealthStatEventReceiver();
+ autoscalerHealthStatEventReceiver.setExecutorService(executorService);
+ autoscalerHealthStatEventReceiver.execute();
+ if (log.isDebugEnabled()) {
+ log.debug("Health statistics receiver thread started");
+ }
// Add AS policies to information model
List<AutoscalePolicy> asPolicies = RegistryManager.getInstance().retrieveASPolicies();
@@ -175,7 +175,7 @@ public class AutoscalerServiceComponent {
AutoscalePolicy asPolicy = asPolicyIterator.next();
PolicyManager.getInstance().addASPolicyToInformationModel(asPolicy);
}
-
+
// Add application policies to information model
List<ApplicationPolicy> applicationPolicies = RegistryManager.getInstance().retrieveApplicationPolicies();
Iterator<ApplicationPolicy> applicationPolicyIterator = applicationPolicies.iterator();
@@ -183,7 +183,7 @@ public class AutoscalerServiceComponent {
ApplicationPolicy applicationPolicy = applicationPolicyIterator.next();
PolicyManager.getInstance().addApplicationPolicyToInformationModel(applicationPolicy);
}
-
+
// Add application policies to information model
List<NetworkPartitionAlgorithmContext> networkPartitionAlgorithmContexts = RegistryManager.getInstance().retrieveNetworkPartitionAlgorithmContexts();
Iterator<NetworkPartitionAlgorithmContext> networkPartitionAlgoCtxtIterator = networkPartitionAlgorithmContexts.iterator();
@@ -191,33 +191,33 @@ public class AutoscalerServiceComponent {
NetworkPartitionAlgorithmContext algorithmContext = networkPartitionAlgoCtxtIterator.next();
AutoscalerContext.getInstance().addNetworkPartitionAlgorithmContext(algorithmContext);
}
-
- //starting the processor chain
- ClusterStatusProcessorChain clusterStatusProcessorChain = new ClusterStatusProcessorChain();
- ServiceReferenceHolder.getInstance().setClusterStatusProcessorChain(clusterStatusProcessorChain);
- GroupStatusProcessorChain groupStatusProcessorChain = new GroupStatusProcessorChain();
- ServiceReferenceHolder.getInstance().setGroupStatusProcessorChain(groupStatusProcessorChain);
+ //starting the processor chain
+ ClusterStatusProcessorChain clusterStatusProcessorChain = new ClusterStatusProcessorChain();
+ ServiceReferenceHolder.getInstance().setClusterStatusProcessorChain(clusterStatusProcessorChain);
- if (log.isInfoEnabled()) {
- log.info("Scheduling tasks to publish applications");
- }
+ GroupStatusProcessorChain groupStatusProcessorChain = new GroupStatusProcessorChain();
+ ServiceReferenceHolder.getInstance().setGroupStatusProcessorChain(groupStatusProcessorChain);
+
+ if (log.isInfoEnabled()) {
+ log.info("Scheduling tasks to publish applications");
+ }
ComponentStartUpSynchronizer componentStartUpSynchronizer =
ServiceReferenceHolder.getInstance().getComponentStartUpSynchronizer();
componentStartUpSynchronizer.addEventListener(new ComponentActivationEventListener() {
@Override
public void activated(Component component) {
- if(component == Component.StratosManager) {
+ if (component == Component.StratosManager) {
Runnable applicationSynchronizer = new ApplicationEventSynchronizer();
scheduler.scheduleAtFixedRate(applicationSynchronizer, 0, 1, TimeUnit.MINUTES);
}
}
});
- }
+ }
protected void deactivate(ComponentContext context) {
- if(asTopologyReceiver != null) {
+ if (asTopologyReceiver != null) {
try {
asTopologyReceiver.terminate();
} catch (Exception e) {
@@ -225,7 +225,7 @@ public class AutoscalerServiceComponent {
}
}
- if(autoscalerHealthStatEventReceiver != null) {
+ if (autoscalerHealthStatEventReceiver != null) {
try {
autoscalerHealthStatEventReceiver.terminate();
} catch (Exception e) {
@@ -254,14 +254,14 @@ public class AutoscalerServiceComponent {
private void shutdownExecutorService(String executorServiceId) {
ExecutorService executorService = StratosThreadPool.getExecutorService(executorServiceId, 1);
- if(executorService != null) {
+ if (executorService != null) {
shutdownExecutorService(executorService);
}
}
private void shutdownScheduledExecutorService(String executorServiceId) {
ExecutorService executorService = StratosThreadPool.getScheduledExecutorService(executorServiceId, 1);
- if(executorService != null) {
+ if (executorService != null) {
shutdownExecutorService(executorService);
}
}
@@ -307,7 +307,7 @@ public class AutoscalerServiceComponent {
}
ServiceReferenceHolder.getInstance().setTaskService(null);
}
-
+
protected void setConfigurationContextService(ConfigurationContextService cfgCtxService) {
ServiceReferenceHolder.getInstance().setAxisConfiguration(
cfgCtxService.getServerConfigContext().getAxisConfiguration());
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/Monitor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/Monitor.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/Monitor.java
index 0930547..d13ae4c 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/Monitor.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/Monitor.java
@@ -31,7 +31,7 @@ import java.util.Map;
*/
public abstract class Monitor implements EventHandler {
- public enum MonitorType { Application, Group, Cluster }
+ public enum MonitorType {Application, Group, Cluster}
//Id of the monitor, cluster=clusterId, group=group-alias, application=app-alias
protected String id;
@@ -63,6 +63,7 @@ public abstract class Monitor implements EventHandler {
/**
* Return the type of the monitor.
+ *
* @return
*/
public abstract MonitorType getMonitorType();
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/MonitorFactory.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/MonitorFactory.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/MonitorFactory.java
index b4c83b7..12340d7 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/MonitorFactory.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/MonitorFactory.java
@@ -106,7 +106,7 @@ public class MonitorFactory {
TopologyInConsistentException {
GroupMonitor groupMonitor;
Application application = ApplicationHolder.getApplications().getApplication(appId);
- if(application == null) {
+ if (application == null) {
throw new RuntimeException("Application not found: [application-id] " + appId);
}
@@ -114,7 +114,7 @@ public class MonitorFactory {
//acquiring read lock to create the monitor
ApplicationHolder.acquireReadLock();
Group group = application.getGroupRecursively(context.getId());
- if(group == null) {
+ if (group == null) {
throw new RuntimeException("Group not found: [group-alias] " + context.getId());
}
@@ -239,13 +239,13 @@ public class MonitorFactory {
try {
Topology topology = TopologyManager.getTopology();
Service service = topology.getService(serviceName);
- if(service == null) {
+ if (service == null) {
String msg = String.format("Service not found in topology: [service] %s", serviceName);
throw new RuntimeException(msg);
}
cluster = service.getCluster(clusterId);
- if(cluster == null) {
+ if (cluster == null) {
String msg = String.format("Cluster not found in topology: [service] %s [cluster] %s",
serviceName, clusterId);
throw new RuntimeException(msg);
@@ -286,7 +286,7 @@ public class MonitorFactory {
// deployment policy validation ends
boolean hasScalingDependents = false;
- if(parentMonitor.getScalingDependencies() != null) {
+ if (parentMonitor.getScalingDependencies() != null) {
for (ScalingDependentList scalingDependentList : parentMonitor.getScalingDependencies()) {
if (scalingDependentList.getScalingDependentListComponents().contains(clusterId)) {
hasScalingDependents = true;
@@ -337,7 +337,7 @@ public class MonitorFactory {
org.apache.stratos.cloud.controller.stub.domain.Partition[] ccPartitions
= new org.apache.stratos.cloud.controller.stub.domain.Partition[partitions.length];
- for(int i = 0; i < partitions.length; i++){
+ for (int i = 0; i < partitions.length; i++) {
org.apache.stratos.cloud.controller.stub.domain.Partition ccPartition
= new org.apache.stratos.cloud.controller.stub.domain.Partition();
ccPartition.setId(partitions[i].getId());
@@ -348,7 +348,7 @@ public class MonitorFactory {
ccPartition.setProvider(partitions[i].getProvider());
ccPartitions[i] = ccPartition;
}
- return ccPartitions;
+ return ccPartitions;
}
// private static org.apache.stratos.cloud.controller.stub.Properties convertPropertiesToCCProperties(
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/cluster/ClusterMonitor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/cluster/ClusterMonitor.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/cluster/ClusterMonitor.java
index 8fd5ec8..9c18530 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/cluster/ClusterMonitor.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/cluster/ClusterMonitor.java
@@ -1301,8 +1301,8 @@ public class ClusterMonitor extends Monitor implements Runnable {
//FIXME to traverse concurrent
// active members
- if(AutoscalerContext.getInstance().getAppMonitor(getAppId()).isForce()){
- log.info(String.format("Terminating all remaining members of partition [partition-id] %s [application-id] %s" , partitionContext.getPartitionId(), getAppId()));
+ if (AutoscalerContext.getInstance().getAppMonitor(getAppId()).isForce()) {
+ log.info(String.format("Terminating all remaining members of partition [partition-id] %s [application-id] %s", partitionContext.getPartitionId(), getAppId()));
partitionContext.terminateAllRemainingInstances();
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/component/ApplicationMonitor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/component/ApplicationMonitor.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/component/ApplicationMonitor.java
index 98abf8c..59b4d5f 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/component/ApplicationMonitor.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/component/ApplicationMonitor.java
@@ -107,7 +107,7 @@ public class ApplicationMonitor extends ParentComponentMonitor {
@Override
public void run() {
if (log.isDebugEnabled()) {
- log.debug("Application monitor is running for [application] " + appId );
+ log.debug("Application monitor is running for [application] " + appId);
}
for (NetworkPartitionContext networkPartitionContext : networkPartitionContexts) {
@@ -119,14 +119,14 @@ public class ApplicationMonitor extends ParentComponentMonitor {
if (instance.getStatus().getCode() <= GroupStatus.Active.getCode()) {
//Gives priority to scaling max out rather than dependency scaling
if (!instanceContext.getIdToScalingOverMaxEvent().isEmpty()) {
- //handling the scaling max out of the children
+ //handling the scaling max out of the children
handleScalingMaxOut(instanceContext, networkPartitionContext);
- } else if(!instanceContext.getIdToScalingEvent().isEmpty()) {
+ } else if (!instanceContext.getIdToScalingEvent().isEmpty()) {
//handling the dependent scaling for application
handleDependentScaling(instanceContext, networkPartitionContext);
- } else if(!instanceContext.getIdToScalingDownBeyondMinEvent().isEmpty()) {
+ } else if (!instanceContext.getIdToScalingDownBeyondMinEvent().isEmpty()) {
//handling the scale down of the application
handleScalingDownBeyondMin(instanceContext, networkPartitionContext);
}
@@ -319,40 +319,40 @@ public class ApplicationMonitor extends ParentComponentMonitor {
ApplicationPolicy applicationPolicy = PolicyManager.getInstance().getApplicationPolicy(application.getApplicationPolicyId());
if (applicationPolicy == null) {
- String msg = String.format("Application policy not found in registry or in-memory [application-id] %s", appId);
- log.error(msg);
- throw new RuntimeException(msg);
- }
-
+ String msg = String.format("Application policy not found in registry or in-memory [application-id] %s", appId);
+ log.error(msg);
+ throw new RuntimeException(msg);
+ }
+
NetworkPartitionAlgorithmContext algorithmContext = AutoscalerContext.getInstance().getNetworkPartitionAlgorithmContext(appId);
if (algorithmContext == null) {
- String msg = String.format("Network partition algorithm context not found in registry or in-memory [application-id] %s", appId);
- log.error(msg);
- throw new RuntimeException(msg);
- }
-
+ String msg = String.format("Network partition algorithm context not found in registry or in-memory [application-id] %s", appId);
+ log.error(msg);
+ throw new RuntimeException(msg);
+ }
+
String networkPartitionAlgorithmName = applicationPolicy.getAlgorithm();
if (log.isDebugEnabled()) {
- String msg = String.format("Network partition algorithm is %s [application-id] %s", networkPartitionAlgorithmName, appId);
- log.debug(msg);
- }
-
+ String msg = String.format("Network partition algorithm is %s [application-id] %s", networkPartitionAlgorithmName, appId);
+ log.debug(msg);
+ }
+
NetworkPartitionAlgorithm algorithm = getNetworkPartitionAlgorithm(networkPartitionAlgorithmName);
if (algorithm == null) {
- String msg = String.format("Coudln't create network partition algorithm [application-id] %s", appId);
- log.error(msg);
- throw new RuntimeException(msg);
- }
-
+ String msg = String.format("Coudln't create network partition algorithm [application-id] %s", appId);
+ log.error(msg);
+ throw new RuntimeException(msg);
+ }
+
List<String> nextNetworkPartitions = algorithm.getNextNetworkPartitions(algorithmContext);
if (nextNetworkPartitions == null || nextNetworkPartitions.isEmpty()) {
- String msg = String.format("No network partitions available for application bursting [application-id] %s", appId);
- log.warn(msg);
- return false;
- }
-
+ String msg = String.format("No network partitions available for application bursting [application-id] %s", appId);
+ log.warn(msg);
+ return false;
+ }
+
for (String networkPartitionIds : nextNetworkPartitions) {
- ApplicationLevelNetworkPartitionContext context =
+ ApplicationLevelNetworkPartitionContext context =
new ApplicationLevelNetworkPartitionContext(networkPartitionIds);
//If application instances found in the ApplicationsTopology,
// then have to add them first before creating new one
@@ -369,9 +369,9 @@ public class ApplicationMonitor extends ParentComponentMonitor {
}
instanceIds.add(instanceId);
log.info("Application instance has been added for the [network partition] " +
- networkPartitionIds + " [appInstanceId] " + instanceId);
- }
-
+ networkPartitionIds + " [appInstanceId] " + instanceId);
+ }
+
startDependency(application, instanceIds);
return initialStartup;
}
@@ -408,50 +408,50 @@ public class ApplicationMonitor extends ParentComponentMonitor {
public void handleApplicationBursting() throws TopologyInConsistentException,
PolicyValidationException,
MonitorNotFoundException {
-
+
Application application = ApplicationHolder.getApplications().getApplication(appId);
if (application == null) {
String msg = "Application cannot be found in the Topology.";
throw new TopologyInConsistentException(msg);
}
-
+
boolean burstNPFound = false;
String instanceId = null;
-
+
ApplicationPolicy applicationPolicy = PolicyManager.getInstance().getApplicationPolicy(application.getApplicationPolicyId());
if (applicationPolicy == null) {
- String msg = String.format("Application policy not found in registry or in-memory [application-id] %s", appId);
- log.error(msg);
- throw new RuntimeException(msg);
- }
-
+ String msg = String.format("Application policy not found in registry or in-memory [application-id] %s", appId);
+ log.error(msg);
+ throw new RuntimeException(msg);
+ }
+
NetworkPartitionAlgorithmContext algorithmContext = AutoscalerContext.getInstance().getNetworkPartitionAlgorithmContext(appId);
if (algorithmContext == null) {
- String msg = String.format("Network partition algorithm context not found in registry or in-memory [application-id] %s", appId);
- log.error(msg);
- throw new RuntimeException(msg);
- }
-
+ String msg = String.format("Network partition algorithm context not found in registry or in-memory [application-id] %s", appId);
+ log.error(msg);
+ throw new RuntimeException(msg);
+ }
+
String networkPartitionAlgorithmName = applicationPolicy.getAlgorithm();
if (log.isDebugEnabled()) {
- String msg = String.format("Network partition algorithm is %s [application-id] %s", networkPartitionAlgorithmName, appId);
- log.debug(msg);
- }
-
+ String msg = String.format("Network partition algorithm is %s [application-id] %s", networkPartitionAlgorithmName, appId);
+ log.debug(msg);
+ }
+
NetworkPartitionAlgorithm algorithm = getNetworkPartitionAlgorithm(networkPartitionAlgorithmName);
if (algorithm == null) {
- String msg = String.format("Coudln't create network partition algorithm [application-id] %s", appId);
- log.error(msg);
- throw new RuntimeException(msg);
- }
-
+ String msg = String.format("Coudln't create network partition algorithm [application-id] %s", appId);
+ log.error(msg);
+ throw new RuntimeException(msg);
+ }
+
List<String> nextNetworkPartitions = algorithm.getNextNetworkPartitions(algorithmContext);
if (nextNetworkPartitions == null || nextNetworkPartitions.isEmpty()) {
- String msg = String.format("No network partitions available for application bursting [application-id] %s", appId);
- log.warn(msg);
- return;
- }
-
+ String msg = String.format("No network partitions available for application bursting [application-id] %s", appId);
+ log.warn(msg);
+ return;
+ }
+
for (String networkPartitionId : nextNetworkPartitions) {
if (!this.networkPartitionCtxts.containsKey(networkPartitionId)) {
@@ -472,8 +472,8 @@ public class ApplicationMonitor extends ParentComponentMonitor {
}
burstNPFound = true;
}
- }
-
+ }
+
if (!burstNPFound) {
log.warn("[Application] " + appId + " cannot be burst as no available resources found");
} else {
@@ -506,36 +506,36 @@ public class ApplicationMonitor extends ParentComponentMonitor {
return false;
}
-
+
private NetworkPartitionAlgorithm getNetworkPartitionAlgorithm(String algorithmName) {
-
- if (algorithmName == null || algorithmName.isEmpty()) {
- return null;
- }
-
- if (algorithmName.equals(StratosConstants.NETWORK_PARTITION_ONE_AFTER_ANOTHER_ALGORITHM_ID)) {
- if (log.isDebugEnabled()) {
- String msg = String.format("Network partition algorithm is set to %s in applicatioin policy",
- StratosConstants.NETWORK_PARTITION_ONE_AFTER_ANOTHER_ALGORITHM_ID);
- log.debug(msg);
- }
- return new OneAfterAnotherAlgorithm();
- } else if (algorithmName.equals(StratosConstants.NETWORK_PARTITION_ALL_AT_ONCE_ALGORITHM_ID)) {
- if (log.isDebugEnabled()) {
- String msg = String.format("Network partition algorithm is set to %s in applicatioin policy",
- StratosConstants.NETWORK_PARTITION_ALL_AT_ONCE_ALGORITHM_ID);
- log.debug(msg);
- }
- return new AllAtOnceAlgorithm();
- }
-
- if (log.isDebugEnabled()) {
- String msg = String.format("Invalid network partition algorithm %s found in applicatioin policy",
- StratosConstants.NETWORK_PARTITION_ALL_AT_ONCE_ALGORITHM_ID);
- log.debug(msg);
- }
-
- return null;
+
+ if (algorithmName == null || algorithmName.isEmpty()) {
+ return null;
+ }
+
+ if (algorithmName.equals(StratosConstants.NETWORK_PARTITION_ONE_AFTER_ANOTHER_ALGORITHM_ID)) {
+ if (log.isDebugEnabled()) {
+ String msg = String.format("Network partition algorithm is set to %s in applicatioin policy",
+ StratosConstants.NETWORK_PARTITION_ONE_AFTER_ANOTHER_ALGORITHM_ID);
+ log.debug(msg);
+ }
+ return new OneAfterAnotherAlgorithm();
+ } else if (algorithmName.equals(StratosConstants.NETWORK_PARTITION_ALL_AT_ONCE_ALGORITHM_ID)) {
+ if (log.isDebugEnabled()) {
+ String msg = String.format("Network partition algorithm is set to %s in applicatioin policy",
+ StratosConstants.NETWORK_PARTITION_ALL_AT_ONCE_ALGORITHM_ID);
+ log.debug(msg);
+ }
+ return new AllAtOnceAlgorithm();
+ }
+
+ if (log.isDebugEnabled()) {
+ String msg = String.format("Invalid network partition algorithm %s found in applicatioin policy",
+ StratosConstants.NETWORK_PARTITION_ALL_AT_ONCE_ALGORITHM_ID);
+ log.debug(msg);
+ }
+
+ return null;
}
public boolean isForce() {
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/component/GroupMonitor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/component/GroupMonitor.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/component/GroupMonitor.java
index f7b5798..1166519 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/component/GroupMonitor.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/component/GroupMonitor.java
@@ -182,13 +182,13 @@ public class GroupMonitor extends ParentComponentMonitor {
if (hasScalingDependents) {
if (nwPartitionContext.getNonTerminatedInstancesCount() >
((GroupLevelNetworkPartitionContext)
- nwPartitionContext).getMinInstanceCount() ) {
+ nwPartitionContext).getMinInstanceCount()) {
//Will scale down based on dependent manner
float minInstances = ((GroupLevelNetworkPartitionContext)
nwPartitionContext).getMinInstanceCount();
- float factor = (nwPartitionContext.getNonTerminatedInstancesCount() - 1)/minInstances;
+ float factor = (nwPartitionContext.getNonTerminatedInstancesCount() - 1) / minInstances;
ScalingEvent scalingEvent = new ScalingEvent(this.id, nwPartitionContext.getId(),
- instanceContext.getId(),factor);
+ instanceContext.getId(), factor);
this.parent.onChildScalingEvent(scalingEvent);
} else {
//Parent has to handle this scale down as by dependent scale down
@@ -480,20 +480,20 @@ public class GroupMonitor extends ParentComponentMonitor {
float requiredInstances = factor * ((GroupLevelNetworkPartitionContext)
networkPartitionContext).getMinInstanceCount();
int ceilingRequiredInstances = (int) Math.ceil(requiredInstances);
- if(ceilingRequiredInstances > currentInstances) {
+ if (ceilingRequiredInstances > currentInstances) {
int instancesToBeCreated = ceilingRequiredInstances - currentInstances;
- for(int count = 0; count < instancesToBeCreated; count++){
+ for (int count = 0; count < instancesToBeCreated; count++) {
createGroupInstanceOnScaling(networkPartitionContext, parentInstanceId);
}
- } else if(ceilingRequiredInstances < currentInstances){
+ } else if (ceilingRequiredInstances < currentInstances) {
int instancesToBeTerminated = currentInstances - ceilingRequiredInstances;
- for(int count = 0; count < instancesToBeTerminated; count++){
+ for (int count = 0; count < instancesToBeTerminated; count++) {
//have to scale down
- if(networkPartitionContext.getPendingInstancesCount() != 0) {
+ if (networkPartitionContext.getPendingInstancesCount() != 0) {
ApplicationBuilder.handleGroupTerminatingEvent(appId, this.id,
networkPartitionContext.getPendingInstances().get(0).getId());
@@ -589,7 +589,7 @@ public class GroupMonitor extends ParentComponentMonitor {
*
* @param parentInstanceContext the parent instance context
* @param networkPartitionContext the GroupLevelNetworkPartitionContext
- * @param groupAlias TODO
+ * @param groupAlias TODO
* @return the partition context
*/
private void addPartitionContext(Instance parentInstanceContext,
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/component/ParentComponentMonitor.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/component/ParentComponentMonitor.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/component/ParentComponentMonitor.java
index 5f6fef8..1b05f4e 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/component/ParentComponentMonitor.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/component/ParentComponentMonitor.java
@@ -220,7 +220,7 @@ public abstract class ParentComponentMonitor extends Monitor implements Runnable
startMonitor(this, context, parentInstanceIds);
} else {
log.info(String.format("Dependent monitor already created, creating instance: " +
- "[application] %s [component] %s", getAppId(), context.getId()));
+ "[application] %s [component] %s", getAppId(), context.getId()));
Monitor monitor = aliasToActiveMonitorsMap.get(context.getId());
// Creating new instance
@@ -234,9 +234,9 @@ public abstract class ParentComponentMonitor extends Monitor implements Runnable
@Override
public void onChildScalingEvent(ScalingEvent scalingEvent) {
- if(log.isInfoEnabled()) {
+ if (log.isInfoEnabled()) {
log.info(String.format("Child scaling event received to [parent] %s [network-partition] %s [event-id] %s " +
- "[group-instance] %s [factor] %s", this.getId(), scalingEvent.getNetworkPartitionId(),
+ "[group-instance] %s [factor] %s", this.getId(), scalingEvent.getNetworkPartitionId(),
scalingEvent.getId(), scalingEvent.getInstanceId(), scalingEvent.getFactor()));
}
String networkPartitionId = scalingEvent.getNetworkPartitionId();
@@ -667,14 +667,14 @@ public abstract class ParentComponentMonitor extends Monitor implements Runnable
protected synchronized void startMonitor(ParentComponentMonitor parent,
ApplicationChildContext context, List<String> parentInstanceIds) {
- if (!this.aliasToActiveMonitorsMap.containsKey(context.getId())) {
- pendingMonitorsList.add(context.getId());
- executorService.submit(new MonitorAdder(parent, context, this.appId, parentInstanceIds));
+ if (!this.aliasToActiveMonitorsMap.containsKey(context.getId())) {
+ pendingMonitorsList.add(context.getId());
+ executorService.submit(new MonitorAdder(parent, context, this.appId, parentInstanceIds));
String monitorTypeStr = AutoscalerUtil.findMonitorType(context).toString().toLowerCase();
log.info(String.format("Monitor scheduled: [type] %s [component] %s ",
- monitorTypeStr, context.getId()));
- }
+ monitorTypeStr, context.getId()));
+ }
}
public Map<String, Monitor> getAliasToActiveMonitorsMap() {
@@ -826,7 +826,7 @@ public abstract class ParentComponentMonitor extends Monitor implements Runnable
pendingMonitorsList.remove(context.getId());
if (log.isInfoEnabled()) {
- long startupTime = (endTime - startTime)/1000;
+ long startupTime = (endTime - startTime) / 1000;
log.info(String.format("Monitor started successfully: [type] %s [component] %s [dependents] %s " +
"[startup-time] %d seconds", monitorTypeStr, context.getId(),
getIdList(context.getApplicationChildContextList()), startupTime));
@@ -835,10 +835,10 @@ public abstract class ParentComponentMonitor extends Monitor implements Runnable
private String getIdList(List<ApplicationChildContext> applicationChildContextList) {
StringBuilder stringBuilder = new StringBuilder();
- if((applicationChildContextList != null) && (applicationChildContextList.size() > 0)) {
- for(ApplicationChildContext applicationChildContext : applicationChildContextList) {
+ if ((applicationChildContextList != null) && (applicationChildContextList.size() > 0)) {
+ for (ApplicationChildContext applicationChildContext : applicationChildContextList) {
stringBuilder.append(applicationChildContext.getId());
- if(applicationChildContextList.indexOf(applicationChildContext) <
+ if (applicationChildContextList.indexOf(applicationChildContext) <
(applicationChildContextList.size() - 1)) {
stringBuilder.append(", ");
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/events/ClusterStatusEvent.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/events/ClusterStatusEvent.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/events/ClusterStatusEvent.java
index 1509a5c..325c42a 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/events/ClusterStatusEvent.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/events/ClusterStatusEvent.java
@@ -30,12 +30,12 @@ public class ClusterStatusEvent extends MonitorStatusEvent {
private ClusterStatus status;
public ClusterStatusEvent(ClusterStatus status, String id, String instanceId) {
- super(id , instanceId);
+ super(id, instanceId);
this.status = status;
}
public ClusterStatusEvent(ClusterStatus status, List<String> instanceIds, String id) {
- super(instanceIds , id);
+ super(instanceIds, id);
this.status = status;
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/events/MonitorEvent.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/events/MonitorEvent.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/events/MonitorEvent.java
index 7936e39..1aa3917 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/events/MonitorEvent.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/events/MonitorEvent.java
@@ -27,16 +27,17 @@ public abstract class MonitorEvent {
protected List<String> instanceIds;
- public MonitorEvent(String id , String instanceId) {
+ public MonitorEvent(String id, String instanceId) {
this.id = id;
this.instanceId = instanceId;
}
- public MonitorEvent(List<String> ids , String instanceId) {
+ public MonitorEvent(List<String> ids, String instanceId) {
this.instanceIds = ids;
this.instanceId = instanceId;
}
- public String getId(){
+
+ public String getId() {
return id;
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/events/MonitorStatusEvent.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/events/MonitorStatusEvent.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/events/MonitorStatusEvent.java
index 8e1c89b..fcecbf6 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/events/MonitorStatusEvent.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/events/MonitorStatusEvent.java
@@ -28,11 +28,11 @@ import java.util.List;
public abstract class MonitorStatusEvent extends MonitorEvent {
public MonitorStatusEvent(String id, String instanceId) {
- super(id , instanceId);
+ super(id, instanceId);
}
public MonitorStatusEvent(List<String> id, String instanceId) {
- super(id , instanceId);
+ super(id, instanceId);
}
public String getId() {
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/events/builder/MonitorStatusEventBuilder.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/events/builder/MonitorStatusEventBuilder.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/events/builder/MonitorStatusEventBuilder.java
index 5f8e53d..49433d7 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/events/builder/MonitorStatusEventBuilder.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/events/builder/MonitorStatusEventBuilder.java
@@ -59,7 +59,7 @@ public class MonitorStatusEventBuilder {
log.info(String.format("Scaling event to the parent, [id] %s, [network Partition Id] %s, [instance id] %s, " +
"[factor] %s", id, networkPartitionId, instanceId, factor));
//Send notifications to parent of the cluster monitor
- ScalingEvent scalingEvent = new ScalingEvent(id, networkPartitionId, instanceId, factor) ;
+ ScalingEvent scalingEvent = new ScalingEvent(id, networkPartitionId, instanceId, factor);
notifyParent(parent, scalingEvent);
}
@@ -69,7 +69,7 @@ public class MonitorStatusEventBuilder {
//Send notifications to parent of the cluster monitor
ScalingUpBeyondMaxEvent scalingUpBeyondMaxEvent = new ScalingUpBeyondMaxEvent(appId, networkPartitionId,
- instanceId) ;
+ instanceId);
notifyParent(parent, scalingUpBeyondMaxEvent);
}
@@ -78,22 +78,23 @@ public class MonitorStatusEventBuilder {
//Send notifications to parent of the cluster monitor
ScalingDownBeyondMinEvent scalingDownBeyondMinEvent = new ScalingDownBeyondMinEvent(appId, networkPartitionId,
- instanceId) ;
+ instanceId);
notifyParent(parent, scalingDownBeyondMinEvent);
}
+
private static void notifyParent(ParentComponentMonitor parent, MonitorStatusEvent statusEvent) {
parent.onChildStatusEvent(statusEvent);
}
- public static void notifyChildren (ParentComponentMonitor componentMonitor, MonitorStatusEvent statusEvent)
- throws MonitorNotFoundException {
+ public static void notifyChildren(ParentComponentMonitor componentMonitor, MonitorStatusEvent statusEvent)
+ throws MonitorNotFoundException {
for (Monitor activeChildMonitor : componentMonitor.getAliasToActiveMonitorsMap().values()) {
activeChildMonitor.onParentStatusEvent(statusEvent);
}
}
public static void notifyChildGroup(Monitor child, GroupStatus state, String instanceId)
- throws MonitorNotFoundException {
+ throws MonitorNotFoundException {
MonitorStatusEvent statusEvent = new GroupStatusEvent(state, child.getId(), instanceId);
child.onParentStatusEvent(statusEvent);
}
@@ -127,7 +128,7 @@ public class MonitorStatusEventBuilder {
parent.onChildScalingOverMaxEvent(scalingUpBeyondMaxEvent);
}
- public static void notifyChildren (ParentComponentMonitor componentMonitor, ScalingEvent scalingEvent) {
+ public static void notifyChildren(ParentComponentMonitor componentMonitor, ScalingEvent scalingEvent) {
for (Monitor activeChildMonitor : componentMonitor.getAliasToActiveMonitorsMap().values()) {
activeChildMonitor.onParentScalingEvent(scalingEvent);
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/Dependencies.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/Dependencies.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/Dependencies.java
index a9e3548..509b12f 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/Dependencies.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/Dependencies.java
@@ -24,9 +24,9 @@ public class Dependencies implements Serializable {
private static final long serialVersionUID = 4187267350546153680L;
- private String [] startupOrders;
+ private String[] startupOrders;
- private String [] scalingDependants;
+ private String[] scalingDependants;
private String terminationBehaviour;
@@ -46,12 +46,12 @@ public class Dependencies implements Serializable {
this.startupOrders = startupOrders;
}
- public String[] getScalingDependants() {
- return scalingDependants;
- }
+ public String[] getScalingDependants() {
+ return scalingDependants;
+ }
+
+ public void setScalingDependants(String[] scalingDependants) {
+ this.scalingDependants = scalingDependants;
+ }
- public void setScalingDependants(String[] scalingDependants) {
- this.scalingDependants = scalingDependants;
- }
-
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/ServiceGroup.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/ServiceGroup.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/ServiceGroup.java
index 381f505..c66592e 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/ServiceGroup.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/ServiceGroup.java
@@ -32,7 +32,7 @@ public class ServiceGroup implements Serializable {
private ServiceGroup[] groups;
- private String [] cartridges;
+ private String[] cartridges;
private Dependencies dependencies;
@@ -44,11 +44,11 @@ public class ServiceGroup implements Serializable {
this.name = name;
}
- public String [] getCartridges() {
+ public String[] getCartridges() {
return cartridges;
}
- public void setCartridges(String [] cartridges) {
+ public void setCartridges(String[] cartridges) {
this.cartridges = cartridges;
}
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/PolicyManager.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/PolicyManager.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/PolicyManager.java
index b81a09f..aac9320 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/PolicyManager.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/PolicyManager.java
@@ -94,7 +94,7 @@ public class PolicyManager {
}
public boolean updateAutoscalePolicy(AutoscalePolicy policy) throws InvalidPolicyException {
- if(StringUtils.isEmpty(policy.getId())){
+ if (StringUtils.isEmpty(policy.getId())) {
throw new AutoScalerException("Autoscaling policy id cannot be empty");
}
this.updateASPolicyInInformationModel(policy);
@@ -120,6 +120,7 @@ public class PolicyManager {
/**
* Add deployment policy to in memory map and persist.
+ *
* @param policy
* @throws InvalidPolicyException
*/
@@ -135,6 +136,7 @@ public class PolicyManager {
/**
* Remove deployment policy from in memory map and registry.
+ *
* @param deploymentPolicyID
* @throws InvalidPolicyException
*/
@@ -176,8 +178,7 @@ public class PolicyManager {
log.debug("Updating autoscaling policy: " + policyID);
}
autoscalePolicyListMap.remove(policyID);
- }
- else{
+ } else {
throw new InvalidPolicyException("No such policy ID [" + policyID + "] exists");
}
}
@@ -188,8 +189,7 @@ public class PolicyManager {
log.debug("Removing application policy [application-id] " + applicationId);
}
applicationPolicyListMap.remove(applicationId);
- }
- else{
+ } else {
throw new InvalidPolicyException("No such application id [" + applicationId + "] exists");
}
}
@@ -232,7 +232,6 @@ public class PolicyManager {
}
-
private void addDeploymentPolicyToPolicyListMap(DeploymentPolicy policy) {
if (StringUtils.isEmpty(policy.getDeploymentPolicyID())) {
throw new RuntimeException("Application id is not found in the deployment policy");
@@ -249,7 +248,7 @@ public class PolicyManager {
}
private void removeDeploymentPolicyFromMap(String applicationId) {
- if(deploymentPolicyListMap.containsKey(applicationId)) {
+ if (deploymentPolicyListMap.containsKey(applicationId)) {
deploymentPolicyListMap.remove(applicationId);
}
}
@@ -367,7 +366,7 @@ public class PolicyManager {
}
public boolean updateApplicationPolicy(ApplicationPolicy applicationPolicy) {
- if(StringUtils.isEmpty(applicationPolicy.getId())){
+ if (StringUtils.isEmpty(applicationPolicy.getId())) {
throw new AutoScalerException("Application policy id cannot be empty");
}
this.updateApplicationPolicyInInformationModel(applicationPolicy);
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/autoscale/AutoscalePolicy.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/autoscale/AutoscalePolicy.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/autoscale/AutoscalePolicy.java
index b448de5..8eee898 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/autoscale/AutoscalePolicy.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/autoscale/AutoscalePolicy.java
@@ -26,22 +26,20 @@ import java.io.Serializable;
*/
public class AutoscalePolicy implements Serializable {
- private static final long serialVersionUID = 1754373171598089271L;
- private LoadThresholds loadThresholds;
- private String id;
- private String displayName;
- private String description;
- private boolean isPublic;
- private int tenantId;
+ private static final long serialVersionUID = 1754373171598089271L;
+ private LoadThresholds loadThresholds;
+ private String id;
+ private String displayName;
+ private String description;
+ private boolean isPublic;
+ private int tenantId;
private float instanceRoundingFactor;
/**
* Gets the value of the loadThresholds property.
- *
- * @return
- * possible object is
- * {@link LoadThresholds }
- *
+ *
+ * @return possible object is
+ * {@link LoadThresholds }
*/
public LoadThresholds getLoadThresholds() {
return loadThresholds;
@@ -49,11 +47,9 @@ public class AutoscalePolicy implements Serializable {
/**
* Sets the value of the loadThresholds property.
- *
- * @param value
- * allowed object is
- * {@link LoadThresholds }
- *
+ *
+ * @param value allowed object is
+ * {@link LoadThresholds }
*/
public void setLoadThresholds(LoadThresholds value) {
this.loadThresholds = value;
@@ -61,11 +57,9 @@ public class AutoscalePolicy implements Serializable {
/**
* Gets the value of the id property.
- *
- * @return
- * possible object is
- * {@link String }
- *
+ *
+ * @return possible object is
+ * {@link String }
*/
public String getId() {
return id;
@@ -73,11 +67,9 @@ public class AutoscalePolicy implements Serializable {
/**
* Sets the value of the id property.
- *
- * @param value
- * allowed object is
- * {@link String }
- *
+ *
+ * @param value allowed object is
+ * {@link String }
*/
public void setId(String value) {
this.id = value;
@@ -85,97 +77,81 @@ public class AutoscalePolicy implements Serializable {
/**
* Gets the value of the displayName property.
- *
- * @return
- * possible object is
- * {@link String }
- *
+ *
+ * @return possible object is
+ * {@link String }
*/
- public String getDisplayName() {
- return displayName;
- }
+ public String getDisplayName() {
+ return displayName;
+ }
- /**
+ /**
* Sets the value of the displayName property.
- *
- * @param displayName
- * allowed object is
- * {@link String }
- *
+ *
+ * @param displayName allowed object is
+ * {@link String }
*/
- public void setDisplayName(String displayName) {
- this.displayName = displayName;
- }
+ public void setDisplayName(String displayName) {
+ this.displayName = displayName;
+ }
- /**
+ /**
* Gets the value of the description property.
- *
- * @return
- * possible object is
- * {@link String }
- *
+ *
+ * @return possible object is
+ * {@link String }
*/
- public String getDescription() {
- return description;
- }
+ public String getDescription() {
+ return description;
+ }
- /**
+ /**
* Sets the value of the description property.
- *
- * @param description
- * allowed object is
- * {@link String }
- *
+ *
+ * @param description allowed object is
+ * {@link String }
*/
- public void setDescription(String description) {
- this.description = description;
- }
-
- /**
+ public void setDescription(String description) {
+ this.description = description;
+ }
+
+ /**
* Gets the value of the isPublic property.
- *
- * @return
- * possible object is boolean
- *
+ *
+ * @return possible object is boolean
*/
- public boolean getIsPublic() {
- return isPublic;
- }
+ public boolean getIsPublic() {
+ return isPublic;
+ }
- /**
+ /**
* Sets the value of the isPublic property.
- *
- * @param isPublic
- * allowed object is boolean
- *
+ *
+ * @param isPublic allowed object is boolean
*/
- public void setIsPublic(boolean isPublic) {
- this.isPublic = isPublic;
- }
-
- /**
+ public void setIsPublic(boolean isPublic) {
+ this.isPublic = isPublic;
+ }
+
+ /**
* Gets the value of the tenantId property.
- *
- *
*/
- public int getTenantId() {
- return tenantId;
- }
+ public int getTenantId() {
+ return tenantId;
+ }
- /**
+ /**
* Sets the value of the tenantId property.
- *
- *
*/
- public void setTenantId(int tenantId) {
- this.tenantId = tenantId;
- }
-
- @Override
- public String toString() {
- return "ASPolicy [id=" + id + ", displayName=" + displayName
- + ", description=" + description + ", isPublic=" + isPublic + "]";
- }
+ public void setTenantId(int tenantId) {
+ this.tenantId = tenantId;
+ }
+
+ @Override
+ public String toString() {
+ return "ASPolicy [id=" + id + ", displayName=" + displayName
+ + ", description=" + description + ", isPublic=" + isPublic + "]";
+ }
public float getInstanceRoundingFactor() {
return instanceRoundingFactor;
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/autoscale/LoadAverage.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/autoscale/LoadAverage.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/autoscale/LoadAverage.java
index 7b723c6..19d1fce 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/autoscale/LoadAverage.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/autoscale/LoadAverage.java
@@ -24,43 +24,43 @@ import java.io.Serializable;
/**
* The model class for LoadAverage definition.
*/
-public class LoadAverage implements Serializable{
+public class LoadAverage implements Serializable {
- private static final long serialVersionUID = -2109860338694123343L;
- private float average = 0.0f;
- private float secondDerivative = 0.0f;
- private float gradient = 0.0f;
+ private static final long serialVersionUID = -2109860338694123343L;
+ private float average = 0.0f;
+ private float secondDerivative = 0.0f;
+ private float gradient = 0.0f;
/**
- * Gets the value of the average property.
+ * Gets the value of the average property.
*/
public float getAverage() {
return average;
}
/**
- * Sets the value of the average property.
+ * Sets the value of the average property.
*/
public void setAverage(float value) {
this.average = value;
}
/**
- * Gets the value of the second-derivative property.
+ * Gets the value of the second-derivative property.
*/
public float getSecondDerivative() {
return secondDerivative;
}
/**
- * Sets the value of the second-derivative property.
+ * Sets the value of the second-derivative property.
*/
public void setSecondDerivative(float value) {
this.secondDerivative = value;
}
/**
- * Gets the value of the gradient property.
+ * Gets the value of the gradient property.
*/
public float getGradient() {
return gradient;
@@ -68,7 +68,6 @@ public class LoadAverage implements Serializable{
/**
* Sets the value of the gradient property.
- *
*/
public void setGradient(float value) {
this.gradient = value;
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/autoscale/LoadAverageThresholds.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/autoscale/LoadAverageThresholds.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/autoscale/LoadAverageThresholds.java
index 7c17a48..c0e4aee 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/autoscale/LoadAverageThresholds.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/autoscale/LoadAverageThresholds.java
@@ -24,20 +24,22 @@ import java.io.Serializable;
/**
* The model class for LoadAverage definition.
*/
-public class LoadAverageThresholds implements Serializable{
-
- private static final long serialVersionUID = -2109860338694123343L;
- private float upperLimit = 80.0F;
-
- public float getUpperLimit() {
- return upperLimit;
- }
- public void setUpperLimit(float upperLimit) {
- this.upperLimit = upperLimit;
- }
- @Override
- public String toString() {
- return "LoadAverage [upperLimit=" + upperLimit + "]";
- }
+public class LoadAverageThresholds implements Serializable {
+
+ private static final long serialVersionUID = -2109860338694123343L;
+ private float upperLimit = 80.0F;
+
+ public float getUpperLimit() {
+ return upperLimit;
+ }
+
+ public void setUpperLimit(float upperLimit) {
+ this.upperLimit = upperLimit;
+ }
+
+ @Override
+ public String toString() {
+ return "LoadAverage [upperLimit=" + upperLimit + "]";
+ }
}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/autoscale/LoadThresholds.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/autoscale/LoadThresholds.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/autoscale/LoadThresholds.java
index 8a85734..e299e15 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/autoscale/LoadThresholds.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/autoscale/LoadThresholds.java
@@ -24,20 +24,18 @@ import java.io.Serializable;
/**
* The model class for LoadThresholds definition.
*/
-public class LoadThresholds implements Serializable{
+public class LoadThresholds implements Serializable {
- private static final long serialVersionUID = -8148571245537655867L;
- private float requestsInFlightThreshold;
- private float memoryConsumptionThreshold;
- private float loadAverageThreshold;
+ private static final long serialVersionUID = -8148571245537655867L;
+ private float requestsInFlightThreshold;
+ private float memoryConsumptionThreshold;
+ private float loadAverageThreshold;
/**
* Gets the value of the requestsInFlightThreshold property.
- *
- * @return
- * possible object is
- * {@link RequestsInFlightThresholds }
- *
+ *
+ * @return possible object is
+ * {@link RequestsInFlightThresholds }
*/
public float getRequestsInFlightThreshold() {
return requestsInFlightThreshold;
@@ -45,11 +43,9 @@ public class LoadThresholds implements Serializable{
/**
* Sets the value of the requestsInFlightThreshold property.
- *
- * @param value
- * allowed object is
- * {@link RequestsInFlightThresholds }
- *
+ *
+ * @param value allowed object is
+ * {@link RequestsInFlightThresholds }
*/
public void setRequestsInFlightThreshold(float value) {
this.requestsInFlightThreshold = value;
@@ -57,11 +53,9 @@ public class LoadThresholds implements Serializable{
/**
* Gets the value of the memoryConsumptionThreshold property.
- *
- * @return
- * possible object is
- * {@link MemoryConsumptionThresholds }
- *
+ *
+ * @return possible object is
+ * {@link MemoryConsumptionThresholds }
*/
public float getMemoryConsumptionThreshold() {
return memoryConsumptionThreshold;
@@ -69,11 +63,9 @@ public class LoadThresholds implements Serializable{
/**
* Sets the value of the memoryConsumptionThreshold property.
- *
- * @param value
- * allowed object is
- * {@link MemoryConsumptionThresholds }
- *
+ *
+ * @param value allowed object is
+ * {@link MemoryConsumptionThresholds }
*/
public void setMemoryConsumptionThreshold(float value) {
this.memoryConsumptionThreshold = value;
@@ -81,11 +73,9 @@ public class LoadThresholds implements Serializable{
/**
* Gets the value of the loadAverageThreshold property.
- *
- * @return
- * possible object is
- * {@link LoadAverageThresholds }
- *
+ *
+ * @return possible object is
+ * {@link LoadAverageThresholds }
*/
public float getLoadAverageThreshold() {
return loadAverageThreshold;
@@ -93,11 +83,9 @@ public class LoadThresholds implements Serializable{
/**
* Sets the value of the loadAverageThreshold property.
- *
- * @param value
- * allowed object is
- * {@link LoadAverageThresholds }
- *
+ *
+ * @param value allowed object is
+ * {@link LoadAverageThresholds }
*/
public void setLoadAverageThreshold(float value) {
this.loadAverageThreshold = value;
http://git-wip-us.apache.org/repos/asf/stratos/blob/506affb8/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/autoscale/MemoryConsumption.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/autoscale/MemoryConsumption.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/autoscale/MemoryConsumption.java
index d072b12..9578126 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/autoscale/MemoryConsumption.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/pojo/policy/autoscale/MemoryConsumption.java
@@ -26,41 +26,41 @@ import java.io.Serializable;
*/
public class MemoryConsumption implements Serializable {
- private static final long serialVersionUID = 5755634390464664663L;
- private float average = 0.0f;
- private float secondDerivative = 0.0f;
- private float gradient = 0.0f;
+ private static final long serialVersionUID = 5755634390464664663L;
+ private float average = 0.0f;
+ private float secondDerivative = 0.0f;
+ private float gradient = 0.0f;
/**
- * Gets the value of the average property.
+ * Gets the value of the average property.
*/
public float getAverage() {
return average;
}
/**
- * Sets the value of the average property.
+ * Sets the value of the average property.
*/
public void setAverage(float value) {
this.average = value;
}
/**
- * Gets the value of the second-derivative property.
+ * Gets the value of the second-derivative property.
*/
public float getSecondDerivative() {
return secondDerivative;
}
/**
- * Sets the value of the second-derivative property.
+ * Sets the value of the second-derivative property.
*/
public void setSecondDerivative(float value) {
this.secondDerivative = value;
}
/**
- * Gets the value of the gradient property.
+ * Gets the value of the gradient property.
*/
public float getGradient() {
return gradient;
@@ -68,7 +68,6 @@ public class MemoryConsumption implements Serializable {
/**
* Sets the value of the gradient property.
- *
*/
public void setGradient(float value) {
this.gradient = value;