« Return to Thread: Re: Master/Slave API

RE: Master/Slave API

by Fabio Luiz Tumiatti :: Rate this Message:

Reply to Author | View in Thread

Some parts of this message have been removed. Learn more about Nabble's security policy.

Hi Fabien,

 

I found the reason for the first problem (Couldnt add the specified resources java.lang.NullPointerException). The class NativeExample calls the init(String[] args) method from class AbstractExample. This method calls the init(String[] args, int number_of_extra_parameters, String text) method sending the parameter number_of_parameters (2) as number_of_extra_parameters. I think this number must be “0”, otherwise the method will return MalformedURLException and won’t initialize the arguments.

 

Now with this bug fixed, I receive the following error:

 

--> This ClassFileServer is reading resources from classpath 2026

Created a new registry on port 1099

rmi://ES-3DDPT2J.es.int.atosorigin.com:1099/Node27297982 successfully bound in registry at rmi://ES-3DDPT2J.es.int.atosorigin.com:1099/Node27297982

Generating class : pa.stub.org.objectweb.proactive.extra.masterslave.core._StubAOMaster

Generating class : pa.stub.org.objectweb.proactive.extra.masterslave.core._StubAOSlave

Generating class : pa.stub.org.objectweb.proactive.extra.masterslave.core._StubAOSlaveManager

Generating class : pa.stub.org.objectweb.proactive.extra.masterslave.core._StubAOPinger

************* Reading deployment descriptor: file:/D:/workspaces/ProActive/src/org/objectweb/proactive/examples/masterslave/RSHListbyHost_Example.xml ********************

created VirtualNode name=matrixNode

rmi://ES-3DDPT2J.es.int.atosorigin.com:1099/matrixNode520007668 successfully bound in registry at rmi://ES-3DDPT2J.es.int.atosorigin.com:1099/matrixNode520007668

**** Mapping VirtualNode matrixNode with Node: rmi://ES-3DDPT2J.es.int.atosorigin.com:1099/matrixNode520007668 done

Generating class : pa.stub.org.objectweb.proactive.extra.masterslave.interfaces.internal._StubTaskIntern

ES-3DDPT2J

ES-3DDPT2J

ES-3DDPT2J

ES-3DDPT2J

ES-3DDPT2J

ES-3DDPT2J

ES-3DDPT2J

ES-3DDPT2J

ES-3DDPT2J

ES-3DDPT2J

ES-3DDPT2J

ES-3DDPT2J

ES-3DDPT2J

ES-3DDPT2J

ES-3DDPT2J

ES-3DDPT2J

ES-3DDPT2J

ES-3DDPT2J

ES-3DDPT2J

ES-3DDPT2J

Generating class : pa.stub.org.objectweb.proactive.core.util.wrapper._StubBooleanWrapper

NFE in a Body

