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

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

Revision: 2237
          http://cogkit.svn.sourceforge.net/cogkit/?rev=2237&view=rev
Author:   hategan
Date:     2008-10-20 21:44:41 +0000 (Mon, 20 Oct 2008)

Log Message:
-----------
log job data

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

Modified: trunk/current/src/cog/modules/provider-coaster/src/org/globus/cog/abstraction/impl/execution/coaster/SubmitJobCommand.java
===================================================================
--- trunk/current/src/cog/modules/provider-coaster/src/org/globus/cog/abstraction/impl/execution/coaster/SubmitJobCommand.java	2008-10-20 21:43:53 UTC (rev 2236)
+++ trunk/current/src/cog/modules/provider-coaster/src/org/globus/cog/abstraction/impl/execution/coaster/SubmitJobCommand.java	2008-10-20 21:44:41 UTC (rev 2237)
@@ -13,6 +13,7 @@
 import java.io.IOException;
 import java.util.Iterator;
 
+import org.apache.log4j.Logger;
 import org.globus.cog.abstraction.interfaces.ExecutionService;
 import org.globus.cog.abstraction.interfaces.JobSpecification;
 import org.globus.cog.abstraction.interfaces.Service;
@@ -21,6 +22,8 @@
 import org.globus.cog.karajan.workflow.service.commands.Command;
 
 public class SubmitJobCommand extends Command {
+    public static final Logger logger = Logger.getLogger(SubmitJobCommand.class);
+    
     public static final String NAME = "SUBMITJOB";
 
     private Task t;
@@ -47,7 +50,8 @@
         //thing needs to be done to communicate with the perl client
         JobSpecification spec = (JobSpecification) t.getSpecification();
         ByteArrayOutputStream baos = new ByteArrayOutputStream();
-        add(baos, "identity", t.getIdentity().getValue());
+        String identity = t.getIdentity().getValue();
+        add(baos, "identity", identity);
         add(baos, "executable", spec.getExecutable());
         add(baos, "directory", spec.getDirectory());
         add(baos, "stdin", spec.getStdInput());
@@ -83,6 +87,9 @@
             add(baos, "jm", "fork");
         }
         baos.close();
+        if (logger.isDebugEnabled()) {
+            logger.debug("Job data: " + baos.toString());
+        }
         addOutData(baos.toByteArray());
     }
 


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