[Cogkit-svn] SF.net SVN: cogkit: [1934] trunk/current/src/cog/modules/provider-gt4_0_0

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

Revision: 1934
          http://cogkit.svn.sourceforge.net/cogkit/?rev=1934&view=rev
Author:   hategan
Date:     2008-03-06 04:06:19 -0800 (Thu, 06 Mar 2008)

Log Message:
-----------
added host_types support

Modified Paths:
--------------
    trunk/current/src/cog/modules/provider-gt4_0_0/CHANGES.txt
    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/CHANGES.txt
===================================================================
--- trunk/current/src/cog/modules/provider-gt4_0_0/CHANGES.txt	2008-02-28 17:42:14 UTC (rev 1933)
+++ trunk/current/src/cog/modules/provider-gt4_0_0/CHANGES.txt	2008-03-06 12:06:19 UTC (rev 1934)
@@ -1,3 +1,7 @@
+(03/06/2008)
+
+*** Added support for host_types attribute (patch from benc)
+
 (02/28/2008)
 
 *** The previous axis update had a bug with the UUID generator.

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	2008-02-28 17:42:14 UTC (rev 1933)
+++ trunk/current/src/cog/modules/provider-gt4_0_0/src/org/globus/cog/abstraction/impl/execution/gt4_0_0/JobSubmissionTaskHandler.java	2008-03-06 12:06:19 UTC (rev 1934)
@@ -13,6 +13,7 @@
 import java.util.Map;
 
 import org.apache.axis.components.uuid.UUIDGenFactory;
+import org.apache.axis.message.MessageElement;
 import org.apache.axis.message.addressing.EndpointReferenceType;
 import org.apache.axis.types.NonNegativeInteger;
 import org.apache.axis.types.PositiveInteger;
@@ -33,6 +34,7 @@
 import org.globus.cog.abstraction.interfaces.Task;
 import org.globus.exec.client.GramJob;
 import org.globus.exec.client.GramJobListener;
+import org.globus.exec.generated.ExtensionsType;
 import org.globus.exec.generated.FaultType;
 import org.globus.exec.generated.JobDescriptionType;
 import org.globus.exec.generated.JobTypeEnumeration;
@@ -300,6 +302,15 @@
             desc.setQueue((String) spec.getAttribute("queue"));
         }
 
+        if (spec.getAttribute("host_types") != null) {
+            MessageElement nodesMessageElement = new MessageElement("",
+                    "nodes", spec.getAttribute("host_types"));
+            MessageElement[] messageElements = new MessageElement[] { nodesMessageElement };
+            ExtensionsType extensions = new ExtensionsType();
+            extensions.set_any(messageElements);
+            desc.setExtensions(extensions);
+        }
+
         desc.setArgument((String[]) spec.getArgumentsAsList().toArray(
                 new String[0]));
 


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