From: <bsc...@us...> - 2013-02-22 11:57:14
|
Revision: 15977 http://unicore.svn.sourceforge.net/unicore/?rev=15977&view=rev Author: bschuller Date: 2013-02-22 11:57:03 +0000 (Fri, 22 Feb 2013) Log Message: ----------- add broker method for brokering a job group (sf feature #2937159 Modified Paths: -------------- workflow/trunk/common/src/main/java/org/chemomentum/common/ws/IResourceBroker.java workflow/trunk/common/src/main/schema/broker.xsd Modified: workflow/trunk/common/src/main/java/org/chemomentum/common/ws/IResourceBroker.java =================================================================== --- workflow/trunk/common/src/main/java/org/chemomentum/common/ws/IResourceBroker.java 2013-02-22 10:37:29 UTC (rev 15976) +++ workflow/trunk/common/src/main/java/org/chemomentum/common/ws/IResourceBroker.java 2013-02-22 11:57:03 UTC (rev 15977) @@ -36,6 +36,8 @@ import javax.jws.WebService; import javax.xml.namespace.QName; +import org.chemomentum.broker.xmlbeans.BrokerJobGroupRequestDocument; +import org.chemomentum.broker.xmlbeans.BrokerJobGroupResponseDocument; import org.chemomentum.broker.xmlbeans.ChooseResourceRequestDocument; import org.chemomentum.broker.xmlbeans.ChooseResourceResponseDocument; @@ -64,5 +66,16 @@ @WebMethod(action=NS+ServiceName+"/ChooseResourceRequest") public ChooseResourceResponseDocument chooseResources(ChooseResourceRequestDocument req); + + /** + * Used to let the resource broker select a single submission resource for all + * the given job descriptions + * + * @param req + * @return + */ + @WebMethod(action=NS+ServiceName+"/BrokerJobGroupRequest") + public BrokerJobGroupResponseDocument brokerJobGroup(BrokerJobGroupRequestDocument req); + } Modified: workflow/trunk/common/src/main/schema/broker.xsd =================================================================== --- workflow/trunk/common/src/main/schema/broker.xsd 2013-02-22 10:37:29 UTC (rev 15976) +++ workflow/trunk/common/src/main/schema/broker.xsd 2013-02-22 11:57:03 UTC (rev 15977) @@ -36,6 +36,27 @@ </xsd:sequence> </xsd:complexType> </xsd:element> + + <!-- + choose a single suitable resource for all the jobs in the list + --> + <xsd:element name="BrokerJobGroupRequest"> + <xsd:complexType> + <xsd:sequence> + <xsd:element name="JobDefinition" type="jsdl:JobDefinition_Type" maxOccurs="unbounded"/> + <xsd:any namespace="##other" processContents="lax" minOccurs="0" maxOccurs="unbounded"/> + </xsd:sequence> + </xsd:complexType> + </xsd:element> + + <xsd:element name="BrokerJobGroupResponse"> + <xsd:complexType> + <xsd:sequence> + <xsd:element name="Result" + type="broker:ResultType" /> + </xsd:sequence> + </xsd:complexType> + </xsd:element> This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site. |