Repository: stratos Updated Branches: refs/heads/master 25d764b5a -> 602beae7d
persisting application after updating Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/602beae7 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/602beae7 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/602beae7 Branch: refs/heads/master Commit: 602beae7df95c893faa240783fb0562a811891aa Parents: 25d764b Author: reka <[email protected]> Authored: Sun Apr 26 22:39:32 2015 +0530 Committer: reka <[email protected]> Committed: Sun Apr 26 22:41:04 2015 +0530 ---------------------------------------------------------------------- .../autoscaler/internal/AutoscalerServiceComponent.java | 3 ++- .../org/apache/stratos/autoscaler/util/AutoscalerUtil.java | 6 +++++- 2 files changed, 7 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/602beae7/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 e3641b6..0695aa4 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 @@ -199,7 +199,8 @@ public class AutoscalerServiceComponent { } // Add application policies to information model - List<NetworkPartitionAlgorithmContext> networkPartitionAlgorithmContexts = RegistryManager.getInstance().retrieveNetworkPartitionAlgorithmContexts(); + List<NetworkPartitionAlgorithmContext> networkPartitionAlgorithmContexts = + RegistryManager.getInstance().retrieveNetworkPartitionAlgorithmContexts(); Iterator<NetworkPartitionAlgorithmContext> networkPartitionAlgoCtxtIterator = networkPartitionAlgorithmContexts.iterator(); while (networkPartitionAlgoCtxtIterator.hasNext()) { NetworkPartitionAlgorithmContext algorithmContext = networkPartitionAlgoCtxtIterator.next(); http://git-wip-us.apache.org/repos/asf/stratos/blob/602beae7/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 3e6c134..a5efd9d 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 @@ -796,6 +796,8 @@ public class AutoscalerUtil { existingGroup.setGroupMinInstances(newGroup.getGroupMinInstances()); //TODO applications Topology update existingGroup.setGroupMaxInstances(newGroup.getGroupMaxInstances()); + //Persisting the existing application + ApplicationHolder.persistApplication(existingApplication); } finally { ApplicationHolder.releaseWriteLock(); } @@ -807,7 +809,6 @@ public class AutoscalerUtil { } } - } public void updateClusterMonitor(Application application) throws ApplicationDefinitionException { @@ -837,10 +838,13 @@ public class AutoscalerUtil { getClusterDataHolderRecursivelyByAlias( AutoscalerUtil.getAliasFromClusterId( clusterDataHolder.getClusterId())); + //Updating the in-memory model existingClusterDataHolder.setMinInstances(clusterDataHolder. getMinInstances()); existingClusterDataHolder.setMaxInstances(clusterDataHolder. getMaxInstances()); + //Persisting the existing application + ApplicationHolder.persistApplication(existingApplication); } finally { ApplicationHolder.releaseWriteLock(); }
