You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by re...@apache.org on 2015/04/27 04:10:05 UTC
stratos git commit: persisting application after updating
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 <rt...@gmail.com>
Authored: Sun Apr 26 22:39:32 2015 +0530
Committer: reka <rt...@gmail.com>
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();
}