[Cogkit-svn] SF.net SVN: cogkit: [1740] trunk/current/src/cog/modules/karajan/src/org/ globus/cog/karajan/scheduler/submitQueue/FixedRateQueue.java

[<ha...@us...>]

Revision: 1740
          http://cogkit.svn.sourceforge.net/cogkit/?rev=1740&view=rev
Author:   hategan
Date:     2007-09-14 14:40:11 -0700 (Fri, 14 Sep 2007)

Log Message:
-----------
only throttle jobs

Modified Paths:
--------------
    trunk/current/src/cog/modules/karajan/src/org/globus/cog/karajan/scheduler/submitQueue/FixedRateQueue.java

Modified: trunk/current/src/cog/modules/karajan/src/org/globus/cog/karajan/scheduler/submitQueue/FixedRateQueue.java
===================================================================
--- trunk/current/src/cog/modules/karajan/src/org/globus/cog/karajan/scheduler/submitQueue/FixedRateQueue.java	2007-09-13 21:20:40 UTC (rev 1739)
+++ trunk/current/src/cog/modules/karajan/src/org/globus/cog/karajan/scheduler/submitQueue/FixedRateQueue.java	2007-09-14 21:40:11 UTC (rev 1740)
@@ -12,16 +12,17 @@
 import java.util.Timer;
 import java.util.TimerTask;
 
+import org.globus.cog.abstraction.interfaces.Task;
+
 public class FixedRateQueue extends AbstractSubmitQueue {
 	private long lastSubmit, delay;
 	private static Timer timer;
 
-
 	public FixedRateQueue(long delay) {
-		super(Math.max(1, (int) (delay/1000)));
+		super(Math.max(1, (int) (delay / 1000)));
 		this.delay = delay;
 	}
-	
+
 	public FixedRateQueue(double rate) {
 		super(Math.max(1, (int) rate));
 		this.delay = (long) (1000 / rate);
@@ -56,4 +57,18 @@
 			nbs.nextQueue();
 		}
 	}
+
+	public void queue(NonBlockingSubmit nbs) {
+		if (nbs != null) {
+			if (nbs.getTask().getType() == Task.JOB_SUBMISSION) {
+				super.queue(nbs);
+			}
+			else {
+				nbs.nextQueue();
+			}
+		}
+		else {
+			super.queue(nbs);
+		}
+	}
 }


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