NFE[rmi://ES-3DDPT2J.es.int.atosorigin.com:1099/Node27297982]: SendReplyCommunicationException: Exception occured in while sending reply to request = terminate: IOException: The body has been Terminated

       at org.objectweb.proactive.core.body.BodyImpl$ActiveLocalBodyStrategy.serveInternal(BodyImpl.java:518)

       at org.objectweb.proactive.core.body.BodyImpl$ActiveLocalBodyStrategy.serve(BodyImpl.java:394)

       at org.objectweb.proactive.core.body.AbstractBody.serve(AbstractBody.java:800)

       at org.objectweb.proactive.core.body.request.RequestReceiverImpl.receiveRequest(RequestReceiverImpl.java:79)

       at org.objectweb.proactive.core.body.BodyImpl.internalReceiveRequest(BodyImpl.java:263)

       at org.objectweb.proactive.core.body.AbstractBody.receiveRequest(AbstractBody.java:291)

       at org.objectweb.proactive.core.body.request.RequestImpl.sendRequest(RequestImpl.java:315)

       at org.objectweb.proactive.core.body.request.RequestImpl.send(RequestImpl.java:163)

       at org.objectweb.proactive.core.body.BodyImpl$ActiveLocalBodyStrategy.sendRequest(BodyImpl.java:548)

       at org.objectweb.proactive.core.body.AbstractBody.sendRequest(AbstractBody.java:843)

       at org.objectweb.proactive.core.body.proxy.UniversalBodyProxy.sendRequestInternal(UniversalBodyProxy.java:339)

       at org.objectweb.proactive.core.body.proxy.UniversalBodyProxy.sendRequest(UniversalBodyProxy.java:313)

       at org.objectweb.proactive.core.body.proxy.UniversalBodyProxy.sendRequest(UniversalBodyProxy.java:267)

       at org.objectweb.proactive.core.body.proxy.AbstractBodyProxy.reifyAsAsynchronous(AbstractBodyProxy.java:267)

       at org.objectweb.proactive.core.body.proxy.AbstractBodyProxy.invokeOnBody(AbstractBodyProxy.java:144)

       at org.objectweb.proactive.core.body.proxy.AbstractBodyProxy.reify(AbstractBodyProxy.java:119)

       at pa.stub.org.objectweb.proactive.extra.masterslave.core._StubAOSlave.terminate(_StubAOSlave.java)

       at org.objectweb.proactive.extra.masterslave.core.AOSlaveManager.freeSlave(AOSlaveManager.java:184)

       at org.objectweb.proactive.extra.masterslave.core.AOSlaveManager.freeSlaves(AOSlaveManager.java:197)

       at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

       at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)

       at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)

       at java.lang.reflect.Method.invoke(Unknown Source)

       at org.objectweb.proactive.core.mop.MethodCall.execute(MethodCall.java:421)

       at org.objectweb.proactive.core.body.request.RequestImpl.serveInternal(RequestImpl.java:242)

       at org.objectweb.proactive.core.body.request.RequestImpl.serve(RequestImpl.java:174)

       at org.objectweb.proactive.core.body.BodyImpl$ActiveLocalBodyStrategy.serveInternal(BodyImpl.java:414)

       at org.objectweb.proactive.core.body.BodyImpl$ActiveLocalBodyStrategy.serve(BodyImpl.java:394)

       at org.objectweb.proactive.core.body.AbstractBody.serve(AbstractBody.java:800)

       at org.objectweb.proactive.Service.blockingServeOldest(Service.java:191)

       at org.objectweb.proactive.Service.blockingServeOldest(Service.java:166)

       at org.objectweb.proactive.Service.fifoServing(Service.java:142)

       at org.objectweb.proactive.core.body.ActiveBody$FIFORunActive.runActivity(ActiveBody.java:286)

       at org.objectweb.proactive.core.body.ActiveBody.run(ActiveBody.java:168)

       at java.lang.Thread.run(Unknown Source)

Caused by: java.io.IOException: The body has been Terminated

       at org.objectweb.proactive.core.body.AbstractBody.receiveReply(AbstractBody.java:321)

       at org.objectweb.proactive.core.body.reply.ReplyImpl.send(ReplyImpl.java:147)

       at org.objectweb.proactive.core.body.BodyImpl$ActiveLocalBodyStrategy.serveInternal(BodyImpl.java:509)

       ... 34 more

