Updated Branches: refs/heads/master d929b3791 -> 8ef8709a7
Adding pending member while spawning instance on member fault event Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/dcdc412d Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/dcdc412d Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/dcdc412d Branch: refs/heads/master Commit: dcdc412d2e0be58bbda99fe983902206156df8a5 Parents: 1aded30 Author: Lahiru Sandaruwan <[email protected]> Authored: Mon Jan 13 13:59:03 2014 +0530 Committer: Lahiru Sandaruwan <[email protected]> Committed: Mon Jan 13 13:59:03 2014 +0530 ---------------------------------------------------------------------- .../message/receiver/health/AutoscalerHealthStatReceiver.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/dcdc412d/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/health/AutoscalerHealthStatReceiver.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/health/AutoscalerHealthStatReceiver.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/health/AutoscalerHealthStatReceiver.java index db71f57..c2f1097 100644 --- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/health/AutoscalerHealthStatReceiver.java +++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/health/AutoscalerHealthStatReceiver.java @@ -740,7 +740,7 @@ public class AutoscalerHealthStatReceiver implements Runnable { PartitionContext partitionCtxt = nwPartitionCtxt.getPartitionCtxt(partitionId); String lbClusterId = AutoscalerRuleEvaluator.getLbClusterId(partitionCtxt, nwPartitionCtxt); - ccClient.spawnAnInstance(partition, clusterId, lbClusterId, nwPartitionCtxt.getId()); + partitionCtxt.addPendingMember(ccClient.spawnAnInstance(partition, clusterId, lbClusterId, nwPartitionCtxt.getId())); if (log.isInfoEnabled()) { log.info(String.format("Instance spawned for fault member: [partition] %s [cluster] %s [lb cluster] %s ", partitionId, clusterId, lbClusterId));
