You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by la...@apache.org on 2014/12/13 17:28:57 UTC
stratos git commit: Fix obsolete rule error
Repository: stratos
Updated Branches:
refs/heads/4.1.0-test 64f030d25 -> 6e860f4b5
Fix obsolete rule error
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/6e860f4b
Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/6e860f4b
Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/6e860f4b
Branch: refs/heads/4.1.0-test
Commit: 6e860f4b52235656fb5ce0084b3c8d07f7c17a19
Parents: 64f030d
Author: Lahiru Sandaruwan <la...@apache.org>
Authored: Sat Dec 13 22:00:59 2014 +0530
Committer: Lahiru Sandaruwan <la...@apache.org>
Committed: Sat Dec 13 22:00:59 2014 +0530
----------------------------------------------------------------------
.../distribution/src/main/conf/drools/obsoletecheck.drl | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/stratos/blob/6e860f4b/products/stratos/modules/distribution/src/main/conf/drools/obsoletecheck.drl
----------------------------------------------------------------------
diff --git a/products/stratos/modules/distribution/src/main/conf/drools/obsoletecheck.drl b/products/stratos/modules/distribution/src/main/conf/drools/obsoletecheck.drl
index 6345de6..894cf2a 100755
--- a/products/stratos/modules/distribution/src/main/conf/drools/obsoletecheck.drl
+++ b/products/stratos/modules/distribution/src/main/conf/drools/obsoletecheck.drl
@@ -55,11 +55,11 @@ rule "Terminate Obsoleted Instances"
dialect "mvel"
when
ctxt : ClusterLevelPartitionContext ()
- eval(log.debug("Running obsolete instances rule: [partition] " + ctxt.getPartitionId() + " [cluster] " + ctxt.getClusterId() + " [network-partition] " + ctxt.getNetworkPartitionId()))
- eval(log.debug("[obsolete-check] [network-partition] " + ctxt.getNetworkPartitionId() + " [cluster] " + ctxt.getClusterId() + " [partition] " + ctxt.getPartitionId() +" Obsolete member count: " + ctxt.getObsoletedMembers().size()))
+ eval(log.debug("Running obsolete instances rule: [partition] " + ctxt.getPartitionId() + " [network-partition] " + ctxt.getNetworkPartitionId()))
+ eval(log.debug("[obsolete-check] [network-partition] " + ctxt.getNetworkPartitionId() + " [partition] " + ctxt.getPartitionId() +" Obsolete member count: " + ctxt.getObsoletedMembers().size()))
eval(ctxt.getObsoletedMembers().keySet().size() > 0)
memberId : String() from ctxt.getObsoletedMembers().keySet()
- eval(log.debug("[obsolete-check] [network-partition] " + ctxt.getNetworkPartitionId() + " [cluster] " + ctxt.getClusterId() + " [partition] " + ctxt.getPartitionId() + " Member id: " + memberId))
+ eval(log.debug("[obsolete-check] [network-partition] " + ctxt.getNetworkPartitionId() + " [partition] " + ctxt.getPartitionId() + " Member id: " + memberId))
then
delegator.terminateObsoleteInstance(memberId);
end
@@ -72,7 +72,7 @@ dialect "mvel"
eval(log.debug("[instance-cleanup-check] [network-partition] " + ctxt.getNetworkPartitionId() + " [partition] " + ctxt.getPartitionId() +" Pending termination member count: " + ctxt.getTerminationPendingMembers().size()))
eval(ctxt.getTerminationPendingMembers().size() > 0)
memberId : String() from ctxt.getTerminationPendingMembers()
- eval(log.debug("[instance-cleanup-check ] [network-partition] " + ctxt.getNetworkPartitionId() + " [partition] " + ctxt.getPartitionId() + " Member id: " + memberId) + " [cluster] " + ctxt.getClusterId())
+ eval(log.debug("[instance-cleanup-check ] [network-partition] " + ctxt.getNetworkPartitionId() + " [partition] " + ctxt.getPartitionId() + " Member id: " + memberId))
then
delegator.delegateInstanceCleanup(memberId);
end