Exception in thread "main" NFE[rmi://ES-3DDPT2J.es.int.atosorigin.com:1099/Node27297982]: SendRequestCommunicationException: Exception occured in reifyAsAsynchronous while sending request for methodcall = terminate: IOException: The body has been Terminated

       at org.objectweb.proactive.core.body.proxy.AbstractBodyProxy.reifyAsAsynchronous(AbstractBodyProxy.java:272)

       at org.objectweb.proactive.core.body.proxy.AbstractBodyProxy.invokeOnBody(AbstractBodyProxy.java:144)

       at org.objectweb.proactive.core.body.proxy.AbstractBodyProxy.reify(AbstractBodyProxy.java:119)

       at pa.stub.org.objectweb.proactive.extra.masterslave.core._StubAOSlaveManager.terminate(_StubAOSlaveManager.java)

       at org.objectweb.proactive.extra.masterslave.core.AOMaster.terminateIntern(AOMaster.java:449)

       at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

       at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)

       at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)

       at java.lang.reflect.Method.invoke(Unknown Source)

       at org.objectweb.proactive.core.mop.MethodCall.execute(MethodCall.java:421)

       at org.objectweb.proactive.core.body.request.RequestImpl.serveInternal(RequestImpl.java:242)

       at org.objectweb.proactive.core.body.request.RequestImpl.serve(RequestImpl.java:174)

       at org.objectweb.proactive.core.body.BodyImpl$ActiveLocalBodyStrategy.serveInternal(BodyImpl.java:414)

       at org.objectweb.proactive.core.body.BodyImpl$ActiveLocalBodyStrategy.serve(BodyImpl.java:394)

       at org.objectweb.proactive.core.body.AbstractBody.serve(AbstractBody.java:800)

       at org.objectweb.proactive.Service.serveOldest(Service.java:238)

       at org.objectweb.proactive.extra.masterslave.core.AOMaster.runActivity(AOMaster.java:317)

       at org.objectweb.proactive.core.body.ActiveBody.run(ActiveBody.java:168)

       at java.lang.Thread.run(Unknown Source)

Caused by: java.io.IOException: The body has been Terminated

       at org.objectweb.proactive.core.body.AbstractBody.receiveRequest(AbstractBody.java:269)

       at org.objectweb.proactive.core.body.request.RequestImpl.sendRequest(RequestImpl.java:315)

       at org.objectweb.proactive.core.body.request.RequestImpl.send(RequestImpl.java:163)

       at org.objectweb.proactive.core.body.BodyImpl$ActiveLocalBodyStrategy.sendRequest(BodyImpl.java:548)

       at org.objectweb.proactive.core.body.AbstractBody.sendRequest(AbstractBody.java:843)

       at org.objectweb.proactive.core.body.proxy.UniversalBodyProxy.sendRequestInternal(UniversalBodyProxy.java:339)

       at org.objectweb.proactive.core.body.proxy.UniversalBodyProxy.sendRequest(UniversalBodyProxy.java:320)

       at org.objectweb.proactive.core.body.proxy.UniversalBodyProxy.sendRequest(UniversalBodyProxy.java:267)

       at org.objectweb.proactive.core.body.proxy.AbstractBodyProxy.reifyAsAsynchronous(AbstractBodyProxy.java:267)

       ... 18 more

 

 

Se attached the deployment file used for this test.

 

Thank you.

 

Best regards,

Fabio Tumiatti

Atos Origin

 

 

-----Original Message-----
From: Fabien Viale [mailto:Fabien.Viale@...]
Sent: viernes, 01 de junio de 2007 17:52
To: Fabio Luiz Tumiatti
Cc: Fabien Viale; Cedric Dalmasso; proactive@...
Subject: Re: Master/Slave API

 

Hi Fabio,

 

I updated the code on the SVN to print a stack trace where you

experience the problem.

 

Could you please update your code and then give me the stack trace ?

 

Thanks in advance,

 

Regards,

 

Fabien Viale

 

Fabio Luiz Tumiatti a écrit :

> 

> Hi Fabien,

> 

> 

> I updated the my src code, but I still have the same problem:

> 

> 

> Couldnt add the specified resources java.lang.NullPointerException

> 

> 

> I am providing the followings parameters:

> 

> 

> D:\workspaces\ProActive\src\org\objectweb\proactive\examples\masterslave\RSHListbyHost_Example.xml

> matrixNode

> 

> 

> Att,

> 

> Tumiatti

> 

> 

> -----Original Message-----

> From: Fabien Viale [mailto:Fabien.Viale@...]

> Sent: jueves, 31 de mayo de 2007 18:38

> To: Fabio Luiz Tumiatti

