---

dataservermpi.h

Go to the documentation of this file.

//**************************************************************************
#ifndef _DATASERVERMPI_H_
#define _DATASERVERMPI_H_
//**************************************************************************
#include "dataserver.h"
//**************************************************************************
class DataServerMPI : public DataServer
{
private:
        int comm_dataserver;
        int numCPUs;
        int procID;
        int portNum;
        bool isMaster()
                { return (procID == 0); }
        void Barrier();
        void BroadcastData(void *var, int size);
        bool isRunningMPI()
                { return true; }
        int RegisterInternal(char *keyword, RemoteSocket *C, int &error_flag, bool register_flag = false);

//      void GetKeyword(RemoteSocket *C, char *key);
//      int AcceptClient();

public:
        DataServerMPI();
        DataServerMPI(int port);
        int Start(int port = 4096);
        ~DataServerMPI();
        int Wait(char *key);
        int Post(char *key);
        int Synchronize(char *filename = NULL);
        template <class Etype>
                Etype Update(Etype *var);
        template <class Etype>
                Etype Update(Etype var);
};
//**************************************************************************
template <class Etype>
Etype DataServerMPI::Update(Etype *var)
{
BroadcastVariable(var);
//Barrier();
return *var;
}
//**************************************************************************
template <class Etype>
Etype DataServerMPI::Update(Etype var)
{
Etype v = var;
BroadcastVariable(&v);
//Barrier();
return v;
}
//**************************************************************************
#endif  // _DATASERVERMPI_H_
//**************************************************************************

---