Home Research Papers Posters Manuals Talks Download People Help Wiki Internal

libs/ck-libs/pose/rep.h

Go to the documentation of this file.

#ifndef REP_H
#define REP_H
#include "sim.decl.h"

extern CProxy_sim POSE_Objects_RO;

// our configuration bundle
extern POSE_Config pose_config;

class rep 
{
 protected:
  strat *myStrat;          
 public:
#if POSE_COMM_ON
  CProxy_sim POSE_Objects;
#endif
  sim *parent;             

  int myHandle;            
  POSE_TimeType ovt;
  double ort;
  unsigned int prand_seed;
  unsigned short int prand48_seed[3];
  int anti_methods;
#ifdef MEM_TEMPORAL
  TimePool *localTimePool;
#endif
  rep() { 
    ovt = 0; ort = 0.0; parent = NULL; myStrat = NULL; 
    anti_methods = 0;
  #ifndef SEQUENTIAL_POSE
  #ifdef POSE_COMM_ON    
    POSE_Objects = POSE_Objects_RO;
    ComlibDelegateProxy(&POSE_Objects);
  #endif
  #endif
#ifdef MEM_TEMPORAL    
    localTimePool = (TimePool *)CkLocalBranch(TempMemID);
#endif
  }
  rep(POSE_TimeType init_ovt) { 
    ovt = init_ovt; ort = 0.0; anti_methods = 0;
      }
  virtual ~rep() {
     }
  void init(eventMsg *m);
  POSE_TimeType OVT() { return ovt; }
  void SetOVT(POSE_TimeType t) { ovt = t; }
  void useAntimethods() { anti_methods = 1; }
  void turnOffAntimethods() { anti_methods = 0; }
  int usesAntimethods() { return anti_methods; }
  void elapse(POSE_TimeType dt) { ovt += dt; }

  void update(POSE_TimeType t, double rt);
  virtual void terminus() { 
    //CkPrintf("Object %d terminus at time %d\n", myHandle, ovt);
  }
  virtual void registerTimestamp(int idx, eventMsg *m, POSE_TimeType offset);

  virtual rep& operator=(const rep& obj) { 
    ovt = obj.ovt; 
    ort = obj.ort;
    myHandle = obj.myHandle;
    anti_methods = obj.anti_methods;
    prand_seed = obj.prand_seed;
    prand48_seed[0]=obj.prand48_seed[0];
    prand48_seed[1]=obj.prand48_seed[1];
    prand48_seed[2]=obj.prand48_seed[2];
    return *this;
  }
#if USE_LONG_TIMESTAMPS
  virtual void dump() { CkPrintf("[REP: ovt=%lld]\n", ovt); }
#else
  virtual void dump() { CkPrintf("[REP: ovt=%d]\n", ovt); }
#endif

  virtual void pup(PUP::er &p) { 
    p(ovt); p(ort); p(myHandle); p(anti_methods); p(prand48_seed,3);
  }
#ifdef SEQUENTIAL_POSE
  void checkpoint(rep *) { }
  void restore(rep *) { }
#endif  
  void POSE_srand(unsigned int pseed) { prand_seed = pseed; }
  int POSE_rand() { 
    int rnum; 
    srand(prand_seed); 
    rnum = rand(); 
    prand_seed = rnum+INT_MAX; 
    return rnum; 
  }
  unsigned int POSE_urand() { 
    int rnum; 
    srand(prand_seed); 
    rnum = rand(); 
    prand_seed = rnum+INT_MAX; 
    return prand_seed;
  }
  inline long int POSE_Linear_rand() { return nrand48(prand48_seed); }
  inline double POSE_Uniform_rand() { return erand48(prand48_seed); }

};

#endif

---