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

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

Revision: 1741
          http://cogkit.svn.sourceforge.net/cogkit/?rev=1741&view=rev
Author:   hategan
Date:     2007-09-18 14:45:30 -0700 (Tue, 18 Sep 2007)

Log Message:
-----------
added socketTimeout attribute handling

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

Modified: trunk/current/src/cog/modules/provider-gt4_0_0/src/org/globus/cog/abstraction/impl/execution/gt4_0_0/JobSubmissionTaskHandler.java
===================================================================
--- trunk/current/src/cog/modules/provider-gt4_0_0/src/org/globus/cog/abstraction/impl/execution/gt4_0_0/JobSubmissionTaskHandler.java	2007-09-14 21:40:11 UTC (rev 1740)
+++ trunk/current/src/cog/modules/provider-gt4_0_0/src/org/globus/cog/abstraction/impl/execution/gt4_0_0/JobSubmissionTaskHandler.java	2007-09-18 21:45:30 UTC (rev 1741)
@@ -176,8 +176,7 @@
                 this.gramJob.addListener(this);
             }
 
-            this.gramJob
-                    .setDelegationEnabled(spec.getDelegation() != Delegation.NO_DELEGATION);
+            setMiscJobParams(spec, this.gramJob);
 
             try {
                 this.gramJob.submit(factoryEndpoint, spec.isBatchJob(), spec
@@ -199,6 +198,23 @@
         }
     }
 
+    protected void setMiscJobParams(JobSpecification spec, GramJob job) {
+        job
+                .setDelegationEnabled(spec.getDelegation() != Delegation.NO_DELEGATION);
+
+        Object soTimeout = spec.getAttribute("socketTimeout");
+        if (soTimeout instanceof Integer) {
+            job.setTimeOut(((Integer) soTimeout).intValue());
+        }
+        else if (soTimeout instanceof String) {
+            job.setTimeOut(Integer.parseInt((String) soTimeout));
+        }
+        else {
+            logger.warn("Unknown value for socketTimeout attribute ("
+                    + soTimeout + "). Ignoring.");
+        }
+    }
+
     public void suspend() throws InvalidSecurityContextException,
             TaskSubmissionException {
         throw new UnsupportedOperationException("suspend");


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