org.objectweb.proactive.mpi.control
Class ProActiveMPIComm

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

public class ProActiveMPIComm
extends java.lang.Object

Nested Class Summary

protected class

ProActiveMPIComm.MessageRecvHandler This class reads all messages from the message queue C2S

Constructor Summary

ProActiveMPIComm()

ProActiveMPIComm(java.lang.String libName, int uniqueID)

Method Summary

void	asleepThread()
void	closeAllSRQueues()
void	closeQueues()
void	createRecvThread()
void	createThread()
int	getMyRank()
void	init(int uniqueID)
void	initQueues()
int	proActiveSendRequest(ProActiveMPIData m_r, byte[] bs)
void	receiveFromMpi(ProActiveMPIData m_r)
void	receiveFromProActive(ProActiveMPIData m_r)
void	sendJobNumber(int jobNumber)
void	sendJobNumberAndRegister()
void	setMyProxy(ProActiveMPICoupling myProxy, ProActiveMPIManager jobManager, int idJob)
java.lang.String	toString()
void	wakeUpThread()

Methods inherited from class java.lang.Object

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

Constructor Detail

ProActiveMPIComm

public ProActiveMPIComm()

ProActiveMPIComm

public ProActiveMPIComm(java.lang.String libName,
                        int uniqueID)

Method Detail

proActiveSendRequest

public int proActiveSendRequest(ProActiveMPIData m_r,
                                byte[] bs)

initQueues

public void initQueues()

closeQueues

public void closeQueues()

closeAllSRQueues

public void closeAllSRQueues()

createRecvThread

public void createRecvThread()

createThread

public void createThread()

sendJobNumberAndRegister

public void sendJobNumberAndRegister()

wakeUpThread

public void wakeUpThread()

asleepThread

public void asleepThread()

setMyProxy

public void setMyProxy(ProActiveMPICoupling myProxy,
                       ProActiveMPIManager jobManager,
                       int idJob)

init

public void init(int uniqueID)

receiveFromProActive

public void receiveFromProActive(ProActiveMPIData m_r)

sendJobNumber

public void sendJobNumber(int jobNumber)

receiveFromMpi

public void receiveFromMpi(ProActiveMPIData m_r)

getMyRank

public int getMyRank()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object