> Cc: Fabien Viale; Cedric Dalmasso

> Subject: Re: Master/Slave API

> 

> 

> Hi Fabio,

> 

> 

> There was a little mistake in the AbstractExample base class of the

> 

> example. I fixed it now on the SVN.

> 

> 

> Remember that you need to provide the fullpath to the descriptor used

> 

> and the name of the virtual node to the example.

> 

> 

> Cheers,

> 

> 

> Fabien Viale

> 

> 

> Fabio Luiz Tumiatti a écrit :

> 

> > Hi Fabien and Cedric.

> 

> >

> 

> > I was testing the Master/Slave API using the NativeExample.java example

> 

> > and it didn't work.

> 

> >

> 

> > I changed the deployment file (RSHListbyHost_Example.xml) to use my

> 

> > local machine.

> 

> >

> 

> > When I execute the example I receive the following error:

> 

> >

> 

> > Couldnt add the specified resources java.lang.NullPointerException

> 

> >

> 

> > Any idea what is happening?

> 

> >

> 

> > Thank you.

> 

> > Fabio Tumiatti

> 

> >

> 

> > -----Original Message-----

> 

> > From: Fabien Viale [mailto:Fabien.Viale@...]

> 

> > Sent: jueves, 31 de mayo de 2007 10:10

> 

> > To: Fabio Luiz Tumiatti

> 

> > Cc: Fabien Viale; Cedric Dalmasso

> 

> > Subject: Re: Master/Slave API

> 

> >

> 

> > Hi Fabio,

> 

> >

> 

> > Feel free to ask, whenever you have doubts,

> 

> >

> 

> > Cheers,

> 

> >

> 

> > Fabien Viale

> 

> >

> 

> >

> 

> > ------------------------------------------------------------------

> 

> > This e-mail and the documents attached are confidential and intended

> solely

> 

> > for the addressee; it may also be privileged. If you receive this e-mail

> 

> > in error, please notify the sender immediately and destroy it.

> 

> > As its integrity cannot be secured on the Internet, the Atos Origin group

> 

> > liability cannot be triggered for the message content. Although the

> 

> > sender endeavours to maintain a computer virus-free network, the

> sender does

> 

> > not warrant that this transmission is virus-free and will not be

> liable for

> 

> > any damages resulting from any virus transmitted.

> 

> >

> 

> > Este mensaje y los ficheros adjuntos pueden contener informacion

> 

> > confidencial destinada solamente a la(s) persona(s) mencionadas

> 

> > anteriormente. Pueden estar protegidos por secreto profesional Si usted

> 

> > recibe este correo electronico por error, gracias de informar

> inmediatamente

> 

> > al remitente y destruir el mensaje.

> 

> > Al no estar asegurada la integridad de este mensaje sobre la red, Atos

> 

> > Origin no se hace responsable por su contenido. Su contenido no

> constituye

> 

> > ningun compromiso para el grupo Atos Origin, salvo ratificacion

> escrita por

> 

> > ambas partes.

> 

> > Aunque se esfuerza al maximo por mantener su red libre de virus, el

> emisor

> 

> > no puede garantizar nada al respecto y no sera responsable de

> cualesquiera

> 

> > danos que puedan resultar de una transmision de virus

> 

> > ------------------------------------------------------------------

> 

> > 

> 

> 

> 

> --

> 

> Fabien Viale

> 

> Software Engineer

> 

> OASIS Project

> 

> INRIA - 2004 rte des Lucioles - BP 93

> 

> 06902 Sophia Antipolis - France

> 

> Tel. +33492387931

> 

> 

> 

 

 

--

Fabien Viale

Software Engineer

OASIS Project

INRIA - 2004 rte des Lucioles - BP 93

06902 Sophia Antipolis - France

Tel. +33492387931

 


