Hi, you can use the DelegationUtil for that. In general you'll have to delegate a credential and populate the job description (what you named rsl) with it. As far as i know we don't have official documentation for that but you can check how ws-gram's java api GramJob is using it for delegation: Download ws-gram by "cvs co -r globus_4_0_5 ws-gram" with CVSROOT set to ":pserver:[EMAIL PROTECTED]:/home/globdev/CVS/globus-packages" and look at ws-gram/client/java/source/src/org/globus/exec/client/GramJob.java and in particular at the methods delegate(), populateJobDescriptionEndpoints() and destroyDelegatedCredentials()
If it's just about a Java API to ws-gram i would recommend using GramJob instead of writing all by yourself. You can also look at the inofficial java command-line client GlobusRun.java in the same directory to see how GramJob can be used. Unfortunately we don't have documentation about the use of GramJob at the moment. It's supposed to come. Martin > > Hi all, > > I got a problem concerning the staging file. > Googoling around it appears that in order to perform the "Delagation" it > is necessary to add the "-S" argument calling "globusrun-ws". > However how should the "delagation" be called from a java application? How > must I get the same behavior (the -S argument) within the RSL ? > Below I have attached the RSL utilized by the java application. How can I > introduce the "stagingCredentialEndpoint" in the RSL? How can the staging > operation be done ? > There is any further step to be done ? > > RSL:<?xml version="1.0" encoding="UTF-8"?> > <job><executable>/home/scope/esempi2/esercizio_2/readwrite.out</executable><directory>/home/scope/esempi2/esercizio_2</directory><stdin>/dev/null</stdin> > <stdout>/home/scope/esempi2/stdout</stdout><stderr>/home/scope/esempi2/stderr</stderr> > <count>1</count><fileStageIn> <transfer> > <sourceUrl>gsiftp://job.submitting.host:2811/home/scope/esempi2/test.dat</sourceUrl> > > <destinationUrl>file:///home/scope/esempi2/esercizio_2/test.dat</destinationUrl> > </transfer> </fileStageIn> <fileStageOut> <transfer> > <sourceUrl>file:///home/scope/esempi2/esercizio_2/test.dat</sourceUrl> > <destinationUrl>gsiftp://job.submitting.host:2811/home/scope/esempi2/test.dat</destinationUrl> > </transfer> </fileStageOut></job> > ----------------------------------- > > //Java class that use GramJob to submit a job > //with a specified RSL : > > > > package esercizio_2; > > import javax.xml.namespace.QName; > import org.globus.exec.client.GramJob; > import org.globus.wsrf.impl.*; > import org.apache.axis.components.uuid.UUIDGen; > import org.apache.axis.components.uuid.UUIDGenFactory; > import org.apache.axis.message.addressing.ReferencePropertiesType; > import org.apache.axis.message.addressing.EndpointReferenceType; > import org.apache.axis.message.addressing.Address; > import org.globus.exec.client.GramJobListener; > import org.globus.exec.generated.StateEnumeration; > import org.globus.exec.utils.ManagedJobConstants; > import org.globus.wsrf.impl.security.authentication.Constants; > import org.globus.wsrf.impl.security.authorization.HostAuthorization; > import org.globus.wsrf.impl.security.authorization.Authorization; > import org.globus.wsrf.impl.SimpleResourceKey; > import java.lang.*; > import java.io.*; > > > public class Submitter2 { > > /* -- Attributi -- */ > private static Object waiter=new Object(); > private Listener2 listener=new Listener2(waiter); > > /* -- Metodi -- */ > public void submitjob() throws Exception { > > //[ .........................] > > > /* Creazione Endpoint del servizio */ > > EndpointReferenceType endpoint=new EndpointReferenceType(); > endpoint.setAddress(new > Address("http://192.168.1.10:8080/wsrf/services"; > +"/ManagedJobFactoryService")); > ReferencePropertiesType properties = new ReferencePropertiesType(); > SimpleResourceKey key = new > SimpleResourceKey(ManagedJobConstants.RESOURCE_KEY_QNAME,"Fork"); > properties.add(key.toSOAPElement()); > endpoint.setProperties(properties); > > /* Determinzione dell'RSL */ > > String rsl=new String(); > > rsl="<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n <job>\n" > > +"<executable>/home/scope/esempi2/esercizio_2/readwrite.out</executable>\n" > +"<directory>/home/scope/esempi2/esercizio_2</directory>\n" > +"<stdin>/dev/null</stdin>\n > <stdout>/home/scope/esempi2/stdout</stdout>\n" > +"<stderr>/home/scope/esempi2/stderr</stderr>\n > <count>1</count>\n" > +"<fileStageIn>\n <transfer>\n <sourceUrl>" > > +"gsiftp://192.168.1.10:2811/home/scope/esempi2/test.dat</sourceUrl>\n" > +"<destinationUrl>file://" > > +"/home/scope/esempi2/esercizio_2/test.dat</destinationUrl>\n" > +"</transfer>\n </fileStageIn>\n <fileStageOut>\n > <transfer>\n <sourceUrl>" > +"file:///home/scope/esempi2/esercizio_2/test.dat" > +"</sourceUrl>\n <destinationUrl>" > > +"gsiftp://192.168.1.10:2811/home/scope/esempi2/test.dat</destinationUrl>\n" > +"</transfer>\n </fileStageOut>\n" > +"</job>"; > > System.out.println("L'RSL usato é :\n"+rsl+"\n"); > > /* Sicurezza */ > Authorization authz=HostAuthorization.getInstance(); > Integer xmlSecurity=Constants.ENCRYPTION; > > /* Generazione dell'id del job */ > UUIDGen uuidgen=UUIDGenFactory.getUUIDGen(); > String submissionID ="uuid:"+uuidgen.nextUUID(); > System.out.println(submissionID); > > /* Crerazione del job e sottomissione */ > org.globus.exec.client.GramJob job=new > org.globus.exec.client.GramJob(rsl); > job.addListener(listener); > job.submit(endpoint, false,false,submissionID); > > /* Attesa fine Job */ > synchronized(waiter){waiter.wait();} > > > } > > } > > > > Thanks in advance > Andrea > > > _________________________________________________________________ > Organizza le tue foto e condividile con i tuoi amici con Raccolta foto di > Windows Live! > http://www.windowslive.it
