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

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

Revision: 880
          http://svn.sourceforge.net/cogkit/?rev=880&view=rev
Author:   hategan
Date:     2006-10-09 08:05:12 -0700 (Mon, 09 Oct 2006)

Log Message:
-----------
oops

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

Modified: trunk/current/src/cog/modules/provider-gt2/src/org/globus/cog/abstraction/impl/execution/gt2/JobSubmissionTaskHandler.java
===================================================================
--- trunk/current/src/cog/modules/provider-gt2/src/org/globus/cog/abstraction/impl/execution/gt2/JobSubmissionTaskHandler.java	2006-10-09 14:45:15 UTC (rev 879)
+++ trunk/current/src/cog/modules/provider-gt2/src/org/globus/cog/abstraction/impl/execution/gt2/JobSubmissionTaskHandler.java	2006-10-09 15:05:12 UTC (rev 880)
@@ -76,7 +76,9 @@
         } catch (Throwable e) {
             throw new IllegalSpecException("Cannot parse the given RSL", e);
         }
-        logger.debug("RSL: " + rsl);
+        if (logger.isDebugEnabled()) {
+            logger.debug("RSL: " + rsl);
+        }
 
         if (rslTree.getOperator() == RslNode.MULTI) {
             this.task.setAttribute("jobCount", "multiple");
@@ -114,7 +116,9 @@
         if (jobmanager != null) {
             server = handleJobManager(server, jobmanager);
         }
-        logger.debug("Execution server: " + server);
+        if (logger.isDebugEnabled()) {
+            logger.debug("Execution server: " + server);
+        }
         boolean limitedDeleg = (securityContext.getDelegation() != GlobusSecurityContextImpl.FULL_DELEGATION);
         limitedDeleg &= !spec.isDelegationEnabled();
         try {
@@ -122,8 +126,10 @@
             // submitted for execution
             if (this.task.getStatus().getStatusCode() == Status.UNSUBMITTED) {
                 this.gramJob.request(server, spec.isBatchJob(), limitedDeleg);
-                logger.debug("Submitted job with Globus ID: "
-                        + this.gramJob.getIDAsString());
+                if (logger.isDebugEnabled()) {
+                    logger.debug("Submitted job with Globus ID: "
+                            + this.gramJob.getIDAsString());
+                }
                 this.task.setStatus(Status.SUBMITTED);
                 if (spec.isBatchJob()) {
                     this.task.setStatus(Status.COMPLETED);
@@ -200,9 +206,10 @@
         boolean limitedDeleg = (securityContext.getDelegation() == GlobusSecurityContextImpl.PARTIAL_DELEGATION);
         try {
             job.request(rmc, false, limitedDeleg);
-            logger
-                    .debug("Submitted job with Globus ID: "
-                            + job.getIDAsString());
+            if (logger.isDebugEnabled()) {
+                logger.debug("Submitted job with Globus ID: "
+                        + job.getIDAsString());
+            }
         } catch (GramException ge) {
             Status newStatus = new StatusImpl();
             Status oldStatus = this.task.getStatus();
@@ -304,12 +311,10 @@
             // sets other parameters
             NameOpValue args = new NameOpValue("arguments", NameOpValue.EQ);
             if (!spec.getArgumentsAsList().isEmpty()) {
-                List arglist = new LinkedList();
                 Iterator i = spec.getArgumentsAsList().iterator();
                 while (i.hasNext()) {
-                    arglist.add(new Value((String) i.next()));
+                    args.add((String) i.next());
                 }
-                args.add(arglist);
                 rsl.add(args);
             }
 


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