DrmaManager.hpp

Go to the documentation of this file.

#ifndef DrmaManager_HPP
#define DrmaManager_HPP

#include "Registration.hpp"
#include "Deregistration.hpp"
#include "BspPut.hpp"
#include "BspGetRequest.hpp"
#include "BspGetReply.hpp"
//#include "BspCentral.hpp"

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


#include <vector>
#include <pthread.h>

using namespace std;

class BspCentral;//For cross-referencing to work


  class DrmaManager{

   private:

      //Fields------------------------------------------------------------------------------

      std::vector<Registration> registrations;           
      std::vector<Registration> pendingRegistrations;    
      std::vector<Deregistration> pendingDeregistrations;
      std::vector<BspPut> pendingPuts;            
      std::vector<BspGetRequest> pendingGetRequests;    
      std::vector<BspGetReply> pendingGetReplies;       
      GuardedVariable<int> superstep_;                   
      pthread_mutex_t pendingRegistrationsLock;          
      pthread_mutex_t pendingDeregistrationsLock;        
      pthread_mutex_t pendingPutsLock;                   
      pthread_mutex_t pendingGetRequestsLock;            
      pthread_mutex_t pendingGetRepliesLock;             
      GuardedVariable<int> pendingGetRepliesCount;       
      Condition noPendingGetReplies;                    
      BspCentral * bspCentral_;                         
      //Methods----------------------------------------------------------------------------

      void commitPendingGetRequests();

      void commitPendingGetReplies();

      void commitRegistrations();

      void commitDeregistrations();

      void commitPendingPuts();

      void deregister(Deregistration & dereg);



  public:

      void addPendingRegistration(void * ptr, int size);

      //TODO: I suppose that removeRegistration should remove the LAST INSERTED
      //registration of a given memory address. It is not clear, though, if this
      //is the correct behavior
      void addPendingDeregistration(void * ptr);

      DrmaManager(BspCentral  * bspCentral);

      void addPendingPut(const BspPut & bspPut);



      int findLastRegistration(void * ptr);

      Registration & getRegistration(int pos);

      void processPendingOperations();

      void incSuperstep(){ superstep_.inc(); }

      int superstep(){ return superstep_.value(); }

      void incPendingGetReplies(){pendingGetRepliesCount.inc(); }

      void addPendingGetRequest(const BspGetRequest & request);

      void addPendingGetReply(const BspGetReply & reply);




  };

#endif//DrmaManager_HPP

---