[Cogkit-svn] SF.net SVN: cogkit: [1864] trunk/current/src/cog/modules/karajan/src/org/ globus/cog/karajan/workflow/nodes/grid/AbstractGridNode.java

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

Revision: 1864
          http://cogkit.svn.sourceforge.net/cogkit/?rev=1864&view=rev
Author:   hategan
Date:     2008-01-04 18:43:28 -0800 (Fri, 04 Jan 2008)

Log Message:
-----------
absence of a scheduler doesn't mean we can rely on preemptive threading

Modified Paths:
--------------
    trunk/current/src/cog/modules/karajan/src/org/globus/cog/karajan/workflow/nodes/grid/AbstractGridNode.java

Modified: trunk/current/src/cog/modules/karajan/src/org/globus/cog/karajan/workflow/nodes/grid/AbstractGridNode.java
===================================================================
--- trunk/current/src/cog/modules/karajan/src/org/globus/cog/karajan/workflow/nodes/grid/AbstractGridNode.java	2008-01-05 02:42:00 UTC (rev 1863)
+++ trunk/current/src/cog/modules/karajan/src/org/globus/cog/karajan/workflow/nodes/grid/AbstractGridNode.java	2008-01-05 02:43:28 UTC (rev 1864)
@@ -31,6 +31,7 @@
 import org.globus.cog.abstraction.interfaces.TaskHandler;
 import org.globus.cog.karajan.arguments.Arg;
 import org.globus.cog.karajan.scheduler.Scheduler;
+import org.globus.cog.karajan.scheduler.submitQueue.NonBlockingSubmit;
 import org.globus.cog.karajan.stack.VariableNotFoundException;
 import org.globus.cog.karajan.stack.VariableStack;
 import org.globus.cog.karajan.util.BoundContact;
@@ -197,7 +198,7 @@
 			tasks.put(task, stack);
 		}
 		try {
-			handler.submit(task);
+			new NonBlockingSubmit(handler, task, null).go();
 		}
 		catch (Exception e) {
 			// avoid failing twice if status is already set


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