BspCentral.hpp

Go to the documentation of this file.

#ifndef BspCentral_HPP
#define BspCentral_HPP


#include <map>

#include <vector>


#include "BspProxyStubPool.hpp"
#include "Registration.hpp"
#include "BspPut.hpp"
#include "DrmaManager.hpp"

#include "utils/c++/Config.hpp"
#include "utils/c++/GuardedVariable.hpp"
#include "utils/c++/Condition.hpp"

using namespace std;

class DrmaManager;

  class BspCentral{

    private:

      //Fields--------------------------------------------------------------------------
      BspProxyStubPool stubPool;            
      std::map<int, std::string> tasks;     
      std::map<int, std::string> iors;      
      int myPid;                            
      int totalNumProcs;                    
      GuardedVariable<int> superstep;       
      GuardedVariable<int> synchedProcecess;
      GuardedVariable<int> pids;            
      DrmaManager drmaManager;              
      pthread_mutex_t bspSynchLock;         
      Condition globalInitDone;             
      Condition synchDone;                  
      //Methods--------------------------------------------------------------------------

      int getNextPid();

      string getIor(int taskNum);

      string getTaskId(int taskNum);

    public:


      BspCentral(Config & config);




      void registerRemoteIor(int pid, string ior);

      void takeYourPid(int pid);

      void waitGlobalInit();

      void initSlave(string processZeroIor);

      int getPid(){ return myPid; }

      void setPid(int pid_){ myPid = pid_; }

      void setTotalNumProcs(int numProcs){ totalNumProcs = numProcs; }
      
      int  getTotalNumProcs(){ return totalNumProcs; }

      string getIor();

      void bspPut(int pid, void * src, void * dst, int offset, int nBytes);

      void bspSynch();

      void bspSynchDone();

      void bspLocalSynch();

      void addPendingPut(const BspPut & bspPut);


      void addPendingRegistration(void * ident, int size);


      void addPendingDeregistration(void * ident);

      void bspEnd();

      void bspGet(int pid, void * src, int offset, void * dst, int nBytes);

      void bspGetRequest(const BspGetRequest & request);

      void bspGetReply(const BspGetReply & reply);

      void bspGetReplyFowarder(const int & pid, const BspGetReply & reply);


  };

#endif//BspCentral_HPP

---