<?xml version="1.0" encoding="UTF-8"?>
<ProActiveDescriptor
        xmlns="urn:proactive:deployment:3.3"
        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
        xsi:schemaLocation="urn:proactive:deployment:3.3 http://www-sop.inria.fr/oasis/ProActive/schemas/deployment/3.3/deployment.xsd">
        <variables>
                <descriptorVariable name="PROACTIVE_HOME" value="/user/fviale/home/eclipse_workspace/ProActive_Latest"/> <!--ProActive home , CHANGE ME!!!! -->
                <descriptorVariable name="JAVA_HOME"
                        value="/user/fviale/home/bin/jdk1.5.0" /><!-- Path of the remote JVM , CHANGE ME!!!! -->
                <descriptorVariable name="ID" value="6608"/><!-- RMI Port , CHANGE ME!!!! -->
        </variables>
        <componentDefinition>
                <virtualNodesDefinition>
                        <virtualNode name="matrixNode" property="multiple" />
                </virtualNodesDefinition>
        </componentDefinition>
        <deployment>
                <mapping>
                        <map virtualNode="matrixNode">
                                <jvmSet>
                                        <currentJVM/>
                                        <!-- <vmName value="Jvm1" /> -->
                                </jvmSet>
                        </map>
                </mapping>
                <jvms>
                        <jvm name="Jvm1">
                                <creation>
                                        <processReference refid="rsh_list" />
                                </creation>
                        </jvm>
                </jvms>
        </deployment>
        <infrastructure>
                <processes>
                        <processDefinition id="localJVM">
                                <jvmProcess class="org.objectweb.proactive.core.process.JVMNodeProcess">
                                        <classpath>
                                                <absolutePath value="${PROACTIVE_HOME}/classes/Core"/>
                                                <absolutePath value="${PROACTIVE_HOME}/classes/Extra"/>
                                                <absolutePath value="${PROACTIVE_HOME}/classes/Examples"/>
                                                <absolutePath value="${PROACTIVE_HOME}/lib/javassist.jar"/>
                                                <absolutePath value="${PROACTIVE_HOME}/lib/bouncycastle.jar"/>
                                                <absolutePath value="${PROACTIVE_HOME}/lib/components/fractal.jar"/>
                                                <absolutePath value="${PROACTIVE_HOME}/lib/log4j.jar"/>
                                                <absolutePath value="${PROACTIVE_HOME}/lib/xercesImpl.jar"/>
                                        </classpath>
                                        <javaPath>
                                                <absolutePath value="${JAVA_HOME}/bin/java"/>
                                        </javaPath>
                                        <policyFile>
                                                <absolutePath value="${PROACTIVE_HOME}/scripts/proactive.java.policy"/>
                                        </policyFile>
                                        <log4jpropertiesFile>
                                                <absolutePath value="${PROACTIVE_HOME}/scripts/proactive-log4j"/>
                                        </log4jpropertiesFile>
                                        <jvmParameters>
                                                <parameter value="-Dproactive.rmi.port=${ID}"/>
                                                <parameter value="-Xms64m -Xmx512m "/>
                                                <parameter value="-Dsun.rmi.server.exceptionTrace=true"/>
                                        </jvmParameters>
                                </jvmProcess>
                        </processDefinition>
                        <processDefinition id="rsh_list">
                                <processListbyHost
                                        class="org.objectweb.proactive.core.process.rsh.RSHProcessList"
                                        hostlist="amda anaconda apple cheypa crios crusoe duff galpage gaudi hajjoura lo maledie meije naruto petawawa pollux psychoquack schubby sidonie tranquility trinidad nyx pincoya">
                                        <processReference refid="localJVM"></processReference>
                                </processListbyHost>
                        </processDefinition>
                </processes>
        </infrastructure>
</ProActiveDescriptor>


--
You receive this message as a subscriber of the proactive@... mailing list.
To unsubscribe: mailto:proactive-unsubscribe@...
For general help: mailto:sympa@...?subject=help
ObjectWeb mailing lists service home page: http://www.objectweb.org/wws

 « Return to Thread: Re: Master/Slave API