[Cogkit-svn] SF.net SVN: cogkit: [1935] trunk/current/src/cog/modules/karajan

[<b_...@us...>]

Revision: 1935
          http://cogkit.svn.sourceforge.net/cogkit/?rev=1935&view=rev
Author:   b_z_c
Date:     2008-03-15 12:10:21 -0700 (Sat, 15 Mar 2008)

Log Message:
-----------
The WeightedHost scheduler now has a lower bound (of -10)
on scoring to reduce the effect of penalising a host in the case of a
large number of transient errors. Previously, a large number of
transient errors would push the score so low that the score would
take far too long to return to a more appropriate value.

Modified Paths:
--------------
    trunk/current/src/cog/modules/karajan/CHANGES.txt
    trunk/current/src/cog/modules/karajan/src/org/globus/cog/karajan/scheduler/WeightedHost.java

Modified: trunk/current/src/cog/modules/karajan/CHANGES.txt
===================================================================
--- trunk/current/src/cog/modules/karajan/CHANGES.txt	2008-03-06 12:06:19 UTC (rev 1934)
+++ trunk/current/src/cog/modules/karajan/CHANGES.txt	2008-03-15 19:10:21 UTC (rev 1935)
@@ -1,3 +1,11 @@
+(03/15/2008)
+
+*** The WeightedHost scheduler now has a lower bound (of -10)
+    on scoring to reduce the effect of penalising a host in the case of a
+    large number of transient errors. Previously, a large number of
+    transient errors would push the score so low that the score would
+    take far too long to return to a more appropriate value.
+
 (02/22/2008)
 
 *** Added sys:dateFormat(pattern, value)

Modified: trunk/current/src/cog/modules/karajan/src/org/globus/cog/karajan/scheduler/WeightedHost.java
===================================================================
--- trunk/current/src/cog/modules/karajan/src/org/globus/cog/karajan/scheduler/WeightedHost.java	2008-03-06 12:06:19 UTC (rev 1934)
+++ trunk/current/src/cog/modules/karajan/src/org/globus/cog/karajan/scheduler/WeightedHost.java	2008-03-15 19:10:21 UTC (rev 1935)
@@ -15,6 +15,9 @@
 import org.globus.cog.karajan.util.BoundContact;
 
 public class WeightedHost implements Comparable {
+
+	static final int MINWEIGHT = -10;
+
 	private BoundContact host;
 	private Double score;
 	private double tscore;
@@ -38,6 +41,7 @@
 	}
 
 	protected void setScore(double score) {
+		if(score<MINWEIGHT) score=MINWEIGHT;
 		this.score = new Double(score);
 		this.tscore = smooth(score);
 	}
@@ -132,4 +136,4 @@
 	public float getJobThrottle() {
 		return jobThrottle;
 	}
-}
\ No newline at end of file
+}


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.