Repository: stratos Updated Branches: refs/heads/docker-grouping-merge 9e19c8770 -> 384e38cc6
moving terminatedependency.drl to conf/drools Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/384e38cc Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/384e38cc Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/384e38cc Branch: refs/heads/docker-grouping-merge Commit: 384e38cc67d3d0c5b2ccd5a7e2b6adc5ea6e47ef Parents: 9e19c87 Author: R-Rajkumar <[email protected]> Authored: Tue Nov 4 09:42:30 2014 +0530 Committer: R-Rajkumar <[email protected]> Committed: Tue Nov 4 09:42:30 2014 +0530 ---------------------------------------------------------------------- .../main/conf/drools/terminatedependency.drl | 52 ++++++++++++++++++++ .../src/main/conf/terminatedependency.drl | 52 -------------------- 2 files changed, 52 insertions(+), 52 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/384e38cc/products/stratos/modules/distribution/src/main/conf/drools/terminatedependency.drl ---------------------------------------------------------------------- diff --git a/products/stratos/modules/distribution/src/main/conf/drools/terminatedependency.drl b/products/stratos/modules/distribution/src/main/conf/drools/terminatedependency.drl new file mode 100644 index 0000000..9ea243c --- /dev/null +++ b/products/stratos/modules/distribution/src/main/conf/drools/terminatedependency.drl @@ -0,0 +1,52 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ + +package org.apache.stratos.autoscaler.rule; + +import org.apache.stratos.messaging.domain.topology.Cluster; +import org.apache.stratos.autoscaler.PartitionContext; + +global org.apache.stratos.autoscaler.rule.RuleLog log; +global org.apache.stratos.autoscaler.rule.RuleTasksDelegator $delegator; +global java.util.Map partitionCtxts; +global java.lang.String clusterId; +global java.lang.String lbRef; +global java.lang.String serviceId; + +global org.apache.stratos.autoscaler.policy.model.AutoscalePolicy autoscalePolicy; + +rule "Terminate Dependency Rule" + +dialect "mvel" + when + $ctxt : PartitionContext () + eval(log.debug("Running terminate dependency rule: [partition] " + $ctxt.getPartitionId() + " [network-partition] " + $ctxt.getNetworkPartitionId())) + eval(log.debug("[terminate dependency] [network-partition] " + $ctxt.getNetworkPartitionId() + " [partition] " + $ctxt.getPartitionId() +" Member count: " + $ctxt.getMemberStatsContexts().size())) + eval(log.debug("Grouping ... in terminatedependency rule terminating all members " + $ctxt.getAllMemberForTerminationCount())) + eval(!$ctxt.checkKillDependencies(serviceId, clusterId)) + eval(log.debug("[terminate dependency] [network-partition] " + $ctxt.getNetworkPartitionId() + " [partition] " + $ctxt.getPartitionId() + " successfully terminated members")) + + eval(log.debug("Grouping:terminatedependency:terminating all")) + + then + $delegator.delegateTerminateAll(clusterId); +end + + + http://git-wip-us.apache.org/repos/asf/stratos/blob/384e38cc/products/stratos/modules/distribution/src/main/conf/terminatedependency.drl ---------------------------------------------------------------------- diff --git a/products/stratos/modules/distribution/src/main/conf/terminatedependency.drl b/products/stratos/modules/distribution/src/main/conf/terminatedependency.drl deleted file mode 100644 index 9ea243c..0000000 --- a/products/stratos/modules/distribution/src/main/conf/terminatedependency.drl +++ /dev/null @@ -1,52 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ - -package org.apache.stratos.autoscaler.rule; - -import org.apache.stratos.messaging.domain.topology.Cluster; -import org.apache.stratos.autoscaler.PartitionContext; - -global org.apache.stratos.autoscaler.rule.RuleLog log; -global org.apache.stratos.autoscaler.rule.RuleTasksDelegator $delegator; -global java.util.Map partitionCtxts; -global java.lang.String clusterId; -global java.lang.String lbRef; -global java.lang.String serviceId; - -global org.apache.stratos.autoscaler.policy.model.AutoscalePolicy autoscalePolicy; - -rule "Terminate Dependency Rule" - -dialect "mvel" - when - $ctxt : PartitionContext () - eval(log.debug("Running terminate dependency rule: [partition] " + $ctxt.getPartitionId() + " [network-partition] " + $ctxt.getNetworkPartitionId())) - eval(log.debug("[terminate dependency] [network-partition] " + $ctxt.getNetworkPartitionId() + " [partition] " + $ctxt.getPartitionId() +" Member count: " + $ctxt.getMemberStatsContexts().size())) - eval(log.debug("Grouping ... in terminatedependency rule terminating all members " + $ctxt.getAllMemberForTerminationCount())) - eval(!$ctxt.checkKillDependencies(serviceId, clusterId)) - eval(log.debug("[terminate dependency] [network-partition] " + $ctxt.getNetworkPartitionId() + " [partition] " + $ctxt.getPartitionId() + " successfully terminated members")) - - eval(log.debug("Grouping:terminatedependency:terminating all")) - - then - $delegator.delegateTerminateAll(clusterId); -end - - -
