communicate.h

Go to the documentation of this file.

#ifndef _COMMUNICATE_H_
#define _COMMUNICATE_H_
#include "definitions.h"

struct MpiCom
{
MPI_Comm mpicom; 
integer myrank; 
integer comsize; 
MpiCom() {};     
MpiCom(MPI_Comm Com); 
};

struct Message  
{
uint count; 
int tag; 
uint sender; 
uint reciever; 
void *buf; 
MPI_Datatype datatype; /*<! Templated using template initialization */
MPI_Status status;  
MPI_Request request; 

void print() 
{
cout<<RED "count "<<count<<endl;
cout<<"tag "<<tag<<endl;
cout<<"sender "<<sender<<endl;
cout<<"reciever " <<reciever<<endl;
cout<<"Datatype " RESET<<datatype<<endl;

};

};

template <class Type>
class CommPoint2Point
{
private:
MpiCom Com;
Message Msg;

public:
CommPoint2Point(void *buff,uint size, uint *tg, uint snd, uint rcv, uint type,MPI_Comm com); 
CommPoint2Point(void *buff,uint size, uint snd, uint rcv); 
CommPoint2Point(void *buff,uint size); 
void assignSender(uint sndr); 
void assignReciever(uint rcv);  
integer myRank(); 
integer mySize();
void Irecv();     
void Isend();     
void recv();      
void send();      
//MPI_Request chechRequest();
void getOffset(uint myvalue,uint *offset); 
~CommPoint2Point() {}; 
};

template<class Type>
class CommCollective 
{
    private:
    MpiCom Com;
    Message Msg;

    public:
    CommCollective( void *buf, uint size, uint root); 
    CommCollective(void *buff,uint size);     
    void bcast(); 
    void Ibcast(); 
    void getTotalNumber(uint *offset,uint *myvalue,uint* totalvalue); 
    void IgetTotalNumber(uint *offset,uint *myvalue,uint* totalvalue); 
    void waitOnRequest();
    ~CommCollective() {}; 
};

#endif