Repository: stratos Updated Branches: refs/heads/master 55e49d0f8 -> e7e376e4a
Add the member stat context for pending members, so that they will be accounted in scaling down member selection Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/940992e0 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/940992e0 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/940992e0 Branch: refs/heads/master Commit: 940992e00cf5b46f4b6eb8061af19909702f174b Parents: 55e49d0 Author: Lahiru Sandaruwan <[email protected]> Authored: Thu Jun 11 17:00:39 2015 +0530 Committer: Lahiru Sandaruwan <[email protected]> Committed: Thu Jun 11 17:00:39 2015 +0530 ---------------------------------------------------------------------- .../java/org/apache/stratos/autoscaler/rule/RuleTasksDelegator.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/940992e0/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/rule/RuleTasksDelegator.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/rule/RuleTasksDelegator.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/rule/RuleTasksDelegator.java index e4cf83b..0ad79fb 100644 --- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/rule/RuleTasksDelegator.java +++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/rule/RuleTasksDelegator.java @@ -204,6 +204,7 @@ public class RuleTasksDelegator { ClusterLevelPartitionContext partitionContext = clusterInstanceContext. getPartitionCtxt(clusterMonitorPartitionContext.getPartitionId()); partitionContext.addPendingMember(memberContext); + partitionContext.addMemberStatsContext(new MemberStatsContext(memberContext.getMemberId())); if (log.isDebugEnabled()) { log.debug(String.format("Pending member added, [member] %s [partition] %s", memberContext.getMemberId(), memberContext.getPartition().getId()));
