[Cogkit-svn] SF.net SVN: cogkit: [1895] trunk/current/src/cog/modules/provider-ssh/src/ org/globus/cog/abstraction/impl/ssh/execution/JobSubmissionTaskHandler.java

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

Revision: 1895
          http://cogkit.svn.sourceforge.net/cogkit/?rev=1895&view=rev
Author:   hategan
Date:     2008-02-12 09:33:40 -0800 (Tue, 12 Feb 2008)

Log Message:
-----------
the same weirdness, propagated from the dawn of time

Modified Paths:
--------------
    trunk/current/src/cog/modules/provider-ssh/src/org/globus/cog/abstraction/impl/ssh/execution/JobSubmissionTaskHandler.java

Modified: trunk/current/src/cog/modules/provider-ssh/src/org/globus/cog/abstraction/impl/ssh/execution/JobSubmissionTaskHandler.java
===================================================================
--- trunk/current/src/cog/modules/provider-ssh/src/org/globus/cog/abstraction/impl/ssh/execution/JobSubmissionTaskHandler.java	2008-02-12 17:32:32 UTC (rev 1894)
+++ trunk/current/src/cog/modules/provider-ssh/src/org/globus/cog/abstraction/impl/ssh/execution/JobSubmissionTaskHandler.java	2008-02-12 17:33:40 UTC (rev 1895)
@@ -80,12 +80,11 @@
 
             SSHRunner r = new SSHRunner(s, exec);
             r.addListener(this);
-            // check if the task has not been canceled after it was submitted
-            // for execution
-            if (this.task.getStatus().getStatusCode() == Status.UNSUBMITTED) {
-                this.task.setStatus(Status.SUBMITTED);
-                r.startRun(exec);
-                this.task.setStatus(Status.ACTIVE);
+            synchronized(this) {
+                if (this.task.getStatus().getStatusCode() != Status.CANCELED) {
+                    r.startRun(exec);
+                    this.task.setStatus(Status.ACTIVE);
+                }
             }
         }
     }
@@ -100,8 +99,9 @@
         // not implemented yet
     }
 
-    public void cancel() throws InvalidSecurityContextException,
+    public synchronized void cancel() throws InvalidSecurityContextException,
             TaskSubmissionException {
+        //TODO implement me
     }
 
     private String prepareSpecification(JobSpecification spec)


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