org.objectweb.proactive.mpi.control
Class ProActiveMPICoupling

java.lang.Object
  org.objectweb.proactive.mpi.control.ProActiveMPICoupling

All Implemented Interfaces:

java.io.Serializable, Active, InitActive

public class ProActiveMPICoupling
extends java.lang.Object
implements java.io.Serializable, InitActive

See Also:

Serialized Form

Constructor Summary

ProActiveMPICoupling()

ProActiveMPICoupling(java.lang.String libName, ProActiveMPIManager manager, java.lang.Integer jobNum)

Method Summary

void	allSendToMpi(int jobID, ProActiveMPIData m_r)
void	createRecvThread()
Node	getNode()
void	initActivity(Body body) Initializes the activity of the active object.
Ack	initEnvironment()
static void	MPISend(byte[] buf, int count, int datatype, int dest, int tag, int jobID)
void	notifyProxy(java.util.Hashtable jobList, java.util.Hashtable groupList, java.util.Hashtable userProxyMap)
void	receiveFromMpi(ProActiveMPIData m_r)
void	receiveFromProActive(ProActiveMPIData m_r)
void	register()
void	register(int rank)
void	registerProcess(int rank)
void	sendToMpi(int jobID, ProActiveMPIData m_r)
Ack	sendToMpi(int jobID, ProActiveMPIData m_r, boolean b)
void	sendToProActive(int jobID, ProActiveMPIData m_r)
java.lang.String	toString()
void	unregisterProcess(int rank)
void	wakeUpThread()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ProActiveMPICoupling

public ProActiveMPICoupling()

ProActiveMPICoupling

public ProActiveMPICoupling(java.lang.String libName,
                            ProActiveMPIManager manager,
                            java.lang.Integer jobNum)
                     throws ActiveObjectCreationException,
                            NodeException,
                            java.lang.ClassNotFoundException,
                            java.lang.InstantiationException,
                            java.lang.IllegalAccessException

Throws:

ActiveObjectCreationException

NodeException

java.lang.ClassNotFoundException

java.lang.InstantiationException

java.lang.IllegalAccessException

Method Detail

initActivity

public void initActivity(Body body)

Description copied from interface: InitActive

Initializes the activity of the active object.

Specified by:

initActivity in interface InitActive

Parameters:

body - the body of the active object being initialized

registerProcess

public void registerProcess(int rank)

register

public void register()

register

public void register(int rank)

unregisterProcess

public void unregisterProcess(int rank)

receiveFromMpi

public void receiveFromMpi(ProActiveMPIData m_r)

receiveFromProActive

public void receiveFromProActive(ProActiveMPIData m_r)

sendToMpi

public void sendToMpi(int jobID,
                      ProActiveMPIData m_r)
               throws java.io.IOException

Throws:

java.io.IOException

sendToMpi

public Ack sendToMpi(int jobID,
                     ProActiveMPIData m_r,
                     boolean b)
              throws java.io.IOException

Throws:

java.io.IOException

MPISend

public static void MPISend(byte[] buf,
                           int count,
                           int datatype,
                           int dest,
                           int tag,
                           int jobID)

initEnvironment

public Ack initEnvironment()

createRecvThread

public void createRecvThread()

notifyProxy

public void notifyProxy(java.util.Hashtable jobList,
                        java.util.Hashtable groupList,
                        java.util.Hashtable userProxyMap)

wakeUpThread

public void wakeUpThread()

getNode

public Node getNode()
             throws NodeException

Throws:

NodeException

allSendToMpi

public void allSendToMpi(int jobID,
                         ProActiveMPIData m_r)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

sendToProActive

public void sendToProActive(int jobID,
                            ProActiveMPIData m_r)
                     throws java.lang.IllegalArgumentException,
                            java.lang.IllegalAccessException,
                            java.lang.reflect.InvocationTargetException,
                            java.lang.SecurityException,
                            java.lang.NoSuchMethodException,
                            java.lang.ClassNotFoundException

Throws:

java.lang.IllegalArgumentException

java.lang.IllegalAccessException

java.lang.reflect.InvocationTargetException

java.lang.SecurityException

java.lang.NoSuchMethodException

java.lang.ClassNotFoundException