ok,

Can you please run

globusrun-ws -submit -job-delegate \
 -F https://141.85.1.213:8443/wsrf/services/ManagedJobFactoryService \
 -dbg -c /bin/date

and send the client-side output.

Also: please start the container in debug mode
(set log4j.category.org.globus=DEBUG in
$GLOBUS_LOCATION/container-log4j.properties)

and send the container logfile too after you submitted the above job.

Martin

> Yes, it works.
>
> [EMAIL PROTECTED] wrote: Silviu,
>
> and it works to that machine if you don't delegate?
>
> Martin
>
>> Hi,
>>
>> I also saw that the problem appears when I run globusrun-ws with
>> -job-delegate .
>>
>> globusrun-ws -submit -job-delegate -F
>> https://141.85.1.213:8443/wsrf/services/ManagedJobFactoryService -c
>> /bin/date
>> Delegating user credentials...Done.
>> Submitting job...Failed.
>> Cleaning up any delegated credentials...Done.
>> globusrun-ws: Error submitting job
>> globus_soap_message_module: Failed receiving response
>> ManagedJobFactoryPortType_createManagedJob.
>> globus_soap_message_module: SOAP Message transport failed: Error in HTTP
>> response
>> globus_xio: Operation was canceled
>>
>>
>> Silviu Popescu  wrote: Hi,
>>
>> I have a simple test client created in java for job submission which I
>> tested before on 4.0.5 containers but now I have some problems
>> submitting
>> a job to a 4.0.6 container.
>> globusrun-ws works fine with the same rls file.
>>
>> On server side:
>> 2008-03-10 20:31:30,794 ERROR factory.ManagedJobFactoryService
>> [ServiceThread-16,createManagedJob:346] Job creation failed.
>> org.globus.wsrf.ResourceException: ; nested exception is:
>>         java.util.MissingResourceException: Can't find resource for
>> bundle
>> java.util.PropertyResourceBundle, key setCredError
>>         at
>> org.globus.exec.service.exec.ManagedExecutableJobResource.initSecurity(ManagedExecutableJobResource.java:362)
>>         at
>> org.globus.exec.service.exec.ManagedExecutableJobResource.initialize(ManagedExecutableJobResource.java:191)
>>         at
>> org.globus.exec.service.exec.ManagedExecutableJobResource.initializeWholeState(ManagedExecutableJobResource.java:162)
>>         at
>> org.globus.exec.service.exec.PersistentManagedExecutableJobResource.initializeWholeState(PersistentManagedExecutableJobResource.java:154)
>>         at
>> org.globus.exec.service.exec.ManagedExecutableJobHome.create(ManagedExecutableJobHome.java:348)
>>         at
>> org.globus.exec.service.factory.ManagedJobFactoryService.createManagedJob(ManagedJobFactoryService.java:296)
>>         at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>>         at
>> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
>>         at
>> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
>>         at java.lang.reflect.Method.invoke(Method.java:597)
>>         at
>> org.apache.axis.providers.java.RPCProvider.invokeMethod(RPCProvider.java:384)
>>         at
>> org.globus.axis.providers.RPCProvider.invokeMethodSub(RPCProvider.java:107)
>>         at
>> org.globus.axis.providers.PrivilegedInvokeMethodAction.run(PrivilegedInvokeMethodAction.java:42)
>>         at java.security.AccessController.doPrivileged(Native Method)
>>         at javax.security.auth.Subject.doAs(Subject.java:396)
>>         at
>> org.globus.gsi.jaas.GlobusSubject.runAs(GlobusSubject.java:55)
>>         at org.globus.gsi.jaas.JaasSubject.doAs(JaasSubject.java:90)
>>         at
>> org.globus.axis.providers.RPCProvider.invokeMethod(RPCProvider.java:97)
>>         at
>> org.apache.axis.providers.java.RPCProvider.processMessage(RPCProvider.java:281)
>>         at
>> org.apache.axis.providers.java.JavaProvider.invoke(JavaProvider.java:319)
>>         at
>> org.apache.axis.strategies.InvocationStrategy.visit(InvocationStrategy.java:32)
>>         at org.apache.axis.SimpleChain.doVisiting(SimpleChain.java:118)
>>         at org.apache.axis.SimpleChain.invoke(SimpleChain.java:83)
>>         at
>> org.apache.axis.handlers.soap.SOAPService.invoke(SOAPService.java:450)
>>         at org.apache.axis.server.AxisServer.invoke(AxisServer.java:285)
>>         at
>> org.globus.wsrf.container.ServiceThread.doPost(ServiceThread.java:664)
>>         at
>> org.globus.wsrf.container.ServiceThread.process(ServiceThread.java:382)
>>         at
>> org.globus.wsrf.container.GSIServiceThread.process(GSIServiceThread.java:153)
>>         at
>> org.globus.wsrf.container.ServiceThread.run(ServiceThread.java:291)
>> Caused by: java.util.MissingResourceException: Can't find resource for
>> bundle java.util.PropertyResourceBundle, key setCredError
>>         at java.util.ResourceBundle.getObject(ResourceBundle.java:384)
>>         at java.util.ResourceBundle.getString(ResourceBundle.java:344)
>>         at org.globus.util.I18n.getMessage(I18n.java:97)
>>         at
>> org.globus.delegation.service.DelegationResource.addListener(DelegationResource.java:214)
>>         at
>> org.globus.delegation.service.DelegationResource.addRefreshListener(DelegationResource.java:187)
>>         at
>> org.globus.delegation.DelegationUtil.registerDelegationListener(DelegationUtil.java:167)
>>         at
>> org.globus.exec.service.utils.DelegatedCredential.getDelegatedCredential(DelegatedCredential.java:179)
>>         at
>> org.globus.exec.service.job.ManagedJobResourceImpl.getJobCredential(ManagedJobResourceImpl.java:421)
>>         at
>> org.globus.exec.service.exec.ManagedExecutableJobResource.initSecurity(ManagedExecutableJobResource.java:354)
>>         ... 28 more
>>
>> On client side:
>> submitting job ...
>> AxisFault
>>  faultCode:
>> {http://schemas.xmlsoap.org/soap/envelope/}Server.userException
>>  faultSubcode:
>>  faultString: java.net.SocketTimeoutException: Read timed out
>>  faultActor:
>>  faultNode:
>>  faultDetail:
>>         
>> {http://xml.apache.org/axis/}stackTrace:java.net.SocketTimeoutException:
>> Read timed out
>>         at java.net.SocketInputStream.socketRead0(Native Method)
>>         at java.net.SocketInputStream.read(SocketInputStream.java:129)
>>         at org.globus.gsi.gssapi.SSLUtil.read(SSLUtil.java:37)
>>         at
>> org.globus.gsi.gssapi.net.impl.GSIGssInputStream.readToken(GSIGssInputStream.java:64)
>>         at
>> org.globus.gsi.gssapi.net.impl.GSIGssInputStream.readMsg(GSIGssInputStream.java:39)
>>         at
>> org.globus.gsi.gssapi.net.GssInputStream.hasData(GssInputStream.java:81)
>>         at
>> org.globus.gsi.gssapi.net.GssInputStream.read(GssInputStream.java:55)
>>         at
>> java.io.BufferedInputStream.fill(BufferedInputStream.java:218)
>>         at
>> java.io.BufferedInputStream.read(BufferedInputStream.java:237)
>>         at
>> org.apache.axis.transport.http.HTTPSender.readHeadersFromSocket(HTTPSender.java:545)
>>         at
>> org.apache.axis.transport.http.HTTPSender.invoke(HTTPSender.java:140)
>>         at
>> org.apache.axis.strategies.InvocationStrategy.visit(InvocationStrategy.java:32)
>>         at org.apache.axis.SimpleChain.doVisiting(SimpleChain.java:118)
>>         at org.apache.axis.SimpleChain.invoke(SimpleChain.java:83)
>>         at org.apache.axis.client.AxisClient.invoke(AxisClient.java:165)
>>         at org.apache.axis.client.Call.invokeEngine(Call.java:2727)
>>         at org.apache.axis.client.Call.invoke(Call.java:2710)
>>         at org.apache.axis.client.Call.invoke(Call.java:2386)
>>         at org.apache.axis.client.Call.invoke(Call.java:2309)
>>         at org.apache.axis.client.Call.invoke(Call.java:1766)
>>         at
>> org.globus.exec.generated.bindings.ManagedJobFactoryPortTypeSOAPBindingStub.createManagedJob(ManagedJobFactoryPortTypeSOAPBindingStub.java:1157)
>>         at
>> org.globus.exec.client.GramJob.createJobEndpoint(GramJob.java:958)
>>         at org.globus.exec.client.GramJob.submit(GramJob.java:464)
>>         at TestSubmit.submitJob(TestSubmit.java:71)
>>         at TestSubmit.main(TestSubmit.java:28)
>>
>>         {http://xml.apache.org/axis/}hostname:silviup-laptop
>>
>> java.net.SocketTimeoutException: Read timed out
>>         at org.apache.axis.AxisFault.makeFault(AxisFault.java:101)
>>         at
>> org.apache.axis.transport.http.HTTPSender.invoke(HTTPSender.java:144)
>>         at
>> org.apache.axis.strategies.InvocationStrategy.visit(InvocationStrategy.java:32)
>>         at org.apache.axis.SimpleChain.doVisiting(SimpleChain.java:118)
>>         at org.apache.axis.SimpleChain.invoke(SimpleChain.java:83)
>>         at org.apache.axis.client.AxisClient.invoke(AxisClient.java:165)
>>         at  org.apache.axis.client.Call.invokeEngine(Call.java:2727)
>>         at org.apache.axis.client.Call.invoke(Call.java:2710)
>>         at org.apache.axis.client.Call.invoke(Call.java:2386)
>>         at org.apache.axis.client.Call.invoke(Call.java:2309)
>>         at org.apache.axis.client.Call.invoke(Call.java:1766)
>>         at
>> org.globus.exec.generated.bindings.ManagedJobFactoryPortTypeSOAPBindingStub.createManagedJob(ManagedJobFactoryPortTypeSOAPBindingStub.java:1157)
>>         at
>> org.globus.exec.client.GramJob.createJobEndpoint(GramJob.java:958)
>>         at org.globus.exec.client.GramJob.submit(GramJob.java:464)
>>         at TestSubmit.submitJob(TestSubmit.java:71)
>>         at TestSubmit.main(TestSubmit.java:28)
>> Caused by: java.net.SocketTimeoutException: Read timed  out
>>         at java.net.SocketInputStream.socketRead0(Native Method)
>>         at java.net.SocketInputStream.read(SocketInputStream.java:129)
>>         at org.globus.gsi.gssapi.SSLUtil.read(SSLUtil.java:37)
>>         at
>> org.globus.gsi.gssapi.net.impl.GSIGssInputStream.readToken(GSIGssInputStream.java:64)
>>         at
>> org.globus.gsi.gssapi.net.impl.GSIGssInputStream.readMsg(GSIGssInputStream.java:39)
>>         at
>> org.globus.gsi.gssapi.net.GssInputStream.hasData(GssInputStream.java:81)
>>         at
>> org.globus.gsi.gssapi.net.GssInputStream.read(GssInputStream.java:55)
>>         at
>> java.io.BufferedInputStream.fill(BufferedInputStream.java:218)
>>         at
>> java.io.BufferedInputStream.read(BufferedInputStream.java:237)
>>         at
>> org.apache.axis.transport.http.HTTPSender.readHeadersFromSocket(HTTPSender.java:545)
>>         at
>> org.apache.axis.transport.http.HTTPSender.invoke(HTTPSender.java:140)
>>         ... 14 more
>>
>> Here is the java client source code :
>> 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.AttributedURI;
>> import  org.apache.axis.message.addressing.EndpointReferenceType;
>> import org.globus.exec.client.GramJob;
>> 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.Authorization;
>> import  org.globus.wsrf.impl.security.authorization.HostAuthorization;
>> import org.globus.wsrf.impl.SimpleResourceKey;
>> import java.io.File;
>>
>>
>> public class TestSubmit implements GramJobListener{
>>            private static Object waiter = new Object();
>>
>>            public static void main(String[] args)
>>             {
>>
>>                TestSubmit client = new TestSubmit();
>>                System.out.print("submitting job ... ");
>>                try {
>>                  client.submitJob();
>>                  System.out.println("done");
>>                  System.out.println("Waiting for notification messages
>> ...");
>>                  synchronized (waiter) {
>>                     waiter.wait();
>>                  }
>>                } catch (Exception e) {
>>                    e.printStackTrace();
>>                }
>>            }
>>
>>            public void submitJob() throws Exception
>>            {
>>               // create factory  epr
>>               EndpointReferenceType endpoint = new
>> EndpointReferenceType();
>>               AttributedURI address= new
>> AttributedURI("https://c13.is.pub.ro/wsrf/services/ManagedJobFactoryService";);
>>               endpoint.setAddress(address);
>>               ReferencePropertiesType props = new
>> ReferencePropertiesType();
>>                SimpleResourceKey key
>>                           = new SimpleResourceKey(
>>                                    ManagedJobConstants.RESOURCE_KEY_QNAME,
>>                                    "Fork");
>>               props.add(key.toSOAPElement());
>>               endpoint.setProperties(props);
>>
>>               // setup security
>>               Authorization authz = HostAuthorization.getInstance();
>>               Integer xmlSecurity = Constants.ENCRYPTION;
>>
>>               boolean batchMode = false;
>>               boolean limitedDelegation = true;
>>
>>               // generate job uuid
>>               UUIDGen uuidgen   = UUIDGenFactory.getUUIDGen();
>>               String submissionID = "uuid:" + uuidgen.nextUUID();
>>
>>               // dam rsl prin fisier
>>               GramJob job = new GramJob(new
>> File("/home/user/job2.xml"));
>>               job.setAuthorization(authz);
>>               job.setMessageProtectionType(xmlSecurity);
>>                job.setDelegationEnabled(true);
>>               job.addListener(this);
>>
>>               job.submit(endpoint,
>>                          batchMode,
>>                          limitedDelegation,
>>                          submissionID);
>>            }
>>
>>            // GramJob calls this method when a job changes its state
>>            // It's part of GramJobListener Interface
>>            public void stateChanged(GramJob job)
>>            {
>>                 StateEnumeration jobState = job.getState();
>>                 System.out.println("   got state notifiation: job is in
>> state " + jobState);
>>                 if (jobState.equals(StateEnumeration.Done)
>>                     || jobState.equals(StateEnumeration.Failed)) {
>>                      System.out.print("job finished. destroying job
>> resource ... ");
>>                     try {
>>                         job.removeListener(this);
>>                         job.destroy();
>>                     } catch (Exception e)  {
>>                        e.printStackTrace();
>>                     } finally {
>>                        System.out.println("done");
>>                        synchronized (waiter) {
>>                             waiter.notify();
>>                        } } } }}
>>
>> Please help I can't find the cause of this errors.
>>
>> Regards,
>>
>>
>>
>> Silviu Popescu
>>
>>
>> Silviu Popescu
>
>
>
>
>
> Silviu Popescu


Reply via email to